jzg/platform/src/main/java/com/jzg/controller/EsmInsCompanyController.java

package com.jzg.controller;


import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.nacos.client.naming.utils.CollectionUtils;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.jzg.commons.core.base.BaseController;
import com.jzg.commons.core.page.HttpResult;
import com.jzg.commons.entity.dto.EsmInsCompanyAdd;
import com.jzg.commons.entity.dto.EsmInsCompanyEnd;
import com.jzg.commons.entity.po.EsmInsCompany;
import com.jzg.commons.entity.po.SysUploadFiles;
import com.jzg.commons.entity.system.vo.SysSystemBusPermsVo;
import com.jzg.commons.entity.vo.EsmInsCompanyReq;
import com.jzg.commons.entity.vo.EsmInsCompanyResVo;
import com.jzg.commons.entity.vo.EsmInsCompanyVo;
import com.jzg.commons.exception.SystemException;
import com.jzg.commons.request.RequestSingleParam;
import com.jzg.commons.util.AssertionUtils;
import com.jzg.commons.util.ConvertUtils;
import com.jzg.commons.util.MinioUtils;
import com.jzg.commons.util.StringUtils;
import com.jzg.constants.ManagementSourceEnum;
import com.jzg.mapper.SysUploadFilesMapper;
import com.jzg.service.EsmInsCompanyService;
import com.jzg.service.SysSystemService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

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

/**
 * ---------------------------
 * 保险公司管理 (EsmInsCompanyController)
 * ---------------------------
 * 作者：
 * ---------------------------
 */
@Tag(name = "保险公司管理")
@RestController
@RequestMapping("esmInsCompany")
public class EsmInsCompanyController extends BaseController {

    private static final Logger log = LoggerFactory.getLogger(EsmInsCompanyController.class);

    @Autowired
    private EsmInsCompanyService esmInsCompanyService;

    @Autowired
    private SysUploadFilesMapper sysUploadFilesMapper;

    @Autowired
    private SysSystemService sysSystemService;

    @Autowired
    private BaseController baseController;

    @Value("${minio.bucket-name}")
    private String bucketName;


    @PostMapping("leftList")
    @Operation(summary = "获取顶级保险公司列表")
    public HttpResult<List<EsmInsCompanyResVo>> leftList(@RequestBody EsmInsCompanyReq req) {
        List<EsmInsCompanyResVo> list = esmInsCompanyService.leftList(req);
        return HttpResult.ok(list);
    }

    /**
     * 通过保险公司id查询下级id及本级id
     * @return
     */
    @GetMapping("getChildCompanyId")
    @Operation(summary = "通过保险公司id查询下级id及本级id")
    public HttpResult<List<String>> getChildCompanyId(String companyId) {
        List<String> list = esmInsCompanyService.getByLowerId(companyId);
        return HttpResult.ok(list);
    }

    @GetMapping("getAllTopCompanyList")
    @Operation(summary = "获取订单报价完成的保险公司")
    public HttpResult getAllTopCompanyList() {
        List<EsmInsCompany> list = esmInsCompanyService.getAllBaseList();
        return HttpResult.ok(list);
    }

    /**
     * 查询下级保险公司（列表）
     *
     * @param req
     * @return
     */
    @Operation(summary = "查询下级保险公司（列表）")
    @PostMapping(value = "/selectLevelList")
    public HttpResult<List<EsmInsCompanyVo>> selectLevelList(@RequestBody EsmInsCompanyReq req) {
        LambdaQueryWrapper<EsmInsCompany> lambdaQueryWrapper = new LambdaQueryWrapper<>();
        lambdaQueryWrapper.eq(EsmInsCompany::getParentId, "0");
        lambdaQueryWrapper.eq(EsmInsCompany::getIsDelete, 0);
        lambdaQueryWrapper.like(StringUtils.isNotEmpty(req.getName()), EsmInsCompany::getName, req.getName());
        List<EsmInsCompany> selectList = esmInsCompanyService.list(lambdaQueryWrapper);
        List<EsmInsCompanyVo> esmInsCompanyVos = BeanUtil.copyToList(selectList, EsmInsCompanyVo.class);
        return HttpResult.ok(esmInsCompanyVos);
    }

