From d77c17f8fab886c6018704533c7cb72233e6b7e0 Mon Sep 17 00:00:00 2001 From: "Lihong@123456" <1090591095@qq.com> Date: Tue, 15 Dec 2020 10:36:33 +0800 Subject: [PATCH] 1 --- .../wisdomcar/bean/vo/StatisticsVo.java | 8 +- .../wisdomcar/persist/dao/StatisticsDao.java | 6 +- .../wisdomcar/rabbitMQ/RabbitController.java | 114 +++++++++--------- .../wisdomcar/service/StatisticsService.java | 13 +- .../resources/mapper_dao/StatisticsDao.xml | 16 ++- 5 files changed, 76 insertions(+), 81 deletions(-) diff --git a/wisdomcar/src/main/java/com/ccsens/wisdomcar/bean/vo/StatisticsVo.java b/wisdomcar/src/main/java/com/ccsens/wisdomcar/bean/vo/StatisticsVo.java index c3421426..5755ceed 100644 --- a/wisdomcar/src/main/java/com/ccsens/wisdomcar/bean/vo/StatisticsVo.java +++ b/wisdomcar/src/main/java/com/ccsens/wisdomcar/bean/vo/StatisticsVo.java @@ -36,8 +36,6 @@ public class StatisticsVo { @Data @ApiModel("各个结点时长") public static class PointTime{ - @ApiModelProperty("节点名") - private String name; @ApiModelProperty("节点耗时") private Long time; } @@ -47,10 +45,10 @@ public class StatisticsVo { @ApiModel("各个结点时长集合") public static class PointTimeList{ @ApiModelProperty("当前数据") - private List pointTimeCurrentList; + private List pointTimeCurrentList; @ApiModelProperty("医院数据") - private List pointTimeHospital; + private List pointTimeHospital; @ApiModelProperty("国际数据") - private List pointTimeInternation; + private List pointTimeInternation; } } diff --git a/wisdomcar/src/main/java/com/ccsens/wisdomcar/persist/dao/StatisticsDao.java b/wisdomcar/src/main/java/com/ccsens/wisdomcar/persist/dao/StatisticsDao.java index db790d82..b4e92cd1 100644 --- a/wisdomcar/src/main/java/com/ccsens/wisdomcar/persist/dao/StatisticsDao.java +++ b/wisdomcar/src/main/java/com/ccsens/wisdomcar/persist/dao/StatisticsDao.java @@ -11,11 +11,11 @@ public interface StatisticsDao extends FirstAidMapper { - List getPointTimeCurrent(@Param("id") Long id); + List getPointTimeCurrent(@Param("id") Long id); - List getPointTimeHospital(@Param("id") Long id); + List getPointTimeHospital(@Param("id") Long id); - List getPointTimeInternation(@Param("id") Long id); + List getPointTimeInternation(@Param("id") Long id); public List selResult(@Param("param")StatisticsDto.UseNum param); diff --git a/wisdomcar/src/main/java/com/ccsens/wisdomcar/rabbitMQ/RabbitController.java b/wisdomcar/src/main/java/com/ccsens/wisdomcar/rabbitMQ/RabbitController.java index bbccaf20..89d029af 100644 --- a/wisdomcar/src/main/java/com/ccsens/wisdomcar/rabbitMQ/RabbitController.java +++ b/wisdomcar/src/main/java/com/ccsens/wisdomcar/rabbitMQ/RabbitController.java @@ -1,57 +1,57 @@ -package com.ccsens.wisdomcar.rabbitMQ; - -import cn.hutool.core.collection.CollectionUtil; -import cn.hutool.core.util.ObjectUtil; -import com.alibaba.fastjson.JSONObject; -import com.ccsens.util.bean.message.common.OutMessage; -import com.ccsens.util.bean.message.common.OutMessageSet; -import com.ccsens.util.config.RabbitMQConfig; -import com.ccsens.wisdomcar.bean.dto.Message.CarRecordMessageDto; -import com.ccsens.wisdomcar.service.IRecordService; -import com.ccsens.wisdomcar.service.RecordService; -import lombok.extern.slf4j.Slf4j; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.amqp.rabbit.annotation.RabbitHandler; -import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.stereotype.Component; - -import javax.annotation.Resource; -import java.util.List; -import java.util.Set; - -@Slf4j -@Component -@RabbitListener(queues = RabbitMQConfig.WISDOM_CAR) -public class RabbitController { - @Resource - private IRecordService recordService; - - private Logger logger = LoggerFactory.getLogger(RabbitController.class); - - @RabbitHandler - public void process(String messageJson) { - logger.info("平车上传消息数据: {}",messageJson); - OutMessageSet outMessageSet = JSONObject.parseObject(messageJson,OutMessageSet.class); - if(ObjectUtil.isNull(outMessageSet)){ - return; - } - Set messageSet = outMessageSet.getMessageSet(); - if (CollectionUtil.isEmpty(messageSet)) { - return; - } - messageSet.forEach(outMessage -> { - CarRecordMessageDto carRecordMessageDto = JSONObject.parseObject(outMessage.getData(),CarRecordMessageDto.class); - if(ObjectUtil.isNull(carRecordMessageDto)){ - return; - } - try { - recordService.disposeMessage(carRecordMessageDto); - } catch (Exception e) { - log.error("处理平车信息异常",e); - e.printStackTrace(); - } - }); - } - -} +//package com.ccsens.wisdomcar.rabbitMQ; +// +//import cn.hutool.core.collection.CollectionUtil; +//import cn.hutool.core.util.ObjectUtil; +//import com.alibaba.fastjson.JSONObject; +//import com.ccsens.util.bean.message.common.OutMessage; +//import com.ccsens.util.bean.message.common.OutMessageSet; +//import com.ccsens.util.config.RabbitMQConfig; +//import com.ccsens.wisdomcar.bean.dto.Message.CarRecordMessageDto; +//import com.ccsens.wisdomcar.service.IRecordService; +//import com.ccsens.wisdomcar.service.RecordService; +//import lombok.extern.slf4j.Slf4j; +//import org.slf4j.Logger; +//import org.slf4j.LoggerFactory; +//import org.springframework.amqp.rabbit.annotation.RabbitHandler; +//import org.springframework.amqp.rabbit.annotation.RabbitListener; +//import org.springframework.stereotype.Component; +// +//import javax.annotation.Resource; +//import java.util.List; +//import java.util.Set; +// +//@Slf4j +//@Component +//@RabbitListener(queues = RabbitMQConfig.WISDOM_CAR) +//public class RabbitController { +// @Resource +// private IRecordService recordService; +// +// private Logger logger = LoggerFactory.getLogger(RabbitController.class); +// +// @RabbitHandler +// public void process(String messageJson) { +// logger.info("平车上传消息数据: {}",messageJson); +// OutMessageSet outMessageSet = JSONObject.parseObject(messageJson,OutMessageSet.class); +// if(ObjectUtil.isNull(outMessageSet)){ +// return; +// } +// Set messageSet = outMessageSet.getMessageSet(); +// if (CollectionUtil.isEmpty(messageSet)) { +// return; +// } +// messageSet.forEach(outMessage -> { +// CarRecordMessageDto carRecordMessageDto = JSONObject.parseObject(outMessage.getData(),CarRecordMessageDto.class); +// if(ObjectUtil.isNull(carRecordMessageDto)){ +// return; +// } +// try { +// recordService.disposeMessage(carRecordMessageDto); +// } catch (Exception e) { +// log.error("处理平车信息异常",e); +// e.printStackTrace(); +// } +// }); +// } +// +//} diff --git a/wisdomcar/src/main/java/com/ccsens/wisdomcar/service/StatisticsService.java b/wisdomcar/src/main/java/com/ccsens/wisdomcar/service/StatisticsService.java index f34d3892..0d3f2eef 100644 --- a/wisdomcar/src/main/java/com/ccsens/wisdomcar/service/StatisticsService.java +++ b/wisdomcar/src/main/java/com/ccsens/wisdomcar/service/StatisticsService.java @@ -59,19 +59,18 @@ public class StatisticsService implements IStatisticsService{ @Override public StatisticsVo.PointTimeList getPointTime(StatisticsDto.Hospital param) { - List pointTimeCurrent1 = new ArrayList<>(); + List pointTimeCurrent1 = new ArrayList<>(); //当前数据 - List pointTimeCurrent = statisticsDao.getPointTimeCurrent(param.getId()); - for (int i = 0; i <7; i++) { + List pointTimeCurrent = statisticsDao.getPointTimeCurrent(param.getId()); + for (int i = 0; i pointTimeHospital = statisticsDao.getPointTimeHospital(param.getId()); + List pointTimeHospital = statisticsDao.getPointTimeHospital(param.getId()); //国际数据 - List pointTimeInternation = statisticsDao.getPointTimeInternation(param.getId()); + List pointTimeInternation = statisticsDao.getPointTimeInternation(param.getId()); StatisticsVo.PointTimeList pointTimeList = new StatisticsVo.PointTimeList(); pointTimeList.setPointTimeCurrentList(pointTimeCurrent1); diff --git a/wisdomcar/src/main/resources/mapper_dao/StatisticsDao.xml b/wisdomcar/src/main/resources/mapper_dao/StatisticsDao.xml index 2f5f6de1..cbae8cb4 100644 --- a/wisdomcar/src/main/resources/mapper_dao/StatisticsDao.xml +++ b/wisdomcar/src/main/resources/mapper_dao/StatisticsDao.xml @@ -34,30 +34,28 @@ FROM - + select tfar.begin_time as time from - t_first_aid_record tfar ,(select id from t_first_aid tfa where tfa.hospital_id=0 and tfa.rec_status=0 ORDER BY tfa.begin_time) t + t_first_aid_record tfar ,(select id from t_first_aid tfa where tfa.hospital_id=#{id} and tfa.rec_status=0 ORDER BY tfa.begin_time) t where tfar.rec_status=0 and t.id = tfar.first_aid_id - select - ts.`name`, MIN(tfas.duration)/1000 as time from t_first_aid_standard tfas left JOIN t_step ts on tfas.step_id = ts.id - where tfas.hospital_id=0 and tfas.type=1 and tfas.rec_status = 0 and ts.rec_status=0 + where tfas.hospital_id=#{id} and tfas.type=1 and tfas.rec_status = 0 and ts.rec_status=0 GROUP BY tfas.step_id; - select - ts.`name`, MIN(tfas.duration)/1000 as time from t_first_aid_standard tfas left JOIN t_step ts on tfas.step_id = ts.id - where tfas.hospital_id=0 and tfas.type=0 and tfas.rec_status = 0 and ts.rec_status=0 + where tfas.hospital_id=#{id} and tfas.type=0 and tfas.rec_status = 0 and ts.rec_status=0 GROUP BY tfas.step_id; \ No newline at end of file