| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | |
|---|
| | | // 团队奖励
|
|---|
| | | public void addFanLiOrderTeamRewardMsg(Long uid) {
|
|---|
| | | cmqUtil.sendMsg(FANLI_ORDER_TEAM_REWARD, uid + "");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public Map<String, Long> consumeOrderTeamRewardMsg(int count) {
|
|---|
| | | List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER_TEAM_REWARD);
|
|---|
| | | Map<String, Long> map = new HashMap<>();
|
|---|
| | | if (list != null)
|
|---|
| | | for (Message msg : list) {
|
|---|
| | | String result = msg.msgBody;
|
|---|
| | | if (!StringUtil.isNullOrEmpty(result)) {
|
|---|
| | | map.put(msg.receiptHandle, Long.parseLong(result));
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | return map;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public void deleteOrderTeamRewardMsg(String receiptHandle) {
|
|---|
| | | cmqUtil.deleteMsg(FANLI_ORDER_TEAM_REWARD, receiptHandle);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | // 维权订单
|
|---|
| | | public void addWeiQuanOrderMsg(TaoBaoWeiQuanOrder order) {
|
|---|
| | | cmqUtil.sendMsg(ORDER_WEIQUAN, new Gson().toJson(order));
|
|---|
