using Newtonsoft.Json;
using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WX.CRM.BLL.Util;
using WX.CRM.BLL.Ww;
using WX.CRM.Common;

namespace WX.CRM.CRMServices.Res_AlloCate
{
    public class WwHhuserAct
    {
        string url = "http://post.hc.dn8188.com/Rights/WeworkUser2Eid.html";

        WW_HHUSER_EID_ACT_BL _wwHhuserAct = new WW_HHUSER_EID_ACT_BL();

        SecurityHelper sHelper = new SecurityHelper();

        public void Start()
        {
            try
            {
                var deptcode = Utility.GetSettingOrNullByKey("DataClientCode");
                var channel = Utility.GetSettingOrNullByKey("Channel");
                var ch = 0;
                if (!string.IsNullOrEmpty(channel))
                {
                    ch = int.Parse(channel);
                }

                var list = _wwHhuserAct.GetList(p => p.ISEXE == 0).OrderBy(p => p.CTIME);

                var time = (long)Utility.ConvertDateTimeInt(DateTime.Now);
                var message = JsonConvert.SerializeObject(new { account = "dn.crm", time });
                var para = sHelper.createSignEncodingStr(message);

                var urlUp = url + "?" + para;

                var listUp = new List<WeworkUser2Eid>();
                foreach (var item in list)
                {
                    listUp.Add(new WeworkUser2Eid(item.APPID, item.USERID, Convert.ToInt32(item.EID), 1, deptcode, ch, item.ASSIGNSTATUS.HasValue ? Convert.ToInt32(item.ASSIGNSTATUS.Value) : 0));
                }

                var rsp = Utility.HttpPostData(urlUp, JsonConvert.SerializeObject(listUp), Encoding.UTF8);

                var ret = JsonConvert.DeserializeAnonymousType(rsp, new { errcode = -1, errmsg = string.Empty });

                if (ret.errcode == 0)
                {
                    foreach (var item in list)
                    {
                        try
                        {
                            item.ISEXE = 1;
                            _wwHhuserAct.Update(item);
                        }
                        catch (Exception ex)
                        {
                            LogHelper.Error("更新上传关系记录失败：" + item.ToJson() + "---" + ex.ToString());
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
            }
        }
    }

    public class WeworkUser2Eid
    {
        public WeworkUser2Eid()
        {
        }

        public WeworkUser2Eid(string appid, string userid, int eid, int status, string deptcode, int ch, int assignstatus)
        {
            this.appid = appid;
            this.userid = userid;
            this.eid = eid;
            this.status = status;
            this.deptcode = deptcode;
            this.ch = ch;
            this.assignstatus = assignstatus;
        }

        public string appid { get; set; }
        public string userid { get; set; }
        public int eid { get; set; }
        public int status { get; set; }
        public string deptcode { get; set; }
        public int ch { get; set; }
        public int assignstatus { get; set; }
    }

    public class WwHhuserActJob : IJob
    {
        static bool _isNotice = false;
        public void Execute(JobExecutionContext context)
        {
            if (_isNotice)
                return;
            _isNotice = true;
            try
            {
                new WwHhuserAct().Start();
            }
            catch (Exception e)
            {
                WX.CRM.Common.LogHelper.Error("WX.CRM.CRMServices.Res_AlloCate.WwHhuserActJob.WwHhuserAct().Execute:" + e);
            }
            finally
            {
                _isNotice = false;
            }
        }
    }
}