Browse Source

2月23日,消息推送

dev
wangguorui 3 weeks ago
parent
commit
7cccb80f46
  1. 18
      src/main/java/com/example/demo/serviceImpl/cash/CashAuditServiceImpl.java

18
src/main/java/com/example/demo/serviceImpl/cash/CashAuditServiceImpl.java

@ -71,7 +71,7 @@ public class CashAuditServiceImpl implements CashAuditService {
updateOrder.setOrderCode(orderCode); updateOrder.setOrderCode(orderCode);
String auditName = cashAuditMapper.getAuditName(auditId); String auditName = cashAuditMapper.getAuditName(auditId);
if (action == 1) { //通过 if (action == 1) { //通过
updateOrder.setStatus(20);
updateOrder.setStatus(1);
if (order.getGoodsName().equals("金币充值")) { if (order.getGoodsName().equals("金币充值")) {
//往金币订单表加一条充值记录 //往金币订单表加一条充值记录
UserGoldRecord rechargeOrder = new UserGoldRecord(); UserGoldRecord rechargeOrder = new UserGoldRecord();
@ -210,22 +210,6 @@ public class CashAuditServiceImpl implements CashAuditService {
message.setMarketName(marketName); message.setMarketName(marketName);
message.setQueryId(action==1?85:60); message.setQueryId(action==1?85:60);
rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_COLLECTION_EXCHANGE, "cash.collection.save", message); rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_COLLECTION_EXCHANGE, "cash.collection.save", message);
// 根据审核结果发送不同的消息
if (action == 1) {
// 发送审核通过消息
rabbitTemplate.convertAndSend(
RabbitMQConfig.CASH_COLLECTION_EXCHANGE,
"collection.audited",
message
);
} else {
// 发送审核驳回消息
rabbitTemplate.convertAndSend(
RabbitMQConfig.CASH_COLLECTION_EXCHANGE,
"collection.rejected",
message
);
}
return true; return true;
} }
} }
Loading…
Cancel
Save