2024-01-16 朱宝民 合并代码

Administrator

2024-01-16 8ed16da7d96f1b0b954d75c20ea5177d23ad9eaf

2024-01-16 朱宝民 合并代码

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoPr/PrControllerMapper.java

@@ -5,7 +5,6 @@
import com.dy.pipIrrGlobal.voPr.VoController;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.security.access.method.P;

import java.util.List;
import java.util.Map;
@@ -50,21 +49,15 @@
     * @param rtuAddr
     * @return
     */
    List<Map<String, Object>> getControllersByCode(@Param("rtuAddr") String rtuAddr);
    List<Map<String, Object>> getControllersByAddr(@Param("rtuAddr") String rtuAddr);

    /**
     * 根据控制器编号获取控制器列表
     * @param rtuAddr
     * @return
     */
    List<PrController> getControllersByRtuAddr(@Param("rtuAddr") String rtuAddr);
    //List<PrController> getControllersByRtuAddr(@Param("rtuAddr") String rtuAddr);

    /**
     * 根据控制器编号获取控制器列表
     * @param rtuAddr
     * @return
     */
    List<PrController> getControllersByRtuAddr(@Param("rtuAddr") String rtuAddr);

    /**
     * 根据控制器编号逻辑删除控制

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

@@ -1,5 +1,7 @@
package com.dy.aceMw.server.rtuData;

import java.text.ParseException;

public interface Task {
    
    
@@ -14,7 +16,7 @@
     * 执行节点任务
     * @param data 需要处理的数据
     */
    public void execute(Object data) ;
    public void execute(Object data) throws ParseException;
    
    /**
     * 得到本任务节点处理产生的中间结果，以供本节点所在树枝的下级任务节点及本树枝的左侧（根在上）所有树枝的节点应用本结果

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

@@ -3,6 +3,8 @@
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.text.ParseException;

/**
 * 部分实现Task
 */
@@ -26,7 +28,7 @@
     * @param data 需要处理的数据
     */
    @Override
    public abstract void execute(Object data) ;
    public abstract void execute(Object data) throws ParseException;
    
    /**
     * 任务采用对象池，以便重用任务对象，

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

@@ -4,10 +4,15 @@
import com.dy.aceMw.server.rtuData.dbSv.DbSv;
import com.dy.common.mw.protocol.Data;
import com.dy.common.springUtil.SpringContextUtil;
import com.dy.common.util.DateTime;
import com.dy.pipIrrGlobal.pojoPr.PrController;
import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;

public class TkPreGenObjs extends TaskSurpport {
    
@@ -21,7 +26,8 @@
     * @param data 需要处理的数据
     */
    @Override
    public void execute(Object data) {
    public void execute(Object data) throws ParseException {
        DateFormat fmt =new SimpleDateFormat(("yyyy_MM_dd_HH_mm_ss"));
        Data d = (Data)data ;
        String rtuAddr = d.getRtuAddr() ;//TkRtuData里判断了rtuAddr为空
        DbSv sv = (DbSv)SpringContextUtil.getBean(DbSv.class) ;
@@ -31,11 +37,11 @@
                //数据库中未查询到控制器（RTU实体）
                //流浪者控制器
                PrControllerTramp rtuTramp = sv.getPrControllerTrampByRtuAddr(rtuAddr);
                //if(rtuTramp == null){
                //    rtuTramp = new PrControllerTramp(null, rtuAddr, d.getProtocol(), DateTime.yyyy_MM_dd_HH_mm_ss()) ;
                //    this.taskResult = new Object[]{sv, null, rtuTramp} ;
                //    this.toNextOneTask(data, TkDealControllerTramp.taskId);
                //}
                if(rtuTramp == null){
                    rtuTramp = new PrControllerTramp(null, rtuAddr, d.getProtocol(), fmt.parse(DateTime.yyyy_MM_dd_HH_mm_ss())) ;
                    this.taskResult = new Object[]{sv, null, rtuTramp} ;
                    this.toNextOneTask(data, TkDealControllerTramp.taskId);
                }
            }
            //不论是否为流浪控制器（RTU实体），都要进行下步工作
            this.taskResult = new Object[]{sv, controller, null} ;