global class NFM609FiledDownloadBatch implements Database.Batchable < sObject > , Database.AllowsCallouts {
|
public String query;
|
public string objectType;
|
global NFM609FiledDownloadBatch() {
|
this.query = query;
|
}
|
|
global NFM609FiledDownloadBatch(String objectType) {
|
this.objectType = objectType;
|
}
|
|
global Database.QueryLocator start(Database.BatchableContext bc) {
|
String sql = 'SELECT Id, AttachmentDownload__c, AttachmentLink__c, AttachmentName__c FROM '+objectType+' where AttachmentDownload__c = true AND AttachmentLink__c != \'\' AND AttachmentName__c != \'\'';
|
System.debug('sql--->'+sql);
|
return Database.getQueryLocator(sql);
|
}
|
|
global void execute(Database.BatchableContext BC, List < sObject > sObjectList) {
|
String endpoint = '';
|
String parentId = '';
|
String attachmentName = '';
|
List<Case> updateCaseList = new List<Case>();
|
List<RepairSubOrder__c> updateSubOrderList = new List<RepairSubOrder__c>();
|
for (sObject obj: sObjectList) {
|
if ('Case'.equals(objectType)) {
|
Case cas = (Case)obj;
|
cas.AttachmentDownload__c = false;
|
endpoint = cas.AttachmentLink__c;
|
parentId = cas.Id;
|
attachmentName = cas.AttachmentName__c;
|
updateCaseList.add(cas);
|
}
|
|
if ('RepairSubOrder__c'.equals(objectType)) {
|
RepairSubOrder__c subOrder = (RepairSubOrder__c)obj;
|
subOrder.AttachmentDownload__c = false;
|
endpoint = subOrder.AttachmentLink__c;
|
parentId = subOrder.Id;
|
attachmentName = subOrder.AttachmentName__c;
|
updateSubOrderList.add(subOrder);
|
}
|
|
}
|
|
try{
|
// 20231103 陈京武 Lightning文件修改 Start
|
List < ContentVersion > newAttList = AttachmentFiledDownload(endpoint, parentId, attachmentName);
|
|
// if (newAttList.size() > 0) {
|
// List < Attachment > delAttaList = [select id from Attachment where ParentId =: parentId];
|
// if (delAttaList.size() > 0) {
|
// delete delAttaList;
|
// }
|
// insert newAttList;
|
// }
|
// 20231103 陈京武 Lightning文件修改 End
|
if (updateCaseList.size() > 0) {
|
update updateCaseList;
|
}
|
|
if (updateSubOrderList.size() > 0) {
|
update updateSubOrderList;
|
}
|
// update sObjectList;
|
} catch (Exception ex) {
|
|
}
|
// }
|
}
|
// 20231103 陈京武 Lightning文件修改 Start
|
global static List < ContentVersion > AttachmentFiledDownload(String endpoint, String parentId, String attachmentName) {
|
List<ContentDocumentLink> linkList = [
|
select
|
ContentDocumentId
|
from ContentDocumentLink where LinkedEntityId =: parentId
|
];
|
if (linkList.size() > 0) {
|
List<Id> idList = new List<Id>();
|
for (ContentDocumentLink link : linkList) {
|
idList.add(link.ContentDocumentId);
|
}
|
List<ContentDocument> conList = [select Id from ContentDocument where Id in: idList];
|
delete conList;
|
}
|
// List < Attachment > result = new List < Attachment > ();
|
List<ContentVersion> result = new List<ContentVersion>();
|
Http http = new Http();
|
HttpRequest req = new HttpRequest();
|
req.setTimeout(120000);
|
req.setEndpoint(endpoint);
|
req.setMethod('GET');
|
|
HTTPResponse response = http.send(req);
|
|
String status = response.getStatus();
|
system.debug('status---->' + status);
|
|
String statusCode = String.valueOf(response.getStatusCode());
|
system.debug('statusCode---->' + statusCode);
|
|
// Attachment atta = new Attachment();
|
// atta.ParentId = parentId;
|
// atta.Name = attachmentName;
|
ContentVersion version = new ContentVersion();
|
version.Title = attachmentName;
|
version.ContentLocation = 's';
|
if ('200'.equals(statusCode)) {
|
// 附件大小
|
// 12,582,912
|
Integer ContentLength = Integer.valueOf(response.getHeader('Content-Length'));
|
System.debug('ContentLength----->' + ContentLength);
|
if (ContentLength < 12582912) {
|
Blob bodyAsBlob = response.getBodyAsBlob();
|
version.VersionData = bodyAsBlob;
|
version.PathOnClient = attachmentName + '.txt';
|
// atta.Body = bodyAsBlob;
|
result.add(version);
|
} else {
|
// atta.Name = '文件大小超过12M,请在新服务系统查看';
|
// atta.Body = Blob.valueOf('文件大小超过12M');
|
version.Title = '文件大小超过12M,请在新服务系统查看';
|
version.PathOnClient = '文件大小超过12M,请在新服务系统查看.txt';
|
version.VersionData = Blob.valueOf('文件大小超过12M');
|
result.add(version);
|
}
|
insert result;
|
version = [select ContentDocumentId from ContentVersion where Id =: version.Id];
|
ContentDocumentLink link = new ContentDocumentLink();
|
link.LinkedEntityId = parentId;
|
link.ShareType = 'I';
|
link.ContentDocumentId = version.ContentDocumentId;
|
link.Visibility = 'AllUsers';
|
insert link;
|
}
|
// 20231103 陈京武 Lightning文件修改 End
|
|
|
// system.debug('responseBody503--->'+bodyAsBlob);
|
return result;
|
}
|
|
global void finish(Database.BatchableContext BC) {
|
|
}
|
}
|
