/**************************
* File Name     : CreateOpportunityService 
* Description   : Webservice class for creating opportunity. 
* =========================================================================== 
* Ver Date        Author                                     Modification 
* --- ---- ------ ---------------- --------------------------------------- 
* 1.0 27-Feb-2020  Kumar                              Created
*************************/ 

@RestResource(urlMapping='/opportunities')
global class CreateOpportunityService {
    public static string jsonString = '';
    @HttpPost
    global  static void Assignment(){
        RestRequest request = RestContext.request;  
        RestResponse response = RestContext.response;
        if( jsonString == '') 
        {
            Blob body = request.requestBody;
            jsonstring = body.toString();
            system.debug('.....jsonstring ...'+jsonstring);
        }
        List<JSON2Apex> recordList= (List<JSON2Apex>) System.JSON.deserialize(jsonstring, List<JSON2Apex>.class);
        system.debug('<<<apexRecords'+recordList); 
        
        
        Set<string> emailSet=new Set<String>();
        Set<String> phoneSet=new Set<String>();
        Set<String> accountIds=new Set<String>();
        Set<Integer> pids=new Set<Integer>();   
        Map<string,contact> conEmailMap=new Map<String,Contact>();
        Map<String,JSON2Apex> conJSON2ApexMap=new Map<String,JSON2Apex>();
        Map<String,list<contact>> AccountToContactMap = new Map<String,list<contact>>();
        Map<String,opportunity> OpportunityMap = new Map<String,opportunity>();
        
        Map<String,Opportunity> accOppMap=new Map<String,Opportunity>();
        List<contact> contacts=new List<contact>();
        List<Opportunity> opportunities=new List<Opportunity>();
        List<account> accounts=new List<account>();
        String result = 'Success';
        Date CloseDt = Date.today()+7;
        String Stage_Name ='Open';
        
        for(JSON2Apex js:recordList){
            if(js.email!=null){
                emailSet.add(js.email);
            }
            else if(js.phone!=null){
                phoneSet.add(js.phone);
            }
        }
        
        system.debug('<<<emailSet'+emailSet);
        system.debug('<<<phoneSet'+phoneSet);

        List<Contact> conList=[SELECT Id,firstName,lastName,Email,Phone,accountId from Contact where email IN :emailSet OR phone IN :phoneSet];
        System.debug('<<<conList'+conList);
        
        if(conList.size()>0){
            for(Contact con:conList){
                conEmailMap.put(con.email,con);
                if(con.email==null){
                    conEmailMap.put(con.phone,con);
                }
                accountIds.add(con.accountId);
            }
            List<Account> accList=[SELECT Id,name,(SELECT id,pid__c,accountId FROM opportunities) from account where id in :accountIds];
            for(account acc:accList){
                for(opportunity opp:acc.opportunities){
                    OpportunityMap.put(opp.accountId,opp);
                }
            }
        }
        
        for(JSON2Apex jsn : recordList){
            String accountId='';
            if(conEmailMap.get(jsn.email)!=null || conEmailMap.get(jsn.phone)!=null){
                if(conEmailMap.get(jsn.email)!=null){
                    accountId= conEmailMap.get(jsn.email).accountId;
                }else{
                    accountId= conEmailMap.get(jsn.phone).accountId;
                }
                if(accountId!=null){
                    if(OpportunityMap.get(accountId)!=null){
                        if(jsn.pid==OpportunityMap.get(accountId).pid__c){
                            //Update opportunity - Not Clear what to Update
                        }
                        else{
                            Opportunity opp=new opportunity();
                            opp.pid__c=jsn.pid;
                            opp.name=jsn.fname+jsn.lname+jsn.pid;
                            opp.accountId=conEmailMap.get(jsn.email).accountid;
                            opp.CloseDate = CloseDt;
                            opp.StageName =Stage_Name;
                            opportunities.add(opp);
                        }
                        
                    }
                }
                
            }
            else{
                Account acc=new Account();
                acc.name= jsn.fname+jsn.lname;
                accounts.add(acc);  
                
                Contact con=new Contact();
                con.Email = jsn.email;
                con.Phone = jsn.Phone;
                con.FirstName = jsn.fname;
                con.LastName = jsn.lname;
                contacts.add(con);
                
                opportunity opp= new opportunity();
                opp.Name = jsn.fname+jsn.lname + jsn.pid ;
                opp.pid__c=jsn.pid;
                opp.CloseDate = CloseDt;
                opp.StageName =Stage_Name;
                opportunities.add(opp);
            }
        }
        if(!accounts.isEmpty()){
            try{
                insert accounts;
            }catch(Exception e){
                result = e.getMessage();
            }
        }
        
        for(Account accTemp : accounts){
            for(contact con :contacts){
                con.accountid = accTemp.id;
            }
        }
        
        for(Account accTemp : accounts){
            for(opportunity opp :opportunities){
                opp.accountid = accTemp.id;
            }
        }
        if(!contacts.isEmpty()){
            try{
                insert contacts;
            }catch(exception e){
                result = e.getMessage();
            }
        }
        
        if(!opportunities.isEmpty()){
            try{
                insert opportunities;
            }catch(exception e){
                result = e.getMessage();
            }
        }
        
    }
    public class JSON2Apex{
        public String pid;
        public String email;
        public String phone;
        public String fname;
        public String lname;
    }
}