|  |  | 
 |  |  | package com.dy.rtuMw.server.rtuData.p206V1_0_0; | 
 |  |  |  | 
 |  |  | import com.dy.common.mw.protocol.UpComResVo; | 
 |  |  | 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; | 
 |  |  | 
 |  |  |                 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() + ")"); | 
 |  |  |                     } | 
 |  |  |                 }catch (Exception e){ | 
 |  |  |                     log.error("保存控制器自报数据时发生异常", e); | 
 |  |  | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     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.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ; | 
 |  |  |         if(obj instanceof DataCd97Vo){ | 
 |  |  |             DataCd97Vo vo = (DataCd97Vo)obj ; | 
 |  |  |             po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ; | 
 |  |  |             //po.setResultText((JSONObject) JSON.toJSON(vo)); | 
 |  |  |             po.setResultText(vo.toString()); | 
 |  |  |             po.setResult(vo.success?(byte)1:(byte)0); | 
 |  |  |             po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code)); | 
 |  |  |             log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code))); | 
 |  |  |         }else if(obj instanceof DataCd98Vo){ | 
 |  |  |             DataCd98Vo vo = (DataCd98Vo)obj ; | 
 |  |  |             po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)); | 
 |  |  |             //po.setResultText((JSONObject) JSON.toJSON(vo)); | 
 |  |  |             po.setResultText(vo.toString()); | 
 |  |  |             po.setResult(vo.success?(byte)1:(byte)0); | 
 |  |  |             po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code)); | 
 |  |  |             log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code))); | 
 |  |  |         }else if(obj instanceof DataCd92Vo){ | 
 |  |  |             DataCd92Vo vo = (DataCd92Vo)obj ; | 
 |  |  |             po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ; | 
 |  |  |             //po.setResultText((JSONObject) JSON.toJSON(vo)); | 
 |  |  |             po.setResultText(vo.toString()); | 
 |  |  |             po.setResult(vo.success?(byte)1:(byte)0); | 
 |  |  |             po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code)); | 
 |  |  |             log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code))); | 
 |  |  |         }else if(obj instanceof DataCd93Vo){ | 
 |  |  |             DataCd93Vo vo = (DataCd93Vo)obj ; | 
 |  |  |             po.setResultTime(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt)) ; | 
 |  |  |             //po.setResultText((JSONObject) JSON.toJSON(vo)); | 
 |  |  |             po.setResultText(vo.toString()); | 
 |  |  |             po.setResult(vo.success?(byte)1:(byte)0); | 
 |  |  |             po.setResultText(vo.comLog()!=null?vo.comLog():vo.comLog(code)); | 
 |  |  |             log.info("----------------------------------\n" + (vo.comLog()!=null?vo.comLog():vo.comLog(code))); | 
 |  |  |         }else 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 ; | 
 |  |  |     } |