手动拉取京东商城订单

business/jxstore/event/event.go

@@ -210,6 +210,15 @@ func GetCheckVendorCookie(ctx *jxcontext.Context, vendorIDs []int, isAuto bool)
 						errMsg += fmt.Sprintf(" 京东page账号:的Cookie无效了！", vv)
 						flag = true
 					}
+				case model.VendorIDJDShop:
+					_, err := api.JdShopAPI.OrderDetail("124350112427")
+					if err != nil {
+						if strings.Contains(err.Error(), "登录") {
+							errMsg += fmt.Sprintf("京东商城:[%v]的Cookie无效了！", vv)
+							flag = true
+						}
+						globals.SugarLogger.Debugf("cookieCheck", err)
+					}
 				}
 				cc.VendorID = v
 				cc.VendorOrgCode = vv

business/jxstore/misc/misc.go

@@ -205,7 +205,7 @@ func Init() {
 			cms.AutoFocusStoreSkusForTopSkus(jxcontext.AdminCtx, true, true)
 		}, createStorePriceTimeList)
 		ScheduleTimerFunc("GetCheckVendorCookie", func() {
-			event.GetCheckVendorCookie(jxcontext.AdminCtx, []int{model.VendorIDEBAI, model.VendorIDJD, model.VendorIDMTWM, model.VendorIDMTPS}, true)
+			event.GetCheckVendorCookie(jxcontext.AdminCtx, []int{model.VendorIDEBAI, model.VendorIDJD, model.VendorIDMTWM, model.VendorIDMTPS, model.VendorIDJDShop}, true)
 		}, checkCookieList)
 		ScheduleTimerFunc("SendSeckillSkusCountMsg", func() {
 			cms.SendSeckillSkusCountMsg(jxcontext.AdminCtx, []int{model.VendorIDEBAI, model.VendorIDJD, model.VendorIDMTWM}, false, true)

controllers/jx_order.go

@@ -1088,3 +1088,18 @@ func (c *OrderController) SendJdwlForJdsOrder() {
 		return retVal, "", err
 	})
 }
+
+// @Title 手动拉取京东商城订单
+// @Description 手动拉取京东商城订单
+// @Param	token			header		string	true	"认证token"
+// @Param	fromTime		formData	string	true	"订单起始时间"
+// @Param	toTime			formData	string	true	"订单结束时间"
+// @Success 200 {object} controllers.CallResult
+// @Failure 200 {object} controllers.CallResult
+// @router /SaveJdsOrders [post]
+func (c *OrderController) SaveJdsOrders() {
+	c.callSaveJdsOrders(func(params *tOrderSaveJdsOrdersParams) (retVal interface{}, errCode string, err error) {
+		err = orderman.SaveJdsOrders(params.Ctx, utils.Str2Time(params.FromTime), utils.Str2Time(params.ToTime))
+		return retVal, "", err
+	})
+}

routers/commentsRouter_controllers.go

@@ -1224,6 +1224,15 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:OrderController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:OrderController"],
+        beego.ControllerComments{
+            Method: "SaveJdsOrders",
+            Router: `/SaveJdsOrders`,
+            AllowHTTPMethods: []string{"post"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:OrderController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:OrderController"],
         beego.ControllerComments{
             Method: "SelfDelivered",