package com.java110.core.factory;

import com.java110.core.client.OutRestTemplate;
import com.java110.core.log.LoggerFactory;
import com.java110.dto.sms.SmsConfigDto;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.factory.ApplicationContextFactory;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import org.springframework.http.*;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.HttpStatusCodeException;

import java.util.Random;

/**
 * 移动短信 对接
 * http://mas.10086.cn/login
 * http://112.35.10.201:1999/smsservice?wsdl
 * webservice 方式
 * Created by wuxw on 2019/3/23.
 */
public class YidongSendMessageFactory {


    private final static Logger logger = LoggerFactory.getLogger(YidongSendMessageFactory.class);


    private static OutRestTemplate outRestTemplate;


    public final static int DEFAULT_MESSAGE_CODE_LENGTH = 6;

    public final static String YIDONG_SMS_DOMAIN = "YIDONG_SMS";


    private final static String WEBSERVICE_BODY = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:ser=\"http://server.webservice.service.mgw.mascloud.umpay.com/\">\n" +
            "   <soapenv:Header/>\n" +
            "   <soapenv:Body>\n" +
            "      <ser:sendTplSms>\n" +
            "         <!--Optional:-->\n" +
            "         <arg0>\n" +
            "\t         <![CDATA[\n" +
            "\t         \t\tREQUESTBODY\n" +
            "\t         ]]>\n" +
            "\t\t</arg0>\n" +
            "      </ser:sendTplSms>\n" +
            "   </soapenv:Body>\n" +
            "</soapenv:Envelope>";
    private final static String WEBSERVICE_BODY2 = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:ser=\"http://server.webservice.service.mgw.mascloud.umpay.com/\">\n" +
            "   <soapenv:Header/>\n" +
            "   <soapenv:Body>\n" +
            "      <ser:sendSms>\n" +
            "         <!--Optional:-->\n" +
            "         <arg0>\n" +
            "\t\t<![CDATA[\n" +
            "\t\tREQUESTBODY\n" +
            "\t\t]]>\n" +
            "\t\t</arg0>\n" +
            "      </ser:sendSms>\n" +
            "   </soapenv:Body>\n" +
            "</soapenv:Envelope>";

    /**
     * 生成6位短信码
     *
     * @return
     */
    public static String generateMessageCode() {
        return generateMessageCode(DEFAULT_MESSAGE_CODE_LENGTH);
    }

    /**
     * 生成验证码
     *
     * @param limit 位数
     * @return
     */
    public static String generateMessageCode(int limit) {
        Random random = new Random();
        String result = "";
        for (int i = 0; i < limit; i++) {
            result += (random.nextInt(9) + 1);
        }
        return result;
    }

//    public static void sendMessage(String tel, String code) {
//
//        String apId = MappingCache.getValue(YIDONG_SMS_DOMAIN, "apId");
//        String secretKey = MappingCache.getValue(YIDONG_SMS_DOMAIN, "secretKey");
//        String ecName = MappingCache.getValue(YIDONG_SMS_DOMAIN, "ecName");
//        String sign = MappingCache.getValue(YIDONG_SMS_DOMAIN, "sign");
//        String addSerial = MappingCache.getValue(YIDONG_SMS_DOMAIN, "addSerial");
//        String templateId = MappingCache.getValue(YIDONG_SMS_DOMAIN, "templateId");
//        String url = MappingCache.getValue(YIDONG_SMS_DOMAIN, "yidong_url");
//
//        String mac = getMac(ecName, apId, secretKey, templateId, tel, code, sign, addSerial);
//
//        //开始发送验证码
//        String reqParam = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" +
//                "<WsSubmitTempletReq>\n" +
//                "  <apId>" + apId + "</apId>\n" +
//                "  <secretKey>" + secretKey + "</secretKey>\n" +
//                "  <ecName>" + ecName + "</ecName>\n" +
//                "  <mobiles>\n" +
//                "    <string>" + tel + "</string>\n" +
//                "  </mobiles>\n" +
//                "  <params>\n" +
//                "    <string>" + code + "</string>\n" +
//                "  </params>\n" +
//                "  <sign>" + sign + "</sign>\n" +
//                "  <addSerial>" + addSerial + "</addSerial>\n" +
//                "  <mac>" + mac + "</mac>\n" +
//                "  <templateId>" + templateId + "</templateId>\n" +
//                "</WsSubmitTempletReq>";
//
//        reqParam = WEBSERVICE_BODY.replace("REQUESTBODY",reqParam);
//        logger.debug("请求移动公司请求报文：{}",reqParam);
//        HttpHeaders httpHeaders = new HttpHeaders();
//        httpHeaders.add("Content-Type","text/xml;charset=UTF-8");
//        outRestTemplate = ApplicationContextFactory.getBean("outRestTemplate",OutRestTemplate.class);
//        HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity(reqParam, httpHeaders);
//        try {
//            ResponseEntity<String> responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
//            logger.debug("移动公司返回报文,{}",responseEntity);
//        }catch (HttpStatusCodeException e){
//            logger.error("调用异常",e);
//        }catch (Exception e){
//            logger.error("调用异常",e);
//        }
//
//    }

