lbbs/src/article_del.c

/* SPDX-License-Identifier: GPL-3.0-or-later */
/*
 * article_del
 *   - user interactive feature to delete article
 *
 * Copyright (C) 2004-2025  Leaflet <leaflet@leafok.com>
 */

#include "article_del.h"
#include "database.h"
#include "io.h"
#include "log.h"
#include "screen.h"
#include "user_priv.h"
#include <ctype.h>
#include <stdlib.h>

int article_del(const SECTION_LIST *p_section, const ARTICLE *p_article)
{
        MYSQL *db = NULL;
        MYSQL_RES *rs = NULL;
        MYSQL_ROW row;
        char sql[SQL_BUFFER_LEN];
        int ret = 0;
        int ch;
        int article_visible = 0;
        int article_excerption = 0;
        int exp_change = 0;

        if (p_section == NULL || p_article == NULL)
        {
                log_error("NULL pointer error\n");
        }

        if (p_article->excerption) // Delete is not allowed
        {
                clearscr();
                moveto(1, 1);
                prints("该文章无法被删除，请联系版主。");
                press_any_key();

                return 0;
        }

        clearscr();
        moveto(1, 1);
        prints("真的要删除文章？(Y)是, (N)否 [N]: ");
        iflush();

        for (ch = 0; !SYS_server_exit; ch = igetch_t(MAX_DELAY_TIME))
        {
                switch (toupper(ch))
                {
                case KEY_NULL:
                case KEY_TIMEOUT:
                        goto cleanup;
                case CR:
                case KEY_ESC:
                case 'N':
                        return 0;
                case 'Y':
                        break;
                default: // Invalid selection
                        continue;
                }

                break;
        }

        if (SYS_server_exit) // Do not save data on shutdown
        {
                goto cleanup;
        }

        db = db_open();
        if (db == NULL)
        {
                log_error("db_open() error: %s\n", mysql_error(db));
                ret = -1;
                goto cleanup;
        }

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

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

        snprintf(sql, sizeof(sql),
                         "SELECT visible, excerption FROM bbs WHERE AID = %d FOR UPDATE",
                         p_article->aid);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Query article status error: %s\n", mysql_error(db));
                ret = -1;
                goto cleanup;
        }
        if ((rs = mysql_use_result(db)) == NULL)
        {
                log_error("Get article status data failed\n");
                ret = -1;
                goto cleanup;
        }

        if ((row = mysql_fetch_row(rs)))
        {
                article_visible = atoi(row[0]);
                article_excerption = atoi(row[1]);
        }
        mysql_free_result(rs);
        rs = NULL;

        if (!article_visible) // Already deleted
        {
                mysql_close(db);
                db = NULL;

                clearscr();
                moveto(1, 1);
                prints("该文章已被删除，请稍后刷新列表。");
                press_any_key();

                goto cleanup;
        }

        if (article_excerption) // Delete is not allowed
        {
                clearscr();
                moveto(1, 1);
                prints("该文章无法被删除，请联系版主。");
                press_any_key();

                goto cleanup;
        }

        // Update article(s)
        snprintf(sql, sizeof(sql),
                         "UPDATE bbs SET visible = 0, reply_count = 0, m_del = %d "
                         "WHERE (AID = %d OR TID = %d) AND visible",
                         (p_article->uid == BBS_priv.uid ? 0 : 1),
                         p_article->aid, p_article->aid);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Update article status error: %s\n", mysql_error(db));
                ret = -1;
                goto cleanup;
        }

        // Update exp
        if (p_article->uid == BBS_priv.uid)
        {
                exp_change = (p_article->tid == 0 ? -20 : -5);
        }
        else
        {
                exp_change = (p_article->tid == 0 ? -50 : -15);
        }

        snprintf(sql, sizeof(sql),
                         "UPDATE user_pubinfo SET exp = exp + %d WHERE UID = %d",
                         exp_change, BBS_priv.uid);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Update exp error: %s\n", mysql_error(db));
                ret = -1;
                goto cleanup;
        }

        // Add log
        snprintf(sql, sizeof(sql),
                         "INSERT INTO bbs_article_op(AID, UID, type, op_dt, op_ip)"
                         "VALUES(%d, %d, '%c', NOW(), '%s')",
                         p_article->aid, BBS_priv.uid,
                         (p_article->uid == BBS_priv.uid ? 'D' : 'X'),
                         hostaddr_client);

        if (mysql_query(db, sql) != 0)
        {
                log_error("Add log error: %s\n", mysql_error(db));
                ret = -1;
                goto cleanup;
        }

        // Set reply count
        if (p_article->tid != 0)
        {
                snprintf(sql, sizeof(sql),
                                 "UPDATE bbs SET reply_count = reply_count - 1 WHERE AID = %d",
                                 p_article->tid);

                if (mysql_query(db, sql) != 0)
                {
                        log_error("Update article error: %s\n", mysql_error(db));
                        ret = -1;
                        goto cleanup;
                }
        }

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

        mysql_close(db);
        db = NULL;

        clearscr();
        moveto(1, 1);
        prints("删除成功，请在%d秒后刷新列表。", BBS_section_list_load_interval);
        press_any_key();
        ret = 1; // Success

