using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.SqlClient;
|
using System.Linq;
|
using System.Net;
|
using System.Net.Http;
|
using System.Text.RegularExpressions;
|
using System.Web;
|
using System.Web.Http;
|
using WebAPI.Code;
|
using WebAPI.Models;
|
using WebAPI.Utility;
|
namespace WebAPI.Controllers
|
{
|
public class MaterialHandingController : ApiController
|
{
|
// GET: MaterialHanding
|
private JsonResult objJsonResult = new JsonResult();
|
private json objjson = new json();
|
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
|
DataSet ds;
|
//获取系统参数
|
Pub_Class.ClsXt_SystemParameter oSystemParameter = new Pub_Class.ClsXt_SystemParameter();
|
[Route("MaterialHandingController/GetMaterialHandingList")]
|
[HttpGet]
|
public object GetMaterialHandingList(string sWhere, string user)
|
{
|
List<object> columnNameList = new List<object>();
|
try
|
{
|
string VsWhere = sWhere;
|
SQLHelper.ClsCN oCn = new SQLHelper.ClsCN();
|
DataSet ds;
|
//其他过滤
|
//string sql = " where 1 = 1 " + sqlWhere;
|
////转换特殊字符
|
//if (Common.SQLtoChange(sql, ref VsWhere, ref PcWhere) == false)
|
//{
|
// objjson.code = "0";
|
// objjson.count = 0;
|
// objjson.Message = "转换特殊字符失败";
|
// objjson.data = null;
|
// return objjson;
|
//}
|
|
//获取返回数据
|
ds = oCn.RunProcReturn("select * from h_v_Gy_UserMaterRelation where 1=1 " + sWhere, "h_v_Gy_UserMaterRelation");
|
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 == null || ds.Tables[0].Rows.Count == 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败,没有相关数据";
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 10000;
|
objjson.Message = "获取成功";
|
objjson.data = ds.Tables[0];
|
objjson.list = columnNameList;
|
return objjson;
|
}
|
}
|
catch (Exception e)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + e.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
}
|
|
#region 启用
|
|
[Route("MaterialHandingController/OpenMaterial")]
|
[HttpGet]
|
public object OpenMaterial(int HInterID, int IsUse, string CurUserName)
|
{
|
try
|
{
|
|
var ds = oCN.RunProcReturn("select * from Gy_UserMaterRelation where HItemID=" + HInterID, "Gy_UserMaterRelation");
|
if (ds.Tables[0].Rows.Count > 0)
|
{
|
IsUse = Convert.ToInt32(ds.Tables[0].Rows[0]["HUseFlag"]) ;
|
if (IsUse == 1) //判断
|
{
|
if (ds.Tables[0].Rows[0]["HUpDater"].ToString() != "")
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "单据已启用!不能再次启用！";
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
}
|
else
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "单据不存在!";
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
|
oCN.BeginTran();
|
|
if (IsUse == 0) //启用判断
|
{
|
|
//禁用前控制=========================================
|
string sql1 = "exec h_p_Gy_MaterPrice_BeforeStopCtrl " + HInterID + ",'" + CurUserName + "'";
|
ds = oCN.RunProcReturn(sql1, "h_p_Gy_MaterPrice_BeforeStopCtrl");
|
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "禁用失败!原因:禁用前判断失败，请与网络管理人员联系";
|
objJsonResult.data = null;
|
oCN.RollBack();
|
return objJsonResult;
|
}
|
|
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
|
objJsonResult.data = null;
|
oCN.RollBack();
|
return objJsonResult;
|
}
|
//==================================================================================
|
|
|
oCN.RunProc("update Gy_UserMaterRelation set HUpDater='" + CurUserName + "',HUpDateDate=getdate(),HUseFlag=1 where HItemID=" + HInterID);
|
|
|
//禁用后控制=========================================
|
string sql2 = "exec h_p_Gy_MaterPrice_AfterStopCtrl " + HInterID + ",'" + CurUserName + "'";
|
ds = oCN.RunProcReturn(sql2, "h_p_Gy_MaterPrice_AfterStopCtrl");
|
if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "禁用失败!原因:禁用后判断失败，请与网络管理人员联系";
|
objJsonResult.data = null;
|
oCN.RollBack();
|
return objJsonResult;
|
}
|
|
if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
|
objJsonResult.data = null;
|
oCN.RollBack();
|
return objJsonResult;
|
}
|
//==================================================================================
|
|
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "启用成功";
|
objJsonResult.data = null;
|
}
|
//if (IsStop == 1) //反禁用判断
|
//{
|
// //反禁用前控制=========================================
|
// string sql1 = "exec h_p_Gy_Gy_MaterPrice_BeforeUnStopCtrl " + HInterID + ",'" + CurUserName + "'";
|
// ds = oCN.RunProcReturn(sql1, "h_p_Gy_Gy_MaterPrice_BeforeUnStopCtrl");
|
// if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
|
// {
|
// objJsonResult.code = "0";
|
// objJsonResult.count = 1;
|
// objJsonResult.Message = "反禁用失败!原因:反禁用前判断失败，请与网络管理人员联系";
|
// objJsonResult.data = null;
|
// oCN.RollBack();
|
// return objJsonResult;
|
// }
|
|
// if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
|
// {
|
// objJsonResult.code = "0";
|
// objJsonResult.count = 1;
|
// objJsonResult.Message = "反禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
|
// objJsonResult.data = null;
|
// oCN.RollBack();
|
// return objJsonResult;
|
// }
|
// //==================================================================================
|
|
|
// oCN.RunProc("update Gy_MaterPrice set HStopEmp='',HStopTime=null,HStopflag=0 where HItemID=" + HInterID);
|
|
|
// //反禁用后控制=========================================
|
// string sql2 = "exec h_p_Gy_MaterPrice_AfterUnStopCtrl " + HInterID + ",'" + CurUserName + "'";
|
// ds = oCN.RunProcReturn(sql2, "h_p_Gy_MaterPrice_AfterUnStopCtrl");
|
// if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
|
// {
|
// objJsonResult.code = "0";
|
// objJsonResult.count = 1;
|
// objJsonResult.Message = "反禁用失败!原因:反禁用后判断失败，请与网络管理人员联系";
|
// objJsonResult.data = null;
|
// oCN.RollBack();
|
// return objJsonResult;
|
// }
|
|
// if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
|
// {
|
// objJsonResult.code = "0";
|
// objJsonResult.count = 1;
|
// objJsonResult.Message = "反禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
|
// objJsonResult.data = null;
|
// oCN.RollBack();
|
// return objJsonResult;
|
// }
|
// //==================================================================================
|
|
// objJsonResult.code = "1";
|
// objJsonResult.count = 1;
|
// objJsonResult.Message = "反禁用成功";
|
// objJsonResult.data = null;
|
//}
|
oCN.Commit();
|
|
return objJsonResult;
|
}
|
catch (Exception e)
|
{
|
oCN.RollBack();
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "启用失败或者反禁用失败！" + e.ToString();
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
#endregion
|
|
#region 物料校验
|
[Route("MaterialHandingController/CheckMaterial")]
|
[HttpGet]
|
public object CheckMaterial(string HMaterID, string user, int param,string OrganizationID)
|
{
|
try
|
{
|
//ds1获取的sql后期记得改回供应商，修改人->供应商
|
var ds1 = oCN.RunProcReturn("select * from h_v_Gy_UserMaterRelationEdit where 物料代码='" + HMaterID + "'" + "and 修改人='" + user + "'", "h_v_Gy_UserMaterRelationEdit");
|
var ds = oCN.RunProcReturn("select * from Gy_Material where HNumber='" + HMaterID+ "'"+ " and HUSEORGID="+"'"+ OrganizationID+"'", "Gy_Material");
|
if(ds.Tables[0].Rows.Count == 0)
|
{
|
return 2;
|
}
|
if (param == 0)
|
{
|
if (ds1.Tables[0].Rows.Count > 0)//物料重复，弹出询问
|
{
|
return 1;
|
|
}
|
else
|
{
|
return GetMaterialResult(ds);
|
}
|
}
|
else
|
{
|
oCN.BeginTran();
|
string sqlUpd = "UPDATE Gy_UserMaterRelation set HUseFlag=0 where HMaterID="+ ds.Tables[0].Rows[0]["HItemID"];
|
oCN.RunProc(sqlUpd);
|
oCN.Commit();
|
|
return GetMaterialResult(ds);
|
}
|
}
|
catch (Exception e)
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "Exception！" + e.ToString();
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
|
private object GetMaterialResult(DataSet ds)
|
{
|
if (ds.Tables[0].Rows.Count > 0)
|
{
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "Success！";
|
objJsonResult.data = ds.Tables[0];
|
return objJsonResult;
|
}
|
else
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "物料不存在！";
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
#endregion
|
|
#region 编辑查看信息
|
[Route("MaterialHandingController/Edit_M")]
|
[HttpGet]
|
public object Edit_M(string HItemID, string user)
|
{
|
try
|
{
|
List<object> columnNameList = new List<object>();
|
string sql1 = string.Format(@"select * from h_v_Gy_UserMaterRelationEdit where HItemID = " + HItemID);
|
|
ds = oCN.RunProcReturn(sql1, "h_v_Gy_UserMaterRelationEdit");
|
|
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "Sucess！";
|
objJsonResult.data = ds.Tables[0];
|
return objJsonResult;
|
}
|
catch (Exception e)
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "Exception！" + e.ToString();
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
#endregion
|
|
#region 新增保存
|
[Route("MaterialHandingController/AddBill")]
|
[HttpPost]
|
public object AddBill([FromBody] JObject msg)
|
{
|
try
|
{
|
var _value = msg["msg"].ToString();
|
string msg3 = _value.ToString();
|
//string[] sArray = msg3.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries);
|
//string msg1 = sArray[0].ToString();
|
//string msg2 = sArray[1].ToString();
|
string msg2 = msg3.ToString();
|
|
//反序列化
|
msg2 = "[" + msg2.ToString() + "]";
|
|
List<Model.Cls_MaterialHandingModel> list = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.Cls_MaterialHandingModel>>(msg2);
|
|
var ds = oCN.RunProcReturn("select * from Gy_Material where HNumber='" + list[0].HMaterNumber + "'", "Gy_Material");
|
|
int HItemID =Convert.ToInt32(list[0].HItemID);
|
string HMaterNumber = list[0].HMaterNumber;
|
int HMaterID =Convert.ToInt32(ds.Tables[0].Rows[0]["HItemID"]);
|
int HSupID = list[0].HSupID;
|
string HUserID = list[0].HUserID;
|
decimal HMinPackQty = list[0].HMinPackQty;
|
decimal HInBoxPackQty = list[0].HInBoxPackQty;
|
decimal HOutBoxPackQty = list[0].HOutBoxPackQty;
|
int HUSEORGID = list[0].HUSEORGID;
|
bool HUseFlag = list[0].HUseFlag;
|
string HMaker = list[0].HMaker!=""? list[0].HMaker :"";
|
string HMakeTime = list[0].HMakeTime;
|
string HUpDater = list[0].HUpDater != "" ? list[0].HUpDater : "";
|
string HUpDateDate = list[0].HUpDateDate;
|
string HCheckEmp = list[0].HCheckEmp != "" ? list[0].HCheckEmp : "";
|
string HCheckTime = list[0].HCheckTime;
|
|
oCN.BeginTran();
|
|
#region 参数化
|
// 构建参数化 SQL 语句
|
string sql = @"INSERT INTO Gy_UserMaterRelation
|
(HMaterID, HSupID, HMinPackQty, HInBoxPackQty, HOutBoxPackQty, HUSEORGID, HUseFlag,
|
HMaker, HMakeTime, HUpDater, HUpDateDate, HCheckEmp, HCheckTime)
|
VALUES(@HMaterID, @HSupID, @HMinPackQty, @HInBoxPackQty, @HOutBoxPackQty, @HUSEORGID, @HUseFlag,
|
@HMaker, @HMakeTime, @HUpDater, @HUpDateDate, @HCheckEmp, @HCheckTime)";
|
|
// 使用 MakeInParam 方法创建参数
|
SqlParameter[] parameters = {
|
oCN.MakeInParam("@HMaterID", SqlDbType.Int, 4, HMaterID),
|
oCN.MakeInParam("@HSupID", SqlDbType.Int, 4, HSupID),
|
//oCN.MakeInParam("@HUserID", SqlDbType.NVarChar, 50, HUserID),
|
oCN.MakeInParam("@HMinPackQty", SqlDbType.Decimal, 8, HMinPackQty),
|
oCN.MakeInParam("@HInBoxPackQty", SqlDbType.Decimal, 8, HInBoxPackQty),
|
oCN.MakeInParam("@HOutBoxPackQty", SqlDbType.Decimal, 8, HOutBoxPackQty),
|
oCN.MakeInParam("@HUSEORGID", SqlDbType.Int, 4, HUSEORGID),
|
oCN.MakeInParam("@HUseFlag", SqlDbType.Bit, 1, HUseFlag),
|
oCN.MakeInParam("@HMaker", SqlDbType.NVarChar, 50, (object)HMaker ?? DBNull.Value),
|
oCN.MakeInParam("@HMakeTime", SqlDbType.NVarChar, 50, (object)HMakeTime ?? DBNull.Value),
|
oCN.MakeInParam("@HUpDater", SqlDbType.NVarChar, 50, (object)HUpDater ?? DBNull.Value),
|
oCN.MakeInParam("@HUpDateDate", SqlDbType.NVarChar, 50, (object)HUpDateDate ?? DBNull.Value),
|
oCN.MakeInParam("@HCheckEmp", SqlDbType.NVarChar, 50, (object)HCheckEmp ?? DBNull.Value),
|
oCN.MakeInParam("@HCheckTime", SqlDbType.NVarChar, 50, (object)HCheckTime ?? DBNull.Value)
|
|
};
|
|
DataSet result = oCN.RunProcReturn(sql, parameters, "Gy_UserMaterRelation");
|
#endregion
|
|
|
oCN.Commit();
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "新增成功！";
|
//objJsonResult.data = null;
|
return objJsonResult;
|
}
|
catch (Exception e)
|
{
|
LogService.Write("送货物料信息保存异常：" + e.Message);
|
oCN.RollBack();
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "Exception！" + e.Message;
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
#endregion
|
|
#region 编辑保存
|
[Route("MaterialHandingController/EditSaveBill")]
|
[HttpPost]
|
public object EditSaveBill([FromBody] JObject msg)
|
{
|
try
|
{
|
var _value = msg["msg"].ToString();
|
string msg3 = _value.ToString();
|
string msg2 = msg3.ToString();
|
|
oCN.BeginTran();
|
//反序列化
|
msg2 = "[" + msg2.ToString() + "]";
|
|
List<Model.Cls_MaterialHandingModel> list = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.Cls_MaterialHandingModel>>(msg2);
|
|
|
int HItemID = Convert.ToInt32(list[0].HItemID);
|
int HMaterID = Convert.ToInt32(list[0].HMaterNumber);
|
int HSupID = list[0].HSupID;
|
//string HUserID = list[0].HUserID;
|
decimal HMinPackQty = list[0].HMinPackQty;
|
decimal HInBoxPackQty = list[0].HInBoxPackQty;
|
decimal HOutBoxPackQty = list[0].HOutBoxPackQty;
|
int HUSEORGID = list[0].HUSEORGID;
|
bool HUseFlag = list[0].HUseFlag;
|
string HMaker = list[0].HMaker != "" ? list[0].HMaker : "";
|
string HMakeTime = list[0].HMakeTime;
|
string HUpDater = list[0].HUpDater != "" ? list[0].HUpDater : "";
|
string HUpDateDate = list[0].HUpDateDate;
|
string HCheckEmp = list[0].HCheckEmp != "" ? list[0].HCheckEmp : "";
|
string HCheckTime = list[0].HCheckTime;
|
|
|
|
#region
|
//主表
|
string sql = @"UPDATE Gy_UserMaterRelation SET
|
HMaterID = @HMaterID,
|
HSupID = @HSupID,
|
HMinPackQty = @HMinPackQty,
|
HInBoxPackQty = @HInBoxPackQty,
|
HUSEORGID = @HUSEORGID,
|
HUseFlag = @HUseFlag,
|
HMaker = @HMaker,
|
HMakeTime = @HMakeTime,
|
HUpDater = @HUpDater,
|
HUpDateDate = @HUpDateDate,
|
HCheckEmp = @HCheckEmp,
|
HCheckTime = @HCheckTime
|
WHERE HItemID = @HItemID";
|
|
SqlParameter[] parameters = {
|
oCN.MakeInParam("@HItemID", SqlDbType.Int, 4, HItemID),
|
oCN.MakeInParam("@HMaterID", SqlDbType.Int, 4, HMaterID),
|
oCN.MakeInParam("@HSupID", SqlDbType.Int, 4, HSupID),
|
//oCN.MakeInParam("@HUserID", SqlDbType.NVarChar, 50, HUserID),
|
oCN.MakeInParam("@HMinPackQty", SqlDbType.Decimal, 8, HMinPackQty),
|
oCN.MakeInParam("@HInBoxPackQty", SqlDbType.Decimal, 8, HInBoxPackQty),
|
oCN.MakeInParam("@HOutBoxPackQty", SqlDbType.Decimal, 8, HOutBoxPackQty),
|
oCN.MakeInParam("@HUSEORGID", SqlDbType.Int, 4, HUSEORGID),
|
oCN.MakeInParam("@HUseFlag", SqlDbType.Bit, 1, HUseFlag),
|
oCN.MakeInParam("@HMaker", SqlDbType.NVarChar, 50, (object)HMaker ?? DBNull.Value),
|
oCN.MakeInParam("@HMakeTime", SqlDbType.NVarChar, 50, (object)HMakeTime ?? DBNull.Value),
|
oCN.MakeInParam("@HUpDater", SqlDbType.NVarChar, 50, (object)HUpDater ?? DBNull.Value),
|
oCN.MakeInParam("@HUpDateDate", SqlDbType.NVarChar, 50, (object)HUpDateDate ?? DBNull.Value),
|
oCN.MakeInParam("@HCheckEmp", SqlDbType.NVarChar, 50, (object)HCheckEmp ?? DBNull.Value),
|
oCN.MakeInParam("@HCheckTime", SqlDbType.NVarChar, 50, (object)HCheckTime ?? DBNull.Value),
|
};
|
|
// 使用 RunProcReturn 执行参数化UPDATE查询，忽略返回的 DataSet
|
DataSet result = oCN.RunProcReturn(sql, parameters, "Gy_UserMaterRelation");
|
#endregion
|
|
oCN.Commit();
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "更新成功！";
|
return objJsonResult;
|
|
}
|
catch (Exception e)
|
{
|
oCN.RollBack();
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "Exception！" + e.Message;
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
}
|
#endregion
|
|
//#region 供应商报价单 删除
|
[Route("MaterialHandingController/DelBill")]
|
[HttpGet]
|
public object DelBill(string HItemID, string user)
|
{
|
|
try
|
{
|
if (HItemID == null || HItemID.Equals(""))
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "HInterID不能为空！";
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
|
oCN.BeginTran();
|
|
// oCN.RunProc("delete from Gy_UserMaterRelation where HInterID = " + HItemID);
|
oCN.RunProc("delete from Gy_UserMaterRelation where HItemID='" + HItemID + "'");
|
|
oCN.Commit();
|
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "Sucess！";
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
catch (Exception e)
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "Exception！" + e.ToString();
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
|
|
|
|
|
}
|
//#endregion
|
|
|
}
|
}
|
