java-insagent-pc/src/main/java/com/ydtech/modules/admin/service/impl/SysUserAccountServiceImpl.java

package com.ydtech.modules.admin.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ydtech.core.page.HttpResult;
import com.ydtech.core.page.PageRequest;
import com.ydtech.exception.SystemException;
import com.ydtech.modules.admin.constants.MoneyAttrConstants;
import com.ydtech.modules.admin.constants.WithdrawTypeConstants;
import com.ydtech.modules.admin.dao.SysUserAccountMapper;
import com.ydtech.modules.admin.dao.SysUserMapper;
import com.ydtech.modules.admin.model.SysDept;
import com.ydtech.modules.admin.model.SysUser;
import com.ydtech.modules.admin.model.dto.*;
import com.ydtech.modules.admin.model.po.*;
import com.ydtech.modules.admin.model.vo.SubOrder;
import com.ydtech.modules.admin.model.vo.SysUserAccountVo;
import com.ydtech.modules.admin.model.vo.SysUserBaseVO;
import com.ydtech.modules.admin.service.*;
import com.ydtech.modules.admin.utils.SliceUpDateUtil;
import com.ydtech.modules.base.controller.BaseController;
import com.ydtech.modules.esm.service.EsmUserReferrerService;
import com.ydtech.modules.message.constants.MessageTypeConstants;
import com.ydtech.modules.message.service.MessageSecretaryService;
import com.ydtech.modules.order.dao.InsAreaCompanyMapper;
import com.ydtech.modules.order.dao.InsOrdersMapper;
import com.ydtech.modules.order.dao.InsUploadFilesMapper;
import com.ydtech.modules.order.entity.BasePageResult;
import com.ydtech.modules.order.entity.InsOrders;
import com.ydtech.modules.order.service.InsAreaCompanyService;
import com.ydtech.modules.protocols.entity.po.InsFeeOrderNew;
import com.ydtech.modules.protocols.service.InsFeeOrderNewService;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @author Administrator
 * @description 针对表【sys_user_account(用户账户表)】的数据库操作Service实现
 * @createDate 2024-03-05 11:52:30
 */
@Service
public class SysUserAccountServiceImpl extends ServiceImpl<SysUserAccountMapper, SysUserAccount> implements SysUserAccountService {

    @Autowired
    private SysUserAccountHistoryService sysUserAccountHistoryService;

    @Autowired
    private SysUserAccountService sysUserAccountService;

    @Autowired
    private EsmUserReferrerService esmUserReferrerService;
    @Autowired
    private SysAmountAuditingService sysAmountAuditingService;

    @Autowired
    private SysUserBankCardService sysUserBankCardService;
    @Autowired
    private InsAreaCompanyService insAreaCompanyService;
    @Autowired
    private InsFeeOrderNewService insFeeOrderNewService;

    @Autowired
    private InsOrdersMapper insOrdersMapper;

    @Autowired
    private MessageSecretaryService messageSecretaryService;

    @Autowired
    private InsAreaCompanyMapper insAreaCompanyMapper;

    @Autowired
    private SysUserService sysUserService;

    @Autowired
    private SysAmountAuditingHistoryService sysAmountAuditingHistoryService;

    @Autowired
    private SysUserMapper sysUserMapper;

    @Autowired
    private InsUploadFilesMapper insUploadFilesMapper;

    @Autowired
    private SysDeptService sysDeptService;

    @Override
    @Transactional
    public void addOrUpdate(SysUserAccount sysUserAccount) {
        //SysUserAccount newSysAccount = baseMapper.getById(sysUserAccount.getUserId());
//         初始化
        if (sysUserAccount.getHandlingFee() == null) {
            sysUserAccount.setHandlingFee(BigDecimal.ZERO);
        }
        if (sysUserAccount.getDocumentary() == null) {
            sysUserAccount.setDocumentary(BigDecimal.ZERO);
        }
        if (sysUserAccount.getPromotion() == null) {
            sysUserAccount.setPromotion(BigDecimal.ZERO);
        }
        //添加总金额 = 手续费+跟单费+推广费
        BigDecimal sumAmount=BigDecimal.ZERO;
        sumAmount= sumAmount.add(sysUserAccount.getHandlingFee()==null?BigDecimal.ZERO:sysUserAccount.getHandlingFee())
                .add(sysUserAccount.getDocumentary()==null?BigDecimal.ZERO:sysUserAccount.getDocumentary())
                .add(sysUserAccount.getPromotion()==null?BigDecimal.ZERO:sysUserAccount.getPromotion());

//      如果用户id有值则累加   没有则 新增
        String userId = sysUserAccount.getUserId();
        SysUserAccount sysUserAccountEntity = baseMapper.getById(userId);
        //SysUserAccount newAccount = new SysUserAccount();

        if (ObjectUtils.isNotEmpty(sysUserAccountEntity)) {
            sysUserAccountEntity.setHandlingFee(sysUserAccount.getHandlingFee().add(sysUserAccountEntity.getHandlingFee()));
            sysUserAccountEntity.setDocumentary(sysUserAccount.getDocumentary().add(sysUserAccountEntity.getDocumentary()));
            sysUserAccountEntity.setPromotion(sysUserAccount.getPromotion().add(sysUserAccountEntity.getPromotion()));
            if (StringUtils.isNotEmpty(sysUserAccount.getDocumentaryStatus())) {
                sysUserAccountEntity.setDocumentaryStatus(sysUserAccount.getDocumentaryStatus());
            }
            // add by hxl  2024-06-18  插入总金额
            sysUserAccountEntity.setSumAmount((sysUserAccountEntity.getSumAmount()==null?BigDecimal.ZERO:sysUserAccountEntity.getSumAmount()).add(sumAmount));
            baseMapper.updateById(sysUserAccountEntity);
        } else {
            sysUserAccountEntity = new SysUserAccount();
            sysUserAccountEntity.setUserId(userId);
            sysUserAccountEntity.setDocumentary(sysUserAccount.getDocumentary());
            sysUserAccountEntity.setPromotion(sysUserAccount.getPromotion());
            sysUserAccountEntity.setHandlingFee(sysUserAccount.getHandlingFee());
            BigDecimal zero = BigDecimal.ZERO;
            sysUserAccountEntity.setHandlingAmountAccount(zero);
            sysUserAccountEntity.setHandlingAmountWithdrawal(zero);
            sysUserAccountEntity.setHandlingAmountPayment(zero);
            sysUserAccountEntity.setDocumentaryAmountAccount(zero);
            sysUserAccountEntity.setDocumentaryAmountWithdrawal(zero);
            sysUserAccountEntity.setDocumentaryAmountpayment(zero);
            sysUserAccountEntity.setPromotionAmountWithdrawal(zero);
            sysUserAccountEntity.setPromotionAmountAccount(zero);
            sysUserAccountEntity.setPromotionAmountPayment(zero);
            sysUserAccountEntity.setSumAmount(zero);
            sysUserAccountEntity.setSumAmountWithdrawal(zero);
            sysUserAccountEntity.setSumAmountAccount(zero);
            sysUserAccountEntity.setSumAmountPayment(zero);
            sysUserAccountEntity.setCreateTime(new Date());
            if (StringUtils.isNotEmpty(sysUserAccount.getDocumentaryStatus())) {
                sysUserAccountEntity.setDocumentaryStatus(sysUserAccount.getDocumentaryStatus());
            }
            // add by hxl  2024-06-18  插入总金额
            sysUserAccountEntity.setSumAmount((sysUserAccountEntity.getSumAmount()==null?BigDecimal.ZERO:sysUserAccountEntity.getSumAmount()).add(sumAmount));
            baseMapper.insert(sysUserAccountEntity);
        }
        StringBuilder commissionMessage = new StringBuilder();
        BigDecimal beforeAmount;
        BigDecimal afterAmount;
        if (StringUtils.isNotEmpty(sysUserAccount.getDocumentaryStatus())) {
            //提现前的金额
            beforeAmount = sysUserAccountEntity.getSumAmount()==null?BigDecimal.ZERO:sysUserAccountEntity.getSumAmount();
//          判断是否是一级二级三级
            SysUserAccountHistory sysUserAccountHistory = new SysUserAccountHistory();
            sysUserAccountHistory.setUserId(sysUserAccount.getUserId());
            sysUserAccountHistory.setDocumentary(Integer.valueOf(sysUserAccount.getDocumentaryStatus()));
            sysUserAccountHistory.setSuborder(sysUserAccount.getSuborderId());
            sysUserAccountHistory.setCreateTime(new Date());
            //跟单费
            if (sysUserAccount.getDocumentary() != null && sysUserAccount.getDocumentary().compareTo(BigDecimal.ZERO) != 0) {
                sysUserAccountHistory.setAmount(sysUserAccount.getDocumentary());
                sysUserAccountHistory.setProperty(MoneyAttrConstants.M_2.getCode());
                commissionMessage.append(MoneyAttrConstants.M_2.getDesc() + "：" + sysUserAccount.getDocumentary() + "元    ");
                if (WithdrawTypeConstants.WT_2.getCode().equals(sysUserAccount.getDocumentaryStatus())) { // 收入  相加
                    sysUserAccountHistory.setSurplusAmount(sysUserAccountEntity.getDocumentary());
                }
                sysUserAccountHistory.setBusinessSegmentsType(1);
                sysUserAccountHistoryService.updayteByUserAccount(sysUserAccountHistory);
            }
            //手续费
            if (sysUserAccount.getHandlingFee() != null && sysUserAccount.getHandlingFee().compareTo(BigDecimal.ZERO) != 0) {
                sysUserAccountHistory.setId(null);
                sysUserAccountHistory.setAmount(sysUserAccount.getHandlingFee());
                sysUserAccountHistory.setProperty(MoneyAttrConstants.M_1.getCode());
                commissionMessage.append(MoneyAttrConstants.M_1.getDesc() + "：" + sysUserAccount.getHandlingFee() + "元    ");
                if (WithdrawTypeConstants.WT_2.getCode().equals(sysUserAccount.getDocumentaryStatus())) { // 收入  相加
                    sysUserAccountHistory.setSurplusAmount(sysUserAccountEntity.getHandlingFee());
                }
                sysUserAccountHistory.setBusinessSegmentsType(1);
                sysUserAccountHistoryService.updayteByUserAccount(sysUserAccountHistory);
            }
            //推广费
            if (sysUserAccount.getPromotion() != null && sysUserAccount.getPromotion().compareTo(BigDecimal.ZERO) != 0) {
                sysUserAccountHistory.setId(null);

                sysUserAccountHistory.setAmount(sysUserAccount.getPromotion());
                sysUserAccountHistory.setProperty(MoneyAttrConstants.M_3.getCode());
                commissionMessage.append(MoneyAttrConstants.M_3.getDesc() + "：" + sysUserAccount.getPromotion() + "元    ");
                if (WithdrawTypeConstants.WT_2.getCode().equals(sysUserAccount.getDocumentaryStatus())) { // 收入  相加
                    //提现后的金额
                    afterAmount = beforeAmount.subtract(sysUserAccount.getPromotion());
                    sysUserAccountHistory.setSurplusAmount(afterAmount); //改变后金额
                    sysUserAccountHistory.setUserAmount(beforeAmount); //改变前金额
                }
                sysUserAccountHistory.setBusinessSegmentsType(1);
                sysUserAccountHistoryService.updayteByUserAccount(sysUserAccountHistory);

            }
            //手续费+跟单费用
            BigDecimal amount_SX_GD=BigDecimal.ZERO;
            amount_SX_GD= amount_SX_GD.add(sysUserAccount.getHandlingFee()==null?BigDecimal.ZERO:sysUserAccount.getHandlingFee())
                    .add(sysUserAccount.getDocumentary()==null?BigDecimal.ZERO:sysUserAccount.getDocumentary());
            //历史记录表添加手续费+跟单费用  add by hxl   2024-06-18
            if(amount_SX_GD.compareTo(BigDecimal.ZERO) != 0){
                sysUserAccountHistory.setId(null);
                sysUserAccountHistory.setAmount(amount_SX_GD);
                sysUserAccountHistory.setProperty(MoneyAttrConstants.M_4.getCode());
                if (WithdrawTypeConstants.WT_2.getCode().equals(sysUserAccount.getDocumentaryStatus())) { // 收入  相加

                    afterAmount = beforeAmount.subtract(amount_SX_GD);
                    sysUserAccountHistory.setSurplusAmount(afterAmount); //改变后金额
                    sysUserAccountHistory.setUserAmount(beforeAmount); //改变前金额
                    sysUserAccountHistory.setSurplusAmount(sysUserAccountEntity.getSumAmount());
                    sysUserAccountHistory.setBusinessSegmentsType(1);
                    sysUserAccountHistoryService.updayteByUserAccount(sysUserAccountHistory);
                }
            }
        }
        //添加佣金消息
        messageSecretaryService.addMessage(MessageTypeConstants.M_5,sysUserAccount.getUserId(),"你有一条佣金消息," + commissionMessage.toString());

    }

