Your Name 6 년 전
부모
커밋
9622f3674d

+ 109 - 128
hg3535/.idea/workspace.xml

@@ -3,9 +3,14 @@
   <component name="ChangeListManager">
     <list default="true" id="7fa42e97-ddea-4404-91db-5a9ccc162649" name="Default Changelist" comment="">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pipeline/bangqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/bangqiu.py" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/pipeline/lanqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/lanqiu.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pipeline/roll_bangqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/roll_bangqiu.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pipeline/roll_lanqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/roll_lanqiu.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pipeline/roll_wangqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/roll_wangqiu.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pipeline/roll_zuqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/roll_zuqiu.py" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/pipeline/wangqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/wangqiu.py" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/spiders/roll_lanqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/spiders/roll_lanqiu.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pipeline/zuqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/zuqiu.py" afterDir="false" />
     </list>
     <option name="EXCLUDED_CONVERTED_TO_IGNORED" value="true" />
     <option name="SHOW_DIALOG" value="false" />
@@ -15,7 +20,7 @@
   </component>
   <component name="CoverageDataManager">
     <SUITE FILE_PATH="coverage/hg3535$items.coverage" NAME="items Coverage Results" MODIFIED="1554291398794" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$" />
-    <SUITE FILE_PATH="coverage/hg3535$main.coverage" NAME="main Coverage Results" MODIFIED="1567237737526" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$" />
+    <SUITE FILE_PATH="coverage/hg3535$main.coverage" NAME="main Coverage Results" MODIFIED="1567238781807" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$" />
     <SUITE FILE_PATH="coverage/hg3535$hgjieshu.coverage" NAME="hgjieshu Coverage Results" MODIFIED="1558494720094" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$/spiders" />
     <SUITE FILE_PATH="coverage/hg3535$halffull.coverage" NAME="halffull Coverage Results" MODIFIED="1554544334424" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$/spiders" />
     <SUITE FILE_PATH="coverage/hg3535$pipelines.coverage" NAME="pipelines Coverage Results" MODIFIED="1554290866137" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$" />
@@ -46,8 +51,8 @@
       <file pinned="false" current-in-tab="false">
         <entry file="file://$PROJECT_DIR$/main.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="200">
-              <caret line="10" column="35" selection-start-line="10" selection-start-column="31" selection-end-line="10" selection-end-column="38" />
+            <state relative-caret-position="180">
+              <caret line="9" column="38" lean-forward="true" selection-start-line="9" selection-start-column="38" selection-end-line="9" selection-end-column="38" />
               <folding>
                 <element signature="e#0#10#0" expanded="true" />
               </folding>
@@ -58,8 +63,8 @@
       <file pinned="false" current-in-tab="true">
         <entry file="file://$PROJECT_DIR$/pipeline/lanqiu.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="1670">
-              <caret line="290" column="27" lean-forward="true" selection-start-line="290" selection-start-column="27" selection-end-line="290" selection-end-column="27" />
+            <state relative-caret-position="1157">
+              <caret line="157" column="17" lean-forward="true" selection-start-line="157" selection-start-column="17" selection-end-line="157" selection-end-column="17" />
               <folding>
                 <element signature="e#0#15#0" expanded="true" />
               </folding>
@@ -68,65 +73,34 @@
         </entry>
       </file>
       <file pinned="false" current-in-tab="false">
-        <entry file="file://$PROJECT_DIR$/pipeline/roll_bangqiu.py">
-          <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="260">
-              <caret line="13" column="2" selection-start-line="13" selection-end-line="13" selection-end-column="110" />
-            </state>
-          </provider>
-        </entry>
-      </file>
-      <file pinned="false" current-in-tab="false">
-        <entry file="file://$PROJECT_DIR$/spiders/wangqiu.py">
-          <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="-160">
-              <caret line="14" column="20" selection-start-line="14" selection-start-column="20" selection-end-line="14" selection-end-column="20" />
-            </state>
-          </provider>
-        </entry>
-      </file>
-      <file pinned="false" current-in-tab="false">
-        <entry file="file://$PROJECT_DIR$/pipeline/wangqiu.py">
+        <entry file="file://$PROJECT_DIR$/pipeline/roll_lanqiu.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="220">
-              <caret line="11" lean-forward="true" selection-start-line="11" selection-end-line="11" />
+            <state relative-caret-position="897">
+              <caret line="295" column="16" lean-forward="true" selection-start-line="295" selection-start-column="16" selection-end-line="295" selection-end-column="16" />
               <folding>
                 <element signature="e#0#15#0" expanded="true" />
-                <element signature="e#1024#12650#0" />
-              </folding>
-            </state>
-          </provider>
-        </entry>
-      </file>
-      <file pinned="false" current-in-tab="false">
-        <entry file="file://$PROJECT_DIR$/spiders/roll_lanqiu.py">
-          <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="264">
-              <caret line="89" column="20" lean-forward="true" selection-start-line="89" selection-start-column="20" selection-end-line="89" selection-end-column="20" />
-              <folding>
-                <element signature="e#24#39#0" expanded="true" />
               </folding>
             </state>
           </provider>
         </entry>
       </file>
       <file pinned="false" current-in-tab="false">
-        <entry file="file://$PROJECT_DIR$/spiders/zuqiu.py">
+        <entry file="file://$PROJECT_DIR$/pipeline/roll_bangqiu.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="200">
-              <caret line="10" lean-forward="true" selection-start-line="10" selection-end-line="10" />
+            <state relative-caret-position="-2383">
+              <caret line="110" column="32" lean-forward="true" selection-start-line="109" selection-end-line="113" selection-end-column="41" />
               <folding>
