1
This commit is contained in:
@@ -707,7 +707,12 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, parentTask tasksch.I
|
||||
if len(loopInfoList) == 1 {
|
||||
taskName = fmt.Sprintf("%s,处理平台%s", taskName, model.VendorChineseNames[loopInfoList[0].VendorID])
|
||||
}
|
||||
globals.SugarLogger.Debug("================刘磊",loopInfoList)
|
||||
|
||||
for k,_ := range loopInfoList {
|
||||
globals.SugarLogger.Debug("刘磊=============",k)
|
||||
globals.SugarLogger.Debug("刘磊=============",len(loopInfoList))
|
||||
|
||||
}
|
||||
// 临时把京东的并发改为2
|
||||
task = tasksch.NewParallelTask(taskName, tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, handler, loopInfoList)
|
||||
if isAsync {
|
||||
|
||||
@@ -339,6 +339,7 @@ func GetStoresMapList2(db *DaoDB, vendorIDs, storeIDs, storeStatuss []int, statu
|
||||
sql += " AND t1.sync_status <> 0"
|
||||
}
|
||||
sql += " ORDER BY t1.store_id , t1.vendor_id"
|
||||
globals.SugarLogger.Debug("刘磊=============sql",sql,sqlParams)
|
||||
if err = GetRows(db, &storeMapList, sql, sqlParams...); err == nil {
|
||||
return storeMapList, nil
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user