package com.zy.asrs.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Arith;
|
import com.core.common.Cools;
|
import com.core.common.R;
|
import com.zy.asrs.domain.dto.AxisBean;
|
import com.zy.asrs.domain.dto.WorkChartAxis;
|
import com.zy.asrs.domain.vo.LocChartPie;
|
import com.zy.asrs.entity.RgvOneSign;
|
import com.zy.asrs.entity.WaitPakin;
|
import com.zy.asrs.mapper.ReportQueryMapper;
|
import com.zy.asrs.mapper.RgvOneSignMapper;
|
import com.zy.asrs.mapper.WaitPakinMapper;
|
import com.zy.asrs.service.ApiLogService;
|
import com.zy.asrs.service.WrkDetlService;
|
import com.zy.common.model.MatDto;
|
import com.zy.common.service.CommonService;
|
import com.zy.core.CrnThread;
|
import com.zy.core.cache.SlaveConnection;
|
import com.zy.core.enums.SlaveType;
|
import com.zy.core.model.DevpSlave;
|
import com.zy.core.model.LedSlave;
|
import com.zy.core.model.command.LedCommand;
|
import com.zy.core.model.protocol.CrnProtocol;
|
import com.zy.core.model.protocol.StaProtocol;
|
import com.zy.core.properties.SlaveProperties;
|
import com.zy.core.thread.BarcodeThread;
|
import com.zy.core.thread.LedThread;
|
import com.zy.core.thread.SiemensDevpThread;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* Created by vincent on 2020/11/16
|
*/
|
@RestController
|
@RequestMapping("/monitor")
|
public class MonitorController {
|
|
private static final String[] WEEK = {"星期日","星期一","星期二","星期三","星期四","星期五","星期六"};
|
|
@Autowired
|
private ReportQueryMapper reportQueryMapper;
|
@Autowired
|
private SlaveProperties slaveProperties;
|
@Autowired
|
private WrkDetlService wrkDetlService;
|
@Autowired
|
private WaitPakinMapper waitPakinMapper;
|
@Autowired
|
private ApiLogService apiLogService;
|
@Autowired
|
private RgvOneSignMapper rgvOneSignMapper;
|
|
/**
|
* 获取当前时间
|
*/
|
@PostMapping("/barcode/two")
|
public R barcodeTwo(@RequestParam Integer palletizingNo) {
|
Date now = new Date();
|
|
String barcode = "";
|
for (DevpSlave devp : slaveProperties.getDevp()) {
|
// 遍历入库口
|
for (DevpSlave.Sta inSta : devp.getDriveSta()) {
|
if (inSta.getStaNo().equals(palletizingNo)){
|
SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 2);
|
StaProtocol staProtocolPall = devpThread.getStation().get(palletizingNo);
|
if (staProtocolPall == null) {
|
continue;
|
} else {
|
staProtocolPall = staProtocolPall.clone();
|
}
|
String errorSta = "";
|
boolean signSta = false;
|
|
if (!staProtocolPall.isAutoing()){
|
errorSta = errorSta+"站点非自动！！！";
|
signSta = true;
|
}
|
if (!staProtocolPall.isLoading()){
|
errorSta = errorSta+"站点无托盘！！！";
|
signSta = true;
|
}
|
if (staProtocolPall.getWorkNo() != 0 ){
|
errorSta = errorSta+"站点存在任务号！！！";
|
signSta = true;
|
}
|
if (!staProtocolPall.isPakMk()){
|
errorSta = errorSta+"站点存在锁定标记！！！";
|
signSta = true;
|
}
|
if (signSta){
|
try{
|
// 保存接口日志
|
apiLogService.save(
|
"中控申请获取"+palletizingNo+"站点当前条码信息",
|
"/monitor/barcode/two",
|
null,
|
null,
|
JSON.toJSONString(palletizingNo),
|
"未就绪！！！请等待... 原因："+errorSta,
|
false
|
);
|
}catch (Exception e){
|
}
|
return R.error("未就绪！！！请等待... 原因："+errorSta);
|
}
|
|
// 获取条码扫描仪信息
|
BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, inSta.getBarcode());
|
if (barcodeThread == null) {
|
continue;
|
}
|
barcode = barcodeThread.getBarcode();
|
|
if (!Cools.isEmpty(barcode)) {
|
// log.info("{}号条码扫描器检测条码信息：{}", inSta.getBarcode(), barcode);
|
if ("NG".endsWith(barcode) || "NoRead".equals(barcode) || "00000000".equals(barcode) || "000000".equals(barcode)) {
|
barcode = "";
|
}
|
} else {
|
break;
|
}
|
}
|
}
|
}
|
// Calendar calendar = Calendar.getInstance();
|
// calendar.setTime(now);
|
if (Cools.isEmpty(barcode) || barcode.equals("")){
|
try{
|
// 保存接口日志
|
apiLogService.save(
|
"中控申请获取"+palletizingNo+"站点当前条码信息",
|
"/monitor/barcode/two",
|
null,
|
null,
|
JSON.toJSONString(palletizingNo),
|
"未就绪！！！托盘条码为空！！！请检查！！！",
|
false
|
);
|
}catch (Exception e){
|
}
|
return R.error("未就绪！！！托盘条码为空！！！请检查！！！");
|
}
|
if (waitPakinMapper.selectCount(new EntityWrapper<WaitPakin>().eq("zpallet", barcode))!=0){
|
try{
|
// 保存接口日志
|
apiLogService.save(
|
"中控申请获取"+palletizingNo+"站点当前条码信息",
|
"/monitor/barcode/two",
|
null,
|
null,
|
JSON.toJSONString(palletizingNo),
|
"未就绪！！！托盘条码不为空但是已存在数据，不可重复使用！！！请检查！！！",
|
false
|
);
|
}catch (Exception e){
|
}
|
return R.error("未就绪！！！托盘条码不为空但是已存在数据，不可重复使用！！！请检查或重新获取！！！");
|
}
|
|
|
RgvOneSign JarTwo = rgvOneSignMapper.selectOneSign(palletizingNo+"barcode"+barcode);
|
if (!Cools.isEmpty(JarTwo)){
|
try{
|
// 保存接口日志
|
apiLogService.save(
|
"中控申请获取"+palletizingNo+"站点当前条码信息",
|
"/monitor/barcode/two",
|
null,
|
null,
|
JSON.toJSONString(palletizingNo),
|
"未就绪！！！条码更新中....",
|
false
|
);
|
}catch (Exception e){
|
}
|
return R.error("未就绪！！！条码更新中....");
|
}
|
|
try{
|
rgvOneSignMapper.deleteBarcode(palletizingNo+"barcode");
|
try{
|
// 保存接口日志
|
apiLogService.save(
|
"中控申请获取"+palletizingNo+"站点当前条码信息",
|
"/monitor/barcode/two",
|
null,
|
null,
|
JSON.toJSONString(palletizingNo),
|
JSON.toJSONString("清除托盘码标记成功！！！"),
|
true
|
);
|
}catch (Exception e){
|
}
|
} catch (Exception e){
|
try{
|
// 保存接口日志
|
apiLogService.save(
|
"中控申请获取"+palletizingNo+"站点当前条码信息",
|
"/monitor/barcode/two",
|
null,
|
null,
|
JSON.toJSONString(palletizingNo),
|
JSON.toJSONString("清除托盘码标记异常！！！"),
|
false
|
);
|
}catch (Exception e1){
|
}
|
}
|
|
Cools.CoolMap coolMap = Cools.add("barcode", barcode).add("Date", now);
|
try{
|
// 保存接口日志
|
apiLogService.save(
|
"中控申请获取"+palletizingNo+"站点当前条码信息",
|
"/monitor/barcode/two",
|
null,
|
null,
|
JSON.toJSONString(palletizingNo),
|
JSON.toJSONString("barcode:"+barcode),
|
true
|
);
|
}catch (Exception e){
|
}
|
return R.ok(coolMap);
|
}
|
|
/**
|
* 获取当前时间
|
*/
|
@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);
|
}
|
|
/**
|
* 自动补零
|
*/
|
private List<Map<String, Object>> fill(List<Map<String, Object>> list, int start, int end){
|
for (int i = start ; i <= end; i++){
|
boolean exist = false;
|
for (Map seq : list){
|
if (Integer.parseInt(String.valueOf(seq.get("node"))) == i){
|
exist = true;
|
}
|
}
|
if (!exist){
|
HashMap<String, Object> map = new HashMap<>();
|
map.put("node", i);
|
map.put("val", 0);
|
list.add(map);
|
}
|
}
|
list.sort(Comparator.comparingInt(o -> (int) o.get("node")));
|
return list;
|
}
|
|
/**
|
* x轴单位转换
|
* @param dot y轴数值保留小数位
|
*/
|
private List<Map<String, Object>> convert(List<Map<String, Object>> list, StatsType statsType, int dot){
|
for (Map<String, Object> map : list){
|
Object val = map.get("val");
|
map.put("val", Arith.multiplys(dot, 1, (Number) val));
|
Object node = map.get("node");
|
switch (statsType){
|
case MONTH:
|
map.put("node", node + "号");
|
break;
|
case YEAR:
|
map.put("node", node + "月");
|
break;
|
default:
|
break;
|
}
|
}
|
return list;
|
}
|
|
enum StatsType{
|
|
YEAR(1,1, 12),
|
MONTH(2,1, 30),
|
;
|
|
int id;
|
int start;
|
int end;
|
StatsType(int id, int start, int end) {
|
this.id = id;
|
this.start = start;
|
this.end = end;
|
}
|
|
static StatsType get(int id) {
|
StatsType[] values = StatsType.values();
|
for (StatsType statsType : values){
|
if (statsType.id == id){
|
return statsType;
|
}
|
}
|
throw new RuntimeException("找不到StatsType类型");
|
}
|
|
}
|
|
|
/***** 电视APP相关接口 ******/
|
@GetMapping("/led/error")
|
public R monitorLedError(@RequestParam("ledId") Integer ledId) {
|
String errorMsg = "";
|
for (LedSlave slave : slaveProperties.getLed()) {
|
if (slave.getStaArr().contains(ledId)) {
|
LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, slave.getId());
|
if (null != ledThread) {
|
errorMsg = ledThread.getErrorMsg().toString();
|
}
|
}
|
}
|
|
return R.ok().add(errorMsg);
|
}
|
|
@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 = null;
|
for (LedSlave slave : slaveProperties.getLed()) {
|
if (slave.getStaArr().contains(ledId)) {
|
LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, slave.getId());
|
if (null != ledThread) {
|
ledContent = ledThread.getStringBuffer().toString();
|
commandList = ledThread.getCommandList();
|
}
|
}
|
}
|
// MatDto matDto = new MatDto();
|
// matDto.setMatNo("1111");
|
// matDto.setCount(100.0);
|
// matDto.setMaknx("测试用料");
|
// LedCommand ledCommand = new LedCommand();
|
// ledCommand.setStaNo(8);
|
// ledCommand.setTitle("入库启动");
|
// ledCommand.setLocNo("0100101");
|
// ledCommand.setWorkNo(9998);
|
// ledCommand.setEmptyMk(false);
|
// ledCommand.setIoType(1);
|
// ledCommand.setSourceStaNo(15);
|
// ArrayList<MatDto> matDtos = new ArrayList<>();
|
// matDtos.add(matDto);
|
// ledCommand.setMatDtos(matDtos);
|
// ArrayList<LedCommand> ledCommands = new ArrayList<>();
|
// ledCommands.add(ledCommand);
|
// return R.ok(ledCommands);
|
return R.ok().add(commandList);
|
}
|
|
/**
|
* 获取其他信息
|
*/
|
@GetMapping("/led/useInfo")
|
public R monitorLedUseInfo(@RequestParam("ledId") Integer ledId) {
|
Integer count1 = wrkDetlService.count1();
|
Integer count11 = wrkDetlService.count11();
|
Integer count3 = wrkDetlService.count3();
|
Map<String, Object> map = new HashMap<>();
|
map.put("count1", count1+count11);
|
map.put("count2", count3);
|
return R.ok().add(map);
|
}
|
/**
|
* 获取其他信息
|
*/
|
@GetMapping("/other")
|
public R monitorOther(@RequestParam("crnId") Integer crnId, @RequestParam("ledId") Integer ledId) {
|
Double xSpeed = 0.0D;
|
Double ySpeed = 0.0D;
|
Double zSpeed = 0.0D;
|
Short forkPos = 1;
|
Double xDistance = 0.0D;
|
Double yDistance = 0.0D;
|
Double xDuration = 0.0D;
|
Double yDuration = 0.0D;
|
|
if (null != crnId) {
|
CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crnId);
|
if (crnThread != null) {
|
CrnProtocol crnProtocol = crnThread.getCrnProtocol();
|
if (crnProtocol != null) {
|
xSpeed = Double.valueOf(crnProtocol.getXSpeed());
|
ySpeed = Double.valueOf(crnProtocol.getYSpeed());
|
zSpeed = Double.valueOf(crnProtocol.getZSpeed());
|
switch (crnProtocol.getForkPos()) {
|
case 0:
|
forkPos = 1;
|
break;
|
case 1:
|
forkPos = 2;
|
break;
|
case 2:
|
forkPos = 0;
|
break;
|
default:
|
forkPos = 1;
|
break;
|
}
|
xDistance = Double.valueOf(crnProtocol.getXDistance());
|
yDistance = Double.valueOf(crnProtocol.getYDistance());
|
xDuration = Double.valueOf(crnProtocol.getXDuration());
|
yDuration = Double.valueOf(crnProtocol.getYDuration());
|
}
|
}
|
}
|
|
|
// ledContent = "ask的模块萨满大算了萨满大了\n 是窘境到埃及嗲家嗲\n 萨达姆打开萨满大凯撒麦当劳萨满大老师";
|
|
return R.ok(
|
Cools.add("xSpeed", Arith.multiplys(1, Math.abs(xSpeed), 1)) // 行走速度
|
.add("ySpeed", Arith.multiplys(1, Math.abs(ySpeed), 1)) // 升降速度
|
.add("zSpeed", Arith.multiplys(1, Math.abs(zSpeed), 1)) // 叉牙速度
|
.add("forkPos", forkPos) // 叉牙速度
|
.add("xDistance", Arith.multiplys(1, Math.abs(xDistance), 1)) // 累计走行距离km
|
.add("yDistance", Arith.multiplys(1, Math.abs(yDistance), 1)) // 累计升降距离km
|
.add("xDuration", Arith.multiplys(1, Math.abs(xDuration), 1)) // 累计走行时长h
|
.add("yDuration", Arith.multiplys(1, Math.abs(yDuration), 1)) // 累计升降时长h
|
);
|
}
|
|
}
|
