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

sms_push_event_user 复用

Browse Source
This commit is contained in:
wangw
2025-10-20 10:51:18 +08:00
parent 78af79294d
commit 05a3be5ecb
3 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cash-api/market-server/src/main/java/com/czg/task/AAMarketTasks.java
View File

@@ -52,6 +52,7 @@ public class AAMarketTasks {
} }
//月累计 发送条数 累计金额
@Resource @Resource
private SmsShopMoneyTask smsShopMoneyTask; private SmsShopMoneyTask smsShopMoneyTask;
//每月1号 0点 0分 1秒 执行 //每月1号 0点 0分 1秒 执行

7
cash-common/cash-common-service/src/main/java/com/czg/market/entity/SmsPushEventUser.java
View File

@@ -35,7 +35,12 @@ public class SmsPushEventUser implements Serializable {
private Long id; private Long id;
/** /**
* sms_user_push_event的id * sms-短信 ac-公众号
*/
private String type;
/**
* sms_push_event的id 或者ac_push_event 的 id
*/ */
private Long eventId; private Long eventId;

10
cash-service/market-service/src/main/java/com/czg/service/market/service/impl/SmsPushEventServiceImpl.java
View File

@@ -69,7 +69,9 @@ public class SmsPushEventServiceImpl extends ServiceImpl<SmsPushEventMapper, Sms
continue; continue;
} }
SmsPushEventUser eventUser = eventUserMapper.selectOneByQuery( SmsPushEventUser eventUser = eventUserMapper.selectOneByQuery(
new QueryWrapper().eq(SmsPushEventUser::getEventId, record.getId()) new QueryWrapper()
.eq(SmsPushEventUser::getType, "sms")
.eq(SmsPushEventUser::getEventId, record.getId())
); );
record.setSmsPushEventUser(eventUser); record.setSmsPushEventUser(eventUser);
} }
@@ -96,6 +98,7 @@ public class SmsPushEventServiceImpl extends ServiceImpl<SmsPushEventMapper, Sms
save(pushEvent); save(pushEvent);
if (param.getUserType() == 2) { if (param.getUserType() == 2) {
SmsPushEventUser eventUser = param.getSmsPushEventUser(); SmsPushEventUser eventUser = param.getSmsPushEventUser();
eventUser.setType("sms");
eventUser.setShopId(param.getShopId()); eventUser.setShopId(param.getShopId());
eventUser.setEventId(pushEvent.getId()); eventUser.setEventId(pushEvent.getId());
eventUserMapper.insert(eventUser); eventUserMapper.insert(eventUser);
@@ -129,6 +132,7 @@ public class SmsPushEventServiceImpl extends ServiceImpl<SmsPushEventMapper, Sms
eventUserMapper.deleteByQuery(new QueryWrapper().eq(SmsPushEventUser::getEventId, pushEvent.getId())); eventUserMapper.deleteByQuery(new QueryWrapper().eq(SmsPushEventUser::getEventId, pushEvent.getId()));
if (param.getUserType() == 2) { if (param.getUserType() == 2) {
SmsPushEventUser eventUser = param.getSmsPushEventUser(); SmsPushEventUser eventUser = param.getSmsPushEventUser();
eventUser.setType("sms");
eventUser.setShopId(param.getShopId()); eventUser.setShopId(param.getShopId());
eventUser.setEventId(pushEvent.getId()); eventUser.setEventId(pushEvent.getId());
eventUserMapper.insert(eventUser); eventUserMapper.insert(eventUser);
@@ -146,7 +150,9 @@ public class SmsPushEventServiceImpl extends ServiceImpl<SmsPushEventMapper, Sms
AssertUtil.isNull(smsPushEvent, "券发放失败，推送事件不存在"); AssertUtil.isNull(smsPushEvent, "券发放失败，推送事件不存在");
SmsPushEventDTO pushEvent = BeanUtil.toBean(smsPushEvent, SmsPushEventDTO.class); SmsPushEventDTO pushEvent = BeanUtil.toBean(smsPushEvent, SmsPushEventDTO.class);
SmsPushEventUser eventUser = eventUserMapper.selectOneByQuery( SmsPushEventUser eventUser = eventUserMapper.selectOneByQuery(
new QueryWrapper().eq(SmsPushEventUser::getEventId, eventId) new QueryWrapper()
.eq(SmsPushEventUser::getType, "sms")
.eq(SmsPushEventUser::getEventId, eventId)
); );
pushEvent.setSmsPushEventUser(eventUser); pushEvent.setSmsPushEventUser(eventUser);
if (StrUtil.isNotBlank(pushEvent.getCoupon())) { if (StrUtil.isNotBlank(pushEvent.getCoupon())) {