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

event

Browse Source
This commit is contained in:
苏尹岚
2020-10-13 14:16:39 +08:00
parent 078327e8d5
commit 60baba6bde
2 changed files with 21 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
controllers/event.go
View File

@@ -3,8 +3,11 @@ package controllers
import (
"log"
"net/http"
"time"
"git.rosy.net.cn/jx-callback/business/jxutils"
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
"git.rosy.net.cn/jx-callback/globals/api"
"git.rosy.net.cn/jx-callback/globals"
@@ -47,17 +50,17 @@ type Message struct {
// @Failure 200 {object} controllers.CallResult
// @router /GetWeixinUnlimited [post]
func (c *EventController) GetWeixinUnlimited() {
// c.callGetWeixinUnlimited(func(params *tEventGetWeixinUnlimitedParams) (retVal interface{}, errCode string, err error) {
// // api.WeixinMiniAPI2.CBRetrieveToken()
// result, err := api.WeixinMiniAPI2.GetUnlimited(params.Scene, params.Page)
// if err != nil || result == nil {
// return retVal, "", err
// }
// fileName := "wxcode" + utils.Int64ToStr(time.Now().Unix()) + ".jpg"
// retVal, err = jxutils.UploadExportContent([]byte(result["fakeData"].(string)), fileName)
// // tasks.RefreshWeixinToken()
// return retVal, "", err
// })
c.callGetWeixinUnlimited(func(params *tEventGetWeixinUnlimitedParams) (retVal interface{}, errCode string, err error) {
// api.WeixinMiniAPI2.CBRetrieveToken()
result, err := api.WeixinMiniAPI2.GetUnlimited(params.Scene, params.Page)
if err != nil || result == nil {
return retVal, "", err
}
fileName := "wxcode" + utils.Int64ToStr(time.Now().Unix()) + ".jpg"
retVal, err = jxutils.UploadExportContent([]byte(result["fakeData"].(string)), fileName)
// tasks.RefreshWeixinToken()
return retVal, "", err
})
}
// @Title 测试websocket
@@ -174,8 +177,8 @@ func handleMessages() {
// @Failure 200 {object} controllers.CallResult
// @router /GetImMessageRecord [get]
func (c *EventController) GetImMessageRecord() {
// c.callGetImMessageRecord(func(params *tEventGetImMessageRecordParams) (retVal interface{}, errCode string, err error) {
// retVal, err = dao.GetImMessageRecord(dao.GetDB(), params.VendorOrderID, "", 0, -1)
// return retVal, "", err
// })
c.callGetImMessageRecord(func(params *tEventGetImMessageRecordParams) (retVal interface{}, errCode string, err error) {
retVal, err = dao.GetImMessageRecord(dao.GetDB(), params.VendorOrderID, "", 0, -1)
return retVal, "", err
})
}

3
controllers/order_controller.go
View File

@@ -32,7 +32,10 @@ func (c *OrderController) Pay() {
// @Failure 200 {object} controllers.CallResult
// @router /CreateOrder [post]
func (c *OrderController) CreateOrder() {
c.callCreateOrder(func(params *tOrderCreateOrderParams) (retVal interface{}, errCode string, err error) {
return retVal, "", err
})
}
// @Title 请求支付订单