逻辑分析
- 会员注册与登录:用户需要能够通过小程序进行会员注册,提供必要信息如手机号码、密码等,注册成功后可登录系统。
- 会员信息管理:包括会员基本信息(姓名、联系方式等)的修改、查看,同时可能涉及会员等级、积分等信息的管理。
- 服务预约与关联:会员能够预约上门服务,并将服务预约与会员身份关联,方便后续查询服务记录和评价。
- 会员权益:不同等级的会员可能享有不同的权益,如折扣优惠、优先预约等。
- 数据存储与安全:将会员相关数据存储在数据库中,并确保数据的安全性和完整性。
程序框架结构化输出
小程序端
- 注册登录页面:
- 布局:包含手机号码输入框、密码输入框、注册 / 登录按钮,可能还有找回密码等辅助功能按钮。
- 交互逻辑:点击注册按钮,将用户输入信息发送到后端进行注册验证;点击登录按钮,验证用户登录信息。
- 会员信息页面:
- 布局:展示会员基本信息,如姓名、手机号码,以及会员等级、积分等信息,提供编辑按钮用于修改信息。
- 交互逻辑:点击编辑按钮进入信息编辑页面,保存修改后的数据发送到后端。
- 服务预约页面:
- 布局:展示可预约的上门服务列表,包括服务名称、价格、服务时间等信息,提供预约按钮。
- 交互逻辑:点击预约按钮,选择预约时间等信息后提交预约请求到后端。
后端
- 数据库设计:
- 会员表:存储会员基本信息,如会员 ID、手机号码、密码、姓名、会员等级、积分等。
- 服务表:记录上门服务相关信息,如服务 ID、服务名称、服务描述、价格等。
- 预约表:关联会员和服务,存储预约信息,如预约 ID、会员 ID、服务 ID、预约时间等。
- 接口设计:
- 注册接口:接收小程序端传来的注册信息,验证并存储到数据库。
- 登录接口:验证用户登录信息,返回登录结果和相关授权信息。
- 获取会员信息接口:根据会员 ID 从数据库查询会员信息并返回。
- 修改会员信息接口:接收修改后的会员信息,更新数据库。
- 服务预约接口:接收预约信息,存储到数据库并处理预约逻辑。
服务端逻辑
- 注册登录逻辑:处理注册和登录接口传来的数据,进行数据验证和用户身份验证。
- 会员信息管理逻辑:根据不同接口请求,查询、修改会员信息。
- 服务预约逻辑:处理服务预约请求,检查服务可用性,存储预约信息。
解决方案
小程序端代码示例(以微信小程序为例)
- 注册页面(pages/register/register.wxml)
<view class="container">
<view class="input-group">
<input type="number" placeholder="请输入手机号码" bindinput="handleInput" data-field="phone" />
</view>
<view class="input-group">
<input type="password" placeholder="请输入密码" bindinput="handleInput" data-field="password" />
</view>
<button bindtap="register">注册</button>
</view>
// pages/register/register.js
Page({
data: {
phone: '',
password: ''
},
handleInput(e) {
this.setData({
[e.target.dataset.field]: e.detail.value
});
},
register() {
const { phone, password } = this.data;
wx.request({
url: 'https://example.com/api/register',
method: 'POST',
data: {
phone,
password
},
success(res) {
if (res.data.success) {
wx.showToast({
title: '注册成功',
icon:'success'
});
wx.navigateTo({
url: '/pages/login/login'
});
} else {
wx.showToast({
title: '注册失败',
icon: 'none'
});
}
}
});
}
});
代码解释
这段微信小程序代码定义了一个注册页面。register.wxml
文件构建了页面的布局,包含两个输入框分别用于输入手机号码和密码,以及一个注册按钮。
在register.js
文件中,Page
函数定义了页面的逻辑。data
对象用于存储页面的状态,包括手机号码和密码。handleInput
方法在用户输入时更新相应的数据字段。register
方法在用户点击注册按钮时被调用,它收集用户输入的手机号码和密码,通过wx.request
发送一个 POST 请求到后端的/api/register
接口。如果请求成功且后端返回success
为true
,则显示注册成功的提示,并跳转到登录页面;否则显示注册失败的提示。
后端代码示例(以 Python + Flask 为例)
from flask import Flask, request, jsonify
import sqlite3
app = Flask(__name__)
def create_connection():
conn = sqlite3.connect('members.db')
return conn
def create_tables():
conn = create_connection()
cursor = conn.cursor()
cursor.execute('''
CREATE TABLE IF NOT EXISTS members (
id INTEGER PRIMARY KEY AUTOINCREMENT,
phone TEXT UNIQUE,
password TEXT,
name TEXT,
member_level INTEGER DEFAULT 1,
points INTEGER DEFAULT 0
)
''')
cursor.execute('''
CREATE TABLE IF NOT EXISTS services (
id INTEGER PRIMARY KEY AUTOINCREMENT,
service_name TEXT,
service_description TEXT,
price REAL
)
''')
cursor.execute('''
CREATE TABLE IF NOT EXISTS bookings (
id INTEGER PRIMARY KEY AUTOINCREMENT,
member_id INTEGER,
service_id INTEGER,
booking_time TEXT,
FOREIGN KEY (member_id) REFERENCES members(id),
FOREIGN KEY (service_id) REFERENCES services(id)
)
''')
conn.commit()
conn.close()
@app.route('/api/register', methods=['POST'])
def register():
data = request.get_json()
phone = data.get('phone')
password = data.get('password')
conn = create_connection()
cursor = conn.cursor()
try:
cursor.execute('INSERT INTO members (phone, password) VALUES (?,?)', (phone, password))
conn.commit()
conn.close()
return jsonify({'success': True})
except sqlite3.IntegrityError:
conn.close()
return jsonify({'success': False,'message': '手机号码已存在'})
@app.route('/api/login', methods=['POST'])
def login():
data = request.get_json()
phone = data.get('phone')
password = data.get('password')
conn = create_connection()
cursor = conn.cursor()
cursor.execute('SELECT id FROM members WHERE phone =? AND password =?', (phone, password))
result = cursor.fetchone()
conn.close()
if result:
return jsonify({'success': True, 'user_id': result[0]})
else:
return jsonify({'success': False,'message': '用户名或密码错误'})
@app.route('/api/member_info/<int:member_id>', methods=['GET'])
def get_member_info(member_id):
conn = create_connection()
cursor = conn.cursor()
cursor.execute('SELECT * FROM members WHERE id =?', (member_id,))
member = cursor.fetchone()
conn.close()
if member:
member_info = {
'id': member[0],
'phone': member[1],
'password': member[2],
'name': member[3],
'member_level': member[4],
'points': member[5]
}
return jsonify(member_info)
else:
return jsonify({'success': False,'message': '会员信息不存在'})
@app.route('/api/update_member_info/<int:member_id>', methods=['PUT'])
def update_member_info(member_id):
data = request.get_json()
name = data.get('name')
member_level = data.get('member_level')
points = data.get('points')
conn = create_connection()
cursor = conn.cursor()
update_query = 'UPDATE members SET '
update_values = []
if name:
update_query += 'name =?, '
update_values.append(name)
if member_level:
update_query += 'member_level =?, '
代码解释
如果member_level
存在,将其添加到更新查询语句和对应的值列表中。同理,对于points
也进行类似处理。
if points:
update_query += 'points =?, '
update_values.append(points)
if not update_values:
return jsonify({'success': False,'message': '没有需要更新的字段'})
update_query = update_query.rstrip(', ')
update_query +='WHERE id =?'
update_values.append(member_id)
try:
cursor.execute(update_query, tuple(update_values))
conn.commit()
conn.close()
return jsonify({'success': True})
except Exception as e:
conn.close()
return jsonify({'success': False,'message': f'更新失败: {str(e)}'})
@app.route('/api/book_service', methods=['POST'])
def book_service():
data = request.get_json()
member_id = data.get('member_id')
service_id = data.get('service_id')
booking_time = data.get('booking_time')
conn = create_connection()
cursor = conn.cursor()
try:
cursor.execute('INSERT INTO bookings (member_id, service_id, booking_time) VALUES (?,?,?)',
(member_id, service_id, booking_time))
conn.commit()
conn.close()
return jsonify({'success': True})
except Exception as e:
conn.close()
return jsonify({'success': False,'message': f'预约失败: {str(e)}'})
if __name__ == '__main__':
create_tables()
app.run(debug=True)
代码解释
- 更新会员信息部分:
- 首先检查传入的数据中是否有需要更新的字段(
name
、member_level
、points
)。如果没有任何需要更新的字段,则直接返回错误信息。 - 构建更新查询语句
update_query
,根据传入的数据动态添加需要更新的字段。最后在查询语句末尾添加WHERE id =?
条件,并将member_id
添加到值列表update_values
中。 - 尝试执行更新操作,如果成功,提交事务并关闭连接,返回成功信息;如果出现异常,关闭连接并返回包含错误信息的响应。
- 首先检查传入的数据中是否有需要更新的字段(
- 服务预约部分:
book_service
函数处理服务预约请求。从请求数据中获取member_id
、service_id
和booking_time
。- 尝试将预约信息插入到
bookings
表中。如果插入成功,提交事务并关闭连接,返回成功信息;如果出现异常,关闭连接并返回包含错误信息的响应。
- 启动部分:
if __name__ == '__main__':
块在脚本直接运行时执行。首先调用create_tables
函数创建数据库表,然后启动 Flask 应用,设置debug=True
以便在开发过程中获取详细的错误信息。
总结
上述代码示例展示了一个上门服务小程序会员系统的基本实现。小程序端提供了注册、登录以及会员信息管理等页面的基本交互功能,通过wx.request
与后端进行数据交互。后端使用 Python 的 Flask 框架搭建服务器,定义了会员注册、登录、获取和更新会员信息以及服务预约等接口,并通过 SQLite 数据库存储会员、服务和预约相关的数据。在实际应用中,还需要进一步完善系统,如添加用户身份验证机制(例如 JWT)增强安全性,优化数据库查询性能,处理并发访问问题,以及完善业务逻辑,如根据会员等级计算服务折扣、积分规则调整等功能,以满足更复杂的业务需求 。