| | |
| | | import com.zy.asrs.entity.CommandInfo; |
| | | import com.zy.asrs.entity.TaskWrk; |
| | | import com.zy.asrs.entity.WaitPakin; |
| | | import com.zy.asrs.entity.param.TaskStatusFeedbackParam; |
| | | import com.zy.asrs.service.CommandInfoService; |
| | | import com.zy.asrs.service.TaskWrkService; |
| | | import com.zy.asrs.utils.PostMesDataUtils; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | |
| | | @Autowired |
| | | private CommandInfoService commandInfoService; |
| | | |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | @Value("${wms.movePath}") |
| | | private String movePath; |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | public void execute() { |
| | | for (TaskWrk taskWrk : taskWrkService.selectToBeHistoryData()) { |
| | | TaskStatusFeedbackParam taskStatusFeedbackParam = new TaskStatusFeedbackParam(taskWrk); |
| | | if (taskWrk.getStatus()==3){ |
| | | taskStatusFeedbackParam.setTaskStatus("done"); |
| | | new PostMesDataUtils().postMesData("完成上报",wmsUrl,movePath,taskWrk); |
| | | }else { |
| | | taskStatusFeedbackParam.setTaskStatus("cancelled"); |
| | | new PostMesDataUtils().postMesData("取消任务完成",wmsUrl,movePath,taskWrk); |
| | | |
| | | } |
| | | if (taskWrkService.saveToHistory(taskWrk.getTaskNo()) > 0) { |
| | | //任务已经转日志,将该任务下面的指令转日志 |
| | | commandInfoService.saveToHistory(taskWrk.getTaskNo()); |