    public static void sendMessage(String tel, String code) {
        String apId = MappingCache.getValue(YIDONG_SMS_DOMAIN, "apId");
        String secretKey = MappingCache.getValue(YIDONG_SMS_DOMAIN, "secretKey");
        String ecName = MappingCache.getValue(YIDONG_SMS_DOMAIN, "ecName");
        String sign = MappingCache.getValue(YIDONG_SMS_DOMAIN, "sign");
        String addSerial = MappingCache.getValue(YIDONG_SMS_DOMAIN, "addSerial");
        String url = MappingCache.getValue(YIDONG_SMS_DOMAIN, "yidong_url");

        String param = "您的验证码是："+code+",验证码有效期5分钟";

        String mac = getMac(ecName, apId, secretKey, tel, param, sign, addSerial);

        //开始发送验证码
        String reqParam = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" +
                "<WsSubmitTempletReq>\n" +
                "  <apId>" + apId + "</apId>\n" +
                "  <secretKey>" + secretKey + "</secretKey>\n" +
                "  <ecName>" + ecName + "</ecName>\n" +
                "  <mobiles>\n" +
                "    <string>" + tel + "</string>\n" +
                "  </mobiles>\n" +
                "    <content>" + param + "</content>\n" +
                "  <sign>" + sign + "</sign>\n" +
                "  <addSerial>" + addSerial + "</addSerial>\n" +
                "  <mac>" + mac + "</mac>\n" +
                "</WsSubmitTempletReq>";

        reqParam = WEBSERVICE_BODY2.replace("REQUESTBODY",reqParam);
        logger.debug("请求移动公司请求报文：{}",reqParam);
        HttpHeaders httpHeaders = new HttpHeaders();
        httpHeaders.add("Content-Type","text/xml;charset=UTF-8");
        outRestTemplate = ApplicationContextFactory.getBean("outRestTemplate",OutRestTemplate.class);
        HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity(reqParam, httpHeaders);
        try {
            ResponseEntity<String> responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
            logger.debug("移动公司返回报文,{}",responseEntity);
        }catch (HttpStatusCodeException e){
            logger.error("调用异常",e);
        }catch (Exception e){
            logger.error("调用异常",e);
        }


    }

    private static String getMac(String ecName, String apId, String secretKey, String templateId, String tel, String code, String sign, String addSerial) {

        String macStr = ecName + apId + secretKey + templateId + tel + code + sign + addSerial;
        return AuthenticationFactory.md5(macStr);
    }

    private static String getMac(String ecName, String apId, String secretKey, String tel, String content, String sign, String addSerial) {

        String macStr = ecName + apId + secretKey  + tel + content + sign + addSerial;
        return AuthenticationFactory.md5(macStr);
    }


    public static ResultVo sendOweFeeSms(String tel, Object param, SmsConfigDto smsConfigDto) {
        String apId = MappingCache.getValue(YIDONG_SMS_DOMAIN, "apId");
        String secretKey = MappingCache.getValue(YIDONG_SMS_DOMAIN, "secretKey");
        String ecName = MappingCache.getValue(YIDONG_SMS_DOMAIN, "ecName");
        String sign = MappingCache.getValue(YIDONG_SMS_DOMAIN, "sign");
        String addSerial = MappingCache.getValue(YIDONG_SMS_DOMAIN, "addSerial");
        String url = MappingCache.getValue(YIDONG_SMS_DOMAIN, "yidong_url");

        String mac = getMac(ecName, apId, secretKey, tel, param.toString(), sign, addSerial);

        //开始发送验证码
        String reqParam = "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" +
                "<WsSubmitTempletReq>\n" +
                "  <apId>" + apId + "</apId>\n" +
                "  <secretKey>" + secretKey + "</secretKey>\n" +
                "  <ecName>" + ecName + "</ecName>\n" +
                "  <mobiles>\n" +
                "    <string>" + tel + "</string>\n" +
                "  </mobiles>\n" +
                "    <content>" + param + "</content>\n" +
                "  <sign>" + sign + "</sign>\n" +
                "  <addSerial>" + addSerial + "</addSerial>\n" +
                "  <mac>" + mac + "</mac>\n" +
                "</WsSubmitTempletReq>";

        reqParam = WEBSERVICE_BODY2.replace("REQUESTBODY",reqParam);
        logger.debug("请求移动公司请求报文：{}",reqParam);
        HttpHeaders httpHeaders = new HttpHeaders();
        httpHeaders.add("Content-Type","text/xml;charset=UTF-8");
        outRestTemplate = ApplicationContextFactory.getBean("outRestTemplate",OutRestTemplate.class);
        HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity(reqParam, httpHeaders);
        try {
            ResponseEntity<String> responseEntity = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
            logger.debug("移动公司返回报文,{}",responseEntity);
        }catch (HttpStatusCodeException e){
            logger.error("调用异常",e);
        }catch (Exception e){
            logger.error("调用异常",e);
        }


        return new ResultVo(ResultVo.CODE_OK, ResultVo.MSG_OK);
    }
}