| | |
| | | import android.view.LayoutInflater; |
| | | import android.view.View; |
| | | |
| | | import androidx.recyclerview.widget.LinearLayoutManager; |
| | | |
| | | import com.dayu.recharge.adapter.NewCardAdapter; |
| | | import com.dayu.recharge.adapter.RechargeAdapter; |
| | | import com.dayu.recharge.databinding.ActivityRechargeListBinding; |
| | | import com.dayu.recharge.dbBean.RechargeBean; |
| | | import com.dayu.recharge.dbBean.UserCardBean; |
| | | import com.dayu.recharge.model.RechargeListModel; |
| | | import com.dayu.recharge.utils.ArithUtil; |
| | | import com.dayu.recharge.utils.TipUtil; |
| | | import com.dayu.recharge.view.datepicker.CustomDatePicker; |
| | | import com.dayu.recharge.view.datepicker.DateFormatUtils; |
| | | import com.scwang.smart.refresh.footer.ClassicsFooter; |
| | | import com.scwang.smart.refresh.layout.api.RefreshLayout; |
| | | import com.scwang.smart.refresh.layout.listener.OnLoadMoreListener; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | | import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers; |
| | | import io.reactivex.rxjava3.core.Observable; |
| | | import io.reactivex.rxjava3.schedulers.Schedulers; |
| | | |
| | | /** |
| | | * Copyright (C), 2023, |
| | |
| | | |
| | | ActivityRechargeListBinding rechargeListBinding; |
| | | RechargeAdapter adapter; |
| | | List<RechargeBean> rechargeList; |
| | | List<RechargeBean> rechargeList = new ArrayList<>(); |
| | | |
| | | private CustomDatePicker beginDatePicker; |
| | | private CustomDatePicker endDatePicker; |
| | | long beginTime; |
| | | long endTime; |
| | | |
| | | int page = 0; |
| | | |
| | | //每页数据条数 |
| | | int limit = 30; |
| | | RefreshLayout myRefreshLayout; |
| | | |
| | | @Override |
| | | protected void onCreate(Bundle savedInstanceState) { |
| | |
| | | rechargeListBinding = ActivityRechargeListBinding.inflate(LayoutInflater.from(this)); |
| | | setContentView(rechargeListBinding.getRoot()); |
| | | setRightButton(); |
| | | setData(); |
| | | initDatePicker(); |
| | | getTotal(); |
| | | initList(); |
| | | getList(); |
| | | } |
| | | |
| | | private void setData() { |
| | | |
| | | rechargeList = baseDao.rechargeDao().findAll(); |
| | | |
| | | private void initList() { |
| | | myRefreshLayout = (RefreshLayout) rechargeListBinding.refreshLayout; |
| | | myRefreshLayout.setEnableRefresh(false); |
| | | myRefreshLayout.setRefreshFooter(new ClassicsFooter(this)); |
| | | myRefreshLayout.setOnLoadMoreListener(new OnLoadMoreListener() { |
| | | @Override |
| | | public void onLoadMore(RefreshLayout refreshlayout) { |
| | | page = page + 1; |
| | | getList(); |
| | | } |
| | | }); |
| | | adapter = new RechargeAdapter(this, rechargeList); |
| | | rechargeListBinding.rechargeList.setAdapter(adapter); |
| | | LinearLayoutManager layoutManager = new LinearLayoutManager(this); |
| | | rechargeListBinding.recyclerView.setLayoutManager(layoutManager); |
| | | rechargeListBinding.recyclerView.setAdapter(adapter); |
| | | } |
| | | |
| | | private void getTotal() { |
| | |
| | | double b = Double.parseDouble(rechargeList.get(i).getMorny()); |
| | | total = ArithUtil.add(total, b); |
| | | } |
| | | rechargeListBinding.rechargeTotal.setText("累计充值:" + String.valueOf(total) + "元"); |
| | | rechargeListBinding.rechargeTotal.setText("已加载数据累计充值:" + String.valueOf(total) + "元"); |
| | | } |
| | | |
| | | } |
| | | |
| | | private void getList() { |
| | | // 创建一个 Observable |
| | | Observable<List<RechargeBean>> observable = Observable.create(emitter -> { |
| | | // 在这里执行异步操作 |
| | | List<RechargeBean> beanList; |
| | | if (beginTime == 0 && endTime == 0) { |
| | | beanList = asynchBaseDao.rechargeDao().findAll(page * limit, limit); |
| | | } else { |
| | | beanList = asynchBaseDao.rechargeDao().ansyFindByTime(beginTime, endTime); |
| | | } |
| | | // 将结果发送给观察者 |
| | | emitter.onNext(beanList); |
| | | emitter.onComplete(); |
| | | }); |
| | | // 订阅观察者 |
| | | observable.subscribeOn(Schedulers.io()) // 指定在 IO 线程执行 |
| | | .observeOn(AndroidSchedulers.mainThread()) // 指定在单一线程观察结果 |
| | | .subscribe( |
| | | result -> { |
| | | // 在这里处理结果,这里是在主线程中 |
| | | // System.out.println("Result: " + result); |
| | | if (result.size() < limit) { |
| | | myRefreshLayout.finishLoadMoreWithNoMoreData(); |
| | | } |
| | | if (result != null && result.size() > 0) { |
| | | rechargeList.addAll(result); |
| | | } |
| | | adapter.notifyDataSetChanged(); |
| | | getTotal(); |
| | | }, |
| | | error -> { |
| | | // 处理错误 |
| | | System.err.println("Error: " + error.getMessage()); |
| | | } |
| | | ); |
| | | } |
| | | |
| | | |
| | |
| | | TipUtil.show(RechargeListActivity.this, "结束时间不能晚于开始时间"); |
| | | } else { |
| | | endTime = endTime + (1000 * 60 * 60 * 24) - 1; |
| | | List<RechargeBean> userList = baseDao.rechargeDao().findByTime(beginTime, endTime); |
| | | rechargeList.clear(); |
| | | rechargeList.addAll(userList); |
| | | adapter.notifyDataSetChanged(); |
| | | getTotal(); |
| | | |
| | | getList(); |
| | | } |
| | | } |
| | | }, beginTimestamp, endTimestamp); |