トリガーメーリング

最初の実装

1. このメールを既に送信した消費者にタグを付ける方法は？
2. すべての消費者をできるだけ迅速に処理すると同時に、サイト（データベース内の同じレコードにアクセスするサイト）の作業を遅くしない方法

1. ニュースレターの送信は、条件に一致する新しい消費者がいるかどうかを定期的に確認するwindows-serviceから行われます。
2. サービスの最初のステップは、 非コミット読み取り分離レベルのデータベースへの1つのクエリです 。 このリクエストにより、レターの送信先であるすべての消費者のIDが取得されます。 分離レベルが低いため、そのような要求はデータベース内のレコードにロックを課さず、その結果、サイトの運用に非常に弱い影響を与えます。 ただし、データの純度を保証するものではないため、より高いレベルの分離で再確認する必要があります。
3. コンシューマのIDを取得した後、各コンシューマに対して、 Serializableの分離レベルで個別のトランザクションを実行します。 このトランザクションでは、消費者が条件に適しているかどうかを再確認し、適切であれば、彼に手紙を送り、マーカーアクションを発行します。 各コンシューマーは個別のトランザクションで処理されるため、ロックは1つのコンシューマーのデータにのみ課され、他のコンシューマーの作業の影響を受けません。 このようなトランザクションは非常に短いため、この時点でサイトを訪問すれば、手紙の送信先の消費者もあまり問題になりません。 トランザクション分離レベルは正確にSerializableである必要があります。これにより、1通の手紙を誤って2回送信したり、突然条件に適合しなくなった消費者に手紙を送信したりしません。 ただし、同じメーリングを送信できるのは1つのストリームと1つのサーバーからのみであり、相互に排他的な条件を持つ2つのメーリングが同じコンシューマーに送信される可能性が小さいことを忘れる場合は、 Read Committedトランザクションを使用できます。

• マーカーアクションテンプレート （以前はテンプレートをアクションタイプと呼んでいました：これは開発者にとってより理解しやすい用語だと思います）、メール送信時に発行されます
• 発送方法
• 追加のアクションを実行するメソッド（たとえば、誕生日の挨拶を送信するとともに、消費者にポイントを発行できます）
• Expression <Func <Customer、bool >>を生成し、コンシューマーが条件に一致することを検証するメソッド

継承をコンポジションに置き換える

• アクションマーカーテンプレートを返すプロパティをオーバーロードする代わりに、このプロパティはクラスインスタンスに付加されます
• 文字/ SMSを送信して追加のロジックを実行するメソッドをオーバーロードする代わりに、任意の操作がクラスインスタンスに置かれます。これはコンシューマで実行する必要があります。 さらに、操作は他の操作の組み合わせであってもよい
• Expressionを形成するメソッドをオーバーロードする代わりに、クラスインスタンスに条件が与えられます。 この場合、条件はAND / ORで組み合わせることができます

Add(new Trigger(“       one-to-one”) { MarkerActionTemplateSystemName = “InvitationMarker”, TriggerAction = new TriggerActionCombination( new GeneratePasswordForCustomerTriggerAction(), new SendEmailTriggerAction(“InvitationMailing”)), TriggerCondition = new AndTriggerConditionSet( new CustomerHasSubscripionCondition(), new CustomerHasEmailTriggerCondition(), new CustomerHadFirstActionOverChannelCondition(“OneToOne”)), });
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 public interface ITriggerAction { void Execute( ModelContext modelContext, //      Customer customer); }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 public class TriggerCondition { private readonly Func<ModelContext, Expression<Func<Customer, bool>>> triggerExpressionBuilder; public TriggerCondition(Func<ModelContext, Expression<Func<Customer, bool>>> triggerExpressionBuilder) { if (triggerExpressionBuilder == null) throw new ArgumentNullException("triggerExpressionBuilder"); this.triggerExpressionBuilder = triggerExpressionBuilder; } public Expression<Func<Customer, bool>> GetExpression(ModelContext modelContext) { return triggerExpressionBuilder(modelContext, brand); } //   Read Uncommitted    c Id ,    public IQueryable<Customer> ChooseCustomers(ModelContext modelContext, IQueryable<Customer> customers) { if (modelContext == null) throw new ArgumentNullException("modelContext"); if (customers == null) throw new ArgumentNullException("customers"); var expression = GetExpression(modelContext); return customers.Where(expression).ExpandExpressions(); } //   Serializable ,  ,        public bool ShouldTrigger(ModelContext modelContext, Customer customer) { if (modelContext == null) throw new ArgumentNullException("modelContext"); if (customer == null) throw new ArgumentNullException("customer"); var expression = GetExpression(modelContext); //      expression.Evaluate(customer), //              return modelContext.Repositories.Get<CustomerRepository>().Items .Where(aCustomer => aCustomer == customer) .Where(aCustomer => expression.Evaluate(aCustomer)) .ExpandExpressions() .Any(); } }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

疲れている、自分でトリガーを開始する

• この時までに、私たちはあらゆる手紙の送信をアクションとして登録し始め、アクションマーカーは不要になりました-すでに誰に手紙を送信したかを判断できました。一般的には、可能な限り不必要なアクションを発行したくない
• 各コンシューマで特定の操作セットを1回実行する単純なトリガーに加えて、 定期的なトリガーがあります 。 これをすべてデータベースに転送すると同時に、 任意のマーカーの使用を許可する方法を理解する必要がありました。
• マーケティング担当者は、トリガーを個別に作成するのではなく、サイトで消費者がトリガーと操作の両方を実行するチェーンとしてサイトにアクセスします（サイトにアクセスして何かを実行するように求める手紙→消費者がサイトでいくつかの操作を実行する→ボーナスポイントが付与されます）これについての手紙が送られます）。 すぐに気づかなかった場合、トリガーと操作の間の依存関係を説明するのが難しくならないように、将来のために基礎を残したいと思います

もっと表現が必要

 public sealed override Expression<Func<CustomerAction, bool>> GetIsMarkerExpression(ModelContext modelContext) { return action => action.ActionTemplateId == ActionTemplateId; }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 public override Expression<Func<CustomerAction, bool>> GetIsMarkerExpression(ModelContext modelContext) { IQueryable<anchor>habracut</anchor> customerPrizes = modelContext.Repositories.Get<CustomerPrizeRepository>().GetByPrizes(Prize); //  ,      return action => customerPrizes.Any(prize => prize.CustomerActionId == action.Id); }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 public override Expression<Func<Customer, bool>> BuildShouldRepeatExpression(ModelContext modelContext, Expression<Func<CustomerAction, bool>> isMarkerExpression) { var markerActions = modelContext.Repositories.Get<CustomerActionRepository>().Items .Where(isMarkerExpression.ExpandExpressions()); return customer => !markerActions.Any(action => action.Customer == customer); }
      
      

        
        
        
      

    
        
        
        
      
      

        
        
        
      

    
     

 public override Expression<Func<Customer, bool>> BuildShouldRepeatExpression( ModelContext modelContext, Expression<Func<CustomerAction, bool>> isMarkerExpression) { var isInPeriodExpression = PeriodType.BuildIsInPeriodExpression(modelContext, PeriodValue); var markerActions = modelContext.Repositories.Get<CustomerActionRepository>().Items .Where(isMarkerExpression.ExpandExpressions()); var markerActionsInPeriod = markerActions.Where(isInPeriodExpression.ExpandExpressions()); if (MaxRepeatCount == null) { return customer => !markerActionsInPeriod.Any(action => action.Customer == customer); } else { return customer => !markerActionsInPeriod.Any(action => action.Customer == customer) && markerActions.Count() < MaxRepeatCount.Value; } }