| package com.zy.asrs.wms.apis.wcs.schedule;  | 
|   | 
| import com.alibaba.fastjson.JSON;  | 
| import com.alibaba.fastjson.JSONObject;  | 
| import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;  | 
| import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;  | 
| import com.fasterxml.jackson.core.JsonProcessingException;  | 
| import com.fasterxml.jackson.databind.ObjectMapper;  | 
| import com.fasterxml.jackson.databind.cfg.CoercionAction;  | 
| import com.fasterxml.jackson.databind.cfg.CoercionInputShape;  | 
| import com.zy.asrs.framework.exception.CoolException;  | 
| import com.zy.asrs.wms.apis.wcs.entity.domain.SystemProperties;  | 
| import com.zy.asrs.wms.apis.wcs.entity.request.ConveyorStarParam;  | 
| import com.zy.asrs.wms.apis.wcs.entity.request.PublishTasksParam;  | 
| import com.zy.asrs.wms.apis.wcs.entity.request.TaskDescribe;  | 
| import com.zy.asrs.wms.apis.wcs.entity.request.TaskParam;  | 
| import com.zy.asrs.wms.apis.wcs.entity.response.CommonReponse;  | 
| import com.zy.asrs.wms.asrs.entity.*;  | 
| import com.zy.asrs.wms.asrs.entity.dto.OrderOutMergeDto;  | 
| import com.zy.asrs.wms.asrs.entity.enums.LocStsType;  | 
| import com.zy.asrs.wms.asrs.entity.enums.TaskStsType;  | 
| import com.zy.asrs.wms.asrs.service.*;  | 
| import com.zy.asrs.wms.asrs.service.impl.LocServiceImpl;  | 
| import com.zy.asrs.wms.utils.Utils;  | 
| import lombok.extern.slf4j.Slf4j;  | 
| import org.springframework.beans.factory.annotation.Autowired;  | 
| import org.springframework.http.HttpEntity;  | 
| import org.springframework.http.HttpHeaders;  | 
| import org.springframework.http.HttpMethod;  | 
| import org.springframework.http.ResponseEntity;  | 
| import org.springframework.jdbc.datasource.DataSourceTransactionManager;  | 
| import org.springframework.scheduling.annotation.Scheduled;  | 
| import org.springframework.stereotype.Component;  | 
| import org.springframework.transaction.annotation.Transactional;  | 
| import org.springframework.util.LinkedMultiValueMap;  | 
| import org.springframework.util.MultiValueMap;  | 
| import org.springframework.web.client.RestTemplate;  | 
|   | 
| import javax.annotation.Resource;  | 
| import java.util.*;  | 
| import java.util.stream.Collectors;  | 
|   | 
| @Slf4j  | 
| @Component  | 
| public class ScheduleJobs {  | 
|   | 
|     @Autowired  | 
|     private DataSourceTransactionManager transactionManager;  | 
|     @Autowired  | 
|     private TaskService taskService;  | 
|     @Autowired  | 
|     private RestTemplate restTemplate;  | 
|     @Autowired  | 
|     private WorkService workService;  | 
|     @Resource  | 
|     private SystemProperties properties;  | 
|     @Autowired  | 
|     private LocServiceImpl locService;  | 
|     @Autowired  | 
|     private LocDetlService locDetlService;  | 
|     @Autowired  | 
|     private TaskDetlService taskDetlService;  | 
|     @Autowired  | 
|     private LocDetlFieldService locDetlFieldService;  | 
|     @Autowired  | 
|     private TaskDetlFieldService taskDetlFieldService;  | 
|     @Autowired  | 
|     private CacheSiteService cacheSiteService;  | 
|     @Autowired  | 
|     private OperationPortService operationPortService;  | 
|   | 
|     /***  | 
|      * 入库任务---通知ESS输送线流动  | 
|      */  | 
|     @Scheduled(cron = "0/3 * * * * ? ")  | 
|     @Transactional(rollbackFor = Exception.class)  | 
|     public void conveyorStart() {  | 
|         List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()  | 
|                 .eq(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id)  | 
|                 .eq(Task::getStatus, 1));  | 
|         tasks.forEach(task -> {  | 
|             try {  | 
|                 ConveyorStarParam conveyorStarParam = new ConveyorStarParam();  | 
|                 conveyorStarParam.setSlotCode(task.getOriginSite())  | 
|                         .setContainerCode(task.getBarcode())  | 
|                         .setDirection("100");  | 
|                 // 原始报文  | 
|                 log.info("通知ESS输送线流动请求地址:{},请求参数:{}", "http://192.168.2.200:9046/conveyor/moveContainer", JSONObject.toJSONString(conveyorStarParam));  | 
|                 HttpHeaders headers = new HttpHeaders();  | 
|                 headers.add("Content-Type", "application/json");  | 
|                 headers.add("api-version", "v2.0");  | 
|                 HttpEntity httpEntity = new HttpEntity<>(conveyorStarParam, headers);  | 
|                 // 调用三方接口,将任务推送至ESS平台  | 
|                 ResponseEntity<String> exchange = restTemplate.exchange("http://192.168.2.200:9046/conveyor/moveContainer", HttpMethod.POST, httpEntity, String.class);  | 
|                 log.info("下发流动通知 返回结果:{}", exchange);  | 
|                 if (exchange.getBody() == null) {  | 
|                     throw new CoolException("下发流动通知失败!!");  | 
|                 } else {  | 
|                     ObjectMapper objectMapper = new ObjectMapper();  | 
|                     objectMapper.coercionConfigDefaults()  | 
|                             .setCoercion(CoercionInputShape.EmptyString, CoercionAction.AsEmpty);  | 
|                     CommonReponse commonReponse = objectMapper.readValue(exchange.getBody(), CommonReponse.class);  | 
|                     if (commonReponse.getCode() == 0) {  | 
|                         taskService.update(new LambdaUpdateWrapper<Task>()  | 
|                                 .eq(Task::getId, task.getId())  | 
|                                 .set(Task::getTaskSts, TaskStsType.WCS_CONVEYOR_START.id));  | 
|                     } else {  | 
|                         throw new CoolException("下发流动通知失败!!");  | 
|                     }  | 
|                 }  | 
|             } catch (Exception ex) {  | 
|                 log.error(ex.getMessage());  | 
|             }  | 
|         });  | 
|   | 
|     }  | 
|   | 
|     /**  | 
|      * 生成自动盘点任务  | 
|      */  | 
| //    @Scheduled(cron = "0/50 * * * * ?")  | 
| //    @Transactional(rollbackFor = Exception.class)  | 
|     public void genCheckTask() {  | 
|         Loc locs = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocStsId, LocStsType.F.val()).orderByAsc(Loc::getLocNo).last("limit 1"));  | 
|         if (Objects.isNull(locs)) {  | 
|             return;  | 
|         }  | 
|         List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().select(Task::getId).eq(Task::getTaskType, 107L));  | 
|         if (!tasks.isEmpty() && tasks.size() >= 4) {  | 
|             //默认生成四个盘点任务,超过4个,停止生成盘点任务;  | 
|             return;  | 
|         }  | 
|         OperationPort operationPort = operationPortService.getOne(new LambdaQueryWrapper<OperationPort>().last("ORDER BY RAND() LIMIT 1;"));  | 
|         if (operationPort == null || Objects.isNull(operationPort)) {  | 
|             throw new CoolException("作业口不存在");  | 
|         }  | 
|         Task task = new Task();  | 
|         task.setTaskNo(workService.generateTaskNo(TaskStsType.GENERATE_OUT.id));  | 
|         task.setTaskSts(TaskStsType.GENERATE_OUT.id);  | 
|         task.setTaskType(107L); //默认107盘点任务,盘点任务没有,按103处理  | 
|         task.setIoPri(workService.generateIoPri(TaskStsType.GENERATE_OUT.id));  | 
|         task.setOriginLoc(locs.getLocNo());  | 
|         task.setTargetSite(operationPort.getFlag());  | 
|         task.setBarcode(locs.getBarcode());  | 
|   | 
|         if (!taskService.save(task)) {  | 
|             throw new CoolException("任务生成失败!!");  | 
|         }  | 
|   | 
|         List<LocDetl> locDetls = locDetlService.list(new LambdaQueryWrapper<LocDetl>().eq(LocDetl::getLocId, locs.getId()));  | 
|         if (locDetls.isEmpty()) {  | 
|             throw new CoolException("明细不存在!!");  | 
|         }  | 
|   | 
|         for (LocDetl locDetl : locDetls) {  | 
|             TaskDetl taskDetl = new TaskDetl();  | 
|             taskDetl.sync(locDetl);  | 
|             taskDetl.setId(null);  | 
|             taskDetl.setTaskId(task.getId());  | 
|             taskDetl.setTaskNo(task.getTaskNo());  | 
|             taskDetl.setAnfme(locDetl.getAnfme());  | 
|             taskDetl.setStock(locDetl.getAnfme());  | 
|             taskDetl.setWaveId(null);  | 
|             taskDetl.setWaveNo(null);  | 
|             taskDetl.setOrderId(null);  | 
|             taskDetl.setOrderNo(null);  | 
|             if (!taskDetlService.save(taskDetl)) {  | 
|                 throw new CoolException("保存工作档明细失败");  | 
|             }  | 
|   | 
|             List<LocDetlField> locDetlFields = locDetlFieldService.list(new LambdaQueryWrapper<LocDetlField>().eq(LocDetlField::getDetlId, locDetl.getId()));  | 
|             for (LocDetlField locDetlField : locDetlFields) {  | 
|                 TaskDetlField taskDetlField = new TaskDetlField();  | 
|                 taskDetlField.sync(locDetlField);  | 
|                 taskDetlField.setId(null);  | 
|                 taskDetlField.setDetlId(taskDetl.getId());  | 
|                 if (!taskDetlFieldService.save(taskDetlField)) {  | 
|                     throw new CoolException("明细扩展生成失败");  | 
|                 }  | 
|             }  | 
|         }  | 
|   | 
|         if (!locService.update(new LambdaUpdateWrapper<Loc>().eq(Loc::getId, locs.getId())  | 
|                 .set(Loc::getUpdateTime, new Date())  | 
|                 .set(Loc::getLocStsId, LocStsType.R.val()))) {  | 
|             throw new CoolException("库位状态修改失败!!");  | 
|         }  | 
|     }  | 
|   | 
|     /***  | 
|      * 入库任务---下发入库任务  | 
|      * 每隔3秒,刷新当前通知档列表,下发待入库订单至ESS  | 
|      * 查询当前任务列表,  | 
|      */  | 
|     @Scheduled(cron = "0/3 * * * * ? ")  | 
|     @Transactional(rollbackFor = Exception.class)  | 
|     public void waitPakinSchedule() throws JsonProcessingException {  | 
|         //获取当前任务档中,所有为待入库状态的任务档,按时间升序排列  | 
|         List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()  | 
| //                        .eq(Task::getTaskType, 1)  | 
|                         .eq(Task::getTaskSts, TaskStsType.GENERATE_IN.id))  | 
|                 .stream().sorted(Comparator.comparing(Task::getTaskSts))  | 
|                 .collect(Collectors.toList());  | 
|         if (tasks.size() == 0) {  | 
|             return;  | 
|         }  | 
|   | 
|         // 数据组装  | 
|         PublishTasksParam tasksParam = new PublishTasksParam();  | 
|         //TODO 确认是否需要单任务多容器码的需求,目前系统都是单容器码生成单任务,多任务明细(物料混装)  | 
|         tasks.forEach(task -> {  | 
|             List<TaskParam> params = new ArrayList<>();  | 
|             TaskParam param = new TaskParam();  | 
|             param.setTaskCode(task.getTaskNo());  | 
|   | 
|             // 处理库位映射  | 
|             String[] parts = task.getTargetLoc().split("-");  | 
|             String formatLocNo = String.format("A-%03d-%03d-%02d",  | 
|                     Integer.parseInt(parts[0]),  | 
|                     Integer.parseInt(parts[1]),  | 
|                     Integer.parseInt(parts[2]));  | 
|             TaskDescribe describe = new TaskDescribe();  | 
|             //设置目标库位,站点  | 
|             describe.setContainerCode(task.getBarcode())  | 
|                     .setToLocationCode(formatLocNo)  | 
|                     .setToStationCode(task.getTargetSite());  | 
|   | 
|             param.setTaskDescribe(describe);  | 
|             params.add(param);  | 
|             tasksParam.setTasks(params);  | 
|         });  | 
|   | 
|         tasksParam.setTaskType("putaway");  | 
|         // TODO 多任务多订单,统一调度,是否会出现部分成功,部分失败的情况  | 
|         log.info("下发入库任务请求地址:{},请求参数:{}", "http://192.168.2.200:9046/task/create", JSONObject.toJSONString(tasksParam));  | 
|         HttpHeaders headers = new HttpHeaders();  | 
|         headers.add("Content-Type", "application/json");  | 
|         headers.add("api-version", "v2.0");  | 
|         HttpEntity httpEntity = new HttpEntity<>(tasksParam, headers);  | 
|         // 请求  | 
|         ResponseEntity<String> exchange = restTemplate.exchange("http://192.168.2.200:9046/task/create", HttpMethod.POST, httpEntity, String.class);  | 
|         log.info("下发任务 返回结果:{}", exchange);  | 
|         if (exchange.getBody() == null) {  | 
|             throw new CoolException("下发任务失败!!");  | 
|         } else {  | 
|             ObjectMapper objectMapper = new ObjectMapper();  | 
|             CommonReponse reponse = objectMapper.readValue(exchange.getBody(), CommonReponse.class);  | 
|             if (reponse.getCode() == 0) {  | 
|                 //  请求成功后,统一修改所有任务档状态为入库执行中。  | 
|                 tasks.forEach(task -> {  | 
|                     taskService.update(new LambdaUpdateWrapper<Task>()  | 
|                             .set(Task::getTaskSts, TaskStsType.WCS_EXECUTE_IN.id)  | 
|                             .eq(Task::getBarcode, task.getBarcode()));  | 
|                 });  | 
|             } else {  | 
|                 // TODO 请求失败需确认是否存在部分成功的情况,部分成功需要单独刷新成功的任务档状态  | 
|                 throw new CoolException(reponse.getMsg());  | 
|             }  | 
|         }  | 
|     }  | 
|   | 
|   | 
|     /**  | 
|      * //fixme 弃用  | 
|      * 出库任务---通知容器流动  | 
|      * 每隔3秒,获取当前出库任务列表状态为COMPLETE_OUT的任务,并通知ESS流动输送线  | 
|      */  | 
| //    @Scheduled(cron = "0/5 * * * * ? ")  | 
|     @Transactional(rollbackFor = Exception.class)  | 
|     public void conveyorToNotify() {  | 
|         List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()  | 
|                 .eq(Task::getTaskSts, TaskStsType.WCS_EXECUTE_OUT_CONVEYOR.id).eq(Task::getStatus, 1));  | 
|   | 
|         // 还需要再修改  | 
|         tasks.forEach(task -> {  | 
| //            try {  | 
| //                ConveyorStarParam conveyorStarParam = new ConveyorStarParam();  | 
| //                conveyorStarParam.setSlotCode(task.getOriginLoc())  | 
| //                        .setContainerCode(task.getBarcode());  | 
| //                if (task.getTaskType() == 101) { //任务类型为101全盘出库,直接取下容器,传200  | 
| //                    conveyorStarParam.setDirection("200");  | 
| //                } else if (task.getTaskType() == 103) { //如果为任务类型为103,需走回库操作,传100  | 
| //                    conveyorStarParam.setDirection("100");  | 
| //                }  | 
| //                //调用三方接口,将任务推送至ESS平台  | 
| //                MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();  | 
| //                // 设置请求参数  | 
| //                params.add("params", JSONObject.toJSONString(conveyorStarParam));  | 
| //                log.info("请求地址:{},请求参数:{}", Constant.CONVEYOR_START, JSONObject.toJSONString(conveyorStarParam));  | 
| //                HttpHeaders headers = new HttpHeaders();  | 
| //                headers.add("Content-Type", "application/json");  | 
| //                HttpEntity httpEntity = new HttpEntity<>(params, headers);  | 
| //                // 请求  | 
| //                ResponseEntity<String> exchange = restTemplate.exchange(Constant.CONVEYOR_START, HttpMethod.POST, httpEntity, String.class);  | 
| //                log.info("下发流动通知 返回结果:{}", exchange);  | 
| //                if (exchange.getBody() == null) {  | 
| //                    throw new CoolException("下发流动通知失败!!");  | 
| //                } else {  | 
| //                    CommonReponse commonReponse = JSON.toJavaObject(JSON.parseObject(exchange.getBody()), CommonReponse.class);  | 
| //                    if (commonReponse.getCode() == 0) {  | 
|             //流动通知下发完成后,修改任务状态为输送线流动中。。  | 
| //                        taskService.update(new LambdaUpdateWrapper<Task>()  | 
| //                                .eq(Task::getId, task.getId())  | 
| //                                .set(Task::getTaskSts, TaskStsType.COMPLETE_OUT.id));  | 
|   | 
| //                        log.info(task.getTaskNo() + "下发流动通知" + commonReponse.getMsg());  | 
| //                    } else {  | 
| //                        throw new CoolException("下发流动通知失败!!");  | 
| //                    }  | 
| //                }  | 
| //            } catch (Exception ex) {  | 
| //                log.error(ex.getMessage());  | 
| //            } finally {  | 
| //                //如果异常修改禁用状态  | 
| //                taskService.update(new LambdaUpdateWrapper<Task>().set(Task::getStatus, 0)  | 
| //                        .set(Task::getUpdateTime, new Date())  | 
| //                        .eq(Task::getId, task.getId()));  | 
| //            }  | 
|         });  | 
|     }  | 
|   | 
|   | 
|     /**  | 
|      * 出库任务--- 每隔3秒,获取当前出库任务列表状态为GENERATE_OUT的任务,下发任务至ESS  | 
|      * //TODO  出库任务分两种:  | 
|      * //TODO 1. 正常出库后,清除任务,  | 
|      * //TODO 2. 出库后还有库存,需要添加容器回库操作  | 
|      */  | 
|     @Scheduled(cron = "0/3 * * * * ? ")  | 
|     @Transactional(rollbackFor = Exception.class)  | 
|     public void waveToTask() throws JsonProcessingException {  | 
|         //获取当前任务档中,所有为待出库状态的任务档,按时间升序排列  | 
|         List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()  | 
|                 .ge(Task::getTaskType, 101) //TODO 如何确认是101,还是103  | 
|                 .eq(Task::getTaskSts, TaskStsType.GENERATE_OUT.id));  | 
|         if (tasks.isEmpty()) {  | 
|             return;  | 
|         }  | 
| //        tasks.stream().sorted(Comparator.comparing(Task::getTaskSts))  | 
| //                .collect(Collectors.toList());  | 
|   | 
|         // 数据组装  | 
|         PublishTasksParam tasksParam = new PublishTasksParam();  | 
|         List<TaskParam> params = new ArrayList<>();  | 
|         //TODO 确认是否需要单任务多容器码的需求,目前系统都是单容器码生成单任务,多任务明细(物料混装)  | 
|         tasks.forEach(task -> {  | 
|             TaskParam param = new TaskParam();  | 
|             //设置容器编码  | 
|             param.setTaskCode(task.getTaskNo());  | 
|             TaskDescribe describe = new TaskDescribe();  | 
|             //设置目标库位,站点  | 
|             describe.setContainerCode(task.getBarcode())  | 
|                     .setToLocationCode(task.getTargetLoc())  | 
|                     .setToStationCode(task.getTargetSite());  | 
|             param.setTaskDescribe(describe);  | 
|             params.add(param);  | 
|         });  | 
|         tasksParam.setTasks(params);  | 
|         tasksParam.setTaskType("carry");  | 
|         log.info("出库任务下发请求地址:{},请求参数:{}", properties.getBaseHost() + properties.getEssReceiveTask(), JSONObject.toJSONString(tasksParam));  | 
|         HttpHeaders headers = new HttpHeaders();  | 
|         headers.add("Content-Type", "application/json");  | 
|         HttpEntity httpEntity = new HttpEntity<>(tasksParam, headers);  | 
|         // 请求  | 
|         ResponseEntity<String> exchange = restTemplate.exchange(properties.getBaseHost() + properties.getEssReceiveTask(), HttpMethod.POST, httpEntity, String.class);  | 
|         log.info("出库任务下发 返回结果:{}", exchange);  | 
|         if (exchange.getBody() == null) {  | 
|             throw new CoolException("下发任务失败!!");  | 
|         } else {  | 
|             ObjectMapper objectMapper = new ObjectMapper();  | 
|             CommonReponse reponse = objectMapper.readValue(exchange.getBody(), CommonReponse.class);  | 
|             if (reponse.getCode() == 0) {  | 
|                 //请求成功后,统一修改所有任务档状态为入库执行中。  | 
|                 tasks.forEach(task -> {  | 
|                     taskService.update(new LambdaUpdateWrapper<Task>()  | 
|                             .set(Task::getTaskSts, TaskStsType.WCS_EXECUTE_OUT.id)  | 
|                             .eq(Task::getId, task.getId()));  | 
|                 });  | 
|             } else {  | 
|                 // TODO 请求失败需确认是否存在部分成功的情况,部分成功需要单独刷新成功的任务档状态  | 
|                 throw new CoolException(reponse.getMsg());  | 
|             }  | 
|         }  | 
|     }  | 
| }  |