尚医通 (三十七) --------- 定时任务与统计

逃离我推掉我的手 2024-03-30 09:47 108阅读 0赞

#### 目录 ####

*  一、就医提醒
 *   *  1. 搭建定时任务模块 service-task
     *  2. 添加就医提醒处理
 *  二、预约统计
 *   *  1. ECharts
     *  2. 获取医院每天平台预约数据接口
     *  3. 添加 feign 方法
     *  4. 搭建 service-statistics
     *  5. 前端展示

--------------------

## 一、就医提醒 ##

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

### 1. 搭建定时任务模块 service-task ###

**A、搭建 service-task 服务**

搭建方式如 service-user

**B、修改配置 pom.xml**

<dependencies>
        <dependency>
            <groupId>com.fancy.yygh</groupId>
            <artifactId>rabbit-util</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
    </dependencies>

说明：引入依赖

**C、添加配置文件**

application.properties

# 服务端口
    server.port=8207
    # 服务名
    spring.application.name=service-task
    # 环境设置：dev、test、prod
    spring.profiles.active=dev
    
    # nacos服务地址
    spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
    
    #rabbitmq地址
    spring.rabbitmq.host=192.168.44.165
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

**D、添加启动类**

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源自动配置
    @EnableDiscoveryClient
    public class ServiceTaskApplication {
        
        public static void main(String[] args) {
        
            SpringApplication.run(ServiceTaskApplication.class, args);
        }
    }

**E、添加常量配置**

在 rabbit-util 模块 com.fancy.yygh.common.constant.MqConst 类添加

public static final String EXCHANGE_DIRECT_TASK = "exchange.direct.task";
    public static final String ROUTING_TASK_8 = "task.8";
    //队列
    public static final String QUEUE_TASK_8 = "queue.task.8";

**F、添加定时任务**

Cron 表达式

![在这里插入图片描述][a1cd88d9d2964c139f58a23c4c02b5da.png]

@Component
    @EnableScheduling
    public class ScheduledTask {
        
    
        @Autowired
        private RabbitService rabbitService;
    
        /**
         * 每天8点执行 提醒就诊
         */
        //@Scheduled(cron = "0 0 1 * * ?")
        @Scheduled(cron = "0/30 * * * * ?")
        public void task1() {
        
            rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_TASK, MqConst.ROUTING_TASK_8, "");
        }
    }

### 2. 添加就医提醒处理 ###

操作模块 service-order

**A、添加 service 接口**

在 OrderService 类添加接口

/**
     * 就诊提醒
     */
    void patientTips();

**B、添加 service 接口实现类**

在 OrderServiceImpl 类添加接口实现

@Override
    public void patientTips() {
        
        QueryWrapper<OrderInfo> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("reserve_date",new DateTime().toString("yyyy-MM-dd"));
        List<OrderInfo> orderInfoList = baseMapper.selectList(queryWrapper);
        for(OrderInfo orderInfo : orderInfoList) {
        
            //短信提示
            MsmVo msmVo = new MsmVo();
            msmVo.setPhone(orderInfo.getPatientPhone());
            String reserveDate = new DateTime(orderInfo.getReserveDate()).toString("yyyy-MM-dd") + (orderInfo.getReserveTime()==0 ? "上午": "下午");
            Map<String,Object> param = new HashMap<String,Object>(){
        {
        
                put("title", orderInfo.getHosname()+"|"+orderInfo.getDepname()+"|"+orderInfo.getTitle());
                put("reserveDate", reserveDate);
                put("name", orderInfo.getPatientName());
            }};
            msmVo.setParam(param);
            rabbitService.sendMessage(MqConst.EXCHANGE_DIRECT_MSM, MqConst.ROUTING_MSM_ITEM, msmVo);
        }
    }

**C、添加 mq 监听**

添加OrderReceiver 类

@Component
    public class OrderReceiver {
        
    
        @Autowired
        private OrderService orderService;
    
        @RabbitListener(bindings = @QueueBinding(
                value = @Queue(value = MqConst.QUEUE_TASK_8, durable = "true"),
                exchange = @Exchange(value = MqConst.EXCHANGE_DIRECT_TASK),
                key = {
        MqConst.ROUTING_TASK_8}
        ))
        public void patientTips(Message message, Channel channel) throws IOException {
        
            orderService.patientTips();
        }
    }

## 二、预约统计 ##

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