-                <element signature="e#24#35#0" expanded="true" />
+                <element signature="e#0#15#0" expanded="true" />
               </folding>
             </state>
           </provider>
         </entry>
       </file>
       <file pinned="false" current-in-tab="false">
-        <entry file="file://$PROJECT_DIR$/pipeline/roll_lanqiu.py">
+        <entry file="file://$PROJECT_DIR$/pipeline/bangqiu.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="450">
-              <caret line="288" column="11" lean-forward="true" selection-start-line="288" selection-start-column="8" selection-end-line="288" selection-end-column="50" />
+            <state relative-caret-position="277">
+              <caret line="14" lean-forward="true" selection-start-line="14" selection-end-line="14" />
               <folding>
                 <element signature="e#0#15#0" expanded="true" />
               </folding>
@@ -134,15 +108,6 @@
           </provider>
         </entry>
       </file>
-      <file pinned="false" current-in-tab="false">
-        <entry file="file://$PROJECT_DIR$/items.py">
-          <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="1018">
-              <caret line="370" column="31" lean-forward="true" selection-start-line="370" selection-start-column="31" selection-end-line="370" selection-end-column="31" />
-            </state>
-          </provider>
-        </entry>
-      </file>
     </leaf>
   </component>
   <component name="FileTemplateManagerImpl">
@@ -272,22 +237,22 @@
         <option value="$PROJECT_DIR$/spiders/guanjun.py" />
         <option value="$PROJECT_DIR$/spiders/roll_zuqiu.py" />
         <option value="$PROJECT_DIR$/spiders/roll_bangqiu.py" />
-        <option value="$PROJECT_DIR$/pipeline/bangqiu.py" />
         <option value="$PROJECT_DIR$/utils/helper.py" />
         <option value="$PROJECT_DIR$/settings.py" />
         <option value="$PROJECT_DIR$/pipeline/ball_func.py" />
-        <option value="$PROJECT_DIR$/pipeline/roll_zuqiu.py" />
-        <option value="$PROJECT_DIR$/pipeline/roll_bangqiu.py" />
         <option value="$PROJECT_DIR$/spiders/roll_wangqiu.py" />
-        <option value="$PROJECT_DIR$/pipeline/roll_wangqiu.py" />
-        <option value="$PROJECT_DIR$/pipeline/zuqiu.py" />
         <option value="$PROJECT_DIR$/spiders/zuqiu.py" />
-        <option value="$PROJECT_DIR$/main.py" />
         <option value="$PROJECT_DIR$/items.py" />
-        <option value="$PROJECT_DIR$/pipeline/roll_lanqiu.py" />
-        <option value="$PROJECT_DIR$/pipeline/wangqiu.py" />
         <option value="$PROJECT_DIR$/spiders/roll_lanqiu.py" />
+        <option value="$PROJECT_DIR$/main.py" />
+        <option value="$PROJECT_DIR$/pipeline/zuqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/roll_zuqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/roll_wangqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/wangqiu.py" />
         <option value="$PROJECT_DIR$/pipeline/lanqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/roll_lanqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/roll_bangqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/bangqiu.py" />
       </list>
     </option>
   </component>
@@ -599,7 +564,7 @@
       <workItem from="1566976369645" duration="4000" />
       <workItem from="1566976385269" duration="13184000" />
       <workItem from="1566990066292" duration="35762000" />
-      <workItem from="1567126891838" duration="54444000" />
+      <workItem from="1567126891838" duration="60887000" />
     </task>
     <task id="LOCAL-00001" summary="修改后,版本二">
       <created>1555727493584</created>
@@ -839,11 +804,25 @@
       <option name="project" value="LOCAL" />
       <updated>1567236587848</updated>
     </task>
-    <option name="localTasksCounter" value="35" />
+    <task id="LOCAL-00035" summary="updata">
+      <created>1567238041397</created>
+      <option name="number" value="00035" />
+      <option name="presentableId" value="LOCAL-00035" />
+      <option name="project" value="LOCAL" />
+      <updated>1567238041398</updated>
+    </task>
+    <task id="LOCAL-00036" summary="updata">
+      <created>1567239137632</created>
+      <option name="number" value="00036" />
+      <option name="presentableId" value="LOCAL-00036" />
+      <option name="project" value="LOCAL" />
+      <updated>1567239137632</updated>
+    </task>
+    <option name="localTasksCounter" value="37" />
     <servers />
   </component>
   <component name="TimeTrackingManager">
-    <option name="totallyTimeSpent" value="1733118000" />
+    <option name="totallyTimeSpent" value="1739561000" />
   </component>
   <component name="TodoView">
     <todo-panel id="selected-file">
@@ -873,7 +852,7 @@
       <window_info anchor="bottom" id="Event Log" order="9" sideWeight="0.50692964" side_tool="true" weight="0.38519314" />
       <window_info anchor="bottom" x="22" y="376" width="1876" height="298" id="Terminal" order="10" sideWeight="0.49307036" weight="0.3530043" />
       <window_info anchor="bottom" id="Python Console" order="11" sideWeight="0.49946696" weight="0.4356223" />
-      <window_info anchor="bottom" id="Run" order="12" sideWeight="0.87473345" visible="true" weight="0.31330472" />
+      <window_info anchor="bottom" id="Run" order="12" sideWeight="0.87473345" visible="true" weight="0.21995708" />
       <window_info anchor="right" id="Commander" internal_type="SLIDING" order="0" type="SLIDING" weight="0.4" />
       <window_info anchor="right" id="Ant Build" order="1" weight="0.25" />
       <window_info anchor="right" content_ui="combo" id="Hierarchy" order="2" weight="0.25" />
