成本小助手

CREATE TABLE IF NOT EXISTS pricing_record (
  id         VARCHAR(36) PRIMARY KEY,
  user_key   VARCHAR(64) NOT NULL,
  name       VARCHAR(120),
  code       VARCHAR(64),
  factory    VARCHAR(120),
  cost       DECIMAL(10,2),
  freight    DECIMAL(10,2),
  target     DECIMAL(10,2),
  coupon     VARCHAR(24),
  coupon_amt DECIMAL(10,2),
  updated_at DATETIME DEFAULT CURRENT_TIMESTAMP
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE INDEX idx_user ON pricing_record(user_key);

const http = require('http');
const TOKEN = 'e6f1c9a2d84b47c0a3f5-换成你自己的长串';

const store = new Map();

http.createServer(function (req, res) {
  function send(code, obj) {
    const b = Buffer.from(JSON.stringify(obj), 'utf8');
    res.writeHead(code, {
      'Content-Type': 'application/json; charset=utf-8',
      'Access-Control-Allow-Origin': '*',
      'Access-Control-Allow-Headers': 'Content-Type, Authorization',
      'Access-Control-Allow-Methods': 'GET, POST, OPTIONS'
    });
    res.end(b);
  }
  if (req.method === 'OPTIONS') return send(204, {});
  if (req.headers.authorization !== 'Bearer ' + TOKEN) {
    return send(401, { ok: false, err: 'token' });
  }
  if (req.url === '/api/pricing' && req.method === 'GET') {
    return send(200, { ok: true, records: Array.from(store.values()) });
  }
  if (req.url === '/api/pricing' && req.method === 'POST') {
    let raw = '';
    req.on('data', function (c) { raw += c; });
    req.on('end', function () {
      try {
        const d = JSON.parse(raw);
        (d.records || []).forEach(function (r) {
          store.set(r.id || String(Date.now() + Math.random()), r);
        });
        send(200, { ok: true, count: store.size });
      } catch (e) { send(400, { ok: false, err: 'bad json' }); }
    });
    return;
  }
  send(404, { ok: false, err: 'not found' });
}).listen(3000, function () { console.log('listening 3000'); });

// 上传：当前所有商品推到你的服务器
await fetch('https://api.你的域名.com/api/pricing', {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'Authorization': 'Bearer 你的TOKEN'
  },
  body: JSON.stringify({ records: db.records })
});

// 拉取
const r = await fetch('https://api.你的域名.com/api/pricing', {
  headers: { 'Authorization': 'Bearer 你的TOKEN' }
});
const { records } = await r.json();

ALTER TABLE records  ADD COLUMN platform VARCHAR(24) DEFAULT 'pdd';
ALTER TABLE pricing_record ADD COLUMN platform VARCHAR(24) DEFAULT 'pdd';