我们为什么需要一个统计模块呢，因为在实际的生成环境中，有很多种各式统计，数据来源于各个服务模块，我们得有一个统计模块来专门管理

### 1. ECharts ###

**A、简介**

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

官方网站：[https://echarts.apache.org/zh/index.html][https_echarts.apache.org_zh_index.html]

**B、基本使用**

引入 ECharts

<script src="echarts.min.js"></script>

定义图表区域

<div id="main" style="width: 600px;height:400px;"></div>

渲染图表 (折线图)

**D、渲染图表(柱状图)**

**E、项目中集成 ECharts**

npm install --save echarts@4.1.0

### 2. 获取医院每天平台预约数据接口 ###

操作模块：service-order

**A、添加Mapper接口**

在 OrderInfoMapper 类添加接口

public interface OrderMapper extends BaseMapper<OrderInfo> {
        
        List<OrderCountVo> selectOrderCount(@Param("vo") OrderCountQueryVo orderCountQueryVo);
    }

在OrderInfoMapper.xml文件添加方法

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
            "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="com.fancy.yygh.order.mapper.OrderMapper">
    
        <select id="selectOrderCount" resultType="com.atguigu.yygh.vo.order.OrderCountVo">
            select reserve_date as reserveDate, count(reserve_date) as count
            from order_info
            <where>
                <if test="vo.hosname != null and vo.hosname != ''">
                    and hosname like CONCAT('%',#{vo.hosname},'%')
                </if>
                <if test="vo.reserveDateBegin != null and vo.reserveDateBegin != ''">
                    and reserve_date >= #{vo.reserveDateBegin}
                </if>
                <if test="vo.reserveDateEnd != null and vo.reserveDateEnd != ''">
                    and reserve_date <= #{vo.reserveDateEnd}
                </if>
                and is_deleted = 0
            </where>
            group by reserve_date
            order by reserve_date
        </select>
    </mapper>

添加 application.properties 配置

mybatis-plus.mapper-locations=classpath:com/fancy/yygh/order/mapper/xml/*.xml

**B、添加 service 接口**

在 OrderService 类添加接口

/**
     * 订单统计
     */
    Map<String, Object> getCountMap(OrderCountQueryVo orderCountQueryVo);

**C、添加 service 接口实现**

在 OrderServiceImpl 类添加实现

@Override
    public Map<String, Object> getCountMap(OrderCountQueryVo orderCountQueryVo) {
        
        Map<String, Object> map = new HashMap<>();
    
        List<OrderCountVo> orderCountVoList = baseMapper.selectOrderCount(orderCountQueryVo);
        //日期列表
        List<String> dateList = orderCountVoList.stream().map(OrderCountVo::getReserveDate).collect(Collectors.toList());
        //统计列表
        List<Integer> countList = orderCountVoList.stream().map(OrderCountVo::getCount).collect(Collectors.toList());
        map.put("dateList", dateList);
        map.put("countList", countList);
        return map;
    }

**D、添加 controller 方法**

在 OrderApiController 类添加方法

@ApiOperation(value = "获取订单统计数据")
    @PostMapping("inner/getCountMap")
    public Map<String, Object> getCountMap(@RequestBody OrderCountQueryVo orderCountQueryVo) {
        
        return orderService.getCountMap(orderCountQueryVo);
    }

### 3. 添加 feign 方法 ###

创建模块：service-order-client

**A、添加 feign 接口**

添加接口和方法

@FeignClient(value = "service-order")
    @Repository
    public interface OrderFeignClient {
        
        /**
         * 获取订单统计数据
         */
        @PostMapping("/api/order/orderInfo/inner/getCountMap")
        Map<String, Object> getCountMap(@RequestBody OrderCountQueryVo orderCountQueryVo);
    
    }

### 4. 搭建 service-statistics ###

**A、搭建service-statistics服务**

搭建方式如 service-user

**B、修改配置 pom.xml**

<dependencies>
        <dependency>
            <groupId>com.fancy.yygh</groupId>
            <artifactId>service-order-client</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
    </dependencies>

**C、添加配置文件**

application.properties

# 服务端口
    server.port=8208
    # 服务名
    spring.application.name=service-statistics
    # 环境设置：dev、test、prod
    spring.profiles.active=dev
    
    # nacos服务地址
    spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

**D、添加启动类**

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)//取消数据源自动配置
    @EnableDiscoveryClient
    @EnableFeignClients
    public class ServiceStatisticsApplication {
        
    
        public static void main(String[] args) {
        
            SpringApplication.run(ServiceStatisticsApplication.class, args);
        }
    
    }

**E、添加 controller 方法**

@Api(tags = "统计管理接口")
    @RestController
    @RequestMapping("/admin/statistics")
    public class StatisticsController {
        
    
        @Autowired
        private OrderFeignClient orderFeignClient;
    
        @ApiOperation(value = "获取订单统计数据")
        @GetMapping("getCountMap")
        public Result getCountMap(@ApiParam(name = "orderCountQueryVo", value = "查询对象", required = false) OrderCountQueryVo orderCountQueryVo) {
        
            return Result.ok(orderFeignClient.getCountMap(orderCountQueryVo));
        }
    }

### 5. 前端展示 ###

**A、添加路由**

在 src/router/index.js 文件添加路由

{
        
    	path: '/statistics',
    	 component: Layout,
    	 redirect: '/statistics/order/index',
    	 name: 'BasesInfo',
    	 meta: {
         title: '统计管理', icon: 'table' },
    	 alwaysShow: true,
    	 children: [
    	     {
        
    			  path: 'order/index',
    			  name: '预约统计',
    			  component: () =>import('@/views/statistics/order/index'),
    			  meta: {
         title: '预约统计' }
    	     }
    	]
    },

**B、封装 api 请求**

创建 /api/statistics/orderStatistics.js

import request from '@/utils/request'
    
    const api_name = '/admin/statistics'
    
    export default {
        
    
        getCountMap(searchObj) {
        
            return request({
        
                url: `${
        api_name}/getCountMap`,
                method: 'get',
                params: searchObj
            })
        }
    }

**C、添加组件**

创建 /views/statistics/order/index.vue 组件

<template>
        <div class="app-container">
        
        <el-form :inline="true" class="demo-form-inline">
            <el-form-item>
                <el-input v-model="searchObj.hosname" placeholder="点击输入医院名称"/>
            </el-form-item>
    
            <el-form-item>
                <el-date-picker
                    v-model="searchObj.reserveDateBegin"
                    type="date"
                    placeholder="选择开始日期"
                    value-format="yyyy-MM-dd"/>
            </el-form-item>
            <el-form-item>
                <el-date-picker
                    v-model="searchObj.reserveDateEnd"
                    type="date"
                    placeholder="选择截止日期"
                    value-format="yyyy-MM-dd"/>
            </el-form-item>
            <el-button
                :disabled="btnDisabled"
                type="primary"
                icon="el-icon-search"
                @click="showChart()">查询</el-button>
        </el-form>
    
        <div class="chart-container">
            <div id="chart" ref="chart" 
                class="chart" style="height:500px;width:100%"/>
       		</div>
        </div>
    </template>
    
    <script>
    import echarts from 'echarts'
    import statisticsApi from '@/api/orderStatistics'
    
    export default {
          
    
        data() {
          
            return {
          
                searchObj: {
          
                    hosname: '',
                    reserveDateBegin: '',
                    reserveDateEnd: ''
                },
                btnDisabled: false,
                chart: null,
                title: '',
                xData: [], // x轴数据
                yData: [] // y轴数据
            }
        },
    
        methods: {
          
            // 初始化图表数据
            showChart() {
          
                statisticsApi.getCountMap(this.searchObj).then(response => {
          
                    this.yData = response.data.countList
                    this.xData = response.data.dateList
                    this.setChartData()
                })
            },
    
            setChartData() {
          
                // 基于准备好的dom，初始化echarts实例
                var myChart = echarts.init(document.getElementById('chart'))
                // 指定图表的配置项和数据
                var option = {
          
                    title: {
          
                        text: this.title + '挂号量统计'
                    },
                    tooltip: {
          },
                    legend: {
          
                        data: [this.title]
                    },
                    xAxis: {
          
                        data: this.xData
                    },
                    yAxis: {
          
                        minInterval: 1
                    },
                    series: [{
          
                        name: this.title,
                        type: 'line',
                        data: this.yData
                    }]
                }
    
                // 使用刚指定的配置项和数据显示图表。
                myChart.setOption(option)
            },
        }
    }
    </script>

[a1cd88d9d2964c139f58a23c4c02b5da.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/2aeb4560e53943bdb069abe89f320dbb.png
[https_echarts.apache.org_zh_index.html]: https://echarts.apache.org/zh/index.html