iboss-server-mdm/src/main/java/com/dk/mdm/service/mst/OrgService.java

package com.dk.mdm.service.mst;

import com.dk.common.infrastructure.annotaiton.Pagination;
import com.dk.common.infrastructure.constant.Constant;
import com.dk.common.model.pojo.PageList;
import com.dk.common.response.ResponseCodeEnum;
import com.dk.common.response.ResponseResultUtil;
import com.dk.common.response.ResponseResultVO;
import com.dk.mdm.infrastructure.convert.core.OrganizationConvert;
import com.dk.mdm.infrastructure.convert.mst.OrgConvert;
import com.dk.mdm.model.pojo.core.Organization;
import com.dk.mdm.model.pojo.mst.Org;
import com.dk.mdm.mapper.mst.OrgMapper;
import com.dk.common.service.BaseService;
import com.dk.common.mapper.BaseMapper;
import com.dk.mdm.model.query.core.OrganizationQuery;
import com.dk.mdm.model.query.mst.GoodsCategoryQuery;
import com.dk.mdm.model.query.mst.OrgQuery;
import com.dk.mdm.model.response.core.OrganizationResponse;
import com.dk.mdm.model.vo.core.OrganizationVO;
import com.dk.mdm.model.vo.mst.OrgVO;
import com.dk.mdm.service.common.CommonService;
import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

import java.util.Map;

@Service
@Transactional
public class OrgService extends BaseService<Org> {
    /**
     * @desc : 重写主键
     * @author : 王英杰
     * @date : 2023/1/9 10:39
     */
    @Override
    public String getPrimaryKey() {
        return "org_id";
    }
    @Override
    public BaseMapper<Org> getRepository() {
        return orgMapper;
    }

    @Autowired
    private OrgMapper orgMapper;

    @Autowired
    private OrgConvert orgConvert;
    @Autowired
    private CommonService commonService;
    /**
     * @desc : 条件查询
     * @author : 王英杰
     * @date : 2023/1/10 17:19
     */
    @Pagination
    public ResponseResultVO<PageList<Org>> selectByCond(OrgQuery orgQuery) {
        return super.mergeListWithCount(orgQuery, orgMapper.selectByCond(orgQuery),
                orgMapper.countByCond(orgQuery));
    }

    /**
     * @desc : 新建组织机构
     * @author : 王英杰
     * @date : 2024/2/27 9:17
     */
    @Transactional(
            rollbackFor = {Exception.class}
    )
    public ResponseResultVO<?> insert(OrgVO orgVO) {
        // 转化实体
        Org organization = orgConvert.convertToPo(orgVO);
        Map<String, Object> codeMap = commonService.getUniqueNoteCode(Constant.docNameConstant.STAFF.getName(), false);

        organization.setOrgId(codeMap.get("outId").toString());
//        organization.setOrgCode(codeMap.get("outNote").toString());

        //查询 本次要加的 部门的 父级下 最大的DisplayNo  然后加1  就是现在要加的DisplayNo
        String parentId = organization.getParentId();
        int maxDisplayNo = orgMapper.maxDisplayNo(parentId) != null ? orgMapper.maxDisplayNo(parentId) + 1 : 0;


        organization.setDisplayNo(maxDisplayNo);
        // 插入组织部门数据
        super.insert(organization);
        //执行函数
        orgMapper.resetLevelOrg(new Org().setTopId(organization.getParentId()).setCpId(organization.getCpId()));
        return ResponseResultUtil.success();
        //        return result == 1 ? ResponseResultUtil.success(organization) :
//                ResponseResultUtil.error(ResponseCodeEnum.INSERT_FAIL);
    }
}