package com.kidgrow.sms.aliyun.controller;

import com.kidgrow.common.base.ResponseCode;
import com.kidgrow.common.model.ResultBody;
import com.kidgrow.redis.template.RedisRepository;
import com.kidgrow.sms.client.SmsClient;
import com.kidgrow.sms.exception.SmsException;
import com.kidgrow.sms.service.AliyunSmsService;
import com.kidgrow.sms.model.SmsModel;
import com.kidgrow.sms.util.AliyunSmsUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br>
 *
 * @Description: <br>
 * @Project: <br>
 * @CreateDate: Created in 2020/2/17 09:15 <br>
 * @Author: <a href="4345453@kidgrow.com">liuke</a>
 */
@RestController
@RequestMapping("sms")
public class SmsController implements AliyunSmsService {

    @Autowired
    private SmsClient smsClient;

    @Autowired
    private RedisRepository redisRepository;

    @Value("${sms.verificationCode.timeOut:180}")
    private Long timeOut;

    @Value("${sms.verificationCode.prefix:default}")
    private String smsPrefix;

    /**
     * 发送短信验证码
     *
     * @param smsModel
     */
    @Override
    public ResultBody sendVerificationCode(@RequestBody SmsModel smsModel) {
        String phoneNumber = smsModel.getPhoneNumber();
        String key = smsModel.getKey();
        if (StringUtils.isBlank(phoneNumber) || StringUtils.isBlank(key)) {
            return ResultBody.fail(ResponseCode.ERROR_PARAMS, "手机号或短信模板不能为空！");
        }
        if (!AliyunSmsUtils.isMobile(phoneNumber)) {
            return ResultBody.fail(ResponseCode.ERROR_PARAMS, "手机号格式不正确！");
        }
        try {
            // 发送验证码
            Integer code = smsClient.sendVerificationCode(key, phoneNumber);
            // 缓存验证码和有效期
            redisRepository.setExpire(smsPrefix + phoneNumber, code.toString(), timeOut);
//            redisRepository.expire(smsPrefix + phoneNumber, timeOut);
            return ResultBody.ok();
        } catch (SmsException smsEx) {
            smsEx.printStackTrace();
            return ResultBody.failed().msg(smsEx.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
            return ResultBody.failed().msg(e.getMessage());
        }
    }

    /**
     * 验证码校验
     *
     * @param smsModel
     */
    @Override
    public ResultBody validateVerificationCode(@RequestBody SmsModel smsModel) {
        String phoneNumber = smsModel.getPhoneNumber();
        String code = smsModel.getCode();
        if (StringUtils.isBlank(phoneNumber) || StringUtils.isBlank(code)) {
            return ResultBody.failed(ResponseCode.ERROR_PARAMS, "手机号或验证码不能为空！");
        }
        try {
            if (redisRepository.exists(smsPrefix + phoneNumber)) {
                String rightCode = (String) redisRepository.get(smsPrefix + phoneNumber);
                if (code.equals(rightCode)) {
                    // 验证成功 移除缓存验证码
                    redisRepository.del(smsPrefix + phoneNumber);
                    return ResultBody.ok();
                } else {
                    return ResultBody.failed(ResponseCode.ERROR_PARAMS, "验证码不正确！");
                }
            } else {
                return ResultBody.failed(ResponseCode.ERROR_PARAMS, "验证码已失效！");
            }
        } catch (Exception e) {
            e.printStackTrace();
            return ResultBody.failed("系统错误");
        }
    }

    /**
     * 发送手机短信消息
     *
     * @param smsModel
     * @return
     */
    @Override
    public ResultBody sendSmsMsg(SmsModel smsModel) {
        List<String> phoneNumbers = smsModel.getPhoneNumbers();
        String key = smsModel.getKey();
//        if ((phoneNumbers == null || phoneNumbers.isEmpty()) || StringUtils.isBlank(key)) {
//            return ResponseBuilder.buildResultError(ResponseCode.ERROR_PARAMS, "手机号或短信模板不能为空！");
//        }

        try {
            // 发送手机短信消息
            smsClient.sendSmsMsg(key, smsModel.getParams(), phoneNumbers);
            return ResultBody.ok();
        } catch (SmsException smsEx) {
            smsEx.printStackTrace();
            return ResultBody.failed(smsEx.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
            return ResultBody.failed(e.getMessage());
        }
    }
}