main.py

@@ -37,6 +37,32 @@ class MyPlugin(Star):
         conn.close()
         yield event.plain_result(f"Hello,{get_user_name(event.get_sender_id())}, 你坚持了{time}s哦，{a}.射出{V}ml,{b}!") 
 
+        @filter.command("给我连打十次")
+        async def dajiao(self, event: AstrMessageEvent):
+            if isUserExist(event.get_sender_id()) != True:
+                insertUser(event.get_sender_id())
+        user_name = event.get_sender_id()
+        conn=pymysql.connect(host = '192.168.31.9' # 连接名称，默认127.0.0.1
+        ,user = 'saipo' # 用户名
+        ,passwd='Grasste0403' # 密码
+        ,port= 3306 # 端口，默认为3306
+        ,db='saipo' # 数据库名称
+        ,charset='utf8' # 字符编码
+        )
+        cur = conn.cursor()
+        time=[];V=[];a=[];b=[]
+        for i in range(0,10):
+            time.append(round(random.uniform(1, 600), 2))
+            V.append(round(random.uniform(0.01,100), 2))
+            a.append(time_long(time))
+            b.append(volume(V))
+            sql = "INSERT INTO dajiao (openid, timelong, volume) VALUES (%s, %s, %s)"
+            values = (user_name,time[i],V[i])
+            cur.execute(sql,values)
+            conn.commit()
+        cur.close()
+        conn.close()
+        yield event.plain_result(f"Hello,{get_user_name(event.get_sender_id())}, 第一次你坚持了{time[0]}s哦，{a[0]}.射出{V[0]}ml,{b[0]}!\n第二次你坚持了{time[1]}s哦，{a[1]}.射出{V[1]}ml,{b[1]}!\n哎呀，一点也打不出来了!") 
 
     @filter.command("打打你的")
     async def dajiao_other(self, event: AstrMessageEvent, message: str):