| | |
| | | for (CacheSite cacheSite:cacheSites) {
|
| | | // 获取任务明细数量
|
| | | List<TaskDetl> taskDetlByTaskId = taskDetlService.getTaskDetlByTaskId(task.getId());
|
| | | double sum = taskDetlByTaskId.stream().mapToDouble(TaskDetl::getAnfme).sum();
|
| | | int sum = (int)taskDetlByTaskId.stream().mapToDouble(TaskDetl::getAnfme).sum();
|
| | | SlapLightControlParam slapLightControlParam = new SlapLightControlParam();
|
| | | slapLightControlParam
|
| | | .setControllerCode(cacheSite.getMemo())
|
| | | .setTagCode(cacheSite.getSiteNo())
|
| | | .setColor("GREEN")
|
| | | .setIndex(cacheSite.getIndex())
|
| | | .setMode("LIGHT")
|
| | | .setDisplay(String.valueOf(sum));
|
| | | .setDisplay(sum + "");
|
| | | // 发起亮灯请求
|
| | | log.info("任务{}到达拣选位,播种墙亮灯下发",task.getTaskNo(), JSONObject.toJSONString(slapLightControlParam));
|
| | | CommonReponse response = HttpEssUtils.post("到达拣选位,播种墙亮灯", HttpEssUtils.PLT_SEND_COMMAND, slapLightControlParam);
|
| | |
| | | public R slapLightLogic(Map<String, Object> request) {
|
| | | String taskNo = request.get("taskNo").toString();
|
| | | String orderNo = request.get("orderNo").toString();
|
| | |
|
| | | String siteNo = Objects.isNull(request.get("siteNo")) ? null : request.get("siteNo").toString();
|
| | | List<CacheSite> performs = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderNo, orderNo));
|
| | | if (Objects.isNull(performs.stream().findFirst().get().getPlatformId())) {
|
| | | throw new CoolException("请打印明细,并绑定目标集货区");
|
| | |
| | | // }).collect(Collectors.toList());
|
| | |
|
| | | //判断数量是否与订单明细的需求量相同,相同则订单完成
|
| | | if (one.getPickStatus() == OrderPickStatus.ORDER_PICK_STATUS_DONE.val) {
|
| | | //播种完成,释放绑定站点
|
| | | List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderNo, orderNo));
|
| | | for (CacheSite cacheSite : cacheSites) {
|
| | | if (!cacheSite.getSiteStatus().equals(CacheSiteStatusType.O.id)) {
|
| | | cacheSite.setSiteStatus(CacheSiteStatusType.O.id);
|
| | | cacheSite.setOrderId(null);
|
| | | cacheSite.setBarcode(null);
|
| | | cacheSite.setOrderNo(null);
|
| | | cacheSite.setPlatformId(null);
|
| | | cacheSite.setPlatformNo(null);
|
| | | cacheSite.setUpdateTime(new Date());
|
| | | if (!cacheSiteService.updateById(cacheSite)) {
|
| | | throw new CoolException("播种站点更新失败");
|
| | | }
|
| | | //播种完成,释放绑定站点
|
| | | List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>()
|
| | | .eq(!Objects.isNull(siteNo), CacheSite::getSiteNo, siteNo)
|
| | | .eq(CacheSite::getOrderNo, orderNo));
|
| | | for (CacheSite cacheSite : cacheSites) {
|
| | | if (!cacheSite.getSiteStatus().equals(CacheSiteStatusType.O.id)) {
|
| | | cacheSite.setSiteStatus(CacheSiteStatusType.O.id);
|
| | | cacheSite.setOrderId(null);
|
| | | cacheSite.setBarcode(null);
|
| | | cacheSite.setOrderNo(null);
|
| | | cacheSite.setPlatformId(null);
|
| | | cacheSite.setPlatformNo(null);
|
| | | cacheSite.setUpdateTime(new Date());
|
| | | if (!cacheSiteService.updateById(cacheSite)) {
|
| | | throw new CoolException("播种站点更新失败");
|
| | | }
|
| | | }
|
| | | }
|