浏览代码

добавлен файл с SQL запросами

root 2 年之前
父节点
当前提交
cbe215d4b0
共有 3 个文件被更改,包括 93 次插入14 次删除
  1. 11 7
      Moodle/send_calendar.py
  2. 69 0
      bot/sql.py
  3. 13 7
      requirements.txt

+ 11 - 7
Moodle/send_calendar.py

@@ -2,16 +2,20 @@
 #
 import paramiko
 import bot.config as cnf
+import shutil
 
 file = 'calendar.ics'
+folder = '/var/www/vmshay/calendar.ics'
 
 
 async def send():
-    with paramiko.SSHClient() as ssh:
-        ssh.load_system_host_keys()
-        ssh.connect(hostname=cnf.SSH_HOST, username=cnf.SSH_USER, password=cnf.SSH_PASS)
+    shutil.copy(file, folder)
+    # with paramiko.SSHClient() as ssh:
+    #     ssh.load_system_host_keys()
+    #     ssh.connect(hostname=cnf.SSH_HOST, username=cnf.SSH_USER, password=cnf.SSH_PASS)
+    #
+    #     sftp = ssh.open_sftp()
+    #
+    #     sftp.chdir('/var/www/vmshay')
+    #     sftp.put(file, file)
 
-        sftp = ssh.open_sftp()
-
-        sftp.chdir('/var/www/vmshay')
-        sftp.put(file, file)

+ 69 - 0
bot/sql.py

@@ -0,0 +1,69 @@
+
+
+def check_admin(data):
+    sql = f"select admin from user_table where tg_id = {data}"
+    return sql
+
+
+def check_id(data):
+    sql = f'select tg_id from user_table where tg_id ={data}'
+    return sql
+
+
+def check_approved(data):
+    sql = f'select approved from user_table where tg_id ={data}'
+    return sql
+
+
+def get_user_event(data):
+    sql = f"select events_table.description, user_table.name, events_table.e_date, events_table.e_start, events_table.e_end" \
+        f" from events_table" \
+        f" inner join user_table on events_table.owner = user_table.tg_id where events_table.owner={data}"
+    return sql
+
+
+def get_all_events(data):
+    sql = f"select events_table.description, user_table.name, events_table.e_date, events_table.e_start, events_table.e_end from events_table" \
+          f" inner join user_table on events_table.owner = user_table.tg_id where events_table.e_date={data}"
+
+    return sql
+
+
+def get_range_events(data):
+    sql = f"select events_table.description, user_table.name, events_table.e_date, events_table.e_start, events_table.e_end " \
+                                   f"from events_table inner join user_table " \
+                                   f"on events_table.owner = user_table.tg_id " \
+                                   f"where events_table.e_date between {data}"
+    return sql
+
+
+def sql_send(data):
+    sql = f"INSERT INTO user_table (tg_id,name,phone) VALUES ({data['id']},'{data['FIO']}',{data['number']})"
+    return sql
+
+
+def sql_booked(data):
+    sql = f"select events_table.id, user_table.name, user_table.phone, events_table.description, events_table.e_start, events_table.e_end from events_table inner join user_table on events_table.owner = user_table.tg_id WHERE events_table.e_date = '{data}'"
+    return sql
+
+
+def sql_booked_time(data):
+    sql = f"select e_start ,e_end from events_table where e_date = '{data}'"
+    return sql
+
+
+def sql_send_event(data):
+    sql = f"insert into events_table (e_date, owner, description, e_start, e_end) values ({data['date']},{data['owner']},'{data['description']}','{data['t_start']}','{data['t_end']}')"
+    return sql
+
+
+def sql_manage_events():
+    sql = f"select events_table.id, user_table.name, user_table.phone, events_table.description, events_table.e_date, events_table.e_start, events_table.e_end from events_table inner join user_table on events_table.owner = user_table.tg_id WHERE events_table.approved = 0"
+    return sql
+
+
+def sql_all_events():
+    sql = f"select events_table.id, events_table.description, user_table.name, events_table.e_date, events_table.e_start, events_table.e_end" \
+          f" from events_table" \
+          f" inner join user_table on events_table.owner = user_table.tg_id where events_table.approved = '1'"
+    return sql

+ 13 - 7
requirements.txt

@@ -1,24 +1,30 @@
-aioschedule
-paramiko
-intervaltree
 aiogram==2.22.2
 aiohttp==3.8.3
+aioschedule==0.5.2
 aiosignal==1.2.0
 async-timeout==4.0.2
 asynctest==0.13.0
 attrs==22.1.0
 Babel==2.9.1
+bcrypt==4.0.1
 certifi==2022.9.24
+cffi==1.15.1
 charset-normalizer==2.1.1
+cryptography==38.0.1
 frozenlist==1.3.1
 idna==3.4
+intervaltree==3.1.0
 multidict==6.0.2
 mysql-connector-python==8.0.30
-phonenumbers==8.12.56
+paramiko==2.11.0
+phonenumbers==8.12.57
 protobuf==3.20.1
+pycparser==2.21
+PyNaCl==1.5.0
 python-dotenv==0.21.0
-pytz==2022.4
-typing-extensions==4.3.0
+pytz==2022.5
+six==1.16.0
+sortedcontainers==2.4.0
+typing_extensions==4.4.0
 yarl==1.8.1
 
-