部门分发添加,分发单型号查询

futian.liu

2023-12-02 edc87e2fc3760cd7d1230bc058acf5620ea2c465

部门分发添加,分发单型号查询

 consum-base/src/main/java/com/consum/base/controller/FinSysTenantDepartmentController.java

@@ -3,7 +3,7 @@
import com.consum.base.BaseController;
import com.consum.base.core.utils.CommonUtil;
import com.consum.base.pojo.FinSysTenantDepartmentParam;
import com.consum.base.service.FinSysTenantDepartmentServiceImpl;
import com.consum.base.service.FinSysTenantDepartmentService;
import com.consum.model.po.FinSysTenantDepartment;
import com.consum.model.po.FinSysTenantUser;
import com.walker.db.page.GenericPager;
@@ -32,7 +32,7 @@
public class FinSysTenantDepartmentController extends BaseController {

    @Autowired
    private FinSysTenantDepartmentServiceImpl departmentService;
    private FinSysTenantDepartmentService departmentService;

    /**
     * @Description 新增

 consum-base/src/main/java/com/consum/base/controller/FinSysTenantUserController.java

@@ -14,7 +14,7 @@
import com.consum.base.pojo.response.FinSysTenantUserVO;
import com.consum.base.pojo.response.FinSysTenantVO;
import com.consum.base.pojo.response.UserVO;
import com.consum.base.service.FinSysTenantDepartmentServiceImpl;
import com.consum.base.service.FinSysTenantDepartmentService;
import com.consum.base.service.FinSysTenantServiceImpl;
import com.consum.base.service.FinSysTenantUserServiceImpl;
import com.consum.model.po.FinSysTenant;
@@ -31,22 +31,38 @@
import com.iplatform.model.po.S_role;
import com.iplatform.model.po.S_user_core;
import com.walker.db.page.GenericPager;
import com.walker.infrastructure.utils.*;
import com.walker.infrastructure.utils.CollectionUtils;
import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.NumberGenerator;
import com.walker.infrastructure.utils.PhoneNumberUtils;
import com.walker.infrastructure.utils.StringUtils;
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.IOException;
import java.lang.reflect.Field;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Optional;
import java.util.Set;
import org.apache.commons.compress.utils.Lists;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.lang.reflect.Field;
import java.util.*;

/**
 * @Description 系统用户
@@ -71,7 +87,7 @@
    private RoleServiceImpl roleService;

    @Autowired
    private FinSysTenantDepartmentServiceImpl finSysTenantDepartmentService;
    private FinSysTenantDepartmentService finSysTenantDepartmentService;


    @Autowired

 consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java

@@ -24,7 +24,7 @@
import com.consum.base.pojo.response.TransferInfoVO;
import com.consum.base.service.BaseWarehouseServiceImpl;
import com.consum.base.service.LWhFormTransferCoreService;
import com.consum.base.service.LWhFormTransferServiceImpl;
import com.consum.base.service.LWhFormTransferService;
import com.consum.base.service.LWhProcureModelService;
import com.consum.base.service.LWhProcureModelUserRecordServiceImpl;
import com.consum.base.service.LWhProcureModelUserServiceImpl;
@@ -71,7 +71,7 @@
public class LWhFormTransferController extends BaseController {

    @Autowired
    private LWhFormTransferServiceImpl lWhFormTransferService;
    private LWhFormTransferService lWhFormTransferService;
    @Autowired
    private LWhProcureModelService lWhProcureModelService;
    @Autowired

 consum-base/src/main/java/com/consum/base/pojo/response/BaseGoodsTemplateInfo.java

@@ -13,4 +13,5 @@

    private String baseGoodsTemplateName;
    private Integer count;
    private String unit;
}

 consum-base/src/main/java/com/consum/base/service/BaseWarehouseServiceImpl.java

@@ -12,12 +12,15 @@
import com.walker.infrastructure.utils.CollectionUtils;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.jdbc.service.BaseServiceImpl;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.*;
import java.util.stream.Collectors;

/**
 * @Description 仓库管理
@@ -32,9 +35,7 @@
    @Autowired
    private FinSysTenantServiceImpl finSysTenantService;
    @Autowired
    private FinSysTenantDepartmentServiceImpl departmentService;
    @Autowired
    private FinSysTenantUserServiceImpl userService;
    private FinSysTenantDepartmentService departmentService;
    @Autowired
    private SDictDataServiceImpl sDictDataService;


 consum-base/src/main/java/com/consum/base/service/DepFormScrappedServiceImpl.java

@@ -10,7 +10,14 @@
import com.consum.base.pojo.LDeptFormScrappedParam;
import com.consum.base.pojo.query.LDeptFormScrappedQry;
import com.consum.base.pojo.response.DepFormScrappedExtendVo;
import com.consum.model.po.*;
import com.consum.model.po.BaseCategory;
import com.consum.model.po.DepFormScrapped;
import com.consum.model.po.DepFormScrappedGoods;
import com.consum.model.po.DepFormScrappedModel;
import com.consum.model.po.FinSysTenantDepartment;
import com.consum.model.po.FinSysTenantUser;
import com.consum.model.po.LWhFormTransfer;
import com.consum.model.po.SDictData;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.iplatform.model.po.S_user_core;
import com.walker.db.page.GenericPager;
@@ -19,16 +26,15 @@
import com.walker.infrastructure.utils.StringUtils;
import com.walker.jdbc.service.BaseServiceImpl;
import com.walker.web.ResponseValue;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/**
 * @ClassName DepFormScrappedServiceImpl
@@ -43,9 +49,9 @@
    @Resource
    private CodeGeneratorService codeGeneratorService;
    @Resource
    private FinSysTenantDepartmentServiceImpl departmentService;
    private FinSysTenantDepartmentService departmentService;
    @Resource
    private LWhFormTransferServiceImpl lWhFormTransferService;
    private LWhFormTransferService lWhFormTransferService;
    @Resource
    private BaseCategoryServiceImpl baseCategoryService;
    @Resource
@@ -85,7 +91,6 @@
            lDeptFormScrapped.setDepartmentId(sysInfo.getSysDeptId());
            lDeptFormScrapped.setDepartmentName(department.getName());
        }


        lDeptFormScrapped.setCreateTime(dealTime);
        lDeptFormScrapped.setStates(1);
@@ -255,10 +260,10 @@
            depFormScrappedModel.setDepFormScrappedGoodsId(scrappedGoodsId);
            List<DepFormScrappedModel> scrappedModelList = select(depFormScrappedModel);
            List<List<DepFormScrappedModel>> modelList = scrappedModelList.stream()
                    .collect(Collectors.groupingBy(DepFormScrappedModel::getBaseGoodsModelsId))
                    .values().stream()
                    .map(list -> list.stream().collect(Collectors.toList()))
                    .collect(Collectors.toList());
                .collect(Collectors.groupingBy(DepFormScrappedModel::getBaseGoodsModelsId))
                .values().stream()
                .map(list -> list.stream().collect(Collectors.toList()))
                .collect(Collectors.toList());

            scrappedGoodsMap.put("models", modelList);
            goodsList.add(scrappedGoodsMap);
@@ -285,6 +290,7 @@
        }
        return select(sql.append(EXPORT_SQL_END).toString(), paramts, new MapperUtil());
    }

    public List<Map<String, Object>> listByModel(LDeptFormScrappedQry param) {
        HashMap<String, Object> paramts = new HashMap<>();
        StringBuilder sql = new StringBuilder(EXPORT_SQL);
@@ -299,7 +305,7 @@
            paramts.put("businessFormCode", param.getBusinessFormCode());
        }
        //物品名称
        if (StringUtils.isNotEmpty(param.getGoodsTemplateName())){
        if (StringUtils.isNotEmpty(param.getGoodsTemplateName())) {
            sql.append(" and model.BASE_GOODS_TEMPLATE_NAME LIKE :goodsTemplateName ");
            paramts.put("goodsTemplateName", StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT);
        }

 consum-base/src/main/java/com/consum/base/service/FinSysTenantDepartmentService.java

New file
@@ -0,0 +1,63 @@
package com.consum.base.service;

import com.consum.base.pojo.FinSysTenantDepartmentParam;
import com.consum.model.po.FinSysTenantDepartment;
import com.consum.model.po.FinSysTenantUser;
import com.walker.db.page.GenericPager;
import com.walker.jdbc.service.BaseService;
import java.util.List;

public interface FinSysTenantDepartmentService extends BaseService {


    FinSysTenantDepartment getByNameAndTenantId(String name, Long tenantId);

    /**
     * @Description 新增
     * @Author 卢庆阳
     * @Date 2023/10/26
     */
    int add(FinSysTenantDepartmentParam param, FinSysTenantUser sysInfo);

