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> getPakinRepData() { List> pakinRep = reportQueryMapper.queryPakinRep(); for (Map map : pakinRep) { if (map.get("node") != null) { map.put("node", String.valueOf(map.get("node")).substring(5, 10)); } } return pakinRep; } @Override public Map getLocIoLineChartsData() { Map map = new HashMap<>(); List list = new ArrayList<>(); List listChart = reportQueryMapper.getChartAxis(); if (listChart != null) { ArrayList data1 = new ArrayList<>(); ArrayList 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 getLocRepData() { List> pie = new ArrayList<>(); LocChartPie locUseRate = reportQueryMapper.getLocUseRate(); int i = locMastService.selectCount(new EntityWrapper().eq("loc_sts", "D")); if (locUseRate != null) { Map map = new HashMap<>(); map.put("name", "在库"); map.put("value", locUseRate.getFqty()); pie.add(map); Map map1 = new HashMap<>(); map1.put("name", "空"); map1.put("value", locUseRate.getOqty()); pie.add(map1); Map map2 = new HashMap<>(); map2.put("name", "使用"); map2.put("value", locUseRate.getUqty()); pie.add(map2); Map 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 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 getLocMapRows() { List rows = reportQueryMapper.getViewLocRowTotal(); if (rows == null) { rows = new ArrayList<>(); } return rows; } @Override public Map 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) redisData; } } List bays = reportQueryMapper.getViewLocBayCount(row); if (bays == null) { bays = new ArrayList<>(); } bays.add(0, ""); List levs = reportQueryMapper.getViewLocLevCount(row); if (levs == null) { levs = new ArrayList<>(); } List> body = new ArrayList<>(); for (String lev : levs) { List dtos = reportQueryMapper.getViewLocBays(row, Integer.parseInt(lev.trim())); if (dtos == null) { dtos = new ArrayList<>(); } dtos.add(0, new ViewLocMapDto(null, null, lev)); Map map = new HashMap<>(); map.put("loc", dtos); body.add(map); } Map result = new HashMap<>(); result.put("title", bays); result.put("body", body); if (redisUtil != null) { redisUtil.set(cacheDataKey, result, LOC_MAP_CACHE_SECONDS); } return result; } }