/[LeafOK_CVS]/lbbs/src/login.c
ViewVC logotype

Diff of /lbbs/src/login.c

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

Revision 1.45 by sysadm, Tue Jun 17 02:06:48 2025 UTC Revision 1.62 by sysadm, Wed Oct 22 16:12:50 2025 UTC
# Line 14  Line 14 
14   *                                                                         *   *                                                                         *
15   ***************************************************************************/   ***************************************************************************/
16    
 #define _POSIX_C_SOURCE 200112L  
   
 #include "login.h"  
17  #include "bbs.h"  #include "bbs.h"
 #include "user_priv.h"  
18  #include "common.h"  #include "common.h"
19  #include "log.h"  #include "database.h"
20  #include "io.h"  #include "io.h"
21    #include "ip_mask.h"
22    #include "log.h"
23    #include "login.h"
24  #include "screen.h"  #include "screen.h"
25  #include "database.h"  #include "user_priv.h"
 #include <errno.h>  
26  #include <ctype.h>  #include <ctype.h>
27    #include <errno.h>
28    #include <stdlib.h>
29  #include <string.h>  #include <string.h>
30  #include <regex.h>  #include <regex.h>
 #include <stdlib.h>  
31  #include <unistd.h>  #include <unistd.h>
32  #include <mysql/mysql.h>  #include <mysql/mysql.h>
33    #include <sys/param.h>
34    
35  int bbs_login(void)  int bbs_login(void)
36  {  {
# Line 41  int bbs_login(void) Line 41  int bbs_login(void)
41    
42          for (; !SYS_server_exit && !ok && i < BBS_login_retry_times; i++)          for (; !SYS_server_exit && !ok && i < BBS_login_retry_times; i++)
43          {          {
44                  prints("\033[1;33m请输入帐号\033[m(试用请输入`\033[1;36mguest\033[m', "                  prints("\033[1;33m璇疯緭鍏ュ笎鍙穃033[m(璇曠敤璇疯緭鍏\033[1;36mguest\033[m', "
45                             "注册请输入`\033[1;31mnew\033[m'): ");                             "娉ㄥ唽璇疯緭鍏\033[1;31mnew\033[m'): ");
46                  iflush();                  iflush();
47    
48                  if (str_input(username, sizeof(username), DOECHO) < 0)                  if (str_input(username, sizeof(username), DOECHO) < 0)
# Line 61  int bbs_login(void) Line 61  int bbs_login(void)
61                  {                  {
62                          display_file(DATA_REGISTER, 1);                          display_file(DATA_REGISTER, 1);
63    
64                          return 0;                          return -1;
65                  }                  }
66    
67                  if (username[0] != '\0')                  if (username[0] != '\0')
68                  {                  {
69                          prints("\033[1;37m请输入密码\033[m: ");                          prints("\033[1;37m璇疯緭鍏ュ瘑鐮乗033[m: ");
70                          iflush();                          iflush();
71    
72                          if (str_input(password, sizeof(password), NOECHO) < 0)                          if (str_input(password, sizeof(password), NOECHO) < 0)
# Line 137  int check_user(const char *username, con Line 137  int check_user(const char *username, con
137    
138          if (!ok)          if (!ok)
139          {          {
140                  prints("\033[1;31m用户名或密码格式错误...\033[m\r\n");                  prints("\033[1;31m鐢ㄦ埛鍚嶆垨瀵嗙爜鏍煎紡閿欒...\033[m\r\n");
141                  ret = 1;                  ret = 1;
142                  goto cleanup;                  goto cleanup;
143          }          }
# Line 181  int check_user(const char *username, con Line 181  int check_user(const char *username, con
181          }          }
182          if ((row = mysql_fetch_row(rs)))          if ((row = mysql_fetch_row(rs)))
183          {          {
184                  if (atoi(row[0]) > BBS_allowed_login_failures_within_interval)                  if (atoi(row[0]) >= BBS_allowed_login_failures_within_interval)
185                  {                  {
186                          prints("\033[1;31m来源存在多次失败登陆尝试，请稍后再试\033[m\r\n");                          prints("\033[1;31m鏉ユ簮瀛樺湪澶氭澶辫触鐧婚檰灏濊瘯锛岃绋嶅悗鍐嶈瘯锛屾垨浣跨敤Web鏂瑰紡璁块棶\033[m\r\n");
187                          ret = 1;                          ret = 1;
188                          goto cleanup;                          goto cleanup;
189                  }                  }
# Line 191  int check_user(const char *username, con Line 191  int check_user(const char *username, con
191          mysql_free_result(rs);          mysql_free_result(rs);
192          rs = NULL;          rs = NULL;
193    
194          // Failed login attempts against the current username during certain time period          // Failed login attempts against the current username since last successful login
195          snprintf(sql, sizeof(sql),          snprintf(sql, sizeof(sql),
196                           "SELECT COUNT(*) AS err_count FROM user_err_login_log "                           "SELECT COUNT(*) AS err_count FROM user_err_login_log "
197                           "WHERE username = '%s' AND login_dt >= SUBDATE(NOW(), INTERVAL 1 DAY)",                           "LEFT JOIN user_list ON user_err_login_log.username = user_list.username "
198                             "LEFT JOIN user_pubinfo ON user_list.UID = user_pubinfo.UID "
199                             "WHERE user_err_login_log.username = '%s' "
200                             "AND (user_err_login_log.login_dt >= user_pubinfo.last_login_dt "
201                             "OR user_pubinfo.last_login_dt IS NULL)",
202                           username);                           username);
203          if (mysql_query(db, sql) != 0)          if (mysql_query(db, sql) != 0)
204          {          {
# Line 210  int check_user(const char *username, con Line 214  int check_user(const char *username, con
214          }          }
215          if ((row = mysql_fetch_row(rs)))          if ((row = mysql_fetch_row(rs)))
216          {          {
217                  if (atoi(row[0]) >= 5)                  if (atoi(row[0]) >= BBS_allowed_login_failures_per_account)
218                  {                  {
219                          prints("\033[1;31m账户存在多次失败登陆尝试，请使用Web方式登录\033[m\r\n");                          prints("\033[1;31m璐︽埛瀛樺湪澶氭澶辫触鐧婚檰灏濊瘯锛岃浣跨敤Web鏂瑰紡鐧诲綍瑙ｉ攣\033[m\r\n");
220                          ret = 1;                          ret = 1;
221                          goto cleanup;                          goto cleanup;
222                  }                  }
# Line 268  int check_user(const char *username, con Line 272  int check_user(const char *username, con
272    
273                  if (p_login == 0)                  if (p_login == 0)
274                  {                  {
275                          prints("\033[1;31m您目前无权登陆...\033[m\r\n");                          prints("\033[1;31m鎮ㄧ洰鍓嶆棤鏉冪櫥闄...\033[m\r\n");
276                          ret = 1;                          ret = 1;
277                          goto cleanup;                          goto cleanup;
278                  }                  }
# Line 297  int check_user(const char *username, con Line 301  int check_user(const char *username, con
301                          goto cleanup;                          goto cleanup;
302                  }                  }
303    
304                  prints("\033[1;31m错误的用户名或密码...\033[m\r\n");                  prints("\033[1;31m閿欒鐨勭敤鎴峰悕鎴栧瘑鐮...\033[m\r\n");
305                  ret = 1;                  ret = 1;
306                  goto cleanup;                  goto cleanup;
307          }          }
# Line 317  int check_user(const char *username, con Line 321  int check_user(const char *username, con
321          case 0: // Login successfully          case 0: // Login successfully
322                  break;                  break;
323          case -1: // Load data error          case -1: // Load data error
324                  prints("\033[1;31m读取用户数据错误...\033[m\r\n");                  prints("\033[1;31m璇诲彇鐢ㄦ埛鏁版嵁閿欒...\033[m\r\n");
325                  ret = -1;                  ret = -1;
326                  goto cleanup;                  goto cleanup;
327          case -2: // Unused          case -2: // Unused
328                  prints("\033[1;31m请通过Web登录更新用户许可协议...\033[m\r\n");                  prints("\033[1;31m璇烽氳繃Web鐧诲綍鏇存柊鐢ㄦ埛璁稿彲鍗忚...\033[m\r\n");
329                  ret = 1;                  ret = 1;
330                  goto cleanup;                  goto cleanup;
331          case -3: // Dead          case -3: // Dead
332                  prints("\033[1;31m很遗憾，您已经永远离开了我们的世界！\033[m\r\n");                  prints("\033[1;31m寰堥仐鎲撅紝鎮ㄥ凡缁忔案杩滅寮浜嗘垜浠殑涓栫晫锛乗033[m\r\n");
333                  ret = 1;                  ret = 1;
334                  goto cleanup;                  goto cleanup;
335          default:          default:
# Line 484  int user_online_add(MYSQL *db) Line 488  int user_online_add(MYSQL *db)
488  {  {
489          char sql[SQL_BUFFER_LEN];          char sql[SQL_BUFFER_LEN];
490    
491          if (user_online_del(db) != 0)          snprintf(sql, sizeof(sql),
492                             "INSERT INTO visit_log(dt, IP) VALUES(NOW(), '%s')",
493                             hostaddr_client);
494            if (mysql_query(db, sql) != 0)
495          {          {
496                    log_error("Add visit log error: %s\n", mysql_error(db));
497                  return -1;                  return -1;
498          }          }
499    
500            if (user_online_del(db) != 0)
501            {
502                    return -2;
503            }
504    
505          snprintf(sql, sizeof(sql),          snprintf(sql, sizeof(sql),
506                           "INSERT INTO user_online(SID, UID, ip, login_tm, last_tm) "                           "INSERT INTO user_online(SID, UID, ip, current_action, login_tm, last_tm) "
507                           "VALUES('Telnet_Process_%d', %d, '%s', NOW(), NOW())",                           "VALUES('Telnet_Process_%d', %d, '%s', 'LOGIN', NOW(), NOW())",
508                           getpid(), BBS_priv.uid, hostaddr_client);                           getpid(), BBS_priv.uid, hostaddr_client);
509          if (mysql_query(db, sql) != 0)          if (mysql_query(db, sql) != 0)
510          {          {
511                  log_error("Add user_online error: %s\n", mysql_error(db));                  log_error("Add user_online error: %s\n", mysql_error(db));
512                  return -1;                  return -3;
513          }          }
514    
515          return 0;          return 0;
# Line 517  int user_online_del(MYSQL *db) Line 530  int user_online_del(MYSQL *db)
530    
531          return 0;          return 0;
532  }  }
533    
534    int user_online_exp(MYSQL *db)
535    {
536            char sql[SQL_BUFFER_LEN];
537    
538            // +1 exp for every 5 minutes online since last logout
539            // but at most 24 hours worth of exp can be gained in Telnet session
540            snprintf(sql, sizeof(sql),
541                             "UPDATE user_pubinfo SET exp = exp + FLOOR(LEAST(TIMESTAMPDIFF("
542                             "SECOND, GREATEST(last_login_dt, IF(last_logout_dt IS NULL, last_login_dt, last_logout_dt)), NOW()"
543                             ") / 60 / 5, 12 * 24)), last_logout_dt = NOW() "
544                             "WHERE UID = %d",
545                             BBS_priv.uid);
546            if (mysql_query(db, sql) != 0)
547            {
548                    log_error("Update user_pubinfo error: %s\n", mysql_error(db));
549                    return -1;
550            }
551    
552            return 0;
553    }
554    
555    int user_online_update(const char *action)
556    {
557            MYSQL *db = NULL;
558            char sql[SQL_BUFFER_LEN];
559    
560            if ((action == NULL || strcmp(BBS_current_action, action) == 0) &&
561                    time(NULL) - BBS_current_action_tm < BBS_current_action_refresh_interval) // No change
562            {
563                    return 0;
564            }
565    
566            if (action != NULL)
567            {
568                    strncpy(BBS_current_action, action, sizeof(BBS_current_action) - 1);
569                    BBS_current_action[sizeof(BBS_current_action) - 1] = '\0';
570            }
571    
572            BBS_current_action_tm = time(NULL);
573    
574            db = db_open();
575            if (db == NULL)
576            {
577                    log_error("db_open() error: %s\n", mysql_error(db));
578                    return -1;
579            }
580    
581            snprintf(sql, sizeof(sql),
582                             "UPDATE user_online SET current_action = '%s', last_tm = NOW() "
583                             "WHERE SID = 'Telnet_Process_%d'",
584                             BBS_current_action, getpid());
585            if (mysql_query(db, sql) != 0)
586            {
587                    log_error("Update user_online error: %s\n", mysql_error(db));
588                    return -2;
589            }
590    
591            mysql_close(db);
592    
593            return 1;
594    }

Legend:
Removed lines/characters  
Changed lines/characters
  Added lines/characters
webmaster@leafok.com
 ViewVC Help
Powered by ViewVC 1.3.0-beta1