| | |
|---|
| | | |
|---|
| | | BasDevp basDevp = basDevpService.selectOne(new EntityWrapper<BasDevp>().eq("dev_no", staDesc.getCrnStn())); |
|---|
| | | |
|---|
| | | staDesc.getCrnNo(); |
|---|
| | | WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("crn_no", staDesc.getCrnNo()).gt("io_type", 100)); |
|---|
| | | if (!Cools.isEmpty(wrkMast)){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (basDevp.getAutoing().equals("Y") && basDevp.getLoading().equals("N") |
|---|
| | | && basDevp.getWrkNo() == 0 && basDevp.getCanining().equals("Y")){ |
|---|
| | | // 更新站点信息 且 下发plc命令 |
|---|
| | | staProtocol.setWorkNo((short) 9997); |
|---|
| | | // staProtocol.setStaNo(basDevp.getDevNo().shortValue()); |
|---|
| | | staProtocol.setStaNo((short) 1013); |
|---|
| | | staProtocol.setStaNo(basDevp.getDevNo().shortValue()); |
|---|
| | | // staProtocol.setStaNo((short) 1013); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | boolean result = MessageQueue.offer(SlaveType.Devp, devpThread.getSlave().getId(), new Task(2, staProtocol)); |
|---|
| | | if (!result) { |
|---|
