|
|
|
@ -226,6 +226,104 @@ public class MessageCenterServiceImpl extends ServiceImpl<MessageCenterMapper, M
|
|
|
|
|
return this.updateById(entity);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public List<MessageCenterEntity> getMobileList(MessageCenterPagination messageCenterPagination) {
|
|
|
|
|
String userId = userProvider.get().getUserId();
|
|
|
|
|
List<String> AllIdList = new ArrayList();
|
|
|
|
|
int total = 0;
|
|
|
|
|
int messageCenterNum = 0;
|
|
|
|
|
QueryWrapper<MessageCenterEntity> messageCenterQueryWrapper = new QueryWrapper<>();
|
|
|
|
|
boolean pcPermission = true;
|
|
|
|
|
boolean appPermission = true;
|
|
|
|
|
boolean isPc = ServletUtil.getHeader("jnpf-origin").equals("pc");
|
|
|
|
|
if (isPc && pcPermission) {
|
|
|
|
|
if (!userProvider.get().getIsAdministrator()) {
|
|
|
|
|
Object messageCenterObj = authorizeService.getCondition(new AuthorizeConditionModel(messageCenterQueryWrapper, messageCenterPagination.getMenuId(), "jg_material"));
|
|
|
|
|
if (ObjectUtil.isEmpty(messageCenterObj)) {
|
|
|
|
|
return new ArrayList<>();
|
|
|
|
|
} else {
|
|
|
|
|
messageCenterQueryWrapper = (QueryWrapper<MessageCenterEntity>) messageCenterObj;
|
|
|
|
|
messageCenterNum++;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (!isPc && appPermission) {
|
|
|
|
|
if (!userProvider.get().getIsAdministrator()) {
|
|
|
|
|
Object messageCenterObj = authorizeService.getCondition(new AuthorizeConditionModel(messageCenterQueryWrapper, messageCenterPagination.getMenuId(), "jg_material"));
|
|
|
|
|
if (ObjectUtil.isEmpty(messageCenterObj)) {
|
|
|
|
|
return new ArrayList<>();
|
|
|
|
|
} else {
|
|
|
|
|
messageCenterQueryWrapper = (QueryWrapper<MessageCenterEntity>) messageCenterObj;
|
|
|
|
|
messageCenterNum++;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (StringUtil.isNotEmpty(messageCenterPagination.getTitle())) {
|
|
|
|
|
messageCenterNum++;
|
|
|
|
|
messageCenterQueryWrapper.lambda().like(MessageCenterEntity::getTitle, messageCenterPagination.getTitle());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (StringUtil.isNotEmpty(messageCenterPagination.getHead())) {
|
|
|
|
|
messageCenterNum++;
|
|
|
|
|
messageCenterQueryWrapper.lambda().like(MessageCenterEntity::getHead, messageCenterPagination.getHead());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (StringUtil.isNotEmpty(messageCenterPagination.getIsRead())) {
|
|
|
|
|
messageCenterNum++;
|
|
|
|
|
messageCenterQueryWrapper.lambda().eq(MessageCenterEntity::getIsRead, messageCenterPagination.getIsRead());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (StringUtil.isNotEmpty(messageCenterPagination.getContext())) {
|
|
|
|
|
messageCenterNum++;
|
|
|
|
|
messageCenterQueryWrapper.lambda().like(MessageCenterEntity::getContext, messageCenterPagination.getContext());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (AllIdList.size() > 0) {
|
|
|
|
|
messageCenterQueryWrapper.lambda().in(MessageCenterEntity::getId, AllIdList);
|
|
|
|
|
}
|
|
|
|
|
//排序
|
|
|
|
|
if (StringUtil.isEmpty(messageCenterPagination.getSidx())) {
|
|
|
|
|
messageCenterQueryWrapper.lambda().orderByDesc(MessageCenterEntity::getId);
|
|
|
|
|
} else {
|
|
|
|
|
try {
|
|
|
|
|
String sidx = messageCenterPagination.getSidx();
|
|
|
|
|
MessageCenterEntity messageCenterEntity = new MessageCenterEntity();
|
|
|
|
|
Field declaredField = messageCenterEntity.getClass().getDeclaredField(sidx);
|
|
|
|
|
declaredField.setAccessible(true);
|
|
|
|
|
String value = declaredField.getAnnotation(TableField.class).value();
|
|
|
|
|
messageCenterQueryWrapper = "asc".equals(messageCenterPagination.getSort().toLowerCase()) ? messageCenterQueryWrapper.orderByAsc(value) : messageCenterQueryWrapper.orderByDesc(value);
|
|
|
|
|
} catch (NoSuchFieldException e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if ((total > 0 && AllIdList.size() > 0) || total == 0) {
|
|
|
|
|
Page<MessageCenterEntity> page = new Page<>(messageCenterPagination.getCurrentPage(), messageCenterPagination.getPageSize());
|
|
|
|
|
messageCenterQueryWrapper.lambda().eq(MessageCenterEntity::getIsRead,"0");
|
|
|
|
|
messageCenterQueryWrapper.orderByDesc("CREATOR_TIME");
|
|
|
|
|
IPage<MessageCenterEntity> userIPage = this.page(page, messageCenterQueryWrapper);
|
|
|
|
|
return messageCenterPagination.setData(userIPage.getRecords(), userIPage.getTotal());
|
|
|
|
|
} else {
|
|
|
|
|
List<MessageCenterEntity> list = new ArrayList();
|
|
|
|
|
return messageCenterPagination.setData(list, list.size());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void idRead(List<String> id) {
|
|
|
|
|
QueryWrapper<MessageCenterEntity> messageCenterQueryWrapper = new QueryWrapper<>();
|
|
|
|
|
messageCenterQueryWrapper.lambda().eq(MessageCenterEntity::getIsRead,"0");
|
|
|
|
|
messageCenterQueryWrapper.lambda().in(MessageCenterEntity::getId,id);
|
|
|
|
|
MessageCenterEntity messageCenterEntity = new MessageCenterEntity();
|
|
|
|
|
messageCenterEntity.setIsRead("1");
|
|
|
|
|
boolean update = this.update(messageCenterEntity,messageCenterQueryWrapper);
|
|
|
|
|
if (update){
|
|
|
|
|
log.warn("更新成功!");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public void delete(MessageCenterEntity entity) {
|
|
|
|
|
if (entity != null) {
|
|
|
|
|