上传合同文件

This commit is contained in:
liuliang 2025-06-16 11:33:27 +08:00
parent fb0b42001e
commit 41a975bcb4
3 changed files with 51 additions and 21 deletions

View File

@ -8,10 +8,6 @@ import java.util.Map;
public interface UploadService {
Map<String, Object> uploadFile(Map<String,Object> fileMap,String folderId, ModuleSource module, Long refId, SimpleEmployee employee, String chunks);
Map<String, Object> importData(List<Map<String, String>> dataList,String tableName,SimpleEmployee employee);
Map<String, Object> jcluploadFile(List<Map<String, Object>> list,String tableName,String folderId,SimpleEmployee employee) throws Exception;
}

View File

@ -171,7 +171,7 @@ public class EmployeeInformationServiceImpl implements EmployeeInformationServic
Map<String,Object> condition = Maps.newHashMap();
condition.put("id",pendingEmployee.getId());
Map<String,Object> param = Maps.newHashMap();
param.put("tableName","uf_jcl_rzgl");
param.put("tableName",uf_jcl_rzgl);
param.put("dataMap",dataMap);
param.put("condition",condition);
commonService.updateCommon(param);
@ -622,25 +622,28 @@ public class EmployeeInformationServiceImpl implements EmployeeInformationServic
Map<String, String> uf_jcl_employee_information_Info = recruitModuleUtils.getEbTableInfo("uf_jcl_employee_information_apptag", "uf_jcl_employee_information_tag");
String uf_jcl_employee_information = uf_jcl_employee_information_Info.get("table_name");
Map<String, String> uf_jcl_querycondition_Info = recruitModuleUtils.getEbTableInfo("uf_jcl_querycondition_apptag", "uf_jcl_querycondition_tag");
String uf_jcl_querycondition = uf_jcl_querycondition_Info.get("table_name");
String rootdata = params.get("rootdata");
String sqltj = CommonUtils.null2String(params.get("sqltj"));
Map<String,Object> param = Maps.newHashMap();
Map<String,Object> dataMap = Maps.newHashMap();
param.put("tableName","uf_jcl_querycondition");
param.put("tableName",uf_jcl_querycondition);
param.put("dataMap",dataMap);
dataMap.put("ry",String.valueOf(simpleEmployee.getId()));
dataMap.put("sxtj",rootdata);
dataMap.put("bm",uf_jcl_employee_information);
String sql = "select id,ry from uf_jcl_querycondition where ry=? and bm=? and delete_type='0'";
String sql = "select id,ry from "+uf_jcl_querycondition+" where ry=? and bm=? and delete_type='0'";
List<Map<String, Object>> dataList = databaseUtils.getSqlList(sql,CommonUtils.getParamList(String.valueOf(simpleEmployee.getId()),uf_jcl_employee_information));
if (dataList.size() > 0){
if (rootdata.equals("")){
sql = "update uf_jcl_querycondition set sqltj=? where id=?";
sql = "update "+uf_jcl_querycondition+" set sqltj=? where id=?";
databaseUtils.execute(sql,CommonUtils.getParamList(sqltj,String.valueOf(dataList.get(0).get("id"))));
}else {
sql = "update uf_jcl_querycondition set sxtj=? where id=?";
sql = "update "+uf_jcl_querycondition+" set sxtj=? where id=?";
databaseUtils.execute(sql,CommonUtils.getParamList(rootdata,String.valueOf(dataList.get(0).get("id"))));
}
@ -677,6 +680,16 @@ public class EmployeeInformationServiceImpl implements EmployeeInformationServic
int current = Integer.valueOf(CommonUtils.null2String(params.get("current")));
int pageSize = Integer.valueOf(CommonUtils.null2String(params.get("pageSize")));
String sql = "select id,app_id,form_id from ebdf_obj where table_name='"+tableName+"' and delete_type='0'";
Map<String, String> uf_jcl_querycondition_Info = recruitModuleUtils.getEbTableInfo("uf_jcl_querycondition_apptag", "uf_jcl_querycondition_tag");
String uf_jcl_querycondition = uf_jcl_querycondition_Info.get("table_name");
if (tableName.equals("uf_jcl_employee_information")){
Map<String, String> uf_jcl_employee_information_Info = recruitModuleUtils.getEbTableInfo("uf_jcl_employee_information_apptag", "uf_jcl_employee_information_tag");
tableName = uf_jcl_employee_information_Info.get("table_name");
}
List<Map<String, Object>> recordList = databaseUtils.getSqlList(sql);
String objId = CommonUtils.null2String(recordList.get(0).get("id"));
String appId = CommonUtils.null2String(recordList.get(0).get("appId"));
@ -685,7 +698,7 @@ public class EmployeeInformationServiceImpl implements EmployeeInformationServic
List<Map<String, Object>> objListId = databaseUtils.getSqlList(sql,CommonUtils.getParamList(objId));
sql = "select b.title,b.data_key,b.component_key,a.* from ebdf_list_field a left join form_field b on a.field_id=b.id where a.list_id=? and b.form_id=? and a.delete_type='0' and b.delete_type='0'";
List<Map<String, Object>> columnList = databaseUtils.getSqlList(sql,CommonUtils.getParamList(objListId.get(0).get("id").toString(),formId));
sql = "select sqltj from uf_jcl_querycondition where ry=? and bm=?";
sql = "select sqltj from "+uf_jcl_querycondition+" where ry=? and bm=?";
List<Map<String, Object>> conditionSqlList = databaseUtils.getSqlList(sql,CommonUtils.getParamList(String.valueOf(simpleEmployee.getId()),tableName));
List<ListColumn> columns = Lists.newArrayList();
@ -840,8 +853,12 @@ public class EmployeeInformationServiceImpl implements EmployeeInformationServic
@Override
public String getallEmployeeConditon(SimpleEmployee simpleEmployee) {
Map<String, String> uf_jcl_querycondition_Info = recruitModuleUtils.getEbTableInfo("uf_jcl_querycondition_apptag", "uf_jcl_querycondition_tag");
String uf_jcl_querycondition = uf_jcl_querycondition_Info.get("table_name");
StringJoiner andCondition = new StringJoiner("");
String sql = "select sqltj from uf_jcl_querycondition where ry=? and bm=? and delete_type='0'";
String sql = "select sqltj from "+uf_jcl_querycondition+" where ry=? and bm=? and delete_type='0'";
List<Map<String, Object>> conditionSqlList = databaseUtils.getSqlList(sql,CommonUtils.getParamList(String.valueOf(simpleEmployee.getId()),"uf_jcl_employee_information"));
if (conditionSqlList.size() > 0){
andCondition.add(String.valueOf(conditionSqlList.get(0).get("sqltj")));
@ -852,9 +869,11 @@ public class EmployeeInformationServiceImpl implements EmployeeInformationServic
@Override
public Map<String,String> getinitCondition(SimpleEmployee simpleEmployee) {
Map<String, String> uf_jcl_querycondition_Info = recruitModuleUtils.getEbTableInfo("uf_jcl_querycondition_apptag", "uf_jcl_querycondition_tag");
String uf_jcl_querycondition = uf_jcl_querycondition_Info.get("table_name");
String sql = "select sqltj,sxtj from uf_jcl_querycondition where ry=? and bm=? and delete_type='0'";
List<Map<String, Object>> conditionSqlList = databaseUtils.getSqlList(sql,CommonUtils.getParamList(String.valueOf(simpleEmployee.getId()),"uf_jcl_employee_information"));
String sql = "select sqltj,sxtj from "+uf_jcl_querycondition+" where ry=? and bm=? and delete_type='0'";
List<Map<String, Object>> conditionSqlList = databaseUtils.getSqlList(sql,CommonUtils.getParamList(String.valueOf(simpleEmployee.getId()),uf_jcl_querycondition));
Map<String,String> resultMap = Maps.newHashMap();
if (conditionSqlList.size() > 0){
resultMap.put("sqltj",CommonUtils.null2String(conditionSqlList.get(0).get("sqltj")));
@ -1448,7 +1467,10 @@ public class EmployeeInformationServiceImpl implements EmployeeInformationServic
* @return
*/
public Map<String,String> getMapping(){
String sql = "select ygxxzdkey,rlxtzdkey from uf_jcl_zdtbysb";
Map<String, String> uf_jcl_zdtbysb_Info = recruitModuleUtils.getEbTableInfo("uf_jcl_employee_information_apptag", "uf_jcl_zdtbysb_tag");
String uf_jcl_zdtbysb = uf_jcl_zdtbysb_Info.get("table_name");
String sql = "select ygxxzdkey,rlxtzdkey from "+uf_jcl_zdtbysb;
List<Map<String, Object>> recordList = databaseUtils.getSqlList(sql);
Map<String, String> resultMap = recordList.stream().collect(Collectors.toMap(e->e.get("ygxxzdkey").toString(),e -> e.get("rlxtzdkey").toString()));

View File

@ -66,6 +66,10 @@ public class UploadServiceImpl implements UploadService {
public Map<String, Object> jcluploadFile(List<Map<String, Object>> list,String tableName,String folderId,SimpleEmployee employee) throws Exception {
Map<String,Object> returnMap = Maps.newHashMap();
List<Map<String, Object>> importList = Lists.newArrayList();
String sql = "select a.* from form_field a left join form_table b on a.form_id=b.form_id where b.table_name=? and a.delete_type='0'";
List<Map<String, Object>> fieldList = databaseUtils.getSqlList(sql,CommonUtils.getParamList(tableName));
Map<String,List<Map<String, Object>>> fieldGroupByTitle = fieldList.stream().collect(Collectors.groupingBy(e->e.get("title").toString()));
for (Map<String, Object> resultMap:list){
FileData fileData = new FileData();
fileData.setLoadUrl(fileDownloadService.getDownloadUrl(CommonUtils.null2String(resultMap.get("url")),CommonUtils.null2String(resultMap.get("tenant_key")),CommonUtils.null2String(resultMap.get("name"))));
@ -112,14 +116,25 @@ public class UploadServiceImpl implements UploadService {
Map<String,Object> fileUploadMap = uploadFile(fileMap,folderId,ModuleSource.ebuildercard,0L,employee,null);
long docId = ((FileObj)fileUploadMap.get("fileObj")).getDocId();
long fileid = ((FileObj)fileUploadMap.get("fileObj")).getFileid();
long id = ((FileObj)fileUploadMap.get("fileObj")).getId();
log.error("docId : [{}],fileid:[{}],id:[{}]",docId,fileid,id);
dataList.get(rowNum-1).put(titles.get(colNum),String.valueOf(docId));
Map<String,String> updataMap = Maps.newHashMap();
updataMap.put("id",dataList.get(rowNum-1).get("数据ID"));
updataMap.put(titles.get(colNum),String.valueOf(docId));
if (fieldGroupByTitle.get(titles.get(colNum)).get(0).get("component_key").equals("FileComponent")){
//附件
log.error("附件字段");
updataMap.put(titles.get(colNum),String.valueOf(fileid));
}else{
log.error("文档字段");
log.error("字段key"+fieldGroupByTitle.get(titles.get(colNum)).get(0).get("component_key"));
updataMap.put(titles.get(colNum),String.valueOf(docId));
}
needUpdataList.add(updataMap);
}
Map<String, Object> importResult = importData(needUpdataList,tableName,employee);
Map<String, Object> importResult = importData(needUpdataList,tableName,fieldGroupByTitle);
importList.add(importResult);
}
returnMap.put("importList",importList);
@ -219,15 +234,12 @@ public class UploadServiceImpl implements UploadService {
return result;
}
@Override
public Map<String, Object> importData(List<Map<String, String>> dataList,String tableName,SimpleEmployee employee) {
public Map<String, Object> importData(List<Map<String, String>> dataList,String tableName,Map<String,List<Map<String, Object>>> fieldGroupByTitle) {
Map<String,Object> resultMap = Maps.newHashMap();
List<Map<String, Object>> updateData = Lists.newArrayList();
String sql = "select a.* from form_field a left join form_table b on a.form_id=b.form_id where b.table_name=? and a.delete_type='0'";
List<Map<String, Object>> fieldList = databaseUtils.getSqlList(sql,CommonUtils.getParamList(tableName));
Map<String,List<Map<String, Object>>> fieldGroupByTitle = fieldList.stream().collect(Collectors.groupingBy(e->e.get("title").toString()));
Map<String,List<Map<String, String>>> dataGroupById = dataList.stream().collect(Collectors.groupingBy(e->e.get("id").toString()));
for (Map.Entry<String,List<Map<String, String>>>entry : dataGroupById.entrySet()){
Map<String,Object> updataMap = Maps.newHashMap();