zhywpt-sp/static/etcUtil/index.js

/**obu蓝牙设备SDK */
// const wjApi = require("../etc/WJAPI/wjBleAPI");
// import * as wjApi from '../../lib/etc/WJAPI/wjBleAPI'
// const jlApi = require("../etc/JLAPI/JLObuSDK.js");
// import * as jlApi from '../../lib/etc/JLAPI/JLObuSDK.js'
const jyApi = require("../etc/JYAPI/GenvictBleUtil.js");
// import * as jlQZApi from '../../lib/etc/JLQZAPI/JLObuSDK.js'
const atApi = require("../etc/ATAPI/ArtcBleUtil.js");
// import * as atApi from '../../lib/etc/ATAPI/ArtcBleUtil.js'

// import * as jtApi from '../../lib/etc/JTAPI/BleUtil.js'
const wqApi = require("../etc/WQAPI/WCDObuSdk.js");
// import * as wqApi from '../../lib/etc/WQAPI/WCDObuSdk.js'
const cgApi = require("../etc/CGAPI/cguBle.js");
// import * as cgApi from '../../lib/etc/CGAPI/cguBle.js'
// const tdApi = require("../etc/TDAPI/TDRObuSDK.js");
// import * as tdApi from '../../lib/etc/TDAPI/TDRObuSDK.js'
// import * as zzApi from '../../lib/etc/WJAPI/wjBleAPI'

const datas = require("./datas.js");
const tools = require('./tools.js');
let jlApi = require("../../static/etc/JLAPI/JLObuSDK.js"); //聚力SDK
let wjApi = require("../etc/WJAPI/wjBleAPI");
let tdApi = require("../etc/TDAPI/TDRObuSDK.js");
let zzApi = require("../etc/WJAPI/wjBleAPI.js");
let jtApi = require("../etc/JTAPI/BleUtil.js");
const jlQZApi = require("../etc/JLQZAPI/JLObuSDK.js");
let kcApi = require("../etc/kcBle/kcBleAPI.js");
let mcApi = require("../etc/MCAPI/MCObuSDK.js");
// let jyApiEtc = require("../etc/JYAPI-ETC/jy-bluetooth-obu-wechatmp.js"); //前装-金溢
let ArtcBleUtilApi = require("../etc/ArtcBleAPI/ArtcGuiZhouAPI.js");//艾特斯 ETC- 5201 国密
let mcApi9901 = require("../etc/MCSDK9901/BleUtil9901.js");  //9901 和 国密5201单片
import { login } from "../../utils/network/api";
import { getItem } from "../../utils/storage";
// import { startHeartbeat, stopHeartbeat } from "@/pages/bluetooth/heartbeatService"

if (getItem('environment') == 'ZFB') {
	tdApi = require("../etc/TDRAPI/TDRObuSDK.js");
	jlApi = require("../etc/JLObuSDK/JLObuSDK.js");
	wjApi = require("../etc/wjBle/WJBleAPI");
	zzApi = require("../etc/wjBle/WJBleAPI.js");
	jtApi = require("../etc/JTAPIS/BleUtil.js");
}
// 9901
const wjApi9901 = require("../etc/WJSDK9901/wjBleAPI.js");
/**
 * 断开蓝牙
 */
function disconnectDevice() {
	var connectPrefixName = datas.getData("connectPrefixName");
	console.log('断开蓝牙connectPrefixName', getItem('environment'), tdApi, datas.getData("connectPrefixName"))
	switch (connectPrefixName) {
		case "ETC":
		    let obj = ""
			if (datas.getData("deviceName").includes("KC") || datas.getData("deviceName").includes("K")) {
				obj=kcApi
			} else if (datas.getData("deviceName").includes("JL")) {
				obj=jlQZApi
			} else if (datas.getData("deviceName").includes("WJ")) {
				obj=wjApi9901
			} else if (datas.getData("deviceName").includes("ATS")) {
				obj=ArtcBleUtilApi
			}else if (datas.getData("deviceName").includes("MC")) {
				obj=mcApi9901
			}else if (datas.getData("deviceName").includes("WQ")) {
				obj=wqApi
			}
			obj.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			// else if (datas.getData("deviceName").includes("JY")) {
			// 	jyApiEtc.disconnectDevice(function(res) {
			// 		datas.setData("bluLinkStatus", false);
			// 		datas.setData("connectPrefixName", "");
			// 	});
			// }
			break;
		case "WJ":
			wjApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
		case "JL":
			jlApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
		case "BY":
			jyApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
		
		case "JY":
			jyApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
		case "AT":
			atApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
				// console.log(res)
			});
			break;
		case "JT":
			jtApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
		case "WQ":
			wqApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
		case "CG":
			cgApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
		case "TD":
			console.log(tdApi, '==================================')
			tdApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
				console.log(res, '=============')
			});
			break;
		case "ZZ":
			zzApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
        case "MC":
			mcApi.disconnectDevice(function(res) {
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
			});
			break;
		default:
			break;
	}
}

