Context Navigation

source: pro-violet-viettel/sourcecode/application/modules/services/models/services_model.php @ 771

Last change on this file since 771 was 768, checked in by dungnv, 10 years ago

File size: 19.5 KB

Rev	Line
[499]	1	<?php if ( ! defined('BASEPATH')) exit('No direct script access allowed');
	2
[647]	3	if ( ! defined('_SBG_MO_REGISTER')) define('_SBG_MO_REGISTER', 'SUBSCR');
	4	if ( ! defined('_SBG_MO_REGISTER_FOR')) define('_SBG_MO_REGISTER_FOR', 'SUBSCR_FOR');
	5	if ( ! defined('_SBG_MO_PHONENUM_CHANGE')) define('_SBG_MO_PHONENUM_CHANGE', 'PHONE_CHANGE');
	6	if ( ! defined('_SBG_MO_PASSWORD_RECOVERY')) define('_SBG_MO_PASSWORD_RECOVERY', 'PWD_RECOVER');
	7	if ( ! defined('_SBG_MO_VIP_REGISTER')) define('_SBG_MO_VIP_REGISTER', 'REG_VIP');
	8	if ( ! defined('_SBG_MO_PAY_TO_ACCOUNT')) define('_SBG_MO_PAY_TO_ACCOUNT', 'PAY');
	9	if ( ! defined('_SBG_MO_PAY_TO_ACCOUNT_FOR')) define('_SBG_MO_PAY_TO_ACCOUNT_FOR', 'PAY_FOR');
	10	if ( ! defined('_SBG_MO_UNSUBSCRIBE_SERVICE')) define('_SBG_MO_UNSUBSCRIBE_SERVICE', 'UNSUBSCR');
	11	if ( ! defined('_SBG_MO_SUPPOR_SERVICE')) define('_SBG_MO_SUPPOR_SERVICE', 'SUPPORT');
	12	if ( ! defined('_SBG_MO_SYNTAX_ERR')) define('_SBG_MO_SYNTAX_ERR', 'SYNTAX_ERR');
[499]	13
[647]	14	if ( ! defined('_SBG_CARD_PAY_FAIL')) define('_SBG_CARD_PAY_FAIL', -1);
	15	if ( ! defined('_SBG_CARD_PAY_SUCCESS')) define('_SBG_CARD_PAY_SUCCESS', 1);
[499]	16
[647]	17	if ( ! defined('_SBG_CHARGING_FAIL')) define('_SBG_CHARGING_FAIL', -1);
	18	if ( ! defined('_SBG_CHARGING_SUCCESS')) define('_SBG_CHARGING_SUCCESS', 1);
	19	if ( ! defined('_SBG_CHARGING_FAIL_NOT_ENOUGH')) define('_SBG_CHARGING_FAIL_NOT_ENOUGH', 401);
	20	if ( ! defined('_SBG_CHARGING_FAIL_NOT_VIETTEL')) define('_SBG_CHARGING_FAIL_NOT_VIETTEL', 402);
	21	if ( ! defined('_SBG_CHARGING_NUMBER_NOT_EXISTED')) define('_SBG_CHARGING_NUMBER_NOT_EXISTED', 403);
	22	if ( ! defined('_SBG_CHARGING_NUMBER_NOT_AVAILABLE')) define('_SBG_CHARGING_NUMBER_NOT_AVAILABLE', 404);
	23	if ( ! defined('_SBG_CHARGING_NUMBER_CHANGED_OWNER')) define('_SBG_CHARGING_NUMBER_CHANGED_OWNER', 405);
	24	if ( ! defined('_SBG_CHARGING_FAIL_MORETHAN_LIMIT')) define('_SBG_CHARGING_FAIL_MORETHAN_LIMIT', 406);
	25	if ( ! defined('_SBG_CHARGING_GENERAL_ERROR')) define('_SBG_CHARGING_GENERAL_ERROR', 440);
	26	if ( ! defined('_SBG_CHARGING_NUMBER_NOT_REGISTED')) define('_SBG_CHARGING_NUMBER_NOT_REGISTED', 501);
