|
@@ -97,34 +97,34 @@ public class RepalRemindReadInfoServiceImpl extends ServiceImpl<RepalRemindReadI
|
|
|
* 风险预警 逾期动态 财产提醒 由于是每天跑调度,一天更新一次即可
|
|
|
* 评级变更 10s更新一次
|
|
|
* @param userId
|
|
|
- * @param trendType
|
|
|
+ * @param remindType
|
|
|
*/
|
|
|
@Override
|
|
|
- public void updateReadInfoByUserId(Long userId, String trendType,Long repalBillId,Long repalBookId) {
|
|
|
- String redisKey = MESSAGE_PRIFIX+userId+"_"+trendType+"_"+repalBookId+"_"+repalBillId;
|
|
|
+ public void updateReadInfoByUserId(Long userId, String remindType,Long repalBillId,Long repalBookId) {
|
|
|
+ String redisKey = MESSAGE_PRIFIX+userId+"_"+remindType+"_"+repalBookId+"_"+repalBillId;
|
|
|
if(redisUtil.get(redisKey) != null){
|
|
|
return;
|
|
|
}
|
|
|
RepalRemindReadInfo repalRemindReadInfo = getReadInfoByUserId(userId,repalBillId,repalBookId);
|
|
|
RepalRemindHistory repalRemindHistory = repalRemindHistoryService.getOne(Wrappers.lambdaQuery(RepalRemindHistory.class)
|
|
|
.eq(RepalRemindHistory::getRepalBillId,repalBillId)
|
|
|
- .eq(RepalRemindHistory::getTrentType, trendType)
|
|
|
+ .eq(RepalRemindHistory::getRemindType, remindType)
|
|
|
.orderByDesc(RepalRemindHistory::getId)
|
|
|
.last(" LIMIT 1 "),false);
|
|
|
if(ObjectUtil.isNotNull(repalRemindHistory)){
|
|
|
- if(RemindEnum.账款评级.getCode().equals(trendType)){
|
|
|
+ if(RemindEnum.账款评级.getCode().equals(remindType)){
|
|
|
repalRemindReadInfo.setRankRemindId(repalRemindHistory.getId());
|
|
|
updateById(repalRemindReadInfo);
|
|
|
redisUtil.setEx(redisKey,"1",10, TimeUnit.SECONDS);
|
|
|
- }else if(RemindEnum.风险预警.getCode().equals(trendType)){
|
|
|
+ }else if(RemindEnum.风险预警.getCode().equals(remindType)){
|
|
|
repalRemindReadInfo.setRiskRemindId(repalRemindHistory.getId());
|
|
|
updateById(repalRemindReadInfo);
|
|
|
redisUtil.setEx(redisKey,"1",calTTL(), TimeUnit.MILLISECONDS);
|
|
|
- }else if(RemindEnum.财产线索.getCode().equals(trendType)){
|
|
|
+ }else if(RemindEnum.财产线索.getCode().equals(remindType)){
|
|
|
repalRemindReadInfo.setFinanceRemindId(repalRemindHistory.getId());
|
|
|
updateById(repalRemindReadInfo);
|
|
|
redisUtil.setEx(redisKey,"1",calTTL(), TimeUnit.MILLISECONDS);
|
|
|
- }else if(RemindEnum.逾期提醒.getCode().equals(trendType)){
|
|
|
+ }else if(RemindEnum.逾期提醒.getCode().equals(remindType)){
|
|
|
repalRemindReadInfo.setOverdueRemindId(repalRemindHistory.getId());
|
|
|
updateById(repalRemindReadInfo);
|
|
|
redisUtil.setEx(redisKey,"1",calTTL(), TimeUnit.MILLISECONDS);
|