GongdengOrderService.php 8.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | Laravel框架 [ Laravel ]
  4. // +----------------------------------------------------------------------
  5. // | 版权所有 2017~2021 Laravel研发中心
  6. // +----------------------------------------------------------------------
  7. // | 官方网站: http://www.laravel.cn
  8. // +----------------------------------------------------------------------
  9. // | Author: wesmiler <12345678@qq.com>
  10. // +----------------------------------------------------------------------
  11. namespace App\Services;
  12. use App\Models\GongdengFoxiangModel;
  13. use App\Models\GongdengOrderModel;
  14. use App\Models\LampMealsModel;
  15. use App\Models\MemberModel;
  16. /**
  17. * 供灯管理-服务类
  18. * @author wesmiler
  19. * @since 2020/11/11
  20. * Class GongdengOrderService
  21. * @package App\Services
  22. */
  23. class GongdengOrderService extends BaseService
  24. {
  25. /**
  26. * 构造函数
  27. * @author wesmiler
  28. * @since 2020/11/11
  29. * GongdengOrderService constructor.
  30. */
  31. public function __construct()
  32. {
  33. $this->model = new GongdengOrderModel();
  34. }
  35. /**
  36. * 功德列表
  37. */
  38. public function getGdList()
  39. {
  40. $params = request()->all();
  41. $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE;
  42. $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE;
  43. $dataList = $this->model::from('gongdeng_orders as a')
  44. ->leftJoin('gongdeng_foxiang as gf', 'gf.id', '=', 'a.source_id')
  45. ->leftJoin('member as m', 'a.user_id', '=', 'm.id')
  46. ->where(['a.mark' => 1, 'a.status' => 2])
  47. ->select(['a.id', 'a.source_id', 'a.user_id', 'a.sf_name', 'a.qf_content', 'a.is_hide', 'gf.name as fx_name', 'm.nickname', 'm.avatar', 'a.status', 'a.create_time', 'a.pay_at', 'a.update_time'])
  48. ->orderBy('a.pay_at', 'desc')
  49. ->orderBy('a.create_time', 'desc')
  50. ->paginate($pageSize);
  51. $dataList = $dataList ? $dataList->toArray() : [];
  52. if ($dataList) {
  53. foreach ($dataList['data'] as &$item) {
  54. $item['avatar'] = $item['avatar'] ? get_image_url($item['avatar']) : '';
  55. $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : '';
  56. $time = $item['pay_at'] ? $item['pay_at'] : $item['create_time'];
  57. $item['time_text'] = $time ? format_time(strtotime($time)) : '刚刚';
  58. if ($item['is_hide']) {
  59. $item['nickname'] = formatName($item['nickname']);
  60. }
  61. }
  62. unset($item);
  63. }
  64. return [
  65. 'code' => 0,
  66. 'success' => true,
  67. 'msg' => '操作成功',
  68. 'count' => isset($dataList['total']) ? $dataList['total'] : 0,
  69. 'data' => isset($dataList['data']) ? $dataList['data'] : 0,
  70. ];
  71. }
  72. /**
  73. * 我的供灯列表
  74. */
  75. public function getMyGdList($userId)
  76. {
  77. $params = request()->all();
  78. $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE;
  79. $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE;
  80. $dataList = $this->model::from('gongdeng_orders as a')
  81. ->leftJoin('gongdeng_foxiang as gf', 'gf.id', '=', 'a.source_id')
  82. ->leftJoin('member as m', 'a.user_id', '=', 'm.id')
  83. ->where(['a.mark' => 1, 'a.status' => 2,'a.user_id'=> $userId])
  84. ->select(['a.id', 'a.source_id', 'a.user_id', 'a.sf_name', 'a.qf_content','a.lamp_status','a.device_num', 'a.is_hide','a.expire_time', 'gf.name as fx_name', 'm.nickname', 'm.avatar', 'a.status', 'a.create_time', 'a.pay_at', 'a.update_time'])
  85. ->orderBy('a.pay_at', 'desc')
  86. ->orderBy('a.create_time', 'desc')
  87. ->paginate($pageSize);
  88. $dataList = $dataList ? $dataList->toArray() : [];
  89. if ($dataList) {
  90. foreach ($dataList['data'] as &$item) {
  91. $item['avatar'] = $item['avatar'] ? get_image_url($item['avatar']) : '';
  92. $item['create_time'] = $item['create_time'] ? datetime($item['create_time'], 'Y-m-d H:i:s') : '';
  93. $item['expire_at'] = $item['expire_time'] ? datetime($item['expire_time'], 'Y-m-d H:i:s') : '';
  94. $time = $item['pay_at'] ? $item['pay_at'] : $item['create_time'];
  95. $item['time_text'] = $time ? format_time(strtotime($time)) : '刚刚';
  96. if ($item['is_hide']) {
  97. $item['nickname'] = formatName($item['nickname']);
  98. }
  99. }
  100. unset($item);
  101. }
  102. return [
  103. 'code' => 0,
  104. 'success' => true,
  105. 'msg' => '操作成功',
  106. 'count' => isset($dataList['total']) ? $dataList['total'] : 0,
  107. 'data' => isset($dataList['data']) ? $dataList['data'] : 0,
  108. ];
  109. }
  110. /**
  111. * 供灯下单
  112. */
  113. public function buy($userId)
  114. {
  115. $params = request()->all();
  116. // 验证佛像信息
  117. $fid = isset($params['fid']) ? $params['fid'] : 0;
  118. $foInfo = GongdengFoxiangModel::where(['id' => $fid, 'status' => 1, 'mark' => 1])
  119. ->select(['id', 'name'])
  120. ->first();
  121. if (!$foInfo || $fid <= 0) {
  122. return message('供灯佛像信息不存在', false);
  123. }
  124. $payType = isset($params['payType']) ? $params['payType'] : 0;
  125. if (!in_array($payType, [1])) {
  126. return message('支付方式暂不支持', false);
  127. }
  128. // 套餐信息
  129. $mid = isset($params['mid']) ? $params['mid'] : 0;
  130. $mealInfo = LampMealsModel::where(['id' => $mid, 'status' => 1, 'mark' => 1])
  131. ->select(['id', 'name', 'price', 'num'])
  132. ->first();
  133. if (!$mealInfo) {
  134. return message('供灯套餐不存在或已下架', false);
  135. }
  136. // 验证用户是否已授权
  137. $memberInfo = MemberModel::where(['id' => $userId, 'mark' => 1, 'status' => 1])
  138. ->select('id', 'openid', 'nickname')
  139. ->first();
  140. $openid = isset($memberInfo['openid']) ? trim($memberInfo['openid']) : '';
  141. if (!$memberInfo) {
  142. return message('账号已被冻结,请联系客服', false);
  143. }
  144. if (empty($openid)) {
  145. return message('账号获取授权参数失败,请退出重试', false);
  146. }
  147. // 验证是否供灯过
  148. $buyType = 1;
  149. $gdCheckData = GongdengOrderModel::where(['source_id' => $fid, 'user_id' => $userId, 'status' => 2, 'mark' => 1])
  150. ->where('expire_time', '>=', time())
  151. ->select(['id', 'source_id', 'user_id','device_num', 'expire_time', 'params'])
  152. ->first();
  153. // 续费
  154. if ($gdCheckData && $gdCheckData->id) {
  155. $buyType = 2;
  156. }
  157. // 创建订单
  158. $expireTime = ($mealInfo->num * 24 * 3600) + time();
  159. $data = [
  160. 'source_id' => $fid,
  161. 'user_id' => $userId,
  162. 'pay_type' => $payType,
  163. 'buy_type' => $buyType,
  164. 'order_sn' => get_order_num('G'),
  165. 'num' => 1,
  166. 'price' => $mealInfo->price,
  167. 'total' => $mealInfo->price,
  168. 'sf_name' => isset($params['sf_name']) ? trim($params['sf_name']) : '',
  169. 'qf_content' => isset($params['qf_content']) ? trim($params['qf_content']) : '',
  170. 'is_hide' => isset($params['is_hide']) ? intval($params['is_hide']) : 0,
  171. 'expire_time' => $expireTime,
  172. 'create_time' => time(),
  173. 'status' => 1,
  174. ];
  175. if($gdCheckData){
  176. $data['params'] = $gdCheckData->params;
  177. }
  178. // 订单
  179. if (!$oid = GongdengOrderModel::insertGetId($data)) {
  180. return message('供灯订单创建失败', false);
  181. }
  182. // 支付参数
  183. switch ($payType) {
  184. case 1: // 微信支付
  185. $order = [
  186. 'openid' => $openid,
  187. 'orderNo' => $data['order_sn'],
  188. 'amount' => $data['total'],
  189. 'body' => '供灯订单支付',
  190. ];
  191. $jsapiParams = WechatService::jsapiUnifiedorder($order);
  192. $code = isset($jsapiParams['code']) ? $jsapiParams['code'] : '';
  193. if ($code == 'error' || empty($jsapiParams)) {
  194. $message = isset($jsapiParams['message']) && $jsapiParams['message'] ? $jsapiParams['message'] : '订单支付处理失败';
  195. return message($message, false);
  196. }
  197. return message('订单创建成功', true, ['id' => $oid, 'params' => $jsapiParams]);
  198. break;
  199. default:
  200. break;
  201. }
  202. return message('支付处理失败', false);
  203. }
  204. }