Explorar o código

新增平台端查看消息记录接口

qrs hai 3 meses
pai
achega
ddb844885f

+ 1 - 0
alien-entity/src/main/resources/mapper/PlatformLifeUserMapper.xml

@@ -23,6 +23,7 @@
         user.user_name,
         user.real_name,
         user.user_phone,
+        concat('user_', user.user_phone) phoneId,
         user.created_time,
         ifnull(orders.consume_num, 0) consume_num,
         ifnull(orders.consume_price, 0) consume_price,

+ 32 - 0
alien-store/src/main/java/shop/alien/store/controller/PlatformLifeMessageController.java

@@ -0,0 +1,32 @@
+package shop.alien.store.controller;
+
+import io.swagger.annotations.*;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+import shop.alien.entity.result.R;
+import shop.alien.entity.store.vo.LifeMessageVo;
+import shop.alien.store.service.PlatformLifeMessageService;
+
+import java.util.List;
+
+@Api(tags = {"平台-消息管理"})
+@Slf4j
+@RestController
+@CrossOrigin
+@RequestMapping("/platformLifeMessage")
+@RequiredArgsConstructor
+public class PlatformLifeMessageController {
+
+    private final PlatformLifeMessageService lifeMessageService;
+
+    @ApiOperation("消息列表")
+    @ApiOperationSupport(order = 1)
+    @ApiImplicitParams({@ApiImplicitParam(name = "receiverId", value = "用户phoneId", dataType = "String", paramType = "query")})
+    @GetMapping("/getMessageList")
+    public R<List<LifeMessageVo>> getMessageList(@RequestParam String receiverId) throws Exception {
+        log.info("LifeMessageController.getMessageList?receiverId={}", receiverId);
+        return R.data(lifeMessageService.getMessageList(receiverId));
+    }
+
+}

+ 11 - 0
alien-store/src/main/java/shop/alien/store/service/PlatformLifeMessageService.java

@@ -0,0 +1,11 @@
+package shop.alien.store.service;
+
+import org.springframework.web.bind.annotation.RequestParam;
+import shop.alien.entity.store.vo.LifeMessageVo;
+
+import java.util.List;
+
+public interface PlatformLifeMessageService {
+
+    List<LifeMessageVo> getMessageList(String receiverId) throws Exception;
+}

+ 33 - 0
alien-store/src/main/java/shop/alien/store/service/impl/PlatformLifeMessageServiceImpl.java

@@ -0,0 +1,33 @@
+package shop.alien.store.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import shop.alien.entity.store.vo.LifeFansVo;
+import shop.alien.entity.store.vo.LifeMessageVo;
+import shop.alien.mapper.LifeMessageMapper;
+import shop.alien.store.service.PlatformLifeMessageService;
+
+import java.util.List;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class PlatformLifeMessageServiceImpl implements PlatformLifeMessageService {
+
+    private final LifeMessageMapper lifeMessageMapper;
+
+    @Override
+    public List<LifeMessageVo> getMessageList(String receiverId) throws Exception {
+        try {
+            QueryWrapper<LifeFansVo> wrapper = new QueryWrapper<>();
+            wrapper.eq("message.num", 1);
+            wrapper.orderByDesc("message.created_time");
+            return lifeMessageMapper.getLifeMessagePageByPhoneId(receiverId, wrapper);
+        } catch (Exception e) {
+            log.error("LifeMessageServiceImpl.getMessageList Error Msg={}", e.getMessage());
+            throw new Exception("获取消息列表失败");
+        }
+    }
+}