CommonRequest.cs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340
  1. /* ==============================================================================
  2. * 功能描述:通用的请求
  3. * 创 建 者:Garrett
  4. * 创建日期:2018/5/17 10:41:38
  5. * ==============================================================================*/
  6. using System;
  7. using System.Collections.Generic;
  8. using System.Linq;
  9. using System.Text;
  10. using System.Text.RegularExpressions;
  11. using System.Threading.Tasks;
  12. using Newtonsoft.Json.Linq;
  13. using SAGA.DotNetUtils;
  14. using SAGA.DotNetUtils.Extend;
  15. using SAGA.DotNetUtils.Http;
  16. using SAGA.MBI.Common;
  17. using SAGA.MBI.DataArrange;
  18. using SAGA.MBI.Tools;
  19. namespace SAGA.MBI.RequestData
  20. {
  21. /// <summary>
  22. /// CommonRequest
  23. /// </summary>
  24. public class CommonRequest
  25. {
  26. /// <summary>
  27. /// 根据localId来查询物理世界的对象
  28. /// ly,可能查询不到部件
  29. /// </summary>
  30. /// <returns></returns>
  31. public static string QueryObjectByLocalId(string floorId, string localId)
  32. {
  33. JObject localIdJObject = new JObject();
  34. localIdJObject.Add("EquipLocalID", new JArray(localId));
  35. return QueryObjectByInfos(floorId, localIdJObject, new[] { "Eq" });
  36. }
  37. /// <summary>
  38. /// 根据物理世界BIMId信息点来查询各物理实体
  39. /// </summary>
  40. /// <returns></returns>
  41. public static string QueryObjectByBIMID(string floorId, string bimId, string[] type = null)
  42. {
  43. JObject bimIdJObject = new JObject();
  44. bimIdJObject.Add("BIMID", new JArray(bimId));
  45. return QueryObjectByInfos(floorId, bimIdJObject, type);
  46. }
  47. /// <summary>
  48. /// 根据信息点来查询各物理实体,使用in操作
  49. /// 优点:连接查询,速度快,大概20ms,
  50. /// 缺点是:首次查询速度慢,大概6000ms,更新信息点值后,再次查询也相当于首次查询,大概6000ms
  51. /// </summary>
  52. /// <returns></returns>
  53. public static string QueryObjectByInfos2(string floorId, JObject infoJObject, string[] type = null)
  54. {
  55. string url = MBIConst.DataPlatformLocalHost + $"data-platform-3/fast/object/in_query?secret={MBIControl.ProjectCur.Password}&projectId={MBIControl.ProjectCur.Id}";
  56. if (type == null)
  57. {
  58. type = new string[] { "Eq", "Ec", "Si", "VOBc" };
  59. }
  60. infoJObject.Add("type", new JArray(type));
  61. if (type.FirstOrDefault(t => Regex.IsMatch(t, "VO.*")) != null)
  62. {
  63. //信标加BuildingId查不出来
  64. }
  65. else if (type.FirstOrDefault(t => new[] { "Eq", "Ec" }.Contains(t)) != null)
  66. {
  67. //设备需要加buildingId
  68. string buildingId = DalProjectTree.GetBuildingIdByFloor(floorId);
  69. infoJObject.Add("id", buildingId);
  70. }
  71. else
  72. {
  73. infoJObject.Add("id", floorId);
  74. }
  75. JObject updateJObject = new JObject();
  76. updateJObject.Add("criteria", infoJObject);
  77. updateJObject.Add("customInfo", true);
  78. //查询厂商库相关的信息点
  79. updateJObject.Add("venderInfo", true);
  80. string postData = updateJObject.ToString();
  81. RestClient client = new RestClient(url, HttpVerb.POST, postData);
  82. string request = client.PostRequest();
  83. return request;
  84. }
  85. /// <summary>
  86. /// 根据信息点来查询各物理实体,速度慢,
  87. /// 优点缺点:稳定,每次查询都是2000ms;
  88. /// </summary>
  89. /// <returns></returns>
  90. public static string QueryObjectByInfos(string floorId, JObject infosJObject, string[] type = null)
  91. {
  92. if (infosJObject.Count == 0) return "";
  93. string url = MBIConst.DataPlatformLocalHost + $"data-platform-3/object/query_by_info?secret={MBIControl.ProjectCur.Password}&projectId={MBIControl.ProjectCur.Id}";
  94. string buildingId = DalProjectTree.GetBuildingIdByFloor(floorId);
  95. JObject criteriaJObject = new JObject();
  96. criteriaJObject.Add("infos", ConvertInfoJObjectToJArray(infosJObject));
  97. //求并集
  98. criteriaJObject.Add("set", false);
  99. if (type != null)
  100. criteriaJObject.Add("type", new JArray(type));
  101. //信标加BuildingId查不出来
  102. if (buildingId.IsNotNullEmpty())
  103. criteriaJObject.Add("id", buildingId);
  104. JObject queryJObject = new JObject();
  105. queryJObject.Add("criteria", criteriaJObject);
  106. queryJObject.Add("customInfo", true);
  107. //查询厂商库相关的信息点
  108. queryJObject.Add("venderInfo", true);
  109. string postData = queryJObject.ToString();
  110. RestClient client = new RestClient(url, HttpVerb.POST, postData);
  111. string request = client.PostRequest();
  112. return request;
  113. }
  114. /// <summary>
  115. /// 根据BIMID中的楼层,下载楼层数据
  116. /// </summary>
  117. /// <returns></returns>
  118. public static string DownLoadFloorDataByBIMFloorInfo(string floorId, JArray jArray, string[] type = null)
  119. {
  120. string url = MBIConst.DataPlatformLocalHost + $"data-platform-3/object/query_by_info?secret={MBIControl.ProjectCur.Password}&projectId={MBIControl.ProjectCur.Id}";
  121. JObject criteriaJObject = new JObject();
  122. criteriaJObject.Add("infos", jArray);
  123. //求并集
  124. criteriaJObject.Add("set", false);
  125. if (type != null)
  126. criteriaJObject.Add("type", new JArray(type));
  127. //信标加BuildingId查不出来
  128. //if (buildingId.IsNotNullEmpty())
  129. // criteriaJObject.Add("id", buildingId);
  130. JObject queryJObject = new JObject();
  131. queryJObject.Add("criteria", criteriaJObject);
  132. queryJObject.Add("customInfo", true);
  133. //查询厂商库相关的信息点
  134. queryJObject.Add("venderInfo", true);
  135. string postData = queryJObject.ToString();
  136. RestClient client = new RestClient(url, HttpVerb.POST, postData);
  137. string request = client.PostRequest();
  138. return request;
  139. }
  140. /// <summary>
  141. /// 根据BIMID中的楼层,下载楼层数据
  142. /// </summary>
  143. /// <returns></returns>
  144. public static string DownLoadFloorDataByBIMFloorInfo(string floorId, string[] type = null)
  145. {
  146. JObject bimObjValue = new JObject();
  147. bimObjValue.Add("$gte", $"{floorId}:");
  148. bimObjValue.Add("$lte", $"{floorId}:a");
  149. JObject bimObjItem = new JObject();
  150. bimObjItem.Add("BIMID", bimObjValue);
  151. JArray infoArray = new JArray(bimObjItem);
  152. return DownLoadFloorDataByBIMFloorInfo(floorId, infoArray, type);
  153. }
  154. /// <summary>
  155. /// 由于in操作,按信息点查询,传入参数不同
  156. /// 将JObject转化为JArray
  157. /// </summary>
  158. /// <param name="infoJObject"></param>
  159. /// <returns></returns>
  160. private static JArray ConvertInfoJObjectToJArray(JObject infoJObject)
  161. {
  162. JArray jArray = new JArray();
  163. var property = infoJObject.Properties().FirstOrDefault();
  164. if (property != null)
  165. {
  166. string key = property.Name;
  167. JArray valueArray = (JArray)infoJObject[key];
  168. if (valueArray != null)
  169. {
  170. foreach (JToken token in valueArray)
  171. {
  172. var valueObject = new JObject();
  173. valueObject.Add(key, (string)token);
  174. jArray.Add(valueObject);
  175. }
  176. }
  177. }
  178. return jArray;
  179. }
  180. /// <summary>
  181. /// 查询楼层下的设备/部件/信标
  182. /// </summary>
  183. /// <returns></returns>
  184. public static string FloorQuery_GoodHand(string floorId, string[] type)
  185. {
  186. if (floorId.IsNullOrEmpty() || type.IsNullOrEmptyExt()) return String.Empty;
  187. string url = MBIConst.GoodHandLocalHost + $"relation/location/floor/query?secret={MBIControl.ProjectCur.Password}&projectId={MBIControl.ProjectCur.Id}";
  188. JObject bimObjItem = new JObject();
  189. bimObjItem.Add("floor_id", floorId);
  190. bimObjItem.Add("type", new JArray(type));
  191. string postData = bimObjItem.ToString();
  192. RestClient client = new RestClient(url, HttpVerb.POST, postData);
  193. string request = client.PostRequest();
  194. return request;
  195. }
  196. /// <summary>
  197. /// 缓存设备和部件数据
  198. /// </summary>
  199. /// <param name="buildingId"></param>
  200. /// <returns></returns>
  201. public static string CacheEqEc(string buildingId)
  202. {
  203. return SubsetQuery(buildingId, new JArray() { "Eq", "Ec" });
  204. }
  205. /// <summary>
  206. /// 缓存所有的Revit数据
  207. /// </summary>
  208. /// <param name="buildingId"></param>
  209. /// <returns></returns>
  210. public static string CacheAllData(string buildingId)
  211. {
  212. return SubsetQuery(buildingId, new JArray() { "Eq", "Ec", "Si" });
  213. }
  214. /// <summary>
  215. /// 查询某个object下指定类型的objects (查询项目下的所有类型, 建筑下的设备, 系统, 楼层, 空间. 查询楼层中的空间, 非关系表查询)
  216. /// </summary>
  217. /// <param name="id">id只能是project id, building id , floor id 或者 equipment id. 不填id或者null, 则默认是project id</param>
  218. /// <param name="typeArray">值可以是设备类型:"TDLS", 系统类型: "TD"或者 "Eq", "Sy", "Fl", "Sp", "Bd", "Pj".</param>
  219. /// <param name="customInfo">选填, 默认为false, true则会把自定义信息点查询出来. false不会查询到自定义信息点</param>
  220. /// <returns></returns>
  221. public static string SubsetQuery(string id, JArray typeArray, bool customInfo = false)
  222. {
  223. string url = MBIConst.DataPlatformLocalHost + $"data-platform-3/object/subset_query?secret={MBIControl.ProjectCur.Password}&projectId={MBIControl.ProjectCur.Id}";
  224. JObject criteriaObject = new JObject();
  225. criteriaObject.Add("id", id);
  226. criteriaObject.Add("type", typeArray);
  227. JObject idJObject = new JObject();
  228. idJObject.Add("criteria", criteriaObject);
  229. // 选填, 默认为false, true则会把自定义信息点查询出来. false不会查询到自定义信息点
  230. idJObject.Add("customInfo", customInfo);
  231. // 选填, 查询岗位时候显示关联资产的信息点, true是显示, false是不显示, 默认true
  232. idJObject.Add("linkInfos", true);
  233. //查询厂商库相关的信息点
  234. idJObject.Add("venderInfo", true);
  235. string postData = idJObject.ToString();
  236. RestClient client = new RestClient(url, HttpVerb.POST, postData);
  237. string request = client.PostRequest();
  238. return request;
  239. }
  240. /// <summary>
  241. /// 获取项目下指定类型的电气设备
  242. /// </summary>
  243. /// <returns></returns>
  244. public static string GetDistribution(JArray array)
  245. {
  246. string request = SubsetQuery(MBIControl.ProjectCur.Id, array, true);
  247. return request;
  248. }
  249. /// <summary>
  250. /// 由id查询岗位信息
  251. /// </summary>
  252. /// <param name="id"></param>
  253. /// <returns></returns>
  254. public static string QueryObjectById(string id)
  255. {
  256. string url = MBIConst.DataPlatformLocalHost + $"data-platform-3/object/batch_query?secret={MBIControl.ProjectCur.Password}&projectId={MBIControl.ProjectCur.Id}";
  257. JObject criteriaObject = new JObject();
  258. criteriaObject.Add("id", id);
  259. JArray array = new JArray();
  260. array.Add(criteriaObject);
  261. JObject idJObject = new JObject();
  262. idJObject.Add("criterias", array);
  263. idJObject.Add("customInfo", true);
  264. //查询厂商库相关的信息点
  265. idJObject.Add("venderInfo", true);
  266. string postData = idJObject.ToString();
  267. RestClient client = new RestClient(url, HttpVerb.POST, postData);
  268. string request = client.PostRequest();
  269. return request;
  270. }
  271. /// <summary>
  272. /// 查询某个建筑/项目内没有绑定某种图类型/图实例, 关系类型的指定类型
  273. /// </summary>
  274. /// <returns></returns>
  275. public static string QueryOutsideObject(string id, string graphId, string graphType, string relType, int side, string[] type)
  276. {
  277. string url = MBIConst.DataPlatformLocalHost + $"data-platform-3/object/outside_query?secret={MBIControl.ProjectCur.Password}&projectId={MBIControl.ProjectCur.Id}";
  278. JObject criteriaObject = new JObject();
  279. criteriaObject.Add("id", id);
  280. if (graphId.IsNotNullEmpty())
  281. criteriaObject.Add("graphId", graphId);
  282. criteriaObject.Add("graphType", graphType);
  283. criteriaObject.Add("relType", relType);
  284. criteriaObject.Add("side", side);
  285. criteriaObject.Add("type", new JArray(type));
  286. JObject idJObject = new JObject();
  287. idJObject.Add("criteria", criteriaObject);
  288. // 选填, 默认为false, true则会把自定义信息点查询出来. false不会查询到自定义信息点
  289. idJObject.Add("customInfo", true);
  290. //查询厂商库相关的信息点
  291. idJObject.Add("venderInfo", true);
  292. string postData = idJObject.ToString();
  293. RestClient client = new RestClient(url, HttpVerb.POST, postData);
  294. string request = client.PostRequest();
  295. return request;
  296. }
  297. /// <summary>
  298. /// 批量更新
  299. /// </summary>
  300. /// <param name="criterias"></param>
  301. /// <returns></returns>
  302. public static string BatchUpdate(JArray criterias)
  303. {
  304. string url = MBIConst.DataPlatformLocalHost + $"data-platform-3/object/batch_update?secret={MBIControl.ProjectCur.Password}&projectId={MBIControl.ProjectCur.Id}";
  305. JObject updateJObject = new JObject();
  306. updateJObject.Add("criterias", criterias);
  307. string postData = updateJObject.ToString();
  308. RestClient client = new RestClient(url, HttpVerb.POST, postData);
  309. string request = client.PostRequest();
  310. return request;
  311. }
  312. }
  313. }