package cn.flightfeather.supervision.lightshare.service.Impl
|
|
import cn.flightfeather.supervision.common.nlp.NlpController
|
import cn.flightfeather.supervision.domain.entity.*
|
import cn.flightfeather.supervision.domain.enumeration.*
|
import cn.flightfeather.supervision.domain.mapper.*
|
import cn.flightfeather.supervision.infrastructure.utils.DateUtil
|
import cn.flightfeather.supervision.lightshare.service.OnLineQuestionService
|
import cn.flightfeather.supervision.lightshare.vo.*
|
import com.github.pagehelper.PageHelper
|
import org.springframework.beans.BeanUtils
|
import org.springframework.stereotype.Component
|
import org.springframework.stereotype.Service
|
import tk.mybatis.mapper.entity.Example
|
import java.util.*
|
import javax.annotation.Resource
|
import javax.servlet.http.HttpServletResponse
|
|
/**
|
* @Description: 月问题实现类
|
*/
|
@Service
|
@Component
|
class OnLineQuestionServiceImpl(
|
private val mgtFileMapper: MgtFileMapper,
|
private val mgtItemMapper: MgtItemMapper,
|
private val userinfoMapper: UserinfoMapper,
|
private val cstQuestionMapper: CstQuestionMapper,
|
private val settingAnswerMapper: SettingAnswerMapper,
|
private val enforceCaseMapper: EnforceCaseMapper,
|
private val nlpController: NlpController
|
) : OnLineQuestionService {
|
@Resource
|
private val onLineQuestionMapper: OnLineQuestionMapper? = null
|
override fun addQuestions(userId: String, questions: List<OnLineQuestion>): Int {
|
var r = 0
|
for (q in questions) {
|
r += onLineQuestionMapper!!.insert(q)
|
}
|
return r
|
}
|
|
override fun getQuestions(userId: String, inUse: Boolean, page: Int, perPage: Int, httpServletResponse: HttpServletResponse): List<OnLineQuestion> {
|
|
// 1.计算出起始位置
|
val startPosition = (page - 1) * perPage
|
//2.分页的方法查询数据
|
PageHelper.startPage<Any>(startPosition, perPage)
|
val allMeetings: List<OnLineQuestion>
|
//3.分页显示数据
|
allMeetings = if (inUse) {
|
onLineQuestionMapper!!.findAll()
|
} else {
|
onLineQuestionMapper!!.findAllfalse()
|
}
|
val counts = onLineQuestionMapper.count()
|
val totalPage = Math.ceil(counts / perPage * 1.0).toInt()
|
httpServletResponse.setIntHeader("totalPage", totalPage)
|
httpServletResponse.setIntHeader("currentPage", page)
|
return allMeetings
|
}
|
|
override fun getQDescription(userId: String, questionId: String): String {
|
return onLineQuestionMapper!!.getQDescription(questionId)
|
}
|
|
override fun getQResource(userId: String, questionId: String, page: Int, perPage: Int, httpServletResponse: HttpServletResponse): List<String> {
|
// 1.计算出起始位置
|
val startPosition = (page - 1) * perPage
|
val getQDescription = onLineQuestionMapper!!.getQResource(questionId)
|
val lis = Arrays.asList(*getQDescription.split("、").toTypedArray())
|
val result: List<String>
|
result = if (startPosition + perPage < lis.size) {
|
lis.subList(startPosition, startPosition + perPage)
|
} else {
|
lis.subList(startPosition, lis.size)
|
}
|
val counts = lis.size
|
val totalPage = Math.ceil(counts / perPage * 1.0).toInt()
|
httpServletResponse.setIntHeader("totalPage", totalPage)
|
httpServletResponse.setIntHeader("currentPage", page)
|
return result
|
}
|
|
override fun getQByConditions(userId: String, inUse: Boolean, qCondition: QCondition, page: Int, perPage: Int, httpServletResponse: HttpServletResponse): List<OnLineQuestion> {
|
val keywords = qCondition.keywords
|
val factorType = qCondition.factorType
|
val resourceKind = qCondition.resourceKind
|
val showLevel = qCondition.showLevel
|
val worKind = qCondition.worKind
|
// 1.计算出起始位置
|
val startPosition = (page - 1) * perPage
|
//2.分页的方法查询数据
|
PageHelper.startPage<Any>(startPosition, perPage)
|
//3.分页显示数据 //模糊查询
|
val result = onLineQuestionMapper!!.getQByConditions(keywords, factorType, resourceKind, showLevel, worKind)
|
val counts = onLineQuestionMapper.getQByConditionsCounts(keywords, factorType, resourceKind, showLevel, worKind)
|
val totalPage = Math.ceil(counts / perPage * 1.0).toInt()
|
httpServletResponse.setIntHeader("totalPage", totalPage)
|
httpServletResponse.setIntHeader("currentPage", page)
|
return result
|
}
|
|
override fun searchLaw(userId: String, keyword: String, type: Byte?, page: Int, perPage: Int): BaseResponse<List<ConsultResultVo>> {
|
// val keywordList = if (keyword.isBlank()) {
|
// emptyList()
|
// } else {
|
// nlpController.execute(keyword)
|
// }
|
// val userInfo = userinfoMapper.selectByPrimaryKey(userId) ?: return BaseResponse(false)
|
// val response = BaseResponse<List<ConsultResultVo>>(false, head = DataHead(page, perPage))
|
// val result = mutableListOf<ConsultResultVo>()
|
//
|
// //当搜索不限制类型时，默认每种类型只获取前5项；当限制类型时，则根据前端请求分页数返回
|
// val _perPage = if (type == null) 5 else perPage
|
// val _page = page
|
//
|
// //法律法规文件
|
// if (type == null || type == ConsultResultType.TYPE1.value) {
|
// val p = PageHelper.startPage<MgtFile>(_page, _perPage)
|
// val example = Example(MgtFile::class.java).apply {
|
// if (keywordList.isNotEmpty()) {
|
// createCriteria().apply {
|
// keywordList.forEach { k ->
|
// orLike("mfName", "%${k}%")
|
// orLike("mfShortName", "%${k}%")
|
// orLike("mfSummary", "%${k}%")
|
// orLike("mfKeywordLv1", "%${k}%")
|
// orLike("mfKeywordLv2", "%${k}%")
|
// orLike("mfKeywordLv3", "%${k}%")
|
// orLike("mfKeywordLv4", "%${k}%")
|
// }
|
// }
|
// and(createCriteria().orLike("mfExtension1", "%${userInfo.extension2}%")
|
// .orEqualTo("mfExtension1", "")
|
// .orIsNull("mfExtension1"))
|
// } else {
|
// // TODO: 2022/9/8 没有关键字时，按照热门获取机制获取
|
// createCriteria().orLike("mfExtension1", "%${userInfo.extension2}%")
|
// .orEqualTo("mfExtension1", "")
|
// .orIsNull("mfExtension1")
|
// }
|
// }
|
// mgtFileMapper.selectByExample(example).forEach {
|
// result.add(ConsultResultFileVo().apply {
|
// id = it.mfGuid
|
// name = it.mfName
|
// des = it.mfSummary
|
// typeId = ConsultResultType.TYPE1.value
|
// typeName = ConsultResultType.TYPE1.des
|
//
|
// fileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
// itemType = EnElementType.getNameByValue(it.mfEpItemType)
|
// itemSubType = EnElementSubType.getSubType(it.mfEpItemType, it.mfEpItemSubtype)
|
// fileUrl = it.mfFileUrl
|
// val keyList = it.mfKeywordLv1.split("、")
|
// for (i in keyList.indices) {
|
// if (i < 5) {
|
// keywords.add(keyList[i])
|
// } else {
|
// break
|
// }
|
// }
|
// time = it.mfUpdateTime
|
// fileType = ConsultFileType.getNameByValue(it.mfFileType)
|
// referenceNumber = it.mfReferenceNumber
|
// effectiveDate = DateUtil.DateToString(it.mfEffectiveDate, DateUtil.DateStyle.YYYY_MM_DD)
|
// closingDate = DateUtil.DateToString(it.mfClosingDate, DateUtil.DateStyle.YYYY_MM_DD)
|
// effective = Date().time > (it.mfClosingDate?.time ?: 0)
|
// })
|
// }
|
// response.success = true
|
// response.head?.run {
|
// this.page = p.pageNum
|
// this.totalPage = p.pages
|
// }
|
// }
|
// //法律法规条目
|
// if (type == null || type == ConsultResultType.TYPE2.value) {
|
// val map = mutableMapOf<String, MgtFile>()
|
// val p = PageHelper.startPage<MgtItem>(_page, _perPage)
|
// val example = Example(MgtItem::class.java).apply {
|
// if (keywordList.isNotEmpty()) {
|
// createCriteria().apply {
|
// keywordList.forEach { k ->
|
// orLike("miChapterKeyword", "%${k}%")
|
// orLike("miKeyword", "%${k}%")
|
// orLike("miItemContent", "%${k}%")
|
// }
|
// }
|
// } else {
|
// // TODO: 2022/9/8 没有关键字时，按照热门获取机制获取条目
|
// }
|
// }
|
// mgtItemMapper.selectByExample(example).forEach {
|
//
|
// if (!map.containsKey(it.mfGuid)) {
|
// map[it.mfGuid] = mgtFileMapper.selectByPrimaryKey(it.mfGuid)
|
// }
|
// result.add(ConsultResultItemVo().apply {
|
// id = it.miGuid
|
// name = it.miItemName
|
// des = it.miItemContent
|
// typeId = ConsultResultType.TYPE2.value
|
// typeName = ConsultResultType.TYPE2.des
|
//
|
//// fileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
//// itemType = EnElementType.getNameByValue(it.mfEpItemType)
|
//// fileUrl = it.mfFileUrl
|
// val keyList = it.miKeyword.split("、")
|
// for (i in keyList.indices) {
|
// if (i < 5) {
|
// keywords.add(keyList[i])
|
// } else {
|
// break
|
// }
|
// }
|
// time = it.miUpdateTime
|
//
|
// chapterName = it.miChapterName
|
// fileId = it.mfGuid
|
// fileName = it.mfName
|
// referenceNumber = it.mfReferenceNumber
|
// effectiveDate = DateUtil.DateToString(map[it.mfGuid]?.mfEffectiveDate, DateUtil.DateStyle.YYYY_MM_DD)
|
// closingDate = DateUtil.DateToString(map[it.mfGuid]?.mfClosingDate, DateUtil.DateStyle.YYYY_MM_DD)
|
// effective = Date().time > (map[it.mfGuid]?.mfClosingDate?.time ?: 0)
|
// relatedItems = it.miRelatedItems?.split(";")?.size ?: 0
|
// })
|
// }
|
// response.success = true
|
// response.head?.run {
|
// this.page = p.pageNum
|
// this.totalPage = p.pages
|
// }
|
// }
|
// //环保问题
|
// if (type == null || type == ConsultResultType.TYPE4.value) {
|
// val p = PageHelper.startPage<CstQuestion>(_page, _perPage)
|
// val example = Example(CstQuestion::class.java).apply {
|
// if (keywordList.isNotEmpty()) {
|
// createCriteria().orLike("cqScenes", "%${userInfo.extension2}%")
|
// .orEqualTo("cqScenes", "")
|
// .orIsNull("cqScenes")
|
// and(
|
// createCriteria().apply {
|
// keywordList.forEach { k ->
|
// orLike("cqContent", "%${k}%")
|
// orLike("cqKeywords", "%${k}%")
|
// }
|
// }
|
// )
|
// } else {
|
// // TODO: 2022/9/8 没有关键字时，按照热门获取机制获取
|
// createCriteria().orLike("cqScenes", "%${userInfo.extension2}%")
|
// orderBy("cqTotalnum")
|
// }
|
// }
|
// cstQuestionMapper.selectByExample(example).forEach {
|
// val answers = settingAnswerMapper.selectByExample(Example(SettingAnswer::class.java).apply {
|
// createCriteria().andEqualTo("cqGuid", it.cqGuid)
|
// })
|
//
|
// result.add(ConsultResultQAVo().apply {
|
// id = it.cqGuid
|
// name = it.cqContent
|
// if (answers.isNotEmpty()) {
|
// des = answers[0].saContent
|
// }
|
// typeId = ConsultResultType.TYPE4.value
|
// typeName = ConsultResultType.TYPE4.des
|
//
|
//// fileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
// itemType = EnElementType.getNameByValue(it.cqKind)
|
// itemSubType = EnElementSubType.getSubType(it.cqKind, it.cqSubkind)
|
//// fileUrl = it.mfFileUrl
|
//// val keyList = it.mfKeywordLv1.split("、")
|
//// for (i in keyList.indices) {
|
//// if (i < 5) {
|
//// keywords.add(keyList[i])
|
//// } else {
|
//// break
|
//// }
|
//// }
|
// time = it.cqCreateTime
|
// punish = it.cqIsPunish
|
// illegal = it.cqIsIllegal
|
// shotSpot = it.cqIsShotspot
|
// supervise = it.cqIsSupervise
|
// })
|
// }
|
// response.success = true
|
// response.head?.run {
|
// this.page = p.pageNum
|
// this.totalPage = p.pages
|
// }
|
// }
|
// //执法案例
|
// if (type == null || type == ConsultResultType.TYPE3.value) {
|
// val p = PageHelper.startPage<EnforceCase>(_page, _perPage)
|
// val example = Example(EnforceCase::class.java).apply {
|
// if (keywordList.isNotEmpty()) {
|
// createCriteria().orLike("ecScenes", "%${userInfo.extension2}%")
|
// .orEqualTo("ecScenes", "")
|
// .orIsNull("ecScenes")
|
// and(
|
// createCriteria().apply {
|
// keywordList.forEach { k ->
|
// orLike("ecTitle", "%${k}%")
|
// orLike("ecKeywords", "%${k}%")
|
// }
|
// }
|
// )
|
// } else {
|
// // TODO: 2022/9/8 没有关键字时，按照热门获取机制获取
|
// createCriteria().orLike("ecScenes", "%${userInfo.extension2}%")
|
// .orEqualTo("ecScenes", "")
|
// .orIsNull("ecScenes")
|
// orderBy("ecOccurDate").desc()
|
// }
|
// }
|
// enforceCaseMapper.selectByExample(example).forEach {
|
// result.add(ConsultResultCaseVo().apply {
|
// id = it.ecGuid
|
// name = it.ecTitle
|
// des = it.ecSummary
|
// typeId = ConsultResultType.TYPE3.value
|
// typeName = ConsultResultType.TYPE3.des
|
//
|
//// fileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
// itemType = EnElementType.getNameByValue(it.ecEpItemType)
|
// itemSubType = EnElementSubType.getSubType(it.ecEpItemType, it.ecEpItemSubtype)
|
// imgUrl = it.ecAppendixUrl?.split(";")?.get(0)
|
// time = it.ecCreateTime
|
//
|
// provinceName = it.ecProvinceName
|
// cityName = it.ecCityName
|
// occurDate = DateUtil.DateToString(it.ecOccurDate, DateUtil.DateStyle.YYYY_MM_DD)
|
// punish = it.ecIsPunish
|
// detained = it.ecIsDetained
|
// illegal = it.ecIsIllegal
|
// shotSpot = it.ecIsShotspot
|
// supervise = it.ecIsSupervise
|
// minor = it.ecIsMinor
|
// })
|
// }
|
// response.success = true
|
// response.head?.run {
|
// this.page = p.pageNum
|
// this.totalPage = p.pages
|
// }
|
// }
|
//
|
//
|
// return response.apply { data = result }
|
|
return searchLaw2(userId, keyword, type, page, perPage)
|
}
|
|
override fun getTopicLaw(userId: String): List<MgtFileVo> {
|
val userInfo = userinfoMapper.selectByPrimaryKey(userId) ?: return emptyList()
|
val perPage = 5
|
val p = PageHelper.startPage<MgtFile>(1, perPage)
|
val result = mutableListOf<MgtFileVo>()
|
mgtFileMapper.selectByExample(Example(MgtFile::class.java).apply {
|
createCriteria().orLike("mfExtension1", "%${userInfo.extension2}%")
|
.orEqualTo("mfExtension1", "")
|
.orIsNull("mfExtension1")
|
}).forEach {
|
val vo = MgtFileVo()
|
BeanUtils.copyProperties(it, vo)
|
vo.apply {
|
mfFileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
mfMgtLevel = ManageLevelType.getNameByValue(it.mfMgtLevel)
|
mfFileType = ConsultFileType.getNameByValue(it.mfFileType)
|
mfEpItemType = EnElementType.getNameByValue(it.mfEpItemType)
|
mfEpItemSubtype = EnElementSubType.getSubType(it.mfEpItemType, it.mfEpItemSubtype)
|
mfSaveType = FileSaveType.getNameByValue(it.mfSaveType)
|
}
|
result.add(vo)
|
}
|
return result
|
}
|
|
override fun getMgtFile(userId: String, fileId: String): MgtFileVo {
|
val result = MgtFileVo()
|
mgtFileMapper.selectByPrimaryKey(fileId)?.let {
|
BeanUtils.copyProperties(it, result)
|
result.apply {
|
mfFileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
mfMgtLevel = ManageLevelType.getNameByValue(it.mfMgtLevel)
|
mfFileType = ConsultFileType.getNameByValue(it.mfFileType)
|
mfEpItemType = EnElementType.getNameByValue(it.mfEpItemType)
|
mfEpItemSubtype = EnElementSubType.getSubType(it.mfEpItemType, it.mfEpItemSubtype)
|
mfSaveType = FileSaveType.getNameByValue(it.mfSaveType)
|
}
|
}
|
|
return result
|
}
|
|
override fun getTopicMgtItems(userId: String): List<MgtItem> {
|
val perPage = 5
|
val p = PageHelper.startPage<MgtFile>(1, perPage)
|
return mgtItemMapper.selectAll()
|
}
|
|
override fun getMgtItem(userId: String, itemId: String): MgtItem {
|
return mgtItemMapper.selectByPrimaryKey(itemId) ?: MgtItem()
|
}
|
|
override fun getTopicQA(userId: String): List<CstQuestionVo> {
|
val userInfo = userinfoMapper.selectByPrimaryKey(userId) ?: return emptyList()
|
val perPage = 5
|
val p = PageHelper.startPage<CstQuestion>(1, perPage)
|
val result = mutableListOf<CstQuestionVo>()
|
cstQuestionMapper.selectByExample(Example(CstQuestion::class.java).apply {
|
createCriteria().orLike("cqScenes", "%${userInfo.extension2}%")
|
orderBy("cqTotalnum")
|
}).forEach {
|
val answers = settingAnswerMapper.selectByExample(Example(SettingAnswer::class.java).apply {
|
createCriteria().andEqualTo("cqGuid", it.cqGuid)
|
})
|
val vo = CstQuestionVo()
|
BeanUtils.copyProperties(it, vo)
|
vo.apply {
|
cqKind = EnElementType.getNameByValue(it.cqKind)
|
cqSubkind = EnElementSubType.getSubType(it.cqKind, it.cqSubkind)
|
}
|
|
if (answers.isNotEmpty()) {
|
vo.answer = answers[0].saContent
|
}
|
result.add(vo)
|
}
|
return result
|
}
|
|
override fun getQuestionsByType(userId: String, kind: Byte?, subKind: Byte?, page: Int, perPage: Int): BaseResponse<List<ConsultResultVo>> {
|
val userInfo = userinfoMapper.selectByPrimaryKey(userId) ?: return BaseResponse(false, "用户不存在")
|
val result = mutableListOf<ConsultResultVo>()
|
val p = PageHelper.startPage<CstQuestion>(page, perPage)
|
val example = Example(CstQuestion::class.java).apply {
|
createCriteria().apply {
|
kind?.let { andEqualTo("cqKind", kind) }
|
subKind?.let { andEqualTo("cqSubkind", subKind) }
|
}
|
.andLike("cqScenes", "%${userInfo.extension2}%")
|
orderBy("cqTotalnum")
|
}
|
cstQuestionMapper.selectByExample(example).forEach {
|
val answers = settingAnswerMapper.selectByExample(Example(SettingAnswer::class.java).apply {
|
createCriteria().andEqualTo("cqGuid", it.cqGuid)
|
})
|
|
result.add(ConsultResultQAVo().apply {
|
id = it.cqGuid
|
name = it.cqContent
|
if (answers.isNotEmpty()) {
|
des = answers[0].saContent
|
}
|
typeId = ConsultResultType.TYPE4.value
|
typeName = ConsultResultType.TYPE4.des
|
itemType = EnElementType.getNameByValue(it.cqKind)
|
itemSubType = EnElementSubType.getSubType(it.cqKind, it.cqSubkind)
|
time = it.cqCreateTime
|
})
|
|
// val vo = CstQuestionVo()
|
// BeanUtils.copyProperties(it, vo)
|
// vo.apply {
|
// cqKind = EnElementType.getNameByValue(it.cqKind)
|
// cqSubkind = EnElementSubType.getSubType(it.ecEpItemType, it.cqSubkind)
|
// }
|
//
|
// if (answers.isNotEmpty()) {
|
// vo.answer = answers[0].saContent
|
// }
|
// result.add(vo)
|
}
|
return BaseResponse(true, head = DataHead(p.pageNum, p.pages, p.total), data = result)
|
}
|
|
override fun getQuestion(userId: String, qId: String): CstQuestionVo {
|
val result = CstQuestionVo()
|
cstQuestionMapper.selectByPrimaryKey(qId)?.let {
|
BeanUtils.copyProperties(it, result)
|
result.apply {
|
cqKind = EnElementType.getNameByValue(it.cqKind)
|
cqSubkind = EnElementSubType.getSubType(it.cqKind, it.cqSubkind)
|
}
|
}
|
|
return result
|
}
|
|
override fun getAnswers(userId: String, qId: String): List<SettingAnswer> {
|
return settingAnswerMapper.selectByExample(Example(SettingAnswer::class.java).apply {
|
createCriteria().andEqualTo("cqGuid", qId)
|
})
|
}
|
|
override fun getTopicCase(userId: String): List<EnforceCaseVo> {
|
val userInfo = userinfoMapper.selectByPrimaryKey(userId) ?: return emptyList()
|
val perPage = 5
|
val p = PageHelper.startPage<MgtFile>(1, perPage)
|
val result = mutableListOf<EnforceCaseVo>()
|
enforceCaseMapper.selectByExample(Example(EnforceCase::class.java).apply {
|
createCriteria().orLike("ecScenes", "%${userInfo.extension2}%")
|
.orEqualTo("ecScenes", "")
|
.orIsNull("ecScenes")
|
orderBy("ecOccurDate").desc()
|
}).forEach {
|
val vo = EnforceCaseVo()
|
BeanUtils.copyProperties(it, vo)
|
vo.apply {
|
ecEpItemType = EnElementType.getNameByValue(it.ecEpItemType)
|
ecEpItemSubtype = EnElementSubType.getSubType(it.ecEpItemType, it.ecEpItemSubtype)
|
ecType = EnforceCaseType.getNameByValue(it.ecType)
|
}
|
result.add(vo)
|
}
|
return result
|
}
|
|
override fun getCase(userId: String, caseId: String): EnforceCaseVo {
|
val result = EnforceCaseVo()
|
enforceCaseMapper.selectByPrimaryKey(caseId)?.let {
|
BeanUtils.copyProperties(it, result)
|
result.apply {
|
ecEpItemType = EnElementType.getNameByValue(it.ecEpItemType)
|
ecEpItemSubtype = EnElementSubType.getSubType(it.ecEpItemType, it.ecEpItemSubtype)
|
ecType = EnforceCaseType.getNameByValue(it.ecType)
|
}
|
}
|
|
return result
|
}
|
|
override fun getEnElementTypes(userId: String): List<Pair<String, Byte>> {
|
return listOf(
|
Pair(EnElementType.TYPE1.des, EnElementType.TYPE1.value),
|
Pair(EnElementType.TYPE2.des, EnElementType.TYPE2.value),
|
Pair(EnElementType.TYPE3.des, EnElementType.TYPE3.value),
|
Pair(EnElementType.TYPE4.des, EnElementType.TYPE4.value),
|
Pair(EnElementType.TYPE5.des, EnElementType.TYPE5.value),
|
Pair(EnElementType.TYPE6.des, EnElementType.TYPE6.value),
|
Pair(EnElementType.TYPE7.des, EnElementType.TYPE7.value),
|
Pair(EnElementType.TYPE8.des, EnElementType.TYPE8.value),
|
Pair(EnElementType.TYPE9.des, EnElementType.TYPE9.value),
|
Pair(EnElementType.TYPE10.des, EnElementType.TYPE10.value),
|
Pair(EnElementType.TYPE21.des, EnElementType.TYPE21.value),
|
Pair(EnElementType.TYPE31.des, EnElementType.TYPE31.value),
|
Pair(EnElementType.TYPE41.des, EnElementType.TYPE41.value),
|
Pair(EnElementType.TYPE51.des, EnElementType.TYPE51.value),
|
Pair(EnElementType.TYPE61.des, EnElementType.TYPE61.value),
|
Pair(EnElementType.TYPE99.des, EnElementType.TYPE99.value),
|
)
|
}
|
|
override fun getEnElementSubTypes(userId: String): List<List<Pair<String, Byte>>> {
|
val result = mutableListOf<List<Pair<String, Byte>>>()
|
EnElementSubType.subTypes.forEach { sList ->
|
val list = mutableListOf<Pair<String, Byte>>()
|
for (i in sList.indices) {
|
if (i == sList.lastIndex) {
|
list.add(Pair(sList[i], 99.toByte()))
|
} else {
|
list.add(Pair(sList[i], (i + 1).toByte()))
|
}
|
}
|
result.add(list)
|
}
|
return result
|
}
|
|
private fun searchLaw2(userId: String, keyword: String, type: Byte?, page: Int, perPage: Int): BaseResponse<List<ConsultResultVo>> {
|
val keywordList = if (keyword.isBlank()) {
|
emptyList()
|
} else {
|
nlpController.execute(keyword)
|
}
|
val userInfo = userinfoMapper.selectByPrimaryKey(userId) ?: return BaseResponse(false)
|
val response = BaseResponse<List<ConsultResultVo>>(false, head = DataHead(page, perPage))
|
val result = mutableListOf<ConsultResultVo>()
|
|
//当搜索不限制类型时，默认每种类型只获取前5项；当限制类型时，则根据前端请求分页数返回
|
val _perPage = if (type == null) 5 else perPage
|
val _page = page
|
|
//法律法规文件
|
if (type == null || type == ConsultResultType.TYPE1.value) {
|
val p = PageHelper.startPage<MgtFile>(_page, _perPage)
|
val resultMap = mutableMapOf<String, Pair<MgtFile, Int>>()
|
val tempList = mutableListOf<Pair<MgtFile, Int>>()
|
if (keywordList.isNotEmpty()) {
|
keywordList.forEach { k ->
|
mgtFileMapper.selectByExample(Example(MgtFile::class.java).apply {
|
createCriteria().orLike("mfName", "%${k}%")
|
.orLike("mfShortName", "%${k}%")
|
.orLike("mfSummary", "%${k}%")
|
.orLike("mfKeywordLv1", "%${k}%")
|
.orLike("mfKeywordLv2", "%${k}%")
|
.orLike("mfKeywordLv3", "%${k}%")
|
.orLike("mfKeywordLv4", "%${k}%")
|
}).forEach { f ->
|
if (!resultMap.containsKey(f.mfGuid)) {
|
resultMap[f.mfGuid] = Pair(f, 0)
|
}
|
resultMap[f.mfGuid] = Pair(f, resultMap[f.mfGuid]?.second?.plus(1) ?: 0)
|
}
|
}
|
resultMap.forEach { (_, u) ->
|
tempList.add(u)
|
}
|
tempList.sortWith { o1, o2 ->
|
//排序条件一：关键词匹配次数
|
if (o1.second != o2.second) {
|
return@sortWith o2.second - o1.second
|
}
|
//排序条件二：浏览量
|
if (o1.first.mfRemark != o2.first.mfRemark) {
|
return@sortWith o2.first.mfRemark.toIntOrNull()?.minus(o1.first.mfRemark.toIntOrNull() ?: 0) ?: 0
|
}
|
//排序条件三：文件发布时间
|
(o2.first.mfReleaseDate.time - o1.first.mfReleaseDate.time).toInt()
|
}
|
} else {
|
mgtFileMapper.selectByExample(Example(MgtFile::class.java).apply {
|
createCriteria().orLike("mfExtension1", "%${userInfo.extension2}%")
|
.orEqualTo("mfExtension1", "")
|
.orIsNull("mfExtension1")
|
}).forEach {
|
tempList.add(Pair(it, 0))
|
}
|
}
|
|
tempList.forEach {p ->
|
val it = p.first
|
result.add(ConsultResultFileVo().apply {
|
id = it.mfGuid
|
name = it.mfName
|
des = it.mfSummary
|
typeId = ConsultResultType.TYPE1.value
|
typeName = ConsultResultType.TYPE1.des
|
|
fileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
itemType = EnElementType.getNameByValue(it.mfEpItemType)
|
itemSubType = EnElementSubType.getSubType(it.mfEpItemType, it.mfEpItemSubtype)
|
fileUrl = it.mfFileUrl
|
val keyList = it.mfKeywordLv1.split("、")
|
for (i in keyList.indices) {
|
if (i < 5) {
|
keywords.add(keyList[i])
|
} else {
|
break
|
}
|
}
|
time = it.mfUpdateTime
|
fileType = ConsultFileType.getNameByValue(it.mfFileType)
|
referenceNumber = it.mfReferenceNumber
|
effectiveDate = DateUtil.DateToString(it.mfEffectiveDate, DateUtil.DateStyle.YYYY_MM_DD)
|
closingDate = DateUtil.DateToString(it.mfClosingDate, DateUtil.DateStyle.YYYY_MM_DD)
|
effective = Date().time > (it.mfClosingDate?.time ?: 0)
|
})
|
}
|
response.success = true
|
response.head?.run {
|
this.page = p.pageNum
|
this.totalPage = p.pages
|
}
|
}
|
//法律法规条目
|
if (type == null || type == ConsultResultType.TYPE2.value) {
|
val map = mutableMapOf<String, MgtFile>()
|
val p = PageHelper.startPage<MgtItem>(_page, _perPage)
|
|
val resultMap = mutableMapOf<String, Pair<MgtItem, Int>>()
|
val tempList = mutableListOf<Pair<MgtItem, Int>>()
|
if (keywordList.isNotEmpty()) {
|
mgtItemMapper.selectByExample(Example(MgtItem::class.java).apply {
|
createCriteria().apply {
|
keywordList.forEach { k ->
|
orLike("miChapterKeyword", "%${k}%")
|
orLike("miKeyword", "%${k}%")
|
orLike("miItemContent", "%${k}%")
|
}
|
}
|
}).forEach { f ->
|
if (!resultMap.containsKey(f.miGuid)) {
|
resultMap[f.miGuid] = Pair(f, 0)
|
}
|
resultMap[f.miGuid] = Pair(f, resultMap[f.miGuid]?.second?.plus(1) ?: 0)
|
}
|
resultMap.forEach { (_, u) ->
|
tempList.add(u)
|
}
|
tempList.sortWith { o1, o2 ->
|
//排序条件一：关键词匹配次数
|
if (o1.second != o2.second) {
|
return@sortWith o2.second - o1.second
|
}
|
//排序条件二：浏览量
|
return@sortWith o2.first.miRemark.toIntOrNull()?.minus(o1.first.miRemark.toIntOrNull() ?: 0) ?: 0
|
}
|
} else {
|
// TODO: 2022/9/8 没有关键字时，按照热门获取机制获取条目
|
mgtItemMapper.selectByExample(Example(MgtItem::class.java).apply {
|
orderBy("miCreateTime").desc()
|
}).forEach {
|
tempList.add(Pair(it, 0))
|
}
|
}
|
|
tempList.forEach {p ->
|
val it = p.first
|
if (!map.containsKey(it.mfGuid)) {
|
map[it.mfGuid] = mgtFileMapper.selectByPrimaryKey(it.mfGuid)
|
}
|
result.add(ConsultResultItemVo().apply {
|
id = it.miGuid
|
name = it.miItemName
|
des = it.miItemContent
|
typeId = ConsultResultType.TYPE2.value
|
typeName = ConsultResultType.TYPE2.des
|
|
// fileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
// itemType = EnElementType.getNameByValue(it.mfEpItemType)
|
// fileUrl = it.mfFileUrl
|
val keyList = it.miKeyword.split("、")
|
for (i in keyList.indices) {
|
if (i < 5) {
|
keywords.add(keyList[i])
|
} else {
|
break
|
}
|
}
|
time = it.miUpdateTime
|
|
chapterName = it.miChapterName
|
fileId = it.mfGuid
|
fileName = it.mfName
|
referenceNumber = it.mfReferenceNumber
|
effectiveDate = DateUtil.DateToString(map[it.mfGuid]?.mfEffectiveDate, DateUtil.DateStyle.YYYY_MM_DD)
|
closingDate = DateUtil.DateToString(map[it.mfGuid]?.mfClosingDate, DateUtil.DateStyle.YYYY_MM_DD)
|
effective = Date().time > (map[it.mfGuid]?.mfClosingDate?.time ?: 0)
|
relatedItems = it.miRelatedItems?.split(";")?.size ?: 0
|
})
|
}
|
response.success = true
|
response.head?.run {
|
this.page = p.pageNum
|
this.totalPage = p.pages
|
}
|
}
|
//环保问题
|
if (type == null || type == ConsultResultType.TYPE4.value) {
|
val p = PageHelper.startPage<CstQuestion>(_page, _perPage)
|
|
val resultMap = mutableMapOf<String, Pair<CstQuestion, Int>>()
|
val tempList = mutableListOf<Pair<CstQuestion, Int>>()
|
if (keywordList.isNotEmpty()) {
|
cstQuestionMapper.selectByExample(Example(CstQuestion::class.java).apply {
|
createCriteria().orLike("cqScenes", "%${userInfo.extension2}%")
|
.orEqualTo("cqScenes", "")
|
.orIsNull("cqScenes")
|
and(
|
createCriteria().apply {
|
keywordList.forEach { k ->
|
orLike("cqContent", "%${k}%")
|
orLike("cqKeywords", "%${k}%")
|
}
|
}
|
)
|
}).forEach { f ->
|
if (!resultMap.containsKey(f.cqGuid)) {
|
resultMap[f.cqGuid] = Pair(f, 0)
|
}
|
resultMap[f.cqGuid] = Pair(f, resultMap[f.cqGuid]?.second?.plus(1) ?: 0)
|
}
|
resultMap.forEach { (_, u) ->
|
tempList.add(u)
|
}
|
tempList.sortWith { o1, o2 ->
|
//排序条件一：关键词匹配次数
|
if (o1.second != o2.second) {
|
return@sortWith o2.second - o1.second
|
}
|
//排序条件二：浏览量
|
return@sortWith o2.first.cqRemark?.toIntOrNull()?.minus(o1.first.cqRemark.toIntOrNull() ?: 0) ?: 0
|
}
|
} else {
|
// TODO: 2022/9/8 没有关键字时，按照热门获取机制获取
|
cstQuestionMapper.selectByExample(Example(CstQuestion::class.java).apply {
|
createCriteria().orLike("cqScenes", "%${userInfo.extension2}%")
|
orderBy("cqTotalnum")
|
}).forEach {
|
tempList.add(Pair(it, 0))
|
}
|
}
|
tempList.forEach {p ->
|
val it = p.first
|
val answers = settingAnswerMapper.selectByExample(Example(SettingAnswer::class.java).apply {
|
createCriteria().andEqualTo("cqGuid", it.cqGuid)
|
})
|
|
result.add(ConsultResultQAVo().apply {
|
id = it.cqGuid
|
name = it.cqContent
|
if (answers.isNotEmpty()) {
|
des = answers[0].saContent
|
}
|
typeId = ConsultResultType.TYPE4.value
|
typeName = ConsultResultType.TYPE4.des
|
|
// fileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
itemType = EnElementType.getNameByValue(it.cqKind)
|
itemSubType = EnElementSubType.getSubType(it.cqKind, it.cqSubkind)
|
// fileUrl = it.mfFileUrl
|
// val keyList = it.mfKeywordLv1.split("、")
|
// for (i in keyList.indices) {
|
// if (i < 5) {
|
// keywords.add(keyList[i])
|
// } else {
|
// break
|
// }
|
// }
|
time = it.cqCreateTime
|
punish = it.cqIsPunish
|
illegal = it.cqIsIllegal
|
shotSpot = it.cqIsShotspot
|
supervise = it.cqIsSupervise
|
})
|
}
|
response.success = true
|
response.head?.run {
|
this.page = p.pageNum
|
this.totalPage = p.pages
|
}
|
}
|
//执法案例
|
if (type == null || type == ConsultResultType.TYPE3.value) {
|
val p = PageHelper.startPage<EnforceCase>(_page, _perPage)
|
|
val resultMap = mutableMapOf<String, Pair<EnforceCase, Int>>()
|
val tempList = mutableListOf<Pair<EnforceCase, Int>>()
|
if (keywordList.isNotEmpty()) {
|
enforceCaseMapper.selectByExample(Example(EnforceCase::class.java).apply {
|
|
createCriteria().orLike("ecScenes", "%${userInfo.extension2}%")
|
.orEqualTo("ecScenes", "")
|
.orIsNull("ecScenes")
|
and(
|
createCriteria().apply {
|
keywordList.forEach { k ->
|
orLike("ecTitle", "%${k}%")
|
orLike("ecKeywords", "%${k}%")
|
}
|
}
|
)
|
}).forEach { f ->
|
if (!resultMap.containsKey(f.ecGuid)) {
|
resultMap[f.ecGuid] = Pair(f, 0)
|
}
|
resultMap[f.ecGuid] = Pair(f, resultMap[f.ecGuid]?.second?.plus(1) ?: 0)
|
}
|
resultMap.forEach { (_, u) ->
|
tempList.add(u)
|
}
|
tempList.sortWith { o1, o2 ->
|
//排序条件一：关键词匹配次数
|
if (o1.second != o2.second) {
|
return@sortWith o2.second - o1.second
|
}
|
//排序条件二：浏览量
|
return@sortWith o2.first.ecRemark.toIntOrNull()?.minus(o1.first.ecRemark.toIntOrNull() ?: 0) ?: 0
|
}
|
} else {
|
// TODO: 2022/9/8 没有关键字时，按照热门获取机制获取
|
enforceCaseMapper.selectByExample(Example(EnforceCase::class.java).apply {
|
createCriteria().orLike("ecScenes", "%${userInfo.extension2}%")
|
.orEqualTo("ecScenes", "")
|
.orIsNull("ecScenes")
|
orderBy("ecOccurDate").desc()
|
}).forEach {
|
tempList.add(Pair(it, 0))
|
}
|
}
|
tempList.forEach {p ->
|
val it = p.first
|
result.add(ConsultResultCaseVo().apply {
|
id = it.ecGuid
|
name = it.ecTitle
|
des = it.ecSummary
|
typeId = ConsultResultType.TYPE3.value
|
typeName = ConsultResultType.TYPE3.des
|
|
// fileIndustry = IndustryType.getNameByValue(it.mfFileIndustry)
|
itemType = EnElementType.getNameByValue(it.ecEpItemType)
|
itemSubType = EnElementSubType.getSubType(it.ecEpItemType, it.ecEpItemSubtype)
|
imgUrl = it.ecAppendixUrl?.split(";")?.get(0)
|
time = it.ecCreateTime
|
|
provinceName = it.ecProvinceName
|
cityName = it.ecCityName
|
occurDate = DateUtil.DateToString(it.ecOccurDate, DateUtil.DateStyle.YYYY_MM_DD)
|
punish = it.ecIsPunish
|
detained = it.ecIsDetained
|
illegal = it.ecIsIllegal
|
shotSpot = it.ecIsShotspot
|
supervise = it.ecIsSupervise
|
minor = it.ecIsMinor
|
})
|
}
|
response.success = true
|
response.head?.run {
|
this.page = p.pageNum
|
this.totalPage = p.pages
|
}
|
}
|
|
|
return response.apply { data = result }
|
}
|
}
|
