lanyun/HH.YiDaSyncNC/DataSync/WL_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 WL_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 WL_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[] { "03010118", "01130210"};
            var ncNo = new string[] { "1001G1100000000ENHUW", "1001G1100000000ENHV0" };

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

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

                ncResData1.bSuccess = true;
                ncResData1.ncNo = ncNo[i];
                ncResData1.log = "同步成功！";

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




            //DBHelper.WriteLog($"进入程序");

            //DingTalkService _dingTalkService = new DingTalkService(_AppType, _SystemToken, _UserId, _FormId);

            //// 宜搭全量数据Id
            //var idList = _dingTalkService.GetFormIdList("{\"radioField_lycrvvtk\":\"Y\"}");

            //DBHelper.WriteLog(JsonConvert.SerializeObject(idList), "idList");

            //// NC ID对照表数据
            //var ncDataIdList = _db_nc.Queryable<xx_idcontrast>().Where(w => w.bill_type == "material").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_marbasclassDic = _db_nc.Queryable<bd_marbasclass>().ToList();
            //var pk_measdocDic = _db_nc.Queryable<bd_measdoc>().ToList();
            //var pk_mattaxesDic = _db_nc.Queryable<bd_mattaxes>().ToList();
            //var pk_brandDic = _db_nc.Queryable<bd_branddoc>().ToList();
            //#endregion

            //#region 循环数据处理业务逻辑
            //foreach (var item in idList.Where(w => !ncDataIdList.Select(s => s.file_id).ToList().Contains(w)))
            //{

            //    DBHelper.WriteLog($"进入程序1");

            //    // 获取此条数据详情
            //    string createTime = "";
            //    string modifyTime = "";
            //    var ydDataSource = _dingTalkService.GetFormDataById(item, out createTime, out modifyTime);


            //    DBHelper.WriteLog(ydDataSource["radioField_lycrvvtk"].ToString(),"222");

            //    if (ydDataSource["radioField_lycrvvtk"].ToString() == "Y")
            //    {
            //        DBHelper.WriteLog($"进入程序2");

            //        #region 构建数据体
            //        var dataSource = new WL_SyncServiceModel.DataModel()
            //        {
            //            pk_group = "0",
            //            pk_org = "0",
            //            code = ydDataSource["textField_lr3axfje"].ToString(),
            //            name = ydDataSource["textField_lr383i4h"].ToString(),
            //            ename = ydDataSource["textField_lwitq6vu"].ToString(),

            //            materialshortname = ydDataSource["textField_lwitq6vv"].ToString(),
            //            materialspec = ydDataSource["textField_ltxy3kh3"].ToString(),
            //            materialtype = ydDataSource["textField_ltxy3kh4"].ToString(),
            //            ematerialspec = ydDataSource["textField_lwitq6vw"].ToString(),
            //            materialmnecode = ydDataSource["textField_lwitq6vx"].ToString(),
            //        };

            //        if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lwitq6w4").Value != null && !string.IsNullOrWhiteSpace(ydDataSource["selectField_lwitq6w4"].ToString()))
            //        {
            //            var data = pk_marbasclassDic.FirstOrDefault(f => f.name.Trim() == ydDataSource["selectField_lwitq6w4"].ToString());
            //            if (data != null)
            //            {
            //                dataSource.pk_marbasclass = data.code; // 分类
            //            }
            //        }
            //        else
            //        {
            //            var resData = new YiDaResDto();
            //            resData.bSuccess = false;
            //            resData.syncTime = DateTime.Now;
            //            resData.ncNo = "";
            //            resData.log = "物料分类为空，无法传入NC";

            //            _dingTalkService.UpdateFormDataSyncDataById(resData, item);

            //            continue;
            //        }

            //        if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lwitq6w5"].ToString()))
            //        {
            //            dataSource.pk_measdoc = pk_measdocDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lwitq6w5"].ToString()).code; // 主计量单位
            //        }

            //        if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lwitq6w6").Value != null && !string.IsNullOrWhiteSpace(ydDataSource["selectField_lwitq6w6"].ToString()))
            //        {
            //            dataSource.pk_mattaxes = pk_mattaxesDic.FirstOrDefault(f => f.mattaxesname == ydDataSource["selectField_lwitq6w6"].ToString()).mattaxescode; // 税类
            //        }
            //        //if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lwitq6we"].ToString()))
            //        //{
            //        //    dataSource.pk_brand = pk_brandDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lwitq6we"].ToString()).code; // 品牌
            //        //}
            //        if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_ltxy3kh6"].ToString()))
            //        {

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

            //        #region 数据传入NC并获取结果
            //        var xmlData = WL_SyncServiceModel.ImportXml.Header(dataSource, item);
            //        XElement tempData = WL_SyncServiceModel.ImportXml.TemplateHeade();

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

            //        DBHelper.WriteLog($"进入程序3");

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

            //        #region 回写状态
            //        var ncResData = new YiDaResDto()
            //        {
            //            syncTime = DateTime.Now,
            //        };

            //        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_material>().First(f => f.code == dataSource.code && f.pk_org == _Static_pk_org_jt);

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

            //                newId++;

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

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

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