package com.zy.asrs.controller;
|
|
import com.core.common.Arith;
|
import com.core.common.Cools;
|
import com.core.common.R;
|
import com.zy.asrs.entity.AxisBean;
|
import com.zy.asrs.entity.LocChartPie;
|
import com.zy.asrs.entity.WorkChartAxis;
|
import com.zy.asrs.mapper.ReportQueryMapper;
|
import com.zy.common.model.MatDto;
|
import com.zy.common.model.command.LedCommand;
|
import com.zy.common.service.CommonService;
|
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;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
@RestController
|
@RequestMapping("/monitor")
|
public class MonitorController {
|
|
private static final String[] WEEK = {"星期日","星期一","星期二","星期三","星期四","星期五","星期六"};
|
|
|
@Autowired
|
private ReportQueryMapper reportQueryMapper;
|
|
/**
|
* 获取当前时间
|
*/
|
@GetMapping("/date")
|
public R monitorDate() {
|
Date now = new Date();
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(now);
|
return R.ok(
|
Cools.add("year", calendar.get(Calendar.YEAR))
|
.add("month", CommonService.zerofill(String.valueOf(calendar.get(Calendar.MONTH)+1), 2))
|
.add("day", CommonService.zerofill(String.valueOf(calendar.get(Calendar.DATE)), 2))
|
.add("hour", CommonService.zerofill(String.valueOf(calendar.get(Calendar.HOUR_OF_DAY)), 2))
|
.add("minute", CommonService.zerofill(String.valueOf(calendar.get(Calendar.MINUTE)), 2))
|
.add("second", CommonService.zerofill(String.valueOf(calendar.get(Calendar.SECOND)) , 2))
|
.add("week", WEEK[calendar.get(Calendar.DAY_OF_WEEK)-1])
|
);
|
}
|
|
|
/**
|
* 入库报表 -- 折线图
|
*/
|
@GetMapping("/pakin/rep")
|
public R monitorPakinRep(){
|
// 入库
|
List<Map<String, Object>> pakinRep = reportQueryMapper.queryPakinRep();
|
for (Map<String, Object> map : pakinRep) {
|
if (map.get("node")!=null) {
|
map.put("node", String.valueOf(map.get("node")).substring(5, 10));
|
}
|
}
|
// 出库
|
List<Map<String, Object>> pakoutRep = reportQueryMapper.queryPakinRep();
|
return R.ok(pakinRep);
|
}
|
|
@GetMapping("/line/charts")
|
public R locIoLineCharts(){
|
Map<String,Object> map=new HashMap<String, Object>();
|
List<AxisBean> list = new ArrayList<AxisBean>();
|
|
List<WorkChartAxis> listChart = reportQueryMapper.getChartAxis();
|
|
if(listChart!=null) {
|
ArrayList<Integer> data1 = new ArrayList<Integer>();
|
ArrayList<Integer> data2 = new ArrayList<Integer>();
|
|
SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd");
|
Calendar calendar = Calendar.getInstance();
|
calendar.add(Calendar.DATE, -12);
|
for(int i=0;i<12;i++) {
|
boolean flag = true;
|
calendar.add(Calendar.DATE, 1);
|
String str = sf.format(calendar.getTime());
|
for(WorkChartAxis workChart : listChart) {
|
if(str.equals(workChart.getYmd())) {
|
data1.add(workChart.getInqty());
|
data2.add(workChart.getOutqty());
|
flag = false;
|
break;
|
}
|
}
|
if(flag) {
|
data1.add(0);
|
data2.add(0);
|
}
|
}
|
AxisBean inqty = new AxisBean();
|
inqty.setName("入库数量");
|
Integer[] array1 = new Integer[data1.size()];
|
inqty.setData(data1.toArray(array1));
|
list.add(inqty);
|
AxisBean outqty = new AxisBean();
|
outqty.setName("出库数量");
|
Integer[] array2 = new Integer[data2.size()];
|
outqty.setData(data2.toArray(array2));
|
list.add(outqty);
|
}
|
map.put("rows",list);
|
return R.ok(map);
|
}
|
|
/**
|
* 库位使用情况统计
|
*/
|
@GetMapping("/loc/rep")
|
public R monitorLocRep(){
|
List<Map<String, Object>> pie = new ArrayList<>();
|
|
LocChartPie locUseRate = reportQueryMapper.getLocUseRate();
|
if(locUseRate!=null) {
|
Map<String, Object> map = new HashMap<>();
|
map.put("name", "在库");
|
map.put("value", locUseRate.getFqty());
|
pie.add(map);
|
|
Map<String, Object> map1 = new HashMap<>();
|
map1.put("name", "空");
|
map1.put("value", locUseRate.getOqty());
|
pie.add(map1);
|
|
Map<String, Object> map2 = new HashMap<>();
|
map2.put("name", "使用");
|
map2.put("value", locUseRate.getUqty());
|
pie.add(map2);
|
|
Map<String, Object> map3 = new HashMap<>();
|
map3.put("name", "禁用");
|
map3.put("value", locUseRate.getXqty());
|
pie.add(map3);
|
}
|
|
// 总库位数
|
Integer total = (int) Arith.add(0, locUseRate.getFqty(), locUseRate.getOqty(), locUseRate.getUqty(), locUseRate.getXqty());
|
// 使用中
|
Integer used = locUseRate.getFqty() + locUseRate.getUqty();
|
// 库位使用率
|
double usedDivides = Arith.divides(3, used, total);
|
double usedPr = Arith.multiplys(1, usedDivides, 100);
|
|
return R.ok(
|
Cools.add("pie", pie)
|
.add("stockCunt", locUseRate.getFqty())
|
.add("emptyCount", locUseRate.getOqty())
|
.add("noneCount", locUseRate.getXqty())
|
.add("total", total)
|
.add("used", used)
|
.add("usedPr", usedPr)
|
);
|
}
|
|
/**
|
* 获取其他信息
|
*/
|
@GetMapping("/led")
|
public R monitorLed(@RequestParam("ledId") Integer ledId) {
|
String ledContent = "";
|
List<LedCommand> commandList = new ArrayList<>();
|
List<MatDto> matDtoList = new ArrayList<>();
|
MatDto matDto = new MatDto(
|
"001",
|
"原材料",
|
100.0,
|
150.0,
|
100.0,
|
200.0,
|
"1.2*1.3",
|
"ZGDW890",
|
"80000001",
|
"DWT01",
|
"中国电网",
|
"中国电网",
|
"ZGDW4396",
|
"ZGDW-9945"
|
|
);
|
matDtoList.add(matDto);
|
if (ledId == 100){
|
LedCommand command = new LedCommand(
|
"全板入库",
|
9527,
|
100,
|
100,
|
"0100101",
|
"",
|
matDtoList,
|
false,
|
1,
|
"80000001"
|
);
|
commandList.add(command);
|
}
|
return R.ok().add(commandList);
|
}
|
|
/**
|
* 异常通知
|
*/
|
@GetMapping("/led/error")
|
public R monitorLedError(@RequestParam("ledId") Integer ledId) {
|
String errorMsg = "";
|
if (ledId == 100){
|
// errorMsg = "麦当劳VS肯德基";
|
}
|
return R.ok().add(errorMsg);
|
}
|
|
@GetMapping("/getLedInfos")
|
public R getLedInfos(HttpServletRequest request) {
|
String remoteAddr = request.getRemoteAddr();
|
if (remoteAddr.equals("127.0.0.1")) {
|
return R.ok();
|
}
|
return R.ok();
|
}
|
}
|