    @PostMapping("/findLeftInsTree")
    @Operation(summary = "查询左侧树")
    public HttpResult<List<EsmInsCompany>> findLeftInsTree(@RequestSingleParam("type") String type) {
        LambdaQueryWrapper<EsmInsCompany> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(StringUtils.isNotEmpty(type), EsmInsCompany::getType, type);
        List<EsmInsCompany> lst = esmInsCompanyService.list(wrapper);
        return HttpResult.ok(lst);
    }

    @PostMapping("/findTree")
    @Operation(summary = "获取树结构")
    public HttpResult<List<EsmInsCompanyVo>> findTree(@RequestBody EsmInsCompanyReq req) {
        return HttpResult.ok(esmInsCompanyService.findTree(req));
    }

    @PostMapping(value = "/saveInsCompany")
    @Operation(summary = "保存信息")
    public HttpResult<Object> save(@Validated @RequestBody EsmInsCompanyAdd companyAdd) {
        ConvertUtils.emptyToNull(companyAdd);
        LambdaQueryWrapper<EsmInsCompany> lqw = new LambdaQueryWrapper<>();
        lqw.eq(EsmInsCompany::getCompanyCode, companyAdd.getCompanyCode());
        AssertionUtils.isFail(esmInsCompanyService.count(lqw) > 0, "供应商编码重复");
        AssertionUtils.isFail(esmInsCompanyService.count(
                new LambdaQueryWrapper<EsmInsCompany>().eq(EsmInsCompany::getName, companyAdd.getName())) > 0, "保司名称重复");
        EsmInsCompany esmInsCompany = BeanUtil.copyProperties(companyAdd, EsmInsCompany.class);
        //如果存在父类型则将type
        if (!companyAdd.getParentId().equals("0")) {
            EsmInsCompany parent = esmInsCompanyService.getById(companyAdd.getParentId());
            AssertionUtils.isEmpty(parent, "父级机构不存在");
            esmInsCompany.setType(parent.getType());
        }
        return esmInsCompanyService.save(esmInsCompany) ? HttpResult.ok("保存成功") : HttpResult.error("保存失败");
    }

    @PostMapping(value = "/editInsCompany")
    @Operation(summary = "修改信息")
    public HttpResult<Object> update(@Validated @RequestBody EsmInsCompanyEnd companyEnd) {
        ConvertUtils.emptyToNull(companyEnd);
        LambdaQueryWrapper<EsmInsCompany> lqw = new LambdaQueryWrapper<>();
        lqw.eq(EsmInsCompany::getCompanyCode, companyEnd.getCompanyCode());
        lqw.ne(EsmInsCompany::getId, companyEnd.getId());
        AssertionUtils.isFail(esmInsCompanyService.count(lqw) > 1, "供应商编码重复");
        EsmInsCompany esmInsCompany = BeanUtil.copyProperties(companyEnd, EsmInsCompany.class);
        return esmInsCompanyService.updateById(esmInsCompany) ? HttpResult.ok("修改成功") : HttpResult.error("修改失败");
    }

    /**
     * 查询下级机构列表
     *
     * @param parentid
     * @return
     */
    @Operation(summary = "查询下级机构列表")
    @PostMapping(value = "/selectList")
    public HttpResult<List<EsmInsCompany>> selectList(@RequestParam String parentid) {
        parentid = StringUtils.isEmpty(parentid) ? "0" : parentid;
        LambdaQueryWrapper<EsmInsCompany> lqw = new LambdaQueryWrapper<>();
        lqw.eq(EsmInsCompany::getParentId, parentid);
        List<EsmInsCompany> selectList = esmInsCompanyService.list(lqw);
        return HttpResult.ok(selectList);
    }

