|
@@ -32,7 +32,7 @@ public class VipUserStream extends StreamConsumer<VipUserParam> {
|
|
|
public void accept(VipUserParam vipUserParam) {
|
|
|
log.info("收到会员套餐消息:{}",vipUserParam);
|
|
|
|
|
|
- VipUserRecord existsRecord = vipUserRecordDao.findTop1ByCpIdOrderByOperateTime(vipUserParam.getCpId());
|
|
|
+ VipUserRecord existsRecord = vipUserRecordDao.findTop1ByCpIdOrderByCreateTimeDesc(vipUserParam.getCpId());
|
|
|
if (ObjectUtils.isNotEmpty(existsRecord) && vipUserParam.getPlanningId().equals(existsRecord.getPlanningId()) && Objects.equals(vipUserParam.getSuc(), existsRecord.getSuc())){
|
|
|
log.info("重复订阅消息");
|
|
|
return;
|