package com.zy.api.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; import com.core.common.R; import com.core.exception.CoolException; import com.zy.api.controller.params.ReceviceTaskParams; import com.zy.api.controller.params.StopOutTaskParams; import com.zy.api.controller.params.WorkTaskParams; import com.zy.api.service.WcsApiService; import com.zy.asrs.entity.*; import com.zy.asrs.service.*; import com.zy.asrs.utils.Utils; import com.zy.common.constant.MesConstant; import com.zy.common.service.CommonService; import com.zy.common.utils.HttpHandler; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.io.IOException; import java.util.*; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; @Slf4j @Service public class WcsApiServiceImpl implements WcsApiService { @Autowired private LocMastService locMastService; @Autowired private WrkMastService wrkMastService; @Autowired private WorkService workService; @Autowired private WrkDetlService wrkDetlService; @Autowired private MatService matService; @Autowired private LocDetlService locDetlService; @Value("${wcs.switch}") private String switchValue; @Value("${wcs.address.URL}") private String wcs_address; @Value("${wcs.address.createOutTask}") private String getWcs_address; @Value("${wcs.address.createInTask}") private String createInTask; @Value("${wcs.address.createLocMoveTask}") private String createLocMoveTask; @Value("${wcs.address.stopOutTask}") private String stopOutTask; @Autowired private CommonService commonService; /** * 下发任务至WCS * * @param params * @return com.core.common.R * @author Ryan * @date 2026/1/10 13:58 */ @Override public R pubWrkToWcs(WorkTaskParams params) { if (params == null) { return R.error("参数不能为空!!"); } WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper().eq("wrk_no", params.getTaskNo())); String validateMsg = validatePubTask(params, wrkMast); if (!Cools.isEmpty(validateMsg)) { return R.error(validateMsg); } String url = resolveTaskPath(params); String response; R r = R.ok(); try { log.info("下发搬运任务给wcs="+JSON.toJSONString(params)); response = new HttpHandler.Builder() .setUri(wcs_address) .setPath(url) .setHttps(wcs_address != null && wcs_address.startsWith("https://")) .setTimeout(10, TimeUnit.SECONDS) .setJson(JSON.toJSONString(params)) .build() .doPost(); JSONObject jsonObject = JSON.parseObject(response); log.info("下发任务给wcs的返回值="+response); Integer code = jsonObject.getInteger("code"); if (code==200) { updateWrkMastAfterPublish(wrkMast); //TODO 上报是否成功 }else { r =R.error(); } } catch (IOException e) { throw new RuntimeException(e); } return r; } @Override public R pubWrksToWcs(List paramsList) { if (paramsList == null || paramsList.isEmpty()) { return R.error("任务不能为空!!"); } // 先一次性把本批任务对应的工作档捞出来,避免循环内重复查库。 Map wrkMastMap = getWrkMastMap(paramsList); Map> groupedTasks = new LinkedHashMap<>(); List skipMsgs = new ArrayList<>(); for (WorkTaskParams params : paramsList) { if (params == null) { skipMsgs.add("任务不能为空!!"); continue; } WrkMast wrkMast = wrkMastMap.get(params.getTaskNo()); String validateMsg = validatePubTask(params, wrkMast); if (!Cools.isEmpty(validateMsg)) { skipMsgs.add(buildTaskMsg(params, validateMsg)); continue; } // 分组主键 = 接口路径 + userNo。 // 这样既能保证入库/出库/移库不会混发,也能保证相同 userNo 的任务会打包到同一次 WCS 请求中。 String groupKey = buildBatchGroupKey(params, wrkMast); groupedTasks.computeIfAbsent(groupKey, key -> new ArrayList<>()).add(params); } if (groupedTasks.isEmpty()) { return R.error(skipMsgs.isEmpty() ? "无可下发任务" : skipMsgs.get(0)).add(skipMsgs); } int successCount = 0; List failMsgs = new ArrayList<>(); for (List group : groupedTasks.values()) { if (group == null || group.isEmpty()) { continue; } // 同一组内的任务类型一致,因此取第一条即可确定本组应该调用哪个 WCS 接口。 String path = resolveTaskPath(group.get(0)); Map payload = new HashMap<>(); // WCS 批量下发报文统一使用 {"tasks":[...]} 结构。 payload.put("tasks", buildTaskPayloads(group)); String response = null; try { log.info("批量下发搬运任务给wcs={}", JSON.toJSONString(payload)); response = new HttpHandler.Builder() .setUri(wcs_address) .setPath(path) .setHttps(wcs_address != null && wcs_address.startsWith("https://")) .setTimeout(10, TimeUnit.SECONDS) .setJson(JSON.toJSONString(payload)) .build() .doPost(); JSONObject jsonObject = JSON.parseObject(response == null ? "{}" : response); log.info("批量下发任务给wcs的返回值={}", response); Integer code = jsonObject.getInteger("code"); if (code != null && code == 200) { successCount += group.size(); // 只有整组下发成功,才回写本地工作档状态,避免 WMS/WCS 状态分叉。 for (WorkTaskParams params : group) { updateWrkMastAfterPublish(wrkMastMap.get(params.getTaskNo())); } } else { String msg = jsonObject.getString("msg"); failMsgs.add("path=" + path + ", msg=" + (Cools.isEmpty(msg) ? "WCS下发任务失败" : msg)); log.error("批量下发任务给wcs失败, path:{}, request:{}, response:{}", path, JSON.toJSONString(payload), response); } } catch (IOException e) { failMsgs.add("path=" + path + ", msg=" + e.getMessage()); log.error("批量下发任务给wcs异常, path:{}, request:{}, response:{}", path, JSON.toJSONString(payload), response, e); } } Map result = new HashMap<>(); result.put("successCount", successCount); result.put("skipCount", skipMsgs.size()); result.put("failCount", failMsgs.size()); if (!skipMsgs.isEmpty()) { result.put("skipMsgs", skipMsgs); } if (!failMsgs.isEmpty()) { result.put("failMsgs", failMsgs); } if (successCount == 0) { String msg = !failMsgs.isEmpty() ? failMsgs.get(0) : (skipMsgs.isEmpty() ? "WCS下发任务失败" : skipMsgs.get(0)); return R.error(msg).add(result); } return R.ok(failMsgs.isEmpty() && skipMsgs.isEmpty() ? "操作成功" : "部分任务下发成功").add(result); } /** * 堆垛机执行状态上报 * * @param params * @return com.core.common.R * @author Ryan * @date 2026/1/10 16:30 */ @Override @Transactional(rollbackFor = Exception.class) public R receviceTaskFromWcs(ReceviceTaskParams params) { log.info("wcs任务反馈="+JSON.toJSONString(params)); if (Objects.isNull(params.getSuperTaskNo())) { throw new CoolException("WMS任务号不能为空!!"); } if (Objects.isNull(params.getNotifyType())) { throw new CoolException("动作类型不能为空!!"); } WrkMast mast = wrkMastService.selectOne(new EntityWrapper().eq("wrk_no", params.getSuperTaskNo())); if (Objects.isNull(mast)) { throw new CoolException("任务档不存在!!"); } if (params.getNotifyType().equals("task")) { //任务 if (params.getMsgType().equals("task_complete")) { if (mast.getIoType() == 1 || mast.getIoType() == 2 ||mast.getIoType() == 10) { mast.setWrkSts(4L); } else if ((mast.getIoType() == 101||mast.getIoType()==110) && mast.getWrkSts()<14) { mast.setWrkSts(14L); if(Cools.isEmpty(mast.getStaNo())){ mast.setOveMk("Y"); } } if (!wrkMastService.updateById(mast)) { throw new CoolException("任务状态修改失败!!"); } //wcs任务取消接口 } else if (params.getMsgType().equals("task_cancel")) { workService.cancelWrkMast(String.valueOf(mast.getWrkNo()), 9955L); } else if (params.getMsgType().equals("task_arrive")) { //到达目的地 //如果出库任务是跨区则需要生成新的入库任务入库 if(!Cools.isEmpty(mast.getLocNo())){ mast.setOnlineYn("N");//等待生成跨区入库任务 } mast.setWrkSts(14L); if(Cools.isEmpty(mast.getStaNo())){ mast.setOveMk("Y"); } mast.setModiTime(new Date()); if (!wrkMastService.updateById(mast)) { throw new CoolException("任务状态修改失败!!"); } } } else if (params.getNotifyType().equals("weight")) { } return R.ok(); } private boolean requiresOutboundErpConfirm(WrkMast wrkMast) { Integer ioType = wrkMast == null ? null : wrkMast.getIoType(); return ioType != null && (ioType == 101 || ioType == 103 || ioType == 104 || ioType == 107 || ioType == 110); } /** * 校验单条任务是否满足下发前提。 *

* 这里既校验接口必填项,也校验业务约束,例如: * 1. 出库任务是否被暂停; * 2. 需要 ERP 确认的出库任务是否已确认。 */ private String validatePubTask(WorkTaskParams params, WrkMast wrkMast) { if (params == null) { return "参数不能为空!!"; } if (Cools.isEmpty(params.getTaskNo())) { return "任务号不能为空!!"; } if (Cools.isEmpty(params.getBarcode())) { return "托盘码不能为空!!"; } if (Cools.isEmpty(params.getLocNo())) { return "目标库位不能为空!!"; } if (!Objects.isNull(wrkMast) && "out".equalsIgnoreCase(params.getType())) { if ("Y".equalsIgnoreCase(wrkMast.getPauseMk())) { return "task paused"; } if (requiresOutboundErpConfirm(wrkMast) && !"Y".equalsIgnoreCase(wrkMast.getPdcType())) { return "task not confirmed by erp"; } } return null; } /** * 按任务类型选择 WCS 接口地址。 * in -> 入库接口 * out -> 出库接口 * move -> 移库接口 */ private String resolveTaskPath(WorkTaskParams params) { if (!Objects.isNull(params.getType()) && params.getType().equals("out")) { return getWcs_address; } if (!Objects.isNull(params.getType()) && params.getType().equals("move")) { return createLocMoveTask; } return createInTask; } /** * WCS 下发成功后推进本地工作档状态。 *

* 这里只处理“已下发”这一层状态,不处理设备执行完成状态; * 设备执行完成依然以 WCS 回写为准。 */ private void updateWrkMastAfterPublish(WrkMast wrkMast) { if (Objects.isNull(wrkMast)) { return; } if (wrkMast.getIoType()==1 || wrkMast.getIoType()==10) { wrkMast.setWrkSts(2L); wrkMast.setModiTime(new Date()); wrkMastService.updateById(wrkMast); }else if(wrkMast.getIoType()==2){ wrkMast.setWrkSts(2L); wrkMast.setModiTime(new Date()); wrkMastService.updateById(wrkMast); }else if (wrkMast.getIoType()==101 || wrkMast.getIoType()==110) { wrkMast.setWrkSts(12L); wrkMast.setModiTime(new Date()); wrkMastService.updateById(wrkMast); } } /** * 把本次待下发的 taskNo 批量映射成工作档,供后续校验、按 userNo 分组、状态回写复用。 */ private Map getWrkMastMap(List paramsList) { List taskNos = paramsList.stream() .filter(Objects::nonNull) .map(WorkTaskParams::getTaskNo) .filter(taskNo -> !Cools.isEmpty(taskNo)) .distinct() .collect(Collectors.toList()); if (taskNos.isEmpty()) { return Collections.emptyMap(); } List wrkMasts = wrkMastService.selectList(new EntityWrapper().in("wrk_no", taskNos)); if (wrkMasts == null || wrkMasts.isEmpty()) { return Collections.emptyMap(); } return wrkMasts.stream() .filter(Objects::nonNull) .collect(Collectors.toMap(mast -> String.valueOf(mast.getWrkNo()), mast -> mast, (left, right) -> left, LinkedHashMap::new)); } /** * 构造批量下发的分组键。 *

* 分组规则: * 1. 先按接口路径区分,避免不同任务类型混用同一个 WCS 接口; * 2. 再按 userNo 区分,确保相同 userNo 的任务一起上报。 *

* 正常情况下 userNo 取自 work_mast.user_no; * 如果当前没查到工作档,则回退到请求里的 batch 字段,保证兼容已有调用。 */ private String buildBatchGroupKey(WorkTaskParams params, WrkMast wrkMast) { String path = resolveTaskPath(params); String userNo = wrkMast == null ? null : wrkMast.getUserNo(); if (Cools.isEmpty(userNo)) { userNo = params.getBatch(); } if (Cools.isEmpty(userNo)) { userNo = "_NO_USER_"; } return path + "#" + userNo; } /** * 将一组业务参数转换成 WCS 批量接口的 tasks 数组。 */ private List> buildTaskPayloads(List tasks) { List> payloads = new ArrayList<>(); for (WorkTaskParams task : tasks) { payloads.add(buildTaskPayload(task)); } return payloads; } /** * 组装单条任务的 WCS 请求体。 * 只放当前任务类型实际需要的字段;空字段不透传,避免给 WCS 造成歧义。 */ private Map buildTaskPayload(WorkTaskParams params) { Map task = new LinkedHashMap<>(); if (!Cools.isEmpty(params.getTaskNo())) { task.put("taskNo", params.getTaskNo()); } if (!Cools.isEmpty(params.getLocNo())) { task.put("locNo", params.getLocNo()); } if (!Cools.isEmpty(params.getSourceLocNo())) { task.put("sourceLocNo", params.getSourceLocNo()); } if (!Cools.isEmpty(params.getSourceStaNo())) { task.put("sourceStaNo", params.getSourceStaNo()); } if (!Cools.isEmpty(params.getBarcode())) { task.put("barcode", params.getBarcode()); } if (!Objects.isNull(params.getTaskPri())) { task.put("taskPri", params.getTaskPri()); } if (!Cools.isEmpty(params.getStaNo())) { task.put("staNo", params.getStaNo()); } if (!Cools.isEmpty(params.getBatch())) { task.put("batch", params.getBatch()); } if (!Objects.isNull(params.getBatchSeq())) { task.put("batchSeq", params.getBatchSeq()); } return task; } /** * 构造跳过/失败信息时统一带上 taskNo,便于排查具体是哪一条工作档未被下发。 */ private String buildTaskMsg(WorkTaskParams params, String msg) { if (params == null || Cools.isEmpty(params.getTaskNo())) { return msg; } return "taskNo=" + params.getTaskNo() + ", msg=" + msg; } @Override public R pauseOutTasks(List> params) { if (params == null || params.size() == 0) { return R.ok("无任务需要取消"); } if (!Boolean.parseBoolean(String.valueOf(switchValue))) { return R.ok("WCS开关关闭"); } String response; try { log.info("调用WCS取消出库任务, request={}", JSON.toJSONString(params)); response = new HttpHandler.Builder() .setUri(wcs_address) .setPath(stopOutTask) .setHttps(wcs_address != null && wcs_address.startsWith("https://")) .setTimeout(10, TimeUnit.SECONDS) .setJson(JSON.toJSONString(params)) .build() .doPost(); JSONObject jsonObject = JSON.parseObject(response == null ? "{}" : response); log.info("WCS取消出库任务返回, response={}", response); Integer code = jsonObject.getInteger("code"); if (code == null || !Objects.equals(code, 200)) { String msg = jsonObject.getString("msg"); throw new CoolException(Cools.isEmpty(msg) ? "WCS取消出库任务失败" : msg); } return R.ok(Cools.isEmpty(jsonObject.getString("msg")) ? "操作成功" : jsonObject.getString("msg")); } catch (IOException e) { throw new CoolException("调用WCS取消出库任务失败: " + e.getMessage()); } } }