1
This commit is contained in:
@@ -443,7 +443,7 @@ type AfsOrderExt struct {
|
|||||||
ShopPrice int64 `json:"shopPrice"`
|
ShopPrice int64 `json:"shopPrice"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *OrderManager) ExportOrders(ctx *jxcontext.Context, fromDateStr, toDateStr string, mapParams map[string]interface{}) (hint string, err error) {
|
func (c *OrderManager) ExportOrders(ctx *jxcontext.Context, fromDateStr, toDateStr string, mapParams map[string]interface{}, isAsync bool) (hint string, err error) {
|
||||||
var (
|
var (
|
||||||
orders []*model.GoodsOrderExt
|
orders []*model.GoodsOrderExt
|
||||||
afsSkuMap map[string]map[int]*model.OrderSkuFinancial
|
afsSkuMap map[string]map[int]*model.OrderSkuFinancial
|
||||||
@@ -638,11 +638,23 @@ func (c *OrderManager) ExportOrders(ctx *jxcontext.Context, fromDateStr, toDateS
|
|||||||
if err = err2; err == nil {
|
if err = err2; err == nil {
|
||||||
task.SetNoticeMsg(excelURL)
|
task.SetNoticeMsg(excelURL)
|
||||||
}
|
}
|
||||||
|
return excelURL, nil
|
||||||
}
|
}
|
||||||
return nil, err
|
return nil, err
|
||||||
}, 5)
|
}, 5)
|
||||||
tasksch.ManageTask(task).Run()
|
tasksch.ManageTask(task).Run()
|
||||||
|
if !isAsync {
|
||||||
|
resultList, err2 := task.GetResult(0)
|
||||||
|
if err = err2; err == nil {
|
||||||
|
if len(resultList) == 0 {
|
||||||
|
hint = "1" // todo 暂时这样
|
||||||
|
} else {
|
||||||
|
hint = jxutils.TaskResult2Hint(resultList)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
hint = task.GetID()
|
hint = task.GetID()
|
||||||
|
}
|
||||||
return hint, err
|
return hint, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -354,12 +354,13 @@ func (c *OrderController) GetOrders() {
|
|||||||
// @Param statuss query string false "订单状态列表[1,2,3],缺省不限制"
|
// @Param statuss query string false "订单状态列表[1,2,3],缺省不限制"
|
||||||
// @Param lockStatuss query string false "订单锁定状态列表[1,2,3],缺省不限制"
|
// @Param lockStatuss query string false "订单锁定状态列表[1,2,3],缺省不限制"
|
||||||
// @Param cities query string false "城市code列表[1,2,3],缺省不限制"
|
// @Param cities query string false "城市code列表[1,2,3],缺省不限制"
|
||||||
|
// @Param isAsync query bool false "是否异步"
|
||||||
// @Success 200 {object} controllers.CallResult
|
// @Success 200 {object} controllers.CallResult
|
||||||
// @Failure 200 {object} controllers.CallResult
|
// @Failure 200 {object} controllers.CallResult
|
||||||
// @router /ExportOrders [get]
|
// @router /ExportOrders [get]
|
||||||
func (c *OrderController) ExportOrders() {
|
func (c *OrderController) ExportOrders() {
|
||||||
c.callExportOrders(func(params *tOrderExportOrdersParams) (retVal interface{}, errCode string, err error) {
|
c.callExportOrders(func(params *tOrderExportOrdersParams) (retVal interface{}, errCode string, err error) {
|
||||||
retVal, err = orderman.FixedOrderManager.ExportOrders(params.Ctx, params.FromDate, params.ToDate, params.MapData)
|
retVal, err = orderman.FixedOrderManager.ExportOrders(params.Ctx, params.FromDate, params.ToDate, params.MapData, params.IsAsync)
|
||||||
return retVal, "", err
|
return retVal, "", err
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user