diff --git a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/controller/OcrMsgReadController.java b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/controller/OcrMsgReadController.java index aeb31714..3fbb42c1 100644 --- a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/controller/OcrMsgReadController.java +++ b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/controller/OcrMsgReadController.java @@ -1,5 +1,6 @@ package cn.jyjz.xiaoyao.ocr.controller; +import cn.hutool.core.bean.BeanUtil; import cn.jyjz.xiaoyao.common.base.service.UserTokenService; import cn.jyjz.xiaoyao.common.base.util.RequestBaseUtil; import cn.jyjz.xiaoyao.common.base.vo.ResultVo; @@ -9,6 +10,7 @@ import cn.jyjz.xiaoyao.ocr.dataobject.OcrMsg; import cn.jyjz.xiaoyao.ocr.dataobject.OcrMsgRead; import cn.jyjz.xiaoyao.ocr.service.IOcrMsgService; import cn.jyjz.xiaoyao.ocr.util.PageRequest; +import cn.jyjz.xiaoyao.ocr.vo.OcrMsgVO; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.pagehelper.PageInfo; import io.swagger.annotations.ApiOperation; @@ -69,7 +71,8 @@ public class OcrMsgReadController { pageQuery.setPageSize(pageSize); - PageInfo>> findPage = iocrmsgservice.selectPage(pageQuery,userToken.getUserid(),msgCategory); + PageInfo findPage = iocrmsgservice.selectPage(pageQuery,userToken.getUserid(),msgCategory); + //执行查询方法 // return new ResponseEntity(findPage, HttpStatus.OK); @@ -121,9 +124,9 @@ public class OcrMsgReadController { UserToken userToken = this.userTokenService.getUserToken(RequestBaseUtil.getToken(request)); QueryWrapper wrapperlist = new QueryWrapper<>(); - wrapperlist.select("id").eq("msg_category",msgCategory).eq("send_status","1").apply(" FIND_IN_SET('"+userToken.getUserid()+"',receive_user_ids)"); - - + wrapperlist.select("id").eq("msg_category",msgCategory).eq("send_status","1").and(wrapper->{ + wrapper.eq("receive_user_type",2).or().apply(" FIND_IN_SET('"+userToken.getUserid()+"',receive_user_ids)"); + }); SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSSS"); diff --git a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/dataDao/OcrMsgMapper.java b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/dataDao/OcrMsgMapper.java index 375546e5..435805b0 100644 --- a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/dataDao/OcrMsgMapper.java +++ b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/dataDao/OcrMsgMapper.java @@ -19,7 +19,7 @@ import java.util.Map; */ @Mapper public interface OcrMsgMapper extends BaseMapper { - List>> selectPage(@Param("userid")String userid,@Param("msgCategory")String msgCategory); + List> selectPage(@Param("userid")String userid,@Param("msgCategory")String msgCategory); Map selectone(@Param("id")String id); diff --git a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/IOcrMsgService.java b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/IOcrMsgService.java index f119ee2f..af71ee7e 100644 --- a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/IOcrMsgService.java +++ b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/IOcrMsgService.java @@ -2,6 +2,7 @@ package cn.jyjz.xiaoyao.ocr.service; import cn.jyjz.xiaoyao.ocr.dataobject.OcrMsg; +import cn.jyjz.xiaoyao.ocr.vo.OcrMsgVO; import com.baomidou.mybatisplus.extension.service.IService; import com.github.pagehelper.PageInfo; import cn.jyjz.xiaoyao.ocr.util.PageRequest; @@ -28,7 +29,7 @@ public interface IOcrMsgService extends IService { * @param pageRequest 自定义,统一分页查询请求 * @return PageResult 自定义,统一分页查询结果 */ - PageInfo>> selectPage(PageRequest pageRequest,String userid, String msgCategory); + PageInfo selectPage(PageRequest pageRequest, String userid, String msgCategory); Map selectone(String id); diff --git a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/impl/OcrMsgServiceImpl.java b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/impl/OcrMsgServiceImpl.java index 3869630b..e0a5da53 100644 --- a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/impl/OcrMsgServiceImpl.java +++ b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/impl/OcrMsgServiceImpl.java @@ -1,8 +1,10 @@ package cn.jyjz.xiaoyao.ocr.service.impl; +import cn.hutool.core.bean.BeanUtil; import cn.jyjz.xiaoyao.ocr.dataDao.OcrMsgMapper; import cn.jyjz.xiaoyao.ocr.dataobject.OcrMsg; import cn.jyjz.xiaoyao.ocr.service.IOcrMsgService; +import cn.jyjz.xiaoyao.ocr.vo.OcrMsgVO; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import cn.jyjz.xiaoyao.ocr.util.PageRequest; import com.github.pagehelper.PageHelper; @@ -30,12 +32,13 @@ public class OcrMsgServiceImpl extends ServiceImpl impleme @Override - public PageInfo>> selectPage(PageRequest pageRequest,String userid, String msgCategory) { + public PageInfo selectPage(PageRequest pageRequest,String userid, String msgCategory) { int pageNum = pageRequest.getPageNum(); int pageSize = pageRequest.getPageSize(); PageHelper.startPage(pageNum, pageSize); - List>> selectPage = ocrmsgmapper.selectPage(userid,msgCategory); - return new PageInfo>>(selectPage); + List> selectPage = ocrmsgmapper.selectPage(userid,msgCategory); + List resultList= BeanUtil.copyToList(selectPage, OcrMsgVO.class); + return new PageInfo<>(resultList); } @Override diff --git a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/vo/OcrMsgVO.java b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/vo/OcrMsgVO.java new file mode 100644 index 00000000..7f689563 --- /dev/null +++ b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/vo/OcrMsgVO.java @@ -0,0 +1,39 @@ +package cn.jyjz.xiaoyao.ocr.vo; + +import lombok.Data; + +/** + * 消息返回实体对象 + * + * @author hugh(shuli.yao) 1397940314@qq.com + * @version 1.0 + * @date 2024/3/24 21:16 + */ +@Data +public class OcrMsgVO { + /** + * 消息id + */ + private String id; + + /** + * 业务json + */ + private String busJson; + + /** + * 发送人名称 + */ + private String userName; + + /** + * 发送时间戳 + */ + private Long sendTime; + + /** + * 是否已读 1以读 0或空未读 + */ + private Integer readFlag; + +} diff --git a/jyjz-system/jyjz-system-oa/src/main/resources/mapper/oa/OcrMsgMapper.xml b/jyjz-system/jyjz-system-oa/src/main/resources/mapper/oa/OcrMsgMapper.xml index 7704c6d5..48ad265d 100644 --- a/jyjz-system/jyjz-system-oa/src/main/resources/mapper/oa/OcrMsgMapper.xml +++ b/jyjz-system/jyjz-system-oa/src/main/resources/mapper/oa/OcrMsgMapper.xml @@ -29,45 +29,20 @@