修复抖音订单更新问题/修复用户注销却自动封禁的bug

admin

2023-01-03 5710fee2bd5c323096377a72d837050dd52d93b1

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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
package com.yeshi.fanli.util.mq.cmq.order;
 
import com.google.gson.Gson;
import com.qcloud.cmq.Message;
import com.yeshi.fanli.dto.mq.UidDateDTO;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
 
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
public class TeamOrderCMQManager {
 
    private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
    private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
    private static TeamOrderCMQManager jdOrderCMQManager;
 
    // 团队分红
    public static String TEAM_DIVIDENTS_PRE = "team_dividents_pre";
    // 团队收益
    public static String FANLI_TEAM_INCOME_ORDER_PRE = "fanli-team-income-order-pre";
 
    // 团队分红
    public static String TEAM_DIVIDENTS = "team_dividents";
    // 团队收益
    public static String FANLI_TEAM_INCOME_ORDER = "fanli-team-income-order";
 
    static {
        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
        TEAM_DIVIDENTS_PRE += "-" + Constant.systemCommonConfig.getProjectName();
        FANLI_TEAM_INCOME_ORDER_PRE += "-" + Constant.systemCommonConfig.getProjectName();
        TEAM_DIVIDENTS += "-" + Constant.systemCommonConfig.getProjectName();
        FANLI_TEAM_INCOME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
        TDMQUtil.getInstance().createQueue(TEAM_DIVIDENTS_PRE);
        TDMQUtil.getInstance().createQueue(FANLI_TEAM_INCOME_ORDER_PRE);
        TDMQUtil.getInstance().createQueue(TEAM_DIVIDENTS);
        TDMQUtil.getInstance().createQueue(FANLI_TEAM_INCOME_ORDER);
    }
 
    public static TeamOrderCMQManager getInstance() {
        if (jdOrderCMQManager == null)
            jdOrderCMQManager = new TeamOrderCMQManager();
        return jdOrderCMQManager;
    }
 
    // 团队分红预到账
    public void addTeamDividentsPreMsg(UidDateDTO dto) {
        TDMQUtil.getInstance().sendMsg(TEAM_DIVIDENTS_PRE, new Gson().toJson(dto));
    }
 
    public Map<String, UidDateDTO> consumeTeamDividentsPreMsg(int count) {
        Gson gson = new Gson();
        List<Message> list = TDMQUtil.getInstance().recieveMsg(count, TEAM_DIVIDENTS_PRE);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                if (!StringUtil.isNullOrEmpty(result)) {
                    map.put(msg.receiptHandle, gson.fromJson(result, UidDateDTO.class));
                }
            }
        return map;
    }
 
    public void deleteTeamDividentsPreMsg(String receiptHandle) {
 
        TDMQUtil.getInstance().deleteMsg(TEAM_DIVIDENTS_PRE, receiptHandle);
 
    }
 
    // 团队收益预到账
    public void addFanLiTeamIncomePreMsg(UidDateDTO dto) {
        TDMQUtil.getInstance().sendMsg(FANLI_TEAM_INCOME_ORDER_PRE, new Gson().toJson(dto) + "");
    }
 
    public Map<String, UidDateDTO> consumeFanLiTeamIncomePreMsg(int count) {
        List<Message> list = TDMQUtil.getInstance().recieveMsg(count, FANLI_TEAM_INCOME_ORDER_PRE);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                UidDateDTO dto = new Gson().fromJson(result, UidDateDTO.class);
                if (!StringUtil.isNullOrEmpty(result)) {
                    map.put(msg.receiptHandle, dto);
                }
            }
        return map;
    }
 
    public void deleteTeamIncomePreMsg(String receiptHandle) {
 
        TDMQUtil.getInstance().deleteMsg(FANLI_TEAM_INCOME_ORDER_PRE, receiptHandle);
 
    }
 
    // 团队分红到账
    public void addTeamDividentsMsg(UidDateDTO dto) {
        TDMQUtil.getInstance().sendMsg(TEAM_DIVIDENTS, new Gson().toJson(dto));
    }
 
    public Map<String, UidDateDTO> consumeTeamDividentsMsg(int count) {
        Gson gson = new Gson();
        List<Message> list = TDMQUtil.getInstance().recieveMsg(count, TEAM_DIVIDENTS);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                if (!StringUtil.isNullOrEmpty(result)) {
                    map.put(msg.receiptHandle, gson.fromJson(result, UidDateDTO.class));
                }
            }
        return map;
    }
 
    public void deleteTeamDividentsMsg(String receiptHandle) {
 
        TDMQUtil.getInstance().deleteMsg(TEAM_DIVIDENTS, receiptHandle);
 
    }
 
    // 团队收益到账
    public void addFanLiTeamIncomeMsg(UidDateDTO dto) {
        TDMQUtil.getInstance().sendMsg(FANLI_TEAM_INCOME_ORDER, new Gson().toJson(dto) + "");
    }
 
    public Map<String, UidDateDTO> consumeFanLiTeamIncomeMsg(int count) {
        List<Message> list = TDMQUtil.getInstance().recieveMsg(count, FANLI_TEAM_INCOME_ORDER);
        Map<String, UidDateDTO> map = new HashMap<>();
        if (list != null)
            for (Message msg : list) {
                String result = msg.msgBody;
                UidDateDTO dto = new Gson().fromJson(result, UidDateDTO.class);
                if (!StringUtil.isNullOrEmpty(result)) {
                    map.put(msg.receiptHandle, dto);
                }
            }
        return map;
    }
 
    public void deleteTeamIncomeMsg(String receiptHandle) {
        TDMQUtil.getInstance().deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);
    }
}