StoreController.php 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Http\Controllers\Controller;
  4. use App\Models\Admin;
  5. use App\Models\Amount;
  6. use App\Models\Apply;
  7. use App\Models\Agent\AgentDwbsUser;
  8. use App\Models\Comment;
  9. use App\Models\DwbsUser;
  10. use App\Models\DwbsWarea;
  11. use App\Models\DwbsAdmin;
  12. use App\Models\GiftOrders;
  13. use App\Models\Order;
  14. use App\Models\Store;
  15. use App\Models\User;
  16. use App\Handlers\SignHandler;
  17. use App\Models\Warea;
  18. use Carbon\Carbon;
  19. use Illuminate\Database\Eloquent\Builder;
  20. use Illuminate\Http\Request;
  21. use Illuminate\Support\Facades\Auth;
  22. use Illuminate\Support\Facades\Cache;
  23. use Illuminate\Support\Facades\DB;
  24. use Illuminate\Support\Facades\Log;
  25. class StoreController extends Controller
  26. {
  27. //获取数据信息
  28. public function getDataInfo(){
  29. $admin_id=Auth::user()->id;
  30. $admin=Admin::where('id',$admin_id)->first();
  31. $lists=[];
  32. if($admin && in_array($admin->role_id,[22,24])){//超级管理员
  33. // $agent_ids=DwbsUser::where('status',0)->where('cert_status',6)->whereNull('deleted_at')->where('service_status',0)->pluck('id');
  34. $apply=Store::query()->groupBy('is_apply')->select(DB::raw('count(id) as num'),'is_apply')->pluck('num','is_apply');//->whereIn('user_id',$agent_ids)
  35. }else{
  36. $agent_ids=DwbsUser::whereHas('warea',function($query)use($admin_id){
  37. $query->where('admin_id',$admin_id);
  38. })->where('status',0)->where('cert_status',6)->whereNull('deleted_at')->where('service_status',0)->pluck('id');
  39. $apply=Store::whereIn('user_id',$agent_ids)->groupBy('is_apply')->select(DB::raw('count(id) as num'),'is_apply')->pluck('num','is_apply');
  40. }
  41. $lists['no_cert']=isset($apply[0])?$apply[0]:0;
  42. $lists['authing']=isset($apply[1])?$apply[1]:0;
  43. $lists['wait_sign']=isset($apply[2])?$apply[2]:0;
  44. $lists['finish']=isset($apply[3])?$apply[3]:0;
  45. $lists['rejected']=isset($apply[4])?$apply[4]:0;
  46. $lists['frozen']=isset($apply[5])?$apply[5]:0;
  47. $lists['delete']=Store::onlyTrashed()->where('is_failure',0)->count();
  48. return $this->success($lists);
  49. }
  50. //获取所有门店
  51. public function list(Request $request){
  52. $page_size=$request->input('page_size');
  53. $page_index=$request->input('page_index');
  54. $num=$page_size*($page_index-1);
  55. $admin_id=Auth::user()->id;
  56. $admin=Admin::where('id',$admin_id)->first();
  57. Log::info('--mendian--'.microtime());
  58. if($admin && in_array($admin->role_id,[22,24])){//超级管理员
  59. Log::info('--mendian1.1--'.microtime());
  60. $agent_ids=DwbsUser::where('status',0)->where('cert_status',6)->whereNull('deleted_at')->where('service_status',0)->pluck('id');
  61. $total=count($agent_ids);//所有可开通店铺人数
  62. Log::info('--mendian1.2--'.microtime());
  63. $data=Store::where('is_failure',0);
  64. }else{
  65. $warea_ids=DwbsWarea::where('admin_id',$admin_id)->pluck('id');
  66. if($request->has('is_delete') && $request->input('is_delete')==1){
  67. $agent_ids=DwbsUser::withTrashed()->where('status',0)->where('cert_status',6)->whereNotNull('deleted_at')->where('service_status',0)->whereIn('warea_id',$warea_ids)->pluck('id');
  68. }else{
  69. $agent_ids=DwbsUser::where('status',0)->where('cert_status',6)->whereNull('deleted_at')->where('service_status',0)->whereIn('warea_id',$warea_ids)->pluck('id');
  70. }
  71. $total=count($agent_ids);//政委可开通店铺人数
  72. $store_ids=Store::withTrashed()->where('is_failure',0)->whereIn('user_id',$agent_ids)->pluck('id');
  73. $data=Store::where('is_failure',0)->whereIn('id',$store_ids);
  74. }
  75. $data->with(['user' => function($query){
  76. $query->with(['warea:id,name','crown:id,nickname'])->select('id','nickname','mobile','level','agent_id','crown_id','warea_id','deleted_at');
  77. }]);
  78. $nums=$data->count();
  79. Log::info('--mendian2.2--'.microtime());
  80. //审核状态筛选
  81. if($request->has('is_apply') && $request->input('is_apply') <> 'all'){
  82. $data->where('is_apply',$request->input('is_apply'));
  83. }
  84. //代理筛选
  85. if($request->has('search_name') && $request->input('search_name')) {
  86. $data->where(function($query)use($request){
  87. $query->where('name','like','%'.$request->input('search_name').'%')
  88. ->orWhere('phone','like','%'.$request->input('search_name').'%');
  89. });
  90. }
  91. if($request->has('is_delete') && $request->input('is_delete')==1){
  92. $data->onlyTrashed()->where('is_failure',0);
  93. }
  94. $count=$data->count();
  95. Log::info('--mendian2.3--'.microtime());
  96. $data->select('id','name','img','user_id','created_at','status','is_apply','created_at','integral','cycle_inte',
  97. 'phone','star','province','city','area','address','username','idCard','account_bank','account_number','deleted_at','is_failure');
  98. $list=$data->orderBy('id','desc')->skip($num)->take($page_size)->get();
  99. Log::info('--mendian2.4--'.microtime());
  100. if(Cache::has('gift_orders')){
  101. $gift_orders=Cache::get('gift_orders');
  102. }else{
  103. $gift_orders=GiftOrders::where('type',0)->groupBy('store_id')
  104. ->select('store_id',DB::raw('sum(num*bonus) as integral'))->pluck('integral','store_id')->toArray();
  105. Cache::add('gift_orders', $gift_orders, 30);
  106. }
  107. Log::info('代理时间计算-3-'.microtime());
  108. foreach($list as $key=>$val){
  109. // $second=mt_rand(2880,7200);
  110. $warea=$val->user->warea;
  111. $list[$key]->warea=$warea['name'];
  112. $crown=$val->user->crown;
  113. $list[$key]->company=$crown['nickname'];
  114. if(array_key_exists($val->id, $gift_orders)){
  115. $list[$key]->finish_integral=$gift_orders[$val->id];
  116. }else{
  117. $list[$key]->finish_integral=0;
  118. }
  119. if(!empty($val->user) && $val->user->level==3){
  120. $list[$key]->company=$val->user->nickname;
  121. }
  122. }
  123. Log::info('代理时间计算-4-'.microtime());
  124. $lists['list']=$list;
  125. $lists['num']=$nums;
  126. $lists['total']=$total;
  127. Log::info('代理时间计算-5-'.microtime());
  128. return $this->success_list($lists,'成功',$count);
  129. }
  130. //导出所有门店
  131. public function export(Request $request){
  132. ini_set('memory_limit', '1280M');
  133. $admin_id=Auth::user()->id;
  134. $admin=Admin::where('id',$admin_id)->first();
  135. Log::info('--mendian--'.microtime());
  136. if($admin && in_array($admin->role_id,[22,24])){//超级管理员
  137. $data=Store::where('is_failure',0);
  138. }else{
  139. $warea_ids=DwbsWarea::where('admin_id',$admin_id)->pluck('id');
  140. $agent_ids=DwbsUser::where('status',0)->where('cert_status',6)->whereNull('deleted_at')->where('service_status',0)->whereIn('warea_id',$warea_ids)->pluck('id');
  141. $data=Store::where('is_failure',0)
  142. ->whereIn('user_id',$agent_ids);
  143. }
  144. // $data->with('user:id,nickname,mobile,level,agent_id,crown_id,warea_id,deleted_at');
  145. $data->with(['user' => function($query){
  146. $query->with(['warea:id,name','crown:id,nickname'])->select('id','nickname','mobile','level','agent_id','crown_id','warea_id','deleted_at');
  147. }]);
  148. //审核状态筛选
  149. if($request->has('is_apply') && $request->input('is_apply') <> 'all'){
  150. $data->where('is_apply',$request->input('is_apply'));
  151. }
  152. // //代理筛选
  153. if($request->has('search_name') && $request->input('search_name')) {
  154. $data->where(function($query)use($request){
  155. $query->where('name','like','%'.$request->input('search_name').'%')
  156. ->orWhere('phone','like','%'.$request->input('search_name').'%');
  157. });
  158. }
  159. if($request->has('search_name') && $request->input('is_delete')==1){
  160. $data->onlyTrashed()->where('is_failure',0);
  161. }
  162. $data->select('id','name','img','user_id','created_at','status','is_apply','created_at','integral','cycle_inte',
  163. 'phone','star','province','city','area','address','username','idCard','account_bank','account_number','deleted_at','is_failure');
  164. $list=$data->orderBy('id','desc')->get();
  165. //return $this->success($list);
  166. foreach($list as $key=>$val){
  167. $warea=$val->user->warea;
  168. $list[$key]->warea=$warea['name'];
  169. $crown=$val->user->crown;
  170. $list[$key]->company=$crown['nickname'];
  171. // if(array_key_exists($val->id, $gift_orders)){
  172. // $list[$key]->finish_integral=$gift_orders[$val->id];
  173. // }else{
  174. // $list[$key]->finish_integral=0;
  175. // }
  176. if(!empty($val->user) && $val->user->level==3){
  177. $list[$key]->company=$val->user->nickname;
  178. }
  179. }
  180. return $this->success($list);
  181. $admin_id=Auth::user()->id;
  182. $admin=Admin::where('id',$admin_id)->first();
  183. if($admin && in_array($admin->role_id,[22,24])){//超级管理员
  184. $store_user_ids=Store::pluck('user_id');
  185. $data=Store::with('user:id,nickname,mobile,level,agent_id');
  186. }else{
  187. $warea_ids=DwbsWarea::where('admin_id',$admin_id)->pluck('id');
  188. $agent_ids=DwbsUser::whereIn('warea_id',$warea_ids)->pluck('id');
  189. $store_ids=Store::whereIn('user_id',$agent_ids)->pluck('id');
  190. $store_user_ids = Store::whereIn('id',$store_ids)->pluck('user_id');
  191. $data=Store::with('user:id,nickname,mobile,level,agent_id')->whereIn('id',$store_ids);
  192. }
  193. //审核状态筛选
  194. if($request->has('is_apply') && ($request->input('is_apply') || $request->input('is_apply')==0) && $request->input('is_apply') <> 'all'){
  195. $data->where('is_apply',$request->input('is_apply'));
  196. }
  197. //代理筛选
  198. if($request->has('search_name') && $request->input('search_name')) {
  199. $data->where(function($query)use($request){
  200. $query->where('name','like','%'.$request->input('search_name').'%')
  201. ->orWhere('phone','like','%'.$request->input('search_name').'%');
  202. });
  203. }
  204. $list=$data->with(['comment','gift_order'])->orderBy('id','desc')->get();
  205. $wareas=Cache::remember('wareas',Carbon::now()->addHours(2),function (){
  206. return DwbsWarea::pluck('name','id');
  207. });
  208. $warea_user_ids=Cache::remember('warea_user_ids',Carbon::now()->addHours(2),function()use($store_user_ids){
  209. return DwbsUser::withTrashed()->whereIn('id',$store_user_ids)->pluck('warea_id','id');
  210. });
  211. if(Cache::has('gift_orders')){
  212. $gift_orders=Cache::get('gift_orders');
  213. }else{
  214. $gift_orders=GiftOrders::where('type',0)->groupBy('store_id')
  215. ->select('store_id',DB::raw('sum(num*bonus) as integral'))->pluck('integral','store_id')->toArray();
  216. Cache::add('gift_orders', $gift_orders, 30);
  217. }
  218. $result=$data->orderBy('id','desc')
  219. ->chunk('1000',function($lists)use($wareas,$warea_user_ids,$gift_orders){
  220. foreach($lists as $key=>$val){
  221. $list=$val;
  222. $second=mt_rand(86400,259200);
  223. if ($val->comment){
  224. $star=floor($val->comment->avg('star'));
  225. $list->star=$star==null?0:$star;
  226. }else{
  227. $list->star=0;
  228. }
  229. if(empty($val->user)){
  230. Log::info('为空拍给你们');
  231. Log::info($val);
  232. }
  233. if(!empty($val->user)){
  234. if(Cache::has('warea-'.$val->user->id)){
  235. $list->warea=Cache::get('warea-'.$val->user->id);
  236. }else{
  237. $warea_id=$warea_user_ids[$val->user_id];
  238. $list->warea=$wareas[$warea_id];
  239. Cache::add('warea-'.$val->user->id, $wareas[$warea_id], $second);
  240. }
  241. }
  242. if(array_key_exists($val->id, $gift_orders)){
  243. $list->finish_integral=$gift_orders[$val->id];
  244. }else{
  245. $list->finish_integral=0;
  246. }
  247. if(!empty($val->user) && $val->user->level==2){
  248. if(Cache::has('company-'.$val->user->id)){
  249. $list->company=Cache::get('company-'.$val->user->id);
  250. }else{
  251. $company=DwbsUser::withTrashed()->where('id',$val->user->agent_id)->value('nickname');
  252. $list->company=$company;
  253. Cache::add('company-'.$val->user->id, $company, $second);
  254. }
  255. }
  256. if(!empty($val->user) && $val->user->level==1){
  257. if(Cache::has('company-'.$val->user->id)){
  258. $list->company=Cache::get('company-'.$val->user->id);
  259. }else{
  260. $agent=DwbsUser::withTrashed()->with('agent:id,nickname')->where('id',$val->user->agent_id)->first();
  261. if($agent->level==3){
  262. $company=$agent->nickname;
  263. }else{
  264. $company=$agent->agent->nickname;
  265. }
  266. $list->company=$company;
  267. Cache::put('company-'.$val->user->id, $company, $second);
  268. }
  269. }
  270. if(!empty($val->user) && $val->user->level==3){
  271. $list->company=$val->user->nickname;
  272. }
  273. $GLOBALS['store'][] = $list;
  274. }
  275. });
  276. return $this->success($GLOBALS['store']);
  277. // $list=$data->has('user')->with(['comment','gift_order'])->orderBy('id','desc')->get();
  278. // return $this->success($list);
  279. return $this->success($list);
  280. }
  281. // //导出所有门店
  282. // public function export123(Request $request){
  283. // $admin_id=Auth::user()->id;
  284. // $admin=Admin::where('id',$admin_id)->first();
  285. // if($admin && in_array($admin->role_id,[22,24])){//超级管理员
  286. // $data=Store::with('user:id,nickname,mobile,level,agent_id');
  287. // }else{
  288. // $warea_ids=DwbsWarea::where('admin_id',$admin_id)->pluck('id');
  289. // $agent_ids=DwbsUser::whereIn('warea_id',$warea_ids)->pluck('id');
  290. // $store_ids=Store::whereIn('user_id',$agent_ids)->pluck('id');
  291. // $data=Store::with('user:id,nickname,mobile,level,agent_id')->whereIn('id',$store_ids);
  292. // }
  293. // //审核状态筛选
  294. // if($request->has('is_apply') && ($request->input('is_apply') || $request->input('is_apply')==0) && $request->input('is_apply') <> 'all'){
  295. // $data->where('is_apply',$request->input('is_apply'));
  296. // }
  297. // //代理筛选
  298. // if($request->has('search_name') && $request->input('search_name')) {
  299. // $data->where('name','like','%'.$request->input('search_name').'%')
  300. // ->orWhere('phone','like','%'.$request->input('search_name').'%');
  301. // }
  302. // $list=$data->orderBy('id','desc')->get();
  303. // $wareas=DwbsWarea::pluck('name','id');
  304. // $store_user_ids=Store::pluck('user_id');
  305. // $warea_user_ids=DwbsUser::withTrashed()->whereIn('id',$store_user_ids)->pluck('warea_id','id')->toArray();
  306. // $gift_orders=GiftOrders::where('type',0)->groupBy('store_id')
  307. // ->select('store_id',DB::raw('sum(num*bonus) as integral'))->pluck('integral','store_id')->toArray();
  308. // foreach($list as $key=>$val){
  309. // $star=Comment::where('store_id',$val->id)->average('star');
  310. // $list[$key]->star=floor($star);
  311. // $warea_id=$warea_user_ids[$val->user_id];
  312. // $list[$key]->warea=$wareas[$warea_id];
  313. // if(array_key_exists($val->id, $gift_orders)){
  314. // $list[$key]->finish_integral=$gift_orders[$val->id];
  315. // }else{
  316. // $list[$key]->finish_integral=0;
  317. // }
  318. // if(!empty($val->user) && $val->user->level==2){
  319. // $list[$key]->company=DwbsUser::where('id',$val->user->agent_id)->value('nickname');
  320. // }
  321. // if(!empty($val->user) && $val->user->level==1){
  322. // $agent_id=DwbsUser::where('id',$val->user->agent_id)->value('agent_id');
  323. // $list[$key]->company=DwbsUser::where('id',$agent_id)->value('nickname');
  324. // }
  325. // if(!empty($val->user) && $val->user->level==3){
  326. // $list[$key]->company=$val->user->nickname;
  327. // }
  328. // }
  329. // return $this->success($list);
  330. // }
  331. //获取所有用户
  332. public function getAllUser(Request $request){
  333. $page_size=$request->input('page_size');
  334. $page_index=$request->input('page_index');
  335. $store_id=$request->input('store_id');
  336. $num=$page_size*($page_index-1);
  337. $data=Order::leftJoin('user as u','u.id','=','order.user_id')->where('order.store_id',$store_id)
  338. ->where('order.is_pay',1)->whereIn('order.apply_cancel',[0,1,3])->whereIn('order.is_refund',[0,1])
  339. ->groupBy('order.user_id')->select('u.nickname','u.phone','u.avatar',DB::raw('sum(order.total) as total'),DB::raw('sum(order.account) as account'));
  340. // $data=User::with('store:id,name')->where('store_id',$store_id)
  341. // ->select('id','nickname','name','phone','avatar','status','store_id');
  342. if($request->has('search_name') && $request->input('search_name')){
  343. $data->where(function($query)use($request){
  344. $query->where('u.phone',$request->input('search_name'))
  345. ->orWhere('u.nickname','like','%'.$request->input('search_name').'%');
  346. });
  347. }
  348. // if($store_id){
  349. // $data->where('store_id',$store_id);
  350. // }
  351. $count=$data->get()->count();
  352. $list=$data->orderByDesc('total')->orderByDesc('account')->OrderBy('u.id')->skip($num)->take($page_size)->get();
  353. return $this->success_list($list,'成功',$count);
  354. }
  355. //店铺禁用
  356. public function disabled(Request $request){
  357. $store=Store::where('id',$request->input('id'))->first();
  358. $store->status=$store->status ? 0 : 1;
  359. $res=$store->save();
  360. if($res){
  361. return $this->success([]);
  362. }else{
  363. return $this->error();
  364. }
  365. }
  366. //删除店铺
  367. public function deleteStore(Request $request)
  368. {
  369. $admin_id=Auth::user()->id;
  370. $admin=Admin::where('id',$admin_id)->first();
  371. $id=$request->input('id');
  372. try{
  373. DB::beginTransaction();
  374. $store=Store::where('id',$id)->first();
  375. $store->remark .= '|'.$admin->name.'-'.date("Y-m-d H:i:s").'删除店铺';
  376. $store->save();
  377. Store::where('id',$id)->delete();
  378. DB::commit();
  379. return $this->success([]);
  380. }catch(Exception $e){
  381. DB::rollBack();
  382. return $this->error($e->getMessage());
  383. }
  384. }
  385. //恢复店铺删除
  386. public function resDelStore(Request $request)
  387. {
  388. $admin_id=Auth::user()->id;
  389. $admin=Admin::where('id',$admin_id)->first();
  390. $id=$request->input('id');
  391. try{
  392. DB::beginTransaction();
  393. Store::withTrashed()->where('is_failure',0)->where('id',$id)->restore();
  394. $store=Store::where('id',$id)->first();
  395. $store->remark .= '|'.$admin->name.'-'.date("Y-m-d H:i:s").'恢复店铺删除';
  396. $store->save();
  397. DB::commit();
  398. return $this->success([]);
  399. }catch(Exception $e){
  400. DB::rollBack();
  401. return $this->error($e->getMessage());
  402. }
  403. }
  404. //重开店铺
  405. public function newStore(Request $request)
  406. {
  407. $admin_id=Auth::user()->id;
  408. $admin=Admin::where('id',$admin_id)->first();
  409. $id=$request->input('id');
  410. try{
  411. DB::beginTransaction();
  412. $store=Store::onlyTrashed()->where('id',$id)->first();
  413. $store->is_failure = 1;
  414. $store->save();
  415. $user=DwbsUser::where('id',$store->user_id)->first();
  416. Store::create([
  417. 'img'=>$user->headimgurl,
  418. 'name'=>$user->nickname,
  419. 'user_id'=>$user->id,
  420. 'phone'=>$user->mobile,
  421. 'remark'=>$admin->name.'-'.date("Y-m-d H:i:s").'重开店铺'
  422. ]);
  423. DB::commit();
  424. return $this->success([]);
  425. }catch(Exception $e){
  426. DB::rollBack();
  427. return $this->error($e->getMessage());
  428. }
  429. }
  430. //查询进件状态
  431. public function query(Request $request){
  432. $store_id=$request->input('id');
  433. $store=Store::withTrashed()->where('is_failure',0)->where('id',$store_id)->first();
  434. $applyment_id=$store->applyment_id??$request->input('applyment_id');//申请编号
  435. if(empty($applyment_id)){
  436. Log::info($store->name.'未提交认证');
  437. return $this->success([]);
  438. }
  439. $handle=new SignHandler();
  440. $url='https://api.mch.weixin.qq.com/v3/ecommerce/applyments/'.$applyment_id;//查询地址
  441. $merchant_id=config('wechat.payment.default.mch_id');//商户号
  442. $serial_no=config('wechat.payment.default.serial_no');//不是平台证书序列号
  443. $mch_private_key=$handle->getPublicKey();//读取商户api证书公钥 getPublicKey()获取方法 见下文
  444. $timestamp=time();//时间戳
  445. $nonce=$handle->nonce_str();//随机字符串
  446. $body="";
  447. $sign=$handle->sign($url,'GET',$timestamp,$nonce,$body,$mch_private_key,$merchant_id,$serial_no);//签名
  448. $header=[
  449. 'Authorization:WECHATPAY2-SHA256-RSA2048 ' . $sign,
  450. 'Accept:application/json',
  451. 'User-Agent:' . $merchant_id,
  452. 'Content-Type:application/json',
  453. 'Wechatpay-Serial:' . $handle->getzhengshu()//获取平台证书序列号
  454. ];
  455. $result=$handle->curl($url,'',$header,'GET');
  456. $result=json_decode($result,true);
  457. $apply=Apply::where('store_id',$store->id)->where('applyment_id',$applyment_id)->OrderBy('id','desc')->first();
  458. if($result['applyment_state']=="ACCOUNT_NEED_VERIFY"){
  459. Apply::where('id',$apply->id)->update(['audit_detail'=>$result['legal_validation_url']]);
  460. }
  461. if($result['applyment_state']=="NEED_SIGN"){
  462. Store::withTrashed()->where('is_failure',0)->where('id',$store_id)->update(['sub_mchid'=>$result['sub_mchid'],'is_apply'=>2]);
  463. Apply::where('id',$apply->id)->update(['sub_mchid'=>$result['sub_mchid'], 'audit_detail'=>$result['sign_url']]);
  464. }
  465. if($result['applyment_state']=="FINISH" && $store->is_apply != 3){
  466. Store::withTrashed()->where('is_failure',0)->where('id',$store_id)->update(['sub_mchid'=>$result['sub_mchid'],'is_apply'=>3]);//'is_cert'=>1,
  467. Apply::where('id',$apply->id)->update(['sub_mchid'=>$result['sub_mchid']]);
  468. }
  469. if($result['applyment_state']=="REJECTED"){//已驳回
  470. Store::withTrashed()->where('is_failure',0)->where('id',$store_id)->update(['is_apply'=>4]);
  471. Apply::where('id',$apply->id)->update(['audit_detail'=>$result['audit_detail'][0]['reject_reason']]);
  472. }
  473. if($result['applyment_state']=="FROZEN"){
  474. Store::withTrashed()->where('is_failure',0)->where('id',$store_id)->update(['is_apply'=>5]);//已冻结
  475. Apply::where('id',$apply->id)->update(['audit_detail'=>$result['audit_detail'][0]['reject_reason']]);
  476. }
  477. if($apply->applyment_state != $result['applyment_state'] && $apply->applyment_state_desc != $result['applyment_state_desc']){
  478. Apply::where('id',$apply->id)->update(['applyment_state'=>$result['applyment_state'],'applyment_state_desc'=>$result['applyment_state_desc']]);
  479. }
  480. return $this->success($result);
  481. // $result['applyment_state']=="FINISH"; //完成签约 其它状态:CHECKING:资料校验中 ACCOUNT_NEED_VERIFY:待账户验 AUDITING:审核中 REJECTED:已驳回 NEED_SIGN:待签约 FINISH:完成 FROZEN:已冻结
  482. }
  483. //获取账户实时余额
  484. public function getAccount($user_id){
  485. $handle=new SignHandler();
  486. $sub_mchid=Store::where('user_id',$user_id)->value('sub_mchid');
  487. $url='https://api.mch.weixin.qq.com/v3/ecommerce/fund/balance/'.$sub_mchid;//查询地址
  488. $merchant_id=config('wechat.payment.default.mch_id');//商户号
  489. $serial_no=config('wechat.payment.default.serial_no');//不是平台证书序列号
  490. $mch_private_key=$handle->getPublicKey();//读取商户api证书公钥 getPublicKey()获取方法 见下文
  491. $timestamp=time();//时间戳
  492. $nonce=$handle->nonce_str();//随机字符串
  493. $body="";
  494. $sign=$handle->sign($url,'GET',$timestamp,$nonce,$body,$mch_private_key,$merchant_id,$serial_no);//签名
  495. $header=[
  496. 'Authorization:WECHATPAY2-SHA256-RSA2048 ' . $sign,
  497. 'Accept:application/json',
  498. 'User-Agent:' . $merchant_id,
  499. 'Content-Type:application/json',
  500. 'Wechatpay-Serial:' . $handle->getzhengshu()//获取平台证书序列号
  501. ];
  502. $result=$handle->curl($url,'',$header,'GET');
  503. $result=json_decode($result,true);
  504. return $result;
  505. }
  506. //获取账户实时余额
  507. public function getAccountInfo(Request $request){
  508. $handle=new SignHandler();
  509. $id=$request->input('id');
  510. $sub_mchid=Store::withTrashed()->where('is_failure',0)->where('id',$id)->value('sub_mchid');
  511. // return $sub_mchid;
  512. $url='https://api.mch.weixin.qq.com/v3/ecommerce/fund/balance/'.$sub_mchid;//查询地址
  513. $merchant_id=config('wechat.payment.default.mch_id');//商户号
  514. $serial_no=config('wechat.payment.default.serial_no');//不是平台证书序列号
  515. $mch_private_key=$handle->getPublicKey();//读取商户api证书公钥 getPublicKey()获取方法 见下文
  516. $timestamp=time();//时间戳
  517. $nonce=$handle->nonce_str();//随机字符串
  518. $body="";
  519. $sign=$handle->sign($url,'GET',$timestamp,$nonce,$body,$mch_private_key,$merchant_id,$serial_no);//签名
  520. $header=[
  521. 'Authorization:WECHATPAY2-SHA256-RSA2048 ' . $sign,
  522. 'Accept:application/json',
  523. 'User-Agent:' . $merchant_id,
  524. 'Content-Type:application/json',
  525. 'Wechatpay-Serial:' . $handle->getzhengshu()//获取平台证书序列号
  526. ];
  527. $result=$handle->curl($url,'',$header,'GET');
  528. $result=json_decode($result,true);
  529. if($result['sub_mchid']){
  530. Store::withTrashed()->where('is_failure',0)->where('sub_mchid',$result['sub_mchid'])
  531. ->update([
  532. 'available_amount'=>round($result['available_amount']/100,2),
  533. 'pending_amount'=>round($result['pending_amount']/100,2)
  534. ]);
  535. }
  536. return $this->success($result);
  537. }
  538. //商户提现状态查询
  539. public function getWithdrawalState(Request $request){
  540. $handle=new SignHandler();
  541. $id=$request->input('id');
  542. $withdraw_id=$request->input('withdraw_id');
  543. $out_request_no=$request->input('out_request_no');
  544. $sub_mchid=Store::withTrashed()->where('is_failure',0)->where('id',$id)->value('sub_mchid');
  545. $url='https://api.mch.weixin.qq.com/v3/ecommerce/fund/withdraw/'.$withdraw_id.'?sub_mchid='.$sub_mchid;//查询地址
  546. // $url='https://api.mch.weixin.qq.com/v3/ecommerce/fund/withdraw/out-request-no/'.$out_request_no.'?sub_mchid='.$sub_mchid;
  547. $merchant_id=config('wechat.payment.default.mch_id');//商户号
  548. $serial_no=config('wechat.payment.default.serial_no');//不是平台证书序列号
  549. $mch_private_key=$handle->getPublicKey();//读取商户api证书公钥 getPublicKey()获取方法 见下文
  550. $timestamp=time();//时间戳
  551. $nonce=$handle->nonce_str();//随机字符串
  552. $body="";
  553. $sign=$handle->sign($url,'GET',$timestamp,$nonce,$body,$mch_private_key,$merchant_id,$serial_no);//签名
  554. $header=[
  555. 'Authorization:WECHATPAY2-SHA256-RSA2048 ' . $sign,
  556. 'Accept:application/json',
  557. 'User-Agent:' . $merchant_id,
  558. 'Content-Type:application/json',
  559. 'Wechatpay-Serial:' . $handle->getzhengshu()//获取平台证书序列号
  560. ];
  561. $result=$handle->curl($url,'',$header,'GET');
  562. $result=json_decode($result,true);
  563. if(!isset($result['status'])){
  564. return $this->error('450001',$result['message']);
  565. }
  566. if($result['status']=='FAIL' ||$result['status']=='REFUND' ||$result['status']=='CLOSE'){
  567. $reason=$result['reason'];
  568. }else{
  569. $reason=null;
  570. }
  571. Amount::where('transaction_id',$withdraw_id)
  572. ->update([
  573. 'status'=>0,
  574. 'status_code'=>$result['status'],
  575. 'reason'=>$reason,
  576. ]);
  577. return $this->success($result);
  578. }
  579. //获取收款记录
  580. public function getAccountDetail(Request $request){
  581. $id=$request->input('id');
  582. $type=$request->input('type');
  583. $cycle=$request->input('cycle');
  584. $page_size=$request->input('page_size');
  585. $page_index=$request->input('page_index');
  586. $num=$page_size*($page_index-1);
  587. $data= Amount::where('store_id',$id)->where('type',$type);
  588. switch($cycle){
  589. case 'year':
  590. $data->whereYear('created_at',date("Y"));
  591. break;
  592. case 'today':
  593. $data->whereDate('created_at',date("Y_m-d"));
  594. break;
  595. case 'week':
  596. $data->whereBetween('created_at',[date("Y-m-d",strtotime("-7 day")),date("Y-m-d 23:59:59")]);
  597. break;
  598. case 'month':
  599. $data->whereBetween('created_at',[date("Y-m-01"),date("Y-m-d 23:59:59")]);
  600. break;
  601. case 'quarter':
  602. $start=(ceil(date("m")/3)-1)*3+1;
  603. $data->whereBetween('created_at',[date("Y-".$start."-01"),date("Y-m-d 23:59:59")]);
  604. break;
  605. default :
  606. // $data->whereDate('created_at',date("Y-m-d"));
  607. }
  608. $count=$data->count();
  609. if($type==3){
  610. $cc=clone $data;
  611. $ll['account']=$cc->where('status_code','SUCCESS')->sum('money');
  612. }else{
  613. $ll['account']=$data->sum('money');
  614. }
  615. $ll['list']=$data->OrderByDesc('id')->skip($num)->take($page_size)->get();
  616. return $this->success_list($ll,'',$count);
  617. }
  618. //重置审核状态
  619. public function setWxAuth(Request $request){
  620. $store_id=$request->input('store_id');
  621. $store=Store::where('id',$store_id)->first();
  622. if($store->is_apply!=2 && $store->is_apply!=4){
  623. return $this->error('450001','当前状态不能重置');
  624. }
  625. $res=Store::where('id',$store_id)->update([
  626. 'out_request_no'=>null,
  627. 'is_apply'=>0
  628. ]);
  629. if($res){
  630. return $this->success([]);
  631. }else{
  632. return $this->error();
  633. }
  634. }
  635. //代理详情
  636. public function getUserDetails(Request $request)
  637. {
  638. $input = $request->all();
  639. $user = DwbsUser::withTrashed()->with(['recom:id,nickname,mobile', 'agent:id,nickname,mobile'
  640. ])->where('mobile', $input['phone'])->first();
  641. if ($user) {
  642. // if ($user->level == '3') {
  643. // $childAgent = DwbsUser::where('agent_id', $user->id)->select('id', 'nickname', 'level', 'mobile')->get()->toArray();
  644. // $childAgentIds = array_column($childAgent, 'id');
  645. // if ($childAgentIds) {
  646. // $childChildAgent = DwbsUser::whereIn('agent_id', $childAgentIds)->select('id', 'nickname', 'level', 'mobile')->get()->toArray();
  647. // $user->child_agent = array_merge($childAgent, $childChildAgent);
  648. // } else {
  649. // $user->child_agent = $childAgent;
  650. // }
  651. // $user->childAgentCount = count($user->child_agent);
  652. // } elseif ($user->level == '2') {
  653. // $user->child_agent = DwbsUser::where('agent_id', $user->id)->select('id', 'nickname', 'level', 'mobile')->get()->toArray();
  654. // $user->childAgentCount = count($user->child_agent);
  655. // $user->crown=$this->get_crown($user->id);
  656. // } else {
  657. // $user->child_agent = [];
  658. // $user->childAgentCount = 0;
  659. // $user->crown=$this->get_crown($user->id);
  660. // }
  661. if ($user->warea_id) {
  662. $warea = DwbsWarea::where('id', $user->warea_id)->first();
  663. $warea->warea_name = $warea->name;
  664. if ($warea->admin_id) {
  665. $warea->commissar = DwbsAdmin::where('id', $warea->admin_id)->value('name');
  666. }
  667. $user->warea=$warea;
  668. }
  669. if (!empty($user->deleted_at)) {
  670. $user->delete = '1';//已删除
  671. } else {
  672. $user->delete = '0';//未删除
  673. }
  674. // $user->up_team=$this->getUpTeam($user->id);
  675. return $this->success($user);
  676. } else {
  677. return $this->error('400004', '代理信息不存在');
  678. }
  679. }
  680. public function GetStoreUser(){
  681. $user_ids=Store::pluck('user_id');
  682. $ids=DwbsUser::onlyTrashed()->whereIn('id',$user_ids)->pluck('id');
  683. // ->select('id','nickname','mobile','level','deleted_at')->get();
  684. // Store::whereIn('user_id',$ids)->update([
  685. // 'deleted_at'=>Carbon::now(),
  686. // 'remark'=>DB::raw('remark').'|统一删除被删除代理店铺'
  687. // ]);
  688. return count($ids);
  689. $user_ids=DwbsUser::onlyTrashed()->pluck('id');
  690. return count($user_ids);
  691. $count=Store::whereIn('user_id',$user_ids)->count();
  692. return $count;
  693. // $data=Store::query();
  694. // $data->where('id',22071);
  695. //// dump($data->count());
  696. //// $data->with('user:id,nickname,mobile,level,agent_id,crown_id,warea_id,deleted_at');
  697. // $data->whereHas('dwuser',function(Builder $builder){
  698. // $builder->from(DB::raw("app.users"));
  699. // });
  700. // dump($data->count());
  701. // dd($data->get());
  702. }
  703. }