<?php

class Crunchbutton_Community_Shift extends Cana_Table {

	public function __construct($id = null) {
		parent::__construct();
		$this
			->table('community_shift')
			->idVar('id_community_shift')
			->load($id);
	}

	public function driversCouldDeliveryOrder( $id_order ){
		if( !$id_order ){
			return false;
		}

		$order = Order::o( $id_order );
		if( $order->restaurant()->timezone ){
			$now = new DateTime( 'now', new DateTimeZone( $order->restaurant()->timezone ) );	
		} else {
			$now = new DateTime( 'now', new DateTimeZone( c::config()->timezone ) );
		}
	
		return Admin::q( 'SELECT a.* FROM admin a 
												INNER JOIN admin_shift_assign asa ON asa.id_admin = a.id_admin 
												INNER JOIN community_shift cs ON cs.id_community_shift = asa.id_community_shift
												INNER JOIN restaurant_community rc ON rc.id_community = cs.id_community
												INNER JOIN `order` o ON o.id_restaurant = rc.id_restaurant
											WHERE o.id_order = ' . $id_order . ' AND cs.date_start <= "' . $now->format( 'Y-m-d H:i:s' ) . '" AND cs.date_end >= "' . $now->format( 'Y-m-d H:i:s' ) . '" AND cs.active = 1 ');
	}

	public function export(){
		$out = [];
		
		$out[ 'community' ] = array( 'id_community' => $this->id_community, 'name' => $this->community()->name );

		$out[ 'period' ] = array( 'toString' => $this->startEndToString(), 
															'day_start' => $this->dateStart()->format( 'M jS Y' ),
															'day_end' => $this->dateEnd()->format( 'M jS Y' ),
															'date_start' => $this->dateStart()->format( 'Y-m-d H:i:s' ),
															'date_end' => $this->dateEnd()->format( 'Y-m-d H:i:s' ),
															'timezone' => $this->timezone(),
															'timezone_abbr' => $this->timezoneAbbr() );

		$out[ 'period_pst' ] = array( 'toString' => $this->startEndToString( c::config()->timezone ), 
																	'day_start' => $this->dateStart( c::config()->timezone )->format( 'M jS Y' ),
																	'day_end' => $this->dateEnd( c::config()->timezone )->format( 'M jS Y' ),
																	'date_start' => $this->dateStart( c::config()->timezone )->format( 'Y-m-d H:i:s' ),
																	'date_end' => $this->dateEnd( c::config()->timezone )->format( 'Y-m-d H:i:s' ),
																	'timezone' => c::config()->timezone,
																	'timezone_abbr' => 'PST' );
		return $out;
	}

	public function nextShiftsByAdmin( $id_admin ){
		$now = new DateTime( 'now', new DateTimeZone( c::config()->timezone  ) );
		$query = 'SELECT cs.* FROM admin_shift_assign ass
								INNER JOIN community_shift cs ON cs.id_community_shift = ass.id_community_shift
								WHERE ass.id_admin = "' . $id_admin . '" AND 
									DATE_FORMAT( cs.date_start, "%Y-%m-%d" ) >= "' . $now->format( 'Y-m-d' )  . '" ORDER BY cs.date_start ASC  LIMIT 20';
		return Crunchbutton_Community_Shift::q( $query );
	}

	public function nextShiftsByCommunities( $communities ){
		if( count( $communities ) > 0 ){
			$now = new DateTime( 'now', new DateTimeZone( c::config()->timezone  ) );
			$now_formated = $now->format( 'Y-m-d' );
			$now->modify( '+ 7 days' );
			$next_days_formated = $now->format( 'Y-m-d' );
			$query = 'SELECT cs.* FROM community_shift cs 
									WHERE cs.id_community IN( ' . join( ',', $communities ) . ' ) AND
										DATE_FORMAT( cs.date_start, "%Y-%m-%d" ) >= "' . $now_formated  . '" AND 
										DATE_FORMAT( cs.date_start, "%Y-%m-%d" ) <= "' . $next_days_formated  . '"
									 ORDER BY cs.date_start ASC';
			return Crunchbutton_Community_Shift::q( $query );	
		}
		return false;
	}

	public function shiftsByDay( $date ){
		Crunchbutton_Community_Shift::createRecurringEvent( $date );
		return Crunchbutton_Community_Shift::q( 'SELECT cs.* FROM community_shift cs INNER JOIN community c ON c.id_community = cs.id_community WHERE DATE_FORMAT( cs.date_start, "%Y-%m-%d" ) = "' . $date . '" ORDER BY c.name, cs.date_start ASC' );
	}

	public function shiftsByCommunityPeriod( $id_community, $from, $to ){
		return Crunchbutton_Community_Shift::q( 'SELECT cs.* FROM community_shift cs WHERE DATE_FORMAT( cs.date_start, "%Y-%m-%d" ) >= "' . $from . '" AND DATE_FORMAT( cs.date_end, "%Y-%m-%d" ) <= "' . $to . '" AND id_community = "' . $id_community . '" ORDER BY cs.date_start ASC' );
	}

	public function week(){
		// Start week at monday #2666
		$date = DateTime::createFromFormat( 'Y-m-d H:i:s', $this->dateStart()->format( 'Y-m-d H:i:s' ), new DateTimeZone( $this->timezone() ) );	
		return $date->format( 'W' );
	}

	public function year(){
		// Start week at monday #2666
		$date = DateTime::createFromFormat( 'Y-m-d H:i:s', $this->dateStart()->format( 'Y-m-d H:i:s' ), new DateTimeZone( $this->timezone() ) );	
		return $date->format( 'Y' );
	}

	public function firstDayOfWeek(){
		// Start week at monday #2666
		$year = $this->year();
		$week = $this->week();
		return new DateTime( date( 'Y-m-d', strtotime( $year . 'W' . $week . 1 ) ), new DateTimeZone( c::config()->timezone  ) );
	}

	public function lastDayOfWeek(){
		// Start week at monday #2666
		$year = $this->year();
		$week = $this->week();
		$day = new DateTime( date( 'Y-m-d', strtotime( $year . 'W' . $week . 1 ) ), new DateTimeZone( c::config()->timezone  ) );
		$day->modify( '+ 6 day' );
		return $day;
	}

	public function isRecurring(){
		if( $this->recurringId() ){
			return true;
		}
	}

	public function recurringId(){
		if( $this->recurring ){
			return $this->id_community_shift;
		}
		if( $this->id_community_shift_father ){
			return $this->id_community_shift_father;
		}
		return false;
	}

	public function shiftByCommunityDay( $id_community, $date ){
		Crunchbutton_Community_Shift::createRecurringEvent( $date );
		return Crunchbutton_Community_Shift::q( 'SELECT * FROM community_shift WHERE id_community = "' . $id_community . '" AND DATE_FORMAT( date_start, "%Y-%m-%d" ) = "' . $date . '" AND active = 1 ORDER BY id_community_shift ASC' );
	}

	public function createRecurringEvent( $date ){
		// Search for recurring events
		$now =  new DateTime( 'now', new DateTimeZone( c::config()->timezone ) );
		$day =  new DateTime( $date, new DateTimeZone( c::config()->timezone ) );
		$weekday = $day->format( 'w' );
		$shifts = Crunchbutton_Community_Shift::q( 'SELECT * FROM community_shift WHERE recurring = 1 AND DATE_FORMAT( date_start, "%w" ) = "' . $weekday . '"' );
		// Create the recurring events
		foreach( $shifts as $shift ){
			if( $shift->dateStart()->format( 'Ymd' ) < $day->format( 'Ymd' ) ){
				$date_base = DateTime::createFromFormat( 'Y-m-d H:i:s', $date . ' 00:00:00', new DateTimeZone( c::config()->timezone ) );
				$hours = Crunchbutton_Admin_Hour::segmentToDate( $date_base, $shift->startEndToString(), $timezone );
				if( $hours ){
					// Check if the recurring event was already created
					$checkShift = Crunchbutton_Community_Shift::q( 'SELECT * FROM community_shift WHERE id_community_shift_father = ' . $shift->id_community_shift . ' AND date_start = "' . $hours[ 'start' ] . '" AND date_end = "' . $hours[ 'end' ] . '"' );
					if( !$checkShift->id_community_shift ){
						$newShift = new Crunchbutton_Community_Shift();
						$newShift->id_community = $shift->id_community;
						$newShift->date_start = $hours[ 'start' ];
						$newShift->date_end = $hours[ 'end' ];
						$newShift->active = 1;
						$newShift->id_community_shift_father = $shift->id_community_shift;
						if( $newShift->date_start && $newShift->date_end ){
							$newShift->save();	
						}

						// Create the permanent assigments
						$permanentlys = Crunchbutton_Admin_Shift_Assign_Permanently::getByShift( $shift->id_community_shift );
						foreach( $permanentlys as $permanently ){
							if( $permanently->id_admin ){
								$assignment = new Crunchbutton_Admin_Shift_Assign();
								$assignment->id_admin = $permanently->id_admin;
								$assignment->id_community_shift = $newShift->id_community_shift;
								$assignment->date = date('Y-m-d H:i:s');
								$assignment->save();
							}	
						}
					} else {

						if( $now < $checkShift->dateStart()->get( 0 ) ){
							// Create the permanent assigments
							$permanentlys = Crunchbutton_Admin_Shift_Assign_Permanently::getByShift( $shift->id_community_shift );
							foreach( $permanentlys as $permanently ){
								if( $permanently->id_admin ){
									if( !Crunchbutton_Admin_Shift_Assign::adminHasShift( $permanently->id_admin, $checkShift->id_community_shift ) ){
										$assignment = new Crunchbutton_Admin_Shift_Assign();
										$assignment->id_admin = $permanently->id_admin;
										$assignment->id_community_shift = $checkShift->id_community_shift;
										$assignment->date = date('Y-m-d H:i:s');
										$assignment->save();	
									}
								}	
							}
						}
					}
				}
			}
		}
	}

	public function shiftByCommunity( $id_community ){
		$weekdays = [ 'mon' =>  false, 'tue' =>  false, 'wed' =>  false, 'thu' =>  false, 'fri' =>  false, 'sat' =>  false, 'sun'  =>  false ];
		foreach( $weekdays as $day => $val ){
			$shifts = Crunchbutton_Community_Shift::q( 'SELECT * FROM community_shift WHERE id_community = "' . $id_community . '" AND day = "' . $day . '" ORDER BY id_community_shift ASC' );	
			$segment = [];
			foreach ( $shifts as $shift ) {
				$segment[] = Crunchbutton_Community_Shift::startEndToSegment( $shift->start, $shift->end );
			}
			$weekdays[ $day ] = join( ', ', $segment );
		}
		return $weekdays;
	}

	public function parseSegment( $segment ){
		$pattern = '@^ *(\d+)(?:\:(\d+))? *(am|pm) *(?:to|-) *(\d+)(?:\:(\d+))? *(am|pm) *$@i';
		preg_match( $pattern, $segment , $matches);
		$start = Crunchbutton_Community_Shift::parseHour( $matches[ 1 ], $matches[ 2 ], $matches[ 3 ] );
		$end = Crunchbutton_Community_Shift::parseHour( $matches[ 4 ], $matches[ 5 ], $matches[ 6 ] );
		return array( 'start' => $start, 'end' => $end );
	}

	public function community(){
		if( !$this->_community ){
			$this->_community = Crunchbutton_Community::o( $this->id_community );
		}
		return $this->_community;
	}

	public function removeRecurring( $id_community_shift ){
		$shift = Crunchbutton_Community_Shift::o( $id_community_shift );
		if( $shift->id_community_shift_father ){
			c::db()->query( "UPDATE community_shift SET recurring = 0 WHERE id_community_shift = " . $shift->id_community_shift_father );	
			Crunchbutton_Community_Shift::removeRecurringChildren( $shift->id_community_shift_father );
		}		
	}

	public function removeRecurringChildren( $id_community_shift_father ){
		$now =  new DateTime( 'now', new DateTimeZone( c::config()->timezone ) );
		c::db()->query( 'DELETE FROM community_shift WHERE id_community_shift_father = ' . $id_community_shift_father . ' AND date_start >= "' . $now->format( 'Y-m-d' ) . '"' );
	}

	public function remove( $id_community_shift ){
		$shift = Crunchbutton_Community_Shift::o( $id_community_shift );
		if( $shift->recurring ){
			// If it is a recurring remove its childen
			Crunchbutton_Community_Shift::removeRecurringChildren( $shift->id_community_shift );
		}
		// If it has a father, just desactive the event - to avoid it the be re created again
		if( $shift->id_community_shift_father ){
			c::db()->query( "UPDATE community_shift SET active = 0 WHERE id_community_shift = " . $id_community_shift );
		} else {
			c::db()->query( "DELETE FROM community_shift WHERE id_community_shift = " . $id_community_shift );
		}		
	}

	public function removeHoursFromDay( $id_community, $date ){
		return c::db()->query( "DELETE FROM community_shift WHERE id_community = $id_community AND DATE_FORMAT( date_start, '%Y-%m-%d' ) = '$date'" );
	}

	public function copyHoursFromTo( $id_community, $dayFrom, $dayTo ){
		$shifts = Crunchbutton_Community_Shift::shiftByCommunityDay( $id_community, $dayFrom );
		foreach( $shifts as $shift ){
			$date_start = DateTime::createFromFormat( 'Y-m-d H:i:s', $dayTo . ' ' . $shift->dateStart()->format( 'H:i:s' ), new DateTimeZone( $shift->timezone() ) );	
			$date_end = DateTime::createFromFormat( 'Y-m-d H:i:s', $dayTo . ' ' . $shift->dateEnd()->format( 'H:i:s' ), new DateTimeZone( $shift->timezone() ) );	
			$newShift = new Crunchbutton_Community_Shift();
			$newShift->id_community = $id_community;
			$newShift->date_start = $date_start->format( 'Y-m-d H:i:s' );
			$newShift->date_end = $date_end->format( 'Y-m-d H:i:s' );
			$newShift->active = 1;
			if( $newShift->date_start && $newShift->date_end ){
				$newShift->save();	
			}
		}
	}

	public function timezone(){
		if( !$this->_timezone ){
			$this->_timezone = $this->community()->timezone;
		}
		return $this->_timezone;
	}

	public function timezoneAbbr(){
		$dateTime = new DateTime(); 
		$dateTime->setTimeZone( new DateTimeZone( $this->timezone() ) ); 
		return $dateTime->format( 'T' ); 
	}

	public function dateStart( $timezone = false ){

		if( $timezone ){
			$date = $this->dateStart();
			$date->setTimezone( new DateTimeZone( $timezone ) );
			return $date;
		}

		if( !$this->_date_start ){
			$this->_date_start = DateTime::createFromFormat( 'Y-m-d H:i:s', $this->date_start, new DateTimeZone( $this->timezone() ) );	
		}
		return $this->_date_start;
	}

	public function dateEnd( $timezone = false ){
		
		if( $timezone ){
			$date = $this->dateEnd();
			$date->setTimezone( new DateTimeZone( $timezone ) );
			return $date;
		}

		if( !$this->_date_end ){
			$this->_date_end = DateTime::createFromFormat( 'Y-m-d H:i:s', $this->date_end, new DateTimeZone( $this->timezone() ) );	
		}
		return $this->_date_end;
	}

	public function startEndToString( $timezone = false ){
		$time = Crunchbutton_Community_Shift::timeToSegmentString( $this->dateStart( $timezone )->format( 'H:i' ) );
		$time .= ' - ';
		$time .= Crunchbutton_Community_Shift::timeToSegmentString( $this->dateEnd( $timezone )->format( 'H:i' ) );
		return trim( $time );
	}

	public function timeToSegmentString( $time ){
		$time = explode( ':' , $time );
		$hour = $time[0];
		$min  = $time[1];
		$separator = ':';
		$ampm = 'am';
		if( $hour > 12 ){
			$hour -= 12;
			$ampm = 'pm';
		}
		if( $hour == 0 ){
			$hour = 12;
		}
		if( intval( $min ) == 0 ){
			$min = '';
			$separator = '';
		}
		return intval( $hour ) . $separator . $min . $ampm;
	}

	public function dateStartFriendly( $timezone = false ){
		return $this->dateStart( $timezone )->format( 'M jS Y g:i A T' );
	}

	public function dateEndFriendly( $timezone = false ){
		return $this->dateEnd( $timezone )->format( 'M jS Y g:i A T' );
	}

	public function fullDate( $timezone = false ){
		return 'From ' . $this->dateStartFriendly( $timezone ) . ' to ' . $this->dateEndFriendly( $timezone ); 
	}

	public function parseHour( $hour, $min, $ampm ){
		if( strtolower( $ampm ) == 'pm' ){
			if( intval( $hour ) < 12 ){
				$hour += 12;
			}
		}
		if( $hour > 24 ){
			$hour -= 24;
		}
		if( trim( $min ) == '' ){
			$min = '00';
		}
		if( trim( $hour ) != '' ){
			return $hour . ':' . $min;	
		}
		return false;
	}

	public function getAdminPreferences(){
		return Crunchbutton_Admin_Shift_Preference::q( 'SELECT * FROM admin_shift_preference WHERE id_community_shift = ' . $this->id_community_shift . ' ORDER BY ranking  DESC' );
	}

	public function getAdminPreferencesByDriver( $id_admin ){
		return Crunchbutton_Admin_Shift_Preference::q( 'SELECT * FROM admin_shift_preference WHERE id_community_shift = ' . $this->id_community_shift . ' AND id_admin = ' . $id_admin . ' ORDER BY ranking  DESC' );
	}

	public function getDrivers(){
		return Crunchbutton_Admin::q( 'SELECT a.* FROM admin a INNER JOIN admin_shift_assign asa ON asa.id_admin = a.id_admin AND asa.id_community_shift = ' . $this->id_community_shift );
	}

	public function communitiesWithDeliveryService(){
		return Crunchbutton_Community::q( 'SELECT DISTINCT( c.id_community ) AS id, c.* FROM community c
																				INNER JOIN restaurant_community rc ON c.id_community = rc.id_community
																				INNER JOIN restaurant r ON r.id_restaurant = rc.id_restaurant AND r.delivery_service = 1 
																			ORDER BY c.name ASC' );
	}

	public function sendWarningToDrivers(){
echo '<pre>';var_dump( 1 );exit();
		$now = new DateTime( 'now', new DateTimeZone( c::config()->timezone  ) );
		if( $now->format( 'l' ) == 'Friday' ){
			$day = $now;	
		} else {
			$day = new DateTime( 'last friday', new DateTimeZone( c::config()->timezone  ) );
		}

		$day->modify( '+ 1 week' );

		$_week = $day->format( 'W' );
		$_year = $day->format( 'Y' );

		$from = new DateTime( $day->format( 'Y-m-d' ), new DateTimeZone( c::config()->timezone  ) );
		$day->modify( '+6 day' );
		$to = new DateTime( $day->format( 'Y-m-d' ), new DateTimeZone( c::config()->timezone  ) );

		$log = 'Starting the driver schedule verification period from ' . $from->format( 'Y-m-d' ) . ' to ' . $to->format( 'Y-m-d' ) . ' at ' . date( 'Y-m-d H:i:s l' );
		Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
		echo $log."\n";

		$warningDrivers = false;

		switch ( date( 'l' ) ) {
			case 'Monday':
				$driversMessage = 'Remember: update your Crunchbutton shift preferences for the driver week of ' . $from->format( 'm/d' ) . '-' . $to->format( 'm/d' ) . ' at cockpit._DOMAIN_/schedule. Due tonight at 5 PM PDT';
				$warningDrivers = true;
				$warningCS = false;
				break;
			case 'Friday':
			case 'Saturday':
			case 'Sunday':
				$driversMessage = 'Remember: update your Crunchbutton shift preferences for the driver week of ' . $from->format( 'm/d' ) . '-' . $to->format( 'm/d' ) . ' at cockpit._DOMAIN_/schedule. Don\'t leave us hanging :(';
				$warningDrivers = true;
				$warningCS = false;
				break;
			case 'Thursday':
				$driversMessage = 'Hey [name]! Please fill out your shift preferences for the driver week of ' . $from->format( 'm/d' ) . '-' . $to->format( 'm/d' ) . ' at cockpit._DOMAIN_/schedule. If you have any questions, just text us back.';
				$warningCS = true;
				$driversMessage = false;
				break;
			default:
				// Send the driver schedule remember notification every day morning #2924
				$driversMessage = 'Remember: update your Crunchbutton schedule for next week at cockpit._DOMAIN_/schedule. Don\'t leave us hanging :(';
				$warningDrivers = false;
				$warningCS = false;
				break;
		}

		$communitiesWithShift = [];
		$communitiesWithoutShift = [];

		$driversWillReceiveTheNotification = [];

		// Get the communities with active and delivery_service restaurants
		$communities = Crunchbutton_Community::q( 'SELECT DISTINCT( c.id_community ) AS id, c.* FROM community c INNER JOIN restaurant_community rc ON rc.id_community = c.id_community INNER JOIN restaurant r ON r.id_restaurant = rc.id_restaurant WHERE r.active = 1 AND r.delivery_service = 1 ORDER BY c.name' );
		foreach( $communities as $community ){

			// Check if the community has shift for current week
			$shifts = Crunchbutton_Community_Shift::shiftsByCommunityPeriod( $community->id_community, $from->format( 'Y-m-d' ), $to->format( 'Y-m-d' ) );
		
			$drivers = $community->getDriversOfCommunity();
			
			echo "\n";
			$log = $community->name . ' has ' .  $drivers->count() . ' drivers';
			Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
			echo $log."\n";
			echo "\n";

			foreach( $drivers as $driver ){

				$preferences = Crunchbutton_Admin_Shift_Status::getByAdminWeekYear( $driver->id_admin, $_week, $_year );

				$receiveSMS = $driver->getConfig( Crunchbutton_Admin::CONFIG_RECEIVE_DRIVER_SCHEDULE_SMS_WARNING );
				if( $receiveSMS->id_admin_config ){
					$receiveSMS = $receiveSMS->value;
				} else {
					$receiveSMS = false;
				}
				if( $receiveSMS ){
					$log = 'driver set up to RECEIVE sms: ' . $driver->name . ' - ' . $community->name;
					Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
					echo $log."\n";
					if( $preferences->completed == 0 ){
						$driversWillReceiveTheNotification[] = array(  'id_admin' => $driver->id_admin, 'name' => $driver->name, 'txt' => $driver->txt, 'phone' => $driver->phone );
					}
				} else {
					$log = 'driver set up to NOT receive sms: ' . $driver->name;
					Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
					echo $log."\n";
				}
			}
			if( $shifts->count() == 0 ){
				$communitiesWithoutShift[] = $community->name;
			}
		}
		echo "\n";
		$log = 'communitiesWithoutShift: ' . count( $communitiesWithoutShift ) . ', list ' . join( ', ', $communitiesWithoutShift );
		Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
		echo $log."\n";

		echo "\n";
		$log = 'driversWillReceiveTheNotification: ' . count( $driversWillReceiveTheNotification );
		Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
		echo $log."\n";

		$env = c::getEnv();

		$twilio = new Twilio( c::config()->twilio->{$env}->sid, c::config()->twilio->{$env}->token );

		// removed this sms for while

		if( false && count( $communitiesWithoutShift ) > 0 ){

			$message = "The following communities doesn't have shifts for the current week: " . join( ', ', $communitiesWithoutShift );
			
			$message = str_split( $message, 160 );

			foreach ( Crunchbutton_Support::getUsers() as $supportName => $supportPhone ) {
				$num = $supportPhone;
				foreach ( $message as $msg ) {
					if( $supportName != $admin->name ){
						try {
							// Log
							Log::debug( [ 'action' => 'community without shift warning', 'admin' => $supportName, 'num' => $num, 'msg' => $msg, 'type' => 'driver-schedule' ] );
							$twilio->account->sms_messages->create( c::config()->twilio->{$env}->outgoingTextCustomer, '+1'.$num, $msg );
						} catch (Exception $e) {
							// Log
							Log::debug( [ 'action' => 'ERROR: community without shift warning', 'admin' => $supportName, 'num' => $num, 'msg' => $msg, 'type' => 'driver-schedule' ] );
						}
					}
				}
			}
		}

		echo "\n";
		Log::debug( [ 'action' => 'notification sms', 'total' => count( $driversWillReceiveTheNotification ), 'type' => 'driver-schedule' ] );

		if( $warningCS && count( $driversWillReceiveTheNotification ) > 0 ){

			$message = count( $driversWillReceiveTheNotification ) . ' drivers didn\'t completed their schedule, the list of drivers is available here at cockpit._DOMAIN_/drivers/shift/status/shift';

			$message = str_split( $message, 160 );

			foreach ( Crunchbutton_Support::getUsers() as $supportName => $supportPhone ) {
				$num = $supportPhone;
				foreach ( $message as $msg ) {
					if( $supportName != $admin->name ){
						try {
							// Log
							Log::debug( [ 'action' => 'sending the drivers list', 'admin' => $supportName, 'num' => $num, 'msg' => $msg, 'type' => 'driver-schedule' ] );
							$log = 'Sending sms to: ' . $supportName . ' - ' . $supportPhone . ': ' . $msg;
							Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
							echo $log."\n";
							$twilio->account->sms_messages->create( c::config()->twilio->{$env}->outgoingTextCustomer, '+1'.$num, $msg );
						} catch (Exception $e) {
							// Log
							$log = 'Error Sending sms to: ' . $supportName . ' - ' . $supportPhone . ': ' . $msg;
							Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
							echo $log."\n";
							Log::debug( [ 'action' => 'ERROR: sending the drivers list', 'admin' => $supportName, 'num' => $num, 'msg' => $msg, 'type' => 'driver-schedule' ] );
						}
					}
				}
			}
		}

		if( $warningDrivers ){

			foreach( $driversWillReceiveTheNotification as $driver ){

				$id_admin = $driver[ 'id_admin' ];
				$name = $driver[ 'name' ];
				$txt = $driver[ 'txt' ];
				$phone = $driver[ 'phone' ];
				
				$message = str_replace( '[name]' , $name, $driversMessage );

				$num = ( $txt != '' ) ? $txt : $phone; 

				$message = str_split( $message, 160 );
				
				if( $num != '' ){
					foreach ( $message as $msg ) {
						try {
							// Log
							Log::debug( [ 'action' => 'sending sms', 'id_admin' => $id_admin, 'name' => $name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-schedule' ] );
							$twilio->account->sms_messages->create( c::config()->twilio->{ $env }->outgoingTextCustomer, '+1'.$num, $msg );
							$log = 'Sending sms to: ' . $name . ' - ' . $num . ': ' . $msg;
							Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
							echo $log."\n";
						} catch (Exception $e) {
							// Log
							Log::debug( [ 'action' => 'ERROR: sending sms', 'id_admin' => $id_admin, 'name' => $name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-schedule' ] );
							$log = 'Error Sending sms to: ' . $name . ' - ' . $num . ': ' . $msg;
							Log::debug( [ 'action' => $log, 'type' => 'driver-schedule' ] );
							echo $log."\n";
						}
					}
				} else {
					Log::debug( [ 'action' => 'ERROR: sending sms', 'id_admin' => $id_admin, 'name' => $name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-schedule' ] );
				}
			}
		}

		Crunchbutton_Community_Shift::remindDriversAboutTheirShiftTomorrow();

	}

	// remind drivers about their shift the day before their shift #2816
	function remindDriversAboutTheirShiftTomorrow(){

		echo "\n";
		$log = 'Starting the remind of tomorrow\'s shift';
		Log::debug( [ 'action' => $log, 'type' => 'driver-remind' ] );
		echo $log."\n";
		echo "\n";

		$env = c::getEnv();

		$twilio = new Twilio( c::config()->twilio->{$env}->sid, c::config()->twilio->{$env}->token );

		$now = new DateTime( 'now', new DateTimeZone( c::config()->timezone  ) );
		$now->modify( '+ 1 day' );
		$assigments = Crunchbutton_Admin_Shift_Assign::q( 'SELECT asa.* FROM admin_shift_assign asa INNER JOIN community_shift cs ON asa.id_community_shift = cs.id_community_shift  WHERE DATE_FORMAT( cs.date_start, "%Y-%m-%d" ) = "' . $now->format( 'Y-m-d' ) . '"' );
		foreach ( $assigments as $assignment ) {
	
			$shift = $assignment->shift();
			$admin = $assignment->admin();

			if( $shift && $admin ){
				$message = "Remember: you're scheduled to drive for Crunchbutton tomorrow, " . $now->format( 'M jS Y' ) . ", from " . $shift->startEndToString() . "\nRemember to charge your phone!";
				$txt = $admin->txt;
				$phone = $admin->phone;

				$num = ( $txt != '' ) ? $txt : $phone; 

				$message = str_split( $message, 160 );

				if( $num != '' ){
					foreach ( $message as $msg ) {
						try {
							// Log
							Log::debug( [ 'action' => 'sending remind sms', 'id_admin' => $admin->id_admin, 'name' => $admin->name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-remind' ] );
							$twilio->account->sms_messages->create( c::config()->twilio->{ $env }->outgoingTextCustomer, '+1'.$num, $msg );
							$log = 'Sending sms to: ' . $admin->name . ' - ' . $num . ': ' . $msg .'; shift_id: ' . $shift->id_community_shift;
							Log::debug( [ 'action' => $log, 'type' => 'driver-remind' ] );
							echo $log."\n";
						} catch (Exception $e) {
							// Log
							Log::debug( [ 'action' => 'ERROR: sending sms', 'id_admin' => $admin->id_admin, 'name' => $admin->name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-remind' ] );
							$log = 'Error Sending sms to: ' . $admin->name . ' - ' . $num . ': ' . $msg .'; shift_id: ' . $shift->id_community_shift;
							Log::debug( [ 'action' => $log, 'type' => 'driver-remind' ] );
							echo $log."\n";
						}
					}
				} else {
					Log::debug( [ 'action' => 'ERROR: sending remind sms', 'id_admin' => $admin->id_admin, 'name' => $admin->name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-remind' ] );
				}				
			}
		}
	}

	public function minutesToStart(){
		$now = new DateTime( 'now', new DateTimeZone( $this->timezone() ) );
		$diff = $now->diff( $this->dateStart() );
		return 	( $diff->i )
					+ ( $diff->h * 60 )
					+ ( $diff->d * 60 * 24 )
					+ ( $diff->m * 60 * 24 * 30 )
					+ ( $diff->y * 60 * 24 * 365 );
	}

	public function warningDriversBeforeTheirShift(){
			
		$env = c::getEnv();

		$twilio = new Twilio( c::config()->twilio->{$env}->sid, c::config()->twilio->{$env}->token );

		$minutes = 15;
		$communities = Crunchbutton_Community::q( 'SELECT DISTINCT( c.id_community ) AS id, c.* FROM community c INNER JOIN restaurant_community rc ON rc.id_community = c.id_community INNER JOIN restaurant r ON r.id_restaurant = rc.id_restaurant WHERE r.active = 1 AND r.delivery_service = 1 ORDER BY c.name' );
		
		foreach( $communities as $community ){
			
			if( $community->timezone ){
				$now = new DateTime( 'now', new DateTimeZone( $community->timezone ) );
				$now->modify( '- 5 minutes' );
				$_now = $now->format( 'Y-m-d H:i' );
				$now->modify( '+ ' . ( $minutes + 5 ) . ' minutes' );
				$_interval = $now->format( 'Y-m-d H:i' );
				$nextShifts = Crunchbutton_Community_Shift::q( 'SELECT DISTINCT( cs.id_community_shift ) AS id, cs.* FROM admin_shift_assign asa 
																													INNER JOIN community_shift cs ON cs.id_community_shift = asa.id_community_shift
																													WHERE DATE_FORMAT( cs.date_start, "%Y-%m-%d %H:%i" ) >= "' . $_now . '" AND DATE_FORMAT( cs.date_start, "%Y-%m-%d %H:%i" ) <= "' . $_interval . '" AND cs.id_community = "' . $community->id_community . '"' );
				if( $nextShifts->count() > 1 ){
					foreach( $nextShifts as $shift ){
						$assigments = Crunchbutton_Admin_Shift_Assign::q( 'SELECT * FROM admin_shift_assign asa WHERE id_community_shift = ' . $shift->id_community_shift . ' AND warned = 0' );
						foreach( $assigments as $assignment ){

							$shift = $assignment->shift();
							$admin = $assignment->admin();
							$minutesToStart = $shift->minutesToStart();
							if( $minutesToStart > 0 ){

								$message = 'Your shift starts in ' . $minutesToStart . ' minutes. Your shift(s) today, ' . $now->format( 'M jS Y' ) . ': ' . $shift->startEndToString() . '. If you have any questions/feedback for us, feel free to text us back!';

								$txt = $admin->txt;
								$phone = $admin->phone;

								$num = ( $txt != '' ) ? $txt : $phone; 

								$message = str_split( $message, 160 );

								if( $num != '' ){
									foreach ( $message as $msg ) {
										try {
											// Log
											Log::debug( [ 'action' => 'sending remind sms before shift', 'id_admin' => $admin->id_admin, 'name' => $admin->name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-remind' ] );
											$twilio->account->sms_messages->create( c::config()->twilio->{ $env }->outgoingTextCustomer, '+1'.$num, $msg );
											$log = 'Sending sms to: ' . $admin->name . ' - ' . $num . ': ' . $msg .'; shift_id: ' . $shift->id_community_shift;
											Log::debug( [ 'action' => $log, 'type' => 'driver-remind' ] );
											echo $log."\n";
											$assignment->warned = 1;
											$assignment->save();
										} catch (Exception $e) {
											// Log
											Log::debug( [ 'action' => 'ERROR: sending remind sms before shift', 'id_admin' => $admin->id_admin, 'name' => $admin->name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-remind' ] );
											$log = 'Error Sending sms to: ' . $admin->name . ' - ' . $num . ': ' . $msg .'; shift_id: ' . $shift->id_community_shift;
											Log::debug( [ 'action' => $log, 'type' => 'driver-remind' ] );
											echo $log."\n";
										}
									}
								} else {
									Log::debug( [ 'action' => 'ERROR: sending sms', 'id_admin' => $admin->id_admin, 'name' => $admin->name, 'num' => $num, 'msg' => $msg, 'type' => 'driver-remind' ] );
								}
							}
						}
					}					
				}
			}
		}
	}
}