AskController.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742
  1. <?php
  2. namespace App\Http\Controllers\Api;
  3. use App\Http\Requests\Api\PostsRequests\AskRequest;
  4. use Illuminate\Http\Request;
  5. use Illuminate\Support\Facades\DB;
  6. use App\Wen\Utils\Utils;
  7. use App\Models\WxOrder;
  8. use App\Models\User\WxUser;
  9. use App\Http\Controllers\Api\Traits\PayTrait;
  10. use App\Wen\Utils\Settings;
  11. use App\Wen\Utils\UserUtils;
  12. use App\Models\WxSlideshow;
  13. use App\Wen\Utils\GatewayUtils;
  14. class AskController extends BaseController
  15. {
  16. use PayTrait;
  17. public function test(Request $request){
  18. $chat_content = '你好'.date('Y-m-d H:i:s');
  19. $chat_image = '';
  20. $uid = $request->uid;
  21. $oid = 4395;
  22. $websocket_id = GatewayUtils::uid2client_id($oid);
  23. $websocket_id = 'all';
  24. if($websocket_id){
  25. GatewayUtils::success($websocket_id, 5, ['chat_content'=>_mini_emoji($chat_content, true), 'chat_image'=>$chat_image,
  26. 'from_user'=>UserUtils::get_cached_user($uid) ]);
  27. }
  28. }
  29. public function config(Request $request){
  30. $result = [
  31. 'askorder_default_question' => Settings::get('askorder_default_question', ''),
  32. 'askorder_default_hidden' => Settings::get('askorder_default_hidden', ''),
  33. 'askorder_default_public' => Settings::get('askorder_default_public', ''),
  34. 'askorder_default_rule' => Settings::get('askorder_default_rule', ''),
  35. ];
  36. return $this->success($result);
  37. }
  38. //发起一个咨询
  39. public function createNew(AskRequest $request){
  40. // 验证
  41. $request->validate('createnew');
  42. //提示绑定手机号
  43. $userinfo = DB::table('wx_user')->where('id',$request->uid)->first();
  44. if(empty($userinfo->phone)){
  45. return $this->fail(200016,[],'请先绑定手机号');
  46. }
  47. //
  48. $question = trim($request->question);
  49. if(mb_strlen($question) > 300){
  50. return $this->fail(200016,[],'咨询内容不能超过300字');
  51. }
  52. //
  53. $images = trim($request->images);
  54. $images = trim($images,',');
  55. if(count(explode(',',$images)) > 9){
  56. return $this->fail(200016,[],'咨询图片最大9张');
  57. }
  58. //验证答主
  59. if($request->uid == $request->blogger_user_id){
  60. return $this->fail(200016,[],'不能咨询自己');
  61. }
  62. $blogger = DB::table('blogger')->where('user_id',$request->blogger_user_id)->first();
  63. if(empty($blogger)){
  64. return $this->fail(200016,[],'此答主没有经过认证');
  65. }
  66. if($blogger->status != 1){
  67. return $this->fail(200016,[],'此答主没有经过认证');
  68. }
  69. if($blogger->ask_status != 1){
  70. return $this->fail(200016,[],'此答主暂时不接受咨询');
  71. }
  72. //
  73. $data = [
  74. 'user_id' => $request->uid,
  75. 'blogger_user_id' => $request->blogger_user_id,
  76. 'question' => $question,
  77. 'images' => $images,
  78. 'createtime' => time(),
  79. 'ask_price' => $blogger->ask_price,
  80. 'sit_price' => $blogger->sit_price,
  81. 'ask_minute' => $blogger->ask_minute,
  82. 'is_hidden' => $request->is_hidden,
  83. 'is_public' => $request->is_public,
  84. 'blogger_rate' => Settings::get('askorder_blogger_balance_rate'),
  85. ];
  86. $data['blogger_price'] = bcdiv(bcmul($data['ask_price'],$data['blogger_rate'],2),100,2);
  87. //0元的直接已付
  88. $need_pay = 1;
  89. if($blogger->ask_price == 0){
  90. $data['status'] = 10;
  91. $data['paytime'] = time();
  92. $need_pay = 0;
  93. }
  94. $order_id = DB::table('ask_order')->insertGetId($data);
  95. //给答主发短信
  96. $blogger_userinfo = DB::table('wx_user')->where('id',$request->blogger_user_id)->first();
  97. if($blogger_userinfo && $blogger_userinfo->phone && $blogger_userinfo->country_code){
  98. $idd = $blogger_userinfo->country_code;
  99. $phone = $blogger_userinfo->phone;
  100. //
  101. $res = Utils::sendSMSnotice($idd,$phone);
  102. }
  103. return $this->success(['order_id'=>$order_id,'need_pay'=>$need_pay]);
  104. }
  105. //评价此次咨询
  106. public function evaluate(AskRequest $request){
  107. // 验证
  108. $request->validate('evaluate');
  109. //
  110. $eva_content = trim($request->eva_content);
  111. if(mb_strlen($eva_content) > 100){
  112. return $this->fail(200016,[],'咨询内容不能超过100字');
  113. }
  114. //
  115. $score = $request->eva_score;
  116. if($score < 0){
  117. $score = 0;
  118. }
  119. if($score > 5){
  120. $score = 5;
  121. }
  122. //
  123. $order_id = _empty_default_($request->order_id,0);
  124. $order = DB::table('ask_order')->where('id',$order_id)->where('user_id',$request->uid)->where('status','>',0)->first();
  125. if(empty($order)){
  126. return $this->fail(200016,[],'没有找到该咨询');
  127. }
  128. if($order->status != 20){
  129. return $this->fail(200016,[],'咨询还没有结束');
  130. }
  131. if($order->eva_time != 0){
  132. return $this->fail(200016,[],'已经评价过了');
  133. }
  134. //
  135. $update = [
  136. 'eva_score' => $request->eva_score,
  137. 'eva_content' => $request->eva_content,
  138. 'eva_time' => time(),
  139. ];
  140. DB::table('ask_order')->where('id',$order_id)->update($update);
  141. //给答主冗余平均分
  142. $eva_score = DB::table('ask_order')->where('blogger_user_id',$order->blogger_user_id)->where('status',20)->where('eva_time','!=',0)->avg('eva_score');
  143. if($eva_score < 0){
  144. $eva_score = 0;
  145. }
  146. if($eva_score > 5){
  147. $eva_score = 5;
  148. }
  149. $eva_score = bcadd($eva_score,0,1);
  150. DB::table('blogger')->where('user_id',$order->blogger_user_id)->update(['order_eva_score'=>$eva_score]);
  151. return $this->success();
  152. }
  153. //结束此次咨询,用户或答主都可操作
  154. public function finish(Request $request){
  155. //
  156. $order_id = _empty_default_($request->order_id,0);
  157. $uid = $request->uid;
  158. $order = DB::table('ask_order')->where('id',$order_id)->where('status','>',0)
  159. // ->where('user_id',$request->uid)
  160. ->where(function($query) use ($uid) {
  161. $query->orWhere('user_id', $uid)
  162. ->orWhere('blogger_user_id', $uid);
  163. })
  164. ->first();
  165. if(empty($order)){
  166. return $this->fail(200016,[],'没有找到该咨询');
  167. }
  168. if($order->status == 20){
  169. return $this->fail(200016,[],'咨询已经结束了');
  170. }
  171. //给答主钱
  172. UserUtils::update_user_financial($order->blogger_user_id, 103, $order->blogger_price, '咨询收益'.$order->blogger_price);
  173. //更新状态
  174. $update = [
  175. 'status' => 20,
  176. 'finish_time' => time(),
  177. ];
  178. DB::table('ask_order')->where('id',$order_id)->update($update);
  179. //更新答主的完成订单数
  180. $order_number = DB::table('ask_order')->where('blogger_user_id',$order->blogger_user_id)->where('status',20)->count();
  181. DB::table('blogger')->where('user_id',$order->blogger_user_id)->update(['order_number' => $order_number]);
  182. //结束了,给另一方发socket通知
  183. $oid = $order['user_id'] == $uid ? $order['blogger_user_id'] : $order['user_id'];
  184. $websocket_id = GatewayUtils::uid2client_id($oid);
  185. if($websocket_id){
  186. $mode = 56;
  187. $socket_content = [
  188. 'ask_order_id' => $ask_order_id,
  189. 'from_user' => UserUtils::get_cached_user($uid),
  190. ];
  191. GatewayUtils::success($websocket_id, $mode, $socket_content);
  192. }
  193. return $this->success();
  194. }
  195. //点赞
  196. public function good(Request $request){
  197. //
  198. $order_id = _empty_default_($request->order_id,0);
  199. $uid = $request->uid;
  200. $good = DB::table('ask_order_good')->where('order_id',$order_id)->where('user_id',$request->uid)->first();
  201. if(!empty($good)){
  202. return $this->fail(200016,[],'您已经赞过了');
  203. }
  204. DB::table('ask_order_good')->insertGetId([
  205. 'order_id' => $order_id,
  206. 'user_id' => $request->uid,
  207. 'createtime' => time(),
  208. ]);
  209. //冗余
  210. $good_number = DB::table('ask_order_good')->where('order_id',$order_id)->count();
  211. DB::table('ask_order')->where('id',$order_id)->update(['good_number'=>$good_number]);
  212. return $this->success();
  213. }
  214. //旁听
  215. public function sit(Request $request){
  216. $order_id = _empty_default_($request->order_id,0);
  217. $order = DB::table('ask_order')->where('id',$order_id)->first();
  218. if(empty($order)){
  219. return $this->fail(200016,[],'没有找到该咨询');
  220. }
  221. if($order->status != 20){
  222. return $this->fail(200016,[],'咨询还没有结束');
  223. }
  224. if($order->is_public != 1){
  225. return $this->fail(200016,[],'咨询没有公开');
  226. }
  227. if($order->user_id == $request->uid){
  228. return $this->fail(200016,[],'不需要旁听自己咨询的内容');
  229. }
  230. if($order->blogger_user_id == $request->uid){
  231. return $this->fail(200016,[],'不需要旁听自己回答的内容');
  232. }
  233. //是否需要支付
  234. $need_pay = 1;
  235. //检查旁听订单
  236. $sit_order_id = 0;
  237. $sit_order = DB::table('ask_sit_order')->where('order_id',$order_id)->where('sit_user_id',$request->uid)->first();
  238. if($sit_order){
  239. $sit_order_id = $sit_order->id;
  240. if($sit_order->status == 10){
  241. return $this->fail(200016,[],'已经旁听过了');
  242. }else{
  243. //去支付即可
  244. }
  245. }else{
  246. $data = [
  247. 'user_id' => $order->user_id,
  248. 'order_id' => $order_id,
  249. 'sit_user_id' => $request->uid,
  250. 'createtime' => time(),
  251. 'sit_price' => $order->sit_price,
  252. //咨询者收益
  253. 'user_rate' => Settings::get('sitorder_user_balance_rate'),
  254. ];
  255. $data['user_price'] = bcdiv(bcmul($data['sit_price'],$data['user_rate'],2),100,2);
  256. if($order->sit_price == 0){
  257. $need_pay = 0; //零元不需要支付
  258. $data['status'] = 10;
  259. $data['paytime'] = time();
  260. }
  261. $sit_order_id = DB::table('ask_sit_order')->insertGetId($data);
  262. }
  263. return $this->success(['sit_order_id'=>$sit_order_id,'need_pay'=>$need_pay]);
  264. }
  265. //付费咨询订单,余额支付+拉起
  266. public function payAskOrder(Request $request)
  267. {
  268. $order_id = _empty_default_($request->order_id,0);
  269. $uid = $request->uid;
  270. $order = DB::table('ask_order')->where('id',$order_id)->where('user_id',$request->uid)->first();
  271. if(empty($order)){
  272. return $this->fail(200016,[],'没有找到该咨询');
  273. }
  274. if($order->status != 0){
  275. return $this->fail(200016,[],'该咨询已经支付过了');
  276. }
  277. //使用余额支付
  278. if($request->pay_type == 'balance'){
  279. //检查支付密码
  280. $rs = $this->check_paycode($uid,$request->paycode);
  281. if($rs !== true){
  282. return $rs;
  283. }
  284. //检查余额
  285. $balance = UserUtils::user_balance($uid);
  286. if($balance <= $order->ask_price){
  287. return $this->fail(200012);
  288. }
  289. DB::beginTransaction();
  290. //余额支付
  291. $pay_res = UserUtils::update_user_financial($uid, 101, $order->ask_price, '您花费了¥'.$order->ask_price.'余额,付费咨询');
  292. if(!$pay_res){
  293. DB::rollBack();
  294. return $this->fail(200012);
  295. }
  296. //直接修改订单状态,支付完成
  297. $rs1 = DB::table('ask_order')->where('id',$order_id)->update(['status'=>10,'paytime'=>time()]);
  298. if(!$rs1){
  299. DB::rollBack();
  300. return $this->fail([],200,'支付失败');
  301. }
  302. DB::commit();
  303. return $this->success([],200,'余额支付成功');
  304. }
  305. //拉起三方支付
  306. $body = '付费咨询';
  307. $data['body'] = '付费咨询';
  308. $total_fee = $order->ask_price;
  309. $orderSn = 'A' . Utils::getSn('A');
  310. $parame = serialize($data);
  311. // 创建订单
  312. $this->createOrder($uid,101,$body,$total_fee,$total_fee,$orderSn,$parame,'ask_order',$order_id);
  313. $openid = WxUser::where('id', $uid)->value('weixin_openid');
  314. $appid = Settings::get('app_id');
  315. $mch_id = Settings::get('mch_id');
  316. $key = Settings::get('mch_secret');
  317. $out_trade_no = $orderSn;
  318. if(_empty_($openid)){
  319. return $this->fail(200043, [
  320. 'title' => '未绑定微信',
  321. 'content' => '还没有获取到您的小程序openId,无法拉起支付',
  322. 'confirmText' => '去绑定',
  323. 'target_type' => 6,
  324. 'target_id' => '/pagesA/mine/editmine/accountbind'
  325. ], '未绑定微信');
  326. }
  327. return $this->payHandler($uid, $request->pay_type, $request->platform, $total_fee, $data['body'], $out_trade_no, 1);
  328. }
  329. //付费旁听订单,余额支付+拉起
  330. public function paySitOrder(Request $request)
  331. {
  332. $order_id = _empty_default_($request->order_id,0);
  333. $uid = $request->uid;
  334. $order = DB::table('ask_sit_order')->where('id',$order_id)->where('sit_user_id',$request->uid)->first();
  335. if(empty($order)){
  336. return $this->fail(200016,[],'没有找到该旁听');
  337. }
  338. if($order->status != 0){
  339. return $this->fail(200016,[],'该旁听已经支付过了');
  340. }
  341. //使用余额支付
  342. if($request->pay_type == 'balance'){
  343. //检查支付密码
  344. $rs = $this->check_paycode($uid,$request->paycode);
  345. if($rs != true){
  346. return $rs;
  347. }
  348. //检查余额
  349. $balance = UserUtils::user_balance($uid);
  350. if($balance <= $order->sit_price){
  351. return $this->fail(200012);
  352. }
  353. DB::beginTransaction();
  354. //余额支付
  355. $pay_res = UserUtils::update_user_financial($uid, 102, $order->sit_price, '您花费了¥'.$order->sit_price.'余额,付费旁听');
  356. if(!$pay_res){
  357. DB::rollBack();
  358. return $this->fail(200012);
  359. }
  360. //分钱给咨询者,扣除平台服务费及IOS渠道费
  361. UserUtils::update_user_financial($order->user_id, 104, $order->user_price, '旁听收益'.$order->user_price);
  362. //直接修改订单状态,支付完成
  363. $rs1 = DB::table('ask_sit_order')->where('id',$order_id)->update(['status'=>10,'paytime'=>time()]);
  364. if(!$rs1){
  365. DB::rollBack();
  366. return $this->fail([],200,'支付失败');
  367. }
  368. //冗余旁听订单数量
  369. $ask_order_id = $order->order_id;
  370. $sit_number = DB::table('ask_sit_order')->where('order_id',$ask_order_id)->where('status',10)->count();
  371. DB::table('ask_order')->where('id',$ask_order_id)->update(['sit_number'=>$sit_number]);
  372. DB::commit();
  373. return $this->success([],200,'余额支付成功');
  374. }
  375. //拉起三方支付
  376. $body = '付费旁听';
  377. $data['body'] = '付费旁听';
  378. $total_fee = $order->sit_price;
  379. $orderSn = 'S' . Utils::getSn('S');
  380. $parame = serialize($data);
  381. // 创建订单
  382. $this->createOrder($uid,102,$body,$total_fee,$total_fee,$orderSn,$parame,'ask_sit_order',$order_id);
  383. $openid = WxUser::where('id', $uid)->value('weixin_openid');
  384. $appid = Settings::get('app_id');
  385. $mch_id = Settings::get('mch_id');
  386. $key = Settings::get('mch_secret');
  387. $out_trade_no = $orderSn;
  388. if(_empty_($openid)){
  389. return $this->fail(200043, [
  390. 'title' => '未绑定微信',
  391. 'content' => '还没有获取到您的小程序openId,无法拉起支付',
  392. 'confirmText' => '去绑定',
  393. 'target_type' => 6,
  394. 'target_id' => '/pagesA/mine/editmine/accountbind'
  395. ], '未绑定微信');
  396. }
  397. return $this->payHandler($uid, $request->pay_type, $request->platform, $total_fee, $data['body'], $out_trade_no, 1);
  398. }
  399. //检查支付密码
  400. private function check_paycode($uid, $paycode){
  401. //验证支付密码
  402. if(_empty_($paycode)){
  403. return $this->fail(200004, [], '请先输入支付密码');
  404. }
  405. if(is_array($paycode) && str_replace(',', '', implode(',', $paycode)) !== get_user_meta($uid, 'paycode', 's')){
  406. return $this->fail(200043, [
  407. 'title' => '支付密码错误',
  408. 'content' => '已忘记,前往修改?',
  409. 'confirmText' => '去修改',
  410. 'target_type' => 6,
  411. 'target_id' => '/pagesA/mine/paycode/forget'
  412. ], '支付密码错误');
  413. }
  414. if(is_string($paycode) && $paycode !== get_user_meta($uid, 'paycode', 's')){
  415. return $this->fail(200004, [], '支付密码不匹配');
  416. }
  417. return true;
  418. }
  419. /**
  420. * 创建支付订单
  421. * $order_type = 101 咨询订单
  422. * $order_type = 102 旁听订单
  423. */
  424. private function createOrder($user_id,$order_type,$order_information,$order_price,$order_pay_price,$order_number,$parame='',$table_name,$table_id)
  425. {
  426. $orderModel = new WxOrder();
  427. $orderModel->user_id = $user_id;
  428. $orderModel->order_type = $order_type;
  429. $orderModel->order_information = $order_information;
  430. $orderModel->order_price = $order_price;
  431. $orderModel->order_pay_price = $order_pay_price;
  432. $orderModel->order_number = $order_number;
  433. $orderModel->parame = $parame;
  434. $orderModel->table_name = $table_name;
  435. $orderModel->table_id = $table_id;
  436. $orderModel->save();
  437. return $orderModel;
  438. }
  439. //首页轮播
  440. public function banner(Request $request){
  441. $ids = Settings::get('app_ask_banner', '', true);
  442. //$ids = '30,32,33,34,35,36,37';
  443. $list = WxSlideshow::wherein('id', explode(',', $ids))->orderBy(DB::raw('FIND_IN_SET(id, "' . $ids . '")'))
  444. ->get(['id', 'poster', 'target_id', 'slideshow_type']);
  445. return $this->success($list);
  446. }
  447. //我购买的旁听列表ok
  448. public function sitList(Request $request){
  449. //分页
  450. $page = $request->page ?? 1;
  451. $limit = $request->limit ?? 10;
  452. $offset = ($page - 1) * $limit;
  453. //
  454. $order_ids = DB::table('ask_sit_order')->where('sit_user_id',$request->uid)->where('status',10)->orderBy('id','desc')->pluck('order_id');
  455. $order_ids = json_decode(json_encode($order_ids),true);
  456. if(empty($order_ids)){
  457. return $this->success();
  458. }
  459. //
  460. $list = DB::table('ask_order')
  461. ->leftJoin('wx_user as user','user.id','=','ask_order.user_id')
  462. ->leftJoin('wx_user as buser','buser.id','=','ask_order.blogger_user_id')
  463. ->leftJoin('blogger','blogger.user_id','=','ask_order.blogger_user_id')
  464. ->select('ask_order.*','user.user_avatar','user.user_name','buser.user_avatar as blogger_avatar','buser.user_name as blogger_name','blogger.info as blogger_info')
  465. ->offset($offset)->limit($limit)
  466. ->where('ask_order.status',20)
  467. ->where('ask_order.is_public',1)
  468. ->whereIN('ask_order.id',$order_ids)
  469. ->orderBy(DB::raw('FIND_IN_SET(ask_order.id, "' . implode(',', $order_ids) . '")'))
  470. ->get();
  471. $list = json_decode(json_encode($list),true);
  472. foreach($list as &$val){
  473. if($val['user_id'] == $request->uid){
  474. //登录者是咨询者
  475. }elseif($val['is_hidden'] == 0 && $val['blogger_user_id'] == $request->uid){
  476. //登录者是答主,并且非匿名
  477. }else{
  478. $val['user_avatar'] = Settings::get('askorder_hidden_user_avatar');//匿名头像
  479. $val['user_name'] = '匿名用户';
  480. }
  481. unset($val['images']);
  482. unset($val['user_id']);
  483. }
  484. return $this->success($list);
  485. }
  486. //所有咨询列表
  487. public function askList(Request $request){
  488. //分页
  489. $page = $request->page ?? 1;
  490. $limit = $request->limit ?? 10;
  491. $offset = ($page - 1) * $limit;
  492. //
  493. $where = [];
  494. //答主
  495. $blogger_user_id = _empty_default_($request->blogger_user_id,0);
  496. if($blogger_user_id){
  497. $where[] = ['ask_order.blogger_user_id','=',$blogger_user_id];
  498. }
  499. //用户
  500. $user_id = _empty_default_($request->user_id,0);
  501. if($user_id){
  502. $where[] = ['ask_order.user_id','=',$user_id];
  503. }
  504. //搜索
  505. $keyword = _empty_default_($request->keyword,'');
  506. if($keyword){
  507. $where[] = ['ask_order.question','like','%'.$keyword.'%'];
  508. }
  509. //
  510. $list = DB::table('ask_order')
  511. ->leftJoin('wx_user as user','user.id','=','ask_order.user_id')
  512. ->leftJoin('wx_user as buser','buser.id','=','ask_order.blogger_user_id')
  513. ->leftJoin('blogger','blogger.user_id','=','ask_order.blogger_user_id')
  514. ->select('ask_order.*','user.user_avatar','user.user_name','buser.user_avatar as blogger_avatar','buser.user_name as blogger_name','blogger.info as blogger_info')
  515. ->offset($offset)->limit($limit)
  516. ->where($where);
  517. //如果登录了
  518. if(($request->uid && $request->uid > 0) && ($request->uid == $user_id || $request->uid == $blogger_user_id)){
  519. $list = $list->whereIn('ask_order.status',[10,15,20]);
  520. }else{
  521. $list = $list->where([
  522. ['ask_order.status','=',20],
  523. ['ask_order.is_public','=',1]
  524. ]);
  525. }
  526. $list = $list->orderBy('ask_order.status','asc')->orderBy('ask_order.id','desc')->get();
  527. $list = json_decode(json_encode($list),true);
  528. if(!empty($list)){
  529. //获取未读信息
  530. $count_data = [];
  531. if(($request->uid && $request->uid > 0) && ($request->uid == $user_id || $request->uid == $blogger_user_id)){
  532. $order_ids = array_column($list,'id');
  533. $count_data = DB::table('wx_chat')->Where('object_id', $request->uid)->where('is_read',0)->where('chat_state',0)->where('expand_type',9)->whereIN('expand_id',$order_ids)->groupBy('expand_id')->select(Db::raw('count(id) as unread_number,expand_id'))->pluck('unread_number','expand_id');
  534. $count_data = json_decode(json_encode($count_data),true);
  535. }
  536. foreach($list as &$val){
  537. if($val['user_id'] == $request->uid){
  538. //登录者是咨询者
  539. }elseif($val['is_hidden'] == 0 && $val['blogger_user_id'] == $request->uid){
  540. //登录者是答主,并且非匿名
  541. }else{
  542. $val['user_avatar'] = Settings::get('askorder_hidden_user_avatar');//匿名头像
  543. $val['user_name'] = '匿名用户';
  544. }
  545. //未读数量
  546. $val['unread_number'] = isset($count_data[$val['id']]) ? $count_data[$val['id']] : 0;
  547. //答主看到的,如果未读为0,且没回复过,给算作1
  548. if($val['unread_number'] == 0 && $val['status'] == 10 && $val['blogger_user_id'] == $request->uid){
  549. $val['unread_number'] = 1;
  550. }
  551. unset($val['images']);
  552. unset($val['user_id']);
  553. }
  554. }
  555. return $this->success($list);
  556. }
  557. //咨询详情
  558. public function askInfo(Request $request){
  559. $order_id = _empty_default_($request->order_id,0);
  560. $info = DB::table('ask_order')
  561. ->leftJoin('wx_user as user','user.id','=','ask_order.user_id')
  562. ->leftJoin('wx_user as buser','buser.id','=','ask_order.blogger_user_id')
  563. ->leftJoin('blogger','blogger.user_id','=','ask_order.blogger_user_id')
  564. ->select('ask_order.*','user.user_avatar','user.user_name','buser.user_avatar as blogger_avatar','buser.user_name as blogger_name','blogger.info as blogger_info')
  565. ->where('ask_order.id',$order_id)
  566. ->first();
  567. $info = json_decode(json_encode($info),true);
  568. //匿名
  569. if($info['user_id'] == $request->uid){
  570. //登录者是咨询者
  571. }elseif($info['is_hidden'] == 0 && $info['blogger_user_id'] == $request->uid){
  572. //登录者是答主,并且非匿名
  573. }else{
  574. $info['user_avatar'] = Settings::get('askorder_hidden_user_avatar');//匿名头像
  575. $info['user_name'] = '匿名用户';
  576. }
  577. //是否点赞
  578. $good = DB::table('ask_order_good')->where('order_id',$order_id)->where('user_id',$request->uid)->first();
  579. $info['is_good'] = !empty($good) ? 1 : 0;
  580. return $this->success($info);
  581. }
  582. //某答主的评价列表
  583. public function bloggerEvaList(Request $request){
  584. //分页
  585. $page = $request->page ?? 1;
  586. $limit = $request->limit ?? 10;
  587. $offset = ($page - 1) * $limit;
  588. $blogger_user_id = $request->user_id;
  589. //
  590. $list = DB::table('ask_order')
  591. ->leftJoin('wx_user','wx_user.id','=','ask_order.user_id')
  592. ->select('ask_order.id','ask_order.user_id','ask_order.blogger_user_id','ask_order.eva_time','ask_order.eva_score','ask_order.eva_content','ask_order.is_hidden','wx_user.user_avatar','wx_user.user_name')
  593. ->where('ask_order.blogger_user_id',$blogger_user_id)
  594. ->where('ask_order.eva_time','>',0)
  595. ->where('ask_order.eva_content','!=','')
  596. ->whereNotNull('ask_order.eva_content')
  597. ->where('ask_order.status',20)
  598. ->orderBy('ask_order.eva_time','desc')
  599. ->offset($offset)->limit($limit)
  600. ->get();
  601. $list = json_decode(json_encode($list),true);
  602. if(empty($list)){
  603. return $this->success([]);
  604. }
  605. foreach($list as &$val){
  606. if($val['user_id'] == $request->uid){
  607. //自己提问的
  608. }elseif($val['is_hidden'] == 0 && $val['blogger_user_id'] == $request->uid){
  609. //登录者是答主,并且非匿名
  610. }else{
  611. $val['user_avatar'] = Settings::get('askorder_hidden_user_avatar');//匿名头像
  612. $val['user_name'] = '匿名用户';
  613. }
  614. }
  615. return $this->success($list);
  616. }
  617. }