大连融科 WMS
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 

154 lines
5.8 KiB

using System;
using System.Linq;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.ServiceModel;
using SiaSun.LMS.Model;
using System.Reflection;
namespace SiaSun.LMS.Implement
{
[ServiceBehavior(IncludeExceptionDetailInFaults = true,
InstanceContextMode = InstanceContextMode.Single,
ConcurrencyMode = ConcurrencyMode.Multiple,
MaxItemsInObjectGraph = int.MaxValue)]
public partial class S_PDAService : S_BaseService, SiaSun.LMS.Interface.I_PDAService
{
#region 操作方法
public DataTable GetList(string strSQL)
{
return base.GetList(strSQL);
}
public object ExecuteScalar(string strSQL)
{
return base.ExecuteScalar(strSQL);
}
public ObjectT GetModel(string statementName, object parameterObject)
{
return base.GetModel(statementName, parameterObject);
}
public bool USER_LOGIN(string USER_CODE, string USER_PASSWORD, out SiaSun.LMS.Model.SYS_USER USER)
{
return base._S_SystemService.USER_LOGIN(USER_CODE, USER_PASSWORD, out USER);
}
public bool ManageCreate(string sClassName, string sMethodName,
SiaSun.LMS.Model.MANAGE_MAIN mMANAGE_MAIN,
List<SiaSun.LMS.Model.MANAGE_LIST> lsMANAGE_LIST,
bool bTrans,
bool bComplete,
bool bAutoSendControl,
out string sResult)
{
if (sClassName.Equals("ManageOut"))
{
mMANAGE_MAIN.START_CELL_ID=16644;
mMANAGE_MAIN.END_CELL_ID = 16644;
return base.Invoke(sClassName, sMethodName, new object[] { mMANAGE_MAIN, lsMANAGE_LIST, bTrans, bAutoSendControl, bComplete }, out sResult);
}
return base.Invoke(sClassName, sMethodName, new object[] { mMANAGE_MAIN, lsMANAGE_LIST, bTrans, bComplete, bAutoSendControl }, out sResult);
}
#endregion
/// <summary>
/// 大连融科入库MES入库 生成暂存区库存
/// </summary>
/// <param name="json"></param>
/// <returns></returns>
public string ProductMangeIn(string json)
{
string sResult = string.Empty;
string connStr_baili = "server=localhost;user=root;database=mydatabase;port=3306;password=mypassword";
string connStr_husong = "server=192.168.10.191;user=wmsuser;database=hssk;port=3306;password=wmspass";
//ResponseData responseData = new ResponseData();
//PRODUCTMANGEIN pRODUCTMANGEIN = Common.JsonHelper.Deserialize<PRODUCTMANGEIN>(json);
//if (pRODUCTMANGEIN == null)
//{
// responseData.success = false;
// responseData.msg = "反序列化为空";
// return Common.JsonHelper.Serializer(responseData);
//}
STORAGE_LIST sTORAGE_LIST = _P_STORAGE_LIST.GetModel(11);
//if (sTORAGE_LIST != null)
//{
// responseData.success = false;
// responseData.msg = $"{pRODUCTMANGEIN.BagNO}已经存在库存";
// return Common.JsonHelper.Serializer(responseData);
//}
GOODS_MAIN gOODS_MAIN = _P_GOODS_MAIN.GetModel("应该从物料信息里面得到,具体物料信息格式确定一下");
if (gOODS_MAIN == null)
{
gOODS_MAIN = new GOODS_MAIN();
gOODS_MAIN.GOODS_CODE = "11";
gOODS_MAIN.GOODS_NAME = "11";
gOODS_MAIN.GOODS_UNITS = "11";
gOODS_MAIN.GOODS_CLASS_ID = 1;
_P_GOODS_MAIN.Add(gOODS_MAIN);
}
STORAGE_MAIN sTORAGE_MAIN = new STORAGE_MAIN();
sTORAGE_MAIN.STOCK_BARCODE = "物料信息唯一码";
sTORAGE_MAIN.CELL_ID = 16644;
// sTORAGE_MAIN. = pRODUCTMANGEIN.Line;
//区分是哪家接口
//sTORAGE_MAIN.STORAGE_REMARK = "11";
_P_STORAGE_MAIN.Add(sTORAGE_MAIN);
STORAGE_MAIN mStorage_main = _P_STORAGE_MAIN.GetModelStockBarcode("11");
if (mStorage_main == null)
{
sResult="";
//responseData.success = true;
//responseData.msg = $"成功";
//return Common.JsonHelper.Serializer(responseData);
}
sTORAGE_LIST = new STORAGE_LIST();
sTORAGE_LIST.STORAGE_ID = sTORAGE_MAIN.STORAGE_ID;
sTORAGE_LIST.BOX_BARCODE = "11";
sTORAGE_LIST.GOODS_ID = gOODS_MAIN.GOODS_ID;
sTORAGE_LIST.ENTRY_TIME = Common.StringUtil.GetDateTime();
sTORAGE_LIST.STORAGE_LIST_QUANTITY = 1;
//生产批次
sTORAGE_LIST.GOODS_PROPERTY1 = "11";
//产品型号代码
sTORAGE_LIST.GOODS_PROPERTY2 = "11";
//原料代码
sTORAGE_LIST.GOODS_PROPERTY3 = "11";
//日期
sTORAGE_LIST.GOODS_PROPERTY4 = "11";
//基地产线代码
sTORAGE_LIST.GOODS_PROPERTY5 = "11";
//mes推送重量
sTORAGE_LIST.GOODS_PROPERTY7 = "11";
////直接连接数据库,获取质检结果,更新库存
//try
//{
//}
//catch (Exception ex)
//{
// responseData.success = false;
// responseData.msg = $"连接数据库发生错误{ex.ToString()}";
// return Common.JsonHelper.Serializer(responseData);
//}
_P_STORAGE_LIST.Add(sTORAGE_LIST);
//responseData.success = true;
//responseData.msg = $"成功";
//return Common.JsonHelper.Serializer(responseData);
return "";
}
}
}