优化

wms-module-system/src/main/java/top/wms/admin/materialProcess/mapper/MaterialProcessMapper.java

@@ -19,4 +19,6 @@ public interface MaterialProcessMapper extends BaseMapper<MaterialProcessDO> {
     void updateByName(@Param("list") List<MaterialProcessDO> updateByNameList);
 
     void updateByCode(@Param("list") List<MaterialProcessDO> updateByCodeList);
+
+    String getCodeByMaterial(@Param("materialCode") String materialCode);
 }

wms-module-system/src/main/resources/mapper/MaterialProcessMapper.xml

@@ -59,4 +59,11 @@
             #{item.processCode}
         </foreach>
     </update>
+
+    <select id="getCodeByMaterial" resultType="java.lang.String">
+        SELECT process_code
+        FROM sys_material_process p
+        left join sys_material_info m on p.id = m.material_process_id
+        WHERE m.encoding = #{materialCode}
+    </select>
 </mapper>

wms-webapi/src/main/java/top/wms/admin/controller/vm/VmCommandController.java

@@ -1,5 +1,6 @@
 package top.wms.admin.controller.vm;
 
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson2.JSONObject;
 import io.netty.channel.Channel;
 import lombok.extern.slf4j.Slf4j;
@@ -8,6 +9,7 @@ import org.springframework.web.bind.annotation.*;
 import top.continew.starter.core.validation.CheckUtils;
 import top.wms.admin.controller.tcp.config.SimpleRequestMatcher;
 import top.wms.admin.controller.tcp.manager.ChannelManager;
+import top.wms.admin.materialProcess.mapper.MaterialProcessMapper;
 
 @Slf4j
 @RestController
@@ -20,10 +22,16 @@ public class VmCommandController {
     @Autowired
     private SimpleRequestMatcher requestMatcher;
 
+    @Autowired
+    private MaterialProcessMapper materialProcessMapper;
+
     @PostMapping("/send")
     public String sendAndWait(@RequestBody JSONObject js) {
         String msg = js.getString("msg");
-        log.info("开始比对: {}", msg);
+        log.info("开始比对物料编码: {}", msg);
+        String processCode = materialProcessMapper.getCodeByMaterial(msg);
+        log.info("物料流程编码: {}", processCode);
+        CheckUtils.throwIf(StrUtil.isBlank(processCode), "未查询到物料流程编码");
 
         // 1. 检查连接
         Channel channel = channelManager.getFirstChannel();