| force-app/main/default/classes/EquipmentCoverageTargetBatch.cls | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
| force-app/main/default/classes/EquipmentRealCoverageRealBatch.cls | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
force-app/main/default/classes/EquipmentCoverageTargetBatch.cls
@@ -1,9 +1,18 @@ global class EquipmentCoverageTargetBatch implements Database.Batchable<sObject> { /************************************************************************************************** @Author: 黄千龙 @Name: EquipmentCoverageTargetBatch @CreateDate: 22/03/2022 @Description: 是否覆盖率目标（分母） @Version 1.0 *****************************************************************************************************/ 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(); public String OCSM_Period_half; public String OCSM_Period = 'FY'+toDayTime.year(); private BatchIF_Log__c iflog; global EquipmentCoverageTargetBatch() { this.query = query; @@ -12,13 +21,25 @@ iflog.Log__c = 'EquipmentRealCoverageBatch start\n'; iflog.ErrorLog__c = ''; insert iflog; if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { OCSM_Period_half = '1H'; }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'; // 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]; @@ -27,102 +48,85 @@ hospIds.add(String.valueOf(a1.get('Hospital__c'))); } } return Database.getQueryLocator(query); } global void execute(Database.BatchableContext BC, list<Account> Accounts) { List<Account_Service_Of_Target__c> asots = new List<Account_Service_Of_Target__c>(); global void execute(Database.BatchableContext BC, list<Asset> Assets) { // List<Account_Service_Of_Target__c> asots = 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 (Account acc1 : Accounts) { accIds.add(acc1.id); for (Asset ass1 : Assets) { accIds.add(ass1.Hospital__c); } List<Account_Service_Of_Target__c> asotList = [select Id,Account_HP__c,OCSM_Period_half__c from Account_Service_Of_Target__c where Account_HP__c in :accIds]; 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]; if (asotList != null) { for (Account_Service_Of_Target__c asot : asotList) { for (Id accid : accIds) { if (asot.Account_HP__c == accid) { asotMap.put(accid+asot.OCSM_Period_half__c,asot); asotMap.put(accid,asot); } } } } for (Account acc1 : Accounts) { Account_Service_Of_Target__c asot = new Account_Service_Of_Target__c(); List<Asset> AssetsTarget = new List<Asset>(); for (Asset ass1 : Assets) { // 覆盖目标（硬）：泌尿科用硬性镜 Integer mirror_1 = 0; // 覆盖目标（软）：鼻咽喉镜 Integer mirror_2 = 0; //覆盖目标（周边）：光源 Integer mirror_3 = 0; List<Asset> AssetsTarget = new List<Asset>(); for (Asset ass1 : acc1.Asset_Hospital__r) { // 标记是否覆盖率目标设备 ass1.IF_Coverage_Target_Asset__c = '1'; AssetsTarget.add(ass1); if (ass1.Product2.Category4__c == '泌尿科用硬性镜') { mirror_1++; } if(ass1.Product2.ServiceCategory__c =='软性镜'){ mirror_2++; } if (ass1.Product2.Category3__c == '光源') { mirror_3++; } // 标记是否覆盖率目标设备 ass1.IF_Coverage_Target_Asset__c = '1'; AssetsTarget.add(ass1); if (ass1.Product2.Category4__c == '泌尿科用硬性镜') { mirror_1++; } if (AssetsTarget!=null) { try { update AssetsTarget; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'update AssetsTarget:'+']'+e.getMessage()+'\n'; } } if (asotMap != null) { Account_Service_Of_Target__c asotOne = new Account_Service_Of_Target__c(); if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { asotOne = asotMap.get(acc1.id+'1H'); }else{ asotOne = asotMap.get(acc1.id+'2H'); } if (asotOne != null) { 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; asots.add(asotOne); } if(ass1.Product2.ServiceCategory__c =='软性镜'){ mirror_2++; } if (asotList.isEmpty()) { 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; }else{ Account_Service_Of_Target__c asot1 = new Account_Service_Of_Target__c(); asot1.Account_HP__c = acc1.id; 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; if (toDayTime.year()<=2029 && toDayTime.year()>=2023) { asot1.OCSM_Period__c = 'FY'+toDayTime.year(); if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { asot1.OCSM_Period_half__c = '1H'; }else{ asot1.OCSM_Period_half__c = '2H'; } } asots.add(asot1); asot1.OCSM_Period__c = OCSM_Period; asot1.OCSM_Period_half__c = OCSM_Period_half; asotMap.put(ass1.hospital__c,asot1); insert asot1; } } if (asots!=null) { try { UpSert asots; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'UpSert asots:'+']'+e.getMessage()+'\n'; } } 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'; } } } global void finish(Database.BatchableContext BC) { force-app/main/default/classes/EquipmentRealCoverageRealBatch.cls
@@ -1,9 +1,18 @@ global class EquipmentRealCoverageRealBatch implements Database.Batchable<sObject> { /************************************************************************************************** @Author: 黄千龙 @Name: EquipmentCoverageTargetBatch @CreateDate: 22/03/2022 @Description: 是否覆盖率实际（分子） @Version 1.0 *****************************************************************************************************/ global class EquipmentRealCoverageRealBatch implements Database.Batchable<sObject>,Database.Stateful { public String query; public Date start_dateH1 ; public Date end_dateH1 ; public Date toDayTime = Date.today(); private BatchIF_Log__c iflog; public String OCSM_Period_half; public String OCSM_Period = 'FY'+toDayTime.year(); global EquipmentRealCoverageRealBatch() { this.query = query; iflog = new BatchIF_Log__c(); @@ -11,34 +20,19 @@ iflog.Log__c = 'EquipmentRealCoverageBatch start\n'; iflog.ErrorLog__c = ''; insert iflog; if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { OCSM_Period_half = '1H'; }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 ' +' IF_Parts_production__c != \'1\' )' +' from Account'; return Database.getQueryLocator(query); } global void execute(Database.BatchableContext BC, list<Account> Accounts) { List<Account_Service_Of_Target__c> asots = 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 (Account acc1 : Accounts) { accIds.add(acc1.id); } List<Account_Service_Of_Target__c> asotList = [select Id,Account_HP__c,OCSM_Period_half__c from Account_Service_Of_Target__c where Account_HP__c in :accIds]; if (asotList != null) { for (Account_Service_Of_Target__c asot : asotList) { for (Id accid : accIds) { if (asot.Account_HP__c == accid) { asotMap.put(accid+asot.OCSM_Period_half__c,asot); } } } } // 实际设备合同时间区间1H(4,9);2H(10,3) 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); @@ -46,9 +40,34 @@ start_dateH1 = Date.newInstance(toDayTime.year(),3,1); end_dateH1 = Date.newInstance(toDayTime.year()+1,3,31); } for (Account acc1 : Accounts) { Account_Service_Of_Target__c asot = new Account_Service_Of_Target__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<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); } 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]; if (asotList != null) { for (Account_Service_Of_Target__c asot : asotList) { for (Id accid : accIds) { if (asot.Account_HP__c == accid) { asotMap.put(accid,asot); } } } } List<Asset> AssetsReal = new List<Asset>(); for (Asset ass1 : Assets) { // 实际覆盖数（硬）：泌尿科用硬性镜 Integer mirror_4 = 0; // 实际覆盖数（硬）：妇科用硬性镜 @@ -57,77 +76,51 @@ Integer mirror_6 = 0; // 实际覆盖数（软）：电子镜 Integer mirror_7 = 0; List<Asset> AssetsReal = new List<Asset>(); for (Asset ass1 : acc1.Asset_Hospital__r) { // 标记是否覆盖率实际设备 if (ass1.CurrentContract__r.Contract_End_Date__c >= start_dateH1 && ass1.CurrentContract__r.Contract_Conclusion_Date__c <= end_dateH1) { ass1.IF_Coverage_Real_Asset__c = '1'; AssetsReal.add(ass1); } // 标记是否覆盖率实际设备 ass1.IF_Coverage_Real_Asset__c = '1'; AssetsReal.add(ass1); if (ass1.Product2.Category4__c == '泌尿科用硬性镜') { mirror_4++; } if (AssetsReal!=null) { try { update AssetsReal; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'update AssetsReal:'+']'+e.getMessage()+'\n'; } if (ass1.Product2.Category4__c == '妇科用硬性镜') { mirror_5++; } for (Asset AtoHp: AssetsReal) { if (AtoHp.Product2.Category4__c == '泌尿科用硬性镜') { mirror_4++; } if (AtoHp.Product2.Category4__c == '妇科用硬性镜') { mirror_5++; } if (AtoHp.Product2.Category3__c == '光源') { mirror_6++; } if (AtoHp.Product2.ServiceCategory__c =='软性镜') { mirror_7++; } if (ass1.Product2.Category3__c == '光源') { mirror_6++; } if (asotMap != null) { 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(); if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { asotOne = asotMap.get(acc1.id+'1H'); }else{ asotOne = asotMap.get(acc1.id+'2H'); } if (asotOne != null) { 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; asots.add(asotOne); } } if (asotList.isEmpty()) { 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; }else{ Account_Service_Of_Target__c asot1 = new Account_Service_Of_Target__c(); asot1.Account_HP__c = acc1.id; 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; if (toDayTime.year()<=2029 && toDayTime.year()>=2023) { asot1.OCSM_Period__c = 'FY'+toDayTime.year(); if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { asot1.OCSM_Period_half__c = '1H'; }else{ asot1.OCSM_Period_half__c = '2H'; } } asots.add(asot1); } } if (asots!=null) { try { UpSert asots; asot1.OCSM_Period__c = OCSM_Period; asot1.OCSM_Period_half__c = OCSM_Period_half; asotMap.put(ass1.hospital__c,asot1); insert asot1; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'UpSert asots:'+']'+e.getMessage()+'\n'; } } } 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) {
