package com.xncoding.pos.utils;
import cn.hutool.core.date.DateUtil;
import cn.hutool.crypto.SecureUtil;
import cn.hutool.http.HttpRequest;
import com.xncoding.pos.config.ShellProperties;
import com.xncoding.pos.config.SmsProperties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;

/**
 * 短信服务
 */
public class SmsUtils {
    private static final Logger logger = LoggerFactory.getLogger(SmsUtils.class);
    private static SmsProperties smsProperties;

    public SmsUtils() {
        if (smsProperties == null){
            smsProperties = (SmsProperties)ApplicationContextUtils.getBean("smsProperties");
        }
    }

    public void sendSms( boolean isSuccess) {
        logger.info("是否发送短信{}",smsProperties.isSendSms());
        if(!smsProperties.isSendSms()){return;}
        //请求入参
        JSONObject requestJson = new JSONObject();
        //账号
        requestJson.put("username", smsProperties.getUserName());
        //tKey
        long tKey = System.currentTimeMillis() / 1000;
        requestJson.put("tKey", tKey);
        //明文密码
        requestJson.put("password", SecureUtil.md5(SecureUtil.md5(smsProperties.getPwd()) + tKey));
        //模板ID
        requestJson.put("tpId",isSuccess? smsProperties.getTpIdSuccess():smsProperties.getTpIdError());
        //签名
        requestJson.put("signature", smsProperties.getSignature());
        //扩展号
        requestJson.put("ext", "");
        //自定义参数
        requestJson.put("extend", "");
        //发送记录集合
        JSONArray records = new JSONArray();
        JSONObject record = new JSONObject();

        String[] split = smsProperties.getMobiles().split(";");
        String now = DateUtil.now();
        for (String mobile : split) {
            //手机号
            record.put("mobile", mobile);
            //替换变量
            JSONObject param = new JSONObject();
            param.put("date",now);
            record.put("tpContent", param);
            records.add(record);

        }
        requestJson.put("records", records);
        logger.info("短信请求：{}", requestJson);
        String result = HttpRequest.post(smsProperties.getUrl())
                .timeout(60000)
                .body(requestJson.toJSONString(),"application/json;charset=UTF-8").execute().body();
        logger.info("短信返回：{}", result);

    }

}