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

a

Browse Source
This commit is contained in:
root 2019-09-02 20:18:33 +08:00
parent 65e7ed440a
commit edcfb370f3
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
get_new_user.py
View File

@ -18,7 +18,6 @@ class InitFirstAD():
self.end = kwargs.get('time') self.end = kwargs.get('time')
self.begin = (datetime.datetime.strptime(self.end, '%Y-%m-%d %H:%M:%S') - datetime.timedelta( self.begin = (datetime.datetime.strptime(self.end, '%Y-%m-%d %H:%M:%S') - datetime.timedelta(
minutes=TimeDelay)).strftime('%Y-%m-%d %H:%M:%S') minutes=TimeDelay)).strftime('%Y-%m-%d %H:%M:%S')
print(f"{self.begin},{self.end}")
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,9 +33,7 @@ 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_user(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:
@ -50,6 +47,7 @@ class InitFirstAD():
log.error(f"insert {line} to mysql Failed !", exc_info=True) log.error(f"insert {line} to mysql Failed !", exc_info=True)
def hide_user(self, data): def hide_user(self, data):
if data: if data:
line = len(data) line = len(data)
@ -71,7 +69,6 @@ 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 +78,7 @@ class InitFirstAD():
def main(): def main():
kwargs = {} kwargs = {}
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=InitFirstAD(kwargs)