Changes

.gitignore

@@ -1,2 +1,4 @@
 .idea
 *.iml
+__pycache__
+.DS_Store

flomo.py

@@ -0,0 +1,37 @@
+import requests
+import time
+
+headers = {
+    'authority': 'flomoapp.com',
+    'accept': 'application/json, text/plain, */*',
+    'accept-language': 'zh-CN,zh;q=0.9,en;q=0.8',
+    'authorization': 'Bearer 1214040|p4pmlD8OOqTlzj7hiwkyAjWb6Q9HyQPyWnR322t5',
+    'cache-control': 'no-cache',
+    'content-type': 'application/json;charset=UTF-8',
+    'origin': 'https://v.flomoapp.com',
+    'pragma': 'no-cache',
+    'referer': 'https://v.flomoapp.com/',
+    'sec-ch-ua': '"Chromium";v="110", "Not A(Brand";v="24", "Google Chrome";v="110"',
+    'sec-ch-ua-mobile': '?0',
+    'sec-ch-ua-platform': '"macOS"',
+    'sec-fetch-dest': 'empty',
+    'sec-fetch-mode': 'cors',
+    'sec-fetch-site': 'same-site',
+    'user-agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/110.0.0.0 Safari/537.36',
+}
+timestamp = int(time.time())
+json_data = {
+    'content': '<p>test2</p>',
+    'created_at': timestamp,
+    'source': 'web',
+    'file_ids': [],
+    'tz': '8:0',
+    'timestamp': timestamp,
+    'api_key': 'flomo_web',
+    'app_version': '2.0',
+    'webp': '1',
+    'sign': '3c2b16926b7ecdaeb58bac6c272f044b',
+}
+
+response = requests.put('https://flomoapp.com/api/v1/memo', headers=headers, json=json_data)
+print(response.text)

tmp/kafka/kafkaReceiveTest.py

@@ -1,9 +1,11 @@
 from kafka import KafkaConsumer
+
 # tag_sink_topic\tag_atom_topic
-consumer = KafkaConsumer('model_update',
-                         group_id='test11',  # 一个组消费一次
+consumer = KafkaConsumer('tag_atom_topic',
+                         group_id='test115',  # 一个组消费一次
                          auto_offset_reset='latest',  # 从最新数据读取,earliest,latest
-                         bootstrap_servers=['kafka-0.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092','kafka-1.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092','kafka-2.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092']
+                         # bootstrap_servers=['kafka-0.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092', 'kafka-1.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092', 'kafka-2.kafka-headless.aimpdev.svc.k5.bigtree.zone:9092']
+                         bootstrap_servers=['kafka-0.kafka-headless.aimptest.svc.k5.bigtree.zone:9092', 'kafka-1.kafka-headless.aimptest.svc.k5.bigtree.zone:9092', 'kafka-2.kafka-headless.aimptest.svc.k5.bigtree.zone:9092']
                          )
 for msg in consumer:
     print(msg.value)

tmp/proxy.py

@@ -4,10 +4,10 @@ import mitmproxy.http
 
 class ProxyForward:
     def request(self, flow: mitmproxy.http.HTTPFlow) -> None:
-        url = flow.request.url
+        url = flow.request.url_date
         if url.startswith("https://eip-portal.qa.mlamp.cn/menura/ui"):
             url = url.replace("https://eip-portal.qa.mlamp.cn/menura/ui", "http://127.0.0.1:8500/ui")
-            flow.request.url = url
+            flow.request.url_date = url
 
     def response(self, flow: mitmproxy.http.HTTPFlow):
         flow.response.headers["test"] = "hhhh"

tmp2.py

@@ -0,0 +1,29 @@
+import requests
+
+
+def get_list(month: str, target: str):
+    headers = {
+        'apikey': '45f51e0b38e14178ad31e4eda44e42cd',
+        'apisecret': 'kEqdZha5xY448kh/JpwniIs74/pX5lPN8AT9lxLnjbGtFIdW32zbjT34Kxp52vqgofC43b/RSOEHPNgaKequKA=='
+    }
+    date_res = requests.get("https://api.btdp.k7.bigtree.tech/api/fakeTenant/ai_risk_model_monitor/1.0/app/dh_date?", headers=headers, params={"date": month})
+    response = requests.get("https://api.btdp.k7.bigtree.tech/api/fakeTenant/ai_risk_model_monitor/1.0/app/dh_monitor", headers=headers,
+                            params={
+                                'update_dt': month,
+                                'tag': target,
+                                'model_id': 'ai_tax_v2',
+                                'startDate': date_res.json()['startDate'],
+                                'endDate': date_res.json()['endDate']
+                            })
+    return response.json()
+
+
+list1 = get_list("2023-02", "dpd7")
+print(list1)
+
+# res_list = [
+#     {
+#         "inModel": "{\"fraud18\":27.0,\"drs_nodebtscore\":41.0,\"tl_id_m6_nbank_passorg\":1.0,\"cn_zerodeclaration_12m\":0.0,\"cn_zeroincome_24m\":0,\"cv_vat_sales_12m\":2.2078623149,\"growth_index\":null,\"income_duty_amount_24m\":11382.1,\"income_tax_12m\":91843.36,\"income_tax_12m_chu_income_duty_amount_12m\":0.9999999985,\"late_fee_24m\":0.0,\"month_late_fee_24m\":0,\"now_amount_tax_arrears_24m\":0.0,\"now_month_tax_arrears_12m\":0,\"slope_vat_sales_12m\":-0.0745797193,\"vat_duty_amount_12m\":132939.54,\"vat_duty_month_3m\":1,\"vat_sales_huanbi_1y\":0.0395612354,\"vat_sales_huanbi_6m\":-0.3750672378,\"penalty_count_total\":0,\"registcapi_chu_reccap\":0.7310585786,\"stockpercent\":80.0,\"stockpercent_jicha\":60.0}",
+#         "tag": "0",
+#         "score": "784       "
+#     }]

tmp3.py

@@ -0,0 +1,15 @@
+from DrissionPage import ChromiumPage
+
+# 创建页面对象，并启动或接管浏览器
+page = ChromiumPage()
+# 跳转到登录页面
+page.get('https://gitee.com/login')
+
+# 定位到账号文本框，获取文本框元素
+ele = page.ele('#user_login')
+# 输入对文本框输入账号
+ele.input('您的账号')
+# 定位到密码文本框并输入密码
+page.ele('#user_password').input('您的密码')
+# 点击登录按钮
+page.ele('@value=登 录').click()