RelationTnInSpController.java 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146
  1. package com.persagy.proxy.adm.controller;
  2. import cn.hutool.core.util.StrUtil;
  3. import com.fasterxml.jackson.databind.node.JsonNodeFactory;
  4. import com.fasterxml.jackson.databind.node.ObjectNode;
  5. import com.persagy.dmp.basic.model.QueryCriteria;
  6. import com.persagy.proxy.adm.constant.AdmRelationTypeEnum;
  7. import com.persagy.proxy.adm.model.relation.TnInSpBase;
  8. import com.persagy.proxy.adm.model.relation.TnInSpBaseList;
  9. import com.persagy.proxy.adm.request.AdmCreateRequest;
  10. import com.persagy.proxy.adm.request.AdmResponse;
  11. import com.persagy.proxy.adm.service.IAdmRelationService;
  12. import com.persagy.proxy.adm.utils.AdmContextUtil;
  13. import com.persagy.proxy.common.entity.InstanceUrlParam;
  14. import com.persagy.proxy.common.entity.RelationDTO;
  15. import lombok.extern.slf4j.Slf4j;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.beans.factory.annotation.Value;
  18. import org.springframework.util.CollectionUtils;
  19. import org.springframework.web.bind.annotation.*;
  20. import java.util.ArrayList;
  21. import java.util.List;
  22. /**
  23. * 租户所租用的业务空间
  24. *
  25. * @author zhangwencheng
  26. */
  27. @Slf4j
  28. @RestController
  29. @RequestMapping("/rel/tn-in-sp-base")
  30. public class RelationTnInSpController {
  31. @Autowired
  32. private IAdmRelationService service;
  33. @Value("${middleware.group.code}")
  34. private String groupCode;
  35. /**
  36. * 创建租户所租用的业务空间关系
  37. *
  38. * @param tnInSpBase 租户和业务空间的关系对象
  39. * @return 创建的结果信息
  40. */
  41. @PostMapping("/link")
  42. public AdmResponse create( @RequestBody AdmCreateRequest<TnInSpBase> tnInSpBase) {
  43. List<TnInSpBase> content = tnInSpBase.getContent();
  44. if(CollectionUtils.isEmpty(content)){
  45. return AdmResponse.failure("content不能为空");
  46. }
  47. AdmRelationTypeEnum typeEnum = AdmRelationTypeEnum.TN2SP;
  48. String graphCode = typeEnum.getGraphCode();
  49. String relCode = typeEnum.getRelCode();
  50. List<RelationDTO> voList = new ArrayList<>();
  51. for (TnInSpBase inSpBase : content) {
  52. String spaceId = inSpBase.getSpaceId();
  53. String tenantId = inSpBase.getTenantId();
  54. String objectType = inSpBase.getObjectType();
  55. if(StrUtil.isEmpty(spaceId)||StrUtil.isBlank(tenantId)){
  56. return AdmResponse.failure("必填项:tenantId(租户Id)、spaceIdList(空间id)");
  57. }
  58. RelationDTO relation = new RelationDTO(null, graphCode, relCode, objectType, tenantId, spaceId);
  59. voList.add(relation);
  60. }
  61. service.doSave(AdmContextUtil.toDmpContext(), voList);
  62. return AdmResponse.success();
  63. }
  64. @PostMapping("/unlink")
  65. public AdmResponse delete(@RequestParam(value = "type",required = false) String type,
  66. @RequestBody List<TnInSpBase> tnInSpBases) {
  67. AdmRelationTypeEnum typeEnum = AdmRelationTypeEnum.TN2SP;
  68. String graphCode = typeEnum.getGraphCode();
  69. String relCode = typeEnum.getRelCode();
  70. if(CollectionUtils.isEmpty(tnInSpBases)){
  71. return AdmResponse.failure("tnInSpBases不能为空");
  72. }
  73. List<QueryCriteria> queryCriteriaList = new ArrayList<>();
  74. for (TnInSpBase tnInSpBase : tnInSpBases) {
  75. String tenantId = tnInSpBase.getTenantId();
  76. String spaceId = tnInSpBase.getSpaceId();
  77. if (StrUtil.isBlank(spaceId) || StrUtil.isEmpty(tenantId)) {
  78. return AdmResponse.failure("必填项:tenantId(租户Id)、spaceId(空间id)");
  79. }
  80. QueryCriteria criteria = new QueryCriteria();
  81. ObjectNode node = JsonNodeFactory.instance.objectNode();
  82. node.put("graphCode", graphCode);
  83. node.put("relCode", relCode);
  84. node.put("relValue", type);
  85. node.put("objFrom", tenantId);
  86. node.put("objTo", spaceId);
  87. criteria.setCriteria(node);
  88. queryCriteriaList.add(criteria);
  89. }
  90. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  91. for (QueryCriteria queryCriteria : queryCriteriaList) {
  92. //问题:如何调用一次接口,如何保证一起成功
  93. service.doDelete(context, queryCriteria);
  94. }
  95. return AdmResponse.success();
  96. }
  97. /**
  98. * 创建租户所租用的业务空间关系
  99. *
  100. * @param tnInSpBaseList 租户和业务空间的关系对象
  101. * @return 创建的结果信息
  102. */
  103. @PostMapping("/link-sp")
  104. public AdmResponse createSp(@RequestParam(value = "type",required = false) String type,
  105. @RequestBody TnInSpBaseList tnInSpBaseList) {
  106. List<String> spaceIdList = tnInSpBaseList.getSpaceIdList();
  107. String tenantId = tnInSpBaseList.getTenantId();
  108. if(CollectionUtils.isEmpty(spaceIdList)||StrUtil.isBlank(tenantId)){
  109. return AdmResponse.failure("必填项:tenantId(租户Id)、spaceIdList(空间id)");
  110. }
  111. InstanceUrlParam context = AdmContextUtil.toDmpContext();
  112. AdmRelationTypeEnum typeEnum = AdmRelationTypeEnum.TN2SP;
  113. String graphCode = typeEnum.getGraphCode();
  114. String relCode = typeEnum.getRelCode();
  115. deleteByTenantId(tenantId,typeEnum,context);
  116. List<RelationDTO> voList = new ArrayList<>();
  117. for (String spaceId : spaceIdList) {
  118. RelationDTO relation = new RelationDTO(null, graphCode, relCode, type, tenantId, spaceId);
  119. voList.add(relation);
  120. }
  121. service.doSave(context, voList);
  122. return AdmResponse.success();
  123. }
  124. //根据租户Id删除
  125. private void deleteByTenantId(String tenantId,AdmRelationTypeEnum typeEnum,InstanceUrlParam context) {
  126. QueryCriteria criteria = new QueryCriteria();
  127. ObjectNode node = JsonNodeFactory.instance.objectNode();
  128. node.put("graphCode", typeEnum.getGraphCode());
  129. node.put("relCode", typeEnum.getRelCode());
  130. // node.put("relValue", type);
  131. node.put("objFrom", tenantId);
  132. // node.put("objTo", spaceId);
  133. criteria.setCriteria(node);
  134. service.doDelete(context, criteria);
  135. }
  136. }