数据访问层使用对象方式同时插入多条数据

插入一条数据并获得返回该数据的主键。

public int SendMessage(InternalMessage IM, string[] IMPStaffID)
        {
            //数据库连接属性 引用using System.Data.SqlClient;
            using (SqlConnection IDbCon = new SqlConnection(ConfigureHelp.Connection))
            {
                //数据库连接
                IDbCon.Open();
                //开启事务。需引用using System.Data;
                IDbTransaction _tran = IDbCon.BeginTransaction();
                
                //OUTPUT INSERTED.IMID ：返回插入这条数据的主键IMID。
                string InsertIMsql = @"INSERT INTO InternalMessage(IMIsIncognito,IMType,IMObjectNum,IMContent,IMFile,IMIsLock,IMDelFlag,IMStaffID,IMDate) OUTPUT INSERTED.IMID  VALUES(@IMIsIncognito,@IMType,@IMObjectNum,@IMContent,@IMFile,@IMIsLock,@IMDelFlag,@IMStaffID,@IMDate)";
                
                string InsertIMPsql = @"INSERT INTO IMPermissions(IMPStaffID,InternalMessageID) VALUES(@IMPStaffID,@InternalMessageID)";
                try
                {
                    var IMID = IDbCon.ExecuteScalar<long>(InsertIMsql, IM,_tran);

                    //将数组循环添加到imp对象中
                    IList<IMPermissions> imp = new List<IMPermissions>();
                    for (int i = 0; i < IMPStaffID.Length; i++)
                    {
                        IMPermissions imps = new IMPermissions();
                        long tId = 0;
                        if (long.TryParse(IMPStaffID[i], out tId))
                        {
                            imps.IMPStaffID = tId;
                            imps.InternalMessageID = IMID;
                            imp.Add(imps);
                        };
                    }

                    if(IMID > 0)
                    {
                        //imp是个对象，同时插入多条数据
                        var IMPcount = IDbCon.Execute(InsertIMPsql, imp, _tran);
                        if(IMPcount >0)
                        {
                            _tran.Commit();
                            return 1;
                        }
                    }
                    _tran.Rollback();
                    return 0;

                }
                catch (Exception ex)
                {
                    UtilityHelp.WriteLog(ex, ex.ToString());
                    return -1;
                }
            }
        }