index.js 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113
  1. // var Parse = getApp().Parse;
  2. // var app = getApp()
  3. // const { wxLogin } = require('./utils/login')
  4. const CONFIG = require("config.js");
  5. let config = {
  6. appid: CONFIG.default.appid,
  7. company: CONFIG.default.company,
  8. rootPage: CONFIG.default.rootPage,
  9. }
  10. const plugin = requirePlugin('fm-plugin')
  11. const { Parse, checkAuth } = plugin
  12. Page({
  13. /**
  14. * 页面的初始数据
  15. */
  16. data: {
  17. splashUrl: wx.getStorageSync("enabledOptions")[0],
  18. loading:true
  19. },
  20. /**
  21. * 生命周期函数--监听页面加载
  22. */
  23. onLoad: async function (options) {
  24. wx.login({
  25. success: function (res) {
  26. if (res.code) {
  27. console.log(res);
  28. // wx.request({
  29. // url: "https://server.fmode.cn/api/wxapp/auth_wxapp",
  30. // data: {
  31. // c: getApp().globalData.company,
  32. // code: res.code,
  33. // },
  34. // async success(res) {
  35. // wx.setStorageSync("userInfo", res.data);
  36. // resolve(res)
  37. // },
  38. // });
  39. }
  40. },
  41. fail: function (err) {
  42. wx.showToast({
  43. title: '服务器繁忙,请稍后重试',
  44. })
  45. }
  46. });
  47. wx.setStorageSync("invite", null);
  48. // 处理扫码链接(options.q 包含完整的URL或activityId)
  49. if (options.q) {
  50. let str = decodeURIComponent(options.q); // 扫描二维码获得的跳转链接
  51. // 兼容一些环境中把 & 编码成 & 的情况,防止参数解析错误(如 scanCount=0&storeId=...)
  52. if (str.indexOf('&') !== -1) {
  53. console.log('🔧 检测到 URL 中包含 &,自动还原为 &');
  54. str = str.replace(/&/g, '&');
  55. }
  56. // 检查是否是员工邀请链接(app.fmode.cn/dev/pobingfeng/manager/staff?invite=xxx)
  57. if (str.includes('app.fmode.cn/dev/pobingfeng/manager/staff')) {
  58. let obj = this.getParaName(str);
  59. if (obj && obj.invite) {
  60. wx.setStorageSync("invite", obj.invite);
  61. console.log('✅ 检测到员工邀请链接,invite:', obj.invite);
  62. }
  63. // 员工邀请链接不需要跳转到店铺,直接返回
  64. this.setData({ options: options });
  65. plugin.init(config, wx.getStorageSync('invite'));
  66. return;
  67. }
  68. // 检查是否是活动海报二维码(activityId作为qrCode参数值)
  69. // 如果str不包含http/https,且看起来像是一个ID,则可能是activityId
  70. if (!str.includes('http://') && !str.includes('https://') && !str.includes('?')) {
  71. // 可能是活动ID,尝试作为activityId处理
  72. if (str && str.length > 0 && !isNaN(str)) {
  73. options.activityId = str;
  74. console.log('✅ 检测到活动海报二维码,activityId:', str);
  75. // 活动二维码需要特殊处理,先保存activityId
  76. wx.setStorageSync("activityId", str);
  77. }
  78. }
  79. // 处理店铺相关的二维码链接(pwa.fmode.cn/gomini/pmd/)
  80. // 从完整URL中提取参数
  81. if (str.includes('pwa.fmode.cn/gomini/pmd') || str.includes('?')) {
  82. let obj = this.getParaName(str);
  83. if (obj && obj.invite) {
  84. wx.setStorageSync("invite", obj.invite);
  85. }
  86. // 将所有参数合并到 options 中
  87. obj && Object.keys(obj).forEach(key=> options[key] = obj[key]);
  88. }
  89. }
  90. // 兼容从编译参数或页面直达传入的 storeId
  91. if (options && options.scene && !options.storeId) {
  92. try {
  93. const sceneStr = decodeURIComponent(options.scene)
  94. if (sceneStr) {
  95. const pairs = sceneStr.split('&')
  96. for (const p of pairs) {
  97. const [k, v] = p.split('=')
  98. if (k === 'storeId' && v) {
  99. options.storeId = v
  100. break
  101. }
  102. }
  103. }
  104. } catch (e) {
  105. console.warn('解析 scene 失败:', e)
  106. }
  107. }
  108. this.setData({
  109. options: options
  110. })
  111. let {
  112. time,
  113. dramaId,
  114. roomId,
  115. orderId,
  116. shopId,
  117. invite,
  118. activityId,
  119. company,
  120. inviteHost,
  121. storeId
  122. } = options
  123. time && wx.setStorageSync("time", time);
  124. dramaId && wx.setStorageSync("dramaId", dramaId);
  125. roomId && wx.setStorageSync("roomId", roomId);
  126. orderId && wx.setStorageSync("orderId", orderId);
  127. shopId && wx.setStorageSync("shopId", shopId);
  128. invite && wx.setStorageSync("invite", invite);
  129. activityId && wx.setStorageSync("activityId", activityId);
  130. inviteHost && wx.setStorageSync("inviteHost", true);
  131. if (storeId) {
  132. wx.setStorageSync('storeId', storeId)
  133. getApp().globalData.storeId = storeId
  134. console.log('✅ 入口页已设置店铺 ID:', storeId)
  135. }
  136. if (company) getApp().globalData.toCompany = true;
  137. // 检查是否是扫码进入(需要统计扫码次数)
  138. this.checkAndHandleScan(options);
  139. plugin.init(config, wx.getStorageSync('invite'))
  140. },
  141. /**
  142. * 生命周期函数--监听页面初次渲染完成
  143. */
  144. onReady: async function () { },
  145. /**
  146. * 生命周期函数--监听页面显示
  147. */
  148. onShow: async function () {
  149. await this.review()
  150. },
  151. async review(force){
  152. try {
  153. let options = this.data.options
  154. let url = getApp().globalData.rootPage || getApp().globalData.defaultTabBar.list[0].pagePath
  155. if (options) {
  156. let objArr = Object.keys(options)
  157. if (objArr && objArr.length > 0) {
  158. let parms = '?'
  159. objArr.forEach((o, index) => {
  160. if (index > 0) {
  161. parms += '&' + o + '=' + options[o]
  162. } else {
  163. parms += o + '=' + options[o]
  164. }
  165. })
  166. url += parms
  167. }
  168. }
  169. let currentUser = Parse.User.current()
  170. console.log('===========================================');
  171. console.log('======= index.js review 方法 =======');
  172. console.log('当前用户:', currentUser ? currentUser.id : '无');
  173. console.log('用户手机号:', currentUser?.get('mobile') || '无');
  174. console.log('用户名:', currentUser?.get('username') || '无');
  175. console.log('Session Token:', currentUser?.getSessionToken()?.substring(0, 20) || '无');
  176. console.log('userLogin 存储:', wx.getStorageSync('userLogin') || '无');
  177. console.log('force 参数:', force);
  178. console.log('===========================================');
  179. // 修改:不强制登录,允许游客访问
  180. if (!currentUser || force) {
  181. console.log('🔄 开始调用 checkAuth...');
  182. // 尝试静默登录(不强制授权)
  183. let r = await checkAuth(false) // 改为 false,不强制授权
  184. console.log('===========================================');
  185. console.log('======= checkAuth 返回结果 =======');
  186. console.log('返回值:', r);
  187. // 重新获取用户信息
  188. currentUser = Parse.User.current();
  189. console.log('checkAuth 后的用户:', currentUser ? currentUser.id : '无');
  190. console.log('checkAuth 后的手机号:', currentUser?.get('mobile') || '无');
  191. console.log('checkAuth 后的 Session Token:', currentUser?.getSessionToken()?.substring(0, 20) || '无');
  192. console.log('===========================================');
  193. // 即使登录失败,也允许继续访问
  194. if(!r) {
  195. console.log('⚠️ 用户未登录或拒绝授权,允许游客访问');
  196. // 不要 return,继续执行后面的跳转逻辑
  197. } else {
  198. // 登录成功,设置 userLogin
  199. if (currentUser && currentUser.get('mobile')) {
  200. wx.setStorageSync("userLogin", currentUser.id);
  201. console.log('✅ 授权登录成功,已设置 userLogin:', currentUser.id);
  202. console.log('✅ 用户手机号:', currentUser.get('mobile'));
  203. } else {
  204. console.warn('⚠️ checkAuth 返回成功,但用户没有手机号!');
  205. console.warn(' 用户对象:', currentUser);
  206. }
  207. // 检查是否有待记录的扫码信息
  208. await this.checkAndRecordPendingScan();
  209. }
  210. } else {
  211. console.log('✅ 用户已登录,跳过 checkAuth');
  212. // 用户已登录,确保 userLogin 已设置
  213. if (currentUser.get('mobile')) {
  214. wx.setStorageSync("userLogin", currentUser.id);
  215. console.log('✅ 已确认 userLogin:', currentUser.id);
  216. }
  217. this.updateUser(currentUser.id)
  218. // 用户已登录,检查是否有待记录的扫码信息
  219. await this.checkAndRecordPendingScan();
  220. }
  221. getApp().Parse = Parse
  222. getApp().checkAuth = checkAuth
  223. if (!await this.getCompanyServerExpire(url)) {
  224. return
  225. }
  226. // 检查是否需要跳转到活动页面
  227. if (wx.getStorageSync('need_activity_redirect') === true) {
  228. await this.redirectToActivityPage();
  229. return;
  230. }
  231. // 检查是否需要跳转到扫码统计页面
  232. if (this.shouldRedirectToScanPage()) {
  233. await this.redirectToScanPage();
  234. return;
  235. }
  236. console.log('✅ 准备跳转到:', url);
  237. wx.redirectTo({
  238. url: url,
  239. success: () => {
  240. console.log('✅ redirectTo 跳转成功');
  241. },
  242. fail: (err) => {
  243. console.error('❌ redirectTo 失败:', err);
  244. console.log('⚠️ 尝试使用 reLaunch');
  245. // 降级:尝试使用 reLaunch
  246. wx.reLaunch({
  247. url: url,
  248. success: () => {
  249. console.log('✅ reLaunch 跳转成功');
  250. },
  251. fail: (err2) => {
  252. console.error('❌ reLaunch 也失败:', err2);
  253. // 显示错误提示
  254. this.setData({ loading: false });
  255. wx.showModal({
  256. title: '温馨提示',
  257. content: '页面加载失败,请检查网络后重试。',
  258. showCancel: true,
  259. cancelText: '退出',
  260. confirmText: '重试',
  261. success: (result) => {
  262. if (result.confirm) {
  263. this.review(true);
  264. } else {
  265. wx.exitMiniProgram();
  266. }
  267. }
  268. });
  269. }
  270. });
  271. }
  272. });
  273. }
  274. catch (err) {
  275. console.log(err);
  276. /* 登录身份信息到期,重新登陆 */
  277. if((err?.message.indexOf('Session token is expired') != -1 || err?.message.indexOf('Invalid session token') != -1) && !force){
  278. let invite = wx.getStorageSync('invite')
  279. wx.clearStorageSync()
  280. invite && wx.setStorageSync('invite', invite)
  281. /* 强制重新登录 */
  282. this.review(true)
  283. return
  284. }
  285. // 如果出错,尝试继续跳转到主页(游客模式)
  286. console.log('⚠️ 登录出错,尝试游客模式访问');
  287. let url = getApp().globalData.rootPage || getApp().globalData.defaultTabBar.list[0].pagePath;
  288. if (this.data.options) {
  289. let objArr = Object.keys(this.data.options)
  290. if (objArr && objArr.length > 0) {
  291. let parms = '?'
  292. objArr.forEach((o, index) => {
  293. if (index > 0) {
  294. parms += '&' + o + '=' + this.data.options[o]
  295. } else {
  296. parms += o + '=' + this.data.options[o]
  297. }
  298. })
  299. url += parms
  300. }
  301. }
  302. wx.redirectTo({
  303. url: url,
  304. fail: () => {
  305. // 如果跳转失败,显示错误提示
  306. this.setData({
  307. loading:false
  308. })
  309. wx.showModal({
  310. title: '温馨提示',
  311. content: '页面加载失败,请检查网络后重试。',
  312. showCancel: true,
  313. cancelText: '退出',
  314. confirmText: '重试',
  315. success: (result) => {
  316. if (result.confirm) {
  317. // 用户选择重试
  318. this.review(true)
  319. } else {
  320. // 用户选择退出
  321. wx.exitMiniProgram()
  322. }
  323. },
  324. });
  325. }
  326. });
  327. }
  328. },
  329. /**
  330. * 检查并记录待处理的扫码统计
  331. */
  332. async checkAndRecordPendingScan() {
  333. try {
  334. const pendingScan = wx.getStorageSync('pending_scan_record');
  335. if (!pendingScan) {
  336. return;
  337. }
  338. console.log('===========================================');
  339. console.log('======= 发现待记录的扫码信息 =======');
  340. console.log('扫码信息:', pendingScan);
  341. console.log('===========================================');
  342. // 检查是否超时(24小时)
  343. const now = Date.now();
  344. const scanTime = pendingScan.timestamp || 0;
  345. const hoursPassed = (now - scanTime) / (1000 * 60 * 60);
  346. if (hoursPassed > 24) {
  347. console.log('⚠️ 扫码信息已超过24小时,不再记录');
  348. wx.removeStorageSync('pending_scan_record');
  349. return;
  350. }
  351. // 记录扫码统计
  352. await this.recordScanStatistics({
  353. storeId: pendingScan.storeId,
  354. sourceType: pendingScan.sourceType,
  355. sourceId: pendingScan.sourceId,
  356. ownerId: pendingScan.ownerId,
  357. employeeId: pendingScan.employeeId,
  358. partnerId: pendingScan.partnerId,
  359. userId: pendingScan.userId,
  360. productId: pendingScan.productId,
  361. scanCount: pendingScan.scanCount
  362. });
  363. // 清除待记录的扫码信息
  364. wx.removeStorageSync('pending_scan_record');
  365. console.log('✅ 扫码统计已记录并清除');
  366. } catch (error) {
  367. console.error('❌ 记录待处理扫码信息失败:', error);
  368. }
  369. },
  370. async updateUser(id) {
  371. let User = new Parse.Query('_User')
  372. let user = await User.get(id)
  373. let invite = wx.getStorageSync('invite')
  374. //查询邀请人user
  375. let query = new Parse.Query("_User")
  376. query.equalTo('objectId', invite)
  377. let result = await query.first()
  378. if (result && result.id && result.get("invite")?.id == user.id) {
  379. console.error('邀请人不能是自己的下级')
  380. return
  381. }
  382. if (invite && !user.get('invite') && user.id != invite && !user.get('agentLevel')) {
  383. console.log('上下级绑定成功');
  384. user.set('invite', {
  385. __type: "Pointer",
  386. className: "_User",
  387. objectId: invite
  388. })
  389. user.set('agent', {
  390. __type: "Pointer",
  391. className: "_User",
  392. objectId: invite
  393. })
  394. await Parse.Cloud.run('user_save', {
  395. userJson: user.toJSON()
  396. })
  397. }
  398. },
  399. async getCompanyServerExpire(url) {
  400. let query = new Parse.Query('Company')
  401. query.equalTo('objectId', getApp().globalData.company)
  402. query.select('expireDate', 'expireMap')
  403. let com = await query.first()
  404. if (com?.id && com?.get('expireDate')) {
  405. let now = + new Date()
  406. let expireTime = + new Date(com?.get('expireDate'))
  407. if (com?.get('expireMap') && com.get('expireMap')[getApp().globalData.appid]) {
  408. expireTime = + new Date(com.get('expireMap')[getApp().globalData.appid])
  409. }
  410. if (now >= expireTime) {
  411. console.log('服务器到期');
  412. wx.reLaunch({
  413. url: `common-page/pages/loading/index?url=${url}`,
  414. });
  415. return
  416. }
  417. }
  418. return true
  419. },
  420. onUnload: function () {
  421. wx.setStorageSync("active", 0);
  422. },
  423. getParaName(url) {
  424. if (!url || url.indexOf('?') == -1) {
  425. return
  426. }
  427. // 兼容 URL 中 & 的情况,先统一还原为 &
  428. if (url.indexOf('&') !== -1) {
  429. url = url.replace(/&/g, '&');
  430. }
  431. // 提取查询参数部分(去除可能的 hash 部分)
  432. let queryString = url.split('?')[1];
  433. // 如果包含 #,只取 # 之前的部分
  434. if (queryString.indexOf('#') !== -1) {
  435. queryString = queryString.split('#')[0];
  436. }
  437. return this.setObject(queryString) //封装成对象
  438. },
  439. setObject(paraArr) {
  440. let obj = {}
  441. let arr1 = paraArr.split('&')
  442. arr1.forEach(item => {
  443. let str = item.split('=')
  444. let key = str[0]
  445. let val = str[1]
  446. obj[key] = val
  447. })
  448. return obj
  449. },
  450. /**
  451. * 检查并处理扫码参数
  452. * 支持所有类型的二维码:
  453. * 1. 推广员二维码: ?scanCount=0&storeId=xxx&userId=xxx
  454. * 2. 产品二维码: ?scanCount=0&storeId=xxx&productId=xxx
  455. * 3. 案例二维码: ?scanCount=0&storeId=xxx&caseId=xxx
  456. * 4. 活动海报二维码: activityId作为qrCode参数值
  457. * 5. 异业合作伙伴二维码(移动端 / PC端统一): ?scanCount=xxx&storeId=xxx&partnerId=xxx
  458. * 6. 员工邀请二维码(移动端): ?scanCount=0&storeId=xxx&employeeId=xxx
  459. * 7. 我的二维码(老板): ?scanCount=0&storeId=xxx&ownerId=xxx
  460. * 8. 我的二维码(员工): ?scanCount=0&storeId=xxx&employeeId=xxx
  461. */
  462. checkAndHandleScan(options) {
  463. const {
  464. scanCount,
  465. ownerId,
  466. employeeId,
  467. partnerId,
  468. storeId,
  469. productId,
  470. caseId,
  471. userId, // 推广员二维码使用userId
  472. activityId
  473. } = options;
  474. // 处理活动海报二维码(activityId作为qrCode参数值)
  475. if (activityId && !storeId) {
  476. console.log('===========================================');
  477. console.log('======= 检测到活动海报二维码 =======');
  478. console.log('活动ID (activityId):', activityId);
  479. console.log('===========================================');
  480. // 活动二维码需要跳转到活动页面,不需要跳转到店铺
  481. wx.setStorageSync('scan_activityId', activityId);
  482. wx.setStorageSync('need_activity_redirect', true);
  483. return;
  484. }
  485. // 如果存在 storeId,说明是扫码进入具体门店(包括异业分享)
  486. if (storeId) {
  487. console.log('===========================================');
  488. console.log('======= 检测到扫码参数 =======');
  489. console.log('店铺ID (storeId):', storeId);
  490. console.log('扫码次数 (scanCount):', scanCount || '0');
  491. // 确定来源类型
  492. let sourceType = 'unknown';
  493. let sourceId = null;
  494. if (employeeId) {
  495. sourceType = 'employee';
  496. sourceId = employeeId;
  497. console.log('来源类型: 员工展业');
  498. console.log('员工ID (employeeId):', employeeId);
  499. } else if (userId) {
  500. // 推广员二维码使用userId
  501. sourceType = 'promoter';
  502. sourceId = userId;
  503. console.log('来源类型: 推广员展业');
  504. console.log('推广员ID (userId):', userId);
  505. } else if (ownerId) {
  506. sourceType = 'owner';
  507. sourceId = ownerId;
  508. console.log('来源类型: 老板展业');
  509. console.log('老板ID (ownerId):', ownerId);
  510. } else if (partnerId) {
  511. sourceType = 'partner';
  512. sourceId = partnerId;
  513. console.log('来源类型: 异业合作伙伴');
  514. console.log('合作伙伴ID (partnerId):', partnerId);
  515. } else {
  516. sourceType = 'store';
  517. console.log('来源类型: 店铺分享');
  518. }
  519. if (productId) {
  520. console.log('产品ID (productId):', productId);
  521. }
  522. if (caseId) {
  523. console.log('案例ID (caseId):', caseId);
  524. }
  525. console.log('===========================================');
  526. // 保存到临时存储,用于后续跳转和统计
  527. wx.setStorageSync('scan_storeId', storeId);
  528. wx.setStorageSync('scan_scanCount', scanCount || '0');
  529. wx.setStorageSync('scan_sourceType', sourceType);
  530. wx.setStorageSync('scan_sourceId', sourceId || '');
  531. wx.setStorageSync('scan_ownerId', ownerId || '');
  532. wx.setStorageSync('scan_employeeId', employeeId || '');
  533. wx.setStorageSync('scan_partnerId', partnerId || '');
  534. wx.setStorageSync('scan_userId', userId || '');
  535. if (productId) {
  536. wx.setStorageSync('scan_productId', productId);
  537. }
  538. if (caseId) {
  539. wx.setStorageSync('scan_caseId', caseId);
  540. }
  541. wx.setStorageSync('need_scan_redirect', true);
  542. } else if (partnerId) {
  543. // 理论上异业二维码现在也必须带 storeId,这里仅作为兜底保护
  544. console.warn('⚠️ 检测到异业合作伙伴二维码缺少 storeId,无法确定门店,请检查二维码生成逻辑');
  545. }
  546. },
  547. /**
  548. * 判断是否需要跳转到扫码统计页面
  549. */
  550. shouldRedirectToScanPage() {
  551. return wx.getStorageSync('need_scan_redirect') === true;
  552. },
  553. /**
  554. * 跳转到扫码对应的店铺页面
  555. * 根据 storeId 跳转到对应店铺,同时记录所有来源信息用于统计
  556. */
  557. async redirectToScanPage() {
  558. try {
  559. // 获取所有扫码相关参数
  560. const storeId = wx.getStorageSync('scan_storeId');
  561. const scanCount = wx.getStorageSync('scan_scanCount');
  562. const sourceType = wx.getStorageSync('scan_sourceType');
  563. const sourceId = wx.getStorageSync('scan_sourceId');
  564. const ownerId = wx.getStorageSync('scan_ownerId');
  565. const employeeId = wx.getStorageSync('scan_employeeId');
  566. const partnerId = wx.getStorageSync('scan_partnerId');
  567. const userId = wx.getStorageSync('scan_userId');
  568. const productId = wx.getStorageSync('scan_productId');
  569. const caseId = wx.getStorageSync('scan_caseId');
  570. // 清除临时存储
  571. wx.removeStorageSync('scan_storeId');
  572. wx.removeStorageSync('scan_scanCount');
  573. wx.removeStorageSync('scan_sourceType');
  574. wx.removeStorageSync('scan_sourceId');
  575. wx.removeStorageSync('scan_ownerId');
  576. wx.removeStorageSync('scan_employeeId');
  577. wx.removeStorageSync('scan_partnerId');
  578. wx.removeStorageSync('scan_userId');
  579. wx.removeStorageSync('scan_productId');
  580. wx.removeStorageSync('scan_caseId');
  581. wx.removeStorageSync('need_scan_redirect');
  582. if (!storeId) {
  583. console.error('❌ 缺少 storeId 参数,无法跳转');
  584. return;
  585. }
  586. console.log('===========================================');
  587. console.log('======= 扫码进入店铺 =======');
  588. console.log('店铺 ID (storeId):', storeId);
  589. console.log('来源类型 (sourceType):', sourceType);
  590. console.log('来源 ID (sourceId):', sourceId || '无');
  591. console.log('扫码次数 (scanCount):', scanCount);
  592. if (ownerId) console.log('老板 ID (ownerId):', ownerId);
  593. if (employeeId) console.log('员工 ID (employeeId):', employeeId);
  594. if (partnerId) console.log('合作伙伴 ID (partnerId):', partnerId);
  595. if (userId) console.log('推广员 ID (userId):', userId);
  596. if (productId) console.log('产品 ID (productId):', productId);
  597. if (caseId) console.log('案例 ID (caseId):', caseId);
  598. console.log('===========================================');
  599. // 设置店铺 ID 到全局和本地存储
  600. wx.setStorageSync('storeId', storeId);
  601. getApp().globalData.storeId = storeId;
  602. // 保存来源信息到本地存储(用于后续统计或绑定关系)
  603. if (sourceId) {
  604. wx.setStorageSync('scan_from_sourceType', sourceType);
  605. wx.setStorageSync('scan_from_sourceId', sourceId);
  606. console.log('✅ 已记录来源信息:', sourceType, sourceId);
  607. }
  608. // 检查用户是否已登录
  609. const currentUser = Parse.User.current();
  610. if (currentUser) {
  611. // 用户已登录,立即记录扫码统计
  612. console.log('✅ 用户已登录,记录扫码统计');
  613. await this.recordScanStatistics({
  614. storeId,
  615. sourceType,
  616. sourceId,
  617. ownerId,
  618. employeeId,
  619. partnerId,
  620. userId,
  621. productId,
  622. scanCount
  623. });
  624. } else {
  625. // 用户未登录,保存扫码信息,等登录后再记录
  626. console.log('⚠️ 用户未登录,保存扫码信息待登录后记录');
  627. wx.setStorageSync('pending_scan_record', {
  628. storeId,
  629. sourceType,
  630. sourceId,
  631. ownerId,
  632. employeeId,
  633. partnerId,
  634. userId,
  635. productId,
  636. scanCount,
  637. timestamp: Date.now()
  638. });
  639. }
  640. // 如果有产品ID,直接跳转到产品详情的 H5 页面
  641. if (productId) {
  642. console.log('🎯 检测到产品ID,跳转到产品详情页');
  643. await this.redirectToProductDetail(storeId, productId, partnerId);
  644. return;
  645. }
  646. // 如果有案例ID,直接跳转到案例详情的 H5 页面
  647. if (caseId) {
  648. console.log('🎯 检测到案例ID,跳转到案例详情页');
  649. await this.redirectToCaseDetail(storeId, caseId, partnerId);
  650. return;
  651. }
  652. // 获取默认首页路径并跳转
  653. let url = getApp().globalData.rootPage || getApp().globalData.defaultTabBar.list[0].pagePath;
  654. url += `?storeId=${storeId}`;
  655. // 如果有产品ID,添加到URL参数中
  656. if (productId) {
  657. url += `&productId=${productId}`;
  658. }
  659. // 如果有异业合作伙伴ID,添加到URL参数中传回web-view
  660. if (partnerId) {
  661. url += `&partnerId=${partnerId}`;
  662. }
  663. console.log('✅ 跳转到店铺页面:', url);
  664. wx.redirectTo({
  665. url: url,
  666. fail: (err) => {
  667. console.error('❌ 跳转失败:', err);
  668. // 如果 redirectTo 失败,尝试 reLaunch
  669. wx.reLaunch({
  670. url: url,
  671. fail: (err2) => {
  672. console.error('❌ reLaunch 也失败:', err2);
  673. }
  674. });
  675. }
  676. });
  677. } catch (error) {
  678. console.error('❌ 跳转到店铺页面失败:', error);
  679. }
  680. },
  681. /**
  682. * 跳转到活动页面
  683. */
  684. async redirectToActivityPage() {
  685. try {
  686. const activityId = wx.getStorageSync('scan_activityId');
  687. // 清除临时存储
  688. wx.removeStorageSync('scan_activityId');
  689. wx.removeStorageSync('need_activity_redirect');
  690. if (!activityId) {
  691. console.error('❌ 缺少 activityId 参数,无法跳转');
  692. return;
  693. }
  694. console.log('===========================================');
  695. console.log('======= 扫码进入活动页面 =======');
  696. console.log('活动 ID (activityId):', activityId);
  697. console.log('===========================================');
  698. // 保存活动ID
  699. wx.setStorageSync('activityId', activityId);
  700. // 获取默认首页路径并跳转(活动页面可能需要根据实际路由调整)
  701. let url = getApp().globalData.rootPage || getApp().globalData.defaultTabBar.list[0].pagePath;
  702. url += `?activityId=${activityId}`;
  703. console.log('✅ 跳转到活动页面:', url);
  704. wx.redirectTo({
  705. url: url,
  706. fail: (err) => {
  707. console.error('❌ 跳转失败:', err);
  708. wx.reLaunch({
  709. url: url,
  710. fail: (err2) => {
  711. console.error('❌ reLaunch 也失败:', err2);
  712. }
  713. });
  714. }
  715. });
  716. } catch (error) {
  717. console.error('❌ 跳转到活动页面失败:', error);
  718. }
  719. },
  720. /**
  721. * 跳转到产品详情的 H5 页面
  722. * @param {string} storeId - 店铺 ID
  723. * @param {string} productId - 产品 ID
  724. * @param {string} partnerId - 可选的合作伙伴 ID
  725. */
  726. async redirectToProductDetail(storeId, productId, partnerId = null) {
  727. try {
  728. console.log('===========================================');
  729. console.log('======= 跳转到产品详情页 =======');
  730. console.log('店铺 ID:', storeId);
  731. console.log('产品 ID:', productId);
  732. if (partnerId) console.log('合作伙伴 ID:', partnerId);
  733. console.log('===========================================');
  734. const currentUser = Parse.User.current();
  735. const token = currentUser ? currentUser.getSessionToken() : null;
  736. // 构建产品详情的 H5 URL(不要在这里编码,后面统一编码)
  737. let h5Url = `https://app.fmode.cn/dev/pobingfeng/owner/nav/products?storeId=${storeId}`;
  738. // 如果有 token,添加到 URL
  739. if (token) {
  740. h5Url += `&token=${token}`;
  741. } else {
  742. // 如果没有 token,使用游客模式
  743. h5Url += `&guestMode=true`;
  744. }
  745. // 添加产品ID(不要在这里编码,避免双重编码)
  746. h5Url += `&productId=${productId}`;
  747. // 如果有合作伙伴ID,也添加到URL中
  748. if (partnerId) {
  749. h5Url += `&partnerId=${partnerId}`;
  750. }
  751. console.log('🌐 H5 URL:', h5Url);
  752. // 编码 URL(统一在这里编码一次)
  753. const encodedUrl = encodeURIComponent(h5Url);
  754. // 构建 web-view 页面路径
  755. let webViewPath = `/common-page/pages/web-view/index?path=${encodedUrl}&storeId=${storeId}`;
  756. console.log('📄 web-view 页面路径:', webViewPath.substring(0, 100) + '...');
  757. console.log('===========================================');
  758. wx.redirectTo({
  759. url: webViewPath,
  760. success: () => {
  761. console.log('✅ 跳转到产品详情页成功');
  762. },
  763. fail: (err) => {
  764. console.error('❌ 跳转失败:', err);
  765. // 如果 redirectTo 失败,尝试 reLaunch
  766. wx.reLaunch({
  767. url: webViewPath,
  768. fail: (err2) => {
  769. console.error('❌ reLaunch 也失败:', err2);
  770. }
  771. });
  772. }
  773. });
  774. } catch (error) {
  775. console.error('❌ 跳转到产品详情页失败:', error);
  776. }
  777. },
  778. /**
  779. * 跳转到案例详情的 H5 页面
  780. * @param {string} storeId - 店铺 ID
  781. * @param {string} caseId - 案例 ID
  782. * @param {string} partnerId - 可选的合作伙伴 ID
  783. */
  784. async redirectToCaseDetail(storeId, caseId, partnerId = null) {
  785. try {
  786. console.log('===========================================');
  787. console.log('======= 跳转到案例详情页 =======');
  788. console.log('店铺 ID:', storeId);
  789. console.log('案例 ID:', caseId);
  790. if (partnerId) console.log('合作伙伴 ID:', partnerId);
  791. console.log('===========================================');
  792. const currentUser = Parse.User.current();
  793. const token = currentUser ? currentUser.getSessionToken() : null;
  794. // 构建案例详情的 H5 URL(不要在这里编码,后面统一编码)
  795. let h5Url = `https://app.fmode.cn/dev/pobingfeng/owner/nav/cases?storeId=${storeId}`;
  796. // 如果有 token,添加到 URL
  797. if (token) {
  798. h5Url += `&token=${token}`;
  799. } else {
  800. // 如果没有 token,使用游客模式
  801. h5Url += `&guestMode=true`;
  802. }
  803. // 添加案例ID(不要在这里编码,避免双重编码)
  804. h5Url += `&caseId=${caseId}`;
  805. // 如果有合作伙伴ID,也添加到URL中
  806. if (partnerId) {
  807. h5Url += `&partnerId=${partnerId}`;
  808. }
  809. console.log('🌐 H5 URL:', h5Url);
  810. // 编码 URL(统一在这里编码一次)
  811. const encodedUrl = encodeURIComponent(h5Url);
  812. // 构建 web-view 页面路径
  813. let webViewPath = `/common-page/pages/web-view/index?path=${encodedUrl}&storeId=${storeId}`;
  814. console.log('📄 web-view 页面路径:', webViewPath.substring(0, 100) + '...');
  815. console.log('===========================================');
  816. wx.redirectTo({
  817. url: webViewPath,
  818. success: () => {
  819. console.log('✅ 跳转到案例详情页成功');
  820. },
  821. fail: (err) => {
  822. console.error('❌ 跳转失败:', err);
  823. // 如果 redirectTo 失败,尝试 reLaunch
  824. wx.reLaunch({
  825. url: webViewPath,
  826. fail: (err2) => {
  827. console.error('❌ reLaunch 也失败:', err2);
  828. }
  829. });
  830. }
  831. });
  832. } catch (error) {
  833. console.error('❌ 跳转到案例详情页失败:', error);
  834. }
  835. },
  836. /**
  837. * 记录扫码统计信息
  838. * @param {Object} params - 扫码参数对象
  839. * @param {string} params.storeId - 店铺 ID
  840. * @param {string} params.sourceType - 来源类型 (employee/owner/partner/promoter/store)
  841. * @param {string} params.sourceId - 来源 ID
  842. * @param {string} params.ownerId - 老板 ID
  843. * @param {string} params.employeeId - 员工 ID
  844. * @param {string} params.partnerId - 合作伙伴 ID
  845. * @param {string} params.userId - 推广员 ID
  846. * @param {string} params.productId - 产品 ID
  847. * @param {string} params.scanCount - 扫码次数
  848. */
  849. async recordScanStatistics(params) {
  850. try {
  851. const {
  852. storeId,
  853. sourceType,
  854. sourceId,
  855. ownerId,
  856. employeeId,
  857. partnerId,
  858. userId,
  859. productId,
  860. scanCount
  861. } = params;
  862. // 检查用户是否已登录
  863. const currentUser = Parse.User.current();
  864. if (!currentUser) {
  865. console.log('⚠️ 用户未登录,不记录扫码统计');
  866. return;
  867. }
  868. // 如果没有来源信息,不记录统计
  869. if (!sourceId && !ownerId && !employeeId && !partnerId && !userId) {
  870. console.log('ℹ️ 无来源信息,跳过统计记录');
  871. return;
  872. }
  873. console.log('✅ 用户已登录,记录扫码统计');
  874. // 创建扫码记录
  875. const ScanRecord = Parse.Object.extend('ScanRecord');
  876. const record = new ScanRecord();
  877. record.set('company', {
  878. __type: 'Pointer',
  879. className: 'Company',
  880. objectId: getApp().globalData.company
  881. });
  882. record.set('storeId', storeId);
  883. record.set('sourceType', sourceType || 'unknown');
  884. record.set('scanCount', parseInt(scanCount) || 0);
  885. record.set('scanTime', new Date());
  886. // 根据来源类型设置对应的ID
  887. if (ownerId) {
  888. record.set('ownerId', ownerId);
  889. }
  890. if (employeeId) {
  891. record.set('employeeId', employeeId);
  892. }
  893. if (partnerId) {
  894. record.set('partnerId', partnerId);
  895. }
  896. if (userId) {
  897. record.set('userId', userId);
  898. }
  899. if (productId) {
  900. record.set('productId', productId);
  901. }
  902. // 记录扫码用户
  903. record.set('user', {
  904. __type: 'Pointer',
  905. className: '_User',
  906. objectId: currentUser.id
  907. });
  908. await record.save();
  909. console.log('✅ 扫码记录已保存');
  910. // 如果存在异业合作伙伴ID,处理异业绑定和扫码次数
  911. if (partnerId) {
  912. try {
  913. console.log('===========================================');
  914. console.log('======= 处理异业扫码逻辑 =======');
  915. console.log('用户ID:', currentUser.id);
  916. console.log('异业ID:', partnerId);
  917. console.log('门店ID:', storeId);
  918. // 检查用户是否已经绑定了异业合作伙伴
  919. const userBoundPartner = currentUser.get('Partner');
  920. const userBoundPartnerId = userBoundPartner ? userBoundPartner.id : null;
  921. console.log('用户已绑定的异业ID:', userBoundPartnerId || '无');
  922. // 规则1:如果用户已绑定其他异业,不处理当前异业的扫码
  923. if (userBoundPartnerId && userBoundPartnerId !== partnerId) {
  924. console.log('⚠️ 用户已绑定其他异业,不处理当前异业的扫码');
  925. console.log(' 已绑定异业:', userBoundPartnerId);
  926. console.log(' 当前扫码异业:', partnerId);
  927. console.log('===========================================');
  928. return;
  929. }
  930. // 规则2:检查该用户在该门店是否已经扫过该异业的码
  931. const ScanRecord = Parse.Object.extend('ScanRecord');
  932. const scanQuery = new Parse.Query(ScanRecord);
  933. scanQuery.equalTo('user', {
  934. __type: 'Pointer',
  935. className: '_User',
  936. objectId: currentUser.id
  937. });
  938. scanQuery.equalTo('partnerId', partnerId);
  939. scanQuery.equalTo('storeId', storeId);
  940. const existingScan = await scanQuery.first();
  941. if (existingScan) {
  942. console.log('⚠️ 该用户在该门店已扫过该异业的码,不重复计数');
  943. console.log(' 首次扫码时间:', existingScan.get('scanTime'));
  944. console.log('===========================================');
  945. return;
  946. }
  947. console.log('✅ 该用户在该门店首次扫该异业码');
  948. // 规则3:如果用户还没有绑定异业,绑定当前异业
  949. if (!userBoundPartnerId) {
  950. console.log('🔗 用户首次扫异业码,绑定异业合作伙伴:', partnerId);
  951. currentUser.set('Partner', {
  952. __type: 'Pointer',
  953. className: 'Partner',
  954. objectId: partnerId
  955. });
  956. await currentUser.save();
  957. console.log('✅ 异业绑定成功');
  958. }
  959. // 规则4:为该异业在该门店增加扫码次数
  960. const Partner = Parse.Object.extend('Partner');
  961. const partnerQuery = new Parse.Query(Partner);
  962. const partnerObj = await partnerQuery.get(partnerId);
  963. if (partnerObj) {
  964. // 获取或初始化门店扫码次数映射
  965. let storeScans = partnerObj.get('storeScans') || {};
  966. // 为该门店的扫码次数 +1
  967. storeScans[storeId] = (storeScans[storeId] || 0) + 1;
  968. partnerObj.set('storeScans', storeScans);
  969. // 同时更新总扫码次数
  970. partnerObj.increment('scanCount', 1);
  971. await partnerObj.save();
  972. console.log('✅ 异业扫码次数已更新');
  973. console.log(' 门店ID:', storeId);
  974. console.log(' 该门店扫码次数:', storeScans[storeId]);
  975. console.log(' 总扫码次数:', partnerObj.get('scanCount'));
  976. }
  977. console.log('===========================================');
  978. } catch (e) {
  979. console.error('❌ 处理异业合作伙伴绑定失败:', e);
  980. console.log('===========================================');
  981. }
  982. }
  983. } catch (error) {
  984. console.warn('⚠️ 保存扫码记录失败:', error);
  985. // 不影响主流程
  986. }
  987. }
  988. });