1
This commit is contained in:
@@ -1,6 +1,7 @@
|
|||||||
package event
|
package event
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"regexp"
|
"regexp"
|
||||||
"strings"
|
"strings"
|
||||||
@@ -30,6 +31,7 @@ type CheckCookie struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func AddOperateEvent(ctx *jxcontext.Context, accessUUID, jsonData string, errCode, errMsg string, useTime int, apiFunctionSpec string) (err error) {
|
func AddOperateEvent(ctx *jxcontext.Context, accessUUID, jsonData string, errCode, errMsg string, useTime int, apiFunctionSpec string) (err error) {
|
||||||
|
fmt.Println("333333333")
|
||||||
var (
|
var (
|
||||||
apiFunction string
|
apiFunction string
|
||||||
db = dao.GetDB()
|
db = dao.GetDB()
|
||||||
@@ -47,7 +49,7 @@ func AddOperateEvent(ctx *jxcontext.Context, accessUUID, jsonData string, errCod
|
|||||||
}
|
}
|
||||||
if apiFunction != "" {
|
if apiFunction != "" {
|
||||||
if apiFunction[0:3] == "Get" || NoUseEventMap[apiFunction] != "" {
|
if apiFunction[0:3] == "Get" || NoUseEventMap[apiFunction] != "" {
|
||||||
return err
|
return errors.New("未知错误")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if accessUUID != "" {
|
if accessUUID != "" {
|
||||||
@@ -76,6 +78,7 @@ func AddOperateEvent(ctx *jxcontext.Context, accessUUID, jsonData string, errCod
|
|||||||
}()
|
}()
|
||||||
err = dao.CreateEntity(db, event)
|
err = dao.CreateEntity(db, event)
|
||||||
dao.Commit(db, txDB)
|
dao.Commit(db, txDB)
|
||||||
|
fmt.Println("4444444444")
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
package mtwm
|
package mtwm
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
|
"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
|
||||||
"git.rosy.net.cn/jx-callback/business/jxutils"
|
"git.rosy.net.cn/jx-callback/business/jxutils"
|
||||||
"git.rosy.net.cn/jx-callback/business/model"
|
"git.rosy.net.cn/jx-callback/business/model"
|
||||||
@@ -11,7 +10,6 @@ import (
|
|||||||
func OnCallbackMsg(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) {
|
func OnCallbackMsg(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) {
|
||||||
if CurPurchaseHandler != nil {
|
if CurPurchaseHandler != nil {
|
||||||
if msg.Cmd == mtwmapi.MsgTypeStoreStatusChanged || msg.Cmd == mtwmapi.MsgTypeStoreAuditStatusChanged {
|
if msg.Cmd == mtwmapi.MsgTypeStoreStatusChanged || msg.Cmd == mtwmapi.MsgTypeStoreAuditStatusChanged {
|
||||||
fmt.Println("222222============",22222222222222)
|
|
||||||
response = CurPurchaseHandler.onStoreStatusChanged(msg)
|
response = CurPurchaseHandler.onStoreStatusChanged(msg)
|
||||||
} else if msg.Cmd == mtwmapi.MsgTypePrivateNumberDowngrade {
|
} else if msg.Cmd == mtwmapi.MsgTypePrivateNumberDowngrade {
|
||||||
response = CurPurchaseHandler.onNumberDowngrade(msg)
|
response = CurPurchaseHandler.onNumberDowngrade(msg)
|
||||||
|
|||||||
@@ -303,7 +303,6 @@ func (p *PurchaseHandler) RefreshAllStoresID(ctx *jxcontext.Context, parentTask
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (p *PurchaseHandler) onStoreStatusChanged(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) {
|
func (p *PurchaseHandler) onStoreStatusChanged(msg *mtwmapi.CallbackMsg) (response *mtwmapi.CallbackResponse) {
|
||||||
fmt.Println("err !============", 111)
|
|
||||||
var err error
|
var err error
|
||||||
vendorStoreID := msg.FormData.Get("app_poi_code")
|
vendorStoreID := msg.FormData.Get("app_poi_code")
|
||||||
storeStatus := 0
|
storeStatus := 0
|
||||||
|
|||||||
Reference in New Issue
Block a user