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


@@ -1,5 +1,18 @@


package com.consum.base.service.impl;




import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.Optional;




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 com.consum.base.core.CodeGeneratorEnum;


import com.consum.base.core.CodeGeneratorService;


import com.consum.base.core.utils.CurrencyUtil;


@@ -23,7 +36,7 @@


import com.consum.base.service.LWhFormTransferService;


import com.consum.base.service.LWhGoodsService;


import com.consum.base.service.LWhProcureModelService;


import com.consum.base.service.LWhProcureModelUserRecordServiceImpl;


import com.consum.base.service.LWhProcureModelUserRecordService;


import com.consum.base.service.LWhProcureModelUserServiceImpl;


import com.consum.model.po.BaseWarehouse;


import com.consum.model.po.BaseWarehouseManager;


@@ -36,17 +49,6 @@


import com.walker.db.page.GenericPager;


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




/**


 * @Description 调拨管理


@@ -73,15 +75,14 @@


    @Autowired


    private LWhProcureModelUserServiceImpl lWhProcureModelUserService;


    @Autowired


    private LWhProcureModelUserRecordServiceImpl lWhProcureModelUserRecordService;


    private LWhProcureModelUserRecordService lWhProcureModelUserRecordService;


    @Autowired


    private BaseWarehouseManagerService 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 "


        + "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 1 = 1 ";




    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 "


            + "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 1 = 1 ";




    /**


     * @Description 新增


@@ -89,9 +90,9 @@


     * @Date 2023/10/30


     */


    public long add(LWhFormTransferParam param, FinSysTenantUser sysInfo) throws Exception {


        //1.新增调拨单记录


        // 1.新增调拨单记录


        LWhFormTransfer lWhFormTransfer = new LWhFormTransfer();


        //调拨单id


        // 调拨单id


        long lWhFormTransferId = IdUtil.generateId();


        lWhFormTransfer.setId(lWhFormTransferId);




@@ -113,7 +114,7 @@


        Long warehouseId = param.getInWarehouseId();


        // 调拨类型单据


        if (businessType == 0) {


            //入库仓库为当前用户的默认仓库


            // 入库仓库为当前用户的默认仓库


            String tenantId = sysInfo.getTenantId();


            String tenantName = sysInfo.getTenantName();


            BaseWarehouse warehouse = baseWarehouseService.getDefaultWarehouseByAgencyId(Long.valueOf(tenantId));


@@ -126,12 +127,12 @@


            lWhFormTransfer.setInAgencyId(Long.valueOf(tenantId));


            lWhFormTransfer.setInAgencyName(tenantName);


        }


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


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


        if (businessType == 1) {


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


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


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


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




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


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


            Long id = sysInfo.getId();


            BaseWarehouseManager manager = new BaseWarehouseManager();


            manager.setManagerId(id);


@@ -165,7 +166,7 @@


            }


        }




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


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


        FinSysTenant finSysTenant = finSysTenantService.get(new FinSysTenant(param.getOutAgencyId()));


        if (finSysTenant == null) {


            log.error("调拨机构不存在");


@@ -175,7 +176,7 @@


        lWhFormTransfer.setOperatorId(sysInfo.getId());


        lWhFormTransfer.setOperatorName(sysInfo.getUserName());


        lWhFormTransfer.setCreateTime(param.getCreateTime());


        //0=待出库；1=待接收；2=已入库库:4=已撤销


        // 0=待出库；1=待接收；2=已入库库:4=已撤销


        lWhFormTransfer.setStates(0);


        lWhFormTransfer.setProcureDoc(param.getProcureDoc());




@@ -184,7 +185,7 @@


            log.error("新增调拨单失败");


        }




        //2.新增物品型号记录


        // 2.新增物品型号记录


        List<LWhFormTransferGoodsInfoParam> transferGoods = param.getTransferGoods();


        List<LWhProcureModel> modelList = new ArrayList<>();


        for (LWhFormTransferGoodsInfoParam transferGoodsInfo : transferGoods) {


@@ -196,7 +197,7 @@


                Long baseGoodsModelsId = model.getBaseGoodsModelsId();


                if (businessType == 0) {


                    lWhProcureModel.setBusinessType(2);


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


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


                    int goodsNum = this.lWhGoodsService.queryGoodsModelNum(0, warehouseId, baseGoodsModelsId, 1, null);


                    lWhProcureModel.setWorehouseCount(goodsNum);


                }


@@ -207,8 +208,9 @@


                lWhProcureModel.setUseCount(model.getCounts());


                lWhProcureModel.setBusinessId(lWhFormTransferId);


                lWhProcureModel.setBaseGoodsModelsId(baseGoodsModelsId);


                //根据型号id查询型号


                List<Map<String, Object>> baseGoodsModels = this.baseGoodsModelsService.queryGoodsModelInfo(baseGoodsModelsId);


                // 根据型号id查询型号


                List<Map<String, Object>> baseGoodsModels =


                    this.baseGoodsModelsService.queryGoodsModelInfo(baseGoodsModelsId);


                Map<String, Object> baseModelMap = baseGoodsModels.get(0);


                if (baseGoodsModels != null && !CollectionUtils.isEmpty(baseModelMap)) {


                    Object modelName = baseModelMap.get("modelName");


@@ -216,9 +218,9 @@


                }


                lWhProcureModel.setSupplier(transferGoodsInfo.getSupplier());




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


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


                // 单据类型 1 采购2 调拨 3出库4部门分发


                //部门分发类型


                // 部门分发类型


                if (businessType == 1 && "A".equals(baseModelMap.get("type"))) {


                    LWhProcureModelUserRecord lWhProcureModelUserRecord = new LWhProcureModelUserRecord();


                    lWhProcureModelUserRecord.setId(IdUtil.generateId());


@@ -261,7 +263,6 @@


        return lWhFormTransferId;


    }






    /**


     * @Description 列表查询


     * @Author 卢庆阳


@@ -270,7 +271,7 @@


    public GenericPager<LWhFormTransfer> queryFormTransferList(TransferQry param) {


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


        StringBuilder sql = new StringBuilder(QUERY_FORM_TRANSFER_LIST);


        //调拨单号


        // 调拨单号


        if (!StringUtils.isEmpty(param.getBusinessFormCode())) {


            sql.append(" and BUSINESS_FORM_CODE = :businessFormCode ");


            paramts.put("businessFormCode", param.getBusinessFormCode());


@@ -279,32 +280,33 @@


            sql.append("and ft.BUSINESS_TYPE = :businessType ");


            paramts.put("businessType", param.getQryType());


        }


        //物品名称


        // 物品名称


        if (!StringUtils.isEmpty(param.getGoodsTemplateName())) {


            sql.append("AND bgt.GOODS_NAME LIKE :goodsTemplateName ");


            paramts.put("goodsTemplateName", StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT);


            paramts.put("goodsTemplateName",


                StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT);


        }


        //调拨机构


        // 调拨机构


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


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


            paramts.put("OUT_AGENCY_ID", param.getOutAgencyId());


        }


        //接收机构


        // 接收机构


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


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


            paramts.put("IN_AGENCY_ID", param.getInAgencyId());


        }


        //状态


        // 状态


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


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


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


        }


        //创建人


        // 创建人


        if (!StringUtils.isEmpty(param.getOperatorName())) {


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


            paramts.put("OPERATOR_NAME", param.getOperatorName());


        }


        //申请时间


        // 申请时间


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


            sql.append(" and ft.CREATE_TIME >=:createTimeStart ");


            paramts.put("createTimeStart", param.getCreateTimeStart() * 1000000);


@@ -313,7 +315,7 @@


            sql.append(" and ft.CREATE_TIME <:createTimeEnd ");


            paramts.put("createTimeEnd", param.getCreateTimeEnd() * 1000000 + 240000);


        }


        //接收时间


        // 接收时间


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


            sql.append(" and IN_TIME >=:inTimeStart ");


            paramts.put("inTimeStart", param.getStartTime() * 1000000);


@@ -322,7 +324,7 @@


            sql.append(" and IN_TIME <:inTimeEnd ");


            paramts.put("inTimeEnd", param.getEndTime() * 1000000 + 240000);


        }


        //分发部门


        // 分发部门


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


            sql.append("and ft.IN_WAREHOUSE_ID = :inWarehouseId ");


            paramts.put("inWarehouseId", param.getInWarehouseId());


@@ -341,7 +343,7 @@


     */


    public LWHFromTransferExtendVO getById(Long id) {


        LWHFromTransferExtendVO result = new LWHFromTransferExtendVO();


        //1.查询调拨单


        // 1.查询调拨单


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


        if (lWhFormTransfer != null) {


            BeanUtils.copyProperties(lWhFormTransfer, result);


@@ -350,13 +352,16 @@




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


            + "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 ";


            + "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", 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());


        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);


@@ -365,22 +370,25 @@


            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 and bgt.id =:baseGoodsTemplateId";


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


                + "WHERE pm.BUSINESS_ID =:id and bgt.id =:baseGoodsTemplateId";


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


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


            goodsModelParamMap.put("baseGoodsTemplateId", baseGoodsTemplateId);


            List<Map<String, Object>> modelList = lWhFormOutputService.select(sql2, goodsModelParamMap, new MapperUtil());


            List<Map<String, Object>> modelList =


                lWhFormOutputService.select(sql2, goodsModelParamMap, new MapperUtil());


            modelList.forEach(item -> {


                GoodsModelVO goodsModelVO = MapUtils.convertMapToObj(item, GoodsModelVO.class);


                Integer businessType = result.getBusinessType();


                String type = procureTemplateInfoVO.getType();


                //部门分发需要查询使用信息


                // 部门分发需要查询使用信息


                if (businessType == 1 && "A".equals(type)) {


                    Long procureModelId = goodsModelVO.getId();


                    LWhProcureModelUser lWhProcureModelUser = new LWhProcureModelUser();


                    lWhProcureModelUser.setWhProcureModelId(procureModelId);


                    lWhProcureModelUser.setProcureModelUserRecordId(lWhProcureModelUserRecord.getId());


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


                    List<LWhProcureModelUser> procureModelUserList =


                        this.lWhProcureModelUserService.select(lWhProcureModelUser);


                    if (!CollectionUtils.isEmpty(procureModelUserList)) {


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


                        procureModelUserList.forEach(useInfo -> {


@@ -407,31 +415,19 @@


        return result;


    }






    /**


     * @Description 导出调拨出库单


     * @Author 卢庆阳


     * @Date 2023/10/31


     */


    public List<TransferExcelTemplate> export(Long id, Integer type) {


        String sql = "SELECT\n"


            + "\tft.BUSINESS_FORM_CODE,\n"


            + "\tft.OPERATOR_NAME,\n"


            + "\tft.CREATE_TIME,\n"


            + "\tft.IN_AGENCY_NAME,\n"


            + "\tft.OUT_AGENCY_NAME,\n"


            + "\tGOODS_NAME templateName,\n"


            + "\tpm.BASE_GOODS_MODELS_NAME baseModelName,\n"


            + "\tpm.COUNTS num,\n"


            + "\tpm.total_amount,\n"


            + "\tft.BEIZ1 remark\n"


            + "FROM\n"


            + "\tl_wh_form_transfer ft\n"


        String sql = "SELECT\n" + "\tft.BUSINESS_FORM_CODE,\n" + "\tft.OPERATOR_NAME,\n" + "\tft.CREATE_TIME,\n"


            + "\tft.IN_AGENCY_NAME,\n" + "\tft.OUT_AGENCY_NAME,\n" + "\tGOODS_NAME templateName,\n"


            + "\tpm.BASE_GOODS_MODELS_NAME baseModelName,\n" + "\tpm.COUNTS num,\n" + "\tpm.total_amount,\n"


            + "\tft.BEIZ1 remark\n" + "FROM\n" + "\tl_wh_form_transfer ft\n"


            + "\tINNER JOIN l_wh_procure_model pm ON ft.ID = pm.BUSINESS_ID\n"


            + "\tINNER JOIN base_goods_models bgm ON bgm.ID = pm.BASE_GOODS_MODELS_ID\n"


            + "\tINNER JOIN base_goods_template bgt ON bgt.ID = bgm.GOODS_TEMPLATES_ID\n"


            + "WHERE\n"


            + "\tft.id = :id";


            + "\tINNER JOIN base_goods_template bgt ON bgt.ID = bgm.GOODS_TEMPLATES_ID\n" + "WHERE\n" + "\tft.id = :id";


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


        paramts.put("id", id);


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


@@ -468,42 +464,45 @@


        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,"


                + "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 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 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 ");


        //单号


        // 单号


        if (StringUtils.isNotEmpty(transferQry.getBusinessFormCode())) {


            sql.append("AND BUSINESS_FORM_CODE like :businessFormCode ");


            paramts.put("businessFormCode", StringUtils.CHAR_PERCENT + transferQry.getBusinessFormCode() + StringUtils.CHAR_PERCENT);


            paramts.put("businessFormCode",


                StringUtils.CHAR_PERCENT + transferQry.getBusinessFormCode() + StringUtils.CHAR_PERCENT);


        }


        //物品名称


        // 物品名称


        if (StringUtils.isNotEmpty(transferQry.getGoodsTemplateName())) {


            sql.append("AND bgt.GOODS_NAME like:goodsName ");


            paramts.put("goodsName", StringUtils.CHAR_PERCENT + transferQry.getGoodsTemplateName() + StringUtils.CHAR_PERCENT);


            paramts.put("goodsName",


                StringUtils.CHAR_PERCENT + transferQry.getGoodsTemplateName() + StringUtils.CHAR_PERCENT);


        }


        // 规格型号


        if (transferQry.getBaseGoodsModelsId() != null) {


            sql.append("AND bgm.id =:goodsModelId ");


            paramts.put("goodsModelId", transferQry.getBaseGoodsModelsId());


        }


        //调拨机构


        // 调拨机构


        if (transferQry.getOutAgencyId() != null) {


            sql.append("AND OUT_AGENCY_ID = :OUT_AGENCY_ID ");


            paramts.put("OUT_AGENCY_ID", transferQry.getOutAgencyId());


        }


        //分发部门


        // 分发部门


        if (transferQry.getInWarehouseId() != null) {


            sql.append("and ft.IN_WAREHOUSE_ID = :inWarehouseId ");


            paramts.put("inWarehouseId", transferQry.getInWarehouseId());


        }


        //创建人


        // 创建人


        if (StringUtils.isNotEmpty(transferQry.getOperatorName())) {


            sql.append("AND ft.OPERATOR_NAME =:OPERATOR_NAME ");


            paramts.put("OPERATOR_NAME", transferQry.getOperatorName());


        }


        //申请时间


        // 申请时间


        if (transferQry.getStartTime() != null) {


            sql.append("AND ft.CREATE_TIME >=:createTimeStart ");


            paramts.put("createTimeStart", transferQry.getStartTime() * 1000000);


@@ -514,23 +513,23 @@


        }


        sql.append("ORDER BY ft.CREATE_TIME DESC");




        GenericPager<Map<String, Object>> mapGenericPager = this.selectSplit(sql.toString(), paramts, transferQry.getPageNum(), transferQry.getPageSize(),


            new MapperUtil());


        GenericPager<Map<String, Object>> mapGenericPager = this.selectSplit(sql.toString(), paramts,


            transferQry.getPageNum(), transferQry.getPageSize(), new MapperUtil());




        return mapGenericPager;


    }






    public GenericPager<Map<String, Object>> queryFormTransferDetailList(TransferQry param) {




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


        StringBuilder sql = new StringBuilder(


            "SELECT ft.id,\n" + "       ft.BUSINESS_FORM_CODE,\n" + "       bgt.GOODS_NAME,\n" + "       bgt.CLASSIFICATION,\n"


                + "       pm.BASE_GOODS_MODELS_NAME,\n" + "       pm.COUNTS,\n" + "       ft.IN_AGENCY_NAME,\n" + "       ft.OPERATOR_NAME,\n"


                + "       ft.CREATE_TIME,\n" + "       ft.IN_TIME,\n" + "       ft.OUT_AGENCY_NAME,\n" + "       ft.OUT_OPERATOR_NAME,\n"


                + "       ft.OUTPUT_TIME\n" + "FROM l_wh_form_transfer ft\n" + "         LEFT JOIN l_wh_procure_model pm ON ft.ID = pm.BUSINESS_ID\n"


                + "         LEFT JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID\n"


                + "         LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID where 1=1 ");


        StringBuilder sql = new StringBuilder("SELECT ft.id,\n" + "       ft.BUSINESS_FORM_CODE,\n"


            + "       bgt.GOODS_NAME,\n" + "       bgt.CLASSIFICATION,\n" + "       pm.BASE_GOODS_MODELS_NAME,\n"


            + "       pm.COUNTS,\n" + "       ft.IN_AGENCY_NAME,\n" + "       ft.OPERATOR_NAME,\n"


            + "       ft.CREATE_TIME,\n" + "       ft.IN_TIME,\n" + "       ft.OUT_AGENCY_NAME,\n"


            + "       ft.OUT_OPERATOR_NAME,\n" + "       ft.OUTPUT_TIME\n" + "FROM l_wh_form_transfer ft\n"


            + "         LEFT JOIN l_wh_procure_model pm ON ft.ID = pm.BUSINESS_ID\n"


            + "         LEFT JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID\n"


            + "         LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID where 1=1 ");


        if (StringUtils.isNotEmpty(param.getBusinessFormCode())) {


            sql.append("AND ft.BUSINESS_FORM_CODE = :businessFormCode ");


            params.put("businessFormCode", param.getBusinessFormCode());


@@ -555,7 +554,7 @@


            sql.append("AND ft.OPERATOR_NAME = :operatorName ");


            params.put("operatorName", param.getOperatorName());


        }


        //申请创建时间


        // 申请创建时间


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


            sql.append("AND ft.CREATE_TIME >= :createTimeStart ");


            params.put("createTimeStart", param.getCreateTimeStart() * 1000000);


@@ -564,7 +563,7 @@


            sql.append("AND ft.CREATE_TIME < :createTimeEnd ");


            params.put("createTimeEnd", param.getCreateTimeEnd() * 1000000 + 240000);


        }


        //接收时间


        // 接收时间


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


            sql.append("AND ft.IN_TIME >= :createTimeStart ");


            params.put("createTimeStart", param.getStartTime() * 1000000);


@@ -573,19 +572,20 @@


            sql.append("AND ft.IN_TIME < :createTimeEnd ");


            params.put("createTimeEnd", param.getEndTime() * 1000000 + 240000);


        }


        GenericPager<Map<String, Object>> mapGenericPager = this.selectSplit(sql.toString(), params, param.getPageNum(), param.getPageSize(), new MapperUtil());


        GenericPager<Map<String, Object>> mapGenericPager =


            this.selectSplit(sql.toString(), params, param.getPageNum(), param.getPageSize(), new MapperUtil());


        return mapGenericPager;




    }




    public List<Map<String, Object>> queryDepartmentTransferOrder() {




        String sql =


            "SELECT ft.id,\n" + "       ft.BUSINESS_FORM_CODE,\n" + "       gr.GOODS_TEMPLATE_NAME,\n" + "       gr.BASE_GOODS_TEMPLATE_ID goodsTemplateId,\n"


                + "       ft.CREATE_TIME\n" + "\n" + "FROM l_wh_form_transfer ft\n" + "         LEFT JOIN L_WAREHOUSE_FLOW wf ON ft.id = wf.BUSINESS_FORM_ID\n"


                + "         left join L_WH_GOODS_RECORD gr on gr.WAREHOUSE_FLOW_ID = wf.id\n"


                + "         LEFT JOIN L_GOODS_WH_RECORD gwr on gwr.WAREHOUSE_FLOW_ID = wf.id\n"


                + "         left join L_WH_GOODS g on g.id = gwr.WH_GOODS_ID where ft.BUSINESS_TYPE = 1 GROUP BY gr.BASE_GOODS_TEMPLATE_ID \n";


        String sql = "SELECT ft.id,\n" + "       ft.BUSINESS_FORM_CODE,\n" + "       gr.GOODS_TEMPLATE_NAME,\n"


            + "       gr.BASE_GOODS_TEMPLATE_ID goodsTemplateId,\n" + "       ft.CREATE_TIME\n" + "\n"


            + "FROM l_wh_form_transfer ft\n" + "         LEFT JOIN L_WAREHOUSE_FLOW wf ON ft.id = wf.BUSINESS_FORM_ID\n"


            + "         left join L_WH_GOODS_RECORD gr on gr.WAREHOUSE_FLOW_ID = wf.id\n"


            + "         LEFT JOIN L_GOODS_WH_RECORD gwr on gwr.WAREHOUSE_FLOW_ID = wf.id\n"


            + "         left join L_WH_GOODS g on g.id = gwr.WH_GOODS_ID where ft.BUSINESS_TYPE = 1 GROUP BY gr.BASE_GOODS_TEMPLATE_ID \n";


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


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


        select.forEach(item -> {