:fix:调用发送消息接口

game-module/game-module-manage/src/main/java/com/zanxiang/game/module/manage/service/impl/CPSendMsgTaskServiceImpl.java

@@ -10,6 +10,7 @@ import com.zanxiang.game.module.base.util.PageUtil;
 import com.zanxiang.game.module.manage.enums.CpSendMsgTaskStatusEnum;
 import com.zanxiang.game.module.manage.enums.CpSendMsgTaskTypeEnum;
 import com.zanxiang.game.module.manage.service.ICPSendMsgTaskService;
+import com.zanxiang.game.module.manage.service.ICpSendMsgLogService;
 import com.zanxiang.game.module.mybatis.entity.CpSendMsgTask;
 import com.zanxiang.game.module.mybatis.mapper.CpSendMsgTaskMapper;
 import com.zanxiang.module.util.bean.BeanUtil;
@@ -33,6 +34,9 @@ public class CPSendMsgTaskServiceImpl extends ServiceImpl<CpSendMsgTaskMapper, C
     @Resource
     private ICPSendMsgTaskService sendMsgTaskService;
 
+    @Resource
+    private ICpSendMsgLogService cpSendMsgLogService;
+
     @Override
     public ResultVO<Boolean> sendMsg(SendMsgDto sendMsgDto) {
         try {
@@ -44,7 +48,7 @@ public class CPSendMsgTaskServiceImpl extends ServiceImpl<CpSendMsgTaskMapper, C
             CpSendMsgTask cpSendMsgTask = createSendMsgTask(sendMsgDto);
             //保存任务
             sendMsgTaskService.save(cpSendMsgTask);
-            //todo：发送消息
+            cpSendMsgLogService.cpSendMsg(cpSendMsgTask.getId(), sendMsgDto.getGameId(), sendMsgDto.getMsg(), sendMsgDto.getRoles());
             log.info("发送消息成功");
             return ResultVO.ok();
         } catch (Exception e) {