aa

business/jxstore/act/act.go

@@ -5,6 +5,7 @@ import (
 	"git.rosy.net.cn/baseapi/platformapi/mtwmapi"
 	"git.rosy.net.cn/jx-callback/business/partner/purchase/mtwm"
 	"math"
+	"sync"
 	"time"
 
 	"git.rosy.net.cn/jx-callback/business/authz"
@@ -2017,3 +2018,34 @@ func RrefreshMtwmVendorAct() (err error) {
 	task.GetID()
 	return err
 }
+
+func RrefreshEbaiVendorAct() (err error) {
+	var (
+		db     = dao.GetDB()
+		actMap = struct {
+			idMap map[int64]struct{}
+			*sync.RWMutex
+		}{}
+	)
+	actMap.idMap = make(map[int64]struct{})
+	//直接做删除，把新的加进来
+	dao.ExecuteSQL(db, `TRUNCATE act_ebai_vendor`)
+	dao.ExecuteSQL(db, `TRUNCATE act_ebai_vendor_sku`)
+	storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDEBAI}, nil, []int{model.StoreStatusOpened, model.StoreStatusHaveRest, model.StoreStatusClosed},
+		model.StoreStatusAll, model.StoreIsSyncAll, "", "", "")
+	task := tasksch.NewParallelTask("刷新饿百活动", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), jxcontext.AdminCtx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			storeMap := batchItemList[0].(*model.StoreMap)
+			actIDs, _ := api.EbaiAPI.ActMultiChannelQueryIDs("", utils.Str2Int64(storeMap.VendorStoreID), "2")
+			for _, v := range actIDs {
+				actMap.Lock()
+				actMap.idMap[v] = struct{}{}
+				actMap.Unlock()
+			}
+			return retVal, err
+		}, storeMaps)
+	tasksch.HandleTask(task, nil, true).Run()
+	task.GetResult(0)
+	fmt.Println("actmap", actMap.idMap)
+	return err
+}