package com.chinagas.modules.schsf.service.impl;

import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.chinagas.api.system.domain.SysUser;
import com.chinagas.common.core.exceptions.ServiceException;
import com.chinagas.common.core.utils.DateUtils;
import com.chinagas.common.core.utils.StringUtils;
import com.chinagas.common.datascope.annotation.DataScope;
import com.chinagas.common.security.utils.SecurityUtils;
import com.chinagas.modules.schsf.domain.McBasicCmty;
import com.chinagas.modules.schsf.domain.McOperationLog;
import com.chinagas.modules.schsf.domain.McVisit;
import com.chinagas.modules.schsf.domain.McVisitStatusNodeInfo;
import com.chinagas.modules.schsf.domain.dto.NodeUsersDto;
import com.chinagas.modules.schsf.domain.notice.McVisitTemplate;
import com.chinagas.modules.schsf.domain.vo.McVisitAuditVo;
import com.chinagas.modules.schsf.domain.vo.McVisitModificationVo;
import com.chinagas.modules.schsf.domain.vo.McVisitVo;
import com.chinagas.modules.schsf.enums.*;
import com.chinagas.modules.schsf.mapper.McFileMapper;
import com.chinagas.modules.schsf.mapper.McVisitMapper;
import com.chinagas.modules.schsf.service.*;
import com.chinagas.modules.schsf.stateMachine.StateMachineNext;
import lombok.extern.slf4j.Slf4j;
import org.jetbrains.annotations.NotNull;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.Month;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;

/**
 * 拜访工单Service业务层处理
 *
 * @author cw
 * @date 2024-05-30
 */

@Slf4j
@Service
public class McVisitServiceImpl implements IMcVisitService {
    private static final Logger log = LoggerFactory.getLogger(McVisitServiceImpl.class);
    @Autowired
    private McVisitMapper mcVisitMapper;
    @Autowired
    private IMcOperationLogService iMcOperationLogService;
    @Autowired
    private IMcIgnitionService iMcIgnitionService;
    @Autowired
    private McFileMapper mcFileMapper;
    @Autowired
    private IMcBasicCmtyService iMcBasicCmtyService;
    @Autowired
    private DingtalkService dingtalkService;
    @Autowired
    private IMcConstructionService iMcConstructionService;


    /**
     * 查询拜访工单
     *
     * @param id 拜访工单主键
     * @return 拜访工单
     */
    @Override
    public McVisit selectMcVisitById(Long id) {
        return mcVisitMapper.selectMcVisitById(id);
    }

