Merge remote-tracking branch 'origin/master'

Administrator

2024-03-27 b8e8696b61f4a896b16269157e7b85aa7b590009

 pipIrr-platform/pipIrr-mw/pipIrr-mw-accept/src/main/java/com/dy/aceMw/server/rtuData/p206V1_0_0/TkDealCloseValveReport.java

@@ -43,7 +43,7 @@
                DbSv sv = (DbSv)objs[0] ;
                PrController controller = (PrController)objs[1] ;
                try{
                    this.dealSave(sv, controller, d.getRtuAddr(), dV1_0_1, dV1_0_1.dataCd83CloseVo) ;
                    this.doDeal(sv, controller, d.getRtuAddr(), dV1_0_1, dV1_0_1.dataCd83CloseVo) ;
                }catch (Exception e){
                    log.error("保存控制器关阀上报时发生异常", e);
                }
@@ -58,7 +58,7 @@
     * @param dV1_0_1 上报数据
     * @param dataCd83CloseVo 关阀上报数据对象
     */
    private void dealSave(DbSv sv, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, DataCd83CloseVo dataCd83CloseVo) throws Exception {
    private void doDeal(DbSv sv, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, DataCd83CloseVo dataCd83CloseVo) throws Exception {
        RmOpenCloseValveLast poLast = sv.getRmOpenCloseValveLast(rtuAddr) ;
        if(poLast == null){
            //首先生成最新数据及历史数据，并先保存历史数据
@@ -72,7 +72,7 @@
            //}else{
                if(poLast.clType == null){
                    //原记录不存在关阀数据，所以当前关阀上报是新的一次关阀，保留原记录开阀数据
                    this.updateCloseValve(poLast, null, dV1_0_1, dataCd83CloseVo, false) ;
                    this.updateCloseValve(controller, poLast, null, dV1_0_1, dataCd83CloseVo, false) ;
                    if(poLast.opType == null){
                        //原记录中不存在开阀数据，没办进行匹配
                        //生成并保存新的关阀上报历史数据记录
@@ -106,7 +106,7 @@
                }else{
                    //if(po.opType == null)
                    //原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理
                    this.updateCloseValve(poLast, null, dV1_0_1, dataCd83CloseVo, false) ;
                    this.updateCloseValve(controller,poLast, null, dV1_0_1, dataCd83CloseVo, false) ;
                    //生成并保存新的关阀上报历史数据记录
                    this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83CloseVo, poLast);
                }
@@ -191,6 +191,7 @@

    /**
     * 更新数据
     * @param controller
     * @param poLast
     * @param poHistory
     * @param dV1_0_1
@@ -198,7 +199,10 @@
     * @param clearOpenValve
     * @throws Exception
     */
    private void updateCloseValve(RmOpenCloseValveLast poLast, RmOpenCloseValveHistory poHistory, DataV1_0_1 dV1_0_1, DataCd83CloseVo dataCd83CloseVo, boolean clearOpenValve) throws Exception {
    private void updateCloseValve(PrController controller, RmOpenCloseValveLast poLast, RmOpenCloseValveHistory poHistory, DataV1_0_1 dV1_0_1, DataCd83CloseVo dataCd83CloseVo, boolean clearOpenValve) throws Exception {
        poLast.controllerId = controller==null?null:controller.getId();
        poLast.intakeId = controller==null?null:controller.getIntakeId();

        poLast.clDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt);
        poLast.clType = dataCd83CloseVo.type;
        poLast.clTotalAmount = dataCd83CloseVo.totalAmount;
@@ -212,6 +216,9 @@
        poLast.closeDt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83CloseVo.closeDt) ;

        if(poHistory != null){
            poHistory.controllerId = controller==null?null:controller.getId();
            poHistory.intakeId = controller==null?null:controller.getIntakeId();

            poHistory.clDt = poLast.clDt;
            poHistory.clType = dataCd83CloseVo.type;
            poHistory.clTotalAmount = dataCd83CloseVo.totalAmount;