From fdf1b9c1e4489a0c2615fa596268b2f71fad7b4c Mon Sep 17 00:00:00 2001 From: liusheng <337615773@qq.com> Date: 星期一, 15 四月 2024 09:08:10 +0800 Subject: [PATCH] 代码提交 --- ruoyi-admin/src/main/java/com/ruoyi/web/controller/smartor/IvrLibaTemplateController.java | 183 ++++++++++++++++++++++++++++++--------------- 1 files changed, 123 insertions(+), 60 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 35963a7..250db7d 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,104 +1,167 @@ -package com.smartor.controller; +package com.ruoyi.web.controller.smartor; -import java.util.List; -import javax.servlet.http.HttpServletResponse; -import org.springframework.security.access.prepost.PreAuthorize; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.PutMapping; -import org.springframework.web.bind.annotation.DeleteMapping; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; import com.ruoyi.common.annotation.Log; import com.ruoyi.common.core.controller.BaseController; import com.ruoyi.common.core.domain.AjaxResult; -import com.ruoyi.common.enums.BusinessType; -import com.smartor.domain.IvrLibaTemplate; -import com.smartor.service.IIvrLibaTemplateService; -import com.ruoyi.common.utils.poi.ExcelUtil; import com.ruoyi.common.core.page.TableDataInfo; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.common.exception.base.BaseException; +import com.ruoyi.common.utils.poi.ExcelUtil; +import com.smartor.config.RabbitMqConfig; +import com.smartor.domain.IvrLibaTemplate; +import com.smartor.domain.IvrLibaTemplateVO; +import com.smartor.service.IIvrLibaTemplateService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.ObjectUtils; +import org.springframework.amqp.AmqpException; +import org.springframework.amqp.core.Message; +import org.springframework.amqp.core.MessagePostProcessor; +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.web.bind.annotation.*; + +import javax.servlet.http.HttpServletResponse; +import java.util.List; /** - * 璇濇湳妯℃澘搴揅ontroller - * - * @author smartor - * @date 2023-03-22 + * 闅忚妯℃澘搴揅ontroller + * + * @author ruoyi + * @date 2023-12-23 */ +@Slf4j +@Api(description = "闅忚妯℃澘搴�") @RestController -@RequestMapping("/smartor/ivrtemplate") -public class IvrLibaTemplateController extends BaseController -{ +@RequestMapping("/smartor/template") +public class IvrLibaTemplateController extends BaseController { @Autowired private IIvrLibaTemplateService ivrLibaTemplateService; + @Autowired + private RabbitTemplate rabbitTemplate; + /** - * 鏌ヨ璇濇湳妯℃澘搴撳垪琛� + * 鏌ヨ妯℃澘搴撳垪琛� */ - @PreAuthorize("@ss.hasPermi('smartor:ivrtemplate:list')") - @GetMapping("/list") - public TableDataInfo list(IvrLibaTemplate ivrLibaTemplate) - { + @ApiOperation("鏌ヨ闅忚妯℃澘搴撳垪琛�") + @PreAuthorize("@ss.hasPermi('smartor:template:list')") + @PostMapping("/list") + public TableDataInfo list(@RequestBody IvrLibaTemplate ivrLibaTemplate) { startPage(); List<IvrLibaTemplate> list = ivrLibaTemplateService.selectIvrLibaTemplateList(ivrLibaTemplate); return getDataTable(list); } /** - * 瀵煎嚭璇濇湳妯℃澘搴撳垪琛� + * 瀵煎嚭妯℃澘搴撳垪琛� */ - @PreAuthorize("@ss.hasPermi('smartor:ivrtemplate:export')") - @Log(title = "璇濇湳妯℃澘搴�", businessType = BusinessType.EXPORT) + @ApiOperation("瀵煎嚭闅忚妯℃澘搴撳垪琛�") + @PreAuthorize("@ss.hasPermi('smartor:template:export')") + @Log(title = "妯℃澘搴�", businessType = BusinessType.EXPORT) @PostMapping("/export") - public void export(HttpServletResponse response, IvrLibaTemplate ivrLibaTemplate) - { + public void export(HttpServletResponse response, IvrLibaTemplate ivrLibaTemplate) { List<IvrLibaTemplate> list = ivrLibaTemplateService.selectIvrLibaTemplateList(ivrLibaTemplate); ExcelUtil<IvrLibaTemplate> util = new ExcelUtil<IvrLibaTemplate>(IvrLibaTemplate.class); - util.exportExcel(response, list, "璇濇湳妯℃澘搴撴暟鎹�"); + util.exportExcel(response, list, "妯℃澘搴撴暟鎹�"); } /** - * 鑾峰彇璇濇湳妯℃澘搴撹缁嗕俊鎭� + * 鑾峰彇妯℃澘搴撹缁嗕俊鎭� */ - @PreAuthorize("@ss.hasPermi('smartor:ivrtemplate:query')") - @GetMapping(value = "/{templateID}") - public AjaxResult getInfo(@PathVariable("templateID") String templateID) - { - return success(ivrLibaTemplateService.selectIvrLibaTemplateByTemplateID(templateID)); + @ApiOperation("鑾峰彇闅忚妯℃澘搴撹缁嗕俊鎭�") + @PreAuthorize("@ss.hasPermi('smartor:template:query')") + @GetMapping(value = "/{ID}") + public AjaxResult getInfo(@PathVariable("ID") Long ID) { + return success(ivrLibaTemplateService.selectIvrLibaTemplateByID(ID)); } /** - * 鏂板璇濇湳妯℃澘搴� + * 鏂板妯℃澘搴� */ - @PreAuthorize("@ss.hasPermi('smartor:ivrtemplate:add')") - @Log(title = "璇濇湳妯℃澘搴�", businessType = BusinessType.INSERT) - @PostMapping - public AjaxResult add(@RequestBody IvrLibaTemplate ivrLibaTemplate) - { + @ApiOperation("鏂板闅忚妯℃澘搴�") + @PreAuthorize("@ss.hasPermi('smartor:template:add')") + @Log(title = "妯℃澘搴�", businessType = BusinessType.INSERT) + @PostMapping("/add") + public AjaxResult add(@RequestBody IvrLibaTemplate ivrLibaTemplate) { return toAjax(ivrLibaTemplateService.insertIvrLibaTemplate(ivrLibaTemplate)); } /** - * 淇敼璇濇湳妯℃澘搴� + * 淇敼妯℃澘搴� */ - @PreAuthorize("@ss.hasPermi('smartor:ivrtemplate:edit')") - @Log(title = "璇濇湳妯℃澘搴�", businessType = BusinessType.UPDATE) - @PutMapping - public AjaxResult edit(@RequestBody IvrLibaTemplate ivrLibaTemplate) - { + @ApiOperation("淇敼闅忚妯℃澘搴�") + @PreAuthorize("@ss.hasPermi('smartor:template:edit')") + @Log(title = "妯℃澘搴�", businessType = BusinessType.UPDATE) + @PostMapping("/edit") + public AjaxResult edit(@RequestBody IvrLibaTemplate ivrLibaTemplate) { return toAjax(ivrLibaTemplateService.updateIvrLibaTemplate(ivrLibaTemplate)); } /** - * 鍒犻櫎璇濇湳妯℃澘搴� + * 鍒犻櫎妯℃澘搴� */ - @PreAuthorize("@ss.hasPermi('smartor:ivrtemplate:remove')") - @Log(title = "璇濇湳妯℃澘搴�", businessType = BusinessType.DELETE) - @DeleteMapping("/{templateIDs}") - public AjaxResult remove(@PathVariable String[] templateIDs) - { - return toAjax(ivrLibaTemplateService.deleteIvrLibaTemplateByTemplateIDs(templateIDs)); + @ApiOperation("鍒犻櫎闅忚妯℃澘搴�") + @PreAuthorize("@ss.hasPermi('smartor:template:remove')") + @Log(title = "妯℃澘搴�", businessType = BusinessType.DELETE) + @GetMapping("/remove/{IDs}") + public AjaxResult remove(@PathVariable Long[] IDs) { + return toAjax(ivrLibaTemplateService.deleteIvrLibaTemplateByIDs(IDs)); + } + + /** + * 鏂板鎴栦慨鏀归殢璁挎ā鏉垮簱璇︽儏 + */ + @ApiOperation("鏂板鎴栦慨鏀归殢璁挎ā鏉垮簱璇︽儏") + @PostMapping("/saveOrUpdateScript") + public AjaxResult saveOrUpdateScript(@RequestBody IvrLibaTemplateVO ivrLibaTemplateVO) { + if (ObjectUtils.isEmpty(ivrLibaTemplateVO)) { + throw new BaseException("鍏ュ弬涓虹┖锛岃妫�鏌ュ叆鍙�"); + } + return success(ivrLibaTemplateService.saveOrUpdateTemplate(ivrLibaTemplateVO)); + } + + /** + * 鏌ヨ妯℃澘璇︽儏鏍规嵁鏉′欢 + */ + @ApiOperation("鏌ヨ妯℃澘璇︽儏鏍规嵁鏉′欢") + @PostMapping("/selectInfoByCondition") + public AjaxResult selectInfoByCondition(@RequestBody IvrLibaTemplateVO ivrLibaTemplateVO) { + if (ObjectUtils.isEmpty(ivrLibaTemplateVO)) { + throw new BaseException("鏌ヨ妯℃澘璇︽儏鍏ュ弬涓虹┖锛岃妫�鏌ュ叆鍙�"); + } + return success(ivrLibaTemplateService.selectInfoByCondition(ivrLibaTemplateVO)); + } + + + /** + * 寮�濮嬫墽琛�(娴嬭瘯鐢�) + */ + @GetMapping("/queryRabbitmq") + public AjaxResult queryRabbitmq(@RequestParam("routintKey") String routintKey, @RequestParam("content") String content, @RequestParam("times") Long times) { + +// rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_NAME, "phone.001", "娴嬭瘯鏁版嵁001"); +// rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_NAME, "phone.002", "娴嬭瘯鏁版嵁002"); +// rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_NAME, "phone.003", "娴嬭瘯鏁版嵁003"); +// rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_NAME, routintKey, message, new MessagePostProcessor() { +// @Override +// public Message postProcessMessage(Message message) throws AmqpException { +//// message.getMessageProperties().setDelay(times); +// message.getMessageProperties().getHeaders().put("x-delay", times); +////message.getMessageProperties().setExpiration(); +// return message; +// } +// }); + + log.info("-------------鍚姩鍜ㄨ搴旂瓟瓒呮椂鎻愰啋寤惰繜闃熷垪-------------"); + this.rabbitTemplate.convertAndSend(RabbitMqConfig.phone_exchange, RabbitMqConfig.routing_key, content, message -> { + //娉ㄦ剰杩欓噷鏃堕棿鍙互浣縧ong锛岃�屼笖鏄缃甴eader + message.getMessageProperties().setHeader("x-delay", times); + return message; + }); + log.info("-------------寤惰繜闃熷垪{}ms鍚庢墽琛�.-------------", times); + return success(); } } -- Gitblit v1.9.3