更新篮球, 父级玩法错误

hg3535/.idea/workspace.xml

@@ -5,6 +5,7 @@
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/main.py" beforeDir="false" afterPath="$PROJECT_DIR$/main.py" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/pipeline/bangqiu.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/bangqiu.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pipeline/guanjun.py" beforeDir="false" afterPath="$PROJECT_DIR$/pipeline/guanjun.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" />
@@ -21,7 +22,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="1568007845292" 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="1568009717445" 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$change.coverage" NAME="change Coverage Results" MODIFIED="1567749757856" 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" />
@@ -53,8 +54,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="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" />
+            <state relative-caret-position="160">
+              <caret line="8" column="37" lean-forward="true" selection-start-line="8" selection-start-column="37" selection-end-line="8" selection-end-column="37" />
               <folding>
                 <element signature="e#0#10#0" expanded="true" />
               </folding>
@@ -62,11 +63,23 @@
           </provider>
         </entry>
       </file>
+      <file pinned="false" current-in-tab="false">
+        <entry file="file://$PROJECT_DIR$/pipeline/zuqiu.py">
+          <provider selected="true" editor-type-id="text-editor">
+            <state relative-caret-position="-7902">
+              <caret line="599" selection-start-line="599" selection-end-line="600" selection-end-column="70" />
+              <folding>
+                <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/lanqiu.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="389">
-              <caret line="138" column="64" selection-start-line="138" selection-start-column="20" selection-end-line="138" selection-end-column="124" />
+            <state relative-caret-position="329">
+              <caret line="93" column="39" selection-start-line="93" selection-start-column="39" selection-end-line="93" selection-end-column="39" />
               <folding>
                 <element signature="e#0#15#0" expanded="true" />
               </folding>
@@ -74,11 +87,35 @@
           </provider>
         </entry>
       </file>
+      <file pinned="false" current-in-tab="false">
+        <entry file="file://$PROJECT_DIR$/pipeline/bangqiu.py">
+          <provider selected="true" editor-type-id="text-editor">
+            <state relative-caret-position="319">
+              <caret line="113" column="23" selection-start-line="113" selection-start-column="12" selection-end-line="113" selection-end-column="23" />
+              <folding>
+                <element signature="e#0#15#0" expanded="true" />
+              </folding>
+            </state>
+          </provider>
+        </entry>
+      </file>
+      <file pinned="false" current-in-tab="true">
+        <entry file="file://$PROJECT_DIR$/pipeline/guanjun.py">
+          <provider selected="true" editor-type-id="text-editor">
+            <state relative-caret-position="215">
+              <caret line="73" column="23" selection-start-line="73" selection-start-column="12" selection-end-line="73" selection-end-column="23" />
+              <folding>
+                <element signature="e#18#32#0" expanded="true" />
+              </folding>
+            </state>
+          </provider>
+        </entry>
+      </file>
       <file pinned="false" current-in-tab="false">
         <entry file="file://$PROJECT_DIR$/pipeline/wangqiu.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="400">
-              <caret line="157" selection-start-line="157" selection-end-line="158" selection-end-column="64" />
+            <state relative-caret-position="440">
+              <caret line="114" column="58" lean-forward="true" selection-start-line="114" selection-start-column="58" selection-end-line="114" selection-end-column="58" />
               <folding>
                 <element signature="e#0#15#0" expanded="true" />
               </folding>
@@ -89,8 +126,8 @@
       <file pinned="false" current-in-tab="false">
         <entry file="file://$PROJECT_DIR$/pipeline/roll_lanqiu.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="940">
-              <caret line="123" selection-start-line="123" selection-end-line="124" selection-end-column="64" />
+            <state relative-caret-position="-1840">
+              <caret line="122" column="44" selection-start-line="122" selection-start-column="44" selection-end-line="122" selection-end-column="44" />
               <folding>
                 <element signature="e#0#15#0" expanded="true" />
               </folding>
@@ -98,11 +135,11 @@
           </provider>
         </entry>
       </file>
