User.php 34 KB

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