Skip to content

V
vue_django_test
Commit 2030137d by 周田
Options

feat：发送消息给 device 模块

parent 7d680efc
Showing with 107 additions and 417 deletions
chat/urls.py
# chat/urls.py # chat/urls.py
from django.urls import path from django.urls import path
from . import views
urlpatterns = [ urlpatterns = [
......
mqtt/auto_generate_python/mod_agi_pb2.py deleted 100644 → 0
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: mod-agi.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rmod-agi.proto\x12\x15satllite.protobuf.agi\"\xd0\x01\n\nCalcTleReq\x12\x0f\n\x07noradID\x18\x01 \x01(\x05\x12\x11\n\tnoradName\x18\x02 \x01(\t\x12\x0c\n\x04year\x18\x03 \x01(\x05\x12\r\n\x05month\x18\x04 \x01(\x05\x12\x0b\n\x03\x64\x61y\x18\x05 \x01(\x05\x12\x0c\n\x04hour\x18\x06 \x01(\x05\x12\x0e\n\x06minute\x18\x07 \x01(\x05\x12\x0e\n\x06second\x18\x08 \x01(\x05\x12\t\n\x01\x61\x18\t \x01(\x02\x12\n\n\x02\x65\x65\x18\n \x01(\x02\x12\t\n\x01I\x18\x0b \x01(\x02\x12\x0c\n\x04raan\x18\x0c \x01(\x02\x12\x0b\n\x03\x61rc\x18\r \x01(\x02\x12\t\n\x01m\x18\x0e \x01(\x02\"9\n\nCalcTleRet\x12\r\n\x05line0\x18\x01 \x01(\t\x12\r\n\x05line1\x18\x02 \x01(\t\x12\r\n\x05line2\x18\x03 \x01(\t\"\xba\x02\n\rCalcReportReq\x12\x15\n\rstartDateTime\x18\x01 \x01(\t\x12\x13\n\x0b\x65ndDateTime\x18\x02 \x01(\t\x12\x10\n\x08latitude\x18\x03 \x01(\x01\x12\x11\n\tlongitude\x18\x04 \x01(\x01\x12\x10\n\x08\x61ltitude\x18\x05 \x01(\x01\x12\r\n\x05slice\x18\x06 \x01(\x01\x12\x0e\n\x06minAzi\x18\x07 \x01(\x01\x12\x0e\n\x06maxAzi\x18\x08 \x01(\x01\x12\x0e\n\x06minEle\x18\t \x01(\x01\x12\x0e\n\x06maxEle\x18\n \x01(\x01\x12\x0f\n\x07minDist\x18\x0b \x01(\x01\x12\x0f\n\x07maxDist\x18\x0c \x01(\x01\x12\x12\n\npointSlice\x18\r \x01(\x01\x12\x14\n\x0cpointCollect\x18\x0e \x01(\x05\x12\r\n\x05line0\x18\x0f \x01(\t\x12\r\n\x05line1\x18\x10 \x01(\t\x12\r\n\x05line2\x18\x11 \x01(\t\"e\n\rCalcReportRet\x12(\n\x04xxds\x18\x01 \x03(\x0b\x32\x1a.satllite.protobuf.agi.Xxd\x12*\n\x05tasks\x18\x02 \x03(\x0b\x32\x1b.satllite.protobuf.agi.Task\";\n\x03Xxd\x12\n\n\x02\x64t\x18\x01 \x01(\t\x12\x0b\n\x03lon\x18\x02 \x01(\x01\x12\x0b\n\x03lat\x18\x03 \x01(\x01\x12\x0e\n\x06height\x18\x04 \x01(\x01\"\xb2\x01\n\x04Task\x12\r\n\x05start\x18\x01 \x01(\t\x12\x0b\n\x03\x65nd\x18\x02 \x01(\t\x12\x10\n\x08startAzi\x18\x03 \x01(\x01\x12\x0e\n\x06\x65ndAzi\x18\x04 \x01(\x01\x12\x10\n\x08startEle\x18\x05 \x01(\x01\x12\x0e\n\x06maxEle\x18\x06 \x01(\x01\x12\x0f\n\x07minDist\x18\x07 \x01(\x01\x12\x0f\n\x07maxDist\x18\x08 \x01(\x01\x12(\n\x04obss\x18\t \x03(\x0b\x32\x1a.satllite.protobuf.agi.Obs\":\n\x03Obs\x12\n\n\x02\x64t\x18\x01 \x01(\t\x12\x0b\n\x03\x61zi\x18\x02 \x01(\x01\x12\x0b\n\x03\x65le\x18\x03 \x01(\x01\x12\r\n\x05range\x18\x04 \x01(\x01\x42\x0cZ\n../protogob\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'mod_agi_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\n../protogo'
_CALCTLEREQ._serialized_start=41
_CALCTLEREQ._serialized_end=249
_CALCTLERET._serialized_start=251
_CALCTLERET._serialized_end=308
_CALCREPORTREQ._serialized_start=311
_CALCREPORTREQ._serialized_end=625
_CALCREPORTRET._serialized_start=627
_CALCREPORTRET._serialized_end=728
_XXD._serialized_start=730
_XXD._serialized_end=789
_TASK._serialized_start=792
_TASK._serialized_end=970
_OBS._serialized_start=972
_OBS._serialized_end=1030
# @@protoc_insertion_point(module_scope)
mqtt/auto_generate_python/mod_return_pb2.py deleted 100644 → 0
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: mod-return.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
from google.protobuf import any_pb2 as google_dot_protobuf_dot_any__pb2
import TDSCmd_pb2 as TDSCmd__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10mod-return.proto\x1a\x19google/protobuf/any.proto\x1a\x0cTDSCmd.proto\"\xdb\x01\n\rReturnElement\x12\x1a\n\x06result\x18\x01 \x01(\x0e\x32\n.CodeValue\x12\x0b\n\x03msg\x18\x02 \x01(\t\x12\r\n\x05\x65nMsg\x18\x03 \x01(\t\x12\"\n\x04\x64\x61ta\x18\x04 \x01(\x0b\x32\x14.google.protobuf.Any\x12\"\n\x04list\x18\x05 \x03(\x0b\x32\x14.google.protobuf.Any\x12\x11\n\tdstSiteNo\x18\x06 \x01(\t\x12\x11\n\tsrcSiteNo\x18\x07 \x01(\t\x12\x0f\n\x07noArray\x18\x08 \x03(\t\x12\x13\n\x0bsiteNoArray\x18\t \x03(\tB\x0cZ\n../protogob\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'mod_return_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\n../protogo'
_RETURNELEMENT._serialized_start=62
_RETURNELEMENT._serialized_end=281
# @@protoc_insertion_point(module_scope)
mqtt/auto_generate_python/mod_satellite_pb2.py deleted 100644 → 0
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: mod-satellite.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13mod-satellite.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\xe4\x03\n\x13RetSatelliteElement\x12\r\n\x05norad\x18\x02 \x01(\t\x12\x0c\n\x04\x63ode\x18\x03 \x01(\t\x12\x0e\n\x06\x63nName\x18\x04 \x01(\t\x12\x0e\n\x06\x65nName\x18\x05 \x01(\t\x12\x11\n\tavailable\x18\x06 \x01(\x08\x12\x10\n\x08priority\x18\x07 \x01(\x05\x12\x16\n\x0epriorityBySite\x18\x08 \x01(\x05\x12,\n\x04\x62\x61se\x18\t \x03(\x0b\x32\x1e.RetSatelliteElement.BaseEntry\x12(\n\x07\x64\x65tails\x18\n \x03(\x0b\x32\x17.RetSiteLevel3Satellite\x12\x34\n\x08\x65lements\x18\x0b \x03(\x0b\x32\".RetSatelliteElement.ElementsEntry\x12,\n\nworkParams\x18\x0c \x01(\x0b\x32\x18.RetSatelliteWorkElement\x12\x0b\n\x03off\x18\r \x01(\x08\x12,\n\x08\x63reateDt\x18\x0e \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x1a+\n\tBaseEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a/\n\rElementsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xbc\x01\n\x16RetSiteLevel3Satellite\x12\x0e\n\x06siteNo\x18\x01 \x01(\t\x12\x10\n\x08priority\x18\x02 \x01(\x05\x12\x11\n\tavailable\x18\x03 \x01(\x08\x12#\n\x0cobserveGrade\x18\x04 \x01(\x0e\x32\r.ObserveGrade\x12+\n\tworkParam\x18\x05 \x01(\x0b\x32\x18.RetSatelliteWorkElement\x12\x1b\n\x13workParamConfigName\x18\x06 \x01(\t\"\xa2\x01\n\rSatelliteList\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12*\n\x04sort\x18\x03 \x01(\x0e\x32\x1c.SatelliteList.satelliteSort\"F\n\rsatelliteSort\x12\x19\n\x15satelliteSort_default\x10\x00\x12\x1a\n\x16satelliteSort_forecast\x10\x01\"?\n\x0fSatelliteDetail\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\r\n\x05norad\x18\x03 \x01(\t\"D\n\x16SatelliteElementUpdate\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x0b\n\x03tle\x18\x03 \x01(\t\"\xc8\x01\n\x13SatelliteBaseUpdate\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\r\n\x05norad\x18\x03 \x01(\t\x12\x0e\n\x06\x63nName\x18\x04 \x01(\t\x12\x0c\n\x04\x63ode\x18\x05 \x01(\t\x12\x10\n\x08\x63odeName\x18\x06 \x01(\t\x12\x0f\n\x07\x63ountry\x18\x07 \x01(\t\x12\x11\n\torbitType\x18\x08 \x01(\t\x12\x0f\n\x07purpose\x18\t \x01(\t\x12\x0e\n\x06remark\x18\n \x01(\t\x12\x0e\n\x06\x65nName\x18\x0b \x01(\t\"A\n\x0cSatelliteDel\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x12\n\nnoradArray\x18\x03 \x03(\t\"6\n\x15SatellitePriorityList\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\"L\n\x17SatellitePriorityUpdate\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x12\n\nnoradArray\x18\x03 \x03(\t\"6\n\x14SatelliteElementLoad\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0f\n\x07idArray\x18\x02 \x03(\t\"\x90\x01\n\x1bSatelliteElementLoadAutoSet\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x0f\n\x07loadUrl\x18\x03 \x01(\t\x12\x0f\n\x07loadHMS\x18\x04 \x01(\t\x12\x15\n\rloadFrequency\x18\x06 \x01(\x05\x12\x19\n\x11tleStrategyStatus\x18\x08 \x01(\x08\"\xe9\x01\n\x15SatelliteDetailUpdate\x12\r\n\x05token\x18\x01 \x01(\x05\x12\r\n\x05norad\x18\x02 \x01(\t\x12\x0e\n\x06siteNo\x18\x03 \x01(\t\x12\x0e\n\x06\x63nName\x18\x04 \x01(\t\x12\x0c\n\x04\x63ode\x18\x05 \x01(\t\x12\x10\n\x08\x63odeName\x18\x06 \x01(\t\x12\x0f\n\x07\x63ountry\x18\x07 \x01(\t\x12\x11\n\torbitType\x18\x08 \x01(\t\x12\x0f\n\x07purpose\x18\t \x01(\t\x12\x0e\n\x06remark\x18\n \x01(\t\x12\x0e\n\x06\x65nName\x18\x0b \x01(\t\x12\x1d\n\x06params\x18\x0c \x03(\x0b\x32\r.DetailParams\"c\n\x0c\x44\x65tailParams\x12\x0e\n\x06siteNo\x18\x01 \x01(\t\x12\x11\n\tavailable\x18\x02 \x01(\x08\x12\x1c\n\x05grade\x18\x03 \x01(\x0e\x32\r.ObserveGrade\x12\x12\n\nworkConfig\x18\x04 \x01(\x05\"\xc7\x01\n\x17RetSatelliteWorkElement\x12\r\n\x05norad\x18\x01 \x01(\t\x12\x10\n\x08\x63onfigId\x18\x02 \x01(\x05\x12\x0e\n\x06remark\x18\x03 \x01(\t\x12\x12\n\nconfigName\x18\x04 \x01(\t\x12\x10\n\x08\x63\x61tegory\x18\x05 \x01(\t\x12\x1a\n\x06params\x18\x06 \x03(\x0b\x32\n.WorkParam\x12\x0b\n\x03off\x18\x07 \x01(\x08\x12,\n\x08\x63reateDt\x18\x08 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"7\n\x16SatelliteWorkParamList\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\"\x9a\x01\n\x18SatelliteWorkParamUpdate\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\r\n\x05norad\x18\x03 \x01(\t\x12\x10\n\x08\x63onfigId\x18\x04 \x01(\x05\x12\x12\n\nconfigName\x18\x05 \x01(\t\x12\x0e\n\x06remark\x18\x06 \x01(\t\x12\x1a\n\x06params\x18\x07 \x03(\x0b\x32\n.WorkParam\"\xc5\x02\n\tWorkParam\x12\x0e\n\x06siteNo\x18\x01 \x01(\t\x12\x1c\n\x14XTrackerSigIntensity\x18\x06 \x01(\x05\x12\x1c\n\x14YTrackerSigIntensity\x18\x07 \x01(\x05\x12\x12\n\nXInitPhase\x18\x08 \x01(\x05\x12\x19\n\x11XPolarizationType\x18\t \x01(\x05\x12\x19\n\x11SPolarizationType\x18\n \x01(\x05\x12\x1c\n\x14XTrackerVoltageLimit\x18\x0b \x01(\x05\x12\x1c\n\x14STrackerVoltageLimit\x18\x0c \x01(\x05\x12\x1b\n\x13SUpPolarizationType\x18\r \x01(\x05\x12\x1b\n\x13XUpPolarizationType\x18\x0e \x01(\x05\x12\x16\n\x0eTrackingStatus\x18\x0f \x01(\x05\x12\x14\n\x0cTrackingBand\x18\x10 \x01(\x05\"X\n\x15SatelliteWorkParamDel\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12 \n\x08keyArray\x18\x03 \x03(\x0b\x32\x0e.NoradConfigId\"0\n\rNoradConfigId\x12\r\n\x05norad\x18\x01 \x01(\t\x12\x10\n\x08\x63onfigId\x18\x02 \x01(\x05\"T\n\x1fSatelliteWorkParamListForChoose\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x12\n\nnoradArray\x18\x03 \x03(\t*`\n\x0cObserveGrade\x12\x17\n\x13ObserveGradeDefault\x10\x00\x12\x11\n\rObserveGrade1\x10\x01\x12\x11\n\rObserveGrade2\x10\x02\x12\x11\n\rObserveGrade3\x10\x03\x42\x0cZ\n../protogob\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'mod_satellite_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\n../protogo'
_RETSATELLITEELEMENT_BASEENTRY._options = None
_RETSATELLITEELEMENT_BASEENTRY._serialized_options = b'8\001'
_RETSATELLITEELEMENT_ELEMENTSENTRY._options = None
_RETSATELLITEELEMENT_ELEMENTSENTRY._serialized_options = b'8\001'
_OBSERVEGRADE._serialized_start=2948
_OBSERVEGRADE._serialized_end=3044
_RETSATELLITEELEMENT._serialized_start=57
_RETSATELLITEELEMENT._serialized_end=541
_RETSATELLITEELEMENT_BASEENTRY._serialized_start=449
_RETSATELLITEELEMENT_BASEENTRY._serialized_end=492
_RETSATELLITEELEMENT_ELEMENTSENTRY._serialized_start=494
_RETSATELLITEELEMENT_ELEMENTSENTRY._serialized_end=541
_RETSITELEVEL3SATELLITE._serialized_start=544
_RETSITELEVEL3SATELLITE._serialized_end=732
_SATELLITELIST._serialized_start=735
_SATELLITELIST._serialized_end=897
_SATELLITELIST_SATELLITESORT._serialized_start=827
_SATELLITELIST_SATELLITESORT._serialized_end=897
_SATELLITEDETAIL._serialized_start=899
_SATELLITEDETAIL._serialized_end=962
_SATELLITEELEMENTUPDATE._serialized_start=964
_SATELLITEELEMENTUPDATE._serialized_end=1032
_SATELLITEBASEUPDATE._serialized_start=1035
_SATELLITEBASEUPDATE._serialized_end=1235
_SATELLITEDEL._serialized_start=1237
_SATELLITEDEL._serialized_end=1302
_SATELLITEPRIORITYLIST._serialized_start=1304
_SATELLITEPRIORITYLIST._serialized_end=1358
_SATELLITEPRIORITYUPDATE._serialized_start=1360
_SATELLITEPRIORITYUPDATE._serialized_end=1436
_SATELLITEELEMENTLOAD._serialized_start=1438
_SATELLITEELEMENTLOAD._serialized_end=1492
_SATELLITEELEMENTLOADAUTOSET._serialized_start=1495
_SATELLITEELEMENTLOADAUTOSET._serialized_end=1639
_SATELLITEDETAILUPDATE._serialized_start=1642
_SATELLITEDETAILUPDATE._serialized_end=1875
_DETAILPARAMS._serialized_start=1877
_DETAILPARAMS._serialized_end=1976
_RETSATELLITEWORKELEMENT._serialized_start=1979
_RETSATELLITEWORKELEMENT._serialized_end=2178
_SATELLITEWORKPARAMLIST._serialized_start=2180
_SATELLITEWORKPARAMLIST._serialized_end=2235
_SATELLITEWORKPARAMUPDATE._serialized_start=2238
_SATELLITEWORKPARAMUPDATE._serialized_end=2392
_WORKPARAM._serialized_start=2395
_WORKPARAM._serialized_end=2720
_SATELLITEWORKPARAMDEL._serialized_start=2722
_SATELLITEWORKPARAMDEL._serialized_end=2810
_NORADCONFIGID._serialized_start=2812
_NORADCONFIGID._serialized_end=2860
_SATELLITEWORKPARAMLISTFORCHOOSE._serialized_start=2862
_SATELLITEWORKPARAMLISTFORCHOOSE._serialized_end=2946
# @@protoc_insertion_point(module_scope)
mqtt/auto_generate_python/mod_site_pb2.py deleted 100644 → 0
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: mod-site.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
import mod_user_pb2 as mod__user__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0emod-site.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x0emod-user.proto\"\xb4\x03\n\x0eRetSiteElement\x12\n\n\x02no\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12&\n\x08operator\x18\x04 \x01(\x0b\x32\x14.RetAdminUserElement\x12\x0e\n\x06remark\x18\x05 \x01(\t\x12\x10\n\x08latitude\x18\x06 \x01(\x01\x12\x11\n\tlongitude\x18\x07 \x01(\x01\x12\x10\n\x08\x61ltitude\x18\x08 \x01(\x01\x12\x0e\n\x06parent\x18\t \x01(\t\x12+\n\x06params\x18\n \x03(\x0b\x32\x1b.RetSiteElement.ParamsEntry\x12+\n\x06\x65xtend\x18\x0b \x03(\x0b\x32\x1b.RetSiteElement.ExtendEntry\x12\x16\n\x0e\x61vailableArray\x18\x0c \x03(\t\x12\x0b\n\x03off\x18\r \x01(\x08\x12,\n\x08\x63reateDt\x18\x0e \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x1a-\n\x0bParamsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a-\n\x0b\x45xtendEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"<\n\x08SiteList\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x11\n\tavailable\x18\x03 \x01(\x08\"\x84\x02\n\nSiteUpdate\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12\x0e\n\x06remark\x18\x04 \x01(\t\x12\x10\n\x08latitude\x18\x05 \x01(\x01\x12\x11\n\tlongitude\x18\x06 \x01(\x01\x12\x10\n\x08\x61ltitude\x18\x07 \x01(\x01\x12\x0f\n\x07\x63ountry\x18\x08 \x01(\t\x12\r\n\x05place\x18\t \x01(\t\x12\x10\n\x08timeZone\x18\n \x01(\t\x12\x0f\n\x07voltage\x18\x0b \x01(\x01\x12\x12\n\ndeltaDelay\x18\x0c \x01(\x05\x12\x11\n\tbandwidth\x18\r \x01(\x01\x12\x18\n\x10networkOperators\x18\x0e \x01(\t\"\xc7\x01\n\x0fSiteParamUpdate\x12\r\n\x05token\x18\x01 \x01(\x05\x12\n\n\x02id\x18\x02 \x01(\x05\x12\r\n\x05slice\x18\x03 \x01(\x01\x12\x13\n\x0bminEleAngle\x18\x04 \x01(\x01\x12\x13\n\x0bmaxEleAngle\x18\x05 \x01(\x01\x12\x13\n\x0bminAziAngle\x18\x06 \x01(\x01\x12\x13\n\x0bmaxAziAngle\x18\x07 \x01(\x01\x12\x0f\n\x07minDist\x18\x08 \x01(\x01\x12\x0f\n\x07maxDist\x18\t \x01(\x01\x12\x14\n\x0ctaskDuration\x18\n \x01(\x01\x42\x0cZ\n../protogob\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'mod_site_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\n../protogo'
_RETSITEELEMENT_PARAMSENTRY._options = None
_RETSITEELEMENT_PARAMSENTRY._serialized_options = b'8\001'
_RETSITEELEMENT_EXTENDENTRY._options = None
_RETSITEELEMENT_EXTENDENTRY._serialized_options = b'8\001'
_RETSITEELEMENT._serialized_start=68
_RETSITEELEMENT._serialized_end=504
_RETSITEELEMENT_PARAMSENTRY._serialized_start=412
_RETSITEELEMENT_PARAMSENTRY._serialized_end=457
_RETSITEELEMENT_EXTENDENTRY._serialized_start=459
_RETSITEELEMENT_EXTENDENTRY._serialized_end=504
_SITELIST._serialized_start=506
_SITELIST._serialized_end=566
_SITEUPDATE._serialized_start=569
_SITEUPDATE._serialized_end=829
_SITEPARAMUPDATE._serialized_start=832
_SITEPARAMUPDATE._serialized_end=1031
# @@protoc_insertion_point(module_scope)
mqtt/auto_generate_python/mod_system_pb2.py deleted 100644 → 0
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: mod-system.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x10mod-system.proto\"\xc6\x01\n\x15RetMoreSettingElement\x12\x0f\n\x07\x64\x65\x66\x61ult\x18\x01 \x01(\t\x12\x1c\n\x07setting\x18\x02 \x01(\x0b\x32\x0b.DataParams\x12\x1d\n\x08\x64\x61taSave\x18\x03 \x03(\x0b\x32\x0b.DataParams\x12\x1c\n\x07tleLoad\x18\x04 \x01(\x0b\x32\x0b.DataParams\x12\"\n\rforecastParam\x18\x05 \x03(\x0b\x32\x0b.DataParams\x12\x1d\n\x08taskAuto\x18\x06 \x03(\x0b\x32\x0b.DataParams\"d\n\nDataParams\x12\'\n\x06params\x18\x01 \x03(\x0b\x32\x17.DataParams.ParamsEntry\x1a-\n\x0bParamsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x1f\n\x0eMoreSettingSet\x12\r\n\x05token\x18\x01 \x01(\x05\"\xa1\x01\n\x12MoreSettingDataSet\x12\r\n\x05token\x18\x01 \x01(\x05\x12\n\n\x02no\x18\x02 \x01(\t\x12\x10\n\x08\x64\x61taType\x18\x03 \x01(\t\x12\x0e\n\x06hostIP\x18\x04 \x01(\t\x12\x10\n\x08hostPort\x18\x05 \x01(\x05\x12\x0e\n\x06userID\x18\x06 \x01(\t\x12\x0b\n\x03pwd\x18\x07 \x01(\t\x12\x11\n\tdirectory\x18\x08 \x01(\t\x12\x0c\n\x04size\x18\t \x01(\x05\"/\n\x12MoreSettingDataDel\x12\r\n\x05token\x18\x01 \x01(\x05\x12\n\n\x02no\x18\x02 \x01(\t\"H\n\x0eMoreSettingGet\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x17\n\x07labelId\x18\x03 \x01(\x0e\x32\x06.Label\"O\n\x15MoreSettingGetDefault\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x17\n\x07labelId\x18\x03 \x01(\x0e\x32\x06.Label\"S\n\x19MoreSettingRestoreDefault\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x17\n\x07labelId\x18\x03 \x01(\x0e\x32\x06.Label*\x86\x01\n\x05Label\x12\x11\n\rLabel_Default\x10\x00\x12\x16\n\x12Label_TaskForecast\x10\x01\x12\x12\n\x0eLabel_DataSave\x10\x02\x12\x11\n\rLabel_TleLoad\x10\x03\x12\x17\n\x13Label_ForecastParam\x10\x04\x12\x12\n\x0eLabel_TaskAuto\x10\x05\x42\x0cZ\n../protogob\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'mod_system_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\n../protogo'
_DATAPARAMS_PARAMSENTRY._options = None
_DATAPARAMS_PARAMSENTRY._serialized_options = b'8\001'
_LABEL._serialized_start=810
_LABEL._serialized_end=944
_RETMORESETTINGELEMENT._serialized_start=21
_RETMORESETTINGELEMENT._serialized_end=219
_DATAPARAMS._serialized_start=221
_DATAPARAMS._serialized_end=321
_DATAPARAMS_PARAMSENTRY._serialized_start=276
_DATAPARAMS_PARAMSENTRY._serialized_end=321
_MORESETTINGSET._serialized_start=323
_MORESETTINGSET._serialized_end=354
_MORESETTINGDATASET._serialized_start=357
_MORESETTINGDATASET._serialized_end=518
_MORESETTINGDATADEL._serialized_start=520
_MORESETTINGDATADEL._serialized_end=567
_MORESETTINGGET._serialized_start=569
_MORESETTINGGET._serialized_end=641
_MORESETTINGGETDEFAULT._serialized_start=643
_MORESETTINGGETDEFAULT._serialized_end=722
_MORESETTINGRESTOREDEFAULT._serialized_start=724
_MORESETTINGRESTOREDEFAULT._serialized_end=807
# @@protoc_insertion_point(module_scope)
mqtt/auto_generate_python/mod_task_exec_pb2.py deleted 100644 → 0
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: mod-task-exec.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
import mod_task_pb2 as mod__task__pb2
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13mod-task-exec.proto\x1a\x0emod-task.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\xa5\x02\n\x12RetTaskExecElement\x12\n\n\x02id\x18\x01 \x01(\x05\x12\x1d\n\x04task\x18\x02 \x01(\x0b\x32\x0f.RetTaskElement\x12+\n\x07startDt\x18\x03 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12)\n\x05\x65ndDt\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12/\n\x06\x65xtend\x18\x05 \x03(\x0b\x32\x1f.RetTaskExecElement.ExtendEntry\x12,\n\x08\x63reateDt\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x1a-\n\x0b\x45xtendEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x97\x01\n\x0cTaskExecList\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x12\n\ncodeSearch\x18\x02 \x01(\t\x12\x10\n\x08noSearch\x18\x03 \x01(\t\x12)\n\x05start\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\'\n\x03\x65nd\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xa1\x01\n\x16TaskExecAnalysisResult\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x12\n\ncodeSearch\x18\x03 \x01(\t\x12\x10\n\x08noSearch\x18\x04 \x01(\t\x12)\n\x05start\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\'\n\x03\x65nd\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.TimestampB\x0cZ\n../protogob\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'mod_task_exec_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\n../protogo'
_RETTASKEXECELEMENT_EXTENDENTRY._options = None
_RETTASKEXECELEMENT_EXTENDENTRY._serialized_options = b'8\001'
_RETTASKEXECELEMENT._serialized_start=73
_RETTASKEXECELEMENT._serialized_end=366
_RETTASKEXECELEMENT_EXTENDENTRY._serialized_start=321
_RETTASKEXECELEMENT_EXTENDENTRY._serialized_end=366
_TASKEXECLIST._serialized_start=369
_TASKEXECLIST._serialized_end=520
_TASKEXECANALYSISRESULT._serialized_start=523
_TASKEXECANALYSISRESULT._serialized_end=684
# @@protoc_insertion_point(module_scope)
mqtt/auto_generate_python/mod_task_pb2.py deleted 100644 → 0
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: mod-task.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
import mod_satellite_pb2 as mod__satellite__pb2
import mod_site_pb2 as mod__site__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0emod-task.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x13mod-satellite.proto\x1a\x0emod-site.proto\"\xdb\x05\n\x0eRetTaskElement\x12\n\n\x02id\x18\x01 \x01(\t\x12\n\n\x02no\x18\x02 \x01(\t\x12\r\n\x05norad\x18\x03 \x01(\t\x12\'\n\tsatellite\x18\x04 \x01(\x0b\x32\x14.RetSatelliteElement\x12\x0e\n\x06siteNo\x18\x05 \x01(\t\x12\x1d\n\x04site\x18\x06 \x01(\x0b\x32\x0f.RetSiteElement\x12\x0c\n\x04type\x18\x07 \x01(\t\x12\x19\n\x05grade\x18\x08 \x01(\x0e\x32\n.TaskGrade\x12\x1b\n\x06status\x18\t \x01(\x0e\x32\x0b.TaskStatus\x12)\n\x05genDt\x18\n \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12+\n\x07startDt\x18\x0b \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12)\n\x05\x65ndDt\x18\x0c \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x15\n\rstartAziAngle\x18\r \x01(\x01\x12\x13\n\x0b\x65ndAziAngle\x18\x0e \x01(\x01\x12\x15\n\rstartEleAngle\x18\x0f \x01(\x01\x12\x13\n\x0bmaxEleAngle\x18\x10 \x01(\x01\x12\x0e\n\x06\x63ircle\x18\x11 \x01(\x05\x12\x0f\n\x07minDist\x18\x12 \x01(\x01\x12\x0f\n\x07maxDist\x18\x13 \x01(\x01\x12\r\n\x05slice\x18\x14 \x01(\x05\x12+\n\x06\x65xtend\x18\x15 \x03(\x0b\x32\x1b.RetTaskElement.ExtendEntry\x12%\n\x03res\x18\x16 \x03(\x0b\x32\x18.RetTaskElement.ResEntry\x12\x0b\n\x03off\x18\x17 \x01(\x08\x12,\n\x08\x63reateDt\x18\x18 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x1a-\n\x0b\x45xtendEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x1a*\n\x08ResEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xe0\x01\n\x08TaskList\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12 \n\x0bstatusArray\x18\x03 \x03(\x0e\x32\x0b.TaskStatus\x12\x12\n\ncodeSearch\x18\x04 \x01(\t\x12\x10\n\x08noSearch\x18\x05 \x01(\t\x12\x19\n\x05grade\x18\x06 \x01(\x0e\x32\n.TaskGrade\x12)\n\x05start\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\'\n\x03\x65nd\x18\x08 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\"\xda\x01\n\x0cTaskForecast\x12\r\n\x05token\x18\x01 \x01(\x05\x12(\n\x0c\x66orecastList\x18\x02 \x03(\x0b\x32\x12.SiteSatelliteList\x12\r\n\x05slice\x18\x03 \x01(\x01\x12\x13\n\x0bminEleAngle\x18\x04 \x01(\x01\x12)\n\x05start\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\'\n\x03\x65nd\x18\x06 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x19\n\x05grade\x18\x07 \x01(\x0e\x32\n.TaskGrade\"E\n\x11SiteSatelliteList\x12\x0e\n\x06siteNo\x18\x01 \x01(\t\x12\x0c\n\x04tles\x18\x02 \x01(\t\x12\x12\n\nnoradArray\x18\x03 \x03(\t\"#\n\x12RetForecastOneOver\x12\r\n\x05norad\x18\x01 \x01(\t\"L\n\x08TaskPlan\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12!\n\x08taskList\x18\x03 \x03(\x0b\x32\x0f.RetTaskElement\"\x9e\x01\n\x12TaskHandleConflict\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x1f\n\x08\x63onflict\x18\x03 \x01(\x0e\x32\r.ConflictType\x12\x11\n\tleastTime\x18\x04 \x01(\x03\x12\x12\n\nswitchTime\x18\x05 \x01(\x03\x12!\n\x08taskList\x18\x06 \x03(\x0b\x32\x0f.RetTaskElement\"b\n\nTaskIssued\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x12\n\nswitchTime\x18\x03 \x01(\x05\x12!\n\x08taskList\x18\x04 \x03(\x0b\x32\x0f.RetTaskElement\";\n\tTaskPause\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x0f\n\x07idArray\x18\x03 \x03(\t\">\n\x0cTaskRecovery\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x0f\n\x07idArray\x18\x03 \x03(\t\"9\n\x07TaskDel\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x0f\n\x07idArray\x18\x03 \x03(\t\":\n\x0bTaskConfirm\x12\x1b\n\x07operate\x18\x01 \x01(\x0e\x32\n.Operation\x12\x0e\n\x06taskId\x18\x02 \x01(\t\"=\n\x0eRetTaskConfirm\x12\x1b\n\x07operate\x18\x01 \x01(\x0e\x32\n.Operation\x12\x0e\n\x06taskId\x18\x02 \x01(\t\"\x85\x01\n\x0cRetTaskIndex\x12%\n\x04\x64\x61ta\x18\x01 \x03(\x0b\x32\x17.RetTaskIndex.DataEntry\x12!\n\x08taskList\x18\x02 \x03(\x0b\x32\x0f.RetTaskElement\x1a+\n\tDataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xf5\x01\n\x14TaskForecastParamSet\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\r\n\x05slice\x18\x03 \x01(\x01\x12\x0f\n\x07maxDist\x18\x04 \x01(\x01\x12\x0f\n\x07minDist\x18\x05 \x01(\x01\x12\x13\n\x0bmaxAziAngle\x18\x06 \x01(\x01\x12\x13\n\x0bminAziAngle\x18\x07 \x01(\x01\x12\x13\n\x0bmaxEleAngle\x18\x08 \x01(\x01\x12\x13\n\x0bminEleAngle\x18\t \x01(\x01\x12\x11\n\tpointStep\x18\n \x01(\x05\x12\x15\n\rpointDuration\x18\x0b \x01(\x05\x12\x0f\n\x07\x64\x61tPath\x18\x0c \x01(\t\"\x8d\x02\n\x0bTaskAutoSet\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0e\n\x06siteNo\x18\x02 \x01(\t\x12\x14\n\x0c\x61utoStartHMS\x18\x03 \x01(\t\x12\x12\n\nautoEndHMS\x18\x04 \x01(\t\x12\x15\n\rautoFrequency\x18\x05 \x01(\x05\x12\x1e\n\x16taskAutoStrategyStatus\x18\x06 \x01(\x08\x12\x1f\n\x08\x63onflict\x18\x07 \x01(\x0e\x32\r.ConflictType\x12\x1e\n\x16\x63onflictStrategyStatus\x18\x08 \x01(\x08\x12\x11\n\tleastTime\x18\t \x01(\x03\x12\x12\n\nswitchTime\x18\n \x01(\x03\x12\x16\n\x0e\x63ollectionTime\x18\x0b \x01(\x03\"*\n\rTaskDetailDat\x12\r\n\x05token\x18\x01 \x01(\x05\x12\n\n\x02id\x18\x02 \x01(\t\"]\n\nRetTaskDat\x12&\n\x02\x64t\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\r\n\x05range\x18\x02 \x01(\x01\x12\x0b\n\x03\x65le\x18\x03 \x01(\x01\x12\x0b\n\x03\x61zi\x18\x04 \x01(\x01\",\n\x0fTaskDetailPoint\x12\r\n\x05token\x18\x01 \x01(\x05\x12\n\n\x02id\x18\x02 \x01(\t\"`\n\x0cRetTaskPoint\x12&\n\x02\x64t\x18\x01 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12\x0b\n\x03lat\x18\x05 \x01(\t\x12\x0b\n\x03lon\x18\x06 \x01(\t\x12\x0e\n\x06height\x18\x07 \x01(\t*\x83\x01\n\nTaskStatus\x12\x0e\n\nStatusInit\x10\x00\x12\x0e\n\nStatusUndo\x10\x01\x12\x11\n\rStatusWaiting\x10\x02\x12\x0f\n\x0bStatusDoing\x10\x03\x12\x0e\n\nStatusDone\x10\x04\x12\x0f\n\x0bStatusPause\x10\x05\x12\x10\n\x0cStatusFailed\x10\n*P\n\tTaskGrade\x12\r\n\tGradeNone\x10\x00\x12\x0f\n\x0bGradeNormal\x10\x01\x12\x12\n\x0eGradeImportant\x10\x02\x12\x0f\n\x0bGradeUrgent\x10\x03*n\n\x0c\x43onflictType\x12\x18\n\x14\x43onflictType_Default\x10\x00\x12\x13\n\x0f\x43onflictType_Dt\x10\x01\x12\x14\n\x10\x43onflictType_Ele\x10\x02\x12\x19\n\x15\x43onflictType_Priority\x10\x03*s\n\tOperation\x12\x14\n\x10OperationDefault\x10\x00\x12\x13\n\x0fOperationIssued\x10\x01\x12\x12\n\x0eOperationPause\x10\x02\x12\x15\n\x11OperationRecovery\x10\x03\x12\x10\n\x0cOperationDel\x10\x04\x42\x0cZ\n../protogob\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'mod_task_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\n../protogo'
_RETTASKELEMENT_EXTENDENTRY._options = None
_RETTASKELEMENT_EXTENDENTRY._serialized_options = b'8\001'
_RETTASKELEMENT_RESENTRY._options = None
_RETTASKELEMENT_RESENTRY._serialized_options = b'8\001'
_RETTASKINDEX_DATAENTRY._options = None
_RETTASKINDEX_DATAENTRY._serialized_options = b'8\001'
_TASKSTATUS._serialized_start=2964
_TASKSTATUS._serialized_end=3095
_TASKGRADE._serialized_start=3097
_TASKGRADE._serialized_end=3177
_CONFLICTTYPE._serialized_start=3179
_CONFLICTTYPE._serialized_end=3289
_OPERATION._serialized_start=3291
_OPERATION._serialized_end=3406
_RETTASKELEMENT._serialized_start=89
_RETTASKELEMENT._serialized_end=820
_RETTASKELEMENT_EXTENDENTRY._serialized_start=731
_RETTASKELEMENT_EXTENDENTRY._serialized_end=776
_RETTASKELEMENT_RESENTRY._serialized_start=778
_RETTASKELEMENT_RESENTRY._serialized_end=820
_TASKLIST._serialized_start=823
_TASKLIST._serialized_end=1047
_TASKFORECAST._serialized_start=1050
_TASKFORECAST._serialized_end=1268
_SITESATELLITELIST._serialized_start=1270
_SITESATELLITELIST._serialized_end=1339
_RETFORECASTONEOVER._serialized_start=1341
_RETFORECASTONEOVER._serialized_end=1376
_TASKPLAN._serialized_start=1378
_TASKPLAN._serialized_end=1454
_TASKHANDLECONFLICT._serialized_start=1457
_TASKHANDLECONFLICT._serialized_end=1615
_TASKISSUED._serialized_start=1617
_TASKISSUED._serialized_end=1715
_TASKPAUSE._serialized_start=1717
_TASKPAUSE._serialized_end=1776
_TASKRECOVERY._serialized_start=1778
_TASKRECOVERY._serialized_end=1840
_TASKDEL._serialized_start=1842
_TASKDEL._serialized_end=1899
_TASKCONFIRM._serialized_start=1901
_TASKCONFIRM._serialized_end=1959
_RETTASKCONFIRM._serialized_start=1961
_RETTASKCONFIRM._serialized_end=2022
_RETTASKINDEX._serialized_start=2025
_RETTASKINDEX._serialized_end=2158
_RETTASKINDEX_DATAENTRY._serialized_start=2115
_RETTASKINDEX_DATAENTRY._serialized_end=2158
_TASKFORECASTPARAMSET._serialized_start=2161
_TASKFORECASTPARAMSET._serialized_end=2406
_TASKAUTOSET._serialized_start=2409
_TASKAUTOSET._serialized_end=2678
_TASKDETAILDAT._serialized_start=2680
_TASKDETAILDAT._serialized_end=2722
_RETTASKDAT._serialized_start=2724
_RETTASKDAT._serialized_end=2817
_TASKDETAILPOINT._serialized_start=2819
_TASKDETAILPOINT._serialized_end=2863
_RETTASKPOINT._serialized_start=2865
_RETTASKPOINT._serialized_end=2961
# @@protoc_insertion_point(module_scope)
mqtt/auto_generate_python/mod_user_pb2.py deleted 100644 → 0
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: mod-user.proto
"""Generated protocol buffer code."""
from google.protobuf.internal import builder as _builder
from google.protobuf import descriptor as _descriptor
from google.protobuf import descriptor_pool as _descriptor_pool
from google.protobuf import symbol_database as _symbol_database
# @@protoc_insertion_point(imports)
_sym_db = _symbol_database.Default()
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0emod-user.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\xf1\x01\n\x13RetAdminUserElement\x12\n\n\x02id\x18\x01 \x01(\x05\x12\x13\n\x04role\x18\x02 \x01(\x0e\x32\x05.Role\x12\x10\n\x08username\x18\x03 \x01(\t\x12\x0b\n\x03pwd\x18\x04 \x01(\t\x12\x0b\n\x03off\x18\x05 \x01(\x05\x12\x30\n\x06\x65xtend\x18\x06 \x03(\x0b\x32 .RetAdminUserElement.ExtendEntry\x12,\n\x08\x63reateDt\x18\x07 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x1a-\n\x0b\x45xtendEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\".\n\x08UserList\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x13\n\x04role\x18\x02 \x01(\x0e\x32\x05.Role\"P\n\nUserCreate\x12\x10\n\x08username\x18\x01 \x01(\t\x12\x0b\n\x03pwd\x18\x02 \x01(\t\x12\x13\n\x04role\x18\x03 \x01(\x0e\x32\x05.Role\x12\x0e\n\x06remark\x18\x04 \x01(\t\"r\n\nUserUpdate\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x10\n\x08username\x18\x02 \x01(\t\x12\x0e\n\x06oldPwd\x18\x03 \x01(\t\x12\x0e\n\x06newPwd\x18\x04 \x01(\t\x12\x13\n\x04role\x18\x05 \x01(\x0e\x32\x05.Role\x12\x0e\n\x06remark\x18\x06 \x01(\t\")\n\x07UserDel\x12\r\n\x05token\x18\x01 \x01(\x05\x12\x0f\n\x07idArray\x18\x02 \x03(\x05\"&\n\x05Login\x12\x10\n\x08username\x18\x01 \x01(\t\x12\x0b\n\x03pwd\x18\x02 \x01(\t*6\n\x04Role\x12\r\n\tUser_None\x10\x00\x12\x0e\n\nUser_Admin\x10\x01\x12\x0f\n\x0bUser_Normal\x10\x02\x42\x0cZ\n../protogob\x06proto3')
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, globals())
_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'mod_user_pb2', globals())
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
DESCRIPTOR._serialized_options = b'Z\n../protogo'
_RETADMINUSERELEMENT_EXTENDENTRY._options = None
_RETADMINUSERELEMENT_EXTENDENTRY._serialized_options = b'8\001'
_ROLE._serialized_start=624
_ROLE._serialized_end=678
_RETADMINUSERELEMENT._serialized_start=52
_RETADMINUSERELEMENT._serialized_end=293
_RETADMINUSERELEMENT_EXTENDENTRY._serialized_start=248
_RETADMINUSERELEMENT_EXTENDENTRY._serialized_end=293
_USERLIST._serialized_start=295
_USERLIST._serialized_end=341
_USERCREATE._serialized_start=343
_USERCREATE._serialized_end=423
_USERUPDATE._serialized_start=425
_USERUPDATE._serialized_end=539
_USERDEL._serialized_start=541
_USERDEL._serialized_end=582
_LOGIN._serialized_start=584
_LOGIN._serialized_end=622
# @@protoc_insertion_point(module_scope)
mqtt/mqtt.py
...@@ -28,8 +28,12 @@ def send_message(data: dict): ...@@ -28,8 +28,12 @@ def send_message(data: dict):
""" """
发送 websocket 消息 发送 websocket 消息
""" """
send_websocket_message(data) send_websocket_message(data)
if data['CMDS'][0] == '$': cmds = data.get('CMDS')
if cmds is None:
return
if cmds[0] == '$':
send_websocket_message(data, group_name="chat_acu7m5") send_websocket_message(data, group_name="chat_acu7m5")
else: else:
send_websocket_message(data, group_name="chat_hwf") send_websocket_message(data, group_name="chat_hwf")
......
mqtt/urls.py
from django.contrib import admin from django.contrib import admin
from django.urls import path, include from django.urls import path, re_path
from . import views from . import views
urlpatterns = [ urlpatterns = [
path('', views.index, name='index'), re_path(r'publish/$', views.publish_message, name='publish'),
path('publish/', views.publish_message, name='publish'), re_path(r'^protocol/(?P<protocol_name>.+)/$', views.cmd_list),
re_path(r'^cmd/(?P<cmd_name>.+)/$', views.cmd_fields_list),
] ]
mqtt/utils.py
...@@ -11,13 +11,35 @@ def parse_proto(data: bytes) -> dict: ...@@ -11,13 +11,35 @@ def parse_proto(data: bytes) -> dict:
device_cmd = TDSXDC_Device_cmd() device_cmd = TDSXDC_Device_cmd()
cmd.parameters[0].Unpack(device_cmd) cmd.parameters[0].Unpack(device_cmd)
data = MessageToJson(device_cmd, # data = MessageToJson(device_cmd,
including_default_value_fields=True, # including_default_value_fields=True,
preserving_proto_field_name=True) # preserving_proto_field_name=True)
device_cmd_dict = json.loads(data) # device_cmd_dict = json.loads(data)
data = {item.get('fieldName'): item.get('value') # print(device_cmd_dict)
for item in device_cmd_dict['fields']} data = {item.fieldName: item.value
for item in device_cmd.fields}
# return json.dumps(json.loads(data), separators=(',', ':')) # return json.dumps(json.loads(data), separators=(',', ':'))
return data return data
def compose_protobuf_message(param: dict, dst_suid: int) -> bytes:
cmd = TDSCmd_pb2.TDSCmd()
cmd.interface_id = TDSCmd_pb2.IID_Device_Xpro_TX_cmd
cmd.dst_suid = dst_suid
cmd.src_suid = 0x1116_0000
cmd.priority = 100
cmd.ts.GetCurrentTime()
parameters = TDSXDC_Device_cmd()
parameters.DeviceID = param['device_id']
parameters.cmd_name = param['cmd_name']
for param_field in param['fields']:
field = parameters.fields.add()
field.fieldName = param_field['fieldname']
field.value = param_field['value']
cmd.parameters.add().Pack(parameters)
data = cmd.SerializeToString()
return data
mqtt/views.py
from django.http import JsonResponse, HttpResponse from rest_framework import status
from django.middleware.csrf import get_token from rest_framework.response import Response
from django.shortcuts import render, redirect from rest_framework.decorators import api_view
from django.dispatch import receiver from .utils import compose_protobuf_message
from device_data_op.models import (TableDevCmdNamePoll,
TableAllDevCmdDefine,
TableXproAllDevinfo)
from device_data_op.serializers import (TableDevCmdNamePollSerializer,
TableAllDevCmdDefineSerializer)
from mqtt.mqtt import client as mqtt_client from mqtt.mqtt import client as mqtt_client
@api_view(['GET'])
def cmd_list(request, protocol_name: str):
"""
返回传入协议的所有发出指令名
"""
cmd_lists = TableDevCmdNamePoll.objects.filter(protocol_name=protocol_name).all()
serializer = TableDevCmdNamePollSerializer(cmd_lists, many=True)
ret_data = [data['cmd_name'] for data in serializer.data
if data['cmd_type'] == 'TX']
return Response(data=ret_data, status=status.HTTP_200_OK)
@api_view(['GET'])
def cmd_fields_list(request, cmd_name: str):
"""
返回传入指令所需要的字段
"""
cmd_fields = TableAllDevCmdDefine.objects.filter(cmd_name=cmd_name).all()
serializer = TableAllDevCmdDefineSerializer(cmd_fields, many=True)
ret_data = [data['fieldname'] for data in serializer.data]
return Response(data=ret_data, status=status.HTTP_200_OK)
@api_view(['POST'])
def publish_message(request): def publish_message(request):
# request_data = json.loads(request.body) """
topic = request.POST['topic'] 发送指令到 device
msg = request.POST['msg']
rc, mid = mqtt_client.publish(topic, msg) :param request:
return JsonResponse({'code': rc}) {
"type": "device",
"station_id": "XX1",
"device_id": 1,
"cmd_name": "HY_ACU7M5_PositionSet",
"fields": [
{
"fieldname": "Xaxis",
"value": "120"
},
{
"fieldname": "Yaxis",
"value": "60"
}
]
}
"""
if request.data['station_id'] == "XX1":
topic = "/1/1/1/3"
dst_suid = 0x1113_0000
elif request.data['station_id'] == "XX0":
topic = "/1/1/0/3"
dst_suid = 0x1103_0000
else:
return Response(status=status.HTTP_400_BAD_REQUEST)
message = compose_protobuf_message(request.data, dst_suid)
rc, mid = mqtt_client.publish(topic, message)
return Response(status=status.HTTP_200_OK)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment