BackgroundData.js 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376
  1. import axios from 'axios';
  2. import { config } from '../../config';
  3. export default class BackgroundData {
  4. /* 当前登录用户 */
  5. LoginUser;
  6. /* 标题栏数据 */
  7. TopPoint = [
  8. {
  9. pointName: "TotalPower",// 实时总功率
  10. pointTag: "JSFW.NX_GD_XXX_XX_XX_XXX_XXX_CI0135",
  11. value: 0
  12. }, {
  13. pointName: "DailyPowerGeneration",// 日发电量
  14. pointTag: "JSFW.NX_GD_XXX_XX_XX_XXX_XXX_CI0088",
  15. value: 0
  16. }, {
  17. pointName: "GridPower",// 上网电量
  18. pointTag: "JSFW.NX_GD_XXX_XX_XX_XXX_XXX_CI0136",
  19. value: 0
  20. }, {
  21. pointName: "MonthlyPowerGeneration",// 月发电量
  22. pointTag: "JSFW.NX_GD_XXX_XX_XX_XXX_XXX_CI0146",
  23. value: 0
  24. }, {
  25. pointName: "AnnualPowerGeneration",// 年发电量
  26. pointTag: "JSFW.NX_GD_XXX_XX_XX_XXX_XXX_CI0037",
  27. value: 0
  28. },
  29. ];
  30. /* 推荐区数据 */
  31. Recommends = {
  32. "DWK": {
  33. stationName: "大武口光伏电站",
  34. content: "通讯中断",
  35. createTime: this.formatDate(new Date("2021-04-15 8:17:59"), 'YY-MM-DD hh:mm'),
  36. isActive: true,
  37. },
  38. "NSSFCJSFW.NX_GD_NSSF_XX_XX_XXX_XXX_CI0263": {
  39. stationName: "牛首山风电场",
  40. content: "限电",
  41. createTime: new Date(),
  42. isActive: false,
  43. },
  44. "QSFCJSFW.NX_GD_QSF_XX_XX_XXX_XXX_CI0263": {
  45. stationName: "青山风电场",
  46. content: "限电",
  47. createTime: new Date(),
  48. isActive: false,
  49. },
  50. "SBQFCJSFW.NX_GD_SBQF_XX_XX_XXX_XXX_CI0263": {
  51. stationName: "石板泉一期",
  52. content: "限电",
  53. createTime: new Date(),
  54. isActive: false,
  55. },
  56. "MHSFCJSFW.NX_GD_MHSF_XX_XX_XXX_XXX_CI0263": {
  57. stationName: "麻黄山风电场",
  58. content: "限电",
  59. createTime: new Date(),
  60. isActive: false,
  61. },
  62. "XSFCJSFW.NX_GD_XSF_XX_XX_XXX_XXX_CI0263": {
  63. stationName: "香山风电场",
  64. content: "限电",
  65. createTime: new Date(),
  66. isActive: false,
  67. },
  68. "SLAGC.NX_GD_QSF_DQ_P1_L1_001_DI0165": {
  69. stationName: "青山三期",
  70. content: "限电",
  71. createTime: new Date(),
  72. isActive: false,
  73. },
  74. "SBQFCJSFW.NX_GD_SBQF_XX_XX_XXX_XXX_CI026X": {
  75. stationName: "石板泉二三四期",
  76. content: "限电",
  77. createTime: new Date(),
  78. isActive: false,
  79. },
  80. };
  81. /* 隐患数据 */
  82. HiddenProblems = new Array();
  83. /* 缺陷数据 */
  84. Defects = new Array();
  85. /* 故障数据 */
  86. Failure = new Array();
  87. /* 事故数据 */
  88. Accidents = new Array();
  89. /* 标记数据 */
  90. Marks = [];
  91. MarkIndex = 0;
  92. constructor() {
  93. this.refreshTPData = this.refreshTPData.bind(this);
  94. this.onTPMessage = this.onTPMessage.bind(this);
  95. this.refreshAlarmData = this.refreshAlarmData.bind(this);
  96. this.onHiddenProblemsMessage = this.onHiddenProblemsMessage.bind(this);
  97. this.formatDate = this.formatDate.bind(this);
  98. this.onDefectsMessage = this.onDefectsMessage.bind(this);
  99. this.onAccidentsMessage = this.onAccidentsMessage.bind(this);
  100. this.isContains = this.isContains.bind(this);
  101. this.refreshRecommendData = this.refreshRecommendData.bind(this);
  102. this.onRDMessage = this.onRDMessage.bind(this);
  103. this.windturbineControl = this.windturbineControl.bind(this);
  104. this.marking = this.marking.bind(this);
  105. this.removeMarked = this.removeMarked.bind(this);
  106. this.initWinturbineBaseData=this.initWinturbineBaseData.bind(this);
  107. this.refreshTPData();
  108. this.refreshAlarmData();
  109. this.refreshRecommendData();
  110. this.refreshTPTimer = setInterval(this.refreshTPData, 3000);// 标题栏数据
  111. this.refreshAlarmTimer = setInterval(this.refreshAlarmData, 10000);// 报警数据
  112. this.refreshRecommendTimer = setInterval(this.refreshRecommendData, 3000);// 推荐数据
  113. }
  114. /* 数据刷新 */
  115. refreshTPData() {
  116. // http://192.168.10.18:8011/ts
  117. var val = '';
  118. for (var v in this.TopPoint) {
  119. val += this.TopPoint[v].pointTag + ',';
  120. }
  121. axios.get(`http://${config.adapterUrl}/ts/latest?keys=${val}`)
  122. .then(this.onTPMessage)
  123. .catch(err =>
  124. console.log(err)
  125. );
  126. }
  127. /* 刷新推荐信息 */
  128. refreshRecommendData() {
  129. var val = '';
  130. for (var v in this.Recommends) {
  131. val += v + ',';
  132. }
  133. axios.get(`http://${config.adapterUrl}/ts/latest?keys=${val}`)
  134. .then(this.onRDMessage)
  135. .catch(err =>
  136. console.log(err)
  137. );
  138. }
  139. /* 刷新报警信息 */
  140. refreshAlarmData() {
  141. // http://192.168.10.18:8075/alarm
  142. // 1、读取一天内的所有open的4级custom报警,作为隐患数据ar
  143. var enddt = new Date();
  144. var tm = enddt.getTime();
  145. enddt = new Date(tm + 900000);
  146. var startdt = new Date(tm - 86400000);
  147. axios.get(`http://${config.shardingUrl}/alarm/snap/page?pagenum=1&pagesize=500&category1=custom&rank=4&isopened=1&starttime=${this.formatDate(startdt)}&endtime=${this.formatDate(enddt)}`)
  148. .then(this.onHiddenProblemsMessage)
  149. .catch(err =>
  150. console.log(err)
  151. );
  152. // 2、读取一天内所有的open的windturbine报警,以故障结尾的报警填充到故障,其他的填充到缺陷
  153. axios.get(`http://${config.shardingUrl}/alarm/snap/page?pagenum=1&pagesize=500&category1=windturbine&isopened=1&starttime=${this.formatDate(startdt)}&endtime=${this.formatDate(enddt)}`)
  154. .then(this.onDefectsMessage)
  155. .catch(err =>
  156. console.log(err)
  157. );
  158. // 3、读取一天内所有open的升压站(SYZ)报警,包含关键字“跳闸”,“开关”,“刀闸”,“断路器”字符的报警信息填充到事故列表
  159. axios.get(`http://${config.shardingUrl}/alarm/snap/page?pagenum=1&pagesize=500&category1=SYZ&isopened=1&starttime=${this.formatDate(startdt)}&endtime=${this.formatDate(enddt)}`)
  160. .then(this.onAccidentsMessage)
  161. .catch(err =>
  162. console.log(err)
  163. );
  164. }
  165. /* 获得故障数据 */
  166. onAccidentsMessage(msg) {
  167. if (!msg.data) return;
  168. this.Accidents = new Array();
  169. for (var v in msg.data.records) {
  170. var val = msg.data.records[v];
  171. if (this.isContains(val.alertText, ["跳闸", "开关", "刀闸", "断路器", "合位", "分位"])) {
  172. // todo 暂时隐藏事故报警
  173. //this.Accidents.push(val);
  174. } else {
  175. if (val.rank == "5") {
  176. this.Failure.push(val);
  177. } else {
  178. this.Defects.push(val);
  179. }
  180. }
  181. }
  182. }
  183. /* 获得缺陷数据 */
  184. onDefectsMessage(msg) {
  185. if (!msg.data) return;
  186. this.Defects = new Array();
  187. this.Failure = new Array();
  188. for (var v in msg.data.records) {
  189. var val = msg.data.records[v];
  190. if (val.alertText.indexOf("故障") > 0) {
  191. this.Failure.push(val);
  192. } else {
  193. this.Defects.push(val);
  194. }
  195. }
  196. }
  197. /* 获得隐患数据 */
  198. onHiddenProblemsMessage(msg) {
  199. if (!msg.data) return;
  200. this.HiddenProblems = msg.data.records;
  201. }
  202. /* 获得标题栏数据 */
  203. onTPMessage(msg) {
  204. if (!msg.data) return;
  205. for (var v in this.TopPoint) {
  206. var val = this.TopPoint[v];
  207. val.value = msg.data[val.pointTag].doubleValue;
  208. }
  209. }
  210. /* 获得推荐信息数据 */
  211. onRDMessage(msg) {
  212. if (!msg.data) return;
  213. for (var v in msg.data) {
  214. var isact = false;
  215. if (!msg.data[v].doubleValue) {
  216. isact = msg.data[v].booleanValue
  217. } else {
  218. isact = msg.data[v].doubleValue != 0;
  219. }
  220. if (isact && !this.Recommends[v].isActive) {
  221. this.Recommends[v].createTime = this.formatDate(new Date(), 'YY-MM-DD hh:mm');
  222. }
  223. this.Recommends[v].isActive = isact;
  224. }
  225. }
  226. /* 格式化时间 */
  227. formatDate(time, format = 'YY-MM-DD hh:mm:ss') {
  228. var date = new Date(time);
  229. var year = date.getFullYear(),
  230. month = date.getMonth() + 1,//月份是从0开始的
  231. day = date.getDate(),
  232. hour = date.getHours(),
  233. min = date.getMinutes(),
  234. sec = date.getSeconds();
  235. var preArr = Array.apply(null, Array(10)).map(function (elem, index) {
  236. return '0' + index;
  237. });
  238. var newTime = format.replace(/YY/g, year)
  239. .replace(/MM/g, preArr[month] || month)
  240. .replace(/DD/g, preArr[day] || day)
  241. .replace(/hh/g, preArr[hour] || hour)
  242. .replace(/mm/g, preArr[min] || min)
  243. .replace(/ss/g, preArr[sec] || sec);
  244. return newTime;
  245. }
  246. /* 判断一个字符串中是否包含第二个字符串列表中的字符 */
  247. isContains(str, strs) {
  248. for (var v in strs) {
  249. if (str.indexOf(strs[v]) > 0) {
  250. return true;
  251. }
  252. }
  253. return false;
  254. }
  255. /* 登录 */
  256. login(uname, psd, action) {
  257. axios.get(`http://${config.calcUrl}/api/user/login?userName=${uname}&psd=${psd}`)
  258. .then(action)
  259. .catch(err => action("登录出现错误:" + err.message));
  260. }
  261. /* 风机控制 */
  262. windturbineControl(windturbines, isLockOrUnlock,success,error) {
  263. var pairs = {};
  264. for (var ind in windturbines) {
  265. var wb = windturbines[ind];
  266. var ct = {
  267. windturbineId: wb.windturbineId,
  268. stationId: wb.stationId,
  269. projectId: wb.projectId,
  270. modelId: wb.modelId,
  271. controlType: wb.controlType,
  272. lockType: wb.lockType,
  273. userName: this.LoginUser.userName,
  274. userId: this.LoginUser.id,
  275. };
  276. pairs[ct.windturbineId] = ct;
  277. }
  278. axios.post(`http://${config.calcUrl}/api/control/send?isLockOrUnlock=${isLockOrUnlock}`, pairs)
  279. .then(msg => {
  280. success(msg);
  281. })
  282. .catch(err => {
  283. error(err);
  284. });
  285. console.log(isLockOrUnlock);
  286. }
  287. /* 系统控制风机,自动下发命令 */
  288. windturbineControlSystem(windturbines) {
  289. var pairs = {};
  290. for (var ind in windturbines) {
  291. var wb = windturbines[ind];
  292. var ct = {
  293. windturbineId: wb.windturbineId,
  294. stationId: wb.stationId,
  295. projectId: wb.projectId,
  296. modelId: wb.modelId,
  297. controlType: wb.controlType,
  298. lockType: wb.lockType,
  299. userName: 'system',
  300. userId: 0,
  301. };
  302. pairs[ct.windturbineId] = ct;
  303. }
  304. axios.post(`http://${config.calcUrl}/api/control/send?isLockOrUnlock=false`, pairs)
  305. .then(msg => {
  306. console.log(msg);
  307. })
  308. .catch(err => {
  309. this.showdialog("错误", "风机控制出现错误", err.message);
  310. console.log(err);
  311. });
  312. }
  313. /* 标记 */
  314. marking(windturbines) {
  315. for (var v in windturbines) {
  316. ++this.MarkIndex;
  317. this.Marks.push({ title: windturbines[v].windturbineId, id: this.MarkIndex });
  318. }
  319. }
  320. /* 移除标记 */
  321. removeMarked(mk) {
  322. var indx = -1;
  323. for (var id in this.Marks) {
  324. if (this.Marks[id].id == mk.id) {
  325. indx = id;
  326. break;
  327. }
  328. }
  329. if (indx < 0) return;
  330. this.Marks.splice(indx, 1);
  331. }
  332. /* 获取风机详情页面数据 */
  333. initWinturbineBaseData(info,action){
  334. axios.get(`http://${config.adapterUrl}/ts/latest?thingType=windturbine&thingId=${info.windturbineId}&uniformCodes=${info.codes}`)
  335. .then(msg=>{
  336. action(msg.data);
  337. })
  338. .catch(err=>{
  339. console.log(err);
  340. });
  341. }
  342. /* 单例 */
  343. static getInstance() {
  344. if (!BackgroundData.instance) {
  345. BackgroundData.instance = new BackgroundData();
  346. }
  347. return BackgroundData.instance;
  348. }
  349. }