1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
package cn.flightfeather.thirdappmodule.repository
 
import cn.flightfeather.thirdappmodule.bean.vo.DPChangeInfo
import cn.flightfeather.thirdappmodule.bean.vo.DPProblemRecurrence
import cn.flightfeather.thirdappmodule.bean.vo.QueryOptSingle
import cn.flightfeather.thirdappmodule.common.net.ResultCallBack
import cn.flightfeather.thirdappmodule.common.net.ResultObserver
import cn.flightfeather.thirdappmodule.common.net.RetrofitFactory
import cn.flightfeather.thirdappmodule.httpservice.DataProdSingleSceneService
import cn.flightfeather.thirdappmodule.model.bean.BaseResponse
 
/**
 * @author riku
 * Date: 2025/10/30
 */
class DataProdSingleSceneRepository {
    companion object {
        @JvmStatic
        val instance:DataProdSingleSceneRepository by lazy(LazyThreadSafetyMode.SYNCHRONIZED) { DataProdSingleSceneRepository()}
    }
 
    val retrofit = RetrofitFactory.instance.retrofit
 
    /**
     * 获取整改情况
     */
    fun getChangeInfo(queryOptSingle: QueryOptSingle, resultCallBack: ResultCallBack<DPChangeInfo>) {
 
        val service = retrofit.create(DataProdSingleSceneService::class.java).getChangeInfo(queryOptSingle)
 
        RetrofitFactory.executeResult(service, object : ResultObserver<BaseResponse<DPChangeInfo>>() {
            override fun onSuccess(result: BaseResponse<DPChangeInfo>?) {
                resultCallBack.onSuccess(result?.data)
            }
 
            override fun onFailure(e: Throwable, isNetWorkError: Boolean) {
                resultCallBack.onFailure()
            }
        })
    }
 
    /**
     * 批量查询整改情况
     */
    fun getChangeInfoList(queryOpts: List<QueryOptSingle>, resultCallBack: ResultCallBack<List<DPChangeInfo>>) {
 
        val service = retrofit.create(DataProdSingleSceneService::class.java).getChangeInfoList(queryOpts)
 
        RetrofitFactory.executeResult(service, object : ResultObserver<BaseResponse<List<DPChangeInfo>>>() {
            override fun onSuccess(result: BaseResponse<List<DPChangeInfo>>?) {
                resultCallBack.onSuccess(result?.data)
            }
 
            override fun onFailure(e: Throwable, isNetWorkError: Boolean) {
                resultCallBack.onFailure()
            }
        })
    }
 
    /**
     * 问题重复情况
     */
    fun getProblemRecurrence(queryOptSingle: QueryOptSingle, resultCallBack: ResultCallBack<List<DPProblemRecurrence>>) {
 
        val service = retrofit.create(DataProdSingleSceneService::class.java).getProblemRecurrence(queryOptSingle)
 
        RetrofitFactory.executeResult(service, object : ResultObserver<BaseResponse<List<DPProblemRecurrence>>>() {
            override fun onSuccess(result: BaseResponse<List<DPProblemRecurrence>>?) {
                resultCallBack.onSuccess(result?.data)
            }
 
            override fun onFailure(e: Throwable, isNetWorkError: Boolean) {
                resultCallBack.onFailure()
            }
        })
    }
}