    /**
     * 根据主键查询保险公司信息
     *
     * @param id
     * @return HttpResult<EsmInsCompany>
     */
    @Operation(summary = "根据主键查询")
    @GetMapping(value = "/findById")
    public HttpResult<EsmInsCompany> findById(@RequestParam String id) {
        log.debug("根据公司id[{}]查询公司信息",id);
        return HttpResult.ok(esmInsCompanyService.getById(id));
    }

    @Operation(summary = "根据主键查询 替换Logo")
    @GetMapping(value = "/findLogoById")
    public HttpResult<EsmInsCompany> findLogoById(@RequestParam String id) {
        EsmInsCompany esmInsCompany = esmInsCompanyService.getById(id);
        SysUploadFiles sysUploadFiles = sysUploadFilesMapper.selectById(esmInsCompany.getLogo());
        Optional.ofNullable(sysUploadFiles)
                .map(SysUploadFiles::getFileName)
                .ifPresent(fileName -> {
                    String presignedObjectUrl = MinioUtils.getPresignedObjectUrl(bucketName, fileName);
                    esmInsCompany.setLogo(presignedObjectUrl);
                });
        return HttpResult.ok(esmInsCompany);
    }

    /**
     * 基础分页查询
     *
     * @param pageRequest
     * @return
     */
//    @PostMapping(value = "/findPage")
//    public HttpResult findPage(@RequestBody PageRequest pageRequest) {
//
//        String id = PageRequest.getColumnFilterValue(pageRequest, "id");
//        String name = PageRequest.getColumnFilterValue(pageRequest, "name");
//        String parentId = PageRequest.getColumnFilterValue(pageRequest, "parentId");
//
//        Page<EsmInsCompany> p = PageRequest.buildPageRequest(pageRequest);
//
//        LambdaQueryWrapper<EsmInsCompany> lqw = new LambdaQueryWrapper<>();
//        lqw.eq(StringUtils.isNotEmpty(id), EsmInsCompany::getId, id);
//        lqw.like(StringUtils.isNotEmpty(name), EsmInsCompany::getName, name);
//        lqw.eq(StringUtils.isNotEmpty(parentId), EsmInsCompany::getParentId, parentId);
//
//        IPage<EsmInsCompany> pResult = esmInsCompanyService.page(p, lqw);
//        //传入查询条件
//        PageResult<EsmInsCompany> pageResult = PageResult.buildPageResult(pResult);
//        return HttpResult.ok(pageResult);
//
//
//    }

//    /**
//     * 删除公司信息
//     *
//     * @param idList
//     * @return
//     */
//    @PostMapping(value = "/deleteInsCompany")
//    public HttpResult delete(@RequestParam List<String> idList) {
//        Integer result = 0;
//        String msg = "删除成功";
//
//        if (idList != null && idList.size() > 0) {
////            result = esmInsCompanyService.delete(idList);
//            esmInsCompanyService.removeByIds(idList);
//
////            esmInsCompanyService.allowQuote(null,idList);
//            return HttpResult.ok(msg);
//
//        } else {
//            msg = "编码不能为空";
//            return HttpResult.ok(msg, result);
//        }
//    }


