29 Commits

Author SHA1 Message Date
9d23303919 Merge remote-tracking branch 'origin/qr_branch' into qr_branch 2025-11-26 08:57:28 +08:00
83cdc4ba30 签出调整 2025-11-26 08:56:58 +08:00
caozehui
29efbae717 源未知异常处理 2025-11-06 08:42:04 +08:00
caozehui
a5177860de 微调 2025-09-03 14:23:05 +08:00
caozehui
66019e0d3c 闪变添加4000变动频度 2025-08-04 10:02:22 +08:00
caozehui
0ca992134f 微调 2025-08-01 09:44:00 +08:00
caozehui
128b02c145 微调 2025-08-01 08:46:44 +08:00
caozehui
bbc08679b9 微调 2025-08-01 08:42:26 +08:00
caozehui
bf8b8c9f0f NPQS-581表单默认加密、密钥和识别码为万能的 2025-07-31 14:16:27 +08:00
caozehui
00893d2d1f 微调 2025-07-31 09:40:12 +08:00
327801d040 出厂检测报告改造 2025-07-24 16:30:19 +08:00
caozehui
9e8e44b886 二楼检测项为空问题 2025-07-18 14:33:12 +08:00
sjl
d2f0382bd9 新增场景切换 2025-07-01 14:58:11 +08:00
sjl
9fecf0ce3f 用户管理去除时间查询 2025-07-01 10:47:59 +08:00
sjl
290586d0ff 全局误差小数位4-6位 2025-06-30 10:06:19 +08:00
sjl
ddc45af223 优化计划弹框 2025-06-27 10:57:57 +08:00
sjl
0e6f123306 新增计划初始化 2025-06-27 10:53:56 +08:00
sjl
7b93363b23 通用配置误差保留小数位 2025-06-27 09:01:06 +08:00
caozehui
2fd0dcb8a3 微调 2025-06-27 08:40:27 +08:00
caozehui
86ee05f8af 微调 2025-06-26 14:01:04 +08:00
caozehui
38814b9f44 手动检测根据检测内容不同动态决定是否进行初始化操作 2025-06-26 13:17:11 +08:00
caozehui
fb5d13671d Merge remote-tracking branch 'origin/master' 2025-06-25 09:22:14 +08:00
caozehui
310a769092 微调 2025-06-25 09:21:58 +08:00
sjl
8c63edabdc 楼下场景不用报告模版 2025-06-24 11:03:55 +08:00
caozehui
5363625a2f 微调 2025-06-24 09:22:36 +08:00
efcd6e1cfe 临时提交(自动检测步骤) 2025-06-23 13:19:38 +08:00
acc4d0ca67 被检设备表格增加IP字段 2025-06-20 14:58:28 +08:00
772f38feca 代码提交 2025-06-20 12:11:57 +08:00
sjl
1eb141e559 新增检测计划默认显示,为空判断 2025-06-11 16:01:23 +08:00
21 changed files with 990 additions and 367 deletions

View File

@@ -43,4 +43,9 @@ export const getPqReportAllVersion = (params:any) => {
//被检设备归档
export const documentedPqDev = (ids: string[]) => {
return http.post(`/report/documented`, ids)
}
//上传报告到云端
export const uploadReportToCloud = (deviceIds: string[]) => {
return http.post(`/report/uploadReportToCloud`, deviceIds)
}

View File

@@ -1,3 +1,4 @@
import http from '@/api'
import {type Base} from '@/api/system/base/interface'
@@ -12,6 +13,10 @@ export const updateTestConfig = (params: Base.ResTestConfig) => {
return http.post(`/sysTestConfig/update`, params)
}
//场景切换
export const updateScene = (params: any) => {
return http.post(`/sysTestConfig/update`,params)
}

View File

@@ -9,6 +9,7 @@ export namespace Base {
autoGenerate:number;//检测报告是否自动生成0 否1是
maxTime:number;//最大复检次数默认3次
state: number; //状态
scale:number;//小数位
createBy?: string| null; //创建用户
createTime?: string| null; //创建时间
updateBy?: string| null; //更新用户

View File

@@ -27,6 +27,7 @@ export default {
changeMode:"Change Mode",
versionRegister:"Version Register",
changeTheme: "Change Theme",
changeScene: "Change Scene",
logout: "Logout"
}
};

View File

@@ -27,6 +27,7 @@ export default {
changeMode:"模式切换",
versionRegister:"版本注册",
changeTheme:"主题切换",
changeScene: "场景切换",
logout: "退出登录"
}
};

View File

@@ -33,6 +33,27 @@
<el-dropdown-item @click="openDialog('versionRegisterRef')">
<el-icon><SetUp /></el-icon>{{ t("header.versionRegister") }}
</el-dropdown-item>
<el-dropdown trigger="hover" placement="left-start" v-if="userStore.userInfo.loginName == 'root'">
<div class="custom-dropdown-trigger">
<el-icon><Tools /></el-icon>
<span>{{ t("header.changeScene") }}</span>
</div>
<template #dropdown>
<el-dropdown-menu>
<el-dropdown-item
v-for="item in dictStore.getDictData('app_scene')"
:key="item.value"
:class="{
'custom-dropdown-item': true,
active: item.value === appSceneStore.currentScene
}"
@click="changeScene(item.value?? '')"
>
{{ item.name }}
</el-dropdown-item>
</el-dropdown-menu>
</template>
</el-dropdown>
</el-dropdown-menu>
</template>
</el-dropdown>
@@ -62,7 +83,7 @@ import PasswordDialog from "./PasswordDialog.vue";
import ThemeDialog from "./ThemeDialog.vue";
import VersionDialog from "@/views/system/versionRegister/index.vue";
import { computed } from "vue";
import { Avatar, Delete, Document, Sunny, Switch } from "@element-plus/icons-vue";
import { ArrowLeft, Avatar, Delete, Document, Sunny, Switch ,Tools} from "@element-plus/icons-vue";
import AssemblySize from "./components/AssemblySize.vue";
import Language from "./components/Language.vue";
import SearchMenu from "./components/SearchMenu.vue";
@@ -75,12 +96,16 @@ import { useModeStore,useAppSceneStore } from "@/stores/modules/mode";
const userStore = useUserStore();
const dictStore = useDictStore();
const username = computed(() => userStore.userInfo.name);
const router = useRouter();
const authStore = useAuthStore();
const modeStore = useModeStore();
const AppSceneStore = useAppSceneStore();
import { useTheme } from "@/hooks/useTheme";
import { useI18n } from "vue-i18n";
import {updateScene} from '@/api/system/base/index'
const { changePrimary} = useTheme();
// 初始化 i18n
@@ -126,7 +151,14 @@ const openDialog = (ref: string) => {
};
const appSceneStore = useAppSceneStore();
const changeScene = async (value: string) => {
appSceneStore.setCurrentMode(value);
await updateScene({scene :dictStore.getDictData('app_scene').find(item => item.value == value)?.id});
// 强制刷新页面
window.location.reload();
};
//模式切换
@@ -168,4 +200,18 @@ const changeMode = () => {
// height: 100%;
}
}
.custom-dropdown-trigger {
padding: 8px 15px;
cursor: pointer;
display: flex;
align-items: center;
gap: 8px;
}
:deep(.el-dropdown-menu__item.custom-dropdown-item.active),
:deep(.el-dropdown-menu__item.custom-dropdown-item.active:hover) {
background-color: var(--el-color-primary-light-9) !important;
color: var(--el-color-primary)
}
</style>

View File

@@ -30,7 +30,7 @@ export interface UserState {
accessToken: string;
refreshToken: string;
isRefreshToken: boolean;
userInfo: { id: string, name: string };
userInfo: { id: string, name: string,loginName:string };
}
/* tabsMenuProps */

View File

