Pay.php 66 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707
  1. <?php
  2. namespace app\api\controller\v1;
  3. use app\api\services\AliPayServices;
  4. use app\api\services\ThirdPayServices;
  5. use app\api\services\WxPayServices;
  6. use app\common\model\ShopGoodsModel;
  7. use app\common\model\ShopOrderGoodsModel as OrderGoods;
  8. use app\common\model\ShopOrderModel;
  9. use app\common\model\UserModel;
  10. use app\common\service\PayConfigService;
  11. use app\common\service\PaymentService;
  12. use app\common\service\SystemConfigService;
  13. use app\common\service\UserBankSignService;
  14. use app\common\service\YsBankService;
  15. use app\model\UserDataModel;
  16. use app\model\VipOrderModel;
  17. use app\Request;
  18. use app\services\balancePayServices;
  19. use app\services\OfflinePayServices;
  20. use jobs\VipOrderJob;
  21. use think\Exception;
  22. use think\facade\Db;
  23. use utils\RedisCache;
  24. /**
  25. * 支付处理 by wes
  26. * Class Pay
  27. * @package app\api\controller\v1
  28. */
  29. class Pay
  30. {
  31. /**
  32. * 支付方式配置
  33. * @param Request $request
  34. * @return \think\Response
  35. */
  36. public function payconfig(Request $request)
  37. {
  38. $paySource = $request->post('app_sources', '');
  39. $orderType = $request->post('order_type');
  40. if (empty($orderType)) {
  41. return api_error_return('参数错误');
  42. }
  43. $channelList = PayConfigService::make()->getChannelList($orderType, $paySource);
  44. return api_succ_return(['msg' => '成功', 'data' => ['setting' => array_values($channelList)]]);
  45. }
  46. /**
  47. * 生成支付订单
  48. * @param Request $request
  49. * @return \think\Response
  50. */
  51. public function paymentInfo(Request $request)
  52. {
  53. $post = $request->post();
  54. $curandroid = env('app.CUR_ANDROID_VERSION', '');
  55. $curios = env('app.CUR_IOS_VERSION', '');;
  56. $curAndroidVersion = str_replace('.', '', $curandroid);
  57. $curAndroidVersion = dispRepair($curAndroidVersion, 4, '0', '0');
  58. $curIosVersion = str_replace('.', '', $curios);
  59. $curIosVersion = dispRepair($curIosVersion, 4, '0', '0');
  60. $app_sources = $request->param('app_sources');
  61. $app_version = $request->param('app_version');
  62. $app_version = str_replace('.', '', $app_version);
  63. $app_version = dispRepair($app_version, 4, '0', '0');
  64. if ($app_sources == 'ios') {
  65. if ($curIosVersion > $app_version) {
  66. return api_error_return('app版本号过低,请更新');
  67. }
  68. }
  69. if ($app_sources == 'android') {
  70. if ($curAndroidVersion > $app_version) {
  71. return api_error_return('app版本号过低,请更新');
  72. }
  73. }
  74. if (empty($app_sources) || empty($app_version)) {
  75. if ($curAndroidVersion > $app_version) {
  76. return api_error_return('app版本号过低,请更新');
  77. }
  78. }
  79. // 限制提交调起
  80. $channel = $request->data['channel']; // 支付方式 1 支付宝支付 2 微信支付 3 余额 4 线下
  81. $orderSn = $request->data['order_id'];
  82. $orderType = isset($post['order_type']) ? intval($post['order_type']) : 0;
  83. $cacheKeyLock = "caches:payment:locks:u{$request->uid}_t{$orderType}_{$channel}";
  84. if (RedisCache::get($cacheKeyLock)) {
  85. return api_error_return('您的操作过于频繁,请5秒钟后重试');
  86. }
  87. // 加锁
  88. $result = false;
  89. RedisCache::setnx($cacheKeyLock, 1, rand(2, 3));
  90. try {
  91. // 服务商订单验证
  92. if ($orderType == 6) {
  93. $userInfo = UserModel::where(['id' => $request->uid])->field('id,store_type')->findOrEmpty();
  94. $storeType = isset($userInfo['store_type']) ? $userInfo['store_type'] : 0;
  95. if ($storeType == 1) {
  96. throw new Exception('已是服务商,无需再次开通');
  97. }
  98. }
  99. $channelList = PayConfigService::make()->getChannelList($orderType, $app_sources);
  100. if(empty($channelList)){
  101. throw new Exception('支付渠道暂未开放,请先配置');
  102. }
  103. $channels = $channelList? array_keys($channelList) : [15, 22, 66];
  104. if (!in_array($channel, $channels)) {
  105. throw new Exception('支付类型错误或未开放');
  106. }
  107. if ($post['order_type'] == 4) {
  108. if (empty($post['order_id'])) {
  109. throw new Exception('参数错误');
  110. }
  111. // 验证订单是否已支付
  112. if (PaymentService::make()->checkPaymentState($request->uid, $orderSn)) {
  113. throw new Exception('订单或已支付');
  114. }
  115. // 订单状态验证
  116. if (!ShopOrderModel::where(['order_sn' => $post['order_id'], 'status' => 0])->value('order_id')) {
  117. throw new Exception('订单不存在或已支付');
  118. }
  119. // 两小时内同一个订单调起未支付数量限制
  120. $limitPayCount = SystemConfigService::make()->getConfigByName('trade_call_pay_limit', 1, 'tradeconfig');
  121. $limitPayCount = $limitPayCount ? $limitPayCount : env('PAYMENT.UNPAY_LIMIT_NUM', 5);
  122. $count = PaymentService::make()->getPaymentCountByState($request->uid, $orderSn, 4, 7, 2);
  123. if ($count >= $limitPayCount) {
  124. throw new Exception("2小时内该笔订单请求支付已超过{$limitPayCount}次,请稍后再试");
  125. }
  126. }
  127. // 支付通道处理
  128. switch ($channel) {
  129. case 1:
  130. // 微信支付
  131. $result = WxPayServices::instance()->userId($request->uid)->data($request->data)->getUnifiedOrder();
  132. break;
  133. case 2:
  134. // 支付宝支付
  135. $result = AliPayServices::instance()->uid($request->uid)->data($request->data)->getUnifiedOrder();
  136. break;
  137. case 3:
  138. // 余额支付
  139. getActionSecury($request->uid, $request->post('security_pass', ''));
  140. $ser = new \app\api\services\BalancePayServices();
  141. $ser->balanceToOrder($request->uid, $request->post('order_id', ''));
  142. $result = api_succ_return(['msg' => '余额支付调用成功', 'data' => []]);
  143. break;
  144. case 14:
  145. // 第三方支付 汇付支付支付
  146. {
  147. $pay = new ThirdPayServices();
  148. $result = $pay->getHfPayInfoHF($request->uid, $request->data);
  149. }
  150. break;
  151. case 15:
  152. // 第三方支付 石区长
  153. {
  154. $pay = new ThirdPayServices();
  155. $result = $pay->getPayInfoSQZ($request->uid, $request->data);
  156. }
  157. break;
  158. case 16:
  159. // 第三方支付 支付宝 石区长
  160. {
  161. $pay = new ThirdPayServices();
  162. $result = $pay->getPayInfoSQZAlipay($request->uid, $request->data);
  163. }
  164. break;
  165. case 17:
  166. // 第三方支付 微信 石区长
  167. {
  168. $pay = new ThirdPayServices();
  169. $result = $pay->getPayInfoSQZWechat($request->uid, $request->data);
  170. }
  171. break;
  172. case 18:
  173. // 第三方支付 银联快捷 石区长 首信易
  174. {
  175. $pay = new ThirdPayServices();
  176. $result = $pay->getPayInfoSQZBankkuai($request->uid, $request->data);
  177. }
  178. break;
  179. case 19:
  180. // 第三方支付 usdt充值
  181. {
  182. $pay = new ThirdPayServices();
  183. $result = $pay->getPayInfoUsdt($request->uid, $request->data);
  184. }
  185. break;
  186. case 20:
  187. // 直连银盛 无卡快捷
  188. {
  189. $pay = new ThirdPayServices();
  190. $result = $pay->getPayInfoYSwk($request->uid, $request->data);
  191. }
  192. break;
  193. case 22:
  194. // 支付宝 电科科技支付
  195. {
  196. $pay = new ThirdPayServices();
  197. $result = $pay->getPayInfoDiankeZfb($request->uid, $request->data);
  198. }
  199. break;
  200. case 56:
  201. // 第三方支付 易票联统一支付
  202. {
  203. $pay = new ThirdPayServices();
  204. $result = $pay->getYsfPayInfoTY($request->uid, $request->data);
  205. }
  206. break;
  207. case 66:
  208. // 电科云闪付
  209. {
  210. $pay = new ThirdPayServices();
  211. $result = $pay->getPayInfoDiankeYsf($request->uid, $request->data);
  212. }
  213. break;
  214. }
  215. } catch (Exception $e) {
  216. RedisCache::clear($cacheKeyLock);
  217. return api_error_return($e->getMessage());
  218. }
  219. RedisCache::keyDel("caches:paymentCall:u{$request->uid}_ot{$orderType}*");
  220. return $result? $result : api_error_return('支付请求错误或未开放,请联系客服');
  221. }
  222. /**
  223. * 石学长 银联支付
  224. * @param Request $request
  225. * @return \think\Response
  226. */
  227. public function sylSurePay(Request $request)
  228. {
  229. Db::startTrans();
  230. try {
  231. $third_pay = new ThirdPayServices();
  232. $third_pay->sylSurePay($request->uid, $request->post());
  233. Db::commit();
  234. } catch (\Exception $e) {
  235. Db::rollback();
  236. return api_error_return($e->getMessage());
  237. }
  238. return api_succ_return('支付订单提交成功,稍后请关注订单列表');
  239. }
  240. /**
  241. * 银盛快捷确认支付
  242. * @param Request $request
  243. * @return \think\Response
  244. */
  245. public function zlysSurePay(Request $request)
  246. {
  247. $post = $request->post();
  248. if (empty($post['trade_no']) || empty($post['sms_code'])) {
  249. return api_error_return('参数错误');
  250. }
  251. Db::startTrans();
  252. try {
  253. $ser = new ThirdPayServices();
  254. $res = $ser->kjPayWithCode($post['trade_no'], $post['sms_code']);
  255. Db::commit();
  256. } catch (\Exception $e) {
  257. Db::rollback();
  258. return api_error_return($e->getMessage());
  259. }
  260. return $res;
  261. }
  262. /**
  263. * 直连银盛 支持的银行卡列表
  264. * @param Request $request
  265. * @return \think\Response
  266. * @throws \think\db\exception\DataNotFoundException
  267. * @throws \think\db\exception\DbException
  268. * @throws \think\db\exception\ModelNotFoundException
  269. */
  270. public function zlysBankList(Request $request)
  271. {
  272. try {
  273. $post = $request->post();
  274. $pageSize = isset($post['limit']) ? $post['limit'] : 0;
  275. return api_succ_return(['msg' => '成功', 'data' => YsBankService::make()->getList($post, $pageSize)]);
  276. } catch (\Exception $exception) {
  277. return api_error_return('获取错误:' . $exception->getMessage());
  278. }
  279. }
  280. /**
  281. * 银盛银行卡支付支持的银行通道
  282. * @param Request $request
  283. * @return \think\Response
  284. */
  285. public function zlysBankPayWay(Request $request)
  286. {
  287. return api_succ_return(['msg' => '成功', 'data' => [
  288. ['bank_name' => '工商银行', 'xiane' => '单笔1万、单日1万、单月5万', 'jieji' => '是', 'xinyong' => '是'],
  289. ['bank_name' => '中国银行', 'xiane' => '单笔5万,单日5万', 'jieji' => '否', 'xinyong' => '是'],
  290. ['bank_name' => '建设银行', 'xiane' => '单笔1万、单日1万、单月5万', 'jieji' => '是', 'xinyong' => '是'],
  291. ['bank_name' => '招商银行', 'xiane' => '单笔5万,单日5万', 'jieji' => '否', 'xinyong' => '是'],
  292. ['bank_name' => '光大银行', 'xiane' => '单笔0.5万、单日5万 ', 'jieji' => '是', 'xinyong' => '是'],
  293. ['bank_name' => '民生银行', 'xiane' => '2万/2万', 'jieji' => '是', 'xinyong' => '是'],
  294. ['bank_name' => '浦发银行', 'xiane' => '借单笔/日2万、贷单笔/日1万、月不限', 'jieji' => '是', 'xinyong' => '是'],
  295. ['bank_name' => '平安银行', 'xiane' => '单笔5万、单日5万、月不限', 'jieji' => '是', 'xinyong' => '否'],
  296. ['bank_name' => '广发银行', 'xiane' => '贷记卡(单笔3w,单日3w)、借记卡(单笔2w,单日2w)', 'jieji' => '是', 'xinyong' => '是'],
  297. ['bank_name' => '中信银行', 'xiane' => '单笔5万、日/月不限', 'jieji' => '是', 'xinyong' => '是'],
  298. ['bank_name' => '交通银行', 'xiane' => '单笔2万,单日2万,单月5万', 'jieji' => '否', 'xinyong' => '是'],
  299. ['bank_name' => '渤海银行', 'xiane' => '借单笔3w,单日3w;贷单笔2w,单日2w', 'jieji' => '是', 'xinyong' => '是'],
  300. ['bank_name' => '上海银行', 'xiane' => '借单笔1w单日1万;贷单笔2w,日不限', 'jieji' => '是', 'xinyong' => '是'],
  301. ['bank_name' => '华夏银行', 'xiane' => '日累计2万,月累计60万', 'jieji' => '是', 'xinyong' => '否'],
  302. ['bank_name' => '邮储银行', 'xiane' => '借记卡:无限额,以发卡测为准;贷记卡:单笔2万、单日2万', 'jieji' => '是', 'xinyong' => '是'],
  303. ['bank_name' => '浙商银行', 'xiane' => '单笔2万、单日2万', 'jieji' => '是', 'xinyong' => '是'],
  304. ['bank_name' => '区域银行', 'xiane' => '无', 'jieji' => '是', 'xinyong' => '是']]
  305. ]);
  306. }
  307. /**
  308. * 用户绑定银行卡
  309. * @param Request $request
  310. * @return \think\Response
  311. */
  312. public function userToSignBank(Request $request)
  313. {
  314. Db::startTrans();
  315. try {
  316. $third_pay = new ThirdPayServices();
  317. $sign_url = $third_pay->userBankSign($request->uid, $request->post());
  318. Db::commit();
  319. } catch (\Exception $e) {
  320. Db::rollback();
  321. return api_error_return($e->getMessage());
  322. }
  323. return api_succ_return(['msg' => '成功', 'data' => ['sign_url' => $sign_url]]);
  324. }
  325. /**
  326. * 用户解绑银行卡
  327. * @param Request $request
  328. * @return \think\Response
  329. */
  330. public function userToUnSignBank(Request $request)
  331. {
  332. Db::startTrans();
  333. try {
  334. $third_pay = new ThirdPayServices();
  335. $third_pay->userUnBankSign($request->uid, $request->post());
  336. Db::commit();
  337. } catch (\Exception $e) {
  338. Db::rollback();
  339. return api_error_return($e->getMessage());
  340. }
  341. return api_succ_return('成功');
  342. }
  343. /**
  344. * 用户绑定银行卡签名
  345. * @param Request $request
  346. * @return \think\Response
  347. * @throws \think\db\exception\DataNotFoundException
  348. * @throws \think\db\exception\DbException
  349. * @throws \think\db\exception\ModelNotFoundException
  350. */
  351. public function myBankSignList(Request $request)
  352. {
  353. $list = Db::name('user_bank_sign')->where('uid', $request->uid)
  354. ->where('status', 2)
  355. ->field('id,name,bank_card,phone')
  356. ->withAttr('bank_card', function ($val, $data) {
  357. $len = strlen($val);
  358. return substr($val, 0, 4) . '****' . substr($val, $len - 5, $len - 1);
  359. })->select()->toArray();
  360. return api_succ_return(['msg' => '成功', 'data' => $list]);
  361. }
  362. /**
  363. * 支持的银行卡
  364. * @param Request $request
  365. * @return \think\Response
  366. */
  367. public function ylBindCanSignList(Request $request)
  368. {
  369. return api_succ_return(['msg' => '成功', 'data' => [
  370. 'chuxuka' => ['中国银行', '建设银行', '工商银行', '浦发银行', '光大银行', '华夏银行', '民生银行', '平安银行', '上海银行', '交通银行', '邮政储蓄银行', '中信银行', '浙商银行', '广东省农村信用社', '山西省农村信用社', '内蒙古自治区农村信用社', '吉林农村信用社', '河南省农村信用社', '黄河农村商业银行', '深圳农村商业银行', '天津滨海农村商业银行股份有限公司', '大连农村商业银行', '鄞州银行', '天津农商银行', '辽宁省农村信用社', '湖北农信', '云南省农村信用社联合社', '陕西省农村信用社', '青海省农村信用社联合社', '湖南省农村信用社', '黑龙江省农村信用社', '广西农村信用社', '苏州银行', '四川省农村信用社', '甘肃省农村信用社', '山东省农村信用社联合社', '广西北部湾银行', '抚顺银行股份有限公司', '辽阳银行股份有限公司', '贵州银行', '晋中银行股份有限公司', '西藏银行股份有限公司', '新疆汇和银行股份有限公司', '江苏江阴农村商业银行股份有限公司', '大连银行', '阜新银行', '吉林银行', '宁夏银行', '嘉兴银行', '常熟农商银行', '江苏江南农村商业银行股份公司', '江苏长江商行', '台州银行', '温州银行', '浙江稠州商业银行', '绍兴银行', '宁波通商银行股份有限公司', '温州民商银行', '浙江民泰商业银行', '浙江泰隆商业银行', '金华银行股份有限公司', '南洋商业银行', '贵阳银行', '韩亚银行', '宜宾商业银行', '自贡市商业银行', '顺德农村商业银行', '桂林银行股份有限公司', '承德银行', '富滇银行', '昆仑银行', '新韩银行中国', '邢台银行', '张家口市商业银行', '沧州银行', '兰州银行', '友利银行', '焦作中旅银行', '泉州银行', '厦门国际银行', '营口银行', '朝阳银行股份有限公司', '广东华兴银行', '长沙银行', '锦州银行', '九江银行', '石嘴山银行股份有限公司', '哈尔滨银行', '龙江银行', '江西银行', '攀枝花市商业银行', '重庆三峡银行', '广州银行', '晋城银行', '上饶银行', '赣州银行', '长城华西银行', '盛京银行', '甘肃银行', '中原银行', '湖北银行', '郑州银行', '富邦华一银行有限公司', '星展银行', '乐山市商业银行股份有限公司', '长治银行', '上海华瑞银行', '湖南三湘银行', '海南银行', '福建海峡银行', '北京农商银行', '河北省农村信用社', '上海农村商业银行', '江苏省农村信用社联合社', '浙江农信', '安徽省农村信用社联合社', '福建省农村信用社联合社', '江西省农村信用社', '海南省农村信用社', '重庆农村商业银行', '贵州省农村信用社', '新疆自治区农村信用社', '武汉农村商业银行', '成都农商银行', '张家港农村商业银行', '江苏紫金农村商业银行', '无锡农村商业银行', '太仓农村商业银行', '昆山农村商业银行', '广东南海农村商业银行', '浙江长兴农村商业银行'],
  371. 'xinyongka' => ['招商银行', '中国银行', '中信银行', '民生银行', '浦发银行', '平安银行', '光大银行', '广东发展银行', '上海银行', '华夏银行', '工商银行', '建设银行', '交通银行', '邮政储蓄银行', '浙商银行', '北京银行']
  372. ]]);
  373. }
  374. /**
  375. * 绑定支付宝账号
  376. * @param Request $request
  377. * @param UserDataModel $model
  378. * @return \think\Response
  379. */
  380. public function bindAlipay(Request $request, UserDataModel $model)
  381. {
  382. $re_data = $request->data;
  383. if (isset($re_data['real_name']) || isset($re_data['alipay'])) {
  384. return api_error_return('参数错误--算出sign_str不要传real_name跟alipay');
  385. }
  386. [$sign_str] = $request->getMore([
  387. ['sign_str', '']
  388. ], true);
  389. if (empty($sign_str))
  390. return api_error_return('参数错误');
  391. $data = json_decode(AESjiemi($sign_str));
  392. if (empty($data))
  393. return api_error_return('参数错误');
  394. $data = object_array($data);
  395. try {
  396. return api_succ_return(['msg' => '绑定成功', 'data' => $model->bindAlipay($data, $request->uid)]);
  397. } catch (\Exception $e) {
  398. return api_error_return('绑定失败');
  399. }
  400. }
  401. /**
  402. * 解绑支付宝
  403. * @param Request $request
  404. * @param UserDataModel $model
  405. * @return \think\Response
  406. */
  407. public function unbindAlipay(Request $request, UserDataModel $model)
  408. {
  409. try {
  410. return api_succ_return(['msg' => '解绑成功', 'data' => $model->unbindAlipay($request)]);
  411. } catch (\Exception $e) {
  412. return api_error_return('解绑失败');
  413. }
  414. }
  415. /************** 支付回调处理 **************/
  416. /**
  417. * 电科支付回调处理
  418. * @param Request $request
  419. * @return string
  420. */
  421. public function thirdPayZfbNewBack(Request $request)
  422. {
  423. $params = $request->param();
  424. $service = new ThirdPayServices();
  425. $date = date('Y-m-d H:i:s');
  426. $outTradeNo = isset($params['orderId'])? trim($params['orderId']) : '';
  427. $isPay = isset($params['pay'])? trim($params['pay']) : '';
  428. $amount = isset($params['amount'])? floatval($params['amount']) : 0;
  429. $paySign = isset($params['sign'])? trim($params['sign']) : '';
  430. if(empty($paySign)){
  431. unset($params['sign']);
  432. return $service->diankesign($params);
  433. }
  434. // 加锁
  435. $key = $outTradeNo? $outTradeNo : date('YmdHis');
  436. $cacheKeyLock = "caches:payNotify:dkpay:locks:otn_{$key}";
  437. $cacheKey = "caches:payNotify:dkpay:otn_{$key}:";
  438. if(RedisCache::get($cacheKeyLock)){
  439. return 'Frequent submission';
  440. }
  441. // 回调处理
  442. RedisCache::setnx($cacheKeyLock, 1, rand(2,3));
  443. RedisCache::set($cacheKey.'callback', ['params'=> $params,'date'=> $date], 7200);
  444. if ($outTradeNo && $amount && $isPay == 'true') {
  445. // 校验签名
  446. if ($paySign) {
  447. $signData = $params;
  448. unset($signData['sign']);
  449. $sign = $service->diankesign($signData);
  450. if ($sign == $paySign) {
  451. Db::startTrans();
  452. try {
  453. PaymentService::make()->payBack($params['orderId'], $params['amount'], 22, json_encode($params));
  454. Db::commit();
  455. return 'success';
  456. } catch (\Exception $e) {
  457. Db::rollback();
  458. $error = [
  459. 'msg'=> $e->getMessage(),
  460. 'trace'=> $e->getTrace(),
  461. ];
  462. RedisCache::set($cacheKey.'fail', ['params'=> $params,'error'=> $error,'date'=> $date], 7200);
  463. RedisCache::clear($cacheKeyLock);
  464. }
  465. } else {
  466. RedisCache::set($cacheKey.'error', ['params'=> $params,'error'=>'签名错误','date'=> $date], 7200);
  467. }
  468. }else{
  469. RedisCache::set($cacheKey.'error', ['params'=> $params,'error'=>'缺少签名参数','date'=> $date], 7200);
  470. }
  471. }
  472. return 'fail';
  473. }
  474. /**
  475. * 支付宝支付回调
  476. * @param Request $request
  477. * @return mixed
  478. */
  479. public function aliResult(Request $request)
  480. {
  481. $data = $request->param();
  482. $key = isset($data['out_trade_no']) ? $data['out_trade_no'] : date("YmdHis");
  483. $cacheKey = "caches:payNotify:alipay:otn_{$key}:";
  484. RedisCache::set($cacheKey."callback", ['params'=>$data,'date'=>'Y-m-d H:i:s'], 7200);
  485. if(empty($data)){
  486. return 'fail:params error';
  487. }
  488. try{
  489. return AliPayServices::instance()->data($data)->getNotifyInfo()->afterPay(2);
  490. } catch (\Exception $exception){
  491. RedisCache::set($cacheKey.'error', ['params'=>$data,'error'=> ['msg'=> $exception->getMessage(),'trace'=>$exception->getTrace()],'date'=>'Y-m-d H:i:s'], 7200);
  492. return 'fail';
  493. }
  494. }
  495. /**
  496. * 微信支付回调
  497. * @param Request $request
  498. * @return mixed
  499. */
  500. public function wxResult(Request $request)
  501. {
  502. $data['body'] = file_get_contents('php://input');
  503. $data['header'] = $request->header();
  504. $key = isset($data['body']['out_trade_no']) ? $data['body']['out_trade_no'] : date("YmdHis");
  505. $cacheKey = "caches:payNotify:wxpay:otn_{$key}:";
  506. RedisCache::set($cacheKey."callback", ['params'=>$data,'date'=>'Y-m-d H:i:s'], 7200);
  507. if(empty($data['body'])){
  508. return 'fail:params error';
  509. }
  510. try{
  511. return \app\api\services\WxPayServices::instance()->data($data)->getNotifyInfo()->afterPay(1);
  512. } catch (\Exception $exception){
  513. RedisCache::set($cacheKey.'error', ['params'=>$data,'error'=> ['msg'=> $exception->getMessage(),'trace'=>$exception->getTrace()],'date'=>'Y-m-d H:i:s'], 7200);
  514. return 'fail';
  515. }
  516. }
  517. /**
  518. *
  519. * thirdPaySqzBack支付三方sqz回调
  520. * @param Request $request
  521. * @return string
  522. */
  523. public function thirdPaySqzBack(Request $request)
  524. {
  525. $params = $request->param();
  526. $date = date('Y-m-d H:i:s');
  527. $service = new ThirdPayServices();
  528. $outTradeNo = isset($params['orderid'])? trim($params['orderid']) : '';
  529. $isPay = isset($params['opstate'])? trim($params['opstate']) : '-1';
  530. $amount = isset($params['ovalue'])? floatval($params['ovalue']) : 0;
  531. $paySign = isset($params['sign'])? trim($params['sign']) : '';
  532. if(empty($paySign)){
  533. return $service->sqzSign($params);
  534. }
  535. // 加锁
  536. $key = $outTradeNo? $outTradeNo : date('YmdHis');
  537. $cacheKeyLock = "caches:payNotify:sqzpay:locks:otn_{$key}";
  538. $cacheKey = "caches:payNotify:sqzpay:otn_{$key}:";
  539. if(RedisCache::get($cacheKeyLock)){
  540. return 'Frequent submission';
  541. }
  542. // 回调处理
  543. RedisCache::setnx($cacheKeyLock, 1, rand(2,3));
  544. RedisCache::set($cacheKey.'callback', ['params'=> $params,'date'=> $date], 7200);
  545. if ($outTradeNo && $isPay>=0 && $amount>0) {
  546. // 校验签名
  547. if ($paySign) {
  548. $sign = $service->sqzSign($params);
  549. if ($sign === $paySign) {
  550. if ($isPay == 0) {
  551. Db::startTrans();
  552. try {
  553. PaymentService::make()->payBack($outTradeNo, $amount, 15, json_encode($params));
  554. Db::commit();
  555. } catch (\Exception $e) {
  556. Db::rollback();
  557. $error = [
  558. 'msg'=> $e->getMessage(),
  559. 'trace'=> $e->getTrace(),
  560. ];
  561. RedisCache::set($cacheKey.'fail', ['params'=> $params,'error'=> $error,'date'=> $date], 7200);
  562. RedisCache::clear($cacheKeyLock);
  563. return 'opstate=0' . $e->getMessage();
  564. }
  565. } else {
  566. RedisCache::set($cacheKey.'error', ['params'=> $params,'error'=>'订单未支付','date'=> $date], 7200);
  567. return 'opstate=01';
  568. }
  569. } else {
  570. RedisCache::set($cacheKey.'error', ['params'=> $params,'error'=>'协议绑卡签名错误','date'=> $date], 7200);
  571. return 'opstate=0';
  572. }
  573. }
  574. }else{
  575. RedisCache::set($cacheKey.'error', ['params'=> $params,'error'=>'回调参数错误','date'=> $date], 7200);
  576. }
  577. return 'opstate=0';
  578. }
  579. /**
  580. * 三方支付宝sqz回调
  581. * @param Request $request
  582. * @return string
  583. */
  584. public function thirdPaySqzAliBack(Request $request)
  585. {
  586. $params = $request->param();
  587. if (isset($params['orderid']) && isset($params['opstate']) && isset($params['ovalue'])) {
  588. // 校验签名
  589. if (isset($params['sign'])) {
  590. $sign = md5('orderid=' . $params['orderid'] . '&opstate=' . $params['opstate'] . '&ovalue=' . $params['ovalue'] . env('PAYSQZ.SIGNKEY'));
  591. if ($sign === $params['sign']) {
  592. if ($params['opstate'] == 0) {
  593. Db::startTrans();
  594. try {
  595. $service = new ThirdPayServices();
  596. $service->payBack($params['orderid'], $params['ovalue'], 16, json_encode($params));
  597. Db::commit();
  598. return 'success';
  599. } catch (\Exception $e) {
  600. Db::rollback();
  601. sr_log($e->getMessage());
  602. return 'opstate=0' . $e->getMessage();
  603. }
  604. } else {
  605. return 'opstate=01';
  606. }
  607. } else {
  608. return 'opstate=0';
  609. }
  610. }
  611. }
  612. return 'opstate=0';
  613. }
  614. /**
  615. * 支付宝支付回调 多来贝
  616. * @param Request $request
  617. * @return mixed
  618. */
  619. public function aliResultDLB(Request $request)
  620. {
  621. sr_log('----------------------支付三方回调-------------------------');
  622. sr_log($request);
  623. sr_log($request->param());
  624. sr_log('----------------------支付三方回调-------------------------');
  625. // DLB1649854201945040279940469OP
  626. $result = [
  627. 'order_id' => 'DLB1649854201945040279940469OP'
  628. ];
  629. $pay_info = Db::name('payment')->where('out_trade_no', $result['order_id'])->find();
  630. if (!$pay_info) {
  631. echo 'success';
  632. die();
  633. } else {
  634. if ($pay_info['state'] != 7) {
  635. echo 'success';
  636. die();
  637. }
  638. Db::startTrans();
  639. try {
  640. Db::name('payment')->where('id', $pay_info['id'])->update(['state' => 6, 'pay_at' => date('Y-m-d H:i:s')]); // 更改订单状态
  641. switch ($pay_info['order_type']) {
  642. case 1: // 充值
  643. break;
  644. case 3:
  645. // 充值会员
  646. //
  647. break;
  648. case 4: //购买商品
  649. // $order = Order::where(['order_sn' => explode(',', $pay_info['remarks'])])->select()->toArray();
  650. // Order::payDoneOrderCallback($order, 3, $pay_info['uid']);
  651. $m_goods = new ShopGoodsModel();
  652. $m_user = new UserModel();
  653. $m_shoporder = new ShopOrderModel();
  654. // 更改订单状态
  655. $order = ShopOrderModel::where('order_sn', $pay_info['remarks'])->find();
  656. $nowTime = date('Y-m-d H:i:s', time());
  657. Db::name('shop_order')->where(['order_sn' => $pay_info['remarks']])
  658. ->update(['pay_type' => 2, 'status' => 1, 'updated_time' => $nowTime]);
  659. // 增加销量
  660. $orderGoods = OrderGoods::where(['order_id' => $order['order_id']])->select()->toArray();
  661. foreach ($orderGoods as $k => $v) {
  662. ShopGoodsModel::where(['goods_id' => $v['goods_id']])->inc('sales_volume', $v['num'])->inc('real_sales_volume', $v['num'])->update();
  663. }
  664. // 送积分
  665. edit_user_score(5, $order['user_id'], $order['rebate_score']);
  666. edit_user_redscore(1, $order['user_id'], $order['rebate_lock_score']);
  667. break;
  668. }
  669. Db::commit();
  670. echo 'success';
  671. die;
  672. } catch (\Exception $e) {
  673. Db::rollback();
  674. echo 'failure';
  675. die;
  676. }
  677. }
  678. echo 'success';
  679. die();
  680. }
  681. /**
  682. * 微信支付回调 多来贝
  683. * @param Request $request
  684. * @return mixed
  685. */
  686. public function wechatResultDLB(Request $request)
  687. {
  688. sr_log('----------------------支付三方回调-------------------------');
  689. sr_log(json_encode($request->param()));
  690. sr_log('----------------------支付三方回调-------------------------');
  691. $result = $request->param();
  692. try {
  693. if (!$result || !$result['sign']) {
  694. sr_log('11111');
  695. echo 'success';
  696. die();
  697. }
  698. $sign = thirdPayGetSign($result, '897d9ea909093173b24dd89c772181e4');
  699. if ($result['sign'] != $sign) {
  700. sr_log('222222');
  701. echo 'success';
  702. die();
  703. }
  704. if ($result['status'] != 1) {
  705. sr_log('33333333');
  706. echo 'success';
  707. die();
  708. }
  709. } catch (Exception $e) {
  710. echo 'success';
  711. sr_log('aaa' . $e->getMessage());
  712. die();
  713. }
  714. $pay_info = Db::name('payment')->where('out_trade_no', $result['order_no'])->find();
  715. if (!$pay_info) {
  716. sr_log('333333333');
  717. echo 'success';
  718. die();
  719. } else {
  720. if ($pay_info['state'] != 7) {
  721. sr_log('8888' . '已经处理过了');
  722. echo 'success';
  723. die();
  724. }
  725. if ($result['total_amount'] < $pay_info['total_fee']) {
  726. sr_testDb(json_encode($pay_info), 1);
  727. sr_log('9999' . '支付金额错误');
  728. echo 'success';
  729. die();
  730. }
  731. Db::startTrans();
  732. try {
  733. Db::name('payment')->where('id', $pay_info['id'])->update(['state' => 6, 'pay_at' => date('Y-m-d H:i:s')]); // 更改订单状态
  734. switch ($pay_info['order_type']) {
  735. case 1: // 充值
  736. break;
  737. case 3:
  738. // 充值会员
  739. break;
  740. case 4: //购买商品
  741. // 更改订单状态
  742. $order = ShopOrderModel::where('order_sn', $pay_info['remarks'])->find();
  743. $nowTime = date('Y-m-d H:i:s', time());
  744. Db::name('shop_order')->where(['order_sn' => $pay_info['remarks']])
  745. ->update(['pay_type' => 2, 'status' => 1, 'updated_time' => $nowTime]);
  746. // 增加销量
  747. $orderGoods = OrderGoods::where(['order_id' => $order['order_id']])->select()->toArray();
  748. foreach ($orderGoods as $k => $v) {
  749. ShopGoodsModel::where(['goods_id' => $v['goods_id']])->inc('sales_volume', $v['num'])->inc('real_sales_volume', $v['num'])->update();
  750. }
  751. // 送积分
  752. edit_user_score(5, $order['user_id'], $order['rebate_score']);
  753. edit_user_redscore(1, $order['user_id'], $order['rebate_lock_score']);
  754. break;
  755. }
  756. Db::commit();
  757. echo 'success';
  758. die;
  759. } catch (\Exception $e) {
  760. Db::rollback();
  761. echo 'failure';
  762. sr_log('微信多乐宝报错:' . $e->getMessage());
  763. die;
  764. }
  765. }
  766. echo 'success';
  767. die();
  768. }
  769. /**
  770. * 微信支付回调 畅联
  771. * @param Request $request
  772. * @return mixed
  773. */
  774. public function wechatResultCL(Request $request)
  775. {
  776. sr_log('----------------------支付三方回调-------------------------');
  777. sr_log(json_encode($request->param()));
  778. sr_log('----------------------支付三方回调-------------------------');
  779. $result = $request->param();
  780. try {
  781. if (!$result || !$result['sign']) {
  782. sr_log('cl11111');
  783. echo 'success';
  784. die();
  785. }
  786. $sign = thirdPayCheckSignCL($result, 'XMLfjHMPOGexsSaadIWSVCNG0XJBClZZ');
  787. if ($result['sign'] != $sign) {
  788. sr_log('cl222222');
  789. echo 'success';
  790. die();
  791. }
  792. if ($result['callbacks'] != 'CODE_SUCCESS') {
  793. sr_log('cl33333333');
  794. echo 'success';
  795. die();
  796. }
  797. } catch (Exception $e) {
  798. echo 'success';
  799. sr_log('claaa' . $e->getMessage());
  800. die();
  801. }
  802. $pay_info = Db::name('payment')->where('out_trade_no', $result['out_trade_no'])->find();
  803. if (!$pay_info) {
  804. sr_log('cl333333333');
  805. echo 'success';
  806. die();
  807. } else {
  808. if ($pay_info['state'] != 7) {
  809. sr_log('cl8888' . '已经处理过了');
  810. echo 'success';
  811. die();
  812. }
  813. if ($result['amount'] < $pay_info['total_fee']) {
  814. sr_testDb(json_encode($pay_info), 1);
  815. sr_log('cl9999' . '支付金额错误');
  816. echo 'success';
  817. die();
  818. }
  819. Db::startTrans();
  820. try {
  821. $pay_info = Db::name('payment')->where('out_trade_no', $result['out_trade_no'])->lock(true)->find();
  822. Db::name("thirdpay_back")->insert([
  823. 'out_order_no' => $result['out_trade_no'],
  824. 'content' => json_encode($result),
  825. 'create_time' => sr_getcurtime(time()),
  826. 'type' => 1,
  827. 'uid' => $pay_info['uid']
  828. ]);
  829. if (empty($pay_info)) {
  830. throw new Exception('畅联并发了');
  831. }
  832. Db::name('payment')->where('id', $pay_info['id'])->update(['state' => 6, 'pay_at' => date('Y-m-d H:i:s')]); // 更改订单状态
  833. switch ($pay_info['order_type']) {
  834. case 1: // 充值
  835. break;
  836. case 3:
  837. // 充值会员
  838. break;
  839. case 4: //购买商品
  840. $m_user = new UserModel();
  841. // 更改订单状态
  842. $order = ShopOrderModel::where('order_sn', $pay_info['remarks'])->find();
  843. $nowTime = date('Y-m-d H:i:s', time());
  844. Db::name('shop_order')->where(['order_sn' => $pay_info['remarks']])
  845. ->update(['status' => 1, 'pay_type' => 7, 'updated_time' => $nowTime]);
  846. // 增加销量
  847. $orderGoods = OrderGoods::where(['order_id' => $order['order_id']])->select()->toArray();
  848. foreach ($orderGoods as $k => $v) {
  849. ShopGoodsModel::where(['goods_id' => $v['goods_id']])->inc('sales_volume', $v['num'])->inc('real_sales_volume', $v['num'])->update();
  850. }
  851. // 送积分
  852. edit_user_score(5, $order['user_id'], $order['rebate_score']);
  853. edit_user_redscore(1, $order['user_id'], $order['rebate_lock_score']);
  854. break;
  855. }
  856. Db::commit();
  857. } catch (\Exception $e) {
  858. Db::rollback();
  859. sr_log('cl微信报错:' . $e->getMessage());
  860. echo 'failure';
  861. die;
  862. }
  863. echo 'success';
  864. die();
  865. }
  866. echo 'success';
  867. die();
  868. }
  869. /**
  870. * 支付宝支付回调 畅联
  871. * @param Request $request
  872. * @return mixed
  873. */
  874. public function AliResultCL(Request $request)
  875. {
  876. sr_log('----------------------支付三方回调-------------------------');
  877. sr_log(json_encode($request->param()));
  878. sr_log('----------------------支付三方回调-------------------------');
  879. $result = $request->param();
  880. $pay_info = Db::name('payment')->where('out_trade_no', $result['out_trade_no'])->find();
  881. if (!$pay_info) {
  882. sr_log('cl333333333');
  883. echo 'success';
  884. die();
  885. } else {
  886. if ($pay_info['state'] != 7) {
  887. sr_log('cl8888' . '已经处理过了');
  888. echo 'success';
  889. die();
  890. }
  891. if ($result['amount'] < $pay_info['total_fee']) {
  892. sr_testDb(json_encode($pay_info), 1);
  893. sr_log('cl9999' . '支付金额错误');
  894. echo 'success';
  895. die();
  896. }
  897. $key = 'api' . $request->pathinfo() . $result['out_trade_no'];
  898. Db::startTrans();
  899. try {
  900. redisLock($key);
  901. $pay_info = Db::name('payment')->where('out_trade_no', $result['out_trade_no'])->lock(true)->find();
  902. Db::name("thirdpay_back")->insert([
  903. 'out_order_no' => $result['out_trade_no'],
  904. 'content' => json_encode($result),
  905. 'create_time' => sr_getcurtime(time()),
  906. 'type' => 1,
  907. 'uid' => $pay_info['uid']
  908. ]);
  909. if (empty($pay_info)) {
  910. throw new Exception('畅联支付宝并发了');
  911. }
  912. Db::name('payment')->where('id', $pay_info['id'])->update(['state' => 6, 'pay_at' => date('Y-m-d H:i:s')]); // 更改订单状态
  913. switch ($pay_info['order_type']) {
  914. case 1: // 充值
  915. break;
  916. case 3:
  917. // 充值会员
  918. break;
  919. case 4: //购买商品
  920. $m_user = new UserModel();
  921. // 更改订单状态
  922. $order = ShopOrderModel::where('order_sn', $pay_info['remarks'])->find();
  923. $nowTime = date('Y-m-d H:i:s', time());
  924. Db::name('shop_order')->where(['order_sn' => $pay_info['remarks']])
  925. ->update(['status' => 1, 'pay_type' => 8, 'updated_time' => $nowTime]);
  926. // 增加销量
  927. $orderGoods = OrderGoods::where(['order_id' => $order['order_id']])->select()->toArray();
  928. foreach ($orderGoods as $k => $v) {
  929. ShopGoodsModel::where(['goods_id' => $v['goods_id']])->inc('sales_volume', $v['num'])->inc('real_sales_volume', $v['num'])->update();
  930. }
  931. // 送积分
  932. edit_user_score(5, $order['user_id'], $order['rebate_score']);
  933. edit_user_redscore(1, $order['user_id'], $order['rebate_lock_score']);
  934. break;
  935. }
  936. Db::commit();
  937. } catch (\Exception $e) {
  938. Db::rollback();
  939. if ($e->getCode() != apiPingFanCode()) {
  940. redisFree($key);
  941. }
  942. sr_log('cl支付宝报错:' . $e->getMessage());
  943. echo 'failure';
  944. die;
  945. }
  946. redisFree($key);
  947. echo 'success';
  948. die();
  949. }
  950. echo 'success';
  951. die();
  952. }
  953. /**
  954. * mo宝银联回调 富友
  955. * @param Request $request
  956. * @return mixed
  957. */
  958. public function BankResultFY(Request $request)
  959. {
  960. $res = file_get_contents('php://input');
  961. sr_log('----------------------支付三方富有回调-------------------------');
  962. sr_log($res);
  963. sr_log('----------------------支付三方富有回调-------------------------');
  964. $result = json_decode($res);
  965. if (isset($result->mchnt_cd) && isset($result->message) && isset($result->resp_code) && isset($result->resp_desc)) {
  966. if ($result->resp_code == 0000) {
  967. $res_decode = json_decode(RSA_openssl($result->message, 'decode'));
  968. if (isset($res_decode->order_st) && $res_decode->order_st == 1) {
  969. $out_trade_no = 'FYYL' . $res_decode->order_id;
  970. $pay_info = Db::name('payment')->where('out_trade_no', $out_trade_no)->find();
  971. if ($pay_info) {
  972. if ($pay_info['state'] == 7) {
  973. if ($res_decode->order_amt < bcmul($pay_info['total_fee'], 100, 0)) {
  974. echo 'success';
  975. die();
  976. }
  977. $key = 'api' . $request->pathinfo() . $out_trade_no;
  978. Db::startTrans();
  979. try {
  980. redisLock($key);
  981. $pay_info = Db::name('payment')->where('out_trade_no', $out_trade_no)->lock(true)->find();
  982. Db::name("thirdpay_back")->insert([
  983. 'out_order_no' => $out_trade_no,
  984. 'content' => json_encode($res_decode),
  985. 'create_time' => sr_getcurtime(time()),
  986. 'type' => 2,
  987. 'uid' => $pay_info['uid']
  988. ]);
  989. Db::name('payment')->where('id', $pay_info['id'])->update(['state' => 6, 'pay_at' => date('Y-m-d H:i:s')]); // 更改订单状态
  990. switch ($pay_info['order_type']) {
  991. case 1: // 充值
  992. break;
  993. case 3:
  994. // 充值会员
  995. //
  996. break;
  997. case 4: //购买商品
  998. $m_user = new UserModel();
  999. // 更改订单状态
  1000. $order = ShopOrderModel::where('order_sn', $pay_info['remarks'])->find();
  1001. $nowTime = date('Y-m-d H:i:s', time());
  1002. Db::name('shop_order')->where(['order_sn' => $pay_info['remarks']])
  1003. ->update(['status' => 1, 'pay_type' => 9, 'updated_time' => $nowTime]);
  1004. // 增加销量
  1005. $orderGoods = OrderGoods::where(['order_id' => $order['order_id']])->select()->toArray();
  1006. foreach ($orderGoods as $k => $v) {
  1007. ShopGoodsModel::where(['goods_id' => $v['goods_id']])->inc('sales_volume', $v['num'])->inc('real_sales_volume', $v['num'])->update();
  1008. }
  1009. $user = $m_user->where('id', $pay_info['uid'])->find();
  1010. // 送积分
  1011. edit_user_score(5, $order['user_id'], $order['rebate_score']);
  1012. edit_user_redscore(1, $order['user_id'], $order['rebate_lock_score']);
  1013. // 释放用户福利积分或者锁定积分到余额
  1014. $sf_money = intval(intval($pay_info['total_fee']) / 100) * 5;
  1015. if ($sf_money > 0) {
  1016. $is_sf = false;
  1017. if ($user['score_away'] > $sf_money && !$is_sf) {
  1018. if ($user['score_away'] <= $sf_money) {
  1019. $sf_money = intval($user['score_away']);
  1020. }
  1021. edit_user_score(24, $pay_info['uid'], $sf_money);
  1022. edit_user_scoreaway(8, $pay_info['uid'], $sf_money);
  1023. $is_sf = true;
  1024. }
  1025. if ($user['score_lock'] > $sf_money && !$is_sf) {
  1026. edit_user_score(25, $pay_info['uid'], $sf_money);
  1027. edit_user_lock_score(2, $pay_info['uid'], $sf_money);
  1028. $is_sf = true;
  1029. }
  1030. }
  1031. break;
  1032. }
  1033. Db::commit();
  1034. } catch (\Exception $e) {
  1035. Db::rollback();
  1036. if ($e->getCode() != apiPingFanCode()) {
  1037. redisFree($key);
  1038. }
  1039. sr_log('fy支付报错:' . $e->getMessage());
  1040. echo 'failure';
  1041. die;
  1042. }
  1043. }
  1044. }
  1045. }
  1046. }
  1047. }
  1048. redisFree($key);
  1049. echo 'success';
  1050. die;
  1051. }
  1052. /**
  1053. * 进件审核回调
  1054. * @param Request $request
  1055. */
  1056. public function yplApplyResult(Request $request)
  1057. {
  1058. $res = file_get_contents('php://input');
  1059. sr_log('----------------------ypl审核回调-------------------------');
  1060. sr_log($res);
  1061. sr_log('----------------------ypl审核回调-------------------------');
  1062. echo "0000";
  1063. die();
  1064. }
  1065. /**
  1066. * @param Request $request
  1067. */
  1068. public function ZfbResultYPL(Request $request)
  1069. {
  1070. $res = file_get_contents('php://input');
  1071. sr_log('----------------------ypl回调-------------------------');
  1072. sr_log($res);
  1073. sr_log('----------------------ypl回调-------------------------');
  1074. $res = json_decode($res, true);
  1075. Db::startTrans();
  1076. try {
  1077. if ($res['payState'] != '00') {
  1078. echo "0000";
  1079. die();
  1080. }
  1081. $pay_info = Db::name('payment')->where('out_trade_no', $res['outTradeNo'])->lock(true)->find();
  1082. Db::name("thirdpay_back")->insert([
  1083. 'out_order_no' => $res['outTradeNo'],
  1084. 'content' => json_encode($res),
  1085. 'create_time' => sr_getcurtime(time()),
  1086. 'type' => 3,
  1087. 'uid' => $pay_info['uid']
  1088. ]);
  1089. Db::name('payment')->where('id', $pay_info['id'])->update(['state' => 6, 'pay_at' => date('Y-m-d H:i:s')]); // 更改订单状态
  1090. switch ($pay_info['order_type']) {
  1091. case 1: // 充值
  1092. break;
  1093. case 3:
  1094. // 充值会员
  1095. break;
  1096. case 4: //购买商品
  1097. $m_user = new UserModel();
  1098. // 更改订单状态
  1099. $order = ShopOrderModel::where('order_sn', $pay_info['remarks'])->find();
  1100. $nowTime = date('Y-m-d H:i:s', time());
  1101. Db::name('shop_order')->where(['order_sn' => $pay_info['remarks']])
  1102. ->update(['status' => 1, 'pay_type' => 8, 'updated_time' => $nowTime]);
  1103. // 增加销量
  1104. $orderGoods = OrderGoods::where(['order_id' => $order['order_id']])->select()->toArray();
  1105. foreach ($orderGoods as $k => $v) {
  1106. ShopGoodsModel::where(['goods_id' => $v['goods_id']])->inc('sales_volume', $v['num'])->inc('real_sales_volume', $v['num'])->update();
  1107. }
  1108. $user = $m_user->where('id', $pay_info['uid'])->find();
  1109. // 送积分
  1110. edit_user_score(5, $order['user_id'], $order['rebate_score']);
  1111. edit_user_redscore(1, $order['user_id'], $order['rebate_lock_score']);
  1112. // 释放用户福利积分或者锁定积分到余额
  1113. $sf_money = intval(intval($pay_info['total_fee']) / 100) * 5;
  1114. if ($sf_money > 0) {
  1115. $is_sf = false;
  1116. if ($user['score_away'] > $sf_money && !$is_sf) {
  1117. if ($user['score_away'] <= $sf_money) {
  1118. $sf_money = intval($user['score_away']);
  1119. }
  1120. edit_user_score(24, $pay_info['uid'], $sf_money);
  1121. edit_user_scoreaway(8, $pay_info['uid'], $sf_money);
  1122. $is_sf = true;
  1123. }
  1124. if ($user['score_lock'] > $sf_money && !$is_sf) {
  1125. edit_user_score(25, $pay_info['uid'], $sf_money);
  1126. edit_user_lock_score(2, $pay_info['uid'], $sf_money);
  1127. $is_sf = true;
  1128. }
  1129. }
  1130. break;
  1131. }
  1132. Db::commit();
  1133. } catch (\Exception $e) {
  1134. Db::rollback();
  1135. sr_log('ypl报错:' . $e->getMessage());
  1136. echo "0000";
  1137. die();
  1138. }
  1139. echo "0000";
  1140. die();
  1141. }
  1142. /**
  1143. * @param Request $request
  1144. * @return \think\Response
  1145. */
  1146. public function ZfbResultHF(Request $request)
  1147. {
  1148. /**
  1149. * 判断支付异步回调业务处理
  1150. * User: shuaishuai.niu
  1151. * Date: 2020/11/16
  1152. * Time: 14:01
  1153. */
  1154. sr_log('----------------------汇付回调-------------------------');
  1155. sr_log($_POST['data']);
  1156. sr_log('----------------------汇付回调-------------------------');
  1157. $params = $_POST['data'];
  1158. # 加载SDK需要的文件
  1159. include_once "../extend/thirdpay/AdapaySdk/init.php";
  1160. # 加载商户的配置文件
  1161. include_once "../extend/thirdpay/config.php";
  1162. $adapay_tools = new \AdaPaySdk\AdapayTools();
  1163. $post_data = json_decode($_POST['data'], 1);
  1164. $post_data_str = json_encode($post_data, JSON_UNESCAPED_UNICODE);
  1165. $post_sign_str = isset($_POST['sign']) ? $_POST['sign'] : '';
  1166. # 先校验签名和返回的数据的签名的数据是否一致
  1167. $sign_flag = $adapay_tools->verifySign($post_data_str, $post_sign_str);
  1168. if ($sign_flag) {
  1169. Db::startTrans();
  1170. try {
  1171. if ($post_data['status'] != 'succeeded') {
  1172. sr_throw('成功1');
  1173. }
  1174. $pay_info = Db::name('payment')->where('out_trade_no', $post_data['order_no'])->lock(true)->find();
  1175. if ($pay_info['state'] != 7) {
  1176. sr_throw('成功1');
  1177. }
  1178. $service = new ThirdPayServices();
  1179. $service->payBack($post_data['order_no'], 0, 14, json_encode($params));
  1180. Db::commit();
  1181. } catch (\Exception $e) {
  1182. Db::rollback();
  1183. sr_log('汇付支付宝回调报错:' . $e->getMessage());
  1184. return api_succ_return('成功2' . $e->getMessage());
  1185. die();
  1186. }
  1187. return api_succ_return('成功');
  1188. die();
  1189. } else {
  1190. sr_log('签名不通过:[' . $post_sign_str . ']' . 'post_data_str--[' . $post_data_str . ']');
  1191. return api_succ_return('成功1');
  1192. die();
  1193. }
  1194. }
  1195. /**
  1196. * 代付回调
  1197. * @param Request $request
  1198. * @return string
  1199. */
  1200. public function thirdPayZfbNewBackdf(Request $request)
  1201. {
  1202. sr_log('----------------------三方支付宝代付电科回调-------------------------1');
  1203. sr_log($request->param());
  1204. sr_log('----------------------三方支付宝代付电科回调-------------------------2');
  1205. $params = $request->param();
  1206. $service = new ThirdPayServices();
  1207. if (isset($params['orderId']) && isset($params['amount'])) {
  1208. // 校验签名
  1209. if (isset($params['sign'])) {
  1210. $back_sign = $params['sign'];
  1211. unset($params['sign']);
  1212. $sign = $service->diankesigndf($params);
  1213. if ($sign == $back_sign) {
  1214. try {
  1215. $service->payDfBack($params['orderId'], $params['amount'], $params, json_encode($params));
  1216. } catch (Exception $e) {
  1217. sr_log('电科报错' . $e->getMessage());
  1218. return 'success';
  1219. }
  1220. } else {
  1221. return 'success';
  1222. }
  1223. }
  1224. }
  1225. return 'success';
  1226. }
  1227. /**
  1228. * 三方微信sqz回调
  1229. * @param Request $request
  1230. * @return string
  1231. */
  1232. public function thirdPaySqzWeixinBack(Request $request)
  1233. {
  1234. sr_log('----------------------三方微信sqz回调-------------------------');
  1235. sr_log($request->param());
  1236. sr_log('----------------------三方微信sqz回调-------------------------');
  1237. $params = $request->param();
  1238. if (isset($params['orderid']) && isset($params['opstate']) && isset($params['ovalue'])) {
  1239. // 校验签名
  1240. if (isset($params['sign'])) {
  1241. $sign = md5('orderid=' . $params['orderid'] . '&opstate=' . $params['opstate'] . '&ovalue=' . $params['ovalue'] . env('PAYSQZ.SIGNKEY'));
  1242. if ($sign === $params['sign']) {
  1243. if ($params['opstate'] == 0) {
  1244. Db::startTrans();
  1245. try {
  1246. $service = new ThirdPayServices();
  1247. $service->payBack($params['orderid'], $params['ovalue'], 17, json_encode($params));
  1248. Db::commit();
  1249. } catch (\Exception $e) {
  1250. Db::rollback();
  1251. sr_log($e->getMessage());
  1252. return 'opstate=0' . $e->getMessage();
  1253. }
  1254. } else {
  1255. return 'opstate=01';
  1256. }
  1257. } else {
  1258. return 'opstate=0';
  1259. }
  1260. }
  1261. }
  1262. return 'opstate=0';
  1263. }
  1264. /**
  1265. * 三方银行快捷sqz回调
  1266. * @param Request $request
  1267. * @return string
  1268. */
  1269. public function thirdPaySqzKuaiBack(Request $request)
  1270. {
  1271. sr_log('----------------------三方银行快捷sqz回调-------------------------');
  1272. sr_log($request->param());
  1273. sr_log('----------------------三方银行快捷sqz回调-------------------------');
  1274. $params = $request->param();
  1275. if (isset($params['orderid']) && isset($params['opstate']) && isset($params['ovalue'])) {
  1276. // 校验签名
  1277. if (isset($params['sign'])) {
  1278. $sign = md5('orderid=' . $params['orderid'] . '&opstate=' . $params['opstate'] . '&ovalue=' . $params['ovalue'] . env('PAYSQZ.SXY_SIGNKEY'));
  1279. if ($sign === $params['sign']) {
  1280. if ($params['opstate'] == 0) {
  1281. Db::startTrans();
  1282. try {
  1283. $service = new ThirdPayServices();
  1284. $service->payBack($params['orderid'], $params['ovalue'], 18, json_encode($params));
  1285. Db::commit();
  1286. } catch (\Exception $e) {
  1287. Db::rollback();
  1288. sr_log($e->getMessage());
  1289. return 'opstate=0' . $e->getMessage();
  1290. }
  1291. } else {
  1292. return 'opstate=01';
  1293. }
  1294. } else {
  1295. sr_log('yinsheng快捷银行签名有问题');
  1296. return 'opstate=01';
  1297. }
  1298. }
  1299. }
  1300. return 'opstate=0';
  1301. }
  1302. /**
  1303. * Ys银盛第三方支付回调
  1304. * @param Request $request
  1305. * @return string
  1306. */
  1307. public function thirdPayYsBack(Request $request)
  1308. {
  1309. $params = $request->post();
  1310. $res = $this->sign_verify($params);
  1311. $date = date('Y-m-d H:i:s');
  1312. $outTradeNo = isset($params['out_trade_no']) ? $params['out_trade_no'] : '0';
  1313. $cacheKey = "caches:payment:ysBack:{$outTradeNo}";
  1314. RedisCache::set($cacheKey . '_param', ['params' => $params, 'sign' => $res, 'date' => $date], 7200);
  1315. if ($res) {
  1316. Db::startTrans();
  1317. try {
  1318. $service = new ThirdPayServices();
  1319. $service->payBack($params['out_trade_no'], $params['settlement_amount'], 20, json_encode($params), $cacheKey);
  1320. Db::commit();
  1321. } catch (\Exception $e) {
  1322. Db::rollback();
  1323. RedisCache::set($cacheKey . '_fail', ['error' => '银盛回调报错:' . $e->getMessage(), 'params' => $params, 'sign' => $res, 'date' => $date], 7200);
  1324. return 'success';
  1325. }
  1326. } else {
  1327. RedisCache::set($cacheKey . '_signFail', ['error' => '银盛签名有问题', 'params' => $params, 'sign' => $res, 'date' => $date], 7200);
  1328. return 'success';
  1329. }
  1330. return 'success';
  1331. }
  1332. /**
  1333. * 验签转明码
  1334. * @param input check
  1335. * @param input msg
  1336. * @return data
  1337. * @return success
  1338. */
  1339. public function sign_check($sign, $data)
  1340. {
  1341. $publickeyFile = env('ZLYS.CER_PATH'); //公钥
  1342. $certificateCAcerContent = file_get_contents($publickeyFile);
  1343. $certificateCApemContent = '-----BEGIN CERTIFICATE-----' . PHP_EOL . chunk_split(base64_encode($certificateCAcerContent), 64, PHP_EOL) . '-----END CERTIFICATE-----' . PHP_EOL;
  1344. // 签名验证
  1345. $success = openssl_verify($data, base64_decode($sign), openssl_get_publickey($certificateCApemContent), OPENSSL_ALGO_SHA1);
  1346. return $success;
  1347. }
  1348. /**
  1349. * 签名验证
  1350. * @param $data
  1351. * @return bool
  1352. */
  1353. public function sign_verify($data)
  1354. {
  1355. //返回的数据处理
  1356. $sign = trim($data['sign']);
  1357. unset($data['sign']);
  1358. ksort($data);
  1359. $url = "";
  1360. foreach ($data as $key => $val) {
  1361. /* 验证签名 */
  1362. if ($val) $url .= $key . '=' . $val . '&';
  1363. }
  1364. $str = trim($url, '&');
  1365. if ($this->sign_check($sign, $str) != true) {
  1366. return false;
  1367. } else {
  1368. return true;
  1369. }
  1370. }
  1371. /**
  1372. * 用户银行卡绑定回调
  1373. * @param Request $request
  1374. * @return string
  1375. * @throws \think\db\exception\DataNotFoundException
  1376. * @throws \think\db\exception\DbException
  1377. * @throws \think\db\exception\ModelNotFoundException
  1378. */
  1379. public function userSignBank(Request $request)
  1380. {
  1381. $para = $request->param();
  1382. $date = date('Y-m-d H:i:s');
  1383. $cacheKey = "caches:userBankSign:callback:";
  1384. RedisCache::set($cacheKey . 'param', ['msg' => '支付三方签约sqz回调', 'params' => $para, 'date' => $date], 7200);
  1385. if (isset($para['userno']) && $para['userno']) {
  1386. // 校验签名
  1387. if (isset($para['orderid']) && isset($para['opstate']) && isset($para['userno']) && isset($para['sign'])) {
  1388. $sign = md5('orderid=' . $para['orderid'] . '&opstate=' . $para['opstate'] . '&userno=' . $para['userno'] . env('PAYSQZ.SIGNKEY'));
  1389. if ($sign === $para['sign']) {
  1390. if (UserBankSignService::make()->checkHasBySignOrderId($para['orderid'])) {
  1391. // 获取userno 然后保存
  1392. Db::name('user_bank_sign')->where('signorder_id', $para['orderid'])->save([
  1393. 'userno' => $para['userno'],
  1394. 'status' => 2
  1395. ]);
  1396. }
  1397. return 'success';
  1398. } else {
  1399. return 'error';
  1400. }
  1401. }
  1402. }
  1403. return 'error';
  1404. }
  1405. /**
  1406. * 之前对接的支付备份
  1407. * @param Request $request
  1408. * @return \think\Response
  1409. */
  1410. private function payOldAction(Request $request)
  1411. {
  1412. $setting = [];
  1413. $appresource = $request->post('app_sources', '');
  1414. $order_type = $request->post('order_type');
  1415. if (empty($order_type)) {
  1416. return api_error_return('参数错误');
  1417. }
  1418. // 商城购买
  1419. if ($order_type == 4) {
  1420. if ($appresource == 'android') {
  1421. // 石学长 银联支付
  1422. array_push($setting, ['is_open' => 1, 'channel' => 15, 'title' => '银联(协议绑卡)', 'icon' => getWebUrl() . '/static/img/payconfig/ic_yinlian_pay.png']);
  1423. }
  1424. if ($appresource == 'ios') {
  1425. // 石学长 银联支付
  1426. array_push($setting, ['is_open' => 1, 'channel' => 15, 'title' => '银联', 'icon' => getWebUrl() . '/static/img/payconfig/ic_yinlian_pay.png']);
  1427. }
  1428. }
  1429. // 购买服务商
  1430. if ($order_type == 6) {
  1431. if ($appresource == 'android') {
  1432. // 石学长 银联支付
  1433. array_push($setting, ['is_open' => 1, 'channel' => 15, 'title' => '银联(协议绑卡)', 'icon' => getWebUrl() . '/static/img/payconfig/ic_yinlian_pay.png']);
  1434. // 无卡快捷支付 直连银盛
  1435. array_push($setting, ['is_open' => 1, 'channel' => 20, 'title' => '无卡快捷银联支付(支持信用卡)', 'icon' => getWebUrl() . '/static/img/payconfig/ic_yinlian_pay.png']);
  1436. }
  1437. if ($appresource == 'ios') {
  1438. // 石学长 银联支付
  1439. array_push($setting, ['is_open' => 1, 'channel' => 15, 'title' => '银联(协议绑卡)', 'icon' => getWebUrl() . '/static/img/payconfig/ic_yinlian_pay.png']);
  1440. // 无卡快捷支付
  1441. array_push($setting, ['is_open' => 1, 'channel' => 20, 'title' => '无卡快捷银联支付(支持信用卡)', 'icon' => getWebUrl() . '/static/img/payconfig/ic_yinlian_pay.png']);
  1442. }
  1443. }
  1444. }
  1445. }