You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
509 lines
19 KiB
509 lines
19 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Configuration;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using FireBirdUtil.SqlUtils;
|
|
using Forks.JsonRpc.Client;
|
|
using Forks.JsonRpc.Client.Data;
|
|
using Utils.Datas;
|
|
using WeighBusiness.BO;
|
|
using WeighBusiness.Utils;
|
|
using WeighBusiness.Utils.SqlUtils;
|
|
|
|
namespace WeighBusiness.BL
|
|
{
|
|
public static class ProductPlanBL
|
|
{
|
|
public static List<long> GetAllLocalProduceBatchDetailID()
|
|
{
|
|
var sql = "select ProducePlan_ID from {0}".FormatWith(TableNames.生产计划);
|
|
var table = SqlHelperEx.DoQuery(sql);
|
|
if (table.Rows.Count == 0)
|
|
return null;
|
|
var detailIds = new List<long>();
|
|
foreach (DataRow row in table.Rows) {
|
|
detailIds.Add((long)((int)row[0]));
|
|
}
|
|
return detailIds;
|
|
}
|
|
|
|
public static List<ProductPlan> GetProductPlanRowVersion()
|
|
{
|
|
var table = SqlHelperEx.DoQuery("select ProductPlan_ID,RowVersion from {0}".FormatWith(TableNames.生产计划));
|
|
if (table.Rows.Count == 0)
|
|
return new List<ProductPlan>();
|
|
var list = new List<ProductPlan>();
|
|
foreach (DataRow row in table.Rows) {
|
|
var plan = new ProductPlan();
|
|
plan.ProductPlan_ID = (long)(int.Parse(row[0].ToString()));
|
|
plan.RowVersion = int.Parse(row[1].ToString());
|
|
list.Add(plan);
|
|
}
|
|
return list;
|
|
}
|
|
|
|
public static void Insert(List<ProductPlan> plans, List<ButcherDetail> butcherDetails,List<ProductBatch> batchs)
|
|
{
|
|
using (var she = new SqlHelperEx()) {
|
|
she.CreateTransaction();
|
|
bool success = false;
|
|
string errorMessage;
|
|
if (plans.Count() > 0) {
|
|
foreach (var plan in plans) {
|
|
string insertSql = InsertUtil.GetInsertSql(TableNames.生产计划,
|
|
new string[] { "ProductPlan_ID", "PlanDate", "RowVersion" },
|
|
new string[] { plan.ProductPlan_ID.ToString(), plan.PlanDate.ToString(), plan.RowVersion.ToString() });
|
|
she.ExecuteNonQuery(insertSql, out success, out errorMessage);
|
|
if (!success && !string.IsNullOrEmpty(errorMessage)) {
|
|
she.Rollback();
|
|
throw new ApplicationException(errorMessage);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (butcherDetails.Count() > 0) {
|
|
foreach (var detail in butcherDetails) {
|
|
string insertSql = InsertUtil.GetInsertSql(TableNames.生产计划分割明细,
|
|
new string[] { "ProductPlan_ID", "DetailID", "Goods_Code", "Goods_Name", "Goods_Spec", "Goods_MainUnit", "Goods_ID", "PlanNumber", "IsFinish", "Department_Name", "Remark", "DeliveryDate" },
|
|
new string[] { detail.ProductPlan_ID.ToString(), detail.DetailID.ToString(), detail.Goods_Code, detail.Goods_Name, detail.Goods_Spec, detail.Goods_MainUnit, detail.Goods_ID.ToString(), detail.PlanNumber == null ? "null" : detail.PlanNumber.Value.ToString(), detail.IsFinish ? "1" : "0", detail.Department_Name, detail.Remark, detail.DeliveryDate == null ? "null" : detail.DeliveryDate.Value.ToString() });
|
|
she.ExecuteNonQuery(insertSql, out success, out errorMessage);
|
|
if (!success && !string.IsNullOrEmpty(errorMessage)) {
|
|
she.Rollback();
|
|
throw new ApplicationException(errorMessage);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (batchs.Count() > 0) {
|
|
foreach (var batch in batchs) {
|
|
string insertSql = InsertUtil.GetInsertSql(TableNames.生产计划生产批次,
|
|
new string[] { "Batch_ID", "Batch", "BillDate", "RowVersion", "ProductPlan_ID" },
|
|
new string[] { batch.Batch_ID.ToString(), batch.Batch, batch.BillDate.ToString(), batch.RowVersion.ToString(), batch.ProductPlan_ID.ToString() });
|
|
she.ExecuteNonQuery(insertSql, out success, out errorMessage);
|
|
if (!success && !string.IsNullOrEmpty(errorMessage)) {
|
|
she.Rollback();
|
|
throw new ApplicationException(errorMessage);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!success) {
|
|
she.Rollback();
|
|
} else {
|
|
she.Commit();
|
|
}
|
|
}
|
|
}
|
|
|
|
public static void UpdateButhcerDetailFinish(long detailId)
|
|
{
|
|
string updateSql = string.Format("update " + TableNames.生产计划分割明细 + " set IsFinish = 1 where DetailID ={0}", detailId);
|
|
bool success = true;
|
|
using (var she = new SqlHelperEx()) {
|
|
she.CreateTransaction();
|
|
she.ExecuteNonQuery(updateSql, out success);
|
|
if (!success) {
|
|
she.Rollback();
|
|
} else {
|
|
she.Commit();
|
|
}
|
|
}
|
|
}
|
|
|
|
//以前逻辑
|
|
public static void UpdateButhcerDetailFinishNum(decimal? finishNum,decimal? detailID,long? goodsId, SqlHelperEx she2 = null)
|
|
{
|
|
string excuteSql = string.Empty;
|
|
var table = SqlHelperEx.DoQuery("select ID from {0} where DetailID = {1}".FormatWith(TableNames.生产计划分割明细完工数量, detailID));
|
|
if (table.Rows.Count > 0) {
|
|
excuteSql = string.Format("update " + TableNames.生产计划分割明细完工数量 + " set FinishNumber = {0} where DetailID ={1}", finishNum, detailID);
|
|
} else {
|
|
excuteSql = InsertUtil.GetInsertSql(TableNames.生产计划分割明细完工数量,
|
|
new string[] { "DetailID", "Goods_ID", "FinishNumber" },
|
|
new string[] { detailID.ToString(), goodsId.ToString(), (finishNum ?? 0).ToString() });
|
|
}
|
|
|
|
bool success = true;
|
|
if (she2 == null) {
|
|
using (var she = new SqlHelperEx()) {
|
|
she.CreateTransaction();
|
|
she.ExecuteNonQuery(excuteSql, out success);
|
|
if (!success) {
|
|
she.Rollback();
|
|
} else {
|
|
she.Commit();
|
|
}
|
|
}
|
|
} else {
|
|
she2.ExecuteNonQuery(excuteSql, out success);
|
|
if (!success) {
|
|
she2.Rollback();
|
|
}
|
|
}
|
|
}
|
|
|
|
//现在逻辑
|
|
public static void UpdateButhcerDetailFinishNum(ButcherDetailData data,decimal? finishNum, long detailID, long? goodsId, SqlHelperEx she2 = null)
|
|
{
|
|
string excuteSql = string.Empty;
|
|
var table = SqlHelperEx.DoQuery("select ID from {0} where DetailID = {1}".FormatWith(TableNames.生产计划分割明细完工数量, detailID));
|
|
if (table.Rows.Count > 0)
|
|
{
|
|
excuteSql = string.Format("update " + TableNames.生产计划分割明细完工数量 + " set FinishNumber = {0} where DetailID ={1}", finishNum, detailID);
|
|
}
|
|
else
|
|
{
|
|
excuteSql = InsertUtil.GetInsertSql(TableNames.生产计划分割明细完工数量,
|
|
new string[] { "DetailID", "Goods_ID", "FinishNumber" },
|
|
new string[] { detailID.ToString(), goodsId.ToString(), (finishNum ?? 0).ToString() });
|
|
}
|
|
|
|
bool success = true;
|
|
if (she2 == null)
|
|
{
|
|
using (var she = new SqlHelperEx())
|
|
{
|
|
she.CreateTransaction();
|
|
she.ExecuteNonQuery(excuteSql, out success);
|
|
if (!success)
|
|
{
|
|
she.Rollback();
|
|
}
|
|
else
|
|
{
|
|
she.Commit();
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
she2.ExecuteNonQuery(excuteSql, out success);
|
|
if (!success)
|
|
{
|
|
she2.Rollback();
|
|
}
|
|
}
|
|
if (success)
|
|
{
|
|
try
|
|
{
|
|
var usId = UserBL.CurrentUser.ERP_User_ID;
|
|
//更新数量
|
|
var method = "/MainSystem/B3_HaoYue/Rpcs/DeliveryNumberInfoRpc/InsertOrUpdateDeliveryNumber";
|
|
var deliveryNum = RpcFacade.Call<decimal>(method, usId, finishNum, detailID);
|
|
data.DeliveryNumber = deliveryNum;
|
|
|
|
}
|
|
catch(Exception e)
|
|
{
|
|
//throw new Exception(e.ToString());
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
public static string Delete(long ID)
|
|
{
|
|
bool success;
|
|
string errorMessage;
|
|
using (var she = new SqlHelperEx()) {
|
|
she.CreateTransaction();
|
|
var sql = SqlUtil.GetDeleteSql(TableNames.生产计划, " where ProductPlan_ID=" + ID.ToString());
|
|
she.ExecuteNonQuery(sql, out success, out errorMessage);
|
|
if (success) {
|
|
var sql2 = SqlUtil.GetDeleteSql(TableNames.生产计划分割明细, " where ProductPlan_ID=" + ID.ToString());
|
|
she.ExecuteNonQuery(sql2, out success, out errorMessage);
|
|
}
|
|
if (success) {
|
|
var sql2 = SqlUtil.GetDeleteSql(TableNames.生产计划生产批次, " where ProductPlan_ID=" + ID.ToString());
|
|
she.ExecuteNonQuery(sql2, out success, out errorMessage);
|
|
}
|
|
if (!success)
|
|
she.Rollback();
|
|
else
|
|
she.Commit();
|
|
}
|
|
return errorMessage;
|
|
}
|
|
|
|
public static void SyncProductPlan()
|
|
{
|
|
var domain_ID = ConfigurationManager.AppSettings["Domain_ID"];
|
|
var accountingUnit_ID = ConfigurationManager.AppSettings["AccountingUnit_ID"];
|
|
var method = "/MainSystem/B3_HaoYue/Rpcs/B3CowButcherManageRpc/GetProductPlanRowVersion";
|
|
if (domain_ID != null && !string.IsNullOrEmpty(domain_ID.ToString()) && accountingUnit_ID != null && !string.IsNullOrEmpty(accountingUnit_ID.ToString())) {
|
|
var productPlanRowVersions = RpcFacade.Call<List<Tuple<long?, int?, DateTime?>>>(method, long.Parse(domain_ID), long.Parse(accountingUnit_ID));
|
|
var oldproductPlanRowVersions = GetProductPlanRowVersion();
|
|
|
|
var needInsertProductPlanID = new List<long?>();
|
|
var needDeleteAndInsertProductPlanID = new List<long?>();
|
|
if (productPlanRowVersions.Count > 0) {
|
|
if (oldproductPlanRowVersions.Count() <= 0) {
|
|
productPlanRowVersions.ForEach(x => needInsertProductPlanID.Add(x.Item1));
|
|
} else {
|
|
foreach (var planRowVersion in productPlanRowVersions) {
|
|
var plan_ID = planRowVersion.Item1;
|
|
var oldProductPlans = oldproductPlanRowVersions.Where(x => x.ProductPlan_ID == plan_ID);
|
|
if (oldProductPlans.Count() > 0 && oldProductPlans.FirstOrDefault().RowVersion != planRowVersion.Item2) {
|
|
needDeleteAndInsertProductPlanID.Add(planRowVersion.Item1);
|
|
} else if (oldProductPlans.Count() <= 0) {
|
|
needInsertProductPlanID.Add(plan_ID);
|
|
}
|
|
}
|
|
|
|
foreach (var oldVersion in oldproductPlanRowVersions) {
|
|
if (!productPlanRowVersions.Any(x => x.Item1 == oldVersion.ProductPlan_ID)) {
|
|
Delete(oldVersion.ProductPlan_ID);
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
Delete();
|
|
}
|
|
|
|
|
|
if (needDeleteAndInsertProductPlanID.Count() > 0) {
|
|
foreach (var productPlanID in needDeleteAndInsertProductPlanID) {
|
|
var error = Delete(productPlanID.Value);
|
|
if (!string.IsNullOrEmpty(error)) {
|
|
throw new ApplicationException(error);
|
|
}
|
|
needInsertProductPlanID.Add(productPlanID);
|
|
}
|
|
}
|
|
|
|
if (needInsertProductPlanID.Count > 0) {
|
|
var getButcherDetail = "/MainSystem/B3_HaoYue/Rpcs/B3CowButcherManageRpc/GetProducePlanButcherDetailData";
|
|
var butcherDetails = RpcFacade.Call<List<RpcObject>>(getButcherDetail, needInsertProductPlanID.ToArray());
|
|
|
|
var list = new List<ProductPlan>();
|
|
var butcherList = new List<ButcherDetail>();
|
|
var batchList = new List<ProductBatch>();
|
|
|
|
foreach (var planID in needInsertProductPlanID) {
|
|
var plan = new ProductPlan();
|
|
plan.ProductPlan_ID = planID.Value;
|
|
var result = productPlanRowVersions.Where(x => x.Item1 == planID).First();
|
|
plan.RowVersion = result.Item2.Value;
|
|
plan.PlanDate = result.Item3.Value;
|
|
list.Add(plan);
|
|
}
|
|
|
|
if (butcherDetails.Count() > 0) {
|
|
foreach (var detail in butcherDetails) {
|
|
var butcherDetail = new ButcherDetail();
|
|
butcherDetail.ProductPlan_ID = detail.Get<long>("ProductPlan_ID");
|
|
butcherDetail.DetailID = detail.Get<long>("DetailID");
|
|
butcherDetail.Goods_Code = detail.Get<string>("Goods_Code");
|
|
butcherDetail.Goods_Name = detail.Get<string>("Goods_Name");
|
|
butcherDetail.Goods_Spec = detail.Get<string>("Goods_Spec");
|
|
butcherDetail.Goods_MainUnit = detail.Get<string>("Goods_MainUnit");
|
|
butcherDetail.Goods_ID = detail.Get<long>("Goods_ID");
|
|
butcherDetail.PlanNumber = detail.Get<decimal?>("PlanNumber");
|
|
butcherDetail.Department_Name = detail.Get<string>("Department_Name");
|
|
butcherDetail.Remark = detail.Get<string>("Remark");
|
|
butcherDetail.DeliveryDate = detail.Get<DateTime?>("DeliveryDate");
|
|
butcherList.Add(butcherDetail);
|
|
}
|
|
}
|
|
|
|
string method3 = "/MainSystem/B3_HaoYue/Rpcs/FourSplitBodyWeightClient/GetProductBatchData";
|
|
var produceBatchs = RpcFacade.Call<List<Tuple<string, long?, int?, DateTime?, long?>>>(method3, needInsertProductPlanID.ToArray());
|
|
if (produceBatchs.Count() > 0) {
|
|
foreach (var batch in produceBatchs) {
|
|
var pBatch = new ProductBatch();
|
|
pBatch.Batch = batch.Item1;
|
|
pBatch.Batch_ID = batch.Item2.Value;
|
|
pBatch.RowVersion = batch.Item3.Value;
|
|
pBatch.BillDate = batch.Item4.Value;
|
|
pBatch.ProductPlan_ID = batch.Item5.Value;
|
|
batchList.Add(pBatch);
|
|
}
|
|
}
|
|
|
|
Insert(list, butcherList, batchList);
|
|
}
|
|
}
|
|
}
|
|
|
|
public static List<ProductBatch> GetProductBatch(DateTime date,DateTime startDate,bool isLoad)
|
|
{
|
|
var list = new List<ProductBatch>();
|
|
var querySql = string.Empty;
|
|
if (!isLoad) {
|
|
querySql = "select Batch_ID,Batch from {0} where BillDate >='{1}' and BillDate < '{2}' order by BillDate desc".FormatWith(TableNames.生产计划生产批次, startDate, date.AddDays(1));
|
|
} else {
|
|
querySql = "select Batch_ID,Batch from {0} order by BillDate desc".FormatWith(TableNames.生产计划生产批次, startDate.AddDays(1));
|
|
}
|
|
var table = SqlHelperEx.DoQuery(querySql);
|
|
if (table.Rows.Count == 0)
|
|
return new List<ProductBatch>();
|
|
foreach (DataRow row in table.Rows) {
|
|
var batch = new ProductBatch();
|
|
batch.Batch_ID = DataTypeUtil.GetLongNum(row[0]);
|
|
batch.Batch = row[1].ToString();
|
|
list.Add(batch);
|
|
}
|
|
return list;
|
|
}
|
|
|
|
public static string Delete()
|
|
{
|
|
bool success;
|
|
string errorMessage;
|
|
using (var she = new SqlHelperEx()) {
|
|
she.CreateTransaction();
|
|
var sql = SqlUtil.GetDeleteSql(TableNames.生产计划);
|
|
she.ExecuteNonQuery(sql, out success, out errorMessage);
|
|
if (success) {
|
|
var sql3 = SqlUtil.GetDeleteSql(TableNames.生产计划分割明细);
|
|
she.ExecuteNonQuery(sql3, out success, out errorMessage);
|
|
}
|
|
if (success) {
|
|
var sql3 = SqlUtil.GetDeleteSql(TableNames.生产计划生产批次);
|
|
she.ExecuteNonQuery(sql3, out success, out errorMessage);
|
|
}
|
|
if (!success)
|
|
she.Rollback();
|
|
else
|
|
she.Commit();
|
|
}
|
|
return errorMessage;
|
|
}
|
|
|
|
public static List<ButcherDetailData> GetButcherDetails(DateTime date,DateTime startDate,long planTeamID)
|
|
{
|
|
var list = new List<ButcherDetailData>();
|
|
var sql = "select a.Goods_ID, a.Goods_Name,a.Goods_Spec,a.Goods_MainUnit,a.PlanNumber,a.DetailID,e.FinishNumber,a.Department_Name,a.Remark,a.DeliveryDate from {0} a inner join {1} b on a.ProductPlan_ID = b.ProductPlan_ID inner join {2} c on c.Goods_ID = a.Goods_ID inner join {3} d on c.ProductTeam_ID = d.ProductTeam_ID left outer join {4} e on a.DetailID = e.DetailID where a.IsFinish = 0 and d.ProductTeam_ID = {5} order by a.DeliveryDate asc".FormatWith(TableNames.生产计划分割明细, TableNames.生产计划, TableNames.生产班组产出明细, TableNames.生产班组, TableNames.生产计划分割明细完工数量, planTeamID);
|
|
if (!string.IsNullOrEmpty(sql)) {
|
|
var table = SqlHelperEx.DoQuery(sql);
|
|
foreach (DataRow row in table.Rows) {
|
|
var outDetail = new ButcherDetailData();
|
|
outDetail.Goods_ID = (long)((int)row[0]);
|
|
outDetail.Goods_Name = (string)row[1];
|
|
outDetail.Goods_Spec = (string)row[2];
|
|
outDetail.Goods_MainUnit = (string)row[3];
|
|
outDetail.PlanNumber = DataTypeUtil.GetDecimalNum(row[4]);
|
|
outDetail.DetailID = (long)((int)row[5]);
|
|
outDetail.FinishNum = DataTypeUtil.GetDecimalNum(row[6]);
|
|
outDetail.Department_Name = (string)row[7];
|
|
outDetail.Remark = (string)row[8];
|
|
var deliveryDate = DataTypeUtil.GetDateTimeNullData(row[9]);
|
|
if (deliveryDate != null) {
|
|
outDetail.DeliveryDate = deliveryDate.Value.Date;
|
|
outDetail.DeliveryDateStr = deliveryDate.Value.Date.ToShortDateString();
|
|
}
|
|
list.Add(outDetail);
|
|
}
|
|
}
|
|
|
|
|
|
try
|
|
{
|
|
//获取全部的完工数量
|
|
var details = list.Select(x => x.DetailID).Distinct();
|
|
var detailStr = string.Join("|", details);
|
|
var method = "/MainSystem/B3_HaoYue/Rpcs/DeliveryNumberInfoRpc/GetDeliveryNumberInfo";
|
|
var deliveryInfo = RpcFacade.Call<List<Tuple<long?, decimal?>>>(method, detailStr);
|
|
foreach(var tuple in deliveryInfo)
|
|
{
|
|
if (tuple.Item1 == null)
|
|
continue;
|
|
foreach(var detail in list.Where(x=> x.DetailID == tuple.Item1.Value))
|
|
{
|
|
detail.DeliveryNumber = tuple.Item2;
|
|
}
|
|
}
|
|
}
|
|
catch(Exception e)
|
|
{
|
|
//throw new Exception(e.ToString());
|
|
}
|
|
return list;
|
|
}
|
|
}
|
|
|
|
public class ButcherDetailData : INotifyPropertyChanged
|
|
{
|
|
public long DetailID { get; set; }
|
|
public long Goods_ID { get; set; }
|
|
public string Goods_Name { get; set; }
|
|
public string Goods_Spec { get; set; }
|
|
public string Goods_MainUnit { get; set; }
|
|
public decimal? PlanNumber { get; set; }
|
|
public string Department_Name { get; set; }
|
|
public string Remark { get; set; }
|
|
public DateTime? DeliveryDate { get; set; }
|
|
public string DeliveryDateStr { get; set; }
|
|
private decimal? mFinishNum;
|
|
/// <summary>
|
|
/// 本机完工数量
|
|
/// </summary>
|
|
public decimal? FinishNum
|
|
{
|
|
get
|
|
{
|
|
return mFinishNum;
|
|
}
|
|
|
|
set
|
|
{
|
|
mFinishNum = value;
|
|
if (PropertyChanged != null) {
|
|
PropertyChanged(this, new PropertyChangedEventArgs("FinishNum"));
|
|
}
|
|
}
|
|
}
|
|
|
|
private decimal? mDeliveryNumber;
|
|
|
|
/// <summary>
|
|
/// 整个系统中的完工数量
|
|
/// </summary>
|
|
public decimal? DeliveryNumber
|
|
{
|
|
get
|
|
{
|
|
return mDeliveryNumber;
|
|
}
|
|
|
|
set
|
|
{
|
|
mDeliveryNumber = value;
|
|
if (PropertyChanged != null)
|
|
{
|
|
PropertyChanged(this, new PropertyChangedEventArgs("DeliveryNumber"));
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
private decimal? mSurplusNum;
|
|
public decimal? SurplusNum
|
|
{
|
|
get
|
|
{
|
|
return mSurplusNum;
|
|
}
|
|
|
|
set
|
|
{
|
|
mSurplusNum = value;
|
|
if (PropertyChanged != null) {
|
|
PropertyChanged(this, new PropertyChangedEventArgs("SurplusNum"));
|
|
}
|
|
}
|
|
}
|
|
|
|
public event PropertyChangedEventHandler PropertyChanged;
|
|
}
|
|
}
|
|
|
|
|
|
|