liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2022-06-22 09:25:13 +08:00
parent 2593c67cd3
commit e4e79d7612
3 changed files with 35 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
business/enterprise/enterprise.go
View File

@@ -5,25 +5,27 @@ import (
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/business/model/dao" "git.rosy.net.cn/jx-callback/business/model/dao"
"git.rosy.net.cn/jx-callback/business/model/legacymodel" "git.rosy.net.cn/jx-callback/business/model/legacymodel"
"git.rosy.net.cn/jx-callback/globals"
"strconv"
) )
var EnterpriseSuite *enterprise_wechat.SuiteTicketInfo var EnterpriseSuite = new(enterprise_wechat.SuiteTicketInfo)
// 初始化加载全局变量 // 初始化加载全局变量
//func init() { func Init() {
// config := make([]*legacymodel.Config, 0) var config []*legacymodel.Config
// sql := `SELECT * FROM config WHERE thirdparty = ? ` sql := `SELECT * FROM config WHERE thirdparty = ? `
// if err := dao.GetRows(dao.GetDB(), config, sql, []interface{}{"enterprise"}); err != nil { if err := dao.GetRows(dao.GetDB(), &config, sql, []interface{}{"enterprise"}...); err != nil {
// globals.SugarLogger.Debugf("enterprice config err = ", err) globals.SugarLogger.Debug("enterprice init config err = ", err)
// } }
// if len(config) >= model.YES { if len(config) >= model.YES {
// EnterpriseSuite.SuiteId = config[0].RefreshToken EnterpriseSuite.SuiteId = config[0].RefreshToken
// EnterpriseSuite.SuiteTicket = config[0].Token EnterpriseSuite.SuiteTicket = config[0].Token
// EnterpriseSuite.InfoType = "" EnterpriseSuite.InfoType = ""
// time, _ := strconv.ParseInt(config[0].Date, 10, 64) time, _ := strconv.ParseInt(config[0].Date, 10, 64)
// EnterpriseSuite.TimeStamp = time EnterpriseSuite.TimeStamp = time
// } }
//} }
func UpdateEnterpriseSuite(data *enterprise_wechat.SuiteTicketInfo) error { func UpdateEnterpriseSuite(data *enterprise_wechat.SuiteTicketInfo) error {
if data.SuiteTicket != "" && data.TimeStamp > 0 { if data.SuiteTicket != "" && data.TimeStamp > 0 {

18
controllers/enterprise_callback.go
View File

@@ -1,7 +1,10 @@
package controllers package controllers
import ( import (
call "git.rosy.net.cn/baseapi/utils/weworkapi_golang-master" "git.rosy.net.cn/jx-callback/business/enterprise"
"git.rosy.net.cn/jx-callback/globals/api"
//call "git.rosy.net.cn/baseapi/utils/weworkapi_golang-master"
"git.rosy.net.cn/jx-callback/globals" "git.rosy.net.cn/jx-callback/globals"
"github.com/astaxie/beego/server/web" "github.com/astaxie/beego/server/web"
) )
@@ -15,5 +18,16 @@ type EnterpriseController struct {
// ，请参考接收消息解析数据包。 // ，请参考接收消息解析数据包。
func (e *EnterpriseController) EnterpriseCallback() { func (e *EnterpriseController) EnterpriseCallback() {
globals.SugarLogger.Debug("=====") globals.SugarLogger.Debug("=====")
call.VerifyURL(e.Ctx.ResponseWriter, e.Ctx.Request) suite, err := api.EnterpriseChatHeadApi.GetEnterpriseMsg(e.Ctx.Request)
if err != nil {
globals.SugarLogger.Debug("EnterpriseCallback=======1", err)
e.Abort("404")
} else {
if err := enterprise.UpdateEnterpriseSuite(suite); err != nil {
globals.SugarLogger.Debug("EnterpriseCallback=======2", err)
}
}
e.Data["xml"] = "success"
e.ServeXML()
//call.VerifyURL(e.Ctx.ResponseWriter, e.Ctx.Request)
} }

2
main.go
View File

@@ -3,6 +3,7 @@ package main
import ( import (
"flag" "flag"
"fmt" "fmt"
"git.rosy.net.cn/jx-callback/business/enterprise"
"net/http" "net/http"
_ "net/http/pprof" _ "net/http/pprof"
"os" "os"
@@ -86,6 +87,7 @@ func Init() {
jdshop.CurPurchaseHandler.StartRefreshComment() jdshop.CurPurchaseHandler.StartRefreshComment()
} }
misc.Init() misc.Init()
enterprise.Init() // 初始化enterprise key
} }
// 返回true表示非运行服务 // 返回true表示非运行服务