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

Last change on this file since 584 was 583, checked in by dungnv, 11 years ago
File size: 11.9 KB
Line 
1<?php if ( ! defined('BASEPATH')) exit('No direct script access allowed');
2
3if ( ! defined('_SBG_MO_REGISTER')) define('_SBG_MO_REGISTER', 0);
4if ( ! defined('_SBG_MO_REGISTER_FOR')) define('_SBG_MO_REGISTER_FOR', 1);
5if ( ! defined('_SBG_MO_PHONENUM_CHANGE')) define('_SBG_MO_PHONENUM_CHANGE', 2);
6if ( ! defined('_SBG_MO_PASSWORD_RECOVERY')) define('_SBG_MO_PASSWORD_RECOVERY', 3);
7if ( ! defined('_SBG_MO_PASSWORD_CHANGE')) define('_SBG_MO_PASSWORD_CHANGE', 4);
8if ( ! defined('_SBG_MO_VIP_REGISTER')) define('_SBG_MO_VIP_REGISTER', 5);
9if ( ! defined('_SBG_MO_PAY_TO_ACCOUNT')) define('_SBG_MO_PAY_TO_ACCOUNT', 6);
10if ( ! defined('_SBG_MO_PAY_TO_ACCOUNT_FOR')) define('_SBG_MO_PAY_TO_ACCOUNT_FOR', 7);
11if ( ! defined('_SBG_MO_UNSUBSCRIBE_SERVICE')) define('_SBG_MO_UNSUBSCRIBE_SERVICE', 8);
12
13if ( ! defined('_SBG_MO_SYNTAX_ERR')) define('_SBG_MO_SYNTAX_ERR', -1);
14if ( ! defined('_SBG_MO_SYNTAX_ERR_MSG')) define('_SBG_MO_SYNTAX_ERR_MSG', 'soanbaigiang.smas.vn khong co dich vu nay!');
15
16if ( ! defined('_SBG_CARD_PAY_FAIL')) define('_SBG_CARD_PAY_FAIL', -1);
17if ( ! defined('_SBG_CARD_PAY_SUCCESS')) define('_SBG_CARD_PAY_SUCCESS', 1);
18
19if ( ! defined('_SBG_CHARGING_FAIL')) define('_SBG_CHARGING_FAIL', -1);
20if ( ! defined('_SBG_CHARGING_SUCCESS')) define('_SBG_CHARGING_SUCCESS', 1);
21
22if ( ! defined('_SBG_CHARGING_FAIL_NOT_ENOUGH')) define('_SBG_CHARGING_FAIL_NOT_ENOUGH', 401);
23if ( ! defined('_SBG_CHARGING_FAIL_NOT_ENOUGH_MSG')) define('_SBG_CHARGING_FAIL_NOT_ENOUGH_MSG', 'Tai khoan chinh cua so dien thoai :sendid: khong du de thuc hien lenh nap :amount: vao tai khoan :username: tren soanbaigiang.smas.vn');
24
25if ( ! defined('_SBG_SEND_MT_FAIL')) define('_SBG_SEND_MT_FAIL', -1);
26if ( ! defined('_SBG_SEND_MT_SUCCESS')) define('_SBG_SEND_MT_SUCCESS', 1);
27
28if ( ! defined('_SBG_MT_SEND_NUMBER')) define('_SBG_MT_SEND_NUMBER', '841662860000');
29if ( ! defined('_SBG_MT_CP_CODE')) define('_SBG_MT_CP_CODE', '601');
30
31if ( ! defined('_SBG_SERVICE_COMMAND_CODE')) define('_SBG_SERVICE_COMMAND_CODE', 'SBG');
32if ( ! defined('_SBG_SERVICE_SERVICEID')) define('_SBG_SERVICE_SERVICEID', '8062');
33
34Class Services_model extends CI_Model
35{
36        private $_arySmsMO = array(
37                _SBG_MO_REGISTER                        => array('pattern' => '/^(SBG[[:blank:]])(DK)$/'),
38                _SBG_MO_REGISTER_FOR            => array('pattern' => '/^(SBG[[:blank:]])(DK)([[:blank:]][0-9]{10,11})$/'),
39                _SBG_MO_PHONENUM_CHANGE         => array('pattern' => '/^(SBG[[:blank:]])(DDT)([[:blank:]][0-9]{10,11})([[:blank:]][a-zA-Z0-9~!@#$%^&*]{4,16})$/'),
40                _SBG_MO_PASSWORD_RECOVERY       => array('pattern' => '/^(SBG[[:blank:]])(MK)$/'),
41                _SBG_MO_PASSWORD_CHANGE         => array('pattern' => '/^(SBG[[:blank:]])(MK)([[:blank:]][a-zA-Z0-9~!@#$%^&*]{4,16})$/'),
42                _SBG_MO_VIP_REGISTER            => array('pattern' => '/^(SBG[[:blank:]])(VIP)([[:blank:]][0-9]{1,2})$/'),
43                _SBG_MO_PAY_TO_ACCOUNT          => array('pattern' => '/^(SBG[[:blank:]])(NAP)([[:blank:]][0-9]{3,})$/'),
44                _SBG_MO_PAY_TO_ACCOUNT_FOR      => array('pattern' => '/^(SBG[[:blank:]])(NAP)([[:blank:]][0-9]{3,})([[:blank:]][0-9]{10,11})$/'),
45                _SBG_MO_UNSUBSCRIBE_SERVICE => array('pattern' => '/^(SBG[[:blank:]])(HUY)$/')
46        );
47       
48        private $_arySmsService = array(
49                        'DK' => _SBG_MO_REGISTER_FOR,
50                        'DDT' => _SBG_MO_PHONENUM_CHANGE,
51                        'NAP' => _SBG_MO_PAY_TO_ACCOUNT_FOR,
52        );     
53       
54        public function __construct(){
55                parent::__construct();
56        }
57       
58        public function messageAnalys ($message)
59        {
60                $aryMatched = array(); 
61                $aryContent = array();
62                $result = false;
63               
64                foreach ($this->_arySmsMO as $key => $pattern)
65                {
66                        $result = preg_match_all ($pattern['pattern'], strtoupper($message), $aryMatched);
67                        if ((bool)$result) break;
68                }
69               
70                $key = (bool)$result ? $key:_SBG_MO_SYNTAX_ERR;
71               
72                if (count ($aryMatched) > 0) {
73                        foreach ($aryMatched as $k => $val) {
74                                if ($k == 0) continue;
75                                $aryContent[] = trim($val[0]);                 
76                        }
77                }
78       
79                if ((bool)$result == FALSE) {
80                        $aryContent = array();
81                        foreach(explode(' ',strtoupper($message)) as $k => $val) {
82                                $aryContent[] = $val;
83                        }
84                        $key = $this->_arySmsService[$aryContent[1]];
85                        $result = 1;
86                }
87               
88                if ($key == _SBG_MO_PASSWORD_CHANGE || $key == _SBG_MO_PHONENUM_CHANGE) {
89                        $index = $key == _SBG_MO_PASSWORD_CHANGE ? 2 : 3;
90                        $upcasePass = $aryContent[$index];
91                        $password = substr($message, -strlen($upcasePass));
92                        $aryContent[$index] = $password;
93                }
94                       
95                $aryResult = (bool)$result ? array('case' => $key, 'content' => $aryContent):array('case' => $key);
96                return $aryResult;
97        }
98       
99        public function processMORequest ($sentNumber,$message)
100        {
101                $debugMsg = $message."\n";
102               
103                $sentNumber = $this->formatPhoneNumber($sentNumber);
104               
105                $smsReturn = '';
106                $aryMOAnalys = $this->messageAnalys($message);         
107                $case = $aryMOAnalys['case'];
108                $aryContents = isset($aryMOAnalys['content']) ? $aryMOAnalys['content']: null;
109                $debugMsg .= var_export($aryMOAnalys);
110                $this->load->model('frontend/user_model', 'objUserModel');
111                $debugMsg .= $case;
112                write_file('mt_log', $debugMsg);
113                switch ($case) {
114                        case _SBG_MO_REGISTER:
115                        case _SBG_MO_REGISTER_FOR:
116                                if ($case == _SBG_MO_REGISTER_FOR) {
117                                        if (!preg_match('/^([0-9]{10,11}$)$/', $aryContents[2])) {
118                                                $smsReturn = '0|So dien thoai khach hang khong hop le';
119                                                break;
120                                        }
121                                }
122                               
123                                $userName = isset($aryContents[2]) ? $this->formatPhoneNumber($aryContents[2]) : $sentNumber; 
124                                $collaborator = isset($aryContents[2]) ? $sentNumber:null;
125                                $collaboratorMsg = '';
126                                $sms = $this->objUserModel->register($userName, $collaborator, $collaboratorMsg);
127                                if ($case == _SBG_MO_REGISTER_FOR) {
128                                        $smsReturn = $collaboratorMsg;
129                                        $arySMS = explode ('|', $sms);
130                                        if ((int)$arySMS[0] == 1 )
131                                                $sendMT = $this->sendMT($this->formatPhoneNumber($userName, -1), $arySMS[1]);
132                                }
133                                else {
134                                        $smsReturn = $sms;
135                                }
136                                break;
137                        case _SBG_MO_PHONENUM_CHANGE:
138                               
139                                if (!preg_match('/^([0-9]{10,11}$)$/', $aryContents[2])) {
140                                        $smsReturn = '0|So dien thoai khach hang khong hop le';
141                                        break;
142                                }
143                               
144                                $oldPhoneNumber = $this->formatPhoneNumber($aryContents[2]);
145                                $password = $aryContents[3];
146                                $smsReturn = $this->objUserModel->changeProfile($sentNumber, $oldPhoneNumber, $password);
147                                $arySMS = explode ('|', $smsReturn);
148                                $sendMT = $this->sendMT($this->formatPhoneNumber($oldPhoneNumber, -1), $arySMS[1]);
149                               
150                                break;
151                        case _SBG_MO_PASSWORD_RECOVERY:
152                        case _SBG_MO_PASSWORD_CHANGE:
153                                $password = isset($aryContents[2]) ? $aryContents[2] : null;
154                                $smsReturn = $this->objUserModel->changePassword($sentNumber, $password);
155                                break;                                         
156                        case _SBG_MO_VIP_REGISTER:
157                                $p_code = $aryContents[2];
158                                $smsReturn = $this->objUserModel->registerVip($sentNumber, $p_code);
159                                break;
160                        case _SBG_MO_PAY_TO_ACCOUNT:
161                        case _SBG_MO_PAY_TO_ACCOUNT_FOR:
162                                $userName = isset($aryContents[3]) ? $this->formatPhoneNumber($aryContents[3]) : $sentNumber;
163                                $amount = $aryContents[2];
164                                $result =$this->chargeRootAccountProcess($sentNumber, $amount);
165                                if ($result == _SBG_CHARGING_FAIL_NOT_ENOUGH) {
166                                        $aryPatterns = array ('/:sendid:/', '/:amount:/', '/:username:/');
167                                        $smsReturn = preg_replace($aryPatterns, array($sentNumber, $amount, $userName), _SBG_CHARGING_FAIL_NOT_ENOUGH_MSG);
168                                        $smsReturn = '0|'.$smsReturn;
169                                }
170                                else {
171                                        $smsReturn = $this->objUserModel->rechargeAccount($userName, $amount);
172                                        if (_SBG_MO_PAY_TO_ACCOUNT_FOR) {
173                                                $arySmsReturn = explode ('|', $smsReturn);
174                                                $smsMT = $arySmsReturn[1] .' tu thue bao '. $sentNumber;
175                                                $sendMT = $this->sendMT($this->formatPhoneNumber($userName, -1), $smsMT);
176                                        }
177                                }
178                               
179                                //write to paid log
180                                $paidTime = date('Y-m-d H:i:s');
181                                $this->objUserModel->insertPaidlog($sentNumber, $userName, _SBG_PAIDTYPE_SMS, $amount, $paidTime);
182                                break;
183                        case _SBG_MO_UNSUBSCRIBE_SERVICE:
184                        case _SBG_MO_SYNTAX_ERR:
185                        default:
186                                $smsReturn = '0|'._SBG_MO_SYNTAX_ERR_MSG;
187                                break;
188                }
189               
190                return $smsReturn.'|'.$case;
191        }
192       
193        public function cardPaidProcess ($aryCardInfo, &$aryTopupResult = array())
194        {
195                /*
196            ["BalanceAfterTransaction"]=>
197            string(1) "0"
198            ["ErrorCode"]=>
199            string(3) "199"
200            ["ErrorMessage"]=>
201            string(29) "L?i exception Payment service"
202            ["LastLockedOutDate"]=>
203            string(19) "0001-01-01T00:00:00"
204            ["RemainTimeToUnLock"]=>
205            string(1) "0"
206            ["Success"]=>
207            string(5) "false"
208            ["TransactionAmount"]=>
209            string(1) "0"
210            ["TransactionID"]=>
211            string(1) "0"
212            ["TransactionTime"]=>
213            string(19) "0001-01-01T00:00:00"
214        */
215                $url = $this->config->item('topup_service_url');
216                $action = 'http://tempuri.org/ITopupService/TopUp';
217                $xml = $this->load->view('topup', $aryCardInfo, true);
218               
219                $client = new nusoap_client($url);
220                $client->useHTTPPersistentConnection();
221                $client->soap_defencoding = 'UTF-8';
222                $client->operation = $action;
223               
224                $result = $client->send($xml, $action);
225               
226                if ($client->fault) {
227                        return _SBG_CARD_PAY_FAIL;
228                }
229               
230                $keys = array_keys($result);
231               
232                $aryTopupResult = $result[$keys[0]];
233               
234                if ($aryTopupResult['Success'] == 'false') {
235                        return _SBG_CARD_PAY_FAIL;
236                }
237               
238                return _SBG_CARD_PAY_SUCCESS;
239        }
240       
241        public function chargeRootAccountProcess ($sentID, $amount = 0, $contents = '')
242        {
243                $url = $this->config->item('charging_service_url');
244                $username = $this->config->item('charging_username');
245                $password = $this->config->item('charging_password');
246                $action = 'http://tempuri.org/processCharging';         
247               
248                $aryParams = array(
249                                'user' => $username,
250                                'pass' => $password,
251                                'MSISDN' => $sentID,
252                                'Charging' => $amount,
253                                'Contents' => $contents
254                );
255               
256                $xml = $this->load->view('charging', $aryParams, true);
257                $client = new nusoap_client($url);
258                $client->useHTTPPersistentConnection();
259                $client->soap_defencoding = 'UTF-8';
260                $client->operation = $action;
261                $result = $client->send($xml, $action);
262               
263                if ($client->fault) {
264                        return _SBG_CHARGING_FAIL;
265                }
266               
267                if ((int)$result['processChargingResult'] == _SBG_CHARGING_FAIL_NOT_ENOUGH)
268                        return _SBG_CHARGING_FAIL_NOT_ENOUGH;
269               
270                return _SBG_CHARGING_SUCCESS;
271        }
272       
273        public function sendMT ($receiverID, $message)
274        {
275                $aryMatch = array();
276               
277                if (preg_match('/^(0)([0-9]{9,10})$/', $receiverID, $aryMatch) == 1) {
278                        $receiverID = '84'. $aryMatch[2];
279                }
280               
281                $username = $this->config->item('mt_username');
282                $password = $this->config->item('mt_password');
283                $action = 'http://tempuri.org/InsertMT';
284               
285                $aryParams = array(
286                                'User' => $username,
287                                'Pass' => $password,
288                                'CPCode' => _SBG_MT_CP_CODE,
289                                'UserID' => _SBG_MT_SEND_NUMBER,
290                                'RequestID' => '4',
291                                'ReceiverID' => $receiverID,
292                                'ServiceID' => _SBG_SERVICE_SERVICEID,
293                                'CommandCode' => _SBG_SERVICE_COMMAND_CODE,
294                                'ContentType' => '0',
295                                'Info' => $message
296                );
297               
298                $xml = $this->load->view('mt', $aryParams, true);
299                $url = $this->config->item('mt_service_url');
300                $client = new nusoap_client($url);
301                $client->useHTTPPersistentConnection();
302                $client->soap_defencoding = 'UTF-8';
303                $client->operation = $action;
304                $result = $client->send($xml, $action);
305               
306                //write_file('mt_log', var_export($client->fault, true)."\n".var_export($xml, true));
307               
308                if ($client->fault || (int)$result['InsertMTResult'] != 1) {
309                        return _SBG_SEND_MT_FAIL;
310                }
311               
312                return _SBG_SEND_MT_SUCCESS;
313        }
314       
315        public function formatPhoneNumber ($phoneNumber, $direction = 1) {
316                $aryMatch = array();
317                if (preg_match('/^(84)([0-9]{9,10})$/', $phoneNumber, $aryMatch) == 1 && $direction == 1) {
318                        $result = '0'. $aryMatch[2];
319                }
320                else if (preg_match('/^(0)([0-9]{9,10})$/', $phoneNumber) == 1 && $direction == 1) {
321                        $result = $phoneNumber;
322                }
323                else if (preg_match('/^(84)([0-9]{9,10})$/', $phoneNumber) == 1 && $direction == -1) {
324                        $result = $phoneNumber;
325                }
326                else if (preg_match('/^(0)([0-9]{9,10})$/', $phoneNumber, $aryMatch) == 1 && $direction == -1) {
327                        $result = '84'. $aryMatch[2];
328                }
329               
330                return $result;
331        }
332}
Note: See TracBrowser for help on using the repository browser.