package com.yami.trading.init.cache;

import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.yami.trading.bean.model.C2cPaymentMethodConfig;
import com.yami.trading.bean.model.C2cTranslate;
import com.yami.trading.common.constants.PayMethodTypeEnum;
import com.yami.trading.common.constants.PayTemplateParamEnum;
import com.yami.trading.common.constants.RedisKeys;
import com.yami.trading.common.util.Json;
import com.yami.trading.service.c2c.C2cPaymentMethodConfigService;
import com.yami.trading.service.c2c.C2cTranslateService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

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

/**
 * C2cTranslate 表加字段后，迁移旧记录，根据规则为新加字段填充值；
 * 所有盘口迁移完后，本服务可以关闭掉。
 *
 * @author caster
 * @since 2023/11/18
 **/
@Service
@Slf4j
public class LoadTranslateCache {
    @Autowired
    C2cPaymentMethodConfigService c2cPaymentMethodConfigService;

    @Autowired
    C2cTranslateService c2cTranslateService;

    @Autowired
    private RedisTemplate redisTemplate;

    public void loadData() {
        try {
            transferOldData();
        } catch (Exception e) {
            log.error("------> LoadTranslateCache.loadData 执行 transferOldData 方法报错: ", e);
        }

        QueryWrapper<C2cTranslate> allTranslateRecordWrapper = new QueryWrapper<C2cTranslate>();
        List<C2cTranslate> allTranslateRecordList = c2cTranslateService.list(allTranslateRecordWrapper);

        for (C2cTranslate oneTranslateEntity : allTranslateRecordList) {
            redisTemplate.opsForValue().set(RedisKeys.C2C_TRANSLATE_CONTENT_LANGUAGE + oneTranslateEntity.getLangKey() +
                    ":" + oneTranslateEntity.getLanguage(), Json.toJsonString(oneTranslateEntity));
        }
    }

    /**
     * 翻译功能改造，t_c2c_translate 表添加新字段：lang_key 后，对旧数据做迁移
     */
    private void transferOldData() {
        // 1. 迁移支付模板自定义参数多语言
        QueryWrapper<C2cPaymentMethodConfig> allPayConfigWrapper = new QueryWrapper<C2cPaymentMethodConfig>();
        List<C2cPaymentMethodConfig> allPayConfigList = c2cPaymentMethodConfigService.list(allPayConfigWrapper);

        String payParamLangKeyPrefix = "pay.param.";
        for (C2cPaymentMethodConfig oneConfigEntity : allPayConfigList) {
            List<C2cTranslate> c2cPaymentMethods = c2cTranslateService.list(Wrappers.<C2cTranslate>query().lambda().eq(C2cTranslate::getPaymentMethodId, oneConfigEntity.getUuid()));
            for (C2cTranslate oneTranslate : c2cPaymentMethods) {
                if (StrUtil.isNotBlank(oneTranslate.getLangKey())) {
                    // 已做过迁移的，跳过，必要情况下可以强制再迁移一次
                    continue;
                }

                if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getMethodName())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.METHOD_NAME.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName1())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_1.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName2())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_2.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName3())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_3.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName4())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_4.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName5())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_5.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName6())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_6.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName7())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_7.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName8())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_8.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName9())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_9.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName10())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_10.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName11())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_11.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName12())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_12.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName13())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_13.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName14())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_14.getCode() + "." + oneConfigEntity.getUuid());
                } else if (oneTranslate.getContent().equalsIgnoreCase(oneConfigEntity.getParamName15())) {
                    oneTranslate.setLangKey(payParamLangKeyPrefix + PayTemplateParamEnum.PARAM_15.getCode() + "." + oneConfigEntity.getUuid());
                } else {
                    log.error("-------> LoadTranslateCache.transferOldData translate 当前记录:{} 的 content 值不正确:{}", oneTranslate.getUuid(), oneTranslate.getContent());
                    continue;
                }

                c2cTranslateService.update(oneTranslate);
            }
        }

        // 2. 迁移支付方式多语言
        String payTypeLangKeyPrefix = "pay.type.";
        List<C2cTranslate> list1 = c2cTranslateService.list(Wrappers.<C2cTranslate>query().lambda().eq(C2cTranslate::getPaymentMethodId, "0"));
        List<C2cTranslate> list2 = c2cTranslateService.list(Wrappers.<C2cTranslate>query().lambda().isNull(C2cTranslate::getPaymentMethodId));
        List<C2cTranslate> list3 = c2cTranslateService.list(Wrappers.<C2cTranslate>query().lambda().eq(C2cTranslate::getPaymentMethodId, ""));

        List<C2cTranslate> payTypeTranslateList = new ArrayList<>();
        payTypeTranslateList.addAll(list1);
        payTypeTranslateList.addAll(list2);
        payTypeTranslateList.addAll(list3);

        for (C2cTranslate oneTranslate : payTypeTranslateList) {
            if (StrUtil.isNotBlank(oneTranslate.getLangKey())) {
                // 已做过迁移的，跳过，必要情况下可以强制再迁移一次
                continue;
            }

            PayMethodTypeEnum payType = PayMethodTypeEnum.nameOf(oneTranslate.getContent());
            if (payType == null) {
                log.error("-------> LoadTranslateCache.transferOldData translate 当前记录:{} 的 content 值不正确:{}", oneTranslate.getUuid(), oneTranslate.getContent());
                continue;
            }

            oneTranslate.setLangKey(payTypeLangKeyPrefix + payType.getCode());
            oneTranslate.setPaymentMethodId("0");

            c2cTranslateService.update(oneTranslate);
        }
    }
}