低值易耗品管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
futian.liu
2023-12-15 b268fd73f060108b8214ed1afcbbf03480435f3a 
 consum-base/src/main/java/com/consum/base/service/impl/LWhFormScrappedServiceImpl.java


@@ -1,10 +1,10 @@


package com.consum.base.service.impl;




import java.util.ArrayList;


import java.util.Arrays;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.Optional;


import java.util.stream.Collectors;




import org.apache.commons.compress.utils.Lists;


@@ -24,17 +24,19 @@


import com.consum.base.pojo.LWhFormScrappedGoodsInfoParam;


import com.consum.base.pojo.LWhFormScrappedGoodsModelParams;


import com.consum.base.pojo.LWhFormScrappedParam;


import com.consum.base.pojo.dto.GoodModelInfoDTO;


import com.consum.base.pojo.excel.ScrappedInfoExcelTemplate;


import com.consum.base.pojo.query.LWhFormScrappedQry;


import com.consum.base.pojo.response.FormScrappedGoodsDetailVO;


import com.consum.base.pojo.response.FormScrappedGoodsVO;


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.LWhFormScrappedExtendVO;


import com.consum.base.service.BaseGoodsModelsService;


import com.consum.base.service.BaseGoodsTemplateService;


import com.consum.base.service.BaseWarehouseService;


import com.consum.base.service.FinSysTenantDepartmentService;


import com.consum.base.service.LWhFormScrappedGoodsService;


import com.consum.base.service.LWhFormScrappedService;


import com.consum.base.service.LWhGoodsService;


import com.consum.base.service.SDictDataServiceImpl;


@@ -48,6 +50,7 @@


import com.consum.model.po.SDictData;


import com.iplatform.model.po.S_user_core;


import com.walker.db.page.GenericPager;


import com.walker.infrastructure.utils.DateUtils;


import com.walker.infrastructure.utils.StringUtils;


import com.walker.jdbc.service.BaseServiceImpl;




@@ -68,7 +71,7 @@


    @Autowired


    private LWhGoodsService lWhGoodsService;


    @Autowired


    private LWhFormScrappedGoodsServiceImpl scrappedGoodsService;


    private LWhFormScrappedGoodsService scrappedGoodsService;


    @Autowired


    private SDictDataServiceImpl sDictDataService;


    @Autowired


@@ -124,6 +127,7 @@


        lWhFormScrapped.setOperatorName(sysInfo.getUserName());


        lWhFormScrapped.setDealTime(param.getDealTime());


        lWhFormScrapped.setStates(0);


        lWhFormScrapped.setCreateTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));


        lWhFormScrapped.setUploadFiles(param.getUploadFiles());


        // 根据部门id查询部门


        FinSysTenantDepartment department = this.departmentService.getById(sysInfo.getSysDeptId());


