news 2026/5/27 6:51:21

泛微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/5/26 7:18:16

    oracle bootstrap$ 损坏修复ORA-00704 ORA-00702

    bootstrap$损坏模拟 --损坏前先备份system.dbf select count(*) from bootstrap$; delete from bootstrap$; commit; shutdown immediate startup ORA-00704: 引导程序进程失败 ORA-00702: 引导程序版本 与版本 8.0.0.0.0 不一致 2、通过10046定位问题 startup mount…

    作者头像 李华
    网站建设 2026/5/25 23:11:24

    3大实战技巧：用ESP32和NimBLE打造超低功耗蓝牙游戏手柄

    3大实战技巧&#xff1a;用ESP32和NimBLE打造超低功耗蓝牙游戏手柄 【免费下载链接】esp-idf Espressif IoT Development Framework. Official development framework for Espressif SoCs. 项目地址: https://gitcode.com/GitHub_Trending/es/esp-idf 你是否曾因传统蓝牙…

    作者头像 李华
    网站建设 2026/5/26 7:18:15

    ChineseFoodNet：开启AI美食识别新纪元

    ChineseFoodNet&#xff1a;开启AI美食识别新纪元 【免费下载链接】ChineseFoodNet大规模中国食物图像识别数据集分享 ChineseFoodNet是一个大规模的中国食物图像识别数据集&#xff0c;旨在为研究人员和开发者提供丰富的图像资源&#xff0c;用于训练和测试食物识别模型。该数…

    作者头像 李华
    网站建设 2026/5/26 7:18:21

    Node.js调试终极方案：3倍效率提升的性能优化实战

    Node.js调试终极方案&#xff1a;3倍效率提升的性能优化实战 【免费下载链接】ndb ndb is an improved debugging experience for Node.js, enabled by Chrome DevTools 项目地址: https://gitcode.com/gh_mirrors/nd/ndb 还在为Node.js应用的性能瓶颈而苦恼&#xff1f…

    作者头像 李华
    网站建设 2026/5/26 4:54:41

    状态转换测试建模方法：提升软件质量的关键策略

    在当今快速迭代的软件开发环境中&#xff0c;确保系统的可靠性和稳定性至关重要。状态转换测试作为一种基于有限状态机&#xff08;FSM&#xff09;理论的测试方法&#xff0c;专注于验证系统在不同状态下对事件响应的正确性。对于软件测试从业者而言&#xff0c;熟练掌握状态转…

    作者头像 李华
    网站建设 2026/5/26 7:47:30

    【Android GLSurfaceView源码学习】第二天：GLSurfaceView深度分析

    GLSurfaceView 在Android图形渲染体系中&#xff0c;SurfaceView作为一种特殊的视图组件&#xff0c;为开发者提供了在独立线程中进行高效绘制的能力。 而GLSurfaceView则是在SurfaceView基础上针对OpenGL ES渲染场景的深度扩展&#xff0c;它封装了复杂的EGL&#xff08;Embed…

    作者头像 李华