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.InspectionBean;

import io.reactivex.rxjava3.core.Completable;
import io.reactivex.rxjava3.core.Single;


@Dao
public interface InspectionDao {
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    Completable insert(InspectionBean inspectionBean);

    @Update
    void update(InspectionBean inspectionBean);

    @Delete
    void delete(InspectionBean inspectionBean);

    @Query("DELETE FROM InspectionBean")
    void deleteAll();

    //查询当前没有关闭巡检的巡检ID
    @Query("SELECT * FROM InspectionBean WHERE stopTime IS NULL OR stopTime = '' ORDER BY startTime DESC LIMIT 1")
    Single<InspectionBean> getMostRecentInspectionWithNoStopTime();

}