@@ -10,7 +10,7 @@ export const useUserStore = defineStore({
refreshToken: "",
isRefreshToken:false,
exp: Number(0),
userInfo: {id:"", name: "admin" },
userInfo: {id:"", name: "" ,loginName:""},
}),
getters: {},
actions: {

View File

@@ -1,185 +1,697 @@
import {ElMessage} from "element-plus";
/**
* WebSocket客户端服务
* 提供WebSocket连接管理、心跳机制、消息处理等功能
* 集成JWT token解析支持自动获取用户登录名
*
* @author hongawen
* @version 2.0
*/
import { ElMessage } from "element-plus";
import { jwtUtil } from "./jwtUtil";
// ============================================================================
// 类型定义 (Types & Interfaces)
// ============================================================================
/**
* WebSocket消息接口定义对应后端WebSocketVO结构
*/
interface WebSocketMessage<T = any> {
type: string; // 消息类型
requestId?: string; // 请求ID
operateCode?: string; // 操作代码
code?: number; // 状态码
desc?: string; // 描述信息
data?: T; // 泛型数据
}
/**
* 回调函数类型定义
*/
type CallbackFunction<T = any> = (message: WebSocketMessage<T>) => void;
/**
* WebSocket配置接口
*/
interface SocketConfig {
url: string; // WebSocket服务器地址
heartbeatInterval?: number; // 心跳间隔时间(ms)
reconnectDelay?: number; // 重连延迟时间(ms)
maxReconnectAttempts?: number; // 最大重连次数
timeout?: number; // 超时时间(ms)
}
/**
* 连接状态枚举
*/
enum ConnectionStatus {
DISCONNECTED = 'disconnected', // 未连接
CONNECTING = 'connecting', // 连接中
CONNECTED = 'connected', // 已连接
RECONNECTING = 'reconnecting', // 重连中
ERROR = 'error' // 连接错误
}
/**
* 常用的WebSocket消息类型定义命名空间
*/
namespace WebSocketMessageTypes {
/**
* 预检测相关消息
*/
export interface PreTestMessage {
deviceId?: string;
status?: string;
progress?: number;
errorInfo?: string;
}
/**
* 系数校准相关消息
*/
export interface CoefficientMessage {
deviceId: string;
channel: number;
voltage?: string;
current?: string;
calibrationResult?: boolean;
}
/**
* 正式检测相关消息
*/
export interface TestMessage {
deviceId: string;
testType: string;
testResult?: 'success' | 'failed' | 'processing';
testData?: any;
}
/**
* 通用响应消息
*/
export interface CommonResponse {
success: boolean;
message?: string;
timestamp?: number;
}
}
// ============================================================================
// 导出类型
// ============================================================================
export type {
WebSocketMessage,
CallbackFunction,
SocketConfig,
WebSocketMessageTypes
};
export {
ConnectionStatus
};
// ============================================================================
// 主要服务类
// ============================================================================
/**
* WebSocket服务类
* 单例模式实现提供完整的WebSocket连接管理功能
*/
export default class SocketService {
static instance = null;
static get Instance() {
// ========================================================================
// 静态属性和方法 (Static)
// ========================================================================
/**
* 单例实例
*/
private static instance: SocketService | null = null;
/**
* 获取单例实例
* @returns SocketService实例
*/
static get Instance(): SocketService {
if (!this.instance) {
this.instance = new SocketService();
}
return this.instance;
}
// 和服务端连接的socket对象
ws = null;
// 存储回调函数
callBackMapping = {};
// 标识是否连接成功
connected = false;
// 记录重试的次数
sendRetryCount = 0;
// 重新连接尝试的次数
connectRetryCount = 0;
work:any;
workerBlobUrl:any;
lastActivityTime= 0; // 上次活动时间戳
lastResponseHeartTime = Date.now();//最后一次收到心跳回复时间
reconnectDelay= 5000; // 重新连接延迟,单位毫秒
// ========================================================================
// 实例属性 (Properties)
// ========================================================================
// 定义连接服务器的方法
connect() {
/**
* WebSocket连接实例
*/
private ws: WebSocket | null = null;
// 连接服务器
/**
* 消息回调函数映射表
*/
private callBackMapping: Record<string, CallbackFunction<any>> = {};
/**
* 当前连接状态
*/
private connectionStatus: ConnectionStatus = ConnectionStatus.DISCONNECTED;
/**
* 发送消息重试计数器
*/
private sendRetryCount: number = 0;
/**
* 连接重试计数器
*/
private connectRetryCount: number = 0;
/**
* 心跳Worker实例
*/
private heartbeatWorker: Worker | null = null;
/**
* Worker脚本的Blob URL
*/
private workerBlobUrl: string | null = null;
/**
* 最后一次收到心跳响应的时间戳
*/
private lastResponseHeartTime: number = Date.now();
/**
* WebSocket连接配置
*/
private config: SocketConfig = {
url: 'ws://127.0.0.1:7777/hello',
// url: 'ws://192.168.1.124:7777/hello',
heartbeatInterval: 9000, // 9秒心跳间隔
reconnectDelay: 5000, // 5秒重连延迟
maxReconnectAttempts: 5, // 最多重连5次
timeout: 30000 // 30秒超时
};
// ========================================================================
// 构造函数 (Constructor)
// ========================================================================
/**
* 私有构造函数,防止外部直接实例化
*/
private constructor() {
this.initializeProperties();
}
/**
* 初始化属性
*/
private initializeProperties(): void {
this.lastResponseHeartTime = Date.now();
}
// ========================================================================
// Getter属性 (Computed)
// ========================================================================
/**
* 获取连接状态
* @returns 是否已连接
*/
get connected(): boolean {
return this.connectionStatus === ConnectionStatus.CONNECTED;
}
// ========================================================================
// 公共方法 (Public Methods)
// ========================================================================
/**
* 配置WebSocket连接参数
* @param config 部分配置对象
*/
public configure(config: Partial<SocketConfig>): void {
this.config = { ...this.config, ...config };
}
/**
* 连接WebSocket服务器同步方式保持向后兼容
*/
public connect(): Promise<void> | void {
// 检查浏览器支持
if (!window.WebSocket) {
return console.log('您的浏览器不支持WebSocket');
// console.log('您的浏览器不支持WebSocket');
return;
}
// let token = $.cookie('123');
// let token = '4E6EF539AAF119D82AC4C2BC84FBA21F';
// 防止重复连接
if (this.connectionStatus === ConnectionStatus.CONNECTING || this.connected) {
// console.warn('WebSocket已连接或正在连接中');
return;
}
this.connectionStatus = ConnectionStatus.CONNECTING;
try {
this.ws = new WebSocket(this.buildWebSocketUrl());
this.setupEventHandlersLegacy();
} catch (error) {
this.connectionStatus = ConnectionStatus.ERROR;
//console.error('WebSocket连接失败:', error);
}
}
/**
* 异步连接WebSocket服务器
* @returns Promise<void>
*/
public connectAsync(): Promise<void> {
return new Promise((resolve, reject) => {
// 检查浏览器支持
if (!window.WebSocket) {
const error = '您的浏览器不支持WebSocket';
//console.error(error);
reject(new Error(error));
return;
}
// 防止重复连接
if (this.connectionStatus === ConnectionStatus.CONNECTING || this.connected) {
//console.warn('WebSocket已连接或正在连接中');
resolve();
return;
}
this.connectionStatus = ConnectionStatus.CONNECTING;
try {
this.ws = new WebSocket(this.buildWebSocketUrl());
this.setupEventHandlers(resolve, reject);
} catch (error) {
this.connectionStatus = ConnectionStatus.ERROR;
reject(error);
}
});
}
/**
* 注册消息回调函数(支持泛型)
* @param messageType 消息类型
* @param callback 回调函数
*/
public registerCallBack<T = any>(messageType: string, callback: CallbackFunction<T>): void {
if (!messageType || typeof callback !== 'function') {
//console.error('注册回调函数参数无效');
return;
}
this.callBackMapping[messageType] = callback;
// console.log(`注册消息处理器: ${messageType}`);
}
/**
* 注销消息回调函数
* @param messageType 消息类型
*/
public unRegisterCallBack(messageType: string): void {
if (this.callBackMapping[messageType]) {
delete this.callBackMapping[messageType];
//console.log(`注销消息处理器: ${messageType}`);
}
}
/**
* 发送数据到WebSocket服务器
* @param data 要发送的数据
* @returns Promise<void>
*/
public send(data: any): Promise<void> {
return new Promise((resolve, reject) => {
if (!this.connected || !this.ws) {
// 未连接时的重试机制
if (this.sendRetryCount < 3) {
this.sendRetryCount++;
setTimeout(() => {
this.send(data).then(resolve).catch(reject);
}, this.sendRetryCount * 500);
return;
} else {
reject(new Error('WebSocket未连接且重试失败'));
return;
}
}
try {
// 重置重试计数
this.sendRetryCount = 0;
// 尝试发送JSON数据失败则发送原始数据
const message = typeof data === 'string' ? data : JSON.stringify(data);
this.ws.send(message);
//console.log('发送消息:', message);
resolve();
} catch (error) {
//console.error('发送消息失败:', error);
reject(error);
}
});
}
/**
* 关闭WebSocket连接
*/
public closeWs(): void {
//console.log('正在关闭WebSocket连接...');
// 清理心跳
this.clearHeartbeat();
// 关闭连接
if (this.ws) {
this.ws.close(1000, '主动关闭连接');
this.ws = null;
}
// 更新状态
this.connectionStatus = ConnectionStatus.DISCONNECTED;
this.connectRetryCount = 0;
this.sendRetryCount = 0;
//console.log('WebSocket连接已关闭');
}
/**
* 获取当前连接状态
* @returns 连接状态枚举值
*/
public getConnectionStatus(): ConnectionStatus {
return this.connectionStatus;
}
/**
* 获取连接统计信息
* @returns 连接统计对象
*/
public getConnectionStats(): {
status: ConnectionStatus;
connectRetryCount: number;
lastResponseHeartTime: number;
} {
return {
status: this.connectionStatus,
connectRetryCount: this.connectRetryCount,
lastResponseHeartTime: this.lastResponseHeartTime
};
}
const url = 'ws://127.0.0.1:7777/hello?name=cdf'
this.ws = new WebSocket(url);
// 连接成功的事件
// ========================================================================
// 私有方法 (Private Methods)
// ========================================================================
/**
* 构建完整的WebSocket URL
* 自动从JWT token中获取loginName作为name参数
* @returns 完整的WebSocket URL
*/
private buildWebSocketUrl(): string {
const { url } = this.config;
// 直接从JWT token中获取loginName作为name参数
const loginName = jwtUtil.getLoginName();
if (loginName) {
const separator = url.includes('?') ? '&' : '?';
return `${url}${separator}name=${encodeURIComponent(loginName)}`;
}
// 如果无法获取loginName返回原始URL并输出警告
console.warn('无法从JWT token中获取loginNameWebSocket连接可能会失败');
return url;
}
/**
* 设置WebSocket事件处理器异步版本
* @param resolve Promise resolve回调
* @param reject Promise reject回调
*/
private setupEventHandlers(resolve: () => void, reject: (error: Error) => void): void {
if (!this.ws) return;
// 连接成功事件
this.ws.onopen = () => {
ElMessage.success("WebSocket连接服务端成功");
// console.log('WebSocket连接成功');
this.connectionStatus = ConnectionStatus.CONNECTED;
this.connectRetryCount = 0;
this.startHeartbeat();
resolve();
};
// 连接关闭事件
this.ws.onclose = (event: CloseEvent) => {
//console.log('WebSocket连接关闭', event.code, event.reason);
this.connectionStatus = ConnectionStatus.DISCONNECTED;
this.clearHeartbeat();
// 非正常关闭且未超过最大重连次数,尝试重连
if (event.code !== 1000 && this.connectRetryCount < this.config.maxReconnectAttempts!) {
this.attemptReconnect();
}
};
// 连接错误事件
this.ws.onerror = (error: Event) => {
console.error('WebSocket连接错误:', error);
ElMessage.error("WebSocket连接异常");
this.connectionStatus = ConnectionStatus.ERROR;
reject(new Error('WebSocket连接失败'));
};
// 消息接收事件
this.ws.onmessage = (event: MessageEvent) => {
this.handleMessage(event);
};
}
/**
* 设置WebSocket事件处理器兼容版本
*/
private setupEventHandlersLegacy(): void {
if (!this.ws) return;
// 连接成功事件
this.ws.onopen = () => {
ElMessage.success("webSocket连接服务端成功了");
console.log('连接服务端成功了');
this.connected = true;
// 重置重新连接的次数
// console.log('连接服务端成功了');
this.connectionStatus = ConnectionStatus.CONNECTED;
this.connectRetryCount = 0;
this.updateLastActivityTime();
this.startHeartbeat();
};
// 1.连接服务端失败
// 2.当连接成功之后, 服务器关闭的情况
this.ws.onclose = () => {
console.log('连接webSocket服务端关闭');
this.connected = false;
this.connectRetryCount++;
// 连接关闭事件
this.ws.onclose = (event: CloseEvent) => {
// console.log('连接webSocket服务端关闭');
this.connectionStatus = ConnectionStatus.DISCONNECTED;
this.clearHeartbeat();
/* setTimeout(() => {
// 保持原有的重连逻辑(被注释掉的)
// this.connectRetryCount++;
/* setTimeout(() => {
this.connect();
}, 500 * this.connectRetryCount);*/
};
// 连接错误事件
this.ws.onerror = () => {
ElMessage.error("webSocket连接异常");
this.connectionStatus = ConnectionStatus.ERROR;
};
// 消息接收事件
this.ws.onmessage = (event: MessageEvent) => {
this.handleMessage(event);
};
}
// 得到服务端发送过来的数据
this.ws.onmessage = (event) => {
// console.log('🚀 ~ SocketService ~ connect ~ event:', event)
if(event.data == 'over') {
//心跳消息处理
this.lastResponseHeartTime = Date.now();
this.updateLastActivityTime(); // 收到心跳响应时更新活动时间
}else {
let message: { [key: string]: any };
try {
console.log('Received message:',event.data)
message = JSON.parse(event.data);
} catch (e) {
return console.error("消息解析失败", event.data, e);
}
/**
* 处理接收到的消息
* 支持心跳响应、JSON消息和普通文本消息
* @param event WebSocket消息事件
*/
private handleMessage(event: MessageEvent): void {
// console.log('Received message:', event.data);
/* 通过接受服务端发送的type字段来回调函数 */
// 心跳响应处理
if (event.data === 'over') {
// console.log(`${new Date().toLocaleTimeString()} - 收到心跳响应`);
this.lastResponseHeartTime = Date.now();
return;
}
// 检查消息是否为空或无效
if (!event.data || event.data.trim() === '') {
console.warn('收到空消息,跳过处理');
return;
}
// 业务消息处理
try {
// 检查是否为JSON格式
if (typeof event.data === 'string' && (event.data.startsWith('{') || event.data.startsWith('['))) {
const message: WebSocketMessage = JSON.parse(event.data);
if (message?.type && this.callBackMapping[message.type]) {
this.callBackMapping[message.type](message);
} else {
console.log("抛弃====>")
console.log(event.data)
/* 丢弃或继续写你的逻辑 */
console.warn('未找到对应的消息处理器:', message.type);
}
} else {
// 非JSON格式的消息作为普通文本处理
// console.log('收到非JSON格式消息:', event.data);
// 可以添加文本消息的处理逻辑
if (this.callBackMapping['text']) {
this.callBackMapping['text']({
type: 'text',
data: event.data
});
}
}
};
}
startHeartbeat() {
this.lastResponseHeartTime = Date.now();
const _this = this
_this.workerBlobUrl = window.URL.createObjectURL(new Blob(['(function(e){setInterval(function(){this.postMessage(null)},9000)})()']));
this.work = new Worker(_this.workerBlobUrl);
this.work.onmessage = function(e){
//判断多久没收到心跳响应
if(_this.lastActivityTime - _this.lastResponseHeartTime > 30000){
//说明已经三轮心跳没收到回复了,关闭检测,提示用户。
ElMessage.error("业务主体模块发生未知异常,请尝试重新启动!");
_this.clearHeartbeat();
return;
}
_this.sendHeartbeat();
}
}
sendHeartbeat() {
console.log(new Date()+"进入心跳消息发送。。。。。。。。。。。。。")
this.ws.send('alive');
this.updateLastActivityTime(); // 发送心跳后更新活动时间
}
updateLastActivityTime() {
this.lastActivityTime = Date.now();
}
clearHeartbeat() {
const _this = this
if (_this.work) {
_this.work.terminate();
_this.work = null;
}
if (_this.workerBlobUrl) {
window.URL.revokeObjectURL(_this.workerBlobUrl); // 释放临时的Blob URL
_this.workerBlobUrl = null;
} catch (error) {
console.error('消息解析失败:', event.data, error);
console.error('消息类型:', typeof event.data);
console.error('消息长度:', event.data?.length || 0);
}
}
// ========================================================================
// 重连机制相关方法
// ========================================================================
/**
* 尝试重新连接WebSocket
*/
private attemptReconnect(): void {
if (this.connectionStatus === ConnectionStatus.RECONNECTING) {
return;
}
// 回调函数的注册
registerCallBack(socketType, callBack) {
this.callBackMapping[socketType] = callBack;
}
// 取消某一个回调函数
unRegisterCallBack(socketType) {
this.callBackMapping[socketType] = null;
}
// 发送数据的方法
send(data) {
// 判断此时此刻有没有连接成功
if (this.connected) {
this.sendRetryCount = 0;
this.connectionStatus = ConnectionStatus.RECONNECTING;
this.connectRetryCount++;
const delay = this.config.reconnectDelay! * this.connectRetryCount;
// console.log(`尝试第${this.connectRetryCount}次重连,${delay}ms后开始...`);
setTimeout(() => {
try {
this.ws.send(JSON.stringify(data));
} catch (e) {
this.ws.send(data);
const result = this.connect();
if (result instanceof Promise) {
result.catch((error: any) => {
console.error('重连失败:', error);
});
}
} catch (error: any) {
console.error('重连失败:', error);
}
} else {
this.sendRetryCount++;
setTimeout(() => {
this.send(data);
}, this.sendRetryCount * 500);
}, delay);
}
// ========================================================================
// 心跳机制相关方法
// ========================================================================
/**
* 启动心跳机制
*/
private startHeartbeat(): void {
this.lastResponseHeartTime = Date.now();
this.createHeartbeatWorker();
}
/**
* 创建心跳Worker
* 使用Worker在独立线程中处理心跳定时器避免主线程阻塞
*/
private createHeartbeatWorker(): void {
try {
// 创建Worker脚本
const workerScript = `
setInterval(function() {
postMessage('heartbeat');
}, ${this.config.heartbeatInterval});
`;
this.workerBlobUrl = window.URL.createObjectURL(
new Blob([workerScript], { type: 'application/javascript' })
);
this.heartbeatWorker = new Worker(this.workerBlobUrl);
// 心跳Worker消息处理
this.heartbeatWorker.onmessage = (event: MessageEvent) => {
this.handleHeartbeatTick();
};
// Worker错误处理
this.heartbeatWorker.onerror = (error: ErrorEvent) => {
console.error('心跳Worker错误:', error);
this.clearHeartbeat();
};
} catch (error) {
console.error('创建心跳Worker失败:', error);
}
}
// 断开方法
closeWs() {
if (this.connected) {
this.ws.close()
/**
* 处理心跳定时器事件
* 检查连接超时并发送心跳消息
*/
private handleHeartbeatTick(): void {
// 检查是否超时(距离上次收到心跳响应的时间)
const timeSinceLastResponse = Date.now() - this.lastResponseHeartTime;
if (timeSinceLastResponse > this.config.timeout!) {
console.error(`WebSocket心跳超时: ${timeSinceLastResponse}ms > ${this.config.timeout}ms`);
ElMessage.error("WebSocket连接超时请检查网络连接");
this.clearHeartbeat();
this.closeWs();
return;
}
console.log('执行WS关闭命令..');
this.sendHeartbeat();
}
}
/**
* 发送心跳消息到服务器
*/
private sendHeartbeat(): void {
if (this.connected && this.ws) {
// console.log(`${new Date().toLocaleTimeString()} - 发送心跳消息`);
this.ws.send('alive');
}
}
/**
* 清理心跳机制
* 终止Worker并清理相关资源
*/
private clearHeartbeat(): void {
if (this.heartbeatWorker) {
this.heartbeatWorker.terminate();
this.heartbeatWorker = null;
}
if (this.workerBlobUrl) {
window.URL.revokeObjectURL(this.workerBlobUrl);
this.workerBlobUrl = null;
}
}
}

View File

@@ -64,8 +64,8 @@
// 默认不做操作就直接在 ProTable 组件上绑定 :requestApi="getUserList"
const getTableList = (params: any) => {
let newParams = JSON.parse(JSON.stringify(params))
newParams.searchEndTime = endDate.value
newParams.searchBeginTime = startDate.value
// newParams.searchEndTime = endDate.value
// newParams.searchBeginTime = startDate.value
return getUserList(newParams)
}
@@ -112,19 +112,19 @@
prop: 'loginTime',
label: '最后一次登录时间',
minWidth: 180,
search: {
render: () => {
return (
<div class='flx-flex-start'>
<TimeControl
include={['日', '周', '月', '自定义']}
default={'月'}
onUpdate-dates={handleDateChange}
/>
</div>
)
},
},
// search: {
// render: () => {
// return (
// <div class='flx-flex-start'>
// <TimeControl
// include={['日', '周', '月', '自定义']}
// default={'月'}
// onUpdate-dates={handleDateChange}
// />
// </div>
// )
// },
// },
},
{
prop: 'state',

View File

@@ -262,6 +262,12 @@ watch(webMsgSend, function (newValue, oldValue) {
type: 'error',
})
TableInit();
} else if (newValue.code == -1) { //todo 10552之后还会发送消息吗
ElMessageBox.alert('源未知异常', '检测失败', {
confirmButtonText: '确定',
type: 'error',
})
TableInit();
} else {
console.log('显示东西code', newValue.code)
console.log('显示东西requestId', newValue.requestId)
@@ -739,7 +745,7 @@ const handleSubmit = async () => {
isButtonDisabled.value = true; // 禁用按钮
tableLoading('big', '系数下装')
await getCoefficientCheck({
/* await getCoefficientCheck({
userPageId: "cdf",
devIds: devIdArray.value,
planId: planId.value,
@@ -747,7 +753,7 @@ const handleSubmit = async () => {
scriptId: select_Plan.value?.scriptId,
operateType: '0', // '0'为预检测、1为正式检测
userId:userStore.userInfo.id
})
})*/
active.value++;
console.log('开始检测active.value', active.value)

View File

@@ -501,6 +501,14 @@ watch(webMsgSend, function (newValue, oldValue) {
})
ts.value = 'error'
step5.value = 'error'
}else if (newValue.code == -1) {
step4.value = 'error'
step4InitLog.value = [{
type: 'error',
log: '源未知异常!',
}];
ts.value = 'error'
step5.value = 'error'
}
break;

View File

@@ -97,10 +97,10 @@
<!-- <el-button type="primary" :icon="CirclePlus" @click="addDevice('设备新增')" v-if="form.activeTabs === 0"
>设备新增</el-button> -->
<el-button type='primary' v-auth.role="'channelsTest'" :icon='Odometer' @click="handleTest('系数校准')"
v-if='form.activeTabs === 0 && appSceneStore.currentScene === "1" '
>系数校准
</el-button>
<!-- <el-button type='primary' v-auth.role="'channelsTest'" :icon='Odometer' @click="handleTest('系数校准')"-->
<!-- v-if='form.activeTabs === 0 && appSceneStore.currentScene === "1" '-->
<!-- >系数校准-->
<!-- </el-button>-->
</el-form-item>
</el-form>
</template>
@@ -136,7 +136,7 @@
link
:icon='Download'
@click="openDrawer('报告下载', scope.row)"
v-if='form.activeTabs === 3 && form.activeChildTabs === 0 && scope.row.reportState === 1'
v-if='form.activeTabs === 3 && form.activeChildTabs === 0 && (scope.row.reportState === 1 ||scope.row.reportState === 3)'
>报告下载
</el-button>
@@ -233,7 +233,7 @@
<SelectTestItemPopup ref="selectTestItemPopupRef" @openTestDialog="openTestDialog"></SelectTestItemPopup>
<!-- 省平台-填写温度湿度弹窗 -->
<WriteTHPopup ref="writeTHPopupRef" @openTestDialog2="openTestDialog2"></WriteTHPopup>
</div>
</template>
@@ -582,6 +582,8 @@ const columns = reactive<ColumnProps<Device.ResPqDev>[]>([
return '已生成'
} else if (scope.row.reportState === 2) {
return '未检'
}else if(scope.row.reportState === 3){
return '已上传'
}
return ''
},
@@ -945,7 +947,7 @@ const handleTest = async (val: string) => {
dialogTitle.value = val
if (val === '手动检测') {
checkStore.setShowDetailType(2)
if (testType === 'reTest') {
ElMessageBox.confirm('请选择复检检测方式', '设备复检',
{
@@ -965,7 +967,8 @@ const handleTest = async (val: string) => {
if(appSceneStore.currentScene === '0'){
writeTHPopupRef.value?.open()
}else{
openTestDialog(true)
selectTestItemPopupRef.value?.open()
//openTestDialog(true)
}
})
.catch((action: Action) => {
@@ -976,17 +979,17 @@ const handleTest = async (val: string) => {
if(appSceneStore.currentScene === '0'){
writeTHPopupRef.value?.open()
}else{
openTestDialog(true)
selectTestItemPopupRef.value?.open()
//openTestDialog(true)
}
}
})
checkStore.setSelectTestItems({preTest: false, timeTest: false, channelsTest: false, test: true})
} else {
checkStore.setReCheckType(1)
selectTestItemPopupRef.value?.open()
checkStore.setReCheckType(1)
}
} else if (val === '系数校准') {
// 检查 socketClient.Instance 是否存在
if (!socketClient.Instance) {
@@ -1051,6 +1054,7 @@ const handleTest = async (val: string) => {
})
checkStore.setSelectTestItems({preTest: false, timeTest: false, channelsTest: false, test: true})
} else {
checkStore.setReCheckType(1)
openTestDialog(true)
}
}
@@ -1190,7 +1194,7 @@ watch(
)
onBeforeMount(async () => {
const response = await getPqDev()
devTypeOptions.value = response.data.map(item => ({
id: item.id,

View File

@@ -12,64 +12,6 @@
style="width: 82%; margin-right: 3%;"
:percentage="percentage"
:color="customColors"/>
<!-- <div style="width: 15%">-->
<!-- <el-button type="primary" v-if="testStatus=='test_init'" disabled @click="handlePause()">-->
<!-- <el-icon class="loading-box" style="color: #fff;margin-right: 8px;">-->
<!-- <component :is="Refresh"/>-->
<!-- </el-icon>-->
<!-- 初始化中-->
<!-- </el-button>-->
<!-- <el-button-->
<!-- type="primary"-->
<!-- v-if="testStatus=='process' && percentage < 100"-->
<!-- :icon="VideoPause"-->
<!-- @click="handlePause()">停止检测-->
<!-- </el-button>-->
<!-- <el-button type="warning" v-if="testStatus === 'paused_ing' && percentage < 100" disabled>-->
<!-- <el-icon class="loading-box" style="margin-right: 8px;">-->
<!-- <component :is="Refresh"/>-->
<!-- </el-icon>-->
<!-- 暂停中-->
<!-- </el-button>-->
<!-- &lt;!&ndash; <el-button&ndash;&gt;-->
<!-- &lt;!&ndash; type="primary"&ndash;&gt;-->
<!-- &lt;!&ndash; v-if="testStatus=='test_init'"&ndash;&gt;-->
<!-- &lt;!&ndash; :icon="VideoPause"&ndash;&gt;-->
<!-- &lt;!&ndash; disabled>初始化中&ndash;&gt;-->
<!-- &lt;!&ndash; </el-button>&ndash;&gt;-->
<!-- &lt;!&ndash; <el-button&ndash;&gt;-->
<!-- &lt;!&ndash; type="danger"&ndash;&gt;-->
<!-- &lt;!&ndash; v-if="testStatus=='test_init_fail'"&ndash;&gt;-->
<!-- &lt;!&ndash; :icon="Failed"&ndash;&gt;-->
<!-- &lt;!&ndash; disabled>初始化失败&ndash;&gt;-->
<!-- &lt;!&ndash; </el-button>&ndash;&gt;-->
<!-- &lt;!&ndash; <el-button&ndash;&gt;-->
<!-- &lt;!&ndash; type="danger"&ndash;&gt;-->
<!-- &lt;!&ndash; v-if="testStatus=='connect_timeout'"&ndash;&gt;-->
<!-- &lt;!&ndash; :icon="Failed"&ndash;&gt;-->
<!-- &lt;!&ndash; disabled>连接超时&ndash;&gt;-->
<!-- &lt;!&ndash; </el-button>&ndash;&gt;-->
<!-- &lt;!&ndash; <el-button&ndash;&gt;-->
<!-- &lt;!&ndash; type="primary"&ndash;&gt;-->
<!-- &lt;!&ndash; :icon="RefreshLeft"&ndash;&gt;-->
<!-- &lt;!&ndash; v-if="testStatus === 'recheck'"&ndash;&gt;-->
<!-- &lt;!&ndash; @click="emit('sendReCheck')">重新检测&ndash;&gt;-->
<!-- &lt;!&ndash; </el-button>&ndash;&gt;-->
<!-- <el-button type="success" v-if="percentage >= 100" :icon="Check" disabled>检测完成</el-button>-->
<!-- <el-button-->
<!-- type="warning"-->
<!-- v-if="(testStatus=='paused' || testStatus === 'pause_timeout') && percentage < 100"-->
<!-- :icon="VideoPlay"-->
<!-- :disabled="testStatus === 'pause_timeout'"-->
<!-- @click="emit('sendResume')"-->
<!-- >继续检测-->
<!-- </el-button>-->
<!-- </div>-->
<el-button style="width: 10%" type="text" :icon="InfoFilled" @click="showTestLog">检测项进度</el-button>
</div>
@@ -335,19 +277,19 @@ const checkResultView: ComputedRef<CheckData.ScriptChnViewItem[]> = computed(()
watch(testStatus, function (newValue, oldValue) {
if (newValue == 'start') {
ElMessage.success('初始化开始!')
if (!checkStore.selectTestItems.preTest && !checkStore.selectTestItems.channelsTest) {
ElMessage.success('初始化开始!')
emit('update:testStatus', 'test_init')
testLogList.push({type: 'info', log: `${new Date().toLocaleString()}:初始化开始!`})
} else {
emit('update:testStatus', 'process')
}
startTimeCount()
showTestLog()
// if (oldValue == 'recheck' || oldValue == 'error' || oldValue == 'test_init_fail' || oldValue == 'connect_timeout' || oldValue == 'pause_timeout' || oldValue == 'error_flow_end') {
// handleReCheck()
// }
emit('update:testStatus', 'test_init')
//startTimer() // todo 可移除
startData.value = new Date();
timeDifference.value = 0;
testLogList.push({type: 'info', log: `${new Date().toLocaleString()}:初始化开始!`})
}
if (newValue == 'recheck' || newValue == 'error' || newValue == 'test_init_fail' || newValue == 'connect_timeout' || newValue == 'pause_timeout' || oldValue == 'error_flow_end') {
@@ -448,6 +390,16 @@ watch(webMsgSend, function (newValue, oldValue) {
})
// emit('update:testStatus', 'recheck')
emit('update:testStatus', 'test_init_fail')
} else if (newValue.code == -1) {
ElMessageBox.alert('源未知异常!', '检测失败!', {
confirmButtonText: '确定',
type: 'error',
})
testLogList.push({
type: 'error',
log: `${new Date().toLocaleString()}:源未知异常!`
})
emit('update:testStatus', 'error')
} else {
switch (newValue.requestId) {
case 'server_error':
@@ -528,14 +480,14 @@ watch(webMsgSend, function (newValue, oldValue) {
testLogList.push({type: 'info', log: `${new Date().toLocaleString()}:源初始化成功!`})
percentage.value = 1
}
if (newValue.code == -1) {
ElMessageBox.alert('源未知异常!', '初始化失败', {
confirmButtonText: '确定',
type: 'error',
})
testLogList.push({type: 'error', log: `${new Date().toLocaleString()}:源未知异常!`})
emit('update:testStatus', 'test_init_fail')
}
// if (newValue.code == -1) {
// ElMessageBox.alert('源未知异常!', '初始化失败', {
// confirmButtonText: '确定',
// type: 'error',
// })
// testLogList.push({type: 'error', log: `${new Date().toLocaleString()}:源未知异常!`})
// emit('update:testStatus', 'test_init_fail')
// }
break;
}
break;
@@ -788,7 +740,7 @@ const initScriptData = async () => {
let response: any = await getBigTestItem({reCheckType: checkStore.reCheckType, planId: checkStore.plan.id, devIds: checkStore.devices.map(item => item.deviceId)})
let temp = response.data.map(item => {
let temp = response.data.map((item: any) => {
return {
...item,
scriptName: item.scriptName

View File

@@ -2,10 +2,12 @@
<el-dialog :title="dialogTitle" width="1550px" :model-value="dialogVisible" :before-close="beforeClose" @close="handleClose" height="1000px" draggable>
<div class="steps-container">
<el-steps class="test-head-steps" simple :active="stepsActiveIndex" process-status="finish" finish-status="success">
<el-steps v-if="showSteps" class="test-head-steps" simple :active="stepsActiveIndex" process-status="finish" finish-status="success">
<el-step v-if="preTestSelected" title="预检测" :icon="stepsActive > 1 || stepsActiveIndex > stepsTotalNum-1? SuccessFilled :Edit" @click="handleStepClick(1)"/>
<el-step v-if="timeTestSelected" title="守时检测" :icon="stepsActive > 2 || stepsActiveIndex > stepsTotalNum-1? SuccessFilled :UploadFilled" @click="handleStepClick(2)"/>
<el-step v-if="channelsTestSelected" title="系数校准" :icon="stepsActive > 3 || stepsActiveIndex > stepsTotalNum-1? SuccessFilled :Odometer" @click="handleStepClick(3)"/>
<el-step v-if="timeTestSelected" title="守时检测" :icon="stepsActive > 2 || stepsActiveIndex > stepsTotalNum-1? SuccessFilled :UploadFilled"
@click="handleStepClick(2)"/>
<el-step v-if="channelsTestSelected" title="系数校准" :icon="stepsActive > 3 || stepsActiveIndex > stepsTotalNum-1? SuccessFilled :Odometer"
@click="handleStepClick(3)"/>
<el-step v-if="testSelected" title="正式检测" :icon="stepsActive > 4 || stepsActiveIndex > stepsTotalNum-1? SuccessFilled :Coin" @click="handleStepClick(4)"/>
<el-step title="检测完成" :icon="stepsActiveIndex > stepsTotalNum-1 ? SuccessFilled :Key"/>
</el-steps>
@@ -15,32 +17,16 @@
:webMsgSend="webMsgSend"/>
<timeTest v-if="showComponent&&timeTestSelected" v-show="timeTestSelected && stepsActiveView==2" v-model:testStatus="timeTestStatus"/>
<!-- <channelsTest v-if="stepsActiveIndex === 3" v-model:testStatus="channelsTestStatus"></channelsTest>-->
<factorTest v-if="showComponent&&channelsTestSelected" v-show="channelsTestSelected && stepsActiveView==3" v-model:testStatus="channelsTestStatus" :webMsgSend="webMsgSend"/>
<factorTest v-if="showComponent&&channelsTestSelected" v-show="channelsTestSelected && stepsActiveView==3" v-model:testStatus="channelsTestStatus"
:webMsgSend="webMsgSend"/>
<test v-if="showComponent&&testSelected" ref="testRef" v-show="testSelected && stepsActiveView==4" v-model:testStatus="TestStatus" :webMsgSend="webMsgSend"
@update:webMsgSend="webMsgSend=$event" @sendPause="sendPause" @sendResume="sendResume" @sendReCheck="sendReCheck" @closeWebSocket="closeWebSocket" :stepsActive="stepsActive"/>
@update:webMsgSend="webMsgSend=$event" @sendPause="sendPause" @sendResume="sendResume" @sendReCheck="sendReCheck" @closeWebSocket="closeWebSocket"
:stepsActive="stepsActive"/>
<template #footer>
<div>
<!-- <el-button type="primary" :icon="DArrowRight" v-if="stepsActiveIndex < stepsTotalNum && ActiveStatue != 'success'" @click="nextStep">跳过</el-button>-->
<el-button type="primary" :icon="VideoPlay" v-if="ActiveStatue === 'waiting'" @click="handleSubmit">开始检测</el-button>
<!-- <el-button type="primary"-->
<!-- v-if="(stepsActiveIndex <= stepsTotalNum - 1) && (ActiveStatue !== 'success' &&ActiveStatue !== 'test_init' && ActiveStatue !=='paused_ing' && ActiveStatue !=='paused' && ActiveStatue !== 'waiting' && ActiveStatue !== 'error' && ActiveStatue !== 'test_init_fail' && ActiveStatue !== 'connect_timeout' && ActiveStatue!=='pause_timeout')"-->
<!-- disabled>-->
<!-- <el-icon class="loading-box" style="color: #fff;margin-right: 8px;">-->
<!-- <component :is="Refresh"/>-->
<!-- </el-icon>-->
<!-- 检测中-->
<!-- </el-button>-->
<!-- <el-button type="primary" v-if="ActiveStatue === 'process'" disabled>-->
<!-- <el-icon class="loading-box" style="color: #fff;margin-right: 8px;">-->
<!-- <component :is="Refresh"/>-->
<!-- </el-icon>-->
<!-- 检测中-->
<!-- </el-button>-->
<!-- <el-button type="warning" :icon="VideoPlay" v-if="TestStatus === 'paused'" @click="handleSubmit">继续检测</el-button>-->
<!-- <el-button type="primary" :icon="RefreshLeft" v-if="ActiveStatue === 'recheck' || ActiveStatue ==='error' || ActiveStatue ==='test_init_fail' || ActiveStatue === 'pause_timeout' || ActiveStatue === 'connect_timeout'" @click="handleSubmit">重新检测</el-button>-->
<!-- <el-button type="primary" :icon="DArrowRight" v-if="stepsActiveIndex < stepsTotalNum && ActiveStatue != 'success'" @click="nextStep">跳过</el-button>-->
<el-button type="primary" :icon="VideoPlay" v-if="ActiveStatue === 'waiting'" @click="handleSubmitFast">开始检测</el-button>
<el-button type="primary" v-if="TestStatus === 'test_init'" disabled>
<el-icon class="loading-box" style="color: #fff;margin-right: 8px;">
<component :is="Refresh"/>
@@ -85,7 +71,7 @@
<script lang="tsx" setup name="testPopup">
import {reactive, ref, watch} from 'vue';
import {ElMessage, ElMessageBox} from 'element-plus'
import {Coin, DArrowRight, Edit, Key, Odometer, Refresh, Right, SuccessFilled, UploadFilled, VideoPlay,VideoPause} from '@element-plus/icons-vue'
import {Coin, Edit, Key, Odometer, Refresh, Right, SuccessFilled, UploadFilled, VideoPause, VideoPlay} from '@element-plus/icons-vue'
import preTest from './preTest.vue'
import timeTest from './timeTest.vue'
import factorTest from './factorTest.vue'
@@ -94,13 +80,13 @@ import socketClient from '@/utils/webSocketClient';
import {useCheckStore} from "@/stores/modules/check";
import {pauseTest, resumeTest, startPreTest} from '@/api/socket/socket'
import {useUserStore} from "@/stores/modules/user";
import { Device } from '@/api/device/interface/device';
const userStore = useUserStore()
const checkStore = useCheckStore();
const nextStepText = ref('下一步');
const dialogVisible = ref(false)
const showSteps = ref(false)
const stepsTotalNum = ref(-1);//步骤总数
const stepsActiveIndex = ref(1); //当前正在执行的步骤索引
const stepsActiveView = ref(-1); //当前正在执行的步骤在(预处理、守时校验、系数校准、正式检测)中的排序,仅用于页面显示
@@ -174,6 +160,7 @@ const initOperate = () => {
}
const open = (title: string) => {
showSteps.value = true
initOperate()
dialogTitle.value = title;
dialogVisible.value = true;
@@ -198,8 +185,7 @@ const open = (title: string) => {
});
}
// let loading;
const handleSubmit = () => {
const handleSubmitFast = () => {
let deviceIds = checkStore.devices.map((item) => item.deviceId)
let planId = checkStore.plan.id
@@ -207,58 +193,84 @@ const handleSubmit = () => {
ElMessage.error('webSocket连接中断')
return
}
console.log("handleSubmit",stepsActive.value,TestStatus.value)
console.log("handleSubmit", stepsActive.value, TestStatus.value)
switch (stepsActive.value) {
case 1:
startPreTest({
userPageId: "cdf",
devIds: deviceIds,
planId: planId,
operateType: '1', // '1'为预检测、2为正式检测、'8'为不合格项复检
userId:userStore.userInfo.id,
temperature:checkStore.temperature,
humidity:checkStore.humidity
}).then(res => {
if (res.code === 'A001014') {
ElMessageBox.alert('装置配置异常', '检测失败', {
confirmButtonText: '确定',
type: 'error',
if (preTestStatus.value == 'waiting') {
if (checkStore.selectTestItems.preTest) {
startPreTest({
userPageId: "cdf",
devIds: deviceIds,
planId: planId,
operateType: checkStore.reCheckType == 1 ? '1' : '2',
userId: userStore.userInfo.id,
temperature: checkStore.temperature,
humidity: checkStore.humidity,
testItemList: [checkStore.selectTestItems.preTest, checkStore.selectTestItems.channelsTest, checkStore.selectTestItems.test]
}).then(res => {
if (res.code === 'A001014') {
ElMessageBox.alert('装置配置异常', '检测失败', {
confirmButtonText: '确定',
type: 'error',
})
preTestStatus.value = 'error'
}
})
preTestStatus.value = 'error'
preTestStatus.value = 'start'
}
})
preTestStatus.value = 'start'
// setTimeout(() => {
// preTestStatus.value = 'success'
// }, 5000)
}
break;
case 2:
timeTestStatus.value = 'start'
break;
case 3:
// 调用系数校准组件的handleSubmit方法
channelsTestStatus.value = 'start'
if (channelsTestStatus.value == 'waiting') {
if (!checkStore.selectTestItems.preTest && checkStore.selectTestItems.channelsTest) {
startPreTest({
userPageId: "cdf",
devIds: deviceIds,
planId: planId,
operateType: checkStore.reCheckType == 1 ? '1' : '2',
userId: userStore.userInfo.id,
temperature: checkStore.temperature,
humidity: checkStore.humidity,
testItemList: [checkStore.selectTestItems.preTest, checkStore.selectTestItems.channelsTest, checkStore.selectTestItems.test]
}).then(res => {
if (res.code === 'A001014') {
ElMessageBox.alert('装置配置异常', '初始化失败', {
confirmButtonText: '确定',
type: 'error',
})
channelsTestStatus.value = 'test_init_fail'
}
})
// 调用系数校准组件的handleSubmit方法
}
channelsTestStatus.value = 'start'
}
break;
case 4:
if (TestStatus.value == "waiting") {
startPreTest({
userPageId: "cdf",
devIds: deviceIds,
planId: planId,
operateType: checkStore.reCheckType ==1 ?'2':'8', // '1'为预检测、2为正式检测、'8'为不合格项复检
userId:userStore.userInfo.id,
temperature:checkStore.temperature,
humidity:checkStore.humidity
}).then(res => {
console.log(res)
if (res.code === 'A001014') {
ElMessageBox.alert('装置配置异常', '初始化失败', {
confirmButtonText: '确定',
type: 'error',
})
TestStatus.value = 'test_init_fail'
}
})
if (!checkStore.selectTestItems.preTest && !checkStore.selectTestItems.channelsTest && checkStore.selectTestItems.test) {
startPreTest({
userPageId: "cdf",
devIds: deviceIds,
planId: planId,
operateType: checkStore.reCheckType == 1 ? '1' : '2',
userId: userStore.userInfo.id,
temperature: checkStore.temperature,
humidity: checkStore.humidity,
testItemList: [checkStore.selectTestItems.preTest, checkStore.selectTestItems.channelsTest, checkStore.selectTestItems.test]
}).then(res => {
if (res.code === 'A001014') {
ElMessageBox.alert('装置配置异常', '初始化失败', {
confirmButtonText: '确定',
type: 'error',
})
TestStatus.value = 'test_init_fail'
}
})
}
TestStatus.value = 'start'
} else if (TestStatus.value == 'paused') {
// 发送继续指令
@@ -275,7 +287,7 @@ const handleSubmit = () => {
default:
break;
}
};
}
const emit = defineEmits<{
@@ -327,22 +339,24 @@ watch(ActiveStatue, function (newValue, oldValue) {
}
if (newValue === 'success' && stepsActiveIndex.value < stepsTotalNum.value - 1) {
nextStep() // 实现自动点击,进入下一个测试内容
handleSubmit()
//handleSubmit()
handleSubmitFast()
}
})
const handleQuit = () => {
console.log('handleQuit',ActiveStatue.value)
console.log('handleQuit', ActiveStatue.value)
if (ActiveStatue.value !== 'success' && ActiveStatue.value !== 'waiting' && ActiveStatue.value !== 'paused' && ActiveStatue.value !== 'test_init_fail' && ActiveStatue.value !== 'connect_timeout' && ActiveStatue.value !== 'pause_timeout') {
beforeClose(() => {})
beforeClose(() => {
})
} else {
handleClose()
}
}
const handlePause=()=>{
const handlePause = () => {
sendPause()
testRef.value?.handlePause()
}
@@ -366,9 +380,9 @@ const sendResume = () => {
devIds: checkStore.devices.map((item) => item.deviceId),
planId: checkStore.plan.id,
operateType: '2', // 0:'系数校验''1'为预检测、2为正式检测、'8'为不合格项复检
userId:userStore.userInfo.id,
temperature:checkStore.temperature,
humidity:checkStore.humidity
userId: userStore.userInfo.id,
temperature: checkStore.temperature,
humidity: checkStore.humidity
})
Object.assign(webMsgSend.value, {
requestId: 'Resume_Success'
@@ -382,9 +396,10 @@ const sendReCheck = () => {
devIds: checkStore.devices.map((item) => item.deviceId),
planId: checkStore.plan.id,
operateType: '2', // 0:'系数校验''1'为预检测、2为正式检测、'8'为不合格项复检
userId:userStore.userInfo.id,
temperature:checkStore.temperature,
humidity:checkStore.humidity
userId: userStore.userInfo.id,
temperature: checkStore.temperature,
humidity: checkStore.humidity,
testItemList: [checkStore.selectTestItems.preTest, checkStore.selectTestItems.channelsTest, checkStore.selectTestItems.test]
}).then(res => {
console.log(res)
if (res.code === 'A001014') {
@@ -475,6 +490,7 @@ const beforeClose = (done: () => void) => {
}
const handleClose = () => {
showSteps.value = false
dataSocket.socketServe.closeWs()
dialogVisible.value = false;
clearData()
@@ -494,7 +510,8 @@ defineExpose({open})
.el-step__head.is-success {
color: #91cc75;
}
.el-step__title.is-success{
.el-step__title.is-success {
color: #91cc75;
}
}

View File

@@ -84,7 +84,6 @@ const modeList = [
const handelOpen = async (item: any) => {
modeStore.setCurrentMode(item.code); // 将模式code存入 store
const {data:scene} = await getCurrentScene(); // 获取当前场景
// AppSceneStore.setCurrentMode(scene+'');//0省级平台1设备出厂2研发自测
AppSceneStore.setCurrentMode(scene+'');//0省级平台1设备出厂2研发自测
await authStore.setShowMenu();

View File

@@ -159,14 +159,12 @@
</template>
<script setup lang='ts'>
import IPAddress from '@/components/IpAddress/index.vue'
import {dialogBig} from '@/utils/elementBind'
import {type Device} from '@/api/device/interface/device'
import {ElMessage, type FormItemRule} from 'element-plus'
import {addPqDev, updatePqDev} from '@/api/device/device'
import {computed, reactive, type Ref, ref} from 'vue'
import {computed, ref} from 'vue'
import {useDictStore} from '@/stores/modules/dict'
import {CirclePlus, Delete, EditPen} from '@element-plus/icons-vue'
// 使用 dayjs 库格式化
import dayjs from 'dayjs'
import MonitorTable from '@/views/machine/device/components/monitorTab.vue';
@@ -204,7 +202,7 @@ function useMetaInfo() {
hardwareVersion: '',
softwareVersion: '',
protocol: 'MMS',
ip: '',
ip: '172.17.102.222',
port: 102,
encryptionFlag: 0,
reCheckNum: 0,
@@ -213,7 +211,7 @@ function useMetaInfo() {
icdId: '',
power: '',
preinvestmentPlan: '',
delegate:''
delegate: ''
})
return {dialogVisible, titleType, formContent}
}
@@ -235,7 +233,7 @@ const resetFormContent = () => {
hardwareVersion: '',
softwareVersion: '',
protocol: 'MMS',
ip: '',
ip: '172.17.102.222',
port: 102,
encryptionFlag: 0,
reCheckNum: 0,
@@ -244,7 +242,7 @@ const resetFormContent = () => {
icdId: '',
power: '',
preinvestmentPlan: '',
delegate:''
delegate: ''
}
}
@@ -446,15 +444,17 @@ const handleDevTypeChange = (value: string) => {
formContent.value.devVolt = dev.devVolt; // 默认值为1
formContent.value.icdId = dev.icd
formContent.value.power = dev.power
// if (dev.name.includes('882B')) {
// formContent.value.ip = '172.17.102.220'
// } else if (dev.name.includes('882A')) {
// formContent.value.ip = '172.17.102.221'
// } else {
// formContent.value.ip = '172.17.102.200'
// }
if(scene.value === '1'){
if (dev.name.includes('NPQS-581') || dev.name.includes('NPQS-580') || dev.name.includes('PQ-COM')) {
formContent.value.encryptionFlag = 1
formContent.value.series = 'Pqs&cn870299'
formContent.value.devKey = '!qaz@wsx3edc4rfv'
} else {
formContent.value.encryptionFlag = 0
formContent.value.series = null
formContent.value.devKey = null
}
}
} else {
formContent.value.devChns = 1; // 默认值为1
formContent.value.devCurr = 1; // 默认值为1

View File

@@ -16,6 +16,7 @@
<el-button v-auth.device="'import'" type='primary' :icon='Download' plain @click="importFile('比对式')"
v-if='modeStore.currentMode === "比对式"'>导入
</el-button>
<el-button type='primary' :icon='Upload' plain @click='uploadFile()' v-if='appSceneStore.currentScene === "1"'>报告上传</el-button>
<el-button v-auth.device="'delete'" type='danger' :icon='Delete' plain :disabled='!scope.isSelected'
@click='batchDelete(scope.selectedListIds)'>
删除
@@ -28,6 +29,8 @@
</el-button>
<el-button v-auth.device="'delete'" type='primary' link :icon='Delete' @click='handleDelete(scope.row)'>删除
</el-button>
</template>
</ProTable>
@@ -38,7 +41,7 @@
<script setup lang='tsx' name='useRole'>
import TimeControl from '@/components/TimeControl/index.vue'
import {type Device} from '@/api/device/interface/device.ts'
import {type Device} from '@/api/device/interface/device'
import {useHandleData} from '@/hooks/useHandleData'
import {useDownload} from '@/hooks/useDownload'
import ProTable from '@/components/ProTable/index.vue'
@@ -47,8 +50,9 @@ import {type ColumnProps, type ProTableInstance} from '@/components/ProTable/int
import DevicePopup from '@/views/machine/device/components/devicePopup.vue'
import {CirclePlus, Delete, Download, EditPen, Upload} from '@element-plus/icons-vue'
import {useDictStore} from '@/stores/modules/dict'
import {deletePqDev, downloadTemplate, exportPqDev, getPqDev, getPqDevList, importPqDev} from '@/api/device/device/index.ts'
import {ElMessageBox} from 'element-plus'
import {deletePqDev, downloadTemplate, exportPqDev, getPqDev, getPqDevList, importPqDev} from '@/api/device/device/index'
import {uploadReportToCloud} from '@/api/device/report/index'
import {ElMessage, ElMessageBox} from 'element-plus'
import {onBeforeMount, reactive, ref} from 'vue'
import {useAppSceneStore, useModeStore} from '@/stores/modules/mode'
@@ -151,6 +155,11 @@ const columns = reactive<ColumnProps<Device.ResPqDev>[]>([
minWidth: 130,
},
{
prop: 'ip',
label: 'IP',
minWidth: 130,
},
{
prop: 'manufacturer',
label: '设备厂家',
@@ -258,6 +267,40 @@ const importFile = async (pattern: string) => {
}
// 报告上传
const uploadFile = async () => {
const selectedRows = proTable.value?.selectedList || []
if (selectedRows.length === 0) {
// 没有选择设备,弹出确认框询问是否处理全部
ElMessageBox.confirm('未选择被检设备,是否对全部设备进行报告上传?', '提示', {
type: 'warning',
confirmButtonText: '全部上传',
cancelButtonText: '取消'
}).then(() => {
// 用户确认全部上传,传递空数组或特殊标识
handleReportUpload([])
}).catch(() => {
// 用户取消
})
} else {
// 有选择设备使用选中的设备ID
const selectedIds = selectedRows.map(row => row.id)
handleReportUpload(selectedIds)
}
}
// 处理报告上传
const handleReportUpload = async (deviceIds: string[]) => {
try {
await uploadReportToCloud(deviceIds)
ElMessage.success('报告上传成功')
} catch (error) {
ElMessage.error('报告上传失败')
console.error('报告上传错误:', error)
}
}
onBeforeMount(async () => {
const response = await getPqDev()
devTypeOptions.value = (response.data as Device.ResDev[]).map(item => ({

View File

@@ -204,7 +204,11 @@ const waveList = [
{
fchagFre: '2400',
fchagValue: '0.77'
}
},
{
fchagFre: '4000',
fchagValue: '2.4'
}
]
},
{

View File

@@ -64,12 +64,12 @@
<el-radio :value="0"></el-radio>
</el-radio-group>
</el-form-item>
<el-form-item label="关联报告模版" :label-width="100" prop='associateReport'>
<!-- <el-form-item label="关联报告模版" :label-width="100" prop='associateReport'>
<el-radio-group v-model="formContent.associateReport">
<el-radio :value="1"></el-radio>
<el-radio :value="0"></el-radio>
</el-radio-group>
</el-form-item>
</el-form-item> -->
<el-form-item label="模版名称" prop="reportTemplateName" :label-width="100" v-if="formContent.associateReport === 1">
<el-select v-model="formContent.reportTemplateName" placeholder="请选择报告模版" autocomplete="off" >
<el-option
@@ -119,6 +119,12 @@
import { type ErrorSystem } from '@/api/device/interface/error';
import { type Device } from '@/api/device/interface/device';
import {getPqReportAllName,getPqReportAllVersion} from '@/api/device/report/index.ts'
import {useAppSceneStore} from "@/stores/modules/mode";
import { fromPairs } from 'lodash';
import { el } from 'element-plus/es/locale';
const AppSceneStore = useAppSceneStore()
const dictStore = useDictStore()
// 定义弹出组件元信息
const dialogFormRef = ref()
@@ -348,22 +354,10 @@ const open = async (sign: string,
mode.value = currentMode
titleType.value = sign
isSelectDisabled.value = false
if (data.id) {
if(data.testState === 0){
isSelectDisabled.value = false
}else{
isSelectDisabled.value = true
}
Object.assign(formContent,{ ...data })
} else {
resetFormContent()
}
// 重置表单
dialogFormRef.value?.resetFields()
if(sign == 'add')
{
resetFormContent()
const [pqSource_Result, PqScript_Result, PqErrSys_Result,pqDevList_Result,pqReportName_Result] = await Promise.all([
getTestSourceList(data),
getPqScriptList(data),
@@ -373,8 +367,6 @@ const open = async (sign: string,
]);
if (Array.isArray(pqReportName_Result.data)) {
pqReportName.value = pqReportName_Result.data.map(item => ({ name: item }));
} else {
@@ -390,14 +382,23 @@ const open = async (sign: string,
boundPqDevList.value = [];
//楼下场景新增下拉框需要默认
formContent.scriptId = pqScriptList.value[0].id;
formContent.errorSysId = pqErrSysList.value[0].id;
formContent.sourceIds = pqSourceList.value[0].id;
formContent.datasourceIds = dictStore.getDictData('Datasource')[0].code;
formContent.dataRule = dictStore.getDictData('Data_Rule')[0].id;
formContent.scriptId = pqScriptList.value[0]?.id ?? '';
formContent.errorSysId = pqErrSysList.value[0]?.id ?? '';
formContent.sourceIds = pqSourceList.value[0]?.id ?? '';
formContent.datasourceIds = dictStore.getDictData('Datasource')[0]?.code ?? '';
formContent.dataRule = dictStore.getDictData('Data_Rule')[0]?.id ?? '';
}else{//编辑时先给表单赋值(这会没接收被检设备),需要手动再给被检设备复制后整体表单赋值
if(data.testState === 0){
isSelectDisabled.value = false
}else{
isSelectDisabled.value = true
}
Object.assign(formContent,{ ...data })
const [pqSource_Result, PqScript_Result, PqErrSys_Result,boundPqDevList_Result, unboundPqDevList_Result,pqReportName_Result] = await Promise.all([
getTestSourceList(data),
getPqScriptList(data),
@@ -444,6 +445,13 @@ const open = async (sign: string,
}
value.value = boundPqDevList.value.map((i: { id: { toString: () => any } }) => i.id.toString());
if(AppSceneStore.currentScene == "1"){//楼下场景不用报告模版
formContent.associateReport = 0
}else{
formContent.associateReport = 1
}
// 所有数据加载完成后显示对话框
dialogVisible.value = true;
}

View File

@@ -15,11 +15,16 @@
</el-form-item>
</el-col>
<el-col :span="8">
<el-form-item label='检测最大次数' prop='maxTime' :label-width="110">
<el-form-item label='检测最大次数' prop='maxTime' :label-width="140">
<!-- <el-input-number v-model='TestConfigForm.maxTime' :min='1' :max='999' onkeypress="return (/[\d]/.test(String.fromCharCode(event.keyCode)))"/>-->
<el-input number v-model.number='TestConfigForm.maxTime' placeholder="请输入检测最大次数" onkeypress="return (/[\d]/.test(String.fromCharCode(event.keyCode)))"/>
</el-form-item>
</el-col>
<el-col :span="8">
<el-form-item label='误差保留小数位' prop='scale' :label-width="140">
<el-input number v-model.number='TestConfigForm.scale' placeholder="请输入误差保留小数位" onkeypress="return (/[\d]/.test(String.fromCharCode(event.keyCode)))"/>
</el-form-item>
</el-col>
<!-- <el-col :span="8">-->
<!-- <el-form-item label='数据处理原则' prop='dataRule' :label-width="140">-->
<!-- <el-select v-model="TestConfigForm.dataRule" clearable placeholder="请选择数据处理原则">-->
@@ -229,6 +234,7 @@ const TestConfigForm = ref<Base.ResTestConfig>({
autoGenerate: 0,
maxTime: 3,
state: 1, //状态
scale:4,
})
const RegResForm = ref<VersionRegister.ResSys_Reg_Res>({
@@ -259,6 +265,10 @@ const rules = computed(() => {
{required: true, trigger: 'blur', message: '检测最大次数必填!'},
{pattern: /^(?:[1-9]|[1-9][0-9]|[1-9][0-9]{2})$/, message: '检测最大次数为1~999的正整数', trigger: 'blur'}
],
scale: [
{required: true, trigger: 'blur', message: '误差保留小数位必填!'},
{pattern: /^[4-6]$/, message: '误差保留小数位为4~6的整数', trigger: 'blur'}
],
realTime: [
{required: true, trigger: 'blur', message: '实时数据有效组数必填!'},
{pattern: /^(?:[1-9]|[1-9][0-9]|[1-9][0-9]{2})$/, message: '实时数据有效组数为1~999的正整数', trigger: 'blur'}
@@ -271,6 +281,7 @@ const rules = computed(() => {
{required: true, trigger: 'blur', message: '闪变数据有效组数必填!'},
{pattern: /^(?:[1-9]|[1-9][0-9]|[1-9][0-9]{2})$/, message: '闪变数据有效组数为1~999的正整数', trigger: 'blur'}
],
});