- RefreshPageStore

business/netspider/netspider.go

@@ -3,6 +3,8 @@ package netspider
 import (
 	"fmt"
 
+	"git.rosy.net.cn/jx-callback/globals"
+
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/jxutils/ditu"
 	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
@@ -148,3 +150,29 @@ func GetAndStoreCitiesShops(ctx *jxcontext.Context, vendorIDs []int, cityCodeLis
 	tasksch.ManageTask(task).Run()
 	return task.GetID(), err
 }
+
+func RefreshPageStore(ctx *jxcontext.Context) (err error) {
+	sql := `
+	SELECT *
+	FROM page_shop t1
+	WHERE t1.vendor_id = 0
+	`
+	db := dao.GetDB()
+	var shopList []*model.PageShop
+	if err = dao.GetRows(db, &shopList, sql); err != nil {
+		return err
+	}
+	for _, v := range shopList {
+		if handler, _ := partner.GetPurchasePlatformFromVendorID(v.VendorID).(partner.IPurchasePlatformNetSpiderHandler); handler != nil {
+			storePageInfo, err2 := handler.GetStorePageInfo(ctx, "", v.VendorStoreID)
+			if err2 == nil {
+				v.RecentOrderNum = storePageInfo.RecentOrderNum
+				v.SkuCount = storePageInfo.SkuCount
+				dao.UpdateEntity(db, v, "RecentOrderNum", "SkuCount")
+			} else {
+				globals.SugarLogger.Debugf("RefreshPageStore err:%v", err)
+			}
+		}
+	}
+	return err
+}

controllers/temp_op.go

@@ -1,9 +1,9 @@
 package controllers
 
 import (
-	"git.rosy.net.cn/jx-callback/business/jxstore/cms"
 	"git.rosy.net.cn/jx-callback/business/jxstore/tempop"
 	"git.rosy.net.cn/jx-callback/business/jxutils"
+	"git.rosy.net.cn/jx-callback/business/netspider"
 	"github.com/astaxie/beego"
 )
 
@@ -240,7 +240,8 @@ func (c *TempOpController) RefreshMtpsWaybillFee() {
 // @router /TestIt [get]
 func (c *TempOpController) TestIt() {
 	c.callTestIt(func(params *tTempopTestItParams) (retVal interface{}, errCode string, err error) {
-		err = cms.SaveAndSendAlarmVendorSnapshot(params.Ctx, nil, nil)
+		// err = cms.SaveAndSendAlarmVendorSnapshot(params.Ctx, nil, nil)
+		err = netspider.RefreshPageStore(params.Ctx)
 		return retVal, "", err
 	})
 }