news 2026/6/23 17:12:43

泛微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/6/23 8:39:13

    性能边界：何时用 Go 何时用 Java 的技术选型指南

    在后端技术栈选型中&#xff0c;Go 和 Java 是两大主流选择。前者以“简单、高效、并发友好”著称&#xff0c;后者凭借“成熟、生态完善、企业级支持强大”占据半壁江山。很多技术团队在选型时会陷入纠结&#xff1a;同样是处理高并发、大数据量场景&#xff0c;到底该选 Go 还…

    作者头像 李华
    网站建设 2026/6/23 18:17:42

    批量将Word中的不同的手机号码替换成同一内容，2种高效方法分享！

    我们在处理word文档中&#xff0c;经常需要处理一些文档隐私信息&#xff0c;例如假如我们有大量不同的手机号码&#xff0c;都需要替换成其他内容&#xff0c;或者进行打码&#xff0c;或者进行删除&#xff0c;以保护手机号码信息&#xff0c;这种操作肯定需要通过一些批量处…

    作者头像 李华
    网站建设 2026/6/23 10:14:52

    123云盘解锁脚本完整教程：免费享受会员级云盘体验

    123云盘解锁脚本完整教程&#xff1a;免费享受会员级云盘体验 【免费下载链接】123pan_unlock 基于油猴的123云盘解锁脚本&#xff0c;支持解锁123云盘下载功能 项目地址: https://gitcode.com/gh_mirrors/12/123pan_unlock 还在为123云盘的下载速度限制和广告干扰而烦恼…

    作者头像 李华
    网站建设 2026/6/15 18:15:19

    AI智能体如何高效通信：构建智能协作网络的核心技术

    AI智能体如何高效通信&#xff1a;构建智能协作网络的核心技术 【免费下载链接】awesome-ai-agents A list of AI autonomous agents 项目地址: https://gitcode.com/GitHub_Trending/aw/awesome-ai-agents 你是否曾好奇&#xff0c;当多个AI智能体协同工作时&#xff0…

    作者头像 李华
    网站建设 2026/6/23 11:35:12

    解密AI智能体通信黑盒：从混乱到高效协作的完整指南

    解密AI智能体通信黑盒&#xff1a;从混乱到高效协作的完整指南 【免费下载链接】awesome-ai-agents A list of AI autonomous agents 项目地址: https://gitcode.com/GitHub_Trending/aw/awesome-ai-agents 为什么你的AI团队总是各自为战&#xff1f;当多个AI智能体协同…

    作者头像 李华
    网站建设 2026/6/22 21:28:31

    这个信号很明显：AI健康，开始换打法了

    这个信号很明显&#xff1a;AI健康&#xff0c;开始换打法了。刚刚蚂蚁集团的AQ&#xff0c;终于改名叫【阿福】了&#xff0c;昨晚我和我妈都装上了。因为这个尝试太大胆了&#xff0c;因为之前没有公司敢把APP用“拟人化”去命名&#xff0c;像我们这种80后的中老年人会觉得很…

    作者头像 李华