up
This commit is contained in:
@@ -188,7 +188,8 @@ func (v *VendorSync) SyncReorderCategories(ctx *jxcontext.Context, db *dao.DaoDB
|
|||||||
func (v *VendorSync) SyncStore2(ctx *jxcontext.Context, db *dao.DaoDB, vendorIDs, storeIDs []int, mustDirty, isAsync bool) (hint string, err error) {
|
func (v *VendorSync) SyncStore2(ctx *jxcontext.Context, db *dao.DaoDB, vendorIDs, storeIDs []int, mustDirty, isAsync bool) (hint string, err error) {
|
||||||
globals.SugarLogger.Debugf("SyncStore2, storeIDs:%d", storeIDs)
|
globals.SugarLogger.Debugf("SyncStore2, storeIDs:%d", storeIDs)
|
||||||
userName := ctx.GetUserName()
|
userName := ctx.GetUserName()
|
||||||
_, hint, err = v.LoopStoresMap2(ctx, db, fmt.Sprintf("同步门店信息:%v", storeIDs), isAsync, false, vendorIDs, storeIDs, mustDirty, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (resultList interface{}, err error) {
|
isManageIt := len(storeIDs) == 0 || len(storeIDs) > 5
|
||||||
|
_, hint, err = v.LoopStoresMap2(ctx, 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)
|
||||||
handler := v.GetStoreHandler(loopMapInfo.VendorID)
|
handler := v.GetStoreHandler(loopMapInfo.VendorID)
|
||||||
if handler != nil {
|
if handler != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user