git -C '/home/opc/rocketa.git' show f14d77f -- oci_func/click/func.py

commit f14d77f0854ea539cc4cf3939a965a90ab2deac3
Author: Satoshi Ujihara <satoshi_ujihara@fivegate.jp>
Date:   Fri Oct 17 18:19:48 2025 +0900

    翻訳作業
    クリック処理更新
    成果受け取り作業更新

diff --git a/oci_func/click/func.py b/oci_func/click/func.py
index 99f2dae..346a71a 100644
--- a/oci_func/click/func.py
+++ b/oci_func/click/func.py
@@ -9,10 +9,14 @@ import string
 import random
 import urllib.parse
 import hashlib
+import os, time
 
 
 from fdk import response
 
+
+os.environ['TZ'] = 'Asia/Tokyo'
+time.tzset()
 logging.basicConfig(level=logging.INFO)
 
 
@@ -70,6 +74,8 @@ def handler(ctx, data: io.BytesIO = None):
     hash_value            = ''
     hash_text             = ''
 
+    other_parameter_list  =[]
+
     defined_parameters = {
         'ad_id',
         'client_id',
@@ -87,9 +93,6 @@ def handler(ctx, data: io.BytesIO = None):
     if headers.get('referer') is not None:
         referer = headers.get('referer')
 
-    if headers.get('referer') is not None:
-        referer = headers.get('referer', [None])[0]
-
     # GETパラメータチェックと変数化
     if query_params.get('ad_id') is not None:
         ad_id = query_params.get('ad_id', [None])[0]
@@ -116,12 +119,15 @@ def handler(ctx, data: io.BytesIO = None):
 
     # パートナー独自パラメータをother_parametersに保存
     for key, value in query_params.items():
+        logging.info(f"■■■125■■■■{key}={value[0]}")
         if key not in defined_parameters:
-            other_parameters = other_parameters + key + '=' + value + '&'
-
+#            other_parameters = other_parameters + key + '=' + value + '&'
+            other_parameter_list.append(f"{key}={value[0]}")
 
+    other_parameters = '&'.join(other_parameter_list)
     if other_parameters is not None:
-        other_parameters = other_parameters.rstrip('&')
+        logging.info(f"■■■131■■■■{other_parameters}")
+#        other_parameters = other_parameters.rstrip('&')
 
     logging.info(f"■■■163■■■■{error}")
     # 広告詳細取得
@@ -425,24 +431,24 @@ def handler(ctx, data: io.BytesIO = None):
         sql_query += ') '
 
         params = {
-            "master_ad_id": int(ad_id or 0),
-            "client_id": int(client_id or 0),
-            "media_id": int(media_id or 0),
-            "banner_id": int(banner_id or 0),
-            "uid": uid,
+            "master_ad_id": int(ad_id),
+            "client_id": int(client_id),
+            "media_id": int(media_id),
+            "banner_id": int(banner_id) if banner_id else None,
+            "uid": uid  if uid else None,
             "sid": sid,
             "ip": ip,
             "user_agent": user_agent,
-            "referer": referer,
-            "net_price": net_price,
-            "net_price_unit": net_price_unit,
-            "gross_price": gross_price,
-            "gross_price_unit": gross_price_unit,
-            "other_parameters": other_parameters,
-            "created_ym": int(created_ym),       
+            "referer": referer if referer else None,
+            "net_price": net_price if net_price else None,
+            "net_price_unit": net_price_unit if net_price_unit else None,
+            "gross_price": gross_price if gross_price else None,
+            "gross_price_unit": gross_price_unit if gross_price_unit else None,
+            "other_parameters": other_parameters if other_parameters else None,
+            "created_ym": int(created_ym),
         }
         result = connection.execute(text(sql_query), params)
-    
+        logging.info(f"■■■445■■■{text(sql_query)}")
         # トランザクションをコミットして変更を永続化
         connection.commit()