package com.consum.base.core; import com.consum.base.core.tools.SqlParameter; import com.consum.base.core.util.DateUtil; import com.consum.model.po.*; import com.walker.infrastructure.utils.NumberGenerator; import com.walker.jdbc.service.BaseServiceImpl; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.util.Assert; import java.util.List; /** * 核心出入库接口 */ @Service @Slf4j public class WarehouseCoreService extends BaseServiceImpl { public static void main(String[] args) { WhGoods goods = new WhGoods(); goods.setId(1l); goods.setWarehouseId(111l); goods.setSupplier("河南金明源"); WhGoods_mapper mapper = new WhGoods_mapper(goods); System.out.println(mapper.getInsertSql_().getParameters()); System.out.println(mapper.getInsertSql_().getSql()); } /** * 统一出入库 */ public CheckWarehouseResult[] unifyCheck(CheckWarehouseParam param) { // TODO: 10/10/2023 此处加了唯一锁,会影响性能,思考是否有更合适的办法 try { Assert.notNull(param, "wareHouse param can not null !"); Assert.notNull(param.getWarehouseId(), "wareHouse id can not null"); CheckWarehouseResult[] result; synchronized (param.getWarehouseId()) { if (param.getIsCheckIn()) { result = new CheckWarehouseResult[]{checkin(param)}; } else { result = checkout(param); } } return result; } catch (Exception e) { log.error(e.getMessage()); throw new RuntimeException(e.getMessage()); } } /** * 出库 */ private CheckWarehouseResult[] checkout(CheckWarehouseParam param) { String sql = "SELECT\n" + " * \n" + "FROM\n" + " WH_GOODS \n" + "WHERE\n" + " WAREHOUSE_ID =:WAREHOUSE_ID \n" + " AND BASE_GOODS_MODELS_ID =:BASE_GOODS_MODELS_ID \n" + " AND STATES =1 \n" + " AND WH_COUNT > 0 \n" + " order by PROCURE_DATE asc PRICE DESC"; SqlParameter parameter = new SqlParameter(); parameter.add("WAREHOUSE_ID",param.getWarehouseId()) .add("BASE_GOODS_MODELS_ID",param.getModelId()); List goodsList = select(sql,parameter,new WhGoods()); for (WhGoods goods : goodsList){ } return null; } private BaseWarehouse getWarehouse(long id){ BaseWarehouse w = get(new BaseWarehouse(),"ID=?",new Object[]{id}); return w; } /** * 入库 */ private CheckWarehouseResult checkin(CheckWarehouseParam param) throws RuntimeException { //如果是采购入库 if (param.getFirst_input_type() ==1){ WhFormProcureModel procureModel = get(new WhFormProcureModel(),"ID=?",new Object[]{param.getFirstInputCode()}); WhFormProcure procure = get(new WhFormProcure(),"ID=?",new Object[]{procureModel.getWhFormProcureId()}); WhGoods goods = new WhGoods(); goods.setId(NumberGenerator.getLongSequenceNumber()); goods.setBaseGoodsTemplateId(procureModel.getBaseGoodsTemplateId()); goods.setGoodsTemplateName(procureModel.getGoodsTemplateName()); goods.setBaseGoodsModelsId(procureModel.getBaseGoodsModelsId()); goods.setBaseGoodsModelsName(procureModel.getBaseGoodsModelsName()); goods.setWhCount(procureModel.getCounts()); goods.setTransferCount(0); goods.setAllCount(procureModel.getCounts()); goods.setFirstInputCode(param.getFirstInputCode()); goods.setFirstInputType(param.getFirst_input_type()); goods.setFirstInputHisId(NumberGenerator.getLongSequenceNumber()); goods.setWarehouseId(procure.getWarehouseId()); goods.setWarehouseName(procure.getWarehouseName()); goods.setSupplier(procureModel.getSupplier()); goods.setUnit(procureModel.getUnit()); goods.setPrice(procureModel.getPrice()); goods.setProcureDate(procure.getIncomeTime()); goods.setBackDate(procure.getIncomeTime()); goods.setStates(1); insert(goods); CheckWarehouseResult result = new CheckWarehouseResult(); result.setWhGoods(goods); result.setInitial_count(0); result.setEnd_count(goods.getAllCount()); return result; //零星入库 } else if (param.getFirst_input_type() ==2){ return null; } String sql = "SELECT\n" + " * \n" + "FROM\n" + " WH_GOODS \n" + "WHERE\n" + " WAREHOUSE_ID =:WAREHOUSE_ID \n" + " AND FIRST_INPUT_CODE =:FIRST_INPUT_CODE \n" + " AND BASE_GOODS_MODELS_ID =:BASE_GOODS_MODELS_ID" + " order by PROCURE_DATE desc PRICE asc"; SqlParameter parameter = new SqlParameter(); parameter.add("WAREHOUSE_ID",param.getWarehouseId()) .add("FIRST_INPUT_CODE",param.getFirstInputCode()) .add("BASE_GOODS_MODELS_ID",param.getModelId()); List goodsList = select(sql,parameter,new WhGoods()); if (goodsList == null || goodsList.size() == 0){ new RuntimeException("查不到历史库存"); return null; } for (WhGoods goods : goodsList){ CheckWarehouseResult result = new CheckWarehouseResult(); result.setWhGoods(goods); result.setInitial_count(goods.getWhCount()); result.setEnd_count(goods.getWhCount() + param.getCount()); WhGoods newGoods = new WhGoods(); newGoods.setId(goods.getId()); newGoods.setWhCount(result.getEnd_count()); newGoods.setAllCount(goods.getAllCount() + param.getCount()); newGoods.setStates(1); newGoods.setBackDate(DateUtil.getCurrentDateFor14()); this.update(newGoods); return result; } return new CheckWarehouseResult(); } }