|
...
|
...
|
@@ -46,7 +46,7 @@ func (dividendsEstimateService *DividendsEstimateService) EstimateDividendsIncen |
|
|
|
if err = broker.Push(constant.TOPIC_UP_BLOCK_CHAIN, broker.NewPushObject(
|
|
|
|
domain.BlockChainSourceCooperationDividendsEstimate,
|
|
|
|
strconv.Itoa(int(v.DividendsEstimateId)),
|
|
|
|
"",
|
|
|
|
strconv.Itoa(int(v.DividendsEstimateId)),
|
|
|
|
v,
|
|
|
|
)); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "消息服务异常"+err.Error())
|
|
...
|
...
|
@@ -84,7 +84,7 @@ func (dividendsEstimateService *DividendsEstimateService) EstimateMoneyIncentive |
|
|
|
if err = broker.Push(constant.TOPIC_UP_BLOCK_CHAIN, broker.NewPushObject(
|
|
|
|
domain.BlockChainSourceCooperationDividendsEstimate,
|
|
|
|
strconv.Itoa(int(v.DividendsEstimateId)),
|
|
|
|
"",
|
|
|
|
strconv.Itoa(int(v.DividendsEstimateId)),
|
|
|
|
v,
|
|
|
|
)); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "消息服务异常"+err.Error())
|
...
|
...
|
|
