This commit is contained in:
suyl
2021-06-17 13:52:34 +08:00
parent 3fa4dd77ef
commit 521039d001
2 changed files with 3 additions and 5 deletions

View File

@@ -641,9 +641,6 @@ func RefreshJDMembers(ctx *jxcontext.Context) (err error) {
pages []int
memberMap = make(map[string]*model.UserMember)
)
if configs, err := dao.QueryConfigs(dao.GetDB(), "jdStorePageCookie", model.ConfigTypeCookie, ""); err == nil {
api.JdAPI.SetCookieWithStr(configs[0].Value)
}
userMemebers, _ := dao.GetUserMemberWithoutDeleted(db, model.VendorIDJD)
for _, v := range userMemebers {
memberMap[v.Mobile] = v

View File

@@ -1843,8 +1843,9 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
var (
db = dao.GetDB()
)
//103065
storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406")
things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"})
things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, []int{23831, 23832, 25387, 27282}, []string{"320406"})
thingIDmap := make(map[int64]string)
thingIDmap2 := make(map[string]int)
for _, v := range things {
@@ -1856,7 +1857,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeMap := batchItemList[0].(*model.StoreMap)
storeSkus, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, nil)
storeSkus, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{23831, 23832, 25387, 27282})
result, _ := FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*model.StoreSkuBind) (result interface{}, successCount int, err error) {
api := jd.GetAPI("320406")
var ids []int64