低值易耗品管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
cy
2023-11-29 2b20f8284d8c59549ebcb9dabca36b5bd5b35702 
 consum-base/src/main/java/com/consum/base/service/LWhFormTransferServiceImpl.java


@@ -14,16 +14,7 @@


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


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


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


import com.consum.model.po.BaseGoodsModels;


import com.consum.model.po.BaseWarehouse;


import com.consum.model.po.FinSysTenant;


import com.consum.model.po.FinSysTenantUser;


import com.consum.model.po.LWhFormOutput;


import com.consum.model.po.LWhFormTransfer;


import com.consum.model.po.LWhGoodsRecord;


import com.consum.model.po.LWhProcureModel;


import com.consum.model.po.LWhProcureModelUser;


import com.consum.model.po.LWhProcureModelUserRecord;


import com.consum.model.po.*;


import com.consum.model.vo.LWhFormOutputVo;


import com.consum.model.vo.LWhGoodsRecordVo;


import com.iplatform.model.po.S_user_core;


@@ -31,16 +22,14 @@


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 org.apache.commons.compress.utils.Lists;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.transaction.interceptor.TransactionAspectSupport;


import org.springframework.util.CollectionUtils;




import java.util.*;




/**


 * @Description 调拨管理


@@ -72,6 +61,8 @@


    private LWhProcureModelUserServiceImpl lWhProcureModelUserService;


    @Autowired


    private LWhProcureModelUserRecordServiceImpl lWhProcureModelUserRecordService;


    @Autowired


    private BaseWarehouseManagerServiceImpl baseWarehouseManagerService;




    private static String QUERY_FORM_TRANSFER_LIST = "SELECT ft.* FROM l_wh_form_transfer ft "


        + "left join L_WH_PROCURE_MODEL pm on pm.BUSINESS_ID = ft.id "


@@ -95,8 +86,16 @@


        // 单据类型。0仓库调拨；1部门分发；2部门物品回退


        // TODO 枚举字典


        lWhFormTransfer.setBusinessType(businessType);


        CodeGeneratorEnum codeGeneratorEnum = null;


        if (businessType == 0){


            codeGeneratorEnum = CodeGeneratorEnum.Transfer;


        } else if (businessType == 1){


            codeGeneratorEnum = CodeGeneratorEnum.Distribute;


        } else if (businessType == 2){


            codeGeneratorEnum = CodeGeneratorEnum.GOBACK;


        }




        lWhFormTransfer.setBusinessFormCode(codeGeneratorService.createBusinessFormCode(CodeGeneratorEnum.Transfer));


        lWhFormTransfer.setBusinessFormCode(codeGeneratorService.createBusinessFormCode(codeGeneratorEnum));




        Long warehouseId = param.getInWarehouseId();


        // 调拨类型单据


@@ -117,11 +116,40 @@


        //当业务类型为部门分发时 添加部门分发记录和使用人


        if (businessType == 1) {


            //部门分发类型 出库仓库类型0机构1部门


            // TODO 出库业务类型 联系电话


            lWhFormTransfer.setOutWarehouseType(1);


            //lWhFormTransfer.setOutOperatorId();


            lWhFormTransfer.setOutOperatorName(param.getOperatorName());


            lWhFormTransfer.setOutputTime(param.getCreateTime());


            //从当前登录库管人从库中出库，入到所选部门的下




            //查询库管员信息和相关仓库


            Long id = sysInfo.getId();


            BaseWarehouseManager manager = new BaseWarehouseManager();


            manager.setManagerId(id);


            List<BaseWarehouseManager> managerList = baseWarehouseManagerService.select(manager);


            if (CollectionUtils.isEmpty(managerList)) {


                log.error("该用户不是库管员");


                throw new Exception("该用户不是库管员");


            }


            Optional<BaseWarehouseManager> first = managerList.stream().findFirst();


            if (first.isPresent()) {


                BaseWarehouseManager baseWarehouseManager = first.get();


                Long baseWarehouseId = baseWarehouseManager.getBaseWarehouseId();


                BaseWarehouse baseWarehouse = new BaseWarehouse();


                baseWarehouse.setId(baseWarehouseId);


                BaseWarehouse warehouse = baseWarehouseService.get(baseWarehouse);




                lWhFormTransfer.setInWarehouseType(1);


                lWhFormTransfer.setInWarehouseId(param.getDepartmentId());


                lWhFormTransfer.setInWarehouseName(param.getDepartmentName());


                lWhFormTransfer.setInOperatorName(param.getOperatorName());


                lWhFormTransfer.setInTime(param.getCreateTime());




                lWhFormTransfer.setOutWarehouseType(0);


                lWhFormTransfer.setOutWarehouseId(warehouse.getId());


                lWhFormTransfer.setOutWarehouseName(warehouse.getWarehouseName());




                lWhFormTransfer.setOutOperatorId(sysInfo.getId());


                lWhFormTransfer.setOutOperatorName(sysInfo.getUserName());


                lWhFormTransfer.setOutputTime(param.getCreateTime());


                lWhFormTransfer.setTel(param.getTel());


            }


        }




        //根据机构id查询调拨机构


@@ -254,7 +282,7 @@


        }


        //状态


        if (param.getStates() != null) {


            sql.append(" and states =:states ");


            sql.append(" and ft.states =:states ");


            paramts.put("states", param.getStates());


        }


        //创建人


@@ -298,6 +326,7 @@


        LWhFormTransfer lWhFormTransfer = this.get(new LWhFormTransfer(id));


        if (lWhFormTransfer != null) {


            BeanUtils.copyProperties(lWhFormTransfer, result);


            result.setDepartmentName(lWhFormTransfer.getInWarehouseName());


        }




        String sql = "SELECT bgt.id, CATEGORY_ID, CATEGORY_NAME, GOODS_NAME,bgt.CLASSIFICATION type "


@@ -306,6 +335,9 @@


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


        paramMap.put("id", result.getId());


        List<Map<String, Object>> procureModelList = lWhFormOutputService.select(sql, paramMap, new MapperUtil());




        String queryRecord = "SELECT * FROM l_wh_procure_model_user_record where TRANS_BUSINESS_ID = :id order by DEAL_TIME desc limit 1";


        LWhProcureModelUserRecord lWhProcureModelUserRecord = lWhProcureModelUserRecordService.get(queryRecord, paramMap, new LWhProcureModelUserRecord());


        List<FormTransferGoodsVO> formTransferGoods = Lists.newArrayList();


        for (Map<String, Object> map : procureModelList) {


            FormTransferGoodsVO procureTemplateInfoVO = MapUtils.convertMapToObj(map, FormTransferGoodsVO.class);


@@ -325,6 +357,7 @@


                    Long procureModelId = goodsModelVO.getId();


                    LWhProcureModelUser lWhProcureModelUser = new LWhProcureModelUser();


                    lWhProcureModelUser.setWhProcureModelId(procureModelId);


                    lWhProcureModelUser.setProcureModelUserRecordId(lWhProcureModelUserRecord.getId());


                    List<LWhProcureModelUser> procureModelUserList = this.lWhProcureModelUserService.select(lWhProcureModelUser);


                    if (!CollectionUtils.isEmpty(procureModelUserList)) {


                        List<DepartGoodsUseInfo> departGoodsUseInfoList = Lists.newArrayList();


@@ -340,8 +373,6 @@


                        });


                        goodsModelVO.setUseInfo(departGoodsUseInfoList);


                    }


                    // TODO 部门名称


//                result.setDepartmentName();




                }


                goodsModelVOList.add(goodsModelVO);


@@ -410,9 +441,10 @@


        HashMap<String, Object> paramts = new HashMap<>();


        StringBuilder sql = new StringBuilder(


            "SELECT ft.id,ft.BUSINESS_FORM_CODE,bgt.GOODS_NAME,bgt.CLASSIFICATION type,bgm.id goodsModelId,bgm.MODEL_NAME goodsModelName,pm.COUNTS goodsCount,fst.`name` tenantName,"


                + "fstd.NAME departmentName,ft.OPERATOR_ID,ft.CREATE_TIME FROM l_wh_form_transfer ft "


                + "ft.IN_WAREHOUSE_NAME departmentName,ft.OPERATOR_ID,ft.CREATE_TIME,ft.OPERATOR_NAME FROM l_wh_form_transfer ft "


                + "inner JOIN l_wh_procure_model pm ON ft.ID = pm.BUSINESS_ID " + "inner JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID "


                + "inner JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID " + "inner JOIN fin_sys_tenant_user fstu ON fstu.id = ft.OPERATOR_ID "


                + "inner JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID "


                + "inner JOIN fin_sys_tenant_user fstu ON fstu.id = ft.OPERATOR_ID "


                + "inner JOIN fin_sys_tenant_department fstd ON fstu.SYS_DEPT_ID = fstd.ID "


                + "inner JOIN fin_sys_tenant fst ON fst.id = fstd.TENANT_ID where ft.BUSINESS_TYPE =1 ");


        //单号