czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

拼团成功 消息 推送

Browse Source
This commit is contained in:
wangw
2025-12-18 15:54:29 +08:00
parent a1ad1088bb
commit 5a22c34a28
3 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConstants.java
View File

@@ -29,6 +29,7 @@ public interface RabbitConstants {
* 1,2,applySmsTemp 模版审核
* 1,2,sendMarkSms 发送营销短信
* 1,2,sendWechatTemp 发送微信模版消息
* 1,2,groupBuyYes 拼团成功
*
*/
public static final String APPLY_SMS_TEMPLATE_QUEUE = "apply.sms.temp";

6
cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java
View File

@@ -106,9 +106,10 @@ public class RabbitPublisher {
/**
* 1,2,applySmsTemp 模版审核 shop_id,sms_shop_template.id,applySmsTemp
* 1,2,sendMarkSms 发送营销短信 shop_id,sms_push_event.id,sendMarkSms
* 1,2,sendWechatTemp 发送微信模版消息 ?
* 1,2,sendWechatTemp 发送微信模版消息 shop_id,ac_push_event.id,sendWechatTemp
* 1,2,groupBuyYes 发送微信模版消息 shop_id,gb_order.id,groupBuyYes
* @param param 店铺Id,主键Id
* @param type applySmsTemp,sendMarkSms,sendWechatTemp
* @param type applySmsTemp,sendMarkSms,sendWechatTemp,groupBuyYes
*/
public void sendApplySmsMsg(String param, String type) {
sendMsg(RabbitConstants.Queue.APPLY_SMS_TEMPLATE_QUEUE, param + "," + type);
@@ -117,7 +118,6 @@ public class RabbitPublisher {
/**
* 发送生日礼品短信队列
*
* @param param
*/
public void sendBirthdayGiftSmsMsg(String param) {
sendMsg(RabbitConstants.Queue.BIRTHDAY_GIFT_SMS_QUEUE, param);

17
cash-service/order-service/src/main/java/com/czg/service/order/service/impl/GbOrderServiceImpl.java
View File

@@ -8,6 +8,7 @@ import com.czg.account.entity.ShopUser;
import com.czg.account.service.ShopConfigService;
import com.czg.account.service.ShopInfoService;
import com.czg.account.service.ShopUserService;
import com.czg.config.RabbitPublisher;
import com.czg.constant.MarketConstants;
import com.czg.enums.OrderNoPrefixEnum;
import com.czg.enums.YesNoEnum;
@@ -71,7 +72,8 @@ public class GbOrderServiceImpl extends ServiceImpl<GbOrderMapper, GbOrder> impl
@Resource
@Lazy
private PayService payService;
@Resource
private RabbitPublisher rabbitPublisher;
@DubboReference
private ShopConfigService shopConfigService;
@@ -290,24 +292,28 @@ public class GbOrderServiceImpl extends ServiceImpl<GbOrderMapper, GbOrder> impl
record.setGroupOrderNo(order.getGroupOrderNo());
if ("success".equals(order.getStatus())) {
record.setStatus("待核销");
//推送 拼团成功
sendMessage(order.getShopId(),order.getId());
}
} else {
GbOrder order = getOne(query().eq(GbOrder::getGroupOrderNo, record.getGroupOrderNo())
.eq(GbOrder::getShopId, record.getShopId()));
order.setCurrentPeopleNum(order.getCurrentPeopleNum() + 1);
if (order.getCurrentPeopleNum().equals(order.getGroupPeopleNum())) {
record.setStatus("待核销");
order.setStatus("success");
order.setGroupEndTime(LocalDateTime.now());
wareService.upGbWareGroupedNum(order.getWareId());
record.setStatus("待核销");
GbOrderDetail upRecord = new GbOrderDetail();
upRecord.setStatus("待核销");
wareService.upGbWareGroupedNum(order.getWareId());
detailService.update(upRecord, query()
.eq(GbOrderDetail::getGroupOrderNo, order.getGroupOrderNo())
.eq(GbOrderDetail::getShopId, order.getShopId())
.eq(GbOrderDetail::getIsDel, YesNoEnum.NO.value())
.eq(GbOrderDetail::getStatus, "待成团")
);
//推送 拼团成功
sendMessage(order.getShopId(),order.getId());
}
updateById(order);
}
@@ -462,4 +468,9 @@ public class GbOrderServiceImpl extends ServiceImpl<GbOrderMapper, GbOrder> impl
upRecord.setCancelReason(reason);
return detailService.update(upRecord, query().eq(GbOrderDetail::getId, record.getId()));
}
//推送 拼团成功 消息
private void sendMessage(Long shopId, Long orderId) {
rabbitPublisher.sendApplySmsMsg(shopId + "," + orderId, "groupBuyYes");
}
}