using System; using System.Threading.Tasks; using Google.Protobuf.WellKnownTypes; using Newtonsoft.Json; using ServerCore; using ServerBase; using ServerControlCenter; using USER_GUID = System.String; namespace ServerCommon; public class BlockUserAttribute : EntityAttributeBase, ICopyEntityAttributeFromDoc, IMergeWithEntityAttribute { [JsonProperty] public USER_GUID UserGuid { get; set; } = string.Empty; [JsonProperty] public USER_GUID BlockGuid { get; set; } = string.Empty; [JsonProperty] public string Nickname { get; set; } = string.Empty; public Int32 IsNew { get; set; } = 0; public DateTime CreateTime { get; set; } = DateTimeHelper.MinTime; public BlockUserAttribute(EntityBase owner) : base(owner) { } public override void onClear() { UserGuid = string.Empty; BlockGuid = string.Empty; Nickname = string.Empty; IsNew = 0; CreateTime = DateTimeHelper.MinTime; getAttributeState().reset(); } public override async Task<(Result, DynamoDbDocBase?)> toDocBase(bool isForQuery = true) { var result = new Result(); var owner = getOwner(); NullReferenceCheckHelper.throwIfNull(owner, () => $"owner is null !!! - {toBasicString()}"); var root_parent = owner.getRootParent(); NullReferenceCheckHelper.throwIfNull(root_parent, () => $"root_parent is null !!! - {toBasicString()}"); var acoount_attribute = root_parent.getEntityAttribute(); NullReferenceCheckHelper.throwIfNull(acoount_attribute, () => $"acoount_attribute is null !!! - {toBasicString()}"); //===================================================================================== // Attribute => try pending Doc //===================================================================================== USER_GUID user_guid = acoount_attribute.UserGuid; var try_pending_doc = getTryPendingDocBase() as BlockUserDoc; if (null == try_pending_doc) { var to_copy_doc = new BlockUserDoc(user_guid, BlockGuid); 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_block_user_attrib = try_pending_doc.getAttrib(); NullReferenceCheckHelper.throwIfNull(to_copy_block_user_attrib, () => $"to_copy_block_user_attrib is null !!! - {toBasicString()}"); to_copy_block_user_attrib.BlockGuid = BlockGuid; to_copy_block_user_attrib.IsNew = IsNew; 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 override EntityAttributeBase onCloned() { var owner = getOwner(); NullReferenceCheckHelper.throwIfNull(owner, () => $"owner is null !!! - {toBasicString()}"); var cloned = new BlockUserAttribute(owner); cloned.deepCopyFromBase(this); cloned.BlockGuid = BlockGuid; cloned.IsNew = IsNew; cloned.CreateTime = CreateTime; cloned.Nickname = Nickname; return cloned; } public Result onMerge(EntityAttributeBase otherEntityAttribute) { var owner = getOwner(); NullReferenceCheckHelper.throwIfNull(owner, () => $"owner is null !!! - {toBasicString()}"); 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; } var other_attribute = otherEntityAttribute as BlockUserAttribute; if (null == other_attribute) { err_msg = $"Failed to cast BlockUserAttribute !!!, other_attribute is null"; result.setFail(ServerErrorCode.ClassTypeCastIsNull, err_msg); Log.getLogger().error(result.toBasicString()); return result; } //===================================================================================== // OtherAttribute => Attribute //===================================================================================== UserGuid = other_attribute.UserGuid; BlockGuid = other_attribute.BlockGuid; Nickname = other_attribute.Nickname; IsNew = other_attribute.IsNew; CreateTime = other_attribute.CreateTime; //===================================================================================== // Attribute Try Pending Doc => Origin Doc //===================================================================================== var try_pending_doc = other_attribute.getTryPendingDocBase() as BlockUserDoc; if (null != try_pending_doc) { other_attribute.resetTryPendingDocBase(); syncOriginDocBaseWithNewDoc(try_pending_doc); } var origin_doc_base = getOriginDocBase(); if (null == origin_doc_base) { // DB 에 저장되어 있지 않는 경우 OriginDoc은 null 이다 !!! return result; } var block_user_attrib = origin_doc_base.getAttrib(); NullReferenceCheckHelper.throwIfNull(block_user_attrib, () => $"block_user_attrib is null !!! - {owner.toBasicString()}"); block_user_attrib.BlockGuid = BlockGuid; block_user_attrib.IsNew = IsNew; return result; } public bool copyEntityAttributeFromDoc(DynamoDbDocBase? docBase) { var block_user_doc_base = docBase as BlockUserDoc; if (null == block_user_doc_base) { var to_cast_string = typeof(BlockUserDoc).Name; var err_msg = $"Failed to copyEntityAttributeFromDoc() !!!, item_doc_base is null :{to_cast_string}"; Log.getLogger().error(err_msg); return false; } //===================================================================================== // New Doc => Origin Doc //===================================================================================== syncOriginDocBaseWithNewDoc(block_user_doc_base); //===================================================================================== // Doc => Attribute //===================================================================================== var doc_attrib = block_user_doc_base.getAttrib(); NullReferenceCheckHelper.throwIfNull(doc_attrib, () => $"doc_attrib is null !!! - {toBasicString()}"); BlockGuid = doc_attrib.BlockGuid; IsNew = doc_attrib.IsNew; return true; } public override IEntityAttributeTransactor onNewEntityAttributeTransactor() { return new BlockUsersAtrributeTransactor(getOwner()); } } public class BlockUsersAtrributeTransactor : EntityAttributeTransactorBase { public BlockUsersAtrributeTransactor(EntityBase owner) : base(owner) { } public bool copyEntityAttributeTransactorBaseFromEntityAttribute(EntityAttributeBase? entityAttributeBase) { //아직 미사용 Log.getLogger().info("copyEntityDbTransactBaseFromEntityAttribute call"); return true; } }