package com.nova.sankuai.service.impl;

import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nova.sankuai.domain.dto.SyncConfigPageDto;
import com.nova.sankuai.domain.entity.*;
import com.nova.sankuai.domain.vo.SyncDateResponse;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.constants.Constants;
import com.nova.sankuai.infra.constants.ResultCode;
import com.nova.sankuai.infra.mapper.SyncConfigMapper;
import com.nova.sankuai.infra.utils.PageRequest;
import com.nova.sankuai.infra.utils.PageUtil;
import com.nova.sankuai.service.*;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * @author weikangdi
 */
@Service
@AllArgsConstructor
@Slf4j
public class SyncConfigServiceImpl extends ServiceImpl<SyncConfigMapper, SyncConfig> implements ISyncConfigService {

    private final SyncConfigMapper syncConfigMapper;

    private final PageUtil pageUtil;

    private IChannelLogService channelLogService;

    private IChannelInfoService channelInfoService;

    private ICityService cityService;

    private ISyncChannelConfigService syncChannelConfigService;

    @Override
    public void invalidSyncConfig(Long id, Integer status) {
        SyncConfig syncConfigDb = getById(id);
        if (syncConfigDb == null) {
            throw new CommonException("该同步配置不存在");
        }
        syncConfigDb.setEnableFlag(status);
        updateById(syncConfigDb);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void deleteSyncConfig(Long id) {
        SyncConfig syncConfigDb = getById(id);
        if (syncConfigDb == null) {
            throw new CommonException("该同步配置不存在");
        }
        removeById(syncConfigDb.getId());
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void editSyncConfig(SyncConfig syncConfig) {
        SyncConfig syncConfigDb = getById(syncConfig.getId());
        if (syncConfigDb == null) {
            throw new CommonException("该同步配置不存在");
        }
        syncConfigDb.setEndpoint(syncConfig.getEndpoint());
        syncConfigDb.setName(syncConfig.getName());
        syncConfigDb.setAppId(syncConfig.getAppId());
        syncConfigDb.setEnableFlag(syncConfig.getEnableFlag());
        syncConfigDb.setDeliveryCity(syncConfig.getDeliveryCity());
        syncConfigDb.setDeliveryCityName(syncConfig.getDeliveryCityName());
        syncConfigDb.setChannelConfig(syncConfig.getChannelConfig());
        updateById(syncConfigDb);
        channelInfoService.updateSyncChannel(syncConfigDb);
        syncChannelConfigService.updateConfig(syncConfig);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void addSyncConfig(SyncConfig syncConfig) {
        syncConfig.setCreationDate(new Date());
        Long channelId = channelInfoService.createSyncChannel(syncConfig);
        syncConfig.setChannelId(channelId);
        save(syncConfig);
        syncChannelConfigService.updateConfig(syncConfig);
    }

    @Override
    public IPage<SyncConfig> pageSyncConfig(SyncConfigPageDto pageDto, PageRequest pageRequest) {
        IPage<SyncConfig> page = syncConfigMapper.pageModel(pageUtil.getPage(pageRequest), pageDto);
        List<SyncConfig> records = page.getRecords();
        List<SyncConfig> newRecords = new ArrayList<>();
        for (SyncConfig record : records) {
            List<Long> channelIds = syncChannelConfigService.getChannelsByConfigId(record.getId());
            record.setChannelIds(channelIds);
            newRecords.add(record);
        }
        page.setRecords(newRecords);
        return page;
    }

    @Override
    public void syncData(Customer customer) {
        try {
            List<SyncConfig> list = new ArrayList<>();
            ChannelInfo customerChannel = channelInfoService.getChannelInfoByCode(customer.getSourceChannel());
            City city = cityService.lambdaQuery().eq(City::getCityId, customer.getCity()).one();
            if (city != null) {
                String provinceId = city.getProvinceId();
                List<SyncConfig> syncConfigs = syncConfigMapper.selectMatchSyncConfig(customer.getCity(), provinceId);
                for (SyncConfig syncConfig : syncConfigs) {
                    log.info("根据同步渠道配置进行筛选:原始同步配置：" + syncConfig.toString() + "原始客户信息" + customer.toString());
                    if (SyncConfig.CHANNEL_NONE == syncConfig.getChannelConfig()) {
                        list.add(syncConfig);
                    } else {
                        List<Long> channelIds = syncChannelConfigService.getChannelsByConfigId(syncConfig.getId());
                        syncConfig.setChannelIds(channelIds);
                        if (SyncConfig.CHANNEL_INCLUDE == syncConfig.getChannelConfig() && channelIds.contains(customerChannel.getId())) {
                            list.add(syncConfig);
                        } else if (SyncConfig.CHANNEL_UNINCLUDE == syncConfig.getChannelConfig() && !channelIds.contains(customerChannel.getId())) {
                            list.add(syncConfig);
                        }
                    }
                }
            } else {
                log.error("数据同步逻辑警告：客户的城市信息为空");
                log.error("原始客户信息：" + customer.toString());
            }
            if (list.size() > 0) {
                log.info("数据同步开始");
                JSONObject param = parseSyncParam(customer, customerChannel);
                for (SyncConfig syncConfig : list) {
                    param.putOnce("appid", syncConfig.getAppId());
                    log.info("同步原始数据" + param.toString());
                    log.info("同步配置信息：" + syncConfig.toString());
                    String result = HttpUtil.post(syncConfig.getEndpoint(), param.toString(), Constants.TIME_OUT);
                    ChannelInfo channelInfo = channelInfoService.getById(syncConfig.getChannelId());
                    try {
                        log.info("同步请求返回数据" + result);
                        SyncDateResponse response = JSONUtil.toBean(result, SyncDateResponse.class);
                        if (response.getCode() == ResultCode.SUCCESS.getCode()) {
                            channelLogService.createExportLog(customer.getSourceChannel(), channelInfo.getCode(), ChannelLog.SUCCESS, customer.getId(), result);
                        } else {
                            channelLogService.createExportLog(customer.getSourceChannel(), channelInfo.getCode(), ChannelLog.FAIL, customer.getId(), result);
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                        log.error("同步数据失败,请求返回结果：" + result);
                        channelLogService.createExportLog(customer.getSourceChannel(), channelInfo.getCode(), ChannelLog.FAIL, customer.getId(), result);
                    }
                }
            }
        } catch (Exception e) {
            log.error("同步数据异常", e);
        }
    }

    private JSONObject parseSyncParam(Customer customer, ChannelInfo customerChannel) {
        JSONObject param = new JSONObject();
        param.putOnce("name", customer.getName());
        param.putOnce("phone", customer.getPhone());
        param.putOnce("professionInfo", customer.getProfessionInfo());
        param.putOnce("sesame", customer.getSesame());
        param.putOnce("socialSecurity", customer.getSocialSecurity());
        param.putOnce("providentFund", customer.getProvidentFund());
        param.putOnce("houseStatus", customer.getHouseStatus());
        param.putOnce("carStatus", customer.getCarStatus());
        param.putOnce("insurancePolicy", customer.getInsurancePolicy());
        param.putOnce("creditCard", customer.getCreditCard());
        param.putOnce("city", customer.getCity());
        param.putOnce("cityName", customer.getCityName());
        param.putOnce("loanAmount", customer.getLoanAmount());
        param.putOnce("loanTerm", customer.getLoanTerm());
        param.putOnce("approvalLoanAmount", customer.getApprovalLoanAmount());
        param.putOnce("approvalLoanTerm", customer.getApprovalLoanTerm());
        param.putOnce("maritalStatus", customer.getMaritalStatus());
        param.putOnce("education", customer.getEducation());
        param.putOnce("useOfLoan", customer.getUseOfLoan());
        param.putOnce("monthlyIncome", customer.getMonthlyIncome());
        param.putOnce("address", customer.getAddress());
        param.putOnce("age", customer.getAge());
        param.putOnce("largeLoanAmount", customer.getLargeLoanAmount());
        param.putOnce("enterpriseInfo", customer.getEnterpriseInfo());
        param.putOnce("payrollAgency", customer.getPayrollAgency());
        param.putOnce("workStatus", customer.getWorkStatus());
        param.putOnce("microLoan", customer.getMicroLoan());
        param.putOnce("houseAttributes", customer.getHouseAttributes());
        param.putOnce("housePayment", customer.getHousePayment());
        param.putOnce("syncChannelCode", customerChannel.getCode());
        param.putOnce("syncChannelName", customerChannel.getName());
        return param;
    }
}