@@ -994,12 +973,12 @@
         </line-breakpoint>
         <line-breakpoint enabled="true" suspend="THREAD" type="python-line">
           <url>file://$PROJECT_DIR$/pipeline/zuqiu.py</url>
-          <line>239</line>
+          <line>248</line>
           <option name="timeStamp" value="46" />
         </line-breakpoint>
         <line-breakpoint enabled="true" suspend="THREAD" type="python-line">
           <url>file://$PROJECT_DIR$/pipeline/roll_zuqiu.py</url>
-          <line>433</line>
+          <line>448</line>
           <option name="timeStamp" value="49" />
         </line-breakpoint>
         <line-breakpoint enabled="true" suspend="THREAD" type="python-line">
@@ -1019,12 +998,12 @@
         </line-breakpoint>
         <line-breakpoint enabled="true" suspend="THREAD" type="python-line">
           <url>file://$PROJECT_DIR$/pipeline/zuqiu.py</url>
-          <line>262</line>
+          <line>271</line>
           <option name="timeStamp" value="62" />
         </line-breakpoint>
         <line-breakpoint enabled="true" suspend="THREAD" type="python-line">
           <url>file://$PROJECT_DIR$/pipeline/zuqiu.py</url>
-          <line>196</line>
+          <line>205</line>
           <option name="timeStamp" value="65" />
         </line-breakpoint>
         <line-breakpoint enabled="true" suspend="THREAD" type="python-line">
@@ -1049,7 +1028,7 @@
         </line-breakpoint>
         <line-breakpoint enabled="true" suspend="THREAD" type="python-line">
           <url>file://$PROJECT_DIR$/pipeline/roll_wangqiu.py</url>
-          <line>267</line>
+          <line>279</line>
           <option name="timeStamp" value="71" />
         </line-breakpoint>
         <line-breakpoint enabled="true" suspend="THREAD" type="python-line">
@@ -1295,16 +1274,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/bangqiu.py">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="1560">
-          <caret line="285" column="36" selection-start-line="284" selection-end-line="286" selection-end-column="41" />
-          <folding>
-            <element signature="e#0#15#0" expanded="true" />
-          </folding>
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/settings.py">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="296">
@@ -1322,16 +1291,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/roll_zuqiu.py">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="441">
-          <caret line="538" selection-start-line="538" selection-end-line="538" selection-end-column="52" />
-          <folding>
-            <element signature="e#18#33#0" expanded="true" />
-          </folding>
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/spiders/wqbodan.py">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="-1665" />
@@ -1354,16 +1313,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/zuqiu.py">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="-652">
-          <caret line="469" column="98" selection-start-line="469" selection-start-column="98" selection-end-line="469" selection-end-column="98" />
-          <folding>
-            <element signature="e#0#15#0" expanded="true" />
-          </folding>
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/spiders/roll_wangqiu.py">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="40">
@@ -1384,16 +1333,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/roll_wangqiu.py">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="4666">
-          <caret line="270" selection-start-line="270" selection-end-line="270" />
-          <folding>
-            <element signature="e#0#15#0" expanded="true" />
-          </folding>
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/items.py">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="1018">
@@ -1418,10 +1357,20 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/roll_lanqiu.py">
+    <entry file="file://$PROJECT_DIR$/main.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="450">
-          <caret line="288" column="11" lean-forward="true" selection-start-line="288" selection-start-column="8" selection-end-line="288" selection-end-column="50" />
+        <state relative-caret-position="180">
+          <caret line="9" column="38" lean-forward="true" selection-start-line="9" selection-start-column="38" selection-end-line="9" selection-end-column="38" />
+          <folding>
+            <element signature="e#0#10#0" expanded="true" />
+          </folding>
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/pipeline/roll_wangqiu.py">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="4937">
+          <caret line="249" column="13" lean-forward="true" selection-start-line="249" selection-start-column="13" selection-end-line="249" selection-end-column="13" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
           </folding>
@@ -1430,28 +1379,37 @@
     </entry>
     <entry file="file://$PROJECT_DIR$/pipeline/wangqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="220">
-          <caret line="11" lean-forward="true" selection-start-line="11" selection-end-line="11" />
+        <state relative-caret-position="543">
+          <caret line="163" column="40" lean-forward="true" selection-start-line="163" selection-start-column="40" selection-end-line="163" selection-end-column="40" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
-            <element signature="e#1024#12650#0" />
           </folding>
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/main.py">
+    <entry file="file://$PROJECT_DIR$/pipeline/roll_zuqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="200">
-          <caret line="10" column="35" selection-start-line="10" selection-start-column="31" selection-end-line="10" selection-end-column="38" />
+        <state relative-caret-position="463">
+          <caret line="86" column="17" lean-forward="true" selection-start-line="86" selection-end-line="88" selection-end-column="43" />
           <folding>
-            <element signature="e#0#10#0" expanded="true" />
+            <element signature="e#18#33#0" expanded="true" />
+          </folding>
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/pipeline/zuqiu.py">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="463">
+          <caret line="121" column="44" selection-start-line="121" selection-start-column="44" selection-end-line="121" selection-end-column="44" />
+          <folding>
+            <element signature="e#0#15#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
     <entry file="file://$PROJECT_DIR$/spiders/roll_lanqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="264">
+        <state relative-caret-position="-12017">
           <caret line="89" column="20" lean-forward="true" selection-start-line="89" selection-start-column="20" selection-end-line="89" selection-end-column="20" />
           <folding>
             <element signature="e#24#39#0" expanded="true" />
@@ -1459,17 +1417,40 @@
         </state>
       </provider>
     </entry>
