<?php

namespace common\models;

use Yii;

use common\components\RoleDefinition;
use common\components\Helper;
use yii\db\Query;

/**
 * TransferListSearch represents the model behind the search form about `common\models\Transfer`.
 */
class TransferListSearch extends Transfer
{
	
	public $mode = 'reception';//reception or admin
	
	/**start date string*/
	public $start;
	/**end date string*/
	public $end;
	/**start date*/
	public $timestampStart;
	/** end date*/
	public $timestampEnd;
	/**if include cassa open*/	
	public $includeCassaOpen = false;
	/**total with cassa open*/
	public $totalWithCassa;
	/**last cassa open*/
	public $cassaOpen;
	
	public $totals;
	/**The accounts*/
	public $accounts;
	/**types*/
	public $types;
	/**users*/
	public $users;
	/**
	 * all money gained with ticket sell
	 * */
	public $ticketMoney = 0;
	/**
	 * all money gained with product sell
	 * */
	public $productMoney = 0;
	/**
	 * all money gained with product sell
	 * */
	public $productMoneyNetto = 0;
	/**
	 * all money gained with product sell grouped by category
	 * */
	public $productMoneies = [];
	/**
	 * all money lost by money movement
	 * */
	public $moneyMovementMoneis  = 0;
	public $moneyMovementMoney = 0;
	/**
	 * total gained money brutto
	 * */
	public $total = 0;
	/**
	 * total gained money netto
	 * */
	public $totalNetto = 0;
	
	/**
	 * ticket sale statisitc
	 * */
	public $ticketStats =[];
	
	/**
	 * money movements by type
	 * */
	public $moneyMovementsByType = [];
	
	public $tickets;
	/**
	 * all product transfer
	 * */
	public $products = [];
	public $moneyMovements = [];
	
	public $productsByCategory = [];
	
	public $currentUser;
	public $currentAccount;
	
	public $output;
	
	public $outputView;

    public $bought_in_interval = false;
    public $payed_in_interval = true;
	
	
    /**
     * @inheritdoc
     */
    public function rules()
    {
        return [
        		
        	[[ 'start',  ], 'date', 'format' =>Yii::$app->formatter->datetimeFormat  , 'timestampAttribute' => 'timestampStart' ,'timestampAttributeFormat' => 'yyyy-MM-dd HH:mm' ,'timeZone' => 'UTC' ],
        	[[ 'end' , ], 'date'  ,'format' =>Yii::$app->formatter->datetimeFormat  , 'timestampAttribute' => 'timestampEnd' ,'timestampAttributeFormat' => 'yyyy-MM-dd HH:mm' ,'timeZone' => 'UTC' ],
        		
        	[['start','end' ], 'required'],
			[ [ 'id_account','id_user'  ] , 'integer'],
        	['types', 'each', 'rule' => ['integer']],
        	['output', 'safe'  ],
        	['outputView', 'safe'  ],
            [['bought_in_interval','payed_in_interval'],'boolean'] ,
//         	['start', 'validateStart']
        ];
    }

    
    public function validateStart($attribute,$param = null){

    	
		if ( $this->isStartDateToEarly() ){
			$this->addError($attribute, 'Érvénytelen kezdő dátum');
		}
		
    }
    
    protected function calcStartDaysSinceToday(){
    	$start = $this->timestampStart;
    	$now = new \DateTime();
    	 
    	$dt =  \DateTime::createFromFormat('Y-m-d H:i', $start);

        return $now->diff($dt)->days;


//            $d = $dt->getTimeStamp();
//    	$days_between = ceil(abs($now->getTimestamp() - $d) / 86400);
//    	echo $days_between . " vs " . $diff->days;
//
//    	return $days_between;
    }
    
    protected function isStartDateToEarly(){
    	$days_visiblity = Helper::getReceptionVisibilityDays();
    	$days_between = $this->calcStartDaysSinceToday();
    	return $days_between > $days_visiblity;
    }
    
    
	public function isModeAdmin(){
		return $this->mode === 'admin';
	}
	public function isModeReception(){
		return $this->mode === 'reception';
	}

