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 |   56 +++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 51 insertions(+), 5 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 d4f5e8e..935194a 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/TestController.java
@@ -33,6 +33,7 @@
 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;
@@ -46,6 +47,11 @@
 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;
@@ -62,6 +68,7 @@
 import javax.servlet.http.HttpServletRequest;
 import java.io.*;
 import java.math.BigDecimal;
+import java.nio.charset.StandardCharsets;
 import java.util.*;
 
 @Controller
@@ -108,6 +115,9 @@
 
     @Resource
     private TaoBaoCouponCacheService taoBaoCouponCacheService;
+
+    @Resource
+    private RabbitTemplate rabbitTemplate;
 
     @RequestMapping(value = "kefu")
     public void kefu(HttpServletRequest request, PrintWriter out) {
@@ -368,7 +378,7 @@
         }
 
         try {
-            OPPOPushUtil.pushGoods(registerIds, "娴嬭瘯鍟嗗搧缃戦〉鎺ㄩ��", "娴嬭瘯鍟嗗搧鎺ㄩ�佸唴瀹�", 1, 577628549116L, androidBaseActivity);
+            OPPOPushUtil.pushGoods(registerIds, "娴嬭瘯鍟嗗搧缃戦〉鎺ㄩ��", "娴嬭瘯鍟嗗搧鎺ㄩ�佸唴瀹�", 1, 577628549116L+"", androidBaseActivity);
         } catch (PushException e) {
             e.printStackTrace();
         }
@@ -408,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);
@@ -432,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);
+
     }
 
 
@@ -443,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