From ccda8b2733a2fabb8c23c062583b1437d6866379 Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期四, 09 十一月 2023 11:47:48 +0800
Subject: [PATCH] feat: 增加查询角色类

---
 consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java |  128 +++++++++++++-----------------------------
 1 files changed, 39 insertions(+), 89 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
index 4ab7093..e79b9e0 100644
--- a/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java
@@ -1,8 +1,9 @@
 package com.consum.base.service;
 
+import com.consum.base.core.CodeGeneratorEnum;
+import com.consum.base.core.CodeGeneratorService;
 import com.consum.base.core.param.BaseWarehouseParam1;
-import com.consum.base.pojo.LWhFormOutputParam;
-import com.consum.base.pojo.LWhProcureModelParams;
+import com.consum.base.pojo.*;
 import com.consum.base.util.IdUtil;
 import com.consum.model.po.*;
 import com.iplatform.model.po.S_user_core;
@@ -30,6 +31,8 @@
 public class LWhFormOutputServiceImpl extends BaseServiceImpl {
 
     @Autowired
+    private CodeGeneratorService codeGeneratorService;
+    @Autowired
     private BaseWarehouseServiceImpl baseWarehouseService;
     @Autowired
     private LWhGoodsService lWhGoodsService;
@@ -37,6 +40,8 @@
     private LWhProcureModelService lWhProcureModelService;
     @Autowired
     private LWhFormOutputCoreService lWhFormOutputCoreService;
+    @Autowired
+    private BaseGoodsModelsServiceImpl baseGoodsModelsService;
 
     private static String QUERY_FORM_OUTPUT_LIST = "SELECT * FROM l_wh_form_output WHERE 1 = 1";
 
@@ -142,84 +147,13 @@
      * @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(0,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;
-//    }
-
-    /**
-     * @Description 鏂板鍑哄簱鍗�
-     * @Author 鍗㈠簡闃�
-     * @Date 2023/10/27
-     */
-    public int add(LWhFormOutputParam param, S_user_core currentUser, FinSysTenantUser sysInfo) {
+    public int add(LWhFormOutputInsertParam param, S_user_core currentUser, FinSysTenantUser sysInfo) {
         //1.鏂板鍑哄簱鍗曡褰�
         LWhFormOutput lWhFormOutput = new LWhFormOutput();
         //鍑哄叆搴搃d
         long lWhFormOutputId = IdUtil.generateId();
         lWhFormOutput.setId(lWhFormOutputId);
+        lWhFormOutput.setBusinessFormCode(codeGeneratorService.createBusinessFormCode(CodeGeneratorEnum.OutPut_Warehouse));
         Long warehouseId = param.getWarehouseId();
         lWhFormOutput.setWarehouseId(warehouseId);
         //鏍规嵁浠撳簱id鏌ヨ浠撳簱
@@ -235,8 +169,7 @@
         lWhFormOutput.setAgencyName(sysInfo.getTenantName());
         lWhFormOutput.setOperatorId(sysInfo.getId());
         lWhFormOutput.setOperatorName(sysInfo.getUserName());
-        long dateTimeNumber = DateUtils.getDateTimeNumber(System.currentTimeMillis());
-        lWhFormOutput.setDealTime(dateTimeNumber);
+        lWhFormOutput.setDealTime(param.getDealTime());
         lWhFormOutput.setStates(1);
         int flag1 = this.insert(lWhFormOutput);
         if (flag1 == 0) {
@@ -244,19 +177,27 @@
             return 0;
         }
         //2.鏂板鐗╁搧鍨嬪彿璁板綍
-        List<LWhProcureModelParams> models = param.getModels();
+        List<LWhFormOutputGoodsParams> goodsList = param.getGoods();
         List<LWhProcureModel> modelList = new ArrayList<>();
-        for (LWhProcureModelParams model : models) {
-            LWhProcureModel lWhProcureModel = new LWhProcureModel();
-            lWhProcureModel.setId(IdUtil.generateId());
-            lWhProcureModel.setBusinessType(3);
-            lWhProcureModel.setBusinessId(lWhFormOutputId);
-            lWhProcureModel.setBaseGoodsModelsId(model.getBaseGoodsModelsId());
-            lWhProcureModel.setCounts(model.getCounts());
-            //鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨
-            int goodsNum = this.lWhGoodsService.queryGoodsModelNum(0,warehouseId, model.getBaseGoodsModelsId(), (short) 1, null);
-            lWhProcureModel.setWorehouseCount(goodsNum);
-            modelList.add(lWhProcureModel);
+        for (LWhFormOutputGoodsParams goods : goodsList) {
+            List<LWhProcureModelParams> models = goods.getModels();
+            for (LWhProcureModelParams model : models) {
+                LWhProcureModel lWhProcureModel = new LWhProcureModel();
+                lWhProcureModel.setId(IdUtil.generateId());
+                lWhProcureModel.setBusinessType(3);
+                lWhProcureModel.setBusinessId(lWhFormOutputId);
+                lWhProcureModel.setBaseGoodsModelsId(model.getBaseGoodsModelsId());
+                //鏍规嵁鍨嬪彿id鏌ヨ鍨嬪彿
+                BaseGoodsModels baseGoodsModels = this.baseGoodsModelsService.get(new BaseGoodsModels(model.getBaseGoodsModelsId()));
+                if (baseGoodsModels != null) {
+                    lWhProcureModel.setBaseGoodsModelsName(baseGoodsModels.getModelName());
+                }
+                lWhProcureModel.setCounts(model.getCounts());
+                //鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨
+                int goodsNum = this.lWhGoodsService.queryGoodsModelNum(0,warehouseId, model.getBaseGoodsModelsId(), (short) 1, null);
+                lWhProcureModel.setWorehouseCount(goodsNum);
+                modelList.add(lWhProcureModel);
+            }
         }
         int flag2 = this.lWhProcureModelService.insert(modelList);
         if (flag2 != modelList.size()) {
@@ -264,6 +205,15 @@
             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
             return 0;
         }
+
+        //3.鏍规嵁鍑哄簱鍗曞嚭搴�
+        Long lWarehouseFlowId = this.lWhFormOutputCoreService.outFormByTransId(lWhFormOutputId, currentUser, param.getDealTime());
+        if (lWarehouseFlowId == null) {
+            log.error("鏍规嵁鍑哄簱鍗曞嚭搴撳け璐�");
+            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+            return 0;
+        }
+
         return 1;
     }
 

--
Gitblit v1.9.1