KxGame/Kg.SeaTime
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

222

Browse Source
This commit is contained in:
Putoo
2026-05-23 18:36:37 +08:00
parent 05e340801f
commit dbace8a8b2
27 changed files with 729 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
Service/Application.Domain/Services/Interface/Map/IGameMapService.cs
View File

@@ -19,4 +19,13 @@ public interface IGameMapService
Task UpdateUserOnMap(string userId, string ip, string mapId);
#endregion
#region 其他相关
Task<List<UserModel>> GetMapUser(string mapId, int area, int showArea, List<string> noUser, int take);
Task<List<UserModel>> GetMapUser(string mapId, int area, int showArea, List<string> noUser, int page,
int limit, RefAsync<int> total);
#endregion
}

7
Service/Application.Domain/Services/Interface/User/IUnitUserService.cs
View File

@@ -24,5 +24,12 @@ public interface IUnitUserService
Task<bool> RegisterUserInfo(string userId, string nick, string sex);
#endregion
#region 其他
Task<int> GetOnlineCount();
#endregion
}

22
Service/Application.Domain/Services/Interface/User/IUnitUserWeight.cs Normal file
View File

@@ -0,0 +1,22 @@
namespace Application.Domain;
public interface IUnitUserWeight
{
Task<unit_user_weight> GetUserWeightInfo(string userId);
Task<bool> UpdateUserWeight(string userId, int op, int weight);
Task<bool> UpdateUserMaxWeight(string userId, int op, int weight);
Task<bool> AddUserWeightLog(string userId, int goodsId, string goodsName, int weight, int count);
Task<bool> CheakUserWeight(string userId, int useWeight);
#region 船只相关
Task<List<unit_user_ship>> GetUserShip(string userId);
Task<int> GetUserShipMaxWeight(string userId);
Task<bool> UpdateUserShipOnWeight(string userId, int op, int weight);
Task<bool> CheakUserShipWeight(string userId, int useWeight);
Task<bool> DeleteUserShip(string usId, string userId);
Task<bool> AddUserShip(string userId, string name, int goodsId, int speed, int weight);
#endregion
}

19
Service/Application.Domain/Services/Service/Goods/GameGoodsService.cs
View File

@@ -2,7 +2,7 @@
namespace Application.Domain;
public class GameGoodsService(ISqlSugarClient DbClient, IRedisCache redis) : IGameEquService, ITransient
public class GameGoodsService(ISqlSugarClient DbClient, IRedisCache redis) : IGameGoodsService, ITransient
{
#region 道具资源
@@ -120,10 +120,21 @@ public class GameGoodsService(ISqlSugarClient DbClient, IRedisCache redis) : IGa
if (isOk)
{
//更新负重
int weightCount = Convert.ToInt32(UserGoods.weight) * count;
if (weightCount > 0)
{
var weightService = App.GetService<IUnitUserWeight>();
if (UserGoods.code == nameof(GoodsEnum.Code.Cargo))//跑商物品处理
{
await weightService.UpdateUserShipOnWeight(userId, op, weightCount);
}
else
{
await weightService.UpdateUserWeight(userId, op, weightCount);
}
}
//添加日志
await AddGoodsLog(userId, goodsId, op, count, remark);
await AddGoodsLog(userId, goodsId, op, count, remark); //添加日志
}
return isOk;

52
Service/Application.Domain/Services/Service/Map/GameMapService.cs
View File

@@ -1,6 +1,6 @@
namespace Application.Domain;
public class GameMapService (ISqlSugarClient DbClient, IRedisCache redis): IGameMapService, ITransient
public class GameMapService(ISqlSugarClient DbClient, IRedisCache redis) : IGameMapService, ITransient
{
#region 城市地图数据
@@ -31,6 +31,7 @@ public class GameMapService (ISqlSugarClient DbClient, IRedisCache redis): IGame
return data;
}
public async Task<List<game_city_map>> GetMapCity(int cityId)
{
string key = string.Format(BaseCache.BaseCacheKeys, "MapCityData", "CityShowMap");
@@ -41,8 +42,10 @@ public class GameMapService (ISqlSugarClient DbClient, IRedisCache redis): IGame
data = await db.Queryable<game_city_map>().Where(it => it.cityId == cityId && it.show == 1).ToListAsync();
await redis.AddHashAsync(key, cityId.ToString(), data);
}
return data;
}
public async Task<int> GetMapCityByMapId(string mapId)
{
var data = await GetMapInfo(mapId);
@@ -69,6 +72,7 @@ public class GameMapService (ISqlSugarClient DbClient, IRedisCache redis): IGame
return data;
}
public async Task<game_city_npc> GetNpcInfo(int npcId)
{
string key = string.Format(BaseCache.BaseCacheKeys, "MapCityData", "NpcInfo");
@@ -77,8 +81,9 @@ public class GameMapService (ISqlSugarClient DbClient, IRedisCache redis): IGame
{
var db = DbClient.AsTenant().GetConnectionWithAttr<game_city_npc>();
data = await db.Queryable<game_city_npc>().Where(it => it.npcId == npcId).SingleAsync();
await redis.AddHashAsync(key, npcId.ToString(),data);
await redis.AddHashAsync(key, npcId.ToString(), data);
}
return data;
}
@@ -126,5 +131,48 @@ public class GameMapService (ISqlSugarClient DbClient, IRedisCache redis): IGame
}
}
#endregion
#region 其他相关
private async Task<List<UserModel>> GetMapUser(string mapId, int area, int showArea, List<string> noUser)
{
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_online>();
long time = TimeExtend.GetTimeStampBySeconds(DateTime.Now.AddMinutes(0 - GameConfig.OnLineTime));
var data = await db.Queryable<unit_user_online>().Where(it => it.upTime > time && it.mapId == mapId)
.WhereIF(noUser.Count > 0, it => !noUser.Contains(it.userId))
.OrderByDescending(it=>it.upTime)
.ToListAsync();
List<UserModel> result = new List<UserModel>();
data.ForEach(async it =>
{
var temp = await UserModelTool.GetUserView(it.userId);
bool isAdd = showArea == 1 && area != temp.area ? false : true;
if (isAdd)
{
result.Add(temp);
}
});
return result;
}
public async Task<List<UserModel>> GetMapUser(string mapId, int area, int showArea, List<string> noUser, int take)
{
var data = await GetMapUser(mapId, area, showArea, noUser);
return data.Take(take).ToList();
}
public async Task<List<UserModel>> GetMapUser(string mapId, int area, int showArea, List<string> noUser, int page,
int limit, RefAsync<int> total)
{
var data = await GetMapUser(mapId, area, showArea, noUser);
total = data.Count;
return data.Skip((page - 1) * limit) // 跳过前面的页
.Take(limit) // 取当前页
.ToList();
}
#endregion
}

