User.php 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835
  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\Request;
  31. use library\services\UtilService;
  32. use library\utils\QRcodeComm;
  33. use library\utils\IdentityCard;
  34. use library\utils\WxpayV2 as wxpayApi;
  35. use think\db\exception\DbException;
  36. use library\lib\weixina;
  37. use think\facade\Db;
  38. use think\Image;
  39. use think\Route;
  40. class User extends BaseController
  41. {
  42. /**
  43. * 获取用户详情
  44. * @param Request $request
  45. */
  46. public function userInfo(Request $request){
  47. //资料审核信息
  48. $infoAuditData = (new InfoAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  49. $userAuditData = (new UserAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  50. $typeAuditData = (new TypeAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  51. $data = [];
  52. $data['nickname'] = $request->user['nickname'];
  53. $data['mobile'] = $request->user['mobile'];
  54. $data['avatar'] = $request->user['avatar'];
  55. $data['name'] = $request->user['name'];
  56. $data['sex'] = $request->user['sex'];
  57. $data['type'] = $request->user['type'];//用户类型
  58. $data['type_name'] = "";//用户类型名称
  59. $data['work_type_id'] = $request->user['work_type_id'];//用户职称类型
  60. $data['work_type_title'] = $request->user['work_type_title'];//用户职称类型名称
  61. $data['info_audit_status'] = empty($infoAuditData)?-2:$infoAuditData["status"];
  62. $data['user_audit_status'] = empty($userAuditData)?-2:$userAuditData["status"];
  63. $data['type_audit_status'] = empty($typeAuditData)?-2:$typeAuditData["status"];
  64. $data['show_template_code'] = "";
  65. $data['show_template_id'] = "";
  66. $tmpData = (new UserShowTemplate)
  67. ->field("t.id,t.code,t.title")
  68. ->alias("b")
  69. ->join("show_template t","t.id = b.show_template_id","left")
  70. ->where("b.uid",$request->user['uid'])
  71. ->order("b.is_default","desc")
  72. ->order("b.id","desc")
  73. ->find();
  74. if(!empty($tmpData)){
  75. $data['show_template_code'] = $tmpData["code"];
  76. $data['show_template_id'] = $tmpData["id"];
  77. }
  78. return app('json')->success($data);
  79. }
  80. /**
  81. * 设置用户信息
  82. * @param Request $request
  83. */
  84. public function setUserInfo(Request $request){
  85. $post = UtilService::getMore([
  86. ['avatar',''],
  87. ['nickname',''],
  88. ['name',''],
  89. // ['mobile',''],
  90. ['sex', ''],
  91. ],$request);
  92. $save=[];
  93. if(!empty($post["avatar"])){
  94. $save["avatar"] = $post["avatar"];
  95. }
  96. if(!empty($post["nickname"])){
  97. $save["nickname"] = $post["nickname"];
  98. }
  99. if(!empty($post["name"])){
  100. $save["name"] = $post["name"];
  101. }
  102. // if(!empty($post["mobile"])){
  103. // if(is_mobile($post["mobile"])){
  104. // return app("json")->fail("请输入正确的手机号码");
  105. // }
  106. // $save["mobile"] = $post["mobile"];
  107. // }
  108. if(in_array((string)$post["sex"],["0","1","2"])){
  109. $save["sex"] = (int)$post["sex"];
  110. }
  111. if(empty($save)){
  112. return app("json")->fail("提交数据为空");
  113. }
  114. //是否需要审核
  115. $isInfoAudit = 0;
  116. if($isInfoAudit==0){
  117. $r = (new UserModel)->where("uid",$request->user["uid"])->update($save);
  118. if(!$r){
  119. return app("json")->fail("提交数据为空");
  120. }
  121. }else{
  122. $data = (new UserAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  123. if(!empty($data) && $data["status"]==0){
  124. return app('json')->fail("资料审核中,请勿重复提交");
  125. }
  126. $save["uid"] = $request->user["uid"];
  127. $save["status"] = 0;
  128. $r = (new UserAudit)->insert($save);
  129. if(!$r){
  130. return app("json")->fail("提交数据为空");
  131. }
  132. }
  133. return app("json")->success("提交成功");
  134. }
  135. /**
  136. * 绑定手机号
  137. * @param Request $request
  138. */
  139. public function bindMobile(Request $request){
  140. [$code] = UtilService::getMore([
  141. ['code', '', 'empty', 'code参数错误'],
  142. ], $request, true);
  143. if(!empty($request->user['mobile'])){
  144. return app('json')->fail("当前账户已绑定过手机号码");
  145. }
  146. $weixinA = new weixina();
  147. $data=$weixinA->getPhoneNumber($code);//新版
  148. if(empty($data) || empty($data['purePhoneNumber'])) {
  149. return app('json')->fail("绑定失败,请重新绑定01".$weixinA->error);
  150. }
  151. $save=[
  152. // "countryCode"=>empty($data['countryCode'])?"":$data['countryCode'],
  153. "mobile"=>$data['purePhoneNumber'],
  154. ];
  155. $r = (new UserModel)->where('uid', $request->user['uid'])->update($save);
  156. if(!$r){
  157. return app('json')->fail("绑定失败,请重新绑定02");
  158. }
  159. $result = [];
  160. $result['nickname'] = $request->user['nickname'];
  161. $result['avatar'] = $request->user['avatar'];
  162. return app('json')->success($result);
  163. }
  164. /**
  165. * 获取名片信息
  166. * @param Request $request
  167. */
  168. public function getUserCardInfo(Request $request){
  169. $data = (new InfoAudit)
  170. ->alias("u")
  171. ->field("u.*,wt.title as user_work_type_title,s.title as service_time_type_title,w.title as user_work_type_title")
  172. ->join("user_work_type wt","wt.id = u.user_work_type_id","left")
  173. ->leftJoin("service_time_type s", "s.code = u.service_type")
  174. ->leftJoin("user_work_type w", "w.id = u.user_work_type_id")
  175. ->where("u.uid",$request->user["uid"])
  176. ->where("u.status",1)
  177. ->order("u.id","desc")
  178. ->find();
  179. if(empty($data)){
  180. return app('json')->fail("您还没有通过名片信息审核");
  181. }
  182. $data = $data->toArray();
  183. $serviceTypeModel = new ServiceTypeModel();
  184. $data["birthday"] = empty($data["birthday"]) ?"":date("Y-m-d",$data["birthday"]);
  185. $data["time"] = date("Y-m-d H:i:s",$data["time"]);
  186. $data["service_audit_imgs"] = getImageAr($data["service_audit_imgs"]);
  187. $data["service_intro_imgs"] = getImageAr($data["service_intro_imgs"]);
  188. $data["service_imgs"] = getImageAr($data["service_imgs"]);
  189. //服务区域
  190. $data["service_area"] = getImageAr($data["service_area"]);
  191. $data["service_area_all"] = [];
  192. foreach($data["service_area"] as $k2=>$v2){
  193. $data["service_area_all"][]=getAreaItemAr($v2);
  194. }
  195. //服务内容
  196. $data["service_project"] = getImageAr($data["service_project"]);
  197. $data["service_project_ar"] = [];
  198. if(!empty($data["service_project"])){
  199. $data["service_project_ar"] = $serviceTypeModel->where("id","in",$data["service_project"])->select();
  200. }
  201. $data["service_label"] = getImageAr($data["service_label"]);
  202. unset($data["admin_id"]);
  203. unset($data["admin_mono"]);
  204. unset($data["admin_time"]);
  205. unset($data["uid"]);
  206. unset($data["id"]);
  207. unset($data["service_price"]);
  208. unset($data["service_area"]);
  209. unset($data["service_project"]);
  210. $typeData = (new TypeAudit)->where("uid",$request->user["uid"])->order("id","desc")->find();
  211. $data["is_type_audit"] = (empty($typeData) || $typeData["status"]!=1)?0:1;
  212. return app('json')->success($data);
  213. }
  214. /**
  215. * 提交资料审核
  216. * @param Request $request
  217. */
  218. public function subInfoAudit(Request $request){
  219. $data = (new InfoAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  220. if(!empty($data) && $data["status"]==0){
  221. return app('json')->fail("资料审核中,请勿重复提交");
  222. }
  223. $post = UtilService::getMore([
  224. ['avatar',''],
  225. ['name','','empty','请输入真实姓名'],
  226. ['mobile','','is_moblie','请输入正确的手机号码'],
  227. ['idcard','','empty','请输入正确的身份证号码'],
  228. ['birthday',''],
  229. ['service_type',''],
  230. ['service_price',''],
  231. ['service_min_price',''],
  232. ['service_max_price',''],
  233. ['service_area',[]],
  234. ['service_project',[]],
  235. ['service_intro_content',''],
  236. ['service_intro_imgs',[]],
  237. ['service_audit_imgs',[]],//此处为我的证书
  238. ['service_imgs',[]],//我的服务照片
  239. ['work_year',''],
  240. ['ancestral_place',''],
  241. ['education',''],
  242. ['minority',''],
  243. ['user_work_type_id','0'],//服务职称
  244. ['service_label',[]],//服务标签
  245. ],$request);
  246. if(!IdentityCard::isValid($post["idcard"])){
  247. return app('json')->fail("请输入正确的身份证号码");
  248. }
  249. $save=[];
  250. $save["avatar"] = empty($post["avatar"]) ? "" : $post["avatar"];
  251. $save["name"] = empty($post["name"]) ? "" : $post["name"];
  252. $save["mobile"] = empty($post["mobile"]) ? "" : $post["mobile"];
  253. $save["idcard"] = empty($post["idcard"]) ? "" : $post["idcard"];
  254. // $save["birthday"] = empty($post["birthday"])? 0 : strtotime($post["birthday"]);
  255. $save["constellation"] = IdentityCard::get_starsign($post["idcard"]);//星座
  256. $save["twelve"] = IdentityCard::get_zodiac($post["idcard"]);//星座
  257. $save["birthday"] = strtotime(IdentityCard::get_birthday($post["idcard"]));
  258. //服务类型
  259. if(!empty($post["service_type"])){
  260. $timeTypeData = (new ServiceTimeType)->where("code",$post["service_type"])->where("status",1)->select();
  261. if(empty($timeTypeData)){
  262. return app('json')->fail("服务时长类型不存在");
  263. }
  264. $save["service_type"] = $post["service_type"];
  265. }
  266. //服务价格区间
  267. // $save["service_price"] = empty($post["service_price"]) ? "" : $post["service_price"];
  268. $save["service_min_price"] = empty($post["service_min_price"]) ? 0 : $post["service_min_price"];
  269. $save["service_max_price"] = empty($post["service_max_price"]) ? 0 : $post["service_max_price"];
  270. //服务区域
  271. $cityModel = new CityModel();
  272. if(!empty($post["service_area"]) && is_array($post["service_area"])){
  273. $saveAre=[];
  274. foreach($post["service_area"] as $k=>$v){
  275. if(empty(trim($v))){
  276. continue;
  277. }
  278. $itemData = $cityModel->where("name",trim($v))->where("level",2)->find();
  279. if(!empty($itemData)){
  280. $saveAre[]=$itemData["id"];
  281. }
  282. }
  283. if(!empty($saveAre)){
  284. $save["service_area"] = implode(",", $saveAre);
  285. }
  286. }
  287. //服务内容
  288. $serviceTypeModel = new ServiceTypeModel();
  289. if(!empty($post["service_project"]) && is_array($post["service_project"])){
  290. $saveCon=[];
  291. foreach($post["service_project"] as $k=>$v){
  292. if(empty(trim($v))){
  293. continue;
  294. }
  295. $itemData = $serviceTypeModel->where("id",(int)$v)->where("status",1)->find();
  296. if(!empty($itemData)){
  297. $saveCon[]=$itemData["id"];
  298. }
  299. }
  300. if(!empty($saveCon)){
  301. $save["service_project"] = implode(",", $saveCon);
  302. }
  303. }
  304. //服务标签
  305. if(!empty($post["service_label"]) && is_array($post["service_label"])){
  306. $labelData = (new ServiceLabelModel)->where("status",1)->where("id","in",$post["service_label"])->column('id');
  307. }
  308. $save["service_label"] = empty($post["service_label"]) ? "" : implode(",", $post["service_label"]);
  309. $save["service_intro_content"] = empty($post["service_intro_content"])? "" : $post["service_intro_content"];
  310. $save["service_intro_imgs"] = empty($post["service_intro_imgs"]) ? "" : implode(",", $post["service_intro_imgs"]);
  311. $save["service_audit_imgs"] = empty($post["service_audit_imgs"]) ? "" : implode(",", $post["service_audit_imgs"]);
  312. $save["service_imgs"] = empty($post["service_imgs"]) ? "" : implode(",", $post["service_imgs"]);//我的服务展示
  313. $save['work_year'] = empty($post["work_year"]) ? "": $post["work_year"];
  314. $save['ancestral_place'] = empty($post["ancestral_place"])? "": $post["ancestral_place"];
  315. $save['education'] = empty($post["education"]) ? "": $post["education"];
  316. $save['minority'] = empty($post["minority"]) ? "": $post["minority"];
  317. $save["status"] = 0;
  318. $save["time"] = time();
  319. $save["uid"] = $request->user["uid"];
  320. //服务职称
  321. $save["user_work_type_id"] = empty($post["user_work_type_id"]) ? 0: (int)$post["user_work_type_id"];
  322. if($save["user_work_type_id"]>0 && (new UserWorkType)->where("id",$post["user_work_type_id"])->where("status",1)->count()<=0){
  323. return app('json')->fail("当前类型不能选择");
  324. }
  325. $r = (new InfoAudit)->insertGetId($save);
  326. if(!$r){
  327. return app('json')->fail("系统错误");
  328. }
  329. $no = "CARD-".date("YmdHis")."-".$r;
  330. (new InfoAudit)->where("id",$r)->update(["no"=>$no]);
  331. return app('json')->success("提交成功,请耐心等待审核");
  332. }
  333. /**
  334. * 平台认证
  335. * @param Request $request
  336. */
  337. public function subTypeAudit(Request $request){
  338. $data = (new TypeAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  339. if(!empty($data) && $data["status"]==0){
  340. return app('json')->fail("平台审核中,请勿重复提交");
  341. }
  342. $post = UtilService::getMore([
  343. ['service_audit_imgs',[],"empty","请上传服务认证截图"],
  344. ],$request);
  345. $save=[];
  346. $save["service_audit_imgs"] = empty($post["service_audit_imgs"]) ?"": implode(",", $post["service_audit_imgs"]);
  347. $save["status"] = 0;
  348. $save["time"] = time();
  349. $save["uid"] = $request->user["uid"];
  350. if(empty($save["service_audit_imgs"])){
  351. return app('json')->fail("请上传服务认证截图");
  352. }
  353. $r = (new TypeAudit)->insertGetId($save);
  354. if(!$r){
  355. return app('json')->fail("系统错误");
  356. }
  357. $no = "CERT-".date("YmdHis")."-".$r;
  358. (new TypeAudit)->where("id",$r)->update(["no"=>$no]);
  359. return app('json')->success("提交成功,请耐心等待审核");
  360. }
  361. /**
  362. * 模板订单提交[第一步]
  363. * @param Request $request
  364. */
  365. public function subShowTemplateOrder(Request $request){
  366. [$id,$pay_type] = UtilService::getMore([
  367. ['id','','empty','参数错误'],
  368. ['pay_type','','empty','请选择支付方式'],
  369. ],$request,true);
  370. if(!in_array($pay_type,["wxpay","balance"])){
  371. return app('json')->fail('不支持该支付方式!');
  372. }
  373. //缓存
  374. $redis = \think\facade\Cache::store('redis');
  375. $key = 'show_template_order_sub_' . $request->user['uid'];
  376. $bool = $redis->handler()->exists($key);
  377. if ($bool) {
  378. return app('json')->fail('请务重复操作,请稍等在重试!');
  379. }
  380. $redis->set($key,1,5);//5秒缓存
  381. $proData = (new ShowTemplate)->where("id",$id)->where("status",1)->find();
  382. if(empty($proData)){
  383. return app('json')->fail("当前模板已下架");
  384. }
  385. $proData = $proData->toArray();
  386. $count = (new UserShowTemplate)->where("uid",$request->user['uid'])->where("show_template_id",$id)->count();
  387. if($count>0){
  388. return app('json')->fail("您已购买过当前模板");
  389. }
  390. //验证
  391. $orderCount = (new ShowTemplateOrder)->where("uid",$request->user['uid'])->where("show_template_id",$id)->where("status",1)->count();
  392. if($orderCount>0){
  393. return app('json')->fail("您已下单该模板,请勿重复下单");
  394. }
  395. $price = floatval($proData["price"]);
  396. // if($price<0.01){
  397. // return app('json')->fail("模板信息错误");
  398. // }
  399. $allMoney = $price;//订单商品费用
  400. $total_money = $allMoney;//订单总费用
  401. $payMoney = $total_money;//订单需支付费用
  402. $payMoney = $payMoney <= 0 ? 0 : $payMoney;
  403. $nowTime = time();
  404. //余额支付验证
  405. if($pay_type=="balance" && $payMoney > $request->user["money"]){
  406. return app('json')->fail("当前余额不足");
  407. }
  408. //主订单数据
  409. $save=[];
  410. $save['uid'] = $request->user['uid'];
  411. $save['order_id'] = makeOrderId($request->user['uid'],"ST");
  412. $save['pay_type'] = $pay_type;//
  413. $save['total_money'] = $total_money;//订单总金额
  414. $save['all_money'] = $allMoney;//商品中金额
  415. $save['pay_money'] = $payMoney;//实际支付金额
  416. $save['balance'] = 0;//余额支付了多少(目前不用)
  417. $save['status'] = $payMoney <= 0 ? 1 : 0;
  418. $save['pay_time'] = $payMoney <= 0 ? time() : 0;
  419. $save['time'] = $nowTime;
  420. $save['show_template_id'] = $proData["id"];
  421. $save['show_template_title'] = $proData["title"];;
  422. $save['show_template_price'] = $proData["price"];
  423. $save['show_template_img'] = empty($proData["imgs"]) ? "" : explode(",", $proData["imgs"])[0];
  424. $save['show_template_code'] = $proData["code"];
  425. //余额实时支付
  426. if($pay_type=="balance"){
  427. $save['status'] = 1;
  428. $save['pay_time'] = time();
  429. }
  430. try{
  431. Db::startTrans();
  432. $o_id = (new ShowTemplateOrder)->insertGetId($save);
  433. if(empty($o_id)){
  434. return app('json')->fail("订单提交失败");
  435. }
  436. //不需要支付
  437. if($payMoney<=0 && $save['status']==1){
  438. //验证并绑定当前模板
  439. (new UserShowTemplate)->userBindTemp($save["show_template_id"],$save['uid']);
  440. Db::commit();
  441. return app("json")->success(["order_id"=>$save['order_id'],"money"=>$payMoney,"status"=>$save['status']]);
  442. }
  443. //余额支付
  444. if($pay_type=="balance"){
  445. //验证并绑定当前模板
  446. (new UserShowTemplate)->userBindTemp($save["show_template_id"],$save['uid']);
  447. //修改用户余额
  448. $res = (new UserDetailModel)->balancePay($request->user["uid"],$payMoney,"show_temp_pay",["to_id"=>$o_id]);
  449. if(!$res){
  450. Db::rollback();
  451. return app('json')->fail("余额支付失败");
  452. }
  453. Db::commit();
  454. return app("json")->success(["order_id"=>$save['order_id'],"money"=>$payMoney,"status"=>$save['status']]);
  455. }
  456. //微信支付
  457. if(empty($request->user['openid'])){
  458. Db::rollback();
  459. return app('json')->fail('用户还未绑定微信!');
  460. }
  461. //清理之前支付凭证 || 防止重复购买
  462. $payTrade = (new PayTradeModel)
  463. ->where("uid",$request->user["uid"])
  464. ->where("o_id",$o_id)
  465. ->where("type","temp")
  466. ->where("status",0)
  467. ->where("time","<",time() - 7*24*60*60)
  468. ->select()
  469. ->toArray();
  470. $wxpay = new wxpayApi();
  471. foreach ($payTrade as $v) {
  472. // if($v['pay_type'] == 'wxpay') {
  473. // $result = $wxpay->closeOrder($v['pay_no']);
  474. // }
  475. (new PayTradeModel)->where("id",$v['id'])->where("status",0)->delete();
  476. }
  477. $mtime = microtime(true)*10000;
  478. $payOn = "T".date("Ymd").$mtime .rand(100,999) . $request->user['uid'];
  479. $out_trade_no="";
  480. $payType = $save["pay_type"];
  481. //添加交易记录
  482. $trade = [
  483. 'uid' => $request->user['uid'],
  484. 'o_id' => $o_id,
  485. 'order_id' =>$save["order_id"],
  486. 'pay_no' => $payOn,
  487. 'out_trade_no' => empty($out_trade_no) ? $payOn : $out_trade_no,
  488. 'pay_type' => $payType,
  489. 'money' => $payMoney,
  490. 'type' => 'temp',
  491. 'd_json' => serialize(['orderId'=>$save["order_id"],"give_score"=>0]),
  492. 'time' => time(),
  493. 'status' => 0,
  494. ];
  495. $r=(new PayTradeModel)->insert($trade);
  496. if(!$r){
  497. Db::rollback();
  498. return app('json')->fail('支付信息获取失败!');
  499. }
  500. $clictip = get_client_ip();
  501. if(empty($clictip)){
  502. $clictip = $request->ip();
  503. }
  504. $payData = $wxpay->wxmpPay([
  505. 'body' => "微信小程序购买模板",
  506. 'out_trade_no' => $payOn,
  507. 'total' => $payMoney,
  508. 'openid' => $request->user['openid'],
  509. 'payer_client_ip' => $clictip,
  510. ]);
  511. if(empty($payData)){
  512. Db::rollback();
  513. return app('json')->fail($wxpay->errorMsg);
  514. }
  515. Db::commit();
  516. $redis->delete($key);
  517. return app('json')->success([
  518. 'jsApiParameters'=> $payData,
  519. 'pay_no' => $payOn,
  520. 'order_id' => $save["order_id"],
  521. "status" => $save['status'],
  522. "money" => $payMoney,
  523. ]);
  524. } catch (DbException $db){
  525. Db::rollback();
  526. return app('json')->fail("订单生成失败");
  527. }
  528. }
  529. /**
  530. * 获取模板购买订单详情
  531. * @param Request $request
  532. */
  533. public function payShowTemplateOrderInfo(Request $request){
  534. [$order_id] = UtilService::getMore([
  535. ['order_id','','empty','参数错误'],
  536. ],$request,true);
  537. $data = (new ShowTemplateOrder)
  538. ->field("order_id,total_money,all_money,pay_money,status,time")
  539. ->where("order_id",$order_id)
  540. ->where("uid",$request->user["uid"])
  541. ->find();
  542. if(empty($data)){
  543. return app('json')->fail('信息不存在!');
  544. }
  545. $data=$data->toArray();
  546. if($data["status"]==0 && $data["time"]<time() - 30*60){
  547. (new ShowTemplateOrder)->where("id",$data["id"])->where("uid",$request->user["uid"])->update(["status"=>-1]);
  548. $data["status"]==-1;
  549. }
  550. $data["time"] = date("Y-m-d H:i:s",$data["time"]);
  551. return app('json')->success($data);
  552. }
  553. /**
  554. * 用户模板列表
  555. * @param Request $request
  556. */
  557. public function userShowTemplateList(Request $request){
  558. $post = UtilService::getMore([
  559. ['page', 1],
  560. ['pageSize', 50],
  561. ], $request);
  562. $post["pageSize"] = $post["pageSize"]>50 ? 50 : (int)$post["pageSize"];
  563. $post["page"] = $post["page"]<=0 ? 1 : (int)$post["page"];
  564. $where=[];
  565. $where[]=["ut.uid","=",$request->user["uid"]];
  566. $totalCount = (new UserShowTemplate)->alias("ut")->where($where)->count();
  567. $data=null;
  568. if($totalCount>0){
  569. $data = (new UserShowTemplate)
  570. ->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")
  571. ->alias("ut")
  572. ->join("show_template t", "t.id = ut.show_template_id","left")
  573. ->where($where)
  574. ->order("ut.is_default", "desc")
  575. ->order("ut.id", "desc")
  576. ->page($post["page"], $post["pageSize"])
  577. ->select();
  578. foreach($data as $k=>$v){
  579. $data[$k]["is_use"] = 1;//是否已经购买或者可以使用
  580. $data[$k]["imgs"] = getImageAr($v["imgs"]);
  581. $data[$k]["img"] = empty($data[$k]["imgs"]) ? "" : $data[$k]["imgs"][0];
  582. $data[$k]["sales_count"] = $data[$k]["real_sales"] + $data[$k]["unreal_sales"];
  583. unset($data[$k]["real_sales"]);
  584. unset($data[$k]["unreal_sales"]);
  585. }
  586. }
  587. $data = empty($data)?[]:$data;
  588. return app('json')->success(["list" => $data, "pageSize" => $post["pageSize"],"page"=>$post["page"],"totalCount"=>$totalCount]);
  589. }
  590. /**
  591. * 设置默认模板
  592. * @param Request $request
  593. */
  594. public function setShowTemplate(Request $request){
  595. [$show_template_id] = UtilService::getMore([
  596. ['show_template_id','','empty','参数错误'],
  597. ],$request,true);
  598. (new UserShowTemplate)->where("uid",$request->user["uid"])->where("is_default",0)->update(["is_default"=>0]);
  599. (new UserShowTemplate)->where("uid",$request->user["uid"])->where("show_template_id",$show_template_id)->update(["is_default"=>1]);
  600. return app('json')->success("设置成功");
  601. }
  602. /**
  603. * 获取小程序码
  604. * @param Request $request
  605. */
  606. public function getWxmpQrcode(Request $request){
  607. $weixinA = new weixina();
  608. $data = $weixinA->getUnlimitedQRCode("pages/index/index","a=1");
  609. if(empty($data)){
  610. return app('json')->fail("小程序码获取失败".$weixinA->error);
  611. }
  612. $base64 = 'data:'.$data['contentType'].';base64,'.base64_encode($data['buffer']);
  613. $res = $this->uploadImageBase64("wximg",$base64);
  614. if($res["code"]!=1){
  615. return app('json')->fail($res["msg"]);
  616. }
  617. return app('json')->success(["img"=>$res["data"]]);
  618. }
  619. /**
  620. *
  621. * @param Request $request
  622. */
  623. public function uploadBase64(Request $request){
  624. [$img,$code] = UtilService::getMore([
  625. ['img', '','empty',"请上传图片"],
  626. ['code', 'image'],
  627. ], $request,true);
  628. // $imgAr = explode("base64,",$img);
  629. // if(empty($imgAr)){
  630. // return app("json")->fail("请上传base64图片");
  631. // }
  632. // $imgBase64 = count($imgAr)==1?$imgAr[0]:$imgAr[1];
  633. // //判断字符串是否经过编码方法
  634. // if($imgBase64!=base64_encode(base64_decode($imgBase64))){
  635. // return app("json")->fail("请上传base64图片");
  636. // }
  637. // $base64 = "data:application/octet-stream;base64,".$imgBase64;//七牛
  638. $res = $this->uploadImageBase64($code,$img);
  639. if($res["code"]!=1){
  640. return app('json')->fail($res["msg"]);
  641. }
  642. return app('json')->success(["img"=>$res["data"]]);
  643. }
  644. /**
  645. * 图片上传
  646. * @param Request $request
  647. * @return type
  648. */
  649. public function upload(Request $request){
  650. $uploadConfig = config('filesystem');
  651. $sysData = (new SysModel())->where("id",1)->find();
  652. $file = $request->file('file');
  653. $code = $request->post("code","image");
  654. if(empty($file)) {
  655. return app('json')->fail("未上传文件");
  656. }
  657. $size = $file->getSize();
  658. if(!empty($size) && $size>$uploadConfig["image"]["size"]*1024*1024){
  659. return app('json')->fail("图片不能超过{$uploadConfig["image"]["size"]}M");
  660. }
  661. if(!in_array($code, $uploadConfig['image']['path'])){
  662. return app('json')->fail("上传路径错误");
  663. }
  664. $ext = $file->extension();
  665. if(!in_array($ext, $uploadConfig['image']['ext'])){
  666. return app('json')->fail("图片类型错误");
  667. }
  668. $upPath = \think\facade\Filesystem::disk('resource')->putFile( $code, $file);
  669. if(!$upPath){
  670. return app('json')->fail("上传失败01");
  671. }
  672. $savePath = $sysData['system_url'].'/resource/' . $upPath;
  673. $imgUrl = str_replace("\\", "/", $savePath);
  674. return app('json')->success(['img'=>$imgUrl,'size'=>$size]);
  675. }
  676. /**
  677. * 视频上传
  678. * @param Request $request
  679. * @return type
  680. */
  681. public function uploadVideo(Request $request){
  682. $uploadConfig = config('filesystem');
  683. $sysData = (new SysModel())->where("id",1)->find();
  684. $file = $request->file('file');
  685. $code = $request->post("code","video");
  686. if(empty($file)) {
  687. return app('json')->fail("未上传文件");
  688. }
  689. if(!in_array($code, $uploadConfig['video']['path'])){
  690. return app('json')->fail("上传路径错误");
  691. }
  692. $ext = $file->extension();
  693. if(!in_array($ext, $uploadConfig['video']['ext'])){
  694. return app('json')->fail("视频类型错误");
  695. }
  696. $upPath = \think\facade\Filesystem::disk('resource')->putFile( $code, $file);
  697. if(!$upPath){
  698. return app('json')->fail("上传失败01");
  699. }
  700. $savePath = $sysData['system_url'].'/resource/' . $upPath;
  701. $imgUrl = str_replace("\\", "/", $savePath);
  702. return app('json')->success(['video'=>$imgUrl]);
  703. }
  704. /**
  705. * base64文件上传
  706. * @param type $code
  707. * @param type $base64
  708. */
  709. public function uploadImageBase64($code,$base64){
  710. $sysData = (new SysModel())->where("id",1)->find();
  711. $uploadConfig = config('filesystem');
  712. //验证base64格式
  713. preg_match('/^(data:\s*image\/(\w+);base64,)/',$base64, $result);
  714. if(!$result){
  715. return ["code"=>-1,"msg"=>"base64格式格式错误"];
  716. }
  717. //验证图片后缀
  718. if (!in_array($result[2], $uploadConfig['image']['ext'], true)) {
  719. return ["code"=>-1,"msg"=>"不支持的图片格式"];
  720. }
  721. $rootPath = config('filesystem.disks.resource.root');
  722. $hashName = $code.DIRECTORY_SEPARATOR.date('Ymd') . DIRECTORY_SEPARATOR . md5((string) microtime(true)).".".$result[2];
  723. $filePath = $rootPath. DIRECTORY_SEPARATOR .$hashName;
  724. $path = dirname($filePath);
  725. // 检测目录
  726. if (!is_dir($path)) {
  727. return ["code"=>-1,"msg"=>"上传目录不存在"];
  728. }
  729. if (!mkdir($path, 0777, true)) {
  730. return ["code"=>-1,"msg"=>"生成目录失败"];
  731. }
  732. //重名文件验证
  733. if (is_file($filePath)) {
  734. return ["code"=>-1,"msg"=>"文件已存在"];
  735. }
  736. if(!file_put_contents($filePath, base64_decode(str_replace($result[1], '', $base64)))){
  737. return ["code"=>-1,"msg"=>"文件报错失败"];
  738. }
  739. $savePath = $sysData['system_url'].config('filesystem.disks.resource.url').DIRECTORY_SEPARATOR.$hashName;
  740. return ["code"=>1,"url"=>str_replace("\\", "/", $savePath)];
  741. }
  742. // public function index(Request $request){
  743. // $file =$request->file('file');
  744. // $isZ = $request->post('isz',1);
  745. // if(empty($file)) {
  746. // return app('json')->fail("未上传文件");
  747. // }
  748. // $rootTmp = config('filesystem.disks.local.root') .'/' . \think\facade\Filesystem::putFile( 'tmp', $file);
  749. // if($isZ == 1) {
  750. // $image_size = @getimagesize($rootTmp);
  751. // if ($image_size[0] > 1000) {
  752. // $imgS = Image::open($rootTmp);
  753. // $imgS->thumb(1000, $image_size[1]);
  754. // $imgS->save($rootTmp);
  755. // } else {
  756. // if ($image_size[1] > 1000) {
  757. // $imgS = Image::open($rootTmp);
  758. // $imgS->thumb($image_size[0], 1000);
  759. // $imgS->save($rootTmp);
  760. // }
  761. // }
  762. // }
  763. // $qiniu = new Qiniu;
  764. // $img_url = $qiniu->updateFile('img', $rootTmp, $rootTmp);
  765. // if(empty($img_url['url'])){
  766. // return app('json')->fail( $qiniu->getError());
  767. // }
  768. //
  769. // return app('json')->success(['img'=>$img_url['url']]);
  770. // }
  771. }