基于区块链的校园快递取件流程简化系统方案报告

学生 → 查淘宝取件码 → 查京东取件码 → 查短信 → 驿站核验 → 取件

学生 → 扫DID二维码 → 驿站匹配 → 一键出库

┌─────────────────────────────────────────────────────┐
│                   微信小程序端                        │
│  ┌──────────────┐    ┌──────────────┐               │
│  │   学生端     │    │   驿站端     │               │
│  │  - DID生成   │    │  - 扫码识别  │               │
│  │  - 二维码    │    │  - 包裹匹配  │               │
│  │  - 包裹列表  │    │  - 批量出库  │               │
│  └──────────────┘    └──────────────┘               │
└─────────────────────────────────────────────────────┘
                        │
                        ▼
┌─────────────────────────────────────────────────────┐
│                微信云开发（CloudBase）                │
│  ┌──────────────┐    ┌──────────────┐               │
│  │  云数据库    │    │   云函数     │               │
│  │  - 用户表    │    │  - 匹配逻辑  │               │
│  │  - 包裹表    │    │  - 状态更新  │               │
│  │  - 取件记录  │    │              │               │
│  └──────────────┘    └──────────────┘               │
└─────────────────────────────────────────────────────┘

// SHA-256脱敏生成DID
function generateDID(studentId, phone) {
  const crypto = require('crypto-js');
  const raw = studentId + phone;
  const hash = crypto.SHA256(raw).toString();
  return 'DID:' + hash.substring(0, 16);
}

// 云函数：根据DID匹配包裹
exports.matchPackages = async (event) => {
  const { did } = event;
  const db = cloud.database();

  // 根据DID查询待取包裹
  const result = await db.collection('packages')
    .where({
      did: did,
      status: 'pending'
    })
    .get();

  return result.data;
};

// pages/register/register.js
Page({
  data: {
    studentId: '',
    phone: ''
  },

  async register() {
    const { studentId, phone } = this.data;

    // 本地生成DID
    const did = this.generateDID(studentId, phone);

    // 调用云函数注册
    const res = await wx.cloud.callFunction({
      name: 'registerUser',
      data: { did }
    });

    if (res.result.success) {
      wx.setStorageSync('did', did);
      wx.navigateTo({ url: '/pages/index/index' });
    }
  },

  generateDID(studentId, phone) {
    const crypto = require('../../utils/crypto');
    const hash = crypto.SHA256(studentId + phone);
    return 'DID:' + hash.substring(0, 16);
  }
});

// pages/index/index.js
Page({
  onLoad() {
    this.generateQRCode();
  },

  generateQRCode() {
    const did = wx.getStorageSync('did');
    this.setData({ qrCode: did });
  }
});

// pages/packages/packages.js
Page({
  data: { packages: [] },

  async onShow() {
    const did = wx.getStorageSync('did');
    const res = await wx.cloud.callFunction({
      name: 'getPackages',
      data: { did }
    });
    this.setData({ packages: res.result.data });
  }
});

// pages/scan/scan.js
Page({
  scanCode() {
    wx.scanCode({
      success: async (res) => {
        const did = res.result;
        await this.matchPackages(did);
      }
    });
  },

  async matchPackages(did) {
    const res = await wx.cloud.callFunction({
      name: 'matchPackages',
      data: { did }
    });
    this.setData({ packages: res.result });
  }
});

// pages/scan/scan.js
Page({
  async batchCollect() {
    const { packages } = this.data;
    const packageIds = packages.map(p => p._id);

    await wx.cloud.callFunction({
      name: 'batchCollect',
      data: { packageIds }
    });

    wx.showToast({ title: '出库成功' });
  }
});

// cloudfunctions/registerUser/index.js
const cloud = require('wx-server-sdk');
cloud.init();
const db = cloud.database();

exports.main = async (event, context) => {
  const { did } = event;
  const wxContext = cloud.getWXContext();

  await db.collection('users').add({
    data: {
      did,
      openid: wxContext.OPENID,
      create_time: new Date()
    }
  });

  return { success: true };
};

// cloudfunctions/matchPackages/index.js
const cloud = require('wx-server-sdk');
cloud.init();
const db = cloud.database();

exports.main = async (event, context) => {
  const { did } = event;

  const result = await db.collection('packages')
    .where({ did, status: 'pending' })
    .get();

  return result;
};

// cloudfunctions/batchCollect/index.js
const cloud = require('wx-server-sdk');
cloud.init();
const db = cloud.database();

exports.main = async (event, context) => {
  const { packageIds } = event;
  const _ = db.command;

  await db.collection('packages')
    .where({ _id: _.in(packageIds) })
    .update({
      data: { status: 'collected', collect_time: new Date() }
    });

  return { success: true };
};

// 模拟包裹数据
const mockPackages = [
  {
    did: 'DID:abc123def456',
    tracking_no: 'SF1234567890',
    company: '顺丰',
    status: 'pending',
    arrive_time: new Date('2026-03-27')
  },
  {
    did: 'DID:abc123def456',
    tracking_no: 'YT9876543210',
    company: '圆通',
    status: 'pending',
    arrive_time: new Date('2026-03-27')
  }
];

// 批量插入模拟数据
db.collection('packages').add({ data: mockPackages });