消息管理

mallplus-portal/src/main/java/com/zscat/mallplus/apirest/SysMessageRest.java

@@ -0,0 +1,66 @@
+package com.zscat.mallplus.apirest;
+
+import com.zscat.mallplus.oms.entity.OmsCartItem;
+import com.zscat.mallplus.ums.entity.SysMessage;
+import com.zscat.mallplus.ums.entity.UmsMember;
+import com.zscat.mallplus.ums.service.ISysMessageService;
+import com.zscat.mallplus.ums.service.IUmsMemberService;
+import com.zscat.mallplus.utils.CommonResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@Api(tags = "SysMessageRest", description = "系统消息")
+@RequestMapping("/api/sys/message")
+public class SysMessageRest {
+
+    @Autowired
+    private IUmsMemberService memberService;
+
+    @Autowired
+    private ISysMessageService messageService;
+
+    @ApiOperation("获取某个会员的消息列表")
+    @RequestMapping(value = "/list", method = RequestMethod.GET)
+    @ResponseBody
+    public Object list() {
+        UmsMember umsMember = memberService.getNewCurrentMember();
+        List<SysMessage> list = new ArrayList<>();
+        if (umsMember != null && umsMember.getId() != null) {
+            list = messageService.listByUserId(umsMember.getId());
+            return new CommonResult().success(list);
+        }
+        return new CommonResult().success(list);
+    }
+
+    @ApiOperation("获取消息内容")
+    @RequestMapping(value = "/info", method = RequestMethod.GET)
+    @ResponseBody
+    public Object info(@RequestParam(value = "id", required = false, defaultValue = "0") Long id) {
+        SysMessage mes = messageService.getById(id);
+        if (mes != null && !mes.getStatus()) {
+            mes.setStatus(true);
+            messageService.updateStatus(mes);
+        }
+        return new CommonResult().success(mes);
+    }
+
+    @ApiOperation("更新")
+    @RequestMapping(value = "/updateStatus", method = RequestMethod.POST)
+    @ResponseBody
+    public Object updateStatus(@RequestBody SysMessage sysMessage) {
+        int count = messageService.updateStatus(sysMessage);
+        if (count > 0) {
+            return new CommonResult().success(count);
+        }
+        return new CommonResult().failed();
+    }
+}

mallplus-portal/src/main/java/com/zscat/mallplus/ums/service/ISysMessageService.java

@@ -3,6 +3,8 @@ package com.zscat.mallplus.ums.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.zscat.mallplus.ums.entity.SysMessage;
 
+import java.util.List;
+
 /**
  * <p>
  * 站内信 服务类
@@ -13,4 +15,7 @@ import com.zscat.mallplus.ums.entity.SysMessage;
  */
 public interface ISysMessageService extends IService<SysMessage> {
 
+    List<SysMessage> listByUserId(Long userId);
+
+    int updateStatus(SysMessage sysMessage);
 }

mallplus-portal/src/main/java/com/zscat/mallplus/ums/service/impl/SysMessageServiceImpl.java

@@ -1,11 +1,14 @@
 package com.zscat.mallplus.ums.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.zscat.mallplus.ums.entity.SysMessage;
 import com.zscat.mallplus.ums.mapper.SysMessageMapper;
 import com.zscat.mallplus.ums.service.ISysMessageService;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 站内信 服务实现类
@@ -17,4 +20,18 @@ import org.springframework.stereotype.Service;
 @Service
 public class SysMessageServiceImpl extends ServiceImpl<SysMessageMapper, SysMessage> implements ISysMessageService {
 
+    @Override
+    public List<SysMessage> listByUserId(Long userId) {
+        QueryWrapper<SysMessage> qw = new QueryWrapper<>();
+        qw.eq("user_id", userId);
+        qw.orderByDesc("ctime");
+        return baseMapper.selectList(qw);
+    }
+
+    @Override
+    public int updateStatus(SysMessage sysMessage) {
+        sysMessage.setUtime(System.currentTimeMillis());
+        baseMapper.updateById(sysMessage);
+        return 1;
+    }
 }