NewLife
/
AntJob
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

数据调度例程完成

This commit is contained in:
大石头 2020-04-10 00:36:03 +08:00
parent c2846ddeba
commit 758158b459
5 changed files with 64 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
Samples/HisAgent/BuildWill.cs Normal file
View File

@ -0,0 +1,49 @@
using System;
using AntJob;
using HisData;
using NewLife.Security;
using XCode;
namespace HisAgent
{
class BuildWill : DataHandler
{
public BuildWill()
{
var job = Job;
job.Start = DateTime.Today;
job.Step = 30;
}
public override Boolean Start()
{
// 指定要抽取数据的实体类以及时间字段
Factory = ZYBH0.Meta.Factory;
Field = ZYBH0._.CreateTime;
return base.Start();
}
protected override Boolean ProcessItem(JobContext ctx, IEntity entity)
{
var pi = entity as ZYBH0;
// 创建医嘱信息
var will = new ZYBHYZ0
{
Bhid = pi.Bhid,
Mgroupid = Rand.Next(9999),
Kyzrq = pi.Ryrq.AddHours(1),
Tyzrq = pi.Cyrq.AddHours(-3),
Kyzys = Rand.NextString(8),
State = pi.State,
};
will.Insert();
return true;
}
}
}

1
Samples/HisAgent/Program.cs
View File

@ -27,6 +27,7 @@ namespace HisAgent
// 添加作业处理器
sc.Handlers.Add(new HelloJob());
sc.Handlers.Add(new BuildPatient());
sc.Handlers.Add(new BuildWill());
// 启动调度引擎，调度器内部多线程处理
sc.Start();

20
Samples/HisData/Entity/病人医嘱信息.cs
View File

@ -41,21 +41,21 @@ namespace HisData
[BindColumn("MGROUPID", "医嘱组号", "", Master = true)]
public Int32 Mgroupid { get => _Mgroupid; set { if (OnPropertyChanging(__.Mgroupid, value)) { _Mgroupid = value; OnPropertyChanged(__.Mgroupid); } } }
private Int32 _Kyzrq;
private DateTime _Kyzrq;
/// <summary>开医嘱日期</summary>
[DisplayName("开医嘱日期")]
[Description("开医嘱日期")]
[DataObjectField(false, false, false, 0)]
[DataObjectField(false, false, true, 0)]
[BindColumn("KYZRQ", "开医嘱日期", "")]
public Int32 Kyzrq { get => _Kyzrq; set { if (OnPropertyChanging(__.Kyzrq, value)) { _Kyzrq = value; OnPropertyChanged(__.Kyzrq); } } }
public DateTime Kyzrq { get => _Kyzrq; set { if (OnPropertyChanging(__.Kyzrq, value)) { _Kyzrq = value; OnPropertyChanged(__.Kyzrq); } } }
private Int32 _Tyzrq;
private DateTime _Tyzrq;
/// <summary>停医嘱日期</summary>
[DisplayName("停医嘱日期")]
[Description("停医嘱日期")]
[DataObjectField(false, false, false, 0)]
[DataObjectField(false, false, true, 0)]
[BindColumn("TYZRQ", "停医嘱日期", "")]
public Int32 Tyzrq { get => _Tyzrq; set { if (OnPropertyChanging(__.Tyzrq, value)) { _Tyzrq = value; OnPropertyChanged(__.Tyzrq); } } }
public DateTime Tyzrq { get => _Tyzrq; set { if (OnPropertyChanging(__.Tyzrq, value)) { _Tyzrq = value; OnPropertyChanged(__.Tyzrq); } } }
private String _Kyzys;
/// <summary>开医嘱医生</summary>
@ -173,8 +173,8 @@ namespace HisData
case __.ID: _ID = value.ToInt(); break;
case __.Bhid: _Bhid = value.ToInt(); break;
case __.Mgroupid: _Mgroupid = value.ToInt(); break;
case __.Kyzrq: _Kyzrq = value.ToInt(); break;
case __.Tyzrq: _Tyzrq = value.ToInt(); break;
case __.Kyzrq: _Kyzrq = value.ToDateTime(); break;
case __.Tyzrq: _Tyzrq = value.ToDateTime(); break;
case __.Kyzys: _Kyzys = Convert.ToString(value); break;
case __.State: _State = value.ToInt(); break;
case __.CreateUser: _CreateUser = Convert.ToString(value); break;
@ -308,10 +308,10 @@ namespace HisData
Int32 Mgroupid { get; set; }
/// <summary>开医嘱日期</summary>
Int32 Kyzrq { get; set; }
DateTime Kyzrq { get; set; }
/// <summary>停医嘱日期</summary>
Int32 Tyzrq { get; set; }
DateTime Tyzrq { get; set; }
/// <summary>开医嘱医生</summary>
String Kyzys { get; set; }

1
Samples/HisData/Entity/病人基本信息.cs
View File

@ -12,6 +12,7 @@ namespace HisData
[DataObject]
[Description("病人基本信息")]
[BindIndex("IU_ZYBH0_BHID", true, "BHID")]
[BindIndex("IX_ZYBH0_CreateTime", false, "CreateTime")]
[BindTable("ZYBH0", Description = "病人基本信息", ConnName = "His", DbType = DatabaseType.None)]
public partial class ZYBH0 : IZYBH0
{

5
Samples/HisData/Model.xml
View File

@ -23,6 +23,7 @@
</Columns>
<Indexes>
<Index Columns="BHID" Unique="True" />
<Index Columns="CreateTime" />
</Indexes>
</Table>
<Table Name="ZYBHYZ0" Description="病人医嘱信息" IgnoreNameCase="False">
@ -30,8 +31,8 @@
<Column Name="ID" DataType="Int32" Identity="True" PrimaryKey="True" Description="编号" />
<Column Name="Bhid" ColumnName="BHID" DataType="Int32" Description="病人ID" />
<Column Name="Mgroupid" ColumnName="MGROUPID" DataType="Int32" Master="True" Description="医嘱组号" />
<Column Name="Kyzrq" ColumnName="KYZRQ" DataType="Int32" Description="开医嘱日期" />
<Column Name="Tyzrq" ColumnName="TYZRQ" DataType="Int32" Description="停医嘱日期" />
<Column Name="Kyzrq" ColumnName="KYZRQ" DataType="DateTime" Description="开医嘱日期" />
<Column Name="Tyzrq" ColumnName="TYZRQ" DataType="DateTime" Description="停医嘱日期" />
<Column Name="Kyzys" ColumnName="KYZYS" DataType="String" Description="开医嘱医生" />
<Column Name="State" ColumnName="STATE" DataType="Int32" Description="状态" />
<Column Name="CreateUser" DataType="String" Description="创建者" />