|
|
@@ -1,6 +1,6 @@
|
|
|
#!/usr/bin/env python
|
|
|
# coding:utf-8
|
|
|
-import n01_anhui ,n03_beijing ,n04_shenzhen,n05_sichuan,n06_jiangsu,n07_zhejiang ,n08_fujian,n09_shandong,n10_guangdong ,n11_guangxi,n12_hebei,n13_liaoning ,n14_heilongjiang ,n15_jilin ,n16_gansu,n17_qinhai,n18_henan,n19_hubei,n20_hunnan,n21_jiangxi,n22_yunnan,n23_hainan,n24_shanxi ,n25_shanxi,n26_guizhou ,n27_neimenggu ,n28_ningxia ,n29_xizang,n33_shanghai #,n30_xj,n31_tj,n32_cq,n33_sh
|
|
|
+import n01_ah ,n03_bj ,n04_sz,n05_sc,n06_js,n07_zj ,n08_fj,n09_sd,n10_gd ,n11_gx,n12_hb,n13_ln ,n14_hlj ,n15_jl ,n16_gs,n17_qh,n18_hn,n19_hb,n20_hn,n21_jx,n22_yn,n23_hn,n24_sx ,n25_sx,n26_gz ,n27_nmg ,n28_nx ,n29_xz,n33_sh #,n30_xj,n31_tj,n32_cq,n33_sh
|
|
|
from mongo_cho import myco1,myco2,myco3,myco4,myco5,myco6,myco7,myco8,myco9,myco10,myco11,myco12,myco13,myco14,myco15,myco16,myco17,myco18,myco19,myco20,myco21,myco22,myco23,myco24,myco25,myco26,myco27,myco28,myco29,myco30,myco31,myco32,myco33
|
|
|
from mongo_cho import r_myco15,mycoup,myco1_b,myco3_b,myco5_b,myco7_b,myco10_b,myco13_b,myco14_b,myco15_b,myco16_b,myco21_b,myco23_b,myco25_b,myco27_b,myco28_b
|
|
|
import arrow
|
|
|
@@ -24,7 +24,7 @@ class Mg_upd():
|
|
|
print('>>>update OK')
|
|
|
|
|
|
def n_01(self):
|
|
|
- rpg = n01_anhui.get_ny()
|
|
|
+ rpg = n01_ah.get_ny()
|
|
|
print(rpg)
|
|
|
ny_rsd = self.se_ms('n01')
|
|
|
year = '2021年'
|
|
|
@@ -33,7 +33,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue,year)
|
|
|
- n01_anhui.r1(searhvalue, year)
|
|
|
+ n01_ah.r1(searhvalue, year)
|
|
|
self.up_ms('n01', i)
|
|
|
|
|
|
def n_03(self):
|
|
|
@@ -44,7 +44,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue,year)
|
|
|
- n03_beijing.runs(year, i)
|
|
|
+ n03_bj.runs(year,i)
|
|
|
self.up_ms('n03', i)
|
|
|
|
|
|
def n_04(self):
|
|
|
@@ -55,7 +55,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue,year)
|
|
|
- n04_shenzhen.runs(year, i) ##
|
|
|
+ n04_sz.runs(year,i) ##
|
|
|
self.up_ms('n04', i)
|
|
|
|
|
|
def n_06(self):
|
|
|
@@ -66,7 +66,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n06_jiangsu.runs(year, i) ##
|
|
|
+ n06_js.runs(year, i) ##
|
|
|
self.up_ms('n06', i)
|
|
|
|
|
|
def n_07(self):
|
|
|
@@ -77,7 +77,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n07_zhejiang.runs(year, i) ##
|
|
|
+ n07_zj.runs(year, i) ##
|
|
|
self.up_ms('n07', i)
|
|
|
|
|
|
def n_08(self):
|
|
|
@@ -89,7 +89,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- etf = n08_fujian.runs(year, i) ##
|
|
|
+ etf = n08_fj.runs(year, i) ##
|
|
|
if etf == 'er1':
|
|
|
self.up_ms('n08', i)
|
|
|
return
|
|
|
@@ -103,7 +103,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n09_shandong.runs(year, i) ##
|
|
|
+ n09_sd.runs(year, i) ##
|
|
|
self.up_ms('n09', i)
|
|
|
|
|
|
def n_10(self):
|
|
|
@@ -114,7 +114,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n10_guangdong.runs(year, i) ##
|
|
|
+ n10_gd.runs(year, i) ##
|
|
|
self.up_ms('n10', i)
|
|
|
|
|
|
def n_11(self):
|
|
|
@@ -125,7 +125,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n11_guangxi.runs(year, i) ##
|
|
|
+ n11_gx.runs(year, i) ##
|
|
|
self.up_ms('n11', i)
|
|
|
|
|
|
def n_12(self):
|
|
|
@@ -136,7 +136,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n12_hebei.runs(year, i) ##
|
|
|
+ n12_hb.runs(year, i) ##
|
|
|
self.up_ms('n12', i)
|
|
|
|
|
|
def n_13(self):
|
|
|
@@ -147,7 +147,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n13_liaoning.runs(year, i) ##
|
|
|
+ n13_ln.runs(year, i) ##
|
|
|
self.up_ms('n13', i)
|
|
|
|
|
|
def n_14(self):
|
|
|
@@ -157,7 +157,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue)
|
|
|
- n14_heilongjiang.runs(i) ##
|
|
|
+ n14_hlj.runs(i) ##
|
|
|
self.up_ms('n14', i)
|
|
|
|
|
|
def n_15(self):
|
|
|
@@ -168,7 +168,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue)
|
|
|
- n15_jilin.runs(year, i) ##
|
|
|
+ n15_jl.runs(year,i) ##
|
|
|
self.up_ms('n15', i)
|
|
|
|
|
|
def n_16(self):
|
|
|
@@ -186,15 +186,15 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}季度'.format(i)
|
|
|
print(searhvalue)
|
|
|
- n16_gansu.r1(year, i) ##
|
|
|
+ n16_gs.r1(year,i) ##
|
|
|
self.up_ms('n16', i)
|
|
|
|
|
|
def n_17(self):
|
|
|
year = self.yea
|
|
|
- n17_qinhai.runs(year)
|
|
|
+ n17_qh.runs(year)
|
|
|
|
|
|
def n_18(self):
|
|
|
- n18_henan.runs()
|
|
|
+ n18_hn.runs()
|
|
|
|
|
|
def n_19(self):
|
|
|
ny_rsd = self.se_ms('n19')
|
|
|
@@ -204,7 +204,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue)
|
|
|
- n19_hubei.runs(year, i) ##
|
|
|
+ n19_hb.runs(year,i) ##
|
|
|
self.up_ms('n19', i)
|
|
|
|
|
|
def n_20(self):
|
|
|
@@ -222,11 +222,11 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}季度'.format(i)
|
|
|
print(searhvalue)
|
|
|
- n20_hunnan.runs(year, i) ##
|
|
|
+ n20_hn.runs(year,i) ##
|
|
|
self.up_ms('n20', i)
|
|
|
|
|
|
def n_21(self):
|
|
|
- n21_jiangxi.runs()
|
|
|
+ n21_jx.runs()
|
|
|
|
|
|
def n_22(self):
|
|
|
ny_rsd = self.se_ms('n22')
|
|
|
@@ -236,7 +236,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n22_yunnan.runs(year, i) ##
|
|
|
+ n22_yn.runs(year, i) ##
|
|
|
self.up_ms('n22', i)
|
|
|
|
|
|
def n_23(self):
|
|
|
@@ -247,7 +247,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n23_hainan.runs(year, i) ##
|
|
|
+ n23_hn.runs(year, i) ##
|
|
|
self.up_ms('n23', i)
|
|
|
|
|
|
def n_24(self):
|
|
|
@@ -258,7 +258,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n24_shanxi.runs(year, i) ##
|
|
|
+ n24_sx.runs(year, i) ##
|
|
|
self.up_ms('n24', i)
|
|
|
|
|
|
def n_25(self):
|
|
|
@@ -269,7 +269,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n25_shanxi.runs(year, i) ##
|
|
|
+ n25_sx.runs(year, i) ##
|
|
|
self.up_ms('n25', i)
|
|
|
|
|
|
def n_26(self):
|
|
|
@@ -280,11 +280,11 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n26_guizhou.runs(year, i) ##
|
|
|
+ n26_gz.runs(year, i) ##
|
|
|
self.up_ms('n26', i)
|
|
|
|
|
|
def n_27(self):
|
|
|
- n27_neimenggu.r1()
|
|
|
+ n27_nmg.r1()
|
|
|
|
|
|
def n_28(self):
|
|
|
ny_rsd = self.se_ms('n28')
|
|
|
@@ -293,11 +293,11 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue)
|
|
|
- n28_ningxia.runs(i) ##
|
|
|
+ n28_nx.runs(i) ##
|
|
|
self.up_ms('n28', i)
|
|
|
|
|
|
def n_29(self):
|
|
|
- n29_xizang.runs()
|
|
|
+ n29_xz.runs()
|
|
|
|
|
|
def n_33(self):
|
|
|
ny_rsd = self.se_ms('n33')
|
|
|
@@ -307,7 +307,7 @@ class Mg_upd():
|
|
|
for i in range(lpg, tpg):
|
|
|
searhvalue = '{}月'.format(i)
|
|
|
print(searhvalue, year)
|
|
|
- n33_shanghai.runs(year, i) ##
|
|
|
+ n33_sh.runs(year, i) ##
|
|
|
self.up_ms('n33', i)
|
|
|
|
|
|
def qidong(self):
|
|
|
@@ -475,7 +475,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n01_anhui.r1_d(url, dt)
|
|
|
+ rsd = n01_ah.r1_d(url,dt)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
myco1.update_one(myquery,newv)
|
|
|
@@ -490,7 +490,7 @@ class bulu_mes():
|
|
|
url = i['uid']
|
|
|
if tfl == 3:
|
|
|
dt1 = dt.replace('/','年度') + '月'
|
|
|
- rsd = n03_beijing.r1_d(url, dt1)
|
|
|
+ rsd = n03_bj.r1_d(url,dt1)
|
|
|
myquery = {"uid":url}
|
|
|
newv = {"$set":rsd}
|
|
|
myco3.update_one(myquery,newv)
|
|
|
@@ -519,7 +519,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n07_zhejiang.r1_d(url, dt)
|
|
|
+ rsd = n07_zj.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -533,7 +533,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['uid']
|
|
|
if tfl == 3:
|
|
|
- rsd = n10_guangdong.r1_d(url, dt)
|
|
|
+ rsd = n10_gd.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"uid":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -547,7 +547,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n13_liaoning.r1_d(url, dt)
|
|
|
+ rsd = n13_ln.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -561,7 +561,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n14_heilongjiang.r1_d(url, dt)
|
|
|
+ rsd = n14_hlj.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -575,7 +575,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n15_jilin.r1_d(url, dt)
|
|
|
+ rsd = n15_jl.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -589,7 +589,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n16_gansu.r1_d(url, dt)
|
|
|
+ rsd = n16_gs.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -604,7 +604,7 @@ class bulu_mes():
|
|
|
url = i['uid']
|
|
|
if tfl == 3:
|
|
|
print(url,'=====')
|
|
|
- rsd = n21_jiangxi.r2(dt, url)
|
|
|
+ rsd = n21_jx.r2(dt,url)
|
|
|
print(rsd)
|
|
|
myquery = {"uid":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -619,7 +619,7 @@ class bulu_mes():
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
print(i)
|
|
|
- rsd = n23_hainan.r1_d(url, dt)
|
|
|
+ rsd = n23_hn.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -633,7 +633,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n25_shanxi.r1_d(url, dt)
|
|
|
+ rsd = n25_sx.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -647,7 +647,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n27_neimenggu.r1_d(url, dt)
|
|
|
+ rsd = n27_nmg.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
|
|
@@ -661,7 +661,7 @@ class bulu_mes():
|
|
|
dt = i['date']
|
|
|
url = i['url']
|
|
|
if tfl == 3:
|
|
|
- rsd = n28_ningxia.r1_d(url, dt)
|
|
|
+ rsd = n28_nx.r1_d(url,dt)
|
|
|
print(rsd)
|
|
|
myquery = {"url":url}
|
|
|
newv = {"$set":rsd}
|
czyc