    /**
     * 批量逻辑删除
     *
     * @author: lig
     * @date: 2023年04月14日 0014
     */
//    @Operation(value = "批量删除操作")
//    @DeleteMapping(value = "/idBatch")
//    public HttpResult<Object> deleteBatch(@RequestParam List<String> idList) {
//
//        LambdaUpdateWrapper<EsmInsCompany> lqw = new LambdaUpdateWrapper<>();
//        lqw.in(EsmInsCompany::getId, idList);
//        esmInsCompanyService.remove(lqw);
//
//        return HttpResult.ok("操作成功");
//
//    }
    @Operation(summary = "删除操作")
    @GetMapping(value = "/{id}")
    public HttpResult<Object> delete(@PathVariable("id") String id) {
        EsmInsCompany esmInsCompany = esmInsCompanyService.isExists(id);
        if ("0".equals(esmInsCompany.getParentId()) && !ManagementSourceEnum.MS_01.getCode()
                .equals(esmInsCompany.getType())) {
            throw new SystemException("财险,寿险,一级保险公司无法删除");
        }

        List<EsmInsCompany> list = esmInsCompanyService.list(new LambdaQueryWrapper<EsmInsCompany>().eq(EsmInsCompany::getParentId, id));
        AssertionUtils.isSucceed(list.isEmpty(), "此公司还有下级公司无法删除");

        esmInsCompanyService.removeById(id);
        return HttpResult.ok("操作成功");

    }

//    @Operation(value = "恢复删除操作")
//    @GetMapping(value = "/{id}")
//    public HttpResult rollBackDelete(@PathVariable("id") String id) {
//
//        EsmInsCompany eic = esmInsCompanyService.getById(id);
//        if (null == eic) return HttpResult.error("对象不存在");
//
//        eic.setDelFlag(0);
//        esmInsCompanyService.updateById(eic);
//
//        return HttpResult.ok("操作成功");
//
//    }


//    @Operation(value = "获取允许报价的保险公司列表")
//    @GetMapping(value = "/gainAllowQuoteList")
//    public HttpResult gainAllowQuoteList() {
//        LambdaQueryWrapper<EsmInsCompany> lqw = new LambdaQueryWrapper<>();
//        lqw.eq(EsmInsCompany::getDelFlag, 0);
//        lqw.eq(EsmInsCompany::getOpenQuote, 1);
//        lqw.eq(EsmInsCompany::getParentId, "0");
//        List<EsmInsCompany> list = esmInsCompanyService.list(lqw);
//        return HttpResult.ok(list);
//
//    }

    @Operation(summary = "获取顶级保险公司列表")
    @GetMapping(value = "/gainTopList")
    public HttpResult<List<EsmInsCompanyResVo>> gainTopList(@RequestParam String type,@RequestParam(required = false) String systemCode) {
        LambdaQueryWrapper<EsmInsCompany> lqw = new LambdaQueryWrapper<>();
        lqw.eq(EsmInsCompany::getParentId, "0");
        lqw.orderByAsc(EsmInsCompany::getOrderNum);
        lqw.eq(StringUtils.isNotEmpty(type), EsmInsCompany::getType, type);
        List<EsmInsCompany> list = esmInsCompanyService.list(lqw);
        if(Objects.nonNull(systemCode)) {
            SysSystemBusPermsVo perms = sysSystemService.getBusPerms(systemCode);
            if (perms.getQuoteCompany() == 2) {
                List<String> quoteCompanyList = perms.getQuoteCompanyList();
                if (!CollectionUtils.isEmpty(quoteCompanyList)) {
                    list = list.stream().filter(r -> quoteCompanyList.contains(r.getId())).collect(Collectors.toList());
                }
            }
        }
        List<EsmInsCompanyResVo> esmInsCompanyResVos = BeanUtil.copyToList(list, EsmInsCompanyResVo.class);
        // modify by lipf, 2026年4月16日17:44:27 对结果进行优化，按照中文进行排序
        // 1. 获取中文 Collator 实例
        Collator collator = Collator.getInstance(Locale.CHINA);
        // 2. 使用 Comparator.comparing 进行排序
        // 升序 (A-Z)
        esmInsCompanyResVos.sort(Comparator.comparing(EsmInsCompanyResVo::getNameSimple, collator));
        return HttpResult.ok(esmInsCompanyResVos);
    }

