305 lines
13 KiB
C#
305 lines
13 KiB
C#
using AxibugEmuOnline.Server.Common;
|
||
using AxibugEmuOnline.Server.Manager.Client;
|
||
using AxibugEmuOnline.Server.NetWork;
|
||
using AxibugProtobuf;
|
||
using MySql.Data.MySqlClient;
|
||
using System.Net.Sockets;
|
||
using static System.Runtime.CompilerServices.RuntimeHelpers;
|
||
|
||
namespace AxibugEmuOnline.Server.Manager
|
||
{
|
||
public class GameShareManager
|
||
{
|
||
Dictionary<int, RomPlatformType> mDictRomID2Platform = new Dictionary<int, RomPlatformType>();
|
||
public GameShareManager()
|
||
{
|
||
NetMsg.Instance.RegNetMsgEvent((int)CommandID.CmdGameMark, RecvGameMark);
|
||
NetMsg.Instance.RegNetMsgEvent((int)CommandID.CmdGamescreenImgUpload, RecvGameScreenCoverImgUpload);
|
||
}
|
||
|
||
|
||
public void RecvGameMark(Socket _socket, byte[] reqData)
|
||
{
|
||
AppSrv.g_Log.DebugCmd("RecvGameMark");
|
||
Protobuf_Game_Mark msg = ProtoBufHelper.DeSerizlize<Protobuf_Game_Mark>(reqData);
|
||
ClientInfo _c = AppSrv.g_ClientMgr.GetClientForSocket(_socket);
|
||
Protobuf_Game_Mark_RESP respData = new Protobuf_Game_Mark_RESP();
|
||
|
||
using (MySqlConnection conn = SQLRUN.GetConn("RecvGameMark"))
|
||
{
|
||
try
|
||
{
|
||
string query = "SELECT id from rom_stars where uid = ?uid and romid = ?romid";
|
||
bool bHad = false;
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?uid", _c.UID);
|
||
command.Parameters.AddWithValue("?romid", msg.RomID);
|
||
using (var reader = command.ExecuteReader())
|
||
{
|
||
while (reader.Read())
|
||
{
|
||
bHad = true;
|
||
break;
|
||
}
|
||
}
|
||
}
|
||
|
||
//收藏
|
||
if (msg.Motion == 1)
|
||
{
|
||
if (bHad)
|
||
{
|
||
AppSrv.g_ClientMgr.ClientSend(_c, (int)CommandID.CmdGameMark, (int)ErrorCode.ErrorRomAlreadyHadStar, ProtoBufHelper.Serizlize(respData));
|
||
return;
|
||
}
|
||
else
|
||
{
|
||
query = "INSERT INTO `haoyue_emu`.`rom_stars` (`uid`, `romid`) VALUES (?uid, ?romid);";
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?uid", _c.UID);
|
||
command.Parameters.AddWithValue("?romid", msg.RomID);
|
||
command.ExecuteNonQuery();
|
||
}
|
||
}
|
||
}
|
||
else//取消收藏
|
||
{
|
||
if (bHad)
|
||
{
|
||
query = "DELETE from rom_stars where uid = ?uid and romid = ?romid";
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?uid", _c.UID);
|
||
command.Parameters.AddWithValue("?romid", msg.RomID);
|
||
command.ExecuteNonQuery();
|
||
}
|
||
}
|
||
else
|
||
{
|
||
AppSrv.g_ClientMgr.ClientSend(_c, (int)CommandID.CmdGameMark, (int)ErrorCode.ErrorRomDontHadStar, ProtoBufHelper.Serizlize(respData));
|
||
return;
|
||
}
|
||
}
|
||
//更新收藏数
|
||
query = "update romlist set stars = (SELECT COUNT(id) from rom_stars where rom_stars.romid = ?romid) where romlist.id = ?romid";
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
command.Parameters.AddWithValue("?romid", msg.RomID);
|
||
command.ExecuteNonQuery();
|
||
}
|
||
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
}
|
||
}
|
||
|
||
respData.Stars = GetRomStart(msg.RomID);
|
||
respData.IsStar = CheckIsRomStar(msg.RomID, _c.UID) ? 1 : 0;
|
||
|
||
respData.RomID = msg.RomID;
|
||
AppSrv.g_ClientMgr.ClientSend(_c, (int)CommandID.CmdGameMark, (int)ErrorCode.ErrorOk, ProtoBufHelper.Serizlize(respData));
|
||
}
|
||
|
||
private void RecvGameScreenCoverImgUpload(Socket _socket, byte[] reqData)
|
||
{
|
||
AppSrv.g_Log.DebugCmd("RecvGameScreenCoverImgUpload");
|
||
ClientInfo _c = AppSrv.g_ClientMgr.GetClientForSocket(_socket);
|
||
Protobuf_GameScreen_Img_Upload msg = ProtoBufHelper.DeSerizlize<Protobuf_GameScreen_Img_Upload>(reqData);
|
||
Protobuf_GameScreen_Img_Upload_RESP respData = new Protobuf_GameScreen_Img_Upload_RESP();
|
||
CheckRomHadCover(msg.RomID, out bool bhadGame, out bool bHadCover, out string coverPath);
|
||
ErrorCode errCode = ErrorCode.ErrorOk;
|
||
if (!bhadGame || (_c.UID > 1 && bHadCover))//UID == 1允许连续上传
|
||
{
|
||
errCode = ErrorCode.ErrorRomAlreadyHadCoverimg;
|
||
}
|
||
|
||
if (errCode == ErrorCode.ErrorOk)
|
||
{
|
||
Helper.FileDelete(Path.Combine(Config.cfg.wwwRootPath, coverPath));
|
||
byte[] ImgData = msg.SavImg.ToArray();
|
||
string imgpath = Path.Combine("UpCover", $"{_c.UID}_{msg.RomID}_{DateTime.Now.ToString("yyyyMMddHHmmss")}.jpg");
|
||
|
||
ImgData = Helper.DecompressByteArray(ImgData);
|
||
|
||
if (Helper.CreateFile(Path.Combine(Config.cfg.wwwRootPath, imgpath), ImgData))
|
||
{
|
||
string query = "update romlist set ImgUrl = ?imgUrl WHERE id = ?romid;";
|
||
using (MySqlConnection conn = SQLRUN.GetConn("RecvGameScreenCoverImgUpload_updateImg"))
|
||
{
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?romid", msg.RomID);
|
||
command.Parameters.AddWithValue("?imgUrl", imgpath);
|
||
if (command.ExecuteNonQuery() < 1)
|
||
{
|
||
AppSrv.g_Log.Error("执行即时存档保存失败");
|
||
}
|
||
}
|
||
}
|
||
query = "INSERT INTO `haoyue_emu`.`uploadcover_log` (`uid`, `romid`) VALUES (?uid, ?romid);";
|
||
using (MySqlConnection conn = SQLRUN.GetConn("RecvGameScreenCoverImgUpload_insertlog"))
|
||
{
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?uid", _c.UID);
|
||
command.Parameters.AddWithValue("?romid", msg.RomID);
|
||
if (command.ExecuteNonQuery() < 1)
|
||
{
|
||
AppSrv.g_Log.Error("执行即时存档保存失败");
|
||
}
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
errCode = ErrorCode.ErrorRomFailCoverimg;
|
||
}
|
||
}
|
||
AppSrv.g_ClientMgr.ClientSend(_c, (int)CommandID.CmdGamescreenImgUpload, (int)errCode, ProtoBufHelper.Serizlize(respData));
|
||
}
|
||
|
||
public int GetRomStart(int RomId)
|
||
{
|
||
int stars = 0;
|
||
using (MySqlConnection conn = SQLRUN.GetConn("GetStart"))
|
||
{
|
||
try
|
||
{
|
||
string query = $"SELECT `stars` FROM romlist where id = ?romid;";
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?RomID", RomId);
|
||
// 执行查询并处理结果
|
||
using (var reader = command.ExecuteReader())
|
||
{
|
||
while (reader.Read())
|
||
{
|
||
stars = reader.GetInt32(0);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
AppSrv.g_Log.Error(e);
|
||
}
|
||
}
|
||
return stars;
|
||
}
|
||
|
||
public bool CheckIsRomStar(int RomId, long uid)
|
||
{
|
||
bool bhad = false;
|
||
using (MySqlConnection conn = SQLRUN.GetConn("CheckIsRomStart"))
|
||
{
|
||
try
|
||
{
|
||
string query = $"SELECT count(id) from rom_stars where uid = ?uid and romid = ?romid";
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?romid", RomId);
|
||
command.Parameters.AddWithValue("?uid", uid);
|
||
// 执行查询并处理结果
|
||
using (var reader = command.ExecuteReader())
|
||
{
|
||
while (reader.Read())
|
||
{
|
||
bhad = reader.GetInt32(0) > 0;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
AppSrv.g_Log.Error("CheckIsRomStar：" + e);
|
||
}
|
||
}
|
||
return bhad;
|
||
}
|
||
|
||
|
||
public void CheckRomHadCover(int RomId, out bool bhadGame, out bool bHadCover, out string coverPath)
|
||
{
|
||
bhadGame = false;
|
||
bHadCover = false;
|
||
coverPath = string.Empty;
|
||
using (MySqlConnection conn = SQLRUN.GetConn("CheckRomHadCover"))
|
||
{
|
||
try
|
||
{
|
||
string query = $"SELECT id,ImgUrl from romlist where Id = ?romid";
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?romid", RomId);
|
||
// 执行查询并处理结果
|
||
using (var reader = command.ExecuteReader())
|
||
{
|
||
while (reader.Read())
|
||
{
|
||
bhadGame = reader.GetInt32(0) > 0;
|
||
coverPath = reader.GetString(1);
|
||
if (!string.IsNullOrEmpty(coverPath))
|
||
bHadCover = true;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
AppSrv.g_Log.Error("CheckRomHadCover：" + e);
|
||
}
|
||
}
|
||
}
|
||
|
||
public RomPlatformType GetRomPlatformType(int RomID)
|
||
{
|
||
if (mDictRomID2Platform.TryGetValue(RomID, out RomPlatformType ptype))
|
||
return ptype;
|
||
|
||
ptype = RomPlatformType.Invalid;
|
||
using (MySqlConnection conn = SQLRUN.GetConn("GetRomPlatformType"))
|
||
{
|
||
try
|
||
{
|
||
string query = "SELECT PlatformType from romlist where Id = ?RomID ";
|
||
using (var command = new MySqlCommand(query, conn))
|
||
{
|
||
// 设置参数值
|
||
command.Parameters.AddWithValue("?RomID", RomID);
|
||
// 执行查询并处理结果
|
||
using (var reader = command.ExecuteReader())
|
||
{
|
||
while (reader.Read())
|
||
{
|
||
ptype = (RomPlatformType)reader.GetInt32(0);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
AppSrv.g_Log.Error(e);
|
||
}
|
||
}
|
||
|
||
if (ptype == RomPlatformType.Invalid)
|
||
AppSrv.g_Log.Error($"RomID {RomID} 没找到平台配置");
|
||
else
|
||
mDictRomID2Platform[RomID] = ptype;
|
||
|
||
return ptype;
|
||
}
|
||
}
|
||
}
|