+ 
+
+
+
+ 结伴客管理
+ JK +
+
+ 首页
+ {{ currentRouteMeta.title }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ userName }}
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/pages/animal/index.vue b/admin-system/src/pages/animal/index.vue
new file mode 100644
index 0000000..cf0d261
--- /dev/null
+++ b/admin-system/src/pages/animal/index.vue
@@ -0,0 +1,688 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 登录
+
+
+
+
+
+
+
+
+
+ {{ appName }}
+欢迎回来，请登录您的账号
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ getTypeText(record.type) }}
+
+
+
+
+
+ {{ getStatusText(record.status) }}
+
+
+
+
+ ¥{{ record.price }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ getClaimStatusText(record.status) }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/pages/dashboard/index.vue b/admin-system/src/pages/dashboard/index.vue
new file mode 100644
index 0000000..3d3a816
--- /dev/null
+++ b/admin-system/src/pages/dashboard/index.vue
@@ -0,0 +1,245 @@
+
+
+
+
+
+
+
+
+ 羊驼
+ 狗狗
+ 猫咪
+ 兔子
+
+
+
+
+
+ 可认领
+ 已认领
+ 预留中
+
+
+
+
+
+
+
+
+ 重置
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 待审核
+ 已通过
+ 已拒绝
+ 已完成
+
+
+
+
+
+
+
+
+ 重置
+
+
+
+
+
+
+
+
+
+
+ 刷新
+ 导出数据
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ item.title }}
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ appVersion }}
+
+
+ {{ environment }}
+
+
+ {{ startupTime }}
+
+
+ 256MB / 2GB
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/pages/merchant/index.vue b/admin-system/src/pages/merchant/index.vue
new file mode 100644
index 0000000..b29f4a8
--- /dev/null
+++ b/admin-system/src/pages/merchant/index.vue
@@ -0,0 +1,420 @@
+
+
+
+ 用户增长图表
+
+
+ 订单分布图表
+{{ item.time }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ getTypeText(record.type) }}
+
+
+
+
+
+ {{ getStatusText(record.status) }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/pages/order/index.vue b/admin-system/src/pages/order/index.vue
new file mode 100644
index 0000000..5d10765
--- /dev/null
+++ b/admin-system/src/pages/order/index.vue
@@ -0,0 +1,437 @@
+
+
+
+
+
+
+
+
+ 花店
+ 活动组织
+ 农场主
+
+
+
+
+
+ 待审核
+ 已通过
+ 已拒绝
+ 已禁用
+
+
+
+
+
+
+
+
+ 重置
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ record.order_no }}
+
+
+ ¥{{ record.amount }}
+
+
+ {{ getStatusText(record.status) }}
+
+
+
+ {{ getPaymentMethodText(record.payment_method) }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ <极速版CloseOutlined />取消
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/pages/promotion/index.vue b/admin-system/src/pages/promotion/index.vue
new file mode 100644
index 0000000..7bd9f84
--- /dev/null
+++ b/admin-system/src/pages/promotion/index.vue
@@ -0,0 +1,573 @@
+
+
+
+
+
+
+
+
+ 待支付
+ 已支付
+ 已发货
+ 已完成
+ 已取消
+ 已退款
+
+
+
+
+
+
+
+
+
+ 重置
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ getStatusText(record.status) }}
+
+
+
+ {{ getRewardTypeText(record.reward_type) }}
+
+
+
+ ¥{{ record.reward_amount }}
+ {{ record.reward_amount }}积分
+ {{ record.re极速版ward_amount }}元券
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ getRewardTypeText(record.reward_type) }}
+
+
+
+ ¥{{ record.reward_amount }}
+ {{ record.reward_amount }}积分
+ {{ record.reward_amount }}元券
+
+
+
+ {{ getRewardStatusText(record.status) }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/pages/system/index.vue b/admin-system/src/pages/system/index.vue
new file mode 100644
index 0000000..ee2c43d
--- /dev/null
+++ b/admin-system/src/pages/system/index.vue
@@ -0,0 +1,289 @@
+
+
+
+
+
+
+
+
+ 进行中
+ 未开始
+ 已结束
+ 已暂停
+
+
+
+
+
+
+
+
+
+ 重置
+
+
+
+
+
+ {{ record.current_participants }}/{{ record.max_participants }}
+
+
+
+
+
+
+
+
+
+
+
+ 现金
+ 积分
+ 优惠券
+
+
+
+
+
+ 待发放
+ 已发放
+ 发放失败
+
+
+
+
+
+
+ 重置
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ v1.0.0
+ Production
+ <极速版a-descriptions-item label="启动时间">2024-03-15 10:00:00
+ 12天3小时
+
+
+
+
+
+
+
+
+ 正常
+
+ MySQL
+ 15极速版/100
+ 1,234次/分钟
+
+
+
+
+
+
+
+
+ 正常
+
+ 65%
+ 92%
+ 1,234
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ item.status === 'running' ? '运行中' : '停止' }}
+
+ {{ item.name }}
+
+
+
+
+
+
+
+
+
+ 停止
+
+
+ 启动
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 保存设置
+ 重置
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/pages/travel/index.vue b/admin-system/src/pages/travel/index.vue
new file mode 100644
index 0000000..d12db8c
--- /dev/null
+++ b/admin-system/src/pages/travel/index.vue
@@ -0,0 +1,382 @@
+
+ 用户登录成功 - admin (2024-03-15 14:30:22)
+ +数据库备份完成 - 备份文件: backup_20240315.sql (2024-03-15 14:00:00)
+系统警告 - 内存使用率超过80% (2024-03-15 13:极速版45:18) +
定时任务执行 - 清理过期日志 (2024-03-15 13:30:00)
+
+ 查看完整日志
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ record.destination }}
+
+ {{ getStatusText(record.status) }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/pages/user/index.vue b/admin-system/src/pages/user/index.vue
new file mode 100644
index 0000000..12d8776
--- /dev/null
+++ b/admin-system/src/pages/user/index.vue
@@ -0,0 +1,650 @@
+
+
+
+
+
+
+
+
+ 招募中
+ 已满员
+ 已完成
+ 已取消
+
+
+
+
+
+
+
+
+
+
+
+ 重置
+
+
+
+
+
+
+
+ {{ record.start_date }} 至 {{ record.end_date }}
+
+
+
+
+ ¥{{ record.budget }}
+
+
+
+
+ {{ record.current_members }}/{{ record.max_members }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{ record.nickname?.charAt(0) }}
+
+
+
+
+
+ {{ getStatusText(record.status) }}
+
+
+
+
+ Lv.{{ record.level }}
+
+
+
+
+
+
+
+
+
+
+
+
+ 更多
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 正常
+ 禁用
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/admin-system/src/router/index.ts b/admin-system/src/router/index.ts
new file mode 100644
index 0000000..3b7f274
--- /dev/null
+++ b/admin-system/src/router/index.ts
@@ -0,0 +1,142 @@
+import { createRouter, createWebHistory } from 'vue-router'
+import type { RouteRecordRaw } from 'vue-router'
+
+// 基础路由
+const routes: RouteRecordRaw[] = [
+ {
+ path: '/',
+ redirect: '/dashboard',
+ meta: { requiresAuth: true }
+ },
+ {
+ path: '/login',
+ name: 'Login',
+ component: () => import('@/pages/Login.vue'),
+ meta: { requiresAuth: false, layout: 'auth' }
+ },
+ {
+ path: '/dashboard',
+ name: 'Dashboard',
+ component: () => import('@/pages/dashboard/index.vue'),
+ meta: {
+ requiresAuth: true,
+ title: '仪表板',
+ icon: 'DashboardOutlined'
+ }
+ },
+ {
+ path: '/users',
+ name: 'Users',
+ component: () => import('@/pages/user/index.vue'),
+ meta: {
+ requiresAuth: true,
+ title: '用户管理',
+ icon: 'UserOutlined',
+ permissions: ['user:read']
+ }
+ },
+ {
+ path: '/merchants',
+ name: 'Merchants',
+ component: () => import('@/pages/merchant/index.vue'),
+ meta: {
+ requiresAuth: true,
+ title: '商家管理',
+ icon: 'ShopOutlined',
+ permissions: ['merchant:read']
+ }
+ },
+ {
+ path: '/travel',
+ name: 'Travel',
+ component: () => import('@/pages/travel/index.vue'),
+ meta: {
+ requiresAuth: true,
+ title: '旅行管理',
+ icon: 'CompassOutlined',
+ permissions: ['travel:read']
+ }
+ },
+ {
+ path: '/animals',
+ name: 'Animals',
+ component: () => import('@/pages/animal/index.vue'),
+ meta: {
+ requiresAuth: true,
+ title: '动物管理',
+ icon: 'HeartOutlined',
+ permissions: ['animal:read']
+ }
+ },
+ {
+ path: '/orders',
+ name: 'Orders',
+ component: () => import('@/pages/order/index.vue'),
+ meta: {
+ requiresAuth: true,
+ title: '订单管理',
+ icon: 'ShoppingCartOutlined',
+ permissions: ['order:read']
+ }
+ },
+ {
+ path: '/promotion',
+ name: 'Promotion',
+ component: () => import('@/pages/promotion/index.vue'),
+ meta: {
+ requiresAuth: true,
+ title: '推广管理',
+ icon: 'GiftOutlined',
+ permissions: ['promotion:read']
+ }
+ },
+ {
+ path: '/system',
+ name: 'System',
+ component: () => import('@/pages/system/index.vue'),
+ meta: {
+ requiresAuth: true,
+ title: '系统设置',
+ icon: 'SettingOutlined',
+ permissions: ['system:read']
+ }
+ },
+ {
+ path: '/:pathMatch(.*)*',
+ name: 'NotFound',
+ component: () => import('@/pages/NotFound.vue'),
+ meta: { requiresAuth: false }
+ }
+]
+
+const router = createRouter({
+ history: createWebHistory(),
+ routes
+})
+
+// 路由守卫
+router.beforeEach(async (to, from, next) => {
+ const { meta } = to
+ const isAuthenticated = localStorage.getItem('admin_token') !== null
+
+ // 检查是否需要认证
+ if (meta.requiresAuth && !isAuthenticated) {
+ next({ name: 'Login', query: { redirect: to.fullPath } })
+ return
+ }
+
+ // 如果已认证且访问登录页，重定向到首页
+ if (to.name === 'Login' && isAuthenticated) {
+ next({ name: 'Dashboard' })
+ return
+ }
+
+ next()
+})
+
+// 错误处理
+router.onError((error) => {
+ console.error('🚨 路由错误:', error)
+})
+
+export default router
\ No newline at end of file
diff --git a/admin-system/src/stores/app.ts b/admin-system/src/stores/app.ts
new file mode 100644
index 0000000..4b23e6d
--- /dev/null
+++ b/admin-system/src/stores/app.ts
@@ -0,0 +1,127 @@
+import { defineStore } from 'pinia'
+import { ref } from 'vue'
+
+interface AppState {
+ // 应用配置
+ name: string
+ version: string
+ // 用户信息
+ user: any
+ // 系统状态
+ loading: boolean
+ error: string | null
+ // 功能开关
+ features: {
+ analytics: boolean
+ debug: boolean
+ }
+}
+
+export const useAppStore = defineStore('app', () => {
+ // 状态
+ const state = ref
+
+
+
+
+
+
+ 正常
+ 禁用
+ 封禁
+
+
+
+
+
+
+
+
+
+
+
+ 重置
+
+
+
+
+
+
+ uni-app] + ADMIN[后台管理系统
Vue.js 3 + Ant Design] + WEBSITE[官网系统
HTML5 + Bootstrap] + end -+------------------+ -| 官网系统 | -| (HTML5+Bootstrap) | -+------------------+ + subgraph "接入层" + GATEWAY[API网关
Nginx + Node.js] + end + + subgraph "应用服务层" + AUTH[认证服务] + USER[用户服务] + TRAVEL[旅行服务] + ANIMAL[动物服务] + MERCHANT[商家服务] + PAYMENT[支付服务] + PROMOTION[推广服务] + end + + subgraph "基础设施层" + DB[MySQL数据库
主从复制] + CACHE[Redis缓存
集群模式] + MQ[RabbitMQ
消息队列] + STORAGE[对象存储
腾讯云COS] + end + + subgraph "监控运维层" + MONITOR[监控系统
Prometheus + Grafana] + LOG[日志系统
ELK Stack] + CI_CD[CI/CD
Jenkins + Docker] + end + + MP --> GATEWAY + ADMIN --> GATEWAY + WEBSITE --> GATEWAY + + GATEWAY --> AUTH + GATEWAY --> USER + GATEWAY --> TRAVEL + GATEWAY --> ANIMAL + GATEWAY --> MERCHANT + GATEWAY --> PAYMENT + GATEWAY --> PROMOTION + + AUTH --> DB + USER --> DB + TRAVEL --> DB + ANIMAL --> DB + MERCHANT --> DB + PAYMENT --> DB + PROMOTION --> DB + + AUTH --> CACHE + USER --> CACHE + TRAVEL --> CACHE + ANIMAL --> CACHE + MERCHANT --> CACHE + + PAYMENT --> MQ + PROMOTION --> MQ + + AUTH --> STORAGE + USER --> STORAGE + ANIMAL --> STORAGE + MERCHANT --> STORAGE + + MONITOR -.-> AUTH + MONITOR -.-> USER + MONITOR -.-> TRAVEL + MONITOR -.-> ANIMAL + MONITOR -.-> MERCHANT + + LOG -.-> AUTH + LOG -.-> USER + LOG -.-> TRAVEL + LOG -.-> ANIMAL + LOG -.-> MERCHANT + + CI_CD -.-> AUTH + CI_CD -.-> USER + CI_CD -.-> TRAVEL + CI_CD -.-> ANIMAL + CI_CD -.-> MERCHANT ``` ## 2. 项目结构 @@ -263,15 +324,13 @@ ## 2. 技术栈选型 ### 2.1 后端技术栈 -- 编程语言：Node.js (TypeScript) -- 框架：Express.js -- API规范：RESTful API -- 容器化：Docker -- 容器编排：Kubernetes -- API网关：Kong -- 监控：Prometheus + Grafana -- 日志：ELK Stack (Elasticsearch, Logstash, Kibana) - +API服务: Node.js + Express.js + TypeScript + RESTful API +数据库: MySQL +缓存系统: Redis +消息队列: RabbitMQ（用于异步处理） +文件存储: 腾讯云对象存储 +实时通信: WebSocket（用于大屏数据推送和实时通知） +API文档: Swagger ### 2.2 前端技术栈 - 小程序框架：uni-app - 开发语言：JavaScript/TypeScript diff --git a/docs/detailed_design.md b/docs/detailed_design.md index e9cd964..bd0140f 100644 --- a/docs/detailed_design.md +++ b/docs/detailed_design.md @@ -1,5 +1,20 @@ # 结伴客系统详细设计文档 +## 2.3 数据库配置 + +### 2.3.1 测试环境 +- **主机**: 192.168.0.240 (MySQL主机地址) +- **端口**: 3306 (MySQL端口) +- **用户名**: root +- **密码**: aiot$Aiot123 +- **数据库**: jiebandata + +### 2.3.2 生产环境 +- **主机**: 129.211.213.226 +- **端口**: 9527 +- **用户名**: root +- **密码**: aiotAiot123! +- **数据库**: jiebandata ## 1. 数据库设计 ### 1.1 ER图 diff --git a/init-database-clean.js b/init-database-clean.js new file mode 100644 index 0000000..6fdc4d9 --- /dev/null +++ b/init-database-clean.js @@ -0,0 +1,183 @@ +const mysql = require('mysql2'); + +// 数据库配置 +const configs = [ + { + name: '测试环境', + host: '192.168.0.240', + port: 3306, + user: 'root', + password: 'aiot$Aiot123' + }, + { + name: '生产环境', + host: '129.211.213.226', + port: 9527, + user: 'root', + password: 'aiotAiot123!' + } +]; + +// 创建数据库的SQL语句 +const createDatabaseSQL = ` +CREATE DATABASE IF NOT EXISTS jiebandata +CHARACTER SET utf8mb4 +COLLATE utf极4_unicode_ci; +`; + +// 创建用户表的SQL语句 +const createUsersTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.users ( + id INT AUTO_INCREMENT PRIMARY KEY, + openid VARCHAR(64) UNIQUE NOT NULL, + nickname VARCHAR(50) NOT NULL, + avatar VARCHAR(255), + gender ENUM('male', 'female', 'other'), + birthday DATE, + phone VARCHAR(20) UNIQUE, + email VARCHAR(100) UNIQUE, + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + INDEX idx_openid (openid), + INDEX idx_phone (phone), + INDEX idx_email (email) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; +`; + +// 创建商家表的SQL语句 +const createMerchantsTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.merchants ( + id INT AUTO_INCREMENT PRIMARY KEY, + user_id INT NOT NULL, + merchant_type ENUM('flower_shop', 'activity_organizer', 'farm_owner') NOT NULL, + business_name VARCHAR(100) NOT NULL, + business_license VARCHAR(255), + contact_person VARCHAR(50) NOT NULL, + contact_phone VARCHAR(20) NOT NULL, + address VARCHAR(255), + description TEXT, + status ENUM('pending', 'approved', 'rejected', 'suspended') NOT NULL DEFAULT 'pending', + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (user_id) REFERENCES users(id), + INDEX idx_user_id (user_id), + INDEX idx_status (status) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; +`; + +// 创建旅行计划表的SQL语句 +const createTravelPlansTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.travel_plans ( + id极INT AUTO_INCREMENT PRIMARY KEY, + user_id INT NOT NULL, + destination VARCHAR(100) NOT NULL, + start_date DATE NOT NULL, + end_date DATE NOT NULL, + budget DECIMAL(10,2) NOT NULL, + interests TEXT, + visibility ENUM('public', 'friends', 'private') NOT NULL DEFAULT 'public', + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (user_id) REFERENCES users(id), + INDEX idx_user_id (user_id), + INDEX idx_destination (destination), + INDEX idx_dates (start_date, end_date) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; +`; + +function executeSQL(connection, sql, description) { + return new Promise((resolve, reject) => { + console.log(`🛠️ ${description}...`); + connection.query(sql, (err, results) => { + if (err) { + console.error(`❌ ${description}失败:`, err.message); + reject(err); + } else { + console.log(`✅ ${description}成功`); + resolve(results); + } + }); + }); +} + +async function initializeDatabase(config) { + console.log(`\n🚀 开始初始化 ${config.name} 数据库...`); + console.log('='.repeat(60)); + + const connection = mysql.createConnection({ + host: config.host, + port: config.port, + user: config.user, + password: config.password, + multipleStatements: true + }); + + try { + // 连接数据库 + await new Promise((resolve, reject) => { + connection.connect((err) => { + if (err) reject(err); + else resolve(); + }); + }); + + // 创建数据库 + await executeSQL(connection, createDatabaseSQL, '创建数据库 jiebandata'); + + // 使用新创建的数据库 + await executeSQL(connection, 'USE jiebandata', '切换到 jiebandata 数据库'); + + // 创建用户表 + await executeSQL(connection, createUsersTableSQL, '创建用户表'); + + // 创建商家表 + await executeSQL(connection, createMerchantsTableSQL, '创建商家表'); + + // 创建旅行计划表 + await executeSQL(connection, createTravelPlansTableSQL, '创建旅行计划表'); + + console.log('✅ 数据库初始化完成！'); + + return { success: true, message: '数据库初始化成功' }; + + } catch (error) { + console.error('❌ 数据库初始化失败:', error.message); + return { success: false, error: error.message }; + } finally { + // 关闭极接 + connection.end(); + console.log('✅ 数据库连接已关闭'); + } +} + +async function main() { + console.log('🎯 结伴客系统数据库初始化工具'); + console.log('='.repeat(60)); + + const results = []; + + for (const config of configs) { + const result = await initializeDatabase(config); + results.push({ + environment: config.name, + success: result.success, + message: result.message || result.error + }); + console.log('\n' + '='.repeat(60)); + } + + // 输出汇总结果 + console.log('📋 初始化结果汇总:'); + results.forEach(result => { + console.log(`${result.environment}: ${result.success ? '✅ 成功' : '❌ 失败'} - ${result.message}`); + }); + + if (results.some(r => r.success)) { + console.log('\n🎉 数据库初始化完成！现在可以运行测试验证数据库结构。'); + } else { + console.log('\n⚠️ 所有环境初始化失败，请检查网络连接和数据库权限'); + } +} + +// 运行初始化 +main().catch(console.error); \ No newline at end of file diff --git a/init-database-fixed.js b/init-database-fixed.js new file mode 100644 index 0000000..11139b8 --- /dev/null +++ b/init-database-fixed.js @@ -0,0 +1,188 @@ +const mysql = require('mysql2'); + +// 数据库配置 +const configs = [ + { + name: '测试环境', + host: '192.168.0.240', + port: 3306, + user: '极', + password: 'aiot$Aiot123' + }, + { + name: '生产环境', + host: '129.211.213.226', + port: 9527, + user: 'root', + password: 'aiotAiot123!' + } +]; + +// 创建数据库的SQL语句 +const createDatabaseSQL = ` +CREATE DATABASE IF NOT EXISTS jiebandata +CHARACTER SET utf8mb4 +COLLATE utf8mb4_unicode_ci; +`; + +// 创建用户表的SQL语句 +const createUsersTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.users ( + id INT AUTO_INCREMENT PRIMARY KEY, + openid VARCHAR(64) UNIQUE NOT NULL, + nickname VARCHAR(50) NOT NULL, + avatar VARCHAR(255), + gender ENUM('male', 'female', 'other'), + birthday DATE, + phone VARCHAR(20) UNIQUE, + email VARCHAR(100) UNIQUE, + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + INDEX idx_openid (openid), + INDEX idx_phone (phone), + INDEX idx_email (email) +) ENGINE=InnoDB DEFAULT CHARSET=utf极4 COLLATE=utf8mb4_unicode_ci; +`; + +// 创建商家表的SQL语句 +const createMerchantsTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.merchants ( + id INT AUTO_INCREMENT PRIMARY KEY, + user_id INT NOT NULL, + merchant_type ENUM('flower_shop', 'activity_organizer', 'farm_owner') NOT NULL, + business_name VARCHAR(100) NOT NULL, + business_license VARCHAR(255), + contact_person VARCHAR极50) NOT NULL, + contact_phone VARCHAR(20) NOT NULL, + address VARCHAR(255), + description TEXT, + status ENUM('pending', 'approved', 'rejected', 'suspended') NOT NULL DEFAULT 'pending', + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (user_id) REFERENCES users(id), + INDEX idx_user_id (user_id), + INDEX idx_status (status) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; +`; + +// 创建旅行计划表的SQL语句 +const createTravelPlansTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.travel_plans ( + id INT AUTO_INCREMENT PRIMARY KEY, + user_id INT NOT NULL, + destination VARCHAR(100) NOT NULL, + start_date DATE NOT NULL, + end_date DATE NOT NULL, + budget DECIMAL(10,2) NOT NULL, + interests TEXT, + visibility ENUM('public', 'friends', 'private') NOT NULL DEFAULT 'public', + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (user_id) REFERENCES users(id), + INDEX idx_user_id (user_id), + INDEX idx_destination (destination), + INDEX idx_dates (start_date, end_date) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; +`; + +// 所有表创建语句 +const tableCreationSQLs = [ + createUsersTableSQL, + createMerchantsTableSQL, + createTravelPlansTableSQL +]; + +function executeSQL(connection, sql, description) { + return new Promise((resolve, reject) => { + console.log(`🛠️ ${description}...`); + connection.query(sql, (err, results) => { + if (err) { + console.error(`❌ ${description}失败:`, err.message); + reject(err); + } else { + console.log(`✅ ${description}成功`); + resolve(results); + } + }); + }); +} + +async function initializeDatabase(config) { + console.log(`\n🚀 开始初始化 ${config.name} 数据库...`); + console.log('='.repeat(60)); + + const connection = mysql.createConnection({ + host: config.host, + port: config.port, + user: config.user, + password: config.password, + multipleStatements: true + }); + + try { + // 连接数据库 + await new Promise((resolve, reject) => { + connection.connect((err) => { + if (err) reject(err); + else resolve(); + }); + }); + + // 创建数据库 + await executeSQL(connection, createDatabaseSQL, '创建数据库 jiebandata'); + + // 使用新创建的数据库 + await executeSQL(connection, 'USE jiebandata', '切换到 jiebandata 数据库'); + + // 创建所有表 + for (let i = 0; i < tableCreationSQLs.length; i++) { + await executeSQL(connection, tableCreationSQLs[i], `创建表 ${i + 1}/${tableCreationSQLs.length}`); + } + + console.log('✅ 数据库初始化完成！'); + + return { success: true, message: '数据库初始化成功' }; + + } catch (error) { + console.error('❌ 数据库初始化失败:', error.message); + return { success: false, error: error.message }; + } finally { + // 关闭连接 + connection.end(); + console.log('✅ 数据库连接已关闭'); + } +} + +async function main() { + console.log('🎯 结伴客系统数据库初始化工具'); + console.log('='.repeat(60)); + + const results = []; + + for (const config of configs) { + const result = await initializeDatabase(config); + results.push({ + environment: config.name, + success: result.success, + message: result.message || result.error + }); + console.log('\n' + '='.repeat(60)); + } + + // 输出汇总结果 + console.log('📋 初始化结果汇总:'); + results.forEach(result => { + console.log(`${result.environment}: ${result.success ? '✅ 成功' : '❌ 失败'} - ${result.message}`); + }); + + // 检查是否所有环境都成功 + const allSuccess = results.every(result => result.success); + if (allSuccess) { + console.log('\n🎉 所有环境数据库初始化成功！'); + } else { + console.log('\n⚠️ 部分环境初始化失败，请检查网络连接和数据库权限'); + } +} + +// 运行初始化 +main().catch(console.error); \ No newline at end of file diff --git a/init-database.js b/init-database.js new file mode 100644 index 0000000..5a74b8e --- /dev/null +++ b/init-database.js @@ -0,0 +1,208 @@ +const mysql = require('mysql2'); + +// 数据库配置 +const configs = [ + { + name: '测试环境', + host: '192.168.0.240', + port: 3306, + user: 'root', + password: 'aiot$Aiot123' + }, + { + name: '生产环境', + host: '129.211.213.226', + port: 9527, + user: 'root', + password: 'aiotAiot123!' + } +]; + +// 创建数据库的SQL语句 +const createDatabaseSQL = ` +CREATE DATABASE IF NOT EXISTS jiebandata +CHARACTER SET utf8mb4 +COLLATE utf8mb4_unicode_ci; +`; + +// 创建用户表的SQL语句 +const createUsersTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.users ( + id INT AUTO_INCREMENT PRIMARY KEY, + openid VARCHAR(64) UNIQUE NOT NULL, + nickname VARCHAR(50) NOT NULL, + avatar VARCHAR(255), + gender ENUM('male', 'female', 'other'), + birthday DATE, + phone VARCHAR(20) UNIQUE, + email VARCHAR(100) UNIQUE, + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + INDEX idx_openid (openid), + INDEX idx_phone (phone), + INDEX idx_email (email) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; +`; + +// 创建商家表的SQL语句 +const createMerchantsTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.merchants ( + id INT AUTO_INCREMENT PRIMARY KEY, + user_id INT NOT NULL, + merchant_type ENUM('flower_shop', 'activity_organizer', 'farm_owner') NOT NULL, + business_name VARCHAR(100) NOT NULL, + business_license VARCHAR(255), + contact_person VARCHAR(50) NOT NULL, + contact_phone VARCHAR(20) NOT NULL, + address VARCHAR(255), + description TEXT, + status ENUM('pending', 'approved', 'rejected', 'suspended') NOT NULL DEFAULT 'pending', + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (user_id) REFERENCES users(id), + INDEX idx_user_id (user_id), + INDEX idx_status (status) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; +`; + +// 创建旅行计划表的SQL语句 +const createTravelPlansTableSQL = ` +CREATE TABLE IF NOT EXISTS jiebandata.travel_plans ( + id INT AUTO_INCREMENT PRIMARY KEY, + user_id INT NOT NULL, + destination VARCHAR(100) NOT NULL, + start_date DATE NOT NULL, + end_date DATE NOT NULL, + budget DECIMAL(10,2) NOT NULL, + interests TEXT, + visibility ENUM('public', 'friends', 'private') NOT NULL DEFAULT 'public', + created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP, + updated_at DATETIME NOT NULL DEFAULT CURRENT极ESTAMP ON UPDATE CURRENT_TIMESTAMP, + FOREIGN KEY (user_id) REFERENCES users(id), + INDEX idx_user_id (user_id), + INDEX idx_destination (destination), + INDEX idx_dates (start_date, end_date) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci; +`; + +// 所有表创建语句 +const tableCreationSQLs = [ + createUsersTableSQL, + createMerchantsTableSQL, + createTravelPlansTableSQL +]; + +function executeSQL(connection, sql, description) { + return new Promise((resolve, reject) => { + console.log(`🛠️ ${description}...`); + connection.query(sql, (err, results) => { + if (err) { + console.error(`❌ ${description}失败:`, err.message); + reject(err); + } else { + console.log(`✅ ${description}成功`); + resolve(results); + } + }); + }); +} + +async function initializeDatabase(config) { + console.log(`\n🚀 开始初始化 ${config.name} 数据库...`); + console.log('='.repeat(60)); + + const connection = mysql.createConnection({ + host: config.host, + port: config.port, + user: config.user, + password: config.password, + multipleStatements: true // 允许执行多条SQL语句 + }); + + try { + // 连接数据库 + await new Promise((resolve, reject) => { + connection.connect((err) => { + if (err) reject(err); + else resolve(); + }); + }); + + // 创建数据库 + await executeSQL(connection, createDatabaseSQL, '创建数据库 jiebandata'); + + // 使用新创建的数据库 + await executeSQL(connection, 'USE jiebandata', '切换到 jiebandata 数据库'); + + // 创建所有表 + for (let i = 0; i < tableCreationSQLs.length; i++) { + await executeSQL(connection, tableCreationSQLs[i], `创建表 ${i + 1}/${tableCreationSQLs.length}`); + } + + // 插入示例数据 + console.log('📝 插入示例数据...'); + + // 插入示例用户 + await executeSQL(connection, ` + INSERT IGNORE INTO users (openid, nickname, avatar, gender, phone, email) VALUES + ('test_openid_1', '测试用户1', 'https://example.com/avatar1.jpg', 'male', '13800138001', 'user1@example.com'), + ('test_openid_2', '测试用户2', 'https://example.com/avatar2.jpg', 'female', '13800138002', 'user2@example.com') + `, '插入示例用户数据'); + + // 验证数据插入 + const [users] = await new Promise((resolve, reject) => { + connection.query('SELECT COUNT(*) as count FROM users', (err, results) => { + if (err) reject(err); + else resolve(results); + }); + }); + + console.log(`✅ 数据库初始化完成！用户表中有 ${users[0].count} 条记录`); + + return { success: true, message: '数据库初始化成功' }; + + } catch (error) { + console.error('❌ 数据库初始化失败:', error.message); + return { success: false, error: error.message }; + } finally { + // 关闭连接 + connection.end(); + console.log('✅ 数据库连接已关闭'); + } +} + +async function main() { + console.log('🎯 结伴客系统数据库初始化工具'); + console.log('='.repeat(60)); + + const results = []; + + for (const config of configs) { + const result = await initializeDatabase(config); + results.push({ + environment: config.name, + success: result.success, + message: result.message || result.error + }); + console.log('\n' + '='.repeat(60)); + } + + // 输出汇总结果 + console.log('📋 初始化结果汇总:'); + results.forEach(result => { + console.log(`${result.environment}: ${result.success ? '✅ 成功' : '❌ 失败'} - ${result.message}`); + }); + + // 检查是否所有环境都成功 + const allSuccess = results.every(result => result.success); + if (allSuccess) { + console.log('\n🎉 所有环境数据库初始化成功！'); + } else { + console.log('\n⚠️ 部分环境初始化失败，请检查网络连接和数据库权限'); + } +} + +// 运行初始化 +main().catch(console.error); + +module.exports = { initializeDatabase }; \ No newline at end of file diff --git a/mini-program/App.vue b/mini-program/App.vue new file mode 100644 index 0000000..8c2b732 --- /dev/null +++ b/mini-program/App.vue @@ -0,0 +1,17 @@ + + + diff --git a/mini-program/api/config.js b/mini-program/api/config.js new file mode 100644 index 0000000..df6caaf --- /dev/null +++ b/mini-program/api/config.js @@ -0,0 +1,87 @@ +// API基础配置 +const config = { + // 开发环境 + development: { + baseURL: 'http://localhost:3000/api', + timeout: 10000 + }, + // 生产环境 + production: { + baseURL: 'https://api.jiebanke.com/api', + timeout: 15000 + } +} + +// 获取当前环境配置 +const getConfig = () => { + const env = process.env.NODE_ENV || 'development' + return config[env] +} + +// API端点 +const endpoints = { + // 用户相关 + USER: { + LOGIN: '/auth/login', + REGISTER: '/auth/register', + PROFILE: '/user/profile', + UPDATE_PROFILE: '/user/profile', + UPLOAD_AVATAR: '/user/avatar' + }, + + // 旅行计划 + TRAVEL: { + LIST: '/travel/list', + DETAIL: '/travel/detail', + CREATE: '/travel/create', + JOIN: '/travel/join', + MY_PLANS: '/travel/my-plans', + SEARCH: '/travel/search' + }, + + // 动物认养 + ANIMAL: { + LIST: '/animal/list', + DETAIL: '/animal/detail', + ADOPT: '/animal/adopt', + MY_ANIMALS: '/animal/my-animals', + CATEGORIES: '/animal/categories' + }, + + // 送花服务 + FLOWER: { + LIST: '/flower/list', + DETAIL: '/flower/detail', + ORDER: '/flower/order', + MY_ORDERS: '/flower/my-orders', + CATEGORIES: '/flower/categories' + }, + + // 订单管理 + ORDER: { + LIST: '/order/list', + DETAIL: '/order/detail', + CANCEL: '/order/cancel', + PAY: '/order/pay', + CONFIRM: '/order/confirm' + }, + + // 支付相关 + PAYMENT: { + CREATE: '/payment/create', + QUERY: '/payment/query', + REFUND: '/payment/refund' + }, + + // 系统相关 + SYSTEM: { + CONFIG: '/system/config', + NOTICE: '/system/notice', + FEEDBACK: '/system/feedback' + } +} + +export default { + ...getConfig(), + endpoints +} \ No newline at end of file diff --git a/mini-program/api/example.js b/mini-program/api/example.js new file mode 100644 index 0000000..87e6127 --- /dev/null +++ b/mini-program/api/example.js @@ -0,0 +1,169 @@ +// API 使用示例 +import api, { userService, travelService, homeService, apiUtils } from './index.js' + +// 示例1: 用户登录 +async function exampleLogin() { + try { + const result = await userService.login({ + username: 'user123', + password: 'password123' + }) + + console.log('登录成功:', result) + // 保存token + api.setAuthToken(result.token) + + } catch (error) { + console.error('登录失败:', error) + api.handleError(error) + } +} + +// 示例2: 获取首页数据 +async function exampleGetHomeData() { + try { + const homeData = await homeService.getHomeData() + console.log('首页数据:', homeData) + + // 或者使用错误处理包装器 + const { success, data, error } = await api.withErrorHandling( + homeService.getHomeData(), + '首页数据加载成功' + ) + + if (success) { + // 处理数据 + console.log('处理首页数据:', data) + } + + } catch (error) { + api.handleError(error, '首页数据加载失败') + } +} + +// 示例3: 分页获取旅行计划 +async function exampleGetTravelPlans() { + try { + const pagination = apiUtils.generatePagination(1, 10) + const travels = await travelService.getList({ + ...pagination, + keyword: '西藏' + }) + + console.log('旅行计划列表:', travels) + + } catch (error) { + api.handleError(error) + } +} + +// 示例4: 文件上传 +async function exampleUploadAvatar() { + try { + // 选择图片 + const res = await uni.chooseImage({ + count: 1, + sizeType: ['compressed'], + sourceType: ['album'] + }) + + const filePath = res.tempFilePaths[0] + const uploadResult = await userService.uploadAvatar(filePath) + + console.log('头像上传成功:', uploadResult) + + } catch (error) { + api.handleError(error, '头像上传失败') + } +} + +// 示例5: 完整的页面数据加载流程 +async function loadPageData() { + try { + // 并行加载多个数据 + const [banners, travels, animals, flowers] = await Promise.all([ + homeService.getBanners(), + homeService.getRecommendedTravels(), + homeService.getHotAnimals(), + homeService.getFeaturedFlowers() + ]) + + return { + banners: banners || [], + travelPlans: travels || [], + animals: animals || [], + flowers: flowers || [] + } + + } catch (error) { + api.handleError(error) + // 返回默认数据或空数据 + return { + banners: [], + travelPlans: [], + animals: [], + flowers: [] + } + } +} + +// 示例6: 订单支付流程 +async function examplePaymentFlow(orderId) { + try { + // 1. 创建支付 + const payment = await paymentService.create({ + orderId, + amount: 100, + paymentMethod: 'wechat' + }) + + // 2. 调用微信支付 + const payResult = await uni.requestPayment({ + timeStamp: payment.timeStamp, + nonceStr: payment.nonceStr, + package: payment.package, + signType: payment.signType, + paySign: payment.paySign + }) + + // 3. 确认支付结果 + if (payResult.errMsg === 'requestPayment:ok') { + // 支付成功，更新订单状态 + await orderService.pay(orderId) + console.log('支付成功') + } + + } catch (error) { + api.handleError(error, '支付失败') + } +} + +// 导出示例函数 +export default { + exampleLogin, + exampleGetHomeData, + exampleGetTravelPlans, + exampleUploadAvatar, + loadPageData, + examplePaymentFlow +} + +// 在页面中使用示例 +/* +// 在Vue组件的methods中 +methods: { + async loadData() { + const pageData = await loadPageData() + this.banners = pageData.banners + this.travelPlans = pageData.travelPlans + this.animals = pageData.animals + this.flowers = pageData.flowers + }, + + async handleLogin() { + await exampleLogin() + // 登录成功后重新加载数据 + await this.loadData() + } +} +*/ \ No newline at end of file diff --git a/mini-program/api/index.js b/mini-program/api/index.js new file mode 100644 index 0000000..1056aa2 --- /dev/null +++ b/mini-program/api/index.js @@ -0,0 +1,99 @@ +// API模块主入口 +import request from './request.js' +import * as services from './services.js' + +// 导出所有服务 +export * from './services.js' + +// 导出请求实例 +export { request } + +// 默认导出 +export default { + // 请求实例 + request, + + // 所有服务 + ...services, + + // 工具函数 + utils: services.apiUtils, + + // 初始化配置 + init(config = {}) { + // 可以在这里进行一些初始化配置 + console.log('API模块初始化完成', config) + }, + + // 设置认证token + setAuthToken(token) { + uni.setStorageSync('token', token) + }, + + // 获取认证token + getAuthToken() { + return uni.getStorageSync('token') + }, + + // 清除认证信息 + clearAuth() { + uni.removeStorageSync('token') + uni.removeStorageSync('refreshToken') + }, + + // 检查是否已登录 + isLoggedIn() { + return !!this.getAuthToken() + }, + + // 统一错误处理 + handleError(error, defaultMessage = '操作失败') { + const errorMessage = error.message || defaultMessage + const errorCode = error.code || 'UNKNOWN_ERROR' + + // 可以根据错误码进行不同的处理 + switch (errorCode) { + case 'UNAUTHORIZED': + this.clearAuth() + uni.navigateTo({ url: '/pages/auth/login' }) + break + case 'NETWORK_ERROR': + uni.showToast({ title: '网络连接失败', icon: 'none' }) + break + default: + uni.showToast({ title: errorMessage, icon: 'none' }) + } + + return { error: true, code: errorCode, message: errorMessage } + }, + + // 请求包装器，自动处理错误 + async withErrorHandling(promise, successMessage = '操作成功') { + try { + const result = await promise + if (successMessage) { + uni.showToast({ title: successMessage, icon: 'success' }) + } + return { success: true, data: result } + } catch (error) { + return this.handleError(error) + } + } +} + +// 自动初始化 +const api = { + request, + ...services +} + +// 全局错误处理 +const originalRequest = uni.request +uni.request = function(config) { + return originalRequest.call(this, config).catch(error => { + console.error('请求失败:', error) + throw error + }) +} + +export default api \ No newline at end of file diff --git a/mini-program/api/mock.js b/mini-program/api/mock.js new file mode 100644 index 0000000..01b8037 --- /dev/null +++ b/mini-program/api/mock.js @@ -0,0 +1,312 @@ +// Mock数据 - 用于开发和测试 +import { OrderStatus, TravelStatus } from './types.js' + +// Mock用户数据 +export const mockUsers = [ + { + id: 1, + username: 'user1', + nickname: '旅行爱好者', + avatar: '/static/user/avatar1.jpg', + phone: '138****1234', + points: 150, + level: 2, + createTime: '2024-01-15' + }, + { + id: 2, + username: 'user2', + nickname: '动物保护者', + avatar: '/static/user/avatar2.jpg', + email: 'user2@example.com', + points: 300, + level: 3, + createTime: '2024-02-20' + } +] + +// Mock轮播图数据 +export const mockBanners = [ + { + id: 1, + image: '/static/banners/banner1.jpg', + title: '西藏之旅', + link: '/pages/travel/list', + type: 'travel' + }, + { + id: 2, + image: '/static/banners/banner2.jpg', + title: '动物认养', + link: '/pages/animal/list', + type: 'animal' + }, + { + id: 3, + image: '/static/banners/banner3.jpg', + title: '鲜花配送', + link: '/pages/flower/list', + type: 'flower' + } +] + +// Mock旅行计划数据 +export const mockTravelPlans = [ + { + id: 1, + title: '西藏拉萨深度游', + destination: '西藏拉萨', + coverImage: '/static/travel/tibet.jpg', + startDate: '2024-10-01', + endDate: '2024-10-07', + budget: 5000, + currentMembers: 3, + maxMembers: 6, + description: '探索西藏神秘文化，感受高原风情', + status: TravelStatus.RECRUITING, + creator: mockUsers[0], + createTime: '2024-08-20' + }, + { + id: 2, + title: '云南大理休闲游', + destination: '云南大理', + coverImage: '/static/travel/yunnan.jpg', + startDate: '2024-10-05', + endDate: '2024-10-12', + budget: 3500, + currentMembers: 2, + maxMembers: 4, + description: '漫步古城，享受洱海风光', + status: TravelStatus.RECRUITING, + creator: mockUsers[1], + createTime: '2024-08-22' + } +] + +// Mock动物数据 +export const mockAnimals = [ + { + id: 1, + name: '小羊驼', + species: '羊驼', + price: 1000, + image: '/static/animals/alpaca.jpg', + description: '温顺可爱的羊驼，适合家庭认养', + location: '西藏牧场', + isHot: true, + status: 'available', + createTime: '2024-08-15' + }, + { + id: 2, + name: '小绵羊', + species: '绵羊', + price: 800, + image: '/static/animals/sheep.jpg', + description: '毛茸茸的小绵羊，非常温顺', + location: '内蒙古草原', + isHot: false, + status: 'available', + createTime: '2024-08-18' + } +] + +// Mock花束数据 +export const mockFlowers = [ + { + id: 1, + name: '浪漫玫瑰', + description: '11朵红玫瑰，象征热烈的爱情', + price: 199, + image: '/static/flowers/rose.jpg', + category: '爱情', + stock: 50, + createTime: '2024-08-10' + }, + { + id: 2, + name: '向日葵花束', + description: '9朵向日葵，象征阳光和希望', + price: 179, + image: '/static/flowers/sunflower.jpg', + category: '祝福', + stock: 30, + createTime: '2024-08-12' + } +] + +// Mock订单数据 +export const mockOrders = [ + { + id: 'ORD202408270001', + orderNo: '202408270001', + type: 'travel', + title: '西藏拉萨深度游', + image: '/static/travel/tibet.jpg', + price: 5000, + count: 1, + totalAmount: 5000, + status: OrderStatus.UNPAID, + createTime: '2024-08-27 10:00:00' + }, + { + id: 'ORD202408270002', + orderNo: '202408270002', + type: 'animal', + title: '小羊驼认养', + image: '/static/animals/alpaca.jpg', + price: 1000, + count: 1, + totalAmount: 1000, + status: OrderStatus.PAID, + createTime: '2024-08-27 11:30:00', + payTime: '2024-08-27 11:35:00' + } +] + +// Mock系统公告 +export const mockNotices = [ + { + id: 1, + title: '系统维护通知', + content: '系统将于今晚进行维护，预计耗时2小时', + type: 'system', + isActive: true, + createTime: '2024-08-26' + }, + { + id: 2, + title: '新功能上线', + content: '送花服务正式上线，欢迎体验', + type: 'feature', + isActive: true, + createTime: '2024-08-27' + } +] + +// Mock API响应 +export const mockResponses = { + // 成功响应 + success: (data, message = '操作成功') => ({ + code: 0, + message, + data, + timestamp: Date.now() + }), + + // 错误响应 + error: (code, message) => ({ + code, + message, + timestamp: Date.now() + }), + + // 分页响应 + pagination: (list, total, page = 1, pageSize = 10) => ({ + code: 0, + message: '操作成功', + data: { + list, + total, + page, + pageSize, + totalPages: Math.ceil(total / pageSize) + }, + timestamp: Date.now() + }) +} + +// Mock服务函数 +export const mockService = { + // 模拟延迟 + delay: (ms = 500) => new Promise(resolve => setTimeout(resolve, ms)), + + // 模拟登录 + mockLogin: async (username, password) => { + await mockService.delay(1000) + + if (username === 'admin' && password === '123456') { + return mockResponses.success({ + token: 'mock-token-123456', + refreshToken: 'mock-refresh-token-123456', + userInfo: mockUsers[0] + }) + } + + return mockResponses.error(1001, '用户名或密码错误') + }, + + // 模拟获取首页数据 + mockHomeData: async () => { + await mockService.delay(800) + return mockResponses.success({ + banners: mockBanners, + travelPlans: mockTravelPlans, + animals: mockAnimals, + flowers: mockFlowers, + notices: mockNotices + }) + }, + + // 模拟获取列表数据 + mockList: async (type, page = 1, pageSize = 10) => { + await mockService.delay(600) + + const allData = { + travel: mockTravelPlans, + animal: mockAnimals, + flower: mockFlowers, + order: mockOrders + } + + const data = allData[type] || [] + const start = (page - 1) * pageSize + const end = start + pageSize + const paginatedData = data.slice(start, end) + + return mockResponses.pagination(paginatedData, data.length, page, pageSize) + }, + + // 模拟获取详情 + mockDetail: async (type, id) => { + await mockService.delay(500) + + const allData = { + travel: mockTravelPlans, + animal: mockAnimals, + flower: mockFlowers, + order: mockOrders + } + + const data = allData[type] || [] + const item = data.find(item => item.id === id || item.id === parseInt(id)) + + if (item) { + return mockResponses.success(item) + } + + return mockResponses.error(404, '数据不存在') + } +} + +// 导出所有Mock数据 +export default { + mockUsers, + mockBanners, + mockTravelPlans, + mockAnimals, + mockFlowers, + mockOrders, + mockNotices, + mockResponses, + mockService +} + +// 使用示例 +/* +// 在开发环境中使用Mock数据 +if (process.env.NODE_ENV === 'development') { + // 可以在这里替换真实的API调用 +} +*/ \ No newline at end of file diff --git a/mini-program/api/request.js b/mini-program/api/request.js new file mode 100644 index 0000000..97a3042 --- /dev/null +++ b/mini-program/api/request.js @@ -0,0 +1,230 @@ +import config from './config.js' + +// 请求队列（用于处理token刷新） +const requestQueue = [] +let isRefreshing = false + +class Request { + constructor() { + this.baseURL = config.baseURL + this.timeout = config.timeout + this.interceptors = { + request: [], + response: [] + } + } + + // 添加请求拦截器 + addRequestInterceptor(interceptor) { + this.interceptors.request.push(interceptor) + } + + // 添加响应拦截器 + addResponseInterceptor(interceptor) { + this.interceptors.response.push(interceptor) + } + + // 执行请求拦截器 + async runRequestInterceptors(config) { + for (const interceptor of this.interceptors.request) { + config = await interceptor(config) + } + return config + } + + // 执行响应拦截器 + async runResponseInterceptors(response) { + for (const interceptor of this.interceptors.response) { + response = await interceptor(response) + } + return response + } + + // 核心请求方法 + async request(options) { + try { + // 合并配置 + const requestConfig = { + url: options.url.startsWith('http') ? options.url : `${this.baseURL}${options.url}`, + method: options.method || 'GET', + header: { + 'Content-Type': 'application/json', + ...options.header + }, + data: options.data, + timeout: this.timeout + } + + // 执行请求拦截器 + const finalConfig = await this.runRequestInterceptors(requestConfig) + + // 发起请求 + const response = await uni.request(finalConfig) + + // 执行响应拦截器 + const finalResponse = await this.runResponseInterceptors(response) + + return finalResponse[1] // uni.request返回的是数组[error, success] + } catch (error) { + console.error('Request error:', error) + throw error + } + } + + // GET请求 + get(url, data = {}, options = {}) { + return this.request({ + url, + method: 'GET', + data, + ...options + }) + } + + // POST请求 + post(url, data = {}, options = {}) { + return this.request({ + url, + method: 'POST', + data, + ...options + }) + } + + // PUT请求 + put(url, data = {}, options = {}) { + return this.request({ + url, + method: 'PUT', + data, + ...options + }) + } + + // DELETE请求 + delete(url, data = {}, options = {}) { + return this.request({ + url, + method: 'DELETE', + data, + ...options + }) + } + + // 上传文件 + upload(url, filePath, formData = {}, options = {}) { + return new Promise((resolve, reject) => { + uni.uploadFile({ + url: `${this.baseURL}${url}`, + filePath, + name: 'file', + formData, + success: resolve, + fail: reject, + ...options + }) + }) + } + + // 下载文件 + download(url, options = {}) { + return new Promise((resolve, reject) => { + uni.downloadFile({ + url: `${this.baseURL}${url}`, + success: resolve, + fail: reject, + ...options + }) + }) + } +} + +// 创建请求实例 +const request = new Request() + +// 添加请求拦截器 - Token处理 +request.addRequestInterceptor(async (config) => { + const token = uni.getStorageSync('token') + if (token) { + config.header.Authorization = `Bearer ${token}` + } + return config +}) + +// 添加响应拦截器 - 错误处理 +request.addResponseInterceptor(async (response) => { + const { statusCode, data } = response + + if (statusCode === 200) { + if (data.code === 0) { + return data.data + } else { + // 业务错误 + const error = new Error(data.message || '业务错误') + error.code = data.code + throw error + } + } else if (statusCode === 401) { + // Token过期，尝试刷新 + return handleTokenExpired(response) + } else { + // 网络错误 + throw new Error(`网络错误: ${statusCode}`) + } +}) + +// Token过期处理 +async function handleTokenExpired(response) { + if (isRefreshing) { + // 如果正在刷新，将请求加入队列 + return new Promise((resolve) => { + requestQueue.push(() => resolve(request.request(response.config))) + }) + } + + isRefreshing = true + const refreshToken = uni.getStorageSync('refreshToken') + + if (!refreshToken) { + // 没有refreshToken，跳转到登录页 + uni.navigateTo({ url: '/pages/auth/login' }) + throw new Error('请重新登录') + } + + try { + // 尝试刷新Token + const result = await request.post(config.endpoints.USER.REFRESH_TOKEN, { + refreshToken + }) + + // 保存新Token + uni.setStorageSync('token', result.token) + uni.setStorageSync('refreshToken', result.refreshToken) + + // 重试原始请求 + const retryResponse = await request.request(response.config) + + // 处理队列中的请求 + processRequestQueue() + + return retryResponse + } catch (error) { + // 刷新失败，清空Token并跳转登录 + uni.removeStorageSync('token') + uni.removeStorageSync('refreshToken') + uni.navigateTo({ url: '/pages/auth/login' }) + throw error + } finally { + isRefreshing = false + } +} + +// 处理请求队列 +function processRequestQueue() { + while (requestQueue.length > 0) { + const retry = requestQueue.shift() + retry() + } +} + +export default request \ No newline at end of file diff --git a/mini-program/api/services.js b/mini-program/api/services.js new file mode 100644 index 0000000..1da5db5 --- /dev/null +++ b/mini-program/api/services.js @@ -0,0 +1,189 @@ +import request from './request.js' +import config from './config.js' + +const { endpoints } = config + +// 用户服务 +export const userService = { + // 登录 + login: (data) => request.post(endpoints.USER.LOGIN, data), + + // 注册 + register: (data) => request.post(endpoints.USER.REGISTER, data), + + // 获取用户信息 + getProfile: () => request.get(endpoints.USER.PROFILE), + + // 更新用户信息 + updateProfile: (data) => request.put(endpoints.USER.UPDATE_PROFILE, data), + + // 上传头像 + uploadAvatar: (filePath) => request.upload(endpoints.USER.UPLOAD_AVATAR, filePath), + + // 退出登录 + logout: () => { + uni.removeStorageSync('token') + uni.removeStorageSync('refreshToken') + return Promise.resolve() + } +} + +// 旅行计划服务 +export const travelService = { + // 获取旅行计划列表 + getList: (params = {}) => request.get(endpoints.TRAVEL.LIST, params), + + // 获取旅行计划详情 + getDetail: (id) => request.get(`${endpoints.TRAVEL.DETAIL}/${id}`), + + // 创建旅行计划 + create: (data) => request.post(endpoints.TRAVEL.CREATE, data), + + // 加入旅行计划 + join: (travelId) => request.post(`${endpoints.TRAVEL.JOIN}/${travelId}`), + + // 获取我的旅行计划 + getMyPlans: (params = {}) => request.get(endpoints.TRAVEL.MY_PLANS, params), + + // 搜索旅行计划 + search: (keyword, params = {}) => request.get(endpoints.TRAVEL.SEARCH, { keyword, ...params }) +} + +// 动物认养服务 +export const animalService = { + // 获取动物列表 + getList: (params = {}) => request.get(endpoints.ANIMAL.LIST, params), + + // 获取动物详情 + getDetail: (id) => request.get(`${endpoints.ANIMAL.DETAIL}/${id}`), + + // 认养动物 + adopt: (animalId, data) => request.post(`${endpoints.ANIMAL.ADOPT}/${animalId}`, data), + + // 获取我的动物 + getMyAnimals: (params = {}) => request.get(endpoints.ANIMAL.MY_ANIMALS, params), + + // 获取动物分类 + getCategories: () => request.get(endpoints.ANIMAL.CATEGORIES) +} + +// 送花服务 +export const flowerService = { + // 获取花束列表 + getList: (params = {}) => request.get(endpoints.FLOWER.LIST, params), + + // 获取花束详情 + getDetail: (id) => request.get(`${endpoints.FLOWER.DETAIL}/${id}`), + + // 下单 + order: (data) => request.post(endpoints.FLOWER.ORDER, data), + + // 获取我的订单 + getMyOrders: (params = {}) => request.get(endpoints.FLOWER.MY_ORDERS, params), + + // 获取花束分类 + getCategories: () => request.get(endpoints.FLOWER.CATEGORIES) +} + +// 订单服务 +export const orderService = { + // 获取订单列表 + getList: (params = {}) => request.get(endpoints.ORDER.LIST, params), + + // 获取订单详情 + getDetail: (id) => request.get(`${endpoints.ORDER.DETAIL}/${id}`), + + // 取消订单 + cancel: (id) => request.post(`${endpoints.ORDER.CANCEL}/${id}`), + + // 支付订单 + pay: (id) => request.post(`${endpoints.ORDER.PAY}/${id}`), + + // 确认收货 + confirm: (id) => request.post(`${endpoints.ORDER.CONFIRM}/${id}`) +} + +// 支付服务 +export const paymentService = { + // 创建支付 + create: (data) => request.post(endpoints.PAYMENT.CREATE, data), + + // 查询支付状态 + query: (paymentId) => request.get(`${endpoints.PAYMENT.QUERY}/${paymentId}`), + + // 退款 + refund: (paymentId, data) => request.post(`${endpoints.PAYMENT.REFUND}/${paymentId}`, data) +} + +// 系统服务 +export const systemService = { + // 获取系统配置 + getConfig: () => request.get(endpoints.SYSTEM.CONFIG), + + // 获取公告列表 + getNotices: (params = {}) => request.get(endpoints.SYSTEM.NOTICE, params), + + // 提交反馈 + submitFeedback: (data) => request.post(endpoints.SYSTEM.FEEDBACK, data) +} + +// 首页数据服务 +export const homeService = { + // 获取首页数据 + getHomeData: () => request.get('/home/data'), + + // 获取轮播图 + getBanners: () => request.get('/home/banners'), + + // 获取推荐旅行计划 + getRecommendedTravels: () => request.get('/home/recommended-travels'), + + // 获取热门动物 + getHotAnimals: () => request.get('/home/hot-animals'), + + // 获取精选花束 + getFeaturedFlowers: () => request.get('/home/featured-flowers') +} + +// 工具函数 +export const apiUtils = { + // 生成分页参数 + generatePagination: (page = 1, pageSize = 10) => ({ + page, + pageSize, + skip: (page - 1) * pageSize + }), + + // 处理上传进度 + handleUploadProgress: (progressEvent) => { + const percent = Math.round((progressEvent.loaded * 100) / progressEvent.total) + return percent + }, + + // 处理下载进度 + handleDownloadProgress: (progressEvent) => { + const percent = Math.round((progressEvent.loaded * 100) / progressEvent.total) + return percent + }, + + // 格式化错误信息 + formatError: (error) => { + if (error.code) { + return error.message + } + return '网络连接失败，请检查网络设置' + } +} + +// 默认导出所有服务 +export default { + userService, + travelService, + animalService, + flowerService, + orderService, + paymentService, + systemService, + homeService, + apiUtils +} \ No newline at end of file diff --git a/mini-program/api/types.js b/mini-program/api/types.js new file mode 100644 index 0000000..cc71d6c --- /dev/null +++ b/mini-program/api/types.js @@ -0,0 +1,242 @@ +// API 类型定义 +/** + * 基础响应类型 + * @template T + * @typedef {Object} BaseResponse + * @property {number} code - 响应码 (0表示成功) + * @property {string} message - 响应消息 + * @property {T} [data] - 响应数据 + * @property {number} [timestamp] - 时间戳 + */ + +/** + * 分页参数 + * @typedef {Object} PaginationParams + * @property {number} [page] - 页码 + * @property {number} [pageSize] - 每页数量 + * @property {string} [keyword] - 搜索关键词 + */ + +/** + * 分页响应 + * @template T + * @typedef {Object} PaginationResponse + * @property {T[]} list - 数据列表 + * @property {number} total - 总数量 + * @property {number} page - 当前页码 + * @property {number} pageSize - 每页数量 + * @property {number} totalPages - 总页数 + */ + +/** + * 用户信息 + * @typedef {Object} UserInfo + * @property {number} id - 用户ID + * @property {string} username - 用户名 + * @property {string} nickname - 昵称 + * @property {string} avatar - 头像URL + * @property {string} [phone] - 手机号 + * @property {string} [email] - 邮箱 + * @property {number} points - 积分 + * @property {number} level - 会员等级 + * @property {string} createTime - 创建时间 + */ + +/** + * 登录请求参数 + * @typedef {Object} LoginParams + * @property {string} username - 用户名 + * @property {string} password - 密码 + */ + +/** + * 登录响应 + * @typedef {Object} LoginResponse + * @property {string} token - 访问令牌 + * @property {string} refreshToken - 刷新令牌 + * @property {UserInfo} userInfo - 用户信息 + */ + +/** + * 旅行计划 + * @typedef {Object} TravelPlan + * @property {number} id - 计划ID + * @property {string} title - 标题 + * @property {string} destination - 目的地 + * @property {string} coverImage - 封面图 + * @property {string} startDate - 开始日期 + * @property {string} endDate - 结束日期 + * @property {number} budget - 预算 + * @property {number} currentMembers - 当前成员数 + * @property {number} maxMembers - 最大成员数 + * @property {string} description - 描述 + * @property {string} status - 状态 + * @property {UserInfo} creator - 创建者 + * @property {string} createTime - 创建时间 + */ + +/** + * 动物信息 + * @typedef {Object} AnimalInfo + * @property {number} id - 动物ID + * @property {string} name - 名称 + * @property {string} species - 种类 + * @property {number} price - 价格 + * @property {string} image - 图片 + * @property {string} description - 描述 + * @property {string} location - 位置 + * @property {boolean} isHot - 是否热门 + * @property {string} status - 状态 + * @property {string} createTime - 创建时间 + */ + +/** + * 花束信息 + * @typedef {Object} FlowerInfo + * @property {number} id - 花束ID + * @property {string} name - 名称 + * @property {string} description - 描述 + * @property {number} price - 价格 + * @property {string} image - 图片 + * @property {string} category - 分类 + * @property {number} stock - 库存 + * @property {string} createTime - 创建时间 + */ + +/** + * 订单信息 + * @typedef {Object} OrderInfo + * @property {string} id - 订单ID + * @property {string} orderNo - 订单编号 + * @property {string} type - 订单类型 (travel/animal/flower) + * @property {string} title - 订单标题 + * @property {string} image - 图片 + * @property {number} price - 单价 + * @property {number} count - 数量 + * @property {number} totalAmount - 总金额 + * @property {string} status - 订单状态 + * @property {string} createTime - 创建时间 + * @property {string} [payTime] - 支付时间 + * @property {string} [completeTime] - 完成时间 + */ + +/** + * 支付信息 + * @typedef {Object} PaymentInfo + * @property {string} paymentId - 支付ID + * @property {number} amount - 支付金额 + * @property {string} status - 支付状态 + * @property {string} createTime - 创建时间 + * @property {string} [payTime] - 支付时间 + */ + +/** + * 系统公告 + * @typedef {Object} SystemNotice + * @property {number} id - 公告ID + * @property {string} title - 标题 + * @property {string} content - 内容 + * @property {string} type - 类型 + * @property {boolean} isActive - 是否激活 + * @property {string} createTime - 创建时间 + */ + +/** + * 错误码定义 + * @enum {number} + */ +export const ErrorCode = { + SUCCESS: 0, + UNAUTHORIZED: 401, + FORBIDDEN: 403, + NOT_FOUND: 404, + INTERNAL_ERROR: 500, + NETWORK_ERROR: 1001, + PARAM_ERROR: 1002, + BUSINESS_ERROR: 1003 +} + +/** + * 订单状态 + * @enum {string} + */ +export const OrderStatus = { + UNPAID: 'unpaid', // 待付款 + PAID: 'paid', // 已付款 + DELIVERED: 'delivered', // 已发货 + COMPLETED: 'completed', // 已完成 + CANCELLED: 'cancelled' // 已取消 +} + +/** + * 支付状态 + * @enum {string} + */ +export const PaymentStatus = { + PENDING: 'pending', // 待支付 + SUCCESS: 'success', // 支付成功 + FAILED: 'failed', // 支付失败 + REFUNDED: 'refunded' // 已退款 +} + +/** + * 旅行计划状态 + * @enum {string} + */ +export const TravelStatus = { + RECRUITING: 'recruiting', // 招募中 + FULL: 'full', // 已满员 + ONGOING: 'ongoing', // 进行中 + COMPLETED: 'completed', // 已完成 + CANCELLED: 'cancelled' // 已取消 +} + +// 导出所有类型 +export default { + BaseResponse, + PaginationParams, + PaginationResponse, + UserInfo, + LoginParams, + LoginResponse, + TravelPlan, + AnimalInfo, + FlowerInfo, + OrderInfo, + PaymentInfo, + SystemNotice, + ErrorCode, + OrderStatus, + PaymentStatus, + TravelStatus +} + +// 类型检查工具 +export const TypeUtils = { + /** + * 检查是否为有效用户信息 + * @param {any} obj + * @returns {boolean} + */ + isUserInfo(obj) { + return obj && typeof obj.id === 'number' && typeof obj.username === 'string' + }, + + /** + * 检查是否为有效旅行计划 + * @param {any} obj + * @returns {boolean} + */ + isTravelPlan(obj) { + return obj && typeof obj.id === 'number' && typeof obj.destination === 'string' + }, + + /** + * 检查是否为有效订单信息 + * @param {any} obj + * @returns {boolean} + */ + isOrderInfo(obj) { + return obj && typeof obj.id === 'string' && typeof obj.orderNo === 'string' + } +} \ No newline at end of file diff --git a/mini-program/index.html b/mini-program/index.html new file mode 100644 index 0000000..b5d330d --- /dev/null +++ b/mini-program/index.html @@ -0,0 +1,20 @@ + + + + + +