print(f'{client_address} 离开')  # 可以放变量

# 列表

# 列表的创建
# 第一种
letar = []

# 第二种
letar2 = ['李四', '王无', '羡羡', '颖颖']

# 第三种 内置list 列表种可以存储不同的数据类型 也可以是任何对象
letar3 = list(['tool', 1, 8.8, ('tool188',), ['tool', 188]])
# 添加元素
letar3.append(90)

# 修改元素 对指定的小标进行重新赋值
letar2[0] = '月亮追太阳'
print(letar2)

# 删除元素
del letar3[2]

# 访问元素
name = list('per1')
print(name[2])  # r

print(name[2:])  # r，1

# 遍历 第一种
for items in letar2:
    print(items)

print('*****************')

# 遍历 第二种 range len遍历 i为下标
for i in range(len(letar2)):
    print(i, letar2[i])

print('*****************')

# 遍历 第三种 enumerate
for i, items in enumerate(letar2):
    print(i, items)

# 元组

# 如果只有一位时后面需要添加,
tel = (1,)

te2 = ('测试1', '测试2', '测试3')
# 访问
print(te2[0])

# 解包
tpl = ('滴滴', '货车帮', '运满满', '货拉拉')
# 解包
a, b, c, d = tpl
print(a, b, c, d)

# 元组的修改

t1 = (1, 88)
t2 = (89, 10)
t3 = t1 + t2
print(t3)

# 元组删除
tup = ('SM Entertainment', 'JYP', 'YG Entertainment', 'DSP')
print(tup)
del tup

# 字典 键值对

# 创建
dicl = {'a': '李四', 'b': '王无'}
print(dicl['a'])

# 更新字典
dicl['a'] = '您好'

# 删除字典
del dicl['a']  # 删除键 'Name'
dicl.clear()  # 清空字典
del dicl  # 删除字典   

# 访问字典
# value = dic[key] key为键

a, b = 0, 1
while b < 1000:
    print(b, end=',') # 同一行
    a, b = b, a + b

# 1,1,2,3,5,8,13,21,34,55,89,144,233,377,610,987,

from random import random

age = int(input("请输入年龄："))
if age >= 18:
    print("成年人！")
else:
    print("小朋友！")

age2 = int(input("请输入年龄："))
if 18 < age2 < 30:
    print("成年人！")
elif age2 > 30:
    print("ok1")
else:
    print("comm me")

# round() 保留指定小数位

age3 = float(input("OK："))
print(round(age3, 2))  # 保留指定位数

# while
b = 0
while 1 == 1:
    b += 1
    print(1)
    if b == 20:
        break

# while else
count = 0
while count < 5:
    print(count, " 小于 5")
    count = count + 1
else:
    print(count, " 大于或等于 5")

# for
letar = [12, 5, 6, 7, 7, 7]
for x in letar:
    print(x)

# for else

for x in letar:
    print(x)
else:  # 循环结束后执行
    print('循环OK！')

# range 指定区间 不包含最后位置 比如下下面只到9
for x in range(1, 10):
    print(x)



# range(0, 10) 生成0到10的序列
# range(开始值，结束值（不包含），步长)
for s in range(0, 101, 10):
    print(1)

print("***********")

# 变量容器 或者 序列 列表
letok = ['李四', '张三', '王开']
for i in range(len(letok)):
    print(i, letok[i])

print("*************")

for name in letok:
    if name == '李四':
        print('有这个人物')
    print(name)

# 元组遍历
mk = (60, 90, 45, 87)
score = 0
for i in mk:
    score += i
    print(i)
print("平均分：" + str(score / 4))

print("*************")

# 字典
zd = {'a': 10, 'b': 20, 'c': 30}
for k in zd:
    print(k)

print("*************")

# 集合
jh = {1, 2, 3, 4, 6}
for k in jh:
    print(k)

starr = [10, 2, 3, 40, 5, 6, 7, 9]

