| | |
|---|
| | | for (DevpSlave.Sta sta : devp.getTakeSta()) { |
|---|
| | | // 根据输送线plc遍历 |
|---|
| | | Map<Integer, StaProtocol> stationMap = stationService.getStationMap(devp.getId()); |
|---|
| | | StaProtocol staProtocol = stationMap.get(sta.getSourceStaNo()); |
|---|
| | | StaProtocol staProtocol = stationMap.get(sta.getStaNo()); |
|---|
| | | if (staProtocol == null) { |
|---|
| | | continue; |
|---|
| | | } else { |
|---|
| | |
|---|
| | | jobByJobNo.setJobSts(ConveyorStateType.SENDTASK.getStatus()); |
|---|
| | | jobByJobNo.setRcsTime(new Date()); |
|---|
| | | jobService.updateById(jobByJobNo); |
|---|
| | | staProtocol.setWorkNo(staProtocol.getWorkNo()); |
|---|
| | | staProtocol.setStaNo(sta.getStaNo()); |
|---|
| | | redis.push(RedisConveyorConstant.CONVEYOR_TASK_FLAG, staProtocol); |
|---|
| | | // staProtocol.setWorkNo(staProtocol.getWorkNo()); |
|---|
| | | // staProtocol.setStaNo(sta.getStaNo()); |
|---|
| | | // redis.push(RedisConveyorConstant.CONVEYOR_TASK_FLAG, staProtocol); |
|---|
| | | News.error("{},任务发送给RCS成功,WMS任务号：{},输送线工作号：{}", config.getMark(), jobByJobNo.getTaskNo(), jobByJobNo.getJobNo()); |
|---|
| | | } else { |
|---|
| | | News.error("{},任务发送给RCS失败,WMS任务号：{},输送线工作号：{}", config.getMark(), jobByJobNo.getTaskNo(), jobByJobNo.getJobNo()); |
|---|
