no message

controllers/wechat.go

@@ -46,7 +46,7 @@ func (this *WechatCommonController) WechatLoginByGzh() {
 	}
 	if item.Errcode != 0 {
 		br.Msg = "获取用户信息失败"
-		br.ErrMsg = "获取access_token 失败 errcode:" + strconv.Itoa(item.Errcode) + " ;errmsg:" + item.Errmsg+"appid:" + utils.WxPublicAppId+"secret:"+utils.WxPublicAppSecret
+		br.ErrMsg = "获取access_token 失败 errcode:" + strconv.Itoa(item.Errcode) + " ;errmsg:" + item.Errmsg + "appid:" + utils.WxPublicAppId + "secret:" + utils.WxPublicAppSecret
 		return
 	}
 	openId := item.Openid
@@ -127,14 +127,14 @@ func (this *WechatCommonController) WechatLoginByGzh() {
 		UnionId:        unionId, //用户union_id
 		Subscribe:      0,
 		NickName:       wxUserInfo.Nickname,   //用户昵称，最大长度：32
-		RealName:       "",   //用户实际名称，最大长度：32
+		RealName:       "",                    //用户实际名称，最大长度：32
 		Sex:            wxUserInfo.Sex,        //普通用户性别，1为男性，2为女性
 		Province:       wxUserInfo.Province,   //普通用户个人资料填写的省份,最大长度：30
 		City:           wxUserInfo.City,       //普通用户个人资料填写的城市,最大长度：30
 		Country:        wxUserInfo.Country,    //国家，如中国为CN,最大长度：30
 		Headimgurl:     wxUserInfo.Headimgurl, //用户第三方（微信）头像,最大长度：512
-		CreateTime:     time.Now(), //创建时间，关系添加时间、用户授权时间
-		CreatePlatform: 12,   //注册平台,1:日度点评公众号,2:管理后台，3：pc端网站,4:查研观向小程序；默认：1
+		CreateTime:     time.Now(),            //创建时间，关系添加时间、用户授权时间
+		CreatePlatform: 12,                    //注册平台,1:日度点评公众号,2:管理后台，3：pc端网站,4:查研观向小程序；默认：1
 		SessionKey:     wxUserInfo.SessionKey, //微信小程序会话密钥，最大长度：255
 	}
 	if mfyxUserRecord == nil {
@@ -416,6 +416,15 @@ func (this *WechatCommonController) Notify() {
 	if method == "POST" {
 		body := this.Ctx.Input.RequestBody
 		utils.FileLog.Info("wechat notify:" + string(body))
+
+		//添加请求日志记录
+		itemApiLog := new(models.CygxThreeApiLog)
+		itemApiLog.CreateTime = time.Now()
+		itemApiLog.Source = 1
+		itemApiLog.Url = this.Ctx.Input.URI()
+		itemApiLog.Body = ""
+		itemApiLog.Result = string(body)
+		go models.AddCygxThreeApiLog(itemApiLog)
 		item := new(models.Notify)
 		err := xml.Unmarshal(body, &item)
 		if err != nil {

models/db.go

@@ -33,6 +33,7 @@ func init() {
 		new(CygxMfyxGzhUserRecord),
 		new(CygxMfyxGzhSession),
 		new(CygxIndustryFllow),
+		new(CygxThreeApiLog),
 	)
 	// 记录ORM查询日志
 	orm.Debug = true

models/three_api_log.go

@@ -0,0 +1,30 @@
+package models
+
+import (
+	"github.com/beego/beego/v2/client/orm"
+	"time"
+)
+
+type CygxThreeApiLog struct {
+	Id         int       `orm:"column(id);pk"`
+	Url        string    `description:"链接"`
+	Body       string    `description:"请求参数"`
+	Result     string    `description:"返回参数"`
+	CreateTime time.Time `description:"活动模板，带P标签"`
+	Source     int       `description:"来源1，易董"`
+}
+
+//添加日志记录
+func AddCygxThreeApiLog(item *CygxThreeApiLog) (lastId int64, err error) {
+	o := orm.NewOrm()
+	lastId, err = o.Insert(item)
+	return
+}
+
+//三十天之后的日志自行删除
+func DeleteCygxThreeApiLog() (err error) {
+	o := orm.NewOrm()
+	sql := `DELETE FROM cygx_three_api_log WHERE  DATE_SUB(CURDATE(), INTERVAL 30 DAY) > date(create_time)`
+	_, err = o.Raw(sql).Exec()
+	return
+}