From 814d37fbb470910e98765b0a7368204f2f28551b Mon Sep 17 00:00:00 2001 From: liuwei Date: Wed, 5 Mar 2025 13:10:50 +0800 Subject: [PATCH] =?UTF-8?q?feature=EF=BC=9A=E7=A7=AF=E5=88=86=E4=BA=A4?= =?UTF-8?q?=E6=98=93=E5=8A=9F=E8=83=BD=E4=B8=8A=E7=BA=BF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- point_trade/main.py | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/point_trade/main.py b/point_trade/main.py index 8ca668e..a814840 100644 --- a/point_trade/main.py +++ b/point_trade/main.py @@ -55,7 +55,6 @@ class PointTrade: # 解析 XML 数据 root = ET.fromstring(xml) - # 查找 元素并提取其文本内容 atuserlist_element = root.find('.//atuserlist') atuserlist_content = (atuserlist_element.text if atuserlist_element is not None else '').strip() # 去除前后的所有空白字符 @@ -136,14 +135,14 @@ class PointTrade: recipient_user_id, recipient_wx_id, recipient_wx_nick_name, recipient_current_points = recipient_result - recipient_current_points =int(recipient_current_points) + recipient_current_points = int(recipient_current_points) # 计算发信人和接收者的新积分 new_sender_points = sender_current_points - reward_points new_recipient_points = recipient_current_points + reward_points # 更新发信人和接收者的积分 - self._update_user_points(sender_user_id, new_sender_points) - self._update_user_points(recipient_user_id, new_recipient_points) + self._update_user_points(sender_user_id, new_sender_points, group_id) + self._update_user_points(recipient_user_id, new_recipient_points, group_id) output = ( f"\n-----Bot-----\n" @@ -194,7 +193,7 @@ class PointTrade: """, (wx_nick_name, group_id)) return cursor.fetchone() - def _update_user_points(self, user_id, new_points): + def _update_user_points(self, user_id, new_points, group_id): """ 更新用户积分 :param user_id: 用户ID @@ -205,5 +204,5 @@ class PointTrade: cursor.execute(""" UPDATE t_sign_record SET points = %s, update_time = %s - WHERE id = %s - """, (new_points, datetime.now(), user_id)) + WHERE id = %s AND group_id = %s + """, (new_points, datetime.now(), user_id, group_id))