From cd05a7b0ab8dd5838f8998fb36fc0435fd9c5b84 Mon Sep 17 00:00:00 2001
From: buli <137736985@qq.com>
Date: 星期二, 11 七月 2023 14:07:40 +0800
Subject: [PATCH] LEX Community Code Deploy0711
---
force-app/main/default/classes/Batch_FixAttachmentToFiles.cls | 156 ++++++++++++++++++++++++++++++++++-----------------
1 files changed, 104 insertions(+), 52 deletions(-)
diff --git a/force-app/main/default/classes/Batch_FixAttachmentToFiles.cls b/force-app/main/default/classes/Batch_FixAttachmentToFiles.cls
index 749b18b..06af07c 100644
--- a/force-app/main/default/classes/Batch_FixAttachmentToFiles.cls
+++ b/force-app/main/default/classes/Batch_FixAttachmentToFiles.cls
@@ -1,57 +1,109 @@
-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;
- objectApiName = objectType;
+global without sharing class Batch_FixAttachmentToFiles implements Database.Batchable<sObject> {
+ // 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, 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 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鎴栬�呭鐞嗗叏閮�
+ global void execute(Database.BatchableContext BC, List<Attachment> scope) {
+ List<ContentVersion> insertContents = new List<ContentVersion>();
+ Map<string, id> nameParentMaps = new Map<string, id>();
+ Set<String> attachmentIds = new Set<String>();
+ for (Attachment att : scope) {
+ nameParentMaps.put(att.Name, 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.Origin = 'C'; //C-Content Origin. H-Chatter Origin.
+ cVersion.Title = att.Name; //Name of the file
+ cVersion.VersionData = att.Body; //File content
+ insertContents.add(cVersion);
}
-
- global void execute(Database.BatchableContext BC, List<sObject> scope) {
- Set<Id> setId = new Set<Id>();
- for(sObject sc: scope){
- setId.add(sc.Id);
- }
- 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);
- 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.Origin = 'C'; //C-Content Origin. H-Chatter Origin.
- cVersion.Title = att.Name; //Name of the file
- cVersion.VersionData = att.Body; //File content
- insertContents.add(cVersion);
- }
- if(insertContents.isEmpty()){
- return;
- }
- Insert insertContents;
- 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<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.ShareType = 'V'; //V - Viewer permission. C - Collaborator permission. I - Inferred permission.
- cDocLink.Visibility = 'AllUsers';
- insertDocLinks.add(cDocLink);
- }
- Insert insertDocLinks;
+ if (insertContents.isEmpty()) {
+ return;
}
-
- global void finish(Database.BatchableContext BC) {
-
+ //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);
}
-}
\ No newline at end of file
+ List<ContentVersion> conDocuments = [
+ SELECT ContentDocumentId, Title
+ 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.ShareType = 'V'; //V - Viewer permission. C - Collaborator permission. I - Inferred permission.
+ cDocLink.Visibility = 'AllUsers';
+ insertDocLinks.add(cDocLink);
+ }
+ //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