From d8dc84a3d56df839895f1c417a4d9cbee763d262 Mon Sep 17 00:00:00 2001
From: 高章伟 <gaozhangwei@prec-tech.com>
Date: 星期五, 03 三月 2023 14:50:59 +0800
Subject: [PATCH] gzw 测试环境代码更新

---
 force-app/main/default/classes/EquipmentCoverageTargetBatch.cls |  208 +++++++++++++++++++++++++++++-----------------------
 1 files changed, 116 insertions(+), 92 deletions(-)

diff --git a/force-app/main/default/classes/EquipmentCoverageTargetBatch.cls b/force-app/main/default/classes/EquipmentCoverageTargetBatch.cls
index 52f19e1..b8e8c16 100644
--- a/force-app/main/default/classes/EquipmentCoverageTargetBatch.cls
+++ b/force-app/main/default/classes/EquipmentCoverageTargetBatch.cls
@@ -12,10 +12,25 @@
     public List<Id> hospIds = new List<Id>();
     public Date toDayTime = Date.today();
     public String OCSM_Period_half;
-    public String OCSM_Period = 'FY'+toDayTime.year();
+    public String OCSM_Period;
     private BatchIF_Log__c iflog;
+    public List < String > accountIdList;
+    public Date egdTime;
+    public Date geTIme;
     global EquipmentCoverageTargetBatch() {
         this.query = query;
+        // OCSM_Period = 'FY'+(toDayTime.year()+1);
+    }
+
+    global EquipmentCoverageTargetBatch(List < String > accountIdList) {
+        this.query = query;
+        // OCSM_Period = 'FY'+(toDayTime.year()+1);
+        this.accountIdList = accountIdList;
+    }
+
+    global Database.QueryLocator start(Database.BatchableContext bc) {
+        
+        system.debug('鎵цstart');
         iflog = new BatchIF_Log__c();
         iflog.Type__c = 'PushNotification';
         iflog.Log__c  = 'EquipmentRealCoverageBatch start\n';
@@ -26,107 +41,116 @@
         }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')));
-           }
+        if(toDayTime.month() >= 1 && toDayTime.month() <= 3){
+            OCSM_Period = 'FY'+(toDayTime.year());
+        }else{
+            OCSM_Period = 'FY'+(toDayTime.year()+1);
         }
-        
+        // 5鏉′互涓婅蒋鎬ч暅鍖婚櫌&&鍖婚櫌鏈夋晥
+        egdTime = Date.newInstance(toDayTime.year()+1,3,31);
+        geTIme = Date.newInstance(3999,12,31);
+        String query = 'SELECT Id,Hospital__c,Hospital__r.name,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,OwnershipMachine_No__c,SerialNumber '
+                                            +' FROM Asset '
+                                            +' WHERE Product2.ServiceCategory__c != null '
+                                            +' AND OwnershipMachine_No__c!=\'A22004A\' AND OwnershipMachine_No__c!=\'A37026A\' AND OwnershipMachine_No__c!=\'A4676A\' AND OwnershipMachine_No__c!=\'WA02946A\''
+                                            +' AND Hospital__r.IF_Coverage_Target_HP__c = \'1\''
+                                            +' AND (Product2.Maintenance_Price_Year__c != 0  and Product2.Maintenance_Price_Year__c != null)'
+                                            +' AND (Status = \'浣跨敤涓璡' or Status = \'鏈娇鐢╘' or Status = \'涓嶆槑\')';
+        if (accountIdList != null && accountIdList.size() > 0) {
+            query += ' AND hospital__c IN :accountIdList ';
+        }                                  
+             query += ' AND (IF_StopParts_production__c != \'1\' or Product2.PartSupplyFinishDate__c = null)'
+                      +' AND (SerMarGuranteeType__c = null' 
+                      +' OR (SerMarGuranteeType__c!=null AND Guarantee_period_for_products__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>();
-        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) {
+    global void execute(Database.BatchableContext BC, list<Asset> assList) {
+        system.debug('鎵цexecute');
+        List<String> accIds = new List<String>();
+        Set<String> OlympusList = new Set<String>();
+        Integer i = 0;
+        for(Asset ass1:assList){
+            if (ass1.Hospital__r.name.contains('Olympus绀惧唴')) {
+              OlympusList.add(ass1.OwnershipMachine_No__c+ass1.SerialNumber);
+            }
             accIds.add(ass1.Hospital__c);
+        }  
+        List<Asset> assetList = new List<Asset>();
+        Set<String> accIdSet = new Set<String>();
+        List<Account_Service_Of_Target__c> targetObjs = new List<Account_Service_Of_Target__c>(); 
+        Map<String,Account_Service_Of_Target__c> targetMap = new Map<String,Account_Service_Of_Target__c>();
+        for(Account_Service_Of_Target__c target:[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 OCSM_Period_half__c = :OCSM_Period_half 
+                                                AND OCSM_Period__c = :OCSM_Period
+                                                AND Account_HP__c IN:accIds]){
+            targetMap.put(target.Account_HP__c,target);
         }
-        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);
-                    }
-                }
-            }
-        }
-            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 == '娉屽翱绉戠敤纭�ч暅') {
-                    mirror_1++;
-                }
-                if(ass1.Product2.ServiceCategory__c =='杞�ч暅'){
-                    mirror_2++;
-                }
-                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 = 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;
 
