Notify.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use app\common\service\UserService;
  5. use kjpay\kjpay;
  6. use think\Request;
  7. use think\Db;
  8. use addons\epay\library\Service;
  9. /**
  10. * 支付回调
  11. */
  12. class Notify extends Api
  13. {
  14. protected $noNeedLogin = ['wechatnotify', 'alipaynotify', 'wechatkjnotify'];
  15. protected $noNeedRight = ['*'];
  16. /**
  17. * 支付回调
  18. */
  19. public function wechatnotify()
  20. {
  21. $paytype = "wechat";
  22. $pay = Service::checkNotify($paytype);
  23. if (!$pay) {
  24. echo '签名错误';
  25. return;
  26. }
  27. $data = $pay->verify();
  28. try {
  29. $payamount = $data['total_fee'] / 100;
  30. $out_trade_no = $data['out_trade_no'];
  31. $transaction_id = $data['transaction_id'];
  32. Db::startTrans();
  33. try {
  34. $orderModel = new \app\common\model\RecharOrder();
  35. $userModel = new \app\common\model\User();
  36. $jewellogModel = new \app\common\model\UserJewelLog();
  37. $rechargelogModel = new \app\common\model\UserRechargeLog();
  38. $orderInfo = $orderModel->where(["order_no" => $out_trade_no])->find();
  39. $userInfo = $userModel->where(["id" => $orderInfo["user_id"]])->find();
  40. // 修改订单状态
  41. $res1 = $orderModel->update(["status" => 1,'transaction_id'=>$transaction_id], ["order_no" => $out_trade_no]);
  42. // 修改用户钻石余额
  43. $res2 = $userModel->where(["id" => $orderInfo["user_id"]])->setInc("jewel", $orderInfo["jewel"]);
  44. //判断是否首充
  45. $jewellogWhere['user_id'] = $orderInfo["user_id"];
  46. $jewellogWhere['type'] = 1;
  47. $userJewelLog = $jewellogModel->where($jewellogWhere)->find();
  48. $isFirst = 1;
  49. if (!empty($userJewelLog)) {
  50. $isFirst = 0;
  51. }
  52. $preUserId = $userInfo['pre_userid'];
  53. // 添加钻石流水记录
  54. $detail = "钻石充值";
  55. $res3 = $jewellogModel->addUserJewelLog($userInfo["id"], $orderInfo["jewel"], "+", $userInfo["jewel"], $detail, 1);
  56. // 添加充值记录
  57. $res4 = $rechargelogModel->addRecord($userInfo["id"], $orderInfo["jewel"], 0, bcadd($userInfo["jewel"], $orderInfo["jewel"], 2), $userInfo["money"], $orderInfo["platform"], 1,$isFirst,$preUserId);
  58. if ($res1 && $res2 && $res3 && $res4) {
  59. // 添加统计
  60. $userInfo->chargecount = $userInfo->chargecount + $payamount;
  61. $userInfo->chargetime = time();
  62. $userInfo->save();
  63. $userService = new UserService();
  64. $userService->inviteMoney(['user_id'=>$orderInfo["user_id"]]);
  65. // +EXP 充值任意金额
  66. \app\common\model\TaskLog::tofinish($orderInfo["user_id"], "5EMwg7la", 1);
  67. // 查询今日充值记录
  68. $today = strtotime(date("Y-m-d 00:00:00"));
  69. $rechargeMoney = \app\common\model\RecharOrder::where(["user_id" => $orderInfo["user_id"], "createtime" => ["gt", $today]])->sum("money");
  70. if ($rechargeMoney >= 100) {
  71. // +EXP 充值超过100
  72. \app\common\model\TaskLog::tofinish($orderInfo["user_id"], "DaCVgOLu", 1);
  73. }
  74. Db::commit();
  75. }
  76. } catch (ValidateException $e) {
  77. Db::rollback();
  78. $this->error($e->getMessage());
  79. } catch (PDOException $e) {
  80. Db::rollback();
  81. $this->error($e->getMessage());
  82. } catch (Exception $e) {
  83. Db::rollback();
  84. $this->error($e->getMessage());
  85. }
  86. //你可以在此编写订单逻辑
  87. } catch (Exception $e) {
  88. }
  89. echo $pay->success();
  90. }
  91. /**
  92. * 支付回调
  93. */
  94. public function alipaynotify()
  95. {
  96. $paytype = "alipay";
  97. $pay = Service::checkNotify($paytype);
  98. if (!$pay) {
  99. echo '签名错误';
  100. return;
  101. }
  102. $data = $pay->verify();
  103. /*$dataStr = '{
  104. "s": "\/api\/notify\/alipaynotify",
  105. "gmt_create": "2023-07-12 09:37:14",
  106. "charset": "utf-8",
  107. "seller_email": "ixiaoqiuqiu@qq.com",
  108. "subject": "充值钻石",
  109. "sign": "SzP5OgA9Z+qD8mSzMbAbKFsYOyB6fiH\/8itILn6YqX0Aloa5FnOxUHXEKCFlv5k3ya+OORjZPDq5mt7eZ3FvwJUasSWnMgDlSa6zWLGhlkKE3HXVAe777tkM5UgnVw53uJEr\/Ur2UsLpI+qEcrZAXhNAhA2nNNWhwkvrA1Fyc3iZERnbtJ3XNT\/8nnxGMBjhS3TWlr3VDZ\/bb26fvC1qHQ9Y6GGz8gvj3z30Fo7\/DlLFvH2HFSi6wky+33vWEtgug+klsqh6ziOWaVJhJKvnt2H+ltINiKLCshYVhu8ZBc856sV8noEwMmxPoFTW4CoG7ut\/3PKLjglygSOZblyf4Q==",
  110. "buyer_id": "2088702050034935",
  111. "invoice_amount": "0.01",
  112. "notify_id": "2023071201222093714034931493558779",
  113. "fund_bill_list": "[{&quot;amount&quot;:&quot;0.01&quot;,&quot;fundChannel&quot;:&quot;ALIPAYACCOUNT&quot;}]",
  114. "notify_type": "trade_status_sync",
  115. "trade_status": "TRADE_SUCCESS",
  116. "receipt_amount": "0.01",
  117. "app_id": "2021004103620776",
  118. "buyer_pay_amount": "0.01",
  119. "sign_type": "RSA2",
  120. "seller_id": "2088641467220712",
  121. "gmt_payment": "2023-07-12 09:37:14",
  122. "notify_time": "2023-07-12 09:37:14",
  123. "version": "1.0",
  124. "out_trade_no": "20230712093707239053",
  125. "total_amount": "0.01",
  126. "trade_no": "2023071222001434931415906799",
  127. "auth_app_id": "2021004103620776",
  128. "buyer_logon_id": "136****5934",
  129. "point_amount": "0.00"
  130. }';
  131. $data = json_decode($dataStr,true);*/
  132. try {
  133. $payamount = $data['total_amount'];
  134. $out_trade_no = $data['out_trade_no'];
  135. $trade_no = $data['trade_no'];
  136. Db::startTrans();
  137. try {
  138. $orderModel = new \app\common\model\RecharOrder();
  139. $userModel = new \app\common\model\User();
  140. $jewellogModel = new \app\common\model\UserJewelLog();
  141. $rechargelogModel = new \app\common\model\UserRechargeLog();
  142. $orderInfo = $orderModel->where(["order_no" => $out_trade_no])->find();
  143. $userInfo = $userModel->where(["id" => $orderInfo["user_id"]])->find();
  144. // 修改订单状态
  145. $res1 = $orderModel->update(["status" => 1,'transaction_id' => $trade_no], ["order_no" => $out_trade_no]);
  146. // 修改用户钻石余额
  147. $res2 = $userModel->where(["id" => $orderInfo["user_id"]])->setInc("jewel", $orderInfo["jewel"]);
  148. //判断是否首充
  149. $jewellogWhere['user_id'] = $orderInfo["user_id"];
  150. $jewellogWhere['type'] = 1;
  151. $userJewelLog = $jewellogModel->where($jewellogWhere)->find();
  152. $isFirst = 1;
  153. if (!empty($userJewelLog)) {
  154. $isFirst = 0;
  155. }
  156. $preUserId = $userInfo['pre_userid'];
  157. // 添加钻石流水记录
  158. $detail = "钻石充值";
  159. $res3 = $jewellogModel->addUserJewelLog($userInfo["id"], $orderInfo["jewel"], "+", $userInfo["jewel"], $detail, 1);
  160. // 添加充值记录
  161. $res4 = $rechargelogModel->addRecord($userInfo["id"], $orderInfo["jewel"], $payamount, bcadd($userInfo["jewel"], $orderInfo["jewel"], 2), $userInfo["money"], $orderInfo["platform"], 2,$isFirst,$preUserId);
  162. if ($res1 && $res2 && $res3 && $res4) {
  163. // 添加统计
  164. $userInfo->chargecount = $userInfo->chargecount + $payamount;
  165. $userInfo->chargetime = time();
  166. $userInfo->save();
  167. $userService = new UserService();
  168. $userService->inviteMoney(['user_id'=>$orderInfo["user_id"]]);
  169. // +EXP 充值任意金额
  170. \app\common\model\TaskLog::tofinish($orderInfo["user_id"], "5EMwg7la", 1);
  171. // 查询今日充值记录
  172. $today = strtotime(date("Y-m-d 00:00:00"));
  173. $rechargeMoney = \app\common\model\RecharOrder::where(["user_id" => $orderInfo["user_id"], "createtime" => ["gt", $today]])->sum("money");
  174. if ($rechargeMoney >= 100) {
  175. // +EXP 充值超过100
  176. \app\common\model\TaskLog::tofinish($orderInfo["user_id"], "DaCVgOLu", 1);
  177. }
  178. } else {
  179. $res1 = $orderModel->update(["status" => -1], ["order_no" => $out_trade_no]);
  180. if (!$res1) {
  181. throw new Exception('更新充值状态失败:'.$out_trade_no);
  182. }
  183. }
  184. Db::commit();
  185. } catch (ValidateException $e) {
  186. Db::rollback();
  187. $this->error($e->getMessage());
  188. } catch (PDOException $e) {
  189. Db::rollback();
  190. $this->error($e->getMessage());
  191. } catch (Exception $e) {
  192. Db::rollback();
  193. $this->error($e->getMessage());
  194. }
  195. //你可以在此编写订单逻辑
  196. } catch (Exception $e) {
  197. }
  198. echo $pay->success();
  199. }
  200. /**
  201. * 支付回调
  202. */
  203. public function wechatkjnotify()
  204. {
  205. $input = file_get_contents("php://input"); // 主题信息
  206. $dataArr = explode("&", urldecode($input));
  207. $data = [];
  208. if ($dataArr) foreach ($dataArr as $k => $v) {
  209. $vv = explode("=", $v);
  210. $data[$vv[0]] = $vv[1];
  211. }
  212. // 实例化支付类
  213. $kjpay = new kjpay();
  214. // 获取公共参数
  215. $config = config("kjPay");
  216. //密钥
  217. $key = $config["key"];
  218. $sign = $data['sign'];
  219. unset($data['sign']);
  220. if ($kjpay->local_sign($data, $key) == $sign) {
  221. //验签成功后,开始业务逻辑
  222. try {
  223. $payamount = $data['amount'];
  224. $out_trade_no = $data['merchant_order_no'];
  225. $pay_channel = $data['pay_channel'];
  226. Db::startTrans();
  227. try {
  228. $orderModel = new \app\common\model\RecharOrder();
  229. $userModel = new \app\common\model\User();
  230. $jewellogModel = new \app\common\model\UserJewelLog();
  231. $rechargelogModel = new \app\common\model\UserRechargeLog();
  232. $orderInfo = $orderModel->where(["order_no" => $out_trade_no])->find();
  233. $userInfo = $userModel->where(["id" => $orderInfo["user_id"]])->find();
  234. // 修改订单状态
  235. $res1 = $orderModel->update(["status" => 1], ["order_no" => $out_trade_no]);
  236. // 修改用户钻石余额
  237. $res2 = $userModel->where(["id" => $orderInfo["user_id"]])->setInc("jewel", $orderInfo["jewel"]);
  238. // 添加钻石流水记录
  239. $detail = "砖石充值";
  240. $res3 = $jewellogModel->addUserJewelLog($userInfo["id"], $orderInfo["jewel"], "+", $userInfo["jewel"], $detail, 1);
  241. // 添加充值记录
  242. $rechargeCount = $rechargelogModel->where('user_id',$orderInfo["user_id"])->count();
  243. $isFirstRecharge = $rechargeCount > 0 ? 0 : 1;
  244. $platformArr = ["wx_app_pay" => 1, "ali_wap_pay" => 2, "wx_public_pay" => 3];
  245. $res4 = $rechargelogModel->addRecord($userInfo["id"], $orderInfo["jewel"], $payamount, bcadd($userInfo["jewel"], $orderInfo["jewel"], 2), $userInfo["money"], $orderInfo["platform"], $platformArr[$pay_channel], $isFirstRecharge, $userInfo["pre_userid"]);
  246. if ($res1 && $res2 && $res3 && $res4) {
  247. // 添加统计
  248. $time = time();
  249. (new \app\common\model\User)->execute("update hx_user set chargecount = chargecount + $payamount,chargetime = $time where id = " . $userInfo["id"]);
  250. // \app\common\model\Test::update(["content"=>"update hx_user set chargecount = chargecount + $payamount,chargetime = $time where id = ".$userInfo["id"]],["id"=>1]);
  251. // 首充赠送
  252. $userInfo = \app\common\model\User::get($orderInfo["user_id"]);
  253. if ($userInfo->is_recharge == 0) { // 首充
  254. Db::startTrans();
  255. try {
  256. // 赠送消息尾灯
  257. $res1 = \app\common\model\AttireBack::addToMyBack(15, $orderInfo["user_id"]);
  258. $userInfo->is_recharge = 1;
  259. $res2 = $userInfo->save();
  260. if ($res1 && $res2) Db::commit();
  261. } catch (ValidateException $e) {
  262. Db::rollback();
  263. $this->error($e->getMessage());
  264. }
  265. }
  266. $this->rebate($orderInfo["user_id"], $data['amount']);
  267. // +EXP
  268. \app\common\model\TaskLog::tofinish($orderInfo["user_id"], "5EMwg7la", 1);
  269. // 查询今日充值记录
  270. $today = strtotime(date("Y-m-d 00:00:00"));
  271. $rechargeMoney = \app\common\model\RecharOrder::where(["user_id" => $orderInfo["user_id"], "createtime" => ["gt", $today]])->sum("money");
  272. if ($rechargeMoney >= 100) {
  273. // +EXP
  274. \app\common\model\TaskLog::tofinish($orderInfo["user_id"], "DaCVgOLu", 1);
  275. }
  276. // 查询新人礼包
  277. $this->addBagGift($orderInfo["user_id"], $data['amount']);
  278. Db::commit();
  279. echo "success";
  280. exit;
  281. }
  282. } catch (ValidateException $e) {
  283. Db::rollback();
  284. $this->error($e->getMessage());
  285. } catch (PDOException $e) {
  286. Db::rollback();
  287. $this->error($e->getMessage());
  288. } catch (Exception $e) {
  289. Db::rollback();
  290. $this->error($e->getMessage());
  291. }
  292. //你可以在此编写订单逻辑
  293. } catch (Exception $e) {
  294. }
  295. }
  296. }
  297. /**
  298. * 银联提现回调
  299. */
  300. public function cashoutNotify()
  301. {
  302. }
  303. /**
  304. * 更新新人礼包
  305. */
  306. private function addBagGift($user_id, $amount)
  307. {
  308. if (!$user_id || !$amount) return false;
  309. // 先看该用户是否有新人礼包特权
  310. $have = \app\common\model\NewBagHave::where(["user_id" => $user_id])->find();
  311. // print_r($have);exit;
  312. if ($have && time() - $have->createtime <= 7 * 86400) {
  313. $where = [];
  314. $where["value"] = ["elt", $amount];
  315. $bagInfo = \app\common\model\NewBag::where($where)->order("value", "desc")->select();
  316. if (!$bagInfo) return false;
  317. $res1 = false;
  318. foreach ($bagInfo as $k => $v) {
  319. // 查询完成情况
  320. $bagfinish = \app\common\model\NewBagFinish::where(["user_id" => $user_id, "bag_id" => $v["id"]])->find();
  321. if (!$bagfinish || $bagfinish->status <= 0) {
  322. if ($bagfinish) {
  323. $bagfinish->status = 1;
  324. $bagfinish->updatetime = time();
  325. $res1 = $bagfinish->save();
  326. } else {
  327. $res1 = \app\common\model\NewBagFinish::insert(["user_id" => $user_id, "bag_id" => $v["id"], "status" => 1, "updatetime" => time()]);
  328. }
  329. break;
  330. }
  331. }
  332. return $res1;
  333. }
  334. }
  335. /**
  336. * 充值返利
  337. */
  338. private function rebate($user_id, $money)
  339. {
  340. // // 获取配置信息
  341. // $config = \app\common\model\RebateConfig::where(["recharge"=>$money])->find();
  342. // if(!$config) return true;
  343. // 找到当前用户的上级和上上级
  344. $userInfo = \app\common\model\User::get($user_id);
  345. if ($userInfo->pre_userid > 0) {
  346. $preUserInfo = \app\common\model\User::where(["id" => $userInfo->pre_userid])->find();// 上一级用户
  347. $this->addRebateMoney($preUserInfo->id, $user_id, $money, 1);
  348. if ($preUserInfo->pre_userid > 0) {
  349. $this->addRebateMoney($preUserInfo->pre_userid, $user_id, $money, 2);
  350. } else {
  351. return true;
  352. }
  353. } else {
  354. return true;
  355. }
  356. }
  357. /**
  358. * 添加返利金额
  359. */
  360. private function addRebateMoney($preUserId, $user_id, $money, $type)
  361. {
  362. Db::startTrans();
  363. try {
  364. // 添加返利记录表
  365. $data = [];
  366. $data["user_id"] = $preUserId;
  367. $data["by_user_id"] = $user_id;
  368. $data["money"] = $money;
  369. $data["rebate_money"] = 0.00;
  370. $data["rebate_type"] = $type;
  371. $data["createtime"] = time();
  372. $res1 = \app\common\model\RebateLog::insertGetId($data);
  373. // $res2 = (new \app\common\model\RebateLog)->execute("update hx_rebate_log set rebate_money = $rebatemoney where id = $res1");
  374. if ($res1) {
  375. Db::commit();
  376. }
  377. } catch (ValidateException $e) {
  378. Db::rollback();
  379. $this->error($e->getMessage());
  380. } catch (PDOException $e) {
  381. Db::rollback();
  382. $this->error($e->getMessage());
  383. } catch (Exception $e) {
  384. Db::rollback();
  385. $this->error($e->getMessage());
  386. }
  387. }
  388. }