From c70b92da60c0d00625da5fc2369b475e69e0b88e Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期四, 22 八月 2024 11:36:41 +0800 Subject: [PATCH] 1、完善代码和application.yml配置文件,去掉不用的引入文件; 2、init-config.xml配置中增加属性 enable,相应解析类也增加了解析与判断; 3、凡是有Server的应用,加载资源方式改为用springboot的工具类加载; 4、通信协议相关的扫描注解功能实现改为采用reflections-0.10.2,以实现可以在jar包情况下能够扫描类(.class)注解。 --- pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkRtuDealCommandResponse.java | 95 ++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 81 insertions(+), 14 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkRtuDealCommandResponse.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkRtuDealCommandResponse.java index 9e80709..1c5f8aa 100644 --- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkRtuDealCommandResponse.java +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/p206V1_0_0/TkRtuDealCommandResponse.java @@ -2,10 +2,7 @@ import com.dy.common.mw.protocol.Data; import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1; -import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd92Vo; -import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd93Vo; -import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd97Vo; -import com.dy.common.mw.protocol.p206V1_0_0.upVos.DataCd98Vo; +import com.dy.common.mw.protocol.p206V1_0_0.upVos.*; import com.dy.common.util.DateTime; import com.dy.pipIrrGlobal.pojoRm.RmCommandHistory; import com.dy.rtuMw.server.rtuData.TaskSurpport; @@ -43,7 +40,7 @@ try{ RmCommandHistory po = sv.getCommandLog(d.commandId) ; if(po != null){ - po = this.updateCommandLogPo(po, dV1_0_1, dV1_0_1.subData) ; + po = this.updateCommandLogPo(po, d.code, dV1_0_1, dV1_0_1.subData) ; sv.updateCommandLog(po); }else{ log.error("鏈緱鍒板懡浠ゆ棩蹇楋紙" + d.getCommandId() + ")"); @@ -55,27 +52,97 @@ } } - public RmCommandHistory updateCommandLogPo(RmCommandHistory po, DataV1_0_1 dV1_0_1, Object obj) throws Exception{ + public RmCommandHistory updateCommandLogPo(RmCommandHistory po, String code, DataV1_0_1 dV1_0_1, Object obj) throws Exception{ + po.setResult((byte)1); + po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ; if(obj instanceof DataCd97Vo){ DataCd97Vo vo = (DataCd97Vo)obj ; - po.setResult((byte)1); - po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ; po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); }else if(obj instanceof DataCd98Vo){ DataCd98Vo vo = (DataCd98Vo)obj ; - po.setResult((byte)1); - po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)); po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); }else if(obj instanceof DataCd92Vo){ DataCd92Vo vo = (DataCd92Vo)obj ; - po.setResult((byte)1); - po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ; po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); }else if(obj instanceof DataCd93Vo){ DataCd93Vo vo = (DataCd93Vo)obj ; - po.setResult((byte)1); - po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ; po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd3AAnd6AVo){ + DataCd3AAnd6AVo vo = (DataCd3AAnd6AVo)obj ; + po.setResultText(vo.comLog(code)); + log.info("----------------------------------\n" + vo.comLog(code)); + }else if(obj instanceof DataCd3BAnd6BVo){ + DataCd3BAnd6BVo vo = (DataCd3BAnd6BVo)obj ; + po.setResultText(vo.comLog(code)); + log.info("----------------------------------\n" + vo.comLog(code)); + }else if(obj instanceof DataCd3BAnd6BVo){ + DataCd3CAnd65Vo vo = (DataCd3CAnd65Vo)obj ; + po.setResultText(vo.comLog(code)); + log.info("----------------------------------\n" + vo.comLog(code)); + }else if(obj instanceof DataCd3DVo){ + DataCd3DVo vo = (DataCd3DVo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd3EVo){ + DataCd3EVo vo = (DataCd3EVo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd5EVo){ + DataCd5EVo vo = (DataCd5EVo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd6CVo){ + DataCd6CVo vo = (DataCd6CVo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd10Vo){ + DataCd10Vo vo = (DataCd10Vo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd21Vo){ + DataCd21Vo vo = (DataCd21Vo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd36Vo){ + DataCd36Vo vo = (DataCd36Vo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd37And67Vo){ + DataCd37And67Vo vo = (DataCd37And67Vo)obj ; + po.setResultText(vo.comLog(code)); + log.info("----------------------------------\n" + vo.comLog(code)); + }else if(obj instanceof DataCd38And68Vo){ + DataCd38And68Vo vo = (DataCd38And68Vo)obj ; + po.setResultText(vo.comLog(code)); + log.info("----------------------------------\n" + vo.comLog(code)); + }else if(obj instanceof DataCd39And69Vo){ + DataCd39And69Vo vo = (DataCd39And69Vo)obj ; + po.setResultText(vo.comLog(code)); + log.info("----------------------------------\n" + vo.comLog(code)); + }else if(obj instanceof DataCd51Vo){ + DataCd51Vo vo = (DataCd51Vo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd66Vo){ + DataCd66Vo vo = (DataCd66Vo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd71Vo){ + DataCd71Vo vo = (DataCd71Vo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCd99Vo){ + DataCd99Vo vo = (DataCd99Vo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); + }else if(obj instanceof DataCdA0Vo){ + DataCdA0Vo vo = (DataCdA0Vo)obj ; + po.setResultText(vo.comLog()); + log.info("----------------------------------\n" + vo.comLog()); } return po ; } -- Gitblit v1.8.0