From 8185480c1594d0b1768443777cfd9f2f1e0ee80f Mon Sep 17 00:00:00 2001 From: gaofei <181547018@qq.com> Date: Fri, 2 Jun 2023 10:26:13 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=95=B0=E6=8D=AE=E4=B8=8A?= =?UTF-8?q?=E6=8A=A5=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../DataSync/CNCECServerController.cs | 224 ++++++++++++++++++ SGGL/WebAPI/WebAPI.csproj | 1 + 2 files changed, 225 insertions(+) create mode 100644 SGGL/WebAPI/Controllers/DataSync/CNCECServerController.cs diff --git a/SGGL/WebAPI/Controllers/DataSync/CNCECServerController.cs b/SGGL/WebAPI/Controllers/DataSync/CNCECServerController.cs new file mode 100644 index 00000000..5d467e30 --- /dev/null +++ b/SGGL/WebAPI/Controllers/DataSync/CNCECServerController.cs @@ -0,0 +1,224 @@ +using BLL; +using Model; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Web; +using System.Web.Http; +using System.Web.Mvc; + +namespace WebAPI.Controllers +{ + /// + /// 上报集团数据接口 + /// + public class CNCECServerController : ApiController + { + /// + /// 获取质量统计数据 + /// + /// + public Model.ReturnData PostGetCQMSData() + { + var returnData = new Model.ReturnData(); + returnData.type = "CQMS"; + returnData.time = DateTime.Now.ToString(); + ServerService.GetToken(); + returnData.token = BLL.SysConstSetService.CNCECToken; + returnData.expiryTime = BLL.SysConstSetService.CNCECTTokenExTime; + if (!string.IsNullOrEmpty(returnData.token) && !string.IsNullOrEmpty(returnData.expiryTime)&& DateTime.Parse(returnData.expiryTime)>DateTime.Now) + { + returnData.data = CQMSDataService.GetTodayCQMSData_CQMS(); + } + else + { + returnData.code = 500; + returnData.message = "token失效"; + } + return returnData; + } + /// + /// 获取质量统计数据成功后,回调通知上报成功 + /// + /// + /// + public Model.ReturnData PostGetCQMSData_CallBalk([FromBody] CQMSData data) + { + var returnData = new Model.ReturnData(); + try + { + returnData.type = "CQMS_Back"; + returnData.time = DateTime.Now.ToString(); + foreach (var item in data.CQMSDataItems) + { + var cQMSData_CQMS= CQMSDataService.GetCQMSData_CQMSById(item.Id); + cQMSData_CQMS.State = Const.CNCEC_State_S; + CQMSDataService.UpdateCQMSData_CQMS(cQMSData_CQMS); + } + + } + catch (Exception ex) + { + + returnData.code = 404; + returnData.message = ex.ToString(); + } + return returnData; + } + /// + /// 获取焊接统计数据 + /// + /// + public Model.ReturnData PostGetHJGLData() + { + var returnData = new Model.ReturnData(); + returnData.type = "HJGL"; + returnData.time = DateTime.Now.ToString(); + ServerService.GetToken(); + returnData.token = BLL.SysConstSetService.CNCECToken; + returnData.expiryTime = BLL.SysConstSetService.CNCECTTokenExTime; + if (!string.IsNullOrEmpty(returnData.token) && !string.IsNullOrEmpty(returnData.expiryTime)&&DateTime.Parse(returnData.expiryTime) > DateTime.Now) + { + returnData.data = HJGLData_HJGLService.GetTodayHJGLData_HJGL(); + } + else + { + returnData.code = 500; + returnData.message = "token失效"; + } + return returnData; + } + /// + /// 获取焊接统计数据 成功后,回调通知上报成功 + /// + /// + /// + public Model.ReturnData PostGetHJGLData_CallBalk([FromBody] Model.HJGLData data) + { + var returnData = new Model.ReturnData(); + try + { + returnData.type = "HJGL_Back"; + returnData.time = DateTime.Now.ToString(); + foreach (var item in data.HJGLDataItems) + { + var hJGLData_HJGL = HJGLData_HJGLService.GetHJGLData_HJGLById(item.Id); + hJGLData_HJGL.State = Const.CNCEC_State_S; + HJGLData_HJGLService.UpdateHJGLData_HJGL(hJGLData_HJGL); + } + } + catch (Exception ex) + { + + returnData.code = 404; + returnData.message = ex.ToString(); + } + return returnData; + } + /// + /// 获取安全统计数据 + /// + /// + public Model.ReturnData PostGetHSSEData() + { + var returnData = new Model.ReturnData(); + returnData.type = "HSSE"; + returnData.time = DateTime.Now.ToString(); + ServerService.GetToken(); + returnData.token = BLL.SysConstSetService.CNCECToken; + returnData.expiryTime = BLL.SysConstSetService.CNCECTTokenExTime; + if (!string.IsNullOrEmpty(returnData.token) && !string.IsNullOrEmpty(returnData.expiryTime) && DateTime.Parse(returnData.expiryTime) > DateTime.Now) + { + returnData.data = HSSEData_HSSEService.GetTodayHSSEData_HSSE(); + } + else + { + returnData.code = 500; + returnData.message = "token失效"; + } + return returnData; + } + /// + /// 获取安全统计数据成功后,回调通知上报成功 + /// + /// + /// + public Model.ReturnData PostGetHSSEData_CallBalk([FromBody] HSSEData data) + { + var returnData = new Model.ReturnData(); + try + { + returnData.type = "HSSE_Back"; + returnData.time = DateTime.Now.ToString(); + + foreach (var item in data.HSSEDataItems) + { + var hSSEData_HSSE = HSSEData_HSSEService.GetHSSEData_HSSEById(item.Id); + hSSEData_HSSE.State = Const.CNCEC_State_S; + HSSEData_HSSEService.UpdateHSSEData_HSSE(hSSEData_HSSE); + } + } + catch (Exception ex) + { + + returnData.code = 404; + returnData.message = ex.ToString(); + } + return returnData; + } + + /// + /// 获取实业统计数据 + /// + /// + public Model.ReturnData PostGetSYHSEData() + { + var returnData = new Model.ReturnData(); + returnData.type = "SYHSE"; + returnData.time = DateTime.Now.ToString(); + ServerService.GetToken(); + returnData.token = BLL.SysConstSetService.CNCECToken; + returnData.expiryTime = BLL.SysConstSetService.CNCECTTokenExTime; + if (!string.IsNullOrEmpty(returnData.token) && !string.IsNullOrEmpty(returnData.expiryTime) && DateTime.Parse(returnData.expiryTime) > DateTime.Now) + { + returnData.data = SYHSEData_SYHSEService.GetTodaySYHSEData_SYHSE(); + } + else + { + returnData.code = 500; + returnData.message = "token失效"; + } + return returnData; + } + /// + /// 获取实业统计数据成功后,回调通知上报成功 + /// + /// + /// + public Model.ReturnData PostGetSYHSEData_CallBalk([FromBody] SYHSEData data) + { + var returnData = new Model.ReturnData(); + try + { + returnData.type = "SYHSE_Back"; + returnData.time = DateTime.Now.ToString(); + foreach (var item in data.SYHSEDataItems) + { + var sYHSEData_SYHSE = SYHSEData_SYHSEService.GetSYHSEData_SYHSEById(item.Id); + sYHSEData_SYHSE.State = Const.CNCEC_State_S; + SYHSEData_SYHSEService.UpdateSYHSEData_SYHSE(sYHSEData_SYHSE); + } + //SYHSEData_SYHSE data = _data; + //data.State = Const.CNCEC_State_S; + //SYHSEData_SYHSEService.UpdateSYHSEData_SYHSE(data); + } + catch (Exception ex) + { + + returnData.code = 404; + returnData.message = ex.ToString(); + } + return returnData; + } + } +} \ No newline at end of file diff --git a/SGGL/WebAPI/WebAPI.csproj b/SGGL/WebAPI/WebAPI.csproj index 19a32c6a..50ff78e2 100644 --- a/SGGL/WebAPI/WebAPI.csproj +++ b/SGGL/WebAPI/WebAPI.csproj @@ -174,6 +174,7 @@ +