代码更新

wangxinhui

2024-11-06 8f392cc88b0768b74efca3b68785cf5aa1c38e70

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
 
using System;
using System.Collections.Generic;
using System.Linq.Expressions;
using WIDESEA_Common.CutomerModel;
using WIDESEA_Core.BaseProvider;
using WIDESEA_Core.EFDbContext;
using WIDESEA_Core.Extensions.AutofacManager;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services.IRepositories;
 
namespace WIDESEA_Services.Repositories
{
    public partial class VV_DispatchRepository : RepositoryBase<VV_Dispatch>, IVV_DispatchRepository
    {
        public VV_DispatchRepository(VOLContext dbContext)
        : base(dbContext)
        {
 
        }
        public static IVV_DispatchRepository Instance
        {
            get { return AutofacContainerModule.GetService<IVV_DispatchRepository>(); }
        }
 
        public override List<VV_Dispatch> Find(Expression<Func<VV_Dispatch, bool>> predicate)
        {
            return base.Find(predicate);
        }
 
        public List<JobOptions> FindToJobOptions(Expression<Func<VV_Dispatch, bool>> predicate)
        {
            List<JobOptions> jobOptions = new List<JobOptions>();
            List<VV_Dispatch> dispatches = base.Find(predicate);
 
            dispatches.ForEach(t =>
            {
                jobOptions.Add(new JobOptions()
                {
                    AssemblyName = t.AssemblyName,
                    BeginTime = t.BeginTime,
                    ClassName = t.ClassName,
                    Cron = t.Cron,
                    CycleRunTimes = 0,//ÖØÊÔ´ÎÊý
                    EndTime = t.EndTime,
                    IntervalSecond = t.IntervalSecond,
                    IsStart = false,
                    JobGroup = t.JobGroup,
                    JobName = t.JobName,
                    JobParams = null,
                    Remark = t.Remark,
                    TriggerType = t.TriggerType
                });
            });
            //List<dt_plcinfohead> heads = dt_plcinfoheadRepository.Instance.Find(x => true);
            //var jobs = dispatches.Join(heads, x => x.JobName, y => y.plcinfo_name, (x, y) => new
            //{
            //    AssemblyName = x.AssemblyName,
            //    BeginTime = x.BeginTime,
            //    ClassName = x.ClassName,
            //    Cron = x.Cron,
            //    CycleRuntiems = x.CycleRuntiems,
            //    EndTime = x.EndTime,
            //    IntervalSecond = x.IntervalSecond,
            //    JobGroup = x.JobGroup,
            //    JobName = x.JobName,
            //    Remark = x.Remark,
            //    TriggerType = x.TriggerType,
            //}).ToList();
            //for (int i = 0; i < jobs.Count; i++)
            //{
            //    JobOptions options = new JobOptions()
            //    {
            //        AssemblyName = jobs[i].AssemblyName,
            //        BeginTime = jobs[i].BeginTime,
            //        ClassName = jobs[i].ClassName,
            //        Cron = jobs[i].Cron,
            //        CycleRunTimes = jobs[i].CycleRuntiems ?? 0,
            //        EndTime = jobs[i].EndTime,
            //        IntervalSecond = jobs[i].IntervalSecond,
            //        IsStart = false,
            //        JobGroup = jobs[i].JobGroup,
            //        JobName = jobs[i].JobName,
            //        JobParams = null,
            //        Remark = jobs[i].Remark,
            //        TriggerType = jobs[i].TriggerType
            //    };
            //    jobOptions.Add(options);
            //}
            return jobOptions;
        }
 
        public List<JobOptions> FindJobOptions(Expression<Func<VV_Dispatch, bool>> predicate)
        {
            List<JobOptions> jobOptions = new List<JobOptions>();
            List<VV_Dispatch> dispatches = base.Find(predicate);
 
            for (int i = 0; i < dispatches.Count; i++)
            {
                JobOptions options = new JobOptions()
                {
                    AssemblyName = dispatches[i].AssemblyName,
                    BeginTime = dispatches[i].BeginTime,
                    ClassName = dispatches[i].ClassName,
                    Cron = dispatches[i].Cron,
                    CycleRunTimes = dispatches[i].CycleRuntiems ?? 0,
                    EndTime = dispatches[i].EndTime,
                    IntervalSecond = dispatches[i].IntervalSecond,
                    IsStart = false,
                    JobGroup = dispatches[i].JobGroup,
                    JobName = dispatches[i].JobName,
                    JobParams = null,
                    Remark = dispatches[i].Remark,
                    TriggerType = dispatches[i].TriggerType,
                    PLCConnectState = "δÁ¬½ÓPLC"
                };
                jobOptions.Add(options);
            }
            return jobOptions;
        }
    }
 
}