    /**
     * Creates data provider instance with search query applied
     *
     * @param array $params
     *
     * @return void
     * @throws \yii\base\InvalidConfigException
     */
    public function search($params)
    {
//        ini_set("memory_limit","128");
//        $query = Transfer::find();

//        $dataProvider = new ActiveDataProvider([
//            'query' => $query,
//        ]);

        
        $this->load($params);
        

        if (!$this->validate()) {
            // TODO: FIX
        }
         
        
        $this->readTicketMoney();
        $this->readProductsMoney();
        $this->readMoneyMovementMoney();
        $this->calcTotal();
        
        if ( $this->isModeReception()){
        	if ( Helper::isAccountStateClosePreloadMoney()){
	        	$this->readCassaOpen();
    	    	$this->calcTotalWithCassaOpen();
        	}
        }
        
        
        $this->readProductsByCategory();
        $this->readProductsByCategoryDetailed();
        $this->readTicketStas();
        $this->readMoneyMovementsStats();
        
        
        $this->readTickets();
        $this->readProducts();
        $this->readMoneyMovements();
        
        if ( $this->isModeAdmin() && RoleDefinition::isAdmin()){
        	
        	if ( $this->id_user){
        		$this->currentUser = User::findOne($this->id_user);
        	}
        	if ( $this->id_account){
        		$this->currentAccount = Account::findOne($this->id_account);
        	}
        	
        	$this->readProductsMoneyNetto();
        	$this->calcTotalNetto();
        }
        
    }
    
    protected function readCassaOpen(){
    	$this->cassaOpen = AccountState::readLast(AccountState::TYPE_OPEN,null,Account::readDefault());
    }
    
    protected function calcTotal(){
    	$this->total = 0;
    	$this->total += $this->ticketMoney;
    	$this->total += $this->productMoney;
    	$this->total += $this->moneyMovementMoneis;
    }
    protected function calcTotalWithCassaOpen(){
    	$this->totalWithCassa = 0;
    	$this->totalWithCassa += $this->total;
    	if ( isset($this->cassaOpen ) ){
    		$this->totalWithCassa += $this->cassaOpen->money;
    	}
    	 
    }
    protected function calcTotalNetto(){
    	$this->totalNetto = 0;
    	$this->totalNetto += $this->ticketMoney;
    	$this->totalNetto += $this->productMoneyNetto;
    	$this->totalNetto += $this->moneyMovementMoneis;
    }


    /**
     * @param Query $query
     */
    protected function addAccountConstraint($query){

    	if (!$this->isModeAdmin() || !RoleDefinition::isAdmin() ){
	    	$query->innerJoin('user_account_assignment','transfer.id_account = user_account_assignment.id_account' );
	    	$query->andWhere(['user_account_assignment.id_user' => Yii::$app->user->id ]);
	    	
	    	if ( RoleDefinition::isReception() || !$this->isModeAdmin()){
	    		$query->andWhere(['transfer.paid_by' => Yii::$app->user->id ]);
	    	}
	    	
	    	
	    	$query->andWhere(['account.type' => Account::TYPE_ALL ]); 
    	}
    	
    }