    @Operation(summary = "获取顶级保险公司和协议子集列表")
    @GetMapping(value = "/gainTopAgreementList")
    public HttpResult<List<EsmInsCompanyResVo>> gainTopAgreementList(@RequestParam String type) {
        LambdaQueryWrapper<EsmInsCompany> lqw = new LambdaQueryWrapper<>();
        lqw.eq(EsmInsCompany::getParentId, "0");
        lqw.orderByAsc(EsmInsCompany::getOrderNum);
        lqw.eq(StringUtils.isNotEmpty(type), EsmInsCompany::getType, type);
        List<EsmInsCompany> list = esmInsCompanyService.list(lqw);
        List<EsmInsCompanyResVo> esmInsCompanyResVos = BeanUtil.copyToList(list, EsmInsCompanyResVo.class);
//        for (EsmInsCompanyResVo esmInsCompany : esmInsCompanyResVos) {
//            PtlAgreementPageVo ptlAgreementPageVo = new PtlAgreementPageVo();
//            ptlAgreementPageVo.setPartnerCompaniesId(esmInsCompany.getId());
//            HttpResult<List<PtlAgreement>> agreement = ptlAgreementService.listAgreement(ptlAgreementPageVo);
//            List<PtlAgreement> agreementList = agreement.getData();
//            for (PtlAgreement ptlAgreement : agreementList) {
//                ptlAgreement.setName(ptlAgreement.getAgreementName() +
//                        (StringUtils.isBlank(ptlAgreement.getJobDescription())? "" : "-"+ptlAgreement.getJobDescription()) +
//                        (StringUtils.isBlank(ptlAgreement.getBusinessDescription())? "" : "-"+ptlAgreement.getBusinessDescription()));
//            }
//            esmInsCompany.setAgreementList(agreementList);
//        }
        return HttpResult.ok(esmInsCompanyResVos);
    }

    @Operation(summary = "查询保司机构下级")
    @GetMapping(value = "/queryListByParentId/{parentId}")
    public HttpResult<List<EsmInsCompany>> queryListByParentId(@PathVariable("parentId") String parentId) {
        if (parentId == null || "".equals(parentId)) {
            return HttpResult.error("parentId父级id不能为空");
        }
        List<EsmInsCompany> esmInsCompanyList = esmInsCompanyService.queryListByParentId(parentId);
        return HttpResult.ok(esmInsCompanyList);
    }

    /**
     * @version
     * @author: hxl
     * @Date: 2024/9/20 16:22
     * @Description: 查询子订单中的保险公司列表
     */
    @Operation(summary = "查询子订单中的保险公司列表")
    @GetMapping(value = "/findOrderCompanyList")
    public HttpResult<List<EsmInsCompanyResVo>> findOrderCompanyList() {
        List<EsmInsCompanyResVo> esmInsCompanyList = esmInsCompanyService.findOrderCompanyList();
        return HttpResult.ok(esmInsCompanyList);
    }

    /**
     * @version
     * @author: hxl
     * @Date: 2024/12/12 14:29
     * @Description: 获取外部协议的保险公司的集合
     */
    @PostMapping("/getExternalAgreementCompanyList")
    @Operation(summary = "获取外部协议的保险公司的集合")
    public HttpResult<List<EsmInsCompanyResVo>> getExternalAgreementCompanyList(@RequestSingleParam("name") String name) {
        List<EsmInsCompanyResVo> lst = esmInsCompanyService.getExternalAgreementCompanyList(name);
        return HttpResult.ok(lst);
    }


    @Operation(summary = "查找存在协议的保险公司列表")
    @GetMapping(value = "/liveCompanyList")
    public HttpResult liveCompanyList() {
        List<EsmInsCompanyResVo> list = esmInsCompanyService.liveCompanyList();
        return HttpResult.ok(list);
    }

    /**
     * @version
     * @author: hxl
     * @date: 2025/1/18 15:26
     * @Description: 查询子订单的合作公司列表
     */
    @Operation(summary = "查询子订单中的合作公司列表")
    @GetMapping(value = "/findOrderPartnerCompanyList")
    public HttpResult<List<EsmInsCompanyResVo>> findOrderPartnerCompanyList() {
        List<EsmInsCompanyResVo> esmInsCompanyList = esmInsCompanyService.findOrderPartnerCompanyList();
        return HttpResult.ok(esmInsCompanyList);
    }

    @Operation(summary = "根据保险公司id获取保司列表")
    @GetMapping(value = "/getCompanyByIds")
    public HttpResult<List<EsmInsCompany>> getCompanyByIds(String ids) {
        List<String> companyList = Arrays.asList(ids.split(","));
        List<EsmInsCompany> esmInsCompanyList = esmInsCompanyService.getCompanyByIds(companyList);
        return HttpResult.ok(esmInsCompanyList);
    }

