lanyun/HH.YiDaSyncNC/DataSync/GYS_SyncService.cs

using HH.YiDaSyncNC.Dtos;
using HH.YiDaSyncNC.Dtos.NC;
using HH.YiDaSyncNC.Helper;
using HH.YiDaSyncNC.Models;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Xml.Linq;

namespace HH.YiDaSyncNC.DataSync
{
    class GYS_SyncService
    {
        public string _AppType;
        public string _SystemToken;
        public string _UserId;
        public string _FormId;
        public SqlSugarClient _db;
        public SqlSugarClient _db_nc;
        public string _NCApiUrl;

        public static string _Static_PK_xx_idcontrast = ConfigurationManager.AppSettings["xx_idcontrast"];
        public static string _Static_pk_org_jt = ConfigurationManager.AppSettings["pk_org_jt"];

        public GYS_SyncService(string AppType, string SystemToken, string UserId, string FormId, SqlSugarClient db, SqlSugarClient db_nc, string NCApiUrl)
        {
            _AppType = AppType;
            _SystemToken = SystemToken;
            _UserId = UserId;
            _FormId = FormId;
            _db = db;
            _db_nc = db_nc;
            _NCApiUrl = NCApiUrl;
        }

        public class IdCodeModel
        {
            public int sourceId { get; set; }
            public string Id { get; set; }
        }

