global class CSportfoliosTask implements Database.Batchable<sObject>
{
    global Database.QueryLocator start(Database.BatchableContext BC)
    {
        datetime next30days = date.today().addDays(30);
        string next30daysformat = next30days.format('yyyy-MM-dd');
        String query = 'SELECT Id, Credit_Card_Expiration__c, Next_Billed_Date__c,Opportunity.Account.OwnerId  FROM opportunity WHERE  StageName = \'Closed Won\' and Susbcription_Status__c =\'Active\' and Next_Billed_Date__c='+next30daysformat;
        return Database.getQueryLocator(query);
    }
	
    global void execute(Database.BatchableContext BC, List<Opportunity> scope)
    {
		List<Task> lstTasktoInsert = new List<Task>();
	
		for(Opportunity o : scope)
		{
			if(o.Credit_Card_Expiration__c!=NULL)
			{
				String ccs = o.Credit_Card_Expiration__c;
				String[] ccsplitted = ccs.split('-'); 
				String ccmonth =  ccsplitted[0];
				String ccyear =  ccsplitted[1];
				String nexts = string.valueOfGmt(o.Next_Billed_Date__c);
				String[] nextSplitted = nexts.split('-');
				String nextYear = nextSplitted[0];
				String nextMonth = nextSplitted[1];
				
				if(ccyear<=nextYear)
				{
					if(Integer.ValueOf(ccmonth)<=Integer.ValueOf(nextMonth))
					{
						 Task taskObj = CreaeTask('Alert - Subscription payment at risk - Expired Card on '+o.Credit_Card_Expiration__c, o.Id , o.Account.OwnerId);
						 
						 lstTasktoInsert.add(taskObj);
					}
				}
				
			}
		}

		/*	
		
			List<Opportunity> opp2 = new List<Opportunity>();
			datetime next30days = date.today().addDays(30);
			string next30daysformat = next30days.format('MM/dd/YYYY');
			date next30daysdate = date.parse(next30daysformat);
			
			opp2= [SELECT Id, Next_Billed_Date__c, Opportunity.Account.OwnerId FROM opportunity WHERE  StageName = 'Closed Won' and Susbcription_Status__c ='Active' and Next_Billed_Date__c=:next30daysdate];
				
			for(Opportunity o2 : opp2)
			{  
				Task taskObj = CreaeTask('Alert - Secure Subscription Renewal on '+o2.Next_Billed_Date__c, o2.Id, o2.Account.OwnerId);
				lstTasktoInsert.add(taskObj);
			}
		
		*/
		
		if(lstTasktoInsert.size() > 0 )
		{
			insert lstTasktoInsert;
		}
		
    }
    
    global Task CreaeTask(String Subject,String Id, String OwnerId){
        Task t = new Task();
        t.Subject = Subject;
        t.Type = 'Outbound Call';
        t.Status = 'Open';
        t.Priority = 'Normal';
        t.ActivityDate= date.today();
        t.WhatId =Id;
        t.OwnerId = OwnerId;
        return t;     
       } 
    
    global void finish(Database.BatchableContext BC)
    {
        Messaging.SingleEmailMessage mail = new Messaging.SingleEmailMessage();
 
        mail.setToAddresses(new String[] {'ahmeds@example.com'});
        mail.setReplyTo('ahmeds@example.com');
        mail.setSenderDisplayName('Batch Processing');
        mail.setSubject('Batch Process Early Warning System for CS portfolios create task Completed');
        mail.setPlainTextBody('Early Warning System for CS portfolios create task Batch Process has Completed');
 
        Messaging.sendEmail(new Messaging.SingleEmailMessage[] { mail });
    }
}

/*	
			List<Opportunity> opp2 = new List<Opportunity>();
			datetime next30days = date.today().addDays(30);
			string next30daysformat = next30days.format('MM/dd/YYYY');
			date next30daysdate = date.parse(next30daysformat);
			
			opp2= [SELECT Id, Next_Billed_Date__c, Opportunity.Account.OwnerId FROM opportunity WHERE  StageName = 'Closed Won' and Susbcription_Status__c ='Active' and Next_Billed_Date__c=:next30daysdate];
				
			for(Opportunity o2 : opp2)
			{  
				Task taskObj = CreaeTask('Alert - Secure Subscription Renewal on '+o2.Next_Billed_Date__c, o2.Id, o2.Account.OwnerId);
				lstTasktoInsert.add(taskObj);
			}
		*/