xingzai 2 rokov pred
rodič
commit
ff21b7abb4
3 zmenil súbory, kde vykonal 38 pridanie a 23 odobranie
  1. 21 20
      controllers/micro_roadshow.go
  2. 15 3
      services/wechat.go
  3. 2 0
      utils/config.go

+ 21 - 20
controllers/micro_roadshow.go

@@ -2,6 +2,7 @@ package controllers
 
 import (
 	"encoding/json"
+	"github.com/medivhzhan/weapp/v2"
 	"github.com/rdlucklib/rdluck_tools/paging"
 	"hongze/hongze_clpt/models"
 	"hongze/hongze_clpt/services"
@@ -378,26 +379,26 @@ func (this *MicroRoadShowController) CommentAdd() {
 		br.Msg = "留言内容不能为空!"
 		return
 	}
-	//itemToken, err := services.WxGetToken()
-	//if err != nil {
-	//	br.Msg = "GetWxAccessToken Err:" + err.Error()
-	//	return
-	//}
-	//if itemToken.AccessToken == "" {
-	//	br.Msg = "accessToken is empty"
-	//	return
-	//}
-	//commerr, err := weapp.MSGSecCheck(itemToken.AccessToken, content)
-	//if err != nil {
-	//	br.Msg = "内容校验失败!"
-	//	br.ErrMsg = "内容校验失败,Err:" + err.Error()
-	//	return
-	//}
-	//if commerr.ErrCode != 0 {
-	//	br.Msg = "内容违规,请重新提交!"
-	//	br.ErrMsg = "内容违规,Err:" + commerr.ErrMSG
-	//	return
-	//}
+	itemToken, err := services.WxGetToken()
+	if err != nil {
+		br.Msg = "GetWxAccessToken Err:" + err.Error()
+		return
+	}
+	if itemToken.AccessToken == "" {
+		br.Msg = "accessToken is empty"
+		return
+	}
+	commerr, err := weapp.MSGSecCheck(itemToken.AccessToken, content)
+	if err != nil {
+		br.Msg = "内容校验失败!"
+		br.ErrMsg = "内容校验失败,Err:" + err.Error()
+		return
+	}
+	if commerr.ErrCode != 0 {
+		br.Msg = "内容违规,请重新提交!"
+		br.ErrMsg = "内容违规,Err:" + commerr.ErrMSG
+		return
+	}
 
 	sourceType := req.SourceType
 

+ 15 - 3
services/wechat.go

@@ -64,7 +64,7 @@ type WxToken struct {
 //	return
 //}
 
-//小助手
+// 小助手
 func WxGetUserOpenIdByCode(code string) (item *WxAccessToken, err error) {
 	if code == "" {
 		err = errors.New("code is empty")
@@ -173,7 +173,7 @@ func GetWxTicket(accessToken string) (string, error) {
 	}
 }
 
-//获取测试环境的AccessToken
+// 获取测试环境的AccessToken
 func GetWxAccessToken() (accessTokenStr string, err error) {
 	o := orm.NewOrm()
 	sql := `SELECT * FROM wx_token LIMIT 1`
@@ -219,7 +219,7 @@ func GetWxAccessToken() (accessTokenStr string, err error) {
 	}
 }
 
-//开放平台
+// 开放平台
 func WxGetUserOpenIdByOpenCode(code string) (item *WxAccessToken, err error) {
 	if code == "" {
 		err = errors.New("code is empty")
@@ -281,3 +281,15 @@ func GetWxAccessOpenToken(code string) (item *WxAccessToken, err error) {
 	//accessTokenStr = WxAccessToken.AccessToken
 	return
 }
+
+func WxGetTokenXcx() (item *WxToken, err error) {
+	requestUrl := `https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s`
+	requestUrl = fmt.Sprintf(requestUrl, utils.WxAppId, utils.WxAppSecret)
+	result, err := http.Get(requestUrl)
+	if err != nil {
+		utils.FileLog.Info("WxGetToken Result:%s ", string(result))
+		return nil, err
+	}
+	err = json.Unmarshal(result, &item)
+	return
+}

+ 2 - 0
utils/config.go

@@ -89,6 +89,8 @@ func init() {
 		fmt.Println(Re)
 		panic(Re)
 	}
+	WxAppId = "wxcc32b61f96720d2f"
+	WxAppSecret = "06894933fafb24dafead7eaae09c08e0"
 	WxMsgTemplateIdAskMsgMobilePublic = "15557270714,18767183922,18621268829"
 	if RunMode == "release" {
 		WxPublicAppId = "wxb7cb8a15abad5b8e"                                          //查研观向小助手