# sorted 排序
newlist = sorted(starr)  # 升序
newlist2 = sorted(starr, reverse=True)  # 降序
print(newlist)
print(newlist2)

# 最大最小值

m1 = max(starr)
print(m1)
m2 = min(starr)
print(m2)

# 求和
su = sum(starr)
print(su)

# 平均数
svg = (sum(starr) / len(starr))
print(svg)

# 反转

newlist3 = reversed(starr)  # 得到的是一个迭代器
for k in newlist3:
    print(k)

# 获取遍历ID
a = 5
b = 5
print(id(a), id(b))  # 4366729584 4366729584


# 二进制转化
a = 12
r = bin(a)
print(r)

# def 函数名 (参数1, 参数2....):
#     函数体

# 变量定义类型  str转化字符串
def fun1(a: str, b: float):
    print("计算机的名字是：" + a + "\t价格：" + str(b))


name = input("请输入计算机的名字：")
price = float(input("请输入电脑价格："))
fun1(name, price)


# 返回多个值
def function1():
    a = 10
    b = 100
    c = 98
    return a, b, c


r1, r2, r3 = function1()
print(r1, r2, r3)

# 匿名函数
xrt = lambda a: a + 10
print(xrt(5))


# 元素形式传 * 不定长度
def printinfo(arg1, *vartuple):
    "打印任何传入的参数"
    print("输出: ")
    print(arg1)
    print(vartuple)


# 调用printinfo 函数
printinfo(70, 60, 50)


# 字典形式传入 **
def funtcion(nam, **mk):
    print(nam)
    print(mk)


funtcion(1, a=2, b=3)


# 默认参数
# 可写函数说明
def printinfo(name, age=35):
    "打印任何传入的字符串"
    print("名字: ", name)
    print("年龄: ", age)
    return


# 调用printinfo函数 没有传值时使用
printinfo(age=50, name="runoob")
print("------------------------")
printinfo(name="runoob")

def ku(a, b):
    return a + b

import mk1

print(mk1.ku(1, 4))

fh = open("/Users/xianxian/Desktop/01.txt", 'w')  # 写入

fh.write('大家好我是渣渣辉！')  # 写入不追加

fh.close()

# 文件追加写入
fh = open('/Users/xianxian/Desktop/01.txt', 'a')  # 追加
fh.write('\r大家好')


//示例
with open('combinations.txt', 'w') as f:
    for combination in combinations:
        f.write(str(combination) + '\n')

let = open('/Users/xianxian/Desktop/未命名.txt', "r")
# 读取使用
data = let.read()
print(data)
let.close()  # 关闭

data = let.readline()  # 按行读取
print(data)

data = let.readlines()  # 按行取所有

for i in let:
    print(i)

let.close()

try:  # 异常处理
    money = float(input("请输入存款金额:"))
    crsql = "update bank set balance=balance+{} where id={}".format(money, dab[0])  # 格式化
    introw = update_db(crsql)  # 执行修改
    if introw >= 1:  # 修改成功
        seall = select_db(se_sql)  # 查询最新数据
        print("存入" + str(money) + "元,余额：" + str(seall[4]))
        break
    else:  # 输入错误
        print("存入错误！")
        continue
except Exception as err:  # 异常回滚
    db.rollback()
    print(err)
    break
finally:
    print(1)

import pymysql

# 打开数据连接 主机地址 端口号 账号 密码
db = pymysql.Connect(host="127.0.0.1", port=3306, user="root", passwd="root", db="studentdb", charset="utf8")

# 创建游标对象 执行数据库操作
cursor = db.cursor()

# 创建表
sql = """create table test(id int not null,name varchar(15),age int)"""
# 执行sql
cursor.execute(sql)

# 添加数据
sql = 'insert into test values(2,"李思2",20)'
cursor.execute(sql)
db.commit()

# 查询数据
sql = "select * from test"
cursor.execute(sql)
data1 = cursor.fetchall()  # fetchall 获取所有  fetchone 获取一行
print(data1)  # 得到的是元组

