Browse Source

空港畅行通代码提交

tags/V1.5.0^2
chenyukun 1 year ago
parent
commit
5feff77b0c
3 changed files with 7 additions and 8 deletions
  1. +2
    -2
      .idea/deployment.xml
  2. +3
    -4
      .idea/workspace.xml
  3. +2
    -2
      service/Dispatcher.py

+ 2
- 2
.idea/deployment.xml View File

<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project version="4"> <project version="4">
<component name="PublishConfigData" autoUpload="Always" serverName="thsw2@192.168.10.66:22" remoteFilesAllowedToDisappearOnAutoupload="false">
<component name="PublishConfigData" autoUpload="Always" serverName="10.11" remoteFilesAllowedToDisappearOnAutoupload="false">
<serverData> <serverData>
<paths name="10.11"> <paths name="10.11">
<serverdata> <serverdata>
<mappings> <mappings>
<mapping deploy="/home/thsw/tuo_heng/prod/algSch" local="$PROJECT_DIR$" web="/" />
<mapping deploy="/home/thsw/tuo_heng/prod/fk" local="$PROJECT_DIR$" web="/" />
</mappings> </mappings>
</serverdata> </serverdata>
</paths> </paths>

+ 3
- 4
.idea/workspace.xml View File

</component> </component>
<component name="ChangeListManager"> <component name="ChangeListManager">
<list default="true" id="4f7dccd9-8f92-4a6e-90cc-33890d102263" name="Changes" comment="Changes"> <list default="true" id="4f7dccd9-8f92-4a6e-90cc-33890d102263" name="Changes" comment="Changes">
<change beforePath="$PROJECT_DIR$/.idea/deployment.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/deployment.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" /> <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/entity/FeedBack.py" beforeDir="false" afterPath="$PROJECT_DIR$/entity/FeedBack.py" afterDir="false" />
<change beforePath="$PROJECT_DIR$/fk_application.yml" beforeDir="false" afterPath="$PROJECT_DIR$/fk_application.yml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/service/Dispatcher.py" beforeDir="false" afterPath="$PROJECT_DIR$/service/Dispatcher.py" afterDir="false" /> <change beforePath="$PROJECT_DIR$/service/Dispatcher.py" beforeDir="false" afterPath="$PROJECT_DIR$/service/Dispatcher.py" afterDir="false" />
<change beforePath="$PROJECT_DIR$/test/kafka/producer_start.py" beforeDir="false" afterPath="$PROJECT_DIR$/test/kafka/producer_start.py" afterDir="false" />
</list> </list>
<option name="SHOW_DIALOG" value="false" /> <option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" /> <option name="HIGHLIGHT_CONFLICTS" value="true" />
<workItem from="1668557058851" duration="7348000" /> <workItem from="1668557058851" duration="7348000" />
<workItem from="1668729963723" duration="1367000" /> <workItem from="1668729963723" duration="1367000" />
<workItem from="1668992475881" duration="5624000" /> <workItem from="1668992475881" duration="5624000" />
<workItem from="1669712597426" duration="710000" />
<workItem from="1669712597426" duration="1097000" />
<workItem from="1669779593434" duration="362000" />
</task> </task>
<servers /> <servers />
</component> </component>

+ 2
- 2
service/Dispatcher.py View File

carUrl = flowMan.get("carUrl") carUrl = flowMan.get("carUrl")
flowManUrlList = flowMan.get("flowManUrlList") flowManUrlList = flowMan.get("flowManUrlList")
args_list = [] args_list = []
if carUrl is not None or len(carUrl) > 0:
if carUrl is not None and len(carUrl) > 0:
args_list.append(('plate', carUrl, gpuId, fkmodel, orc, msgId)) args_list.append(('plate', carUrl, gpuId, fkmodel, orc, msgId))
for flowManUrl in flowManUrlList: for flowManUrl in flowManUrlList:
if flowManUrl is not None or len(flowManUrl) > 0:
if flowManUrl is not None and len(flowManUrl) > 0:
args_list.append(('code', flowManUrl, gpuId, fkmodel, orc, msgId)) args_list.append(('code', flowManUrl, gpuId, fkmodel, orc, msgId))
register = message_register(registerId=registerId, carUrl=carUrl, carCode="", flowManRecognitionlList=[]) register = message_register(registerId=registerId, carUrl=carUrl, carCode="", flowManRecognitionlList=[])
with ThreadPoolExecutor(max_workers=2) as t: with ThreadPoolExecutor(max_workers=2) as t:

Loading…
Cancel
Save