    @Override
    public BasePageResult<SysUserAccount> queryByVo(SysUserAccountVo sysUserAccountVo) {
        Page<SysUserAccount> page = new Page<>(sysUserAccountVo.getPageNum(), sysUserAccountVo.getPageSize());
        Page<SysUserAccount> sysUserAccountHistoryPage = baseMapper.queryPageOrder(sysUserAccountVo, page);
        return new BasePageResult<>(sysUserAccountVo.getPageNum(), page.getSize(), sysUserAccountHistoryPage.getTotal(), page.getPages(),
                sysUserAccountHistoryPage.getRecords());
    }
    //
    @Override
    public IPage<SysUserAccount> queryByVo1(SysUserAccountVo sysUserAccountVo) {
        PageRequest pageRequest = new PageRequest();
        pageRequest.setPageNum(sysUserAccountVo.getPageNum());
        pageRequest.setPageSize(sysUserAccountVo.getPageSize());
        List<SysUserAccount> sysUserAccountHistoryPage = baseMapper.queryPageOrder1(sysUserAccountVo);
        IPage ipage = PageRequest.buildPageRequest(pageRequest);
        ipage.setRecords(sysUserAccountHistoryPage.stream().skip((sysUserAccountVo.getPageNum() - 1) * sysUserAccountVo.getPageSize()).limit(sysUserAccountVo.getPageSize()).
                collect(Collectors.toList()));
        ipage.setTotal(sysUserAccountHistoryPage.size());
        return ipage;
    }

