asg_backend/asg_form/qqbot.cs

using asg_form.Controllers;
using Mirai.Net.Data.Messages.Concretes;
using Mirai.Net.Data.Messages;
using Mirai.Net.Data.Messages.Receivers;
using Mirai.Net.Sessions;
using Mirai.Net.Sessions.Http.Managers;
using System.Reactive.Linq;
using Microsoft.EntityFrameworkCore;
using Mirai.Net.Data.Events.Concretes.Bot;
using static asg_form.Controllers.schedule;
using Manganese.Array;
using System.Drawing;
using System.Drawing.Imaging;
using Masuit.Tools.Hardware;
using Masuit.Tools.Win32;
using Masuit.Tools;
using Microsoft.AspNetCore.Connections;
using Zack.EventBus;
using Flandre.Framework.Common;
using Flandre.Framework.Routing;
using static asg_form.Controllers.InviteReferee;
using System.Net.Http.Headers;
using System.Net.Http;
using System.Text;
using Flandre.Core.Messaging;
using Flandre.Core.Common;
using Microsoft.OpenApi.Models;
using Flurl.Http;
using Microsoft.AspNetCore.Identity;

namespace asg_form
{

    public static class runbot
    {
        public static Bot runbotr { get; set; }
    }
    [EventName("查询选手")]
    public class qqbot:Plugin
    {
        [Command]
        public string 查询选手(string name)
        {
            try
            {
                    TestDbContext ctx = new TestDbContext();

                    string msg = "";
                    var roles = ctx.Roles.Include(a => a.form).Where(a => a.role_name.IndexOf(name) >= 0).ToList();
                    foreach (var role in roles)
                    {
                        msg = $"{msg}\r\n姓名:{role.role_name}\r\n第五人格ID:{role.role_id}\r\n选手id:{role.Id}\r\n阵营:{role.role_lin}\r\n属于队伍:{role.form.team_name}\r\n";
                    }
                    return msg ;
      

            }
            catch
            {
                return "出现错误";
            }

        }


        [Command]
        public string 查询黑名单()
        {
            try
            {
                using (TestDbContext ctx = new TestDbContext())
                {
                   var blacks= ctx.T_blacks.ToList();
                    string msg = "为了良好的赛事环境，我们对以下选手进行禁赛处理";
                    foreach (var b in blacks)
                    {
                        msg = $"{msg}\r\n{b.record_time}  {b.violator}  {b.platform_record}  {b.offending_details}  {b.processing_result}  {b.feature_id}";
                    }
                    return msg;
                }

                

            }
            catch
            {
                return "出现错误";
            }

        }






        [Command]
        public string 近期赛程()
        {
            try
            {
                TestDbContext testDb = new TestDbContext();
                                int q = testDb.team_Games.Count();
                var t = (DateTime.Now);
                var a = testDb.team_Games.Where(a => string.Compare(a.opentime, t.ToString()) >= 0).Take(7);
                string msg = "";
                foreach (var b in a)
                {
                msg = $"{msg}\r\n{b.team1_name} VS {b.team2_name}\r\n时间:{b.opentime.ToString()}";
                }
                return msg;
             

            }
            catch
            {
                return "出现错误";
            }

        }


      

        [Command]
        public string 查询冠军()
        {
            try
            {
                TestDbContext ctx = new TestDbContext();

                var teams = ctx.Champions.Include(a => a.events).Include(a => a.form.role).Select(a => new { a.form, a.events, a.msg }).ToList();
                string msg = "";
                foreach (var t in teams)
                {
                    string role = "";

                    foreach (var t2 in t.form.role)
                    {
                        role = $"{role}  {t2.role_name}";
                    }
                    msg = $"{msg}\r\n队伍名称:{t.form.team_name}\r\n队员：{role}\r\n属于：{t.events.name}\r\n简介：{t.msg}\r\n";
                }
                return msg;


            }
            catch
            {
                return "出现错误";
            }

        }

        [Command]
        public string 查询战队(string name)
        {
            try
            {
                TestDbContext ctx = new TestDbContext();

                                              List<form> teams = ctx.Forms.Include(a => a.role).Where(a => a.team_name.IndexOf(name) >= 0).ToList();
                                         string msg = "";
                                         foreach (var t in teams)
                                         {
                                             string role = "";
                                             foreach (var t2 in t.role)
                                             {
                                                 role = $"{role}  {t2.role_name}";
                                             }
                                             msg = $"{msg}\r\n队伍名称:{t.team_name}\r\n队员：{role}\r\n";
                                         }
                return msg;


            }
            catch
            {
                return "出现错误";
            }

        }


        [Command]
        public async Task<string> 抱抱罗比(MessageContext ctx)
        {
            try
            {
                using(TestDbContext testDb=new TestDbContext())
                {
                    Random ran = new Random();
                    int n = ran.Next(30, 100);

                  

                    if (!testDb.Qqusers.Any(a => a.qqid == ctx.UserId))
                    {
                        await testDb.Qqusers.AddAsync(new qquser { qqid = ctx.UserId, money = n ,time=DateTime.Now});

                    }
                    else
                    {
                       var user=await testDb.Qqusers.FirstAsync(a=>a.qqid == ctx.UserId);
                        if (isToday(user.time))
                        {
                            return "你已经签到过了！";
                        }
                        user.money += n;
                        user.time = DateTime.Today;
                    }
                   
                    await testDb.SaveChangesAsync();
                    return $"罗比很开心\r\n给你棒棒糖：{n.ToString()}个";
                }
          
                

            }
            catch
            {
                return "出现错误";
            }

        }
        public class MessagesItem
        {
            /// <summary>
            /// 
            /// </summary>
            public string role { get; set; }
            /// <summary>
            /// 
            /// </summary>
            public string content { get; set; }
        }

