上传文件至 'dify日志导出后端'

dify日志导出后端/departmentMessage.json

@@ -0,0 +1,100 @@
+{
+    "data":[
+        {
+            "departmentId":8,
+            "departmentName":"新一代信息技术产业部",
+            "minister":"钟锦光",
+            "deputyMinister":"冯玮杰"
+        },
+        {
+            "departmentId":9,
+            "departmentName":"智能终端产业部",
+            "minister":"唐双",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":5,
+            "departmentName":"智慧生活产业部",
+            "minister":"何丽",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":15,
+            "departmentName":"国际与涉外案件部",
+            "minister":"刘桂兰",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":38,
+            "departmentName":"国际与涉外案件组",
+            "minister":"",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":39,
+            "departmentName":"赋能产业部",
+            "minister":"",
+            "deputyMinister":"徐赛玉、时乐行"
+        },
+        {
+            "departmentId":6,
+            "departmentName":"数字经济产业部",
+            "minister":"沈靖俞",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":12,
+            "departmentName":"新能源材料产业部",
+            "minister":"张晓薇",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":10,
+            "departmentName":"软件信息产业部",
+            "minister":"李姣",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":30,
+            "departmentName":"智能装备产业部",
+            "minister":"杨超",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":16,
+            "departmentName":"半导体技术产业部",
+            "minister":"李建民",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":40,
+            "departmentName":"光电显示产业部",
+            "minister":"石慧",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":7,
+            "departmentName":"互联网产业部",
+            "minister":"何倚雯",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":28,
+            "departmentName":"重庆分所",
+            "minister":"赵静",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":29,
+            "departmentName":"成都分所",
+            "minister":"赵静",
+            "deputyMinister":""
+        },
+        {
+            "departmentId":36,
+            "departmentName":"广州分所",
+            "minister":"",
+            "deputyMinister":""
+        }
+    ]
+}

dify日志导出后端/personnel_area.json

@@ -0,0 +1,177 @@
+{
+    "data":{
+        "599": "深圳",
+        "41": "深圳",
+        "25": "深圳",
+        "518": "深圳",
+        "116": "深圳",
+        "125": "深圳",
+        "124": "深圳",
+        "497": "深圳",
+        "597": "深圳",
+        "516": "深圳",
+        "47": "深圳",
+        "515": "深圳",
+        "79": "深圳",
+        "526": "深圳",
+        "549": "深圳",
+        "606": "深圳",
+        "600": "深圳",
+        "637": "深圳",
+        "664": "深圳",
+        "726": "深圳",
+        "641": "苏州",
+        "16": "昆山",
+        "477": "昆山",
+        "476": "昆山",
+        "474": "昆山",
+        "603": "昆山",
+        "614": "苏州",
+
+        "814":"深圳",
+        "829":"深圳",
+        "794":"深圳",
+        "795": "深圳",
+        "18": "深圳",
+        "24": "深圳",
+        "546": "深圳",
+        "27": "深圳",
+        "455": "深圳",
+        "487": "深圳",
+        "500": "深圳",
+        "512": "深圳",
+        "22": "深圳",
+        "494": "深圳",
+        "473": "深圳",
+        "395": "深圳",
+        "463": "深圳",
+        "454": "深圳",
+        "511": "深圳",
+        "472": "深圳",
+        "439": "深圳",
+        "452": "深圳",
+        "35": "深圳",
+        "492": "深圳",
+        "496": "深圳",
+        "471": "深圳",
+        "485": "深圳",
+        "421": "坪山",
+        "114": "深圳",
+        "450": "深圳",
+        "438": "深圳",
+        "437": "深圳",
+        "54": "深圳",
+        "28": "深圳",
+        "49": "深圳",
+        "52": "坪山",
+        "57": "深圳",
+        "58": "深圳",
+        "343": "深圳",
+        "495": "深圳",
+        "469": "深圳",
+        "484": "深圳",
+        "405": "深圳",
+        "447": "深圳",
+        "605": "深圳",
+        "601": "深圳",
+        "607": "深圳",
+        "608": "深圳",
+        "611": "深圳",
+        "638": "深圳",
+        "630": "深圳",
+        "643": "坪山",
+        "550": "坪山",
+        "679": "深圳",
+        "700": "深圳",
+        "701": "深圳",
+        "695": "深圳",
+        "702": "深圳",
+        "725": "深圳",
+        "440": "广州",
+        "613": "广州",
+        "468": "武汉",
+        "115": "武汉",
+        "401": "武汉",
+        "467": "武汉",
+        "466": "武汉",
+        "332": "武汉",
+        "502": "武汉",
+        "501": "武汉",
+        "465": "武汉",
+        "431": "西安",
+        "464": "西安",
+        "430": "西安",
+        "429": "西安",
+        "428": "西安",
+        "400": "西安",
+        "40": "西安",
+        "399": "西安",
+        "39": "西安",
+        "427": "西安",
+        "426": "西安",
+        "703": "西安",
+        "755": "西安",
+        "756": "西安",
+        "30": "苏州",
+        "481": "苏州",
+        "490": "苏州",
+        "489": "苏州",
+        "44": "苏州",
+        "404": "苏州",
+        "402": "苏州",
+        "480": "苏州",
+        "479": "苏州",
+        "629": "苏州",
+        "757": "苏州",
+        "445": "南通",
+        "462": "南通",
+        "488": "南通",
+        "444": "南通",
+        "443": "南通",
+        "56": "南通",
+        "138": "南通",
+        "137": "南通",
+        "163": "南通",
+        "145": "南通",
+        "615": "南通",
+        "461": "杭州",
+        "453": "杭州",
+        "478": "杭州",
+        "460": "杭州",
+        "459": "杭州",
+        "457": "杭州",
+        "403": "杭州",
+        "55": "杭州",
+        "63": "杭州",
+        "135": "杭州",
+        "441": "杭州",
+        "602": "杭州",
+        "423": "北京小美",
+        "422": "北京小美",
+        "449": "北京小美",
+        "393": "重庆",
+        "448": "重庆",
+        "510": "重庆",
+        "499": "重庆",
+        "509": "重庆",
+        "162": "重庆",
+        "160": "重庆",
+        "161": "重庆",
+        "508": "重庆",
+        "507": "重庆",
+        "20": "重庆",
+        "506": "重庆",
+        "544": "重庆",
+        "616": "重庆",
+        "618": "重庆",
+        "647": "重庆",
+        "680": "重庆",
+        "727": "重庆",
+        "436": "成都",
+        "34": "成都",
+        "435": "成都",
+        "554": "成都",
+        "619": "成都"
+    },
+    "areas":["深圳","坪山","广州","武汉","西安","苏州","南通","杭州","北京小美","重庆","成都"]
+}

