文件更新

cppc_python脚本/服务器脚本/daily_script_python_yun/dianwutong_shops_info.py

@@ -54,7 +54,7 @@ def getToken():
     headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36'}
     json_params = {"employee_relation_id":"7008629262119084032"}
     resp = requests.post(url,headers=headers,json=json_params).json()
-    print(json.dumps(resp,ensure_ascii=False))
+    # print(json.dumps(resp,ensure_ascii=False))
     return resp['app_id'],resp['token']
 
 #店务通查询所有门店信息
@@ -164,7 +164,7 @@ def updateInfoInMysql(db,in_json):
     cursor.execute (sql, value)
     cursor.close ()
 
-def selectNewInfoFromMysql(db,Token,applicationId,log_date,template_dict):
+def selectNewInfoFromMysql(db,Token,applicationId,log_date,template_dict,app_id, token):
 
     brand_dict = {'浆小白': '1',
                   '粥粥鲜': '2',
@@ -185,6 +185,7 @@ def selectNewInfoFromMysql(db,Token,applicationId,log_date,template_dict):
             store_id = info[0]
             data = json.loads(info[1])
             code = info[4]
+            msg = selectAllShopProvinceCityDistrictName(app_id, token, store_id) #门店区域信息
             try:
                 template = template_dict[data['order_template_id']]
             except:
@@ -201,6 +202,7 @@ def selectNewInfoFromMysql(db,Token,applicationId,log_date,template_dict):
                             '门店当前服务费率': template,
                             '服务费率最近一次变更时间': log_date,
                             '费率更新日志': f'{log_date}--新建门店信息',
+                            '门店区域':msg
                         },
                         "id": store_id,
                         "version": 0,
@@ -215,6 +217,7 @@ def selectNewInfoFromMysql(db,Token,applicationId,log_date,template_dict):
                             '门店当前服务费率': template,
                             '服务费率最近一次变更时间': log_date,
                             '费率更新日志': f'{log_date}--新建门店信息(门店基础信息不完整)',
+                            '门店区域': msg
                         },
                         "id": store_id,
                         "version": 0,
@@ -259,7 +262,8 @@ def selectNewInfoFromMysql(db,Token,applicationId,log_date,template_dict):
                     variables_parent = {
                             '门店当前服务费率': template,
                             '服务费率最近一次变更时间': log_date,
-                            '费率更新日志': template_new_log}
+                            '费率更新日志': template_new_log,
+                            '门店区域':msg}
                     update_7qiaoPlus_row (Token, applicationId, formModelId_0, variables_parent, store_id, version_parent)
                 #2主表下子表的更新操作做
                 resp_sun = select_7qiaoPlus_subrow (Token, applicationId, formModelId_1, store_id, '门店id')
@@ -440,26 +444,85 @@ def handleDWTshopInfo():
     selectAllStoreInfoSendToMysql (app_id, token, db, log_date)
     template_dict = selectServiceRate(app_id,token)
     db = linkTomySql (host, passwd, db_name, port)
-    selectNewInfoFromMysql (db, Token, applicationId, log_date, template_dict)
+    selectNewInfoFromMysql (db, Token, applicationId, log_date, template_dict,app_id, token)
+
+# 店务通查询门店省市区
+def selectAllShopProvinceCityDistrictName(app_id,token,store_id):
+    url = 'https://cloud.xc-fintech.com/api/v1/store/receiver/list'
+    headers = {
+        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36',
+        'Authorization': token}
+    json_0 = {"app_id": app_id, "store_id": store_id}
+    resp = requests.post(url,headers=headers,json=json_0).json()
+    try:
+        detail = resp['detail']
+        for info in detail:
+            if info['is_default']:
+                try:
+                    province_name = info['province_name']
+                except:
+                    province_name = '未指定'
+                try:
+                    city_name = info['city_name']
+                except:
+                    city_name = '未指定'
+                try:
+                    district_name = info['district_name']
+                except:
+                    district_name = '未指定'
+                provinceCityDistrictName = f'{province_name}-{city_name}-{district_name}'
+    except:
+        provinceCityDistrictName = '无信息'
+    return provinceCityDistrictName
+
+# 查询平台门店上线时间
+def selectPlateShopUptime(db,shop_id):
+    cursor = db.cursor()
+    sql = f'SELECT `日期` FROM shop_daily_operation_data_app WHERE `门店id` = {shop_id} AND `有效单量` > 0 ORDER BY `日期`;'
+    cursor.execute(sql)
+    try:
+        uptime = cursor.fetchall()[0][0]
+    except:
+        uptime = 'null'
+    cursor.close()
+
+    return uptime
 
 
 if __name__ == '__main__':
     # handleDWTshopInfo ()
