diff --git a/cronjob/vas/fix_diamonds.py b/cronjob/vas/fix_diamonds.py
index 25f9acf..a8964f5 100644
--- a/cronjob/vas/fix_diamonds.py
+++ b/cronjob/vas/fix_diamonds.py
@@ -52,7 +52,14 @@ class S:
             now_dias, now_wdias = self.get_mid_now_dias_wdias(mid)
             # logger.Info("mid:{}, 总钻石:{}, 背包钻石:{}, 钻石差:{}, 背包提现钻石:{}, 已提现钻石:{}".format(mid, all_dias, now_dias, all_dias - now_dias, now_wdias, wdias))
 
-            logger.Info("mid:{}, 背包钻石:{}, 修改后的背包钻石:{}, 背包提现钻石:{}".format(mid, all_dias, all_dias-wdias, now_wdias))
+            logger.Info("mid:{}, 背包钻石:{}, 修改后的背包钻石:{}, 背包提现钻石:{}".format(mid, all_dias, all_dias - wdias, now_wdias))
+
+            new_dias = all_dias - wdias
+            update_sql = '''update vas_wallet set diamonds={} where id={}'''.format(new_dias, mid)
+            logger.Info("update_sql: {}".format(update_sql))
+            # ret = self.mysql_db_vas.exec(update_sql, (new_dias, mid))
+            # logger.Info("sql_ret: {}".format(ret))
+
 
 s = S()
 s.proc()