package com.kingdee.eas.custom.esign.service; import com.alibaba.fastjson.JSONObject; import com.kingdee.bos.BOSException; import com.kingdee.bos.Context; import com.kingdee.bos.bsf.service.app.IHRMsfService; import com.kingdee.bos.metadata.entity.EntityViewInfo; import com.kingdee.bos.metadata.entity.FilterInfo; import com.kingdee.bos.metadata.entity.FilterItemInfo; import com.kingdee.bos.metadata.entity.SelectorItemCollection; import com.kingdee.bos.metadata.query.util.CompareType; import com.kingdee.bos.sql.ParserException; import com.kingdee.bos.util.BOSObjectType; import com.kingdee.bos.util.BOSUuid; import com.kingdee.eas.common.EASBizException; import com.kingdee.eas.custom.dataconfig.utils.SqlUtils; import com.kingdee.eas.custom.entryconfig.DataConfigInfo; import com.kingdee.eas.custom.entryconfig.DataConfigSelectFieldEntryCollection; import com.kingdee.eas.custom.entryconfig.DataConfigSelectFieldEntryInfo; import com.kingdee.eas.custom.esign.*; import com.kingdee.eas.custom.esign.bizEnum.ComponentTypeEnum; import com.kingdee.eas.custom.esign.utils.ESignFieldMappingUtils; import com.kingdee.eas.fi.arap.util.DBUtil; import com.kingdee.jdbc.rowset.IRowSet; import java.sql.SQLException; import java.text.SimpleDateFormat; import java.util.Map; public class OtherESignConfigDataService implements IHRMsfService { @Override public Object process(Context context, Map map) throws EASBizException, BOSException { // 从参数映射中获取"number"参数值，用于定位配置信息 Object o = map.get("number"); // 从参数映射中获取"filter"参数值，用于构建查询过滤条件 Object id = map.get("id"); // 若"number"参数为null，返回空字符串（无效请求） if (o == null) { return ""; } // 将"number"参数转换为字符串类型 String number = o.toString(); // 将"filter"参数转换为字符串类型（若为null则转换为"null"字符串） String filter = id.toString(); // 声明实体视图信息对象，用于查询时的字段映射配置 EntityViewInfo entityViewInfo = null; try { // 调用方法获取实体视图信息，该视图包含查询所需的字段映射配置 entityViewInfo = this.getEntityViewInfo(number); } catch (ParserException e) { // 解析异常时，封装为运行时异常抛出 throw new RuntimeException(e); } // 通过字段映射工厂，根据实体视图信息查询对应的字段映射集合 FieldMappingCollection fieldMappingCollection = FieldMappingFactory. getLocalInstance(context).getFieldMappingCollection(entityViewInfo); // 创建SQL工具类实例，用于SQL语句的构建辅助 //SqlUtils sqlUtils = new SqlUtils(); // 创建电子签字段映射工具类实例，用于字段映射的核心处理 ESignFieldMappingUtils utils = new ESignFieldMappingUtils(); // 获取字段映射集合中的第一个映射信息（默认取第一个配置项） FieldMappingInfo fieldMappingInfo = fieldMappingCollection.get(0); // 获取当前字段映射信息中的明细项集合（包含具体的字段映射关系） FieldMappingEntryCollection entrys = fieldMappingInfo.getEntrys(); // 获取当前字段映射信息对应的数据源配置 //DataConfigInfo dataSource = fieldMappingInfo.getDataSource(); // 验证数据源配置是否有效（非空且编号存在） //if (dataSource != null && dataSource.getNumber() != null && !dataSource.getNumber().equals("")) { // 通过工具类从字段映射明细中获取电子签SQL所需的字段集合 //DataConfigSelectFieldEntryCollection eSignSqlField = utils.getESignSqlField(entrys); // 创建字符串构建器，用于拼接SQL查询的字段部分 //StringBuilder sqlField = new StringBuilder(); // 调用SQL工具类，将电子签字段集合拼接为SQL的SELECT子句 //sqlUtils.getSelectField(eSignSqlField, sqlField); // 获取数据源配置的编号 //String number1 = dataSource.getNumber(); // 获取当前字段映射信息对应的电子签模板信息 ESignTemplateInfo eSignFile = fieldMappingInfo.getESignFile(); // if (sqlField.toString().equals("")) { // JSONObject jsonObject = this.reassembleData(eSignFile, context); // return jsonObject; // } // 通过工具类根据数据源编号和上下文获取电子签基础查询SQL //String eSignSql = utils.getESignSql(number1, context); // 替换SQL中的{{filed}}占位符为实际拼接的查询字段 //eSignSql = eSignSql.replace("{{filed}}",sqlField.toString()); // 在SQL末尾添加过滤条件（换行分隔，便于阅读） //eSignSql += "\n"+filter; // 执行SQL查询并将结果封装为JSON对象（包含字段映射关系） String eSignTemplateNum = eSignFile.getESignTemplateNum(); JSONObject data = this.getData(getSql(filter), context, entrys,eSignTemplateNum); // 重新组装电子签模板数据为JSON对象 JSONObject jsonObject = this.reassembleData(eSignFile,eSignTemplateNum, context); // 合并查询数据与模板数据，返回合并后的JSON对象 JSONObject newJSONObject = utils.mergeAgreements(data, jsonObject); return newJSONObject; // } // else { // // 若数据源无效，直接获取电子签模板信息 // ESignTemplateInfo eSignFile = fieldMappingInfo.getESignFile(); // // 重新组装模板数据并返回 // JSONObject jsonObject = this.reassembleData(eSignFile, context); // return jsonObject; // } } public String getSql(String id) { StringBuilder sql = new StringBuilder(); sql.append("SELECT").append("\n"); sql.append("person.FNAME_L2 AS person_name , -- 人员姓名").append("\n"); sql.append("elation.FEnterDate eDate , --入职日期").append("\n"); sql.append("-- 1. 固定工资（税前）= 标准基本工资+综合工资+其他工资+加班工资").append("\n"); sql.append("ISNULL(SUM(CASE WHEN sitem.FNUMBER IN ('TD01', 'T012', 'T013', 'TD02') THEN fas.FMoney ELSE 0 END), 0) AS fixed_salary ,").append("\n"); sql.append("-- 2. 试用期固定工资（税前）= 标准基本工资+综合工资+其他工资+加班工资").append("\n"); sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER IN ('TD01', 'T012', 'T013', 'TD02') THEN fas.FMoney ELSE 0 END), 0) AS prob_fixed_salary ,").append("\n"); sql.append(" -- 3. 绩效奖金（税前）= 标准绩效奖金").append("\n"); sql.append("ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'TD04' THEN fas.FMoney ELSE 0 END), 0) AS perf_bonus ,").append("\n"); sql.append("-- 4. 试用期绩效奖金（税前）= 试用期标准绩效奖金").append("\n"); sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'TD74' THEN fas.FMoney ELSE 0 END), 0) AS prob_perf_bonus ,").append("\n"); sql.append("-- 5. 国内餐补 = 餐补补贴").append("\n"); sql.append("ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'T025' THEN fas.FMoney ELSE 0 END), 0) AS domestic_meal_subsidy ,").append("\n"); sql.append(" -- 6. 艰苦补贴 = 艰苦补贴").append("\n"); sql.append("ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'T038' THEN fas.FMoney ELSE 0 END), 0) AS hardship_subsidy ,").append("\n"); sql.append("-- 7. 社保公积金补贴 = 社保公积金补贴").append("\n"); sql.append("ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'TD101' THEN fas.FMoney ELSE 0 END), 0) AS social_fund").append("\n"); sql.append("FROM").append("\n"); sql.append("T_bd_Person person").append("\n"); sql.append(" LEFT JOIN T_HR_EmpLaborRelation elation on person.fid = elation.FPersonID").append("\n"); sql.append("LEFT JOIN").append("\n"); sql.append("T_HR_SFixAdjustSalary fas ON person.FID = fas.FPersonID").append("\n"); sql.append(" LEFT JOIN").append("\n"); sql.append("T_HR_SCmpItem sitem ON fas.FCmpItemID = sitem.FID").append("\n"); sql.append("WHERE").append("\n"); sql.append("sitem.FNUMBER IN ('TD01', 'T012', 'T013', 'TD02', 'TD04', 'TD74', 'T025', 'T038', 'TD101')").append("\n"); BOSUuid read = BOSUuid.read(id); BOSObjectType type = read.getType(); System.out.println(type.toString()); if (type.toString().equals("7BD37592")){//id类型为合同 sql.append("and person.fid in (select FEmployeeID from T_HR_EmployeeContract where fid = '"+id+"')").append("\n"); }else if (type.toString().equals("80EF7DED")){//id类型为员工 sql.append("and person.fid = '"+id+"'").append("\n"); } sql.append(" GROUP BY").append("\n"); sql.append("person.FID, person.FNAME_L2 , elation.FEnterDate").append("\n"); sql.append("ORDER BY").append("\n"); sql.append("person.FNAME_L2").append("\n"); return sql.toString(); } /** * 执行SQL查询并将结果封装为JSON对象 * * @param sql 要执行的查询SQL * @param context 上下文对象 * @param entrys 字段映射明细集合 * @return 封装后的JSON对象，包含电子签模板各字段信息 */ public JSONObject getData(String sql, Context context, FieldMappingEntryCollection entrys,String eSignTemplateNum) { // 创建JSON对象用于存储最终封装的数据 JSONObject jsonObject = new JSONObject(); try { // 执行SQL查询，获取结果集 IRowSet iRowSet1 = DBUtil.executeQuery(context, sql); // 遍历结果集中的每一行数据 while (iRowSet1.next()) { // 遍历每个字段映射明细项 for (int i = 0; i < entrys.size(); i++) { // 获取当前索引对应的字段映射明细信息 FieldMappingEntryInfo fieldMappingEntryInfo = entrys.get(i); // 获取明细项中关联的电子签模板字段信息 ESignTemplateFileEntryFieldInfo eField = fieldMappingEntryInfo.getEField(); // 判断该字段是否无效（已废弃） boolean invalid = eField.isInvalid(); // 若字段无效，跳过当前循环（不处理） if (invalid) { continue; } // 获取明细项中关联的电子签模板明细信息 ESignTemplateFileEntryInfo template = fieldMappingEntryInfo.getTemplate(); // 获取电子签模板的ID String eSignTemplateId = template.getESignTemplateId(); // 从JSON对象中获取该模板ID对应的子JSON对象 JSONObject templateJSON = jsonObject.getJSONObject(eSignTemplateId); // 若模板对应的子JSON对象不存在，则创建并初始化（设置ID和名称） if (templateJSON == null) { templateJSON = new JSONObject(); templateJSON.put("id", eSignTemplateId); // 设置模板ID templateJSON.put("name", template.getName()); // 设置模板名称 templateJSON.put("eSignTemplateNum",eSignTemplateNum); jsonObject.put(eSignTemplateId, templateJSON); // 将模板信息存入主JSON对象 } // 从模板子JSON对象中获取字段信息对应的子JSON对象 JSONObject fields = templateJSON.getJSONObject("fields"); // 若字段信息子JSON对象不存在，则创建并添加到模板子JSON中 if (fields == null) { fields = new JSONObject(); templateJSON.put("fields", fields); } // 获取电子签模板字段的ID String templateFieldId = eField.getTemplateFieldId(); // 创建用于存储字段值信息的JSON对象 JSONObject value = new JSONObject(); value.put("name", eField.getTemplateFieldName()); // 设置字段名称 // 获取明细项中关联的数据源字段信息 //DataConfigSelectFieldEntryInfo dataSourceField = fieldMappingEntryInfo.getDataSourceField(); // if (dataSourceField==null){ // value.put("value",""); // value.put("dataFormat", eField.getDataFormat()); // }else { // 获取数据源字段的映射键（对应数据库列名） String name = fieldMappingEntryInfo.getEFieldMark(); // 去除映射键中的双引号（处理可能的格式问题） //name = name.replace("\"", ""); // 从结果集中获取该字段对应的值，并存入字段值JSON对象 if (name != null && !name.equals("")) { Object object = null; try { object= iRowSet1.getObject(name); }catch (Exception e){ object= null; } value.put("value",object); } // 设置字段的数据类型（取自数据源字段的类型别名） //value.put("dataType", dataSourceField.getDataType().getAlias()); // if (dataSourceField.getDataType().getAlias().equals("Date")) { // Object object = iRowSet1.getObject(name); // if (object != null) { // SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy年MM月dd日"); // value.put("value", simpleDateFormat.format(iRowSet1.getDate(name))); // } // value.put("dataFormat", eField.getDataFormat()); // } //} if (eField.getComponentType().getValue() == 6 || eField.getComponentType().getValue() == 106) { value.put("positionX", eField.getPositionX()); value.put("positionY", eField.getPositionY()); value.put("pageNum", eField.getPageNum()); } // 将字段值信息存入字段信息子JSON对象（以模板字段ID为键） fields.put(templateFieldId, value); } } } catch (BOSException e) { // BOS异常时，封装为运行时异常抛出 throw new RuntimeException(e); } catch (SQLException e) { // SQL异常时，封装为运行时异常抛出 throw new RuntimeException(e); } // 返回封装好的JSON对象 return jsonObject; } /** * 构建查询字段映射信息的实体视图 * * @param number 字段映射的编号，用于过滤 * @return 构建好的实体视图信息 * @throws ParserException 解析异常 */ public EntityViewInfo getEntityViewInfo(String number) throws ParserException { // 创建实体视图信息对象 EntityViewInfo entityViewInfo = new EntityViewInfo(); // 创建选择项集合，用于指定查询返回的字段 SelectorItemCollection selectorItemCollection = new SelectorItemCollection(); selectorItemCollection.add("*"); // 选择所有基础字段 selectorItemCollection.add("eSignFile.*"); // 选择关联的电子签文件的所有字段 selectorItemCollection.add("dataSource.*"); // 选择关联的数据源的所有字段 selectorItemCollection.add("entrys.*"); // 选择关联的明细项的所有字段 selectorItemCollection.add("entrys.eField.*"); // 选择明细项中电子签字段的所有字段 selectorItemCollection.add("entrys.dataSourceField.*"); // 选择明细项中数据源字段的所有字段 selectorItemCollection.add("entrys.template.*"); // 选择明细项中模板的所有字段 // 为实体视图设置选择项（指定查询返回的字段集） entityViewInfo.setSelector(selectorItemCollection); // 创建过滤信息对象，用于设置查询条件 FilterInfo filterInfo = new FilterInfo(); // 添加过滤条件：字段映射的编号等于传入的number filterInfo.getFilterItems().add(new FilterItemInfo("number", number)); // 为实体视图设置过滤条件 entityViewInfo.setFilter(filterInfo); // 返回构建好的实体视图信息 return entityViewInfo; } /** * 重新组装数据（当前未实现完整逻辑，仅基础框架） * * @param eSignFile 电子签模板信息 * @param context 上下文对象 * @return 重新组装后的JSON对象（数据可能为null） */ public JSONObject reassembleData(ESignTemplateInfo eSignFile,String eSignTemplateNum, Context context) { // 获取电子签模板的ID BOSUuid id = eSignFile.getId(); // 声明用于存储组装后数据的JSON对象 JSONObject dataJSON; try { // 初始化数据JSON对象 dataJSON = new JSONObject(); // 创建实体视图信息对象 EntityViewInfo entityViewInfo = new EntityViewInfo(); // 创建选择项集合，指定查询返回的字段 SelectorItemCollection selectorItemCollection = new SelectorItemCollection(); selectorItemCollection.add("*"); // 选择所有基础字段 selectorItemCollection.add("Parent1.*"); // 选择父级对象的所有字段 // 为实体视图设置选择项 entityViewInfo.setSelector(selectorItemCollection); // 创建过滤信息对象 FilterInfo filterInfo = new FilterInfo(); // 添加过滤条件：字段未失效（Invalid为false） filterInfo.getFilterItems().add(new FilterItemInfo("Invalid", 1, CompareType.NOTEQUALS)); // 添加过滤条件：父级的父级ID等于电子签模板ID filterInfo.getFilterItems().add(new FilterItemInfo("Parent1.Parent.id", id)); // 为实体视图设置过滤条件 entityViewInfo.setFilter(filterInfo); // 根据实体视图查询电子签模板字段明细集合 ESignTemplateFileEntryFieldCollection eFields = ESignTemplateFileEntryFieldFactory. getLocalInstance(context).getESignTemplateFileEntryFieldCollection(entityViewInfo); // 遍历字段明细集合 for (int i = 0; i < eFields.size(); i++) { // 获取当前索引对应的电子签模板字段明细 ESignTemplateFileEntryFieldInfo eFile = eFields.get(i); // 获取该字段明细的父级对象（模板明细） ESignTemplateFileEntryInfo parent1 = eFile.getParent1(); // 获取电子签模板ID String eSignTemplateId = parent1.getESignTemplateId(); // 获取电子签模板名称 String name = parent1.getName(); // 从数据JSON中获取模板ID对应的子JSON对象 JSONObject signTemplate = dataJSON.getJSONObject(eSignTemplateId); // 若模板子JSON对象不存在，则创建并初始化 if (signTemplate == null) { signTemplate = new JSONObject(); signTemplate.put("name", name); // 设置模板名称 signTemplate.put("id", eSignTemplateId); // 设置模板ID signTemplate.put("eSignTemplateNum",eSignTemplateNum); JSONObject fields = new JSONObject(); // 创建字段信息JSON对象 signTemplate.put("fields", fields); // 将字段信息存入模板JSON dataJSON.put(eSignTemplateId, signTemplate); } // 从模板子JSON中获取字段信息JSON对象 JSONObject fields = signTemplate.getJSONObject("fields"); // 获取模板字段ID String templateFieldId = eFile.getTemplateFieldId(); // 从字段信息JSON中获取该字段ID对应的子JSON对象 JSONObject field = fields.getJSONObject(templateFieldId); // 若字段子JSON对象不存在，则创建并添加到字段信息JSON if (field == null) { field = new JSONObject(); fields.put(templateFieldId, field); } // 获取模板字段名称 String templateFieldName = eFile.getTemplateFieldName(); // 设置字段名称到字段子JSON field.put("name", templateFieldName); // 获取字段组件类型 ComponentTypeEnum componentType = eFile.getComponentType(); // 设置字段数据类型（取自组件类型的别名） field.put("dataType", componentType.getAlias()); field.put("dataFormat", eFile.getDataFormat()); field.put("isRequired", eFile.isRequired()); field.put("seq", eFile.getSeq()); // 字段值暂设为null field.put("value", null); } } catch (BOSException e) { // BOS异常时，封装为运行时异常抛出 throw new RuntimeException(e); } // 返回重新组装后的JSON对象 return dataJSON; } }