import * as QcloudSms from 'qcloudsms_js'
import { errors } from '../errors';
import { controller, action, routeData } from 'maishu-node-mvc';
import { UserDataContext, } from '../data-context';
import { permissionDataContext } from "../decorators";
import { settings } from '../global';
import { guid } from 'maishu-toolkit';

interface SMSRecord {
    id: string,
    mobile: string,
    content: string,
    code: string,
    create_date_time: Date
}

@controller('sms')
export default class SMSController {
    @action()
    async sendVerifyCode(@permissionDataContext dc: UserDataContext, @routeData { mobile, type }: { mobile: string, type: 'register' | 'resetPassword' }) {

        if (!mobile) throw errors.argumentNull('mobile')
        if (!type) throw errors.argumentNull('type')

        let verifyCode = getRandomInt(1000, 9999).toFixed(0)
        let verifyCodeText: string = settings.verifyCodeText.default;

        let msg = verifyCodeText.replace('{0}', verifyCode);
        // let obj = await connect(async conn => {

        if (type == 'register') {
            // 检查手机号码未被注册
            // let sql = 'select mobile from user where mobile = ?'
            // let [rows] = await execute(conn, sql, [mobile])
            // if (rows.length != 0)
            //     throw errors.mobileExists(mobile)
            let smsRecords = await dc.smsRecords.find({ where: { mobile }, select: ["id"] });
            if (smsRecords.length != 0)
                throw errors.mobileExists(mobile);
        }

        let obj: SMSRecord = {
            id: guid(), mobile, content: msg,
            code: verifyCode, create_date_time: new Date(Date.now())
        }
        await dc.smsRecords.insert(obj);
        sendMobileMessage(mobile, msg)
        return { smsId: obj.id };
    }

    @action()
    async checkVerifyCode(@permissionDataContext dc: UserDataContext, { smsId, verifyCode }: { smsId: string, verifyCode: string }) {
        let smsRecord = await dc.smsRecords.findOne(smsId);
        if (smsRecord == null || smsRecord.code != verifyCode)
            return false;

        return true;
    }

}

/**
 * Returns a random integer between min (inclusive) and max (inclusive)
 * Using Math.round() will give you a non-uniform distribution!
 */
function getRandomInt(min, max): number {
    return Math.floor(Math.random() * (max - min + 1)) + min;
}


function sendMobileMessage(mobile: string, content: string) {

    //=====================================
    // 如果测试模式
    if (settings.test != null) {
        // 如果不发短信，则退出
        if (!settings.test.sendMessage)
            return

        // 短信发送到测试手机
        if (settings.test.mobile)
            mobile = settings.test.mobile;
    }
    //=====================================

    return new Promise((resolve, reject) => {
        // 短信应用SDK AppID
        var appid = 1400061073;  // SDK AppID是1400开头

        // 短信应用SDK AppKey
        var appkey = "1d912a9628717fe43a464874313ca996";

        // 实例化QcloudSms
        var qcloudsms = QcloudSms(appid, appkey);
        let ssender = qcloudsms.SmsSingleSender();
        var smsType = 0; // Enum{0: 普通短信, 1: 营销短信}
        ssender.send(smsType, 86, mobile, content, "", "", (err, res, resData) => {
            if (err) {
                reject(err)
                return
            }

            resolve(resData)
        });
    })
}

// 设置请求回调处理, 这里只是演示，用户需要自定义相应处理回调
function callback(err, res, resData) {
    if (err) {
        console.log("err: ", err);
    } else {
        console.log("request data: ", res.req);
        console.log("response data: ", resData);
    }
}