riku
2025-09-11 307b17ef15c73a071912a262834f2a5f68e1fa87
src/utils/factor/data.js
@@ -159,33 +159,35 @@
/**
 * 获取历史数据
 */
function fetchHistoryData(params) {
  // if (import.meta.env.VITE_DATA_MODE == 'jingan') {
  //   const _params = {
  //     compUser: 'user1',
  //     compPassword: 'User1@jingan',
  //     mn: params.deviceCode,
  //     dtFrom: params.startTime
  //       ? params.startTime
  //       : moment().subtract(6, 'm').format('YYYY-MM-DD HH:mm:ss'),
  //     dtTo: params.endTime
  //       ? params.endTime
  //       : moment().format('YYYY-MM-DD HH:mm:ss')
  //   };
  //   return fetchThirdPartyData(_params);
  // } else {
  //   return fetchOriginHistoryData(params);
  // }
  return fetchOriginHistoryData(params);
function fetchHistoryData(params, origin = true) {
  if (origin) {
    return fetchOriginHistoryData(params);
  } else if (import.meta.env.VITE_DATA_MODE == 'jingan') {
    const _params = {
      compUser: 'user1',
      compPassword: 'User1@jingan',
      mn: params.deviceCode,
      dtFrom: params.startTime
        ? params.startTime
        : moment().subtract(6, 'm').format('YYYY-MM-DD HH:mm:ss'),
      dtTo: params.endTime
        ? params.endTime
        : moment().format('YYYY-MM-DD HH:mm:ss')
    };
    return fetchThirdPartyData(_params);
  } else {
    return fetchOriginHistoryData(params);
  }
}
var fetchingTask;
var isFetching;
var pause = false;
/**
 * 开启实时数据循环获取
 * @param {Object} params
 */
function startLoopFetchRealTimeData(onParam, callback) {
function startLoopFetchRealTimeData(onParam, callback, _interval) {
  // 时间间隔
  let interval;
  // 数据获取方法
@@ -198,10 +200,13 @@
    fetchFun = fetchOriginRealTimeData;
    interval = 10 * 1000;
  }
  if (_interval) {
    interval = _interval;
  }
  // 开始循环任务
  clearFetchingTask();
  fetchingTask = setInterval(() => {
    if (isFetching) {
    if (isFetching || pause) {
      return;
    }
    isFetching = true;
@@ -233,6 +238,11 @@
  }, interval);
}
function pauseTask() {
  pause = !pause;
  return pause;
}
/**
 * 清理历史实时数据获取任务
 */
@@ -244,4 +254,9 @@
  }
}
export { fetchHistoryData, startLoopFetchRealTimeData, clearFetchingTask };
export {
  fetchHistoryData,
  startLoopFetchRealTimeData,
  clearFetchingTask,
  pauseTask
};