- fk
This commit is contained in:
@@ -969,7 +969,7 @@ func RefreshMtpsWaybillFee(ctx *jxcontext.Context, isAsync, isContinueWhenError
|
|||||||
if err = dao.GetRows(db, &waybillList, `
|
if err = dao.GetRows(db, &waybillList, `
|
||||||
SELECT *
|
SELECT *
|
||||||
FROM waybill
|
FROM waybill
|
||||||
WHERE status_time > '2019-05-10' AND waybill_vendor_id = 102 AND desired_fee > 0
|
WHERE status_time > '2019-05-10' AND waybill_vendor_id = 102 AND desired_fee = 0
|
||||||
`); err == nil {
|
`); err == nil {
|
||||||
globals.SugarLogger.Debugf("RefreshMtpsWaybillFee, count:%d", len(waybillList))
|
globals.SugarLogger.Debugf("RefreshMtpsWaybillFee, count:%d", len(waybillList))
|
||||||
rootTask := tasksch.NewParallelTask("RefreshMtpsWaybillFee", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
|
rootTask := tasksch.NewParallelTask("RefreshMtpsWaybillFee", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
|
||||||
|
|||||||
Reference in New Issue
Block a user