+    <entry file="file://$PROJECT_DIR$/pipeline/roll_lanqiu.py">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="897">
+          <caret line="295" column="16" lean-forward="true" selection-start-line="295" selection-start-column="16" selection-end-line="295" selection-end-column="16" />
+          <folding>
+            <element signature="e#0#15#0" expanded="true" />
+          </folding>
+        </state>
+      </provider>
+    </entry>
     <entry file="file://$PROJECT_DIR$/pipeline/roll_bangqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="260">
-          <caret line="13" column="2" selection-start-line="13" selection-end-line="13" selection-end-column="110" />
+        <state relative-caret-position="-2383">
+          <caret line="110" column="32" lean-forward="true" selection-start-line="109" selection-end-line="113" selection-end-column="41" />
+          <folding>
+            <element signature="e#0#15#0" expanded="true" />
+          </folding>
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/pipeline/bangqiu.py">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="277">
+          <caret line="14" lean-forward="true" selection-start-line="14" selection-end-line="14" />
+          <folding>
+            <element signature="e#0#15#0" expanded="true" />
+          </folding>
         </state>
       </provider>
     </entry>
     <entry file="file://$PROJECT_DIR$/pipeline/lanqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="1670">
-          <caret line="290" column="27" lean-forward="true" selection-start-line="290" selection-start-column="27" selection-end-line="290" selection-end-column="27" />
+        <state relative-caret-position="1157">
+          <caret line="157" column="17" lean-forward="true" selection-start-line="157" selection-start-column="17" selection-end-line="157" selection-end-column="17" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
           </folding>

+ 19 - 9
hg3535/pipeline/bangqiu.py

@@ -119,12 +119,18 @@ class Bangqiupipeline(object):
             league_list.append(league_data)
             league_dict['data'] = league_list
             res = Helper.async_post(LEAGUE_URL, league_dict)
-            if '成功' in res:
-                self.db.bq_league35.insert(league_data)
-                logger.info('棒球联赛提交成功, {}'.format(res))
+            if res:
+                if '成功' in res:
+                    self.db.bq_league35.insert(league_data)
+                    logger.info('棒球联赛提交成功, {}'.format(res))
+                else:
+                    logger.warning('棒球联赛提交失败, {}'.format(res))
+                    logger.warning(league_dict)
             else:
-                logger.warning('棒球联赛提交失败, {}'.format(res))
+                logger.warning('棒球滚球联赛,接口异常,提交失败, {}'.format(res))
                 logger.warning(league_dict)
+        else:
+            logger.info('棒球滚球联赛, 已存在不提交')
 
         pt_dict = {'1': 'is_today', '2': 'is_morningplate', '3': 'is_stringscene', '4': 'is_rollball'}
         pt_status = pt_dict[pt]
@@ -157,11 +163,15 @@ class Bangqiupipeline(object):
             match_list.append(match_data)
             match_dict['data'] = match_list
             res = Helper.async_post(MATCH_URL, match_dict)
-            if '成功' in res:
-                self.db.bq_competition35.insert(match_data)
-                logger.info('棒球赛事提交成功, {}'.format(res))
+            if res:
+                if '成功' in res:
+                    self.db.bq_competition35.insert(match_data)
+                    logger.info('棒球赛事提交成功, {}'.format(res))
+                else:
+                    logger.warning('棒球赛事提交失败, {}'.format(res))
+                    logger.warning(match_data)
             else:
-                logger.warning('棒球赛事提交失败, {}'.format(res))
+                logger.warning('棒球赛事接口异常, 提交失败, {}'.format(res))
                 logger.warning(match_data)
         else:
             logger.info("棒球赛事已存在,不做修改")
@@ -283,7 +293,7 @@ class Bangqiupipeline(object):
                     logger.warning('棒球赔率提交失败, {}'.format(res))
                     logger.warning(odds_dict)
             else:
-                logger.warning('详细接口赔率返回异常, {}'.format(res))
+                logger.warning('棒球详细接口赔率,接口异常, 提交失败')
                 logger.warning(odds_dict)
         else:
             logger.info('棒球详细赔率列表为空, 不提交')

+ 35 - 9
hg3535/pipeline/lanqiu.py

@@ -104,8 +104,19 @@ class Lanqiupipeline(object):
             league_list.append(league_data)
             league_dict['data'] = league_list
             res = Helper.async_post(LEAGUE_URL, league_dict)
-            if "成功" in res:
-                self.db.zq_league35.insert(league_data)
+            if res:
+                if '成功' in res:
+                    logger.info('篮球联赛提交成功, {}'.format(res))
+                    self.db.hg3535_lq_league.insert(league_list)
+                    logger.info(league_dict)
+                else:
+                    logger.warning('篮球联赛提交失败, {}'.format(res))
+            else:
+                logger.warning('篮球联赛接口, 提交失败, {}'.format(res))
+                logger.warning(league_dict)
+        else:
+            logger.info('篮球联赛已存在')
+
         """赛事"""
         if pt == 3:
             is_rollball = 0
@@ -136,8 +147,19 @@ class Lanqiupipeline(object):
             match_list.append(match_data)
             match_dict['data'] = match_list
             res = Helper.async_post(MATCH_URL, match_dict)
-            if "成功" in res:
-                self.db.lq_competition35.insert(match_data)
+            if res:
+                if '成功' in res:
+                    logger.info('篮球赛事提交成功, {}'.format(res))
+                    self.db.hg3535_lq_competition.insert(match_list)
+                    logger.info(match_dict)
+                else:
+                    logger.warning('篮球赛事提交失败, {}'.format(res))
+                    logger.warning(match_dict)
+            else:
+                logger.warning('篮球赛事接口异常,提交失败, {}'.format(res))
+                logger.warning(match_dict)
+        else:
+            logger.info('篮球赛事已存在')
 
         """赔率"""
         data_list = []
@@ -286,12 +308,16 @@ class Lanqiupipeline(object):
         odds_dict = dict(zip(odds_key, odds_value))
         if data_list:
             res = Helper.async_post(ODDS_URL, odds_dict)
-            if '成功' in res:
-                logger.info('篮球详细赔率提交成功, {}'.format(res))
-                logger.info(odds_dict)
+            if res:
+                if '成功' in res:
+                    logger.info('篮球详细赔率提交成功, {}'.format(res))
+                    logger.info(odds_dict)
+                else:
+                    logger.warning('篮球详细赔率提交成功, {}'.format(res))
+                    logger.warning(odds_dict)
             else:
-                logger.warning('篮球详细赔率提交成功, {}'.format(res))
+                logger.warning('篮球详细赔率接口异常, 提交成功, {}'.format(res))
                 logger.warning(odds_dict)
         else:
-            logger.info('详细赔率')
+            logger.info('详细赔率列表为空')
         reactor.callFromThread(out.callback, item)

+ 33 - 17
hg3535/pipeline/roll_bangqiu.py

@@ -21,12 +21,12 @@ class Roll_Banqiupipeline(object):
 
     # @defer.inlineCallbacks
     def process_item(self, item, spider):
-    #     out = defer.Deferred()
-    #     reactor.callInThread(self._do_calculation, item, out)
-    #     yield out
-    #     defer.returnValue(item)
+        out = defer.Deferred()
+        reactor.callInThread(self._do_calculation, item, out)
+        yield out
+        defer.returnValue(item)
     #
-    # def _do_calculation(self, item, out):
+    def _do_calculation(self, item, out):
         # 使用twisted将mysql插入变成异步执行
         logger = logging.getLogger(__name__)
         # 联赛id
@@ -100,12 +100,18 @@ class Roll_Banqiupipeline(object):
             league_list.append(league_data)
             league_dict['data'] = league_list
             res = Helper.async_post(LEAGUE_URL, league_dict)
-            if '成功' in res:
-                self.db.bq_league35.insert(league_data)
-                logger.info('棒球滚球联赛提交成功, {}'.format(res))
+            if res:
+                if '成功' in res:
+                    self.db.bq_league35.insert(league_data)
+                    logger.info('棒球滚球联赛提交成功, {}'.format(res))
+                else:
+                    logger.warning('棒球滚球联赛提交失败, {}'.format(res))
+                    logger.warning(league_dict)
             else:
-                logger.warning('棒球滚球联赛提交失败, {}'.format(res))
+                logger.warning('棒球滚球联赛,接口异常,提交失败, {}'.format(res))
                 logger.warning(league_dict)
+        else:
+            logger.info('棒球滚球联赛, 已存在不提交')
         """赛事"""
         if self.db.bq_competition35.find({"match_id": match_id, 'is_rollball': 1}).count() < 1:
             match_list = []
@@ -119,10 +125,14 @@ class Roll_Banqiupipeline(object):
             match_list.append(match_data)
             match_dict['data'] = match_list
             res = Helper.async_post(MATCH_URL, match_dict)
-            if '成功' in res:
-                self.db.hg3535_bq_competition.insert(match_data)
+            if res:
+                if '成功' in res:
+                    self.db.hg3535_bq_competition.insert(match_data)
+                else:
+                    logger.warning('棒球滚球赛事提交失败, {}'.format(res))
+                    logger.warning(match_data)
             else:
-                logger.warning('棒球滚球赛事提交失败, {}'.format(res))
+                logger.warning('棒球滚球赛事,接口异常,提交失败, {}'.format(res))
                 logger.warning(match_data)
         else:
             logger.info("棒球赛事已存在,棒球赛事状态时间未改变,不做修改")
@@ -197,11 +207,15 @@ class Roll_Banqiupipeline(object):
         odds_dict = dict(zip(odds_key, odds_value))
         if data_list:
             res = Helper.async_post(ODDS_URL, odds_dict)
-            if "成功" in res:
-                logger.info('棒球滚球赔率提交成功, {}'.format(res))
-                logger.info(odds_dict)
+            if res:
+                if "成功" in res:
+                    logger.info('棒球滚球赔率提交成功, {}'.format(res))
+                    logger.info(odds_dict)
+                else:
+                    logger.warning('棒球滚球赔率提交失败, {}'.format(res))
+                    logger.warning(odds_dict)
             else:
-                logger.warning('棒球滚球赔率提交失败, {}'.format(res))
+                logger.warning('棒球滚球赔率接口异常,提交失败, {}'.format(res))
                 logger.warning(odds_dict)
         else:
             logger.info('棒球滚球详细赔率列表为空, 不提交')
@@ -233,9 +247,11 @@ class Roll_Banqiupipeline(object):
                 else:
                     logger.warning('棒球滚球结果记录提交失败, {}'.format(res))
                     logger.warning(odds_dict)
+
             except Exception as e:
                 logger.warning("滚球接口数据异常, 提交失败, {}".format(e))
+                logging.warning(r_data_dict)
         else:
             logger.info('棒球滚球结果记录为空, 不提交')
-        # reactor.callFromThread(out.callback, item)
+        reactor.callFromThread(out.callback, item)
 

+ 30 - 12
hg3535/pipeline/roll_lanqiu.py

@@ -102,11 +102,16 @@ class Roll_Lanqiupipeline(object):
             league_list.append(league_data)
             league_dict['data'] = league_list
             res = Helper.async_post(LEAGUE_URL, league_dict)
