init repo

Author: jozhn

.gitignore

@@ -127,3 +127,5 @@ dmypy.json
 
 # Pyre type checker
 .pyre/
+
+.idea/

README.md

@@ -1,2 +1,30 @@
 # ddmc.monitor
-叮咚买菜 运力监控
+叮咚买菜运力监控。监控叮咚站点首页信息和购物车预约时间信息，通过Bark app通知到手机。
+
+## 使用说明
+
+### 抓包
+
+首先需要自己使用Fiddler等工具对叮咚买菜小程序抓包（PC小程序比较方便），获取`config.py`中需要的参数。
+
+### 运行
+
+本脚本提供了两种监控方式：
+
+1. **站点首页关键字监控**(免登陆，不会封号但可能封ip，默认使用)
+    - 抓包获取站点id，填写**station_id**即可
+    - 关键词不存在时则提醒(关键词为`由于近期疫情问题，配送运力紧张，本站点当前运力已约满`)
+    - 可能相比购物车有延迟
+2. **购物车预约时间监控**(需要登录，有封号风险，谨慎使用)
+    - 需要填写UA等信息作为header
+    - 然后`raw_body`填Fiddler里面请求信息的Raw tab最下面的一串url格式的字符串(类似`uid=xxx&longitude=xxx`)
+
+执行main.py即可
+
+## 依赖
+- python3
+- requests
+
+## 声明
+
+仅供学习交流使用，请勿用于非法用途。

config.py

@@ -0,0 +1,17 @@
+station_id = ''  # 站点id
+bark_id = ''  # bark app通知id
+duration = 15  # 执行间隔时间秒
+run_type = 1  # 监控类型 1首页监控 2购物车监控
+key_word = '由于近期疫情问题，配送运力紧张，本站点当前运力已约满'
+
+# 以下参数是购物车监控需要填的
+ua = ''  # User-Agent
+cookie = 'DDXQSESSID=XXXXX'  # 账号cookie 类似:DDXQSESSID=XXXXX
+city_number = '0101'  # ddmc-city-number 0101上海
+device_id = ''  # ddmc-device-id
+longitude = ''  # ddmc-longitude
+latitude = ''  # ddmc-latitude
+uid = ''  # ddmc-uid
+
+raw_body = ''
+

main.py

@@ -0,0 +1,77 @@
+import requests
+import time
+import config
+
+bark_msg_url = 'https://api.day.app/' + config.bark_id + '/'
+
+
+# 检查主页公告 无需cookie
+def check_home():
+    url = 'https://maicai.api.ddxq.mobi/homeApi/newDetails'
+    payload = {'station_id': config.station_id}
+    r = requests.get(url, params=payload)
+    if r.status_code == 200:
+        r.encoding = 'utf-8'
+        res = r.json()
+        if res['code'] == 0:
+            find = r.text.find(config.key_word)
+            params = {'group': '叮咚买菜'}
+            print(res)
+            if find > 0:
+                txt = '叮咚买菜有运力啦!!!'
+                requests.get(bark_msg_url + txt, params=params)
+            else:
+                print('还没有运力！', time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()))
+
+
+# 检查购物车 需要cookie
+def check_cart():
+    url = 'https://maicai.api.ddxq.mobi/order/getMultiReserveTime'
+    headers = {'Cookie': config.cookie,
+               'Connection': 'keep-alive',
+               'Content-Type': 'application/x-www-form-urlencoded',
+               'User-Agent': config.ua,
+               'ddmc-api-version': '9.49.1',
+               'ddmc-app-client-id': '4',
+               'ddmc-build-version': '2.81.4',
+               'ddmc-channel': 'applet',
+               'ddmc-city-number': config.city_number,
+               'ddmc-device-id': config.device_id,
+               'ddmc-ip': '',
+               'ddmc-latitude': config.latitude,
+               'ddmc-longitude': config.longitude,
+               'ddmc-os-version': '[object Undefined]',
+               'ddmc-station-id': config.station_id,
+               'ddmc-uid': config.uid,
+               'Accept-Encoding': 'gzip,compress,br,deflate',
+               'Referer': 'https://servicewechat.com/wx1e113254eda17715/421/page-frame.html',
+               }
+    raw = config.raw_body
+    r = requests.post(url, headers=headers, data=raw)
+    if r.status_code == 200:
+        r.encoding = 'utf-8'
+        res = r.json()
+        print(res)
+        if res['code'] == 0:
+            reserve_times = res['data'][0]['time'][0]['times']
+            params = {'group': '叮咚买菜'}
+            for reserve_time in reserve_times:
+                if not reserve_time['fullFlag']:
+                    txt = '叮咚买菜可以预约啦!!!最早可预约时间：' + reserve_time['select_msg']
+                    requests.get(bark_msg_url + txt, params=params)
+                    break
+        else:
+            print('还没有可预约时间!')
+
+
+def run():
+    while True:
+        if config.run_type == 1:
+            check_home()
+        else:
+            check_cart()
+        time.sleep(config.duration)
+
+
+if __name__ == '__main__':
+    run()