package com.moral.api.service.impl;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.system.ApplicationHome;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.ObjectUtils;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.text.DecimalFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.Comparator;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
import java.util.stream.Collectors;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.moral.api.entity.Dustld;
|
import com.moral.api.mapper.DustldMapper;
|
import com.moral.api.mapper.HistorySecondCruiserMapper;
|
import com.moral.api.pojo.dust.DustForm;
|
import com.moral.api.pojo.dust.TimeForm;
|
import com.moral.api.service.DustldService;
|
import com.moral.util.DateUtils;
|
import com.moral.util.FileUtils;
|
|
@Service
|
@Slf4j
|
public class DustldServiceImpl implements DustldService {
|
|
|
@Autowired
|
private HistorySecondCruiserMapper historySecondCruiserMapper;
|
|
@Autowired
|
private DustldMapper dustldMapper;
|
|
/**
|
* 保存日报信息
|
* @param params
|
* @param file
|
* @return
|
* @throws ParseException
|
*/
|
@Override
|
public Integer getDailyDustld(Map<String, Object> params,MultipartFile file ) {
|
|
//获取jar包所在目录
|
ApplicationHome applicationHome = new ApplicationHome(getClass());
|
//在jar包所在目录下生成一个upload文件夹用来存储上传的图片
|
String path = applicationHome.getSource().getParentFile().toString() + "/static/img";
|
|
|
String mac = params.get("mac").toString();
|
String time3 = params.get("time3").toString();
|
String time4 = params.get("time4").toString();
|
String table = params.get("table").toString();
|
String substring = time3.substring(0, 10);
|
//路段名
|
String road = params.get("road").toString();
|
|
ArrayList<Double> list = new ArrayList<>();
|
List<TimeForm> tables = JSONArray.parseArray(table, TimeForm.class);
|
|
if (!ObjectUtils.isEmpty(tables)){
|
for (TimeForm timeForm : tables) {
|
String start = timeForm.getStart();
|
String end = timeForm.getEnd();
|
List<Double> dust = historySecondCruiserMapper.getDust(start, end, mac);
|
ArrayList<Double> rsDouble = new ArrayList<>();
|
for (Double aDouble : dust) {
|
double v =0.0;
|
if (aDouble>=0 && aDouble<40 ){
|
v = aDouble + 170;
|
}
|
if (aDouble>=40 && aDouble<60 ){
|
v = aDouble + 130;
|
}
|
if (aDouble>=60 && aDouble<100 ){
|
v = aDouble + 110;
|
}
|
if (aDouble>=100 && aDouble<150 ){
|
v = aDouble + 70;
|
}
|
if (aDouble>=150 && aDouble<180 ){
|
v = aDouble + 30;
|
}
|
if (aDouble>=180){
|
v= aDouble;
|
}
|
rsDouble.add(v);
|
}
|
list.addAll(rsDouble);
|
}
|
}
|
String format = "";
|
if (!ObjectUtils.isEmpty(list)){
|
Double collect = (list.stream().collect(Collectors.averagingDouble(Double::doubleValue)))/1000;
|
format = new DecimalFormat("0.000").format(collect);
|
}
|
|
QueryWrapper<Dustld> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("mac",mac).likeRight("time",substring);
|
Dustld dustld = dustldMapper.selectOne(queryWrapper);
|
|
if (ObjectUtils.isEmpty(dustld)){
|
Dustld dustld1 = new Dustld();
|
if (!ObjectUtils.isEmpty(file)){
|
HashMap<String, Object> hashMap = new HashMap<>();
|
String fileType = file.getContentType();
|
if ("image/jpg".equals(fileType) || "image/png".equals(fileType) || "image/jpeg".equals(fileType)){
|
//获取文件名
|
String fileName = file.getOriginalFilename();
|
//获取文件后缀名
|
String suffixName = fileName.substring(fileName.lastIndexOf("."));
|
//每一次都需要
|
fileName.substring(fileName.lastIndexOf("."));
|
//重新生成文件名
|
fileName = UUID.randomUUID() + suffixName;
|
//图片上传
|
if (FileUtils.upload(file, path, fileName)) {
|
hashMap.put("file1",fileName);
|
String s = JSON.toJSONString(hashMap);
|
dustld1.setImages(s);
|
}
|
}
|
}
|
|
HashMap<String, Object> map = new HashMap<>();
|
|
map.put(road,format);
|
String value = JSON.toJSONString(map);
|
dustld1.setMac(mac);
|
dustld1.setTime(DateUtils.getDate(time3,DateUtils.yyyy_MM_dd_HH_mm_ss_EN));
|
dustld1.setValue(value);
|
dustld1.setEndTime(DateUtils.getDate(time4,DateUtils.yyyy_MM_dd_HH_mm_ss_EN));
|
dustldMapper.insert(dustld1);
|
return 200;
|
}else {
|
if (!ObjectUtils.isEmpty(file)){
|
HashMap<String, Object> hashMap = new HashMap<>();
|
String fileType = file.getContentType();
|
if ("image/jpg".equals(fileType) || "image/png".equals(fileType) || "image/jpeg".equals(fileType)){
|
//获取文件名
|
String fileName = file.getOriginalFilename();
|
//获取文件后缀名
|
String suffixName = fileName.substring(fileName.lastIndexOf("."));
|
//每一次都需要
|
fileName.substring(fileName.lastIndexOf("."));
|
//重新生成文件名
|
fileName = UUID.randomUUID() + suffixName;
|
//图片上传
|
if (FileUtils.upload(file, path, fileName)) {
|
hashMap.put("file1",fileName);
|
String s = JSON.toJSONString(hashMap);
|
dustld.setImages(s);
|
}
|
}
|
}
|
String value = dustld.getValue();
|
JSONObject jsonObject = JSONObject.parseObject(value);
|
jsonObject.put(road,format);
|
String rsValue = JSONObject.toJSONString(jsonObject);
|
dustld.setValue(rsValue);
|
dustldMapper.updateById(dustld);
|
return 200;
|
}
|
|
}
|
|
/**
|
* 下载日报
|
* @param id
|
* @return
|
*/
|
@Override
|
public Map<String,Object> dailyDustld(Integer id,List<MultipartFile> files) {
|
//获取jar包所在目录
|
ApplicationHome applicationHome = new ApplicationHome(getClass());
|
//在jar包所在目录下生成一个upload文件夹用来存储上传的图片
|
String path = applicationHome.getSource().getParentFile().toString() + "/static/img";
|
|
HashMap<String, Object> map = new HashMap<>();
|
ArrayList<DustForm> list1 = new ArrayList<>();
|
ArrayList<DustForm> list2= new ArrayList<>();
|
|
Dustld dustld = dustldMapper.selectById(id);
|
if (ObjectUtils.isEmpty(dustld)){
|
return null;
|
}
|
String pathList = getList(path, files);
|
String images = dustld.getImages();
|
if (ObjectUtils.isEmpty(images)){
|
HashMap<String, Object> map1 = new HashMap<>();
|
map1.put("file1","");
|
if (pathList==null){
|
map1.put("file2","");
|
}else {
|
map1.put("file2",pathList);
|
}
|
|
String s = JSON.toJSONString(map1);
|
dustld.setImages(s);
|
dustldMapper.updateById(dustld);
|
}else {
|
JSONObject jsonObject = JSONObject.parseObject(images);
|
if (ObjectUtils.isEmpty(pathList)){
|
jsonObject.put("file2","");
|
}else {
|
jsonObject.put("file2",pathList);
|
}
|
String s = JSON.toJSONString(jsonObject);
|
dustld.setImages(s);
|
dustldMapper.updateById(dustld);
|
}
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日HH时mm分ss秒");
|
String stsrtTime = sdf.format(dustld.getTime());
|
String substring = stsrtTime.substring(5, 14);
|
String endTime = sdf.format(dustld.getEndTime());
|
String substring1 = endTime.substring(5, 14);
|
|
String value = dustld.getValue();
|
JSONObject jsonObject = JSONObject.parseObject(value);
|
Iterator<Map.Entry<String, Object>> iterator = jsonObject.entrySet().iterator();
|
while (iterator.hasNext()) {
|
DustForm dustForm = new DustForm();
|
Map.Entry entry = (Map.Entry) iterator.next();
|
dustForm.setRoad(entry.getKey().toString());
|
dustForm.setValue(Double.parseDouble(entry.getValue().toString()));
|
double aDouble = Double.parseDouble(entry.getValue().toString());
|
list2.add(dustForm);
|
if (aDouble>=0.3){
|
list1.add(dustForm);
|
}
|
}
|
|
//排序
|
list1.sort(Comparator.comparing(DustForm::getValue).reversed());
|
list2.sort(Comparator.comparing(DustForm::getValue).reversed());
|
map.put("list1",list1);
|
map.put("list2",list2);
|
map.put("time",substring+"-"+substring1);
|
map.put("images",JSON.parseObject(dustld.getImages()));
|
return map;
|
}
|
|
/**
|
* 查询尘负荷高值
|
* @param id
|
* @return
|
*/
|
@Override
|
public Map<String,Object> selectDust(Integer id) {
|
|
HashMap<String, Object> rsMap = new HashMap<>();
|
ArrayList<DustForm> list1 = new ArrayList<>();
|
|
Dustld dustld = dustldMapper.selectById(id);
|
if (ObjectUtils.isEmpty(dustld)){
|
return null;
|
}
|
String value = dustld.getValue();
|
JSONObject jsonObject = JSONObject.parseObject(value);
|
Iterator<Map.Entry<String, Object>> iterator = jsonObject.entrySet().iterator();
|
while (iterator.hasNext()) {
|
DustForm dustForm = new DustForm();
|
Map.Entry entry = (Map.Entry) iterator.next();
|
dustForm.setRoad(entry.getKey().toString());
|
dustForm.setValue(Double.parseDouble(entry.getValue().toString()));
|
double aDouble = Double.parseDouble(entry.getValue().toString());
|
if (aDouble>=0.3){
|
list1.add(dustForm);
|
}
|
}
|
if (!ObjectUtils.isEmpty(list1)){
|
list1.sort(Comparator.comparing(DustForm::getValue).reversed());
|
}
|
rsMap.put("list",list1);
|
rsMap.put("count",list1.size());
|
return rsMap;
|
}
|
|
/**
|
* 查询日报记录
|
* @param params
|
* @return
|
*/
|
@Override
|
public List<Dustld> selectAll(Map<String, Object> params) {
|
String mac = params.get("mac").toString();
|
String time1 = params.get("startTime").toString();
|
String time2 = params.get("endTime").toString();
|
|
QueryWrapper<Dustld> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("mac",mac).between("time",time1,time2);
|
List<Dustld> dustlds = dustldMapper.selectList(queryWrapper);
|
if (ObjectUtils.isEmpty(dustlds)){
|
return null;
|
}
|
return dustlds;
|
}
|
|
|
//获取图片地址
|
private String getList(String path, List<MultipartFile> files1) {
|
ArrayList<String> images = new ArrayList<>();
|
if (!ObjectUtils.isEmpty(files1)){
|
for (MultipartFile file : files1) {
|
String fileType = file.getContentType();
|
if ("image/jpg".equals(fileType) || "image/png".equals(fileType) || "image/jpeg".equals(fileType)){
|
//获取文件名
|
String fileName = file.getOriginalFilename();
|
//获取文件后缀名
|
String suffixName = fileName.substring(fileName.lastIndexOf("."));
|
//每一次都需要
|
fileName.substring(fileName.lastIndexOf("."));
|
//重新生成文件名
|
fileName = UUID.randomUUID() + suffixName;
|
//图片上传
|
if (FileUtils.upload(file, path, fileName)) {
|
images.add(fileName);
|
}
|
}
|
}
|
}
|
|
if (!ObjectUtils.isEmpty(images)) {
|
String image = images.stream()
|
.map(String::valueOf)
|
.collect(Collectors.joining(","));
|
|
return image;
|
}
|
return null;
|
}
|
|
}
|
