金蝶插件同步

llj

2025-10-21 22e94cbe8e20e99d0c7d873868a768a17f3836fa

金蝶插件同步

 Model/»ù´¡×ÊÁÏ/»ù´¡×ÊÁÏ/ClsGy_PropertyType_Model.cs

@@ -6,6 +6,11 @@
{
    public class ClsGy_PropertyType_Model : DBUtility.ClsGy_Base_Model
    {
       //
        public string HERPItemID;
        public string HAuxpuID;
        public string HISDefault;
        public string HSno;
        public int HMaterID;

    }
}

 Model/»ù´¡×ÊÁÏ/»ù´¡×ÊÁÏ/ClsGy_SupplierContact_Model.cs

@@ -16,5 +16,6 @@
        public string HStopEmp { get; set; }
        public int HUSEORGID { get; set; }
        public int HCREATEORGID { get; set; }
        public string HIsDefault { get; set; }
    }
}

 WebAPI/Controllers/BaseSet/Gy_PropertyController.cs

@@ -374,39 +374,52 @@
            try
            {
                var _value = msg["model"].ToString();
                _value = _value.Replace("\"hendflag\": \"1\"", "\"hendflag\": true")
                LogService.Write("1" + _value);
                var entry = msg["model"]["HENTRY"].ToString();
                LogService.Write("1" + _value);
                LogService.Write("12" + entry);
                entry = entry.Replace("\"hendflag\": \"1\"", "\"hendflag\": true")
                               .Replace("\"hstopflag\": \"0\"", "\"hstopflag\": false")
                               .Replace("\"hendflag\": \"0\"", "\"hendflag\": false")
                               .Replace("\"hstopflag\": \"1\"", "\"hstopflag\": true");

                LogService.Write($"处理后的JSON: {_value}");
                //LogService.Write(_value);
                _value = "[" + _value.ToString() + "]";
                SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
                ListModels oListModels = new ListModels();
                List<Model.ClsGy_Property_Model> lsmain = new List<Model.ClsGy_Property_Model>();
                lsmain = oListModels.getObjectByJson_Gy_Property(_value);
                List<Model.ClsGy_PropertyType_Model> lsmain = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.ClsGy_PropertyType_Model>>(_value);
                List<Model.ClsGy_Property_Model> lssub = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.ClsGy_Property_Model>>(entry);
                string sql = string.Empty;
                LogService.Write(lsmain);
                //保存
                oCN.BeginTran();
                sql = $"delete Gy_Property where HItemID = {lsmain[0].HItemID}";
                oCN.RunProc(sql);
                foreach (var osub in lssub)
                {
                    sql = $"delete Gy_Property where HItemID = {osub.HItemID}";
                    oCN.RunProc(sql);
                }
                foreach (var osub in lsmain)
                {
                    sql = $"delete Gy_PropertyEntry where HItemID = {osub.HItemID}";
                    oCN.RunProc(sql);
                }
                    
                
                sql = "set identity_insert Gy_Property on";
                oCN.RunProc(sql);

                oCN.RunProc($@"insert into Gy_Property(HItemID,HNumber,HShortNumber,HName,HHelpCode,HParentID
                    ,HLevel,HEndFlag,HStopflag,HRemark,HPropertyTypeID,HUseFlag,HERPItemID,HMakeTime)
                  values({lsmain[0].HItemID},'{lsmain[0].HNumber}','{lsmain[0].HShortNumber}','{lsmain[0].HName}','{lsmain[0].HHelpCode}',{lsmain[0].HParentID},{lsmain[0].HLevel}
           ,{Convert.ToString(lsmain[0].HEndFlag ? 1 : 0)},{Convert.ToString(lsmain[0].HStopflag ? 1 : 0) },'{lsmain[0].HRemark}',{lsmain[0].HPropertyTypeID},'{lsmain[0].HUseFlag}',{lsmain[0].HERPItemID},'{lsmain[0].HMakeTime}')", ref DBUtility.ClsPub.sExeReturnInfo);
                LogService.Write("主表插入成功");
                  values({lssub[0].HItemID},'{lssub[0].HNumber}','{lssub[0].HShortNumber}','{lssub[0].HName}','{lssub[0].HHelpCode}',{lssub[0].HParentID},{lssub[0].HLevel}
           ,{Convert.ToString(lssub[0].HEndFlag ? 1 : 0)},{Convert.ToString(lssub[0].HStopflag ? 1 : 0) },'{lssub[0].HRemark}',{lssub[0].HPropertyTypeID},'{lssub[0].HUseFlag}',{lssub[0].HERPItemID},'{lssub[0].HMakeTime}')", ref DBUtility.ClsPub.sExeReturnInfo);
                LogService.Write("辅助属性表插入成功");

                ////新增辅助子表：
                //oCN.RunProc($@"insert into Gy_PropertyEntry
                //            (HItemID,HERPItemID,HAuxpuID,HMaterID,HISDefault,HStopflag,HSno)
                //  values({lsmain[1].HItemID},'{lsmain[1].HERPItemID}','{lsmain[1].HAuxpuID}','{lsmain[1].HMaterID}','{lsmain[1].HISDefault}',{Convert.ToString(lsmain[0].HStopflag ? 1 : 0) },'{lsmain[1].HSno}')", ref DBUtility.ClsPub.sExeReturnInfo);
                ////修改上级为非末级代码
                //sql = "set identity_insert Gy_Property off";
                //LogService.Write("子表插入成功");
                //新增辅助子表：
                oCN.RunProc($@"insert into Gy_PropertyEntry
                            (HItemID,HERPItemID,HAuxpuID,HMaterID,HISDefault,HStopflag,HSno)
                  values({lsmain[0].HItemID},'{lsmain[0].HERPItemID}','{lsmain[0].HAuxpuID}','{lsmain[0].HMaterID}','{lsmain[0].HISDefault}',{Convert.ToString(lsmain[0].HStopflag ? 1 : 0) },'{lsmain[0].HSno}')", ref DBUtility.ClsPub.sExeReturnInfo);
                //修改上级为非末级代码
                sql = "set identity_insert Gy_Property off";
                LogService.Write("辅助属性值表插入成功");
                oCN.RunProc(sql);
                oCN.Commit();


 WebAPI/Controllers/BaseSet/Gy_SourceController.cs

@@ -367,7 +367,7 @@
        #region ç”Ÿäº§èµ„源列表-分页
        [Route("Gy_Source/list_byPage")]
        [HttpGet]
        public object GetSourceList_byPage(string sWhere, string user, string Organization, int page, int size)
        public object GetSourceList_byPage1(string sWhere, string user, string Organization, int page, int size)
        {
            try
            {

 WebAPI/Controllers/BaseSet/Gy_SupplierController.cs

@@ -481,10 +481,14 @@
            {
                var _value = msg["model"].ToString();
                LogService.Write("1" + _value);
                var entry = msg["model"]["HENTRY"].ToString();
                LogService.Write("1" + _value);
                LogService.Write("12" + entry);
                SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
                //反序列化
                _value = "[" + _value.ToString() + "]";
                List<Supplier> lsmain = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Supplier>>(_value);
                List<Model.ClsGy_SupplierContact_Model> lssub = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.ClsGy_SupplierContact_Model>>(entry);
                string sql = string.Empty;
                 LogService.Write("2");
                //保存
@@ -524,9 +528,30 @@
                 ",'" + lsmain[0].HEnglishAddress + "'," + lsmain[0].HCurID + "," + lsmain[0].HSSID + "," + lsmain[0].HAreaID +",'"+lsmain[0].HMaterClass+ 
                 "'," + lsmain[0].HItemID + ",'" + lsmain[0].HUseOrgID + "','" + lsmain[0].HCreateOrgID +
                  "') ");
                //修改上级为非末级代码
                sql = "set identity_insert Gy_Supplier off";
                oCN.RunProc(sql);
                ///////////
                foreach (var osub in lssub)
                {
                    sql = " set identity_insert Gy_SupplierContact on";
                    oCN.RunProc(sql);
                    LogService.Write("开始插入供应商联系人");
                    sql = $"delete from Gy_SupplierContact where HItemID = {osub.HItemID}";
                    oCN.RunProc(sql);
                    oCN.RunProc("insert into Gy_SupplierContact" +
                     "(HItemID,HNumber,HName,HShortNumber,HParentID,HLevel" +
                    ", HEndFlag, HStopflag, HRemark, HUseFlag, HIsDefault, HUSEORGID, HCREATEORGID) " +
                     " values('" + osub.HItemID + "','" + osub.HNumber + "','" + osub.HName + "'," + "'" + osub.HShortNumber + "'," + osub.HParentID + "," + osub.HLevel + ",'" + osub.HEndFlag + "','" + osub.HStopflag + "'" +
                     "," + "'" + osub.HRemark + "'" + ",'" + osub.HUseFlag + "','" + osub.HIsDefault + "'," + osub.HUSEORGID + "," + osub.HCREATEORGID +
                      ") ");
                    sql = "set identity_insert Gy_SupplierContact off";
                    oCN.RunProc(sql);
                }
                   
                //修改上级为非末级代码
                

                LogService.Write("插入供应商联系人compelete");
                oCN.Commit();

                objJsonResult.code = "1";
@@ -537,6 +562,7 @@
            }
            catch (Exception e)
            {
                LogService.Write(e);
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "保存失败！" + e.ToString();
@@ -716,6 +742,7 @@
            }
            catch (Exception e)
            {

                oCN.RollBack();
                objJsonResult.code = "0";
                objJsonResult.count = 0;

 WebAPI/Controllers/²Ö´æ¹ÜÀí/ίÍâÓÃÁÏ/WW_PPBomBillController.cs

@@ -101,7 +101,6 @@
            LogService.Write("开始同步");
            try
            {
                // è®°å½•å®Œæ•´çš„接收数据
                LogService.Write($"接收到的完整数据: {sMainSub.ToString()}");
                var model = sMainSub["model"].ToString();
                var entry = sMainSub["model"]["HENTRY"].ToString();