using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using Pub_Class;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.IO;
using System.Web;
using System.Web.Http;
using WebAPI.Models;
using WebAPI.Service;
namespace WebAPI.Controllers.基础资料.基础资料
{
public class Gy_CarController : ApiController
{
public DBUtility.ClsPub.Enum_BillStatus BillStatus;
private json objJsonResult = new json();
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
DataSet ds;
///
/// 返回车辆列表
///参数：string sql。
///返回值：object。
///
[Route("Gy_Car/list")]
[HttpGet]
public object list(string sWhere, string user)
{
try
{
List columnNameList = new List();
//判断是否有查询权限
if (!DBUtility.ClsPub.Security_Log("Gy_Car_Query", 1, false, user))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "无权限查询!";
objJsonResult.data = null;
return objJsonResult;
}
if (sWhere == null || sWhere.Equals(""))
{
ds = oCN.RunProcReturn("select * from h_v_Gy_CarList where 1=1 order by 车牌号 ", "h_v_Gy_CarList");
}
else
{
string sql1 = "select * from h_v_Gy_CarList where 1=1 ";
string sql = sql1 + sWhere + " order by 车牌号";
ds = oCN.RunProcReturn(sql, "h_v_Gy_CarList");
}
//添加列名
foreach (DataColumn col in ds.Tables[0].Columns)
{
Type dataType = col.DataType;
string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";
columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名
}
//if (ds.Tables[0].Rows.Count != 0 || ds != null)
//{
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "Sucess！";
objJsonResult.data = ds.Tables[0];
objJsonResult.list = columnNameList;
return objJsonResult;
//}
//else
//{
//objJsonResult.code = "0";
//objJsonResult.count = 0;
//objJsonResult.Message = "无数据";
//objJsonResult.data = null;
//return objJsonResult;
//}
}
catch (Exception e)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "Exception！" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#region 车辆列表-分页
[Route("Gy_Car/list_byPage")]
[HttpGet]
public object GetCarList_byPage(string sWhere, string user, int page, int size)
{
try
{
List columnNameList = new List(); //定义声明变量 ，把通过 new List()创建的 实例，赋值给变量
//判断是否有查询权限
if (!DBUtility.ClsPub.Security_Log("Gy_Car_Query", 1, false, user))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "无权限查询!";
objJsonResult.data = null;
return objJsonResult;
}
if (sWhere == null || sWhere.Equals(""))
{
ds = oCN.RunProcReturn("exec h_p_Gy_CarList " + page + "," + size + "," + "''", "h_p_Gy_CarList");
}
else
{
sWhere = sWhere.Replace("'", "''");
ds = oCN.RunProcReturn("exec h_p_Gy_CarList " + page + "," + size + ",'" + sWhere + "'", "h_p_Gy_CarList");
}
//添加列名
foreach (DataColumn col in ds.Tables[0].Columns)
{
Type dataType = col.DataType;
string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";
columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名
}
if(ds.Tables[0].Rows.Count > 0)
{
objJsonResult.code = "1";
objJsonResult.count = int.Parse(ds.Tables[1].Rows[0]["count"].ToString());
objJsonResult.Message = "Sucess！";
objJsonResult.list = columnNameList;
objJsonResult.data = ds.Tables[0];
return objJsonResult;
}
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "没有返回任何记录！";
objJsonResult.list = columnNameList;
objJsonResult.data = ds.Tables[0];
return objJsonResult;
}
catch (Exception e)
{
oCN.RollBack();
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "失败！" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#endregion
#region 保存 车辆信息
///
/// 保存车辆信息
///
/// lsmain = new List();
msg1 = msg1.Replace("\\", "");
msg1 = msg1.Replace("\n", ""); //\n
lsmain = oListModels.getObjectByJson_Gy_Car2(msg1);
foreach (Model.ClsGy_Car_Model_2 oItem in lsmain)
{
if (oItem.HNumber.Trim() == "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！车牌号不能为空！";
objJsonResult.data = 1;
return objJsonResult;
}
if (oItem.HName.Trim() == "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！车辆名称不能为空！";
objJsonResult.data = 1;
return objJsonResult;
}
//查询数据中是否存在重复代码
ds = oCN.RunProcReturn("select * from Gy_Car where HStopflag=0 and HNumber='" + oItem.HNumber.Trim() + "'", "Gy_Car");
if (oItem.HNumber.Trim() == "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！车牌号为空！";
objJsonResult.data = 1;
return objJsonResult;
}
//新增时判断
if (oItem.HItemID == 0)
{
if (ds == null || ds.Tables[0].Rows.Count == 0)
{
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！车牌号重复！";
objJsonResult.data = 1;
return objJsonResult;
}
//检查父级是否存在
string sParent;
sParent = DBUtility.ClsPub.GetParentCode(oItem.HNumber.Trim());
if (sParent.Trim() == "")
{
oBill.oModel.HParentID = 0;
}
else
{
if (oBill.HavParentCode(sParent.Trim(), HItemID))
{
oBill.oModel.HParentID = oBill.oModel.HItemID;
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！上级代码不存在或被禁用！";
objJsonResult.data = 1;
return objJsonResult;
}
}
}
else//编辑时判断
{
//已审核不允许修改
DataSet dss;
dss = oCN.RunProcReturn("select * from Gy_Car where HItemID=" + oItem.HItemID, "Gy_Car");
//判断是否可编辑
if (dss.Tables[0].Rows[0]["HCheckEmp"].ToString() != "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "此单据状态已经审核，不允许修改！";
objJsonResult.data = null;
return objJsonResult;
}
//检查父级是否存在
string sParent;
sParent = DBUtility.ClsPub.GetParentCode(oItem.HNumber.Trim());
if (sParent.Trim() == "")
{
oBill.oModel.HParentID = 0;
}
else
{
if (oBill.HavParentCode(sParent.Trim(), oItem.HItemID))
{
oBill.oModel.HParentID = oBill.oModel.HItemID;
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！上级代码不存在或被禁用！";
objJsonResult.data = 1;
return objJsonResult;
}
}
}
//得到短代码
string sShortNumber;
sShortNumber = DBUtility.ClsPub.GetShortNumber(oItem.HNumber.Trim());
if (sShortNumber.Trim() == "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！短代码为空！";
objJsonResult.data = 1;
return objJsonResult;
}
oItem.HShortNumber = sShortNumber;//短代码
oItem.HEndFlag = true;//末级标志
oItem.HLevel = DBUtility.ClsPub.GetLevel(oItem.HNumber.Trim()); //等级
oItem.HMakeEmp = msg2;//创建人
oBill.oModel = oItem;
}
//保存
//保存完毕后处理
bool bResult;
if (oBill.oModel.HItemID == 0)
{
bResult = oBill.AddNew(ref DBUtility.ClsPub.sExeReturnInfo);
}
else
{
oBill.oModel.HModifyEmp = msg2;
bResult = oBill.ModifyByID(oBill.oModel.HItemID, ref DBUtility.ClsPub.sExeReturnInfo);
}
if (bResult)
{
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "保存成功！";
objJsonResult.data = 1;
return objJsonResult;
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！" + DBUtility.ClsPub.sExeReturnInfo;
objJsonResult.data = 1;
return objJsonResult;
}
}
catch (Exception e)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败！" + e.ToString();
objJsonResult.data = 1;
return objJsonResult;
}
}
#endregion
#region 车辆审核、反审核
///
///
///
///
///
///
/// columnNameList = new List();
string sql1 = $@"select * from h_v_Gy_CarList where HItemID = {HID}";
ds = oCN.RunProcReturn(sql1, "h_v_Gy_CarList");
//添加列名
foreach (DataColumn col in ds.Tables[0].Columns)
{
Type dataType = col.DataType;
string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";
columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名
}
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "Sucess！";
objJsonResult.data = ds.Tables[0];
objJsonResult.list = columnNameList;
return objJsonResult;
}
catch (Exception e)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "Exception！" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#endregion
#region 车辆文件上传
[Route("Gy_Car/Gy_Car_UploadFile")]
[HttpPost]
public object Gy_Car_UploadFile()
{
string HBillNo = HttpContext.Current.Request.Params["HNumber"]; //车牌号
string HPrefix = HttpContext.Current.Request.Params["HPrefix"]; //目录
string HUserName = HttpContext.Current.Request.Params["HUserName"]; //创建人
HttpPostedFile files = HttpContext.Current.Request.Files["file"];
string path = HttpContext.Current.Server.MapPath("~/../Files/Gy_Car/" + HBillNo + HPrefix );
dynamic dyResult = UpLoadFile(files, path, HBillNo, HPrefix, HUserName);
if (dyResult != null && dyResult.result == 1)
{
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "上传成功！";
objJsonResult.data = null;
return objJsonResult;
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = dyResult.returnval;
objJsonResult.data = null;
return objJsonResult;
}
}
#endregion
public dynamic UpLoadFile(HttpPostedFile files, string path, string HBillNo, string HPrefix, string HUserName)
{
dynamic Result_Ob = new { result = 1, returnval = "上传成功！" };
string filePath = Path.GetFullPath(files.FileName);//文件上传路径
string fileExtension = Path.GetExtension(files.FileName);// 文件扩展名
string filename = files.FileName;//文件名
string fileSavePath = path;// 上传保存路径
int filesize = files.ContentLength;//获取上传文件的大小单位为字节byte
int Maxsize = 40000 * 1024;//定义上传文件的最大空间大小为40M
try
{
if (files == null || files.ContentLength <= 0)
{
Result_Ob = new { result = 0, returnval = "文件不能为空!" };
return Result_Ob;
}
if (filesize >= Maxsize)
{
Result_Ob = new { result = 0, returnval = "上传文件超过40M，不能上传！" };
return Result_Ob;
}
string fileurl = Path.Combine(fileSavePath, filename);
if (Directory.Exists(fileurl) == true) //如果存在重名文件就提示
{
Result_Ob = new { result = 0, returnval = "存在同名文件！" };
return Result_Ob;
}
//删除数据表数据
ds = oCN.RunProcReturn("delete from MES_AccessoriesList where HSourceBillNo ='" + HBillNo + "' and HFileName='" + filename + "'", "MES_AccessoriesList");
if (Directory.Exists(path))
{
File.Delete(fileurl); //删除指定文件
files.SaveAs(fileurl);
string StrPath = "/files/Gy_Car/" + HBillNo + HPrefix +"/" + filename;
if (File.Exists(fileurl))
{
//这里可以执行一些其它的操作，比如更新数据库
//写入数据表
oCN.RunProc("Insert into MES_AccessoriesList (HFileName,HFilePath,HFilePath_Cus,HFileType" +
",HLoadMan,HLoadDate,HRemark,HVerNum,HFileSize" +
",HFileClsID,HSourceBillNo" +
") values('"
+ filename.ToString() + "','" + StrPath.ToString() + "','" + filePath.ToString() + "','" + fileExtension.ToString() + "'" +
",'" + HUserName + "',getdate(),'','V1','" + filesize +
"','" + 0 + "','" + HBillNo +
"') ");
}
else
{
Result_Ob = new { result = 0, returnval = "上传失败！此文件为恶意文件" };
}
}
else
{
Directory.CreateDirectory(fileSavePath); //添加文件夹
files.SaveAs(fileurl);
string StrPath = "/files/Gy_Car/" + HBillNo + HPrefix + "/" + filename;
if (File.Exists(fileurl))
{
//这里可以执行一些其它的操作，比如更新数据库
//写入数据表
oCN.RunProc("Insert into MES_AccessoriesList (HFileName,HFilePath,HFilePath_Cus,HFileType" +
",HLoadMan,HLoadDate,HRemark,HVerNum,HFileSize" +
",HFileClsID,HSourceBillNo" +
") values('"
+ filename.ToString() + "','" + StrPath.ToString() + "','" + filePath.ToString() + "','" + fileExtension.ToString() + "'" +
",'" + HUserName + "',getdate(),'','V1','" + filesize +
"','" + 0 + "','" + HBillNo +
"') ");
}
else
{
Result_Ob = new { result = 0, returnval = "上传失败！此文件为恶意文件" };
}
}
}
catch (Exception e)
{
Result_Ob = new { result = 0, returnval = e.Message };
}
return Result_Ob;
}
}
}