User.php 34 KB

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