-      <file pinned="false" current-in-tab="true">
-        <entry file="file://$PROJECT_DIR$/pipeline/bangqiu.py">
+      <file pinned="false" current-in-tab="false">
+        <entry file="file://$PROJECT_DIR$/pipeline/roll_wangqiu.py">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="-541">
-              <caret line="163" column="19" lean-forward="true" selection-start-line="163" selection-start-column="19" selection-end-line="163" selection-end-column="19" />
+            <state relative-caret-position="460">
+              <caret line="110" column="52" lean-forward="true" selection-start-line="110" selection-start-column="52" selection-end-line="110" selection-end-column="52" />
               <folding>
                 <element signature="e#0#15#0" expanded="true" />
               </folding>
@@ -113,8 +150,8 @@
       <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="400">
-              <caret line="86" selection-start-line="86" selection-end-line="87" selection-end-column="64" />
+            <state relative-caret-position="500">
+              <caret line="115" column="21" lean-forward="true" selection-start-line="115" selection-start-column="21" selection-end-line="115" selection-end-column="21" />
               <folding>
                 <element signature="e#0#15#0" expanded="true" />
               </folding>
@@ -245,7 +282,6 @@
         <option value="$PROJECT_DIR$/pipeline/saiguo.py" />
         <option value="$PROJECT_DIR$/spiders/saiguo.py" />
         <option value="$PROJECT_DIR$/spiders/guanjun.py" />
-        <option value="$PROJECT_DIR$/pipeline/guanjun.py" />
         <option value="$PROJECT_DIR$/items.py" />
         <option value="$PROJECT_DIR$/change.py" />
         <option value="$PROJECT_DIR$/spiders/wangqiu.py" />
@@ -260,14 +296,15 @@
         <option value="$PROJECT_DIR$/spiders/jieshu.py" />
         <option value="$PROJECT_DIR$/pipeline/jieshu.py" />
         <option value="$PROJECT_DIR$/main.py" />
-        <option value="$PROJECT_DIR$/pipeline/lanqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/roll_zuqiu.py" />
         <option value="$PROJECT_DIR$/pipeline/zuqiu.py" />
         <option value="$PROJECT_DIR$/pipeline/wangqiu.py" />
-        <option value="$PROJECT_DIR$/pipeline/roll_zuqiu.py" />
         <option value="$PROJECT_DIR$/pipeline/roll_wangqiu.py" />
         <option value="$PROJECT_DIR$/pipeline/roll_lanqiu.py" />
         <option value="$PROJECT_DIR$/pipeline/roll_bangqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/lanqiu.py" />
         <option value="$PROJECT_DIR$/pipeline/bangqiu.py" />
+        <option value="$PROJECT_DIR$/pipeline/guanjun.py" />
       </list>
     </option>
   </component>
@@ -613,28 +650,7 @@
       <workItem from="1567765446416" duration="3616000" />
       <workItem from="1567826229018" duration="3226000" />
       <workItem from="1567836768286" duration="10382000" />
-      <workItem from="1567990502559" duration="12416000" />
-    </task>
-    <task id="LOCAL-00007" summary="不启用，scrapy_deltafetch">
-      <created>1555902621561</created>
-      <option name="number" value="00007" />
-      <option name="presentableId" value="LOCAL-00007" />
-      <option name="project" value="LOCAL" />
-      <updated>1555902621561</updated>
-    </task>
-    <task id="LOCAL-00008" summary="修改棒球联赛表写入错误">
-      <created>1555925357368</created>
-      <option name="number" value="00008" />
-      <option name="presentableId" value="LOCAL-00008" />
-      <option name="project" value="LOCAL" />
-      <updated>1555925357368</updated>
-    </task>
-    <task id="LOCAL-00009" summary="修改冠军">
-      <created>1555989344488</created>
-      <option name="number" value="00009" />
-      <option name="presentableId" value="LOCAL-00009" />
-      <option name="project" value="LOCAL" />
-      <updated>1555989344488</updated>
+      <workItem from="1567990502559" duration="14139000" />
     </task>
     <task id="LOCAL-00010" summary="联赛添加redis测试">
       <created>1556014183609</created>
@@ -958,11 +974,32 @@
       <option name="project" value="LOCAL" />
       <updated>1567998227722</updated>
     </task>
