DmpBaseService.kt 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. package com.persagy.server.services
  2. import cn.hutool.core.collection.CollUtil
  3. import com.alibaba.fastjson.JSONObject
  4. import com.persagy.dmp.basic.utils.JsonNodeUtils
  5. import com.persagy.dmp.digital.entity.ObjectDigital
  6. import com.persagy.server.Opts
  7. import com.persagy.server.client.DmpDicClient
  8. import com.persagy.server.datacenter.models.entities.dict.EquipCategory
  9. import com.persagy.server.datacenter.models.entities.task.EquipCategoryDic
  10. import com.persagy.server.entities.request.InstanceUrlParam
  11. import com.persagy.server.util.AdmEntityTransferUtil
  12. import com.persagy.service.utils.SSpringContextUtil
  13. import org.springframework.stereotype.Service
  14. /**
  15. * 物理世界对象查询
  16. * @author:linhuili
  17. * @date:2021/10/19
  18. */
  19. @Service
  20. class DmpBaseService {
  21. /** 自定义 sql */
  22. private val rwdClient by lazy {
  23. SSpringContextUtil.getBean(DmpDicClient::class.java) as DmpDicClient
  24. }
  25. /**
  26. * 查询字典类型
  27. * @param params
  28. * @return
  29. */
  30. fun queryDictType(params: JSONObject?): List<EquipCategoryDic>? {
  31. //封装基础查询参数
  32. val instanceUrlParam = InstanceUrlParam()
  33. instanceUrlParam.groupCode = Opts.groupCode
  34. instanceUrlParam.projectId = Opts.projectId
  35. //查询对象信息
  36. val dmpResult = rwdClient!!.queryDictObjectType(instanceUrlParam, params) ?: return ArrayList()
  37. if(CollUtil.isEmpty(dmpResult.data)){
  38. return ArrayList<EquipCategoryDic>()
  39. }
  40. return AdmEntityTransferUtil.toAdmMultiEntity(dmpResult.data, null, EquipCategoryDic::class.java)
  41. }
  42. /**
  43. * 查询设备类型
  44. */
  45. fun getEquipCategory(classCode:String): List<EquipCategory>? {
  46. //查询中台类型数据,2021.10.25日中心中台整合调整
  47. val param = JSONObject()
  48. val criteria = JSONObject()
  49. criteria["code"] = classCode!!
  50. param["criteria"] = criteria
  51. val dictTypes = queryDictType(param)
  52. return AdmEntityTransferUtil.toAdmMultiEntity(dictTypes, null, EquipCategory::class.java)
  53. }
  54. }