    /**
     * 查询拜访工单列表
     *
     * @param mcVisit 拜访工单
     * @return 拜访工单
     */
    @DataScope(deptAlias = "d", userAlias = "u")
    @Override
    public List<McVisit> selectMcVisitList(McVisitVo mcVisitVo) {
        if (StringUtils.isNotEmpty(mcVisitVo.getIsMyAuditing()) && mcVisitVo.getIsMyAuditing().equals("Y")) {
            List<HashMap> statusMapList = new ArrayList<HashMap>();
            //是否待我审批
            List<String> menuPermsList = mcVisitMapper.selectUserPermsList(SecurityUtils.getUserId().toString());
            for (String perms : menuPermsList) {
                HashMap<String, String> map = new HashMap<>();
                if (perms.equals("schsf:mcVisit:ticket_submitAuditOne")) {
                    //一级审核
                    map.put("publishStatus", "PENDING_LEVEL_1_AUDIT");
                    statusMapList.add(map);
                } else if (perms.equals("schsf:mcVisit:ticket_submitAuditTwo")) {
                    //二级审核
                    map.put("publishStatus", "PENDING_LEVEL_2_AUDIT");
                    statusMapList.add(map);
                } else if (perms.equals("schsf:mcVisit:modification_submitAuditOne")) {
                    //异动-一级审核
                    map.put("modificationStatus", "PENDING_LEVEL_1_AUDIT");
                    statusMapList.add(map);
                } else if (perms.equals("schsf:mcVisit:modification_submitAuditTwo")) {
                    //异动-二级审核
                    map.put("modificationStatus", "PENDING_LEVEL_2_AUDIT");
                    statusMapList.add(map);
                }
            }
            if (statusMapList == null || statusMapList.size() == 0) {
                return new ArrayList<McVisit>();
            }
            mcVisitVo.setStatusMapList(statusMapList);
        } else {
            mcVisitVo.setIsMyAuditing(null);
        }
        List<McVisit> mcVisits = mcVisitMapper.selectMcVisitList(mcVisitVo);
//        for (McVisit mcVisit : mcVisits) {
//            if (mcVisit.getPublishStatus().equals("PENDING_LEVEL_1_AUDIT")) {
//                List<SysUser> statusNodeUserList = mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:ticket_submitAuditOne");
//                mcVisit.setStatusNodeUserList(statusNodeUserList);
//            } else if (mcVisit.getPublishStatus().equals("PENDING_LEVEL_2_AUDIT")) {
//                List<SysUser> statusNodeUserList = mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:ticket_submitAuditTwo");
//                mcVisit.setStatusNodeUserList(statusNodeUserList);
//            } else if (StringUtils.isNotEmpty(mcVisit.getModificationStatus()) && mcVisit.getModificationStatus().equals("PENDING_LEVEL_1_AUDIT")) {
//                List<SysUser> statusNodeUserList = mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:modification_submitAuditOne");
//                mcVisit.setStatusNodeUserList(statusNodeUserList);
//            } else if (StringUtils.isNotEmpty(mcVisit.getModificationStatus()) && mcVisit.getModificationStatus().equals("PENDING_LEVEL_2_AUDIT")) {
//                List<SysUser> statusNodeUserList = mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:modification_submitAuditTwo");
//                mcVisit.setStatusNodeUserList(statusNodeUserList);
//            }
//        }
        return mcVisits;
    }

    /**
     * 新增拜访工单
     *
     * @param mcVisit 拜访工单
     * @return 结果
     */
    @Transactional
    @Override
    public int insertMcVisit(McVisit mcVisit) {
        log.info("拜访工单-新增拜访工单，参数对象:{}", mcVisit);
        List<McBasicCmty> mcBasicCmties = iMcBasicCmtyService.selectVisitDeptList(mcVisit);
        if (mcBasicCmties == null || mcBasicCmties.size() == 0) {
            throw new ServiceException("选择的组织不存在！");
        }
        String userId = SecurityUtils.getUserId().toString();
        String userAccount = SecurityUtils.getUsername();
        String userName = SecurityUtils.getLoginUser().getSysUser().getNickName();

        mcVisit.setIsCharged(StringUtils.nvl(mcVisit.getIsCharged(), YesNoEnums.N.getName()));
        mcVisit.setIsVisited(StringUtils.nvl(mcVisit.getIsVisited(), YesNoEnums.N.getName()));
        mcVisit.setBillingPersonAccount(userAccount);
        mcVisit.setBillingPersonId(SecurityUtils.getUserId());
        mcVisit.setBillingPersonName(userName);
        mcVisit.setCreateTime(DateUtils.getNowLocal());
        mcVisit.setCreateBy(userId);
        mcVisit.setUpdateTime(DateUtils.getNowLocal());
        mcVisit.setUpdateBy(userId);
        //获取工单号
        mcVisit.setTicketNumber(getTicketNumber());

        log.info("拜访工单-新增拜访工单，获取工单号:{}", mcVisit.getTicketNumber());
        //工单类型
        mcVisit.setTicketType(getTicketType(mcVisit.getIsCharged(), mcVisit.getIsVisited()));
        log.info("拜访工单-新增拜访工单，工单类型:{}", mcVisit.getTicketType());
        //状态获取
        getStatusNodeInfo(mcVisit, VisitlsEventEnums.PUBLISH);
        //收费验证
        isChargedValidate(mcVisit);
        log.info("拜访工单-新增拜访工单，添加工单实体:{}", mcVisit);
        int i = mcVisitMapper.insertMcVisit(mcVisit);
        if (i > 0) {
            if (StringUtils.isNotEmpty(mcVisit.getFieldPhotoFile())) {
                String fieldPhotoFile = mcVisit.getFieldPhotoFile();
                mcFileMapper.updateMcFileAddCount(Arrays.asList(fieldPhotoFile.split(",")));
            }
            if (StringUtils.isNotEmpty(mcVisit.getAttachmentFile())) {
                mcFileMapper.updateMcFileAddCount(Arrays.asList(mcVisit.getAttachmentFile()));
            }
        }
        //1:添加记录
        iMcOperationLogService.insertMcOperationLog("mc_visit", mcVisit.getId(), "schsf:mcVisit:add",
                "发起", "1", mcVisit.getRemark(), null, JSON.toJSONString(mcVisit));

        sendMcVisitNotification(mcVisit.getId());
//        iMcOperationLogService.insertMcOperationRoleNameLog("mc_visit", mcVisit.getId(), "项目公司_收费员",
//                "发起", "1", null, null, JSON.toJSONString(mcVisit));
        return i;

    }

