微信云开发实战：基于TBaaS的回收订单哈希上链存证全流程解析

1次阅读

共计 2131 个字符，预计需要花费 6 分钟才能阅读完成。

在环保回收行业中，订单数据的真实性和不可篡改性直接关系到碳积分核算、政府补贴发放等核心业务。传统数据库存储存在数据易被篡改、难自证清白的问题。比如回收员 A 声称某日回收了 100 公斤废品，但后期修改数据为 150 公斤以骗取补贴，中心化系统无法提供可信证明。

中心化数据库 ：
优点：写入速度快（毫秒级），开发成本低
缺点：管理员可篡改历史数据，审计困难
自建区块链节点 ：
优点：完全自主可控
缺点：需要专业运维团队，硬件成本高（年费 5 万 +）
TBaaS（Tencent Blockchain as a Service）：
免维护底层节点
按实际存储量计费（1KB 数据约 0.02 元）
提供标准 SDK 对接微信云开发

登录微信开发者工具
新建项目时勾选「小程序·云开发」
在云控制台激活免费环境（注意选择上海地域）

// 云函数入口文件
const tbaas = require('tbaas-nodejs-sdk');
const crypto = require('crypto');

// 配置常量（实际项目应放环境变量）const CHANNEL_NAME = 'recycle_channel';
const CHAINCODE_NAME = 'order_chaincode';

// 生成订单哈希
const generateHash = (orderData) => {
  // 关键字段排序防篡改
  const str = `${orderData.id}|${orderData.weight}|${orderData.timestamp}`;
  return crypto.createHash('sha256').update(str).digest('hex');
};

// 主函数
exports.main = async (event, context) => {
  try {
    // 参数校验
    if (!event.orderData) throw new Error('缺少订单数据');

    // 1. 生成哈希
    const hash = generateHash(event.orderData);

    // 2. 调用 TBaaS 上链
    const client = new tbaas({
      channelName: CHANNEL_NAME,
      chaincodeName: CHAINCODE_NAME
    });

    const txData = {
      func: 'saveHash',
      args: [hash, JSON.stringify(event.orderData)]
    };

    // 3. 带重试机制的调用
    let retry = 0;
    while (retry < 3) {
      try {const result = await client.invoke(txData);
        return { 
          success: true,
          txId: result.txId,
          hash: hash
        };
      } catch (e) {
        retry++;
        if (retry >= 3) throw e;
        await new Promise(resolve => setTimeout(resolve, 1000 * retry));
      }
    }
  } catch (err) {console.error('上链失败:', err);
    return {
      success: false,
      error: err.message
    };
  }
};

// 前端调用代码
Page({submitOrder() {
    const orderData = {
      id: 'REC20230001',
      weight: 12.5, // 公斤
      timestamp: Date.now(),
      // 注意：敏感字段需脱敏
      operator: '张 *'
    };

    wx.cloud.callFunction({
      name: 'blockchainSave',
      data: {orderData},
      success: res => {if (res.result.success) {console.log('上链成功，交易 ID:', res.result.txId);
        } else {wx.showToast({ title: '存证失败'});
        }
      },
      fail: err => {console.error('云函数调用异常:', err);
      }
    });
  }
})