1.1-1227

game/src/main/java/com/ccsens/game/api/ClientController.java

@@ -1,12 +1,37 @@
 package com.ccsens.game.api;
 
+import com.ccsens.game.bean.dto.ClientDto;
+import com.ccsens.game.bean.dto.ScreenDto;
+import com.ccsens.game.bean.vo.ClientVo;
+import com.ccsens.game.service.IClientService;
+import com.ccsens.util.JsonResponse;
+import com.ccsens.util.bean.dto.QueryDto;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RestController;
-
+@Slf4j
 @Api(tags = "客户端相关api" , description = "ClientController")
 @RestController
 @RequestMapping("/client")
 public class ClientController {
+    @Autowired
+    private IClientService clientService;
 
+    @ApiOperation(value = "查看全部排行榜", notes = "")
+    @ApiImplicitParams({
+    })
+    @RequestMapping(value = "members", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
+    public JsonResponse<ClientVo.RankingAll> startAgain(@ApiParam @Validated @RequestBody QueryDto<ClientDto.GatRanking> params) throws Exception {
+        log.info("查看全部排行榜：{}",params);
+        ClientVo.RankingAll rankingAll = clientService.getRankingAll(params);
+        return JsonResponse.newInstance().ok(rankingAll);
+    }
 }

game/src/main/java/com/ccsens/game/api/ScreenController.java

@@ -58,10 +58,19 @@ public class ScreenController {
     @ApiImplicitParams({
     })
     @RequestMapping(value = "start", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
-    public JsonResponse startGame(HttpServletRequest request,
-                                      @ApiParam @Validated @RequestBody ScreenDto.MemberRecordAndTime memberRecordAndTime) throws Exception {
+    public JsonResponse startGame(@ApiParam @Validated @RequestBody ScreenDto.MemberRecordAndTime memberRecordAndTime) throws Exception {
         log.info("开始游戏：{}",memberRecordAndTime);
 
         return JsonResponse.newInstance().ok();
     }
+
+    @ApiOperation(value = "再玩一次", notes = "")
+    @ApiImplicitParams({
+    })
+    @RequestMapping(value = "startAgain", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
+    public JsonResponse<String> startAgain(@ApiParam @Validated @RequestBody QueryDto<ScreenDto.MemberRecord> params) throws Exception {
+        log.info("开始游戏：{}",params);
+        String url = screenService.startAgain(params);
+        return JsonResponse.newInstance().ok(url);
+    }
 }

game/src/main/java/com/ccsens/game/bean/dto/ClientDto.java

@@ -1,8 +1,11 @@
 package com.ccsens.game.bean.dto;
 
 import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
+import java.util.List;
+
 /**
  * @description:
  * @author: wuHuiJuan
@@ -15,4 +18,17 @@ public class ClientDto {
     public static class Join{
 
     }
+
+    @Data
+    @ApiModel("getRanking")
+    public static class GatRanking{
+        @ApiModelProperty("创建的游戏记录的id")
+        private Long recordId;
+        @ApiModelProperty("页数")
+        private int pageNum;
+        @ApiModelProperty("每页多少条")
+        private int pageSize;
+    }
+
+
 }

game/src/main/java/com/ccsens/game/bean/po/GameUserJoin.java

@@ -10,7 +10,7 @@ public class GameUserJoin implements Serializable {
 
     private String nickname;
 
-    private String avatarurl;
+    private String avatarUrl;
 
     private Long recordId;
 
@@ -56,12 +56,12 @@ public class GameUserJoin implements Serializable {
         this.nickname = nickname == null ? null : nickname.trim();
     }
 
-    public String getAvatarurl() {
-        return avatarurl;
+    public String getAvatarUrl() {
+        return avatarUrl;
     }
 
-    public void setAvatarurl(String avatarurl) {
-        this.avatarurl = avatarurl == null ? null : avatarurl.trim();
+    public void setAvatarUrl(String avatarUrl) {
+        this.avatarUrl = avatarUrl == null ? null : avatarUrl.trim();
     }
 
     public Long getRecordId() {
@@ -145,7 +145,7 @@ public class GameUserJoin implements Serializable {
         sb.append(", id=").append(id);
         sb.append(", userId=").append(userId);
         sb.append(", nickname=").append(nickname);
-        sb.append(", avatarurl=").append(avatarurl);
+        sb.append(", avatarUrl=").append(avatarUrl);
         sb.append(", recordId=").append(recordId);
         sb.append(", times=").append(times);
         sb.append(", score=").append(score);

game/src/main/java/com/ccsens/game/bean/po/GameUserJoinExample.java

@@ -295,73 +295,73 @@ public class GameUserJoinExample {
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlIsNull() {
-            addCriterion("avatarUrl is null");
+        public Criteria andAvatarUrlIsNull() {
+            addCriterion("avatar_url is null");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlIsNotNull() {
-            addCriterion("avatarUrl is not null");
+        public Criteria andAvatarUrlIsNotNull() {
+            addCriterion("avatar_url is not null");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlEqualTo(String value) {
-            addCriterion("avatarUrl =", value, "avatarurl");
+        public Criteria andAvatarUrlEqualTo(String value) {
+            addCriterion("avatar_url =", value, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlNotEqualTo(String value) {
-            addCriterion("avatarUrl <>", value, "avatarurl");
+        public Criteria andAvatarUrlNotEqualTo(String value) {
+            addCriterion("avatar_url <>", value, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlGreaterThan(String value) {
-            addCriterion("avatarUrl >", value, "avatarurl");
+        public Criteria andAvatarUrlGreaterThan(String value) {
+            addCriterion("avatar_url >", value, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlGreaterThanOrEqualTo(String value) {
-            addCriterion("avatarUrl >=", value, "avatarurl");
+        public Criteria andAvatarUrlGreaterThanOrEqualTo(String value) {
+            addCriterion("avatar_url >=", value, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlLessThan(String value) {
-            addCriterion("avatarUrl <", value, "avatarurl");
+        public Criteria andAvatarUrlLessThan(String value) {
+            addCriterion("avatar_url <", value, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlLessThanOrEqualTo(String value) {
-            addCriterion("avatarUrl <=", value, "avatarurl");
+        public Criteria andAvatarUrlLessThanOrEqualTo(String value) {
+            addCriterion("avatar_url <=", value, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlLike(String value) {
-            addCriterion("avatarUrl like", value, "avatarurl");
+        public Criteria andAvatarUrlLike(String value) {
+            addCriterion("avatar_url like", value, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlNotLike(String value) {
-            addCriterion("avatarUrl not like", value, "avatarurl");
+        public Criteria andAvatarUrlNotLike(String value) {
+            addCriterion("avatar_url not like", value, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlIn(List<String> values) {
-            addCriterion("avatarUrl in", values, "avatarurl");
+        public Criteria andAvatarUrlIn(List<String> values) {
+            addCriterion("avatar_url in", values, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlNotIn(List<String> values) {
-            addCriterion("avatarUrl not in", values, "avatarurl");
+        public Criteria andAvatarUrlNotIn(List<String> values) {
+            addCriterion("avatar_url not in", values, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlBetween(String value1, String value2) {
-            addCriterion("avatarUrl between", value1, value2, "avatarurl");
+        public Criteria andAvatarUrlBetween(String value1, String value2) {
+            addCriterion("avatar_url between", value1, value2, "avatarUrl");
             return (Criteria) this;
         }
 
-        public Criteria andAvatarurlNotBetween(String value1, String value2) {
-            addCriterion("avatarUrl not between", value1, value2, "avatarurl");
+        public Criteria andAvatarUrlNotBetween(String value1, String value2) {
+            addCriterion("avatar_url not between", value1, value2, "avatarUrl");
             return (Criteria) this;
         }
 

game/src/main/java/com/ccsens/game/bean/vo/ClientVo.java

@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
+import java.util.List;
+
 /**
  * @description:
  * @author: wuHuiJuan
@@ -15,4 +17,34 @@ public class ClientVo {
     public static class Join{
 
     }
+
+
+    @Data
+    @ApiModel("RankingAll")
+    public static class RankingAll{
+        @ApiModelProperty("参加总人数")
+        private int totalMembers;
+        @ApiModelProperty("是否为第一页")
+        private boolean isFirstPage;
+        @ApiModelProperty("是否为最后一页")
+        private boolean isLastPage;
+        @ApiModelProperty("用户信息（排名）")
+        private List<MemberInfo> memberInfoList;
+    }
+
+    @Data
+    @ApiModel("RankingAll")
+    public static class MemberInfo{
+        private  Long id;
+        @ApiModelProperty("用户头像")
+        private String headImgUrl;
+        @ApiModelProperty("昵称")
+        private String nickname;
+        @ApiModelProperty("排名次序")
+        private int sort;
+        @ApiModelProperty("次数")
+        private int times;
+        @ApiModelProperty("分数")
+        private int score;
+    }
 }

game/src/main/java/com/ccsens/game/persist/dao/GameUserJoinDao.java

@@ -1,8 +1,12 @@
 package com.ccsens.game.persist.dao;
 
+import com.ccsens.game.bean.vo.ClientVo;
 import com.ccsens.game.persist.mapper.GameUserJoinMapper;
+import feign.Param;
 import org.springframework.stereotype.Repository;
 
 @Repository
 public interface GameUserJoinDao extends GameUserJoinMapper {
+
+    ClientVo.MemberInfo selectByRecordId(@Param("recordId") Long recordId);
 }

game/src/main/java/com/ccsens/game/service/ClientService.java

@@ -1,9 +1,46 @@
 package com.ccsens.game.service;
 
+import com.ccsens.game.bean.dto.ClientDto;
+import com.ccsens.game.bean.po.GameUserJoin;
+import com.ccsens.game.bean.po.GameUserJoinExample;
+import com.ccsens.game.bean.vo.ClientVo;
+import com.ccsens.game.persist.dao.GameUserJoinDao;
+import com.ccsens.util.bean.dto.QueryDto;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import lombok.extern.slf4j.Slf4j;
+import org.eclipse.jetty.server.Authentication;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
 /**
  * @description:
  * @author: wuHuiJuan
  * @create: 2019/12/26 15:01
  */
+@Slf4j
+@Service
 public class ClientService implements IClientService {
+
+    @Autowired
+    private GameUserJoinDao gameUserJoinDao;
+
+    @Override
+    public ClientVo.RankingAll getRankingAll(QueryDto<ClientDto.GatRanking> params) {
+        ClientDto.GatRanking gatRanking = params.getParam();
+
+        GameUserJoinExample userJoinExample = new GameUserJoinExample();
+        userJoinExample.createCriteria().andRecordIdEqualTo(gatRanking.getRecordId());
+        List<GameUserJoin> userJoinList = gameUserJoinDao.selectByExample(userJoinExample);
+
+
+        PageHelper.startPage(gatRanking.getPageNum(), gatRanking.getPageSize());
+        ClientVo.MemberInfo memberInfo = gameUserJoinDao.selectByRecordId(gatRanking.getRecordId());
+        log.info("查询成员信息");
+        PageInfo pageInfo =new PageInfo<>();
+
+        return null;
+    }
 }

game/src/main/java/com/ccsens/game/service/IClientService.java

@@ -1,11 +1,12 @@
 package com.ccsens.game.service;
 
-/**
+import com.ccsens.game.bean.dto.ClientDto;
+import com.ccsens.game.bean.vo.ClientVo;
+import com.ccsens.util.bean.dto.QueryDto; /**
  * @description:
  * @author: wuHuiJuan
  * @create: 2019/12/26 15:00
  */
 public interface IClientService {
-
-
+    ClientVo.RankingAll getRankingAll(QueryDto<ClientDto.GatRanking> params);
 }

game/src/main/java/com/ccsens/game/service/IScreenService.java

@@ -10,4 +10,6 @@ public interface IScreenService {
     ScreenVo.GameInfoVo getGameInformation(QueryDto<ScreenDto.MemberRecord> params);
 
     ScreenVo.GameStatusVo getGameStatusVo(QueryDto<ScreenDto.MemberRecord> params);
+
+    String startAgain(QueryDto<ScreenDto.MemberRecord> params);
 }

game/src/main/java/com/ccsens/game/service/ScreenService.java

@@ -237,6 +237,38 @@ public class ScreenService implements IScreenService{
         return gameStatusVo;
     }
 
+    /**
+     * 再玩一次
+     */
+    @Override
+    public String startAgain(QueryDto<ScreenDto.MemberRecord> params) {
+        ScreenDto.MemberRecord memberRecord = params.getParam();
+        GameRecord gameRecord = gameRecordDao.selectByPrimaryKey(memberRecord.getMemberRecord());
+        if(ObjectUtil.isNull(gameRecord)){
+            throw new BaseException(CodeEnum.NOT_GAME_RECORD);
+        }
+        GameUserPay gameUserPay = typeMemberDao.selectByPrimaryKey(gameRecord.getUserPayId());
+        if(ObjectUtil.isNull(gameUserPay)){
+            throw new BaseException(CodeEnum.NOT_GAME_TYPE);
+        }
+        GameType gameType = gameTypeDao.selectByPrimaryKey(gameUserPay.getId());
+        if(ObjectUtil.isNull(gameType)){
+            throw new BaseException(CodeEnum.NOT_GAME_TYPE);
+        }
+        //添加一场新的游戏记录
+        GameRecord gameRecordNew = new GameRecord();
+        gameRecordNew.setId(snowflake.nextId());
+        gameRecordNew.setUserPayId(gameUserPay.getId());
+        gameRecordNew.setUrl(WebConstant.TEST_URL_GAME + gameRecordNew.getId() +  File.separator + gameType.getScreenUrl());
+        gameRecordNew.setQrCodeUrl(WebConstant.TEST_URL_GAME + gameRecordNew.getId() +  File.separator + gameType.getClientUrl());
+        gameRecordDao.insertSelective(gameRecordNew);
+        //修改购买的游戏的使用次数
+        gameUserPay.setUsedCount(gameUserPay.getUsedCount() + 1);
+        typeMemberDao.updateByPrimaryKeySelective(gameUserPay);
+
+        return gameRecordNew.getUrl();
+    }
+
     /**
      * 查找活动规则
      */

game/src/main/resources/application-test.yml

@@ -7,22 +7,22 @@ spring:
     name: game
   datasource:
     type: com.alibaba.druid.pool.DruidDataSource
-    rabbitmq:
-      host: api.ccsens.com
-      password: 111111
-      port: 5672
-      username: admin
-    redis:
-      database: 0
-      host: 127.0.0.1
-      jedis:
-        pool:
-          max-active: 200
-          max-idle: 10
-          max-wait: -1ms
-          min-idle: 0
-      password: ''
-      port: 6379
-      timeout: 1000ms
+  rabbitmq:
+    host: api.ccsens.com
+    password: 111111
+    port: 5672
+    username: admin
+  redis:
+    database: 0
+    host: 127.0.0.1
+    jedis:
+      pool:
+        max-active: 200
+        max-idle: 10
+        max-wait: -1ms
+        min-idle: 0
+    password: ''
+    port: 6379
+    timeout: 1000ms
 swagger:
   enable: true

game/src/main/resources/mapper_dao/GameUserJoinDao.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ccsens.game.persist.dao.GameUserJoinDao">
+    <resultMap id="resultMap_memberInfo" type="com.ccsens.game.bean.vo.ClientVo$MemberInfo">
+        <id column="uId" property="id"/>
+        <result column="uHeadImgUrl" property="headImgUrl"/>
+        <result column="uNickname" property="nickname"/>
+        <result column="uTimes" property="times"/>
+        <result column="uScore" property="score"/>
+    </resultMap>
+
+    <select id="selectByRecordId" parameterType="java.util.Map" resultMap="resultMap_memberInfo">
+        SELECT
+          id as uId,
+          avatar_url as uHeadImgUrl,
+          nickname as uNickname,
+          times as uTimes,
+          score as uScore
+        FROM
+          t_game_user_join
+        WHERE
+          record_id = #{recordId}
+    </select>
+
+</mapper>

game/src/main/resources/mapper_raw/GameUserJoinMapper.xml

@@ -5,7 +5,7 @@
     <id column="id" jdbcType="BIGINT" property="id" />
     <result column="user_id" jdbcType="BIGINT" property="userId" />
     <result column="nickname" jdbcType="VARCHAR" property="nickname" />
-    <result column="avatarUrl" jdbcType="VARCHAR" property="avatarurl" />
+    <result column="avatar_url" jdbcType="VARCHAR" property="avatarUrl" />
     <result column="record_id" jdbcType="BIGINT" property="recordId" />
     <result column="times" jdbcType="INTEGER" property="times" />
     <result column="score" jdbcType="INTEGER" property="score" />
@@ -75,7 +75,7 @@
     </where>
   </sql>
   <sql id="Base_Column_List">
-    id, user_id, nickname, avatarUrl, record_id, times, score, time_difference, local_start_time, 
+    id, user_id, nickname, avatar_url, record_id, times, score, time_difference, local_start_time, 
     local_end_time, created_at, updated_at, rec_status
   </sql>
   <select id="selectByExample" parameterType="com.ccsens.game.bean.po.GameUserJoinExample" resultMap="BaseResultMap">
@@ -110,12 +110,12 @@
   </delete>
   <insert id="insert" parameterType="com.ccsens.game.bean.po.GameUserJoin">
     insert into t_game_user_join (id, user_id, nickname, 
-      avatarUrl, record_id, times, 
+      avatar_url, record_id, times, 
       score, time_difference, local_start_time, 
       local_end_time, created_at, updated_at, 
       rec_status)
     values (#{id,jdbcType=BIGINT}, #{userId,jdbcType=BIGINT}, #{nickname,jdbcType=VARCHAR}, 
-      #{avatarurl,jdbcType=VARCHAR}, #{recordId,jdbcType=BIGINT}, #{times,jdbcType=INTEGER}, 
+      #{avatarUrl,jdbcType=VARCHAR}, #{recordId,jdbcType=BIGINT}, #{times,jdbcType=INTEGER}, 
       #{score,jdbcType=INTEGER}, #{timeDifference,jdbcType=INTEGER}, #{localStartTime,jdbcType=BIGINT}, 
       #{localEndTime,jdbcType=BIGINT}, #{createdAt,jdbcType=TIMESTAMP}, #{updatedAt,jdbcType=TIMESTAMP}, 
       #{recStatus,jdbcType=TINYINT})
@@ -132,8 +132,8 @@
       <if test="nickname != null">
         nickname,
       </if>
-      <if test="avatarurl != null">
-        avatarUrl,
+      <if test="avatarUrl != null">
+        avatar_url,
       </if>
       <if test="recordId != null">
         record_id,
@@ -173,8 +173,8 @@
       <if test="nickname != null">
         #{nickname,jdbcType=VARCHAR},
       </if>
-      <if test="avatarurl != null">
-        #{avatarurl,jdbcType=VARCHAR},
+      <if test="avatarUrl != null">
+        #{avatarUrl,jdbcType=VARCHAR},
       </if>
       <if test="recordId != null">
         #{recordId,jdbcType=BIGINT},
@@ -223,8 +223,8 @@
       <if test="record.nickname != null">
         nickname = #{record.nickname,jdbcType=VARCHAR},
       </if>
-      <if test="record.avatarurl != null">
-        avatarUrl = #{record.avatarurl,jdbcType=VARCHAR},
+      <if test="record.avatarUrl != null">
+        avatar_url = #{record.avatarUrl,jdbcType=VARCHAR},
       </if>
       <if test="record.recordId != null">
         record_id = #{record.recordId,jdbcType=BIGINT},
@@ -263,7 +263,7 @@
     set id = #{record.id,jdbcType=BIGINT},
       user_id = #{record.userId,jdbcType=BIGINT},
       nickname = #{record.nickname,jdbcType=VARCHAR},
-      avatarUrl = #{record.avatarurl,jdbcType=VARCHAR},
+      avatar_url = #{record.avatarUrl,jdbcType=VARCHAR},
       record_id = #{record.recordId,jdbcType=BIGINT},
       times = #{record.times,jdbcType=INTEGER},
       score = #{record.score,jdbcType=INTEGER},
@@ -286,8 +286,8 @@
       <if test="nickname != null">
         nickname = #{nickname,jdbcType=VARCHAR},
       </if>
-      <if test="avatarurl != null">
-        avatarUrl = #{avatarurl,jdbcType=VARCHAR},
+      <if test="avatarUrl != null">
+        avatar_url = #{avatarUrl,jdbcType=VARCHAR},
       </if>
       <if test="recordId != null">
         record_id = #{recordId,jdbcType=BIGINT},
@@ -323,7 +323,7 @@
     update t_game_user_join
     set user_id = #{userId,jdbcType=BIGINT},
       nickname = #{nickname,jdbcType=VARCHAR},
-      avatarUrl = #{avatarurl,jdbcType=VARCHAR},
+      avatar_url = #{avatarUrl,jdbcType=VARCHAR},
       record_id = #{recordId,jdbcType=BIGINT},
       times = #{times,jdbcType=INTEGER},
       score = #{score,jdbcType=INTEGER},

mt/src/main/resources/application-test.yml

@@ -7,22 +7,22 @@ spring:
     name: mt
   datasource:
     type: com.alibaba.druid.pool.DruidDataSource
-    rabbitmq:
-      host: api.ccsens.com
-      password: 111111
-      port: 5672
-      username: admin
-    redis:
-      database: 0
-      host: 127.0.0.1
-      jedis:
-        pool:
-          max-active: 200
-          max-idle: 10
-          max-wait: -1ms
-          min-idle: 0
-      password: ''
-      port: 6379
-      timeout: 1000ms
+  rabbitmq:
+    host: api.ccsens.com
+    password: 111111
+    port: 5672
+    username: admin
+  redis:
+    database: 0
+    host: 127.0.0.1
+    jedis:
+      pool:
+        max-active: 200
+        max-idle: 10
+        max-wait: -1ms
+        min-idle: 0
+    password: ''
+    port: 6379
+    timeout: 1000ms
 swagger:
   enable: true

tall/src/main/java/com/ccsens/tall/service/MessageService.java

@@ -60,7 +60,8 @@ public class MessageService implements IMessageService{
 
             SyncMessageWithStartDto message = new SyncMessageWithStartDto(projectId, sender, receivers, roleId, taskId, null, time, duration);
             //FixMe 发送到消息队列
-            rabbitTemplate.convertAndSend(RabbitMQConfig.TALL_MESSAGE_1,
+            System.out.println(message);
+            rabbitTemplate.convertAndSend(RabbitMQConfig.RabbitMQ_QUEUE_NAME,
                     JacksonUtil.beanToJson(message));
         }
     }

tall/src/main/java/com/ccsens/tall/service/TaskSubTimeService.java

@@ -185,7 +185,6 @@ public class TaskSubTimeService implements ITaskSubTimeService {
             taskSubTime.setComplatedStatus(1);
             taskSubTimeDao.updateByPrimaryKeySelective(taskSubTime);
 
-
             //发送同步消息
             SysProject project = sysProjectDao.selectByPrimaryKey(startTaskDto.getProjectId());
             //已发布的项目才同步

util/src/main/java/com/ccsens/util/config/RabbitMQConfig.java

@@ -6,21 +6,21 @@ import org.springframework.context.annotation.Configuration;
 
 @Configuration
 public class RabbitMQConfig {
+    public static final String RabbitMQ_QUEUE_NAME = "Queue_Anyring";
     public static final String TALL_MESSAGE_1 = "tall_message_1";
     public static final String TALL_MESSAGE_2 = "tall_message_2";
-    public static final String RabbitMQ_QUEUE_NAME = "Queue_Anyring";
 
     @Bean
-    public Queue queue(){
-        return new Queue(TALL_MESSAGE_1);
+    public Queue queue (){
+        return new Queue(RabbitMQ_QUEUE_NAME);
     }
     @Bean
     public Queue queue1(){
-        return new Queue(TALL_MESSAGE_2);
+        return new Queue(TALL_MESSAGE_1);
     }
     @Bean
     public Queue queue2(){
-        return new Queue(RabbitMQ_QUEUE_NAME);
+        return new Queue(TALL_MESSAGE_2);
     }
 
 }