package cn.lili.modules.sms.serviceimpl;

import cn.lili.common.enums.ResultCode;
import cn.lili.common.exception.ServiceException;
import cn.lili.common.vo.PageVO;
import cn.lili.modules.sms.entity.dos.SmsSign;
import cn.lili.modules.sms.mapper.SmsSignMapper;
import cn.lili.modules.sms.plugin.SmsPluginFactory;
import cn.lili.modules.sms.service.SmsSignService;
import cn.lili.mybatis.util.PageUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 短信签名业务层实现
 *
 * @author Chopper
 * @since 2021/1/30 4:27 下午
 */
@Slf4j
@Service
public class SmsSignServiceImpl extends ServiceImpl<SmsSignMapper, SmsSign> implements SmsSignService {
    @Autowired
    private SmsPluginFactory smsPluginFactory;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void addSmsSign(SmsSign smsSign) {
        try {
            //如果短信签名已存在，不能重复申请
            if (this.getOne(new QueryWrapper<SmsSign>().eq("sign_name", smsSign.getSignName())) != null) {
                throw new ServiceException(ResultCode.SMS_SIGN_EXIST_ERROR);
            }
            smsPluginFactory.smsPlugin().addSmsSign(smsSign);
            smsSign.setSignStatus(0);
            this.save(smsSign);
        } catch (Exception e) {
            log.error("添加短信签名错误", e);
        }
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void deleteSmsSign(String id) {
        try {
            SmsSign smsSign = this.getById(id);
            if (smsSign != null) {
                smsPluginFactory.smsPlugin().deleteSmsSign(smsSign.getSignName());
                this.removeById(id);
            }
        } catch (Exception e) {
            log.error("删除短信签名错误", e);
        }

    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void querySmsSign() {
        try {
            Map<String, Object> map = new HashMap<>(16);
            //获取未审核通过的签名列表
            List<SmsSign> list = list(new LambdaQueryWrapper<SmsSign>().ne(SmsSign::getSignStatus, 1));
            //查询签名状态
            for (SmsSign smsSign : list) {
                map = smsPluginFactory.smsPlugin().querySmsSign(smsSign.getSignName());
                smsSign.setSignStatus((Integer) map.get("SignStatus"));
                smsSign.setReason(map.get("Reason").toString());
                this.updateById(smsSign);
            }
        } catch (Exception e) {
            log.error("查询短信签名错误", e);
        }
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void modifySmsSign(SmsSign smsSign) {
        try {
            smsPluginFactory.smsPlugin().modifySmsSign(smsSign);
            this.updateById(smsSign);
        } catch (Exception e) {
            log.error("更新短信签名错误", e);
        }
    }

    @Override
    public IPage<SmsSign> page(PageVO pageVO, Integer signStatus) {
        return this.page(PageUtil.initPage(pageVO), new QueryWrapper<SmsSign>()
                .eq(signStatus != null, "sign_status", signStatus));
    }
}