using System;
|
using System.Data;
|
using System.Linq;
|
using CSFramework.DB;
|
using CSFrameworkV5.Models;
|
using CSFrameworkV5.Core;
|
using CSFrameworkV5.Common;
|
using CSFrameworkV5.Interfaces;
|
using CSFrameworkV5.Business;
|
using CSFrameworkV5.DataAccess;
|
using CSFrameworkV5.Order.womdaa;
|
|
/*===================================================================
|
* 程序说明: WOMDAA的业务逻辑层源码
|
* 作者资料: 孙中吕
|
* 创建日期: 2024/05/20 05:58:20
|
* 最后修改: 2024/05/20 05:58:20
|
*
|
* 注: 本文件由代码生成器(Code Generator)自动生成。
|
* (此源码文件请放置在 YourProject.Business 模块)
|
* 版权所有 Copyright 2006~2024, C/S框架网(www.cscode.net)
|
*===================================================================*/
|
|
namespace CSFrameworkV5.Business
|
{
|
/// <summary>
|
/// 业务逻辑层:bllWOMDAA
|
/// </summary>
|
public class bllWOMDAA : bllBaseBusiness
|
{
|
private dalWOMDAA _DAL = null;
|
|
/// <summary>
|
/// 构造器
|
/// </summary>
|
public bllWOMDAA()
|
{
|
_KeyFieldName = WOMDAA.__KeyName; //主键字段
|
_SummaryTableName = WOMDAA.__TableName; //表名
|
_WriteDataLog = false; //保存数据修改日志
|
_CurrentAppNAME = "排产报工";
|
_DAL = new dalWOMDAA(Loginer.CurrentUser); //实例化DAL层
|
}
|
|
/// <summary>
|
///根据单据号码取业务数据
|
/// </summary>
|
public override DataSet GetDataByKey(string keyValue, bool resetCurrent)
|
{
|
var ds = _DAL.GetDataByKey(keyValue);
|
SetNumericDefaultValue(ds); //设置预设值
|
if (resetCurrent) _CurrentBusiness = ds; //保存当前业务数据的对象引用
|
return ds;
|
}
|
|
/// <summary>
|
///删除单据
|
/// </summary>
|
public override bool Delete(string keyValue)
|
{
|
return _DAL.Delete(keyValue);
|
}
|
|
/// <summary>
|
///检查单号是否存在
|
/// </summary>
|
public bool CheckNoExists(string keyValue)
|
{
|
return _DAL.CheckNoExists(keyValue);
|
}
|
|
/// <summary>
|
///保存数据
|
/// </summary>
|
public override SaveResult Update(DataSet saveData)
|
{
|
return _DAL.Update(saveData); //交给数据层处理
|
}
|
|
/// <summary>
|
///审核单据
|
/// </summary>
|
public override bool ApprovalBusiness(DataRow summaryRow)
|
{
|
var key = ConvertEx.ToString(summaryRow[_KeyFieldName]);
|
|
var P = new QueryApproval
|
{
|
DBID = Loginer.CurrentUser.DBID,
|
TableName = _SummaryTableName,
|
KeyFieldName = _KeyFieldName,
|
KeyValue = key,
|
AppDate = DateTime.Now,
|
AppUser = Loginer.CurrentUser.Account,
|
FlagApp = "Y",
|
AppNAME = _CurrentAppNAME
|
};
|
|
if (_DAL.ApprovalBusiness(P))
|
{
|
summaryRow[CommonFields.AppDate] = DateTime.Now;
|
summaryRow[CommonFields.AppUser] = Loginer.CurrentUser.Account;
|
summaryRow[CommonFields.FlagApp] = "Y";
|
summaryRow[CommonFields.AppNAME] = _CurrentAppNAME;
|
return true;
|
}
|
|
return false;
|
}
|
|
/// <summary>
|
///反审核单据。
|
/// </summary>
|
public override bool ApprovalBusinessUndo(DataRow summaryRow)
|
{
|
var key = ConvertEx.ToString(summaryRow[_KeyFieldName]);
|
|
var P = new QueryApproval
|
{
|
DBID = Loginer.CurrentUser.DBID,
|
TableName = _SummaryTableName,
|
KeyFieldName = _KeyFieldName,
|
KeyValue = key,
|
AppDate = DateTime.Now,
|
AppUser = Loginer.CurrentUser.Account,
|
FlagApp = "N",
|
AppNAME = _CurrentAppNAME
|
};
|
|
if (_DAL.ApprovalBusiness(P))
|
{
|
summaryRow[CommonFields.AppDate] = DateTime.Now;
|
summaryRow[CommonFields.AppUser] = Loginer.CurrentUser.Account;
|
summaryRow[CommonFields.FlagApp] = "N";
|
return true;
|
}
|
else
|
{
|
return false;
|
}
|
}
|
|
/// <summary>
|
///新增一张业务单据
|
/// </summary>
|
public override void NewBusiness()
|
{
|
var summaryTable =
|
_CurrentBusiness.Tables[WOMDAA.__TableName];
|
var row = summaryTable.Rows.Add();
|
|
//新增状态：主表记录设置初始值
|
row[WOMDAA.__KeyName] = Guid.NewGuid();
|
}
|
|
/// <summary>
|
///创建用于保存的临时数据
|
/// </summary>
|
public override DataSet CreateSaveData(DataSet sourceData)
|
{
|
DataBindRow.EndEdit();
|
|
//创建用于保存的临时数据,包含主表或明细表
|
var save = new DataSet();
|
save.Tables.Add(DataBinder.Copy()); //将<主表>添加到数据集
|
|
var row = save.Tables[0].Rows[0];
|
|
var s = row["DAA001"].ToString();
|
|
if (string.IsNullOrEmpty(s))
|
{
|
Msg.Warning("工单号不能为空!");
|
return null;
|
}
|
|
var db = SqlSugarHelper.GetInstance();
|
|
//如果是新增状态下就校验工单是否重复
|
if (row.RowState == DataRowState.Added)
|
{
|
var count = db.Queryable<Models.Order>()
|
.Where(a => a.Daa001 == s).Count();
|
if (count > 0)
|
{
|
Msg.Warning("工单号已存在!");
|
return null;
|
}
|
}
|
//第一次修改的状态是Modified，再次修改时会是Unchanged
|
//也有可能是在详情页中修改的状态是Unchanged
|
else if (row.RowState == DataRowState.Unchanged ||
|
row.RowState == DataRowState.Modified)
|
{
|
//同一个机台下只能存在一个开工
|
|
//工单状态
|
var daa022 = row["DAA022"].ToString();
|
|
//产线
|
var daa042 = row["DAA042"].ToString();
|
var lineNo = row["LINE_NO"].ToString();
|
var deptName = row["DeptName"].ToString();
|
|
if ("开工".Equals(daa022))
|
{
|
//校验跳过自己
|
var single = db.Queryable<Models.Order>()
|
.Where(x => x.Daa022 == daa022 && x.Daa042 == daa042)
|
.Single();
|
|
if (single != null)
|
if (single.Daa001 != s)
|
{
|
var count = db.Queryable<Models.Order>()
|
.Where(s1 => s1.Daa042 == daa042
|
&& s1.Daa022 == daa022
|
&& s1.DeptName == deptName
|
&& s1.LineNo == lineNo).Count();
|
|
if (count > 0)
|
{
|
Msg.Warning(daa042 + "这条产线已经有工单" + daa022 +
|
"，不允许" +
|
daa022 + "新的工单");
|
return null;
|
}
|
}
|
}
|
}
|
//Console.WriteLine(s);
|
|
UpdateCommonFieldsValue(save.Tables[0]); //更新公共字段数据
|
|
//收集明细表数据
|
var detail =
|
sourceData.Tables[DAA01.__TableName].GetChanges();
|
|
|
if (detail != null && detail.Rows.Count > 0)
|
{
|
if (detail.Rows.Count == 1 &&
|
detail.Rows[0].RowState == DataRowState.Deleted)
|
{
|
SqlSugarHelper.UseTransactionWithOracle(db1 =>
|
{
|
var id = row["ID"].ToString();
|
|
return db1.Updateable<Models.Order>()
|
.SetColumns(order => order.ISOk == 0)
|
.Where(order => order.id == id).ExecuteCommand();
|
});
|
}
|
else
|
{
|
//报工后反写已完成数
|
//报工数等于工单数时自动更改为已完工的状态
|
|
var pid = detail.Rows[0]["pid"].ToString();
|
|
|
var single = db.Queryable<Models.Order>()
|
.Where(s1 => s1.id == pid).Single();
|
|
var sum = db.Queryable<SqlDaa01>()
|
.Where(daa01 => daa01.pid == pid).Sum<int>(d => d.ISOK);
|
|
var i = detail.AsEnumerable()
|
.Sum(r => r.Field<int>("ISOK"));
|
|
var sum1 = sum + i;
|
|
var user = Loginer.CurrentUser.Account;
|
var time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
|
SqlSugarHelper.UseTransactionWithOracle(db1 =>
|
{
|
var isUpdateColumns = single.Daa027 <= sum1;
|
|
return db1.Updateable<Models.Order>()
|
.SetColumns(order => order.ISOk == sum1)
|
.SetColumnsIF(isUpdateColumns,
|
order => order.Daa022 == "完工")
|
.SetColumnsIF(isUpdateColumns,
|
order => order.Daa022Date == time)
|
.SetColumnsIF(isUpdateColumns,
|
order => order.Daa022By == user)
|
.Where(order => order.id == pid).ExecuteCommand();
|
});
|
}
|
|
UpdateCommonFieldsValue(detail); //更新明细表的公共字段数据
|
save.Tables.Add(detail); //将<明细表>添加到数据集
|
}
|
|
return save;
|
}
|
|
/// <summary>
|
///查询数据
|
/// </summary>
|
public DataTable Query(QueryWOMDAA P)
|
{
|
return _DAL.Query(P);
|
}
|
|
/// <summary>
|
///获取报表数据
|
/// </summary>
|
public DataSet QueryReportData(QueryWOMDAA P)
|
{
|
return _DAL.QueryReportData(P);
|
}
|
|
public DataTable GETDAT(string sql)
|
{
|
return _DAL.GetDataTable(sql);
|
}
|
}
|
}
|
