| | |
|---|
| | | import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveHistory; |
|---|
| | | import com.dy.pipIrrGlobal.pojoRm.RmOpenCloseValveLast; |
|---|
| | | import com.dy.pipIrrGlobal.pojoSe.SeClient; |
|---|
| | | import com.dy.rtuMw.server.msCenter.MsCenterUnit; |
|---|
| | | import com.dy.rtuMw.server.msCenter.MsObj; |
|---|
| | | import com.dy.rtuMw.server.rtuData.TaskSurpport; |
|---|
| | | import com.dy.rtuMw.server.rtuData.dbSv.DbSv; |
|---|
| | | import org.apache.logging.log4j.LogManager; |
|---|
| | |
|---|
| | | PrController controller = (PrController)objs[1] ; |
|---|
| | | SeClient clientVo = (SeClient)objs[3] ;//这个值对象中只有id和name会有值 |
|---|
| | | try{ |
|---|
| | | this.toMsCenter(clientVo, controller, d.getRtuAddr(), dV1, (DataCd83CloseVo)cdObj) ; |
|---|
| | | this.doDeal(sv, clientVo, controller, d.getRtuAddr(), dV1, (DataCd83CloseVo)cdObj) ; |
|---|
| | | }catch (Exception e){ |
|---|
| | | log.error("保存控制器开阀上报时发生异常", e); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 把开阀消息存入消息中心 |
|---|
| | | * @param clientVo |
|---|
| | | * @param controller |
|---|
| | | * @param rtuAddr |
|---|
| | | * @param dV1 |
|---|
| | | * @param dataCd83CloseVo |
|---|
| | | */ |
|---|
| | | private void toMsCenter(SeClient clientVo, PrController controller, String rtuAddr, DataV1 dV1, DataCd83CloseVo dataCd83CloseVo){ |
|---|
| | | if(clientVo != null && controller != null){ |
|---|
| | | MsObj msObj = new MsObj() ; |
|---|
| | | msObj.put("name", "关阀"); |
|---|
| | | msObj.put("clientId", clientVo.getId()); |
|---|
| | | msObj.put("clientName", clientVo.getName()); |
|---|
| | | msObj.put("clientAddress", clientVo.getAddress()); |
|---|
| | | msObj.put("icCardNo", dataCd83CloseVo.icCardNo); |
|---|
| | | msObj.put("rtuAddr", rtuAddr); |
|---|
| | | msObj.put("intakeId", controller.getIntakeId()); |
|---|
| | | msObj.put("dt", dV1.dt); |
|---|
| | | MsCenterUnit.getInstance().pushMs(msObj); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 保存数据 |
|---|
| | | * @param sv 服务 |
|---|
| | | * @param clientVo 农户对象（不为空时，只有id和name有值） |
|---|
| | | * @param clientVo 农户对象 |
|---|
| | | * @param controller 控制器对象 |
|---|
| | | * @param rtuAddr 控制器地址 |
|---|
| | | * @param dV1 上报数据 |
|---|
