utils/game/money.c

/* SPDX-License-Identifier: GPL-3.0-or-later */
/*
 * money
 *   - basic operations of user money
 *
 * Copyright (C) 2004-2025  Leaflet <leaflet@leafok.com>
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#include "database.h"
#include "log.h"
#include "money.h"
#include "user_priv.h"
#include <stdio.h>
#include <stdlib.h>
#include <mysql.h>

int BBS_user_money = 0;

int money_balance()
{
        return BBS_user_money;
}

int money_deposit(int money)
{
        MYSQL *db;
        MYSQL_RES *rs;
        MYSQL_ROW row;
        char sql[SQL_BUFFER_LEN];
        int ret = 0;

        if (money <= 0)
        {
                return 0;
        }

        db = db_open();
        if (db == NULL)
        {
                return -1;
        }

        // Begin transaction
        if (mysql_query(db, "SET autocommit=0") != 0)
        {
                log_error("SET autocommit=0 error: %s", mysql_error(db));
                return -1;
        }

        if (mysql_query(db, "BEGIN") != 0)
        {
                log_error("Begin transaction error: %s", mysql_error(db));
                return -1;
        }

        snprintf(sql, sizeof(sql),
                         "SELECT game_money FROM user_pubinfo WHERE UID = %d FOR UPDATE",
                         BBS_priv.uid);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Query user_pubinfo error: %s", mysql_error(db));
                return -1;
        }
        if ((rs = mysql_store_result(db)) == NULL)
        {
                log_error("Get user money failed");
                return -1;
        }
        if ((row = mysql_fetch_row(rs)))
        {
                BBS_user_money = atoi(row[0]);
        }
        mysql_free_result(rs);

        if (BBS_user_money + money < USER_MONEY_MAX)
        {
                ret = money;
                BBS_user_money += money;
        }
        else if (BBS_user_money < USER_MONEY_MAX)
        {
                ret = USER_MONEY_MAX - BBS_user_money;
                BBS_user_money = USER_MONEY_MAX;
        }
        else // Balance exceeds 1 billion !!!
        {
                mysql_close(db);
                return -2;
        }

        snprintf(sql, sizeof(sql),
                         "UPDATE user_pubinfo SET game_money = %d WHERE UID = %d",
                         BBS_user_money, BBS_priv.uid);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Update user_pubinfo error: %s", mysql_error(db));
                return -1;
        }

        // Commit transaction
        if (mysql_query(db, "COMMIT") != 0)
        {
                log_error("Commit transaction error: %s", mysql_error(db));
                return -1;
        }

        mysql_close(db);

        return ret;
}

int money_withdraw(int money)
{
        MYSQL *db;
        MYSQL_RES *rs;
        MYSQL_ROW row;
        char sql[SQL_BUFFER_LEN];
        int ret = 0;

        if (money <= 0)
        {
                return 0;
        }

        db = db_open();
        if (db == NULL)
        {
                return -1;
        }

        // Begin transaction
        if (mysql_query(db, "SET autocommit=0") != 0)
        {
                log_error("SET autocommit=0 error: %s", mysql_error(db));
                return -1;
        }

        if (mysql_query(db, "BEGIN") != 0)
        {
                log_error("Begin transaction error: %s", mysql_error(db));
                return -1;
        }

        snprintf(sql, sizeof(sql),
                         "SELECT game_money FROM user_pubinfo WHERE UID = %d FOR UPDATE",
                         BBS_priv.uid);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Query user_pubinfo error: %s", mysql_error(db));
                return -1;
        }
        if ((rs = mysql_store_result(db)) == NULL)
        {
                log_error("Get user money failed");
                return -1;
        }
        if ((row = mysql_fetch_row(rs)))
        {
                BBS_user_money = atoi(row[0]);
        }
        mysql_free_result(rs);

        if (BBS_user_money >= money)
        {
                ret = money;
                BBS_user_money -= money;
        }
        else // No enough balance
        {
                mysql_close(db);
                return -2;
        }

        snprintf(sql, sizeof(sql),
                         "UPDATE user_pubinfo SET game_money = %d WHERE UID = %d",
                         BBS_user_money, BBS_priv.uid);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Update user_pubinfo error: %s", mysql_error(db));
                return -1;
        }

        // Commit transaction
        if (mysql_query(db, "COMMIT") != 0)
        {
                log_error("Commit transaction error: %s", mysql_error(db));
                return -1;
        }

        mysql_close(db);

        return ret;
}

int money_refresh(void)
{
        MYSQL *db;
        MYSQL_RES *rs;
        MYSQL_ROW row;
        char sql[SQL_BUFFER_LEN];

        db = db_open();
        if (db == NULL)
        {
                return -1;
        }

        snprintf(sql, sizeof(sql),
                         "SELECT game_money FROM user_pubinfo WHERE UID = %d FOR UPDATE",
                         BBS_priv.uid);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Query user_pubinfo error: %s", mysql_error(db));
                return -1;
        }
        if ((rs = mysql_store_result(db)) == NULL)
        {
                log_error("Get user money failed");
                return -1;
        }
        if ((row = mysql_fetch_row(rs)))
        {
                BBS_user_money = atoi(row[0]);
        }
        mysql_free_result(rs);

        mysql_close(db);

        return 0;
}
1	sysadm	1.9	/* SPDX-License-Identifier: GPL-3.0-or-later */
2			/*
3			* money
4			* - basic operations of user money
5			*
6	sysadm	1.10	* Copyright (C) 2004-2025 Leaflet <leaflet@leafok.com>
7	sysadm	1.9	*/
8	sysadm	1.8
9	sysadm	1.11	#ifdef HAVE_CONFIG_H
10			#include "config.h"
11			#endif
12
13	sysadm	1.3	#include "database.h"
14			#include "log.h"
15	sysadm	1.7	#include "money.h"
16	sysadm	1.3	#include "user_priv.h"
17			#include <stdio.h>
18	sysadm	1.4	#include <stdlib.h>
19	sysadm	1.12	#include <mysql.h>
20	sysadm	1.1
21	sysadm	1.3	int BBS_user_money = 0;
22
23			int money_balance()
24			{
25			return BBS_user_money;
26			}
27
28			int money_deposit(int money)
29	sysadm	1.2	{
30	sysadm	1.3	MYSQL *db;
31			MYSQL_RES *rs;
32			MYSQL_ROW row;
33			char sql[SQL_BUFFER_LEN];
34			int ret = 0;
35
36			if (money <= 0)
37			{
38			return 0;
39			}
40
41			db = db_open();
42			if (db == NULL)
43			{
44			return -1;
45			}
46
47			// Begin transaction
48			if (mysql_query(db, "SET autocommit=0") != 0)
49			{
50	sysadm	1.13	log_error("SET autocommit=0 error: %s", mysql_error(db));
51	sysadm	1.3	return -1;
52			}
53
54			if (mysql_query(db, "BEGIN") != 0)
55			{
56	sysadm	1.13	log_error("Begin transaction error: %s", mysql_error(db));
57	sysadm	1.3	return -1;
58			}
59
60			snprintf(sql, sizeof(sql),
61	sysadm	1.6	"SELECT game_money FROM user_pubinfo WHERE UID = %d FOR UPDATE",
62	sysadm	1.3	BBS_priv.uid);
63
64			if (mysql_query(db, sql) != 0)
65			{
66	sysadm	1.13	log_error("Query user_pubinfo error: %s", mysql_error(db));
67	sysadm	1.3	return -1;
68			}
69			if ((rs = mysql_store_result(db)) == NULL)
70			{
71	sysadm	1.13	log_error("Get user money failed");
72	sysadm	1.3	return -1;
73			}
74			if ((row = mysql_fetch_row(rs)))
75			{
76			BBS_user_money = atoi(row[0]);
77			}
78			mysql_free_result(rs);
79
80			if (BBS_user_money + money < USER_MONEY_MAX)
81			{
82			ret = money;
83	sysadm	1.2	BBS_user_money += money;
84	sysadm	1.3	}
85			else if (BBS_user_money < USER_MONEY_MAX)
86			{
87			ret = USER_MONEY_MAX - BBS_user_money;
88			BBS_user_money = USER_MONEY_MAX;
89			}
90			else // Balance exceeds 1 billion !!!
91			{
92			mysql_close(db);
93			return -2;
94			}
95
96			snprintf(sql, sizeof(sql),
97	sysadm	1.6	"UPDATE user_pubinfo SET game_money = %d WHERE UID = %d",
98	sysadm	1.3	BBS_user_money, BBS_priv.uid);
99
100			if (mysql_query(db, sql) != 0)
101			{
102	sysadm	1.13	log_error("Update user_pubinfo error: %s", mysql_error(db));
103	sysadm	1.3	return -1;
104			}
105
106			// Commit transaction
107			if (mysql_query(db, "COMMIT") != 0)
108			{
109	sysadm	1.13	log_error("Commit transaction error: %s", mysql_error(db));
110	sysadm	1.3	return -1;
111			}
112
113			mysql_close(db);
114
115			return ret;
116	sysadm	1.1	}
117
118	sysadm	1.3	int money_withdraw(int money)
119	sysadm	1.2	{
120	sysadm	1.3	MYSQL *db;
121			MYSQL_RES *rs;
122			MYSQL_ROW row;
123			char sql[SQL_BUFFER_LEN];
124			int ret = 0;
125
126			if (money <= 0)
127			{
128			return 0;
129			}
130
131			db = db_open();
132			if (db == NULL)
133			{
134			return -1;
135			}
136
137			// Begin transaction
138			if (mysql_query(db, "SET autocommit=0") != 0)
139			{
140	sysadm	1.13	log_error("SET autocommit=0 error: %s", mysql_error(db));
141	sysadm	1.3	return -1;
142			}
143
144			if (mysql_query(db, "BEGIN") != 0)
145			{
146	sysadm	1.13	log_error("Begin transaction error: %s", mysql_error(db));
147	sysadm	1.3	return -1;
148			}
149
150			snprintf(sql, sizeof(sql),
151	sysadm	1.6	"SELECT game_money FROM user_pubinfo WHERE UID = %d FOR UPDATE",
152	sysadm	1.3	BBS_priv.uid);
153
154			if (mysql_query(db, sql) != 0)
155			{
156	sysadm	1.13	log_error("Query user_pubinfo error: %s", mysql_error(db));
157	sysadm	1.3	return -1;
158			}
159			if ((rs = mysql_store_result(db)) == NULL)
160			{
161	sysadm	1.13	log_error("Get user money failed");
162	sysadm	1.3	return -1;
163			}
164			if ((row = mysql_fetch_row(rs)))
165			{
166			BBS_user_money = atoi(row[0]);
167			}
168			mysql_free_result(rs);
169
170			if (BBS_user_money >= money)
171			{
172			ret = money;
173	sysadm	1.2	BBS_user_money -= money;
174	sysadm	1.3	}
175			else // No enough balance
176			{
177			mysql_close(db);
178			return -2;
179			}
180
181			snprintf(sql, sizeof(sql),
182	sysadm	1.6	"UPDATE user_pubinfo SET game_money = %d WHERE UID = %d",
183	sysadm	1.3	BBS_user_money, BBS_priv.uid);
184
185			if (mysql_query(db, sql) != 0)
186			{
187	sysadm	1.13	log_error("Update user_pubinfo error: %s", mysql_error(db));
188	sysadm	1.3	return -1;
189			}
190
191			// Commit transaction
192			if (mysql_query(db, "COMMIT") != 0)
193			{
194	sysadm	1.13	log_error("Commit transaction error: %s", mysql_error(db));
195	sysadm	1.3	return -1;
196			}
197
198			mysql_close(db);
199
200			return ret;
201			}
202
203			int money_refresh(void)
204			{
205			MYSQL *db;
206			MYSQL_RES *rs;
207			MYSQL_ROW row;
208			char sql[SQL_BUFFER_LEN];
209
210			db = db_open();
211			if (db == NULL)
212			{
213			return -1;
214			}
215
216			snprintf(sql, sizeof(sql),
217	sysadm	1.6	"SELECT game_money FROM user_pubinfo WHERE UID = %d FOR UPDATE",
218	sysadm	1.3	BBS_priv.uid);
219
220			if (mysql_query(db, sql) != 0)
221			{
222	sysadm	1.13	log_error("Query user_pubinfo error: %s", mysql_error(db));
223	sysadm	1.3	return -1;
224			}
225			if ((rs = mysql_store_result(db)) == NULL)
226			{
227	sysadm	1.13	log_error("Get user money failed");
228	sysadm	1.3	return -1;
229			}
230			if ((row = mysql_fetch_row(rs)))
231			{
232			BBS_user_money = atoi(row[0]);
233			}
234			mysql_free_result(rs);
235
236			mysql_close(db);
237
238			return 0;
239	sysadm	1.1	}
webmaster@leafok.com	ViewVC Help
Powered by ViewVC 1.3.0-beta1