// LHJ 20190712 HWAG-BDH9V5 Start
|
//global class RollupToMaintenanceContractBatch implements Database.Batchable<AggregateResult> {
|
global class RollupToMaintenanceContractBatch implements Database.Batchable<SObject> , Database.Stateful {
|
// LHJ 20190712 HWAG-BDH9V5 End
|
// LHJ 20190712 HWAG-BDH9V5 Start
|
global Integer totalCount = 0; // 总件数
|
global Integer failedCount = 0;
|
global List<String> emailMessages = new List<String>();
|
public List<Id> ConId;
|
|
global RollupToMaintenanceContractBatch(List<Id> conID) {
|
this.ConId = conID;
|
}
|
// LHJ 20190712 HWAG-BDH9V5 End
|
|
/**
|
* コンスタント
|
*/
|
global RollupToMaintenanceContractBatch() {
|
}
|
|
/**
|
* startには、queryを実行、维修合同を検索
|
*/
|
//global Iterable<AggregateResult> start(Database.batchableContext BC){
|
global Database.QueryLocator start(Database.batchableContext BC){
|
//return new AggregateResultIterable();
|
/* CHAN-B7J5EK 2018/12/18 按照维修合同划分进行检索 start
|
return Database.getQueryLocator(
|
[select Id from User where Id = :UserInfo.getUserId()]
|
);
|
CHAN-B7J5EK 2018/12/18 按照维修合同划分进行检索 end
|
*/
|
// LHJ 20190712 HWAG-BDH9V5 Start
|
//return Database.getQueryLocator(
|
// [select Id from Maintenance_Contract__c]
|
//);
|
|
|
if(ConId != null && ConId.size() > 0) {
|
return Database.getQueryLocator([select Id from Maintenance_Contract__c where Id in :ConId]);
|
} else {
|
// 20221117 ljh DB202211258553 start
|
// return Database.getQueryLocator([select Id from Maintenance_Contract__c]);
|
return Database.getQueryLocator([select Id from Maintenance_Contract__c where Status__c = '契約' OR (Status__c = '契約満了' and Contract_End_Date__c >= :Date.today().addMonths(-6))]);
|
// 20221117 ljh DB202211258553 end
|
}
|
|
|
// LHJ 20190712 HWAG-BDH9V5 End
|
|
// if(ConId != null && ConId.size() > 0) {
|
// return Database.getQueryLocator()
|
// }
|
}
|
|
global void execute(Database.BatchableContext BC, List<SObject> mcList) {
|
// LHJ 20190712 HWAG-BDH9V5 Start
|
Savepoint sp = Database.setSavepoint();
|
totalCount += 1;
|
|
try {
|
// LHJ 20190712 HWAG-BDH9V5 End
|
// 维修合同更新
|
Map<Id, Maintenance_Contract__c> updateMC = new Map<Id, Maintenance_Contract__c>();
|
/******************************* HWAG-AV2C67 2018/1/17 START ******************************/
|
//List<Id> mcids = new List<Id>();
|
|
// 已经SAP的循环汇总
|
List<Repair__c> sapRepairList =
|
[select Repair_List_Price_formula__c,
|
Repair_cost__c,
|
Maintenance_Contract__c,
|
Maintenance_Contract__r.Contract_Start_Date__c,
|
Maintenance_Contract__r.Contract_End_Date__c,
|
Failure_Occurrence_Date__c,
|
Repair_Quotation_Id__r.LatestQuotationDate__c,
|
Repair_Quotation_Id__c
|
from Repair__c
|
where Maintenance_Contract__c != null
|
/* CHAN-B7J5EK 2018/12/18 按照维修合同划分进行检索 start */
|
and Maintenance_Contract__c in: mcList
|
/* CHAN-B7J5EK 2018/12/18 按照维修合同划分进行检索 end */
|
and Status2__c !='00.删除'
|
and Status2__c !='00.取消'
|
and Repair_Quotation_Id__c !=null
|
and (CutPrice_Reason__c='维修合同'
|
or CutPrice_Reason__c='套餐折扣,维修合同'
|
or CutPrice_Reason__c='营业对应,维修合同')
|
order by Maintenance_Contract__c];
|
|
if (sapRepairList != null && sapRepairList.size() > 0) {
|
for (Repair__c rc : sapRepairList) {
|
Maintenance_Contract__c mc = new Maintenance_Contract__c();
|
if (updateMC.containsKey(rc.Maintenance_Contract__c)) {
|
mc = updateMC.get(rc.Maintenance_Contract__c);
|
} else {
|
mc.Id = rc.Maintenance_Contract__c;
|
mc.Sum_repair_price__c=0.0;
|
mc.Repair_Cost_Sum__c =0.0;
|
}
|
Date dTDate = rc.Failure_Occurrence_Date__c;
|
Date dSDate = rc.Maintenance_Contract__r.Contract_Start_Date__c;
|
Date dEDate = rc.Maintenance_Contract__r.Contract_End_Date__c;
|
|
if (dTDate >= dSDate && dTDate <= dEDate) {
|
mc.Sum_repair_price__c += rc.Repair_List_Price_formula__c == null ? 0 : rc.Repair_List_Price_formula__c;
|
mc.Repair_Cost_Sum__c += rc.Repair_cost__c == null ? 0 : rc.Repair_cost__c;
|
}
|
updateMC.put(rc.Maintenance_Contract__c, mc);
|
}
|
}
|
|
// 没有SAP的循环汇总
|
List<Repair__c> noSapRepairList =
|
[select Repair_List_Price_formula__c,
|
Repair_cost__c,
|
Maintenance_Contract__c,
|
Maintenance_Contract__r.Contract_Start_Date__c,
|
Maintenance_Contract__r.Contract_End_Date__c,
|
Failure_Occurrence_Date__c,
|
Repair_Quotation_Id__c
|
from Repair__c
|
where Maintenance_Contract__c != null
|
/* CHAN-B7J5EK 2018/12/18 按照维修合同划分进行检索 start */
|
and Maintenance_Contract__c in: mcList
|
/* CHAN-B7J5EK 2018/12/18 按照维修合同划分进行检索 end */
|
and Status2__c !='00.删除'
|
and Status2__c !='00.取消'
|
and Repair_Quotation_Id__c=null
|
order by Maintenance_Contract__c];
|
if (noSapRepairList != null && noSapRepairList.size() > 0) {
|
for (Repair__c rc : noSapRepairList) {
|
Maintenance_Contract__c mc = new Maintenance_Contract__c();
|
if (updateMC.containsKey(rc.Maintenance_Contract__c)) {
|
mc = updateMC.get(rc.Maintenance_Contract__c);
|
} else {
|
mc.Id = rc.Maintenance_Contract__c;
|
mc.Sum_repair_price__c=0.0;
|
mc.Repair_Cost_Sum__c =0.0;
|
}
|
Date dTDate = rc.Failure_Occurrence_Date__c;
|
Date dSDate = rc.Maintenance_Contract__r.Contract_Start_Date__c;
|
Date dEDate = rc.Maintenance_Contract__r.Contract_End_Date__c;
|
|
if (dTDate >= dSDate && dTDate <= dEDate) {
|
mc.Sum_repair_price__c += rc.Repair_List_Price_formula__c == null ? 0 : rc.Repair_List_Price_formula__c;
|
mc.Repair_Cost_Sum__c += rc.Repair_cost__c == null ? 0 : rc.Repair_cost__c;
|
}
|
updateMC.put(rc.Maintenance_Contract__c, mc);
|
}
|
}
|
|
// LHJ 20190712 HWAG-BDH9V5 Start
|
|
List<Repair__c> newRepairList =
|
[select Id,Usage_Ratio_Price__c,
|
Repair_cost__c,
|
Maintenance_Contract__c,
|
Maintenance_Contract__r.Contract_Start_Date__c,
|
Maintenance_Contract__r.Contract_End_Date__c,
|
Failure_Occurrence_Date__c,
|
Repair_Quotation_Id__c,
|
EquipmentGuaranteeFlg_Asset__c,
|
if_Rental_Apply__c,
|
Offer_Rental_New__c,
|
Usage_Ratio_Price_Guarantee__c,
|
VM_Maintenance_Contract__c,
|
VM_Maintenance_Contract__r.RecordType_DeveloperName__c,
|
Maintenance_Contract__r.RecordType_DeveloperName__c,
|
VM_Maintenance_Contract__r.startDateGurantee__c,
|
VM_Maintenance_Contract__r.endDateGurantee__c
|
from Repair__c
|
where (Maintenance_Contract__c != null or VM_Maintenance_Contract__c != null)
|
and (Maintenance_Contract__c in: mcList or VM_Maintenance_Contract__c in: mcList)
|
and Status2__c !='00.删除'
|
and Status2__c !='00.取消'
|
order by Maintenance_Contract__c
|
];
|
|
if (newRepairList != null && newRepairList.size() > 0) {
|
|
for (Repair__c rc : newRepairList) {
|
if (rc.Maintenance_Contract__c != null) {
|
|
Maintenance_Contract__c mc = new Maintenance_Contract__c();
|
if (updateMC.containsKey(rc.Maintenance_Contract__c)) {
|
mc = updateMC.get(rc.Maintenance_Contract__c);
|
} else {
|
mc.Id = rc.Maintenance_Contract__c;
|
mc.Sum_repair_price_new__c=0.00;
|
}
|
Date dTDate = rc.Failure_Occurrence_Date__c;
|
Date dSDate = rc.Maintenance_Contract__r.Contract_Start_Date__c;
|
Date dEDate = rc.Maintenance_Contract__r.Contract_End_Date__c;
|
|
if (mc.Sum_repair_price_new__c == null) {
|
mc.Sum_repair_price_new__c = 0.00;
|
}
|
if (dTDate >= dSDate && dTDate <= dEDate) {
|
mc.Sum_repair_price_new__c += rc.Usage_Ratio_Price__c == null ? 0 : rc.Usage_Ratio_Price__c;
|
}
|
updateMC.put(rc.Maintenance_Contract__c, mc);
|
}
|
//20210106 zh LJPH-BWM5HM 多年保修【合同期间修理金额】逻辑修改 start
|
if (rc.VM_Maintenance_Contract__c != null) {
|
Maintenance_Contract__c mc = new Maintenance_Contract__c();
|
if (updateMC.containsKey(rc.VM_Maintenance_Contract__c)) {
|
mc = updateMC.get(rc.VM_Maintenance_Contract__c);
|
} else {
|
mc.Id = rc.VM_Maintenance_Contract__c;
|
mc.Sum_repair_price_new__c=0.00;
|
}
|
Date dTDate = rc.Failure_Occurrence_Date__c;
|
Date dSDate = rc.VM_Maintenance_Contract__r.startDateGurantee__c;
|
Date dEDate = rc.VM_Maintenance_Contract__r.endDateGurantee__c;
|
|
if (mc.Sum_repair_price_new__c == null) {
|
mc.Sum_repair_price_new__c = 0.00;
|
}
|
// gzw LJPH-BZDA84 多年保合同修理价格不根据开始结束日算 start
|
// if (dTDate >= dSDate && dTDate <= dEDate) {
|
//20210106 zh LJPH-BWM5HM 多年保修【合同期间修理金额】逻辑修改 start
|
// mc.Sum_repair_price_new__c += rc.Usage_Ratio_Price__c == null ? 0 : rc.Usage_Ratio_Price__c;
|
if ('VM_Contract'.equals(rc.VM_Maintenance_Contract__r.RecordType_DeveloperName__c)) {
|
mc.Sum_repair_price_new__c += rc.Usage_Ratio_Price_Guarantee__c == null ? 0 : rc.Usage_Ratio_Price_Guarantee__c;
|
}
|
//20210106 zh LJPH-BWM5HM 多年保修【合同期间修理金额】逻辑修改 end
|
// }
|
// // gzw LJPH-BZDA84 多年保合同修理价格不根据开始结束日算 end
|
updateMC.put(rc.VM_Maintenance_Contract__c, mc);
|
//20210106 zh LJPH-BWM5HM 多年保修【合同期间修理金额】逻辑修改 end
|
}
|
}
|
}
|
|
// LD 20200721 备品出借可视化管理 Start
|
|
|
//根据维修合同ID查询所有对应维修合同
|
List<Maintenance_Contract__c> conList = [SELECT Id,Name,
|
RentalRelatedCnt__c,
|
NoRentalRelatedCnt__c,
|
RentalRelatedRepairCnt__c,
|
RentalRelatedApplyCnt__c,
|
RentalRelatedSupplyCnt__c,
|
NoRentalRelatedRepairCnt__c,
|
NoRentalRelatedApplyCnt__c,
|
NoRentalRelatedSupplyCnt__c
|
FROM Maintenance_Contract__c
|
WHERE
|
Id IN :mcList];
|
|
//根据维修合同ID查询对应维修保有设备
|
List<Maintenance_Contract_Asset__c> assList =
|
[SELECT Id,
|
Asset__r.EGFlg_fromContract_asset__c
|
, Maintenance_Contract__c
|
FROM Maintenance_Contract_Asset__c
|
WHERE Maintenance_Contract__c = :mcList];
|
newRepairList = [
|
select id, EquipmentGuaranteeFlg_Asset__c,
|
if_Rental_Apply__c, Offer_Rental_New__c,Maintenance_Contract__c
|
from Repair__c
|
where Maintenance_Contract__c in: mcList
|
and Status2__c !='00.删除'
|
and Status2__c !='00.取消'
|
order by Maintenance_Contract__c
|
|
];
|
|
|
//维修合同
|
if (conList != null && conList.size() > 0) {
|
for (Maintenance_Contract__c con : conList) {
|
|
if(updateMc.containsKey(con.Id)){
|
con = updateMc.get(con.Id);
|
}
|
|
con.RentalRelatedCnt__c = 0;
|
con.NoRentalRelatedCnt__c = 0;
|
con.RentalRelatedRepairCnt__c = 0;
|
con.RentalRelatedApplyCnt__c = 0;
|
con.RentalRelatedSupplyCnt__c = 0;
|
con.NoRentalRelatedRepairCnt__c = 0;
|
con.NoRentalRelatedApplyCnt__c = 0;
|
con.NoRentalRelatedSupplyCnt__c = 0;
|
|
if (assList != null && assList.size() > 0) {
|
for (Maintenance_Contract_Asset__c ass : assList) {
|
System.debug(ass.Maintenance_Contract__c+'====ass.CurrentContract__c');
|
System.debug(con.Id+'====con.Id');
|
if(ass.Maintenance_Contract__c == con.Id){
|
if (ass.Asset__r.EGFlg_fromContract_asset__c == true) {
|
con.RentalRelatedCnt__c = con.RentalRelatedCnt__c + 1;
|
}else{
|
con.NoRentalRelatedCnt__c = con.NoRentalRelatedCnt__c + 1;
|
}
|
updateMC.put(con.Id,con);
|
}
|
}
|
}
|
|
if (newRepairList != null && newRepairList.size() > 0) {
|
for (Repair__c repc : newRepairList) {
|
if( con.Id == repc.Maintenance_Contract__c){
|
//备品确保提供选框为True
|
if(repc.EquipmentGuaranteeFlg_Asset__c == true){
|
con.RentalRelatedRepairCnt__c = con.RentalRelatedRepairCnt__c + 1;
|
//是否申请备品选框为True
|
if(repc.if_Rental_Apply__c == true){
|
con.RentalRelatedApplyCnt__c = con.RentalRelatedApplyCnt__c + 1;
|
}
|
//是否提供备品选框为True
|
if(repc.Offer_Rental_New__c == true){
|
con.RentalRelatedSupplyCnt__c = con.RentalRelatedSupplyCnt__c + 1;
|
}
|
}
|
//备品确保提供对象为False
|
if(repc.EquipmentGuaranteeFlg_Asset__c == false){
|
con.NoRentalRelatedRepairCnt__c = con.NoRentalRelatedRepairCnt__c + 1;
|
//是否申请备品选框为True
|
if(repc.if_Rental_Apply__c == true){
|
con.NoRentalRelatedApplyCnt__c = con.NoRentalRelatedApplyCnt__c + 1;
|
}
|
//是否提供备品选框为True
|
if(repc.Offer_Rental_New__c == true){
|
con.NoRentalRelatedSupplyCnt__c = con.NoRentalRelatedSupplyCnt__c + 1;
|
}
|
}
|
updateMC.put(con.Id,con);
|
}
|
}
|
}
|
}
|
}
|
|
// LD 20200721 备品出借可视化管理 End
|
if (updateMC.size() > 0) {
|
update updateMC.values();
|
}
|
} catch (Exception e) {
|
Database.rollback(sp);
|
emailMessages.add(e.getMessage());
|
System.debug(emailMessages);
|
failedCount += mcList.size();
|
System.debug(failedCount);
|
}
|
// LHJ 20190712 HWAG-BDH9V5 End
|
|
|
|
|
//for (SObject sobj : mcList) {
|
// Maintenance_Contract__c mc = new Maintenance_Contract__c(Id=String.valueOf(sobj.get('Maintenance_Contract__c')));
|
// initMC(mc);
|
// updateMC.put(mc.Id, mc);
|
// mcids.add(String.valueOf(sobj.get('Maintenance_Contract__c')));
|
//}
|
//筛选出需要更新的数据
|
//List<Maintenance_Contract__c> NeedUpdate = new List<Maintenance_Contract__c>();
|
// 修理 修理金额
|
// 要判断是否SAP
|
//已经SAP的循环汇总
|
//for (AggregateResult aggAst : [
|
// select SUM(Repair_List_Price_formula__c) sum_Price,
|
// SUM(Repair_cost__c) sum_PricePr,
|
// Maintenance_Contract__c,
|
// Maintenance_Contract__r.Contract_Start_Date__c,
|
// Maintenance_Contract__r.Contract_End_Date__c,
|
// Failure_Occurrence_Date__c,
|
// Repair_Quotation_Id__r.LatestQuotationDate__c,
|
// Repair_Quotation_Id__c
|
// from Repair__c
|
// where Maintenance_Contract__c != null
|
// and Status2__c !='00.删除'
|
// and Repair_Quotation_Id__c !=null
|
// and (CutPrice_Reason__c='维修合同' or CutPrice_Reason__c='套餐折扣,维修合同'or CutPrice_Reason__c='营业对应,维修合同')
|
// group by Maintenance_Contract__c,Maintenance_Contract__r.Contract_Start_Date__c,Maintenance_Contract__r.Contract_End_Date__c,
|
// Failure_Occurrence_Date__c,Repair_Quotation_Id__r.LatestQuotationDate__c,Repair_Quotation_Id__c
|
// ]) {
|
// Id mcid = (Id) aggAst.get('Maintenance_Contract__c');
|
// Maintenance_Contract__c mc = updateMC.get(mcid);
|
// Date dRDate = Date.valueOf(aggAst.get('LatestQuotationDate__c'));
|
// Date dTDate = Date.valueOf(aggAst.get('Failure_Occurrence_Date__c'));
|
// Date dSDate = Date.valueOf(aggAst.get('Contract_Start_Date__c'));
|
// Date dEDate = Date.valueOf(aggAst.get('Contract_End_Date__c'));
|
// id RqcID = (id) aggAst.get('Repair_Quotation_Id__c');
|
// if (dTDate >= dSDate && dTDate <= dEDate) {
|
|
// mc.Sum_repair_price__c += aggAst.get('sum_Price') == null ? 0 : Decimal.valueOf(String.valueOf(aggAst.get('sum_Price')));
|
// mc.Repair_Cost_Sum__c += aggAst.get('sum_PricePr') == null ? 0 : Decimal.valueOf(String.valueOf(aggAst.get('sum_PricePr')));
|
// }
|
// }
|
|
//没有SAP的循环汇总
|
//for (AggregateResult aggAst : [
|
// select SUM(Repair_List_Price_formula__c) sum_Price,
|
// SUM(Repair_cost__c) sum_PricePr,
|
// Maintenance_Contract__c,
|
// Maintenance_Contract__r.Contract_Start_Date__c,
|
// Maintenance_Contract__r.Contract_End_Date__c,
|
// Failure_Occurrence_Date__c,
|
// Repair_Quotation_Id__c
|
// from Repair__c
|
// where Maintenance_Contract__c != null
|
// and Status2__c !='00.删除'
|
// and Repair_Quotation_Id__c=null
|
// group by Maintenance_Contract__c,Maintenance_Contract__r.Contract_Start_Date__c,Maintenance_Contract__r.Contract_End_Date__c,
|
// Failure_Occurrence_Date__c,Repair_Quotation_Id__c
|
//]) {
|
// Id mcid = (Id) aggAst.get('Maintenance_Contract__c');
|
// Maintenance_Contract__c mc = updateMC.get(mcid);
|
// Date dTDate = Date.valueOf(aggAst.get('Failure_Occurrence_Date__c'));
|
// Date dSDate = Date.valueOf(aggAst.get('Contract_Start_Date__c'));
|
// Date dEDate = Date.valueOf(aggAst.get('Contract_End_Date__c'));
|
// id RqcID = (id) aggAst.get('Repair_Quotation_Id__c');
|
// if (dTDate >= dSDate && dTDate <= dEDate) {
|
|
// mc.Sum_repair_price__c += aggAst.get('sum_Price') == null ? 0 : Decimal.valueOf(String.valueOf(aggAst.get('sum_Price')));
|
// mc.Repair_Cost_Sum__c += aggAst.get('sum_PricePr') == null ? 0 : Decimal.valueOf(String.valueOf(aggAst.get('sum_PricePr')));
|
// }
|
//}
|
/******************************* HWAG-AV2C67 2018/1/17 END ******************************/
|
|
|
}
|
//and (CutPrice_Reason__c='维修合同' or CutPrice_Reason__c='维修合同，套餐折扣'or CutPrice_Reason__c='营业对应，维修合同')
|
|
// LHJ 20190712 HWAG-BDH9V5 Start
|
global void finish(Database.BatchableContext BC) {
|
// 今回はやることないです
|
sendFieldEmail();
|
}
|
|
private void sendFieldEmail() {
|
PretechBatchEmailUtil be = new PretechBatchEmailUtil();
|
String[] toList = new String[] {UserInfo.getUserEmail()};
|
String title = '维修合同更新失败';
|
String[] ccList = new String[] {};
|
if(System.Test.isRunningTest()){
|
be.successMail('', 1);
|
}
|
if (emailMessages.size() > 0) {
|
be.failedMail(toList, ccList, title,
|
String.join(this.emailMessages, '\n'),
|
totalCount, totalCount - failedCount, failedCount,'',false);
|
be.send();
|
}
|
}
|
// LHJ 20190712 HWAG-BDH9V5 End
|
/******************************* HWAG-AV2C67 2018/1/17 START ******************************/
|
// private void initMC(Maintenance_Contract__c mc) {
|
// mc.Sum_repair_price__c = 0.0;
|
// mc.Repair_Cost_Sum__c =0.0;
|
// }
|
|
// public class AggregateResultIterator implements Iterator<AggregateResult> {
|
// AggregateResult [] results {get;set;}
|
// // tracks which result item is returned
|
// Integer index {get; set;}
|
|
// public AggregateResultIterator() {
|
// index = 0;
|
// // Fire query here to load the results
|
// Date tdate = Date.today();
|
// Date before2day = tdate.addDays(-2);
|
// Date sdate = tdate.addDays(-30);
|
// Datetime before2dayTime = Datetime.newInstance(before2day, Time.newInstance(0, 0, 0, 0));
|
// results = [
|
// Select Maintenance_Contract__c
|
// From Repair__c
|
// Where Maintenance_Contract__c != null
|
|
// GROUP BY Maintenance_Contract__c
|
|
// ];
|
// }
|
|
// public boolean hasNext(){
|
// return results != null && !results.isEmpty() && index < results.size();
|
// }
|
|
// public AggregateResult next(){
|
// return results[index++];
|
// }
|
//}
|
|
//public class AggregateResultIterable implements Iterable<AggregateResult> {
|
// public Iterator<AggregateResult> Iterator(){
|
// return new AggregateResultIterator();
|
// }
|
//}
|
/******************************* HWAG-AV2C67 2018/1/17 END ******************************/
|
}
|
