From 19df4ea6a5bfbfb7522c18fc6d0cde09ca216065 Mon Sep 17 00:00:00 2001
From: 杨凯 <398860375@qq.com>
Date: 星期二, 17 十月 2023 22:06:09 +0800
Subject: [PATCH] 上传核心业务服务
---
consum-base/src/main/java/com/consum/base/core/WarehouseBusinessService.java | 113 ++++++++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 105 insertions(+), 8 deletions(-)
diff --git a/consum-base/src/main/java/com/consum/base/core/WarehouseBusinessService.java b/consum-base/src/main/java/com/consum/base/core/WarehouseBusinessService.java
index ae212eb..d39badc 100644
--- a/consum-base/src/main/java/com/consum/base/core/WarehouseBusinessService.java
+++ b/consum-base/src/main/java/com/consum/base/core/WarehouseBusinessService.java
@@ -1,15 +1,19 @@
package com.consum.base.core;
import com.consum.base.core.po.WhFormInventory;
-import com.consum.base.core.po.WhFormProcure;
-import com.consum.base.core.po.WhFormTransfer;
+import com.consum.base.core.tools.SqlParameter;
+import com.consum.model.po.*;
+import com.walker.infrastructure.utils.NumberGenerator;
+import com.walker.jdbc.service.BaseServiceImpl;
import org.springframework.stereotype.Service;
+
+import java.util.List;
/**
* 杩涘嚭搴� 涓氬姟澶� 绫�
*/
@Service
-public class WarehouseBusinessService {
+public class WarehouseBusinessService extends BaseServiceImpl {
private WarehouseCoreService coreService;
@@ -23,12 +27,52 @@
* @param procure
*/
public void doProcure(WhFormProcure procure){
- CheckWarehouseParam param = new CheckWarehouseParam();
- param.setIsCheckIn(true);
- param.setWarehouseId(procure.getId());
- param.setIsCheckIn(true);
- coreService.unifyCheck(param);
+ String sql = "SELECT\n" +
+ " * \n" +
+ "FROM\n" +
+ " WH_FORM_PROCURE_MODEL A \n" +
+ "WHERE\n" +
+ " A.WH_FORM_PROCURE_ID = : PROCURE_ID";
+
+ List<WhFormProcureModel> modelList = this.select(sql,new SqlParameter().put("PROCURE_ID",procure.getId()),new WhFormProcureModel());
+
+ for (WhFormProcureModel model : modelList){
+ CheckWarehouseParam param = new CheckWarehouseParam();
+ param.setIsCheckIn(true);
+ param.setWarehouseId(procure.getId());
+ param.setCount(model.getCounts());
+ param.setFirstInputCode(model.getId().toString());
+ param.setFirst_input_type(1);
+ param.setModelId(model.getBaseGoodsModelsId());
+ CheckWarehouseResult result = coreService.unifyCheck(param)[0];
+
+
+ WhGoodsDetails details = new WhGoodsDetails();
+ details.setId(result.getWhGoods().getFirstInputHisId());
+ details.setBusinessFormId(procure.getId());
+ details.setBusinessFormCode(procure.getBusinessFormCode());
+ details.setBusinessFormName(procure.getWarehouseName() + "閲囪喘鍏ュ簱鍗�:" + details.getBusinessFormCode());
+ details.setInitialCount(result.getInitial_count());
+ details.setThisType(1);
+ details.setEndCount(result.getEnd_count());
+ details.setWarehouseId(param.getWarehouseId());
+ details.setWarehouseName(procure.getWarehouseName());
+ details.setClassification(1);
+ details.setOperatorId(procure.getOperatorId2());
+ details.setOperatorName(procure.getOperatorName2());
+ details.setDealTime(procure.getIncomeTime());
+ details.setWhGoodsId(result.getWhGoods().getId());
+
+ this.insert(details);
+
+
+ model.setInWhGoodsDetailsId(details.getId());
+ update(model);
+
+ procure.setStates(2);
+ update(procure);
+ }
}
/**
@@ -40,7 +84,50 @@
* @param transfer
*/
public void doTransferOutPut(WhFormTransfer transfer){
+ String sql = "SELECT\n" +
+ " * \n" +
+ "FROM\n" +
+ " WH_FORM_TRANSFER_GOODS A \n" +
+ "WHERE\n" +
+ " A.WH_FORM_TRANSFER_ID = : TRANSFER_ID";
+ List<WhFormTransferGoods> goodsList = this.select(sql,new SqlParameter()
+ .put("TRANSFER_ID",transfer.getId()),new WhFormTransferGoods());
+
+ for (WhFormTransferGoods goods : goodsList){
+ CheckWarehouseParam param = new CheckWarehouseParam();
+ param.setIsCheckIn(false);
+ param.setWarehouseId(transfer.getOutWarehouseId());
+ param.setCount(goods.getCounts());
+ CheckWarehouseResult[] results = coreService.unifyCheck(param);
+ for (CheckWarehouseResult result : results){
+ WhFormTransferModel model = new WhFormTransferModel();
+ model.setId(NumberGenerator.getLongSequenceNumber());
+ model.setWhFormTransferId(transfer.getId());
+ model.setWorehouseCount(result.getInitial_count());
+ model.setCounts(result.getInitial_count() - result.getInitial_count());
+ model.setOutWhGoodsDetailsId(result.getWhGoods().getId());
+ model.setWhFormTransferGoodsId(goods.getId());
+ insert(model);
+
+ WhGoodsDetails details = new WhGoodsDetails();
+ details.setBusinessFormId(transfer.getId());
+ details.setBusinessFormCode(transfer.getBusinessFormCode());
+ details.setBusinessFormName("璋冩嫧鍑哄簱鍗曪細" + transfer.getBusinessFormCode());
+ details.setInitialCount(result.getInitial_count());
+ details.setThisType(2);
+ details.setThisCount(result.getInitial_count() - result.getEnd_count());
+ details.setEndCount(result.getEnd_count());
+ details.setWarehouseId(result.getWhGoods().getWarehouseId());
+ details.setWarehouseName(result.getWhGoods().getWarehouseName());
+ details.setClassification(5);
+ details.setOperatorId(transfer.getOperatorId());
+ details.setOperatorName(transfer.getOperatorName());
+ details.setDealTime(transfer.getOutputTime());
+ details.setWhGoodsId(result.getWhGoods().getId());
+ this.insert(details);
+ }
+ }
}
/**
@@ -53,6 +140,16 @@
*/
public void doTransferInPut(WhFormTransfer transfer){
+ String sql = "SELECT\n" +
+ " * \n" +
+ "FROM\n" +
+ " WH_FORM_TRANSFER_GOODS A \n" +
+ "WHERE\n" +
+ " A.WH_FORM_TRANSFER_ID = : TRANSFER_ID";
+
+ List<WhFormTransferGoods> goodsList = this.select(sql,new SqlParameter()
+ .put("TRANSFER_ID",transfer.getId()),new WhFormTransferGoods());
+
}
/**
--
Gitblit v1.9.1