package com.dayu.pipirrapp.dao;
|
|
import androidx.room.Dao;
|
import androidx.room.Delete;
|
import androidx.room.Insert;
|
import androidx.room.OnConflictStrategy;
|
import androidx.room.Query;
|
import androidx.room.Update;
|
|
import com.dayu.pipirrapp.bean.db.InspectionLocationBean;
|
|
import java.util.List;
|
|
import io.reactivex.rxjava3.core.Completable;
|
import io.reactivex.rxjava3.core.Single;
|
|
@Dao
|
public interface InspectionLocationDao {
|
@Insert(onConflict = OnConflictStrategy.REPLACE)
|
Completable insert(InspectionLocationBean inspectionLocationBean);
|
|
@Update
|
Completable update(InspectionLocationBean inspectionLocationBean);
|
|
@Delete
|
void delete(InspectionLocationBean inspectionLocationBean);
|
|
@Query("DELETE FROM InspectionLocationBean")
|
void deleteAll();
|
|
@Query("select * from InspectionLocationBean limit 1")
|
InspectionLocationBean findFirst();
|
|
//查询所有没有上传的坐标
|
@Query("select * from InspectionLocationBean where isPost=false AND mInspectId=:mInspectId ORDER BY locateTime ASC")
|
Single<List<InspectionLocationBean>> findByNoPostAndInspectId(String mInspectId);
|
|
|
//查询所有该巡检id的坐标
|
@Query("select * from InspectionLocationBean where mInspectId=:mInspectId ORDER BY locateTime ASC")
|
Single<List<InspectionLocationBean>> findByInspectId(String mInspectId);
|
|
//查询所有未上传的mInspectId
|
@Query("SELECT DISTINCT mInspectId FROM InspectionLocationBean WHERE isPost = false")
|
Single<List<String>> getUnpostedMInspectIds();
|
|
//更新所有mInspectId下的已上传状态
|
@Query("UPDATE InspectionLocationBean SET isPost = true WHERE mInspectId = :mInspectId")
|
Completable updataByInspectIdSetIsPost(String mInspectId);
|
}
|