        public void DataSync()
        {
            DingTalkService _dingTalkService = new DingTalkService(_AppType, _SystemToken, _UserId, _FormId);

            var codeList = new string[] { "GYS00075" };
            var ncNo = new string[] { "1001G1100000000EQHXH" };

            for (int i = 0; i < codeList.Count(); i++)
            {
                var idList1 = _dingTalkService.GetFormIdList("{\"textField_lrhgjspd\":\"" + codeList[i] + "\"}");

                var ncResData1 = new YiDaResDto()
                {
                    syncTime = DateTime.Now,
                };

                ncResData1.bSuccess = true;
                ncResData1.ncNo = ncNo[i];//1001G1100000000DVG2J    1001G1100000000DVG3B
                ncResData1.log = "同步成功!";

                var ydRes1 = _dingTalkService.UpdateFormDataSyncDataById(ncResData1, idList1.FirstOrDefault());
            }

            // 宜搭全量数据Id
            // var idList = _dingTalkService.GetFormIdList();

            //// NC ID对照表数据
            //var ncDataIdList = _db_nc.Queryable<xx_idcontrast>().Where(w => w.bill_type == "supplier").ToList();

            //// 获取当前最大Id
            //var newId = 100000001;
            //var maxData = ncDataIdList.OrderByDescending(obd => Convert.ToDateTime(obd.ts)).FirstOrDefault();
            //if (maxData != null && maxData.pk_idcontra.Contains(_Static_PK_xx_idcontrast))
            //{
            //    newId = Convert.ToInt32(maxData.pk_idcontra.Replace(_Static_PK_xx_idcontrast, "")) + 1;
            //}

            //#region 获取NC中选项数据的Id
            //var pk_supplierclassDic = _db_nc.Queryable<bd_supplierclass>().ToList();
            //#endregion

            //#region 循环数据处理业务逻辑
            //// 向NC插入数据
            //foreach (var item in idList)
            //{
            //    string createTime = "";
            //    string modifyTime = "";

            //    var ydDataSource = _dingTalkService.GetFormDataById(item, out createTime, out modifyTime);

            //    var suplinkmanDataList = new List<GYS_SyncServiceModel.DataModel.SuplinkmanItem>();

            //    //tableField_lrn5j23r

            //    var suplinkmanObjList = new List<object>();

            //    if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lrn5j24e").Value != null)
            //        suplinkmanObjList = (List<object>)ydDataSource["tableField_lrn5j24e"];

            //    foreach (var objItem in suplinkmanObjList)
            //    {
            //        suplinkmanDataList.Add(new GYS_SyncServiceModel.DataModel.SuplinkmanItem()
            //        {
            //            name = ((Dictionary<string, object>)objItem)["textField_lrn5j244"].ToString(),
            //            cell = ((Dictionary<string, object>)objItem)["textField_lrn5j245"].ToString(),
            //        });
            //    }


            //    var dataSource = new GYS_SyncServiceModel.DataModel()
            //    {
            //        pk_group = "0",
            //        pk_org = "0",
            //        code = ydDataSource["textField_lrhgjspd"].ToString(),
            //        name = ydDataSource["textField_lrhgjspc"].ToString(),
            //        taxpayerid = ydDataSource["textField_lrhgjspr"].ToString(),
            //    };

            //    if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lrn5j22q"].ToString()))
            //    {
            //        var a = pk_supplierclassDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lrn5j22q"].ToString());
            //        if (a != null)
            //            dataSource.pk_supplierclass = a.code; // 分类s
            //    }
            //    if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lrn5j22p"].ToString()))
            //    {

            //        switch (ydDataSource["selectField_lrn5j22p"].ToString())
            //        {
            //            case "启用":
            //                dataSource.enablestate = ((int)EnumType.enablestate.已启用).ToString();
            //                break;
            //            case "未启用":
            //                dataSource.enablestate = ((int)EnumType.enablestate.已停用).ToString();
            //                break;
            //        }
            //    }

            //    dataSource.suplinkman = suplinkmanDataList;

            //    var xmlData = GYS_SyncServiceModel.ImportXml.Header(dataSource, item);
            //    XElement tempData = GYS_SyncServiceModel.ImportXml.TemplateHeade();

            //    var results = NCImportFunc.NCImport(tempData, xmlData, _NCApiUrl + "?account=01&groupcode=0");

            //    XElement xE = XElement.Parse(results);
            //    string resultcode = xE.Element("sendresult").Element("resultcode").Value;
            //    string resultdescription = xE.Element("sendresult").Element("resultdescription")?.Value;

            //    var ncResData = new YiDaResDto()
            //    {
            //        syncTime = DateTime.Now,
            //    };

            //    // NC接口执行完成后的处理
            //    if (resultcode == "1")
            //    {
            //        DBHelper.WriteLog($"Id为【{JsonConvert.SerializeObject(item)}】的单据操作成功!");

            //        ncResData.bSuccess = true;
            //        ncResData.ncNo = xE.Element("sendresult").Element("content").Value;
            //        ncResData.log = "同步成功！";
            //    }
            //    else
            //    {
            //        if (resultdescription.Contains("不允许重复"))
            //        {
            //            // 已存在数据，绑定Id
            //            var nowData = _db_nc.Queryable<bd_supplier>().First(f => f.code == dataSource.code && f.pk_org == _Static_pk_org_jt);

            //            var idcData = new xx_idcontrast()
            //            {
            //                bill_type = "supplier",
            //                dr = 0,
            //                file_id = item,
            //                pk_bill = nowData.pk_supplier,
            //                pk_idcontra = _Static_PK_xx_idcontrast + newId
            //            };
            //            _db_nc.Insertable(idcData).ExecuteCommand();

            //            newId++;

            //            ncResData.bSuccess = true;
            //            ncResData.ncNo = nowData.pk_supplier;
            //            ncResData.log = "数据已存在，无需同步，已自动对照！";
            //        }
            //        else
            //        {
            //            DBHelper.WriteLog($"Id为【{JsonConvert.SerializeObject(item)}】的单据操作失败!" + resultdescription + ";");

            //            ncResData.bSuccess = false;
            //            ncResData.ncNo = "";
            //            ncResData.log = "同步失败！原因为【" + resultdescription + "】";
            //        }


            //        //DBHelper.WriteLog($"Id为【{JsonConvert.SerializeObject(item)}】的单据操作失败!" + resultdescription + ";");

            //        //if (resultdescription.Contains("不允许重复"))
            //        //{
            //        //    ncResData.bSuccess = true;
            //        //    ncResData.ncNo = "";
            //        //    ncResData.log = "数据已存在，无需同步！";
            //        //}
            //        //else
            //        //{
            //        //    ncResData.bSuccess = false;
            //        //    ncResData.ncNo = "";
            //        //    ncResData.log = "同步失败！原因为【" + resultdescription + "】";
            //        //}
            //    }

            //    var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, item);
            //}
            //#endregion

            // radioField_lycrvvtk

            //var ncResData = new YiDaResDto()
            //{
            //    syncTime = DateTime.Now,
            //};
            //ncResData.bSuccess = true;
            //ncResData.ncNo = "1001G1100000000DS51M";
            //ncResData.log = "同步成功！ || 同步成功！ ||  同步成功！";
            //var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, "FINST-G0A66Z81V0KMGG7J93ECT8JZATO63QA8SGIYLH4N2");
        }
    }
}