From c71b5238897cded7b0ad3be599b085e6e1fd46a4 Mon Sep 17 00:00:00 2001 From: kongdeqiang <123456> Date: 星期五, 21 七月 2023 14:06:04 +0800 Subject: [PATCH] 提交 --- src/main/java/com/boying/controller/ApiController.java | 325 ++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 313 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/boying/controller/ApiController.java b/src/main/java/com/boying/controller/ApiController.java index c36aea7..7eb03ca 100755 --- a/src/main/java/com/boying/controller/ApiController.java +++ b/src/main/java/com/boying/controller/ApiController.java @@ -4,6 +4,7 @@ import cn.hutool.http.HttpRequest; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.api.R; import com.boying.entity.*; import com.boying.service.*; @@ -16,6 +17,7 @@ import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; +import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -96,6 +98,23 @@ } } + @GetMapping("/getHostInfo") + public R getServerInfo(){ + List<Map<String,Object>> resultList = new ArrayList<>(); + QueryWrapper<SystemInfo> wrapper = new QueryWrapper<>(); + wrapper.select(" id,host_name,uptime,state,remark"); + List<SystemInfo> list = systemInfoService.list(wrapper); + for (SystemInfo systemInfo : list) { + Map<String,Object> map = new HashMap<>(); + map.put("name",systemInfo.getHostName()); + map.put("runDate",systemInfo.getUptime()); + map.put("isRun",systemInfo.getState()); + map.put("remark",systemInfo.getRemark()); + resultList.add(map); + } + return R.ok(resultList); + } + @GetMapping("/getSnmp") public R getSnmp(){ Map<String,Object> map = new HashMap<>(); @@ -116,14 +135,34 @@ } } + @GetMapping("/getSnmpInfo") + public R getSnmpInfo(){ + List<Map<String,Object>> resultList = new ArrayList<>(); + QueryWrapper<SnmpInfo> wrapper = new QueryWrapper<>(); + wrapper.select(" id,host_name,uptime,state,remark"); + List<SnmpInfo> list = snmpInfoService.list(wrapper); + for (SnmpInfo snmpInfo : list) { + Map<String,Object> map = new HashMap<>(); + map.put("name",snmpInfo.getHostName()); + map.put("bytes",snmpInfo.getBytesSent()); + map.put("isRun",snmpInfo.getState()); + map.put("remark",snmpInfo.getRemark()); + resultList.add(map); + } + return R.ok(resultList); + } + @GetMapping("/getTask") public R getTask(){ Map<String,Object> map = new HashMap<>(); try { QueryWrapper<InspectionTask> wrapper = new QueryWrapper<>(); + wrapper.select(" id,is_ok"); wrapper.lambda() .eq(InspectionTask::getIsOk,1); - List<InspectionTask> inspectionTasks = inspectionTaskService.list(null); + QueryWrapper<InspectionTask> wrapper1 = new QueryWrapper<>(); + wrapper1.select(" id,is_ok"); + List<InspectionTask> inspectionTasks = inspectionTaskService.list(wrapper1); List<InspectionTask> inspectionTasks2 = inspectionTaskService.list(wrapper); map.put("count",inspectionTasks.size()); map.put("normalCount",inspectionTasks2.size()); @@ -137,6 +176,7 @@ public R getTaskInfoById(String id){ try { QueryWrapper<TaskInfo> wrapper = new QueryWrapper<>(); + wrapper.select(" id,task_id,task_date,is_ok,content"); wrapper.lambda() .eq(TaskInfo::getTaskId,id); List<TaskInfo> infos = taskInfoService.list(wrapper); @@ -150,8 +190,9 @@ public R getTaskByDate(String startDate,String endDate){ try { QueryWrapper<InspectionTask> wrapper = new QueryWrapper<>(); + wrapper.select(" id,title,start_date"); wrapper.lambda() - .between(InspectionTask::getStartDate,startDate,endDate); + .between(StringUtils.isNotBlank(startDate) && StringUtils.isNotBlank(endDate),InspectionTask::getStartDate,startDate,endDate); return R.ok(inspectionTaskService.list(wrapper)); } catch (Exception e) { return R.failed("鍑洪敊"); @@ -159,28 +200,235 @@ } @GetMapping("/getUps") public R getUps(){ + int upsError=0; + int dianchiError=0; + SnmpInfo snmpInfo = new SnmpInfo(); + snmpInfo.setSnmpCommunity("private"); + snmpInfo.setSnmpVersion("1"); + snmpInfo.setSnmpPort("161"); + snmpInfo.setHostName("139.24.190.121"); + + List<String> list = new ArrayList<>(); + list.add("1.3.6.1.4.1.32701.4.1.8.1.3.6660"); + list.add("1.3.6.1.4.1.32701.4.1.8.1.3.7172"); + for (String s : list) { + String s1 = SnmpUtil.snmpGetTest(snmpInfo, s); + if(s1.equals("5")){ + upsError++; + } + } + + List<String> list1 = new ArrayList<>(); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.7686"); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.8198"); + for (String s : list1) { + String s1 = SnmpUtil.snmpGetTest(snmpInfo, s); + if(s1.equals("0")){ + upsError++; + } + } + + List<String> list2 = new ArrayList<>(); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6145"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6146"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6147"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6148"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6149"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6150"); + for (String s : list2) { + String s1 = SnmpUtil.snmpGetTest(snmpInfo, s); + if(!s1.equals("0") && !s1.equals("1")&& !s1.equals("4")&& !s1.equals("6")){ + dianchiError++; + } + } + + Map<String,Object> map = new HashMap<>(); try { map.put("ups",4); - map.put("ups2",4); + map.put("ups2",4-upsError); map.put("dianchi",6); - map.put("dianchi2",6); + map.put("dianchi2",6-dianchiError); return R.ok(map); } catch (Exception e) { return R.failed("鍑洪敊"); } } + @GetMapping("/getUpsInfo") + public R getUpsInfo(){ + List<Map<String,Object>> resultList = new ArrayList<>(); + SnmpInfo snmpInfo = new SnmpInfo(); + snmpInfo.setSnmpCommunity("private"); + snmpInfo.setSnmpVersion("1"); + snmpInfo.setSnmpPort("161"); + snmpInfo.setHostName("139.24.190.121"); + try { + List<String> list = new ArrayList<>(); + list.add("1.3.6.1.4.1.32701.4.1.8.1.3.6660"); + list.add("1.3.6.1.4.1.32701.4.1.8.1.3.7172"); + for (int i = 0; i < list.size(); i++) { + String s1 = SnmpUtil.snmpGetTest(snmpInfo, list.get(i)); + Map<String,Object> map = new HashMap<>(); + String state = ""; + if(s1.equals("5"))state="鍏虫満"; + if(s1.equals("4"))state="寮�鏈�"; + if(i==0){ + map.put("name","UPS1"); + map.put("bianliang","寮�鍏虫満鐘舵��"); + map.put("isRun",state); + } + if(i==1){ + map.put("name","UPS2"); + map.put("bianliang","寮�鍏虫満鐘舵��"); + map.put("isRun",state); + } + resultList.add(map); + } + + List<String> list1 = new ArrayList<>(); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.7686"); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.8198"); + for (int i = 0; i < list1.size(); i++) { + String s1 = SnmpUtil.snmpGetTest(snmpInfo, list1.get(i)); + Map<String,Object> map = new HashMap<>(); + String state = ""; + if(s1.equals("0"))state="鍏抽棴"; + if(s1.equals("1"))state="鎵撳紑"; + if(i==0){ + map.put("name","UPS3"); + map.put("bianliang","杈撳嚭寮�鍏�"); + map.put("isRun",state); + } + if(i==1){ + map.put("name","UPS4"); + map.put("bianliang","杈撳嚭寮�鍏�"); + map.put("isRun",state); + } + resultList.add(map); + } + + List<String> list2 = new ArrayList<>(); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6149"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6150"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6147"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6148"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6145"); + list2.add("1.3.6.1.4.1.32701.4.1.8.1.3.6146"); + + for (int i = 0; i < list2.size(); i++) { + String s1 = SnmpUtil.snmpGetTest(snmpInfo, list2.get(i)); + Map<String,Object> map = new HashMap<>(); + String state = ""; + if(s1.equals("0"))state="娴厖"; + if(s1.equals("1"))state="鍏呯數"; + if(s1.equals("4"))state="鏀剧數"; + if(s1.equals("6"))state="鍐呴樆娴嬭瘯"; + if(!s1.equals("0") && !s1.equals("1")&& !s1.equals("4")&& !s1.equals("6")){ + state="鐘舵�佸紓甯�"; + } + map.put("name","鐢垫睜"+i); + map.put("bianliang","宸ヤ綔鐘舵��"); + map.put("isRun",state); + resultList.add(map); + } + + return R.ok(resultList); + } catch (Exception e) { + return R.failed("鍑洪敊"); + } + } + + @GetMapping("/getKongtiao") public R getKongtiao(){ + int upsError=0; + int jifangError=0; + SnmpInfo snmpInfo = new SnmpInfo(); + snmpInfo.setSnmpCommunity("private"); + snmpInfo.setSnmpVersion("1"); + snmpInfo.setSnmpPort("161"); + snmpInfo.setHostName("139.24.190.121"); + + List<String> list = new ArrayList<>(); + list.add("1.3.6.1.4.1.32701.4.1.8.1.3.9729"); + list.add("1.3.6.1.4.1.32701.4.1.8.1.3.9731"); + for (String s : list) { + String s1 = SnmpUtil.snmpGetTest(snmpInfo, s); + if(s1.equals("0")){ + upsError++; + } + } + + List<String> list1 = new ArrayList<>(); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.2049"); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.2561"); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.3073"); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.4097"); + for (String s : list1) { + String s1 = SnmpUtil.snmpGetTest(snmpInfo, s); + if(s1.equals("0")){ + jifangError++; + } + } Map<String,Object> map = new HashMap<>(); + map.put("upsKongtiao",2); + map.put("upsKongtiao2",upsError); + map.put("zhongxinKongtiao",4); + map.put("zhongxinKongtiao2",jifangError); + return R.ok(map); + } + + @GetMapping("/getKongtiaoInfo") + public R getKongtiaoInfo(){ + List<Map<String,Object>> resultList = new ArrayList<>(); + SnmpInfo snmpInfo = new SnmpInfo(); + snmpInfo.setSnmpCommunity("private"); + snmpInfo.setSnmpVersion("1"); + snmpInfo.setSnmpPort("161"); + snmpInfo.setHostName("139.24.190.121"); try { - map.put("upsKongtiao",2); - map.put("upsKongtiao2",2); - map.put("zhongxinKongtiao",4); - map.put("zhongxinKongtiao2",4); - return R.ok(map); + List<String> list = new ArrayList<>(); + list.add("1.3.6.1.4.1.32701.4.1.8.1.3.9729"); + list.add("1.3.6.1.4.1.32701.4.1.8.1.3.9731"); + for (int i = 0; i < list.size(); i++) { + String state = ""; + Map<String,Object> map = new HashMap<>(); + String s1 = SnmpUtil.snmpGetTest(snmpInfo, list.get(i)); + if(s1.equals("0"))state="鍏虫満"; + if(s1.equals("1"))state="寮�鏈�"; + if(i==0){ + map.put("name","UPS鏈烘埧绌鸿皟5锛圫TULZ-CCU121A)"); + map.put("bianliang","绌鸿皟宸ヤ綔鐘舵��"); + map.put("isRun",state); + resultList.add(map); + } + if(i==1){ + map.put("name","UPS鏈烘埧绌鸿皟6锛圫TULZ-CCU121A)"); + map.put("bianliang","绌鸿皟宸ヤ綔鐘舵��"); + map.put("isRun",state); + resultList.add(map); + } + } + List<String> list1 = new ArrayList<>(); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.2049"); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.2561"); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.4097"); + list1.add("1.3.6.1.4.1.32701.4.1.8.1.3.3073"); + for (int i = 0; i < list1.size(); i++) { + String state = ""; + Map<String,Object> map = new HashMap<>(); + String s1 = SnmpUtil.snmpGetTest(snmpInfo, list1.get(i)); + if(s1.equals("0"))state="鍏抽棴"; + if(s1.equals("1"))state="寮�鍚�"; + map.put("name","涓績鏈烘埧绌鸿皟"+(i+1)); + map.put("bianliang","寮�鍏虫満鐘舵��"); + map.put("isRun",state); + resultList.add(map); + } + return R.ok(resultList); }catch (Exception e){ + e.printStackTrace(); return R.failed("鍑洪敊"); } } @@ -195,8 +443,60 @@ QueryWrapper<WarnLog> wrapper = new QueryWrapper<>(); wrapper.lambda().eq(type != null,WarnLog::getType,type) .orderByDesc(WarnLog::getWarnDate) - .last( " limit 15"); + .last( " limit 11"); List<WarnLog> list = warnService.list(wrapper); + return R.ok(list); + } + + /** + * 鍦板浘鏁版嵁 + * @param + * @return + */ + @GetMapping("/getMapData") + public R getMapData(){ + List<Map<String,Object>> list = new ArrayList<>(); + Map<String,Object> map1 = new HashMap<>(); + map1.put("lon","118.14360"); + map1.put("lat","39.67260"); + map1.put("address","娌冲寳鐪佸攼灞卞競璺寳鍖洪暱瀹侀亾603鍙�"); + map1.put("health",0); + + Map<String,Object> map2 = new HashMap<>(); + map2.put("lon","118.26958"); + map2.put("lat","39.68333"); + map2.put("address","娌冲寳鐪佸攼灞卞競寮�骞冲尯涓滆タ澶ц199鍙�"); + map2.put("health",0); + + Map<String,Object> map3 = new HashMap<>(); + map3.put("lon","118.15782"); + map3.put("lat","39.63102"); + map3.put("address","娌冲寳鐪佸攼灞卞競璺崡鍖烘柊鍗庤タ閬�76鍙�4灞�"); + map3.put("health",0); + + Map<String,Object> map4 = new HashMap<>(); + map4.put("lon","118.09289"); + map4.put("lat","39.58163"); + map4.put("address","娌冲寳鐪佸攼灞卞競涓板崡鍖烘鑻戝ぇ琛�7鍙�"); + map4.put("health",0); + + Map<String,Object> map5 = new HashMap<>(); + map5.put("lon","118.14114"); + map5.put("lat","39.83368"); + map5.put("address","娌冲寳鐪佸攼灞卞競涓版鼎鍖烘浌闆姽澶ц17鍙�"); + map5.put("health",0); + + Map<String,Object> map6 = new HashMap<>(); + map6.put("lon","118.45153"); + map6.put("lat","39.74049"); + map6.put("address","娌冲寳鐪佸攼灞卞競鍙ゅ喍鍖烘案鐩涜矾"); + map6.put("health",0); + list.add(map1); + list.add(map2); + list.add(map3); + list.add(map4); + list.add(map5); + list.add(map6); return R.ok(list); } @@ -209,8 +509,8 @@ @RequestMapping("/upload") public R upload(@RequestParam("file") MultipartFile file,@RequestParam("type") Integer type)throws Exception{ String name = file.getOriginalFilename(); - String s = name.split(".")[1]; - if(!s.equals(".xls")) { + String[] split = name.split("\\."); + if(!split[1].equals("xlsx")) { throw new Exception("鏂囦欢鏍煎紡閿欒"); } if(type == 0){ @@ -234,4 +534,5 @@ return R.ok("鎴愬姛"); } } + } -- Gitblit v1.9.1