ops/datacollect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

f

Browse Source
This commit is contained in:
root 2019-09-02 20:11:27 +08:00
parent fe2ef66f17
commit 8cf9e6a9d9
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
get_new_user.py
View File

@ -8,7 +8,7 @@ import random
define_logger("/data/logs/init_first_ad_channel.log") define_logger("/data/logs/init_first_ad_channel.log")
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
TimeDelay = 10 TimeDelay = 60*60
DB = {'user': 'mytga', 'pswd': 'gzVwh4HGR68G', 'host': '10.10.3.5', 'db': 'games_report'} DB = {'user': 'mytga', 'pswd': 'gzVwh4HGR68G', 'host': '10.10.3.5', 'db': 'games_report'}
@ -16,9 +16,7 @@ DB = {'user': 'mytga', 'pswd': 'gzVwh4HGR68G', 'host': '10.10.3.5', 'db': 'games
class InitFirstAD(): class InitFirstAD():
def __init__(self, kwargs): def __init__(self, kwargs):
self.end = kwargs.get('time') self.end = kwargs.get('time')
self.begin = datetime.datetime.strftime( self.begin=(datetime.datetime.now() - datetime.timedelta(minutes=TimeDelay)).strftime('%Y-%m-%d %H:%M:%S')
datetime.datetime.strptime(self.end, '%Y-%M-%d ''%H:%M:%S') - datetime.timedelta(minutes=TimeDelay),
'%Y-%M-%d ''%H:%M:%S')
self.gameid = kwargs.get('gameid') self.gameid = kwargs.get('gameid')
self.channelid = kwargs.get('channelid') self.channelid = kwargs.get('channelid')
g = GetTgaConfig() g = GetTgaConfig()
@ -34,7 +32,9 @@ class InitFirstAD():
def run(self): def run(self):
users = self.get_new_user() users = self.get_new_user()
print(f"all={users}")
mark_users = self.hide(users) mark_users = self.hide(users)
print(f"new={mark_users}")
table_name = "newuser" table_name = "newuser"
if mark_users: if mark_users:
for line in mark_users: for line in mark_users:
@ -69,6 +69,7 @@ class InitFirstAD():
gameid='{self.gameid}' gameid='{self.gameid}'
AND "account_register_time" BETWEEN timestamp'{self.begin}' AND timestamp'{self.end}' """ AND "account_register_time" BETWEEN timestamp'{self.begin}' AND timestamp'{self.end}' """
data = self.tga.get_data(sql) data = self.tga.get_data(sql)
print(f"sql={sql}")
if data: if data:
for line in data: for line in data:
if line: if line:
@ -81,7 +82,8 @@ def main():
kwargs['time'] = datetime.datetime.now().strftime("%Y-%M-%d ''%H:%M:%S") kwargs['time'] = datetime.datetime.now().strftime("%Y-%M-%d ''%H:%M:%S")
kwargs['gameid'] = 2001 kwargs['gameid'] = 2001
kwargs['channelid'] = 6001 kwargs['channelid'] = 6001
cc=InitFirstAD(kwargs)
cc.run()
if __name__ == "__main__": if __name__ == "__main__":
main() main()