    /**
     * 验证是否可以收费，  用户已村子
     *
     * @param mcVisit
     */
    private void isChargedValidate(McVisit mcVisit) {
        if (mcVisit.getIsCharged().equals(YesNoEnums.Y.getName())) {
            McVisit mcVisit2 = new McVisit();
            mcVisit2.setId(mcVisit.getId());
            mcVisit2.setRegionName(mcVisit.getRegionName());
            mcVisit2.setGroupName(mcVisit.getGroupName());
            mcVisit2.setCompanyCode(mcVisit.getCompanyCode());
            mcVisit2.setCompanyName(mcVisit.getCompanyName());
            mcVisit2.setUserProvince(mcVisit.getUserProvince());
            mcVisit2.setUserCity(mcVisit.getUserCity());
            mcVisit2.setUserDistrict(mcVisit.getUserDistrict());
            mcVisit2.setUserStreet(mcVisit.getUserStreet());
            mcVisit2.setVlgOrCmty(mcVisit.getVlgOrCmty());
            mcVisit2.setUserName(mcVisit.getUserName());
            mcVisit2.setUserPhone(mcVisit.getUserPhone());
            List<McVisit> data = mcVisitMapper.selectMcVisitByData(mcVisit2);
            if (data != null && data.size() > 0) {
                throw new RuntimeException("当前用户已全款收费，不可再发起收费");
            }
        }
    }

    /**
     * 获取节点状态
     *
     * @param mcVisit
     * @param event
     * @return
     */
    private McVisit getStatusNodeInfo(McVisit mcVisit, VisitlsEventEnums event) {
        log.info("获取工单最新状态，工单信息:{}", mcVisit);
        log.info("获取工单最新状态，执行动作代码:{}", event);
        VisitlsStatusNodeEnums visitlsStatusNodeEnums = StateMachineNext.getNext(mcVisit.getIsCharged(), event);
        McVisitStatusNodeInfo info = visitlsStatusNodeEnums.getInfo();
        mcVisit.setPublishStatus(StringUtils.isNotEmpty(info.getPublishStatus()) && info.getPublishStatus().equals("ISNOT") ? mcVisit.getPublishStatus() : info.getPublishStatus());
        mcVisit.setModificationStatus(StringUtils.isNotEmpty(info.getModificationStatus()) && info.getModificationStatus().equals("ISNOT") ? mcVisit.getModificationStatus() : info.getModificationStatus());
        mcVisit.setStatusNodeName(info.getStatusNodeName());
        mcVisit.setStatusCode(info.getStatusCode());
        mcVisit.setStatusName(info.getStatusName());
        log.info("获取工单最新状态，执行动作后状态:{}", mcVisit);
        return mcVisit;
    }

    /**
     * 获取工单号
     *
     * @return
     */
    private static @NotNull String getTicketNumber() {
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS");
        AtomicInteger sequenceCounter = new AtomicInteger(0);
        // 获取当前的日期和时间，并格式化为字符串
        String timestamp = LocalDateTime.now().format(formatter);
        // 生成并格式化六位自增序列号
        int randomNum = ThreadLocalRandom.current().nextInt(1000000);
        String sequencePart = String.format("%06d", randomNum);
        // 合并时间戳和序列号以生成工单编号
        String ticketNumber = timestamp + sequencePart;
        return ticketNumber;
    }


