From 5b5c1e16deaa3a9d6d0ed1ffca390655ed103df7 Mon Sep 17 00:00:00 2001
From: buli <137736985@qq.com>
Date: 星期五, 14 七月 2023 14:56:14 +0800
Subject: [PATCH] lex community

---
 force-app/main/default/classes/Batch_FixAttachmentToFiles.cls |   82 ++++++++++++++++++++++++++++++-----------
 1 files changed, 60 insertions(+), 22 deletions(-)

diff --git a/force-app/main/default/classes/Batch_FixAttachmentToFiles.cls b/force-app/main/default/classes/Batch_FixAttachmentToFiles.cls
index 749b18b..ccb9821 100644
--- a/force-app/main/default/classes/Batch_FixAttachmentToFiles.cls
+++ b/force-app/main/default/classes/Batch_FixAttachmentToFiles.cls
@@ -1,30 +1,37 @@
 global without sharing class Batch_FixAttachmentToFiles implements Database.Batchable<sObject>{
-    // Id batchJobId = Database.executeBatch(new Batch_FixAttachmentToFiles(Datetime.newInstance(2023, 5, 20, 8, 0, 0),'Consumable_order__c'),2000);
-    private Datetime endDate = null;
-    private String objectApiName = null;
-    public Batch_FixAttachmentToFiles(Datetime setTime,String objectType) {
-        endDate = setTime;
+    // Id batchJobId = Database.executeBatch(new Batch_FixAttachmentToFiles('Consumable_order__c',Datetime.newInstance(2023, 1, 1, 8, 0, 0),Datetime.newInstance(2024, 1, 1, 8, 0, 0)),2000);
+    private Datetime creStartDate = null;
+    private Datetime creEndDate = null;
+    private String objectApiName  = null;
+    private Set<String> parentIds = new Set<String>();//Add by Li Jun 20230703 
+    public Batch_FixAttachmentToFiles(String objectType, Datetime startTime, Datetime endTime) {
+        creStartDate = startTime;
+        creEndDate = endTime;
         objectApiName = objectType;
     }
-
+    //Add by Li Jun 20230703 Start
+    public Batch_FixAttachmentToFiles(Set<String> parentIds) {
+        this.parentIds = parentIds;
+    }
+     //Add by Li Jun 20230703 End
     global Database.QueryLocator start(Database.BatchableContext BC) {
-        String queryObject = 'SELECT Id FROM ' + objectApiName + ' WHERE CreatedDate >=:endDate' + ' order by CreatedDate desc';
-        System.debug('queryObject:' + queryObject);
-        return Database.getQueryLocator(queryObject);//鍙栨寚瀹歄bject涓嬮潰鐨処d鎴栬�呭鐞嗗叏閮�
+        String queryObject = 'SELECT Id, Name, OwnerId, ParentId, Parent.Name, Parent.Type, Body, CreatedDate, CreatedById FROM Attachment WHERE Parent.Type =:objectApiName AND CreatedDate >=:creStartDate AND CreatedDate <:creEndDate Order by CreatedDate ASC';
+        if(parentIds.size() > 0){
+            queryObject = 'SELECT Id, Name, OwnerId, ParentId, Parent.Name, Parent.Type, Body, CreatedDate, CreatedById FROM Attachment WHERE ParentId in:parentIds';
+        }
+        return Database.getQueryLocator(queryObject);
     }
 
-    global void execute(Database.BatchableContext BC, List<sObject> scope) {
-        Set<Id> setId = new Set<Id>();
-        for(sObject sc: scope){
-            setId.add(sc.Id);
-        }
+    global void execute(Database.BatchableContext BC, List<Attachment> scope) {
         List<ContentVersion> insertContents = new List<ContentVersion>();
-        Map<string,id> nameParentMaps = new Map<string,id>();
-        for (Attachment att : [select Id,Name ,OwnerId,ParentId, Body, CreatedById from Attachment where ParentId in: setId Order by Name desc]) {
-            nameParentMaps.put(att.name, att.ParentId);   
+        Map<string,id> nameParentMaps = new Map<string,id>();  
+        Set<String> attachmentIds = new Set<String>();   
+        for (Attachment att : scope) {
+            nameParentMaps.put(att.Id, att.ParentId);
+            attachmentIds.add(att.Id);   
             ContentVersion cVersion = new ContentVersion();
             cVersion.ContentLocation = 'S';     //S-Document is in Salesforce. E-Document is outside of Salesforce. L-Document is on a Social Netork.
-            cVersion.PathOnClient = att.Name;   //File name with extention
+            cVersion.PathOnClient = att.Id;   //File name with extention
             cVersion.Origin = 'C';              //C-Content Origin. H-Chatter Origin.   
             cVersion.Title = att.Name;          //Name of the file
             cVersion.VersionData = att.Body;    //File content
@@ -33,24 +40,55 @@
         if(insertContents.isEmpty()){
             return;
         }
-        Insert insertContents;
+        //Insert insertContents;
+        List<Database.SaveResult> saveResultsContents = Database.insert(insertContents, false);
+        insertLog(saveResultsContents,attachmentIds);
         set<Id> contentIds = new set<Id>();
         for(ContentVersion cv : insertContents){
             contentIds.add(cv.id);
         }
-        List<ContentVersion> conDocuments = [SELECT ContentDocumentId, Title FROM ContentVersion WHERE Id in: contentIds];
+        List<ContentVersion> conDocuments = [SELECT ContentDocumentId, Title,PathOnClient FROM ContentVersion WHERE Id in: contentIds];
         List<ContentDocumentLink> insertDocLinks = new List<ContentDocumentLink>();  
         for(ContentVersion cv : conDocuments){
             ContentDocumentLink cDocLink = new ContentDocumentLink();
             cDocLink.ContentDocumentId = cv.ContentDocumentId;          //Add ContentDocumentId
-            cDocLink.LinkedEntityId = nameParentMaps.get(cv.Title);     //Add attachment parentId
+            cDocLink.LinkedEntityId = nameParentMaps.get(cv.PathOnClient);     //Add attachment parentId
             cDocLink.ShareType = 'V';                                   //V - Viewer permission. C - Collaborator permission. I - Inferred permission.
             cDocLink.Visibility = 'AllUsers';
             insertDocLinks.add(cDocLink);
         }
-        Insert insertDocLinks;
+        //Insert insertDocLinks;
+        List<Database.SaveResult> saveResultsLinks = Database.insert(insertDocLinks, false);
+        insertLog(saveResultsLinks,attachmentIds);
     }
 
+    global void insertLog(List<Database.SaveResult> saveResults,Set<String> attachmentIds) {
+        Transaction_Log__c traLog = new Transaction_Log__c();
+        List<Map<String,String>> logMapList = new List<Map<String,String>>();
+        for (Database.SaveResult result : saveResults) {
+            String recordId = result.getId();
+            if (!result.isSuccess()) {
+                for (Database.Error error : result.getErrors()) {
+                    Map<String,String> logMap = new Map<String,String>();
+                    String errorMsg = error.getMessage();
+                    logMap.put('recordId',recordId);
+                    logMap.put('errorMsg',errorMsg);
+                    logMapList.add(logMap);
+                }
+            }
+        }
+        if(logMapList.size() > 0){
+            Map<String,String> attachmentIdMap = new Map<String,String>();
+            attachmentIdMap.put('attachmentIds',JSON.serialize(attachmentIds));
+            logMapList.add(attachmentIdMap);
+            traLog.Response__c = JSON.serialize(logMapList);
+            traLog.Module__c = 'Attachment COnvert Transaction ';
+            Insert traLog;
+        }
+    }
+
+
+
     global void finish(Database.BatchableContext BC) {
 
     }

--
Gitblit v1.9.1