chenxiangxue
/
FuZhou_Custom_BulkCargo_Server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'main' of http://172.16.1.12/chenxiangxue/FuZhou_Custom_BulkCargo_Server 

# Conflicts:
#	.gitignore
This commit is contained in:
陈向学 2024-06-13 14:49:28 +08:00
parent 832cff5ff7 5366d036a7
commit a1dd3696ba
17 changed files with 1702 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

186
CompetitionAPI/CompetitionAPI/Competition.Mysql/BLL/v_model_version.cs Normal file
View File

@ -0,0 +1,186 @@
/** 版本信息模板在安装目录下，可自行修改。
* v_model_version.cs
*
* 功 能： N/A
* 类 名： v_model_version
*
* Ver 变更日期 负责人 变更内容
* ───────────────────────────────────
* V0.01 2024/6/13 13:55:19 N/A 初版
*
* Copyright (c) 2012 Maticsoft Corporation. All rights reserved.
*┌──────────────────────────────────┐
*│　此技术信息为本公司机密信息，未经本公司书面同意禁止向第三方披露．　│
*│　版权所有：动软卓越（北京）科技有限公司　　　　　　　　　　　　　　│
*└──────────────────────────────────┘
*/
using System;
using System.Data;
using System.Collections.Generic;
using Maticsoft.Common;
using Competition.Mysql.Model;
namespace Competition.Mysql.BLL
{
/// <summary>
/// v_model_version
/// </summary>
public partial class v_model_version
{
private readonly Competition.Mysql.DAL.v_model_version dal=new Competition.Mysql.DAL.v_model_version();
public v_model_version()
{}
#region BasicMethod
/// <summary>
/// 是否存在该记录
/// </summary>
public bool Exists(string ModelId)
{
return dal.Exists(ModelId);
}
/// <summary>
/// 增加一条数据
/// </summary>
public bool Add(Competition.Mysql.Model.v_model_version model)
{
return dal.Add(model);
}
/// <summary>
/// 更新一条数据
/// </summary>
public bool Update(Competition.Mysql.Model.v_model_version model)
{
return dal.Update(model);
}
/// <summary>
/// 删除一条数据
/// </summary>
public bool Delete(string ModelId)
{
return dal.Delete(ModelId);
}
/// <summary>
/// 删除一条数据
/// </summary>
public bool DeleteList(string ModelIdlist )
{
return dal.DeleteList(ModelIdlist );
}
/// <summary>
/// 得到一个对象实体
/// </summary>
public Competition.Mysql.Model.v_model_version GetModel(string ModelId)
{
return dal.GetModel(ModelId);
}
/// <summary>
/// 得到一个对象实体，从缓存中
/// </summary>
public Competition.Mysql.Model.v_model_version GetModelByCache(string ModelId)
{
string CacheKey = "v_model_versionModel-" + ModelId;
object objModel = Maticsoft.Common.DataCache.GetCache(CacheKey);
if (objModel == null)
{
try
{
objModel = dal.GetModel(ModelId);
if (objModel != null)
{
int ModelCache = Maticsoft.Common.ConfigHelper.GetConfigInt("ModelCache");
Maticsoft.Common.DataCache.SetCache(CacheKey, objModel, DateTime.Now.AddMinutes(ModelCache), TimeSpan.Zero);
}
}
catch{}
}
return (Competition.Mysql.Model.v_model_version)objModel;
}
/// <summary>
/// 获得数据列表
/// </summary>
public DataSet GetList(string strWhere)
{
return dal.GetList(strWhere);
}
/// <summary>
/// 获得前几行数据
/// </summary>
public DataSet GetList(int Top,string strWhere,string filedOrder)
{
return dal.GetList(Top,strWhere,filedOrder);
}
/// <summary>
/// 获得数据列表
/// </summary>
public List<Competition.Mysql.Model.v_model_version> GetModelList(string strWhere)
{
DataSet ds = dal.GetList(strWhere);
return DataTableToList(ds.Tables[0]);
}
/// <summary>
/// 获得数据列表
/// </summary>
public List<Competition.Mysql.Model.v_model_version> DataTableToList(DataTable dt)
{
List<Competition.Mysql.Model.v_model_version> modelList = new List<Competition.Mysql.Model.v_model_version>();
int rowsCount = dt.Rows.Count;
if (rowsCount > 0)
{
Competition.Mysql.Model.v_model_version model;
for (int n = 0; n < rowsCount; n++)
{
model = dal.DataRowToModel(dt.Rows[n]);
if (model != null)
{
modelList.Add(model);
}
}
}
return modelList;
}
/// <summary>
/// 获得数据列表
/// </summary>
public DataSet GetAllList()
{
return GetList("");
}
/// <summary>
/// 分页获取数据列表
/// </summary>
public int GetRecordCount(string strWhere)
{
return dal.GetRecordCount(strWhere);
}
/// <summary>
/// 分页获取数据列表
/// </summary>
public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
{
return dal.GetListByPage( strWhere, orderby, startIndex, endIndex);
}
/// <summary>
/// 分页获取数据列表
/// </summary>
//public DataSet GetList(int PageSize,int PageIndex,string strWhere)
//{
//return dal.GetList(PageSize,PageIndex,strWhere);
//}
#endregion BasicMethod
#region ExtensionMethod
#endregion ExtensionMethod
}
}

186
CompetitionAPI/CompetitionAPI/Competition.Mysql/BLL/v_starter_version.cs Normal file
View File

