Parcourir la source

:feat:查询消息任务列表

zhangxianyu il y a 1 an
Parent
commit
9182ae6b65

+ 17 - 0
game-data/game-data-base/src/main/java/com/zangxiang/game/base/pojo/vo/SendMsgVo.java

@@ -0,0 +1,17 @@
+package com.zangxiang.game.base.pojo.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+@Data
+public class SendMsgVo implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+
+
+
+
+}

+ 5 - 0
game-data/game-data-base/src/main/java/com/zangxiang/game/base/rpc/SendMsgRpc.java

@@ -2,7 +2,10 @@ package com.zangxiang.game.base.rpc;
 
 
 import com.zangxiang.game.base.pojo.dto.SendMsgDto;
+import com.zangxiang.game.base.pojo.vo.SendMsgVo;
 import com.zanxiang.module.util.pojo.ResultVO;
+import org.apache.dubbo.common.utils.DefaultPage;
+import org.apache.dubbo.common.utils.Page;
 
 /**
  * @author : ZhangXianyu
@@ -12,4 +15,6 @@ import com.zanxiang.module.util.pojo.ResultVO;
 public interface SendMsgRpc {
 
     ResultVO<Boolean> sendMsg(SendMsgDto sendMsgDto);
+
+    ResultVO<DefaultPage<SendMsgVo>> getSendMsgTaskList();
 }

+ 9 - 0
game-data/game-data-serve/src/main/java/com/zanxiang/game/data/serve/controller/RoleManageController.java

@@ -1,6 +1,8 @@
 package com.zanxiang.game.data.serve.controller;
 
+import com.zangxiang.game.base.pojo.vo.SendMsgVo;
 import com.zanxiang.erp.security.annotation.PreAuthorize;
+import com.zanxiang.game.data.serve.pojo.dto.MsgTaskDto;
 import com.zanxiang.game.data.serve.pojo.dto.RoleCombatRankingDTO;
 import com.zanxiang.game.data.serve.pojo.dto.RoleRechargeRankingDTO;
 import com.zanxiang.game.data.serve.pojo.dto.SendMsgTaskDto;
@@ -55,4 +57,11 @@ public class RoleManageController {
         return ResultVO.ok();
     }
 
+    @ApiOperation(value = "查询发送消息任务列表")
+    @PreAuthorize(permissionKey = "roleManage:sendMsgTask:list")
+    @PostMapping("/sendMsgTask/list")
+    public ResultVO<Page<SendMsgVo>> getSendMsgTaskList(@RequestBody MsgTaskDto dto) {
+        return ResultVO.ok(roleManageService.getSendMsgTaskList(dto));
+    }
+
 }

+ 8 - 0
game-data/game-data-serve/src/main/java/com/zanxiang/game/data/serve/pojo/dto/MsgTaskDto.java

@@ -0,0 +1,8 @@
+package com.zanxiang.game.data.serve.pojo.dto;
+
+import com.zanxiang.game.data.serve.pojo.base.BasePage;
+import lombok.Data;
+
+@Data
+public class MsgTaskDto extends BasePage {
+}

+ 8 - 0
game-data/game-data-serve/src/main/java/com/zanxiang/game/data/serve/service/IRoleManageService.java

@@ -1,5 +1,7 @@
 package com.zanxiang.game.data.serve.service;
 
+import com.zangxiang.game.base.pojo.vo.SendMsgVo;
+import com.zanxiang.game.data.serve.pojo.dto.MsgTaskDto;
 import com.zanxiang.game.data.serve.pojo.dto.RoleCombatRankingDTO;
 import com.zanxiang.game.data.serve.pojo.dto.RoleRechargeRankingDTO;
 import com.zanxiang.game.data.serve.pojo.dto.SendMsgTaskDto;
@@ -28,4 +30,10 @@ public interface IRoleManageService {
      */
     List<Map> getRoleList(RoleRechargeRankingDTO dto);
 
+    /**
+     * 获取发送消息任务列表
+     * @param dto
+     * @return
+     */
+    Page<SendMsgVo> getSendMsgTaskList(MsgTaskDto dto);
 }

+ 15 - 0
game-data/game-data-serve/src/main/java/com/zanxiang/game/data/serve/service/impl/RoleManageServiceImpl.java

@@ -2,9 +2,11 @@ package com.zanxiang.game.data.serve.service.impl;
 
 import com.alibaba.fastjson2.JSON;
 import com.zangxiang.game.base.pojo.dto.SendMsgDto;
+import com.zangxiang.game.base.pojo.vo.SendMsgVo;
 import com.zanxiang.erp.base.ErpServer;
 import com.zanxiang.erp.base.rpc.ISysUserRpc;
 import com.zanxiang.erp.security.util.SecurityUtil;
+import com.zanxiang.game.data.serve.pojo.dto.MsgTaskDto;
 import com.zanxiang.game.data.serve.pojo.dto.RoleCombatRankingDTO;
 import com.zanxiang.game.data.serve.pojo.dto.RoleRechargeRankingDTO;
 import com.zanxiang.game.data.serve.pojo.dto.SendMsgTaskDto;
@@ -51,6 +53,8 @@ public class RoleManageServiceImpl implements IRoleManageService {
 
 
 
+
+
     /**
      * 角色充值排行榜
      * @param dto RoleRechargeRankingDTO
@@ -555,6 +559,17 @@ public class RoleManageServiceImpl implements IRoleManageService {
         return sql.getList(Map.class);
     }
 
+    /**
+     * 获取发送消息任务列表
+     * @param dto dto
+     * @return Page<SendMsgVo>
+     */
+    @Override
+    public Page<SendMsgVo> getSendMsgTaskList(MsgTaskDto dto) {
+        sendMsgRpc.getSendMsgTaskList();
+        return null;
+    }
+
     /**
      * 通过id获取 GS、运营、客服人员、投手名字
      * @param dataMap dataMap