From b4adff68a07b783fc90da1c9370d8be5f383e700 Mon Sep 17 00:00:00 2001 From: 黎星凯 <13949086503@163.com> Date: 星期三, 08 五月 2024 13:46:34 +0800 Subject: [PATCH] 20240528修改: bug41、42、43修改 领用单(分发单),调拨单,流程优化 --- consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java | 246 +++++++++++++++++++++++++++++------------------- 1 files changed, 148 insertions(+), 98 deletions(-) diff --git a/consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java b/consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java index 931b356..b8d85e1 100644 --- a/consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java +++ b/consum-base/src/main/java/com/consum/base/controller/LWhFormOutputController.java @@ -1,38 +1,59 @@ package com.consum.base.controller; -import com.consum.base.BaseController; -import com.consum.base.core.utils.CommonUtil; -import com.consum.base.core.utils.MapUtils; -import com.consum.base.pojo.LWhFormOutputInsertParam; -import com.consum.base.pojo.query.LWhFormOutputQry; -import com.consum.base.pojo.response.FormOutputGoodsVO; -import com.consum.base.pojo.response.FormOutputTemplateInfoVO; -import com.consum.base.pojo.response.FormOutputVO; -import com.consum.base.pojo.response.GoodsModelVO; -import com.consum.base.pojo.response.LWhFormOutputExtendVO; -import com.consum.base.service.LWhFormOutputServiceImpl; -import com.consum.base.service.LWhGoodsService; -import com.consum.base.service.LWhProcureModelService; -import com.consum.model.po.LWhFormOutput; -import com.iplatform.model.po.S_user_core; -import com.walker.db.page.GenericPager; -import com.walker.infrastructure.utils.CollectionUtils; -import com.walker.web.ResponseValue; -import io.swagger.annotations.Api; -import io.swagger.annotations.ApiImplicitParam; -import io.swagger.annotations.ApiImplicitParams; -import io.swagger.annotations.ApiOperation; +import java.io.InputStream; import java.lang.reflect.Field; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.Map.Entry; +import java.util.Optional; +import java.util.stream.Collectors; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletResponse; + import org.apache.commons.compress.utils.Lists; +import org.apache.poi.hssf.usermodel.HSSFWorkbook; +import org.apache.poi.ss.usermodel.Workbook; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.core.io.ClassPathResource; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; + +import com.consum.base.BaseController; +import com.consum.base.core.utils.CommonUtil; +import com.consum.base.core.utils.CurrencyUtil; +import com.consum.base.core.utils.PageUtil; +import com.consum.base.pojo.LWhFormOutputParam; +import com.consum.base.pojo.dto.GoodModelInfoDTO; +import com.consum.base.pojo.excel.OutputExcelTemplate; +import com.consum.base.pojo.query.LWhFormOutputQry; +import com.consum.base.pojo.response.FormOutputVO; +import com.consum.base.pojo.response.GoodsModelVO; +import com.consum.base.pojo.response.GoodsTemplateCountVO; +import com.consum.base.pojo.response.GoodsTemplateInfoVO; +import com.consum.base.pojo.response.LWhFormOutputExtendVO; +import com.consum.base.service.LWarehouseFlowService; +import com.consum.base.service.LWhFormOutputService; +import com.consum.base.service.LWhProcureModelService; +import com.consum.model.po.FinSysTenantUser; +import com.consum.model.po.LWhFormOutput; +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.web.ResponseValue; + +import cn.afterturn.easypoi.excel.ExcelExportUtil; +import cn.afterturn.easypoi.excel.entity.TemplateExportParams; +import cn.hutool.core.util.ReflectUtil; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; /** * @Description 鍑哄簱鍗� @@ -45,11 +66,11 @@ public class LWhFormOutputController extends BaseController { @Autowired - private LWhFormOutputServiceImpl lWhFormOutputService; + private LWhFormOutputService lWhFormOutputService; @Autowired private LWhProcureModelService lWhProcureModelService; - @Autowired - private LWhGoodsService lWhGoodsService; + @Resource + private LWarehouseFlowService lWarehouseFlowServiceImpl; /** * @Description 鏂板鍑哄簱鍗� @@ -57,12 +78,11 @@ * @Date 2023/10/27 */ @ApiOperation(value = "鏂板鍑哄簱鍗�", notes = "鏂板鍑哄簱鍗�") - @ApiImplicitParams({ - @ApiImplicitParam(name = "param", value = "鍑哄簱鍗曞疄浣�", required = true, dataType = "LWhFormOutputInsertParam", paramType = "body") - }) + @ApiImplicitParams({@ApiImplicitParam(name = "param", value = "鍑哄簱鍗曞疄浣�", dataType = "lWhFormOutputParam", + dataTypeClass = LWhFormOutputParam.class, paramType = "body")}) @PostMapping("/add") public ResponseValue add() { - LWhFormOutputInsertParam param = CommonUtil.getObjFromReqBody(LWhFormOutputInsertParam.class); + LWhFormOutputParam param = CommonUtil.getObjFromReqBody(LWhFormOutputParam.class); S_user_core currentUser = this.getCurrentUser(); if (currentUser == null) { return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�"); @@ -78,7 +98,8 @@ * @Description 鍒楄〃鏌ヨ */ @ApiOperation(value = "鍒楄〃鏌ヨ", notes = "鍒楄〃鏌ヨ") - @ApiImplicitParam(name = "param", value = "鍑哄簱鍗曞疄浣�", required = true, dataType = "LWhFormOutputParam", paramType = "query") + @ApiImplicitParam(name = "param", value = "鍑哄簱鍗曞疄浣�", required = true, dataType = "LWhFormOutputParam", + paramType = "query") @GetMapping("/list") public ResponseValue queryFormOutputList() { LWhFormOutputQry param = CommonUtil.getObjFromReq(LWhFormOutputQry.class); @@ -86,42 +107,34 @@ if (currentUser == null) { return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�"); } - + /*褰撳墠鐧诲綍浜哄彧鑳界湅鍒拌嚜宸辨満鏋勪笅鐨勫垪琛�*/ + FinSysTenantUser sysInfo = this.getSysInfo(); + String tenantId = sysInfo.getTenantId(); + if (param.getAgencyId() == null) { + param.setAgencyId(Long.valueOf(tenantId)); + } GenericPager genericPager = lWhFormOutputService.queryFormOutputList(param); List<LWhFormOutput> data = genericPager.getDatas(); List<FormOutputVO> resultList = Lists.newArrayList(); if (!CollectionUtils.isEmpty(data)) { data.forEach(item -> { - // 鏌ヨ鍨嬪彿鏁伴噺 FormOutputVO formOutputVO = new FormOutputVO(); BeanUtils.copyProperties(item, formOutputVO); - List<FormOutputTemplateInfoVO> procureTemplateInfoList = Lists.newArrayList(); - - // 鏌ヨ鍨嬪彿鏁伴噺 - String sql = "SELECT bgt.id,bgm.GOODS_TEMPLATES_ID,GOODS_NAME,sum( counts ) count FROM " - + "l_wh_procure_model pm LEFT JOIN base_goods_models bgm ON pm.BASE_GOODS_MODELS_ID = bgm.id " - + "LEFT JOIN base_goods_template bgt ON bgm.GOODS_TEMPLATES_ID = bgt.id " - + "WHERE pm.BUSINESS_ID =:id GROUP BY bgm.GOODS_TEMPLATES_ID"; - Map<String, Object> paramMap = new HashMap<>(); - paramMap.put("id", item.getId()); - List<Map<String, Object>> procureModelList = lWhProcureModelService.select(sql, paramMap); - for (Map<String, Object> map : procureModelList) { - FormOutputTemplateInfoVO procureTemplateInfoVO = MapUtils.convertMapToObj(MapUtils.toReplaceKeyLow(map), FormOutputTemplateInfoVO.class); - procureTemplateInfoList.add(procureTemplateInfoVO); - } - formOutputVO.setFormOutputTemplateInfoList(procureTemplateInfoList); + // 鏌ヨ鐗╁搧鍨嬪彿缁熻鏁伴噺 + List<GoodsTemplateCountVO> goodsTemplateCount = + lWhProcureModelService.getGoodsTemplateCountByBusinessId(item.getId()); + formOutputVO.setFormOutputTemplateInfoList(goodsTemplateCount); resultList.add(formOutputVO); }); } try { Field fieldDatas = GenericPager.class.getDeclaredField("datas"); - fieldDatas.setAccessible(true); - fieldDatas.set(genericPager, resultList); + ReflectUtil.setFieldValue(genericPager, fieldDatas, resultList); } catch (Exception e) { - e.printStackTrace(); + logger.error("鏌ヨ鍑哄簱鍗曞垪琛ㄥけ璐�", e); } return ResponseValue.success(genericPager); } @@ -132,76 +145,113 @@ @ApiOperation(value = "鏍规嵁id鏌ヨ璇︽儏", notes = "鏍规嵁id鏌ヨ璇︽儏") @ApiImplicitParam(name = "id", value = "鍑哄簱鍗昳d", required = true, dataType = "Long", paramType = "query") @GetMapping("/detail") - public ResponseValue getById(Long id) throws IllegalAccessException { + public ResponseValue getById(Long id) throws Exception { if (id == null) { return ResponseValue.error("鍑哄簱鍗昳d涓虹┖"); } LWhFormOutput lWhFormOutput = lWhFormOutputService.get(new LWhFormOutput(id)); LWhFormOutputExtendVO lWhFormOutputExtendVO = new LWhFormOutputExtendVO(); BeanUtils.copyProperties(lWhFormOutput, lWhFormOutputExtendVO); + lWhFormOutputExtendVO.setDoc(lWhFormOutput.getOutputDoc()); - String sql = "SELECT bgt.id, CATEGORY_ID, CATEGORY_NAME, GOODS_NAME " - + "FROM l_wh_procure_model pm LEFT JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID " - + "LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID " - + "WHERE pm.BUSINESS_ID =:id GROUP BY bgt.id "; - Map<String, Object> paramMap = new HashMap<>(); - paramMap.put("id", lWhFormOutputExtendVO.getId()); - List<Map<String, Object>> procureModelList = lWhFormOutputService.select(sql, paramMap); - List<FormOutputGoodsVO> fromOutputGoods = Lists.newArrayList(); - for (Map<String, Object> map : procureModelList) { - FormOutputGoodsVO procureTemplateInfoVO = MapUtils.convertMapToObj(MapUtils.toReplaceKeyLow(map), FormOutputGoodsVO.class); - - // 鏌ヨ鍨嬪彿鏁伴噺 - List<GoodsModelVO> goodsModelVOList = Lists.newArrayList(); - String sql2 = "SELECT pm.id,pm.BASE_GOODS_MODELS_NAME,bgm.UNIT,COUNTS,total_amount " - + "FROM l_wh_procure_model pm LEFT JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID " - + "LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID " - + "WHERE pm.BUSINESS_ID =:id"; - List<Map<String, Object>> modelList = lWhFormOutputService.select(sql2, paramMap); - modelList.forEach(item -> { - GoodsModelVO goodsModelVO = MapUtils.convertMapToObj(MapUtils.toReplaceKeyLow(item), GoodsModelVO.class); - goodsModelVOList.add(goodsModelVO); - }); - procureTemplateInfoVO.setModels(goodsModelVOList); - fromOutputGoods.add(procureTemplateInfoVO); + List<GoodModelInfoDTO> goodsModelList = + lWhProcureModelService.getGoodsModelListByBusinessId(lWhFormOutputExtendVO.getId(), null); + if (CollectionUtils.isEmpty(goodsModelList)) { + return ResponseValue.success(lWhFormOutputExtendVO); } - lWhFormOutputExtendVO.setFromOutputGoods(fromOutputGoods); + Map<Long, List<GoodModelInfoDTO>> collect = + goodsModelList.stream().collect(Collectors.groupingBy(GoodModelInfoDTO::getBaseGoodsTemplateId)); + List<GoodsTemplateInfoVO> goodsTemplateInfoList = Lists.newArrayList(); + for (Map.Entry<Long, List<GoodModelInfoDTO>> entry : collect.entrySet()) { + GoodsTemplateInfoVO goodsTemplateInfoVO = getFormOutputGoodsVO(entry); + goodsTemplateInfoList.add(goodsTemplateInfoVO); + } + lWhFormOutputExtendVO.setFromOutputGoods(goodsTemplateInfoList); return ResponseValue.success("鏌ヨ鎴愬姛!", lWhFormOutputExtendVO); } - /** - * @Description 鏍规嵁浠撳簱id鍜屽瀷鍙穒d 鏌ヨ搴撳瓨 - * @Author 鍗㈠簡闃� - * @Date 2023/11/2 - */ - @ApiOperation(value = "鏍规嵁浠撳簱id鍜屽瀷鍙穒d 鏌ヨ搴撳瓨", notes = "鏍规嵁浠撳簱id鍜屽瀷鍙穒d 鏌ヨ搴撳瓨") - @ApiImplicitParams({ - @ApiImplicitParam(name = "warehouseId", value = "浠撳簱id", required = true, dataType = "Long", paramType = "query"), - @ApiImplicitParam(name = "baseGoodsModelsId", value = "鍨嬪彿id", required = true, dataType = "Long", paramType = "query") - }) - @GetMapping("/select/number") - public ResponseValue selectNumber(Long warehouseId, Long baseGoodsModelsId) { - if (warehouseId == null || baseGoodsModelsId == null) { - return ResponseValue.error("鍙傛暟閿欒"); + private GoodsTemplateInfoVO getFormOutputGoodsVO(Entry<Long, List<GoodModelInfoDTO>> entry) { + Long baseGoodsTemplateId = entry.getKey(); + List<GoodModelInfoDTO> goodModelInfoDTOS = entry.getValue(); + GoodModelInfoDTO goodModelInfoDTO = goodModelInfoDTOS.stream().findFirst().orElse(null); + GoodsTemplateInfoVO goodsTemplateInfoVO = new GoodsTemplateInfoVO(); + if (goodModelInfoDTO != null) { + goodsTemplateInfoVO.setId(baseGoodsTemplateId); + goodsTemplateInfoVO.setCategoryName(goodModelInfoDTO.getCategoryName()); + goodsTemplateInfoVO.setGoodsName(goodModelInfoDTO.getBaseGoodsModelsName()); } - int num = this.lWhGoodsService.queryGoodsModelNum(0, warehouseId, baseGoodsModelsId, (short) 1, null); - return ResponseValue.success(num); + List<GoodsModelVO> goodsModelList = Lists.newArrayList(); + for (GoodModelInfoDTO goodModelInfo : goodModelInfoDTOS) { + GoodsModelVO goodsModelVO = new GoodsModelVO(); + goodsModelVO.setId(goodModelInfo.getId()); + goodsModelVO.setBaseGoodsModelsName(goodModelInfo.getBaseGoodsModelsName()); + goodsModelVO.setUnit(goodModelInfo.getUnit()); + goodsModelVO.setCounts(goodModelInfo.getCounts()); + goodsModelVO.setTotalAmount(CurrencyUtil.convertFenToYuan(goodModelInfo.getTotalAmount())); + goodsModelList.add(goodsModelVO); + } + goodsTemplateInfoVO.setModels(goodsModelList); + return goodsTemplateInfoVO; } @ApiOperation(value = "鏌ヨ鍑哄簱鍗曡鎯呮槑缁�", notes = "鏌ヨ鍑哄簱鍗曡鎯呮槑缁�") - @ApiImplicitParam(name = "formOutputQry", value = "鍑哄簱鍗曡鎯呮煡璇㈡潯浠�", required = true, dataType = "LWhFormOutputQry", paramType = "query") - @GetMapping("detail/list") + @ApiImplicitParam(name = "formOutputQry", value = "鍑哄簱鍗曡鎯呮煡璇㈡潯浠�", required = true, dataType = "LWhFormOutputQry", + paramType = "query") + @GetMapping("/detail/list") public ResponseValue queryFormOutputDetailList() { LWhFormOutputQry formOutputQry = CommonUtil.getObjFromReq(LWhFormOutputQry.class); - S_user_core currentUser = this.getCurrentUser(); + FinSysTenantUser currentUser = this.getSysInfo(); if (currentUser == null) { return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�"); } - - GenericPager genericPager = lWhFormOutputService.queryFormOutputDetailList(formOutputQry); + formOutputQry.setAgencyId(Long.valueOf(currentUser.getTenantId())); + PageUtil genericPager = lWarehouseFlowServiceImpl.queryAllBusinessFlow(formOutputQry); return ResponseValue.success(genericPager); } -} + @ApiOperation(value = "鍑哄簱鍗曞鍑�", notes = "鍑哄簱鍗曞鍑�") + @ApiImplicitParam(name = "id", value = "鍑哄簱鍗昳d", required = true, dataType = "Long", paramType = "query") + @GetMapping("/list/export") + public ResponseValue export(Long id, HttpServletResponse response) throws Exception { + FinSysTenantUser sysInfo = this.getSysInfo(); + if (sysInfo == null) { + throw new RuntimeException("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�"); + } + ClassPathResource classPathResource = new ClassPathResource("import/鍑哄簱鍗�.xls"); + // 鑾峰彇鏂囦欢杈撳叆娴� + InputStream inputStream = classPathResource.getInputStream(); + Workbook wb = new HSSFWorkbook(inputStream); + TemplateExportParams params = new TemplateExportParams(); + params.setTemplateWb(wb); + params.setHeadingStartRow(2); + List<OutputExcelTemplate> exportList = lWhFormOutputService.getExportList(id); + + if (CollectionUtils.isEmpty(exportList)) { + throw new RuntimeException("鏁版嵁涓虹┖"); + } + int countNum = + exportList.stream().filter(item -> item.getNum() != null).mapToInt(OutputExcelTemplate::getNum).sum(); + double totalAmount = exportList.stream().filter(item -> item.getTotalAmount() != null) + .mapToDouble(OutputExcelTemplate::getAmount).sum(); + Optional<OutputExcelTemplate> first = exportList.stream().findFirst(); + OutputExcelTemplate templateExcelExport = first.get(); + String businessFormCode = templateExcelExport.getBusinessFormCode(); + Long createTime = templateExcelExport.getCreateTime(); + String operatorName = templateExcelExport.getOperatorName(); + + Map<String, Object> map = new HashMap<>(); + map.put("code", businessFormCode); + map.put("date", DateUtils.toShowDate(createTime)); + map.put("name", operatorName); + map.put("countNum", countNum); + map.put("totalAmount", totalAmount); + + Workbook workbook = ExcelExportUtil.exportExcel(params, OutputExcelTemplate.class, exportList, map); + String filePath = downLoadExcel("鍑哄簱鍗�", workbook); + return ResponseValue.success("瀵煎嚭鎴愬姛", filePath); + + } + +} -- Gitblit v1.9.1