TestController.php 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115
  1. <?php
  2. namespace mall\controllers;
  3. use bizMall\shop\classes\ShopClass;
  4. use common\components\dict;
  5. use common\components\noticeUtil;
  6. use common\components\payUtil;
  7. use common\components\util;
  8. use Yii;
  9. use common\components\lakala\Lakala;
  10. use bizHd\order\classes\OrderClass;
  11. use biz\shop\classes\ShopExtClass;
  12. use biz\wx\classes\WxMessageClass;
  13. class TestController extends BaseController
  14. {
  15. public $guestAccess = ['trade-query'];
  16. //收银台订单查询 ssh 20231026
  17. public function actionTradeQuery()
  18. {
  19. $shopId = 36524;
  20. $shop = ShopClass::getById($shopId, true);
  21. if (empty($shop)) {
  22. util::fail('没有找到门店80');
  23. }
  24. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  25. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  26. $params = [
  27. 'appid' => 'OP00002119',
  28. 'serial_no' => '018b08cfddbd',
  29. 'merchant_no' => $shop->lklSjNo,
  30. 'term_no' => $shop->lklScanTermNo,
  31. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  32. 'lklCertificatePath' => $lklCertificatePath,
  33. ];
  34. $laResource = new Lakala($params);
  35. $orderSn = 'KD_CS61235138';
  36. $cashParams = [
  37. 'out_order_no' => $orderSn,
  38. ];
  39. $response = $laResource->cashierQuery($cashParams);
  40. if (isset($response['code']) == false || $response['code'] != '000000') {
  41. util::fail('支付失败了');
  42. }
  43. $postData = $response['resp_data'] ?? [];
  44. $orderTradeInfoList = $postData['order_trade_info_list'] ?? [];
  45. if (empty($orderTradeInfoList)) {
  46. util::fail('数据错误');
  47. }
  48. $orderTradeInfo = current($orderTradeInfoList);
  49. $payMode = $orderTradeInfo['pay_mode'] ?? null;
  50. if (empty($payMode)) {
  51. noticeUtil::push('收银台支付回调失败了,没有找到钱包类型,请注意,orderSn:' . $orderSn, '15280215347');
  52. util::end();
  53. }
  54. $trade_amount = $orderTradeInfo['trade_amount'] ?? 0;
  55. $totalFee = $trade_amount / 100;
  56. $orderStatus = $postData['order_status'];
  57. $transactionId = $postData['pay_order_no'] ?? 0;
  58. $tradeType = $orderTradeInfo['trade_type'] ?? '';
  59. if ($tradeType != 'PAY') {
  60. noticeUtil::push('收银台支付回调验证失败了,不是消费的回调,orderSn:' . $orderSn, '15280215347');
  61. util::end();
  62. }
  63. $capitalType = dict::getDict('capitalType', 'xhOrder', 'id');
  64. $connection = Yii::$app->db;
  65. $transaction = $connection->beginTransaction();
  66. try {
  67. if ($orderStatus == 2) {
  68. $payWayType = null;
  69. if ($payMode == 'ALIPAY') {
  70. $payWayType = dict::getDict('payWay', 'alipay');
  71. }
  72. if ($payMode == 'WECHAT') {
  73. $payWayType = dict::getDict('wxPay', 'alipay');
  74. }
  75. if (isset($payWayType) == false) {
  76. noticeUtil::push('收银台支付回调验证失败了,没有找到支付方式,orderSn:' . $orderSn, '15280215347');
  77. util::end();
  78. }
  79. $attach = '';
  80. payUtil::thirdPay($payWayType, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  81. $transaction->commit();
  82. //打印小票和语音播报
  83. $order = OrderClass::getByCondition(['orderSn' => $orderSn], true);
  84. ShopExtClass::hdGatheringReport($order);
  85. OrderClass::onlinePrint($order);
  86. $shopId = $order->shopId ?? 0;
  87. $shop = ShopClass::getById($shopId, true);
  88. if (in_array($order->fromType, [dict::getDict("fromType", "shop"), dict::getDict("fromType", "friend")])) {
  89. //您有新的收入提醒
  90. WxMessageClass::gatheringIncomeInform($shop, $order);
  91. }
  92. if ($order->fromType == dict::getDict("fromType", "mall")) {
  93. //来自商城的新订单微信通知
  94. WxMessageClass::hdNewOrderInform($shop, $order);
  95. }
  96. }
  97. //请不要修改
  98. echo "SUCCESS";
  99. exit();
  100. } catch (\Exception $e) {
  101. $transaction->rollBack();
  102. Yii::error("失败原因:" . $e->getMessage());
  103. }
  104. }
  105. }