global class SpareIsLoanBatch implements Database.Batchable<sObject> {
	//----SWAG-B624XU-----XHL--------20181101-------------------
	//该Batch 运行后会 修改 Opportunity(询价) 和 Rental_Apply__c(备品借出申请)
	
	List<String> oppIdListBatch;

	Boolean IsNeedExecute = false; // 2021-06-07  mzy  WLIG-BYHD79  SFDC环境batch合并调查  是否符合执行条件

	//默认执行为无参
	global SpareIsLoanBatch() {
		
	}
	// 备品借出申请Rental_Apply__c 中 Follow_UP_Opp__c 询价ID
	global SpareIsLoanBatch(List<String> oppIdList) {
		this.oppIdListBatch = oppIdList;
	}
  
	//2021-06-07 mzy   WLIG-BYHD79  SFDC环境batch合并调查   start
	global SpareIsLoanBatch(Boolean needExecute) {
		this.IsNeedExecute = needExecute; 
	}
	// 2021-06-07  mzy  WLIG-BYHD79  SFDC环境batch合并调查   end

	global Database.QueryLocator start(Database.BatchableContext BC) {
		if (oppIdListBatch == null || oppIdListBatch.size() == 0 ) {
			// 查询 跟进询价1 不为 空的 备品借出申请
			return  Database.getQueryLocator(
				[SELECT Id,Follow_UP_Opp__c,Follow_UP_Opp__r.Spare_Application_Singular__c,Follow_UP_Opp__r.Estimation_Decision__c,Follow_UP_Opp__r.EffectiveRentalApply__c   
			FROM Rental_Apply__c WHERE Follow_UP_Opp__c != null ]);
		} else {
			return  Database.getQueryLocator(
				[SELECT Id,Follow_UP_Opp__c,Follow_UP_Opp__r.Spare_Application_Singular__c,Follow_UP_Opp__r.EffectiveRentalApply__c,Follow_UP_Opp__r.Estimation_Decision__c   
			FROM Rental_Apply__c WHERE Follow_UP_Opp__c In :oppIdListBatch ]);
		}
			
	}

   	global void execute(Database.BatchableContext BC, List<Rental_Apply__c> raList) {

		//询价所用
		Map<String,Decimal>  countMap = new Map<String,Decimal>(); 
		Map<String,Integer>  resultsMap = new Map<String,Integer>();
		List<String> rA_statusList = new List<String>();
		Map<String,Opportunity> updateOpportunityMap = new Map<String,Opportunity>();
		Map<String,Decimal> selectQuantityMap = new Map<String,Decimal>();
		//备品借出申请所用
		List<Rental_Apply__c> racList = new List<Rental_Apply__c>();
		Map<String,Decimal>  racCountMap = new Map<String,Decimal>();
		Map<String,Integer>  racResultsMap = new Map<String,Integer>();

		rA_statusList.add('已出库');rA_statusList.add('医院已装机确认');rA_statusList.add('已回寄');
		rA_statusList.add('欠品中');rA_statusList.add('申请者已收货');rA_statusList.add('已回收');
		rA_statusList.add('完了');
		//A集合 跟进询价1 不为 空的 备品借出申请
		for(Rental_Apply__c ra: raList){
			String oppId = ra.Follow_UP_Opp__c;
			Decimal singular = ra.Follow_UP_Opp__r.Spare_Application_Singular__c;
			Decimal effectiveRentalApply = ra.Follow_UP_Opp__r.EffectiveRentalApply__c;
			countMap.put(oppId,singular);
			selectQuantityMap.put(oppId,effectiveRentalApply);
		}
		//B集合 使用目的2 不是 已购待货 并且 状态是 出库及以后状态的 备品借出申请
		AggregateResult[]  results = [select Follow_UP_Opp__c,count(Id) cnt
		 		from Rental_Apply__c
				where Follow_UP_Opp__c In :countMap.keySet() AND RA_Status__c In :rA_statusList AND demo_purpose2__c != '已购待货'  group by Follow_UP_Opp__c];
		// SWAG-BVA5V8	XHL 2020-12-14 Add AND demo_purpose2__c != '已购待货'
		for(AggregateResult ar :results){
			resultsMap.put(String.valueOf(ar.get('Follow_UP_Opp__c')), Integer.valueOf(ar.get('cnt')));
		}
		Opportunity  opp = null;
		//B集合是A集合的子集
		for (String ids :countMap.keySet()) {
			
			if (resultsMap.containsKey(ids)) {
				// A 集合的值 在B集合中
				// 询价 找到符合要求的备品借出申请
				if (countMap.get(ids) == null) {
					// 询价 备品申请单数 的值 为空
					opp = new Opportunity();
					opp.Spare_Application_Singular__c = resultsMap.get(ids);
					opp.Id = ids;
					updateOpportunityMap.put(ids,opp);
				} else if(countMap.get(ids) != resultsMap.get(ids)) {
					// 询价 备品申请单数 有值，但是新值不等于旧值 
					opp = new Opportunity();
					opp.Spare_Application_Singular__c = resultsMap.get(ids);
					opp.Id = ids;
					updateOpportunityMap.put(ids,opp);
				}

			} else {
				// A 集合的值 不在B集合中 
				// 询价 没有找到符合要求的备品借出申请
				if (countMap.get(ids) == null) {
					// 询价 备品申请单数 的值 为空 置零
					opp = new Opportunity();
					opp.Spare_Application_Singular__c = 0;
					opp.Id = ids;
					updateOpportunityMap.put(ids,opp);
				} else if (countMap.get(ids)>0) {
					// 询价 备品申请单数 的值 不为为空 置零
					opp = new Opportunity();
					opp.Id = ids;
					opp.Spare_Application_Singular__c = 0;
					updateOpportunityMap.put(ids,opp);
				}
				
			}
			
		}

		if (selectQuantityMap != null && selectQuantityMap.size() > 0) {

			// 查找 借出备品配套一览 获取 备品配套明细型号	
			List<Rental_Apply_Equipment_Set__c> getRAESList = [SELECT Id,Name,Rental_Apply__c,First_RAESD_Model_No_F__c,Rental_Apply__r.Follow_UP_Opp__c,Rental_Apply__r.Demo_purpose1__c,Rental_Apply__r.demo_purpose2__c,Bollow_Date__c FROM  Rental_Apply_Equipment_Set__c WHERE Rental_Apply__r.Demo_purpose1__c = '产品试用' AND (Rental_Apply__r.demo_purpose2__c = '试用（有询价）' OR Rental_Apply__r.demo_purpose2__c = '试用（无询价）') AND Rental_Apply__r.Bollow_Date__c != null AND Rental_Apply__r.Follow_UP_Opp__c IN: selectQuantityMap.keySet() order by Rental_Apply__r.Follow_UP_Opp__c ];
			// 将每个询价下  借出备品配套一览 的 备品配套明细型号 放进集合
			Map<String,List<String>> model_NoMap  = new Map<String,List<String>>();
			for(Rental_Apply_Equipment_Set__c raes :getRAESList){
				String opportunityId = raes.Rental_Apply__r.Follow_UP_Opp__c;
				List<String> model_NoList = new List<String>();

				if (model_NoMap.containsKey(opportunityId)) {
					model_NoList = model_NoMap.get(opportunityId);
				}
				model_NoList.add(raes.First_RAESD_Model_No_F__c);
				model_NoMap.put(opportunityId,model_NoList);

			}
			// 查找 询价产品 获取 OCSM内部产品型号(略称)
			List<OpportunityLineItem> getOpportunityLineItemList = [Select Id, Asset_Model_No__c, OCM_internal_product_name__c,OpportunityId From OpportunityLineItem where OpportunityId In:selectQuantityMap.keySet() order by OpportunityId];
			Map<String,Decimal>  effectiveRental_ApplyMap  = new  Map<String,Decimal>();

			if (getOpportunityLineItemList.size() >0) {
				for(OpportunityLineItem oli:getOpportunityLineItemList)	{
					String opportunityId = oli.OpportunityId;
					if (model_NoMap.containsKey(opportunityId)) {
						
						for (String model_No :model_NoMap.get(opportunityId)){

							if (oli.Asset_Model_No__c.equals(model_No) && !effectiveRental_ApplyMap.containsKey(opportunityId)) {
								// 备品申请单一览中的主机型号与产品的型号相同
								effectiveRental_ApplyMap.put(opportunityId,1);
							}
						}

					} else {
						// 询价 下 备品借出申请 无 借出备品配套一览
						effectiveRental_ApplyMap.put(opportunityId,0);
					}
				}	
			}
			
		
			for (String oppId:selectQuantityMap.keySet()){

				opp = new Opportunity();
				opp.Id = oppId;
				if (updateOpportunityMap.containsKey(oppId)) {
					opp = updateOpportunityMap.get(oppId);
				}
				if (!effectiveRental_ApplyMap.containsKey(oppId)) {
					if (selectQuantityMap.get(oppId) != 0) {
						// 备品申请单一览中的主机型号与产品的型号不相同，或者 询价下 无询价产品，有效备品申请 置0。
						opp.EffectiveRentalApply__c = 0;
						updateOpportunityMap.put(oppId,opp);
					}
					
				} else  {
					if (effectiveRental_ApplyMap.get(oppId) != selectQuantityMap.get(oppId)) {
						opp.EffectiveRentalApply__c = effectiveRental_ApplyMap.get(oppId);
						updateOpportunityMap.put(oppId,opp);
					}
				}
			}
		}
		
		
		List<Report__c> raLists = [Select Id,Loaner_request_no1__c,Loaner_request_no1__r.OPDAmount__c 
			from Report__c where Loaner_request_no1__c != null ];
		
		for (Report__c ra: raLists) {

			racCountMap.put(ra.Loaner_request_no1__c,ra.Loaner_request_no1__r.OPDAmount__c);
			
		}
		results = [select Loaner_request_no1__c,count(Id) cnt  from  Report__c where Loaner_request_no1__c In :racCountMap.keySet() and Status__c = '批准' group by Loaner_request_no1__c];
		system.debug('results'+results);
		for (AggregateResult ar :results) {
			racResultsMap.put(String.valueOf(ar.get('Loaner_request_no1__c')), Integer.valueOf(ar.get('cnt')));
		}
		Rental_Apply__c rac = null;
		for (String ids :racCountMap.keySet()) {
			if (racResultsMap.containsKey(ids)) {
				if (racCountMap.get(ids) == null) {
					rac = new Rental_Apply__c();
					rac.OPDAmount__c = racResultsMap.get(ids);
					rac.Id = ids;
					racList.add(rac);
				} else if(racCountMap.get(ids) != racResultsMap.get(ids)) {
					rac = new Rental_Apply__c();
					rac.OPDAmount__c = racResultsMap.get(ids);
					rac.Id = ids;
					racList.add(rac);
				}

			} else {

				if (racCountMap.get(ids) == null) {
					rac = new Rental_Apply__c();
					rac.OPDAmount__c = 0;
					rac.Id = ids;
					racList.add(rac);
				} else if (racCountMap.get(ids)>0) {
					rac = new Rental_Apply__c();
					rac.Id = ids;
					rac.OPDAmount__c = 0;
					racList.add(rac);
				}
				
			}
			
		}
		if (racList.size()>0) {
			update racList;
		}
		// if (oppList.size()>0) {
		// 	update oppList;
		// }
		if (updateOpportunityMap != null && updateOpportunityMap.size() > 0) {
			update updateOpportunityMap.values();
		}
	}
	
	global void finish(Database.BatchableContext BC) {

		
      //2021-07-13  mzy  WLIG-BYHD79  SFDC环境batch合并调查  start
        //if(!Test.isRunningTest() &&IsNeedExecute==true){
          //batch里调用下一个batch时，希望跟原有的Schedule里面传的条数保持一致
        //   Id execBTId = Database.executebatch(new SubAuthorizedBatch(true),10);
        //}
        if(!Test.isRunningTest() &&IsNeedExecute==true){
          //batch里调用下一个batch时，希望跟原有的Schedule里面传的条数保持一致
           Id execBTId = Database.executebatch(new CreateOpportunityTaskBatch(true),20);
        }
      //2021-07-13  mzy  WLIG-BYHD79  SFDC环境batch合并调查 end
	}
	
}