From 15d4f4bb9073883433c2788e1536b4b8fca93914 Mon Sep 17 00:00:00 2001
From: pengtao <pengtao@kingsome.cn>
Date: Wed, 9 Oct 2019 16:57:41 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BC=80=E5=90=AF=E6=97=A5=E5=BF=97=E7=94=A8?=
 =?UTF-8?q?=E4=BA=8E=E8=B0=83=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ops/ad_produce.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/ops/ad_produce.py b/ops/ad_produce.py
index 3b7fe50..c31cef4 100644
--- a/ops/ad_produce.py
+++ b/ops/ad_produce.py
@@ -31,6 +31,7 @@ def get_area_by_locationid(ldid):
 
 def split_ad_info(localtionid, line):
     # 从locationid获取位置相关属性，与ad信息打包，产生提供给接口用的数据
+    log.info(f"split_ad_info {localtionid} {line} ")
     new = copy.deepcopy(line)
     location_sql = f"select x,y,x_offset,y_offset,type,mode,ld_property from location WHERE  id={localtionid}"
     data = mydb.query(location_sql)
@@ -143,11 +144,13 @@ def produce_task():
                             str01 = f"{line.get('gameid', 0)}_{locationid}_{area}"
                             key = "ad::{0}::{1}::{2}::{3}".format(str01, line['channelid'], area, locationid)
                             if int(line['ad_num']) == 0:
+                                log.info(f"add {key} {line}")
                                 sadd_adkey(key, line)
                             elif int(line['ad_num']) > 0:
                                 num = my_redis.get(f"adnum::{line['id']}_{locationid}::num") or 0
                                 print(f" get {line['id']} {locationid} num was {num}!")
                                 if int(line['ad_num']) > int(num):
+                                    log.info(f"add {key} {line}")
                                     sadd_adkey(key, line)
                                 else:
                                     redis_key = f"{line['id']}_{locationid}"