DemandServiceImpl.java 13.1 KB

Raw Blame History Permalink

package com.csbr.qingcloud.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.csbr.cloud.common.enums.SystemError;
import com.csbr.cloud.common.exception.CsbrSystemException;
import com.csbr.cloud.common.util.CommonUtil;
import com.csbr.cloud.common.util.CsbrBeanUtil;
import com.csbr.cloud.common.util.MessageSourceUtil;
import csbr.cloud.entity.domain.base.vo.PageListVO;
import com.csbr.qingcloud.domain.vo.DemandQueryVO;
import com.csbr.qingcloud.domain.vo.DemandRQVO;
import com.csbr.qingcloud.domain.vo.DemandRSVO;
import com.csbr.qingcloud.mybatis.entity.MfDemand;
import com.csbr.qingcloud.mybatis.service.MfDemandService;
import com.csbr.qingcloud.service.DemandService;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

/**
 * @program: D:/csbr/sjzc/ms-data-circulation-portal-service
 * @description: 业务逻辑实现
 * @author: xushaobo
 * @create: 2024-12-30 16:30
 **/
@Slf4j
@Service
public class DemandServiceImpl implements DemandService {

    /**
     * 功能名称
     */
    private static final String FUNCTION_NAME = "";

    @Resource
    private MfDemandService mfDemandService;

    @Resource
    private CsbrBeanUtil csbrBeanUtil;

    @Resource
    private MessageSourceUtil messageSourceUtil;

    /**
     * 分页查询
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param queryVO
     * @return com.csbr.cloud.mybatis.entity.PageListVO<com.csbr.qingcloud.domain.vo.DemandRSVO>
     */
    @Override
    public PageListVO<DemandRSVO> pageList(DemandQueryVO queryVO) {
        beforeQuery(queryVO);
        LambdaQueryWrapper<MfDemand> queryWrapper = mfDemandService.csbrQueryWrapper(queryVO, MfDemand.class);
        queryWrapper.orderByDesc(MfDemand::getCreateTime);
        PageListVO<MfDemand> pageList = mfDemandService.csbrPageList(queryVO, queryWrapper);
        PageListVO<DemandRSVO> rsPageList = csbrBeanUtil.convert(pageList, PageListVO.class);
        afterQuery(pageList, rsPageList);
        return rsPageList;
    }

    /**
     * 获取详情数据
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param guid
     * @return com.csbr.qingcloud.domain.vo.DemandRSVO
     */
    @Override
    public DemandRSVO getDemandDetail(String guid) {
        if (StringUtils.isBlank(guid)) {
            // W00012 = {0}:参数[{1}]不能为空!
            throw new CsbrSystemException(SystemError.DATA_INPUT_ERROR, messageSourceUtil.getMessage("W00010",
                    String.format("获取%s详情数据", FUNCTION_NAME), "数据唯一标识"));
        }
        MfDemand entity = mfDemandService.getById(guid);
        if (entity == null) {
            throw new CsbrSystemException(SystemError.DATA_NOT_EXISTS, messageSourceUtil.notExistsToSelectMessage(String.format("获取%s详情数据", FUNCTION_NAME)));
        }
        return convertToVO(entity);
    }