-            if '成功' in res:
-                logger.info('篮球滚球联赛提交成功, {}'.format(res))
-                self.db.hg3535_lq_league.insert(league_list)
+            if res:
+                if '成功' in res:
+                    logger.info('篮球滚球联赛提交成功, {}'.format(res))
+                    self.db.hg3535_lq_league.insert(league_list)
+                    logger.info(league_dict)
+                else:
+                    logger.warning('篮球滚球联赛提交失败, {}'.format(res))
             else:
-                logger.warning('篮球滚球联赛提交失败, {}'.format(res))
+                logger.warning('篮球滚球联赛接口, 提交失败, {}'.format(res))
+                logger.warning(league_dict)
         else:
             logger.info('篮球滚球联赛已存在')
 
@@ -122,11 +127,16 @@ class Roll_Lanqiupipeline(object):
             match_list.append(match_data)
             match_dict['data'] = match_list
             res = Helper.async_post(MATCH_URL, match_dict)
-            if '成功' in res:
-                logger.info('篮球滚球赛事提交成功, {}'.format(res))
-                self.db.hg3535_lq_competition.insert(match_list)
+            if res:
+                if '成功' in res:
+                    logger.info('篮球滚球赛事提交成功, {}'.format(res))
+                    self.db.hg3535_lq_competition.insert(match_list)
+                    logger.info(match_dict)
+                else:
+                    logger.warning('篮球滚球赛事提交失败, {}'.format(res))
+                    logger.warning(match_dict)
             else:
-                logger.warning('篮球滚球赛事提交失败, {}'.format(res))
+                logger.warning('篮球滚球赛事接口异常,提交失败, {}'.format(res))
                 logger.warning(match_dict)
         else:
             logger.info('篮球滚球赛事已存在')
@@ -255,11 +265,17 @@ class Roll_Lanqiupipeline(object):
         odds_dict = dict(zip(odds_key, odds_value))
         if data_list:
             res = Helper.async_post(ODDS_URL, odds_dict)
-            if "成功" in res:
-                    logger.info('篮球滚球详细赔率提交成功, {}'.format(res))
+            if res:
+                if "成功" in res:
+                        logger.info('篮球滚球详细赔率提交成功, {}'.format(res))
+                else:
+                    logger.warning('篮球滚球详细赔率提交失败, {}'.format(res))
+                    logger.warning(odds_dict)
             else:
-                logger.warning('篮球滚球详细赔率提交失败, {}'.format(res))
+                logger.warning('篮球滚球详细赔率接口异常, 提交失败, {}'.format(res))
                 logger.warning(odds_dict)
+        else:
+            logger.info('篮球滚球详细赔率列表, 不提交, {}'.format(res))
         data_list = []
         lq_rball = {"home_team": team_home, "guest_team": team_guest,
                     "lg_id": league_id, "home_rate": 0,
@@ -285,5 +301,7 @@ class Roll_Lanqiupipeline(object):
                     logger.warning('篮球滚球赛事结果记录提交失败, {}'.format(res))
                     logger.warning(r_data_dict)
             except Exception as e:
-                logger.warning('滚球数据接口异常,提交失败, {}'.format(e))
+                logger.warning('篮球滚球赛事结果数据,接口异常,提交失败, {}'.format(e))
+        else:
+            logger.info('篮球滚球赛事结果数据,为空不提交')
         reactor.callFromThread(out.callback, item)

+ 33 - 21
hg3535/pipeline/roll_wangqiu.py

@@ -17,15 +17,15 @@ class Roll_Wangqiupipeline(object):
                                          authSource='kaiyou')
         self.db = self.mongo[M_DB]
 
-    # @defer.inlineCallbacks
-    # def process_item(self, item, spider):
-    #     out = defer.Deferred()
-    #     reactor.callInThread(self._do_calculation, item, out)
-    #     yield out
-    #     defer.returnValue(item)
-    #
-    # def _do_calculation(self, item, out):
+    @defer.inlineCallbacks
     def process_item(self, item, spider):
+        out = defer.Deferred()
+        reactor.callInThread(self._do_calculation, item, out)
+        yield out
+        defer.returnValue(item)
+    #
+    def _do_calculation(self, item, out):
+    # def process_item(self, item, spider):
         logger = logging.getLogger(__name__)
         # 联赛id
         league_id = item['league_id']
@@ -108,11 +108,15 @@ class Roll_Wangqiupipeline(object):
             league_list.append(league_data)
             league_dict['data'] = league_list
             res = Helper.async_post(LEAGUE_URL, league_dict)
-            if '成功' in res:
-                self.db.wq_league35.insert(league_data)
-                logger.info('网球联赛提交成功, {}'.format(res))
+            if res:
+                if '成功' in res:
+                    self.db.wq_league35.insert(league_data)
+                    logger.info('网球联赛提交成功, {}'.format(res))
+                else:
+                    logger.warning('网球联赛提交失败, {}'.format(res))
+                    logger.warning(league_dict)
             else:
-                logger.warning('网球联赛提交失败, {}'.format(res))
+                logger.warning('网球滚球联赛接口异常提交失败, {}'.format(res))
                 logger.warning(league_dict)
         else:
             logger.info('网球联赛已存在, 不提交')
@@ -130,11 +134,15 @@ class Roll_Wangqiupipeline(object):
             match_list.append(match_data)
             match_dict['data'] = match_list
             res = Helper.async_post(MATCH_URL, match_dict)
-            if '成功' in res:
-                self.db.wq_competition35.insert(match_data)
-                logger.info('网球赛事提交成功, {}'.format(res))
+            if res:
+                if '成功' in res:
+                    self.db.wq_competition35.insert(match_data)
+                    logger.info('网球赛事提交成功, {}'.format(res))
+                else:
+                    logger.warning('网球赛事提交失败, {}'.format(res))
+                    logger.warning(match_data)
             else:
