企业负面信息

comData/negative_news/ccpg.py

@@ -155,7 +155,7 @@ def getProcessitem(bdetail):
     nowDate=getNowDate()
     content=bdetail['content']
     if content!='':
-        sid='1706193555675926530'
+        sid='1534600788921110530'
         processitem={
             "sid":sid,
             "source":"18",

comData/negative_news/creditchina.py

@@ -12,6 +12,7 @@
     pageSize: 10
 }
 """
+import datetime
 import json
 import time
 from urllib import parse
@@ -31,6 +32,15 @@ r = redis.Redis(host="114.115.236.206", port=6379, password='clbzzsn', db=0)
 import urllib3
 urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
 taskType = '企业负面新闻'
+
+#获取当前时间
+def getNowDate():
+    # 获取当前时间
+    current_time = datetime.datetime.now()
+    # 将时间转换为字符串
+    currentdate = current_time.strftime("%Y-%m-%d %H:%M:%S")
+    return currentdate
+
 def sendKafka(dic_news):
     start_time = time.time()
     try:  # 114.116.116.241
@@ -293,15 +303,19 @@ def abnormal(headers,com_name,social_code):
     return url,list_abhormal
 
 def dic_data(com_name,listData,type,detailurl):
+    nowDate = getNowDate()
     dic_news = {
         'title':com_name + type,
         'structuredData':listData[:1],
         'ynStructure':1,
         'content': '',
         'contentHtml': '',
-        'source': '信用中国',
+        'source': 17,
+        'origin':'信用中国',
         'publishtime': '',
         'detailurl': detailurl,
+        'sid':'1684760229991882754',
+        'createDate':nowDate
     }
     return dic_news