@ -0,0 +1,186 @@
/** 版本信息模板在安装目录下，可自行修改。
* v_starter_version.cs
*
* 功 能： N/A
* 类 名： v_starter_version
*
* Ver 变更日期 负责人 变更内容
* ───────────────────────────────────
* V0.01 2024/6/13 13:55:19 N/A 初版
*
* Copyright (c) 2012 Maticsoft Corporation. All rights reserved.
*┌──────────────────────────────────┐
*│　此技术信息为本公司机密信息，未经本公司书面同意禁止向第三方披露．　│
*│　版权所有：动软卓越（北京）科技有限公司　　　　　　　　　　　　　　│
*└──────────────────────────────────┘
*/
using System;
using System.Data;
using System.Collections.Generic;
using Maticsoft.Common;
using Competition.Mysql.Model;
namespace Competition.Mysql.BLL
{
/// <summary>
/// v_starter_version
/// </summary>
public partial class v_starter_version
{
private readonly Competition.Mysql.DAL.v_starter_version dal=new Competition.Mysql.DAL.v_starter_version();
public v_starter_version()
{}
#region BasicMethod
/// <summary>
/// 是否存在该记录
/// </summary>
public bool Exists(string StarterId)
{
return dal.Exists(StarterId);
}
/// <summary>
/// 增加一条数据
/// </summary>
public bool Add(Competition.Mysql.Model.v_starter_version model)
{
return dal.Add(model);
}
/// <summary>
/// 更新一条数据
/// </summary>
public bool Update(Competition.Mysql.Model.v_starter_version model)
{
return dal.Update(model);
}
/// <summary>
/// 删除一条数据
/// </summary>
public bool Delete(string StarterId)
{
return dal.Delete(StarterId);
}
/// <summary>
/// 删除一条数据
/// </summary>
public bool DeleteList(string StarterIdlist )
{
return dal.DeleteList(StarterIdlist );
}
/// <summary>
/// 得到一个对象实体
/// </summary>
public Competition.Mysql.Model.v_starter_version GetModel(string StarterId)
{
return dal.GetModel(StarterId);
}
/// <summary>
/// 得到一个对象实体，从缓存中
/// </summary>
public Competition.Mysql.Model.v_starter_version GetModelByCache(string StarterId)
{
string CacheKey = "v_starter_versionModel-" + StarterId;
object objModel = Maticsoft.Common.DataCache.GetCache(CacheKey);
if (objModel == null)
{
try
{
objModel = dal.GetModel(StarterId);
if (objModel != null)
{
int ModelCache = Maticsoft.Common.ConfigHelper.GetConfigInt("ModelCache");
Maticsoft.Common.DataCache.SetCache(CacheKey, objModel, DateTime.Now.AddMinutes(ModelCache), TimeSpan.Zero);
}
}
catch{}
}
return (Competition.Mysql.Model.v_starter_version)objModel;
}
/// <summary>
/// 获得数据列表
/// </summary>
public DataSet GetList(string strWhere)
{
return dal.GetList(strWhere);
}
/// <summary>
/// 获得前几行数据
/// </summary>
public DataSet GetList(int Top,string strWhere,string filedOrder)
{
return dal.GetList(Top,strWhere,filedOrder);
}
/// <summary>
/// 获得数据列表
/// </summary>
public List<Competition.Mysql.Model.v_starter_version> GetModelList(string strWhere)
{
DataSet ds = dal.GetList(strWhere);
return DataTableToList(ds.Tables[0]);
}
/// <summary>
/// 获得数据列表
/// </summary>
public List<Competition.Mysql.Model.v_starter_version> DataTableToList(DataTable dt)
{
List<Competition.Mysql.Model.v_starter_version> modelList = new List<Competition.Mysql.Model.v_starter_version>();
int rowsCount = dt.Rows.Count;
if (rowsCount > 0)
{
Competition.Mysql.Model.v_starter_version model;
for (int n = 0; n < rowsCount; n++)
{
model = dal.DataRowToModel(dt.Rows[n]);
if (model != null)
{
modelList.Add(model);
}
}
}
return modelList;
}
/// <summary>
/// 获得数据列表
/// </summary>
public DataSet GetAllList()
{
return GetList("");
}
/// <summary>
/// 分页获取数据列表
/// </summary>
public int GetRecordCount(string strWhere)
{
return dal.GetRecordCount(strWhere);
}
/// <summary>
/// 分页获取数据列表
/// </summary>
public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
{
return dal.GetListByPage( strWhere, orderby, startIndex, endIndex);
}
/// <summary>
/// 分页获取数据列表
/// </summary>
//public DataSet GetList(int PageSize,int PageIndex,string strWhere)
//{
//return dal.GetList(PageSize,PageIndex,strWhere);
//}
#endregion BasicMethod
#region ExtensionMethod
#endregion ExtensionMethod
}
}

1
CompetitionAPI/CompetitionAPI/Competition.Mysql/Competition.Mysql.csproj
View File

@ -28,7 +28,6 @@
</ItemGroup>
<ItemGroup>
<Folder Include="Model\" />
<Folder Include="Other\" />
</ItemGroup>

394
CompetitionAPI/CompetitionAPI/Competition.Mysql/DAL/v_model_version.cs Normal file
View File

