用户头像

src/main/java/com/hy/modules/bz/domain/BzGiftRecord.java

@@ -66,5 +66,7 @@ public class BzGiftRecord extends BaseDomain{
     /** 赠送时间 */
     private Date publishTime;
 
+    /** 用户头像 */
+    private String userHeadImg;
 
 }

src/main/java/com/hy/modules/bz/mapper/xml/BzGiftRecordMapper.xml

@@ -24,6 +24,7 @@
         <result property="createBy" column="create_by"/>
         <result property="updateBy" column="update_by"/>
         <result property="remark" column="remark"/>
+        <result property="userHeadImg" column="user_head_img"/>
     </resultMap>
 
     <resultMap id="RankingDto" type="com.hy.modules.bz.webapi.dto.RankingDto">
@@ -37,6 +38,7 @@
         SELECT
             user_id,
             user_id AS user_nick_name,
+            max(user_head_img) as user_head_img,
             SUM( gift_value ) AS total_gift_value
         FROM
             bz_gift_record
@@ -53,6 +55,7 @@
         SELECT
             user_id,
             user_id AS user_nick_name,
+            max(user_head_img) as user_head_img,
             SUM( gift_value ) AS total_gift_value
         FROM
             bz_gift_record

src/main/java/com/hy/modules/bz/webapi/dto/RankingDto.java

@@ -21,6 +21,11 @@ public class RankingDto implements Serializable {
      */
     private String userNickName;
 
+    /**
+     * 用户头像
+     */
+    private String userHeadImg;
+
     /**
      * 用户赠送礼物总价值
      */

src/main/java/com/hy/modules/bz/websocket/BarrageWebSocketServer.java

@@ -136,6 +136,7 @@ public class BarrageWebSocketServer extends AbstractWebSocketServer {
         giftRecord.setAnchorCode(anchorStudio.getCode());
         giftRecord.setAnchorId(anchorStudio.getAnchorId());
         giftRecord.setAnchorNickName(anchorStudio.getAnchorNickName());
+        giftRecord.setUserHeadImg(giftMessage.getHeadImg());
         giftRecord.setGiftCount(Long.valueOf(giftMessage.getGiftCount()));
         giftRecord.setGiftInfo(giftMessage.getGiftName());
         giftRecord.setGiftValue(score.multiply(BigDecimal.valueOf(giftRecord.getGiftCount())));