-    log_date = datetime.now ().strftime ("%Y-%m-%d")  # 日志记录日期
+    if 1==0:
+        log_date = datetime.now ().strftime ("%Y-%m-%d")  # 日志记录日期
 
-    host = '124.222.188.59'
-    passwd = '111...Clown'
-    db_name = 'zuzu_data'
-    port = 63306
-    db = linkTomySql (host, passwd, db_name, port)
-    app_id, token = getToken ()
+        host = '124.222.188.59'
+        passwd = '111...Clown'
+        db_name = 'zuzu_data'
+        port = 63306
+        db = linkTomySql (host, passwd, db_name, port)
+        app_id, token = getToken ()
 
-    update_key_value_pair_7qiaoPlus (db, '道一云', '7qiaoPlus', 'all', '')
-    key_json = read_key_value_pair (db, '道一云', '7qiaoPlus', 'all')
-    Token = key_json['data']
-    applicationId = '63fee5abc8584e7ec9cd0bd4'
-    formModelId_1 = '640471b6addd14030e1bfe0b'
-    template_dict = selectServiceRate (app_id, token)
-    selectNewInfoFromMysql (db, Token, applicationId, "2023-03-15", template_dict)
-    # resp = select_7qiaoPlus_subrow (Token, applicationId, formModelId_1, '4990566520350973952', '门店id')
-    # print(resp)
+        update_key_value_pair_7qiaoPlus (db, '道一云', '7qiaoPlus', 'all', '')
+        key_json = read_key_value_pair (db, '道一云', '7qiaoPlus', 'all')
+        Token = key_json['data']
+        applicationId = '63fee5abc8584e7ec9cd0bd4'
+        formModelId_1 = '640471b6addd14030e1bfe0b'
+        template_dict = selectServiceRate (app_id, token)
+        selectNewInfoFromMysql (db, Token, applicationId, "2023-03-15", template_dict,app_id, token)
+        # resp = select_7qiaoPlus_subrow (Token, applicationId, formModelId_1, '4990566520350973952', '门店id')
+        # print(resp)
+    if 1==1:
+        host = '124.222.188.59'
+        passwd = '111???clown'
+        db_name = 'jxb-h'
+        port = 10036
+        db = linkTomySql(host, passwd, db_name, port)
+        # app_id, token = getToken()
+        app_id = '7005337094168150016'
+        token = '20240304-1ca76c872747486a9aaeca634925a8e6'
+        print(app_id,token)
+        store_id = '7039071139418873856'
+        msg = selectAllShopProvinceCityDistrictName(app_id, token, store_id)
+        print(msg)
+        shop_id = 1180812699
+        uptime = selectPlateShopUptime(db, shop_id)
+        print(uptime)

cppc_python脚本/服务器脚本/demo_20221026.py

@@ -1998,22 +1998,22 @@ if __name__ == '__main__':
         # 操作区
         # 运行发货单下载 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间
         start_date = '2024-02-01'
-        end_date = '2024-02-23'
+        end_date = '2024-02-29'
         mode = 'supplier_split'  # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间
         save_path = io_path
         runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode)
-        start_date = '2024-02-17'
-        end_date = '2024-02-23'
+        start_date = '2024-03-01'
+        end_date = '2024-03-01'
         mode = 'supplier_split'  # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间  11
         save_path = io_path
         runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode)
-        # start_date = '2023-12-01'
-        # end_date = '2023-12-01'
-        # mode = 'supplier_split'  # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间
-        # save_path = io_path
-        # runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode)
-        start_date = '2024-02-01'
-        end_date = '2024-02-23'
+        start_date = '2024-02-24'
+        end_date = '2024-03-01'
+        mode = 'supplier_split'  # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间
+        save_path = io_path
+        runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode)
+        start_date = '2024-03-01'
+        end_date = '2024-03-01'
         mode = 'pay'  # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间
         save_path = io_path
         runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode)