241 lines
10 KiB
C#
241 lines
10 KiB
C#
using Google.Protobuf;
|
|
using Google.Protobuf.WellKnownTypes;
|
|
|
|
|
|
using ServerCore;
|
|
using ServerBase;
|
|
using ServerCommon;
|
|
using ServerCommon.BusinessLogDomain;
|
|
using MetaAssets;
|
|
|
|
|
|
using UGQDatabase.Models;
|
|
|
|
|
|
namespace GameServer;
|
|
|
|
public class UgqAbortAction : EntityActionBase
|
|
{
|
|
public UgqAbortAction(EntityBase owner)
|
|
: base(owner)
|
|
{
|
|
}
|
|
|
|
public override async Task<Result> onInit()
|
|
{
|
|
await Task.CompletedTask;
|
|
|
|
var result = new Result();
|
|
|
|
return result;
|
|
}
|
|
|
|
public override void onClear()
|
|
{
|
|
}
|
|
|
|
public async Task<Result> ugqAbort(UInt32 questId, UInt32 questRevision)
|
|
{
|
|
var player = getOwner() as Player;
|
|
NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");
|
|
|
|
var server_logic = GameServerApp.getServerLogic();
|
|
var quest_action = player.getEntityAction<QuestAction>();
|
|
|
|
var result = quest_action.getQuest(EQuestType.UGQ, questId, out var quest);
|
|
if (result.isFail())
|
|
{
|
|
return result;
|
|
}
|
|
NullReferenceCheckHelper.throwIfNull(quest, () => $"quest is null !!!");
|
|
|
|
//내가 들고 있는 퀘스트 리비전기준으로 apiserver 에서 정보를 가져와서 shutdown 상태가 아니면 환불 취소를 할수없다.
|
|
var quest_attribute = quest.getEntityAttribute<QuestAttribute>();
|
|
NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");
|
|
var owned_quest_revision = quest_attribute.UgqInfo.QuestRevision;
|
|
|
|
var ugq_info_action = player.getEntityAction<UgqInfoAction>();
|
|
NullReferenceCheckHelper.throwIfNull(ugq_info_action, () => $"ugq_info_action is null !!! - {player.toBasicString()}");
|
|
var account_attribute = player!.getEntityAttribute<AccountAttribute>();
|
|
NullReferenceCheckHelper.throwIfNull(account_attribute, () => $"account_attribute is null !!! - {player.toBasicString()}");
|
|
var language_type = account_attribute.LanguageType;
|
|
|
|
(result, var state, _) = await ugq_info_action.makeUgqCurrentState(questId, owned_quest_revision, language_type);
|
|
if (result.isFail())
|
|
{
|
|
return result;
|
|
}
|
|
NullReferenceCheckHelper.throwIfNull(state, () => $"state is null !!! - {player.toBasicString()}");
|
|
|
|
//리비전 변경된 상태도 아니고, 셧다운 상태도 아니, 스탠바이 상태도 아니면 포기할수 없다.
|
|
if (state.UgqState != UgqStateType.Shutdown && state.UgqState != UgqStateType.RevisionChanged && state.UgqState != UgqStateType.Standby)
|
|
{
|
|
var err_msg = $"can't abort ugq, cause ugqState Invalid () !!! questId : {questId}, revision : {owned_quest_revision}, state : {state.UgqState} - {player.toBasicString()}";
|
|
result.setFail(ServerErrorCode.UgqAbortCannotCauseInvalidState, err_msg);
|
|
Log.getLogger().error(err_msg);
|
|
return result;
|
|
}
|
|
|
|
var fn_transaction_runner = async delegate ()
|
|
{
|
|
var result = new Result();
|
|
quest_attribute = quest.getEntityAttribute<QuestAttribute>();
|
|
NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");
|
|
|
|
quest_attribute.deleteEntityAttribute();
|
|
|
|
(result, var quest_meta_all_base_info) = await QuestMetaManager.It.getQuestMeta(player, questId, questRevision);
|
|
if (result.isFail()) return result;
|
|
|
|
NullReferenceCheckHelper.throwIfNull(quest_meta_all_base_info, () => $"quest_meta_all_base_info is null !!! - {player.toBasicString()}");
|
|
NullReferenceCheckHelper.throwIfNull(quest_meta_all_base_info.m_quest_data_entity, () => $"quest_meta_all_base_info.m_quest_data_entity is null !!! - {player.toBasicString()}");
|
|
|
|
var cost = UgqMetaHelper.getUgqCost(quest_meta_all_base_info.m_quest_data_entity.GradeType);
|
|
var end_quest_action = player.getEntityAction<EndQuestAction>();
|
|
NullReferenceCheckHelper.throwIfNull(end_quest_action, () => $"end_quest_action is null !!! - {player.toBasicString()}");
|
|
|
|
var has_end_quest = end_quest_action.hasEndQuest(questId, questRevision);
|
|
|
|
//이미 깬 이력이 있으면 환불할 것도 없다.
|
|
if (cost > 0 && has_end_quest == false)
|
|
{
|
|
var currency_type = UgqMetaHelper.getUgqUsageFeeType(quest_meta_all_base_info.m_quest_data_entity.GradeType);
|
|
var money_action = player.getEntityAction<MoneyAction>();
|
|
result = await money_action.changeMoney(currency_type, cost);
|
|
if (result.isFail()) return result;
|
|
}
|
|
|
|
var batch = new QueryBatchEx<QueryRunnerWithDocument>(player, LogActionType.UgqAbort, server_logic.getDynamoDbClient());
|
|
{
|
|
batch.addQuery(new DBQWriteToAttributeAllWithTransactionRunner());
|
|
}
|
|
|
|
var log_invoker = new UgqAbortBusinessLog(questId, questRevision, UgqAbortType.Revision_Changed);
|
|
batch.appendBusinessLog(log_invoker);
|
|
|
|
result = await QueryHelper.sendQueryAndBusinessLog(batch);
|
|
if (result.isFail())
|
|
{
|
|
return result;
|
|
}
|
|
|
|
var found_transaction_runner = player.findTransactionRunner(TransactionIdType.PrivateContents);
|
|
NullReferenceCheckHelper.throwIfNull(found_transaction_runner, () => $"found_transaction_runner is null !!! - {player.toBasicString()}");
|
|
|
|
var common_result = found_transaction_runner.getCommonResult();
|
|
QuestNotifyHelper.send_GS2C_NTF_QUEST_REWARD(player, common_result);
|
|
|
|
return result;
|
|
};
|
|
|
|
|
|
result = await player.runTransactionRunnerSafely(TransactionIdType.PrivateContents, "UgqAbort", fn_transaction_runner);
|
|
if (result.isFail())
|
|
{
|
|
var err_msg = $"Failed to runTransactionRunnerSafely() !!! : {result.toBasicString()} - {player.toBasicString()}";
|
|
Log.getLogger().error(err_msg);
|
|
return result;
|
|
}
|
|
|
|
result = quest_action.deleteQuest(EQuestType.UGQ, questId);
|
|
|
|
UGQAbortReason reason = state.UgqState.convertUGQAbortReason();
|
|
var ugq_api_manager = server_logic.GetUqgApiManager();
|
|
var api_result = await ugq_api_manager.setUgqQuestAborted(player.getUserGuid(), questId, owned_quest_revision, reason, language_type);
|
|
if (api_result.isFail())
|
|
{
|
|
//로그만 남긴다.
|
|
Log.getLogger().error($"Failed to setUgqQuestAborted : {api_result.toBasicString()} - {player.toBasicString()}");
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
public async Task<Result> ugqAbortBySelf(UInt32 questId, UInt32 questRevision)
|
|
{
|
|
//셀프 포기는 재화를 환불해 주지 않는다.
|
|
var player = getOwner() as Player;
|
|
NullReferenceCheckHelper.throwIfNull(player, () => $"player is null !!!");
|
|
|
|
var server_logic = GameServerApp.getServerLogic();
|
|
var quest_action = player.getEntityAction<QuestAction>();
|
|
|
|
var ugq_api_manager = server_logic.GetUqgApiManager();
|
|
|
|
var account_attribute = player!.getEntityAttribute<AccountAttribute>();
|
|
NullReferenceCheckHelper.throwIfNull(account_attribute, () => $"account_attribute is null !!! - {player.toBasicString()}");
|
|
|
|
var language_type = account_attribute.LanguageType;
|
|
|
|
(var result, var latest_quest_data) = await ugq_api_manager.getUgqLatestQuestData(questId, language_type);
|
|
if (result.isFail()) return result;
|
|
|
|
NullReferenceCheckHelper.throwIfNull(latest_quest_data, () => $"latest_quest_data is null !!! - {player.toBasicString()}");
|
|
var latest_revision = latest_quest_data.Revision;
|
|
|
|
result = quest_action.getQuest(EQuestType.UGQ, questId, out var quest);
|
|
if (result.isFail())
|
|
{
|
|
return result;
|
|
}
|
|
NullReferenceCheckHelper.throwIfNull(quest, () => $"quest is null !!!");
|
|
|
|
var quest_attribute = quest.getEntityAttribute<QuestAttribute>();
|
|
NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");
|
|
|
|
if (quest_attribute.UgqInfo.QuestRevision != latest_revision || latest_quest_data.State != QuestContentState.Live)
|
|
{
|
|
var err_msg = $"can't abort ugq by self, cause quest revision changed !!! questId : {questId}, revision : {quest_attribute.UgqInfo.QuestRevision}, latest_revision : {latest_revision} - {player.toBasicString()}";
|
|
result.setFail(ServerErrorCode.UgqAbortCannotCauseInvalidState, err_msg);
|
|
Log.getLogger().error(err_msg);
|
|
return result;
|
|
}
|
|
|
|
var fn_transaction_runner = async delegate ()
|
|
{
|
|
var result = new Result();
|
|
|
|
quest_attribute = quest.getEntityAttribute<QuestAttribute>();
|
|
NullReferenceCheckHelper.throwIfNull(quest_attribute, () => $"quest_attribute is null !!! - {player.toBasicString()}");
|
|
quest_attribute.deleteEntityAttribute();
|
|
|
|
var batch = new QueryBatchEx<QueryRunnerWithDocument>(player, LogActionType.None, server_logic.getDynamoDbClient());
|
|
{
|
|
batch.addQuery(new DBQWriteToAttributeAllWithTransactionRunner());
|
|
}
|
|
|
|
var log_invoker = new UgqAbortBusinessLog(questId, questRevision, UgqAbortType.Self);
|
|
batch.appendBusinessLog(log_invoker);
|
|
|
|
result = await QueryHelper.sendQueryAndBusinessLog(batch);
|
|
if (result.isFail())
|
|
{
|
|
return result;
|
|
}
|
|
|
|
return result;
|
|
};
|
|
|
|
|
|
result = await player.runTransactionRunnerSafely(TransactionIdType.PrivateContents, "UgqAbortBySelf", fn_transaction_runner);
|
|
if (result.isFail())
|
|
{
|
|
var err_msg = $"Failed to runTransactionRunnerSafely() !!! : {result.toBasicString()} - {player.toBasicString()}";
|
|
Log.getLogger().error(err_msg);
|
|
return result;
|
|
}
|
|
result = quest_action.deleteQuest(EQuestType.UGQ, questId);
|
|
|
|
|
|
var api_result = await ugq_api_manager.setUgqQuestAborted(player.getUserGuid(), questId, questRevision, UGQAbortReason.Player, language_type);
|
|
if (api_result.isFail())
|
|
{
|
|
//로그만 남긴다.
|
|
Log.getLogger().error($"Failed to setUgqQuestAborted by self : {api_result.toBasicString()} - {player.toBasicString()}");
|
|
}
|
|
|
|
|
|
return result;
|
|
}
|
|
}
|