-    <option name="localTasksCounter" value="56" />
+    <task id="LOCAL-00056" summary="更新篮球, 父级玩法错误">
+      <created>1568008923499</created>
+      <option name="number" value="00056" />
+      <option name="presentableId" value="LOCAL-00056" />
+      <option name="project" value="LOCAL" />
+      <updated>1568008923499</updated>
+    </task>
+    <task id="LOCAL-00057" summary="更新篮球, 父级玩法错误">
+      <created>1568009060523</created>
+      <option name="number" value="00057" />
+      <option name="presentableId" value="LOCAL-00057" />
+      <option name="project" value="LOCAL" />
+      <updated>1568009060523</updated>
+    </task>
+    <task id="LOCAL-00058" summary="更新篮球, 父级玩法错误">
+      <created>1568009292368</created>
+      <option name="number" value="00058" />
+      <option name="presentableId" value="LOCAL-00058" />
+      <option name="project" value="LOCAL" />
+      <updated>1568009292368</updated>
+    </task>
+    <option name="localTasksCounter" value="59" />
     <servers />
   </component>
   <component name="TimeTrackingManager">
-    <option name="totallyTimeSpent" value="1895820000" />
+    <option name="totallyTimeSpent" value="1897543000" />
   </component>
   <component name="TodoView">
     <todo-panel id="selected-file">
@@ -992,7 +1029,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.2693133" />
-      <window_info anchor="bottom" id="Run" order="12" sideWeight="0.87473345" visible="true" weight="0.26502147" />
+      <window_info anchor="bottom" id="Run" order="12" sideWeight="0.87473345" visible="true" weight="0.20386267" />
       <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" />
@@ -1414,16 +1451,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/guanjun.py">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="238">
-          <caret line="12" selection-start-line="12" selection-end-line="13" />
-          <folding>
-            <element signature="e#18#32#0" expanded="true" />
-          </folding>
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/spiders/guanjun.py">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="28">
@@ -1546,16 +1573,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/jieshu.py">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="391">
-          <caret line="46" column="18" lean-forward="true" selection-start-line="46" selection-start-column="18" selection-end-line="46" selection-end-column="18" />
-          <folding>
-            <element signature="e#18#33#0" expanded="true" />
-          </folding>
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/../../zq_match_status.log">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="337">
@@ -1609,30 +1626,50 @@
         </state>
       </provider>
     </entry>
+    <entry file="file://$PROJECT_DIR$/spiders/lanqiu.py">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="122">
+          <caret line="74" selection-start-line="74" selection-end-line="74" />
+          <folding>
+            <element signature="e#24#35#0" expanded="true" />
+          </folding>
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/pipeline/jieshu.py">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="195">
+          <caret line="48" column="13" lean-forward="true" selection-start-line="48" selection-start-column="13" selection-end-line="48" selection-end-column="13" />
+          <folding>
+            <element signature="e#18#33#0" expanded="true" />
+          </folding>
+        </state>
+      </provider>
+    </entry>
     <entry file="file://$PROJECT_DIR$/main.py">
       <provider selected="true" editor-type-id="text-editor">
-        <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" />
+        <state relative-caret-position="160">
+          <caret line="8" column="37" lean-forward="true" selection-start-line="8" selection-start-column="37" selection-end-line="8" selection-end-column="37" />
           <folding>
             <element signature="e#0#10#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/spiders/lanqiu.py">
+    <entry file="file://$PROJECT_DIR$/pipeline/roll_zuqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="122">
-          <caret line="74" selection-start-line="74" selection-end-line="74" />
+        <state relative-caret-position="10578">
+          <caret line="1142" lean-forward="true" selection-start-line="1142" selection-end-line="1142" />
           <folding>
-            <element signature="e#24#35#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="255">
-          <caret line="596" column="23" lean-forward="true" selection-start-line="596" selection-start-column="23" selection-end-line="596" selection-end-column="23" />
+        <state relative-caret-position="-7902">
+          <caret line="599" selection-start-line="599" selection-end-line="600" selection-end-column="70" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
           </folding>
@@ -1641,70 +1678,70 @@
     </entry>
     <entry file="file://$PROJECT_DIR$/pipeline/wangqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="400">
-          <caret line="157" selection-start-line="157" selection-end-line="158" selection-end-column="64" />
+        <state relative-caret-position="440">
+          <caret line="114" column="58" lean-forward="true" selection-start-line="114" selection-start-column="58" selection-end-line="114" selection-end-column="58" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/roll_zuqiu.py">
+    <entry file="file://$PROJECT_DIR$/pipeline/roll_wangqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="311">
-          <caret line="110" selection-start-line="110" selection-end-line="111" selection-end-column="64" />
+        <state relative-caret-position="460">
+          <caret line="110" column="52" lean-forward="true" selection-start-line="110" selection-start-column="52" selection-end-line="110" selection-end-column="52" />
           <folding>