# 更新操作
sql = "update test set name='羡羡' where id=2"
cursor.execute(sql)
# 获取更新行数
row_count = cursor.rowcount
db.commit()

# 删除操作
sql = "delete from test where id=1"
cursor.execute(sql)
db.commit()

# 事务回滚
sql = "delete from test where id=1"
try:
    cursor.execute(sql)
    db.commit()
except Exception as e:
    db.rollback()  # 回滚

cursor.close()

import pymysql


# connect to the database（连接数据库）
def connect_db():
    return pymysql.connect(
        host='127.0.0.1',
        port=3306,
        user='root',
        password='root',
        database='cctv',
        charset='utf8'
    )


# 插入
def insert_data(tb: str, conn: pymysql.Connection):
    cur = conn.cursor()
    sql = 'INSERT INTO {table} (post_id) VALUES (1), (2), (3)'.format(table=tb)
    cur.execute(sql)
    cur.close()
    conn.commit()
    conn.close()


# 查询 fetchone获取一条数据 fetchmany(size)获取指定条数 fetchall（）获取所有
def select_data(tb: str, conn: pymysql.Connection):
    cur = conn.cursor()
    sql = 'SELECT * FROM {table}'.format(table=tb)
    cur.execute(sql)
    result = cur.fetchone()
    print(type(result), result)
    cur.close()


# 删除
def detel_from_table(tb: str, conn: pymysql.Connection):
    cur = conn.cursor()
    sql = 'delete from {table}'.format(table=tb)
    cur.execute(sql)
    cur.close()
    conn.commit()
    conn.close()

import pymysql

# 打开数据连接 主机地址 端口号 账号 密码
db = pymysql.Connect(
    host="127.0.0.1",
    port=3306,
    user="root",
    passwd="root",
    db="cctv",
    charset="utf8"
)

# 创建游标对象 执行数据库操作
cursor = db.cursor()


# 查询数据库
def select_db(sql):
    cursor.execute(sql)
    data = cursor.fetchone()  # 获取一条
    return data


# 修改数据库
def update_db(sql):
    cursor.execute(sql)
    # 获取更新行数
    row_count = cursor.rowcount
    db.commit()
    return row_count


count = 0  # 统计错误
se_sql = ""  # 查询语句
while 1 == 1:
    carid = input("请输入卡号：")
    carpwd = input("请输入密码：")
    se_sql = "select * from bank where carid=" + carid + " and uspass=" + carpwd
    dab = select_db(se_sql)  # 执行查询
    if dab is not None:  # 当查询到数据时
        print("欢迎" + dab[1] + "登录成功！")
    else:  # 没有查询到数据 错误时
        count += 1
        if count == 3:  # 错误次数满3次 锁定银行卡
            upse = "update bank set isdisable=1 where carid=" + carid
            # 执行数据库锁定银行卡
            update_db(upse)
            print("您已经连续输入错3次，银行卡被锁定！")
            break
        else:
            print("您已经连续" + str(count) + '次错误,还有' + str(3 - count) + "次机会")
            continue
    while 2 == 2:
        choice = int(input("请输入需要办理的业务编号：(1.存款 2.取款 3.退出)\n"))
        if choice == 1:  # 存款
            try:  # 异常处理
                money = float(input("请输入存款金额:"))
                crsql = "update bank set balance=balance+{} where id={}".format(money, dab[0])  # 格式化
                introw = update_db(crsql)  # 执行修改
                if introw >= 1:  # 修改成功
                    seall = select_db(se_sql)  # 查询最新数据
                    print("存入" + str(money) + "元,余额：" + str(seall[4]))
                    break
                else:  # 输入错误
                    print("存入错误！")
                    continue
            except Exception as err:  # 异常回滚
                db.rollback()
                print(err)
                break
        elif choice == 2:  # 取款
            try:
                money = float(input("请输入取款金额:"))
                qcsql = "update bank set balance=balance-{} where id={}".format(money, dab[0])  # 格式化
                qrint = update_db(qcsql)
                if qrint >= 1:
                    qcall = select_db(se_sql)
                    print("取出" + str(money) + "元,余额：" + str(qcall[4]))
                    break
                else:
                    print("取出错误！")
                    continue
            except Exception as err:
                db.rollback()
                print(err)
                break
            # 执行修改
        elif choice == 3:  # 退出
            print("------退出-----")
            break
        else:
            print("没有该业务！")
            continue