    /**
     * add common transfer conditions.
     * mode and role will be used to build to correct condition
     * @param  Query $query
     */
    protected function addQueryFilters($query){
    	$query->innerJoin('account', 'transfer.id_account = account.id_account');
    	
    	$this->addAccountConstraint($query);
    	
    	$query->andFilterWhere([
    			'transfer.id_account' => $this->id_account,
    			'transfer.type' => $this->type,
    			'transfer.paid_by' => $this->id_user,
    	]);

        $all = ($this->bought_in_interval && $this->payed_in_interval)
            || ( !$this->bought_in_interval && !$this->payed_in_interval);


        $orConditions = [];

        if ( $all || $this->bought_in_interval){
    	$created_condition = ['and',[ '>=', 'transfer.created_at', $this->timestampStart ] ,[ '<', 'transfer.created_at', $this->timestampEnd ]  ];
            $orConditions[] = $created_condition;
        }

        if ( $all || $this->payed_in_interval ){
    	$paid_condition = ['and',[ '>=', 'transfer.paid_at', $this->timestampStart ] ,[ '<', 'transfer.paid_at', $this->timestampEnd ]  ];
            $orConditions[] = $paid_condition;
        }

        if ( count($orConditions) === 2){
            $query->andFilterWhere(['or', $orConditions[0], $orConditions[1]]);
        }else if ( count($orConditions) === 1 ){
            $query->andFilterWhere($orConditions[0]);
        }

    	
    	$query->andWhere(['transfer.status' => Transfer::STATUS_PAID]);
    	
    	if ( !$this->isModeAdmin()){
    		$query->andWhere(['transfer.payment_method' => Transfer::PAYMENT_METHOD_CASH]);

    	}
    	
    	
    	if ( !RoleDefinition::isAdmin() ){
    		/**
    		 * Csak az admin láthat minden adatot
    		 * ha a start dátum korábbi, mint ahogy azt a recepciósok láthatják,
    		 * hozzáadjuk a querykhez a dátum korlátozást
    		 * */
    		if ( $this->isStartDateToEarly() ){
    			 
    			$days = Helper::getReceptionVisibilityDays();
    			$time = date( 'Y-m-d H:i:s', strtotime("today -$days day") );
    			 
    			$start_date_condition = ['or',[ '>=', 'transfer.created_at', $time ] ,[ '>=', 'transfer.paid_at', $time]   ];
    		
    			$query->andFilterWhere( $start_date_condition );
    			 
    		}
    	}
    	
    	 
    }
    
    
    protected function readTicketStas(){
    
    	$query = (new Query());
    	$query->select(['ticket_type.name as ticket_type_name' , 'coalesce(sum(abs(transfer.count)),0) AS ticket_count', 'coalesce(sum(abs(transfer.money)),0) AS ticket_money']);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_TICKET]);
    	$query->innerJoin('ticket', 'ticket.id_ticket = transfer.id_object');
    	$query->innerJoin('ticket_type', 'ticket.id_ticket_type = ticket_type.id_ticket_type');
    	
    	$query->groupBy(['ticket_type.id_ticket_type','ticket_type.name']);
    	$query->orderBy(['ticket_type.name' => SORT_ASC]);
    	$this->addQueryFilters($query);
    	
    
    	$this->ticketStats = $query->all();
    }
    
    
    protected function readTicketMoney(){
    	 
    	$query = (new Query());
    	$query->select([' coalesce(sum(abs(transfer.money)),0) AS ticket_money']);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_TICKET]);
    	$query->innerJoin('ticket', 'ticket.id_ticket = transfer.id_object');
    	$this->addQueryFilters($query);
    	$this->ticketMoney = $query->scalar();
    }
    
    protected function readProductsByCategory(){
    
    	 
    	$query = (new Query());
    	$query->select(['coalesce(sum(transfer.money),0) AS product_money', 'coalesce(sum(transfer.count),0) as category_count', 'product_category.name as category_name']);
    	$query->from('transfer');
    	$query->groupBy(['product_category.id_product_category','product_category.name']);
    	$query->andWhere(['transfer.type' => Transfer::TYPE_PRODUCT]);
    	$query->innerJoin('sale', 'sale.id_sale = transfer.id_object');
    	$query->innerJoin('product', 'sale.id_product = product.id_product');
    	$query->innerJoin('product_category', 'product.id_product_category = product_category.id_product_category');
    	$this->addQueryFilters($query);
    	 
    	$this->productMoneies  = $query->all();
    	 
    }
    
    
    protected function readProductsByCategoryDetailed(){
    
    	$formatted = [];
    	$formatted['categories'] = [];
    	$formatted['total'] = 0;
    	$prevCategory = null;
    	$curCategory = null;
    	
    	$category = null;
    
    	$query = (new Query());
    	$query->select(['product_category.id_product_category as product_category_id','product_category.name as product_category_name', 'product.name as product_name' ,'coalesce(sum(transfer.money),0) AS product_money', 'coalesce(sum(transfer.count),0) as product_count']);
    	$query->from('transfer');
    	$query->groupBy(['product.id_product','product.name','product_category.id_product_category','product_category.name']);
    	$query->andWhere(['transfer.type' => Transfer::TYPE_PRODUCT]);
    	$query->innerJoin('sale', 'sale.id_sale = transfer.id_object');
    	$query->innerJoin('product', 'sale.id_product = product.id_product');
    	$query->innerJoin('product_category', 'product.id_product_category = product_category.id_product_category');
    	$query->orderBy(['product_category.name'  => SORT_ASC,'product.name'  => SORT_ASC]);
    	$this->addQueryFilters($query);
    
    	$result = $query->all();
    	
    	foreach ($result as $row){
    		$curCategory = $row['product_category_id'];
    		if ( $curCategory  != $prevCategory ){
    			//store last category
    			if ( $category != null ){
    				$formatted['categories'][] = $category;
    			}
    			$prevCategory = $curCategory;
    			//create new category
    			$category = [];
    			$category['category'] = [];
    			$category['category']['name'] = $row['product_category_name'];
    			$category['category']['id'] = $row['product_category_id'];
    			$category['products'] = [];
    			$category['total'] = 0;
    			
    		}
    		$category['products'][] = $row;
    		$category['total'] += $row['product_money'];
    		$formatted['total'] += $row['product_money'];
    			
    	}
    	
    	if ( $category != null ){
    		$formatted['categories'][]= $category;
    	}
    	
    	$this->productsByCategory = $formatted;
    
    }
    
    protected function readProductsMoney(){
    
    	 
    	$query = (new Query());
    	$query->select(['coalesce(sum(transfer.money),0) AS product_money' ]);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_PRODUCT]);
    	$query->innerJoin('sale', 'sale.id_sale = transfer.id_object');
    	$this->addQueryFilters($query);
    	 
    	$this->productMoney  = $query->scalar();
    	 
    }
    protected function readProductsMoneyNetto(){
    
    	 
    	$query = (new Query());
    	$query->select(['coalesce(sum(transfer.count * GREATEST((  product.sale_price - coalesce(product.purchase_price,0)),0)),0) AS product_money' ]);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_PRODUCT]);
    	$query->andWhere(['transfer.payment_method' => Transfer::PAYMENT_METHOD_CASH]);
    	$query->innerJoin('sale', 'sale.id_sale = transfer.id_object');
    	$query->innerJoin('product', 'sale.id_product = product.id_product');
    	$this->addQueryFilters($query);
    	 
    	$this->productMoneyNetto  = $query->scalar();
    	 
    }
    
    
    protected function readMoneyMovementMoney(){
    	$query = (new Query());
    	$query->select([' coalesce(sum( case when transfer.direction = ' . Transfer::DIRECTION_IN. ' then transfer.money else -1 * transfer.money end  ),0) AS money_movement_money']);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_MONEY_MOVEMENT_OUT]);
    	$query->innerJoin('money_movement', 'money_movement.id_money_movement = transfer.id_object');
    	$this->addQueryFilters($query);
    
    	$this->moneyMovementMoneis  = $query->scalar();
    }
    protected function readMoneyMovementsStats(){
    	$query = (new Query());
    	$query->select([ 'money_movement.type as money_movement_type', ' coalesce(count(transfer.id_transfer),0) AS money_movement_count', 'coalesce(sum( case when transfer.direction = ' . Transfer::DIRECTION_IN. ' then transfer.money else -1 * transfer.money end  ),0) AS money_movement_money']);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_MONEY_MOVEMENT_OUT]);
    	$query->innerJoin('money_movement', 'money_movement.id_money_movement = transfer.id_object');
    	$query->groupBy(['money_movement.type']);
    	$this->addQueryFilters($query);
    
    	$this->moneyMovementsByType  = $query->all();
    	$count = count($this->moneyMovementsByType);
    	for  ($i = 0; $i < $count  ;$i++ ){
    		$this->moneyMovementsByType[$i]['name'] = MoneyMovement::typeName($this->moneyMovementsByType[$i]['money_movement_type']);
    	}
    }
    
    protected function readTickets(){
    	$query = (new Query());
    	$query->select([ 'customer.name as customer_name', 'user.username as user_name',  'account.name as account_name','ticket_type.name as ticket_type_name' , 'transfer.count AS ticket_count', 'transfer.money AS ticket_money','transfer.item_price AS ticket_item_price', 'transfer.created_at as ticket_created_at','transfer.paid_at as ticket_paid_at']);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_TICKET]);
    	$query->innerJoin('ticket', 'ticket.id_ticket = transfer.id_object');
    	$query->innerJoin('customer', 'customer.id_customer = transfer.id_customer');
    	$query->innerJoin('ticket_type', 'ticket.id_ticket_type = ticket_type.id_ticket_type');
    	$query->innerJoin('user', 'transfer.paid_by = user.id');
    	$query->orderBy(['transfer.created_at'  => SORT_ASC]);
    	$this->addQueryFilters($query);
    	 
    	$this->tickets = $query->all();

    	$count = count($this->tickets);
    	for  ($i = 0; $i < $count ;$i++ ){
    		$this->tickets[$i]['ticket_created_at'] = Yii::$app->formatter->asDatetime($this->tickets[$i]['ticket_created_at'], 'yyyy.MM.dd HH:mm:ss');
    		$this->tickets[$i]['ticket_paid_at'] =  empty($this->tickets[$i]['ticket_paid_at'] ) ? '-' : Yii::$app->formatter->asDatetime($this->tickets[$i]['ticket_paid_at'], 'yyyy.MM.dd HH:mm:ss');
    	}
    	
    }
    
    protected function readProducts(){
     
    	$query = (new Query());
    	$query->select([ 'user.username as user_name','account.name as account_name' , 'product_category.name as product_category_name', 'product.name as product_name', 'transfer.money AS product_money', 'transfer.count AS product_count', 'transfer.money AS product_money','transfer.item_price AS product_item_price', 'transfer.created_at as product_created_at','transfer.paid_at as product_paid_at']);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_PRODUCT]);
    	$query->innerJoin('sale', 'sale.id_sale = transfer.id_object');
    	$query->innerJoin('product', 'sale.id_product = product.id_product');
    	$query->innerJoin('product_category', 'product.id_product_category = product_category.id_product_category');
    	
    	$query->innerJoin('user', 'transfer.paid_by = user.id');
    	$query->orderBy(['transfer.created_at'  => SORT_ASC]);
    	$this->addQueryFilters($query);
    	 
    	$this->products  = $query->all();

    	 $count = count($this->products);
    	for  ($i = 0; $i < $count ;$i++ ){
    		$this->products[$i]['product_created_at'] = Yii::$app->formatter->asDatetime($this->products[$i]['product_created_at'], 'yyyy.MM.dd HH:mm:ss');
    		$this->products[$i]['product_paid_at'] =  empty($this->products[$i]['product_paid_at'] ) ? '-' : Yii::$app->formatter->asDatetime($this->products[$i]['product_paid_at'], 'yyyy.MM.dd HH:mm:ss');
    	}
    	 
    }

    /**
     * @throws \yii\base\InvalidConfigException
     */
    protected function readMoneyMovements(){
    	$query = new Query();
    	$query->select([ 'user.username as user_name','account.name as account_name', 'transfer.direction as transfer_direction' ,'money_movement.type as money_movement_type', 'transfer.money AS money_movement_money', 'money_movement.name as money_movement_name','transfer.created_at as money_movement_created_at', 'money_movement.comment as money_movement_comment' ]);
    	$query->from('transfer');
    	$query->andWhere(['transfer.type' => Transfer::TYPE_MONEY_MOVEMENT_OUT]);
    	$query->innerJoin('money_movement', 'money_movement.id_money_movement = transfer.id_object');
    	$query->innerJoin('user', 'transfer.paid_by = user.id');
    	$query->orderBy(['transfer.created_at'  => SORT_ASC]);
    	$this->addQueryFilters($query);
    
    	$this->moneyMovements  = $query->all();

    	$count = count($this->moneyMovements);
    	for  ($i = 0; $i < $count ;$i++ ){
    		$this->moneyMovements[$i]['money_movement_type_name'] = MoneyMovement::typeName($this->moneyMovements[$i]['money_movement_type']);
    		$this->moneyMovements[$i]['money_movement_created_at'] = Yii::$app->formatter->asDatetime($this->moneyMovements[$i]['money_movement_created_at'], 'yyyy.MM.dd HH:mm:ss');
    		$this->moneyMovements[$i]['signed_money'] = Transfer::toSignedMoney($this->moneyMovements[$i]['transfer_direction'],$this->moneyMovements[$i]['money_movement_money']);
    	}
    }
    
    
}