# import os
# import threading
#
# from jpype import *
# import jpype
# # jvmPath = jpype.getDefaultJVMPath()
# # jvmPath = os.path.join(os.getcwd(),"endpoints","web","corretto-1.8.0_362","jre","bin","server","jvm.dll")
# # jarPath = os.path.join(os.getcwd(),"endpoints","web","RSNetDevice-2.2.2.jar")
# # jpype.startJVM(jvmPath, f"-Djava.class.path={jarPath}")
# jvmPath = u'C:\\Users\\HP\\.jdks\\corretto-1.8.0_362\\jre\\bin\\server\\jvm.dll'
# jpype.startJVM(jvmPath, "-Djava.class.path=C:\\Users\\HP\\IdeaProjects\\JavaSDKV2.2.2\\JavaSDKV2.2.2\\RSNetDevice-2.2.2.jar")
# # jpype.java.lang.System.out.println("hello world!")
# # jpype.shutdownJVM()
#
# # 定义全局变量
# global_temp = None
# global_voc = None
# # 赋值函数
# def set_global_temp_value(value):
#     global global_temp
#     global_temp = value
#
# # 返回数据的接口函数
# def get_global_temp_value():
#     return global_temp
#
# def set_global_voc_value(value):
#     global global_voc
#     global_voc = value
#
# # 返回数据的接口函数
# def get_global_voc_value():
#     return global_voc
#
# IDataListener = JClass('com.jnrsmcu.sdk.netdevice.IDataListener')
# LoginData = JClass('com.jnrsmcu.sdk.netdevice.LoginData')
# NodeData = JClass('com.jnrsmcu.sdk.netdevice.NodeData')
# RSServer = JClass('com.jnrsmcu.sdk.netdevice.RSServer')
# RealTimeData = JClass('com.jnrsmcu.sdk.netdevice.RealTimeData')
# StoreData = JClass('com.jnrsmcu.sdk.netdevice.StoreData')
# TelecontrolAck = JClass('com.jnrsmcu.sdk.netdevice.TelecontrolAck')
# TimmingAck = JClass('com.jnrsmcu.sdk.netdevice.TimmingAck')
#
#
# @JImplements("com.jnrsmcu.sdk.netdevice.IDataListener")
# class MyImpl:
#     @JOverride
#     def receiveTimmingAck(self, data):
#         print('receiveTimmingAck!')
#     @JOverride
#     def receiveTelecontrolAck(self, data):
#         print('receiveTelecontrolAck!')
#     @JOverride
#     def receiveStoreData(self, data):
#         print('receiveStoreData!')
#     @JOverride
#     def receiveRealtimeData(self, data):
#         try:
#             for nd in data.getNodeList():
#                 print("DeviceId:"+str(data.getDeviceId())
#                 + " NodeId:" + str(nd.getNodeId()) + " Tem:" + str(nd.getTem())
#                 + " Hum:" + str(nd.getHum()) + " Lng:" + str(data.getLng())
#                 + " Lat:" + str(data.getLat()) + " CoordinateType:"
#                 + str(data.getCoordinateType()) + " RelayStatus:"
#                 + str(data.getRelayStatus()))
#                 set_global_temp_value(nd.getTem())
#                 set_global_voc_value(nd.getHum())
#         except Exception as e:
#             print(e)
#     @JOverride
#     def receiveLoginData(self, data):
#         print('receiveLoginData!')
#     @JOverride
#     def receiveParamIds(self, data):
#         print('receiveParamIds!')
#     @JOverride
#     def receiveParam(self, data):
#         print('receiveParam!')
#     @JOverride
#     def receiveWriteParamAck(self, jstr):
#         print('receiveWriteParamAck!')
#     @JOverride
#     def receiveTransDataAck(self, jstr):
#         print('receiveTransDataAck!')
# def startTempVocListener():
#     rsServer = RSServer.Initiate(8087)
#     rsServer.addDataListener(MyImpl())
#     rsServer.start()
# def startTempVocListenerThread():
#     thread = threading.Thread(target=startTempVocListener)
#     thread.daemon = True  # 设置为守护线程，使应用退出时自动关闭
#     thread.start()
#