AdmSystemController.java 27 KB

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