UpstreamSendCalendar.cs
2.65 KB
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
using System;
using Hh.Mes.Common.log;
using Hh.Mes.Pojo.System;
using Hh.Mes.POJO.ApiEntity;
using Hh.Mes.POJO.Entity;
using Hh.Mes.POJO.EnumEntitys;
using Hh.Mes.POJO.Response;
using static Microsoft.AspNetCore.Hosting.Internal.HostingApplication;
namespace Hh.Mes.Service.ApiService
{
public partial class UpstreamService
{
public dynamic SendCalendar(CalendarEntity entity)
{
return ExceptionsHelp.Instance.ExecuteT(() =>
{
var response = new ResponseUpstream<string>(entity.plmeid);
var calendar = new base_calendar
{
keys = Guid.NewGuid(),
plmeId = entity.plmeid,
workShopCode = entity.work_code,
currentDate = entity.current_date,
shift = entity.shift,
startTime = entity.start_time,
endTime = entity.end_time,
timeFlag = entity.time,
isDelete = AddOrUpdateFlag
};
int resultCount = 0;
if (entity.type == EnumAction.I.ToString())
{
if (Context.Queryable<base_calendar>().Any(t => t.plmeId == calendar.plmeId && t.isDelete == AddOrUpdateFlag))
{
return response.ResponseError($"【MOM】【plmeid】日历信息[{entity.plmeid}]已经存在，请勿重复添加！");
}
calendar.createTime = DateTime.Now;
resultCount = Context.Insertable(calendar).ExecuteCommand();
}
else if (entity.type == EnumAction.U.ToString())
{
calendar.updateTime = DateTime.Now;
resultCount = Context.Updateable(calendar).IgnoreColumns(it => new { it.keys, it.createBy, it.createTime })
.Where(x => x.plmeId == entity.plmeid && x.isDelete == AddOrUpdateFlag)
.ExecuteCommand();
}
else if (entity.type == EnumAction.D.ToString())
{
calendar.updateTime = DateTime.Now;
resultCount = Context.Updateable<base_calendar>()
.SetColumns(t => t.isDelete == DeleteFlag)
.Where(x => x.plmeId.Equals(entity.plmeid) && x.isDelete == AddOrUpdateFlag)
.ExecuteCommand();
}
return resultCount > 0 ? response.ResponseSuccess() : response.ResponseError();
});
}
}
}