no message

skyouc

2025-07-10 25579b7079f5fab8fc660358644deb5aea633ed2

no message

 zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/controller/OutStockController.java

@@ -26,8 +26,10 @@

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;

@Slf4j
@RestController
@@ -115,18 +117,23 @@
            throw new CoolException("当前站点不存在！！");
        }

        WaveSeed waveSeed = waveSeedService.getOne(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getSiteNo, request.get("tagCode").toString()));
        List<WaveSeed> waveSeed = waveSeedService.list(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getSiteNo, request.get("tagCode").toString()));
        if (Objects.isNull(waveSeed)) {
            throw new CoolException("播种墙地标未绑定！！");
        }

        List<Long> taskIds = waveSeed.stream().map(WaveSeed::getTaskId).collect(Collectors.toList());

        // 根据播种站点信息条码，查任务
        Task task = taskService.getOne(new LambdaQueryWrapper<Task>().eq(Task::getId, waveSeed.getTaskId()));
        if (Objects.isNull(task)) {
        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().in(Task::getId, taskIds));
        if (tasks.isEmpty()) {
            throw new CoolException("当前站点任务不存在！！");
        }

        List<String> taskNos = tasks.stream().map(Task::getTaskNo).collect(Collectors.toList());

        Map<String, Object> param = new HashMap<>();
        param.put("taskNo", task.getTaskNo());
        param.put("taskNo", taskNos);
        param.put("siteNo", cacheSite.getSiteNo());
        param.put("orderNo",cacheSite.getOrderNo());


 zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java

@@ -348,7 +348,7 @@
    @Override

    @Transactional(rollbackFor = Exception.class)

    public R slapLightLogic(Map<String, Object> request) {

        String taskNo = request.get("taskNo").toString();

        List<String> taskNos = (List<String>)request.get("taskNo");

        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));

@@ -359,6 +359,8 @@
        //* 1. 判断当前容器是否还有物料未拣，未拣完闪灯，拣完通知容器流动，并灭灯

        SlapLightControlParam slapParam = new SlapLightControlParam();

        MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();



        taskNos.forEach(taskNo -> {

        //判断当前任务是否还有物料未拣

        if (!checked(orderNo, taskNo)) {

            log.info("未完成闪灯请求地址：{}，请求参数：{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));

@@ -411,7 +413,7 @@
            log.error("执行异常:UNK",  e);

            throw new CoolException(e.getMessage());

        }



        });

        return R.ok();

    }




 zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/entity/CacheSite.java

@@ -155,7 +155,7 @@
        this.siteStatus = siteStatus;

        this.orderId = orderId;

        this.orderNo = orderNo;

//        this.barcode = barcode;

        this.barcode = barcode;

        this.hostId = hostId;

        this.status = status;

        this.deleted = deleted;