Storm实时处理线下订单计算

线下订单计算 消息 currdate.equals(messagetime) "salebill".equals(tableName) if (IsOutRule == 0 && SaleTag == 0 && time.equals(SaleTime)) { String key = SaleTime + BillNumber + DeptCode; billmap.put(key, 1); } "salebilldetail".equals(tableName) || "sale_rent_detail".equals(tableName) if (CancelFlag == 0 && billmap.containsKey(key)) { deal_total_fee = deal_total_fee + SaleEarning + SaleTax; } "card_trading_details".equals(tableName) time2.equals(TradingTime) String key = "storm_OffLine_" + messagetime + "_" + Accounts; // 消费人数 long result = cachebd.increment(key); if (result == 1) { consume_count = consume_count + 1; }