From eb8577aac0f1f7d783ecd067e7eef05e53e7fd10 Mon Sep 17 00:00:00 2001
From: luqingyang <lqy5492@163.com>
Date: 星期五, 27 十月 2023 17:24:26 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java |  204 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 204 insertions(+), 0 deletions(-)

diff --git a/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java
new file mode 100644
index 0000000..5ac7972
--- /dev/null
+++ b/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java
@@ -0,0 +1,204 @@
+package com.consum.base.service;
+
+import com.consum.base.Constants;
+import com.consum.base.core.param.BaseWarehouseParam1;
+import com.consum.base.pojo.LWhFormOutputParam;
+import com.consum.base.util.IdUtil;
+import com.consum.model.po.*;
+import com.iplatform.model.po.S_user_core;
+import com.walker.infrastructure.utils.DateUtils;
+import com.walker.jdbc.service.BaseServiceImpl;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+
+/**
+ * @Description 鍑哄簱鍗�
+ * @Author 鍗㈠簡闃�
+ * @Date 2023/10/27
+ */
+@Slf4j
+@Service
+public class LWhFormOutputServiceImpl extends BaseServiceImpl {
+
+    @Autowired
+    private BaseWarehouseServiceImpl baseWarehouseService;
+    @Autowired
+    private LWhGoodsService lWhGoodsService;
+    @Autowired
+    private LWhProcureModelService lWhProcureModelService;
+    @Autowired
+    private LWhFormOutputCoreService lWhFormOutputCoreService;
+
+//    /**
+//     * @Description 鏂板鍑哄簱鍗�
+//     * @Author 鍗㈠簡闃�
+//     * @Date 2023/10/27
+//     */
+//    public int add(LWhFormOutputParam param, S_user_core currentUser, FinSysTenantUser sysInfo) {
+//        //1.鏂板鍑哄簱鍗曡褰�
+//        LWhFormOutput lWhFormOutput = new LWhFormOutput();
+//        //鍑哄叆搴搃d
+//        long lWhFormOutputId = IdUtil.generateId();
+//        lWhFormOutput.setId(lWhFormOutputId);
+//        Long warehouseId = param.getWarehouseId();
+//        lWhFormOutput.setWarehouseId(warehouseId);
+//        //鏍规嵁浠撳簱id鏌ヨ浠撳簱
+//        BaseWarehouse warehouse = this.baseWarehouseService.getById(warehouseId);
+//        if (warehouse == null) {
+//            log.error("浠撳簱id涓嶅瓨鍦�");
+//            return 0;
+//        }
+//        lWhFormOutput.setWarehouseName(warehouse.getWarehouseName());
+//        lWhFormOutput.setOutputCode(BaseWarehouseParam1.In_OutPutTypeEnum.Fragmentary_Output.getValue()+"");
+//        lWhFormOutput.setOutputName("闆舵槦鍑哄簱");
+//        lWhFormOutput.setAgencyId(Long.valueOf(sysInfo.getTenantId()));
+//        lWhFormOutput.setAgencyName(sysInfo.getTenantName());
+//        lWhFormOutput.setOperatorId(sysInfo.getId());
+//        lWhFormOutput.setOperatorName(sysInfo.getUserName());
+//        long dateTimeNumber = DateUtils.getDateTimeNumber(System.currentTimeMillis());
+//        lWhFormOutput.setDealTime(dateTimeNumber);
+//        lWhFormOutput.setStates(1);
+//        int flag1 = this.insert(lWhFormOutput);
+//
+//        //2.鏍规嵁鍑哄簱鍗曞嚭搴�
+//        Long lWarehouseFlowId = this.lWhFormOutputCoreService.outFormByTransId(lWhFormOutput.getId(), currentUser, dateTimeNumber);
+//        //3.鍚戝嚭搴撳崟 鎻掑叆 杩涘嚭搴撴祦姘存�昏〃ID
+//        int flag3 = 0;
+//        if (flag1 > 0) {
+//            LWhFormOutput lWhFormOutput1 = new LWhFormOutput(lWhFormOutputId);
+//            lWhFormOutput1.setWarehouseFlowId(lWarehouseFlowId);
+//            flag3 = this.update(lWhFormOutput1);
+//        }
+//
+//        //4.鏂板l_wh_goods_record璁板綍
+//        List<LWhGoodsRecord> recordList = param.getList();
+//        if (CollectionUtils.isEmpty(recordList)) {
+//            log.error("瑙勬牸鍨嬪彿涓虹┖");
+//            return 0;
+//        }
+//        int flag5 = 0;
+//        int number = -1;  //鍑哄簱鍚庯紝鐗╁搧鍓╀綑鏁伴噺
+//        for (LWhGoodsRecord record : recordList) {
+//            //鐗╁搧id鍜岀墿鍝佸悕绉�
+//            record.setBaseGoodsTemplateId(param.getBaseGoodsTemplateId());
+//            record.setGoodsTemplateName(param.getGoodsTemplateName());
+//
+//            record.setId(IdUtil.generateId());
+//            record.setWarehouseId(warehouseId);
+//            //鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨
+//            int goodsNum = this.lWhGoodsService.queryGoodsModelNum(warehouseId, record.getBaseGoodsModelsId(), (short) 1, null);
+//            record.setInitialCount(goodsNum);
+//            record.setThisType(2);
+//
+//            //鍒ゆ柇鍑哄簱鏁伴噺鏄惁灏忎簬搴撳瓨
+//            number = goodsNum - record.getThisCount();
+//            if (number < 0) {
+//                log.error("搴撳瓨涓嶈冻");
+//                break;
+//            }
+//            record.setEndCount(number);
+//            record.setDealTime(dateTimeNumber);
+//            record.setWarehouseFlowId(lWarehouseFlowId);
+//
+//            //5.鏂板L_WH_PROCURE_MODEL璁板綍
+//            LWhProcureModel lWhProcureModel = new LWhProcureModel();
+//            lWhProcureModel.setId(IdUtil.generateId());
+//            lWhProcureModel.setBusinessType(3);
+//            lWhProcureModel.setBaseGoodsModelsId(record.getBaseGoodsModelsId());
+//            lWhProcureModel.setCounts(record.getThisCount());
+//            lWhProcureModel.setWorehouseCount(goodsNum);
+//            int res = this.lWhProcureModelService.insert(lWhProcureModel);
+//            flag5 += res;
+//        }
+//        //濡傛灉鍑哄簱鍚庯紝鍓╀綑搴撳瓨澶т簬0锛屾柊澧瀕_wh_goods_record璁板綍
+//        int flag4 = 0;
+//        if (number >= 0){
+//            flag4 = this.lWhGoodsService.insert(recordList);
+//        }
+//
+//        //濡傛灉鏈変竴鏉¤褰曟柊澧炲け璐ワ紝鍒欏洖婊�
+//        if (flag1 == 0 || flag3 == 0 || flag4 != recordList.size() || flag5 != recordList.size() || number < 0) {
+//            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+//            return 0;
+//        }
+//
+//        return 1;
+//    }
+
+    /**
+     * @Description 鏂板鍑哄簱鍗�
+     * @Author 鍗㈠簡闃�
+     * @Date 2023/10/27
+     */
+    public int add(LWhFormOutputParam param, S_user_core currentUser, FinSysTenantUser sysInfo) {
+        //1.鏂板鍑哄簱鍗曡褰�
+        LWhFormOutput lWhFormOutput = new LWhFormOutput();
+        //鍑哄叆搴搃d
+        long lWhFormOutputId = IdUtil.generateId();
+        lWhFormOutput.setId(lWhFormOutputId);
+        Long warehouseId = param.getWarehouseId();
+        lWhFormOutput.setWarehouseId(warehouseId);
+        //鏍规嵁浠撳簱id鏌ヨ浠撳簱
+        BaseWarehouse warehouse = this.baseWarehouseService.getById(warehouseId);
+        if (warehouse == null) {
+            log.error("浠撳簱id涓嶅瓨鍦�");
+            return 0;
+        }
+        lWhFormOutput.setWarehouseName(warehouse.getWarehouseName());
+        lWhFormOutput.setOutputCode(BaseWarehouseParam1.In_OutPutTypeEnum.Fragmentary_Output.getValue() + "");
+        lWhFormOutput.setOutputName("闆舵槦鍑哄簱");
+        lWhFormOutput.setAgencyId(Long.valueOf(sysInfo.getTenantId()));
+        lWhFormOutput.setAgencyName(sysInfo.getTenantName());
+        lWhFormOutput.setOperatorId(sysInfo.getId());
+        lWhFormOutput.setOperatorName(sysInfo.getUserName());
+        long dateTimeNumber = DateUtils.getDateTimeNumber(System.currentTimeMillis());
+        lWhFormOutput.setDealTime(dateTimeNumber);
+        lWhFormOutput.setStates(1);
+        int flag1 = this.insert(lWhFormOutput);
+
+        //4.鏂板l_wh_goods_record璁板綍
+        List<LWhGoodsRecord> recordList = param.getList();
+        if (CollectionUtils.isEmpty(recordList)) {
+            log.error("瑙勬牸鍨嬪彿涓虹┖");
+            return 0;
+        }
+        int flag5 = 0;
+        for (LWhGoodsRecord record : recordList) {
+            //鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨
+            int goodsNum = this.lWhGoodsService.queryGoodsModelNum(warehouseId, record.getBaseGoodsModelsId(), (short) 1, null);
+
+            //5.鏂板L_WH_PROCURE_MODEL璁板綍
+            LWhProcureModel lWhProcureModel = new LWhProcureModel();
+            lWhProcureModel.setId(IdUtil.generateId());
+            lWhProcureModel.setBusinessType(3);
+            lWhProcureModel.setBaseGoodsModelsId(record.getBaseGoodsModelsId());
+            lWhProcureModel.setCounts(record.getThisCount());
+            lWhProcureModel.setWorehouseCount(goodsNum);
+            int res = this.lWhProcureModelService.insert(lWhProcureModel);
+            flag5 += res;
+        }
+
+        //2.鏍规嵁鍑哄簱鍗曞嚭搴�
+        Long lWarehouseFlowId = this.lWhFormOutputCoreService.outFormByTransId(lWhFormOutput.getId(), currentUser, dateTimeNumber);
+        //3.鍚戝嚭搴撳崟 鎻掑叆 杩涘嚭搴撴祦姘存�昏〃ID
+        int flag3 = 0;
+        if (flag1 > 0) {
+            LWhFormOutput lWhFormOutput1 = new LWhFormOutput(lWhFormOutputId);
+            lWhFormOutput1.setWarehouseFlowId(lWarehouseFlowId);
+            flag3 = this.update(lWhFormOutput1);
+        }
+
+        //濡傛灉鏈変竴鏉¤褰曟柊澧炲け璐ワ紝鍒欏洖婊�
+        if (flag1 == 0 || flag3 == 0 || flag5 != recordList.size()) {
+            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+            return 0;
+        }
+
+        return 1;
+    }
+}

--
Gitblit v1.9.1