HdOrderController.php 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151
  1. <?php
  2. namespace console\controllers;
  3. use bizHd\order\classes\OrderClass;
  4. use bizHd\order\models\Order;
  5. use common\components\dict;
  6. use common\components\noticeUtil;
  7. use yii\console\Controller;
  8. use Yii;
  9. use biz\shop\classes\ShopExtClass;
  10. use bizHd\shop\classes\ShopClass;
  11. use bizHd\wx\classes\WxOpenClass;
  12. use common\components\payUtil;
  13. use biz\wx\classes\WxMessageClass;
  14. class HdOrderController extends Controller
  15. {
  16. //【重要脚本,不能删除】花店订单脚本
  17. public function actionSelect()
  18. {
  19. $query = new \yii\db\Query();
  20. $query->from(Order::tableName());
  21. $now = time();
  22. $current = bcsub($now, 120);
  23. $time = date("Y-m-d H:i:s", $current);
  24. $query->where(['status' => 1])->andWhere(['<=', 'addTime', $time]);
  25. $query->orderBy('deadline ASC');
  26. foreach ($query->batch() as $batchOrder) {
  27. foreach ($batchOrder as $order) {
  28. $connection = Yii::$app->db;
  29. $transaction = $connection->beginTransaction();
  30. $id = $order['id'] ?? 0;
  31. $orderSn = $order['orderSn'] ?? '';
  32. try {
  33. $order = OrderClass::getById($id, true);
  34. $orderSn = $order->orderSn ?? '';
  35. $totalFee = $order->mainPay ?? 0;
  36. $capitalType = dict::getDict('capitalType', 'xhOrder', 'id');
  37. //查询微信是否付款成功
  38. $payWay = dict::getDict('payWay', 'wxPay');
  39. $wx = Yii::getAlias("@vendor/wxPayApi_v3.0.10");
  40. require_once($wx . '/lib/WxPay.Api.php');
  41. require_once($wx . '/example/WxPay.MicroPay.php');
  42. //获取微信商户号等信息
  43. $sjExtend = WxOpenClass::getMallWxInfo();
  44. $microPay = new \MicroPay();
  45. $payReturn = $microPay->query($orderSn, $sjExtend);
  46. if ($payReturn["return_code"] == "SUCCESS" && $payReturn["result_code"] == "SUCCESS") {
  47. if ($payReturn["trade_state"] == "SUCCESS") {
  48. //支付成功
  49. $transactionId = $payReturn['transaction_id'] ?? '';
  50. $order->onlinePay = dict::getDict('onlinePay', 'yes');
  51. $order->save();
  52. $attach = '';
  53. payUtil::thirdPay($payWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  54. //打印小票和语音播报
  55. $newOrder = OrderClass::getById($id, true);
  56. OrderClass::onlinePrint($newOrder);
  57. ShopExtClass::hdGatheringReport($newOrder);
  58. $shopId = $newOrder->shopId ?? 0;
  59. $shop = ShopClass::getById($shopId, true);
  60. WxMessageClass::gatheringIncomeInform($shop, $newOrder);
  61. noticeUtil::push("查到微信已付款!订单号:{$orderSn}", '15280215347');
  62. continue;
  63. }
  64. }
  65. //查询支付宝是否付款成功
  66. $payWay = dict::getDict('payWay', 'alipay');
  67. $aliF2F = Yii::getAlias("@vendor/alipayF2F");
  68. require_once($aliF2F . '/f2fpay/model/builder/AlipayTradePayContentBuilder.php');
  69. require_once($aliF2F . '/f2fpay/service/AlipayTradeService.php');
  70. $aliPId = '2021003122664465';
  71. $aliKey = 'MIIEpAIBAAKCAQEAnefrChYa5FUbGTlZNMTDNG531WrVP+TBPw3/hSmycRlBE/1sg9EryM0S3a9OQKQenRdYOoalqkkBuzt41ygJUC5hfNeaiV2OzphIiAyxUaiL1mSftP5B8joBN3HGG2AKbcvKlWcFoeiGY4ZmV/K0t3fqj/uPP6N/pEtnx6X4Ifgz4WGCDKUXKqT1Pyk2rqyIpel2EYk+HtC+9iicfac9kKQQiksDopb7sYosttdk64Dmjp2nMLDSpR+KOZUaqB39MEeHcJGeTzdVrp+Z9wW/NcJzSkSUb9juA0YjmogdbiKltykVHTbP6J0uPyByvzfyyY22QPqwNPiIPbCN6H543QIDAQABAoIBAQCO0+rOecYjSDO1siDVUTC8KTutR+/R1klRjojUWy3zjQNHYJAZ/0ZaX9wzttDSOWETeL0uWwJYL6coQxf/jVA3PWyirqYyn/R/PFFG9iwhj5HE/8lRvjXKMttM2lV2B34HaDE6yC/ZDmkYdsX1wSvjU81QJRuiVXIsGqSpep8hoVvVAn5sjvoC+zBSUaCsYy+7v7IXc6L8f/oLCBXY1r5j/+F/XFU1uFv4j162eRShQs6jQyVqQGLGCy4sSujj+8mpd6uCyJSIGJQHJlaN6cibTYStU/Z9+I/AP/+wQPVx31OwEC5J2xBfSHsezMsHSF7HQnfpQSz5AsOYZ3MOkiglAoGBAPV8sZz3C1gQ6WX5eKZE7PEUSxvAHsP+X6AAA6sWfH4cZq1uGJXgiDpTqN5dOqfNpNAU8gBDNTx4xUZ+cDuDH4WYxqkCe3CDdL97QmXDl2PnNvCKgHl735g3U1v3kCXgUAfBomc/xEIDguiEtsjPpknfjte/HmDE0zrWMOAQkJqXAoGBAKSrD5ryiVREpBmUohsI1g+e7BVR2nAtGYiquXIk2lkk5eQVO1yDh/LOU0jf8kI+UyRv16fANBjXqVc/twG016US5FNPV6fSllevsr0V020QemInO0+yJnTojSAfcayLroQId8Y3nPqVPpKMwvjvV7r50nGCCqXBtQsF4KITRzqrAoGAZBNyYNgBguRaEd1Sxw2gPmOUfvqiUCo6F4MJ+8xN8idn4FnaofcH8ic613PQPqpB/yYaxeqgIEfnvGY9ILXCuvbePfYqFmMwzALWvZ+v7uVKa2M7HstWCrq7O+m/lQFN/ut8ZnUDcBn4WwwHa/PjCYietetO2gpDRmAdSqrWGH8CgYBkwp+r6pkJzW60kHSZIlEKAe7oJMwLNC2ZqQ4MwGwzfBaH+E34kCuR8ZqYzyAIVOa/Nwi5By1Zvi1KzBwJmUUTJ3o7WCOE96EzSrmOZlqXNCwO/36Vh6dshhhE/birIlXJSP0xdzpBQy2ksyli9eGy8cdJ2Y72Wo+TjSclRbKiPQKBgQD1C/CJRQbahz6B3Sc4NOiFUQioM30qDKbDibzUq95u5PtQOx69+/h68tA2nj7ILZOXoh6/KF6LM9WK0QctY0HR5Uy4Uz8YkY/Y0L/LExSkNdpYqbpBc8DdIsKYHoMLNHDwc03tpINRLrmq00sD0907oeuY8/2l6P7XOZSnCvE5Fw==';
  72. $aliPublicKey = 'MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAgEb9zdQQDva63DhksZHPZCDrRe2xvZcTRy9mEiWs/pUhCG0QABkuePUyvqTAKINiCEv2QJmdF8qt3hmTSXuME5bT4vghckSGUTp4CNzsT90Vfjk4wci+bpAqNnpUASDuqZLCzebTuOhxYtGVBqYzhp/CxcC/Mag3ISjUG6jRqyUi15R1e2ruq74sohLGnb4m3nnwRVwnNVAaUcVfV1J0Nb0/9pusrj2t6FCyCkFeWbRDzKhplPQejaET2p5yplwSUpd1gqF+3srIn3erW5uAR6F0Z0NoCMzlo5TEXKWY2XMq97ubueE7Cgp8/c3dh5dkscAT2CCWwRq23aKozp+XMwIDAQAB';
  73. $config = array(
  74. //签名方式,默认为RSA2(RSA2048)
  75. 'sign_type' => "RSA2",
  76. //支付宝公钥
  77. 'alipay_public_key' => $aliPublicKey,
  78. //商户私钥
  79. 'merchant_private_key' => $aliKey,
  80. //编码格式
  81. 'charset' => "UTF-8",
  82. //支付宝网关
  83. 'gatewayUrl' => "https://openapi.alipay.com/gateway.do",
  84. //应用ID
  85. 'app_id' => $aliPId,
  86. //异步通知地址,只有扫码支付预下单可用
  87. 'notify_url' => Yii::$app->params['mallHost'] . "/notice/ali-callback",
  88. //最大查询重试次数
  89. 'MaxQueryRetry' => "10",
  90. //查询间隔
  91. 'QueryDuration' => "3"
  92. );
  93. //构造查询业务请求参数对象
  94. $queryContentBuilder = new \AlipayTradeQueryContentBuilder();
  95. $queryContentBuilder->setOutTradeNo($orderSn);
  96. //初始化类对象,调用queryTradeResult方法获取查询应答
  97. $queryResponse = new \AlipayTradeService($config);
  98. $queryResult = $queryResponse->queryTradeResult($queryContentBuilder);
  99. if ($queryResult->getTradeStatus() == 'SUCCESS') {
  100. $respond = $queryResult->getResponse();
  101. $transactionId = $respond->trade_no ?? '';
  102. $order->onlinePay = dict::getDict('onlinePay', 'yes');
  103. $order->save();
  104. $attach = '';
  105. payUtil::thirdPay($payWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  106. //打印小票和语音播报
  107. $newOrder = OrderClass::getById($id, true);
  108. OrderClass::onlinePrint($newOrder);
  109. ShopExtClass::hdGatheringReport($newOrder);
  110. $shopId = $newOrder->shopId ?? 0;
  111. $shop = ShopClass::getById($shopId, true);
  112. WxMessageClass::gatheringIncomeInform($shop, $newOrder);
  113. noticeUtil::push("查到支付宝已付款!订单号:{$orderSn}", '15280215347');
  114. }
  115. } catch (\Exception $e) {
  116. $transaction->rollBack();
  117. $msg = $e->getMessage();
  118. noticeUtil::push("查询订单是否付款出错了!订单号:{$orderSn},错误信息:{$msg}", '15280215347');
  119. }
  120. }
  121. }
  122. }
  123. }