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 @@ +