同步逻辑

gistfile1.java

String today  = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
String seller = "onitsukatiger官方旗舰店";
// 同步队列
SyncQueue ot = OT.orderQueue(seller, today);

Query sql = dbconn.createQuery("from Trade where seller_nick = ? and status = ? and (end_time between ? and ?)");
      sql.setString(0, seller);
      sql.setString(1, "TRADE_FINISHED");
      sql.setString(2, today + " 00:00:00");
      sql.setString(3, today + " 23:59:59");

// 交易
List<Trade> trades = sql.list();
for (Trade trade : trades) {
  for (Order order : trade.orders) {
    ot.add(order) // 加入队列
  }
}

Query sql = dbconn.createQuery("from Refund where seller_nick = ? and status = ? and (modified between ? and ?)");
      sql.setString(0, seller);
      sql.setString(1, "SUCCESS");
      sql.setString(2, today + " 00:00:00");
      sql.setString(3, today + " 23:59:59");

// 退款
List<Refund> refunds = sql.list();
for (Refund refund : refunds) {
  // 退款，订单状态
  switch (refund.order_status) {
    case "TRADE_FINISHED": // 原订单，不同步
        ot.add(refund.order) // 加入队列
      break;
    default: // 原订单，同步
        ot.add(Order.find(refund.oid)) // 找原订单
        ot.add(refund.order, -1) // 销售状态，退款
      break;
  }
}