上海网站建设设网络推广合作

上海网站建设设,网络推广合作,wordpress漫画采集,重庆1000元网站建设实现场景#xff1a; 目标#xff1a;实现将流程相关资源中附件与文档内容复制到新字段中 使用泛微ESB实现复制相关资源文档#xff0c;附件的docid到新字段中实现附件汇集 附件1 字段存有a.txt,b.pdf; 附件2 字段存有 c.xls,d.ppt; 文档字段3 存有 d.doc在线文档在新增…实现场景目标实现将流程相关资源中附件与文档内容复制到新字段中使用泛微ESB实现复制相关资源文档附件的docid到新字段中实现附件汇集附件1 字段存有a.txt,b.pdf; 附件2 字段存有 c.xls,d.ppt; 文档字段3 存有 d.doc在线文档在新增的自定义字段collectannex通过esb接口实现将以上内容复制到该字段中ESB思路最后更新表单要去除获取到的docid之间的空格实现思路通过 流程requestid 获取表名与流程创建者id通过1中的内容获取流程相关资源的文件docid复制所有相关资源中的docid生成复制后新的docid执行更新SQL实现将以上新生成的docid复制到新字段collectannex中完整代码package com.weaver.esb.package_20251215021826; import com.api.doc.detail.util.DecodeUtil; import com.engine.workflow.biz.workflowCore.RequestBaseBiz; import com.engine.workflow.entity.core.RequestInfoEntity; import weaver.conn.RecordSet; import weaver.docs.webservices.DocAttachment; import weaver.docs.webservices.DocInfo; import weaver.docs.webservices.DocServiceImpl; import weaver.file.ImageFileManager; import weaver.general.Util; import weaver.hrm.User; import weaver.hrm.resource.ResourceComInfo; import weaver.wechat.util.Utils; import weaver.workflow.request.RequestResources; import weaver.workflow.workflow.WorkflowComInfo; import java.io.ByteArrayOutputStream; import java.io.InputStream; import java.util.*; public class OperateWorkflowAnnex { /** * param: param(Map collections) * 参数名称不能包含特殊字符,.[]!#$%()*:;?\^{}|~/ 中文字符、标点 U007F U0000到U001F */ public Map execute(MapString,Object params) { MapString,Object ret new HashMap(); String requestid Utils.null2String(params.get(requestid)); //1. obtain tablename by requestid String tableName getWorkflowTablenameByRequestid(requestid); // 2. obtain creater by requestid String creater getCreaterByRequestid(requestid); int useridInt Integer.parseInt(creater) ; User user new User(useridInt) ; // 3. obtain annex files ids by requestid,creater ListString docidList getAnnexfilesList( requestid , creater ); ListString CollectAnnexDocidList new ArrayList(); try { for(String docId : docidList){ MapString, String imageInfo getImageFileidByDocid(docId); String decodeimagefileid Util.null2String(DecodeUtil.decodeByImageFileIdByTianyu(Integer.parseInt(imageInfo.get(imagefileid)))); String imagefilename imageInfo.get(imagefilename); InputStream inputStream ImageFileManager.getInputStreamById(Integer.parseInt(decodeimagefileid)); String relatedDocid createDocument(inputStream,/app/weaver/ecology/Archives,imagefilename,creater,user,imagefilename); CollectAnnexDocidList.add(relatedDocid); } } catch (Exception e) { ret.put(code,400); ret.put(message,erro get files :e.toString()); throw new RuntimeException(e); } RecordSet updateAppendixRS new RecordSet() ; String collectannex String.join(, , CollectAnnexDocidList); collectannex collectannex.replaceAll(\\s, ); String updateWorkflowSQL update tableName set collectannex collectannex where requestidrequestid; updateAppendixRS.execute(updateWorkflowSQL ) ; ret.put(code,200); ret.put(message, tableName; creater:creater docidList:docidList CollectAnnexDocidListCollectAnnexDocidList ***updateWorkflowSQL); return ret; } public String createDocument(InputStream inputStream, String filePath, String fileName, String userid, User user, String wdmc) throws Exception { // System.out.println(进入生成文档方法); String docid ; ListInputStream inputStreams new ArrayList(); byte[] content new byte[102400]; // 上传附件创建html文档 content null; try { int byteread; byte data[] new byte[1024]; // InputStreamReader reader new InputStreamReader(input,UTF-8); ByteArrayOutputStream out new ByteArrayOutputStream(); while ((byteread inputStream.read(data)) ! -1) { out.write(data, 0, byteread); out.flush(); } content out.toByteArray(); inputStream.close(); out.close(); } catch (Exception e) { e.printStackTrace(); } DocAttachment da new DocAttachment(); da.setDocid(0); da.setImagefileid(0); da.setFilecontent(org.apache.axis.encoding.Base64.encode(content)); da.setFilerealpath(filePath); da.setIszip(1); da.setFilename(fileName); da.setIsextfile(1); da.setDocfiletype(3); DocServiceImpl docService new DocServiceImpl(); DocInfo doc new DocInfo();//创建文档 doc.setDoccreaterid(Integer.parseInt(userid));// doc.setDoccreatertype(0); doc.setAccessorycount(1); doc.setMaincategory(Integer.parseInt(92));//主目录id doc.setSeccategory(Integer.parseInt(92));//子目录id doc.setOwnerid(Integer.parseInt(userid)); doc.setDocStatus(1); doc.setId(0); doc.setDocType(2); doc.setDocSubject(wdmc); doc.setDoccontent(); doc.setAttachments(new DocAttachment[]{da}); int newDocid docService.createDocByUser(doc, user); System.out.println(新文档id newDocid); return newDocid ; } public static MapString, String getImageFileidByDocid(String docid) { String sql select imagefileid,imagefilename from docimagefile where docid docid ; RecordSet rs new RecordSet(); rs.executeQuery(sql); MapString, String map new HashMap(); if (rs.next()) { map.put(imagefileid, weaver.general.Util.null2String(rs.getString(imagefileid))); map.put(imagefilename, (weaver.general.Util.null2String(rs.getString(imagefilename))).replace(/,-)); } return map; } static ListString getAnnexfilesList(String requestidStr,String creatoridStr){ ListString docidList new ArrayList() ; int requestid Integer.parseInt(requestidStr) ; int useridInt Integer.parseInt(creatoridStr) ; if(requestidStr.equals()||requestidStrnull){ return null ; } User user new User(useridInt) ; try { RequestInfoEntity infoEntity RequestBaseBiz.loadRequestInfo(requestid); int workflowid infoEntity.getWorkflowId(); WorkflowComInfo comInfo new WorkflowComInfo(); int isbill Util.getIntValue(comInfo.getIsBill(Util.null2String(workflowid))); int formid Util.getIntValue(comInfo.getFormId(Util.null2String(workflowid))); RequestResources reqResources new RequestResources(user, infoEntity.getWorkflowId(), requestid, isbill, formid, , , , 0, 0, 0); // type:资源类型 1:相关流程 2相关文档 3相关附件 String fromSql reqResources.getReqResSqlByType(3); String querySQL select id, resname, restype, creator, creatortype, createdate, docid from fromSql order by id asc; RecordSet rs new RecordSet(); rs.executeQuery(querySQL); while (rs.next()) { int id rs.getInt(id); rs.getString(creator); //文档类型的附件查出来的是docid还要根据docid去查询docImageFileId String docid Util.null2String(rs.getInt(docid)); String imagefileid getDocImageFileIdByDocid(docid).get(imagefileid).toString(); docidList.add( docid); } // type:资源类型 1:相关流程 2相关文档 3相关附件 fromSql reqResources.getReqResSqlByType(2); querySQL select id, resname, restype, creator, creatortype, createdate, docid from fromSql order by id asc; rs.executeQuery(querySQL); while (rs.next()) { int id rs.getInt(id); rs.getString(creator); //文档类型的附件查出来的是docid还要根据docid去查询docImageFileId String docid Util.null2String(rs.getInt(docid)); String imagefileid getDocImageFileIdByDocid(docid).get(imagefileid).toString(); // imagefileidList.add( imagefileid); docidList.add( docid); } }catch (Exception e) { // writeLog(e.getMessage(), e); } return docidList ; } /** * 根据docid获取最新一次的DocImageFileId * param docid * return */ static MapString,Object getDocImageFileIdByDocid(String docid){ MapString,Object map new HashMap(); String zwflag1; int imagefileid0; RecordSet rs new RecordSet(); String sqlselect * from docdetail where iddocid; rs.executeSql(sql); sqlselect * from DocImageFile where docid docid; sql order by id desc ; rs.executeSql(sql); if(rs.next()){ imagefileid Util.getIntValue(rs.getString(imagefileid),0); map.put(imagefilename,rs.getString(imagefilename)); } map.put(imagefileid,imagefileid); return map; } /** * obtain creater by requestid * param requestid * return */ static String getCreaterByRequestid(String requestid){ //get creater by requestid String queryCreaterSQL select creater from workflow_requestbase where requestid ?; RecordSet rs new RecordSet(); rs.executeQuery(queryCreaterSQL,requestid) ; String creater 28525 ; if(rs.next()){ createrrs.getString(creater) ; } //get all annex files about requestid return creater ; } /** * obtain tablename by requestid * param requestid * return tablename */ static String getWorkflowTablenameByRequestid(String requestid){ String queryTableNameSQL SELECT b.tablename\n FROM workflow_requestbase r\n JOIN workflow_base w ON r.workflowid w.id\n JOIN workflow_bill b ON w.formid b.id\n WHERE r.requestid ? ; RecordSet rs new RecordSet(); rs.executeQuery(queryTableNameSQL,requestid) ; String result ; if(rs.next()){ resultrs.getString(tablename) ; } return result ; } }代码解析使用requestid获取流程对应的表名与创建人需要进行多个表的转换queryTableNameSQL获取tablename表名 拆解来源如下select creater from workflow_requestbase where requestid 80095263 -- workflowid 448621 select * from workflow_base where id 448621 --- formid -4654 select tablename from workflow_bill where id -4654 -- tablename获取相关资源在之前的获取流程相关资源文章提到了获取相关流程requestid参数为1参数为2或者3即可获取相关资源的文档和附件docid代码不同数字代表不同资源类型其中 1:相关流程 2相关文档 3相关附件 以下方法通过输入流程requestid与创建人id返回该流程相关资源中所有文档与附件的docidstatic ListString getAnnexfilesList(String requestidStr,String creatoridStr){ ListString docidList new ArrayList() ; int requestid Integer.parseInt(requestidStr) ; int useridInt Integer.parseInt(creatoridStr) ; if(requestidStr.equals()||requestidStrnull){ return null ; } User user new User(useridInt) ; try { RequestInfoEntity infoEntity RequestBaseBiz.loadRequestInfo(requestid); int workflowid infoEntity.getWorkflowId(); WorkflowComInfo comInfo new WorkflowComInfo(); int isbill Util.getIntValue(comInfo.getIsBill(Util.null2String(workflowid))); int formid Util.getIntValue(comInfo.getFormId(Util.null2String(workflowid))); RequestResources reqResources new RequestResources(user, infoEntity.getWorkflowId(), requestid, isbill, formid, , , , 0, 0, 0); // type:资源类型 1:相关流程 2相关文档 3相关附件 String fromSql reqResources.getReqResSqlByType(3); String querySQL select id, resname, restype, creator, creatortype, createdate, docid from fromSql order by id asc; RecordSet rs new RecordSet(); rs.executeQuery(querySQL); while (rs.next()) { int id rs.getInt(id); rs.getString(creator); //文档类型的附件查出来的是docid还要根据docid去查询docImageFileId String docid Util.null2String(rs.getInt(docid)); String imagefileid getDocImageFileIdByDocid(docid).get(imagefileid).toString(); docidList.add( docid); } // type:资源类型 1:相关流程 2相关文档 3相关附件 fromSql reqResources.getReqResSqlByType(2); querySQL select id, resname, restype, creator, creatortype, createdate, docid from fromSql order by id asc; rs.executeQuery(querySQL); while (rs.next()) { int id rs.getInt(id); rs.getString(creator); //文档类型的附件查出来的是docid还要根据docid去查询docImageFileId String docid Util.null2String(rs.getInt(docid)); String imagefileid getDocImageFileIdByDocid(docid).get(imagefileid).toString(); // imagefileidList.add( imagefileid); docidList.add( docid); } }catch (Exception e) { // writeLog(e.getMessage(), e); } return docidList ; }将docid复制后存入新的字段collectannex中前需要复制生成新的文件docidpublic String createDocument(InputStream inputStream, String filePath, String fileName, String userid, User user, String wdmc) throws Exception { // System.out.println(进入生成文档方法); String docid ; ListInputStream inputStreams new ArrayList(); byte[] content new byte[102400]; // 上传附件创建html文档 content null; try { int byteread; byte data[] new byte[1024]; // InputStreamReader reader new InputStreamReader(input,UTF-8); ByteArrayOutputStream out new ByteArrayOutputStream(); while ((byteread inputStream.read(data)) ! -1) { out.write(data, 0, byteread); out.flush(); } content out.toByteArray(); inputStream.close(); out.close(); } catch (Exception e) { e.printStackTrace(); } DocAttachment da new DocAttachment(); da.setDocid(0); da.setImagefileid(0); da.setFilecontent(org.apache.axis.encoding.Base64.encode(content)); da.setFilerealpath(filePath); da.setIszip(1); da.setFilename(fileName); da.setIsextfile(1); da.setDocfiletype(3); DocServiceImpl docService new DocServiceImpl(); DocInfo doc new DocInfo();//创建文档 doc.setDoccreaterid(Integer.parseInt(userid));// doc.setDoccreatertype(0); doc.setAccessorycount(1); doc.setMaincategory(Integer.parseInt(92));//主目录id doc.setSeccategory(Integer.parseInt(92));//子目录id doc.setOwnerid(Integer.parseInt(userid)); doc.setDocStatus(1); doc.setId(0); doc.setDocType(2); doc.setDocSubject(wdmc); doc.setDoccontent(); doc.setAttachments(new DocAttachment[]{da}); int newDocid docService.createDocByUser(doc, user); System.out.println(新文档id newDocid); return newDocid ; } public static MapString, String getImageFileidByDocid(String docid) { String sql select imagefileid,imagefilename from docimagefile where docid docid ; RecordSet rs new RecordSet(); rs.executeQuery(sql); MapString, String map new HashMap(); if (rs.next()) { map.put(imagefileid, weaver.general.Util.null2String(rs.getString(imagefileid))); map.put(imagefilename, (weaver.general.Util.null2String(rs.getString(imagefilename))).replace(/,-)); } return map; }代码中方法getImageFileidByDocid 输入文件docid获取对应的imagefileid与imagefilename作为获取新文档docid方法createDocument的参数具体通过遍历上一步获取到所有资源docid的list循环生成代码如下for(String docId : docidList){ MapString, String imageInfo getImageFileidByDocid(docId); String decodeimagefileid Util.null2String(DecodeUtil.decodeByImageFileIdByTianyu(Integer.parseInt(imageInfo.get(imagefileid)))); String imagefilename imageInfo.get(imagefilename); InputStream inputStream ImageFileManager.getInputStreamById(Integer.parseInt(decodeimagefileid)); String relatedDocid createDocument(inputStream,/app/weaver/ecology/Archives,imagefilename,creater,user,imagefilename); CollectAnnexDocidList.add(relatedDocid); }补充说明当一个