package com.nova.sankuai.infra.utils.sms.shandongMessage;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import lombok.AllArgsConstructor;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import java.io.UnsupportedEncodingException;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;

/**
 * @Author Lilinhong
 * @Date 2022/6/13 15:28
 */
@Component
@AllArgsConstructor
public class ShanDongMessageSendUtil {

    private static final Logger logger = LoggerFactory.getLogger("smsLogger");

    private static final String appkey = "tGCOUa";
    private static final String appsecret = "e2N9oH";
    private static final String appcode = "1000";
    private static final String URL = "http://39.103.200.133:9090/sms/distinct/v1";



    public static boolean sendMessage(String phone, String content) {
        HttpClient httpClient = null;
        HttpPost httppost = null;
        String response = null;
        Map<String, Object> map = new HashMap<>();
        map.put("appkey", ShanDongMessageSendUtil.appkey);
        map.put("appcode", ShanDongMessageSendUtil.appcode);
        String timestamp = System.currentTimeMillis() + "";
        map.put("timestamp", timestamp);
        ArrayList<SmsParam> smsParams = new ArrayList<>();
        SmsParam sms = new SmsParam();
        sms.setMsg(content);
        sms.setPhone(phone);
        smsParams.add(sms);
        map.put("sms", smsParams);
        String sign = null;
        try {
            sign = md5(ShanDongMessageSendUtil.appkey + ShanDongMessageSendUtil.appsecret + timestamp);
        } catch (Exception e) {
            logger.info("山东商帮登录验证码日志: 用户手机：" + phone + "参数md5加密失败");
            e.printStackTrace();
            return false;
        }
        map.put("sign", sign);
        logger.info("山东商帮登录验证码日志: 用户手机：" + phone + "验证码发送参数：" + map);
        try {
            httpClient = new DefaultHttpClient();
            httppost = new HttpPost(ShanDongMessageSendUtil.URL);
            String json = JSONObject.toJSONString(map);
            StringEntity formEntity = new StringEntity(json, "utf-8");
            httppost.setEntity(formEntity);
            HttpResponse httpresponse = null;
            httpresponse = httpClient.execute(httppost);
            HttpEntity httpEntity = httpresponse.getEntity();
            response = EntityUtils.toString(httpEntity, "utf-8");
            logger.info("山东商帮登录验证码日志: 用户手机：" + phone + "验证码发送返回结果：" + response);
        } catch (Exception e) {
            logger.info("山东商帮登录验证码日志: 用户手机：" + phone + "验证码发送返回失败");
            e.printStackTrace();
            return false;
        } finally {
            if (httppost != null) {
                httppost.abort();
            }
            if (httpClient != null) {
                httpClient.getConnectionManager().shutdown();
            }
        }
        ShanDongMessageResponse shanDongMessageResponse = null;
        try {
            shanDongMessageResponse = JSON.parseObject(response, ShanDongMessageResponse.class);
        } catch (Exception e) {
            logger.info("山东商帮登录验证码日志: 用户手机：" + phone + "验证码发送返回结果转换失败");
            e.printStackTrace();
            return false;
        }
        if (shanDongMessageResponse != null) {
            logger.info("山东商帮登录验证码日志: 用户手机：" + phone + "验证码发送返回结果转换：" + shanDongMessageResponse.toString());
        }
        if (shanDongMessageResponse != null && "00000".equals(shanDongMessageResponse.getCode())
                && shanDongMessageResponse.getResult() != null && "00000".equals(shanDongMessageResponse.getResult().get(0).getStatus())) {
            return true;
        }
        return false;
    }

    public static boolean sendSMSContent(String phone, String content) {
        HttpClient httpClient = null;
        HttpPost httppost = null;
        String response = null;
        Map<String, Object> map = new HashMap<>();
        map.put("appkey", ShanDongMessageSendUtil.appkey);
        map.put("appcode", ShanDongMessageSendUtil.appcode);
        String timestamp = System.currentTimeMillis() + "";
        map.put("timestamp", timestamp);
        ArrayList<SmsParam> smsParams = new ArrayList<>();
        SmsParam sms = new SmsParam();
        sms.setMsg(content);
        sms.setPhone(phone);
        smsParams.add(sms);
        map.put("sms", smsParams);
        String sign = null;
        try {
            sign = md5(ShanDongMessageSendUtil.appkey + ShanDongMessageSendUtil.appsecret + timestamp);
        } catch (Exception e) {
            logger.info("山东供应商发送自定义短信内容日志: 用户手机：" + phone + "参数md5加密失败");
            e.printStackTrace();
            return false;
        }
        map.put("sign", sign);
        logger.info("山东供应商发送自定义短信内容日志: 用户手机：" + phone + "验证码发送参数：" + map);
        try {
            httpClient = new DefaultHttpClient();
            httppost = new HttpPost(ShanDongMessageSendUtil.URL);
            String json = JSONObject.toJSONString(map);
            StringEntity formEntity = new StringEntity(json, "utf-8");
            httppost.setEntity(formEntity);
            HttpResponse httpresponse = null;
            httpresponse = httpClient.execute(httppost);
            HttpEntity httpEntity = httpresponse.getEntity();
            response = EntityUtils.toString(httpEntity, "utf-8");
            logger.info("山东供应商自定义短信内容日志: 用户手机：" + phone + "自定义短信内容发送返回结果：" + response);
        } catch (Exception e) {
            logger.info("山东供应商自定义短信内容日志: 用户手机：" + phone + "自定义短信内容发送返回失败");
            e.printStackTrace();
            return false;
        } finally {
            if (httppost != null) {
                httppost.abort();
            }
            if (httpClient != null) {
                httpClient.getConnectionManager().shutdown();
            }
        }
        ShanDongMessageResponse shanDongMessageResponse = null;
        try {
            shanDongMessageResponse = JSON.parseObject(response, ShanDongMessageResponse.class);
        } catch (Exception e) {
            logger.info("山东供应商自定义短信内容日志: 用户手机：" + phone + "自定义短信内容发送返回结果转换失败");
            e.printStackTrace();
            return false;
        }
        if (shanDongMessageResponse != null) {
            logger.info("山东供应商自定义短信内容日志: 用户手机：" + phone + "自定义短信内容发送返回结果转换：" + shanDongMessageResponse.toString());
        }
        if (shanDongMessageResponse != null && "00000".equals(shanDongMessageResponse.getCode())
                && shanDongMessageResponse.getResult() != null && "00000".equals(shanDongMessageResponse.getResult().get(0).getStatus())) {
            return true;
        }
        return false;
    }

    private static String md5(String param) throws NoSuchAlgorithmException, UnsupportedEncodingException {
        MessageDigest md5 = MessageDigest.getInstance("MD5");
        byte[] md5Byte = md5.digest(param.getBytes("utf8"));
        String result = byteToHex(md5Byte);
        return result;
    }

    private static String byteToHex(byte[] md5Byte) {
        String result = "";
        StringBuilder sb = new StringBuilder();
        for (byte each : md5Byte) {
            int value = each & 0xff;
            String hex = Integer.toHexString(value);
            if (value < 16) {
                sb.append("0");
            }
            sb.append(hex);
        }
        result = sb.toString();
        return result;
    }

    public static int byte4ToInteger(byte[] b, int offset) {
        return (0xff & b[offset]) << 24 | (0xff & b[offset + 1]) << 16 |
                (0xff & b[offset + 2]) << 8 | (0xff & b[offset + 3]);
    }


}