UserController.php 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695
  1. <?php
  2. namespace app\controller;
  3. use app\api\repositories\UsersRepositories;
  4. use app\business\BankCardBusiness;
  5. use app\business\LoginBusiness;
  6. use app\business\StreamBusiness;
  7. use app\business\UserIdentityBusiness;
  8. use Illuminate\Support\Arr;
  9. use Matrix\Exception;
  10. use Respect\Validation\Validator;
  11. use support\Db;
  12. use support\Redis;
  13. use support\Request;
  14. use hg\apidoc\annotation as Apidoc;
  15. use Throwable;
  16. use Webman\Captcha\CaptchaBuilder;
  17. use Webman\Captcha\PhraseBuilder;
  18. use function Symfony\Component\String\s;
  19. #[Apidoc\Title("用户信息")]
  20. #[Apidoc\Group("User")]
  21. #[Apidoc\Sort(5)]
  22. class UserController
  23. {
  24. #[Apidoc\Title("用户信息")]
  25. #[Apidoc\Url("api/user.html")]
  26. #[Apidoc\Method("POST")]
  27. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  28. #[Apidoc\Returned(name: "uuid", type: "int", require: true, desc: 'UUID', default: '100001')]
  29. #[Apidoc\Returned(name: "mobile", type: "string", require: true, desc: '账号', default: '15800000000')]
  30. #[Apidoc\Returned(name: "name", type: "string", require: true, desc: '名称', default: '主号')]
  31. #[Apidoc\Returned(name: "money", type: "string", require: true, desc: '总资产', default: '0.00')]
  32. #[Apidoc\Returned(name: "money_one", type: "string", require: true, desc: '脱贫金', default: '0.00')]
  33. #[Apidoc\Returned(name: "money_two", type: "string", require: true, desc: '团队金', default: '0.00')]
  34. #[Apidoc\Returned(name: "money_four", type: "string", require: true, desc: '充值钱包', default: '0.00')]
  35. #[Apidoc\Returned(name: "card_code", type: "string", require: true, desc: '卡号', default: '0.00')]
  36. #[Apidoc\Returned(name: "total_sign", type: "int", require: true, desc: '签到总天数', default: '')]
  37. #[Apidoc\Returned(name: "day_is_sign", type: "int", require: true, desc: '今日是否签到', default: '')]
  38. #[Apidoc\Returned(name: "user_identity", type: "array", desc: '实名信息', default: '', children: [
  39. ['name' => "name", 'type' => 'string', 'require' => true, 'default' => '张三1', 'desc' => '姓名'],
  40. ['name' => "number", 'type' => 'string', 'require' => true, 'default' => '500221233312836451', 'desc' => '身份证号'],
  41. ])]
  42. #[Apidoc\Returned(name: "bank_card", type: "string", desc: '银行卡', default: '', children: [
  43. ['name' => "affiliated_bank", 'type' => 'string', 'require' => true, 'default' => '中国银行1', 'desc' => '归属银行'],
  44. ['name' => "account_holder", 'type' => 'string', 'require' => true, 'default' => '张三', 'desc' => '开户人'],
  45. ['name' => "card_number", 'type' => 'string', 'require' => true, 'default' => '500221233312836451', 'desc' => '卡号'],
  46. ])]
  47. #[Apidoc\Returned(name: "is_buy_sign", type: "string", desc: '是否签署承诺书', default: '', children: [
  48. ['name' => "has", 'type' => 'string', 'require' => true, 'default' => '1', 'desc' => '判断 1没有购买专属卡 需要提示跳转 2没有签署 3 已签署'],
  49. ['name' => "goods_data", 'type' => 'array', 'require' => true, 'default' => '张三', 'desc' => '产品信息'],
  50. ])]
  51. public function userData(Request $request)
  52. {
  53. //查询今日是否已签到
  54. // $day_is_sign = Db::table('wa_stream')
  55. // ->where('type', streamType2)
  56. // ->whereBetween('add_time', [strtotime(date('Y-m-d')) . ' 00:00:00', strtotime(date('Y-m-d') . ' 23:59:59')])
  57. // ->where('user_id', $request->user_data['id'])
  58. // ->first();
  59. $total_sign = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count();
  60. $is_buy_card = Db::table('wa_payorder')
  61. ->where('user_id', $request->user_data['id'])
  62. ->where('is_pay', 2)
  63. ->where('goods_type', 1)
  64. ->exists();
  65. // $is_buy_binding = Db::table('wa_payorder')
  66. // ->where('user_id', $request->user_data['id'])
  67. // ->where('is_pay', 2)
  68. // ->where('goods_type', 3)
  69. // ->exists();
  70. //
  71. // $is_buy_kaitong = Db::table('wa_payorder')
  72. // ->where('user_id', $request->user_data['id'])
  73. // ->where('is_pay', 2)
  74. // ->where('goods_type', 5)
  75. // ->exists();
  76. //
  77. // $is_buy_binding_mobile = Db::table('wa_payorder')
  78. // ->where('user_id', $request->user_data['id'])
  79. // ->where('is_pay', 2)
  80. // ->where('goods_type', 6)
  81. // ->exists();
  82. $is_buy_activate = Db::table('wa_payorder')
  83. ->where('user_id', $request->user_data['id'])
  84. ->where('is_pay', 2)
  85. ->where('goods_type', 8)
  86. ->exists();
  87. // $is_buy_double = Db::table('wa_payorder')
  88. // ->where('user_id', $request->user_data['id'])
  89. // ->where('is_pay', 2)
  90. // ->where('goods_type', 9)
  91. // ->exists();
  92. //
  93. // $is_buy_fast = Db::table('wa_payorder')
  94. // ->where('user_id', $request->user_data['id'])
  95. // ->where('is_pay', 2)
  96. // ->where('goods_type', 10)
  97. // ->exists();
  98. //
  99. // $is_buy_stampduty = Db::table('wa_payorder')
  100. // ->where('user_id', $request->user_data['id'])
  101. // ->where('is_pay', 2)
  102. // ->where('goods_type', 11)
  103. // ->exists();
  104. //
  105. // $is_buy_packaging = Db::table('wa_payorder')
  106. // ->where('user_id', $request->user_data['id'])
  107. // ->where('is_pay', 2)
  108. // ->where('goods_type', 12)
  109. // ->exists();
  110. // $is_buy_whitelist = Db::table('wa_payorder')
  111. // ->where('user_id', $request->user_data['id'])
  112. // ->where('is_pay', 2)
  113. // ->where('goods_type', 13)
  114. // ->exists();
  115. //
  116. // $is_buy_voucher = Db::table('wa_payorder')
  117. // ->where('user_id', $request->user_data['id'])
  118. // ->where('is_pay', 2)
  119. // ->where('goods_type', 14)
  120. // ->exists();
  121. //
  122. // $is_buy_cardactivation = Db::table('wa_payorder')
  123. // ->where('user_id', $request->user_data['id'])
  124. // ->where('is_pay', 2)
  125. // ->where('goods_type', 15)
  126. // ->exists();
  127. //
  128. // $is_buy_enable = Db::table('wa_payorder')
  129. // ->where('user_id', $request->user_data['id'])
  130. // ->where('is_pay', 2)
  131. // ->where('goods_type', 16)
  132. // ->exists();
  133. //
  134. // $is_buy_equanqdj = Db::table('wa_payorder')
  135. // ->where('user_id', $request->user_data['id'])
  136. // ->where('is_pay', 2)
  137. // ->where('goods_type', 17)
  138. // ->exists();
  139. //
  140. // $is_buy_jihuosz = Db::table('wa_payorder')
  141. // ->where('user_id', $request->user_data['id'])
  142. // ->where('is_pay', 2)
  143. // ->where('goods_type', 18)
  144. // ->exists();
  145. //
  146. // $is_buy_jkuaijiezf = Db::table('wa_payorder')
  147. // ->where('user_id', $request->user_data['id'])
  148. // ->where('is_pay', 2)
  149. // ->where('goods_type', 19)
  150. // ->exists();
  151. //
  152. // $is_buy_shoufukuan = Db::table('wa_payorder')
  153. // ->where('user_id', $request->user_data['id'])
  154. // ->where('is_pay', 2)
  155. // ->where('goods_type', 20)
  156. // ->exists();
  157. $is_buy_vipshengji = Db::table('wa_payorder')
  158. ->where('user_id', $request->user_data['id'])
  159. ->where('is_pay', 2)
  160. ->where('goods_type', 21)
  161. ->exists();
  162. $is_buy_tisxyhh = Db::table('wa_payorder')
  163. ->where('user_id', $request->user_data['id'])
  164. ->where('is_pay', 2)
  165. ->where('goods_type', 22)
  166. ->exists();
  167. $is_buy_jiashubao = Db::table('wa_payorder')
  168. ->where('user_id', $request->user_data['id'])
  169. ->where('is_pay', 2)
  170. ->where('goods_type', 23)
  171. ->exists();
  172. $is_buy_xianshangzhif = Db::table('wa_payorder')
  173. ->where('user_id', $request->user_data['id'])
  174. ->where('is_pay', 2)
  175. ->where('goods_type', 25)
  176. ->exists();
  177. $is_buy_fangfushenj = Db::table('wa_payorder')
  178. ->where('user_id', $request->user_data['id'])
  179. ->where('is_pay', 2)
  180. ->where('goods_type', 26)
  181. ->exists();
  182. $is_buy_ckdengji = Db::table('wa_payorder')
  183. ->where('user_id', $request->user_data['id'])
  184. ->where('is_pay', 2)
  185. ->where('goods_type', 27)
  186. ->exists();
  187. $is_buy_ckyanzheng = Db::table('wa_payorder')
  188. ->where('user_id', $request->user_data['id'])
  189. ->where('is_pay', 2)
  190. ->where('goods_type', 28)
  191. ->exists();
  192. $is_buy_zhuanzshenq = Db::table('wa_payorder')
  193. ->where('user_id', $request->user_data['id'])
  194. ->where('is_pay', 2)
  195. ->where('goods_type', 29)
  196. ->exists();
  197. $buy_sign['has'] = 1;
  198. $buy_sign['goods_data'] = [];
  199. $wa_user_social_cark = Db::table('wa_user_social_cark')
  200. ->where('user_id', $request->user_data['id'])
  201. ->first();
  202. if (!empty($wa_user_social_cark->goods_id)) {
  203. $buy_sign['has'] = 2;
  204. $relevance_goods = Db::table('wa_goods')
  205. ->where('type', 4)
  206. ->where('relevance_goods_id', $wa_user_social_cark->goods_id)
  207. ->first();
  208. if (!empty($relevance_goods)) {
  209. $is_buy_sign = Db::table('wa_payorder')
  210. ->where('user_id', $request->user_data['id'])
  211. ->where('is_pay', 2)
  212. ->where('goods_id', $relevance_goods->id)
  213. ->where('goods_type', 4)
  214. ->exists();
  215. if (empty($is_buy_sign) && !empty($wa_user_social_cark->goods_id)) {
  216. $buy_sign['goods_data'] = $relevance_goods;
  217. } elseif (!empty($is_buy_sign)) {
  218. $buy_sign['has'] = 3;
  219. }
  220. }
  221. $binding_mobile = $wa_user_social_cark->binding_mobile;
  222. } else {
  223. $binding_mobile = '';
  224. }
  225. if ($is_buy_activate) {
  226. if (!empty(Redis::get('879' . $request->user_data['id']))) {
  227. $dynamic_pass = Redis::get('879' . $request->user_data['id']);
  228. } else {
  229. $conter = mt_rand(100000, 999999);
  230. Redis::setEx('879' . $request->user_data['id'], 600, $conter);
  231. $dynamic_pass = $conter;
  232. }
  233. } else {
  234. $dynamic_pass = '';
  235. }
  236. $arr = [
  237. 'img' => !empty($request->user_data['img']) ? imageToBase64($request->user_data['img']) : '',
  238. 'uuid' => $request->user_data['uuid'],
  239. 'mobile' => $request->user_data['mobile'],
  240. 'name' => $request->user_data['name'],
  241. 'is_autonym' => $request->user_data['is_autonym'],
  242. 'is_num' => $request->user_data['is_num'],
  243. 'money' => $request->user_data['money'],
  244. 'money_one' => $request->user_data['money_one'],
  245. 'money_two' => $request->user_data['money_two'],
  246. 'money_four' => $request->user_data['money_four'],
  247. 'money_six' => $request->user_data['money_six'],
  248. 'card_code' => $request->user_data['card_code'],
  249. 'signature_time' => $request->user_data['signature_time'],
  250. 'vip_name' => $request->user_data['vip_name'],
  251. 'card_number' => $request->user_data['card_number'],
  252. 'front_ima' => imageToBase64($request->user_data['front_ima']),
  253. 'reverse_ima' => imageToBase64($request->user_data['reverse_ima']),
  254. 'vip_img' => imageToBase64($request->user_data['vip_img']),
  255. // 'day_is_sign' => $day_is_sign ? true : false,
  256. 'is_buy_card' => $is_buy_card ? true : false,
  257. // 'is_buy_binding' => $is_buy_binding ? true : false,
  258. // 'is_buy_kaitong' => $is_buy_kaitong ? true : false,
  259. // 'is_buy_binding_mobile' => $is_buy_binding_mobile ? true : false,
  260. // 'is_buy_activate' => $is_buy_activate ? true : false,
  261. // 'is_buy_double' => $is_buy_double ? true : false,
  262. // 'is_buy_fast' => $is_buy_fast ? true : false,
  263. // 'is_buy_stampduty' => $is_buy_stampduty ? true : false,
  264. // 'is_buy_packaging' => $is_buy_packaging ? true : false,
  265. // 'is_buy_whitelist' => $is_buy_whitelist ? true : false,
  266. // 'is_buy_voucher' => $is_buy_voucher ? true : false,
  267. // 'is_buy_cardactivation' => $is_buy_cardactivation ? true : false,
  268. // 'is_buy_enable' => $is_buy_enable ? true : false,
  269. // 'is_buy_equanqdj' => $is_buy_equanqdj ? true : false,
  270. // 'is_buy_jihuosz' => $is_buy_jihuosz ? true : false,
  271. // 'is_buy_jkuaijiezf' => $is_buy_jkuaijiezf ? true : false,
  272. // 'is_buy_shoufukuan' => $is_buy_shoufukuan ? true : false,
  273. 'day_is_sign' => true,
  274. 'is_buy_binding' => true,
  275. 'is_buy_kaitong' => true,
  276. 'is_buy_binding_mobile' => true,
  277. 'is_buy_activate' => true,
  278. 'is_buy_double' => true,
  279. 'is_buy_fast' => true,
  280. 'is_buy_stampduty' => true,
  281. 'is_buy_packaging' => true,
  282. 'is_buy_whitelist' => true,
  283. 'is_buy_voucher' => true,
  284. 'is_buy_cardactivation' => true,
  285. 'is_buy_enable' => true,
  286. 'is_buy_equanqdj' => true,
  287. 'is_buy_jihuosz' => true,
  288. 'is_buy_jkuaijiezf' => true,
  289. 'is_buy_shoufukuan' => true,
  290. 'is_buy_vipshengji' => $is_buy_vipshengji ? true : false,
  291. 'is_buy_tisxyhh' => $is_buy_tisxyhh ? true : false,
  292. 'is_buy_jiashubao' => $is_buy_jiashubao ? true : false,
  293. 'is_buy_xianshangzhif' => $is_buy_xianshangzhif ? true : false,
  294. 'is_buy_fangfushenj' => $is_buy_fangfushenj ? true : false,
  295. 'is_buy_ckdengji' => $is_buy_ckdengji ? true : false,
  296. 'is_buy_ckyanzheng' => $is_buy_ckyanzheng ? true : false,
  297. 'is_buy_zhuanzshenq' => $is_buy_zhuanzshenq ? true : false,
  298. 'is_buy_sign' => $buy_sign,
  299. 'total_sign' => $total_sign,
  300. 'dynamic_pass' => $dynamic_pass,
  301. 'binding_mobile' => $binding_mobile,
  302. 'user_identity' => UserIdentityBusiness::data(['uid' => $request->user_data['id']]),
  303. 'bank_card' => BankCardBusiness::data(['uid' => $request->user_data['id']]),
  304. ];
  305. return success($arr);
  306. }
  307. #[Apidoc\Title("签到列表")]
  308. #[Apidoc\Url("api/user/signlist.html")]
  309. #[Apidoc\Method("POST")]
  310. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  311. #[Apidoc\Returned(name: "money", type: "string", desc: '签到奖励', default: '')]
  312. #[Apidoc\Returned(name: "day", type: "string", desc: '天数', default: '')]
  313. #[Apidoc\Returned(name: "has", type: "string", desc: '是否签到', default: 'true 已签到 false 未签到')]
  314. #[Apidoc\Returned(name: "signcount", type: "string", desc: '累计签到', default: 'true 已签到 false 未签到')]
  315. #[Apidoc\Returned(name: "continuity", type: "string", desc: '连续签到', default: 'true 已签到 false 未签到')]
  316. #[Apidoc\Returned(name: "is_sign", type: "string", desc: '今日是否签到', default: 'true 已签到 false 未签到')]
  317. public function signlist(Request $request)
  318. {
  319. $system = Db::table('wa_system')->first();
  320. $arr[] = date('Y-m-d', strtotime('monday this week'));
  321. $arr[] = date('Y-m-d', strtotime('monday this week +1 day'));
  322. $arr[] = date('Y-m-d', strtotime('monday this week +2 day'));
  323. $arr[] = date('Y-m-d', strtotime('monday this week +3 day'));
  324. $arr[] = date('Y-m-d', strtotime('monday this week +4 day'));
  325. $arr[] = date('Y-m-d', strtotime('monday this week +5 day'));
  326. $arr[] = date('Y-m-d', strtotime('sunday this week'));
  327. $array = [];
  328. $money = 0;
  329. foreach ($arr as $k => $v) {
  330. $money = bcadd($money, 1000);
  331. $day = date('d', strtotime($v));
  332. $array[] = [
  333. 'money' => $money,
  334. 'day' => date('d', strtotime($v)),
  335. 'has' => Db::table('wa_stream')
  336. ->where('user_id', $request->user_data['id'])
  337. ->where('type', streamType2)
  338. ->whereBetween('add_time', [strtotime($v . ' 00:00:00'), strtotime($v . ' 23:59:59')])->exists()
  339. ];
  340. if ($money == 5000) {
  341. $money = 0;
  342. }
  343. }
  344. $signcount = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count();
  345. $is_sign = Db::table('wa_stream')
  346. ->where('user_id', $request->user_data['id'])
  347. ->where('type', streamType2)
  348. ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
  349. ->exists();
  350. return success([
  351. 'list' => $array,
  352. 'signcount' => $signcount,
  353. 'continuity' => $request->user_data['continuity'],
  354. 'is_sign' => $is_sign,
  355. ]);
  356. // $param = $request->param_data;
  357. // $param['user_data'] = $request->user_data;
  358. // $month_num = date('t');
  359. // $res = [];
  360. // //查询当前用户当月签到记录
  361. // $this_month_sign = Db::table('wa_stream')
  362. // ->where('type', streamType2)
  363. // ->where('user_id', $param['user_data']['id'])
  364. // ->whereRaw("DATE_FORMAT(created_at,'%Y-%m')=?", date('Y-m'))
  365. // ->get();
  366. // $money = 0;
  367. // for ($i = 1; $i <= $month_num; $i++) {
  368. // $date = $i > 9 ? date('Y-m-') . $i : date('Y-m-') . '0' . $i;
  369. // $money = bcadd($money, 1000);
  370. // $res[] = [
  371. // 'day' => $i,
  372. // 'has' => Db::table('wa_stream')
  373. // ->where('user_id', $request->user_data['id'])
  374. // ->where('type', streamType2)
  375. // ->whereBetween('add_time', [strtotime($date . ' 00:00:00'), strtotime($date . ' 23:59:59')])
  376. // ->exists(),
  377. // 'money' => $money,
  378. // ];
  379. // if ($i % 5 == 0) {
  380. // $money = 0;
  381. // }
  382. // }
  383. // $signcount = Db::table('wa_stream')
  384. // ->where('type', streamType2)
  385. // ->where('user_id', $param['user_data']['id'])
  386. // ->count();
  387. // $is_sign = Db::table('wa_stream')
  388. // ->where('user_id', $param['user_data']['id'])
  389. // ->where('type', streamType2)
  390. // ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
  391. // ->exists();
  392. // return success([
  393. // 'list' => $res,
  394. // 'signcount' => $signcount,
  395. // 'continuity' => $param['user_data']['continuity'],
  396. // 'is_sign' => $is_sign,
  397. // ]);
  398. }
  399. #[Apidoc\Title("签到")]
  400. #[Apidoc\Url("api/user/sign.html")]
  401. #[Apidoc\Method("POST")]
  402. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  403. #[Apidoc\Returned(name: "money", type: "string", desc: '奖励金额', default: '888')]
  404. #[Apidoc\Returned(name: "signcount", type: "string", desc: '累计签到天数', default: '888')]
  405. public function sign(Request $request)
  406. {
  407. Db::beginTransaction();
  408. try {
  409. $param = $request->param_data;
  410. $zuotian = Db::table('wa_stream')
  411. ->where('user_id', $request->user_data['id'])
  412. ->where('type', streamType2)
  413. ->whereBetween('add_time', [bcsub(strtotime(date('Y-m-d') . ' 00:00:00'), 86400), bcadd(strtotime(date('Y-m-d') . ' 23:59:59'), 86400)])
  414. ->exists();
  415. if ($zuotian) {
  416. $continuity = bcadd($request->user_data['continuity'], 1);
  417. } else {
  418. $continuity = 1;
  419. }
  420. $has = Db::table('wa_stream')
  421. ->where('user_id', $request->user_data['id'])
  422. ->where('type', streamType2)
  423. ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
  424. ->exists();
  425. if ($has) {
  426. throw new \Exception('今日已签到,请不要重复签到');
  427. }
  428. $arr[] = date('Y-m-d', strtotime('monday this week'));
  429. $arr[] = date('Y-m-d', strtotime('monday this week +1 day'));
  430. $arr[] = date('Y-m-d', strtotime('monday this week +2 day'));
  431. $arr[] = date('Y-m-d', strtotime('monday this week +3 day'));
  432. $arr[] = date('Y-m-d', strtotime('monday this week +4 day'));
  433. $arr[] = date('Y-m-d', strtotime('monday this week +5 day'));
  434. $arr[] = date('Y-m-d', strtotime('sunday this week'));
  435. $day_money = 0;
  436. foreach ($arr as $k => $v) {
  437. $day_money = bcadd($day_money, 1000);
  438. $day = date('d', strtotime($v));
  439. if (date('d', time()) == $day) {
  440. $money = $day_money;
  441. }
  442. if ($day_money == 5000) {
  443. $day_money = 0;
  444. }
  445. }
  446. // $system = Db::table('wa_system')->first();
  447. // if (!empty($system->sign_award)) {
  448. // StreamBusiness::addStream($request->user_data['id'], $system->sign_award, streamType2, moldType2, moldTypefild2);
  449. // }
  450. StreamBusiness::addStream($request->user_data['id'], $money, streamType2, moldType2, moldTypefild2);
  451. Db::table('wa_users')->where(['id' => $request->user_data['id']])->update(['continuity' => $continuity]);
  452. $signcount = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count();
  453. } catch (\Throwable $exception) {
  454. Db::rollBack();
  455. return error($exception->getMessage());
  456. }
  457. Db::commit();
  458. return success([
  459. 'money' => $day_money,
  460. 'signcount' => $signcount
  461. ], '签到成功');
  462. }
  463. #[Apidoc\Title("我的团队头数据")]
  464. #[Apidoc\Url("api/user/team.html")]
  465. #[Apidoc\Method("POST")]
  466. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  467. #[Apidoc\Returned(name: "num", type: "int", require: true, desc: '团队总人数', default: '1')]
  468. #[Apidoc\Returned(name: "earnings", type: "int", require: true, desc: '总拥金收益', default: '0')]
  469. #[Apidoc\Returned(name: "dayearnings", type: "int", require: true, desc: '今日收益', default: '0')]
  470. #[Apidoc\Returned(name: "one", type: "int", require: true, desc: '一级人数', default: '0')]
  471. #[Apidoc\Returned(name: "two", type: "int", require: true, desc: '二级人数', default: '0')]
  472. #[Apidoc\Returned(name: "three", type: "int", require: true, desc: '三级人数', default: '0')]
  473. #[Apidoc\Returned(name: "rebate", type: "int", require: true, desc: '一级返佣', default: '0')]
  474. #[Apidoc\Returned(name: "rebate_one", type: "int", require: true, desc: '二级返佣', default: '0')]
  475. #[Apidoc\Returned(name: "rebate_two", type: "int", require: true, desc: '三级返佣', default: '0')]
  476. public function team(Request $request)
  477. {
  478. $param = $request->user_data;
  479. $data = Db::table('wa_users')->where(function ($query) use ($param) {
  480. $query->orWhere('pid', $param['id']);
  481. $query->orWhere('ppid', $param['id']);
  482. $query->orWhere('toppid', $param['id']);
  483. });
  484. $system = Db::table('wa_system')->first();
  485. /** @var $num 团队总人数 */
  486. $num = (clone $data)->count();
  487. // $stream = Db::table('wa_stream')
  488. // ->where('mold', moldType1)
  489. // ->where('type', streamType14)
  490. // ->where('user_id', $request->user_data['id']);
  491. return success([
  492. 'num' => $num,
  493. // 'earnings' => (clone $stream)->sum('money'),
  494. // 'dayearnings' => (clone $stream)
  495. // ->where('add_time', '>=', strtotime(date('Y-m-d')))
  496. // ->where('add_time', '<=', strtotime(date('Y-m-d 23:59:59')))
  497. // ->sum('money'),
  498. 'earnings' => '0.00',
  499. 'dayearnings' => '0.00',
  500. 'one' => Db::table('wa_users')->where('pid', $param['id'])->count(),
  501. 'two' => Db::table('wa_users')->where('ppid', $param['id'])->count(),
  502. 'three' => Db::table('wa_users')->where('toppid', $param['id'])->count(),
  503. 'rebate' => $system->rebate,
  504. 'rebate_one' => $system->rebate_one,
  505. 'rebate_two' => $system->rebate_two,
  506. ]);
  507. }
  508. #[Apidoc\Title("我的团队列表数据")]
  509. #[Apidoc\Url("api/user/team_list.html")]
  510. #[Apidoc\Method("POST")]
  511. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  512. #[Apidoc\Param("page", type: "int", require: true, desc: "页面", mock: 1)]
  513. #[Apidoc\Param("limit", type: "int", require: true, desc: "输出条数", mock: 10)]
  514. #[Apidoc\Param("grade", type: "int", require: true, desc: "等级 1一级 2二级 3三级", mock: 1)]
  515. #[Apidoc\Returned(name: "name", type: "string", require: true, desc: '名称', default: '未实名')]
  516. #[Apidoc\Returned(name: "mobile", type: "string", require: true, desc: '电话', default: '158****0002')]
  517. #[Apidoc\Returned(name: "join_time", type: "string", require: true, desc: '注册时间', default: '2024-07-08 01:20:47')]
  518. #[Apidoc\Returned(name: "invest_money", type: "string", require: true, desc: '消费金额', default: '0.00')]
  519. public function teamList(Request $request)
  520. {
  521. try {
  522. $param = $request->param_data;
  523. $param['user_data'] = $request->user_data;
  524. Validator::input($param, [
  525. 'page' => Validator::notEmpty()->intType()->setName('页面'),
  526. 'limit' => Validator::notEmpty()->intType()->setName('输出条数'),
  527. 'grade' => Validator::notEmpty()->intType()->setName('等级'),
  528. ]);
  529. $data = Db::table('wa_users')->where(function ($query) use ($param) {
  530. if (Arr::get($param, 'grade')) {
  531. if ($param['grade'] == 1) {
  532. $query->where('pid', $param['user_data']['id']);
  533. } elseif ($param['grade'] == 2) {
  534. $query->where('ppid', $param['user_data']['id']);
  535. } elseif ($param['grade'] == 3) {
  536. $query->where('toppid', $param['user_data']['id']);
  537. }
  538. } else {
  539. $query->where('pid', $param['user_data']['id']);
  540. }
  541. })->select(['name', 'mobile', 'join_time', 'invest_money'])
  542. ->orderByDesc('id')
  543. ->paginate(Arr::get($param, 'limit', 10), ['*'], 'page', Arr::get($param, 'page'))
  544. ->toArray();
  545. foreach ($data['data'] as $k => $v) {
  546. $data['data'][$k]->mobile = substr_replace($v->mobile, '****', 3, 4);
  547. }
  548. } catch (\Throwable $exception) {
  549. return new Exception($exception->getMessage());
  550. }
  551. return success($data['data'], '成功', 200, $data['total']);
  552. }
  553. // #[Apidoc\Title("我的投资")]
  554. // #[Apidoc\Url("api/user/mygoods")]
  555. // #[Apidoc\Method("POST")]
  556. // #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  557. // #[Apidoc\Param("page", type: "int", require: true, desc: "页面", mock: 1)]
  558. // #[Apidoc\Param("limit", type: "int", require: true, desc: "输出条数", mock: 10)]
  559. // #[Apidoc\Returned(name: "id", type: "string", require: true, desc: '购买记录ID', default: '485')]
  560. // #[Apidoc\Returned(name: "goods_id", type: "string", require: true, desc: '产品ID', default: '5')]
  561. // #[Apidoc\Returned(name: "img", type: "string", require: true, desc: '封面图', default: '')]
  562. // #[Apidoc\Returned(name: "name", type: "string", require: true, desc: '产品名称', default: '')]
  563. // #[Apidoc\Returned(name: "type", type: "string", require: true, desc: '产品类型 1 慈善 2助力', default: '')]
  564. // #[Apidoc\Returned(name: "price", type: "string", require: true, desc: '价格', default: '')]
  565. // #[Apidoc\Returned(name: "pay_price", type: "string", require: true, desc: '通道支付金额', default: '')]
  566. // #[Apidoc\Returned(name: "period", type: "string", require: true, desc: '周期', default: '')]
  567. // #[Apidoc\Returned(name: "bl", type: "string", require: true, desc: '比例', default: '')]
  568. // #[Apidoc\Returned(name: "bonus", type: "string", require: true, desc: '每日分红金额', default: '')]
  569. // #[Apidoc\Returned(name: "predict", type: "string", require: true, desc: '预计收益', default: '')]
  570. // #[Apidoc\Returned(name: "created_at", type: "string", require: true, desc: '购买时间', default: '')]
  571. // #[Apidoc\Returned(name: "expiretime", type: "string", require: true, desc: '到期时间戳', default: '')]
  572. // #[Apidoc\Returned(name: "is_grant", type: "string", require: true, desc: '是否退本 1未退本 2已退本', default: '')]
  573. // public function mygoods(Request $request)
  574. // {
  575. // try {
  576. // $param = Arr::only($request->all(), ['page', 'limit', 'grade']);
  577. // $param['user_data'] = $request->user_data;
  578. // Validator::input($param, [
  579. // 'page' => Validator::notEmpty()->intType()->setName('页码'),
  580. // 'limit' => Validator::notEmpty()->intType()->setName('输出条数'),
  581. // ]);
  582. // $data = Db::table('wa_my_goods')
  583. // ->join('wa_goods', 'wa_goods.id', '=', 'wa_my_goods.goods_id')
  584. // ->where('wa_my_goods.user_id', $param['user_data']['id'])
  585. // ->select(['wa_my_goods.id', 'wa_my_goods.goods_id', 'wa_goods.img', 'wa_goods.type', 'wa_goods.pay_price', 'wa_goods.price', 'wa_goods.name', 'wa_goods.period', 'wa_goods.bl', 'wa_goods.bonus', 'wa_goods.predict', 'wa_goods.bonus', 'wa_my_goods.created_at', 'wa_my_goods.expiretime', 'wa_my_goods.is_grant'])
  586. // ->orderByDesc('wa_my_goods.id')
  587. // ->paginate(Arr::get($param, 'limit', 10))
  588. // ->toArray();
  589. // foreach ($data['data'] as $k => $v) {
  590. // $data['data'][$k]->img = getenv('IMG') . $v->img;
  591. // }
  592. // } catch (\Throwable $exception) {
  593. // return error($exception->getMessage());
  594. // }
  595. //
  596. // return success($data['data'], '成功', 200, $data['total']);
  597. // }
  598. #[Apidoc\Title("退出登录")]
  599. #[Apidoc\Url("api/user/quit.html")]
  600. #[Apidoc\Method("POST")]
  601. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  602. public function quit(Request $request)
  603. {
  604. Redis::del($request->user_data['id']);
  605. return success([], '已退出登录!');
  606. }
  607. #[Apidoc\Title("修改密码")]
  608. #[Apidoc\Url("api/user/save.html")]
  609. #[Apidoc\Method("POST")]
  610. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  611. #[Apidoc\Param("type", type: "int", require: true, desc: "类型 1修改名称 2 修改密码 ", mock: 1)]
  612. #[Apidoc\Param("name", type: "string", require: true, desc: "名称", mock: 1)]
  613. #[Apidoc\Param("old_password", type: "string", require: true, desc: "旧密码", mock: 1)]
  614. #[Apidoc\Param("password", type: "string", require: true, desc: "新密码", mock: 10)]
  615. public function save(Request $request)
  616. {
  617. Db::beginTransaction();
  618. try {
  619. $param = $request->param_data;
  620. Validator::input($param, [
  621. 'type' => Validator::notEmpty()->intType()->setName('操作类型'),
  622. ]);
  623. if (Arr::get($param, 'type') == 1) {
  624. Validator::input($param, [
  625. 'name' => Validator::notEmpty()->setName('操作类型'),
  626. ]);
  627. $arr['name'] = $param['name'];
  628. } elseif (Arr::get($param, 'type') == 2) {
  629. Validator::input($param, [
  630. 'old_password' => Validator::notEmpty()->setName('旧密码'),
  631. 'password' => Validator::notEmpty()->setName('新密码'),
  632. ]);
  633. if ($request->user_data['password'] != md5($param['old_password'])) {
  634. throw new \Exception('密码验证失败');
  635. }
  636. $arr['password'] = md5($param['password']);
  637. }
  638. if (empty($arr)) {
  639. throw new \Exception('非法操作');
  640. }
  641. Db::table('wa_users')->where('id', $request->user_data['id'])->update($arr);
  642. } catch (\Throwable $exception) {
  643. Db::rollBack();
  644. return error($exception->getMessage());
  645. }
  646. Db::commit();
  647. return success([], '修改成功');
  648. }
  649. }