Paypal.php 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908
  1. <?php
  2. /*
  3. * FecShop file.
  4. *
  5. * @link http://www.fecshop.com/
  6. * @copyright Copyright (c) 2016 FecShop Software LLC
  7. * @license http://www.fecshop.com/license/
  8. */
  9. namespace fecshop\services\payment;
  10. //use fecshop\models\mysqldb\IpnMessage;
  11. use fecshop\services\Service;
  12. use Yii;
  13. /**
  14. * Payment Paypal services.
  15. * @author Terry Zhao <2358269014@qq.com>
  16. * @since 1.0
  17. */
  18. class Paypal extends Service
  19. {
  20. /**
  21. * paypal支付状态 详细参看:https://developer.paypal.com/docs/classic/api/merchant/DoExpressCheckoutPayment_API_Operation_NVP/
  22. * 打开url后,浏览器查找:PAYMENTINFO_n_PAYMENTSTATUS , 即可找到下面各个状态对应的含义
  23. */
  24. public $payment_status_none = 'none';
  25. public $payment_status_completed = 'completed';
  26. public $payment_status_denied = 'denied';
  27. public $payment_status_expired = 'expired';
  28. public $payment_status_failed = 'failed';
  29. public $payment_status_in_progress = 'in_progress';
  30. public $payment_status_pending = 'pending';
  31. public $payment_status_refunded = 'refunded';
  32. public $payment_status_refunded_part= 'partially_refunded';
  33. public $payment_status_reversed = 'reversed';
  34. public $payment_status_unreversed = 'canceled_reversal';
  35. public $payment_status_processed = 'processed';
  36. public $payment_status_voided = 'voided';
  37. public $seller_email ;
  38. // 是否使用证书的方式(https)
  39. public $use_local_certs = false;
  40. // 在payment中 express paypal 的配置值
  41. public $express_payment_method;
  42. public $standard_payment_method;
  43. public $version = '109.0';
  44. public $crt_file;
  45. protected $_postData;
  46. protected $_order;
  47. const EXPRESS_TOKEN = 'paypal_express_token';
  48. const EXPRESS_PAYER_ID = 'paypal_express_payer_id';
  49. protected $payerID;
  50. protected $token;
  51. // 允许更改的订单状态,不存在这里面的订单状态不允许修改
  52. protected $_allowChangOrderStatus;
  53. protected $_ipnMessageModelName = '\fecshop\models\mysqldb\IpnMessage';
  54. protected $_ipnMessageModel;
  55. public function init()
  56. {
  57. parent::init();
  58. $this->_account = Yii::$app->store->get('payment_paypal', 'paypal_account');
  59. $this->_password = Yii::$app->store->get('payment_paypal', 'paypal_password');
  60. $this->_signature = Yii::$app->store->get('payment_paypal', 'paypal_signature');
  61. $this->_env = Yii::$app->store->get('payment_paypal', 'paypal_env');
  62. list($this->_ipnMessageModelName, $this->_ipnMessageModel) = \Yii::mapGet($this->_ipnMessageModelName);
  63. $this->_allowChangOrderStatus = [
  64. Yii::$service->order->payment_status_pending,
  65. Yii::$service->order->payment_status_processing,
  66. ];
  67. }
  68. /**
  69. * @param $domain | string
  70. * @return 得到证书crt文件的绝对路径
  71. */
  72. public function getCrtFile($domain)
  73. {
  74. if (isset($this->crt_file[$domain]) && !empty($this->crt_file[$domain])) {
  75. return Yii::getAlias($this->crt_file[$domain]);
  76. }
  77. }
  78. /**
  79. * 在paypal 标准支付中,paypal会向网站发送IPN消息,告知fecshop订单支付状态,
  80. * 进而fecshop更改订单状态。
  81. * fecshop一方面验证消息是否由paypal发出,另一方面要验证订单是否和后台的一致。
  82. */
  83. public function receiveIpn($post)
  84. {
  85. \Yii::info('receiveIpn', 'fecshop_debug');
  86. if ($this->verifySecurity($post)) {
  87. \Yii::info('verifySecurity', 'fecshop_debug');
  88. // 验证数据是否已经发送
  89. //if ($this->isNotDuplicate()) {
  90. // 验证数据是否被篡改。
  91. if ($this->isNotDistort()) {
  92. \Yii::info('updateOrderStatusByIpn', 'fecshop_debug');
  93. $this->updateOrderStatusByIpn();
  94. } else {
  95. // 如果数据和订单数据不一致,而且,支付状态为成功,则此订单
  96. // 标记为可疑的。
  97. $suspected_fraud = Yii::$service->order->payment_status_suspected_fraud;
  98. $this->updateOrderStatusByIpn($suspected_fraud);
  99. }
  100. // }
  101. }
  102. }
  103. /**
  104. * 该函数是为了验证IPN是否是由paypal发出,
  105. * 当paypal发送IPN消息给fecshop,fecshop不知道是否是伪造的支付消息,
  106. * 因此,fecshop将接收到的参数传递给paypal,询问paypal是否是paypal
  107. * 发送的IPN消息,如果是,则返回VERIFIED。
  108. */
  109. protected function verifySecurity($post)
  110. {
  111. $this->_postData = $post;
  112. $verifyUrl = $this->getVerifyUrl();
  113. \Yii::info('verifyUrl:'.$verifyUrl, 'fecshop_debug');
  114. $verifyReturn = $this->curlGet($verifyUrl);
  115. \Yii::info('verifyReturn:'.$verifyReturn, 'fecshop_debug');
  116. if ($verifyReturn == 'VERIFIED') {
  117. return true;
  118. }
  119. }
  120. /**
  121. * paypal发送的IPN,需要进行验证是否IPN是由paypal发出
  122. * 因此需要请求paypal确认,此函数返回请求paypal的url。
  123. */
  124. protected function getVerifyUrl()
  125. {
  126. $urlParamStr = '';
  127. if ($this->_postData) {
  128. foreach ($this->_postData as $k => $v) {
  129. $urlParamStr .= '&'.$k.'='.urlencode($v);
  130. }
  131. }
  132. $urlParamStr .= '&cmd=_notify-validate';
  133. $urlParamStr = substr($urlParamStr, 1);
  134. $current_payment_method = Yii::$service->payment->getPaymentMethod();
  135. // if ($current_payment_method == $this->standard_payment_method) {
  136. // $verifyUrl = Yii::$service->payment->getStandardWebscrUrl($this->standard_payment_method);
  137. // } else {
  138. // $verifyUrl = Yii::$service->payment->getExpressWebscrUrl($this->express_payment_method);
  139. // }
  140. if ($this->_env == Yii::$service->payment->env_sanbox) {
  141. $verifyUrl = 'https://www.sandbox.paypal.com/cgi-bin/webscr';
  142. } else {
  143. $verifyUrl = 'https://www.paypal.com/cgi-bin/webscr';
  144. }
  145. $verifyUrl = $verifyUrl.'?'.$urlParamStr;
  146. return $verifyUrl;
  147. }
  148. /**
  149. * @param $url | string, 请求的url
  150. * @param $i | 请求的次数,因为curl可能存在失败的可能,当
  151. * 失败后,就会通过递归的方式进行多次请求,这里设置的最大请求5次。
  152. * @return 返回请求url的return信息。
  153. */
  154. protected function curlGet($url, $i = 0)
  155. {
  156. $ch = curl_init($url);
  157. curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
  158. curl_setopt($ch, CURLOPT_POST, 1);
  159. curl_setopt($ch, CURLOPT_VERBOSE, 1);
  160. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  161. curl_setopt($ch, CURLOPT_POSTFIELDS, $req);
  162. curl_setopt($ch, CURLOPT_TIMEOUT, 30);
  163. curl_setopt($ch, CURLOPT_SSLVERSION, 6);
  164. if ($this->use_local_certs) {
  165. $crtFile = $this->getCrtFile('www.paypal.com');
  166. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 1);
  167. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
  168. curl_setopt($ch, CURLOPT_CAINFO, $crtFile);
  169. } else {
  170. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  171. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  172. }
  173. curl_setopt($ch, CURLOPT_FORBID_REUSE, 1);
  174. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
  175. curl_setopt($ch, CURLOPT_HTTPHEADER, ['Connection: Close']);
  176. $httpResponse = curl_exec($ch);
  177. if (!$httpResponse) {
  178. $i++;
  179. if ($i <= 5) {
  180. return $this->curlGet($url, $i);
  181. } else {
  182. return $httpResponse;
  183. }
  184. }
  185. return $httpResponse;
  186. }
  187. /**
  188. * paypal 可能发送多次IPN消息
  189. * 判断是否重复,如果不重复,把当前的插入。
  190. */
  191. /*
  192. protected function isNotDuplicate()
  193. {
  194. $ipn = $this->_ipnMessageModel->find()
  195. ->asArray()
  196. ->where([
  197. 'txn_id'=>$this->_postData['txn_id'],
  198. 'payment_status'=>$this->_postData['payment_status'],
  199. ])
  200. ->one();
  201. if (is_array($ipn) && !empty($ipn)) {
  202. return false;
  203. } else {
  204. $IpnMessage = new $this->_ipnMessageModelName();
  205. $IpnMessage->txn_id = $this->_postData['txn_id'];
  206. $IpnMessage->payment_status = $this->_postData['payment_status'];
  207. $IpnMessage->updated_at = time();
  208. $IpnMessage->save();
  209. return true;
  210. }
  211. }
  212. */
  213. /**
  214. * 验证订单数据是否被篡改。
  215. * 通过订单号找到订单,查看是否存在
  216. * 验证邮件地址,订单金额是否准确。
  217. */
  218. protected function isNotDistort()
  219. {
  220. //Yii::$app->mylog->log("begin isNotDistort..");
  221. $increment_id = $this->_postData['invoice'];
  222. $mc_gross = $this->_postData['mc_gross'];
  223. $mc_currency = $this->_postData['mc_currency'];
  224. if ($increment_id && $mc_gross && $mc_currency) {
  225. $this->_order = Yii::$service->order->getByIncrementId($increment_id);
  226. if ($this->_order) {
  227. $order_currency_code = $this->_order['order_currency_code'];
  228. if ($order_currency_code == $mc_currency) {
  229. // 核对订单总额
  230. $currentCurrencyGrandTotal = $this->_order['grand_total'];
  231. // if (round($currentCurrencyGrandTotal, 2) == round($mc_gross, 2)) {
  232. // 因为float精度问题,使用高精度函数进行比较,精度到2位小数
  233. if(bccomp($currentCurrencyGrandTotal, $mc_gross, 2) == 0){
  234. return true;
  235. } else {
  236. }
  237. } else {
  238. }
  239. }
  240. }
  241. return false;
  242. }
  243. /**
  244. * @param $orderstatus | String 订单状态
  245. * 根据接收的ipn消息,更改订单状态。
  246. */
  247. protected function updateOrderStatusByIpn($orderstatus = '')
  248. {
  249. $order_cancel_status = Yii::$service->order->payment_status_canceled;
  250. // 如果订单状态被取消,那么不能进行支付。
  251. if ($this->_order->order_status == $order_cancel_status) {
  252. Yii::$service->helper->error->add('The order status has been canceled and you can not pay for item ,you can create a new order to pay');
  253. return;
  254. }
  255. $updateArr = [];
  256. if ($this->_postData['txn_type']) {
  257. $updateArr['txn_type'] = $this->_postData['txn_type'];
  258. }
  259. if ($this->_postData['txn_id']) {
  260. $updateArr['txn_id'] = $this->_postData['txn_id'];
  261. }
  262. if ($this->_postData['payer_id']) {
  263. $updateArr['payer_id'] = $this->_postData['payer_id'];
  264. }
  265. if ($this->_postData['ipn_track_id']) {
  266. $updateArr['ipn_track_id'] = $this->_postData['ipn_track_id'];
  267. }
  268. if ($this->_postData['receiver_id']) {
  269. $updateArr['receiver_id'] = $this->_postData['receiver_id'];
  270. }
  271. if ($this->_postData['verify_sign']) {
  272. $updateArr['verify_sign'] = $this->_postData['verify_sign'];
  273. }
  274. if ($this->_postData['charset']) {
  275. $updateArr['charset'] = $this->_postData['charset'];
  276. }
  277. if ($this->_postData['mc_fee']) {
  278. $updateArr['payment_fee'] = $this->_postData['mc_fee'];
  279. $currency = $this->_postData['mc_currency'];
  280. $updateArr['base_payment_fee'] = Yii::$service->page->currency->getBaseCurrencyPrice($this->_postData['mc_fee'], $currency);
  281. }
  282. if ($this->_postData['payment_type']) {
  283. $updateArr['payment_type'] = $this->_postData['payment_type'];
  284. }
  285. if ($this->_postData['payment_date']) {
  286. $updateArr['paypal_order_datetime'] = date('Y-m-d H:i:s', $this->_postData['payment_date']);
  287. }
  288. if ($this->_postData['protection_eligibility']) {
  289. $updateArr['protection_eligibility'] = $this->_postData['protection_eligibility'];
  290. }
  291. $updateArr['updated_at'] = time();
  292. //$this->_order->updated_at = time();
  293. // 在service中不要出现事务代码,如果添加事务,请在调用层使用。
  294. //$innerTransaction = Yii::$app->db->beginTransaction();
  295. //try {
  296. // 可以更改的订单状态
  297. if ($orderstatus) {
  298. $updateArr['order_status'] = $orderstatus;
  299. $this->_order->updateAll(
  300. $updateArr,
  301. [
  302. 'and',
  303. ['order_id' => $this->_order['order_id']],
  304. ['in','order_status',$this->_allowChangOrderStatus]
  305. ]
  306. );
  307. // 指定了订单状态
  308. // $this->_order->order_status = $orderstatus;
  309. // $this->_order->save();
  310. // $payment_status = strtolower($this->_postData['payment_status']);
  311. // Yii::$app->mylog->log('save_'.$orderstatus);
  312. } else {
  313. $payment_status = strtolower($this->_postData['payment_status']);
  314. if ($payment_status == $this->payment_status_completed) {
  315. // paypal支付完成,将订单状态改成:收款已确认。
  316. // 只有存在于 $this->_allowChangOrderStatus 数组的状态,才允许更改,按照目前的设置,取消了的订单是不允许更改的
  317. $orderstatus = Yii::$service->order->payment_status_confirmed;
  318. $updateArr['order_status'] = $orderstatus;
  319. $updateColumn = $this->_order->updateAll(
  320. $updateArr,
  321. [
  322. 'and',
  323. ['order_id' => $this->_order['order_id']],
  324. ['in','order_status',$this->_allowChangOrderStatus]
  325. ]
  326. );
  327. //$this->_order->order_status = Yii::$service->order->payment_status_processing;
  328. // 更新订单信息
  329. //$this->_order->save();
  330. // 因为IPN消息可能不止发送一次,但是这里只允许一次,
  331. // 如果重复发送,$updateColumn 的更新返回值将为0
  332. if (!empty($updateColumn)) {
  333. Yii::$service->order->orderPaymentCompleteEvent($this->_order['increment_id']);
  334. // 上面的函数已经执行下面的代码,因此注释掉。
  335. // $orderInfo = Yii::$service->order->getOrderInfoByIncrementId($this->_order['increment_id']);
  336. // 发送新订单邮件
  337. // Yii::$service->email->order->sendCreateEmail($orderInfo);
  338. }
  339. } elseif ($payment_status == $this->payment_status_pending) {
  340. // pending 代表信用卡预付方式,需要等待paypal从信用卡中把钱扣除,因此订单状态是processing
  341. $orderstatus = Yii::$service->order->payment_status_processing;
  342. $updateArr['order_status'] = $orderstatus;
  343. $updateColumn = $this->_order->updateAll(
  344. $updateArr,
  345. [
  346. 'and',
  347. ['order_id' => $this->_order['order_id']],
  348. ['order_status' => Yii::$service->order->payment_status_pending]
  349. ]
  350. );
  351. } elseif ($payment_status == $this->payment_status_failed) {
  352. // 暂不处理
  353. } elseif ($payment_status == $this->payment_status_refunded) {
  354. // 暂不处理
  355. } else {
  356. // 暂不处理
  357. }
  358. }
  359. //$innerTransaction->commit();
  360. return true;
  361. //} catch (\Exception $e) {
  362. // $innerTransaction->rollBack();
  363. //}
  364. //return false;
  365. }
  366. // express 部分
  367. /**
  368. * @param $token | String , 通过 下面的 PPHttpPost5 方法返回的paypal express的token
  369. * @return String,通过token得到跳转的 paypal url,通过这个url跳转到paypal登录页面,进行支付的开始
  370. */
  371. public function getExpressCheckoutUrl($token)
  372. {
  373. if ($token) {
  374. //$webscrUrl = Yii::$service->payment->getExpressWebscrUrl($this->express_payment_method);
  375. if ($this->_env == Yii::$service->payment->env_sanbox) {
  376. $webscrUrl = 'https://www.sandbox.paypal.com/cgi-bin/webscr';
  377. } else {
  378. $webscrUrl = 'https://www.paypal.com/cgi-bin/webscr';
  379. }
  380. return $webscrUrl.'?cmd=_express-checkout&token='.urlencode($token);
  381. }
  382. }
  383. /**
  384. * @param $token | String , 通过 下面的 PPHttpPost5 方法返回的paypal standard的token
  385. * @return String,通过token得到跳转的 paypal url,通过这个url跳转到paypal登录页面,进行支付的开始
  386. */
  387. public function getStandardCheckoutUrl($token)
  388. {
  389. if ($token) {
  390. // $webscrUrl = Yii::$service->payment->getStandardWebscrUrl($this->standard_payment_method);
  391. if ($this->_env == Yii::$service->payment->env_sanbox) {
  392. $webscrUrl = 'https://www.sandbox.paypal.com/cgi-bin/webscr';
  393. } else {
  394. $webscrUrl = 'https://www.paypal.com/cgi-bin/webscr';
  395. }
  396. return $webscrUrl.'?useraction=commit&cmd=_express-checkout&token='.urlencode($token);
  397. }
  398. }
  399. /**
  400. * @param $methodName_ | String,请求的方法,譬如: $methodName_ = "SetExpressCheckout";
  401. * @param $nvpStr_ | String ,请求传递的购物车中的产品和总额部分的数据,组合成字符串的格式。
  402. * @param $i | Int , 限制递归次数的变量,当api获取失败的时候,可以通过递归的方式多次尝试,直至超过最大失败次数,才会返回失败
  403. * 此方法为获取token。返回的数据为数组,里面含有 ACK TOKEN 等值。
  404. * 也就是和paypal进行初次的api账号密码验证,成功后返回token等信息。
  405. */
  406. public function PPHttpPost5($methodName_, $nvpStr_, $i = 1)
  407. {
  408. $current_payment_method = Yii::$service->payment->getPaymentMethod();
  409. $API_NvpUrl = Yii::$service->payment->getStandardNvpUrl($this->standard_payment_method);
  410. $API_Signature = $this->_signature;
  411. $API_UserName = $this->_account;
  412. $API_Password = $this->_password;
  413. if ($this->_env == Yii::$service->payment->env_sanbox) {
  414. $API_NvpUrl = 'https://api-3t.sandbox.paypal.com/nvp';
  415. } else {
  416. $API_NvpUrl = 'https://api-3t.paypal.com/nvp';
  417. }
  418. if ($current_payment_method == $this->standard_payment_method) {
  419. $ipn_url = Yii::$service->payment->getStandardIpnUrl($this->standard_payment_method);
  420. } else {
  421. $ipn_url = Yii::$service->payment->getExpressIpnUrl($this->express_payment_method);
  422. }
  423. // Set the API operation, version, and API signature in the request.
  424. $nvpreq = "METHOD=$methodName_&PWD=$API_Password&USER=$API_UserName&SIGNATURE=$API_Signature$nvpStr_";
  425. $nvpreq .= "&PAYMENTREQUEST_0_NOTIFYURL=".urlencode($ipn_url);
  426. //echo $nvpreq;
  427. //\Yii::info($nvpreq, 'fecshop_debug');
  428. //exit;
  429. $ch = curl_init();
  430. curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
  431. curl_setopt($ch, CURLOPT_URL, $API_NvpUrl);
  432. curl_setopt($ch, CURLOPT_VERBOSE, 1);
  433. curl_setopt($ch, CURLOPT_TIMEOUT, 30);
  434. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  435. curl_setopt($ch, CURLOPT_POST, 1);
  436. curl_setopt($ch, CURLOPT_SSLVERSION, 6);
  437. if ($this->use_local_certs) {
  438. $crtFile = $this->getCrtFile('api-3t.paypal.com');
  439. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 1);
  440. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
  441. curl_setopt($ch, CURLOPT_CAINFO, $crtFile);
  442. } else {
  443. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  444. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  445. }
  446. // Set the request as a POST FIELD for curl.
  447. curl_setopt($ch, CURLOPT_POSTFIELDS, $nvpreq);
  448. curl_setopt($ch, CURLOPT_FORBID_REUSE, 1);
  449. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
  450. curl_setopt($ch, CURLOPT_HTTPHEADER, ['Connection: Close']);
  451. // Get response from the server.
  452. $httpResponse = curl_exec($ch);
  453. //echo "<br><br>%%%%%".$httpResponse."%%%%%<br><br>";
  454. if (!$httpResponse) {
  455. $i++;
  456. if ($i > 5) {
  457. //获取三次失败后,则推出。
  458. exit("$methodName_ failed: ".curl_error($ch).'('.curl_errno($ch).')');
  459. } else {
  460. $httpResponse = $this->PPHttpPost5($methodName_, $nvpStr_, $i);
  461. }
  462. } else {
  463. //第一次获取数据失败,则再次获取。并返回、
  464. if ($i > 0) {
  465. //return $httpResponse;
  466. }
  467. }
  468. //paypal返回的是一系列的字符串,譬如:L_TIMESTAMP0=2014-11-08T01:51:13Z&L_TIMESTAMP1=2014-11-08T01:40:41Z&L_TIMESTAMP2=2014-11-08T01:40:40Z&
  469. //下面要做的是先把字符串通过&字符打碎成数组
  470. //
  471. //echo "***************<br>";
  472. //echo urldecode($httpResponse);
  473. //echo "<br>***************<br>";
  474. $httpResponseAr = explode('&', urldecode($httpResponse));
  475. $httpParsedResponseAr = [];
  476. foreach ($httpResponseAr as $i => $value) {
  477. $tmpAr = explode('=', $value);
  478. if (sizeof($tmpAr) > 1) {
  479. $httpParsedResponseAr[$tmpAr[0]] = $tmpAr[1];
  480. }
  481. }
  482. if ((0 == sizeof($httpParsedResponseAr)) || !array_key_exists('ACK', $httpParsedResponseAr)) {
  483. exit("Invalid HTTP Response for POST request($nvpreq) to $API_NvpUrl.");
  484. }
  485. return $httpParsedResponseAr;
  486. }
  487. /**
  488. * @param $nvp_array | Array, 各个配置参数
  489. * 将数组里面的key和value,组合成url的字符串,生成nvp url
  490. */
  491. public function getRequestUrlStrByArray($nvp_array)
  492. {
  493. $str = '';
  494. if (is_array($nvp_array) && !empty($nvp_array)) {
  495. foreach ($nvp_array as $k=>$v) {
  496. $str .= '&'.urlencode($k).'='.urlencode($v);
  497. }
  498. }
  499. //echo $str;exit;
  500. return $str;
  501. }
  502. /**
  503. * 【paypal支付部分】api发送付款请求的参数部分
  504. * 通过该函数,将参数组合成字符串,为下一步api发送给paypal进行付款做准备
  505. */
  506. public function getCheckoutPaymentNvpStr($token)
  507. {
  508. $nvp_array = [];
  509. $nvp_array['PAYERID'] = $this->getPayerID();
  510. $nvp_array['TOKEN'] = $this->getToken();
  511. $nvp_array['PAYMENTREQUEST_0_PAYMENTACTION'] = 'Sale';
  512. $nvp_array['VERSION'] = $this->version;
  513. // https://developer.paypal.com/docs/classic/api/merchant/SetExpressCheckout_API_Operation_NVP/
  514. // 检查地址
  515. $nvp_array['ADDROVERRIDE'] = 0;
  516. //ADDROVERRIDE
  517. // 得到购物车的信息,通过购物车信息填写。
  518. $orderInfo = Yii::$service->order->getInfoByPaymentToken($token);
  519. //$cartInfo = Yii::$service->cart->getCartInfo(true);
  520. $currency = Yii::$service->page->currency->getCurrentCurrency();
  521. $grand_total = Yii::$service->helper->format->number_format($orderInfo['grand_total']);
  522. $subtotal = Yii::$service->helper->format->number_format($orderInfo['subtotal']);
  523. $shipping_total = Yii::$service->helper->format->number_format($orderInfo['shipping_total']);
  524. $discount_amount= Yii::$service->helper->format->number_format($orderInfo['subtotal_with_discount']);
  525. $subtotal = $subtotal - $discount_amount;
  526. $nvp_array['PAYMENTREQUEST_0_SHIPTOSTREET'] = $orderInfo['customer_address_street1'].' '.$orderInfo['customer_address_street2'];
  527. $nvp_array['PAYMENTREQUEST_0_SHIPTOCITY'] = $orderInfo['customer_address_city'];
  528. $nvp_array['PAYMENTREQUEST_0_SHIPTOSTATE'] = $orderInfo['customer_address_state_name'];
  529. $nvp_array['PAYMENTREQUEST_0_SHIPTOCOUNTRYCODE'] = $orderInfo['customer_address_country'];
  530. $nvp_array['PAYMENTREQUEST_0_SHIPTOZIP'] = $orderInfo['customer_address_zip'];
  531. $nvp_array['PAYMENTREQUEST_0_SHIPTONAME'] = $orderInfo['customer_firstname'].' '.$orderInfo['customer_lastname'];
  532. $nvp_array['PAYMENTREQUEST_0_INVNUM'] = $orderInfo['increment_id'];
  533. $nvp_array['PAYMENTREQUEST_0_CURRENCYCODE'] = $currency;
  534. $nvp_array['PAYMENTREQUEST_0_AMT'] = $grand_total;
  535. $nvp_array['PAYMENTREQUEST_0_ITEMAMT'] = $subtotal;
  536. $nvp_array['PAYMENTREQUEST_0_SHIPPINGAMT'] = $shipping_total;
  537. if ($this->seller_email) {
  538. $nvp_array['PAYMENTREQUEST_0_SELLERPAYPALACCOUNTID'] = $this->seller_email;
  539. }
  540. $i = 0;
  541. foreach ($orderInfo['products'] as $item) {
  542. $nvp_array['L_PAYMENTREQUEST_0_QTY'.$i] = $item['qty'];
  543. $nvp_array['L_PAYMENTREQUEST_0_NUMBER'.$i] = $item['sku'];
  544. $nvp_array['L_PAYMENTREQUEST_0_AMT'.$i] = Yii::$service->helper->format->number_format($item['price']);
  545. $nvp_array['L_PAYMENTREQUEST_0_NAME'.$i] = $item['name'];
  546. $nvp_array['L_PAYMENTREQUEST_0_CURRENCYCODE'.$i] = $currency;
  547. $i++;
  548. }
  549. $nvp_array['L_PAYMENTREQUEST_0_NAME'.$i] = 'Discount';
  550. $nvp_array['L_PAYMENTREQUEST_0_AMT'.$i] = '-'.$discount_amount;
  551. //var_dump($nvp_array);
  552. $nvpStr = $this->getRequestUrlStrByArray($nvp_array);
  553. //var_dump($nvpStr);
  554. return $nvpStr;
  555. }
  556. /**
  557. * 【paypal快捷支付部分】将参数组合成字符串。
  558. * 通过api token,从paypal获取用户在paypal保存的货运地址。
  559. */
  560. public function getExpressAddressNvpStr()
  561. {
  562. $nvp_array = [];
  563. $nvp_array['VERSION'] = Yii::$service->payment->paypal->version;
  564. $nvp_array['token'] = Yii::$service->payment->paypal->getToken();
  565. return $this->getRequestUrlStrByArray($nvp_array);
  566. }
  567. /**
  568. * @param $landingPage | String ,访问api的类型,譬如login
  569. * 【paypal快捷支付部分】通过购物车中的数据,组合成访问paypal express api的url
  570. * 这里返回的的字符串,是快捷支付部分获取token和payerId的参数。
  571. * 将返回的参数,传递给Yii::$service->payment->paypal->PPHttpPost5($methodName_, $nvpStr_)
  572. * 最终得到paypal express的token和payerId
  573. */
  574. public function getExpressTokenNvpStr($landingPage = 'Login', $return_url='', $cancel_url='')
  575. {
  576. $nvp_array = [];
  577. $nvp_array['LANDINGPAGE'] = $landingPage;
  578. if ($return_url) {
  579. $nvp_array['RETURNURL'] = $return_url;
  580. } else {
  581. $nvp_array['RETURNURL'] = Yii::$service->payment->getExpressReturnUrl($this->express_payment_method);
  582. }
  583. if ($cancel_url) {
  584. $nvp_array['CANCELURL'] = $cancel_url;
  585. } else {
  586. $nvp_array['CANCELURL'] = Yii::$service->payment->getExpressCancelUrl($this->express_payment_method);
  587. }
  588. $nvp_array['PAYMENTREQUEST_0_PAYMENTACTION'] = 'Sale';
  589. $nvp_array['VERSION'] = $this->version;
  590. // 得到购物车的信息,通过购物车信息填写。
  591. $cartInfo = Yii::$service->cart->getCartInfo(true);
  592. $currency = Yii::$service->page->currency->getCurrentCurrency();
  593. $grand_total = $cartInfo['grand_total'];
  594. $subtotal = $cartInfo['product_total'];
  595. $shipping_total = $cartInfo['shipping_cost'];
  596. $discount_amount = $cartInfo['coupon_cost'];
  597. $subtotal = $subtotal - $discount_amount;
  598. $nvp_array['PAYMENTREQUEST_0_CURRENCYCODE'] = $currency;
  599. $nvp_array['PAYMENTREQUEST_0_AMT'] = $grand_total;
  600. $nvp_array['PAYMENTREQUEST_0_ITEMAMT'] = $subtotal;
  601. $nvp_array['PAYMENTREQUEST_0_SHIPPINGAMT'] = $shipping_total;
  602. if ($this->seller_email) {
  603. $nvp_array['PAYMENTREQUEST_0_SELLERPAYPALACCOUNTID'] = $this->seller_email;
  604. }
  605. $i = 0;
  606. foreach ($cartInfo['products'] as $item) {
  607. $nvp_array['L_PAYMENTREQUEST_0_QTY'.$i] = $item['qty'];
  608. $nvp_array['L_PAYMENTREQUEST_0_NUMBER'.$i] = $item['sku'];
  609. $nvp_array['L_PAYMENTREQUEST_0_AMT'.$i] = $item['product_price'];
  610. $nvp_array['L_PAYMENTREQUEST_0_NAME'.$i] = Yii::$service->store->getStoreAttrVal($item['name'], 'name');
  611. $nvp_array['L_PAYMENTREQUEST_0_CURRENCYCODE'.$i] = $currency;
  612. $i++;
  613. }
  614. $nvp_array['L_PAYMENTREQUEST_0_NAME'.$i] = 'Discount';
  615. $nvp_array['L_PAYMENTREQUEST_0_AMT'.$i] = '-'.$discount_amount;
  616. return $this->getRequestUrlStrByArray($nvp_array);
  617. }
  618. /**
  619. * @param $landingPage | String ,访问api的类型,譬如login
  620. * 【paypal标准支付部分】通过订单中的数据,组合成访问paypal api的url
  621. * 这里返回的的字符串,是标准支付部分获取token和payerId的参数。
  622. * 通过 $checkoutReturn = Yii::$service->payment->paypal->PPHttpPost5($methodName_, $nvpStr_);
  623. * 获取token和payerId的参数。($nvpStr_ 就是本函数的返回值)
  624. */
  625. public function getStandardTokenNvpStr($landingPage = 'Login', $return_url='', $cancel_url='')
  626. {
  627. $nvp_array = [];
  628. $nvp_array['LANDINGPAGE'] = $landingPage;
  629. if ($return_url) {
  630. $nvp_array['RETURNURL'] = $return_url;
  631. } else {
  632. $nvp_array['RETURNURL'] = Yii::$service->payment->getStandardReturnUrl('paypal_standard');
  633. }
  634. if ($cancel_url) {
  635. $nvp_array['CANCELURL'] = $cancel_url;
  636. } else {
  637. $nvp_array['CANCELURL'] = Yii::$service->payment->getStandardCancelUrl('paypal_standard');
  638. }
  639. $nvp_array['PAYMENTREQUEST_0_PAYMENTACTION'] = 'Sale';
  640. $nvp_array['VERSION'] = $this->version;
  641. // 得到购物车的信息,通过购物车信息填写。
  642. $orderInfo = Yii::$service->order->getCurrentOrderInfo();
  643. //var_dump($orderInfo);
  644. $currency = $orderInfo['order_currency_code'];
  645. $grand_total = Yii::$service->helper->format->number_format($orderInfo['grand_total']);
  646. $subtotal = Yii::$service->helper->format->number_format($orderInfo['subtotal']);
  647. $shipping_total = Yii::$service->helper->format->number_format($orderInfo['shipping_total']);
  648. $discount_amount= $orderInfo['subtotal_with_discount'] ? $orderInfo['subtotal_with_discount'] : 0;
  649. $subtotal = $subtotal - $discount_amount;
  650. $nvp_array['PAYMENTREQUEST_0_CURRENCYCODE'] = $currency;
  651. $nvp_array['PAYMENTREQUEST_0_AMT'] = $grand_total;
  652. $nvp_array['PAYMENTREQUEST_0_ITEMAMT'] = $subtotal;
  653. $nvp_array['PAYMENTREQUEST_0_SHIPPINGAMT'] = $shipping_total;
  654. if ($this->seller_email) {
  655. $nvp_array['PAYMENTREQUEST_0_SELLERPAYPALACCOUNTID'] = $this->seller_email;
  656. }
  657. $i = 0;
  658. foreach ($orderInfo['products'] as $item) {
  659. $nvp_array['L_PAYMENTREQUEST_0_QTY'.$i] = $item['qty'];
  660. $nvp_array['L_PAYMENTREQUEST_0_NUMBER'.$i] = $item['sku'];
  661. $nvp_array['L_PAYMENTREQUEST_0_AMT'.$i] = Yii::$service->helper->format->number_format($item['price']);
  662. $nvp_array['L_PAYMENTREQUEST_0_NAME'.$i] = $item['name'];
  663. ;
  664. $nvp_array['L_PAYMENTREQUEST_0_CURRENCYCODE'.$i] = $currency;
  665. $i++;
  666. }
  667. $nvp_array['L_PAYMENTREQUEST_0_NAME'.$i] = 'Discount';
  668. $nvp_array['L_PAYMENTREQUEST_0_AMT'.$i] = '-'.$discount_amount;
  669. //var_dump($nvp_array);
  670. //exit;
  671. return $this->getRequestUrlStrByArray($nvp_array);
  672. }
  673. /**
  674. * 从get参数里得到paypal支付的token
  675. */
  676. public function getToken()
  677. {
  678. if (!$this->token) {
  679. $token = Yii::$app->request->get('token');
  680. if (!$token) {
  681. $token = Yii::$app->request->post('token');
  682. }
  683. $token = \Yii::$service->helper->htmlEncode($token);
  684. if ($token) {
  685. $this->token = $token;
  686. }
  687. }
  688. return $this->token;
  689. }
  690. /**
  691. * 从get参数里得到paypal支付的PayerID
  692. */
  693. public function getPayerID()
  694. {
  695. if (!$this->payerID) {
  696. $payerID = Yii::$app->request->get('PayerID');
  697. if (!$payerID) {
  698. $payerID = Yii::$app->request->post('PayerID');
  699. }
  700. $payerID = \Yii::$service->helper->htmlEncode($payerID);
  701. if ($payerID) {
  702. $this->payerID = $payerID;
  703. }
  704. }
  705. return $this->payerID;
  706. }
  707. /**
  708. * @param $doCheckoutReturn | Array ,
  709. * paypal付款状态提交后,更新订单的支付部分的信息。
  710. */
  711. public function updateOrderPayment($doCheckoutReturn, $token)
  712. {
  713. if ($doCheckoutReturn) {
  714. $order = Yii::$service->order->getByPaymentToken($token);
  715. $order_cancel_status = Yii::$service->order->payment_status_canceled;
  716. // 如果订单状态被取消,那么不能进行支付。
  717. if ($order['order_status'] == $order_cancel_status) {
  718. Yii::$service->helper->errors->add('The order status has been canceled and you can not pay for item ,you can create a new order to pay');
  719. return false;
  720. }
  721. $updateArr = [];
  722. if ($order['increment_id']) {
  723. //echo 'bbb';
  724. $updateArr['txn_id'] = $doCheckoutReturn['PAYMENTINFO_0_TRANSACTIONID'];
  725. $updateArr['txn_type'] = $doCheckoutReturn['PAYMENTINFO_0_TRANSACTIONTYPE'];
  726. $PAYMENTINFO_0_AMT = $doCheckoutReturn['PAYMENTINFO_0_AMT'];
  727. $updateArr['payment_fee'] = $doCheckoutReturn['PAYMENTINFO_0_FEEAMT'];
  728. $currency = $doCheckoutReturn['PAYMENTINFO_0_CURRENCYCODE'];
  729. $updateArr['base_payment_fee'] = Yii::$service->page->currency->getBaseCurrencyPrice($updateArr['payment_fee'], $currency);
  730. $updateArr['payer_id'] = $this->getPayerID();
  731. $updateArr['correlation_id'] = $doCheckoutReturn['CORRELATIONID'];
  732. $updateArr['protection_eligibility'] = $doCheckoutReturn['PAYMENTINFO_0_PROTECTIONELIGIBILITY'];
  733. $updateArr['protection_eligibility_type'] = $doCheckoutReturn['PAYMENTINFO_0_PROTECTIONELIGIBILITYTYPE'];
  734. $updateArr['secure_merchant_account_id'] = $doCheckoutReturn['PAYMENTINFO_0_SECUREMERCHANTACCOUNTID'];
  735. $updateArr['build'] = $doCheckoutReturn['BUILD'];
  736. $updateArr['payment_type'] = $doCheckoutReturn['PAYMENTINFO_0_PAYMENTTYPE'];
  737. $updateArr['paypal_order_datetime'] = date('Y-m-d H:i:s', $doCheckoutReturn['PAYMENTINFO_0_ORDERTIME']);
  738. $PAYMENTINFO_0_PAYMENTSTATUS = $doCheckoutReturn['PAYMENTINFO_0_PAYMENTSTATUS'];
  739. $updateArr['updated_at'] = time();
  740. if (
  741. strtolower($PAYMENTINFO_0_PAYMENTSTATUS) == $this->payment_status_completed
  742. ||
  743. strtolower($PAYMENTINFO_0_PAYMENTSTATUS) == $this->payment_status_processed
  744. ) {
  745. $order_status = Yii::$service->order->payment_status_confirmed;
  746. if ($currency == $order['order_currency_code'] && $PAYMENTINFO_0_AMT == $order['grand_total']) {
  747. $updateArr['order_status'] = $order_status;
  748. $updateColumn = $order->updateAll(
  749. $updateArr,
  750. [
  751. 'and',
  752. ['order_id' => $order['order_id']],
  753. ['in','order_status',$this->_allowChangOrderStatus]
  754. ]
  755. );
  756. // 因为IPN消息可能不止发送一次,但是这里只允许一次,
  757. // 如果重复发送,$updateColumn 的更新返回值将为0
  758. if (!empty($updateColumn)) {
  759. // 执行订单支付成功后的事情。
  760. Yii::$service->order->orderPaymentCompleteEvent($order['increment_id']);
  761. // 上面的函数已经执行下面的代码,因此注释掉。
  762. // $orderInfo = Yii::$service->order->getOrderInfoByIncrementId($order['increment_id']);
  763. // Yii::$service->email->order->sendCreateEmail($orderInfo);
  764. }
  765. return true;
  766. } else {
  767. // 金额不一致,判定为欺诈
  768. Yii::$service->helper->errors->add('The amount of payment is inconsistent with the amount of the order');
  769. $order_status = Yii::$service->order->payment_status_suspected_fraud;
  770. $updateArr['order_status'] = $order_status;
  771. $updateColumn = $order->updateAll(
  772. $updateArr,
  773. [
  774. 'and',
  775. ['order_id' => $order['order_id']],
  776. ['in','order_status',$this->_allowChangOrderStatus]
  777. ]
  778. );
  779. }
  780. } elseif (strtolower($PAYMENTINFO_0_PAYMENTSTATUS) == $this->payment_status_pending) {
  781. // 这种情况代表paypal 信用卡预售,需要等待一段时间才知道是否收到钱
  782. $order_status = Yii::$service->order->payment_status_processing;
  783. if ($currency == $order['order_currency_code'] && $PAYMENTINFO_0_AMT == $order['grand_total']) {
  784. $updateArr['order_status'] = $order_status;
  785. $updateColumn = $order->updateAll(
  786. $updateArr,
  787. [
  788. 'and',
  789. ['order_id' => $order['order_id']],
  790. ['order_status' => Yii::$service->order->payment_status_pending]
  791. ]
  792. );
  793. // 这种情况并没有接收到paypal的钱,只是一种支付等待状态,
  794. // 因此,对于这种支付状态,视为正常订单,但是没有支付成功,需要延迟等待,如果支付成功,paypal会继续发送IPN消息。
  795. return true;
  796. } else {
  797. // 金额不一致,判定为欺诈
  798. Yii::$service->helper->errors->add('The amount of payment is inconsistent with the amount of the order');
  799. $order_status = Yii::$service->order->payment_status_suspected_fraud;
  800. $updateArr['order_status'] = $order_status;
  801. $updateColumn = $order->updateAll(
  802. $updateArr,
  803. [
  804. 'and',
  805. ['order_id' => $order['order_id']],
  806. ['in','order_status',$this->_allowChangOrderStatus]
  807. ]
  808. );
  809. }
  810. } else {
  811. Yii::$service->helper->errors->add('paypal payment is not complete , current payment status is {payment_status}', ['payment_status' => $PAYMENTINFO_0_PAYMENTSTATUS]);
  812. }
  813. } else {
  814. Yii::$service->helper->errors->add('current order is not exist');
  815. }
  816. } else {
  817. Yii::$service->helper->errors->add('CheckoutReturn is empty');
  818. }
  819. return false;
  820. }
  821. }