• Day119.尚医通：取消预约(微信退款)、就医提醒(定时任务)、预约统计

    目录

    一、取消预约 (微信退款)

    1、准备工作

    2、保存退款记录接口

    3、实现微信退款

    4、取消预约接口

    5、前端实现

    二、就医提醒

    1、准备工作，搭建模块

    2、在orders模块实现功能

    三、预约统计功能

    1、开发统计每天预约数据接口

    一、取消预约 (微信退款)

    1、准备工作

    1. 确认需求

    （1）未支付取消订单，直接通知医院更新取消预约状态

    （2）已支付取消订单，先退款给用户，然后通知医院更新取消预约状态

    参考文档：https://pay.weixin.qq.com/wiki/doc/api/jsapi.php?chapter=9_4

    该接口需要使用证书，详情参考文档并下载证书

    2. 确认证书

    ​

    3. 添加配置证书地址，解开相关注释

    1. #双向证书
    2. weixin.cert=E:\\apiclient_cert.p12


    ​

    4. 获取支付记录方法

    PaymentService

    1.     //获取支付记录
    2.     PaymentInfo getPaymentInfo(Long orderId, Integer paymentType);
    3.  
    4.     //获取支付记录
    5.     @Override
    6.     public PaymentInfo getPaymentInfo(Long orderId, Integer paymentType) {
    7.         QueryWrapper wrapper = new QueryWrapper<>();
    8.         wrapper.eq("order_id", orderId);
    9.         wrapper.eq("payment_type", paymentType);
    10.         PaymentInfo paymentInfo = baseMapper.selectOne(wrapper);
    11.         return paymentInfo;
    12.     }

    2、保存退款记录接口

    1. 确认库表 refund_info

    ​

    2. 创建相关接口、类

    ​

    3. 接口实现

    1. public interface RefundInfoService extends IService {
    2.     //保存退款记录
    3.     RefundInfo saveRefundInfo(PaymentInfo paymentInfo);
    4. }
    5.  
    6. @Service
    7. public class RefundInfoServiceImpl extends ServiceImpl implements RefundInfoService {
    8.     //保存退款记录
    9.     @Override
    10.     public RefundInfo saveRefundInfo(PaymentInfo paymentInfo) {
    11.         //1.查询退款记录，如果存在直接返回
    12.         QueryWrapper queryWrapper = new QueryWrapper<>();
    13.         queryWrapper.eq("order_id", paymentInfo.getOrderId());
    14.         queryWrapper.eq("payment_type", paymentInfo.getPaymentType());
    15.         RefundInfo refundInfo = baseMapper.selectOne(queryWrapper);
    16.         if(null != refundInfo) return refundInfo;
    17.  
    18.         //2.如果不存在，新增退款记录
    19.         refundInfo = new RefundInfo();
    20.         refundInfo.setCreateTime(new Date());
    21.         refundInfo.setOrderId(paymentInfo.getOrderId());
    22.         refundInfo.setPaymentType(paymentInfo.getPaymentType());
    23.         refundInfo.setOutTradeNo(paymentInfo.getOutTradeNo());
    24.         refundInfo.setRefundStatus(RefundStatusEnum.UNREFUND.getStatus());//1 退款中
    25.         refundInfo.setSubject(paymentInfo.getSubject());
    26.         //paymentInfo.setSubject("test");
    27.         refundInfo.setTotalAmount(paymentInfo.getTotalAmount());
    28.         baseMapper.insert(refundInfo);
    29.         return refundInfo;
    30.     }
    31. }

    3、实现微信退款

    1. 接口实现

    weixinService 

    1.     //退款
    2.     Boolean refund(Long orderId);
    3.  
    4.     //退款
    5.     @Override
    6.     public Boolean refund(Long orderId) {
    7.         try {
    8.             //1.根据参数查询交易记录
    9.             PaymentInfo paymentInfo = paymentService.getPaymentInfo(orderId, PaymentTypeEnum.WEIXIN.getStatus());
    10.             if (paymentInfo == null) {
    11.                 throw new YyghException(20001, "交易记录有误");
    12.             }
    13.  
    14.             //2.根据交易记录添加退款记录，确认退款状态
    15.             RefundInfo refundInfo = refundInfoService.saveRefundInfo(paymentInfo);
    16.             if (refundInfo.getRefundStatus() ==
    17.                     RefundStatusEnum.REFUND.getStatus()) {
    18.                 return true; //已完成退款
    19.             }
    20.  
    21.             //3.封装调用接口参数
    22.             Map paramMap = new HashMap<>(8);
    23.             paramMap.put("appid",ConstantPropertiesUtils.APPID);       //公众账号ID
    24.             paramMap.put("mch_id",ConstantPropertiesUtils.PARTNER);   //商户编号
    25.             paramMap.put("nonce_str",WXPayUtil.generateNonceStr());
    26.             paramMap.put("transaction_id",paymentInfo.getTradeNo()); //微信订单号
    27.             paramMap.put("out_trade_no",paymentInfo.getOutTradeNo()); //商户订单编号
    28.             paramMap.put("out_refund_no","tk"+paymentInfo.getOutTradeNo()); //商户退款单号
    29.             //paramMap.put("total_fee",paymentInfoQuery.getTotalAmount().multiply(new BigDecimal("100")).longValue()+"");
    30.             //paramMap.put("refund_fee",paymentInfoQuery.getTotalAmount().multiply(new BigDecimal("100")).longValue()+"");
    31.             paramMap.put("total_fee","1");  //总金额
    32.             paramMap.put("refund_fee","1"); //退款多少，小于总金额
    33.  
    34.  
    35.             //4.创建客户端(设置url) 参考文档
    36.             HttpClient client = new HttpClient("https://api.mch.weixin.qq.com/secapi/pay/refund");
    37.  
    38.             //5.设置参数 (map=>xml)，开启读取证书开关
    39.             String paramXml = WXPayUtil.generateSignedXml(paramMap,ConstantPropertiesUtils.PARTNERKEY);
    40.             client.setXmlParam(paramXml);
    41.             client.setHttps(true);
    42.             client.setCert(true); //开启读取证书开关
    43.             client.setCertPassword(ConstantPropertiesUtils.PARTNER); //整证密码(商户编号)
    44.             //6.客户端发送请求
    45.             client.post();
    46.  
    47.             //7.获取响应，转化响应类型(xml=>map)
    48.             String xml = client.getContent();
    49.             System.out.println("退款xml = " + xml);
    50.             Map resultMap = WXPayUtil.xmlToMap(xml);
    51.  
    52.             //8.如果退款成功，更新退款记录信息
    53.             if (null != resultMap &&
    54.                     WXPayConstants.SUCCESS.equalsIgnoreCase(resultMap.get("result_code"))) {
    55.                 refundInfo.setCallbackTime(new Date());
    56.                 refundInfo.setTradeNo(resultMap.get("refund_id"));//交易编号
    57.                 refundInfo.setRefundStatus(RefundStatusEnum.REFUND.getStatus());//退款编号
    58.                 refundInfo.setCallbackContent(JSONObject.toJSONString(resultMap));//退款状态
    59.                 refundInfoService.updateById(refundInfo);//报文
    60.                 return true;
    61.             }
    62.             return false;
    63.         } catch (Exception e) {
    64.             e.printStackTrace();
    65.         }
    66.         return false;
    67.     }

    4、取消预约接口

    1. OrderController 方法

    *参数：orderId

    *返回值：R.ok()

    1.     @ApiOperation(value = "取消预约")
    2.     @GetMapping("auth/cancelOrder/{orderId}")
    3.     public R cancelOrder(
    4.             @ApiParam(name = "orderId", value = "订单id", required = true)
    5.             @PathVariable("orderId") Long orderId) {
    6.  
    7.         Boolean flag = orderService.cancelOrder(orderId);
    8.         return R.ok().data("flag",flag);
    9.     }

    2. service

    注释掉医院取消预约 校验签名

    ​

    1.     //取消预约
    2.     @Override
    3.     public Boolean cancelOrder(Long orderId) {
    4.         //1.查询订单信息
    5.         OrderInfo orderInfo = baseMapper.selectById(orderId);
    6.         if(orderInfo==null){
    7.             throw new YyghException(20001,"订单信息有误");
    8.         }
    9.  
    10.         //2.判断是否已过退号时间
    11.         DateTime quitDateTime = new DateTime(orderInfo.getQuitTime());
    12.         if(quitDateTime.isBeforeNow()){
    13.             throw new YyghException(20001,"已过取消预约截止时间");
    14.         }
    15.  
    16.         //3.调用医院系统接口，取消预约
    17.         Map reqMap = new HashMap<>();
    18.         reqMap.put("hoscode",orderInfo.getHoscode());
    19.         reqMap.put("hosRecordId",orderInfo.getHosRecordId());
    20.         reqMap.put("timestamp", HttpRequestHelper.getTimestamp());
    21.         reqMap.put("sign", "");
    22.  
    23.         JSONObject result = HttpRequestHelper.sendRequest(reqMap, "http://localhost:9998/order/updateCancelStatus");
    24.  
    25.         //4.医院取消预约成功
    26.         if(result.getInteger("code")!=200){
    27.             throw new YyghException(20001,"取消预约失败");
    28.         }else {
    29.             //判断是否已支付
    30.             if(orderInfo.getOrderStatus() == OrderStatusEnum.PAID.getStatus()) {
    31.                 //5.如果已支付，调用微信退款
    32.                 Boolean refund = weixinService.refund(orderId);
    33.                 if(!refund){
    34.                     throw new YyghException(20001,"微信退款失败");
    35.                 }
    36.             }
    37.             //6.更新订单状态
    38.             orderInfo.setOrderStatus(OrderStatusEnum.CANCLE.getStatus());
    39.             this.updateById(orderInfo);
    40.  
    41.             //7.发送MQ消息，更新号源，通知就诊人
    42.             OrderMqVo orderMqVo = new OrderMqVo();
    43.             orderMqVo.setScheduleId(orderInfo.getHosScheduleId());
    44.             orderMqVo.setHoscode(orderInfo.getHoscode());
    45.             //短信提示
    46.             MsmVo msmVo = new MsmVo();
    47.             msmVo.setPhone(orderInfo.getPatientPhone());
    48.             orderMqVo.setMsmVo(msmVo);
    49.             rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_ORDER, MqConst.ROUTING_ORDER, orderMqVo);
    50.             return true;
    51.         }
    52.     }

    3. 改造HospitalReceiver 监听器，判断取消预约还是创建订单

    1. @Component
    2. public class HospitalReceiver {
    3.     @Autowired
    4.     private ScheduleService scheduleService;
    5.     @Autowired
    6.     private RabbitService rabbitService;
    7.     @RabbitListener(bindings = @QueueBinding(
    8.             value = @Queue(value = MqConst.QUEUE_ORDER, durable = "true"),
    9.             exchange = @Exchange(value = MqConst.EXCHANGE_DIRECT_ORDER),
    10.             key = {MqConst.ROUTING_ORDER}
    11.     ))
    12.     public void receiver(OrderMqVo orderMqVo, Message message, Channel channel) throws IOException {
    13.         //1.取出参数
    14.         String hoscode = orderMqVo.getHoscode();
    15.         String hosScheduleId = orderMqVo.getScheduleId();
    16.         Integer reservedNumber = orderMqVo.getReservedNumber();
    17.         Integer availableNumber = orderMqVo.getAvailableNumber();
    18.         MsmVo msmVo = orderMqVo.getMsmVo();
    19.  
    20.         //2.根据参数查询排班信息
    21.         Schedule schedule = scheduleService.getScheduleByIds(hoscode, hosScheduleId);
    22.  
    23.         //2.5判断创建订单,还是取消预约 (剩余预约数是否为空 取消订单医院接口没有返回值)
    24.         if(StringUtils.isEmpty(availableNumber)){
    25.             //取消预约，更新号源
    26.             availableNumber = schedule.getAvailableNumber().intValue() + 1;
    27.             schedule.setAvailableNumber(availableNumber);
    28.         }else {
    29.             //创建订单，更新号源
    30.             schedule.setReservedNumber(reservedNumber);
    31.             schedule.setAvailableNumber(availableNumber);
    32.         }
    33.         //3.更新排班信息
    34.         schedule.setUpdateTime(new Date()); //MongoDB不会自动更新时间
    35.         scheduleService.update(schedule);
    36.  
    37.         //4.发送短信相关MQ消息
    38.         if(msmVo!=null){
    39.             rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_MSM, MqConst.ROUTING_MSM_ITEM, msmVo);
    40.         }
    41.     }
    42. }

    5、前端实现

    1. wx.js 创建API接口方法

    1.   //取消预约订单
    2.   cancelOrder(orderId) {
    3.     return request({
    4.       url: `/api/order/orderInfo/auth/cancelOrder/${orderId}`,
    5.       method: 'get'
    6.     })
    7.   },

    2. JS实现

    1.             //取消预约
    2.             cancelOrder() {
    3.                 this.$confirm('此操作将取消预约，是否继续?', '提示', {
    4.                     confirmButtonText: '确定',
    5.                     cancelButtonText: '取消',
    6.                     type: 'warning'
    7.                 }).then(() => {
    8.                     return weixinApi.cancelOrder(this.orderId).then(response => {
    9.                         this.$message({
    10.                             type: "success",
    11.                             message: "取消预约成功!"
    12.                         })
    13.                         window.location.reload()
    14.                     })
    15.                 }).catch(() => {
    16.                     this.$message({
    17.                         type: "info",
    18.                         message: "已取消操作"
    19.                     })
    20.                 })
    21.             }

    5. 测试，收到微信退款、短信

    二、就医提醒 (定时调度)

    我们通过定时任务，每天8点执行，提醒就诊

    1、准备工作，搭建模块

    1. 新建service_task 模块

    ​

    1.     <dependencies>
    2.         <dependency>
    3.             <groupId>com.atguigugroupId>
    4.             <artifactId>rabbit_utilartifactId>
    5.             <version>0.0.1-SNAPSHOTversion>
    6.         dependency>
    7.     dependencies>
    1. # 服务端口
    2. server.port=8208
    3. # 服务名
    4. spring.application.name=service-task
    5. # 环境设置：dev、test、prod
    6. spring.profiles.active=dev
    7.  
    8. # nacos服务地址
    9. spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
    10.  
    11. #rabbitmq地址
    12. spring.rabbitmq.host=192.168.86.86
    13. spring.rabbitmq.port=5672
    14. spring.rabbitmq.username=guest
    15. spring.rabbitmq.password=guest
    1. @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    2. @EnableDiscoveryClient
    3. @ComponentScan(basePackages = {"com.atguigu"})
    4. public class ServiceTaskApplication {
    5.     public static void main(String[] args) {
    6.         SpringApplication.run(ServiceTaskApplication.class, args);
    7.     }
    8. }

    2. 添加常量配置

    在rabbit-util模块MqConst类添加

    1.     //定时任务
    2.     public static final String EXCHANGE_DIRECT_TASK = "exchange.direct.task";
    3.     public static final String ROUTING_TASK_8 = "task.8";
    4.     //队列
    5.     public static final String QUEUE_TASK_8 = "queue.task.8";

    3. 七域表达式 (七个时间区域)

    在线Cron表达式生成器

    ​

    4. ScheduledTask 实现

    1. @Component
    2. @EnableScheduling //开启定时任务
    3. public class ScheduledTask {
    4.  
    5.     @Autowired
    6.     private RabbitService rabbitService;
    7.     
    8.     //@Scheduled(cron = "0 0 8 * * ?")
    9.     @Scheduled(cron = "0/5 * * * * ?")
    10.     public void test() {
    11.         System.out.println("定时任务启动");
    12.     }
    13.     
    14.     //每天8点执行 提醒就诊
    15.     @Scheduled(cron = "0 0 8 * * ?")
    16.     public void task1() {
    17.         System.out.println(new Date().toLocaleString());
    18.         rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_TASK, MqConst.ROUTING_TASK_8, "");
    19.     }
    20. }

    2、在orders模块实现功能

    1. OrderService 添加方法 就诊提醒

    1.     //就诊提醒
    2.     void patientTips();
    3.     //就诊提醒
    4.     @Override
    5.     public void patientTips() {
    6.         //1.查询符合条件订单集合
    7.         QueryWrapper queryWrapper = new QueryWrapper<>();
    8.         queryWrapper.eq("reserve_date",
    9.                 new DateTime().toString("yyyy-MM-dd"));
    10.         List orderInfoList = baseMapper.selectList(queryWrapper);
    11.  
    12.         //2.遍历集合，拼写短信，发送mq消息
    13.         for(OrderInfo orderInfo : orderInfoList) {
    14.             //短信提示
    15.             MsmVo msmVo = new MsmVo();
    16.             msmVo.setPhone(orderInfo.getPatientPhone());
    17.             String reserveDate = new DateTime(orderInfo.getReserveDate()).toString("yyyy-MM-dd") + (orderInfo.getReserveTime()==0 ? "上午": "下午");
    18.             Map param = new HashMap(){{
    19.                 put("title", orderInfo.getHosname()+"|"+orderInfo.getDepname()+"|"+orderInfo.getTitle());
    20.                 put("reserveDate", reserveDate);
    21.                 put("name", orderInfo.getPatientName());
    22.             }};
    23.             msmVo.setParam(param);
    24.             rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_MSM, MqConst.ROUTING_MSM_ITEM, msmVo);
    25.         }

    2. 创建监听器

    receiver/OrderReceiver

    1. @ComponentScan
    2. public class OrderReceiver {
    3.  
    4.     @Autowired
    5.     OrderService orderService;
    6.     
    7.     //定时任务:就医提醒
    8.     @RabbitListener(bindings = @QueueBinding(
    9.             value = @Queue(value = MqConst.QUEUE_TASK_8, durable = "true"),
    10.             exchange = @Exchange(value = MqConst.EXCHANGE_DIRECT_TASK),
    11.             key = {MqConst.ROUTING_TASK_8}
    12.     ))
    13.     public void patientTips(Message message, Channel channel) throws IOException {
    14.         orderService.patientTips();
    15.     }
    16. }

    三、预约统计功能

    我们统计医院每天的预约情况，通过图表的形式展示，统计的数据都来自订单模块，因此我们在该模块封装好数据，在统计模块通过feign的形式获取数据。

    1、分析统计分析方案

    (1) 创建远程接口统计数据

    优势：实时查询

    劣势：影响各个模块使用的性能 (占用服务器资源)

    (2) 每天固定时间，统计分析各个指标数据，生成前一天统计报表

    优势：各个模块使用影响相对小

    劣势：不是实时数据

    (3) 使用脚本语言、数据库编程、数据统计分析

    优势： 数据统计块，对资源占用少

    劣势：不能使用JAVA实现 (学习成本高)

    2、开发统计每天预约数据接口

    1. 查询数据sql

    SELECT o.`reserve_date`,COUNT(o.`id`) FROM order_info o

    WHERE XXXXX

    GROUP BY o.`reserve_date`;

    2. 接口分析

    *参数：OrderCountQueryVo

    *返回值：Map (x轴，y轴数据)

    3. OrderApiController 新增方法

    1.     @ApiOperation(value = "获取订单统计数据")
    2.     @PostMapping("inner/getCountMap")
    3.     public Map getCountMap(@RequestBody OrderCountQueryVo orderCountQueryVo) {
    4.         Map map = orderService.getCountMap(orderCountQueryVo);
    5.         return map;
    6.     }

    4. 实现mapper

    由于MP(MybatisPlus) 无法实现统计sql，需要自行实现

    1. public interface OrderInfoMapper extends BaseMapper {
    2.     //统计每天平台预约数据
    3.     List selectOrderCount(OrderCountQueryVo orderCountQueryVo);
    4. }

    创建 mapper/xml/OrderInfoMapper.xml

    2. mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    3.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    4. <mapper namespace="com.atguigu.yygh.order.mapper.OrderInfoMapper">
    5.     
    6.     <select id="selectOrderCount" resultType="com.atguigu.yygh.vo.order.OrderCountVo">
    7.         select reserve_date as reserveDate, count(reserve_date) as count
    8.         from order_info
    9.         <where>
    10.             <if test="hosname != null and hosname != ''">
    11.                 and hosname like CONCAT('%',#{hosname},'%')
    12.             if>
    13.             <if test="reserveDateBegin != null and reserveDateBegin != ''">
    14.                 and reserve_date >= #{reserveDateBegin}
    15.             if>
    16.             <if test="reserveDateEnd != null and reserveDateEnd != ''">
    17.                 and reserve_date <= #{reserveDateEnd}
    18.             if>
    19.             and is_deleted = 0
    20.         where>
    21.         group by reserve_date
    22.         order by reserve_date
    23.     select>
    24. mapper>

    5. 添加配置

    *service.pom.xml 添加 maven插件，部署xml文件

    2.     <build>
    3.         <plugins>
    4.             <plugin>
    5.                 <groupId>org.springframework.bootgroupId>
    6.                 <artifactId>spring-boot-maven-pluginartifactId>
    7.             plugin>
    8.         plugins>
    9.         <resources>
    10.             <resource>
    11.                 <directory>src/main/javadirectory>
    12.                 <includes>
    13.                     <include>**/*.ymlinclude>
    14.                     <include>**/*.propertiesinclude>
    15.                     <include>**/*.xmlinclude>
    16.                 includes>
    17.                 <filtering>falsefiltering>
    18.             resource>
    19.             <resource>
    20.                 <directory>src/main/resourcesdirectory>
    21.                 <includes> <include>**/*.ymlinclude>
    22.                     <include>**/*.propertiesinclude>
    23.                     <include>**/*.xmlinclude>
    24.                 includes>
    25.                 <filtering>falsefiltering>
    26.             resource>
    27.         resources>
    28.     build>

    *order 配置文件添加相关配置

    1. #mapper xml文件扫描
    2. mybatis-plus.mapper-locations=classpath:com/atguigu/yygh/order/mapper/xml/*.xml

    6. 实现service

    1.     //获取订单统计数据
    2.     @Override
    3.     public Map getCountMap(OrderCountQueryVo orderCountQueryVo) {
    4.         //1.查询统计信息
    5.         List orderCountVoList = baseMapper.selectOrderCount(orderCountQueryVo);
    6.  
    7.         //2.收集x轴、y轴数据
    8.         List dateList   //日期列表
    9.                 =orderCountVoList.stream()
    10.                 .map(OrderCountVo::getReserveDate)
    11.                 .collect(Collectors.toList());
    12.         List countList //统计列表
    13.                 =orderCountVoList.stream()
    14.                 .map(OrderCountVo::getCount)
    15.                 .collect(Collectors.toList());
    16.  
    17.         //3.封装数据返回
    18.         Map map = new HashMap<>();
    19.         map.put("dateList", dateList);
    20.         map.put("countList", countList);
    21.         return map;
    22.     }

    7. 测试

    ​

    3、创建远程调用接口

    1. 创建模块 service_order_client

    2. 创建目录、接口

    1. @FeignClient(value = "service-orders")
    2. @Repository
    3. public interface OrderFeignClient {
    4.     //获取订单统计数据
    5.     @PostMapping("/api/order/orderInfo/inner/getCountMap")
    6.     Map getCountMap(@RequestBody OrderCountQueryVo orderCountQueryVo);
    7.  
    8. }

    4. 创建统计分析模块

    1. service下创建service_statistics模块

    1.     <dependencies>
    2.         <dependency>
    3.             <groupId>com.atguigugroupId>
    4.             <artifactId>service_order_clientartifactId>
    5.             <version>0.0.1-SNAPSHOTversion>
    6.         dependency>
    7.     dependencies>
    1. # 服务端口
    2. server.port=8209
    3. # 服务名
    4. spring.application.name=service-sta
    5. # 环境设置：dev、test、prod
    6. spring.profiles.active=dev
    7.  
    8. # nacos服务地址
    9. spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
    1. @SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
    2. @EnableDiscoveryClient
    3. @EnableFeignClients(basePackages = {"com.atguigu"})
    4. @ComponentScan(basePackages = {"com.atguigu"})
    5. public class ServiceStatisticsApplication {
    6.     public static void main(String[] args) {
    7.         SpringApplication.run(ServiceStatisticsApplication.class, args);
    8.     }
    9. }

    添加网关配置

    1. #设置路由id
    2. spring.cloud.gateway.routes[7].id=service-sta
    3. #设置路由的uri
    4. spring.cloud.gateway.routes[7].uri=lb://service-sta
    5. #设置路由断言,代理servicerId为auth-service的/auth/路径
    6. spring.cloud.gateway.routes[7].predicates= Path=/*/statistics/**

    2. 实现 controller

    1. @Api(tags = "统计管理接口")
    2. @RestController
    3. @RequestMapping("/admin/statistics")
    4. public class StatisticsController {
    5.  
    6.     @Autowired
    7.     private OrderFeignClient orderFeignClient;
    8.  
    9.     @ApiOperation(value = "获取订单统计数据")
    10.     @GetMapping("getCountMap")
    11.     public R getCountMap(OrderCountQueryVo orderCountQueryVo) {
    12.         Map map = orderFeignClient.getCountMap(orderCountQueryVo);
    13.         return R.ok().data(map);
    14.     }
    15. }

    5、统计功能前端 (ECharts)

    ​ECharts是百度的一个项目，后来百度把Echart捐给apache，用于图表展示，提供了常规的折线图、柱状图、散点图、饼图、K线图，用于统计的盒形图，用于地理数据可视化的地图、热力图、线图，用于关系数据可视化的关系图、treemap、旭日图，多维数据可视化的平行坐标，还有用于 BI 的漏斗图，仪表盘，并且支持图与图之间的混搭。

    官网：Apache ECharts

    1. 后台前端 安装echarts

    npm install --save echarts@4.1.0

    2. 添加路由、创建页面

    1.   {
    2.     path: '/statistics',
    3.     component: Layout,
    4.     redirect: '/statistics/order/index',
    5.     name: 'BasesInfo',
    6.     meta: { title: '统计管理', icon: 'table' },
    7.     alwaysShow: true,
    8.     children: [
    9.       {
    10.         path: 'order/index',
    11.         name: '预约统计',
    12.         component: () => import('@/views/yygh/sta/order/index'),
    13.         meta: { title: '预约统计' }
    14.       }
    15.     ]
    16.   },

    3. 添加API接口方法 sta.js

    1. import request from '@/utils/request'
    2.  
    3. const api_name = '/admin/statistics'
    4.  
    5. export default {
    6.     //获取统计数据
    7.     getCountMap(searchObj) {
    8.         return request({
    9.             url: `${api_name}/getCountMap`,
    10.             method: 'get',
    11.             params: searchObj
    12.         })
    13.     }
    14. }

    4. 实现相关页面

    2. <script>
    3.     import echarts from 'echarts'
    4.     import statisticsApi from '@/api/yygh/sta'
    5.  
    6.     export default {
    7.  
    8.         data() {
    9.             return {
    10.                 searchObj: {
    11.                     hosname: '',
    12.                     reserveDateBegin: '',
    13.                     reserveDateEnd: ''
    14.                 },
    15.                 btnDisabled: false,
    16.                 chart: null,
    17.                 title: '',
    18.                 xData: [], // x轴数据
    19.                 yData: [] // y轴数据
    20.             }
    21.         },
    22.  
    23.         methods: {
    24.             // 初始化图表数据
    25.             showChart() {
    26.                 statisticsApi.getCountMap(this.searchObj).then(response => {
    27.                     this.yData = response.data.countList
    28.                     this.xData = response.data.dateList
    29.                     this.setChartData()
    30.                 })
    31.             },
    32.  
    33.             setChartData() {
    34.                 // 基于准备好的dom，初始化echarts实例
    35.                 var myChart = echarts.init(document.getElementById('chart'))
    36.                 // 指定图表的配置项和数据
    37.                 var option = {
    38.                     title: {
    39.                         text: this.title + '挂号量统计'
    40.                     },
    41.                     tooltip: {},
    42.                     legend: {
    43.                         data: [this.title]
    44.                     },
    45.                     xAxis: {
    46.                         data: this.xData
    47.                     },
    48.                     yAxis: {
    49.                         minInterval: 1
    50.                     },
    51.                     series: [{
    52.                         name: this.title,
    53.                         type: 'line',
    54.                         data: this.yData
    55.                     }]
    56.                 }
    57.  
    58.                 // 使用刚指定的配置项和数据显示图表。
    59.                 myChart.setOption(option)
    60.             },
    61.         }
    62.     }
    63. script>

    5. 实现相关页面

  • 相关阅读:
    11月22日星期三今日早报简报微语报早读
    SpringBoot+Mybatis-Plus+Thymeleaf 实现增删改查+登录/注册
    powderdesigner 关于mysql生成pdm和java的方法
    趣味C语言——【猜数字】小游戏
    Nodejs+vue体育用品商城商品购物推荐系统_t81xg
    Spring Boot 2.x系列【20】应用监控篇之Actuator入门案例及端点配置详解
    Makefile 基础（二）—— Makefile 自动推导+ Makefile伪目标
    postgresql|数据库|序列Sequence的创建和管理
    FSDP(Fully Sharded Data Parallel)
    Integration by parts
  • 原文地址：https://blog.csdn.net/a111042555/article/details/126182914