| | |
| | | // 在这里执行异步操作 |
| | | List<RechargeBean> beanList; |
| | | if (beginTime == 0 && endTime == 0) { |
| | | beanList = asynchBaseDao.rechargeDao().findAll(QHOnLineApplication.qhAloneApplication.adminId, page * limit, limit); |
| | | beanList = asynchBaseDao.rechargeDao().findAll(QHOnLineApplication.qhOnLineApplication.adminId, page * limit, limit); |
| | | } else { |
| | | beanList = asynchBaseDao.rechargeDao().ansyFindByTime(QHOnLineApplication.qhAloneApplication.adminId, beginTime, endTime); |
| | | beanList = asynchBaseDao.rechargeDao().ansyFindByTime(QHOnLineApplication.qhOnLineApplication.adminId, beginTime, endTime); |
| | | } |
| | | // 将结果发送给观察者 |
| | | emitter.onNext(beanList); |