@ -0,0 +1,394 @@
/** 版本信息模板在安装目录下，可自行修改。
* v_model_version.cs
*
* 功 能： N/A
* 类 名： v_model_version
*
* Ver 变更日期 负责人 变更内容
* ───────────────────────────────────
* V0.01 2024/6/13 13:55:19 N/A 初版
*
* Copyright (c) 2012 Maticsoft Corporation. All rights reserved.
*┌──────────────────────────────────┐
*│　此技术信息为本公司机密信息，未经本公司书面同意禁止向第三方披露．　│
*│　版权所有：动软卓越（北京）科技有限公司　　　　　　　　　　　　　　│
*└──────────────────────────────────┘
*/
using System;
using System.Data;
using System.Text;
using System.Data.SqlClient;
using Maticsoft.DBUtility;//Please add references
namespace Competition.Mysql.DAL
{
/// <summary>
/// 数据访问类:v_model_version
/// </summary>
public partial class v_model_version
{
public v_model_version()
{}
#region BasicMethod
/// <summary>
/// 是否存在该记录
/// </summary>
public bool Exists(string ModelId)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select count(1) from v_model_version");
strSql.Append(" where ModelId=@ModelId ");
SqlParameter[] parameters = {
new SqlParameter("@ModelId", SqlDbType.VarChar,50) };
parameters[0].Value = ModelId;
return DbHelperSQL.Exists(strSql.ToString(),parameters);
}
/// <summary>
/// 增加一条数据
/// </summary>
public bool Add(Competition.Mysql.Model.v_model_version model)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("insert into v_model_version(");
strSql.Append("ModelId,MONITOR_ID,ModelName,VersionNumber,MapLongitude,MapLatitude,TrainingSize,ModelResources,UpdateTime,Remark1,Remark2,Remark3)");
strSql.Append(" values (");
strSql.Append("@ModelId,@MONITOR_ID,@ModelName,@VersionNumber,@MapLongitude,@MapLatitude,@TrainingSize,@ModelResources,@UpdateTime,@Remark1,@Remark2,@Remark3)");
SqlParameter[] parameters = {
new SqlParameter("@ModelId", SqlDbType.VarChar,50),
new SqlParameter("@MONITOR_ID", SqlDbType.VarChar,40),
new SqlParameter("@ModelName", SqlDbType.VarChar,255),
new SqlParameter("@VersionNumber", SqlDbType.VarChar,255),
new SqlParameter("@MapLongitude", SqlDbType.VarChar,255),
new SqlParameter("@MapLatitude", SqlDbType.VarChar,255),
new SqlParameter("@TrainingSize", SqlDbType.VarChar,255),
new SqlParameter("@ModelResources", SqlDbType.VarChar,2000),
new SqlParameter("@UpdateTime", SqlDbType.DateTime),
new SqlParameter("@Remark1", SqlDbType.VarChar,255),
new SqlParameter("@Remark2", SqlDbType.VarChar,255),
new SqlParameter("@Remark3", SqlDbType.VarChar,255)};
parameters[0].Value = model.ModelId;
parameters[1].Value = model.MONITOR_ID;
parameters[2].Value = model.ModelName;
parameters[3].Value = model.VersionNumber;
parameters[4].Value = model.MapLongitude;
parameters[5].Value = model.MapLatitude;
parameters[6].Value = model.TrainingSize;
parameters[7].Value = model.ModelResources;
parameters[8].Value = model.UpdateTime;
parameters[9].Value = model.Remark1;
parameters[10].Value = model.Remark2;
parameters[11].Value = model.Remark3;
int rows=DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 更新一条数据
/// </summary>
public bool Update(Competition.Mysql.Model.v_model_version model)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("update v_model_version set ");
strSql.Append("MONITOR_ID=@MONITOR_ID,");
strSql.Append("ModelName=@ModelName,");
strSql.Append("VersionNumber=@VersionNumber,");
strSql.Append("MapLongitude=@MapLongitude,");
strSql.Append("MapLatitude=@MapLatitude,");
strSql.Append("TrainingSize=@TrainingSize,");
strSql.Append("ModelResources=@ModelResources,");
strSql.Append("UpdateTime=@UpdateTime,");
strSql.Append("Remark1=@Remark1,");
strSql.Append("Remark2=@Remark2,");
strSql.Append("Remark3=@Remark3");
strSql.Append(" where ModelId=@ModelId ");
SqlParameter[] parameters = {
new SqlParameter("@MONITOR_ID", SqlDbType.VarChar,40),
new SqlParameter("@ModelName", SqlDbType.VarChar,255),
new SqlParameter("@VersionNumber", SqlDbType.VarChar,255),
new SqlParameter("@MapLongitude", SqlDbType.VarChar,255),
new SqlParameter("@MapLatitude", SqlDbType.VarChar,255),
new SqlParameter("@TrainingSize", SqlDbType.VarChar,255),
new SqlParameter("@ModelResources", SqlDbType.VarChar,2000),
new SqlParameter("@UpdateTime", SqlDbType.DateTime),
new SqlParameter("@Remark1", SqlDbType.VarChar,255),
new SqlParameter("@Remark2", SqlDbType.VarChar,255),
new SqlParameter("@Remark3", SqlDbType.VarChar,255),
new SqlParameter("@ModelId", SqlDbType.VarChar,50)};
parameters[0].Value = model.MONITOR_ID;
parameters[1].Value = model.ModelName;
parameters[2].Value = model.VersionNumber;
parameters[3].Value = model.MapLongitude;
parameters[4].Value = model.MapLatitude;
parameters[5].Value = model.TrainingSize;
parameters[6].Value = model.ModelResources;
parameters[7].Value = model.UpdateTime;
parameters[8].Value = model.Remark1;
parameters[9].Value = model.Remark2;
parameters[10].Value = model.Remark3;
parameters[11].Value = model.ModelId;
int rows=DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 删除一条数据
/// </summary>
public bool Delete(string ModelId)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("delete from v_model_version ");
strSql.Append(" where ModelId=@ModelId ");
SqlParameter[] parameters = {
new SqlParameter("@ModelId", SqlDbType.VarChar,50) };
parameters[0].Value = ModelId;
int rows=DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 批量删除数据
/// </summary>
public bool DeleteList(string ModelIdlist )
{
StringBuilder strSql=new StringBuilder();
strSql.Append("delete from v_model_version ");
strSql.Append(" where ModelId in ("+ModelIdlist + ") ");
int rows=DbHelperSQL.ExecuteSql(strSql.ToString());
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 得到一个对象实体
/// </summary>
public Competition.Mysql.Model.v_model_version GetModel(string ModelId)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select top 1 ModelId,MONITOR_ID,ModelName,VersionNumber,MapLongitude,MapLatitude,TrainingSize,ModelResources,UpdateTime,Remark1,Remark2,Remark3 from v_model_version ");
strSql.Append(" where ModelId=@ModelId ");
SqlParameter[] parameters = {
new SqlParameter("@ModelId", SqlDbType.VarChar,50) };
parameters[0].Value = ModelId;
Competition.Mysql.Model.v_model_version model=new Competition.Mysql.Model.v_model_version();
DataSet ds=DbHelperSQL.Query(strSql.ToString(),parameters);
if(ds.Tables[0].Rows.Count>0)
{
return DataRowToModel(ds.Tables[0].Rows[0]);
}
else
{
return null;
}
}
/// <summary>
/// 得到一个对象实体
/// </summary>
public Competition.Mysql.Model.v_model_version DataRowToModel(DataRow row)
{
Competition.Mysql.Model.v_model_version model=new Competition.Mysql.Model.v_model_version();
if (row != null)
{
if(row["ModelId"]!=null)
{
model.ModelId=row["ModelId"].ToString();
}
if(row["MONITOR_ID"]!=null)
{
model.MONITOR_ID=row["MONITOR_ID"].ToString();
}
if(row["ModelName"]!=null)
{
model.ModelName=row["ModelName"].ToString();
}
if(row["VersionNumber"]!=null)
{
model.VersionNumber=row["VersionNumber"].ToString();
}
if(row["MapLongitude"]!=null)
{
model.MapLongitude=row["MapLongitude"].ToString();
}
if(row["MapLatitude"]!=null)
{
model.MapLatitude=row["MapLatitude"].ToString();
}
if(row["TrainingSize"]!=null)
{
model.TrainingSize=row["TrainingSize"].ToString();
}
if(row["ModelResources"]!=null)
{
model.ModelResources=row["ModelResources"].ToString();
}
if(row["UpdateTime"]!=null && row["UpdateTime"].ToString()!="")
{
model.UpdateTime=DateTime.Parse(row["UpdateTime"].ToString());
}
if(row["Remark1"]!=null)
{
model.Remark1=row["Remark1"].ToString();
}
if(row["Remark2"]!=null)
{
model.Remark2=row["Remark2"].ToString();
}
if(row["Remark3"]!=null)
{
model.Remark3=row["Remark3"].ToString();
}
}
return model;
}
/// <summary>
/// 获得数据列表
/// </summary>
public DataSet GetList(string strWhere)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select ModelId,MONITOR_ID,ModelName,VersionNumber,MapLongitude,MapLatitude,TrainingSize,ModelResources,UpdateTime,Remark1,Remark2,Remark3 ");
strSql.Append(" FROM v_model_version ");
if(strWhere.Trim()!="")
{
strSql.Append(" where "+strWhere);
}
return DbHelperSQL.Query(strSql.ToString());
}
/// <summary>
/// 获得前几行数据
/// </summary>
public DataSet GetList(int Top,string strWhere,string filedOrder)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select ");
if(Top>0)
{
strSql.Append(" top "+Top.ToString());
}
strSql.Append(" ModelId,MONITOR_ID,ModelName,VersionNumber,MapLongitude,MapLatitude,TrainingSize,ModelResources,UpdateTime,Remark1,Remark2,Remark3 ");
strSql.Append(" FROM v_model_version ");
if(strWhere.Trim()!="")
{
strSql.Append(" where "+strWhere);
}
strSql.Append(" order by " + filedOrder);
return DbHelperSQL.Query(strSql.ToString());
}
/// <summary>
/// 获取记录总数
/// </summary>
public int GetRecordCount(string strWhere)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select count(1) FROM v_model_version ");
if(strWhere.Trim()!="")
{
strSql.Append(" where "+strWhere);
}
object obj = DbHelperSQL.GetSingle(strSql.ToString());
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 分页获取数据列表
/// </summary>
public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("SELECT * FROM ( ");
strSql.Append(" SELECT ROW_NUMBER() OVER (");
if (!string.IsNullOrEmpty(orderby.Trim()))
{
strSql.Append("order by T." + orderby );
}
else
{
strSql.Append("order by T.ModelId desc");
}
strSql.Append(")AS Row, T.* from v_model_version T ");
if (!string.IsNullOrEmpty(strWhere.Trim()))
{
strSql.Append(" WHERE " + strWhere);
}
strSql.Append(" ) TT");
strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
return DbHelperSQL.Query(strSql.ToString());
}
/*
/// <summary>
/// 分页获取数据列表
/// </summary>
public DataSet GetList(int PageSize,int PageIndex,string strWhere)
{
SqlParameter[] parameters = {
new SqlParameter("@tblName", SqlDbType.VarChar, 255),
new SqlParameter("@fldName", SqlDbType.VarChar, 255),
new SqlParameter("@PageSize", SqlDbType.Int),
new SqlParameter("@PageIndex", SqlDbType.Int),
new SqlParameter("@IsReCount", SqlDbType.Bit),
new SqlParameter("@OrderType", SqlDbType.Bit),
new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
};
parameters[0].Value = "v_model_version";
parameters[1].Value = "ModelId";
parameters[2].Value = PageSize;
parameters[3].Value = PageIndex;
parameters[4].Value = 0;
parameters[5].Value = 0;
parameters[6].Value = strWhere;
return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
}*/
#endregion BasicMethod
#region ExtensionMethod
#endregion ExtensionMethod
}
}