@@ -174,8 +178,9 @@


                LWhFormScrappedGoods scrappedGoods = new LWhFormScrappedGoods();


                scrappedGoods.setId(IdUtil.generateId());


                // 根据物品型号查询物品库存


                List<Long> warehouseIds = new ArrayList<>(Arrays.asList(warehouseId));


                int goodsNum =


                    lWhGoodsService.queryGoodsModelNum(0, warehouseId, scrappedGoods.getBaseGoodsModelsId(), 1, null);


                    lWhGoodsService.queryGoodsModelNum(0, warehouseIds, scrappedGoods.getBaseGoodsModelsId(), 1, null);


                if (params.getCounts() > goodsNum) {


                    log.error("报废数量大于库存数量");


                    return 0;


@@ -199,7 +204,7 @@


                scrappedGoodsList.add(scrappedGoods);


            }


            int flag2 = this.scrappedGoodsService.insertBatch(scrappedGoodsList);


            if (flag2 != scrappedGoodsList.size()) {


            if (flag2 == 0) {


                log.error("新增报废单物品记录 失败");


                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();


                return 0;


@@ -272,31 +277,23 @@


        if (lWhFormScrapped != null) {


            BeanUtils.copyProperties(lWhFormScrapped, scrappedExtend);


        }


        // 2.查询报废单


        List<LWhFormScrappedGoods> scrappedGoodsList = this.scrappedGoodsService.getByFormScrappedId(id);


        // 2.查询报废单商品信息


        List<GoodModelInfoDTO> scrappedGoodsInfoList = scrappedGoodsService.getScrappedGoodsByScrappedId(id);


        // 通过baseGoodsTemplateId 进行分组


        Map<Long, List<LWhFormScrappedGoods>> map =


            scrappedGoodsList.stream().collect(Collectors.groupingBy(LWhFormScrappedGoods::getBaseGoodsTemplateId));


        Map<Long, List<GoodModelInfoDTO>> map =


            scrappedGoodsInfoList.stream().collect(Collectors.groupingBy(GoodModelInfoDTO::getBaseGoodsTemplateId));


        // 循环map的key和value


        List<FormScrappedGoodsVO> scrappedGoodsVO = Lists.newArrayList();


        for (Map.Entry<Long, List<LWhFormScrappedGoods>> entry : map.entrySet()) {


            Long baseGoodsTemplateId = entry.getKey();


            List<LWhFormScrappedGoods> goodsList = entry.getValue();


            LWhFormScrappedGoods lWhFormScrappedGoods = goodsList.stream().findFirst().get();


            FormScrappedGoodsVO formScrappedGoodsVO = new FormScrappedGoodsVO();


            formScrappedGoodsVO.setBaseGoodsTemplateId(baseGoodsTemplateId);


            formScrappedGoodsVO.setGoodsName(lWhFormScrappedGoods.getGoodsTemplateName());




            String sql = "select CATEGORY_NAME from base_goods_template where id = :id";


            Map<String, Object> param = new HashMap<>();


            param.put("id", baseGoodsTemplateId);


            List<Map<String, Object>> goodTemplate = this.select(sql, param, new MapperUtil());


            if (!CollectionUtils.isEmpty(goodTemplate)) {


                Optional<Map<String, Object>> first = goodTemplate.stream().findFirst();


                Map<String, Object> objectMap = first.get();


                formScrappedGoodsVO.setCategoryName(objectMap.get("categoryName").toString());


        List<GoodsTemplateInfoVO> scrappedGoodsVO = Lists.newArrayList();


        for (Map.Entry<Long, List<GoodModelInfoDTO>> entry : map.entrySet()) {


            List<GoodModelInfoDTO> goodsList = entry.getValue();


            GoodModelInfoDTO goodModelInfoDTO = goodsList.stream().findFirst().orElse(null);


            GoodsTemplateInfoVO goodsTemplateInfoVO = new GoodsTemplateInfoVO();


            if (goodModelInfoDTO != null) {


                goodsTemplateInfoVO.setId(goodModelInfoDTO.getId());


                goodsTemplateInfoVO.setGoodsName(goodModelInfoDTO.getBaseGoodsName());


                goodsTemplateInfoVO.setCategoryName(goodModelInfoDTO.getCategoryName());


                goodsTemplateInfoVO.setId(goodModelInfoDTO.getId());


            }




            List<GoodsModelVO> goodsModelList = Lists.newArrayList();


            goodsList.forEach(item -> {


                GoodsModelVO goodsModelVO = new GoodsModelVO();


@@ -308,8 +305,8 @@


                goodsModelVO.setScrappedName(item.getScrappedName());


                goodsModelList.add(goodsModelVO);


            });


            formScrappedGoodsVO.setModels(goodsModelList);


            scrappedGoodsVO.add(formScrappedGoodsVO);


            goodsTemplateInfoVO.setModels(goodsModelList);


            scrappedGoodsVO.add(goodsTemplateInfoVO);




        }


        scrappedExtend.setScrappedGoods(scrappedGoodsVO);