+        
+        // for(asset assOlympus:[select id,name,OwnershipMachine_No__c,SerialNumber 
+        //                         from asset 
+        //                         where Hospital__r.name like  '%Olympus绀惧唴%']){
+        //     // 鎶婂尰闄㈠悕涓篛lympus绀惧唴鐨勫瀷鍙峰拰鏈鸿韩缂栫爜鏀惧叆set鍚庣画鍋氬瓨鍦ㄥ垽鏂�
+            
+        // }
+        // Account_Service_Of_Target__c asot = null;
+        for(Asset ass:assList){
+            
+            if(!accIdSet.contains(ass.Hospital__c)){
+                if(!targetMap.containskey(ass.Hospital__c)){
+                    // Account_Service_Of_Target__c asot = targetMap.get(ass.Hospital__c);
+                    // asot.Target_Rigid_Mirror_2__c = 0;
+                    // asot.Target_Soft_Mirror_2__c = 0;
+                    // asot.Target_Correlation_Lightsource__c = 0;
+
+                // }else{
+                    Account_Service_Of_Target__c asot = new Account_Service_Of_Target__c();
+                    asot.Account_HP__c = ass.Hospital__c;
+                    asot.Coverage_Target_Account__c = true;
+                    asot.Target_Rigid_Mirror_2__c = 0;
+                    asot.Target_Soft_Mirror_2__c = 0;
+                    asot.Target_Correlation_Lightsource__c = 0;
+                    asot.OCSM_Period__c = OCSM_Period; 
+                    asot.OCSM_Period_half__c = OCSM_Period_half;
+                    targetMap.put(ass.Hospital__c,asot);
+                }
+                accIdSet.add(ass.Hospital__c);
+            }
+            ass.IF_Coverage_Target_Asset__c = '1';
+            // 鍨嬪彿+鏈鸿韩缂栫爜
+            String assTarget = ass.OwnershipMachine_No__c+ass.SerialNumber;
+            if(OlympusList.contains(assTarget)){
+                ass.IF_Coverage_Target_Asset__c = '0';
+            }
+            assetList.add(ass);
+            if (!OlympusList.contains(assTarget)){
+                if (ass.Product2.ServiceCategory__c == '纭�ч暅') {
+                    targetMap.get(ass.Hospital__c).Target_Rigid_Mirror_2__c ++;
+                }
+                if(ass.Product2.ServiceCategory__c =='杞�ч暅'){
+                    targetMap.get(ass.Hospital__c).Target_Soft_Mirror_2__c ++;
+                }
+                if (ass.Product2.ServiceCategory__c == '鍛ㄨ竟') {
+                    targetMap.get(ass.Hospital__c).Target_Correlation_Lightsource__c ++;
                 }
             }
-            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';
-                     }
+            i++;
         }
-                
+        system.debug('涓�鍏辨湁'+i+'涓澶�');
+
+        Oly_TriggerHandler.bypass('AssetTrigger');
+        Oly_TriggerHandler.bypass('AssetHandlerCheck');
+        system.debug('鎵цupdate AssetsTarget鍓�');
+        update assetList;  
+        system.debug('鎵цupdate accList鍓�'); 
+        Oly_TriggerHandler.bypass('NFM701ControllerHandler');
+        Oly_TriggerHandler.bypass('UpdateContractAimAmountHandler');
+        UpSert targetMap.values();
     }
 
     global void finish(Database.BatchableContext BC) {

--
Gitblit v1.9.1