358
CompetitionAPI/CompetitionAPI/Competition.Mysql/DAL/v_starter_version.cs Normal file
View File

@ -0,0 +1,358 @@
/** 版本信息模板在安装目录下，可自行修改。
* v_starter_version.cs
*
* 功 能： N/A
* 类 名： v_starter_version
*
* Ver 变更日期 负责人 变更内容
* ───────────────────────────────────
* V0.01 2024/6/13 13:55:19 N/A 初版
*
* Copyright (c) 2012 Maticsoft Corporation. All rights reserved.
*┌──────────────────────────────────┐
*│　此技术信息为本公司机密信息，未经本公司书面同意禁止向第三方披露．　│
*│　版权所有：动软卓越（北京）科技有限公司　　　　　　　　　　　　　　│
*└──────────────────────────────────┘
*/
using System;
using System.Data;
using System.Text;
using System.Data.SqlClient;
using Maticsoft.DBUtility;//Please add references
namespace Competition.Mysql.DAL
{
/// <summary>
/// 数据访问类:v_starter_version
/// </summary>
public partial class v_starter_version
{
public v_starter_version()
{}
#region BasicMethod
/// <summary>
/// 是否存在该记录
/// </summary>
public bool Exists(string StarterId)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select count(1) from v_starter_version");
strSql.Append(" where StarterId=@StarterId ");
SqlParameter[] parameters = {
new SqlParameter("@StarterId", SqlDbType.VarChar,50) };
parameters[0].Value = StarterId;
return DbHelperSQL.Exists(strSql.ToString(),parameters);
}
/// <summary>
/// 增加一条数据
/// </summary>
public bool Add(Competition.Mysql.Model.v_starter_version model)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("insert into v_starter_version(");
strSql.Append("StarterId,SoftwareName,VersionNumber,LauncherResources,UpdateResources,Remark1,Remark2,Remark3)");
strSql.Append(" values (");
strSql.Append("@StarterId,@SoftwareName,@VersionNumber,@LauncherResources,@UpdateResources,@Remark1,@Remark2,@Remark3)");
SqlParameter[] parameters = {
new SqlParameter("@StarterId", SqlDbType.VarChar,50),
new SqlParameter("@SoftwareName", SqlDbType.VarChar,255),
new SqlParameter("@VersionNumber", SqlDbType.VarChar,255),
new SqlParameter("@LauncherResources", SqlDbType.VarChar,2000),
new SqlParameter("@UpdateResources", SqlDbType.VarChar,2000),
new SqlParameter("@Remark1", SqlDbType.VarChar,255),
new SqlParameter("@Remark2", SqlDbType.VarChar,255),
new SqlParameter("@Remark3", SqlDbType.VarChar,255)};
parameters[0].Value = model.StarterId;
parameters[1].Value = model.SoftwareName;
parameters[2].Value = model.VersionNumber;
parameters[3].Value = model.LauncherResources;
parameters[4].Value = model.UpdateResources;
parameters[5].Value = model.Remark1;
parameters[6].Value = model.Remark2;
parameters[7].Value = model.Remark3;
int rows=DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 更新一条数据
/// </summary>
public bool Update(Competition.Mysql.Model.v_starter_version model)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("update v_starter_version set ");
strSql.Append("SoftwareName=@SoftwareName,");
strSql.Append("VersionNumber=@VersionNumber,");
strSql.Append("LauncherResources=@LauncherResources,");
strSql.Append("UpdateResources=@UpdateResources,");
strSql.Append("Remark1=@Remark1,");
strSql.Append("Remark2=@Remark2,");
strSql.Append("Remark3=@Remark3");
strSql.Append(" where StarterId=@StarterId ");
SqlParameter[] parameters = {
new SqlParameter("@SoftwareName", SqlDbType.VarChar,255),
new SqlParameter("@VersionNumber", SqlDbType.VarChar,255),
new SqlParameter("@LauncherResources", SqlDbType.VarChar,2000),
new SqlParameter("@UpdateResources", SqlDbType.VarChar,2000),
new SqlParameter("@Remark1", SqlDbType.VarChar,255),
new SqlParameter("@Remark2", SqlDbType.VarChar,255),
new SqlParameter("@Remark3", SqlDbType.VarChar,255),
new SqlParameter("@StarterId", SqlDbType.VarChar,50)};
parameters[0].Value = model.SoftwareName;
parameters[1].Value = model.VersionNumber;
parameters[2].Value = model.LauncherResources;
parameters[3].Value = model.UpdateResources;
parameters[4].Value = model.Remark1;
parameters[5].Value = model.Remark2;
parameters[6].Value = model.Remark3;
parameters[7].Value = model.StarterId;
int rows=DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 删除一条数据
/// </summary>
public bool Delete(string StarterId)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("delete from v_starter_version ");
strSql.Append(" where StarterId=@StarterId ");
SqlParameter[] parameters = {
new SqlParameter("@StarterId", SqlDbType.VarChar,50) };
parameters[0].Value = StarterId;
int rows=DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 批量删除数据
/// </summary>
public bool DeleteList(string StarterIdlist )
{
StringBuilder strSql=new StringBuilder();
strSql.Append("delete from v_starter_version ");
strSql.Append(" where StarterId in ("+StarterIdlist + ") ");
int rows=DbHelperSQL.ExecuteSql(strSql.ToString());
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 得到一个对象实体
/// </summary>
public Competition.Mysql.Model.v_starter_version GetModel(string StarterId)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select top 1 StarterId,SoftwareName,VersionNumber,LauncherResources,UpdateResources,Remark1,Remark2,Remark3 from v_starter_version ");
strSql.Append(" where StarterId=@StarterId ");
SqlParameter[] parameters = {
new SqlParameter("@StarterId", SqlDbType.VarChar,50) };
parameters[0].Value = StarterId;
Competition.Mysql.Model.v_starter_version model=new Competition.Mysql.Model.v_starter_version();
DataSet ds=DbHelperSQL.Query(strSql.ToString(),parameters);
if(ds.Tables[0].Rows.Count>0)
{
return DataRowToModel(ds.Tables[0].Rows[0]);
}
else
{
return null;
}
}
/// <summary>
/// 得到一个对象实体
/// </summary>
public Competition.Mysql.Model.v_starter_version DataRowToModel(DataRow row)
{
Competition.Mysql.Model.v_starter_version model=new Competition.Mysql.Model.v_starter_version();
if (row != null)
{
if(row["StarterId"]!=null)
{
model.StarterId=row["StarterId"].ToString();
}
if(row["SoftwareName"]!=null)
{
model.SoftwareName=row["SoftwareName"].ToString();
}
if(row["VersionNumber"]!=null)
{
model.VersionNumber=row["VersionNumber"].ToString();
}
if(row["LauncherResources"]!=null)
{
model.LauncherResources=row["LauncherResources"].ToString();
}
if(row["UpdateResources"]!=null)
{
model.UpdateResources=row["UpdateResources"].ToString();
}
if(row["Remark1"]!=null)
{
model.Remark1=row["Remark1"].ToString();
}
if(row["Remark2"]!=null)
{
model.Remark2=row["Remark2"].ToString();
}
if(row["Remark3"]!=null)
{
model.Remark3=row["Remark3"].ToString();
}
}
return model;
}
/// <summary>
/// 获得数据列表
/// </summary>
public DataSet GetList(string strWhere)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select StarterId,SoftwareName,VersionNumber,LauncherResources,UpdateResources,Remark1,Remark2,Remark3 ");
strSql.Append(" FROM v_starter_version ");
if(strWhere.Trim()!="")
{
strSql.Append(" where "+strWhere);
}
return DbHelperSQL.Query(strSql.ToString());
}
/// <summary>
/// 获得前几行数据
/// </summary>
public DataSet GetList(int Top,string strWhere,string filedOrder)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select ");
if(Top>0)
{
strSql.Append(" top "+Top.ToString());
}
strSql.Append(" StarterId,SoftwareName,VersionNumber,LauncherResources,UpdateResources,Remark1,Remark2,Remark3 ");
strSql.Append(" FROM v_starter_version ");
if(strWhere.Trim()!="")
{
strSql.Append(" where "+strWhere);
}
strSql.Append(" order by " + filedOrder);
return DbHelperSQL.Query(strSql.ToString());
}
/// <summary>
/// 获取记录总数
/// </summary>
public int GetRecordCount(string strWhere)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select count(1) FROM v_starter_version ");
if(strWhere.Trim()!="")
{
strSql.Append(" where "+strWhere);
}
object obj = DbHelperSQL.GetSingle(strSql.ToString());
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 分页获取数据列表
/// </summary>
public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("SELECT * FROM ( ");
strSql.Append(" SELECT ROW_NUMBER() OVER (");
if (!string.IsNullOrEmpty(orderby.Trim()))
{
strSql.Append("order by T." + orderby );
}
else
{
strSql.Append("order by T.StarterId desc");
}
strSql.Append(")AS Row, T.* from v_starter_version T ");
if (!string.IsNullOrEmpty(strWhere.Trim()))
{
strSql.Append(" WHERE " + strWhere);
}
strSql.Append(" ) TT");
strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
return DbHelperSQL.Query(strSql.ToString());
}
/*
/// <summary>
/// 分页获取数据列表
/// </summary>
public DataSet GetList(int PageSize,int PageIndex,string strWhere)
{
SqlParameter[] parameters = {
new SqlParameter("@tblName", SqlDbType.VarChar, 255),
new SqlParameter("@fldName", SqlDbType.VarChar, 255),
new SqlParameter("@PageSize", SqlDbType.Int),
new SqlParameter("@PageIndex", SqlDbType.Int),
new SqlParameter("@IsReCount", SqlDbType.Bit),
new SqlParameter("@OrderType", SqlDbType.Bit),
new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
};
parameters[0].Value = "v_starter_version";
parameters[1].Value = "StarterId";
parameters[2].Value = PageSize;
parameters[3].Value = PageIndex;
parameters[4].Value = 0;
parameters[5].Value = 0;
parameters[6].Value = strWhere;
return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
}*/
#endregion BasicMethod
#region ExtensionMethod
#endregion ExtensionMethod
}
}

