设备智能识别违章功能
This commit is contained in:
parent
ac2c7c252c
commit
5ea3afbdef
|
|
@ -0,0 +1,100 @@
|
|||
package com.bonus.system.api.domain;
|
||||
|
||||
import com.bonus.common.core.web.domain.BaseEntity;
|
||||
|
||||
public class SysFileSource extends BaseEntity{
|
||||
|
||||
private String fileName;
|
||||
|
||||
private String fileSuffix;
|
||||
|
||||
private String filePath;
|
||||
|
||||
private int fileType;
|
||||
|
||||
|
||||
private String sourceId;
|
||||
|
||||
private String sourceType;
|
||||
|
||||
private String createUser;
|
||||
|
||||
private Long id;
|
||||
|
||||
private String updateUser;
|
||||
|
||||
|
||||
public Long getId() {
|
||||
return id;
|
||||
}
|
||||
|
||||
public void setId(Long id) {
|
||||
this.id = id;
|
||||
}
|
||||
|
||||
public String getFileName() {
|
||||
return fileName;
|
||||
}
|
||||
|
||||
public void setFileName(String fileName) {
|
||||
this.fileName = fileName;
|
||||
}
|
||||
|
||||
public String getFileSuffix() {
|
||||
return fileSuffix;
|
||||
}
|
||||
|
||||
public void setFileSuffix(String fileSuffix) {
|
||||
this.fileSuffix = fileSuffix;
|
||||
}
|
||||
|
||||
public String getFilePath() {
|
||||
return filePath;
|
||||
}
|
||||
|
||||
public void setFilePath(String filePath) {
|
||||
this.filePath = filePath;
|
||||
}
|
||||
|
||||
public int getFileType() {
|
||||
return fileType;
|
||||
}
|
||||
|
||||
public void setFileType(int fileType) {
|
||||
this.fileType = fileType;
|
||||
}
|
||||
|
||||
public String getSourceId() {
|
||||
return sourceId;
|
||||
}
|
||||
|
||||
public void setSourceId(String sourceId) {
|
||||
this.sourceId = sourceId;
|
||||
}
|
||||
|
||||
public String getSourceType() {
|
||||
return sourceType;
|
||||
}
|
||||
|
||||
public void setSourceType(String sourceType) {
|
||||
this.sourceType = sourceType;
|
||||
}
|
||||
|
||||
public String getCreateUser() {
|
||||
return createUser;
|
||||
}
|
||||
|
||||
public void setCreateUser(String createUser) {
|
||||
this.createUser = createUser;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public String getUpdateUser() {
|
||||
return updateUser;
|
||||
}
|
||||
|
||||
public void setUpdateUser(String updateUser) {
|
||||
this.updateUser = updateUser;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,147 @@
|
|||
package com.bonus.common.core.utils;
|
||||
|
||||
import cn.hutool.core.codec.Base64;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
import sun.misc.BASE64Decoder;
|
||||
|
||||
import javax.imageio.ImageIO;
|
||||
import java.awt.image.BufferedImage;
|
||||
import java.io.*;
|
||||
|
||||
/**
|
||||
* @author：cwchen
|
||||
* @date：2024-06-11 17:53-10:10
|
||||
* @version：1.0
|
||||
* @description：字节数组转文件
|
||||
*/
|
||||
public class BASE64DecodedMultipartFile implements MultipartFile {
|
||||
|
||||
private final byte[] imgContent;
|
||||
private final String header;
|
||||
private final static String IMG_PREFIX = "data:image/jpeg;base64";
|
||||
|
||||
public BASE64DecodedMultipartFile(byte[] imgContent, String header) {
|
||||
this.imgContent = imgContent;
|
||||
this.header = header.split(";")[0];
|
||||
}
|
||||
|
||||
@Override
|
||||
public String getName() {
|
||||
return System.currentTimeMillis() + Math.random() + "." + header.split("/")[1];
|
||||
}
|
||||
|
||||
@Override
|
||||
public String getOriginalFilename() {
|
||||
return System.currentTimeMillis() + (int) Math.random() * 10000 + "." + header.split("/")[1];
|
||||
}
|
||||
|
||||
@Override
|
||||
public String getContentType() {
|
||||
return header.split(":")[1];
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean isEmpty() {
|
||||
return imgContent == null || imgContent.length == 0;
|
||||
}
|
||||
|
||||
@Override
|
||||
public long getSize() {
|
||||
return imgContent.length;
|
||||
}
|
||||
|
||||
@Override
|
||||
public byte[] getBytes() throws IOException {
|
||||
return imgContent;
|
||||
}
|
||||
|
||||
@Override
|
||||
public InputStream getInputStream() throws IOException {
|
||||
return new ByteArrayInputStream(imgContent);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void transferTo(File dest) throws IOException, IllegalStateException {
|
||||
new FileOutputStream(dest).write(imgContent);
|
||||
}
|
||||
|
||||
public static MultipartFile base64ToMultipart(String base64) {
|
||||
try {
|
||||
String[] baseStrs = base64.split(",");
|
||||
|
||||
BASE64Decoder decoder = new BASE64Decoder();
|
||||
byte[] b = new byte[0];
|
||||
b = decoder.decodeBuffer(baseStrs[1]);
|
||||
|
||||
for (int i = 0; i < b.length; ++i) {
|
||||
if (b[i] < 0) {
|
||||
b[i] += 256;
|
||||
}
|
||||
}
|
||||
|
||||
return new BASE64DecodedMultipartFile(b, baseStrs[0]);
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
public static MultipartFile base64ToMultipart2(String base64) {
|
||||
try {
|
||||
if (StringUtils.isEmpty(base64)) {
|
||||
return null;
|
||||
}
|
||||
String[] baseStrs = base64.split(",");
|
||||
if (baseStrs.length == 1) {
|
||||
BASE64Decoder decoder = new BASE64Decoder();
|
||||
byte[] b = new byte[0];
|
||||
b = decoder.decodeBuffer(baseStrs[0]);
|
||||
|
||||
for (int i = 0; i < b.length; ++i) {
|
||||
if (b[i] < 0) {
|
||||
b[i] += 256;
|
||||
}
|
||||
}
|
||||
return new BASE64DecodedMultipartFile(b, IMG_PREFIX);
|
||||
} else if (baseStrs.length == 2) {
|
||||
BASE64Decoder decoder = new BASE64Decoder();
|
||||
byte[] b = new byte[0];
|
||||
b = decoder.decodeBuffer(baseStrs[1]);
|
||||
|
||||
for (int i = 0; i < b.length; ++i) {
|
||||
if (b[i] < 0) {
|
||||
b[i] += 256;
|
||||
}
|
||||
}
|
||||
return new BASE64DecodedMultipartFile(b, baseStrs[0]);
|
||||
}
|
||||
return null;
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public static String getBase64(String path) {
|
||||
File file = new File(path);
|
||||
String base64 = null;
|
||||
try {
|
||||
BufferedImage image = ImageIO.read(file);
|
||||
Integer width = image.getWidth();
|
||||
Integer height = image.getHeight();
|
||||
System.out.println("宽：" + width + " 高:" + height);
|
||||
|
||||
//输出流
|
||||
ByteArrayOutputStream stream = new ByteArrayOutputStream();
|
||||
ImageIO.write(image, "png", stream);
|
||||
base64 = Base64.encode(stream.toByteArray());
|
||||
System.out.println(base64);
|
||||
} catch (IOException e) {
|
||||
// TODO Auto-generated catch block
|
||||
e.printStackTrace();
|
||||
}
|
||||
return base64;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,931 @@
|
|||
package com.bonus.common.core.utils;
|
||||
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
|
||||
import java.text.*;
|
||||
import java.time.*;
|
||||
import java.util.*;
|
||||
|
||||
import static org.apache.commons.lang3.time.DateUtils.parseDate;
|
||||
|
||||
|
||||
/**
|
||||
* @author HeiZi
|
||||
*/
|
||||
@Slf4j
|
||||
public class DateTimeHelper {
|
||||
|
||||
|
||||
private static String[] parsePatterns = {
|
||||
"yyyy-MM-dd", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm", "yyyy-MM",
|
||||
"yyyy/MM/dd", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm", "yyyy/MM",
|
||||
"yyyy.MM.dd", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm", "yyyy.MM"};
|
||||
|
||||
public static String format(Date d, String f) {
|
||||
SimpleDateFormat df = new SimpleDateFormat(f, Locale.US);
|
||||
return df.format(d);
|
||||
}
|
||||
|
||||
public static boolean compareMonth(String time, String now) {
|
||||
try {
|
||||
int year = Integer.parseInt(time.split("-")[0].trim());
|
||||
int month = Integer.parseInt(time.split("-")[1].trim());
|
||||
int year1 = Integer.parseInt(now.split("-")[0].trim());
|
||||
int month1 = Integer.parseInt(now.split("-")[1].trim());
|
||||
if (year > year1) {
|
||||
return false;
|
||||
}
|
||||
if (year == year1) {
|
||||
if (month >= month1) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
return true;
|
||||
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* 增加 LocalDateTime ==> Date
|
||||
*/
|
||||
public static Date toDate(LocalDateTime temporalAccessor) {
|
||||
ZonedDateTime zdt = temporalAccessor.atZone(ZoneId.systemDefault());
|
||||
return Date.from(zdt.toInstant());
|
||||
}
|
||||
|
||||
/**
|
||||
* 增加 LocalDate ==> Date
|
||||
*/
|
||||
public static Date toDate(LocalDate temporalAccessor) {
|
||||
LocalDateTime localDateTime = LocalDateTime.of(temporalAccessor, LocalTime.of(0, 0, 0));
|
||||
ZonedDateTime zdt = localDateTime.atZone(ZoneId.systemDefault());
|
||||
return Date.from(zdt.toInstant());
|
||||
}
|
||||
|
||||
|
||||
public static String dateTimeNow() {
|
||||
return dateTimeNow("yyyyMMddHHmmss");
|
||||
}
|
||||
|
||||
|
||||
public static String dateTimeNow(final String format) {
|
||||
return parseDateToStr(format, new Date());
|
||||
}
|
||||
|
||||
public static String parseDateToStr(final String format, final Date date) {
|
||||
return new SimpleDateFormat(format).format(date);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 日期型字符串转化为日期 格式
|
||||
*/
|
||||
public static Date parseDates(Object str) {
|
||||
if (str == null) {
|
||||
return null;
|
||||
}
|
||||
try {
|
||||
return parseDate(str.toString(), parsePatterns);
|
||||
} catch (ParseException e) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前时间
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getNowTime() {
|
||||
return format(new Date(), "yyyy-MM-dd HH:mm:ss");
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前时间的年份
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getNowYear() {
|
||||
return format(new Date(), "yyyy");
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 获取当前月份
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getNowMonths() {
|
||||
return format(new Date(), "MM");
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前小时
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getNowHours() {
|
||||
return format(new Date(), "HH");
|
||||
}
|
||||
|
||||
|
||||
public static String getNowYmd() {
|
||||
return new SimpleDateFormat("yyyyMMdd").format(new Date());
|
||||
}
|
||||
|
||||
|
||||
public static String getNowDay() {
|
||||
return new SimpleDateFormat("yyyy-MM-dd").format(new Date());
|
||||
}
|
||||
|
||||
public static String getTimesUpDown(String time) {
|
||||
try {
|
||||
if (StringUtils.isEmpty(time)) {
|
||||
return time;
|
||||
}
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||
Date date = sdf.parse(time);
|
||||
// 创建Calendar对象，表示当前时间
|
||||
Calendar calendar = Calendar.getInstance();
|
||||
// 将Calendar对象设置为当前时间
|
||||
calendar.setTime(date);
|
||||
// 将时间减去5分钟
|
||||
calendar.add(Calendar.MINUTE, -5);
|
||||
calendar.add(Calendar.SECOND, -13);
|
||||
// 获取减去5分钟后的时间
|
||||
Date newTime = calendar.getTime();
|
||||
return sdf.format(newTime);
|
||||
} catch (ParseException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return time;
|
||||
}
|
||||
|
||||
public static String getNextDay() {
|
||||
Calendar calendar = Calendar.getInstance();
|
||||
// 对日期进行加1天的操作
|
||||
calendar.add(Calendar.DAY_OF_MONTH, 1);
|
||||
// 获取明天的年、月、日
|
||||
int year = calendar.get(Calendar.YEAR);
|
||||
// 注意：月份从0开始计算
|
||||
int month = calendar.get(Calendar.MONTH) + 1;
|
||||
int day = calendar.get(Calendar.DAY_OF_MONTH);
|
||||
return year + "-" + month + "-" + day;
|
||||
}
|
||||
|
||||
|
||||
public static String getHouDay() {
|
||||
Date date = new Date();
|
||||
Calendar calendar = new GregorianCalendar();
|
||||
calendar.setTime(new Date());
|
||||
// 把日期往后增加一天.整数往后推,负数往前移动
|
||||
calendar.add(Calendar.DATE, 1);
|
||||
// 这个时间就是日期往后推一天的结果
|
||||
date = calendar.getTime();
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
return sdf.format(date);
|
||||
}
|
||||
|
||||
@SuppressWarnings("static-access")
|
||||
public static String getYesTodayt() {
|
||||
Date date = new Date();
|
||||
Calendar calendar = new GregorianCalendar();
|
||||
calendar.setTime(new Date());
|
||||
// 把日期往后增加一天.整数往后推,负数往前移动
|
||||
calendar.add(calendar.DATE, -1);
|
||||
date = calendar.getTime();
|
||||
// 这个时间就是日期往后推一天的结果
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
return sdf.format(date);
|
||||
}
|
||||
|
||||
@SuppressWarnings("static-access")
|
||||
public static String getQtDay() {
|
||||
Date date = new Date();
|
||||
Calendar calendar = new GregorianCalendar();
|
||||
calendar.setTime(new Date());
|
||||
// 把日期往后增加一天.整数往后推,负数往前移动
|
||||
calendar.add(calendar.DATE, -2);
|
||||
// 这个时间就是日期往后推一天的结果
|
||||
date = calendar.getTime();
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
return sdf.format(date);
|
||||
}
|
||||
|
||||
|
||||
public static String format(String str, String format, String disFormat) {
|
||||
Date d = parse(str, format);
|
||||
return format(d, disFormat);
|
||||
}
|
||||
|
||||
/**
|
||||
* 格式化 时间
|
||||
*
|
||||
* @param format
|
||||
* @return
|
||||
*/
|
||||
public static String format(Date d, DateFormat format) {
|
||||
return format.format(d);
|
||||
}
|
||||
|
||||
/**
|
||||
* 格式化 时间
|
||||
*
|
||||
* @param format
|
||||
* @return Date
|
||||
* @throws ParseException
|
||||
*/
|
||||
public static Date parse(String dateStr, String format) {
|
||||
SimpleDateFormat df = new SimpleDateFormat(format);
|
||||
try {
|
||||
return df.parse(dateStr);
|
||||
} catch (ParseException e) {
|
||||
return new Date();
|
||||
}
|
||||
}
|
||||
|
||||
public static Date parse(String dateStr, String format, Date d) {
|
||||
try {
|
||||
SimpleDateFormat df = new SimpleDateFormat(format);
|
||||
return df.parse(dateStr);
|
||||
} catch (Exception e) {
|
||||
return d;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 解析时间
|
||||
*
|
||||
* @return Date
|
||||
* @throws ParseException
|
||||
*/
|
||||
public static Date parse(String dateStr, DateFormat format) throws ParseException {
|
||||
return format.parse(dateStr);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前时间的年月
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getPrevMonth() {
|
||||
return minusMonth(new Date(), 1);
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前时间的上个年月
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getNowMonth() {
|
||||
return format(new Date(), "yyyy-MM");
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前时间的年月日
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getNowDate() {
|
||||
return format(new Date(), "yyyy-MM-dd");
|
||||
}
|
||||
|
||||
/**
|
||||
* @return
|
||||
*/
|
||||
public static String minusMonth(Date date, int c) {
|
||||
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM");
|
||||
try {
|
||||
Calendar cal = Calendar.getInstance();
|
||||
cal.setTime(date);
|
||||
cal.add(Calendar.MONTH, -c);
|
||||
return format(cal.getTime(), df);
|
||||
} catch (Exception e) {
|
||||
return format(date, df);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* @param month
|
||||
* @return
|
||||
*/
|
||||
public static String minusMonth(String month, int c) {
|
||||
try {
|
||||
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM");
|
||||
Date date = parse(month, df);
|
||||
|
||||
Calendar cal = Calendar.getInstance();
|
||||
cal.setTime(date);
|
||||
cal.add(Calendar.MONTH, -c);
|
||||
|
||||
return format(cal.getTime(), df);
|
||||
} catch (Exception e) {
|
||||
return month;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* @return
|
||||
*/
|
||||
public static Date minus(Date d, int type, int c) {
|
||||
try {
|
||||
Calendar cal = Calendar.getInstance();
|
||||
cal.setTime(d);
|
||||
cal.add(type, -c);
|
||||
return cal.getTime();
|
||||
} catch (Exception e) {
|
||||
return new Date();
|
||||
}
|
||||
}
|
||||
|
||||
private static String[] digits = {"零", "一", "二", "三", "四", "五", "六", "七", "八", "九"};
|
||||
|
||||
public static String getWeekTimes(String time) {
|
||||
try {
|
||||
int month = Integer.parseInt(time.split("-")[1].trim());
|
||||
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");
|
||||
Date date = df.parse(time);
|
||||
Calendar cal = Calendar.getInstance();
|
||||
cal.setFirstDayOfWeek(Calendar.MONDAY);
|
||||
cal.setTime(date);
|
||||
int weekOfMonth = cal.get(Calendar.WEEK_OF_MONTH);
|
||||
String msg = digits[weekOfMonth];
|
||||
return month + "月" + msg + "周";
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
|
||||
public static String getAddMonth(String time, int num) {
|
||||
try {
|
||||
Integer year = Integer.parseInt(time.split("-")[0].trim());
|
||||
Integer month = Integer.parseInt(time.split("-")[1].trim());
|
||||
YearMonth yearMonth = YearMonth.of(year, month);
|
||||
YearMonth addedMonth = yearMonth.plusMonths(1);
|
||||
return addedMonth.toString();
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
return null;
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取七周日期
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static List<String> getWeekList() {
|
||||
List<String> list = new ArrayList<>();
|
||||
String time = DateTimeHelper.getNowDay();
|
||||
int max = 6;
|
||||
for (int i = max; i >= 1; i--) {
|
||||
String timess = getDayAddOrReduce(time, -7 * i);
|
||||
list.add(timess);
|
||||
}
|
||||
list.add(time);
|
||||
return list;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 得到前一个月
|
||||
*
|
||||
* @param month
|
||||
* @return
|
||||
*/
|
||||
public static String prevMonth(String month) {
|
||||
return minusMonth(month, 1);
|
||||
}
|
||||
|
||||
/**
|
||||
* 得到前一个月
|
||||
*
|
||||
* @param month
|
||||
* @return
|
||||
*/
|
||||
public static String prevMonth(String month, int c) {
|
||||
return minusMonth(month, c);
|
||||
}
|
||||
|
||||
public static float duration(String startTime, String stopTime) {
|
||||
Date sd = DateTimeHelper.parse(startTime, "yyyy-MM-dd HH:mm");
|
||||
long sl = sd.getTime();
|
||||
|
||||
Date ed = DateTimeHelper.parse(stopTime, "yyyy-MM-dd HH:mm");
|
||||
long el = ed.getTime();
|
||||
|
||||
float l = el - sl;
|
||||
if (l <= 0) {
|
||||
l = 0;
|
||||
}
|
||||
l = l / (1000 * 60);
|
||||
return l;
|
||||
}
|
||||
|
||||
public static String getStartYearMonthBySeason(String year, int season) {
|
||||
switch (season) {
|
||||
case 1:
|
||||
return getYearMonth(year, "01");
|
||||
case 2:
|
||||
return getYearMonth(year, "04");
|
||||
case 3:
|
||||
return getYearMonth(year, "07");
|
||||
case 4:
|
||||
return getYearMonth(year, "10");
|
||||
default:
|
||||
return getYearMonth(year, "01");
|
||||
}
|
||||
}
|
||||
|
||||
private static String getYearMonth(String year, String month) {
|
||||
return year + "-" + month;
|
||||
}
|
||||
|
||||
public static String getEndYearMonthBySeason(String year, int season) {
|
||||
switch (season) {
|
||||
case 1:
|
||||
return getYearMonth(year, "03");
|
||||
case 2:
|
||||
return getYearMonth(year, "06");
|
||||
case 3:
|
||||
return getYearMonth(year, "09");
|
||||
case 4:
|
||||
return getYearMonth(year, "12");
|
||||
default:
|
||||
return getYearMonth(year, "03");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取本周的时间段 本周一至本周日
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getCurrentWeekTime() {
|
||||
String result = "";
|
||||
String currentDay = getNowDay();
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
Calendar cal = Calendar.getInstance();
|
||||
Date time;
|
||||
try {
|
||||
time = sdf.parse(currentDay);
|
||||
cal.setTime(time);
|
||||
System.out.println("要计算日期为:" + sdf.format(cal.getTime()));
|
||||
|
||||
//判断要计算的日期是否是周日，如果是则减一天计算周六的，否则会出问题，计算到下一周去了//获得当前日期是一个星期的第几天
|
||||
int dayWeek = cal.get(Calendar.DAY_OF_WEEK);
|
||||
if (1 == dayWeek) {
|
||||
cal.add(Calendar.DAY_OF_MONTH, -1);
|
||||
}
|
||||
//设置一个星期的第一天，按中国的习惯一个星期的第一天是星期一
|
||||
cal.setFirstDayOfWeek(Calendar.MONDAY);
|
||||
//获得当前日期是一个星期的第几天
|
||||
int day = cal.get(Calendar.DAY_OF_WEEK);
|
||||
//根据日历的规则，给当前日期减去星期几与一个星期第一天的差值
|
||||
cal.add(Calendar.DATE, cal.getFirstDayOfWeek() - day);
|
||||
System.out.println("所在周一的日期：" + sdf.format(cal.getTime()));
|
||||
result += sdf.format(cal.getTime());
|
||||
System.out.println(cal.getFirstDayOfWeek() + "-" + day + "+6=" + (cal.getFirstDayOfWeek() - day + 6));
|
||||
|
||||
cal.add(Calendar.DATE, 6);
|
||||
result += "," + sdf.format(cal.getTime());
|
||||
System.out.println("所在下周日的日期：" + sdf.format(cal.getTime()));
|
||||
return result;
|
||||
|
||||
} catch (ParseException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取下周的开始时间和结束时间
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getNextWeekTime() {
|
||||
Date date = getBeginDayOfWeek();
|
||||
String time = format(date, "yyyy-MM-dd");
|
||||
Date date2 = getEndDayOfWeek();
|
||||
String time2 = format(date2, "yyyy-MM-dd");
|
||||
|
||||
return time + "," + time2;
|
||||
}
|
||||
|
||||
public static Date getBeginDayOfWeek() {
|
||||
Date date = new Date();
|
||||
Calendar cal = Calendar.getInstance();
|
||||
cal.setTime(date);
|
||||
int dayofweek = cal.get(Calendar.DAY_OF_WEEK);
|
||||
cal.add(Calendar.WEEK_OF_MONTH, 1);
|
||||
if (dayofweek == 1) {
|
||||
dayofweek += 7;
|
||||
}
|
||||
cal.add(Calendar.DATE, 2 - dayofweek);
|
||||
return cal.getTime();
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取前一周的开始和结束时间
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getPrevWeek() {
|
||||
Date date = getBeginDayOfPrevWeek();
|
||||
String time = format(date, "yyyy-MM-dd");
|
||||
Date date2 = getEndDayOfPrevWeek();
|
||||
String time2 = format(date2, "yyyy-MM-dd");
|
||||
|
||||
return time + "," + time2;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取前一周的开始时间
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static Date getBeginDayOfPrevWeek() {
|
||||
Date date = new Date();
|
||||
Calendar cal = Calendar.getInstance();
|
||||
cal.setTime(date);
|
||||
int dayofweek = cal.get(Calendar.DAY_OF_WEEK);
|
||||
cal.add(Calendar.WEEK_OF_MONTH, -1);
|
||||
if (dayofweek == 1) {
|
||||
dayofweek -= 7;
|
||||
}
|
||||
cal.add(Calendar.DATE, 2 - dayofweek);
|
||||
return cal.getTime();
|
||||
}
|
||||
|
||||
public static Date getEndDayOfPrevWeek() {
|
||||
Calendar cal = Calendar.getInstance();
|
||||
cal.setTime(getBeginDayOfPrevWeek());
|
||||
cal.add(Calendar.DAY_OF_WEEK, 6);
|
||||
Date weekEndSta = cal.getTime();
|
||||
return weekEndSta;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 获取指定时间 当前周的周一至周日的时间
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static List<String> getWeekDataList(String time) {
|
||||
List<String> week = new ArrayList<String>();
|
||||
try {
|
||||
if (StringUtils.isEmpty(time)) {
|
||||
time = DateTimeHelper.getNowDay();
|
||||
}
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
Date dataTime = sdf.parse(time);
|
||||
Calendar calendar = Calendar.getInstance();
|
||||
calendar.setTime(dataTime);
|
||||
// 如果是周日
|
||||
if (calendar.get(Calendar.DAY_OF_WEEK) == Calendar.SUNDAY) {
|
||||
calendar.add(Calendar.DAY_OF_YEAR, -1);
|
||||
}
|
||||
// 获取当前日期是当周的第i天
|
||||
int i = calendar.get(Calendar.DAY_OF_WEEK) - 1;
|
||||
// 获取当前日期所在周的第一天
|
||||
calendar.add(Calendar.DATE, -i + 1);
|
||||
int max = 7;
|
||||
for (int j = 0; j < max; j++) {
|
||||
if (j > 0) {
|
||||
calendar.add(Calendar.DATE, 1);
|
||||
}
|
||||
week.add(sdf.format(calendar.getTime()));
|
||||
System.err.println(sdf.format(calendar.getTime()));
|
||||
}
|
||||
return week;
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
return week;
|
||||
}
|
||||
|
||||
/**
|
||||
* 仁义日期加减
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getDayAddOrReduce(String time, int num) {
|
||||
String returnTime = null;
|
||||
try {
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
Date dataTime = sdf.parse(time);
|
||||
Calendar calendar = Calendar.getInstance();
|
||||
calendar.setTime(dataTime);
|
||||
// 如果是周日
|
||||
if (calendar.get(Calendar.DAY_OF_WEEK) == Calendar.SUNDAY) {
|
||||
calendar.add(Calendar.DAY_OF_YEAR, -1);
|
||||
}
|
||||
calendar.add(Calendar.DATE, num);
|
||||
return sdf.format(calendar.getTime());
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
return returnTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* 周开始和周结束时间
|
||||
*
|
||||
* @param time
|
||||
* @param isStart
|
||||
* @return
|
||||
*/
|
||||
public static String getWeekStartOrEndTime(String time, boolean isStart) {
|
||||
String returnTime = null;
|
||||
try {
|
||||
if (StringUtils.isEmpty(time)) {
|
||||
time = DateTimeHelper.getNowDay();
|
||||
}
|
||||
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
Date dataTime = sdf.parse(time);
|
||||
Calendar calendar = Calendar.getInstance();
|
||||
calendar.setTime(dataTime);
|
||||
// 如果是周日
|
||||
if (calendar.get(Calendar.DAY_OF_WEEK) == Calendar.SUNDAY) {
|
||||
calendar.add(Calendar.DAY_OF_YEAR, -1);
|
||||
}
|
||||
// 获取当前日期是当周的第i天
|
||||
int i = calendar.get(Calendar.DAY_OF_WEEK) - 1;
|
||||
// 获取当前日期所在周的第一天
|
||||
calendar.add(Calendar.DATE, -i + 1);
|
||||
if (isStart) {
|
||||
return sdf.format(calendar.getTime());
|
||||
} else {
|
||||
calendar.add(Calendar.DATE, 6);
|
||||
return sdf.format(calendar.getTime());
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
|
||||
return returnTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前日期是多少周 周
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static int getNowWeeks(String time) {
|
||||
try {
|
||||
Date date = new Date();
|
||||
if (StringUtils.isNotEmpty(time)) {
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
date = sdf.parse(time);
|
||||
}
|
||||
Calendar calendar = Calendar.getInstance();
|
||||
calendar.setTime(date);
|
||||
// 获取一年中的第几周
|
||||
int weekOfYear = calendar.get(Calendar.WEEK_OF_YEAR);
|
||||
return weekOfYear;
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 获取前一天的日期
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public static String getFrontDay() {
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
Date date = new Date();
|
||||
Calendar now = Calendar.getInstance();
|
||||
now.setTime(date);
|
||||
now.add(Calendar.DAY_OF_MONTH, -1);
|
||||
return sdf.format(now.getTime());
|
||||
|
||||
}
|
||||
|
||||
public static Date getEndDayOfWeek() {
|
||||
Calendar cal = Calendar.getInstance();
|
||||
cal.setTime(getBeginDayOfWeek());
|
||||
cal.add(Calendar.DAY_OF_WEEK, 6);
|
||||
Date weekEndSta = cal.getTime();
|
||||
return weekEndSta;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取两个时间之间的所有日期
|
||||
*
|
||||
* @param startTime
|
||||
* @param endTime
|
||||
* @return
|
||||
*/
|
||||
public static List<String> getBetweenDate(String startTime, String endTime) {
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
||||
List<String> list = new ArrayList<>();
|
||||
try {
|
||||
//转化日期类型
|
||||
Date startDate = sdf.parse(startTime);
|
||||
Date endDate = sdf.parse(endTime);
|
||||
//用calendar 进行日期比较判断
|
||||
Calendar calendar = Calendar.getInstance();
|
||||
while (startDate.getTime() <= endDate.getTime()) {
|
||||
//把日期添加到集合中
|
||||
list.add(sdf.format(startDate));
|
||||
//设置日期
|
||||
calendar.setTime(startDate);
|
||||
|
||||
//把日期加一天
|
||||
calendar.add(Calendar.DATE, 1);
|
||||
|
||||
//获取增加后的日期
|
||||
startDate = calendar.getTime();
|
||||
}
|
||||
|
||||
} catch (ParseException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
return list;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return float
|
||||
* @Author ccw
|
||||
* @Description 秒换算成小时
|
||||
* @Date 14:08 2022/6/24
|
||||
* @Param [seconds]
|
||||
*/
|
||||
public static String getHours(int seconds) {
|
||||
NumberFormat numberFormat = NumberFormat.getInstance();
|
||||
//保留几位小数填写几
|
||||
numberFormat.setMaximumFractionDigits(3);
|
||||
return numberFormat.format((float) seconds / (float) 3600);
|
||||
}
|
||||
|
||||
/**
|
||||
* @return int
|
||||
* @Author ccw
|
||||
* @Description 时间差
|
||||
* @Date 14:05 2022/6/24
|
||||
* @Param [startTime, endTime]
|
||||
*/
|
||||
public static int getTimeDifference2(String startTime, String endTime) throws ParseException {
|
||||
SimpleDateFormat simpleFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||
Date date = simpleFormat.parse(startTime);
|
||||
long time = date.getTime();
|
||||
Date date2 = simpleFormat.parse(endTime);
|
||||
long time2 = date2.getTime();
|
||||
long timestamp = time2 - time;
|
||||
return (int) (timestamp / 1000);
|
||||
}
|
||||
|
||||
/**
|
||||
* 小时差
|
||||
*
|
||||
* @param endTime
|
||||
* @param startTime
|
||||
* @return
|
||||
* @throws ParseException
|
||||
*/
|
||||
public static Double getTimeHours(String endTime, String startTime) throws ParseException {
|
||||
try {
|
||||
SimpleDateFormat simpleFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||
Date st = simpleFormat.parse(startTime);
|
||||
Date et = simpleFormat.parse(endTime);
|
||||
long time = et.getTime() - st.getTime();
|
||||
DecimalFormat decimalFormat = new DecimalFormat("0.00");
|
||||
String format = decimalFormat.format(time * 1.0 / 3600000 * 1.0);
|
||||
return Double.valueOf(format);
|
||||
} catch (Exception e) {
|
||||
return 0.0;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 分钟差
|
||||
*
|
||||
* @param endTime
|
||||
* @param startTime
|
||||
* @return
|
||||
* @throws ParseException
|
||||
*/
|
||||
public static Long getTimeMine(String endTime, String startTime) throws ParseException {
|
||||
try {
|
||||
SimpleDateFormat simpleFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||
Date st = simpleFormat.parse(startTime);
|
||||
Date et = simpleFormat.parse(endTime);
|
||||
long time = et.getTime() - st.getTime();
|
||||
double times = Double.parseDouble(time + "");
|
||||
double b = times / 1000 / 60;
|
||||
return time / 1000 / 60;
|
||||
} catch (Exception e) {
|
||||
return 0L;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 日期解析为时间戳
|
||||
*
|
||||
* @param dateString
|
||||
* @param format
|
||||
* @return Long
|
||||
* @description
|
||||
* @author cwchen
|
||||
* @date 2024/3/16 15:11
|
||||
*/
|
||||
public static Long convertDateStringToTimestamp(String dateString, String format) {
|
||||
Date date = null;
|
||||
try {
|
||||
SimpleDateFormat sdf = new SimpleDateFormat(format);
|
||||
date = sdf.parse(dateString);
|
||||
} catch (ParseException e) {
|
||||
log.error("日期解析为时间戳异常", e);
|
||||
return null;
|
||||
}
|
||||
return date.getTime();
|
||||
}
|
||||
|
||||
/**
|
||||
* 两个日期之间的差值
|
||||
*
|
||||
* @param startDate
|
||||
* @param endDate
|
||||
* @return Long
|
||||
* @description
|
||||
* @author cwchen
|
||||
* @date 2024/3/28 20:38
|
||||
*/
|
||||
public static Long getDayDifference(String startDate, String endDate) {
|
||||
if (StringUtils.isBlank(startDate) || StringUtils.isBlank(endDate)) {
|
||||
return 0L;
|
||||
}
|
||||
DateFormat dft = new SimpleDateFormat("yyyy-MM-dd");
|
||||
try {
|
||||
Date star = dft.parse(startDate);
|
||||
Date endDay = dft.parse(endDate);
|
||||
Long starTime = star.getTime();
|
||||
Long endTime = endDay.getTime();
|
||||
Long num = endTime - starTime;
|
||||
System.out.println("相差天数为：" + num / 24 / 60 / 60 / 1000);
|
||||
return (num / 24 / 60 / 60 / 1000) + 1;
|
||||
} catch (ParseException e) {
|
||||
log.error("两个日期之间的差值", e);
|
||||
return 0L;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取当前月的第一天和最后一天
|
||||
*/
|
||||
public static String getMonthFirstAndLastDay() {
|
||||
Calendar a = Calendar.getInstance();
|
||||
//把日期设置为当月第一天
|
||||
a.set(Calendar.DATE, 1);
|
||||
//日期回滚一天，也就是最后一天
|
||||
a.roll(Calendar.DATE, -1);
|
||||
//当月有多少天
|
||||
int maxDate = a.get(Calendar.DATE);
|
||||
SimpleDateFormat sdfTwo = new SimpleDateFormat("yyyy-MM-");
|
||||
String startTime = sdfTwo.format(new Date()) + "01";
|
||||
String endTime = sdfTwo.format(new Date()) + maxDate;
|
||||
return startTime + " - " + endTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* 比较两个时间
|
||||
* @param startTime
|
||||
* @param endTime
|
||||
* @return boolean
|
||||
* @description
|
||||
* @author cwchen
|
||||
* @date 2024/4/24 9:55
|
||||
*/
|
||||
public static boolean compareTime(String startTime, String endTime) {
|
||||
Long aLong = convertDateStringToTimestamp(startTime, "yyyy-MM-dd");
|
||||
Long bLong = convertDateStringToTimestamp(endTime, "yyyy-MM-dd");
|
||||
if (aLong > bLong) {
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* 将时间戳转换为时间
|
||||
*/
|
||||
public static String stampToDate(String stap) {
|
||||
String time;
|
||||
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||
long lt = new Long(stap);
|
||||
Date date = new Date(lt * 1000);
|
||||
time = simpleDateFormat.format(date);
|
||||
return time;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,56 @@
|
|||
package com.bonus.common.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
/**
|
||||
* @className:DeviceUseVo
|
||||
* @author:cwchen
|
||||
* @date:2024-08-27-15:36
|
||||
* @version:1.0
|
||||
* @description:设备领用-vo
|
||||
*/
|
||||
@Data
|
||||
public class DeviceUseVo {
|
||||
private Long id;
|
||||
/**设备ID*/
|
||||
private Long devId;
|
||||
|
||||
/**工程ID*/
|
||||
private Long proId;
|
||||
/**班组ID*/
|
||||
private Long teamId;
|
||||
/**杆塔ID*/
|
||||
private Long gtId;
|
||||
/**人员身份证号*/
|
||||
private String idCard;
|
||||
/**人员ID*/
|
||||
private Long userId;
|
||||
/**告警内容*/
|
||||
private String warnContent;
|
||||
/**告警时间*/
|
||||
private String warnTime;
|
||||
/**告警类型 1 设备告警 2 违章识别 3 带电体告警*/
|
||||
private String warnType = "2";
|
||||
private Date createTime = new Date();
|
||||
/**删除状态*/
|
||||
private Integer delFlag = 0;
|
||||
/**设备关联类型 0手环 1设备*/
|
||||
private Integer devType = 1;
|
||||
/**人员类型 0默认 1 临时人员*/
|
||||
private Integer peopleType = 0;
|
||||
|
||||
private String bidId;
|
||||
/**设备ID*/
|
||||
private Integer bindDevId;
|
||||
|
||||
/**设备ID*/
|
||||
private String bidTime;
|
||||
|
||||
// 设备负责人
|
||||
private String deviceUser;
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,21 @@
|
|||
package com.bonus.common.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* @className:PeopleVioVo
|
||||
* @author:cwchen
|
||||
* @date:2024-08-27-16:06
|
||||
* @version:1.0
|
||||
* @description:人员违章-vo
|
||||
*/
|
||||
@Data
|
||||
public class PeopleVioVo {
|
||||
|
||||
/**人员ID*/
|
||||
private Long id;
|
||||
/**姓名*/
|
||||
private String name;
|
||||
/**人员类别 0-班组成员 1-临时人员*/
|
||||
private Integer peopleType;
|
||||
}
|
||||
|
|
@ -138,7 +138,11 @@
|
|||
<artifactId>spring-boot-starter-test</artifactId>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>dom4j</groupId>
|
||||
<artifactId>dom4j</artifactId>
|
||||
<version>1.6.1</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.junit.vintage</groupId>
|
||||
<artifactId>junit-vintage-engine</artifactId>
|
||||
|
|
|
|||
|
|
@ -0,0 +1,213 @@
|
|||
package com.bonus.project.controller;
|
||||
|
||||
import com.bonus.common.core.utils.BASE64DecodedMultipartFile;
|
||||
import com.bonus.common.core.utils.DateTimeHelper;
|
||||
import com.bonus.common.entity.DeviceUseVo;
|
||||
import com.bonus.common.redis.service.RedisService;
|
||||
import com.bonus.project.service.SmartIdentifyService;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.collections4.CollectionUtils;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.dom4j.Document;
|
||||
import org.dom4j.DocumentException;
|
||||
import org.dom4j.DocumentHelper;
|
||||
import org.dom4j.Element;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.springframework.web.bind.annotation.RequestBody;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
import java.util.Objects;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.concurrent.locks.ReentrantLock;
|
||||
|
||||
/**
|
||||
* @className:SmartIdentifyController
|
||||
* @author:cwchen
|
||||
* @date:2024-08-27-14:26
|
||||
* @version:1.0
|
||||
* @description:球机智能识别
|
||||
*/
|
||||
@Slf4j
|
||||
@RestController
|
||||
@RequestMapping("/ball")
|
||||
public class SmartIdentifyController {
|
||||
|
||||
@Autowired
|
||||
private RedisService redisService;
|
||||
|
||||
@Autowired
|
||||
private SmartIdentifyService service;
|
||||
|
||||
public static final ReentrantLock BED_LOCK = new ReentrantLock();
|
||||
|
||||
/**
|
||||
* 事件id集合
|
||||
* E_IVS_HelmetNotWear ：未带安全帽
|
||||
* E_IVS_Smoking ：抽烟报警
|
||||
* E_IVS_NotWear3ColorVest ：未穿三色马甲报警
|
||||
*/
|
||||
public static List<String> eventIds = new ArrayList<>();
|
||||
|
||||
{
|
||||
eventIds.add("E_IVS_HelmetNotWear");
|
||||
eventIds.add("E_IVS_Smoking");
|
||||
eventIds.add("E_IVS_NotWear3ColorVest");
|
||||
}
|
||||
|
||||
/**
|
||||
* 清新互联平台事件推送接口
|
||||
*
|
||||
* @param xml
|
||||
* @return
|
||||
*/
|
||||
@PostMapping("xmlAnalysis")
|
||||
public String xmlAnalysis(@RequestBody String xml) {
|
||||
try {
|
||||
// 设置对象锁
|
||||
boolean flag = BED_LOCK.tryLock(10L * 1000L, TimeUnit.MILLISECONDS);
|
||||
if (flag) {
|
||||
boolean existence = false;
|
||||
//解析xml字符串为Document
|
||||
Document doc = null;
|
||||
//事件ID
|
||||
String evenID = null;
|
||||
//身份证号
|
||||
String idCard = null;
|
||||
//事件时间
|
||||
String eventTime = DateTimeHelper.getNowTime();
|
||||
//解析xml内容
|
||||
doc = DocumentHelper.parseText(xml);
|
||||
//获取根节点
|
||||
Element root = doc.getRootElement();
|
||||
//获取根节点下的所有M子节点
|
||||
Iterator it = root.elementIterator("E");
|
||||
//获取单个事件
|
||||
if (it != null) {
|
||||
Element element = (Element) it.next();
|
||||
String id = element.attributeValue("ID");
|
||||
evenID = id;
|
||||
//获取事件发生时间
|
||||
if (StringUtils.isNotBlank(element.attributeValue("Time"))) {
|
||||
eventTime = DateTimeHelper.stampToDate(element.attributeValue("Time"));
|
||||
}
|
||||
Iterator desc2Interator = element.elementIterator("Desc2");
|
||||
if (desc2Interator != null) {
|
||||
Element idCardEle = (Element) desc2Interator.next();
|
||||
idCard = idCardEle.attributeValue("IDCard");
|
||||
}
|
||||
Iterator srcInterator = element.elementIterator("Src");
|
||||
String ballName = null;
|
||||
if (srcInterator != null) {
|
||||
Element headEle = (Element) srcInterator.next();
|
||||
String puid = headEle.attributeValue("ID");
|
||||
// 十分钟内存在该事件，直接返回
|
||||
Object cacheObject = redisService.getCacheObject(evenID + "_" + puid);
|
||||
if (Objects.nonNull(cacheObject)) {
|
||||
log.info("十分钟内存在该事件");
|
||||
return "error";
|
||||
}
|
||||
Iterator resInterator = headEle.elementIterator("Res");
|
||||
if (resInterator != null) {
|
||||
Element nameEle = (Element) resInterator.next();
|
||||
ballName = nameEle.attributeValue("Name");
|
||||
}
|
||||
boolean sf = eventIds.contains(evenID);
|
||||
List<DeviceUseVo> devices = null;
|
||||
if (sf) {
|
||||
devices = service.getDevices(puid);
|
||||
existence = CollectionUtils.isNotEmpty(devices) ? true : false;
|
||||
}
|
||||
//存在该设备
|
||||
if (existence) {
|
||||
switchEvent(evenID, element, eventTime, puid, ballName, idCard, devices);
|
||||
// 事件推送成功后，设置缓存
|
||||
String key = evenID + "_" + puid;
|
||||
log.info("redis-key:{}", key);
|
||||
redisService.setCacheObject(key, puid, 10L, TimeUnit.MINUTES);
|
||||
} else {
|
||||
return "error";
|
||||
}
|
||||
} else {
|
||||
return "error";
|
||||
}
|
||||
} else {
|
||||
return "error";
|
||||
}
|
||||
} else {
|
||||
log.info("系统繁忙，请稍后重试");
|
||||
return "error";
|
||||
}
|
||||
} catch (InterruptedException e) {
|
||||
log.error("对象锁", e);
|
||||
} catch (DocumentException e) {
|
||||
throw new RuntimeException(e);
|
||||
} finally {
|
||||
// 确保锁被释放
|
||||
BED_LOCK.unlock();
|
||||
}
|
||||
return "ok";
|
||||
}
|
||||
|
||||
private void switchEvent(String eventId, Element element, String eventTime, String puid, String ballName, String idCard, List<DeviceUseVo> devices) {
|
||||
List<MultipartFile> files = null;
|
||||
DeviceUseVo deviceUseVo = devices.get(0);
|
||||
deviceUseVo.setWarnTime(eventTime);
|
||||
deviceUseVo.setIdCard(idCard);
|
||||
switch (eventId) {
|
||||
case "E_IVS_HelmetNotWear":
|
||||
log.info(puid + ":违章事件：未戴安全帽");
|
||||
deviceUseVo.setWarnContent("未戴安全帽");
|
||||
files = deviceVolEvenHandler(element);
|
||||
service.addEventData(deviceUseVo, files);
|
||||
break;
|
||||
case "E_IVS_Smoking":
|
||||
log.info(puid + ":违章事件：吸烟行为");
|
||||
deviceUseVo.setWarnContent("吸烟行为");
|
||||
files = deviceVolEvenHandler(element);
|
||||
service.addEventData(deviceUseVo, files);
|
||||
break;
|
||||
case "E_IVS_NotWear3ColorVest":
|
||||
log.info(puid + ":违章事件：未穿马甲");
|
||||
deviceUseVo.setWarnContent("未穿马甲");
|
||||
files = deviceVolEvenHandler(element);
|
||||
service.addEventData(deviceUseVo, files);
|
||||
break;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
private List<MultipartFile> deviceVolEvenHandler(Element element) {
|
||||
List<MultipartFile> multipartFiles = new ArrayList<>();
|
||||
Iterator silcesInterator = element.elementIterator("Slices");
|
||||
if (silcesInterator.hasNext()) {
|
||||
Element silcesEle = (Element) silcesInterator.next();
|
||||
if (silcesEle != null) {
|
||||
Iterator silcInterator = silcesEle.elementIterator("Slice");
|
||||
if (silcInterator.hasNext()) {
|
||||
Element snapshotEle = (Element) silcInterator.next();
|
||||
if (snapshotEle != null) {
|
||||
Iterator snapshotInterator = snapshotEle.elementIterator("Snapshot");
|
||||
if (snapshotInterator.hasNext()) {
|
||||
Element TestEle = (Element) snapshotInterator.next();
|
||||
String photoBase64 = TestEle.getText();
|
||||
log.info("base64地址：{}", photoBase64);
|
||||
MultipartFile multipartFile = BASE64DecodedMultipartFile.base64ToMultipart2(photoBase64);
|
||||
if (multipartFile != null) {
|
||||
multipartFiles.add(multipartFile);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return multipartFiles;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,33 @@
|
|||
package com.bonus.project.service;
|
||||
|
||||
import com.bonus.common.entity.DeviceUseVo;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @className:SmartIdentifyService
|
||||
* @author:cwchen
|
||||
* @date:2024-08-27-15:15
|
||||
* @version:1.0
|
||||
* @description:智能识别
|
||||
*/
|
||||
public interface SmartIdentifyService {
|
||||
/**
|
||||
* 判断球机是否被班组领用
|
||||
*
|
||||
* @param puid
|
||||
* @return boolean
|
||||
* @date 2024/8/27 15:22
|
||||
*/
|
||||
List<DeviceUseVo> getDevices(String puid);
|
||||
|
||||
/**
|
||||
* 添加智能识别告警信息
|
||||
* @param deviceUseVo
|
||||
* @param files
|
||||
* @return void
|
||||
* @date 2024/8/27 16:00
|
||||
*/
|
||||
void addEventData(DeviceUseVo deviceUseVo, List<MultipartFile> files);
|
||||
}
|
||||
|
|
@ -0,0 +1,124 @@
|
|||
package com.bonus.project.service.impl;
|
||||
|
||||
import com.alibaba.fastjson2.JSON;
|
||||
import com.alibaba.fastjson2.JSONObject;
|
||||
import com.bonus.common.core.constant.HttpStatus;
|
||||
import com.bonus.common.core.constant.SecurityConstants;
|
||||
import com.bonus.common.core.domain.R;
|
||||
import com.bonus.common.core.utils.encryption.Sm4Utils;
|
||||
import com.bonus.common.entity.DeviceUseVo;
|
||||
import com.bonus.common.entity.PeopleVioVo;
|
||||
import com.bonus.project.mapper.SmartIdentifyMapper;
|
||||
import com.bonus.project.service.SmartIdentifyService;
|
||||
import com.bonus.system.api.RemoteFileService;
|
||||
import com.bonus.system.api.domain.SysFileSource;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.collections4.CollectionUtils;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
import org.springframework.transaction.interceptor.TransactionAspectSupport;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @className:SmartIdentifyServiceImpl
|
||||
* @author:cwchen
|
||||
* @date:2024-08-27-15:15
|
||||
* @version:1.0
|
||||
* @description:智能识别
|
||||
*/
|
||||
@Service
|
||||
@Slf4j
|
||||
public class SmartIdentifyServiceImpl implements SmartIdentifyService {
|
||||
|
||||
@Resource
|
||||
private SmartIdentifyMapper mapper;
|
||||
|
||||
@Resource
|
||||
private RemoteFileService remoteFileService;
|
||||
|
||||
@Override
|
||||
public List<DeviceUseVo> getDevices(String puid) {
|
||||
List<DeviceUseVo> list = null;
|
||||
try {
|
||||
list = mapper.getDevices(puid);
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
return list;
|
||||
}
|
||||
|
||||
@Override
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public void addEventData(DeviceUseVo deviceUseVo, List<MultipartFile> files) {
|
||||
// 文件ID
|
||||
String delFileId = null;
|
||||
try {
|
||||
if (StringUtils.isNotBlank(deviceUseVo.getIdCard())) {
|
||||
/* List<PeopleVioVo> userIds = mapper.getUserByIdCard(Sm4Utils.encode(deviceUseVo.getIdCard()));
|
||||
if (CollectionUtils.isNotEmpty(userIds)) {
|
||||
deviceUseVo.setUserId(userIds.get(0).getId());
|
||||
deviceUseVo.setPeopleType(userIds.get(0).getPeopleType());
|
||||
deviceUseVo.setWarnContent(userIds.get(0).getName() + deviceUseVo.getWarnContent());
|
||||
}*/
|
||||
}
|
||||
// 添加告警信息
|
||||
mapper.addWarnInfo(deviceUseVo);
|
||||
// 上传智能识别图片
|
||||
if (CollectionUtils.isNotEmpty(files)) {
|
||||
delFileId = uploadFile(files.get(0), deviceUseVo.getId());
|
||||
}
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
||||
// 添加失败-删除文件
|
||||
/*if (delFileId != null) {
|
||||
remoteFileService.delFile(delFileId, SecurityConstants.INNER);
|
||||
}*/
|
||||
}
|
||||
}
|
||||
|
||||
public String uploadFile(MultipartFile file, Long warnId) {
|
||||
if (file == null) {
|
||||
return null;
|
||||
}
|
||||
R result = remoteFileService.singleUploadFile(file, SecurityConstants.INNER);
|
||||
if (result != null && result.getCode() == HttpStatus.ERROR) {
|
||||
log.error("违章照片上传失败");
|
||||
return null;
|
||||
} else if (result != null && result.getCode() == HttpStatus.SUCCESS && result.getData() != null) {
|
||||
String jsonString = JSON.toJSONString(result.getData());
|
||||
JSONObject item = JSON.parseObject(jsonString);
|
||||
if (item != null) {
|
||||
SysFileSource fileVo = setResourceFileData(item, warnId);
|
||||
try {
|
||||
Integer i = mapper.addFileSource(fileVo);
|
||||
if (i <= 0) {
|
||||
// 资源文件保存失败，删除文件
|
||||
// remoteFileService.delFile(item.getString("fileId"), SecurityConstants.INNER);
|
||||
return null;
|
||||
}
|
||||
} catch (Exception e) {
|
||||
log.error(e.toString(), e);
|
||||
}
|
||||
}
|
||||
return item.getString("fileId");
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
public SysFileSource setResourceFileData(JSONObject item, Long warnId) {
|
||||
SysFileSource fileVo = new SysFileSource();
|
||||
fileVo.setFileType(1);
|
||||
fileVo.setFilePath(item.getString("fileId"));
|
||||
fileVo.setFileSuffix(item.getString("suffix"));
|
||||
fileVo.setFileName(item.getString("fileName"));
|
||||
fileVo.setSourceId(warnId + "");
|
||||
fileVo.setSourceType("8");
|
||||
return fileVo;
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,59 @@
|
|||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<!DOCTYPE mapper
|
||||
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
||||
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.bonus.project.mapper.SmartIdentifyMapper">
|
||||
<!--添加告警信息-->
|
||||
<insert id="addWarnInfo" useGeneratedKeys="true" keyProperty="id">
|
||||
INSERT INTO tb_warn
|
||||
<trim prefix="(" suffix=")" suffixOverrides=",">
|
||||
<if test="proId != null">pro_id,</if>
|
||||
<if test="devId != null">dev_id,</if>
|
||||
<if test="warnContent != null and warnContent!=''">warn_content,</if>
|
||||
<if test="warnTime != null and warnTime!=''">warn_time,</if>
|
||||
<if test="warnType != null">warn_type,</if>
|
||||
<if test="devType != null">dev_type,</if>
|
||||
create_time,
|
||||
</trim>
|
||||
<trim prefix="values (" suffix=")" suffixOverrides=",">
|
||||
<if test="proId != null">#{proId},</if>
|
||||
<if test="devId != null">#{devId},</if>
|
||||
<if test="warnContent != null and warnContent!=''">#{warnContent},</if>
|
||||
<if test="warnTime != null and warnTime!=''">#{warnTime},</if>
|
||||
<if test="warnType != null">#{warnType},</if>
|
||||
<if test="devType != null">#{devType},</if>
|
||||
now(),
|
||||
</trim>
|
||||
</insert>
|
||||
<insert id="addFileSource">
|
||||
INSERT INTO sys_file_source(
|
||||
file_name, file_suffix, file_path,
|
||||
file_type, source_id, source_type,
|
||||
create_time,create_user,update_time,
|
||||
update_user, del_flag
|
||||
) VALUE(
|
||||
#{fileName},#{fileSuffix},#{filePath},
|
||||
#{fileType},#{sourceId},#{sourceType},
|
||||
now(),#{createUser},now(),
|
||||
#{updateUser},0
|
||||
)
|
||||
</insert>
|
||||
|
||||
<!--判断球机是否被班组领用-->
|
||||
<select id="getDevices" resultType="com.bonus.common.entity.DeviceUseVo">
|
||||
SELECT pdi.dev_id AS devId,
|
||||
pdi.device_user AS deviceUser,
|
||||
ldp.pro_id AS proId
|
||||
FROM pf_device_info AS pdi
|
||||
LEFT JOIN pt_device_type AS pdt ON pdi.device_type = pdt.device_type AND pdt.is_active = '1'
|
||||
LEFT JOIN lk_device_pro AS ldp ON ldp.device_id = pdi.device_id AND ldp.is_active = '1'
|
||||
LEFT JOIN pt_project_info AS ppi ON ppi.pro_id = ldp.pro_id AND ppi.is_active = '1'
|
||||
WHERE pdi.is_active = '1'
|
||||
</select>
|
||||
<!--根据身份证号获取班组成员/临时人员-->
|
||||
<select id="getUserByIdCard" resultType="com.bonus.common.entity.PeopleVioVo">
|
||||
SELECT id,name,0 AS peopleType FROM tb_people tp WHERE id_card = #{idCard} AND del_flag = 0
|
||||
UNION ALL
|
||||
SELECT id,name,0 AS peopleType FROM tb_ls_user tlu WHERE id_card = #{idCard}
|
||||
</select>
|
||||
</mapper>
|
||||
Loading…
Reference in New Issue