using System;
using System.Collections.Generic;
using System.Threading;
using BWP.B3Frameworks;
using BWP.B3Frameworks.BL;
using BWP.B3Frameworks.BO;
using BWP.B3Frameworks.Utils;
using BWP.B3Sale.BL;
using BWP.B3Sale.BO;
using Forks.EnterpriseServices.BusinessInterfaces;
using Forks.EnterpriseServices.DomainObjects2;
using Forks.EnterpriseServices.DomainObjects2.DQuery;
using TSingSoft.WebPluginFramework;
using TSingSoft.WebPluginFramework.TimerTasks;

namespace BWP.B3_YunKen.TimerTask {

  public class StoppedCustomerTask : ITimerTask {

    public string Name { get { return "耘垦停用客户定时任务"; } }

    public int Days { get { return new B3YunKenOnlineConfiguration().AutoStoppedCustomerDays.Value; } }//天数

    volatile static object _lockObj = new object();

    public void Execute() {
      if (!Monitor.TryEnter(_lockObj)) {
        throw new SameTaskNotFinishException(this);
      }

      try {
        DoExecute();
      } finally {
        Monitor.Exit(_lockObj);
      }

    }

    //A:查找启用状态的客户  
    //B:根据客户查找客户的【销售出库单】  
    //C:确定客户最晚【销售出库单】的日期  
    //D:若当前日期-最晚【销售出库单】的日期=60  则停用客户
    //E:查找客户档案上的销售人员，根据销售人员查找关联的用户
    //F:将停用客户的名单推送给销售人员关联的用户

    private void DoExecute() {
 
      var mDmoTypeID = DmoTypeIDAttribute.GetID(typeof(Customer));
      var dom = new DQueryDom(new JoinAlias(typeof(Customer)));
      dom.Columns.Add(DQSelectColumn.Field("ID"));
      dom.Columns.Add(DQSelectColumn.Field("LastGoodsOutStoreDate"));

      dom.Where.Conditions.Add(DQCondition.EQ("Stopped", false));
      dom.Where.Conditions.Add(DQCondition.IsNotNull(DQExpression.Field("LastGoodsOutStoreDate")));
      var list = dom.EExecuteList<long, DateTime>();
      var userMesageBL = BIFactory.Create<IUserMessageBL>();
      var cusBL = BIFactory.Create<ICustomerBL>();
      foreach (var tuple in list) {
        var span = DateTime.Today - tuple.Item2;
        if (span.Days >= Days)
        {
          var cus = cusBL.Load(tuple.Item1);
          cus.StopedByCustomerTask = true;
          cus.StopReason = Days + "天内未发货";
          cusBL.Update(cus);
          cusBL.Stop(cus);
          if (cus.Employee_ID.HasValue) {
            var userID = GetBindingEmployeeID(cus.Employee_ID.Value);
            if (userID == null)
              continue;
            var message = new CommonUserMessage();
            message.TargetDmoTypeID = mDmoTypeID;
            message.TargetDmoID = tuple.Item1;
            message.Text = string.Format("客户{0}NO.{1}因{2}天内未发货，被系统自动停用。", cus.Name, tuple.Item1, Days);
            userMesageBL.Insert(BLContext.User.ID, new long[] { userID.Value }, message);
          }
        }
      }


    }

    private static long? GetBindingEmployeeID(long employeeID) {

      var query = new DQueryDom(new JoinAlias(typeof(User_Employee)));
      query.Where.Conditions.Add(DQCondition.EQ("Employee_ID", employeeID));
      query.Columns.Add(DQSelectColumn.Field("User_ID"));

      var result = (long?)query.EExecuteScalar();
      return result;
    }
  }
}