RelationSpInBdOrFlController.java 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137
  1. package com.persagy.proxy.adm.controller;
  2. import cn.hutool.core.util.StrUtil;
  3. import com.alibaba.fastjson.JSONArray;
  4. import com.alibaba.fastjson.JSONObject;
  5. import com.fasterxml.jackson.databind.node.JsonNodeFactory;
  6. import com.fasterxml.jackson.databind.node.ObjectNode;
  7. import com.persagy.dmp.basic.model.QueryCriteria;
  8. import com.persagy.proxy.adm.request.AdmResponse;
  9. import com.persagy.proxy.adm.service.IAdmRelationService;
  10. import com.persagy.proxy.adm.utils.AdmContextUtil;
  11. import com.persagy.proxy.common.client.DmpRwdClient;
  12. import com.persagy.proxy.common.entity.InstanceUrlParam;
  13. import com.persagy.proxy.common.entity.RelationDTO;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.beans.factory.annotation.Value;
  16. import org.springframework.web.bind.annotation.PostMapping;
  17. import org.springframework.web.bind.annotation.RequestBody;
  18. import org.springframework.web.bind.annotation.RequestMapping;
  19. import org.springframework.web.bind.annotation.RestController;
  20. import java.util.ArrayList;
  21. import java.util.List;
  22. /**
  23. * @description:025、关系-业务空间所在的建筑楼层
  24. * @author:lgy
  25. * @data:2021/9/24 19:46
  26. */
  27. @RestController
  28. @RequestMapping("/rel/sp-in")
  29. public class RelationSpInBdOrFlController {
  30. @Autowired
  31. private IAdmRelationService service;
  32. @Autowired
  33. DmpRwdClient rwdClient;
  34. @Value("${middleware.group.code}")
  35. private String groupCode;
  36. /**
  37. * 默认图类型
  38. */
  39. public static String DEFAULT_GRAPH_CODE = "ArchSubset";
  40. /**
  41. * 默认边类型
  42. */
  43. public static String DEFAULT_REL_CODE = "Bd2Sp";
  44. /**
  45. * 创建业务空间和建筑的关系
  46. * @param param
  47. * @return
  48. * @throws Exception
  49. */
  50. @PostMapping(value = {"/bd-create"})
  51. public AdmResponse spInBdCreate(@RequestBody JSONObject param) throws Exception {
  52. String buildingId = param.getString("buildingId");
  53. String spaceId = param.getString("spaceId");
  54. String type = param.getString("objectType");
  55. if(!StrUtil.isAllNotEmpty(buildingId,spaceId,type)) {
  56. return AdmResponse.failure("必填项:buildingId(竖井id)、spaceId(业务空间id),objectType");
  57. }
  58. // 创建关系对象
  59. List<RelationDTO> voList = new ArrayList<>();
  60. voList.add(new RelationDTO(null, DEFAULT_GRAPH_CODE, DEFAULT_REL_CODE, type, buildingId , spaceId));
  61. service.doSave(AdmContextUtil.toDmpContext(), voList);
  62. return AdmResponse.success();
  63. }
  64. /**
  65. * 删除业务空间和建筑的关系
  66. * @param paramList 对象
  67. * @return 删除的结果信息
  68. */
  69. @PostMapping("/bd-del")
  70. public AdmResponse delete(@RequestBody JSONArray paramList) throws Exception {
  71. // 组装上下文条件
  72. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  73. for (int i = 0; i < paramList.size(); i++) {
  74. JSONObject param = paramList.getJSONObject(i);
  75. String buildingId = param.getString("buildingId");
  76. String spaceId = param.getString("spaceId");
  77. String type = param.getString("objectType");
  78. if(!StrUtil.isAllNotEmpty(buildingId,spaceId)) {
  79. return AdmResponse.failure("spaceId和buildingId 不可以为空");
  80. }
  81. ObjectNode node = JsonNodeFactory.instance.objectNode();
  82. node.put("graphCode", DEFAULT_GRAPH_CODE);
  83. node.put("relCode", DEFAULT_REL_CODE);
  84. node.put("objFrom", buildingId);
  85. node.put("objTo",spaceId);
  86. QueryCriteria criteria = new QueryCriteria();
  87. criteria.setCriteria(node);
  88. service.doDelete(context, criteria);
  89. }
  90. return AdmResponse.success();
  91. }
  92. /**
  93. * 修改业务空间所在的建筑
  94. * @param requestParam 对象
  95. * @return 删除的结果信息
  96. */
  97. @PostMapping("/bd-update")
  98. public AdmResponse delete(@RequestBody JSONObject requestParam) throws Exception {
  99. JSONArray content = requestParam.getJSONArray("content");
  100. for (int i = 0; i < content.size(); i++) {
  101. JSONObject param = content.getJSONObject(i);
  102. String buildingId = param.getString("buildingId");
  103. String spaceId = param.getString("spaceId");
  104. String type = param.getString("objectType");
  105. if(!StrUtil.isAllNotEmpty(buildingId,spaceId,type)) {
  106. return AdmResponse.failure("buildingId、spaceId、objectType 不能为空");
  107. }
  108. }
  109. // 组装上下文条件
  110. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  111. for (int i = 0; i < content.size(); i++) {
  112. JSONObject param = content.getJSONObject(i);
  113. String buildingId = param.getString("buildingId");
  114. String spaceId = param.getString("spaceId");
  115. String type = param.getString("objectType");
  116. ObjectNode node = JsonNodeFactory.instance.objectNode();
  117. node.put("graphCode", DEFAULT_GRAPH_CODE);
  118. node.put("relCode", DEFAULT_REL_CODE);
  119. node.put("objFrom", buildingId);
  120. node.put("objTo",spaceId);
  121. QueryCriteria criteria = new QueryCriteria();
  122. criteria.setCriteria(node);
  123. service.doDelete(context, criteria);
  124. // 创建关系对象
  125. List<RelationDTO> voList = new ArrayList<>();
  126. voList.add(new RelationDTO(null, DEFAULT_GRAPH_CODE, DEFAULT_REL_CODE, type, buildingId , spaceId));
  127. service.doSave(context, voList);
  128. }
  129. return AdmResponse.success();
  130. }
  131. }