package com.zy.asrs.service.impl;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.core.common.Arith;
|
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.LocMast;
|
import com.zy.asrs.entity.ViewLocMapDto;
|
import com.zy.asrs.mapper.ReportQueryMapper;
|
import com.zy.asrs.service.LocMastService;
|
import com.zy.asrs.service.MonitorReportService;
|
import com.zy.common.utils.RedisUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Slf4j
|
@Service
|
public class MonitorReportServiceImpl implements MonitorReportService {
|
|
private static final String LOC_MAP_CACHE_KEY_PREFIX = "monitor:loc:map:row:";
|
private static final long LOC_MAP_CACHE_SECONDS = 1800L;
|
|
@Autowired
|
private ReportQueryMapper reportQueryMapper;
|
@Autowired
|
private LocMastService locMastService;
|
@Autowired(required = false)
|
private RedisUtil redisUtil;
|
|
@Override
|
public List<Map<String, Object>> getPakinRepData() {
|
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));
|
}
|
}
|
return pakinRep;
|
}
|
|
@Override
|
public Map<String, Object> getLocIoLineChartsData() {
|
Map<String, Object> map = new HashMap<>();
|
List<AxisBean> list = new ArrayList<>();
|
List<WorkChartAxis> listChart = reportQueryMapper.getChartAxis();
|
|
if (listChart != null) {
|
ArrayList<Integer> data1 = new ArrayList<>();
|
ArrayList<Integer> data2 = new ArrayList<>();
|
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 map;
|
}
|
|
@Override
|
public Map<String, Object> getLocRepData() {
|
List<Map<String, Object>> pie = new ArrayList<>();
|
LocChartPie locUseRate = reportQueryMapper.getLocUseRate();
|
int i = locMastService.selectCount(new EntityWrapper<LocMast>().eq("loc_sts", "D"));
|
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", i);
|
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);
|
|
Map<String, Object> result = new HashMap<>();
|
result.put("pie", pie);
|
result.put("stockCunt", locUseRate.getFqty() - i);
|
result.put("emptyCount", locUseRate.getOqty());
|
result.put("noneCount", i);
|
result.put("total", total);
|
result.put("used", used);
|
result.put("usedPr", usedPr);
|
return result;
|
}
|
|
@Override
|
public List<Integer> getLocMapRows() {
|
List<Integer> rows = reportQueryMapper.getViewLocRowTotal();
|
if (rows == null) {
|
rows = new ArrayList<>();
|
}
|
return rows;
|
}
|
|
@Override
|
public Map<String, Object> getLocMapData(Integer row) {
|
String cacheDataKey = LOC_MAP_CACHE_KEY_PREFIX + row;
|
if (redisUtil != null) {
|
Object redisData = redisUtil.get(cacheDataKey);
|
if (redisData instanceof Map) {
|
return (Map<String, Object>) redisData;
|
}
|
}
|
|
List<String> bays = reportQueryMapper.getViewLocBayCount(row);
|
if (bays == null) {
|
bays = new ArrayList<>();
|
}
|
bays.add(0, "");
|
List<String> levs = reportQueryMapper.getViewLocLevCount(row);
|
if (levs == null) {
|
levs = new ArrayList<>();
|
}
|
List<Map<String, Object>> body = new ArrayList<>();
|
for (String lev : levs) {
|
List<ViewLocMapDto> dtos = reportQueryMapper.getViewLocBays(row, Integer.parseInt(lev.trim()));
|
if (dtos == null) {
|
dtos = new ArrayList<>();
|
}
|
dtos.add(0, new ViewLocMapDto(null, null, lev));
|
Map<String, Object> map = new HashMap<>();
|
map.put("loc", dtos);
|
body.add(map);
|
}
|
Map<String, Object> result = new HashMap<>();
|
result.put("title", bays);
|
result.put("body", body);
|
if (redisUtil != null) {
|
redisUtil.set(cacheDataKey, result, LOC_MAP_CACHE_SECONDS);
|
}
|
return result;
|
}
|
}
|
