| | |
|---|
| | | package com.dy.rtuMw.server.rtuData.p206V202404; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol.Data; |
|---|
| | | import com.dy.common.mw.protocol.UpComResVo; |
|---|
| | | import com.dy.common.mw.protocol.p206V202404.DataV202404; |
|---|
| | | import com.dy.common.util.DateTime; |
|---|
| | | import com.dy.pipIrrGlobal.pojoRm.RmCommandHistory; |
|---|
| | | import com.dy.rtuMw.server.rtuData.TaskSurpport; |
|---|
| | | import com.dy.rtuMw.server.rtuData.dbSv.DbSv; |
|---|
| | | import org.apache.logging.log4j.LogManager; |
|---|
| | | import org.apache.logging.log4j.Logger; |
|---|
| | | |
|---|
| | |
|---|
| | | if(protocolData != null){ |
|---|
| | | DataV202404 dV202404 = (DataV202404)protocolData ; |
|---|
| | | if(dV202404 != null) { |
|---|
| | | // if (dV1 != null && dV1.dataCdC0Vo != null) { |
|---|
| | | // Object[] objs = this.getTaskResults(TkPreGenObjs.taskId) ; |
|---|
| | | // DbSv sv = (DbSv)objs[0] ; |
|---|
| | | // PrController controller = (PrController)objs[1] ; |
|---|
| | | // try{ |
|---|
| | | // this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), dV1, dV1.dataCdC0Vo) ; |
|---|
| | | // this.saveHistory(sv, controller, d.getRtuAddr(),dV1, dV1.dataCdC0Vo) ; |
|---|
| | | // }catch (Exception e){ |
|---|
| | | // log.error("保存控制器自报数据时发生异常", e); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | Object[] objs = this.getTaskResults(TkPreGenObjsV202404.taskId); |
|---|
| | | DbSv sv = (DbSv) objs[0]; |
|---|
| | | //PrController controller = (PrController) objs[1]; |
|---|
| | | try{ |
|---|
| | | RmCommandHistory po = sv.getCommandLog(d.commandId) ; |
|---|
| | | if(po != null){ |
|---|
| | | po = this.updateCommandLogPo(po, d.code, dV202404, dV202404.subData) ; |
|---|
| | | sv.updateCommandLog(po); |
|---|
| | | }else{ |
|---|
| | | log.error("未得到命令日志（" + d.getCommandId() + ")"); |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | log.error("保存控制器自报数据时发生异常", e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public RmCommandHistory updateCommandLogPo(RmCommandHistory po, String code, DataV202404 dV202404, Object obj) throws Exception{ |
|---|
| | | po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV202404.dt==null?DateTime.yyyy_MM_dd_HH_mm_ss():dV202404.dt)); |
|---|
| | | if(obj instanceof UpComResVo){ |
|---|
| | | UpComResVo vo = (UpComResVo)obj ; |
|---|
| | | po.setResult((byte)1); |
|---|
| | | po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code)); |
|---|
| | | log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code))); |
|---|
| | | } |
|---|
| | | return po ; |
|---|
| | | } |
|---|
| | | } |
|---|
