global class EquipmentRealCoverageBatch implements Database.Batchable,Database.Stateful { public String query; public Date start_dateH1 ; public Date end_dateH1 ; public List conIds = new List(); public List hospIds = new List(); public Date toDayTime = Date.today(); // public String type ; private BatchIF_Log__c iflog; global EquipmentRealCoverageBatch() { // if (i == 1) { // this.query = 'select Id,(select Id,IF_Coverage_Real_Asset__c from Asset_Hospital__r where CurrentContract__c In :conIds) from Account'; // type = '分子'; // } // if (i == 2) { this.query = 'select Id,(select id,IF_Coverage_Target_Asset__c,IF_Coverage_Real_Asset__c,CurrentContract__r.Contract_End_Date__c,Product2.Category4__c,Product2.ServiceCategory__c,Product2.Category3__c from Asset_Hospital__r where Status != \'廃棄\' and Status != \'待报废\'' +' and SerMarGuranteeType__c != \'服务多年保修\' and SerMarGuranteeType__c != \'市场多年保修\'' +' and Product2.ServiceCategory__c != null) from Account where id in :hospIds'; // type = '分母'; // } iflog = new BatchIF_Log__c(); iflog.Type__c = 'PushNotification'; iflog.Log__c = 'EquipmentRealCoverageBatch start\n'; iflog.ErrorLog__c = ''; insert iflog; } global Database.QueryLocator start(Database.BatchableContext bc) { // if (type == '分子') { // List conList = new List(); // // 判断为1H还是为2H // if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { // start_dateH1 = Date.newInstance(toDayTime.year(),4,1); // end_dateH1 = Date.newInstance(toDayTime.year(),9,30); // }else{ // start_dateH1 = Date.newInstance(toDayTime.year(),10,1); // end_dateH1 = Date.newInstance(toDayTime.year()+1,3,31); // } // List conList1 = [select Id,Name,Contract_Start_Date__c,Contract_End_Date__c from Maintenance_Contract__c where Contract_Start_Date__c >= :start_dateH1 and Contract_End_Date__c <= :end_dateH1]; // conList.addAll(conList1); // if(conList!=null){ // for (Maintenance_Contract__c con : conList) { // conIds.add(con.id); // } // } // } // if (type == '分母') { // 5条以上软性镜医院&&医院有效 List 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 accList) { List asotList = new List(); // if (type == '分子') { // for (Account a : accList) { // for (Asset as1 : a.Asset_Hospital__r) { // // 标记是否覆盖率实际设备 // as1.IF_Coverage_Real_Asset__c = '1'; // AssetsNew.add(as1); // } // } // } // if (type == '分母') { // 实际设备合同时间区间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); } for (Account acc1 : accList) { Account_Service_Of_Target__c asot = new Account_Service_Of_Target__c(); // 覆盖目标(硬):泌尿科用硬性镜 Integer mirror_1 = 0; // 覆盖目标(软):鼻咽喉镜 Integer mirror_2 = 0; //覆盖目标(周边):光源 Integer mirror_3 = 0; // 实际覆盖数(硬):泌尿科用硬性镜 Integer mirror_4 = 0; // 实际覆盖数(硬):妇科用硬性镜 Integer mirror_5 = 0; // 实际覆盖数(周边):光源 Integer mirror_6 = 0; // 实际覆盖数(软):电子镜 Integer mirror_7 = 0; List AssetsTarget = new List(); List AssetsReal = new List(); for (Asset ass1 : acc1.Asset_Hospital__r) { // 标记是否覆盖率目标设备 ass1.IF_Coverage_Target_Asset__c = '1'; AssetsTarget.add(ass1); // 标记是否覆盖率实际设备 if (ass1.CurrentContract__r.Contract_End_Date__c >= start_dateH1 && ass1.CurrentContract__r.Contract_End_Date__c <= end_dateH1) { ass1.IF_Coverage_Real_Asset__c = '1'; AssetsReal.add(ass1); } if (ass1.Product2.Category4__c == '泌尿科用硬性镜') { mirror_1++; } if(ass1.Product2.ServiceCategory__c =='软性镜'){ mirror_2++; } if (ass1.Product2.Category3__c == '光源') { mirror_3++; } if (AssetsTarget!=null) { try { update AssetsTarget; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'update AssetsTarget:'+']'+e.getMessage()+'\n'; } } if (AssetsReal!=null) { try { update AssetsReal; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'update AssetsReal:'+']'+e.getMessage()+'\n'; } } } // List assList = [select id,Product2.Category4__c,Product2.ServiceCategory__c,Product2.Category3__c from Asset // where IF_Coverage_Real_Asset__c = '1' and Hospital__c = :acc1.id]; 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++; } } asot.Account_HP__c = acc1.id; asot.Coverage_Target_Account__c = true; asot.Target_Rigid_Mirror_2__c = mirror_1; asot.Target_Soft_Mirror_2__c = mirror_2; asot.Target_Correlation_Lightsource__c = mirror_3; asot.Finish_Rigid_Mirror_2__c = mirror_4; asot.Finish_Rigid_Mirror_3__c = mirror_5; asot.Finish_Correlation_Lightsource__c = mirror_6; asot.Finish_Rigid_Mirror_1__c = mirror_7; if (toDayTime.year()<=2029 && toDayTime.year()>=2023) { asot.OCSM_Period__c = 'FY'+toDayTime.year(); if (toDayTime.month() >= 4 && toDayTime.month() <= 9) { asot.OCSM_Period_half__c = '1H'; }else{ asot.OCSM_Period_half__c = '2H'; } } asotList.add(asot); } if (asotList!=null) { try { insert asotList; } catch (Exception e) { iflog.ErrorLog__c += 'ERROR'+'['+'insert asotList:'+']'+e.getMessage()+'\n'; } } } global void finish(Database.BatchableContext BC) { iflog.Log__c += '\nEquipmentRealCoverageBatch end'; String tmp = iflog.ErrorLog__c; if (tmp.length() > 65000) { tmp = tmp.substring(0, 65000); tmp += ' ...have more lines...'; iflog.ErrorLog__c = tmp; } update iflog; } }