package com.consum.base.core;
|
|
import com.consum.base.core.po.WhFormInventory;
|
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 extends BaseServiceImpl {
|
|
|
private WarehouseCoreService coreService;
|
|
/**
|
* 执行采购入库
|
* 第一步：通过采购单【WH_FORM_PROCURE】查询采购单型号【WH_FORM_PROCURE_MODEL】数据
|
* 第二步：组织CheckWarehouseParam，调用WarehouseCoreService.unifyCheck()执行入库
|
* 第三步：更新采购单型号【WH_FORM_PROCURE_MODEL】库存物品编号字段及主表WH_FORM_PROCURE状态信息
|
* 第四步：更新 进出库流水（仓库）【WH_GOODS_DETAILS】
|
* @param procure
|
*/
|
public void doProcure(WhFormProcure procure){
|
|
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);
|
}
|
}
|
|
/**
|
* 执行调拨出库操作
|
* 1. 通过调拨单【WH_FORM_TRANSFER】、调拨单物品【WH_FORM_TRANSFER_GOODS】组织CheckWarehouseParam
|
* 2. 调用调用WarehouseCoreService.unifyCheck()执行出库
|
* 3. 更新进出库流水（仓库）【WH_GOODS_DETAILS】
|
* 4. 更新调拨单【WH_FORM_TRANSFER】为待接收，更新调拨单物品【WH_FORM_TRANSFER_MODEL】出库流水ID
|
* @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);
|
}
|
}
|
}
|
|
/**
|
* 执行调拨入库操作
|
* 1. 通过调拨单【WH_FORM_TRANSFER】、调拨单物品【WH_FORM_TRANSFER_GOODS】组织CheckWarehouseParam
|
* 2. 调用调用WarehouseCoreService.unifyCheck()执行出库
|
* 3. 更新进出库流水（仓库）【WH_GOODS_DETAILS】
|
* 4. 更新调拨单【WH_FORM_TRANSFER】为已入库，，更新调拨单物品【WH_FORM_TRANSFER_MODEL】入库流水ID
|
* @param transfer
|
*/
|
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());
|
|
}
|
|
/**
|
* 创建盘点任务，创建盘点任务时，根据当时时间会将库存数据冻结一份放入待盘点单。
|
* 1.从库存物品【WH_GOODS】中按照仓库将数据放入盘点单物品【WH_FORM_INVENTORY_GOODS】，主要是
|
* 期初数量INIT_COUNTS，和 库存物品编号WH_GOODS_ID字段
|
* @param inventory
|
*/
|
public void createInventory(WhFormInventory inventory){
|
|
}
|
|
}
|
