| | |
| | | @RestController |
| | | public class CrnController { |
| | | |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | @Value("${wms.movePath}") |
| | | private String movePath; |
| | | |
| | | |
| | | @Autowired |
| | |
| | | private BasCrnErrorMapper basCrnErrorMapper; |
| | | @Autowired |
| | | private BasCrnpService basCrnpService; |
| | | @Autowired |
| | | private MainServiceImpl mainService; |
| | | @Autowired |
| | | private LocMastService locMastService; |
| | | |
| | |
| | | private LocMastService locMastService; |
| | | @Autowired |
| | | private BasCrnErrorService basCrnErrorService; |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | |
| | | |
| | | public static <T> List<T> convertListMapToListObject(List<HashMap<String, Object>> listMap, Class<T> clazz) throws Exception { |
| | | List<T> list = new ArrayList<>(); |
| | |
| | | package com.zy.asrs.controller; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
| | | import com.baomidou.mybatisplus.mapper.Wrapper; |
| | |
| | | import com.zy.asrs.domain.enums.TaskStatusType; |
| | | import com.zy.asrs.entity.LocMast; |
| | | import com.zy.asrs.entity.TaskWrk; |
| | | import com.zy.asrs.service.ApiLogService; |
| | | import com.zy.asrs.service.CommandInfoService; |
| | | import com.zy.asrs.service.LocMastService; |
| | | import com.zy.asrs.service.TaskWrkService; |
| | | import com.zy.common.utils.HttpHandler; |
| | | import com.zy.asrs.service.ToWmsService; |
| | | import com.zy.common.web.BaseController; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import java.util.*; |
| | |
| | | @Slf4j |
| | | public class TaskWrkController extends BaseController { |
| | | |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | |
| | | @Autowired |
| | | private TaskWrkService taskWrkService; |
| | | |
| | | @Autowired |
| | | private CommandInfoService commandInfoService; |
| | | |
| | | @Autowired |
| | | private LocMastService locMastService; |
| | | |
| | | @Value("${wms.taskExecCallback}") |
| | | private String TaskExecCallback; |
| | | |
| | | @Autowired |
| | | private ApiLogService apiLogService; |
| | | private ToWmsService toWmsService; |
| | | |
| | | public static String getTaskType(Integer paramIoType) { |
| | | switch (paramIoType) { |
| | |
| | | locMast.setBarcode(taskWrk.getBarcode()); |
| | | |
| | | } |
| | | String response = ""; |
| | | try { |
| | | HashMap<String, Object> headParam = new HashMap<>(); |
| | | headParam.put("TaskNo", taskWrk.getTaskNo()); |
| | | headParam.put("Result", 1); |
| | | // headParam.put("reportTime",new Date()); |
| | | log.info("wcs手动完成任务上报wms={}", taskWrk); |
| | | response = new HttpHandler.Builder() |
| | | // .setHeaders(headParam) |
| | | .setUri(wmsUrl) |
| | | .setPath(TaskExecCallback) |
| | | .setJson(JSON.toJSONString(headParam)) |
| | | .build() |
| | | .doPost(); |
| | | |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | apiLogService.save("wcs手动完成任务上报wms" |
| | | , wmsUrl + TaskExecCallback |
| | | , null |
| | | , "127.0.0.1" |
| | | , JSON.toJSONString(headParam) |
| | | , response |
| | | , true |
| | | ); |
| | | } catch (Exception e) { |
| | | log.error("wcs手动完成任务上报wms失{},返回值={}", taskWrk, response); |
| | | // throw new CoolException(e); |
| | | } |
| | | toWmsService.addReportLog(taskWrk); |
| | | locMastService.updateById(locMast); |
| | | taskWrk.setStatus(7);//手动完成任务 |
| | | taskWrk.setModiTime(new Date()); |
| | |
| | | } catch (Exception e) { |
| | | taskWrk.setModiUser(9999L);//操作员 |
| | | } |
| | | String response = ""; |
| | | try { |
| | | HashMap<String, Object> headParam = new HashMap<>(); |
| | | headParam.put("TaskNo", taskWrk.getTaskNo()); |
| | | headParam.put("Result", 0); |
| | | // headParam.put("reportTime",new Date()); |
| | | toWmsService.addReportLog(taskWrk); |
| | | |
| | | log.info("wcs手动取消任务上报wm={}", taskWrk); |
| | | response = new HttpHandler.Builder() |
| | | // .setHeaders(headParam) |
| | | .setUri(wmsUrl) |
| | | .setPath(TaskExecCallback) |
| | | .setJson(JSON.toJSONString(headParam)) |
| | | .build() |
| | | .doPost(); |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | apiLogService.save("wcs手动取消任务上报wms" |
| | | , wmsUrl + TaskExecCallback |
| | | , null |
| | | , "127.0.0.1" |
| | | , JSON.toJSONString(headParam) |
| | | , response |
| | | , true |
| | | ); |
| | | } catch (Exception e) { |
| | | log.error("wcs手动取消任务上报wms失败={},返回值={}", taskWrk, response); |
| | | // throw new CoolException(e); |
| | | } |
| | | taskWrk.setCompleteTime(now);//完结时间 |
| | | taskWrkService.updateById(taskWrk); |
| | | return R.ok(); |
| | |
| | | import com.zy.asrs.entity.TaskWrkLog; |
| | | import com.zy.asrs.service.ApiLogService; |
| | | import com.zy.asrs.service.TaskWrkLogService; |
| | | import com.zy.asrs.service.TaskWrkReportService; |
| | | import com.zy.asrs.service.ToWmsService; |
| | | import com.zy.common.utils.HttpHandler; |
| | | import com.zy.common.web.BaseController; |
| | | import lombok.extern.slf4j.Slf4j; |
| | |
| | | @RestController |
| | | public class TaskWrkLogController extends BaseController { |
| | | |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | @Value("${wms.taskExecCallback}") |
| | | private String TaskExecCallback; |
| | | @Autowired |
| | | private ApiLogService apiLogService; |
| | | |
| | | @Autowired |
| | | private TaskWrkLogService taskWrkLogService; |
| | | |
| | | @Autowired |
| | | private ToWmsService toWmsService; |
| | | |
| | | @RequestMapping(value = "/taskWrkLog/{id}/auth") |
| | | @ManagerAuth |
| | |
| | | public R resubmitTheTask(@RequestParam String taskNo) { |
| | | TaskWrkLog taskWrk = taskWrkLogService.selectOne(new EntityWrapper<TaskWrkLog>().eq("task_no", taskNo)); |
| | | if (!Cools.isEmpty(taskWrk)) { |
| | | HashMap<String, Object> headParam = new HashMap<>(); |
| | | if (taskWrk.getStatus().equals(TaskStatusType.OVER.id)) {//完成 |
| | | headParam.put("Result", 1); |
| | | } else if (taskWrk.getStatus().equals(TaskStatusType.CANCEL.id)) { |
| | | headParam.put("Result", 2); |
| | | } |
| | | String response = ""; |
| | | Boolean bool = false; |
| | | try { |
| | | headParam.put("TaskNo", taskWrk.getTaskNo()); |
| | | log.info("重新上报任务完结={}", taskWrk); |
| | | response = new HttpHandler.Builder() |
| | | // .setHeaders(headParam) |
| | | .setUri(wmsUrl) |
| | | .setPath(TaskExecCallback) |
| | | .setJson(JSON.toJSONString(headParam)) |
| | | .build() |
| | | .doPost(); |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | |
| | | if (jsonObject.get("ReturnStatus").equals(0)) { |
| | | bool = true; |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("重新上报任务完结失败{},返回值={}", taskWrk, response); |
| | | } finally { |
| | | apiLogService.save("重新上报任务完结" |
| | | , wmsUrl + TaskExecCallback |
| | | , null |
| | | , "127.0.0.1" |
| | | , JSON.toJSONString(headParam) |
| | | , response |
| | | , bool |
| | | ); |
| | | } |
| | | toWmsService.addReportLog(taskWrk); |
| | | } |
| | | return R.ok(); |
| | | } |
| | |
| | | |
| | | RECEIVE(1, "接收"), |
| | | DISTRIBUTE(2, "派发"), |
| | | COMPLETE(3, "命令完成"), |
| | | //COMPLETE(3, "命令完成"), |
| | | CANCEL(4, "取消"), |
| | | OVER(5, "完结"); |
| | | |
| | |
| | | package com.zy.asrs.service; |
| | | |
| | | import com.zy.asrs.entity.TaskWrk; |
| | | import com.zy.asrs.entity.TaskWrkLog; |
| | | import com.zy.asrs.entity.WrkMast; |
| | | import com.zy.asrs.entity.wms.StorageEscalationParam; |
| | | import com.zy.asrs.entity.wms.WmsResult; |
| | | |
| | |
| | | |
| | | void addReportLog(TaskWrk taskWrk); |
| | | |
| | | void addReportLog(TaskWrkLog taskWrk); |
| | | |
| | | void addReportLog(WrkMast wrkMast); |
| | | |
| | | TaskWrk getLocNoFromWms(StorageEscalationParam wmsParam); |
| | | |
| | | } |
| | |
| | | @Slf4j |
| | | @Service("locMastService") |
| | | public class LocMastServiceImpl extends ServiceImpl<LocMastMapper, LocMast> implements LocMastService { |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | @Autowired |
| | | private ApiLogService apiLogService; |
| | | |
| | | @Override |
| | | public List<Integer> queryDistinctRow(Integer crnNo) { |
| | |
| | | param.setContainerTypeCode(locMast.getContainerTypeCode()); |
| | | } |
| | | |
| | | try { |
| | | response = new HttpHandler.Builder() |
| | | .setHeaders(map) |
| | | .setUri(wmsUrl) |
| | | .setPath("wcsManager/wcsInterface/locationUpdate") |
| | | .setJson(JSON.toJSONString(param)) |
| | | .build() |
| | | .doPost(); |
| | | } catch (Exception e) { |
| | | log.error("堆垛机任务完成,请求wms任务完成接口失败"); |
| | | } |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | |
| | | |
| | | apiLogService.save("Wms变更货位状态" |
| | | , wmsUrl + "wcsManager/wcsInterface/inboundTaskApply" |
| | | , null |
| | | , "127.0.0.1" |
| | | , JSON.toJSONString(param) |
| | | , response |
| | | , true |
| | | ); |
| | | // try { |
| | | // response = new HttpHandler.Builder() |
| | | // .setHeaders(map) |
| | | // .setUri(wmsUrl) |
| | | // .setPath("wcsManager/wcsInterface/locationUpdate") |
| | | // .setJson(JSON.toJSONString(param)) |
| | | // .build() |
| | | // .doPost(); |
| | | // } catch (Exception e) { |
| | | // log.error("堆垛机任务完成,请求wms任务完成接口失败"); |
| | | // } |
| | | // JSONObject jsonObject = JSON.parseObject(response); |
| | | // |
| | | // |
| | | // apiLogService.save("Wms变更货位状态" |
| | | // , wmsUrl + "wcsManager/wcsInterface/inboundTaskApply" |
| | | // , null |
| | | // , "127.0.0.1" |
| | | // , JSON.toJSONString(param) |
| | | // , response |
| | | // , true |
| | | // ); |
| | | |
| | | return null; |
| | | } |
| | |
| | | import com.zy.asrs.mapper.WrkMastMapper; |
| | | import com.zy.asrs.service.*; |
| | | import com.zy.asrs.utils.Utils; |
| | | import com.zy.common.service.CommonService; |
| | | import com.zy.core.CrnThread; |
| | | import com.zy.core.DevpThread; |
| | | import com.zy.core.cache.MessageQueue; |
| | |
| | | import com.zy.core.properties.SlaveProperties; |
| | | import com.zy.core.thread.BarcodeThread; |
| | | import com.zy.core.thread.SiemensDevpThread; |
| | | import com.zy.system.service.ConfigService; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | |
| | | |
| | | @Autowired |
| | | private CommonService commonService; |
| | | |
| | | @Autowired |
| | | private ToWmsService toWmsService; |
| | | |
| | | |
| | | @Autowired |
| | | private CrnController crnController; |
| | | |
| | | @Autowired |
| | | private ConfigService configService; |
| | | |
| | | public void generateStoreWrkFile1() throws IOException, InterruptedException { |
| | | try { |
| | |
| | | package com.zy.asrs.service.impl; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.service.impl.ServiceImpl; |
| | | import com.core.common.Cools; |
| | | import com.core.exception.CoolException; |
| | |
| | | import com.zy.asrs.service.ApiLogService; |
| | | import com.zy.asrs.service.StaDescService; |
| | | import com.zy.asrs.service.TaskWrkService; |
| | | import com.zy.asrs.service.ToWmsService; |
| | | import com.zy.asrs.utils.Utils; |
| | | import com.zy.common.service.CommonService; |
| | | import com.zy.common.utils.HttpHandler; |
| | | import com.zy.core.DevpThread; |
| | | import com.zy.core.cache.MessageQueue; |
| | | import com.zy.core.cache.SlaveConnection; |
| | |
| | | import com.zy.core.model.protocol.StaProtocol; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Propagation; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.Date; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | |
| | | @Slf4j |
| | |
| | | |
| | | @Autowired |
| | | private CommonService commonService; |
| | | |
| | | @Autowired |
| | | private StaDescService staDescService; |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | @Value("${wms.taskStatusFeedbackPath}") |
| | | private String taskStatusFeedbackPath; |
| | | |
| | | |
| | | @Autowired |
| | | private ApiLogService apiLogService; |
| | | |
| | | |
| | | @Autowired |
| | | private ToWmsService toWmsService; |
| | | |
| | | @Override |
| | | public TaskWrk selectByTaskNo(String taskNo) { |
| | |
| | | taskWrk.setCrnNo(staDesc.getCrnNo());//堆垛机号 |
| | | taskWrk.setModiTime(new Date()); |
| | | taskWrk.setModiUser(userId); |
| | | updateById(taskWrk); |
| | | super.updateById(taskWrk); |
| | | |
| | | CrnSlave.CrnStn crnStn = Utils.getCrnStnByStaNo(staDesc.getCrnStn(), true); |
| | | if (crnStn == null) { |
| | |
| | | log.error("堆垛机命令生成失败,堆垛机号={},任务数据={}", taskWrk.getCrnNo(), JSON.toJSON(crnCommand)); |
| | | throw new CoolException("堆垛机命令生成失败"); |
| | | } else { |
| | | try { |
| | | HashMap<String, Object> headParam = new HashMap<>(); |
| | | headParam.put("taskNo", taskWrk.getTaskNo()); |
| | | headParam.put("status", taskWrk.getStatus()); |
| | | headParam.put("ioType", taskWrk.getIoType()); |
| | | headParam.put("barcode", taskWrk.getBarcode()); |
| | | // headParam.put("reportTime",new Date()); |
| | | String response; |
| | | response = new HttpHandler.Builder() |
| | | // .setHeaders(headParam) |
| | | .setUri(wmsUrl) |
| | | .setPath(taskStatusFeedbackPath) |
| | | .setJson(JSON.toJSONString(headParam)) |
| | | .build() |
| | | .doPost(); |
| | | |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | apiLogService.save("wcs派发入库任务上报wms" |
| | | , wmsUrl + taskStatusFeedbackPath |
| | | , null |
| | | , "127.0.0.1" |
| | | , JSON.toJSONString(headParam) |
| | | , response |
| | | , true |
| | | ); |
| | | } catch (Exception e) { |
| | | log.error("wcs派发入库任务上报wms失败", taskWrk); |
| | | // throw new CoolException("wcs派发入库任务上报wms失败"); |
| | | } |
| | | |
| | | toWmsService.addReportLog(taskWrk); |
| | | } |
| | | } |
| | | |
| | |
| | | taskWrk.setCrnNo(staDesc.getCrnNo());//堆垛机号 |
| | | taskWrk.setModiTime(new Date()); |
| | | taskWrk.setModiUser(userId); |
| | | updateById(taskWrk); |
| | | super.updateById(taskWrk); |
| | | |
| | | CrnSlave.CrnStn crnStn = Utils.getCrnStnByStaNo(staDesc.getCrnStn(), false); |
| | | if (crnStn == null) { |
| | |
| | | //taskWrk.setCrnNo(staDesc.getCrnNo());//堆垛机号 |
| | | taskWrk.setModiTime(new Date()); |
| | | taskWrk.setModiUser(userId); |
| | | updateById(taskWrk); |
| | | super.updateById(taskWrk); |
| | | } |
| | | |
| | | @Override |
| | |
| | | import com.core.common.Cools; |
| | | import com.zy.asrs.domain.enums.TaskStatusType; |
| | | import com.zy.asrs.domain.enums.WorkNoType; |
| | | import com.zy.asrs.entity.LocMast; |
| | | import com.zy.asrs.entity.TaskWrk; |
| | | import com.zy.asrs.entity.TaskWrkReport; |
| | | import com.zy.asrs.entity.*; |
| | | import com.zy.asrs.entity.wms.StorageEscalationParam; |
| | | import com.zy.asrs.entity.wms.WmsResult; |
| | | import com.zy.asrs.service.*; |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void addReportLog(TaskWrkLog taskWrk) { |
| | | TaskWrkReport taskWrkReport = new TaskWrkReport(); |
| | | Synchro.Copy(taskWrk, taskWrkReport); |
| | | taskWrkReport.setCreateTime(new Date()); |
| | | taskWrkReportService.insert(taskWrkReport); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public void addReportLog(WrkMast taskWrk) { |
| | | TaskWrkReport taskWrkReport = new TaskWrkReport(); |
| | | Synchro.Copy(taskWrk, taskWrkReport); |
| | | taskWrkReport.setCreateTime(new Date()); |
| | | taskWrkReportService.insert(taskWrkReport); |
| | | } |
| | | |
| | | @Override |
| | | public TaskWrk getLocNoFromWms(StorageEscalationParam wmsParam) { |
| | | String response = ""; |
| | | Boolean success = false; |
| | |
| | | if (!Cools.isEmpty(response)) { |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | if (!Cools.isEmpty(jsonObject.get(code)) && jsonObject.get(code).equals(successCode)) { |
| | | //有些三方wms系统不能及时返回库位号,这时候就需要 |
| | | //ZWmsResult result = JSON.parseObject(jsonObject.get(data).toString(), WmsResult.class); |
| | | TaskWrk taskWrk = null; |
| | | int i = 1; |
| | | while (i < 10) { |
| | | taskWrk = taskWrkService.selectByBarcode(wmsParam.getBarcode()); |
| | | if (taskWrk != null) { |
| | | break; |
| | | } |
| | | try { |
| | | i++; |
| | | Thread.sleep(500L); |
| | | } catch (InterruptedException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | return taskWrk; |
| | | WmsResult result = JSON.parseObject(jsonObject.get(data).toString(), WmsResult.class); |
| | | return createInTask(result, wmsParam.getBarcode(), wmsParam.getStationCode()); |
| | | } |
| | | } |
| | | } catch (IOException e) { |
| | |
| | | |
| | | @Autowired |
| | | private WrkMastService wrkMastService; |
| | | |
| | | @Autowired |
| | | private LocMastService locMastService; |
| | | @Autowired |
| | | private WaitPakinService waitPakinService; |
| | | |
| | | @Autowired |
| | | private WrkMastLogService wrkMastLogService; |
| | | |
| | | @Autowired |
| | | private WrkDetlLogService wrkDetlLogService; |
| | | @Autowired |
| | | private WrkDetlService wrkDetlService; |
| | | @Autowired |
| | | private ApiLogService apiLogService; |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | @Value("${wms.inboundTaskApplyPath}") |
| | | private String inboundTaskApplyPath; |
| | | @Value("${wms.movePath}") |
| | | private String movePath; |
| | | @Value("${wms.taskStatusFeedbackPath}") |
| | | private String taskStatusFeedbackPath; |
| | | private ToWmsService toWmsService; |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | @Override |
| | | @Transactional |
| | |
| | | HashMap<String, Object> headParam = new HashMap<>(); |
| | | headParam.put("TaskNo", wrkMast.getTaskNo()); |
| | | headParam.put("Result", 0);//完成 |
| | | toWmsService.addReportLog(wrkMast); |
| | | |
| | | try { |
| | | String response; |
| | | log.error("wcs手动完结任务上报wms={}", wrkMast); |
| | | |
| | | response = new HttpHandler.Builder() |
| | | // .setHeaders(headParam) |
| | | .setUri(wmsUrl) |
| | | .setPath(taskStatusFeedbackPath) |
| | | .setJson(JSON.toJSONString(headParam)) |
| | | .build() |
| | | .doPost(); |
| | | apiLogService.save("wcs手动完成任务上报wms" |
| | | , wmsUrl + taskStatusFeedbackPath |
| | | , null |
| | | , "127.0.0.1" |
| | | , JSON.toJSONString(headParam) |
| | | , response |
| | | , true |
| | | ); |
| | | } catch (Exception e) { |
| | | log.error("wcs手动完结任务上报wms失败={}", wrkMast); |
| | | log.error("wcs手动完结任务上报wms失败,报错信息:", e); |
| | | // throw new CoolException("wcs派发入库任务上报wms失败"); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | |
| | | HashMap<String, Object> headParam = new HashMap<>(); |
| | | headParam.put("TaskNo", wrkMast.getTaskNo()); |
| | | headParam.put("Result", 1);//取消 |
| | | toWmsService.addReportLog(wrkMast); |
| | | |
| | | try { |
| | | String response; |
| | | log.error("wcs手动取消任务上报wms={}", wrkMast); |
| | | |
| | | response = new HttpHandler.Builder() |
| | | // .setHeaders(headParam) |
| | | .setUri(wmsUrl) |
| | | .setPath(taskStatusFeedbackPath) |
| | | .setJson(JSON.toJSONString(headParam)) |
| | | .build() |
| | | .doPost(); |
| | | apiLogService.save("wcs手动取消任务上报wms" |
| | | , wmsUrl + taskStatusFeedbackPath |
| | | , null |
| | | , "127.0.0.1" |
| | | , JSON.toJSONString(headParam) |
| | | , response |
| | | , true |
| | | ); |
| | | } catch (Exception e) { |
| | | log.error("wcs手动取消任务上报wms失败={}", wrkMast); |
| | | log.error("wcs手动取消任务上报wms失败,报错信息:", e); |
| | | // throw new CoolException("wcs派发入库任务上报wms失败"); |
| | | } |
| | | } |
| | | } |
| | |
| | | private String TaskExecCallback; |
| | | |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | //@Scheduled(cron = "0/3 * * * * ? ") |
| | | public void execute() throws IOException { |
| | | Page<TaskWrkReport> taskWrkReportPage = taskWrkReportService.selectPage(new Page<>(0, 100), new EntityWrapper<TaskWrkReport>().orderBy("createTime", true)); |
| | | Page<TaskWrkReport> taskWrkReportPage = taskWrkReportService.selectPage(new Page<>(0, 100), new EntityWrapper<TaskWrkReport>().orderBy("create_time", true)); |
| | | if (taskWrkReportPage.getRecords() != null) { |
| | | //新增一个过滤机制 |
| | | for (TaskWrkReport taskWrk : taskWrkReportPage.getRecords()) { |
| | |
| | | private CrnSlave slave; |
| | | private CrnProtocol crnProtocol; |
| | | private boolean resetFlag = false; |
| | | @Value("${wms.url}") |
| | | private String wmsUrl; |
| | | |
| | | |
| | | |
| | | public SiemensCrnThread(CrnSlave slave) { |
| | |
| | | "height": 706, |
| | | "stns": [{ |
| | | "type": "stn", |
| | | "id": "site-103", |
| | | "text": "103", |
| | | "top": 99, |
| | | "left": 771, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | | "type": "stn", |
| | | "id": "site-102", |
| | | "text": "102", |
| | | "top": 99, |
| | | "left": 771, |
| | | "left": 705, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-101", |
| | | "text": "101", |
| | | "top": 99, |
| | | "left": 705, |
| | | "left": 639, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | | "type": "stn", |
| | | "id": "site-106", |
| | | "text": "106", |
| | | "top": 160, |
| | | "left": 771, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-105", |
| | | "text": "105", |
| | | "top": 160, |
| | | "left": 771, |
| | | "left": 705, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-104", |
| | | "text": "104", |
| | | "top": 160, |
| | | "left": 705, |
| | | "left": 639, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | | "type": "stn", |
| | | "id": "site-109", |
| | | "text": "109", |
| | | "top": 231, |
| | | "left": 771, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-108", |
| | | "text": "108", |
| | | "top": 231, |
| | | "left": 771, |
| | | "left": 705, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-107", |
| | | "text": "107", |
| | | "top": 231, |
| | | "left": 705, |
| | | "left": 639, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | | "type": "stn", |
| | | "id": "site-112", |
| | | "text": "112", |
| | | "top": 304, |
| | | "left": 771, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-111", |
| | | "text": "111", |
| | | "top": 304, |
| | | "left": 771, |
| | | "left": 705, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-110", |
| | | "text": "110", |
| | | "top": 304, |
| | | "left": 705, |
| | | "left": 639, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | | "type": "stn", |
| | | "id": "site-115", |
| | | "text": "115", |
| | | "top": 460, |
| | | "left": 771, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-114", |
| | | "text": "114", |
| | | "top": 460, |
| | | "left": 771, |
| | | "left": 705, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-113", |
| | | "text": "113", |
| | | "top": 460, |
| | | "left": 705, |
| | | "left": 639, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-210", |
| | | "text": "210", |
| | | "top": 510, |
| | | "left": 1050, |
| | | "left": 950, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-211", |
| | | "text": "211", |
| | | "top": 535, |
| | | "left": 1050, |
| | | "left": 950, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-212", |
| | | "text": "212", |
| | | "top": 560, |
| | | "left": 1050, |
| | | "left": 950, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | | "type": "stn", |
| | | "id": "site-214", |
| | | "text": "214", |
| | | "top": 560, |
| | | "left": 1016, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "height": 23 |
| | | },{ |
| | | "type": "stn", |
| | | "id": "site-209", |
| | | "text": "209", |
| | | "top": 560, |
| | | "left": 1216, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | | "type": "stn", |
| | | "id": "site-201", |
| | | "text": "201", |
| | | "top": 510, |
| | | "left": 1250, |
| | | "left": 1350, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-202", |
| | | "text": "202", |
| | | "top": 535, |
| | | "left": 1250, |
| | | "left": 1350, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | "id": "site-203", |
| | | "text": "203", |
| | | "top": 560, |
| | | "left": 1250, |
| | | "left": 1350, |
| | | "width": 62, |
| | | "height": 23 |
| | | },{ |
| | |
| | | <script type="text/javascript" src="../../static/wms/js/common.js" charset="utf-8"></script> |
| | | <script type="text/javascript" src="../../static/wms/js/cool.js" charset="utf-8"></script> |
| | | <!--地图json--> |
| | | <script src="../../static/wcs/js/console.map.js"></script> |
| | | <script src="../../static/wcs/js/console.js"></script> |
| | | <script src="../../static/wcs/js/common.js"></script> |
| | | <script src="../../static/wcs/js/console.map.js?v=1"></script> |
| | | <script src="../../static/wcs/js/console.js?v=1"></script> |
| | | <script src="../../static/wcs/js/common.js?v=1"></script> |
| | | </head> |
| | | <script type="text/html" id="errorTpl"> |
| | | {{# if( d.error === false ){ }} |