    /**
     * @Description 部门列表查询
     * @Author 卢庆阳
     * @Date 2023/10/26
     */
    GenericPager<FinSysTenantDepartment> queryList(FinSysTenantDepartmentParam param);

    FinSysTenantDepartment selectByCode(String code);

    /**
     * @Description 编辑
     * @Author 卢庆阳
     * @Date 2023/10/26
     */
    int updateFinSysTenantDepartment(FinSysTenantDepartment department, FinSysTenantUser sysInfo);

    /**
     * 根据部门id查询部门详情
     *
     * @author 卢庆阳
     * @Date 2023/10/26
     */
    FinSysTenantDepartment getById(Long id);

    /**
     * @param department
     * @param currentUser
     * @Description 根据id删除部门
     * @Author 卢庆阳
     * @Date 2023/10/26
     */
    int updateById(FinSysTenantDepartment department, FinSysTenantUser currentUser);

    /**
     * 根据机构id查询部门
     *
     * @param agencyId
     * @return
     */
    List<FinSysTenantDepartment> getByTenantId(Long agencyId);

}

 consum-base/src/main/java/com/consum/base/service/LWhFormScrappedServiceImpl.java

@@ -15,20 +15,30 @@
import com.consum.base.pojo.response.FormScrappedGoodsVO;
import com.consum.base.pojo.response.GoodsModelVO;
import com.consum.base.pojo.response.LWhFormScrappedExtendVO;
import com.consum.model.po.*;
import com.consum.model.po.BaseGoodsModels;
import com.consum.model.po.BaseGoodsTemplate;
import com.consum.model.po.BaseWarehouse;
import com.consum.model.po.FinSysTenantDepartment;
import com.consum.model.po.FinSysTenantUser;
import com.consum.model.po.LWhFormScrapped;
import com.consum.model.po.LWhFormScrappedGoods;
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.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 java.util.stream.Collectors;
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.*;
import java.util.stream.Collectors;

