public with sharing class Vconnect_SchemeProduct {
    
    @AuraEnabled(Cacheable=true)
    public static List <VConnect_Product_Master__c> getProducts() {
        
        List<VConnect_Product_Master__c> ProductList  = [Select Id,Name, VConnect_Material_Code__c, VConnect_Pack_Size__c,VConnect_Material_Code_Description__c,VConnect_Category__c FROM VConnect_Product_Master__c];
        return ProductList;
    }  

    // @AuraEnabled
    // public static List<VConnect_Product_Master__c> getCategoryValues(String categoryName,String schemeId){
    //     system.debug('schemeId'+schemeId);
    //     List<VConnect_Scheme_Product__c> schemeProdLst = [SELECT Id, Name, VConnect_Scheme__c, VConnect_Product__c FROM VConnect_Scheme_Product__c  where VConnect_Scheme__c =: schemeId];
       
    //     set<id> productId = new set<id>();

    //     for(VConnect_Scheme_Product__c schemeProd : schemeProdLst)
    //     productId.add(schemeProd.VConnect_Product__c);

    //      List<VConnect_Product_Master__c> ProductList  = [Select Id, VConnect_Material_Code__c, VConnect_Pack_Size__c,VConnect_Material_Code_Description__c,VConnect_Category__c FROM VConnect_Product_Master__c 
    //      WHERE VConnect_Category__c = :categoryName AND Id NOT IN: productId];
    //      return ProductList;
    // }  

    @AuraEnabled
    public static String getCategoryValues(String categoryName,String schemeId,Integer pageSize, Integer pageNumber){
      //  system.debug('schemeId'+schemeId);
        List<VConnect_Scheme_Product__c> schemeProdLst = [SELECT Id, Name, VConnect_Scheme__c, VConnect_Product__c FROM VConnect_Scheme_Product__c  where VConnect_Scheme__c =: schemeId];
       
        set<id> productId = new set<id>();

        for(VConnect_Scheme_Product__c schemeProd : schemeProdLst)
        productId.add(schemeProd.VConnect_Product__c);

         List<VConnect_Product_Master__c> ProductList  = [Select Id, VConnect_Material_Code__c, VConnect_Pack_Size__c,VConnect_Material_Code_Description__c,VConnect_Category__c FROM VConnect_Product_Master__c 
         WHERE VConnect_Category__c = :categoryName AND Id NOT IN: productId];
        // return ProductList;

        
        String jsonDT = '';
         
        //Offset for SOQL
        Integer offset = (pageNumber - 1) * pageSize;
         
        //Total Records
      //  Integer totalRecords = [SELECT COUNT() FROM Account];
        Integer totalRecords = ProductList.size();

        Integer recordEnd = pageSize * pageNumber;
         
        ProductDTWrapper objDT =  new ProductDTWrapper();  
        objDT.pageSize = pageSize;
        objDT.pageNumber = pageNumber;
        objDT.recordStart = offset + 1;
        objDT.recordEnd = totalRecords >= recordEnd ? recordEnd : totalRecords;
        objDT.totalRecords = totalRecords;
        objDT.products = [Select Id, VConnect_Material_Code__c, VConnect_Pack_Size__c,VConnect_Material_Code_Description__c,VConnect_Category__c FROM VConnect_Product_Master__c 
        WHERE VConnect_Category__c = :categoryName AND Id NOT IN: productId LIMIT :pageSize OFFSET :offset];
        jsonDT = JSON.serialize(objDT);

       // system.debug('b'+ objDT.accounts );
        return jsonDT;

    } 

    public class ProductDTWrapper {
        public Integer pageSize {get;set;}
        public Integer pageNumber {get;set;}
        public Integer totalRecords {get;set;}
        public Integer recordStart {get;set;}
        public Integer recordEnd {get;set;}
        public List<VConnect_Product_Master__c> products {get;set;}
    }

    @AuraEnabled
     public static List<Sobject> createproductscheme(List<SObject> lstSobjectRecords){
        System.debug('lstSobjectRecords===>'+lstSobjectRecords);
        insert lstSobjectRecords;
        return lstSobjectRecords;
    }

    @AuraEnabled(Cacheable=true)
    public static List<Account> getAreaManger(List<String> selectedState){
        return [SELECT Id, VConnect_Area_Manager__c,VConnect_Area_Manager__r.Name,Zone__c FROM Account where VConnect_Area_Manager__r.state IN : selectedState];
    }  

    @AuraEnabled(Cacheable=true)
    public static List<Account> getDistributor(List<String> selectedAreaManager){
        return [SELECT Id,Name, VConnect_Area_Manager__c,VConnect_Area_Manager__r.Name,Zone__c FROM 
        Account where VConnect_Area_Manager__c IN : selectedAreaManager AND RecordType.Developername = 'VConnect_Distributor'];
    }  

    

    @AuraEnabled
    public static String getRetailer(List<String> selectedDistributor, String schemeId,Integer pageSize, Integer pageNumber){

        List<VConnect_Scheme_Audience__c> schemeAudLst = [Select VConnect_Retailer__c, VConnect_Scheme__c FROM VConnect_Scheme_Audience__c where VConnect_Scheme__c =: schemeId ];
        set<id> retailerId = new set<id>();
        for(VConnect_Scheme_Audience__c schemeAud : schemeAudLst)
        retailerId.add(schemeAud.VConnect_Retailer__c);
        
        list<Account> accLst = [ SELECT Id,Name,VConnect_Distributor__c ,VConnect_Telephone__c,VConnect_City__c,VConnect_Email_Id__c,VConnect_Distributor__r.Name,Zone__c FROM 
         Account where VConnect_Distributor__c IN : selectedDistributor AND RecordType.Developername = 'VConnect_Retailer'  AND ID NOT IN: retailerId];
        

        String jsonDT = '';
         
        //Offset for SOQL
        Integer offset = (pageNumber - 1) * pageSize;
         
        //Total Records
      //  Integer totalRecords = [SELECT COUNT() FROM Account];
        Integer totalRecords = accLst.size();

        Integer recordEnd = pageSize * pageNumber;
         
        AccountDTWrapper objDT =  new AccountDTWrapper();  
        objDT.pageSize = pageSize;
        objDT.pageNumber = pageNumber;
        objDT.recordStart = offset + 1;
        objDT.recordEnd = totalRecords >= recordEnd ? recordEnd : totalRecords;
        objDT.totalRecords = totalRecords;
        objDT.accounts = [SELECT Id,Name,VConnect_Distributor__c ,VConnect_Telephone__c,VConnect_City__c,VConnect_Email_Id__c,VConnect_Distributor__r.Name,Zone__c FROM 
        Account where VConnect_Distributor__c IN : selectedDistributor AND RecordType.Developername = 'VConnect_Retailer'  AND ID NOT IN: retailerId LIMIT :pageSize OFFSET :offset];
        jsonDT = JSON.serialize(objDT);

        system.debug('b'+ objDT.accounts );
        return jsonDT;
    }  

    public class AccountDTWrapper {
        public Integer pageSize {get;set;}
        public Integer pageNumber {get;set;}
        public Integer totalRecords {get;set;}
        public Integer recordStart {get;set;}
        public Integer recordEnd {get;set;}
        public List<Account> accounts {get;set;}
    }

    @AuraEnabled
    public static List<Sobject> createSchemeAudience(List<SObject> lstSobjectRecords){
       System.debug('lstSobjectRecords===>'+lstSobjectRecords);
       insert lstSobjectRecords;
       return lstSobjectRecords;
   }
   
    @AuraEnabled
     public static void insertSchemeSlabs(String jsonOflistOfSlabs) {
        List<VConnect_Scheme_Slab__c> listOfSlabs = (List<VConnect_Scheme_Slab__c>) JSON.deserialize(jsonOflistOfSlabs, List<VConnect_Scheme_Slab__c>.class);
        insert listOfSlabs;
    }

    @AuraEnabled
    public static List<Sobject> upsertSchemeSlabs(List<SObject>  lstSobjectRecords) {
       upsert lstSobjectRecords;
       return lstSobjectRecords;
   }

 @AuraEnabled
    public static List<VConnect_Scheme_Slab__c> saveSchemeSlabs(List<VConnect_Scheme_Slab__c> lstSlabs){
       System.debug('lstSlabs===>'+lstSlabs);
       insert lstSlabs;
       return lstSlabs;
}

@AuraEnabled
public static String getFOCProducts(Integer pageSize, Integer pageNumber ) {
    String jsonDT = '';
         
        //Offset for SOQL
        Integer offset = (pageNumber - 1) * pageSize;
         
        //Total Records
        Integer totalRecords = [SELECT COUNT() FROM VConnect_FOC_Master__c];
       // Integer totalRecords = accLst.size();

        Integer recordEnd = pageSize * pageNumber;
         
        FocProductDTWrapper objDT =  new FocProductDTWrapper();  
        objDT.pageSize = pageSize;
        objDT.pageNumber = pageNumber;
        objDT.recordStart = offset + 1;
        objDT.recordEnd = totalRecords >= recordEnd ? recordEnd : totalRecords;
        objDT.totalRecords = totalRecords;
        objDT.focProducts = [Select Id,Name,VConnect_Product__c,VConnect_Product__r.Name,VConnect_ProductCode__c,VConnect_Amount__c FROM VConnect_FOC_Master__c LIMIT :pageSize OFFSET :offset];
        jsonDT = JSON.serialize(objDT);

        system.debug('b'+ objDT.focProducts );
        return jsonDT;
    }  

    public class FocProductDTWrapper {
        public Integer pageSize {get;set;}
        public Integer pageNumber {get;set;}
        public Integer totalRecords {get;set;}
        public Integer recordStart {get;set;}
        public Integer recordEnd {get;set;}
        public List<VConnect_FOC_Master__c> focProducts {get;set;}
    }
    // List<VConnect_FOC_Master__c> FOCProductList  = [Select Id,Name,VConnect_Product__c,VConnect_ProductCode__c,VConnect_Amount__c FROM VConnect_FOC_Master__c];
    // return FOCProductList;
}