rhymix/common/framework/drivers/sms/solapi.php

<?php

namespace Rhymix\Framework\Drivers\SMS;

/**
 * The Solapi SMS driver.
 */
class SolAPI extends Base implements \Rhymix\Framework\Drivers\SMSInterface
{
	private static $apiHost = 'https://api.solapi.com/';
	private static $solapiConfig = null;
	
	/**
	 * API specifications.
	 */
	protected static $_spec = array(
		'max_recipients'              => 1000,
		'sms_max_length'              => 90,
		'sms_max_length_in_charset'   => 'CP949',
		'lms_supported'               => true,
		'lms_supported_country_codes' => array(82),
		'lms_max_length'              => 2000,
		'lms_max_length_in_charset'   => 'CP949',
		'lms_subject_supported'       => true,
		'lms_subject_max_length'      => 40,
		'mms_supported'               => true,
		'mms_supported_country_codes' => array(82),
		'mms_max_length'              => 2000,
		'mms_max_length_in_charset'   => 'CP949',
		'mms_subject_supported'       => true,
		'mms_subject_max_length'      => 40,
		'image_allowed_types'         => array('jpg', 'gif', 'png'),
		'image_max_dimensions'        => array(2048, 2048),
		'image_max_filesize'          => 300000,
		'delay_supported'             => true,
	);

	/**
	 * Config keys used by this driver are stored here.
	 */
	protected static $_required_config = array('api_key', 'api_secret');
	protected static $_optional_config = array('sender_key');

	/**
	 * Check if the current SMS driver is supported on this server.
	 *
	 * This method returns true on success and false on failure.
	 *
	 * @return bool
	 */
	public static function isSupported()
	{
		return true;
	}

	/**
	 * Send a message.
	 *
	 * This method returns true on success and false on failure.
	 *
	 * @param array $messages
	 * @param object $original
	 * @return bool
	 */
	public function send(array $messages, \Rhymix\Framework\SMS $original)
	{
		//HACK(Rambo): static 에서 Config 를 사용할 일이 잇어서 static 맴버 변수에 다시 정의함.
		self::$solapiConfig = $this->_config;
		$groupId = self::createGroup();
		if(!$groupId)
		{
			return false;
		}
		
		$keyNumber = 0;
		$groupArray = array();
		foreach ($messages as $i => $message)
		{
			$options = new \stdClass;
			if ($this->_config['sender_key'])
			{
				$options->sender_key = $this->_config['sender_key'];
				$options->type = 'CTA';
			}
			else
			{
				$options->type = $message->type;
			}
			$options->from = $message->from;
			if (count($message->to) > 1)
			{
				$samePhone = true;
			}
			else
			{
				$sendToPhoneNumber = implode(',', $message->to);;
			}
			$options->to = $options->text = $message->content ?: $message->type;
			if ($message->delay && $message->delay > time())
			{
				$options->datetime = gmdate('YmdHis', $message->delay + (3600 * 9));
			}
			if ($message->country && $message->country != 82)
			{
				$options->country = $message->country;
			}
			if ($message->subject)
			{
				$options->subject = $message->subject;
			}
			else
			{
				if($message->type != 'SMS')
				{
					$options->subject = cut_str($message->content, 20);
				}
			}
			if ($message->image)
			{
				$output = self::uploadImage($message->image, $message->type);
				$options->imageId = $output->fileId;
			}

			if ($samePhone)
			{
				// HACK : PHP7.3 에서 $groupArray 에 Value 를 넣으니 기존에 먼저 추가한 값들이 바뀌는 문제 발생되어서 새로운 오브젝트를 따로 넣도록함
				$options = get_object_vars($options);
				foreach ($message->to as $key => $value)
				{
					$args = new \stdClass();
					foreach ($options as $kayName => $val)
					{
						$args->{$kayName} = $val;
					}
					$args->to = $value;
					$groupArray[$keyNumber] = $args;
					$keyNumber++;
				}
			}
			else
			{
				$options->to = $sendToPhoneNumber;
				$groupArray[$keyNumber] = $options;
				$keyNumber++;
			}
		}
		$jsonObject = new \stdClass();
		$jsonObject->messages = json_encode($groupArray);

		$result = json_decode(self::request("PUT", "messages/v4/groups/{$groupId}/messages", $jsonObject));
		if ($result->errorCount > 0)
		{
			return false;
		}
		$result = json_decode(self::request("POST", "messages/v4/groups/{$groupId}/send"));
		if ($result->status != 'SENDING')
		{
			return false;
		}
		
		return true;
	}

	/**
	 * Create header string for http protocol
	 * @param $config
	 * @return string
	 */
	private static function getHeader($config)
	{
		date_default_timezone_set('Asia/Seoul');
		$date = date('Y-m-d\TH:i:s.Z\Z', time());
		$salt = uniqid();
		$signature = hash_hmac('sha256', $date . $salt, $config['api_secret']);
		return "Authorization: HMAC-SHA256 apiKey={$config['api_key']}, date={$date}, salt={$salt}, signature={$signature}";
	}

	/**
	 * Create message group
	 * @return string : group id
	 */
	private static function createGroup()
	{
		$args = new \stdClass();
		$args->appId = 'PAOe9c8ftH8R';
		$result = self::request("POST", 'messages/v4/groups', $args);
		$groupId = json_decode($result)->groupId;
		return $groupId;
	}
	
	private static function uploadImage($imageDir, $type)
	{
		$path = $imageDir;
		$data = file_get_contents($path);
		$imageData = base64_encode($data);
		$jsonData = new \stdClass();
		$jsonData->file = $imageData;
		$jsonData->type = $type;
		$url = "storage/v1/files";
		return json_decode(self::request('POST', $url, $jsonData));
	}

	/**
	 * Request string message.
	 * @param $method
	 * @param $url
	 * @param bool $data
	 * @return bool|string
	 */
	private static function request($method, $url, $data = false)
	{
		$url = self::$apiHost . $url;
		$curl = curl_init();
		switch ($method)
		{
			case "POST":
				curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "POST");
				if ($data)
				{
					curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data));
				}
				break;
			case "PUT":
				curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "PUT");
				if ($data)
				{
					curl_setopt($curl, CURLOPT_POSTFIELDS, json_encode($data));
				}
				break;
			default:
				if ($data)
				{
					$url = sprintf("%s?%s", $url, http_build_query($data));
				}
		}
		curl_setopt($curl, CURLOPT_HTTPHEADER, array(self::getHeader(self::$solapiConfig), "Content-Type: application/json"));
		curl_setopt($curl, CURLOPT_URL, $url);
		curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
		if (curl_error($curl))
		{
			print curl_error($curl);
		}
		$result = curl_exec($curl);
		curl_close($curl);
		return $result;
	}
}