SpringBootServerFrame/src/main/java/com/zero/barrageserver/common/convert/ServerMsgConvert.java at master · zerochl/SpringBootServerFrame · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
package com.zero.barrageserver.common.convert;

import com.zero.barrageserver.common.constant.Constant;
import com.zero.barrageserver.common.entity.servermsg.*;
import com.alibaba.fastjson.JSONObject;
import com.zero.barrageserver.common.constant.Constant;
import com.zero.barrageserver.common.entity.servermsg.*;
import org.springframework.stereotype.Component;

/**
 * Created by zero大神 on 2017/12/14.
 */
@Component
public class ServerMsgConvert {
    /**
     * 解析服务端推送过来的消息
     * @param msgEntity
     * @return
     */
    public BaseRequestMsgEntity convertToServerMsg(BaseRequestRootMsgEntity msgEntity){
        if(null == msgEntity){
            return null;
        }
        BaseRequestMsgEntity qqimBaseInfo = null;
        switch (msgEntity.getMsgtype()){
            case Constant.BARRAGE_TYPE_COMMENT:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestCommentMsg.class);
                break;
            case Constant.BARRAGE_TYPE_AWARD:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestAwardMsg.class);
                break;
            case Constant.BARRAGE_TYPE_LIKE:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestLikeMsg.class);
                break;
            case Constant.BARRAGE_TYPE_SONG:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestSongMsg.class);
                break;
            case Constant.BARRAGE_TYPE_VP:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestVPMsg.class);
                break;
            case Constant.BARRAGE_TYPE_SILKBAG:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestSilkBagUseMsg.class);
                break;
            case Constant.BARRAGE_TYPE_PK_HOT:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestPKHotMsg.class);
                break;
            case Constant.BARRAGE_TYPE_NORMAL_HOT:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestNormalHotMsg.class);
                break;
            case Constant.BARRAGE_TYPE_IMAGE:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestImageMsg.class);
                break;
            case Constant.BARRAGE_TYPE_MOVIE:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestMovieMsg.class);
                break;
            case Constant.BARRAGE_TYPE_IMAGE_WALL:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestImageWallMsg.class);
                break;
            case Constant.BARRAGE_TYPE_CONSUME_LIST:
                qqimBaseInfo = JSONObject.parseObject(msgEntity.getValue(), RequestConsumeListMsg.class);
                break;
        }
        if(null != qqimBaseInfo){
            qqimBaseInfo.setMsgType(msgEntity.getMsgtype());
            qqimBaseInfo.setActivityId(msgEntity.getActivityid());
            qqimBaseInfo.setCommentId(msgEntity.getCommentId());
        }
        return qqimBaseInfo;
    }
}