using PMS.BusinessModels.ComplaintManage;
using PMS.DBService.ComplaintManage;
using PMS.EntityModels.PersonManager;
using PMS.Interface.ComplaintManage;
using QWPlatform.IService;
using QWPlatform.SystemLibrary;
using QWPlatform.SystemLibrary.Security;
using QWPlatform.SystemLibrary.Utils;
using QWPlatform.SystemLibrary.Web;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;


namespace PMS.BusinessService.ComplaintManage
{
    /// <summary>
    /// 创建人：伍莲魁
    /// 创建日期：2018/12/13
    /// 功能说明：投诉管理业务层
    /// </summary>
    public class ComplaintList : IComplaintList
    {
        private Complaintrecordservice Com_Service = DataServiceBase.Instance<Complaintrecordservice>();
        public string GetComplaintDatagrid(SelectComplaintListModel Model)
        {
            string json;
            if (Model.My == "2")
            {
                json = Com_Service.GetComplaintDatagrid(Model);
            }
            else
            {
                json = Com_Service.GetMyComplaintDatagrid(Model);
            }
            return json;

        }
        public string GetComplaintFile(string id)
        {
            var dt = Com_Service.GetComplaintFile(id);
            return dt.ToJson();
        }
        public string GetComplaintFileFromFTP(string id)
        {
            var dt = Com_Service.GetComplaintFile(id);
            List<FTPFileModel> listmodel = new List<FTPFileModel>();
            if (dt != null && dt.Rows.Count > 0)
            {
             
                //便利ID
                foreach (DataRow dr in dt.Rows)
                {
                    var src= dr.GetValueByName<string>("附件路径");
                    string[] arr = { src };
                    var r = QWPlatform.SystemLibrary.Service.DynamicCallWebService.InvokeWebService("http://192.168.31.202:8098/FTPService.asmx", "", "getBase64File", arr);
                    var json= r.ToString();
                    FTPFileModel model = Strings.JsonToModel<FTPFileModel>(json);
                    if (!String.IsNullOrEmpty(model.base64))
                    {
                        listmodel.Add(model);
                    }
                    
                }
                
            }
            return Strings.ObjectToJson(listmodel);
        }
        public string GetComplaintPerson(string PID)
        {
            var dt = Com_Service.GetComplaintPerson(PID);
            return dt.ToJson();
        }
        public Person_Model GetPersonModel(string PID)
        {
            return Com_Service.GetPersonModel(PID);
        }
        public string GetDealProcess(string id)
        {
            var dt = Com_Service.GetDealProcess(id);
            return dt.ToJson();
        }
        public string GetCommunicate(string id)
        {
            var dt = Com_Service.GetCommunicate(id);
            if (dt == null)
            {
                return "[]";
            }
            return dt.ToJson();
        }
        public bool SubmitCmt(string id, string Content, string UserId)
        {
            var result = Com_Service.SubmitCmt(id, Content, UserId);
            return result == -1;
        }
        public bool ComplaintAccept(FormAcceptComplaint model)
        {
            var result = Com_Service.ComplaintAccept(model);
            return result == -1;
        }
        public bool ComplaintDistributeSub(FormAcceptComplaint model)
        {
            int result;
            if (model.headquarters == "on")
            {
                result = Com_Service.ComplaintDistributeSubHead(model);
            }
            else
            {
                result = Com_Service.ComplaintDistributeSub(model);
            }
           
            return result == -1;
        }
        public string ComplaintRegistration(string typeCode, string events, string detail, string PersonID)
        {

            var str = Com_Service.ComplaintRegistration(typeCode, events, detail, PersonID);
            return str;
        }
        public bool ImageUpload(string CompliantID, string src)
        {
            var r = Com_Service.ImageUpload(CompliantID, src);
            return r == -1;
        }
        public string QueryComplaint(QueryComplaintModel model)
        {
            var dt = Com_Service.QueryComplaint(model);
            if (dt != null && dt.Rows.Count > 0)
            {
                foreach(DataRow dr in dt.Rows)
                {
                    var src = dr.GetValueByName<string>("附件路径");
                    ///判断路径是否为空
                    if (!String.IsNullOrEmpty(src))
                    {
                        string[] arr = { src };
                        var r = QWPlatform.SystemLibrary.Service.DynamicCallWebService.InvokeWebService("http://192.168.31.202:8098/FTPService.asmx", "", "getBase64File", arr);
                        var json = r.ToString();
                        FTPFileModel modelf = Strings.JsonToModel<FTPFileModel>(json);
                        ///判断图片接收是否异常
                        if (!String.IsNullOrEmpty(modelf.base64))
                        {
                            dr["附件路径"] = modelf.base64ToImage;
                        }
                    }
                }
            }
                return dt.ToJson();
        }
        public string GetComplaintDetail(string id)
        {
            var dt = Com_Service.GetComplaintDetail(id);
            return dt.ToJson();
        }
        public bool DeleteComplaint(string id)
        {
            var r = Com_Service.DeleteComplaint(id);
            return r == "1";
        }


    }
}