242 lines
9.9 KiB
C#
242 lines
9.9 KiB
C#
using AutoMapper;
|
||
using APT.BaseData.Domain.Entities;
|
||
using APT.BaseData.Domain.Entities;
|
||
using APT.BaseData.Domain.Enums;
|
||
using APT.BaseData.Domain.IServices;
|
||
using APT.BaseData.Domain.Msg;
|
||
using APT.Infrastructure.Core;
|
||
using APT.Utility;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Linq.Expressions;
|
||
using APT.Infrastructure.Api;
|
||
namespace APT.BaseData.Services.DomainServices
|
||
{
|
||
public partial class PFCodeRuleSerialService : CommonService, IPFCodeRuleSerialService
|
||
{
|
||
public PFCodeRuleSerialService(IRepository repository)
|
||
: base(repository)
|
||
{
|
||
}
|
||
/// <summary>
|
||
/// 跑批
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public bool RunBatch()
|
||
{
|
||
//增加跑批日志表
|
||
var logs = this.GetEntities<T_PF_CODE_RULE_RUN_LOG>(i => i.IS_COMPLETE == false);
|
||
if (logs.Any())
|
||
{
|
||
foreach (var l in logs)
|
||
{
|
||
if (l.START_TIME <= DateTime.Now.AddHours(-6))
|
||
{
|
||
l.IS_COMPLETE = true;
|
||
}
|
||
}
|
||
this.BantchUpdateEntity(logs);
|
||
//如果有未完成的跑批数据不继续跑批，如超过6个小时，则认为是异常中断
|
||
if (logs.Any(i => i.START_TIME > DateTime.Now.AddHours(-6)))
|
||
{
|
||
return false;
|
||
}
|
||
}
|
||
//开始跑批
|
||
const int Day = -2;
|
||
var date = DateTime.Now.ToString("yyyyMMdd");
|
||
var nextDate = DateTime.Now.AddDays(1).ToString("yyyyMMdd");
|
||
var codeRules = this.GetEntities<T_PF_CODE_RULE>(i => i.ENABLE_STATUS == (int)FMEnableStatusEnum.启用,
|
||
new BaseFilter(), new string[] { "Nav_Org" }).ToList();
|
||
if (codeRules.Any())
|
||
{
|
||
//跑批日志表增加一条数据
|
||
var log = new T_PF_CODE_RULE_RUN_LOG
|
||
{
|
||
ID = Guid.NewGuid(),
|
||
CREATE_TIME = DateTime.Now,
|
||
START_TIME = DateTime.Now,
|
||
IS_COMPLETE = false,
|
||
ORG_ID = codeRules.FirstOrDefault().ORG_ID
|
||
};
|
||
this.AddEntity(log);
|
||
try
|
||
{
|
||
//var dbCodeRuleSerials=this.GetEntities<T_PF_CODE_RULE_SERIAL>(t => t.STATUS == (int)PFCodeRuleStatus.未用).ToList();
|
||
List<T_PF_CODE_RULE_SERIAL> codeRuleSerials = new List<T_PF_CODE_RULE_SERIAL>();
|
||
foreach (var rule in codeRules)
|
||
{
|
||
DoGenSerialByRule(rule, date, codeRuleSerials);
|
||
}
|
||
//预生成第二天的编码 因为工厂通常有夜班 编码未必可以及时生成
|
||
foreach (var rule in codeRules)
|
||
{
|
||
DoGenSerialByRule(rule, nextDate, codeRuleSerials);
|
||
}
|
||
this.BantchAddEntity(codeRuleSerials);
|
||
|
||
var towDay = DateTime.Now.AddDays(Day).ToString("yyyyMMdd");
|
||
var serialLogs = this.GetEntities<T_PF_CODE_RULE_SERIAL>(i => i.DATE_VALUE != null
|
||
&& string.Compare(i.DATE_VALUE, towDay) <= 0, true).ToList();
|
||
if (serialLogs.Any())
|
||
{
|
||
var seialAddLogs = new List<T_PF_CODE_RULE_SERIAL>();
|
||
foreach (var s in serialLogs)
|
||
{
|
||
seialAddLogs.Add(s);
|
||
if (seialAddLogs.Count >= 10000)
|
||
{
|
||
AddLogByInValidSerial(seialAddLogs);
|
||
seialAddLogs.Clear();
|
||
}
|
||
}
|
||
AddLogByInValidSerial(seialAddLogs);
|
||
}
|
||
}
|
||
finally
|
||
{
|
||
var oldLog = this.GetEntity<T_PF_CODE_RULE_RUN_LOG>(log.ID.ToString());
|
||
if (oldLog != null)
|
||
{
|
||
oldLog.END_TIME = DateTime.Now;
|
||
oldLog.IS_COMPLETE = true;
|
||
this.UpdateEntity(oldLog);
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
private void AddLogByInValidSerial(List<T_PF_CODE_RULE_SERIAL> list)
|
||
{
|
||
if (list == null || !list.Any()) return;
|
||
this.DeleteEntity<T_PF_CODE_RULE_SERIAL>(list);
|
||
//var seialAddLogs = new List<T_PF_CODE_RULE_SERIAL_LOG>();
|
||
//foreach (var s in list)
|
||
//{
|
||
// var log = new T_PF_CODE_RULE_SERIAL_LOG();// Mapper.Map<T_PF_CODE_RULE_SERIAL, T_PF_CODE_RULE_SERIAL_LOG>(s);
|
||
// log.ORG_ID = log.ORG_ID;
|
||
// CopyUtils.CopyObject(log, s);
|
||
// seialAddLogs.Add(log);
|
||
//}
|
||
//this.BantchAddEntity(seialAddLogs);
|
||
}
|
||
|
||
private void DoGenSerialByRule(T_PF_CODE_RULE rule, string date, List<T_PF_CODE_RULE_SERIAL> codeRuleSerials)
|
||
{
|
||
Expression<Func<T_PF_CODE_RULE_SERIAL, bool>> expression = t => t.ORG_ID == rule.ORG_ID
|
||
&& t.CODE_TYPE == rule.CODE_TYPE;
|
||
if (!rule.IS_IGNORE_DATE.HasValue || !rule.IS_IGNORE_DATE.Value)
|
||
expression = expression.And(t => t.DATE_VALUE == date);
|
||
var pageFilter = new BasePageFilter(1, 1);
|
||
pageFilter.Sort = "NUM";
|
||
pageFilter.Order = DbOrder.DESC;
|
||
var maxDbCodeRuleSerial = this.GetOrderPageEntities<T_PF_CODE_RULE_SERIAL>(expression, pageFilter);
|
||
int num = 0;
|
||
T_PF_CODE_RULE_SERIAL maxCodeRuleSerail = null;
|
||
if (maxDbCodeRuleSerial.Items.Any())
|
||
{
|
||
maxCodeRuleSerail = maxDbCodeRuleSerial.Items.FirstOrDefault();
|
||
if (maxCodeRuleSerail != null)
|
||
num = maxCodeRuleSerail.NUM;
|
||
}
|
||
num++;
|
||
|
||
Expression<Func<T_PF_CODE_RULE_SERIAL, bool>> expression1 = t => t.ORG_ID == rule.ORG_ID
|
||
&& t.CODE_TYPE == rule.CODE_TYPE && t.STATUS == (int)PFCodeRuleStatus.未用;
|
||
if (!rule.IS_IGNORE_DATE.HasValue || !rule.IS_IGNORE_DATE.Value)
|
||
expression1 = expression1.And(t => t.DATE_VALUE == date);
|
||
|
||
var minUnUseSerial = this.GetEntity<T_PF_CODE_RULE_SERIAL>(expression1, new BaseFilter()
|
||
{
|
||
Order = DbOrder.ASC,
|
||
Sort = "NUM"
|
||
});
|
||
int minUnUseNum = 0;
|
||
if (minUnUseSerial != null)
|
||
minUnUseNum = minUnUseSerial.NUM - 1;
|
||
else if (maxCodeRuleSerail != null && maxCodeRuleSerail.STATUS != (int)PFCodeRuleStatus.未用)
|
||
minUnUseNum = maxCodeRuleSerail.NUM;
|
||
|
||
var maxQty = rule.QTY == null || rule.QTY == 0 ? 100 : rule.QTY;
|
||
maxQty += minUnUseNum;
|
||
var serial = new T_PF_CODE_RULE_SERIAL
|
||
{
|
||
ORG_ID = rule.ORG_ID,
|
||
CODE_TYPE = rule.CODE_TYPE,
|
||
DATE_VALUE = rule.IS_IGNORE_DATE.HasValue && rule.IS_IGNORE_DATE.Value ? null : date,
|
||
STATUS = (int)PFCodeRuleStatus.未用
|
||
};
|
||
//位数限制
|
||
var ruleMaxQty = Math.Floor(Math.Pow(10, rule.SERIAL_NUM_LEN) - 1);
|
||
if (maxQty > (int)ruleMaxQty)
|
||
maxQty = (int)ruleMaxQty;
|
||
|
||
for (int i = num; i <= maxQty; i++)
|
||
{
|
||
var cpSerial = (T_PF_CODE_RULE_SERIAL)serial.Clone();
|
||
cpSerial.ID = Guid.NewGuid();
|
||
cpSerial.NUM = i;
|
||
cpSerial.SERIAL = string.Concat(rule.CODE_PREFIX,
|
||
(rule.Nav_Org == null ? string.Empty : (rule.Nav_Org.CODE)),
|
||
(rule.IS_IGNORE_DATE.HasValue && rule.IS_IGNORE_DATE.Value ? string.Empty : date),
|
||
i.ToString().PadLeft(rule.SERIAL_NUM_LEN, '0'));
|
||
codeRuleSerials.Add(cpSerial);
|
||
if (codeRuleSerials.Count >= 1000)
|
||
{
|
||
this.BantchAddEntity(codeRuleSerials);
|
||
codeRuleSerials.Clear();
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 手动触发
|
||
/// </summary>
|
||
/// <param name="filter"></param>
|
||
/// <returns></returns>
|
||
public bool GenSerial(KeywordFilter filter)
|
||
{
|
||
var date = DateTime.Now.ToString("yyyyMMdd");
|
||
var type = int.Parse(filter.Keyword);
|
||
filter.Sort = string.Empty;
|
||
var codeRule = this.GetEntity<T_PF_CODE_RULE>(i => i.CODE_TYPE == type, filter, new string[] { "Nav_Org" });
|
||
|
||
if (codeRule == null)
|
||
throw new Exception(ErrMsg.PF_ERR_CODE_RULE_TYPE + ":" + type);
|
||
|
||
List<T_PF_CODE_RULE_SERIAL> codeRuleSerials = new List<T_PF_CODE_RULE_SERIAL>();
|
||
DoGenSerialByRule(codeRule, date, codeRuleSerials);
|
||
this.BantchAddEntity(codeRuleSerials);
|
||
|
||
return true;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 检验预取流水
|
||
/// </summary>
|
||
/// <returns></returns>
|
||
public bool SerialCheck()
|
||
{
|
||
var checkSerial = this.GetEntities<T_PF_CODE_RULE_SERIAL>(i => i.STATUS == (int)PFCodeRuleStatus.预取
|
||
&& i.RELEASE_TIME != null && i.RELEASE_TIME < DateTime.Now).ToList();
|
||
if (checkSerial.Any())
|
||
{
|
||
checkSerial.ForEach(i =>
|
||
{
|
||
i.STATUS = (int)PFCodeRuleStatus.未用;
|
||
i.TAKE_TIME = null; i.RELEASE_TIME = null;
|
||
});
|
||
//commit
|
||
//1.初始化当前的数据
|
||
this.BantchUpdateEntity(checkSerial);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
}
|
||
}
|