2025.9.30

feiyu02

2025-09-30 84569abda51ecf6c5549dec4cadee8d043422379

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
78
79
80
81
82
83
84
85
86
87
88
89
package com.flightfeather.grid.service.impl
 
import com.flightfeather.grid.config.exception.BizException
import com.flightfeather.grid.domain.ds1.entity.ClueConclusion
import com.flightfeather.grid.domain.ds1.entity.ClueQuestion
import com.flightfeather.grid.domain.ds1.mapper.ClueConclusionMapper
import com.flightfeather.grid.domain.ds1.mapper.ClueMapper
import com.flightfeather.grid.external.ClueHttpService
import com.flightfeather.grid.service.ClueConclusionService
import com.flightfeather.grid.vo.BaseResponse
import org.springframework.stereotype.Service
import tk.mybatis.mapper.entity.Example
import java.util.*
 
@Service
class ClueConclusionServiceImpl(
    val clueConclusionMapper: ClueConclusionMapper,
    val clueMapper: ClueMapper,
    val clueHttpService: ClueHttpService,
) : ClueConclusionService {
 
    override fun uploadConclusion(clueConclusion: ClueConclusion): Boolean {
        clueConclusion.cId ?: throw BizException("线索id缺失")
        clueConclusion.ccUploaded = false
        clueConclusion.ccCreateTime = Date()
        if (clueConclusion.ccInternal == null) clueConclusion.ccInternal = false
        val conclusion: ClueConclusion?
        try {
            conclusion = clueConclusionMapper.selectOne(ClueConclusion().apply {
                cId = clueConclusion.cId
                ccInternal = clueConclusion.ccInternal
            })
        } catch (e: Exception) {
            throw BizException("每条线索最多能有一条结论，该线索结论存在多条，请检查系统逻辑")
        }
        // 更新
        return if (conclusion != null) {
            if (conclusion.ccUploaded) throw BizException("线索结论已推送，无法修改")
            clueConclusion.ccId = conclusion.ccId
            val res = clueConclusionMapper.updateByPrimaryKeySelective(clueConclusion)
            res == 1
        }
        // 插入
        else {
            val res = clueConclusionMapper.insert(clueConclusion)
            res == 1
        }
 
    }
 
    override fun getClueConclusion(clueId: String, internal: Boolean?): ClueConclusion? {
        val res = clueConclusionMapper.selectByExample(Example(ClueConclusion::class.java).apply {
            createCriteria().andEqualTo("cId", clueId)
                .apply {
                    if (internal == true) {
                        andEqualTo("ccInternal", true)
                    } else {
                        and(
                            createCriteria().orIsNull("ccInternal")
                                .orEqualTo("ccInternal", false)
                        )
                    }
                }
        })
        return if (res.isNotEmpty()) res[0] else null
    }
 
    override fun pushConclusion(conclusionIdList: List<String>?): Boolean {
        clueConclusionMapper.selectByExample(Example(ClueConclusion::class.java).apply {
            createCriteria()
                .andEqualTo("ccUploaded", false)
                .apply {
                    conclusionIdList?.let {
                        andIn("ccId", it)
                    }
                    // 排除掉内部线索结论
                    and(
                        createCriteria().orIsNull("ccInternal")
                            .orEqualTo("ccInternal", false)
                    )
                }
        }).forEach {
            it?.let {
                clueHttpService.uploadConclusion(it)
            }
        }
        return true
    }
}