-            <element signature="e#18#33#0" expanded="true" />
+            <element signature="e#0#15#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/roll_wangqiu.py">
+    <entry file="file://$PROJECT_DIR$/pipeline/roll_lanqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="-2865">
-          <caret line="136" column="40" lean-forward="true" selection-start-line="136" selection-end-line="137" selection-end-column="64" />
+        <state relative-caret-position="-1840">
+          <caret line="122" column="44" selection-start-line="122" selection-start-column="44" selection-end-line="122" selection-end-column="44" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/lanqiu.py">
+    <entry file="file://$PROJECT_DIR$/pipeline/roll_bangqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="389">
-          <caret line="138" column="64" selection-start-line="138" selection-start-column="20" selection-end-line="138" selection-end-column="124" />
+        <state relative-caret-position="500">
+          <caret line="115" column="21" lean-forward="true" selection-start-line="115" selection-start-column="21" selection-end-line="115" selection-end-column="21" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/roll_lanqiu.py">
+    <entry file="file://$PROJECT_DIR$/pipeline/lanqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="940">
-          <caret line="123" selection-start-line="123" selection-end-line="124" selection-end-column="64" />
+        <state relative-caret-position="329">
+          <caret line="93" column="39" selection-start-line="93" selection-start-column="39" selection-end-line="93" selection-end-column="39" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/roll_bangqiu.py">
+    <entry file="file://$PROJECT_DIR$/pipeline/bangqiu.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="400">
-          <caret line="86" selection-start-line="86" selection-end-line="87" selection-end-column="64" />
+        <state relative-caret-position="319">
+          <caret line="113" column="23" selection-start-line="113" selection-start-column="12" selection-end-line="113" selection-end-column="23" />
           <folding>
             <element signature="e#0#15#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/pipeline/bangqiu.py">
+    <entry file="file://$PROJECT_DIR$/pipeline/guanjun.py">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="-541">
-          <caret line="163" column="19" lean-forward="true" selection-start-line="163" selection-start-column="19" selection-end-line="163" selection-end-column="19" />
+        <state relative-caret-position="215">
+          <caret line="73" column="23" selection-start-line="73" selection-start-column="12" selection-end-line="73" selection-end-column="23" />
           <folding>
-            <element signature="e#0#15#0" expanded="true" />
+            <element signature="e#18#32#0" expanded="true" />
           </folding>
         </state>
       </provider>

hg3535/main.py

@@ -5,8 +5,8 @@ from scrapy.cmdline import execute
 # print(os.path.dirname(os.path.abspath(__file__)))
 sys.path.append(os.path.dirname(os.path.abspath(__file__)))
 # execute(["scrapy", "crawl", "liansai"])
-# execute(["scrapy", "crawl", "zuqiu"])
-execute(["scrapy", "crawl", "lanqiu"])
+execute(["scrapy", "crawl", "zuqiu"])
+# execute(["scrapy", "crawl", "lanqiu"])
 # execute(["scrapy", "crawl", "guanjun"])
 # execute(["scrapy", "crawl", "wangqiu"])
 # execute(["scrapy", "crawl", "wqbodan"])

hg3535/pipeline/bangqiu.py

@@ -117,9 +117,9 @@ class Bangqiupipeline(object):
             res = Helper.async_post(LEAGUE_URL, league_dict)
             if res:
                 if '成功' in res:
-                    # self.db.bq_league35.insert(league_data)
-                    self.db.bq_league35.update({'lg_id': league_id}, {'$set': league_data},
-                                                    upsert=True)
+                    self.db.bq_league35.insert(league_data)
+                    # self.db.bq_league35.update({'lg_id': league_id}, {'$set': league_data},
+                    #                                 upsert=True)
                     logger.info('棒球联赛提交成功, {}'.format(res))
                 else:
                     logger.warning('棒球联赛提交失败, {}'.format(res))
@@ -163,9 +163,9 @@ class Bangqiupipeline(object):
             res = Helper.async_post(MATCH_URL, match_dict)
             if res:
                 if '成功' in res:
