RelationSyInFlController.java 8.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205
  1. package com.persagy.proxy.relation.controller;
  2. import cn.hutool.core.collection.CollUtil;
  3. import cn.hutool.core.util.StrUtil;
  4. import com.alibaba.excel.util.CollectionUtils;
  5. import com.fasterxml.jackson.databind.node.ArrayNode;
  6. import com.fasterxml.jackson.databind.node.JsonNodeFactory;
  7. import com.fasterxml.jackson.databind.node.ObjectNode;
  8. import com.persagy.dmp.basic.model.QueryCriteria;
  9. import com.persagy.dmp.digital.entity.ObjectRelation;
  10. import com.persagy.proxy.adm.constant.AdmRelationTypeEnum;
  11. import com.persagy.proxy.adm.request.AdmResponse;
  12. import com.persagy.proxy.adm.service.IAdmRelationService;
  13. import com.persagy.proxy.adm.utils.AdmContextUtil;
  14. import com.persagy.proxy.common.entity.InstanceUrlParam;
  15. import com.persagy.proxy.common.entity.RelationDTO;
  16. import com.persagy.proxy.relation.model.FlInSyList;
  17. import com.persagy.proxy.relation.model.SyInFl;
  18. import com.persagy.proxy.relation.model.SyInFlList;
  19. import lombok.extern.slf4j.Slf4j;
  20. import org.apache.commons.lang3.StringUtils;
  21. import org.springframework.beans.factory.annotation.Autowired;
  22. import org.springframework.web.bind.annotation.PostMapping;
  23. import org.springframework.web.bind.annotation.RequestBody;
  24. import org.springframework.web.bind.annotation.RequestMapping;
  25. import org.springframework.web.bind.annotation.RestController;
  26. import java.util.ArrayList;
  27. import java.util.List;
  28. import java.util.Map;
  29. /**
  30. * @author zhangwencheng
  31. * 系统所在楼层相关接口
  32. */
  33. @Slf4j
  34. @RestController
  35. @RequestMapping("/rel/sy-in-fl")
  36. public class RelationSyInFlController {
  37. @Autowired
  38. private IAdmRelationService service;
  39. /**
  40. * 创建系统所在楼层关系
  41. *
  42. * @param syInFl
  43. * @param
  44. * @return
  45. * @throws Exception
  46. */
  47. @PostMapping("/link")
  48. public AdmResponse create(@RequestBody SyInFl syInFl) throws Exception {
  49. //系统Id
  50. String sysID = syInFl.getSysId();
  51. //楼层Id
  52. String floorId = syInFl.getFloorId();
  53. //
  54. String type = syInFl.getType();
  55. if (StrUtil.isBlank(sysID) || StrUtil.isBlank(floorId)) {
  56. return AdmResponse.failure("必填项:SysId(系统id)、floorId(楼层id)");
  57. }
  58. List<RelationDTO> voList = new ArrayList<>();
  59. AdmRelationTypeEnum sy2fl = AdmRelationTypeEnum.SY2FL;
  60. String graphCode = sy2fl.getGraphCode();
  61. String relCode = sy2fl.getRelCode();
  62. RelationDTO relation = new RelationDTO(null, graphCode, relCode, type, sysID, floorId);
  63. voList.add(relation);
  64. // 组装上下文条件
  65. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  66. service.doSave(context, voList);
  67. return AdmResponse.success();
  68. }
  69. /**
  70. * 创建所在系统和楼层的关系 系统楼层一对多
  71. *
  72. * @param
  73. * @return
  74. * @throws Exception
  75. */
  76. @PostMapping("/link-fl")
  77. public AdmResponse createSy(@RequestBody SyInFlList syInFlList) throws Exception {
  78. log.info("创建系统所在楼层关系link-fl方法开始,参数projectId为{}", AdmContextUtil.toDmpContext().getProjectId());
  79. //系统Id
  80. String sysId = syInFlList.getSysId();
  81. //楼层Id
  82. List<String> floorIdList = syInFlList.getFloorIdList();
  83. if (StringUtils.isBlank(sysId) || CollectionUtils.isEmpty(floorIdList)) {
  84. //return AdmResponse.failure("必填项:sysId(系统id)、floorIdList(楼层Id)");
  85. //兼容adm历史逻辑,若楼层id为空时,返回success
  86. return AdmResponse.success();
  87. }
  88. List<RelationDTO> voList = new ArrayList<>();
  89. AdmRelationTypeEnum sy2fl = AdmRelationTypeEnum.SY2FL;
  90. String graphCode = sy2fl.getGraphCode();
  91. String relCode = sy2fl.getRelCode();
  92. for (String floorId : floorIdList) {
  93. RelationDTO relation = new RelationDTO(null, graphCode, relCode, null, sysId, floorId);
  94. voList.add(relation);
  95. }
  96. //查询 floor所属的建筑 增加关系
  97. QueryCriteria criteriaQuery = new QueryCriteria();
  98. ObjectNode criteria = JsonNodeFactory.instance.objectNode();
  99. criteria.put(ObjectRelation.REL_CODE_HUM, "Fl2Bd");
  100. criteria.put(ObjectRelation.GRAPH_CODE_HUM, "ArchSubset");
  101. ArrayNode arrayNode = criteria.putObject("objFrom").putArray("$in");
  102. floorIdList.stream().forEach(floorId -> arrayNode.add(floorId));
  103. criteriaQuery.setCriteria(criteria);
  104. List<ObjectRelation> relationList = service.queryByCondition(AdmContextUtil.toDmpContext(), criteriaQuery);
  105. if(CollUtil.isNotEmpty(relationList)){
  106. Map<String,ObjectRelation> objectRelationMap = CollUtil.fieldValueMap(relationList, "objTo");
  107. for (String buildingId : objectRelationMap.keySet()) {
  108. RelationDTO relation = new RelationDTO(null, graphCode, "Sy2Bd", null, sysId, buildingId);
  109. voList.add(relation);
  110. }
  111. }
  112. // 组装上下文条件
  113. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  114. service.doSave(context, voList);
  115. log.info("创建系统所在楼层关系link-fl方法结束");
  116. return AdmResponse.success();
  117. }
  118. /**
  119. * 所在楼层的系统,楼层一对多系统
  120. */
  121. @PostMapping("/link-sy")
  122. public AdmResponse createSy(@RequestBody FlInSyList flInSyList) {
  123. log.info("创建系统所在楼层关系link-sy方法开始,参数projectId为{}", AdmContextUtil.toDmpContext().getProjectId());
  124. String floorId = flInSyList.getFloorId();
  125. List<String> sysIdList = flInSyList.getSysIdList();
  126. if (StringUtils.isBlank(floorId) || CollectionUtils.isEmpty(sysIdList)) {
  127. return AdmResponse.failure("必填项:sysIdList(系统id不能为空)、floorId(楼层Id)");
  128. }
  129. AdmRelationTypeEnum sy2fl = AdmRelationTypeEnum.SY2FL;
  130. String graphCode = sy2fl.getGraphCode();
  131. String relCode = sy2fl.getRelCode();
  132. List<RelationDTO> voList = new ArrayList<>();
  133. for (String sysId : sysIdList) {
  134. RelationDTO relation = new RelationDTO(null, graphCode, relCode, null, sysId, floorId);
  135. voList.add(relation);
  136. }
  137. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  138. service.doSave(context, voList);
  139. log.info("创建系统所在楼层关系link-sy方法结束");
  140. return AdmResponse.success();
  141. }
  142. /**
  143. * 系统所在楼层,系统一对多楼层,此方法不会覆盖
  144. */
  145. @PostMapping("/link-fl-sy")
  146. public AdmResponse createSyFl(@RequestBody SyInFlList syInFlList) {
  147. log.info("创建系统所在楼层关系link-fl-sy方法开始,参数projectId为{}", AdmContextUtil.toDmpContext().getProjectId());
  148. List<String> floorIdList = syInFlList.getFloorIdList();
  149. String sysId = syInFlList.getSysId();
  150. if (StringUtils.isBlank(sysId) || CollectionUtils.isEmpty(floorIdList)) {
  151. return AdmResponse.failure("必填项:sysId(系统sysId不能为空)、floorIdList(楼层Id不能为空)");
  152. }
  153. AdmRelationTypeEnum sy2fl = AdmRelationTypeEnum.SY2FL;
  154. String graphCode = sy2fl.getGraphCode();
  155. String relCode = sy2fl.getRelCode();
  156. List<RelationDTO> voList = new ArrayList<>();
  157. for (String floorId : floorIdList) {
  158. RelationDTO relation = new RelationDTO(null, graphCode, relCode, null, sysId, floorId);
  159. voList.add(relation);
  160. }
  161. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  162. service.doSave(context, voList);
  163. log.info("创建系统所在楼层关系link-fl-sy方法结束");
  164. return AdmResponse.success();
  165. }
  166. /**
  167. * 根据对象删除
  168. *
  169. * @return
  170. */
  171. @PostMapping("/unlink")
  172. public AdmResponse delete(@RequestBody SyInFl syInFl) {
  173. String floorId = syInFl.getFloorId();
  174. String sysId = syInFl.getSysId();
  175. AdmRelationTypeEnum sy2fl = AdmRelationTypeEnum.SY2FL;
  176. String graphCode = sy2fl.getGraphCode();
  177. String relCode = sy2fl.getRelCode();
  178. String type = syInFl.getType();
  179. ObjectNode node = JsonNodeFactory.instance.objectNode();
  180. node.put("graphCode", graphCode);
  181. node.put("relCode", relCode);
  182. node.put("relValue",type);
  183. node.put("objFrom", sysId);
  184. node.put("objTo", floorId);
  185. QueryCriteria criteria = new QueryCriteria();
  186. criteria.setCriteria(node);
  187. // 组装上下文条件
  188. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  189. service.doDelete(context,criteria);
  190. return AdmResponse.success();
  191. }
  192. }