/**
 * 透传
 * type 10 写卡 20 写OBU
 */
function transCmd(cmdArr, type, func, callBack = null) {
	var connectPrefixName = datas.getData("connectPrefixName");
	console.log('指令执行内容1', datas.getData("connectPrefixName"), cmdArr, type)
	switch (connectPrefixName) {
		case "ETC":
			//-------------deviceName前装-科畅
			console.log("datas.-----",datas.getData("deviceName"),datas.getData("deviceName").includes("KC"),datas.getData("deviceName").includes("K"))
			let obj = ""
			if (datas.getData("deviceName").includes("KC")|| datas.getData("deviceName").includes("K")) {
				console.log('kc执行内容====', cmdArr, type)
				obj=kcApi
			} else if (datas.getData("deviceName").includes("JL")) {
				obj=jlQZApi
			} else if (datas.getData("deviceName").includes("WJ")) {
				obj=wjApi9901
			} else if (datas.getData("deviceName").includes("ATS")) {
				obj=ArtcBleUtilApi
			} else if (datas.getData("deviceName").includes("MC")) {
				obj=mcApi9901
			}else if (datas.getData("deviceName").includes("WQ")) {
				obj=wqApi
			}
			obj.transCmd(cmdArr, type, function(res) {
				console.log(datas.getData("deviceName")+'执行内容====11111', res)
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			// else if (datas.getData("deviceName").includes("JY")) {
			// 	jyApiEtc.transCmd(cmdArr, type, function(res) {
			// 		console.log('JY执行内容====11111', res)
			// 		if (res.code == 0) {
			// 			func(res.data);
			// 		} else {
			// 			if (callBack != null) {
			// 				callBack(res);
			// 			} else {
			// 				alertF(res.msg);
			// 			}
			// 		}
			// 	});
			// }
		
			break;
		case "WJ":
			console.log('WJ执行内容====', cmdArr, type)
			wjApi.transCmd(cmdArr, type, function(res) {
				console.log('WJ执行内容====11111', res)
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "JL":
			console.log('JL执行内容====', cmdArr, type)
			jlApi.transCmd(cmdArr, type, function(res) {
				console.log('JL执行内容====11111', res)
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "BY":
			console.log('JL执行内容====', cmdArr, type)
			jyApi.transCmd(cmdArr, type, function(res) {
				console.log('JL执行内容====11111', res)
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "BY":
			console.log('JL执行内容====', cmdArr, type)
			jyApi.transCmd(cmdArr, type, function(res) {
				console.log('JL执行内容====11111', res)
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res.msg);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "JY":
			jyApi.transCmd(cmdArr, type, function(res) {
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "AT":
			atApi.transCmd(cmdArr, type, function(res) {
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "JT":
			jtApi.transCmd(cmdArr, type, function(res) {
				console.log('指令执行结果：', res)
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "WQ":
			wqApi.transCmd(cmdArr, type, function(res) {
				console.log('握奇执行结果：===========', res)
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "CG":
			cgApi.transCmd(cmdArr, type, function(res) {
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "TD":
			console.log('TD执行内容====', cmdArr, type)
			tdApi.transCmd(cmdArr, type, function(res) {
				console.log('TD执行内容====123', cmdArr, type,res)
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "ZZ":
			zzApi.transCmd(cmdArr, type, function(res) {
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
		case "MC":
			mcApi.transCmd(cmdArr, type, function(res) {
				if (res.code == 0) {
					func(res.data);
				} else {
					if (callBack != null) {
						callBack(res);
					} else {
						alertF(res.msg);
					}
				}
			});
			break;
			
		default:
			datas.setData("bluLinkStatus", false);
			datas.setData("connectPrefixName", "");
			if (callBack != null) {
				callBack("没有找到设备"+connectPrefixName);
			} else {
				alertF("没有找到设备");
			}
			break;
	}
}

/**
 * 透传
 * type 10 写卡 20 写OBU
 */
function transCmdAfter(cmdArr, type, callBack = null) {
	var connectPrefixName = datas.getData("connectPrefixName");
	console.log('指令执行内容1', datas.getData("connectPrefixName"), cmdArr, type)
	return new Promise((resolve, reject) => {
		switch (connectPrefixName) {
			case "ETC": 
				//-------------deviceName前装-科畅
				console.log("datas.-----",datas.getData("deviceName"),datas.getData("deviceName").includes("KC"),datas.getData("deviceName").includes("K"))
				let obj = ""
				if (datas.getData("deviceName").includes("KC")|| datas.getData("deviceName").includes("K")) {
					console.log('kc执行内容====', cmdArr, type)
					obj=kcApi
				} else if (datas.getData("deviceName").includes("JL")) {
					obj=jlQZApi
				} else if (datas.getData("deviceName").includes("WJ")) {
					obj=wjApi9901
				} else if (datas.getData("deviceName").includes("ATS")) {
					obj=ArtcBleUtilApi
				} else if (datas.getData("deviceName").includes("MC")) {
					obj=mcApi9901
				}else if (datas.getData("deviceName").includes("WQ")) {
					obj=wqApi
				}
				obj.transCmd(cmdArr, type, function(res) {
					console.log(datas.getData("deviceName")+'执行内容====11111', res)
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				// else if (datas.getData("deviceName").includes("JY")) {
				// 	jyApiEtc.transCmd(cmdArr, type, function(res) {
				// 		console.log('JY执行内容====11111', res)
				// 		if (res.code == 0) {
				// 			resolve(res.data);
				// 		} else {
				// 			if (callBack != null) {
				// 				callBack(res);
				// 			} else {
				// 				alertF(res.msg);
				// 			}
				// 		}
				// 	});
				// }
			
				break;
			case "WJ":
				console.log('WJ执行内容====', cmdArr, type)
				wjApi.transCmd(cmdArr, type, function(res) {
					console.log('WJ执行内容====11111', res)
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "JL":
				console.log('JL执行内容====', cmdArr, type)
				jlApi.transCmd(cmdArr, type, function(res) {
					console.log('JL执行内容====11111', res)
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "BY":
				console.log('JL执行内容====', cmdArr, type)
				jyApi.transCmd(cmdArr, type, function(res) {
					console.log('JL执行内容====11111', res)
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "BY":
				console.log('JL执行内容====', cmdArr, type)
				jyApi.transCmd(cmdArr, type, function(res) {
					console.log('JL执行内容====11111', res)
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res.msg);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "JY":
				jyApi.transCmd(cmdArr, type, function(res) {
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "AT":
				atApi.transCmd(cmdArr, type, function(res) {
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "JT":
				jtApi.transCmd(cmdArr, type, function(res) {
					console.log('指令执行结果：', res)
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "WQ":
				wqApi.transCmd(cmdArr, type, function(res) {
					console.log('握奇执行结果：===========', res)
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "CG":
				cgApi.transCmd(cmdArr, type, function(res) {
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "TD":
				console.log('TD执行内容====', cmdArr, type)
				tdApi.transCmd(cmdArr, type, function(res) {
					console.log('TD执行内容====123', cmdArr, type,res)
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "ZZ":
				zzApi.transCmd(cmdArr, type, function(res) {
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
			case "MC":
				mcApi.transCmd(cmdArr, type, function(res) {
					if (res.code == 0) {
						resolve(res.data);
					} else {
						if (callBack != null) {
							callBack(res);
						} else {
							alertF(res.msg);
						}
					}
				});
				break;
				
			default:
				datas.setData("bluLinkStatus", false);
				datas.setData("connectPrefixName", "");
				if (callBack != null) {
					callBack("没有找到设备"+connectPrefixName);
				} else {
					alertF("没有找到设备");
				}
				break;
		}
	});
}
/**
 * 透传
 * type 10 写卡 20 写OBU
 */
function transCmdArrAfter(cmdArr, type) {
	return new Promise(async (resole, reject) => {
		try {
			console.log('指令执行内容', cmdArr, type)
			// 判断是否为数组
			if (typeof cmdArr === 'string') {
				// 如果是字符串，转换为字符数组
				cmdArr = cmdArr.split(',');
			}
			const datas = {}
			for (let i = 0; i < cmdArr.length; i++) {
				const cmdStr = cmdArr[i]
				console.log(i, cmdStr, 'cmdStr');
				const itemDatas = await transCmdAfter([cmdStr], type)
				datas[cmdStr] = itemDatas
			}
			console.log(datas, '----------执行结果---------', cmdArr, type);
			for (let i in datas) {
        console.log(" datas[i]", datas[i])
				let itemCode = datas[i][0].substring(datas[i][0].length - 4);
				if (itemCode !== '9000') {
					reject(datas);
					uni.hideLoading()
					return
				}
				datas[i][0] = datas[i][0].toUpperCase();
			}
			resole(datas)
		} catch (e) {
			//TODO handle the exception
			console.log('错误错误', e);
			reject(e);
		}


	})
}
/**
 * 提示加关蓝牙
 */
function alertF(msg) {
	// 隐藏加载框
	// tools.hideLoadingAlert();
	// 提示对话框
	tools.showModalAlert(msg);
	// stopHeartbeat();
}

module.exports = {
	disconnectDevice,
	transCmd,
	transCmdAfter,
	transCmdArrAfter
};