Recharge.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417
  1. <?php
  2. declare (strict_types=1);
  3. namespace app\system\controller;
  4. use app\BaseController;
  5. use app\Request;
  6. use app\model\api\RechargeConfig;
  7. use app\model\api\RechargeOrder;
  8. use app\model\api\User;
  9. use library\services\UtilService;
  10. use think\facade\Db;
  11. class Recharge extends BaseController
  12. {
  13. /**
  14. * 充值配置列表
  15. * @param Request $request
  16. * @return mixed
  17. */
  18. public function configList(Request $request)
  19. {
  20. $post = UtilService::getMore([
  21. ['page', 1],
  22. ['pageSize', 20],
  23. ['title', ''],
  24. ['is_show', '']
  25. ], $request);
  26. $where = [];
  27. if (!empty($post['title'])) {
  28. $where['title'] = ['like', '%' . $post['title'] . '%'];
  29. }
  30. if (!empty($post['is_show'])) {
  31. $where['is_show'] = $post['is_show'];
  32. }
  33. $rechargeConfig = new RechargeConfig();
  34. $list = $rechargeConfig->getList($where, '*', $post['page'], $post['pageSize'], 'sort asc,id asc');
  35. return app('json')->success([
  36. 'list' => $list[1],
  37. 'total' => $list[0],
  38. 'page' => $post['page'],
  39. 'pageSize' => $post['pageSize']
  40. ]);
  41. }
  42. /**
  43. * 充值配置详情
  44. * @param Request $request
  45. * @return mixed
  46. */
  47. public function configDetail(Request $request)
  48. {
  49. $post = UtilService::getMore([
  50. ['id', 0]
  51. ], $request);
  52. if ($post['id'] <= 0) {
  53. return app('json')->fail('参数错误');
  54. }
  55. $rechargeConfig = new RechargeConfig();
  56. $config = $rechargeConfig->getById($post['id']);
  57. if (!$config) {
  58. return app('json')->fail('充值配置不存在');
  59. }
  60. return app('json')->success($config);
  61. }
  62. /**
  63. * 添加充值配置
  64. * @param Request $request
  65. * @return mixed
  66. */
  67. public function configAdd(Request $request)
  68. {
  69. $post = UtilService::getMore([
  70. ['title', ''],
  71. ['price', 0],
  72. ['integral', 0],
  73. ['give_integral', 0],
  74. ['sort', 0],
  75. ['is_show', 1],
  76. ['is_default', 0],
  77. ['min_price', 0],
  78. ['max_price', 0],
  79. ['content', '']
  80. ], $request);
  81. if (empty($post['title'])) {
  82. return app('json')->fail('套餐名称不能为空');
  83. }
  84. if ($post['price'] <= 0) {
  85. return app('json')->fail('充值金额必须大于0');
  86. }
  87. if ($post['integral'] <= 0) {
  88. return app('json')->fail('获得积分必须大于0');
  89. }
  90. $rechargeConfig = new RechargeConfig();
  91. $data = [
  92. 'title' => $post['title'],
  93. 'price' => $post['price'],
  94. 'integral' => $post['integral'],
  95. 'give_integral' => $post['give_integral'],
  96. 'sort' => $post['sort'],
  97. 'is_show' => $post['is_show'],
  98. 'is_default' => $post['is_default'],
  99. 'min_price' => $post['min_price'],
  100. 'max_price' => $post['max_price'],
  101. 'content' => $post['content'],
  102. 'add_time' => time(),
  103. 'update_time' => time()
  104. ];
  105. $result = $rechargeConfig->saveData($data);
  106. if (!$result) {
  107. return app('json')->fail('添加失败');
  108. }
  109. return app('json')->success('添加成功');
  110. }
  111. /**
  112. * 编辑充值配置
  113. * @param Request $request
  114. * @return mixed
  115. */
  116. public function configEdit(Request $request)
  117. {
  118. $post = UtilService::getMore([
  119. ['id', 0],
  120. ['title', ''],
  121. ['price', 0],
  122. ['integral', 0],
  123. ['give_integral', 0],
  124. ['sort', 0],
  125. ['is_show', 1],
  126. ['is_default', 0],
  127. ['min_price', 0],
  128. ['max_price', 0],
  129. ['content', '']
  130. ], $request);
  131. if ($post['id'] <= 0) {
  132. return app('json')->fail('参数错误');
  133. }
  134. if (empty($post['title'])) {
  135. return app('json')->fail('套餐名称不能为空');
  136. }
  137. if ($post['price'] <= 0) {
  138. return app('json')->fail('充值金额必须大于0');
  139. }
  140. if ($post['integral'] <= 0) {
  141. return app('json')->fail('获得积分必须大于0');
  142. }
  143. $rechargeConfig = new RechargeConfig();
  144. $config = $rechargeConfig->getById($post['id']);
  145. if (!$config) {
  146. return app('json')->fail('充值配置不存在');
  147. }
  148. $data = [
  149. 'title' => $post['title'],
  150. 'price' => $post['price'],
  151. 'integral' => $post['integral'],
  152. 'give_integral' => $post['give_integral'],
  153. 'sort' => $post['sort'],
  154. 'is_show' => $post['is_show'],
  155. 'is_default' => $post['is_default'],
  156. 'min_price' => $post['min_price'],
  157. 'max_price' => $post['max_price'],
  158. 'content' => $post['content'],
  159. 'update_time' => time()
  160. ];
  161. $result = $rechargeConfig->updateConfig($post['id'], $data);
  162. if (!$result) {
  163. return app('json')->fail('编辑失败');
  164. }
  165. return app('json')->success('编辑成功');
  166. }
  167. /**
  168. * 删除充值配置
  169. * @param Request $request
  170. * @return mixed
  171. */
  172. public function configDelete(Request $request)
  173. {
  174. $post = UtilService::getMore([
  175. ['id', 0]
  176. ], $request);
  177. if ($post['id'] <= 0) {
  178. return app('json')->fail('参数错误');
  179. }
  180. $rechargeConfig = new RechargeConfig();
  181. $config = $rechargeConfig->getById($post['id']);
  182. if (!$config) {
  183. return app('json')->fail('充值配置不存在');
  184. }
  185. $result = $rechargeConfig->deleteData($post['id']);
  186. if (!$result) {
  187. return app('json')->fail('删除失败');
  188. }
  189. return app('json')->success('删除成功');
  190. }
  191. /**
  192. * 充值订单列表(后台)
  193. * @param Request $request
  194. * @return mixed
  195. */
  196. public function orderList(Request $request)
  197. {
  198. $post = UtilService::getMore([
  199. ['page', 1],
  200. ['pageSize', 20],
  201. ['order_id', ''],
  202. ['uid', ''],
  203. ['nickname', ''],
  204. ['mobile', ''],
  205. ['pay_type', ''],
  206. ['paid', ''],
  207. ['status', ''],
  208. ['time', []]
  209. ], $request);
  210. $where = [];
  211. if (!empty($post['order_id'])) {
  212. $where['order_id'] = $post['order_id'];
  213. }
  214. if (!empty($post['uid'])) {
  215. $where['uid'] = $post['uid'];
  216. }
  217. if (!empty($post['nickname'])) {
  218. $where['nickname'] = $post['nickname'];
  219. }
  220. if (!empty($post['mobile'])) {
  221. $where['mobile'] = $post['mobile'];
  222. }
  223. if (!empty($post['pay_type'])) {
  224. $where['pay_type'] = $post['pay_type'];
  225. }
  226. if (!empty($post['paid'])) {
  227. $where['paid'] = $post['paid'];
  228. }
  229. if (!empty($post['status'])) {
  230. $where['status'] = $post['status'];
  231. }
  232. if (!empty($post['time']) && !empty($post['time'][0]) && !empty($post['time'][1])) {
  233. $where['time'] = $post['time'];
  234. }
  235. $rechargeOrder = new RechargeOrder();
  236. $list = $rechargeOrder->getAdminList($where, '*', $post['page'], $post['pageSize']);
  237. return app('json')->success([
  238. 'list' => $list[1],
  239. 'total' => $list[0],
  240. 'page' => $post['page'],
  241. 'pageSize' => $post['pageSize']
  242. ]);
  243. }
  244. /**
  245. * 充值订单详情(后台)
  246. * @param Request $request
  247. * @return mixed
  248. */
  249. public function orderDetail(Request $request)
  250. {
  251. $post = UtilService::getMore([
  252. ['id', 0]
  253. ], $request);
  254. if ($post['id'] <= 0) {
  255. return app('json')->fail('参数错误');
  256. }
  257. $rechargeOrder = new RechargeOrder();
  258. $order = $rechargeOrder->getById($post['id']);
  259. if (!$order) {
  260. return app('json')->fail('订单不存在');
  261. }
  262. // 获取用户信息
  263. $userModel = new User();
  264. $user = $userModel->where('uid', $order['uid'])->find();
  265. $order['user_info'] = $user ? [
  266. 'nickname' => $user['nickname'],
  267. 'mobile' => $user['mobile'],
  268. 'avatar' => $user['avatar']
  269. ] : [];
  270. return app('json')->success($order);
  271. }
  272. /**
  273. * 后台手动充值(系统充值)
  274. * @param Request $request
  275. * @return mixed
  276. */
  277. public function systemRecharge(Request $request)
  278. {
  279. $post = UtilService::getMore([
  280. ['uid', 0],
  281. ['price', 0],
  282. ['integral', 0],
  283. ['give_integral', 0],
  284. ['remark', '']
  285. ], $request);
  286. if ($post['uid'] <= 0) {
  287. return app('json')->fail('用户ID错误');
  288. }
  289. if ($post['price'] <= 0) {
  290. return app('json')->fail('充值金额必须大于0');
  291. }
  292. if ($post['integral'] <= 0) {
  293. return app('json')->fail('获得积分必须大于0');
  294. }
  295. $userModel = new User();
  296. $user = $userModel->where('uid', $post['uid'])->find();
  297. if (!$user) {
  298. return app('json')->fail('用户不存在');
  299. }
  300. $rechargeOrder = new RechargeOrder();
  301. $totalIntegral = $post['integral'] + $post['give_integral'];
  302. // 创建系统充值订单
  303. $orderSn = $rechargeOrder->createOrder($post['uid'], 0, $post['price'], $post['integral'], $post['give_integral'], 'system', $request->admin_id, $post['remark']);
  304. if (!$orderSn) {
  305. return app('json')->fail('创建订单失败');
  306. }
  307. // 直接完成支付(系统充值无需支付)
  308. $updateResult = $rechargeOrder->updatePayStatus($orderSn, 'system_' . time(), '系统充值');
  309. if (!$updateResult) {
  310. return app('json')->fail('更新订单状态失败');
  311. }
  312. // 增加用户积分
  313. $userModel->where('uid', $post['uid'])->inc('score', $totalIntegral)->inc('score_in', $totalIntegral)->inc('total_recharge', $post['price'])->update();
  314. // 记录积分明细
  315. $scoreDetail = new UserScoreDetail();
  316. $scoreDetail->incomeScore($post['uid'], $totalIntegral, $orderSn, 'income_score', [
  317. 'o_id' => $rechargeOrder->getByOrderSn($orderSn)['id']
  318. ], $rechargeOrder->getByOrderSn($orderSn)['id']);
  319. return app('json')->success([
  320. 'order_id' => $orderSn,
  321. 'price' => $post['price'],
  322. 'integral' => $post['integral'],
  323. 'give_integral' => $post['give_integral'],
  324. 'total_integral' => $totalIntegral
  325. ]);
  326. }
  327. /**
  328. * 关闭充值订单
  329. * @param Request $request
  330. * @return mixed
  331. */
  332. public function closeOrder(Request $request)
  333. {
  334. $post = UtilService::getMore([
  335. ['order_id', '']
  336. ], $request);
  337. if (empty($post['order_id'])) {
  338. return app('json')->fail('订单号不能为空');
  339. }
  340. $rechargeOrder = new RechargeOrder();
  341. $order = $rechargeOrder->getByOrderSn($post['order_id']);
  342. if (!$order) {
  343. return app('json')->fail('订单不存在');
  344. }
  345. if ($order['paid'] == 1) {
  346. return app('json')->fail('已支付的订单不能关闭');
  347. }
  348. $result = $rechargeOrder->closeOrder($post['order_id']);
  349. if (!$result) {
  350. return app('json')->fail('关闭订单失败');
  351. }
  352. return app('json')->success('关闭订单成功');
  353. }
  354. }