消息

bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/basic/controller/BmMessageController.java

@@ -41,10 +41,23 @@ public class BmMessageController extends BaseController {
     @ApiOperation(value = "查询消息列表")
     @RequiresPermissions("basic:message:list")
     @GetMapping("/list")
-    public TableDataInfo list(BmMessage bmMessage) {
+    public AjaxResult list(BmMessage bmMessage) {
-        startPage();
+        //TODO get from cache
+
+        //TODO if no content from cache, then read from db?
         List<BmMessage> list = bmMessageService.selectBmMessageList(bmMessage);
-        return getDataTable(list);
+        return AjaxResult.success(list);
+    }
+
+    /**
+     * 查询消息列表
+     */
+    @ApiOperation(value = "查询消息列表")
+    @RequiresPermissions("basic:message:list")
+    @GetMapping("/listFromDB")
+    public AjaxResult listFromDB(BmMessage bmMessage) {
+        List<BmMessage> list = bmMessageService.selectBmMessageList(bmMessage);
+        return AjaxResult.success(list);
     }
 
     /**

bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/basic/service/IBmMessageService.java

@@ -26,6 +26,8 @@ public interface IBmMessageService {
      */
     public List<BmMessage> selectBmMessageList(BmMessage bmMessage);
 
+    public List<BmMessage> selectBmMessageListFromCache(BmMessage bmMessage);
+
     /**
      * 新增【请填写功能名称】
      * 

bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/basic/service/impl/BmMessageServiceImpl.java

@@ -4,9 +4,11 @@ import java.util.List;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
+import com.alibaba.fastjson2.JSONObject;
 import com.bonus.common.biz.constant.MaterialConstants;
 import com.bonus.common.core.constant.CacheConstants;
 import com.bonus.common.core.exception.ServiceException;
+import com.bonus.common.core.text.Convert;
 import com.bonus.common.core.utils.DateUtils;
 import com.bonus.common.core.utils.StringUtils;
 import com.bonus.common.redis.service.RedisService;
@@ -58,6 +60,12 @@ public class BmMessageServiceImpl implements IBmMessageService {
         return bmMessageMapper.selectBmMessageList(bmMessage);
     }
 
+    @Override
+    public List<BmMessage> selectBmMessageListFromCache(BmMessage bmMessage) {
+        List<BmMessage> bmMessages = redisService.getCacheList(MaterialConstants.CACHE_MATERIAL_MALL_MESSAGE_CODE);
+        return bmMessages;
+    }
+
     /**
      * 新增【请填写功能名称】
      * 
@@ -68,9 +76,10 @@ public class BmMessageServiceImpl implements IBmMessageService {
     public int insertBmMessage(BmMessage bmMessage) {
         bmMessage.setCreateTime(DateUtils.getNowDate());
         try {
-            String uuid = String.valueOf(UUID.randomUUID());
+            bmMessage.setUuid(String.valueOf(UUID.randomUUID()));
-            String verifyKey = MaterialConstants.CACHE_MATERIAL_MALL_MESSAGE_CODE + StringUtils.nvl(uuid + "_" + bmMessage.getMessageTopic(), "");
+            String msgKey = MaterialConstants.CACHE_MATERIAL_MALL_MESSAGE_CODE;
-            redisService.setCacheObject(verifyKey, uuid, verificationCodeConfig.getTime(), TimeUnit.MINUTES);
+            String msgContent = JSONObject.toJSONString(bmMessage);
+            redisService.setCacheObject(msgKey, msgContent, verificationCodeConfig.getTime(), TimeUnit.MINUTES);
             return bmMessageMapper.insertBmMessage(bmMessage);
         } catch (Exception e) {
             throw new ServiceException("错误信息描述");