MARKUS

using KCOMDataModel.DataModel;

using log4net;

using Newtonsoft.Json.Linq;

using System;

using System.Collections.Generic;

using System.Configuration;

using System.Linq;

using System.Runtime.Serialization;

using System.ServiceModel;

using System.ServiceModel.Activation;

using System.ServiceModel.Web;

using System.Text;

namespace KCOM_API

{

    [ServiceContract(Namespace = "")]

    [AspNetCompatibilityRequirements(RequirementsMode = AspNetCompatibilityRequirementsMode.Allowed)]

    public class MarkusService : System.Web.Services.WebService

    {

        protected ILog logger = LogManager.GetLogger(typeof(MarkusService));

        [WebGet(UriTemplate = "AddMember?UserId={UserId}&Name={Name}&Company={Company}&Department={Department}&Position={Position}&email={email}", BodyStyle = WebMessageBodyStyle.Wrapped, RequestFormat = WebMessageFormat.Json, ResponseFormat = WebMessageFormat.Json)]

        [OperationContract]

        public AddMemberResults AddMember(string UserId,string Name, string Company, string Department,string Position,string email)

        {

            AddMemberResults results = new AddMemberResults(false,null);

            try

            {

                string sCIConnString = ConfigurationManager.ConnectionStrings["CIConnectionString"].ConnectionString;

                using (CIEntities _ci = new CIEntities(sCIConnString))

                {

                    if (_ci.MEMBER.Count(x => x.ID == UserId) == 0)

                    {

                        _ci.AddToMEMBER(new MEMBER

                        {

                            ID = UserId,

                            NAME = Name,

                            COMPANY = Company,

                            DEPARTMENT = Department,

                            POSITION = Position,

                            EMAIL_ADDRESS = email,

                            MODIFIED_DATETIME = DateTime.Now,

                            CREATE_DATETIME = DateTime.Now

                        });

                        _ci.SaveChanges();

                        results.IsSuccess = true;

                    }

                    else

                    {

                        results.Message = "User already exists.";

                    }

                }

            }

            catch (Exception ex)

            {

                results.Message = "system Error";

            }

            finally

            {

            }

            return results;

        }

        [WebInvoke(UriTemplate = "GetMembers",Method ="POST", BodyStyle = WebMessageBodyStyle.Wrapped, RequestFormat = WebMessageFormat.Json, ResponseFormat = WebMessageFormat.Json)]

        [OperationContract]

        public GetMembersResults GetMembers()

        {

            GetMembersResults results = new GetMembersResults();

            try

            {

                string sCIConnString = ConfigurationManager.ConnectionStrings["CIConnectionString"].ConnectionString;

                using (CIEntities _ci = new CIEntities(sCIConnString))

                {

                    if (_ci.MEMBER.Count() > 0)

                    {

                        results.Members = _ci.MEMBER.Select(m => new Member

                        {

                            ID = m.ID,

                            NAME = m.NAME,

                            COMPANY = m.COMPANY,

                            DEPARTMENT = m.DEPARTMENT,

                            POSITION = m.POSITION,

                            EMAIL_ADDRESS = m.EMAIL_ADDRESS

                        }).ToArray();

                    }

                }

            }

            catch (Exception ex)

            {

            }

            finally

            {

            }

            return results;

        }

        [WebGet(UriTemplate = "ConvertRun?rev_No={rev_No}&document_No={document_No}&document_Name={document_Name}&group_No={group_No}&prj_No={prj_No}&document_Id={document_Id}&document_Url={document_Url}", BodyStyle = WebMessageBodyStyle.Wrapped, RequestFormat = WebMessageFormat.Json, ResponseFormat = WebMessageFormat.Json)]

        [OperationContract]

        public string ConvertRun(string rev_No, string document_No, string document_Name, string group_No, string prj_No, string document_Id, string document_Url)

        {

            string _result = null;

            try

            {

                logger.Info($"Conversion Web Service ConvertRun call rev_No :{rev_No} document_No : {document_No}  document_Name : {document_Name}  group_No : {group_No}  prj_No : {prj_No}  document_Id : {document_Id}  document_Url : {document_Url}");

                string sConnString = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;

                using (KCOMEntities deepViewEntity = new KCOMEntities(sConnString))

                {

                    //_result = ConnectStringBuilder.DeepViewConnectionString().ToString();

                    //var _RunProjects = deepViewEntity.RUN_PROJECTS.Where(r => r.PROJECT_NO == projNumber && DateTime.Parse(r.RUN_DATETIME)<= DateTime.Now);

                    //var _RunProjects = deepViewEntity.RUN_PROJECTS.Where(r => r.PROJECT_NO == projNumber);

                    var _RunProjects = deepViewEntity.RUN_PROJECTS.Where(r => r.PROJECT_NO == prj_No).ToList();

                    if (_RunProjects.Count() == 0)

                    {

                        deepViewEntity.RUN_PROJECTS.AddObject(new RUN_PROJECTS { PROJECT_NO = prj_No, IS_ACTIVITY = 1, PROJECT_NAME = "", RUN_DATETIME = DateTime.Today });

                        var items = deepViewEntity.PROPERTIES.Where(x => x.PROPERTY == "SAMPLEPRJ");

                        foreach (var item in items)

                        {

                            deepViewEntity.PROPERTIES.AddObject(new PROPERTIES { TYPE = item.TYPE, PROPERTY = prj_No, VALUE = item.VALUE });

                        }

                        deepViewEntity.SaveChanges();

                    }

                }

                _result = SendKcom(rev_No, document_No, document_Name, group_No, prj_No, document_Id, document_Url);

            }

            catch (Exception ex)

            {

                logger.Error($"Conversion Web Service ConvertRun Error rev_No :{rev_No} document_No : {document_No}  document_Name : {document_Name}  group_No : {group_No}  prj_No : {prj_No}  document_Id : {document_Id}  document_Url : {document_Url}", ex);

                _result = "Error";

            }

            return _result;

        }

