1
This commit is contained in:
@@ -39,10 +39,10 @@ func (c *PurchaseHandler) isAfsMsg(orderStatus string, orderId string) bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (c *PurchaseHandler) OnAfsOrderMsg(orderId, status string, msg interface{}) (retVal *tao_vegetable.CallBackResult) {
|
func (c *PurchaseHandler) OnAfsOrderMsg(orderId, status string, msg interface{}) (retVal *tao_vegetable.CallBackResult) {
|
||||||
jxutils.CallMsgHandlerAsync(func() {
|
// 取消线程池执行代码,异步返回
|
||||||
retVal = c.onAfsOrderMsg(status, msg)
|
//jxutils.CallMsgHandlerAsync(func() {
|
||||||
globals.SugarLogger.Debugf("=============errr : %s", utils.Format4Output(retVal, false))
|
retVal = c.onAfsOrderMsg(status, msg)
|
||||||
}, jxutils.ComposeUniversalOrderID(orderId, model.VendorIDTaoVegetable))
|
//}, jxutils.ComposeUniversalOrderID(orderId, model.VendorIDTaoVegetable))
|
||||||
return retVal
|
return retVal
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user