网站开发敬请期待,电脑更新后wordpress,顺的网站建设精英,描述photoshop在网站建设中的作用与特点.1、从Kafka中读取飞机数据#xff0c;并进行清洗 此步骤在前面的“使用Spark清洗统计业务数据并保存到数据库中”任务阶段应该已经完成。如果没有完成#xff0c;请参考源代码自行完成。核心类主要有三个#xff1a;SparkStreamingApplication类、SparkUtil类和MapManager类…1、从Kafka中读取飞机数据并进行清洗 此步骤在前面的“使用Spark清洗统计业务数据并保存到数据库中”任务阶段应该已经完成。如果没有完成请参考源代码自行完成。核心类主要有三个SparkStreamingApplication类、SparkUtil类和MapManager类以及一些辅助类。
BigData-Etl-KongGuan/src/main/java/com/qrsoft/etl/spark/SparkStreamingApplication.java类的作用是实时读取Kafka中所有Topic的数据然后进入到不同的处理分支程序中进行数据清洗和存储处理“实时飞行的航迹数据”的分支的代码如下
SparkUtil sparkUtil new SparkUtil();
try {switch (topName) {case Constants.TASK_RADAR:sparkUtil.TaskRadarStr(taskRadar);break;
进入 Constants.TASK_RADAR 分支后会调用SparkUtil类中的TaskRadarStr方法来处理数据BigData-Etl-KongGuan/src/main/java/com/qrsoft/etl/spark/SparkUtil.java类中相关的核心代码如下 /*** 业务处理* param strs 航迹数据*/public void TaskRadarStr(String strs){System.out.println(strs);String[] str strs.split(,);logger.info(str.toString());try {//判断是哪个扇区 sectionG sectionK sectionEString sectionVal ;MapManager mapMan new MapManager();double lat Double.valueOf(str[8]);double lng Double.valueOf(str[9]);if(mapMan.isInRectangleArea(lat,lng,sectionG[0],sectionG[1],sectionG[2],sectionG[3])){sectionVal G;}else if(mapMan.isInRectangleArea(lat,lng,sectionK[0],sectionK[1],sectionK[2],sectionK[3])){sectionVal K;}else if(mapMan.isInRectangleArea(lat,lng,sectionE[0],sectionE[1],sectionE[2],sectionE[3])){sectionVal E;};System.out.println();System.out.println(sectionVal);System.out.println();MultiRadar mr new MultiRadar();//MultiRadar mr new MultiRadar(str[1],str[12],str[11],str[0],str[17],str[15],str[18],str[19],str[9],str[8],str[7],str[13],str[14],str[10],str[3],str[6],str[4],str[16],str[5],str[2],sectionVal);mr.setAcid(str[0]);mr.setAreaSource(str[1]);mr.setClimbordownSpeed(str[2]);mr.setDirection(str[3]);mr.setFcu(str[4]);mr.setFlyStatus(str[5]);mr.setRadarCFL(str[6]);mr.setRadarHeight(str[7]);mr.setRadarLatitude(str[8]);mr.setRadarLongTitude(str[9]);mr.setRadarSpeed(str[10]);mr.setRadarType(str[11]);mr.setSendRadarTime(str[12]);mr.setSpeedX(str[13]);mr.setSpeedY(str[14]);mr.setSsrCode(str[15]);mr.setTime(str[16]);mr.setTrackNumber(str[17]);mr.setZhiJiaoX(str[18]);mr.setZhiJiaoY(str[19]);mr.setSection(sectionVal);//根据航班号查询是否已经开始对该航迹进行统计MultiRadarDao dao new MultiRadarDao();boolean bool dao.isExistThisRadar(mr.getAcid());if(bool) {//存在修改数据库中该航迹dao.updateAnRadarMsg(mr);}else{//尚未进行统计 创建一个统计信息dao.createAnRadarMsg(mr);}}catch (Exception e){e.printStackTrace();logger.info( MultiRadar错误数据 [{}], strs);}}
在处理“实时飞行的航迹数据”时会使用到一个辅助类MapManager该类的功能包括判断飞机是否在指定的矩形区域内、判断飞机是否在指定的经纬度范围内核心代码如下
public class MapManager {/*** 是否在矩形区域内* * param lat 测试点经度* param lng 测试点纬度* param minLat 纬度范围限制1* param maxLat 纬度范围限制2* param minLng 经度限制范围1* param maxLng 经度范围限制2*/public boolean isInRectangleArea(double lat,double lng,double minLat, double maxLat,double minLng,double maxLng){if(this.isInRange(lat, minLat, maxLat)){//如果在纬度的范围内if(minLng*maxLng0){if(this.isInRange(lng, minLng, maxLng)){return true;}else {return false;}}else {if(Math.abs(minLng)Math.abs(maxLng)180){if(this.isInRange(lng, minLng, maxLng)){return true;}else {return false;}}else{double left Math.max(minLng, maxLng);double right Math.min(minLng, maxLng);if(this.isInRange(lng, left, 180)||this.isInRange(lng, right,-180)){return true;}else {return false;}}}}else{return false;}}/*** 判断是否在经纬度范围内* * param point* param left* param right*/public boolean isInRange(double point, double left,double right){if(pointMath.min(left, right)pointMath.max(left, right)){return true;}else {return false;}}
}
2、打开前端Vue项目kongguan_web完成前端Vue页面src/views/Home/Map.vue设计
在Vue页面 src/views/Home/Map.vue 中引入百度地图首先添加百度地图背景图并在地图上飞机飞机相当于在地图上添加mark点
其中bm-marker是飞机bm-label是飞机旁边显示的标签通过v-for标签循环绑定数据 例如v-foritem in caseListcaseList是在下边的数据获取步骤中赋值的。
templatediv styleheight: 100%baidu-map :centercenter :zoomzoom styleheight:100% clickgetClickInfo:scroll-wheel-zoomtrue :map-stylemapStylebm-marker v-foritem in caseList :keyitem.id:position{lng: item.radarLongtitude, lat: item.radarLatitude} :rotationNumber(item.direction):icon{url: urlz(item.id), size: {width: 100, height: 75}}bm-label :position{lng: item.radarLongtitude, lat: item.radarLatitude}:contentitem.acid:labelStyle{color: gray, fontSize : 8px,backgroundColor: rgba(0,0,0,0),border:0}titleHover me//bm-marker!-- 缩放控件注册此组件才会显示拖放进度 --bm-navigation anchorBMAP_ANCHOR_TOP_LEFT/bm-navigation/baidu-map
... 接下文 ...
在Vue页面中添加扇区管理的页面设计
页面中包含G、K、E三个扇区的按钮并绑定了click事件当点击其中任意一个扇区对应的按钮时会触发click事件执行clickData方法clickData方法在后面的步骤中定义主要是根据传入的不同的参数G、K、E获取不同扇区的数据。
... 接上文 ...div classallStatistics boximg src../../assets/images/nl.png width45px height45px styleposition: absolute;right: 90px;top: 75pximg src../../assets/images/gj.png width45px height45pxstyleposition: absolute ;right: 290px;top: 70pxdiv style margin-left: 70px;margin-top: 12pxdiv当前时间{{new Date().getFullYear()}}-{{new Date().getMonth()}}-{{new Date().getDate()}} ensp;{{newDate().getHours()}}:{{new Date().getMinutes()}}:{{new Date().getSeconds()}}/divdiv stylemargin-left: -17px当前位置{{this.center.lng}} {{this.center.lat}}/div/divdiv style font-weight: bold;position: absolute;top: 145px;left: 45pxspan stylecolor: #2a58f4轨迹数/spanspan stylecolor: #2a58f4{{count}}/spanspan stylecolor: #f17140;margin-left: 52px告警数/spanspan stylecolor: #f17140{{count1}}/span/div/divdiv classsectors1 boxdiv classtitle当前用户: span classnpc管理员 G/span/divdiv el-button :typeisActiveG?success:primary stylemargin-left: 16px clickclickData(G)G/el-buttonel-button :typeisActiveK?success:primary :classisActive 2?active:clickclickData(K)k/el-buttonel-button :typeisActiveE?success:primary :classisActive 3?active:clickclickData(E)E/el-button/div/divdiv classsectors2 boxdiv classtitle扇区状态栏/divdivel-button :typeisActiveG?success:primary stylemargin-left: 16px clickclickData(G)G/el-buttonel-button :typeisActiveK?success:primary :classisActive 2?active:clickclickData(K)k/el-buttonel-button :typeisActiveE?success:primary :classisActive 3?active:clickclickData(E)E/el-button/div/divdiv classsimi_box boxdiv classsimilarityel-tag effectdarkspan classtag-group__title style相似航班数提醒/span/el-tagdiv v-for(it,index) in atcList :keyindex styleheight: 45px; font-weight: bold;spanstylemargin-left: 25px{{it.gjSector}}/spanspanstylemargin-left: 45px{{it.gj}}/span/div/divdiv classsimilarityel-tag effectdarkspan classtag-group__title style管制指令纠错/span/el-tagdiv v-for(it,index) in warnList :keyindexdiv styleheight: 45px;text-align: centerspanstylewidth: 100%; font-weight: bold;{{it.gj_acids}}/span/divdiv styleheight: 45px;text-align: center;table styleheight: 45pxtrtd stylewidth: 150px; border: #2a58f4 3px solid; border-left: none{{it.gj_name}}/tdtd stylewidth: 83px; border: #2a58f4 3px solid{{it.gj_track_num1}}/tdtd stylewidth: 83px; border: #2a58f4 3px solid{{it.gj_track_num2}}/tdtd stylewidth: 83px; border: #2a58f4 3px solid; border-right: none{{it.gj_distinct}}/td/tr/table/div/div/div/div/div
/template
导入访问服务端的api路由
scriptimport {findLocusCount,findMultRadar,findWarnSimilarOfATC,findWarnSimilarOfATCCount,findWarnTp} from /api/map/map;
... 接下文 ...
初始化数据在地图上设置一个初始点并设置样式
... 接上文 ...export default {name: TestBaiDu,data() {return {center: {lng: 118.78995, lat: 36.62934},zoom: 8,url1: require(../../assets/images/fj.png),url2: require(../../assets/images/hfj.png),markerPoint: {lng: 116.404, lat: 39.915},caseList: [],warnList: [],atcList: [],count: 1,count1: 1,isActive: G,mapStyle: {styleJson: [{featureType: water,elementType: all,stylers: {color: #285ea5}},{featureType: land,elementType: all,stylers: {color: #0c3c7f}},{featureType: road,elementType: all,stylers: {visibility: off}},{featureType: point,elementType: all,stylers: {visibility: off}},{featureType: all,elementType: labels.text.fill,stylers: {color: #2da0c6,visibility: off}}]},timer: null,}},
... 接下文 ...
获取数据
其中loadData方法是用来获取实时飞行数据loadWarn方法是获取告警信息clickData方法是响应扇区按钮的点击事件查询不同扇区对应的数据。
... 接上文 ...mounted() {this.loadWarn();this.loadData();this.clickData();this.timeOut();},beforeDestroy() { //页面关闭时清除定时器 window.clearInterval(this.timer);this.timer null;},destroyed() {window.clearInterval(this.timer);this.timer null; },methods: {urlz(data){for(let i0;ithis.warnList.length;i){var value1 this.warnList[i].gj_track_num1;var value2 this.warnList[i].gj_track_num2;if(value1 data || value2 data){return this.url2;}}return this.url1;},getClickInfo(e) {this.center.lng e.point.lngthis.center.lat e.point.lat},loadData() {findMultRadar().then(data {if (data.isSuccess) {this.caseList data.result;this.caseList.forEach(it {it.count it.areaSource , it.trackNumber})} else {this.$message.error(数据获取失败);}})},loadWarn(){findWarnTp().then(data {if (data.isSuccess) {this.warnList data.result;} else {this.warnList.error(数据获取失败);}})},clickData(data) {if (data null) {this.isActive Gdata G} else {this.isActive data}findLocusCount(data).then(data {if (data.isSuccess) {this.count data.result;} else {this.warnList.error(数据获取失败);}}),findWarnSimilarOfATC(data).then(data {if (data.isSuccess) {this.atcList data.result;} else {this.atcList.error(数据获取失败);}}),findWarnSimilarOfATCCount(data).then(data {if (data.isSuccess) {this.count1 data.result;} else {this.count1.error(数据获取失败);}})},
... 接下文 ...
创建一个定时器定时获取数据以更新飞机的位置
... 接上文 ...timeOut(){// 需要在一开始就先调用一遍该方法否则在开始的5s内是没有数据的 if (this.timer) {window.clearInterval(this.timer)} else {this.timer window.setInterval(() {this.loadData();}, 9000)}},}}
/script
... 接下文 ...
页面样式
... 接上文 ...
style.sectors1 { top: 20px; right: 450px; background: #fff; width: 220px; height: 80px; margin-top: 30px; }.sectors2 { top: 20px; right: 690px; background: #fff; width: 220px; height: 80px; margin-top: 30px; }.box { position: absolute; margin-top: 70px; }.allStatistics { background: #fff; width: 400px; height: 200px; top: 60px; right: 20px; margin-top: 30px; }.similarity { background: #fff; overflow: hidden; border-radius: 5px 5px 0 0; margin-bottom: 20px; }.simi_box { top: 300px; right: 20px; width: 400px; height: 400px; margin-top: 18px; }.npc { color: #2a58f4; }.title { color: #575757; text-align: center; font-weight: bold; }.active { background-color: #00b700; }.el-button { height: 25px; }.el-tag { width: 400px; border-radius: 0px; }.common-right{ padding-top: 60px; padding-right: 0; padding-left: 0; }
/style
在src/api/目录下创建map目录然后创建api路由文件 src/api/map/map.js用于访问服务端相应的Controller主要是通过findMultRadar()方法“查询综合航迹数据”并显示航迹图还会涉及到“管制指令纠错”、“根据扇区名称获取该扇区航班数”、“根据扇区号查询相似航班”、“根据扇区号查询相似航班告警总数”等数据的展示
import request from ../../utils/request;//综合航迹数据查询相关的服务器端请求的根路径
const baseUrl/api/multiRadar
//年度统计查询相关的服务器端请求的根路径
const warUrl /api/warnFlightHistory
//航班告警查询相关的服务器端请求的根路径
const warSimUrl /api/warnSimilarHistory
//扇区操作查询相关的服务器端请求的根路径
const atcUrl /api/atc//查询综合航迹数据
export function findMultRadar(){return request({url:baseUrl/findMultRadar,method: get,})
}
//管制指令纠错
export function findWarnTp(){return request({url:warUrl/findWarnTp,method: get,})
}
//根据扇区名称获取该扇区航班数
export function findLocusCount(data){return request({url:atcUrl/findLocusCount?planSectorNamedata,method: get,})
}
//根据扇区号查询相似航班
export function findWarnSimilarOfATC(data){return request({url:warSimUrl/findWarnSimilarOfATC?sectorNamedata,method: get,})
}
//根据扇区号查询相似航班告警总数
export function findWarnSimilarOfATCCount(data){return request({url:warSimUrl/findWarnSimilarOfATCCount?sectorNamedata,method: get,})
}
修改 src/router/index.js 路由文件添加Map.vue页面的路由跳转
... 略 ...{path: /,component: Layout,redirect: /map,children: [{path: map,component: resolve require([/views/Home/Map], resolve),name: map,meta: { title: map }}]},
... 略 ...
src/router/index.js文件的完整内容如下
import Vue from vue
import Router from vue-routerconst originalPush Router.prototype.push;
Router.prototype.push function push(location) {return originalPush.call(this, location).catch(err err)
}Vue.use(Router)
/* Layout */
import Layout from /views/Layout/Layout
const router new Router({base: process.env.BASE_URL,mode: history,routes: [{path: /login,component: resolve require([/views/Login/Login], resolve),hidden: true,meta: {auth: true}},{path: /,component: Layout,redirect: /home,children: [{path: home,component: resolve require([/views/Home/Index], resolve),name: home,meta: { title: home }}]},{path: /,component: Layout,redirect: /map,children: [{path: map,component: resolve require([/views/Home/Map], resolve),name: map,meta: { title: map }}]},]
})// 导航守卫
// 使用 router.beforeEach 注册一个全局前置守卫判断用户是否登陆
router.beforeEach((to, from, next) {if (to.path /login) {next();} else {let token localStorage.getItem(Authorization);if (token null || token ) {next(/login);} else {next();}}
});
export default router
确保 src/App.vue 文件的内容如下
templatediv idapprouter-view//div
/templatescript
export default {name: App,
}
/scriptstyle
html,body,#app{height: 100%;
}
/style
3、打开后端项目BigData-KongGuan完成后台逻辑实现
编写以下Controller类来处理客户端发送过来的请求涉及以下几个类 类/接口 作用 com.qrsoft.controller.AtcController扇区操作类处理客户端的 /api/atc 相关的扇区操作请求com.qrsoft.controller.MultiRadarController综合航迹数据处理客户端的 /api/multiRadar 相关的综合航迹数据查询请求com.qrsoft.controller.WarnFlightHistoryController年度告警统计处理客户端的 /api/warnFlightHistory 相关的年度统计查询请求com.qrsoft.controller.WarnSimilarHistoryController航班告警处理客户端的 /api/warnSimilarHistory 相关的航班告警查询请求
1在com.qrsoft.controller.AtcController类中主要调用其中的 findLocusCount() 方法用于根据扇区名称获取该扇区航班数。
/**
* 根据扇区名称获取该扇区航班数
*/
ApiOperation(value 根据扇区名称获取该扇区航班数)
GetMapping(/findLocusCount)
public Result findLocusCount(RequestParam String planSectorName){return service.findLocusCount(planSectorName);
}
AtcController类的完整内容如下
Api(tags 扇区操作类)
RestController
RequestMapping(/api/atc)
public class AtcController {Autowiredprivate AtcService service;/*** 获取各扇区航班数*/ApiOperation(value 获取各扇区航班数)GetMapping(/findSectorSortie)public Result findSectorSortie(){return service.findSectorSortie();}/*** 根据扇区名称获取该扇区航班数*/ApiOperation(value 根据扇区名称获取该扇区航班数)GetMapping(/findLocusCount)public Result findLocusCount(RequestParam String planSectorName){return service.findLocusCount(planSectorName);}/*** 扇区架次数动态统计(饼状图)*/ApiOperation(value 扇区架次数动态统计(饼状图))GetMapping(/findATCTime)public Result findATCTime(){return service.findATCTime();}
}
2在com.qrsoft.controller.MultiRadarController类中主要调用findMultRadar()方法用于综合航迹数据查询MultiRadarController类的内容如下
Api(tags 综合航迹数据)
RestController
RequestMapping(/api/multiRadar)
public class MultiRadarController {Autowiredprivate MultiRadarService service;/*** 查询综合航迹数据*/GetMapping(/findMultRadar)public Result findMultRadar(){return service.findMultRadar();}
}
3在com.qrsoft.controller.WarnFlightHistoryController类中主要调用 findWarnTp() 方法用于查询“管制指令纠错”的数据。 /*** 管制指令纠错*/
ApiOperation(value 管制指令纠错)
GetMapping(/findWarnTp)
public Result findWarnTp(){return service.findWarnTp();
}
WarnFlightHistoryController类的完整内容如下
Api(tags 年度统计)
RestController
RequestMapping(/api/warnFlightHistory)
public class WarnFlightHistoryController {Autowiredprivate WarnFlightHistoryService service;/*** 年度警告分类统计*/ApiOperation(value 年度警告分类统计)GetMapping(/annualWarningStatisticsByCategory)public Result annualWarningStatisticsByCategory(){return service.annualWarningStatisticsByCategory();}/*** 年度警告区域统计*/ApiOperation(value 年度警告区域统计)GetMapping(/annualWarningAreaStatistics)public Result annualWarningAreaStatistics(){return service.annualWarningAreaStatistics();}/*** 管制指令纠错*/ApiOperation(value 管制指令纠错)GetMapping(/findWarnTp)public Result findWarnTp(){return service.findWarnTp();}
}
4创建com.qrsoft.controller.WarnSimilarHistoryController类在类中主要调用findWarnSimilarOfATC()和findWarnSimilarOfATCCount()方法用于“根据扇区号查询相似航班告警”和“根据扇区号查询相似航班告警总数”。
/**
* 根据扇区号查询相似航班告警
*/
ApiOperation(value 根据扇区号查询相似航班)
GetMapping(/findWarnSimilarOfATC)
public Result findWarnSimilarOfATC(RequestParam String sectorName){return service.findWarnSimilarOfATC(sectorName);
}
/**
* 根据扇区号查询相似航班告警总数
*/
ApiOperation(value 根据扇区号查询相似航班告警总数)
GetMapping(/findWarnSimilarOfATCCount)
public Result findWarnSimilarOfATCCount(RequestParam String sectorName){return service.findWarnSimilarOfATCCount(sectorName);
}
WarnSimilarHistoryController类的完整代码如下
package com.qrsoft.controller;import com.qrsoft.common.Result;
import com.qrsoft.service.WarnSimilarHistoryService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;Api(tags 航班告警)
RestController
RequestMapping(/api/warnSimilarHistory)
public class WarnSimilarHistoryController {Autowiredprivate WarnSimilarHistoryService service;/*** 查询相似航班告警*/ApiOperation(value 查询相似航班告警)GetMapping(/findWarnSimilarHistory)public Result findWarnSimilarHistory(){return service.findWarnSimilarHistory();}/*** 根据扇区号查询相似航班告警*/ApiOperation(value 根据扇区号查询相似航班)GetMapping(/findWarnSimilarOfATC)public Result findWarnSimilarOfATC(RequestParam String sectorName){return service.findWarnSimilarOfATC(sectorName);}/*** 根据扇区号查询相似航班告警总数*/ApiOperation(value 根据扇区号查询相似航班告警总数)GetMapping(/findWarnSimilarOfATCCount)public Result findWarnSimilarOfATCCount(RequestParam String sectorName){return service.findWarnSimilarOfATCCount(sectorName);}
}
编写以下Controller对应的Service类包括以下几个类 类/接口 作用 com.qrsoft.service.AtcService扇区操作的业务模块处理类com.qrsoft.service.MultiRadarService综合航迹数据查询的业务模块处理类com.qrsoft.service.WarnFlightHistoryService年度告警数据查询的业务模块处理类com.qrsoft.service.WarnSimilarHistoryService航班告警数据查询的业务模块处理类
1com.qrsoft.service.AtcService类的内容如下
Service
public class AtcService extends ServiceImplAtcMapper, Atc {Autowiredprivate MultiRadarService multiRadarService;/*** 查询所有扇区航班架次*/public Result findSectorSortie() {ListAtc sectorSortie baseMapper.findSectorSortie();return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS, sectorSortie);}/*** 根据扇区号查询架次*/public Result findLocusCount(String planSectorName) {QueryWrapperMultiRadar queryWrapper new QueryWrapper();queryWrapper.eq(section,planSectorName);int count multiRadarService.count(queryWrapper);return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS, count);}/*** 扇区架次数动态统计(饼状图)*/public Result findATCTime() {ListString sectorName new ArrayList();sectorName.add(K);sectorName.add(S);sectorName.add(E);sectorName.add(P);sectorName.add(G);ListString executeTime baseMapper.findATCTime();List list new ArrayList();for (int i 0; executeTime.size() i; i) {ArrayListObject objects new ArrayList();for (int j 0; sectorName.size() j; j) {Atc atcTime2 baseMapper.findATCTime2(executeTime.get(i), sectorName.get(j));HashMapString, Object map new HashMap();if (atcTime2.getPlanSectorName() ! null) {map.put(atcTime2.getPlanSectorName(), atcTime2.getCount());}else {map.put(sectorName.get(j),0);}objects.add(map);}list.add(objects);}return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS, list);}
}
2创建com.qrsoft.service.MultiRadarService类类中包含一个findMultRadar()方法用于查询综合航迹数据内容如下
package com.qrsoft.service;import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.qrsoft.common.Result;
import com.qrsoft.common.ResultConstants;
import com.qrsoft.entity.MultiRadar;
import com.qrsoft.mapper.MultiRadarMapper;
import org.springframework.stereotype.Service;import java.util.List;Service
public class MultiRadarService extends ServiceImplMultiRadarMapper, MultiRadar {/*** 查询综合航迹数据*/public Result findMultRadar(){ListMultiRadar multiRadars baseMapper.selectList(null);return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS,multiRadars);}
}
3com.qrsoft.service.WarnFlightHistoryService类的内容如下
Service
public class WarnFlightHistoryService extends ServiceImplWarnFlightHistoryMapper, WarnFlightHistory {/*** 年度警告区域统计*/public Result annualWarningAreaStatistics(){ListWarnFlightHistory warnFlightHistories baseMapper.annualWarningAreaStatistics();return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS,warnFlightHistories);}/*** 年度警告分类统计*/public Result annualWarningStatisticsByCategory(){ListWarnFlightHistory warnFlightHistories baseMapper.annualWarningStatisticsByCategory();return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS,warnFlightHistories);}/*** 管制指令纠错*/public Result findWarnTp(){ListHashMapString, Object result new ArrayList();ListHashMapString, Object warnTp baseMapper.findWarnTp();for (HashMapString,Object hm :warnTp){String gj_acids (String)hm.get(gj_acids);String[] split gj_acids.split(-);System.out.println(split.length);if(split.length2) {Integer warn baseMapper.getWarn(split[0], split[1]);if(warn 2){result.add(hm);}}}return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS,result);}
}
4创建com.qrsoft.service.WarnSimilarHistoryService类内容如下
package com.qrsoft.service;import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.qrsoft.common.Result;
import com.qrsoft.common.ResultConstants;
import com.qrsoft.entity.MultiRadar;
import com.qrsoft.entity.WarnSimilarHistory;
import com.qrsoft.mapper.MultiRadarMapper;
import com.qrsoft.mapper.WarnSimilarHistoryMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;Service
public class WarnSimilarHistoryService extends ServiceImplWarnSimilarHistoryMapper, WarnSimilarHistory {Autowiredprivate MultiRadarMapper multiRadarMapper;/*** 查询相似航班告警*/public Result findWarnSimilarHistory(){ListWarnSimilarHistory warnSimilarHistory baseMapper.findWarnSimilarHistory();return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS,warnSimilarHistory);}/*** 根据扇区号查询相似航班*/public Result findWarnSimilarOfATC(String sectorName){QueryWrapperMultiRadar queryWrapper new QueryWrapper();queryWrapper.eq(section,sectorName);ListMultiRadar list multiRadarMapper.selectList(queryWrapper);ListMapString,String result new ArrayList();System.out.println(list);for(MultiRadar m1 :list){for(MultiRadar m2:list){String acid1 m1.getAcid();String substring acid1.substring(0,3);String acid2 m2.getAcid();if(acid2.startsWith(substring)){if(acid1.equals(acid2)){break;}HashMapString, String res new HashMap();res.put(gj, acid1 - acid2);res.put(gjSector,sectorName);result.add(res);break;}}}return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS,result);}/*** 查询航班数量*/public Result findWarnSimilarOfATCCount(String sectorName){Result warnSimilarOfATC this.findWarnSimilarOfATC(sectorName);Object result warnSimilarOfATC.getResult();List? result1 (List?) result;int size result1.size();return new Result(ResultConstants.SUCCESS, ResultConstants.C_SUCCESS,size);}
}
编写对应的Mapper数据访问类包括以下几个类 类/接口 作用 com.qrsoft.mapper.AtcMapper扇区操作的数据访问类com.qrsoft.mapper.MultiRadarMapper综合航迹数据查询的数据访问类com.qrsoft.mapper.WarnFlightHistoryMapper年度告警数据查询的数据访问类com.qrsoft.mapper.WarnSimilarHistoryMapper航班告警数据查询的数据访问类
1com.qrsoft.mapper.AtcMapper类的内容如下
Mapper
public interface AtcMapper extends BaseMapperAtc {Select(select PLAN_SECTOR_NAME,COUNT(*) as count from atc_number GROUP BY PLAN_SECTOR_NAME;)ListAtc findSectorSortie();Select(select EXECUTE_DATE from atc_number group by EXECUTE_DATE order by EXECUTE_DATE desc limit 19;)ListString findATCTime();Select(select PLAN_SECTOR_NAME,count(*) as count from atc_number where EXECUTE_DATE #{executeTime} and PLAN_SECTOR_NAME #{sectorName})Atc findATCTime2(String executeTime,String sectorName);
}
2com.qrsoft.mapper.MultiRadarMapper类的内容如下
Mapper
public interface MultiRadarMapper extends BaseMapperMultiRadar {}
3com.qrsoft.mapper.WarnFlightHistoryMapper类的内容如下
Mapper
public interface WarnFlightHistoryMapper extends BaseMapperWarnFlightHistory {Select(SELECT gj_sector,COUNT(*) as gjCount FROM warnflighthistory_number GROUP BY gj_sector ORDER BY sum(count) desc LIMIT 11;)ListWarnFlightHistory annualWarningAreaStatistics();Select(select gj_name,count(*) as gjCount from warnflighthistory_number group by gj_name;)ListWarnFlightHistory annualWarningStatisticsByCategory();Select(select gj_type,gj_id,gj_msg_type,gj_track_num1,gj_track_num2,gj_distinct,gj_radian,gj_name,gj_distinct_bz,gj_city,gj_date,gj_acids,gj_num1_long,gj_num1_lat,gj_num2_long,gj_num2_lat from warntp_number;)ListHashMapString,Object findWarnTp();Select(select count(*) from multiradar_number where ACID IN (#{acid},#{bcid});)Integer getWarn(Param(acid) String acid, Param(bcid) String bcid);
}
4创建com.qrsoft.mapper.WarnSimilarHistoryMapper类内容如下
package com.qrsoft.mapper;import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.qrsoft.entity.WarnSimilarHistory;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;import java.util.List;Mapper
public interface WarnSimilarHistoryMapper extends BaseMapperWarnSimilarHistory {Select(SELECT gj_sector,gj_acid FROM warnsimilarhistory_number ORDER BY id DESC LIMIT 4;)ListWarnSimilarHistory findWarnSimilarHistory();Select(SELECT gj_sector,gj_acid FROM warnsimilarhistory_number where gj_sector #{sectorName} ORDER BY id DESC LIMIT 4;)ListWarnSimilarHistory findWarnSimilarOfATC(Param(sectorName) String sectorName);
}
涉及的数据实体类包括在前面的任务中已经创建过此处只需确认一下是否存在 类/接口 作用 com.qrsoft.entity.Atc扇区对应的实体类com.qrsoft.entity.MultiRadar雷达对应的实体类com.qrsoft.entity.WarnFlightHistory年度告警飞行历史记录对应的实体类com.qrsoft.entity.WarnSimilarHistory航班告警历史记录对应的实体类com.qrsoft.entity.Company航空公司信息表对应的实体类com.qrsoft.common.Result返回结果类com.qrsoft.common.ResultConstants返回常量结果类
1需要创建com.qrsoft.entity.WarnSimilarHistory类用于航班告警历史记录对应的实体类内容如下
package com.qrsoft.entity;import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;import java.io.Serializable;Data
AllArgsConstructor
NoArgsConstructor
TableName(warnsimilarhistory_number)
public class WarnSimilarHistory implements Serializable {private Integer id;TableField(value gj_type)private String gjType;TableField(value gj_id)private String gjDd;TableField(value gj_msg_type)private String gjMsgType;TableField(value gj_num)private String gjNum;TableField(value gj_track_num)private String gjTrackNum;TableField(value gj_sector)private String gjSector;TableField(value gj_acid)private String gjAcid;TableField(value gj_status)private String gjStatus;TableField(value gj_city)private String gjCity;TableField(value gj_date)private String gjDate;TableField(value count)private Integer count;}
2其他实体类在前面的任务中已经创建这里不需要重复创建。 4、功能测试
启动后端程序BigData-KongGuan 启动后端程序BigData-Etl-KongGuan 启动前端程序 页面显示效果下面图中是原企业项目的真实展示页面在当前项目中由于数据集的特点实际展示效果可能会有差异 文章转载自： http://www.morning.wrtsm.cn.gov.cn.wrtsm.cn http://www.morning.wwxg.cn.gov.cn.wwxg.cn http://www.morning.bkryb.cn.gov.cn.bkryb.cn http://www.morning.rnwt.cn.gov.cn.rnwt.cn http://www.morning.grtwn.cn.gov.cn.grtwn.cn http://www.morning.gzzxlp.com.gov.cn.gzzxlp.com http://www.morning.nlrxh.cn.gov.cn.nlrxh.cn http://www.morning.qxlgt.cn.gov.cn.qxlgt.cn http://www.morning.pghry.cn.gov.cn.pghry.cn http://www.morning.rsjf.cn.gov.cn.rsjf.cn http://www.morning.sgfpn.cn.gov.cn.sgfpn.cn http://www.morning.njqpg.cn.gov.cn.njqpg.cn http://www.morning.rxfbf.cn.gov.cn.rxfbf.cn http://www.morning.pyncm.cn.gov.cn.pyncm.cn http://www.morning.bmtkp.cn.gov.cn.bmtkp.cn http://www.morning.fmdvbsa.cn.gov.cn.fmdvbsa.cn http://www.morning.kwblwbl.cn.gov.cn.kwblwbl.cn http://www.morning.xjmyq.com.gov.cn.xjmyq.com http://www.morning.ptslx.cn.gov.cn.ptslx.cn http://www.morning.mkyny.cn.gov.cn.mkyny.cn http://www.morning.tjndb.cn.gov.cn.tjndb.cn http://www.morning.ljzqb.cn.gov.cn.ljzqb.cn http://www.morning.cqwb25.cn.gov.cn.cqwb25.cn http://www.morning.pwdrc.cn.gov.cn.pwdrc.cn http://www.morning.yrnyz.cn.gov.cn.yrnyz.cn http://www.morning.dnpft.cn.gov.cn.dnpft.cn http://www.morning.wgrm.cn.gov.cn.wgrm.cn http://www.morning.bfnbn.cn.gov.cn.bfnbn.cn http://www.morning.jrksk.cn.gov.cn.jrksk.cn http://www.morning.xtqld.cn.gov.cn.xtqld.cn http://www.morning.skscy.cn.gov.cn.skscy.cn http://www.morning.bpmnh.cn.gov.cn.bpmnh.cn http://www.morning.lpzyq.cn.gov.cn.lpzyq.cn http://www.morning.webife.com.gov.cn.webife.com http://www.morning.rdtp.cn.gov.cn.rdtp.cn http://www.morning.nclps.cn.gov.cn.nclps.cn http://www.morning.bzfwn.cn.gov.cn.bzfwn.cn http://www.morning.lhhdy.cn.gov.cn.lhhdy.cn http://www.morning.wddmr.cn.gov.cn.wddmr.cn http://www.morning.bxyzr.cn.gov.cn.bxyzr.cn http://www.morning.nxpqw.cn.gov.cn.nxpqw.cn http://www.morning.ffwrq.cn.gov.cn.ffwrq.cn http://www.morning.dnmzl.cn.gov.cn.dnmzl.cn http://www.morning.ymwny.cn.gov.cn.ymwny.cn http://www.morning.tnjz.cn.gov.cn.tnjz.cn http://www.morning.yfnhg.cn.gov.cn.yfnhg.cn http://www.morning.lgnz.cn.gov.cn.lgnz.cn http://www.morning.rgfx.cn.gov.cn.rgfx.cn http://www.morning.cpktd.cn.gov.cn.cpktd.cn http://www.morning.ndfwh.cn.gov.cn.ndfwh.cn http://www.morning.xdfkrd.cn.gov.cn.xdfkrd.cn http://www.morning.wflsk.cn.gov.cn.wflsk.cn http://www.morning.fpkdd.cn.gov.cn.fpkdd.cn http://www.morning.ylqpp.cn.gov.cn.ylqpp.cn http://www.morning.pybqq.cn.gov.cn.pybqq.cn http://www.morning.nwpnj.cn.gov.cn.nwpnj.cn http://www.morning.swbhq.cn.gov.cn.swbhq.cn http://www.morning.drqrl.cn.gov.cn.drqrl.cn http://www.morning.rtsdz.cn.gov.cn.rtsdz.cn http://www.morning.xxfxxf.cn.gov.cn.xxfxxf.cn http://www.morning.qtbnm.cn.gov.cn.qtbnm.cn http://www.morning.nckzt.cn.gov.cn.nckzt.cn http://www.morning.njntp.cn.gov.cn.njntp.cn http://www.morning.kqfdrqb.cn.gov.cn.kqfdrqb.cn http://www.morning.grlth.cn.gov.cn.grlth.cn http://www.morning.qgqck.cn.gov.cn.qgqck.cn http://www.morning.rnmc.cn.gov.cn.rnmc.cn http://www.morning.msbmp.cn.gov.cn.msbmp.cn http://www.morning.kngx.cn.gov.cn.kngx.cn http://www.morning.fhrt.cn.gov.cn.fhrt.cn http://www.morning.rzmzm.cn.gov.cn.rzmzm.cn http://www.morning.rtsdz.cn.gov.cn.rtsdz.cn http://www.morning.ghxsn.cn.gov.cn.ghxsn.cn http://www.morning.ymwny.cn.gov.cn.ymwny.cn http://www.morning.tkyxl.cn.gov.cn.tkyxl.cn http://www.morning.rynqh.cn.gov.cn.rynqh.cn http://www.morning.wjqbr.cn.gov.cn.wjqbr.cn http://www.morning.nlbhj.cn.gov.cn.nlbhj.cn http://www.morning.lhsdf.cn.gov.cn.lhsdf.cn http://www.morning.skbbt.cn.gov.cn.skbbt.cn
