diff --git a/SGGL/BLL/WebService/CNCECHSSEWebService.cs b/SGGL/BLL/WebService/CNCECHSSEWebService.cs
index bee897ac..210fecd6 100644
--- a/SGGL/BLL/WebService/CNCECHSSEWebService.cs
+++ b/SGGL/BLL/WebService/CNCECHSSEWebService.cs
@@ -2,7 +2,9 @@
{
using System;
using System.Collections.Generic;
+ using BLL.CNCECHSSEService;
using System.Data;
+ using Newtonsoft.Json;
using System.Linq;
public static class CNCECHSSEWebService
@@ -75,23 +77,32 @@
AttemptedEventNum = x.AttemptedEventNum,
LossDayNum = x.LossDayNum,
};
-
- var getR = hsseC.DataInsertInformation_MillionsMonthlyReportTable(upReport.ToList(), upReportItem.ToList());
- foreach (var item in getR)
+
+ //老接口Serveice
+ //var getR = hsseC.DataInsertInformation_MillionsMonthlyReportTable(upReport.ToList(), upReportItem.ToList());
+ //新接口Api
+ code = UpApiMillionsMonthlyReport(upReport, upReportItem).ToString();
+ if (code == "1")
{
- var report = db.Information_MillionsMonthlyReport.FirstOrDefault(e => e.MillionsMonthlyReportId == item);
- if (report != null)
+ foreach (var item in upReport.Select(p => p.MillionsMonthlyReportId))
{
- report.UpState = BLL.Const.UpState_3;
- db.SubmitChanges();
- ////更新 当前人要处理的意见
- ProjectDataFlowSetService.CloseFlowOperate(Const.MillionsMonthlyReportMenuId, item, string.Empty);
- // //更新催报信息
- UrgeReportService.SetComplete(report.UnitId, Const.ReportType_1, report.Year.ToString(), report.Month.ToString());
+ var report = db.Information_MillionsMonthlyReport.FirstOrDefault(e => e.MillionsMonthlyReportId == item);
+ if (report != null)
+ {
+ report.UpState = BLL.Const.UpState_3;
+ db.SubmitChanges();
+ ////更新 当前人要处理的意见
+ ProjectDataFlowSetService.CloseFlowOperate(Const.MillionsMonthlyReportMenuId, item, string.Empty);
+ // //更新催报信息
+ UrgeReportService.SetComplete(report.UnitId, Const.ReportType_1, report.Year.ToString(), report.Month.ToString());
+ }
}
+ LogService.AddSys_Log(CurrUser, "【百万工时安全统计月报表】上传到服务器" + upReport.Count().ToString() + "条数据;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
+ }
+ else
+ {
+ LogService.AddSys_Log(CurrUser, "【百万工时安全统计月报表】上传到服务器失败;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
- code = "1";
- LogService.AddSys_Log(CurrUser, "【百万工时安全统计月报表】上传到服务器" + getR.Count.ToString() + "条数据;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
catch (Exception ex)
{
@@ -101,6 +112,23 @@
return code;
}
}
+ ///
+ /// UpApiMillionsMonthlyReportApi调用
+ ///
+ /// 主表
+ /// 明细表
+ ///
+ private static int UpApiMillionsMonthlyReport(IQueryable upReport, IQueryable upReportItem)
+ {
+ string baseurl = "/api/InformationData/SaveMillionsMonthlyReport";
+ //合并
+ //var resultJson = JsonConvert.SerializeObject(new { upReport, ReportItem = upReportItem });
+ var resultJsonReport = JsonConvert.SerializeObject(upReport.FirstOrDefault());
+ var resultJsonReportItem = JsonConvert.SerializeObject(new { MillionsMonthlyReportItem = upReportItem });
+ resultJsonReport = "{\"InformationDataItems\":[" + (resultJsonReport + resultJsonReportItem).Replace("}{", ",") + "]}";
+ var responeData = BLL.ServerService.PushCNCEC(resultJsonReport, baseurl);
+ return responeData.code;
+ }
#endregion
#region 职工伤亡事故原因分析报表上报
@@ -189,23 +217,32 @@
Injuries11 = x.Injuries11,
MinorInjuries11 = x.MinorInjuries11,
};
-
- var getR = hsseC.DataInsertInformation_AccidentCauseReportTable(upReport.ToList(), upReportItem.ToList());
- foreach (var item in getR)
+ //老接口Serveice
+ // var getR = hsseC.DataInsertInformation_AccidentCauseReportTable(upReport.ToList(), upReportItem.ToList());
+ //新接口Api
+ code = UpApiAccidentCauseReport(upReport, upReportItem).ToString();
+ if (code == "1")
{
- var report = db.Information_AccidentCauseReport.FirstOrDefault(e => e.AccidentCauseReportId == item);
- if (report != null)
+ foreach (var item in upReport.Select(p => p.AccidentCauseReportId))
{
- report.UpState = BLL.Const.UpState_3;
- db.SubmitChanges();
- ////更新 当前人要处理的意见
- ProjectDataFlowSetService.CloseFlowOperate(Const.MillionsMonthlyReportMenuId, item, string.Empty);
- ////更新催报信息
- UrgeReportService.SetComplete(report.UnitId, Const.ReportType_2, report.Year.ToString(), report.Month.ToString());
+ var report = db.Information_AccidentCauseReport.FirstOrDefault(e => e.AccidentCauseReportId == item);
+ if (report != null)
+ {
+ report.UpState = BLL.Const.UpState_3;
+ db.SubmitChanges();
+ ////更新 当前人要处理的意见
+ ProjectDataFlowSetService.CloseFlowOperate(Const.MillionsMonthlyReportMenuId, item, string.Empty);
+ ////更新催报信息
+ UrgeReportService.SetComplete(report.UnitId, Const.ReportType_2, report.Year.ToString(), report.Month.ToString());
+ }
}
+
+ LogService.AddSys_Log(CurrUser, "【职工伤亡事故原因分析报表】上传到服务器" + upReport.Count().ToString() + "条数据;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
+ }
+ else
+ {
+ LogService.AddSys_Log(CurrUser, "【职工伤亡事故原因分析报表】上传到服务器失败;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
- code = "1";
- LogService.AddSys_Log(CurrUser, "【职工伤亡事故原因分析报表】上传到服务器" + getR.Count.ToString() + "条数据;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
catch (Exception ex)
{
@@ -216,12 +253,27 @@
return code;
}
}
+ ///
+ /// AccidentCauseReportApi调用
+ ///
+ /// 主表
+ /// 明细表
+ ///
+ private static int UpApiAccidentCauseReport(IQueryable upReport, IQueryable upReportItem)
+ {
+ string baseurl = "/api/InformationData/SaveAccidentCauseReport";
+ //合并
+ //var resultJson = JsonConvert.SerializeObject(new { upReport, ReportItem = upReportItem });
+ var resultJson = JsonConvert.SerializeObject(upReport.FirstOrDefault());
+ var resultJson1 = JsonConvert.SerializeObject(new { AccidentCauseReportItem = upReportItem });
+ resultJson = "{\"InformationDataItems\":[" + (resultJson + resultJson1).Replace("}{", ",") + "]}";
+ var responeData = BLL.ServerService.PushCNCEC(resultJson, baseurl);
+
+ return responeData.code;
+ }
#endregion
#region 安全生产数据季报上报
- ///
- /// 安全生产数据季报上报
- ///
public static string UpSafetyQuarterlyReport(string safetyQuarterlyReportId, Model.Sys_User CurrUser)
{
string code = "0";
@@ -231,7 +283,7 @@
{
CNCECHSSEService.HSSEServiceClient hsseC = new CNCECHSSEService.HSSEServiceClient();
var upReport = from x in db.Information_SafetyQuarterlyReport
- where x.SafetyQuarterlyReportId == safetyQuarterlyReportId
+ where x.SafetyQuarterlyReportId == safetyQuarterlyReportId
select new CNCECHSSEService.Information_SafetyQuarterlyReport
{
SafetyQuarterlyReportId = x.SafetyQuarterlyReportId,
@@ -248,6 +300,7 @@
WorkHoursAccuracyRemark = x.WorkHoursAccuracyRemark,
MainBusinessIncome = x.MainBusinessIncome,
MainBusinessIncomeRemark = x.MainBusinessIncomeRemark,
+ FillingDate = x.FillingDate,
ConstructionRevenue = x.ConstructionRevenue,
ConstructionRevenueRemark = x.ConstructionRevenueRemark,
UnitTimeIncome = x.UnitTimeIncome,
@@ -316,33 +369,55 @@
HarmfulMediumCoverRate = x.HarmfulMediumCoverRate,
HarmfulMediumCoverRateRemark = x.HarmfulMediumCoverRateRemark
};
-
- var getR = hsseC.DataInsertInformation_SafetyQuarterlyReportTable(upReport.ToList());
- foreach (var item in getR)
+ //老接口Serveice
+ // var getR = hsseC.DataInsertInformation_SafetyQuarterlyReportTable(upReport.ToList());
+ //新接口Api
+ code = UpApiSaveSafetyQuarterlyReport(upReport).ToString();
+ if (code == "1")
{
- var report = db.Information_SafetyQuarterlyReport.FirstOrDefault(e => e.SafetyQuarterlyReportId == item);
- if (report != null)
+ foreach (var item in upReport.Select(p => p.SafetyQuarterlyReportId))
{
- report.UpState = BLL.Const.UpState_3;
- db.SubmitChanges();
- ////更新 当前人要处理的意见
- ProjectDataFlowSetService.CloseFlowOperate(Const.MillionsMonthlyReportMenuId, item, string.Empty);
- ////更新催报信息
- UrgeReportService.SetComplete(report.UnitId, Const.ReportType_3, report.YearId.ToString(), report.Quarters.ToString());
- }
+ var report = db.Information_SafetyQuarterlyReport.FirstOrDefault(e => e.SafetyQuarterlyReportId == item);
+ if (report != null)
+ {
+ report.UpState = BLL.Const.UpState_3;
+ db.SubmitChanges();
+ ////更新 当前人要处理的意见
+ ProjectDataFlowSetService.CloseFlowOperate(Const.MillionsMonthlyReportMenuId, item, string.Empty);
+ ////更新催报信息
+ UrgeReportService.SetComplete(report.UnitId, Const.ReportType_3, report.YearId.ToString(), report.Quarters.ToString());
+ }
+ };
+ LogService.AddSys_Log(CurrUser, "【安全生产数据季报上报】上传到服务器" + upReport.Count().ToString() + "条数据;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
+
+ }
+ else
+ {
+ LogService.AddSys_Log(CurrUser, "【安全生产数据季报上报】上传到服务器失败;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
- code = "1";
- LogService.AddSys_Log(CurrUser, "【安全生产数据季报上报】上传到服务器" + getR.Count.ToString() + "条数据;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
catch (Exception ex)
{
ErrLogInfo.WriteLog("【安全生产数据季报上报】上传到服务器", ex);
LogService.AddSys_Log(CurrUser, "【安全生产数据季报上报】上传到服务器失败;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
-
return code;
}
}
+ ///
+ /// DrillConductedQuarterlyReportApi调用
+ ///
+ /// 主表
+ /// 明细表
+ ///
+ private static int UpApiSaveSafetyQuarterlyReport(IQueryable upReport)
+ {
+ string baseurl = "/api/InformationData/SaveSafetyQuarterlyReport";
+ var resultJson = JsonConvert.SerializeObject(new { InformationDataItems = upReport });
+ var responeData = BLL.ServerService.PushCNCEC(resultJson, baseurl);
+
+ return responeData.code;
+ }
#endregion
#region 应急演练开展情况季报表上报
@@ -393,23 +468,31 @@
SDDesktop = x.SDDesktop,
SortIndex = x.SortIndex,
};
-
- var getR = hsseC.DataInsertInformation_DrillConductedQuarterlyReportTable(upReport.ToList(), upReportItem.ToList());
- foreach (var item in getR)
+ //老接口Serveice
+ //var getR = hsseC.DataInsertInformation_DrillConductedQuarterlyReportTable(upReport.ToList(), upReportItem.ToList());
+ //新接口Api
+ code = UpApiSaveDrillConductedQuarterlyReport(upReport, upReportItem).ToString();
+ if (code == "1")
{
- var report = db.Information_DrillConductedQuarterlyReport.FirstOrDefault(e => e.DrillConductedQuarterlyReportId == item);
- if (report != null)
+ foreach (var item in upReport.Select(p => p.DrillConductedQuarterlyReportId))
{
- report.UpState = BLL.Const.UpState_3;
- db.SubmitChanges();
- ////更新 当前人要处理的意见
- ProjectDataFlowSetService.CloseFlowOperate(Const.MillionsMonthlyReportMenuId, item, string.Empty);
- ////更新催报信息
- UrgeReportService.SetComplete(report.UnitId, Const.ReportType_4, report.YearId.ToString(), report.Quarter.ToString());
+ var report = db.Information_DrillConductedQuarterlyReport.FirstOrDefault(e => e.DrillConductedQuarterlyReportId == item);
+ if (report != null)
+ {
+ report.UpState = BLL.Const.UpState_3;
+ db.SubmitChanges();
+ ////更新 当前人要处理的意见
+ ProjectDataFlowSetService.CloseFlowOperate(Const.MillionsMonthlyReportMenuId, item, string.Empty);
+ ////更新催报信息
+ UrgeReportService.SetComplete(report.UnitId, Const.ReportType_4, report.YearId.ToString(), report.Quarter.ToString());
+ }
}
+ LogService.AddSys_Log(CurrUser, "【应急演练开展情况季报表上报】上传到服务器" + upReport.Count().ToString() + "条数据;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
+ }
+ else
+ {
+ LogService.AddSys_Log(CurrUser, "【应急演练开展情况季报表上报】上传到服务器失败;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
- code = "1";
- LogService.AddSys_Log(CurrUser, "【应急演练开展情况季报表上报】上传到服务器" + getR.Count.ToString() + "条数据;", null, BLL.Const.MillionsMonthlyReportMenuId, BLL.Const.BtnUploadResources);
}
catch (Exception ex)
{
@@ -420,6 +503,23 @@
return code;
}
}
+ ///
+ /// DrillConductedQuarterlyReportApi调用
+ ///
+ /// 主表
+ /// 明细表
+ ///
+ private static int UpApiSaveDrillConductedQuarterlyReport(IQueryable upReport, IQueryable upReportItem)
+ {
+ string baseurl = "/api/InformationData/SaveDrillConductedQuarterlyReport";
+ //合并
+ //var resultJson = JsonConvert.SerializeObject(new { upReport, ReportItem = upReportItem });
+ var resultJson = JsonConvert.SerializeObject(upReport.FirstOrDefault());
+ var resultJson1 = JsonConvert.SerializeObject(new { drillConductedQuarterlyReportItem = upReportItem });
+ resultJson = "{\"InformationDataItems\":[" + (resultJson + resultJson1).Replace("}{", ",") + "]}";
+ var responeData = BLL.ServerService.PushCNCEC(resultJson, baseurl);
+ return responeData.code;
+ }
#endregion
#region 应急演练工作计划半年报表
@@ -460,23 +560,33 @@
ExerciseWay = x.ExerciseWay,
SortIndex = x.SortIndex,
};
-
- var getR = hsseC.DataInsertInformation_DrillPlanHalfYearReportTable(upReport.ToList(), upReportItem.ToList());
- foreach (var item in getR)
+ //老接口Serveice
+ // var getR = hsseC.DataInsertInformation_DrillPlanHalfYearReportTable(upReport.ToList(), upReportItem.ToList());
+ //新接口Api
+ code = UpApiDrillPlanHalfYearReport(upReport, upReportItem).ToString();
+ if (code == "1")
{
- var report = db.Information_DrillPlanHalfYearReport.FirstOrDefault(e => e.DrillPlanHalfYearReportId == item);
- if (report != null)
+ foreach (var item in upReport.Select(p => p.DrillPlanHalfYearReportId))
{
- report.UpState = BLL.Const.UpState_3;
- db.SubmitChanges();
- ////更新 当前人要处理的意见
- ProjectDataFlowSetService.CloseFlowOperate(Const.DrillPlanHalfYearReportMenuId, item, string.Empty);
- ////更新催报信息
- UrgeReportService.SetComplete(report.UnitId, Const.ReportType_5, report.YearId.ToString(), report.HalfYearId.ToString());
+ var report = db.Information_DrillPlanHalfYearReport.FirstOrDefault(e => e.DrillPlanHalfYearReportId == item);
+ if (report != null)
+ {
+ report.UpState = BLL.Const.UpState_3;
+ db.SubmitChanges();
+ ////更新 当前人要处理的意见
+ ProjectDataFlowSetService.CloseFlowOperate(Const.DrillPlanHalfYearReportMenuId, item, string.Empty);
+ ////更新催报信息
+ UrgeReportService.SetComplete(report.UnitId, Const.ReportType_5, report.YearId.ToString(), report.HalfYearId.ToString());
+ }
}
+
+ LogService.AddSys_Log(CurrUser, "【应急演练工作计划半年报表】上传到服务器" + upReport.Count().ToString() + "条数据;", null, BLL.Const.DrillPlanHalfYearReportMenuId, BLL.Const.BtnUploadResources);
}
- code = "1";
- LogService.AddSys_Log(CurrUser, "【应急演练工作计划半年报表】上传到服务器" + getR.Count.ToString() + "条数据;", null, BLL.Const.DrillPlanHalfYearReportMenuId, BLL.Const.BtnUploadResources);
+ else
+ {
+ LogService.AddSys_Log(CurrUser, "【应急演练工作计划半年报表】上传到服务器失败;", null, BLL.Const.DrillPlanHalfYearReportMenuId, BLL.Const.BtnUploadResources);
+ }
+
}
catch (Exception ex)
{
@@ -486,6 +596,24 @@
return code;
}
}
+ ///
+ /// DrillPlanHalfYearReportApi调用
+ ///
+ /// 主表
+ /// 明细表
+ ///
+ private static int UpApiDrillPlanHalfYearReport(IQueryable upReport, IQueryable upReportItem)
+ {
+ string baseurl = "/api/InformationData/SaveDrillPlanHalfYearReport";
+ //合并
+ //var resultJson = JsonConvert.SerializeObject(new { upReport, ReportItem = upReportItem });
+ var resultJson = JsonConvert.SerializeObject(upReport.FirstOrDefault());
+ var resultJson1 = JsonConvert.SerializeObject(new { drillPlanHalfYearReportItem = upReportItem });
+ resultJson = "{\"InformationDataItems\":[" + (resultJson + resultJson1).Replace("}{", ",") + "]}";
+
+ var responeData = BLL.ServerService.PushCNCEC(resultJson, baseurl);
+ return responeData.code;
+ }
#endregion
#region 企业监督检查报告上报