|
@@ -1,77 +1,43 @@
|
|
|
-import { setallLampHttp } from '@/services/ant-design-pro/equipment';
|
|
|
-
|
|
|
-let endTime = null;
|
|
|
-let startTime = null;
|
|
|
+import { setallLampHttp, getStatusHttp } from '@/services/ant-design-pro/equipment';
|
|
|
+import { message } from 'antd';
|
|
|
|
|
|
// 定时调用 查询指令接口
|
|
|
-export const checkChangeLightStatusSuccess = (paramsArr) => {
|
|
|
- if (endTime - startTime >= 5000) {
|
|
|
- message.error('网络故障,请重试');
|
|
|
- } else {
|
|
|
- setallLampHttp(paramsArr).then((res) => {
|
|
|
- return judgeChangeResponeseSuccess(res);
|
|
|
- });
|
|
|
- }
|
|
|
+export const checkChangeLightStatusSuccess = (paramsArr, result, fn) => {
|
|
|
+ let checkParams = paramsArr;
|
|
|
+ checkParams.forEach((item) => {
|
|
|
+ item.orderSeqNum = result.orderSeqNum;
|
|
|
+ });
|
|
|
+ getStatusHttp(checkParams).then((res) => {
|
|
|
+ judgeChangeResponeseSuccess(res, paramsArr, fn);
|
|
|
+ });
|
|
|
};
|
|
|
|
|
|
// 检查开关指令下发状态
|
|
|
-export const judgeChangeResponeseSuccess = (response) => {
|
|
|
- return new Promise((resolve, reject) => {
|
|
|
- let result = response.content[0];
|
|
|
- if (result.result === 'success') {
|
|
|
- if (result.state === 200 && result.exeResult === 'success') {
|
|
|
- resolve({ status: 'success', data: result });
|
|
|
- } else if (result.state === 500) {
|
|
|
- reject();
|
|
|
- } else {
|
|
|
- checkChangeLightStatusSuccess();
|
|
|
- resolve({ status: 'processing', data: result });
|
|
|
- }
|
|
|
+export const judgeChangeResponeseSuccess = (response, paramsArr, fn) => {
|
|
|
+ let result = response.content[0];
|
|
|
+ if (result.result === 'success') {
|
|
|
+ if (result.state === 200 && result.exeResult === 'success') {
|
|
|
+ console.log('成功了');
|
|
|
+ fn(); // 查询灯设备
|
|
|
+ } else if (
|
|
|
+ (result.state === 200 && result.exeResult === 'processing:rcvd') ||
|
|
|
+ (result.state === 202 && !result.exeResult)
|
|
|
+ ) {
|
|
|
+ setTimeout(() => {
|
|
|
+ checkChangeLightStatusSuccess(paramsArr, result, fn);
|
|
|
+ }, 500);
|
|
|
+ }else if (result.state === 200 && result.exeResult === 'fail:timeout') {
|
|
|
+ message.error('网络超时,请重试');
|
|
|
} else {
|
|
|
- reject();
|
|
|
- console.log('judgeChangeResponeseSuccess-fail');
|
|
|
+ message.error('操作失败,请重试');
|
|
|
}
|
|
|
- });
|
|
|
+ } else {
|
|
|
+ message.error('操作失败,请重试');
|
|
|
+ }
|
|
|
};
|
|
|
// 开关
|
|
|
-export const setallLamps = (paramsArr,fn) => {
|
|
|
-// let paramsArr = [];
|
|
|
-// if (type == 'total') {
|
|
|
-// lampArr.forEach((item) => {
|
|
|
-// paramsArr.push({
|
|
|
-// id: item.id,
|
|
|
-// switch: val,
|
|
|
-// });
|
|
|
-// });
|
|
|
-// } else {
|
|
|
-// paramsArr.push({ id: id, switch: val });
|
|
|
-// }
|
|
|
- setallLampHttp(paramsArr)
|
|
|
- .then((res) => {
|
|
|
- startTime = Date.now(); // 开始计时'
|
|
|
- return judgeChangeResponeseSuccess(res);
|
|
|
- })
|
|
|
- .then(
|
|
|
- (res) => {
|
|
|
- switch (res.status) {
|
|
|
- case 'success':
|
|
|
- fn(); // 查询灯设备
|
|
|
- break;
|
|
|
- case 'processing':
|
|
|
- // 继续查询
|
|
|
- endTime = Date.now();
|
|
|
- setTimeout(() => {
|
|
|
- let checkParams = paramsArr;
|
|
|
- checkParams.forEach((item) => {
|
|
|
- item.orderSeqNum = res.data.orderSeqNum;
|
|
|
- });
|
|
|
- checkChangeLightStatusSuccess(paramsArr);
|
|
|
- }, 20);
|
|
|
- break;
|
|
|
- }
|
|
|
- },
|
|
|
- () => {
|
|
|
- message.error('操作失败,请重试');
|
|
|
- },
|
|
|
- );
|
|
|
+export const setallLamps = (paramsArr, fn) => {
|
|
|
+ setallLampHttp(paramsArr).then((res) => {
|
|
|
+ judgeChangeResponeseSuccess(res, paramsArr, fn);
|
|
|
+ });
|
|
|
};
|