27
Service/Application.Domain/Services/Service/User/UnitUserService.cs
View File

@@ -90,7 +90,6 @@ public class UnitUserService : IUnitUserService, ITransient
await _redisClient.DelHashAsync(string.Format(UserCache.BaseCacheKeys, "UserInfo", "UserNo"), result.userNo);
await _redisClient.DelHashAsync(string.Format(UserCache.BaseCacheKeys, "UserInfo", "Sid"), result.token);
}
#endregion
@@ -144,8 +143,8 @@ public class UnitUserService : IUnitUserService, ITransient
.Where(it => it.userId == userId).ExecuteCommandAsync() > 0;
if (result)
{
await ClearUserInfo(0, userId);//清理个人信息表缓存
await ClearUserInfo(0, userId); //清理个人信息表缓存
//注册账户
unit_user_acc acc = new unit_user_acc();
acc.userId = userId;
@@ -159,7 +158,7 @@ public class UnitUserService : IUnitUserService, ITransient
copper.userId = userId;
copper.copper = 0;
db.Insertable(copper).AddQueue();
//注册个人基础属性
unit_user_attr userAttr = GameTool.GetAttrData(1);
userAttr.userId = userId;
@@ -175,14 +174,14 @@ public class UnitUserService : IUnitUserService, ITransient
morale.userId = userId;
morale.morale = userAttr.upMorale;
db.Insertable(morale).AddQueue();
//注册等级经验
unit_user_exp exp = new unit_user_exp();
exp.userId = userId;
exp.exp = 0;
exp.upExp = GameTool.GetUserUpExp(1);
db.Insertable(exp).AddQueue();
//注册负重
unit_user_weight weight = new unit_user_weight();
weight.userId = userId;
@@ -196,7 +195,7 @@ public class UnitUserService : IUnitUserService, ITransient
vitality.upVitality = 50;
vitality.upTime = TimeAssist.GetDateTimeYMDString(0);
db.Insertable(vitality).AddQueue();
//注册在线
unit_user_online online = new unit_user_online();
online.userId = userId;
@@ -204,9 +203,8 @@ public class UnitUserService : IUnitUserService, ITransient
online.mapId = "16_27";
online.upTime = TimeAssist.GetTimeStampNum;
db.Insertable(online).AddQueue();
await db.SaveQueuesAsync(false);
}
return result;
@@ -245,4 +243,15 @@ public class UnitUserService : IUnitUserService, ITransient
}
#endregion
#region 其他
public async Task<int> GetOnlineCount()
{
long time = TimeExtend.GetTimeStampBySeconds(DateTime.Now.AddMinutes(0-GameConfig.OnLineTime));
var db = _dbClient.AsTenant().GetConnectionWithAttr<unit_user_online>();
return await db.Queryable<unit_user_online>().Where(it => it.upTime > time).CountAsync();
}
#endregion
}

177
Service/Application.Domain/Services/Service/User/UnitUserWeight.cs Normal file
View File

