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