bak.txt 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354
  1. func InitTriggerConfig() {
  2. config.OssMutex.Lock()
  3. defer config.OssMutex.Unlock()
  4. triggerLocalPathsMapTriggerId := make(map[string]string)
  5. c_log.GlobalLogger.Info("主节点加载触发器插件 - 开始。")
  6. // 1 获取数采任务的触发器列表
  7. cloudTriggers := &config.PlatformConfig.TaskTriggers
  8. // 2 获取本地触发器列表(触发器目录的一级子目录为【触发器ID_触发器Label】)
  9. localTriggerIds := util.GetFirstLevelSubdirectories(config.CloudConfig.TriggersDir)
  10. // 3 对比触发器列表,本地没有的则下载
  11. for _, trigger := range *cloudTriggers {
  12. id := util.ToString(trigger.TriggerId)
  13. hasIdDir := slices.Contains(localTriggerIds, id) // 改成了 slices 工具库
  14. triggerLocalDir := config.CloudConfig.TriggersDir + id + "/"
  15. hasLabelSo, soPaths := util.CheckSoFilesInDirectory(triggerLocalDir)
  16. var triggerLocalPath string
  17. if hasIdDir && hasLabelSo { // 已存在的触发器需要判断是否大小一致
  18. triggerLocalPath = soPaths[0]
  19. ossSize, _ := util.GetOSSFileSize(config.OssBucket, trigger.TriggerScriptPath)
  20. localSize, _ := util.GetFileSize(triggerLocalPath)
  21. if ossSize == localSize {
  22. c_log.GlobalLogger.Info("触发器插件 ", triggerLocalPath, " 存在且与云端触发器大小一致。")
  23. triggerLocalPathsMapTriggerId[triggerLocalPath] = id
  24. continue
  25. }
  26. }
  27. label := util.GetFileNameWithoutExtension(config.CloudConfig.TriggersDir + trigger.TriggerScriptPath)
  28. triggerLocalPath = config.CloudConfig.TriggersDir + id + "/" + label + ".so"
  29. c_log.GlobalLogger.Info("开始下载触发器插件从 ", trigger.TriggerScriptPath, " 到 ", triggerLocalPath)
  30. _ = util.CreateParentDir(triggerLocalPath)
  31. for {
  32. if err := config.OssBucket.GetObjectToFile(trigger.TriggerScriptPath, triggerLocalPath); err != nil {
  33. c_log.GlobalLogger.Error("下载触发器插件失败,再次尝试:", err)
  34. continue
  35. }
  36. break
  37. }
  38. triggerLocalPathsMapTriggerId[triggerLocalPath] = id
  39. }
  40. success := 0
  41. // 加载所有触发器的文件
  42. for triggerLocalPath, triggerId := range triggerLocalPathsMapTriggerId {
  43. // 载入插件到数组
  44. open, err := plugin.Open(triggerLocalPath)
  45. if err != nil {
  46. c_log.GlobalLogger.Error("加载本地插件", triggerLocalPath, "失败。", err)
  47. continue
  48. }
  49. topic0, err := open.Lookup("Topic")
  50. if err != nil {
  51. c_log.GlobalLogger.Error("加载本地插件", triggerLocalPath, "中的Topic方法失败。", err)
  52. continue
  53. }
  54. topic1, ok := topic0.(func() string)
  55. if ok != true {
  56. c_log.GlobalLogger.Error("插件", triggerLocalPath, "中的Topic方法必须是(func() string):", err)
  57. continue
  58. }
  59. topic2 := topic1()
  60. rule, err := open.Lookup("Rule")
  61. if err != nil {
  62. c_log.GlobalLogger.Error("加载本地插件", triggerLocalPath, "中的Rule方法失败。", err)
  63. continue
  64. }
  65. if Topic1 == topic2 { // 1
  66. if f, ok1 := rule.(func(data *std_msgs.Int16MultiArray) string); ok1 {
  67. Rule1 = append(Rule1, f)
  68. goto JudgeDone
  69. }
  70. log(triggerLocalPath)
  71. continue
  72. } else if Topic2 == topic2 { // 2
  73. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  74. Rule2 = append(Rule2, f)
  75. goto JudgeDone
  76. }
  77. log(triggerLocalPath)
  78. continue
  79. } else if Topic3 == topic2 { // 3
  80. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  81. Rule3 = append(Rule3, f)
  82. goto JudgeDone
  83. }
  84. log(triggerLocalPath)
  85. continue
  86. } else if Topic4 == topic2 { // 4
  87. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  88. Rule4 = append(Rule4, f)
  89. goto JudgeDone
  90. }
  91. log(triggerLocalPath)
  92. continue
  93. } else if Topic5 == topic2 { // 5
  94. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  95. Rule5 = append(Rule5, f)
  96. goto JudgeDone
  97. }
  98. log(triggerLocalPath)
  99. continue
  100. } else if Topic6 == topic2 { // 6
  101. if f, ok1 := rule.(func(data *geometry_msgs.PoseWithCovarianceStamped) string); ok1 {
  102. Rule6 = append(Rule6, f)
  103. goto JudgeDone
  104. }
  105. log(triggerLocalPath)
  106. continue
  107. } else if Topic7 == topic2 { // 7
  108. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  109. Rule7 = append(Rule7, f)
  110. goto JudgeDone
  111. }
  112. log(triggerLocalPath)
  113. continue
  114. } else if Topic8 == topic2 { // 8
  115. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  116. Rule8 = append(Rule8, f)
  117. goto JudgeDone
  118. }
  119. log(triggerLocalPath)
  120. continue
  121. } else if Topic9 == topic2 { // 9
  122. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  123. Rule9 = append(Rule9, f)
  124. goto JudgeDone
  125. }
  126. log(triggerLocalPath)
  127. continue
  128. } else if Topic10 == topic2 { // 10
  129. if f, ok1 := rule.(func(data *std_msgs.Int8) string); ok1 {
  130. Rule10 = append(Rule10, f)
  131. goto JudgeDone
  132. }
  133. log(triggerLocalPath)
  134. continue
  135. } else if Topic11 == topic2 { // 11
  136. if f, ok1 := rule.(func(data *std_msgs.Int8) string); ok1 {
  137. Rule11 = append(Rule11, f)
  138. goto JudgeDone
  139. }
  140. log(triggerLocalPath)
  141. continue
  142. } else if Topic12 == topic2 { // 12
  143. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  144. Rule12 = append(Rule12, f)
  145. goto JudgeDone
  146. }
  147. log(triggerLocalPath)
  148. continue
  149. } else if Topic13 == topic2 { // 13
  150. if f, ok1 := rule.(func(data *sensor_msgs.BatteryState) string); ok1 {
  151. Rule13 = append(Rule13, f)
  152. goto JudgeDone
  153. }
  154. log(triggerLocalPath)
  155. continue
  156. } else if Topic14 == topic2 { // 14
  157. if f, ok1 := rule.(func(data *std_msgs.Int16) string); ok1 {
  158. Rule14 = append(Rule14, f)
  159. goto JudgeDone
  160. }
  161. log(triggerLocalPath)
  162. continue
  163. } else if Topic15 == topic2 { // 15
  164. if f, ok1 := rule.(func(data *visualization_msgs.Marker) string); ok1 {
  165. Rule15 = append(Rule15, f)
  166. goto JudgeDone
  167. }
  168. log(triggerLocalPath)
  169. continue
  170. } else if Topic16 == topic2 { // 16
  171. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  172. Rule16 = append(Rule16, f)
  173. goto JudgeDone
  174. }
  175. log(triggerLocalPath)
  176. continue
  177. } else if Topic17 == topic2 { // 17
  178. if f, ok1 := rule.(func(data *sensor_msgs.CameraInfo) string); ok1 {
  179. Rule17 = append(Rule17, f)
  180. goto JudgeDone
  181. }
  182. log(triggerLocalPath)
  183. continue
  184. } else if Topic18 == topic2 { // 18
  185. if f, ok1 := rule.(func(data *sensor_msgs.Image) string); ok1 {
  186. Rule18 = append(Rule18, f)
  187. goto JudgeDone
  188. }
  189. log(triggerLocalPath)
  190. continue
  191. } else if Topic19 == topic2 { // 19
  192. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  193. Rule19 = append(Rule19, f)
  194. goto JudgeDone
  195. }
  196. log(triggerLocalPath)
  197. continue
  198. } else if Topic20 == topic2 { // 20
  199. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  200. Rule20 = append(Rule20, f)
  201. goto JudgeDone
  202. }
  203. log(triggerLocalPath)
  204. continue
  205. } else if Topic21 == topic2 { // 21
  206. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  207. Rule21 = append(Rule21, f)
  208. goto JudgeDone
  209. }
  210. log(triggerLocalPath)
  211. continue
  212. } else if Topic22 == topic2 { // 22
  213. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  214. Rule22 = append(Rule22, f)
  215. goto JudgeDone
  216. }
  217. log(triggerLocalPath)
  218. continue
  219. } else if Topic23 == topic2 { // 23
  220. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  221. Rule23 = append(Rule23, f)
  222. goto JudgeDone
  223. }
  224. log(triggerLocalPath)
  225. continue
  226. } else if Topic24 == topic2 { // 24
  227. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  228. Rule24 = append(Rule24, f)
  229. goto JudgeDone
  230. }
  231. log(triggerLocalPath)
  232. continue
  233. } else if Topic25 == topic2 { // 25
  234. if f, ok1 := rule.(func(data *theora_image_transport.Packet) string); ok1 {
  235. Rule25 = append(Rule25, f)
  236. goto JudgeDone
  237. }
  238. log(triggerLocalPath)
  239. continue
  240. } else if Topic26 == topic2 { // 26
  241. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  242. Rule26 = append(Rule26, f)
  243. goto JudgeDone
  244. }
  245. log(triggerLocalPath)
  246. continue
  247. } else if Topic27 == topic2 { // 27
  248. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  249. Rule27 = append(Rule27, f)
  250. goto JudgeDone
  251. }
  252. log(triggerLocalPath)
  253. continue
  254. } else if Topic28 == topic2 { // 28
  255. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  256. Rule28 = append(Rule28, f)
  257. goto JudgeDone
  258. }
  259. log(triggerLocalPath)
  260. continue
  261. } else if Topic29 == topic2 { // 29
  262. if f, ok1 := rule.(func(data *sensor_msgs.CameraInfo) string); ok1 {
  263. Rule29 = append(Rule29, f)
  264. goto JudgeDone
  265. }
  266. log(triggerLocalPath)
  267. continue
  268. } else if Topic30 == topic2 { // 30
  269. if f, ok1 := rule.(func(data *sensor_msgs.Image) string); ok1 {
  270. Rule30 = append(Rule30, f)
  271. goto JudgeDone
  272. }
  273. log(triggerLocalPath)
  274. continue
  275. } else if Topic31 == topic2 { // 31
  276. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  277. Rule31 = append(Rule31, f)
  278. goto JudgeDone
  279. }
  280. log(triggerLocalPath)
  281. continue
  282. } else if Topic32 == topic2 { // 32
  283. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  284. Rule32 = append(Rule32, f)
  285. goto JudgeDone
  286. }
  287. log(triggerLocalPath)
  288. continue
  289. } else if Topic33 == topic2 { // 33
  290. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  291. Rule33 = append(Rule33, f)
  292. goto JudgeDone
  293. }
  294. log(triggerLocalPath)
  295. continue
  296. } else if Topic34 == topic2 { // 34
  297. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  298. Rule34 = append(Rule34, f)
  299. goto JudgeDone
  300. }
  301. log(triggerLocalPath)
  302. continue
  303. } else if Topic35 == topic2 { // 35
  304. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  305. Rule35 = append(Rule35, f)
  306. goto JudgeDone
  307. }
  308. log(triggerLocalPath)
  309. continue
  310. } else if Topic36 == topic2 { // 36
  311. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  312. Rule36 = append(Rule36, f)
  313. goto JudgeDone
  314. }
  315. log(triggerLocalPath)
  316. continue
  317. } else if Topic37 == topic2 { // 37
  318. if f, ok1 := rule.(func(data *theora_image_transport.Packet) string); ok1 {
  319. Rule37 = append(Rule37, f)
  320. goto JudgeDone
  321. }
  322. log(triggerLocalPath)
  323. continue
  324. } else if Topic38 == topic2 { // 38
  325. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  326. Rule38 = append(Rule38, f)
  327. goto JudgeDone
  328. }
  329. log(triggerLocalPath)
  330. continue
  331. } else if Topic39 == topic2 { // 39
  332. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  333. Rule39 = append(Rule39, f)
  334. goto JudgeDone
  335. }
  336. log(triggerLocalPath)
  337. continue
  338. } else if Topic40 == topic2 { // 40
  339. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  340. Rule40 = append(Rule40, f)
  341. goto JudgeDone
  342. }
  343. log(triggerLocalPath)
  344. continue
  345. } else if Topic41 == topic2 { // 41
  346. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  347. Rule41 = append(Rule41, f)
  348. goto JudgeDone
  349. }
  350. log(triggerLocalPath)
  351. continue
  352. } else if Topic42 == topic2 { // 42
  353. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  354. Rule42 = append(Rule42, f)
  355. goto JudgeDone
  356. }
  357. log(triggerLocalPath)
  358. continue
  359. } else if Topic43 == topic2 { // 43
  360. if f, ok1 := rule.(func(data *std_msgs.Int8) string); ok1 {
  361. Rule43 = append(Rule43, f)
  362. goto JudgeDone
  363. }
  364. log(triggerLocalPath)
  365. continue
  366. } else if Topic44 == topic2 { // 44
  367. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  368. Rule44 = append(Rule44, f)
  369. goto JudgeDone
  370. }
  371. log(triggerLocalPath)
  372. continue
  373. } else if Topic45 == topic2 { // 45
  374. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  375. Rule45 = append(Rule45, f)
  376. goto JudgeDone
  377. }
  378. log(triggerLocalPath)
  379. continue
  380. } else if Topic46 == topic2 { // 46
  381. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  382. Rule46 = append(Rule46, f)
  383. goto JudgeDone
  384. }
  385. log(triggerLocalPath)
  386. continue
  387. } else if Topic47 == topic2 { // 47
  388. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  389. Rule47 = append(Rule47, f)
  390. goto JudgeDone
  391. }
  392. log(triggerLocalPath)
  393. continue
  394. } else if Topic48 == topic2 { // 48
  395. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  396. Rule48 = append(Rule48, f)
  397. goto JudgeDone
  398. }
  399. log(triggerLocalPath)
  400. continue
  401. } else if Topic49 == topic2 { // 49
  402. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  403. Rule49 = append(Rule49, f)
  404. goto JudgeDone
  405. }
  406. log(triggerLocalPath)
  407. continue
  408. } else if Topic50 == topic2 { // 50
  409. if f, ok1 := rule.(func(data *visualization_msgs.MarkerArray) string); ok1 {
  410. Rule50 = append(Rule50, f)
  411. goto JudgeDone
  412. }
  413. log(triggerLocalPath)
  414. continue
  415. } else if Topic51 == topic2 { // 51
  416. if f, ok1 := rule.(func(data *geometry_msgs.PolygonStamped) string); ok1 {
  417. Rule51 = append(Rule51, f)
  418. goto JudgeDone
  419. }
  420. log(triggerLocalPath)
  421. continue
  422. } else if Topic52 == topic2 { // 52
  423. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  424. Rule52 = append(Rule52, f)
  425. goto JudgeDone
  426. }
  427. log(triggerLocalPath)
  428. continue
  429. } else if Topic53 == topic2 { // 53
  430. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  431. Rule53 = append(Rule53, f)
  432. goto JudgeDone
  433. }
  434. log(triggerLocalPath)
  435. continue
  436. } else if Topic54 == topic2 { // 54
  437. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  438. Rule54 = append(Rule54, f)
  439. goto JudgeDone
  440. }
  441. log(triggerLocalPath)
  442. continue
  443. } else if Topic55 == topic2 { // 55
  444. if f, ok1 := rule.(func(data *std_msgs.Float32) string); ok1 {
  445. Rule55 = append(Rule55, f)
  446. goto JudgeDone
  447. }
  448. log(triggerLocalPath)
  449. continue
  450. } else if Topic56 == topic2 { // 56
  451. if f, ok1 := rule.(func(data *std_msgs.Int32) string); ok1 {
  452. Rule56 = append(Rule56, f)
  453. goto JudgeDone
  454. }
  455. log(triggerLocalPath)
  456. continue
  457. } else if Topic57 == topic2 { // 57
  458. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  459. Rule57 = append(Rule57, f)
  460. goto JudgeDone
  461. }
  462. log(triggerLocalPath)
  463. continue
  464. } else if Topic58 == topic2 { // 58
  465. if f, ok1 := rule.(func(data *clean_msg.ErrorInfo) string); ok1 {
  466. Rule58 = append(Rule58, f)
  467. goto JudgeDone
  468. }
  469. log(triggerLocalPath)
  470. continue
  471. } else if Topic59 == topic2 { // 59
  472. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  473. Rule59 = append(Rule59, f)
  474. goto JudgeDone
  475. }
  476. log(triggerLocalPath)
  477. continue
  478. } else if Topic60 == topic2 { // 60
  479. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  480. Rule60 = append(Rule60, f)
  481. goto JudgeDone
  482. }
  483. log(triggerLocalPath)
  484. continue
  485. } else if Topic61 == topic2 { // 61
  486. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  487. Rule61 = append(Rule61, f)
  488. goto JudgeDone
  489. }
  490. log(triggerLocalPath)
  491. continue
  492. } else if Topic62 == topic2 { // 62
  493. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  494. Rule62 = append(Rule62, f)
  495. goto JudgeDone
  496. }
  497. log(triggerLocalPath)
  498. continue
  499. } else if Topic63 == topic2 { // 63
  500. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  501. Rule63 = append(Rule63, f)
  502. goto JudgeDone
  503. }
  504. log(triggerLocalPath)
  505. continue
  506. } else if Topic64 == topic2 { // 64
  507. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  508. Rule64 = append(Rule64, f)
  509. goto JudgeDone
  510. }
  511. log(triggerLocalPath)
  512. continue
  513. } else if Topic65 == topic2 { // 65
  514. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  515. Rule65 = append(Rule65, f)
  516. goto JudgeDone
  517. }
  518. log(triggerLocalPath)
  519. continue
  520. } else if Topic66 == topic2 { // 66
  521. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  522. Rule66 = append(Rule66, f)
  523. goto JudgeDone
  524. }
  525. log(triggerLocalPath)
  526. continue
  527. } else if Topic67 == topic2 { // 67
  528. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  529. Rule67 = append(Rule67, f)
  530. goto JudgeDone
  531. }
  532. log(triggerLocalPath)
  533. continue
  534. } else if Topic68 == topic2 { // 68
  535. if f, ok1 := rule.(func(data *geometry_msgs.PolygonStamped) string); ok1 {
  536. Rule68 = append(Rule68, f)
  537. goto JudgeDone
  538. }
  539. log(triggerLocalPath)
  540. continue
  541. } else if Topic69 == topic2 { // 69
  542. if f, ok1 := rule.(func(data *geometry_msgs.PointStamped) string); ok1 {
  543. Rule69 = append(Rule69, f)
  544. goto JudgeDone
  545. }
  546. log(triggerLocalPath)
  547. continue
  548. } else if Topic70 == topic2 { // 70
  549. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  550. Rule70 = append(Rule70, f)
  551. goto JudgeDone
  552. }
  553. log(triggerLocalPath)
  554. continue
  555. } else if Topic71 == topic2 { // 71
  556. if f, ok1 := rule.(func(data *geometry_msgs.Twist) string); ok1 {
  557. Rule71 = append(Rule71, f)
  558. goto JudgeDone
  559. }
  560. log(triggerLocalPath)
  561. continue
  562. } else if Topic72 == topic2 { // 72
  563. if f, ok1 := rule.(func(data *geometry_msgs.Twist) string); ok1 {
  564. Rule72 = append(Rule72, f)
  565. goto JudgeDone
  566. }
  567. log(triggerLocalPath)
  568. continue
  569. } else if Topic73 == topic2 { // 73
  570. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  571. Rule73 = append(Rule73, f)
  572. goto JudgeDone
  573. }
  574. log(triggerLocalPath)
  575. continue
  576. } else if Topic74 == topic2 { // 74
  577. if f, ok1 := rule.(func(data *common_msgs.CreateMapInfo) string); ok1 {
  578. Rule74 = append(Rule74, f)
  579. goto JudgeDone
  580. }
  581. log(triggerLocalPath)
  582. continue
  583. } else if Topic75 == topic2 { // 75
  584. if f, ok1 := rule.(func(data *geometry_msgs.Twist) string); ok1 {
  585. Rule75 = append(Rule75, f)
  586. goto JudgeDone
  587. }
  588. log(triggerLocalPath)
  589. continue
  590. } else if Topic76 == topic2 { // 76
  591. if f, ok1 := rule.(func(data *common_msgs.SensorStatus) string); ok1 {
  592. Rule76 = append(Rule76, f)
  593. goto JudgeDone
  594. }
  595. log(triggerLocalPath)
  596. continue
  597. } else if Topic77 == topic2 { // 77
  598. if f, ok1 := rule.(func(data *geometry_msgs.PoseArray) string); ok1 {
  599. Rule77 = append(Rule77, f)
  600. goto JudgeDone
  601. }
  602. log(triggerLocalPath)
  603. continue
  604. } else if Topic78 == topic2 { // 78
  605. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  606. Rule78 = append(Rule78, f)
  607. goto JudgeDone
  608. }
  609. log(triggerLocalPath)
  610. continue
  611. } else if Topic79 == topic2 { // 79
  612. if f, ok1 := rule.(func(data *common_msgs.IdentifierObjsInfo) string); ok1 {
  613. Rule79 = append(Rule79, f)
  614. goto JudgeDone
  615. }
  616. log(triggerLocalPath)
  617. continue
  618. } else if Topic80 == topic2 { // 80
  619. if f, ok1 := rule.(func(data *common_msgs.McuDiagnostic) string); ok1 {
  620. Rule80 = append(Rule80, f)
  621. goto JudgeDone
  622. }
  623. log(triggerLocalPath)
  624. continue
  625. } else if Topic81 == topic2 { // 81
  626. if f, ok1 := rule.(func(data *diagnostic_msgs.DiagnosticArray) string); ok1 {
  627. Rule81 = append(Rule81, f)
  628. goto JudgeDone
  629. }
  630. log(triggerLocalPath)
  631. continue
  632. } else if Topic82 == topic2 { // 82
  633. if f, ok1 := rule.(func(data *std_msgs.Int8) string); ok1 {
  634. Rule82 = append(Rule82, f)
  635. goto JudgeDone
  636. }
  637. log(triggerLocalPath)
  638. continue
  639. } else if Topic83 == topic2 { // 83
  640. if f, ok1 := rule.(func(data *std_msgs.Int16) string); ok1 {
  641. Rule83 = append(Rule83, f)
  642. goto JudgeDone
  643. }
  644. log(triggerLocalPath)
  645. continue
  646. } else if Topic84 == topic2 { // 84
  647. if f, ok1 := rule.(func(data *geometry_msgs.Vector3Stamped) string); ok1 {
  648. Rule84 = append(Rule84, f)
  649. goto JudgeDone
  650. }
  651. log(triggerLocalPath)
  652. continue
  653. } else if Topic85 == topic2 { // 85
  654. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  655. Rule85 = append(Rule85, f)
  656. goto JudgeDone
  657. }
  658. log(triggerLocalPath)
  659. continue
  660. } else if Topic86 == topic2 { // 86
  661. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  662. Rule86 = append(Rule86, f)
  663. goto JudgeDone
  664. }
  665. log(triggerLocalPath)
  666. continue
  667. } else if Topic87 == topic2 { // 87
  668. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  669. Rule87 = append(Rule87, f)
  670. goto JudgeDone
  671. }
  672. log(triggerLocalPath)
  673. continue
  674. } else if Topic88 == topic2 { // 88
  675. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  676. Rule88 = append(Rule88, f)
  677. goto JudgeDone
  678. }
  679. log(triggerLocalPath)
  680. continue
  681. } else if Topic89 == topic2 { // 89
  682. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  683. Rule89 = append(Rule89, f)
  684. goto JudgeDone
  685. }
  686. log(triggerLocalPath)
  687. continue
  688. } else if Topic90 == topic2 { // 90
  689. if f, ok1 := rule.(func(data *std_msgs.Int32) string); ok1 {
  690. Rule90 = append(Rule90, f)
  691. goto JudgeDone
  692. }
  693. log(triggerLocalPath)
  694. continue
  695. } else if Topic91 == topic2 { // 91
  696. if f, ok1 := rule.(func(data *common_msgs.TaskInfo) string); ok1 {
  697. Rule91 = append(Rule91, f)
  698. goto JudgeDone
  699. }
  700. log(triggerLocalPath)
  701. continue
  702. } else if Topic92 == topic2 { // 92
  703. if f, ok1 := rule.(func(data *common_msgs.MapInfo) string); ok1 {
  704. Rule92 = append(Rule92, f)
  705. goto JudgeDone
  706. }
  707. log(triggerLocalPath)
  708. continue
  709. } else if Topic93 == topic2 { // 93
  710. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  711. Rule93 = append(Rule93, f)
  712. goto JudgeDone
  713. }
  714. log(triggerLocalPath)
  715. continue
  716. } else if Topic94 == topic2 { // 94
  717. if f, ok1 := rule.(func(data *common_msgs.VideoStream) string); ok1 {
  718. Rule94 = append(Rule94, f)
  719. goto JudgeDone
  720. }
  721. log(triggerLocalPath)
  722. continue
  723. } else if Topic95 == topic2 { // 95
  724. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  725. Rule95 = append(Rule95, f)
  726. goto JudgeDone
  727. }
  728. log(triggerLocalPath)
  729. continue
  730. } else if Topic96 == topic2 { // 96
  731. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  732. Rule96 = append(Rule96, f)
  733. goto JudgeDone
  734. }
  735. log(triggerLocalPath)
  736. continue
  737. } else if Topic97 == topic2 { // 97
  738. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  739. Rule97 = append(Rule97, f)
  740. goto JudgeDone
  741. }
  742. log(triggerLocalPath)
  743. continue
  744. } else if Topic98 == topic2 { // 98
  745. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  746. Rule98 = append(Rule98, f)
  747. goto JudgeDone
  748. }
  749. log(triggerLocalPath)
  750. continue
  751. } else if Topic99 == topic2 { // 99
  752. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  753. Rule99 = append(Rule99, f)
  754. goto JudgeDone
  755. }
  756. log(triggerLocalPath)
  757. continue
  758. } else if Topic100 == topic2 { // 100
  759. if f, ok1 := rule.(func(data *geometry_msgs.PointStamped) string); ok1 {
  760. Rule100 = append(Rule100, f)
  761. goto JudgeDone
  762. }
  763. log(triggerLocalPath)
  764. continue
  765. } else if Topic101 == topic2 { // 101
  766. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  767. Rule101 = append(Rule101, f)
  768. goto JudgeDone
  769. }
  770. log(triggerLocalPath)
  771. continue
  772. } else if Topic102 == topic2 { // 102
  773. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  774. Rule102 = append(Rule102, f)
  775. goto JudgeDone
  776. }
  777. log(triggerLocalPath)
  778. continue
  779. } else if Topic103 == topic2 { // 103
  780. if f, ok1 := rule.(func(data *geometry_msgs.PoseWithCovarianceStamped) string); ok1 {
  781. Rule103 = append(Rule103, f)
  782. goto JudgeDone
  783. }
  784. log(triggerLocalPath)
  785. continue
  786. } else if Topic104 == topic2 { // 104
  787. if f, ok1 := rule.(func(data *geometry_msgs.Pose) string); ok1 {
  788. Rule104 = append(Rule104, f)
  789. goto JudgeDone
  790. }
  791. log(triggerLocalPath)
  792. continue
  793. } else if Topic105 == topic2 { // 105
  794. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  795. Rule105 = append(Rule105, f)
  796. goto JudgeDone
  797. }
  798. log(triggerLocalPath)
  799. continue
  800. } else if Topic106 == topic2 { // 106
  801. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  802. Rule106 = append(Rule106, f)
  803. goto JudgeDone
  804. }
  805. log(triggerLocalPath)
  806. continue
  807. } else if Topic107 == topic2 { // 107
  808. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  809. Rule107 = append(Rule107, f)
  810. goto JudgeDone
  811. }
  812. log(triggerLocalPath)
  813. continue
  814. } else if Topic108 == topic2 { // 108
  815. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  816. Rule108 = append(Rule108, f)
  817. goto JudgeDone
  818. }
  819. log(triggerLocalPath)
  820. continue
  821. } else if Topic109 == topic2 { // 109
  822. if f, ok1 := rule.(func(data *std_msgs.Float64) string); ok1 {
  823. Rule109 = append(Rule109, f)
  824. goto JudgeDone
  825. }
  826. log(triggerLocalPath)
  827. continue
  828. } else if Topic110 == topic2 { // 110
  829. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  830. Rule110 = append(Rule110, f)
  831. goto JudgeDone
  832. }
  833. log(triggerLocalPath)
  834. continue
  835. } else if Topic111 == topic2 { // 111
  836. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  837. Rule111 = append(Rule111, f)
  838. goto JudgeDone
  839. }
  840. log(triggerLocalPath)
  841. continue
  842. } else if Topic112 == topic2 { // 112
  843. if f, ok1 := rule.(func(data *sensor_msgs.Imu) string); ok1 {
  844. Rule112 = append(Rule112, f)
  845. goto JudgeDone
  846. }
  847. log(triggerLocalPath)
  848. continue
  849. } else if Topic113 == topic2 { // 113
  850. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  851. Rule113 = append(Rule113, f)
  852. goto JudgeDone
  853. }
  854. log(triggerLocalPath)
  855. continue
  856. } else if Topic114 == topic2 { // 114
  857. if f, ok1 := rule.(func(data *std_msgs.Int8) string); ok1 {
  858. Rule114 = append(Rule114, f)
  859. goto JudgeDone
  860. }
  861. log(triggerLocalPath)
  862. continue
  863. } else if Topic115 == topic2 { // 115
  864. if f, ok1 := rule.(func(data *std_msgs.Int16) string); ok1 {
  865. Rule115 = append(Rule115, f)
  866. goto JudgeDone
  867. }
  868. log(triggerLocalPath)
  869. continue
  870. } else if Topic116 == topic2 { // 116
  871. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  872. Rule116 = append(Rule116, f)
  873. goto JudgeDone
  874. }
  875. log(triggerLocalPath)
  876. continue
  877. } else if Topic117 == topic2 { // 117
  878. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  879. Rule117 = append(Rule117, f)
  880. goto JudgeDone
  881. }
  882. log(triggerLocalPath)
  883. continue
  884. } else if Topic118 == topic2 { // 118
  885. if f, ok1 := rule.(func(data *geometry_msgs.PoseWithCovarianceStamped) string); ok1 {
  886. Rule118 = append(Rule118, f)
  887. goto JudgeDone
  888. }
  889. log(triggerLocalPath)
  890. continue
  891. } else if Topic119 == topic2 { // 119
  892. if f, ok1 := rule.(func(data *sensor_msgs.JointState) string); ok1 {
  893. Rule119 = append(Rule119, f)
  894. goto JudgeDone
  895. }
  896. log(triggerLocalPath)
  897. continue
  898. } else if Topic120 == topic2 { // 120
  899. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  900. Rule120 = append(Rule120, f)
  901. goto JudgeDone
  902. }
  903. log(triggerLocalPath)
  904. continue
  905. } else if Topic121 == topic2 { // 121
  906. if f, ok1 := rule.(func(data *cartographer_ros_msgs.LandmarkList) string); ok1 {
  907. Rule121 = append(Rule121, f)
  908. goto JudgeDone
  909. }
  910. log(triggerLocalPath)
  911. continue
  912. } else if Topic122 == topic2 { // 122
  913. if f, ok1 := rule.(func(data *nav_msgs.Odometry) string); ok1 {
  914. Rule122 = append(Rule122, f)
  915. goto JudgeDone
  916. }
  917. log(triggerLocalPath)
  918. continue
  919. } else if Topic123 == topic2 { // 123
  920. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  921. Rule123 = append(Rule123, f)
  922. goto JudgeDone
  923. }
  924. log(triggerLocalPath)
  925. continue
  926. } else if Topic124 == topic2 { // 124
  927. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  928. Rule124 = append(Rule124, f)
  929. goto JudgeDone
  930. }
  931. log(triggerLocalPath)
  932. continue
  933. } else if Topic125 == topic2 { // 125
  934. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  935. Rule125 = append(Rule125, f)
  936. goto JudgeDone
  937. }
  938. log(triggerLocalPath)
  939. continue
  940. } else if Topic126 == topic2 { // 126
  941. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  942. Rule126 = append(Rule126, f)
  943. goto JudgeDone
  944. }
  945. log(triggerLocalPath)
  946. continue
  947. } else if Topic127 == topic2 { // 127
  948. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  949. Rule127 = append(Rule127, f)
  950. goto JudgeDone
  951. }
  952. log(triggerLocalPath)
  953. continue
  954. } else if Topic128 == topic2 { // 128
  955. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  956. Rule128 = append(Rule128, f)
  957. goto JudgeDone
  958. }
  959. log(triggerLocalPath)
  960. continue
  961. } else if Topic129 == topic2 { // 129
  962. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  963. Rule129 = append(Rule129, f)
  964. goto JudgeDone
  965. }
  966. log(triggerLocalPath)
  967. continue
  968. } else if Topic130 == topic2 { // 130
  969. if f, ok1 := rule.(func(data *geometry_msgs.PoseWithCovarianceStamped) string); ok1 {
  970. Rule130 = append(Rule130, f)
  971. goto JudgeDone
  972. }
  973. log(triggerLocalPath)
  974. continue
  975. } else if Topic131 == topic2 { // 131
  976. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  977. Rule131 = append(Rule131, f)
  978. goto JudgeDone
  979. }
  980. log(triggerLocalPath)
  981. continue
  982. } else if Topic132 == topic2 { // 132
  983. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  984. Rule132 = append(Rule132, f)
  985. goto JudgeDone
  986. }
  987. log(triggerLocalPath)
  988. continue
  989. } else if Topic133 == topic2 { // 133
  990. if f, ok1 := rule.(func(data *common_msgs.LocateInfo) string); ok1 {
  991. Rule133 = append(Rule133, f)
  992. goto JudgeDone
  993. }
  994. log(triggerLocalPath)
  995. continue
  996. } else if Topic134 == topic2 { // 134
  997. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  998. Rule134 = append(Rule134, f)
  999. goto JudgeDone
  1000. }
  1001. log(triggerLocalPath)
  1002. continue
  1003. } else if Topic135 == topic2 { // 135
  1004. if f, ok1 := rule.(func(data *std_msgs.Float64MultiArray) string); ok1 {
  1005. Rule135 = append(Rule135, f)
  1006. goto JudgeDone
  1007. }
  1008. log(triggerLocalPath)
  1009. continue
  1010. } else if Topic136 == topic2 { // 136
  1011. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1012. Rule136 = append(Rule136, f)
  1013. goto JudgeDone
  1014. }
  1015. log(triggerLocalPath)
  1016. continue
  1017. } else if Topic137 == topic2 { // 137
  1018. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1019. Rule137 = append(Rule137, f)
  1020. goto JudgeDone
  1021. }
  1022. log(triggerLocalPath)
  1023. continue
  1024. } else if Topic138 == topic2 { // 138
  1025. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  1026. Rule138 = append(Rule138, f)
  1027. goto JudgeDone
  1028. }
  1029. log(triggerLocalPath)
  1030. continue
  1031. } else if Topic139 == topic2 { // 139
  1032. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1033. Rule139 = append(Rule139, f)
  1034. goto JudgeDone
  1035. }
  1036. log(triggerLocalPath)
  1037. continue
  1038. } else if Topic140 == topic2 { // 140
  1039. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  1040. Rule140 = append(Rule140, f)
  1041. goto JudgeDone
  1042. }
  1043. log(triggerLocalPath)
  1044. continue
  1045. } else if Topic141 == topic2 { // 141
  1046. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1047. Rule141 = append(Rule141, f)
  1048. goto JudgeDone
  1049. }
  1050. log(triggerLocalPath)
  1051. continue
  1052. } else if Topic142 == topic2 { // 142
  1053. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1054. Rule142 = append(Rule142, f)
  1055. goto JudgeDone
  1056. }
  1057. log(triggerLocalPath)
  1058. continue
  1059. } else if Topic143 == topic2 { // 143
  1060. if f, ok1 := rule.(func(data *nav_msgs.MapMetaData) string); ok1 {
  1061. Rule143 = append(Rule143, f)
  1062. goto JudgeDone
  1063. }
  1064. log(triggerLocalPath)
  1065. continue
  1066. } else if Topic144 == topic2 { // 144
  1067. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  1068. Rule144 = append(Rule144, f)
  1069. goto JudgeDone
  1070. }
  1071. log(triggerLocalPath)
  1072. continue
  1073. } else if Topic145 == topic2 { // 145
  1074. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  1075. Rule145 = append(Rule145, f)
  1076. goto JudgeDone
  1077. }
  1078. log(triggerLocalPath)
  1079. continue
  1080. } else if Topic146 == topic2 { // 146
  1081. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  1082. Rule146 = append(Rule146, f)
  1083. goto JudgeDone
  1084. }
  1085. log(triggerLocalPath)
  1086. continue
  1087. } else if Topic147 == topic2 { // 147
  1088. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  1089. Rule147 = append(Rule147, f)
  1090. goto JudgeDone
  1091. }
  1092. log(triggerLocalPath)
  1093. continue
  1094. } else if Topic148 == topic2 { // 148
  1095. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1096. Rule148 = append(Rule148, f)
  1097. goto JudgeDone
  1098. }
  1099. log(triggerLocalPath)
  1100. continue
  1101. } else if Topic149 == topic2 { // 149
  1102. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1103. Rule149 = append(Rule149, f)
  1104. goto JudgeDone
  1105. }
  1106. log(triggerLocalPath)
  1107. continue
  1108. } else if Topic150 == topic2 { // 150
  1109. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1110. Rule150 = append(Rule150, f)
  1111. goto JudgeDone
  1112. }
  1113. log(triggerLocalPath)
  1114. continue
  1115. } else if Topic151 == topic2 { // 151
  1116. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1117. Rule151 = append(Rule151, f)
  1118. goto JudgeDone
  1119. }
  1120. log(triggerLocalPath)
  1121. continue
  1122. } else if Topic152 == topic2 { // 152
  1123. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  1124. Rule152 = append(Rule152, f)
  1125. goto JudgeDone
  1126. }
  1127. log(triggerLocalPath)
  1128. continue
  1129. } else if Topic153 == topic2 { // 153
  1130. if f, ok1 := rule.(func(data *sensor_msgs.CameraInfo) string); ok1 {
  1131. Rule153 = append(Rule153, f)
  1132. goto JudgeDone
  1133. }
  1134. log(triggerLocalPath)
  1135. continue
  1136. } else if Topic154 == topic2 { // 154
  1137. if f, ok1 := rule.(func(data *sensor_msgs.Image) string); ok1 {
  1138. Rule154 = append(Rule154, f)
  1139. goto JudgeDone
  1140. }
  1141. log(triggerLocalPath)
  1142. continue
  1143. } else if Topic155 == topic2 { // 155
  1144. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1145. Rule155 = append(Rule155, f)
  1146. goto JudgeDone
  1147. }
  1148. log(triggerLocalPath)
  1149. continue
  1150. } else if Topic156 == topic2 { // 156
  1151. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1152. Rule156 = append(Rule156, f)
  1153. goto JudgeDone
  1154. }
  1155. log(triggerLocalPath)
  1156. continue
  1157. } else if Topic157 == topic2 { // 157
  1158. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1159. Rule157 = append(Rule157, f)
  1160. goto JudgeDone
  1161. }
  1162. log(triggerLocalPath)
  1163. continue
  1164. } else if Topic158 == topic2 { // 158
  1165. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1166. Rule158 = append(Rule158, f)
  1167. goto JudgeDone
  1168. }
  1169. log(triggerLocalPath)
  1170. continue
  1171. } else if Topic159 == topic2 { // 159
  1172. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1173. Rule159 = append(Rule159, f)
  1174. goto JudgeDone
  1175. }
  1176. log(triggerLocalPath)
  1177. continue
  1178. } else if Topic160 == topic2 { // 160
  1179. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1180. Rule160 = append(Rule160, f)
  1181. goto JudgeDone
  1182. }
  1183. log(triggerLocalPath)
  1184. continue
  1185. } else if Topic161 == topic2 { // 161
  1186. if f, ok1 := rule.(func(data *theora_image_transport.Packet) string); ok1 {
  1187. Rule161 = append(Rule161, f)
  1188. goto JudgeDone
  1189. }
  1190. log(triggerLocalPath)
  1191. continue
  1192. } else if Topic162 == topic2 { // 162
  1193. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1194. Rule162 = append(Rule162, f)
  1195. goto JudgeDone
  1196. }
  1197. log(triggerLocalPath)
  1198. continue
  1199. } else if Topic163 == topic2 { // 163
  1200. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1201. Rule163 = append(Rule163, f)
  1202. goto JudgeDone
  1203. }
  1204. log(triggerLocalPath)
  1205. continue
  1206. } else if Topic164 == topic2 { // 164
  1207. if f, ok1 := rule.(func(data *sensor_msgs.CameraInfo) string); ok1 {
  1208. Rule164 = append(Rule164, f)
  1209. goto JudgeDone
  1210. }
  1211. log(triggerLocalPath)
  1212. continue
  1213. } else if Topic165 == topic2 { // 165
  1214. if f, ok1 := rule.(func(data *sensor_msgs.Image) string); ok1 {
  1215. Rule165 = append(Rule165, f)
  1216. goto JudgeDone
  1217. }
  1218. log(triggerLocalPath)
  1219. continue
  1220. } else if Topic166 == topic2 { // 166
  1221. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1222. Rule166 = append(Rule166, f)
  1223. goto JudgeDone
  1224. }
  1225. log(triggerLocalPath)
  1226. continue
  1227. } else if Topic167 == topic2 { // 167
  1228. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1229. Rule167 = append(Rule167, f)
  1230. goto JudgeDone
  1231. }
  1232. log(triggerLocalPath)
  1233. continue
  1234. } else if Topic168 == topic2 { // 168
  1235. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1236. Rule168 = append(Rule168, f)
  1237. goto JudgeDone
  1238. }
  1239. log(triggerLocalPath)
  1240. continue
  1241. } else if Topic169 == topic2 { // 169
  1242. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1243. Rule169 = append(Rule169, f)
  1244. goto JudgeDone
  1245. }
  1246. log(triggerLocalPath)
  1247. continue
  1248. } else if Topic170 == topic2 { // 170
  1249. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1250. Rule170 = append(Rule170, f)
  1251. goto JudgeDone
  1252. }
  1253. log(triggerLocalPath)
  1254. continue
  1255. } else if Topic171 == topic2 { // 171
  1256. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1257. Rule171 = append(Rule171, f)
  1258. goto JudgeDone
  1259. }
  1260. log(triggerLocalPath)
  1261. continue
  1262. } else if Topic172 == topic2 { // 172
  1263. if f, ok1 := rule.(func(data *theora_image_transport.Packet) string); ok1 {
  1264. Rule172 = append(Rule172, f)
  1265. goto JudgeDone
  1266. }
  1267. log(triggerLocalPath)
  1268. continue
  1269. } else if Topic173 == topic2 { // 173
  1270. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1271. Rule173 = append(Rule173, f)
  1272. goto JudgeDone
  1273. }
  1274. log(triggerLocalPath)
  1275. continue
  1276. } else if Topic174 == topic2 { // 174
  1277. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1278. Rule174 = append(Rule174, f)
  1279. goto JudgeDone
  1280. }
  1281. log(triggerLocalPath)
  1282. continue
  1283. } else if Topic175 == topic2 { // 175
  1284. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  1285. Rule175 = append(Rule175, f)
  1286. goto JudgeDone
  1287. }
  1288. log(triggerLocalPath)
  1289. continue
  1290. } else if Topic176 == topic2 { // 176
  1291. if f, ok1 := rule.(func(data *sensor_msgs.CameraInfo) string); ok1 {
  1292. Rule176 = append(Rule176, f)
  1293. goto JudgeDone
  1294. }
  1295. log(triggerLocalPath)
  1296. continue
  1297. } else if Topic177 == topic2 { // 177
  1298. if f, ok1 := rule.(func(data *sensor_msgs.Image) string); ok1 {
  1299. Rule177 = append(Rule177, f)
  1300. goto JudgeDone
  1301. }
  1302. log(triggerLocalPath)
  1303. continue
  1304. } else if Topic178 == topic2 { // 178
  1305. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1306. Rule178 = append(Rule178, f)
  1307. goto JudgeDone
  1308. }
  1309. log(triggerLocalPath)
  1310. continue
  1311. } else if Topic179 == topic2 { // 179
  1312. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1313. Rule179 = append(Rule179, f)
  1314. goto JudgeDone
  1315. }
  1316. log(triggerLocalPath)
  1317. continue
  1318. } else if Topic180 == topic2 { // 180
  1319. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1320. Rule180 = append(Rule180, f)
  1321. goto JudgeDone
  1322. }
  1323. log(triggerLocalPath)
  1324. continue
  1325. } else if Topic181 == topic2 { // 181
  1326. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1327. Rule181 = append(Rule181, f)
  1328. goto JudgeDone
  1329. }
  1330. log(triggerLocalPath)
  1331. continue
  1332. } else if Topic182 == topic2 { // 182
  1333. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1334. Rule182 = append(Rule182, f)
  1335. goto JudgeDone
  1336. }
  1337. log(triggerLocalPath)
  1338. continue
  1339. } else if Topic183 == topic2 { // 183
  1340. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1341. Rule183 = append(Rule183, f)
  1342. goto JudgeDone
  1343. }
  1344. log(triggerLocalPath)
  1345. continue
  1346. } else if Topic184 == topic2 { // 184
  1347. if f, ok1 := rule.(func(data *theora_image_transport.Packet) string); ok1 {
  1348. Rule184 = append(Rule184, f)
  1349. goto JudgeDone
  1350. }
  1351. log(triggerLocalPath)
  1352. continue
  1353. } else if Topic185 == topic2 { // 185
  1354. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1355. Rule185 = append(Rule185, f)
  1356. goto JudgeDone
  1357. }
  1358. log(triggerLocalPath)
  1359. continue
  1360. } else if Topic186 == topic2 { // 186
  1361. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1362. Rule186 = append(Rule186, f)
  1363. goto JudgeDone
  1364. }
  1365. log(triggerLocalPath)
  1366. continue
  1367. } else if Topic187 == topic2 { // 187
  1368. if f, ok1 := rule.(func(data *sensor_msgs.CameraInfo) string); ok1 {
  1369. Rule187 = append(Rule187, f)
  1370. goto JudgeDone
  1371. }
  1372. log(triggerLocalPath)
  1373. continue
  1374. } else if Topic188 == topic2 { // 188
  1375. if f, ok1 := rule.(func(data *sensor_msgs.Image) string); ok1 {
  1376. Rule188 = append(Rule188, f)
  1377. goto JudgeDone
  1378. }
  1379. log(triggerLocalPath)
  1380. continue
  1381. } else if Topic189 == topic2 { // 189
  1382. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1383. Rule189 = append(Rule189, f)
  1384. goto JudgeDone
  1385. }
  1386. log(triggerLocalPath)
  1387. continue
  1388. } else if Topic190 == topic2 { // 190
  1389. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1390. Rule190 = append(Rule190, f)
  1391. goto JudgeDone
  1392. }
  1393. log(triggerLocalPath)
  1394. continue
  1395. } else if Topic191 == topic2 { // 191
  1396. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1397. Rule191 = append(Rule191, f)
  1398. goto JudgeDone
  1399. }
  1400. log(triggerLocalPath)
  1401. continue
  1402. } else if Topic192 == topic2 { // 192
  1403. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1404. Rule192 = append(Rule192, f)
  1405. goto JudgeDone
  1406. }
  1407. log(triggerLocalPath)
  1408. continue
  1409. } else if Topic193 == topic2 { // 193
  1410. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1411. Rule193 = append(Rule193, f)
  1412. goto JudgeDone
  1413. }
  1414. log(triggerLocalPath)
  1415. continue
  1416. } else if Topic194 == topic2 { // 194
  1417. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1418. Rule194 = append(Rule194, f)
  1419. goto JudgeDone
  1420. }
  1421. log(triggerLocalPath)
  1422. continue
  1423. } else if Topic195 == topic2 { // 195
  1424. if f, ok1 := rule.(func(data *theora_image_transport.Packet) string); ok1 {
  1425. Rule195 = append(Rule195, f)
  1426. goto JudgeDone
  1427. }
  1428. log(triggerLocalPath)
  1429. continue
  1430. } else if Topic196 == topic2 { // 196
  1431. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1432. Rule196 = append(Rule196, f)
  1433. goto JudgeDone
  1434. }
  1435. log(triggerLocalPath)
  1436. continue
  1437. } else if Topic197 == topic2 { // 197
  1438. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1439. Rule197 = append(Rule197, f)
  1440. goto JudgeDone
  1441. }
  1442. log(triggerLocalPath)
  1443. continue
  1444. } else if Topic198 == topic2 { // 198
  1445. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  1446. Rule198 = append(Rule198, f)
  1447. goto JudgeDone
  1448. }
  1449. log(triggerLocalPath)
  1450. continue
  1451. } else if Topic199 == topic2 { // 199
  1452. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  1453. Rule199 = append(Rule199, f)
  1454. goto JudgeDone
  1455. }
  1456. log(triggerLocalPath)
  1457. continue
  1458. } else if Topic200 == topic2 { // 200
  1459. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  1460. Rule200 = append(Rule200, f)
  1461. goto JudgeDone
  1462. }
  1463. log(triggerLocalPath)
  1464. continue
  1465. } else if Topic201 == topic2 { // 201
  1466. if f, ok1 := rule.(func(data *std_msgs.UInt8) string); ok1 {
  1467. Rule201 = append(Rule201, f)
  1468. goto JudgeDone
  1469. }
  1470. log(triggerLocalPath)
  1471. continue
  1472. } else if Topic202 == topic2 { // 202
  1473. if f, ok1 := rule.(func(data *nav_msgs.Odometry) string); ok1 {
  1474. Rule202 = append(Rule202, f)
  1475. goto JudgeDone
  1476. }
  1477. log(triggerLocalPath)
  1478. continue
  1479. } else if Topic203 == topic2 { // 203
  1480. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1481. Rule203 = append(Rule203, f)
  1482. goto JudgeDone
  1483. }
  1484. log(triggerLocalPath)
  1485. continue
  1486. } else if Topic204 == topic2 { // 204
  1487. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1488. Rule204 = append(Rule204, f)
  1489. goto JudgeDone
  1490. }
  1491. log(triggerLocalPath)
  1492. continue
  1493. } else if Topic205 == topic2 { // 205
  1494. if f, ok1 := rule.(func(data *nav_msgs.Odometry) string); ok1 {
  1495. Rule205 = append(Rule205, f)
  1496. goto JudgeDone
  1497. }
  1498. log(triggerLocalPath)
  1499. continue
  1500. } else if Topic206 == topic2 { // 206
  1501. if f, ok1 := rule.(func(data *sensor_msgs.Imu) string); ok1 {
  1502. Rule206 = append(Rule206, f)
  1503. goto JudgeDone
  1504. }
  1505. log(triggerLocalPath)
  1506. continue
  1507. } else if Topic207 == topic2 { // 207
  1508. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  1509. Rule207 = append(Rule207, f)
  1510. goto JudgeDone
  1511. }
  1512. log(triggerLocalPath)
  1513. continue
  1514. } else if Topic208 == topic2 { // 208
  1515. if f, ok1 := rule.(func(data *geometry_msgs.PoseArray) string); ok1 {
  1516. Rule208 = append(Rule208, f)
  1517. goto JudgeDone
  1518. }
  1519. log(triggerLocalPath)
  1520. continue
  1521. } else if Topic209 == topic2 { // 209
  1522. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  1523. Rule209 = append(Rule209, f)
  1524. goto JudgeDone
  1525. }
  1526. log(triggerLocalPath)
  1527. continue
  1528. } else if Topic210 == topic2 { // 210
  1529. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  1530. Rule210 = append(Rule210, f)
  1531. goto JudgeDone
  1532. }
  1533. log(triggerLocalPath)
  1534. continue
  1535. } else if Topic211 == topic2 { // 211
  1536. if f, ok1 := rule.(func(data *geometry_msgs.PoseWithCovarianceStamped) string); ok1 {
  1537. Rule211 = append(Rule211, f)
  1538. goto JudgeDone
  1539. }
  1540. log(triggerLocalPath)
  1541. continue
  1542. } else if Topic212 == topic2 { // 212
  1543. if f, ok1 := rule.(func(data *geometry_msgs.Vector3Stamped) string); ok1 {
  1544. Rule212 = append(Rule212, f)
  1545. goto JudgeDone
  1546. }
  1547. log(triggerLocalPath)
  1548. continue
  1549. } else if Topic213 == topic2 { // 213
  1550. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1551. Rule213 = append(Rule213, f)
  1552. goto JudgeDone
  1553. }
  1554. log(triggerLocalPath)
  1555. continue
  1556. } else if Topic214 == topic2 { // 214
  1557. if f, ok1 := rule.(func(data *common_msgs.FunctionAreas) string); ok1 {
  1558. Rule214 = append(Rule214, f)
  1559. goto JudgeDone
  1560. }
  1561. log(triggerLocalPath)
  1562. continue
  1563. } else if Topic215 == topic2 { // 215
  1564. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  1565. Rule215 = append(Rule215, f)
  1566. goto JudgeDone
  1567. }
  1568. log(triggerLocalPath)
  1569. continue
  1570. } else if Topic216 == topic2 { // 216
  1571. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  1572. Rule216 = append(Rule216, f)
  1573. goto JudgeDone
  1574. }
  1575. log(triggerLocalPath)
  1576. continue
  1577. } else if Topic217 == topic2 { // 217
  1578. if f, ok1 := rule.(func(data *std_msgs.Float64MultiArray) string); ok1 {
  1579. Rule217 = append(Rule217, f)
  1580. goto JudgeDone
  1581. }
  1582. log(triggerLocalPath)
  1583. continue
  1584. } else if Topic218 == topic2 { // 218
  1585. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1586. Rule218 = append(Rule218, f)
  1587. goto JudgeDone
  1588. }
  1589. log(triggerLocalPath)
  1590. continue
  1591. } else if Topic219 == topic2 { // 219
  1592. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1593. Rule219 = append(Rule219, f)
  1594. goto JudgeDone
  1595. }
  1596. log(triggerLocalPath)
  1597. continue
  1598. } else if Topic220 == topic2 { // 220
  1599. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1600. Rule220 = append(Rule220, f)
  1601. goto JudgeDone
  1602. }
  1603. log(triggerLocalPath)
  1604. continue
  1605. } else if Topic221 == topic2 { // 221
  1606. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  1607. Rule221 = append(Rule221, f)
  1608. goto JudgeDone
  1609. }
  1610. log(triggerLocalPath)
  1611. continue
  1612. } else if Topic222 == topic2 { // 222
  1613. if f, ok1 := rule.(func(data *geometry_msgs.PoseWithCovarianceStamped) string); ok1 {
  1614. Rule222 = append(Rule222, f)
  1615. goto JudgeDone
  1616. }
  1617. log(triggerLocalPath)
  1618. continue
  1619. } else if Topic223 == topic2 { // 223
  1620. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1621. Rule223 = append(Rule223, f)
  1622. goto JudgeDone
  1623. }
  1624. log(triggerLocalPath)
  1625. continue
  1626. } else if Topic224 == topic2 { // 224
  1627. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1628. Rule224 = append(Rule224, f)
  1629. goto JudgeDone
  1630. }
  1631. log(triggerLocalPath)
  1632. continue
  1633. } else if Topic225 == topic2 { // 225
  1634. if f, ok1 := rule.(func(data *localization_monitor.RobotStatus) string); ok1 {
  1635. Rule225 = append(Rule225, f)
  1636. goto JudgeDone
  1637. }
  1638. log(triggerLocalPath)
  1639. continue
  1640. } else if Topic226 == topic2 { // 226
  1641. if f, ok1 := rule.(func(data *std_msgs.Float64MultiArray) string); ok1 {
  1642. Rule226 = append(Rule226, f)
  1643. goto JudgeDone
  1644. }
  1645. log(triggerLocalPath)
  1646. continue
  1647. } else if Topic227 == topic2 { // 227
  1648. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1649. Rule227 = append(Rule227, f)
  1650. goto JudgeDone
  1651. }
  1652. log(triggerLocalPath)
  1653. continue
  1654. } else if Topic228 == topic2 { // 228
  1655. if f, ok1 := rule.(func(data *actionlib_msgs.GoalID) string); ok1 {
  1656. Rule228 = append(Rule228, f)
  1657. goto JudgeDone
  1658. }
  1659. log(triggerLocalPath)
  1660. continue
  1661. } else if Topic229 == topic2 { // 229
  1662. if f, ok1 := rule.(func(data *ipa_building_msgs.MapSegmentationActionFeedback) string); ok1 {
  1663. Rule229 = append(Rule229, f)
  1664. goto JudgeDone
  1665. }
  1666. log(triggerLocalPath)
  1667. continue
  1668. } else if Topic230 == topic2 { // 230
  1669. if f, ok1 := rule.(func(data *ipa_building_msgs.MapSegmentationActionGoal) string); ok1 {
  1670. Rule230 = append(Rule230, f)
  1671. goto JudgeDone
  1672. }
  1673. log(triggerLocalPath)
  1674. continue
  1675. } else if Topic231 == topic2 { // 231
  1676. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1677. Rule231 = append(Rule231, f)
  1678. goto JudgeDone
  1679. }
  1680. log(triggerLocalPath)
  1681. continue
  1682. } else if Topic232 == topic2 { // 232
  1683. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1684. Rule232 = append(Rule232, f)
  1685. goto JudgeDone
  1686. }
  1687. log(triggerLocalPath)
  1688. continue
  1689. } else if Topic233 == topic2 { // 233
  1690. if f, ok1 := rule.(func(data *ipa_building_msgs.MapSegmentationActionResult) string); ok1 {
  1691. Rule233 = append(Rule233, f)
  1692. goto JudgeDone
  1693. }
  1694. log(triggerLocalPath)
  1695. continue
  1696. } else if Topic234 == topic2 { // 234
  1697. if f, ok1 := rule.(func(data *nav_msgs.OccupancyGrid) string); ok1 {
  1698. Rule234 = append(Rule234, f)
  1699. goto JudgeDone
  1700. }
  1701. log(triggerLocalPath)
  1702. continue
  1703. } else if Topic235 == topic2 { // 235
  1704. if f, ok1 := rule.(func(data *actionlib_msgs.GoalStatusArray) string); ok1 {
  1705. Rule235 = append(Rule235, f)
  1706. goto JudgeDone
  1707. }
  1708. log(triggerLocalPath)
  1709. continue
  1710. } else if Topic236 == topic2 { // 1
  1711. if f, ok1 := rule.(func(data *rosgraph_msgs.Log) string); ok1 {
  1712. Rule236 = append(Rule236, f)
  1713. goto JudgeDone
  1714. }
  1715. log(triggerLocalPath)
  1716. continue
  1717. } else if Topic237 == topic2 { // 2
  1718. if f, ok1 := rule.(func(data *rosgraph_msgs.Log) string); ok1 {
  1719. Rule237 = append(Rule237, f)
  1720. goto JudgeDone
  1721. }
  1722. log(triggerLocalPath)
  1723. continue
  1724. } else if Topic238 == topic2 { // 3
  1725. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  1726. Rule238 = append(Rule238, f)
  1727. goto JudgeDone
  1728. }
  1729. log(triggerLocalPath)
  1730. continue
  1731. } else if Topic239 == topic2 { // 4
  1732. if f, ok1 := rule.(func(data *geometry_msgs.Vector3Stamped) string); ok1 {
  1733. Rule239 = append(Rule239, f)
  1734. goto JudgeDone
  1735. }
  1736. log(triggerLocalPath)
  1737. continue
  1738. } else if Topic240 == topic2 { // 5
  1739. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  1740. Rule240 = append(Rule240, f)
  1741. goto JudgeDone
  1742. }
  1743. log(triggerLocalPath)
  1744. continue
  1745. } else if Topic241 == topic2 { // 6
  1746. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  1747. Rule241 = append(Rule241, f)
  1748. goto JudgeDone
  1749. }
  1750. log(triggerLocalPath)
  1751. continue
  1752. } else if Topic242 == topic2 { // 7
  1753. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  1754. Rule242 = append(Rule242, f)
  1755. goto JudgeDone
  1756. }
  1757. log(triggerLocalPath)
  1758. continue
  1759. } else if Topic243 == topic2 { // 8
  1760. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  1761. Rule243 = append(Rule243, f)
  1762. goto JudgeDone
  1763. }
  1764. log(triggerLocalPath)
  1765. continue
  1766. } else if Topic244 == topic2 { // 9
  1767. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  1768. Rule244 = append(Rule244, f)
  1769. goto JudgeDone
  1770. }
  1771. log(triggerLocalPath)
  1772. continue
  1773. } else if Topic245 == topic2 { // 10
  1774. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  1775. Rule245 = append(Rule245, f)
  1776. goto JudgeDone
  1777. }
  1778. log(triggerLocalPath)
  1779. continue
  1780. } else if Topic246 == topic2 { // 11
  1781. if f, ok1 := rule.(func(data *sensor_msgs.PointCloud2) string); ok1 {
  1782. Rule246 = append(Rule246, f)
  1783. goto JudgeDone
  1784. }
  1785. log(triggerLocalPath)
  1786. continue
  1787. } else if Topic247 == topic2 { // 12
  1788. if f, ok1 := rule.(func(data *visualization_msgs.MarkerArray) string); ok1 {
  1789. Rule247 = append(Rule247, f)
  1790. goto JudgeDone
  1791. }
  1792. log(triggerLocalPath)
  1793. continue
  1794. } else if Topic248 == topic2 { // 13
  1795. if f, ok1 := rule.(func(data *common_msgs.SensorTask) string); ok1 {
  1796. Rule248 = append(Rule248, f)
  1797. goto JudgeDone
  1798. }
  1799. log(triggerLocalPath)
  1800. continue
  1801. } else if Topic249 == topic2 { // 14
  1802. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1803. Rule249 = append(Rule249, f)
  1804. goto JudgeDone
  1805. }
  1806. log(triggerLocalPath)
  1807. continue
  1808. } else if Topic250 == topic2 { // 15
  1809. if f, ok1 := rule.(func(data *geometry_msgs.Vector3Stamped) string); ok1 {
  1810. Rule250 = append(Rule250, f)
  1811. goto JudgeDone
  1812. }
  1813. log(triggerLocalPath)
  1814. continue
  1815. } else if Topic251 == topic2 { // 16
  1816. if f, ok1 := rule.(func(data *common_msgs.SonarList) string); ok1 {
  1817. Rule251 = append(Rule251, f)
  1818. goto JudgeDone
  1819. }
  1820. log(triggerLocalPath)
  1821. continue
  1822. } else if Topic252 == topic2 { // 17
  1823. if f, ok1 := rule.(func(data *nav_msgs.Odometry) string); ok1 {
  1824. Rule252 = append(Rule252, f)
  1825. goto JudgeDone
  1826. }
  1827. log(triggerLocalPath)
  1828. continue
  1829. } else if Topic253 == topic2 { // 18
  1830. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  1831. Rule253 = append(Rule253, f)
  1832. goto JudgeDone
  1833. }
  1834. log(triggerLocalPath)
  1835. continue
  1836. } else if Topic254 == topic2 { // 19
  1837. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  1838. Rule254 = append(Rule254, f)
  1839. goto JudgeDone
  1840. }
  1841. log(triggerLocalPath)
  1842. continue
  1843. } else if Topic255 == topic2 { // 20
  1844. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  1845. Rule255 = append(Rule255, f)
  1846. goto JudgeDone
  1847. }
  1848. log(triggerLocalPath)
  1849. continue
  1850. } else if Topic256 == topic2 { // 21
  1851. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1852. Rule256 = append(Rule256, f)
  1853. goto JudgeDone
  1854. }
  1855. log(triggerLocalPath)
  1856. continue
  1857. } else if Topic257 == topic2 { // 22
  1858. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  1859. Rule257 = append(Rule257, f)
  1860. goto JudgeDone
  1861. }
  1862. log(triggerLocalPath)
  1863. continue
  1864. } else if Topic258 == topic2 { // 23
  1865. if f, ok1 := rule.(func(data *sensor_msgs.CameraInfo) string); ok1 {
  1866. Rule258 = append(Rule258, f)
  1867. goto JudgeDone
  1868. }
  1869. log(triggerLocalPath)
  1870. continue
  1871. } else if Topic259 == topic2 { // 24
  1872. if f, ok1 := rule.(func(data *common_msgs.SysInfo) string); ok1 {
  1873. Rule259 = append(Rule259, f)
  1874. goto JudgeDone
  1875. }
  1876. log(triggerLocalPath)
  1877. continue
  1878. } else if Topic260 == topic2 { // 25
  1879. if f, ok1 := rule.(func(data *sensor_msgs.Image) string); ok1 {
  1880. Rule260 = append(Rule260, f)
  1881. goto JudgeDone
  1882. }
  1883. log(triggerLocalPath)
  1884. continue
  1885. } else if Topic261 == topic2 { // 26
  1886. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1887. Rule261 = append(Rule261, f)
  1888. goto JudgeDone
  1889. }
  1890. log(triggerLocalPath)
  1891. continue
  1892. } else if Topic262 == topic2 { // 27
  1893. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1894. Rule262 = append(Rule262, f)
  1895. goto JudgeDone
  1896. }
  1897. log(triggerLocalPath)
  1898. continue
  1899. } else if Topic263 == topic2 { // 28
  1900. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1901. Rule263 = append(Rule263, f)
  1902. goto JudgeDone
  1903. }
  1904. log(triggerLocalPath)
  1905. continue
  1906. } else if Topic264 == topic2 { // 29
  1907. if f, ok1 := rule.(func(data *sensor_msgs.CompressedImage) string); ok1 {
  1908. Rule264 = append(Rule264, f)
  1909. goto JudgeDone
  1910. }
  1911. log(triggerLocalPath)
  1912. continue
  1913. } else if Topic265 == topic2 { // 30
  1914. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1915. Rule265 = append(Rule265, f)
  1916. goto JudgeDone
  1917. }
  1918. log(triggerLocalPath)
  1919. continue
  1920. } else if Topic266 == topic2 { // 31
  1921. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1922. Rule266 = append(Rule266, f)
  1923. goto JudgeDone
  1924. }
  1925. log(triggerLocalPath)
  1926. continue
  1927. } else if Topic267 == topic2 { // 32
  1928. if f, ok1 := rule.(func(data *theora_image_transport.Packet) string); ok1 {
  1929. Rule267 = append(Rule267, f)
  1930. goto JudgeDone
  1931. }
  1932. log(triggerLocalPath)
  1933. continue
  1934. } else if Topic268 == topic2 { // 33
  1935. if f, ok1 := rule.(func(data *dynamic_reconfigure.ConfigDescription) string); ok1 {
  1936. Rule268 = append(Rule268, f)
  1937. goto JudgeDone
  1938. }
  1939. log(triggerLocalPath)
  1940. continue
  1941. } else if Topic269 == topic2 { // 34
  1942. if f, ok1 := rule.(func(data *dynamic_reconfigure.Config) string); ok1 {
  1943. Rule269 = append(Rule269, f)
  1944. goto JudgeDone
  1945. }
  1946. log(triggerLocalPath)
  1947. continue
  1948. } else if Topic270 == topic2 { // 35
  1949. if f, ok1 := rule.(func(data *std_msgs.Bool) string); ok1 {
  1950. Rule270 = append(Rule270, f)
  1951. goto JudgeDone
  1952. }
  1953. log(triggerLocalPath)
  1954. continue
  1955. } else if Topic271 == topic2 { // 36
  1956. if f, ok1 := rule.(func(data *geometry_msgs.PoseStamped) string); ok1 {
  1957. Rule271 = append(Rule271, f)
  1958. goto JudgeDone
  1959. }
  1960. log(triggerLocalPath)
  1961. continue
  1962. } else if Topic272 == topic2 { // 37
  1963. if f, ok1 := rule.(func(data *geometry_msgs.Vector3Stamped) string); ok1 {
  1964. Rule272 = append(Rule272, f)
  1965. goto JudgeDone
  1966. }
  1967. log(triggerLocalPath)
  1968. continue
  1969. } else if Topic273 == topic2 { // 38
  1970. if f, ok1 := rule.(func(data *common_msgs.TaskFeedbackInfo) string); ok1 {
  1971. Rule273 = append(Rule273, f)
  1972. goto JudgeDone
  1973. }
  1974. log(triggerLocalPath)
  1975. continue
  1976. } else if Topic274 == topic2 { // 39
  1977. if f, ok1 := rule.(func(data *common_msgs.Points) string); ok1 {
  1978. Rule274 = append(Rule274, f)
  1979. goto JudgeDone
  1980. }
  1981. log(triggerLocalPath)
  1982. continue
  1983. } else if Topic275 == topic2 { // 40
  1984. if f, ok1 := rule.(func(data *tf2_msgs.TFMessage) string); ok1 {
  1985. Rule275 = append(Rule275, f)
  1986. goto JudgeDone
  1987. }
  1988. log(triggerLocalPath)
  1989. continue
  1990. } else if Topic276 == topic2 { // 41
  1991. if f, ok1 := rule.(func(data *std_msgs.String) string); ok1 {
  1992. Rule276 = append(Rule276, f)
  1993. goto JudgeDone
  1994. }
  1995. log(triggerLocalPath)
  1996. continue
  1997. } else if Topic277 == topic2 { // 42
  1998. if f, ok1 := rule.(func(data *tf2_msgs.TFMessage) string); ok1 {
  1999. Rule277 = append(Rule277, f)
  2000. goto JudgeDone
  2001. }
  2002. log(triggerLocalPath)
  2003. continue
  2004. } else if Topic278 == topic2 { // 43
  2005. if f, ok1 := rule.(func(data *nav_msgs.Path) string); ok1 {
  2006. Rule278 = append(Rule278, f)
  2007. goto JudgeDone
  2008. }
  2009. log(triggerLocalPath)
  2010. continue
  2011. } else if Topic279 == topic2 { // 44
  2012. if f, ok1 := rule.(func(data *common_msgs.UpLoadFileList) string); ok1 {
  2013. Rule279 = append(Rule279, f)
  2014. goto JudgeDone
  2015. }
  2016. log(triggerLocalPath)
  2017. continue
  2018. } else if Topic280 == topic2 { // 45
  2019. if f, ok1 := rule.(func(data *sensor_msgs.Range) string); ok1 {
  2020. Rule280 = append(Rule280, f)
  2021. goto JudgeDone
  2022. }
  2023. log(triggerLocalPath)
  2024. continue
  2025. } else if Topic281 == topic2 { // 46
  2026. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  2027. Rule281 = append(Rule281, f)
  2028. goto JudgeDone
  2029. }
  2030. log(triggerLocalPath)
  2031. continue
  2032. } else if Topic282 == topic2 { // 47
  2033. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  2034. Rule282 = append(Rule282, f)
  2035. goto JudgeDone
  2036. }
  2037. log(triggerLocalPath)
  2038. continue
  2039. } else if Topic283 == topic2 { // 48
  2040. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  2041. Rule283 = append(Rule283, f)
  2042. goto JudgeDone
  2043. }
  2044. log(triggerLocalPath)
  2045. continue
  2046. } else if Topic284 == topic2 { // 49
  2047. if f, ok1 := rule.(func(data *sensor_msgs.LaserScan) string); ok1 {
  2048. Rule284 = append(Rule284, f)
  2049. goto JudgeDone
  2050. }
  2051. log(triggerLocalPath)
  2052. continue
  2053. } else {
  2054. c_log.GlobalLogger.Error("未知的topic:", topic2)
  2055. continue
  2056. }
  2057. JudgeDone:
  2058. label, err := open.Lookup("Label")
  2059. if err != nil {
  2060. c_log.GlobalLogger.Error("加载本地插件 ", triggerLocalPath, " 中的 Label 方法失败。", err)
  2061. continue
  2062. }
  2063. labelFunc := label.(func() string)
  2064. labelString := labelFunc()
  2065. LabelMapTriggerId.Store(labelString, triggerId)
  2066. success++
  2067. }
  2068. c_log.GlobalLogger.Info("一共应加载", len(config.PlatformConfig.TaskTriggers), "个触发器,实际加载 ", success, " 个触发器。")
  2069. }