From 67c7ce6b0e647e0307c29c6d655f8d461d344a17 Mon Sep 17 00:00:00 2001
From: gaofei <181547018@qq.com>
Date: Mon, 16 Jan 2023 17:04:50 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BA=94=E5=BC=A0=E6=8A=A5?=
=?UTF-8?q?=E8=A1=A8=E4=B8=8A=E6=8A=A5=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
SGGL/BLL/WebService/CNCECHSSEWebService.cs | 270 +++++++++++++++------
1 file changed, 199 insertions(+), 71 deletions(-)
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 企业监督检查报告上报