zt/platform
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化

Browse Source
This commit is contained in:
zt
2025-03-20 16:57:49 +08:00
parent 21ded5ae19
commit 8476158fc1
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
ruoyi-system/src/main/java/com/ruoyi/bgt/service/impl/BgtMessageServiceImpl.java
View File

@ -1,9 +1,9 @@
package com.ruoyi.bgt.service.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.bgt.bo.BgtMessageQueryBo;
@ -47,7 +47,6 @@ import java.util.Map;
import java.util.stream.Collectors;
import static com.ruoyi.common.constants.BgtMessageConstant.*;
import static com.ruoyi.common.constants.WgzAndBgtMessageConstant.OPERATION_ALREADY;
import static com.ruoyi.common.constants.WgzAndBgtMessageConstant.OPERATION_NEED;
/**
@ -268,17 +267,14 @@ public class BgtMessageServiceImpl extends ServicePlusImpl<BgtMessageMapper, Bgt
@Override
@Async
public void operation(String senderType,Long senderId,String recipientType,Long recipientId,Long tableId,String tableName) {
LambdaQueryWrapper<BgtMessage> wrapper = new LambdaQueryWrapper<>();
LambdaUpdateWrapper<BgtMessage> wrapper = new LambdaUpdateWrapper<>();
wrapper.eq(BgtMessage::getRecipientId, recipientId);
wrapper.eq(BgtMessage::getRecipientType, recipientType);
wrapper.eq(BgtMessage::getSenderId, senderId);
wrapper.eq(BgtMessage::getSenderType, senderType);
wrapper.eq(BgtMessage::getTableId, tableId);
wrapper.eq(BgtMessage::getTableName, tableName);
List<BgtMessage> list = list(wrapper);
if (CollUtil.isNotEmpty(list)) {
lambdaUpdate().in(BgtMessage::getId, list.stream().map(BgtMessage::getId).collect(Collectors.toList()))
.set(BgtMessage::getIsOperation, OPERATION_ALREADY).update();
}
wrapper.set(BgtMessage::getIsOperation, OPERATION_NEED);
update(wrapper);
}
}