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

1

Browse Source
This commit is contained in:
邹宗楠
2022-11-21 14:26:14 +08:00
parent d7f4e8ca62
commit 636c45afe3
2 changed files with 44 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
business/jxstore/cms/sync_store_sku.go
View File

@@ -678,14 +678,14 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, causeFlag
// } // }
} }
globals.SugarLogger.Debugf("==============createList=%s", utils.Format4Output(createList, false)) //globals.SugarLogger.Debugf("==============createList=%s", utils.Format4Output(createList, false))
globals.SugarLogger.Debugf("===============updateList%s", utils.Format4Output(updateList, false)) //globals.SugarLogger.Debugf("===============updateList%s", utils.Format4Output(updateList, false))
globals.SugarLogger.Debugf("==============deleteList=%s", utils.Format4Output(deleteList, false)) //globals.SugarLogger.Debugf("==============deleteList=%s", utils.Format4Output(deleteList, false))
globals.SugarLogger.Debugf("===============priceList%s", utils.Format4Output(priceList, false)) //globals.SugarLogger.Debugf("===============priceList%s", utils.Format4Output(priceList, false))
globals.SugarLogger.Debugf("===============stockList%s", utils.Format4Output(stockList, false)) //globals.SugarLogger.Debugf("===============stockList%s", utils.Format4Output(stockList, false))
globals.SugarLogger.Debugf("==============onlineList=%s", utils.Format4Output(onlineList, false)) //globals.SugarLogger.Debugf("==============onlineList=%s", utils.Format4Output(onlineList, false))
globals.SugarLogger.Debugf("===============offlineList %s", utils.Format4Output(offlineList, false)) //globals.SugarLogger.Debugf("===============offlineList %s", utils.Format4Output(offlineList, false))
globals.SugarLogger.Debugf("===============offlineList %s", utils.Format4Output(offlineList, false)) //globals.SugarLogger.Debugf("===============offlineList %s", utils.Format4Output(offlineList, false))
task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx, task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError2), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {

74
controllers/cms_sku.go
View File

@@ -867,46 +867,44 @@ func (c *SkuController) UpdateTiktokCategory() {
if err := dao.GetRows(db, &skuList, sql, param...); err != nil { if err := dao.GetRows(db, &skuList, sql, param...); err != nil {
return nil, "", err return nil, "", err
} }
for _, v1 := range data { for _, v := range skuList {
for _, v := range skuList { count++
count++ item := &model.SkuVendorCategoryMap{
item := &model.SkuVendorCategoryMap{ ModelIDCULD: model.ModelIDCULD{
ModelIDCULD: model.ModelIDCULD{ CreatedAt: time.Now(),
CreatedAt: time.Now(), UpdatedAt: time.Now(),
UpdatedAt: time.Now(), DeletedAt: utils.DefaultTimeValue,
DeletedAt: utils.DefaultTimeValue, LastOperator: "18981810340",
LastOperator: "18981810340", },
}, NameID: v.NameId,
NameID: v.NameId, VendorID: model.VendorIDDD,
VendorID: model.VendorIDDD,
}
item.VendorCategoryID = v1
skuVendorCategoryMap := &model.SkuVendorCategoryMap{}
if err := dao.GetRow(db, skuVendorCategoryMap, `SELECT * FROM sku_vendor_category_map WHERE name_id = ? AND vendor_id = ? AND deleted_at = ?`, []interface{}{v.NameId, model.VendorIDDD, utils.DefaultTimeValue}); err != nil {
globals.SugarLogger.Debugf("====================err3 %s", err)
}
if skuVendorCategoryMap != nil && skuVendorCategoryMap.ID > 0 {
if _, err := dao.UpdateEntity(db, skuVendorCategoryMap, "VendorCategoryID"); err != nil {
globals.SugarLogger.Debugf("====================err4 %s", err)
}
} else {
if err := dao.CreateEntity(db, item); err != nil {
globals.SugarLogger.Debugf("====================err5 %s", err)
}
}
go func() {
hit, err := cms.CurVendorSync.SyncStoresSkus(params.Ctx, nil, 0, db, []int{14}, []int{v.StoreId}, []int{v.Id}, true, false, true)
globals.SugarLogger.Debugf("===============hit:%s err: %s", hit, err)
}()
} }
item.VendorCategoryID = data[v.DdId]
skuVendorCategoryMap := &model.SkuVendorCategoryMap{}
if err := dao.GetRow(db, skuVendorCategoryMap, `SELECT * FROM sku_vendor_category_map WHERE name_id = ? AND vendor_id = ? AND deleted_at = ?`, []interface{}{v.NameId, model.VendorIDDD, utils.DefaultTimeValue}); err != nil {
globals.SugarLogger.Debugf("====================err3 %s", err)
}
if skuVendorCategoryMap != nil && skuVendorCategoryMap.ID > 0 {
if _, err := dao.UpdateEntity(db, skuVendorCategoryMap, "VendorCategoryID"); err != nil {
globals.SugarLogger.Debugf("====================err4 %s", err)
}
} else {
if err := dao.CreateEntity(db, item); err != nil {
globals.SugarLogger.Debugf("====================err5 %s", err)
}
}
go func() {
time.Sleep(500 * time.Millisecond)
hit, err := cms.CurVendorSync.SyncStoresSkus(params.Ctx, nil, 0, db, []int{14}, []int{v.StoreId}, []int{v.Id}, true, false, true)
globals.SugarLogger.Debugf("===============hit:%s err: %s", hit, err)
}()
}
if page*pageSize < total {
page++
} else {
break
} }
break
//if page*pageSize < total {
// page++
//} else {
// break
//}
} }
return count, "", nil return count, "", nil
}) })