        private string SendKcom(string rev_No, string document_No, string document_Name, string group_No, string prj_No, string document_Id, string document_Url)

        {

            string result = false.ToString();

            //string _id = GetGuid(0, GuidGenerator.GetUniqueGuid()).ToString();

            string _id = shortGuid();

            string _doc_id = document_Id;// ((UInt32)document_Id.GetHashCode()).ToString();

            string sCIConnString = ConfigurationManager.ConnectionStrings["CIConnectionString"].ConnectionString;

            using (CIEntities _kcomEntity = new CIEntities(sCIConnString))

            {

                if (string.IsNullOrEmpty(group_No))

                {

                    group_No = "0";

                }

                //if (!document_Url.ToLower().Contains("http%3a%2f%2f"))

                //{

                //    document_Url = Base64Decode(document_Url);

                //    document_Url = System.Net.WebUtility.UrlEncode(document_Url);

                //}

                //document_Name = Base64DecodeFromStr(document_Name);

                var doc = _kcomEntity.DOCUMENT_ITEM.Where(d => d.PROJECT_NO == prj_No && d.ID == document_Id).FirstOrDefault();

                if (doc != null)

                {

                    doc.DOCUMENT_ID = _doc_id;

                    doc.REVISION = rev_No;

                    doc.GROUP_NO = group_No;

                    doc.DOCUMENT_NO = document_No;

                    doc.DOCUMENT_NAME = document_Name;

                    doc.ORIGINAL_FILE = document_Url;

                }

                else

                {

                    _kcomEntity.AddToDOCUMENT_ITEM(new DOCUMENT_ITEM

                    {

                        ID = document_Id,

                        REVISION = rev_No,

                        DOCUMENT_NO = document_No,

                        DOCUMENT_NAME = document_Name,

                        GROUP_NO = group_No,

                        ORIGINAL_FILE = document_Url,

                        DOCUMENT_ID = _doc_id,

                        PROJECT_NO = prj_No,

                    });

                }

                _kcomEntity.SaveChanges();

            }

            string sConnString = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;

            using (KCOMEntities _entity = new KCOMEntities(sConnString))

            {

                _entity.AddToCONVERTER_DOC(new CONVERTER_DOC

                {

                    ID = _id,

                    CREATE_DATETIME = DateTime.Now,

                    DOCUMENT_URL = document_Url,

                    PROJECT_NO = prj_No,

                    DOCUMENT_ID = _doc_id,

                });

                _entity.SaveChanges();

            }

            try

            {

                System.Net.WebClient client = new System.Net.WebClient();

                var convertResult = client.DownloadString($"{Properties.Settings.Default.CovnertService}/Rest/ConvertAdd?ProjectNo={prj_No}&ConvertID={_id}");

                JObject jObject = JObject.Parse(convertResult, new JsonLoadSettings());

                result = jObject["ConvertAddResult"].ToString();

            }

            catch (Exception ex)

            {

                logger.Error("Conversion Web Service SendKcom Error", ex);

                result = $"Markus V3 Connect Error {ex.ToString()}";

            }

            return result;

        }

        public string Base64DecodeFromStr(string data)

        {

            try

            {

                System.Text.UTF8Encoding encoder = new System.Text.UTF8Encoding();

                System.Text.Decoder utf8Decode = encoder.GetDecoder();

                byte[] todecode_byte = Convert.FromBase64String(data);

                int charCount = utf8Decode.GetCharCount(todecode_byte, 0, todecode_byte.Length);

                char[] decoded_char = new char[charCount];

                utf8Decode.GetChars(todecode_byte, 0, todecode_byte.Length, decoded_char, 0);

                string result = new String(decoded_char);

                return result;

            }

            catch (Exception)

            {

                return data;

            }

        }

        public string Base64Decode(string data)

        {

            try

            {

                if (data.Contains("http://"))

                {

                    return data;

                }

                else

                {

                    System.Text.UTF8Encoding encoder = new System.Text.UTF8Encoding();

                    System.Text.Decoder utf8Decode = encoder.GetDecoder();

                    byte[] todecode_byte = Convert.FromBase64String(data);

                    int charCount = utf8Decode.GetCharCount(todecode_byte, 0, todecode_byte.Length);

                    char[] decoded_char = new char[charCount];

                    utf8Decode.GetChars(todecode_byte, 0, todecode_byte.Length, decoded_char, 0);

                    string result = new String(decoded_char);

                    return result;

                }

            }

            catch (Exception e)

            {

                throw new Exception("Error in Base64Decode: " + e.Message);

            }

        }

        public string shortGuid()

        {

            byte[] bytes = new byte[16];

            using (var provider = System.Security.Cryptography.RandomNumberGenerator.Create())

            {

                provider.GetBytes(bytes);

            }

            var guid = new Guid(bytes);

            return Convert.ToBase64String(guid.ToByteArray())

                .Substring(0, 10)

                .Replace("/", "")

                .Replace("+", "") + DateTime.UtcNow.Ticks.ToString("x");

        }

    }

}