-                    # self.db.bq_competition35.insert(match_data)
-                    self.db.bq_competition35.update({"match_id": match_id, pt_status: 1}, {'$set': match_data},
-                                                    upsert=True)
+                    self.db.bq_competition35.insert(match_data)
+                    # self.db.bq_competition35.update({"match_id": match_id, pt_status: 1}, {'$set': match_data},
+                    #                                 upsert=True)
                     logger.info('棒球赛事提交成功, {}'.format(res))
                 else:
                     logger.warning('棒球赛事提交失败, {}'.format(res))

hg3535/pipeline/guanjun.py

@@ -80,9 +80,9 @@ class Guanjunpipeline(object):
                     if "成功" in res:
                         logger.info('{}, {}冠军联赛, 提交成功, {}'.format(game_code, league_name, res))
                         logger.info(league_list)
-                        # self.db[league_table].insert(league_list)
-                        self.db[league_table].update({'lg_id': league_id}, {'$set': league_dict},
-                                                        upsert=True)
+                        self.db[league_table].insert(league_dict)
+                        # self.db[league_table].update({'lg_id': league_id}, {'$set': league_dict},
+                        #                                 upsert=True)
                     else:
                         logger.warning('{}, {}, 冠军联赛, 提交失败, {}'.format(game_code, league_name, res))
                         logger.warning(l_payload)

hg3535/pipeline/lanqiu.py

@@ -91,8 +91,8 @@ class Lanqiupipeline(object):
             if res:
                 if '成功' in res:
                     logger.info('篮球联赛提交成功, {}'.format(res))
-                    # self.db.hg3535_lq_league.insert(league_data)
-                    self.db.lq_league35.update({'lg_id': league_id}, {'$set': league_data}, upsert=True)
+                    self.db.lq_league35.insert(league_data)
+                    # self.db.lq_league35.update({'lg_id': league_id}, {'$set': league_data}, upsert=True)
                     logger.info(league_dict)
                 else:
                     logger.warning('篮球联赛提交失败, {}'.format(res))
@@ -135,8 +135,8 @@ class Lanqiupipeline(object):
             if res:
                 if '成功' in res:
                     logger.info('篮球赛事提交成功, {}'.format(res))
-                    # self.db.hg3535_lq_competition.insert(match_data)
-                    self.db.lq_competition35.update({'match_id': match_id, pt_status: 1}, {'$set': match_data}, upsert=True)
+                    self.db.lq_competition35.insert(match_data)
+                    # self.db.lq_competition35.update({'match_id': match_id, pt_status: 1}, {'$set': match_data}, upsert=True)
                     logger.info(match_dict)
                 else:
                     logger.warning('篮球赛事提交失败, {}'.format(res))

hg3535/pipeline/roll_bangqiu.py

@@ -83,9 +83,9 @@ class Roll_Banqiupipeline(object):
             res = Helper.async_post(LEAGUE_URL, league_dict)
             if res:
                 if '成功' in res:
-                    # self.db.bq_league35.insert(league_data)
-                    self.db.bq_competition35.update({'lg_id': league_id}, {'$set': league_data},
-                                                    upsert=True)
+                    self.db.bq_league35.insert(league_data)
+                    # self.db.bq_competition35.update({'lg_id': league_id}, {'$set': league_data},
+                    #                                 upsert=True)
                     logger.info('棒球滚球联赛提交成功, {}'.format(res))
                 else:
                     logger.warning('棒球滚球联赛提交失败, {}'.format(res))
@@ -110,9 +110,9 @@ class Roll_Banqiupipeline(object):
             res = Helper.async_post(MATCH_URL, match_dict)
             if res:
                 if '成功' in res:
-                    # self.db.hg3535_bq_competition.insert(match_data)
-                    self.db.bq_competition35.update({"match_id": match_id, 'is_rollball': 1}, {'$set': match_data},
-                                                    upsert=True)
+                    self.db.bq_competition35.insert(match_data)
+                    # self.db.bq_competition35.update({"match_id": match_id, 'is_rollball': 1}, {'$set': match_data},
+                    #                                 upsert=True)
                 else:
                     logger.warning('棒球滚球赛事提交失败, {}'.format(res))
                     logger.warning(match_data)

hg3535/pipeline/roll_lanqiu.py

