From bc30484ac7a5feea3162d56b9ff76a9c976aba48 Mon Sep 17 00:00:00 2001 From: liusheng <337615773@qq.com> Date: 星期四, 25 四月 2024 15:06:41 +0800 Subject: [PATCH] 代码提交 --- ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/IvrLibaTemplateController.java | 33 ++++++++++++++++++++++++++++----- 1 files changed, 28 insertions(+), 5 deletions(-) diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/IvrLibaTemplateController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/IvrLibaTemplateController.java index 250db7d..8500f89 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/IvrLibaTemplateController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/IvrLibaTemplateController.java @@ -1,5 +1,7 @@ package com.ruoyi.web.controller.smartor; +import com.alibaba.fastjson2.JSON; +import com.google.gson.Gson; import com.ruoyi.common.annotation.Log; import com.ruoyi.common.core.controller.BaseController; import com.ruoyi.common.core.domain.AjaxResult; @@ -7,9 +9,11 @@ import com.ruoyi.common.enums.BusinessType; import com.ruoyi.common.exception.base.BaseException; import com.ruoyi.common.utils.poi.ExcelUtil; +import com.smartor.config.PhoneUtils; import com.smartor.config.RabbitMqConfig; import com.smartor.domain.IvrLibaTemplate; import com.smartor.domain.IvrLibaTemplateVO; +import com.smartor.domain.Test1Vo; import com.smartor.service.IIvrLibaTemplateService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; @@ -17,6 +21,7 @@ import org.apache.commons.lang3.ObjectUtils; import org.springframework.amqp.AmqpException; import org.springframework.amqp.core.Message; +import org.springframework.amqp.core.MessageBuilder; import org.springframework.amqp.core.MessagePostProcessor; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; @@ -24,7 +29,9 @@ import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletResponse; +import java.util.HashMap; import java.util.List; +import java.util.Map; /** * 闅忚妯℃澘搴揅ontroller @@ -42,6 +49,9 @@ @Autowired private RabbitTemplate rabbitTemplate; + + @Autowired + private PhoneUtils phoneUtils; /** * 鏌ヨ妯℃澘搴撳垪琛� @@ -139,8 +149,8 @@ /** * 寮�濮嬫墽琛�(娴嬭瘯鐢�) */ - @GetMapping("/queryRabbitmq") - public AjaxResult queryRabbitmq(@RequestParam("routintKey") String routintKey, @RequestParam("content") String content, @RequestParam("times") Long times) { + @PostMapping("/queryRabbitmq") + public AjaxResult queryRabbitmq(@RequestBody Test1Vo test1Vo) { // rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_NAME, "phone.001", "娴嬭瘯鏁版嵁001"); // rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_NAME, "phone.002", "娴嬭瘯鏁版嵁002"); @@ -156,12 +166,25 @@ // }); log.info("-------------鍚姩鍜ㄨ搴旂瓟瓒呮椂鎻愰啋寤惰繜闃熷垪-------------"); - this.rabbitTemplate.convertAndSend(RabbitMqConfig.phone_exchange, RabbitMqConfig.routing_key, content, message -> { + String data = JSON.toJSONString(test1Vo.getTestVo()); + String substring = data.substring(1, data.length() - 1); + + this.rabbitTemplate.convertAndSend(RabbitMqConfig.phone_exchange, RabbitMqConfig.routing_key, substring, message -> { //娉ㄦ剰杩欓噷鏃堕棿鍙互浣縧ong锛岃�屼笖鏄缃甴eader - message.getMessageProperties().setHeader("x-delay", times); + message.getMessageProperties().setHeader("x-delay", test1Vo.getTimes()); return message; }); - log.info("-------------寤惰繜闃熷垪{}ms鍚庢墽琛�.-------------", times); + log.info("-------------寤惰繜闃熷垪{}ms鍚庢墽琛�.-------------", test1Vo.getTimes()); return success(); } + + + /** + * 寮�濮嬫墽琛�(娴嬭瘯鐢�) + */ + @GetMapping("/addUser2") + public AjaxResult addUser2() { + String s = phoneUtils.ob("","","","","","","","3001","",true); + return AjaxResult.success(s); + } } -- Gitblit v1.9.3