MemberService.php 85 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797
  1. <?php
  2. namespace app\admin\service\member;
  3. use app\common\Tree;
  4. use app\model\ClientPoints;
  5. use app\model\CouponDetail;
  6. use app\model\Device;
  7. use app\model\Family;
  8. use app\model\FamilyMember;
  9. use app\model\Goods;
  10. use app\model\Member;
  11. use app\model\MemberAccount;
  12. use app\model\MemberAccountList;
  13. use app\model\MemberCert;
  14. use app\model\MemberDevice;
  15. use app\model\MemberInfo;
  16. use app\model\MemberRole;
  17. use app\model\Order;
  18. use app\model\OrderSheet;
  19. use app\model\PayDetail;
  20. use app\model\SysCategory;
  21. use app\model\SysDept;
  22. use app\model\SysSerial;
  23. use app\model\SysUser;
  24. use support\Db;
  25. use support\exception\BusinessException;
  26. use support\Log;
  27. use support\Request;
  28. use support\Response;
  29. class MemberService
  30. {
  31. public static function list(Request $request)
  32. {
  33. $page = $request->get('page', 1);
  34. $pageSize = $request->get('pageSize', 10);
  35. $name = $request->get('name', '');
  36. $nickname = $request->get('nickname', '');
  37. $mobile = $request->get('mobile', '');
  38. $level = $request->get('level', '');
  39. $isAuth = $request->get('is_auth', '');
  40. $addtime = $request->get('member_addtimes', []);
  41. $type = $request->get('type', '');
  42. $status = $request->get('member_status', '');
  43. $memberIsPartner = $request->get('member_is_partner', '');
  44. $memberIsReferrer = $request->get('member_is_referrer', '');
  45. $rows = Member::with([
  46. 'account' => function ($query) {
  47. $query->where('member_account_status', 'ACTIVED');
  48. }
  49. ])
  50. ->where('member_is_owner', 'N')
  51. ->where('member_mobile', '<>', '0000')
  52. ->leftJoin('member_info', 'member_info.join_info_member_id', 'member.member_id')
  53. ->leftJoin('member_cert', 'member_cert.join_cert_member_id', 'member.member_id')
  54. // ->leftjoin('member_account', 'member.member_id', '=', 'member_account.join_account_member_id')
  55. ->leftJoin('member_role', 'member_role.member_role_id', 'member.join_member_role_id')
  56. // ->where('member_account.member_account_classify', 'CASH')
  57. ->when($name != '', function ($query) use ($name) {
  58. $query->where('member_cert.member_cert_name', 'like', '%' . $name . '%');
  59. })->when($mobile != '', function ($query) use ($mobile) {
  60. $query->where('member.member_mobile', 'like', '%' . $mobile . '%');
  61. })->when($level != '', function ($query) use ($level) {
  62. if ($level == 'other') {
  63. $query->where('member.join_member_role_id', NULL)->orWhere('member.join_member_role_id', '');
  64. } else if ($level == 'VIP') {
  65. $query->where('member.member_is_vip', 'Y');
  66. } else {
  67. $query->where('member_role.member_role_id', $level);
  68. }
  69. })->when($isAuth != '', function ($query) use ($isAuth) {
  70. if ($isAuth == 'Y') {
  71. $query->where('member_cert.member_cert_name', '<>', NULL)->where('member_cert.member_cert_nbr', '<>', NULL)->where('member_cert.member_cert_name', '<>', '')->where('member_cert.member_cert_nbr', '<>', '');
  72. } else {
  73. $query->where('member_cert.member_cert_name', NULL)->orWhere('member_cert.member_cert_nbr', NULL)->orWhere('member_cert.member_cert_name', '')->orWhere('member_cert.member_cert_nbr', '');
  74. }
  75. })->when(!empty($addtime), function ($query) use ($addtime) {
  76. $addtime[0] = strtotime($addtime[0]);
  77. $addtime[1] = strtotime($addtime[1]);
  78. $query->whereBetween('member.member_addtimes', $addtime);
  79. })->when(!empty($type), function ($query) use ($type) {
  80. if ($type == 'todayAdd') {
  81. $addtime[0] = strtotime(date('Y-m-d') . ' 00:00:00');
  82. $addtime[1] = strtotime(date('Y-m-d') . ' 23:59:59');
  83. } else if ($type == 'monthAdd') {
  84. $addtime[0] = strtotime(date('Y-m-01') . ' 00:00:00');
  85. $addtime[1] = strtotime(date('Y-m-t') . ' 23:59:59');
  86. }
  87. $query->whereBetween('member.member_addtimes', $addtime);
  88. })->when(!empty($nickname), function ($query) use ($nickname) {
  89. $query->where(function ($query2) use ($nickname) {
  90. $query2->where('member_info.member_info_nickname', 'like', '%' . $nickname . '%')->orWhere('member.member_mobile', 'like', '%' . $nickname . '%');
  91. });
  92. })->when(!empty($status), function ($query) use ($status) {
  93. $query->where('member_status', $status);
  94. })->when(!empty($memberIsPartner), function ($query) use ($memberIsPartner) {
  95. if ($memberIsPartner == 'Y') {
  96. $query->where('member_is_partner', 'Y');
  97. }
  98. })->when(!empty($memberIsReferrer), function ($query) use ($memberIsReferrer) {
  99. if ($memberIsReferrer == 'Y') {
  100. $query->where('member_is_referrer', 'Y');
  101. }
  102. })
  103. ->select('member_id', 'member_is_vip', 'member_is_owner', 'join_invite_member_id', 'member_is_partner', 'member_is_referrer', 'member_classify', 'member_status', 'member_mobile', 'member_from', 'member_addtimes', 'member_extend_json',
  104. 'member_info.member_info_nickname', 'member_info.member_info_headimg', 'member_info.member_info_referee', 'member_info.member_info_business', 'member_info.member_info_service', 'member_info.member_info_city', 'member_info.member_info_address', 'member_info.member_info_gender', 'member_info.member_info_birthday',
  105. 'member_role.member_role_id', 'member_role.member_role_name',
  106. 'member_cert.member_cert_birth', 'member_cert.member_cert_gender', 'member_cert.member_cert_name', 'member_cert.member_cert_nbr', 'member_cert.member_cert_province', 'member_cert.member_cert_addr', 'member_cert.member_cert_face', 'member_cert.member_cert_photo', 'member_cert.member_cert_nation'
  107. // 'member_account.member_account_surplus'
  108. );
  109. // 总条数
  110. $total = $rows->count('member_id');
  111. $rows = $rows->orderBy('member_addtimes', 'DESC')
  112. ->forPage($page, $pageSize)
  113. ->get()
  114. ->toArray();
  115. foreach ($rows as &$row) {
  116. $row['coupon_count'] = CouponDetail::where('join_coupon_detail_member_id', $row['member_id'])->count();
  117. $row['member_mobile'] = substr($row['member_mobile'], 0, 3) . '****' . substr($row['member_mobile'], 7);
  118. // 推荐人
  119. if (!empty($row['join_invite_member_id'])) {
  120. $row['referrer_name'] = MemberService::getMemberNameByMemberId($row['join_invite_member_id']);
  121. }
  122. $row['info'] = [
  123. 'member_info_nickname' => !empty($row['member_info_nickname']) ? $row['member_info_nickname'] : substr($row['member_mobile'], -4, 4) . '会员',
  124. 'member_info_headimg' => !empty($row['member_info_headimg']) ? $row['member_info_headimg'] : '',
  125. 'member_info_referee' => !empty($row['member_info_referee']) ? $row['member_info_referee'] : '',
  126. 'member_info_business' => !empty($row['member_info_business']) ? $row['member_info_business'] : '',
  127. 'member_info_service' => !empty($row['member_info_service']) ? $row['member_info_service'] : '',
  128. 'member_info_city' => !empty($row['member_info_city']) ? explode('-', $row['member_info_city']) : '',
  129. 'member_info_address' => !empty($row['member_info_address']) ? $row['member_info_address'] : '',
  130. 'member_info_birthday' => !empty($row['member_info_birthday']) ? $row['member_info_birthday'] : '',
  131. 'member_info_gender' => !empty($row['member_info_gender']) ? $row['member_info_gender'] : '',
  132. ];
  133. if (substr($row['info']['member_info_headimg'], 0, 2) == '..') {
  134. $row['info']['member_info_headimg'] = '';
  135. }
  136. if (!empty($row['info']['member_info_address']) && in_array($row['info']['member_info_address'], ['请选择', '省-市-区'])) {
  137. $row['info']['member_info_address'] = '';
  138. }
  139. $row['cert'] = [
  140. 'member_cert_birth' => $row['member_cert_birth'],
  141. 'member_cert_gender' => $row['member_cert_gender'],
  142. 'member_cert_name' => $row['member_cert_name'],
  143. 'member_cert_nbr' => $row['member_cert_nbr'],
  144. 'member_cert_province' => !empty($row['member_cert_province']) && is_json($row['member_cert_province']) ? json_decode($row['member_cert_province']) : '',
  145. 'member_cert_addr' => $row['member_cert_addr'],
  146. 'member_cert_face' => !empty($row['member_cert_face']) ? getenv('STORAGE_DOMAIN') . $row['member_cert_face'] : '',
  147. 'member_cert_photo' => !empty($row['member_cert_photo']) ? getenv('STORAGE_DOMAIN') . $row['member_cert_photo'] : '',
  148. 'member_cert_nation' => $row['member_cert_nation'],
  149. ];
  150. $account = [];
  151. if (!empty($row['account'])) {
  152. foreach ($row['account'] as $item) {
  153. if ($item['member_account_classify'] == 'WELFARE') {
  154. $account['welfare'] = [
  155. 'member_account_name' => $item['member_account_name'],
  156. 'member_account_income' => $item['member_account_income'],
  157. 'member_account_expend' => $item['member_account_expend'],
  158. 'member_account_surplus' => $item['member_account_surplus'],
  159. 'member_account_added' => $item['member_account_added'],
  160. ];
  161. } else if ($item['member_account_classify'] == 'POINTS') {
  162. $account['points'] = [
  163. 'member_account_name' => $item['member_account_name'],
  164. 'member_account_income' => $item['member_account_income'],
  165. 'member_account_expend' => $item['member_account_expend'],
  166. 'member_account_surplus' => $item['member_account_surplus'],
  167. 'member_account_added' => $item['member_account_added'],
  168. ];
  169. } else if ($item['member_account_classify'] == 'CASH') {
  170. $account['cash'] = [
  171. 'member_account_name' => $item['member_account_name'],
  172. 'member_account_income' => $item['member_account_income'],
  173. 'member_account_expend' => $item['member_account_expend'],
  174. 'member_account_surplus' => $item['member_account_surplus'],
  175. 'member_account_added' => $item['member_account_added'],
  176. ];
  177. } else if ($item['member_account_classify'] == 'CARD') {
  178. $account['card'] = [
  179. 'member_account_name' => $item['member_account_name'],
  180. 'member_account_income' => $item['member_account_income'],
  181. 'member_account_expend' => $item['member_account_expend'],
  182. 'member_account_surplus' => $item['member_account_surplus'],
  183. 'member_account_added' => $item['member_account_added'],
  184. ];
  185. } else if ($item['member_account_classify'] == 'VIP') {
  186. $account['vip'] = [
  187. 'member_account_name' => $item['member_account_name'],
  188. 'member_account_income' => $item['member_account_income'],
  189. 'member_account_expend' => $item['member_account_expend'],
  190. 'member_account_surplus' => $item['member_account_surplus'],
  191. 'member_account_added' => $item['member_account_added'],
  192. ];
  193. }
  194. }
  195. }
  196. $row['account'] = $account;
  197. $row['is_auth'] = "未认证";
  198. if (!empty($row['member_cert_nbr']) && !empty($row['member_cert_name'])) {
  199. $row['is_auth'] = "已认证";
  200. }
  201. $row['source'] = "APP";
  202. $row['belong'] = [];
  203. $row['referee'] = [];
  204. if (!empty($row['member_extend_json'])) {
  205. $extendJson = json_decode($row['member_extend_json'], true);
  206. if (isset($extendJson['come_from'])) {
  207. $row['source'] = $extendJson['come_from'] ?? '';
  208. }
  209. if (isset($extendJson['belong'])) {
  210. $user = SysUser::where('user_id', $extendJson['belong']['user_id'])->select('user_name', 'user_mobile')->first();
  211. if ($user) {
  212. $row['belong']['user_id'] = $extendJson['belong']['user_id'];
  213. $row['belong']['username'] = $user->user_name;
  214. $row['belong']['user_mobile'] = $user->user_mobile;
  215. }
  216. $row['belong']['deptName'] = SysDept::where('dept_id', $extendJson['belong']['premises'])->value('dept_name');
  217. }
  218. if (isset($extendJson['referee'])) {
  219. foreach ($extendJson['referee'] as $key => $referee) {
  220. $row['referee'][] = [
  221. 'name' => $referee,
  222. 'time' => $key
  223. ];
  224. }
  225. }
  226. }
  227. // 粉丝
  228. $fans1 = Member::where('join_invite_member_id', $row['member_id'])
  229. ->select('member_id')
  230. ->get()
  231. ->toArray();
  232. $fans1Ids = array_column($fans1, 'member_id');
  233. $fans2Count = Member::whereIn('join_invite_member_id', $fans1Ids)
  234. ->count();
  235. $row['fans_total'] = count($fans1) + $fans2Count;
  236. }
  237. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  238. }
  239. public static function exportMember(Request $request)
  240. {
  241. $memberIds = $request->get('member_id', '');
  242. $name = $request->get('name', '');
  243. $mobile = $request->get('mobile', '');
  244. $level = $request->get('level', '');
  245. $isAuth = $request->get('is_auth', '');
  246. $addtime = $request->get('member_addtimes', []);
  247. $isPartner = $request->get('member_is_partner', '');
  248. $isReferrer = $request->get('member_is_referrer', '');
  249. $rows = Member::with('account')
  250. ->where('member_is_owner', 'N')
  251. ->where('member_mobile', '<>', '0000')
  252. ->leftJoin('member_info', 'member_info.join_info_member_id', 'member.member_id')
  253. ->leftJoin('member_cert', 'member_cert.join_cert_member_id', 'member.member_id')
  254. // ->leftjoin('member_account', 'member.member_id', '=', 'member_account.join_account_member_id')
  255. ->leftJoin('member_role', 'member_role.member_role_id', 'member.join_member_role_id')
  256. // ->where('member_account.member_account_classify', 'CASH')
  257. ->when($memberIds != '', function ($query) use ($memberIds) {
  258. $query->whereIn('member.member_id', $memberIds);
  259. })->when($name != '', function ($query) use ($name) {
  260. $query->where('member_cert.member_cert_name', 'like', '%' . $name . '%');
  261. })->when($mobile != '', function ($query) use ($mobile) {
  262. $query->where('member.member_mobile', 'like', '%' . $mobile . '%');
  263. })->when($isPartner != '', function ($query) use ($isPartner) {
  264. $query->where('member.member_is_partner', $isPartner);
  265. })->when($isReferrer != '', function ($query) use ($isReferrer) {
  266. $query->where('member.member_is_referrer', $isReferrer);
  267. })->when($level != '', function ($query) use ($level) {
  268. if ($level == 'other') {
  269. $query->where('member.join_member_role_id', NULL)->orWhere('member.join_member_role_id', '');
  270. } else {
  271. $query->where('member_role.member_role_id', $level);
  272. }
  273. })->when($isAuth != '', function ($query) use ($isAuth) {
  274. if ($isAuth == 'Y') {
  275. $query->where('member_cert.member_cert_name', '<>', NULL)->where('member_cert.member_cert_nbr', '<>', NULL)->where('member_cert.member_cert_name', '<>', '')->where('member_cert.member_cert_nbr', '<>', '');
  276. } else {
  277. $query->where('member_cert.member_cert_name', NULL)->where('member_cert.member_cert_nbr', NULL)->where('member_cert.member_cert_name', '')->where('member_cert.member_cert_nbr', '');
  278. }
  279. })->when(!empty($addtime), function ($query) use ($addtime) {
  280. $addtime[0] = strtotime($addtime[0]);
  281. $addtime[1] = strtotime($addtime[1]);
  282. $query->whereBetween('member.member_addtimes', $addtime);
  283. })->select('member_id', 'join_invite_member_id', 'member_is_owner', 'member_classify', 'member_status', 'member_mobile', 'member_from', 'member_addtimes', 'member_extend_json',
  284. 'member_info.member_info_nickname', 'member_info.member_info_headimg', 'member_info.member_info_referee', 'member_info.member_info_business', 'member_info.member_info_service',
  285. 'member_role.member_role_id', 'member_role.member_role_name',
  286. 'member_cert.member_cert_birth', 'member_cert.member_cert_gender', 'member_cert.member_cert_name', 'member_cert.member_cert_nbr', 'member_cert.member_cert_province', 'member_cert.member_cert_addr', 'member_cert.member_cert_face', 'member_cert.member_cert_photo', 'member_cert.member_cert_nation',
  287. // 'member_account.member_account_surplus'
  288. )->orderBy('member_addtimes', 'DESC')
  289. ->get()
  290. ->toArray();
  291. $exportData = [];
  292. foreach ($rows as $row) {// 推荐人
  293. if (!empty($row['join_invite_member_id'])) {
  294. $row['referrer_name'] = MemberService::getMemberNameByMemberId($row['join_invite_member_id']);
  295. }
  296. $row['info'] = [
  297. 'member_info_nickname' => !empty($row['member_info_nickname']) ? $row['member_info_nickname'] : substr($row['member_mobile'], -4, 4) . '会员',
  298. 'member_info_headimg' => !empty($row['member_info_headimg']) ? $row['member_info_headimg'] : '',
  299. 'member_info_referee' => !empty($row['member_info_referee']) ? $row['member_info_referee'] : '',
  300. 'member_info_business' => !empty($row['member_info_business']) ? $row['member_info_business'] : '',
  301. 'member_info_service' => !empty($row['member_info_service']) ? $row['member_info_service'] : ''
  302. ];
  303. $row['cert'] = [
  304. 'member_cert_name' => $row['member_cert_name'],
  305. ];
  306. $account = [];
  307. if (!empty($row['account'])) {
  308. foreach ($row['account'] as $item) {
  309. if ($item['member_account_classify'] == 'POINTS') {
  310. $account['points'] = [
  311. 'member_account_surplus' => $item['member_account_surplus'],
  312. 'member_account_added' => $item['member_account_added'],
  313. ];
  314. } else if ($item['member_account_classify'] == 'CASH') {
  315. $account['cash'] = [
  316. 'member_account_surplus' => $item['member_account_surplus'],
  317. 'member_account_added' => $item['member_account_added'],
  318. ];
  319. } else if ($item['member_account_classify'] == 'CARD') {
  320. $account['card'] = [
  321. 'member_account_surplus' => $item['member_account_surplus'],
  322. 'member_account_added' => $item['member_account_added'],
  323. ];
  324. }
  325. }
  326. }
  327. // $row['account'] = $account;
  328. $row['is_auth'] = "未认证";
  329. if (!empty($row['member_cert_nbr']) && !empty($row['member_cert_name'])) {
  330. $row['is_auth'] = "已认证";
  331. }
  332. $row['source'] = "APP";
  333. if (!empty($row['member_extend_json'])) {
  334. $extendJson = json_decode($row['member_extend_json'], true);
  335. if (isset($extendJson['come_from'])) {
  336. $row['source'] = $extendJson['come_from'] ?? '';
  337. }
  338. }
  339. $sourceStr = ['APP' => "APP", 'CUSTOMER' => "客户管理", 'SYSTEM' => "后台"];
  340. $exportData[] = [
  341. 'member_id' => $row['member_id'],
  342. 'member_info_nickname' => $row['info']['member_info_nickname'] ?? '',
  343. 'member_mobile' => $row['member_mobile'] ?? '',
  344. 'member_cert_name' => $row['cert']['member_cert_name'] ?? '',
  345. 'source' => in_array($row['source'], $sourceStr) ? $sourceStr[$row['source']] : 'APP',
  346. 'cash' => isset($account['cash']) ? $account['cash']['member_account_surplus'] + $account['cash']['member_account_added'] : 0,
  347. 'points' => isset($account['points']) ? $account['points']['member_account_surplus'] + $account['points']['member_account_added'] : 0,
  348. 'is_auth' => $row['is_auth'],
  349. 'level' => $row['member_role_name'] ?? '普通会员',
  350. 'member_addtimes' => $row['member_addtimes'],
  351. 'referrer_name' => $row['referrer_name'] ?? '',
  352. 'member_info_business' => $row['info']['member_info_business'] ?? '',
  353. 'member_info_service' => $row['info']['member_info_service'] ?? '',
  354. ];
  355. }
  356. return json_success('', $exportData);
  357. }
  358. public static function info($memberId)
  359. {
  360. $member = Member::with([
  361. 'cert',
  362. 'info',
  363. 'role' => function ($query) {
  364. $query->select('member_role_id', 'member_role_name');
  365. }
  366. ])
  367. ->where('member_id', $memberId)
  368. ->first();
  369. if (!$member) {
  370. return json_fail('查询错误');
  371. }
  372. $member = $member->toArray();
  373. $member['info'] = [
  374. 'member_info_nickname' => !empty($member['info']) && !empty($member['info']['member_info_nickname']) ? $member['info']['member_info_nickname'] : substr($member['member_mobile'], -4, 4) . '会员',
  375. 'member_info_headimg' => !empty($member['info']) && !empty($member['info']['member_info_headimg']) ? $member['info']['member_info_headimg'] : '',
  376. 'member_info_referee' => !empty($member['info']) && !empty($member['info']['member_info_referee']) ? $member['info']['member_info_referee'] : '',
  377. 'member_info_business' => !empty($member['info']) && !empty($member['info']['member_info_business']) ? $member['info']['member_info_business'] : '',
  378. 'member_info_service' => !empty($member['info']) && !empty($member['info']['member_info_service']) ? $member['info']['member_info_service'] : '',
  379. 'member_info_city' => !empty($member['info']) && !empty($member['info']['member_info_city']) ? explode('-', $member['info']['member_info_city']) : '',
  380. 'member_info_address' => !empty($member['info']) && !empty($member['info']['member_info_address']) ? $member['info']['member_info_address'] : '',
  381. 'member_info_gender' => !empty($member['info']) && !empty($member['info']['member_info_gender']) ? $member['info']['member_info_gender'] : '',
  382. 'member_info_birthday' => !empty($member['info']) && !empty($member['info']['member_info_birthday']) ? $member['info']['member_info_birthday'] : '',
  383. ];
  384. if (!empty($member['info']['member_info_address']) && in_array($member['info']['member_info_address'], ['请选择', '省-市-区'])) {
  385. $member['info']['member_info_address'] = '';
  386. }
  387. $member['cert'] = [
  388. 'member_cert_birth' => $member['cert']['member_cert_birth'] ?? '',
  389. 'member_cert_gender' => $member['cert']['member_cert_gender'] ?? '',
  390. 'member_cert_name' => $member['cert']['member_cert_name'] ?? '',
  391. 'member_cert_nbr' => $member['cert']['member_cert_nbr'] ?? '',
  392. 'member_cert_province' => !empty($member['cert']) && !empty($member['cert']['member_cert_province']) && is_json($member['cert']['member_cert_province']) ? json_decode($member['cert']['member_cert_province']) : '',
  393. 'member_cert_addr' => $member['cert']['member_cert_addr'] ?? '',
  394. 'member_cert_face' => !empty($member['cert']) && !empty($member['cert']['member_cert_face']) ? getenv('STORAGE_DOMAIN') . $member['cert']['member_cert_face'] : '',
  395. 'member_cert_photo' => !empty($member['cert']) && !empty($member['cert']['member_cert_photo']) ? getenv('STORAGE_DOMAIN') . $member['cert']['member_cert_photo'] : '',
  396. 'member_cert_nation' => $member['cert']['member_cert_nation'] ?? '',
  397. 'member_cert_addtimes' => $member['cert']['member_cert_addtimes'] ?? '',
  398. ];
  399. if (!empty($member['cert']['member_cert_addtimes'])) {
  400. $member['cert']['member_cert_addtimes'] = date('Y-m-d', $member['cert']['member_cert_addtimes']);
  401. } else {
  402. $member['cert']['member_cert_addtimes'] = date('Y-m-d', strtotime($member['member_addtimes']));
  403. }
  404. if (!empty($member['join_invite_member_id'])) {
  405. $inviteMember = Member::with([
  406. 'info' => function ($query) {
  407. $query->select('join_info_member_id', 'member_info_nickname');
  408. },
  409. 'cert' => function ($query) {
  410. $query->select('join_cert_member_id', 'member_cert_name');
  411. }
  412. ])->where('member_id', $member['join_invite_member_id'])
  413. ->first();
  414. $inviteMemberName = '';
  415. if (!empty($inviteMember->cert) && !empty($inviteMember->cert->member_cert_name)) {
  416. $inviteMemberName = $inviteMember->cert->member_cert_name;
  417. } elseif (!empty($inviteMemberName->info) && !empty($inviteMemberName->info->member_info_nickname)) {
  418. $inviteMemberName = $inviteMemberName->info->member_info_nickname;
  419. }
  420. $member['invite_member'] = $inviteMemberName . (!empty($inviteMember->member_invite_code) ? '(' . $inviteMember->member_invite_code . ')' : '');
  421. }
  422. $member['is_auth'] = "未认证";
  423. if (!empty($member['cert']['member_cert_nbr']) && !empty($member['cert']['member_cert_name'])) {
  424. $member['is_auth'] = "已认证";
  425. }
  426. $member['source'] = "APP";
  427. $member['belong'] = [];
  428. $member['referee'] = [];
  429. if (!empty($member['member_extend_json'])) {
  430. $extendJson = json_decode($member['member_extend_json'], true);
  431. if (isset($extendJson['come_from'])) {
  432. $member['source'] = $extendJson['come_from'] ?? '';
  433. }
  434. if (isset($extendJson['belong'])) {
  435. $user = SysUser::where('user_id', $extendJson['belong']['user_id'])->select('user_name', 'user_mobile')->first();
  436. if ($user) {
  437. $member['belong']['user_id'] = $extendJson['belong']['user_id'];
  438. $member['belong']['username'] = $user->user_name;
  439. $member['belong']['user_mobile'] = $user->user_mobile;
  440. }
  441. $member['belong']['deptName'] = SysDept::where('dept_id', $extendJson['belong']['premises'])->value('dept_name');
  442. }
  443. if (isset($extendJson['referee'])) {
  444. foreach ($extendJson['referee'] as $key => $referee) {
  445. $member['referee'][] = [
  446. 'name' => $referee,
  447. 'time' => $key
  448. ];
  449. }
  450. }
  451. }
  452. if (!empty($member['join_invite_member_id'])) {
  453. $inviteMember = Member::with('cert', 'info')
  454. ->where('member_id', $member['join_invite_member_id'])
  455. ->select('member_id', 'member_mobile', 'member_invite_code')
  456. ->first();
  457. if (!empty($inviteMember)) {
  458. $inviteMember = $inviteMember->toArray();
  459. $mobile = '';
  460. if (!empty($inviteMember['member_mobile'])) {
  461. $mobile = $inviteMember['member_mobile'];
  462. }
  463. $nickname = '';
  464. if (!empty($inviteMember['info']) && !empty($inviteMember['info']['member_info_nickname'])) {
  465. $nickname = $inviteMember['info']['member_info_nickname'];
  466. }
  467. $certname = '';
  468. if (!empty($inviteMember['cert']) && !empty($inviteMember['cert']['member_info_nickname'])) {
  469. $nickname = $inviteMember['cert']['member_cert_name'];
  470. }
  471. $member['invite_name'] = MemberService::getMemberName($mobile, $certname, $nickname);
  472. $member['invite_code'] = $inviteMember['member_invite_code'] ?? '';
  473. }
  474. }
  475. return json_success('', $member);
  476. }
  477. /**
  478. * VIP账户明细
  479. */
  480. public static function vipInfo(Request $request)
  481. {
  482. $memberId = $request->get('member_id', '');
  483. $page = $request->get('page', 1);
  484. $pageSize = $request->get('pageSize', 20);
  485. $account = MemberAccount::where('join_account_member_id', $memberId)
  486. ->where('member_account_classify', 'VIP')
  487. ->first();
  488. if (!$account) {
  489. return json_fail('暂无数据');
  490. }
  491. $balance = $account->member_account_surplus + $account->member_account_added;
  492. $info = PayDetail::where(function ($query) use ($memberId) {
  493. $query->where('join_pay_member_id', $memberId)
  494. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  495. ->where('pay_category', 'VIP')
  496. ->where('pay_status', 'SUCCESS');
  497. })->orWhere(function ($query) use ($memberId) {
  498. $query->where('join_pay_member_id', $memberId)
  499. ->where('pay_prepayid', 'like', '%VIP%')
  500. ->where('pay_status', 'SUCCESS');
  501. })->orderByDesc('pay_addtimes')
  502. ->get()
  503. ->toArray();
  504. $data = [];
  505. foreach ($info as $key => $item) {
  506. $categoryIds = [];
  507. if (!empty($item['join_pay_order_id'])) {
  508. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  509. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  510. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  511. }
  512. $categoryName = [];
  513. foreach ($categoryIds as $id) {
  514. $category = SysCategory::where('category_id', $id)->first();
  515. if (!empty($category->category_super_path)) {
  516. $path = explode('#', $category->category_super_path);
  517. $ids = array_filter($path);
  518. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  519. } else {
  520. $categoryName[] = $category->category_name;
  521. }
  522. }
  523. $item['goods_category'] = implode(',', array_unique($categoryName));
  524. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  525. $item['goods_category'] = '自定义金额充值';
  526. }
  527. if (in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  528. $item['balance_type'] = 'add';
  529. } else {
  530. $item['balance_type'] = 'cut';
  531. }
  532. if ($key == 0 && in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  533. if (!empty($item['pay_extend_json'])) {
  534. $extendJson = json_decode($item['pay_extend_json'], true);
  535. if (!isset($extendJson['added_amount'])) {
  536. $extendJson['added_amount'] = 0;
  537. }
  538. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  539. $data[] = [
  540. 'join_pay_member_id' => $item['join_pay_member_id'],
  541. 'pay_addtimes' => $item['pay_addtimes'],
  542. 'pay_amount' => $extendJson['added_amount'],
  543. 'pay_category' => 'ADDED',
  544. 'balance' => number_format($balance, 2, '.', ''),
  545. 'balance_type' => 'add',
  546. ];
  547. }
  548. $balance = $balance - $extendJson['added_amount'];
  549. }
  550. $item['balance'] = number_format($balance, 2, '.', '');
  551. $balance = $balance - $item['pay_amount'];
  552. $data[] = $item;
  553. continue;
  554. }
  555. if (in_array($item['pay_category'], ['VIP', 'REFUND'])) {
  556. if (!empty($item['pay_extend_json'])) {
  557. $extendJson = json_decode($item['pay_extend_json'], true);
  558. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  559. $data[] = [
  560. 'join_pay_member_id' => $item['join_pay_member_id'],
  561. 'pay_addtimes' => $item['pay_addtimes'],
  562. 'pay_amount' => $extendJson['added_amount'],
  563. 'pay_category' => 'ADDED',
  564. 'balance' => number_format($balance, 2, '.', ''),
  565. 'balance_type' => 'add',
  566. ];
  567. $balance = $balance - $extendJson['added_amount'];
  568. }
  569. }
  570. $item['balance'] = number_format($balance, 2, '.', '');
  571. $balance = $balance - $item['pay_amount'];
  572. } else {
  573. $item['balance'] = number_format($balance, 2, '.', '');
  574. $balance = $balance + $item['pay_amount'];
  575. }
  576. $data[] = $item;
  577. }
  578. $total = count($data);
  579. $start = ($page - 1) * $pageSize;
  580. $rows = array_slice($data, $start, $pageSize);
  581. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  582. }
  583. public static function welfareInfo(Request $request)
  584. {
  585. $memberId = $request->get('member_id', '');
  586. $page = $request->get('page', 1);
  587. $pageSize = $request->get('pageSize', 20);
  588. $account = MemberAccount::where('join_account_member_id', $memberId)
  589. ->where('member_account_classify', 'WELFARE')
  590. ->first();
  591. if (!$account) {
  592. return json_fail('暂无数据');
  593. }
  594. $balance = $account->member_account_surplus + $account->member_account_added;
  595. $info = PayDetail::where(function ($query) use ($memberId) {
  596. $query->where('join_pay_member_id', $memberId)
  597. // ->whereIn('pay_prepayid', ['W06', 'A01'])
  598. ->where('pay_category', 'RECHARGE')
  599. ->where('pay_prepayid', 'WELFARE')
  600. ->where('pay_status', 'SUCCESS');
  601. })->orWhere(function ($query) use ($memberId) {
  602. $query->where('join_pay_member_id', $memberId)
  603. ->where('pay_prepayid', 'like', '%WELFARE%')
  604. ->where('pay_status', 'SUCCESS');
  605. })->orderByDesc('pay_addtimes')
  606. ->get()
  607. ->toArray();
  608. $data = [];
  609. foreach ($info as $key => $item) {
  610. $categoryIds = [];
  611. if (!empty($item['join_pay_order_id'])) {
  612. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  613. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  614. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  615. }
  616. $categoryName = [];
  617. foreach ($categoryIds as $id) {
  618. $category = SysCategory::where('category_id', $id)->first();
  619. if (!empty($category->category_super_path)) {
  620. $path = explode('#', $category->category_super_path);
  621. $ids = array_filter($path);
  622. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  623. } else {
  624. $categoryName[] = $category->category_name;
  625. }
  626. }
  627. $item['goods_category'] = implode(',', array_unique($categoryName));
  628. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  629. $item['goods_category'] = '自定义金额充值';
  630. }
  631. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  632. $item['balance_type'] = 'add';
  633. } else {
  634. $item['balance_type'] = 'cut';
  635. }
  636. if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  637. if (!empty($item['pay_extend_json'])) {
  638. $extendJson = json_decode($item['pay_extend_json'], true);
  639. if (!isset($extendJson['added_amount'])) {
  640. $extendJson['added_amount'] = 0;
  641. }
  642. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  643. $data[] = [
  644. 'join_pay_member_id' => $item['join_pay_member_id'],
  645. 'pay_addtimes' => $item['pay_addtimes'],
  646. 'pay_amount' => $extendJson['added_amount'],
  647. 'pay_category' => 'ADDED',
  648. 'balance' => number_format($balance, 2, '.', ''),
  649. 'balance_type' => 'add',
  650. ];
  651. }
  652. $balance = $balance - $extendJson['added_amount'];
  653. }
  654. $item['balance'] = number_format($balance, 2, '.', '');
  655. $balance = $balance - $item['pay_amount'];
  656. $data[] = $item;
  657. continue;
  658. }
  659. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND'])) {
  660. if (!empty($item['pay_extend_json'])) {
  661. $extendJson = json_decode($item['pay_extend_json'], true);
  662. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  663. $data[] = [
  664. 'join_pay_member_id' => $item['join_pay_member_id'],
  665. 'pay_addtimes' => $item['pay_addtimes'],
  666. 'pay_amount' => $extendJson['added_amount'],
  667. 'pay_category' => 'ADDED',
  668. 'balance' => number_format($balance, 2, '.', ''),
  669. 'balance_type' => 'add',
  670. ];
  671. $balance = $balance - $extendJson['added_amount'];
  672. }
  673. }
  674. $item['balance'] = number_format($balance, 2, '.', '');
  675. $balance = $balance - $item['pay_amount'];
  676. } else {
  677. $item['balance'] = number_format($balance, 2, '.', '');
  678. $balance = $balance + $item['pay_amount'];
  679. }
  680. $data[] = $item;
  681. }
  682. $total = count($data);
  683. $start = ($page - 1) * $pageSize;
  684. $rows = array_slice($data, $start, $pageSize);
  685. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  686. }
  687. /**
  688. * @Desc 佣金记录
  689. * @Author Gorden
  690. * @Date 2024/9/30 14:52
  691. *
  692. * @param Request $request
  693. * @return Response
  694. */
  695. public static function commissionList(Request $request)
  696. {
  697. $memberId = $request->get('member_id');
  698. $page = $request->get('page', 1);
  699. $pageSize = $request->get('pageSize', 20);
  700. $rows = MemberAccountList::where('join_member_account_list_member_id', $memberId)
  701. ->where('member_account_list_attr', 'IN');
  702. $total = $rows->count();
  703. $rows = $rows->forPage($page, $pageSize)
  704. ->get()
  705. ->toArray();
  706. foreach ($rows as &$row) {
  707. if (!empty($row['member_account_list_json'])) {
  708. $memberAccountListJson = json_decode($row['member_account_list_json'], true);
  709. if ($memberAccountListJson['master_member_id']) {
  710. $row['master_member_name'] = MemberService::getMemberNameByMemberId($memberAccountListJson['master_member_id']);
  711. }
  712. }
  713. }
  714. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  715. }
  716. /**
  717. * @Desc 我的粉丝列表
  718. * @Author Gorden
  719. * @Date 2024/9/20 10:22
  720. *
  721. * @param Request $request
  722. */
  723. public static function fansList(Request $request)
  724. {
  725. $memberId = $request->get('member_id');
  726. $name = $request->get('name', '');
  727. $mobile = $request->get('mobile', '');
  728. $memberIds = [];
  729. $memberInviteIds = [];
  730. if (!empty($name)) {
  731. $memberIds = MemberCert::where('member_cert_name', 'like', '%' . $name . '%')->pluck('join_cert_member_id')->toArray();
  732. $memberInviteIds = Member::whereIn('member_id', $memberIds)->pluck('join_invite_member_id')->toArray();
  733. }
  734. if (!empty($mobile)) {
  735. $members = Member::where('member_mobile', 'like', '%' . $mobile . '%')
  736. ->select('member_id', 'join_invite_member_id')
  737. ->get()
  738. ->toArray();
  739. $memberIds2 = array_column($members, 'member_id');
  740. $memberInviteIds2 = array_column($members, 'join_invite_member_id');
  741. $memberIds = array_merge($memberIds, $memberIds2);
  742. $memberInviteIds = array_merge($memberInviteIds, $memberInviteIds2);
  743. }
  744. $fans1 = Member::with([
  745. 'info' => function ($query) {
  746. $query->select('join_info_member_id', 'member_info_nickname', 'member_info_headimg');
  747. },
  748. 'cert' => function ($query) {
  749. $query->select('join_cert_member_id', 'member_cert_name');
  750. },
  751. 'role' => function ($query) {
  752. $query->select('member_role_id', 'member_role_name');
  753. }
  754. ])->where('join_invite_member_id', $memberId)
  755. ->when(!empty($memberIds), function ($query) use ($memberIds, $memberInviteIds) {
  756. $allSub = array_merge($memberIds, $memberInviteIds);
  757. $query->whereIn('member_id', $allSub);
  758. })
  759. ->select('member_id', 'join_member_role_id', 'member_id as id', 'join_invite_member_id as pid', 'member_partner_json', 'member_mobile', 'member_addtimes', 'member_is_owner', 'member_is_vip', 'member_is_partner', 'member_is_referrer')
  760. ->get()
  761. ->toArray();
  762. $fans1Ids = array_column($fans1, 'id');
  763. $fans2 = Member::with([
  764. 'info' => function ($query) {
  765. $query->select('join_info_member_id', 'member_info_nickname', 'member_info_headimg');
  766. },
  767. 'cert' => function ($query) {
  768. $query->select('join_cert_member_id', 'member_cert_name');
  769. },
  770. 'role' => function ($query) {
  771. $query->select('member_role_id', 'member_role_name');
  772. }
  773. ])->whereIn('join_invite_member_id', $fans1Ids)
  774. ->when(!empty($memberIds), function ($query) use ($memberIds) {
  775. $query->whereIn('member_id', $memberIds);
  776. })
  777. ->select('member_id', 'join_member_role_id', 'member_id as id', 'join_invite_member_id as pid', 'member_partner_json', 'member_mobile', 'member_addtimes', 'member_is_owner', 'member_is_vip', 'member_is_partner', 'member_is_referrer')
  778. ->get()
  779. ->toArray();
  780. $fans = array_merge($fans1, $fans2);
  781. foreach ($fans as &$fan) {
  782. $memberMobile = $fan['member_mobile'] ?? '';
  783. // $memberNickname = $fan['info'] && $fan['info']['member_info_nickname'] ? $fan['info']['member_info_nickname'] : '';
  784. $memberCertName = $fan['cert'] && $fan['cert']['member_cert_name'] ? $fan['cert']['member_cert_name'] : '';
  785. $fan['member_name'] = '';
  786. if (!empty($memberCertName) && !empty($memberMobile)) {
  787. $fan['member_name'] = $memberCertName . '-' . $memberMobile;
  788. } elseif (!empty($memberCertName)) {
  789. $fan['member_name'] = $memberCertName;
  790. } elseif (!empty($memberMobile)) {
  791. $fan['member_name'] = $memberMobile;
  792. }
  793. if (!empty($fan['info']) && substr($fan['info']['member_info_headimg'], 0, 4) == 'http') {
  794. $fan['member_info_headimg'] = $fan['info']['member_info_headimg'];
  795. } else {
  796. $fan['member_info_headimg'] = 'https://img.wanyuewellness.com.cn/images/avatar_default.png';
  797. }
  798. // 等级名称
  799. $fan['role_name'] = $fan['role'] && $fan['role']['member_role_name'] ? $fan['role']['member_role_name'] : '';
  800. unset($fan['info'], $fan['cert'], $fan['role']);
  801. }
  802. $tree = new Tree($fans);
  803. return json_success('success', $tree->getTree());
  804. }
  805. /**
  806. * 格式化树
  807. * @param $items
  808. * @return Response
  809. */
  810. protected static function formatTree($items): Response
  811. {
  812. $format_items = [];
  813. foreach ($items as $item) {
  814. $format_items[] = [
  815. 'name' => $item->title ?? $item->name ?? $item->id,
  816. 'value' => (string)$item->id,
  817. 'id' => $item->id,
  818. 'pid' => $item->pid,
  819. ];
  820. }
  821. $tree = new Tree($format_items);
  822. return json_success('success', $tree->getTree());
  823. }
  824. public static function clearWelfare(Request $request)
  825. {
  826. $memberId = $request->post('member_id');
  827. $payTime = $request->post('pay_paytimes', date('Y-m-d H:i:s'));
  828. $payTime = date('Y-m-d H:i:s', strtotime($payTime));
  829. $payRemark = $request->post('pay_remark', '');
  830. $clearPwd = $request->post('clear_password');
  831. if (!$clearPwd || $clearPwd != '123456') {
  832. return json_fail('清零密码错误');
  833. }
  834. Db::beginTransaction();
  835. try {
  836. $account = MemberAccount::where('join_account_member_id', $memberId)
  837. ->where('member_account_classify', 'WELFARE')
  838. ->where('member_account_status', 'ACTIVED')
  839. ->first();
  840. if (!$account) {
  841. throw new BusinessException("账户异常");
  842. }
  843. if ($account->member_account_surplus <= 0) {
  844. throw new BusinessException("账户余额为0,无需清零");
  845. }
  846. // 创建清除记录
  847. PayDetail::insert([
  848. 'join_pay_member_id' => $memberId,
  849. 'pay_status' => 'SUCCESS',
  850. 'pay_category' => 'CLEAR',
  851. 'pay_amount' => $account->member_account_surplus,
  852. 'pay_paytimes' => $payTime,
  853. 'pay_prepayid' => $memberId . '-WELFARE',
  854. 'pay_remark' => $payRemark,
  855. 'pay_addtimes' => time()
  856. ]);
  857. // 账户归零
  858. $account->member_account_expend = $account->member_account_expend + $account->member_account_surplus;
  859. $account->member_account_surplus = 0;
  860. $account->save();
  861. Db::commit();
  862. return json_success('success');
  863. } catch (BusinessException $e) {
  864. Db::rollBack();
  865. return json_fail($e->getMessage());
  866. } catch (\Exception $e) {
  867. dump($e->getMessage());
  868. Db::rollBack();
  869. return json_fail('清零失败');
  870. }
  871. }
  872. public static function balanceInfo(Request $request)
  873. {
  874. $memberId = $request->get('member_id', '');
  875. $page = $request->get('page', 1);
  876. $pageSize = $request->get('pageSize', 20);
  877. $account = MemberAccount::where('join_account_member_id', $memberId)
  878. ->where('member_account_classify', 'CASH')
  879. ->first();
  880. if (!$account) {
  881. return json_fail('暂无数据');
  882. }
  883. $balance = $account->member_account_surplus + $account->member_account_added;
  884. $info = PayDetail::where(function ($query) use ($memberId) {
  885. $query->where('join_pay_member_id', $memberId)
  886. ->whereIn('pay_category', ['RECHARGE'])
  887. ->where('pay_prepayid', '<>', $memberId . '-WELFARE')
  888. ->where('pay_status', 'SUCCESS');
  889. })->orWhere(function ($query) use ($memberId) {
  890. $query->where('join_pay_member_id', $memberId)
  891. ->where('pay_prepayid', 'like', '%CASH%')
  892. ->where('pay_status', 'SUCCESS');
  893. })->select('join_pay_object_json', 'join_pay_member_id', 'pay_category', 'join_pay_order_id', 'pay_extend_json', 'pay_addtimes', 'pay_amount');
  894. // ->orderByDesc('pay_addtimes')
  895. // ->get()
  896. // ->toArray();
  897. $memberAccountList = MemberAccountList::where('join_member_account_list_member_id', $memberId)
  898. ->where('member_account_list_status', 'ACTIVED')
  899. ->selectRaw('
  900. member_account_list_extend_json as join_pay_object_json,
  901. join_member_account_list_member_id as join_pay_member_id,
  902. member_account_list_attr as pay_category,
  903. join_list_member_account_nbr as pay_prepayid,
  904. member_account_list_extend_json as pay_extend_json,
  905. member_account_list_addtimes as pay_addtimes,
  906. member_account_list_amount as pay_amount');
  907. $info = $info->union($memberAccountList)
  908. ->orderByDesc('pay_addtimes')
  909. ->get()
  910. ->toArray();
  911. $data = [];
  912. foreach ($info as $key => $item) {
  913. $payObjectJson = [];
  914. if (!empty($item['join_pay_object_json'])) {
  915. $payObjectJson = json_decode($item['join_pay_object_json'], true);
  916. }
  917. // if ($item['pay_category'] == 'PARTNER') {
  918. // $payObjectJson = json_decode($item['join_pay_object_json'], true);
  919. // if (!Order::where('order_id', $payObjectJson['order_id'])->where('order_is_complete', 'Y')->exists()) {
  920. // continue;
  921. // }
  922. // }
  923. // if ($item['pay_category'] == 'REFERRER') {
  924. // $payObjectJson = json_decode($item['join_pay_object_json'], true);
  925. // if (!Order::where('order_id', $payObjectJson['order_id'])->where('order_is_complete', 'Y')->exists()) {
  926. // continue;
  927. // }
  928. // }
  929. $categoryIds = [];
  930. if (!empty($item['join_pay_order_id'])) {
  931. $goodsIds = [];
  932. if (in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE', 'REFERRER'])) {
  933. if (isset($payObjectJson['recharge_goods_id'])) {
  934. $goodsIds = [$payObjectJson['recharge_goods_id']];
  935. }
  936. } else {
  937. $orderIds = Order::where('order_groupby', $item['join_pay_order_id'])->pluck('order_id');
  938. $goodsIds = OrderSheet::whereIn('join_sheet_order_id', $orderIds)->pluck('join_sheet_goods_id');
  939. }
  940. $categoryIds = Goods::whereIn('goods_id', $goodsIds)->pluck('join_goods_category_id');
  941. }
  942. $categoryName = [];
  943. foreach ($categoryIds as $id) {
  944. $category = SysCategory::where('category_id', $id)->first();
  945. if (!empty($category->category_super_path)) {
  946. $path = explode('#', $category->category_super_path);
  947. $ids = array_filter($path);
  948. $categoryName[] = SysCategory::where('category_id', current($ids))->value('category_name');
  949. } else {
  950. $categoryName[] = $category->category_name;
  951. }
  952. }
  953. $item['goods_category'] = implode(',', array_unique($categoryName));
  954. if (mb_substr($item['goods_category'], 0, 7) == '自定义金额充值') {
  955. $item['goods_category'] = '自定义金额充值';
  956. } else if (mb_substr($item['goods_category'], 0, 7) == '会员合伙人产品') {
  957. $item['goods_category'] = '会员合伙人充值';
  958. }
  959. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND', 'GIVE', 'PARTNER', 'IN'])) {
  960. $item['balance_type'] = 'add';
  961. } else {
  962. $item['balance_type'] = 'cut';
  963. }
  964. if ($key == 0 && in_array($item['pay_category'], ['RECHARGE', 'REFUND', 'GIVE'])) {
  965. if (!empty($item['pay_extend_json']) && !in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE'])) {
  966. $extendJson = json_decode($item['pay_extend_json'], true);
  967. if (!isset($extendJson['added_amount'])) {
  968. $extendJson['added_amount'] = 0;
  969. }
  970. // 计划任务还没跑
  971. // if ($item['pay_category'] == 'RECHARGE' && (!isset($extendJson['notify']) || $extendJson['notify'] != 'success')) {
  972. // continue;
  973. // }
  974. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  975. $data[] = [
  976. 'join_pay_member_id' => $item['join_pay_member_id'],
  977. 'pay_addtimes' => $item['pay_addtimes'],
  978. 'pay_amount' => $extendJson['added_amount'],
  979. 'pay_category' => $item['pay_category'] == 'GIVE' ? 'GIVE' : 'ADDED',
  980. 'balance' => number_format($balance, 2, '.', ''),
  981. 'balance_type' => 'add',
  982. ];
  983. }
  984. $balance = $balance - $extendJson['added_amount'];
  985. }
  986. if (in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE'])) {
  987. $addedAmount = 0;
  988. if (!isset($payObjectJson['recharge_config'])) {
  989. $addedAmount = 0;
  990. }
  991. if (isset($payObjectJson['recharge_config']) && !empty($payObjectJson['recharge_config']['nbr']) && floatval($payObjectJson['recharge_config']['nbr'] > 0)) {
  992. $addedAmount = $payObjectJson['recharge_config']['nbr'];
  993. $data[] = [
  994. 'join_pay_member_id' => $item['join_pay_member_id'],
  995. 'pay_addtimes' => $item['pay_addtimes'],
  996. 'pay_amount' => $addedAmount,
  997. 'pay_category' => 'ADDED',
  998. 'balance' => number_format($balance, 2, '.', ''),
  999. 'balance_type' => 'add',
  1000. ];
  1001. }
  1002. $balance = $balance - $addedAmount;
  1003. }
  1004. $item['balance'] = number_format($balance, 2, '.', '');
  1005. $balance = $balance - $item['pay_amount'];
  1006. if ($item['pay_category'] != 'GIVE') {
  1007. $data[] = $item;
  1008. }
  1009. continue;
  1010. }
  1011. if (in_array($item['pay_category'], ['RECHARGE', 'REFUND', 'GIVE', 'PARTNER', 'COMBINE', 'IN'])) {
  1012. if (!empty($item['pay_extend_json']) && !in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE'])) {
  1013. $extendJson = json_decode($item['pay_extend_json'], true);
  1014. if (isset($extendJson['added_amount']) && floatval($extendJson['added_amount']) > 0) {
  1015. $data[] = [
  1016. 'join_pay_member_id' => $item['join_pay_member_id'],
  1017. 'pay_addtimes' => $item['pay_addtimes'],
  1018. 'pay_amount' => $extendJson['added_amount'],
  1019. 'pay_category' => $item['pay_category'] == 'GIVE' ? 'GIVE' : 'ADDED',
  1020. 'balance' => number_format($balance, 2, '.', ''),
  1021. 'balance_type' => 'add',
  1022. ];
  1023. $balance = $balance - $extendJson['added_amount'];
  1024. }
  1025. }
  1026. if (in_array($item['join_pay_order_id'], ['PARTNER', 'COMBINE'])) {
  1027. $addedAmount = 0;
  1028. if (!isset($payObjectJson['recharge_config'])) {
  1029. $addedAmount = 0;
  1030. }
  1031. if (isset($payObjectJson['recharge_config']) && !empty($payObjectJson['recharge_config']['nbr']) && floatval($payObjectJson['recharge_config']['nbr'] > 0)) {
  1032. $addedAmount = $payObjectJson['recharge_config']['nbr'];
  1033. $data[] = [
  1034. 'join_pay_member_id' => $item['join_pay_member_id'],
  1035. 'pay_addtimes' => $item['pay_addtimes'],
  1036. 'pay_amount' => $addedAmount,
  1037. 'pay_category' => 'ADDED',
  1038. 'balance' => number_format($balance, 2, '.', ''),
  1039. 'balance_type' => 'add',
  1040. ];
  1041. }
  1042. $balance = $balance - $addedAmount;
  1043. }
  1044. $item['balance'] = number_format($balance, 2, '.', '');
  1045. $balance = $balance - $item['pay_amount'];
  1046. } else {
  1047. $item['balance'] = number_format($balance, 2, '.', '');
  1048. $balance = $balance + $item['pay_amount'];
  1049. }
  1050. if ($item['pay_category'] != 'GIVE') {
  1051. $data[] = $item;
  1052. }
  1053. }
  1054. $total = count($data);
  1055. $start = ($page - 1) * $pageSize;
  1056. $rows = array_slice($data, $start, $pageSize);
  1057. return json_success('', compact('rows', 'page', 'pageSize', 'total'));
  1058. }
  1059. public static function pointInfo($memberId)
  1060. {
  1061. $account = MemberAccount::where('join_account_member_id', $memberId)
  1062. ->where('member_account_classify', 'POINTS')
  1063. ->first();
  1064. if (!$account) {
  1065. return json_fail('暂无数据');
  1066. }
  1067. $balance = $account->member_account_surplus + $account->member_account_added;
  1068. $points = ClientPoints::where('join_client_points_member_id', $memberId)->orderBy('client_points_addtimes', 'DESC')->get()->toArray();
  1069. $nowPoint = 0;
  1070. foreach ($points as $key => &$point) {
  1071. $point['goods_category'] = '其他';
  1072. if (!empty($point['join_client_points_goods_id'])) {
  1073. $categoryId = Goods::where('goods_id', $point['join_client_points_goods_id'])->pluck('join_goods_category_id');
  1074. $category = SysCategory::where('category_id', $categoryId)->first();
  1075. if (!empty($category->category_super_path)) {
  1076. $path = explode('#', $category->category_super_path);
  1077. $ids = array_filter($path);
  1078. $point['goods_category'] = SysCategory::where('category_id', current($ids))->value('category_name');
  1079. } else {
  1080. $point['goods_category'] = $category->category_name;
  1081. }
  1082. }
  1083. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
  1084. $point['balance_type'] = 'add';
  1085. } else {
  1086. $point['balance_type'] = 'cut';
  1087. }
  1088. if ($key == 0) {
  1089. $point['balance'] = number_format($balance, 2, '.', '');
  1090. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
  1091. $balance = $balance - $point['client_points_nbr'];
  1092. } else {
  1093. $balance = $balance + $point['client_points_nbr'];
  1094. }
  1095. continue;
  1096. }
  1097. if (in_array($point['client_points_category'], ["评价", "消费", "活动", "赠送", '登录活动积分'])) {
  1098. $point['balance'] = number_format($balance, 2, '.', '');
  1099. $balance = $balance - $point['client_points_nbr'];
  1100. // $point['balance'] = $balance = $nowPoint = number_format($balance - $point['client_points_nbr'], 2, '.', '');
  1101. } else {
  1102. $point['balance'] = number_format($balance, 2, '.', '');
  1103. $balance = $balance + $point['client_points_nbr'];
  1104. // $point['balance'] = $balance = $nowPoint = number_format($balance + $point['client_points_nbr'], 2, '.', '');
  1105. }
  1106. }
  1107. return json_success('', $points);
  1108. }
  1109. /**
  1110. * @Desc 添加会员
  1111. * @Author Gorden
  1112. * @Date 2024/3/25 13:40
  1113. *
  1114. * @param $params
  1115. * @return \support\Response
  1116. */
  1117. public static function add($params)
  1118. {
  1119. Db::beginTransaction();
  1120. try {
  1121. // 排重
  1122. if (Member::where('member_mobile', $params['mobile'])->where('member_status', 'ACTIVED')->exists()) {
  1123. throw new BusinessException("会员已存在");
  1124. }
  1125. $memberId = self::generateMemberId();
  1126. // 先写主表,要ID
  1127. $memberData = [
  1128. 'member_id' => $memberId,
  1129. 'member_is_owner' => $params['is_owner'] ?? 'N',
  1130. 'member_classify' => $params['classify'] ?? '',
  1131. 'member_status' => $params['status'] ?? 'PENDING',
  1132. 'member_mobile' => $params['mobile'] ?? '',
  1133. 'member_category' => $params['member_category'] ?? '后台添加',
  1134. 'member_invite_code' => self::generateInviteCode(),
  1135. // 'member_from' => $params['source'],
  1136. // 'member_extend_json' => json_encode(['come_from' => $params['source']]),
  1137. 'member_addtimes' => time(),
  1138. ];
  1139. $extendJson['come_from'] = $params['source'];
  1140. if (!empty($params['user_id'])) {
  1141. $deptId = SysUser::where('user_id', $params['user_id'])->value('join_user_dept_id');
  1142. if (!$deptId) {
  1143. throw new BusinessException('请先关联业务员和门店');
  1144. }
  1145. $extendJson['belong'] = ['user_id' => $params['user_id'], 'premises' => $deptId];
  1146. }
  1147. $memberData['member_extend_json'] = json_encode($extendJson);
  1148. Member::insert($memberData);
  1149. // 账户表
  1150. $accountData = [
  1151. 'join_account_member_id' => $memberId,
  1152. 'member_account_classify' => 'POINTS',
  1153. 'member_account_status' => 'ACTIVED',
  1154. 'member_account_category' => 'NORMAL',
  1155. 'member_account_nbr' => $memberId . '-POINTS',
  1156. 'member_account_name' => '积分账户',
  1157. 'member_account_addtimes' => time()
  1158. ];
  1159. // 积分账户
  1160. MemberAccount::insert($accountData);
  1161. $accountData['member_account_classify'] = 'CASH';
  1162. $accountData['member_account_nbr'] = $memberId . '-CASH';
  1163. $accountData['member_account_name'] = '余额账户';
  1164. // 现金/余额账户
  1165. MemberAccount::insert($accountData);
  1166. // 福利账户
  1167. // if (!empty($params['member_classify']) && $params['member_classify'] == 'EMPLOY'){
  1168. // $welfareData = [
  1169. // 'join_account_member_id'=>$memberId,
  1170. // 'member_account_classify'=>'WELFARE',
  1171. // 'member_account_status'=>'ACTIVED',
  1172. // 'member_account_category'=>'NORMAL',
  1173. // 'member_account_nbr'=>$memberId.'-WELFARE',
  1174. // 'member_account_name'=>'福利账户',
  1175. // 'member_account_addtimes'=>time()
  1176. // ];
  1177. // MemberAccount::insert($welfareData);
  1178. // }
  1179. // member cert
  1180. $certData = [
  1181. 'join_cert_member_id' => $memberId,
  1182. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  1183. 'member_cert_name' => $params['cert_name'] ?? '',
  1184. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  1185. 'member_cert_birth' => !empty($params['birth']) ? date('Y-m-d', strtotime($params['birth'])) : '',
  1186. 'member_cert_gender' => $params['gender'] ?? '',
  1187. // 'member_cert_province' => !empty($params['province']) ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
  1188. // 'member_cert_city' => $params['city'] ?? '',
  1189. // 'member_cert_addr' => $params['addr'] ?? '',
  1190. // 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  1191. // 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  1192. ];
  1193. MemberCert::insert($certData);
  1194. // member info
  1195. $infoData = [
  1196. 'join_info_member_id' => $memberId,
  1197. 'member_info_nickname' => $params['account_name'] ?? '',
  1198. 'member_info_headimg' => !empty($params['avatar']) ? getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']) : '',
  1199. 'member_info_referee' => $params['member_info_referee'] ?? '',
  1200. 'member_info_business' => $params['member_info_business'] ?? '',
  1201. 'member_info_service' => $params['member_info_service'] ?? '',
  1202. 'member_info_city' => !empty($params['province']) ? implode('-', $params['province']) : '',
  1203. 'member_info_address' => $params['member_info_address'] ?? '',
  1204. 'member_info_birthday' => !empty($params['birth']) ? date('Y-m-d', strtotime($params['birth'])) : '',
  1205. 'member_info_gender' => $params['gender'] ?? '',
  1206. ];
  1207. MemberInfo::insert($infoData);
  1208. Db::commit();
  1209. } catch (BusinessException $e) {
  1210. Db::rollBack();
  1211. return json_fail($e->getMessage());
  1212. } catch (\Exception $e) {
  1213. Db::rollBack();
  1214. dump($e->getMessage() . ';line:' . $e->getLine());
  1215. return json_fail("数据添加失败");
  1216. }
  1217. return json_success('数据添加成功', ['member_id' => $memberId]);
  1218. }
  1219. /**
  1220. * @Desc 编辑会员/ 业主
  1221. * @Author Gorden
  1222. * @Date 2024/4/20 15:18
  1223. *
  1224. * @param $params
  1225. * @return \support\Response
  1226. */
  1227. public static function update($params)
  1228. {
  1229. Db::beginTransaction();
  1230. try {
  1231. $memberId = $params['member_id'];
  1232. $member = Member::where('member_id', $params['member_id'])->first();
  1233. if (!$member) {
  1234. throw new BusinessException('数据异常');
  1235. }
  1236. $extendJson = [];
  1237. if (!empty($member->member_extend_json)) {
  1238. $extendJson = json_decode($member->member_extend_json, true);
  1239. }
  1240. $extendJson['come_from'] = $params['source'];
  1241. // 门店、业务员
  1242. if (!empty($params['user_id'])) {
  1243. $deptId = SysUser::where('user_id', $params['user_id'])->value('join_user_dept_id');
  1244. if (!$deptId) {
  1245. throw new BusinessException('您选择的业务员没有关联门店');
  1246. }
  1247. $extendJson['belong'] = ['user_id' => $params['user_id'], 'premises' => $deptId];
  1248. }
  1249. // 先写主表,要ID
  1250. $memberData = [
  1251. 'member_id' => $memberId,
  1252. 'member_is_owner' => $params['is_owner'],
  1253. 'member_classify' => $params['member_classify'],
  1254. 'member_status' => $params['status'],
  1255. // 'member_mobile' => $params['mobile'],
  1256. // 'member_from' => $params['source'],
  1257. 'member_extend_json' => json_encode($extendJson)
  1258. ];
  1259. Member::where('member_id', $params['member_id'])->update($memberData);
  1260. // member cert
  1261. $certData = [
  1262. 'join_cert_member_id' => $memberId,
  1263. 'member_cert_nation' => $params['member_cert_nation'] ?? '',
  1264. 'member_cert_name' => $params['cert_name'] ?? '',
  1265. 'member_cert_nbr' => $params['cert_nbr'] ?? '',
  1266. 'member_cert_birth' => $params['birth'] ? date('Y-m-d', strtotime($params['birth'])) : '',
  1267. 'member_cert_gender' => $params['gender'] ?? '',
  1268. // 'member_cert_province' => $params['province'] ? json_encode($params['province'], JSON_UNESCAPED_UNICODE) : '[]',
  1269. // 'member_cert_city' => $params['city'] ?? '',
  1270. // 'member_cert_addr' => $params['addr'] ?? '',
  1271. 'member_cert_face' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_face']),
  1272. 'member_cert_photo' => str_replace(getenv('STORAGE_DOMAIN'), '', $params['member_cert_photo']),
  1273. ];
  1274. if (!MemberCert::where('join_cert_member_id', $memberId)->exists()) {
  1275. MemberCert::insert($certData);
  1276. } else {
  1277. MemberCert::where('join_cert_member_id', $params['member_id'])->update($certData);
  1278. }
  1279. // member info
  1280. $avatar = '';
  1281. if ($params['avatar'] && (strpos($params['avatar'], getenv('APP_IMAGE_DOMAIN')) !== false || strpos($params['avatar'], getenv('SYSTEM_AVATAR_DOMAIN')) !== false)) {
  1282. $avatar = $params['avatar'];
  1283. } else if ($params['avatar']) {
  1284. $avatar = getenv('SYSTEM_AVATAR_DOMAIN') . str_replace(getenv('STORAGE_DOMAIN'), '', $params['avatar']);
  1285. }
  1286. $infoData = [
  1287. 'join_info_member_id' => $memberId,
  1288. 'member_info_nickname' => $params['account_name'],
  1289. 'member_info_headimg' => $avatar,
  1290. 'member_info_referee' => $params['member_info_referee'] ?? '',
  1291. 'member_info_business' => $params['member_info_business'] ?? '',
  1292. 'member_info_service' => $params['member_info_service'] ?? '',
  1293. 'member_info_city' => !empty($params['province']) ? implode('-', $params['province']) : '',
  1294. 'member_info_address' => $params['member_info_address'] ?? '',
  1295. 'member_info_birthday' => $params['birth'] ? date('Y-m-d', strtotime($params['birth'])) : '',
  1296. 'member_info_gender' => $params['gender'] ?? '',
  1297. ];
  1298. if (!MemberInfo::where('join_info_member_id', $params['member_id'])->exists()) {
  1299. MemberInfo::insert($infoData);
  1300. } else {
  1301. MemberInfo::where('join_info_member_id', $params['member_id'])->update($infoData);
  1302. }
  1303. // 福利账户
  1304. if (!empty($params['member_classify']) && $params['member_classify'] == 'EMPLOY' && !MemberAccount::where('member_account_nbr', $memberId . '-WELFARE')->exists()) {
  1305. $welfareData = [
  1306. 'join_account_member_id' => $memberId,
  1307. 'member_account_classify' => 'WELFARE',
  1308. 'member_account_status' => 'ACTIVED',
  1309. 'member_account_category' => 'NORMAL',
  1310. 'member_account_nbr' => $memberId . '-WELFARE',
  1311. 'member_account_name' => '福利账户',
  1312. 'member_account_addtimes' => time()
  1313. ];
  1314. MemberAccount::insert($welfareData);
  1315. }
  1316. Db::commit();
  1317. } catch (BusinessException $e) {
  1318. Db::rollBack();
  1319. dump($e->getMessage() . ';line:' . $e->getLine());
  1320. return json_fail($e->getMessage());
  1321. } catch (\Exception $e) {
  1322. Db::rollBack();
  1323. dump($e->getMessage() . ';line:' . $e->getLine());
  1324. return json_fail("数据更新失败");
  1325. }
  1326. return json_success('数据更新成功');
  1327. }
  1328. /**
  1329. * @Desc 会员关联设备列表
  1330. * @Author Gorden
  1331. * @Date 2024/4/7 9:52
  1332. *
  1333. * @param $id
  1334. * @return \support\Response
  1335. */
  1336. public static function deviceList($id)
  1337. {
  1338. $family = Family::where('join_family_creator_member_id', $id)->get()->toArray();
  1339. $familyMemberIds = '';
  1340. if ($family) {
  1341. $familyIds = array_column($family, 'family_id');
  1342. $familyMember = FamilyMember::whereIn('join_family_id', $familyIds)->get()->toArray();
  1343. $familyMemberIds = array_column($familyMember, 'join_family_member_id');
  1344. }
  1345. $rows = MemberDevice::leftJoin('device', 'device.device_id', '=', 'member_device.join_member_device_id')
  1346. ->leftJoin('member', 'member.member_id', '=', 'member_device.join_device_member_id')
  1347. ->leftJoin('family_member', 'family_member.join_family_member_id', '=', 'member_device.join_device_member_id')
  1348. ->select('device.device_category', 'device.device_name', 'device.device_type', 'member.member_mobile', 'member_device.*', 'family_member.family_member_name')
  1349. ->when(!empty($familyMemberIds), function ($query) use ($familyMemberIds) {
  1350. $query->whereIn('member_device.join_device_master_member_id', $familyMemberIds);
  1351. })
  1352. ->when(empty($familyMemberIds), function ($query) use ($id) {
  1353. $query->where('member_device.join_device_master_member_id', $id);
  1354. })->orderBy('member_device_addtimes', 'desc')
  1355. ->get()
  1356. ->toArray();
  1357. return json_success('', ['rows' => $rows]);
  1358. }
  1359. /**
  1360. * @Desc 绑定设备
  1361. * @Author Gorden
  1362. * @Date 2024/4/7 10:27
  1363. *
  1364. * @param Request $request
  1365. * @return \support\Response
  1366. */
  1367. public static function addDevice(Request $request)
  1368. {
  1369. $params = $request->post();
  1370. Db::beginTransaction();
  1371. try {
  1372. $data = [
  1373. 'join_device_member_id' => $params['join_device_member_id'] ?? '',
  1374. 'join_device_master_member_id' => $params['join_device_master_member_id'],
  1375. 'join_member_device_id' => $params['join_member_device_id'],
  1376. 'member_device_status' => $params['member_device_status'],
  1377. 'member_device_key' => $params['member_device_key'] ?? '',
  1378. 'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
  1379. 'member_device_remark' => $params['member_device_remark'] ?? null,
  1380. 'member_device_addtimes' => time(),
  1381. ];
  1382. MemberDevice::insert($data);
  1383. $device = Device::where('device_id', $params['join_member_device_id'])->whereIn('device_status', ['PROCESSING', 'PENDING'])->first();
  1384. // 激活设备
  1385. if (!$device) {
  1386. Db::rollBack();
  1387. return json_fail('当前设备不是可激活状态');
  1388. }
  1389. $device->device_status = 'ACTIVED';
  1390. $device->save();
  1391. Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => 'ACTIVED']);
  1392. _syslog("绑定设备", "用户【" . ($params['join_device_member_id'] ?? $params['join_device_master_member_id']) . '】,绑定设备【' . $device->device_name . '】');
  1393. Db::commit();
  1394. } catch (\Exception $e) {
  1395. Db::rollBack();
  1396. dump($e->getMessage());
  1397. return json_fail('绑定失败');
  1398. }
  1399. return json_success('绑定成功');
  1400. }
  1401. public static function updateDevice(Request $request)
  1402. {
  1403. $params = $request->post();
  1404. Db::beginTransaction();
  1405. try {
  1406. $data = [
  1407. 'member_device_status' => $params['member_device_status'],
  1408. 'member_device_key' => $params['member_device_key'],
  1409. 'join_device_member_id' => $params['join_device_member_id'],
  1410. 'member_device_config_json' => !empty($params['member_device_config_json']) ? $params['member_device_config_json'] : null,
  1411. 'member_device_remark' => $params['member_device_remark'] ?? null,
  1412. ];
  1413. MemberDevice::where('member_device_id', $request->post('member_device_id'))->update($data);
  1414. $device = Device::where('device_id', $params['join_member_device_id'])->first();
  1415. if ($device->device_status != $params['member_device_status']) {
  1416. $device->device_status = $params['member_device_status'];
  1417. $device->save();
  1418. }
  1419. // Device::where('device_id', $params['join_member_device_id'])->update(['device_status' => $params['member_device_status']]);
  1420. Db::commit();
  1421. _syslog("更新绑定设备", "用户【" . ($params['join_device_member_id'] == "" ? $params['join_device_member_id'] : $params['join_device_master_member_id']) . '】,绑定设备【' . $device->device_name . '】');
  1422. } catch (\Exception $e) {
  1423. Db::rollBack();
  1424. dump($e->getMessage());
  1425. return json_fail('绑定更新失败');
  1426. }
  1427. return json_success('绑定更新成功');
  1428. }
  1429. public static function deleteDevice(Request $request)
  1430. {
  1431. try {
  1432. Db::beginTransaction();
  1433. $memberDevice = MemberDevice::where('member_device_id', $request->post('member_device_id'))->first();
  1434. if (!$memberDevice) {
  1435. return json_fail('数据不存在');
  1436. }
  1437. $device = Device::where('device_id', $memberDevice->join_member_device_id)->first();
  1438. $device->device_status = "DISABLED";
  1439. $device->save();
  1440. // Device::where('device_id', $memberDevice->join_member_device_id)->update(['device_status' => 'DISABLED']);
  1441. $memberDevice->delete();
  1442. Db::commit();
  1443. _syslog("解除绑定设备", "用户【" . ($memberDevice->join_device_member_id == "" ? $memberDevice->join_device_member_id : $memberDevice->join_device_master_member_id) . '】,解除绑定设备【' . $device->device_name . '】');
  1444. return json_success('解除绑定成功');
  1445. } catch (\Exception $e) {
  1446. Db::rollBack();
  1447. return json_fail('绑定失败');
  1448. }
  1449. }
  1450. /**
  1451. * 手动创建会员
  1452. */
  1453. public static function createMember($params)
  1454. {
  1455. $memberId = $params['member_id'] ?? '';
  1456. if (!$memberId) {
  1457. throw new BusinessException("参数异常");
  1458. }
  1459. // 主表
  1460. $memberData = [
  1461. 'member_id' => $memberId,
  1462. 'member_is_owner' => 'N',
  1463. 'member_classify' => 'MEMBER',
  1464. 'member_status' => 'ACTIVED',
  1465. 'member_mobile' => $params['mobile'],
  1466. 'member_invite_code' => self::generateInviteCode(),
  1467. 'member_extend_json' => json_encode(['come_from' => 'SYSTEM']),
  1468. 'member_addtimes' => time()
  1469. ];
  1470. Member::insert($memberData);
  1471. // 账户表
  1472. $accountData = [
  1473. 'join_account_member_id' => $memberId,
  1474. 'member_account_classify' => 'POINTS',
  1475. 'member_account_status' => 'ACTIVED',
  1476. 'member_account_category' => 'NORMAL',
  1477. 'member_account_nbr' => $memberId . '-POINTS',
  1478. 'member_account_name' => '积分账户',
  1479. 'member_account_addtimes' => time()
  1480. ];
  1481. // 积分账户
  1482. MemberAccount::insert($accountData);
  1483. $accountData['member_account_classify'] = 'CASH';
  1484. $accountData['member_account_nbr'] = $memberId . '-CASH';
  1485. $accountData['member_account_name'] = '余额账户';
  1486. // 现金/余额账户
  1487. MemberAccount::insert($accountData);
  1488. // info
  1489. $infoData = [
  1490. 'join_info_member_id' => $memberId,
  1491. 'member_info_nickname' => $params['username']
  1492. ];
  1493. MemberInfo::insert($infoData);
  1494. }
  1495. private static function generateMemberId()
  1496. {
  1497. $id = SysSerial::getSerial();
  1498. return "MR" . date('ymdHi') . random_string(4, 'up');
  1499. }
  1500. public static function getMemberName($mobile, $certName, $nickname)
  1501. {
  1502. $name = '';
  1503. if (!empty($certName)) {
  1504. $name = $certName;
  1505. } elseif (!empty($nickname)) {
  1506. $name = $nickname;
  1507. }
  1508. if (!empty($name) && !empty($mobile)) {
  1509. $name .= '-' . $mobile;
  1510. } elseif (!empty($mobile)) {
  1511. $name = $mobile;
  1512. }
  1513. return $name;
  1514. }
  1515. public static function getMemberCertName($mobile, $certName, $nickname)
  1516. {
  1517. $name = '';
  1518. if (!empty($certName)) {
  1519. $name = $certName;
  1520. }
  1521. if (!empty($name) && !empty($mobile)) {
  1522. $name .= '-' . $mobile;
  1523. } elseif (!empty($mobile)) {
  1524. $name = $mobile;
  1525. }
  1526. return $name;
  1527. }
  1528. public static function getMemberNameByMemberId($memberId)
  1529. {
  1530. $member = Member::with([
  1531. 'cert' => function ($query) {
  1532. $query->select('join_cert_member_id', 'member_cert_name');
  1533. },
  1534. 'info' => function ($query) {
  1535. $query->select('join_info_member_id', 'member_info_nickname');
  1536. },
  1537. ]
  1538. )->where('member_id', $memberId)
  1539. ->first();
  1540. if (empty($member)) {
  1541. return;
  1542. }
  1543. $member = $member->toArray();
  1544. $mobile = $certName = $nickname = '';
  1545. if (!empty($member['member_mobile'])) {
  1546. $mobile = $member['member_mobile'];
  1547. }
  1548. if (!empty($member['cert']) && !empty($member['cert']['member_cert_name'])) {
  1549. $certName = $member['cert']['member_cert_name'];
  1550. }
  1551. if (!empty($member['info']) && !empty($member['info']['member_info_nickname'])) {
  1552. $nickname = $member['info']['member_info_nickname'];
  1553. }
  1554. return self::getMemberName($mobile, $certName, $nickname);
  1555. }
  1556. /**
  1557. * @Desc 生成推荐码
  1558. * @Author Gorden
  1559. * @Date 2024/9/6 9:05
  1560. *
  1561. * @return string
  1562. */
  1563. public static function generateInviteCode()
  1564. {
  1565. $code = random_string(8, 'number');
  1566. if (Member::where('member_invite_code', $code)->exists()) {
  1567. return self::generateInviteCode();
  1568. } else {
  1569. return $code;
  1570. }
  1571. }
  1572. public static function getAvatarUrl($url)
  1573. {
  1574. if (substr($url, 0, 1) == '.' || substr($url, 0, 1) == '/' || empty($url)) {
  1575. $url = "https://img.wanyuewellness.com.cn/images/avatar_default.png";
  1576. }
  1577. return $url;
  1578. }
  1579. public static function getRoleName($roleId)
  1580. {
  1581. if (empty($roleId)) {
  1582. return '';
  1583. }
  1584. return MemberRole::where('member_role_id', $roleId)->value('member_role_name');
  1585. }
  1586. /**
  1587. * @Desc 获取身份-合伙人,推荐官
  1588. * @Author Gorden
  1589. * @Date 2024/9/28 13:41
  1590. *
  1591. * @param $isPartner
  1592. * @param $isReferrer
  1593. * @return string
  1594. */
  1595. public static function getIdentity($isPartner, $isReferrer)
  1596. {
  1597. if ($isPartner == 'Y') {
  1598. return "PARTNER";
  1599. } elseif ($isReferrer == 'Y') {
  1600. return "REFERRER";
  1601. } else {
  1602. return 'NON';
  1603. }
  1604. }
  1605. /**
  1606. * @Desc 会员合伙人过期
  1607. * @Author Gorden
  1608. * @Date 2024/10/10 9:50
  1609. *
  1610. * @return void
  1611. */
  1612. public static function partnerExpired()
  1613. {
  1614. $members = Member::where('member_is_partner', 'Y')->get()->toArray();
  1615. foreach ($members as $member) {
  1616. $partnerJson = ['member_id' => $member['member_id']];
  1617. if (!empty($member['member_partner_json'])) {
  1618. $partnerJson = json_decode($member['member_partner_json'], true);
  1619. }
  1620. if (isset($partnerJson['duedate'])) {
  1621. $duedateUnix = strtotime($partnerJson['duedate'] . ' 23:59:59');
  1622. if ($duedateUnix > time()) {
  1623. continue;
  1624. }
  1625. }
  1626. Member::where('member_id', $member['member_id'])->update(['member_is_partner' => 'N', 'member_partner_json' => '[]']);
  1627. _syslog("会员合伙人过期", "取消身份", false, $partnerJson, 1001);
  1628. Log::info("会员【" . $member['member_id'] . '】会员合伙人身份已过期', $partnerJson);
  1629. }
  1630. }
  1631. /**
  1632. * @Desc 康养推荐官过期
  1633. * @Author Gorden
  1634. * @Date 2024/10/10 10:14
  1635. *
  1636. * @return void
  1637. */
  1638. public static function referrerExpired()
  1639. {
  1640. $members = Member::where('member_is_referrer', 'Y')->get()->toArray();
  1641. foreach ($members as $member) {
  1642. $referrerJson = ['member_id' => $member['member_id']];
  1643. if (!empty($member['member_referrer_json'])) {
  1644. $referrerJson = json_decode($member['member_referrer_json'], true);
  1645. }
  1646. if (isset($referrerJson['duedate'])) {
  1647. $duedateUnix = strtotime($referrerJson['duedate'] . ' 23:59:59');
  1648. if ($duedateUnix > time()) {
  1649. continue;
  1650. }
  1651. }
  1652. Member::where('member_id', $member['member_id'])->update(['member_is_referrer' => 'N', 'member_referrer_json' => '[]']);
  1653. _syslog("康养推荐官过期", "取消身份", false, $referrerJson, 1001);
  1654. Log::info("会员【" . $member['member_id'] . '】康养推荐官身份已过期', $referrerJson);
  1655. }
  1656. }
  1657. }