-                logger.warning('网球赛事提交失败, {}'.format(res))
+                logger.warning('网球滚球赛事接口异常提交失败, {}'.format(res))
                 logger.warning(match_data)
         else:
             logging.info('网球赛事已存在, 不提交')
@@ -229,11 +237,15 @@ class Roll_Wangqiupipeline(object):
         odds_dict = dict(zip(odds_key, odds_value))
         if data_list:
             res = Helper.async_post(ODDS_URL, odds_dict)
-            if "成功" in res:
-                logger.info('网球滚球赔率提交成功, {}'.format(res))
-                logger.info(odds_dict)
+            if res:
+                if "成功" in res:
+                    logger.info('网球滚球赔率提交成功, {}'.format(res))
+                    logger.info(odds_dict)
+                else:
+                    logger.warning('网球滚球赔率提交失败, {}'.format(res))
+                    logger.warning(odds_dict)
             else:
-                logger.warning('网球滚球赔率提交失败, {}'.format(res))
+                logger.warning('网球滚球赔率接口异常提交失败, {}'.format(res))
                 logger.warning(odds_dict)
         else:
             logger.info('网球滚球详细赔率列表为空, 不提交')
@@ -276,4 +288,4 @@ class Roll_Wangqiupipeline(object):
                 logger.warning("网球接口数据异常, 提交失败, {}".format(e))
         else:
             logger.info('网球滚球结果记录为空, 不提交')
-        # reactor.callFromThread(out.callback, item)
+        reactor.callFromThread(out.callback, item)

+ 36 - 13
hg3535/pipeline/roll_zuqiu.py

@@ -76,10 +76,16 @@ class Roll_Zuqiupipeline(object):
             league_list.append(league_data)
             league_dict['data'] = league_list
             res = Helper.async_post(LEAGUE_URL, league_dict)
-            if "成功" in res:
-                self.db.hg3535_zq_league.insert(league_list)
+            if res:
+                if "成功" in res:
+                    self.db.hg3535_zq_league.insert(league_list)
+                    logger.info('足球滚球联赛提交失败, {}'.format(res))
+                    logger.info(league_dict)
+                else:
+                    logger.warning('足球滚球联赛提交失败, {}'.format(res))
+                    logger.warning(league_dict)
             else:
-                logger.warning('足球滚球联赛提交失败, {}'.format(res))
+                logger.warning('足球滚球联赛接口异常提交失败, {}'.format(res))
                 logger.warning(league_dict)
         else:
             logger.info('足球滚球联赛已存在, 不存在')
@@ -95,8 +101,17 @@ class Roll_Zuqiupipeline(object):
             match_list.append(match_data)
             match_dict['data'] = match_list
             res = Helper.async_post(MATCH_URL, match_dict)
-            if "成功" in res:
-                self.db.zq_competition35.insert(match_data)
+            if res:
+                if "成功" in res:
+                    self.db.zq_competition35.insert(match_data)
+                    logger.info('足球滚球赛事提交成功, {}'.format(res))
+                    logger.info(match_data)
+                else:
+                    logger.warning('足球滚球赛事,提交失败, {}'.format(res))
+                    logger.warning(match_data)
+            else:
+                logger.warning('足球滚球赛事接口异常提交失败, {}'.format(res))
+                logger.warning(match_data)
         else:
             logger.info('足球滚球赛事已存在, 不提交')
         p_code = "GS"
@@ -502,10 +517,14 @@ class Roll_Zuqiupipeline(object):
         odds_dict = dict(zip(odds_key, odds_value))
         if data_list:
             res = Helper.async_post(ODDS_URL, odds_dict)
-            if "成功" in res:
-                logger.info('足球滚球详细赔率提交成功, {}'.format(res))
+            if res:
+                if "成功" in res:
+                    logger.info('足球滚球详细赔率提交成功, {}'.format(res))
+                else:
+                    logger.warning('足球滚球详细赔率提交失败, {}'.format(res))
+                    logger.warning(odds_dict)
             else:
-                logger.warning('足球滚球详细赔率提交失败, {}'.format(res))
+                logger.warning('足球滚球详细赔率接口异常,提交失败, {}'.format(res))
                 logger.warning(odds_dict)
         else:
             logger.info('足球滚球详细赔率列表为空')
@@ -528,15 +547,19 @@ class Roll_Zuqiupipeline(object):
         if data_list:
             try:
                 res = Helper.async_post(MATCH_RESULT, r_data_dict)
-                if "成功" in res:
-                    logger.info('足球滚球结果记录提交成功, {}'.format(res))
-                    logger.info(r_data_dict)
+                if res:
+                    if "成功" in res:
+                        logger.info('足球滚球结果记录提交成功, {}'.format(res))
+                        logger.info(r_data_dict)
+                    else:
+                        logger.warning('足球滚球结果记录提交失败, {}'.format(res))
+                        logger.warning(r_data_dict)
                 else:
-                    logger.warning('足球滚球结果记录提交失败, {}'.format(res))
+                    logger.warning('足球滚球结果记录接口异常,提交失败, {}'.format(res))
                     logger.warning(r_data_dict)
             except Exception as e:
                 logger.warning('滚球数据接口异常,提交失败, {}'.format(e))
-        # reactor.callFromThread(out.callback, item)
+        reactor.callFromThread(out.callback, item)
 
 
 

+ 17 - 9
hg3535/pipeline/wangqiu.py

@@ -107,11 +107,15 @@ class Wangqiupipeline(object):
             league_list.append(league_data)
             league_dict['data'] = league_list
             res = Helper.async_post(LEAGUE_URL, league_dict)
