using Model;
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.Web.Http;
using WebAPI.Controllers.SCGL.日计划管理;
using WebAPI.Models;
namespace WebAPI.Controllers
{
public class Gy_WarehouseController : ApiController
{
//获取系统参数
Pub_Class.ClsXt_SystemParameter oSystemParameter = new Pub_Class.ClsXt_SystemParameter();
public DBUtility.ClsPub.Enum_BillStatus BillStatus;
private json objJsonResult = new json();
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
DataSet ds;
///
/// 返回仓库列表
///参数:string sql。
///返回值:object。
///
[Route("Gy_Warehouse/list")]
[HttpGet]
public object list(string sWhere,string user,string Organization)
{
try
{
List columnNameList = new List();
//编辑权限
if (!DBUtility.ClsPub.Security_Log_second("Gy_Warehouse", 1, false, user))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "无查看权限!";
objJsonResult.data = null;
return objJsonResult;
}
string sql1 = string.Format(@"select * from h_v_IF_WareHouseList where 组织名称='" + Organization + "'");
if (sWhere == null || sWhere.Equals(""))
{
ds = oCN.RunProcReturn(sql1 + sWhere + " order by 仓库代码 ", "h_v_IF_WareHouseList");
}
else
{
string sql = sql1 + sWhere + " order by 仓库代码 ";
ds = oCN.RunProcReturn(sql, "h_v_IF_WareHouseList");
}
//添加列名
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;
}
}
///
/// 根据基础资料ID 查找记录
///参数:string sql。
///返回值:object。
///
[Route("Gy_Warehouse/cx")]
[HttpGet]
public object cx(long HInterID)
{
try
{
ds = oCN.RunProcReturn("select * from h_v_IF_WareHouseListDetail where HitemID=" + HInterID, "h_v_IF_WareHouseListtDetail");
if (ds == null || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "false!";
objJsonResult.data = null;
return objJsonResult;
}
else
{
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;
}
}
///
/// 返回仓位列表
///参数:string sql。
///返回值:object。
///
[Route("Gy_StockPlace/list1")]
[HttpGet]
public object list1(string sWhere)
{
try
{
if (sWhere == null || sWhere.Equals(""))
{
ds = oCN.RunProcReturn("select * from h_v_IF_StockPlaceList where 1=1" , "h_v_IF_StockPlaceList");
}
else
{
string sql1 = "select * from h_v_IF_StockPlaceList where 1 = 1 ";
string sql = sql1 + sWhere;
ds = oCN.RunProcReturn(sql, "h_v_IF_StockPlaceList");
}
if (ds == null || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "false!";
objJsonResult.data = null;
return objJsonResult;
}
else
{
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;
}
}
[Route("Gy_StockPlace/LoadTree")]
[HttpGet]
public object LoadTree_Json(string sWhere)
{
SQLHelper.ClsCN SubCn = new SQLHelper.ClsCN();
//ds = oCN.RunProcReturn("select * from h_v_IF_GroupList " + sWhere, "h_v_IF_GroupList");
ds = oCN.RunProcReturn("select * from h_v_StockPlaceLoadTree", "h_v_StockPlaceLoadTree");
if (ds == null || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "false!";
objJsonResult.data = null;
return objJsonResult;
}
else
{
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "Sucess!";
objJsonResult.data = ds.Tables[0];
return objJsonResult;
}
}
///
/// 新增单据-保存按钮
///参数:string sql。
///返回值:object。
///
[Route("Gy_Warehouse/AddNew")]
[HttpPost]
public object AddNew([FromBody] JObject oMain)
{
try
{
var _value = oMain["oMain"].ToString();
string msg1 = _value.ToString();
//反序列化
msg1 = "[" + msg1.ToString() + "]";
DAL.ClsGy_Warehouse_Ctl oDept = new DAL.ClsGy_Warehouse_Ctl();
DAL.ClsGy_Warehouse_View oDeptHlp = new DAL.ClsGy_Warehouse_View();
List list = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg1);
long HItemID = list[0].HItemID;
string HNumber = list[0].HNumber;
string HName = list[0].HName;
string HHelpCode = list[0].HHelpCode;
string HShortNumber = list[0].HShortNumber;
long HParentID = list[0].HParentID;
long HLevel = list[0].HLevel;
bool HEndFlag = list[0].HEndFlag;
bool HStopflag = list[0].HStopFlag;
string HRemark = list[0].HRemark;
string HBarCode = list[0].HBarCode;
long HEmpID = list[0].HEmpID;
string HAddress = list[0].HAddress;
string HPhone = list[0].HPhone;
long HUSEORGID = list[0].HUSEORGID;
string HMaker = list[0].HMaker;
if (!DBUtility.ClsPub.AllowNumber(HNumber))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "代码中不能出现连续‘.’并且首位末位不能为‘.’!";
objJsonResult.data = null;
return objJsonResult;
}
//若MAINDI重复则重新获取
oCN.BeginTran();
//主表
oCN.RunProc("Insert Into Gy_Warehouse " +
"(HNumber,HName,HHelpCode,HShortNumber,HParentID" +
",HLevel,HEndFlag,HStopFlag,HRemark,HBarCode" +
",HEmpID,HAddress,HPhone,HUSEORGID,HMaker" +
") " +
" values('" + HNumber + "','" + HName + "','" + HHelpCode + "','" + HShortNumber + "'," + HParentID.ToString() +
"," + HLevel.ToString() + "," + Convert.ToString(HEndFlag ? 1 : 0) + "," + Convert.ToString(HStopflag ? 1 : 0) + ",'" + HRemark + "','" + HBarCode + "'" +
"," + HEmpID.ToString() + ",'" + HAddress + "','" + HPhone + "'," + HUSEORGID.ToString() + ",'" + HMaker + "'" +
") ");
//修改上级为非末级代码
oCN.RunProc("Update Gy_Warehouse set HEndflag=0 where HItemID=" + HParentID, ref DBUtility.ClsPub.sExeReturnInfo);
oCN.Commit();
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "新增单据成功!";
//objJsonResult.data = null;
return objJsonResult;
}
catch (Exception e)
{
oCN.RollBack();
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "Exception!" + e.Message;
objJsonResult.data = null;
return objJsonResult;
}
}
///
/// 保存按钮
///参数:string sql。
///返回值:object。
///
[Route("Gy_Warehouse/ModifyByID")]
[HttpPost]
public object ModifyByID([FromBody] JObject oMain)
{
try
{
DAL.ClsGy_Warehouse_Ctl oDept = new DAL.ClsGy_Warehouse_Ctl();
DAL.ClsGy_Warehouse_View oDeptHlp = new DAL.ClsGy_Warehouse_View();
var _value = oMain["oMain"].ToString();
string msg1 = _value.ToString();
string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries);
string msg2 = sArray[0].ToString();
string msg3 = sArray[1].ToString();
////判断权限
if (!ClsPub.Security_Log("Gy_Warehouse_Edit", 1, false, msg3))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "没有找到该功能模块!";
objJsonResult.data = null;
return objJsonResult;
}
//反序列化
msg2 = "[" + msg2.ToString() + "]";
List list = Newtonsoft.Json.JsonConvert.DeserializeObject>(msg2);
long HItemID = list[0].HItemID;
string HNumber = list[0].HNumber;
string HName = list[0].HName;
string HHelpCode = list[0].HHelpCode;
bool HStopflag = list[0].HStopFlag;
string HRemark = list[0].HRemark;
string HBarCode = list[0].HBarCode;
long HEmpID = list[0].HEmpID;
string HAddress = list[0].HAddress;
string HPhone = list[0].HPhone;
long HUSEORGID = list[0].HUSEORGID;
//long HCREATEORGID = list[0].HCREATEORGID;
string HUpDater = list[0].HUpDater;
long HSPFlag = list[0].HSPFlag;
//得到短代码
string HShortNumber = DBUtility.ClsPub.GetShortNumber(HNumber);
if (HShortNumber.Trim() == "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败!短代码为空!";
objJsonResult.data = 1;
return objJsonResult;
}
//等级
int HLevel = DBUtility.ClsPub.GetLevel(HNumber);
//检查父级是否存在
long HParentID = 0;
string sParent = DBUtility.ClsPub.GetParentCode(HNumber);
if (sParent.Trim() == "")
{
HParentID = 0;
}
else
{
ds = oCN.RunProcReturn("select * from Gy_Warehouse where HNumber='" + sParent + "' and HStopFlag=0 ", "Gy_Warehouse");
if (ds.Tables[0].Rows.Count>0)
{
HParentID =long.Parse(ds.Tables[0].Rows[0]["HItemID"].ToString());
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败!上级代码不存在或被禁用!";
objJsonResult.data = 1;
return objJsonResult;
}
}
//末级标志
int HEndFlag = 1;
//if (!DBUtility.ClsPub.AllowNumber(HNumber))
//{
// objJsonResult.code = "0";
// objJsonResult.count = 0;
// objJsonResult.Message = "代码中不能出现连续‘.’并且首位末位不能为‘.’!";
// objJsonResult.data = null;
// return objJsonResult;
//}
//if (oDept.HavSameNumber(HItemID, HNumber))
//{
// objJsonResult.code = "0";
// objJsonResult.count = 0;
// objJsonResult.Message = "代码重复!";
// objJsonResult.data = null;
// return objJsonResult;
//}
//保存
//保存完毕后处理
if (HItemID == 0)
{
oCN.BeginTran();
oCN.RunProc("Insert into Gy_Warehouse " +
" (HNumber,HName,HHelpCode,HShortNumber,HParentID" +
",HLevel,HEndFlag,HStopflag,HRemark,HEmpID,HAddress,HPhone,HUSEORGID,HSPFlag,HCREATEORGID,HMaker,HMakeTime) " +
" Values('" + HNumber + "','" + HName + "','" + HHelpCode + "','" + HShortNumber + "'," + HParentID.ToString() +
"," + HLevel.ToString() + "," + HEndFlag + "," + Convert.ToString(HStopflag ? 1 : 0) + ",'" + HRemark + "'," + HEmpID.ToString() + ",'" + HAddress + "','" + HPhone + "','"+ HUSEORGID + "',"+ HSPFlag + ","+ HUSEORGID + ",'"+msg3+"',getdate())", ref DBUtility.ClsPub.sExeReturnInfo);
//修改上级为非末级代码
oCN.RunProc("Update Gy_Warehouse set HEndflag=0 where HItemID=" + HParentID, ref DBUtility.ClsPub.sExeReturnInfo);
//启用仓位
if (HSPFlag == 1)
{
//回填 HSPGroupID
oCN.RunProc("Update Gy_Warehouse set HSPGroupID=HItemID where HNumber='" + HNumber + "' and HName='" + HName + "' ", ref DBUtility.ClsPub.sExeReturnInfo);
}
oCN.Commit();
}
else {
//若MAINDI重复则重新获取
oCN.BeginTran();
//主表
oCN.RunProc("Update Gy_Warehouse set " +
" HNumber='" + HNumber + "'" +
",HName='" + HName + "'" +
",HShortNumber='" + HShortNumber + "'" +
",HHelpCode='" + HHelpCode + "'" +
",HLevel=" + HLevel.ToString() +
",HParentID=" + HParentID.ToString() +
",HStopflag=" + Convert.ToString(HStopflag ? 1 : 0) +
",HEmpID=" + HEmpID.ToString() +
",HAddress='" + HAddress + "'" +
",HPhone='" + HPhone + "'" +
",HUSEORGID='" + HUSEORGID + "'" +
",HCREATEORGID='" + HUSEORGID + "'" +
",HSPFlag='" + HSPFlag + "'" +
//",HSPGroupID='" + HSPGroupID + "'" +
",HUpdater='" + HUpDater + "'" +
",HUpdateDate= getdate()" +
",HRemark= '" + HRemark + "' Where HItemID=" + HItemID, ref DBUtility.ClsPub.sExeReturnInfo);
//修改子项目代码
//oCN.RunProc("exec h_p_Gy_UpdateNumber Gy_Warehouse,'" + HNumber + ".','" + this.HOldNumber + ".'", ref DBUtility.ClsPub.sExeReturnInfo);
//将上级 为非末级
oCN.RunProc("Update Gy_Warehouse set HEndflag=0 where HItemID=" + HParentID, ref DBUtility.ClsPub.sExeReturnInfo);
//
//启用仓位
if (HSPFlag == 1)
{
//回填 HSPGroupID
oCN.RunProc("Update Gy_Warehouse set HSPGroupID=HItemID where HItemID=" + HItemID , ref DBUtility.ClsPub.sExeReturnInfo);
}
else {
//回填 HSPGroupID
oCN.RunProc("Update Gy_Warehouse set HSPGroupID=0 where HItemID=" + HItemID, ref DBUtility.ClsPub.sExeReturnInfo);
}
oCN.Commit();
}
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "保存成功!";
//WebAPIController.Add_Log("送货单下推", UserName, "生成送货单");
objJsonResult.data = 1;
return objJsonResult;
}
catch (Exception e)
{
oCN.RollBack();
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "Exception!" + e.Message;
objJsonResult.data = null;
return objJsonResult;
}
}
[Route("Gy_Warehouse/SaveGy_WarehouseListApi")]
[HttpPost]
public object SaveGy_WarehouseListApi([FromBody] JObject msg)
{
try
{
var model = msg["model"].ToString();
var stockplaceModel = msg["model"]["HStockplaceEntry"].ToString();
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
//反序列化
model = "[" + model.ToString() + "]";
List list = Newtonsoft.Json.JsonConvert.DeserializeObject>(model);//仓库
List stockplaceList = Newtonsoft.Json.JsonConvert.DeserializeObject>(stockplaceModel);//仓位
string sql = string.Empty;
//DataTable dt = DataHelper.ListToDataTable(list);
//oCN.SqlBulkCopyByDatatable("Gy_Warehouse", dt);
//保存
oCN.BeginTran();
sql = $"delete Gy_Warehouse where HItemID = {list[0].HItemID}";
oCN.RunProc(sql);
sql = "set identity_insert Gy_Warehouse on";
oCN.RunProc(sql);
oCN.RunProc("Insert into Gy_Warehouse " +
" (HItemID,HNumber,HName,HHelpCode,HShortNumber,HParentID" +
",HLevel,HEndFlag,HStopflag,HRemark,HEmpID,HAddress,HPhone,HUSEORGID,HCREATEORGID,HSPFlag,HSPGroupID,HUnderStock,HSTOCKPROPERTY) " +
" Values('" + list[0].HItemID + "','" + list[0].HNumber + "','" +list[0].HName + "','" + list[0].HHelpCode + "','" + list[0].HShortNumber + "'," + list[0].HParentID.ToString() +
"," + list[0].HLevel.ToString() + "," + Convert.ToString(list[0].HEndFlag ? 1 : 0) + "," + Convert.ToString(list[0].HStopFlag ? 1 : 0) + ",'" + list[0].HRemark + "'," + list[0].HEmpID.ToString() + ",'" + list[0].HAddress + "','" + list[0].HPhone + "','" + list[0].HUSEORGID + "','" + list[0].HCREATEORGID + "','" + list[0].HSPFlag + "','" + list[0].HSPGroupID + "','" + list[0].HUnderStock + "','" + list[0].HSTOCKPROPERTY + "')", ref DBUtility.ClsPub.sExeReturnInfo);
//修改上级为非末级代码
sql = "set identity_insert Gy_Warehouse off";
oCN.RunProc(sql);
sql = $"delete gy_stockplace where HSPGroupID in ({list[0].HItemID})";
oCN.RunProc(sql);
sql = "set identity_insert gy_stockplace on";
oCN.RunProc(sql);
foreach (var item in stockplaceList)
{
oCN.RunProc("Insert into gy_stockplace " +
" (HItemID,HNumber,HName,HHelpCode,HShortNumber,HParentID" +
",HLevel,HEndFlag,HStopflag,HRemark,HUSEORGID,HCREATEORGID,HSPGroupID,HSPType,HSrcSPType,HDesSPType) " +
" Values('" + item.HItemID + "','" + item.HNumber + "','" + item.HName + "','" + item.HHelpCode + "','" + item.HShortNumber + "'," + item.HParentID.ToString() +
"," + item.HLevel.ToString() + "," + Convert.ToString(item.HEndFlag ? 1 : 0) + "," + Convert.ToString(item.HStopFlag ? 1 : 0) + ",'" + item.HRemark + "','" + item.HUSEORGID + "','" + item.HCREATEORGID + "','" + item.HSPGroupID + "','" + item.HSPType + "','" + item.HSrcSPType + "','" + item.HDesSPType + "')", ref DBUtility.ClsPub.sExeReturnInfo);
}
sql = "set identity_insert gy_stockplace off";
oCN.RunProc(sql);
oCN.Commit();
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "保存成功!";
objJsonResult.data = 1;
return objJsonResult;
}
catch (Exception e)
{
oCN.RollBack();
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "保存失败!" + e.ToString();
objJsonResult.data = 1;
return objJsonResult;
}
}
///
/// 仓库列表删除功能
///
///
[Route("DeltetGy_Warehouse")]
[HttpGet]
public object DeltetGy_Warehouse(string HItemID,string user)
{
DataSet ds;
DataSet ds1;
try
{
//删除权限
if (!DBUtility.ClsPub.Security_Log("Gy_Warehouse_Delete", 1, false, user))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "无删除权限";
objJsonResult.data = null;
return objJsonResult;
}
SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
if (string.IsNullOrWhiteSpace(HItemID))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "HItemID为空!";
objJsonResult.data = null;
return objJsonResult;
}
oCN.BeginTran();//开始事务
ds = oCN.RunProcReturn("select * from Gy_Warehouse where HItemID=" + HItemID, "Gy_Warehouse");
if (ds == null || ds.Tables[0].Rows.Count == 0)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "没有数据,无法删除!";
objJsonResult.data = null;
return objJsonResult; ;
}
//var HStopflag = Convert.ToBoolean(ds.Tables[0].Rows[0]["HStopflag"]);
//if (HStopflag)
//{
// oCN.RollBack();//回滚事务
// objJsonResult.code = "0";
// objJsonResult.count = 0;
// objJsonResult.Message = "数据已删除无法再次删除!";
// objJsonResult.data = null;
// return objJsonResult;
//}
ds1 = oCN.RunProcReturn("Select HItemID from Gy_Warehouse Where HParentID='" + HItemID + "'", "Gy_Warehouse");
if (ds1.Tables[0].Rows.Count != 0)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "此项目存在子项目,不能删除!";
objJsonResult.data = null;
return objJsonResult;
}
string HUseFlag = Convert.ToString(ds.Tables[0].Rows[0]["HUseFlag"]);
if (HUseFlag == "已使用")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "此项目已使用,不能删除!";
objJsonResult.data = null;
return objJsonResult;
}
oCN.RunProc("delete from Gy_Warehouse where HItemID=" + HItemID);
oCN.Commit();//提交事务
objJsonResult.code = "0";
objJsonResult.count = 1;
objJsonResult.Message = "* 数据删除成功!";
objJsonResult.data = null;
return objJsonResult; ;
}
catch (Exception e)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "删除失败!" + e.ToString();
objJsonResult.data = null;
return objJsonResult;
}
}
#region [同步基础资料]
[Route("Gy_Warehouse/Gy_WarehouseViewApi")]
[HttpGet]
public json Gy_WarehouseViewApi(string Number, string Type)
{
string sql = string.Empty;
string sReturn = "";
if (oSystemParameter.ShowBill(ref sReturn) == true)
{
//系统参数是否为私有云模式,N为公有云模式,Y为私有云模式
if (oSystemParameter.omodel.WMS_CloudMode == "Y")
{
#region [私有云模式,直接调用数据库存储过程更新]
try
{
oCN.BeginTran();
SQLHelper.ClsCN oCn = new SQLHelper.ClsCN();
DataSet DS = oCn.RunProcReturn("exec h_p_WMS_ERPBasicInfoToLocal '" + Number + "','" + Type + "'", "h_p_WMS_ERPBasicInfoToLocal");
if (DS == null)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "基础资料同步失败";
objJsonResult.data = null;
return objJsonResult;
}
else
{
if (DBUtility.ClsPub.isStrNull(DS.Tables[0].Rows[0]["HBack"]) == "2")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "ERP中不存在该代码";
objJsonResult.data = null;
return objJsonResult;
}
else
{
objJsonResult.code = "1";
objJsonResult.count = 1;
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;
}
#endregion
}
else
{
#region [公有云模式,调用WEBAPI的方式进行更新]
var json = new
{
CreateOrgId = 0,
Number = Number,
Id = ""
};
#region [金蝶部分]
//登录金蝶
var loginRet = InvokeHelper.Login();
var isSuccess = JObject.Parse(loginRet)["LoginResultType"].Value();
//判断是否登录成功
if (isSuccess < 0)
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = loginRet;
objJsonResult.data = null;
return objJsonResult;
}
//查看 获取数据
var _result = InvokeHelper.View("BD_STOCK", JsonConvert.SerializeObject(json));
var _saveObj = JObject.Parse(_result);
//判断数据是否获取成功
if (_saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "金蝶仓库仓位同步失败jsonRoot:" + _result;
objJsonResult.data = null;
return objJsonResult;
}
#endregion
//获取数据
DataSet Ds;
Ds = oCN.RunProcReturn("select * from Gy_Warehouse where HNumber = '" + Number + "'", "Gy_Warehouse");
if (Ds.Tables[0].Rows.Count != 0 && ClsPub.isLong(Ds.Tables[0].Rows[0]["HItemID"].ToString()) != 0)
{
}
#region [表数据赋值]
var jsonData = new
{
HItemID = _saveObj["Result"]["Result"]["Id"],
HERPItemID = _saveObj["Result"]["Result"]["Id"],
HNumber = _saveObj["Result"]["Result"]["Number"],
HName = _saveObj["Result"]["Result"]["Name"][0]["Value"],
HShortNumber = _saveObj["Result"]["Result"]["Number"],
HParentID = 0,
HLevel = 1,
HEndFlag = 1,
HStopflag = _saveObj["Result"]["Result"]["ForbidStatus"].ToString() == "A" ? 0 : 1,
HRemark = "CLD-ERP导入",
HSPFlag = _saveObj["Result"]["Result"]["IsOpenLocation"].ToString() == "false" ? 0 : 1,
HSPGroupID = 0,
HUnderStock = _saveObj["Result"]["Result"]["AllowMinusQty"].ToString() == "false" ? 0 : 1,
HUseFlag = "已使用",
HMakeTime = _saveObj["Result"]["Result"]["CreateDate"],
HCREATEORGID = _saveObj["Result"]["Result"]["CreateOrgId_Id"],
HUSEORGID = _saveObj["Result"]["Result"]["UseOrgId_Id"],
HSTOCKPROPERTY = _saveObj["Result"]["Result"]["StockProperty"],
HDEFSTOCKSTATUSID = _saveObj["Result"]["Result"]["DefStockStatusId_Id"],
};
#endregion
// 删除主表对应数据
sql = $"delete from Gy_Warehouse where HItemID = " + jsonData.HItemID + " and HNumber = '" + Number + "'";
oCN.RunProc(sql);
sql = "set identity_insert Gy_Warehouse on";
oCN.RunProc(sql);
//插入表
sql = $@"
insert into Gy_Warehouse
(HItemID,HERPItemID,HNumber,HName,HShortNumber,HParentID
,HLevel,HEndFlag,HStopflag,HRemark
,HSPFlag,HSPGroupID,HUnderStock,HUseFlag
,HMakeTime,HCREATEORGID,HUSEORGID,HSTOCKPROPERTY,HDEFSTOCKSTATUSID
)
values
({jsonData.HItemID},{jsonData.HERPItemID},'{jsonData.HNumber}','{jsonData.HName}',
'{jsonData.HShortNumber}',{jsonData.HParentID},{jsonData.HLevel},{jsonData.HEndFlag},{jsonData.HStopflag},'{jsonData.HRemark}',{jsonData.HSPFlag},{jsonData.HSPGroupID},{jsonData.HUnderStock},'{jsonData.HUseFlag}','{jsonData.HMakeTime}',{jsonData.HCREATEORGID},{jsonData.HUSEORGID},{jsonData.HSTOCKPROPERTY},{jsonData.HDEFSTOCKSTATUSID})";
oCN.RunProc(sql);
sql = "set identity_insert Gy_Warehouse off";
oCN.RunProc(sql);
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "仓库仓位同步成功!";
objJsonResult.data = null;
return objJsonResult;
#endregion
}
}
else
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "基础资料读取失败!";
objJsonResult.data = null;
return objJsonResult;
}
}
#endregion
#region 物料分类审核、反审核
///
///
///
/// 单据ID
/// 审核(0),反审核(1)
/// 审核人
///
[Route("Gy_Warehouse/AuditGy_Warehouse")]
[HttpGet]
public object AuditGy_MaterType(int HInterID, int IsAudit, string CurUserName)
{
try
{
//审核权限
if (!DBUtility.ClsPub.Security_Log_second("Gy_Warehouse_Check", 1, false, CurUserName))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "审核失败!无权限!";
objJsonResult.data = null;
return objJsonResult;
}
var ds = oCN.RunProcReturn("select * from Gy_Warehouse where HItemID=" + HInterID, "Gy_Warehouse");
if (ds.Tables[0].Rows.Count > 0)
{
if (IsAudit == 0) //审核判断
{
if (ds.Tables[0].Rows[0]["HCheckEmp"].ToString() != "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "单据已审核!不能再次审核!";
objJsonResult.data = null;
return objJsonResult;
}
}
if (IsAudit == 1) //反审核判断
{
if (ds.Tables[0].Rows[0]["HCheckEmp"].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 (IsAudit == 0) //审核判断
{
oCN.RunProc("update Gy_Warehouse set HCheckEmp='" + CurUserName + "',HCheckTime=getdate() where HItemID=" + HInterID);
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "审核成功";
objJsonResult.data = null;
}
if (IsAudit == 1) //反审核判断
{
oCN.RunProc("update Gy_Warehouse set HCheckEmp='',HCheckTime=null where HItemID=" + HInterID);
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 物料分类禁用、反禁用
///
///
///
/// 单据ID
/// 禁用(0),反禁用(1)
/// 审核人
///
[Route("Gy_Warehouse/StopGy_Warehouse")]
[HttpGet]
public object StopGy_MaterType(int HInterID, int IsStop, string CurUserName)
{
try
{
//审核权限
if (!DBUtility.ClsPub.Security_Log_second("Gy_Warehouse_Stop", 1, false, CurUserName))
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "禁用失败!无权限!";
objJsonResult.data = null;
return objJsonResult;
}
var ds = oCN.RunProcReturn("select * from Gy_Warehouse where HItemID=" + HInterID, "Gy_Warehouse");
if (ds.Tables[0].Rows.Count > 0)
{
if (IsStop == 0) //禁用判断
{
if (ds.Tables[0].Rows[0]["HStopEmp"].ToString() != "")
{
objJsonResult.code = "0";
objJsonResult.count = 0;
objJsonResult.Message = "单据已禁用!不能再次禁用!";
objJsonResult.data = null;
return objJsonResult;
}
}
if (IsStop == 1) //反禁用判断
{
if (ds.Tables[0].Rows[0]["HStopEmp"].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 (IsStop == 0) //禁用判断
{
oCN.RunProc("update Gy_Warehouse set HStopEmp='" + CurUserName + "',HStopTime=getdate(),HStopflag=1 where HItemID=" + HInterID);
objJsonResult.code = "1";
objJsonResult.count = 1;
objJsonResult.Message = "禁用成功";
objJsonResult.data = null;
}
if (IsStop == 1) //反禁用判断
{
oCN.RunProc("update Gy_Warehouse set HStopEmp='',HStopTime=null,HStopflag=0 where HItemID=" + HInterID);
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
}
}