二开插件：移动端上传的文件和图片，直接保存到pc单据对应的字段中

栏目：云星空知识作者：金蝶来源：金蝶云社区发布：2024-09-23浏览：3

经常收到小伙伴的反馈，移动表单，移动单据中上传的附件或图片，怎么保存到pc端目标单据的指定字段中呢？今天通过一个插件示例，来完成该工作；
适用范围：在移动单据、移动表单中，将移动端上传的附件和图片，直接与pc端对应的附件文件服务器，附件数据库，图片文件服务器，图片数据库相关联；
温馨提示：如果仅需要保存到pc端单据的附件列表中，那么直接使用单据附件控件即可；仅附件数据库支持多选，其他控件仅支持单选；
准备工作：如果仅需要关联附件文件服务器，附件数据库，那么7.5以上版本均可；如果关联图片文件服务器，图片数据库，则需要升级2021年3月份及以上的补丁；
需求描述（示例）：测试单据中包含：附件文件服务器，附件数据库，图片文件服务器，图片数据库4个字段，要求在移动表单中上传的文件和图片，与在测试单据中上传保持一致，数据互通；测试单据示例：
移动表单设计：如下图所示，包含附件控件和图片控件，需要勾选允许上传：

pc端运行效果图：

插件代码：

using Kingdee.BOS.Core;
using Kingdee.BOS.Core.Metadata;
using Kingdee.BOS.FileServer.Core;
using Kingdee.BOS.FileServer.Core.Object;
using Kingdee.BOS.FileServer.ProxyService;
using Kingdee.BOS.JSON;
using Kingdee.BOS.KDThread;
using Kingdee.BOS.Mobile.Metadata.ControlDataEntity;
using Kingdee.BOS.Mobile.PlugIn;
using Kingdee.BOS.Mobile.PlugIn.ControlModel;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.ServiceHelper;
using Kingdee.BOS.Util;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Text;
using System.Web;
namespace Kingdee.BOS.Mobile.FormPlugIns.Test
{
    /// <summary>
    /// 附件上传测试
    /// </summary>
    /// <remarks>
    /// 附件上传涉及以下步骤：
    /// 1. 附件控件将选取文件拷贝到临时目录
    /// 2. 触发AfterMobileUpload函数并传入所需参数
    /// 3. 从临时目录将文件保存至数据库
    /// </remarks>
    [Description("测试附件字段上传--与pc单据字段关联")]
    public class TestAccessoryFieldUpload : AbstractMobilePlugin
    {
        /// <summary>
        /// 上传类型
        /// </summary>
        private enum SubmitType
        {
            FileServer,
            FileDatabase,
            ImageServer,
            ImageDatabase
        }
        private SubmitType submitType;
        /// <summary>
        /// 表单上的按钮点击事件
        /// </summary>
        /// <param name="e"></param>
        public override void ButtonClick(Core.DynamicForm.PlugIn.Args.ButtonClickEventArgs e)
        {
            if ("FButtonFileServer".EqualsIgnoreCase(e.Key))
            {
                // 检查是否启用了文件服务器
                if (!Kingdee.BOS.ServiceHelper.FileServer.FileServerHelper.UsedFileServer(this.Context))
                {
                    this.View.ShowMessage("未启用文件服务器，无法实现上传。");
                    return;
                }
                submitType = SubmitType.FileServer;
                this.View.GetControl<FileUploadControl>("FFileUpload").UploadFieldBatch();
            }
            else if ("FButtonFileDatabase".EqualsIgnoreCase(e.Key))
            {
                submitType = SubmitType.FileDatabase;
                // 将附件上传至临时目录
                this.View.GetControl<FileUploadControl>("FFileUpload").UploadFieldBatch();
            }
            else if ("FButtonImageServer".EqualsIgnoreCase(e.Key))
            {
                // 检查是否启用了文件服务器
                if (!Kingdee.BOS.ServiceHelper.FileServer.FileServerHelper.UsedFileServer(this.Context))
                {
                    this.View.ShowMessage("未启用文件服务器，无法实现上传。");
                    return;
                }
                submitType = SubmitType.ImageServer;
                this.View.GetControl<ImageUploadControl>("FImageUpload").UploadFieldBatch();
            }
            else if ("FButtonImageDatabase".EqualsIgnoreCase(e.Key))
            {
                submitType = SubmitType.ImageDatabase;
                // 将图片上传至临时目录
                this.View.GetControl<ImageUploadControl>("FImageUpload").UploadFieldBatch();
            }
            base.ButtonClick(e);
        }
        /// <summary>
        /// 通过二开插件直接将上传的文件保存到pc单据对应的字段中
        /// </summary>
        /// <param name="e"></param>
        public override void AfterMobileUpload(PlugIn.Args.MobileUploadEventArgs e)
        {
            string _FormId  = "kd_FlexTest"; // 目标单据唯一标识，即formid
            string _InterID = "100016"; // 单据内码，这个ID将作为我们下载的识别标识
            string fileServerName = "F_MOB_FileServer"; //单据中文件服务器控件的字段名
            string fileDatabaseName = "F_MOB_FileDatabase"; //单据中文件数据库控件的字段名
            string imageServerName = "F_MOB_ImageServer"; //单据中图片服务器控件的字段名
            string imageDatabaseName = "F_MOB_ImageDatabase"; //单据中图片数据库控件的字段名
 
            var businessInfo = ((FormMetadata)MetaDataServiceHelper.Load(this.Context, _FormId)).BusinessInfo;
            var dyn = BusinessDataServiceHelper.LoadSingle(this.Context, _InterID, businessInfo.GetDynamicObjectType());
            dyn = dyn ?? new DynamicObject(businessInfo.GetDynamicObjectType());
            // 获取文件上传的临时目录
            string tempDirPath = HttpContext.Current.Request.PhysicalApplicationPath + KeyConst.TEMPFILEPATH;
            //仅文件数据库支持上传多个文件，其他仅支持上传一个文件
            if (submitType == SubmitType.FileDatabase) //上传附件至数据库
            {
                StringBuilder sb = new StringBuilder();
                JSONArray fileArray = new JSONArray();
                foreach (FiledUploadEntity file in e.FileNameArray)
                {
                    if (!file.IsSuccess) continue; // 检查文件是否上传成功
                    var filePath = System.IO.Path.Combine(tempDirPath, file.FileName); // 检查文件是否存在
                    if (!System.IO.File.Exists(filePath)) continue;
                    JSONObject fileObject = new JSONObject();
                    var dataBuff = System.IO.File.ReadAllBytes(filePath);
                    string fileName = Guid.NewGuid().ToString() + " " + file.OldName;
                    fileObject.Put("ServerFileName", fileName);
                    fileObject.Put("FileName", file.OldName);
                    fileObject.Put("FileLength", dataBuff.Length);
                    fileObject.Put("FileBytesLength", dataBuff.Length);
                    fileObject.Put("FileContent", dataBuff);
                    fileArray.Add(fileObject);
                }
                if (fileArray.Count == 0) return;
                dyn[fileDatabaseName] = SerializatonUtil.SerializeToBase64(fileArray);
                BusinessDataServiceHelper.Save(this.Context, businessInfo, dyn);
                sb.AppendLine();
                sb.AppendLine("上传成功"); 
                this.Model.SetValue("FFileLog", sb.ToString());
            }
            else
            {
                string str = string.Empty;
                var file = e.FileNameArray[0];
                if (file == null || !file.IsSuccess) str = "上传失败"; // 检查文件是否上传成功
                var filePath = System.IO.Path.Combine(tempDirPath, file.FileName);
                if (!System.IO.File.Exists(filePath)) str = "文件不存在"; // 检查文件是否存在
                var dataBuff = System.IO.File.ReadAllBytes(filePath);
                if (submitType == SubmitType.FileServer)  //上传附件至文件服务器
                {
                    var result = this.UploadAttachment(file.FileName, dataBuff); // 将数据上传至文件服务器，并返回上传结果
                    if (result.Success)
                    {
                        dyn[fileServerName] = result.FileId;
                        BusinessDataServiceHelper.Save(this.Context, businessInfo, dyn);
                        str = "上传成功";
                    }
                    else
                    {
                        str = string.Format("附件：{0}，上传失败：{1}", file.FileName, result.Message); // 上传失败，收集失败信息
                    }
                    this.Model.SetValue("FFileLog", str);
                }
                else if (submitType == SubmitType.ImageServer)  //上传图片至文件服务器
                {
                    var result = this.UploadAttachment(file.FileName, dataBuff); // 将数据上传至文件服务器，并返回上传结果
                    if (result.Success)
                    {
                        dyn[imageServerName] = result.FileId;
                        BusinessDataServiceHelper.Save(this.Context, businessInfo, dyn);
                        str = "上传成功";
                    }
                    else
                    {
                        str = string.Format("附件：{0}，上传失败：{1}", file.FileName, result.Message); // 上传失败，收集失败信息
                    }
                    this.Model.SetValue("FImageLog", str);
                }
                else if (submitType == SubmitType.ImageDatabase)  //上传图片至数据库
                {
                    dyn[imageDatabaseName] = dataBuff;
                    BusinessDataServiceHelper.Save(this.Context, businessInfo, dyn);
                    str = "上传成功";
                }
            }
            base.AfterMobileUpload(e);
        }
        /// <summary>
        /// 上传至文件服务器的方法
        /// </summary>
        /// <param name="fileName"></param>
        /// <param name="dataBuff"></param>
        /// <returns></returns>
        private FileUploadResult UploadAttachment(string fileName, byte[] dataBuff)
        {
            // 初始化上传下载服务
            var service = new UpDownloadService();
            int len = 0, less = 0;
            string fileId = null;
            byte[] buff = null;
            while (len < dataBuff.Length)
            {
                // 文件服务器采用分段上传，每次上传4096字节, 最后一次如果不够则上传剩余长度
                less = (dataBuff.Length - len) >= 4096 ? 4096 : (dataBuff.Length - len);
                buff = new byte[less];
                Array.Copy(dataBuff, len, buff, 0, less);
                len += less;
                using (System.IO.MemoryStream ms = new System.IO.MemoryStream(buff))
                {
                    TFileInfo tFile = new TFileInfo()
                    {
                        FileId = fileId,
                        FileName = fileName,
                        CTX = this.Context,
                        Last = len >= dataBuff.Length,//标记是否为文件的最后一个片段 
                        Stream = ms
                    };
                    var result = submitType == SubmitType.FileServer ? service.UploadAttachment(tFile) : service.UploadImage(tFile);
                    // 注意点：上传时fileId传入null为新文件开始,会返回一个文件的fileId，后续采用这个fileId标识均为同一文件的不同片段。
                    fileId = result.FileId;
                    if (!result.Success)
                    {
                        return result;
                    }
                }
            }
            return new FileUploadResult()
            {
                Success = true,
                FileId = fileId
            };
        }
    }
}