From 934389b1fba64d2f871bd82d8eb6d9e5368d3b50 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Fri, 5 Jul 2024 13:21:35 +0800
Subject: [PATCH] 'commit'

---
 .../{ => Backup}/addModelWithDataBase.py      |  0
 BaiHu/Tools/addJinDou.py                      | 30 +++++++++++++++++++
 .../QingLong/HuiYa/Model/HuiYaModel.java      | 13 ++++++++
 3 files changed, 43 insertions(+)
 rename BaiHu/Tools/{ => Backup}/addModelWithDataBase.py (100%)
 create mode 100644 BaiHu/Tools/addJinDou.py

diff --git a/BaiHu/Tools/addModelWithDataBase.py b/BaiHu/Tools/Backup/addModelWithDataBase.py
similarity index 100%
rename from BaiHu/Tools/addModelWithDataBase.py
rename to BaiHu/Tools/Backup/addModelWithDataBase.py
diff --git a/BaiHu/Tools/addJinDou.py b/BaiHu/Tools/addJinDou.py
new file mode 100644
index 00000000..b727f39f
--- /dev/null
+++ b/BaiHu/Tools/addJinDou.py
@@ -0,0 +1,30 @@
+import requests
+from Util.AesUtil import *
+from Util.CommonUtil import set_http_proxy
+from Util.PgUtil import *
+
+if __name__ == '__main__':
+    # 禁止代理
+    set_http_proxy("")
+    # 配置文件
+    config = ConfigUtil.getConfig()
+    # 处理机编号
+    machine_id = config['system']['machine_id']
+    # 获取签名
+    en_data = getenData(machine_id)
+    # WEB服务器地址
+    web_url = config['webServer']['web_url']
+    # 请求的地址
+    url = web_url + '/QingLong/HuiYa/addJinDou'
+
+    # 要发送的数据，可以是字典形式
+    id = 1
+    jd_count = 100
+    data = {
+        "enData": en_data,
+        "id": id,
+        "jd_count": jd_count
+    }
+    # 发送POST请求
+    response = requests.post(url, data=data)
+    print(response.text)
diff --git a/QingLong/src/main/java/com/dsideal/QingLong/HuiYa/Model/HuiYaModel.java b/QingLong/src/main/java/com/dsideal/QingLong/HuiYa/Model/HuiYaModel.java
index c4f27866..7929123b 100644
--- a/QingLong/src/main/java/com/dsideal/QingLong/HuiYa/Model/HuiYaModel.java
+++ b/QingLong/src/main/java/com/dsideal/QingLong/HuiYa/Model/HuiYaModel.java
@@ -652,5 +652,18 @@ public class HuiYaModel {
     public void addJinDou(int id, int jd_count) {
         String sql = "update t_hy_user set jd_count=jd_count+? where id=?";
         Db.update(sql, jd_count, id);
+        //添加变更历史记录
+        sql = "select user_id, from t_hy_user where id=?";
+        String user_id = Db.queryStr(sql, id);
+        //记录金豆变化日志
+        //before
+        Record rUser = Db.findById("t_hy_user", "user_id", user_id);
+        int before_jd_count = rUser.getInt("jd_count");
+        //after
+        int after_jd_count = before_jd_count + jd_count;
+        sql = "update t_hy_user set jd_count=jd_count+? where user_id=?";
+        Db.update(sql, jd_count, user_id);
+
+        wxAddJournal(user_id, 1, 0, 0, jd_count, before_jd_count, after_jd_count, "管理员授于,获得金豆" + jd_count + "个。");
     }
 }