User.php 34 KB

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