fanli-server.git

			@@ -2,13 +2,8 @@

			import com.google.gson.Gson;
			import com.qcloud.cmq.Message;
			import com.yeshi.fanli.dto.money.UserMoneyChangeDTO;
			import com.yeshi.fanli.dto.push.PushContentDetailDTO;
			import com.yeshi.fanli.log.LogHelper;
			import com.yeshi.fanli.util.Constant;
			import com.yeshi.fanli.util.StringUtil;
			import com.yeshi.fanli.util.mq.cmq.order.JDOrderCMQManager;
			import org.yeshi.utils.CMQUtil;

			import java.util.HashMap;
			import java.util.List;
			@@ -19,14 +14,14 @@
			private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
			private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
			private static PushCMQManager pushCMQManager;
			private static CMQUtil cmqUtil;

			public static String PUSH_HW = "push-hw";

			static {
			cmqUtil = CMQUtil.getInstance(secretId, secretKey);
			TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

			PUSH_HW += "-" + Constant.systemCommonConfig.getProjectName();
			cmqUtil.createQueue(PUSH_HW);
			TDMQUtil.getInstance().createQueue(PUSH_HW);
			}

			public static PushCMQManager getInstance() {
			@@ -42,7 +37,7 @@
			if (dto == null)
			return;
			String json = new Gson().toJson(dto);
			cmqUtil.sendMsg(PUSH_HW, json);
			TDMQUtil.getInstance().sendMsg(PUSH_HW, json);
			}

			/**
			@@ -52,7 +47,7 @@
			* @return
			*/
			public Map<String, PushContentDetailDTO> consumeHWPush(int count) {
			List<Message> list = cmqUtil.recieveMsg(count, PUSH_HW);
			List<Message> list = TDMQUtil.getInstance().recieveMsg(count, PUSH_HW);
			Map<String, PushContentDetailDTO> map = new HashMap<>();
			if (list != null)
			for (Message msg : list) {
			@@ -69,6 +64,6 @@
			* @param receiptHandle
			*/
			public void deleteHWPush(String receiptHandle) {
			cmqUtil.deleteMsg(PUSH_HW, receiptHandle);
			TDMQUtil.getInstance().deleteMsg(PUSH_HW, receiptHandle);
			}
			}