    @Override
    @Transactional
    public HttpResult<Object> inert(SysUserAccountVo sysUserAccountVo) {
        String userId = BaseController.getUser().getId();
        BigDecimal zero = BigDecimal.ZERO;
        BigDecimal beforeAmount;
        BigDecimal afterAmount;
//       用户当前金额
        BigDecimal amount = sysUserAccountVo.getAmount();
        SysUserAccountHistory sysUserAccountHistory = new SysUserAccountHistory();  // 记录
        sysUserAccountHistory.setDocumentary(1);  // 1提现
        sysUserAccountHistory.setUserId(userId);
        sysUserAccountHistory.setProperty(6);
        sysUserAccountHistory.setBusinessSegmentsType(1);
        SysAmountAuditingEntity sysAmountAuditingEntity = new SysAmountAuditingEntity();//审核记录表
        sysAmountAuditingEntity.setUserId(userId);
        sysAmountAuditingEntity.setAmount(sysUserAccountVo.getAmount());
        sysUserAccountHistory.setCreateTime(new Date());
//        SysAmountAuditingEntity judge = sysAmountAuditingService.getByUserId(userId, sysUserAccountVo.getAmountStatus());
//        if (ObjectUtils.isNotEmpty(judge)) {
//            return HttpResult.ok("有未提现审核单据, 请审核完成之后再提现");
//        }
//      通过银行卡id 查询卡包
        String fromBankCardId = sysUserAccountVo.getFromBankCardId();
        if (fromBankCardId != null) {
//            SysUserBankCard byId = sysUserBankCardService.getById(fromBankCardId);
            SysUserBankCard byId = sysUserBankCardService.getByBankNumber(fromBankCardId, userId);
            if (byId == null) {
                throw new SystemException("该卡未绑定此账号,或输入卡号错误,或该账号尚未审核通过,请检查");
            }
            byId.setIsDefault(1);

            sysAmountAuditingEntity.setBankNumber(byId.getBankNumber());
            sysUserAccountHistory.setFromBankCard(byId.getBankNumber());
            sysUserBankCardService.updateById(byId);
        }

        if (StringUtils.isNotEmpty(userId)) {
            SysUserAccount sysUserAccount = baseMapper.getById(userId);

            //if (StringUtils.isNotEmpty(sysUserAccountVo.getAmountStatus())) {
                //sysUserAccountHistory.setProperty(Integer.valueOf(sysUserAccountVo.getAmountStatus()));   //金额类型
                /**
                if ("1".equals(sysUserAccountVo.getAmountStatus())) {
//                  用户当前费用金
                    beforeAmount = sysUserAccount.getHandlingFee();
                    afterAmount = beforeAmount.subtract(amount);
                    sysUserAccount.setHandlingFee(afterAmount);
                    sysUserAccount.setHandlingAmountPayment(sysUserAccount.getHandlingAmountPayment().add(amount));
                    sysUserAccount.setHandlingAmountWithdrawal(sysUserAccount.getHandlingAmountWithdrawal().add(amount));
                } else if ("2".equals(sysUserAccountVo.getAmountStatus())) {
//                    用户当前 非跟单佣金
                    beforeAmount = sysUserAccount.getDocumentary();
                    afterAmount = beforeAmount.subtract(amount);
                    sysUserAccount.setDocumentary(afterAmount);
                    sysUserAccount.setDocumentaryAmountpayment(sysUserAccount.getDocumentaryAmountpayment().add(amount));
                    sysUserAccount.setDocumentaryAmountWithdrawal(sysUserAccount.getDocumentaryAmountWithdrawal().add(amount));
                } else {
                    beforeAmount = sysUserAccount.getPromotion();
                    afterAmount = beforeAmount.subtract(amount);
                    sysUserAccount.setPromotion(afterAmount);
                    sysUserAccount.setPromotionAmountPayment(sysUserAccount.getPromotionAmountPayment().add(amount));
                    sysUserAccount.setPromotionAmountWithdrawal(sysUserAccount.getPromotionAmountWithdrawal().add(amount));
                }
                 **/
                //提现前的金额
                beforeAmount = sysUserAccount.getSumAmount()==null?BigDecimal.ZERO:sysUserAccount.getSumAmount();
                //提现后的金额
                afterAmount = beforeAmount.subtract(amount);
                sysUserAccount.setSumAmount(afterAmount);
                //支付中总金额 = 原先的支付金额 + 提现的金额
                sysUserAccount.setSumAmountPayment((sysUserAccount.getSumAmountPayment()==null?BigDecimal.ZERO:sysUserAccount.getSumAmountPayment()).add(amount));
                //提现的总金额 = 原先的提现总金额 + 提现的金额
                sysUserAccount.setSumAmountWithdrawal((sysUserAccount.getSumAmountWithdrawal()==null?BigDecimal.ZERO:sysUserAccount.getSumAmountWithdrawal().add(amount)));
//              用户相差
                if (beforeAmount.compareTo(zero) == 0 || afterAmount.compareTo(zero) < 0) {
                    return HttpResult.ok("余额不足");
                }
                sysUserAccountHistory.setAmount(amount);  // 金额
                sysUserAccountHistory.setSurplusAmount(afterAmount); // 剩余金额
                sysUserAccountHistory.setUserAmount(beforeAmount);   // 用户剩余金额
                sysAmountAuditingEntity.setCreateTime(new Date());
                sysAmountAuditingEntity.setAuditingStatus("2");   // 2  为待审核  3  审核通过
               // sysAmountAuditingEntity.setAmountStatus(sysUserAccountVo.getAmountStatus());
//              新增金额记录
                sysAmountAuditingService.save(sysAmountAuditingEntity);
                sysUserAccountHistory.setAuditiingId(sysAmountAuditingEntity.getId());
                sysUserAccountService.updateById(sysUserAccount);
                sysUserAccountHistoryService.updayteByUserAccount(sysUserAccountHistory);
           // }
            // 提现审核插入轨迹表   待审核数据 和审核处理中的数据

           // Calendar calendar = Calendar.getInstance();
            Date date = new Date();
            //calendar.add(Calendar.MINUTE, 1);
           // Date afterDate = calendar.getTime();
            SysAmountAuditingHistory sysAmountAuditingHistory =new SysAmountAuditingHistory(null, sysAmountAuditingEntity.getId(), amount, userId,date,"1", "1",sysUserAccountHistory.getId());
            SysAmountAuditingHistory sysAmountAuditingHistoryTwo =new SysAmountAuditingHistory(null, sysAmountAuditingEntity.getId(), amount, userId,date, "2", "1",sysUserAccountHistory.getId());
            sysAmountAuditingHistoryService.save(sysAmountAuditingHistory);
            sysAmountAuditingHistoryService.save(sysAmountAuditingHistoryTwo);

        }
        return HttpResult.ok("提现成功，等待审核");
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/18 17:30
     *  @Description:  提现修改为总金额
     */
    @Override
    @Transactional
    public HttpResult withdraw(SysUserAccountVo sysUserAccountVo) {
        String userId = sysUserAccountVo.getUserId();
        BigDecimal zero = BigDecimal.ZERO;
        BigDecimal beforeAmount;
        BigDecimal afterAmount;
//       用户当前金额
        BigDecimal amount = sysUserAccountVo.getAmount();
        SysUserAccountHistory sysUserAccountHistory = new SysUserAccountHistory();  // 记录
        sysUserAccountHistory.setDocumentary(1);  // 1支出
        sysUserAccountHistory.setUserId(userId);
        sysUserAccountHistory.setProperty(6); //3提现
        sysUserAccountHistory.setBusinessSegmentsType(1);
        SysAmountAuditingEntity sysAmountAuditingEntity = new SysAmountAuditingEntity();//审核记录表
        sysAmountAuditingEntity.setUserId(userId);
        sysAmountAuditingEntity.setAmount(sysUserAccountVo.getAmount());
        sysUserAccountHistory.setCreateTime(new Date());
//        SysAmountAuditingEntity judge = sysAmountAuditingService.getByUserId(userId, sysUserAccountVo.getAmountStatus());
//        if (ObjectUtils.isNotEmpty(judge)) {
//            throw new SystemException("有未提现审核单据, 请审核完成之后再提现");
//        }
//      通过银行卡id 查询卡包
        String fromBankCardId = sysUserAccountVo.getFromBankCardId();
        SysUserBankCard byId = sysUserBankCardService.getByBankNumber(fromBankCardId, userId);
        if (byId == null) {
            throw new SystemException("该卡未绑定此账号,或输入卡号错误,或该账号尚未审核通过,请检查");
        }
        if (fromBankCardId != null && byId.getUserId().equals(userId)) {
            byId.setIsDefault(1);

            sysAmountAuditingEntity.setBankNumber(byId.getBankNumber());
            sysUserAccountHistory.setFromBankCard(byId.getBankNumber());
            sysUserBankCardService.updateById(byId);
        }

        if (StringUtils.isNotEmpty(userId)) {
            SysUserAccount sysUserAccount = baseMapper.getById(userId);


            //if (StringUtils.isNotEmpty(sysUserAccountVo.getAmountStatus())) {
                //sysUserAccountHistory.setProperty(Integer.valueOf(sysUserAccountVo.getAmountStatus()));   //金额类型
                //注释掉类型提现,直接提现总金额
                /**
                 if ("1".equals(sysUserAccountVo.getAmountStatus())) {
                 //                  用户当前费用金
                 beforeAmount = sysUserAccount.getHandlingFee();
                 afterAmount = beforeAmount.subtract(amount);
                 sysUserAccount.setHandlingFee(afterAmount);
                 sysUserAccount.setHandlingAmountPayment(sysUserAccount.getHandlingAmountPayment().add(amount));
                 sysUserAccount.setHandlingAmountWithdrawal(sysUserAccount.getHandlingAmountWithdrawal().add(amount));
                 } else if ("2".equals(sysUserAccountVo.getAmountStatus())) {
                 //                    用户当前 非跟单佣金
                 beforeAmount = sysUserAccount.getDocumentary();
                 afterAmount = beforeAmount.subtract(amount);
                 sysUserAccount.setDocumentary(afterAmount);
                 sysUserAccount.setDocumentaryAmountpayment(sysUserAccount.getDocumentaryAmountpayment().add(amount));
                 sysUserAccount.setDocumentaryAmountWithdrawal(sysUserAccount.getDocumentaryAmountWithdrawal().add(amount));
                 } else {
                 beforeAmount = sysUserAccount.getPromotion();
                 afterAmount = beforeAmount.subtract(amount);
                 sysUserAccount.setPromotion(afterAmount);
                 sysUserAccount.setPromotionAmountPayment(sysUserAccount.getPromotionAmountPayment().add(amount));
                 sysUserAccount.setPromotionAmountWithdrawal(sysUserAccount.getPromotionAmountWithdrawal().add(amount));
                 }
                 **/
                //提现前的金额
                beforeAmount = sysUserAccount.getSumAmount()==null?BigDecimal.ZERO:sysUserAccount.getSumAmount();
                //提现后的金额
                afterAmount = beforeAmount.subtract(amount);
                sysUserAccount.setSumAmount(afterAmount);
                //支付中总金额 = 原先的支付金额 + 提现的金额
                sysUserAccount.setSumAmountPayment((sysUserAccount.getSumAmountPayment()==null?BigDecimal.ZERO:sysUserAccount.getSumAmountPayment()).add(amount));
                //提现的总金额 = 原先的提现总金额 + 提现的金额
                sysUserAccount.setSumAmountWithdrawal((sysUserAccount.getSumAmountWithdrawal()==null?BigDecimal.ZERO:sysUserAccount.getSumAmountWithdrawal().add(amount)));

                //              用户相差
                if (beforeAmount.compareTo(zero) == 0 || afterAmount.compareTo(zero) < 0) {
                    return HttpResult.error("余额不足");
                }
                sysUserAccountHistory.setAmount(amount);  // 金额
                sysUserAccountHistory.setSurplusAmount(afterAmount); // 剩余金额
                sysUserAccountHistory.setUserAmount(beforeAmount);   // 用户剩余金额
                sysAmountAuditingEntity.setCreateTime(new Date());
                sysAmountAuditingEntity.setAuditingStatus("2");   // 2  为待审核  3  审核通过
                sysAmountAuditingEntity.setAmountStatus(sysUserAccountVo.getAmountStatus());
//              新增金额记录
                sysAmountAuditingService.save(sysAmountAuditingEntity);
                sysUserAccountHistory.setAuditiingId(sysAmountAuditingEntity.getId());
                sysUserAccountService.updateById(sysUserAccount);
                sysUserAccountHistoryService.updayteByUserAccount(sysUserAccountHistory);
            //}
            // 提现审核插入轨迹表   待审核数据 和审核处理中的数据

            Calendar calendar = Calendar.getInstance();
            Date date = calendar.getTime();
            calendar.add(Calendar.MINUTE, 1);
            Date afterDate = calendar.getTime();
            SysAmountAuditingHistory sysAmountAuditingHistory =new SysAmountAuditingHistory(null, sysAmountAuditingEntity.getId(), amount, userId,date,"1", "1",sysUserAccountHistory.getId());
            SysAmountAuditingHistory sysAmountAuditingHistoryTwo =new SysAmountAuditingHistory(null, sysAmountAuditingEntity.getId(), amount, userId,afterDate, "2", "1",sysUserAccountHistory.getId());
            sysAmountAuditingHistoryService.save(sysAmountAuditingHistory);
            sysAmountAuditingHistoryService.save(sysAmountAuditingHistoryTwo);

        }
        return HttpResult.ok("提现成功，等待审核");
    }

    @Override
    public SysUserAccount getSysUserAmount(String userid) {
        SysUserAccount sysUserAccount = baseMapper.getById(userid);

        return sysUserAccount;
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/11 16:05
     *  @Description: 注释掉实收的总金额提升查询效率
     */
    @Override
    public SysUserAccountVo getSysAllAmount(String userId) {
        SysUserAccountVo sysUserAccountVo = new SysUserAccountVo();
        SysUserAccount sysUserAccount = baseMapper.getById(userId);
        // 验证账户信息是否有值
        if (ObjectUtils.isEmpty(sysUserAccount)) {
            return sysUserAccountVo;
        }
        BeanUtils.copyProperties(sysUserAccount, sysUserAccountVo);
        BigDecimal willHalding = BigDecimal.ZERO;        //预收手续费佣金
        BigDecimal willDocumentary = BigDecimal.ZERO;   //预收 非跟单佣金
        BigDecimal willPromotion = BigDecimal.ZERO;   //预收 推广
        //BigDecimal receivedWillHalding = BigDecimal.ZERO;        //实收手续费佣金
        // BigDecimal receivedWillDocumentary = BigDecimal.ZERO;   //实收非跟单佣金
        // BigDecimal receivedWillPromotion = BigDecimal.ZERO;   //实收推广费
        // 预收手续费佣金
        willPromotion = this.willPromotionAll(willPromotion, userId,"1");
        // 实收手续费佣金
        //receivedWillPromotion = this.willPromotionAll(willPromotion, userId,"2");
        // add by   hxl  修改sql 添加承保状态和不在审核表中的条件   begin ===============
        List<InsFeeOrderNew> willList = insFeeOrderNewService.getByUserIdAndOrderStatusAndNoCheckType(userId,"1");
        //List<InsFeeOrderNew> willListnew = insFeeOrderNewService.getByUserIdAndOrderStatusAndNoCheckType(userId,"2");
        if (!CollectionUtils.isEmpty(willList)) {
            for (InsFeeOrderNew item : willList) {
                if (ObjectUtils.isNotEmpty(item)) {
                    //1.预收手续费佣金  2. 预收非跟单佣金
                    willHalding = willHalding.add(this.willAmountNew(item,1));
                    willDocumentary = willDocumentary.add(this.willAmountNew(item,2));
                }
            }
        }
        /**
         if (!CollectionUtils.isEmpty(willListnew)) {
         for (InsFeeOrderNew item : willListnew) {
         if (ObjectUtils.isNotEmpty(item)) {
         //1.实收手续费佣金  2. 实收非跟单佣金
         receivedWillHalding = willHalding.add(this.willAmountNew(item,1));
         receivedWillDocumentary = willDocumentary.add(this.willAmountNew(item,2));
         }
         }
         }
         **/
        //预收手续费佣金
        sysUserAccountVo.setWillHalding(willHalding);
        //预收非跟单佣金
        sysUserAccountVo.setWillDocumentary(willDocumentary);
        //实收手续费佣金
        //sysUserAccountVo.setReceivedWillHalding(receivedWillHalding);
        //实收非跟单佣金
        //sysUserAccountVo.setReceivedWillDocumentary(receivedWillDocumentary);
        //提现现中 手续费、非跟单、推广费
        HashMap<String, Object> params = new HashMap<>();
        params.put("auditingStatus", "2");  // 待审核
        params.put("userId", userId);
        List<SysAmountAuditingEntity> sysAmountAuditingProgressIng = sysAmountAuditingService.getProgressIng(params);
        this.judge(sysAmountAuditingProgressIng, sysUserAccountVo);
        params.clear();
        params.put("auditingStatus", "3");  // 已审核审核
        params.put("userId", userId);
        //已提现 手续费、非跟单、推广费
        List<SysAmountAuditingEntity> sysAmountAuditingApproved = sysAmountAuditingService.getProgressIng(params);
        this.judgeSysAmountAuditing(sysAmountAuditingApproved, sysUserAccountVo);
        //预收手续费佣金
        sysUserAccountVo.setWillPromotion(willPromotion);
        //实收手续费佣金
        // sysUserAccountVo.setReceivedWillPromotion(receivedWillPromotion);
        return sysUserAccountVo;
    }

    @Override
    public SysUserAccountVo getInsOrders(SysUserAccountVo sysUserAccountVo) {
        ArrayList<InsFeeOrderNew> resultList = new ArrayList<>();
        HashMap<String, Object> params = new HashMap<>();
        params.put("userId", BaseController.getUser().getId());
        //日期
        params.put("timeFiltering", sysUserAccountVo.getTimeFiltering());
        //1预收2.实收
        params.put("type",sysUserAccountVo.getSearchType());
        sysUserAccountVo.setInsFeeOrderNewList(null);
        //金额类型 1. 手续费金额 2. 跟单金额  3. 推广金额
        if ("3".equals(sysUserAccountVo.getAmountType())) {
            List<InsFeeOrderNew> sumWillAmountGeneralization = insFeeOrderNewService.getSumWillAmountGeneralizationNew(params);
            sysUserAccountVo.setInsFeeOrderNewList(sumWillAmountGeneralization);
        } else {
            List<InsFeeOrderNew> resultInsFeeOrderNew = insFeeOrderNewService.getSumWillAmountNew(params);
            if (resultInsFeeOrderNew!=null && resultInsFeeOrderNew.size()>0) {
                for (InsFeeOrderNew item : resultInsFeeOrderNew) {
                    BigDecimal willPromotion = BigDecimal.ZERO;
                    if ("1".equals(sysUserAccountVo.getAmountType())) {
                        //手续费出口预收
                        willPromotion = willPromotion.add(item.getJqExportSuperviseCostsPremiums()).add(item.getSyExportSuperviseCostsPremiums()).add(item.getNoExportSuperviseCostsPremiums());
                    } else if ("2".equals(sysUserAccountVo.getAmountType())) {
                        willPromotion = willPromotion.add(item.getJqExportOtherCostsPremiums()).add(item.getSyExportOtherCostsPremiums()).add(item.getNoExportOtherCostsPremiums());
                    }
                    item.setWillAmount(willPromotion);
                    if (willPromotion.compareTo(BigDecimal.ZERO) != 0) {
                        resultList.add(item);
                    }
                }
                sysUserAccountVo.setInsFeeOrderNewList(resultList);
            }
        }
        return sysUserAccountVo;
    }

    private void getWillAmount(InsFeeOrderNew insFeeOrderNew) {
        if (ObjectUtils.isNotEmpty(insFeeOrderNew)) {
            //交强手续费出口比例
            BigDecimal jqExportProceduresFee =
                    insFeeOrderNew.getJqPremium().multiply(insFeeOrderNew.getJqSuperviseCostsProportion().divide(new BigDecimal(100))).setScale(2, BigDecimal.ROUND_DOWN);
            //商业手续费出口比例
            BigDecimal syExportProceduresFee =
                    insFeeOrderNew.getSyPremium().multiply(insFeeOrderNew.getSySuperviseCostsProportion().divide(new BigDecimal(100))).setScale(2, BigDecimal.ROUND_DOWN);
            //非车手续费出口比例
            BigDecimal noExportProceduresFee =
                    insFeeOrderNew.getNoPremium().multiply(insFeeOrderNew.getNoSuperviseCostsProportion().divide(new BigDecimal(100))).setScale(2, BigDecimal.ROUND_DOWN);


            //非车出口比例
            //总机构 交强管理比例
            BigDecimal sumJqDeptProportion = insFeeOrderNew.getJqDeptProportionLevel1()
                    .add(insFeeOrderNew.getJqDeptProportionLevel2())
                    .add(insFeeOrderNew.getJqDeptProportionLevel3())
                    .add(insFeeOrderNew.getJqDeptProportionLevel4())
                    .add(insFeeOrderNew.getJqDeptProportionLevel5());

            //总机构 商业管理比例
            BigDecimal sumSyDeptProportion = insFeeOrderNew.getSyDeptProportionLevel1()
                    .add(insFeeOrderNew.getSyDeptProportionLevel2())
                    .add(insFeeOrderNew.getSyDeptProportionLevel3())
                    .add(insFeeOrderNew.getSyDeptProportionLevel4())
                    .add(insFeeOrderNew.getSyDeptProportionLevel5());

            //总机构 非车管理比例
            BigDecimal sumNoDeptProportion = insFeeOrderNew.getNoDeptProportionLevel1()
                    .add(insFeeOrderNew.getNoDeptProportionLevel2())
                    .add(insFeeOrderNew.getNoDeptProportionLevel3())
                    .add(insFeeOrderNew.getNoDeptProportionLevel4())
                    .add(insFeeOrderNew.getNoDeptProportionLevel5());
            BigDecimal noExportProceduresProportion = new BigDecimal(0);
            //总分销比例
            BigDecimal sumRetail =
                    insFeeOrderNew.getFirstDetailProportion().add(insFeeOrderNew.getSecondDetailProportion()).add(insFeeOrderNew.getThirdDetailProportion());
            if (insFeeOrderNew.getNoCostsProportion().compareTo(sumNoDeptProportion.add(sumRetail)) > 0) {
                noExportProceduresProportion = insFeeOrderNew.getNoCostsProportion().subtract(sumNoDeptProportion).subtract(sumRetail);
            }
            //商业出口比例
            BigDecimal syExportProceduresProportion = new BigDecimal(0);
            if (insFeeOrderNew.getSyCostsProportion().compareTo(sumSyDeptProportion.add(sumRetail)) > 0) {
                syExportProceduresProportion = insFeeOrderNew.getSyCostsProportion().subtract(sumSyDeptProportion).subtract(sumRetail);
            }
            //交强出口比例
            BigDecimal jqExportProceduresProportion = new BigDecimal(0);
            if (insFeeOrderNew.getJqCostsProportion().compareTo(sumJqDeptProportion.add(sumRetail)) > 0) {
                jqExportProceduresProportion = insFeeOrderNew.getJqCostsProportion().subtract(sumJqDeptProportion).subtract(sumRetail);
            }
            //交强跟单出口费用
            BigDecimal jqExportOtherFee = insFeeOrderNew.getJqPremium()
                    .multiply(jqExportProceduresProportion
                            .subtract(insFeeOrderNew.getJqSuperviseCostsProportion()).divide(new BigDecimal(100))).setScale(2,
                            BigDecimal.ROUND_DOWN);

            //商业跟单出口比例
            BigDecimal syExportOtherFee = insFeeOrderNew.getSyPremium()
                    .multiply(syExportProceduresProportion
                            .subtract(insFeeOrderNew.getSySuperviseCostsProportion()).divide(new BigDecimal(100))).setScale(2,
                            BigDecimal.ROUND_DOWN);
            //非车跟单出口比例
            BigDecimal noExportOtherFee = insFeeOrderNew.getNoPremium()
                    .multiply(noExportProceduresProportion
                            .subtract(insFeeOrderNew.getNoSuperviseCostsProportion()).divide(new BigDecimal(100))).setScale(2,
                            BigDecimal.ROUND_DOWN);

            if (StringUtils.isNotEmpty(insFeeOrderNew.getAmountType())) {
                if ("1".equals(insFeeOrderNew.getAmountType())) {
                    //用户出口手续费
                    insFeeOrderNew.setWillAmount(jqExportProceduresFee.add(syExportProceduresFee).add(noExportProceduresFee));
                }
                if ("2".equals(insFeeOrderNew.getAmountType())) {
                    //用户出口跟单费
                    insFeeOrderNew.setWillAmount(jqExportOtherFee.add(syExportOtherFee).add(noExportOtherFee));
                }
            }
        }
    }

    private BigDecimal getWillPromotion(InsFeeOrderNew insFeeOrderNew, BigDecimal willPromotion) {
        InsOrders InsOrders = insAreaCompanyService.selectByInFeeOrderNew(insFeeOrderNew);
        if (ObjectUtils.isNotEmpty(InsOrders)) {
            BigDecimal willFirstPremiums = ObjectUtils.defaultIfNull(InsOrders.getWillFirstPremiums(), BigDecimal.ZERO);
            // 累加保费
            willPromotion = willPromotion.add(willFirstPremiums);
        }
        return willPromotion;
    }


    private void judgeSysAmountAuditing(List<SysAmountAuditingEntity> sysAmountAuditingApproved, SysUserAccountVo sysUserAccountVo) {
        if (!CollectionUtils.isEmpty(sysAmountAuditingApproved)) {
            for (SysAmountAuditingEntity item : sysAmountAuditingApproved) {
                if ("1".equals(item.getAmountStatus())) {  //手续费
                    BigDecimal amount = item.getAmount();
                    sysUserAccountVo.setApprovedHalding(amount);
                }
                if ("2".equals(item.getAmountStatus())) {  //非跟单
                    BigDecimal amount = item.getAmount();
                    sysUserAccountVo.setApprovedDocumentary(amount);
                }
                if ("3".equals(item.getAmountStatus())) {  //推广费
                    BigDecimal amount = item.getAmount();
                    sysUserAccountVo.setApprovedPromotion(amount);
                }

            }
        }
    }

    private void judge(List<SysAmountAuditingEntity> sysAmountAuditingProgressIng, SysUserAccountVo sysUserAccountVo) {
        if (!CollectionUtils.isEmpty(sysAmountAuditingProgressIng)) {
            for (SysAmountAuditingEntity item : sysAmountAuditingProgressIng) {
                if ("1".equals(item.getAmountStatus())) {  //手续费
                    BigDecimal amount = item.getAmount();
                    sysUserAccountVo.setWithdrawalHalding(amount);
                }
                if ("2".equals(item.getAmountStatus())) {  //非跟单
                    BigDecimal amount = item.getAmount();
                    sysUserAccountVo.setWithdrawalDocumentary(amount);
                }
                if ("3".equals(item.getAmountStatus())) {  //推广费
                    BigDecimal amount = item.getAmount();
                    sysUserAccountVo.setWithdrawalPromotion(amount);
                }

            }
        }

    }

    private BigDecimal willPromotion(BigDecimal willPromotion, String userId) {
        InsFeeOrderNew insFeeOrderNew = new InsFeeOrderNew();
        insFeeOrderNew.setUserId(userId);
        InsOrders InsOrders = insAreaCompanyService.selectByInFeeOrderNew(insFeeOrderNew);
        if (ObjectUtils.isNotEmpty(InsOrders)) {
            BigDecimal willFirstPremiums = ObjectUtils.defaultIfNull(InsOrders.getWillFirstPremiums(), BigDecimal.ZERO);
            // 累加保费
            willPromotion = willPromotion.add(willFirstPremiums);
        }
        return willPromotion;
    }

    private void willAmount(InsFeeOrderNew insFeeOrderNew, BigDecimal willHalding, BigDecimal willDocumentary,
                            SysUserAccountVo sysUserAccountVo) {
        if (ObjectUtils.isNotEmpty(insFeeOrderNew)) {
            //交强手续费
            BigDecimal jqExportProceduresFee = insFeeOrderNew.getJqExportSuperviseCostsPremiums();
            //商业手续费
            BigDecimal syExportProceduresFee = insFeeOrderNew.getSyExportSuperviseCostsPremiums();
            //非车手续费
            BigDecimal noExportProceduresFee = insFeeOrderNew.getNoExportSuperviseCostsPremiums();
            if (sysUserAccountVo.getWillHalding() == null) {
                sysUserAccountVo.setWillHalding(BigDecimal.ZERO);
            }
            sysUserAccountVo.setWillHalding(sysUserAccountVo.getWillHalding().add(jqExportProceduresFee).add(syExportProceduresFee).add(noExportProceduresFee));
            //交强跟单出口费用
            BigDecimal jqExportOtherCostsPremiums = insFeeOrderNew.getJqExportOtherCostsPremiums();
            //商业跟单出口费用
            BigDecimal syExportOtherCostsPremiums = insFeeOrderNew.getSyExportOtherCostsPremiums();
            //非车跟单出口费用
            BigDecimal noExportOtherCostsPremiums = insFeeOrderNew.getNoExportOtherCostsPremiums();
            //用户出口跟单费
            if (sysUserAccountVo.getWillDocumentary() == null) {
                sysUserAccountVo.setWillDocumentary(BigDecimal.ZERO);
            }
            sysUserAccountVo.setWillDocumentary(sysUserAccountVo.getWillDocumentary().add(jqExportOtherCostsPremiums).add(syExportOtherCostsPremiums).add(noExportOtherCostsPremiums));
        }
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/3 11:20
     *  @Description:  通过类型查询预收、实收的金额
     */
    private BigDecimal willPromotionAll(BigDecimal willPromotion, String userId,String type) {
        InsFeeOrderNew insFeeOrderNew = new InsFeeOrderNew();
        insFeeOrderNew.setUserId(userId);
        InsOrders InsOrders = insAreaCompanyService.selectByInFeeOrderNewByType(insFeeOrderNew,type);
        if (ObjectUtils.isNotEmpty(InsOrders)) {
            BigDecimal willFirstPremiums = ObjectUtils.defaultIfNull(InsOrders.getWillFirstPremiums(), BigDecimal.ZERO);
            // 累加保费
            willPromotion = willPromotion.add(willFirstPremiums);
        }
        return willPromotion;
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/4 11:51
     *  @Description:  获取费用
     */
    private BigDecimal willAmountNew(InsFeeOrderNew insFeeOrderNew, int type) {
        BigDecimal  val= BigDecimal.ZERO;
        if (ObjectUtils.isNotEmpty(insFeeOrderNew)) {
            if(type==1){
                // 交强手续费+商业手续费+非车手续费
                val= val.add(insFeeOrderNew.getJqExportSuperviseCostsPremiums()).add(insFeeOrderNew.getSyExportSuperviseCostsPremiums()).add(insFeeOrderNew.getNoExportSuperviseCostsPremiums());
            }else{
                // 交强跟单出口费用+商业跟单出口费用+非车跟单出口费用
                val= val.add(insFeeOrderNew.getJqExportOtherCostsPremiums()).add(insFeeOrderNew.getSyExportOtherCostsPremiums()).add(insFeeOrderNew.getNoExportOtherCostsPremiums());
            }
        }
        return val;
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/3 15:16
     *  @Description: 查询子订单的详细信息
     */
    @Override
    public SubOrder getSubOrderDetails(String subOrderId, String userId) {
        SubOrder subOrder=insAreaCompanyMapper.getSubOrderDetails(subOrderId);
        subOrder.setAgentName(this.getUserName(subOrder.getUserId()));
        subOrder.setAgentLevel("");
        //根据用户id查询分销等级
        InsFeeOrderNew insFeeOrderNew = insFeeOrderNewService.getOne(new LambdaQueryWrapper<InsFeeOrderNew>()
                .eq(InsFeeOrderNew::getInsOrderNo, subOrder.getSubOrderId()));
        if(userId.equals(insFeeOrderNew.getFirstLevelUserId())){
            //subOrder.setAgentName(this.getUserName(insFeeOrderNew.getFirstLevelUserId()));
            subOrder.setAgentLevel("一级分销代理");
        }
        if(userId.equals(insFeeOrderNew.getTwoLevelUserId())){
            //subOrder.setAgentName(this.getUserName(insFeeOrderNew.getTwoLevelUserId()));
            subOrder.setAgentLevel("二级分销代理");
        }
        if(userId.equals(insFeeOrderNew.getThreeLevelUserId())){
            //subOrder.setAgentName(this.getUserName(insFeeOrderNew.getThreeLevelUserId()));
            subOrder.setAgentLevel("三级分销代理");
        }
        return subOrder;
    }



    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/3 16:34
     *  @Description: 查询分销人名称
     */
    private String getUserName(String userId) {
        if(StringUtils.isNotEmpty(userId)){
            SysUser sysUser = sysUserService.getBaseMapper().selectById(userId);
            if(ObjectUtils.isNotEmpty(sysUser)){
                return sysUser.getName();
            }
        }
        return "";
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 9:04
     *  @Description: 查询我的账户总金额
     */
    @Override
    public BigDecimal getUserSumAmountByUserId(String userId) {
        if(StringUtils.isBlank(userId)){
            throw new SystemException("用户id-userId不能为空");
        }
        //通过用户id查询用户账户的总金额
        LambdaQueryWrapper<SysUserAccount> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(SysUserAccount::getUserId, userId);
        SysUserAccount sysUserAccount = sysUserAccountService.getOne(queryWrapper);
        if(sysUserAccount==null){
            return BigDecimal.ZERO;
        }
        return sysUserAccount.getSumAmount()==null?BigDecimal.ZERO:sysUserAccount.getSumAmount();
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 11:04
     *  @Description: 查询预收数据明细
     */
    @Override
    public MyCollectInAdvanceAllDto findMyCollectInAdvanceByUserId(MyCollectInAdvanceQueryDto myCollectInAdvanceQueryDto) {
        if(StringUtils.isBlank(myCollectInAdvanceQueryDto.getUserId())){
            throw new SystemException("用户id-userId不能为空");
        }
        BigDecimal sumAmount=BigDecimal.ZERO;

        //判断时间类型  1.一周内  2. 一月内  3. 三月内  4. 三月内
        HashMap<String, String> dateMap = getDateMapByType(myCollectInAdvanceQueryDto.getDateQueryType(),myCollectInAdvanceQueryDto.getStartDate(),myCollectInAdvanceQueryDto.getEndDate());
        myCollectInAdvanceQueryDto.setStartDate(dateMap.get("startDate"));
        myCollectInAdvanceQueryDto.setEndDate(dateMap.get("endDate"));

        if(myCollectInAdvanceQueryDto.getBusinessSegmentsType()==null || "".equals(myCollectInAdvanceQueryDto.getBusinessSegmentsType())){
            myCollectInAdvanceQueryDto.setBusinessSegmentsType("1");
        }
        if(myCollectInAdvanceQueryDto.getTransactionType()==null || "".equals(myCollectInAdvanceQueryDto.getTransactionType())){
            myCollectInAdvanceQueryDto.setTransactionType("1");
        }
        if(StringUtils.isEmpty(myCollectInAdvanceQueryDto.getAuditstatus())){
            myCollectInAdvanceQueryDto.setAuditstatus("0");
        }
        Page<MyCollectInAdvanceDto> page = new Page<>(myCollectInAdvanceQueryDto.getPageNum(), myCollectInAdvanceQueryDto.getPageSize());
       // page.setSearchCount(false).setOptimizeCountSql(false);//关闭count查询
        Page<MyCollectInAdvanceDto> orderVoPage = new Page<>();
        // 1为车险板块
        if ("1".equals(myCollectInAdvanceQueryDto.getBusinessSegmentsType())) {
            //金额类型 1. 手续费金额 +跟单金额  2. 推广金额
            if("2".equals(myCollectInAdvanceQueryDto.getTransactionType())){
                orderVoPage = insFeeOrderNewService.findMyCollectInAdvanceWillAmountByUserId(page,myCollectInAdvanceQueryDto);
               // Long total=insFeeOrderNewService.findMyCollectInAdvanceWillAmountByUserIdCount(myCollectInAdvanceQueryDto);
              //  orderVoPage.setTotal(total);
                sumAmount = insFeeOrderNewService.findSumWillAmount(myCollectInAdvanceQueryDto);
            }else{
                orderVoPage = insFeeOrderNewService.findMyCollectInAdvanceSumByUserId(page,myCollectInAdvanceQueryDto);
               // Long total=insFeeOrderNewService.findMyCollectInAdvanceSumByUserIdCount(myCollectInAdvanceQueryDto);
               // orderVoPage.setTotal(total);
                sumAmount = insFeeOrderNewService.findSumAmount(myCollectInAdvanceQueryDto);
            }
        } else {
            //其他板块预留逻辑处理
        }
        List<MyCollectInAdvanceDto> recordsNew =new ArrayList<>();
        if(orderVoPage.getRecords()!=null && orderVoPage.getRecords().size()>0){
            for(MyCollectInAdvanceDto dto :orderVoPage.getRecords()) {
                //车险的显示且收入
                if ("1".equals(dto.getBusinessSegmentsType())) {
                    if ("4".equals(dto.getTransactionType())) {
                        dto.setTransactionType("1");
                    } else if ("3".equals(dto.getTransactionType())) {
                        dto.setTransactionType("2");
                    }
                }
                recordsNew.add(dto);
            }
        }
        orderVoPage.setRecords(recordsNew);
        BasePageResult<MyCollectInAdvanceDto> myCollectInAdvanceDtoBasePageResult = new BasePageResult<>(myCollectInAdvanceQueryDto.getPageNum(), myCollectInAdvanceQueryDto.getPageSize(), orderVoPage.getTotal(),
                orderVoPage.getPages()
                , orderVoPage.getRecords());
        return new MyCollectInAdvanceAllDto(sumAmount,myCollectInAdvanceDtoBasePageResult);
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 11:57
     *  @Description:  通过时间类型判断
     */
    private static HashMap<String,String> getDateMapByType(String type,String startDate,String endDate) {
        HashMap<String,String> map =new HashMap<>();
        String  startDateStr="";
        String  endDateStr="";
        if(StringUtils.isNotBlank(startDate) && StringUtils.isNotBlank(endDate)){
            startDateStr= StringUtils.isNotBlank(startDate)?startDate+" 00:00:00":null;
            endDateStr= StringUtils.isNotBlank(endDate)?endDate+" 23:59:59":null;
        }else{
            if("0".equals(type)){
                //全部
                startDateStr=null;
                endDateStr=null;
            }else if("1".equals(type)){
                // 一周内
                startDateStr=SliceUpDateUtil.getBeforeDay(new Date(),1)+" 00:00:00";
                endDateStr=SliceUpDateUtil.getBeforeDay(new Date(),0)+" 23:59:59";
            }else if("2".equals(type)){
                // 一月内
                startDateStr=SliceUpDateUtil.getBeforeDay(new Date(),2)+" 00:00:00";
                endDateStr=SliceUpDateUtil.getBeforeDay(new Date(),0)+" 23:59:59";
            }else if("3".equals(type)){
                // 三月内
                startDateStr=SliceUpDateUtil.getBeforeDay(new Date(),3)+" 00:00:00";
                endDateStr=SliceUpDateUtil.getBeforeDay(new Date(),0)+" 23:59:59";
            }else if("4".equals(type)){
                // 三月内
                startDateStr=SliceUpDateUtil.getBeforeDay(new Date(),4)+" 00:00:00";
                endDateStr=SliceUpDateUtil.getBeforeDay(new Date(),0)+" 23:59:59";
            }else{
                startDateStr= StringUtils.isNotBlank(startDate)?startDate+" 00:00:00":null;
                endDateStr= StringUtils.isNotBlank(endDate)?endDate+" 23:59:59":null;
            }
        }
        map.put("startDate",startDateStr);
        map.put("endDate",endDateStr);
        return map;
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/19 11:04
     *  @Description: 查询收支数据明细
     */
    @Override
    public MyCollectInAdvanceAllDto findIncomeAndExpensesByUserId(MyIncomeAndExpensesQueryDto myIncomeAndExpensesQueryDto) {
        if (StringUtils.isBlank(myIncomeAndExpensesQueryDto.getUserId())) {
            throw new SystemException("用户id-userId不能为空");
        }
        BigDecimal sumAmountSR = BigDecimal.ZERO;
        BigDecimal sumAmountZC = BigDecimal.ZERO;
        BasePageResult<MyCollectInAdvanceDto> myCollectInAdvanceDtoBasePageResult = new BasePageResult<MyCollectInAdvanceDto>();

        //判断时间类型  1.一周内  2. 一月内  3. 三月内  4. 三月内
        HashMap<String, String> dateMap = getDateMapByType(myIncomeAndExpensesQueryDto.getDateQueryType(), myIncomeAndExpensesQueryDto.getStartDate(), myIncomeAndExpensesQueryDto.getEndDate());
        myIncomeAndExpensesQueryDto.setStartDate(dateMap.get("startDate"));
        myIncomeAndExpensesQueryDto.setEndDate(dateMap.get("endDate"));

        Page<MyCollectInAdvanceDto> page = new Page<>(myIncomeAndExpensesQueryDto.getPageNum(), myIncomeAndExpensesQueryDto.getPageSize());
        //page.setSearchCount(false).setOptimizeCountSql(false);//关闭count查询
        Page<MyCollectInAdvanceDto> orderVoPage = new Page<>();
        if ("0".equals(myIncomeAndExpensesQueryDto.getBusinessSegmentsType())) {
            myIncomeAndExpensesQueryDto.setBusinessSegmentsType(null);
        }
        if ("0".equals(myIncomeAndExpensesQueryDto.getTransactionType())) {
            myIncomeAndExpensesQueryDto.setTransactionType(null);
        }
        if ("0".equals(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType())) {
            myIncomeAndExpensesQueryDto.setIncomeAndExpensesType(null);
        }
        // 1为车险板块  1 收入时
        if ( StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getBusinessSegmentsType()) &&   StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType()) &&"1".equals(myIncomeAndExpensesQueryDto.getBusinessSegmentsType()) &&"1".equals(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType())) {
            //判断收入类型  1 收入
            if(StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getTransactionType())  && "3".equals(myIncomeAndExpensesQueryDto.getTransactionType())){
                throw new SystemException("收入类型不能选择提现类型");
            }
        }
        if (StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType()) &&"2".equals(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType())) {
            //判断支出类型
            if(StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getTransactionType())  && !"3".equals(myIncomeAndExpensesQueryDto.getTransactionType())){
                throw new SystemException("支出类型不能选择（手续+跟单）或者手续费、退款类型");
            }
        }
        if ( (StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getBusinessSegmentsType()) && StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType()) && "2".equals(myIncomeAndExpensesQueryDto.getBusinessSegmentsType()) &&"1".equals(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType()))
                ||
                (StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType()) && ("2".equals(myIncomeAndExpensesQueryDto.getBusinessSegmentsType())))){
            //判断退款类型
            if(StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getTransactionType())  &&!"4".equals(myIncomeAndExpensesQueryDto.getTransactionType())){
                throw new SystemException("退款板块只能选择退款类型");
            }
        }
        //处理 手续费+跟单、推广费类型转换
        if (StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getTransactionType())  && "2".equals(myIncomeAndExpensesQueryDto.getTransactionType())) {
            myIncomeAndExpensesQueryDto.setTransactionType("3");
        } else if (StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getTransactionType())  &&"1".equals(myIncomeAndExpensesQueryDto.getTransactionType())) {
            myIncomeAndExpensesQueryDto.setTransactionType("4");
        } else if (StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getTransactionType())  &&"4".equals(myIncomeAndExpensesQueryDto.getTransactionType())) {
            myIncomeAndExpensesQueryDto.setTransactionType("5");
        } else if (StringUtils.isNotBlank(myIncomeAndExpensesQueryDto.getTransactionType())  &&"3".equals(myIncomeAndExpensesQueryDto.getTransactionType())) {
            myIncomeAndExpensesQueryDto.setTransactionType("6");
        }
        //处理收入和支出类型转换
        if (myIncomeAndExpensesQueryDto.getIncomeAndExpensesType() != null && "0".equals(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType())) {
            myIncomeAndExpensesQueryDto.setIncomeAndExpensesType(null);
        } else if (myIncomeAndExpensesQueryDto.getIncomeAndExpensesType() != null && "1".equals(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType())) {
            myIncomeAndExpensesQueryDto.setIncomeAndExpensesType("2");
        } else if (myIncomeAndExpensesQueryDto.getIncomeAndExpensesType() != null && "2".equals(myIncomeAndExpensesQueryDto.getIncomeAndExpensesType())){
            myIncomeAndExpensesQueryDto.setIncomeAndExpensesType("1");
        }
        orderVoPage = sysUserAccountHistoryService.findMyIncomeAndExpensesAmountByUserId(page,myIncomeAndExpensesQueryDto);
       // Long total=sysUserAccountHistoryService.findMyIncomeAndExpensesAmountByUserIdCount(myIncomeAndExpensesQueryDto);
       // orderVoPage.setTotal(total);
        List<MyCollectInAdvanceDto> recordsNew =new ArrayList<>();
        if(orderVoPage.getRecords()!=null && orderVoPage.getRecords().size()>0){
            for(MyCollectInAdvanceDto dto :orderVoPage.getRecords()) {
                //车险的显示且收入
                if ("1".equals(dto.getBusinessSegmentsType()) && "2".equals(dto.getIncomeAndExpensesType())) {
                    if ("4".equals(dto.getTransactionType())) {
                        dto.setTransactionType("1");
                    } else if ("3".equals(dto.getTransactionType())) {
                        dto.setTransactionType("2");
                    }
                    dto.setIncomeAndExpensesType("1");
                    //退款 且退款
                } else if ("2".equals(dto.getBusinessSegmentsType()) && "2".equals(dto.getIncomeAndExpensesType())){
                    dto.setIncomeAndExpensesType("1");
                    dto.setTransactionType("4");
                    //退款设置为空
                    dto.setAuditingStatus("");
                    //提现
                }else if("6".equals(dto.getTransactionType()) && "1".equals(dto.getIncomeAndExpensesType())){
                    dto.setIncomeAndExpensesType("2");
                    dto.setTransactionType("3");
                }
                recordsNew.add(dto);
            }
        }
        orderVoPage.setRecords(recordsNew);
        myCollectInAdvanceDtoBasePageResult = new BasePageResult<>(myIncomeAndExpensesQueryDto.getPageNum(), myIncomeAndExpensesQueryDto.getPageSize(), orderVoPage.getTotal(),
                orderVoPage.getPages()
                , orderVoPage.getRecords());
        //

        sumAmountSR=sysUserAccountHistoryService.findSumAmountByUserId(myIncomeAndExpensesQueryDto.getUserId(),"2");
        sumAmountZC=sysUserAccountHistoryService.findSumAmountByUserId(myIncomeAndExpensesQueryDto.getUserId(),"1");
        return new MyCollectInAdvanceAllDto(sumAmountSR,sumAmountZC,myCollectInAdvanceDtoBasePageResult);
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/20 13:48
     *  @Description: 提现详情
     */
    @Override
    public WithdrawalDetalsDto findDetailById(String id) {
        //id为历史表的id
        //通过历史记录表查询数据
        SysUserAccountHistory his = sysUserAccountHistoryService.getById(id);
        LambdaQueryWrapper<SysAmountAuditingHistory> lqw = new LambdaQueryWrapper<>();
        lqw.eq(SysAmountAuditingHistory::getHistoryId, id);
        lqw.orderByAsc(SysAmountAuditingHistory::getCreateTime);
        List<SysAmountAuditingHistory> listAll = sysAmountAuditingHistoryService.list(lqw);
        SysAmountAuditingEntity audi = sysAmountAuditingService.getById(his.getAuditiingId());
        WithdrawalDetalsDto withdrawalDetalsDto=new WithdrawalDetalsDto();
        if(audi!=null){
            withdrawalDetalsDto.setBankNumber(audi.getBankNumber());
            withdrawalDetalsDto.setTransactionNumber(audi.getId());
            withdrawalDetalsDto.setWithdrawalAmount(audi.getAmount());
            withdrawalDetalsDto.setBankAccount(audi.getBankAccount());
        }
        List<WithdrawalDetalsRecordDto>  recordList =new ArrayList<WithdrawalDetalsRecordDto>();
        if(listAll!=null && listAll.size()>0){
            SysAmountAuditingHistory first = listAll.get(0);
            SysAmountAuditingHistory last = listAll.get(listAll.size() - 1);
            //申请时间
            Date createTime = first.getCreateTime();
            withdrawalDetalsDto.setApplicationDate(createTime);
            String auditingStatus = last.getAuditingStatus();
            withdrawalDetalsDto.setWithdrawalStatus(auditingStatus);
            String auditingStatusName="";
            if("1".equals(auditingStatus)){
                auditingStatusName="提现申请";
            }else if("2".equals(auditingStatus)){
                auditingStatusName="处理中";
            }else if("3".equals(auditingStatus)){
                auditingStatusName="提现失败";
            }else if("4".equals(auditingStatus)){
                auditingStatusName="提现成功";
                withdrawalDetalsDto.setPaymentDate(last.getCreateTime());
            }
            withdrawalDetalsDto.setWithdrawalStatusName(auditingStatusName);
            WithdrawalDetalsRecordDto dto1 = new WithdrawalDetalsRecordDto("1", false, "提现申请", null);
            WithdrawalDetalsRecordDto dto2 = new WithdrawalDetalsRecordDto("2", false, "处理中", null);
            WithdrawalDetalsRecordDto dto3 = null;
            WithdrawalDetalsRecordDto dto4 = new WithdrawalDetalsRecordDto("4", false, "提现成功", null);
            for(SysAmountAuditingHistory sysAmountAuditingHistory:listAll){
                if("1".equals(sysAmountAuditingHistory.getAuditingStatus())){
                    dto1.setProcessingStatusFlag(true);
                    dto1.setProcessingDate(sysAmountAuditingHistory.getCreateTime());
                }else if("2".equals(sysAmountAuditingHistory.getAuditingStatus())){
                    dto2.setProcessingStatusFlag(true);
                    dto2.setProcessingDate(sysAmountAuditingHistory.getCreateTime());
                }else if("3".equals(sysAmountAuditingHistory.getAuditingStatus())){
                    dto3 =new WithdrawalDetalsRecordDto("3", true, "提现失败", sysAmountAuditingHistory.getCreateTime());
                }else if("4".equals(sysAmountAuditingHistory.getAuditingStatus())){
                    dto4.setProcessingStatusFlag(true);
                    dto4.setProcessingDate(sysAmountAuditingHistory.getCreateTime());
                }
            }
            recordList.add(dto1);
            recordList.add(dto2);
            if(dto3!=null){
                recordList.add(dto3);
                withdrawalDetalsDto.setRejectReason(audi.getRejectReason()==null?"":audi.getRejectReason());
            }else{
                //add  by   hxl   2024-07-09 添加银行回单的路径
                if(audi!=null && StringUtils.isNotBlank(audi.getPicId())){
                    //add by hxl  2024-08-15 屏蔽银行回单的路径
                   // InsUploadFiles insUploadFiles = insUploadFilesMapper.selectById(audi.getPicId());
                   // withdrawalDetalsDto.setBankReceipt(insUploadFiles==null?"":insUploadFiles.getUrl());
                }
                recordList.add(dto4);
            }
            withdrawalDetalsDto.setRecord(recordList);
        }
        return withdrawalDetalsDto;
    }

    @Override
    public OrderDetalsDto findOrderDetailById(String subOrderId) {
        return null;
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/21 18:27
     *  @Description: 查看退款详情
     */
    @Override
    public RefundDetalsDto findRefundDetailById(String id) {
        //id为历史表的id
        //通过历史记录表查询数据
        SysUserAccountHistory his = sysUserAccountHistoryService.getById(id);
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String dateStr = sdf.format(his.getCreateTime());
        return new RefundDetalsDto(dateStr,his.getAmount(),his.getAuditiingId());
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 15:28
     *  @Description:  查询车险明细
     */
    @Override
    public BasePageResult<ExportExpenditureTypeDetalsDto> findMyInsuranceByUserId(MyInsuranceQueryDto myInsuranceQueryDto) {
        Page<ExportExpenditureTypeDetalsDto> page = new Page<>(myInsuranceQueryDto.getPageNum(),
                myInsuranceQueryDto.getPageSize());
        List<String> userList = getStrings(myInsuranceQueryDto);
        //赋值开始和结束时间
        if(StringUtils.isNotBlank(myInsuranceQueryDto.getStartDate())){
            myInsuranceQueryDto.setStartDate(myInsuranceQueryDto.getStartDate()+" 00:00:00");
        }
        if(StringUtils.isNotBlank(myInsuranceQueryDto.getEndDate())){
            myInsuranceQueryDto.setEndDate(myInsuranceQueryDto.getEndDate()+" 23:59:59");
        }
        Page<ExportExpenditureTypeDetalsDto> pageList=insFeeOrderNewService.findMyInsuranceByUserId(page,myInsuranceQueryDto,userList);

        BasePageResult<ExportExpenditureTypeDetalsDto> result = new BasePageResult<>(myInsuranceQueryDto.getPageNum(), myInsuranceQueryDto.getPageSize(), pageList.getTotal(),
                pageList.getPages()
                , pageList.getRecords());
        return  result;
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 17:59
     *  @Description:  获取渠道团队长管理的下级人
     */
    private List<String> getStrings(MyInsuranceQueryDto myInsuranceQueryDto) {
        //查询当前管理的代理人信息
        LambdaQueryWrapper<SysUser> lqw = new LambdaQueryWrapper<>();
        lqw.eq(SysUser::getStatus, 1);
        lqw.eq(SysUser::getOperatorCode, myInsuranceQueryDto.getUserId());
        List<SysUser> users= sysUserMapper.selectList(lqw);
        List<String> userList=new ArrayList<>();
        if(users!=null && users.size()>0){
            for(SysUser user: users){
                userList.add(user.getId());
            }
        }
        return userList;
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 18:05
     *  @Description: 查询推广费分页
     */
    @Override
    public BasePageResult<ExportExpenditureTypeDetalsTGDto> findMyInsuranceTGByUserId(MyInsuranceTgQueryDto myInsuranceTgQueryDto) {
        Page<ExportExpenditureTypeDetalsTGDto> page = new Page<>(myInsuranceTgQueryDto.getPageNum(),
                myInsuranceTgQueryDto.getPageSize());
        //赋值开始和结束时间
        if(StringUtils.isNotBlank(myInsuranceTgQueryDto.getStartDate())){
            myInsuranceTgQueryDto.setStartDate(myInsuranceTgQueryDto.getStartDate()+" 00:00:00");
        }
        if(StringUtils.isNotBlank(myInsuranceTgQueryDto.getEndDate())){
            myInsuranceTgQueryDto.setEndDate(myInsuranceTgQueryDto.getEndDate()+" 23:59:59");
        }
        Page<ExportExpenditureTypeDetalsTGDto> pageList=insFeeOrderNewService.findMyInsuranceTGByUserId(page,myInsuranceTgQueryDto);
        BasePageResult<ExportExpenditureTypeDetalsTGDto> result = new BasePageResult<>(myInsuranceTgQueryDto.getPageNum(), myInsuranceTgQueryDto.getPageSize(), pageList.getTotal(),
                pageList.getPages()
                , pageList.getRecords());
        return  result;
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 18:05
     *  @Description: 查询车险导出数据
     */
    @Override
    public List<ExportExpenditureTypeDetalsDto> exportMyInsuranceByUserId(MyInsuranceQueryDto myInsuranceQueryDto) {
        List<String> userList = getStrings(myInsuranceQueryDto);
        //赋值开始和结束时间
        if(StringUtils.isNotBlank(myInsuranceQueryDto.getStartDate())){
            myInsuranceQueryDto.setStartDate(myInsuranceQueryDto.getStartDate()+" 00:00:00");
        }
        if(StringUtils.isNotBlank(myInsuranceQueryDto.getEndDate())){
            myInsuranceQueryDto.setEndDate(myInsuranceQueryDto.getEndDate()+" 23:59:59");
        }
        return insFeeOrderNewService.exportMyInsuranceByUserId(myInsuranceQueryDto,userList);
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 18:05
     *  @Description: 查询推广导出数据
     */
    @Override
    public List<ExportExpenditureTypeDetalsTGDto> exportMyInsuranceTGByUserId(MyInsuranceTgQueryDto myInsuranceTgQueryDto) {
        //赋值开始和结束时间
        if(StringUtils.isNotBlank(myInsuranceTgQueryDto.getStartDate())){
            myInsuranceTgQueryDto.setStartDate(myInsuranceTgQueryDto.getStartDate()+" 00:00:00");
        }
        if(StringUtils.isNotBlank(myInsuranceTgQueryDto.getEndDate())){
            myInsuranceTgQueryDto.setEndDate(myInsuranceTgQueryDto.getEndDate()+" 23:59:59");
        }
        return insFeeOrderNewService.exportMyInsuranceTGByUserId(myInsuranceTgQueryDto);
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/7/1 9:02
     *  @Description:  查询收支明细数据
     */
    @Override
    public BasePageResult<ExportExpenditureTypeDetalsSZDto> findMyIncomeAndExpensesNewByUserId(MyCollectInAdvanceQueryNewDto myCollectInAdvanceQueryNewDto) {
        //校验数据
        myCollectInAdvanceQueryNewDto = checkData(myCollectInAdvanceQueryNewDto);
        Page<ExportExpenditureTypeDetalsSZDto> page = new Page<>(myCollectInAdvanceQueryNewDto.getPageNum(), myCollectInAdvanceQueryNewDto.getPageSize());
        Page<ExportExpenditureTypeDetalsSZDto> orderVoPage = sysUserAccountHistoryService.findMyIncomeAndExpensesAmountNewByUserId(page,myCollectInAdvanceQueryNewDto);
        List<ExportExpenditureTypeDetalsSZDto> recordsNew =new ArrayList<>();
        //格式化数据
        if(orderVoPage.getRecords()!=null && orderVoPage.getRecords().size()>0){
            for(ExportExpenditureTypeDetalsSZDto dto :orderVoPage.getRecords()) {
                //车险的显示且收入
                if ("1".equals(dto.getBusinessSegmentsType()) && "2".equals(dto.getIncomeAndExpensesType())) {
                    if ("4".equals(dto.getTransactionType())) {
                        dto.setTransactionType("1");
                    } else if ("3".equals(dto.getTransactionType())) {
                        dto.setTransactionType("2");
                    }
                    dto.setIncomeAndExpensesType("1");
                    //退款 且退款
                } else if ("2".equals(dto.getBusinessSegmentsType()) && "2".equals(dto.getIncomeAndExpensesType())){
                    dto.setIncomeAndExpensesType("1");
                    dto.setTransactionType("4");
                    //退款设置为空
                    dto.setAuditingStatus("");
                    //提现
                }else if("6".equals(dto.getTransactionType()) && "1".equals(dto.getIncomeAndExpensesType())){
                    dto.setIncomeAndExpensesType("2");
                    dto.setTransactionType("3");
                }
                recordsNew.add(dto);
            }
        }
        orderVoPage.setRecords(recordsNew);
        return  new BasePageResult<>(myCollectInAdvanceQueryNewDto.getPageNum(), myCollectInAdvanceQueryNewDto.getPageSize(), orderVoPage.getTotal(),
                orderVoPage.getPages()
                , orderVoPage.getRecords());
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/7/1 9:06
     *  @Description:  校验数据
     */
    private static MyCollectInAdvanceQueryNewDto checkData(MyCollectInAdvanceQueryNewDto myCollectInAdvanceQueryNewDto) {
        if (StringUtils.isBlank(myCollectInAdvanceQueryNewDto.getUserId())) {
            throw new SystemException("用户id-userId不能为空");
        }
        //判断时间类型  1.一周内  2. 一月内  3. 三月内  4. 三月内
        HashMap<String, String> dateMap = getDateMapByType(myCollectInAdvanceQueryNewDto.getDateQueryType(), myCollectInAdvanceQueryNewDto.getStartDate(), myCollectInAdvanceQueryNewDto.getEndDate());
        myCollectInAdvanceQueryNewDto.setStartDate(dateMap.get("startDate"));
        myCollectInAdvanceQueryNewDto.setEndDate(dateMap.get("endDate"));
        if ("0".equals(myCollectInAdvanceQueryNewDto.getBusinessSegmentsType())) {
            myCollectInAdvanceQueryNewDto.setBusinessSegmentsType(null);
        }
        if ("0".equals(myCollectInAdvanceQueryNewDto.getTransactionType())) {
            myCollectInAdvanceQueryNewDto.setTransactionType(null);
        }
        if ("0".equals(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType())) {
            myCollectInAdvanceQueryNewDto.setIncomeAndExpensesType(null);
        }
        // 1为车险板块  1 收入时
        if ( StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getBusinessSegmentsType()) &&   StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType()) &&"1".equals(myCollectInAdvanceQueryNewDto.getBusinessSegmentsType()) &&"1".equals(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType())) {
            //判断收入类型  1 收入
            if(StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getTransactionType())  && "3".equals(myCollectInAdvanceQueryNewDto.getTransactionType())){
                throw new SystemException("收入类型不能选择提现类型");
            }
        }
        if (StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType()) &&"2".equals(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType())) {
            //判断支出类型
            if(StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getTransactionType())  && !"3".equals(myCollectInAdvanceQueryNewDto.getTransactionType())){
                throw new SystemException("支出类型不能选择（手续+跟单）或者手续费、退款类型");
            }
        }
        if ( (StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getBusinessSegmentsType()) && StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType()) && "2".equals(myCollectInAdvanceQueryNewDto.getBusinessSegmentsType()) &&"1".equals(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType()))
                ||
                (StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType()) && ("2".equals(myCollectInAdvanceQueryNewDto.getBusinessSegmentsType())))){
            //判断退款类型
            if(StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getTransactionType())  &&!"4".equals(myCollectInAdvanceQueryNewDto.getTransactionType())){
                throw new SystemException("退款板块只能选择退款类型");
            }
        }
        //处理 手续费+跟单、推广费类型转换
        if (StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getTransactionType())  && "2".equals(myCollectInAdvanceQueryNewDto.getTransactionType())) {
            myCollectInAdvanceQueryNewDto.setTransactionType("3");
        } else if (StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getTransactionType())  &&"1".equals(myCollectInAdvanceQueryNewDto.getTransactionType())) {
            myCollectInAdvanceQueryNewDto.setTransactionType("4");
        } else if (StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getTransactionType())  &&"4".equals(myCollectInAdvanceQueryNewDto.getTransactionType())) {
            myCollectInAdvanceQueryNewDto.setTransactionType("5");
        } else if (StringUtils.isNotBlank(myCollectInAdvanceQueryNewDto.getTransactionType())  &&"3".equals(myCollectInAdvanceQueryNewDto.getTransactionType())) {
            myCollectInAdvanceQueryNewDto.setTransactionType("6");
        }
        //处理收入和支出类型转换
        if (myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType() != null && "0".equals(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType())) {
            myCollectInAdvanceQueryNewDto.setIncomeAndExpensesType(null);
        } else if (myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType() != null && "1".equals(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType())) {
            myCollectInAdvanceQueryNewDto.setIncomeAndExpensesType("2");
        } else if (myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType() != null && "2".equals(myCollectInAdvanceQueryNewDto.getIncomeAndExpensesType())){
            myCollectInAdvanceQueryNewDto.setIncomeAndExpensesType("1");
        }
        return myCollectInAdvanceQueryNewDto;
    }

    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/7/1 9:03
     *  @Description:  查询导出收支明细
     */
    @Override
    public List<ExportExpenditureTypeDetalsSZDto> exportMyIncomeAndExpensesNewByUserId(MyCollectInAdvanceQueryNewDto myCollectInAdvanceQueryNewDto) {
        //校验数据
        myCollectInAdvanceQueryNewDto = checkData(myCollectInAdvanceQueryNewDto);
        //查询数据
        List<ExportExpenditureTypeDetalsSZDto> list = sysUserAccountHistoryService.exportMyIncomeAndExpensesAmountNewByUserId(myCollectInAdvanceQueryNewDto);
        List<ExportExpenditureTypeDetalsSZDto> recordsNew =new ArrayList<>();
        //格式化数据
        if(list!=null && list.size()>0){
            for(ExportExpenditureTypeDetalsSZDto dto :list) {
                //车险的显示且收入
                if ("1".equals(dto.getBusinessSegmentsType()) && "2".equals(dto.getIncomeAndExpensesType())) {
                    if ("4".equals(dto.getTransactionType())) {
                        dto.setTransactionType("手续费+跟单");
                    } else if ("3".equals(dto.getTransactionType())) {
                        dto.setTransactionType("推广");
                    }
                    dto.setIncomeAndExpensesType("收入");
                    dto.setBusinessSegmentsType("车险");
                    //退款 且退款
                } else if ("2".equals(dto.getBusinessSegmentsType()) && "2".equals(dto.getIncomeAndExpensesType())){
                    dto.setIncomeAndExpensesType("收入");
                    dto.setTransactionType("退款");
                    //退款设置为空
                    dto.setAuditingStatus("");
                    dto.setBusinessSegmentsType("退款");
                    //提现
                }else if("6".equals(dto.getTransactionType()) && "1".equals(dto.getIncomeAndExpensesType())){
                    dto.setIncomeAndExpensesType("收入");
                    dto.setTransactionType("提现");
                    dto.setBusinessSegmentsType("车险");
                }
                recordsNew.add(dto);
            }
        }
        return  recordsNew;
    }
    /**
     *  @version
     *  @author: hxl
     *  @Date: 2024/6/30 18:55
     *  @Description:  查询页面总金额
     */
    @Override
    public MySumAmountDto findMyAmount(MySumAmountQueryDto mySumAmountQueryDto) {
        //赋值开始和结束时间
        if(StringUtils.isNotBlank(mySumAmountQueryDto.getStartDate())){
            mySumAmountQueryDto.setStartDate(mySumAmountQueryDto.getStartDate()+" 00:00:00");
        }
        if(StringUtils.isNotBlank(mySumAmountQueryDto.getEndDate())){
            mySumAmountQueryDto.setEndDate(mySumAmountQueryDto.getEndDate()+" 23:59:59");
        }
        String userId = mySumAmountQueryDto.getUserId();
        //添加预收明细 如果是渠道团队长查询管理下级的出单员
        SysUserBaseVO sysUserBaseVO = sysUserService.selectUserById(userId);
        SysUser user = sysUserService.getById(userId);
        SysDept dept = sysDeptService.getById(user.getDeptId());
        String deptId="";
        //出单员是19 且是渠道的话，给渠道团队长
        if ("21".equals(sysUserBaseVO.getRoleId()) && "1".equals(dept.getManagementSource())) {
            deptId = dept.getId();
            mySumAmountQueryDto.setDeptId(deptId);
        }
        //查询预收和实收的总金额
        mySumAmountQueryDto.setAuditstatus("0");
        BigDecimal ysAmount= insFeeOrderNewService.findMyAmountYSOrSSCXAmount(mySumAmountQueryDto);
        mySumAmountQueryDto.setAuditstatus("1");
        BigDecimal ssAmount= insFeeOrderNewService.findMyAmountYSOrSSCXAmount(mySumAmountQueryDto);
        BigDecimal ysAndSsAmount=ysAmount.add(ssAmount);

        mySumAmountQueryDto.setAuditstatus("0");
        BigDecimal ysTGAmount= insFeeOrderNewService.findMyAmountYSOrSSTGAmount(mySumAmountQueryDto);
        mySumAmountQueryDto.setAuditstatus("1");
        BigDecimal ssTGAmount= insFeeOrderNewService.findMyAmountYSOrSSTGAmount(mySumAmountQueryDto);
        BigDecimal ysAndSsTGAmount=ysTGAmount.add(ssTGAmount);

        // 已提现金额   查询历史表中的审核状态为3的数据
        BigDecimal ysTXAmount= insFeeOrderNewService.findMyAmountYTXmount(mySumAmountQueryDto.getUserId(),"3");
        // 可提现金额    查询账户的钱
        mySumAmountQueryDto.setAuditstatus("1");
        SysUserAccount sysUserAccountEntity = baseMapper.getById(mySumAmountQueryDto.getUserId());

        BigDecimal txzTXAmount= insFeeOrderNewService.findMyAmountYTXmount(mySumAmountQueryDto.getUserId(),"2");
        BigDecimal ssKTAmount =BigDecimal.ZERO;
        if(sysUserAccountEntity!=null){
            ssKTAmount = sysUserAccountEntity.getSumAmount()==null?BigDecimal.ZERO: sysUserAccountEntity.getSumAmount();
        }
        BigDecimal sumAmount=ysTXAmount.add(ssKTAmount).add(txzTXAmount);

        return new MySumAmountDto(ysAmount,ssAmount,ysAndSsAmount,ysTGAmount,ssTGAmount,ysAndSsTGAmount,ysTXAmount,ssKTAmount,sumAmount,txzTXAmount);
    }
}