128
CompetitionAPI/CompetitionAPI/Competition.Mysql/Model/T_BAS_COP_GOODS.cs → CompetitionAPI/CompetitionAPI/Competition.Mysql/Model/T_BAS_GOODS.cs
View File

@ -1,12 +1,12 @@
/** 版本信息模板在安装目录下，可自行修改。
* T_BAS_COP_GOODS.cs
* T_BAS_GOODS.cs
*
* 功 能： N/A
* 类 名： T_BAS_COP_GOODS
* 类 名： T_BAS_GOODS
*
* Ver 变更日期 负责人 变更内容
* ───────────────────────────────────
* V0.01 2024/6/12 16:53:44 N/A 初版
* V0.01 2024/6/12 16:53:51 N/A 初版
*
* Copyright (c) 2012 Maticsoft Corporation. All rights reserved.
*┌──────────────────────────────────┐
@ -18,18 +18,28 @@ using System;
namespace Competition.Mysql.Model
{
/// <summary>
/// T_BAS_COP_GOODS:实体类(属性说明自动提取数据库字段的描述信息)
/// T_BAS_GOODS:实体类(属性说明自动提取数据库字段的描述信息)
/// </summary>
[Serializable]
public partial class T_BAS_COP_GOODS
public partial class T_BAS_GOODS
{
public T_BAS_COP_GOODS()
public T_BAS_GOODS()
{}
#region Model
private string _monitor_id;
private string _goods_code;
private string _code_ts;
private int _goods_type;
private string _lsjm_flag;
private string _standard_name;
private string _common_name;
private bool _enable;
private decimal? _density;
private int? _goods_density_type;
private int? _sign_group;
private decimal? _density_upper_limit;
private decimal? _density_lower_limit;
private int? _goods_measure_type;
private int? _goods_state_type;
private decimal? _state_temperature;
private string _field_char1;
private string _field_char2;
private string _field_char3;
@ -39,14 +49,6 @@ namespace Competition.Mysql.Model
/// <summary>
///
/// </summary>
public string MONITOR_ID
{
set{ _monitor_id=value;}
get{return _monitor_id;}
}
/// <summary>
///
/// </summary>
public string GOODS_CODE
{
set{ _goods_code=value;}
@ -55,6 +57,62 @@ namespace Competition.Mysql.Model
/// <summary>
///
/// </summary>
public string CODE_TS
{
set{ _code_ts=value;}
get{return _code_ts;}
}
/// <summary>
///
/// </summary>
public int GOODS_TYPE
{
set{ _goods_type=value;}
get{return _goods_type;}
}
/// <summary>
///
/// </summary>
public string LSJM_FLAG
{
set{ _lsjm_flag=value;}
get{return _lsjm_flag;}
}
/// <summary>
///
/// </summary>
public string STANDARD_NAME
{
set{ _standard_name=value;}
get{return _standard_name;}
}
/// <summary>
///
/// </summary>
public string COMMON_NAME
{
set{ _common_name=value;}
get{return _common_name;}
}
/// <summary>
///
/// </summary>
public bool ENABLE
{
set{ _enable=value;}
get{return _enable;}
}
/// <summary>
///
/// </summary>
public decimal? DENSITY
{
set{ _density=value;}
get{return _density;}
}
/// <summary>
///
/// </summary>
public int? GOODS_DENSITY_TYPE
{
set{ _goods_density_type=value;}
@ -63,10 +121,42 @@ namespace Competition.Mysql.Model
/// <summary>
///
/// </summary>
public int? SIGN_GROUP
public decimal? DENSITY_UPPER_LIMIT
{
set{ _sign_group=value;}
get{return _sign_group;}
set{ _density_upper_limit=value;}
get{return _density_upper_limit;}
}
/// <summary>
///
/// </summary>
public decimal? DENSITY_LOWER_LIMIT
{
set{ _density_lower_limit=value;}
get{return _density_lower_limit;}
}
/// <summary>
///
/// </summary>
public int? GOODS_MEASURE_TYPE
{
set{ _goods_measure_type=value;}
get{return _goods_measure_type;}
}
/// <summary>
///
/// </summary>
public int? GOODS_STATE_TYPE
{
set{ _goods_state_type=value;}
get{return _goods_state_type;}
}
/// <summary>
///
/// </summary>
public decimal? STATE_TEMPERATURE
{
set{ _state_temperature=value;}
get{return _state_temperature;}
}
/// <summary>
///

141
CompetitionAPI/CompetitionAPI/Competition.Mysql/Model/v_model_version.cs Normal file
View File

@ -0,0 +1,141 @@
/** 版本信息模板在安装目录下，可自行修改。
* v_model_version.cs
*
* 功 能： N/A
* 类 名： v_model_version
*
* Ver 变更日期 负责人 变更内容
* ───────────────────────────────────
* V0.01 2024/6/13 13:55:19 N/A 初版
*
* Copyright (c) 2012 Maticsoft Corporation. All rights reserved.
*┌──────────────────────────────────┐
*│　此技术信息为本公司机密信息，未经本公司书面同意禁止向第三方披露．　│
*│　版权所有：动软卓越（北京）科技有限公司　　　　　　　　　　　　　　│
*└──────────────────────────────────┘
*/
using System;
namespace Competition.Mysql.Model
{
/// <summary>
/// v_model_version:实体类(属性说明自动提取数据库字段的描述信息)
/// </summary>
[Serializable]
public partial class v_model_version
{
public v_model_version()
{}
#region Model
private string _modelid;
private string _monitor_id;
private string _modelname;
private string _versionnumber;
private string _maplongitude;
private string _maplatitude;
private string _trainingsize;
private string _modelresources;
private DateTime _updatetime;
private string _remark1;
private string _remark2;
private string _remark3;
/// <summary>
///
/// </summary>
public string ModelId
{
set{ _modelid=value;}
get{return _modelid;}
}
/// <summary>
///
/// </summary>
public string MONITOR_ID
{
set{ _monitor_id=value;}
get{return _monitor_id;}
}
/// <summary>
///
/// </summary>
public string ModelName
{
set{ _modelname=value;}
get{return _modelname;}
}
/// <summary>
///
/// </summary>
public string VersionNumber
{
set{ _versionnumber=value;}
get{return _versionnumber;}
}
/// <summary>
///
/// </summary>
public string MapLongitude
{
set{ _maplongitude=value;}
get{return _maplongitude;}
}
/// <summary>
///
/// </summary>
public string MapLatitude
{
set{ _maplatitude=value;}
get{return _maplatitude;}
}
/// <summary>
///
/// </summary>
public string TrainingSize
{
set{ _trainingsize=value;}
get{return _trainingsize;}
}
/// <summary>
///
/// </summary>
public string ModelResources
{
set{ _modelresources=value;}
get{return _modelresources;}
}
/// <summary>
///
/// </summary>
public DateTime UpdateTime
{
set{ _updatetime=value;}
get{return _updatetime;}
}
/// <summary>
///
/// </summary>
public string Remark1
{
set{ _remark1=value;}
get{return _remark1;}
}
/// <summary>
///
/// </summary>
public string Remark2
{
set{ _remark2=value;}
get{return _remark2;}
}
/// <summary>
///
/// </summary>
public string Remark3
{
set{ _remark3=value;}
get{return _remark3;}
}
#endregion Model
}
}

