From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/controller/TestController.java | 93 ++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 84 insertions(+), 9 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java b/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
index 7ae26f1..935194a 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
@@ -4,14 +4,19 @@
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.dao.dynamic.DynamicInfoDao;
import com.yeshi.fanli.dao.mybatis.help.HelpCenterMapper;
+import com.yeshi.fanli.dto.push.PushContentDTO;
import com.yeshi.fanli.entity.SystemEnum;
import com.yeshi.fanli.entity.bus.activity.ActivityShareResult;
import com.yeshi.fanli.entity.bus.activity.RecommendActivity;
+import com.yeshi.fanli.entity.bus.msg.MsgOrderDetail;
+import com.yeshi.fanli.entity.bus.user.UserInfo;
+import com.yeshi.fanli.entity.config.push.PushMsgFactory;
import com.yeshi.fanli.entity.dynamic.InviteMaterial;
import com.yeshi.fanli.exception.ActivityException;
import com.yeshi.fanli.exception.push.PushException;
import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
+import com.yeshi.fanli.exception.user.UserInfoException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.log.LogManager;
import com.yeshi.fanli.log.LogType;
@@ -21,10 +26,14 @@
import com.yeshi.fanli.service.inter.dynamic.InviteMaterialService;
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
+import com.yeshi.fanli.service.inter.order.msg.MsgOrderDetailService;
+import com.yeshi.fanli.service.inter.push.PushService;
+import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.db.MongoDBManager;
+import com.yeshi.fanli.util.email.MailSenderUtil;
import com.yeshi.fanli.util.push.OPPOPushUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import com.yeshi.goods.facade.entity.taobao.TaoBaoCouponCache;
@@ -32,13 +41,17 @@
import com.yeshi.goods.facade.service.TaoBaoCouponCacheService;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
-import org.apache.dubbo.config.annotation.Reference;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.select.Elements;
import org.quartz.JobExecutionContext;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.core.MessageProperties;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.cache.ehcache.EhCacheCacheManager;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -55,6 +68,7 @@
import javax.servlet.http.HttpServletRequest;
import java.io.*;
import java.math.BigDecimal;
+import java.nio.charset.StandardCharsets;
import java.util.*;
@Controller
@@ -101,6 +115,9 @@
@Resource
private TaoBaoCouponCacheService taoBaoCouponCacheService;
+
+ @Resource
+ private RabbitTemplate rabbitTemplate;
@RequestMapping(value = "kefu")
public void kefu(HttpServletRequest request, PrintWriter out) {
@@ -328,29 +345,51 @@
out.println(array.toString());
}
+ @Resource
+ private MsgOrderDetailService msgOrderDetailService;
+
+ @Resource
+ private PushService pushService;
+
+ @Resource
+ private UserInfoService userInfoService;
+
+ @RequestMapping(value = "pushOrderMsg")
+ public void pushOrderMsg(String id, PrintWriter out) throws UserInfoException, PushException {
+ MsgOrderDetail msgOrderDetail = msgOrderDetailService.selectByPrimaryKey(Long.parseLong(id));
+ if (msgOrderDetail == null) {
+ out.print("ID涓嶅瓨鍦�");
+ return;
+ }
+ UserInfo userInfo = userInfoService.getUserInfo(msgOrderDetail.getUser().getId());
+ PushContentDTO dto = PushMsgFactory.createFanLiOrderStatisticed(msgOrderDetail.getOrderType(), msgOrderDetail.getOrderId(), msgOrderDetail.getHongBaoMoney());
+ pushService.pushZNX(userInfo.getId(), dto.getTitle(), dto.getContent(), null, null, userInfo.getSystem());
+ }
+
@RequestMapping(value = "pushOppo")
public void pushOppo(String registerId, PrintWriter out) {
List<String> registerIds = new ArrayList<>();
registerIds.add(registerId);
+ String androidBaseActivity = "";
try {
- OPPOPushUtil.pushUrl(registerIds, "娴嬭瘯缃戦〉鎺ㄩ��", "娴嬭瘯缃戦〉鎺ㄩ�佸唴瀹�", "http://www.baidu.com");
+ OPPOPushUtil.pushUrl(registerIds, "娴嬭瘯缃戦〉鎺ㄩ��", "娴嬭瘯缃戦〉鎺ㄩ�佸唴瀹�", "http://www.baidu.com", androidBaseActivity);
} catch (PushException e) {
e.printStackTrace();
}
try {
- OPPOPushUtil.pushGoods(registerIds, "娴嬭瘯鍟嗗搧缃戦〉鎺ㄩ��", "娴嬭瘯鍟嗗搧鎺ㄩ�佸唴瀹�", 1, 577628549116L);
+ OPPOPushUtil.pushGoods(registerIds, "娴嬭瘯鍟嗗搧缃戦〉鎺ㄩ��", "娴嬭瘯鍟嗗搧鎺ㄩ�佸唴瀹�", 1, 577628549116L+"", androidBaseActivity);
} catch (PushException e) {
e.printStackTrace();
}
try {
- OPPOPushUtil.pushUserSignInNotification(registerIds, "娴嬭瘯绛惧埌鎺ㄩ��", "娴嬭瘯绛惧埌鎺ㄩ��");
+ OPPOPushUtil.pushUserSignInNotification(registerIds, "娴嬭瘯绛惧埌鎺ㄩ��", "娴嬭瘯绛惧埌鎺ㄩ��", androidBaseActivity);
} catch (PushException e) {
e.printStackTrace();
}
try {
- OPPOPushUtil.pushWelfareCenter(registerIds, "娴嬭瘯绂忓埄涓績鎺ㄩ��", "娴嬭瘯绂忓埄涓績鎺ㄩ��");
+ OPPOPushUtil.pushWelfareCenter(registerIds, "娴嬭瘯绂忓埄涓績鎺ㄩ��", "娴嬭瘯绂忓埄涓績鎺ㄩ��", androidBaseActivity);
} catch (PushException e) {
e.printStackTrace();
}
@@ -379,7 +418,7 @@
}
@RequestMapping("getTBGoodsCate")
- public void getTaoBaoGoodsCat(Long id, PrintWriter out) {
+ public void getTaoBaoGoodsCat(String id, PrintWriter out) {
TaoBaoGoodsBrief goods = null;
try {
goods = TaoKeApiUtil.getSimpleGoodsInfo(id);
@@ -403,9 +442,14 @@
out.print(data.toString());
}
- @RequestMapping("log")
- public void log(PrintWriter out) {
+ Logger testLogger= LoggerFactory.getLogger("testLog");
+
+ @RequestMapping("wx")
+ public void log(HttpServletRequest request, PrintWriter out) {
LogManager.getLogger(LogType.taobaoAuth).info("123123123");
+ String content = WXUtil.getContent(request);
+ testLogger.info("wx: "+content);
+
}
@@ -414,8 +458,39 @@
TaoBaoCouponCache cache = new TaoBaoCouponCache();
cache.setActivityId("123123123");
cache.setPid("mm_12_12_12");
- cache.setAuctionId(123123L);
+ cache.setAuctionId(123123L+"");
taoBaoCouponCacheService.save(cache);
}
+ @RequestMapping("email")
+ public void testEmail(PrintWriter out) {
+ MailSenderUtil.sendEmail("1101184511@qq.com", "kuaisheng110@163.com", "CMZASWUPTJSFXCNP", "娴嬭瘯", "娴嬭瘯鍐呭:" + System.currentTimeMillis());
+ out.print("success");
+ }
+
+ @RequestMapping("testRabbit")
+ public void testRabbit(){
+ String msg = "浣犲ソ:"+TimeUtil.getGernalTime(System.currentTimeMillis(),"yyyy-MM-dd HH:mm:ss");
+ // 鍚戦槦鍒楀彂閫佹秷鎭�
+// rabbitTemplate.convertAndSend("order-all-fanli",msg);
+ // 鍚慹xchange鍙戦�佹秷鎭�
+// rabbitTemplate.convertAndSend("topic_place_order", "*", msg);
+
+// Message message = MessageBuilder.withBody(msg.getBytes()).setDeliveryMode(MessageDeliveryMode.PERSISTENT).setExpiration("10000").build();
+ rabbitTemplate.convertAndSend("test_queue",msg);
+ }
+ @RequestMapping("testRabbitDelay")
+ public void testRabbitDelay(){
+ String msg = "杩欐槸娴嬭瘯鐨勪竴鏉″欢鏃舵秷鎭�";
+ int time = 5;
+ MessageProperties messageProperties = new MessageProperties();
+ messageProperties.setHeader("x-delay", 1000 * time);//寤惰繜5绉掕鍒犻櫎
+ Message message = new Message(msg.getBytes(StandardCharsets.UTF_8), messageProperties);
+ rabbitTemplate.convertAndSend("delay_exchange", "delay", message);//浜ゆ崲鏈哄拰璺敱閿繀椤诲拰閰嶇疆鏂囦欢绫讳腑淇濇寔涓�鑷�
+ System.out.println(TimeUtil.getGernalTime(System.currentTimeMillis(),"yyyy-MM-dd HH:mm:ss") + " 鍙戦�佷竴鏉℃秷鎭�");
+ }
+
+
+
+
}
--
Gitblit v1.8.0