AdmSystemController.java 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570
  1. package com.persagy.proxy.adm.controller;
  2. import cn.hutool.core.collection.CollUtil;
  3. import cn.hutool.core.util.StrUtil;
  4. import cn.hutool.json.JSONUtil;
  5. import com.alibaba.fastjson.JSONObject;
  6. import com.fasterxml.jackson.databind.node.ArrayNode;
  7. import com.fasterxml.jackson.databind.node.JsonNodeFactory;
  8. import com.fasterxml.jackson.databind.node.ObjectNode;
  9. import com.persagy.dmp.basic.dto.RequestData;
  10. import com.persagy.dmp.basic.model.QueryCriteria;
  11. import com.persagy.dmp.common.model.entity.BaseEntity;
  12. import com.persagy.dmp.define.client.DigitalDefineFacade;
  13. import com.persagy.dmp.define.entity.ObjectTypeDefine;
  14. import com.persagy.dmp.digital.client.DigitalObjectFacade;
  15. import com.persagy.dmp.digital.client.DigitalRelationFacade;
  16. import com.persagy.dmp.digital.entity.ObjectRelation;
  17. import com.persagy.dmp.simple.client.DigitalObjectSimpleFacade;
  18. import com.persagy.proxy.adm.model.*;
  19. import com.persagy.proxy.adm.request.AdmCreateRequest;
  20. import com.persagy.proxy.adm.request.AdmQueryCriteria;
  21. import com.persagy.proxy.adm.request.AdmResponse;
  22. import com.persagy.proxy.adm.service.*;
  23. import com.persagy.proxy.adm.utils.AdmContextUtil;
  24. import com.persagy.proxy.adm.utils.AdmQueryCriteriaHelper;
  25. import com.persagy.proxy.adm.utils.ObjectNameUtil;
  26. import com.persagy.proxy.common.entity.DmpResult;
  27. import com.persagy.proxy.common.entity.RelationDTO;
  28. import org.springframework.beans.factory.annotation.Autowired;
  29. import org.springframework.web.bind.annotation.*;
  30. import javax.json.JsonObject;
  31. import javax.validation.constraints.NotNull;
  32. import javax.ws.rs.QueryParam;
  33. import java.util.ArrayList;
  34. import java.util.Arrays;
  35. import java.util.List;
  36. import java.util.Map;
  37. /**
  38. * Adm 系统 API
  39. * @author lvxy
  40. * @date 2021/8/16
  41. */
  42. @RestController
  43. @RequestMapping("/object/general-system")
  44. public class AdmSystemController {
  45. @Autowired
  46. private IAdmSystemService service;
  47. @Autowired
  48. private IAdmBuildingService buildingService;
  49. @Autowired
  50. private IAdmFloorService floorService;
  51. @Autowired
  52. private IAdmDictService dictService;
  53. @Autowired
  54. private IAdmRelationService relationService;
  55. /**
  56. * 统计
  57. * @param request
  58. * @return
  59. * @throws Exception
  60. */
  61. @PostMapping("/count")
  62. public AdmResponse count(@RequestBody AdmQueryCriteria request) throws Exception {
  63. request.setName(AdmSystem.OBJ_TYPE);
  64. request.setOnlyCount(true);
  65. return service.doQuery(AdmContextUtil.toDmpContext(), request, AdmSystem.class);
  66. }
  67. /**
  68. * 创建
  69. * @param createRequest
  70. * @return
  71. * @throws Exception
  72. */
  73. @PostMapping("/create")
  74. public AdmResponse create(@RequestBody AdmCreateRequest<AdmSystem> createRequest, @QueryParam("projectId") String projectId) throws Exception {
  75. List<AdmSystem> vos = CollUtil.newArrayList(createRequest.getContent());
  76. vos = service.doInsert(AdmContextUtil.toDmpContext(), AdmSystem.class, vos);
  77. return AdmResponse.success(vos);
  78. }
  79. /**
  80. * 创建系统信息-处理建筑楼层
  81. * @param createRequest
  82. * @return
  83. * @throws Exception
  84. */
  85. @PostMapping("/create-bd-fl")
  86. public AdmResponse createBdFl(@RequestBody AdmCreateRequest<AdmSystem> createRequest) throws Exception {
  87. List<AdmSystem> vos = CollUtil.newArrayList(createRequest.getContent());
  88. Map<String, AdmSystem> admSystemMap = CollUtil.fieldValueMap(vos, "classCode");
  89. QueryCriteria defineCriteria = new QueryCriteria();
  90. ObjectNode criteria = JsonNodeFactory.instance.objectNode();
  91. ArrayNode array = criteria.putObject("code").putArray("$in");
  92. admSystemMap.keySet().stream().forEach(classCode -> array.add(classCode));
  93. defineCriteria.setCriteria(criteria);
  94. List<ObjectTypeDefine> defineList = DigitalDefineFacade.queryObjectType(AdmContextUtil.toDmpContext().getGroupCode(),AdmContextUtil.toDmpContext().getProjectId(),AdmContextUtil.toDmpContext().getAppId(),null,defineCriteria);
  95. Map<String, ObjectTypeDefine> defineMap = CollUtil.fieldValueMap(defineList, "code");
  96. vos.stream().forEach(admSystem -> {
  97. if(StrUtil.isEmpty(admSystem.getName())){
  98. if(CollUtil.isNotEmpty(defineList) && defineMap.containsKey(admSystem.getClassCode())){
  99. admSystem.setName(ObjectNameUtil.objectName(defineMap.get(admSystem.getClassCode()).getName()+"系统-"));
  100. }else {
  101. admSystem.setName(ObjectNameUtil.objectName("系统-"));
  102. }
  103. }
  104. });
  105. List<AdmSystem> unRelationSys = new ArrayList<>();
  106. List<AdmSystem> admSystemList = new ArrayList<>(vos.size());
  107. vos.stream().forEach(admSystem -> {
  108. if(CollUtil.isNotEmpty(admSystem.getBuildingFloorInfoList())){
  109. List<AdmSystem> admSystems = service.doInsert(AdmContextUtil.toDmpContext(), AdmSystem.class, CollUtil.newArrayList(admSystem));
  110. //添加关系
  111. String systemId = admSystems.get(0).getId();
  112. List<RelationDTO> relationDTOS = new ArrayList<>(admSystem.getBuildingFloorInfoList().size());
  113. admSystem.getBuildingFloorInfoList().forEach(info -> {
  114. String floorId = info.get("FloorID").textValue();
  115. String buildID = info.get("BuildID").textValue();
  116. if(StrUtil.isNotEmpty(floorId)){
  117. relationDTOS.add(new RelationDTO(null, "MechInArch", "Bd2Fl", null, systemId , floorId));
  118. }
  119. if(StrUtil.isNotEmpty(buildID)){
  120. relationDTOS.add(new RelationDTO(null, "MechForArch", "Sy2Bd", null, systemId , buildID));
  121. }
  122. });
  123. if(CollUtil.isNotEmpty(relationDTOS)){
  124. relationService.doSave(AdmContextUtil.toDmpContext(), relationDTOS);
  125. }
  126. admSystemList.addAll(admSystems);
  127. }else{
  128. unRelationSys.add(admSystem);
  129. }
  130. });
  131. if(CollUtil.isNotEmpty(unRelationSys)){
  132. List<AdmSystem> systemList = service.doInsert(AdmContextUtil.toDmpContext(), AdmSystem.class, unRelationSys);
  133. admSystemList.addAll(systemList);
  134. }
  135. return AdmResponse.success(admSystemList);
  136. }
  137. /**
  138. * 根据ID删除
  139. * @param vos
  140. * @return
  141. * @throws Exception
  142. */
  143. @PostMapping("/delete")
  144. public AdmResponse delete( @RequestBody List<AdmSystem> vos) throws Exception {
  145. service.doDelete(AdmContextUtil.toDmpContext(), vos);
  146. return AdmResponse.success();
  147. }
  148. /**
  149. * 更新
  150. * @param createRequest
  151. * @return
  152. * @throws Exception
  153. */
  154. @PostMapping("/update")
  155. public AdmResponse update(@RequestBody AdmCreateRequest<AdmSystem> createRequest, @QueryParam("projectId") String projectId) throws Exception {
  156. List<AdmSystem> vos = CollUtil.newArrayList(createRequest.getContent());
  157. vos = service.doUpdate(AdmContextUtil.toDmpContext(), AdmSystem.class, vos);
  158. return AdmResponse.success(vos);
  159. }
  160. /**
  161. * 系统绑定的动态信息点或静态信息点
  162. * type: static(静态),iot (动态)
  163. * @param request
  164. * @return
  165. * @throws Exception
  166. */
  167. @GetMapping("/export")
  168. public AdmResponse exportInfos(
  169. @RequestBody AdmQueryCriteria request) throws Exception {
  170. request.setName(AdmSystem.OBJ_TYPE);
  171. return service.doQuery(AdmContextUtil.toDmpContext(), request, AdmSystem.class);
  172. }
  173. /**
  174. * 创建系统下的设备关系
  175. * @param createRequest
  176. * @return
  177. * @throws Exception
  178. */
  179. @PostMapping("/link-equip")
  180. public AdmResponse createRelateEquip(@RequestBody JsonObject createRequest, @QueryParam("projectId") String projectId) throws Exception {
  181. String sysId = createRequest.get("sysId").toString();
  182. List<String> equipIdList = (List<String>)createRequest.get("equipIdList");
  183. List<ObjectNode> relations = new ArrayList<>(equipIdList.size());
  184. equipIdList.stream().forEach(euipId -> {
  185. ObjectNode objectNode = JsonNodeFactory.instance.objectNode();
  186. objectNode.put("relCode", "Sy2Eq");
  187. objectNode.put("graphCode","MechSubset");
  188. objectNode.put("objFrom", sysId);
  189. objectNode.put("objTo", euipId);
  190. });
  191. List<ObjectRelation> list = DigitalRelationFacade.create(AdmContextUtil.toDmpContext().getGroupCode(),AdmContextUtil.toDmpContext().getProjectId(), AdmContextUtil.toDmpContext().getAppId(), null, relations);
  192. return AdmResponse.success(list);
  193. }
  194. /**
  195. * 查询
  196. * @param request
  197. * @return
  198. * @throws Exception
  199. */
  200. @PostMapping("/query")
  201. public AdmResponse query(@RequestBody AdmQueryCriteria request) throws Exception {
  202. request.setName(AdmSystem.OBJ_TYPE);
  203. AdmResponse admResponse = service.doQuery(AdmContextUtil.toDmpContext(), request, AdmSystem.class);
  204. List<AdmSystem> systemList = (List<AdmSystem>) admResponse.getContent();
  205. if(CollUtil.isNotEmpty(systemList)){
  206. AdmDict admDict = new AdmDict();
  207. admDict.setType(AdmSystem.OBJ_TYPE);
  208. AdmResponse admResponseDic = dictService.queryCategory(AdmContextUtil.toDmpContext(), admDict, AdmObjectType.class);
  209. if(CollUtil.isNotEmpty(admResponseDic.getContent())){
  210. List<AdmObjectType> admDictList = (List<AdmObjectType>) admResponseDic.getContent();
  211. Map<String, AdmObjectType> admDictMap = CollUtil.fieldValueMap(admDictList, "code");
  212. systemList.stream().forEach(admSystem -> {
  213. if(admDictMap.keySet().contains(admSystem.getClassCode())){
  214. AdmObjectType admDictTemp = admDictMap.get(admSystem.getClassCode());
  215. admSystem.setCategoryName(admDictTemp.getName());
  216. }
  217. });
  218. admResponse.setContent(systemList);
  219. }
  220. }
  221. return admResponse;
  222. }
  223. /**
  224. * 查询系统信息-系统建筑楼层一对多
  225. * MajorName 专业名称 ,级联查询 系统分类名(categoryNames),系统下的设备(equipmentList),系统下的竖井(shaftList),业务空间(zoneSpaceBaseTableList)
  226. *
  227. * 明确建筑楼层的 adm级联 查询获取建筑楼层信息 使用正常接口 先查询楼层 再根据楼层信息拼接建筑
  228. * 未明确建筑/未明确楼层 中台定制接口
  229. *
  230. * 这个参见中心代码,
  231. * @param buildingId buildingId=1,未明确建筑
  232. * @param floorId floorId=1,未明确楼层
  233. * @param request
  234. * @return
  235. * @throws Exception
  236. */
  237. @PostMapping("/query-new")
  238. public AdmResponse queryNew(@QueryParam("buildingId") String buildingId,
  239. @QueryParam("floorId") String floorId, @RequestBody AdmQueryCriteria request) throws Exception {
  240. request.setName(AdmSystem.OBJ_TYPE);
  241. AdmResponse syses = new AdmResponse();
  242. List<AdmSystem> admSystemList = new ArrayList<>();
  243. if(StrUtil.isAllEmpty(buildingId,floorId)){
  244. //case one 查询全部系统,级联建筑,建筑级联楼层
  245. AdmQueryCriteria admQueryCriteriaBd = new AdmQueryCriteria();
  246. admQueryCriteriaBd.setName("buildingList");
  247. AdmQueryCriteria admQueryCriteriaFl = new AdmQueryCriteria();
  248. admQueryCriteriaFl.setName("floorList");
  249. List<AdmQueryCriteria> cascade = new ArrayList<>(1);
  250. cascade.add(admQueryCriteriaBd);
  251. cascade.add(admQueryCriteriaFl);
  252. request.setCascade(cascade);
  253. syses = service.doQuery(AdmContextUtil.toDmpContext(),request,AdmSystem.class);
  254. //处理数据 BuildingFloorInfo
  255. if(CollUtil.isNotEmpty(syses.getContent())){
  256. admSystemList = (List<AdmSystem>) syses.getContent();
  257. admSystemList.stream().forEach(admSystem -> {
  258. List<ObjectNode> buildingFloorInfoList = new ArrayList<>();
  259. List<AdmBuilding> buildingList = admSystem.getBuildingList();
  260. if(CollUtil.isNotEmpty(buildingList)){
  261. buildingList.stream().forEach(admBuilding -> {
  262. ObjectNode info = JsonNodeFactory.instance.objectNode();
  263. info.put("BuildID",admBuilding.getId());
  264. info.put("BuildName",admBuilding.getLocalName());
  265. List<AdmFloor> admFloorList = admSystem.getFloorList();
  266. if(CollUtil.isNotEmpty(admFloorList)){
  267. Map<String, AdmFloor> admFloorMap = CollUtil.fieldValueMap(admFloorList, "buildingId");
  268. if(admFloorMap.containsKey(admBuilding.getId())){
  269. info.put("FloorID",admFloorMap.get(admBuilding.getId()).getId());
  270. info.put("FloorName",admFloorMap.get(admBuilding.getId()).getLocalName());
  271. }
  272. }
  273. buildingFloorInfoList.add(info);
  274. });
  275. admSystem.setBuildingFloorInfoList(buildingFloorInfoList);
  276. admSystem.setBuildingList(null);
  277. admSystem.setFloorList(null);
  278. } else{
  279. admSystem.setBuildingFloorInfoList(buildingFloorInfoList);
  280. }
  281. });
  282. syses.setContent(CollUtil.isEmpty(admSystemList) ? new ArrayList<>(1) : admSystemList);
  283. }
  284. }else{
  285. QueryCriteria rwdQueryCriteria = AdmQueryCriteriaHelper.toDmpCriteria(request);
  286. ObjectNode criteria = rwdQueryCriteria.getCriteria();
  287. if(JSONUtil.isNull(criteria)){
  288. return AdmResponse.failure("请求参数错误");
  289. }
  290. if (StrUtil.isAllNotEmpty(buildingId, floorId)) {
  291. if(!"1".equals(floorId)){
  292. //case two 明确建筑、明确楼层的 系统
  293. JSONObject relationFrom = new JSONObject();
  294. relationFrom.put("relCode", "Sy2Fl");
  295. relationFrom.put("graphCode", "MechInArch");
  296. relationFrom.put("objTo", floorId);
  297. criteria.putPOJO("relationFrom",relationFrom);
  298. rwdQueryCriteria.setCriteria(criteria);
  299. syses = service.doQuery(AdmContextUtil.toDmpContext(), rwdQueryCriteria, AdmSystem.class);
  300. if (CollUtil.isNotEmpty(syses.getContent())) {
  301. admSystemList = (List<AdmSystem>) syses.getContent();
  302. }
  303. }else if("1".equals(floorId)){
  304. //case three 明确建筑 不明确楼层
  305. admSystemList = queryNotSureObj(buildingId, rwdQueryCriteria);
  306. //处理通用返回结果
  307. dealRespose(syses, request);
  308. }
  309. if(CollUtil.isNotEmpty(admSystemList)){
  310. //处理数据 BuildingFloorInfo
  311. admSystemList = dealBdFlInfo(floorId,buildingId,admSystemList);
  312. syses.setContent(admSystemList);
  313. }
  314. }else{
  315. //处理通用返回结果
  316. dealRespose(syses, request);
  317. if(StrUtil.isNotEmpty(buildingId) && buildingId.equals("1")){
  318. //case four 未明确建筑
  319. admSystemList = queryNotSureObj(null, rwdQueryCriteria);
  320. if(CollUtil.isNotEmpty(admSystemList)){
  321. //处理数据 BuildingFloorInfo
  322. admSystemList = dealBdFlInfo(null,null, admSystemList);
  323. }
  324. }
  325. }
  326. if(CollUtil.isNotEmpty(admSystemList))
  327. syses.setTotal(admSystemList.size()*1l);
  328. }
  329. if(CollUtil.isNotEmpty(admSystemList)){
  330. syses.setContent(admSystemList);
  331. }else{
  332. syses.setContent(new ArrayList<>(1));
  333. }
  334. return syses;
  335. }
  336. private void dealRespose(AdmResponse syses, AdmQueryCriteria request){
  337. syses.setPageSize(request.getPageSize());
  338. syses.setPageNumber(request.getPageNumber());
  339. syses.setResult(DmpResult.SUCCESS);
  340. syses.setTotal(0L);
  341. }
  342. /**
  343. * 查询不确定建筑/楼层的系统
  344. * @param buildingId
  345. * @param rwdQueryCriteria
  346. * @return
  347. */
  348. private List<AdmSystem> queryNotSureObj(String buildingId, QueryCriteria rwdQueryCriteria){
  349. RequestData requestData = new RequestData();
  350. String classCode = rwdQueryCriteria.getCriteria().get("classCode").textValue();
  351. if(StrUtil.isNotEmpty(classCode)){
  352. requestData.setClassCode(classCode);
  353. }
  354. if(StrUtil.isNotEmpty(buildingId)){
  355. requestData.setBuildingId(buildingId);
  356. }
  357. requestData.setObjType(AdmSystem.OBJ_TYPE);
  358. requestData.setPage(rwdQueryCriteria.getPage());
  359. requestData.setSize(rwdQueryCriteria.getSize());
  360. List result = DigitalObjectSimpleFacade.queryNotSureSystem(AdmContextUtil.toDmpContext().getGroupCode(), AdmContextUtil.toDmpContext().getProjectId(), AdmContextUtil.toDmpContext().getAppId(),null, requestData);
  361. if(CollUtil.isNotEmpty(result)){
  362. List<AdmSystem> admSystemList = JSONUtil.toList(result.toString(), AdmSystem.class);
  363. return admSystemList;
  364. }else{
  365. return null;
  366. }
  367. }
  368. /**
  369. * 处理建筑楼层信息 建筑确定,楼层可为空
  370. * @param floorId
  371. * @param buildingId
  372. * @param admSystemList
  373. * @return
  374. */
  375. private List<AdmSystem> dealBdFlInfo(String floorId, String buildingId, List<AdmSystem> admSystemList){
  376. if(CollUtil.isEmpty(admSystemList)){
  377. return null;
  378. }
  379. if(StrUtil.isEmpty(buildingId)){//处理成adm目标格式
  380. List<ObjectNode> nullList = new ArrayList<>(0);
  381. admSystemList.stream().forEach(admSystem -> {
  382. admSystem.setBuildingFloorInfoList(nullList);
  383. });
  384. return admSystemList;
  385. }
  386. AdmResponse buildings = null;
  387. if(StrUtil.isNotEmpty(buildingId)){
  388. AdmQueryCriteria admQueryCriteria = getAdmQueryCriteria(AdmBuilding.OBJ_TYPE, buildingId);
  389. buildings = buildingService.doQuery(AdmContextUtil.toDmpContext(), admQueryCriteria, AdmBuilding.class);
  390. }
  391. AdmResponse floors = null;
  392. if(StrUtil.isNotEmpty(floorId)){
  393. AdmQueryCriteria admQueryCriteria = getAdmQueryCriteria(AdmFloor.OBJ_TYPE, floorId);
  394. floors = floorService.doQuery(AdmContextUtil.toDmpContext(), admQueryCriteria, AdmFloor.class);
  395. }
  396. ObjectNode buildingFloorInfo = JsonNodeFactory.instance.objectNode();
  397. if (CollUtil.isNotEmpty(buildings.getContent())) {
  398. AdmBuilding admBuilding = (AdmBuilding) buildings.getContent().get(0);
  399. buildingFloorInfo.put("BuildID",admBuilding.getId());
  400. buildingFloorInfo.put("BuildName",admBuilding.getLocalName());
  401. }
  402. if (null!=floors && CollUtil.isNotEmpty(floors.getContent())) {
  403. AdmFloor floor = (AdmFloor) floors.getContent().get(0);
  404. buildingFloorInfo.put("FloorID",floor.getId());
  405. buildingFloorInfo.put("FloorName",floor.getLocalName());
  406. }
  407. admSystemList.stream().forEach(admSystem -> {
  408. admSystem.setBuildingFloorInfoList(Arrays.asList(buildingFloorInfo));
  409. });
  410. return admSystemList;
  411. }
  412. private AdmQueryCriteria getAdmQueryCriteria(String objType, String Id){
  413. AdmQueryCriteria admQueryCriteria = new AdmQueryCriteria();
  414. admQueryCriteria.setName(objType);
  415. admQueryCriteria.setFilters("id = " + Id);
  416. return admQueryCriteria;
  417. }
  418. /**
  419. * 查询系统信息-试图级联建筑楼层 暂未使用
  420. * @param request
  421. * @return
  422. * @throws Exception
  423. */
  424. @PostMapping("/query-bdfl")
  425. public AdmResponse queryUnBdFl(@RequestBody AdmQueryCriteria request) throws Exception {
  426. request.setName(AdmSystem.OBJ_TYPE);
  427. return service.doQuery(AdmContextUtil.toDmpContext(), request, AdmSystem.class);
  428. }
  429. /**
  430. * 查询没有和当前系统关联的设备
  431. * id 为系统id
  432. * @param request
  433. * @return
  434. * @throws Exception
  435. */
  436. @PostMapping("/un-sys-equip")
  437. public AdmResponse queryUnEquip( @NotNull @QueryParam("sysId") String sysId,
  438. @RequestBody AdmQueryCriteria request) throws Exception {
  439. AdmResponse admResponse = queryObjectByType(sysId,request,"Sy2Eq","MechSubset", AdmEquipment.OBJ_TYPE);
  440. return admResponse;
  441. }
  442. /**
  443. * 查询没有和当前系统关联的竖井
  444. * id 为系统id
  445. * @param request
  446. * @return
  447. * @throws Exception
  448. */
  449. @PostMapping("/un-sys-shaft")
  450. public AdmResponse queryUnSh( @NotNull @QueryParam("sysId") String sysId,
  451. @RequestBody AdmQueryCriteria request) throws Exception {
  452. AdmResponse admResponse = queryObjectByType(sysId,request,"Sy2Sh",null, AdmShaft.OBJ_TYPE);
  453. return admResponse;
  454. }
  455. /**
  456. * 查询没有和当前系统关联的业务空间
  457. * id 为系统id
  458. * @param request
  459. * @return
  460. * @throws Exception
  461. */
  462. @PostMapping("/un-sys-zoneSpaceBaseTable")
  463. public AdmResponse queryUnZoneSp(@NotNull @QueryParam("sysId") String sysId,
  464. @RequestBody AdmQueryCriteria request) throws Exception {
  465. AdmResponse admResponse = queryObjectByType(sysId,request,"Sy2Sp",null, AdmSpace.OBJ_TYPE);
  466. return admResponse;
  467. }
  468. /**
  469. * 查询没有和当前空间绑定的系统
  470. * 例如:prijectId=Pj4201050001,type=AirConditioningZone spaceId=Sp4201050001df2091cdf719443b80bb737aeabf0525 spaceId 为当前空间id type为当前空间类型
  471. * @param request
  472. * @return
  473. * @throws Exception
  474. */
  475. @PostMapping("/unspace-sys")
  476. public AdmResponse queryUnSpSy( @QueryParam("type") String type, @QueryParam("spaceId") String spaceId,
  477. @RequestBody AdmQueryCriteria request) throws Exception {
  478. if(StrUtil.isNotEmpty(spaceId)){
  479. AdmResponse admResponse = queryObjectByType(spaceId, request,"Sy2Sp",null, AdmSystem.OBJ_TYPE);
  480. return admResponse;
  481. }else{
  482. if(StrUtil.isNotEmpty(type)){
  483. QueryCriteria queryCriteriaObj = AdmQueryCriteriaHelper.toDmpCriteria(request);
  484. ObjectNode criteriaObj = JsonNodeFactory.instance.objectNode();
  485. criteriaObj.put("objType", AdmSpace.OBJ_TYPE);
  486. queryCriteriaObj.setCriteria(criteriaObj);
  487. List<ObjectNode> objs = DigitalObjectFacade.query(AdmContextUtil.toDmpContext().getGroupCode(),AdmContextUtil.toDmpContext().getProjectId(), AdmContextUtil.toDmpContext().getAppId(), null, queryCriteriaObj);
  488. QueryCriteria queryCriteriaObjSys = AdmQueryCriteriaHelper.toDmpCriteria(request);
  489. ObjectNode criteriaSys = JsonNodeFactory.instance.objectNode();
  490. criteriaObj.put("objType", AdmSystem.OBJ_TYPE);
  491. if(CollUtil.isNotEmpty(objs)){
  492. ArrayNode arrayNode = criteriaObj.putObject("id").putArray("$notcontains");
  493. for(ObjectNode objectNode: objs){
  494. arrayNode.add(objectNode.get("id").toString());
  495. }
  496. }
  497. queryCriteriaObj.setCriteria(criteriaObj);
  498. List<ObjectNode> syses = DigitalObjectFacade.query(AdmContextUtil.toDmpContext().getGroupCode(),AdmContextUtil.toDmpContext().getProjectId(), AdmContextUtil.toDmpContext().getAppId(), null, queryCriteriaObjSys);
  499. return AdmResponse.success(syses);
  500. }
  501. return AdmResponse.success();
  502. }
  503. }
  504. private AdmResponse queryObjectByType(String sysId, AdmQueryCriteria request, String relCode, String graphCode, String objType){
  505. QueryCriteria queryCriteria = new QueryCriteria();
  506. ObjectNode criteria = JsonNodeFactory.instance.objectNode();
  507. criteria.put("objFrom", sysId);
  508. criteria.put("relCode", relCode);
  509. if(StrUtil.isNotEmpty(graphCode)){
  510. criteria.put("graphCode", graphCode);
  511. }
  512. queryCriteria.setCriteria(criteria);
  513. queryCriteria.setSize(request.getPageSize()*1L);
  514. queryCriteria.setPage(request.getPageNumber()*1L);
  515. List<ObjectRelation> relations = DigitalRelationFacade.query(AdmContextUtil.toDmpContext().getGroupCode(),AdmContextUtil.toDmpContext().getProjectId(), AdmContextUtil.toDmpContext().getAppId(), null, queryCriteria);
  516. QueryCriteria queryCriteriaObj = AdmQueryCriteriaHelper.toDmpCriteria(request);
  517. ObjectNode criteriaObj = JsonNodeFactory.instance.objectNode();
  518. criteriaObj.put("objType", objType);
  519. if(CollUtil.isNotEmpty(relations)){
  520. Map<String, ObjectRelation> objectRelationMap = CollUtil.fieldValueMap(relations,BaseEntity.PROP_ID);
  521. ArrayNode arrayNode = criteriaObj.putObject("id").putArray("$notcontains");
  522. objectRelationMap.keySet().stream().forEach(id -> arrayNode.add(id));
  523. }
  524. queryCriteriaObj.setCriteria(criteriaObj);
  525. List<ObjectNode> obj = DigitalObjectFacade.query(AdmContextUtil.toDmpContext().getGroupCode(),AdmContextUtil.toDmpContext().getProjectId(), AdmContextUtil.toDmpContext().getAppId(), null, queryCriteriaObj);
  526. return AdmResponse.success(obj);
  527. }
  528. }