package com.landtool.lanbase.modules.api.controller;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.serializer.SerializerFeature;
|
import com.landtool.lanbase.config.SysTemPropertyConfig;
|
import com.landtool.lanbase.modules.org.redis.OrgUserDefUnitRedis;
|
import com.landtool.lanbase.modules.org.redis.OrgUserRedis;
|
import com.landtool.lanbase.modules.org.redis.SysSystemInfoRedis;
|
import com.landtool.lanbase.modules.org.service.OrgUnitService;
|
import com.landtool.lanbase.modules.org.service.OrgUserService;
|
import com.landtool.lanbase.modules.res.entity.Res_ActionRecord;
|
import com.landtool.lanbase.modules.res.entity.Res_MainInfo;
|
import com.landtool.lanbase.modules.res.entity.ZiYuanTongJi.GroupByMuLu;
|
import com.landtool.lanbase.modules.res.entity.ZiYuanTongJi.GroupByZiYuanLeiXing;
|
import com.landtool.lanbase.modules.res.service.*;
|
import com.landtool.lanbase.modules.sys.controller.AbstractController;
|
import com.landtool.lanbase.modules.sys.service.SysFieldvalueService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.ui.Model;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import oshi.SystemInfo;
|
import oshi.hardware.CentralProcessor;
|
import oshi.hardware.GlobalMemory;
|
|
import java.text.DecimalFormat;
|
import java.util.HashMap;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
@Controller
|
@RequestMapping("/api/monitor/jitmonitor")
|
public class JitmonitorApiController extends AbstractController {
|
|
@Autowired
|
private SysTemPropertyConfig sysConfig;
|
|
@Autowired
|
private OrgUserRedis orgUserRedis;
|
|
@Autowired
|
SysSystemInfoRedis sysSystemInfoRedis;
|
|
@Autowired
|
private OrgUserDefUnitRedis orgUserDefUnitRedis;
|
|
@Autowired
|
private JitMonitorService jitMonitorService;
|
|
@Autowired
|
private ResMainInfoService resMainInfoService;
|
|
@Autowired
|
private ResProblemFeedbackService resProblemFeedbackService;
|
|
@Autowired
|
private ResCatalogService resCatalogService;
|
|
@Autowired
|
private SysFieldvalueService FieldUtils;
|
|
@Autowired
|
private OrgUnitService orgUnitService;
|
|
@Autowired
|
private OrgUserService orgUserService;
|
|
@Autowired
|
private ResApplyRecommendService resApplyRecommendService;
|
|
@Autowired
|
private ResActionRecordService resActionRecordService;
|
|
@Autowired
|
public ZiYuanMuLuService ziYuanMuLuService;
|
|
public static String strMuLu = "";
|
|
/**
|
* 资源中心
|
* @param model
|
* @return
|
*/
|
@RequestMapping("index")
|
@ResponseBody
|
public String newZiYuanZhongXinIndex(Model model) {
|
Map<String,Object> map=new HashMap<String, Object>();
|
LinkedHashMap<String, String> ResourceTypeList = FieldUtils.getFieldListByKey("ResourceType");// 获取资源类型列表
|
// 资源类型饼状统计图
|
List<GroupByZiYuanLeiXing> resourceclassList = resMainInfoService.selectResMainInfoGroupByLeiXing();
|
|
Integer resourcecount=resMainInfoService.getAllTotal();
|
String AllSeries = "";
|
// 多于4个类型的话数据显示前7个资源数量最多的类型，后面的都以其它统计
|
if (resourceclassList.size() > 4) {
|
int counter = 0;
|
for (int i = 4; i < resourceclassList.size(); i++) {
|
counter += resourceclassList.get(i).getCount();
|
}
|
for (int i = 0; i < 4; i++) {
|
GroupByZiYuanLeiXing item = resourceclassList.get(i);
|
String leixing = ResourceTypeList.get(item.getResourceclass());
|
AllSeries += (AllSeries == "" ? "" : ",") + "{ value: " + item.getCount() + ", name: '" + leixing + "'}";
|
}
|
AllSeries += (AllSeries == "" ? "" : ",") + "{ value: " + counter + ", name: '" + "其它" + "'}";
|
}
|
// 少于等于4个类型就全部显示
|
else {
|
for (int i = 0; i < resourceclassList.size(); i++) {
|
GroupByZiYuanLeiXing item = resourceclassList.get(i);
|
String leixing = ResourceTypeList.get(item.getResourceclass());
|
AllSeries += (AllSeries == "" ? "" : ",") + "{ value: " + item.getCount() + ", name: '" + leixing + "'}";
|
}
|
}
|
map.put("resourceclassSeries", "[" + AllSeries + "]");
|
|
|
|
// 资源目录统计图
|
List<GroupByMuLu> catlogidList = resMainInfoService.selectResMainInfoGroupByMuLu();
|
String MuLuLegends = "";
|
String MuLuSeries = "";
|
for (int i = 0; i < catlogidList.size(); i++) {
|
GroupByMuLu item = catlogidList.get(i);
|
// if (item.getCatlogCode().equals("0"))
|
// continue;
|
strMuLu = "";
|
// String legend = GetBianMu(item.getCatlogCode() == null ? 0 : Integer.parseInt(item.getCatlogCode()));
|
MuLuLegends += (MuLuLegends == "" ? "" : ",") + "'" + item.getTitle() + "'";
|
MuLuSeries += (MuLuSeries == "" ? "" : ",") + item.getCount();
|
}
|
map.put("MuLuLegends", "[" + MuLuLegends + "]");
|
map.put("MuLuSeries", "[" + MuLuSeries + "]");
|
|
// 资源审核状态统计图
|
map.put("shenhezhuangtaiSeries", "[" + ziYuanMuLuService.getZYTJ_ShenHeZhuangTai() + "]");
|
|
//共享协议统计图
|
map.put("sharprotocolSeries", "[" + ziYuanMuLuService.getGongXiangXieYiChart() + "]");
|
map.put("resourcecount",resourcecount);
|
|
|
|
|
return JSONObject.toJSONStringWithDateFormat(map, "yyyy-MM-dd HH:mm:ss", SerializerFeature.PrettyFormat);
|
}
|
/**
|
* 资源推荐
|
*/
|
private int getMainInfoRecommendCount() {
|
Long userid = getUserId();
|
Long unitId = orgUserService.getDefaultUnit(userid).getUnitid();
|
int count = 0;
|
//获取关键字
|
List<String> keyWords = resActionRecordService.selectKeyWordsByUserid(Integer.parseInt(userid.toString()));
|
if (keyWords != null && keyWords.size() > 0) {
|
Map<String, Object> paramMap = new HashMap<String, Object>();
|
paramMap.put("userid", userid);
|
paramMap.put("isDiTuFuwu", null);
|
List<Res_MainInfo> resourceList = resActionRecordService.selectMainInfoRecommends(paramMap);
|
count = resourceList != null && resourceList.size() > 0 ? count = resourceList.size() : 0;
|
}
|
return count;
|
}
|
|
@RequestMapping("/queryResActionRecordByZyId")
|
@ResponseBody
|
public String selectResActionRecordByResourceId(Integer resourceid,Integer page,Integer limit){
|
Map<String,Object> param=new HashMap<>();
|
param.put("page", page);
|
param.put("limit", limit);
|
param.put("resourceid", resourceid);
|
List<Res_ActionRecord> list=jitMonitorService.selectResActionRecordByResourceId(param);
|
for(Res_ActionRecord map: list){
|
map.setUsername(orgUserService.getChinesename(map.getUserid()));
|
}
|
|
JSONObject json=new JSONObject();
|
json.put("total", list.size());
|
json.put("data", list);
|
return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.PrettyFormat);
|
}
|
@RequestMapping("warning")
|
@ResponseBody
|
public String warnlogshow() {
|
List<Map> list=resProblemFeedbackService.getlatestalarm();
|
JSONObject json=new JSONObject();
|
json.put("total", list.size());
|
json.put("data", list);
|
return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.PrettyFormat);
|
}
|
@RequestMapping("serverstatus")
|
@ResponseBody
|
public String serverstatus() throws InterruptedException {
|
JSONObject json=new JSONObject();
|
json.put("cpuinfo", printlnCpuInfo());
|
json.put("meminfo", MemInfo());
|
return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.PrettyFormat);
|
|
}
|
|
@RequestMapping("getGisResNumByResStatus")
|
@ResponseBody
|
public String getGisResNumByResStatus() throws InterruptedException {
|
JSONObject json=new JSONObject();
|
Map<String,Object> map=new HashMap<>();
|
map.put("actionType", "调用");
|
List<Map> activeResources=jitMonitorService.getActiveResource(map);
|
json.put("resStatus", jitMonitorService.getGisResNumByResStatus());
|
json.put("activeResource", activeResources);
|
json.put("activeResourceNum", activeResources.size());
|
return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.PrettyFormat);
|
}
|
|
/**
|
* 统计调用服务次数最多的前10个用户
|
* @return
|
* @throws InterruptedException
|
*/
|
@RequestMapping("getTop10UserAndUnit")
|
@ResponseBody
|
public String calTop10UserForInvokingResource(String actionType) throws InterruptedException {
|
//获取用户
|
Map<String,Object> map=new HashMap<>();
|
map.put("actionType", actionType);
|
return JSONObject.toJSONStringWithDateFormat(jitMonitorService.calTop10UserForInvokingResource(map), "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
|
}
|
|
|
|
|
/**
|
* 统计调用服务次数最多的前10个单位
|
* @return
|
* @throws InterruptedException
|
*/
|
@RequestMapping("getTop10Sys")
|
@ResponseBody
|
public String calTop10SysForInvokingResource(String actionType) throws InterruptedException {
|
Map<String,Object> map=new HashMap<>();
|
map.put("actionType", actionType);
|
return JSONObject.toJSONStringWithDateFormat(jitMonitorService.calTop10SysForInvokingResource(map), "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
|
}
|
|
/**
|
* 日志统计 res_action_
|
*/
|
@RequestMapping("/assignLogChart")
|
public String assignLogChart() {
|
|
|
return null;
|
|
}
|
|
|
/**
|
* 查询热门资源前10
|
* @params actionType 操作类型
|
* @return
|
* @throws InterruptedException
|
*/
|
@RequestMapping("getHotZyByActionType")
|
@ResponseBody
|
public String getTop10ResourceByActionType(String actionType) throws InterruptedException {
|
Map<String,Object> map=new HashMap<>();
|
map.put("actionType", actionType);
|
//List<Map<String,Object>> list=jitMonitorService.getHotZy();
|
return JSONObject.toJSONStringWithDateFormat(jitMonitorService.getTop10ResourceByActionType(map), "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
|
}
|
|
|
|
|
@RequestMapping("getResourceAssignTimesCount")
|
@ResponseBody
|
public String getResourceAssignTimesCount(Integer resourceid) throws InterruptedException {
|
Map<String, Object> map=new HashMap<>();
|
map.put("actionType", "调用");
|
map.put("resourceid", resourceid);
|
List<Map> list=jitMonitorService.getResourceAssignTimesCount(map);
|
JSONObject json=new JSONObject();
|
json.put("data", list);
|
return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
|
|
}
|
@RequestMapping("queryResourceLog")
|
@ResponseBody
|
public String queryResourceLog(Integer resourceid) throws InterruptedException {
|
Map<String, Object> map=new HashMap<>();
|
map.put("actionType", "调用");
|
map.put("resourceid", resourceid);
|
List<Map> list=jitMonitorService.queryResourceLog(map);
|
JSONObject json=new JSONObject();
|
json.put("data", list);
|
return JSONObject.toJSONStringWithDateFormat(json, "yyyy-MM-dd HH:mm:ss", SerializerFeature.WriteMapNullValue);
|
|
}
|
|
|
private JSONObject printlnCpuInfo() throws InterruptedException {
|
//map.put("----------------cpu信息----------------");
|
SystemInfo systemInfo = new SystemInfo();
|
CentralProcessor processor = systemInfo.getHardware().getProcessor();
|
long[] prevTicks = processor.getSystemCpuLoadTicks();
|
// 睡眠1s
|
TimeUnit.SECONDS.sleep(1);
|
long[] ticks = processor.getSystemCpuLoadTicks();
|
long nice = ticks[CentralProcessor.TickType.NICE.getIndex()] - prevTicks[CentralProcessor.TickType.NICE.getIndex()];
|
long irq = ticks[CentralProcessor.TickType.IRQ.getIndex()] - prevTicks[CentralProcessor.TickType.IRQ.getIndex()];
|
long softirq = ticks[CentralProcessor.TickType.SOFTIRQ.getIndex()] - prevTicks[CentralProcessor.TickType.SOFTIRQ.getIndex()];
|
long steal = ticks[CentralProcessor.TickType.STEAL.getIndex()] - prevTicks[CentralProcessor.TickType.STEAL.getIndex()];
|
long cSys = ticks[CentralProcessor.TickType.SYSTEM.getIndex()] - prevTicks[CentralProcessor.TickType.SYSTEM.getIndex()];
|
long user = ticks[CentralProcessor.TickType.USER.getIndex()] - prevTicks[CentralProcessor.TickType.USER.getIndex()];
|
long iowait = ticks[CentralProcessor.TickType.IOWAIT.getIndex()] - prevTicks[CentralProcessor.TickType.IOWAIT.getIndex()];
|
long idle = ticks[CentralProcessor.TickType.IDLE.getIndex()] - prevTicks[CentralProcessor.TickType.IDLE.getIndex()];
|
long totalCpu = user + nice + cSys + idle + iowait + irq + softirq + steal;
|
JSONObject map=new JSONObject();
|
|
|
map.put("cpu核数", processor.getLogicalProcessorCount());
|
map.put("cpu系统使用率", new DecimalFormat("#.##%").format(cSys * 1.0 / totalCpu));
|
map.put("cpu用户使用率", new DecimalFormat("#.##%").format(user * 1.0 / totalCpu));
|
map.put("cpu当前等待率", new DecimalFormat("#.##%").format(iowait * 1.0 / totalCpu));
|
map.put("cpu当前使用率", new DecimalFormat("#.##%").format(1.0-(idle * 1.0 / totalCpu)));
|
return map;
|
}
|
|
public JSONObject MemInfo(){
|
JSONObject map=new JSONObject();
|
SystemInfo systemInfo = new SystemInfo();
|
GlobalMemory memory = systemInfo.getHardware().getMemory();
|
//总内存
|
long totalByte = memory.getTotal();
|
//剩余
|
long acaliableByte = memory.getAvailable();
|
map.put("总内存", formatByte(totalByte));
|
map.put("使用", formatByte(totalByte-acaliableByte));
|
map.put("剩余内存 ", formatByte(acaliableByte));
|
map.put("使用率", new DecimalFormat("#.##%").format((totalByte-acaliableByte)*1.0/totalByte));
|
return map;
|
}
|
public static String formatByte(long byteNumber){
|
//换算单位
|
double FORMAT = 1024.0;
|
double kbNumber = byteNumber/FORMAT;
|
if(kbNumber<FORMAT){
|
return new DecimalFormat("#.##KB").format(kbNumber);
|
}
|
double mbNumber = kbNumber/FORMAT;
|
if(mbNumber<FORMAT){
|
return new DecimalFormat("#.##MB").format(mbNumber);
|
}
|
double gbNumber = mbNumber/FORMAT;
|
if(gbNumber<FORMAT){
|
return new DecimalFormat("#.##GB").format(gbNumber);
|
}
|
double tbNumber = gbNumber/FORMAT;
|
return new DecimalFormat("#.##TB").format(tbNumber);
|
}
|
|
@RequestMapping("warningIdList")
|
@ResponseBody
|
public String warningIdList() {
|
List<Map> getlatestalarm = resProblemFeedbackService.getlatestalarm();
|
List<Object> resourceids = resProblemFeedbackService.getlatestalarm().stream().map(map -> map.get("RESOURCEID")).collect(Collectors.toList());
|
JSONObject json=new JSONObject();
|
json.put("data", resourceids);
|
return JSONObject.toJSONString(json);
|
}
|
}
|
