| force-app/main/default/classes/EquipmentCoverageTargetBatch.cls | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| force-app/main/default/classes/EquipmentRealCoverageRealBatch.cls | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
force-app/main/default/classes/EquipmentCoverageTargetBatch.cls
@@ -2,19 +2,18 @@ @Author: 黄千龙 @Name: EquipmentCoverageTargetBatch @CreateDate: 22/03/2022 @Description: 是否覆盖率目标（分母） @Description: 是否覆盖率实际（分子） @Version 1.0 *****************************************************************************************************/ global class EquipmentCoverageTargetBatch implements Database.Batchable<sObject>,Database.Stateful { global class EquipmentRealCoverageRealBatch implements Database.Batchable<sObject>,Database.Stateful { public String query; public Date start_dateH1 ; public Date end_dateH1 ; public List<Id> hospIds = new List<Id>(); public Date toDayTime = Date.today(); private BatchIF_Log__c iflog; public String OCSM_Period_half; public String OCSM_Period = 'FY'+toDayTime.year(); private BatchIF_Log__c iflog; global EquipmentCoverageTargetBatch() { global EquipmentRealCoverageRealBatch() { this.query = query; iflog = new BatchIF_Log__c(); iflog.Type__c = 'PushNotification'; @@ -26,40 +25,34 @@ }else{ OCSM_Period_half = '2H'; } } global Database.QueryLocator start(Database.BatchableContext bc) { // query = 'select Id,(select id,IF_Coverage_Target_Asset__c,IF_Coverage_Real_Asset__c,CurrentContract__r.Contract_End_Date__c,CurrentContract__r.Contract_Conclusion_Date__c,Product2.Category4__c,Product2.ServiceCategory__c,Product2.Category3__c from Asset_Hospital__r where Status != \'廃棄\' and Status != \'待报废\'' // +' and IF_Parts_production__c != \'1\'' // +' and ((SerMarGuranteeType__c != \'服务多年保修\' and SerMarGuranteeType__c != \'市场多年保修\') or Extend_Gurantee_DateTo__c >= :egdTime)' // +' and Product2.ServiceCategory__c != null) from Account where id in :hospIds'; system.debug('执行start'); query = 'select Id,Hospital__c,IF_Coverage_Target_Asset__c,IF_Coverage_Real_Asset__c,CurrentContract__r.Contract_End_Date__c,CurrentContract__r.Contract_Conclusion_Date__c,Product2.Category4__c,Product2.ServiceCategory__c,Product2.Category3__c from Asset' +' where Hospital__c in :hospIds and Product2.ServiceCategory__c != null and Status != \'廃棄\' and Status != \'待报废\' and CurrentContract__c != null' +' and IF_Parts_production__c != \'1\' and SerMarGuranteeType__c = null and (Extend_Gurantee_DateTo__c = null or Extend_Gurantee_DateTo__c < :egdTime) order by hospital__c'; // 5条以上软性镜医院&&医院有效 Date egdTime = Date.newInstance(toDayTime.year()+1,3,1); List<AggregateResult> Asset1 = [select count(Id),Hospital__c from asset where Product2.ServiceCategory__c ='软性镜' Group by Hospital__c having count(Id)>=5]; if(Asset1!=null){ for (AggregateResult a1 : Asset1) { hospIds.add(String.valueOf(a1.get('Hospital__c'))); } } system.debug('执行start'); query = 'select id,Hospital__c,IF_Coverage_Target_Asset__c,IF_Coverage_Real_Asset__c,CurrentContract__r.Contract_End_Date__c,CurrentContract__r.Contract_Conclusion_Date__c,Product2.Category4__c,Product2.ServiceCategory__c,Product2.Category3__c from Asset where ' +' IF_Parts_production__c != \'1\' and CurrentContract__c != null' +' and (CurrentContract__r.Contract_End_Date__c >= :start_dateH1 and CurrentContract__r.Contract_Conclusion_Date__c <= :end_dateH1) order by hospital__c'; // 实际设备合同时间区间1H(4,9);2H(10,3) if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { start_dateH1 = Date.newInstance(toDayTime.year(),9,1); end_dateH1 = Date.newInstance(toDayTime.year(),9,30); }else{ start_dateH1 = Date.newInstance(toDayTime.year(),3,1); end_dateH1 = Date.newInstance(toDayTime.year()+1,3,31); } return Database.getQueryLocator(query); } global void execute(Database.BatchableContext BC, list<Asset> Assets) { // List<Account_Service_Of_Target__c> asots = new List<Account_Service_Of_Target__c>(); List<Account_Service_Of_Target__c> asots = new List<Account_Service_Of_Target__c>(); // List<Account_Service_Of_Target__c> asotsIN = new List<Account_Service_Of_Target__c>(); List<Id> accIds = new List<Id>(); Map<String,Account_Service_Of_Target__c> asotMap = new Map<String,Account_Service_Of_Target__c>(); for (Asset ass1 : Assets) { accIds.add(ass1.Hospital__c); for (Asset ass : Assets) { accIds.add(ass.Hospital__c); } List<Account_Service_Of_Target__c> asotList = [select Id,Target_Rigid_Mirror_2__c,Target_Soft_Mirror_2__c,Target_Correlation_Lightsource__c,Account_HP__c,OCSM_Period_half__c List<Account_Service_Of_Target__c> asotList = [select Id,Finish_Rigid_Mirror_2__c,Finish_Rigid_Mirror_3__c,Finish_Correlation_Lightsource__c,Finish_Rigid_Mirror_1__c,Account_HP__c,OCSM_Period_half__c from Account_Service_Of_Target__c where Account_HP__c in :accIds and OCSM_Period_half__c = :OCSM_Period_half and OCSM_Period__c = :OCSM_Period]; @@ -71,62 +64,69 @@ } } } } List<Asset> AssetsTarget = new List<Asset>(); } List<Asset> AssetsReal = new List<Asset>(); for (Asset ass1 : Assets) { // 覆盖目标（硬）：泌尿科用硬性镜 Integer mirror_1 = 0; // 覆盖目标（软）：鼻咽喉镜 Integer mirror_2 = 0; //覆盖目标（周边）：光源 Integer mirror_3 = 0; // 标记是否覆盖率目标设备 ass1.IF_Coverage_Target_Asset__c = '1'; AssetsTarget.add(ass1); // 实际覆盖数（硬）：泌尿科用硬性镜 Integer mirror_4 = 0; // 实际覆盖数（硬）：妇科用硬性镜 Integer mirror_5 = 0; // 实际覆盖数（周边）：光源 Integer mirror_6 = 0; // 实际覆盖数（软）：电子镜 Integer mirror_7 = 0; // 标记是否覆盖率实际设备 ass1.IF_Coverage_Real_Asset__c = '1'; AssetsReal.add(ass1); if (ass1.Product2.Category4__c == '泌尿科用硬性镜') { mirror_1++; mirror_4++; } if(ass1.Product2.ServiceCategory__c =='软性镜'){ mirror_2++; if (ass1.Product2.Category4__c == '妇科用硬性镜') { mirror_5++; } if (ass1.Product2.Category3__c == '光源') { mirror_3++; } if (asotMap.containsKey(ass1.Hospital__c)) { Account_Service_Of_Target__c asotOne = asotMap.get(ass1.Hospital__c); system.debug('asotOne=='+ asotOne); asotOne.Coverage_Target_Account__c = true; asotOne.Target_Rigid_Mirror_2__c += mirror_1; asotOne.Target_Soft_Mirror_2__c += mirror_2; asotOne.Target_Correlation_Lightsource__c += mirror_3; update asotOne; mirror_6++; } if (ass1.Product2.ServiceCategory__c =='软性镜') { mirror_7++; } if (asotMap.containsKey(ass1.hospital__c)) { Account_Service_Of_Target__c asotOne = new Account_Service_Of_Target__c(); asotOne = asotMap.get(ass1.hospital__c); asotOne.Finish_Rigid_Mirror_2__c += mirror_4; asotOne.Finish_Rigid_Mirror_3__c += mirror_5; asotOne.Finish_Correlation_Lightsource__c += mirror_6; asotOne.Finish_Rigid_Mirror_1__c += mirror_7; if (!asots.contains(asotOne)) { asots.add(asotOne); } }else{ Account_Service_Of_Target__c asot1 = new Account_Service_Of_Target__c(); asot1.Account_HP__c = ass1.Hospital__c; asot1.Coverage_Target_Account__c = true; asot1.Target_Rigid_Mirror_2__c = mirror_1; asot1.Target_Soft_Mirror_2__c = mirror_2; asot1.Target_Correlation_Lightsource__c = mirror_3; asot1.OCSM_Period__c = OCSM_Period; asot1.OCSM_Period_half__c = OCSM_Period_half; asot1.Account_HP__c = ass1.hospital__c; asot1.Finish_Rigid_Mirror_2__c = mirror_4; asot1.Finish_Rigid_Mirror_3__c = mirror_5; asot1.Finish_Correlation_Lightsource__c = mirror_6; asot1.Finish_Rigid_Mirror_1__c = mirror_7; asot1.OCSM_Period__c = OCSM_Period; asot1.OCSM_Period_half__c = OCSM_Period_half; asotMap.put(ass1.hospital__c,asot1); insert asot1; if (!asots.contains(asot1)) { asots.add(asot1); } } } system.debug('map=='+asotMap); if (AssetsTarget!=null) { try { system.debug('执行update'); Oly_TriggerHandler.bypass('AssetTrigger'); update AssetsTarget; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'update AssetsTarget:'+']'+e.getMessage()+'\n'; } } upsert asots; system.debug('这个集合：AssetsReal ==='+AssetsReal); if (AssetsReal!=null) { try { update AssetsReal; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'update AssetsReal:'+']'+e.getMessage()+'\n'; } } } global void finish(Database.BatchableContext BC) { force-app/main/default/classes/EquipmentRealCoverageRealBatch.cls
@@ -2,18 +2,19 @@ @Author: 黄千龙 @Name: EquipmentCoverageTargetBatch @CreateDate: 22/03/2022 @Description: 是否覆盖率实际（分子） @Description: 是否覆盖率目标（分母） @Version 1.0 *****************************************************************************************************/ global class EquipmentRealCoverageRealBatch implements Database.Batchable<sObject>,Database.Stateful { global class EquipmentCoverageTargetBatch implements Database.Batchable<sObject>,Database.Stateful { public String query; public Date start_dateH1 ; public Date end_dateH1 ; public List<Id> hospIds = new List<Id>(); public Date toDayTime = Date.today(); private BatchIF_Log__c iflog; public String OCSM_Period_half; public String OCSM_Period = 'FY'+toDayTime.year(); global EquipmentRealCoverageRealBatch() { private BatchIF_Log__c iflog; global EquipmentCoverageTargetBatch() { this.query = query; iflog = new BatchIF_Log__c(); iflog.Type__c = 'PushNotification'; @@ -25,33 +26,42 @@ }else{ OCSM_Period_half = '2H'; } } global Database.QueryLocator start(Database.BatchableContext bc) { system.debug('执行start'); query = 'select id,Hospital__c,IF_Coverage_Target_Asset__c,IF_Coverage_Real_Asset__c,CurrentContract__r.Contract_End_Date__c,CurrentContract__r.Contract_Conclusion_Date__c,Product2.Category4__c,Product2.ServiceCategory__c,Product2.Category3__c from Asset where ' +' IF_Parts_production__c != \'1\' and CurrentContract__c != null' +' and (CurrentContract__r.Contract_End_Date__c >= :start_dateH1 and CurrentContract__r.Contract_Conclusion_Date__c <= :end_dateH1) order by hospital__c'; // 实际设备合同时间区间1H(4,9);2H(10,3) if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { start_dateH1 = Date.newInstance(toDayTime.year(),9,1); end_dateH1 = Date.newInstance(toDayTime.year(),9,30); }else{ start_dateH1 = Date.newInstance(toDayTime.year(),3,1); end_dateH1 = Date.newInstance(toDayTime.year()+1,3,31); } // query = 'select Id,(select id,IF_Coverage_Target_Asset__c,IF_Coverage_Real_Asset__c,CurrentContract__r.Contract_End_Date__c,CurrentContract__r.Contract_Conclusion_Date__c,Product2.Category4__c,Product2.ServiceCategory__c,Product2.Category3__c from Asset_Hospital__r where Status != \'廃棄\' and Status != \'待报废\'' // +' and IF_Parts_production__c != \'1\'' // +' and ((SerMarGuranteeType__c != \'服务多年保修\' and SerMarGuranteeType__c != \'市场多年保修\') or Extend_Gurantee_DateTo__c >= :egdTime)' // +' and Product2.ServiceCategory__c != null) from Account where id in :hospIds'; system.debug('执行start'); query = 'select Id,Hospital__c,IF_Coverage_Target_Asset__c,IF_Coverage_Real_Asset__c,CurrentContract__r.Contract_End_Date__c,CurrentContract__r.Contract_Conclusion_Date__c,Product2.Category4__c,Product2.ServiceCategory__c,Product2.Category3__c from Asset' +' where Hospital__c in :hospIds and Product2.ServiceCategory__c != null and Status != \'廃棄\' and Status != \'待报废\' and CurrentContract__c != null' +' and IF_Parts_production__c != \'1\' and SerMarGuranteeType__c = null and (Extend_Gurantee_DateTo__c = null or Extend_Gurantee_DateTo__c < :egdTime) order by hospital__c'; // 5条以上软性镜医院&&医院有效 Date egdTime = Date.newInstance(toDayTime.year()+1,3,1); List<AggregateResult> Asset1 = [select count(Id),Hospital__c from asset where Product2.ServiceCategory__c ='软性镜' Group by Hospital__c having count(Id)>=5]; if(Asset1!=null){ for (AggregateResult a1 : Asset1) { hospIds.add(String.valueOf(a1.get('Hospital__c'))); } } return Database.getQueryLocator(query); } global void execute(Database.BatchableContext BC, list<Asset> Assets) { // List<Account_Service_Of_Target__c> asots = new List<Account_Service_Of_Target__c>(); List<Account_Service_Of_Target__c> asots = new List<Account_Service_Of_Target__c>(); // List<Account_Service_Of_Target__c> asotsIN = new List<Account_Service_Of_Target__c>(); List<Id> accIds = new List<Id>(); Map<String,Account_Service_Of_Target__c> asotMap = new Map<String,Account_Service_Of_Target__c>(); for (Asset ass : Assets) { accIds.add(ass.Hospital__c); for (Asset ass1 : Assets) { accIds.add(ass1.Hospital__c); } List<Account_Service_Of_Target__c> asotList = [select Id,Finish_Rigid_Mirror_2__c,Finish_Rigid_Mirror_3__c,Finish_Correlation_Lightsource__c,Finish_Rigid_Mirror_1__c,Account_HP__c,OCSM_Period_half__c List<Account_Service_Of_Target__c> asotList = [select Id,Target_Rigid_Mirror_2__c,Target_Soft_Mirror_2__c,Target_Correlation_Lightsource__c,Account_HP__c,OCSM_Period_half__c from Account_Service_Of_Target__c where Account_HP__c in :accIds and OCSM_Period_half__c = :OCSM_Period_half and OCSM_Period__c = :OCSM_Period]; @@ -63,64 +73,65 @@ } } } } List<Asset> AssetsReal = new List<Asset>(); } List<Asset> AssetsTarget = new List<Asset>(); for (Asset ass1 : Assets) { // 实际覆盖数（硬）：泌尿科用硬性镜 Integer mirror_4 = 0; // 实际覆盖数（硬）：妇科用硬性镜 Integer mirror_5 = 0; // 实际覆盖数（周边）：光源 Integer mirror_6 = 0; // 实际覆盖数（软）：电子镜 Integer mirror_7 = 0; // 标记是否覆盖率实际设备 ass1.IF_Coverage_Real_Asset__c = '1'; AssetsReal.add(ass1); // 覆盖目标（硬）：泌尿科用硬性镜 Integer mirror_1 = 0; // 覆盖目标（软）：鼻咽喉镜 Integer mirror_2 = 0; //覆盖目标（周边）：光源 Integer mirror_3 = 0; // 标记是否覆盖率目标设备 ass1.IF_Coverage_Target_Asset__c = '1'; AssetsTarget.add(ass1); if (ass1.Product2.Category4__c == '泌尿科用硬性镜') { mirror_4++; mirror_1++; } if (ass1.Product2.Category4__c == '妇科用硬性镜') { mirror_5++; if(ass1.Product2.ServiceCategory__c =='软性镜'){ mirror_2++; } if (ass1.Product2.Category3__c == '光源') { mirror_6++; } if (ass1.Product2.ServiceCategory__c =='软性镜') { mirror_7++; } if (asotMap.containsKey(ass1.hospital__c)) { Account_Service_Of_Target__c asotOne = new Account_Service_Of_Target__c(); asotOne = asotMap.get(ass1.hospital__c); asotOne.Finish_Rigid_Mirror_2__c += mirror_4; asotOne.Finish_Rigid_Mirror_3__c += mirror_5; asotOne.Finish_Correlation_Lightsource__c += mirror_6; asotOne.Finish_Rigid_Mirror_1__c += mirror_7; update asotOne; mirror_3++; } if (asotMap.containsKey(ass1.Hospital__c)) { Account_Service_Of_Target__c asotOne = asotMap.get(ass1.Hospital__c); system.debug('asotOne=='+ asotOne); asotOne.Coverage_Target_Account__c = true; asotOne.Target_Rigid_Mirror_2__c += mirror_1; asotOne.Target_Soft_Mirror_2__c += mirror_2; asotOne.Target_Correlation_Lightsource__c += mirror_3; if (!asots.contains(asotOne)) { asots.add(asotOne); } }else{ Account_Service_Of_Target__c asot1 = new Account_Service_Of_Target__c(); asot1.Account_HP__c = ass1.hospital__c; asot1.Finish_Rigid_Mirror_2__c = mirror_4; asot1.Finish_Rigid_Mirror_3__c = mirror_5; asot1.Finish_Correlation_Lightsource__c = mirror_6; asot1.Finish_Rigid_Mirror_1__c = mirror_7; asot1.OCSM_Period__c = OCSM_Period; asot1.OCSM_Period_half__c = OCSM_Period_half; asot1.Account_HP__c = ass1.Hospital__c; asot1.Coverage_Target_Account__c = true; asot1.Target_Rigid_Mirror_2__c = mirror_1; asot1.Target_Soft_Mirror_2__c = mirror_2; asot1.Target_Correlation_Lightsource__c = mirror_3; asot1.OCSM_Period__c = OCSM_Period; asot1.OCSM_Period_half__c = OCSM_Period_half; asotMap.put(ass1.hospital__c,asot1); insert asot1; if (!asots.contains(asot1)) { asots.add(asot1); } } } system.debug('这个集合：AssetsReal ==='+AssetsReal); if (AssetsReal!=null) { try { update AssetsReal; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'update AssetsReal:'+']'+e.getMessage()+'\n'; } } UpSert asots; if (AssetsTarget!=null) { try { system.debug('执行update'); Oly_TriggerHandler.bypass('AssetTrigger'); update AssetsTarget; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'update AssetsTarget:'+']'+e.getMessage()+'\n'; } } } global void finish(Database.BatchableContext BC) {