    /**
     * 工单类型
     *
     * @param isCharged
     * @param isVisited
     * @return
     */
    public String getTicketType(String isCharged, String isVisited) {
        if (YesNoEnums.Y.getName().equals(isCharged) && YesNoEnums.Y.getName().equals(isVisited)) {
            return VisitTypeEnums.VISITANDSFEES.getCode();
        } else if (YesNoEnums.Y.getName().equals(isCharged) && YesNoEnums.N.getName().equals(isVisited)) {
            return VisitTypeEnums.CHARGE.getCode();
        } else if (YesNoEnums.N.getName().equals(isCharged) && YesNoEnums.Y.getName().equals(isVisited)) {
            return VisitTypeEnums.VISIT.getCode();
        } else {
            throw new ServiceException("请选择拜访，收费，或者拜访+收费。");
//            return VisitTypeEnums.OTHER.getCode();
        }
    }


    /**
     * 修改拜访工单
     *
     * @param mcVisit 拜访工单
     * @return 结果
     */
    @Transactional
    @Override
    public int updateMcVisit(McVisit mcVisit_old) throws CloneNotSupportedException {
        List<McBasicCmty> mcBasicCmties = iMcBasicCmtyService.selectVisitDeptList(mcVisit_old);
        if (mcBasicCmties == null || mcBasicCmties.size() == 0) {
            throw new ServiceException("选择的组织或小区不存在！");
        }
        //判断修改前数据是否有文件
        McVisit mcVisit = mcVisitMapper.selectMcVisitById(mcVisit_old.getId());
        if (mcVisit == null) {
            throw new RuntimeException("工单不存在");
        }
        if (StringUtils.isNotEmpty(mcVisit.getFieldPhotoFile())) {
            String fieldPhotoFile = mcVisit.getFieldPhotoFile();
            mcFileMapper.updateMcFileReduceCount(Arrays.asList(fieldPhotoFile.split(",")));
        }
        if (StringUtils.isNotEmpty(mcVisit.getAttachmentFile())) {
            mcFileMapper.updateMcFileReduceCount(Arrays.asList(mcVisit.getAttachmentFile()));
        }

        LocalDateTime updateTime = DateUtils.getNowLocal();
        String userId = SecurityUtils.getUserId().toString();
        String userAccount = SecurityUtils.getUsername();
        String userName = SecurityUtils.getLoginUser().getSysUser().getNickName();
        McVisit mcVisit_new = mcVisit_old.clone();
        mcVisit_new.setUpdateTime(updateTime);
        mcVisit_new.setUpdateBy(userId);
        mcVisit_new.setIsCharged(StringUtils.nvl(mcVisit_new.getIsCharged(), YesNoEnums.N.getName()));
        mcVisit_new.setIsVisited(StringUtils.nvl(mcVisit_new.getIsVisited(), YesNoEnums.N.getName()));
        //工单类型
        mcVisit_new.setTicketType(getTicketType(mcVisit_new.getIsCharged(), mcVisit_new.getIsVisited()));
        getStatusNodeInfo(mcVisit_new, VisitlsEventEnums.PUBLISH);
        //收费验证
        isChargedValidate(mcVisit_new);
        int i = mcVisitMapper.updateMcVisit(mcVisit_new);
        if (i > 0) {
            if (StringUtils.isNotEmpty(mcVisit_new.getFieldPhotoFile())) {
                String fieldPhotoFile = mcVisit_new.getFieldPhotoFile();
                mcFileMapper.updateMcFileAddCount(Arrays.asList(fieldPhotoFile.split(",")));
            }
            if (StringUtils.isNotEmpty(mcVisit_new.getAttachmentFile())) {
                mcFileMapper.updateMcFileAddCount(Arrays.asList(mcVisit_new.getAttachmentFile()));
            }
        }
        //1:添加记录
        iMcOperationLogService.insertMcOperationLog("mc_visit", mcVisit_new.getId(), "schsf:mcVisit:edit",
                "重新发起", "1", null, null, JSON.toJSONString(mcVisit_new));

//        iMcOperationLogService.insertMcOperationRoleNameLog("mc_visit", mcVisit_new.getId(), "项目公司_收费员",
//                "重新发起", "1", null, null, JSON.toJSONString(mcVisit_new));
        sendMcVisitNotification(mcVisit_new.getId());
        return i;
    }

