|
Server : Apache System : Linux ruga7-004.fmcity.com 3.10.0-1160.119.1.el7.x86_64 #1 SMP Tue Jun 4 14:43:51 UTC 2024 x86_64 User : tkt_travelbus ( 1137) PHP Version : 7.0.0p1 Disable Function : mysql_pconnect Directory : /tkt_travelbus/www/Lib/ |
Upload File : |
<?
/////////////////////////////////////////////////////////////
// zend 처리
/////////////////////////////////////////////////////////////
function get_characterset_encoding($str) {
return mb_detect_encoding($str, "EUC-KR, UTF-8");
}
function characterset_encoding_utf8($str) {
return iconv(get_characterset_encoding($str), "utf-8", $str);
}
class PcaAccount {
public $CustomerID;
public $AccountNumber;
public $AccountName;
public $PhoneNumber;
public $BankCode;
function __construct($customerID, $accountNumber, $accountName, $phoneNumber, $bankCode) {
$this->CustomerID = $customerID;
$this->AccountNumber = $accountNumber;
$this->AccountName = $accountName;
$this->PhoneNumber = $phoneNumber;
$this->BankCode = $bankCode;
}
}
class TransferDataWS01C {
public $CustomerID;
public $UserID;
function __construct($customerID, $userID) {
$this->CustomerID = $customerID;
$this->UserID = $userID;
}
}
class TransferDataWS02C {
public $ActionMode;
public $AccountInfo;
function __construct($actionMode, $accountInfo) {
$this->ActionMode = $actionMode;
$this->AccountInfo = $accountInfo;
}
}
class TransferDataWS03C {
public $CustomerID;
public $UserID;
public $ActionMode;
function __construct($customerID, $userID, $actionMode) {
$this->CustomerID = $customerID;
$this->UserID = $userID;
$this->ActionMode = $actionMode;
}
}
class TransferDataWS11C {
public $CustomerID;
public $UserID;
function __construct($customerID, $userID) {
$this->CustomerID = $customerID;
$this->UserID = $userID;
}
}
class TransferDataWS31C {
public $CustomerID;
public $UserID;
public $EventCode;
public $EventName;
public $EventPersonName;
public $Content;
public $URL;
function __construct($customerID, $userID, $eventCode, $eventName, $eventPersonName, $content, $url) {
$this->CustomerID = $customerID;
$this->UserID = $userID;
$this->EventCode = $eventCode;
$this->EventName = characterset_encoding_utf8($eventName);
$this->EventPersonName = characterset_encoding_utf8($eventPersonName);
$this->Content = characterset_encoding_utf8($content);
$this->URL = $url;
}
}
class TransferDataWS51C {
public $CustomerID;
public $UserID;
public $BankCode;
public $BankName;
public $AccountNumber;
public $AccountName;
public $FlagInout;
public $InoutProvider;
public $InoutAmount;
function __construct($customerID, $userID, $bankCode, $bankName, $accountNumber, $accountName, $flagInout, $inoutProvider, $inoutAmount) {
$this->CustomerID = $customerID;
$this->UserID = $userID;
$this->BankCode = $bankCode;
$this->BankName = characterset_encoding_utf8($bankName);
$this->AccountNumber = $accountNumber;
$this->AccountName = characterset_encoding_utf8($accountName);
$this->FlagInout = $flagInout;
$this->InoutProvider = characterset_encoding_utf8($inoutProvider);
$this->InoutAmount = $inoutAmount;
}
}
function pca_socket_connect() {
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, array('sec' => 1, 'usec' => 0));
socket_set_option($socket, SOL_SOCKET, SO_SNDTIMEO, array('sec' => 1, 'usec' => 0));
if ($socket === false) {
socket_close($socket);
return false;
}
$result = socket_connect($socket, PCA_SERVER_IP, PCA_SERVER_PORT);
if ($result === false) {
socket_close($socket);
return false;
}
return $socket;
}
function pca_socket_disconnect($socket) {
socket_close($socket);
}
function pca_send_WS01($customer_id, $user_ids) {
$socket = pca_socket_connect();
if (!$socket) {
return;
}
$transfer_data = json_encode(array('CommandCode'=>"WS01", 'Data'=>new TransferDataWS01C($customer_id, $user_ids)));
socket_write($socket, $transfer_data, strlen($transfer_data));
///////////////////////////////////////////////////////////////////////////////////////////////////////
// 서버에서 전달해 주는 결과 이용하기
// $input = socket_read($socket, 1024) or die("Could not read from Socket\n");
// echo "결과 = " . $input;
// http://blog.naver.com/lunacastech/140166729096
////////////////////////////////////////////////////////////////////////////////////////////////////////
pca_socket_disconnect($socket);
}
function pca_send_WS02($action_mode, $customer_id, $account_number, $account_name, $phone_number, $bank_code) {
$return_value = "";
$socket = pca_socket_connect();
if ($socket) {
$account_info = new PcaAccount($customer_id, $account_number, $account_name, $phone_number, $bank_code);
$transfer_data = json_encode(array('CommandCode'=>"WS02", 'Data'=>new TransferDataWS02C($action_mode, $account_info)));
socket_write($socket, $transfer_data, strlen($transfer_data));
$return_value = socket_read($socket, 1024);
//deanLog("return_value", $return_value, "k1");
pca_socket_disconnect($socket);
}
return $return_value;
}
function pca_send_WS03($customer_id, $user_id, $action_mode) {
$return_value = "";
$socket = pca_socket_connect();
if ($socket) {
$transfer_data = json_encode(array('CommandCode'=>"WS03", 'Data'=>new TransferDataWS03C($customer_id, $user_id, $action_mode)));
socket_write($socket, $transfer_data, strlen($transfer_data));
$return_value = socket_read($socket, 1024);
//deanLog("return_value", $return_value, "k1");
pca_socket_disconnect($socket);
}
return $return_value;
}
function pca_send_WS11($customer_id, $user_id) {
$socket = pca_socket_connect();
if (!$socket) {
return;
}
$transfer_data = json_encode(array('CommandCode'=>"WS11", 'Data'=>new TransferDataWS11C($customer_id, $user_id)));
socket_write($socket, $transfer_data, strlen($transfer_data));
///////////////////////////////////////////////////////////////////////////////////////////////////////
// 서버에서 전달해 주는 결과 이용하기
// $input = socket_read($socket, 1024) or die("Could not read from Socket\n");
// echo "결과 = " . $input;
// http://blog.naver.com/lunacastech/140166729096
////////////////////////////////////////////////////////////////////////////////////////////////////////
pca_socket_disconnect($socket);
}
function pca_send_WS31($customer_id, $event_code, $event_person_name="", $content="", $url="") {
$socket = pca_socket_connect();
if (!$socket) {
return;
}
// 디비검색을 통해 해당 event_name 를 할당.
$sql = "select name from TB_PCA_ALIM_EVENT where code = '{$event_code}'";
//deanLog("sql", $sql, "k1");
$row = db_fetch($sql);
$event_name = $row['name'];
// 디비검색을 통해 해당 event_code 에 해당되는 user_id 를 ||| 분리문자열과 합쳐서 user_ids 를 만듬.
$user_ids = "";
$sql = "select mb_id from TB_PCA_ALIM_MEMBER where event_code = '{$event_code}'";
//deanLog("sql", $sql, "k1");
$rs = db_query($sql);
while ($row = db_fetch_array($rs)) {
// TB_PCA_ALIM_LOG insert
$sql = "insert TB_PCA_ALIM_LOG set ";
$sql .= "send_date = curdate(), ";
$sql .= "send_time = curtime(), ";
$sql .= "mb_id = '{$row['mb_id']}', ";
$sql .= "event_code = '{$event_code}', ";
$sql .= "event_name = '{$event_name}', ";
$sql .= "event_person_name = '{$event_person_name}', ";
$sql .= "content = '{$content}', ";
$sql .= "url = '{$url}'";
//deanLog("sql", $sql, "k1");
$result = db_query($sql);
$user_ids .= $row['mb_id'] . PCA_DIVISION_STRING;
//deanLog("user_ids", $user_ids, "k1");
}
$transfer_data = json_encode(array('CommandCode'=>"WS31", 'Data'=>new TransferDataWS31C($customer_id, $user_ids, $event_code, $event_name, $event_person_name, $content, $url)));
socket_write($socket, $transfer_data, strlen($transfer_data));
pca_socket_disconnect($socket);
}
function pca_send_WS51($customer_id, $bank_code, $bank_name, $account_number, $account_name, $flag_inout, $inout_provider, $inout_amount) {
$socket = pca_socket_connect();
if (!$socket) {
return;
}
// 디비검색을 통해 해당 event_code 에 해당되는 user_id 를 ||| 분리문자열과 합쳐서 user_ids 를 만듬.
$user_ids = "";
$sql = "select mb_id from TB_PCA_ACCOUNT_MEMBER where account_number = '{$account_number}' and flag_inout = '{$flag_inout}'";
//deanLog("sql", $sql, "k1");
$rs = db_query($sql);
while ($row = db_fetch_array($rs)) {
// TB_PCA_ALIM_LOG insert
$sql = "insert TB_PCA_ACCOUNT_LOG set ";
$sql .= "send_date = curdate(), ";
$sql .= "send_time = curtime(), ";
$sql .= "mb_id = '{$row['mb_id']}', ";
$sql .= "bank_code = '{$bank_code}', ";
$sql .= "bank_name = '{$bank_name}', ";
$sql .= "account_number = '{$account_number}', ";
$sql .= "account_name = '{$account_name}', ";
$sql .= "flag_inout = '{$flag_inout}', ";
$sql .= "inout_provider = '{$inout_provider}', ";
$sql .= "inout_amount = '{$inout_amount}'";
deanLog("sql", $sql, "k1");
$result = db_query($sql);
$user_ids .= $row['mb_id'] . PCA_DIVISION_STRING;
//deanLog("user_ids", $user_ids, "k1");
}
$transfer_data = json_encode(array('CommandCode'=>"WS51", 'Data'=>new TransferDataWS51C($customer_id, $user_ids, $bank_code, $bank_name, $account_number, $account_name, $flag_inout, $inout_provider, $inout_amount)));
socket_write($socket, $transfer_data, strlen($transfer_data));
pca_socket_disconnect($socket);
}
?>