/**
 * @Description 报废单
@@ -43,7 +53,7 @@
    @Autowired
    private BaseWarehouseServiceImpl baseWarehouseService;
    @Autowired
    private FinSysTenantDepartmentServiceImpl departmentService;
    private FinSysTenantDepartmentService departmentService;
    @Autowired
    private LWhGoodsService lWhGoodsService;
    @Autowired
@@ -72,7 +82,7 @@
     * @return 1.新增报废单  2.新增报废单物品
     */

    public int add(LWhFormScrappedParam param,  S_user_core currentUser, FinSysTenantUser sysInfo) {
    public int add(LWhFormScrappedParam param, S_user_core currentUser, FinSysTenantUser sysInfo) {
        //1.新增报废单记录
        LWhFormScrapped lWhFormScrapped = new LWhFormScrapped();
        //报废单id
@@ -93,25 +103,6 @@
            return 0;
        }
        wareHouseName = warehouse.getWarehouseName();
//        if (0 == 0) {
//            warehouseId = param.getWarehouseId();
//            //根据仓库id查询仓库
//            BaseWarehouse warehouse = this.baseWarehouseService.getById(warehouseId);
//            if (warehouse == null) {
//                log.error("仓库不存在");
//                return 0;
//            }
//            wareHouseName = warehouse.getWarehouseName();
//        } else {
//            // 查询部门名称
//            warehouseId = param.getDepartmentId();
//            FinSysTenantDepartment sysTenantDepartment = departmentService.getById(warehouseId);
//            if (sysTenantDepartment == null) {
//                log.error("部门不存在");
//                return 0;
//            }
//            wareHouseName = sysTenantDepartment.getName();
//        }
        lWhFormScrapped.setWarehouseId(warehouseId);
        lWhFormScrapped.setWarehouseName(wareHouseName);
        lWhFormScrapped.setAgencyId(Long.valueOf(sysInfo.getTenantId()));

 consum-base/src/main/java/com/consum/base/service/LWhFormTransferCoreService.java

@@ -5,23 +5,27 @@
import com.consum.base.core.service.LWhWarningCoreServiceImpl;
import com.consum.base.core.utils.IdUtil;
import com.consum.base.core.utils.LockManage;
import com.consum.model.po.*;
import com.consum.model.po.LGoodsUserRecord;
import com.consum.model.po.LWarehouseFlow;
import com.consum.model.po.LWhFormTransfer;
import com.consum.model.po.LWhGoodsRecord;
import com.consum.model.po.LWhGoodsRecordDetails;
import com.consum.model.po.LWhProcureModelUser;
import com.iplatform.model.po.S_user_core;
import com.walker.infrastructure.utils.CollectionUtils;
import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.NumberGenerator;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

/**
 * @ClassName LWhFormTransferCoreService
@@ -35,7 +39,7 @@
public class LWhFormTransferCoreService {

    @Resource
    private LWhFormTransferServiceImpl lWhFormTransferService;
    private LWhFormTransferService lWhFormTransferService;
    @Resource
    private LWhFormOutputCoreService lWhFormOutputCoreService;
    @Resource
@@ -128,7 +132,7 @@
        String nickName = currentUser.getNick_name();
        // 出库单流水id
        Long outWarehouseFlowId = lWhFormTransfer.getOutWarehouseFlowId();
        if (outWarehouseFlowId == null){
        if (outWarehouseFlowId == null) {
            log.error("调拨失败！未找到出库单");
            return;
        }
@@ -188,7 +192,7 @@
            synchronized (warehouseModelLockObj) {
                // 根据出库流水ID 查询 出库的物品ID
                outGoodsIds = getGoodsidByFlowId(outWarehouseFlowId, oldRecordId);
                if (CollectionUtils.isEmpty(outGoodsIds)){
                if (CollectionUtils.isEmpty(outGoodsIds)) {
                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                    throw new RuntimeException("入库单失败，未查询到物品！");
                }
@@ -211,7 +215,7 @@
                lWhProcureModelUser.setTransBusinessId(whFormTransferId);
                lWhProcureModelUser.setBaseGoodsModelsId(baseGoodsModelsId);
                List<LWhProcureModelUser> goodsUserInfo = goodsBaseService.select(lWhProcureModelUser);
                if (CollectionUtils.isEmpty(goodsUserInfo)){
                if (CollectionUtils.isEmpty(goodsUserInfo)) {
                    continue;
                }
                int totalGoodsNum = goodsUserInfo.stream().filter(item -> item.getGoodsNum() != null).mapToInt(LWhProcureModelUser::getGoodsNum).sum();
@@ -258,7 +262,6 @@
            //将保管仓库信息更新到 物品仓库保管记录【L_GOODS_WH_RECORD】
            lGoodsWhRecordService.insertNewRecord(outGoodsIds, inWarehouseFlowId, dealTime);


            LWhGoodsRecordDetails lWhGoodsRecordDetails = new LWhGoodsRecordDetails();
            lWhGoodsRecordDetails.setWhGoodsRecordId(oldRecordId);
            List<LWhGoodsRecordDetails> goodsRecordDetailsList = lWhGoodsRecordDetailsService.select(lWhGoodsRecordDetails);
@@ -282,7 +285,7 @@
        lWhFormTransferService.update(lWhFormTransfer);

        //当库存变动时调用该方法
        if (inWarehouseType == 0){
        if (inWarehouseType == 0) {
            lWhWarningCoreService.updateKuCun(Convert.toShort(inWarehouseType, (short) 0), inWarehouseId, allChangModelList, null, dealTime);
        }
        log.info("调拨单：{} 入库完成", whFormTransferId);

 consum-base/src/main/java/com/consum/base/service/LWhFormTransferService.java

New file
@@ -0,0 +1,57 @@
package com.consum.base.service;

import com.consum.base.pojo.excel.TransferExcelTemplate;
import com.consum.base.pojo.query.TransferQry;
import com.consum.base.pojo.request.LWhFormTransferParam;
import com.consum.base.pojo.response.LWHFromTransferExtendVO;
import com.consum.model.po.FinSysTenantUser;
import com.consum.model.po.LWhFormTransfer;
import com.walker.db.page.GenericPager;
import com.walker.jdbc.service.BaseService;
import java.util.List;
import java.util.Map;

public interface LWhFormTransferService extends BaseService {

    long add(LWhFormTransferParam param, FinSysTenantUser sysInfo) throws Exception;


    /**
     * @Description 列表查询
     * @Author 卢庆阳
     * @Date 2023/10/30
     */
    GenericPager<LWhFormTransfer> queryFormTransferList(TransferQry param);

    /**
     * @Description 根据id查询详情
     * @Author 卢庆阳
     * @Date 2023/10/30
     */
    LWHFromTransferExtendVO getById(Long id);


    /**
     * @Description 导出调拨出库单
     * @Author 卢庆阳
     * @Date 2023/10/31
     */
    List<TransferExcelTemplate> export(Long id, Integer type);

    /**
     * 撤销
     *
     * @author 卢庆阳
     * @date 2023/10/31
     */
    int updateStatus(Long id);

    GenericPager<Map<String, Object>> queryTransferInfo(TransferQry transferQry);


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

    List<Map<String, Object>> queryDepartmentTransferOrder();

    LWhFormTransfer selectById(Long id);
}

 consum-base/src/main/java/com/consum/base/service/impl/FinSysTenantDepartmentServiceImpl.java