105
CompetitionAPI/CompetitionAPI/Competition.Mysql/Model/v_starter_version.cs Normal file
View File

@ -0,0 +1,105 @@
/** 版本信息模板在安装目录下，可自行修改。
* v_starter_version.cs
*
* 功 能： N/A
* 类 名： v_starter_version
*
* Ver 变更日期 负责人 变更内容
* ───────────────────────────────────
* V0.01 2024/6/13 13:55:19 N/A 初版
*
* Copyright (c) 2012 Maticsoft Corporation. All rights reserved.
*┌──────────────────────────────────┐
*│　此技术信息为本公司机密信息，未经本公司书面同意禁止向第三方披露．　│
*│　版权所有：动软卓越（北京）科技有限公司　　　　　　　　　　　　　　│
*└──────────────────────────────────┘
*/
using System;
namespace Competition.Mysql.Model
{
/// <summary>
/// v_starter_version:实体类(属性说明自动提取数据库字段的描述信息)
/// </summary>
[Serializable]
public partial class v_starter_version
{
public v_starter_version()
{}
#region Model
private string _starterid;
private string _softwarename;
private string _versionnumber;
private string _launcherresources;
private string _updateresources;
private string _remark1;
private string _remark2;
private string _remark3;
/// <summary>
///
/// </summary>
public string StarterId
{
set{ _starterid=value;}
get{return _starterid;}
}
/// <summary>
///
/// </summary>
public string SoftwareName
{
set{ _softwarename=value;}
get{return _softwarename;}
}
/// <summary>
///
/// </summary>
public string VersionNumber
{
set{ _versionnumber=value;}
get{return _versionnumber;}
}
/// <summary>
///
/// </summary>
public string LauncherResources
{
set{ _launcherresources=value;}
get{return _launcherresources;}
}
/// <summary>
///
/// </summary>
public string UpdateResources
{
set{ _updateresources=value;}
get{return _updateresources;}
}
/// <summary>
///
/// </summary>
public string Remark1
{
set{ _remark1=value;}
get{return _remark1;}
}
/// <summary>
///
/// </summary>
public string Remark2
{
set{ _remark2=value;}
get{return _remark2;}
}
/// <summary>
///
/// </summary>
public string Remark3
{
set{ _remark3=value;}
get{return _remark3;}
}
#endregion Model
}
}

