异常单回滚

啊鑫

9 天以前 5707781039b9d902ce1d2d6727fba65bbab14574

 WebApi/Gs.Sys/Services/FmController.cs

@@ -176,6 +176,41 @@
                "读取失败！");
        }


        /// <summary>
        ///     读取
        /// </summary>
        /// <param name="guid"></param>
        /// <returns></returns>
        [RequestMethod(RequestMethods.POST)]
        public ReturnDto<string> GetModelByVersion([FromBody] dynamic model)
        {
            string formPath = model.formPath.ToString();
            string strMsg = "";
            SqlParameter[] parameters =
            {
                new("@formPath", formPath),
                new("@userGuid", _userGuid),
            };
            var dset = new DataSet();
            try
            {
                dset = DbHelperSQL.RunProcedure("[fm_get_layout_ver]", parameters, "0");
                if (dset != null && dset.Tables.Count > 0
                 )
                {
                    strMsg = dset.Tables[0].Rows[0][0].ToString();
                }
            }
            catch (Exception ex)
            {
                LogHelper.Debug(ToString(), ex.Message+ ",formPath:"+ formPath+ ",_userGuid:"+ _userGuid);

            }
            return ReturnDto<string>.QuickReturn(strMsg, ReturnCode.Success, "读取成功！");
        }


        #endregion

        private int? chkAdmin()
@@ -224,11 +259,11 @@
                if (string.IsNullOrEmpty(idtype))
                    (_rtnInt, _rtnStr) = InterfaceUtil.HttpPostErp(_erpJson, keyUserGuid, keyGuid, keyNo);
                else
                    (_rtnInt, _rtnStr) = InterfaceUtil.HttpPostErp(_erpJson, keyUserGuid, keyGuid, keyNo,2);
                    (_rtnInt, _rtnStr) = InterfaceUtil.HttpPostErp(_erpJson, keyUserGuid, keyGuid, keyNo, 2);
            }
            catch (Exception ex)
            {
                Gs.Toolbox.LogHelper.Debug(this.ToString(), "SendErp:" + ex.Message);
                Gs.Toolbox.LogHelper.Debug(this.ToString(), "Fm SendErp:" + ex.Message);
                return "发送erp失败:" + ex.Message;
            }
            if (_rtnInt <= 0)
@@ -253,8 +288,8 @@
            string keyMeth = model.keyMeth;
            string keyNo = model.keyNo;
            string idtype = model.idtype;//这个仅仅是更新工单状态的时候有
            //if (keyMeth.ToUpper() == "delete".ToUpper())
            //    return "";
            if (keyMeth.ToUpper() == "delete".ToUpper())
                return "";
            try
            {
                System.Data.DataSet dset = new System.Data.DataSet();
@@ -278,7 +313,7 @@
                    dynamic _datajson = new ExpandoObject();
                    if (dset.Tables.Count > 1)
                    {
                        //这是结案，结构和其它不一样
                        //这是这是普通的接口里的结案，结构和其它不一样
                        if (keyMeth.ToLower() == "toclose".ToLower() || keyMeth.ToLower() == "closure".ToLower() || keyMeth.ToLower() == "unfinish")
                        {
                            _datajson = dset.Tables[1].Rows[0].RowToDynamic();
@@ -290,29 +325,27 @@
                            ((IDictionary<string, object>)_datajson)[keyChild] = _lst;
                        }
                    }
                    //var _obj = new
                    //{
                    //    mesid = _mesGuid,
                    //    taskname = keyTaskName,
                    //    optype = keyMeth,
                    //    datajson = JsonConvert.SerializeObject(),
                    //   // datajson = (_datajson),
                    //};
                    return JsonConvert.SerializeObject(_datajson);
                    var _obj = new
                    {
                        mesid = _mesGuid,
                        taskname = keyTaskName,
                        optype = keyMeth,
                        datajson = JsonConvert.SerializeObject(_datajson),
                    };
                    return JsonConvert.SerializeObject(_obj);
                }
                //这是订单回传标识
                List<dynamic> _datajson22 = new List<dynamic>();
                dynamic _ob= new ExpandoObject();
                dynamic _ob = new ExpandoObject();
                _ob.ENTRY = dset.Tables[0].TableToDynamicList();
                _datajson22.Add(_ob);

                //var _obj22 = new
                //{
                //    taskname = keyTaskName,
                //    idtype = idtype,
                //    datajson = JsonConvert.SerializeObject(_datajson22),
                //};
                return JsonConvert.SerializeObject(_datajson22);
                var _obj22 = new
                {
                    taskname = keyTaskName,
                    idtype = idtype,
                    datajson = JsonConvert.SerializeObject(_datajson22),
                };
                return JsonConvert.SerializeObject(_obj22);
            }
            catch (Exception ex)
            {
@@ -350,7 +383,8 @@
                if (_sb.Length > 0)
                    _sb.Append("~");
                _sb.Append(_line);
            };
            }
            ;
            var lst = new List<dynamic>();
            SqlParameter[] parameters =
            {
@@ -403,15 +437,23 @@
            {
                Gs.Toolbox.LogHelper.Debug(this.ToString(), "EditModel isAdmin error：" + ex.Message);
            }
            Gs.Toolbox.DbHelperSQL.ExecuteSql("delete from [FM_QUERY_TABLE] where formPath=@formPath ", new SqlParameter[] { new SqlParameter("@formPath", formPath) });
            foreach (var _obj in model.list)
            try
            {
                System.Text.StringBuilder _sb = new System.Text.StringBuilder();
                _sb.Append("INSERT INTO [dbo].[FM_QUERY_TABLE]([guid],[formPath] ,[tableName] ,[lastUpdateBy] ,[lastUpdateDate],[tableOtherName])");
                _sb.Append(" values(newid(),'" + formPath + "','" + _obj.tableName + "','',getdate(),'" + _obj.tableOtherName + "')");
                arrayList.Add(_sb.ToString());
                Gs.Toolbox.DbHelperSQL.ExecuteSql("delete from [FM_QUERY_TABLE] where formPath=@formPath ", new SqlParameter[] { new SqlParameter("@formPath", formPath) });
                foreach (var _obj in model.list)
                {
                    System.Text.StringBuilder _sb = new System.Text.StringBuilder();
                    _sb.Append("INSERT INTO [dbo].[FM_QUERY_TABLE]([guid],[formPath] ,[tableName] ,[lastUpdateBy] ,[lastUpdateDate],[tableOtherName])");
                    _sb.Append(" values(newid(),'" + formPath + "','" + _obj.tableName + "','',getdate(),'" + _obj.tableOtherName + "')");
                    arrayList.Add(_sb.ToString());
                }
                Gs.Toolbox.DbHelperSQL.ExecuteSqlTran(arrayList);
            }
            Gs.Toolbox.DbHelperSQL.ExecuteSqlTran(arrayList);
            catch (Exception ex)
            {
                m.outMsg = ex.Message;
                return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, ex.Message);
            }
            m.outMsg = "操作成功！";
            return ReturnDto<dynamic>.QuickReturn(m, ReturnCode.Default, "操作成功！");
        }