feat:1.新增LMS 生箔缓存位管理。2.新增LMS 空辊缓存位管理。3.ACSToLMS称重完成上报接口。4.手持呼叫-上满下空。5.生箔任务反馈处理。

nl-module-task/nl-module-task-api/src/main/java/cn/code/nl/module/task/enums/AcsTaskTypeEnum.java

@@ -0,0 +1,24 @@
+package cn.code.nl.module.task.enums;
+
+import lombok.Getter;
+
+/**
+ * @author dsh
+ * 2026/7/28
+ */
+@Getter
+public enum AcsTaskTypeEnum {
+
+    AGV_TASK("1","agv任务"),
+    TRUSS_TASK("6","桁架任务");
+
+
+    private String code;
+
+    private String name;
+
+    AcsTaskTypeEnum(String code,String name){
+        this.code = code;
+        this.name = name;
+    }
+}

nl-module-task/nl-module-task-api/src/main/java/cn/code/nl/module/task/enums/TaskOwnerServiceEnum.java

@@ -0,0 +1,23 @@
+package cn.code.nl.module.task.enums;
+
+import lombok.Getter;
+
+/**
+ * @author dsh
+ * 2026/7/29
+ */
+@Getter
+public enum TaskOwnerServiceEnum {
+
+    LMS("LMS","生产业务"),
+    WMS("WMS","仓储业务");
+
+    private String code;
+
+    private String name;
+
+    TaskOwnerServiceEnum(String code,String name){
+        this.code = code;
+        this.name = name;
+    }
+}

nl-module-task/nl-module-task-api/src/main/java/cn/code/nl/module/task/enums/TaskTypeEnum.java

@@ -0,0 +1,24 @@
+package cn.code.nl.module.task.enums;
+
+import lombok.Getter;
+
+/**
+ * @author dsh
+ * 2026/7/30
+ */
+@Getter
+public enum TaskTypeEnum {
+
+    RAW_FOIL_STANDARD_TASK("010101","生箔标准任务"),
+    RAW_FOIL_INSTORAGE_TASK("010102","称重入库任务");
+
+
+    private String code;
+
+    private String name;
+
+    TaskTypeEnum(String code,String name){
+        this.code = code;
+        this.name = name;
+    }
+}

nl-module-task/nl-module-task-server/src/main/java/cn/code/nl/module/task/mq/producer/TaskEventProducer.java

@@ -33,7 +33,8 @@ public class TaskEventProducer {
     public void publishEvent(TaskEventMessage message) {
         message.setEventId(message.getTaskId().toString());
 
-        String destination = message.getOwnerService() + "_" + topic;
+        // ownerService 为大写枚举值（LMS/WMS），topic 配置为小写前缀，RocketMQ topic 大小写敏感，需统一转小写
+        String destination = message.getOwnerService().toLowerCase() + "_" + topic;
         try {
             rocketMQTemplate.syncSend(destination, message);
             log.info("MQ 发送成功, destination={}, taskId={}, eventType={}",

nl-module-task/nl-module-task-server/src/main/java/cn/code/nl/module/task/service/transporttask/TransportTaskServiceImpl.java

@@ -77,7 +77,7 @@ public class TransportTaskServiceImpl implements TransportTaskService {
     @Override
     @LogRecord(type = TASK_INFO,
             subType = TASK_INFO_OPERATE_TYPE,
-            bizNo = "{{_ret}}",
+            bizNo = "{{#_ret}}",
             success = TASK_INFO_CREATE_BY_RPC)
     public Long createTransportTaskByRpc(TransportTaskCreateReqDTO reqDTO) {
         TransportTaskDO task = BeanUtils.toBean(reqDTO, TransportTaskDO.class);