[716]	27	if ( ! defined('_SBG_CHARGING_MAX_VALUE')) define('_SBG_CHARGING_MAX_VALUE', 50000);
[499]	28
[716]	29
[647]	30	if ( ! defined('_SBG_SEND_MT_FAIL')) define('_SBG_SEND_MT_FAIL', -1);
	31	if ( ! defined('_SBG_SEND_MT_SUCCESS')) define('_SBG_SEND_MT_SUCCESS', 1);
	32	if ( ! defined('_SBG_MT_SEND_NUMBER')) define('_SBG_MT_SEND_NUMBER', '841662860000');
	33	if ( ! defined('_SBG_MT_CP_CODE')) define('_SBG_MT_CP_CODE', '601');
[499]	34
[647]	35	if ( ! defined('_SBG_SERVICE_COMMAND_CODE')) define('_SBG_SERVICE_COMMAND_CODE', 'SBG');
	36	if ( ! defined('_SBG_SERVICE_SERVICEID')) define('_SBG_SERVICE_SERVICEID', '8062');
[598]	37
[647]	38	if ( ! defined('_SBG_MO_PROCCESS_ERR')) define('_SBG_MO_PROCCESS_ERR', 0);
[598]	39
[716]	40	if ( ! defined('_SBG_GET_COLLABORATOR_FAIL')) define('_SBG_GET_COLLABORATOR_FAIL', -1);
[685]	41
[499]	42	Class Services_model extends CI_Model
	43	{
	44	private $_arySmsMO = array(
[647]	45	_SBG_MO_REGISTER => array('pattern' => '/^(SBG)([[:blank:]])(DK)$/'),
	46	_SBG_MO_REGISTER_FOR => array('pattern' => '/^(SBG)([[:blank:]])(DK)([[:blank:]])([0-9]{10,11})$/'),
[707]	47	//_SBG_MO_PHONENUM_CHANGE => array('pattern' => '/^(SBG)([[:blank:]])(DDT)([[:blank:]])([0-9]{10,11})([[:blank:]])([a-zA-Z0-9]{1,})$/'),
[647]	48	_SBG_MO_PASSWORD_RECOVERY => array('pattern' => '/^(SBG)([[:blank:]])(MK)$/'),
	49	_SBG_MO_VIP_REGISTER => array('pattern' => '/^(SBG)([[:blank:]])(VIP)([[:blank:]])([a-zA-Z0-9]{1,})$/'),
	50	_SBG_MO_PAY_TO_ACCOUNT => array('pattern' => '/^(SBG)([[:blank:]])(NAP)([[:blank:]])([0-9]{3,})$/'),
	51	_SBG_MO_PAY_TO_ACCOUNT_FOR => array('pattern' => '/^(SBG)([[:blank:]])(NAP)([[:blank:]])([0-9]{3,})([[:blank:]])([0-9]{10,11})$/'),
	52	_SBG_MO_SUPPOR_SERVICE => array('pattern' => '/^(SBG)([[:blank:]])(HD)$/'),
	53	_SBG_MO_UNSUBSCRIBE_SERVICE => array('pattern' => '/^(SBG)([[:blank:]])(HUY)$/')
	54	);
[499]	55
	56	public function __construct(){
	57	parent::__construct();
[636]	58	$this->load->helper('language');
	59	$this->lang->load('messages', 'message');
[499]	60	}
	61
[647]	62	/**
	63	* messageAnalys
	64	*
	65	* @todo Analysis content of incoming message
	66	*
	67	* @param String $message - coming SMS
	68	* @return multitype:Ambigous <string, multitype> multitype:multitype
	69	*/
[579]	70	public function messageAnalys ($message)
[499]	71	{
[579]	72	$aryMatched = array();
	73	$aryContent = array();
[647]	74	$result = FALSE;
[579]	75
[647]	76	foreach ($this->_arySmsMO as $case => $pattern)
[499]	77	{
[647]	78	$result = preg_match($pattern['pattern'], strtoupper(trim($message)));
	79	if ((bool)$result) {
	80	$aryMatched = explode(' ', trim($message));
	81	break;
	82	}
[499]	83	}
	84
[647]	85	$case = (bool)$result ? $case:_SBG_MO_SYNTAX_ERR;
[583]	86
[647]	87	foreach($aryMatched as $k => $val) {
	88	if ($k > 1) $aryContent[] = $val;
[579]	89	}
[583]	90
[707]	91	return array('case' => $case, 'content' => $aryContent);
[499]	92	}
	93
[647]	94	/**
	95	* processMORequest
	96	*
	97	* @todo process action analysed from messageAnalys
	98	*
	99	* @param unknown $sentNumber
	100	* @param unknown $message
	101	* @return string
	102	*/
[768]	103	public function processMORequest ($sentNumber, $message, &$mtBody = null)
[499]	104	{
[513]	105	$debugMsg = $message."\n";
	106
[575]	107	$sentNumber = $this->formatPhoneNumber($sentNumber);
[499]	108
	109	$smsReturn = '';
	110	$aryMOAnalys = $this->messageAnalys($message);
	111	$case = $aryMOAnalys['case'];
	112	$aryContents = isset($aryMOAnalys['content']) ? $aryMOAnalys['content']: null;
	113	$this->load->model('frontend/user_model', 'objUserModel');
[513]	114	$debugMsg .= $case;
[615]	115
[499]	116	switch ($case) {
	117	case _SBG_MO_REGISTER:
	118	case _SBG_MO_REGISTER_FOR:
[583]	119	if ($case == _SBG_MO_REGISTER_FOR) {
[647]	120	if (!preg_match('/^([0-9]{10,11}$)$/', $aryContents[0])) {
[636]	121	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.lang('_SBG_MO_PHONENUM_WRONG_FORMAT_MSG');
[583]	122	break;
	123	}
	124	}
	125
[647]	126	$userName = isset($aryContents[0]) ? $this->formatPhoneNumber($aryContents[0]) : $sentNumber;
	127	$collaborator = isset($aryContents[0]) ? $sentNumber:null;
[579]	128	$collaboratorMsg = '';
[615]	129
[579]	130	$sms = $this->objUserModel->register($userName, $collaborator, $collaboratorMsg);
[707]	131
[528]	132	if ($case == _SBG_MO_REGISTER_FOR) {
[579]	133	$smsReturn = $collaboratorMsg;
[528]	134	$arySMS = explode ('\|', $sms);
[768]	135	if ((int)$arySMS[0] == 1 ) {
	136	$mtBody = $arySMS[1];
	137	$sendMT = $this->sendMT($this->formatPhoneNumber($userName, -1), $mtBody);
	138	}
	139
[528]	140	}
	141	else {
	142	$smsReturn = $sms;
	143	}
[707]	144
[499]	145	break;
[768]	146	/* case _SBG_MO_PHONENUM_CHANGE:
[647]	147	if (!preg_match('/^(09\d{8}\|01\d{9})$/', $aryContents[0])) {
[636]	148	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.lang('_SBG_MO_PHONENUM_WRONG_FORMAT_MSG');
[583]	149	break;
	150	}
[615]	151
[647]	152	$oldPhoneNumber = $this->formatPhoneNumber($aryContents[0]);
	153	$password = $aryContents[1];
[499]	154	$smsReturn = $this->objUserModel->changeProfile($sentNumber, $oldPhoneNumber, $password);
[615]	155
	156	$arySMS = explode('\|', $smsReturn);
	157	$changeResult = (int)$arySMS[0];
	158
[636]	159	$aryPatterns = array('/:sentNumber:/');
	160	$sms = preg_replace($aryPatterns, array($sentNumber), lang('_SBG_MO_USER_OLD_PHONENUM_CHANGE_SUCCESS_MSG'));
[615]	161	$sendMT = $changeResult == 1 ? $this->sendMT($this->formatPhoneNumber($oldPhoneNumber, -1), $sms) : '';
[768]	162	break; */
[499]	163	case _SBG_MO_PASSWORD_RECOVERY:
[647]	164	$smsReturn = $this->objUserModel->changePassword($sentNumber);
	165	break;
[499]	166	case _SBG_MO_VIP_REGISTER:
[707]	167	$packageData = array();
[647]	168	$p_code = $aryContents[0];
[707]	169	$smsReturn = $this->objUserModel->registerVip($sentNumber, $p_code, $packageData);
	170
	171	$arySmsReturn = explode('\|', $smsReturn);
	172	$result = $arySmsReturn[0];
	173
	174	if (trim($arySmsReturn[1]) == trim(lang('_SBG_MO_USER_REGISTER_VIP_FAIL_NOT_ENOUGH_MSG'))) {
[768]	175	$maxCharging = 50000;
[707]	176	$amount = $packageData ['p_price'];
[716]	177	$count = $amount > $maxCharging ? ceil($amount/ _SBG_CHARGING_MAX_VALUE) : 1;
	178	$value = 0;
	179	for ($i = 1; $i <= $count; $i++) {
	180	$value = $amount > _SBG_CHARGING_MAX_VALUE ? _SBG_CHARGING_MAX_VALUE : $amount;
	181	$amount -= $value;
	182	$result = $this->chargeRootAccountProcess($sentNumber, $value, $sentNumber.' paid for SBG');
	183	}
[707]	184
	185	if ($result == _SBG_CHARGING_SUCCESS) {
[716]	186	$amount = $packageData ['p_price'];
[707]	187	$this->objUserModel->rechargeAccount($sentNumber, $amount);
	188	$smsReturn = $this->objUserModel->registerVip($sentNumber, $p_code, $packageData);
	189	$paidTime = date('Y-m-d H:i:s');
	190	$this->objUserModel->insertPaidlog($sentNumber, $sentNumber, _SBG_PAIDTYPE_SMS, $amount, $paidTime);
	191	$result = 1;
	192	}
	193	}
	194
	195	if ((int)$result == 1) $this->objUserModel->insertRegisterVipLog($sentNumber, $p_code, true);
[499]	196	break;
[707]	197
[499]	198	case _SBG_MO_PAY_TO_ACCOUNT:
	199	case _SBG_MO_PAY_TO_ACCOUNT_FOR:
[716]	200	error_log(date('Y-m-d H:i:s').' -- DATA: '. var_export($aryContents, TRUE).' -- CASE: '. $case . "\n", 3, '/srv/www/sbg/log/pay.log');
[647]	201	$userName = isset($aryContents[1]) ? $this->formatPhoneNumber($aryContents[1]) : $sentNumber;
[612]	202	if ($case == _SBG_MO_PAY_TO_ACCOUNT_FOR && !preg_match('/^(09\d{8}\|01\d{9})$/', $userName)) {
[636]	203	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.lang('_SBG_MO_PHONENUM_WRONG_FORMAT_MSG');
[603]	204	break;
	205	}
	206
[647]	207	$amount = $aryContents[0];
[615]	208	if (!preg_match('/^[0-9]{3,}$/', $amount)) {
[636]	209	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.lang('_SBG_MO_AMOUNT_WRONG_FORMAT_MSG');
[615]	210	break;
	211	}
	212
[598]	213	$result =$this->chargeRootAccountProcess($sentNumber, $amount, $sentNumber.' paid for SBG');
	214
	215	if ($result == _SBG_CHARGING_SUCCESS) {
[499]	216	$smsReturn = $this->objUserModel->rechargeAccount($userName, $amount);
[598]	217	if ($case == _SBG_MO_PAY_TO_ACCOUNT_FOR) {
[579]	218	$arySmsReturn = explode ('\|', $smsReturn);
[653]	219	$aryPatterns = array('/:amount:/', '/:sentNumber:/');
	220	$smsMT = preg_replace($aryPatterns, array($amount, $sentNumber), lang('_SBG_MO_PAY_TO_ACCOUNT_FOR_MSG'));
[768]	221	$mtBody = $smsMT;
[579]	222	$sendMT = $this->sendMT($this->formatPhoneNumber($userName, -1), $smsMT);
[707]	223	$smsReturn = $arySmsReturn[0].'\|'.preg_replace(array('/:amount:/','/:username:/'), array($amount, $userName), lang('_SBG_MO_PAY_TO_ACCOUNT_FOR_OTHER_SUCCESS_MSG'));
[556]	224	}
[598]	225	//write to paid log
	226	$paidTime = date('Y-m-d H:i:s');
	227	$this->objUserModel->insertPaidlog($sentNumber, $userName, _SBG_PAIDTYPE_SMS, $amount, $paidTime);
[499]	228	}
[598]	229	else if ($result == _SBG_CHARGING_FAIL_NOT_ENOUGH) {
[653]	230	$aryPatterns = array ('/:amount:/');
	231	$smsReturn = preg_replace($aryPatterns, array($amount), lang('_SBG_MO_CHARGING_FAIL_NOT_ENOUGH_MSG'));
	232	if ($case == _SBG_MO_PAY_TO_ACCOUNT_FOR) {
	233	$aryPatterns = array ('/:amount:/', '/:username:/');
	234	$smsReturn = preg_replace($aryPatterns, array($amount, $userName), lang('_SBG_MO_CHARGING_FAIL_NOT_ENOUGH_FOR_MSG'));
	235	}
[636]	236	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.$smsReturn;
[598]	237	}
	238	else if ($result == _SBG_CHARGING_FAIL_MORETHAN_LIMIT) {
	239	$aryPatterns = array ('/:sendid:/');
[636]	240	$smsReturn = preg_replace($aryPatterns, array($sentNumber), lang('_SBG_MO_CHARGING_FAIL_MORETHAN_LIMIT_MSG'));
	241	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.$smsReturn;
[612]	242	}else if ($result == _SBG_CHARGING_FAIL_NOT_VIETTEL \|\| $result == _SBG_CHARGING_NUMBER_NOT_EXISTED \|\| $result == _SBG_CHARGING_NUMBER_NOT_AVAILABLE) {
[636]	243	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.lang('_SBG_MO_CHARGING_FAIL_NOT_VIETTEL_MSG');
[598]	244	}
	245	else {
[636]	246	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.lang('_SBG_MO_CHARGING_FAIL_MSG');
[598]	247	}
[499]	248	break;
[647]	249	case _SBG_MO_SUPPOR_SERVICE:
	250	$smsReturn = '1\|'.lang('_SBG_MO_SUPPORT_MSG');
	251	break;
[529]	252	case _SBG_MO_UNSUBSCRIBE_SERVICE:
[499]	253	case _SBG_MO_SYNTAX_ERR:
	254	default:
[636]	255	$smsReturn = _SBG_MO_PROCCESS_ERR.'\|'.lang('_SBG_MO_SYNTAX_ERR_MSG');
[499]	256	break;
	257	}
	258
[768]	259	$mtBody = $smsReturn . "\n" . $mtBody;
	260
[579]	261	return $smsReturn.'\|'.$case;
[499]	262	}
	263
[647]	264
	265	/**
	266	* cardPaidProcess
	267	*
	268	* @todo Call Topup webservice to check and lock prepaid-card
	269	* @param Array $aryCardInfo
	270	* @param Array $aryTopupResult
	271	* @return string
	272	*/
[506]	273	public function cardPaidProcess ($aryCardInfo, &$aryTopupResult = array())
[499]	274	{
	275	$url = $this->config->item('topup_service_url');
	276	$action = 'http://tempuri.org/ITopupService/TopUp';
	277	$xml = $this->load->view('topup', $aryCardInfo, true);
	278
	279	$client = new nusoap_client($url);
	280	$client->useHTTPPersistentConnection();
	281	$client->soap_defencoding = 'UTF-8';
	282	$client->operation = $action;
	283
[519]	284	$result = $client->send($xml, $action);
[499]	285
	286	if ($client->fault) {
	287	return _SBG_CARD_PAY_FAIL;
	288	}
	289
[528]	290	$keys = array_keys($result);
[499]	291
[528]	292	$aryTopupResult = $result[$keys[0]];
[632]	293
	294	$debugMsg = 'Logged time: '. date('Y-m-d H:i:s') ."\n";
	295	$debugMsg .= 'Send:'."\n" .$xml ."\n\n";
	296	$debugMsg .= 'Result:'."\n". var_export($result, TRUE);
	297	write_file('./log/topup_log', $debugMsg);
	298
[499]	299	if ($aryTopupResult['Success'] == 'false') {
	300	return _SBG_CARD_PAY_FAIL;
	301	}
	302
	303	return _SBG_CARD_PAY_SUCCESS;
	304	}
	305
[647]	306	/**
	307	* chargeRootAccountProcess
	308	*
	309	* @todo Call charging webservice to charged fee from phone root account
	310	* @param String $sentID
	311	* @param Integer $amount
	312	* @param String $contents
	313	* @return string\|number
	314	*/
[499]	315	public function chargeRootAccountProcess ($sentID, $amount = 0, $contents = '')
	316	{
	317	$url = $this->config->item('charging_service_url');
	318	$username = $this->config->item('charging_username');
	319	$password = $this->config->item('charging_password');
	320	$action = 'http://tempuri.org/processCharging';
	321
	322	$aryParams = array(
	323	'user' => $username,
	324	'pass' => $password,
	325	'MSISDN' => $sentID,
	326	'Charging' => $amount,
	327	'Contents' => $contents
	328	);
[707]	329
[499]	330	$xml = $this->load->view('charging', $aryParams, true);
	331	$client = new nusoap_client($url);
	332	$client->useHTTPPersistentConnection();
	333	$client->soap_defencoding = 'UTF-8';
	334	$client->operation = $action;
	335	$result = $client->send($xml, $action);
[629]	336
[499]	337	if ($client->fault) {
	338	return _SBG_CHARGING_FAIL;
	339	}
	340
[647]	341	$aryErrs = array ( _SBG_CHARGING_FAIL_NOT_ENOUGH,
	342	_SBG_CHARGING_FAIL_NOT_VIETTEL,
	343	_SBG_CHARGING_FAIL_MORETHAN_LIMIT,
	344	_SBG_CHARGING_NUMBER_NOT_EXISTED,
	345	_SBG_CHARGING_NUMBER_NOT_AVAILABLE,
	346	_SBG_CHARGING_NUMBER_CHANGED_OWNER,
	347	_SBG_CHARGING_GENERAL_ERROR,
	348	_SBG_CHARGING_NUMBER_NOT_REGISTED);
[499]	349
[598]	350	if (in_array((int)$result['processChargingResult'], $aryErrs))
	351	return (int)$result['processChargingResult'];
	352
[499]	353	return _SBG_CHARGING_SUCCESS;
	354	}
	355
[647]	356	/**
	357	* sendMT
	358	*
	359	* @todo Calling MT webservice to send a SMS to a phone number
	360	* @param String $receiverID
	361	* @param String $message
	362	* @return string
	363	*/
[499]	364	public function sendMT ($receiverID, $message)
	365	{
	366	$aryMatch = array();
[575]	367
[499]	368	if (preg_match('/^(0)([0-9]{9,10})$/', $receiverID, $aryMatch) == 1) {
	369	$receiverID = '84'. $aryMatch[2];
	370	}
	371
	372	$username = $this->config->item('mt_username');
	373	$password = $this->config->item('mt_password');
	374	$action = 'http://tempuri.org/InsertMT';
	375
	376	$aryParams = array(
	377	'User' => $username,
	378	'Pass' => $password,
	379	'CPCode' => _SBG_MT_CP_CODE,
	380	'UserID' => _SBG_MT_SEND_NUMBER,
	381	'RequestID' => '4',
	382	'ReceiverID' => $receiverID,
	383	'ServiceID' => _SBG_SERVICE_SERVICEID,
	384	'CommandCode' => _SBG_SERVICE_COMMAND_CODE,
	385	'ContentType' => '0',
	386	'Info' => $message
	387	);
	388
	389	$xml = $this->load->view('mt', $aryParams, true);
[513]	390	$url = $this->config->item('mt_service_url');
[499]	391	$client = new nusoap_client($url);
	392	$client->useHTTPPersistentConnection();
	393	$client->soap_defencoding = 'UTF-8';
	394	$client->operation = $action;
	395	$result = $client->send($xml, $action);
	396
	397	if ($client->fault \|\| (int)$result['InsertMTResult'] != 1) {
	398	return _SBG_SEND_MT_FAIL;
	399	}
	400
	401	return _SBG_SEND_MT_SUCCESS;
	402	}
[575]	403
[677]	404	public function getCollaborator ($type = 2, $page = 10, $displaypage = 1) {
	405	$action = 'http://tempuri.org/InsertMT';
	406	$url = $this->config->item('bccs_service_url');
	407	$username = $this->config->item('bccs_username');
	408	$password = $this->config->item('bccs_password');
	409	$wscode = 'getListShopAndStaftInfo';
	410	$aryParams = array(
	411	'user' => $username,
	412	'pass' => $password,
	413	'wscode' => $wscode,
	414	'type' => $type,
	415	'page' => $page,
	416	'displaypage' => $displaypage
	417	);
	418	$xml = $this->load->view('bscc', $aryParams, true);
	419
	420	$client = new nusoap_client($url);
	421	$client->useHTTPPersistentConnection();
	422	$client->soap_defencoding = 'UTF-8';
[685]	423	//$client->soap_defencoding = 'ISO-8859-1';
	424
[677]	425	$client->operation = $action;
	426	$result = $client->send($xml, $action);
[685]	427	if ($client->fault \|\| (int)$result['Result']['error'] != 0) {
	428	return _SBG_GET_COLLABORATOR_FAIL;
	429	}
	430
	431	return $result['Result']['original'];
[677]	432	}
	433
[647]	434	/**
	435	* formatPhoneNumber
	436	*
	437	* @todo format phone number to prefix 0 or 84
	438	* @param String $phoneNumber
	439	* @param Integer $direction
	440	* @return String
	441	*/
[579]	442	public function formatPhoneNumber ($phoneNumber, $direction = 1) {
[575]	443	$aryMatch = array();
[579]	444	if (preg_match('/^(84)([0-9]{9,10})$/', $phoneNumber, $aryMatch) == 1 && $direction == 1) {
[575]	445	$result = '0'. $aryMatch[2];
	446	}
[579]	447	else if (preg_match('/^(0)([0-9]{9,10})$/', $phoneNumber) == 1 && $direction == 1) {
[575]	448	$result = $phoneNumber;
	449	}
[579]	450	else if (preg_match('/^(84)([0-9]{9,10})$/', $phoneNumber) == 1 && $direction == -1) {
	451	$result = $phoneNumber;
	452	}
	453	else if (preg_match('/^(0)([0-9]{9,10})$/', $phoneNumber, $aryMatch) == 1 && $direction == -1) {
	454	$result = '84'. $aryMatch[2];
	455	}
[575]	456
	457	return $result;
	458	}
[688]	459
	460
	461	public function syncCollaborator($data){
	462	if ($data){
	463	$sql = $this->db->insert_string('tblcollaborator', $data) . ' ON DUPLICATE KEY UPDATE address = "'.$data['address'].'",
	464	code = "'.$data['code'].'",
	465	district = "'.$data['district'].'",
	466	email = "'.$data['email'].'",
	467	full_name = "'.$data['full_name'].'",
	468	cellphone = "'.$data['cellphone'].'",
	469	precinct = "'.$data['precinct'].'",
	470	province = "'.$data['province'].'",
[711]	471	created_time = "'.$data['created_time'].'",
[688]	472	updated_time = "'.$data['updated_time'].'"';
	473	$this->db->query($sql);
	474	$id = $this->db->insert_id();
	475	if ($this->db->affected_rows()){
[689]	476	//echo "Collaborator ID: ".$id.". Sync Success !<br/>";
	477	$logMsg = date('Y-m-d H:i:s') . " Collaborator ID: ".$id.". Sync Success !\n";
	478	write_file('./log/sync_collaborator.log', $logMsg, FOPEN_WRITE_CREATE);
[688]	479	}else{
[689]	480	//echo "Collaborator ID: ".$id.". Sync fail!. Sql = ".$sql."<br/>";
	481	$logMsg = date('Y-m-d H:i:s') . " Collaborator ID: ".$id.". Sync fail!. Sql = ".$sql."\n";
	482	write_file('./log/sync_collaborator.log', $logMsg, FOPEN_WRITE_CREATE);
[688]	483	}
	484	}else {
[689]	485	$logMsg = date('Y-m-d H:i:s') . " Data is null \n";
	486	write_file('./log/sync_collaborator.log', $logMsg, FOPEN_WRITE_CREATE);
[688]	487	}
	488	}
[717]	489
	490	public function deleteCollaborator($id){
	491	$sql = "DELETE FROM tblcollaborator WHERE id = ". $id;
	492	$this->db->query($sql);
	493	if ($this->db->affected_rows()){
[721]	494	$logMsg = date('Y-m-d H:i:s') . " Collaborator ID: ".$id.". Delete success!\n";
[717]	495	write_file('./log/delete_collaborator.log', $logMsg, FOPEN_WRITE_CREATE);
	496	}else{
[721]	497	$logMsg = date('Y-m-d H:i:s') . " Collaborator ID: ".$id.". Delete fail!. Sql = ".$sql."\n";
[717]	498	write_file('./log/delete_collaborator.log', $logMsg, FOPEN_WRITE_CREATE);
	499	}
	500	}
	501
	502	public function getAllCollaboratorID(){
	503	$sql = "Select id from tblcollaborator";
	504	$query = $this->db->query($sql);
	505	if ($this->db->affected_rows()){
	506	return $query->result();
	507	}else
	508	{
	509	return array();
	510	}
	511	}
[499]	512	}

Note: See TracBrowser for help on using the repository browser.

Download in other formats: