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 Cg_OrderTransportBillListController : ApiController
{
public DBUtility.ClsPub.Enum_BillStatus BillStatus;
private json objJsonResult = new json();
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
DataSet ds;
///
/// 返回运单申请列表
///参数：string sql。
///返回值：object。
///
[Route("Cg_OrderTransportBill/list")]
[HttpGet]
public object list(string sWhere, string user)
{
try
{
List columnNameList = new List();
//判断是否有查询权限
if (!DBUtility.ClsPub.Security_Log("Cg_OrderTransportBill_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_Cg_OrderTransportBillList where 1=1 order by hmainid ", "h_v_Cg_OrderTransportBillList");
}
else
{
string sql1 = "select * from h_v_Cg_OrderTransportBillList where 1=1 ";
string sql = sql1 + sWhere + " order by hmainid";
ds = oCN.RunProcReturn(sql, "h_v_Cg_OrderTransportBillList");
}
//添加列名
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("Cg_OrderTransportBill/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("Cg_OrderTransportBill_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_Cg_OrderTransportBillListPage " + page + "," + size + "," + "''", "h_p_Cg_OrderTransportBillList");
}
else
{
sWhere = sWhere.Replace("'", "''");
ds = oCN.RunProcReturn("exec h_p_Cg_OrderTransportBillListPage " + page + "," + size + ",'" + sWhere + "'", "h_p_Cg_OrderTransportBillList");
}
//添加列名
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_Cg_OrderTransportBill(msg1);
foreach (Model.ClsCg_OrderTransportBill_Model oItem in lsmain)
{
//新增时判断
if (oprType == "1" || oprType == "2")
{
oItem.HMaker = msg2;//创建人
}
else if(oprType == "3")//编辑时判断
{
//已审核不允许修改
DataSet dss;
dss = oCN.RunProcReturn("select * from Cg_OrderTransportBill where HItemID=" + oItem.HItemID, "Cg_OrderTransportBill");
//判断是否可编辑
if (dss.Tables[0].Rows[0]["HChecker"].ToString() != "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "此单据状态已经审核，不允许修改！";
objJsonResult.data = null;
return objJsonResult;
}
}
oBill.oModel = oItem;
}
//保存
//保存完毕后处理
bool bResult;
if (oprType == "1" || oprType == "2")
{
bResult = oBill.AddBill(ref DBUtility.ClsPub.sExeReturnInfo);
}
else if(oprType == "3")
{
oBill.oModel.HModifyEmp = msg2;
bResult = oBill.ModifyBill(oBill.oModel.HItemID, ref DBUtility.ClsPub.sExeReturnInfo);
}
else
{
throw new Exception("该单据为浏览状态，不可保存");
}
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_Cg_OrderTransportBillList where HItemID = {HID}";
ds = oCN.RunProcReturn(sql1, "h_v_Cg_OrderTransportBillList");
//添加列名
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("Cg_OrderTransportBill/Cg_OrderTransportBill_UploadFile")]
[HttpPost]
public object Cg_OrderTransportBill_UploadFile()
{
string HBillNo = HttpContext.Current.Request.Params["HBillNo"]; //车牌号
string HUserName = HttpContext.Current.Request.Params["HUserName"]; //创建人
HttpPostedFile files = HttpContext.Current.Request.Files["file"];
string path = HttpContext.Current.Server.MapPath("~/../Files/Cg_OrderTransportBill/" + HBillNo);
dynamic dyResult = UpLoadFile(files, path, HBillNo, 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 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/Cg_OrderTransportBill/" + HBillNo + "/" + 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/Cg_OrderTransportBill/" + HBillNo + "/" + 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;
}
}
}