ptr，msg接口

src/dashoo.cn/backend/api/business/oilrtx/RtxService.go

@@ -1,15 +1,16 @@
 package oilrtx
 
 import (
-	"dashoo.cn/backend/api/business/organize"
-	. "dashoo.cn/utils/db"
 	"encoding/json"
-	"github.com/go-xorm/xorm"
 	"io/ioutil"
 	"log"
 	"net/http"
 	"strings"
 	"time"
+
+	"dashoo.cn/backend/api/business/organize"
+	. "dashoo.cn/utils/db"
+	"github.com/go-xorm/xorm"
 )
 
 type RtxService struct {
@@ -26,8 +27,8 @@ func GetRtxService(xormEngine *xorm.Engine) *RtxService {
 func (s *RtxService) RtxLogin() *http.Response {
 	client := &http.Client{}
 	var rtx RtxLogin
-	rtx.Username = "yuedefeng"
-	rtx.Password = "123456"
+	rtx.Username = "ORG_YJS"
+	rtx.Password = "ORG_YJS!@#"
 	rtx.UserDomain = "LOCAL_IDENT"
 	json, err := json.Marshal(rtx)
 	params := string(json)
@@ -82,15 +83,14 @@ func (s *RtxService) GetOrgList() RtxOrganizeItems {
 	jsonBlob, _ := ioutil.ReadAll(respToken.Body)
 	var rtxRespToken RtxRespToken
 	json.Unmarshal(jsonBlob, &rtxRespToken)
-	if len(rtxRespToken.token) > 0 {
-		respOrgList := s.GetOrgListByToken(rtxRespToken.token)
+	if len(rtxRespToken.Token) > 0 {
+		respOrgList := s.GetOrgListByToken(rtxRespToken.Token)
 		jsonBlob2, _ := ioutil.ReadAll(respOrgList.Body)
 		json.Unmarshal(jsonBlob2, &item)
 	}
 	return item
 }
 
-
 func (s *RtxService) AutoSyncOrgList() bool {
 	organizeItem := s.GetOrgList()
 	return s.RecursionOrganize(organizeItem.Items)
@@ -147,3 +147,61 @@ func (s *RtxService) RecursionOrganize(rtxOrganizes []RtxOrganize) bool {
 	}
 	return true
 }
+
+func (s *RtxService) HandleSendMsg(username string, tomobile string, message string) *http.Response {
+	client := &http.Client{}
+	var msg Msg
+
+	msg.UserName = username
+	msg.ToMobile = tomobile
+	msg.Msg = message
+
+	json, err := json.Marshal(msg)
+	params := string(json)
+
+	req, err := http.NewRequest("post", "http://api.uidp.dgyt.petrochina/SMS/API/sendSMS", strings.NewReader(params))
+	req.Header.Add("Content-Type", "application/json")
+	req.Header.Add("X-Token", "rzkTZhCbQKLFUOJI5L7VEqjsUWF+PoaewKQbvJHYo2Nimtn+fEWBne7G7JbWF3fpdJnAUN3e1pQ=")
+
+	resp, err := client.Do(req)
+	if err != nil {
+		log.Println("err= ", err)
+	}
+	log.Println("resp= ", resp)
+
+	return resp
+}
+
+func (s *RtxService) HandlePtrLogin(username string, password string) *http.Response {
+	client := &http.Client{}
+	var ptrUser PtrUser
+
+	ptrUser.UserName = username
+	ptrUser.PassWord = password
+
+	reqJson, err := json.Marshal(ptrUser)
+	params := string(reqJson)
+
+	req, err := http.NewRequest("post", "http://api.uidp.dgyt.petrochina/PTR/API/validatePTR", strings.NewReader(params))
+	req.Header.Add("Content-Type", "application/json")
+	req.Header.Add("X-Token", "HJpczmIJr9z26t9KcV0i1OsBE9RXFeuyhuN9MdV+Ts/FlUjCgDOxaaubo9DkF91t+X2MCxBqX6s=")
+
+	resp, err := client.Do(req)
+	if err != nil {
+		log.Println("err= ", err)
+	}
+	log.Println("resp= ", resp)
+
+	jsonBlob, _ := ioutil.ReadAll(resp.Body)
+	var rtxRespToken RtxRespToken
+	json.Unmarshal(jsonBlob, &rtxRespToken)
+
+	if rtxRespToken.Code == "2000" {
+		log.Println("hahaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa")
+		//在这里生成好的token
+	} else {
+		log.Println("出错了！！！！！！！！！！！！！！！！！！！！")
+	}
+
+	return resp
+}

src/dashoo.cn/backend/api/business/oilrtx/rtx.go

@@ -1,11 +1,21 @@
 package oilrtx
 
-
 //"time"
 
 type RtxMsg struct {
-	Msg        string `json:"msg"`
-	Receiver   string `json:"receiver"`
+	Msg      string `json:"msg"`
+	Receiver string `json:"receiver"`
+}
+
+type PtrUser struct {
+	UserName string `json:"username"`
+	PassWord string `json:"password"`
+}
+
+type Msg struct {
+	UserName string `json:"UserName"`
+	ToMobile string `json:"ToMobile"`
+	Msg      string `json:"MSG"`
 }
 
 type RtxLogin struct {
@@ -15,23 +25,22 @@ type RtxLogin struct {
 }
 
 type RtxRespToken struct {
-	code   		string `json:"code"`
-	message   	string `json:"message"`
-	token 		string `json:"token"`
+	Code    string `json:"code"`
+	Message string `json:"message"`
+	Token   string `json:"token"`
 }
 
 type RtxOrganize struct {
-	Id   			string `json:"code"`
-	OrgCode   		string `json:"message"`
-	OrgName 		string `json:"token"`
-	OrgShortName 	string `json:"orgShortName"`
-	ParentId 		string `json:"parentId"`
-	IsInValid 		string `json:"ISINVALID"`
-	Remark 			string `json:"remark"`
-	Children 		[]RtxOrganize `json:"children"`
+	Id           string        `json:"id"`
+	OrgCode      string        `json:"message"`
+	OrgName      string        `json:"token"`
+	OrgShortName string        `json:"orgShortName"`
+	ParentId     string        `json:"parentId"`
+	IsInValid    string        `json:"ISINVALID"`
+	Remark       string        `json:"remark"`
+	Children     []RtxOrganize `json:"children"`
 }
 
 type RtxOrganizeItems struct {
-	Items	[]RtxOrganize	`json:"items"`
-
+	Items []RtxOrganize `json:"items"`
 }

src/dashoo.cn/backend/api/controllers/rtx/rtx.go

@@ -10,7 +10,6 @@ type RtxController struct {
 	BaseController
 }
 
-
 // @Title get
 // @Description get workflow by token
 // @Success 200 {object} historicTasks
@@ -40,3 +39,36 @@ func (this *RtxController) SyncOrganizeList() {
 	this.Data["json"] = &datainfo
 	this.ServeJSON()
 }
+
+// @Title send message
+// @Description send message in dagangnetwork
+// @Success 200 {object} historicTasks
+// @router /sendmsg [post]
+func (this *RtxController) SendMsg() {
+	rtxSvc := oilrtx.GetRtxService(utils.DBE)
+	userName := "yuedefeng"   //说明：用户名称（RTX，AD的登录号）备注：短信接收者账号（主要是日志用到）
+	toMobile := "15563862958" //目的手机号，多个目的手机号用英文逗号分割
+	msg := "你好"               //短信内容，注意长度不要超过70个汉字（字符集GBK，url编码）
+	resp := rtxSvc.HandleSendMsg(userName, toMobile, msg)
+
+	var datainfo DataInfo
+	datainfo.Items = resp
+	this.Data["json"] = &datainfo
+	this.ServeJSON()
+}
+
+// @Title send message
+// @Description send message in dagangnetwork
+// @Success 200 {object} historicTasks
+// @router /ptrlogin [post]
+func (this *RtxController) PtrLogin() {
+	rtxSvc := oilrtx.GetRtxService(utils.DBE)
+	userName := "yuedefeng" //用户名
+	passWord := "123456"    //密码
+	resp := rtxSvc.HandlePtrLogin(userName, passWord)
+
+	var datainfo DataInfo
+	datainfo.Items = resp
+	this.Data["json"] = &datainfo
+	this.ServeJSON()
+}