OlyMEBG.git - Gitblit

			@@ -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);//取指定Object下面的Id或者处理全部
			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) {

			}