ContractServiceImpl.java

package vion.service.impl;

import cn.dev33.satoken.stp.StpUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.core.toolkit.support.SFunction;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.toolkit.Db;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.node.ArrayNode;
import com.github.yulichang.base.MPJBaseServiceImpl;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import io.github.linpeilie.Converter;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.dromara.hutool.core.array.ArrayUtil;
import org.dromara.hutool.core.bean.BeanUtil;
import org.dromara.hutool.core.bean.copier.CopyOptions;
import org.dromara.hutool.core.collection.CollUtil;
import org.dromara.hutool.core.collection.ListUtil;
import org.dromara.hutool.core.collection.set.SetUtil;
import org.dromara.hutool.core.comparator.CompareUtil;
import org.dromara.hutool.core.date.TimeUtil;
import org.dromara.hutool.core.io.file.FileNameUtil;
import org.dromara.hutool.core.io.file.FileUtil;
import org.dromara.hutool.core.lang.Assert;
import org.dromara.hutool.core.lang.Opt;
import org.dromara.hutool.core.map.MapUtil;
import org.dromara.hutool.core.math.NumberUtil;
import org.dromara.hutool.core.text.StrUtil;
import org.dromara.hutool.core.util.ObjUtil;
import org.dromara.hutool.crypto.SecureUtil;
import org.dromara.hutool.http.client.HttpDownloader;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.MediaType;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.client.RestClient;
import vion.dto.ContractDTO;
import vion.dto.RContractTeamDTO;
import vion.mapper.ContractMapper;
import vion.mapper.SettlementDiffMapper;
import vion.model.Dictionary;
import vion.model.*;
import vion.service.*;
import vion.third.DingMod;
import vion.utils.JsonUtil;
import vion.vo.*;

import java.io.File;
import java.io.IOException;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.stream.StreamSupport;

/**
 * @author vion
 * @date 2023/11/29
 */
@Service
@RequiredArgsConstructor
@Slf4j
public class ContractServiceImpl extends MPJBaseServiceImpl<ContractMapper, Contract> implements IContractService {

    private final IFileService fileService;
    private final IContractPaymentService contractPaymentService;
    private final IRContractStoreService contractStoreService;
    private final IContractLogService contractLogService;
    private final IRContractTeamService contractTeamService;
    private final IRContractUserService contractUserService;
    private final IRContractProductService contractProductService;
    private final IRStoreUserService storeUserService;
    // 引入 settlementDiffService 会循环依赖
    private final SettlementDiffMapper settlementDiffMapper;
    private final DingMod dingMod;
    private final Converter converter;
    private final RestClient bongRestClient;

    @Value("${fileUrl:}")
    private String fileUrl;
    @Value("${xbongbong.corpid}")
    private String corpId;
    @Value("${xbongbong.token}")
    private String token;

    @Override
    public Page<ContractVO> list(ContractDTO dto) {
        Result result = getResult(dto);

        Page<ContractVO> page = Page.of(dto.getPageNum(), dto.getPageSize());
        Opt.ofNullable(dto.getOrderItem())
                .ifPresent(page::addOrder);
        Page<ContractVO> contractVOList = this.selectJoinListPage(page, ContractVO.class, result.wrapper);

        var idList = Opt.ofEmptyAble(contractVOList.getRecords())
                .map(r -> r.stream().map(ContractVO::getId).collect(Collectors.toList()))
                .orElse(ListUtil.empty());

        // 结算差异
        Opt.ofEmptyAble(idList)
                .map(l -> settlementDiffMapper.selectList(Wrappers.<SettlementDiff>lambdaQuery()
                        .in(SettlementDiff::getContractId, l)))
                .map(list -> list.stream().collect(Collectors.groupingBy(SettlementDiff::getContractId, Collectors.reducing(BigDecimal.ZERO, SettlementDiff::getSettlementDiff, BigDecimal::add))))
                .ifPresent(map -> contractVOList.getRecords().forEach(vo -> vo.setDiffAmount(map.getOrDefault(vo.getId(), BigDecimal.ZERO))));
        // 合同绑定销售
        Opt.ofEmptyAble(idList)
                .map(l -> contractUserService.lambdaQuery()
                        .in(RContractUser::getContractId, l)
                        .list())
                .map(list -> list.stream().collect(Collectors.groupingBy(RContractUser::getContractId)))
                .ifPresent(map -> contractVOList.getRecords().forEach(vo -> map.getOrDefault(vo.getId(), ListUtil.empty()).stream()
                        .max(Comparator.comparing(RContractUser::getEnterDate))
                        .map(RContractUser::getUsername)
                        .ifPresent(vo::setSaleName)));

        completeStoreName(contractVOList.getRecords());
        if (!result.roleCodeList.contains("admin") && !result.roleCodeList.contains("xiaoshou") && !result.roleCodeList.contains("caiwu")) {
            contractVOList.getRecords().forEach(vo -> {
                vo.setTotalAmount(null);
                vo.setPaidAmount(null);
                vo.setReceivableAmount(null);
                vo.setOutstandingAmount(null);
                vo.setInvoiceAmount(null);
                vo.setDiffAmount(null);
            });
        }
        return contractVOList;
    }

    @Override
    public Page<ContractVO> listPart(ContractDTO dto) {
        List<Long> ids = Opt.ofNullable(dto.getStoreId())
                .map(storeId -> contractStoreService.listObjs(Wrappers.<RContractStore>lambdaQuery().select(RContractStore::getContractId).eq(RContractStore::getStoreId, dto.getStoreId()), o -> Long.valueOf(o.toString())))
                .filter(CollUtil::isNotEmpty)
                .orElse(ListUtil.of(0L));

        Page<Contract> contractList = this.lambdaQuery(converter.convert(dto, Contract.class))
                .select(Contract::getId, Contract::getName, Contract::getContractNo, Contract::getType, Contract::getSignDate, Contract::getWarrantyPeriod, Contract::getFinalDate, Contract::getStatus, Contract::getSaleName, Contract::getCustomerName, Contract::getMaintainSdate, Contract::getMaintainEdate)
                .in(ObjUtil.isNotNull(dto.getStoreId()), Contract::getId, ids)
                .orderByDesc(Contract::getEntryTime)
                .page(Page.of(dto.getPageNum(), dto.getPageSize()));
        List<ContractVO> contractVOList = converter.convert(contractList.getRecords(), ContractVO.class);
        completeStoreName(contractVOList);
        return Page.<ContractVO>of(contractList.getCurrent(), contractList.getSize(), contractList.getTotal()).setRecords(contractVOList);
    }

