| | |
| | | .subscribe(strings -> { |
| | | //循环查询所有id |
| | | for (String data : strings) { |
| | | DaoSingleton.getAsynchInstance(context).inspectionDao().findBymInspectId(data) |
| | | .subscribeOn(Schedulers.io()) |
| | | .observeOn(Schedulers.io()) |
| | | .subscribe(inspectionBeans -> { |
| | | DaoSingleton.getAsynchInstance(context).inspectionLocationDao().findByNoPostAndInspectId(data) |
| | | .subscribeOn(Schedulers.io()) |
| | | .observeOn(Schedulers.io()) |
| | | .subscribe(inspectionLocationBeans -> { |
| | | if (inspectionLocationBeans != null && inspectionLocationBeans.size() > 0) { |
| | | postInspectionData(context, inspectionBeans, inspectionLocationBeans); |
| | | } |
| | | }); |
| | | }); |
| | | if (!TextUtils.isEmpty(data)) { |
| | | DaoSingleton.getAsynchInstance(context).inspectionDao().findBymInspectId(data) |
| | | .subscribeOn(Schedulers.io()) |
| | | .observeOn(Schedulers.io()) |
| | | .subscribe(inspectionBeans -> { |
| | | DaoSingleton.getAsynchInstance(context).inspectionLocationDao().findByNoPostAndInspectId(data) |
| | | .subscribeOn(Schedulers.io()) |
| | | .observeOn(Schedulers.io()) |
| | | .subscribe(inspectionLocationBeans -> { |
| | | if (inspectionLocationBeans != null && inspectionLocationBeans.size() > 0) { |
| | | postInspectionData(context, inspectionBeans, inspectionLocationBeans); |
| | | } |
| | | }); |
| | | }); |
| | | } |
| | | } |
| | | |
| | | }); |