-            if '成功' in res:
-                self.db.wq_league35.insert(league_data)
-                logger.info('网球联赛提交成功, {}'.format(res))
+            if res:
+                if '成功' in res:
+                    self.db.wq_league35.insert(league_data)
+                    logger.info('网球联赛提交成功, {}'.format(res))
+                else:
+                    logger.warning('网球联赛提交失败, {}'.format(res))
+                    logger.warning(league_dict)
             else:
-                logger.warning('网球联赛提交失败, {}'.format(res))
+                logger.warning('网球联赛接口异常,提交失败, {}'.format(res))
                 logger.warning(league_dict)
         else:
             logger.info('网球联赛已存在, 不提交')
@@ -146,12 +150,16 @@ class Wangqiupipeline(object):
             match_list.append(match_data)
             match_dict['data'] = match_list
             res = Helper.async_post(MATCH_URL, match_dict)
-            if '成功' in res:
-                self.db.wq_competition35.insert(match_data)
-                logger.info('网球赛事提交成功, {}'.format(res))
+            if res:
+                if '成功' in res:
+                    self.db.wq_competition35.insert(match_data)
+                    logger.info('网球赛事提交成功, {}'.format(res))
+                else:
+                    logger.warning('网球赛事提交失败, {}'.format(res))
+                    logger.warning(match_data)
             else:
-                logger.warning('网球赛事提交失败, {}'.format(res))
-                logger.warning(match_data)
+                logger.warning('网球赛事接口异常,提交失败, {}'.format(res))
+                logger.warning(match_dict)
         else:
             logging.info('网球赛事已存在, 不提交')
 

+ 36 - 22
hg3535/pipeline/zuqiu.py

@@ -18,15 +18,15 @@ class Zuqiupipeline(object):
         self.mongo = pymongo.MongoClient(host=M_HOST, username=M_USER, password=M_PASSWORD, port=M_POST, authSource='kaiyou')
         self.db = self.mongo[M_DB]
 
-    # @defer.inlineCallbacks
-    # def process_item(self, item, spider):
-    #     out = defer.Deferred()
-    #     reactor.callInThread(self._do_calculation, item, out)
-    #     yield out
-    #     defer.returnValue(item)
-
+    @defer.inlineCallbacks
     def process_item(self, item, spider):
-    # def _do_calculation(self, item, out):
+        out = defer.Deferred()
+        reactor.callInThread(self._do_calculation, item, out)
+        yield out
+        defer.returnValue(item)
+
+    # def process_item(self, item, spider):
+    def _do_calculation(self, item, out):
         logger = logging.getLogger(__name__)
         # 比赛日期
         try:
@@ -74,9 +74,14 @@ class Zuqiupipeline(object):
             league_data = dict(zip(league_key, league_value))
             league_list.append(league_data)
             league_dict['data'] = league_list
-            response_data = Helper.async_post(LEAGUE_URL, league_dict)
-            if "成功" in response_data:
-                self.db.zq_league35.insert(league_list)
+            res = Helper.async_post(LEAGUE_URL, league_dict)
+            if res:
+                if "成功" in res:
+                    self.db.zq_league35.insert(league_list)
+            else:
+                logging.warning('足球详细赔率接口异常, {}'.format(res))
+        else:
+            logging.info('{},联赛已存在, 不提交'.format(league_name))
         pt_dict = {'1': 'is_today', '2': 'is_morningplate', '3': 'is_stringscene', '4': 'is_rollball'}
         pt_status = pt_dict[pt]
         if pt == '3':
@@ -106,11 +111,15 @@ class Zuqiupipeline(object):
             match_data = dict(zip(match_kay, match_value))
             match_list.append(match_data)
             match_dict['data'] = match_list
-            response_data = Helper.async_post(MATCH_URL, match_dict)
-            if "成功" in response_data:
-                self.db.zq_competition35.insert(match_data)
+            res = Helper.async_post(MATCH_URL, match_dict)
+            if res:
+                if "成功" in res:
+                    self.db.zq_competition35.insert(match_data)
+                else:
+                    logger.warning('足球赛事表提交失败, {}'.format(res))
+                    logger.warning(match_dict)
             else:
-                logger.warning('足球赛事表提交失败, {}'.format(response_data))
+                logger.warning('足球赛事接口异常提交失败, {}'.format(res))
                 logger.warning(match_dict)
         else:
             logger.info('足球赛事已存在,不提交')
@@ -515,11 +524,16 @@ class Zuqiupipeline(object):
         odds_value = ["zq", "odds", match_id, league_id, data_list, "hg3535", odds_onlys, tag_number, uuid, ris_stringscene, utime, pt]
         odds_dict = dict(zip(odds_key, odds_value))
         if data_list:
-            response_data = Helper.async_post(ODDS_URL, odds_dict)
-            if "成功" in response_data:
-                logger.info('足球详细赔率提交成功, {}'.format(response_data))
-                logger.info(odds_dict)
+            res = Helper.async_post(ODDS_URL, odds_dict)
+            if res:
+                if "成功" in res:
+                    logger.info('足球详细赔率提交成功, {}'.format(res))
+                    logger.info(odds_dict)
+                else:
+                    logger.warning('足球相信赔率提交失败, {}'.format(res))
+                    logger.warning(odds_dict)
             else:
-                logger.warning('足球相信赔率提交失败, {}'.format(response_data))
-                logger.warning(odds_dict)
-        # reactor.callFromThread(out.callback, item)
+                logging.warning('足球详细赔率接口异常, {}'.format(res))
+        else:
+            logger.info('足球详细赔率列表为空')
+        reactor.callFromThread(out.callback, item)