    @Override
    public Page<ContractVO> listByMain(ContractDTO dto) {
        Result result = getResult(dto);

        Page<ContractVO> page = Page.of(dto.getPageNum(), dto.getPageSize());
        Opt.ofNullable(dto.getOrderItem())
                .ifPresent(page::addOrder);
        Page<ContractVO> contractVOList = this.selectJoinListPage(page, ContractVO.class, result.wrapper);

        var idList = Opt.ofEmptyAble(contractVOList.getRecords())
                .map(r -> r.stream().map(ContractVO::getId).collect(Collectors.toList()))
                .orElse(List.of());

        // 根据合同关联的项目，获取项目的相关信息
        var contractStoreList = Opt.ofEmptyAble(idList)
                .map(ids -> contractStoreService.lambdaQuery().in(RContractStore::getContractId, ids).list())
                .orElse(List.of());
        var contractId2StoresMap = Opt.ofEmptyAble(contractStoreList)
                .map(l -> l.stream().collect(Collectors.groupingBy(RContractStore::getContractId,
                        Collectors.mapping(RContractStore::getStoreId, Collectors.toList()))))
                .orElse(Map.of());
        var storeMap = Opt.ofEmptyAble(contractStoreList)
                .map(cs -> cs.stream().map(RContractStore::getStoreId).toList())
                .map(storeIds -> Db.listByIds(storeIds, Store.class).stream().collect(Collectors.toMap(Store::getId, Function.identity())))
                .orElse(Map.of());
        var storeId2UserIdMap = Opt.ofEmptyAble(contractStoreList)
                .map(cs -> cs.stream().map(RContractStore::getStoreId).toList())
                .map(storeIds -> storeUserService.lambdaQuery().in(RStoreUser::getStoreId, storeIds).eq(RStoreUser::getIsMain, 1).list())
                .map(suList -> suList.stream().collect(Collectors.toMap(RStoreUser::getStoreId, RStoreUser::getUserId)))
                .orElse(MapUtil.empty());

        // 合同绑定销售
        Opt.ofEmptyAble(idList)
                .map(l -> contractUserService.lambdaQuery()
                        .in(RContractUser::getContractId, l)
                        .list())
                .map(list -> list.stream().collect(Collectors.groupingBy(RContractUser::getContractId)))
                .ifPresent(map -> contractVOList.getRecords().forEach(vo -> map.getOrDefault(vo.getId(), ListUtil.empty()).stream()
                        .max(Comparator.comparing(RContractUser::getEnterDate))
                        .map(RContractUser::getUsername)
                        .ifPresent(vo::setSaleName)));

        completeStoreName(contractVOList.getRecords());
        contractVOList.getRecords().forEach(vo -> {
            vo.setTotalAmount(null);
            vo.setPaidAmount(null);
            vo.setReceivableAmount(null);
            vo.setOutstandingAmount(null);
            vo.setInvoiceAmount(null);
            vo.setDiffAmount(null);
            var storeList = contractId2StoresMap.getOrDefault(vo.getId(), List.of()).stream()
                    .map(storeMap::get)
                    .collect(Collectors.toList());
            var storeVOList = converter.convert(storeList, StoreVO.class);
            storeVOList.forEach(storeVO -> storeVO.setMainUser(storeId2UserIdMap.getOrDefault(storeVO.getId(), null)));
            vo.setStoreVOS(storeVOList);
        });
        return contractVOList;
    }

    /**
     * 查出合同关联的项目名
     *
     * @param contractVOList list
     */
    private void completeStoreName(List<ContractVO> contractVOList) {
        Map<Long, List<Long>> contractStoreIdsMap = Opt.ofEmptyAble(contractVOList)
                .map(list -> list.stream().map(ContractVO::getId).collect(Collectors.toList()))
                .map(contractIds -> contractStoreService.list(Wrappers.<RContractStore>lambdaQuery().in(RContractStore::getContractId, contractIds)))
                .map(contractStoreList -> contractStoreList.stream().collect(Collectors.groupingBy(RContractStore::getContractId, Collectors.mapping(RContractStore::getStoreId, Collectors.toList()))))
                .orElse(MapUtil.empty());

        Opt.of(contractStoreIdsMap)
                .filter(MapUtil::isNotEmpty)
                .map(map -> map.values().stream().flatMap(List::stream).collect(Collectors.toList()))
                .map(storeIds -> Db.listByIds(storeIds, Store.class))
                .map(storeList -> storeList.stream().collect(Collectors.toMap(Store::getId, Function.identity())))
                .ifPresent(storeId2StoreMap -> contractVOList.forEach(contractVO -> {
                    if (contractStoreIdsMap.containsKey(contractVO.getId())) {
                        List<StoreVO> storeVOS = converter.convert(contractStoreIdsMap.get(contractVO.getId()).stream().map(storeId2StoreMap::get).collect(Collectors.toList()), StoreVO.class);
                        contractVO.setStoreVOS(storeVOS);
                    }
                }));
    }

    @Override
    public ContractVO getVOById(Long id) {
        UserVO userVO = (UserVO) StpUtil.getTokenSession().get("curLoginUser");
        Set<String> roleCodeList = Opt.ofEmptyAble(userVO.getRoleVOList())
                .map(l -> l.stream().map(RoleVO::getCode).collect(Collectors.toSet()))
                .orElse(SetUtil.zero());
        MPJLambdaWrapper<Contract> wrapper = new MPJLambdaWrapper<Contract>()
                .selectAll(Contract.class)
                .selectCollection(ContractLog.class, ContractVO::getContractLogs)
                .leftJoin(ContractLog.class, ContractLog::getContractNo, Contract::getContractNo)
                .eq(Contract::getId, id);
        ContractVO contractVO = this.selectJoinOne(ContractVO.class, wrapper);
        if (!roleCodeList.contains("admin") && !roleCodeList.contains("xiaoshou") && !roleCodeList.contains("caiwu")) {
            contractVO.setTotalAmount(null);
            contractVO.setPaidAmount(null);
            contractVO.setReceivableAmount(null);
            contractVO.setOutstandingAmount(null);
            contractVO.setInvoiceAmount(null);
        }
        // 合同关联产品
        var contractProducts = contractProductService.lambdaQuery()
                .eq(RContractProduct::getContractNo, contractVO.getContractNo())
                .list();
        // 合同绑定销售
        Opt.ofEmptyAble(contractUserService.lambdaQuery().eq(RContractUser::getContractId, contractVO.getId()).list())
                .ifPresent(l -> l.stream()
                        .max(Comparator.comparing(RContractUser::getEnterDate))
                        .map(RContractUser::getUsername)
                        .ifPresent(contractVO::setSaleName));
        contractVO.setContractProducts(contractProducts);
        return contractVO;
    }

