Context Navigation

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

Last change on this file since 689 was 689, checked in by namnd, 10 years ago

File size: 17.0 KB

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

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

Download in other formats: