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

完善代码

Browse Source
This commit is contained in:
RuicyWu
2026-01-22 16:49:36 +08:00
parent 2435926edb
commit 6652165e86
9 changed files with 338 additions and 123 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/seeyon/utils/form/ClauseFactor.java
View File

@@ -1,6 +1,7 @@
package com.seeyon.utils.form;
public enum ClauseFactor {
NEQ,//不相等
EQ, //相等
GT, //大于
GE, //大于等于
@@ -10,10 +11,16 @@ public enum ClauseFactor {
NOT_NULL, //非空
LIKE, //模糊
AND,
OR
OR,
IN,
NOT_IN
;
public boolean isNullType() {
return this == NULL || this == NOT_NULL;
}
public boolean isInType() {
return this == IN || this == NOT_IN;
}
}

74
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.api.FormApi4Cap4;
import com.seeyon.cap4.form.bean.FormBean;
import com.seeyon.cap4.form.bean.FormFieldBean;
import com.seeyon.cap4.form.bean.FormTableBean;
@@ -12,34 +11,30 @@ import com.seeyon.ctp.common.po.ctpenumnew.CtpEnumItem;
import com.seeyon.ctp.util.JDBCAgent;
import org.apache.commons.lang3.StringUtils;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.*;
public class EnumMapUtils {
public static String getMasterTableEnumItemValue(String formNo,String fieldDisplay, String targetValue) {
public static String getEnumItemValueByDisplayValue(FormBean cap4FormBean,String fieldDisplay, String targetValue) {
if(targetValue == null || "null".equals(targetValue) || "".equals(targetValue)){
return "";
return null;
}
try {
FormApi4Cap4 formApi4Cap4 = (FormApi4Cap4) AppContext.getBean("formApi4Cap4");
FormBean cap4FormBean = formApi4Cap4.getFormByFormCode(formNo);
FormTableBean masterTableBean = cap4FormBean.getMasterTableBean();
FormFieldBean beanByDisplay = masterTableBean.getFieldBeanByDisplay(fieldDisplay);
if(beanByDisplay == null || beanByDisplay.getEnumId() == 0l) {
return "";
return null;
}
return getEnumItemValueByEnumId(targetValue, beanByDisplay.getEnumId());
} catch (Exception e) {
return "";
return null;
}
}
public static String getEnumItemIdByGroupNameAndItemShowValue(String enumGroupName, String targetValue) {
String sql = "SELECT * FROM ctp_enum ce let join ctp_enum_item cei on ce.`ID` = cei.REF_ENUMID where ce.`ENUMNAME` = ? and CEI.`SHOWVALUE` = ?";
if(StringUtils.isAnyBlank(enumGroupName, targetValue)){
return "";
return null;
}
Long enumId = null;
JDBCAgent agent = new JDBCAgent();
@@ -47,7 +42,7 @@ public class EnumMapUtils {
agent.execute(sql, Arrays.asList(enumGroupName,targetValue));
List<Map<String, Object>> list = (List<Map<String, Object>>) agent.resultSetToList();
if(list == null || list.size() == 0) {
return "";
return null;
}
Map map = list.get(0);
enumId = (Long)map.get("ID");
@@ -57,13 +52,13 @@ public class EnumMapUtils {
}finally {
agent.close();
}
return "";
return null;
}
public static String getEnumItemValue(String rootPCode, String groupValue, String targetValue) {
public static String getEnumItemValueByRootPCode(String rootPCode, String groupValue, String targetValue) {
if(targetValue == null || "null".equals(targetValue) || "".equals(targetValue)){
return "";
return null;
}
String queryIdSql = "SELECT ce.ID FROM ctp_enum ce inner join ctp_enum cei on ce.`PARENT_ID` = cei.ID where CEI.`PROGRAM_CODE` = ? and ce.`ENUMNAME` = ?";
Long enumId = null;
@@ -72,62 +67,89 @@ public class EnumMapUtils {
agent.execute(queryIdSql, Arrays.asList(rootPCode,groupValue));
List<Map<String, Object>> list = (List<Map<String, Object>>) agent.resultSetToList();
if(list == null || list.size() == 0) {
return "";
return null;
}
Map map = list.get(0);
enumId = (Long)map.get("ID");
} catch (Exception e) {
return "";
return null;
}finally {
agent.close();
}
EnumManager enumManagerNew = (EnumManager) AppContext.getBean("enumManagerNew");
CtpEnumBean ctpEnumBean = enumManagerNew.getEnum(enumId);
if(ctpEnumBean == null) {
return "";
return null;
}
List<CtpEnumItem> ctpEnumItems = ctpEnumBean.getItems();
if(ctpEnumBean.getItems() == null) {
return "";
return null;
}
for (CtpEnumItem enumItem : ctpEnumItems) {
if(enumItem.getShowvalue().equals(targetValue)) {
return enumItem.getId() + "";
}
}
return "";
return null;
}
public static Set<String> getEnumItemValues(FormBean cap4FormBean, String fieldDisplay) {
Set<String> set = new HashSet<>();
try {
FormTableBean masterTableBean = cap4FormBean.getMasterTableBean();
FormFieldBean beanByDisplay = masterTableBean.getFieldBeanByDisplay(fieldDisplay);
if(beanByDisplay == null || beanByDisplay.getEnumId() == 0l) {
return set;
}
EnumManager enumManagerNew = (EnumManager) AppContext.getBean("enumManagerNew");
CtpEnumBean ctpEnumBean = enumManagerNew.getEnum(beanByDisplay.getEnumId());
if(ctpEnumBean == null) {
return set;
}
List<CtpEnumItem> ctpEnumItems = ctpEnumBean.getItems();
if(ctpEnumBean.getItems() == null) {
return set;
}
for (CtpEnumItem enumItem : ctpEnumItems) {
set.add(enumItem.getShowvalue());
}
} catch (Exception e) {
}
return set;
}
public static String getEnumItemValueByEnumId(String showValue,long enumId) {
EnumManager enumManagerNew = (EnumManager) AppContext.getBean("enumManagerNew");
CtpEnumBean ctpEnumBean = enumManagerNew.getEnum(enumId);
if(ctpEnumBean == null) {
return "";
return null;
}
List<CtpEnumItem> ctpEnumItems = ctpEnumBean.getItems();
if(ctpEnumBean.getItems() == null) {
return "";
return null;
}
for (CtpEnumItem enumItem : ctpEnumItems) {
if(enumItem.getShowvalue().equals(showValue)) {
return enumItem.getId() + "";
}
}
return "";
return null;
}
public static String getEnumShowValue(Object enumItemId) throws BusinessException {
if(enumItemId == null) {
return "";
return null;
}
Long temp = enumItemId instanceof Long ? (Long)enumItemId : (enumItemId instanceof String ? Long.parseLong((String)enumItemId) : null);
if(temp == null) {
return "";
return null;
}
EnumManager enumManagerNew = (EnumManager) AppContext.getBean("enumManagerNew");
CtpEnumItem ctpEnumItem = enumManagerNew.getCtpEnumItem(temp);
if(ctpEnumItem == null) {
return "";
return null;
}
return ctpEnumItem.getShowvalue();
}

24
src/main/java/com/seeyon/utils/form/FormExportUtil.java → src/main/java/com/seeyon/utils/form/FormSaveUtil.java
View File

@@ -1,5 +1,8 @@
package com.seeyon.utils.form;
import com.seeyon.ctp.services.ServiceException;
import com.seeyon.v3x.services.form.FormFactory;
import com.seeyon.v3x.services.form.bean.FormExport;
import com.seeyon.v3x.services.form.bean.RecordExport;
import com.seeyon.v3x.services.form.bean.SubordinateFormExport;
import com.seeyon.v3x.services.form.bean.ValueExport;
@@ -10,14 +13,14 @@ import java.util.Map;
import java.util.Set;
//创建无流程表单数据处理工具类
public class FormExportUtil {
public class FormSaveUtil {
/**
* 设置主表信息
* @param map 设置主表字段。Map<主表显示名称,主表数据>
* @return
*/
public List<ValueExport> setFormValue(Map<String, Object> map ){
public static List<ValueExport> setFormValue(Map<String, Object> map ){
// 创建返回值对象
List<ValueExport> valueExports = new ArrayList<ValueExport>();
ValueExport valueExport ;
@@ -32,7 +35,6 @@ public class FormExportUtil {
valueExport.setValue(map.get(key).toString());
valueExports.add(valueExport);
}
System.out.println(key+":"+map.get(key));
}
}
return valueExports;
@@ -42,7 +44,7 @@ public class FormExportUtil {
* 设置从表信息
* @param lists 设置主表字段。List<Map<显示名称,数据值>>
*/
public List<SubordinateFormExport> setSubordinateFormValue(List<Map<String, Object>> lists){
public static List<SubordinateFormExport> setSubordinateFormValue(List<Map<String, Object>> lists){
List<SubordinateFormExport> subordinateFormExports = new ArrayList<SubordinateFormExport>();
SubordinateFormExport subordinateFormExport = new SubordinateFormExport();
List<RecordExport> recordExports = new ArrayList<RecordExport>();
@@ -60,7 +62,7 @@ public class FormExportUtil {
return subordinateFormExports;
}
public List<SubordinateFormExport> setAllSubordinateFormValue(List<Map<String,Object>> lists){
public static List<SubordinateFormExport> setAllSubordinateFormValue(List<Map<String,Object>> lists){
List<SubordinateFormExport> subordinateFormExports = new ArrayList<SubordinateFormExport>();
for (Map<String, Object> list : lists) {
SubordinateFormExport subordinateFormExport = new SubordinateFormExport();
@@ -80,5 +82,15 @@ public class FormExportUtil {
return subordinateFormExports;
}
public static void formSave(String loginName, String formNo, FormFactory formFactory, Map<String,Object> mainFormData, List<Map<String,Object>> subFormDatas) throws ServiceException {
FormExport formExport = new FormExport();
FormExportUtil formExportUtil = new FormExportUtil();
List<ValueExport> valueExport = formExportUtil.setFormValue(mainFormData);
formExport.setValues(valueExport);
if(subFormDatas != null) {
formExport.setSubordinateForms(formExportUtil.setAllSubordinateFormValue(subFormDatas));
}
formFactory.importBusinessFormData(loginName, formNo,
formExport, new String[] {});
}
}

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

@@ -4,7 +4,6 @@ import com.seeyon.aicloud.common.JsonUtils;
import com.seeyon.cap4.form.api.FormApi4Cap4;
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;
import com.seeyon.ctp.common.exceptions.BusinessException;
import com.seeyon.ctp.util.JDBCAgent;
@@ -16,18 +15,16 @@ import java.util.stream.Collectors;
public class FormTableExecutor {
/* ========== 表定位 ========== */
private static final Log log = LogFactory.getLog(FormTableExecutor.class);
/* ========== 表定位 ========== */
public TableContext master(String formNo) throws BusinessException {
/*获取主表定义bean对象*/
public static TableContext master(String formNo) throws BusinessException {
FormBean form = getForm(formNo);
return new TableContext(form.getMasterTableBean());
}
public TableContext sub(String formNo, String subTable) throws BusinessException {
/*获取从表定义bean对象*/
public static TableContext sub(String formNo, String subTable) throws BusinessException {
FormBean form = getForm(formNo);
return form.getSubTableBean().stream()
.filter(t -> t.getTableName().equals(subTable) || t.getDisplay().equals(subTable))
@@ -36,12 +33,13 @@ public class FormTableExecutor {
.orElseThrow(() -> new BusinessException("未找到子表：" + subTable));
}
private FormBean getForm(String formNo) throws BusinessException {
private static FormBean getForm(String formNo) throws BusinessException {
FormApi4Cap4 api = (FormApi4Cap4) AppContext.getBean("formApi4Cap4");
return api.getFormByFormCode(formNo);
}
private void fillUpdateFields(TableContext ctx, List<FormUpdateField> updateFields) {
/*填充update字段fieldName*/
private static void fillUpdateFields(TableContext ctx, List<FormUpdateField> updateFields) {
if (updateFields == null) return;
for (FormUpdateField c : updateFields) {
@@ -52,7 +50,8 @@ public class FormTableExecutor {
}
}
private void fillConditionFields(TableContext ctx, List<FormWhereCondition> conditions) {
/*填充condition字段fieldName*/
private static void fillConditionFields(TableContext ctx, List<FormWhereCondition> conditions) {
if (conditions == null) return;
for (FormWhereCondition c : conditions) {
@@ -67,7 +66,8 @@ public class FormTableExecutor {
}
}
private List<String> resolveQueryColumns(TableContext ctx, List<String> displays) {
/*将查询列display转换为fieldName*/
private static List<String> resolveQueryColumns(TableContext ctx, List<String> displays) {
if (displays == null) return Collections.emptyList();
return displays.stream()
.map(ctx.getTableBean()::getFieldBeanByDisplay)
@@ -78,7 +78,7 @@ public class FormTableExecutor {
/* ========== 查询方法 ========== */
public List<FormColumn> query(TableContext ctx,
public static List<FormColumn> query(TableContext ctx,
List<String> queryDisplays,
List<FormWhereCondition> conditions,
boolean changeEnum) {
@@ -110,7 +110,8 @@ public class FormTableExecutor {
return new ArrayList<>();
}
public FormColumn queryOne(TableContext ctx,
/*查询单条记录*/
public static FormColumn queryOne(TableContext ctx,
List<FormWhereCondition> conditions,
boolean changeEnum) {
@@ -138,7 +139,8 @@ public class FormTableExecutor {
return null;
}
public List<FormColumn> pageQuery(TableContext ctx,
/*分页查询*/
public static List<FormColumn> pageQuery(TableContext ctx,
List<String> displays,
List<FormWhereCondition> conditions,
int pageNo,
@@ -174,7 +176,8 @@ public class FormTableExecutor {
return new ArrayList<>();
}
public long count(TableContext ctx,List<String> countField,List<FormWhereCondition> conditions) {
/*统计数量*/
public static long count(TableContext ctx,List<String> countField,List<FormWhereCondition> conditions) {
fillConditionFields(ctx, conditions);
List<String> countColumn = resolveQueryColumns(ctx,countField);
SqlBuildParam param = new SqlBuildParam();
@@ -199,8 +202,8 @@ public class FormTableExecutor {
}
public int update(TableContext ctx, List<FormUpdateField> fields, List<FormWhereCondition> conditions) {
/*更新操作*/
public static int update(TableContext ctx, List<FormUpdateField> fields, List<FormWhereCondition> conditions) {
if (fields == null || fields.isEmpty()) throw new IllegalArgumentException("更新字段不能为空");
if (conditions == null || conditions.isEmpty()) throw new IllegalArgumentException("UPDATE必须带条件");
fillConditionFields(ctx, conditions);
@@ -224,7 +227,8 @@ public class FormTableExecutor {
return 0;
}
public int delete(TableContext ctx, List<FormWhereCondition> conditions) {
/*删除操作*/
public static int delete(TableContext ctx, List<FormWhereCondition> conditions) {
if (conditions == null || conditions.isEmpty()) throw new IllegalArgumentException("DELETE必须带条件");
fillConditionFields(ctx, conditions);
SqlBuildParam param = new SqlBuildParam();
@@ -247,7 +251,8 @@ public class FormTableExecutor {
}
/* ========== 构建 FormColumn ========== */
private FormColumn buildFormColumn(Map<String, Object> row,
/*填充结果字段*/
private static FormColumn buildFormColumn(Map<String, Object> row,
TableContext ctx,
boolean changeEnum) {
FormColumn column = new FormColumn();
@@ -262,10 +267,8 @@ public class FormTableExecutor {
if (changeEnum && field.isEnumField()) {
value = EnumMapUtils.getEnumShowValue(value);
}
// 枚举、部门、成员等特殊字段处理
value = handleFieldSpecialType(field, value);
// value = handleFieldSpecialType(field, value);
FormFieldVo vo = new FormFieldVo();
vo.setDisplayName(field.getDisplay());
vo.setValue(value);
@@ -284,13 +287,13 @@ public class FormTableExecutor {
return column;
}
private Object handleFieldSpecialType(FormFieldBean field, Object value) throws BusinessException {
private static Object handleFieldSpecialType(FormFieldBean field, Object value) throws BusinessException {
if (value == null) return null;
switch (field.getInputType()) {
case "select":
if (field.getEnumId() != 0L) {
return EnumMapUtils.getEnumItemValueByEnumId(String.valueOf(value), field.getEnumId());
if (field.isEnumField()) {
return EnumMapUtils.getEnumShowValue(value);
}
break;
case "department":
@@ -308,22 +311,7 @@ public class FormTableExecutor {
return value;
}
public boolean isMasterTableFile(String displayName, String formNo) {
FormApi4Cap4 formApi4Cap4 = (FormApi4Cap4) AppContext.getBean("formApi4Cap4");
try {
FormBean cap4FormBean = formApi4Cap4.getFormByFormCode(formNo);
FormTableBean masterTableBean = cap4FormBean.getMasterTableBean();
FormFieldBean fieldBeanByDisplay = masterTableBean.getFieldBeanByDisplay(displayName);
return fieldBeanByDisplay != null &&
("image".equals(fieldBeanByDisplay.getInputType()) ||
"attachment".equals(fieldBeanByDisplay.getInputType()));
} catch (BusinessException e) {
}
return false;
}
private Map<String, Object> buildCountSql(
private static Map<String, Object> buildCountSql(
String countField,
String tableName,
List<FormWhereCondition> conditions) {
@@ -337,7 +325,7 @@ public class FormTableExecutor {
return buildResult(sql, params);
}
private Map<String, Object> buildSelectSql(
private static Map<String, Object> buildSelectSql(
String tableName,
List<String> queryColumns,
List<FormWhereCondition> conditions,
@@ -374,7 +362,7 @@ public class FormTableExecutor {
return buildResult(sql, params);
}
private Map<String, Object> buildUpdateSql(
private static Map<String, Object> buildUpdateSql(
String tableName,
List<FormUpdateField> fields,
List<FormWhereCondition> conditions) {
@@ -417,7 +405,7 @@ public class FormTableExecutor {
return buildResult(sql, params);
}
private Map<String, Object> buildDeleteSql(
private static Map<String, Object> buildDeleteSql(
String tableName,
List<FormWhereCondition> conditions) {
@@ -435,7 +423,7 @@ public class FormTableExecutor {
return buildResult(sql, params);
}
private Map<String, Object> buildInsertSql(
private static Map<String, Object> buildInsertSql(
String tableName,
Map<String, Object> data) {
@@ -474,63 +462,82 @@ public class FormTableExecutor {
* @param params 参数列表（引用传递）
* @return 拼接后的 WHERE 子句（包含 WHERE 关键字）
*/
private String buildWhereClause(List<FormWhereCondition> conditions, List<Object> params) {
private static String buildWhereClause(List<FormWhereCondition> conditions, List<Object> params) {
if (conditions == null || conditions.isEmpty()) {
return "";
}
StringBuilder whereClause = new StringBuilder(" WHERE ");
int conditionIndex = 0;
for (FormWhereCondition condition : conditions) {
// 处理括号起始
if (condition.isStartWithBracket()) {
whereClause.append("(");
StringBuilder whereCause = new StringBuilder(" WHERE ");
for (int i = 0; i < conditions.size(); i++) {
FormWhereCondition c = conditions.get(i);
// 左括号
if (c.isStartWithBracket()) {
whereCause.append("(");
}
// 字段名校验
String fieldName = condition.getFieldName();
ClauseFactor factor = condition.getClauseFactor();
String field = c.getFieldName();
ClauseFactor factor = c.getClauseFactor();
String operator = parseOperator(factor);
// 构建条件表达式
String conditionExpr;
if (factor != null && factor.isNullType()) {
// 处理 NULL/NOT NULL 条件（无需参数）
conditionExpr = String.format("%s %s", fieldName, operator);
// NULL / NOT NULL
if (factor.isNullType()) {
whereCause.append(field).append(" ").append(operator);
} else if (factor.isInType()) {
appendInClause(whereCause, field, operator, c.getValue(), params);
} else {
// 处理普通条件（带占位符）
conditionExpr = String.format("%s %s ?", fieldName, operator);
// 处理函数模板（如 TO_DATE）
if (condition.getIndex() != null) {
conditionExpr = conditionExpr.replace("?", condition.getIndex());
String placeholder = "?";
// 函数模板（如 TO_DATE(?)）
if (c.getIndex() != null) {
placeholder = c.getIndex();
}
// 添加参数值
params.add(condition.getValue());
whereCause.append(field).append(" ").append(operator).append(" ").append(placeholder);
if (ClauseFactor.LIKE.equals(factor)) {
params.add("%" + c.getValue() + "%");
} else {
params.add(c.getValue());
}
}
// 右括号
if (c.isEndWithBracket()) {
whereCause.append(")");
}
// AND / OR
if (i < conditions.size() - 1) {
whereCause.append(" ").append(c.getConcatFactor()).append(" ");
}
}
return whereCause.toString();
}
whereClause.append(conditionExpr);
// 处理括号闭合
if (condition.isEndWithBracket()) {
whereClause.append(")");
private static void appendInClause(
StringBuilder sql,
String field,
String operator,
Object value,
List<Object> params) {
if (!(value instanceof Collection)) {
throw new IllegalArgumentException("IN 条件的值必须是 Collection");
}
// 添加连接符（AND/OR）
if (conditionIndex < conditions.size() - 1) {
whereClause.append(" ").append(condition.getConcatFactor()).append(" ");
Collection<?> values = (Collection<?>) value;
if (values.isEmpty()) {
// 防止 SQL 语法错误
sql.append("1 = 0");
return;
}
conditionIndex++;
sql.append(field).append(" ").append(operator).append(" (");
int index = 0;
for (Object v : values) {
if (index > 0) {
sql.append(", ");
}
return whereClause.toString();
sql.append("?");
params.add(v);
index++;
}
sql.append(")");
}
/**
* 解析运算符映射（eq -> =, lt -> < 等）
*/
private String parseOperator(ClauseFactor factor) {
private static String parseOperator(ClauseFactor factor) {
if(factor == null) {
return "=";
}
@@ -547,14 +554,14 @@ public class FormTableExecutor {
}
}
private Map<String, Object> buildResult(StringBuilder sql, List<Object> params) {
private static Map<String, Object> buildResult(StringBuilder sql, List<Object> params) {
Map<String, Object> result = new HashMap<>();
result.put("sql", sql.toString());
result.put("params", params);
return result;
}
private Map<String, Object> generateSql(SqlBuildParam param) {
private static Map<String, Object> generateSql(SqlBuildParam param) {
if (param == null || param.getSqlType() == null) {
throw new IllegalArgumentException("SqlBuildParam or SqlType cannot be null");

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

@@ -1,9 +1,13 @@
package com.seeyon.utils.form;
import java.util.ArrayList;
import java.util.List;
public class FormWhereCondition {
private String display;
private String fieldName; //字段名
private Object value; //值
private List<Object> values; //值
private ClauseFactor clauseFactor; //条件因子 eq lt gt not_null null
private ClauseFactor concatFactor = ClauseFactor.AND; //拼接因子
private boolean startWithBracket = false; //是否以括号开头生成子条件
@@ -11,6 +15,7 @@ public class FormWhereCondition {
private String index;
public FormWhereCondition() {
this.values = new ArrayList<>();
}
public String getDisplay() {
@@ -118,4 +123,15 @@ public class FormWhereCondition {
public void setEndWithBracket(boolean endWithBracket) {
this.endWithBracket = endWithBracket;
}
public List<Object> getValues() {
return values;
}
public FormWhereCondition addValue(Object value) {
this.values.add(value);
return this;
}
public void setValues(List<Object> values) {
this.values = values;
}
}

6
src/main/java/com/seeyon/utils/http/HttpClient.java
View File

@@ -246,18 +246,18 @@ public class HttpClient {
HttpEntity entity = httpResponse.getEntity();
content = EntityUtils.toString(entity, encode);
} catch (Exception e) {
e.printStackTrace();
}finally{
try {
httpResponse.close();
} catch (IOException e) {
e.printStackTrace();
}
}
try { //关闭连接、释放资源
closeableHttpClient.close();
} catch (IOException e) {
e.printStackTrace();
}
return content;
}

32
src/main/java/com/seeyon/utils/http/OaResp.java Normal file
View File

@@ -0,0 +1,32 @@
package com.seeyon.utils.http;
public class OaResp {
private Integer code;
private String message;
private Object data;
public Integer getCode() {
return code;
}
public void setCode(Integer code) {
this.code = code;
}
public String getMessage() {
return message;
}
public void setMessage(String message) {
this.message = message;
}
public Object getData() {
return data;
}
public void setData(Object data) {
this.data = data;
}
}

114
src/main/java/com/seeyon/utils/http/OaRestClient.java Normal file
View File

@@ -0,0 +1,114 @@
package com.seeyon.utils.http;
import com.alibaba.fastjson.JSONObject;
import com.seeyon.aicloud.common.JsonUtils;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicHeader;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class OaRestClient {
private static final Logger log = LoggerFactory.getLogger(OaRestClient.class);
private String oaHost;
private String restName;
private String restPwd;
private Boolean cacheToken = false;
private ConcurrentHashMap<String, String> tokenCache = new ConcurrentHashMap<>();
public OaRestClient(String oaHost, String restName, String restPwd, Boolean cacheToken) {
this.oaHost = oaHost;
this.restName = restName;
this.restPwd = restPwd;
this.cacheToken = cacheToken;
}
public OaResp sendGet(String bizName, String url) throws Exception {
Map<String,String> headers = new HashMap<>();
headers.put("token",getToken());
log.info(bizName + "请求链接为：" + url);
String respStr = HttpClient.httpGet(oaHost + "/seeyon/rest" + url,headers,null);
log.info(bizName + "响应结果为：" + respStr);
return resovleResp(respStr);
}
public OaResp sendPost(String bizName,String url,Map<String,Object> params) throws Exception {
Map<String,String> headers = new HashMap<>();
headers.put("token",getToken());
String paramStr = JsonUtils.toJSONString(params);
log.info(bizName + "请求参数为：" + paramStr);
String respStr = HttpClient.httpPostRaw(oaHost + "/seeyon/rest" + url,paramStr,headers,null);
log.info(bizName + "响应结果为：" + respStr);
return resovleResp(respStr);
}
OaResp resovleResp(String respStr){
return JsonUtils.parseObject(respStr,OaResp.class);
}
private String applyToken() {
String url = oaHost +"/seeyon/rest/token/" + restName + "/" + restPwd + "?loginName=" + restName;
DefaultHttpClient client = new DefaultHttpClient();
String result = "";
HttpGet get = new HttpGet(url);
// 添加 Headers 信息
get.addHeader(new BasicHeader("Accept", "application/json"));
try {
HttpResponse res = client.execute(get);
if (res.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
result = EntityUtils.toString(res.getEntity());
}
} catch (Exception e) {
throw new RuntimeException(e);
}
String token = null;
if(result.contains("{")) {
JSONObject jsObj = JSONObject.parseObject(result);
token = jsObj.get("id").toString();
}else {
token = result;
}
return token;
}
private String getToken(){
if(cacheToken) {
String token = tokenCache.get(restName);
if(token != null && !checkExpire(token)) {
return token;
}else {
String tokenStr = applyToken();
tokenCache.put(restName, tokenStr);
return tokenStr;
}
}
return applyToken();
}
private boolean checkExpire(String token) {
String url = oaHost + "/seeyon/rest/cap4/batch/refresh";
try{
Map<String,String> headers = new HashMap<>();
headers.put("token",token);
headers.put("loginName",restName);
String respStr = HttpClient.httpPostRaw(url, null, headers,null);
Map map = JsonUtils.parseObject(respStr, Map.class);
if("0".equals(map.get("code"))) {
return false;
}else {
return true;
}
} catch (Exception e){
return true;
}
}
}

5
src/test/OaRestClientTest.java Normal file
View File

@@ -0,0 +1,5 @@
public class OaRestClientTest {
public static void main(String[] args) {
OaRestClientTest oaRestClientTest = new OaRestClientTest();
}
}