From cbab3d8795d1e0589e37261d978eac22cc904318 Mon Sep 17 00:00:00 2001 From: 黄千龙 <huangqianlong@prec-tech.com> Date: 星期二, 29 三月 2022 13:38:57 +0800 Subject: [PATCH] 20220329KPI黄千龙提交 --- force-app/main/default/classes/EquipmentCoverageTargetBatch.cls | 91 ++++++++++++++++++++++++++------------------- 1 files changed, 53 insertions(+), 38 deletions(-) diff --git a/force-app/main/default/classes/EquipmentCoverageTargetBatch.cls b/force-app/main/default/classes/EquipmentCoverageTargetBatch.cls index 52f19e1..1e0b322 100644 --- a/force-app/main/default/classes/EquipmentCoverageTargetBatch.cls +++ b/force-app/main/default/classes/EquipmentCoverageTargetBatch.cls @@ -14,8 +14,22 @@ public String OCSM_Period_half; public String OCSM_Period = 'FY'+toDayTime.year(); private BatchIF_Log__c iflog; + public List < String > accountIdList; global EquipmentCoverageTargetBatch() { this.query = query; + } + + global EquipmentCoverageTargetBatch(List < String > accountIdList) { + this.query = query; + this.accountIdList = accountIdList; + } + + 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'); iflog = new BatchIF_Log__c(); iflog.Type__c = 'PushNotification'; iflog.Log__c = 'EquipmentRealCoverageBatch start\n'; @@ -26,38 +40,40 @@ }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){ + List<AggregateResult> Asset1 = new List<AggregateResult>(); + if (accountIdList != null && accountIdList.size() > 0) { + Asset1 = [select count(Id),Hospital__c from asset where Hospital__c IN :accountIdList and Product2.ServiceCategory__c ='杞�ч暅' Group by Hospital__c having count(Id)>=5]; + }else{ + Asset1 = [select count(Id),Hospital__c from asset where Product2.ServiceCategory__c ='杞�ч暅' Group by Hospital__c having count(Id)>=5]; + } + + if(Asset1!=null && Asset1.size() > 0){ for (AggregateResult a1 : Asset1) { hospIds.add(String.valueOf(a1.get('Hospital__c'))); } } - + query = 'select Id,Hospital__c,Hospital__r.IF_Coverage_Target_HP__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 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'; 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>(); + system.debug('鎵цexecute'); + 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); + } + List<Account> accList = [select id from Account where id in :accIds]; + for (Account acc : accList) { + // 鏍囪鏄惁瑕嗙洊鐜囩洰鏍囧尰闄� + acc.IF_Coverage_Target_HP__c = '1'; } 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 @@ -74,23 +90,23 @@ } List<Asset> AssetsTarget = 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); - if (ass1.Product2.Category4__c == '娉屽翱绉戠敤纭�ч暅') { + if (ass1.Product2.ServiceCategory__c == '纭�ч暅') { mirror_1++; } if(ass1.Product2.ServiceCategory__c =='杞�ч暅'){ mirror_2++; } - if (ass1.Product2.Category3__c == '鍏夋簮') { + if (ass1.Product2.ServiceCategory__c == '鍛ㄨ竟') { mirror_3++; } if (asotMap.containsKey(ass1.Hospital__c)) { @@ -100,7 +116,9 @@ 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; + 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; @@ -111,22 +129,19 @@ 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; + Oly_TriggerHandler.bypass('AssetTrigger'); + system.debug('鎵цupdate AssetsTarget鍓�'); + update AssetsTarget; + system.debug('鎵цupdate accList鍓�'); + Oly_TriggerHandler.bypass('AccountTrigger'); + update accList; + } global void finish(Database.BatchableContext BC) { -- Gitblit v1.9.1