    /**
     * 批量删除拜访工单
     *
     * @param ids 需要删除的拜访工单主键
     * @return 结果
     */
    @Transactional
    @Override
    public int deleteMcVisitByIds(Long[] ids) {
        return mcVisitMapper.deleteMcVisitByIds(ids);
    }

    /**
     * 删除拜访工单信息
     *
     * @param id 拜访工单主键
     * @return 结果
     */
    @Transactional
    @Override
    public int deleteMcVisitById(Long id) {
        return mcVisitMapper.deleteMcVisitById(id);
    }

    @Transactional
    @Override
    public void SubmitAudit(McVisitAuditVo mcVisitAuditVo) throws CloneNotSupportedException {
        String status = mcVisitAuditVo.getStatus();
        String remarks = mcVisitAuditVo.getRemarks();
        McVisit mcVisit = mcVisitMapper.selectMcVisitById(mcVisitAuditVo.getId());
        log.info("拜访工单-审核，被审核对象:{}", mcVisit);
        if (BeanUtil.isEmpty(mcVisit)) {
            throw new RuntimeException("未查询到记录");
        }
        LocalDateTime updateTime = DateUtils.getNowLocal();
        String userId = SecurityUtils.getUserId().toString();
        String userAccount = SecurityUtils.getUsername();
        String userName = SecurityUtils.getLoginUser().getSysUser().getNickName();

        McVisit mcVisit_new = mcVisit.clone();
        mcVisit_new.setUpdateTime(updateTime);
        mcVisit_new.setUpdateBy(userId);
        VisitlsEventEnums visitlsEventEnums = null;
        String menuCode = null;
        String opType = "";
        String procRole = "";
        switch (mcVisitAuditVo.getType()) {
            case "1":
                //发布-一级审核
                if (!mcVisit.getPublishStatus().equals(VisitPublishStatusEnums.PENDING_LEVEL_1_AUDIT.getCode())) {
                    log.info("拜访工单-发布-一级审核，状态异常,被审核对象:{}", mcVisit);
                    throw new RuntimeException("状态异常,请刷新核对状态。");
                }
                visitlsEventEnums = status.equals(YesNoEnums.Y.getName()) ? VisitlsEventEnums.PUBLISH_1_AUDIT_YES : VisitlsEventEnums.PUBLISH_1_AUDIT_NO;
                menuCode = "schsf:mcVisit:ticket_submitAuditOne";
                opType = "1";
                procRole = "项目公司_市场负责人";
                break;
            case "2":
                if (!mcVisit.getPublishStatus().equals(VisitPublishStatusEnums.PENDING_LEVEL_2_AUDIT.getCode())) {
                    log.info("拜访工单-发布-二级审核，状态异常,被审核对象:{}", mcVisit);
                    throw new RuntimeException("状态异常,请刷新核对状态。");
                }
                visitlsEventEnums = status.equals(YesNoEnums.Y.getName()) ? VisitlsEventEnums.PUBLISH_2_AUDIT_YES : VisitlsEventEnums.PUBLISH_2_AUDIT_NO;
                menuCode = "schsf:mcVisit:ticket_submitAuditTwo";
                opType = "1";
                //2：判断是否需要添加至点火记录
                if (status.equals(YesNoEnums.Y.getName())) {
                    iMcIgnitionService.insertMcVisitByMcIgnition(mcVisit);
                    //施工维护通知
                    iMcConstructionService.sendMcConstructionNotification(mcVisit);
                }
                procRole = "项目公司_财务";
                break;
            case "3":
                //异动-一级审核
                if (!mcVisit.getModificationStatus().equals(VisitModificationStatusEnums.PENDING_LEVEL_1_AUDIT.getCode())) {
                    log.info("拜访工单-异动-一级审核，状态异常,被审核对象:{}", mcVisit);
                    throw new RuntimeException("状态异常,请刷新核对状态。");
                }
                visitlsEventEnums = status.equals(YesNoEnums.Y.getName()) ? VisitlsEventEnums.MODIFICATION_1_AUDIT_YES : VisitlsEventEnums.MODIFICATION_1_AUDIT_NO;
                menuCode = "schsf:mcVisit:modification_submitAuditOne";
                opType = "2";
                modificationReduction(status, mcVisit_new);
                procRole = "项目公司_分管领导";
                break;
            case "4":
                //异动-二级审核
                if (!mcVisit.getModificationStatus().equals(VisitModificationStatusEnums.PENDING_LEVEL_2_AUDIT.getCode())) {
                    log.info("拜访工单-异动-二级审核，状态异常,被审核对象:{}", mcVisit);
                    throw new RuntimeException("状态异常,请刷新核对状态。");
                }
                visitlsEventEnums = status.equals(YesNoEnums.Y.getName()) ? VisitlsEventEnums.MODIFICATION_2_AUDIT_YES : VisitlsEventEnums.MODIFICATION_2_AUDIT_NO;
                menuCode = "schsf:mcVisit:modification_submitAuditTwo";
                opType = "2";
                modificationReduction(status, mcVisit_new);
                procRole = "项目公司_分管领导";
                break;
            default:
                throw new RuntimeException("非法请求");
        }
        getStatusNodeInfo(mcVisit_new, visitlsEventEnums);
        log.info("拜访工单-审核，被审核对象修改信息:{}", mcVisit_new);
        mcVisitMapper.updateMcVisit(mcVisit_new);
        iMcOperationLogService.insertMcOperationLog("mc_visit", mcVisit.getId(), menuCode,
                status.equals("Y") ? "通过" : "驳回", opType, remarks, JSON.toJSONString(mcVisit), JSON.toJSONString(mcVisit_new));
        sendMcVisitNotification(mcVisitAuditVo.getId());
//        iMcOperationLogService.insertMcOperationRoleNameLog("mc_visit", mcVisit.getId(), procRole,
//                status.equals("Y") ? "通过" : "驳回", opType, remarks, JSON.toJSONString(mcVisit), JSON.toJSONString(mcVisit_new));
    }