        public class aimessage
        {
            /// <summary>
            /// 
            /// </summary>
            public string model { get; set; }
            /// <summary>
            /// 
            /// </summary>
            public List<MessagesItem> messages { get; set; }
        }

        private static async Task<string> SendPostRequestAsync(string url, aimessage Content, string apiKey)
        {
           var re= await url.WithOAuthBearerToken(apiKey).PostJsonAsync(Content);
          var a=  await re.GetJsonAsync();
            return a.choices[0].message.content;
        }


      

        [Command]
        public async Task<string> 绑定QQ(string username, MessageContext ctx)
        {
            try
            {
                using(IDBcontext db=new IDBcontext()) {
                   var auser=await db.users.FirstAsync(a => a.UserName == username);
                    auser.qqnumber = ctx.UserId;
                    await db.SaveChangesAsync();
                    return $"绑定成功！\r\n姓名：{auser.chinaname}";
                }

            }
            catch (Exception ex)
            {
                return $"出现错误{ex.Message}";
            }

        }

        [Command]
        public async Task<string> ai(string msg)
        {
            try
            {
               var message= new List<MessagesItem> ();
                  message.Add(new MessagesItem {role="user", content = msg });
       var ai1= new aimessage() { model= "qwen-turbo",messages=message };
             var msg1=  await SendPostRequestAsync("https://dashscope.aliyuncs.com/compatible-mode/v1/chat/completions", ai1, "sk-c6f37689f4014b5bbf5fd8b2e872d20b");
               return msg1;

            }
            catch(Exception ex)
            {
                return $"出现错误{ex.Message}";
            }

        }


        [Command]
        public async Task<string> aimath(string msg)
        {

            try
            {
                var message = new List<MessagesItem>();
                 message.Add(new MessagesItem { role = "user", content = msg });
                var ai = new aimessage() { model = "qwen-math-plus", messages = message };
                var msg1 = await SendPostRequestAsync("https://dashscope.aliyuncs.com/compatible-mode/v1/chat/completions", ai, "sk-c6f37689f4014b5bbf5fd8b2e872d20b");
                return msg1;

            }
            catch
            {
                return "出现错误";
            }



         

        }








        public static bool isToday(DateTime dt)
        {
            DateTime today = DateTime.Today;
            DateTime tempToday = new DateTime(dt.Year, dt.Month, dt.Day);
            if (today == tempToday)
                return true;
            else
                return false;
        }

        private async void doAt1AM(object state)
        {
            //执行功能...

        }



   //     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
   //     {
   //                try
   //         {
               
   //             var client = new OnebotClient(ConnectionFactory.FromWebsocket("localhost", 7890, "WHO_S_YOUR_DADDY"));
   //             await client.SendPrivateMessageAsync("10000", new Message()
   //             {
   //             MessageSegment.Text("hello")
   //             });
   //             client.

   //             bot.EventReceived
   //                       .OfType<DroppedEvent>()
   // .Subscribe(async receiver =>
   // {
   //      await Task.Delay(10000);
   //     await ExecuteAsync(stoppingToken);
   // });

   //                 bot.MessageReceived
   //     .OfType<GroupMessageReceiver>()
   //     .Subscribe(async x =>
   //     {
   //         try
   //         {
 
   //         }
   //         catch(Exception ex) 
   //         {
   //             await MessageManager.SendGroupMessageAsync(x.GroupId, $"错误:{ex.Message}");

   //         }


   //     });



   //                 bot.MessageReceived
   //  .OfType<GroupMessageReceiver>()
   //  .Where(a=>a.MessageChain.GetPlainMessage().StartsWith("查询战队 "))
   //                 .Subscribe(async x =>
   //                 {

   //                     try {
   //                         TestDbContext ctx = new TestDbContext();

   //                         string result = x.MessageChain.GetPlainMessage().Substring(5); // 截取从'o'之后的字符串
   //                         Console.WriteLine(result);
   //                         List<form> teams = ctx.Forms.Include(a => a.role).Where(a => a.team_name.IndexOf(result) >= 0).ToList();
   //                         string msg = "";
   //                         foreach (var t in teams)
   //                         {
   //                             string role = "";
   //                             foreach (var t2 in t.role)
   //                             {
   //                                 role = $"{role}  {t2.role_name}";
   //                             }
   //                             msg = $"{msg}\r\n队伍名称:{t.team_name}\r\n队员：{role}\r\n";
   //                         }
   //                         await MessageManager.SendGroupMessageAsync(x.GroupId, msg);
   //                     }
   //                     catch
   //                     {

   //                     }
                     
   //                 });


   //                 bot.MessageReceived
   //.OfType<GroupMessageReceiver>()
   //.Where(a => a.MessageChain.GetPlainMessage().StartsWith("查询选手 "))
   //               .Subscribe(async x =>
   //               {

                    

   //               });











   //             }
   //             catch
   //             {
                   
   //             }
            
   //     }

       
    }
    }