hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-11 03:46:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

清空添加事务

Browse Source
This commit is contained in:
Guava
2023-07-03 14:18:52 +08:00
parent e9d82eafda
commit 38e18b7d37
1 changed files with 47 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

93
servers/boe-server-all/src/main/java/com/xboe/system/user/service/impl/MessageServiceImpl.java
View File

@@ -21,8 +21,8 @@ import java.util.List;
import java.util.Map; import java.util.Map;
/** /**
* 消息 * 消息
* */ */
@Service @Service
public class MessageServiceImpl implements IMessageService { public class MessageServiceImpl implements IMessageService {
@@ -38,9 +38,9 @@ public class MessageServiceImpl implements IMessageService {
builder.addOrder(OrderCondition.desc("id")); builder.addOrder(OrderCondition.desc("id"));
builder.setPageIndex(pageIndex); builder.setPageIndex(pageIndex);
builder.setPageSize(pageSize); builder.setPageSize(pageSize);
builder.addFilter(FieldFilters.eq("acceptId",aid)); builder.addFilter(FieldFilters.eq("acceptId", aid));
if(isRead!=null){ if (isRead != null) {
builder.addFilter(FieldFilters.eq("isRead",isRead)); builder.addFilter(FieldFilters.eq("isRead", isRead));
} }
PageList<Message> list = dao.findPage(builder.builder()); PageList<Message> list = dao.findPage(builder.builder());
return list; return list;
@@ -52,12 +52,12 @@ public class MessageServiceImpl implements IMessageService {
builder.addOrder(OrderCondition.desc("id")); builder.addOrder(OrderCondition.desc("id"));
builder.setPageIndex(pageIndex); builder.setPageIndex(pageIndex);
builder.setPageSize(pageSize); builder.setPageSize(pageSize);
builder.addFilter(FieldFilters.eq("acceptId",aid)); builder.addFilter(FieldFilters.eq("acceptId", aid));
builder.addFilter(FieldFilters.ne("refType","3")); builder.addFilter(FieldFilters.ne("refType", "3"));
builder.addFilter(FieldFilters.ne("refType","6")); builder.addFilter(FieldFilters.ne("refType", "6"));
// builder.addFilter(FieldFilters.ne("refType","3", FilterCheckValue.NONE)); // builder.addFilter(FieldFilters.ne("refType","3", FilterCheckValue.NONE));
if(isRead!=null){ if (isRead != null) {
builder.addFilter(FieldFilters.eq("isRead",isRead)); builder.addFilter(FieldFilters.eq("isRead", isRead));
} }
PageList<Message> list = dao.findPage(builder.builder()); PageList<Message> list = dao.findPage(builder.builder());
return list; return list;
@@ -66,21 +66,21 @@ public class MessageServiceImpl implements IMessageService {
@Override @Override
@Transactional @Transactional
public void delete(List<String> ids) { public void delete(List<String> ids) {
dao.deleteByFilter(FieldFilters.in("id",ids)); dao.deleteByFilter(FieldFilters.in("id", ids));
} }
@Override @Override
@Transactional @Transactional
public Message detail(String id) { public Message detail(String id) {
Message message = dao.get(id); Message message = dao.get(id);
if(!message.getIsRead()){ if (!message.getIsRead()) {
dao.updateFieldById(id,"isRead",true); dao.updateFieldById(id, "isRead", true);
if("99".equals(message.getRefType())){ if ("99".equals(message.getRefType())) {
casesRecommendPushRecordDao.update(UpdateBuilder.from(CasesRecommendPushRecord.class) casesRecommendPushRecordDao.update(UpdateBuilder.from(CasesRecommendPushRecord.class)
.addUpdateField("readFlag",1) .addUpdateField("readFlag", 1)
.addUpdateField("readStartTime",new Date()) .addUpdateField("readStartTime", new Date())
.addFilter(FieldFilters.eq("id",message.getRefId())) .addFilter(FieldFilters.eq("id", message.getRefId()))
.builder()); .builder());
} }
} }
@@ -96,8 +96,8 @@ public class MessageServiceImpl implements IMessageService {
@Override @Override
public Integer isRead(String aid) { public Integer isRead(String aid) {
QueryBuilder builder = QueryBuilder.from(Message.class); QueryBuilder builder = QueryBuilder.from(Message.class);
builder.addFilter(FieldFilters.eq("isRead",false)); builder.addFilter(FieldFilters.eq("isRead", false));
builder.addFilter(FieldFilters.eq("acceptId",aid)); builder.addFilter(FieldFilters.eq("acceptId", aid));
PageList<Message> page = dao.findPage(builder.builder()); PageList<Message> page = dao.findPage(builder.builder());
return page.getCount(); return page.getCount();
} }
@@ -105,23 +105,23 @@ public class MessageServiceImpl implements IMessageService {
@Override @Override
@Transactional @Transactional
public void updateIsRead(List<String> ids) { public void updateIsRead(List<String> ids) {
if(CollectionUtils.isEmpty(ids)){ if (CollectionUtils.isEmpty(ids)) {
return; return;
} }
//更新最后读时间 //更新最后读时间
for (String id:ids){ for (String id : ids) {
Message message = dao.get(id); Message message = dao.get(id);
if("99".equals(message.getRefType())){ if ("99".equals(message.getRefType())) {
casesRecommendPushRecordDao.update(UpdateBuilder.from(CasesRecommendPushRecord.class) casesRecommendPushRecordDao.update(UpdateBuilder.from(CasesRecommendPushRecord.class)
.addUpdateField("readEndTime",new Date()) .addUpdateField("readEndTime", new Date())
.addFilter(FieldFilters.eq("id",message.getRefId())) .addFilter(FieldFilters.eq("id", message.getRefId()))
.builder()); .builder());
} }
} }
dao.update(UpdateBuilder.from(Message.class) dao.update(UpdateBuilder.from(Message.class)
.addUpdateField("isRead",true) .addUpdateField("isRead", true)
.addFilter(FieldFilters.in("id",ids)) .addFilter(FieldFilters.in("id", ids))
.builder()); .builder());
} }
@@ -130,52 +130,53 @@ public class MessageServiceImpl implements IMessageService {
public Map<String, Object> messGroup(String aid) { public Map<String, Object> messGroup(String aid) {
Map<String, Object> map = new HashMap<>(); Map<String, Object> map = new HashMap<>();
QueryBuilder builder = QueryBuilder.from(Message.class); QueryBuilder builder = QueryBuilder.from(Message.class);
builder.addFilter(FieldFilters.eq("acceptId",aid)); builder.addFilter(FieldFilters.eq("acceptId", aid));
builder.addGroupBy("acceptId"); builder.addGroupBy("acceptId");
List<Message> list = dao.findList(builder.builder()); List<Message> list = dao.findList(builder.builder());
map.put("mess",list); map.put("mess", list);
//在查出未读消息数 //在查出未读消息数
String sql="select count(1) from boe_message where is_read=false and acceptId=?1"; String sql = "select count(1) from boe_message where is_read=false and acceptId=?1";
int count = dao.sqlCount(sql, aid); int count = dao.sqlCount(sql, aid);
map.put("count",count); map.put("count", count);
return map; return map;
} }
@Override @Override
@Transactional @Transactional
public void remove(String aid) { public void remove(String aid) {
dao.deleteByFilter(FieldFilters.eq("acceptId",aid)); dao.deleteByFilter(FieldFilters.eq("acceptId", aid));
} }
@Override @Override
public List<Message> userMess(String aid) { public List<Message> userMess(String aid) {
QueryBuilder builder = QueryBuilder.from(Message.class); QueryBuilder builder = QueryBuilder.from(Message.class);
builder.addFilter(FieldFilters.eq("acceptId",aid)); builder.addFilter(FieldFilters.eq("acceptId", aid));
builder.addGroupBy("acceptId"); builder.addGroupBy("acceptId");
builder.addOrder(OrderCondition.desc("msgTime")); builder.addOrder(OrderCondition.desc("msgTime"));
List<Message> list = dao.findList(builder.builder()); List<Message> list = dao.findList(builder.builder());
return list; return list;
} }
@Override @Override
@Transactional @Transactional
public void setReadByAcceptId(String aid) { public void setReadByAcceptId(String aid) {
dao.update("Update "+Message.class.getSimpleName()+" set isRead=?1 where acceptId=?2 and isRead=?3", true,aid,false); dao.update("Update " + Message.class.getSimpleName() + " set isRead=?1 where acceptId=?2 and isRead=?3", true, aid, false);
} }
@Override @Override
public void cleanByAcceptId(String aid) { @Transactional
dao.deleteByField("acceptId", aid); public void cleanByAcceptId(String aid) {
dao.deleteByField("acceptId", aid);
} }
@Override @Override
@Transactional @Transactional
public void batchSave(List<Message> list) { public void batchSave(List<Message> list) {
// for(Message msg : list) { // for(Message msg : list) {
// //
// } // }
dao.saveList(list); dao.saveList(list);
} }
} }