From df1e8bb8c13ef138291cbf85631880cd9e5505c8 Mon Sep 17 00:00:00 2001 From: ic_excellent Date: Thu, 8 Dec 2022 15:07:18 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=9B=B8=E5=85=B3=E5=B7=A5?= =?UTF-8?q?=E5=85=B7=E7=B1=BB=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../commons/config/entity/WeaverFile.java | 28 ++ .../config/service/DealWithMapping.java | 39 +++ .../core/BaseActionHandleFunction.java | 25 ++ .../xiao/commons/core/CusBaseAction.java | 276 +++++++++++++++ .../commons/exception/VerifyException.java | 21 ++ .../xiao/commons/utils/DocImageFileUtil.java | 292 ++++++++++++++++ .../xiao/commons/utils/HttpManager.java | 98 ++++++ .../xiao/commons/utils/RequestUtil.java | 2 +- .../xiao/commons/utils/SFTPClientUtil.java | 221 ++++++++++++ .../weaver/xiao/commons/utils/SqlUtil.java | 65 +++- .../weaver/xiao/commons/utils/VerifyUtil.java | 328 ++++++++++++++++++ .../commons/utils/annotation/JsonParse.java | 19 + .../utils/annotation/RequiredVerify.java | 17 + .../java/youhong/ai/pcn/TestOrganization.java | 19 - 14 files changed, 1427 insertions(+), 23 deletions(-) create mode 100644 src/main/java/weaver/xiao/commons/config/entity/WeaverFile.java create mode 100644 src/main/java/weaver/xiao/commons/core/BaseActionHandleFunction.java create mode 100644 src/main/java/weaver/xiao/commons/core/CusBaseAction.java create mode 100644 src/main/java/weaver/xiao/commons/exception/VerifyException.java create mode 100644 src/main/java/weaver/xiao/commons/utils/DocImageFileUtil.java create mode 100644 src/main/java/weaver/xiao/commons/utils/HttpManager.java create mode 100644 src/main/java/weaver/xiao/commons/utils/SFTPClientUtil.java create mode 100644 src/main/java/weaver/xiao/commons/utils/VerifyUtil.java create mode 100644 src/main/java/weaver/xiao/commons/utils/annotation/JsonParse.java create mode 100644 src/main/java/weaver/xiao/commons/utils/annotation/RequiredVerify.java diff --git a/src/main/java/weaver/xiao/commons/config/entity/WeaverFile.java b/src/main/java/weaver/xiao/commons/config/entity/WeaverFile.java new file mode 100644 index 0000000..471b71e --- /dev/null +++ b/src/main/java/weaver/xiao/commons/config/entity/WeaverFile.java @@ -0,0 +1,28 @@ +package weaver.xiao.commons.config.entity; + +import lombok.Data; +import weaver.xiao.commons.utils.annotation.SqlFieldMapping; + +import java.io.InputStream; + +/** + *

文件信息实体类

+ * + * @author XiaoBokang + * @create 2022/8/8 10:24 + */ + +@Data +public class WeaverFile { + + @SqlFieldMapping("imagefilename") + String fileName; + + @SqlFieldMapping("imagefileid") + String imageFileId; + + @SqlFieldMapping("docid") + String docId; + + InputStream inputStream; +} diff --git a/src/main/java/weaver/xiao/commons/config/service/DealWithMapping.java b/src/main/java/weaver/xiao/commons/config/service/DealWithMapping.java index 6263380..0217882 100644 --- a/src/main/java/weaver/xiao/commons/config/service/DealWithMapping.java +++ b/src/main/java/weaver/xiao/commons/config/service/DealWithMapping.java @@ -1239,6 +1239,45 @@ public class DealWithMapping extends ToolUtil { } } + /** + *

请求结果赋值到配置信息中

+ * @param responseMappingList 回写信息配置列表 + * @param requestRes 请求结果 + * @return 要插入的信息 + */ + public Map> dealResponse(List responseMappingList, Map requestRes) { + this.writeDebuggerLog("回写信息转换处理 responseMappingList==>" + responseMappingList + " requestRes==>" + requestRes); + Map> tableUpdateMap = new HashMap<>(); + if (responseMappingList != null && !responseMappingList.isEmpty()) { + Map mainUpdateMap = new HashMap<>(); + List detailResponseList = new ArrayList<>(); + for (ResponseMapping responseMapping : responseMappingList) { + if (responseMapping.getMainOrDetail() == 0) { + String resVal = Util.null2String(requestRes.get(responseMapping.getResponseFieldName())); + mainUpdateMap.put(responseMapping.getWorkflowFieldName(), resVal); + } else { + detailResponseList.add(responseMapping); + } + } + tableUpdateMap.put(mainTable, mainUpdateMap); + Map> groupMap = detailResponseList.stream().collect(Collectors.groupingBy(ResponseMapping::getDetailTableId)); + Set>> entries = groupMap.entrySet(); + for (Map.Entry> entry : entries) { + Map detailUpdateMap = new HashMap<>(); + String detailId = entry.getKey(); + List responseMappings = entry.getValue(); + String detailTableName = mainTable + "_dt" + detailId; + for (ResponseMapping responseMapping : responseMappings) { + String resVal = Util.null2String(requestRes.get(responseMapping.getResponseFieldName())); + detailUpdateMap.put(responseMapping.getWorkflowFieldName(), resVal); + } + tableUpdateMap.put(detailTableName, detailUpdateMap); + } + } + this.writeDebuggerLog("回写信息tableUpdateMap==> " + tableUpdateMap); + return tableUpdateMap; + } + /** * 自定义时间格式化 * diff --git a/src/main/java/weaver/xiao/commons/core/BaseActionHandleFunction.java b/src/main/java/weaver/xiao/commons/core/BaseActionHandleFunction.java new file mode 100644 index 0000000..6639a1f --- /dev/null +++ b/src/main/java/weaver/xiao/commons/core/BaseActionHandleFunction.java @@ -0,0 +1,25 @@ +package weaver.xiao.commons.core; + +import weaver.hrm.User; +import weaver.workflow.request.RequestManager; + +/** + * @ClassName BaseActionHandleFunction + * @Author 肖博亢 + * @Date 2022/11/25 12:17 + * @Description

流程提交类型处理方法

+ **/ +@FunctionalInterface +public interface BaseActionHandleFunction { + /** + *

流程处理方法action

+ * + * @param requestId 流程请求ID + * @param billTable 流程对应主表名称 + * @param workflowId 流程对应流程ID + * @param user 当前节点操作者用户 + * @param requestManager 请求管理对象 + */ + void handle(String requestId, String billTable, int workflowId, + User user, RequestManager requestManager) throws Exception; +} diff --git a/src/main/java/weaver/xiao/commons/core/CusBaseAction.java b/src/main/java/weaver/xiao/commons/core/CusBaseAction.java new file mode 100644 index 0000000..51b2775 --- /dev/null +++ b/src/main/java/weaver/xiao/commons/core/CusBaseAction.java @@ -0,0 +1,276 @@ +package weaver.xiao.commons.core; + +import org.apache.log4j.Logger; +import weaver.conn.RecordSetTrans; +import weaver.hrm.User; +import weaver.interfaces.workflow.action.Action; +import weaver.soa.workflow.request.*; +import weaver.workflow.request.RequestManager; +import weaver.workflow.workflow.WorkflowBillComInfo; +import weaver.workflow.workflow.WorkflowComInfo; +import weaver.xiao.commons.utils.LogUtil; +import weaver.xiao.commons.utils.VerifyUtil; + +import java.util.*; + + +/** + * @ClassName BaseAction + * @Author 肖博亢 + * @Date 2022/11/25 12:09 + * @Description

实现Action接口并具备一些基本功能

+ **/ +public abstract class CusBaseAction implements Action { + + /** 全局日志对象 */ + protected final Logger log = LogUtil.getLogger(); + + /** 全局requestInfo对象 */ + protected RequestInfo requestInfo; + + /** 全局数据处理事务类 */ + protected RecordSetTrans recordSetTrans = new RecordSetTrans(); + + /** 流程提交方式处理方法集合 */ + private final Map actionHandleMethod = new HashMap<>(); + + + /** + *

初始化流程默认的处理方法

+ */ + private void initHandleMethod() { + //提交 + actionHandleMethod.put(ActionRunType.SUBMIT, this::doSubmit); + //退回 + actionHandleMethod.put(ActionRunType.REJECT, this::doReject); + //撤回 + actionHandleMethod.put(ActionRunType.WITHDRAW, this::doWithdraw); + //强制收回 + actionHandleMethod.put(ActionRunType.DRAW_BACK, this::doDrawBack); + } + + @Override + public final String execute(RequestInfo requestInfo) { + this.requestInfo = requestInfo; + RequestManager requestManager = requestInfo.getRequestManager(); + String billTable = requestManager.getBillTableName(); + String requestId = requestInfo.getRequestid(); + User user = requestInfo.getRequestManager().getUser(); + int workflowId = requestManager.getWorkflowid(); + //操作类型 submit - 提交 reject - 退回 等 + String src = requestManager.getSrc(); + if ("".equals(billTable)) { + WorkflowComInfo workflowComInfo = new WorkflowComInfo(); + String formId = workflowComInfo.getFormId(String.valueOf(workflowId)); + WorkflowBillComInfo workflowBillComInfo = new WorkflowBillComInfo(); + billTable = workflowBillComInfo.getTablename(formId); + } + try { + VerifyUtil.requireVerify(this); + if (VerifyUtil.isBlank(src)) { + src = "submit"; + } + //初始化默认的流程处理方法 + initHandleMethod(); + //提供自定义注册处理方法 + registerHandler(actionHandleMethod); + //获取流程对应的处理方法 + BaseActionHandleFunction cusBaseActionHandleFunction = actionHandleMethod.get(src); + //默认没有直接成功不做拦截 + if (null == cusBaseActionHandleFunction) { + return Action.SUCCESS; + } + cusBaseActionHandleFunction.handle(requestId, billTable, workflowId, user, requestManager); + }catch (Exception e) { + e.printStackTrace(); + log.info("action执行异常 ==>"+LogUtil.getExceptionStr(e)); + String message = doExceptionDeal(e,requestId,workflowId,user,requestManager); + requestInfo.getRequestManager().setMessageid("11111C " + requestId + " 22222"); + requestInfo.getRequestManager().setMessagecontent(message); + return Action.FAILURE_AND_CONTINUE; + } + return Action.SUCCESS; + } + + /** + *

流程其他流转类型处理方法注册

+ * + * @param actionHandleMethod 处理方法对应map + */ + public void registerHandler(Map actionHandleMethod) { + } + + + /** + *

action 提交流程业务处理方法

+ *

具体业务逻辑实现 + * 全局存在log成员变量，用于日志的输出 + * Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败 + *

+ * + * @param requestId 流程请求ID + * @param billTable 流程对应主表名称 + * @param workflowId 流程对应流程ID + * @param user 当前节点操作者用户 + * @param requestManager 请求管理对象 + */ + + public abstract void doSubmit(String requestId, String billTable, int workflowId, + User user, RequestManager requestManager) throws Exception; + + + /** + *

action 退回流程业务处理方法

+ *

具体业务逻辑实现 + * 全局存在log成员变量，用于日志的输出 + * Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败 + *

+ * + * @param requestId 流程请求ID + * @param billTable 流程对应主表名称 + * @param workflowId 流程对应流程ID + * @param user 当前节点操作者用户 + * @param requestManager 请求管理对象 + */ + public void doReject(String requestId, String billTable, int workflowId, + User user, RequestManager requestManager) throws Exception{ + } + + /** + *

action 撤回、撤回流程流程业务处理方法

+ *

具体业务逻辑实现 + * 全局存在log成员变量，用于日志的输出 + * Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败 + *

+ * + * @param requestId 流程请求ID + * @param billTable 流程对应主表名称 + * @param workflowId 流程对应流程ID + * @param user 当前节点操作者用户 + * @param requestManager 请求管理对象 + */ + public void doWithdraw(String requestId, String billTable, int workflowId, + User user, RequestManager requestManager) throws Exception{ + } + + + /** + *

action 强制收回流程业务处理方法

+ *

具体业务逻辑实现 + * 全局存在log成员变量，用于日志的输出 + * Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败 + *

+ * + * @param requestId 流程请求ID + * @param billTable 流程对应主表名称 + * @param workflowId 流程对应流程ID + * @param user 当前节点操作者用户 + * @param requestManager 请求管理对象 + */ + public void doDrawBack(String requestId, String billTable, int workflowId, + User user, RequestManager requestManager) throws Exception{ + } + + /** + *

action 发生异常处理方法

+ * @param e 异常信息 + * @param requestId 请求id + * @param workflowId 流程id + * @param user 用户信息 + * @param requestManager 请求管理对象 + * @return 提示信息 + */ + public abstract String doExceptionDeal(Exception e,String requestId,int workflowId,User user,RequestManager requestManager); + + /** + *

获取流程主表数据

+ * + * @return 流程主表数据 + */ + protected Map getMainTableValue() { + //获取主表数据 + Property[] propertyArr = requestInfo.getMainTableInfo().getProperty(); + if (null == propertyArr) { + return Collections.emptyMap(); + } + Map mainTable = new HashMap<>((int) Math.ceil(propertyArr.length * 1.4)); + for (Property property : propertyArr) { + String fieldName = property.getName(); + String value = property.getValue(); + mainTable.put(fieldName, value); + } + return mainTable; + } + + + /** + *

获取所有明细数据

+ * + * @return 以明细表需要为键，以明细表数据为值的键值对明细数据信息 + */ + protected Map>> getDetailTableValue() { + DetailTable[] detailTableArr = requestInfo.getDetailTableInfo().getDetailTable(); + Map>> detailDataList = new HashMap<>((int) Math.ceil(detailTableArr.length * 1.4)); + for (DetailTable detailTable : detailTableArr) { + List> detailData = getDetailValue(detailTable); + detailDataList.put(detailTable.getId(), detailData); + } + return detailDataList; + } + + + /** + *

获取指定明细表的表数据

+ * + * @param detailNo 明细表编号 + * @return 明细数据 + */ + protected List> getDetailTableValueByDetailNo(int detailNo) { + DetailTable detailTable = requestInfo.getDetailTableInfo().getDetailTable(detailNo); + return getDetailValue(detailTable); + } + + /** + *

根据明细表信息获取明细表数据

+ * + * @param detailTable 明细表对象 + * @return 明细表数据 + */ + private List> getDetailValue(DetailTable detailTable) { + Row[] rowArr = detailTable.getRow(); + List> detailData = new ArrayList<>(rowArr.length); + for (Row row : rowArr) { + Cell[] cellArr = row.getCell(); + Map rowData = new HashMap<>((int) Math.ceil(cellArr.length * (1 + 0.4))); + rowData.put("id", row.getId()); + for (Cell cell : cellArr) { + String fieldName = cell.getName(); + String value = cell.getValue(); + rowData.put(fieldName, value); + } + detailData.add(rowData); + } + return detailData; + } + + + public static final class ActionRunType { + /** + * 退回 + */ + public static final String REJECT = "reject"; + /** + * 撤回 + */ + public static final String WITHDRAW = "withdraw"; + /** + * 强制收回 + */ + public static final String DRAW_BACK = "drawBack"; + /** + * 提交 + */ + public static final String SUBMIT = "submit"; + } + +} diff --git a/src/main/java/weaver/xiao/commons/exception/VerifyException.java b/src/main/java/weaver/xiao/commons/exception/VerifyException.java new file mode 100644 index 0000000..724b955 --- /dev/null +++ b/src/main/java/weaver/xiao/commons/exception/VerifyException.java @@ -0,0 +1,21 @@ +package weaver.xiao.commons.exception; + +/** + * @author XiaoBokang + * @create 2022/7/28 14:47 + */ + +public class VerifyException extends RuntimeException{ + public VerifyException(String message){ + super(message); + } + + public VerifyException(String message, Throwable cause) { + super(message, cause); + } + + @Override + public synchronized Throwable fillInStackTrace() { + return super.fillInStackTrace(); + } +} diff --git a/src/main/java/weaver/xiao/commons/utils/DocImageFileUtil.java b/src/main/java/weaver/xiao/commons/utils/DocImageFileUtil.java new file mode 100644 index 0000000..9d2b53a --- /dev/null +++ b/src/main/java/weaver/xiao/commons/utils/DocImageFileUtil.java @@ -0,0 +1,292 @@ +package weaver.xiao.commons.utils; + +import aiyh.utils.excention.CustomerException; +import org.apache.log4j.Logger; +import weaver.docs.docs.DocImageManager; +import weaver.docs.webservices.DocInfo; +import weaver.docs.webservices.DocServiceImpl; +import weaver.file.ImageFileManager; +import weaver.general.IOUtils; +import weaver.hrm.User; +import weaver.xiao.commons.config.entity.WeaverFile; + +import java.io.*; +import java.nio.charset.Charset; +import java.nio.file.Files; +import java.nio.file.Paths; +import java.util.Enumeration; +import java.util.List; +import java.util.zip.ZipEntry; +import java.util.zip.ZipFile; +import java.util.zip.ZipOutputStream; + + +/** + * @author XiaoBokang + * @create 2022/7/28 16:05 + */ + +public class DocImageFileUtil { + + private static final Logger logger = LogUtil.getLogger(); + + public static final String DOC = "doc"; + public static final String XLS = "xls"; + public static final String PPTX = "pptx"; + public static final String PPT = "ppt"; + public static final String WPS = "wps"; + public static final String DOCX = "docx"; + public static final String XLSX = "xlsx"; + private static final int BUFFER_SIZE = 2 * 1024; + + /** + *

zip解压

+ * @param srcFile zip源文件 + * @param destDirPath 解压后的目标文件夹 + * @throws RuntimeException 解压失败会抛出运行时异常 + */ + public static void unZip(File srcFile, String destDirPath) throws RuntimeException { + long start = System.currentTimeMillis(); + // 判断源文件是否存在 + if (!srcFile.exists()) { + throw new RuntimeException(srcFile.getPath() + "所指文件不存在"); + } + // 开始解压 + ZipFile zipFile = null; + try { + zipFile = new ZipFile(srcFile, Charset.forName("GBK")); + Enumeration entries = zipFile.entries(); + while (entries.hasMoreElements()) { + ZipEntry entry = (ZipEntry) entries.nextElement(); + System.out.println("解压" + entry.getName()); + // 如果是文件夹，就创建个文件夹 + if (entry.isDirectory()) { + String dirPath = destDirPath + "/" + entry.getName(); + File dir = new File(dirPath); + dir.mkdirs(); + } else { + // 如果是文件，就先创建一个文件，然后用io流把内容copy过去 + File targetFile = new File(destDirPath + "/" + entry.getName()); + // 保证这个文件的父文件夹必须存在 + if(!targetFile.getParentFile().exists()){ + targetFile.getParentFile().mkdirs(); + } + targetFile.createNewFile(); + // 将压缩文件内容写入到这个文件中 + InputStream is = zipFile.getInputStream(entry); + FileOutputStream fos = new FileOutputStream(targetFile); + int len; + byte[] buf = new byte[BUFFER_SIZE]; + while ((len = is.read(buf)) != -1) { + fos.write(buf, 0, len); + } + // 关流顺序，先打开的后关闭 + fos.close(); + is.close(); + } + } + } catch (Exception e) { + logger.info("解压文件出现异常 ==>"+LogUtil.getExceptionStr(e)); + throw new RuntimeException("unzip error from ZipUtils", e); + } finally { + if(zipFile != null){ + try { + zipFile.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + } + } + + /** + *

压缩成ZIP方法

+ * @param srcFiles 需要压缩的文件列表 + * @param out 压缩文件输出流 + * @throws RuntimeException 压缩失败会抛出运行时异常 + */ + public static void toZip(List srcFiles , OutputStream out)throws Exception { + long start = System.currentTimeMillis(); + ZipOutputStream zos = null ; + try { + zos = new ZipOutputStream(out); + for (File srcFile : srcFiles) { + byte[] buf = new byte[BUFFER_SIZE]; + zos.putNextEntry(new ZipEntry(srcFile.getName())); + int len; + FileInputStream in = new FileInputStream(srcFile); + while ((len = in.read(buf)) != -1){ + zos.write(buf, 0, len); + } + zos.closeEntry(); + in.close(); + } + long end = System.currentTimeMillis(); + System.out.println("压缩完成，耗时：" + (end - start) +" ms"); + } catch (Exception e) { + logger.info("压缩文件出现异常 ==>"+LogUtil.getExceptionStr(e)); + throw new RuntimeException("zip error from ZipUtils",e); + }finally{ + if(zos != null){ + try { + zos.close(); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + + /** + * 在指定目录下生成对应的压缩文件 + * @param fileList 文件集合列表 + * @param dirPath 目录 + * @param fileName 压缩文件名 + */ + public static void toZipFileName(List fileList,String dirPath,String fileName) throws IOException { + String filePath = dirPath + File.separator + fileName; + File file = new File(filePath); + if(!file.exists()){ + file.createNewFile(); + } + OutputStream outputStream = Files.newOutputStream(file.toPath()); + toZipByWeaverFile(fileList,outputStream); + } + + /** + * 将文件集合压缩 + * @param fileList 文件信息集合 + * @param outputStream 压缩文件输出流 + */ + public static void toZipByWeaverFile(List fileList, OutputStream outputStream){ + ZipOutputStream zos = null ; + try { + zos = new ZipOutputStream(outputStream); + for (WeaverFile weaverFile : fileList) { + byte[] buf = new byte[BUFFER_SIZE]; + zos.putNextEntry(new ZipEntry(weaverFile.getFileName())); + int len; + InputStream inputStream = weaverFile.getInputStream(); + while ((len = inputStream.read(buf)) != -1){ + zos.write(buf, 0, len); + } + inputStream.close(); + zos.closeEntry(); + } + zos.flush(); + } catch (Exception e) { + e.printStackTrace(); + throw new RuntimeException("zip error from ZipUtils",e); + }finally{ + if(zos != null){ + try { + zos.finish(); + zos.close(); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + } + + /** + *

创建物理文件

+ * @param content 文件流 + * @param fileName 文件名 + * @return 文件id + */ + public static int createFileByInputSteam(InputStream content, String fileName) { + ImageFileManager imageFileManager = new ImageFileManager(); + int imgFileId = -1; + try { + ImageFileManager.class.getMethod("saveImageFileByInputStream", InputStream.class, String.class); + imgFileId = imageFileManager.saveImageFileByInputStream(content, fileName); + } catch (NoSuchMethodException e) { + imageFileManager.setImagFileName(fileName); + try { + imageFileManager.setData(IOUtils.toBytes(content)); + } catch (Exception ex) { + throw new CustomerException("创建文件失败，文件流转换失败", e); + } + imgFileId = imageFileManager.saveImageFile(); + } catch (Exception e) { + throw new CustomerException("创建文件失败"); + } + return imgFileId; + } + + /** + *

创建文件信息，文件权限继承文档目录权限

+ * + * @param fileName 文件名称 + * @param secCategory 文件目录 + * @param imageFileId 物理文件ID + * @param userId 用户ID + * @return 文档ID + * @throws Exception 可能会出现的异常 + */ + public static int createDocByImageFileId(String fileName, int secCategory, int imageFileId, int userId) throws Exception { + DocInfo docInfo = new DocInfo(); + docInfo.setImagefileId(imageFileId); + docInfo.setSeccategory(secCategory); + docInfo.setDocSubject(fileName); + docInfo.setDoccontent(""); + DocServiceImpl docService = new DocServiceImpl(); + int docId = docService.createDocByUser(docInfo, new User(userId)); + DocImageManager imgManger = new DocImageManager(); + imgManger.resetParameter(); + imgManger.setDocid(docId); + imgManger.setImagefileid(imageFileId); + imgManger.setImagefilename(fileName); + imgManger.setIsextfile("1"); + String ext = fileName.substring(fileName.lastIndexOf(".") + 1); + if (DOC.equalsIgnoreCase(ext)) { + imgManger.setDocfiletype("3"); + } else if (XLS.equalsIgnoreCase(ext)) { + imgManger.setDocfiletype("4"); + } else if (PPT.equalsIgnoreCase(ext)) { + imgManger.setDocfiletype("5"); + } else if (WPS.equalsIgnoreCase(ext)) { + imgManger.setDocfiletype("6"); + } else if (DOCX.equalsIgnoreCase(ext)) { + imgManger.setDocfiletype("7"); + } else if (XLSX.equalsIgnoreCase(ext)) { + imgManger.setDocfiletype("8"); + } else if (PPTX.equalsIgnoreCase(ext)) { + imgManger.setDocfiletype("9"); + } else { + imgManger.setDocfiletype("2"); + } + imgManger.AddDocImageInfo(); + return docId; + } + + + /** + * 删除临时文件 + * @param tempFilePath 临时文件路径 + */ + public static void deleteTempFile(String tempFilePath){ + logger.info("=========删除临时文件："+tempFilePath+"================"); + boolean deleteFlag = true; + int n = 0; + while (deleteFlag) { + try { + n++; + Files.delete(Paths.get(tempFilePath)); + deleteFlag = false; + } catch (Exception e) { + //设置线程沉睡500毫秒，等待jvm进行垃圾回收，将持有临时文件的流对象回收，确保临时文件能删除 + try { + Thread.sleep(500); + } catch (InterruptedException interruptedException) { + deleteFlag = false; + } + if (n > 5) { + deleteFlag = false; + } + } + } + } + +} diff --git a/src/main/java/weaver/xiao/commons/utils/HttpManager.java b/src/main/java/weaver/xiao/commons/utils/HttpManager.java new file mode 100644 index 0000000..7ffa86c --- /dev/null +++ b/src/main/java/weaver/xiao/commons/utils/HttpManager.java @@ -0,0 +1,98 @@ +package weaver.xiao.commons.utils; + +import org.apache.http.client.CredentialsProvider; +import org.apache.http.client.config.RequestConfig; +import org.apache.http.conn.ssl.NoopHostnameVerifier; +import org.apache.http.conn.ssl.SSLConnectionSocketFactory; +import org.apache.http.impl.client.CloseableHttpClient; +import org.apache.http.impl.client.HttpClientBuilder; +import org.apache.http.impl.client.HttpClients; +import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; +import org.apache.http.ssl.SSLContextBuilder; + +import javax.net.ssl.HostnameVerifier; +import javax.net.ssl.SSLContext; +import java.security.KeyManagementException; +import java.security.KeyStoreException; +import java.security.NoSuchAlgorithmException; + + +/** + * @author XiaoBokang + * @create 2021/12/7 14:19 + */ + +public class HttpManager { + + /** + * 创建连接池管理对象 + */ + + + private static final int CONNECT_TIMEOUT = 1000 * 60 * 3; + private static final int CONNECTION_REQUEST_TIMEOUT = 1000 * 60 * 3; + private static final int SOCKET_TIMEOUT = 10000 * 60 * 3; + private static final int MAX_TOTAL = 500; + private static final int MAX_PRE_ROUTE = 500; + + /** + * 设置请求配置 + */ + static RequestConfig requestConfig = RequestConfig.custom() + //网络请求的超时时间 + .setConnectTimeout(CONNECT_TIMEOUT) + //连接池去获取连接的超时时间 + .setConnectionRequestTimeout(CONNECTION_REQUEST_TIMEOUT) + //设置socket超时时间 + .setSocketTimeout(SOCKET_TIMEOUT) + .build(); + static PoolingHttpClientConnectionManager manager = new PoolingHttpClientConnectionManager(); + static { + // 配置最大的连接数 + manager.setMaxTotal(MAX_TOTAL); + // 每个路由最大连接数（路由是根据host来管理的，大小不好控制） + manager.setDefaultMaxPerRoute(MAX_PRE_ROUTE); + } + + /** + * 获取连接对象 从连接池里面去获取，根据url创建对应的对象，http / https + * @param url 请求地址 + * @return 连接对象 + */ + public static CloseableHttpClient getHttpConnection(String url, CredentialsProvider credentialsProvider){ + if(url.trim().toUpperCase().startsWith("https".toUpperCase())){ + SSLContext sslContext; + SSLConnectionSocketFactory sslsf = null; + try { + sslContext = new SSLContextBuilder().loadTrustMaterial(null, (x509Certificates, s) -> { +// 绕过所有验证 + return true; + }).build(); + HostnameVerifier hostnameVerifier = NoopHostnameVerifier.INSTANCE; + sslsf = new SSLConnectionSocketFactory(sslContext,hostnameVerifier); + } catch (NoSuchAlgorithmException | KeyStoreException | KeyManagementException e) { + e.printStackTrace(); + } + HttpClientBuilder httpClientBuilder = HttpClients.custom() + .setSSLSocketFactory(sslsf) + .setConnectionManager(manager) + .setConnectionManagerShared(true) + .setDefaultRequestConfig(requestConfig); + if(credentialsProvider != null){ + httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider); + } + return httpClientBuilder + .build(); + }else{ + HttpClientBuilder httpClientBuilder = HttpClients.custom() + .setConnectionManager(manager) + .setDefaultRequestConfig(requestConfig) + .setConnectionManagerShared(true); + if(credentialsProvider != null){ + httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider); + } + return httpClientBuilder + .build(); + } + } +} diff --git a/src/main/java/weaver/xiao/commons/utils/RequestUtil.java b/src/main/java/weaver/xiao/commons/utils/RequestUtil.java index e8073b6..8fc8a73 100644 --- a/src/main/java/weaver/xiao/commons/utils/RequestUtil.java +++ b/src/main/java/weaver/xiao/commons/utils/RequestUtil.java @@ -10,9 +10,9 @@ import org.apache.http.entity.mime.HttpMultipartMode; import org.apache.http.entity.mime.MultipartEntityBuilder; import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.util.EntityUtils; +import weaver.wechat.request.HttpManager; import weaver.xiao.commons.exception.RequestException; import weaver.zwl.common.ToolUtil; -import weaver.wechat.request.HttpManager; import javax.ws.rs.core.MediaType; import java.io.IOException; diff --git a/src/main/java/weaver/xiao/commons/utils/SFTPClientUtil.java b/src/main/java/weaver/xiao/commons/utils/SFTPClientUtil.java new file mode 100644 index 0000000..ddea61e --- /dev/null +++ b/src/main/java/weaver/xiao/commons/utils/SFTPClientUtil.java @@ -0,0 +1,221 @@ +package weaver.xiao.commons.utils; + +import com.jcraft.jsch.*; +import org.apache.log4j.Logger; + +import java.io.File; +import java.io.FileOutputStream; +import java.nio.file.Files; +import java.util.Iterator; +import java.util.Properties; +import java.util.Vector; + +/** + * @author XiaoBokang + * @create 2022/8/10 12:07 + */ + +public class SFTPClientUtil { + + private final Logger logger = LogUtil.getLogger(); + + /** + * 连接sftp服务器 + * @param host 主机 + * @param port 端口 + * @param username 用户名 + * @param password 密码 + * @return + */ + public ChannelSftp connect(String host, int port, String username, String password) { + ChannelSftp sftp = null; + Channel channel=null; + Session sshSession=null; + try { + JSch jsch = new JSch(); + jsch.getSession(username, host, port); + sshSession = jsch.getSession(username, host, port); + if(logger.isInfoEnabled()){ + logger.info("***************** Session created. **********************"); + logger.info("***************** stf host is "+host+"port is "+port+" username is "+username+" password is "+password+"**********************"); + } + sshSession.setPassword(password); + Properties sshConfig = new Properties(); + sshConfig.put("StrictHostKeyChecking", "no"); + sshSession.setConfig(sshConfig); + sshSession.connect(); + if(logger.isInfoEnabled()){ + logger.info("***************** Session connected. **********************"); + logger.info("***************** Opening Channel. **********************"); + } + channel = sshSession.openChannel("sftp"); + channel.connect(); + sftp = (ChannelSftp) channel; + if(logger.isInfoEnabled()){ + logger.info("***************** Connected to " + host + ". **********************"); + } + } catch (Throwable e) { + if (channel!=null) { + try { + channel.disconnect(); + }catch(Throwable e1) { + } + } + + if (sshSession!=null) { + try { + sshSession.disconnect(); + }catch(Throwable e1) { + } + } + + logger.error(e.getMessage(), e); + } + return sftp; + } + + /** + * 关闭连接 + * @param sftp + */ + public void disconnect(String host, ChannelSftp sftp){ + // 关闭连接 + try { + if (null != sftp) { + sftp.disconnect(); + if(logger.isInfoEnabled()){ + logger.info("***************** Closing Channel. **********************"); + } + if (null != sftp.getSession()) { + sftp.getSession().disconnect(); + if(logger.isInfoEnabled()){ + logger.info("***************** Session disconnect. **********************"); + } + } + } + if (logger.isInfoEnabled()) { + logger.info("**************** Disconnect to " + host + ". *******************"); + } + } catch (Exception e) { + e.printStackTrace(); + } + } + + /** + * 判断目录下是否存在文件或者文件夹 + * @param directory 目录 + * @param fileName 文件 + * @param sftp 连接 + * @return 是否存在 + */ + public boolean isExist(String directory, String fileName, ChannelSftp sftp) { + try { + Vector v = listFiles(directory, sftp); + Iterator it = v.iterator(); + while (it.hasNext()) { + ChannelSftp.LsEntry entry = it.next(); + String flName = entry.getFilename(); + if (flName.equals(fileName)) { + return true; + } + } + } catch (SftpException e) { + e.printStackTrace(); + } + return false; + } + + /** + * 上传文件 + * @param directory 上传的目录 + * @param uploadFile 要上传的文件 + * @param sftp 连接 + */ + public boolean upload(String directory, String uploadFile, ChannelSftp sftp) { + boolean successFlg = true; + try { + sftp.cd(directory); + File file = new File(uploadFile); + sftp.put(Files.newInputStream(file.toPath()), file.getName()); + if(logger.isInfoEnabled()){ + logger.info("***************** Finished **********************"); + } + } catch (Exception e) { + successFlg = false; + logger.info(LogUtil.getExceptionStr(e)); + } + return successFlg; + } + + /** + * 下载文件 + * @param directory 下载目录 + * @param downloadFile 下载的文件 + * @param saveFile 存在本地的路径 + * @param sftp 连接 + */ + public boolean download(String directory, String downloadFile, String saveFile, ChannelSftp sftp) { + boolean successFlg = true; + try { + sftp.cd(directory); + File file = new File(saveFile); + if(!file.getParentFile().exists()){ + file.getParentFile().mkdirs(); + } + sftp.get(downloadFile, new FileOutputStream(file)); + if(logger.isInfoEnabled()){ + logger.info("***************** Finished **********************"); + } + } catch (Exception e) { + successFlg = false; + logger.info(LogUtil.getExceptionStr(e)); + } + return successFlg; + } + + /** + * 删除文件 + * @param directory 要删除文件所在目录 + * @param deleteFile 要删除的文件 + * @param sftp 连接 + */ + public void delete(String directory, String deleteFile, ChannelSftp sftp) { + try { + sftp.cd(directory); + sftp.rm(deleteFile); + if(logger.isInfoEnabled()){ + logger.info("***************** Finished **********************"); + } + if (null != sftp) { + sftp.disconnect(); + if (null != sftp.getSession()) { + sftp.getSession().disconnect(); + } + } + } catch (Exception e) { + e.printStackTrace(); + } + } + + /** + * 列出目录下的文件 + * @param directory 要列出的目录 + * @param sftp 连接 + * @return + * @throws SftpException + */ + @SuppressWarnings("unchecked") + public Vector listFiles(String directory, ChannelSftp sftp) throws SftpException { + return sftp.ls(directory); + } + + /** + * 判断本地路径是否存在，不存在就创建路径 + */ + public void makeDirs(String localSavePath) { + File localFile = new File(localSavePath); + if (!localFile.exists()) { + localFile.mkdirs(); + } + } +} diff --git a/src/main/java/weaver/xiao/commons/utils/SqlUtil.java b/src/main/java/weaver/xiao/commons/utils/SqlUtil.java index 8d6a386..12e6bf6 100644 --- a/src/main/java/weaver/xiao/commons/utils/SqlUtil.java +++ b/src/main/java/weaver/xiao/commons/utils/SqlUtil.java @@ -8,7 +8,6 @@ import weaver.general.TimeUtil; import weaver.general.Util; import weaver.xiao.commons.utils.annotation.SqlFieldMapping; - import java.lang.reflect.Field; import java.util.*; @@ -59,6 +58,7 @@ public class SqlUtil { case 2:{ valueText = this.getFieldVal(fieldType,value); }break; + default:break; } field.set(res,valueText); } @@ -78,18 +78,51 @@ public class SqlUtil { */ public Object getFieldVal(Class fieldType,String tempValue){ Object fieldVal = null; - if(fieldType.equals(int.class)){ + if(fieldType.equals(Integer.class)){ fieldVal = Util.getIntValue(tempValue); }else if(fieldType.equals(String.class)){ fieldVal = Util.null2String(tempValue); - }else if(fieldType.equals(boolean.class)){ + }else if(fieldType.equals(Boolean.class)){ fieldVal = Boolean.parseBoolean(tempValue); + }else if(fieldType.equals(Double.class)){ + fieldVal = Util.getDoubleValue(tempValue,0.0); }else { fieldVal = ""; } return fieldVal; } + /** + * 根据表名和条件获取结果集 + * @param tableName 表名 + * @param param 参数 + * @return 数据集合 + */ + public RecordSet getTableMessage(String tableName, Map param){ + List paramList = new ArrayList<>(); + RecordSet recordSet = new RecordSet(); + Set> entries = param.entrySet(); + StringBuilder whereBuilder = new StringBuilder(); + whereBuilder.append("select * from ").append(tableName); + for (Map.Entry entry : entries) { + if("cusSql".equals(entry.getKey())){ + whereBuilder.append(" and ").append(entry.getValue()); + continue; + } + whereBuilder.append(" and ") + .append(entry.getKey()) + .append(" = ? "); + paramList.add(entry.getValue()); + } + String whereStr = whereBuilder.toString(); + if(!"".equals(whereStr)){ + whereStr = whereStr.replaceFirst(" and"," where"); + } + logger.info("执行查询的sql>>>" + whereStr + " paramList>>>" + paramList); + recordSet.executeQuery(whereStr,paramList); + return recordSet; + } + /** * 构建更新语句 * @param tableName 表名 @@ -120,6 +153,10 @@ public class SqlUtil { updateBuilder.append(tableName).append(" set "); Set> updateEntries = updateParam.entrySet(); for (Map.Entry updateEntry : updateEntries) { + if("cusSql".equals(updateEntry.getKey())){ + updateBuilder.append(updateEntry.getValue()); + continue; + } updateBuilder.append(updateEntry.getKey()) .append(" = ?,"); paramList.add(updateEntry.getValue()); @@ -127,6 +164,10 @@ public class SqlUtil { StringBuilder whereBuilder = new StringBuilder(); Set> whereEntries = whereParam.entrySet(); for (Map.Entry whereEntry : whereEntries) { + if("cusSql".equals(whereEntry.getKey())){ + whereBuilder.append(" and ").append(whereEntry.getValue()); + continue; + } whereBuilder.append(" and ") .append(whereEntry.getKey()) .append(" = ? "); @@ -257,4 +298,22 @@ public class SqlUtil { return modeId; } + /** + * 全角转半角 + * @param input + * @return + */ + public String toDBC(String input) { + char c[] = input.toCharArray(); + for (int i = 0; i < c.length; i++) { + if (c[i] == '\u3000') { + c[i] = ' '; + } else if (c[i] > '\uFF00' && c[i] < '\uFF5F') { + c[i] = (char) (c[i] - 65248); + } + } + String returnString = new String(c); + return returnString; + } + } diff --git a/src/main/java/weaver/xiao/commons/utils/VerifyUtil.java b/src/main/java/weaver/xiao/commons/utils/VerifyUtil.java new file mode 100644 index 0000000..b727a0a --- /dev/null +++ b/src/main/java/weaver/xiao/commons/utils/VerifyUtil.java @@ -0,0 +1,328 @@ +package weaver.xiao.commons.utils; + +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.type.CollectionType; +import org.apache.log4j.Logger; +import org.jdom.Document; +import org.jdom.input.SAXBuilder; +import org.xml.sax.InputSource; +import weaver.xiao.commons.exception.ValueDealException; +import weaver.xiao.commons.exception.VerifyException; +import weaver.xiao.commons.utils.annotation.JsonParse; +import weaver.xiao.commons.utils.annotation.RequiredVerify; + +import javax.xml.bind.JAXBContext; +import javax.xml.bind.Marshaller; +import javax.xml.bind.Unmarshaller; +import java.io.InputStream; +import java.io.StringReader; +import java.io.StringWriter; +import java.lang.reflect.Field; +import java.lang.reflect.Method; +import java.lang.reflect.ParameterizedType; +import java.lang.reflect.Type; +import java.util.*; + +/** + * @author XiaoBokang + * @create 2022/7/28 12:38 + */ + +public class VerifyUtil { + + private static final Logger logger = LogUtil.getLogger(); + + public static void requireVerify(T t) throws IllegalAccessException { + Class clazz = t.getClass(); + Field[] declaredFields = clazz.getDeclaredFields(); + for (Field declaredField : declaredFields) { + declaredField.setAccessible(true); + boolean annotationPresent = declaredField.isAnnotationPresent(RequiredVerify.class); + if (annotationPresent) { + Object value = declaredField.get(t); + Class type = declaredField.getType(); + boolean valueIsNull = isNull(type, value); + RequiredVerify annotation = declaredField.getAnnotation(RequiredVerify.class); + if (valueIsNull) { + throw new VerifyException(annotation.value()); + } + } + } + } + + public static T xmlStrToObject(Class clazz, String xmlStr) throws Exception { + T t = null; + JAXBContext context = JAXBContext.newInstance(clazz); + // 进行将Xml转成对象的核心接口 + Unmarshaller unmarshaller = context.createUnmarshaller(); + StringReader sr = new StringReader(xmlStr); + t = (T) unmarshaller.unmarshal(sr); + dealJsonStr(clazz, t); + return t; + } + + public static T xmlStrToObject(Class clazz, InputStream inputStream) throws Exception { + T t = null; + JAXBContext context = JAXBContext.newInstance(clazz); + // 进行将Xml转成对象的核心接口 + Unmarshaller unmarshaller = context.createUnmarshaller(); + t = (T) unmarshaller.unmarshal(inputStream); + dealJsonStr(clazz, t); + return t; + } + + private static T dealJsonStr(Class clazz, T t) throws Exception { + Field[] declaredFields = clazz.getDeclaredFields(); + for (Field declaredField : declaredFields) { + declaredField.setAccessible(true); + boolean annotationPresent = declaredField.isAnnotationPresent(JsonParse.class); + if (annotationPresent) { + JsonParse annotation = declaredField.getAnnotation(JsonParse.class); + String sourceFieldName = annotation.value(); + Field sourceField = clazz.getDeclaredField(sourceFieldName); + String sourceMethodName = "get" + sourceFieldName.substring(0, 1).toUpperCase() + sourceFieldName.substring(1); + Method declaredMethod = clazz.getDeclaredMethod(sourceMethodName); + Object sourceValue = declaredMethod.invoke(t); + Class sourceType = sourceField.getType(); + if (isNotNull(sourceType, sourceValue)) { + ObjectMapper objectMapper = new ObjectMapper(); + String targetFieldName = declaredField.getName(); + Class targetType = declaredField.getType(); + String targetMethodName = "set" + targetFieldName.substring(0, 1).toUpperCase() + targetFieldName.substring(1); + Method targetMethod = clazz.getDeclaredMethod(targetMethodName, targetType); + if (targetType.equals(List.class)) { + Type genericType = declaredField.getGenericType(); + ParameterizedType pt = (ParameterizedType) genericType; + //得到泛型里的class类型对象 + Class genericClazz = (Class) pt.getActualTypeArguments()[0]; + CollectionType listType = objectMapper.getTypeFactory().constructCollectionType(ArrayList.class, genericClazz); + List list = objectMapper.readValue(sourceValue.toString(), listType); + targetMethod.invoke(t, list); + } else { + Object o = objectMapper.readValue(sourceValue.toString(), targetType); + targetMethod.invoke(t, o); + } + } + } + } + return t; + } + + public static String beanToXml(T t, String encoding) { + String xmlStr = ""; + try { + //1、创建上下文 + JAXBContext context = JAXBContext.newInstance(t.getClass()); + StringWriter writer = new StringWriter(); + //2、创建Marshaller 这个是用于转换成xml的 + Marshaller marshaller = context.createMarshaller(); + //3、设置marshaller的属性 + //JAXB_FORMATTED_OUTPUT：格式化 + //JAXB_ENCODING:编码格式 + marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true); + marshaller.setProperty(Marshaller.JAXB_ENCODING, encoding); + //4、将实体类读取到writer中 + marshaller.marshal(t, writer); + xmlStr = writer.toString(); + } catch (Exception e) { + logger.info("java bean 转换 xml异常 ==>" + LogUtil.getExceptionStr(e)); + } + return xmlStr; + } + + public static String mapToXml(Map map) { + StringBuilder stringBuilder = new StringBuilder(); + stringBuilder.append("").append("\n").append("").append("\n"); + String xmlBody = mapDeal(map); + stringBuilder.append(xmlBody).append(""); + return stringBuilder.toString(); + } + + public static String mapDeal(Map map) { + StringBuilder stringBuilder = new StringBuilder(); + Set> entries = map.entrySet(); + for (Map.Entry entry : entries) { + String key = entry.getKey(); + Object value = entry.getValue(); + stringBuilder.append("\t").append("<").append(key).append(">"); + if (value instanceof Map) { + String s = mapDeal((Map) value); + stringBuilder.append(s); + } else if (value instanceof List) { + String nodeName = "node"; + String s = listDeal((List) value, nodeName); + stringBuilder.append(s); + } else { + stringBuilder.append(value); + } + stringBuilder.append("").append("\n"); + } + return stringBuilder.toString(); + } + + public static String listDeal(List list, String nodeName) { + StringBuilder stringBuilder = new StringBuilder(); + for (Object o : list) { + stringBuilder.append("\t").append("<").append(nodeName).append(">"); + if (o instanceof Map) { + String s = mapToXml((Map) o); + stringBuilder.append(s); + } else if (o instanceof List) { + throw new ValueDealException("不支持嵌套list"); + } else { + stringBuilder.append(o); + } + stringBuilder.append("").append("\n"); + } + return stringBuilder.toString(); + } + + + public static Document convertStringToDocument(String xmlStr) { + SAXBuilder sb = new SAXBuilder(); + try { + return sb.build(new InputSource(new StringReader(xmlStr))); + } catch (Exception e) { + logger.info("xml字符串解析异常 ==>" + LogUtil.getExceptionStr(e)); + } + return null; + } + + public static Document convertStringToDocument(InputStream inputStream) { + SAXBuilder sb = new SAXBuilder(); + try { + return sb.build(inputStream); + } catch (Exception e) { + logger.info("xml字符串解析异常 ==>" + LogUtil.getExceptionStr(e)); + } + return null; + } + + + public static boolean isNull(Class type, Object value) { + if (type.equals(String.class)) { + return isBlank(value); + } else { + return value == null; + } + } + + public static boolean isNotNull(Class type, Object value) { + return !isNull(type, value); + } + + + public static boolean isNotBlank(Object value) { + return !isBlank(value); + } + + public static boolean isBlank(Object value) { + if (value == null) { + return true; + } + String cs = String.valueOf(value); + int strLen; + if ((strLen = cs.length()) == 0) { + return true; + } + for (int i = 0; i < strLen; i++) { + if (!Character.isWhitespace(cs.charAt(i))) { + return false; + } + } + return true; + } + + /** + *

驼峰转下划线

+ * @param sourceMap 原参数 + * @return 转换后的map + */ + public static Map humpToUnderlineMap(Map sourceMap) { + return paramConversion(sourceMap, 2); + } + + /** + *

下划线转驼峰

+ * @param sourceMap 原参数 + * @return 转换后的map + */ + public static Map underlineToHumpMap(Map sourceMap) { + return paramConversion(sourceMap, 1); + } + + /** + *

参数转换

+ * @param sourceMap 原参数信息 + * @param conversionType 转换类型 1：下划线转驼峰；2：驼峰转下划线 + * @return 转换后的map + */ + public static Map paramConversion(Map sourceMap, int conversionType) { + if (sourceMap == null || sourceMap.isEmpty()) { + return sourceMap; + } + Map targetMap = new HashMap<>(); + Set> entries = sourceMap.entrySet(); + for (Map.Entry entry : entries) { + String key = entry.getKey(); + Object value = entry.getValue(); + if (conversionType == 1) { + key = toCamelCase(key); + } else { + key = toUnderlineCase(key); + } + targetMap.put(key, value); + } + return targetMap; + } + + /** + *

驼峰转下划线方法

+ * @param sourceString 原字符串 + * @return 转换后字符串 + */ + public static String toUnderlineCase(String sourceString) { + if (VerifyUtil.isBlank(sourceString)) { + return sourceString; + } + StringBuffer stringBuffer = new StringBuffer(); + char[] chars = sourceString.toCharArray(); + for (char aChar : chars) { + if (aChar >= 65 && aChar <= 90) { + stringBuffer.append("_").append(aChar += 32); + } else { + stringBuffer.append(aChar); + } + } + return stringBuffer.toString(); + } + + /** + *

下划线转驼峰

+ * @param sourceString 原字符串 + * @return 转换后字符串 + */ + public static String toCamelCase(String sourceString) { + if (VerifyUtil.isBlank(sourceString)) { + return sourceString; + } + StringBuffer stringBuffer = new StringBuffer(); + char[] chars = sourceString.toCharArray(); + boolean isConversion = false; + for (char aChar : chars) { + //判断是否为'_' + if (aChar == 95) { + isConversion = true; + continue; + } + if (isConversion) { + stringBuffer.append(aChar -= 32); + isConversion = false; + } else { + stringBuffer.append(aChar); + } + } + return stringBuffer.toString(); + } + +} diff --git a/src/main/java/weaver/xiao/commons/utils/annotation/JsonParse.java b/src/main/java/weaver/xiao/commons/utils/annotation/JsonParse.java new file mode 100644 index 0000000..daaf8c4 --- /dev/null +++ b/src/main/java/weaver/xiao/commons/utils/annotation/JsonParse.java @@ -0,0 +1,19 @@ +package weaver.xiao.commons.utils.annotation; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +/** + *

标记于字段上用于JSON转换

+ * + * @author XiaoBokang + * @create 2022/8/5 15:13 + */ + +@Target({ElementType.FIELD}) +@Retention(RetentionPolicy.RUNTIME) +public @interface JsonParse { + String value(); +} diff --git a/src/main/java/weaver/xiao/commons/utils/annotation/RequiredVerify.java b/src/main/java/weaver/xiao/commons/utils/annotation/RequiredVerify.java new file mode 100644 index 0000000..fbbf43f --- /dev/null +++ b/src/main/java/weaver/xiao/commons/utils/annotation/RequiredVerify.java @@ -0,0 +1,17 @@ +package weaver.xiao.commons.utils.annotation; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +/** + * @author XiaoBokang + * @create 2022/7/28 12:11 + */ + +@Target({ElementType.FIELD,ElementType.TYPE}) +@Retention(RetentionPolicy.RUNTIME) +public @interface RequiredVerify { + String value(); +} diff --git a/src/test/java/youhong/ai/pcn/TestOrganization.java b/src/test/java/youhong/ai/pcn/TestOrganization.java index 89992af..b2e6b87 100644 --- a/src/test/java/youhong/ai/pcn/TestOrganization.java +++ b/src/test/java/youhong/ai/pcn/TestOrganization.java @@ -224,24 +224,5 @@ public class TestOrganization extends BaseTest { System.out.println(JSON.toJSONString(orgChartTree)); } - @Test - public void testDownload() throws IOException { - HttpUtils httpUtils = new HttpUtils(); -// String url = "http://e-sign-dev-yace-web-alb-1694614450.cn-north-1.elb.amazonaws.com.cn:8070/contract/download?appId=100000&signType=SHA256&sign=OEI4RDA5RjMwRTE3Qzk1ODI0RkM3OENCQTA3QzZEQUFBQTgwRjM5MDdDMkIzQTIxNDFERDkyNUI5RDVFRjc4Qg==×tamp=2022-12-07%2014:32:08&bizContent=JTdCJTIyZG9jTm8lMjIlM0ElMjJjMGY5YzhjYTk5OTQ0MzZjYThjY2Y0MWVmMTZkMDUzYSUyMiU3RA=="; - String url = "https://apigwaws-lite.porsche-cloudservice.com/env-101/econtract/econtract/contract/api/v1/contract/download"; - String heard = "{\"apikey\":\"TulQxnZSRKeHoQfmeZzOUzGn6KpTDkDK\",\"appId\":\"100001\",\"bizContent\":\"JTdCJTIyY29udHJhY3RObyUyMiUzQSUyMjAwZDBkNmFlYzFkOTQzNGE4YjFlZjc5YzZjODcwNWFmJTIyJTdE\",\"sign\":\"M0I2NjhGRjgwNDY2RjM4MjRBMTg4RUQ0QUU0MkEzOUVEQTAxNTZCRTgwRDE3NzQ3RkQxMzZGOEE1M0FCODRGOA==\",\"signType\":\"SHA256\",\"Content-Type\":\"application/json\",\"timestamp\":\"2022-12-07 17:38:07\"} "; - Map map = JSONObject.parseObject(heard, Map.class); - FaRequestUtils.downContract(new HashMap() {{ - put("contractNo", "00d0d6aec1d9434a8b1ef79c6c8705af"); - }}, (map1, response) -> { - getFileName(response); - Header[] allHeaders = response.getAllHeaders(); - for (Header allHeader : allHeaders) { - System.out.println(allHeader); - } - return null; - }, url); - - } }