global class CBF2batch implements Database.Batchable<SObject> , Database.Stateful {
|
public String query;
|
public String cbfId;
|
public String xhId;
|
private BatchIF_Log__c iflog;
|
|
global CBF2batch() {
|
this.query = query;
|
}
|
|
global CBF2batch(String cbfId,String xhId) {
|
this.query = query;
|
this.cbfId = cbfId;
|
this.xhId = xhId;
|
}
|
|
global Database.QueryLocator start(Database.BatchableContext bc) {
|
//添加邮件提醒 start
|
system.debug('执行start');
|
iflog = new BatchIF_Log__c();
|
iflog.Type__c = 'CBF2batch';
|
iflog.Log__c = 'CBF2batch start\n';
|
iflog.ErrorLog__c = '';
|
insert iflog;
|
//添加邮件提醒 end
|
query = 'select id,name,cbf_execute__c from Account where Is_Active_Formula__c = \'有效\' and Acc_Record_Type__c = \'病院\'';
|
if (cbfId != null && cbfId != '') {
|
query += ' and id = :cbfId';
|
}else {
|
query += ' and id in(select Hospital__c from Repair__c WHERE Cumulative_Uses__c != null AND Cumulative_Times__c != null)';
|
}
|
System.debug('执行结果：'+Database.getQueryLocator(query));
|
return Database.getQueryLocator(query);
|
}
|
|
global void execute(Database.BatchableContext BC, list<Account> AccountList) {
|
List<String> accountIds = new List<String>();
|
for (Account acc : AccountList) {
|
accountIds.add(acc.id);
|
}
|
iflog.Log3__c = JSON.serialize(accountIds);
|
update iflog;
|
List<Repair__c> repairList = [SELECT Id,
|
Name,
|
Cumulative_Uses__c,
|
Cumulative_Times__c,
|
Repair_Ordered_Date__c,
|
Cycle_between_failure__c,
|
Product_Unique_Value__c,
|
OwnershipMachine_No__c,
|
Repair_Inspection_Date__c,
|
Difference_in_repair_intervals__c,
|
Hospital__c
|
FROM Repair__c
|
WHERE
|
Repair_Inspection_Date__c != null
|
AND Hospital__c in: accountIds and OwnershipMachine_No__c = :xhId ORDER BY Repair_Ordered_Date__c Asc];
|
try {
|
// 定义一个列表来存储查询结果
|
List<Repair__c> resultList = new List<Repair__c>();
|
|
// 通过map 对相同Product_Unique_Value__c 组合的数据进行分组
|
Map<String, List<Repair__c>> repairMap = new Map<String, List<Repair__c>>();
|
for(Repair__c r : repairList) {
|
if(repairMap.containsKey(r.Product_Unique_Value__c)) {
|
repairMap.get(r.Product_Unique_Value__c).add(r);
|
} else {
|
List<Repair__c> tempList = new List<Repair__c>();
|
tempList.add(r);
|
repairMap.put(r.Product_Unique_Value__c, tempList);
|
}
|
}
|
for(String key : repairMap.keySet()) {
|
Date prevDate = null; // 记录前一个日期
|
Id lastRepairId = null; // 记录上一个修理的Id
|
List<Repair__c> rList = repairMap.get(key);
|
for (Integer i = 0; i < rList.size(); i++) {
|
Repair__c repair = rList[i];
|
Date currentDate = repair.Repair_Inspection_Date__c;
|
if (i == 0) { // 如果是第一条记录
|
repair.Difference_in_repair_intervals__c = 0;
|
} else { // 如果不是第一条记录
|
if (rList[i-1].Cycle_between_failure__c != null) {
|
Integer days = prevDate.daysBetween(currentDate);
|
repair.Difference_in_repair_intervals__c = Math.abs(days);
|
}else {
|
Integer days = prevDate.daysBetween(currentDate);
|
repair.Difference_in_repair_intervals__c = Math.abs(days) + rList[i-1].Difference_in_repair_intervals__c;
|
}
|
}
|
repair.LastRepair__c = lastRepairId; // 设置 LastRepair__c 字段为上一个修理的Id
|
|
prevDate = currentDate; // 更新前一个日期为当前日期
|
lastRepairId = repair.Id; // 更新上一个修理的Id为当前修理的Id
|
}
|
resultList.addAll(rList);
|
}
|
|
System.debug('更新数据打印:'+resultList);
|
Database.SaveResult[] saveTenderResults = Database.update(resultList, false);
|
|
for (Integer save = 0; save < saveTenderResults.size(); save++) {
|
Database.SaveResult sr = saveTenderResults[save];
|
if (!sr.isSuccess()) {
|
Database.Error emsg = sr.getErrors()[0];
|
iflog.ErrorLog__c += 'ERROR ' + saveTenderResults[save].id + 'SS_oli:' + emsg + '\n';
|
}else {
|
iflog.Log2__c += saveTenderResults[save].id +',';
|
}
|
}
|
|
} catch (Exception e) {
|
// 记录错误消息
|
String errorMessage = e.getMessage()+'===========>报错医院'+accountIds;
|
iflog.ErrorLog__c += errorMessage;
|
update iflog;
|
return;
|
}
|
}
|
|
global void finish(Database.BatchableContext BC) {
|
iflog.Log__c += '\nCBFbatch end';
|
update iflog;
|
}
|
|
public static Integer calculateDaysBetween(Date startDate, Date endDate) {
|
// 使用Date类的daysBetween方法计算天数差异
|
Integer days = startDate.daysBetween(endDate);
|
|
return Math.abs(days); // 如果你希望天数始终为正数，可以使用Math.abs方法
|
}
|
|
}
|
