| | |
|---|
| | | sv.addOrUpdateOftenUseIntake(dto.getOperator(), dto.getIntakeId()) ; |
|---|
| | | //开阀成功，虚拟卡记录上标记已被占用 |
|---|
| | | sv.setVcUsed(vcPo.getId(), dto.getIntakeId()); |
|---|
| | | //记录开阀命令，以备远程关阀 |
|---|
| | | RmCommandOpen comOpen = sv.getCommandOpen(dto.getIntakeId()); |
|---|
| | | if(comOpen == null){ |
|---|
| | | RmCommandOpen po = newRmCommandOpen(comId, ctrlPo.getProtocol(), ComCode, comName, dto.getIntakeId(), ctrlPo.getRtuAddr(), vcPo.getVcNum(), orderNo, dto.getOperator()) ; |
|---|
| | | sv.saveCommandOpen(po); |
|---|
| | | }else{ |
|---|
| | | setRmCommandOpen(comOpen, comId, ctrlPo.getProtocol(), ComCode, comName, dto.getIntakeId(), ctrlPo.getRtuAddr(), vcPo.getVcNum(), orderNo, dto.getOperator()) ; |
|---|
| | | sv.updateCommandOpen(comOpen); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //记录开阀命令，以备远程关阀 |
|---|
| | | RmCommandOpen comOpen = sv.getCommandOpen(dto.getIntakeId()); |
|---|
| | | if(comOpen == null){ |
|---|
| | | RmCommandOpen po = newRmCommandOpen(comId, ctrlPo.getProtocol(), ComCode, comName, dto.getIntakeId(), ctrlPo.getRtuAddr(), vcPo.getVcNum(), orderNo, dto.getOperator()) ; |
|---|
| | | sv.saveCommandOpen(po); |
|---|
| | | }else{ |
|---|
| | | setRmCommandOpen(comOpen, comId, ctrlPo.getProtocol(), ComCode, comName, dto.getIntakeId(), ctrlPo.getRtuAddr(), vcPo.getVcNum(), orderNo, dto.getOperator()) ; |
|---|
| | | sv.updateCommandOpen(comOpen); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | @Override |
|---|
| | | public void call(Object... objs) { |
|---|
