aa
This commit is contained in:
@@ -349,7 +349,7 @@ func (c *OrderManager) GetOrders(ctx *jxcontext.Context, isIncludeFake bool, fro
|
|||||||
task := tasksch.NewParallelTask("RefreshOrderFinancial", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
|
task := tasksch.NewParallelTask("RefreshOrderFinancial", tasksch.NewParallelConfig().SetIsContinueWhenError(true), 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.GoodsOrderExt)
|
order := batchItemList[0].(*model.GoodsOrderExt)
|
||||||
afsOrder := &AfsOrderExt{}
|
var afsOrder *AfsOrderExt
|
||||||
sql := `
|
sql := `
|
||||||
SELECT t1.afs_total_shop_money, t2.shop_price
|
SELECT t1.afs_total_shop_money, t2.shop_price
|
||||||
FROM afs_order t1
|
FROM afs_order t1
|
||||||
|
|||||||
Reference in New Issue
Block a user