From 31692354e8191b583250c213152bfd0068ffe0fc Mon Sep 17 00:00:00 2001 From: futian.liu <liufutianyoo@163.com> Date: 星期一, 13 十一月 2023 10:43:05 +0800 Subject: [PATCH] 整理代码 --- consum-base/src/main/java/com/consum/base/service/LWhFormInventoryServiceImpl.java | 88 ++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 84 insertions(+), 4 deletions(-) diff --git a/consum-base/src/main/java/com/consum/base/service/LWhFormInventoryServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/LWhFormInventoryServiceImpl.java index b40b06d..f1ad54d 100644 --- a/consum-base/src/main/java/com/consum/base/service/LWhFormInventoryServiceImpl.java +++ b/consum-base/src/main/java/com/consum/base/service/LWhFormInventoryServiceImpl.java @@ -2,9 +2,10 @@ import com.consum.base.core.CodeGeneratorEnum; import com.consum.base.core.CodeGeneratorService; +import com.consum.base.core.utils.MapRowMapper; import com.consum.base.pojo.LWhFormInventoryDto; import com.consum.base.pojo.LWhFormInventoryParam; -import com.consum.base.util.IdUtil; +import com.consum.base.core.utils.IdUtil; import com.consum.model.po.*; import com.iplatform.model.po.S_user_core; import com.walker.db.page.GenericPager; @@ -14,11 +15,9 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.security.core.parameters.P; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; -import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -54,6 +53,18 @@ " AND STATES = ?\n" + " GROUP BY BASE_GOODS_MODELS_ID) record ON record.BASE_GOODS_MODELS_ID = model.id\n" + "left join base_goods_template bgt on bgt.ID = model.GOODS_TEMPLATES_ID; "; + + private static final String QUERY_PD_DETAIL_LIST = "select lwfi.WAREHOUSE_NAME,lwfig.GOODS_TEMPLATE_NAME,\n" + + " lwfig.BASE_GOODS_MODELS_NAME,\n" + + " lwfig.INVENTORY_RESULT,\n" + + " lwfig.INIT_COUNTS,\n" + + " lwfig.INVENTORY_COUNTS,\n" + + " lwfig.ERROR_COUNTS,\n" + + " lwfi.AGENCY_NAME,\n" + + " lwfi.OPERATOR_NAME,\n" + + " lwfi.STOP_TIME\n" + + "from l_wh_form_inventory lwfi\n" + + " inner join l_wh_form_inventory_goods lwfig on lwfi.ID = lwfig.WH_FORM_INVENTORY_ID "; /** * @Description 鏂板 @@ -224,7 +235,7 @@ } else { inventoryGoods.setInventoryResult(1); } - inventoryGoods.setErrorCounts(errorCounts); + inventoryGoods.setErrorCounts(Math.abs(errorCounts)); } int flag2 = inventoryGoodsService.update(inventoryGoodsList); if (flag2 != inventoryGoodsList.size()) { @@ -233,4 +244,73 @@ } return 1; } + + /** + * @Description 寮傚父鏄庣粏鍒楄〃鏌ヨ + * @Author 鍗㈠簡闃� + * @Date 2023/11/1 + * @return + */ + public GenericPager<Map<String, Object>> queryPdDetailList(LWhFormInventoryParam param, FinSysTenantUser sysInfo) { + StringBuilder sql = new StringBuilder(QUERY_PD_DETAIL_LIST); + HashMap<String, Object> paramts = new HashMap<>(); + + //鏈烘瀯 + sql.append(" and AGENCY_ID like:AGENCY_ID "); + if (param.getAgencyId() != null) { + paramts.put("AGENCY_ID", param.getAgencyId() + StringUtils.CHAR_PERCENT); + } else { + paramts.put("AGENCY_ID", sysInfo.getTenantId() + StringUtils.CHAR_PERCENT); + } + //浠撳簱缂栧彿 + if (param.getWarehouseId() != null) { + sql.append(" and WAREHOUSE_ID =:WAREHOUSE_ID "); + paramts.put("WAREHOUSE_ID", param.getWarehouseId()); + } + //鐗╁搧鍚嶇О + if (!StringUtils.isEmpty(param.getGoodsTemplateName())) { + sql.append(" and GOODS_TEMPLATE_NAME =:GOODS_TEMPLATE_NAME "); + paramts.put("GOODS_TEMPLATE_NAME", StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT); + } + //瑙勬牸鍨嬪彿 + if (param.getBaseGoodsModelsId() != null) { + sql.append(" and BASE_GOODS_MODELS_ID =:BASE_GOODS_MODELS_ID "); + paramts.put("BASE_GOODS_MODELS_ID", param.getBaseGoodsModelsId()); + } + //绫诲瀷(鍑哄叆搴撶被鍨�) + Integer inventoryResult = param.getInventoryResult(); + if (inventoryResult != null) { + sql.append(" and INVENTORY_RESULT =:INVENTORY_RESULT "); + paramts.put("INVENTORY_RESULT", inventoryResult); + } + //鍑哄叆搴撳崟鍙� + if (param.getWarehouseFormCode() != null) { + if (inventoryResult == 2) { //鐩樼泩鍏ュ簱 + sql.append(" and IN_BUSINESS_FORM_CODE =:IN_BUSINESS_FORM_CODE "); + paramts.put("IN_BUSINESS_FORM_CODE", StringUtils.CHAR_PERCENT + param.getWarehouseFormCode() + StringUtils.CHAR_PERCENT); + } else { //鐩樹簭鍑哄簱 + sql.append(" and OUT_BUSINESS_FORM_CODE =:OUT_BUSINESS_FORM_CODE "); + paramts.put("OUT_BUSINESS_FORM_CODE", StringUtils.CHAR_PERCENT + param.getWarehouseFormCode() + StringUtils.CHAR_PERCENT); + } + } + //鎿嶄綔浜� + if (!StringUtils.isEmpty(param.getOperatorName())) { + sql.append(" and OPERATOR_NAME =:OPERATOR_NAME "); + paramts.put("OPERATOR_NAME", StringUtils.CHAR_PERCENT + param.getOperatorName() + StringUtils.CHAR_PERCENT); + } + //缁撴潫鏃堕棿 + if (param.getStopTimeStart() != null) { + sql.append(" and STOP_TIME >=:stopTimeStart "); + paramts.put("stopTimeStart", param.getStopTimeStart() * 1000000); + } + if (param.getStopTimeEnd() != null) { + sql.append(" and STOP_TIME <:stopTimeEnd "); + paramts.put("stopTimeEnd", param.getStopTimeEnd() * 1000000 + 240000); + } + + sql.append(" ORDER BY CREATE_TIME DESC "); + + return selectSplit(sql.toString(), paramts, param.getPageNum(), param.getPageSize(), new MapRowMapper()); + } + } -- Gitblit v1.9.1