    @Operation(summary = "获取保司排序信息")
    @GetMapping(value = "getCompanySort")
    public HttpResult<List<EsmInsCompany>> getCompanySort(){
        List<EsmInsCompany> companyByIds = esmInsCompanyService.getCompanySort(baseController.getUserSystemCode());
        return HttpResult.ok(companyByIds);
    }

    @Operation(summary = "更新保司排序信息")
    @PostMapping(value = "updateCompanySort")
    public HttpResult<String> updateCompanySort(@RequestBody List<EsmInsCompany> esmInsCompanyList){
        boolean result = esmInsCompanyService.updateCompanySort(esmInsCompanyList,baseController.getUserSystemCode());
        return result ?  HttpResult.ok("更新保司排序成功") : HttpResult.error("更新保司排序失败");
    }

    @Operation(summary = "获取保司的所有下级id")
    @PostMapping(value = "getParentIds")
    public HttpResult getParentIds(@RequestBody List<String> companyIds){
        return HttpResult.ok(esmInsCompanyService.getParentIds(companyIds));
    }

    @Operation(summary = "查找顶级保司id")
    @PostMapping(value = "getTopCompanyId")
    public HttpResult getTopCompanyId(@RequestBody String companyId){
        return HttpResult.ok(esmInsCompanyService.getTopCompanyId(companyId));
    }

    /**
     * 获取所有保险公司的全路径名称
     * Key: 公司ID
     * Value: 总公司/分公司/支公司
     */
    @Operation(summary = "获取所有保险公司的全路径名称")
    @GetMapping("getAllCompanyHierarchyPaths")
    public Map<String, String> getAllCompanyHierarchyPaths(){
        return esmInsCompanyService.getAllCompanyHierarchyPaths();
    }

    /**
     * 获取所有保险公司的对应关系
     *
     * @return HttpResult<Map<String,EsmInsCompany>> key是保险公司id， value是保险公司对象实体
     * @author lipf
     * @date 2026年5月23日09:06:47
     */
    @Operation(summary = "获取所有保险公司的对应关系")
    @GetMapping("queryAllCompanyMap")
    public HttpResult<Map<String,EsmInsCompany>> queryAllCompanyMap(){
        return HttpResult.ok(esmInsCompanyService.queryAllCompanyMap());
    }

    /**
     * 查询保险公司关联的所有子公司和总公司
     *
     * @param companyId 保险公司的id
     * @return HttpResult<List<String>>
     * @author lipf
     * @date 2026年7月31日09:29:26
     */
    @Operation(summary = "查询保险公司关联的所有子公司和总公司")
    @GetMapping("/queryRelatedCompanyIds")
    HttpResult<List<String>> queryRelatedCompanyIds(@RequestParam("companyId") String companyId){
        List<String> companyIds = esmInsCompanyService.queryRelatedCompanyIds(companyId);
        companyIds = companyIds.stream().distinct().toList();
        log.info("查询保险公司关联的所有子公司和总公司： companyId=[{}], companyIds=[{}],companyIds.size=[{}]", companyId, JSONUtil.toJsonStr(companyIds), CollUtil.size(companyIds));
        return HttpResult.ok(companyIds);
    }

    /**
     * 查询保险公司的所有子公司(含子子公司)以及保险公司本身
     *
     * @author lipf
     * @date 2026/7/31 9:44
     */
    @GetMapping("/queryOwnAndSubCompandyIds")
    HttpResult<List<String>> queryOwnAndSubCompandyIds(@RequestParam("companyId") String companyId){
        List<String> companyIds = esmInsCompanyService.queryOwnAndSubCompandyIds(companyId);
        companyIds = companyIds.stream().distinct().toList();
        log.info("查询保险公司关联的所有子公司： companyId=[{}], companyIds=[{}],companyIds.size=[{}]", companyId, JSONUtil.toJsonStr(companyIds), CollUtil.size(companyIds));
        return HttpResult.ok(companyIds);
    }
}