Yangwl
/
lanju-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'a93724a4eb'
${ noResults }
lanju-client/shangjian/XGL.Data/DBService/DBService.cs

3403 lines
154 KiB
C#
Raw Normal View History Unescape Escape

1
2 years ago
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using CentralControl.BaseData;
using CommonFunc;
using LanJuLib;
using System.Data;
using System.Data.SqlClient;
using MySql.Data.MySqlClient;
1
2 years ago
using CommonFunc.Tools;
添加烘房小看板
2 years ago
using XGL.Models.Model;
1
2 years ago
1
2 years ago
namespace CentralControl.DBDAO
{
public class DBService
3
2 years ago
{
1
2 years ago
/// <summary>
/// 得到一个对象实体集合
/// </summary>
public static List<CarProduct> GetCarProductList(string strWhere)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select");
strSql.Append(" id, carNo, productNo, productNm, IsDeleted, DATE_FORMAT(CreateTime,'%Y-%m-%d %H:%i:%s') CreateTime, CreateId, CreateBy, DATE_FORMAT(ModifyTime,'%Y-%m-%d %H:%i:%s') ModifyTime, ModifyId, ModifyBy");
strSql.Append(" from data_carproduct");
if (!string.IsNullOrWhiteSpace(strWhere))
strSql.Append(" where " + strWhere);
List<CarProduct> Items = new List<CarProduct>();
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
if (ds.Tables[0].Rows.Count > 0)
{
foreach (DataRow row in ds.Tables[0].Rows)
{
CarProduct model = new CarProduct();
if (row["id"] != DBNull.Value)
{
model.id = Convert.ToInt32(row["id"]);
}
if (row["carNo"] != DBNull.Value)
{
model.carNo = Convert.ToString(row["carNo"]);
}
if (row["productNo"] != DBNull.Value)
{
model.productNo = Convert.ToString(row["productNo"]);
}
if (row["productNm"] != DBNull.Value)
{
model.productNm = Convert.ToString(row["productNm"]);
}
if (row["IsDeleted"] != DBNull.Value)
{
model.IsDeleted = row["IsDeleted"].ToString() == "False" ? false : true;
}
if (row["CreateTime"] != DBNull.Value)
{
model.CreateTime = Convert.ToString(row["CreateTime"]);
}
if (row["CreateId"] != DBNull.Value)
{
model.CreateId = Convert.ToInt32(row["CreateId"]);
}
if (row["CreateBy"] != DBNull.Value)
{
model.CreateBy = Convert.ToString(row["CreateBy"]);
}
if (row["ModifyTime"] != DBNull.Value)
{
model.ModifyTime = Convert.ToString(row["ModifyTime"]);
}
if (row["ModifyId"] != DBNull.Value)
{
model.ModifyId = Convert.ToInt32(row["ModifyId"]);
}
if (row["ModifyBy"] != DBNull.Value)
{
model.ModifyBy = Convert.ToString(row["ModifyBy"]);
}
Items.Add(model);
}
}
return Items;
}
3
2 years ago
public DataTable GetFactoryInfo(string sitecode)
{
string sql = $"select factory_name from sys_factory where factory_code = '{sitecode}'";
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
1
2 years ago
/// <summary>
/// 删除一条数据
/// </summary>
public static bool DeleteCarProductByCarNo(string carno)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("delete from data_carproduct ");
strSql.Append(" where carno=@carno");
MySqlParameter[] parameters = {
new MySqlParameter("@carno", MySqlDbType.String)
};
parameters[0].Value = carno;
int rows = DbHelperSQLServer.ExecuteNonQuery(strSql.ToString(), parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 获取库区和路途中库存信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetErrorMessage()
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @"select base_production_order_split.*,base_materialinfobom.materiel_box_no from base_production_order_split left join base_materialinfobom on base_production_order_split.prod_code=base_materialinfobom.materiel_finish_no where UpQuantity<Quantity and UpQuantity-DownQuantity<50 order by RAND() desc limit 1;";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取库区和路途中库存信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetFlag(string flag_no)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @"select * from base_flag where flag_no ='" + flag_no + "';";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 增加一条数据
/// </summary>
public static int AddCarProduct(CarProduct model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into data_carproduct(");
strSql.Append("id,carNo,productNo,productNm,IsDeleted,CreateTime,CreateId,CreateBy,ModifyTime,ModifyId,ModifyBy)");
strSql.Append(" values (");
strSql.Append("@id,@carNo,@productNo,@productNm,@IsDeleted,@CreateTime,@CreateId,@CreateBy,@ModifyTime,@ModifyId,@ModifyBy)");
strSql.Append(";select @@identity; ");
MySqlParameter[] parameters = {
new MySqlParameter("@id",model.id),
new MySqlParameter("@carNo",model.carNo),
new MySqlParameter("@productNo",model.productNo),
new MySqlParameter("@productNm",model.productNm),
new MySqlParameter("@IsDeleted",model.IsDeleted),
new MySqlParameter("@CreateTime",model.CreateTime),
new MySqlParameter("@CreateId",model.CreateId),
new MySqlParameter("@CreateBy",model.CreateBy),
new MySqlParameter("@ModifyTime",model.ModifyTime),
new MySqlParameter("@ModifyId",model.ModifyId),
new MySqlParameter("@ModifyBy",model.ModifyBy),
};
object obj = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// </summary>
/// 修改一条数据
/// </summary>
public static bool UpdateCarMaterial(CarMaterial model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("update data_carmaterial set");
strSql.Append(" carNo = @carNo , ");
strSql.Append(" materialNo = @materialNo , ");
strSql.Append(" materialNm = @materialNm , ");
strSql.Append(" materialBarno = @materialBarno , ");
strSql.Append(" IsDeleted = @IsDeleted , ");
strSql.Append(" CreateTime = @CreateTime , ");
strSql.Append(" CreateId = @CreateId , ");
strSql.Append(" CreateBy = @CreateBy , ");
strSql.Append(" ModifyTime = @ModifyTime , ");
strSql.Append(" ModifyId = @ModifyId , ");
strSql.Append(" ModifyBy = @ModifyBy");
strSql.Append(" where id = @id");
MySqlParameter[] parameters = {
new MySqlParameter("@id", model.id),
new MySqlParameter("@carNo", model.carNo),
new MySqlParameter("@materialNo", model.materialNo),
new MySqlParameter("@materialNm", model.materialNm),
new MySqlParameter("@materialBarno", model.materialBarno),
new MySqlParameter("@IsDeleted", model.IsDeleted),
new MySqlParameter("@CreateTime", model.CreateTime),
new MySqlParameter("@CreateId", model.CreateId),
new MySqlParameter("@CreateBy", model.CreateBy),
new MySqlParameter("@ModifyTime", model.ModifyTime),
new MySqlParameter("@ModifyId", model.ModifyId),
new MySqlParameter("@ModifyBy", model.ModifyBy),
};
int rows = DbHelperSQLServer.ExecuteNonQuery(strSql.ToString(), parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 得到一个对象实体集合
/// </summary>
public static List<CarMaterial> GetCarMaterialList(string strWhere)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select");
strSql.Append(" id, carNo, materialNo, materialNm, materialBarno, IsDeleted, DATE_FORMAT(CreateTime,'%Y-%m-%d %H:%i:%s') CreateTime, CreateId, CreateBy, DATE_FORMAT(ModifyTime,'%Y-%m-%d %H:%i:%s') ModifyTime, ModifyId, ModifyBy");
strSql.Append(" from data_carmaterial");
if (!string.IsNullOrWhiteSpace(strWhere))
strSql.Append(" where " + strWhere);
List<CarMaterial> Items = new List<CarMaterial>();
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
if (ds.Tables[0].Rows.Count > 0)
{
foreach (DataRow row in ds.Tables[0].Rows)
{
CarMaterial model = new CarMaterial();
if (row["id"] != DBNull.Value)
{
model.id = Convert.ToInt32(row["id"]);
}
if (row["carNo"] != DBNull.Value)
{
model.carNo = Convert.ToString(row["carNo"]);
}
if (row["materialNo"] != DBNull.Value)
{
model.materialNo = Convert.ToString(row["materialNo"]);
}
if (row["materialNm"] != DBNull.Value)
{
model.materialNm = Convert.ToString(row["materialNm"]);
}
if (row["materialBarno"] != DBNull.Value)
{
model.materialBarno = Convert.ToString(row["materialBarno"]);
}
if (row["IsDeleted"] != DBNull.Value)
{
model.IsDeleted = row["IsDeleted"].ToString() == "False" ? false : true;
}
if (row["CreateTime"] != DBNull.Value)
{
model.CreateTime = Convert.ToString(row["CreateTime"]);
}
if (row["CreateId"] != DBNull.Value)
{
model.CreateId = Convert.ToInt32(row["CreateId"]);
}
if (row["CreateBy"] != DBNull.Value)
{
model.CreateBy = Convert.ToString(row["CreateBy"]);
}
if (row["ModifyTime"] != DBNull.Value)
{
model.ModifyTime = Convert.ToString(row["ModifyTime"]);
}
if (row["ModifyId"] != DBNull.Value)
{
model.ModifyId = Convert.ToInt32(row["ModifyId"]);
}
if (row["ModifyBy"] != DBNull.Value)
{
model.ModifyBy = Convert.ToString(row["ModifyBy"]);
}
Items.Add(model);
}
}
return Items;
}
/// <summary>
/// 删除一条数据
/// </summary>
public static bool DeleteCarMaterialByCarNo(string carno)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("delete from data_carmaterial ");
strSql.Append(" where carno=@carno");
MySqlParameter[] parameters = {
new MySqlParameter("@carno", MySqlDbType.String)
};
parameters[0].Value = carno;
int rows = DbHelperSQLServer.ExecuteNonQuery(strSql.ToString(), parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 增加一条数据
/// </summary>
public static int AddCarMaterial(CarMaterial model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into data_carmaterial(");
strSql.Append("id,carNo,materialNo,materialNm,materialBarno,IsDeleted,CreateTime,CreateId,CreateBy,ModifyTime,ModifyId,ModifyBy)");
strSql.Append(" values (");
strSql.Append("@id,@carNo,@materialNo,@materialNm,@materialBarno,@IsDeleted,@CreateTime,@CreateId,@CreateBy,@ModifyTime,@ModifyId,@ModifyBy)");
strSql.Append("; select @@identity; ");
MySqlParameter[] parameters = {
new MySqlParameter("@id",model.id),
new MySqlParameter("@carNo",model.carNo),
new MySqlParameter("@materialNo",model.materialNo),
new MySqlParameter("@materialNm",model.materialNm),
new MySqlParameter("@materialBarno",model.materialBarno),
new MySqlParameter("@IsDeleted",model.IsDeleted),
new MySqlParameter("@CreateTime",model.CreateTime),
new MySqlParameter("@CreateId",model.CreateId),
new MySqlParameter("@CreateBy",model.CreateBy),
new MySqlParameter("@ModifyTime",model.ModifyTime),
new MySqlParameter("@ModifyId",model.ModifyId),
new MySqlParameter("@ModifyBy",model.ModifyBy),
};
object obj = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 设置系统配置字段
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int SetSystemConfigItem(string settingno, string val)
{
string sql = " update basedata_systemconfig set settingval='" + val + "' where settingno='" + settingno + "' ; ";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
/// <summary>
/// 得到一个对象实体集合
/// </summary>
public static List<MaterialBom> GetMaterialBomList(string strWhere, List<MaterialInfo> mlist)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select ");
strSql.Append(" Id, materiel_finish_no, materiel_box_no, Version, is_delete, DATE_FORMAT(create_time, '%Y-%m-%d %H:%i:%s') CreateTime,");
strSql.Append(" create_id CreateId, create_by CreateBy, DATE_FORMAT(modify_time, '%Y-%m-%d %H:%i:%s') ModifyTime, modify_id ModifyId, modify_by ModifyBy ");
strSql.Append("from base_materialinfobom");
if (!string.IsNullOrWhiteSpace(strWhere))
strSql.Append(" where " + strWhere);
List<MaterialBom> Items = new List<MaterialBom>();
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
if (ds.Tables[0].Rows.Count > 0)
{
foreach (DataRow row in ds.Tables[0].Rows)
{
MaterialBom model = new MaterialBom();
if (row["Id"] != DBNull.Value)
{
model.Id = row["Id"].ToString();
}
if (row["materiel_finish_no"] != DBNull.Value)
{
model.MaterialNo = Convert.ToString(row["materiel_finish_no"]);
model.ParentMaterialInfo = mlist.FirstOrDefault(t => t.MaterialNo == model.MaterialNo);
}
if (row["GateMaterialNo"] != DBNull.Value)
{
model.ChildMaterialNo = Convert.ToString(row["GateMaterialNo"]);
model.ChildMaterialInfo = mlist.FirstOrDefault(t => t.MaterialNo == model.ChildMaterialNo);
}
if (row["Version"] != DBNull.Value)
{
model.Version = Convert.ToString(row["Version"]);
}
Items.Add(model);
}
}
return Items;
}
/// <summary>
/// 获取系统配置字段
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static string GetSystemConfigItem(string settingno)
{
string sql = " select settingval from basedata_systemconfig where settingno='" + settingno + "' ; ";
return DbHelperSQLServer.ExecuteScalar(sql).ToString();
}
/// <summary>
/// 获取库位内物料明细
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int GetClearMaterial(string where)
{
string sql = " update basedata_carrealinfo set materialno='',materialbarno='' ; ";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
public static void NightClearOldData()
{
string sql =
@"delete from basedata_offlinemateriallist where createtime <'" + DateTime.Now.AddDays(-1) + @"';
delete from basedata_offlinemateriallist_his where createtime < '" + DateTime.Now.AddDays(-7) + @"';
delete from sysnotices where createtime < '" + DateTime.Now.AddDays(-7) + @"';
delete from basedata_uplinescancarlist where createtime < '" + DateTime.Now.AddDays(-7) + @"';
delete from basedata_uplinemateriallist where createtime < '" + DateTime.Now.AddDays(-7) + @"';
delete from sysconfig_operatelog where createtime < '" + DateTime.Now.AddDays(-7) + @"';
delete from basedata_productinfo where createtime < '" + DateTime.Now.AddDays(-7) + @"';
";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
}
/// <summary>
/// 获取库位内分配物料明细
/// 获取库位内分配物料明细
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int CleartLineAreaMaterial(string where)
{
string sql = " update basedata_linecatcharea set MaterialNo='' where areatype=4 ";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
/// <summary>
/// 获取库位内分配物料明细
/// 获取库位内分配物料明细
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int SetLineAreaMaterial(int lineareaid, string materialno, string materialnm)
{
string sql = " update basedata_linecatcharea set MaterialNo='" + materialno + "',MaterialNm='" + materialnm + "' where id=" + lineareaid;
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
/// <summary>
/// 获取库位内物料明细
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static bool GetDBTime(string where)
{
string sql = @"select now();";
object obj = DbHelperSQLServer.ExecuteScalar(sql);
if (obj != null)
{
return true;
}
return false;
}
/// <summary>
/// 获取库位内物料明细
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int ClearScanOffMaterialDetailList()
{
string sql = @"delete from basedata_offlinemateriallist_detail;";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
/// <summary>
/// 获取库位内物料明细
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static DataTable GetOffLocatorMaterialView(string where)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @"
select a.TrayCode,a.ProductBarNo,a.carcode,a.createtime,a.lineno,b.HadNumber
from basedata_offlinemateriallist a left join basedata_carrealinfo b on a.carcode=b.carno
where a.IsDeleted=0 order by a.createtime
";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetUnitList()
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.OutWareHouseQuantity FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.est>=date_sub(curdate(),interval 1 day) and a.IsOver=0 order by a.line_code,a.est ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetUnitList_new()
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,a.prod_desc,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.OutWareHouseQuantity,a.production_sequence FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.est>=date_sub(curdate(),interval 1 day) and a.IsOver=0 order by a.line_code,a.est,a.production_sequence ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取库区和路途中库存信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetWareHouseList_new_new()
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT materiel_no materielNo,SUM(materiel_num) materielNum,'库中' carStatus FROM base_cararea
where 1=1 and materiel_no <>''
GROUP BY materielNo
union
SELECT materiel_no materielNo,sum(materiel_num) materielNum,'队列' carStatus FROM base_waitdownline
group by materielNo
UNION
select '总计' materielNo, (SELECT IFNULL(SUM(IFNULL(materiel_num,0)),0) materielNum FROM base_cararea where 1 = 1 and materiel_no<>'')+(SELECT IFNULL(sum(IFNULL(materiel_num,0)),0) materielNum FROM
base_waitdownline ) materielNum,'总计' carStatus ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取工单信息
/// </summary>
/// <returns></returns>
public DataTable GetWorkOrderList()
{
string sql = @"SELECT DISTINCT
t1.workorder_code WorkOrderCode,
t1.order_code OrderCode,
t1.product_name ProductName,
t1.product_spc ProductSpc,
t1.quantity_split QuantitySplit,
STUFF(
( SELECT ',' + t2.batch_code FROM pro_order_workorder_batch t2 WHERE t1.workorder_id = t2.workorder_id FOR XML PATH ( '' ) ),
1,
1,
''
) AS BatchCode
FROM
pro_order_workorder t1
INNER JOIN pro_order_workorder_batch t2 ON t1.workorder_id = t2.workorder_id
AND t1.status = 'w1'";
1
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
1
2 years ago
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
优化自动更新、成品报工、操作日志等。。。
2 years ago
public DataTable GetWetPlanInfo(string date,string shiftID)
no message
2 years ago
{
优化
2 years ago
//删除湿料计划主表
// string sql = $@"select wet.id,wet.factory_code,wet.prod_code, wetDetail.sync_flag,wet.plan_time,
//wetDetail.workorder_id,bucket_id,bucket_code,material_code,material_name,
//wetDetail.product_name,wet.shift_desc,prod_line_code,workorder.status,workorder.workorder_code
//from pro_wet_material_plan wet
//LEFT JOIN pro_wet_material_plan_detail wetDetail
//on wet.id = wetDetail.wet_material_plan_id
//left join pro_order_workorder workorder on workorder.workorder_id = wetDetail.workorder_id where 1=1 and workorder.status = 'w1' and workorder.end_flag = '1' and CONVERT(VARCHAR(10), wet.plan_time , 120)= CONVERT(VARCHAR(10), GetDate() , 120)";
//workorder.status = 'w1' and
优化自动更新、成品报工、操作日志等。。。
2 years ago
string where = "";
if (!string.IsNullOrEmpty(shiftID))
{
where = $"and wetDetail.shift_id = '{shiftID}'";
}
优化
2 years ago
string sql = $@"select wetDetail.id,wetDetail.factory_code,wetDetail.material_code as prod_code, wetDetail.sync_flag,wetDetail.plan_time,
2
2 years ago
wetDetail.workorder_id,bucket_id,bucket_code,material_code,material_name,
烘房取数逻辑修改、工单准备物料清单添加
2 years ago
wetDetail.material_name as product_name,shifts.shift_desc,prod_line_code,workorder.status,workorder.workorder_code,route_code
成品报工
2 years ago
from pro_wet_material_plan_detail wetDetail WITH (NOLOCK)
left join pro_order_workorder workorder WITH (NOLOCK) on workorder.workorder_id = wetDetail.workorder_id
left JOIN base_shifts_t shifts WITH (NOLOCK) on wetDetail.shift_id = shifts.shift_id
烘房取数逻辑修改、工单准备物料清单添加
2 years ago
where 1=1 and
优化自动更新、成品报工、操作日志等。。。
2 years ago
workorder.end_flag = '1' and workorder.del_flag = '0' and wetDetail.del_flag='0' and CONVERT(VARCHAR(10), wetDetail.plan_time , 120)= CONVERT(VARCHAR(10), '{date}' , 120) {where} ORDER BY bucket_code";
no message
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
展示设备名称
2 years ago
public List<BaseEquipment> GeteqmentInfo()
{
List<BaseEquipment> baseeqlist = new List<BaseEquipment>();
string sql = $@"SELECT * FROM base_equipment WHERE 1=1";
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
var dt = dtset.Tables[0]; // 请注意，这只是一个示例，您可以循环遍历所有行
foreach (DataRow row in dt.Rows)
{
BaseEquipment equipment = new BaseEquipment
{
EquipmentId = row[0] != DBNull.Value ? Convert.ToInt32(row[0]) : 0,
EquipmentCode = row[1] != DBNull.Value ? row[1].ToString() : string.Empty,
EquipmentName = row[2] != DBNull.Value ? row[2].ToString() : string.Empty,
EquipmentBrand = row[3] != DBNull.Value ? row[3].ToString() : string.Empty,
EquipmentSpec = row[4] != DBNull.Value ? row[4].ToString() : string.Empty,
EquipmentTypeId = row[5] != DBNull.Value ? Convert.ToInt64(row[5]) : 0,
EquipmentTypeCode = row[6] != DBNull.Value ? row[6].ToString() : string.Empty,
EquipmentTypeName = row[7] != DBNull.Value ? row[7].ToString() : string.Empty,
WorkshopId = row[8] != DBNull.Value ? Convert.ToInt64(row[8]) : 0,
WorkshopCode = row[9] != DBNull.Value ? row[9].ToString() : string.Empty,
WorkshopName = row[10] != DBNull.Value ? row[10].ToString() : string.Empty,
Status = row[11] != DBNull.Value ? row[11].ToString() : string.Empty,
Remark = row[12] != DBNull.Value ? row[12].ToString() : string.Empty,
Attr1 = row[13] != DBNull.Value ? row[13].ToString() : string.Empty,
Attr2 = row[14] != DBNull.Value ? row[14].ToString() : string.Empty,
Attr3 = row[15] != DBNull.Value ? row[15].ToString() : string.Empty,
Attr4 = row[16] != DBNull.Value ? row[16].ToString() : string.Empty,
// CreateTime = row[17] != DBNull.Value ? Convert.ToDateTime(row[17]) : DateTime.MinValue,
CreateBy = row[18] != DBNull.Value ? row[18].ToString() : string.Empty,
// UpdateTime = row[19] != DBNull.Value ? Convert.ToDateTime(row[19]) : DateTime.MinValue,
UpdateBy = row[20] != DBNull.Value ? row[20].ToString() : string.Empty,
WorkshopSection = row[21] != DBNull.Value ? row[21].ToString() : string.Empty,
EquipmentLocation = row[22] != DBNull.Value ? row[22].ToString() : string.Empty,
//HourlyUnitPrice = row["hourly_unit_price"] != DBNull.Value ? Convert.ToDecimal(row["hourly_unit_price"]) : 0m,
//EquipmentBarcode = row["equipment_barcode"] != DBNull.Value ? row["equipment_barcode"].ToString() : string.Empty,
//EquipmentBarcodeImage = row["equipment_barcode_image"] != DBNull.Value ? row["equipment_barcode_image"].ToString() : string.Empty,
//Manufacturer = row["manufacturer"] != DBNull.Value ? row["manufacturer"].ToString() : string.Empty,
//Supplier = row["supplier"] != DBNull.Value ? row["supplier"].ToString() : string.Empty,
//UseLife = row["use_life"] != DBNull.Value ? Convert.ToInt32(row["use_life"]) : 0,
//BuyTime = row["buy_time"] != DBNull.Value ? Convert.ToDateTime(row["buy_time"]) : DateTime.MinValue,
//AssetOriginalValue = row["asset_original_value"] != DBNull.Value ? Convert.ToDecimal(row["asset_original_value"]) : 0m,
//NetAssetValue = row["net_asset_value"] != DBNull.Value ? Convert.ToDecimal(row["net_asset_value"]) : 0m,
//AssetHead = row["asset_head"] != DBNull.Value ? row["asset_head"].ToString() : string.Empty,
//FixedAssetCode = row["fixed_asset_code"] != DBNull.Value ? row["fixed_asset_code"].ToString() : string.Empty,
//Department = row["department"] != DBNull.Value ? row["department"].ToString() : string.Empty,
//UnitWorkingHours = row["unit_working_hours"] != DBNull.Value ? Convert.ToInt32(row["unit_working_hours"]) : 0,
//PlcIp = row["plc_ip"] != DBNull.Value ? row["plc_ip"].ToString() : string.Empty,
//PlcPort = row["plc_port"] != DBNull.Value ? Convert.ToInt32(row["plc_port"]) : 0,
//DelFlag = row["del_flag"] != DBNull.Value ? row["del_flag"].ToString() == "1" : false,
//SapAsset = row["sap_asset"] != DBNull.Value ? row["sap_asset"].ToString() : string.Empty,
//EquipmentHead = row["equipment_head"] != DBNull.Value ? row["equipment_head"].ToString() : string.Empty
};
baseeqlist.Add(equipment);
}
}
return baseeqlist;
}
1
2 years ago
/// <summary>
/// 查询工艺
/// </summary>
/// <returns></returns>
public DataTable GetFlowInfo(string workorderno)
{
查看工艺、物料、SOP
2 years ago
string sql = $@"SELECT process_code,process_name,order_num,next_process_code,next_process_name,color_code,workorder.workorder_code,route.route_code,route_name,workorder.product_code,workorder.product_name
1
2 years ago
FROM [dbo].[pro_route_process] process
LEFT JOIN pro_route route on process.route_id = route.route_id
LEFT JOIN pro_order_workorder workorder on route.route_code = workorder.route_code
where workorder_code = '{workorderno}'
order by order_num"; //where CONVERT(VARCHAR(10), wet.plan_time , 120)= CONVERT(VARCHAR(10), GetDate() , 120)
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
查看工艺、物料、SOP
2 years ago
/// <summary>
/// 查询SOP信息
/// </summary>
/// <returns></returns>
public DataTable GetSOPInfo(string processid)
{
string sql = $@"select file_name,file_address from pro_route route
LEFT JOIN base_file files ON route.route_id = files.source_id
where route.route_code = '{processid}'"; //where CONVERT(VARCHAR(10), wet.plan_time , 120)= CONVERT(VARCHAR(10), GetDate() , 120)
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
添加烘房小看板
2 years ago
/// <summary>
/// 查询烘房状态
/// </summary>
/// <returns></returns>
public List<BaseEquipmentAttached> GetHFStatusInfo()
{
上位机看板添加数量
2 years ago
string sql = $@"SELECT * FROM [dbo].[base_equipment_attached] WHERE (property='dollyNumber' OR property='state' or property='Intheoven') AND device_code LIKE '%H%' ORDER BY device_code";
添加烘房小看板
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
List<BaseEquipmentAttached> result = new List<BaseEquipmentAttached>();
foreach (DataRow row in dtset.Tables[0].Rows)
{
BaseEquipmentAttached model = new BaseEquipmentAttached
{
id = row["id"].ToString(),
device_type = row["device_type"].ToString(),
device_code = row["device_code"].ToString(),
property = row["property"].ToString(),
explain = row["explain"].ToString(),
isvalue = row["isvalue"].ToString(),
last_update_time = row["last_update_time"].ToString()
};
result.Add(model);
}
return result;
}
return null;
}
查看工艺、物料、SOP
2 years ago
/// <summary>
/// 查询物料信息
/// </summary>
/// <returns></returns>
public DataTable GetMaterialInfo(string processid)
{
string sql = $@" select workorder_code, product_code, product_name, material_code, material_name,quantity,product_spc from mes_prepare pre
LEFT JOIN mes_prepare_detail detail on pre.prepare_id = detail.prepare_id
where workorder_code = '{processid}'"; //where CONVERT(VARCHAR(10), wet.plan_time , 120)= CONVERT(VARCHAR(10), GetDate() , 120)
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
1
2 years ago
/// <summary>
/// 获取工单是否齐套
/// </summary>
/// <returns></returns>
public DataTable GetWorkOrderQitaoLv(string workOrderNo)
{
no message
2 years ago
string sql = $@"select status from mes_prepare where wet_detail_plan_id = '{workOrderNo}'";
1
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
1
2 years ago
3
2 years ago
/// <summary>
1
2 years ago
/// 更新湿料计划同步状态、工单状态
3
2 years ago
/// </summary>
/// <returns></returns>
优化
2 years ago
public bool UpdateSycnFlag(string workOrderID)
3
2 years ago
{
1
2 years ago
List<string> sqlList = new List<string>();
优化
2 years ago
string sql = $@"update pro_wet_material_plan_detail set sync_flag = 'Y', update_by = '{LoginUser.UserName}',update_time = GETDATE() where workorder_id = '{workOrderID}' ";
string sql1 = $@"update pro_order_workorder set status = 'w2', update_by = '{LoginUser.UserName}',update_time = GETDATE() where workorder_id = '{workOrderID}' ";
sqlList.Add(sql);
sqlList.Add(sql1);
1
2 years ago
return Utils.netClientDBHelper.executeBatchSql(sqlList);
3
2 years ago
}
同步湿料计划修改
2 years ago
/// <summary>
/// 获取湿料计划指向的成型机
/// </summary>
/// <returns></returns>
public DataTable GetCXJList(string workOrderNo)
{
优化
2 years ago
//根据湿料计划获取所有工单用到的成型机
//string sql = $@"select prod_line_code,bucket_code
//from pro_wet_material_plan wet
//LEFT JOIN pro_wet_material_plan_detail wetDetail
//on wet.id = wetDetail.wet_material_plan_id
//left join pro_order_workorder workorder on workorder.workorder_id = wetDetail.workorder_id
//where wet.id = '{workOrderNo}'";
//根据工单获取成型机
同步物料
2 years ago
string sql = $@"select prod_line_code,bucket_code
优化
2 years ago
from pro_order_workorder workorder
LEFT JOIN pro_wet_material_plan_detail wetDetail on workorder.workorder_id = wetDetail.workorder_id
where workorder.workorder_id = '{workOrderNo}'";
1
2 years ago
同步湿料计划修改
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
1
2 years ago
添加查看日志
2 years ago
/// <summary>
/// 获取日志
/// </summary>
/// <returns></returns>
添加烘房小看板
2 years ago
public DataTable GetLogList(string datetime,string key,string selectin)
{
if (selectin!="")
{
//根据工单获取成型机
添加烘房的排序
2 years ago
string sql = $@"SELECT Top 2000 * FROM [dbo].[mes_interface_log] where CONVERT(VARCHAR(10), creter_time , 120)= CONVERT(VARCHAR(10), '{datetime}' , 120) and remark like '%{selectin}%' and messsge like '%{key}%' order by creter_time desc ; ";
添加烘房小看板
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
}
else
{
//根据工单获取成型机
添加烘房的排序
2 years ago
string sql = $@"SELECT Top 2000 * FROM [dbo].[mes_interface_log] where CONVERT(VARCHAR(10), creter_time , 120)= CONVERT(VARCHAR(10), '{datetime}' , 120) and messsge like '%{key}%' order by creter_time desc ; ";
添加烘房小看板
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
}
return null;
}
/// <summary>
/// 获取类型
/// </summary>
/// <returns></returns>
public DataTable GettypeList()
添加查看日志
2 years ago
{
//根据工单获取成型机
查看日志优化
2 years ago
//string sql = $@" SELECT DISTINCT remark FROM[dbo].[mes_interface_log] ";
string sql = $@"SELECT DISTINCT REPLACE(REPLACE(remark, '回参', ''), '入参', '') as remark FROM mes_interface_log";
添加查看日志
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
添加烘房小看板
2 years ago
查看plc信息
2 years ago
public DataTable GetPlcValueList(string key,string deviceCode)
{
//根据工单获取成型机
string sql = $@"SELECT * FROM [dbo].[base_equipment_attached] where explain like '%{key}%' and device_code like '%{deviceCode}%' ORDER BY device_code ; ";
1
2 years ago
查看plc信息
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
添加查询烘房plc值变更sql
2 years ago
public DataTable GetHFPlcValueList(string deviceCode)
{
//根据工单获取成型机
string sql = $@"SELECT * FROM mes_plc_log WHERE device_code ='{deviceCode}' and address='DB1.DBW6034' ORDER BY create_time DESC";
1
2 years ago
添加查询烘房plc值变更sql
2 years ago
DataSet dtset = Utils.netClientDBHelper.getDataSet(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
1
2 years ago
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetUnitList_new_new(string line_name)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,a.prod_desc,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.OutWareHouseQuantity,a.production_sequence FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.est>=date_sub(curdate(),interval 1 day) and a.IsOver=0 ";
if (!string.IsNullOrEmpty(line_name))
{
sql += " and a.line_name='" + line_name + "' ";
}
sql += "order by a.line_code,a.est,a.production_sequence";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
public DataTable GetUnitList_line(string lineCode)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,a.prod_desc,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.OutWareHouseQuantity,a.production_sequence FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.est>=date_sub(curdate(),interval 1 day) and a.IsOver=0 ";
if (!string.IsNullOrEmpty(lineCode))
{
sql += " and a.line_code='" + lineCode + "' ";
}
sql += "order by a.line_code,a.est,a.production_sequence ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetOrderZYList()
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.outwarehousequantity,a.UpQuantity-a.outwarehousequantity kzquantity FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.upquantity>a.outwarehousequantity order by a.line_code,a.est ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetOrderZFZYList()
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.outwarehousequantity,a.UpQuantity-a.outwarehousequantity kzquantity FROM base_production_order_split_line a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.upquantity>a.outwarehousequantity and order_status=4 order by a.line_code,a.est ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetOrderTJList()
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,a.prod_desc,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.OutWareHouseQuantity,a.production_sequence FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.est>=date_sub(curdate(),interval 1 day) and a.IsOver=0 order by a.line_code,a.est,a.production_sequence ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
public DataTable GetOrderTJList_new(string lineCode)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,a.prod_desc,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.OutWareHouseQuantity,a.production_sequence FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.est>=date_sub(curdate(),interval 1 day) and a.IsOver=0 ";
if (!string.IsNullOrEmpty(lineCode))
{
sql += " and a.line_code='" + lineCode + "' ";
}
sql += "order by a.line_code,a.est,a.production_sequence ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取可用物料数量
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetMaterielNoNumber(string materiel_no)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT IFNULL(sum(materiel_num),0) as materiel_num FROM base_cararea WHERE area_no IN(SELECT area_no FROM base_area WHERE ware_house IN (1,3,4)) AND car_status != 2 AND materiel_no = '" + materiel_no + "' ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
public DataTable GetMaterielNoNumber_xb(string line_code, string materiel_no)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = "";
if (line_code == "C线")
{
sql = "SELECT IFNULL(SUM(materiel_num),0) AS materiel_num_add FROM base_cararea WHERE area_no IN (SELECT area_no FROM base_area WHERE ware_house = 5) AND materiel_no = '" + materiel_no + "' ";
}
else if (line_code == "B线")
{
sql = "SELECT IFNULL(SUM(materiel_num),0) AS materiel_num_add FROM base_cararea WHERE area_no IN (SELECT area_no FROM base_area WHERE ware_house = 6) AND materiel_no = '" + materiel_no + "' ";
}
else if (line_code == "F线")
{
sql = "SELECT IFNULL(SUM(materiel_num),0) AS materiel_num_add FROM base_cararea WHERE area_no IN (17,18,19) AND materiel_no = '" + materiel_no + "' ";
}
else
{
sql = " SELECT IFNULL(SUM(materiel_num),0) AS materiel_num_add FROM base_cararea WHERE area_no IN (44,10,11,12,13,14,15,16) AND materiel_no = '" + materiel_no + "' ";
}
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取订单上件数量
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetMaterielNoNumber_dingdan()
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT * FROM base_production_order_split a LEFT JOIN base_materialinfobom b ON a.prod_code = b.materiel_finish_no ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 修改订单数量
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int SetUpdateOrderNum(string order_code, int num)
{
string sql = " update base_production_order_split set UpQuantity=UpQuantity+" + num + " where order_code='" + order_code + "'";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
/// <summary>
/// 修改订单数量
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int SetUpdateOrderLineNum(string order_code, int num)
{
string sql = " update base_production_order_split_line set UpQuantity=UpQuantity+" + num + " where order_code='" + order_code + "'";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
/// <summary>
/// 修改订单上件数量/转入
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int SetUpdateOrderLineNum_zhuanruCK(string order_code, int num)
{
string sql = " UPDATE base_production_order_split SET OutWareHouseQuantity = OutWareHouseQuantity + '" + num + "' WHERE order_code = '" + order_code + "'";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
/// <summary>
/// 修改订单上件数量/转入
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static int SetUpdateOrderLineNum_zhuanru(string order_code, int num)
{
string sql = " UPDATE base_production_order_split SET UpQuantity = UpQuantity + '" + num + "' WHERE order_code = '" + order_code + "'";
int ret = DbHelperSQLServer.ExecuteNonQuery(sql);
return ret;
}
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetOrderZYList(string order_code)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.outwarehousequantity FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.upquantity>a.outwarehousequantity and order_code='" + order_code + "' order by a.line_code,a.est ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetOrderZYList(string order_code, string aa)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.outwarehousequantity FROM base_production_order_split a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where order_code='" + order_code + "' order by a.line_code,a.est ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取订单信息
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public DataTable GetOrderZFZYList(string order_code)
{
//string sql = @"select materialno,MaterialBarNo,count(1) as carno from basedata_carrealinfo where IsOutLocator=0 and MaterialNo<>'' group by materialno,MaterialBarNo order by CarNo desc;";
string sql = @" SELECT a.id,a.order_code,case a.line_code when 'D3' then 'A线' when 'TV' then 'B线' when 'TQ' then 'C线' when 'W8' then 'F线' end line_code,a.prod_code,b.materiel_box_no,a.est,a.Quantity,a.UpQuantity,a.outwarehousequantity FROM base_production_order_split_line a LEFT JOIN base_materialinfobom b on a.prod_code = b.materiel_finish_no where a.upquantity>a.outwarehousequantity and order_code='" + order_code + "' and order_status=4 order by a.line_code,a.est ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
添加查看日志
2 years ago
1
2 years ago
/// <summary>
/// 获取库位内物料明细
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static DataTable GetLocatorMaterialGroup(string where)
{
string sql = @"
select aa.materialno,aa.MaterialBarNo,(ifnull(aa.number,0)-ifnull(bb.number,0) ) as number,ifnull(cc.number,0) as total
from (select basedata_carrealinfo.materialno,MaterialBarNo
,sum(ifnull(basedata_carrealinfo.HadNumber,0)) as number
from basedata_carrealinfo
where basedata_carrealinfo.MaterialNo<>'' and ( basedata_carrealinfo.locatorid>0
or basedata_carrealinfo.IsProOutLocator=1 ) group by basedata_carrealinfo.materialno,MaterialBarNo) aa
left join (select basedata_offlinemateriallist.materialno
,count(1) as number
from basedata_offlinemateriallist where isdeleted=0 and IsOver=0 and Number=1
group by basedata_offlinemateriallist.materialno) bb on aa.materialno=bb.materialno
left join (select basedata_offlinemateriallist_detail.materialno
,count(1) as number
from basedata_offlinemateriallist_detail where isdeleted=0
group by basedata_offlinemateriallist_detail.materialno) cc on aa.materialno=cc.materialno
order by aa.materialno desc
";
// string sql = @"
//select basedata_carrealinfo.materialno,MaterialBarNo
//,sum(ifnull(basedata_carrealinfo.HadNumber,0)) as number
//from basedata_carrealinfo
// where basedata_carrealinfo.MaterialNo<>'' and (basedata_carrealinfo.locatorid>0
// or basedata_carrealinfo.IsProOutLocator=1)
//group by basedata_carrealinfo.materialno,MaterialBarNo";
// string sql = @"
//select aa.materialno,aa.MaterialBarNo,(ifnull(aa. number,0)-ifnull(bb.number,0) ) as carno
// from (select basedata_carrealinfo.materialno,MaterialBarNo
//,sum(ifnull(basedata_carrealinfo.HadNumber,0)) as number
//from basedata_carrealinfo
// where basedata_carrealinfo.MaterialNo<>'' and basedata_carrealinfo.locatorid>0
//group by basedata_carrealinfo.materialno,MaterialBarNo) aa
// left join (select basedata_offlinemateriallist.materialno
//,count(1) as number
//from basedata_offlinemateriallist where isover=0 and Number>0 group by basedata_offlinemateriallist.materialno) bb on aa.materialno=bb.materialno
//order by carno desc
//";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取库位内物料明细
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static DataTable GetUpLIneMaterialView(int weekno)
{
string sql = @"
select a.MaterialNo,a.MaterialBarNo,a.HadNumber ,a.MaxNumber,a.AreaNo,ifnull(amount,0) as amount,ifnull(total,0) total
from (
select a.MaterialNo,MaterialBarNo,sum(Number) as HadNumber ,b.MaxNumber,b.AreaNo
from (
select a.MaterialNo,MaterialBarNo,LocatorId as LocatorId,count(1) as Number
from basedata_carrealinfo a
where a.MaterialNo<>'' and LocatorId>0
group by a.MaterialNo,MaterialBarNo,LocatorId
union all
select b.MaterialNo,MaterialBarNo,LocatorNodeId as LocatorId ,count(1) as Number
from basedata_carrealinfo b
where b.MaterialNo<>'' and LocatorNodeId>0
group by b.MaterialNo,MaterialBarNo,LocatorNodeId ) a
left join basedata_linecatcharea b on (a.LocatorId=b.Id )
where a.MaterialNo<>''
group by a.MaterialNo,MaterialBarNo,b.AreaNo,b.MaxNumber
) a left join (select productcode,ifnull(amount,0) as amount,(ifnull(amount,0)-sum(ifnull(b.Number,0))) as total from basedata_orderplan a
left join basedata_uplinescancarlist b on a.productcode=b.materialno and WEEK(b.createtime)=" + weekno + @"
where a.planweek=" + weekno + @" group by productcode,amount ) b
on a.materialno=b.productcode
ORDER BY a.AreaNo desc";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 从mes获取 扫描时间端内的条码信息
/// </summary>
/// <param name="bdt"></param>
/// <param name="edt"></param>
/// <returns></returns>
public static DataTable GetOffLineMaterialByMESView(string bdt, string edt)
{
string sql = @" select * from basedata_offlinemateriallist_his where createtime<='" + bdt + "' and createtime>='" + edt + "'; ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0 && dtset.Tables[0].Rows.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
public static int AddSystemLog(string titel, string message)
{
string strSql = "insert into sysnotices(Title,Content) values(@titel,@message);";
MySqlParameter[] parameters = { new MySqlParameter("@titel", titel), new MySqlParameter("@message", message) };
object obj = DbHelperSQLServer.ExecuteScalar(strSql, parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
public static int AddSystemLog(string titel, CarRealInfo car)
{
string carstr = "CarNo:" + car.CarNo + ",CurrNodeId:" + car.CurrNodeId + ",IsOutLocator:" + car.IsOutLocator + ",IsProOutLocator:" + car.IsProOutLocator + ",Number:" + car.Number + ",HadNumber:" + car.HadNumber + ",MaterialNo:" + car.MaterialNo + ",OffMaterialId:" + car.OffMaterialId + ",CreateDt:" + car.OutLocatorDt + ",OptDt:" + car.OptDt + ",LocatorId:" + car.LocatorId + ",IsOver:" + car.IsOver + ",";
string strSql = "insert into sysnotices(Title,Content,createtime) values(@titel,@message,now());";
MySqlParameter[] parameters = { new MySqlParameter("@titel", titel), new MySqlParameter("@message", carstr) };
object obj = DbHelperSQLServer.ExecuteScalar(strSql, parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 增加一条数据
/// </summary>
public static int AddOffLineMaterialList(OffLineMaterialList model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into basedata_offlinemateriallist(");
strSql.Append("MaterialNo,ProductBarNo,IsOver,IsDeleted,CreateTime,CreateId,CreateBy,ModifyTime,ModifyId,ModifyBy,Number,CarCode,TrayCode,LineNo");
strSql.Append(") values (");
strSql.Append("@MaterialNo,@ProductBarNo,@IsOver,@IsDeleted,@CreateTime,@CreateId,@CreateBy,@ModifyTime,@ModifyId,@ModifyBy,@Number,@CarCode,@TrayCode,@LineNo");
strSql.Append(") ");
strSql.Append(";select @@IDENTITY");
MySqlParameter[] parameters = {
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ProductBarNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@IsOver", MySqlDbType.Int32,11) ,
new MySqlParameter("@IsDeleted", MySqlDbType.Int32,1) ,
new MySqlParameter("@CreateTime", MySqlDbType.DateTime) ,
new MySqlParameter("@CreateId", MySqlDbType.Int32,11) ,
new MySqlParameter("@CreateBy", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ModifyTime", MySqlDbType.DateTime) ,
new MySqlParameter("@ModifyId", MySqlDbType.Int32,11) ,
new MySqlParameter("@ModifyBy", MySqlDbType.VarChar,50),
new MySqlParameter("@Number", MySqlDbType.VarChar,50),
new MySqlParameter("@CarCode", MySqlDbType.VarChar,50),
new MySqlParameter("@TrayCode", MySqlDbType.VarChar,50),
new MySqlParameter("@LineNo", MySqlDbType.VarChar,50),
};
parameters[0].Value = model.MaterialNo;
parameters[1].Value = model.ProductBarNo;
parameters[2].Value = model.IsOver;
parameters[3].Value = model.IsDeleted;
parameters[4].Value = model.CreateTime;
parameters[5].Value = model.CreateId;
parameters[6].Value = model.CreateBy;
parameters[7].Value = model.ModifyTime;
parameters[8].Value = model.ModifyId;
parameters[9].Value = model.ModifyBy;
parameters[10].Value = model.Number;
parameters[11].Value = model.CarCode;
parameters[12].Value = model.MaterialDes;
parameters[13].Value = model.LineNo;
object obj = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 增加一条数据
/// </summary>
public static int AddOffLineMaterialDetailList(OffLineMaterialList model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into basedata_offlinemateriallist_detail(");
strSql.Append("MaterialNo,ProductBarNo,IsOver,IsDeleted,CreateTime,CreateId,CreateBy,ModifyTime,ModifyId,ModifyBy,Number,CarCode,TrayCode,LineNo");
strSql.Append(") values (");
strSql.Append("@MaterialNo,@ProductBarNo,@IsOver,@IsDeleted,@CreateTime,@CreateId,@CreateBy,@ModifyTime,@ModifyId,@ModifyBy,@Number,@CarCode,@TrayCode,@LineNo");
strSql.Append(") ");
strSql.Append(";select @@IDENTITY");
MySqlParameter[] parameters = {
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ProductBarNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@IsOver", MySqlDbType.Int32,11) ,
new MySqlParameter("@IsDeleted", MySqlDbType.Int32,1) ,
new MySqlParameter("@CreateTime", MySqlDbType.DateTime) ,
new MySqlParameter("@CreateId", MySqlDbType.Int32,11) ,
new MySqlParameter("@CreateBy", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ModifyTime", MySqlDbType.DateTime) ,
new MySqlParameter("@ModifyId", MySqlDbType.Int32,11) ,
new MySqlParameter("@ModifyBy", MySqlDbType.VarChar,50),
new MySqlParameter("@Number", MySqlDbType.VarChar,50),
new MySqlParameter("@CarCode", MySqlDbType.VarChar,50),
new MySqlParameter("@TrayCode", MySqlDbType.VarChar,50),
new MySqlParameter("@LineNo", MySqlDbType.VarChar,50),
};
parameters[0].Value = model.MaterialNo;
parameters[1].Value = model.ProductBarNo;
parameters[2].Value = model.IsOver;
parameters[3].Value = model.IsDeleted;
parameters[4].Value = model.CreateTime;
parameters[5].Value = model.CreateId;
parameters[6].Value = model.CreateBy;
parameters[7].Value = model.ModifyTime;
parameters[8].Value = model.ModifyId;
parameters[9].Value = model.ModifyBy;
parameters[10].Value = model.Number;
parameters[11].Value = model.CarCode;
parameters[12].Value = model.MaterialDes;
parameters[13].Value = model.LineNo;
object obj = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 增加一条数据
/// </summary>
public static int AddOffLineMaterialHistoryList(OffLineMaterialList model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into basedata_offlinemateriallist_his(");
strSql.Append("MaterialNo,ProductBarNo,IsOver,IsDeleted,CreateTime,CreateId,CreateBy,ModifyTime,ModifyId,ModifyBy,Number,CarCode,TrayCode,LineNo");
strSql.Append(") values (");
strSql.Append("@MaterialNo,@ProductBarNo,@IsOver,@IsDeleted,@CreateTime,@CreateId,@CreateBy,@ModifyTime,@ModifyId,@ModifyBy,@Number,@CarCode,@TrayCode,@LineNo");
strSql.Append(") ");
strSql.Append(";select @@IDENTITY");
MySqlParameter[] parameters = {
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ProductBarNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@IsOver", MySqlDbType.Int32,11) ,
new MySqlParameter("@IsDeleted", MySqlDbType.Int32,1) ,
new MySqlParameter("@CreateTime", MySqlDbType.DateTime) ,
new MySqlParameter("@CreateId", MySqlDbType.Int32,11) ,
new MySqlParameter("@CreateBy", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ModifyTime", MySqlDbType.DateTime) ,
new MySqlParameter("@ModifyId", MySqlDbType.Int32,11) ,
new MySqlParameter("@ModifyBy", MySqlDbType.VarChar,50),
new MySqlParameter("@Number", MySqlDbType.VarChar,50),
new MySqlParameter("@CarCode", MySqlDbType.VarChar,50),
new MySqlParameter("@TrayCode", MySqlDbType.VarChar,50),
new MySqlParameter("@LineNo", MySqlDbType.VarChar,50),
};
parameters[0].Value = model.MaterialNo;
parameters[1].Value = model.ProductBarNo;
parameters[2].Value = model.IsOver;
parameters[3].Value = model.IsDeleted;
parameters[4].Value = model.CreateTime;
parameters[5].Value = model.CreateId;
parameters[6].Value = model.CreateBy;
parameters[7].Value = model.ModifyTime;
parameters[8].Value = model.ModifyId;
parameters[9].Value = model.ModifyBy;
parameters[10].Value = model.Number;
parameters[11].Value = model.CarCode;
parameters[12].Value = model.MaterialDes;
parameters[13].Value = model.LineNo;
object obj = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 更新一条数据
/// </summary>
public static bool UpdateOffLineMaterialList(OffLineMaterialList model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("update basedata_offlinemateriallist set ");
strSql.Append(" MaterialNo = @MaterialNo , ");
strSql.Append(" ProductBarNo = @ProductBarNo , ");
strSql.Append(" LineNo = @LineNo , ");
strSql.Append(" IsOver = @IsOver , ");
strSql.Append(" IsDeleted = @IsDeleted , ");
strSql.Append(" CreateTime = @CreateTime , ");
strSql.Append(" CreateId = @CreateId , ");
strSql.Append(" CreateBy = @CreateBy , ");
strSql.Append(" ModifyTime = @ModifyTime , ");
strSql.Append(" ModifyId = @ModifyId , ");
strSql.Append(" CarCode = @CarCode , ");
strSql.Append(" LeftNoData = @LeftNoData , ");
strSql.Append(" RightNoData = @RightNoData , ");
strSql.Append(" Number = @Number ");
strSql.Append(" where Id=@Id ");
MySqlParameter[] parameters = {
new MySqlParameter("@Id", MySqlDbType.Int32,11) ,
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ProductBarNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@LineNo", MySqlDbType.Int32,11) ,
new MySqlParameter("@IsOver", MySqlDbType.Int32,11) ,
new MySqlParameter("@IsDeleted", MySqlDbType.Int32,1) ,
new MySqlParameter("@CreateTime", MySqlDbType.DateTime) ,
new MySqlParameter("@CreateId", MySqlDbType.Int32,11) ,
new MySqlParameter("@CreateBy", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ModifyTime", MySqlDbType.DateTime) ,
new MySqlParameter("@ModifyId", MySqlDbType.Int32,11) ,
new MySqlParameter("@CarCode", MySqlDbType.VarChar,50),
new MySqlParameter("@Number", MySqlDbType.VarChar,50),
new MySqlParameter("@LeftNoData", MySqlDbType.VarChar,50),
new MySqlParameter("@RightNoData", MySqlDbType.VarChar,50)
};
parameters[0].Value = model.Id;
parameters[1].Value = model.MaterialNo;
parameters[2].Value = model.ProductBarNo;
parameters[3].Value = model.LineNo;
parameters[4].Value = model.IsOver;
parameters[5].Value = model.IsDeleted;
parameters[6].Value = model.CreateTime;
parameters[7].Value = model.CreateId;
parameters[8].Value = model.CreateBy;
parameters[9].Value = model.ModifyTime;
parameters[10].Value = model.ModifyId;
parameters[11].Value = model.CarCode;
parameters[12].Value = model.Number;
parameters[13].Value = model.LeftNoData;
parameters[14].Value = model.RightNoData;
int rows = DbHelperSQLServer.ExecuteNonQuery(strSql.ToString(), parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
public static List<OffLineMaterialList> getOffLineMaterialLists(string strwhere)
{
List<OffLineMaterialList> list = new List<OffLineMaterialList>();
string sql = @"select * FROM basedata_offlinemateriallist where isdeleted=0 " + strwhere + " order by createtime; ";
DataSet ds = DbHelperSQLServer.Query(sql);
if (ds != null && ds.Tables.Count > 0)
{
for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
{
OffLineMaterialList model = new OffLineMaterialList();
if (ds.Tables[0].Rows[i]["Id"].ToString() != "")
{
model.Id = int.Parse(ds.Tables[0].Rows[i]["Id"].ToString());
}
model.MaterialNo = ds.Tables[0].Rows[i]["MaterialNo"].ToString();
model.ProductBarNo = ds.Tables[0].Rows[i]["ProductBarNo"].ToString();
if (ds.Tables[0].Rows[i]["Number"].ToString() != "")
{
model.Number = int.Parse(ds.Tables[0].Rows[i]["Number"].ToString());
}
if (ds.Tables[0].Rows[i]["CarCode"].ToString() != "")
{
model.CarCode = ds.Tables[0].Rows[i]["CarCode"].ToString();
}
if (ds.Tables[0].Rows[i]["IsOver"].ToString() != "")
{
model.IsOver = int.Parse(ds.Tables[0].Rows[i]["IsOver"].ToString());
}
if (ds.Tables[0].Rows[i]["IsDeleted"].ToString() != "")
{
model.IsDeleted = ds.Tables[0].Rows[i]["IsDeleted"].ToString() == "False" ? 0 : 1;
}
if (ds.Tables[0].Rows[i]["CreateTime"].ToString() != "")
{
model.CreateTime = DateTime.Parse(ds.Tables[0].Rows[i]["CreateTime"].ToString());
}
if (ds.Tables[0].Rows[i]["CreateId"].ToString() != "")
{
model.CreateId = int.Parse(ds.Tables[0].Rows[i]["CreateId"].ToString());
}
if (ds.Tables[0].Rows[i]["LeftNoData"].ToString() != "")
{
model.LeftNoData = int.Parse(ds.Tables[0].Rows[i]["LeftNoData"].ToString());
}
if (ds.Tables[0].Rows[i]["RightNoData"].ToString() != "")
{
model.RightNoData = int.Parse(ds.Tables[0].Rows[i]["RightNoData"].ToString());
}
model.CreateBy = ds.Tables[0].Rows[i]["CreateBy"].ToString();
if (ds.Tables[0].Rows[i]["ModifyTime"].ToString() != "")
{
model.ModifyTime = DateTime.Parse(ds.Tables[0].Rows[i]["ModifyTime"].ToString());
}
if (ds.Tables[0].Rows[i]["ModifyId"].ToString() != "")
{
model.ModifyId = int.Parse(ds.Tables[0].Rows[i]["ModifyId"].ToString());
}
model.ModifyBy = ds.Tables[0].Rows[i]["ModifyBy"].ToString();
list.Add(model);
}
}
return list;
}
/// <summary>
/// 增加一条数据
/// </summary>
public int Addofflinemateriallist(OffLineMaterialList model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into basedata_offlinemateriallist(");
strSql.Append("MaterialNo,ProductBarNo,LineNo,IsOver,IsDeleted,CreateTime,CreateId,CreateBy,ModifyTime,ModifyId,ModifyBy,Number");
strSql.Append(") values (");
strSql.Append("@MaterialNo,@ProductBarNo,@LineNo,@IsOver,@IsDeleted,@CreateTime,@CreateId,@CreateBy,@ModifyTime,@ModifyId,@ModifyBy,@Number");
strSql.Append(") ");
strSql.Append(";select @@IDENTITY");
MySqlParameter[] parameters = {
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ProductBarNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@LineNo", MySqlDbType.Int32,11) ,
new MySqlParameter("@IsOver", MySqlDbType.Int32,11) ,
new MySqlParameter("@IsDeleted", MySqlDbType.Int32,1) ,
new MySqlParameter("@CreateTime", MySqlDbType.DateTime) ,
new MySqlParameter("@CreateId", MySqlDbType.Int32,11) ,
new MySqlParameter("@CreateBy", MySqlDbType.VarChar,50) ,
new MySqlParameter("@ModifyTime", MySqlDbType.DateTime) ,
new MySqlParameter("@ModifyId", MySqlDbType.Int32,11) ,
new MySqlParameter("@ModifyBy", MySqlDbType.VarChar,50),
new MySqlParameter("@Number", MySqlDbType.VarChar,50)
};
parameters[0].Value = model.MaterialNo;
parameters[1].Value = model.ProductBarNo;
//parameters[2].Value = model.LineNo;
parameters[3].Value = model.IsOver;
parameters[4].Value = model.IsDeleted;
parameters[5].Value = model.CreateTime;
parameters[6].Value = model.CreateId;
parameters[7].Value = model.CreateBy;
parameters[8].Value = model.ModifyTime;
parameters[9].Value = model.ModifyId;
parameters[10].Value = model.ModifyBy;
parameters[11].Value = model.Number;
object obj = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 增加一条数据
/// </summary>
public int AddOffProductInfo(OffProductInfo model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into basedata_offproductinfo(");
strSql.Append("ProductBarno,MaterialNo,LineNo,IsDeleted,CreateTime,CreateId,CreateBy,ModifyTime,ModifyId,ModifyBy");
strSql.Append(") values (");
strSql.Append("@ProductBarno,@MaterialNo,@LineNo,@IsDeleted,@CreateTime,@CreateId,@CreateBy,@ModifyTime,@ModifyId,@ModifyBy");
strSql.Append(") ");
strSql.Append(";select @@IDENTITY");
MySqlParameter[] parameters = {
new MySqlParameter("@ProductBarno", MySqlDbType.VarChar,50) ,
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@LineNo", MySqlDbType.Int32,11) ,
new MySqlParameter("@IsDeleted", MySqlDbType.Int32,1) ,
new MySqlParameter("@CreateTime", MySqlDbType.DateTime) ,
new MySqlParameter("@CreateId", MySqlDbType.Int32,11) ,
new MySqlParameter("@CreateBy", MySqlDbType.LongText) ,
new MySqlParameter("@ModifyTime", MySqlDbType.DateTime) ,
new MySqlParameter("@ModifyId", MySqlDbType.Int32,11) ,
new MySqlParameter("@ModifyBy", MySqlDbType.LongText)
};
parameters[0].Value = model.ProductBarno;
parameters[1].Value = model.MaterialNo;
parameters[2].Value = model.LineNo;
object obj = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
/// <summary>
/// 修改点位放行状态
/// </summary>
/// <param name="carid"></param>
/// <param name="val"></param>
/// <returns></returns>
public static int UpdateNodesettingState(int nodeid, int val)
{
string sqlstr = "update basedata_nodesetting set IsClearCar=@val where id=@id";
MySqlParameter[] parameters = {
new MySqlParameter("@id", MySqlDbType.Int32,4) ,
new MySqlParameter("@val", MySqlDbType.Int32,4)
};
parameters[0].Value = nodeid;
parameters[1].Value = val;
return DbHelperSQLServer.ExecuteNonQuery(sqlstr, parameters);
}
/// <summary>
/// 修改小车时候结束状态
/// </summary>
/// <param name="carid"></param>
/// <param name="val"></param>
/// <returns></returns>
public static int UpdateCarOverState(int carno, int val)
{
string sqlstr = "update basedata_carrealinfo set IsOver=@val where carno=@id";
MySqlParameter[] parameters = {
new MySqlParameter("@id", MySqlDbType.Int32,4) ,
new MySqlParameter("@val", MySqlDbType.Int32,4)
};
parameters[0].Value = carno;
parameters[1].Value = val;
return DbHelperSQLServer.ExecuteNonQuery(sqlstr, parameters);
}
/// <summary>
/// 修改小车时候结束状态
/// </summary>
/// <param name="carid"></param>
/// <param name="val"></param>
/// <returns></returns>
public static int SetLocatorMaterial(int locatorid, string val, string val1)
{
string sqlstr = "update basedata_linecatcharea set materialno='" + val + "' , materialnm='" + val1 + "' where id=" + locatorid + ";";
return DbHelperSQLServer.ExecuteNonQuery(sqlstr);
}
/// <summary>
/// 获取点位关系列表
/// </summary>
/// <param name="strWhere"></param>
/// <returns></returns>
public static List<NodePrecuss> getNodeRelation(string strWhere)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(@" select * from basedata_nodeprecuss a INNER join basedata_nodesetting b on a.PreNodeId=b.Id INNER join basedata_nodesetting c on a.AfterNodeId=c.Id where a.isdeleted=0;");
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
List<NodePrecuss> list = new List<NodePrecuss>();
if (ds.Tables[0].Rows.Count > 0)
{
for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
{
NodePrecuss model = new NodePrecuss();
if (ds.Tables[0].Rows[i]["Id"].ToString() != "")
{
model.Id = int.Parse(ds.Tables[0].Rows[i]["Id"].ToString());
}
if (ds.Tables[0].Rows[i]["PreNodeId"].ToString() != "")
{
model.PreNodeId = int.Parse(ds.Tables[0].Rows[i]["PreNodeId"].ToString());
}
if (ds.Tables[0].Rows[i]["AfterNodeId"].ToString() != "")
{
model.AfterNodeId = int.Parse(ds.Tables[0].Rows[i]["AfterNodeId"].ToString());
}
if (ds.Tables[0].Rows[i]["NodeValue"].ToString() != "")
{
model.NodeValue = int.Parse(ds.Tables[0].Rows[i]["NodeValue"].ToString());
}
model.PreNodeSetting = new NodeSetting();
if (ds.Tables[0].Rows[i]["Id1"].ToString() != "")
{
model.PreNodeSetting.Id = int.Parse(ds.Tables[0].Rows[i]["Id1"].ToString());
}
model.PreNodeSetting.NodeNo = ds.Tables[0].Rows[i]["NodeNo"].ToString();
model.PreNodeSetting.NodeDesc = ds.Tables[0].Rows[i]["NodeDesc"].ToString();
if (ds.Tables[0].Rows[i]["PlcId"].ToString() != "")
{
model.PreNodeSetting.PlcId1 = int.Parse(ds.Tables[0].Rows[i]["PlcId"].ToString());
}
if (ds.Tables[0].Rows[i]["NodeType"].ToString() != "")
{
model.PreNodeSetting.NodeType = int.Parse(ds.Tables[0].Rows[i]["NodeType"].ToString());
}
if (ds.Tables[0].Rows[i]["LineAreaId"].ToString() != "")
{
model.PreNodeSetting.LineAreaId = int.Parse(ds.Tables[0].Rows[i]["LineAreaId"].ToString());
}
if (ds.Tables[0].Rows[i]["IsStaticNumber"].ToString() != "")
{
model.PreNodeSetting.IsStaticNumber = int.Parse(ds.Tables[0].Rows[i]["IsStaticNumber"].ToString());
}
if (ds.Tables[0].Rows[i]["IsClearCar"].ToString() != "")
{
model.PreNodeSetting.IsClearCar = int.Parse(ds.Tables[0].Rows[i]["IsClearCar"].ToString());
}
if (ds.Tables[0].Rows[i]["LocalThriftip"].ToString() != "")
{
model.PreNodeSetting.LocalThriftip = ds.Tables[0].Rows[i]["LocalThriftip"].ToString();
}
if (ds.Tables[0].Rows[i]["LocalThriftport"].ToString() != "")
{
model.PreNodeSetting.LocalThriftport = int.Parse(ds.Tables[0].Rows[i]["LocalThriftport"].ToString());
}
if (ds.Tables[0].Rows[i]["ServerThriftport"].ToString() != "")
{
model.PreNodeSetting.ServerThriftport = int.Parse(ds.Tables[0].Rows[i]["ServerThriftport"].ToString());
}
model.AfterNodeSetting = new NodeSetting();
if (ds.Tables[0].Rows[i]["Id2"].ToString() != "")
{
model.AfterNodeSetting.Id = int.Parse(ds.Tables[0].Rows[i]["Id2"].ToString());
}
model.AfterNodeSetting.NodeNo = ds.Tables[0].Rows[i]["NodeNo1"].ToString();
model.AfterNodeSetting.NodeDesc = ds.Tables[0].Rows[i]["NodeDesc1"].ToString();
if (ds.Tables[0].Rows[i]["PlcId1"].ToString() != "")
{
model.AfterNodeSetting.PlcId1 = int.Parse(ds.Tables[0].Rows[i]["PlcId1"].ToString());
}
if (ds.Tables[0].Rows[i]["NodeType1"].ToString() != "")
{
model.AfterNodeSetting.NodeType = int.Parse(ds.Tables[0].Rows[i]["NodeType1"].ToString());
}
if (ds.Tables[0].Rows[i]["LineAreaId1"].ToString() != "")
{
model.AfterNodeSetting.LineAreaId = int.Parse(ds.Tables[0].Rows[i]["LineAreaId1"].ToString());
}
if (ds.Tables[0].Rows[i]["IsStaticNumber1"].ToString() != "")
{
model.AfterNodeSetting.IsStaticNumber = int.Parse(ds.Tables[0].Rows[i]["IsStaticNumber1"].ToString());
}
if (ds.Tables[0].Rows[i]["IsClearCar1"].ToString() != "")
{
model.AfterNodeSetting.IsClearCar = int.Parse(ds.Tables[0].Rows[i]["IsClearCar1"].ToString());
}
if (ds.Tables[0].Rows[i]["LocalThriftip"].ToString() != "")
{
model.PreNodeSetting.LocalThriftip = ds.Tables[0].Rows[i]["LocalThriftip"].ToString();
}
if (ds.Tables[0].Rows[i]["LocalThriftport"].ToString() != "")
{
model.PreNodeSetting.LocalThriftport = int.Parse(ds.Tables[0].Rows[i]["LocalThriftport"].ToString());
}
if (ds.Tables[0].Rows[i]["ServerThriftport"].ToString() != "")
{
model.PreNodeSetting.ServerThriftport = int.Parse(ds.Tables[0].Rows[i]["ServerThriftport"].ToString());
}
list.Add(model);
}
}
return list;
}
/// <summary>
/// 获取小车实时数据缓存,便于启动初始化
/// </summary>
/// <param name="strWhere"></param>
/// <returns></returns>
public static List<CarRealInfo> getCarInfoList(string strWhere, List<LineCatchArea> arealist, List<CarMaterial> materialist, List<CarProduct> productlist)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(@" select * from basedata_carrealinfo a
left join basedata_nodesetting b on a.CurrNodeId=b.Id
where a.isdeleted=0 order by a.OptDt ");
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
List<CarRealInfo> list = new List<CarRealInfo>();
if (ds.Tables[0].Rows.Count > 0)
{
for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
{
CarRealInfo model = new CarRealInfo();
model.CarNo = ds.Tables[0].Rows[i]["CarNo"].ToString();
model.LoadingMaterial = materialist.Where(t => t.carNo == model.CarNo).ToList();
model.LoadingProduct = productlist.Where(t => t.carNo == model.CarNo).ToList();
model.MaterialNo = ds.Tables[0].Rows[i]["MaterialNo"].ToString();
model.MaterialBarNo = ds.Tables[0].Rows[i]["MaterialBarNo"].ToString();
if (ds.Tables[0].Rows[i]["CurrNodeId"].ToString() != "")
{
model.CurrNodeId = int.Parse(ds.Tables[0].Rows[i]["CurrNodeId"].ToString());
}
if (ds.Tables[0].Rows[i]["LocatorNodeId"].ToString() != "")
{
model.LocatorNodeId = int.Parse(ds.Tables[0].Rows[i]["LocatorNodeId"].ToString());
model.ProLocatorArea = arealist != null ? arealist.FirstOrDefault(t => t.Id == model.LocatorNodeId) : null;
}
if (ds.Tables[0].Rows[i]["IsOver"].ToString() != "")
{
model.IsOver = int.Parse(ds.Tables[0].Rows[i]["IsOver"].ToString());
}
if (ds.Tables[0].Rows[i]["HadNumber"].ToString() != "")
{
model.HadNumber = int.Parse(ds.Tables[0].Rows[i]["HadNumber"].ToString());
}
if (ds.Tables[0].Rows[i]["LocatorId"].ToString() != "")
{
model.LocatorId = int.Parse(ds.Tables[0].Rows[i]["LocatorId"].ToString());
model.LocatorArea = arealist != null ? arealist.FirstOrDefault(t => t.Id == model.LocatorId) : null;
}
if (ds.Tables[0].Rows[i]["OptDt"].ToString() != "")
{
model.OptDt = DateTime.Parse(ds.Tables[0].Rows[i]["OptDt"].ToString());
}
if (ds.Tables[0].Rows[i]["createtime"].ToString() != "")
{
model.OutLocatorDt = DateTime.Parse(ds.Tables[0].Rows[i]["createtime"].ToString());
}
if (ds.Tables[0].Rows[i]["Id"].ToString() != "")
{
model.Id = int.Parse(ds.Tables[0].Rows[i]["Id"].ToString());
}
if (ds.Tables[0].Rows[i]["Number"].ToString() != "")
{
model.Number = int.Parse(ds.Tables[0].Rows[i]["Number"].ToString());
}
if (ds.Tables[0].Rows[i]["OffMaterialId"].ToString() != "")
{
model.OffMaterialId = int.Parse(ds.Tables[0].Rows[i]["OffMaterialId"].ToString());
}
if (ds.Tables[0].Rows[i]["IsOutLocator"].ToString() != "")
{
model.IsOutLocator = int.Parse(ds.Tables[0].Rows[i]["IsOutLocator"].ToString());
}
if (ds.Tables[0].Rows[i]["IsProOutLocator"].ToString() != "")
{
model.IsProOutLocator = int.Parse(ds.Tables[0].Rows[i]["IsProOutLocator"].ToString());
}
model.CurrNodeSetting = new NodeSetting();
if (ds.Tables[0].Rows[i]["Id1"].ToString() != "")
{
model.CurrNodeSetting.Id = int.Parse(ds.Tables[0].Rows[i]["Id1"].ToString());
}
model.CurrNodeSetting.NodeNo = ds.Tables[0].Rows[i]["NodeNo"].ToString();
model.CurrNodeSetting.NodeDesc = ds.Tables[0].Rows[i]["NodeDesc"].ToString();
if (ds.Tables[0].Rows[i]["PlcId"].ToString() != "")
{
model.CurrNodeSetting.PlcId1 = int.Parse(ds.Tables[0].Rows[i]["PlcId"].ToString());
}
if (ds.Tables[0].Rows[i]["NodeType"].ToString() != "")
{
model.CurrNodeSetting.NodeType = int.Parse(ds.Tables[0].Rows[i]["NodeType"].ToString());
}
if (ds.Tables[0].Rows[i]["LineAreaId"].ToString() != "")
{
model.CurrNodeSetting.LineAreaId = int.Parse(ds.Tables[0].Rows[i]["LineAreaId"].ToString());
}
if (ds.Tables[0].Rows[i]["IsStaticNumber"].ToString() != "")
{
model.CurrNodeSetting.IsStaticNumber = int.Parse(ds.Tables[0].Rows[i]["IsStaticNumber"].ToString());
}
if (ds.Tables[0].Rows[i]["IsClearCar"].ToString() != "")
{
model.CurrNodeSetting.IsClearCar = int.Parse(ds.Tables[0].Rows[i]["IsClearCar"].ToString());
}
if (ds.Tables[0].Rows[i]["LocalThriftip"].ToString() != "")
{
model.CurrNodeSetting.LocalThriftip = ds.Tables[0].Rows[i]["LocalThriftip"].ToString();
}
if (ds.Tables[0].Rows[i]["LocalThriftport"].ToString() != "")
{
model.CurrNodeSetting.LocalThriftport = int.Parse(ds.Tables[0].Rows[i]["LocalThriftport"].ToString());
}
if (ds.Tables[0].Rows[i]["ServerThriftport"].ToString() != "")
{
model.CurrNodeSetting.ServerThriftport = int.Parse(ds.Tables[0].Rows[i]["ServerThriftport"].ToString());
}
// model.LocatorNodeSetting = new NodeSetting();
//if (ds.Tables[0].Rows[i]["Id2"].ToString() != "")
//{
// model.LocatorNodeSetting.Id = int.Parse(ds.Tables[0].Rows[i]["Id2"].ToString());
//}
//model.LocatorNodeSetting.NodeNo = ds.Tables[0].Rows[i]["NodeNo1"].ToString();
//model.LocatorNodeSetting.NodeDesc = ds.Tables[0].Rows[i]["NodeDesc1"].ToString();
//if (ds.Tables[0].Rows[i]["PlcId1"].ToString() != "")
//{
// model.LocatorNodeSetting.PlcId1 = int.Parse(ds.Tables[0].Rows[i]["PlcId1"].ToString());
//}
//if (ds.Tables[0].Rows[i]["NodeType1"].ToString() != "")
//{
// model.LocatorNodeSetting.NodeType = int.Parse(ds.Tables[0].Rows[i]["NodeType1"].ToString());
//}
//if (ds.Tables[0].Rows[i]["LineAreaId1"].ToString() != "")
//{
// model.LocatorNodeSetting.LineAreaId = int.Parse(ds.Tables[0].Rows[i]["LineAreaId1"].ToString());
//}
//if (ds.Tables[0].Rows[i]["IsStaticNumber1"].ToString() != "")
//{
// model.LocatorNodeSetting.IsStaticNumber = int.Parse(ds.Tables[0].Rows[i]["IsStaticNumber1"].ToString());
//}
//if (ds.Tables[0].Rows[i]["IsClearCar1"].ToString() != "")
//{
// model.LocatorNodeSetting.IsClearCar = int.Parse(ds.Tables[0].Rows[i]["IsClearCar1"].ToString());
//}
list.Add(model);
}
}
return list;
}
/// <summary>
/// 获取小车实时数据缓存,便于启动初始化
/// </summary>
/// <param name="strWhere"></param>
/// <returns></returns>
public static List<CarRealInfo> getOutCarInfo()
{
StringBuilder strSql = new StringBuilder();
strSql.Append(@" select carno,a.materialno,a.materialbarno,b.areano,a.createtime from basedata_carrealinfo a
left join basedata_linecatcharea b on a.locatorid=b.id
where a.isdeleted=0 and isoutlocator=1 order by a.createtime ");
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
List<CarRealInfo> list = new List<CarRealInfo>();
if (ds.Tables[0].Rows.Count > 0)
{
for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
{
CarRealInfo model = new CarRealInfo();
model.CarNo = ds.Tables[0].Rows[i]["carno"].ToString();
model.MaterialNo = ds.Tables[0].Rows[i]["materialno"].ToString();
model.MaterialBarNo = ds.Tables[0].Rows[i]["materialbarno"].ToString();
model.LineAreaNo = ds.Tables[0].Rows[i]["areano"].ToString();
model.TimeStr = DateTime.Parse(ds.Tables[0].Rows[i]["createtime"].ToString()).ToString("yyyy-MM-dd HH:mm:ss");
list.Add(model);
}
}
return list;
}
/// <summary>
/// 获取小车实时数据缓存,便于启动初始化
/// </summary>
/// <param name="strWhere"></param>
/// <returns></returns>
public static List<CarRealInfo> getCurrCarInfo(string carno)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(@" select carno,a.materialno,a.materialbarno,b.areano,a.optdt,c.nodeno from basedata_carrealinfo a
left join basedata_linecatcharea b on a.locatorid=b.id
left join basedata_nodesetting c on a.CurrNodeId=c.id
where carno=@carno ");
MySqlParameter param = new MySqlParameter("@carno", carno);
DataSet ds = DbHelperSQLServer.Query(strSql.ToString(), param);
List<CarRealInfo> list = new List<CarRealInfo>();
if (ds.Tables[0].Rows.Count > 0)
{
for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
{
CarRealInfo model = new CarRealInfo();
model.CarNo = ds.Tables[0].Rows[i]["carno"].ToString();
model.MaterialNo = ds.Tables[0].Rows[i]["materialno"].ToString();
model.MaterialBarNo = ds.Tables[0].Rows[i]["materialbarno"].ToString();
model.LineAreaNo = ds.Tables[0].Rows[i]["areano"].ToString();
model.TimeStr = DateTime.Parse(ds.Tables[0].Rows[i]["optdt"].ToString()).ToString("yyyy-MM-dd HH:mm:ss");
model.CurrNodeNo = ds.Tables[0].Rows[i]["nodeno"].ToString();
list.Add(model);
}
}
return list;
}
/// <summary>
/// 修改订单表上件 下件数量
/// </summary>
/// <param name="id"></param>
/// <param name="UpDownType">0: 上件总数量 1 :下件数量修改</param>
/// <returns></returns>
public static int UpdatePlanOrderAmount(int id, int UpDownType)
{
string sqlstr = "";
if (UpDownType == 0)
{
sqlstr = "UPDATE basedata_orderplan set upAmount=UpAmount+1 where id=@id";
}
else
{
sqlstr = "UPDATE basedata_orderplan set downAount=downAount+1 where id=@id";
}
MySqlParameter[] parameters = {
new MySqlParameter("@id", MySqlDbType.Int32,4) ,
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50)
};
parameters[0].Value = id;
parameters[1].Value = UpDownType;
return DbHelperSQLServer.ExecuteNonQuery(sqlstr, parameters);
}
public static DateTime GetLastTime()
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select max(createtime) from basedata_offlinemateriallist_his where isdeleted=0 ;");
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
if (ds.Tables[0].Rows.Count > 0 && ds.Tables[0].Rows[0][0] != DBNull.Value)
{
return Convert.ToDateTime(ds.Tables[0].Rows[0][0]);
}
return DateTime.Now.AddMinutes(-10);
}
/// <summary>
/// 增加一条数据
/// </summary>
public static int AddProductInfo(Productinfo model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into basedata_productinfo(");
strSql.Append("ProductBarno,MaterialNo,IsDeleted,CreateTime,CreateId,CreateBy,ModifyTime,ModifyId,ModifyBy");
strSql.Append(") values (");
strSql.Append("@ProductBarno,@MaterialNo,@IsDeleted,@CreateTime,@CreateId,@CreateBy,@ModifyTime,@ModifyId,@ModifyBy");
strSql.Append(") ");
strSql.Append(";select @@IDENTITY");
MySqlParameter[] parameters = {
new MySqlParameter("@ProductBarno", MySqlDbType.VarChar,50) ,
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@IsDeleted", MySqlDbType.Int32,1) ,
new MySqlParameter("@CreateTime", MySqlDbType.DateTime) ,
new MySqlParameter("@CreateId", MySqlDbType.Int32,11) ,
new MySqlParameter("@CreateBy", MySqlDbType.LongText) ,
new MySqlParameter("@ModifyTime", MySqlDbType.DateTime) ,
new MySqlParameter("@ModifyId", MySqlDbType.Int32,11) ,
new MySqlParameter("@ModifyBy", MySqlDbType.LongText)
};
parameters[0].Value = model.ProductBarno;
parameters[1].Value = model.MaterialNo;
parameters[2].Value = model.IsDeleted;
parameters[3].Value = model.CreateTime;
parameters[4].Value = model.CreateId;
parameters[5].Value = model.CreateBy;
parameters[6].Value = model.ModifyTime;
parameters[7].Value = model.ModifyId;
parameters[8].Value = model.ModifyBy;
object obj = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (obj == null)
{
return 0;
}
else
{
return Convert.ToInt32(obj);
}
}
//public static List<UpLineMaterialList> getUpLineMaterialLists(string strwhere)
//{
// List<UpLineMaterialList> list = new List<UpLineMaterialList>();
// StringBuilder strSql = new StringBuilder();
// strSql.Append("select * from basedata_uplinemateriallist ");
// DataSet ds = DbHelperMySQL.Query(strSql.ToString());
// if (ds.Tables[0].Rows.Count > 0)
// {
// for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
// {
// UpLineMaterialList model = new UpLineMaterialList();
// if (ds.Tables[0].Rows[i]["Id"].ToString() != "")
// {
// model.Id = int.Parse(ds.Tables[0].Rows[i]["Id"].ToString());
// }
// model.MaterialNo = ds.Tables[0].Rows[i]["MaterialNo"].ToString();
// model.ProductBarNo = ds.Tables[0].Rows[i]["ProductBarNo"].ToString();
// model.LineNo = ds.Tables[0].Rows[i]["LineNo"].ToString();
// if (ds.Tables[0].Rows[i]["IsOver"].ToString() != "")
// {
// model.IsOver = int.Parse(ds.Tables[0].Rows[i]["IsOver"].ToString());
// }
// list.Add(model);
// }
// }
// return list;
//}
public static List<UpLineScanCarList> getUpLineScanCarLists(string strwhere)
{
List<UpLineScanCarList> list = new List<UpLineScanCarList>();
StringBuilder strSql = new StringBuilder();
strSql.Append("select * from basedata_uplinescancarlist where isdeleted=0;");
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
if (ds.Tables[0].Rows.Count > 0)
{
for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
{
UpLineScanCarList model = new UpLineScanCarList();
if (ds.Tables[0].Rows[i]["Id"].ToString() != "")
{
model.Id = int.Parse(ds.Tables[0].Rows[i]["Id"].ToString());
}
model.MaterialNo = ds.Tables[0].Rows[i]["MaterialNo"].ToString();
model.CarNo = ds.Tables[0].Rows[i]["Carcode"].ToString();
model.LineNo = ds.Tables[0].Rows[i]["LineNo"].ToString();
if (ds.Tables[0].Rows[i]["IsOver"].ToString() != "")
{
model.IsOver = int.Parse(ds.Tables[0].Rows[i]["IsOver"].ToString());
}
if (ds.Tables[0].Rows[i]["number"].ToString() != "")
{
model.Number = int.Parse(ds.Tables[0].Rows[i]["number"].ToString());
}
list.Add(model);
}
}
return list;
}
/// <summary>
/// 删除一条数据
/// </summary>
public static bool DeleteUpLineMaterial(int Id)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("delete from basedata_uplinescancarlist ");
strSql.Append(" where Id=@Id ");
MySqlParameter[] parameters = {
new MySqlParameter("@Id", MySqlDbType.Int32,11) };
parameters[0].Value = Id;
int rows = DbHelperSQLServer.ExecuteNonQuery(strSql.ToString(), parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 删除一条数据
/// </summary>
public static bool DeleteOffLineMaterial(int Id)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("delete from basedata_offlinemateriallist ");
strSql.Append(" where Id=@Id ");
MySqlParameter[] parameters = {
new MySqlParameter("@Id", MySqlDbType.Int32,11) };
parameters[0].Value = Id;
int rows = DbHelperSQLServer.ExecuteNonQuery(strSql.ToString(), parameters);
if (rows > 0)
{
return true;
}
else
{
return false;
}
}
///// <summary>
///// 增加一条数据
///// </summary>
//public static int AddUpLineMaterial(UpLineMaterialList model)
//{
// StringBuilder strSql = new StringBuilder();
// strSql.Append("insert into basedata_uplinemateriallist(");
// strSql.Append("Id,MaterialNo,ProductBarNo,LineNo");
// strSql.Append(") values (");
// strSql.Append("@Id,@MaterialNo,@ProductBarNo,@LineNo");
// strSql.Append(");select @@IDENTITY ");
// MySqlParameter[] parameters = {
// new MySqlParameter("@Id", MySqlDbType.Int32,11) ,
// new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
// new MySqlParameter("@ProductBarNo", MySqlDbType.VarChar,50) ,
// new MySqlParameter("@LineNo", MySqlDbType.Int32,11) ,
// //new MySqlParameter("@IsDeleted", MySqlDbType.Int32,1) ,
// //new MySqlParameter("@CreateTime", MySqlDbType.DateTime) ,
// //new MySqlParameter("@CreateId", MySqlDbType.Int32,11) ,
// //new MySqlParameter("@CreateBy", MySqlDbType.LongText) ,
// //new MySqlParameter("@ModifyTime", MySqlDbType.DateTime) ,
// //new MySqlParameter("@ModifyId", MySqlDbType.Int32,11) ,
// //new MySqlParameter("@ModifyBy", MySqlDbType.LongText)
// };
// parameters[0].Value = model.Id;
// parameters[1].Value = model.MaterialNo;
// parameters[2].Value = model.ProductBarNo;
// // parameters[3].Value = model.LineNo;
// //parameters[4].Value = model.IsDeleted;
// //parameters[5].Value = model.CreateTime;
// //parameters[6].Value = model.CreateId;
// //parameters[7].Value = model.CreateBy;
// //parameters[8].Value = model.ModifyTime;
// //parameters[9].Value = model.ModifyId;
// //parameters[10].Value = model.ModifyBy;
// int id = 0;
// object ret = DbHelperMySQL.ExecuteScalar(strSql.ToString(), parameters);
// if (ret != null && ret != DBNull.Value)
// {
// id = Convert.ToInt32(ret);
// }
// return id;
//}
/// <summary>
/// 增加一条数据
/// </summary>
public static int AddUpLineScancar(UpLineScanCarList model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into basedata_uplinescancarlist(");
strSql.Append("Id,MaterialNo,CarNo,MaterialBarCode,ProductMaterialNo,LineNo,Number,CreateTime,IsDeleted");
strSql.Append(") values (");
strSql.Append("@Id,@MaterialNo,@CarNo,@MaterialBarCode,@ProductMaterialNo,@LineNo,@Number,now(),0");
strSql.Append(");select @@IDENTITY ");
MySqlParameter[] parameters = {
new MySqlParameter("@Id", MySqlDbType.Int32,11) ,
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@CarNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@MaterialBarCode",MySqlDbType.VarChar,50) ,
new MySqlParameter("@ProductMaterialNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@LineNo", MySqlDbType.VarChar,50) ,
new MySqlParameter("@Number", MySqlDbType.Int32,11) ,
};
parameters[0].Value = model.Id;
parameters[1].Value = model.MaterialNo;
parameters[2].Value = model.CarNo;
parameters[3].Value = model.MaterialBarCode;
parameters[4].Value = model.ProductMaterialNo;
parameters[5].Value = model.LineNo;
parameters[6].Value = model.Number;
int id = 0;
object ret = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (ret != null && ret != DBNull.Value)
{
id = Convert.ToInt32(ret);
}
return id;
}
/// <summary>
/// 查询时序订单
/// </summary>
/// <param name="strWhere"></param>
/// <returns></returns>
public static List<Orderplan> getOrderPlanList(string strWhere)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select a.*,b.material_name FROM base_orderinfo a left join ");
strSql.Append("base_materialinfo b on a.material_no = b.material_no where a.is_delete = 0 and b.is_delete = 0 ");
if (strWhere.Trim() != "")
{
strSql.Append(" where " + strWhere);
}
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
List<Orderplan> list = new List<Orderplan>();
if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
{
for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
{
Orderplan model = new Orderplan();
if (ds.Tables[0].Rows[i]["id"].ToString() != "")
{
model.id = ds.Tables[0].Rows[i]["id"].ToString(); //id
}
model.orderNo = ds.Tables[0].Rows[i]["order_no"].ToString();//订单号
model.productCode = ds.Tables[0].Rows[i]["material_no"].ToString();//物料号
model.productDesc = ds.Tables[0].Rows[i]["material_name"].ToString();//物料描述
if (ds.Tables[0].Rows[i]["product_amount"].ToString() != "")
{
model.amount = int.Parse(ds.Tables[0].Rows[i]["product_amount"].ToString()); //计划数量
}
//model.planType = ds.Tables[0].Rows[i]["planType"].ToString(); //类型 需求计划类型（0:T - 1需求计划,1:两小时时序计划）
if (ds.Tables[0].Rows[i]["product_sortno"].ToString() != "")
{
model.PlanOrder = int.Parse(ds.Tables[0].Rows[i]["product_sortno"].ToString());//顺序号
}
if (ds.Tables[0].Rows[i]["plan_state"].ToString() != "")
{
model.planState = int.Parse(ds.Tables[0].Rows[i]["plan_state"].ToString());//计划状态
}
if (ds.Tables[0].Rows[i]["plan_starttime"].ToString() != "")
{
model.planStartTime = DateTime.Parse(ds.Tables[0].Rows[i]["plan_starttime"].ToString());//计划日期
}
if (ds.Tables[0].Rows[i]["up_amount"].ToString() != "")
{
model.upAmount = int.Parse(ds.Tables[0].Rows[i]["up_amount"].ToString());//上件数量
}
if (ds.Tables[0].Rows[i]["down_amount"].ToString() != "")
{
model.downAmount = int.Parse(ds.Tables[0].Rows[i]["down_amount"].ToString());//下件数量
}
list.Add(model);
}
}
return list;
}
public static DataTable getOrderPlanDt(string strWhere)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select ProductCode,ProductDesc as selectitem FROM basedata_orderplan where isdeleted=0; ");
if (strWhere.Trim() != "")
{
strSql.Append(" where " + strWhere);
}
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
List<Orderplan> list = new List<Orderplan>();
if (ds.Tables[0].Rows.Count > 0)
{
return ds.Tables[0];
}
return null; ;
}
新增修改班次时间模块
1 year ago
public static DataTable getShiftTime()
{
StringBuilder strSql = new StringBuilder();
strSql.Append("SELECT t.Shift_Code,t.Shift_Desc,t.Shift_Start_Time,Shift_End_Time from base_shifts_t t where del_flag=0");
DataSet ds = Utils.netClientDBHelper.getDataSet(strSql.ToString());
List<Orderplan> list = new List<Orderplan>();
if (ds.Tables[0].Rows.Count > 0)
{
return ds.Tables[0];
}
return null; ;
}
public static bool ModShiftTime(string Code,string beginTime,string endTime, string Code1, string beginTime1, string endTime1)
{
List<string> sqlList = new List<string>();
string sql=@"update base_shifts_t set Shift_Start_Time='"+ beginTime + "', Shift_End_Time='"+ endTime + "' where del_flag = 0 and Shift_Code = '"+ Code + "'";
string sql1 = @"update base_shifts_t set Shift_Start_Time='" + beginTime1 + "', Shift_End_Time='" + endTime1 + "' where del_flag = 0 and Shift_Code = '" + Code1 + "'";
sqlList.Add(sql); sqlList.Add(sql1);
bool result = Utils.netClientDBHelper.executeBatchSql(sqlList);
return result;
}
1
2 years ago
/// <summary>
/// 是否存在该小车记录
/// </summary>
/// <param name="CarNo">主键值</param>
/// <returns>是否存在</returns>
public static bool ExistsCarRealInfo(string CarNo)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select count(1) from BaseData_CarRealInfo");
strSql.Append(" where CarNo = @CarNo ");
MySqlParameter[] parameters = {
new MySqlParameter("@CarNo", MySqlDbType.VarChar,50)
};
parameters[0].Value = CarNo;
return Convert.ToInt32(DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters)) != 0;
}
/// <summary>
/// 增加一条数据
/// </summary>
/// <param name="model">model</param>
public static int AddCarRealRecord(CarRealInfo model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(@"
insert into BaseData_CarRealInfo(CarNo,MaterialNo,MaterialBarNo,CurrNodeId,LocatorNodeId,LocatorId,OptDt,OffMaterialId,Number,IsOver,HadNumber,createtime)
values (@CarNo,@MaterialNo,@MaterialBarNo,@CurrNodeId,@LocatorNodeId,@LocatorId,@OptDt,@OffMaterialId,@Number,0,@HadNumber,now())");
strSql.Append(@"
; select @@identity; ");
MySqlParameter[] parameters = {
new MySqlParameter("@CarNo", MySqlDbType.VarChar,50),
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50),
new MySqlParameter("@MaterialBarNo", MySqlDbType.VarChar,50),
new MySqlParameter("@CurrNodeId", MySqlDbType.Int32),
new MySqlParameter("@LocatorNodeId", MySqlDbType.Int32),
new MySqlParameter("@LocatorId", MySqlDbType.Int32),
new MySqlParameter("@OptDt", MySqlDbType.DateTime),
new MySqlParameter("@OffMaterialId", MySqlDbType.Int32),
new MySqlParameter("@Number", MySqlDbType.Int32),
new MySqlParameter("@HadNumber", MySqlDbType.Int32)
};
parameters[0].Value = model.CarNo;
parameters[1].Value = model.MaterialNo;
parameters[2].Value = model.MaterialBarNo;
parameters[3].Value = model.CurrNodeId;
parameters[4].Value = model.LocatorNodeId;
parameters[5].Value = model.LocatorId;
parameters[6].Value = DateTime.Now;
parameters[7].Value = model.OffMaterialId;
parameters[8].Value = model.Number;
parameters[9].Value = model.HadNumber;
int id = 0;
object ret = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (ret != null && ret != DBNull.Value)
{
id = Convert.ToInt32(ret);
}
return id;
}
/// <summary>
/// 更新一条数据
/// </summary>
/// <param name="model">model</param>
public static void ModifyRealCarinfoRecord(CarRealInfo model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(@"
update BaseData_CarRealInfo set
MaterialNo=@MaterialNo,
MaterialBarNo=@MaterialBarNo,
CurrNodeId=@CurrNodeId,
LocatorNodeId=@LocatorNodeId,
LocatorId=@LocatorId,
OffMaterialId=@OffMaterialId,
IsOver=@IsOver,
Number=@Number,
Number=@Number,
OptDt=@OptDt,
IsProOutLocator=@IsProOutLocator,
IsOutLocator=@IsOutLocator,
HadNumber=@HadNumber
,createtime=now()
where CarNo = @CarNo ");
MySqlParameter[] parameters = {
new MySqlParameter("@CarNo", MySqlDbType.VarChar,50),
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50),
new MySqlParameter("@MaterialBarNo", MySqlDbType.VarChar,50),
new MySqlParameter("@CurrNodeId", MySqlDbType.Int32),
new MySqlParameter("@LocatorNodeId", MySqlDbType.Int32),
new MySqlParameter("@LocatorId", MySqlDbType.Int32),
new MySqlParameter("@OptDt", MySqlDbType.DateTime),
new MySqlParameter("@OffMaterialId", MySqlDbType.Int32),
new MySqlParameter("@Number", MySqlDbType.Int32),
new MySqlParameter("@IsOver", MySqlDbType.Int32),
new MySqlParameter("@IsProOutLocator", MySqlDbType.Int32),
new MySqlParameter("@IsOutLocator", MySqlDbType.Int32),
new MySqlParameter("@HadNumber", MySqlDbType.Int32),
// new MySqlParameter("@CreateTime", MySqlDbType.DateTime),
};
parameters[0].Value = model.CarNo;
parameters[1].Value = model.MaterialNo;
parameters[2].Value = model.MaterialBarNo;
parameters[3].Value = model.CurrNodeId;
parameters[4].Value = model.LocatorNodeId;
parameters[5].Value = model.LocatorId;
parameters[6].Value = model.OptDt;
parameters[7].Value = model.OffMaterialId;
parameters[8].Value = model.Number;
parameters[9].Value = model.IsOver;
parameters[10].Value = model.IsProOutLocator;
parameters[11].Value = model.IsOutLocator;
parameters[12].Value = model.HadNumber;
// parameters[12].Value = model.CreateDt;
DbHelperSQLServer.ExecuteNonQuery(strSql.ToString(), parameters);
}
/// <summary>
/// 增加一条数据
/// </summary>
/// <param name="model">model</param>
public static int AddCarHistoryRecord(CarRealInfo model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(@"
insert into BaseData_CarHistoryInfo(CarNo,MaterialNo,MaterialBarNo,CurrNodeId,LocatorNodeId,LocatorId,OptDt,OffMaterialId,Number,IsOver)
values (@CarNo,@MaterialNo,@MaterialBarNo,@CurrNodeId,@LocatorNodeId,@LocatorId,@OptDt,@OffMaterialId,@Number,0)");
strSql.Append(@"
; select @@identity; ");
MySqlParameter[] parameters = {
new MySqlParameter("@CarNo", MySqlDbType.VarChar,50),
new MySqlParameter("@MaterialNo", MySqlDbType.VarChar,50),
new MySqlParameter("@MaterialBarNo", MySqlDbType.VarChar,50),
new MySqlParameter("@CurrNodeId", MySqlDbType.Int32),
new MySqlParameter("@LocatorNodeId", MySqlDbType.Int32),
new MySqlParameter("@LocatorId", MySqlDbType.Int32),
new MySqlParameter("@OptDt", MySqlDbType.DateTime),
new MySqlParameter("@OffMaterialId", MySqlDbType.Int32),
new MySqlParameter("@Number", MySqlDbType.Int32)
};
parameters[0].Value = model.CarNo;
parameters[1].Value = model.MaterialNo;
parameters[2].Value = model.MaterialBarNo;
parameters[3].Value = model.CurrNodeId;
parameters[4].Value = model.LocatorNodeId;
parameters[5].Value = model.LocatorId;
parameters[6].Value = DateTime.Now;
parameters[7].Value = model.OffMaterialId;
parameters[8].Value = model.Number;
int id = 0;
object ret = DbHelperSQLServer.ExecuteScalar(strSql.ToString(), parameters);
if (ret != null && ret != DBNull.Value)
{
id = Convert.ToInt32(ret);
}
return id;
}
/// <summary>
/// 得到一个model
/// </summary>
/// <param name="CarNo">主键值</param>
/// <returns>model</returns>
public static CarRealInfo GetCarModel(string CarNo)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(@"
select *
from BaseData_CarRealInfo");
strSql.Append(@"
where CarNo = @CarNo ");
MySqlParameter[] parameters = {
new MySqlParameter("@CarNo", MySqlDbType.VarChar,50)
};
parameters[0].Value = CarNo;
CarRealInfo model = new CarRealInfo();
DataSet ds = DbHelperSQLServer.Query(strSql.ToString(), parameters);
if (ds.Tables[0].Rows.Count > 0)
{
DataRow row = ds.Tables[0].Rows[0];
if (row["Id"] != DBNull.Value)
{
model.Id = Convert.ToInt32(row["Id"]);
}
if (row["CarNo"] != DBNull.Value)
{
model.CarNo = Convert.ToString(row["CarNo"]);
}
if (row["IsOver"] != DBNull.Value)
{
model.IsOver = Convert.ToInt32(row["IsOver"]);
}
if (row["MaterialNo"] != DBNull.Value)
{
model.MaterialNo = Convert.ToString(row["MaterialNo"]);
}
if (row["MaterialBarNo"] != DBNull.Value)
{
model.MaterialBarNo = Convert.ToString(row["MaterialBarNo"]);
}
if (row["CurrNodeId"] != DBNull.Value)
{
model.CurrNodeId = Convert.ToInt32(row["CurrNodeId"]);
}
if (row["LocatorNodeId"] != DBNull.Value)
{
model.LocatorNodeId = Convert.ToInt32(row["LocatorNodeId"]);
}
if (row["LocatorId"] != DBNull.Value)
{
model.LocatorId = Convert.ToInt32(row["LocatorId"]);
}
if (row["OptDt"] != DBNull.Value)
{
model.OptDt = Convert.ToDateTime(row["OptDt"]);
}
return model;
}
else
{
return null;
}
}
///// <summary>
///// 获取线体列表
///// </summary>
///// <param name="where"></param>
///// <returns></returns>
//public static List<LineInfo> GetLineInfoList(string where)
//{
// List<LineInfo> list = new List<LineInfo>();
// string sql = "select * from basedata_lineinfo ";
// DataSet dtset = DbHelperMySQL.Query(sql);
// if (dtset != null && dtset.Tables.Count > 0)
// {
// foreach (DataRow row in dtset.Tables[0].Rows)
// {
// LineInfo model = new LineInfo();
// if (row["Id"] != DBNull.Value)
// {
// model.Id = Convert.ToInt32(row["Id"]);
// }
// if (row["LineNumber"] != DBNull.Value)
// {
// model.LineNumber = Convert.ToString(row["LineNumber"]);
// }
// if (row["LineNm"] != DBNull.Value)
// {
// model.LineNm = Convert.ToString(row["LineNm"]);
// }
// if (row["LineNo"] != DBNull.Value)
// {
// model.LineNo = Convert.ToString(row["LineNo"]);
// }
// if (row["LineType"] != DBNull.Value)
// {
// model.LineType = Convert.ToInt32(row["LineType"]);
// }
// list.Add(model);
// }
// }
// return list;
//}
/// <summary>
/// 获取线体缓存区列表
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static List<LineCatchArea> GetLineCatchAreaList(string where)
{
List<LineCatchArea> list = new List<LineCatchArea>();
string sql = "select * from basedata_linecatcharea where isdeleted=0 " + where;
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0)
{
foreach (DataRow row in dtset.Tables[0].Rows)
{
LineCatchArea model = new LineCatchArea();
if (row["Id"] != DBNull.Value)
{
model.Id = Convert.ToInt32(row["Id"]);
}
if (row["AreaNo"] != DBNull.Value)
{
model.AreaNo = Convert.ToString(row["AreaNo"]);
}
model.MaterialNo = row["Materialno"].ToString();
model.MaterialNm = row["MaterialNm"].ToString();
if (row["AreaNm"] != DBNull.Value)
{
model.AreaNm = Convert.ToString(row["AreaNm"]);
}
if (row["LineNo"] != DBNull.Value)
{
model.LineNo = row["LineNo"].ToString();
}
if (row["AreaType"].ToString() != "")
{
model.AreaType = int.Parse(row["AreaType"].ToString());
}
if (row["MaxNumber"].ToString() != "")
{
model.MaxNumber = int.Parse(row["MaxNumber"].ToString());
}
if (row["AreaStorageType"].ToString() != "")
{
model.AreaStorageType = int.Parse(row["AreaStorageType"].ToString());
}
list.Add(model);
}
}
return list;
}
/// <summary>
/// 获取线体缓存区列表
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static DataTable GetLineCatchAreaDt(string where)
{
List<LineCatchArea> list = new List<LineCatchArea>();
string sql = "select areano as selectitem from basedata_linecatcharea where isdeleted=0 " + where;
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0)
{
return dtset.Tables[0];
}
return null;
}
/// <summary>
/// 获取PLC配置列表
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static Dictionary<string, PlcSetting> GetPlcSettingList(string where)
{
Dictionary<string, PlcSetting> list = new Dictionary<string, PlcSetting>();
string sql = "select * from BaseData_PlcSetting where isdeleted=0";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0)
{
foreach (DataRow row in dtset.Tables[0].Rows)
{
PlcSetting model = new PlcSetting();
if (row["Id"] != DBNull.Value)
{
model.Id = Convert.ToInt32(row["Id"]);
}
if (row["PlcNo"] != DBNull.Value)
{
model.PlcNo = Convert.ToString(row["PlcNo"]);
}
if (row["PlcAddress"] != DBNull.Value)
{
model.PlcAddress = Convert.ToString(row["PlcAddress"]);
}
if (row["PlcValueLength"] != DBNull.Value)
{
model.PlcValueLength = Convert.ToString(row["PlcValueLength"]);
}
if (row["PlcDataType"] != DBNull.Value)
{
model.PlcDataType = Convert.ToInt32(row["PlcDataType"]);
}
list.Add(model.PlcNo, model);
}
}
return list;
}
/// <summary>
/// 获取线体预设列表
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static List<LinePreInfo> GetLinePreInfoList(string where)
{
List<LinePreInfo> list = new List<LinePreInfo>();
string sql = "select * from BaseData_LinePreInfo ";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0)
{
foreach (DataRow row in dtset.Tables[0].Rows)
{
LinePreInfo model = new LinePreInfo();
if (row["Id"] != DBNull.Value)
{
model.Id = Convert.ToInt32(row["Id"]);
}
if (row["LinePreNo"] != DBNull.Value)
{
model.LinePreNo = Convert.ToString(row["LinePreNo"]);
}
if (row["LineStartNo"] != DBNull.Value)
{
model.LineStartNo = Convert.ToString(row["LineStartNo"]);
}
if (row["LineEndNo"] != DBNull.Value)
{
model.LineEndNo = Convert.ToString(row["LineEndNo"]);
}
if (row["AllNeedTime"] != DBNull.Value)
{
model.AllNeedTime = Convert.ToInt32(row["AllNeedTime"]);
}
if (row["RunType"] != DBNull.Value)
{
model.RunType = Convert.ToInt32(row["RunType"]);
}
list.Add(model);
}
}
return list;
}
/// <summary>
/// 获取节点配置列表
/// </summary>
/// <param name="where"></param>
/// <returns></returns>
public static List<NodeSetting> GetNodeSettingList(string where, List<LineCatchArea> Arealist)
{
List<NodeSetting> list = new List<NodeSetting>();
string sql = @"select * from basedata_nodesetting a
left join basedata_plcsetting b on a.PlcId=b.Id
left join basedata_linecatcharea g on g.Id=a.LineAreaId
left join basedata_plcsetting c on a.PlcId2=c.Id
left join basedata_plcsetting d on a.PlcId3=d.Id
left join basedata_plcsetting e on a.PlcId4=e.Id
left join basedata_plcsetting f on a.PlcId5=f.Id
where a.isdeleted=0;
";
DataSet dtset = DbHelperSQLServer.Query(sql);
if (dtset != null && dtset.Tables.Count > 0)
{
foreach (DataRow row in dtset.Tables[0].Rows)
{
NodeSetting model = new NodeSetting();
if (row["Id"] != DBNull.Value)
{
model.Id = Convert.ToInt32(row["Id"]);
}
if (row["NodeNo"] != DBNull.Value)
{
model.NodeNo = Convert.ToString(row["NodeNo"]);
}
if (row["NodeDesc"] != DBNull.Value)
{
model.NodeDesc = Convert.ToString(row["NodeDesc"]);
}
if (row["PlcId"] != DBNull.Value)
{
model.PlcId1 = Convert.ToInt32(row["PlcId"]);
}
if (row["NodeType"] != DBNull.Value)
{
model.NodeType = Convert.ToInt32(row["NodeType"]);
}
if (row["LineAreaId"] != DBNull.Value)
{
model.LineAreaId = Convert.ToInt32(row["LineAreaId"]);
var linearea = Arealist.FirstOrDefault(t => t.Id == model.LineAreaId);
if (linearea != null)
{
model.LineCatchArea = linearea;
}
}
if (row["LocalThriftip"].ToString() != "")
{
model.LocalThriftip = row["LocalThriftip"].ToString();
}
if (row["LocalThriftport"].ToString() != "")
{
model.LocalThriftport = int.Parse(row["LocalThriftport"].ToString());
}
if (row["ServerThriftport"].ToString() != "")
{
model.ServerThriftport = int.Parse(row["ServerThriftport"].ToString());
}
if (row["IsStaticNumber"] != DBNull.Value)
{
model.IsStaticNumber = Convert.ToInt32(row["IsStaticNumber"]);
}
if (row["IsClearCar"] != DBNull.Value)
{
model.IsClearCar = Convert.ToInt32(row["IsClearCar"]);
}
PlcSetting plcmodel = new PlcSetting();
if (row["Id1"] != DBNull.Value)
{
plcmodel.Id = Convert.ToInt32(row["Id1"]);
}
if (row["PlcNo"] != DBNull.Value)
{
plcmodel.PlcNo = Convert.ToString(row["PlcNo"]);
}
if (row["PlcAddress"] != DBNull.Value)
{
plcmodel.PlcAddress = Convert.ToString(row["PlcAddress"]);
}
if (row["PlcValueLength"] != DBNull.Value)
{
plcmodel.PlcValueLength = Convert.ToString(row["PlcValueLength"]);
}
if (row["PlcDataType"] != DBNull.Value)
{
plcmodel.PlcDataType = Convert.ToInt32(row["PlcDataType"]);
}
model.PlcSetting1 = plcmodel;
model.PlcSetting2 = new PlcSetting();
if (row["Id3"] != DBNull.Value)
{
model.PlcSetting2.Id = Convert.ToInt32(row["Id3"]);
}
if (row["PlcNo1"] != DBNull.Value)
{
model.PlcSetting2.PlcNo = Convert.ToString(row["PlcNo1"]);
}
if (row["PlcAddress1"] != DBNull.Value)
{
model.PlcSetting2.PlcAddress = Convert.ToString(row["PlcAddress1"]);
}
if (row["PlcValueLength1"] != DBNull.Value)
{
model.PlcSetting2.PlcValueLength = Convert.ToString(row["PlcValueLength1"]);
}
if (row["PlcDataType1"] != DBNull.Value)
{
model.PlcSetting2.PlcDataType = Convert.ToInt32(row["PlcDataType1"]);
}
model.PlcSetting3 = new PlcSetting();
if (row["Id4"] != DBNull.Value)
{
model.PlcSetting3.Id = Convert.ToInt32(row["Id4"]);
}
if (row["PlcNo2"] != DBNull.Value)
{
model.PlcSetting3.PlcNo = Convert.ToString(row["PlcNo2"]);
}
if (row["PlcAddress2"] != DBNull.Value)
{
model.PlcSetting3.PlcAddress = Convert.ToString(row["PlcAddress2"]);
}
if (row["PlcValueLength2"] != DBNull.Value)
{
model.PlcSetting3.PlcValueLength = Convert.ToString(row["PlcValueLength2"]);
}
if (row["PlcDataType2"] != DBNull.Value)
{
model.PlcSetting3.PlcDataType = Convert.ToInt32(row["PlcDataType2"]);
}
model.PlcSetting4 = new PlcSetting();
if (row["Id5"] != DBNull.Value)
{
model.PlcSetting4.Id = Convert.ToInt32(row["Id5"]);
}
if (row["PlcNo3"] != DBNull.Value)
{
model.PlcSetting4.PlcNo = Convert.ToString(row["PlcNo3"]);
}
if (row["PlcAddress3"] != DBNull.Value)
{
model.PlcSetting4.PlcAddress = Convert.ToString(row["PlcAddress3"]);
}
if (row["PlcValueLength3"] != DBNull.Value)
{
model.PlcSetting4.PlcValueLength = Convert.ToString(row["PlcValueLength3"]);
}
if (row["PlcDataType3"] != DBNull.Value)
{
model.PlcSetting4.PlcDataType = Convert.ToInt32(row["PlcDataType3"]);
}
model.PlcSetting5 = new PlcSetting();
if (row["Id6"] != DBNull.Value)
{
model.PlcSetting5.Id = Convert.ToInt32(row["Id6"]);
}
if (row["PlcNo4"] != DBNull.Value)
{
model.PlcSetting5.PlcNo = Convert.ToString(row["PlcNo4"]);
}
if (row["PlcAddress4"] != DBNull.Value)
{
model.PlcSetting5.PlcAddress = Convert.ToString(row["PlcAddress4"]);
}
if (row["PlcValueLength4"] != DBNull.Value)
{
model.PlcSetting5.PlcValueLength = Convert.ToString(row["PlcValueLength4"]);
}
if (row["PlcDataType4"] != DBNull.Value)
{
model.PlcSetting5.PlcDataType = Convert.ToInt32(row["PlcDataType4"]);
}
list.Add(model);
}
}
return list;
}
/// <summary>
/// 得到一个对象实体集合
/// </summary>
public static List<MaterialInfo> GetMaterialInfoList(string strWhere)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select Id, material_no, material_name, is_delete, DATE_FORMAT(create_time,'%Y-%m-%d %H:%i:%s') create_time, create_id, ");
strSql.Append("create_by, DATE_FORMAT(modify_time, '%Y-%m-%d %H:%i:%s') modify_time, modify_id, modify_by from base_materialinfo");
if (!string.IsNullOrWhiteSpace(strWhere))
strSql.Append(" where isdeleted=0 " + strWhere);
List<MaterialInfo> Items = new List<MaterialInfo>();
DataSet ds = DbHelperSQLServer.Query(strSql.ToString());
if (ds.Tables[0].Rows.Count > 0)
{
foreach (DataRow row in ds.Tables[0].Rows)
{
MaterialInfo model = new MaterialInfo();
if (row["Id"] != DBNull.Value)
{
model.Id = Guid.Parse(row["Id"].ToString());
}
if (row["material_no"] != DBNull.Value)
{
model.MaterialNo = Convert.ToString(row["material_no"]).Trim().ToUpper();
}
if (row["material_name"] != DBNull.Value)
{
model.MaterialNm = Convert.ToString(row["material_name"]);
}
Items.Add(model);
}
}
return Items;
}
// /// <summary>
// /// 获取物料bom列表
// /// </summary>
// /// <param name="where"></param>
// /// <returns></returns>
// public static List<MaterialBom> GetMaterialBomList(string where)
// {
// List<MaterialBom> list = new List<MaterialBom>();
// string sql = @"select a.id,b.id as pid,b.MaterialNo as bmno,b.MaterialNm as bmnm,c.id as cid,c.MaterialNo as cmno,c.MaterialNm as cmnm
// from basedata_materialbom a
//left join basedata_materialinfo b on a.ProductNo=b.MaterialNo
//left join basedata_materialinfo c on a.GateMaterialNo=c.MaterialNo
// where a.isdeleted=0;
// ";
// DataSet dtset = DbHelperMySQL.Query(sql);
// if (dtset != null && dtset.Tables.Count > 0)
// {
// foreach (DataRow row in dtset.Tables[0].Rows)
// {
// MaterialBom model = new MaterialBom();
// model.ParentMaterialInfo = new MaterialInfo();
// model.ChildMaterialInfo = new MaterialInfo();
// if (row["Id"] != DBNull.Value)
// {
// model.Id = Convert.ToInt32(row["Id"]);
// }
// if (row["pid"] != DBNull.Value)
// {
// model.ParentMaterialInfo.Id = Convert.ToInt32(row["pid"]);
// }
// if (row["cid"] != DBNull.Value)
// {
// model.ChildMaterialInfo.Id = Convert.ToInt32(row["pid"]);
// }
// if (row["bmno"] != DBNull.Value)
// {
// model.ParentMaterialInfo.MaterialNo = row["bmno"].ToString();
// model.MaterialNo = row["bmno"].ToString();
// }
// if (row["bmnm"] != DBNull.Value)
// {
// model.ParentMaterialInfo.MaterialNm = row["bmnm"].ToString();
// }
// if (row["cmno"] != DBNull.Value)
// {
// model.ChildMaterialInfo.MaterialNo = row["cmno"].ToString();
// }
// if (row["cmnm"] != DBNull.Value)
// {
// model.ChildMaterialInfo.MaterialNm = row["cmnm"].ToString();
// }
// list.Add(model);
// }
// }
// return list;
// }
新增修改班次时间模块
1 year ago
1
2 years ago
}
}