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.DivideBean;
import com.dayu.pipirrapp.bean.db.MarkerBean;
import com.dayu.pipirrapp.bean.db.SearchResultBean;

import java.util.List;

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

/**
 * DivideDao -分水房
 *
 * @author zuoxiao
 * @version 1.0
 * @since 2025-01-13
 */
@Dao
public interface DivideDao {
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    void insert(DivideBean divideBean);

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    Completable insertAll(List<DivideBean> divideBeans); // 使用 Completable 进行异步插入

//    @Insert(onConflict = OnConflictStrategy.REPLACE)
//    void insertAll(List<MarkerBean> markerBeans); // 使用 Completable 进行异步插入

    @Update
    void update(DivideBean divideBean);

    @Delete
    void delete(DivideBean divideBean);

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

    @Query("select  * from DivideBean limit 1")
    DivideBean findFirst();

    @Query("select  * from DivideBean")
    List<DivideBean> findAll();

    @Query("select  * from DivideBean")
    Single<List<DivideBean>> findAllToSingle();

    @Query("SELECT * FROM DivideBean")
    Maybe<List<DivideBean>> getAll();  // 改为返回Maybe<List<DivideBean>>

    @Query("SELECT * FROM DivideBean WHERE divideName LIKE '%' || :name || '%'")
    Single<List<DivideBean>> findByDivideNameLike(String name);

    @Query("SELECT divideName as name, 'divide' as type, lat, lng, address, divideId as id FROM DivideBean " +
           "WHERE divideName LIKE '%' || :keyword || '%' " +
           "UNION " +
           "SELECT name, 'marker' as type, lat, lng, address, id FROM MarkerBean " +
           "WHERE name LIKE '%' || :keyword || '%'")
    Single<List<SearchResultBean>> searchAllByKeyword(String keyword);
}