package com.xzx.gc.common.utils.ali;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpException;
import cn.hutool.http.HttpRequest;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject;
import com.aliyuncs.CommonRequest;
import com.aliyuncs.CommonResponse;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.http.MethodType;
import com.aliyuncs.profile.DefaultProfile;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.dto.AuthNameDto;
import com.xzx.gc.common.utils.sms.MixSmsUtil;
import lombok.experimental.UtilityClass;
import lombok.extern.slf4j.Slf4j;

import java.util.Map;

@Slf4j
@UtilityClass
public class SmsUtil {


    private static final String AL_AUTH_NAME_URL="https://phone3.market.alicloudapi.com/phonethree";
    private static final String AL_AUTH_NAME_CODE="decedbfd4e0c4a46b9165adc10d47bcf";
    private static final String AL_KEY_ID="LTAI4GDj5oLisR1higZwHm1T";
    private static final String AL_SECRET="DveOusgX8cIfeyWwKfLwCM87pfek3a";

    /**
     * 发送短信
     * @param phoneNum
     * @param map
     * @throws ClientException
     */
    public  String send(String phoneNum,Map<String,String> map,String templateCode,String channel) throws ClientException {
        if(CommonEnum.阿里云短信.getValue().equals(channel)) {
            DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou", AL_KEY_ID, AL_SECRET);
            IAcsClient client = new DefaultAcsClient(profile);

            CommonRequest request = new CommonRequest();
            request.setMethod(MethodType.POST);
            request.setDomain("dysmsapi.aliyuncs.com");
            request.setVersion("2017-05-25");
            request.setAction("SendSms");
            request.putQueryParameter("RegionId", "cn-hangzhou");
            request.putQueryParameter("PhoneNumbers", phoneNum);
            request.putQueryParameter("SignName", "小棕熊到家");
            // request.putQueryParameter("TemplateCode", "SMS_172840259");
            request.putQueryParameter("TemplateCode", templateCode);
            //设置短信内容  json字符串格式
            String message = JSONObject.toJSONString(map);
            request.putQueryParameter("TemplateParam", message);
            CommonResponse response = client.getCommonResponse(request);
            String data = response.getData();
            cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(data);
            String code = jsonObject.getStr("Code");
            String msg = jsonObject.getStr("Message","短信发送失败");
            if("OK".equals(code)){
                log.info("阿里短信发送成功：" + data);
            }else{
                log.error("阿里短信发送失败：" + msg);
                return msg;
            }
        }else if(CommonEnum.助通短信.getValue().equals(channel)){

            String s = sendPointByTemplate(phoneNum, map, templateCode,1);
            if(StrUtil.isNotBlank(s)){
                return s;
            }
        }
        return null;
    }

    /**
     * 助通单群发短信
     * @param phoneNum
     * @param content
     */
    public  int sendPoint(String phoneNum,String content)  {
        content=MixSmsUtil.sign+content;
        String s = MixSmsUtil.sendSmsPoint(phoneNum, content);
        cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(s);
        if(jsonObject.getInt("code")==200){
            log.info("助通单群发短信发送成功,手机号码：{},{}" ,phoneNum,s);
            return 0;
        }else{
            log.error("助通单群发短信发送失败：" +jsonObject.getStr("msg"));
            return -1;
        }
    }

    /**
     * 助通根据模板发送
     * @param phoneNum
     * @param templateCode
     * @param map
     * @param type
     * @return
     */
    public  String sendPointByTemplate(String phoneNum,Map<String,String> map,String templateCode,int type)  {
        String s = MixSmsUtil.sendSms(phoneNum, map, templateCode,type);
        cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(s);
        String msg = jsonObject.getStr("msg","短信发送失败");
        if(jsonObject.getInt("code")==200){
            log.info("助通短信发送成功：" +s);
        }else{
            log.error("助通短信发送失败：" +msg);
            return msg;
        }
        return null;
    }


    /**
     * 实名认证
     * @param authNameDto
     * @return
     */
    public Result authName(AuthNameDto authNameDto){
        Result result=new Result();
        try {
            String authorization = HttpRequest.get(AL_AUTH_NAME_URL).form(BeanUtil.beanToMap(authNameDto)).header("Authorization", "APPCODE " + AL_AUTH_NAME_CODE).execute().body();
            cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(authorization);
            Integer code = jsonObject.getInt("code");
            String msg = jsonObject.getStr("msg");
            cn.hutool.json.JSONObject data = jsonObject.getJSONObject("data");
            if(200==code){
                result.setData(data);
                return result;
            }else{
                return Result.error(-1,msg);
            }
        } catch (HttpException e) {
            log.error("远程实名接口请求失败",e);
            return Result.error(-1,"业务异常");
        }
    }
}