9/21

base/RedisPPData.py

@@ -389,18 +389,18 @@ def yahooCode_task():
 
 #新三板
 def NQEnterprise():
-    cnx, cursor = connectSql()
+    cnx_, cursor_ = cnn11()
 
-    nq_query = "select gpdm from NQEnterprise where QCCID is not null "
-    cursor.execute(nq_query)
-    nq_result = cursor.fetchall()
+    nq_query = "SELECT social_credit_code FROM sys_base_enterprise_ipo WHERE securities_type='新三板' and listed='1'"
+    cursor_.execute(nq_query)
+    nq_result = cursor_.fetchall()
     nq_social_list = [item[0] for item in nq_result]
 
     for item in nq_social_list:
         # r.rpush('NQEnterprise:nq_Ipo', item)
         r.rpush('NQEnterprise:nq_finance',item)
         # r.rpush('NQEnterprise:nq_notice',item)
-    closeSql(cnx, cursor)
+    closeSql(cnx_, cursor_)
 
 def omeng():
     cnx, cursor = connectSql()