import socket
import threading

# 设置主机和端口号
HOST = '127.0.0.1'
PORT = 8888

# 创建一个socket对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 将socket对象绑定到指定的主机和端口号
server_socket.bind((HOST, PORT))

# 开始监听连接
server_socket.listen()
print("服务器开启成功...")

# 存储客户端套接字的列表
clients = []


# 定义一个函数，用于向所有客户端广播消息
def broadcast(msg, sender):
    for client in clients:
        if client != sender:
            client.send(msg)


# 定义一个函数，用于处理客户端的连接
def handle_client(client_socket, client_address):
    print(f'来自新的连接 {client_address}')

    # 将客户端套接字添加到列表中
    clients.append(client_socket)

    while True:
        try:
            # 接收客户端发送的消息
            msg = client_socket.recv(1024)
            if msg:
                # 广播消息给所有客户端
                broadcast(msg, client_socket)
            else:
                # 如果客户端断开连接，将其套接字从列表中移除
                clients.remove(client_socket)
                print(f'{client_address} 离开')
                break
        except:
            # 如果发生错误，将其套接字从列表中移除
            clients.remove(client_socket)
            print(f'{client_address} 离开')
            break


while True:
    # 等待客户端连接
    client_socket, client_address = server_socket.accept()

    # 创建一个线程来处理客户端连接
    client_thread = threading.Thread(target=handle_client, args=(client_socket, client_address))
    client_thread.start()

import socket
import threading

# 设置服务器主机和端口号
SERVER_HOST = '127.0.0.1'
SERVER_PORT = 8888

# 创建一个socket对象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 连接到服务器
client_socket.connect((SERVER_HOST, SERVER_PORT))

# 请求用户输入昵称
nickname = input('请输入您的昵称: ')


# 定义一个函数，用于从服务器接收消息
def receive():
    while True:
        try:
            # 接收消息
            msg = client_socket.recv(1024).decode('utf-8')
            if msg == 'NICK':
                # 如果服务器要求用户输入昵称，将昵称发送给服务器
                client_socket.send(nickname.encode('utf-8'))
            else:
                # 否则，打印消息和发送者昵称
                print(msg)
        except:
            # 如果发生错误，关闭客户端套接字并退出程序
            client_socket.close()
            break


# 定义一个函数，用于向服务器发送消息
def send():
    while True:
        msg = input()
        message = f'{nickname}: {msg}'
        client_socket.send(message.encode('utf-8'))


# 创建两个线程，一个用于接收消息，一个用于发送消息
receive_thread = threading.Thread(target=receive)
send_thread = threading.Thread(target=send)

# 启动两个线程
receive_thread.start()
send_thread.start()

import requests

response = requests.get('https://api.mtyqx.cn/tapi/random.php')
print(response.url)

def te2(a, b):
    return a + b


def te3(a, b):
    print(a - b)

import t1

res = t1.te2(1, 6)
print(res)

import schedule
import time

# 定义要执行的函数
def job():
    print("Hello, World!")

# 设置早上 8 点和晚上 10 点执行定时任务
schedule.every().day.at("08:00").do(job)
schedule.every().day.at("22:00").do(job)

while True:
    schedule.run_pending()
    time.sleep(1)

from flask import Flask
app = Flask(__name__)

@app.route('/')
def hello_world():
   return 'Hello World'

if __name__ == '__main__':
   app.run()

nohup python3 -u /opt/tools/Jkcdn/main.py &

nohup python /opt/tools/BackupCM/main.py > output.log 2>&1 &

from tqdm import tqdm

for i in tqdm (range (100), desc="Loading..."):
	pass