This commit is contained in:
lwl0608 2024-02-25 23:07:57 +08:00
parent bd04bec67c
commit b62096921a
2 changed files with 16 additions and 8 deletions

View File

@ -1,4 +1,6 @@
import os import os
import time
from pymongo import UpdateOne from pymongo import UpdateOne
from lib.all import * from lib.all import *
from PIL import Image from PIL import Image
@ -131,7 +133,7 @@ class S:
def proc(self): def proc(self):
images = self.get_wait_deal_images() images = self.get_wait_deal_images()
logger.Info("len(images): {}".format(len(images))) logger.Info("====== {} ====== len(images): {}".format(get_time_str_by_ts(int(time.time())), len(images)))
idx = 0 idx = 0
for image in images: for image in images:
idx += 1 idx += 1
@ -199,12 +201,6 @@ class S:
logger.Info("{}/{}, success, oss_src_id: {}, id: {}".format(idx, len(images), oss_src_id, safe_get_int(image, "_id"))) logger.Info("{}/{}, success, oss_src_id: {}, id: {}".format(idx, len(images), oss_src_id, safe_get_int(image, "_id")))
def proc_loop(self):
while True:
logger.Info("loop, {}".format(get_time_str_by_ts(int(time.time()))))
self.proc()
time.sleep(10)
s = S() s = S()
s.proc_loop() s.proc()

View File

@ -12,3 +12,15 @@ for d in data:
ret = mysql.exec(sql, (oid3, _id)) ret = mysql.exec(sql, (oid3, _id))
print(_id, idx, ret) print(_id, idx, ret)
'''
select * from vas_order where order_status>0 and oid3=2021004115647165 and product_id='membership' and order_status=1 order by ct asc limit 10;
select * from vas_order where id=1759363707747446784;
update vas_order set ct=1707742486 where id=1759363707747446784;
select * from vas_ch_income where order_id=1759363707747446784;
curl -d '{"order_id":"1759363707747446784"}' 'https://api.tiefen.fun/api/vas/deal_one_order'
'''