AdmSystemController.java 24 KB

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