package com.landtool.lanbase.modules.log.controller;
|
|
import cn.hutool.core.date.DateTime;
|
import com.alibaba.fastjson.JSONObject;
|
import com.landtool.lanbase.common.utils.PageUtils;
|
import com.landtool.lanbase.common.utils.Query;
|
import com.landtool.lanbase.common.utils.Result;
|
import com.landtool.lanbase.modules.log.entity.LogAction;
|
import com.landtool.lanbase.modules.log.entity.LogKettleJob;
|
import com.landtool.lanbase.modules.log.entity.LogKettleStepcount;
|
import com.landtool.lanbase.modules.log.entity.LogKettleStepcountJoinYear;
|
import com.landtool.lanbase.modules.log.service.LogActionService;
|
import com.landtool.lanbase.modules.log.service.LogKettleStepcountService;
|
import com.landtool.lanbase.modules.sys.controller.AbstractController;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiParam;
|
import org.apache.shiro.authz.annotation.RequiresPermissions;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.sql.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
@RestController
|
@RequestMapping("/log/kettlestepcount")
|
@Api(value = "", tags = {"日志"})
|
public class LogKettleStepcountController extends AbstractController{
|
|
@Autowired
|
private LogKettleStepcountService logKettleStepcountService;
|
|
/**
|
* 列表
|
*/
|
@com.landtool.lanbase.common.annotation.LogAction("数据抽取,抽取日志,抽取日志列表查询,查询")
|
@RequestMapping(value="/list",method ={RequestMethod.POST, RequestMethod.GET})
|
@RequiresPermissions("org_user_admin")
|
@ApiOperation(
|
value = "系统模块操作日志",
|
notes = "系统模块操作日志列表"
|
)
|
public Result list(@ApiParam(name="params",value="",required=true)@RequestParam Map<String, Object> params){
|
//查询列表数据
|
Query query = new Query(params);
|
List<LogKettleStepcount> actionList = logKettleStepcountService.queryList(query);
|
actionList.stream().forEach(s->{
|
long endTime = s.getEndDate().getTime();
|
long startTime = s.getStartDate().getTime();
|
Double totalTime=((double) (endTime-startTime)/1000/60);//不足0.5取值0.5 ,大于0.5小于1 取值 1
|
if(totalTime.compareTo(0.50)>=0&&totalTime.compareTo(1.0)<=0){
|
totalTime=1.0;
|
}else if(totalTime.compareTo(0.5)<0){
|
totalTime=0.5;
|
}else { //大于 1.0 的取值保留小数点后2位
|
totalTime = new BigDecimal(totalTime.toString()).setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue();
|
}
|
s.setTotalTime(totalTime);
|
});
|
int total = logKettleStepcountService.queryTotal(query);
|
PageUtils pageUtil = new PageUtils(actionList, total, query.getLimit(), query.getPage());
|
return Result.ok().put("page", pageUtil);
|
}
|
|
/**
|
* 信息
|
*/
|
@GetMapping("/info/{channelid}")
|
public Result info(@ApiParam(name="channelid",value="",required=true)@PathVariable("channelid") String channelid){
|
LogKettleStepcount logKettleStepcount = logKettleStepcountService.queryObject(channelid);
|
String result = "";
|
if (logKettleStepcount != null) {
|
result = logKettleStepcount.getLogfield();
|
}
|
return Result.ok().put("result", result);
|
}
|
|
@RequestMapping(value="/getechartdata",method ={RequestMethod.POST})
|
public Result getechartdata(@ApiParam(name="params",value="",required=true)@RequestParam Map<String, Object> params){
|
Query query = new Query(params);
|
Integer yearBeg = DateTime.now().year()-9;
|
Integer yearFin = DateTime.now().year();
|
if(params.get("logdatebegin").equals("") && params.get("logdatefinish").equals("")){
|
params.put("logdatebegin", DateTime.now().year()-9);
|
}
|
if(!params.get("logdatebegin").equals("") && !params.get("logdatefinish").equals("")){
|
yearBeg = Integer.valueOf(params.get("logdatebegin").toString());
|
yearFin = Integer.valueOf(params.get("logdatefinish").toString());
|
}
|
if(!params.get("logdatebegin").equals("") && params.get("logdatefinish").equals("")){
|
yearBeg = Integer.valueOf(params.get("logdatebegin").toString());
|
yearFin = yearBeg + 9;
|
params.replace("logdatefinish",yearFin);
|
}
|
if(!params.get("logdatefinish").equals("") && params.get("logdatebegin").equals("")){
|
yearFin = Integer.valueOf(params.get("logdatefinish").toString());
|
yearBeg = yearFin-9;
|
params.replace("logdatebegin",yearBeg);
|
}
|
List<LogKettleStepcountJoinYear> list = logKettleStepcountService.queryLinesByYear(query);
|
String legendData = "";
|
String inData = "";
|
String outData = "";
|
String rsb = "";
|
for (int i = yearBeg; i <= yearFin; i++)
|
{
|
legendData += "'" + i + "年',";
|
boolean isExits = false;
|
for (int j=0;j<list.size();j++){
|
if(list.get(j).getYear() == i){
|
inData += list.get(j).getSuminput() + ",";
|
outData += list.get(j).getSumoutput() + ",";
|
isExits = true;
|
break;
|
}
|
}
|
if(!isExits){
|
inData += "0" + ",";
|
outData += "0" + ",";
|
}
|
}
|
legendData = legendData.substring(0,legendData.length()-1);
|
inData = inData.length() > 0 ? inData.substring(0,inData.length()-1):inData;
|
outData = outData.length() > 0 ? outData.substring(0,outData.length()-1):outData;
|
rsb = "{legendData:[" + legendData + "],seriesData:[[" + inData + "],[" + outData + "]]}";
|
return Result.ok().put("data",rsb);
|
}
|
}
|
