diff --git a/task/summary_pay.py b/task/summary_pay.py index b3e3038..6cf6783 100644 --- a/task/summary_pay.py +++ b/task/summary_pay.py @@ -62,7 +62,8 @@ class SummaryPay(Task): bulk_data.append(UpdateOne({'orderid': model.orderid}, {'$set': data}, upsert=True)) except Exception as e: msg = traceback.format_exc() - ddsend_msg(f'{self.game_name}.{source_coll}字段异常 {msg}') + ddsend_msg(f'严重警告!!!{self.game_name}.{source_coll}字段异常 {msg}') + bulk_data.append(UpdateOne({'orderid': item['orderid']}, {'$set': item}, upsert=True)) logger.error(repr(e)) if bulk_data: self.local_db[self.dest_coll].bulk_write(bulk_data, ordered=False)