cleanup:
        mysql_free_result(rs);
        mysql_close(db);

        return ret;
}
1	/* SPDX-License-Identifier: GPL-3.0-or-later */
2	/*
3	* article_del
4	* - user interactive feature to delete article
5	*
6	* Copyright (C) 2004-2025 Leaflet <leaflet@leafok.com>
7	*/
8
9	#include "article_del.h"
10	#include "database.h"
11	#include "io.h"
12	#include "log.h"
13	#include "screen.h"
14	#include "user_priv.h"
15	#include <ctype.h>
16	#include <stdlib.h>
17
18	int article_del(const SECTION_LIST p_section, const ARTICLE p_article)
19	{
20	MYSQL *db = NULL;
21	MYSQL_RES *rs = NULL;
22	MYSQL_ROW row;
23	char sql[SQL_BUFFER_LEN];
24	int ret = 0;
25	int ch;
26	int article_visible = 0;
27	int article_excerption = 0;
28	int exp_change = 0;
29
30	if (p_section == NULL \|\| p_article == NULL)
31	{
32	log_error("NULL pointer error\n");
33	}
34
35	if (p_article->excerption) // Delete is not allowed
36	{
37	clearscr();
38	moveto(1, 1);
39	prints("该文章无法被删除，请联系版主。");
40	press_any_key();
41
42	return 0;
43	}
44
45	clearscr();
46	moveto(1, 1);
47	prints("真的要删除文章？(Y)是, (N)否 [N]: ");
48	iflush();
49
50	for (ch = 0; !SYS_server_exit; ch = igetch_t(MAX_DELAY_TIME))
51	{
52	switch (toupper(ch))
53	{
54	case KEY_NULL:
55	case KEY_TIMEOUT:
56	goto cleanup;
57	case CR:
58	case KEY_ESC:
59	case 'N':
60	return 0;
61	case 'Y':
62	break;
63	default: // Invalid selection
64	continue;
65	}
66
67	break;
68	}
69
70	if (SYS_server_exit) // Do not save data on shutdown
71	{
72	goto cleanup;
73	}
74
75	db = db_open();
76	if (db == NULL)
77	{
78	log_error("db_open() error: %s\n", mysql_error(db));
79	ret = -1;
80	goto cleanup;
81	}
82
83	// Begin transaction
84	if (mysql_query(db, "SET autocommit=0") != 0)
85	{
86	log_error("SET autocommit=0 error: %s\n", mysql_error(db));
87	ret = -1;
88	goto cleanup;
89	}
90
91	if (mysql_query(db, "BEGIN") != 0)
92	{
93	log_error("Begin transaction error: %s\n", mysql_error(db));
94	ret = -1;
95	goto cleanup;
96	}
97
98	snprintf(sql, sizeof(sql),
99	"SELECT visible, excerption FROM bbs WHERE AID = %d FOR UPDATE",
100	p_article->aid);
101
102	if (mysql_query(db, sql) != 0)
103	{
104	log_error("Query article status error: %s\n", mysql_error(db));
105	ret = -1;
106	goto cleanup;
107	}
108	if ((rs = mysql_use_result(db)) == NULL)
109	{
110	log_error("Get article status data failed\n");
111	ret = -1;
112	goto cleanup;
113	}
114
115	if ((row = mysql_fetch_row(rs)))
116	{
117	article_visible = atoi(row[0]);
118	article_excerption = atoi(row[1]);
119	}
120	mysql_free_result(rs);
121	rs = NULL;
122
123	if (!article_visible) // Already deleted
124	{
125	mysql_close(db);
126	db = NULL;
127
128	clearscr();
129	moveto(1, 1);
130	prints("该文章已被删除，请稍后刷新列表。");
131	press_any_key();
132
133	goto cleanup;
134	}
135
136	if (article_excerption) // Delete is not allowed
137	{
138	clearscr();
139	moveto(1, 1);
140	prints("该文章无法被删除，请联系版主。");
141	press_any_key();
142
143	goto cleanup;
144	}
145
146	// Update article(s)
147	snprintf(sql, sizeof(sql),
148	"UPDATE bbs SET visible = 0, reply_count = 0, m_del = %d "
149	"WHERE (AID = %d OR TID = %d) AND visible",
150	(p_article->uid == BBS_priv.uid ? 0 : 1),
151	p_article->aid, p_article->aid);
152
153	if (mysql_query(db, sql) != 0)
154	{
155	log_error("Update article status error: %s\n", mysql_error(db));
156	ret = -1;
157	goto cleanup;
158	}
159
160	// Update exp
161	if (p_article->uid == BBS_priv.uid)
162	{
163	exp_change = (p_article->tid == 0 ? -20 : -5);
164	}
165	else
166	{
167	exp_change = (p_article->tid == 0 ? -50 : -15);
168	}
169
170	snprintf(sql, sizeof(sql),
171	"UPDATE user_pubinfo SET exp = exp + %d WHERE UID = %d",
172	exp_change, BBS_priv.uid);
173
174	if (mysql_query(db, sql) != 0)
175	{
176	log_error("Update exp error: %s\n", mysql_error(db));
177	ret = -1;
178	goto cleanup;
179	}
180
181	// Add log
182	snprintf(sql, sizeof(sql),
183	"INSERT INTO bbs_article_op(AID, UID, type, op_dt, op_ip)"
184	"VALUES(%d, %d, '%c', NOW(), '%s')",
185	p_article->aid, BBS_priv.uid,
186	(p_article->uid == BBS_priv.uid ? 'D' : 'X'),
187	hostaddr_client);
188
189	if (mysql_query(db, sql) != 0)
190	{
191	log_error("Add log error: %s\n", mysql_error(db));
192	ret = -1;
193	goto cleanup;
194	}
195
196	// Set reply count
197	if (p_article->tid != 0)
198	{
199	snprintf(sql, sizeof(sql),
200	"UPDATE bbs SET reply_count = reply_count - 1 WHERE AID = %d",
201	p_article->tid);
202
203	if (mysql_query(db, sql) != 0)
204	{
205	log_error("Update article error: %s\n", mysql_error(db));
206	ret = -1;
207	goto cleanup;
208	}
209	}
210
211	// Commit transaction
212	if (mysql_query(db, "COMMIT") != 0)
213	{
214	log_error("Commit transaction error: %s\n", mysql_error(db));
215	ret = -1;
216	goto cleanup;
217	}
218
219	mysql_close(db);
220	db = NULL;
221
222	clearscr();
223	moveto(1, 1);
224	prints("删除成功，请在%d秒后刷新列表。", BBS_section_list_load_interval);
225	press_any_key();
226	ret = 1; // Success
227
228	cleanup:
229	mysql_free_result(rs);
230	mysql_close(db);
231
232	return ret;
233	}
webmaster@leafok.com	ViewVC Help
Powered by ViewVC 1.3.0-beta1