    /**
     * 异动还原
     *
     * @param status
     * @param mcVisit
     */
    private void modificationReduction(String status, McVisit mcVisit) {
        if (status.equals("N")) {
            McOperationLog mcOperationLog = iMcOperationLogService.selectMcOperationLogNewYdById(mcVisit.getId());
            String beforeDataJson = mcOperationLog.getBeforeDataJson();
            // 1. 判断是否为有效JSON
            try {
                JSONObject.parseObject(beforeDataJson);
            } catch (Exception e) {
                throw new RuntimeException("数据还原，JSON格式无效");
            }
            // 2. 转换为McVisit
            McVisit McVisit_hy = JSON.parseObject(beforeDataJson, McVisit.class);
            // 3. 数据还原
            mcVisit.setUserIdCard(McVisit_hy.getUserIdCard());
            mcVisit.setInvoiceNo(McVisit_hy.getInvoiceNo());
            mcVisit.setChargeAmt(McVisit_hy.getChargeAmt());
            mcVisit.setPaymentMeth(McVisit_hy.getPaymentMeth());
            mcVisit.setChargeType(McVisit_hy.getChargeType());
            mcVisit.setAttachmentFile(McVisit_hy.getAttachmentFile());
        }
    }

    /**
     * 发起异动
     *
     * @param Modification_mcVisit
     * @return
     * @throws CloneNotSupportedException
     */
    @Transactional
    @Override
    public int updateMcVisitModification(McVisitModificationVo mcVisitModificationVo) throws CloneNotSupportedException {
        McVisit mcVisit_old = mcVisitMapper.selectMcVisitById(mcVisitModificationVo.getId());
        log.info("拜访工单-发起异动，被异动对象:{}", mcVisit_old);
        if (BeanUtil.isEmpty(mcVisit_old)) {
            throw new RuntimeException("未查询到记录");
        }
        if (!mcVisit_old.getPublishStatus().equals(VisitPublishStatusEnums.APPROVED.getCode())) {
            throw new RuntimeException("状态异常");
        }
        if (StringUtils.isNotEmpty(mcVisit_old.getFieldPhotoFile())) {
            String fieldPhotoFile = mcVisit_old.getFieldPhotoFile();
            mcFileMapper.updateMcFileReduceCount(Arrays.asList(fieldPhotoFile.split(",")));
        }
        if (StringUtils.isNotEmpty(mcVisit_old.getAttachmentFile())) {
            mcFileMapper.updateMcFileReduceCount(Arrays.asList(mcVisit_old.getAttachmentFile()));
        }
        LocalDateTime updateTime = DateUtils.getNowLocal();
        String userId = SecurityUtils.getUserId().toString();
        String userAccount = SecurityUtils.getUsername();
        String userName = SecurityUtils.getLoginUser().getSysUser().getNickName();
        McVisit mcVisit_new = mcVisit_old.clone();
        mcVisit_new.setUpdateTime(updateTime);
        mcVisit_new.setUpdateBy(userId);
        //状态获取
        getStatusNodeInfo(mcVisit_new, VisitlsEventEnums.MODIFICATION);
        mcVisit_new.setUserIdCard(mcVisitModificationVo.getUserIdCard());
        mcVisit_new.setInvoiceNo(mcVisitModificationVo.getInvoiceNo());
        mcVisit_new.setChargeAmt(mcVisitModificationVo.getChargeAmt());
        mcVisit_new.setPaymentMeth(mcVisitModificationVo.getPaymentMeth());
        mcVisit_new.setChargeType(mcVisitModificationVo.getChargeType());
        mcVisit_new.setAttachmentFile(mcVisitModificationVo.getAttachmentFile());
        //收费验证
        isChargedValidate(mcVisit_new);
        log.info("拜访工单-发起异动，更新被异动对象信息:{}", mcVisit_new);
        int i = mcVisitMapper.updateMcVisit(mcVisit_new);
        if (i > 0) {
            if (StringUtils.isNotEmpty(mcVisit_new.getFieldPhotoFile())) {
                String fieldPhotoFile = mcVisit_new.getFieldPhotoFile();
                mcFileMapper.updateMcFileAddCount(Arrays.asList(fieldPhotoFile.split(",")));
            }
            if (StringUtils.isNotEmpty(mcVisit_new.getAttachmentFile())) {
                mcFileMapper.updateMcFileAddCount(Arrays.asList(mcVisit_new.getAttachmentFile()));
            }
        }
        //1:添加记录
        iMcOperationLogService.insertMcOperationLog("mc_visit", mcVisit_new.getId(), "schsf:mcVisit:modification",
                "发起异动", "2", mcVisitModificationVo.getRemark(), JSON.toJSONString(mcVisit_old), JSON.toJSONString(mcVisit_new));

        sendMcVisitNotification(mcVisit_new.getId());
//        iMcOperationLogService.insertMcOperationRoleNameLog("mc_visit", mcVisit_new.getId(), "项目公司_财务",
//                "发起异动", "2", mcVisitModificationVo.getRemark(), JSON.toJSONString(mcVisit_old), JSON.toJSONString(mcVisit_new));
        return i;
    }