dify日志导出后端/xiaoshi_AI_userRecord_api_time.py

@@ -0,0 +1,90 @@
+# 定时
+from apscheduler.schedulers.blocking import BlockingScheduler
+import json
+import requests
+from datetime import datetime, timedelta
+import logging
+logging.basicConfig()
+logging.getLogger('apscheduler').setLevel(logging.DEBUG)
+
+#时间格式转换
+def formateDate(time_str="Thu, 07 Mar 2024 18:36:18 GMT",time_format = "%a, %d %b %Y %H:%M:%S GMT",formate='%Y-%m-%d %H:%M:%S'):
+    # 解析时间字符串为datetime对象，并设置时区为GMT
+    dt = ''
+    if isinstance(time_str, datetime):
+        dt = time_str
+    else:
+        dt = datetime.strptime(time_str, time_format)
+    # 转换为所需的日期格式 YYYY-mm-dd
+    formatted_date = dt.strftime(formate)
+    return formatted_date
+
+# 登录dify
+def dify_login():
+    result = ''
+    headers={
+        'Content-Type': 'application/json'
+    }
+    params = {
+        'email': "zhuliu@china-wispro.com",
+        'language': "zh-Hans",
+        'password': "xiaoshi221101",
+        'remember_me': True,
+    }
+    url = f"http://192.168.2.24/console/api/login"
+    response = requests.post(url, headers=headers,data=json.dumps(params))
+    response.raise_for_status()
+    json_obj = response.json()
+    if json_obj['result'] == 'success':
+        result = json_obj['data']['access_token']
+    return result
+
+# 定时任务
+def job():
+    print('启动定时')
+    # 获取token
+    token = dify_login()
+    if not token:
+        print("获取登录token失败")
+        return False
+    difyIds = ['a30f1218-bc9d-4f2a-985a-2386671a91dc','7f7812ce-89f4-4981-a55c-efe2e016cb36','01f7efbf-d23f-49f9-8ee4-740892c4f6a5']
+    yesterday =  formateDate(datetime.now() - timedelta(days=1),"%a, %d %b %Y %H:%M:%S GMT",'%Y-%m-%d')
+    startTime = f"{yesterday}T00:00"
+    endTime = f"{yesterday}T23:59"
+    headers={
+        'Content-Type': 'application/json'
+    }
+    for difyId in difyIds:
+        params = {
+            'difyId':difyId,
+            'startTime':startTime,
+            'endTime':endTime,
+            'token':token
+        }
+        try:
+            url = f"http://192.168.2.100:3500/api/getDifyRecord"
+            response = requests.post(url, headers=headers,data=json.dumps(params))
+        except Exception as e:
+            pass
+
+
+def main():
+    print("定时开始启动")
+    scheduler = BlockingScheduler()
+    # scheduler.add_job(job, 'interval', seconds=5)
+    scheduler.add_job(job, 'cron', hour=1, minute=10) 
+    # scheduler.add_job(job, 'cron', second='*/5') 
+    
+    try:
+        print("定时启动")
+        # 启动调度器
+        scheduler.start()
+        print("定时启动成功")
+    except (KeyboardInterrupt, SystemExit):
+        print("定时关闭")
+        # 关闭调度器
+        scheduler.shutdown()
+        print("Scheduler shutdown complete")
+
+if __name__ == '__main__':
+    main()