15
CompetitionAPI/CompetitionAPI/CompetitionAPI/CompetitionAPI.csproj
View File

@ -7,6 +7,13 @@
<DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
</PropertyGroup>
<ItemGroup>
<Compile Remove="wwwroot\Json\**" />
<Content Remove="wwwroot\Json\**" />
<EmbeddedResource Remove="wwwroot\Json\**" />
<None Remove="wwwroot\Json\**" />
</ItemGroup>
<ItemGroup>
<None Remove="Controllers\demo\p3k2d4gz.r22~" />
</ItemGroup>
@ -46,10 +53,6 @@
</None>
</ItemGroup>
<ItemGroup>
<Folder Include="wwwroot\Json\" />
</ItemGroup>
<ItemGroup>
<Content Update="wwwroot\Upload\1.jpg">
<CopyToOutputDirectory>Always</CopyToOutputDirectory>
@ -83,4 +86,8 @@
</Content>
</ItemGroup>
<ItemGroup>
<Folder Include="wwwroot\" />
</ItemGroup>
</Project>

4
CompetitionAPI/CompetitionAPI/CompetitionAPI/CompetitionAPI.csproj.user
View File

@ -2,8 +2,8 @@
<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
<PropertyGroup>
<ActiveDebugProfile>CompetitionAPI</ActiveDebugProfile>
<Controller_SelectedScaffolderID>MvcControllerEmptyScaffolder</Controller_SelectedScaffolderID>
<Controller_SelectedScaffolderCategoryPath>root/Common/MVC/Controller</Controller_SelectedScaffolderCategoryPath>
<Controller_SelectedScaffolderID>ApiControllerEmptyScaffolder</Controller_SelectedScaffolderID>
<Controller_SelectedScaffolderCategoryPath>root/Common/Api</Controller_SelectedScaffolderCategoryPath>
<NameOfLastUsedPublishProfile>F:\项目\禄口机场农电竞赛\web\LKJCpowerSupplyOfficeSimulationSystem\CompetitionAPI\Properties\PublishProfiles\FolderProfile.pubxml</NameOfLastUsedPublishProfile>
</PropertyGroup>
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

11
CompetitionAPI/CompetitionAPI/CompetitionAPI/Controllers/version/EditModelController.cs Normal file
View File

