TransBase.cs

using System;
using System.Collections.Generic;
using System.Text.Json.Serialization;

namespace DtmCommon
{
    public class TransBase
    {
        [JsonPropertyName("gid")]
        public string Gid { get; set; }

        [JsonPropertyName("trans_type")]
        public string TransType { get; set; }

        [JsonPropertyName("custom_data")]
        public string CustomData { get; set; }

        [JsonPropertyName("wait_result")]
        public bool WaitResult { get; set; }

        [JsonPropertyName("timeout_to_fail")]
        public long TimeoutToFail { get; set; }
        [JsonPropertyName("request_timeout")]
        public long RequestTimeout { get; set; }

        [JsonPropertyName("retry_interval")]
        public long RetryInterval { get; set; }

        [JsonPropertyName("branch_headers")]
        public Dictionary<string, string> BranchHeaders { get; set; }

        [JsonPropertyName("retry_limit")]
        public long RetryLimit { get; set; }

        [JsonPropertyName("retry_count")]
        public long RetryCount { get; set; }

        /// <summary>
        /// use in MSG/SAGA
        /// </summary>
        [JsonPropertyName("steps")]
        public List<Dictionary<string, string>> Steps { get; set; }

        /// <summary>
        /// used in MSG/SAGA
        /// </summary>
        [JsonPropertyName("payloads")]
        public List<string> Payloads { get; set; }

        [JsonIgnore]
        public List<byte[]> BinPayloads { get; set; }

        /// <summary>
        /// used in XA/TCC
        /// </summary>
        [JsonIgnore]
        public BranchIDGen BranchIDGen { get; set; }

        /// <summary>
        /// used in XA/TCC
        /// </summary>
        [JsonIgnore]
        public string Op { get; set; }

        /// <summary>
        /// used in MSG
        /// </summary>
        [JsonPropertyName("query_prepared")]
        public string QueryPrepared { get; set; }

        [JsonPropertyName("protocol")]
        public string Protocol { get; set; }

        [JsonPropertyName("rollback_reason")]
        public string RollbackReason { get; set; }

        [JsonIgnore]
        public string Dtm { get; set; }

        public DateTime NextCronTime { get; set; }

        public static TransBase NewTransBase(string gid, string transType, string dtm, string branchID)
        {
            return new TransBase
            {
                Gid = gid,
                TransType = transType,
                Dtm = dtm,
                BranchIDGen = new BranchIDGen(branchID),
            };
        }
    }

}