From 1fb272e554f965f71564d8cc8f91a75a060f1637 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com> Date: Thu, 23 Mar 2023 10:35:25 +0800 Subject: [PATCH] 'commit' --- ETL/Mars/Model/HuiJiModel.py | 9 ++++++++- .../__pycache__/HuiJiModel.cpython-37.pyc | Bin 15042 -> 15126 bytes 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/ETL/Mars/Model/HuiJiModel.py b/ETL/Mars/Model/HuiJiModel.py index 62909c3..4df75f7 100644 --- a/ETL/Mars/Model/HuiJiModel.py +++ b/ETL/Mars/Model/HuiJiModel.py @@ -27,6 +27,8 @@ class HuiJiModel(object): # 根据任务ID获取表名 def getTableName(self, task_id): res = self.getTask(task_id) + if res is None: + return None moudle_id = res["module_id"] table_name = self.tablePrefix + str(moudle_id) return table_name @@ -100,7 +102,10 @@ class HuiJiModel(object): # 获取任务 def getTask(self, task_id): sql = "select * from t_huiji_task where task_id=%s" % task_id - return Db.findFirst(sql) + l1 = Db.find(sql) + if len(l1) == 0: + return None + return l1[0] def expandTaskReceiveOrgsPrefix(self, record): r = json.loads(record["range_json"]) @@ -441,6 +446,8 @@ class HuiJiModel(object): # 获取填报情况 def getTaskFillInfo(self, task_id, flag, page, limit): table_name = self.getTableName(task_id) + if table_name is None: + return None, 0 sql = "select distinct t1.org_code,t2.organizationname,t1.flag from {table_name} as t1 inner join schoolbusinessrelation as t2 on t1.org_code=t2.organizationno ".format( table_name=table_name) sql = sql + " where task_id={task_id} and t2.recordyear={recordyear}".format(task_id=task_id, diff --git a/ETL/Mars/Model/__pycache__/HuiJiModel.cpython-37.pyc b/ETL/Mars/Model/__pycache__/HuiJiModel.cpython-37.pyc index 81c372cb836cc8c170242eca7c2dcafec59bfc54..c3c708f4d9595fdb48f2bdae8981e2d2d2ba3f6f 100644 GIT binary patch delta 1419 zcmYk6UrbwN6u^5f{d3z==s*g#1sd2&?_farQ=q_7U@9V%f1ME~xXz2LwiNu@vW*o? zG-@Ql7>_Y#@o#)Edz$1XnwS_96OArWx5TH$@ZyuknE2p}KIl2$7}BJ_` zI6wun@r`*xfm6l_+b+N$zN6lSxRJGg0+28oojU-__+EKeg_#`6=s!mP+-XeN0#!|X zT(L}79;ByM7T;>ce^n1wxN2GjkeOB{*h@4s0=!`smAv*cst6?|6ULb9fvQy!a*T?i38*WL*mk8u_{%h{V{M{YvJiQ~7Jh5+7krfHBHy zOTMs?SrOa@aSlV?mth=ld3{zHZV>Ny18~#$(>no_=#W36D1dqYP3th*C$PExM}Lf$ zc7{sOY{z=CfE5j1xPV%NAIgn~8~PQ9;q!r$a1m!BO%64a%HwlnYVFi#-()IU14p3jm2 zWvn2Hlw&3DE?{F%H++WkJrB)o(#Fvzz*4jvega_Lq$|$?$z^-6Z7o`LGf9wFbjzMn zYoZ-Rx2BccIeOaCib#-!N*0Q4$Acct;fQNWT)y9E@BQVx>QSpztLjkgs?E63H>0?xSUbt+ hWenrr1CLa0)3T&oUK3&7>mc7+T#Yu-tG*lU{|^oQHDdq( delta 1318 zcmZ9MVQ5=b6vuP!US3|Bq{hXjF==DArfHtF?bdc_7F*VJ*le}NvQ%8!)tcpH?Q7B` zz9hAqX$J$H9n`4@hKe6n6hs)(`9N^u7e!$M6%qUpL`1(i+&4d|;61M;76bX^-gE!w zp7YK*dDmCIs5Xx|98D(vxnli0^TYJ5X1~xJQ1v^`S%7QUx&L=Kg-+LLcuUW? z{$wzSDffmg!acO3gkk){{emq)%P3(4)z;Vd>|-c+<{*LRJe?55S3O-2)3-hA5III_ z@~aCOwQ^x6wGJ|l5(0$d9CdT0TFPg&F*2M$#rq1x@t)Tw8sTDS_XXg6y~j5JJkiy* z2>Zu`+if3;!=z8*eEWBB4Ey|EID->@uYZQjEe*K&sxF;Z^ZDs?IcL!?`=gBOKMMq5 z9)AgRgGaX?xC<>5y>2O%Dr&J%t_y|qa#l;}_YMvNjAA(WxGhdsW(X-P1icW%jo=-A z(`s9?uB`UtcP(b}lqP6uf_ zf?s!keu&yycNVpUbV0qCre~!Gm2EpMnIa*LZQZO?mrG?Wf%;;HCcia1#pyUxgdB=CRr-!hg*PQC{ZVmf-B*0DO$s2A>$Gr*HhF z%?d0*&8)CZSQBfavXAee!W3bXwVJqvDdrq2NBOUqW7r$b?fMRH3nNtBu- ft0d_6ho+cwk`zx81_{HMh{d6X*Evt%&#~ygU=A=E