package cn.flightfeather.thirdappmodule.repository.dao
|
|
import cn.flightfeather.thirdappmodule.bean.entity.MediaFileCache
|
import cn.flightfeather.thirdappmodule.bean.entity.Mediafile
|
import cn.flightfeather.thirdappmodule.common.database.DbFactory
|
import cn.flightfeather.thirdappmodule.common.database.FlatSaveInterface
|
import cn.flightfeather.thirdappmodule.common.database.flatMapDbSaveResult
|
import com.ping.greendao.gen.MediaFileCacheDao
|
import com.ping.greendao.gen.MediafileDao
|
import io.reactivex.Observable
|
import org.greenrobot.greendao.AbstractDao
|
|
/**
|
* @author riku
|
* Date: 2019/7/29
|
* 多媒体文件相关数据库操作
|
*/
|
class MediaFileDao {
|
|
/**
|
* 查询本地是否有图片未上传
|
*/
|
fun checkUnUploadImage(): Observable<Boolean> {
|
return DbFactory.getGreenDaoObservable().map {
|
it.mediafileDao.queryBuilder()
|
.where(
|
MediafileDao.Properties.Remark.eq("未上传")
|
).count()
|
}.map {
|
it > 0
|
}
|
}
|
|
/**
|
* 保存
|
*/
|
fun insert(mediaFile: Mediafile): Observable<Int> {
|
return DbFactory.getGreenDaoObservable().map {
|
it.mediafileDao.insert(mediaFile).toInt()
|
}
|
}
|
|
/**
|
* 根据类型获取巡查中的图片
|
*/
|
fun getMediaFile(inspectionId: String, businessType: Int): Observable<List<Mediafile>> {
|
return DbFactory.getGreenDaoObservable().map {
|
it.mediafileDao.queryBuilder()
|
.where(
|
MediafileDao.Properties.Iguid.eq(inspectionId),
|
MediafileDao.Properties.Businesstypeid.eq(businessType),
|
MediafileDao.Properties.Remark.eq("未上传")
|
).list()
|
}
|
}
|
|
/**
|
* 根据问题id获取对应的相关图片
|
*/
|
fun getMediaFileByProblemId(problemId: String): Observable<List<Mediafile>> {
|
return DbFactory.getGreenDaoObservable().map {
|
it.mediafileDao.queryBuilder().where(
|
MediafileDao.Properties.Businessguid.eq(problemId),
|
MediafileDao.Properties.Remark.eq("未上传")
|
).list()
|
}
|
}
|
|
/**
|
* 删除图片
|
*/
|
fun deleteMediaFile(id: String): Observable<Boolean> {
|
return DbFactory.getGreenDaoObservable().map {
|
it.mediafileDao.deleteByKey(id)
|
true
|
}
|
}
|
|
/**
|
* 获取缓存的文件
|
*/
|
fun getFileCache(url: String?): Observable<String> {
|
return DbFactory.getGreenDaoObservable().map {
|
val resultList = it.mediaFileCacheDao.queryBuilder()
|
.where(MediaFileCacheDao.Properties.Url.eq(url))
|
.list()
|
if (resultList.isNotEmpty()) {
|
resultList[0].path
|
} else {
|
""
|
}
|
}
|
}
|
|
/**
|
* 保存缓存的文件
|
*/
|
fun saveFileCache(url: String, localPath: String, thumbnailPath: String? = null) {
|
flatMapDbSaveResult(DbFactory.getInstance().mediaFileCacheDao,
|
object : FlatSaveInterface<MediaFileCache, Long> {
|
override fun onQuery(dao: AbstractDao<MediaFileCache, Long>): List<MediaFileCache> {
|
return dao.queryBuilder()
|
.where(MediaFileCacheDao.Properties.Url.eq(url))
|
.list()
|
}
|
|
override fun onUpdate(list: List<MediaFileCache>) {
|
list[0].apply {
|
path = localPath
|
}
|
}
|
|
override fun onInsert(): List<MediaFileCache> {
|
return listOf(MediaFileCache().apply {
|
this.url = url
|
this.path = localPath
|
})
|
}
|
})
|
}
|
}
|
