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 ZC_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_fa_card = ConfigurationManager.AppSettings["fa_card"]; public static string _Static_pk_org_jt = ConfigurationManager.AppSettings["pk_org_jt"]; public ZC_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[] { "CG-1-1-2502-053", "CG-1-1-2502-052" }; //var ncNo = new string[] { "1001G1100000000EM104", "1001G1100000000EM10I" }; //for (int i = 0; i < codeList.Count(); i++) //{ // var idList1 = _dingTalkService.GetFormIdList("{\"textField_lty0oyv4\":\"" + 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()); //} #region 回写状态 var idList = _dingTalkService.GetFormIdList("{\"radioField_lycrvvtk\":\"Y\"}"); foreach (var item in idList) { var ncResData = new YiDaResDto() { syncTime = DateTime.Now, }; //DBHelper.WriteLog($"Id为【{JsonConvert.SerializeObject(item)}】的单据操作成功!"); ncResData.bSuccess = false; ncResData.ncNo = ""; ncResData.log = "同步失败【使用部门为空！】"; var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, item); } #endregion //DingTalkService _dingTalkService = new DingTalkService(_AppType, _SystemToken, _UserId, _FormId); //// 宜搭全量数据Id //var idList = _dingTalkService.GetFormIdList("{\"radioField_lycrvvtk\":\"Y\"}"); //// 获取当前最大Id ////var newId = 100000001; ////var maxData = _db_nc.Queryable().OrderByDescending(obd => Convert.ToDateTime(obd.creationtime)).First(); ////if (maxData != null && maxData.pk_card.Contains(_Static_PK_fa_card)) ////{ //// newId = Convert.ToInt32(maxData.pk_card.Replace(_Static_PK_fa_card, "")) + 1; ////} ////string createTime = ""; ////string modifyTime = ""; //// var ydDataSource = _dingTalkService.GetFormDataById("FINST-G9766T71XRHMWPDI7JZFU6GVQ1X839MR8B4YLT31", out createTime, out modifyTime); ////var data = new Dictionary(); ////data.Add("numberField_lu2ejqd4", "1277603.26"); ////data.Add("numberField_lzc572v2", "0"); ////data.Add("numberField_lutjo2dt", "19"); ////data.Add("dateField_lty0oyva", UnixTimeHelper.ConvertToMilliseconds(Convert.ToDateTime("2044-07-05")).ToString()); ////var ydRes = _dingTalkService.UpdateFormDataById(data, "FINST-G9766T71XRHMWPDI7JZFU6GVQ1X839MR8B4YLT31"); //#region 获取NC中选项数据的Id //// var pam_addreducestyleDic = _db_nc.Queryable().ToList(); //#endregion //// 资产部门ID textField_lydsc49c //// 管理部门ID textField_lydsc49b //#region 循环数据处理业务逻辑 //foreach (var item in idList) //{ // // 获取此条数据详情 // string createTime = ""; // string modifyTime = ""; // var ydDataSource = _dingTalkService.GetFormDataById(item, out createTime, out modifyTime); // //#region 构建数据体 // //var data = new fa_card(); // //data.archarea = 0; // //data.asset_code = ydDataSource["textField_lty0oyv4"].ToString(); // //data.asset_name = ydDataSource["textField_lty0oyuj"].ToString(); // //data.begin_date = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); // //data.bill_source = "handin"; // //data.bill_type = "H1"; // //data.billmaker = "1001G110000000000ADH"; // //data.billmaketime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); // //data.business_date = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); // //data.creationtime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); // //data.creator = "1001G110000000000ADH"; // //data.currmoney = 0; // //data.dismant_cost = 0; // //data.dy_flag = "N"; // //data.install_fee = 0; // //data.machinepower = 0; // //data.machinequan = 0; // //data.nettonnage = 0; // //data.other_cost = 0; // //data.pk_group = _Static_pk_org_jt; // //data.pk_org = "0001G110000000001MVP"; // //data.pk_org_v = "0001G110000000001MVO"; // //data.card_code = "0000001242"; // //data.assetsuit_code = "营运部(项目)0354"; // //// 主键 // //data.pk_currency = "1002Z0100000000001K1"; // //data.pk_transitype = "0001G110000000001B48"; // //data.transi_type = "H1-00"; // //data.ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); // //var a = ydDataSource.FirstOrDefault(f => f.Key == "textField_lydsc49c").Value; // var ncResData = new YiDaResDto() // { // syncTime = DateTime.Now, // }; // ncResData.bSuccess = false; // ncResData.ncNo = ""; // ncResData.log = "同步失败【折旧已经制单！】"; // var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, item); // //if (ydDataSource["textField_lydsc49c"].ToString() == "") // //{ // // var ncResData = new YiDaResDto() // // { // // syncTime = DateTime.Now, // // }; // // ncResData.bSuccess = false; // // ncResData.ncNo = ""; // // ncResData.log = "同步失败【使用部门为空！】"; // // var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, item); // //} // //else if (ydDataSource["textField_lydsc49c"].ToString().Contains("PM")) // //{ // // var ncResData = new YiDaResDto() // // { // // syncTime = DateTime.Now, // // }; // // ncResData.bSuccess = false; // // ncResData.ncNo = ""; // // ncResData.log = "同步失败【使用部门错误，无法关联有效的部门！】"; // // var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, item); // //} // //var ncResData = new YiDaResDto() // //{ // // syncTime = DateTime.Now, // //}; // //ncResData.bSuccess = false; // //ncResData.ncNo = ""; // //ncResData.log = "同步失败【使用部门为空！】"; // //var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, item); // //if (ydDataSource.FirstOrDefault(f => f.Key == "selectField_lwk48b8s").Value != null) // //{ // // if (!string.IsNullOrWhiteSpace(ydDataSource["selectField_lwk48b8s"].ToString())) // // { // // var tempData = pam_addreducestyleDic.FirstOrDefault(f => f.style_name == ydDataSource["selectField_lwk48b8s"].ToString()); // // if (tempData != null) // // { // // data.pk_addreducestyle = tempData.pk_addreducestyle; // 增加方式 // // } // // } // //} // //#endregion // //#region 数据传入NC并获取结果 // //var nowData = _db_nc.Queryable().First(f => f.asset_code == data.asset_code); // //if (nowData == null) // //{ // // data.pk_card = "DINGTALKFAC100000006"; //_Static_PK_fa_card + newId; // // _db_nc.Insertable(data).ExecuteCommand(); // // newId++; // //} // //else // //{ // // data.pk_card = nowData.pk_card; // // _db_nc.Updateable(data).ExecuteCommand(); // //} // //#endregion // //#region 回写状态 // //var ncResData = new YiDaResDto() // //{ // // syncTime = DateTime.Now, // //}; // ////DBHelper.WriteLog($"Id为【{JsonConvert.SerializeObject(item)}】的单据操作成功!"); // //ncResData.bSuccess = false; // //ncResData.ncNo = ""; // //ncResData.log = "同步失败：【增加方式为空】"; // //var ydRes = _dingTalkService.UpdateFormDataSyncDataById(ncResData, item); // //#endregion //} //#endregion } } }