From 368b3db6778e5b14105c348d188c322e1aed1a71 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 01 三月 2021 17:06:34 +0800
Subject: [PATCH] #

---
 src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java |   65 ++++++++++++++++++++++++++++++--
 1 files changed, 61 insertions(+), 4 deletions(-)

diff --git a/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java b/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java
index 23e3801..34293ea 100644
--- a/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java
+++ b/src/main/java/zy/cloud/wms/manager/service/impl/WorkServiceImpl.java
@@ -1,9 +1,24 @@
 package zy.cloud.wms.manager.service.impl;
 
-import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.common.Cools;
+import com.core.common.R;
+import com.core.exception.CoolException;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import zy.cloud.wms.common.utils.VersionUtils;
+import zy.cloud.wms.manager.entity.Comb;
+import zy.cloud.wms.manager.entity.LocDetl;
+import zy.cloud.wms.manager.entity.Node;
 import zy.cloud.wms.manager.entity.param.StockInParam;
+import zy.cloud.wms.manager.service.CombService;
+import zy.cloud.wms.manager.service.LocDetlService;
+import zy.cloud.wms.manager.service.NodeService;
 import zy.cloud.wms.manager.service.WorkService;
+
+import java.util.Date;
+import java.util.List;
 
 /**
  * Created by vincent on 2021/2/25
@@ -11,10 +26,52 @@
 @Service("workService")
 public class WorkServiceImpl implements WorkService {
 
+    @Autowired
+    private NodeService nodeService;
+    @Autowired
+    private CombService combService;
+    @Autowired
+    private LocDetlService locDetlService;
 
     @Override
-    public String stockIn(StockInParam param, Long userId) {
-        System.out.println(JSON.toJSONString(param));
-        return null;
+    @Transactional
+    public R stockIn(StockInParam param, Long userId) {
+        Node node = nodeService.selectByUuid(param.getNodeId());
+        if (node == null) {
+            return R.error("璐т綅涓嶅瓨鍦�");
+        }
+        List<Comb> combs = combService.selectList(new EntityWrapper<Comb>().eq("zpallet", param.getZpallet()).eq("io_status", 1));
+        if (Cools.isEmpty(combs)) {
+            return R.error("鐗╂枡涓嶅瓨鍦�");
+        }
+        Date now = new Date();
+        for (Comb comb : combs) {
+            // 鏀瑰彉缁勬墭妗g姸鎬�
+            comb.setIoStatus(4);
+            comb.setUpdateBy(userId);
+            comb.setUpdateTime(now);
+            boolean update = combService.update(comb, new EntityWrapper<Comb>().eq("zpallet", param.getZpallet()).eq("matnr", comb.getMatnr()));
+            if (!update) {
+                throw new CoolException("淇敼鎵樼洏璧勬枡妗eけ璐�");
+            }
+            // 鏇存柊璐т綅搴撳瓨鏄庣粏
+            LocDetl locDetl = new LocDetl();
+            locDetl.setLocNo(node.getName());
+            locDetl.setNodeId(node.getId());
+            locDetl.setZpallet(param.getZpallet());
+            locDetl.setAnfme(comb.getAnfme());
+            VersionUtils.setLocDetl(locDetl, comb);
+            locDetl.setStatus(1);
+            locDetl.setCreateBy(userId);
+            locDetl.setCreateTime(now);
+            locDetl.setUpdateBy(userId);
+            locDetl.setUpdateTime(now);
+            boolean insert = locDetlService.insert(locDetl);
+            if (!insert) {
+                throw new CoolException("鏂板搴撳瓨鏄庣粏妗eけ璐�");
+            }
+        }
+        return R.ok();
     }
+
 }

--
Gitblit v1.9.1