package com.consum.base.service.impl; import com.consum.base.service.core.LWhFormOutputCoreService; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import org.apache.commons.compress.utils.Lists; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.springframework.transaction.interceptor.TransactionAspectSupport; import com.consum.base.core.CodeGeneratorEnum; import com.consum.base.core.CodeGeneratorService; import com.consum.base.core.WhBusinessEnum; import com.consum.base.core.type.GoodsModelType; import com.consum.base.core.type.InAndOutPutType; import com.consum.base.core.type.OutPutStatesType; import com.consum.base.core.type.WareHouseType; import com.consum.base.core.utils.CurrencyUtil; import com.consum.base.core.utils.IdUtil; import com.consum.base.core.utils.MapUtils; import com.consum.base.core.utils.MapperUtil; import com.consum.base.pojo.LWFormsOutputGoodsInfoParam; import com.consum.base.pojo.LWFormsOutputGoodsModelParam; import com.consum.base.pojo.LWhFormOutputParam; import com.consum.base.pojo.excel.OutputExcelTemplate; import com.consum.base.pojo.query.LWhFormOutputQry; import com.consum.base.service.BaseGoodsModelsService; import com.consum.base.service.BaseWarehouseService; import com.consum.base.service.LWhFormOutputService; import com.consum.base.service.LWhGoodsService; import com.consum.base.service.LWhProcureModelService; import com.consum.model.po.BaseGoodsModels; import com.consum.model.po.BaseWarehouse; import com.consum.model.po.FinSysTenantUser; import com.consum.model.po.LWhFormOutput; import com.consum.model.po.LWhProcureModel; import com.consum.model.po.WhFormOutput; import com.iplatform.model.po.S_user_core; import com.walker.db.page.GenericPager; import com.walker.infrastructure.utils.CollectionUtils; import com.walker.infrastructure.utils.StringUtils; import com.walker.jdbc.service.BaseServiceImpl; import lombok.extern.slf4j.Slf4j; /** * @Description 出库单 * @Author 卢庆阳 * @Date 2023/10/27 */ @Slf4j @Service public class LWhFormOutputServiceImpl extends BaseServiceImpl implements LWhFormOutputService { @Autowired private CodeGeneratorService codeGeneratorService; @Autowired private BaseWarehouseService baseWarehouseService; @Autowired private LWhGoodsService lWhGoodsService; @Autowired private LWhProcureModelService lWhProcureModelService; @Autowired @Lazy private LWhFormOutputCoreService lWhFormOutputCoreService; @Autowired private BaseGoodsModelsService baseGoodsModelsService; private static String QUERY_FORM_OUTPUT_LIST = "SELECT * FROM l_wh_form_output WHERE 1 = 1"; /** * @Description 新增出库单 * @Author 卢庆阳 * @Date 2023/10/27 */ @Override public int add(LWhFormOutputParam param, S_user_core currentUser, FinSysTenantUser sysInfo) { // 1.新增出库单记录 LWhFormOutput lWhFormOutput = new LWhFormOutput(); // 出入库id long lWhFormOutputId = IdUtil.generateId(); lWhFormOutput.setId(lWhFormOutputId); lWhFormOutput .setBusinessFormCode(codeGeneratorService.createBusinessFormCode(CodeGeneratorEnum.OutPut_Warehouse)); 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(InAndOutPutType.Fragmentary_Output.getValue() + ""); lWhFormOutput.setOutputName("零星出库"); lWhFormOutput.setAgencyId(Long.valueOf(sysInfo.getTenantId())); lWhFormOutput.setAgencyName(sysInfo.getTenantName()); lWhFormOutput.setOperatorId(sysInfo.getId()); lWhFormOutput.setOperatorName(sysInfo.getUserName()); lWhFormOutput.setDealTime(param.getDealTime()); lWhFormOutput.setStates(OutPutStatesType.OUT_PENDING.getValue()); lWhFormOutput.setOutputDoc(param.getDoc()); int outputInsertNum = this.insert(lWhFormOutput); if (outputInsertNum == 0) { log.error("新增出库单记录失败"); return 0; } // 2.新增物品型号记录 Set allChangModelList = new HashSet<>(); List goodsList = param.getGoods(); List modelList = new ArrayList<>(); for (LWFormsOutputGoodsInfoParam goods : goodsList) { List models = goods.getModels(); for (LWFormsOutputGoodsModelParam model : models) { LWhProcureModel lWhProcureModel = new LWhProcureModel(); lWhProcureModel.setId(IdUtil.generateId()); lWhProcureModel.setBusinessType(GoodsModelType.OUT_PUT.getValue()); lWhProcureModel.setBusinessId(lWhFormOutputId); lWhProcureModel.setBaseGoodsModelsId(model.getBaseGoodsModelsId()); allChangModelList.add(model.getBaseGoodsModelsId()); // 根据型号id查询型号 BaseGoodsModels baseGoodsModels = this.baseGoodsModelsService.get(new BaseGoodsModels(model.getBaseGoodsModelsId())); if (baseGoodsModels != null) { lWhProcureModel.setBaseGoodsModelsName(baseGoodsModels.getModelName()); } lWhProcureModel.setCounts(model.getCounts()); // 根据物品型号查询物品库存 List warehouseIds = new ArrayList<>(Arrays.asList(warehouseId)); int goodsNum = this.lWhGoodsService.queryGoodsModelNum(WareHouseType.TENANT.getValue(), warehouseIds, model.getBaseGoodsModelsId(), 1, null); lWhProcureModel.setWorehouseCount(goodsNum); modelList.add(lWhProcureModel); } } int modelInsertNum = this.lWhProcureModelService.insert(modelList); if (modelInsertNum != modelList.size()) { log.error("新增物品型号失败"); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return 0; } // 3.根据出库单出库 Long lWarehouseFlowId = this.lWhFormOutputCoreService.outFormByTransId(lWhFormOutputId, WhBusinessEnum.CHUKU, currentUser, param.getDealTime(), null); if (lWarehouseFlowId == null) { log.error("根据出库单出库失败"); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return 0; } // 4 预警 // 当库存变动时调用该方法 // lWhWarningCoreService.updateKuCun((short) 0, warehouseId, new ArrayList<>(allChangModelList), null, // DateUtils.getDateTimeNumber(System.currentTimeMillis())); return 1; } /** * @Description 列表查询 * @Author 卢庆阳 * @Date 2023/10/30 */ @Override public GenericPager queryFormOutputList(LWhFormOutputQry param) { HashMap paramts = new HashMap<>(); StringBuilder sql = new StringBuilder(QUERY_FORM_OUTPUT_LIST); // 出库单号 if (!StringUtils.isEmpty(param.getBusinessFormCode())) { sql.append(" and BUSINESS_FORM_CODE = :businessFormCode "); paramts.put("businessFormCode", param.getBusinessFormCode()); } // 物品名称 if (!StringUtils.isEmpty(param.getGoodsName())) { sql.append( " AND id IN (SELECT BUSINESS_ID FROM L_WH_PROCURE_MODEL procureModel LEFT JOIN BASE_GOODS_MODELS baseModel ON procureModel.BASE_GOODS_MODELS_ID=baseModel.ID LEFT JOIN BASE_GOODS_TEMPLATE baseTemp ON baseModel.GOODS_TEMPLATES_ID=baseTemp.id WHERE procureModel.BUSINESS_TYPE=3 AND baseTemp.GOODS_NAME LIKE :goodsTemplateName)"); paramts.put("goodsTemplateName", StringUtils.CHAR_PERCENT + param.getGoodsName() + StringUtils.CHAR_PERCENT); } // 机构 if (param.getAgencyId() != null) { sql.append(" and AGENCY_ID like :agencyId "); paramts.put("agencyId", param.getAgencyId() + StringUtils.CHAR_PERCENT); } // 创建人 if (!StringUtils.isEmpty(param.getCreateName())) { sql.append(" and operator_name =:operator_name "); paramts.put("operator_name", param.getCreateName()); } // 状态 if (param.getStates() != null) { sql.append(" and states =:states "); paramts.put("states", param.getStates()); } // 出库时间 if (param.getStartTime() != null) { sql.append(" and DEAL_TIME >=:outputTimeStart "); paramts.put("outputTimeStart", param.getStartTime() * 1000000); } if (param.getEndTime() != null) { sql.append(" and DEAL_TIME <:outputTimeEnd "); paramts.put("outputTimeEnd", param.getEndTime() * 1000000 + 240000); } sql.append(" ORDER BY DEAL_TIME DESC"); GenericPager genericPager = selectSplit(sql.toString(), paramts, new LWhFormOutput()); return genericPager; } @Override public GenericPager> queryFormOutputDetailList(LWhFormOutputQry param) { HashMap paramts = new HashMap<>(); StringBuilder sql = new StringBuilder("SELECT pm.id,fp.BUSINESS_FORM_CODE,fpg.GOODS_TEMPLATE_NAME,pm.PRICE,pm.COUNTS, " + "( pm.PRICE * pm.COUNTS ) amount,fp.AGENCY_NAME,fp.BUYER_NAME,fp.PROCURE_TIME,pm.BUSINESS_ID,pm.BASE_GOODS_MODELS_NAME FROM l_wh_procure_model pm " + "LEFT JOIN l_wh_form_procure fp ON pm.BUSINESS_ID = fp.id " + "LEFT JOIN l_wh_form_procure_goods fpg ON fp.id = fpg.WH_FORM_PROCURE_ID WHERE pm.BUSINESS_TYPE = 1 "); // 入库单号 if (!StringUtils.isEmpty(param.getBusinessFormCode())) { sql.append("and BUSINESS_FORM_CODE = :businessFormCode "); paramts.put("businessFormCode", param.getBusinessFormCode()); } // 物品名称 if (!StringUtils.isEmpty(param.getGoodsName())) { sql.append("and fpg.GOODS_TEMPLATE_NAME like :goodsTemplateName "); paramts.put("goodsTemplateName", StringUtils.CHAR_PERCENT + param.getGoodsName() + StringUtils.CHAR_PERCENT); } if (param.getAgencyId() != null) { sql.append("and AGENCY_ID like :agencyId "); paramts.put("agencyId", param.getAgencyId() + StringUtils.CHAR_PERCENT); } // 创建人 if (!StringUtils.isEmpty(param.getCreateName())) { sql.append("and buyer_Name =:buyerName "); paramts.put("buyerName", param.getCreateName()); } // 入库开始时间 if (param.getStartTime() != null) { sql.append("and INCOME_TIME >=:incomeTimeStart "); paramts.put("incomeTimeStart", param.getStartTime() * 1000000); } // 入库结束时间 if (param.getEndTime() != null) { sql.append("and INCOME_TIME <:incomeTimeEnd "); paramts.put("incomeTimeEnd", param.getEndTime() * 1000000 + 240000); } // 规格型号 if (param.getBaseGoodsModelsId() != null) { sql.append("and pm.BASE_GOODS_MODELS_ID =:baseGoodsModelsId "); paramts.put("baseGoodsModelsId", param.getBaseGoodsModelsId()); } sql.append("ORDER BY PROCURE_TIME DESC"); GenericPager genericPager = selectSplit(sql.toString(), paramts, param.getPageNum(), param.getPageSize(), new MapperUtil()); return genericPager; } @Override public List getExportList(Long id) { String sql = "SELECT\n" + "\tfo.BUSINESS_FORM_CODE,\n" + "\tfo.AGENCY_NAME tenantName,\n" + "\tGOODS_NAME templateName,\n" + "\tpm.BASE_GOODS_MODELS_NAME baseModelName,\n" + "\tcounts num,\n" + "\ttotal_amount totalAmount,\n" + "\tfo.DEAL_TIME createTime,\n" + "\tfo.OPERATOR_NAME,\n" + "\tBEIZ remark\n" + "FROM\n" + "\tl_wh_procure_model pm\n" + "\tLEFT JOIN base_goods_models bgm ON pm.BASE_GOODS_MODELS_ID = bgm.id\n" + "\tLEFT JOIN base_goods_template bgt ON bgm.GOODS_TEMPLATES_ID = bgt.id\n" + "\tLEFT JOIN l_wh_form_output fo ON fo.ID = pm.BUSINESS_ID\n" + "WHERE\n" + "\tpm.BUSINESS_ID = :id"; Map param = new HashMap<>(); param.put("id", id); List> select = this.select(sql, param, new MapperUtil()); if (CollectionUtils.isEmpty(select)) { return null; } List list = Lists.newArrayList(); select.forEach(item -> { OutputExcelTemplate templateExcelExport = MapUtils.convertMapToObj(item, OutputExcelTemplate.class); templateExcelExport.setAmount(CurrencyUtil.convertFenToYuan(templateExcelExport.getTotalAmount())); list.add(templateExcelExport); }); return list; } /** * 通过调拨单查询出库单id * * @param transBusinessId * @return */ private static String QUEYR_ID_BY_TRANSFERID = "select id from L_WH_FORM_OUTPUT where TRANS_BUSINESS_ID =:transBusinessId limit 1"; @Override public Long queyrIdByTransferId(Long transBusinessId) { HashMap map = new HashMap<>(); map.put("transBusinessId", transBusinessId); List whFormOutputs = select(QUEYR_ID_BY_TRANSFERID, map, new WhFormOutput()); if (CollectionUtils.isEmpty(whFormOutputs)) { return null; } return whFormOutputs.get(0).getId(); } }