    /**
     * 作废
     *
     * @param id
     * @param remark
     * @return
     * @throws CloneNotSupportedException
     */
    @Transactional
    @Override
    public int updateMcVisitCancel(Long id, String remark) throws CloneNotSupportedException {
        McVisit mcVisit = mcVisitMapper.selectMcVisitById(id);
        if (BeanUtil.isEmpty(mcVisit)) {
            throw new RuntimeException("未查询到记录");
        }
        LocalDateTime updateTime = DateUtils.getNowLocal();
        String userId = SecurityUtils.getUserId().toString();
        String userAccount = SecurityUtils.getUsername();
        String userName = SecurityUtils.getLoginUser().getSysUser().getNickName();
        McVisit mcVisit_new = mcVisit.clone();
        mcVisit_new.setUpdateTime(updateTime);
        mcVisit_new.setUpdateBy(userId);
        getStatusNodeInfo(mcVisit_new, VisitlsEventEnums.CANCEL);
//        mcVisit.setStatusNodeName("");
//        mcVisit.setStatusCode(VisitStatusEnums.CANCEL.getCode());
//        mcVisit.setStatusName(VisitStatusEnums.CANCEL.getInfo());
        iMcOperationLogService.insertMcOperationLog("mc_visit", mcVisit.getId(), "schsf:mcVisit:cancel",
                "作废", "1", remark, JSON.toJSONString(mcVisit), JSON.toJSONString(mcVisit_new));
        //2：作废至点火记录
        iMcIgnitionService.updateMcIgnitionCancel(id);
        return mcVisitMapper.updateMcVisit(mcVisit_new);
    }

