using System; using System.IO; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Runtime.Serialization; using System.Runtime.Serialization.Formatters.Binary; using Newtonsoft.Json; using Microsoft.Extensions.Options; using ServerCore; using ServerBase; using USER_GUID = System.String; using Amazon.S3.Model; namespace ServerCommon { public class CharacterProfileAttribute : EntityAttributeBase, ICopyEntityAttributeFromDoc, IMergeWithEntityAttribute { public string SNSLick { get; set; } = string.Empty; public string Message { get; set; } = string.Empty; public CharacterProfileAttribute(EntityBase owner) : base(owner) { } public override void onClear() { SNSLick = string.Empty; Message = string.Empty; getAttributeState().reset(); } public CharacterProfileAttribute Cloned() { var owner = getOwner() as UserBase; NullReferenceCheckHelper.throwIfNull(owner, () => $"owner is null !!!"); var cloned = new CharacterProfileAttribute(owner); cloned.SNSLick = SNSLick; cloned.Message = Message; return cloned; } public override EntityAttributeBase onCloned() { var owner = getOwner() as UserBase; NullReferenceCheckHelper.throwIfNull(owner, () => $"owner is null !!!"); var cloned = new CharacterProfileAttribute(owner); cloned.SNSLick = SNSLick; cloned.Message = Message; return cloned; } public override IEntityAttributeTransactor onNewEntityAttributeTransactor() { var owner = getOwner() as UserBase; NullReferenceCheckHelper.throwIfNull(owner, () => $"owner is null !!!"); return new CharacterProfileAttributeTransactor(owner); } public override async Task<(Result, DynamoDbDocBase?)> toDocBase(bool isForQuery = true) { var result = new Result(); var err_msg = string.Empty; var owner = getOwner(); NullReferenceCheckHelper.throwIfNull(owner, () => $"owner is null !!!"); var acoount_attribute = owner.getEntityAttribute(); NullReferenceCheckHelper.throwIfNull(acoount_attribute, () => $"acoount_attribute is null !!!"); USER_GUID user_guid = acoount_attribute.UserGuid; //===================================================================================== // Attribute => try pending Doc //===================================================================================== var try_pending_doc = getTryPendingDocBase() as CharacterProfileDoc; if (null == try_pending_doc) { var to_copy_doc = new CharacterProfileDoc(user_guid); var origin_doc = getOriginDocBase(); if (null != origin_doc) { to_copy_doc.copyTimestampsFromOriginDocBase(origin_doc); } try_pending_doc = to_copy_doc; setTryPendingDocBase(try_pending_doc); } var to_copy_doc_attrib = try_pending_doc.getAttrib(); NullReferenceCheckHelper.throwIfNull(to_copy_doc_attrib, () => $"to_copy_doc_attrib is null !!!"); to_copy_doc_attrib.SNSLick = SNSLick; to_copy_doc_attrib.Message = Message; if (false == isForQuery) { return (result, try_pending_doc); } //===================================================================================== // Doc QueryType 반영 //===================================================================================== (result, var to_query_doc) = await applyDoc4Query(try_pending_doc); if (result.isFail()) { return (result, null); } return (result, to_query_doc); } public bool copyEntityAttributeFromDoc(DynamoDbDocBase docBase) { var result = new Result(); var err_msg = string.Empty; var to_cast_string = typeof(CharacterProfileDoc).Name; var character_profile_doc_base = docBase as CharacterProfileDoc; if (null == character_profile_doc_base) { err_msg = $"Failed to copyEntityAttributeFromDoc() !!!, character_profile_doc_base is null :{to_cast_string}"; Log.getLogger().error(err_msg); return false; } //===================================================================================== // New Doc => Origin Doc //===================================================================================== syncOriginDocBaseWithNewDoc(character_profile_doc_base); var doc_attrib = character_profile_doc_base.getAttrib(); if (doc_attrib == null) { err_msg = $"Failed to get character profile attrib : {nameof(CharacterProfileAttrib)}"; result.setFail(ServerErrorCode.EntityAttributeIsNull, err_msg); Log.getLogger().error(err_msg); return false; } SNSLick = doc_attrib.SNSLick; Message = doc_attrib.Message; return true; } public Result onMerge(EntityAttributeBase otherEntityAttribute) { var owner = getOwner(); NullReferenceCheckHelper.throwIfNull(owner, () => $"owner is null !!!"); var result = new Result(); var err_msg = string.Empty; if (null == otherEntityAttribute) { err_msg = $"Invalid Param !!!, otherEntityAttribute is null"; result.setFail(ServerErrorCode.FunctionParamNull, err_msg); Log.getLogger().error(result.toBasicString()); return result; } //===================================================================================== // OtherAttribute => Attribute //===================================================================================== var character_profile_attribute = otherEntityAttribute as CharacterProfileAttribute; if (null == character_profile_attribute) { err_msg = $"Failed to cast CharacterProfileAttribute !!!, character_profile_attribute is null"; result.setFail(ServerErrorCode.ClassTypeCastIsNull, err_msg); Log.getLogger().error(result.toBasicString()); return result; } SNSLick = character_profile_attribute.SNSLick; Message = character_profile_attribute.Message; //===================================================================================== // Attribute Try Pending Doc => Origin Doc //===================================================================================== var try_pending_doc = character_profile_attribute.getTryPendingDocBase() as CharacterProfileDoc; if (null != try_pending_doc) { character_profile_attribute.resetTryPendingDocBase(); syncOriginDocBaseWithNewDoc(try_pending_doc); } var origin_doc_base = getOriginDocBase(); if (null == origin_doc_base) { // DB 에 저장되어 있지 않는 경우 OriginDoc은 null 이다 !!! return result; } var character_profile_attrib = origin_doc_base.getAttrib(); NullReferenceCheckHelper.throwIfNull(character_profile_attrib, () => $"character_profile_attrib is null !!! - {owner.toBasicString()}"); character_profile_attrib.SNSLick = SNSLick; character_profile_attrib.Message = Message; return result; } } public class CharacterProfileAttributeTransactor : EntityAttributeTransactorBase, ICopyEntityAttributeTransactorFromEntityAttribute { public CharacterProfileAttributeTransactor(UserBase owner) : base(owner) { } public bool copyEntityAttributeTransactorFromEntityAttribute(EntityAttributeBase? entityAttributeBase) { var err_msg = string.Empty; var to_cast_string = typeof(CharacterProfileAttribute).Name; var copy_from_character_profile_attribute = entityAttributeBase as CharacterProfileAttribute; if (null == copy_from_character_profile_attribute) { err_msg = $"Failed to copyEntityAttributeTransactorFromEntityAttribute() !!!, copy_from_character_profile_attribute is null :{to_cast_string}"; Log.getLogger().error(err_msg); return false; } var copy_to_character_profile_attribute = getClonedEntityAttribute() as CharacterProfileAttribute; if (null == copy_to_character_profile_attribute) { err_msg = $"Failed to copyEntityAttributeTransactorFromEntityAttribute() !!!, copy_to_character_profile_attribute is null :{to_cast_string}"; Log.getLogger().error(err_msg); return false; } copy_to_character_profile_attribute.SNSLick = copy_from_character_profile_attribute.SNSLick; copy_to_character_profile_attribute.Message = copy_from_character_profile_attribute.Message; return true; } } }