123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253 |
- package com.persagy.server.services.task
- import cn.hutool.core.collection.CollUtil
- import com.alibaba.fastjson.JSONObject
- import com.persagy.database.SFilter
- import com.persagy.database.functions.SLength
- import com.persagy.mybatis.SMybatisDao
- import com.persagy.server.datacenter.models.entities.dictnew.DefClass
- import com.persagy.server.datacenter.models.entities.objects.Equipment
- import com.persagy.server.datacenter.models.entities.task.CategoryStatistics
- import com.persagy.server.datacenter.models.entities.task.EquipScanTaskQuery
- import com.persagy.server.services.AdmBaseService
- import com.persagy.server.services.DmpBaseService
- import com.persagy.server.util.AdmEntityTransferUtil
- import com.persagy.service.SObjectService
- import com.persagy.service.SPageContext
- import com.persagy.service.models.SCascadeQuery
- import com.persagy.service.models.requests.SQueryRequest
- import com.persagy.service.models.responses.SQueryResponse
- import org.slf4j.LoggerFactory
- import org.springframework.beans.factory.annotation.Autowired
- import java.util.stream.Collectors
- object EquipScanTaskQueryService : SObjectService<EquipScanTaskQuery>(SMybatisDao(EquipScanTaskQuery::class.java)) {
-
-
-
- private val logger = LoggerFactory.getLogger(EquipScanTaskQueryService::class.java)
- @Autowired
- private val dmpBaseService: DmpBaseService? = DmpBaseService()
- @Autowired
- private val admBaseService: AdmBaseService? = AdmBaseService()
- fun pageQuerys(request: SQueryRequest): SQueryResponse<EquipScanTaskQuery> {
-
- val projectId = SPageContext.getHeader("projectId").toString()
- val withFilterList = ArrayList<SFilter>()
- withFilterList.add(SFilter.eq("projectId", SPageContext.getHeader("projectId").toString()))
- withFilterList.add(SFilter.lt(SLength("classCode"), 7))
- val pageQuery = pageQuery(request, withFilterList)
- if (!pageQuery.content.isNullOrEmpty()&&pageQuery.content!!.size>0){
-
- val equipScanTaskList = pageQuery.content
- var cascadeQueryAdmEquip = arrayListOf<Equipment>()
- if (equipScanTaskList != null) {
- val cascades = ArrayList<SCascadeQuery>()
-
- val buildCacade = SCascadeQuery()
- buildCacade.name = "building"
- cascades.add(buildCacade)
-
- val floorCacade = SCascadeQuery()
- floorCacade.name="floor"
- cascades.add(floorCacade)
- request.cascade= cascades
- cascadeQueryAdmEquip = cascadeQueryAdmEquip(equipScanTaskList, request) as ArrayList<Equipment>
- }
- val equipMap = cascadeQueryAdmEquip?.stream()?.collect(Collectors.groupingBy { item: Equipment -> item.id })
- for (content in pageQuery.content!!){
-
- val caseNodes = equipMap.get(content.equipId)
- if(CollUtil.isNotEmpty(caseNodes)){
- val equip = caseNodes?.get(0)
- if (equip != null) {
- content.building = equip.building
- content.floor = equip.floor
-
- }
- }
-
- val exec = select(SFilter.eq("parentId", content.equipId!!),SFilter.eq("taskParentId", content.id!!)).exec()
- if (exec.size>0){
- content.component = exec
- }
-
- val param = JSONObject()
- val criteria = JSONObject()
- criteria["code"] = content.classCode!!
- param["criteria"] = criteria
- val dictTypes =dmpBaseService!!.queryDictType(param)
- val defClass = AdmEntityTransferUtil.toAdmMultiEntity(dictTypes, null, DefClass::class.java)
-
- if (defClass!=null && defClass.size>0) {
- content.equipCategory = defClass.get(0)
- }
- }
- }
- return pageQuery
- }
- fun pageQueryTwo(request: SQueryRequest): SQueryResponse<EquipScanTaskQuery> {
- val projectId = SPageContext.getHeader("projectId").toString()
- val withFilterList = ArrayList<SFilter>()
- withFilterList.add(SFilter.eq("projectId", SPageContext.getHeader("projectId").toString()))
- val pageQuery = pageQuery(request, withFilterList)
- if (!pageQuery.content.isNullOrEmpty()&&pageQuery.content!!.size>0){
-
- val equipScanTaskList = pageQuery.content
- var cascadeQueryAdmEquip = arrayListOf<Equipment>()
- if (equipScanTaskList != null) {
- cascadeQueryAdmEquip = cascadeQueryAdmEquip(equipScanTaskList, request) as ArrayList<Equipment>
- }
- val equipMap = cascadeQueryAdmEquip?.stream()?.collect(Collectors.groupingBy { item: Equipment -> item.id })
- for (content in pageQuery.content!!){
-
- val caseNodes = equipMap.get(content.equipId)
- if(CollUtil.isNotEmpty(caseNodes)){
- val equip = caseNodes?.get(0)
- if (equip != null) {
- content.building = equip.building
- content.floor = equip.floor
-
- }
- }
- val exec = select(SFilter.eq("parentId", content.equipId!!),SFilter.eq("taskParentId", content.id!!)).exec()
- if (exec.size>0){
- content.component = exec
- }
-
- val param = JSONObject()
- val criteria = JSONObject()
- criteria["code"] = content.classCode!!
- param["criteria"] = criteria
- val dictTypes =dmpBaseService!!.queryDictType(param)
- val defClass = AdmEntityTransferUtil.toAdmMultiEntity(dictTypes, null, DefClass::class.java)
-
- if (defClass!=null && defClass.size>0) {
- content.equipCategory = defClass.get(0)
- }
- }
- }
- return pageQuery
- }
-
- fun cascadeQueryAdmEquip(equipScanTaskList: List<EquipScanTaskQuery>,request: SQueryRequest): List<Equipment>? {
-
- if(CollUtil.isEmpty(equipScanTaskList)){
- return ArrayList<Equipment>()
- }
- val equipIds = equipScanTaskList?.stream()?.map(EquipScanTaskQuery::equipId)?.collect(Collectors.toList<String>())
- var equipRequest = SQueryRequest()
- equipRequest.filters = "id in "+"(\'" + java.lang.String.join("\',\'", equipIds) + "\')"
- val requestCascade = request.cascade
-
- val cascadeList = arrayListOf<SCascadeQuery>()
- if (requestCascade != null) {
- for(cascade in requestCascade){
- if("scanScheme".equals(cascade.name)){
- continue
- }
- cascadeList.add(cascade)
- }
- equipRequest.cascade = cascadeList;
- return admBaseService?.queryEquip(equipRequest)
- }
- return ArrayList<Equipment>()
- }
-
- fun categoryStatistics(projectId:String,id: String,equipId: String): ArrayList<CategoryStatistics>{
- val result = ArrayList<CategoryStatistics>()
-
- val dictTypeList = dmpBaseService?.queryDictType(JSONObject())
- val dictTypeMap = HashMap<String, String>()
- if (dictTypeList != null) {
- for(dictType in dictTypeList){
- dictType.code?.let { dictType.name?.let { it1 -> dictTypeMap.put(it, it1) } }
- }
- }
-
- val request = SQueryRequest()
- val withFilterList = ArrayList<SFilter>()
- withFilterList.add(SFilter.eq("projectId", projectId))
- withFilterList.add(SFilter.eq("taskParentId", id))
- withFilterList.add(SFilter.eq("parentId", equipId))
- val pageQuery = EquipScanTaskQueryService.pageQuery(request, withFilterList)
- val equipScanTask = pageQuery.content
- if (!pageQuery.content.isNullOrEmpty()&&pageQuery.content!!.size>0) {
- val equipScanTaskMap: Map<String?, List<EquipScanTaskQuery>> = equipScanTask?.stream()
- ?.collect(Collectors.groupingBy(EquipScanTaskQuery::classCode)) as Map<String?, List<EquipScanTaskQuery>>
- for ((key, value) in equipScanTaskMap.entries) {
- val categoryStatistics = CategoryStatistics()
- categoryStatistics.code = key
- categoryStatistics.name = dictTypeMap.get(key)
- categoryStatistics.count = value.size
- result.add(categoryStatistics)
- }
- }
- return result
- }
- }
|