    /**
     * 查询当前财年
     *
     * @return
     */
    @Override
    public int getCurrentFiscalYear() {
        LocalDate date = LocalDate.now();
        if (date.getMonth() == Month.APRIL || (date.getMonth().getValue() > Month.APRIL.getValue() && date.getYear() != 2100)) {
            return date.getYear();
        } else if (date.getMonth().getValue() < Month.APRIL.getValue()) {
            return date.getYear() - 1;
        } else {
            return date.getYear() + 1;
        }
    }

    /**
     * 节点处理人
     *
     * @param id
     * @return
     */
    @Override
    public List<NodeUsersDto> selectStatusNodeUserList(Long id) {
        McVisit mcVisit = mcVisitMapper.selectMcVisitById(id);
        if (BeanUtil.isEmpty(mcVisit) || StringUtils.isEmpty(mcVisit.getStatusCode())
                || mcVisit.getStatusCode().equals(VisitStatusEnums.APPROVED)
                || mcVisit.getStatusCode().equals(VisitStatusEnums.CANCEL)) {
            return null;
        }
        List<SysUser> statusNodeUserList = new ArrayList<>();
        if (mcVisit.getPublishStatus().equals("PENDING_LEVEL_1_AUDIT")) {
            return mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:ticket_submitAuditOne");
        } else if (mcVisit.getPublishStatus().equals("PENDING_LEVEL_2_AUDIT")) {
            return mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:ticket_submitAuditTwo");
        } else if (mcVisit.getPublishStatus().equals("REJECTED") || mcVisit.getPublishStatus().equals("EDITING")) {
            return mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:edit");
        } else if (StringUtils.isNotEmpty(mcVisit.getModificationStatus()) && mcVisit.getModificationStatus().equals("PENDING_LEVEL_1_AUDIT")) {
            return mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:modification_submitAuditOne");
        } else if (StringUtils.isNotEmpty(mcVisit.getModificationStatus()) && mcVisit.getModificationStatus().equals("PENDING_LEVEL_2_AUDIT")) {
            return mcVisitMapper.selectMcVisitStatusNodeUserList(mcVisit.getId().toString(), "schsf:mcVisit:modification_submitAuditTwo");
        }
        return Collections.emptyList();
    }

    /**
     * 消息通知
     *
     * @param id
     */
    private void sendMcVisitNotification(Long id) {
        McVisit mcVisit = mcVisitMapper.selectMcVisitById(id);
        log.info("拜访工单-钉钉通知，拜访单对象信息:{}", mcVisit);
        if (BeanUtil.isEmpty(mcVisit)) {throw new ServiceException("未查询到记录");}
        //发送通知
        List<NodeUsersDto> mcVisitNodeUsersDtos = this.selectStatusNodeUserList(id);
        if (mcVisitNodeUsersDtos != null) {
            List<String> userIds = mcVisitNodeUsersDtos.stream().filter(mcVisitNodeUsersDto -> StringUtils.isNotEmpty(mcVisitNodeUsersDto.getDingTalkUserId())).map(NodeUsersDto::getDingTalkUserId).collect(Collectors.toList());
            dingtalkService.sendMarketFeeNotification(userIds, "市场化收费", new McVisitTemplate(mcVisit).getNoticemarkdown());
        }
    }

}