using CYQ.Data;
using CYQ.Data.Cache;
using CYQ.Data.Table;
using Newtonsoft.Json;
using Song.Entities;
using Song.Extend;
using System;
using System.Collections.Generic;
using System.Dynamic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Taurus.Core;
using Taurus.Mvc;
using Taurus.Mvc.Attr;

namespace PeiXun.Controllers.BasicInfo
{
    public  class UserVideoLogAPIController:Controller
    {
        [Token]
        [HttpPost]
        public void SeVideotTimeLong()
        {
            dynamic obj = new ExpandoObject();

            try
            {
                int videoTimeLong = Query<int>("VideoTimeLong");
                string videoId = Query<string>("VideoId");

                //if (videoTimeLong==0)
                //{
                //    obj.code = 0;
                //    obj.msg = "VideoTimeLong不能为空";
                //    Write(JsonConvert.SerializeObject(obj));
                //}
                if (string.IsNullOrEmpty(videoId))
                {
                    obj.code = 0;
                    obj.msg = "VideoId不能为空";
                    Write(JsonConvert.SerializeObject(obj));
                    return;
                }

                string token = Query<string>("token").TrimStart("xyl:".ToCharArray());
                Song.Entities.Accounts emp = DistributedCache.Instance.Get<Song.Entities.Accounts>(token);
                int userId = emp.Ac_ID;


                MAction ma = new MAction("UserVideoLog");
                ma.Set("UserId", userId);
                ma.Set("VideoId", videoId);
                ma.Set("VideoTimeLong", videoTimeLong);
                ma.Set("CreateTime", DateTime.Now);
                if (ma.Exists($@"UserId ='{userId}' and VideoId = '{videoId}'"))
                {
                    ma.Update($@"UserId ='{userId}' and VideoId = '{videoId}'");
                }
                else
                {
                    ma.Insert();
                }

                obj.code = 1;
                obj.msg = "success";
                Write(JsonConvert.SerializeObject(obj));

            }
            catch 
            {
                obj.code = 0;
                obj.msg = "failure";
                Write(JsonConvert.SerializeObject(obj));
            }
        }

        [Token]
        [HttpGet]
        public void GeVideotTimeLong()
        {
            dynamic obj = new ExpandoObject();

            int videoTimeLong = Query<int>("VideoTimeLong");
            string videoId = Query<string>("VideoId");

           
            if (string.IsNullOrEmpty(videoId))
            {
                obj.code = 0;
                obj.msg = "VideoId不能为空";
                Write(JsonConvert.SerializeObject(obj));
                return;

            }

            string token = Query<string>("token").TrimStart("xyl:".ToCharArray());
            Song.Entities.Accounts emp = DistributedCache.Instance.Get<Song.Entities.Accounts>(token);
            int userId = emp.Ac_ID;

            MAction ma = new MAction("UserVideoLog");
            ma.Set("UserId", userId);
            ma.Set("VideoId", videoId);
            ma.Set("VideoTimeLong", videoTimeLong);
            ma.Set("CreateTime", DateTime.Now);
            MDataTable mdt = ma.Select($@"UserId ='{userId}' and VideoId = '{videoId}'");

            if (mdt != null && mdt.Rows.Count > 0)
            {
                obj.code = 1;
                obj.msg = "success";
                obj.data = mdt.ToList<UserVideoLog>().FirstOrDefault();
                Write(JsonConvert.SerializeObject(obj));
                return;

            }
            else
            {
                obj.code = 0;
                obj.msg = "无数据";
                Write(JsonConvert.SerializeObject(obj));
                return;

            }
        }
    }

}