change sms port

notice/sms.go

@@ -1,83 +1,128 @@
 package notice
 
 import (
-	"encoding/xml"
+	"bytes"
+	"encoding/json"
+	"errors"
 	"fmt"
 	"io/ioutil"
 	"net/http"
 	"net/url"
-	"strings"
 )
 
-func SendChineseSMS(host, user, pass, mobile, content string) error {
-	client := &http.Client{}
-	req, err := http.NewRequest("POST", host, strings.NewReader("account="+user+"&password="+pass+"&mobile="+mobile+"&content="+content))
+// SendChineseSMS 发送国内手机验证码
+func SendChineseSMS(user, pass, mobile, content string) error {
+	params := make(map[string]interface{})
+	params["account"] = user
+	params["password"] = pass
+	params["phone"] = mobile
+	params["msg"] = url.QueryEscape(content)
+	params["report"] = true
+
+	bytesData, err := json.Marshal(params)
+	if err != nil {
+		return err
+	}
+
+	reader := bytes.NewReader(bytesData)
+	url := "http://smssh1.253.com/msg/send/json"
+	request, err := http.NewRequest("POST", url, reader)
 	if err != nil {
 		return err
 	}
 
-	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
 
-	resp, err := client.Do(req)
+	client := http.Client{}
+	resp, err := client.Do(request)
 	if err != nil {
 		return err
 	}
 
 	defer resp.Body.Close()
 
-	body, err := ioutil.ReadAll(resp.Body)
+	respBytes, err := ioutil.ReadAll(resp.Body)
 	if err != nil {
 		return err
 	}
 
 	result := struct {
-		Code int    `xml:"code"`
-		Msg  string `xml:"msg"`
+		Code     string `json:"code"`
+		MsgID    string `json:"msgId"`
+		Time     string `json:"time"`
+		ErrorMsg string `json:"errorMsg"`
 	}{}
 
-	err = xml.Unmarshal(body, &result)
+	err = json.Unmarshal(respBytes, &result)
 	if err != nil {
 		return err
 	}
 
-	if result.Code != 2 {
+	if result.Code != "0" {
 		switch result.Code {
-		case 406, 4030:
-			return fmt.Errorf("phone number format is not correct")
-		case 4072:
-			return fmt.Errorf("your message must match the templat")
-		case 4081:
+		case "103":
 			return fmt.Errorf("one verification code per minute per phone")
-		case 4085:
+		case "107":
+			return fmt.Errorf("phone number format is not correct")
+		case "135":
 			return fmt.Errorf("up to 5 verification codes a day")
 		default:
-			return fmt.Errorf("send sms faild")
+			return fmt.Errorf(result.ErrorMsg)
 		}
 	}
 
 	return nil
 }
 
+// SendForeignSMS 发送国外手机验证码
 func SendForeignSMS(user, pass, mobile, content string) error {
-	content = url.QueryEscape(content)
-	url := "http://222.73.117.140:8044/mt?dc=15&tf=3&rf=1&un=" + user + "&pw=" + pass + "&da=" + mobile + "&sm=" + content
+	params := make(map[string]interface{})
+	params["account"] = user
+	params["password"] = pass
+	params["mobile"] = mobile
+	params["msg"] = url.QueryEscape(content)
+	params["report"] = true
+
+	bytesData, err := json.Marshal(params)
+	if err != nil {
+		return err
+	}
 
-	resp, err := http.Get(url)
+	reader := bytes.NewReader(bytesData)
+	url := "http://intapi.253.com/send/json"
+	request, err := http.NewRequest("POST", url, reader)
+	if err != nil {
+		return err
+	}
+
+	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+
+	client := http.Client{}
+	resp, err := client.Do(request)
 	if err != nil {
 		return err
 	}
 
 	defer resp.Body.Close()
 
-	body, err := ioutil.ReadAll(resp.Body)
+	respBytes, err := ioutil.ReadAll(resp.Body)
 	if err != nil {
 		return err
 	}
 
-	result := string(body)
+	result := struct {
+		Code  string `json:"code"`
+		Error string `json:"error"`
+		MsgID string `json:"msgid"`
+	}{}
+
+	err = json.Unmarshal(respBytes, &result)
+	if err != nil {
+		return err
+	}
 
-	if !strings.Contains(result, "id") {
-		return fmt.Errorf("phone number format is not correct")
+	if result.Code != "0" {
+		return errors.New(result.Error)
 	}
 
 	return nil