@@ -93,9 +93,9 @@ class Roll_Lanqiupipeline(object):
             if res:
                 if '成功' in res:
                     logger.info('篮球滚球联赛提交成功, {}'.format(res))
-                    self.db.lq_league35.update({'lg_id': league_id}, {'$set': league_data},
-                                                    upsert=True)
-                    # self.db.lq_league35222.insert(league_data)
+                    # self.db.lq_league35.update({'lg_id': league_id}, {'$set': league_data},
+                    #                                 upsert=True)
+                    self.db.lq_league35.insert(league_data)
                     logger.info(league_dict)
                 else:
                     logger.warning('篮球滚球联赛提交失败, {}'.format(res))
@@ -120,9 +120,9 @@ class Roll_Lanqiupipeline(object):
             if res:
                 if '成功' in res:
                     logger.info('篮球滚球赛事提交成功, {}'.format(res))
-                    # self.db.hg3535_lq_competition.insert(match_data)
-                    self.db.lq_competition35.update({"match_id": match_id, 'is_rollball': 1}, {'$set': match_data},
-                                                    upsert=True)
+                    self.db.lq_competition35.insert(match_data)
+                    # self.db.lq_competition35.update({"match_id": match_id, 'is_rollball': 1}, {'$set': match_data},
+                    #                                 upsert=True)
                     logger.info(match_dict)
                 else:
                     logger.warning('篮球滚球赛事提交失败, {}'.format(res))

hg3535/pipeline/roll_wangqiu.py

@@ -105,9 +105,9 @@ class Roll_Wangqiupipeline(object):
             res = Helper.async_post(LEAGUE_URL, league_dict)
             if res:
                 if '成功' in res:
-                    # self.db.wq_league35.insert(league_data)
-                    self.db.wq_league35.update({'lg_id': league_id}, {'$set': league_data},
-                                                    upsert=True)
+                    self.db.wq_league35.insert(league_data)
+                    # self.db.wq_league35.update({'lg_id': league_id}, {'$set': league_data},
+                    #                                 upsert=True)
                     logger.info('网球联赛提交成功, {}'.format(res))
                 else:
                     logger.warning('网球联赛提交失败, {}'.format(res))
@@ -133,9 +133,9 @@ class Roll_Wangqiupipeline(object):
             res = Helper.async_post(MATCH_URL, match_dict)
             if res:
                 if '成功' in res:
-                    # self.db.wq_competition35.insert(match_data)
-                    self.db.wq_competition35.update({'match_id': match_id, 'is_rollball': 1}, {'$set': match_data},
-                                                    upsert=True)
+                    self.db.wq_competition35.insert(match_data)
+                    # self.db.wq_competition35.update({'match_id': match_id, 'is_rollball': 1}, {'$set': match_data},
+                    #                                 upsert=True)
                     logger.info('网球赛事提交成功, {}'.format(res))
                 else:
                     logger.warning('网球赛事提交失败, {}'.format(res))

hg3535/pipeline/roll_zuqiu.py

@@ -79,9 +79,9 @@ class Roll_Zuqiupipeline(object):
             res = Helper.async_post(LEAGUE_URL, league_dict)
             if res:
                 if "成功" in res:
-                    # self.db.zq_league35.insert(league_list)
-                    self.db.zq_league35.update({'lg_id': league_id}, {'$set': league_data},
-                                                    upsert=True)
+                    self.db.zq_league35.insert(league_data)
+                    # self.db.zq_league35.update({'lg_id': league_id}, {'$set': league_data},
+                    #                                 upsert=True)
                     logger.info('足球滚球联赛提交成功, {}'.format(res))
                     logger.info(league_dict)
                 else:
@@ -107,9 +107,9 @@ class Roll_Zuqiupipeline(object):
             res = Helper.async_post(MATCH_URL, match_dict)
             if res:
                 if "成功" in res:
-                    # self.db.zq_competition35.insert(match_data)
-                    self.db.zq_competition35.update({'match_id': match_id, 'is_rollball': 1}, {'$set': match_data},
-                                                    upsert=True)
+                    self.db.zq_competition35.insert(match_data)
+                    # self.db.zq_competition35.update({'match_id': match_id, 'is_rollball': 1}, {'$set': match_data},
+                    #                                 upsert=True)
                     logger.info('足球滚球赛事提交成功, {}'.format(res))
                     logger.info(match_data)
                 else:
