news 2026/4/23 12:44:56

泛微OA文档附件复制汇集

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
泛微OA文档附件复制汇集

实现场景：

目标：实现将流程相关资源中附件与文档内容复制到新字段中

使用泛微ESB实现复制相关资源文档，附件的docid到新字段中实现附件汇集

  • 附件1 字段存有a.txt,b.pdf; 附件2 字段存有 c.xls,d.ppt; 文档字段3 存有 d.doc在线文档
  • 在新增的自定义字段collectannex，通过esb接口实现将以上内容复制到该字段中

ESB思路：

最后更新表单要去除获取到的docid之间的空格！！！

实现思路：

  1. 通过 流程requestid 获取表名与流程创建者id
  2. 通过1中的内容获取流程相关资源的文件docid
  3. 复制所有相关资源中的docid生成复制后新的docid
  4. 执行更新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) * 参数名称不能包含特殊字符+,.[]!"#$%&'()*:;<=>?@\^`{}|~/ 中文字符、标点 U+007F U+0000到U+001F */ public Map execute(Map<String,Object> params) { Map<String,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 List<String> docidList = getAnnexfilesList( requestid , creater ); List<String> CollectAnnexDocidList = new ArrayList<>(); try { for(String docId : docidList){ Map<String, 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 requestid="+requestid; updateAppendixRS.execute(updateWorkflowSQL ) ; ret.put("code","200"); ret.put("message", tableName+"; creater:"+creater+" docidList:"+docidList+" CollectAnnexDocidList"+CollectAnnexDocidList+" ***"+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 = ""; List<InputStream> 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 Map<String, String> getImageFileidByDocid(String docid) { String sql = "select imagefileid,imagefilename from docimagefile where docid='" + docid + "'"; RecordSet rs = new RecordSet(); rs.executeQuery(sql); Map<String, 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 List<String> getAnnexfilesList(String requestidStr,String creatoridStr){ List<String> docidList = new ArrayList<>() ; int requestid = Integer.parseInt(requestidStr) ; int useridInt = Integer.parseInt(creatoridStr) ; if(requestidStr.equals("")||requestidStr==null){ 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 Map<String,Object> getDocImageFileIdByDocid(String docid){ Map<String,Object> map = new HashMap<>(); String zwflag="1"; int imagefileid=0; RecordSet rs = new RecordSet(); String sql="select * from docdetail where id="+docid; rs.executeSql(sql); sql="select * 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()){ creater=rs.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()){ result=rs.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返回该流程相关资源中所有文档与附件的docid：

static List<String> getAnnexfilesList(String requestidStr,String creatoridStr){ List<String> docidList = new ArrayList<>() ; int requestid = Integer.parseInt(requestidStr) ; int useridInt = Integer.parseInt(creatoridStr) ; if(requestidStr.equals("")||requestidStr==null){ 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）中前需要复制生成新的文件docid
public String createDocument(InputStream inputStream, String filePath, String fileName, String userid, User user, String wdmc) throws Exception { // System.out.println("+++++++++++++++++++++++++++++++++++++++++++进入生成文档方法+++++++++++++++++++++++++++++++++++++++++++"); String docid = ""; List<InputStream> 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 Map<String, String> getImageFileidByDocid(String docid) { String sql = "select imagefileid,imagefilename from docimagefile where docid='" + docid + "'"; RecordSet rs = new RecordSet(); rs.executeQuery(sql); Map<String, 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){ Map<String, 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); }

补充说明：

当一个

    版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！
    网站建设 2026/4/23 9:59:13

    AI + 区块链：去中心化智能的未来形态

    在数字经济快速迭代的今天&#xff0c;人工智能&#xff08;AI&#xff09;与区块链作为两大核心技术支柱&#xff0c;各自引领着智能革命与信任革命。AI凭借强大的数据处理与决策能力&#xff0c;重塑了生产生活的效率边界&#xff1b;区块链则以去中心化、不可篡改的特性&…

    作者头像 李华
    网站建设 2026/4/21 17:29:14

    ReadCat：极致纯净的开源小说阅读器，打造你的专属阅读空间

    ReadCat&#xff1a;极致纯净的开源小说阅读器&#xff0c;打造你的专属阅读空间 【免费下载链接】read-cat 一款免费、开源、简洁、纯净、无广告的小说阅读器 项目地址: https://gitcode.com/gh_mirrors/re/read-cat 在信息爆炸的数字时代&#xff0c;寻找一款纯净无广…

    作者头像 李华
    网站建设 2026/4/22 18:44:19

    PDF电路图AI解析实战：电子元件智能识别技术深度解析

    PDF电路图AI解析实战&#xff1a;电子元件智能识别技术深度解析 【免费下载链接】PDF-Extract-Kit A Comprehensive Toolkit for High-Quality PDF Content Extraction 项目地址: https://gitcode.com/gh_mirrors/pd/PDF-Extract-Kit 在电子工程和电路设计领域&#xff…

    作者头像 李华
    网站建设 2026/4/23 11:15:27

    phpstorm 2022.3 如何修改快捷键单行注释开始的位置

    在PhpStorm 2022.3中&#xff0c;使用快捷键&#xff08;如Ctrl/&#xff09;进行单行注释时&#xff0c;注释默认会紧跟在代码行左侧。但可以通过调整代码样式设置来实现注释与代码内容之间保留一定间距。‌‌1具体操作路径为&#xff1a;进入‌File‌ > ‌Settings‌&…

    作者头像 李华
    网站建设 2026/4/19 19:43:32

    FLUX.1 Kontext Dev：本地化AI图像生成解决方案深度解析

    随着人工智能技术的快速发展&#xff0c;开源AI图像生成模型正成为技术社区的热点话题。2025年10月&#xff0c;Black Forest Labs正式开源了FLUX.1 Kontext Dev模型&#xff0c;这款拥有120亿参数的扩散变换器为开发者提供了完整的本地化图像生成能力。 【免费下载链接】FLUX.…

    作者头像 李华