From 91f5537b351fa2880e14368c38c6e743257907d4 Mon Sep 17 00:00:00 2001 From: lijingtao <18301674552@163.COM> Date: Sun, 17 Mar 2024 16:59:06 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=8E=A5=E5=8F=A3=E6=B8=85?= =?UTF-8?q?=E9=99=A4=20=20=E4=BF=AE=E6=94=B9bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ocr/controller/OcrMsgReadController.java | 29 ++++++++++++------- 1 file changed, 18 insertions(+), 11 deletions(-) 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 3d2fc7db..da169420 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 @@ -112,12 +112,13 @@ public class OcrMsgReadController { QueryWrapper wrapperlist = new QueryWrapper<>(); wrapperlist.select("id").eq("msg_category",msgCategory).eq("send_status","1").apply(" FIND_IN_SET('"+userToken.getUserid()+"',receive_user_ids)"); - QueryWrapper wrapperone = new QueryWrapper<>(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSSS"); List list = iocrmsgservice.list(wrapperlist); for (OcrMsg msg:list){ + QueryWrapper wrapperone = new QueryWrapper<>(); wrapperone.eq("msg_id", msg.getId()).eq("user_id",userToken.getUserid()); OcrMsgRead one = ocrMsgReadService.getOne(wrapperone); if(null==one) { @@ -144,18 +145,24 @@ public class OcrMsgReadController { SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSSS"); + QueryWrapper wrapperone = new QueryWrapper<>(); + wrapperone.eq("msg_id", msgid).eq("user_id",userToken.getUserid()); + OcrMsgRead one = ocrMsgReadService.getOne(wrapperone); + if(null==one) { + OcrMsgRead ocrmsgread=new OcrMsgRead(); + ocrmsgread.setId(Long.valueOf(sdf.format(System.currentTimeMillis()))); + ocrmsgread.setMsgId(Long.valueOf(msgid)); + ocrmsgread.setUserId(Long.valueOf(userToken.getUserid())); + ocrmsgread.setReadFlag(1); + ocrmsgread.setReadTime(System.currentTimeMillis()); + + ocrMsgReadService.save(ocrmsgread); + return ResultVoUtil.success(ResultVo.SUCCESS); + } - OcrMsgRead ocrmsgread=new OcrMsgRead(); - ocrmsgread.setId(Long.valueOf(sdf.format(System.currentTimeMillis()))); - ocrmsgread.setMsgId(Long.valueOf(msgid)); - ocrmsgread.setUserId(Long.valueOf(userToken.getUserid())); - ocrmsgread.setReadFlag(1); - ocrmsgread.setReadTime(System.currentTimeMillis()); - boolean save = ocrMsgReadService.save(ocrmsgread); - //此处需要手工处理 返回需要将修改后的数据返回 -// return new ResponseEntity(save,HttpStatus.OK); - return ResultVoUtil.success(save); + + return ResultVoUtil.success(ResultVo.SUCCESS); } }