    /**
     * 数据新增
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param rqVO
     * @return boolean
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public void saveDemand(DemandRQVO rqVO) {
        beforeSave(rqVO);
        MfDemand entity = convertToEntity(rqVO);
        boolean flag = mfDemandService.save(entity);
        if (!flag) {
            throw new CsbrSystemException(SystemError.DATA_ADD_ERROR, messageSourceUtil.addMessage(FUNCTION_NAME));
        }
        afterSave(rqVO, entity);
    }

    /**
     * 数据修改
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param rqVO
     * @return boolean
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public void updateDemand(DemandRQVO rqVO) {
        beforeUpdate(rqVO);
        // 将修改前数据查出来缓存下来，传入到修改后方法中，用于一些特殊逻辑处理，如某个值变化才进行
        // MfDemand oldEntity = mfDemandService.getById(rqVO.getGuid());
        MfDemand entity = convertToEntity(rqVO);
        boolean flag = mfDemandService.updateById(entity);
        if (!flag) {
            throw new CsbrSystemException(SystemError.DATA_UPDATE_ERROR, messageSourceUtil.updateMessage(FUNCTION_NAME));
        }
        afterUpdate(rqVO, entity);
    }

   /**
    * 数据删除
    * @author xushaobo
    * @date 2024-12-30 16:30
    * @param guids
    * @return void
    */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public void removeByGuids(List<String> guids) {
        if (CollectionUtils.isEmpty(guids)) {
            // W00012 = {0}:参数[{1}]不能为空!
            throw new CsbrSystemException(SystemError.DATA_INPUT_ERROR, messageSourceUtil.getMessage("W00012",
                    String.format("删除%s数据", FUNCTION_NAME), "数据唯一标识"));
        }
        if (!mfDemandService.isExistsData(guids, MfDemand.class)) {
            throw new CsbrSystemException(SystemError.DATA_DEL_ERROR, messageSourceUtil.notExistsToDelMessage(FUNCTION_NAME));
        }
        boolean flag = mfDemandService.csbrDeleteData(guids, MfDemand.class);
        if (!flag) {
            throw new CsbrSystemException(SystemError.DATA_DEL_ERROR, messageSourceUtil.delMessage(FUNCTION_NAME));
        }
    }

    /**
     * 数据删除、并有相关的处理操作
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param guids
     * @return void
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public void removeHandleByGuids(List<String> guids) {
        if (CollectionUtils.isEmpty(guids)) {
            // W00012 = {0}:参数[{1}]不能为空!
            throw new CsbrSystemException(SystemError.DATA_INPUT_ERROR, messageSourceUtil.getMessage("W00012",
                    String.format("删除%s数据", FUNCTION_NAME), "数据唯一标识"));
        }
        for (String guid : guids) {
            MfDemand entity = mfDemandService.getById(guid);
            beforeRemove(entity);
            boolean flag = mfDemandService.removeById(guid);
            if (!flag) {
                throw new CsbrSystemException(SystemError.DATA_DEL_ERROR, messageSourceUtil.delMessage(FUNCTION_NAME));
            }
            afterRemove(entity);
        }
    }

    /**
     * 新新增前置处理
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param rqVO
     * @return void
     */
    private void beforeSave(DemandRQVO rqVO) {
        //region 1.输入基础验证
        //endregion

        //region 2.数据验证特殊处理
        //region 2.1.业务合规性验证
        //endregion 2.1.业务合规性验证

        //region 2.2.业务数据验证
        //endregion 2.2.业务数据验证

        //endregion 2.数据验证特殊处理

        //region 3.数据转换处理

        //region 3.1.数据过程转换
        //endregion 3.1.数据过程转换

        //endregion 3.数据转换处理

        //region 4.数据过滤与补充处理

        //endregion 4.数据过滤与补充处理

        //region 5.过程处理

        //region 5.1.计算逻辑处理
        //endregion 5.1.计算逻辑处理

        //region 5.2.业务逻辑处理
        //endregion 5.2.业务逻辑处理

        //endregion 5.过程处理
    }

    /**
     * 新增后置处理
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param rqVO
     * @param entity
     * @return void
     */
    private void afterSave(DemandRQVO rqVO, MfDemand entity) {
        //region 1.输出特殊转换

        //region 1.1.输出过滤与补充处理
        //endregion 1.1.输出过滤与补充处理

        //endregion 1.输出特殊转换
    }

    /**
     * 修改前置校验、处理
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param rqVO
     * @return void
     */
    private void beforeUpdate(DemandRQVO rqVO) {
        //region 1.输入基础验证
        if (StringUtils.isBlank(rqVO.getGuid())) {
            // W00012 = {0}:参数[{1}]不能为空!
            throw new CsbrSystemException(SystemError.DATA_INPUT_ERROR, messageSourceUtil.getMessage("W00010", String.format("修改%s数据",FUNCTION_NAME), "数据唯一标识"));
        }
        //endregion

        //region 2.数据验证特殊处理
        //region 2.1.业务合规性验证
        //endregion 2.1.业务合规性验证

        //region 2.2.业务数据验证
        if (!mfDemandService.isExistsData(Collections.singletonList(rqVO.getGuid()), MfDemand.class)) {
            throw new CsbrSystemException(SystemError.DATA_DEL_ERROR, messageSourceUtil.notExistsToUpdateMessage(FUNCTION_NAME));
        }
        //endregion 2.2.业务数据验证

        //endregion 2.数据验证特殊处理

        //region 3.数据转换处理

        //region 3.1.数据过程转换
        //endregion 3.1.数据过程转换

        //endregion 3.数据转换处理

        //region 4.数据过滤与补充处理
        //endregion 4.数据过滤与补充处理

        //region 5.过程处理

        //region 5.1.计算逻辑处理
        //endregion 5.1.计算逻辑处理

        //region 5.2.业务逻辑处理
        //endregion 5.2.业务逻辑处理

        //endregion 5.过程处理
    }

