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")
  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. ->where("u.uid",$request->user["uid"])
  175. ->where("u.status",1)
  176. ->order("u.id","desc")
  177. ->find();
  178. if(empty($data)){
  179. return app('json')->fail("您还没有通过名片信息审核");
  180. }
  181. $data = $data->toArray();
  182. $serviceTypeModel = new ServiceTypeModel();
  183. $data["birthday"] = empty($data["birthday"]) ?"":date("Y-m-d",$data["birthday"]);
  184. $data["time"] = date("Y-m-d H:i:s",$data["time"]);
  185. $data["service_audit_imgs"] = getImageAr($data["service_audit_imgs"]);
  186. $data["service_intro_imgs"] = getImageAr($data["service_intro_imgs"]);
  187. $data["service_imgs"] = getImageAr($data["service_imgs"]);
  188. //服务区域
  189. $data["service_area"] = getImageAr($data["service_area"]);
  190. $data["service_area_all"] = [];
  191. foreach($data["service_area"] as $k2=>$v2){
  192. $data["service_area_all"][]=getAreaItemAr($v2);
  193. }
  194. //服务内容
  195. $data["service_project"] = getImageAr($data["service_project"]);
  196. $data["service_project_ar"] = [];
  197. if(!empty($data["service_project"])){
  198. $data["service_project_ar"] = $serviceTypeModel->where("id","in",$data["service_project"])->select();
  199. }
  200. $data["service_label"] = getImageAr($data["service_label"]);
  201. $data["service_label_ar"] = (new ServiceLabelModel)->getColumnList("id", "title", $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. $save["service_label"]="";
  306. $labelData = (new ServiceLabelModel)->getColumnList("id","id",$post["service_label"]);
  307. if(!empty($labelData)){
  308. $save["service_label"] = implode(",", $labelData);
  309. }
  310. $save["service_intro_content"] = empty($post["service_intro_content"])? "" : $post["service_intro_content"];
  311. $save["service_intro_imgs"] = empty($post["service_intro_imgs"]) ? "" : implode(",", $post["service_intro_imgs"]);
  312. $save["service_audit_imgs"] = empty($post["service_audit_imgs"]) ? "" : implode(",", $post["service_audit_imgs"]);
  313. $save["service_imgs"] = empty($post["service_imgs"]) ? "" : implode(",", $post["service_imgs"]);//我的服务展示
  314. $save['work_year'] = empty($post["work_year"]) ? "": $post["work_year"];
  315. $save['ancestral_place'] = empty($post["ancestral_place"])? "": $post["ancestral_place"];
  316. $save['education'] = empty($post["education"]) ? "": $post["education"];
  317. $save['minority'] = empty($post["minority"]) ? "": $post["minority"];
  318. $save["status"] = 0;
  319. $save["time"] = time();
  320. $save["uid"] = $request->user["uid"];
  321. //服务职称
  322. $save["user_work_type_id"] = empty($post["user_work_type_id"]) ? 0: (int)$post["user_work_type_id"];
  323. if($save["user_work_type_id"]>0 && (new UserWorkType)->where("id",$post["user_work_type_id"])->where("status",1)->count()<=0){
  324. return app('json')->fail("当前类型不能选择");
  325. }
  326. $r = (new InfoAudit)->insertGetId($save);
  327. if(!$r){
  328. return app('json')->fail("系统错误");
  329. }
  330. $no = "CARD-".date("YmdHis")."-".$r;
  331. (new InfoAudit)->where("id",$r)->update(["no"=>$no]);
  332. return app('json')->success("提交成功,请耐心等待审核");
  333. }
  334. /**
  335. * 平台认证
  336. * @param Request $request
  337. */
  338. public function subTypeAudit(Request $request){
  339. $data = (new TypeAudit)->where("uid",$request->user["uid"])->order("id desc")->find();
  340. if(!empty($data) && $data["status"]==0){
  341. return app('json')->fail("平台审核中,请勿重复提交");
  342. }
  343. $post = UtilService::getMore([
  344. ['service_audit_imgs',[],"empty","请上传服务认证截图"],
  345. ],$request);
  346. $save=[];
  347. $save["service_audit_imgs"] = empty($post["service_audit_imgs"]) ?"": implode(",", $post["service_audit_imgs"]);
  348. $save["status"] = 0;
  349. $save["time"] = time();
  350. $save["uid"] = $request->user["uid"];
  351. if(empty($save["service_audit_imgs"])){
  352. return app('json')->fail("请上传服务认证截图");
  353. }
  354. $r = (new TypeAudit)->insertGetId($save);
  355. if(!$r){
  356. return app('json')->fail("系统错误");
  357. }
  358. $no = "CERT-".date("YmdHis")."-".$r;
  359. (new TypeAudit)->where("id",$r)->update(["no"=>$no]);
  360. return app('json')->success("提交成功,请耐心等待审核");
  361. }
  362. /**
  363. * 模板订单提交[第一步]
  364. * @param Request $request
  365. */
  366. public function subShowTemplateOrder(Request $request){
  367. [$id,$pay_type] = UtilService::getMore([
  368. ['id','','empty','参数错误'],
  369. ['pay_type','','empty','请选择支付方式'],
  370. ],$request,true);
  371. if(!in_array($pay_type,["wxpay","balance"])){
  372. return app('json')->fail('不支持该支付方式!');
  373. }
  374. //缓存
  375. $redis = \think\facade\Cache::store('redis');
  376. $key = 'show_template_order_sub_' . $request->user['uid'];
  377. $bool = $redis->handler()->exists($key);
  378. if ($bool) {
  379. return app('json')->fail('请务重复操作,请稍等在重试!');
  380. }
  381. $redis->set($key,1,5);//5秒缓存
  382. $proData = (new ShowTemplate)->where("id",$id)->where("status",1)->find();
  383. if(empty($proData)){
  384. return app('json')->fail("当前模板已下架");
  385. }
  386. $proData = $proData->toArray();
  387. $count = (new UserShowTemplate)->where("uid",$request->user['uid'])->where("show_template_id",$id)->count();
  388. if($count>0){
  389. return app('json')->fail("您已购买过当前模板");
  390. }
  391. //验证
  392. $orderCount = (new ShowTemplateOrder)->where("uid",$request->user['uid'])->where("show_template_id",$id)->where("status",1)->count();
  393. if($orderCount>0){
  394. return app('json')->fail("您已下单该模板,请勿重复下单");
  395. }
  396. $price = floatval($proData["price"]);
  397. // if($price<0.01){
  398. // return app('json')->fail("模板信息错误");
  399. // }
  400. $allMoney = $price;//订单商品费用
  401. $total_money = $allMoney;//订单总费用
  402. $payMoney = $total_money;//订单需支付费用
  403. $payMoney = $payMoney <= 0 ? 0 : $payMoney;
  404. $nowTime = time();
  405. //余额支付验证
  406. if($pay_type=="balance" && $payMoney > $request->user["money"]){
  407. return app('json')->fail("当前余额不足");
  408. }
  409. //主订单数据
  410. $save=[];
  411. $save['uid'] = $request->user['uid'];
  412. $save['order_id'] = makeOrderId($request->user['uid'],"ST");
  413. $save['pay_type'] = $pay_type;//
  414. $save['total_money'] = $total_money;//订单总金额
  415. $save['all_money'] = $allMoney;//商品中金额
  416. $save['pay_money'] = $payMoney;//实际支付金额
  417. $save['balance'] = 0;//余额支付了多少(目前不用)
  418. $save['status'] = $payMoney <= 0 ? 1 : 0;
  419. $save['pay_time'] = $payMoney <= 0 ? time() : 0;
  420. $save['time'] = $nowTime;
  421. $save['show_template_id'] = $proData["id"];
  422. $save['show_template_title'] = $proData["title"];;
  423. $save['show_template_price'] = $proData["price"];
  424. $save['show_template_img'] = empty($proData["imgs"]) ? "" : explode(",", $proData["imgs"])[0];
  425. $save['show_template_code'] = $proData["code"];
  426. //余额实时支付
  427. if($pay_type=="balance"){
  428. $save['status'] = 1;
  429. $save['pay_time'] = time();
  430. }
  431. try{
  432. Db::startTrans();
  433. $o_id = (new ShowTemplateOrder)->insertGetId($save);
  434. if(empty($o_id)){
  435. return app('json')->fail("订单提交失败");
  436. }
  437. //不需要支付
  438. if($payMoney<=0 && $save['status']==1){
  439. //验证并绑定当前模板
  440. (new UserShowTemplate)->userBindTemp($save["show_template_id"],$save['uid']);
  441. Db::commit();
  442. return app("json")->success(["order_id"=>$save['order_id'],"money"=>$payMoney,"status"=>$save['status']]);
  443. }
  444. //余额支付
  445. if($pay_type=="balance"){
  446. //验证并绑定当前模板
  447. (new UserShowTemplate)->userBindTemp($save["show_template_id"],$save['uid']);
  448. //修改用户余额
  449. $res = (new UserDetailModel)->balancePay($request->user["uid"],$payMoney,"show_temp_pay",["to_id"=>$o_id]);
  450. if(!$res){
  451. Db::rollback();
  452. return app('json')->fail("余额支付失败");
  453. }
  454. Db::commit();
  455. return app("json")->success(["order_id"=>$save['order_id'],"money"=>$payMoney,"status"=>$save['status']]);
  456. }
  457. //微信支付
  458. if(empty($request->user['openid'])){
  459. Db::rollback();
  460. return app('json')->fail('用户还未绑定微信!');
  461. }
  462. //清理之前支付凭证 || 防止重复购买
  463. $payTrade = (new PayTradeModel)
  464. ->where("uid",$request->user["uid"])
  465. ->where("o_id",$o_id)
  466. ->where("type","temp")
  467. ->where("status",0)
  468. ->where("time","<",time() - 7*24*60*60)
  469. ->select()
  470. ->toArray();
  471. $wxpay = new wxpayApi();
  472. foreach ($payTrade as $v) {
  473. // if($v['pay_type'] == 'wxpay') {
  474. // $result = $wxpay->closeOrder($v['pay_no']);
  475. // }
  476. (new PayTradeModel)->where("id",$v['id'])->where("status",0)->delete();
  477. }
  478. $mtime = microtime(true)*10000;
  479. $payOn = "T".date("Ymd").$mtime .rand(100,999) . $request->user['uid'];
  480. $out_trade_no="";
  481. $payType = $save["pay_type"];
  482. //添加交易记录
  483. $trade = [
  484. 'uid' => $request->user['uid'],
  485. 'o_id' => $o_id,
  486. 'order_id' =>$save["order_id"],
  487. 'pay_no' => $payOn,
  488. 'out_trade_no' => empty($out_trade_no) ? $payOn : $out_trade_no,
  489. 'pay_type' => $payType,
  490. 'money' => $payMoney,
  491. 'type' => 'temp',
  492. 'd_json' => serialize(['orderId'=>$save["order_id"],"give_score"=>0]),
  493. 'time' => time(),
  494. 'status' => 0,
  495. ];
  496. $r=(new PayTradeModel)->insert($trade);
  497. if(!$r){
  498. Db::rollback();
  499. return app('json')->fail('支付信息获取失败!');
  500. }
  501. $clictip = get_client_ip();
  502. if(empty($clictip)){
  503. $clictip = $request->ip();
  504. }
  505. $payData = $wxpay->wxmpPay([
  506. 'body' => "微信小程序购买模板",
  507. 'out_trade_no' => $payOn,
  508. 'total' => $payMoney,
  509. 'openid' => $request->user['openid'],
  510. 'payer_client_ip' => $clictip,
  511. ]);
  512. if(empty($payData)){
  513. Db::rollback();
  514. return app('json')->fail($wxpay->errorMsg);
  515. }
  516. Db::commit();
  517. $redis->delete($key);
  518. return app('json')->success([
  519. 'jsApiParameters'=> $payData,
  520. 'pay_no' => $payOn,
  521. 'order_id' => $save["order_id"],
  522. "status" => $save['status'],
  523. "money" => $payMoney,
  524. ]);
  525. } catch (DbException $db){
  526. Db::rollback();
  527. return app('json')->fail("订单生成失败");
  528. }
  529. }
  530. /**
  531. * 获取模板购买订单详情
  532. * @param Request $request
  533. */
  534. public function payShowTemplateOrderInfo(Request $request){
  535. [$order_id] = UtilService::getMore([
  536. ['order_id','','empty','参数错误'],
  537. ],$request,true);
  538. $data = (new ShowTemplateOrder)
  539. ->field("order_id,total_money,all_money,pay_money,status,time")
  540. ->where("order_id",$order_id)
  541. ->where("uid",$request->user["uid"])
  542. ->find();
  543. if(empty($data)){
  544. return app('json')->fail('信息不存在!');
  545. }
  546. $data=$data->toArray();
  547. if($data["status"]==0 && $data["time"]<time() - 30*60){
  548. (new ShowTemplateOrder)->where("id",$data["id"])->where("uid",$request->user["uid"])->update(["status"=>-1]);
  549. $data["status"]==-1;
  550. }
  551. $data["time"] = date("Y-m-d H:i:s",$data["time"]);
  552. return app('json')->success($data);
  553. }
  554. /**
  555. * 用户模板列表
  556. * @param Request $request
  557. */
  558. public function userShowTemplateList(Request $request){
  559. $post = UtilService::getMore([
  560. ['page', 1],
  561. ['pageSize', 50],
  562. ], $request);
  563. $post["pageSize"] = $post["pageSize"]>50 ? 50 : (int)$post["pageSize"];
  564. $post["page"] = $post["page"]<=0 ? 1 : (int)$post["page"];
  565. $where=[];
  566. $where[]=["ut.uid","=",$request->user["uid"]];
  567. $totalCount = (new UserShowTemplate)->alias("ut")->where($where)->count();
  568. $data=null;
  569. if($totalCount>0){
  570. $data = (new UserShowTemplate)
  571. ->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")
  572. ->alias("ut")
  573. ->join("show_template t", "t.id = ut.show_template_id","left")
  574. ->where($where)
  575. ->order("ut.is_default", "desc")
  576. ->order("ut.id", "desc")
  577. ->page($post["page"], $post["pageSize"])
  578. ->select();
  579. foreach($data as $k=>$v){
  580. $data[$k]["is_use"] = 1;//是否已经购买或者可以使用
  581. $data[$k]["imgs"] = getImageAr($v["imgs"]);
  582. $data[$k]["img"] = empty($data[$k]["imgs"]) ? "" : $data[$k]["imgs"][0];
  583. $data[$k]["sales_count"] = $data[$k]["real_sales"] + $data[$k]["unreal_sales"];
  584. unset($data[$k]["real_sales"]);
  585. unset($data[$k]["unreal_sales"]);
  586. }
  587. }
  588. $data = empty($data)?[]:$data;
  589. return app('json')->success(["list" => $data, "pageSize" => $post["pageSize"],"page"=>$post["page"],"totalCount"=>$totalCount]);
  590. }
  591. /**
  592. * 设置默认模板
  593. * @param Request $request
  594. */
  595. public function setShowTemplate(Request $request){
  596. [$show_template_id] = UtilService::getMore([
  597. ['show_template_id','','empty','参数错误'],
  598. ],$request,true);
  599. (new UserShowTemplate)->where("uid",$request->user["uid"])->where("is_default",0)->update(["is_default"=>0]);
  600. (new UserShowTemplate)->where("uid",$request->user["uid"])->where("show_template_id",$show_template_id)->update(["is_default"=>1]);
  601. return app('json')->success("设置成功");
  602. }
  603. /**
  604. * 获取小程序码
  605. * @param Request $request
  606. */
  607. public function getWxmpQrcode(Request $request){
  608. $weixinA = new weixina();
  609. $data = $weixinA->getUnlimitedQRCode("pages/index/index","a=1");
  610. if(empty($data)){
  611. return app('json')->fail("小程序码获取失败".$weixinA->error);
  612. }
  613. $base64 = 'data:'.$data['contentType'].';base64,'.base64_encode($data['buffer']);
  614. $res = $this->uploadImageBase64("wximg",$base64);
  615. if($res["code"]!=1){
  616. return app('json')->fail($res["msg"]);
  617. }
  618. return app('json')->success(["img"=>$res["data"]]);
  619. }
  620. /**
  621. *
  622. * @param Request $request
  623. */
  624. public function uploadBase64(Request $request){
  625. [$img,$code] = UtilService::getMore([
  626. ['img', '','empty',"请上传图片"],
  627. ['code', 'image'],
  628. ], $request,true);
  629. // $imgAr = explode("base64,",$img);
  630. // if(empty($imgAr)){
  631. // return app("json")->fail("请上传base64图片");
  632. // }
  633. // $imgBase64 = count($imgAr)==1?$imgAr[0]:$imgAr[1];
  634. // //判断字符串是否经过编码方法
  635. // if($imgBase64!=base64_encode(base64_decode($imgBase64))){
  636. // return app("json")->fail("请上传base64图片");
  637. // }
  638. // $base64 = "data:application/octet-stream;base64,".$imgBase64;//七牛
  639. $res = $this->uploadImageBase64($code,$img);
  640. if($res["code"]!=1){
  641. return app('json')->fail($res["msg"]);
  642. }
  643. return app('json')->success(["img"=>$res["data"]]);
  644. }
  645. /**
  646. * 图片上传
  647. * @param Request $request
  648. * @return type
  649. */
  650. public function upload(Request $request){
  651. $uploadConfig = config('filesystem');
  652. $sysData = (new SysModel())->where("id",1)->find();
  653. $file = $request->file('file');
  654. $code = $request->post("code","image");
  655. if(empty($file)) {
  656. return app('json')->fail("未上传文件");
  657. }
  658. $size = $file->getSize();
  659. if(!empty($size) && $size>$uploadConfig["image"]["size"]*1024*1024){
  660. return app('json')->fail("图片不能超过{$uploadConfig["image"]["size"]}M");
  661. }
  662. if(!in_array($code, $uploadConfig['image']['path'])){
  663. return app('json')->fail("上传路径错误");
  664. }
  665. $ext = $file->extension();
  666. if(!in_array($ext, $uploadConfig['image']['ext'])){
  667. return app('json')->fail("图片类型错误");
  668. }
  669. $upPath = \think\facade\Filesystem::disk('resource')->putFile( $code, $file);
  670. if(!$upPath){
  671. return app('json')->fail("上传失败01");
  672. }
  673. $savePath = $sysData['system_url'].'/resource/' . $upPath;
  674. $imgUrl = str_replace("\\", "/", $savePath);
  675. return app('json')->success(['img'=>$imgUrl,'size'=>$size]);
  676. }
  677. /**
  678. * 视频上传
  679. * @param Request $request
  680. * @return type
  681. */
  682. public function uploadVideo(Request $request){
  683. $uploadConfig = config('filesystem');
  684. $sysData = (new SysModel())->where("id",1)->find();
  685. $file = $request->file('file');
  686. $code = $request->post("code","video");
  687. if(empty($file)) {
  688. return app('json')->fail("未上传文件");
  689. }
  690. if(!in_array($code, $uploadConfig['video']['path'])){
  691. return app('json')->fail("上传路径错误");
  692. }
  693. $ext = $file->extension();
  694. if(!in_array($ext, $uploadConfig['video']['ext'])){
  695. return app('json')->fail("视频类型错误");
  696. }
  697. $upPath = \think\facade\Filesystem::disk('resource')->putFile( $code, $file);
  698. if(!$upPath){
  699. return app('json')->fail("上传失败01");
  700. }
  701. $savePath = $sysData['system_url'].'/resource/' . $upPath;
  702. $imgUrl = str_replace("\\", "/", $savePath);
  703. return app('json')->success(['video'=>$imgUrl]);
  704. }
  705. /**
  706. * base64文件上传
  707. * @param type $code
  708. * @param type $base64
  709. */
  710. public function uploadImageBase64($code,$base64){
  711. $sysData = (new SysModel())->where("id",1)->find();
  712. $uploadConfig = config('filesystem');
  713. //验证base64格式
  714. preg_match('/^(data:\s*image\/(\w+);base64,)/',$base64, $result);
  715. if(!$result){
  716. return ["code"=>-1,"msg"=>"base64格式格式错误"];
  717. }
  718. //验证图片后缀
  719. if (!in_array($result[2], $uploadConfig['image']['ext'], true)) {
  720. return ["code"=>-1,"msg"=>"不支持的图片格式"];
  721. }
  722. $rootPath = config('filesystem.disks.resource.root');
  723. $hashName = $code.DIRECTORY_SEPARATOR.date('Ymd') . DIRECTORY_SEPARATOR . md5((string) microtime(true)).".".$result[2];
  724. $filePath = $rootPath. DIRECTORY_SEPARATOR .$hashName;
  725. $path = dirname($filePath);
  726. // 检测目录
  727. if (!is_dir($path)) {
  728. return ["code"=>-1,"msg"=>"上传目录不存在"];
  729. }
  730. if (!mkdir($path, 0777, true)) {
  731. return ["code"=>-1,"msg"=>"生成目录失败"];
  732. }
  733. //重名文件验证
  734. if (is_file($filePath)) {
  735. return ["code"=>-1,"msg"=>"文件已存在"];
  736. }
  737. if(!file_put_contents($filePath, base64_decode(str_replace($result[1], '', $base64)))){
  738. return ["code"=>-1,"msg"=>"文件报错失败"];
  739. }
  740. $savePath = $sysData['system_url'].config('filesystem.disks.resource.url').DIRECTORY_SEPARATOR.$hashName;
  741. return ["code"=>1,"url"=>str_replace("\\", "/", $savePath)];
  742. }
  743. // public function index(Request $request){
  744. // $file =$request->file('file');
  745. // $isZ = $request->post('isz',1);
  746. // if(empty($file)) {
  747. // return app('json')->fail("未上传文件");
  748. // }
  749. // $rootTmp = config('filesystem.disks.local.root') .'/' . \think\facade\Filesystem::putFile( 'tmp', $file);
  750. // if($isZ == 1) {
  751. // $image_size = @getimagesize($rootTmp);
  752. // if ($image_size[0] > 1000) {
  753. // $imgS = Image::open($rootTmp);
  754. // $imgS->thumb(1000, $image_size[1]);
  755. // $imgS->save($rootTmp);
  756. // } else {
  757. // if ($image_size[1] > 1000) {
  758. // $imgS = Image::open($rootTmp);
  759. // $imgS->thumb($image_size[0], 1000);
  760. // $imgS->save($rootTmp);
  761. // }
  762. // }
  763. // }
  764. // $qiniu = new Qiniu;
  765. // $img_url = $qiniu->updateFile('img', $rootTmp, $rootTmp);
  766. // if(empty($img_url['url'])){
  767. // return app('json')->fail( $qiniu->getError());
  768. // }
  769. //
  770. // return app('json')->success(['img'=>$img_url['url']]);
  771. // }
  772. }