lanyun/HH.YiDaSyncNC/DataSync/BZJ_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 BZJ_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_ct_bondapply = ConfigurationManager.AppSettings["ct_bondapply"];
        public static string _Static_PK_ct_bondapply_b = ConfigurationManager.AppSettings["ct_bondapply_b"];
        public static string _Static_pk_org_jt = ConfigurationManager.AppSettings["pk_org_jt"];

        public BZJ_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 class FormItem
        {
            public string title { get; set; }
        }

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

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

            var idList = _dingTalkService.GetFormIdList("{\"radioField_lycrvvtk\":\"Y\"}");

            LogHelper.WriteLog(JsonConvert.SerializeObject(idList.Count), "idList");

            // 获取当前最大Id
            var newId = 100000001;
            var maxData = _db_nc.Queryable<bd_project>().OrderByDescending(obd => obd.pk_project).First();
            if (maxData != null && maxData.pk_project.Contains(_Static_PK_ct_bondapply))
            {
                newId = Convert.ToInt32(maxData.pk_project.Replace(_Static_PK_ct_bondapply, "")) + 1;
            }

            #region 获取NC中选项数据的Id
            var bd_customerDic = _db_nc.Queryable<bd_customer>().ToList();
            var bd_incomeDic = _db_nc.Queryable<bd_income>().ToList();
            var org_orgsDic = _db_nc.Queryable<org_orgs>().ToList();
            var bd_projectDic = _db_nc.Queryable<bd_project>().ToList();
            var bd_materialDic = _db_nc.Queryable<bd_material>().ToList();
            var bd_measdocDic = _db_nc.Queryable<bd_measdoc>().ToList();
            var org_deptDic = _db_nc.Queryable<org_dept>().ToList();
            var bd_psndocDic = _db_nc.Queryable<bd_psndoc>().ToList();
            var sm_userDic = _db_nc.Queryable<sm_user>().ToList();
            var bd_defdoc_kplx = _db_nc.Queryable<bd_defdoc>().Where(w => w.pk_defdoclist == "1001G1100000000016FV").ToList(); // 开票类型
            var bd_defdoc_htywlx = _db_nc.Queryable<bd_defdoc>().Where(w => w.pk_defdoclist == "1001G1100000000010PV").ToList(); // 合同业务类型
            #endregion

            #region 接口方式
            // 向NC插入数据
            foreach (var item in idList)
            {
                string createTime = "";
                string modifyTime = "";

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

                // 如果NC单据号为空，说明没有传入过NC，此时需要走此逻辑去创建销售订单等
                if (ydDataSource.FirstOrDefault(f => f.Key == "textField_ltxyt75m").Value != null && !string.IsNullOrWhiteSpace(ydDataSource["textField_ltxyt75m"].ToString()))
                {
                    continue;
                }

                var ncResData = new List<YiDaResDto>();


                #region 表头
                // 表头
                var dataSource = new KP_SyncServiceModel.DataModel();

                if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vo").Value != null)
                {
                    if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vo"].ToString()))
                    {
                        var tempData = org_orgsDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vo"].ToString());
                        if (tempData != null)
                        {
                            dataSource.组织 = tempData.code; // 组织
                        }
                    }
                }

                dataSource.单据日期 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");

                if (!string.IsNullOrWhiteSpace(ydDataSource["dateField_lw5ud9bk"].ToString()))
                {
                    dataSource.单据日期 = UnixTimeHelper.ConvertMillisecondsToDateTime(Convert.ToInt64(ydDataSource["dateField_lw5ud9bk"].ToString())).ToString("yyyy-MM-dd HH:mm:ss");
                }


                if (ydDataSource.FirstOrDefault(f => f.Key == "textField_lvdojfuj").Value != null)
                {
                    if (!string.IsNullOrWhiteSpace(ydDataSource["textField_lvdojfuj"].ToString()))
                    {
                        var tempData = bd_customerDic.FirstOrDefault(f => f.code == ydDataSource["textField_lvdojfuj"].ToString());
                        if (tempData != null)
                        {
                            dataSource.客户 = tempData.code; // 客户
                        }
                    }
                }

                if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vq").Value != null)
                {
                    if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vq"].ToString()))
                    {
                        var tempData = bd_incomeDic.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vq"].ToString());
                        if (tempData != null)
                        {
                            dataSource.收款协议 = tempData.code; // 收款协议
                        }
                    }
                }

                if (ydDataSource.FirstOrDefault(f => f.Key == "departmentSelectField_lvc7mi3w").Value != null)
                {
                    if (!string.IsNullOrWhiteSpace(ydDataSource["departmentSelectField_lvc7mi3w"].ToString()))
                    {
                        var tempData = org_deptDic.FirstOrDefault(f => f.name == JsonConvert.DeserializeObject<List<string>>(JsonConvert.SerializeObject(ydDataSource["departmentSelectField_lvc7mi3w"]))[0]);
                        if (tempData != null)
                        {
                            dataSource.部门 = tempData.code; // 部门
                        }
                    }
                }

                dataSource.审批人 = "OA-NC";
                dataSource.制单人 = "OA-NC";
                dataSource.创建人 = "OA-NC";

                dataSource.审批时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                dataSource.制单时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                dataSource.创建时间 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");


                if (ydDataSource.FirstOrDefault(f => f.Key == "textField_lvdntzul").Value != null)
                {
                    if (!string.IsNullOrWhiteSpace(ydDataSource["textField_lvdntzul"].ToString()))
                    {
                        var tempData = bd_projectDic.FirstOrDefault(f => f.project_code == ydDataSource["textField_lvdntzul"].ToString());
                        if (tempData != null)
                        {
                            dataSource.项目 = tempData.project_code; // 项目
                        }
                    }
                }

                dataSource.发票号 = ydDataSource["textField_lvd8pp35"].ToString();
                dataSource.客户打印名称 = ydDataSource["selectField_lvdojfui"].ToString();

                if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vp").Value != null)
                {
                    if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vp"].ToString()))
                    {
                        var tempName = ydDataSource["selectField_lvc9x4vp"].ToString();
                        if (ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税专票")
                        {
                            tempName = "增值税专用发票";
                        }

                        if (ydDataSource["selectField_lvc9x4vp"].ToString() == "增值税普票")
                        {
                            tempName = "增值税普通发票";
                        }

                        var tempData = bd_defdoc_kplx.FirstOrDefault(f => f.name == tempName);
                        if (tempData != null)
                        {
                            dataSource.开票类型 = tempData.pk_defdoc; // 开票类型
                        }
                    }
                }

                dataSource.OA单据号 = ydDataSource["textField_lvdosccc"].ToString();

                if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lvc9x4vn").Value != null)
                {
                    if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lvc9x4vn"].ToString()))
                    {
                        if (ydDataSource["selectField_lvc9x4vn"].ToString().Contains("一次性") || ydDataSource["selectField_lvc9x4vn"].ToString().Contains("工程订单"))
                        {
                            dataSource.合同业务类型 = "1001G11000000000113F";
                        }
                        else
                        {
                            var tempData = bd_defdoc_htywlx.FirstOrDefault(f => f.name == ydDataSource["selectField_lvc9x4vn"].ToString());
                            if (tempData != null)
                            {
                                dataSource.合同业务类型 = tempData.pk_defdoc; // 合同业务类型
                            }
                        }
                    }
                }

                dataSource.年份 = DateTime.Now.ToString("yyyy");
                dataSource.月份 = DateTime.Now.ToString("MM");

                #endregion

                var detailList = new List<KP_SyncServiceModel.DataModel.OrderB>();

                #region 大业主开票明细
                if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvc9x4vt").Value != null)
                {
                    if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvc9x4vt").Value != null)
                    {
                        var detailObjList1 = (List<object>)ydDataSource["tableField_lvc9x4vt"]; // 大业主开票明细

                        if (detailObjList1.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList1.FirstOrDefault())["textField_lvdojfup"].ToString()))
                        {

                            foreach (var objItem in detailObjList1)
                            {
                                var detailItem = new KP_SyncServiceModel.DataModel.OrderB();

                                if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynhq7p_id"].ToString()))
                                {
                                    var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynhq7p_id"].ToString().Replace("\\", "");
                                    var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
                                    var b = JsonConvert.DeserializeObject<List<FormItem>>(a);

                                    var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);

                                    detailItem.物料 = materialData.code; // 物料

                                    var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);

                                    detailItem.计量单位 = unitCode.code; // 计量单位
                                }

                                var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2v"].ToString());
                                var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2z"].ToString());
                                var wsdj = hsdj - se;
                                var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2w"].ToString());
                                var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp30"].ToString());
                                var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2y"].ToString());

                                // 含税单价
                                detailItem.含税单价 = hsdj.ToString();

                                // 无税单价
                                detailItem.无税单价 = wsdj.ToString();

                                //  含税净价
                                detailItem.含税净价 = hsdj.ToString();

                                // 无税净价
                                detailItem.无税净价 = wsdj.ToString();

                                // 税额
                                detailItem.税额 = se.ToString();

                                // 无税金额
                                detailItem.无税金额 = wsje.ToString();

                                // 数量
                                detailItem.数量 = sl.ToString();

                                // 价税合计
                                detailItem.价税合计 = jshj.ToString();

                                detailItem.换算率 = "1.00/1.00";
                                detailItem.税码 = "CN04"; // 税率码 
                                detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp2x"].ToString()).ToString(); // 税率

                                detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvd8pp2t"].ToString();

                                detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfup"].ToString();

                                detailList.Add(detailItem);
                            }
                        }
                    }
                }
                #endregion

                #region 工程订单开票明细
                if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvd8pp44").Value != null)
                {
                    var detailObjList2 = (List<object>)ydDataSource["tableField_lvd8pp44"]; // 工程订单开票明细
                    if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvd8pp44").Value != null)
                    {
                        if (detailObjList2.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList2.FirstOrDefault())["textField_lvdojfur"].ToString()))
                        {
                            dataSource.项目 = "PM99001";

                            foreach (var objItem in detailObjList2)
                            {
                                var detailItem = new KP_SyncServiceModel.DataModel.OrderB();

                                if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynrr6a_id"].ToString()))
                                {
                                    var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynrr6a_id"].ToString().Replace("\\", "");
                                    var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
                                    var b = JsonConvert.DeserializeObject<List<FormItem>>(a);

                                    var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);

                                    detailItem.物料 = materialData.code; // 物料

                                    var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);

                                    detailItem.计量单位 = unitCode.code; // 计量单位
                                }

                                var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp3y"].ToString());
                                var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp42"].ToString());
                                var wsdj = hsdj - se;
                                var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp3z"].ToString());
                                var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp43"].ToString());
                                var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp41"].ToString());

                                // 含税单价
                                detailItem.含税单价 = hsdj.ToString();

                                // 无税单价
                                detailItem.无税单价 = wsdj.ToString();

                                //  含税净价
                                detailItem.含税净价 = hsdj.ToString();

                                // 无税净价
                                detailItem.无税净价 = wsdj.ToString();

                                // 税额
                                detailItem.税额 = se.ToString();

                                // 无税金额
                                detailItem.无税金额 = wsje.ToString();

                                // 数量
                                detailItem.数量 = sl.ToString();

                                // 价税合计
                                detailItem.价税合计 = jshj.ToString();

                                detailItem.换算率 = "1.00/1.00";
                                detailItem.税码 = "CN04"; // 税率码 
                                detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvd8pp40"].ToString()).ToString(); // 税率

                                detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvd8pp3w"].ToString();

                                detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfur"].ToString();

                                detailList.Add(detailItem);
                            }
                        }
                    }
                }
                #endregion

                #region 小业主开票明细
                if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvdnme13").Value != null)
                {
                    var detailObjList3 = (List<object>)ydDataSource["tableField_lvdnme13"]; // 小业主
                    if (ydDataSource.FirstOrDefault(f => f.Key == "tableField_lvdnme13").Value != null)
                    {
                        if (detailObjList3.Count() > 0 && !string.IsNullOrWhiteSpace(((Dictionary<string, object>)detailObjList3.FirstOrDefault())["textField_lvdojfus"].ToString()))
                        {

                            foreach (var objItem in detailObjList3)
                            {
                                var detailItem = new KP_SyncServiceModel.DataModel.OrderB();

                                if (!string.IsNullOrWhiteSpace(((Dictionary<string, object>)objItem)["associationFormField_lvynrr6c_id"].ToString()))
                                {
                                    var sourceStr = ((Dictionary<string, object>)objItem)["associationFormField_lvynrr6c_id"].ToString().Replace("\\", "");
                                    var a = sourceStr = sourceStr.Substring(1, sourceStr.Length - 2);
                                    var b = JsonConvert.DeserializeObject<List<FormItem>>(a);

                                    var materialData = bd_materialDic.FirstOrDefault(f => f.name == b[0].title);

                                    detailItem.物料 = materialData.code; // 物料

                                    var unitCode = bd_measdocDic.FirstOrDefault(f => f.pk_measdoc == materialData.pk_measdoc);

                                    detailItem.计量单位 = unitCode.code; // 计量单位
                                }

                                var hsdj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0w"].ToString());
                                var se = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme10"].ToString());
                                var wsdj = hsdj - se;
                                var sl = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0x"].ToString());
                                var wsje = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme11"].ToString());
                                var jshj = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0z"].ToString());

                                // 含税单价
                                detailItem.含税单价 = hsdj.ToString();

                                // 无税单价
                                detailItem.无税单价 = wsdj.ToString();

                                //  含税净价
                                detailItem.含税净价 = hsdj.ToString();

                                // 无税净价
                                detailItem.无税净价 = wsdj.ToString();

                                // 税额
                                detailItem.税额 = se.ToString();

                                // 无税金额
                                detailItem.无税金额 = wsje.ToString();

                                // 数量
                                detailItem.数量 = sl.ToString();

                                // 价税合计
                                detailItem.价税合计 = jshj.ToString();

                                detailItem.换算率 = "1.00/1.00";
                                detailItem.税码 = "CN04"; // 税率码 
                                detailItem.税率 = Convert.ToDecimal(((Dictionary<string, object>)objItem)["numberField_lvdnme0y"].ToString()).ToString(); // 税率

                                detailItem.开票内容 = ((Dictionary<string, object>)objItem)["textField_lvdnme0u"].ToString();

                                detailItem.行id = ((Dictionary<string, object>)objItem)["textField_lvdojfus"].ToString();

                                detailList.Add(detailItem);
                            }
                        }
                    }
                }
                #endregion

                dataSource.明细 = detailList;

                dataSource.数量 = dataSource.明细.Sum(s => Convert.ToDecimal(s.数量)).ToString();
                dataSource.价税合计 = dataSource.明细.Sum(s => Convert.ToDecimal(s.价税合计)).ToString();


                var results_销售订单 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售订单.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售订单.Header(dataSource, item + DateTime.Now.ToString("MMddHHmmss")), _NCApiUrl + "?account=LY01&groupcode=0");

                LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售订单), "results_销售订单");

                XElement xE_销售订单 = XElement.Parse(results_销售订单);
                string resultcode_销售订单 = xE_销售订单.Element("sendresult").Element("resultcode").Value;
                string resultdescription_销售订单 = xE_销售订单.Element("sendresult").Element("resultdescription")?.Value;

                if (resultcode_销售订单 == "1")
                {
                    ncResData.Add(new YiDaResDto()
                    {
                        bSuccess = true,
                        ncNo = xE_销售订单.Element("sendresult").Element("content").Value,
                        log = "同步成功！"
                    });
                }
                else
                {
                    ncResData.Add(new YiDaResDto()
                    {
                        bSuccess = false,
                        ncNo = "",
                        log = "同步失败！原因为【" + resultdescription_销售订单 + "】！"
                    });

                    continue;
                }

                // -------------------------------销售订单同步完，开始同步销售发票

                var saleorderData = _db_nc.Queryable<so_saleorder>().First(f => f.csaleorderid == xE_销售订单.Element("sendresult").Element("content").Value);
                var saleorderbData = _db_nc.Queryable<so_saleorder_b>().Where(f => f.csaleorderid == xE_销售订单.Element("sendresult").Element("content").Value).ToList();

                dataSource.销售订单单据号 = saleorderData.vbillcode;
                dataSource.销售订单主表id = saleorderData.csaleorderid;

                foreach (var detailItem in dataSource.明细)
                {
                    detailItem.销售订单子表id = saleorderbData.FirstOrDefault(f => f.vbdef10 == detailItem.行id).csaleorderbid;
                }

                var results_销售发票 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_销售发票.TemplateHeade(), KP_SyncServiceModel.ImportXml_销售发票.Header(dataSource, item + DateTime.Now.ToString("MMddHHmmss")), _NCApiUrl + "?account=LY01&groupcode=0");


                LogHelper.WriteLog(JsonConvert.SerializeObject(results_销售发票), "results_销售发票");

                XElement xE_销售发票 = XElement.Parse(results_销售发票);
                string resultcode_销售发票 = xE_销售发票.Element("sendresult").Element("resultcode").Value;
                string resultdescription_销售发票 = xE_销售发票.Element("sendresult").Element("resultdescription")?.Value;

                if (resultcode_销售发票 == "1")
                {
                    ncResData.Add(new YiDaResDto()
                    {
                        bSuccess = true,
                        ncNo = xE_销售发票.Element("sendresult").Element("content").Value,
                        log = "同步成功！"
                    });
                }
                else
                {
                    ncResData.Add(new YiDaResDto()
                    {
                        bSuccess = false,
                        ncNo = "",
                        log = "同步失败！原因为【" + resultdescription_销售发票 + "】！"
                    });
                }

                // -------------------------------销售发票同步完，开始同步应收

                var saleinvoicebData = _db_nc.Queryable<so_saleinvoice_b>().Where(f => f.csaleinvoiceid == xE_销售发票.Element("sendresult").Element("content").Value).ToList();
                var squareinvbData = _db_nc.Queryable<so_squareinv_d>().Where(f => f.csquarebillid == xE_销售发票.Element("sendresult").Element("content").Value).ToList();

                dataSource.销售发票主表id = xE_销售发票.Element("sendresult").Element("content").Value;

                //foreach (var detailItem in dataSource.明细)
                //{
                //    var a = saleinvoicebData.FirstOrDefault(f => f.vbdef10 == detailItem.行id).csaleinvoicebid;
                //    var b = squareinvbData.FirstOrDefault(f => f.csquarebillbid == a);
                //    detailItem.销售发票子表id = b.csalesquaredid;
                //}

                var results_应收单 = NCImportFunc.NCImport(KP_SyncServiceModel.ImportXml_应收单.TemplateHeade(), KP_SyncServiceModel.ImportXml_应收单.Header(dataSource, item + "02"), _NCApiUrl + "?account=01&groupcode=0");

                LogHelper.WriteLog(JsonConvert.SerializeObject(results_应收单), "results_应收单");

                XElement xE_应收单 = XElement.Parse(results_应收单);
                string resultcode_应收单 = xE_应收单.Element("sendresult").Element("resultcode").Value;
                string resultdescription_应收单 = xE_应收单.Element("sendresult").Element("resultdescription")?.Value;

                var recitemData = _db_nc.Queryable<ar_recitem>().Where(w => w.pk_recbill == xE_应收单.Element("sendresult").Element("content").Value).ToList();

                foreach (var recitem in recitemData)
                {
                    recitem.scomment = recitem.def1;

                    _db_nc.Updateable(recitem).ExecuteCommand();
                }


                if (resultcode_应收单 == "1")
                {
                    ncResData.Add(new YiDaResDto()
                    {
                        bSuccess = true,
                        ncNo = xE_应收单.Element("sendresult").Element("content").Value,
                        log = "同步成功！"
                    });
                }
                else
                {
                    ncResData.Add(new YiDaResDto()
                    {
                        bSuccess = false,
                        ncNo = "",
                        log = "同步失败！原因为【" + resultdescription_应收单 + "】！"
                    });
                }

                var finalResData = new YiDaResDto();

                if (ncResData.FirstOrDefault(f => !f.bSuccess) != null)
                {
                    finalResData.bSuccess = false;
                    finalResData.syncTime = DateTime.Now;
                    finalResData.ncNo = xE_销售订单.Element("sendresult").Element("content").Value;
                    finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
                }
                else
                {
                    finalResData.bSuccess = true;
                    finalResData.syncTime = DateTime.Now;
                    finalResData.ncNo = xE_销售订单.Element("sendresult").Element("content").Value;
                    finalResData.log = string.Join(" || ", ncResData.Select(s => s.log));
                }

                var ydRes = _dingTalkService.UpdateFormDataSyncDataById(finalResData, item);
            }

            #endregion
        }
    }
}