File was renamed from consum-base/src/main/java/com/consum/base/service/FinSysTenantDepartmentServiceImpl.java
@@ -1,19 +1,19 @@
package com.consum.base.service;
package com.consum.base.service.impl;

import com.consum.base.Constants;
import com.consum.base.pojo.FinSysTenantDepartmentParam;
import com.consum.base.core.utils.IdUtil;
import com.consum.base.pojo.FinSysTenantDepartmentParam;
import com.consum.base.service.FinSysTenantDepartmentService;
import com.consum.model.po.FinSysTenantDepartment;
import com.consum.model.po.FinSysTenantUser;
import com.walker.db.page.GenericPager;
import com.walker.infrastructure.utils.DateUtils;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.jdbc.service.BaseServiceImpl;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.List;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

/**
 * @Description 部门管理
@@ -21,16 +21,17 @@
 * @Date 2023/10/26
 */
@Service
public class FinSysTenantDepartmentServiceImpl extends BaseServiceImpl {
public class FinSysTenantDepartmentServiceImpl extends BaseServiceImpl implements FinSysTenantDepartmentService {

    private static final String QUERY_BY_CODE = "SELECT * FROM fin_sys_tenant_department WHERE CODE = ?";

    /**
     * @Description  根据 部门名称和机构id 查询部门
     * @Description 根据 部门名称和机构id 查询部门
     * @Author 卢庆阳
     * @Date 2023/10/26
     */
    public FinSysTenantDepartment getByNameAndTenantId(String name,Long tenantId) {
    @Override
    public FinSysTenantDepartment getByNameAndTenantId(String name, Long tenantId) {
        StringBuilder sql = new StringBuilder("SELECT * FROM fin_sys_tenant_department WHERE 1 = 1 ");
        HashMap<String, Object> paramts = new HashMap<>();

@@ -48,10 +49,11 @@
    }

    /**
     * @Description  新增
     * @Description 新增
     * @Author 卢庆阳
     * @Date 2023/10/26
     */
    @Override
    public int add(FinSysTenantDepartmentParam param, FinSysTenantUser sysInfo) {
        FinSysTenantDepartment department = new FinSysTenantDepartment();
        BeanUtils.copyProperties(param, department);
@@ -70,6 +72,7 @@
     * @Author 卢庆阳
     * @Date 2023/10/26
     */
    @Override
    public GenericPager<FinSysTenantDepartment> queryList(FinSysTenantDepartmentParam param) {
        StringBuilder sql = new StringBuilder("SELECT * FROM fin_sys_tenant_department WHERE 1 = 1 and is_delete = 0 ");
        HashMap<String, Object> paramts = new HashMap<>();
@@ -101,6 +104,7 @@
        return selectSplit(sql.toString(), paramts, new FinSysTenantDepartment());
    }

    @Override
    public FinSysTenantDepartment selectByCode(String code) {
        List<FinSysTenantDepartment> select = this.select(QUERY_BY_CODE, new Object[]{code}, new FinSysTenantDepartment());
        if (StringUtils.isEmptyList(select)) {
@@ -115,6 +119,7 @@
     * @Author 卢庆阳
     * @Date 2023/10/26
     */
    @Override
    public int updateFinSysTenantDepartment(FinSysTenantDepartment department, FinSysTenantUser sysInfo) {
        department.setUpdateTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
        department.setUpdateBy(sysInfo.getUserName());
@@ -123,20 +128,23 @@

    /**
     * 根据部门id查询部门详情
     *
     * @author 卢庆阳
     * @Date 2023/10/26
     */
    @Override
    public FinSysTenantDepartment getById(Long id) {
        return this.get(new FinSysTenantDepartment(id));
    }

    /**
     * @param department
     * @param currentUser
     * @Description 根据id删除部门
     * @Author 卢庆阳
     * @Date 2023/10/26
     * @param department
     * @param currentUser
     */
    @Override
    public int updateById(FinSysTenantDepartment department, FinSysTenantUser currentUser) {
        department.setIsDelete(Constants.IS_DELETE_YES);
        //删除时间
@@ -148,9 +156,11 @@

    /**
     * 根据机构id查询部门
     *
     * @param agencyId
     * @return
     */
    @Override
    public List<FinSysTenantDepartment> getByTenantId(Long agencyId) {
        StringBuilder sql = new StringBuilder("SELECT * FROM fin_sys_tenant_department WHERE 1 = 1 and is_delete = 0 ");
        HashMap<String, Object> paramts = new HashMap<>();

 consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java

File was renamed from consum-base/src/main/java/com/consum/base/service/LWhFormTransferServiceImpl.java
@@ -1,4 +1,4 @@
package com.consum.base.service;
package com.consum.base.service.impl;

import com.consum.base.core.CodeGeneratorEnum;
import com.consum.base.core.CodeGeneratorService;
@@ -15,10 +15,32 @@
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.*;
import com.consum.base.service.BaseGoodsModelsServiceImpl;
import com.consum.base.service.BaseWarehouseManagerService;
import com.consum.base.service.BaseWarehouseServiceImpl;
import com.consum.base.service.FinSysTenantServiceImpl;
import com.consum.base.service.LWhFormOutputServiceImpl;
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.LWhProcureModelUserServiceImpl;
import com.consum.model.po.BaseWarehouse;
import com.consum.model.po.BaseWarehouseManager;
import com.consum.model.po.FinSysTenant;
import com.consum.model.po.FinSysTenantUser;
import com.consum.model.po.LWhFormTransfer;
import com.consum.model.po.LWhProcureModel;
import com.consum.model.po.LWhProcureModelUser;
import com.consum.model.po.LWhProcureModelUserRecord;
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;
@@ -26,15 +48,13 @@
import org.springframework.transaction.interceptor.TransactionAspectSupport;
import org.springframework.util.CollectionUtils;

import java.util.*;

/**
 * @Description 调拨管理
 * @Author 卢庆阳
 * @Date 2023/10/30
 */
@Service
public class LWhFormTransferServiceImpl extends BaseServiceImpl {
public class LWhFormTransferServiceImpl extends BaseServiceImpl implements LWhFormTransferService {

    @Autowired
    private BaseWarehouseServiceImpl baseWarehouseService;
@@ -47,11 +67,7 @@
    @Autowired
    private LWhProcureModelService lWhProcureModelService;
    @Autowired
    private LWhFormOutputCoreService lWhFormOutputCoreService;
    @Autowired
    private LWhFormOutputServiceImpl lWhFormOutputService;
    @Autowired
    private LWhGoodsRecordService lWhGoodsRecordService;
    @Autowired
    private BaseGoodsModelsServiceImpl baseGoodsModelsService;
    @Autowired
@@ -60,8 +76,6 @@
    private LWhProcureModelUserRecordServiceImpl lWhProcureModelUserRecordService;
    @Autowired
    private BaseWarehouseManagerService baseWarehouseManagerService;
    @Autowired
    private BaseGoodsTemplateServiceImpl baseGoodsTemplateService;

    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 "
@@ -346,13 +360,16 @@
        List<FormTransferGoodsVO> formTransferGoods = Lists.newArrayList();
        for (Map<String, Object> map : procureModelList) {
            FormTransferGoodsVO procureTemplateInfoVO = MapUtils.convertMapToObj(map, FormTransferGoodsVO.class);

            Long baseGoodsTemplateId = procureTemplateInfoVO.getId();
            // 查询型号数量
            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, new MapperUtil());
                + "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());
            modelList.forEach(item -> {
                GoodsModelVO goodsModelVO = MapUtils.convertMapToObj(item, GoodsModelVO.class);
                Integer businessType = result.getBusinessType();
@@ -381,9 +398,8 @@

                }
                goodsModelVOList.add(goodsModelVO);
                procureTemplateInfoVO.setModels(goodsModelVOList);
            });

            procureTemplateInfoVO.setModels(goodsModelVOList);
            formTransferGoods.add(procureTemplateInfoVO);
        }
        result.setFormTransferGoods(formTransferGoods);
@@ -577,4 +593,11 @@
        return select;

    }

    @Override
    public LWhFormTransfer selectById(Long id) {
        LWhFormTransfer lWhFormTransfer = new LWhFormTransfer();
        lWhFormTransfer.setId(id);
        return this.get(lWhFormTransfer);
    }
}

 consum-base/src/main/java/com/consum/base/service/impl/UsingFormBackServiceImpl.java

@@ -19,11 +19,15 @@
import com.consum.base.pojo.response.UsingFormBackModelInfo;
import com.consum.base.pojo.response.UsingFormBackVO;
import com.consum.base.service.BaseCategoryServiceImpl;
import com.consum.base.service.FinSysTenantDepartmentService;
import com.consum.base.service.LWhFormTransferService;
import com.consum.base.service.UsingFormBackGoodsService;
import com.consum.base.service.UsingFormBackModelService;
import com.consum.base.service.UsingFormBackService;
import com.consum.model.po.BaseCategory;
import com.consum.model.po.FinSysTenantDepartment;
import com.consum.model.po.FinSysTenantUser;
import com.consum.model.po.LWhFormTransfer;
import com.consum.model.po.UsingFormBack;
import com.consum.model.po.UsingFormBackGoods;
import com.consum.model.po.UsingFormBackModel;
@@ -59,13 +63,20 @@
    private UsingFormBackModelService usingFormBackModelService;
    @Autowired
    private UsingFormBackGoodsService usingFormBackGoodsService;

    @Autowired
    private FinSysTenantDepartmentService finSysTenantDepartmentService;
    @Autowired
    private LWhFormTransferService lWhFormTransferService;

    @Override
    public void add(UsingFormBackParam usingFormBackParam, FinSysTenantUser sysInfo) {

        Long departmentId = usingFormBackParam.getDepartmentId();
        String departmentName = usingFormBackParam.getDepartmentName();
        FinSysTenantDepartment department = finSysTenantDepartmentService.getById(departmentId);
        if (department == null) {
            throw new RuntimeException("部门不存在");
        }
        String departmentName = department.getName();
        Long operatorId = usingFormBackParam.getOperatorId();
        String operatorName = usingFormBackParam.getOperatorName();
        Long backTime = usingFormBackParam.getDealTime();
@@ -93,8 +104,12 @@
            usingFormBackGoods.setClassification(classification);
            usingFormBackGoods.setTransBusinessId(transBusinessId);
            usingFormBackGoods.setBusinessFormCode(businessFormCode);
//            usingFormBackGoods.setTransOutWarehouseType();
//            usingFormBackGoods.setTransOutWarehouseId();

            LWhFormTransfer lWhFormTransfer = lWhFormTransferService.selectById(transBusinessId);
            Integer outWarehouseType = lWhFormTransfer.getOutWarehouseType();
            Long outWarehouseId = lWhFormTransfer.getOutWarehouseId();
            usingFormBackGoods.setTransOutWarehouseType(outWarehouseType);
            usingFormBackGoods.setTransOutWarehouseId(outWarehouseId);

            usingFormBackModelService.insert(usingFormBackGoods);
            for (baseGoodModel model : backingGoodsInfo.getModels()) {
@@ -180,7 +195,7 @@
            map.put("agencyId", agencyId);
        }
        if (StringUtils.isNotEmpty(createName)) {
            sql.append("AND ufb.CREATE_NAME = :createName ");
            sql.append("AND ufb.OPERATOR_NAME = :createName ");
            map.put("createName", createName);
        }
        sql.append("ORDER BY ufb.CREATE_TIME DESC ");
@@ -194,7 +209,8 @@
            Long id = usingFormBackVO.getId();
            StringBuilder countSql = new StringBuilder("SELECT \n"
                + "\tufbg.BASE_GOODS_TEMPLATE_NAME,\n"
                + "\tsum(ufbm.COUNTS) count\n"
                + "\tsum(ufbm.COUNTS) count,\n"
                + "\tufbm.UNIT\n"
                + "FROM\n"
                + "\tusing_form_back_goods ufbg\n"
                + "\tLEFT JOIN using_form_back_model ufbm ON ufbg.ID = ufbm.USING_FORM_BACK_GOODS_ID\n"
@@ -350,7 +366,7 @@
            map.put("agencyId", agencyId);
        }
        if (StringUtils.isNotEmpty(createName)) {
            sql.append("AND ufb.CREATE_NAME = :createName ");
            sql.append("AND ufb.OPERATOR_NAME = :createName ");
            map.put("createName", createName);
        }
        sql.append("ORDER BY ufb.CREATE_TIME DESC ");
@@ -373,9 +389,9 @@
        UsingFormBack usingFormBack = new UsingFormBack();
        usingFormBack.setId(IdUtil.generateId());
        usingFormBack.setBusinessFormCode(codeGeneratorService.createBusinessFormCode(CodeGeneratorEnum.GOBACK));
//        usingFormBack.setOutWarehouseType();
//        usingFormBack.setOutWarehouseId();
//        usingFormBack.setOutWarehouseName();
        usingFormBack.setOutWarehouseType(1);
        usingFormBack.setOutWarehouseId(departmentId);
        usingFormBack.setOutWarehouseName(departmentName);

        String tenantId = sysInfo.getTenantId();
        String tenantName = sysInfo.getTenantName();
@@ -384,9 +400,14 @@
        usingFormBack.setCreateTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
        usingFormBack.setStates(1);

        usingFormBack.setDepartmentId(departmentId);
        usingFormBack.setDepartmentName(departmentName);
        usingFormBack.setOperatorId(operatorId);
        Long sysDeptId = sysInfo.getSysDeptId();
        FinSysTenantDepartment department = finSysTenantDepartmentService.getById(sysDeptId);
        if (department == null) {
            throw new RuntimeException("部门不存在");
        }
        usingFormBack.setDepartmentId(department.getId());
        usingFormBack.setDepartmentName(department.getName());
        usingFormBack.setOperatorId(sysInfo.getId());
        usingFormBack.setOperatorName(operatorName);
        usingFormBack.setDealTime(backTime);
        usingFormBack.setProcureDoc(procureDoc);