From fabd5e0d5ec9642cf1867637d675e5306258f0bf Mon Sep 17 00:00:00 2001 From: Jiang Peng <2622360564@qq.com> Date: Fri, 21 Jun 2024 22:37:40 +0800 Subject: [PATCH] =?UTF-8?q?feat():=E5=AE=8C=E5=96=84=E6=95=85=E9=9A=9C?= =?UTF-8?q?=E6=8A=A5=E8=AD=A6=EF=BC=8Cmq=E7=9B=91=E5=90=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/VehicleController.java | 6 +- ...VehicleMapper.java => Vehicle1Mapper.java} | 2 +- .../business/domain/FaultRecordVo.java | 22 +++ .../muyu-customer-business-server/pom.xml | 15 ++ .../controller/FaultCodeController.java | 12 -- .../controller/FaultRecordController.java | 7 + .../business/mapper/FaultCodeMapper.java | 1 - .../business/mapper/FaultRecordMapper.java | 10 + .../business/mapper/VehicleMapper.java | 1 - .../business/produce/VehicleProducer.java | 185 ++++++++++++++++++ .../rabbit/ConfirmCallbackConfig.java | 48 +++++ .../business/rabbit/RabbitAdminConfig.java | 54 +++++ .../business/rabbit/RabbitmqConfig.java | 16 ++ .../business/rabbit/ReturnCallbackConfig.java | 34 ++++ .../business/service/FaultRecordService.java | 7 + .../service/impl/FaultRecordServiceImpl.java | 22 +++ .../service/impl/VehicleServiceImpl.java | 1 + .../src/main/resources/bootstrap.yml | 13 ++ .../customerBusiness/FaultRecordMapper.xml | 17 ++ 19 files changed, 455 insertions(+), 18 deletions(-) rename muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/mapper/{VehicleMapper.java => Vehicle1Mapper.java} (78%) create mode 100644 muyu-modules/muyu-customer-business/muyu-customer-business-common/src/main/java/com/muyu/customer/business/domain/FaultRecordVo.java create mode 100644 muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/produce/VehicleProducer.java create mode 100644 muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/ConfirmCallbackConfig.java create mode 100644 muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/RabbitAdminConfig.java create mode 100644 muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/RabbitmqConfig.java create mode 100644 muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/ReturnCallbackConfig.java diff --git a/muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/controller/VehicleController.java b/muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/controller/VehicleController.java index 1c709ba..a103f3e 100644 --- a/muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/controller/VehicleController.java +++ b/muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/controller/VehicleController.java @@ -2,7 +2,7 @@ package com.muyu.cloud.many.datasource.controller; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.muyu.cloud.many.datasource.domain.Vehicle; -import com.muyu.cloud.many.datasource.mapper.VehicleMapper; +import com.muyu.cloud.many.datasource.mapper.Vehicle1Mapper; import com.muyu.common.core.domain.Result; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; @@ -20,10 +20,10 @@ import java.util.List; @RequestMapping("/vehicle") public class VehicleController { @Autowired - private VehicleMapper vehicleMapper; + private Vehicle1Mapper vehicle1Mapper; @GetMapping("/list/all") public Result> findAll () { - return Result.success(vehicleMapper.selectList(new QueryWrapper<>())); + return Result.success(vehicle1Mapper.selectList(new QueryWrapper<>())); } } diff --git a/muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/mapper/VehicleMapper.java b/muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/mapper/Vehicle1Mapper.java similarity index 78% rename from muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/mapper/VehicleMapper.java rename to muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/mapper/Vehicle1Mapper.java index d671b6f..7d579e9 100644 --- a/muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/mapper/VehicleMapper.java +++ b/muyu-modules/cloud-modules-many-datasource/src/main/java/com/muyu/cloud/many/datasource/mapper/Vehicle1Mapper.java @@ -8,6 +8,6 @@ import com.muyu.cloud.many.datasource.domain.Vehicle; * * Date 2024/6/4 14:07 */ -public interface VehicleMapper extends BaseMapper { +public interface Vehicle1Mapper extends BaseMapper { } diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-common/src/main/java/com/muyu/customer/business/domain/FaultRecordVo.java b/muyu-modules/muyu-customer-business/muyu-customer-business-common/src/main/java/com/muyu/customer/business/domain/FaultRecordVo.java new file mode 100644 index 0000000..b9a71c3 --- /dev/null +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-common/src/main/java/com/muyu/customer/business/domain/FaultRecordVo.java @@ -0,0 +1,22 @@ +package com.muyu.customer.business.domain; + + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * BingRui.Hou + * + * @Description 描述 + * @ClassName FaultRecordVo + * @Date 2024/06/21 11:44 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class FaultRecordVo { + private String faultCode; + private String vin; + private String count; +} diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/pom.xml b/muyu-modules/muyu-customer-business/muyu-customer-business-server/pom.xml index 72d1dec..4a9814f 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/pom.xml +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/pom.xml @@ -24,6 +24,11 @@ muyu-customer-business-common 3.6.3 + + com.muyu + cloud-modules-many-datasource + 3.6.3 + com.alibaba.cloud @@ -36,6 +41,11 @@ spring-cloud-starter-alibaba-nacos-config + + org.springframework.boot + spring-boot-starter-amqp + + com.alibaba.cloud @@ -84,6 +94,11 @@ com.muyu muyu-common-swagger + + org.springframework.amqp + spring-amqp + 2.4.1 + diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/controller/FaultCodeController.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/controller/FaultCodeController.java index d6d4cb4..a3569e6 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/controller/FaultCodeController.java +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/controller/FaultCodeController.java @@ -109,16 +109,4 @@ public class FaultCodeController extends BaseController { return toAjax(faultCodeService.removeBatchByIds(ids)); } - /** - *删除车辆故障码 - */ - @RequiresPermissions("customerBusiness:faultCode:delete") - @Log(title = "车辆故障码",businessType = BusinessType.DELETE) - @DeleteMapping("/{ids}") - @ApiOperation("删除车辆故障码") - @ApiImplicitParam(name = "id",value = "id",required = true,dataType = "Long",paramType = "path",dataTypeClass = String.class,example = "1,2,3,4") - public Result delete(@PathVariable List ids){ - return toAjax(faultCodeService.removeBatchByIds(ids)); - } - } diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/controller/FaultRecordController.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/controller/FaultRecordController.java index a478cb9..50335ac 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/controller/FaultRecordController.java +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/controller/FaultRecordController.java @@ -8,6 +8,7 @@ import com.muyu.common.log.annotation.Log; import com.muyu.common.log.enums.BusinessType; import com.muyu.common.security.annotation.RequiresPermissions; import com.muyu.customer.business.domain.FaultRecord; +import com.muyu.customer.business.domain.FaultRecordVo; import com.muyu.customer.business.domain.req.FaultRecordEditReq; import com.muyu.customer.business.domain.req.FaultRecordQueryReq; import com.muyu.customer.business.domain.req.FaultRecordSaveReq; @@ -105,5 +106,11 @@ public class FaultRecordController extends BaseController { return toAjax(faultRecordService.removeBatchByIds(ids)); } + @Log(title = "柱状图",businessType = BusinessType.DELETE) + @GetMapping("/countList") + @ApiOperation("柱状图展示") + public Result> countList( ) { + return Result.success(faultRecordService.countList()); + } } diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/FaultCodeMapper.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/FaultCodeMapper.java index 7ee1cd1..912d222 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/FaultCodeMapper.java +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/FaultCodeMapper.java @@ -1,6 +1,5 @@ package com.muyu.customer.business.mapper; -import java.util.List; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.muyu.customer.business.domain.FaultCode; diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/FaultRecordMapper.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/FaultRecordMapper.java index 1bf97c8..ee41268 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/FaultRecordMapper.java +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/FaultRecordMapper.java @@ -2,6 +2,9 @@ package com.muyu.customer.business.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.muyu.customer.business.domain.FaultRecord; +import com.muyu.customer.business.domain.FaultRecordVo; + +import java.util.List; /** * 故障记录Mapper接口 @@ -10,4 +13,11 @@ import com.muyu.customer.business.domain.FaultRecord; * @date 2024-06-20 */ public interface FaultRecordMapper extends BaseMapper { + + void updateByFaultRecord(FaultRecord build); + + FaultRecord getByFaultRecord(FaultRecord faultRecord); + + List countList(); + } diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/VehicleMapper.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/VehicleMapper.java index aa124e4..3d0b558 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/VehicleMapper.java +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/mapper/VehicleMapper.java @@ -1,6 +1,5 @@ package com.muyu.customer.business.mapper; -import java.util.List; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.muyu.customer.business.domain.Vehicle; diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/produce/VehicleProducer.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/produce/VehicleProducer.java new file mode 100644 index 0000000..8658c41 --- /dev/null +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/produce/VehicleProducer.java @@ -0,0 +1,185 @@ +package com.muyu.customer.business.produce; + +import com.alibaba.fastjson.JSON; +import com.muyu.cloud.many.datasource.config.holder.DynamicDataSourceHolder; +import com.muyu.customer.business.domain.FaultRecord; +import com.muyu.customer.business.service.FaultRecordService; +import com.rabbitmq.client.AMQP; +import lombok.extern.log4j.Log4j2; +//import org.apache.logging.log4j.message.Message; +import org.springframework.amqp.rabbit.annotation.Queue; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.stereotype.Component; +import org.springframework.amqp.core.Message; +import com.rabbitmq.client.Channel; +import java.io.IOException; +//import java.nio.channels.Channel; + +@Component +@Log4j2 +public class VehicleProducer { + + @Autowired + private RedisTemplate redisTemplate; + + @Autowired + private FaultRecordService faultRecordService; + + //调用注解 添加队列名称 + + @RabbitListener(queuesToDeclare = {@Queue(name = "queue_astatus_abnormal")}) + + public void smsConfigStart(String msg, Message message, Channel channel){ + + //获取消息的ID + String messageId = message.getMessageProperties().getMessageId(); + + try { + + Long count = redisTemplate.opsForSet().add("messageId", messageId); + + if (count==1) { + + log.info("开始消费！{}", msg); + + FaultRecord faultRecord = JSON.parseObject(msg, FaultRecord.class); + + //判断车辆属于哪个企业 + + String s = redisTemplate.opsForValue().get(faultRecord.getVin()+"1"); + + //选择数据源，切换数据源， + + DynamicDataSourceHolder.setDynamicDataSourceKey("test_"+s); + + // 进行添加故障表 + + FaultRecord build = FaultRecord + + .builder() + + .faultCode(faultRecord.getFaultCode()) + + .vin(faultRecord.getVin()) + + .startTime(faultRecord.getStartTime()).build(); + + faultRecordService.save(build); + + // 移除数据源， + + DynamicDataSourceHolder.removeDynamicDataSourceKey(); + + channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); + + log.info("消费成功！数据源为：{}",message); + + } + + } catch (IOException e) { + + log.info("消费失败，{}",e.getMessage()); + + try { + + //回退消息 + + channel.basicReject(message.getMessageProperties().getDeliveryTag(),false); + + log.info("回退成功"); + + }catch (IOException ex){ + + log.info("回退失败:{}",ex.getMessage()); + + } + + throw new RuntimeException(e); + + } + + } + + @RabbitListener(queuesToDeclare = {@Queue(name = "")}) + + public void smsConfigEnt(String msg, Message message, Channel channel){ + + //获取消息的ID + + String messageId = message.getMessageProperties().getMessageId(); + + try { + + //添加消息id到redis set集合中 添加成功返回1 表示未消费 添加失败返回0 表示已消费 + + Long count = redisTemplate.opsForSet().add("messageId", messageId); + + //添加成功 正常消费信息 + + if (count == 1) { + + log.info("开始消费:{}",msg); + + FaultRecord faultRecord = JSON.parseObject(msg, FaultRecord.class); + + //判断车辆属于哪个企业 + + String s = redisTemplate.opsForValue().get(faultRecord.getVin()+"1"); + + //选择数据源，切换数据源， + + DynamicDataSourceHolder.setDynamicDataSourceKey("test_"+s); + + // 进行查询故障表 + + FaultRecord faultRecordOne = faultRecordService.getByFaultRecord(faultRecord); + + log.info("查询到的故障为：{}",faultRecordOne); + + faultRecordOne.setEndTime(faultRecord.getEndTime()); + + // 进行修改故障表 + + faultRecordService.updateByFaultRecord(faultRecordOne); + + // 移除数据源， + + DynamicDataSourceHolder.removeDynamicDataSourceKey(); + + //确认消费 + + channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); + + log.info("消费成功"); + + } + + } catch (Exception e) { + + //删除队列ID + + log.info("消费失败，{}",e.getMessage()); + + try { + + //回退消息 + + channel.basicReject(message.getMessageProperties().getDeliveryTag(),false); + + log.info("回退消息"); + + } catch (IOException ex) { + + //回退失败 + + log.info("回退失败"); + + } + + } + + } + +} diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/ConfirmCallbackConfig.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/ConfirmCallbackConfig.java new file mode 100644 index 0000000..4aa9677 --- /dev/null +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/ConfirmCallbackConfig.java @@ -0,0 +1,48 @@ +package com.muyu.customer.business.rabbit; + +import org.springframework.amqp.rabbit.connection.CorrelationData; +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; + +/** + * 消息发送确认配置 消息发送到交换机的确认 + */ +@Component +public class ConfirmCallbackConfig implements RabbitTemplate.ConfirmCallback { + + @Autowired + private RabbitTemplate rabbitTemplate; + + /** + * @PostContruct是spring框架的注解，在⽅法上加该注解会在项⽬启动的时候执⾏该⽅法，也可以理解为在spring容器初始化的时候执 + * @PostConstruct bean 被初始化的时候执行的方法的注解 + * @PreDestory bean 被销毁的时候执行的方法的注解 + */ + @PostConstruct + public void init() { + rabbitTemplate.setConfirmCallback(this); + } + + /** + * 交换机不管是否收到消息的一个回调方法 + * + * @param correlationData 消息相关数据 + * @param ack 交换机是否收到消息 + * @param cause 失败原因 + */ + @Override + public void confirm(CorrelationData correlationData, boolean ack, String cause) { + if (ack) { + // 消息投递到 broker 的状态，true表示成功 + System.out.println("消息发送成功！"); + } else { + // 发送异常 + System.out.println("发送异常原因 = " + cause); + // TODO 可以将消息 内容 以及 失败的原因 记录到 日志表中 + } + } + +} diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/RabbitAdminConfig.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/RabbitAdminConfig.java new file mode 100644 index 0000000..aae02cc --- /dev/null +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/RabbitAdminConfig.java @@ -0,0 +1,54 @@ +package com.muyu.customer.business.rabbit; + +import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; +import org.springframework.amqp.rabbit.connection.ConnectionFactory; +import org.springframework.amqp.rabbit.core.RabbitAdmin; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * RabbitAdmin是RabbitMQ的一个Java客户端库，它提供了管理RabbitMQ资源的功能。它是通过与RabbitMQ服务器进行交互来执行管理操作的。 + */ +@Configuration +public class RabbitAdminConfig { + + @Value("${spring.rabbitmq.host}") + private String host; + @Value("${spring.rabbitmq.username}") + private String username; + @Value("${spring.rabbitmq.password}") + private String password; + @Value("${spring.rabbitmq.virtualhost}") + private String virtualhost; + + /** + * 构建 RabbitMQ的连接工厂 + * + * @return + */ + @Bean + public CachingConnectionFactory connectionFactory() { + CachingConnectionFactory connectionFactory = new CachingConnectionFactory(); + connectionFactory.setAddresses(host); + connectionFactory.setUsername(username); + connectionFactory.setPassword(password); + connectionFactory.setVirtualHost(virtualhost); + // 配置发送确认回调时，次配置必须配置，否则即使在RabbitTemplate配置了ConfirmCallback也不会生效 + connectionFactory.setPublisherConfirmType(CachingConnectionFactory.ConfirmType.CORRELATED); + connectionFactory.setPublisherReturns(true); + return connectionFactory; + } + + /** + * 自己初始化 RabbitAdmin + * @param connectionFactory + * @return + */ + @Bean + public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) { + RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory); + rabbitAdmin.setAutoStartup(true); + return rabbitAdmin; + } +} diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/RabbitmqConfig.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/RabbitmqConfig.java new file mode 100644 index 0000000..e1a79f1 --- /dev/null +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/RabbitmqConfig.java @@ -0,0 +1,16 @@ +package com.muyu.customer.business.rabbit; + + +import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; +import org.springframework.amqp.support.converter.MessageConverter; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +@Configuration +public class RabbitmqConfig { + // 消息转换配置 + @Bean + public MessageConverter jsonMessageConverter() { + return new Jackson2JsonMessageConverter(); + } +} diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/ReturnCallbackConfig.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/ReturnCallbackConfig.java new file mode 100644 index 0000000..0376092 --- /dev/null +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/rabbit/ReturnCallbackConfig.java @@ -0,0 +1,34 @@ +package com.muyu.customer.business.rabbit; + +import org.springframework.amqp.core.ReturnedMessage; +import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.PostConstruct; + +/** + * 消息发送到队列的确认 一旦消息发送到队列失败 则会执行 returnedMessage 方法 + */ +@Component +public class ReturnCallbackConfig implements RabbitTemplate.ReturnsCallback { + + @Autowired + private RabbitTemplate rabbitTemplate; + + @PostConstruct // @PostContruct是spring框架的注解，在⽅法上加该注解会在项⽬启动的时候执⾏该⽅法，也可以理解为在spring容器初始化的时候执 + public void init() { + rabbitTemplate.setReturnsCallback(this); + } + + /** + * 消息发送到 队列失败 执行的 方法 + * @param returnedMessage the returned message and metadata. + */ + @Override + public void returnedMessage(ReturnedMessage returnedMessage) { + System.out.println("消息" + returnedMessage.getMessage().toString() + "被交换机" + returnedMessage.getExchange() + "回退！" + + "退回原因为：" + returnedMessage.getReplyText()); + // 回退了所有的信息，可做补偿机制 记录到 数据库 + } +} diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/FaultRecordService.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/FaultRecordService.java index 97068e4..3e0a58f 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/FaultRecordService.java +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/FaultRecordService.java @@ -2,6 +2,7 @@ package com.muyu.customer.business.service; import com.baomidou.mybatisplus.extension.service.IService; import com.muyu.customer.business.domain.FaultRecord; +import com.muyu.customer.business.domain.FaultRecordVo; import java.util.List; @@ -21,4 +22,10 @@ public interface FaultRecordService extends IService { */ public List list(FaultRecord faultRecord); + void updateByFaultRecord(FaultRecord build); + + FaultRecord getByFaultRecord(FaultRecord faultRecord); + + List countList(); + } diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/impl/FaultRecordServiceImpl.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/impl/FaultRecordServiceImpl.java index c00629d..a427c16 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/impl/FaultRecordServiceImpl.java +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/impl/FaultRecordServiceImpl.java @@ -4,10 +4,12 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.muyu.common.core.utils.ObjUtils; import com.muyu.customer.business.domain.FaultRecord; +import com.muyu.customer.business.domain.FaultRecordVo; import com.muyu.customer.business.mapper.FaultRecordMapper; import com.muyu.customer.business.service.FaultRecordService; import lombok.experimental.SuperBuilder; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @@ -15,6 +17,10 @@ import java.util.List; @Slf4j @Service public class FaultRecordServiceImpl extends ServiceImpl implements FaultRecordService { + + @Autowired + private FaultRecordMapper faultRecordMapper; + /** * 查询故障记录列表 * @@ -40,4 +46,20 @@ public class FaultRecordServiceImpl extends ServiceImpl countList() { + return faultRecordMapper.countList(); + } + + } diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/impl/VehicleServiceImpl.java b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/impl/VehicleServiceImpl.java index 0b78ed6..30c10bc 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/impl/VehicleServiceImpl.java +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/java/com/muyu/customer/business/service/impl/VehicleServiceImpl.java @@ -4,6 +4,7 @@ import java.util.List; import com.muyu.common.core.utils.ObjUtils; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.muyu.customer.business.mapper.VehicleMapper; import com.muyu.customer.business.domain.Vehicle; diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/resources/bootstrap.yml b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/resources/bootstrap.yml index 01c25bc..84cf749 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/resources/bootstrap.yml @@ -4,6 +4,19 @@ server: # Spring spring: + rabbitmq: + username: guest + password: guest + virtual-host: / + port: 5672 + host: 101.34.248.9 + listener: + simple: + prefetch: 1 + publisher-confirm-type: correlated + publisher-returns: true + main: + allow-circular-references: true application: # 应用名称 name: muyu-customer-business diff --git a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/resources/mapper/customerBusiness/FaultRecordMapper.xml b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/resources/mapper/customerBusiness/FaultRecordMapper.xml index 94abd44..c6cb567 100644 --- a/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/resources/mapper/customerBusiness/FaultRecordMapper.xml +++ b/muyu-modules/muyu-customer-business/muyu-customer-business-server/src/main/resources/mapper/customerBusiness/FaultRecordMapper.xml @@ -17,4 +17,21 @@ select id, fault_code, vin, start_time, end_time, fault_level, fault_handle from fault_record + + + update fault_record set end_time=#{endTime} where id=#{id} + + + + + +