package cn.iocoder.yudao.module.mp.service.message;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.mp.controller.admin.message.vo.template.MpMessageTemplateListReqVO;
import cn.iocoder.yudao.module.mp.controller.admin.message.vo.template.MpMessageTemplateSendReqVO;
import cn.iocoder.yudao.module.mp.dal.dataobject.account.MpAccountDO;
import cn.iocoder.yudao.module.mp.dal.dataobject.message.MpMessageTemplateDO;
import cn.iocoder.yudao.module.mp.dal.dataobject.user.MpUserDO;
import cn.iocoder.yudao.module.mp.dal.mysql.message.MpMessageTemplateMapper;
import cn.iocoder.yudao.module.mp.framework.mp.core.MpServiceFactory;
import cn.iocoder.yudao.module.mp.service.account.MpAccountService;
import cn.iocoder.yudao.module.mp.service.user.MpUserService;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.mp.bean.template.WxMpTemplate;
import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

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

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertMap;
import static cn.iocoder.yudao.module.mp.enums.ErrorCodeConstants.*;

/**
 * 公众号模版消息 Service 实现类
 *
 * @author dengsl
 */
@Service
@Validated
@Slf4j
public class MpMessageTemplateServiceImpl implements MpMessageTemplateService {

    @Resource
    @Lazy // 延迟加载，为了解决延迟加载
    private MpServiceFactory mpServiceFactory;

    @Resource
    private MpMessageTemplateMapper messageTemplateMapper;

    @Resource
    private MpAccountService mpAccountService;

    @Resource
    private MpUserService mpUserService;

    @Override
    public void deleteMessageTemplate(Long id) {
        // 校验存在
        MpMessageTemplateDO template = validateMsgTemplateExists(id);

        // 第一步，删除模板到公众号平台
        try {
            mpServiceFactory.getRequiredMpService(template.getAppId())
                    .getTemplateMsgService().delPrivateTemplate(template.getTemplateId());
        } catch (WxErrorException e) {
            throw exception(MESSAGE_TEMPLATE_DELETE_FAIL, e.getError().getErrorMsg());
        }

        // 第二步，删除模板到数据库
        messageTemplateMapper.deleteById(id);
    }

    private MpMessageTemplateDO validateMsgTemplateExists(Long id) {
        MpMessageTemplateDO template = messageTemplateMapper.selectById(id);
        if (template == null) {
            throw exception(MESSAGE_TEMPLATE_NOT_EXISTS);
        }
        return template;
    }

    @Override
    public MpMessageTemplateDO getMessageTemplate(Long id) {
        return messageTemplateMapper.selectById(id);
    }

    @Override
    public List<MpMessageTemplateDO> getMessageTemplateList(MpMessageTemplateListReqVO listReqVO) {
        return messageTemplateMapper.selectList(listReqVO);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void syncMessageTemplate(Long accountId) {
        MpAccountDO account = mpAccountService.getRequiredAccount(accountId);

        // 第一步，从公众号平台获取最新的模板列表
        List<WxMpTemplate> wxTemplates;
        try {
            wxTemplates = mpServiceFactory.getRequiredMpService(accountId)
                    .getTemplateMsgService().getAllPrivateTemplate();
        } catch (WxErrorException e) {
            throw exception(MESSAGE_TEMPLATE_SYNC_FAIL, e.getError().getErrorMsg());
        }

        // 第二步，合并更新回自己的数据库
        Map<String, MpMessageTemplateDO> templateMap = convertMap(
                messageTemplateMapper.selectList(new LambdaQueryWrapperX<MpMessageTemplateDO>()
                        .eq(MpMessageTemplateDO::getAppId, account.getAppId())),
                MpMessageTemplateDO::getTemplateId);
        wxTemplates.forEach(wxTemplate -> {
            MpMessageTemplateDO template = templateMap.remove(wxTemplate.getTemplateId());
            // 情况一，不存在，新增
            if (template == null) {
                template = new MpMessageTemplateDO().setAccountId(account.getId()).setAppId(account.getAppId())
                        .setTemplateId(wxTemplate.getTemplateId()).setTitle(wxTemplate.getTitle())
                        .setContent(wxTemplate.getContent()).setExample(wxTemplate.getExample())
                        .setPrimaryIndustry(wxTemplate.getPrimaryIndustry()).setDeputyIndustry(wxTemplate.getDeputyIndustry());
                messageTemplateMapper.insert(template);
                return;
            }
            // 情况二，存在，则更新
            messageTemplateMapper.updateById(new MpMessageTemplateDO().setId(template.getId())
                    .setTitle(wxTemplate.getTitle()).setContent(wxTemplate.getContent()).setExample(wxTemplate.getExample())
                    .setPrimaryIndustry(wxTemplate.getPrimaryIndustry()).setDeputyIndustry(wxTemplate.getDeputyIndustry()));
        });
        // 情况三，部分模板已经不存在了，删除
        if (CollUtil.isNotEmpty(templateMap)) {
            messageTemplateMapper.deleteByIds(convertList(templateMap.values(), MpMessageTemplateDO::getId));
        }
    }

    @Override
    public void sendMessageTempalte(MpMessageTemplateSendReqVO sendReqVO) {
        // 获得关联信息
        MpUserDO user = mpUserService.getRequiredUser(sendReqVO.getUserId());
        MpMessageTemplateDO template = validateMsgTemplateExists(sendReqVO.getId());

        // 发送模版消息
        WxMpTemplateMessage templateMessage = buildTemplateMessage(template, user, sendReqVO);
        try {
            mpServiceFactory.getRequiredMpService(template.getAppId())
                    .getTemplateMsgService().sendTemplateMsg(templateMessage);
        } catch (WxErrorException e) {
            throw exception(MESSAGE_TEMPLATE_SEND_FAIL, e.getError().getErrorMsg());
        }

        // 不用记录 MpMessageDO 记录，因为，微信会主动推送，可见文档 https://developers.weixin.qq.com/doc/service/guide/product/template_message/Template_Message_Interface.html
    }

    private WxMpTemplateMessage buildTemplateMessage(MpMessageTemplateDO msgTemplateDO, MpUserDO user,
                                                     MpMessageTemplateSendReqVO sendReqVO) {
        List<WxMpTemplateData> data = new ArrayList<>();
        WxMpTemplateMessage.WxMpTemplateMessageBuilder builder = WxMpTemplateMessage.builder()
                .templateId(msgTemplateDO.getTemplateId())
                .data(data)
                .toUser(user.getOpenid());
        // 设置跳转链接
        if (StrUtil.isNotBlank(sendReqVO.getUrl())) {
            builder.url(sendReqVO.getUrl());
        }
        // 设置小程序跳转
        if (StrUtil.isNotBlank(sendReqVO.getMiniprogram())) {
            // https://developers.weixin.qq.com/doc/service/api/notify/template/api_sendtemplatemessage.html#Body__miniprogram
            builder.miniProgram(JsonUtils.parseObject(sendReqVO.getMiniprogram(), WxMpTemplateMessage.MiniProgram.class));
        }
        // 设置模板数据
        if (sendReqVO.getData() != null) {
            sendReqVO.getData().forEach((key, value) -> data.add(new WxMpTemplateData(key, value)));
        }
        return builder.build();
    }

}