今天完成的事情：学习实时推送 我们实际中用的都是 http拉取的方式

简单地说  每隔一段时间 去获取一次消息 如果有更新小红点

如果没有 线程休眠一段时间 然后再次检测

private static final long SLEEP_MILLISECOND = 180000;// ====空转任务间隔休息毫秒数

private static final Log log = LogFactory.getLog("autoScan");

private OrdersService ordersService;

private PayOrderService payOrderService;



private Long interval = 2000L;

public OrdersService getOrdersService() {
  return ordersService;
}

public void setOrdersService(OrdersService ordersService) {
  this.ordersService = ordersService;
}

public Long getInterval() {
  return interval;
}

public void setInterval(Long interval) {
  this.interval = interval;
}

public PayOrderService getPayOrderService() {
  return payOrderService;
}

public void setPayOrderService(PayOrderService payOrderService) {
  this.payOrderService = payOrderService;
}

public PayAndWithdrawalEtl() {
  super();
}

public void process() throws InterruptedException {
  
  while (true) {
    
    try {
      
      // 1. get data of unconfirm order
      List<Orders> orderses = getOutOfDateOrders();
      if (CollectionUtils.isEmpty(orderses)) {
        log.info("orderses etl not get any id ,sleep " + SLEEP_MILLISECOND + " ms ");
        Thread.sleep(SLEEP_MILLISECOND);
        
      }
      // 2.query result from consignment,if success
      updateOutOfDateOrdersStatus(orderses);
      
    }
    catch (Throwable t) {
      t.printStackTrace();
      Thread.sleep(SLEEP_MILLISECOND);
      log.error("process goods bytime status error ,sleep " + t.getMessage());
    }
    
  }
  
}

private List<Orders> getOutOfDateOrders() throws ServiceException, ServiceDaoException {
  
  List<Orders> orderses = new ArrayList<>();
  Long now = System.currentTimeMillis();
  log.info(" getOutOfDateOrders start ,now =  " + now);
  Map<String, Object> map = DynamicUtil.getOrders(now, Orders.PAYSTATUS_WAIT, false);
  log.info(" map = " + map);
  List<Long> ordersIds = ordersService.getIdsByDynamicCondition(Orders.class, map, 0, 50);
  if (CollectionUtils.isEmpty(ordersIds)) {
    log.info(" outOfDate orders ids is empty");
    
  }
  else {
    log.info(" outOfDate orders ids size is " + ordersIds);
    orderses = ordersService.getObjectsByIds(ordersIds);
    
  }
  
  return orderses;
  
}

private void updateOutOfDateOrdersStatus(List<Orders> orderses)
    throws ServiceException, ServiceDaoException {
  log.info(" updateOutOfDateOrdersStatus start,orders size = " + orderses);
  if (CollectionUtils.isEmpty(orderses)) {
    log.info(" outOfDate orders  is empty");
    
  }
  else {
    log.info(" outOfDate orders  size is " + orderses.size());
    for (Orders orders : orderses) {
      orders.setStatus(Orders.PAYSTATUS_OUTOFDATE);
    }
    ordersService.updateList(orderses);
    log.info(" updateOutOfDateOrdersStatus success");
  }
  
}

public static Map<String, Object> getOrders(Long now, int status, Boolean count) {
  
  log.info(" status = " + status + " now = " + now);
  Map<String, Object> params = new HashMap<String, Object>();
  
  params.put(" orders_invalid_at & <= ", "'" + now + "'");
  params.put(" status  ", "'" + status + "'");
  
  if (count) {
    params.put("@query", " count(id) ");
  }
  else {
    params.put("@query", " id ");
  }
  params.put("@table", "  orders ");
  
  return params;
}

明天计划的事情：继续 设计方案 
遇到的问题：要不要做一个用户唯一登陆的设计

因为金融产品比较严谨 

收获：while （true） 搭配if的使用

Thread.sleep（）的使用

Java线程具有五中基本状态

新建状态（New）：当线程对象对创建后，即进入了新建状态，如：Thread t = new MyThread();

就绪状态（Runnable）：当调用线程对象的start()方法（t.start();），线程即进入就绪状态。处于就绪状态的线程，只是说明此线程已经做好了准备，随时等待CPU调度执行，并不是说执行了t.start()此线程立即就会执行；

运行状态（Running）：当CPU开始调度处于就绪状态的线程时，此时线程才得以真正执行，即进入到运行状态。注：就     绪状态是进入到运行状态的唯一入口，也就是说，线程要想进入运行状态执行，首先必须处于就绪状态中；

阻塞状态（Blocked）：处于运行状态中的线程由于某种原因，暂时放弃对CPU的使用权，停止执行，此时进入阻塞状态，直到其进入到就绪状态，才 有机会再次被CPU调用以进入到运行状态。根据阻塞产生的原因不同，阻塞状态又可以分为三种：

1.等待阻塞：运行状态中的线程执行wait()方法，使本线程进入到等待阻塞状态；

2.同步阻塞 -- 线程在获取synchronized同步锁失败(因为锁被其它线程所占用)，它会进入同步阻塞状态；

3.其他阻塞 -- 通过调用线程的sleep()或join()或发出了I/O请求时，线程会进入到阻塞状态。当sleep()状态超时、join()等待线程终止或者超时、或者I/O处理完毕时，线程重新转入就绪状态。

死亡状态（Dead）：线程执行完了或者因异常退出了run()方法，该线程结束生命周期。