@@ -0,0 +1,177 @@
namespace Application.Domain;
public class UnitUserWeight(ISqlSugarClient DbClient, IRedisCache redis) : IUnitUserWeight, ITransient
{
public async Task<unit_user_weight> GetUserWeightInfo(string userId)
{
string key = string.Format(UserCache.BaseCacheKeys, "WeightData", "Weight");
var data = await redis.GetHashAsync<unit_user_weight>(key, userId);
if (data == null)
{
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_weight>();
data = await db.Queryable<unit_user_weight>().Where(it => it.userId == userId).SingleAsync();
await redis.AddHashAsync(key, userId, data);
}
data.maxWeight = await GetUserMaxWeight(data);
return data;
}
private async Task<int> GetUserMaxWeight(unit_user_weight data)
{
int result = (int)data.maxWeight;
//其他属性加层
return result;
}
private async Task ClearUserWeightInfo(string userId)
{
string key = string.Format(UserCache.BaseCacheKeys, "WeightData", "Weight");
await redis.DelHashAsync(key, userId);
}
public async Task<bool> UpdateUserWeight(string userId, int op, int weight)
{
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_weight>();
bool result = await db.Updateable<unit_user_weight>()
.SetColumnsIF(op == 0, it => it.onWeight == it.onWeight - weight)
.SetColumnsIF(op == 1, it => it.onWeight == it.onWeight + weight)
.SetColumnsIF(op == 2, it => it.onWeight == weight)
.Where(it => it.userId == userId).ExecuteCommandAsync() > 0;
if (result)
{
await ClearUserWeightInfo(userId);
}
return result;
}
public async Task<bool> UpdateUserMaxWeight(string userId, int op, int weight)
{
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_weight>();
bool result = await db.Updateable<unit_user_weight>()
.SetColumnsIF(op == 0, it => it.maxWeight == it.maxWeight - weight)
.SetColumnsIF(op == 1, it => it.maxWeight == it.maxWeight + weight)
.Where(it => it.userId == userId).ExecuteCommandAsync() > 0;
if (result)
{
await ClearUserWeightInfo(userId);
}
return result;
}
public async Task<bool> AddUserWeightLog(string userId, int goodsId, string goodsName, int weight, int count)
{
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_weight_log>();
unit_user_weight_log log = new unit_user_weight_log();
log.logId = StringAssist.NewGuid;
log.userId = userId;
log.goodsId = goodsId;
log.goodsName = goodsName;
log.weight = weight;
log.count = count;
log.sum = weight * count;
log.addTime = DateTime.Now;
return await db.Insertable(log).ExecuteCommandAsync() > 0;
}
public async Task<bool> CheakUserWeight(string userId, int useWeight)
{
bool result = false;
var weightInfo = await GetUserWeightInfo(userId);
if (weightInfo != null)
{
result = (useWeight + weightInfo.onWeight) <= weightInfo.maxWeight;
}
return result;
}
#region 船只相关
public async Task<List<unit_user_ship>> GetUserShip(string userId)
{
string key = string.Format(UserCache.BaseCacheKeys, "WeightData", "Ship");
var data = await redis.GetHashAsync<List<unit_user_ship>>(key, userId);
if (data == null)
{
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_ship>();
data = await db.Queryable<unit_user_ship>().Where(it => it.userId == userId).ToListAsync();
await redis.AddHashAsync(key, userId, data);
}
return data;
}
public async Task<int> GetUserShipMaxWeight(string userId)
{
var data = await GetUserShip(userId);
return data.Sum(it => (int)it.weight);
}
private async Task ClearUserShipData(string userId)
{
string key = string.Format(UserCache.BaseCacheKeys, "WeightData", "Ship");
await redis.DelHashAsync(key, userId);
}
public async Task<bool> UpdateUserShipOnWeight(string userId, int op, int weight)
{
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_weight>();
bool result = await db.Updateable<unit_user_weight>()
.SetColumnsIF(op == 0, it => it.shipOnWeight == it.shipOnWeight - weight)
.SetColumnsIF(op == 1, it => it.shipOnWeight == it.shipOnWeight + weight)
.Where(it => it.userId == userId).ExecuteCommandAsync() > 0;
if (result)
{
await ClearUserWeightInfo(userId);
}
return result;
}
public async Task<bool> CheakUserShipWeight(string userId, int useWeight)
{
bool result = false;
var weightInfo = await GetUserWeightInfo(userId);
var maxShipWeight = await GetUserShipMaxWeight(userId);
if (weightInfo != null)
{
result = (useWeight + weightInfo.onWeight) <= maxShipWeight;
}
return result;
}
public async Task<bool> DeleteUserShip(string usId,string userId)
{
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_ship>();
bool result = await db.Deleteable<unit_user_ship>().Where(it => it.usId == usId).ExecuteCommandAsync() > 0;
if (result)
{
await ClearUserShipData(userId);
}
return result;
}
public async Task<bool> AddUserShip(string userId,string name,int goodsId,int speed,int weight)
{
unit_user_ship ship = new unit_user_ship();
ship.usId = StringAssist.NewGuid;
ship.userId = userId;
ship.goodsId = goodsId;
ship.name = name;
ship.speed = speed;
ship.weight = weight;
var db = DbClient.AsTenant().GetConnectionWithAttr<unit_user_ship>();
bool result = await db.Insertable(ship).ExecuteCommandAsync() > 0;
if (result)
{
await ClearUserShipData(userId);
}
return result;
}
#endregion
}