index.js 41 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300
  1. let Parse = getApp().Parse;
  2. let company = getApp().globalData.company
  3. const request = require("../../utils/request");
  4. const qiniuUploader = require("../../utils/qiniuUploader");
  5. //获取应用实例
  6. const app = getApp()
  7. const real = require('../../utils/real')
  8. var timer
  9. function normalizeCnMobile(value) {
  10. if (value === null || value === undefined) return '';
  11. const digits = String(value).replace(/\D/g, '');
  12. if (!digits) return '';
  13. const last11 = digits.length >= 11 ? digits.slice(-11) : digits;
  14. if (/^1\d{10}$/.test(last11)) return last11;
  15. if (/^1\d{10}$/.test(digits)) return digits;
  16. return '';
  17. }
  18. function addCnMobileToSet(set, value) {
  19. const m = normalizeCnMobile(value);
  20. if (m) set.add(m);
  21. }
  22. async function localRejudgeIfNeeded() {
  23. try {
  24. const pending = wx.getStorageSync('traffic_deduct_pending');
  25. if (!pending) return;
  26. const storeId = pending && pending.storeId ? pending.storeId : null;
  27. const currentUser = Parse.User.current();
  28. const numsSet = new Set();
  29. addCnMobileToSet(numsSet, currentUser && currentUser.get('mobile'));
  30. addCnMobileToSet(numsSet, currentUser && currentUser.get('phone'));
  31. try { addCnMobileToSet(numsSet, wx.getStorageSync('user_mobile')); } catch (e) {}
  32. const uniqUserNumbers = Array.from(numsSet);
  33. console.log('🚦 [traffic] 授权页本地复判开始:', {
  34. storeId,
  35. userId: currentUser?.id,
  36. userNumbers: uniqUserNumbers
  37. });
  38. if (!storeId || !uniqUserNumbers.length) {
  39. console.log('🚦 [traffic] 本地复判条件不足,退出');
  40. return;
  41. }
  42. const phones = new Set();
  43. const mobiles = new Set();
  44. const tryPartnerQueries = [
  45. { key: 'storeId', value: storeId },
  46. { key: 'store', value: { __type: 'Pointer', className: 'ShopStore', objectId: storeId } },
  47. { key: 'shopStore', value: { __type: 'Pointer', className: 'ShopStore', objectId: storeId } }
  48. ];
  49. for (const item of tryPartnerQueries) {
  50. try {
  51. const q = new Parse.Query('Partner');
  52. q.equalTo(item.key, item.value);
  53. q.limit(200);
  54. q.select('phone', 'mobile', 'name');
  55. const list = await q.find();
  56. if (list && list.length) {
  57. list.forEach((p) => {
  58. addCnMobileToSet(phones, p.get('phone'));
  59. addCnMobileToSet(mobiles, p.get('mobile'));
  60. });
  61. }
  62. } catch (e) {}
  63. }
  64. console.log('🚦 [traffic] 授权页本地复判 Partner 集合:', {
  65. phoneCount: phones.size,
  66. mobileCount: mobiles.size
  67. });
  68. const phoneHit = uniqUserNumbers.some((n) => phones.has(n));
  69. const mobileHit = uniqUserNumbers.some((n) => mobiles.has(n));
  70. if (phoneHit || mobileHit) {
  71. console.log('🚦 [traffic] 授权页本地复判命中:', {
  72. reason: phoneHit ? 'partner_phone_match' : 'partner_mobile_match',
  73. matches: uniqUserNumbers.filter((n) => phoneHit ? phones.has(n) : mobiles.has(n))
  74. });
  75. try {
  76. currentUser.set('trafficExempt', true);
  77. currentUser.set('trafficExemptAt', new Date());
  78. currentUser.set('trafficExemptStoreId', storeId);
  79. await currentUser.save();
  80. } catch (e) {}
  81. wx.removeStorageSync('traffic_deduct_pending');
  82. } else {
  83. console.log('🚦 [traffic] 授权页本地复判未命中,等待首页复判继续');
  84. }
  85. } catch (e) {
  86. console.warn('🚦 [traffic] 授权页本地复判失败:', e?.message || e);
  87. }
  88. }
  89. async function flushPendingScanRecord(mobileHint) {
  90. try {
  91. const pending = wx.getStorageSync('pending_scan_record');
  92. if (!pending) {
  93. console.log('ℹ️ [ScanRecord] 授权页未发现 pending_scan_record');
  94. return false;
  95. }
  96. const now = Date.now();
  97. const scanTime = pending.timestamp || 0;
  98. const hoursPassed = scanTime ? (now - scanTime) / (1000 * 60 * 60) : 0;
  99. if (hoursPassed > 24) {
  100. console.log('⚠️ [ScanRecord] pending_scan_record 已超过24小时,清除');
  101. wx.removeStorageSync('pending_scan_record');
  102. return false;
  103. }
  104. const currentUser = Parse.User.current();
  105. if (!currentUser || !currentUser.id) {
  106. console.log('⚠️ [ScanRecord] 授权页补记失败:无登录用户');
  107. return false;
  108. }
  109. let storageMobile = '';
  110. try { storageMobile = wx.getStorageSync('user_mobile') || ''; } catch (e) {}
  111. const normalized = normalizeCnMobile(
  112. currentUser.get('mobile') || currentUser.get('phone') || storageMobile || mobileHint
  113. );
  114. console.log('📌 [ScanRecord] 授权页补记前置:', {
  115. userId: currentUser.id,
  116. mobile: normalizeCnMobile(currentUser.get('mobile')) || '无',
  117. phone: normalizeCnMobile(currentUser.get('phone')) || '无',
  118. storage: normalizeCnMobile(storageMobile) || '无',
  119. hint: normalizeCnMobile(mobileHint) || '无',
  120. normalized: normalized || '无',
  121. storeId: pending.storeId || '无',
  122. partnerId: pending.partnerId || '无'
  123. });
  124. if (!normalized) {
  125. console.log('⏳ [ScanRecord] 授权页补记失败:仍未获取到手机号');
  126. return false;
  127. }
  128. const ScanRecord = Parse.Object.extend('ScanRecord');
  129. const record = new ScanRecord();
  130. record.set('company', {
  131. __type: 'Pointer',
  132. className: 'Company',
  133. objectId: company
  134. });
  135. record.set('storeId', pending.storeId);
  136. record.set('sourceType', pending.sourceType || 'unknown');
  137. record.set('scanCount', parseInt(pending.scanCount) || 0);
  138. record.set('scanTime', new Date());
  139. if (pending.employeeId) record.set('employeeId', pending.employeeId);
  140. if (pending.partnerId) record.set('partnerId', pending.partnerId);
  141. if (pending.userId) record.set('userId', pending.userId);
  142. if (pending.productId) record.set('productId', pending.productId);
  143. record.set('user', {
  144. __type: 'Pointer',
  145. className: '_User',
  146. objectId: currentUser.id
  147. });
  148. record.set('userid', currentUser.id);
  149. await record.save();
  150. console.log('✅ [ScanRecord] 授权页补记保存成功', { recordId: record.id });
  151. wx.removeStorageSync('pending_scan_record');
  152. return true;
  153. } catch (e) {
  154. console.error('❌ [ScanRecord] 授权页补记保存失败:', e?.message || e);
  155. try {
  156. console.error(' - code:', e.code);
  157. console.error(' - details:', e.details);
  158. } catch (e2) {}
  159. return false;
  160. }
  161. }
  162. /**
  163. * @class NovaAppAuth
  164. * @memberof module:components
  165. * @tutorial userauth
  166. * @desc 通用登录组件
  167. * # 登录组件相关数据表
  168. * - _User
  169. */
  170. Page({
  171. data: {
  172. phoneModal: false, //短信验证码登录弹窗
  173. logo: "https://file-cloud.fmode.cn/MldI5PBNt7/20210928/g0k1jb034826.png",
  174. name: "未来商城",
  175. desc: "江西脑控科技有限公司是国内领先的IT技术企业。专注于互联网+服务,面向政府提供区块链、大数据、物联网、人工智能解决方案",
  176. wxModel: false,
  177. avatarUrl: '',
  178. avatar: '',
  179. nickname: '',
  180. check: false,
  181. mobile: '', //手机号
  182. verilyCode: '', //验证码
  183. s: 0, //获取验证码倒计时 秒/s
  184. countDown: false,
  185. avatarKey: Date.now(), // 用于强制刷新头像显示
  186. isProcessingAuth: false, // 标记是否正在处理授权流程
  187. },
  188. onLoad: async function (options) {
  189. let Company = new Parse.Query('Company')
  190. Company.equalTo("objectId", company)
  191. let currentCompany = await Company.first()
  192. if (currentCompany && currentCompany.id) {
  193. this.setData({
  194. logo: currentCompany.get('logo'),
  195. name: currentCompany.get('name'),
  196. desc: currentCompany.get('desc')
  197. })
  198. }
  199. this.getUptoken()
  200. this.getAgreement() //用户协议
  201. },
  202. async getUptoken() {
  203. let res = await Parse.Cloud.run('qiniu_uptoken', {
  204. company: company
  205. })
  206. this.setData({
  207. uptokenURL: res.uptoken,
  208. domain: res.domain,
  209. uploadURL: res.zoneUrl
  210. })
  211. },
  212. async getAgreement() {
  213. let query = new Parse.Query('ContractAgreement')
  214. query.equalTo('type', 'wxapp')
  215. query.equalTo('company', company)
  216. query.select('title', 'content')
  217. let res = await query.first()
  218. if (res?.id) {
  219. this.setData({
  220. agreement: res.toJSON()
  221. })
  222. }
  223. },
  224. /* 是否同意授权协议 */
  225. getAgreementAuth() {
  226. if (!this.data.check && this.data.agreement) {
  227. wx.showModal({
  228. title: '提示',
  229. content: `请您仔细阅读并充分理解相关条款,点击同意即代表已阅读并同意《${this.data.agreement.title || '用户隐私协议'}》`,
  230. showCancel: true,
  231. cancelText: '取消',
  232. cancelColor: '#000000',
  233. confirmText: '同意',
  234. confirmColor: '#3CC51F',
  235. success: (result) => {
  236. if (result.confirm) {
  237. this.setData({
  238. check: true,
  239. })
  240. // this.getUserProfile()
  241. }
  242. },
  243. fail: () => { },
  244. complete: () => { }
  245. });
  246. return
  247. }
  248. // this.getUserProfile()
  249. return true
  250. },
  251. /* 判断是否绑定手机号 */
  252. async getUserProfile() {
  253. // 检查用户是否已登录
  254. let currentUser = Parse.User.current();
  255. if (!currentUser?.id) {
  256. console.log('⚠️ 用户未登录,需要先登录');
  257. // 不要在这里调用 checkAuth(true),因为它会触发微信官方的强制授权弹窗
  258. // 应该在外层(index.js)处理登录逻辑
  259. return false;
  260. }
  261. /* 如果手机号存在,已注册过判断是否上传过头像昵称信息 */
  262. if (currentUser?.get('mobile')) {
  263. wx.setStorageSync("userLogin", currentUser.id);
  264. // 检查是否需要完善信息(可选)
  265. // 如果用户没有昵称或昵称是默认的,提示完善信息
  266. const needProfile = !currentUser.get('nickname') ||
  267. currentUser.get('nickname') === '微信用户' ||
  268. currentUser.get('nickname') === '';
  269. if (needProfile) {
  270. // 显示自定义的完善信息弹窗(允许跳过)
  271. console.log('ℹ️ 显示自定义头像昵称弹窗');
  272. this.setData({
  273. wxModel: true
  274. });
  275. return false;
  276. }
  277. // 用户信息完整,返回上一页
  278. this.backLoad();
  279. return false;
  280. }
  281. // 用户已登录但没有手机号,允许继续
  282. return true;
  283. },
  284. /* 短信验证码登录弹窗 */
  285. async showDialogBtn() {
  286. let auth = this.getAgreementAuth()
  287. if (!auth) return
  288. let userProfile = await this.getUserProfile()
  289. if (!userProfile) return
  290. // 标记正在处理授权
  291. this.setData({
  292. isProcessingAuth: true,
  293. phoneModal: true
  294. })
  295. },
  296. async getPhoneNumber(e) {
  297. let auth = this.getAgreementAuth()
  298. if (!auth) return
  299. let userProfile = await this.getUserProfile()
  300. if (!userProfile) return
  301. // 标记正在处理授权
  302. this.setData({
  303. isProcessingAuth: true
  304. })
  305. let {
  306. code
  307. } = e.detail
  308. console.log('📱 [mobile] getPhoneNumber code:', code || '无');
  309. if (!code) {
  310. console.error('❌ [mobile] getPhoneNumber 缺少 code,无法换取手机号');
  311. return
  312. }
  313. let phoneNumber = await request.getPhone(code)
  314. console.log('📱 [mobile] request.getPhone 返回:', phoneNumber || '无');
  315. if(phoneNumber) {
  316. await this.authMobileUser(phoneNumber)
  317. } else {
  318. console.error('❌ [mobile] 未获取到手机号(request.getPhone 返回空)');
  319. }
  320. },
  321. //合并User与绑定手机号逻辑
  322. async authMobileUser(mobile) {
  323. let pendingScan = null
  324. try { pendingScan = wx.getStorageSync('pending_scan_record'); } catch (e) {}
  325. let currentUser = Parse.User.current()
  326. console.log('📱 [mobile] 开始处理手机号绑定/合并:', {
  327. userId: currentUser?.id || '无',
  328. mobile: mobile || '无',
  329. hasPendingScan: !!pendingScan
  330. })
  331. let queryMobUser = new Parse.Query('_User')
  332. queryMobUser.equalTo('mobile', mobile)
  333. queryMobUser.equalTo('company', company)
  334. queryMobUser.notEqualTo('type', 'admin')
  335. queryMobUser.notEqualTo('isDeleted', true)
  336. // queryMobUser.exists(`wxapp.${getApp().globalData.appid}`)
  337. let resMobUser = await queryMobUser.first()
  338. if (resMobUser?.id) {
  339. //请求User合并API,获取token重新登录,再更新昵称头像信息等
  340. let token = await this.getUpdateUserToken(currentUser.id, resMobUser.id)
  341. console.log(token);
  342. if (token) {
  343. Parse.User.become(token).then(async user => {
  344. // let user = Parse.User.current();
  345. wx.setStorageSync("userLogin", user.id);
  346. try {
  347. const hasMobile = !!normalizeCnMobile(user.get('mobile') || user.get('phone') || mobile);
  348. if (hasMobile && !normalizeCnMobile(user.get('mobile'))) {
  349. user.set('mobile', mobile);
  350. }
  351. if (hasMobile && !normalizeCnMobile(user.get('phone'))) {
  352. user.set('phone', mobile);
  353. }
  354. if (hasMobile) {
  355. await user.save();
  356. }
  357. console.log('✅ [mobile] merge-become 后用户手机号状态:', {
  358. userId: user?.id || '无',
  359. mobile: user.get('mobile') || '无',
  360. phone: user.get('phone') || '无'
  361. })
  362. } catch (e) {
  363. console.error('❌ [mobile] merge-become 后写入手机号失败:', e?.message || e);
  364. }
  365. try {
  366. wx.setStorageSync('user_mobile', (user.get('mobile') || mobile) || '');
  367. } catch (e) {}
  368. try {
  369. await flushPendingScanRecord(mobile);
  370. } catch (e) {}
  371. try {
  372. if (typeof getApp().checkAndRecordPendingScan === 'function') {
  373. const ok = await getApp().checkAndRecordPendingScan();
  374. console.log('📌 [ScanRecord] merge-become 补记结果:', ok ? 'success' : 'not_written');
  375. setTimeout(() => {
  376. try { getApp().checkAndRecordPendingScan(); } catch (e) {}
  377. }, 500);
  378. setTimeout(() => {
  379. try { getApp().checkAndRecordPendingScan(); } catch (e) {}
  380. }, 1500);
  381. } else {
  382. console.warn('⚠️ [ScanRecord] getApp().checkAndRecordPendingScan 不存在,无法触发补记');
  383. }
  384. } catch (e) {
  385. console.warn('⚠️ [ScanRecord] merge-become 触发补记失败:', e?.message || e);
  386. }
  387. try {
  388. if (typeof getApp().checkTrafficDeductPending === 'function') {
  389. console.log('🚦 [traffic] 触发暂缓扣减复判(merge-become 成功后)');
  390. await getApp().checkTrafficDeductPending();
  391. } else {
  392. await localRejudgeIfNeeded();
  393. }
  394. } catch (e) {}
  395. if (!user.get('avatar') || user.get('nickname') == '微信用户' || !user.get('nickname')) {
  396. this.setData({
  397. phoneModal: false,
  398. wxModel: true
  399. })
  400. return
  401. }
  402. this.backLoad()
  403. return
  404. })
  405. .catch(async err => {
  406. console.log('❌ Parse.User.become 失败:', err);
  407. // 不要直接退出,而是尝试重新登录
  408. wx.showModal({
  409. title: '提示',
  410. content: '登录状态异常,是否重新登录?',
  411. showCancel: true,
  412. cancelText: '取消',
  413. confirmText: '重新登录',
  414. success: async (result) => {
  415. if (result.confirm) {
  416. // 清除登录状态
  417. wx.removeStorageSync("sessionToken");
  418. wx.removeStorageSync("userLogin");
  419. try {
  420. // 尝试重新登录
  421. await Parse.User.logOut();
  422. await getApp().checkAuth(true);
  423. // 重新获取用户信息
  424. const currentUser = Parse.User.current();
  425. if (currentUser && currentUser.get('mobile')) {
  426. wx.setStorageSync("userLogin", currentUser.id);
  427. this.backLoad();
  428. }
  429. } catch (reloginErr) {
  430. console.error('❌ 重新登录失败:', reloginErr);
  431. wx.showToast({
  432. title: '登录失败,请稍后重试',
  433. icon: 'none'
  434. });
  435. }
  436. } else {
  437. // 用户取消,返回上一页
  438. wx.navigateBack();
  439. }
  440. },
  441. });
  442. return
  443. })
  444. return
  445. }
  446. return
  447. }
  448. try {
  449. currentUser.set('mobile', mobile)
  450. currentUser.set('phone', mobile)
  451. await currentUser.save()
  452. console.log('✅ [mobile] 已写入手机号:', {
  453. userId: currentUser?.id || '无',
  454. mobile: currentUser.get('mobile') || '无',
  455. phone: currentUser.get('phone') || '无'
  456. })
  457. } catch (e) {
  458. console.error('❌ [mobile] 写入手机号失败:', e?.message || e);
  459. return
  460. }
  461. try {
  462. wx.setStorageSync('user_mobile', mobile || '');
  463. try {
  464. await flushPendingScanRecord(mobile);
  465. } catch (e) {}
  466. if (typeof getApp().checkAndRecordPendingScan === 'function') {
  467. const ok = await getApp().checkAndRecordPendingScan();
  468. console.log('📌 [ScanRecord] 绑定手机号后补记结果:', ok ? 'success' : 'not_written');
  469. setTimeout(() => {
  470. try { getApp().checkAndRecordPendingScan(); } catch (e) {}
  471. }, 500);
  472. setTimeout(() => {
  473. try { getApp().checkAndRecordPendingScan(); } catch (e) {}
  474. }, 1500);
  475. } else {
  476. console.warn('⚠️ [ScanRecord] getApp().checkAndRecordPendingScan 不存在,无法触发补记');
  477. }
  478. } catch (e) {
  479. console.warn('⚠️ [ScanRecord] 绑定手机号后触发补记失败:', e?.message || e);
  480. }
  481. try {
  482. if (typeof getApp().checkTrafficDeductPending === 'function') {
  483. console.log('🚦 [traffic] 触发暂缓扣减复判(绑定手机号后)');
  484. await getApp().checkTrafficDeductPending();
  485. } else {
  486. await localRejudgeIfNeeded();
  487. }
  488. } catch (e) {}
  489. if (!currentUser.get('avatar') || currentUser.get('nickname') == '微信用户' || !currentUser.get('nickname')) {
  490. this.setData({
  491. phoneModal: false,
  492. wxModel: true
  493. })
  494. return
  495. }
  496. this.backLoad()
  497. return
  498. },
  499. async getUpdateUserToken(oldUser, newUserId) {
  500. return new Promise((resolve, reject) => {
  501. wx.login({
  502. success: function (res) {
  503. let parms = {
  504. oldUserId: oldUser,
  505. newUserId: newUserId,
  506. appId: getApp().globalData.appid,
  507. code: res.code,
  508. companyId: company,
  509. appType: getApp().globalData.appType || ''
  510. }
  511. if (res.code) {
  512. let url = 'https://server.fmode.cn/api/wxapp/combine/user'
  513. wx.request({
  514. url: url,
  515. data: parms,
  516. header: { 'content-type': 'application/json' },
  517. method: 'POST',
  518. async success(res) {
  519. console.log(res);
  520. let data = res.data
  521. if (data.code == 200) {
  522. wx.setStorageSync("sessionToken", data.data.token);
  523. // 用户合并成功后,更新 ScanRecord 表中的 user 字段
  524. console.log('🔄 [用户合并] 开始更新 ScanRecord 中的用户关联');
  525. console.log(' - 旧用户ID:', oldUser);
  526. console.log(' - 新用户ID:', newUserId);
  527. try {
  528. // 使用 Parse.User.become 切换到新用户
  529. await Parse.User.become(data.data.token);
  530. // 查询所有旧用户的扫码记录
  531. const ScanRecord = Parse.Object.extend('ScanRecord');
  532. const scanQuery = new Parse.Query(ScanRecord);
  533. scanQuery.equalTo('user', {
  534. __type: 'Pointer',
  535. className: '_User',
  536. objectId: oldUser
  537. });
  538. scanQuery.limit(1000); // 设置查询上限
  539. const oldRecords = await scanQuery.find();
  540. console.log(`📋 [查询结果] 找到 ${oldRecords.length} 条旧用户的扫码记录`);
  541. if (oldRecords.length > 0) {
  542. // 批量更新所有记录,将 user 指向新用户
  543. const updatePromises = oldRecords.map(record => {
  544. record.set('user', {
  545. __type: 'Pointer',
  546. className: '_User',
  547. objectId: newUserId
  548. });
  549. return record.save();
  550. });
  551. await Promise.all(updatePromises);
  552. console.log(`✅ [更新成功] 已将 ${oldRecords.length} 条扫码记录的用户更新为新用户`);
  553. } else {
  554. console.log('ℹ️ [无需更新] 旧用户没有扫码记录');
  555. }
  556. } catch (updateError) {
  557. console.error('❌ [更新失败] 更新 ScanRecord 失败:', updateError);
  558. console.error(' - 错误信息:', updateError.message);
  559. // 不影响主流程,继续返回 token
  560. }
  561. resolve(data.data.token)
  562. } else {
  563. console.log(data?.mess);
  564. wx.showModal({
  565. title: '提示',
  566. content: data?.mess,
  567. showCancel: false,
  568. cancelText: '取消',
  569. cancelColor: '#000000',
  570. confirmText: '确定',
  571. confirmColor: '#3CC51F',
  572. success: (result) => {
  573. if (result.confirm) {
  574. }
  575. },
  576. fail: () => { },
  577. complete: () => { }
  578. });
  579. resolve()
  580. }
  581. },
  582. });
  583. }
  584. },
  585. fail: function (err) {
  586. wx.showModal({
  587. title: '提示',
  588. content: '登录超时,请稍后重试',
  589. showCancel: false,
  590. cancelText: '取消',
  591. cancelColor: '#000000',
  592. confirmText: '确定',
  593. confirmColor: '#3CC51F',
  594. success: (result) => {
  595. if (result.confirm) {
  596. }
  597. },
  598. fail: () => { },
  599. complete: () => { }
  600. });
  601. console.warn('小程序wx.login失败');
  602. resolve()
  603. }
  604. });
  605. })
  606. },
  607. //获取验证码
  608. async getPhoneCode() {
  609. let { mobile, s, countDown } = this.data
  610. if (!real.isPoneAvailable(mobile)) {
  611. wx.showToast({
  612. title: '手机号格式有误',
  613. icon: 'error',
  614. duration: 1500,
  615. mask: false,
  616. });
  617. return
  618. }
  619. if(countDown || s > 0) return
  620. this.setData({
  621. countDown:true
  622. })
  623. let parsm = {
  624. company: company,
  625. mobile: mobile
  626. }
  627. let code = await this.getRequest(parsm, 'message')
  628. if(code?.code == 1){
  629. this.setData({
  630. s:60
  631. })
  632. this.decrementTime()
  633. }else{
  634. wx.showToast({
  635. title: '验证码获取失败',
  636. icon: 'error',
  637. image: '',
  638. duration: 1500,
  639. mask: false,
  640. });
  641. this.setData({
  642. countDown:false
  643. })
  644. }
  645. },
  646. //接口请求
  647. getRequest(parsm, apig) {
  648. return new Promise((resolve, rej) => {
  649. let url = 'https://server.fmode.cn/api/apig/'
  650. wx.request({
  651. url: url + apig,
  652. data: parsm,
  653. header: { 'content-type': 'application/json' },
  654. method: 'POST',
  655. dataType: 'json',
  656. responseType: 'text',
  657. success: (result) => {
  658. console.log(result);
  659. resolve(result.data)
  660. },
  661. fail: () => {
  662. resolve(false)
  663. },
  664. complete: () => { }
  665. });
  666. })
  667. },
  668. // 倒计时
  669. decrementTime(){
  670. timer = setTimeout(() => {
  671. let { s } = this.data
  672. if(s == 0){
  673. this.setData({ countDown:false })
  674. timer && clearTimeout(timer)
  675. return
  676. }
  677. s--
  678. this.setData({
  679. s:s
  680. })
  681. this.decrementTime()
  682. }, 1000);
  683. },
  684. //验证码绑定手机号登录
  685. async completePhone() {
  686. let { mobile, verilyCode } = this.data
  687. if(!real.isPoneAvailable(mobile) || !verilyCode.toString().trim()){
  688. wx.showToast({
  689. title: '手机号或验证码不正确',
  690. icon: 'none',
  691. image: '',
  692. duration: 1500,
  693. mask: false,
  694. });
  695. return
  696. }
  697. // 标记正在处理授权
  698. this.setData({
  699. isProcessingAuth: true
  700. })
  701. let parsm = {
  702. mobile: mobile,
  703. code:verilyCode
  704. }
  705. let isVerify = await this.getRequest(parsm, 'verifyCode')
  706. console.log(isVerify);
  707. if(isVerify.code == 200){
  708. this.authMobileUser(mobile.toString())
  709. }else{
  710. // 验证失败,重置标记
  711. this.setData({
  712. isProcessingAuth: false
  713. })
  714. wx.showToast({
  715. title:isVerify?.msg || '验证码错误',
  716. icon: 'none',
  717. image: '',
  718. duration: 1500,
  719. mask: false,
  720. });
  721. return
  722. }
  723. },
  724. //关闭手机号授权弹窗
  725. hideModal: function () {
  726. this.setData({
  727. phoneModal: false,
  728. isProcessingAuth: false // 重置标记
  729. })
  730. },
  731. backLoad() {
  732. console.log('===========================================');
  733. console.log('======= backLoad 方法调用 =======');
  734. let pages = getCurrentPages();
  735. console.log('当前页面栈层数:', pages.length);
  736. console.log('当前页面路由:', pages[pages.length - 1]?.route);
  737. // 检查是否有 returnUrl 参数(从 H5 页面传递过来)
  738. const currentPage = pages[pages.length - 1];
  739. const returnUrl = currentPage?.options?.returnUrl;
  740. if (returnUrl) {
  741. console.log('📍 检测到 returnUrl 参数:', returnUrl);
  742. // 如果是 web-view 页面,跳转回去
  743. const decodedUrl = decodeURIComponent(returnUrl);
  744. console.log('🔙 准备跳转回 H5 页面:', decodedUrl);
  745. let nextUrl = `/common-page/pages/web-view/index?path=${encodeURIComponent(decodedUrl)}`;
  746. const storeId = currentPage?.options?.storeId;
  747. const storeName = currentPage?.options?.storeName;
  748. if (storeId) {
  749. nextUrl += `&storeId=${storeId}`;
  750. }
  751. if (storeName) {
  752. nextUrl += `&storeName=${storeName}`;
  753. }
  754. wx.redirectTo({
  755. url: nextUrl,
  756. success: () => {
  757. console.log('✅ 跳转回 H5 页面成功');
  758. console.log('===========================================');
  759. },
  760. fail: (err) => {
  761. console.error('❌ 跳转回 H5 页面失败:', err);
  762. wx.reLaunch({
  763. url: nextUrl,
  764. success: () => {
  765. console.log('✅ reLaunch 跳转回 H5 页面成功');
  766. console.log('===========================================');
  767. },
  768. fail: () => {
  769. this.normalBackLoad();
  770. }
  771. });
  772. }
  773. });
  774. return;
  775. }
  776. // 没有 returnUrl,执行正常的返回逻辑
  777. this.normalBackLoad();
  778. },
  779. normalBackLoad() {
  780. let pages = getCurrentPages();
  781. // 如果页面栈只有1层或没有上一页,直接跳转到首页
  782. if (pages.length <= 1) {
  783. console.log('⚠️ 没有上一个页面,直接跳转到首页');
  784. this.goToHome();
  785. return;
  786. }
  787. // 有上一个页面
  788. let beforePage = pages[pages.length - 2];
  789. console.log('上一个页面路由:', beforePage.route);
  790. // 尝试调用上一个页面的 onLoad 方法(如果存在)
  791. if (beforePage && typeof beforePage.onLoad === 'function') {
  792. try {
  793. let options = beforePage.options || { isInit: true };
  794. beforePage.onLoad(options);
  795. console.log('✅ 已调用上一个页面的 onLoad');
  796. } catch (err) {
  797. console.warn('⚠️ 调用上一个页面 onLoad 失败:', err);
  798. }
  799. }
  800. // 返回上一页
  801. console.log('🔙 执行 navigateBack...');
  802. wx.navigateBack({
  803. delta: 1,
  804. success: () => {
  805. console.log('✅ navigateBack 成功');
  806. console.log('===========================================');
  807. },
  808. fail: (err) => {
  809. console.error('❌ navigateBack 失败:', err);
  810. console.log('⚠️ 尝试使用 reLaunch 跳转到首页');
  811. this.goToHome();
  812. }
  813. });
  814. },
  815. // 跳转到首页
  816. goToHome() {
  817. console.log('===========================================');
  818. console.log('======= goToHome 方法调用 =======');
  819. const app = getApp();
  820. console.log('globalData.rootPage:', app.globalData.rootPage);
  821. console.log('globalData.defaultTabBar:', app.globalData.defaultTabBar);
  822. // 尝试多个可能的首页路径
  823. let rootPage = app.globalData.rootPage
  824. || app.globalData.defaultTabBar?.list?.[0]?.pagePath
  825. || '/pages/index/index'
  826. || '/index/index';
  827. // 确保路径以 / 开头
  828. if (!rootPage.startsWith('/')) {
  829. rootPage = '/' + rootPage;
  830. }
  831. console.log('准备跳转到:', rootPage);
  832. wx.reLaunch({
  833. url: rootPage,
  834. success: () => {
  835. console.log('✅ reLaunch 成功');
  836. console.log('===========================================');
  837. },
  838. fail: (err) => {
  839. console.error('❌ reLaunch 失败:', err);
  840. console.log('⚠️ 尝试使用 switchTab');
  841. // 如果是 tabBar 页面,尝试使用 switchTab
  842. wx.switchTab({
  843. url: rootPage,
  844. success: () => {
  845. console.log('✅ switchTab 成功');
  846. console.log('===========================================');
  847. },
  848. fail: (err2) => {
  849. console.error('❌ switchTab 也失败:', err2);
  850. console.log('⚠️ 最后尝试:直接 navigateBack');
  851. // 最后的兜底:直接返回
  852. wx.navigateBack({
  853. delta: 1,
  854. fail: (err3) => {
  855. console.error('❌ 所有跳转方式都失败了:', err3);
  856. console.log('===========================================');
  857. // 显示错误提示
  858. wx.showModal({
  859. title: '提示',
  860. content: '页面跳转失败,请手动返回',
  861. showCancel: false
  862. });
  863. }
  864. });
  865. }
  866. });
  867. }
  868. });
  869. },
  870. goBack: function () {
  871. wx.navigateBack({
  872. delta: 1,
  873. })
  874. },
  875. //手动获取微信头像
  876. onChooseAvatar(e) {
  877. console.log('=== onChooseAvatar 触发 ===');
  878. console.log('事件对象:', e);
  879. const { avatarUrl } = e.detail;
  880. console.log('获取到的头像URL:', avatarUrl);
  881. console.log('头像URL类型:', typeof avatarUrl);
  882. console.log('头像URL长度:', avatarUrl ? avatarUrl.length : 0);
  883. if (avatarUrl) {
  884. // 微信头像URL可能是临时路径,需要先下载
  885. // 临时路径格式:http://tmp/xxx.jpg
  886. // 相机拍照路径格式:wxfile://tmp_xxx.jpg
  887. this.setData({
  888. avatarUrl: avatarUrl,
  889. avatarKey: Date.now() // 更新key强制刷新
  890. }, () => {
  891. console.log('✅ 头像URL已更新到data:', this.data.avatarUrl);
  892. console.log('✅ avatarKey已更新:', this.data.avatarKey);
  893. });
  894. } else {
  895. console.error('❌ 未获取到头像URL');
  896. wx.showToast({
  897. title: '开发工具不支持,请真机测试',
  898. icon: 'none',
  899. duration: 2000
  900. });
  901. }
  902. },
  903. //获取昵称
  904. onChangeName(e) {
  905. console.log('=== 昵称输入事件 ===');
  906. console.log('事件对象:', e);
  907. // 注意:type="nickname" 的 input 会在用户输入时自动更新 model:value
  908. // 这里只是记录日志,实际的值更新由 model:value 自动处理
  909. if (e.detail && e.detail.value !== undefined) {
  910. console.log('昵称值:', e.detail.value);
  911. }
  912. },
  913. //确定头像昵称
  914. async onComplete() {
  915. console.log('=== onComplete 方法被调用 ===');
  916. if (this.data.isProcessingAuth) return;
  917. this.setData({
  918. isProcessingAuth: true
  919. })
  920. let {
  921. nickname,
  922. avatarUrl
  923. } = this.data
  924. const finalNickname = (nickname || '').toString().trim();
  925. console.log('昵称:', nickname);
  926. console.log('头像URL:', avatarUrl);
  927. let user = Parse.User.current();
  928. if (!user) {
  929. console.error('❌ 用户未登录,无法保存信息');
  930. wx.showToast({
  931. title: '用户未登录',
  932. icon: 'none'
  933. });
  934. return;
  935. }
  936. console.log('当前用户ID:', user.id);
  937. if (!finalNickname) {
  938. this.setData({
  939. isProcessingAuth: false
  940. })
  941. wx.showToast({
  942. title: '请输入微信昵称',
  943. icon: 'none'
  944. });
  945. return;
  946. }
  947. const hasAvatar = !!user.get('avatar')
  948. if (!hasAvatar && !avatarUrl) {
  949. this.setData({
  950. isProcessingAuth: false
  951. })
  952. wx.showToast({
  953. title: '请选择微信头像',
  954. icon: 'none'
  955. });
  956. return;
  957. }
  958. // 显示加载提示
  959. wx.showLoading({
  960. title: '保存中...',
  961. mask: true
  962. });
  963. try {
  964. if (avatarUrl) {
  965. console.log('📤 开始上传头像...');
  966. let avatar = await this.updataAvatar(avatarUrl);
  967. if (avatar) {
  968. user.set("avatar", avatar);
  969. console.log('✅ 头像上传成功:', avatar);
  970. } else {
  971. console.warn('⚠️ 头像上传失败');
  972. wx.hideLoading();
  973. this.setData({
  974. isProcessingAuth: false
  975. })
  976. wx.showToast({
  977. title: '头像上传失败,请重试',
  978. icon: 'none'
  979. });
  980. return;
  981. }
  982. }
  983. user.set("nickname", finalNickname);
  984. console.log('✅ 昵称已设置:', finalNickname);
  985. await user.save();
  986. try {
  987. await user.fetch();
  988. } catch (e) {}
  989. if (!user.get('avatar')) {
  990. wx.hideLoading();
  991. this.setData({
  992. isProcessingAuth: false
  993. })
  994. wx.showToast({
  995. title: '头像保存失败,请重试',
  996. icon: 'none'
  997. });
  998. return;
  999. }
  1000. console.log('✅ 用户信息保存成功');
  1001. wx.hideLoading();
  1002. // 关闭弹窗
  1003. this.onClose();
  1004. // 延迟一下再跳转,确保弹窗关闭动画完成
  1005. setTimeout(() => {
  1006. console.log('🚀 准备跳转...');
  1007. try {
  1008. const u = Parse.User.current();
  1009. if (u && u.id) {
  1010. wx.setStorageSync('userLogin', u.id);
  1011. }
  1012. } catch (e) {}
  1013. this.backLoad();
  1014. }, 300);
  1015. } catch (err) {
  1016. wx.hideLoading();
  1017. this.setData({
  1018. isProcessingAuth: false
  1019. })
  1020. console.error('❌ 保存用户信息失败:', err);
  1021. wx.showModal({
  1022. title: '提示',
  1023. content: '保存失败,请重试',
  1024. showCancel: false,
  1025. confirmText: '重试'
  1026. });
  1027. }
  1028. },
  1029. //关闭头像昵称填写弹窗
  1030. onClose() {
  1031. this.setData({
  1032. wxModel: false,
  1033. isProcessingAuth: false // 重置标记
  1034. })
  1035. },
  1036. //上传头像
  1037. async updataAvatar(url) {
  1038. const normalizeUrl = (value) => {
  1039. if (!value) return '';
  1040. let s = String(value).trim();
  1041. if (!s) return '';
  1042. if (s.startsWith('//')) return 'https:' + s;
  1043. return s.replace(/^http:\/\//i, 'https://');
  1044. };
  1045. const normalizeDomain = (value) => {
  1046. const d = normalizeUrl(value);
  1047. if (!d) return '';
  1048. return d.endsWith('/') ? d.slice(0, -1) : d;
  1049. };
  1050. const downloadIfNeeded = (src) => {
  1051. return new Promise((resolve) => {
  1052. if (!src) return resolve('');
  1053. const isRemote = /^https?:\/\//i.test(src) || src.startsWith('//');
  1054. if (!isRemote) return resolve(src);
  1055. wx.downloadFile({
  1056. url: normalizeUrl(src),
  1057. success: (res) => resolve(res?.tempFilePath || ''),
  1058. fail: () => resolve('')
  1059. });
  1060. });
  1061. };
  1062. try {
  1063. if (!this.data.uptokenURL || !this.data.domain || !this.data.uploadURL) {
  1064. await this.getUptoken();
  1065. }
  1066. } catch (e) {}
  1067. const filePath = await downloadIfNeeded(normalizeUrl(url));
  1068. if (!filePath) return false;
  1069. return new Promise((resolve) => {
  1070. qiniuUploader.upload(
  1071. filePath,
  1072. (res) => {
  1073. const img = normalizeUrl(res?.imageURL || res?.fileUrl || '');
  1074. resolve(img || false);
  1075. },
  1076. (error) => {
  1077. console.log("error: " + error);
  1078. resolve(false);
  1079. },
  1080. {
  1081. region: "SCN",
  1082. uploadURL: this.data.uploadURL,
  1083. domain: normalizeDomain(this.data.domain),
  1084. uptoken: this.data.uptokenURL,
  1085. }
  1086. );
  1087. });
  1088. },
  1089. //选择勾选用户协议
  1090. onCheckAgreement() {
  1091. this.setData({
  1092. check: !this.data.check
  1093. })
  1094. },
  1095. //附件下载
  1096. openFile() {
  1097. let {
  1098. agreement
  1099. } = this.data
  1100. let url = agreement.content,
  1101. name = agreement.title
  1102. const _this = this;
  1103. let rep = this.getFileType(url)
  1104. console.log(url, name);
  1105. wx.showLoading({
  1106. title: '加载中',
  1107. })
  1108. wx.downloadFile({
  1109. url: url, //要预览的PDF的地址
  1110. filePath: wx.env.USER_DATA_PATH + `/${name}.${rep}`,
  1111. success: function (res) {
  1112. console.log(res);
  1113. if (res.statusCode === 200) { //成功
  1114. var Path = res.filePath //返回的文件临时地址,用于后面打开本地预览所用
  1115. console.log(Path)
  1116. wx.openDocument({
  1117. filePath: Path, //要打开的文件路径
  1118. showMenu: true,
  1119. success: function (res) {
  1120. wx.hideLoading()
  1121. console.log(res, '打开PDF成功');
  1122. },
  1123. fail: function (res) {
  1124. console.log(res)
  1125. wx.hideLoading()
  1126. }
  1127. })
  1128. }
  1129. },
  1130. fail: function (res) {
  1131. wx.hideLoading()
  1132. console.log(res); //失败
  1133. },
  1134. })
  1135. },
  1136. //解析文件类型
  1137. getFileType(url) {
  1138. let pdfReg = /^.+(\.pdf)$/
  1139. let txtReg = /^.+(\.txt)$/
  1140. let wordReg = /^.+(\.doc|\.docx)$/
  1141. let excelReg = /^.+(\.xls|\.xlsx)$/
  1142. let jpgPng = /^.+(\.png)$/
  1143. let jpgJpg = /^.+(\.jpg)$/
  1144. let jpgJpeg = /^.+(\.jpeg)$/
  1145. if (pdfReg.test(url)) {
  1146. return 'pdf'
  1147. }
  1148. if (txtReg.test(url)) {
  1149. return 'txt'
  1150. }
  1151. if (wordReg.test(url)) {
  1152. return 'docx'
  1153. }
  1154. if (excelReg.test(url)) {
  1155. return 'xls'
  1156. }
  1157. if (jpgPng.test(url)) {
  1158. return 'png'
  1159. }
  1160. if (jpgJpg.test(url)) {
  1161. return 'jpg'
  1162. }
  1163. if (jpgJpeg.test(url)) {
  1164. return 'jpeg'
  1165. }
  1166. },
  1167. onShow: function () {
  1168. console.log('=== onShow 方法被调用 ===');
  1169. // 如果正在处理授权流程,不要自动返回
  1170. if (this.data.isProcessingAuth) {
  1171. console.log('ℹ️ 正在处理授权流程,不自动返回');
  1172. return;
  1173. }
  1174. // 如果有弹窗显示(手机号弹窗或头像昵称弹窗),不要自动返回
  1175. if (this.data.phoneModal || this.data.wxModel) {
  1176. console.log('ℹ️ 有弹窗显示,不自动返回');
  1177. return;
  1178. }
  1179. let userLogin = wx.getStorageSync('userLogin');
  1180. let currentUser = Parse.User.current();
  1181. console.log('userLogin 存储:', userLogin);
  1182. console.log('当前用户:', currentUser ? currentUser.id : '无');
  1183. console.log('手机号:', currentUser?.get('mobile') || '无');
  1184. // 检查是否是从其他页面跳转过来的(有 returnUrl 参数)
  1185. const pages = getCurrentPages();
  1186. const currentPage = pages[pages.length - 1];
  1187. const hasReturnUrl = currentPage?.options?.returnUrl;
  1188. if (hasReturnUrl) {
  1189. console.log('ℹ️ 检测到 returnUrl 参数,用户需要完成登录流程');
  1190. // 不要自动返回,让用户完成登录
  1191. return;
  1192. }
  1193. // 只有当用户已登录且有手机号,并且不是从其他页面跳转过来时才返回
  1194. if (userLogin && currentUser && currentUser.get('mobile')) {
  1195. console.log('✅ 用户已完整登录,返回上一页');
  1196. wx.navigateBack({
  1197. fail: () => {
  1198. console.log('⚠️ 返回失败,可能是首页');
  1199. }
  1200. });
  1201. } else {
  1202. console.log('ℹ️ 用户未完整登录,显示授权页面');
  1203. }
  1204. },
  1205. onReady: function () {
  1206. },
  1207. })