1
This commit is contained in:
@@ -235,9 +235,9 @@ func (v *VendorSync) SyncStore2(ctx *jxcontext.Context, db *dao.DaoDB, vendorIDs
|
|||||||
isManageIt := len(storeIDs) == 0 || len(storeIDs) > 5
|
isManageIt := len(storeIDs) == 0 || len(storeIDs) > 5
|
||||||
_, hint, err = v.LoopStoresMap2(ctx, nil, db, fmt.Sprintf("同步门店信息:%v", storeIDs), isAsync, isManageIt, vendorIDs, storeIDs, mustDirty, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (resultList interface{}, err error) {
|
_, hint, err = v.LoopStoresMap2(ctx, nil, db, fmt.Sprintf("同步门店信息:%v", storeIDs), isAsync, isManageIt, vendorIDs, storeIDs, mustDirty, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (resultList interface{}, err error) {
|
||||||
loopMapInfo := batchItemList[0].(*LoopStoreMapInfo)
|
loopMapInfo := batchItemList[0].(*LoopStoreMapInfo)
|
||||||
globals.SugarLogger.Debugf("==============handler %s", utils.Format4Output(loopMapInfo, false))
|
|
||||||
var failedList []*partner.StoreSkuInfoWithErr
|
var failedList []*partner.StoreSkuInfoWithErr
|
||||||
handler := v.GetStoreHandler(loopMapInfo.VendorID)
|
handler := v.GetStoreHandler(loopMapInfo.VendorID)
|
||||||
|
globals.SugarLogger.Debugf("==============handler %d", loopMapInfo.VendorID)
|
||||||
if handler != nil {
|
if handler != nil {
|
||||||
globals.SugarLogger.Debugf("==============handler %s", "11111111111")
|
globals.SugarLogger.Debugf("==============handler %s", "11111111111")
|
||||||
if len(loopMapInfo.StoreMapList) > 1 {
|
if len(loopMapInfo.StoreMapList) > 1 {
|
||||||
|
|||||||
Reference in New Issue
Block a user