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 NPOI.OpenXmlFormats.Spreadsheet;
using Manganese.Array;
using static NPOI.HSSF.Util.HSSFColor;
using System.Drawing;
using System.Drawing.Imaging;
using Masuit.Tools.Hardware;
using Masuit.Tools.Win32;
using Masuit.Tools;
using Microsoft.AspNetCore.Connections;
using NPOI.SS.Formula.Functions;
using Onebot.Protocol;
using Onebot.Protocol.Models.Messages;
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 Azure.Identity;
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
            {
                TestDbContext testDb = new TestDbContext();
                                int q = testDb.team_Games.Count();
                                 var a = testDb.team_Games.Where(a => a.opentime >= DateTime.Now).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("f")}";
                                 }
                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 = "我们来玩角色扮演接下来你是一个没有父母但很喜欢姐姐的一个小男孩" });
                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
   //             {
                   
   //             }
            
   //     }

       
    }
    }