中间件，对于水肥机数据，每条上报数据都进行最新上报数据处理，以备前端界面及时显示水肥机状态。

liurunyu

2025-08-01 6efa476dad8e425ff71c37cd57437c99928cd405

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/pSdV1/TkDealManureSdV1.java

@@ -55,7 +55,7 @@
                        MqttSubMsg msg,
                        ManureVo stVo) throws Exception {
        RmManureHistory hpo = this.saveHistory(sv, stPo, msg, stVo);
        this.saveOrUpdateLast(sv, stPo, msg, stVo, hpo);
        this.saveOrUpdateLast(sv, stPo, msg, stVo, hpo, true);
    }
    /**
     * 处理上行消息数据
@@ -65,11 +65,12 @@
     * @param stVo 上行的设备数据
     * @param hpo 历史记录最新数据
     */
    private void saveOrUpdateLast(DbSv sv,
    protected void saveOrUpdateLast(DbSv sv,
                                  PrStManure stPo,
                                  MqttSubMsg msg,
                                  ManureVo stVo,
                                  RmManureHistory hpo) throws Exception {
                                  RmManureHistory hpo,
                                  boolean sendDingMs) throws Exception {
        RmManureLast po = sv.getRmManureLast(stPo.id) ;
        if(po == null){
            po = new RmManureLast();
@@ -77,7 +78,7 @@
            po.manureId = stPo.id ;
            po.lastHistoryId = hpo==null?null:hpo.id ;
            sv.saveRmManureLast(po) ;
            if(stVo.alarm != null && stVo.alarm == 1){
            if(stVo.alarm != null && stVo.alarm == 1 && sendDingMs){
                this.sendMessage(stPo, msg, stVo);
            }
        }else{
@@ -85,7 +86,7 @@
            po.manureId = stPo.id ;
            po.lastHistoryId = hpo==null?null:hpo.id ;
            sv.updateRmManureLast(po);
            if(stVo.alarm != null && stVo.alarm == 1){
            if(stVo.alarm != null && stVo.alarm == 1 && sendDingMs){
                this.sendMessage(stPo, msg, stVo);
            }
        }