NotifyController.php 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. <?php
  2. namespace App\Http\Controllers\Api\v1;
  3. use App\Http\Controllers\Api\BaseController;
  4. use App\Services\NotifyService;
  5. use App\Services\RedisService;
  6. use App\Services\SiyuanService;
  7. use App\Services\WechatService;
  8. /**
  9. * 回调控制器
  10. * @author wesmiler
  11. * @since 2020/11/10
  12. * Class NotifyController
  13. * @package App\Http\Controllers
  14. */
  15. class NotifyController extends BaseController
  16. {
  17. /**
  18. * 构造函数
  19. * @author wesmiler
  20. * @since 2020/11/11
  21. * NotifyController constructor.
  22. */
  23. public function __construct()
  24. {
  25. parent::__construct();
  26. $this->service = new SiyuanService();
  27. }
  28. /**
  29. * 支付回调
  30. */
  31. public function pay($scene){
  32. $postData = request()->all();
  33. RedisService::set('caches:payments:'.$scene.':result'.date('YmdHis'), ['result'=> request()->all()], 7200);
  34. $postData = isset($postData['resource'])? $postData['resource'] : [];
  35. if(empty($scene) || empty($postData)){
  36. return NotifyService::make()->rebackMsg('回调参数错误');
  37. }
  38. // 解密
  39. $ciphertext = isset($postData['ciphertext'])? $postData['ciphertext'] : '';
  40. if(empty($ciphertext)){
  41. return NotifyService::make()->rebackMsg('解密数据不存在');
  42. }
  43. $postData = WechatService::decryptNotifyData($postData);
  44. $outTradeNo = isset($postData['out_trade_no']) ? $postData['out_trade_no'] : '';
  45. if(empty($postData) || empty($outTradeNo)){
  46. return NotifyService::make()->rebackMsg('获取解密数据失败');
  47. }
  48. RedisService::set('caches:payments:'.$scene.':result_'.$outTradeNo, ['result'=> $postData], 7200);
  49. if (WechatService::checkJsapiNotify($postData) === true) {
  50. switch($scene){
  51. case 'index': // 供灯订单
  52. return NotifyService::make()->notifyGongdeng($postData, $outTradeNo);
  53. case 'recharge': // 充值
  54. break;
  55. default:
  56. break;
  57. }
  58. }
  59. return NotifyService::make()->rebackMsg('回调失败');
  60. }
  61. }