kaifabu/ChenyonUtils
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: kaifabu:cabf83391faabccdb5ba3de80dee6286ac407257
Branches Tags
kaifabu:main
...
compare: kaifabu:main
Branches Tags
kaifabu:main

1 Commits
cabf83391f ... main

Author SHA1 Message Date
RuicyWu
a59d3c076c 优化工具包代码 2026-02-10 14:21:18 +08:00
4 changed files with 536 additions and 9 deletions
Expand all files Collapse all files

11
src/main/java/com/seeyon/utils/form/EnumMapUtils.java
View File

@@ -1,6 +1,5 @@
package com.seeyon.utils.form;
import com.seeyon.cap4.form.bean.FormBean;
import com.seeyon.cap4.form.bean.FormFieldBean;
import com.seeyon.cap4.form.bean.FormTableBean;
import com.seeyon.ctp.common.AppContext;
@@ -15,13 +14,12 @@ import java.util.*;
public class EnumMapUtils {
public static String getEnumItemValueByDisplayValue(FormBean cap4FormBean,String fieldDisplay, String targetValue) {
public static String getEnumItemValueByDisplayValue(FormTableBean formTableBean,String fieldDisplay, String targetValue) {
if(targetValue == null || "null".equals(targetValue) || "".equals(targetValue)){
return null;
}
try {
FormTableBean masterTableBean = cap4FormBean.getMasterTableBean();
FormFieldBean beanByDisplay = masterTableBean.getFieldBeanByDisplay(fieldDisplay);
FormFieldBean beanByDisplay = formTableBean.getFieldBeanByDisplay(fieldDisplay);
if(beanByDisplay == null || beanByDisplay.getEnumId() == 0l) {
return null;
}
@@ -93,11 +91,10 @@ public class EnumMapUtils {
return null;
}
public static Set<String> getEnumItemValues(FormBean cap4FormBean, String fieldDisplay) {
public static Set<String> getEnumItemValues(FormTableBean formTableBean, String fieldDisplay) {
Set<String> set = new HashSet<>();
try {
FormTableBean masterTableBean = cap4FormBean.getMasterTableBean();
FormFieldBean beanByDisplay = masterTableBean.getFieldBeanByDisplay(fieldDisplay);
FormFieldBean beanByDisplay = formTableBean.getFieldBeanByDisplay(fieldDisplay);
if(beanByDisplay == null || beanByDisplay.getEnumId() == 0l) {
return set;
}

24
src/main/java/com/seeyon/utils/form/FormTableExecutor.java
View File

@@ -227,6 +227,28 @@ public class FormTableExecutor {
return 0;
}
public static int update(String tableName, List<FormUpdateField> fields, List<FormWhereCondition> conditions) {
if (fields == null || fields.isEmpty()) throw new IllegalArgumentException("更新字段不能为空");
if (conditions == null || conditions.isEmpty()) throw new IllegalArgumentException("UPDATE必须带条件");
SqlBuildParam param = new SqlBuildParam();
param.setSqlType(SqlType.UPDATE);
param.setTableName(tableName);
param.setConditions(conditions);
param.setUpdateFields(fields);
Map<String, Object> sqlMap = generateSql(param);
JDBCAgent agent = new JDBCAgent();
try {
return agent.execute((String) sqlMap.get("sql"), (List<Object>) sqlMap.get("params"));
} catch (Exception e){
log.error("执行sql为: " + sqlMap.get("sql"));
log.error("执行sql参数为: " + JsonUtils.toJSONString(sqlMap.get("params")));
log.error(e.getMessage(),e);
}finally {
agent.close();
}
return 0;
}
/*删除操作*/
public static int delete(TableContext ctx, List<FormWhereCondition> conditions) {
if (conditions == null || conditions.isEmpty()) throw new IllegalArgumentException("DELETE必须带条件");
@@ -356,7 +378,7 @@ public class FormTableExecutor {
sql.append(" order by "+ orderField +" desc");
}
if(limit != null && offset != null) {
sql.append(" "+ offset + "," + limit);
sql.append(" LIMIT "+ offset + "," + limit);
}
sql.append(";");
return buildResult(sql, params);

7
src/main/java/com/seeyon/utils/form/FormWhereCondition.java
View File

@@ -8,7 +8,7 @@ public class FormWhereCondition {
private String fieldName; //字段名
private Object value; //值
private List<Object> values; //值
private ClauseFactor clauseFactor; //条件因子 eq lt gt not_null null
private ClauseFactor clauseFactor = ClauseFactor.EQ; //条件因子 eq lt gt not_null null
private ClauseFactor concatFactor = ClauseFactor.AND; //拼接因子
private boolean startWithBracket = false; //是否以括号开头生成子条件
private boolean endWithBracket = false; //是否以括号结尾结束子条件
@@ -57,6 +57,11 @@ public class FormWhereCondition {
return this;
}
public FormWhereCondition fieldName(String fieldName) {
this.fieldName = fieldName;
return this;
}
public FormWhereCondition concatFactor(ClauseFactor concatFactor) {
this.concatFactor = concatFactor;
return this;

503
src/main/java/com/seeyon/utils/http/FileUtil.java Normal file
View File

@@ -0,0 +1,503 @@
package com.seeyon.utils.http;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.seeyon.ctp.common.AppContext;
import com.seeyon.ctp.common.SystemEnvironment;
import com.seeyon.ctp.common.exceptions.BusinessException;
import com.seeyon.ctp.common.filemanager.manager.AttachmentManager;
import com.seeyon.ctp.common.filemanager.manager.FileManager;
import com.seeyon.ctp.common.po.filemanager.Attachment;
import com.seeyon.ctp.organization.bo.V3xOrgAccount;
import com.seeyon.ctp.organization.bo.V3xOrgMember;
import com.seeyon.ctp.organization.manager.OrgManager;
import com.seeyon.ctp.services.FileUploadExporter;
import org.apache.commons.lang3.StringUtils;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import www.seeyon.com.utils.StringUtil;
import www.seeyon.com.utils.UUIDUtil;
import java.io.*;
import java.text.SimpleDateFormat;
import java.util.*;
public class FileUtil {
private static final long MAX_FILE_SIZE = 100 * 1024 * 1024; // 100MB
private static final String TEMP_DIR = System.getProperty("java.io.tmpdir") + File.separator + "seeyontempfile";
private static final String DEFAULT_FILENAME_PREFIX = "没有文件名_";
private static final String CATEGORY_CODE = "66";
private FileManager fileManager;
public void setFileManager(FileManager fileManager) {
this.fileManager = fileManager;
}
public FileManager getFileManager() {
if (fileManager == null) {
fileManager = (FileManager) AppContext.getBean("fileManager");
}
return fileManager;
}
private AttachmentManager attachmentManager;
public void setAttachmentManager(AttachmentManager attachmentManager) {
this.attachmentManager = attachmentManager;
}
public AttachmentManager getAttachmentManager() {
if (attachmentManager == null) {
attachmentManager = (AttachmentManager) AppContext.getBean("attachmentManager");
}
return attachmentManager;
}
public void isFilePath(String filePath) {
File directory = new File(filePath);
if (!directory.exists()) {
directory.mkdirs();
}
}
/**
* 上传附件
*
* @param fileNames
* @throws Exception
* @throws NumberFormatException
*/
public List<Attachment> fileUpload(List<String> fileNames, String summaryId, Long memberId, Long accountId) throws NumberFormatException, Exception {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
FileUploadExporter fileUpload = new FileUploadExporter();
List<Attachment> attachments = new ArrayList<Attachment>();
File f = null;
long l = UUIDUtil.getUUIDLong();
for (int i = 0; i < fileNames.size(); i++) {
String fileName = fileNames.get(i);
if (StringUtils.isNotEmpty(fileName)) {
f = new File(fileName);
if (!f.exists()) {
return null;
}
if (f.length() > 102400000) {
return null;
}
}
String[] strs = new String[]{f.getAbsolutePath()};
String s = fileUpload.processUpload(strs);
Map<String, String> map = new HashMap();
String attachName = f.getName();
String[] suffixNames = attachName.split("\\.");
map.put("type", "0");
map.put("fileUrl", s);
map.put("mimeType", "application/" + suffixNames[suffixNames.length - 1].toLowerCase());
map.put("size", f.length() + "");
map.put("subReference", l + "");
map.put("category", "66");
map.put("createdate", sdf.format(new Date()));
map.put("filename", f.getName());
map.put("reference", summaryId);
Attachment attachment = new Attachment(map);
attachments.add(attachment);
}
String str = getAttachmentManager().create(attachments, memberId, accountId);
return attachments;
}
public List<String> fieldFileDownload(Long refId, String path) throws BusinessException {
// 判断路径是否存在
File file = new File(path);
if (!file.exists()) {
file.mkdirs();
}
List<Long> fileUrls = getAttachmentManager().getBySubReference(refId);
System.out.println(fileUrls.size());
List<String> filepaths = new ArrayList<>();
for (Long fileUrl : fileUrls) {
Attachment attachment = getAttachmentManager().getAttachmentByFileURL(fileUrl);
InputStream inputStream = getFileManager().getFileInputStream(attachment.getFileUrl());
String filepath = path + attachment.getFilename();
try (OutputStream outputStream = new BufferedOutputStream(new FileOutputStream(filepath))) {
byte[] buffer = new byte[1024];
int bytesRead;
while ((bytesRead = inputStream.read(buffer)) != -1) {
outputStream.write(buffer, 0, bytesRead);
}
outputStream.flush();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
filepaths.add(filepath);
}
return filepaths;
}
public JSONArray getFileContent(String filePath) throws IOException {
JSONArray jsonArray = new JSONArray();
String houzhui = filePath.substring(filePath.lastIndexOf(".") + 1);
// 创建文件输入流
FileInputStream file = new FileInputStream(new File(filePath));
// 创建工作簿对象
Workbook workbook;
System.out.println("当前文件为"+houzhui+"后缀");
if ("xlsx".equals(houzhui) || "XLSX".equals(houzhui)) {
workbook = new XSSFWorkbook(file);
} else {
workbook = new HSSFWorkbook(file);
}
// 获取第一个工作表
Sheet sheet = workbook.getSheetAt(0);
// 迭代行
Iterator<Row> rowIterator = sheet.iterator();
// 根据行跳过设置
row : while (rowIterator.hasNext()) {
Row row = rowIterator.next();
if (row.getRowNum() < 2) {
continue;
}
int num = 0;
int bj = 0;
JSONObject jsonObject = new JSONObject();
JSONArray SPS = new JSONArray();
JSONObject SP = new JSONObject();
boolean isddh = false;
// 迭代单元格
Iterator<Cell> cellIterator = row.cellIterator();
cell : while (cellIterator.hasNext()) {
// 获取单元格对象
Cell cell = cellIterator.next();
// 单元格索引为1的数据（订单号）
if (cell.getColumnIndex() == 1) {
String ddh = "";
switch (cell.getCellType()) {
case STRING:
ddh = cell.getStringCellValue();
break;
case NUMERIC:
ddh = cell.getNumericCellValue()+"";
break;
default:
ddh = "";
}
// 如果当前订单号为空，则跳过当前行数据
// 查询当前订单号是否已经存在
for (int i = 0; i < jsonArray.size(); i++) {
JSONObject json = jsonArray.getJSONObject(i);
if (ddh.equals(json.getString("DDH"))) {
// 订单号已经存在
bj = i;
isddh = true;
jsonObject = json;
SPS = jsonObject.getJSONArray("SPS");
} else {
num++;
}
}
if (num == jsonArray.size()) {
// switch (cell.getCellType()) {
// case STRING:
jsonObject.put("DDH",ddh);
// break;
// case NUMERIC:
// jsonObject.put("DDH", cell.getNumericCellValue());
// break;
// default:
// jsonObject.put("DDH", "");
// }
//// jsonObject.put("DDH", cell.getStringCellValue());
}
}
switch (cell.getColumnIndex()) {
case 3:
if (!isddh) {
switch (cell.getCellType()) {
case STRING:
jsonObject.put("GMFMC", cell.getStringCellValue());
break;
case NUMERIC:
jsonObject.put("GMFMC", cell.getNumericCellValue());
break;
default:
jsonObject.put("GMFMC", "");
}
}
break;
case 4:
if (!isddh) {
switch (cell.getCellType()) {
case STRING:
jsonObject.put("GMFNSRSBH", cell.getStringCellValue());
break;
case NUMERIC:
jsonObject.put("GMFNSRSBH", cell.getNumericCellValue());
break;
default:
jsonObject.put("GMFNSRSBH", "");
}
}
break;
case 5:
if (!isddh) {
switch (cell.getCellType()) {
case STRING:
jsonObject.put("GMFYX", cell.getStringCellValue());
break;
case NUMERIC:
jsonObject.put("GMFYX", cell.getNumericCellValue());
break;
default:
jsonObject.put("GMFYX", "");
}
}
break;
case 6:
if (!isddh) {
switch (cell.getCellType()) {
case STRING:
jsonObject.put("GMFSJ", cell.getStringCellValue());
break;
case NUMERIC:
jsonObject.put("GMFSJ", cell.getNumericCellValue());
break;
default:
jsonObject.put("GMFSJ", "");
}
}
break;
case 17:
if (!isddh) {
switch (cell.getCellType()) {
case STRING:
jsonObject.put("BZ", cell.getStringCellValue());
break;
case NUMERIC:
jsonObject.put("BZ", cell.getNumericCellValue());
break;
default:
jsonObject.put("BZ", "");
}
}
break;
case 2:
switch (cell.getCellType()) {
case STRING:
SP.put("FXHXZ", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("FXHXZ", cell.getNumericCellValue());
break;
default:
SP.put("FXHXZ", "");
}
break;
case 7:
switch (cell.getCellType()) {
case STRING:
SP.put("XMMC", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("XMMC", cell.getNumericCellValue());
break;
default:
SP.put("XMMC", "");
}
break;
case 8:
switch (cell.getCellType()) {
case STRING:
SP.put("SPBM", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("SPBM", cell.getNumericCellValue());
break;
default:
SP.put("SPBM", "");
}
break;
case 9:
switch (cell.getCellType()) {
case STRING:
SP.put("GGXH", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("GGXH", cell.getNumericCellValue());
break;
default:
SP.put("GGXH", "");
}
break;
case 10:
switch (cell.getCellType()) {
case STRING:
SP.put("DW", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("DW", cell.getNumericCellValue());
break;
default:
SP.put("DW", "");
}
break;
case 11:
switch (cell.getCellType()) {
case STRING:
SP.put("NUM", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("NUM", cell.getNumericCellValue());
break;
default:
SP.put("NUM", "");
}
break;
case 12:
switch (cell.getCellType()) {
case STRING:
SP.put("SPDJ", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("SPDJ", cell.getNumericCellValue());
break;
default:
SP.put("SPDJ", "");
}
break;
case 13:
switch (cell.getCellType()) {
case STRING:
SP.put("JE", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("JE", cell.getNumericCellValue());
break;
default:
SP.put("JE", "");
}
break;
case 14:
switch (cell.getCellType()) {
case STRING:
SP.put("SL", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("SL", cell.getNumericCellValue());
break;
default:
SP.put("SL", "");
}
break;
case 15:
switch (cell.getCellType()) {
case STRING:
SP.put("ZKJE", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("ZKJE", cell.getNumericCellValue());
break;
default:
SP.put("ZKJE", "");
}
break;
case 16:
switch (cell.getCellType()) {
case STRING:
SP.put("YHZCBS", cell.getStringCellValue());
break;
case NUMERIC:
SP.put("YHZCBS", cell.getNumericCellValue());
break;
default:
SP.put("YHZCBS", "");
}
break;
}
}
if(StringUtil.isEmpty(jsonObject.getString("DDH"))){
continue row;
}
SPS.add(SP);
jsonObject.put("SPS", SPS);
if (num == jsonArray.size()) {
jsonArray.add(jsonObject);
} else {
jsonArray.set(bj, jsonObject);
}
}
// 关闭工作簿
workbook.close();
file.close();
return jsonArray;
}
public JSONArray getFileContent(long fileId) throws IOException {
System.out.println("获取参数附件ID"+fileId);
// 附件路径
String path = SystemEnvironment.getApplicationFolder()+"/hxinvoiceFile/"+fileId+"/";
System.out.println("文件下载路径"+path);
List<Long> fileUrls = getAttachmentManager().getBySubReference(fileId);
Attachment attachment = getAttachmentManager().getAttachmentByFileURL(fileUrls.get(0));
String filePath = path+attachment.getFilename();
JSONArray jsonArray = getFileContent(filePath);
return jsonArray;
}
public static String uploadContractToOA(Object[] fileInfos, String formId, String loginName, String updateAccountName) throws Exception {
OrgManager orgManager = (OrgManager) AppContext.getBean("orgManager");
V3xOrgMember member = orgManager.getMemberByLoginName(loginName);
V3xOrgAccount account = orgManager.getAccountByName(updateAccountName);
String refId = String.valueOf(Math.abs(UUID.randomUUID().getLeastSignificantBits()));
List<Attachment> attachments = new ArrayList<>();
File tempDir = new File(TEMP_DIR);
if (!tempDir.exists()) {
tempDir.mkdirs();
}
for (Object fileInfo : fileInfos) {
Map<String, Object> fileInfoMap = (Map<String, Object>) fileInfo;
String fileName = (String) fileInfoMap.get("fileName");
String url = (String) fileInfoMap.get("downloadUrl");
String savePath = TEMP_DIR + File.separator + fileName;
HttpClient.httpDownloadFile(url, null,savePath,"ITF-8");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
FileUploadExporter fileUpload = new FileUploadExporter();
File file = new File(savePath);
if (file.exists() && file.length() <= MAX_FILE_SIZE) {
String uploadedPath = fileUpload.processUpload(new String[]{file.getAbsolutePath()});
Map<String, String> attachMeta = new HashMap<>();
attachMeta.put("type", "0");
attachMeta.put("fileUrl", uploadedPath);
attachMeta.put("size", String.valueOf(file.length()));
attachMeta.put("subReference", refId);
attachMeta.put("category", CATEGORY_CODE);
attachMeta.put("createdate", sdf.format(new Date()));
attachMeta.put("filename", fileName);
attachMeta.put("reference", formId);
attachMeta.put("mimeType", "application/" + "pdf");
attachments.add(new Attachment(attachMeta));
file.delete();
}
}
if (attachments.isEmpty()) return null;
AttachmentManager attachmentManager = (AttachmentManager) AppContext.getBean("attachmentManager");
attachmentManager.create(attachments, member.getId(), account.getId());
return refId;
}
private static boolean isBlank(String str) {
return str == null || str.trim().isEmpty();
}
}