| | |
|---|
| | | if (jsonObject.getInteger("code").equals(200)) { |
|---|
| | | basDevp.setReportSign(1); |
|---|
| | | basDevpService.updateById(basDevp); |
|---|
| | | StartupDto dto = jsonObject.getObject("data", StartupDto.class); |
|---|
| | | |
|---|
| | | // 更新站点信息 且 下发plc命令 |
|---|
| | | staProtocol.setWorkNo(dto.getWorkNo()); |
|---|
| | | staProtocol.setStaNo(607); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(5, staProtocol)); |
|---|
| | | if (!result) { |
|---|
| | | throw new CoolException("更新plc站点信息失败"); |
|---|
| | | } |
|---|
| | | // StartupDto dto = jsonObject.getObject("data", StartupDto.class); |
|---|
| | | // |
|---|
| | | // // 更新站点信息 且 下发plc命令 |
|---|
| | | // staProtocol.setWorkNo(dto.getWorkNo()); |
|---|
| | | // staProtocol.setStaNo(607); |
|---|
| | | // devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | // boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(5, staProtocol)); |
|---|
| | | // if (!result) { |
|---|
| | | // throw new CoolException("更新plc站点信息失败"); |
|---|
| | | // } |
|---|
| | | } else { |
|---|
| | | log.error("请求接口失败！！！url：{}；request：{}；response：{}", wmsUrl + "/rpc/pakin/loc/v1", JSON.toJSONString(param), response); |
|---|
| | | } |
|---|
| | |
|---|
| | | if (!Cools.isEmpty(wrkMast)){ |
|---|
| | | staProtocol607.setWorkNo(wrkMast.getWrkNo()); |
|---|
| | | staProtocol607.setStaNo(staNo1); |
|---|
| | | boolean result2 = MessageQueue.offer(SlaveType.Devp, 2, new Task(5, staProtocol607)); |
|---|
| | | boolean result2 = MessageQueue.offer(SlaveType.Devp, 2, new Task(2, staProtocol607)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else { |
|---|
