package com.consum.base.service; import com.consum.base.core.CodeGeneratorEnum; import com.consum.base.core.CodeGeneratorService; import com.consum.base.core.WhBusinessEnum; import com.consum.base.core.param.BaseWarehouseParam1; 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.TemplateExcelExport; import com.consum.base.pojo.query.LWhFormOutputQry; 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.iplatform.model.po.S_user_core; import com.walker.db.page.GenericPager; import com.walker.infrastructure.utils.CollectionUtils; import com.walker.infrastructure.utils.DateUtils; import com.walker.infrastructure.utils.StringUtils; import com.walker.jdbc.service.BaseServiceImpl; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Optional; import lombok.extern.slf4j.Slf4j; import org.apache.commons.compress.utils.Lists; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.interceptor.TransactionAspectSupport; /** * @Description 出库单 * @Author 卢庆阳 * @Date 2023/10/27 */ @Slf4j @Service public class LWhFormOutputServiceImpl extends BaseServiceImpl { @Autowired private CodeGeneratorService codeGeneratorService; @Autowired private BaseWarehouseServiceImpl baseWarehouseService; @Autowired private LWhGoodsService lWhGoodsService; @Autowired 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"; /** * @Description 新增出库单 * @Author 卢庆阳 * @Date 2023/10/27 */ 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(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()); lWhFormOutput.setDealTime(param.getDealTime()); lWhFormOutput.setStates(1); lWhFormOutput.setOutputDoc(param.getProcureDoc()); int flag1 = this.insert(lWhFormOutput); if (flag1 == 0) { log.error("新增出库单记录"); return 0; } //2.新增物品型号记录 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(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(), 1, null); lWhProcureModel.setWorehouseCount(goodsNum); modelList.add(lWhProcureModel); } } int flag2 = this.lWhProcureModelService.insert(modelList); if (flag2 != modelList.size()) { log.error("新增物品型号失败"); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return 0; } //3.根据出库单出库 Long lWarehouseFlowId = this.lWhFormOutputCoreService.outFormByTransId(lWhFormOutputId, WhBusinessEnum.CHUKU, currentUser, param.getDealTime()); if (lWarehouseFlowId == null) { log.error("根据出库单出库失败"); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return 0; } return 1; } /** * @Description 列表查询 * @Author 卢庆阳 * @Date 2023/10/30 */ 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; } 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; } public Map getExportList(Long id, String userName) { String sql = "SELECT\n" + "\tfo.BUSINESS_FORM_CODE,\n" + "\tfo.AGENCY_NAME tenantName,\n" + "\tGOODS_NAME goodsName,\n" + "\tpm.BASE_GOODS_MODELS_NAME goodsModeName,\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 -> { TemplateExcelExport templateExcelExport = MapUtils.convertMapToObj(item, TemplateExcelExport.class); templateExcelExport.setTenantName(StringUtils.isNotEmpty(templateExcelExport.getTenantName()) ? templateExcelExport.getTenantName() : ""); templateExcelExport.setRemark(StringUtils.isNotEmpty(templateExcelExport.getRemark()) ? templateExcelExport.getRemark() : ""); templateExcelExport.setTotalAmount(templateExcelExport.getTotalAmount() == null ? 0 : templateExcelExport.getTotalAmount()); templateExcelExport.setNum(templateExcelExport.getNum() == null ? 0 : templateExcelExport.getNum()); list.add(templateExcelExport); }); int sum = list.stream().filter(item -> item.getNum() != null).mapToInt(TemplateExcelExport::getNum).sum(); int totalAmount = list.stream().filter(export -> export.getTotalAmount() != null).mapToInt(TemplateExcelExport::getTotalAmount).sum(); Optional first = list.stream().findFirst(); TemplateExcelExport templateExcelExport = first.get(); String businessFormCode = templateExcelExport.getBusinessFormCode(); Long createTime = templateExcelExport.getCreateTime(); String operatorName = templateExcelExport.getOperatorName(); Map map = new HashMap<>(); map.put("code", businessFormCode); map.put("date", DateUtils.toShowDate(createTime)); map.put("name", operatorName); map.put("sum", sum); map.put("totalAmount", totalAmount); map.put("data", list); return map; } }