Dynamics CRM中自定義頁面實現附件管理包含下載模板、上傳、下載、刪除

  1 using Microsoft.Xrm.Sdk;
  2 using Microsoft.Xrm.Sdk.Query;
  3 using Newtonsoft.Json;
  4 using NPOI.OpenXml4Net.OPC.Internal;
  5 using System;
  6 using System.Collections.Generic;
  7 using System.Data.Entity.Core.Objects.DataClasses;
  8 using System.IO;
  9 using System.Linq;
 10 using System.Net;
 11 using System.Net.Http;
 12 using System.Net.Http.Headers;
 13 using System.Reflection;
 14 using System.Text;
 15 using System.Threading.Tasks;
 16 using System.Web;
 17 using System.Web.Http;
 18 using ZZ_Common_API.Crm;
 19 using ZZ_Common_API.Models.QDRWModels;
 20 using EntityReference = Microsoft.Xrm.Sdk.EntityReference;
 21 
 22 namespace ZZ_Common_API.Controllers.QDRWControllers
 23 {
 24     /// <summary>
 25     /// 附件相關WebAPI介面
 26     /// </summary>
 27     [RoutePrefix("AccountChannelAccess")]
 28     public class AccountChannelAccessController : ApiController
 29     {
 30         #region 下載模板檔案 strat
 31         /// <summary>
 32         /// 下載附件
 33         /// </summary>
 34         /// <param name="type">1商業計劃書新籤,2商業計劃書續簽,3渠道基本資訊評價表,4海外網路退出要素確認表</param>
 35         /// <returns></returns>
 36         [Route("DownloadFileTemplate")]
 37         [HttpGet]
 38         public async Task<dynamic> DownloadFileTemplate(int type) 
 39         {
 40             HttpResponseMessage responseMessage = new HttpResponseMessage(HttpStatusCode.OK);
 41             string fileName = string.Empty;
 42             switch (type)
 43             {
 44                 case 1:
 45                     fileName = "附件1：商業計劃書新籤(可下載模版).pptx";
 46                     break;
 47                 case 2:
 48                     fileName = "附件2：商業計劃書續簽(可下載模版).pptx";
 49                     break;
 50                 case 3:
 51                     fileName = "附件3：渠道基本資訊評價表(可下載模版).docx";
 52                     break;
 53                 case 4:
 54                     fileName = "附件4：海外網路退出要素確認表（可下載模板）.docx";
 55                     break;
 56                 default:
 57                     fileName = "附件1：商業計劃書新籤(可下載模版).pptx";
 58                     break;
 59             }
 60            
 61             var filePath = AppDomain.CurrentDomain.BaseDirectory + @"\Files\Template\" + fileName;
 62             if (!File.Exists(filePath))
 63             {
 64                 return ResponseMessage(new HttpResponseMessage()
 65                 {
 66                     Content =
 67                      new StringContent(JsonConvert.SerializeObject(Json(new { code = 0, msg = $"下載失敗，未能找到檔案-{fileName}的路徑" })),
 68                        Encoding.GetEncoding("UTF-8"), "application/json"),
 69                     StatusCode = HttpStatusCode.NoContent
 70                 });
 71             }
 72             var stream = new FileStream(filePath, FileMode.Open);
 73             responseMessage.Content = new StreamContent(stream);
 74             responseMessage.Content.Headers.ContentType = new MediaTypeHeaderValue("application/octet-stream");
 75             HttpContext.Current.Response.AddHeader("Content-Disposition", "attachment;filename=" + HttpUtility.UrlPathEncode(fileName));
 76             return ResponseMessage(responseMessage);
 77         }
 78         
 79 
 80         #endregion 下載模板檔案 end
 81 
 82         #region 上傳附件 start
 83         /// <summary>
 84         /// 使用系統的註釋Annotation  新增附件
 85         /// </summary>
 86         /// <returns></returns>
 87         [Route("SaveAnnotation")]
 88         [HttpPost]
 89         public object SaveAnnotation()
 90         {
 91             try
 92             {
 93                 HttpFileCollection fileCollection = HttpContext.Current.Request.Files;
 94                 if (fileCollection.Count <= 0)
 95                 {
 96                     return Json(new { code = 0, msg = $"請先選擇檔案後點選上傳" });
 97                 }
 98                 var formData = HttpContext.Current.Request.Form;
 99                 var entityId = formData["entityId"];
100                 var entityName = formData["entityName"];
101 
102                 Guid objId = Guid.Empty;
103                 if (!Guid.TryParse(entityId, out objId)) //檢驗實體id是否合法
104                 {
105                     return Json(new { code = 0, msg = $"上傳失敗，entityId是不合法的GUID：{entityId}" });
106                 }
107                 HttpPostedFile formFile = fileCollection[0];
108                 if (formFile.ContentLength > 1048576000)//檢查檔案大小
109                 {
110                     return Json(new { code = 0, msg = $"{formFile.FileName}檔案大小不得超過{1048576000 / (1024f * 1024f)}M" });//請求體過大，檔案大小超標
111                 }
112                 var suffix = Path.GetExtension(formFile.FileName);//提取上傳的檔案檔案字尾
113                 if (".js;.bat;.exe;.sh".IndexOf(suffix) > 0) //檢查檔案格式
114                 {
115                     return Json(new { code = 0, msg = $"不支援此檔案型別-{suffix}" });//型別不正確
116                 }
117 
118                 AnnotationModel model = new AnnotationModel();
119                 model.Subject = Path.GetFileName(formFile.FileName).Substring(1);
120                 model.NoteText = "";
121                 model.ObjectId = objId;
122                 model.ObjectIdName = entityName;
123                 model.MimeType = formFile.ContentType;
124                 model.FileSize = formFile.ContentLength;
125                 model.FileName = Path.GetFileName(formFile.FileName);
126                 model.DocumentBody = Convert.ToBase64String(GetFileByte(formFile));
127                 //儲存到Annotation中
128                 CreateAnnotation(model);
129 
130                 return Json(new { code = 1, msg = "上傳成功" });
131             }
132             catch (Exception ex)
133             {
134                 return Json(new { code = 0, msg = $"上傳失敗 + {ex.Message}" });
135             }
136         }
137         #endregion 上傳附件 end
138 
139         #region 下載附件 start
140         /// <summary>
141         /// 下載附件
142         /// </summary>
143         /// <param name="id">附件id</param>
144         /// <returns></returns>
145         [Route("DownloadAnnotation")]
146         [AcceptVerbs("GET")]
147         public IHttpActionResult DownloadAnnotation(string id)
148         {
149             //通過附件id 找到附件 然後轉化附件位元組流 填入到響應中
150             HttpResponseMessage responseMessage = new HttpResponseMessage(HttpStatusCode.OK);
151             try
152             {
153                 if (string.IsNullOrEmpty(id))
154                 {
155                     return ResponseMessage(new HttpResponseMessage(HttpStatusCode.Gone));
156                 }
157                 Tuple<string, Stream> tuple = GetAnnotationStream(id);
158                 if (tuple.Item1 == "未能獲取到位元組流")
159                 {
160                     return ResponseMessage(new HttpResponseMessage(HttpStatusCode.Gone));
161                 }
162                 responseMessage.Content = new StreamContent(tuple.Item2);
163                 responseMessage.Content.Headers.ContentType = new MediaTypeHeaderValue("application/octet-stream");
164                 HttpContext.Current.Response.AddHeader("Content-Disposition", "attachment;filename=" + HttpUtility.UrlPathEncode(tuple.Item1));
165             }
166             catch (Exception ex)
167             {
168                 return ResponseMessage(new HttpResponseMessage()
169                 {
170                     Content =
171                      new StringContent(JsonConvert.SerializeObject(Json(new { code = 0, msg = $"下載失敗-{ex.Message}" })),
172                        Encoding.GetEncoding("UTF-8"), "application/json"),
173                     StatusCode = HttpStatusCode.NoContent
174                 });
175             }
176             return ResponseMessage(responseMessage);
177         }
178         #endregion 下載附件 end
179 
180         #region 根據實體id獲取實體資料下相關所有附件，打包成zip檔案下載 start
181         /// <summary>
182         /// 下載實體資料下所有的附件zip
183         /// 根據實體id獲取實體資料下相關所有附件，打包成zip檔案下載
184         /// </summary>
185         /// <param name="id"></param>
186         /// <returns></returns>
187         [Route("DownloadAnnotationAll")]
188         [AcceptVerbs("GET")]
189         public IHttpActionResult DownloadAnnotationAll(string id)
190         {
191             HttpResponseMessage responseMessage = new HttpResponseMessage(HttpStatusCode.OK);
192             try
193             {
194                 if (string.IsNullOrEmpty(id))
195                 {
196                     return ResponseMessage(new HttpResponseMessage(HttpStatusCode.Gone));
197                 }
198                 //通過模組id 找到相關的所有附件 然後將所有的附件打包成zip檔案 將zip檔案轉化位元組流 填入到響應流中
199                 if (string.IsNullOrEmpty(id))
200                 {
201                     return ResponseMessage(new HttpResponseMessage(HttpStatusCode.Gone));
202                 }
203                 Tuple<string, Stream> tuple = GetAllAnnotationStream(id);
204                 if (tuple.Item1 == "未能獲取到位元組流")
205                 {
206                     return ResponseMessage(new HttpResponseMessage(HttpStatusCode.Gone));
207                 }
208                 responseMessage.Content = new StreamContent(tuple.Item2);
209                 responseMessage.Content.Headers.ContentType = new MediaTypeHeaderValue("application/octet-stream");
210                 HttpContext.Current.Response.AddHeader("Content-Disposition", "attachment;filename=" + HttpUtility.UrlPathEncode(tuple.Item1));
211             }
212             catch (Exception ex)
213             {
214                 return ResponseMessage(new HttpResponseMessage()
215                 {
216                     Content =
217                      new StringContent(JsonConvert.SerializeObject(Json(new { code = 0, msg = $"下載失敗-{ex.Message}" })),
218                        Encoding.GetEncoding("UTF-8"), "application/json"),
219                     StatusCode = HttpStatusCode.NoContent
220                 });
221             }
222             return ResponseMessage(responseMessage);
223         }
224 
225         #endregion 根據實體id獲取實體資料下相關所有附件，打包成zip檔案下載 end
226 
227         #region API專用 刪除附件
228         /// <summary>
229         /// 刪除附件
230         /// </summary>
231         /// <param name="id">附件ids</param>
232         /// <returns></returns>
233         [Route("DelAnnotation")]
234         [HttpPost]
235         public object DelAnnotation([FromBody] string id)
236         {
237             try
238             {
239                 if (string.IsNullOrEmpty(id))
240                 {
241                     return Json(new { code = 0, msg = $"刪除附件時id不能為空" });
242                 }
243                 DeleteAnnotation(id);
244                 return Json(new { code = 1, msg = "刪除成功" }); ;
245             }
246             catch (Exception ex)
247             {
248                 return Json(new { code = 0, msg = $"刪除失敗：{ex.Message}" });
249             }
250         }
251         #endregion API專用 刪除附件
252 
253         #region 內部方法 start
254 
255         #region 上傳附件存到Annotation中 start
256         /// <summary>
257         /// 將上傳檔案物件轉化成byte位元組流
258         /// </summary>
259         /// <param name="httpPostedFile">上傳檔案</param>
260         /// <returns></returns>
261         private byte[] GetFileByte(HttpPostedFile httpPostedFile)
262         {
263             byte[] bytes = new byte[httpPostedFile.ContentLength];
264             using (BinaryReader reader = new BinaryReader(httpPostedFile.InputStream, Encoding.UTF8))
265             {
266                 bytes = reader.ReadBytes(bytes.Length);
267             }
268             return bytes;
269         }
270         /// <summary>
271         /// 建立附件資料
272         /// </summary>
273         /// <param name="annotation"></param>
274         /// <returns></returns>
275         private Guid CreateAnnotation(AnnotationModel annotation)
276         {
277             Guid guid = Guid.Empty;
278             IOrganizationService orgService = OrgServiceUtil.Client;
279             Entity entity = new Entity("annotation");
280             entity["filename"] = annotation.FileName;
281             entity["subject"] = annotation.Subject;
282             entity["mimetype"] = annotation.MimeType;
283             entity["filesize"] = annotation.FileSize;
284             entity["documentbody"] = annotation.DocumentBody;
285             entity["objectid"] = new EntityReference(annotation.ObjectIdName, annotation.ObjectId);
286             guid = orgService.Create(entity);
287             return guid;
288         }
289         #endregion 上傳附件存到Annotation中 end
290 
291 
292         #region 根據附件id獲取附件位元組流 start
293         /// <summary>
294         /// 根據附件id獲取附件位元組流
295         /// </summary>
296         /// <param name="annotationid">annotationid</param>
297         /// <returns></returns>
298         public Tuple<string, Stream> GetAnnotationStream(string annotationid)
299         {
300             Tuple<string, Stream> rr = new Tuple<string, Stream>("未能獲取到位元組流", null);
301             try
302             {
303                 IOrganizationService orgService = OrgServiceUtil.Client;
304                 ColumnSet cols = new ColumnSet("filename", "documentbody");
305                 Entity entity = orgService.Retrieve("annotation", new Guid(annotationid), cols);
306                 string documentbody = entity.GetAttributeValue<string>("documentbody");
307                 string filename = entity.GetAttributeValue<string>("filename");
308                 byte[] fileContent = Convert.FromBase64String(documentbody);
309                 Stream fileStream = new MemoryStream(fileContent);
310                 rr = new Tuple<string, Stream>(filename, fileStream);
311             }
312             catch (Exception)
313             {
314                 return rr;
315             }
316             return rr;
317         }
318         #endregion 根據附件id獲取附件位元組流 end
319 
320         #region 根據實體資料id獲取所有附件並打包成zip檔案，然後轉換成位元組流 start
321         /// <summary>
322         /// 根據實體資料id獲取所有附件達成zip包後轉換成位元組流
323         /// </summary>
324         /// <param name="entityId">實體資料id</param>
325         /// <returns></returns>
326         public Tuple<string, Stream> GetAllAnnotationStream(string entityId)
327         {
328             Tuple<string, Stream> rr = new Tuple<string, Stream>("未能獲取到位元組流", null);
329             try
330             {
331                 IOrganizationService orgService = OrgServiceUtil.Client;
332                 //1.根據實體資料id查詢出所有相關得附件
333                 var dbList = GetDbFileByEntityId(orgService,new Guid(entityId));
334                 //2.遍歷所有相關得附件 將各個附件流轉化存放到記憶體字典中
335                 Dictionary<string, byte[]> dic = new Dictionary<string, byte[]>();
336                 foreach (var cc in dbList)
337                 {
338                     string documentbody = cc.GetAttributeValue<string>("documentbody");
339                     string filename = cc.GetAttributeValue<string>("filename");
340                     byte[] fileContent = Convert.FromBase64String(documentbody);
341                     Tuple<string, byte[]> tt = new Tuple<string, byte[]>(filename, fileContent);
342                     if (tt.Item2 == null)
343                     {
344                         continue;
345                     }
346                     dic.Add(tt.Item1, tt.Item2);
347                 }
348                 if (dic.Count > 0)
349                 {
350                     //3.將多個位元組流從字典壓縮成zip檔案並轉成一個位元組流
351                     Stream stream = ZipByteHelper.SetbytesToZipStream2(dic);
352                     rr = new Tuple<string, Stream>("附件.zip", stream);
353                 }
354             }
355             catch (Exception)
356             {
357                 return rr;
358             }
359             return rr;
360         }
361 
362         private List<Entity> GetDbFileByEntityId(IOrganizationService orgService,Guid entityId) 
363         {
364             var list = new List<Entity>();
365             QueryExpression query = new QueryExpression("annotation");
366             query.ColumnSet = new ColumnSet(true);
367             query.Criteria.AddCondition(new ConditionExpression("objectid", ConditionOperator.Equal, entityId));
368             var datas = orgService.RetrieveMultiple(query);
369             list = datas.Entities.ToArray().ToList();
370             return list;
371         }
372         #endregion 根據實體資料id獲取所有附件並打包成zip檔案，然後轉化稱位元組流 end
373 
374         #region 刪除附件 start
375         /// <summary>
376         /// 刪除附件註釋
377         /// </summary>
378         /// <param name="annotationid">附件id</param>
379         /// <returns></returns>
380         /// <exception cref="Exception"></exception>
381         public bool DeleteAnnotation(string annotationid)
382         {
383             bool result = true;
384             if (string.IsNullOrEmpty(annotationid))
385             {
386                 result = false;
387             }
388             IOrganizationService orgService = OrgServiceUtil.Client;
389             orgService.Delete("annotation", Guid.Parse(annotationid));
390             return result;
391         }
392         #endregion 刪除附件 end
393         #endregion 內部方法 end
394     }
395 }