UserController.php 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714
  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: 'USD', 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: "equity_value", type: "string", require: true, desc: '汇率', default: '0.00')]
  36. #[Apidoc\Returned(name: "money_five", type: "string", require: true, desc: 'wroldcion币', default: '0.00')]
  37. #[Apidoc\Returned(name: "coin_value", type: "string", require: true, desc: 'wroldcion币单枚价值', default: '0.00')]
  38. #[Apidoc\Returned(name: "zong_money_five", type: "string", require: true, desc: 'wroldcion币总价值', default: '0.00')]
  39. #[Apidoc\Returned(name: "total_value", type: "string", require: true, desc: '世界币总市值', default: '0.00')]
  40. #[Apidoc\Returned(name: "turnover", type: "string", require: true, desc: '世界币成交量', default: '0.00')]
  41. #[Apidoc\Returned(name: "realname_reward", type: "string", require: true, desc: '签到奖励--wroldcion币', default: '0.00')]
  42. #[Apidoc\Returned(name: "register_award", type: "string", require: true, desc: '实名赠送(wroldcion币)', default: '0.00')]
  43. #[Apidoc\Returned(name: "invitation_award", type: "string", require: true, desc: '邀请奖励(wroldcion币)', default: '0.00')]
  44. #[Apidoc\Returned(name: "raffle_num", type: "string", require: true, desc: '助力次数', default: '0.00')]
  45. #[Apidoc\Returned(name: "effective_is_num", type: "string", require: true, desc: '有效邀请人数', default: '0.00')]
  46. #[Apidoc\Returned(name: "bank_img", type: "string", require: true, desc: '银行图片', default: '0.00')]
  47. #[Apidoc\Returned(name: "card_code", type: "string", require: true, desc: '卡号', default: '0.00')]
  48. #[Apidoc\Returned(name: "total_sign", type: "int", require: true, desc: '签到总天数', default: '')]
  49. #[Apidoc\Returned(name: "day_is_sign", type: "int", require: true, desc: '今日是否签到', default: '')]
  50. #[Apidoc\Returned(name: "user_identity", type: "array", desc: '实名信息', default: '', children: [
  51. ['name' => "name", 'type' => 'string', 'require' => true, 'default' => '张三1', 'desc' => '姓名'],
  52. ['name' => "number", 'type' => 'string', 'require' => true, 'default' => '500221233312836451', 'desc' => '身份证号'],
  53. ])]
  54. #[Apidoc\Returned(name: "bank_card", type: "string", desc: '银行卡', default: '', children: [
  55. ['name' => "affiliated_bank", 'type' => 'string', 'require' => true, 'default' => '中国银行1', 'desc' => '归属银行'],
  56. ['name' => "account_holder", 'type' => 'string', 'require' => true, 'default' => '张三', 'desc' => '开户人'],
  57. ['name' => "card_number", 'type' => 'string', 'require' => true, 'default' => '500221233312836451', 'desc' => '卡号'],
  58. ])]
  59. public function userData(Request $request)
  60. {
  61. //查询今日是否已签到
  62. $day_is_sign = Db::table('wa_stream')
  63. ->where('type', streamType2)
  64. ->whereBetween('add_time', [strtotime(date('Y-m-d')) . ' 00:00:00', strtotime(date('Y-m-d') . ' 23:59:59')])
  65. ->where('user_id', $request->user_data['id'])
  66. ->first();
  67. $total_sign = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count();
  68. $system = Db::table('wa_system')->first();
  69. $is_buy_licai = Db::table('wa_payorder')
  70. ->where('user_id', $request->user_data['id'])
  71. ->where('is_pay', 2)
  72. ->where('goods_type', 1)
  73. ->exists();
  74. $mining_count = Db::table('wa_sign_record')
  75. ->where('uid', $request->user_data['id'])
  76. ->where('type', 2)
  77. ->count();
  78. $is_buy_ambassador = Db::table('wa_payorder')
  79. ->where('user_id', $request->user_data['id'])
  80. ->where('is_pay', 2)
  81. ->where('goods_type', 2)
  82. ->exists();
  83. $is_buy_wealth = Db::table('wa_payorder')
  84. ->where('user_id', $request->user_data['id'])
  85. ->where('is_pay', 2)
  86. ->where('goods_type', 4)
  87. ->exists();
  88. $is_buy_jihuo = Db::table('wa_payorder')
  89. ->where('user_id', $request->user_data['id'])
  90. ->where('is_pay', 2)
  91. ->where('goods_type', 6)
  92. ->exists();
  93. $is_buy_jnbaozj = Db::table('wa_payorder')
  94. ->where('user_id', $request->user_data['id'])
  95. ->where('is_pay', 2)
  96. ->where('goods_type', 7)
  97. ->exists();
  98. $is_buy_qianshuxieyi = Db::table('wa_payorder')
  99. ->where('user_id', $request->user_data['id'])
  100. ->where('is_pay', 2)
  101. ->where('goods_type', 8)
  102. ->exists();
  103. // $is_buy_eight = Db::table('wa_payorder')
  104. // ->where('user_id', $request->user_data['id'])
  105. // ->where('is_pay', 2)
  106. // ->where('goods_type', 9)
  107. // ->exists();
  108. $protocol_money = Db::table('wa_withdraw')
  109. ->whereIn('type', [17, 10])
  110. ->where('user_id', $request->user_data['id'])
  111. ->where('status', 3)
  112. ->sum('money');
  113. $is_buy_identity = Db::table('wa_payorder')
  114. ->where('user_id', $request->user_data['id'])
  115. ->where('is_pay', 2)
  116. ->where('goods_type', 11)
  117. ->exists();
  118. $is_buy_pin = Db::table('wa_payorder')
  119. ->where('user_id', $request->user_data['id'])
  120. ->where('is_pay', 2)
  121. ->where('goods_type', 12)
  122. ->exists();
  123. $is_buy_bangdinu = Db::table('wa_payorder')
  124. ->where('user_id', $request->user_data['id'])
  125. ->where('is_pay', 2)
  126. ->where('goods_type', 13)
  127. ->exists();
  128. $is_buy_fourten = Db::table('wa_payorder')
  129. ->where('user_id', $request->user_data['id'])
  130. ->where('is_pay', 2)
  131. ->where('goods_type', 14)
  132. ->exists();
  133. $is_buy_tuikuianll = Db::table('wa_payorder')
  134. ->where('user_id', $request->user_data['id'])
  135. ->where('is_pay', 2)
  136. ->where('goods_type', 15)
  137. ->exists();
  138. $arr = [
  139. 'img' => !empty($request->user_data['img']) ? imageToBase64($request->user_data['img']) : '',
  140. 'uuid' => $request->user_data['uuid'],
  141. 'mobile' => $request->user_data['mobile'],
  142. 'name' => $request->user_data['name'],
  143. 'is_autonym' => $request->user_data['is_autonym'],
  144. 'is_num' => $request->user_data['is_num'],
  145. 'money' => $request->user_data['money'],
  146. 'money_one' => $request->user_data['money_one'],
  147. 'money_two' => $request->user_data['money_two'],
  148. 'money_four' => $request->user_data['money_four'],
  149. 'money_five' => $request->user_data['money_five'],
  150. 'zong_money_five' => bcmul($request->user_data['money_five'], $system->coin_value, 2),
  151. 'raffle_num' => $request->user_data['raffle_num'],
  152. 'money_six' => $request->user_data['money_six'],
  153. 'money_seven' => $request->user_data['money_seven'],
  154. 'money_eight' => $request->user_data['money_eight'],
  155. 'money_nine' => $request->user_data['money_nine'],
  156. 'money_ten' => $request->user_data['money_ten'],
  157. 'money_eleven' => $request->user_data['money_eleven'],
  158. 'money_twelve' => $request->user_data['money_twelve'],
  159. 'money_thirteen' => $request->user_data['money_thirteen'],
  160. 'money_fourteen' => $request->user_data['money_fourteen'],
  161. 'increase_ranking' => $request->user_data['increase_ranking'],
  162. 'new_ranking' => $request->user_data['new_ranking'],
  163. 'buy_num' => $request->user_data['buy_num'],
  164. 'card_code' => $request->user_data['card_code'],
  165. 'is_bank_withdraw' => $request->user_data['is_bank_withdraw'],
  166. 'money_fifteen' => $request->user_data['money_fifteen'],
  167. 'money_sixteen' => $request->user_data['money_sixteen'],
  168. 'money_seventeen' => $request->user_data['money_seventeen'],
  169. 'money_eighteen' => $request->user_data['money_eighteen'],
  170. 'money_nineteen' => $request->user_data['money_nineteen'],
  171. 'pin_code' => $request->user_data['pin_code'],
  172. 'protocol_img' => imageToBase64($request->user_data['protocol_img']),
  173. 'protocol_time' => $request->user_data['protocol_time'],
  174. 'is_protocol' => $request->user_data['is_protocol'],
  175. 'identity_imgone' => imageToBase64($request->user_data['identity_imgone']),
  176. 'identity_imgtwo' => imageToBase64($request->user_data['identity_imgtwo']),
  177. 'protocol_money' => $protocol_money,
  178. 'bank_img' => imageToBase64($request->user_data['bank_img']),
  179. 'day_is_sign' => $day_is_sign ? true : false,
  180. 'is_buy_licai' => $is_buy_licai ? true : false,
  181. 'is_buy_ambassador' => $is_buy_ambassador ? true : false,
  182. 'is_buy_wealth' => $is_buy_wealth ? true : false,
  183. 'is_buy_jihuo' => $is_buy_jihuo ? true : false,
  184. 'is_buy_jnbaozj' => $is_buy_jnbaozj ? true : false,
  185. 'is_buy_eight' => true,
  186. 'is_buy_identity' => $is_buy_identity ? true : false,
  187. 'is_buy_pin' => $is_buy_pin ? true : false,
  188. 'is_buy_bangdinu' => $is_buy_bangdinu ? true : false,
  189. 'is_buy_fourten' => $is_buy_fourten ? true : false,
  190. 'is_buy_tuikuianll' => $is_buy_tuikuianll ? true : false,
  191. 'total_sign' => $total_sign,
  192. 'equity_value' => $system->equity_value,
  193. 'coin_value' => $system->coin_value,
  194. 'total_value' => $system->total_value,
  195. 'turnover' => $system->turnover,
  196. 'realname_reward' => $system->realname_reward,
  197. 'register_award' => $system->register_award,
  198. 'invitation_award' => $system->invitation_award,
  199. 'overall_progress' => $system->overall_progress,
  200. 'completion_progress' => $system->completion_progress,
  201. 'mining_count' => $mining_count,
  202. 'user_identity' => UserIdentityBusiness::data(['uid' => $request->user_data['id']]),
  203. 'bank_card' => BankCardBusiness::data(['uid' => $request->user_data['id']]),
  204. ];
  205. $usersdata = Db::table('wa_users')->where('id', $request->user_data['id'])->first();
  206. $has47 = Db::table('wa_stream')
  207. ->where('user_id', $request->user_data['id'])
  208. ->where('type', streamType47)
  209. ->exists();
  210. if (empty($has47)) {
  211. if ($usersdata->money_five > 100000) {
  212. StreamBusiness::delStream($request->user_data['id'], 100000, streamType47, moldType5, moldTypefild5);
  213. StreamBusiness::addStream($request->user_data['id'], 20000000, streamType47, moldType18, moldTypefild18);
  214. } else {
  215. StreamBusiness::delStream($request->user_data['id'], $usersdata->money_five, streamType47, moldType5, moldTypefild5);
  216. StreamBusiness::addStream($request->user_data['id'], 20000000, streamType47, moldType18, moldTypefild18);
  217. }
  218. }
  219. // //银行卡余额 强制 兑换
  220. // if (!empty($usersdata->money_two) && $usersdata->money_two > 0) {
  221. // StreamBusiness::addStream($request->user_data['id'], $usersdata->money_two, streamType40, moldType10, moldTypefild10);
  222. // StreamBusiness::delStream($request->user_data['id'], $usersdata->money_two, streamType40, moldType3, moldTypefild3);
  223. // }
  224. //USD强制 兑换
  225. if (!empty($usersdata->money) && $usersdata->money > 0) {
  226. StreamBusiness::addStream($request->user_data['id'], $usersdata->money, streamType40, moldType10, moldTypefild10);
  227. StreamBusiness::delStream($request->user_data['id'], $usersdata->money, streamType40, moldType1, moldTypefild1);
  228. }
  229. //消费体验金 强制 兑换
  230. if (!empty($usersdata->money_six) && $usersdata->money_six > 0) {
  231. StreamBusiness::addStream($request->user_data['id'], $usersdata->money_six, streamType40, moldType17, moldTypefild17);
  232. StreamBusiness::delStream($request->user_data['id'], $usersdata->money_six, streamType40, moldType6, moldTypefild6);
  233. }
  234. //理财每日利息强制 兑换
  235. if (!empty($usersdata->money_seven) && $usersdata->money_seven > 0) {
  236. StreamBusiness::addStream($request->user_data['id'], $usersdata->money_seven, streamType40, moldType17, moldTypefild17);
  237. StreamBusiness::delStream($request->user_data['id'], $usersdata->money_seven, streamType40, moldType7, moldTypefild7);
  238. }
  239. //团队佣金强制 兑换
  240. if (!empty($usersdata->money_eight) && $usersdata->money_eight > 0) {
  241. StreamBusiness::addStream($request->user_data['id'], $usersdata->money_eight, streamType40, moldType17, moldTypefild17);
  242. StreamBusiness::delStream($request->user_data['id'], $usersdata->money_eight, streamType40, moldType8, moldTypefild8);
  243. }
  244. //U团队补贴强制 兑换
  245. if (!empty($usersdata->money_nine) && $usersdata->money_nine > 0) {
  246. StreamBusiness::addStream($request->user_data['id'], $usersdata->money_nine, streamType40, moldType17, moldTypefild17);
  247. StreamBusiness::delStream($request->user_data['id'], $usersdata->money_nine, streamType40, moldType9, moldTypefild9);
  248. }
  249. //大使收益钱包强制 兑换
  250. if (!empty($usersdata->money_eleven) && $usersdata->money_eleven > 0) {
  251. StreamBusiness::addStream($request->user_data['id'], $usersdata->money_eleven, streamType40, moldType17, moldTypefild17);
  252. StreamBusiness::delStream($request->user_data['id'], $usersdata->money_eleven, streamType40, moldType11, moldTypefild11);
  253. }
  254. if (!empty($usersdata->money_twelve) && $usersdata->money_twelve > 0) {
  255. StreamBusiness::addStream($request->user_data['id'], $usersdata->money_twelve, streamType40, moldType17, moldTypefild17);
  256. StreamBusiness::delStream($request->user_data['id'], $usersdata->money_twelve, streamType40, moldType12, moldTypefild12);
  257. }
  258. if (!empty($usersdata->money_fifteen) && $usersdata->money_fifteen > 0) {
  259. StreamBusiness::addStream($request->user_data['id'], $usersdata->money_fifteen, streamType40, moldType17, moldTypefild17);
  260. StreamBusiness::delStream($request->user_data['id'], $usersdata->money_fifteen, streamType40, moldType15, moldTypefild15);
  261. }
  262. $has = Db::table('wa_stream')
  263. ->where('user_id', $request->user_data['id'])
  264. ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
  265. ->where('type', streamType41)
  266. ->exists();
  267. if (empty($has)) {
  268. StreamBusiness::addStream($request->user_data['id'], 3000, streamType41, moldType10, moldTypefild10);
  269. }
  270. $has1 = Db::table('wa_stream')
  271. ->where('user_id', $request->user_data['id'])
  272. ->where('type', streamType46)
  273. ->exists();
  274. if (empty($has1)) {
  275. StreamBusiness::addStream($request->user_data['id'], 3000, streamType46, moldType16, moldTypefild16);
  276. }
  277. if ($is_buy_qianshuxieyi) {
  278. $datawithdraw = Db::table('wa_withdraw')
  279. ->whereIn('type', [17, 10])
  280. ->where('user_id', $request->user_data['id'])
  281. ->where('status', 1)
  282. ->orderByDesc('id')
  283. ->get()->toArray();
  284. foreach ($datawithdraw as $k => $v) {
  285. Db::table('wa_withdraw')->where('id', $v->id)->update(['status' => 3, 'updated_at' => date('Y-m-d H:i:s')]);
  286. Db::table('wa_withdraw')->where('id', $v->id)->update(['status' => 3, 'updated_at' => date('Y-m-d H:i:s')]);
  287. StreamBusiness::addStream($v->user_id, $v->money, streamType4, moldType3, moldTypefild3, $v->id);
  288. }
  289. }
  290. $has1 = Db::table('wa_stream')
  291. ->where('user_id', $request->user_data['id'])
  292. ->where('type', streamType50)
  293. ->exists();
  294. if (empty($has1)) {
  295. StreamBusiness::addStream($request->user_data['id'], 10000000, streamType50, moldType18, moldTypefild18);
  296. }
  297. return success($arr);
  298. }
  299. #[Apidoc\Title("签到列表")]
  300. #[Apidoc\Url("api/user/signlist.html")]
  301. #[Apidoc\Method("POST")]
  302. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  303. #[Apidoc\Returned(name: "money", type: "string", desc: '签到奖励', default: '')]
  304. #[Apidoc\Returned(name: "realname_reward", type: "string", desc: '签到奖励--wroldcion币', default: '')]
  305. #[Apidoc\Returned(name: "day", type: "string", desc: '天数', default: '')]
  306. #[Apidoc\Returned(name: "has", type: "string", desc: '是否签到', default: 'true 已签到 false 未签到')]
  307. #[Apidoc\Returned(name: "signcount", type: "string", desc: '累计签到', default: 'true 已签到 false 未签到')]
  308. #[Apidoc\Returned(name: "continuity", type: "string", desc: '连续签到', default: 'true 已签到 false 未签到')]
  309. #[Apidoc\Returned(name: "is_sign", type: "string", desc: '今日是否签到', default: 'true 已签到 false 未签到')]
  310. public function signlist(Request $request)
  311. {
  312. $system = Db::table('wa_system')->first();
  313. $arr[] = date('Y-m-d', strtotime('monday this week'));
  314. $arr[] = date('Y-m-d', strtotime('monday this week +1 day'));
  315. $arr[] = date('Y-m-d', strtotime('monday this week +2 day'));
  316. $arr[] = date('Y-m-d', strtotime('monday this week +3 day'));
  317. $arr[] = date('Y-m-d', strtotime('monday this week +4 day'));
  318. $arr[] = date('Y-m-d', strtotime('monday this week +5 day'));
  319. $arr[] = date('Y-m-d', strtotime('sunday this week'));
  320. $array = [];
  321. foreach ($arr as $k => $v) {
  322. $array[] = [
  323. 'day' => date('d', strtotime($v)),
  324. 'has' => Db::table('wa_stream')
  325. ->where('user_id', $request->user_data['id'])
  326. ->where('type', streamType2)
  327. ->whereBetween('add_time', [strtotime($v . ' 00:00:00'), strtotime($v . ' 23:59:59')])->exists()
  328. ];
  329. }
  330. $signcount = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count();
  331. $is_sign = Db::table('wa_stream')
  332. ->where('user_id', $request->user_data['id'])
  333. ->where('type', streamType2)
  334. ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
  335. ->exists();
  336. return success([
  337. 'list' => $array,
  338. 'signcount' => $signcount,
  339. 'continuity' => $request->user_data['continuity'],
  340. 'money' => $system->realname_reward,
  341. 'original_sign_award' => $system->sign_award,
  342. 'is_sign' => $is_sign,
  343. ]);
  344. // $param = $request->param_data;
  345. // $param['user_data'] = $request->user_data;
  346. // $month_num = date('t');
  347. // $res = [];
  348. // //查询当前用户当月签到记录
  349. // $this_month_sign = Db::table('wa_stream')
  350. // ->where('type', streamType2)
  351. // ->where('user_id', $param['user_data']['id'])
  352. // ->whereRaw("DATE_FORMAT(created_at,'%Y-%m')=?", date('Y-m'))
  353. // ->get();
  354. // for ($i = 1; $i <= $month_num; $i++) {
  355. // $date = $i > 9 ? date('Y-m-') . $i : date('Y-m-') . '0' . $i;
  356. // $check_sign = collect($this_month_sign)
  357. // ->where('created_at', '>=', $date . ' 00:00:00')
  358. // ->where('created_at', '<=', $date . ' 23:59:59')
  359. // ->exists();
  360. // $res[] = [
  361. // 'day' => $i,
  362. // 'has' => $check_sign,
  363. // ];
  364. // }
  365. // $signcount = Db::table('wa_stream')
  366. // ->where('type', streamType2)
  367. // ->where('user_id', $request->user_data['id'])
  368. // ->count();
  369. // $is_sign = Db::table('wa_stream')
  370. // ->where('user_id', $request->user_data['id'])
  371. // ->where('type', streamType2)
  372. // ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
  373. // ->exists();
  374. // return success([
  375. // 'list' => $res,
  376. // 'signcount' => $signcount,
  377. // 'continuity' => $request->user_data['continuity'],
  378. // 'is_sign' => $is_sign,
  379. // ]);
  380. }
  381. #[Apidoc\Title("签到")]
  382. #[Apidoc\Url("api/user/sign.html")]
  383. #[Apidoc\Method("POST")]
  384. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  385. #[Apidoc\Returned(name: "money", type: "string", desc: '奖励金额', default: '888')]
  386. #[Apidoc\Returned(name: "signcount", type: "string", desc: '累计签到天数', default: '888')]
  387. public function sign(Request $request)
  388. {
  389. Db::beginTransaction();
  390. try {
  391. $zuotian = Db::table('wa_stream')
  392. ->where('user_id', $request->user_data['id'])
  393. ->where('type', streamType2)
  394. ->whereBetween('add_time', [bcsub(strtotime(date('Y-m-d') . ' 00:00:00'), 86400), bcadd(strtotime(date('Y-m-d') . ' 23:59:59'), 86400)])
  395. ->exists();
  396. if ($zuotian) {
  397. $continuity = bcadd($request->user_data['continuity'], 1);
  398. } else {
  399. $continuity = 1;
  400. }
  401. $has = Db::table('wa_stream')
  402. ->where('user_id', $request->user_data['id'])
  403. ->where('type', streamType2)
  404. ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
  405. ->exists();
  406. if ($has) {
  407. throw new \Exception('今日已签到,请不要重复签到');
  408. }
  409. $system = Db::table('wa_system')->first();
  410. if (!empty($system->sign_award)) {
  411. StreamBusiness::addStream($request->user_data['id'], $system->sign_award, streamType2, moldType1, moldTypefild1);
  412. }
  413. if (!empty($system->realname_reward)) {
  414. StreamBusiness::addStream($request->user_data['id'], $system->realname_reward, streamType2, moldType5, moldTypefild5);
  415. }
  416. Db::table('wa_users')->where(['id' => $request->user_data['id']])->update(['continuity' => $continuity]);
  417. $signcount = Db::table('wa_stream')->where('type', streamType2)->where('user_id', $request->user_data['id'])->count();
  418. $userdata = Db::table('wa_users')->where(['id' => $request->user_data['id']])->first();
  419. if ($continuity >= 3 && $request->user_data['is_boost'] == 1 && $userdata->is_effective == 0 && !empty($request->user_data['pid'])) {
  420. Db::table('wa_users')->where('id', $request->user_data['pid'])->increment('effective_is_num', 1);
  421. Db::table('wa_users')->where(['id' => $request->user_data['id']])->update(['is_effective' => 1]);
  422. }
  423. } catch (\Throwable $exception) {
  424. Db::rollBack();
  425. return error($exception->getMessage());
  426. }
  427. Db::commit();
  428. return success([
  429. 'money' => $system->sign_award,
  430. 'signcount' => $signcount
  431. ], '签到成功');
  432. }
  433. #[Apidoc\Title("我的团队头数据")]
  434. #[Apidoc\Url("api/user/team.html")]
  435. #[Apidoc\Method("POST")]
  436. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  437. #[Apidoc\Returned(name: "num", type: "int", require: true, desc: '团队总人数', default: '1')]
  438. #[Apidoc\Returned(name: "earnings", type: "int", require: true, desc: '总拥金收益', default: '0')]
  439. #[Apidoc\Returned(name: "dayearnings", type: "int", require: true, desc: '今日收益', default: '0')]
  440. #[Apidoc\Returned(name: "one", type: "int", require: true, desc: '一级人数', default: '0')]
  441. #[Apidoc\Returned(name: "two", type: "int", require: true, desc: '二级人数', default: '0')]
  442. #[Apidoc\Returned(name: "three", type: "int", require: true, desc: '三级人数', default: '0')]
  443. #[Apidoc\Returned(name: "rebate", type: "int", require: true, desc: '一级返佣', default: '0')]
  444. #[Apidoc\Returned(name: "rebate_one", type: "int", require: true, desc: '二级返佣', default: '0')]
  445. #[Apidoc\Returned(name: "rebate_two", type: "int", require: true, desc: '三级返佣', default: '0')]
  446. public function team(Request $request)
  447. {
  448. $param = $request->user_data;
  449. $data = Db::table('wa_users')->where(function ($query) use ($param) {
  450. $query->orWhere('pid', $param['id']);
  451. $query->orWhere('ppid', $param['id']);
  452. $query->orWhere('toppid', $param['id']);
  453. });
  454. $system = Db::table('wa_system')->first();
  455. /** @var $num 团队总人数 */
  456. $num = (clone $data)->count();
  457. // $stream = Db::table('wa_stream')
  458. // ->where('mold', moldType1)
  459. // ->where('type', streamType14)
  460. // ->where('user_id', $request->user_data['id']);
  461. return success([
  462. 'num' => $num,
  463. 'earnings' => 0,
  464. 'dayearnings' => 0,
  465. 'one' => Db::table('wa_users')->where('pid', $param['id'])->count(),
  466. 'two' => Db::table('wa_users')->where('ppid', $param['id'])->count(),
  467. 'three' => Db::table('wa_users')->where('toppid', $param['id'])->count(),
  468. 'rebate' => $system->rebate,
  469. 'rebate_one' => $system->rebate_one,
  470. 'rebate_two' => $system->rebate_two,
  471. ]);
  472. }
  473. #[Apidoc\Title("我的团队列表数据")]
  474. #[Apidoc\Url("api/user/team_list.html")]
  475. #[Apidoc\Method("POST")]
  476. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  477. #[Apidoc\Param("page", type: "int", require: true, desc: "页面", mock: 1)]
  478. #[Apidoc\Param("limit", type: "int", require: true, desc: "输出条数", mock: 10)]
  479. #[Apidoc\Param("grade", type: "int", require: true, desc: "等级 1一级 2二级 3三级", mock: 1)]
  480. #[Apidoc\Returned(name: "name", type: "string", require: true, desc: '名称', default: '未实名')]
  481. #[Apidoc\Returned(name: "mobile", type: "string", require: true, desc: '电话', default: '158****0002')]
  482. #[Apidoc\Returned(name: "join_time", type: "string", require: true, desc: '注册时间', default: '2024-07-08 01:20:47')]
  483. #[Apidoc\Returned(name: "invest_money", type: "string", require: true, desc: '消费金额', default: '0.00')]
  484. public function teamList(Request $request)
  485. {
  486. try {
  487. $param = $request->param_data;
  488. $param['user_data'] = $request->user_data;
  489. Validator::input($param, [
  490. 'page' => Validator::notEmpty()->intType()->setName('页面'),
  491. 'limit' => Validator::notEmpty()->intType()->setName('输出条数'),
  492. 'grade' => Validator::notEmpty()->intType()->setName('等级'),
  493. ]);
  494. $data = Db::table('wa_users')->where(function ($query) use ($param) {
  495. if (Arr::get($param, 'grade')) {
  496. if ($param['grade'] == 1) {
  497. $query->where('pid', $param['user_data']['id']);
  498. } elseif ($param['grade'] == 2) {
  499. $query->where('ppid', $param['user_data']['id']);
  500. } elseif ($param['grade'] == 3) {
  501. $query->where('toppid', $param['user_data']['id']);
  502. }
  503. } else {
  504. $query->where('pid', $param['user_data']['id']);
  505. }
  506. })->select(['name', 'mobile', 'join_time', 'invest_money'])
  507. ->orderByDesc('id')
  508. ->paginate(Arr::get($param, 'limit', 10), ['*'], 'page', Arr::get($param, 'page'))
  509. ->toArray();
  510. foreach ($data['data'] as $k => $v) {
  511. $data['data'][$k]->mobile = substr_replace($v->mobile, '****', 3, 4);
  512. }
  513. } catch (\Throwable $exception) {
  514. return new Exception($exception->getMessage());
  515. }
  516. return success($data['data'], '成功', 200, $data['total']);
  517. }
  518. // #[Apidoc\Title("我的投资")]
  519. // #[Apidoc\Url("api/user/mygoods")]
  520. // #[Apidoc\Method("POST")]
  521. // #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  522. // #[Apidoc\Param("page", type: "int", require: true, desc: "页面", mock: 1)]
  523. // #[Apidoc\Param("limit", type: "int", require: true, desc: "输出条数", mock: 10)]
  524. // #[Apidoc\Returned(name: "id", type: "string", require: true, desc: '购买记录ID', default: '485')]
  525. // #[Apidoc\Returned(name: "goods_id", type: "string", require: true, desc: '产品ID', default: '5')]
  526. // #[Apidoc\Returned(name: "img", type: "string", require: true, desc: '封面图', default: '')]
  527. // #[Apidoc\Returned(name: "name", type: "string", require: true, desc: '产品名称', default: '')]
  528. // #[Apidoc\Returned(name: "type", type: "string", require: true, desc: '产品类型 1 慈善 2助力', default: '')]
  529. // #[Apidoc\Returned(name: "price", type: "string", require: true, desc: '价格', default: '')]
  530. // #[Apidoc\Returned(name: "pay_price", type: "string", require: true, desc: '通道支付金额', default: '')]
  531. // #[Apidoc\Returned(name: "period", type: "string", require: true, desc: '周期', default: '')]
  532. // #[Apidoc\Returned(name: "bl", type: "string", require: true, desc: '比例', default: '')]
  533. // #[Apidoc\Returned(name: "bonus", type: "string", require: true, desc: '每日分红金额', default: '')]
  534. // #[Apidoc\Returned(name: "predict", type: "string", require: true, desc: '预计收益', default: '')]
  535. // #[Apidoc\Returned(name: "created_at", type: "string", require: true, desc: '购买时间', default: '')]
  536. // #[Apidoc\Returned(name: "expiretime", type: "string", require: true, desc: '到期时间戳', default: '')]
  537. // #[Apidoc\Returned(name: "is_grant", type: "string", require: true, desc: '是否退本 1未退本 2已退本', default: '')]
  538. // public function mygoods(Request $request)
  539. // {
  540. // try {
  541. // $param = Arr::only($request->all(), ['page', 'limit', 'grade']);
  542. // $param['user_data'] = $request->user_data;
  543. // Validator::input($param, [
  544. // 'page' => Validator::notEmpty()->intType()->setName('页码'),
  545. // 'limit' => Validator::notEmpty()->intType()->setName('输出条数'),
  546. // ]);
  547. // $data = Db::table('wa_my_goods')
  548. // ->join('wa_goods', 'wa_goods.id', '=', 'wa_my_goods.goods_id')
  549. // ->where('wa_my_goods.user_id', $param['user_data']['id'])
  550. // ->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'])
  551. // ->orderByDesc('wa_my_goods.id')
  552. // ->paginate(Arr::get($param, 'limit', 10))
  553. // ->toArray();
  554. // foreach ($data['data'] as $k => $v) {
  555. // $data['data'][$k]->img = getenv('IMG') . $v->img;
  556. // }
  557. // } catch (\Throwable $exception) {
  558. // return error($exception->getMessage());
  559. // }
  560. //
  561. // return success($data['data'], '成功', 200, $data['total']);
  562. // }
  563. #[Apidoc\Title("退出登录")]
  564. #[Apidoc\Url("api/user/quit.html")]
  565. #[Apidoc\Method("POST")]
  566. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  567. public function quit(Request $request)
  568. {
  569. Redis::del($request->user_data['id']);
  570. return success([], '已退出登录!');
  571. }
  572. #[Apidoc\Title("修改密码")]
  573. #[Apidoc\Url("api/user/save.html")]
  574. #[Apidoc\Method("POST")]
  575. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  576. #[Apidoc\Param("type", type: "int", require: true, desc: "类型 1修改名称 2 修改密码 ", mock: 1)]
  577. #[Apidoc\Param("name", type: "string", require: true, desc: "名称", mock: 1)]
  578. #[Apidoc\Param("old_password", type: "string", require: true, desc: "旧密码", mock: 1)]
  579. #[Apidoc\Param("password", type: "string", require: true, desc: "新密码", mock: 10)]
  580. public function save(Request $request)
  581. {
  582. Db::beginTransaction();
  583. try {
  584. $param = $request->param_data;
  585. Validator::input($param, [
  586. 'type' => Validator::notEmpty()->intType()->setName('操作类型'),
  587. ]);
  588. if (Arr::get($param, 'type') == 1) {
  589. Validator::input($param, [
  590. 'name' => Validator::notEmpty()->setName('操作类型'),
  591. ]);
  592. $arr['name'] = $param['name'];
  593. } elseif (Arr::get($param, 'type') == 2) {
  594. Validator::input($param, [
  595. 'old_password' => Validator::notEmpty()->setName('旧密码'),
  596. 'password' => Validator::notEmpty()->setName('新密码'),
  597. ]);
  598. if ($request->user_data['password'] != md5($param['old_password'])) {
  599. throw new \Exception('密码验证失败');
  600. }
  601. $arr['password'] = md5($param['password']);
  602. }
  603. if (empty($arr)) {
  604. throw new \Exception('非法操作');
  605. }
  606. Db::table('wa_users')->where('id', $request->user_data['id'])->update($arr);
  607. } catch (\Throwable $exception) {
  608. Db::rollBack();
  609. return error($exception->getMessage());
  610. }
  611. Db::commit();
  612. return success([], '修改成功');
  613. }
  614. #[Apidoc\Title("统计数据")]
  615. #[Apidoc\Url("api/user/cfxstat.html")]
  616. #[Apidoc\Method("POST")]
  617. #[Apidoc\Header("token", type: "string", require: true, desc: "身份令牌Token", mock: "@token")]
  618. #[Apidoc\Returned(name: "coin_value", type: "string", require: true, desc: 'wroldcion币单枚价值', default: '0.00')]
  619. #[Apidoc\Returned(name: "total_value", type: "string", require: true, desc: '世界币总市值', default: '0.00')]
  620. #[Apidoc\Returned(name: "turnover", type: "string", require: true, desc: '世界币成交量', default: '0.00')]
  621. #[Apidoc\Returned(name: "realname_reward", type: "string", require: true, desc: '签到奖励--wroldcion币', default: '0.00')]
  622. #[Apidoc\Returned(name: "register_award", type: "string", require: true, desc: '实名赠送(wroldcion币)', default: '0.00')]
  623. #[Apidoc\Returned(name: "invitation_award", type: "string", require: true, desc: '邀请奖励(wroldcion币)', default: '0.00')]
  624. public function cfxstat(Request $request)
  625. {
  626. Db::beginTransaction();
  627. try {
  628. $system = Db::table('wa_system')->first();
  629. $cfxdata = Db::table('wa_cfx_data')->orderByRaw('id')->limit(30)
  630. ->get()
  631. ->toArray();
  632. $categories = [];
  633. $series = [];
  634. foreach ($cfxdata as $k => $v) {
  635. if (empty($v->created_at)) {
  636. $categories[$k] = date('m/d', $v->createtime);
  637. } else {
  638. $categories[$k] = date('m/d', strtotime($v->created_at));
  639. }
  640. $series[] = [$categories[$k], $v->open, $v->close, $v->up, $v->lower];
  641. }
  642. $list = [
  643. 'series' => $series,
  644. ];
  645. $data = [
  646. 'list' => $list,
  647. 'coin_value' => $system->coin_value,
  648. 'total_value' => $system->total_value,
  649. 'turnover' => $system->turnover,
  650. 'realname_reward' => $system->realname_reward,
  651. 'original_realname_reward' => $system->original_realname_reward,
  652. 'register_award' => $system->register_award,
  653. 'original_register_award' => $system->original_register_award,
  654. 'invitation_award' => $system->invitation_award,
  655. 'original_invitation_award' => $system->original_invitation_award,
  656. ];
  657. } catch (\Throwable $exception) {
  658. Db::rollBack();
  659. return error($exception->getMessage());
  660. }
  661. Db::commit();
  662. return success($data, '获取成功');
  663. }
  664. }