This commit is contained in:
邹宗楠
2023-05-26 17:13:19 +08:00
parent e406cccc69
commit 77eb8e19a6
3 changed files with 38 additions and 5 deletions

View File

@@ -2219,14 +2219,13 @@ func UpdateStoreName() error {
var db = dao.GetDB()
sql := ` SELECT * FROM store_courier_map WHERE vendor_id IN (?,?,?,?) AND deleted_at = ?`
courierList := make([]*model.StoreCourierMap, 0, 0)
globals.SugarLogger.Debugf("====================len : %d", len(courierList))
if err := dao.GetRows(db, &courierList, sql, []interface{}{model.VendorIDMTPS, model.VendorIDFengNiao, model.VendorIDDada, model.VendorIDUUPT, utils.DefaultTimeValue}...); err != nil {
globals.SugarLogger.Debugf("query Order err := %v", err)
return err
}
globals.SugarLogger.Debugf("====================len : %d", len(courierList))
work := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
var resultList []interface{}
storeCourier := batchItemList[0].(*model.StoreCourierMap)
globals.SugarLogger.Debugf("====================storeId : %d", storeCourier.StoreID)
errList := errlist.New()
@@ -2242,7 +2241,7 @@ func UpdateStoreName() error {
}
}
}
return resultList, errList.GetErrListAsOne()
return nil, errList.GetErrListAsOne()
}
// 定时任务更新或者创建时修改东西
task := tasksch.NewParallelTask("UpdateStoreName", tasksch.NewParallelConfig().SetIsContinueWhenError(false), jxcontext.AdminCtx, work, courierList)