dataMap);
+
+
+
+ /**
+ * 删除建模数据
+ * @param tableName 表单名称
+ * @param dataId 数据ID
+ * @return 更新结果
+ */
+ @Delete("delete from $t{tableName} where id = #{dataId}")
+ boolean deleteRedundancyData(@ParamMapper("tableName") String tableName, @ParamMapper("dataId") int dataId);
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/action/CommonVoucherAction.java b/src/main/java/weaver/weilin/zhu/common/voucher/action/CommonVoucherAction.java
new file mode 100644
index 0000000..7c6c3b0
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/action/CommonVoucherAction.java
@@ -0,0 +1,230 @@
+package weaver.weilin.zhu.common.voucher.action;
+
+import aiyh.utils.Util;
+import aiyh.utils.action.SafeCusBaseAction;
+import aiyh.utils.annotation.ActionDefaultTestValue;
+import aiyh.utils.annotation.PrintParamMark;
+import aiyh.utils.annotation.RequiredMark;
+import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
+import weaver.conn.RecordSet;
+import weaver.conn.RecordSetTrans;
+import weaver.hrm.User;
+import weaver.soa.workflow.request.RequestInfo;
+import weaver.weilin.zhu.common.voucher.entity.BaseConfigDao;
+import weaver.weilin.zhu.common.voucher.util.CommonVoucherUtil;
+import weaver.weilin.zhu.common.voucher.mapper.CommVoucherSqlMapper;
+import weaver.zwl.common.ToolUtilNew;
+
+import java.lang.reflect.Constructor;
+import java.lang.reflect.InvocationTargetException;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 通用凭证Action入口
+ * @author bleach
+ * @version 2023-07-10
+ */
+public class CommonVoucherAction extends SafeCusBaseAction {
+
+ /**
+ * 日志操作类
+ */
+ private final Logger logger = Util.getLogger();
+
+ /**
+ * SQL接口
+ */
+ private final CommVoucherSqlMapper sqlMapper = Util.getMapper(CommVoucherSqlMapper.class);
+
+ /**
+ * 自定义参数值
+ */
+ private String cusParamValue;
+
+ /**
+ * 后置实现类接口路径
+ */
+ @RequiredMark("具体接口请求实现接口类路径!")
+ @ActionDefaultTestValue("weaver.weilin.zhu.asc.workflow.VoucherPushAction")
+ @PrintParamMark
+ private String implementorPath;
+
+
+
+ /**
+ * action 提交流程业务处理方法
+ * 具体业务逻辑实现
+ * 全局存在log成员变量，用于日志的输出 Util.actionFailException(requestManager,"error msg"); 用于提示action执行失败
+ *
+ *
+ * @param requestId 流程请求ID
+ * @param billTable 流程对应主表名称
+ * @param workflowId 流程对应流程ID
+ * @param user 当前节点操作者用户
+ * @param requestInfo 请求管理对象
+ */
+ @Override
+ public void doSubmit(String requestId, String billTable, int workflowId, User user, RequestInfo requestInfo) {
+ logger.info("--------------- CommonVoucherAction Begin ---------------");
+
+ Map workflowBaseMap = getWorkflowBaseInfo(requestInfo.getRsTrans(),requestId);
+
+ CommonVoucherUtil voucherUtil = new CommonVoucherUtil();
+
+ voucherUtil.setWorkflowBaseMap(workflowBaseMap);
+
+ //自定义配置
+ BaseConfigDao baseConfigDao = voucherUtil.getConfigurationByWorkflowId(String.valueOf(workflowId), cusParamValue);
+
+ assert baseConfigDao != null;
+
+ voucherUtil.setThisUser(user);
+ voucherUtil.setObjectMappingDaoList(baseConfigDao.getObjectMappingDaoList());
+ voucherUtil.setNodeFieldMappingDaoList(baseConfigDao.getNodeFieldMappingDaoList());
+
+ RecordSet rs ;
+
+ String dataCondition = baseConfigDao.getDataCondition();
+
+ if(StringUtils.isNotBlank(dataCondition)){
+ rs = sqlMapper.getWorkflowMainTableInfoAndCondition(billTable,requestId, ToolUtilNew.staticToDBC(dataCondition));
+ } else {
+ rs = sqlMapper.getWorkflowMainTableInfo(billTable,requestId);
+ }
+
+ if(!rs.next()){
+ logger.info("当前流程不满足自定义条件！");
+ }
+
+ workflowBaseMap.put("mainId",Util.null2String(rs.getString("id")));
+
+ //推送的报文
+ JSONObject postJsonObj = new JSONObject();
+
+ StringBuilder postXmlObj = new StringBuilder();
+
+ if(baseConfigDao.getDataFormat() == 1){
+ postXmlObj = voucherUtil.recursionGenerateXML("",null,null,0,0,0);
+ } else {
+ //推送的报文
+ postJsonObj = voucherUtil.recursionGenerateJsonObject("",null,null,0,0,0);
+ }
+
+ if(postJsonObj != null || postXmlObj.length() > 0){
+
+ if(StringUtils.isNotBlank(implementorPath)){
+ Map pathParam = Util.parseCusInterfacePathParam(implementorPath);
+ String className = pathParam.remove("_ClassPath");
+
+ Map paramsMap = new HashMap<>();
+ paramsMap.put("pushJsonObject",postJsonObj);
+ paramsMap.put("pushXmlObject",postXmlObj);
+ paramsMap.put("pathParam",pathParam);
+ paramsMap.put("requestInfo",requestInfo);
+ paramsMap.put("workflowBaseMap",workflowBaseMap);
+ paramsMap.put("userInfo",user);
+
+ ResultMessageUtil resultMessageUtil = executePostProcessor(className,paramsMap);
+
+ if(resultMessageUtil.isSuccess()){
+ String backFieldname = baseConfigDao.getBackFieldname();
+
+ String backFieldValue = resultMessageUtil.getBackFieldValue();
+
+ sqlMapper.resultBackToWorkflowBill(billTable,backFieldname,backFieldValue,requestId);
+ } else {
+ //获取失败的错误提示
+ String tipMessage = resultMessageUtil.getTipMessage();
+
+ if(baseConfigDao.getExceptionContinue() == 0){
+ //阻止流程提交
+ Util.actionFail(requestInfo.getRequestManager(),tipMessage);
+ }
+ }
+ }
+ }
+
+ logger.info("--------------- CommonVoucherAction End ---------------");
+ }
+
+ /**
+ * 获取流程基础信息
+ * @param trans 当前事务
+ * @param requestId 流程请求ID
+ * @return 当前流程信息
+ */
+ private Map getWorkflowBaseInfo(RecordSetTrans trans,String requestId){
+ Map baseInfo = new HashMap<>();
+
+ if(trans == null){
+ trans = new RecordSetTrans();
+ }
+
+ String selectSQL = "select requestName,requestMark from workflow_requestBase where requestId = ?";
+
+ try {
+ if(trans.executeQuery(selectSQL,requestId) && trans.next()){
+ baseInfo.put("requestName",Util.null2String(trans.getString(1)));
+ baseInfo.put("requestMark",Util.null2String(trans.getString(2)));
+ }
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+
+ return baseInfo;
+ }
+
+
+ /**
+ * 执行自定义后置处理方法
+ *
+ * @param className 全路径类名
+ * @param params 参数
+ * @return 返回值
+ */
+ private ResultMessageUtil executePostProcessor(String className, Map params) {
+ Class aClass;
+ try {
+ aClass = Class.forName(className);
+ } catch (ClassNotFoundException e) {
+ throw new IllegalArgumentException("未能找到自定义action接口处理方法：" + className);
+ }
+ Constructor constructor;
+ try {
+ constructor = aClass.getConstructor();
+ } catch (NoSuchMethodException e) {
+ throw new IllegalArgumentException(className + "没有空参构造方法，无法获取构造方法对象！");
+ }
+ if (!CusActionPostInterface.class.isAssignableFrom(aClass)) {
+ throw new IllegalArgumentException("自定义后置处理接口：" + className + " 不是"
+ + CusActionPostInterface.class.getName() + "的子类或实现类！");
+ }
+ CusActionPostInterface o;
+ try {
+ o = (CusActionPostInterface) constructor.newInstance();
+ } catch (InstantiationException | IllegalAccessException | InvocationTargetException e) {
+ throw new IllegalArgumentException("无法构造" + className + "对象！");
+ }
+ return o.postProcessor(params);
+ }
+
+
+ public String getCusParamValue() {
+ return cusParamValue;
+ }
+
+ public void setCusParamValue(String cusParamValue) {
+ this.cusParamValue = cusParamValue;
+ }
+
+ public String getImplementorPath() {
+ return implementorPath;
+ }
+
+ public void setImplementorPath(String implementorPath) {
+ this.implementorPath = implementorPath;
+ }
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/action/CusActionPostInterface.java b/src/main/java/weaver/weilin/zhu/common/voucher/action/CusActionPostInterface.java
new file mode 100644
index 0000000..762cdeb
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/action/CusActionPostInterface.java
@@ -0,0 +1,22 @@
+package weaver.weilin.zhu.common.voucher.action;
+
+import java.util.Map;
+
+/**
+ * 自定义接口操作
+ * 通过配置动态生成了JSONObject或者XML信息
+ * 该接口中拿到对应的信息进行后续操作
+ *
+ * @author bleach
+ */
+
+public interface CusActionPostInterface {
+
+ /**
+ * 后置处理方法
+ *
+ * @param params 后置处理器参数
+ * @return 处理后返回值
+ */
+ ResultMessageUtil postProcessor(Map params);
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/action/ResultMessageUtil.java b/src/main/java/weaver/weilin/zhu/common/voucher/action/ResultMessageUtil.java
new file mode 100644
index 0000000..6d7f7dd
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/action/ResultMessageUtil.java
@@ -0,0 +1,32 @@
+package weaver.weilin.zhu.common.voucher.action;
+
+import lombok.Data;
+
+/**
+ * 自定义接口操作
+ * 返回信息实体类
+ */
+@Data
+public class ResultMessageUtil {
+
+ /**
+ * 是否调用成功
+ */
+ private boolean isSuccess;
+
+ /**
+ * 提示消息说明
+ */
+ private String tipMessage;
+
+ /**
+ * 接口返回信息
+ */
+ private String responseBody;
+
+ /**
+ * 回写的字段值
+ */
+ private String backFieldValue;
+
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/convert/CusAsyncConvert.java b/src/main/java/weaver/weilin/zhu/common/voucher/convert/CusAsyncConvert.java
new file mode 100644
index 0000000..99aa139
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/convert/CusAsyncConvert.java
@@ -0,0 +1,21 @@
+package weaver.weilin.zhu.common.voucher.convert;
+
+
+import weaver.weilin.zhu.common.voucher.entity.NodeFieldMappingDao;
+
+import java.util.Map;
+
+/**
+ * 自定义转换规则接口
+ * @author bleach
+ */
+public interface CusAsyncConvert {
+ /**
+ * 自定义转换接口
+ * @param dao 配置信息
+ * @param param 自定义转换规则参数
+ * @param pathParam 自定义接口路径
+ * @return 转换后的值
+ */
+ String cusConvert(NodeFieldMappingDao dao, RuleMethodParam param, Map pathParam);
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/convert/FieldChangeRuleMethod.java b/src/main/java/weaver/weilin/zhu/common/voucher/convert/FieldChangeRuleMethod.java
new file mode 100644
index 0000000..15a6b83
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/convert/FieldChangeRuleMethod.java
@@ -0,0 +1,213 @@
+package weaver.weilin.zhu.common.voucher.convert;
+
+import aiyh.utils.Util;
+import aiyh.utils.annotation.MethodRuleNo;
+import aiyh.utils.excention.CustomerException;
+import com.google.common.base.Strings;
+import org.apache.commons.lang3.StringUtils;
+import weaver.general.TimeUtil;
+import weaver.weilin.zhu.common.util.FieldDetailInfo;
+import weaver.weilin.zhu.common.voucher.entity.NodeFieldMappingDao;
+import weaver.zwl.common.ToolUtilNew;
+
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.function.BiFunction;
+
+/**
+ * 流程字段转换规则处理
+ * @author bleach
+ * @version 2023-07-04
+ */
+public class FieldChangeRuleMethod {
+
+ public static final Map> VALUE_RULE_FUNCTION = new HashMap<>();
+
+ static {
+ Class valueRuleMethodClass = FieldChangeRuleMethod.class;
+ Method[] methods = valueRuleMethodClass.getMethods();
+ for (Method method : methods) {
+ if (method.isAnnotationPresent(MethodRuleNo.class)) {
+ MethodRuleNo annotation = method.getAnnotation(MethodRuleNo.class);
+ int value = annotation.value();//规则标识
+ VALUE_RULE_FUNCTION.put(value, (config, map) -> {
+ try {
+ FieldChangeRuleMethod valueRuleMethod = new FieldChangeRuleMethod();
+ return method.invoke(valueRuleMethod, config, map).toString();
+ } catch (IllegalAccessException | InvocationTargetException e) {
+ throw new RuntimeException(e);
+ }
+ });
+ }
+ }
+ }
+
+
+ /**
+ * 不转换
+ * @param dao 流程字段配置信息
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 0, desc = "不转换")
+ public String noChange(NodeFieldMappingDao dao, RuleMethodParam param) {
+ String fieldValue = "";
+ FieldDetailInfo fieldInfo = dao.getWfField();
+
+ if(fieldInfo != null){
+ String fieldName = fieldInfo.getFieldName();//字段名称
+
+ if(StringUtils.isNotBlank(fieldName)){
+ int viewType = fieldInfo.getViewType();
+
+ if(viewType == 0){
+ fieldValue = Util.null2String(param.getRs().getString(fieldName));
+ } else if(viewType == 1 && param.getRs_detail() != null){
+ fieldValue = Util.null2String(param.getRs_detail().getString(fieldName));
+ }
+
+ }
+ }
+ return fieldValue;
+ }
+
+ /**
+ * 流程请求ID
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 1, desc = "流程请求ID")
+ public String workflowRequestId(NodeFieldMappingDao dao,RuleMethodParam param) {
+ return Util.null2String(param.getWorkflowBaseMap().get("requestId"));
+ }
+
+ /**
+ * 流程请求标题
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 2, desc = "流程请求标题")
+ public String workflowRequestTitle(NodeFieldMappingDao dao,RuleMethodParam param) {
+ return Util.null2String(param.getWorkflowBaseMap().get("requestName"));
+ }
+
+ /**
+ * 流程请求编号
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 3, desc = "流程请求编号")
+ public String workflowRequestMark(NodeFieldMappingDao dao,RuleMethodParam param) {
+ return Util.null2String(param.getWorkflowBaseMap().get("requestMark"));
+ }
+
+ /**
+ * 系统日期
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 4, desc = "系统日期")
+ public String systemDate(NodeFieldMappingDao dao,RuleMethodParam param) {
+ return TimeUtil.getCurrentDateString();
+ }
+
+ /**
+ * 系统日期时间
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 5, desc = "系统日期时间")
+ public String systemDateTime(NodeFieldMappingDao dao,RuleMethodParam param) {
+ return TimeUtil.getCurrentTimeString();
+ }
+
+ /**
+ * 固定值
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 6, desc = "固定值")
+ public String fixValue(NodeFieldMappingDao dao,RuleMethodParam param) {
+ return Util.null2String(dao.getCusSQL());
+ }
+
+ /**
+ * 明细序列
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 7, desc = "明细序列")
+ public String getDetailRowNum(NodeFieldMappingDao dao,RuleMethodParam param) {
+ return Util.null2String(param.getRowNum());
+ }
+
+
+ /**
+ * 自定义SQL转换
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 8, desc = "自定义SQL")
+ public String customizeSQL(NodeFieldMappingDao dao,RuleMethodParam param) {
+ String fieldName = dao.getNodeName();//字段名称
+
+ //字段值
+ String fieldValue = noChange(dao,param);
+
+ String cusSQL = dao.getCusSQL();
+
+ int detailKeyId = -1;
+ if(StringUtils.isNotBlank(cusSQL)){
+ if( cusSQL.contains("{dt.id}") && param.getRs_detail() != null) {
+ detailKeyId = Util.getIntValue(param.getRs_detail().getString("id"), -1);
+ }
+
+ if(param.getThisUser() != null){
+ cusSQL = cusSQL.replace("{userId}", String.valueOf(param.getThisUser().getUID()));
+
+ cusSQL = cusSQL.replace("{departmentId}", String.valueOf(param.getThisUser().getUserDepartment()));
+
+ cusSQL = cusSQL.replace("{subCompanyId}", String.valueOf(param.getThisUser().getUserSubCompany1()));
+ }
+ }
+
+ fieldValue = ToolUtilNew.getStaticValueByChangeRule(cusSQL,fieldValue,Util.null2String(param.getWorkflowBaseMap().get("requestId")),detailKeyId);
+
+ return fieldValue;
+ }
+
+ /**
+ * 自定义转换接口
+ * @param dao 明细配置
+ * @param param 转换规则参数集合
+ * @return 返回转换后的值
+ */
+ @MethodRuleNo(value = 9, desc = "自定义接口")
+ public String getCusConvertInterface(NodeFieldMappingDao dao, RuleMethodParam param) {
+ String cusText = dao.getCusSQL();
+ if(Strings.isNullOrEmpty(cusText)){
+ return null;
+ }
+ try {
+ Class clazz = Class.forName(cusText);
+ if(!CusAsyncConvert.class.isAssignableFrom(clazz)){
+ throw new CustomerException(cusText + " 接口不存在或者未实现 weaver.weilin.zhu.common.voucher.convert.CusAsyncConvert类!");
+ }
+ CusAsyncConvert o = (CusAsyncConvert) clazz.newInstance();
+ Map pathParam = Util.parseCusInterfacePathParam(cusText);
+ return o.cusConvert(dao, param, pathParam);
+ }catch (Exception e){
+ return null;
+ }
+ }
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/convert/RuleMethodParam.java b/src/main/java/weaver/weilin/zhu/common/voucher/convert/RuleMethodParam.java
new file mode 100644
index 0000000..f75a93a
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/convert/RuleMethodParam.java
@@ -0,0 +1,43 @@
+package weaver.weilin.zhu.common.voucher.convert;
+
+import lombok.Getter;
+import lombok.Setter;
+import weaver.conn.RecordSet;
+import weaver.hrm.User;
+
+import java.util.Map;
+
+/**
+ * 转换规则方法需要的参数类
+ * @author bleach
+ * @version 2023-07-04
+ */
+@Getter
+@Setter
+public class RuleMethodParam {
+ /**
+ * 流程主表数据集
+ */
+ private RecordSet rs ;
+
+ /**
+ * 流程明细表某一行数据集
+ */
+ private RecordSet rs_detail;
+
+ /**
+ * 流程基础信息数组
+ */
+ private Map workflowBaseMap;
+
+ /**
+ * 明细序列
+ */
+ private int rowNum;
+
+ /**
+ * 当前用户
+ */
+ private User thisUser;
+
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/entity/BaseConfigDao.java b/src/main/java/weaver/weilin/zhu/common/voucher/entity/BaseConfigDao.java
new file mode 100644
index 0000000..045b90e
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/entity/BaseConfigDao.java
@@ -0,0 +1,60 @@
+package weaver.weilin.zhu.common.voucher.entity;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 凭证通用功能
+ * 基础配置
+ * @author bleach
+ * @version 2023-07-10
+ */
+@Data
+public class BaseConfigDao {
+
+ /**
+ * 配置ID
+ */
+ private int id;
+
+ /**
+ * 流程类型ID
+ */
+ private String workflowId;
+
+ /**
+ * 自定义参数值
+ */
+ private String cusParamValue;
+
+ /**
+ * 数据条件
+ */
+ private String dataCondition;
+
+ /**
+ * 异常是否继续
+ */
+ private int exceptionContinue;
+
+ /**
+ * 数据格式 0-JSON 1-XML
+ */
+ private int dataFormat;
+
+ /**
+ * 回写字段名称
+ */
+ private String backFieldname;
+
+ /**
+ * 对象与流程明细映射关系配置
+ */
+ private List objectMappingDaoList;
+
+ /**
+ * 节点与流程字段详细配置
+ */
+ private List nodeFieldMappingDaoList;
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/entity/NodeFieldMappingDao.java b/src/main/java/weaver/weilin/zhu/common/voucher/entity/NodeFieldMappingDao.java
new file mode 100644
index 0000000..41b246c
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/entity/NodeFieldMappingDao.java
@@ -0,0 +1,59 @@
+package weaver.weilin.zhu.common.voucher.entity;
+
+import lombok.Data;
+import weaver.weilin.zhu.common.util.FieldDetailInfo;
+
+/**
+ * 凭证通用功能
+ * 节点与流程字段配置详细
+ * @author bleach
+ * @version 2023-07-10
+ */
+@Data
+public class NodeFieldMappingDao {
+
+ /**
+ * 配置的数据ID
+ */
+ private int id;
+
+ /**
+ * 节点名称
+ */
+ private String nodeName;
+
+ /**
+ * 父节点名称
+ */
+ private String parentNode;
+
+ /**
+ * 节点类型 0-普通文本 1-普通对象 2-数组文本 3-数组对象
+ */
+ private int nodeType;
+
+ /**
+ * 流程字段信息
+ */
+ private FieldDetailInfo wfField;
+
+ /**
+ * 借贷方向
+ */
+ private String entriesDirection;
+
+ /**
+ * 转换规则
+ */
+ private int changeRule;
+
+ /**
+ * 自定义规则
+ */
+ private String cusSQL;
+
+ /**
+ * 特殊属性 0-普通字段 1-金额控制字段 2-科目字段
+ */
+ private int specialAttr;
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/entity/ObjectMappingDao.java b/src/main/java/weaver/weilin/zhu/common/voucher/entity/ObjectMappingDao.java
new file mode 100644
index 0000000..2c4db1f
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/entity/ObjectMappingDao.java
@@ -0,0 +1,43 @@
+package weaver.weilin.zhu.common.voucher.entity;
+
+import lombok.Data;
+
+/**
+ * 凭证通用功能
+ * 对象与流程明细映射关系配置
+ * @author bleach
+ * @version 2023-07-10
+ */
+@Data
+public class ObjectMappingDao {
+
+ /**
+ * 数据ID
+ */
+ private int id;
+
+ /**
+ * 对象名称
+ */
+ private String objectName;
+
+ /**
+ * 流程明细
+ */
+ private int dtIndex;
+
+ /**
+ * 别名
+ */
+ private String alias;
+
+ /**
+ * 借贷方向
+ */
+ private String entriesDirection;
+
+ /**
+ * 数据条件
+ */
+ private String dtCondition;
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/entity/VoucherConstants.java b/src/main/java/weaver/weilin/zhu/common/voucher/entity/VoucherConstants.java
new file mode 100644
index 0000000..2521903
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/entity/VoucherConstants.java
@@ -0,0 +1,62 @@
+package weaver.weilin.zhu.common.voucher.entity;
+
+/**
+ * 凭证通过功能
+ * 常量配置
+ */
+public class VoucherConstants {
+
+
+ /**
+ * 借贷方向 - 非凭证分录
+ */
+ public static final int EntriesDirection_NoVoucher = 0;
+
+ /**
+ * 借贷方向 - 普通借方
+ */
+ public static final int EntriesDirection_Comm_Debit = 1;
+
+
+ /**
+ * 借贷方向 - 税额借方
+ */
+ public static final int EntriesDirection_Tax_Debit = 2;
+
+
+
+ /**
+ * 借贷方向 - 普通贷方
+ */
+ public static final int EntriesDirection_Comm_Credit = 3;
+
+
+ /**
+ * 借贷方向 - 冲销贷方
+ */
+ public static final int EntriesDirection_WriteOff_Credit = 4;
+
+
+ /**
+ * 节点类型 - 普通文本
+ */
+ public static final int Node_Type_Comm_Text = 0;
+
+
+ /**
+ * 节点类型 - 普通对象
+ */
+ public static final int Node_Type_Comm_Object = 1;
+
+
+ /**
+ * 节点类型 - 数组文本
+ */
+ public static final int Node_Type_Array_Text = 2;
+
+
+ /**
+ * 节点类型 - 数组对象
+ */
+ public static final int Node_Type_Array_Object = 3;
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/mapper/CommVoucherSqlMapper.java b/src/main/java/weaver/weilin/zhu/common/voucher/mapper/CommVoucherSqlMapper.java
new file mode 100644
index 0000000..ce813f9
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/mapper/CommVoucherSqlMapper.java
@@ -0,0 +1,143 @@
+package weaver.weilin.zhu.common.voucher.mapper;
+
+import aiyh.utils.annotation.recordset.*;
+import weaver.conn.RecordSet;
+import weaver.weilin.zhu.common.voucher.entity.BaseConfigDao;
+import weaver.weilin.zhu.common.voucher.entity.NodeFieldMappingDao;
+import weaver.weilin.zhu.common.voucher.entity.ObjectMappingDao;
+
+import java.util.List;
+
+/**
+ * 凭证通用功能
+ * 凭证相关数据操作接口
+ * @author bleach
+ */
+@SqlMapper
+public interface CommVoucherSqlMapper {
+
+ /**
+ * 根据流程类型ID获取其对应的配置信息
+ * @param workflowIds 流程类型ID
+ * @return 配置信息
+ */
+ @Select("select * from uf_comm_voucher where wfId in ($t{workflowIds})")
+ @CollectionMappings({
+ @CollectionMapping(
+ property = "objectMappingDaoList",
+ column = "id",
+ id = @Id(value = Integer.class, methodId = 1)
+ ),
+ @CollectionMapping(
+ property = "nodeFieldMappingDaoList",
+ column = "id",
+ id = @Id(value = Integer.class,methodId = 2)
+ )
+ })
+ BaseConfigDao getConfigurationByWorkflowId(@ParamMapper("workflowIds") String workflowIds);
+
+
+
+ /**
+ * 根据流程类型ID获取其对应的配置信息
+ * @param workflowIds 流程类型ID
+ * @return 配置信息
+ */
+ @Select("select * from uf_comm_voucher where wfId in ($t{workflowIds}) and cusParamValue = #{cusParamValue}")
+ @CollectionMappings({
+ @CollectionMapping(
+ property = "objectMappingDaoList",
+ column = "id",
+ id = @Id(value = Integer.class, methodId = 1)
+ ),
+ @CollectionMapping(
+ property = "nodeFieldMappingDaoList",
+ column = "id",
+ id = @Id(value = Integer.class,methodId = 2)
+ )
+ })
+ BaseConfigDao getConfigurationByWorkflowIdAndCondition(@ParamMapper("workflowIds") String workflowIds,@ParamMapper("cusParamValue") String cusParamValue);
+
+
+
+ /**
+ * 获取对象与流程明细表映射配置信息
+ * @param mainId 主表主键ID
+ * @return 映射详细信息
+ */
+ @Select("select * from uf_comm_voucher_dt1 where mainId = #{mainId}")
+ @CollectionMethod(value = 1,desc = "获取对象与流程明细表映射配置信息")
+ List getObjectMappingByMainKeyId(@ParamMapper("mainId") int mainId);
+
+
+
+ /**
+ * 获取对象与流程明细表映射配置信息
+ * @param mainId 主表主键ID
+ * @return 映射详细信息
+ */
+ @Select("select * from uf_comm_voucher_dt2 where mainId = #{mainId}")
+ @Associations({
+ @Association(
+ property = "wfField",
+ column = "wfField",
+ select = "weaver.weilin.zhu.common.util.CommonUtil.getFieldDetailInfo",
+ id = @Id(Integer.class)
+ )
+ })
+ @CaseConversion(value = false)
+ @CollectionMethod(value = 2,desc = "获取节点名称与字段详细配置信息")
+ List getNodeFieldMappingByMainKeyId(@ParamMapper("mainId") int mainId);
+
+
+
+ /**
+ * 查询流程主表的信息
+ * @param billTableMain 明细表名称
+ * @param requestId 流程请求D值
+ * @return 查询结果数据集
+ */
+ @Select("select * from $t{billTableMain} where requestId = #{requestId}")
+ RecordSet getWorkflowMainTableInfo(@ParamMapper("billTableMain") String billTableMain,@ParamMapper("requestId") String requestId);
+
+
+ /**
+ * 查询流程主表的信息
+ * @param billTableMain 明细表名称
+ * @param requestId 流程请求D值
+ * @return 查询结果数据集
+ */
+ @Select("select * from $t{billTableMain} where requestId = #{requestId} and $t{condition}")
+ RecordSet getWorkflowMainTableInfoAndCondition(@ParamMapper("billTableMain") String billTableMain,@ParamMapper("requestId") String requestId,@ParamMapper("condition") String condition);
+
+
+
+ /**
+ * 查询流程某个明细表的信息
+ * @param detailTableName 明细表名称
+ * @param mainId 流程主表主键ID值
+ * @return 查询结果数据集
+ */
+ @Select("select * from $t{detailTableName} where mainId = #{mainId}")
+ RecordSet getWorkflowDetailTableInfo(@ParamMapper("detailTableName") String detailTableName,@ParamMapper("mainId") String mainId);
+
+
+ /**
+ * 查询流程某个明细表的信息
+ * @param detailTableName 明细表名称
+ * @param mainId 流程主表主键ID值
+ * @return 查询结果数据集
+ */
+ @Select("select * from $t{detailTableName} where mainId = #{mainId} and $t{condition}")
+ RecordSet getWorkflowDetailTableInfoAndCondition(@ParamMapper("detailTableName") String detailTableName,@ParamMapper("mainId") String mainId,@ParamMapper("condition") String condition);
+
+ /**
+ * 更新流程表单字段信息
+ * @param billTable 表单名称
+ * @param backFieldName 回写字段名称
+ * @param backFieldValue 回写字段值
+ * @param requestId 流程请求ID
+ */
+ @Update("update $t{billTable} set $t{backFieldName} = #{backFieldValue} where requestId = #{requestId}")
+ void resultBackToWorkflowBill(@ParamMapper("billTable") String billTable,@ParamMapper("backFieldName") String backFieldName,@ParamMapper("backFieldValue") String backFieldValue,@ParamMapper("requestId") String requestId);
+}
diff --git a/src/main/java/weaver/weilin/zhu/common/voucher/util/CommonVoucherUtil.java b/src/main/java/weaver/weilin/zhu/common/voucher/util/CommonVoucherUtil.java
new file mode 100644
index 0000000..190076d
--- /dev/null
+++ b/src/main/java/weaver/weilin/zhu/common/voucher/util/CommonVoucherUtil.java
@@ -0,0 +1,416 @@
+package weaver.weilin.zhu.common.voucher.util;
+
+import aiyh.utils.Util;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.lang3.StringUtils;
+import weaver.conn.RecordSet;
+import weaver.hrm.User;
+import weaver.weilin.zhu.common.util.FieldDetailInfo;
+import weaver.weilin.zhu.common.voucher.convert.FieldChangeRuleMethod;
+import weaver.weilin.zhu.common.voucher.convert.RuleMethodParam;
+import weaver.weilin.zhu.common.voucher.entity.BaseConfigDao;
+import weaver.weilin.zhu.common.voucher.entity.NodeFieldMappingDao;
+import weaver.weilin.zhu.common.voucher.entity.ObjectMappingDao;
+import weaver.weilin.zhu.common.voucher.mapper.CommVoucherSqlMapper;
+import weaver.workflow.workflow.WorkflowVersion;
+import weaver.weilin.zhu.common.voucher.entity.VoucherConstants;
+import weaver.zwl.common.ToolUtilNew;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 凭证通用功能
+ * 凭证操作工具类
+ * @author bleach
+ * @version 2023-07-10
+ */
+public class CommonVoucherUtil {
+
+ /**
+ * 数据操作接口
+ */
+ private final CommVoucherSqlMapper sqlMapper = Util.getMapper(CommVoucherSqlMapper.class);
+
+
+ /**
+ * 流程基础信息
+ */
+ private Map workflowBaseMap;
+
+ /**
+ * 当前用户
+ */
+ private User thisUser;
+
+ /**
+ * 对象与流程明细映射关系配置集合
+ */
+ private List objectMappingDaoList;
+
+ /**
+ * 节点与流程字段配置集合
+ */
+ private List nodeFieldMappingDaoList;
+
+ public CommonVoucherUtil() {
+ }
+
+ /**
+ * 根据流程类型ID和自定义参数值，获取其对应的配置信息
+ * @param workflowId 流程类型ID
+ * @param cusParamValue 自定义参数值
+ * @return 配置信息
+ */
+ public BaseConfigDao getConfigurationByWorkflowId(String workflowId,String cusParamValue){
+ BaseConfigDao dao = new BaseConfigDao();
+
+ //获取该流程类型对应的所有版本ID
+ String allWorkflowIds = WorkflowVersion.getAllVersionStringByWFIDs(workflowId);
+
+ if(StringUtils.isNotBlank(cusParamValue)){
+ dao = sqlMapper.getConfigurationByWorkflowIdAndCondition(allWorkflowIds,cusParamValue);
+ } else {
+ dao = sqlMapper.getConfigurationByWorkflowId(allWorkflowIds);
+ }
+
+ return dao;
+ }
+
+ /**
+ * 递归生成JSON对象
+ * @param parentNode 父节点名称
+ * @param rs 流程主表数据集
+ * @param rs_detail 流程某个明细表某行数据集
+ * @param dtIndex 明细序列
+ * @param itemDirection 借贷方向
+ * @param rowNum 明细序号
+ * @return JSON对象
+ */
+ public JSONObject recursionGenerateJsonObject(String parentNode, RecordSet rs,RecordSet rs_detail, int dtIndex, int itemDirection,int rowNum){
+ JSONObject jsonObject = new JSONObject();
+
+ for(NodeFieldMappingDao nodeFieldMappingDao : nodeFieldMappingDaoList){
+ //节点名称
+ String _nodeName = nodeFieldMappingDao.getNodeName();
+
+ if(StringUtils.isBlank(_nodeName)){
+ continue;
+ }
+
+ /* 父节点名称 */
+ String _parentNode = nodeFieldMappingDao.getParentNode();
+
+ if(!_parentNode.equals(parentNode)){
+ continue;
+ }
+
+ int _nodeType = nodeFieldMappingDao.getNodeType();
+
+ if(itemDirection > 0){//说明为会计分录
+ String _entriesDirection = nodeFieldMappingDao.getEntriesDirection();
+
+ if(!_entriesDirection.contains(String.valueOf(itemDirection))){//传进来的会计分录方向与当前不一致
+ continue;
+ }
+ }
+
+ //流程字段新
+ FieldDetailInfo workflowField = nodeFieldMappingDao.getWfField();
+
+ if(workflowField != null){
+ int _viewType = workflowField.getViewType();
+
+ int _detailIndex = workflowField.getDetailIndex();
+ if(_viewType == 1 && _detailIndex != dtIndex){
+ continue;
+ }
+ }
+
+ RuleMethodParam param = new RuleMethodParam();
+ param.setRs(rs);
+ param.setRs_detail(rs_detail);
+ param.setWorkflowBaseMap(workflowBaseMap);
+ param.setRowNum(rowNum);
+ param.setThisUser(thisUser);
+
+ switch (_nodeType){
+ case VoucherConstants.Node_Type_Comm_Text:
+ String nodeValue = FieldChangeRuleMethod.VALUE_RULE_FUNCTION.get(nodeFieldMappingDao.getChangeRule()).apply(nodeFieldMappingDao, param);
+
+ if(nodeFieldMappingDao.getSpecialAttr() == 1 && Util.getDoubleValue(nodeValue,0.0) == 0){
+ return null;
+ }
+
+ jsonObject.put(_nodeName,nodeValue);
+
+ break;
+ case VoucherConstants.Node_Type_Comm_Object:
+ JSONObject commObj = recursionGenerateJsonObject(_nodeName,rs,rs_detail,dtIndex,itemDirection,rowNum);
+
+ jsonObject.put(_nodeName,commObj);
+ break;
+ case VoucherConstants.Node_Type_Array_Text:
+ JSONArray arrayText = new JSONArray();
+
+ String arrayTextValue = FieldChangeRuleMethod.VALUE_RULE_FUNCTION.get(nodeFieldMappingDao.getChangeRule()).apply(nodeFieldMappingDao,param);
+
+ if(StringUtils.isNotBlank(arrayTextValue)){
+ arrayText.addAll(Arrays.asList(Util.TokenizerString2(arrayTextValue, ",")));
+ }
+
+ jsonObject.put(_nodeName,arrayText);
+ break;
+ case VoucherConstants.Node_Type_Array_Object:
+
+ JSONArray itemArray = new JSONArray();
+
+ int _rowNum = 1;
+
+ for(ObjectMappingDao objectMappingDao : objectMappingDaoList){
+ String _objectName = objectMappingDao.getObjectName();
+
+ //别名
+ String alias = objectMappingDao.getAlias();
+
+ if(!_objectName.equals(_nodeName) || (StringUtils.isNotBlank(alias) && !alias.equals(_nodeName))){//对象节点名称 与当前节点不一致
+ continue;
+ }
+
+ int _dtIndex = objectMappingDao.getDtIndex();
+
+ String _entriesDirection = objectMappingDao.getEntriesDirection();
+
+ //父节点名称
+ String tmpParentNode = StringUtils.isNotBlank(alias) ? alias : _objectName;
+
+ if(_dtIndex > 0){
+ String dtCondition = objectMappingDao.getDtCondition();
+
+ RecordSet _rs_detail;
+
+ //流程明细表名称
+ String detailTable = Util.null2String(workflowBaseMap.get("billTableName")) + "_dt" + _dtIndex;
+
+ if(StringUtils.isNotBlank(dtCondition)){
+ dtCondition = ToolUtilNew.staticToDBC(dtCondition);
+
+ _rs_detail = sqlMapper.getWorkflowDetailTableInfoAndCondition(detailTable,Util.null2String(workflowBaseMap.get("mainId")),dtCondition);
+ } else {
+ _rs_detail = sqlMapper.getWorkflowDetailTableInfo(detailTable,Util.null2String(workflowBaseMap.get("mainId")));
+ }
+
+ while(_rs_detail.next()){
+ for(String direction : Util.TokenizerString2(_entriesDirection,",")) {
+ JSONObject itemObj = recursionGenerateJsonObject(tmpParentNode, rs, _rs_detail, _dtIndex, Util.getIntValue(direction), _rowNum++);
+
+ if(itemObj == null || itemObj.isEmpty()){
+ _rowNum--;
+ } else {
+ itemArray.add(itemObj);
+ }
+ }
+ }
+ } else {//说明信息来自主表
+ for(String direction : Util.TokenizerString2(_entriesDirection,",")){
+ JSONObject itemObj = recursionGenerateJsonObject(tmpParentNode,rs,null,0,Util.getIntValue(direction),_rowNum++);
+
+ if(itemObj == null || itemObj.isEmpty()){
+ _rowNum--;
+ } else {
+ itemArray.add(itemObj);
+ }
+ }
+ }
+ }
+
+ jsonObject.put(_nodeName,itemArray);
+
+ break;
+ }
+ }
+
+ return jsonObject;
+ }
+
+ /**
+ * 递归生成XML字符串
+ * @param parentNode 父节点名称
+ * @param rs 流程主表数据集
+ * @param rs_detail 流程某个明细表某行数据集
+ * @param dtIndex 明细序列
+ * @param itemDirection 借贷方向
+ * @param rowNum 明细序号
+ * @return XML字符串
+ */
+ public StringBuilder recursionGenerateXML(String parentNode, RecordSet rs,RecordSet rs_detail, int dtIndex, int itemDirection,int rowNum){
+ StringBuilder xmlBuilder = new StringBuilder();
+ for(NodeFieldMappingDao nodeFieldMappingDao : nodeFieldMappingDaoList) {
+ //节点名称
+ String _nodeName = nodeFieldMappingDao.getNodeName();
+
+ if (StringUtils.isBlank(_nodeName)) {
+ continue;
+ }
+
+ //父节点名称
+ String _parentNode = nodeFieldMappingDao.getParentNode();
+
+ if (!_parentNode.equals(parentNode)) {
+ continue;
+ }
+
+ int _nodeType = nodeFieldMappingDao.getNodeType();
+
+ if (itemDirection > 0) {//说明为会计分录
+ String _entriesDirection = nodeFieldMappingDao.getEntriesDirection();
+
+ if (!_entriesDirection.contains(String.valueOf(itemDirection))) {//传进来的会计分录方向与当前不一致
+ continue;
+ }
+ }
+
+ //流程字段新
+ FieldDetailInfo workflowField = nodeFieldMappingDao.getWfField();
+
+ if (workflowField != null) {
+ int _viewType = workflowField.getViewType();
+
+ int _detailIndex = workflowField.getDetailIndex();
+ if (_viewType == 1 && _detailIndex != dtIndex) {
+ continue;
+ }
+ }
+
+ RuleMethodParam param = new RuleMethodParam();
+ param.setRs(rs);
+ param.setRs_detail(rs_detail);
+ param.setWorkflowBaseMap(workflowBaseMap);
+ param.setRowNum(rowNum);
+ param.setThisUser(thisUser);
+
+ switch (_nodeType) {
+ case VoucherConstants.Node_Type_Comm_Text:
+ String nodeValue = FieldChangeRuleMethod.VALUE_RULE_FUNCTION.get(nodeFieldMappingDao.getChangeRule()).apply(nodeFieldMappingDao, param);
+
+ if (nodeFieldMappingDao.getSpecialAttr() == 1 && Util.getDoubleValue(nodeValue, 0.0) == 0) {
+ return null;
+ }
+ xmlBuilder.append("<").append(_nodeName).append(">");
+ xmlBuilder.append(nodeValue);
+ xmlBuilder.append("\n");
+ break;
+ case VoucherConstants.Node_Type_Array_Text:
+ break;
+
+ case VoucherConstants.Node_Type_Comm_Object:
+ StringBuilder innerXML = recursionGenerateXML(_nodeName,rs,rs_detail,dtIndex,itemDirection,rowNum);
+ xmlBuilder.append("<").append(_nodeName).append(">");
+ xmlBuilder.append(innerXML);
+ xmlBuilder.append("\n");
+ break;
+
+ case VoucherConstants.Node_Type_Array_Object:
+ int _rowNum = 1;
+
+ for(ObjectMappingDao objectMappingDao : objectMappingDaoList) {
+ String _objectName = objectMappingDao.getObjectName();
+
+ //别名
+ String alias = objectMappingDao.getAlias();
+
+ if (!_objectName.equals(_nodeName) || (StringUtils.isNotBlank(alias) && !alias.equals(_nodeName))) {//对象节点名称 与当前节点不一致
+ continue;
+ }
+
+ int _dtIndex = objectMappingDao.getDtIndex();
+
+ String _entriesDirection = objectMappingDao.getEntriesDirection();
+
+ //父节点名称
+ String tmpParentNode = StringUtils.isNotBlank(alias) ? alias : _objectName;
+
+ if (_dtIndex > 0) {
+ String dtCondition = objectMappingDao.getDtCondition();
+
+ RecordSet _rs_detail;
+
+ //流程明细表名称
+ String detailTable = Util.null2String(workflowBaseMap.get("billTableName")) + "_dt" + _dtIndex;
+
+ if (StringUtils.isNotBlank(dtCondition)) {
+ dtCondition = ToolUtilNew.staticToDBC(dtCondition);
+
+ _rs_detail = sqlMapper.getWorkflowDetailTableInfoAndCondition(detailTable, Util.null2String(workflowBaseMap.get("mainId")), dtCondition);
+ } else {
+ _rs_detail = sqlMapper.getWorkflowDetailTableInfo(detailTable, Util.null2String(workflowBaseMap.get("mainId")));
+ }
+
+ while (_rs_detail.next()) {
+ for (String direction : Util.TokenizerString2(_entriesDirection, ",")) {
+ StringBuilder innerItem = recursionGenerateXML(tmpParentNode,rs,_rs_detail,_dtIndex,Util.getIntValue(direction),_rowNum);
+
+ if(innerItem != null && innerItem.length() > 0){
+ xmlBuilder.append("<").append(_nodeName).append(">");
+ xmlBuilder.append(innerItem);
+ xmlBuilder.append("\n");
+ } else {
+ _rowNum--;
+ }
+ }
+ }
+ } else { //说明数据来自主表
+ for(String direction : Util.TokenizerString2(_entriesDirection,",")){
+ StringBuilder innerItem = recursionGenerateXML(tmpParentNode,rs,null,0,Util.getIntValue(direction),_rowNum++);
+
+ if(innerItem != null && innerItem.length() > 0){
+ xmlBuilder.append("<").append(_nodeName).append(">");
+ xmlBuilder.append(innerItem);
+ xmlBuilder.append("\n");
+ } else {
+ _rowNum--;
+ }
+ }
+ }
+ }
+
+ break;
+ }
+ }
+ return xmlBuilder;
+ }
+
+ public User getThisUser() {
+ return thisUser;
+ }
+
+ public void setThisUser(User thisUser) {
+ this.thisUser = thisUser;
+ }
+
+ public Map getWorkflowBaseMap() {
+ return workflowBaseMap;
+ }
+
+ public void setWorkflowBaseMap(Map workflowBaseMap) {
+ this.workflowBaseMap = workflowBaseMap;
+ }
+
+ public List getObjectMappingDaoList() {
+ return objectMappingDaoList;
+ }
+
+ public void setObjectMappingDaoList(List objectMappingDaoList) {
+ this.objectMappingDaoList = objectMappingDaoList;
+ }
+
+ public List getNodeFieldMappingDaoList() {
+ return nodeFieldMappingDaoList;
+ }
+
+ public void setNodeFieldMappingDaoList(List nodeFieldMappingDaoList) {
+ this.nodeFieldMappingDaoList = nodeFieldMappingDaoList;
+ }
+}
diff --git a/src/main/java/weaver/weilin/zhu/xyzq/scheduled/sqlmapper/OrganizationSyncSqlMapper.java b/src/main/java/weaver/weilin/zhu/xyzq/scheduled/sqlmapper/OrganizationSyncSqlMapper.java
index b75d680..f3ade99 100644
--- a/src/main/java/weaver/weilin/zhu/xyzq/scheduled/sqlmapper/OrganizationSyncSqlMapper.java
+++ b/src/main/java/weaver/weilin/zhu/xyzq/scheduled/sqlmapper/OrganizationSyncSqlMapper.java
@@ -48,7 +48,7 @@ public interface OrganizationSyncSqlMapper {
@Association(
property = "modeField",
column = "modeField",
- select = "weaver.common.util.CommonUtil.getFieldInfo",
+ select = "weaver.weilin.zhu.common.util.CommonUtil.getFieldDetailInfo",
id = @Id(Integer.class)
)
})
diff --git a/src/main/java/weaver/weilin/zhu/xyzq/scheduled/task/SyncOrgDataTask.java b/src/main/java/weaver/weilin/zhu/xyzq/scheduled/task/SyncOrgDataTask.java
index a6e2c5a..b424c23 100644
--- a/src/main/java/weaver/weilin/zhu/xyzq/scheduled/task/SyncOrgDataTask.java
+++ b/src/main/java/weaver/weilin/zhu/xyzq/scheduled/task/SyncOrgDataTask.java
@@ -22,7 +22,6 @@ public class SyncOrgDataTask extends BaseCronJob {
public void execute() {
if(StringUtils.isNotBlank(keyId)){
OrganizationSyncUtil syncUtil = new OrganizationSyncUtil();
-
syncUtil.syncData(Util.getIntValue(keyId,0));
}
}
diff --git a/src/main/jinwei_tao_old_src/com/api/taojw/common/action/RequestDataToApiAction.java b/src/main/jinwei_tao_old_src/com/api/taojw/common/action/RequestDataToApiAction.java
index a9d2b8e..8fcdd87 100644
--- a/src/main/jinwei_tao_old_src/com/api/taojw/common/action/RequestDataToApiAction.java
+++ b/src/main/jinwei_tao_old_src/com/api/taojw/common/action/RequestDataToApiAction.java
@@ -67,7 +67,7 @@ public class RequestDataToApiAction implements Action {
} catch (Exception e) {
requestInfo.getRequestManager().setMessageid("2022052791002");
requestInfo.getRequestManager().setMessagecontent("Action接口发生异常,requestId:"+ requestId +"，请联系管理员!");
- logger.error("VoucherAction.select * from workflow_requestBase error;requestId:" + requestId + "exception:" + e.getMessage() + ";e:" + e);
+ logger.error("CommonVoucherAction.select * from workflow_requestBase error;requestId:" + requestId + "exception:" + e.getMessage() + ";e:" + e);
return Action.FAILURE_AND_CONTINUE;
}
//获取当前流程信息
diff --git a/src/main/jinwei_tao_old_src/weaver/taojw/common/action/RequestDataToApiAction.java b/src/main/jinwei_tao_old_src/weaver/taojw/common/action/RequestDataToApiAction.java
index 68fa61b..c527a91 100644
--- a/src/main/jinwei_tao_old_src/weaver/taojw/common/action/RequestDataToApiAction.java
+++ b/src/main/jinwei_tao_old_src/weaver/taojw/common/action/RequestDataToApiAction.java
@@ -66,7 +66,7 @@ public class RequestDataToApiAction implements Action {
} catch (Exception e) {
requestInfo.getRequestManager().setMessageid("2022052791002");
requestInfo.getRequestManager().setMessagecontent("Action接口发生异常,requestId:"+ requestId +"，请联系管理员!");
- logger.error("VoucherAction.select * from workflow_requestBase error;requestId:" + requestId + "exception:" + e.getMessage() + ";e:" + e);
+ logger.error("CommonVoucherAction.select * from workflow_requestBase error;requestId:" + requestId + "exception:" + e.getMessage() + ";e:" + e);
return Action.FAILURE_AND_CONTINUE;
}
//获取当前流程信息
diff --git a/src/test/java/bokang/xiao/NormalTest.java b/src/test/java/bokang/xiao/NormalTest.java
index 1803b34..bd19a33 100644
--- a/src/test/java/bokang/xiao/NormalTest.java
+++ b/src/test/java/bokang/xiao/NormalTest.java
@@ -45,6 +45,7 @@ import weaver.bokang.xiao.porsche.schedule.CompanyWriteBackSchedule;
import weaver.bokang.xiao.porsche.schedule.SalaryUpdateSchedule;
import weaver.bokang.xiao.sh_bigdata.action.DataPushAction;
import weaver.bokang.xiao.shtx.schedule.ExamineSchedule;
+import weaver.bokang.xiao.shtx.schedule.SyncTeachDataSchedule;
import weaver.bokang.xiao.xhny_mode.search.CustomSearchDepart;
import weaver.bokang.xiao.xhny_report.entity.SourceTrackingData;
import weaver.bokang.xiao.xhny_report.schedule.GenerateReportSchedule;
@@ -84,7 +85,7 @@ public class NormalTest extends BaseTest {
@Test
public void testWord(){
- GenerateFileUtil.createCronJobDocument(ExamineSchedule.class);
+ GenerateFileUtil.createCronJobDocument(SyncTeachDataSchedule.class);
//GenerateFileUtil.createActionDocument(DataPushAction.class);
//GenerateFileUtil.createActionDocument(DateFieldUpdateAction.class);
}
@@ -126,8 +127,8 @@ public class NormalTest extends BaseTest {
ParseTest parseTest = new ParseTest();
Map resultData = parseTest.getResultData();
System.out.println(JSON.toJSONString(resultData));
- ResponseMappingDeal responseMappingDeal = new ResponseMappingDeal();
- responseMappingDeal.doResponseSync("test1",resultData);
+ //ResponseMappingDeal responseMappingDeal = new ResponseMappingDeal();
+ //responseMappingDeal.doResponseSync("test1",resultData);
}
@Test
diff --git a/src/test/java/xuanran/wang/eny/ModelFieldAsyncTest.java b/src/test/java/xuanran/wang/eny/ModelFieldAsyncTest.java
index cf1698c..1810c2f 100644
--- a/src/test/java/xuanran/wang/eny/ModelFieldAsyncTest.java
+++ b/src/test/java/xuanran/wang/eny/ModelFieldAsyncTest.java
@@ -9,6 +9,7 @@ import aiyh.utils.tool.org.apache.commons.jexl3.MapContext;
import basetest.BaseTest;
import com.alibaba.fastjson.JSONObject;
import com.api.nonstandardext.model_field_async.entity.ModelFieldAsyncConfigClass;
+import com.api.xuanran.wang.eny.workflow.mapper.ExchangeRateMapper;
import org.apache.commons.lang3.StringUtils;
import org.junit.Test;
import com.api.nonstandardext.model_field_async.entity.ModelFieldAsyncConfig;
@@ -89,6 +90,22 @@ public class ModelFieldAsyncTest extends BaseTest {
return (T) response.get(split[len - 1]);
}
+ private final ExchangeRateMapper mapper = Util.getMapper(ExchangeRateMapper.class);
+ @Test
+ public void testE(){
+ String json ="{\"date\":\"2021-04-07\",\"interfaceCurrency\":\"CNY\",\"printParams\":1,\"fieldList\":[{\"field\":\"field11111\",\"money\":12920295.96}],\"baseCurrency\":\"1\"} ";
+ Map map = JSONObject.parseObject(json, Map.class);
+ List> fieldList = (List>) map.get("fieldList");
+ System.out.println("list : " + fieldList);
+ for (Map objectMap : fieldList) {
+ double money = Util.getDoubleValue(Util.null2DefaultStr(objectMap.get("money"), ""), 0);
+ if(money == 0){
+ break;
+ }
+ System.out.println("money : " + money);
+ }
+ }
+
}
diff --git a/src/test/java/youhong/ai/utiltest/resultjsonparase/ParseTest.java b/src/test/java/youhong/ai/utiltest/resultjsonparase/ParseTest.java
index b7620a4..7694a0e 100644
--- a/src/test/java/youhong/ai/utiltest/resultjsonparase/ParseTest.java
+++ b/src/test/java/youhong/ai/utiltest/resultjsonparase/ParseTest.java
@@ -97,7 +97,7 @@ public class ParseTest extends BaseTest {
Map data = new HashMap<>();
data.put("name", "肖博亢");
data.put("age", 18);
- data.put("sex", "女");
+ data.put("sex", "男");
List> friends = new ArrayList<>();
for (int i = 0; i < 5; i++) {
Map friend = new HashMap<>();