@ -0,0 +1,11 @@
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
namespace CompetitionAPI.Controllers.version
{
[Route("api/[controller]")]
[ApiController]
public class EditModelController : ControllerBase
{
}
}

11
CompetitionAPI/CompetitionAPI/CompetitionAPI/Controllers/version/EditStarterController.cs Normal file
View File

@ -0,0 +1,11 @@
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
namespace CompetitionAPI.Controllers.version
{
[Route("api/[controller]")]
[ApiController]
public class EditStarterController : ControllerBase
{
}
}

11
CompetitionAPI/CompetitionAPI/CompetitionAPI/Controllers/version/GetModelListController.cs Normal file
View File

@ -0,0 +1,11 @@
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
namespace CompetitionAPI.Controllers.version
{
[Route("api/[controller]")]
[ApiController]
public class GetModelListController : ControllerBase
{
}
}

36
CompetitionAPI/CompetitionAPI/CompetitionAPI/Controllers/version/GetStarterListController.cs Normal file
View File

@ -0,0 +1,36 @@
using Competition.Common.Util;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
namespace CompetitionAPI.Controllers.version
{
[Route("api/[controller]")]
[ApiController]
public class GetStarterListController : Controller
{
//Competition.Mysql.BLL.v bll = new Competition.Mysql.BLL.T_BAS_CORPORATION();
//public GetStarterListController()
//{
//}
///// <summary>
///// 获取企业接口
///// </summary>
///// <param name="req"></param>
///// <returns></returns>
//[HttpGet]
//public JsonResult Index()
//{
// //读取配置文件示例
// var mysql = Configuration.GetConnectionString("MySQL").ToString();
// //查询企业表所有数据
// var list = bll.GetModelList("");
// return Json(Tool.GetJsonWithCode(APICode.Success, list));
//}
}
}

129
CompetitionAPI/CompetitionAPI/CompetitionAPI/Controllers/version/UploadController.cs Normal file
View File

@ -0,0 +1,129 @@
using Competition.Common.Util;
using CompetitionAPI.api;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Polly;
namespace CompetitionAPI.Controllers.version
{
[Route("api/[controller]")]
[ApiController]
public class UploadController : Controller
{
private readonly IWebHostEnvironment _webHostEnvironment;
public IConfiguration Configuration { get; }
public UploadController(IWebHostEnvironment webHostEnvironment, IConfiguration configuration)
{
_webHostEnvironment = webHostEnvironment;
Configuration = configuration;
}
/// <summary>
/// 分片上传文件接口
/// </summary>
/// <param name="file">请求参数</param>
/// <returns></returns>
[Authorize]
[HttpPost]
public async Task<JsonResult> RuleUploadFile([FromQuery] SliceFileInfo file)
{
try
{
string path = System.IO.Path.Combine(_webHostEnvironment.WebRootPath, "Upload", file.FolderName);
var files = Request.Form.Files;
var buffer = new byte[file.Size];
var fileName = file.Name.Replace("(", "").Replace(")", "").Replace("（", "").Replace("）", "");
path = path + "//" + fileName + "//";
if (!System.IO.Directory.Exists(path))
{
System.IO.Directory.CreateDirectory(path);
}
string filepath = path + "//" + file.Name.Replace("(", "").Replace(")", "").Replace("（", "").Replace("）", "") + "^" + file.Number;
using (var stream = new FileStream(filepath, FileMode.Append))
{
await files[0].CopyToAsync(stream);
}
var filesList = Directory.GetFiles(Path.GetDirectoryName(path));
//当顺序号等于分片总数量 合并文件
if ((file.Number + 1) == file.Count || filesList.Length == file.Count)
{
await MergeFile(file);
return Json(Tool.GetJsonWithCode(APICode.Success, "/Upload/" + file.FolderName + "/" + file.Name.Replace("(", "").Replace(")", "").Replace("（", "").Replace("）", "") + "/" + fileName.Split("~")[0].ToString()));
}
else
{
return Json(Tool.GetJsonWithCode(APICode.Success, "成功"));
}
}
catch (Exception ex)
{
return Json(Tool.GetJsonWithCode(APICode.Fail, ex.Message));
}
}
/// <summary>
/// 合并文件
/// </summary>
/// <param name="file"></param>
/// <returns></returns>
private async Task MergeFile(SliceFileInfo file)
{
string path = System.IO.Path.Combine(_webHostEnvironment.WebRootPath, "Upload", file.FolderName);
var fileName = file.Name.Replace("(", "").Replace(")", "").Replace("（", "").Replace("）", "");
path = path + "//" + fileName + "//";
string baseFileName = path + fileName.Split("~")[0].ToString();
if (!System.IO.Directory.Exists(path))
{
System.IO.Directory.CreateDirectory(path);
}
var filesList = Directory.GetFiles(Path.GetDirectoryName(path));
if (filesList.Length != file.Count)
{
return;
}
List<FileSort> lstFile = new List<FileSort>();
foreach (var item in filesList)
{
lstFile.Add(new FileSort()
{
Name = item,
NumBer = Convert.ToInt32(item.Substring(item.IndexOf('^') + 1))
});
}
lstFile = lstFile.OrderBy(x => x.NumBer).ToList();
using (var fileStream = new FileStream(baseFileName, FileMode.Create))
{
//foreach (var fileSort in filesList)
//{
// using (FileStream fileChunk = new FileStream(fileSort, FileMode.Open))
// {
// await fileChunk.CopyToAsync(fileStream);
// }
//}
await Policy.Handle<IOException>()
.RetryForeverAsync()
.ExecuteAsync(async () =>
{
foreach (var fileSort in lstFile)
{
using (FileStream fileChunk = new FileStream(fileSort.Name, FileMode.Open))
{
await fileChunk.CopyToAsync(fileStream);
}
}
});
}
//删除分片文件
foreach (var dirfile in filesList)
{
System.IO.File.Delete(dirfile);
}
}
}
}

6
CompetitionAPI/CompetitionAPI/CompetitionAPI/api/version/EditModelRequest.cs Normal file
View File

@ -0,0 +1,6 @@
namespace CompetitionAPI.api.version
{
public class EditModelRequest
{
}
}

6
CompetitionAPI/CompetitionAPI/CompetitionAPI/api/version/EditStarterRequest.cs Normal file
View File

@ -0,0 +1,6 @@
namespace CompetitionAPI.api.version
{
public class EditStarterRequest
{
}
}