    /**
     * 修改后置处理
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param rqVO
     * @param entity
     * @return void
     */
    protected void afterUpdate(DemandRQVO rqVO, MfDemand entity) {
        //region 1.输出特殊转换

        //region 1.1.输出过滤与补充处理
        //endregion 1.1.输出过滤与补充处理

        //endregion 1.输出特殊转换
    }


    /**
     * 删除前置处理
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param entity
     * @return void
     */
    private void beforeRemove(MfDemand entity) {
        if (entity == null) {
            throw new CsbrSystemException(SystemError.DATA_DEL_ERROR, messageSourceUtil.notExistsToDelMessage(FUNCTION_NAME));
        }
    }

    /**
     * 删除后置处理
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param entity
     * @return void
     */
    private void afterRemove(MfDemand entity) {

    }

    /**
     * 查询方法前置验证、处理
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param rqQueryVO
     * @return void
     */
    private void beforeQuery(DemandQueryVO rqQueryVO) {

    }

    /**
     * 查询方法后置数据转换、处理
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param pageList   数据库查询数据
     * @param rsPageList 返回的最终数据
     * @return void
     */
    private void afterQuery(PageListVO<MfDemand> pageList, PageListVO<DemandRSVO> rsPageList) {
        if (CollectionUtils.isNotEmpty(pageList.getRecords())) {
            rsPageList.setRecords(convertToVO(pageList.getRecords()));
        }
        // 需要特殊处理数据时使用
        /*if(CollectionUtils.isNotEmpty(pageList.getRecords())){
            List<DemandRSVO> results = new ArrayList<>();
            for (MfDemand item : pageList.getRecords()){
                DemandRSVO vo = convertToVO(item);
                results.add(vo);
            }
            rsPageList.setRecords(results);
        }*/
    }

    //region 辅助操作

    /**
     * 实体数据转换为视图对象数据（多个）
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param entityList 实体数据列表
     * @return java.util.List<com.csbr.qingcloud.domain.vo.DemandRSVO> 视图对象列表
     */
    private List<DemandRSVO> convertToVO(List<MfDemand> entityList) {
        if (CollectionUtils.isEmpty(entityList)) {
            // W00012 = {0}:参数[{1}]不能为空!
            throw new CsbrSystemException(SystemError.DATA_INPUT_ERROR, messageSourceUtil.getMessage("W00012",
                    "实体数据转换为视图对象实体数据", "实体数据"));
        }
        List<DemandRSVO> voList = new ArrayList<>(entityList.size());
        for (MfDemand item : entityList) {
            DemandRSVO vo = convertToVO(item);
            voList.add(vo);
        }
        return voList;
    }

    /**
     * 实体数据转换为视图对象数据
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param entity
     * @return com.csbr.qingcloud.domain.vo.DemandRSVO
     */
    private DemandRSVO convertToVO(MfDemand entity) {
        DemandRSVO vo = csbrBeanUtil.convert(entity, DemandRSVO.class);
        return vo;
    }

    /**
     * 新增、修改和其他情况的参数转换为实体
     * @author xushaobo
     * @date 2024-12-30 16:30
     * @param vo
     * @return com.csbr.qingcloud.mybatis.entity.MfDemand
     */
    private MfDemand convertToEntity(DemandRQVO vo) {
        MfDemand entity = csbrBeanUtil.convert(vo, MfDemand.class);
        // 新增时数据默认guid赋值，转换后该guid可能别使用
        if (StringUtils.isBlank(vo.getGuid())) {
            entity.setGuid(CommonUtil.newGuid());
        }
        return entity;
    }

    //endregion

}