From 88b54772dbcf5ecab1e2316e4e4626ac901b8908 Mon Sep 17 00:00:00 2001
From: yujian <yujian>
Date: 星期二, 22 一月 2019 15:58:24 +0800
Subject: [PATCH] 邀请码添加返回状态
---
fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java | 47 +++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 45 insertions(+), 2 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java b/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
index 5c4cc2e..600238f 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
@@ -6,7 +6,7 @@
import java.util.List;
import java.util.Map;
-import net.sf.json.JSONObject;
+import org.yeshi.utils.CMQUtil;
import com.alipay.api.response.AlipayFundTransToaccountTransferResponse;
import com.google.gson.Gson;
@@ -16,11 +16,13 @@
import com.yeshi.fanli.entity.bus.user.AlipayTransferResultInfo;
import com.yeshi.fanli.entity.bus.user.Extract;
import com.yeshi.fanli.entity.bus.user.HongBao;
+import com.yeshi.fanli.entity.bus.user.HongBaoV2;
import com.yeshi.fanli.entity.common.AdminUser;
import com.yeshi.fanli.entity.push.PushQueueRecord;
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
-import org.yeshi.utils.CMQUtil;
+
+import net.sf.json.JSONObject;
public class CMQManager {
private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
@@ -36,6 +38,10 @@
// TODO 杩斿埄闃熷垪
public static String FANLI_ORDER = "fanli-order";
+
+ // TODO 杩斿埄闃熷垪
+ public static String FANLI_ORDER_NEW = "fanli-order-new";
+
// TODO 鎻愭垚璁㈠崟
public static String FANLI_TICHENG_ORDER = "fanli-ticheng-order";
// TODO 缁存潈璁㈠崟
@@ -44,10 +50,22 @@
public static String GOODS_UPDATE = "goods_update_queue";
static {
+
+ if (Constant.IS_TEST) {
+ QUEUENAME_ORDER = "test-" + QUEUENAME_ORDER;
+ EXTRACT_RESULT = "test-" + EXTRACT_RESULT;
+ PUSH_IOS = "test-" + PUSH_IOS;
+ FANLI_ORDER = "test-" + FANLI_ORDER;
+ FANLI_ORDER_NEW = "test-" + FANLI_ORDER_NEW;
+ FANLI_TICHENG_ORDER = "test-" + FANLI_TICHENG_ORDER;
+ ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;
+ }
+
QUEUENAME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
EXTRACT_RESULT += "-" + Constant.systemCommonConfig.getProjectName();
PUSH_IOS += "-" + Constant.systemCommonConfig.getProjectName();
FANLI_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
+ FANLI_ORDER_NEW += "-" + Constant.systemCommonConfig.getProjectName();
FANLI_TICHENG_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
ORDER_WEIQUAN += "-" + Constant.systemCommonConfig.getProjectName();
@@ -57,6 +75,7 @@
cmqUtil.createQueue(EXTRACT_RESULT);
cmqUtil.createQueue(PUSH_IOS);
cmqUtil.createQueue(FANLI_ORDER);
+ cmqUtil.createQueue(FANLI_ORDER_NEW);
cmqUtil.createQueue(FANLI_TICHENG_ORDER);
cmqUtil.createQueue(ORDER_WEIQUAN);
cmqUtil.createQueue(GOODS_UPDATE);
@@ -167,6 +186,12 @@
cmqUtil.sendMsg(FANLI_ORDER, content);
}
+ // 鏂扮増璁㈠崟杩斿埄
+ public void addFanLiMsgNew(HongBaoV2 hongBao) {
+ String content = new Gson().toJson(hongBao);
+ cmqUtil.sendMsg(FANLI_ORDER_NEW, content);
+ }
+
public Map<String, HongBao> consumeFanLiMsg(int count) {
List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER);
Map<String, HongBao> map = new HashMap<>();
@@ -181,10 +206,28 @@
return map;
}
+ public Map<String, HongBaoV2> consumeFanLiMsgNew(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER_NEW);
+ Map<String, HongBaoV2> map = new HashMap<>();
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ HongBaoV2 hongBao = new Gson().fromJson(result, HongBaoV2.class);
+ map.put(msg.receiptHandle, hongBao);
+ }
+ }
+ return map;
+ }
+
public void deleteFanLiMsg(String receiptHandle) {
cmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);
}
+ public void deleteFanLiMsgNew(String receiptHandle) {
+ cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);
+ }
+
// 鎻愭垚杩斿埄
public void addFanLiTiChengMsg(Long uid) {
cmqUtil.sendMsg(FANLI_TICHENG_ORDER, uid + "");
--
Gitblit v1.8.0