    @Override
    public ContractVO getByNo(String no) {
        Contract contract = this.lambdaQuery()
                .select(Contract::getId, Contract::getName, Contract::getContractNo, Contract::getType, Contract::getSignDate, Contract::getWarrantyPeriod, Contract::getFinalDate, Contract::getStatus, Contract::getSaleName, Contract::getCustomerName)
                .eq(Contract::getContractNo, no)
                .one();
        ContractVO contractVO = converter.convert(contract, ContractVO.class);
        Assert.notNull(contractVO, "合同不存在");
        MPJLambdaWrapper<RContractStore> wrapper = new MPJLambdaWrapper<RContractStore>()
                .select(Store::getId, Store::getName)
                .leftJoin(Store.class, Store::getId, RContractStore::getStoreId)
                .eq(RContractStore::getContractId, contract.getId());
        List<StoreVO> storeVOS = contractStoreService.selectJoinList(StoreVO.class, wrapper);
        contractVO.setStoreVOS(storeVOS);
        return contractVO;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String updateById(Long id, String contractNo, ContractDTO dto) {
        Contract existContract = new Contract();
        if (ObjUtil.isNotNull(id)) {
            existContract = this.getById(id);
        } else if (StrUtil.isNotBlank(contractNo)) {
            existContract = this.lambdaQuery().eq(Contract::getContractNo, contractNo).one();
        }
        Assert.isFalse(BeanUtil.isEmpty(existContract), "合同不存在");

        Contract contract = converter.convert(dto, Contract.class);
        // 如果当前合同进度在要修改的进度前，此时不能修改合同进度。e.g 当前合同进度是项目验收，此时传参过来到货，那么不能修改
        if (ObjUtil.isNotNull(contract.getStatus()) && contract.getStatus() < existContract.getStatus()) {
            contract.setStatus(null);
        }
        Long contractId = existContract.getId();
        String existContractNo = existContract.getContractNo();
        contract.setId(contractId);
        contractPaymentService.calMoney(existContract, contract);
        if (this.updateById(contract)) {
            Opt.ofNullable(dto.getNodeDate())
                    .ifPresent(date -> contractPaymentService.lambdaUpdate()
                            .set(ContractPayment::getNodeDate, date)
                            .eq(ContractPayment::getContractId, contractId)
                            .eq(ContractPayment::getPaymentType, dto.getStatus())
                            .update(new ContractPayment()));

            UserVO userVO = (UserVO) StpUtil.getTokenSession().get("curLoginUser");
            Contract finalExistContract = existContract;
            Opt.ofNullable(dto.getStatus())
                    .ifPresent(status -> {
                        // 当前合同进度在要修改的进度前，不再推送钉钉消息和记录日志
                        if (ObjUtil.isNull(contract.getStatus())) {
                            return;
                        }
                        String useridStr = Opt.ofEmptyAble(contractUserService.lambdaQuery()
                                        .eq(RContractUser::getContractNo, existContractNo).list())
                                .map(l -> l.stream().map(RContractUser::getContractNo).collect(Collectors.joining(",")))
                                .orElse("");

                        ContractLog contractLog = new ContractLog();
                        contractLog.setContractNo(existContractNo);
                        if (status.equals(1)) {
                            contractLog.setContent("合同：已签订");
                        } else if (status.equals(2)) {
                            contractLog.setContent("合同：已到货");
                        } else if (status.equals(3)) {
                            contractLog.setContent("合同：系统验收");
                            dingMod.workMsg(buildMsg(useridStr, dto, finalExistContract, "系统验收(初验)"));
                        } else if (status.equals(4)) {
                            contractLog.setContent("合同：项目验收");
                            dingMod.workMsg(buildMsg(useridStr, dto, finalExistContract, "项目验收(终验)"));
                        } else if (status.equals(5)) {
                            contractLog.setContent("合同：质保");
                        } else if (status.equals(6)) {
                            contractLog.setContent("合同：第一笔维保款");
                        } else if (status.equals(7)) {
                            contractLog.setContent("合同：第二笔维保款");
                        } else if (status.equals(8)) {
                            contractLog.setContent("合同：第三笔维保款");
                        } else if (status.equals(9)) {
                            contractLog.setContent("合同：维保进度款");
                        } else if (status.equals(10)) {
                            contractLog.setContent("合同：维保验收款");
                        }
                        contractLog.setOperator(userVO.getId());
                        contractLogService.save(contractLog);
                    });

            Opt.ofNullable(dto.getFiles())
                    .ifPresent(fileList ->
                            Arrays.stream(fileList).forEach(infile -> {
                                //上传url地址
                                String orgName = infile.getOriginalFilename();
                                String mainName = FileNameUtil.mainName(orgName);
                                String fileExt = FileNameUtil.extName(orgName);
                                String filename = StrUtil.format("{}_{}.{}", mainName, TimeUtil.format(LocalDateTime.now(), "yyyyMMdd_HHmmssSSS"), fileExt);
                                String path = fileUrl + FileUtil.FILE_SEPARATOR + "contract" + FileUtil.FILE_SEPARATOR + contract.getId() + FileUtil.FILE_SEPARATOR + filename;
                                File file = FileUtil.touch(path);
                                try {
                                    infile.transferTo(file);
                                } catch (IOException e) {
                                    log.error("保存文件出错", e);
                                }

                                FileInfo fileInfo = new FileInfo();
                                fileInfo.setStoreId(-1L);
                                fileInfo.setSourceId(contract.getId());
                                fileInfo.setSourceType(dto.getSourceType());
                                fileInfo.setContractId(contract.getId());
                                fileInfo.setName(filename);
                                fileInfo.setUrl(path);
                                fileInfo.setType(fileExt);
                                fileInfo.setSha256(SecureUtil.sha256(file).toUpperCase());
                                fileInfo.setUploader(userVO.getUsername());
                                fileService.save(fileInfo);
                            }));
            return "更新成功";
        } else {
            return "更新失败";
        }
    }

    @Override
    public JsonNode calAmount(ContractDTO dto) {
        Result result = getResult(dto);

        var obj = JsonUtil.createObj()
                .put("totalAmount", 0)
                .put("paidAmount", 0)
                .put("recAmount", 0)
                .put("outAmount", 0)
                .put("invoiceAmount", 0);
        if (!result.roleCodeList.contains("admin") && !result.roleCodeList.contains("xiaoshou") && !result.roleCodeList.contains("caiwu")) {
            return obj;
        }
        List<Contract> contracts = this.selectJoinList(Contract.class, result.wrapper);

        Opt.ofEmptyAble(contracts)
                .ifPresent(list -> {
                    BigDecimal totalAmount = list.stream().map(Contract::getTotalAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
                    BigDecimal paidAmount =
                            list.stream().map(v -> CompareUtil.max(BigDecimal.ZERO, v.getPaidAmount())).reduce(BigDecimal.ZERO,
                                    BigDecimal::add);
                    BigDecimal recAmount = list.stream().map(v -> CompareUtil.max(BigDecimal.ZERO, v.getReceivableAmount())).reduce(BigDecimal.ZERO, BigDecimal::add);
                    BigDecimal outAmount = list.stream().map(Contract::getOutstandingAmount).reduce(BigDecimal.ZERO, BigDecimal::add);

                    List<String> noList = list.stream().map(Contract::getContractNo).collect(Collectors.toList());
                    List<BigDecimal> invoices = Db.listObjs(Wrappers.lambdaQuery(Invoice.class).select(Invoice::getInvoiceAmount).in(BeanUtil.isNotEmpty(dto), Invoice::getContractNo, noList), Invoice::getInvoiceAmount);
                    BigDecimal invoiceAmount = invoices.stream().reduce(BigDecimal.ZERO, BigDecimal::add);

                    obj.put("totalAmount", totalAmount)
                            .put("paidAmount", paidAmount)
                            .put("recAmount", recAmount)
                            .put("outAmount", outAmount)
                            .put("invoiceAmount", invoiceAmount);
                });
        return obj;
    }

    @Override
    public Map<Integer, Long> statStatus(ContractDTO dto) {
        Result result = getResult(dto);
        List<Contract> contracts = this.selectJoinList(Contract.class, result.wrapper);
        return contracts.stream().collect(Collectors.groupingBy(Contract::getStatus, Collectors.counting()));
    }

    @Override
    public Map<String, Object> analyze(ContractDTO dto) {
        List<Contract> contractList = this.lambdaQuery(converter.convert(dto, Contract.class))
                .gt(Contract::getReceivableAmount, 0)
                .gt(Contract::getTotalAmount, 0)
                .between(ArrayUtil.isAllNotNull(dto.getSignDateStart(), dto.getSignDateEnd()), Contract::getSignDate, dto.getSignDateStart(), dto.getSignDateEnd())
                .list();
        if (CollUtil.isEmpty(contractList)) {
            return Map.of();
        }

        Map<Long, List<ContractPayment>> id2PaymentMap = Opt.ofEmptyAble(contractPaymentService
                        .lambdaQuery().gt(ContractPayment::getPaymentRatio, 0)
                        .list())
                .map(list -> list.stream().collect(Collectors.groupingBy(ContractPayment::getContractId)))
                .orElse(MapUtil.empty());
        if (MapUtil.isEmpty(id2PaymentMap)) {
            return Map.of();
        }
        List<FinancialAgeVO> financialAgeVOList = new ArrayList<>();

        contractList.forEach(c -> {
            List<ContractPayment> contractPaymentList = id2PaymentMap.get(c.getId());
            if (CollUtil.isEmpty(contractPaymentList)) {
                return;
            }
            BigDecimal totalAmount = c.getTotalAmount();
            BigDecimal paidAmount = c.getPaidAmount();
            Map<Integer, LocalDate> type2DateMap =
                    contractPaymentList.stream().filter(cp -> cp.getPaymentType() <= c.getStatus()).collect(HashMap::new, (m, v) -> m.put(v.getPaymentType(), v.getPaymentDate()), HashMap::putAll);

            Map<Integer, BigDecimal> type2AmountMap = contractPaymentList.stream().filter(cp -> cp.getPaymentType() <= c.getStatus()).collect(Collectors.toMap(ContractPayment::getPaymentType, v -> NumberUtil.mul(v.getPaymentRatio(), totalAmount)));
            TreeMap<Integer, BigDecimal> sortMap = MapUtil.sort(type2AmountMap, Comparator.comparingInt(Integer::intValue));

            for (Map.Entry<Integer, BigDecimal> entry : sortMap.entrySet()) {
                Integer type = entry.getKey();
                BigDecimal curAmount = entry.getValue();
                if (CompareUtil.gt(paidAmount, BigDecimal.ZERO)) {
                    paidAmount = NumberUtil.sub(paidAmount, curAmount);
                    if (NumberUtil.equals(paidAmount, BigDecimal.ZERO)) {
                        continue;
                    }
                }
                if (CompareUtil.le(paidAmount, BigDecimal.ZERO)) {
                    FinancialAgeVO financialAgeVO = new FinancialAgeVO();
                    financialAgeVO.setContractNo(c.getContractNo());
                    financialAgeVO.setContractName(c.getName());
                    financialAgeVO.setStatus(type);
                    financialAgeVO.setAmount(NumberUtil.equals(paidAmount, BigDecimal.ZERO) ? curAmount : BigDecimal.valueOf(Math.abs(paidAmount.doubleValue())));
                    Opt.ofNullable(type2DateMap.get(type)).ifPresent(
                            date -> {
                                financialAgeVO.setPayableDate(date);
                                long age = Math.abs(date.until(LocalDate.now(), ChronoUnit.DAYS));
                                financialAgeVO.setAge(((int) age));
                            }
                    );
                    financialAgeVOList.add(financialAgeVO);
                    paidAmount = BigDecimal.ZERO;
                }
            }
        });
        Map<String, Object> map = MapUtil.<String, Object>builder()
                .put("totalAmount", financialAgeVOList.stream().map(FinancialAgeVO::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add)).build();
        // 手动分页 todo hutool 6.0 暂时没有
        int[] transToStartEnd = {(dto.getPageNum() - 1) * dto.getPageSize(),
                (dto.getPageNum() - 1) * dto.getPageSize() + dto.getPageSize()};
        Page<FinancialAgeVO> financialAgeVOPage = Page.<FinancialAgeVO>of(dto.getPageNum(), dto.getPageSize(), financialAgeVOList.size())
                .setRecords(CollUtil.sub(financialAgeVOList, transToStartEnd[0], transToStartEnd[1]));
        map.put("list", financialAgeVOPage);
        return map;
    }

    @Override
    public String dispatch(RContractTeamDTO dto) {
        RContractTeam rContractTeam = converter.convert(dto, RContractTeam.class);
        if (contractTeamService.save(rContractTeam)) {
            // todo 推送钉钉消息到王平川，要支持可配置吗？
            Contract contract = this.getById(dto.getContractId());
            dingMod.workMsg(buildMsg("01005444040832705136", contract, dto.getApplicantName()));
            return "派工成功，待分配施工队。";
        }
        return "派工失败";
    }

    @Override
    public Page<RContractUser> getSaleList(RContractUser dto) {
        return contractUserService.lambdaQuery(dto).orderByDesc(RContractUser::getEnterDate).page(Page.of(dto.getPageNum(), dto.getPageSize()));
    }

    @Override
    public String assignSale(RContractUser contractUser) {
        return contractUserService.save(contractUser) ? "分配成功" : "分配失败";
    }

    @Override
    public String unbindSale(RContractUser contractUser) {
        return contractUserService.remove(Wrappers.<RContractUser>lambdaQuery().eq(RContractUser::getContractId, contractUser.getContractId()).eq(RContractUser::getUserId, contractUser.getUserId())) ? "解绑成功" : "解绑失败";
    }

    @Override
    public List<RContractProduct> getProduct(String contractNo) {
        return contractProductService.lambdaQuery().eq(RContractProduct::getContractNo, contractNo).list();
    }

    @Override
    public String createContract(String contractJson) {
        var sha256 = SecureUtil.sha256(contractJson + token);
        var jobj = bongRestClient.post()
                .uri("/pro/v2/api/contract/list")
                .contentType(MediaType.APPLICATION_JSON)
                .header("sign", sha256)
                .body(contractJson)
                .retrieve()
                .body(JsonNode.class);
        if (ObjUtil.isNull(jobj) || jobj.path("code").asInt() != 1) {
            log.error("调用CRM接口创建合同失败,错误原因:{}", jobj);
            return "创建合同失败";
        }
        return "合同创建成功";
    }

    @Override
    public JsonNode getCRMProduct(String name, String code, Integer page, Integer pageSize) {
        var conditions = JsonUtil.createArr().add(JsonUtil.createObj()
                .put("attr", "num_3")
                .put("symbol", "noequal")
                .putPOJO("value", new int[]{0}));
        if (StrUtil.isNotBlank(name)) {
            conditions.add(JsonUtil.createObj()
                    .put("attr", "text_1")
                    .put("symbol", "like")
                    .putPOJO("value", new String[]{name}));
        }
        if (StrUtil.isNotBlank(code)) {
            conditions.add(JsonUtil.createObj()
                    .put("attr", "serialNo")
                    .put("symbol", "like")
                    .putPOJO("value", new String[]{code}));
        }
        var json = JsonUtil.createObj()
                .put("corpid", "ding6bb660048f7ae2dcee0f45d8e4f7c288")
                .put("page", page)
                .put("pageSize", pageSize)
                .set("conditions", conditions);

        var jobj = bongRestClient.post()
                .uri("/pro/v2/api/product/list")
                .contentType(MediaType.APPLICATION_JSON)
                .header("sign", SecureUtil.sha256(json.toString() + token))
                .body(json.toString())
                .retrieve()
                .body(JsonNode.class);
        if (ObjUtil.isNull(jobj) || jobj.path("code").asInt() != 1) {
            log.error("调用CRM接口获取产品列表失败,错误原因:{}", jobj);
            return JsonUtil.createObj();
        }
        return JsonUtil.createObj().putPOJO("records", jobj.path("result").withArray("list"))
                .put("current", page)
                .put("size", pageSize)
                .put("total", jobj.path("result").path("totalCount").asInt())
                .put("pages", jobj.path("result").path("totalPage").asInt());
    }

    @Override
    public String syncContractFile(String[] contractNoList) {
        log.info("同步销帮帮合同文件[开始]");
        // 只同步申请日期（原CRM中的签订日期）2024-05-07号（含）之后的合同
        var conditions = JsonUtil.createArr()
                .add(JsonUtil.createObj()
                        .put("attr", "date_3")
                        .put("symbol", "greaterequal")
                        .putPOJO("value", new String[]{"1715356800"}));
        if (ArrayUtil.isNotEmpty(contractNoList)) {
            conditions.add(JsonUtil.createObj()
                    .put("attr", "serialNo")
                    .put("symbol", "in")
                    .putPOJO("value", contractNoList));
        }
        var json = JsonUtil.createObj()
                .put("corpid", corpId)
                .put("formId", 8429903)
                .put("pageSize", 100)
                .set("conditions", conditions);
        var jobO = bongRestClient.post()
                .uri("/pro/v2/api/contract/list")
                .contentType(MediaType.APPLICATION_JSON)
                .header("sign", SecureUtil.sha256(json.toString() + token))
                .body(json.toString())
                .retrieve()
                .body(JsonNode.class);
        if (ObjUtil.isNull(jobO) || jobO.path("code").asInt() != 1) {
            var errorInfo = StrUtil.format("获取合同列表失败,错误原因:{}", jobO);
            log.error(errorInfo);
            return errorInfo;
        }
        var cnt = jobO.path("result").path("totalCount").asInt();
        var page = jobO.path("result").path("totalPage").asInt();
        if (NumberUtil.equals(cnt, 0)) {
            return "没有需要插入或更新的合同";
        }
        ArrayNode jsonArray = jobO.path("result").withArray("list");
        var fileList = StreamSupport.stream(jsonArray.spliterator(), false)
                .map(v -> {
                    var fileArr = JsonUtil.parseTree(v.path("data").path("file_1").asText());
                    var contractNo = v.path("data").path("serialNo").asText();
                    return (JsonNode) JsonUtil.createObj().put("contractNo", contractNo).set("fileArr", fileArr);
                }).collect(Collectors.toList());

        for (int i = 2; i <= page; i++) {
            var jsonR = JsonUtil.createObj()
                    .putPOJO("conditions", conditions)
                    .put("corpid", corpId)
                    .put("formId", 8429903)
                    .put("page", i)
                    .put("pageSize", 100);

            var jobR = bongRestClient.post()
                    .uri("/pro/v2/api/contract/list")
                    .contentType(MediaType.APPLICATION_JSON)
                    .header("sign", SecureUtil.sha256(jsonR.toString() + token))
                    .body(jsonR.toString())
                    .retrieve()
                    .body(JsonNode.class);
            var jsonArrR = jobR.path("result").withArray("list");
            var fileListR = StreamSupport.stream(jsonArrR.spliterator(), false)
                    .map(v -> {
                        var fileArr = JsonUtil.parseTree(v.path("data").path("file_1").asText());
                        var contractNo = v.path("data").path("serialNo").asText();
                        return (JsonNode) JsonUtil.createObj().put("contractNo", contractNo).set("fileArr", fileArr);
                    }).toList();
            fileList.addAll(fileListR);
        }

        var contractList = this.lambdaQuery().likeRight(Contract::getContractNo, "SC").list();
        var contractNo2IdMap = contractList.stream().collect(Collectors.toMap(Contract::getContractNo, Contract::getId));
        var fileInfoList = fileService.lambdaQuery()
                .in(FileInfo::getContractId, contractNo2IdMap.values())
                .eq(FileInfo::getSourceType, 5)
                .list();
        // 合同id -> sha256 的 List
        var contractId2Sha256Map = fileInfoList.stream().collect(Collectors.groupingBy(FileInfo::getContractId,
                Collectors.mapping(FileInfo::getSha256, Collectors.toList())));

        for (JsonNode entries : fileList) {
            var contractNo = entries.path("contractNo").asText();
            var fileArr = entries.path("fileArr");
            if (ObjUtil.isNull(fileArr) || fileArr.isEmpty()) {
                log.info("合同：{}，没有文件", contractNo);
                continue;
            }
            var contractId = contractNo2IdMap.get(contractNo);
            if (ObjUtil.isNull(contractId)) {
                log.info("合同：{}，不存在，还未同步", contractNo);
                continue;
            }

            List<FileInfo> saveFileInfoList = new ArrayList<>();
            for (JsonNode o : fileArr) {
                var filename = o.path("filename").asText();
                String path = fileUrl + FileUtil.FILE_SEPARATOR + "contract" + FileUtil.FILE_SEPARATOR + contractId + FileUtil.FILE_SEPARATOR + filename;
                byte[] bytes;
                try {
                    bytes = HttpDownloader.downloadBytes(o.path("attachIndex").asText());
                } catch (Exception e) {
                    log.error("合同：{}，[{}] 文件同步失败", contractNo, filename, e);
                    continue;
                }
                var sha256 = SecureUtil.sha256().digestHex(bytes).toUpperCase();
                // sha256 对应的文件不存在已有的文件列表，才保存
                if (contractId2Sha256Map.getOrDefault(contractId, ListUtil.empty()).contains(sha256)) {
                    log.info("合同：{}，文件已存在", contractNo);
                    continue;
                }
                var file = FileUtil.writeBytes(bytes, path);
                log.info("合同：{},文件存入路径：{}", contractNo, path);
                FileInfo fileInfo = new FileInfo();
                fileInfo.setStoreId(-1L);
                fileInfo.setSourceId(contractId);
                fileInfo.setSourceType(5);
                fileInfo.setContractId(contractId);
                fileInfo.setName(filename);
                fileInfo.setUrl(path);
                fileInfo.setType(FileNameUtil.extName(file));
                fileInfo.setSha256(sha256);
                fileInfo.setUploader("销帮帮同步");
                saveFileInfoList.add(fileInfo);
            }
            fileService.saveBatch(saveFileInfoList);
        }
        log.info("同步销帮帮合同文件[完成]");
        return "销帮帮合同文件同步完成，请核对已同步文件！";
    }

    private Result getResult(ContractDTO dto) {
        // 查询已关联项目的合同id
        List<Long> contractIdList = dto.getSwitchFlag() == 1 ?
                contractStoreService.listObjs(Wrappers.<RContractStore>lambdaQuery()
                        .select(RContractStore::getContractId), o -> Long.valueOf(o.toString()))
                : ListUtil.empty();
        // 根据产品线查出关联的合同
        List<Long> lineContractIdList = Opt.ofEmptyAble(dto.getProductLines())
                .map(pl -> Db.listObjs(Wrappers.lambdaQuery(Store.class).in(Store::getProductLine, pl), Store::getId))
                .map(storeIds -> contractStoreService.listObjs(Wrappers.<RContractStore>lambdaQuery().select(RContractStore::getContractId).in(RContractStore::getStoreId, storeIds), o -> Long.valueOf(o.toString())))
                .orElse(new ArrayList<>());
        // 根据当前登录用户的角色获取用户名
        UserVO userVO = (UserVO) StpUtil.getTokenSession().get("curLoginUser");
        Set<String> roleCodeList = Opt.ofEmptyAble(userVO.getRoleVOList())
                .map(l -> l.stream().map(RoleVO::getCode).collect(Collectors.toSet()))
                .orElse(SetUtil.zero());
        Assert.notEmpty(roleCodeList, "当前用户角色不详，请联系管理员");
        String curName = "";
        boolean isPerm = !roleCodeList.contains("admin") && !roleCodeList.contains("shangwu") && !roleCodeList.contains("caiwu");
        if (isPerm) {
            // 不是以上三个角色，只能访问自己相关的合同
            curName = userVO.getUsername();
        }

        // 根据查询条件的销售人查询关联的合同
        List<Long> contractUserIdList1 = Opt.ofBlankAble(dto.getSaleName())
                .map(name -> contractUserService.listObjs(Wrappers.<RContractUser>lambdaQuery()
                        .select(RContractUser::getContractId).eq(RContractUser::getUsername, name), o -> Long.valueOf(o.toString())))
                .orElse(new ArrayList<>());
        // 根据查询条件的销售人查询其销售的合同
        List<Long> contractUserIdList2 = Opt.ofBlankAble(dto.getSaleName())
                .map(name -> this.listObjs(Wrappers.<Contract>lambdaQuery()
                        .select(Contract::getId).eq(Contract::getSaleName, name), o -> Long.valueOf(o.toString())))
                .orElse(new ArrayList<>());
        // 查询共同销售人为当前用户的关联合同
        List<Long> contractUserIdList3 = Opt.ofBlankAble(curName)
                .map(name -> contractUserService.listObjs(Wrappers.<RContractUser>lambdaQuery()
                        .select(RContractUser::getContractId).eq(RContractUser::getUsername, name), o -> Long.valueOf(o.toString())))
                .orElse(new ArrayList<>());
        // 查询合同销售人为当前用户的合同
        List<Long> contractUserIdList4 = Opt.ofBlankAble(curName)
                .map(name -> this.listObjs(Wrappers.<Contract>lambdaQuery()
                        .select(Contract::getId).eq(Contract::getSaleName, name), o -> Long.valueOf(o.toString())))
                .orElse(new ArrayList<>());
        Collection<Long> queryContractUserIdList = ListUtil.addAllIfNotContains(contractUserIdList1, contractUserIdList2);
        Collection<Long> curContractUserIdList = ListUtil.addAllIfNotContains(contractUserIdList3, contractUserIdList4);
        Set<Long> allContractUserIdList;
        if (StrUtil.isNotBlank(curName) && StrUtil.isNotBlank(dto.getSaleName())) {
            // 当前用户和查询条件的销售人都存在，取交集
            allContractUserIdList = CollUtil.intersectionDistinct(queryContractUserIdList, curContractUserIdList);
        } else {
            allContractUserIdList = CollUtil.unionDistinct(queryContractUserIdList, curContractUserIdList);
        }

        Set<Long> finalIdSet;
        if (isPerm) {
            // 不是以上三个角色，只能访问自己相关的合同或自己产品线相关的合同
            if (CollUtil.isNotEmpty(dto.getProductLines())) {
                finalIdSet = CollUtil.intersectionDistinct(lineContractIdList, allContractUserIdList);
            } else {
                finalIdSet = CollUtil.unionDistinct(lineContractIdList, allContractUserIdList);
            }
            if (CollUtil.isEmpty(finalIdSet)) {
                // 根据条件筛选要查询的合同为空，集合补元素 -1，防止数据库查询出错
                finalIdSet.add(-1L);
            }
        } else {
            if (StrUtil.isNotBlank(dto.getSaleName()) && CollUtil.isNotEmpty(dto.getProductLines())) {
                finalIdSet = CollUtil.intersectionDistinct(lineContractIdList, allContractUserIdList);
            } else {
                finalIdSet = CollUtil.unionDistinct(lineContractIdList, allContractUserIdList);
            }
            if ((StrUtil.isNotBlank(dto.getSaleName()) || CollUtil.isNotEmpty(dto.getProductLines())) && CollUtil.isEmpty(finalIdSet)) {
                finalIdSet.add(-1L);
            }
        }

        // 前端传参中的 saleName 字段已单独处理，这里置空，不参与下一步的 converter.convert
        dto.setSaleName(null);
        MPJLambdaWrapper<Contract> wrapper = new MPJLambdaWrapper<>(converter.convert(dto, Contract.class))
                .selectAll(Contract.class)
                .in(CollUtil.isNotEmpty(finalIdSet), Contract::getId, finalIdSet)
                .notIn(CollUtil.isNotEmpty(contractIdList), Contract::getId, contractIdList)
                .between(ArrayUtil.isAllNotNull(dto.getSignDateStart(), dto.getSignDateEnd()), Contract::getSignDate, dto.getSignDateStart(), dto.getSignDateEnd());
        if (StrUtil.isNotBlank(dto.getOperator()) && ObjUtil.isNotNull(dto.getAmount())) {
            String ope = dto.getOperator();
            if (">".equals(ope)) {
                wrapper.gt(getCol(dto), dto.getAmount());
            } else if ("<".equals(ope)) {
                wrapper.lt(getCol(dto), dto.getAmount());
            } else {
                wrapper.eq(getCol(dto), dto.getAmount());
            }
        }
        return new Result(roleCodeList, wrapper);
    }

    private SFunction<Contract, Object> getCol(ContractDTO dto) {
        if (dto.getTotalAmount() != null) {
            return Contract::getTotalAmount;
        } else if (dto.getPaidAmount() != null) {
            return Contract::getPaidAmount;
        } else if (dto.getReceivableAmount() != null) {
            return Contract::getReceivableAmount;
        } else {
            return Contract::getOutstandingAmount;
        }
    }

    String buildMsg(String userid, Contract contract, String applicantName) {
        var jsonObj = JsonUtil.createObj()
                .put("agent_id", 2358374016L)
                .put("userid_list", userid);

        var content = JsonUtil.createObj().put("title", "合同施工申请，请及时处理哦~_~");
        String template = """
                ### 合同施工申请
                #### 合同编号: **{}**
                #### 合同名称：**{}**
                #### 申请人：{}
                #### 发送时间：{}
                """;
        String markdown = StrUtil.format(template,
                contract.getContractNo(), contract.getName(), applicantName, TimeUtil.formatNormal(LocalDateTime.now()));
        content.put("markdown", markdown);

        var msg = JsonUtil.createObj().put("msgtype", "action_card").set("action_card", content);
        jsonObj.set("msg", msg);
        return jsonObj.toString();
    }

    String buildMsg(String userid, ContractDTO dto, Contract contract, String statusStr) {
        var jsonObj = JsonUtil.createObj()
                .put("agent_id", 2358374016L)
                .put("userid_list", userid);

        var content = JsonUtil.createObj().put("title", "验收提醒");
        String template = """
                #### 验收提醒
                #### 合同编号:**{}**
                #### 合同名称:**{}**
                #### 状态:{}
                #### 验收时间:{}
                #### 发送时间:{}
                """;
        String markdown = StrUtil.format(template,
                contract.getContractNo(), contract.getName(), statusStr, dto.getNodeDate(), TimeUtil.formatNormal(LocalDateTime.now()));
        content.put("text", markdown);

        var msg = JsonUtil.createObj().put("msgtype", "markdown").set("markdown", content);
        jsonObj.set("msg", msg);
        return jsonObj.toString();
    }

    private record Result(Set<String> roleCodeList, MPJLambdaWrapper<Contract> wrapper) {
    }

    /*
     * 1.校验合同数量，以及合同编号
     * 2.校验合同金额
     * */
    @Scheduled(cron = "0 0 8 * * ?")
    public void verifyNum() {
        log.info("合同比对开始");
        var contractNoList = this.listObjs(Wrappers.<Contract>lambdaQuery().select(Contract::getContractNo),
                Object::toString);

        var json = JsonUtil.createObj()
                .putPOJO("sortMap", JsonUtil.createObj()
                        .put("field", "updateTime")
                        .put("sort", "desc"))
                .put("corpid", corpId)
                .put("formId", 8429903)
                .put("pageSize", 100);
        var jobO = bongRestClient.post()
                .uri("/pro/v2/api/contract/list")
                .contentType(MediaType.APPLICATION_JSON)
                .header("sign", SecureUtil.sha256(json.toString() + token))
                .body(json.toString())
                .retrieve()
                .body(JsonNode.class);
        if (ObjUtil.isNull(jobO) || jobO.path("code").asInt() != 1) {
            log.error("获取合同列表失败,错误原因:{}", jobO);
        }
        var cnt = jobO.path("result").path("totalCount").asInt();
        var page = jobO.path("result").path("totalPage").asInt();
        if (NumberUtil.equals(cnt, 0)) {
            log.info("没有需要插入或更新的合同");
        }
        var jsonArray = jobO.path("result").withArray("list");
        // 合同编号
        var dataIdSet = StreamSupport.stream(jsonArray.spliterator(), false)
                .map(v -> v.path("data").path("serialNo").asText())
                .collect(Collectors.toSet());

        for (int i = 2; i <= page; i++) {
            var jsonR = JsonUtil.createObj()
                    .putPOJO("sortMap", JsonUtil.createObj()
                            .put("field", "updateTime")
                            .put("sort", "desc"))
                    .put("corpid", corpId)
                    .put("formId", 8429903)
                    .put("page", i)
                    .put("pageSize", 100);
            var jobR = bongRestClient.post()
                    .uri("/pro/v2/api/contract/list")
                    .contentType(MediaType.APPLICATION_JSON)
                    .header("sign", SecureUtil.sha256(jsonR.toString() + token))
                    .body(jsonR.toString())
                    .retrieve()
                    .body(JsonNode.class);
            var jsonArrR = jobR.path("result").withArray("list");
            var dataIdSetR = StreamSupport.stream(jsonArrR.spliterator(), false)
                    .map(v -> v.path("data").path("serialNo").asText())
                    .collect(Collectors.toSet());
            dataIdSet.addAll(dataIdSetR);
        }

        // 返回销帮帮存在，但项目运维管理平台不存在的合同
        var unsyncedList = CollUtil.subtractToList(dataIdSet, contractNoList);
        // 返回项目运维管理平台存在，但销帮帮不存在的合同（可能销帮帮对该合同删除了）
        var extraList = CollUtil.subtractToList(contractNoList, dataIdSet);
        // 两平台共存的合同
        log.info("合同编号验证：{}", JsonUtil.createObj().putPOJO("unsynced", unsyncedList).putPOJO("extra", extraList));
        var sameList = CollUtil.intersectionDistinct(dataIdSet, contractNoList);
        // 只比对合同编号SC开头的合同
        contractDiff(sameList.stream().filter(no -> StrUtil.startWith(no, "SC")).sorted(String::compareTo).collect(Collectors.toCollection(LinkedHashSet::new)));
        log.info("合同比对结束");
    }

    /**
     * 校验两系统都存在的合同的差异，记录差异合同
     */
    public void contractDiff(Set<String> contractNoList) {
        for (String contractNo : contractNoList) {
            var wrapper = new MPJLambdaWrapper<Contract>()
                    .selectCollection(ContractPayment.class, ContractVO::getContractPayments)
                    .leftJoin(ContractPayment.class, ContractPayment::getContractId, Contract::getId)
                    .eq(Contract::getContractNo, contractNo);
            var platContractVO = this.selectJoinOne(ContractVO.class, wrapper);
            var platContract = Opt.ofEmptyAble(platContractVO.getContractPayments())
                    .map(cps -> {
                        var contract = converter.convert(platContractVO, Contract.class);
                        cps.forEach(cp -> {
                            if (ObjUtil.equals(cp.getPaymentType(), 1) && ObjUtil.notEquals(cp.getPaymentRatio(),
                                    BigDecimal.ZERO)) {
                                contract.setSignRatio(cp.getPaymentRatio());
                                contract.setSignDate1(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 2) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setArriveRatio(cp.getPaymentRatio());
                                contract.setArriveDate(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 3) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setSystemCheckRatio(cp.getPaymentRatio());
                                contract.setSystemCheckDate(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 4) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setProjectCheckRatio(cp.getPaymentRatio());
                                contract.setProjectCheckDate(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 5) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setWarrantyRatio(cp.getPaymentRatio());
                                contract.setWarrantyDate(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 6) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setMaintainRatio1(cp.getPaymentRatio());
                                contract.setMaintainDate1(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 7) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setMaintainRatio2(cp.getPaymentRatio());
                                contract.setMaintainDate2(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 8) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setMaintainRatio3(cp.getPaymentRatio());
                                contract.setMaintainDate3(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 9) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setMaintainProgressRatio(cp.getPaymentRatio());
                                contract.setMaintainProgressDate(cp.getPaymentDate());
                            } else if (ObjUtil.equals(cp.getPaymentType(), 10) && ObjUtil.notEquals(cp.getPaymentRatio(), BigDecimal.ZERO)) {
                                contract.setMaintainAcceptanceRatio(cp.getPaymentRatio());
                                contract.setMaintainAcceptanceDate(cp.getPaymentDate());
                            }
                        });
                        return contract;
                    }).orElse(new Contract());

            var copyOptions = CopyOptions.of().setIgnoreProperties(Contract::getId, Contract::getStatus,
                            Contract::getPaidAmount,
                            Contract::getReceivableAmount, Contract::getOutstandingAmount, Contract::getSubject,
                            Contract::getRemark, Contract::getCreateUser, Contract::getModifyUser, Contract::getCreateTime,
                            Contract::getModifyTime, Contract::getFinalDate, Contract::getInvoiceAmount,
                            Contract::getFinancialStatus, Contract::getOriginalModTime, Contract::getBackInfo)
                    .setIgnoreNullValue(true);
            var platMap = BeanUtil.beanToMap(platContract, new HashMap<>(), copyOptions);

            var json = JsonUtil.createObj()
                    .putPOJO("conditions", JsonUtil.createArr()
                            .add(JsonUtil.createObj()
                                    .put("attr", "serialNo")
                                    .put("symbol", "equal")
                                    .set("value", JsonUtil.createArr().add(contractNo)))
                    )
                    .put("corpid", corpId)
                    .put("formId", 8429903)
                    .put("pageSize", 100);
            var jobO = bongRestClient.post()
                    .uri("/pro/v2/api/contract/list")
                    .contentType(MediaType.APPLICATION_JSON)
                    .header("sign", SecureUtil.sha256(json.toString() + token))
                    .body(json.toString())
                    .retrieve()
                    // fixme GOAWAY received
                    .body(JsonNode.class);
            if (ObjUtil.isNull(jobO) || jobO.path("code").asInt() != 1) {
                log.error("获取合同列表失败,错误原因:{}", jobO);
            }
            var jsonArray = jobO.path("result").withArray("list");
            // 合同记录唯一 dataId
            var dataIdSet = StreamSupport.stream(jsonArray.spliterator(), false)
                    .map(v -> v.path("dataId").asInt())
                    .collect(Collectors.toSet());

            var json1 = JsonUtil.createObj()
                    .put("corpid", corpId)
                    .put("dataId", CollUtil.getFirst(dataIdSet));
            var jobj1 = bongRestClient.post()
                    .uri("/pro/v2/api/contract/detail")
                    .contentType(MediaType.APPLICATION_JSON)
                    .header("sign", SecureUtil.sha256(json1.toString() + token))
                    .body(json1.toString())
                    .retrieve()
                    .body(JsonNode.class);
            if (ObjUtil.isNull(jobj1) || jobj1.path("code").asInt() != 1) {
                log.error("获取合同详情失败,错误原因:{}", jobj1);
            }
            var result = jobj1.path("result");
            var jsonObj1 = result.path("data");

            Map<String, Integer> contractTypeMap = Db.list(Wrappers.lambdaQuery(Dictionary.class).eq(Dictionary::getType, "contract_type"))
                    .stream()
                    .collect(Collectors.toMap(Dictionary::getValue, Dictionary::getKey));

            Contract xbongContract = new Contract();
            xbongContract.setName(jsonObj1.path("text_14").asText());
            xbongContract.setContractNo(jsonObj1.path("serialNo").asText());
            xbongContract.setType(contractTypeMap.getOrDefault(jsonObj1.path("text_17").path("text").asText(), 0));
            xbongContract.setSignDate(TimeUtil.of(jsonObj1.path("date_1").asLong() * 1000).toLocalDate());
            xbongContract.setMaintainSdate(Opt.ofNullable(jsonObj1.path("date_4")).filter(JsonNode::isNumber).map(sec -> TimeUtil.of(sec.asLong() * 1000).toLocalDate()).orElse(null));
            xbongContract.setMaintainEdate(Opt.ofNullable(jsonObj1.path("date_5")).filter(JsonNode::isNumber).map(sec -> TimeUtil.of(sec.asLong() * 1000).toLocalDate()).orElse(null));
            String warrantyPeriod = jsonObj1.path("text_23").path("text").asText("");
            if (StrUtil.isNotBlank(warrantyPeriod) && warrantyPeriod.contains("个月")) {
                String substring = warrantyPeriod.substring(0, (warrantyPeriod.length() - 2));
                xbongContract.setWarrantyPeriod(Integer.parseInt(substring));
            }
            xbongContract.setStatus(1);
            xbongContract.setTotalAmount(jsonObj1.path("num_1").decimalValue());
            xbongContract.setPaidAmount(BigDecimal.ZERO);
            xbongContract.setReceivableAmount(BigDecimal.ZERO);
            xbongContract.setOutstandingAmount(jsonObj1.path("num_1").decimalValue());
            var paymentForm = jsonObj1.withArray("subForm_1");
            if (!paymentForm.isEmpty()) {
                paymentForm.forEach(pf -> {
                    var ratio = NumberUtil.div(BigDecimal.valueOf(Double.parseDouble(pf.path("text_1").asText())), 100);
                    var date = TimeUtil.of(pf.path("date_1").asLong() * 1000).toLocalDate();
                    var stage = pf.path("text_2").path("text").asText();
                    if (StrUtil.equals(stage, "预付款")) {
                        xbongContract.setSignRatio(ratio);
                        xbongContract.setSignDate1(date);
                    } else if (StrUtil.equals(stage, "到货款")) {
                        xbongContract.setArriveRatio(ratio);
                        xbongContract.setArriveDate(date);
                    } else if (StrUtil.equals(stage, "系统验收款")) {
                        xbongContract.setSystemCheckRatio(ratio);
                        xbongContract.setSystemCheckDate(date);
                    } else if (StrUtil.equals(stage, "项目终验款")) {
                        xbongContract.setProjectCheckRatio(ratio);
                        xbongContract.setProjectCheckDate(date);
                    } else if (StrUtil.equals(stage, "质保款")) {
                        xbongContract.setWarrantyRatio(ratio);
                        xbongContract.setWarrantyDate(date);
                    } else if (StrUtil.equals(stage, "维保第一笔款")) {
                        xbongContract.setMaintainRatio1(ratio);
                        xbongContract.setMaintainDate1(date);
                    } else if (StrUtil.equals(stage, "维保第二笔款")) {
                        xbongContract.setMaintainRatio2(ratio);
                        xbongContract.setMaintainDate2(date);
                    } else if (StrUtil.equals(stage, "维保第三笔款")) {
                        xbongContract.setMaintainRatio3(ratio);
                        xbongContract.setMaintainDate3(date);
                    } else if (StrUtil.equals(stage, "维保进度款")) {
                        xbongContract.setMaintainProgressRatio(ratio);
                        xbongContract.setMaintainProgressDate(date);
                    } else if (StrUtil.equals(stage, "维保验收款")) {
                        xbongContract.setMaintainAcceptanceRatio(ratio);
                        xbongContract.setMaintainAcceptanceDate(date);
                    }
                });
            }
            xbongContract.setSubject("北京文安智能技术股份有限公司");
            xbongContract.setCustomerName(jsonObj1.path("text_2").path("name").asText());
            xbongContract.setSaleName(jsonObj1.path("text_8").path("name").asText());
            xbongContract.setCreateUser(-1L);
            xbongContract.setModifyUser(-1L);
            xbongContract.setEntryTime(TimeUtil.of(result.path("addTime").asLong() * 1000));
            xbongContract.setOriginalModTime(TimeUtil.of(result.path("updateTime").asLong() * 1000));

            var bongMap = BeanUtil.beanToMap(xbongContract, new HashMap<>(), copyOptions);
            if (!mapEqual(platMap, bongMap)) {
                log.info("不一致的合同：{}", contractNo);
            }
        }
    }

    public <K, V> boolean mapEqual(Map<K, V> map1, Map<K, V> map2) {
        if (map1.size() != map2.size()) {
            return false;
        }
        for (Map.Entry<K, V> entry : map1.entrySet()) {
            K key = entry.getKey();
            V value = entry.getValue();

            if (!map2.containsKey(key) || ObjUtil.notEquals(value, map2.get(key))) {
                log.info("不一致内容项：{}", key);
                return false;
            }
        }
        return true;
    }

}