验证cookie增加美团配送

This commit is contained in:
苏尹岚
2020-01-17 10:56:39 +08:00
parent f49143cc8e
commit 5488e459f9
2 changed files with 53 additions and 43 deletions

View File

@@ -1,6 +1,7 @@
package event
import (
"fmt"
"strings"
"time"
@@ -23,8 +24,9 @@ var (
)
type CheckCookie struct {
VendorID int `json:"vendorID"`
Status string `json:"status"`
VendorID int `json:"vendorID"`
VendorOrgCode string `json:"vendorOrgCode"`
Status string `json:"status"`
}
func AddOperateEvent(ctx *jxcontext.Context, accessUUID string) (err error) {
@@ -117,53 +119,58 @@ func GetCheckVendorCookie(ctx *jxcontext.Context, vendorIDs []int, isAuto bool)
var (
ebaiOrderID = "1577329467196263592"
ebaiErr = "return not json"
// mtOrderID = "69761763472881638"
// mtStoreID = "6976176"
mtErr = "返回结果格式不正常"
jdUpcCode = "6952395700895"
jdErr = "请输入用户名"
errMsg = ""
mtStoreID = "7388603"
mtErr = "返回结果格式不正常"
jdUpcCode = "6952395700895"
jdErr = "请输入用户名"
mtpsErr = "用户未登录"
errMsg = ""
)
for _, v := range vendorIDs {
var flag = false
cc := &CheckCookie{}
switch v {
case 3:
resultMap, err := api.EbaiAPI.GetStoreOrderInfo(ebaiOrderID)
if len(resultMap) < 1 && err != nil {
if strings.Contains(err.Error(), ebaiErr) {
//Cookie无效了
errMsg += " 饿百Cookie无效了"
flag = true
}
}
case 1:
err := api.MtwmAPI.PackagePriceUpdate("7388603", 1, 50)
if err != nil {
if strings.Contains(err.Error(), mtErr) {
errMsg += " 美团Cookie无效了"
flag = true
}
}
case 0:
for _, vv := range apimanager.CurAPIManager.GetAppOrgCodeList(v) {
result, err := jd.GetAPI(vv).GetJdUpcCodeByName("", jdUpcCode, 1, 5)
if len(result) < 1 && err != nil {
if strings.Contains(err.Error(), jdErr) {
//Cookie无效
errMsg += " 京东Cookie无效了"
for _, vv := range apimanager.CurAPIManager.GetAppOrgCodeList(v) {
cc := &CheckCookie{}
var flag = false
switch v {
case model.VendorIDEBAI:
resultMap, err := api.EbaiAPI.GetStoreOrderInfo(ebaiOrderID)
if len(resultMap) < 1 && err != nil {
if strings.Contains(err.Error(), ebaiErr) {
errMsg += fmt.Sprintf(" 饿百账号:[%v]的Cookie无效了", vv)
flag = true
}
}
case model.VendorIDMTWM:
_, err := api.MtwmAPI.PackagePriceGet(mtStoreID)
if err != nil {
if strings.Contains(err.Error(), mtErr) {
errMsg += fmt.Sprintf(" 美团账号:[%v]的Cookie无效了", vv)
flag = true
}
}
case model.VendorIDJD:
result, err := jd.GetAPI(vv).GetJdUpcCodeByName("", jdUpcCode, 1, 5)
if len(result) < 1 && err != nil {
if strings.Contains(err.Error(), jdErr) {
errMsg += fmt.Sprintf(" 京东账号:[%v]的Cookie无效了", vv)
flag = true
}
}
case model.VendorIDMTPS:
err := api.MtpsAPI.GetAccountDetail()
if err != nil && strings.Contains(err.Error(), mtpsErr) {
errMsg += fmt.Sprintf(" 美团配送账号:[%v]的Cookie无效了", vv)
flag = true
}
}
cc.VendorID = v
cc.VendorOrgCode = vv
if flag {
cc.Status = "无效"
} else {
cc.Status = "有效"
}
ccList = append(ccList, cc)
}
cc.VendorID = v
if flag {
cc.Status = "无效"
} else {
cc.Status = "有效"
}
ccList = append(ccList, cc)
}
if isAuto && len(ccList) > 0 {
globals.SugarLogger.Warnf("GetCheckVendorCookie", errMsg)

View File

@@ -77,7 +77,10 @@ func GetOperateEvents(db *DaoDB, apiFunction, name string, operateType int, skuI
sql += " AND b.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
sqlParams = append(sqlParams, storeIDs)
}
sql += " LIMIT ? OFFSET ?"
sql += `
ORDER BY a.created_at DESC
LIMIT ? OFFSET ?
`
sqlParams = append(sqlParams, pageSize, offset)
Begin(db)
defer Commit(db)