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

aa

Browse Source
This commit is contained in:
suyl
2021-05-14 10:04:49 +08:00
parent 87f5b06c52
commit 4a495cb077
2 changed files with 48 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
business/jxstore/misc/misc.go
View File

@@ -124,11 +124,11 @@ var (
cancelPayTimeOutOrderList = localjx.GetHalfHoursList() cancelPayTimeOutOrderList = localjx.GetHalfHoursList()
discountActJxList = localjx.GetDiscountActHoursList() discountActJxList = localjx.GetDiscountActHoursList()
ebaiStorePageCookieExdTOKEN string //ebaiStorePageCookieExdTOKEN string
ebaiStorePageCookieWMUSS2 string //ebaiStorePageCookieWMUSS2 string
ebaiStorePageCookieWMSTOKEN2 string //ebaiStorePageCookieWMSTOKEN2 string
ebaiStorePageCookieWMUSS string ebaiStorePageCookie string
ebaiStorePageCookieWMSTOKEN string //ebaiStorePageCookieWMSTOKEN string
mtwmCookieStr string mtwmCookieStr string
mtpsStoreToken string mtpsStoreToken string
jd2StorePageCookie string jd2StorePageCookie string
@@ -248,26 +248,6 @@ func Init() {
ScheduleTimerFunc("CleanUserOrderSMSMark", func() { ScheduleTimerFunc("CleanUserOrderSMSMark", func() {
cms.CleanUserOrderSMSMark(jxcontext.AdminCtx) cms.CleanUserOrderSMSMark(jxcontext.AdminCtx)
}, priceReferTimeList) }, priceReferTimeList)
// ScheduleTimerFunc("exSync", func() {
// var (
// db = dao.GetDB()
// storeList []int
// exSyncStoreIDList string
// syncFlag = 0
// )
// syncFlag = model.SyncFlagPriceMask
// if (time.Now().Unix()/24*3600)%10 == 0 {
// syncFlag |= model.SyncFlagSaleMask
// }
// if configs, err := dao.QueryConfigs(dao.GetDB(), "exSyncStoreIDList", model.ConfigTypeSys, ""); err == nil {
// exSyncStoreIDList = configs[0].Value
// }
// storeIDList := strings.Split(exSyncStoreIDList, ",")
// for _, v := range storeIDList {
// storeList = append(storeList, int(utils.Str2Int64(v)))
// }
// cms.CurVendorSync.SyncStoresSkus2(jxcontext.AdminCtx, nil, 0, db, partner.GetMultiStoreVendorIDs(), storeList, false, nil, []int{27379}, syncFlag, true, true)
// }, exSyncList)
ScheduleTimerFunc("CreateOrderByPriceDefend", func() { ScheduleTimerFunc("CreateOrderByPriceDefend", func() {
localjx.CreateOrderByPriceDefend(jxcontext.AdminCtx) localjx.CreateOrderByPriceDefend(jxcontext.AdminCtx)
}, []string{ }, []string{
@@ -323,20 +303,8 @@ func Init() {
"22:00:00", "22:00:00",
}) })
} }
if configs, err := dao.QueryConfigs(dao.GetDB(), "ebaiStorePageCookieExdTOKEN", model.ConfigTypeCookie, ""); err == nil { if configs, err := dao.QueryConfigs(dao.GetDB(), "ebaiStorePageCookie", model.ConfigTypeCookie, ""); err == nil {
ebaiStorePageCookieExdTOKEN = configs[0].Value ebaiStorePageCookie = configs[0].Value
}
if configs, err := dao.QueryConfigs(dao.GetDB(), "ebaiStorePageCookieWMUSS2", model.ConfigTypeCookie, ""); err == nil {
ebaiStorePageCookieWMUSS2 = configs[0].Value
}
if configs, err := dao.QueryConfigs(dao.GetDB(), "ebaiStorePageCookieWMSTOKEN2", model.ConfigTypeCookie, ""); err == nil {
ebaiStorePageCookieWMSTOKEN2 = configs[0].Value
}
if configs, err := dao.QueryConfigs(dao.GetDB(), "ebaiStorePageCookieWMUSS", model.ConfigTypeCookie, ""); err == nil {
ebaiStorePageCookieWMUSS = configs[0].Value
}
if configs, err := dao.QueryConfigs(dao.GetDB(), "ebaiStorePageCookieWMSTOKEN", model.ConfigTypeCookie, ""); err == nil {
ebaiStorePageCookieWMSTOKEN = configs[0].Value
} }
if configs, err := dao.QueryConfigs(dao.GetDB(), "mtwmCookieStr", model.ConfigTypeCookie, ""); err == nil { if configs, err := dao.QueryConfigs(dao.GetDB(), "mtwmCookieStr", model.ConfigTypeCookie, ""); err == nil {
mtwmCookieStr = configs[0].Value mtwmCookieStr = configs[0].Value
@@ -367,12 +335,13 @@ func Init() {
if globals.Jd2OrgCode != "" { if globals.Jd2OrgCode != "" {
api.Jd2API.SetJdCookie(jd2StorePageCookie) api.Jd2API.SetJdCookie(jd2StorePageCookie)
} }
api.EbaiAPI.SetCookie("PASSPORT_DELIMONT_TOKEN", ebaiStorePageCookieExdTOKEN) //api.EbaiAPI.SetCookie("PASSPORT_DELIMONT_TOKEN", ebaiStorePageCookieExdTOKEN)
api.EbaiAPI.SetCookie("WMUSS", ebaiStorePageCookieWMUSS) //api.EbaiAPI.SetCookie("WMUSS", ebaiStorePageCookieWMUSS)
api.EbaiAPI.SetCookie("WMSTOKEN", ebaiStorePageCookieWMSTOKEN) //api.EbaiAPI.SetCookie("WMSTOKEN", ebaiStorePageCookieWMSTOKEN)
api.Ebai2API.SetCookie("PASSPORT_DELIMONT_TOKEN", ebaiStorePageCookieExdTOKEN) //api.Ebai2API.SetCookie("PASSPORT_DELIMONT_TOKEN", ebaiStorePageCookieExdTOKEN)
api.Ebai2API.SetCookie("WMUSS", ebaiStorePageCookieWMUSS2) //api.Ebai2API.SetCookie("WMUSS", ebaiStorePageCookieWMUSS2)
api.Ebai2API.SetCookie("WMSTOKEN", ebaiStorePageCookieWMSTOKEN2) //api.Ebai2API.SetCookie("WMSTOKEN", ebaiStorePageCookieWMSTOKEN2)
api.EbaiAPI.SetCookieWithStr(ebaiStorePageCookie)
api.MtwmAPI.SetCookieWithStr(mtwmCookieStr) api.MtwmAPI.SetCookieWithStr(mtwmCookieStr)
api.MtpsAPI.SetCookie("token", mtpsStoreToken) api.MtpsAPI.SetCookie("token", mtpsStoreToken)
api.JdAPI.SetJdCookie(JdStorePageCookie) api.JdAPI.SetJdCookie(JdStorePageCookie)

51
controllers/jd_callback.go
View File

@@ -235,28 +235,29 @@ func (c *DjswController) OrderInfoChange() {
} }
} }
func (c *DjswController) MemberCreateCard() { //免费开卡接不到回调
if c.Ctx.Input.Method() == http.MethodPost { //func (c *DjswController) MemberCreateCard() {
callbackResponse := c.handleMsg(func(a *jdapi.API, obj interface{}) (callbackResponse *jdapi.CallbackResponse) { // if c.Ctx.Input.Method() == http.MethodPost {
callbackResponse = jd.MemberCreateMsg(obj.(*jdapi.CallbackMemberMsg)) // callbackResponse := c.handleMsg(func(a *jdapi.API, obj interface{}) (callbackResponse *jdapi.CallbackResponse) {
return callbackResponse // callbackResponse = jd.MemberCreateMsg(obj.(*jdapi.CallbackMemberMsg))
}) // return callbackResponse
c.Data["json"] = c.transferResponse("MemberCreateCard", callbackResponse) // })
c.ServeJSON() // c.Data["json"] = c.transferResponse("MemberCreateCard", callbackResponse)
} else { // c.ServeJSON()
c.Abort("404") // } else {
} // c.Abort("404")
} // }
//}
func (c *DjswController) MemberRenewCard() { //
if c.Ctx.Input.Method() == http.MethodPost { //func (c *DjswController) MemberRenewCard() {
callbackResponse := c.handleMsg(func(a *jdapi.API, obj interface{}) (callbackResponse *jdapi.CallbackResponse) { // if c.Ctx.Input.Method() == http.MethodPost {
callbackResponse = jd.MemberRenewMsg(obj.(*jdapi.CallbackMemberMsg)) // callbackResponse := c.handleMsg(func(a *jdapi.API, obj interface{}) (callbackResponse *jdapi.CallbackResponse) {
return callbackResponse // callbackResponse = jd.MemberRenewMsg(obj.(*jdapi.CallbackMemberMsg))
}) // return callbackResponse
c.Data["json"] = c.transferResponse("MemberRenewCard", callbackResponse) // })
c.ServeJSON() // c.Data["json"] = c.transferResponse("MemberRenewCard", callbackResponse)
} else { // c.ServeJSON()
c.Abort("404") // } else {
} // c.Abort("404")
} // }
//}