@@ -636,9 +636,9 @@ class Roll_Zuqiupipeline(object):
                 res = Helper.async_post(MATCH_URL, match_dict)
                 if res:
                     if "成功" in res:
-                        # self.db.zq_competition35.insert(match_data)
-                        self.db.zq_competition35.update({'match_id': match_id, 'is_rollball': 1}, {'$set': match_data},
-                                                        upsert=True)
+                        self.db.zq_competition35.insert(match_data)
+                        # self.db.zq_competition35.update({'match_id': match_id, 'is_rollball': 1}, {'$set': match_data},
+                        #                                 upsert=True)
                         logger.info('足球滚球角球, 赛事提交成功, {}'.format(res))
                         logger.info(match_data)
                     else:

hg3535/pipeline/wangqiu.py

@@ -109,9 +109,9 @@ class Wangqiupipeline(object):
             res = Helper.async_post(LEAGUE_URL, league_dict)
             if res:
                 if '成功' in res:
-                    # self.db.wq_league35.insert(league_data)
-                    self.db.wq_league35.update({'lg_id': league_id}, {'$set': league_data},
-                                                    upsert=True)
+                    self.db.wq_league35.insert(league_data)
+                    # self.db.wq_league35.update({'lg_id': league_id}, {'$set': league_data},
+                    #                                 upsert=True)
                     logger.info('网球联赛提交成功, {}'.format(res))
                 else:
                     logger.warning('网球联赛提交失败, {}'.format(res))
@@ -154,9 +154,9 @@ class Wangqiupipeline(object):
             res = Helper.async_post(MATCH_URL, match_dict)
             if res:
                 if '成功' in res:
-                    # self.db.wq_competition35.insert(match_data)
-                    self.db.wq_competition35.update({'match_id': match_id, pt_status: 1}, {'$set': match_data},
-                                                    upsert=True)
+                    self.db.wq_competition35.insert(match_data)
+                    # self.db.wq_competition35.update({'match_id': match_id, pt_status: 1}, {'$set': match_data},
+                    #                                 upsert=True)
                     logger.info('网球赛事提交成功, {}'.format(res))
                 else:
                     logger.warning('网球赛事提交失败, {}'.format(res))

hg3535/pipeline/zuqiu.py

@@ -80,9 +80,9 @@ class Zuqiupipeline(object):
             res = Helper.async_post(LEAGUE_URL, league_dict)
             if res:
                 if "成功" in res:
-                    # self.db.zq_league35.insert(league_list)
-                    self.db.zq_league35.update({'lg_id': league_id}, {'$set': league_data},
-                                                    upsert=True)
+                    self.db.zq_league35.insert(league_data)
+                    # self.db.zq_league35.update({'lg_id': league_id}, {'$set': league_data},
+                    #                                 upsert=True)
             else:
                 logging.warning('足球详细赔率接口异常, {}'.format(res))
         else:
@@ -119,9 +119,9 @@ class Zuqiupipeline(object):
             res = Helper.async_post(MATCH_URL, match_dict)
             if res:
                 if "成功" in res:
-                    # self.db.zq_competition35.insert(match_data)
-                    self.db.zq_competition35.update({'match_id': match_id, pt_status: 1}, {'$set': match_data},
-                                                    upsert=True)
+                    self.db.zq_competition35.insert(match_data)
+                    # self.db.zq_competition35.update({'match_id': match_id, pt_status: 1}, {'$set': match_data},
+                    #                                 upsert=True)
                 else:
                     logger.warning('足球赛事表提交失败, {}'.format(res))
                     logger.warning(match_dict)
@@ -596,9 +596,9 @@ class Zuqiupipeline(object):
                 res = Helper.async_post(MATCH_URL, match_dict)
                 if res:
                     if "成功" in res:
-                        # self.db.zq_competition35.insert(match_data)
-                        self.db.zq_competition35.update({'match_id': match_id, pt_status: 1}, {'$set': match_data},
-                                                        upsert=True)
+                        self.db.zq_competition35.insert(match_data)
+                        # self.db.zq_competition35.update({'match_id': match_id, pt_status: 1}, {'$set': match_data},
+                        #                                 upsert=True)
                         logger.info('足球角球, 赛事表提交失败, {}'.format(res))
                         logger.info(match_dict)
                     else: