消息全部已读

business-service/src/main/java/com/ozs/service/mapper/MsgWebPushMapper.java

@@ -25,4 +25,6 @@ public interface MsgWebPushMapper extends BaseMapper<MsgWebPush> {
     Map<String, Integer> messageMoreNum(@Param("userId") String userId);
 
     int updateByPushId(MsgWebPush msgWebPush);
+
+    int readAll(@Param("userId") String userId);
 }

business-service/src/main/java/com/ozs/service/service/MsgWebPushService.java

@@ -22,4 +22,6 @@ public interface MsgWebPushService extends IService<MsgWebPush> {
     IPage<MsgAlarm> messageMore(MsgAlarmVo msgAlarmVo);
 
     Map<String, Integer> messageMoreNum(String userId);
+
+    int readAll(String userId);
 }

business-service/src/main/java/com/ozs/service/service/impl/MsgWebPushServiceImpl.java

@@ -129,4 +129,9 @@ public class MsgWebPushServiceImpl extends ServiceImpl<MsgWebPushMapper, MsgWebP
         Map<String, Integer> map = msgWebPushMapper.messageMoreNum(userId);
         return map;
     }
+
+    @Override
+    public int readAll(String userId) {
+        return msgWebPushMapper.readAll(userId);
+    }
 }

business-service/src/main/resources/mapper/service/MsgWebPushMapper.xml

@@ -74,4 +74,12 @@
         </set>
         where push_id = #{pushId}
     </update>
+
+    <update id="readAll" parameterType="java.lang.String">
+        update msg_web_push
+        <set>
+            status = 2
+        </set>
+        where receive_by = #{userId} and status = 1
+    </update>
 </mapper>

hazard-admin/src/main/java/com/ozs/web/controller/accountmanagment/MsgAlarmController.java

@@ -129,6 +129,16 @@ public class MsgAlarmController extends BaseController {
         return AjaxResult.success(webAlarm);
     }
 
+    /**
+     * web消息全部已读
+     */
+    @PostMapping("/readAll")
+    @ApiOperation(value = "web消息全部已读")
+    @Log(title = "报警信息管理", businessType = BusinessType.SELECT)
+    public AjaxResult readAll() {
+        return toAjax(msgWebPushService.readAll(getUserId()));
+    }
+
     /**
      * web消息已读
      */