User.php 42 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | [ WE CAN DO IT MORE SIMPLE ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2018-2020 rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Author: TABLE ME
  8. // +----------------------------------------------------------------------
  9. // | Date: 2020-08-25 17:23
  10. // +----------------------------------------------------------------------
  11. declare (strict_types=1);
  12. namespace app\api\controller;
  13. use app\BaseController;
  14. use app\model\api\User as UserModel;
  15. use app\model\api\UserDetail as UserDetailModel;
  16. use app\model\api\ServiceType as ServiceTypeModel;
  17. use app\model\api\InfoAudit;
  18. use app\model\api\TypeAudit;
  19. use app\model\api\UserAudit;
  20. use app\model\api\ServiceType;
  21. use app\model\api\ServiceLabel as ServiceLabelModel;
  22. use app\model\api\ServiceTimeType;
  23. use app\model\api\City as CityModel;
  24. use app\model\api\Sys as SysModel;
  25. use app\model\api\ShowTemplate;
  26. use app\model\api\ShowTemplateOrder;
  27. use app\model\api\UserShowTemplate;
  28. use app\model\api\UserWorkType;
  29. use app\model\api\PayTrade as PayTradeModel;
  30. use app\api\controller\pub;
  31. use app\Request;
  32. use library\services\UtilService;
  33. use library\utils\QRcodeComm;
  34. use library\utils\Qiniu;
  35. use library\utils\IdentityCard;
  36. use library\utils\WxpayV2 as wxpayApi;
  37. use think\db\exception\DbException;
  38. use library\lib\weixina;
  39. use think\facade\Db;
  40. use think\Image;
  41. use think\Route;
  42. use think\Collection;
  43. class User extends BaseController
  44. {
  45. /**
  46. * 获取用户详情
  47. * @param Request $request
  48. */
  49. public function userInfo(Request $request){
  50. //资料审核信息
  51. $infoAuditData = (new InfoAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  52. $userAuditData = (new UserAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  53. $typeAuditData = (new TypeAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  54. $data = [];
  55. $data['uid'] = $request->user['uid'];
  56. $data['nickname'] = $request->user['nickname'];
  57. $data['mobile'] = $request->user['mobile'];
  58. $data['avatar'] = $request->user['avatar'];
  59. $data['name'] = $request->user['name'];
  60. $data['sex'] = $request->user['sex'];
  61. $data['type'] = $request->user['type'];//用户类型
  62. $data['type_name'] = "";//用户类型名称
  63. $data['work_type_id'] = $request->user['work_type_id'];//用户职称类型
  64. $data['work_type_title'] = $request->user['work_type_title'];//用户职称类型名称
  65. $data['card_look_count'] = $request->user['card_look_count'];//用户名片浏览次数
  66. $data['info_audit_status'] = empty($infoAuditData)?-2:$infoAuditData["status"];
  67. $data['user_audit_status'] = empty($userAuditData)?-2:$userAuditData["status"];
  68. $data['type_audit_status'] = empty($typeAuditData)?-2:$typeAuditData["status"];
  69. //资料通过需要重新提交认证
  70. if(!empty($infoAuditData) && !empty($typeAuditData)){
  71. if($infoAuditData["status"]==1 && $typeAuditData["status"]==1 && $infoAuditData["admin_time"]>$typeAuditData["admin_time"]){
  72. $data['type_audit_status'] = -3;
  73. }
  74. }
  75. $data['show_template_code'] = "";
  76. $data['show_template_id'] = "";
  77. $tmpData = (new UserShowTemplate)
  78. ->field("t.id,t.code,t.title,t.is_init,b.is_default")
  79. ->alias("b")
  80. ->join("show_template t","t.id = b.show_template_id","left")
  81. ->where("b.uid",$request->user['uid'])
  82. ->order("b.is_default","desc")
  83. ->order("b.id","desc")
  84. ->find();
  85. if(!empty($tmpData)){
  86. $data['show_template_code'] = $tmpData["code"];
  87. $data['show_template_id'] = $tmpData["id"];
  88. $data['show_template_init'] = $tmpData["is_init"];
  89. $data['show_template_default'] = $tmpData["is_default"];
  90. }
  91. return app('json')->success($data);
  92. }
  93. /**
  94. * 获取用户子级列表
  95. * @param Request $request
  96. */
  97. public function getChildList(Request $request){
  98. $post = UtilService::getMore([
  99. ['page', 1],
  100. ['pageSize', 50],
  101. ], $request);
  102. $post["pageSize"] = $post["pageSize"]>50 ? 50 : (int)$post["pageSize"];
  103. $post["page"] = $post["page"]<=0 ? 1 : (int)$post["page"];
  104. $post["parent_uid"]= $request->user["uid"];
  105. $data = (new UserModel)->getDataList($post,"u.uid,u.mobile,u.nickname,u.avatar");
  106. return app('json')->success($data);
  107. }
  108. /**
  109. * 获取用户总邀请人数排行榜
  110. * @param Request $request
  111. */
  112. public function getInviterRanking(Request $request)
  113. {
  114. $time = $request->param('time');
  115. $times = $request->param('times');
  116. $users = (new UserModel())
  117. ->where('parent_uid', '<>', 0)
  118. ->where('regtime', '>=', $time)
  119. ->where('regtime', '<=', $times)
  120. ->field('parent_uid as uid, count(*) as invite_count')
  121. ->group('parent_uid')
  122. ->order('invite_count', 'desc')
  123. ->select();
  124. $rankList = [];
  125. foreach ($users as $key => $value) {
  126. $userInfo = (new UserModel)->where('uid', $value['uid'])->find();
  127. $auth = (new InfoAudit)->where('uid', $value['uid'])->find();
  128. $user_work_type_title = (new UserWorkType)->where('id', $auth['user_work_type_id'])->find();
  129. $rankList[] = [
  130. 'rank' => $key + 1,
  131. 'uid' => $value['uid'],
  132. 'nickname' => $userInfo['nickname'],
  133. 'avatar' => $userInfo['avatar'],
  134. 'invite_count' => $value['invite_count'],
  135. 'is_type_audit' => $auth && $auth['status'] == 1 ? 1 : 0,
  136. 'ancestral_place' => $auth ? $auth['ancestral_place'] : '',
  137. 'auth_info' => $auth ? $auth->toArray() : [],
  138. 'user_work_type_id' => $user_work_type_title['title'],
  139. ];
  140. }
  141. $rankList = array_values(array_filter($rankList, function ($item) {
  142. return !empty($item['ancestral_place']);
  143. }));
  144. $data['list'] = $rankList;
  145. return app('json')->success($data);
  146. }
  147. /**
  148. * 设置用户信息
  149. * @param Request $request
  150. */
  151. public function setUserInfo(Request $request){
  152. $post = UtilService::getMore([
  153. ['avatar',''],
  154. ['nickname',''],
  155. ['name',''],
  156. // ['mobile',''],
  157. ['sex', ''],
  158. ],$request);
  159. $save=[];
  160. if(!empty($post["avatar"])){
  161. $save["avatar"] = $post["avatar"];
  162. }
  163. if(!empty($post["nickname"])){
  164. $save["nickname"] = $post["nickname"];
  165. }
  166. if(!empty($post["name"])){
  167. $save["name"] = $post["name"];
  168. }
  169. // if(!empty($post["mobile"])){
  170. // if(is_mobile($post["mobile"])){
  171. // return app("json")->fail("请输入正确的手机号码");
  172. // }
  173. // $save["mobile"] = $post["mobile"];
  174. // }
  175. if(in_array((string)$post["sex"],["0","1","2"])){
  176. $save["sex"] = (int)$post["sex"];
  177. }
  178. if(empty($save)){
  179. return app("json")->fail("提交数据为空");
  180. }
  181. //是否需要审核
  182. $isInfoAudit = 0;
  183. if($isInfoAudit==0){
  184. $r = (new UserModel)->where("uid",$request->user["uid"])->update($save);
  185. if(!$r){
  186. return app("json")->fail("提交数据为空");
  187. }
  188. }else{
  189. $data = (new UserAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  190. if(!empty($data) && $data["status"]==0){
  191. return app('json')->fail("资料审核中,请勿重复提交");
  192. }
  193. $save["uid"] = $request->user["uid"];
  194. $save["status"] = 0;
  195. $r = (new UserAudit)->insert($save);
  196. if(!$r){
  197. return app("json")->fail("提交数据为空");
  198. }
  199. }
  200. return app("json")->success("提交成功");
  201. }
  202. /**
  203. * 绑定手机号
  204. * @param Request $request
  205. */
  206. public function bindMobile(Request $request){
  207. [$code] = UtilService::getMore([
  208. ['code', '', 'empty', 'code参数错误'],
  209. ], $request, true);
  210. if(!empty($request->user['mobile'])){
  211. return app('json')->fail("当前账户已绑定过手机号码");
  212. }
  213. $weixinA = new weixina();
  214. $data=$weixinA->getPhoneNumber($code);//新版
  215. if(empty($data) || empty($data['purePhoneNumber'])) {
  216. return app('json')->fail("绑定失败,请重新绑定01".$weixinA->error);
  217. }
  218. $save=[
  219. // "countryCode"=>empty($data['countryCode'])?"":$data['countryCode'],
  220. "mobile"=>$data['purePhoneNumber'],
  221. ];
  222. // if($request->user["nickname"]=="微信用户"){
  223. // $save["nickname"] = $data['purePhoneNumber'];
  224. // }
  225. $r = (new UserModel)->where('uid', $request->user['uid'])->update($save);
  226. if(!$r){
  227. return app('json')->fail("绑定失败,请重新绑定02");
  228. }
  229. $result = [];
  230. $result['nickname'] = $request->user['nickname'];
  231. $result['avatar'] = $request->user['avatar'];
  232. return app('json')->success($result);
  233. }
  234. /**
  235. * 获取名片信息
  236. * @param Request $request
  237. */
  238. public function getUserCardInfo(Request $request){
  239. $data = (new InfoAudit)->getItem(["uid"=>$request->user["uid"],"status"=>1]);
  240. if(empty($data)){
  241. return app('json')->fail("您还没有通过名片信息审核");
  242. }
  243. $typeData = (new TypeAudit)->where("uid",$request->user["uid"])->order("id","desc")->find();
  244. $data["is_type_audit"] = (empty($typeData) || $typeData["status"]!=1)?0:1;
  245. return app('json')->success($data);
  246. }
  247. /**
  248. * 提交资料审核
  249. * @param Request $request
  250. */
  251. public function subInfoAudit(Request $request){
  252. $data = (new InfoAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  253. if(!empty($data) && $data["status"]==0){
  254. return app('json')->fail("资料审核中,请勿重复提交");
  255. }
  256. $post = UtilService::getMore([
  257. ['avatar',''],
  258. ['name','','empty','请输入真实姓名'],
  259. ['mobile','','is_moblie','请输入正确的手机号码'],
  260. ['idcard','','empty','请输入正确的身份证号码'],
  261. ['birthday',''],
  262. ['service_type',''],
  263. ['service_price',''],
  264. ['service_min_price',''],
  265. ['service_max_price',''],
  266. ['service_area',[]],
  267. ['service_project',[]],
  268. ['service_intro_content',''],
  269. ['service_intro_imgs',[]],
  270. ['service_audit_imgs',[]],//此处为我的证书
  271. ['service_imgs',[]],//我的服务照片
  272. ['service_count',0],
  273. ['work_year',''],
  274. ['ancestral_place',''],
  275. ['education',''],
  276. ['minority',''],
  277. ['is_china',1],
  278. ['user_work_type_id','0'],//服务职称
  279. ['service_label',[]],//服务标签
  280. ],$request);
  281. if(!IdentityCard::isValid($post["idcard"])){
  282. return app('json')->fail("请输入正确的身份证号码");
  283. }
  284. $save=[];
  285. $save["avatar"] = empty($post["avatar"]) ? "" : $post["avatar"];
  286. $save["name"] = empty($post["name"]) ? "" : $post["name"];
  287. $save["mobile"] = empty($post["mobile"]) ? "" : $post["mobile"];
  288. $save["idcard"] = empty($post["idcard"]) ? "" : $post["idcard"];
  289. $save["service_count"] = $post['service_count'];
  290. // $save["birthday"] = empty($post["birthday"])? 0 : strtotime($post["birthday"]);
  291. $save["constellation"] = IdentityCard::get_starsign($post["idcard"]);//星座
  292. $save["twelve"] = IdentityCard::get_zodiac($post["idcard"]);//星座
  293. $save["birthday"] = strtotime(IdentityCard::get_birthday($post["idcard"]));
  294. //服务类型
  295. if(!empty($post["service_type"])){
  296. $timeTypeData = (new ServiceTimeType)->where("code",$post["service_type"])->where("status",1)->select();
  297. if(empty($timeTypeData)){
  298. return app('json')->fail("服务时长类型不存在");
  299. }
  300. $save["service_type"] = $post["service_type"];
  301. }
  302. //服务价格区间
  303. // $save["service_price"] = empty($post["service_price"]) ? "" : $post["service_price"];
  304. $save["service_min_price"] = empty($post["service_min_price"]) ? 0 : $post["service_min_price"];
  305. $save["service_max_price"] = empty($post["service_max_price"]) ? 0 : $post["service_max_price"];
  306. //服务区域
  307. $cityModel = new CityModel();
  308. if(!empty($post["service_area"]) && is_array($post["service_area"])){
  309. $saveAre=[];
  310. foreach($post["service_area"] as $v){
  311. $stc = str_replace(['省','市','区','县'],['','','',''],$v);
  312. $str = str_replace(['辖'],['市辖'],$stc);
  313. $arr = explode(",",$str);
  314. $city_id = $cityModel->where('merger_name','like',"%".$arr[1].",".$arr[2])->value('id');
  315. if(!$city_id) $city_id = $cityModel->where('merger_name','like',"%".$arr[0].",".$arr[1])->value('id');
  316. $saveAre[] = $city_id;
  317. }
  318. if(!empty($saveAre)){
  319. $save["service_area"] = implode(",", $saveAre);
  320. }
  321. }
  322. // //服务区域
  323. // $cityModel = new CityModel();
  324. // if(!empty($post["service_area"]) && is_array($post["service_area"])){
  325. // $saveAre=[];
  326. // foreach($post["service_area"] as $v){
  327. // @file_put_contents('dub.txt','1');
  328. // $arr = explode(",",$v);
  329. // $str1 = $arr[0].','.$arr[1];
  330. // @file_put_contents('dub.txt','2');
  331. // $stc = str_replace(['省','市','区','县'],['','','',''],$str1);
  332. // $str2 = $stc.",".$arr[2]!='市辖区'?str_replace(['省','市','区','县'],['','','',''],$arr[2]):'市辖区';
  333. // $arr3 = explode(",",$str2);
  334. // $city_id = $cityModel->where('merger_name','like',"%".$arr3[1].",".$arr3[2])->value('id');
  335. // @file_put_contents('dub.txt','3');
  336. // if(!$city_id)
  337. // {
  338. // $city_id = $cityModel->where('merger_name','like',"%".$arr3[0].",".$arr3[1])->value('id');
  339. // $city_id1 = $cityModel->where('merger_name','like',"%".$arr3[0].",".$arr3[1])->value('city_id');
  340. // $city_id2 = $cityModel->where('parent_id',$city_id1)->where('name','市辖区')->value('id');
  341. // if($city_id2>0) $city_id= $city_id2;
  342. // }
  343. // @file_put_contents('dub.txt','4');
  344. // $saveAre[] = $city_id;
  345. //
  346. // }
  347. // if(!empty($saveAre)){
  348. // $save["service_area"] = implode(",", $saveAre);
  349. // }
  350. // }
  351. //服务内容
  352. $serviceTypeModel = new ServiceTypeModel();
  353. if(!empty($post["service_project"]) && is_array($post["service_project"])){
  354. $saveCon=[];
  355. foreach($post["service_project"] as $k=>$v){
  356. if(empty(trim($v))){
  357. continue;
  358. }
  359. $itemData = $serviceTypeModel->where("id",(int)$v)->where("status",1)->find();
  360. if(!empty($itemData)){
  361. $saveCon[]=$itemData["id"];
  362. }
  363. }
  364. if(!empty($saveCon)){
  365. $save["service_project"] = implode(",", $saveCon);
  366. }
  367. }
  368. //服务标签
  369. $save["service_label"]="";
  370. $labelData = (new ServiceLabelModel)->getColumnList("id","id",$post["service_label"]);
  371. if(!empty($labelData)){
  372. $save["service_label"] = implode(",", $labelData);
  373. }
  374. $save["service_intro_content"] = empty($post["service_intro_content"])? "" : $post["service_intro_content"];
  375. $save["service_intro_imgs"] = empty($post["service_intro_imgs"]) ? "" : implode(",", $post["service_intro_imgs"]);
  376. $save["service_audit_imgs"] = empty($post["service_audit_imgs"]) ? "" : implode(",", $post["service_audit_imgs"]);
  377. $save["service_imgs"] = empty($post["service_imgs"]) ? "" : implode(",", $post["service_imgs"]);//我的服务展示
  378. $save['work_year'] = empty($post["work_year"]) ? "": $post["work_year"];
  379. $save['ancestral_place'] = empty($post["ancestral_place"])? "": $post["ancestral_place"];
  380. $save['education'] = empty($post["education"]) ? "": $post["education"];
  381. $save['minority'] = empty($post["minority"]) ? "": $post["minority"];
  382. $save["status"] = 0;
  383. $save["time"] = time();
  384. $save["uid"] = $request->user["uid"];
  385. $save['is_china'] = $post["is_china"];
  386. //服务职称
  387. $save["user_work_type_id"] = empty($post["user_work_type_id"]) ? 0: (int)$post["user_work_type_id"];
  388. if($save["user_work_type_id"]>0 && (new UserWorkType)->where("id",$post["user_work_type_id"])->where("status",1)->count()<=0){
  389. return app('json')->fail("当前类型不能选择");
  390. }
  391. //生成编码
  392. $r = (new InfoAudit)->insertGetId($save);
  393. if (!$r) {
  394. return app('json')->fail("系统错误");
  395. }
  396. $exist = (new InfoAudit)->where('uid', $save['uid'])->find();
  397. if ($exist && !empty($exist['no'])) {
  398. $no = $exist['no'];
  399. } else {
  400. $id = str_pad($r, 5, "0", STR_PAD_LEFT);
  401. $no = "MYJ" . date("ym") . $id;
  402. }
  403. (new InfoAudit)->where("id", $r)->update(["no" => $no]);
  404. return app('json')->success("提交成功,请耐心等待审核");
  405. }
  406. /**
  407. * 平台认证
  408. * @param Request $request
  409. */
  410. public function subTypeAudit(Request $request){
  411. $data = (new TypeAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  412. if(!empty($data) && $data["status"]==0){
  413. return app('json')->fail("平台审核中,请勿重复提交");
  414. }
  415. $post = UtilService::getMore([
  416. ['service_audit_imgs',[],"empty","请上传服务认证截图"],
  417. ],$request);
  418. $save=[];
  419. $save["service_audit_imgs"] = empty($post["service_audit_imgs"]) ?"": implode(",", $post["service_audit_imgs"]);
  420. $save["status"] = 0;
  421. $save["time"] = time();
  422. $save["uid"] = $request->user["uid"];
  423. if(empty($save["service_audit_imgs"])){
  424. return app('json')->fail("请上传服务认证截图");
  425. }
  426. $r = (new TypeAudit)->insertGetId($save);
  427. if(!$r){
  428. return app('json')->fail("系统错误");
  429. }
  430. $no = "CERT-".date("YmdHis")."-".$r;
  431. (new TypeAudit)->where("id",$r)->update(["no"=>$no]);
  432. return app('json')->success("提交成功,请耐心等待审核");
  433. }
  434. /**
  435. * 模板订单提交[第一步]
  436. * @param Request $request
  437. */
  438. public function subShowTemplateOrder(Request $request){
  439. [$id,$pay_type] = UtilService::getMore([
  440. ['id','','empty','参数错误'],
  441. ['pay_type','','empty','请选择支付方式'],
  442. ],$request,true);
  443. if(!in_array($pay_type,["wxpay","balance"])){
  444. return app('json')->fail('不支持该支付方式!');
  445. }
  446. $weixinConfig = (new SysModel)->getWeixinConfig();
  447. // if(empty($weixinConfig)){
  448. // return app('json')->fail('支付配置为空!');
  449. // }
  450. //缓存
  451. $redis = \think\facade\Cache::store('redis');
  452. $key = 'show_template_order_sub_' . $request->user['uid'];
  453. $bool = $redis->handler()->exists($key);
  454. if ($bool) {
  455. return app('json')->fail('请务重复操作,请稍等在重试!');
  456. }
  457. $redis->set($key,1,5);//5秒缓存
  458. $proData = (new ShowTemplate)->where("id",$id)->where("status",1)->find();
  459. if(empty($proData)){
  460. return app('json')->fail("当前模板已下架");
  461. }
  462. $proData = $proData->toArray();
  463. $count = (new UserShowTemplate)->where("uid",$request->user['uid'])->where("show_template_id",$id)->count();
  464. if($count>0){
  465. return app('json')->fail("您已购买过当前模板");
  466. }
  467. //验证
  468. $orderCount = (new ShowTemplateOrder)->where("uid",$request->user['uid'])->where("show_template_id",$id)->where("status",1)->count();
  469. if($orderCount>0){
  470. return app('json')->fail("您已下单该模板,请勿重复下单");
  471. }
  472. $price = floatval($proData["price"]);
  473. // if($price<0.01){
  474. // return app('json')->fail("模板信息错误");
  475. // }
  476. $allMoney = $price;//订单商品费用
  477. $total_money = $allMoney;//订单总费用
  478. $payMoney = $total_money;//订单需支付费用
  479. $payMoney = $payMoney <= 0 ? 0 : $payMoney;
  480. $nowTime = time();
  481. //余额支付验证
  482. if($pay_type=="balance" && $payMoney > $request->user["money"]){
  483. return app('json')->fail("当前余额不足");
  484. }
  485. //主订单数据
  486. $save=[];
  487. $save['uid'] = $request->user['uid'];
  488. $save['order_id'] = makeOrderId($request->user['uid'],"ST");
  489. $save['pay_type'] = $pay_type;//
  490. $save['total_money'] = $total_money;//订单总金额
  491. $save['all_money'] = $allMoney;//商品中金额
  492. $save['pay_money'] = $payMoney;//实际支付金额
  493. $save['balance'] = 0;//余额支付了多少(目前不用)
  494. $save['status'] = $payMoney <= 0 ? 1 : 0;
  495. $save['pay_time'] = $payMoney <= 0 ? time() : 0;
  496. $save['time'] = $nowTime;
  497. $save['show_template_id'] = $proData["id"];
  498. $save['show_template_title'] = $proData["title"];;
  499. $save['show_template_price'] = $proData["price"];
  500. $save['show_template_img'] = empty($proData["imgs"]) ? "" : explode(",", $proData["imgs"])[0];
  501. $save['show_template_code'] = $proData["code"];
  502. //余额实时支付
  503. if($pay_type=="balance"){
  504. $save['status'] = 1;
  505. $save['pay_time'] = time();
  506. }
  507. try{
  508. Db::startTrans();
  509. $o_id = (new ShowTemplateOrder)->insertGetId($save);
  510. if(empty($o_id)){
  511. return app('json')->fail("订单提交失败");
  512. }
  513. //不需要支付
  514. if($payMoney<=0 && $save['status']==1){
  515. //验证并绑定当前模板
  516. (new UserShowTemplate)->userBindTemp($save["show_template_id"],$save['uid']);
  517. Db::commit();
  518. return app("json")->success(["order_id"=>$save['order_id'],"money"=>$payMoney,"status"=>$save['status']]);
  519. }
  520. //余额支付
  521. if($pay_type=="balance"){
  522. //验证并绑定当前模板
  523. (new UserShowTemplate)->userBindTemp($save["show_template_id"],$save['uid']);
  524. //修改用户余额
  525. $res = (new UserDetailModel)->balancePay($request->user["uid"],$payMoney,"show_temp_pay",["to_id"=>$o_id]);
  526. if(!$res){
  527. Db::rollback();
  528. return app('json')->fail("余额支付失败");
  529. }
  530. Db::commit();
  531. return app("json")->success(["order_id"=>$save['order_id'],"money"=>$payMoney,"status"=>$save['status']]);
  532. }
  533. //微信支付
  534. if(empty($request->user['openid'])){
  535. Db::rollback();
  536. return app('json')->fail('用户还未绑定微信!');
  537. }
  538. //清理之前支付凭证 || 防止重复购买
  539. $payTrade = (new PayTradeModel)
  540. ->where("uid",$request->user["uid"])
  541. ->where("o_id",$o_id)
  542. ->where("type","temp")
  543. ->where("status",0)
  544. ->where("time","<",time() - 7*24*60*60)
  545. ->select()
  546. ->toArray();
  547. $wxpay = new wxpayApi();
  548. // $wxpay = new wxpayApi($weixinConfig);
  549. foreach ($payTrade as $v) {
  550. // if($v['pay_type'] == 'wxpay') {
  551. // $result = $wxpay->closeOrder($v['pay_no']);
  552. // }
  553. (new PayTradeModel)->where("id",$v['id'])->where("status",0)->delete();
  554. }
  555. $mtime = microtime(true)*10000;
  556. $payOn = "T".date("Ymd").$mtime .rand(100,999) . $request->user['uid'];
  557. $out_trade_no="";
  558. $payType = $save["pay_type"];
  559. //添加交易记录
  560. $trade = [
  561. 'uid' => $request->user['uid'],
  562. 'o_id' => $o_id,
  563. 'order_id' =>$save["order_id"],
  564. 'pay_no' => $payOn,
  565. 'out_trade_no' => empty($out_trade_no) ? $payOn : $out_trade_no,
  566. 'pay_type' => $payType,
  567. 'money' => $payMoney,
  568. 'type' => 'temp',
  569. 'd_json' => serialize(['orderId'=>$save["order_id"],"give_score"=>0]),
  570. 'time' => time(),
  571. 'status' => 0,
  572. ];
  573. $r=(new PayTradeModel)->insert($trade);
  574. if(!$r){
  575. Db::rollback();
  576. return app('json')->fail('支付信息获取失败!');
  577. }
  578. $clictip = get_client_ip();
  579. if(empty($clictip)){
  580. $clictip = $request->ip();
  581. }
  582. $payData = $wxpay->wxmpPay([
  583. 'body' => "微信小程序购买模板",
  584. 'out_trade_no' => $payOn,
  585. 'total' => $payMoney,
  586. 'openid' => $request->user['openid'],
  587. 'payer_client_ip' => $clictip,
  588. ]);
  589. if(empty($payData)){
  590. Db::rollback();
  591. return app('json')->fail($wxpay->errorMsg);
  592. }
  593. Db::commit();
  594. $redis->delete($key);
  595. return app('json')->success([
  596. 'jsApiParameters'=> $payData,
  597. 'pay_no' => $payOn,
  598. 'order_id' => $save["order_id"],
  599. "status" => $save['status'],
  600. "money" => $payMoney,
  601. ]);
  602. } catch (DbException $db){
  603. Db::rollback();
  604. return app('json')->fail("订单生成失败");
  605. }
  606. }
  607. /**
  608. * 获取模板购买订单详情
  609. * @param Request $request
  610. */
  611. public function payShowTemplateOrderInfo(Request $request){
  612. [$order_id] = UtilService::getMore([
  613. ['order_id','','empty','参数错误'],
  614. ],$request,true);
  615. $data = (new ShowTemplateOrder)
  616. ->field("order_id,total_money,all_money,pay_money,status,time")
  617. ->where("order_id",$order_id)
  618. ->where("uid",$request->user["uid"])
  619. ->find();
  620. if(empty($data)){
  621. return app('json')->fail('信息不存在!');
  622. }
  623. $data=$data->toArray();
  624. if($data["status"]==0 && $data["time"]<time() - 30*60){
  625. (new ShowTemplateOrder)->where("id",$data["id"])->where("uid",$request->user["uid"])->update(["status"=>-1]);
  626. $data["status"]==-1;
  627. }
  628. $data["time"] = date("Y-m-d H:i:s",$data["time"]);
  629. return app('json')->success($data);
  630. }
  631. /**
  632. * 用户模板列表
  633. * @param Request $request
  634. */
  635. public function userShowTemplateList(Request $request){
  636. $post = UtilService::getMore([
  637. ['page', 1],
  638. ['pageSize', 50],
  639. ], $request);
  640. $post["pageSize"] = $post["pageSize"]>50 ? 50 : (int)$post["pageSize"];
  641. $post["page"] = $post["page"]<=0 ? 1 : (int)$post["page"];
  642. $where=[];
  643. $where[]=["ut.uid","=",$request->user["uid"]];
  644. $totalCount = (new UserShowTemplate)->alias("ut")->where($where)->count();
  645. $data=null;
  646. if($totalCount>0){
  647. $data = (new UserShowTemplate)
  648. ->field("ut.id,t.id as show_template_id,t.title,t.price,t.old_price,t.status,t.imgs,t.is_hot,t.is_recommend,t.code,look_count,t.real_sales,t.unreal_sales,ut.is_default")
  649. ->alias("ut")
  650. ->join("show_template t", "t.id = ut.show_template_id","left")
  651. ->where($where)
  652. ->order("ut.is_default", "desc")
  653. ->order("ut.id", "desc")
  654. ->page($post["page"], $post["pageSize"])
  655. ->select();
  656. foreach($data as $k=>$v){
  657. $data[$k]["is_use"] = 1;//是否已经购买或者可以使用
  658. $data[$k]["imgs"] = getImageAr($v["imgs"]);
  659. $data[$k]["img"] = empty($data[$k]["imgs"]) ? "" : $data[$k]["imgs"][0];
  660. $data[$k]["sales_count"] = $data[$k]["real_sales"] + $data[$k]["unreal_sales"];
  661. unset($data[$k]["real_sales"]);
  662. unset($data[$k]["unreal_sales"]);
  663. }
  664. }
  665. $data = empty($data)?[]:$data;
  666. return app('json')->success(["list" => $data, "pageSize" => $post["pageSize"],"page"=>$post["page"],"totalCount"=>$totalCount]);
  667. }
  668. /**
  669. * 设置默认模板
  670. * @param Request $request
  671. */
  672. public function setShowTemplate(Request $request) {
  673. [$show_template_id] = UtilService::getMore([
  674. ['show_template_id', '', 'empty', '参数错误'],
  675. ], $request, true);
  676. (new UserShowTemplate)->where("uid", $request->user["uid"])->where("is_default", 1)->update(["is_default" => 0]);
  677. (new UserShowTemplate)->where("uid", $request->user["uid"])->where("show_template_id", $show_template_id)->update(["is_default" => 1]);
  678. return app('json')->success("设置成功");
  679. }
  680. /**
  681. * 获取邀请海报小程序码
  682. * @param Request $request
  683. */
  684. public function getWxmpInviteQrcode(Request $request){
  685. $inviteData = (new SysModel)->getDataInfo("invite");
  686. $bgimg = $inviteData["img"];
  687. if(!empty($request->user["invite_img"])){
  688. return app('json')->success(["qrcode"=>$request->user["invite_img"],"bgimg"=>$bgimg]);
  689. }
  690. $weixinA = new weixina();
  691. // $data = $weixinA->getUnlimitedQRCode("pages/index/index","scene=".$request->user["uid"]);
  692. $data = $weixinA->getUnlimitedQRCode("pages/index/index",$request->user["uid"]);
  693. // var_dump($data);
  694. if(empty($data)){
  695. return app('json')->fail("小程序码获取失败".$weixinA->error);
  696. }
  697. $base64 = 'data:'.$data['contentType'].';base64,'.base64_encode($data['buffer']);
  698. $res = $this->uploadImageBase64("wximg",$base64,1);
  699. if($res["code"]!=1){
  700. return app('json')->fail($res["msg"]);
  701. }
  702. (new UserModel)->where("uid",$request->user["uid"])->update(["invite_img"=>$res["url"]]);
  703. return app('json')->success(["qrcode"=>$res["url"],"bgimg"=>$bgimg]);
  704. }
  705. // public function getWxmpInviteQrcode2(Request $request){
  706. //
  707. // //获取小程序码
  708. // $weixinA = new weixina();
  709. // $data = $weixinA->getUnlimitedQRCode("pages/index/index","scene=".$request->user["uid"]);
  710. // if(empty($data)){
  711. // return app('json')->fail("小程序码获取失败".$weixinA->error);
  712. // }
  713. // $base64 = 'data:'.$data['contentType'].';base64,'.base64_encode($data['buffer']);
  714. // $code = "temp";
  715. // $sysData = (new SysModel())->where("id",1)->find();
  716. // $uploadConfig = config('filesystem');
  717. // //验证base64格式
  718. // preg_match('/^(data:\s*image\/(\w+);base64,)/',$base64, $result);
  719. // if(!$result){
  720. // return ["code"=>-1,"msg"=>"base64格式格式错误"];
  721. // }
  722. // //验证图片后缀
  723. // if (!in_array($result[2], $uploadConfig['image']['ext'], true)) {
  724. // return ["code"=>-1,"msg"=>"不支持的图片格式"];
  725. // }
  726. // $rootPath = config('filesystem.disks.resource.root');
  727. // $hashName = $code.DIRECTORY_SEPARATOR.date('Ymd') . DIRECTORY_SEPARATOR . md5((string) microtime(true)).".".$result[2];
  728. // $filePath = $rootPath. DIRECTORY_SEPARATOR .$hashName;
  729. // $path = dirname($filePath);
  730. // // 检测目录
  731. // if (!is_dir($path)) {
  732. // if (!mkdir($path, 0777, true)) {
  733. // return ["code"=>-1,"msg"=>"生成目录失败"];
  734. // }
  735. // return ["code"=>-1,"msg"=>"上传目录不存在"];
  736. // }
  737. // //重名文件验证
  738. // if (is_file($filePath)) {
  739. // return ["code"=>-1,"msg"=>"文件已存在"];
  740. // }
  741. // if(!file_put_contents($filePath, base64_decode(str_replace($result[1], '', $base64)))){
  742. // return ["code"=>-1,"msg"=>"文件报错失败"];
  743. // }
  744. //
  745. // //获取海报背景
  746. // $inviteData = (new SysModel)->getDataInfo("invite");
  747. // if(empty($inviteData["img"])){
  748. // return ["code"=>-1,"msg"=>"海报背景不存在"];
  749. // }
  750. // $bgimg =explode("resource", $inviteData["img"])[1];
  751. // if(empty($bgimg)){
  752. // return ["code"=>-1,"msg"=>"海报背景不存在"];
  753. // }
  754. //
  755. // $savePath = $rootPath. DIRECTORY_SEPARATOR .$code.DIRECTORY_SEPARATOR.date('Ymd') . DIRECTORY_SEPARATOR . md5((string) microtime(true))."b".".jpg";
  756. //
  757. //
  758. //
  759. //
  760. // $bg = $rootPath.$bgimg;
  761. // $bgSize = getimagesize($bg);
  762. // $qrcodeSize = getimagesize($filePath);
  763. // $handle = Image::open($bg);
  764. // $handle->water($filePath,[($bgSize[0]-$qrcodeSize[0])/2,($bgSize[1]-$qrcodeSize[1])/2]);
  765. // $handle->save($savePath,"jpg",80);
  766. // $qiniu = new Qiniu;
  767. // $img_url = $qiniu->updateFile('img', $savePath, $savePath);
  768. // if (empty($img_url['url'])) {
  769. // return ["code"=>-1,"msg"=>"文件报错失败:".$qiniu->getError()];
  770. // }
  771. // @unlink($filePath);
  772. // @unlink($savePath);
  773. // return ["code"=>1,"url"=>str_replace("\\", "/", $img_url['url'])];
  774. // }
  775. //
  776. // public function checkImgPath(){
  777. //
  778. // }
  779. /**
  780. * 图片合成
  781. * @param type $bg
  782. * @param type $qrcode
  783. * @param type $savePath
  784. */
  785. public function createPosterImg($bg,$qrcode,$savePath){
  786. }
  787. /**
  788. * 获取小程序码
  789. * @param Request $request
  790. */
  791. public function getWxmpQrcode(Request $request){
  792. $weixinA = new weixina();
  793. $data = $weixinA->getUnlimitedQRCode("pages/index/index","a=1");
  794. if(empty($data)){
  795. return app('json')->fail("小程序码获取失败".$weixinA->error);
  796. }
  797. $base64 = 'data:'.$data['contentType'].';base64,'.base64_encode($data['buffer']);
  798. $res = $this->uploadImageBase64("wximg",$base64);
  799. if($res["code"]!=1){
  800. return app('json')->fail($res["msg"]);
  801. }
  802. return app('json')->success(["img"=>$res["data"]]);
  803. }
  804. /**
  805. *
  806. * @param Request $request
  807. */
  808. public function uploadBase64(Request $request){
  809. [$img,$code] = UtilService::getMore([
  810. ['img', '','empty',"请上传图片"],
  811. ['code', 'image'],
  812. ], $request,true);
  813. // $imgAr = explode("base64,",$img);
  814. // if(empty($imgAr)){
  815. // return app("json")->fail("请上传base64图片");
  816. // }
  817. // $imgBase64 = count($imgAr)==1?$imgAr[0]:$imgAr[1];
  818. // //判断字符串是否经过编码方法
  819. // if($imgBase64!=base64_encode(base64_decode($imgBase64))){
  820. // return app("json")->fail("请上传base64图片");
  821. // }
  822. // $base64 = "data:application/octet-stream;base64,".$imgBase64;//七牛
  823. $res = $this->uploadImageBase64($code,$img);
  824. if($res["code"]!=1){
  825. return app('json')->fail($res["msg"]);
  826. }
  827. return app('json')->success(["img"=>$res["data"]]);
  828. }
  829. /**
  830. * 图片上传
  831. * @param Request $request
  832. * @return type
  833. */
  834. public function upload(Request $request){
  835. $uploadConfig = config('filesystem');
  836. $sysData = (new SysModel())->where("id",1)->find();
  837. $file = $request->file('file');
  838. $code = $request->post("code","image");
  839. if(empty($file)) {
  840. return app('json')->fail("未上传文件");
  841. }
  842. $size = $file->getSize();
  843. if(!empty($size) && $size>$uploadConfig["image"]["size"]*1024*1024){
  844. return app('json')->fail("图片不能超过{$uploadConfig["image"]["size"]}M");
  845. }
  846. if(!in_array($code, $uploadConfig['image']['path'])){
  847. return app('json')->fail("上传路径错误");
  848. }
  849. $ext = $file->extension();
  850. if(!in_array($ext, $uploadConfig['image']['ext'])){
  851. return app('json')->fail("图片类型错误");
  852. }
  853. $upPath = \think\facade\Filesystem::disk('resource')->putFile( $code, $file);
  854. if(!$upPath){
  855. return app('json')->fail("上传失败01");
  856. }
  857. $savePath = $sysData['system_url'].'/resource/' . $upPath;
  858. $imgUrl = str_replace("\\", "/", $savePath);
  859. return app('json')->success(['img'=>$imgUrl,'size'=>$size]);
  860. }
  861. /**
  862. * 视频上传
  863. * @param Request $request
  864. * @return type
  865. */
  866. public function uploadVideo(Request $request){
  867. $uploadConfig = config('filesystem');
  868. $sysData = (new SysModel())->where("id",1)->find();
  869. $file = $request->file('file');
  870. $code = $request->post("code","video");
  871. if(empty($file)) {
  872. return app('json')->fail("未上传文件");
  873. }
  874. if(!in_array($code, $uploadConfig['video']['path'])){
  875. return app('json')->fail("上传路径错误");
  876. }
  877. $ext = $file->extension();
  878. if(!in_array($ext, $uploadConfig['video']['ext'])){
  879. return app('json')->fail("视频类型错误");
  880. }
  881. $upPath = \think\facade\Filesystem::disk('resource')->putFile( $code, $file);
  882. if(!$upPath){
  883. return app('json')->fail("上传失败01");
  884. }
  885. $savePath = $sysData['system_url'].'/resource/' . $upPath;
  886. $imgUrl = str_replace("\\", "/", $savePath);
  887. return app('json')->success(['video'=>$imgUrl]);
  888. }
  889. /**
  890. * base64文件上传
  891. * @param type $code
  892. * @param type $base64
  893. */
  894. public function uploadImageBase64($code,$base64,$isQiniu=0){
  895. $sysData = (new SysModel())->where("id",1)->find();
  896. $uploadConfig = config('filesystem');
  897. //验证base64格式
  898. preg_match('/^(data:\s*image\/(\w+);base64,)/',$base64, $result);
  899. if(!$result){
  900. return ["code"=>-1,"msg"=>"base64格式格式错误"];
  901. }
  902. //验证图片后缀
  903. if (!in_array($result[2], $uploadConfig['image']['ext'], true)) {
  904. return ["code"=>-1,"msg"=>"不支持的图片格式"];
  905. }
  906. $rootPath = config('filesystem.disks.resource.root');
  907. $hashName = $code.DIRECTORY_SEPARATOR.date('Ymd') . DIRECTORY_SEPARATOR . md5((string) microtime(true)).".".$result[2];
  908. $filePath = $rootPath. DIRECTORY_SEPARATOR .$hashName;
  909. $path = dirname($filePath);
  910. // 检测目录
  911. if (!is_dir($path)) {
  912. if (!mkdir($path, 0777, true)) {
  913. return ["code"=>-1,"msg"=>"生成目录失败"];
  914. }
  915. return ["code"=>-1,"msg"=>"上传目录不存在"];
  916. }
  917. //重名文件验证
  918. if (is_file($filePath)) {
  919. return ["code"=>-1,"msg"=>"文件已存在"];
  920. }
  921. if(!file_put_contents($filePath, base64_decode(str_replace($result[1], '', $base64)))){
  922. return ["code"=>-1,"msg"=>"文件报错失败"];
  923. }
  924. //七牛上传
  925. if($isQiniu==1){
  926. $qiniu = new Qiniu;
  927. $img_url = $qiniu->updateFile('img', $filePath, $filePath);
  928. if (empty($img_url['url'])) {
  929. return ["code"=>-1,"msg"=>"文件报错失败:".$qiniu->getError()];
  930. }
  931. @unlink($filePath);
  932. return ["code"=>1,"url"=>str_replace("\\", "/", $img_url['url'])];
  933. }
  934. $savePath = $sysData['system_url'].config('filesystem.disks.resource.url').DIRECTORY_SEPARATOR.$hashName;
  935. return ["code"=>1,"url"=>str_replace("\\", "/", $savePath)];
  936. }
  937. /**
  938. * 七牛上传图片
  939. * @param Request $request
  940. */
  941. public function qiniuUpload(Request $request)
  942. {
  943. $file = $request->file('file');
  944. if (empty($file)) {
  945. return app('json')->fail("未上传文件");
  946. }
  947. $rootTmp = config('filesystem.disks.local.root') . '/' . \think\facade\Filesystem::putFile('tmp', $file);
  948. $image_size = @getimagesize($rootTmp);
  949. if ($image_size[0] > 1000) {
  950. $imgS = Image::open($rootTmp);
  951. $imgS->thumb(1000, $image_size[1]);
  952. $imgS->save($rootTmp);
  953. } else {
  954. if ($image_size[1] > 1000) {
  955. $imgS = Image::open($rootTmp);
  956. $imgS->thumb($image_size[0], 1000);
  957. $imgS->save($rootTmp);
  958. }
  959. }
  960. $qiniu = new Qiniu;
  961. $img_url = $qiniu->updateFile('img', $rootTmp, $rootTmp);
  962. if (empty($img_url['url'])) {
  963. return app('json')->fail($qiniu->getError());
  964. }
  965. @unlink($rootTmp);
  966. return app('json')->success(['img' => $img_url['url']]);
  967. }
  968. /**
  969. * 七牛上传token
  970. * @param Request $request
  971. */
  972. public function qiniuUploadToken(Request $request){
  973. [$bucket] = UtilService::getMore([
  974. ['bucket', ''],
  975. ], $request,true);
  976. $qiniu = new Qiniu;
  977. $token = $qiniu->createUploadToken($bucket);
  978. return app('json')->success(['token' => $token]);
  979. }
  980. /**
  981. * 获取用户总邀请人数
  982. * @param int $uid 用户ID
  983. * @return int 总邀请人数
  984. */
  985. public function getTotalInvites($uid)
  986. {
  987. return (new UserModel)->where('parent_uid', $uid)->count();
  988. }
  989. }