调试去掉
This commit is contained in:
@@ -738,7 +738,6 @@ func (c *OrderManager) RefreshHistoryOrdersEarningPrice(ctx *jxcontext.Context,
|
|||||||
task := tasksch.NewParallelTask("刷新历史订单结算价", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
|
task := tasksch.NewParallelTask("刷新历史订单结算价", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx,
|
||||||
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
|
||||||
order := batchItemList[0].(*model.GoodsOrder)
|
order := batchItemList[0].(*model.GoodsOrder)
|
||||||
fmt.Println("test333333333333333333333333333333", order.VendorOrderID)
|
|
||||||
db := dao.GetDB()
|
db := dao.GetDB()
|
||||||
updateSingleOrderEarningPrice(order, db)
|
updateSingleOrderEarningPrice(order, db)
|
||||||
dao.Begin(db)
|
dao.Begin(db)
|
||||||
|
|||||||
Reference in New Issue
Block a user