From e4f537a87d13e9cca53e564a18fd6c60ef1e7c39 Mon Sep 17 00:00:00 2001 From: kchh <365619549@qq.com> Date: Thu, 8 Aug 2024 17:30:55 +0800 Subject: [PATCH] k --- utils/pom.xml | 103 +++++ .../com/haitongauto/utils/CorsConfig.java | 51 +++ .../com/haitongauto/utils/DateTimeHelper.java | 73 ++++ .../haitongauto/utils/FileDownloadUtil.java | 90 +++++ .../com/haitongauto/utils/FormatDateTime.java | 352 ++++++++++++++++++ .../com/haitongauto/utils/GetDateTime.java | 103 +++++ .../com/haitongauto/utils/HtmlToPdfUtils.java | 183 +++++++++ .../haitongauto/utils/HttpClientHelper.java | 145 ++++++++ .../com/haitongauto/utils/HttpRequest.java | 253 +++++++++++++ .../com/haitongauto/utils/HttpTemplate.java | 236 ++++++++++++ .../java/com/haitongauto/utils/IpHelper.java | 49 +++ .../haitongauto/utils/PageEventHandler.java | 49 +++ .../java/com/haitongauto/utils/PdfUtils.java | 119 ++++++ .../java/com/haitongauto/utils/PostFiles.java | 47 +++ .../haitongauto/utils/QueueNumberHelper.java | 51 +++ .../com/haitongauto/utils/StringHelper.java | 21 ++ .../utils/WaterMarkEventHandler.java | 84 +++++ .../haitongauto/utils/check/CheckHelper.java | 77 ++++ .../ExcelCustomCellWriteHeightConfig.java | 61 +++ .../ExcelCustomCellWriteWidthConfig.java | 87 +++++ .../utils/excel/ExcelGenerateHelper.java | 239 ++++++++++++ .../haitongauto/utils/http/OkHttpUtils.java | 223 +++++++++++ .../haitongauto/utils/minio/MinioProp.java | 26 ++ .../haitongauto/utils/minio/MinioUtils.java | 113 ++++++ utils/src/main/resources/log4j2.xml | 13 + utils/src/main/resources/utils.yml | 15 + utils/src/test/java/QueueNumTest.java | 40 ++ utils/utils.iml | 6 + 28 files changed, 2909 insertions(+) create mode 100644 utils/pom.xml create mode 100644 utils/src/main/java/com/haitongauto/utils/CorsConfig.java create mode 100644 utils/src/main/java/com/haitongauto/utils/DateTimeHelper.java create mode 100644 utils/src/main/java/com/haitongauto/utils/FileDownloadUtil.java create mode 100644 utils/src/main/java/com/haitongauto/utils/FormatDateTime.java create mode 100644 utils/src/main/java/com/haitongauto/utils/GetDateTime.java create mode 100644 utils/src/main/java/com/haitongauto/utils/HtmlToPdfUtils.java create mode 100644 utils/src/main/java/com/haitongauto/utils/HttpClientHelper.java create mode 100644 utils/src/main/java/com/haitongauto/utils/HttpRequest.java create mode 100644 utils/src/main/java/com/haitongauto/utils/HttpTemplate.java create mode 100644 utils/src/main/java/com/haitongauto/utils/IpHelper.java create mode 100644 utils/src/main/java/com/haitongauto/utils/PageEventHandler.java create mode 100644 utils/src/main/java/com/haitongauto/utils/PdfUtils.java create mode 100644 utils/src/main/java/com/haitongauto/utils/PostFiles.java create mode 100644 utils/src/main/java/com/haitongauto/utils/QueueNumberHelper.java create mode 100644 utils/src/main/java/com/haitongauto/utils/StringHelper.java create mode 100644 utils/src/main/java/com/haitongauto/utils/WaterMarkEventHandler.java create mode 100644 utils/src/main/java/com/haitongauto/utils/check/CheckHelper.java create mode 100644 utils/src/main/java/com/haitongauto/utils/excel/ExcelCustomCellWriteHeightConfig.java create mode 100644 utils/src/main/java/com/haitongauto/utils/excel/ExcelCustomCellWriteWidthConfig.java create mode 100644 utils/src/main/java/com/haitongauto/utils/excel/ExcelGenerateHelper.java create mode 100644 utils/src/main/java/com/haitongauto/utils/http/OkHttpUtils.java create mode 100644 utils/src/main/java/com/haitongauto/utils/minio/MinioProp.java create mode 100644 utils/src/main/java/com/haitongauto/utils/minio/MinioUtils.java create mode 100644 utils/src/main/resources/log4j2.xml create mode 100644 utils/src/main/resources/utils.yml create mode 100644 utils/src/test/java/QueueNumTest.java create mode 100644 utils/utils.iml diff --git a/utils/pom.xml b/utils/pom.xml new file mode 100644 index 0000000..bb70dd5 --- /dev/null +++ b/utils/pom.xml @@ -0,0 +1,103 @@ + + + + rtos-wh + org.example + 1.0-SNAPSHOT + + 4.0.0 + utils + + + 1.8 + 1.8 + UTF-8 + + + + org.springframework.boot + spring-boot-starter + 2.7.8 + + + org.springframework.boot + spring-boot-starter-web + 2.7.8 + + + com.itextpdf + html2pdf + 3.0.2 + + + + com.itextpdf + font-asian + 7.1.13 + + + org.projectlombok + lombok + 1.18.26 + compile + + + org.example + models + 1.0-SNAPSHOT + compile + + + + com.alibaba + easyexcel + 3.0.2 + + + + cglib + cglib + 3.1 + + + io.minio + minio + 6.0.11 + + + com.alibaba + fastjson + 1.2.7 + + + junit + junit + test + + + com.bestvike + linq + 3.1.0 + + + top.jfunc.json + Json-Gson + 1.0 + + + org.apache.logging.log4j + log4j-api + 2.14.1 + + + org.apache.logging.log4j + log4j-core + 2.14.1 + + + + + + \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/CorsConfig.java b/utils/src/main/java/com/haitongauto/utils/CorsConfig.java new file mode 100644 index 0000000..99fbc47 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/CorsConfig.java @@ -0,0 +1,51 @@ +package com.haitongauto.utils; + +import org.springframework.context.annotation.Configuration; +import org.springframework.web.servlet.config.annotation.CorsRegistry; +import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry; +import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; + +/** + * 跨域配置：重写WebMvcConfigurer即可 + */ +@Configuration +public class CorsConfig implements WebMvcConfigurer { + /** + * 跨域支持方法 + * @param registry 开启跨域注册 + */ + @Override + public void addCorsMappings(CorsRegistry registry){ + //addMapping 添加可跨域的请求地址 + registry.addMapping("/**") + //设置跨域 域名权限 规定由某一个指定的域名+端口能访问跨域项目 + .allowedOrigins("*") + //.allowedOrigins("http://localhost:8080") + //是否开启cookie跨域 + .allowCredentials(false) + //规定能够跨域访问的方法类型 + .allowedMethods("GET","POST","DELETE","PUT","OPTIONS") + //添加验证请求头信息 token + .allowedHeaders("*") + //预请求存活时间，在此期间不在发送预请求 + .maxAge(3600); + } + + /** + * 请求拦截：将请求路径映射到安全的目标路径 + * @param registry 注册实例 + */ + @Override + public void addResourceHandlers(ResourceHandlerRegistry registry) { + ////addResourceHandler：请求路径 + ////addResourceLocations：映射路径 + //registry.addResourceHandler("/**") + // .addResourceLocations("classpath:/static/"); + //registry.addResourceHandler("swagger-ui.html") + // .addResourceLocations("classpath:/META-INF/resources/"); + //registry.addResourceHandler("doc.html") + // .addResourceLocations("classpath:/META-INF/resources/"); + //registry.addResourceHandler("/webjars/**") + // .addResourceLocations("classpath:/META-INF/resources/webjars/"); + } +} diff --git a/utils/src/main/java/com/haitongauto/utils/DateTimeHelper.java b/utils/src/main/java/com/haitongauto/utils/DateTimeHelper.java new file mode 100644 index 0000000..f815f85 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/DateTimeHelper.java @@ -0,0 +1,73 @@ +package com.haitongauto.utils; + +import java.text.ParsePosition; +import java.text.SimpleDateFormat; +import java.time.LocalDate; +import java.time.LocalDateTime; +import java.time.LocalTime; +import java.util.Date; + +public class DateTimeHelper { + /** + * 字符串转日期时间 + * @param my_date_time my_date_time + * @return return + */ + public static Date DateStrToDateTime(String my_date_time){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + ParsePosition pos = new ParsePosition(0); + return sdf.parse(my_date_time,pos); + } + + /** + * 字符串转日期 + * @param my_date my_date + * @return return + */ + public static Date DateStrToDate(String my_date){ + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + ParsePosition pos = new ParsePosition(0); + return sdf.parse(my_date,pos); + } + + /** + * 字符串转时间 + * @param my_date my_date + * @return return + */ + public static Date DateStrToTime(String my_date){ + SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss"); + ParsePosition pos = new ParsePosition(0); + return sdf.parse(my_date,pos); + } + + + /** + * 字符串转LoaclDateTime + * @param my_date：日期时间字符串 + * @return 日期时间对象 + */ + public static LocalDateTime DateTimeStrToLocalDateTime(String my_date){ + my_date=my_date.replace(" ","T"); + return LocalDateTime.parse(my_date); + } + + /** + * 字符串转LocalDate + * @param my_date my_date + * @return return + */ + public static LocalDate DateStrToLocalDate(String my_date){ + return LocalDate.parse(my_date); + } + + /** + * 字符串转LocalTime + * @param my_date my_date + * @return return + */ + public static LocalTime DateStrToLocalTime(String my_date){ + return LocalTime.parse(my_date); + } + +} diff --git a/utils/src/main/java/com/haitongauto/utils/FileDownloadUtil.java b/utils/src/main/java/com/haitongauto/utils/FileDownloadUtil.java new file mode 100644 index 0000000..deb89a3 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/FileDownloadUtil.java @@ -0,0 +1,90 @@ +package com.haitongauto.utils; + +import javax.servlet.http.HttpServletResponse; +import java.io.*; +import java.net.HttpURLConnection; +import java.net.MalformedURLException; +import java.net.ProtocolException; +import java.net.URL; + +public class FileDownloadUtil { + + /** + * 从服务器获得一个输入流 + * @param urlPath 路径 + * @return 返回输入流 + */ + public static InputStream getInputStream(String urlPath) { + InputStream inputStream = null; + HttpURLConnection httpURLConnection = null; + try { + URL url = new URL(urlPath); + httpURLConnection = (HttpURLConnection) url.openConnection(); + // 设置网络连接超时时间 + httpURLConnection.setConnectTimeout(3000); + // 设置应用程序要从网络连接读取数据 + httpURLConnection.setDoInput(true); + httpURLConnection.setRequestMethod("GET"); + int responseCode = httpURLConnection.getResponseCode(); + System.out.println("responseCode is:" + responseCode); + if (responseCode == HttpURLConnection.HTTP_OK) { + // 从服务器返回一个输入流 + inputStream = httpURLConnection.getInputStream(); + } else { + inputStream = httpURLConnection.getErrorStream(); + } + } catch (MalformedURLException e) { + e.printStackTrace(); + } catch (IOException e) { + throw new RuntimeException(e); + } + return inputStream; + } + + /** + * @param resp resp + * @param inputStream inputStream + * @description: 将输入流输出到页面 + */ + public static void writeFile(HttpServletResponse resp, InputStream inputStream) { + OutputStream out = null; + try { + out = resp.getOutputStream(); + int len = 0; + byte[] b = new byte[4096]; + while ((len = inputStream.read(b)) != -1) { + out.write(b, 0, len); + } + out.flush(); + } catch (IOException e) { + e.printStackTrace(); + } finally { + try { + //inputStream.close(); + if (out != null) { + out.close(); + } + } catch (Exception e) { + e.printStackTrace(); + } + } + } + + + /** + * 获得输入流 + * @param filePath 完整的文夹路径名 + * @return 返回输入流 + */ + public static InputStream fileToInputStream(String filePath) { + File file = new File(filePath); + FileInputStream fileInputStream = null; + try { + fileInputStream = new FileInputStream(file); + } catch (FileNotFoundException e) { + throw new RuntimeException(e); + } + return fileInputStream; + } + +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/FormatDateTime.java b/utils/src/main/java/com/haitongauto/utils/FormatDateTime.java new file mode 100644 index 0000000..05bd666 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/FormatDateTime.java @@ -0,0 +1,352 @@ +package com.haitongauto.utils; + +import java.text.ParsePosition; +import java.text.SimpleDateFormat; +import java.time.Instant; +import java.time.LocalDate; +import java.time.ZoneId; +import java.util.Calendar; +import java.util.Date; +import java.util.GregorianCalendar; +import java.util.concurrent.TimeUnit; + +public class FormatDateTime { + /** + * 日期加一天 + * + * @return 返回时间类型 yyyy-MM-dd HH:mm:ss + */ + public static Date getDateAddOne(Date myDate) { + Date currentTime = myDate; + Calendar calendar = new GregorianCalendar(); + calendar.setTime(currentTime); + calendar.add(Calendar.DATE, 1); + currentTime = calendar.getTime(); + return currentTime; + } + + /** + * 获取今天文件夹日期 + * + * @return 返回时间类型 yyyy-MM-dd HH:mm:ss + */ + public static String getTodayStr() { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMdd"); + String dateString = formatter.format(currentTime); + return dateString; + } + + /** + * 获取昨天文件夹日期 + * + * @return 返回时间类型 yyyy-MM-dd HH:mm:ss + */ + public static String getYesTodayStr() { + Date currentTime = new Date(); + Calendar calendar = new GregorianCalendar(); + calendar.setTime(currentTime); + calendar.add(Calendar.DATE, -1); + currentTime = calendar.getTime(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMdd"); + String dateString = formatter.format(currentTime); + return dateString; + } + + + /** + * 获取现在时间 + * + * @return 返回时间类型 yyyy-MM-dd HH:mm:ss + */ + public static Date getNowDate() { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String dateString = formatter.format(currentTime); + ParsePosition pos = new ParsePosition(8); + return formatter.parse(dateString, pos); + } + + /** + * 获取现在时间 + * + * @return 返回字符串格式 yyyy-MM-dd HH:mm:ss + */ + public static String getStringDate() { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + return formatter.format(currentTime); + } + + /** + * 获取现在时间 + * + * @return 返回短时间字符串格式yyyy-MM-dd + */ + public static String getStringDateShort() { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd"); + return formatter.format(currentTime); + } + + /** + * 获取时间 小时:分;秒 HH:mm:ss + * + * @return 返回字符串格式 HH:mm:ss + */ + public static String getTimeShort() { + SimpleDateFormat formatter = new SimpleDateFormat("HH:mm:ss"); + Date currentTime = new Date(); + return formatter.format(currentTime); + } + + /** + * 将长时间格式字符串转换为时间 yyyy-MM-dd HH:mm:ss + * + * @param strDateTime strDateTime + * @return 长时间格式字符串转换为时间 yyyy-MM-dd HH:mm:ss + */ + public static Date strToDateTime(String strDateTime) { + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + ParsePosition pos = new ParsePosition(0); + return formatter.parse(strDateTime, pos); + } + + /** + * 将换长时间格式时间转为字符串 yyyy-MM-dd HH:mm:ss + * + * @param dateDate dateDate + * @return 换长时间格式时间转为字符串 yyyy-MM-dd HH:mm:ss + */ + public static String dateTimeToStr(Date dateDate) { + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + return formatter.format(dateDate); + } + + /** + * 将短时间格式时间转换为字符串 yyyy-MM-dd + * + * @param dateDate dateDate + * @return 短时间格式时间转换为字符串 yyyy-MM-dd + */ + public static String dateToStr(Date dateDate) { + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd"); + return formatter.format(dateDate); + } + + /** + * 将短时间格式字符串转换为时间 yyyy-MM-dd + * + * @param strDate strDate + * @return return + */ + public static Date strToDate(String strDate) { + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd"); + ParsePosition pos = new ParsePosition(0); + return formatter.parse(strDate, pos); + } + + /** + * 得到现在时间 + * + * @return return + */ + public static Date getNow() { + return new Date(); + } + + /** + * 提取一个月中的最后一天 + * + * @param day day + * @return 一个月中的最后一天 + */ + public static Date getLastDate(long day) { + Date date = new Date(); + long date_3_hm = date.getTime() - 3600000 * 34 * day; + return new Date(date_3_hm); + } + + /** + * 得到现在时间 + * + * @return 字符串 yyyyMMdd HHmmss + */ + public static String getStringToday() { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMdd HHmmss"); + return formatter.format(currentTime); + } + + /** + * 得到现在小时 + */ + public static String getHour() { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String dateString = formatter.format(currentTime); + String hour; + hour = dateString.substring(11, 13); + return hour; + } + + /** + * 得到现在分钟 + * + * @return return + */ + public static String getTime() { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String dateString = formatter.format(currentTime); + String min; + min = dateString.substring(14, 16); + return min; + } + + /** + * 根据用户传入的时间表示格式，返回当前时间的格式 如果是yyyyMMdd，注意字母y不能大写。 + * + * @param sformat yyyyMMddhhmmss + * @return return + */ + public static String getUserDate(String sformat) { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat(sformat); + return formatter.format(currentTime); + } + + public static Date getDateFromLocalDate(LocalDate localDate) { + ZoneId zone = ZoneId.systemDefault(); + Instant instant = localDate.atStartOfDay().atZone(zone).toInstant(); + return Date.from(instant); + } + + + /** + * 获取两个时间字符串的时间差 + * + * @param startTimeStr 开始时间 + * @param endTimeStr 结束时间 + * @return 时间差 (秒数) + */ + public static long getTimeCha(String startTimeStr, String endTimeStr) { + if (startTimeStr == null || startTimeStr.isEmpty()) { + return 0; + } + if (endTimeStr == null || endTimeStr.isEmpty()) { + return 0; + } + SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + long diffInMilliseconds = 0; + //long diffInMinutes = 0; + //long diffInHour = 0; + try { + Date startTime = format.parse(startTimeStr); + Date endTime = format.parse(endTimeStr); + diffInMilliseconds = endTime.getTime() - startTime.getTime(); + //diffInMinutes = TimeUnit.MILLISECONDS.toMinutes(diffInMilliseconds); + //diffInHour=TimeUnit.MILLISECONDS.toHours(diffInMilliseconds); + System.out.println("Time difference in minutes: " + diffInMilliseconds); + + } catch (Exception e) { + e.printStackTrace(); + } + return diffInMilliseconds; + } + + + /** + * 将日期字符串转化为星期 + * @param dateString 日期字符串 + * @return 星期 + */ + public static String getWeekDayStringByDateString(String dateString) { + if (dateString == null || dateString.isEmpty()) { + return null; + } + String weekDayString = ""; + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); + try { + Date date = dateFormat.parse(dateString); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(date); + int weekDay = calendar.get(Calendar.DAY_OF_WEEK); + switch (weekDay) { + case Calendar.SUNDAY: + weekDayString = "星期日"; + break; + case Calendar.MONDAY: + weekDayString = "星期一"; + break; + case Calendar.TUESDAY: + weekDayString = "星期二"; + break; + case Calendar.WEDNESDAY: + weekDayString = "星期三"; + break; + case Calendar.THURSDAY: + weekDayString = "星期四"; + break; + case Calendar.FRIDAY: + weekDayString = "星期五"; + break; + case Calendar.SATURDAY: + weekDayString = "星期六"; + break; + } + + } catch (Exception e) { + e.printStackTrace(); + } + return weekDayString; + } + + /** + * 将日期时间字符串转化为星期 + * @param dateTimeString 日期时间字符串 + * @return 星期 + */ + public static String getWeekDayStringByDateTimeString(String dateTimeString) { + if (dateTimeString == null || dateTimeString.isEmpty()) { + return ""; + } + //String dateTimeString = "2023-10-18 09:13:40"; + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String weekDayString = ""; + try { + Date dateTime = dateFormat.parse(dateTimeString); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(dateTime); + int weekDay = calendar.get(Calendar.DAY_OF_WEEK); + switch (weekDay) { + case Calendar.SUNDAY: + weekDayString = "星期日"; + break; + case Calendar.MONDAY: + weekDayString = "星期一"; + break; + case Calendar.TUESDAY: + weekDayString = "星期二"; + break; + case Calendar.WEDNESDAY: + weekDayString = "星期三"; + break; + case Calendar.THURSDAY: + weekDayString = "星期四"; + break; + case Calendar.FRIDAY: + weekDayString = "星期五"; + break; + case Calendar.SATURDAY: + weekDayString = "星期六"; + break; + } + System.out.println(weekDayString); + } catch (Exception e) { + e.printStackTrace(); + } + return weekDayString; + } + +} diff --git a/utils/src/main/java/com/haitongauto/utils/GetDateTime.java b/utils/src/main/java/com/haitongauto/utils/GetDateTime.java new file mode 100644 index 0000000..43c0cd8 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/GetDateTime.java @@ -0,0 +1,103 @@ +package com.haitongauto.utils; + +import org.springframework.stereotype.Component; + +import java.text.DateFormat; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.time.LocalDateTime; +import java.time.ZoneId; +import java.util.Calendar; +import java.util.Date; +import java.util.TimeZone; + +@Component +public class GetDateTime { + /** + * 生成当前日期 + * + * @return 当前日期 + */ + public static Date nowDate() { + LocalDateTime localDateTime = LocalDateTime.now(); + return Date.from(localDateTime.atZone(ZoneId.systemDefault()).toInstant()); + } + + /** + * 原始日期时间型格式转换为标准字符串型（yyyy-MM-dd HH:mm:ss） + * + * @param dateVal 原始日期时间 + * @return 标准字符串型数据 + */ + public static String getDateTimeToString(Date dateVal) { + //创建SimpleDateFormat对象，指定样式,如：2022-03-23 22:56:30 + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + //格式转换 + + return sdf.format(dateVal); + } + + /** + * 显示本系统当前时区 + * @param args args + */ + public static void getSystemTimeArea(String[] args) { + Calendar ca = Calendar.getInstance(); + TimeZone tz = ca.getTimeZone(); + System.out.println(tz.getID()); //现在显示为：GMT+08:00,为中国时间（东八区）时间，所以，数据库连接的时区需要修改为：serverTimezone=Asia/Shanghai或者serverTimezone=GMT%2B8 + } + + /** + * 将日期转换为星期 + */ + public static String dateToWeek(String datetime) throws ParseException { + String[] weekDays = {"星期日", "星期一", "星期二", "星期三", "星期四", "星期五", "星期六"}; + Date date = new SimpleDateFormat("yyyy-MM-dd").parse(datetime); + Calendar cal = Calendar.getInstance(); + cal.setTime(date); + int w = Math.max(cal.get(Calendar.DAY_OF_WEEK) - 1, 0); + return weekDays[w]; + } + + /** + * 日期加减天数获得新日期 + * @date 原始日期 + * @n 增减天数，减为负数 */ + public static Date getNewDate(Date date,int n){ + //定义日期时间格式 + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + + Calendar calstart = Calendar.getInstance(); + + calstart.setTime(date);//放入所要修改的日期 + + calstart.add(Calendar.DAY_OF_WEEK, n);//进行加减运算 + + System.out.println(sdf.format(calstart.getTime())); + + return calstart.getTime(); + } + + /** + * 计算两个日期相差的天数 + * @param date1 较小的日期 + * @param date2 较大的日期 + */ + public static Integer getDaysForTwoDate(Date date1, Date date2){ + DateFormat df = new SimpleDateFormat("yyyy-MM-dd"); + int x =0; + try { + Date star = df.parse(df.format(date1));//开始时间 + Date endDay = df.parse(df.format(date2));//结束时间 + Long starTime=star.getTime(); + Long endTime=endDay.getTime(); + Long num=endTime-starTime;//时间戳相差的毫秒数 + //计算为天数 + x =(int)(num/(24*60*60*1000)); + System.out.println("相差天数为："+ x); + } catch (ParseException e) { + e.printStackTrace(); + } + return x; + } +} diff --git a/utils/src/main/java/com/haitongauto/utils/HtmlToPdfUtils.java b/utils/src/main/java/com/haitongauto/utils/HtmlToPdfUtils.java new file mode 100644 index 0000000..37b6ed4 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/HtmlToPdfUtils.java @@ -0,0 +1,183 @@ +package com.haitongauto.utils; + +import com.itextpdf.html2pdf.ConverterProperties; +import com.itextpdf.html2pdf.HtmlConverter; +import com.itextpdf.io.source.ByteArrayOutputStream; +import com.itextpdf.kernel.events.PdfDocumentEvent; +import com.itextpdf.kernel.font.PdfFont; + +import com.itextpdf.kernel.font.PdfFontFactory; +import com.itextpdf.kernel.geom.PageSize; +import com.itextpdf.kernel.pdf.PdfDocument; +import com.itextpdf.kernel.pdf.PdfWriter; +import com.itextpdf.layout.font.FontProvider; +//import io.micrometer.common.util.StringUtils; +import lombok.extern.slf4j.Slf4j; + +import java.io.*; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +/** + * Itext7转换工具类 + */ +@Slf4j +public class HtmlToPdfUtils { + + + /** + * html文件转化为 pdf文件 + * @param htmlFile html文件所在相对路径 如 "C:/Users/lenovo/Desktop/teee/myTest.html"; + * @param pdfFile pdf文件存储相对路径 如 "C:/Users/lenovo/Desktop/teee/x6.pdf"; + * @param waterMarkText 自定义水印 + */ + public static void htmlToPdf(String htmlFile,String pdfFile,String waterMarkText) { + if (htmlFile.isEmpty()||pdfFile.isEmpty()) + { + log.error("错误信息：{html文件所在相对路径不能为空，且pdf文件存储相对路径不能为空}"); + return; + } + + if (waterMarkText==null){ + waterMarkText = ""; + } + long startTime = System.currentTimeMillis(); + InputStream inputStream = null; + try { + inputStream = new FileInputStream(htmlFile); + } catch (FileNotFoundException e) { + throw new RuntimeException(e); + } + OutputStream outputStream = null; + try { + outputStream = new FileOutputStream(pdfFile); + } catch (FileNotFoundException e) { + throw new RuntimeException(e); + } + //微软雅黑在windows系统里的位置如下，linux系统直接拷贝该文件放在linux目录下即可 + // String fontPath = "src/main/resources/font/STHeiti Light.ttc,0"; + String fontPath = "src/main/resources/font/simsun.ttc,0"; + HtmlToPdfUtils.convertToPdf(inputStream, waterMarkText, fontPath, outputStream); + } + + + + /** + * html转pdf + * + * @param inputStream 输入流 + * @param waterMark 水印 + * @param fontPath 字体路径，ttc后缀的字体需要添加,0 + * @param outputStream 输出流 + * @date : 2021/1/15 14:07 + */ + public static void convertToPdf(InputStream inputStream, String waterMark, String fontPath, OutputStream outputStream) { + PdfWriter pdfWriter = new PdfWriter(outputStream); + PdfDocument pdfDocument = new PdfDocument(pdfWriter); + //设置为A4大小 + pdfDocument.setDefaultPageSize(PageSize.A4); + //添加水印 + pdfDocument.addEventHandler(PdfDocumentEvent.END_PAGE, new WaterMarkEventHandler(waterMark)); + + //添加中文字体支持 + ConverterProperties properties = new ConverterProperties(); + FontProvider fontProvider = new FontProvider(); + + + // 设置字体 + PdfFont sysFont = null; + try { + sysFont = PdfFontFactory.createFont("STSongStd-Light", "UniGB-UCS2-H", false); + } catch (IOException e) { + throw new RuntimeException(e); + } + fontProvider.addFont(sysFont.getFontProgram(), "UniGB-UCS2-H"); + + //添加自定义字体，例如微软雅黑 +// if (StringUtils.isNotBlank(fontPath)) { +// PdfFont microsoft = PdfFontFactory.createFont(fontPath, PdfEncodings.IDENTITY_H, false); +// fontProvider.addFont(microsoft.getFontProgram(), PdfEncodings.IDENTITY_H); +// } + + properties.setFontProvider(fontProvider); + // 读取Html文件流，查找出当中的 或出现类似的符号空格字符 + inputStream = readInputStrem(inputStream); + if (inputStream != null) { + // 生成pdf文档 + try { + HtmlConverter.convertToPdf(inputStream, pdfDocument, properties); + } catch (IOException e) { + throw new RuntimeException(e); + } + try { + pdfWriter.close(); + } catch (IOException e) { + throw new RuntimeException(e); + } + pdfDocument.close(); + return; + } else { + log.error("转换失败！"); + } + } + + /** + * 读取HTML 流文件，并查询当中的 或类似符号直接替换为空格 + * + * @param inputStream + * @return + */ + private static InputStream readInputStrem(InputStream inputStream) { + // 定义一些特殊字符的正则表达式 如： + String regEx_special = "\\&[a-zA-Z]{1,10};"; + try { + //<1>创建字节数组输出流，用来输出读取到的内容 + ByteArrayOutputStream baos = new ByteArrayOutputStream(); + //<2>创建缓存大小 + byte[] buffer = new byte[1024]; // 1KB + //每次读取到内容的长度 + int len = -1; + //<3>开始读取输入流中的内容 + while ((len = inputStream.read(buffer)) != -1) { //当等于-1说明没有数据可以读取了 + baos.write(buffer, 0, len); //把读取到的内容写到输出流中 + } + //<4> 把字节数组转换为字符串 + String content = baos.toString(); + //<5>关闭输入流和输出流 + // inputStream.close(); + baos.close(); + // log.info("读取的内容：{}", content); + // 判断HTML内容是否具有HTML的特殊字符标记 + Pattern compile = Pattern.compile(regEx_special, Pattern.CASE_INSENSITIVE); + Matcher matcher = compile.matcher(content); + String replaceAll = matcher.replaceAll(""); + // log.info("替换后的内容：{}", replaceAll); + // 将字符串转化为输入流返回 + InputStream stringStream = getStringStream(replaceAll); + //<6>返回结果 + return stringStream; + } catch (Exception e) { + e.printStackTrace(); + log.error("错误信息：{}", e.getMessage()); + return null; + } + } + + /** + * 将一个字符串转化为输入流 + * @param sInputString 字符串 + * @return + */ + public static InputStream getStringStream(String sInputString) { + if (sInputString != null && !sInputString.trim().equals("")) { + try { + ByteArrayInputStream tInputStringStream = new ByteArrayInputStream(sInputString.getBytes()); + return tInputStringStream; + } catch (Exception e) { + e.printStackTrace(); + } + } + return null; + } + +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/HttpClientHelper.java b/utils/src/main/java/com/haitongauto/utils/HttpClientHelper.java new file mode 100644 index 0000000..45afdee --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/HttpClientHelper.java @@ -0,0 +1,145 @@ +package com.haitongauto.utils; + +import com.google.gson.Gson; +import org.apache.http.HttpEntity; +import org.apache.http.HttpResponse; +import org.apache.http.client.HttpClient; +import org.apache.http.client.methods.HttpPost; +import org.apache.http.entity.StringEntity; +import org.apache.http.impl.client.HttpClientBuilder; +import org.apache.http.util.EntityUtils; + +import java.io.*; +import java.net.HttpURLConnection; +import java.net.URL; +import java.nio.charset.StandardCharsets; + +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; + +public class HttpClientHelper { + private static final Logger logger = LogManager.getLogger(HttpClientHelper.class); + + public static String forwardSend(T entity, String myUrl) throws CloneNotSupportedException { + String result; + HttpClient httpClient = null; + HttpPost httpPost = null; + HttpResponse response = null; + HttpEntity resEntity = null; + try { + // 创建实体对象，例如： + //Student student = new Student("John", 20); + // 创建HttpClient实例 + httpClient = HttpClientBuilder.create().build(); + // 创建HttpPost实例 + //String url = "http://example.com/api/students"; + String url = myUrl; + httpPost = new HttpPost(url); + // 设置请求头 + httpPost.setHeader("Content-Type", "application/json"); + // 将Student对象转换为JSON字符串 + // String json = "{\"name\": \"" + student.getName() + "\", \"age\": " + student.getAge() + "}"; + //String json = JSON.toJSONString(entity, SerializerFeature.WriteMapNullValue); + String json = new Gson().toJson(entity); + + // 设置请求体 + httpPost.setEntity(new StringEntity(json)); + + // 发送请求 + response = httpClient.execute(httpPost); + // 获取响应实体 + resEntity = response.getEntity(); + // 判断响应状态 + if (response.getStatusLine().getStatusCode() == 200) { + // 读取响应内容 + String responseBody = EntityUtils.toString(resEntity); + result = responseBody; + } else { + result = ""; + } + } catch (Exception ex) { + result = ""; + } finally { + httpPost.clone(); + } + return result; + } + + public static String forwardSendNew(T entity, String myUrl) { + StringBuilder result = new StringBuilder(); + HttpURLConnection connection = null; + InputStream inputStream = null; + try { + URL url = new URL(myUrl); + connection = (HttpURLConnection) url.openConnection(); + //请求方式是POST + connection.setRequestMethod("POST"); + // Post 请求不能使用缓存 + // connection.setUseCaches(false); + // http正文内，因此需要设为true(不设置会要了你的老命) + connection.setDoOutput(Boolean.TRUE); + connection.setDoInput(Boolean.TRUE); + //设置连接超时时间 + connection.setConnectTimeout(10000); + //设置读取超时时间 + connection.setReadTimeout(15000); + //必须设置false，否则会自动redirect到重定向后的地址 + connection.setInstanceFollowRedirects(false); + // 设置通用的请求属性 + connection.setRequestProperty("accept", "*/*"); + connection.setRequestProperty("connection", "Keep-Alive"); + connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + connection.setRequestProperty("Content-Type", "application/json"); + connection.setRequestProperty("Accept-Encoding", "gzip, deflate, br"); + + // 创建要发送的实体 Student 对象，并将其转换为 JSON 字符串 + //String jsonBody = JSON.toJSONString(entity, SerializerFeature.WriteMapNullValue); + String jsonBody = new Gson().toJson(entity); + // 设置请求头部的 Content-Length 属性 + int contentLength = jsonBody.getBytes(StandardCharsets.UTF_8).length; + connection.setRequestProperty("Content-Length", String.valueOf(4096)); + + // 获取输出流，并将 JSON 字符串写入连接 + OutputStream outputStream = connection.getOutputStream(); + outputStream.write(jsonBody.getBytes(StandardCharsets.UTF_8)); + // outputStream.write(jsonBody.getBytes()); + outputStream.flush(); + outputStream.close(); + // int responseCode = connection.getResponseCode(); +// if (responseCode == HttpURLConnection.HTTP_OK) { +// inputStream = connection.getInputStream(); +// // 处理输入流的内容 +// // 定义 BufferedReader输入流来读取URL的响应 +// BufferedReader in = new BufferedReader(new InputStreamReader(inputStream)); +// String line; +// while ((line = in.readLine()) != null) { +// result.append(line); +// } +// inputStream.close(); +// } else { +// // 处理错误情况 +// } + + inputStream = connection.getInputStream(); + // 处理输入流的内容 + // 定义 BufferedReader输入流来读取URL的响应 + BufferedReader in = new BufferedReader(new InputStreamReader(inputStream)); + String line; + while ((line = in.readLine()) != null) { + result.append(line); + } + inputStream.close(); + + + } catch (Exception ex) { + System.out.println("错误：" + ex.getMessage()); + result.append(ex.getMessage()); + return result.toString(); + } finally { + // 关闭流和连接 + connection.disconnect(); + } + + return result.toString(); + } +} diff --git a/utils/src/main/java/com/haitongauto/utils/HttpRequest.java b/utils/src/main/java/com/haitongauto/utils/HttpRequest.java new file mode 100644 index 0000000..bcfc6b0 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/HttpRequest.java @@ -0,0 +1,253 @@ +package com.haitongauto.utils; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.io.PrintWriter; +import java.net.URL; +import java.net.URLConnection; +import java.util.List; +import java.util.Map; + +public class HttpRequest { + + /** + * 向指定URL发送GET方法的请求 + * + * @param access_token 权限请求头 必须项 + * @param url 发送请求的URL + * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。 + * @return URL 所代表远程资源的响应结果 + */ + public static String sendGet(String access_token, String url, String param) { + StringBuilder result = new StringBuilder(); + BufferedReader in = null; + try { + String urlNameString = url + "?" + param; + URL realUrl = new URL(urlNameString); + // 打开和URL之间的连接 + URLConnection connection = realUrl.openConnection(); + // 设置通用的请求属性 + connection.setRequestProperty("accept", "*/*"); + connection.setRequestProperty("connection", "Keep-Alive"); + connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + + //设置权限请求头 access_token 必须项 + if (access_token != null && !access_token.equals("")) { + String myToken = "Bearer " + access_token; + connection.setRequestProperty("authorization", myToken); + } + //设置连接超时时间 + connection.setConnectTimeout(10000); + //设置读取超时时间 + connection.setReadTimeout(10000); + // 建立实际的连接 + connection.connect(); + // 获取所有响应头字段 + Map> map = connection.getHeaderFields(); + // 遍历所有的响应头字段 + for (String key : map.keySet()) { + System.out.println(key + "--->" + map.get(key)); + } + // 定义 BufferedReader输入流来读取URL的响应 + in = new BufferedReader(new InputStreamReader( + connection.getInputStream())); + String line; + while ((line = in.readLine()) != null) { + result.append(line); + } + } catch (Exception e) { + System.out.println("发送GET请求出现异常！" + e); + e.printStackTrace(); + } + // 使用finally块来关闭输入流 + finally { + try { + if (in != null) { + in.close(); + } + } catch (Exception e2) { + e2.printStackTrace(); + } + } + return result.toString(); + } + + + /** + * 向指定URL发送GET方法的请求 + * + * @param url 发送请求的URL + * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。 + * @return URL 所代表远程资源的响应结果 + */ + public static String sendGet(String url, String param) { + StringBuilder result = new StringBuilder(); + BufferedReader in = null; + try { + String urlNameString = url + "?" + param; + URL realUrl = new URL(urlNameString); + // 打开和URL之间的连接 + URLConnection connection = realUrl.openConnection(); + // 设置通用的请求属性 + connection.setRequestProperty("accept", "*/*"); + connection.setRequestProperty("connection", "Keep-Alive"); + connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + + //设置连接超时时间 + connection.setConnectTimeout(10000); + //设置读取超时时间 + connection.setReadTimeout(10000); + // 建立实际的连接 + connection.connect(); + // 获取所有响应头字段 + Map> map = connection.getHeaderFields(); + // 遍历所有的响应头字段 + for (String key : map.keySet()) { + System.out.println(key + "--->" + map.get(key)); + } + // 定义 BufferedReader输入流来读取URL的响应 + in = new BufferedReader(new InputStreamReader( + connection.getInputStream())); + String line; + while ((line = in.readLine()) != null) { + result.append(line); + } + } catch (Exception e) { + System.out.println("发送GET请求出现异常！" + e); + e.printStackTrace(); + } + // 使用finally块来关闭输入流 + finally { + try { + if (in != null) { + in.close(); + } + } catch (Exception e2) { + e2.printStackTrace(); + } + } + return result.toString(); + } + + /** + * 向指定 URL 发送POST方法的请求 + * + * @param url 发送请求的 URL + * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。 + * @return 所代表远程资源的响应结果 + */ + public static String sendPost(String access_token, String url, String param) { + PrintWriter out = null; + BufferedReader in = null; + StringBuilder result = new StringBuilder(); + try { + URL realUrl = new URL(url); + // 打开和URL之间的连接 + URLConnection conn = realUrl.openConnection(); + // 设置通用的请求属性 + conn.setRequestProperty("accept", "*/*"); + conn.setRequestProperty("connection", "Keep-Alive"); + conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + //设置权限请求头 access_token 必须项 + if (access_token != null && !access_token.equals("")) { + String myToken = "Bearer " + access_token; + conn.setRequestProperty("authorization", myToken); + } + //设置连接超时时间 + conn.setConnectTimeout(15000); + //设置读取超时时间 + conn.setReadTimeout(15000); + // 发送POST请求必须设置如下两行 + conn.setDoOutput(true); + conn.setDoInput(true); + // 获取URLConnection对象对应的输出流 + out = new PrintWriter(conn.getOutputStream()); + // 发送请求参数 + out.print(param); + // flush输出流的缓冲 + out.flush(); + // 定义BufferedReader输入流来读取URL的响应 + in = new BufferedReader(new InputStreamReader(conn.getInputStream())); + String line; + while ((line = in.readLine()) != null) { + result.append(line); + } + } catch (Exception e) { + System.out.println("发送 POST 请求出现异常！" + e); + e.printStackTrace(); + } + //使用finally块来关闭输出流、输入流 + finally { + try { + if (out != null) { + out.close(); + } + if (in != null) { + in.close(); + } + } catch (IOException ex) { + ex.printStackTrace(); + } + } + return result.toString(); + } + + /** + * 向指定 URL 发送POST方法的请求 + * + * @param url 发送请求的 URL + * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。 + * @return 所代表远程资源的响应结果 + */ + public static String sendPost(String url, String param) { + PrintWriter out = null; + BufferedReader in = null; + StringBuilder result = new StringBuilder(); + try { + URL realUrl = new URL(url); + // 打开和URL之间的连接 + URLConnection conn = realUrl.openConnection(); + // 设置通用的请求属性 + conn.setRequestProperty("accept", "*/*"); + conn.setRequestProperty("connection", "Keep-Alive"); + conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); + //设置连接超时时间 + conn.setConnectTimeout(15000); + //设置读取超时时间 + conn.setReadTimeout(15000); + // 发送POST请求必须设置如下两行 + conn.setDoOutput(true); + conn.setDoInput(true); + // 获取URLConnection对象对应的输出流 + out = new PrintWriter(conn.getOutputStream()); + // 发送请求参数 + out.print(param); + // flush输出流的缓冲 + out.flush(); + // 定义BufferedReader输入流来读取URL的响应 + in = new BufferedReader(new InputStreamReader(conn.getInputStream())); + String line; + while ((line = in.readLine()) != null) { + result.append(line); + } + } catch (Exception e) { + System.out.println("发送 POST 请求出现异常！" + e); + e.printStackTrace(); + } + //使用finally块来关闭输出流、输入流 + finally { + try { + if (out != null) { + out.close(); + } + if (in != null) { + in.close(); + } + } catch (IOException ex) { + ex.printStackTrace(); + } + } + return result.toString(); + } +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/HttpTemplate.java b/utils/src/main/java/com/haitongauto/utils/HttpTemplate.java new file mode 100644 index 0000000..634989e --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/HttpTemplate.java @@ -0,0 +1,236 @@ +package com.haitongauto.utils; + +import org.springframework.lang.Nullable; + +import java.io.*; +import java.net.HttpURLConnection; +import java.net.MalformedURLException; +import java.net.URL; +import java.nio.charset.StandardCharsets; + +/** + * 文件名： ${file_name} + * 版权： Copyright by wsnet + * 描述： + * 修改人： kch + * 修改时间：2023/6/13 + * 跟踪单号： + * 修改单号： + * 修改内容： + */ + +public class HttpTemplate { + /** + * http get请求 + * + * @param httpUrl 链接 + * @return 响应数据 + */ + public static String doGet(String httpUrl) { + //链接 + HttpURLConnection connection = null; + InputStream is = null; + BufferedReader br = null; + StringBuilder result = new StringBuilder(); + try { + //创建连接 + URL url = new URL(httpUrl); + connection = (HttpURLConnection) url.openConnection(); + //设置请求方式 + connection.setRequestMethod("GET"); + //设置连接超时时间 + connection.setConnectTimeout(10000); + //设置读取超时时间 + connection.setReadTimeout(15000); + //开始连接 + connection.connect(); + //获取响应数据 + if (connection.getResponseCode() == 200) { + //获取返回的数据 + is = connection.getInputStream(); + if (is != null) { + br = new BufferedReader(new InputStreamReader(is, "UTF-8")); + String temp = null; + while ((temp = br.readLine()) != null) { + result.append(temp); + } + } + } + } catch (IOException e) { + e.printStackTrace(); + } finally { + if (br != null) { + try { + br.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + if (is != null) { + try { + is.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + assert connection != null; + connection.disconnect();// 关闭远程连接 + } + return result.toString(); + } + + /** + * post请求 + * + * @param httpUrl 链接 + * @param param 参数 + * @return 返回请求结果 + */ + public static String doPost(String httpUrl, @Nullable String param) { + StringBuilder result = new StringBuilder(); + //连接 + HttpURLConnection connection = null; + OutputStream os = null; + InputStream is = null; + BufferedReader br = null; + try { + //创建连接对象 + URL url = new URL(httpUrl); + //创建连接 + connection = (HttpURLConnection) url.openConnection(); + //设置请求方法 + connection.setRequestMethod("POST"); + //设置连接超时时间 + connection.setConnectTimeout(15000); + //设置读取超时时间 + connection.setReadTimeout(15000); + //设置是否可读取 + connection.setDoOutput(true); + //设置响应是否可读取 + connection.setDoInput(true); + //设置参数类型 + connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); + //拼装参数 + if (param != null && !param.equals("")) { + //设置参数 + os = connection.getOutputStream(); + //拼装参数 + os.write(param.getBytes(StandardCharsets.UTF_8)); + } + //设置权限 + //设置请求头等 + //开启连接 + //connection.connect(); + //读取响应 + if (connection.getResponseCode() == 200) { + is = connection.getInputStream(); + if (is != null) { + br = new BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8)); + String temp = null; + if ((temp = br.readLine()) != null) { + result.append(temp); + } + } + } + //关闭连接 + } catch (IOException e) { + e.printStackTrace(); + } finally { + if (br != null) { + try { + br.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + if (os != null) { + try { + os.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + if (is != null) { + try { + is.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + //关闭连接 + assert connection != null; + connection.disconnect(); + } + return result.toString(); + } + + /** + * http get请求 + * + * @param httpUrl 链接 + * @return 响应数据 + */ + public static String doPicUpload(String httpUrl) { + //链接 + HttpURLConnection connection = null; + InputStream is = null; + BufferedReader br = null; + StringBuilder result = new StringBuilder(); + try { + //创建连接 + URL url = new URL(httpUrl); + connection = (HttpURLConnection) url.openConnection(); + //设置请求方式 + connection.setRequestMethod("GET"); + //设置连接超时时间 + connection.setConnectTimeout(10000); + //设置读取超时时间 + connection.setReadTimeout(15000); + +// DataInputStream in = new DataInputStream(new FileInputStream(file)); +// int bytes = 0; +// byte[] bufferOut = new byte[2048]; +// while ((bytes = in.read(bufferOut)) != -1) { +// out.write(bufferOut, 0, bytes); +// } + //in.close(); + + + //开始连接 + connection.connect(); + //获取响应数据 + if (connection.getResponseCode() == 200) { + //获取返回的数据 + is = connection.getInputStream(); + if (is != null) { + br = new BufferedReader(new InputStreamReader(is, "UTF-8")); + String temp = null; + while ((temp = br.readLine()) != null) { + result.append(temp); + } + } + } + } catch (IOException e) { + e.printStackTrace(); + } finally { + if (br != null) { + try { + br.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + if (is != null) { + try { + is.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + assert connection != null; + connection.disconnect();// 关闭远程连接 + } + return result.toString(); + } + +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/IpHelper.java b/utils/src/main/java/com/haitongauto/utils/IpHelper.java new file mode 100644 index 0000000..8010f91 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/IpHelper.java @@ -0,0 +1,49 @@ +package com.haitongauto.utils; + +import javax.servlet.http.HttpServletRequest; +import java.net.InetAddress; +import java.net.UnknownHostException; + +/** + * @author G1F + * @date 2019/12/23 9:02 + * @description 获取请求真实IP + */ +public class IpHelper { + // + public static String getIpAddr(HttpServletRequest request) { + String ipAddress = null; + try { + ipAddress = request.getHeader("x-forwarded-for"); + if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) { + ipAddress = request.getHeader("Proxy-Client-IP"); + } + if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) { + ipAddress = request.getHeader("WL-Proxy-Client-IP"); + } + if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) { + ipAddress = request.getRemoteAddr(); + if (ipAddress.equals("127.0.0.1")) { + // 根据网卡取本机配置的IP + InetAddress inet = null; + try { + inet = InetAddress.getLocalHost(); + } catch (UnknownHostException e) { + e.printStackTrace(); + } + assert inet != null; + ipAddress = inet.getHostAddress(); + } + } + // 对于通过多个代理的情况，第一个IP为客户端真实IP，多个IP按照','分割 + if (ipAddress != null && ipAddress.length() > 15) { // "***.***.***.***".length() + if (ipAddress.indexOf(",") > 0) { + ipAddress = ipAddress.substring(0, ipAddress.indexOf(",")); + } + } + } catch (Exception e) { + ipAddress = ""; + } + return ipAddress; + } +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/PageEventHandler.java b/utils/src/main/java/com/haitongauto/utils/PageEventHandler.java new file mode 100644 index 0000000..c4fac03 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/PageEventHandler.java @@ -0,0 +1,49 @@ +package com.haitongauto.utils; + +import com.itextpdf.kernel.events.Event; +import com.itextpdf.kernel.events.IEventHandler; +import com.itextpdf.kernel.events.PdfDocumentEvent; +import com.itextpdf.kernel.font.PdfFont; +import com.itextpdf.kernel.font.PdfFontFactory; +import com.itextpdf.kernel.geom.Rectangle; +import com.itextpdf.kernel.pdf.PdfDocument; +import com.itextpdf.kernel.pdf.PdfPage; +import com.itextpdf.kernel.pdf.canvas.PdfCanvas; +import com.itextpdf.layout.Canvas; +import com.itextpdf.layout.element.Paragraph; +import com.itextpdf.layout.property.TextAlignment; +import org.springframework.stereotype.Component; + +import java.io.IOException; + +/** + * 页码 + */ +@Component +public class PageEventHandler implements IEventHandler { + + @Override + public void handleEvent(Event event) { + PdfDocumentEvent documentEvent = (PdfDocumentEvent) event; + PdfDocument document = documentEvent.getDocument(); + PdfPage page = documentEvent.getPage(); + Rectangle pageSize = page.getPageSize(); + + PdfFont pdfFont = null; + try { + pdfFont = PdfFontFactory.createFont("STSongStd-Light", "UniGB-UCS2-H", false); + } catch (IOException e) { + e.printStackTrace(); + } + + PdfCanvas pdfCanvas = new PdfCanvas(page.getLastContentStream(), page.getResources(), document); + Canvas canvas = new Canvas(pdfCanvas, pageSize); + float x = (pageSize.getLeft() + pageSize.getRight()) / 2; + float y = pageSize.getBottom() + 15; + Paragraph paragraph = new Paragraph("第" + document.getPageNumber(page) + "页/共" + document.getNumberOfPages() + "页") + .setFontSize(10) + .setFont(pdfFont); + canvas.showTextAligned(paragraph, x, y, TextAlignment.CENTER); + canvas.close(); + } +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/PdfUtils.java b/utils/src/main/java/com/haitongauto/utils/PdfUtils.java new file mode 100644 index 0000000..513768e --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/PdfUtils.java @@ -0,0 +1,119 @@ +package com.haitongauto.utils; + +//import com.itextpdf.text.*; +//import com.itextpdf.text.pdf.*; +//import org.apache.commons.io.FileUtils; +//import org.apache.commons.io.IOUtils; +//import org.apache.commons.lang3.StringUtils; +//import org.apache.tomcat.util.http.fileupload.FileUtils; +//import org.apache.tomcat.util.http.fileupload.IOUtils; +//import org.junit.Test; +//import pojo.user; +//import java.io.*; +//import java.util.*; +public class PdfUtils { +// /** +// * @param map 需要填充的字段 +// * @param sourceFile 原文件路径 +// * @param targetFile 目标文件路径 +// * @param imgURLMap 填充图片路径 +// * @throws IOException +// */ +// public static void genPdf(Map map, String sourceFile, String targetFile) throws IOException { +// File templateFile = new File(sourceFile); +// fillParam(map, FileUtils.readFileToByteArray(templateFile), targetFile); +// } +// +// /** +// *使用map中的参数填充pdf，map中的key和pdf表单中的field对应 +// * @param fieldValueMap +// * @param file +// * @param contractFileName +// * @param imgURLMap //这边暂时吧图片给注释了，如需填充图片直接加参数即可 +// */ +// public static void fillParam(Map fieldValueMap,byte[] file, String contractFileName) { +// //输出流 +// FileOutputStream fos = null; +// try { +// fos = new FileOutputStream(contractFileName); +// //获取PdfReader对象,获取模板位置 +// PdfReader reader = null; +// /* 将要生成的目标PDF文件名称 */ +// PdfStamper stamper = null; +// BaseFont base = null; +// //取出模板中的所有字段 +// AcroFields acroFields = null; +// // 获取存在resources目录下的pdf模板位置 URL +// //URL file = PdfUtils.class.getClassLoader().getResource("CONTRACT.pdf"); +// try { +// reader = new PdfReader(file); +// stamper = new PdfStamper(reader, fos); +// stamper.setFormFlattening(true); +// //简体中文字体 +// base = BaseFont.createFont("STSong-Light", "UniGB-UCS2-H", BaseFont.NOT_EMBEDDED); +// acroFields = stamper.getAcroFields(); +// +// //如果图片放在resources目录下需要这么写 +// // String imgUrl = new ClassPathResource("static/IMG_5809.JPG").getURL().getPath(); +// //循环添加公章图片 +// //for(String key : imgURLMap.keySet()) { +// // String value = imgURLMap.get(key).toString(); +// // //获取图片域名 +// // AcroFields.FieldPosition position = acroFields.getFieldPositions(key).get(0); +// // //通过域名获取所在页和坐标，左下角为起点 +// // int pageNo = position.page; +// // Rectangle signRect = position.position; +// // float x = signRect.getLeft(); +// // float y = signRect.getBottom(); +// // //读图片 +// // Image image = Image.getInstance(value); +// // //获取操作页面 +// // PdfContentByte under = stamper.getOverContent(pageNo); +// // //根据域的大小缩放图片 +// // image.scaleToFit(signRect.getWidth(),signRect.getHeight()); +// // //添加图片 +// // image.setAbsolutePosition(x,y); +// // under.addImage(image); +// // System.out.println("--"+key+"---"+value); +// //} +// for (String key : acroFields.getFields().keySet()) { +// acroFields.setFieldProperty(key, "textfont", base, null); +// //字体大小 +// acroFields.setFieldProperty(key, "textsize", new Float(12), null); +// } +// if (fieldValueMap != null) { +// for (String fieldName : fieldValueMap.keySet()) { +// +// if (StringUtils.isNotBlank(fieldValueMap.get(fieldName))) { +// //获取map中key对应的Value是否为On，若是则勾选复选框 +// if (fieldValueMap.get(fieldName).equals("On") || fieldValueMap.get(fieldName) == "On") { +// acroFields.setField(fieldName, fieldValueMap.get(fieldName),"true"); +// }else{ +// acroFields.setField(fieldName, fieldValueMap.get(fieldName)); +// } +// } +// } +// } +// } catch (Exception e) { +// e.printStackTrace(); +// } finally { +// if (stamper != null) { +// try { +// stamper.close(); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } +// if (reader != null) { +// reader.close(); +// } +// } +// +// } catch (Exception e) { +// System.out.println("填充参数异常"); +// e.printStackTrace(); +// } finally { +// IOUtils.closeQuietly(fos); +// } +// } +} diff --git a/utils/src/main/java/com/haitongauto/utils/PostFiles.java b/utils/src/main/java/com/haitongauto/utils/PostFiles.java new file mode 100644 index 0000000..6cde763 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/PostFiles.java @@ -0,0 +1,47 @@ +package com.haitongauto.utils; + +public class PostFiles { + +// public static void saveFile( MultipartFile filecontent){ +// OutputStream os = null; +// InputStream inputStream = null; +// String fileName = null; +// try { +// inputStream = filecontent.getInputStream(); +// fileName = fileconteXKfIbmTzZDnt.getOriginalFilename(); +// //fileName = fileconteXKfIbmTzZDnt.getOriginalFilename(); +// } catch (IOException e) { +// e.printStackTrace(); +// } +// try { +// String path = "C:\\test\\"; +// // 2、保存到临时文件 +// // 1K的数据缓冲 +// byte[] bs = new byte[1024]; +// // 读取到的数据长度 +// int len; +// // 输出的文件流保存到本地文件 +// File tempFile = new File(path); +// if (!tempFile.exists()) { +// tempFile.mkdirs(); +// } +// os = new FileOutputStream(tempFile.getPath() + File.separator + fileName); +// // 开始读取 +// while ((len = inputStream.read(bs)) != -1) { +// os.write(bs, 0, len); +// } +// } catch (IOException e) { +// e.printStackTrace(); +// } catch (Exception e) { +// e.printStackTrace(); +// } finally { +// // 完毕，关闭所有链接 +// try { +// os.close(); +// inputStream.close(); +// } catch (IOException e) { +// e.printStackTrace(); +// } +// } +// } +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/QueueNumberHelper.java b/utils/src/main/java/com/haitongauto/utils/QueueNumberHelper.java new file mode 100644 index 0000000..c4f2540 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/QueueNumberHelper.java @@ -0,0 +1,51 @@ +package com.haitongauto.utils; + +import java.text.SimpleDateFormat; +import java.util.Date; + +/** + * 排队号帮助类 + */ +public class QueueNumberHelper { + + /** + * 获得新排队号 + * @param lastQueueNumber 前排队号 + * @return 返回排队号 + */ + public static String getNewQueueNumber(String lastQueueNumber) { + String queueNumber = ""; + if (lastQueueNumber == null || lastQueueNumber.length() < 10) { + queueNumber = getTodayStr() + "0001"; + return queueNumber; + } + String lastDateStr = lastQueueNumber.substring(0, 6); + String todayStr = getTodayStr(); + //同一天 + if (lastDateStr.equals(todayStr)) { + try { + long res = Long.parseLong(lastQueueNumber); + res = res + 1; + queueNumber = Long.toString(res); + } catch (Exception ignored) { + } + + } else { + //日期转钟的处理 + queueNumber = getTodayStr() + "0001"; + } + return queueNumber; + } + + + /** + * 获取今天文件夹日期 + * + * @return 返回时间类型 yyyyMMdd + */ + private static String getTodayStr() { + Date currentTime = new Date(); + SimpleDateFormat formatter = new SimpleDateFormat("yyMMdd"); + return formatter.format(currentTime); + } +} diff --git a/utils/src/main/java/com/haitongauto/utils/StringHelper.java b/utils/src/main/java/com/haitongauto/utils/StringHelper.java new file mode 100644 index 0000000..3ed194a --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/StringHelper.java @@ -0,0 +1,21 @@ +package com.haitongauto.utils; + +public class StringHelper { + /** + * htmlStr 转化位纯文本 + * @param htmlStr htmlStr + * @return txt + */ + public static String getTxtByHtml(String htmlStr) { + do { + int a = htmlStr.indexOf("<"); + int b = htmlStr.indexOf(">"); + if (a != -1 && b != -1) { + htmlStr = htmlStr.substring(0, a) + htmlStr.substring(b + 1); + } + } while (htmlStr.indexOf("<") != -1 && htmlStr.indexOf(">") != -1); + + return htmlStr; + } + +} diff --git a/utils/src/main/java/com/haitongauto/utils/WaterMarkEventHandler.java b/utils/src/main/java/com/haitongauto/utils/WaterMarkEventHandler.java new file mode 100644 index 0000000..7b41bbf --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/WaterMarkEventHandler.java @@ -0,0 +1,84 @@ +package com.haitongauto.utils; + + +import com.itextpdf.kernel.colors.WebColors; +import com.itextpdf.kernel.events.Event; +import com.itextpdf.kernel.events.IEventHandler; +import com.itextpdf.kernel.events.PdfDocumentEvent; +import com.itextpdf.kernel.font.PdfFont; +import com.itextpdf.kernel.font.PdfFontFactory; +import com.itextpdf.kernel.geom.Rectangle; +import com.itextpdf.kernel.pdf.PdfDocument; +import com.itextpdf.kernel.pdf.PdfPage; +import com.itextpdf.kernel.pdf.canvas.PdfCanvas; +import com.itextpdf.layout.Canvas; +import com.itextpdf.layout.element.Paragraph; +import com.itextpdf.layout.property.TextAlignment; +import com.itextpdf.layout.property.VerticalAlignment; +import org.springframework.stereotype.Component; + +import java.io.IOException; + +/** + * 水印 + */ +@Component +public class WaterMarkEventHandler implements IEventHandler { + + /** + * 水印内容 + */ + private final String waterMarkContent; + + /** + * 一页中有几列水印 + */ + private final int waterMarkX; + + /** + * 一页中每列有多少水印 + */ + private final int waterMarkY; + + public WaterMarkEventHandler(String waterMarkContent) { + this(waterMarkContent, 5, 5); + } + + public WaterMarkEventHandler(String waterMarkContent, int waterMarkX, int waterMarkY) { + this.waterMarkContent = waterMarkContent; + this.waterMarkX = waterMarkX; + this.waterMarkY = waterMarkY; + } + + @Override + public void handleEvent(Event event) { + + PdfDocumentEvent documentEvent = (PdfDocumentEvent) event; + PdfDocument document = documentEvent.getDocument(); + PdfPage page = documentEvent.getPage(); + Rectangle pageSize = page.getPageSize(); + + PdfFont pdfFont = null; + try { + pdfFont = PdfFontFactory.createFont(); + } catch (IOException e) { + e.printStackTrace(); + } + + PdfCanvas pdfCanvas = new PdfCanvas(page.newContentStreamAfter(), page.getResources(), document); + + Paragraph waterMark = new Paragraph(waterMarkContent).setOpacity(0.5f); + Canvas canvas = new Canvas(pdfCanvas, pageSize) + .setFontColor(WebColors.getRGBColor("lightgray")) + .setFontSize(16) + .setFont(pdfFont); + + for (int i = 0; i < waterMarkX; i++) { + for (int j = 0; j < waterMarkY; j++) { + canvas.showTextAligned(waterMark, (150 + i * 300), (160 + j * 150), document.getNumberOfPages(), + TextAlignment.CENTER, VerticalAlignment.BOTTOM, 120); + } + } + canvas.close(); + } +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/check/CheckHelper.java b/utils/src/main/java/com/haitongauto/utils/check/CheckHelper.java new file mode 100644 index 0000000..68986dc --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/check/CheckHelper.java @@ -0,0 +1,77 @@ +package com.haitongauto.utils.check; + +import com.bestvike.linq.Linq; + +import java.util.ArrayList; +import java.util.List; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +public class CheckHelper { + /** + * 验证vins受否狗17位(6-17 位 王文文提出) + * 返回验证不通过的vins + */ + public static List CheckVinLength(List vinlist) { + if (vinlist == null || vinlist.size() == 0) { + return null; + } + List myvinlist = Linq.of(vinlist).where(p -> p != null && !p.isEmpty()).toList(); + if (vinlist == null || vinlist.size() == 0) { + return null; + } + List vins = new ArrayList<>(); + //找出长度不在6-17之间的（即不合格的）vin, + vins = Linq.of(myvinlist).where(o -> !(o.length() >= 6 && o.length() <= 17)).toList(); + return vins; + } + + /** + * 验证vins只能包含数字或英文字母 digit + * 返回验证不通过的vins + */ + public static List CheckVinContainEnOrDi(List vinlist) { + if (vinlist == null || vinlist.size() == 0) { + return null; + } + List myvinlist = Linq.of(vinlist).where(p -> p != null && !p.isEmpty()).toList(); + if (vinlist == null || vinlist.size() == 0) { + return null; + } + List vins = new ArrayList<>(); + //包含字母或数字的正则 + String pattern = "^[a-zA-Z0-9]+$"; + //找出有不包含字母或数字的 + vins = Linq.of(myvinlist).where(o -> !o.matches(pattern)).toList(); + return vins; + } + + /** + * 验证手机号码 + * + * @param phoneNumber 你要验证的手机号 + * @return 返回 + */ + public static Boolean checkTelPhoneNumber(String phoneNumber) { + Boolean res = false; + if (phoneNumber == null || phoneNumber.isEmpty()) { + return false; + } + // 定义手机号的正则表达式 + String regex = "^(13\\d|14[5-9]|15[0-3,5-9]|16[2,5,6]|17[0-8]|18\\d|19[0-3,5-9])\\d{8}$"; + // 创建 Pattern 对象 + Pattern pattern = Pattern.compile(regex); + // 创建 Matcher 对象 + Matcher matcher = pattern.matcher(phoneNumber); + // 判断手机号是否符合正则表达式 + if (matcher.matches()) { + res = true; + System.out.println("手机号验证通过"); + } else { + res = false; + System.out.println("手机号验证不通过"); + } + return res; + } + +} diff --git a/utils/src/main/java/com/haitongauto/utils/excel/ExcelCustomCellWriteHeightConfig.java b/utils/src/main/java/com/haitongauto/utils/excel/ExcelCustomCellWriteHeightConfig.java new file mode 100644 index 0000000..d1dc533 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/excel/ExcelCustomCellWriteHeightConfig.java @@ -0,0 +1,61 @@ +package com.haitongauto.utils.excel; + +import com.alibaba.excel.write.style.row.AbstractRowHeightStyleStrategy; +import org.apache.poi.ss.usermodel.Cell; +import org.apache.poi.ss.usermodel.CellType; +import org.apache.poi.ss.usermodel.Row; + +import java.util.Iterator; + +public class ExcelCustomCellWriteHeightConfig extends AbstractRowHeightStyleStrategy { + /** + * 默认高度 + */ + private static final Integer DEFAULT_HEIGHT = 300; + + /** + * + * @param row row + * @param relativeRowIndex relativeRowIndex + */ + @Override + protected void setHeadColumnHeight(Row row, int relativeRowIndex) { + } + + /** + * + * @param row row + * @param relativeRowIndex relativeRowIndex + */ + @Override + protected void setContentColumnHeight(Row row, int relativeRowIndex) { + Iterator cellIterator = row.cellIterator(); + if (!cellIterator.hasNext()) { + return; + } + // 默认为 1行高度 + int maxHeight = 1; + while (cellIterator.hasNext()) { + Cell cell = cellIterator.next(); + if (cell.getCellTypeEnum() == CellType.STRING) { + String value = cell.getStringCellValue(); + int len = value.length(); + int num = 0; + if (len > 50) { + num = len % 50 > 0 ? len / 50 : len / 2 - 1; + } + if (num > 0) { + for (int i = 0; i < num; i++) { + value = value.substring(0, (i + 1) * 50 + i) + "\n" + value.substring((i + 1) * 50 + i, len + i); + } + } + if (value.contains("\n")) { + int length = value.split("\n").length; + maxHeight = Math.max(maxHeight, length) + 1; + } + } + } + row.setHeight((short) ((maxHeight) * DEFAULT_HEIGHT)); + } + +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/excel/ExcelCustomCellWriteWidthConfig.java b/utils/src/main/java/com/haitongauto/utils/excel/ExcelCustomCellWriteWidthConfig.java new file mode 100644 index 0000000..094de57 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/excel/ExcelCustomCellWriteWidthConfig.java @@ -0,0 +1,87 @@ +package com.haitongauto.utils.excel; +import com.alibaba.excel.enums.CellDataTypeEnum; +import com.alibaba.excel.metadata.Head; +import com.alibaba.excel.metadata.data.CellData; +import com.alibaba.excel.metadata.data.WriteCellData; +import com.alibaba.excel.write.metadata.holder.WriteSheetHolder; +import com.alibaba.excel.write.style.column.AbstractColumnWidthStyleStrategy; +//import org.apache.commons.collections.CollectionUtils; +import org.apache.poi.ss.usermodel.Cell; +import org.apache.poi.ss.usermodel.Sheet; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; + + +public class ExcelCustomCellWriteWidthConfig extends AbstractColumnWidthStyleStrategy { + + private final Map> CACHE = new HashMap<>(); + + /** + * + * @param writeSheetHolder writeSheetHolder + * @param cellDataList cellDataList + * @param cell cell + * @param head head + * @param integer integer + * @param isHead isHead + */ + @Override + protected void setColumnWidth(WriteSheetHolder writeSheetHolder, List> cellDataList, Cell cell, Head head, Integer integer, Boolean isHead) { + //boolean needSetWidth = isHead || !CollectionUtils.isEmpty(cellDataList); + boolean needSetWidth = isHead ||cellDataList!=null||cellDataList.size()>0; + if (needSetWidth) { + Map maxColumnWidthMap = CACHE.computeIfAbsent(writeSheetHolder.getSheetNo(), k -> new HashMap<>()); + + Integer columnWidth = this.dataLength(cellDataList, cell, isHead); + // 单元格文本长度大于60换行 + if (columnWidth >= 0) { + if (columnWidth > 60) { + columnWidth = 60; + } + Integer maxColumnWidth = maxColumnWidthMap.get(cell.getColumnIndex()); + if (maxColumnWidth == null || columnWidth > maxColumnWidth) { + maxColumnWidthMap.put(cell.getColumnIndex(), columnWidth); + Sheet sheet = writeSheetHolder.getSheet(); + sheet.setColumnWidth(cell.getColumnIndex(), columnWidth * 256); + } + } + } + } + + /** + * 计算长度 + * + * @param cellDataList cellDataList + * @param cell cell + * @param isHead isHead + * @return return + */ + private Integer dataLength(List> cellDataList, Cell cell, Boolean isHead) { + if (isHead) { + return cell.getStringCellValue().getBytes().length; + } else { + CellData cellData = cellDataList.get(0); + CellDataTypeEnum type = cellData.getType(); + if (type == null) { + return -1; + } else { + switch (type) { + case STRING: + // 换行符（数据需要提前解析好） + int index = cellData.getStringValue().indexOf("\n"); + return index != -1 ? + cellData.getStringValue().substring(0, index).getBytes().length + 1 : cellData.getStringValue().getBytes().length + 1; + case BOOLEAN: + return cellData.getBooleanValue().toString().getBytes().length; + case NUMBER: + return cellData.getNumberValue().toString().getBytes().length; + default: + return -1; + } + } + } + } + +} \ No newline at end of file diff --git a/utils/src/main/java/com/haitongauto/utils/excel/ExcelGenerateHelper.java b/utils/src/main/java/com/haitongauto/utils/excel/ExcelGenerateHelper.java new file mode 100644 index 0000000..4933b37 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/excel/ExcelGenerateHelper.java @@ -0,0 +1,239 @@ +package com.haitongauto.utils.excel; + +import com.alibaba.excel.EasyExcel; +import com.alibaba.excel.ExcelWriter; +import com.alibaba.excel.write.metadata.WriteSheet; +import com.haitongauto.utils.FormatDateTime; + +import java.io.FileOutputStream; +import java.io.IOException; +import java.util.List; +import java.util.UUID; + +public class ExcelGenerateHelper { + /** + * 导出 Excel 文件, 有表头 + * + * @param dateList 想要导出的数据列表 + * @param clazz 待导出数据的类型 + * @param filePath 导出后的excel文件的存储路径 + * @param 类型 + */ + public static void outPutExcel(List dateList, Class clazz, String filePath) { + // 默认导出地址 obj.getClass().getName() 使用反射获取类的名称 + //String fileName = "C:\\Users\\lenovo\\Desktop\\图片工具" + "\\" + clazz.getSimpleName() + ".xlsx"; + String fileName = ""; + if (filePath != null && !filePath.isEmpty()) { + fileName = filePath + clazz.getSimpleName() + ".xlsx"; + } else { + return; + } + + System.out.println("Excel文件: " + clazz.getSimpleName() + ".xlsx 开始生成"); + + // 创建一个输出流，将文件输出 + FileOutputStream outputStream = null; + + try { + outputStream = new FileOutputStream(fileName); + // EasyExcel.write(outputStream) 为了使用流将数据导出 + ExcelWriter writer = EasyExcel.write(outputStream).build(); + // writerSheet 中 sheetNo 表示导出的是 Excel 中第几页数据，sheetName 表示导出的该页数据名称 + // head 表示 Excel 数据需要映射的类 + WriteSheet sheet = EasyExcel.writerSheet(0, "Excel表第0页的名称") + .registerWriteHandler(new ExcelCustomCellWriteWidthConfig()) /*自适应列宽*/ + .registerWriteHandler(new ExcelCustomCellWriteHeightConfig()) /*自适应行高（根据自己情况选择使用，我这里没用到）*/ + .head(clazz)//根据实体类设置表头 + .build(); + + // 开始写入数据 + writer.write(dateList, sheet); + // 刷新数据 + writer.finish(); + outputStream.flush(); + System.out.println("Excel文件生成成功 ---> 生成位置: " + fileName); + } catch (IOException e) { + e.printStackTrace(); + } finally { + try { + if (outputStream != null) { + // 关闭流 + outputStream.close(); + } + } catch (IOException e) { + e.printStackTrace(); + } + } + } + + /** + * @param dateList 数据 + * @param clazz 类型 + * @param filePath 文件路径 + * @param 类型 + * @return 返回文件名（全路径） + */ + public static String outPutExcelReturnFileName(List dateList, Class clazz, String filePath) { + + // 默认导出地址 obj.getClass().getName() 使用反射获取类的名称 + //String fileName = "C:\\Users\\lenovo\\Desktop\\图片工具" + "\\" + clazz.getSimpleName() + ".xlsx"; + String fileName = ""; + if (filePath != null && !filePath.isEmpty()) { + fileName = filePath + clazz.getSimpleName() + FormatDateTime.getStringDate() + ".xlsx"; + } else { + return fileName; + } + System.out.println("Excel文件: " + clazz.getSimpleName() + ".xlsx 开始生成"); + // 创建一个输出流，将文件输出 + FileOutputStream outputStream = null; + try { + outputStream = new FileOutputStream(fileName); + // EasyExcel.write(outputStream) 为了使用流将数据导出 + ExcelWriter writer = EasyExcel.write(outputStream).build(); + // writerSheet 中 sheetNo 表示导出的是 Excel 中第几页数据，sheetName 表示导出的该页数据名称 + // head 表示 Excel 数据需要映射的类 + WriteSheet sheet = EasyExcel.writerSheet(0, "Excel表第0页的名称") + .registerWriteHandler(new ExcelCustomCellWriteWidthConfig()) /*自适应列宽*/ + .registerWriteHandler(new ExcelCustomCellWriteHeightConfig()) /*自适应行高（根据自己情况选择使用，我这里没用到）*/ + + .head(clazz)//根据实体类设置表头 + .build(); + + // 开始写入数据 + writer.write(dateList, sheet); + // 刷新数据 + writer.finish(); + outputStream.flush(); + System.out.println("Excel文件生成成功 ---> 生成位置: " + fileName); + } catch (IOException e) { + e.printStackTrace(); + } finally { + try { + if (outputStream != null) { + // 关闭流 + outputStream.close(); + } + } catch (IOException e) { + e.printStackTrace(); + } + } + + return fileName; + + } + + + /** + * 导出 Excel 文件, 不带表头的 + * + * @param dateList 想要导出的数据列表 + * @param clazz 待导出数据的类型 + * @param filePath 导出后的excel文件的存储路径 + * @param 类型 + */ + public static void outPutExcelUnHear(List dateList, Class clazz, String filePath) { + + // 默认导出地址 obj.getClass().getName() 使用反射获取类的名称 + //String fileName = "C:\\Users\\lenovo\\Desktop\\图片工具" + "\\" + clazz.getSimpleName() + ".xlsx"; + String fileName = ""; + if (filePath != null && !filePath.isEmpty()) { + fileName = filePath + clazz.getSimpleName() + ".xlsx"; + } else { + return; + } + + System.out.println("Excel文件: " + clazz.getSimpleName() + ".xlsx 开始生成"); + + // 创建一个输出流，将文件输出 + FileOutputStream outputStream = null; + + try { + outputStream = new FileOutputStream(fileName); + // EasyExcel.write(outputStream) 为了使用流将数据导出 + ExcelWriter writer = EasyExcel.write(outputStream).build(); + // writerSheet 中 sheetNo 表示导出的是 Excel 中第几页数据，sheetName 表示导出的该页数据名称 + // head 表示 Excel 数据需要映射的类 + WriteSheet sheet = EasyExcel.writerSheet(0, "Excel表第0页的名称") + .registerWriteHandler(new ExcelCustomCellWriteWidthConfig()) /*自适应列宽*/ + .registerWriteHandler(new ExcelCustomCellWriteHeightConfig()) /*自适应行高（根据自己情况选择使用，我这里没用到）*/ + //.head(clazz) + .build(); + + // 开始写入数据 + writer.write(dateList, sheet); + // 刷新数据 + writer.finish(); + outputStream.flush(); + System.out.println("Excel文件生成成功 ---> 生成位置: " + fileName); + } catch (IOException e) { + e.printStackTrace(); + } finally { + try { + if (outputStream != null) { + // 关闭流 + outputStream.close(); + } + } catch (IOException e) { + e.printStackTrace(); + } + } + } + + /** + * @param dateList 数据 + * @param clazz 类型 + * @param filePath 文件路径 + * @param 类型 + * @return 文件名（全路径） + */ + public static String outPutExcelUnHearReturnFileName(List dateList, Class clazz, String filePath) { + + // 默认导出地址 obj.getClass().getName() 使用反射获取类的名称 + String fileName = ""; + if (filePath != null && !filePath.isEmpty()) { + fileName = filePath + clazz.getSimpleName() + FormatDateTime.getStringDate() + ".xlsx"; + } else { + return fileName; + } + + System.out.println("Excel文件: " + clazz.getSimpleName() + ".xlsx 开始生成"); + + // 创建一个输出流，将文件输出 + FileOutputStream outputStream = null; + + try { + outputStream = new FileOutputStream(fileName); + // EasyExcel.write(outputStream) 为了使用流将数据导出 + ExcelWriter writer = EasyExcel.write(outputStream).build(); + // writerSheet 中 sheetNo 表示导出的是 Excel 中第几页数据，sheetName 表示导出的该页数据名称 + // head 表示 Excel 数据需要映射的类 + WriteSheet sheet = EasyExcel.writerSheet(0, "Excel表第0页的名称") + .registerWriteHandler(new ExcelCustomCellWriteWidthConfig()) /*自适应列宽*/ + .registerWriteHandler(new ExcelCustomCellWriteHeightConfig()) /*自适应行高（根据自己情况选择使用，我这里没用到）*/ + //.head(clazz) + .build(); + + // 开始写入数据 + writer.write(dateList, sheet); + // 刷新数据 + writer.finish(); + outputStream.flush(); + System.out.println("Excel文件生成成功 ---> 生成位置: " + fileName); + } catch (IOException e) { + e.printStackTrace(); + } finally { + try { + if (outputStream != null) { + // 关闭流 + outputStream.close(); + } + } catch (IOException e) { + e.printStackTrace(); + } + } + + return fileName; + } + + +} diff --git a/utils/src/main/java/com/haitongauto/utils/http/OkHttpUtils.java b/utils/src/main/java/com/haitongauto/utils/http/OkHttpUtils.java new file mode 100644 index 0000000..392bc81 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/http/OkHttpUtils.java @@ -0,0 +1,223 @@ +package com.haitongauto.utils.http; + + +import okhttp3.*; + +import java.io.IOException; +import java.util.Map; +import java.util.concurrent.TimeUnit; + +public class OkHttpUtils { + + // 创建OkHttpClient对象 + private static final OkHttpClient client = new OkHttpClient.Builder() + .connectTimeout(30, TimeUnit.SECONDS) // 连接超时时间 + .readTimeout(30, TimeUnit.SECONDS) // 读取超时时间 + .writeTimeout(30, TimeUnit.SECONDS) // 写入超时时间 + .build(); + + /** + * GET请求 + * @param url 请求URL + * @return 响应体字符串 + * @throws IOException 请求或响应过程中发生的错误 + */ + public static String get(String url) throws IOException { + Request request = new Request.Builder() + .url(url) + .build(); + Response response = client.newCall(request).execute(); + if (response.isSuccessful()) { + return response.body().string(); + } else { + throw new IOException("Unexpected code " + response); + } + } + + public static String get(String url, Map headers) throws IOException { + Request.Builder builder = new Request.Builder() + .url(url); + if (headers != null && headers.size() > 0) { + for (Map.Entry entry : headers.entrySet()) { + builder.addHeader(entry.getKey(), entry.getValue()); + } + } + Request request = builder.build(); + Response response = client.newCall(request).execute(); + if (response.isSuccessful()) { + return response.body().string(); + } else { + throw new IOException("Unexpected code " + response); + } + } + + /** + * POST请求 + * @param url 请求URL + * @param requestBody 请求体 + * @param headers 请求头 + * @return 响应体字符串 + * @throws IOException 请求或响应过程中发生的错误 + */ + public static String post(String url, RequestBody requestBody, Map headers) throws IOException { + Request.Builder builder = new Request.Builder() + .url(url) + .post(requestBody); + if (headers != null && headers.size() > 0) { + for (Map.Entry entry : headers.entrySet()) { + builder.addHeader(entry.getKey(), entry.getValue()); + } + } + Request request = builder.build(); + Response response = client.newCall(request).execute(); + if (response.isSuccessful()) { + return response.body().string(); + } else { + throw new IOException("Unexpected code " + response); + } + } + + /** + * 构造JSON请求体 + * @param jsonStr JSON字符串 + * @return JSON请求体 + */ + public static RequestBody buildJsonRequestBody(String jsonStr) { + return RequestBody.create(MediaType.parse("application/json"), jsonStr); + } + + /** + * 构造表单请求体 + * @param formParams 表单参数 + * @return 表单请求体 + */ + public static RequestBody buildFormRequestBody(Map formParams) { + FormBody.Builder builder = new FormBody.Builder(); + if (formParams != null && formParams.size() > 0) { + for (Map.Entry entry : formParams.entrySet()) { + builder.add(entry.getKey(), entry.getValue()); + } + } + return builder.build(); + } + + /** + * 构造Multipart请求体 + * @param multipartParams Multipart参数 + * @return Multipart请求体 + */ + public static RequestBody buildMultipartRequestBody(Map multipartParams) { + MultipartBody.Builder builder = new MultipartBody.Builder() + .setType(MultipartBody.FORM); + if (multipartParams != null && multipartParams.size() > 0) { + for (Map.Entry entry : multipartParams.entrySet()) { + String key = entry.getKey(); + Object value = entry.getValue(); + if (value instanceof String) { + builder.addFormDataPart(key, (String) value); + } else if (value instanceof byte[]) { + builder.addFormDataPart(key, null, + RequestBody.create(MediaType.parse("application/octet-stream"), (byte[]) value)); + } else if (value instanceof RequestBody) { + builder.addFormDataPart(key, null, (RequestBody) value); + } + } + } + return builder.build(); + } + + /** + * 构造Multipart请求体，支持上传文件 + * @param multipartParams Multipart参数 + * @return Multipart请求体 + */ + public static RequestBody buildMultipartRequestBodyWithFiles(Map multipartParams) { + MultipartBody.Builder builder = new MultipartBody.Builder() + .setType(MultipartBody.FORM); + if (multipartParams != null && multipartParams.size() > 0) { + for (Map.Entry entry : multipartParams.entrySet()) { + String key = entry.getKey(); + Object value = entry.getValue(); + if (value instanceof String) { + builder.addFormDataPart(key, (String) value); + } else if (value instanceof byte[]) { + builder.addFormDataPart(key, null, + RequestBody.create(MediaType.parse("application/octet-stream"), (byte[]) value)); + } else if (value instanceof RequestBody) { + builder.addFormDataPart(key, null, (RequestBody) value); + } else if (value instanceof UploadFile) { // 支持上传文件 + UploadFile file = (UploadFile) value; + builder.addFormDataPart(key, file.getName(), + RequestBody.create(MediaType.parse(file.getMimeType()), file.getFile())); + } + } + } + return builder.build(); + } + + /** + * 上传文件 + * @param url 请求URL + * @param file 上传的文件 + * @param headers 请求头 + * @return 响应体字符串 + * @throws IOException 请求或响应过程中发生的错误 + */ + public static String uploadFile(String url, UploadFile file, Map headers) throws IOException { + RequestBody requestBody = new MultipartBody.Builder() + .setType(MultipartBody.FORM) + .addFormDataPart("file", file.getName(), + RequestBody.create(MediaType.parse(file.getMimeType()), file.getFile())) + .build(); + Request.Builder builder = new Request.Builder() + .url(url) + .post(requestBody); + if (headers != null && headers.size() > 0) { + for (Map.Entry entry : headers.entrySet()) { + builder.addHeader(entry.getKey(), entry.getValue()); + } + } + Request request = builder.build(); + Response response = client.newCall(request).execute(); + if (response.isSuccessful()) { + return response.body().string(); + } else { + throw new IOException("Unexpected code " + response); + } + } + + /** + * 封装文件上传参数 + */ + public static class UploadFile { + private final String name; + private final String mimeType; + private final byte[] file; + + public UploadFile(String name, String mimeType, byte[] file) { + this.name = name; + this.mimeType = mimeType; + this.file = file; + } + + public String getName() { + return name; + } + + public String getMimeType() { + return mimeType; + } + + public byte[] getFile() { + return file; + } + } + + + + + + + + +} diff --git a/utils/src/main/java/com/haitongauto/utils/minio/MinioProp.java b/utils/src/main/java/com/haitongauto/utils/minio/MinioProp.java new file mode 100644 index 0000000..ed7691d --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/minio/MinioProp.java @@ -0,0 +1,26 @@ +package com.haitongauto.utils.minio; + +import lombok.Data; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.stereotype.Component; + +@Data +public class MinioProp { + /** + * 连接url + */ + private String endpoint; + /** + * 用户名 + */ + private String accesskey; + /** + * 密码 + */ + private String secretKey; + /** + * 桶名称 + */ + private String bucket; + +} diff --git a/utils/src/main/java/com/haitongauto/utils/minio/MinioUtils.java b/utils/src/main/java/com/haitongauto/utils/minio/MinioUtils.java new file mode 100644 index 0000000..cdbf522 --- /dev/null +++ b/utils/src/main/java/com/haitongauto/utils/minio/MinioUtils.java @@ -0,0 +1,113 @@ +package com.haitongauto.utils.minio; + +import com.alibaba.fastjson.JSON; +import io.minio.MinioClient; +import io.minio.errors.*; +import org.springframework.stereotype.Component; +import org.springframework.web.multipart.MultipartFile; +import org.xmlpull.v1.XmlPullParserException; +import org.yaml.snakeyaml.Yaml; + +import java.io.DataInputStream; +import java.io.File; +import java.io.IOException; +import java.io.InputStream; +import java.nio.file.Files; +import java.security.InvalidKeyException; +import java.security.NoSuchAlgorithmException; +import java.util.Map; + +@Component +public class MinioUtils { + + public MinioUtils() { + } + + private static MinioClient client; + + private static MinioProp minioProp; + + /** + * 创建bucket + * + * @param bucketName bucket名称 + */ + + public static void createBucket(String bucketName) throws InvalidBucketNameException, InsufficientDataException, XmlPullParserException, ErrorResponseException, NoSuchAlgorithmException, IOException, NoResponseException, InvalidKeyException, InvalidResponseException, InternalException, RegionConflictException { + if (!client.bucketExists(bucketName)) { + client.makeBucket(bucketName); + } + } + + /** + * 上传文件 + * + * @param file 文件 + * @return 返回结果 + */ + public static String uploadFile(MultipartFile file) throws InvalidPortException, InvalidEndpointException { + + // 判断上传文件是否为空 + if (null == file || 0 == file.getSize()) { + try { + throw new Exception("上传文件不能为空"); + } catch (Exception e) { + throw new RuntimeException(e); + } + } + String fileUrl = ""; + //minio服务配置 + if (minioProp == null||minioProp.getEndpoint()==null||minioProp.getEndpoint().equals("")) { + minioProp = ymlReader(); + } + //minio客户端访问对象 + if (client == null) { + client = new MinioClient(minioProp.getEndpoint()); + } + + try { + // 判断存储桶是否存在，如果不存在创建桶 + createBucket(minioProp.getBucket()); + // 文件名 + String originalFilename = file.getOriginalFilename(); + // 新的文件名 = 存储桶名称_时间戳+【10000-99999】随机数字.后缀名 + //Random random = new Random(); + //String fileName = minioProp.getBucket() + "_" + System.currentTimeMillis() + (random.nextInt(99999 - 10000) + 10000 + 1) + originalFilename.substring(originalFilename.lastIndexOf(".")); + String fileName = "img_" + file.getOriginalFilename(); + // 开始上传 + client.putObject(minioProp.getBucket(), fileName, file.getInputStream(), file.getContentType()); + fileUrl = minioProp.getEndpoint() + "/" + minioProp.getBucket() + "/" + fileName; + return fileUrl; + } catch (Exception ex) { + fileUrl=""; + throw new RuntimeException(ex); + } + } + + + /** + * @return 返回配置 + */ + public static MinioProp ymlReader() { + MinioProp minioProp = new MinioProp(); + try { + Yaml yaml = new Yaml(); + final File initialFile = new File("utils/src/main/resources/utils.yml"); + final InputStream in = new DataInputStream(Files.newInputStream(initialFile.toPath())); + Map map = yaml.load(in); + Object minio = map.get("minio"); + if (minio != null && !minio.equals("")) { + minioProp = JSON.parseObject(JSON.toJSONString(minio), MinioProp.class); + } + System.out.println(map); + } catch (Exception e) { + e.printStackTrace(); + } + return minioProp; + } + + +} + + + diff --git a/utils/src/main/resources/log4j2.xml b/utils/src/main/resources/log4j2.xml new file mode 100644 index 0000000..32c8f6b --- /dev/null +++ b/utils/src/main/resources/log4j2.xml @@ -0,0 +1,13 @@ + + + + + + + + + + + + + \ No newline at end of file diff --git a/utils/src/main/resources/utils.yml b/utils/src/main/resources/utils.yml new file mode 100644 index 0000000..a9bb130 --- /dev/null +++ b/utils/src/main/resources/utils.yml @@ -0,0 +1,15 @@ +# minio 文件存储配置信息 https://rtops4.haitongauto.com/minio/ +minio: + endpoint: http://192.168.61.130:20001 + accesskey: hfyth + secretKey: hfyth2022 + bucket: rtos-saas-dev + +# minio 文件存储配置信息(本地) +#minio: +# endpoint: http://192.168.0.16:9000 +# accesskey: admin +# secretKey: admin@123 +# bucket: rtos-saas-dev + + diff --git a/utils/src/test/java/QueueNumTest.java b/utils/src/test/java/QueueNumTest.java new file mode 100644 index 0000000..16690ee --- /dev/null +++ b/utils/src/test/java/QueueNumTest.java @@ -0,0 +1,40 @@ +import com.haitongauto.utils.QueueNumberHelper; +import org.junit.Test; + +public class QueueNumTest { + @Test + public void geQueueNum() { + String queueNum = QueueNumberHelper.getNewQueueNumber("2308211003"); + String aaa=""; + + + // AppointForward appointForward=new AppointForward(); +// appointForward.setId("1"); +// appointForward.setOpenId("oBFJt5KzWJPJHHRpYPEOWvTUvqjA"); +// appointForward.setTruckNo("沪A88888"); +// appointForward.setOrderTm("2024-1-1 10:20:00"); +// appointForward.setOrderType("外贸出口"); +// appointForward.setWhafType("外高桥"); +// appointForward.setGodType("商品车"); +// appointForward.setGodNum(2); +// appointForward.setPhone("13118057744"); +// List dataList=new ArrayList<>(); +// VinDetail vinDetail1=new VinDetail(); +// vinDetail1.setVin("NSTOOS00000000001"); +// vinDetail1.setPotNm("达曼"); +// vinDetail1.setVlsNm("阿拉伯海"); +// vinDetail1.setBrdNm("江淮"); +// dataList.add(vinDetail1); +// VinDetail vinDetail2=new VinDetail(); +// vinDetail2.setVin("NSTOOS00000000002"); +// vinDetail2.setPotNm("达曼"); +// vinDetail2.setVlsNm("阿拉伯海"); +// vinDetail2.setBrdNm("江淮"); +// dataList.add(vinDetail2); +// appointForward.setDataList(dataList); +// +// String res= HttpClientHelper.forwardSendNew(appointForward,"http://192.168.161.81:8090/rtopswebapi/api/NsOrder/execTruckOrder"); + + + } +} diff --git a/utils/utils.iml b/utils/utils.iml new file mode 100644 index 0000000..563af64 --- /dev/null +++ b/utils/utils.iml @@ -0,0 +1,6 @@ + + + + + \ No newline at end of file