using System;
using System.Collections.Generic;
using System.Configuration;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Security.Policy;
using System.Web.Http;
using BLL;
using Model;
namespace WebAPI.Controllers
{
///
/// 安全管理数据同步
///
public class HsseController : ApiController
{
#region 查询接口
///
/// 根据项目名称返回项目projectid
///
///
///
private string getProjectIdByCode(string ProjectName) {
using (Model.SUBQHSEDB db = new Model.SUBQHSEDB(Funs.ConnString))
{
var model = db.Base_Project.FirstOrDefault(x => x.ProjectName == ProjectName);
if (model != null)
{
return model.ProjectId;
}
else {
return "";
}
}
}
///
/// 根据单位名称获取单位id
///
///
///
private string getUnitIdByUnitCollCropCode(string unitname) {
using (Model.SUBQHSEDB db = new Model.SUBQHSEDB(Funs.ConnString))
{
var model = db.Base_Unit.FirstOrDefault(x => x.UnitName == unitname);
if (model != null)
{
return model.UnitId;
}
else
{
return "";
}
}
}
///
/// 根据身份证号码获取userid
///
///
///
private string getUserIdByIdentityCard(string IdentityCard)
{
using (Model.SUBQHSEDB db = new Model.SUBQHSEDB(Funs.ConnString))
{
var model = db.Sys_User.FirstOrDefault(x => x.IdentityCard == IdentityCard);
if (model != null)
{
return model.UserId;
}
else
{
return "";
}
}
}
private string getUrlByType(string type)
{
string folderUrl = "FileUpLoad/" + type + "/" + DateTime.Now.ToString("yyyy-MM") + "/";
string localRoot = ConfigurationManager.AppSettings["localRoot"] + folderUrl; //物理路径
if (!Directory.Exists(localRoot))
{
Directory.CreateDirectory(localRoot);
}
string url = localRoot + string.Format("{0:yyyyMMddHHmmssffff}", DateTime.Now) + ".jpg";
return url;
}
#endregion
///
/// 人员信息档案同步
///
///
///
[Route("PersonSync")]
[HttpPost]
public Model.ResponeData PersonSync([FromBody] SitePersonPersonItem dto)
{
var responeData = new Model.ResponeData();
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
using (Model.SUBQHSEDB db = new Model.SUBQHSEDB(Funs.ConnString))
{
#region 判断参数
if (string.IsNullOrEmpty(model.PersonName))
{
responeData.code = 0;
responeData.message = "人员姓名（PersonName）不能为空";
return responeData;
}
if (string.IsNullOrEmpty(model.IdentityCard))
{
responeData.code = 0;
responeData.message = "证件号码（IdentityCard）不能为空";
return responeData;
}
if (string.IsNullOrEmpty(model.WorkPostId))
{
responeData.code = 0;
responeData.message = "所属岗位（WorkPostId）不能为空";
return responeData;
}
else {
var pmodel = db.Base_WorkPost.FirstOrDefault(x => x.WorkPostName == model.WorkPostId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "所属岗位(WorkPostId)未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.WorkPostId = pmodel.WorkPostId;
}
}
#region 系统参数判断
if (string.IsNullOrEmpty(model.ProjectId))
{
responeData.code = 0;
responeData.message = "项目名称ProjectId不能为空";
return responeData;
}
else
{
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "当前项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else{
model.ProjectId = pid;
}
}
if (string.IsNullOrEmpty(model.UnitId))
{
responeData.code = 0;
responeData.message = "单位名称UnitId不能为空。";
return responeData;
}
else
{
var uid = getUnitIdByUnitCollCropCode(model.UnitId);
if (uid == "")
{
responeData.code = 0;
responeData.message = "单位名称UnitId未查询到数据，请检查是否正确。";
return responeData;
}
else {
model.UnitId = uid;
}
}
#endregion
if (!string.IsNullOrEmpty(model.TeamGroupId))
{
var pmodel = db.ProjectData_TeamGroup.FirstOrDefault(x => x.TeamGroupName == model.TeamGroupId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "所属班组（TeamGroupId）未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.TeamGroupId = pmodel.TeamGroupId;
}
}
if (!string.IsNullOrEmpty(model.MainCNProfessionalId))
{
var pmodel = db.Base_CNProfessional.FirstOrDefault(x => x.CNProfessionalId == model.MainCNProfessionalId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "主专业(MainCNProfessionalId)未查询到数据，请检查是否正确。";
return responeData;
}
}
if (!string.IsNullOrEmpty(model.ViceCNProfessionalId))
{
var pmodel = db.Base_CNProfessional.FirstOrDefault(x =>model.MainCNProfessionalId.Split(',').Contains(x.CNProfessionalId));
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "副专业(ViceCNProfessionalId)未查询到数据，请检查是否正确。";
return responeData;
}
}
if (!string.IsNullOrEmpty(model.WorkAreaId))
{
var WorkAreaId="";
foreach (var item in model.WorkAreaId.Split(','))
{
var pmodel = db.WBS_UnitWork.FirstOrDefault(x => x.UnitWorkName==item);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "单位工程(WorkAreaId)" + item + "未查询到数据，请检查是否正确。";
return responeData;
}
else {
WorkAreaId += pmodel.UnitWorkId + ",";
}
}
model.WorkAreaId= WorkAreaId.Substring(0, WorkAreaId.Length - 1);
}
if (string.IsNullOrEmpty(model.DepartId))
{
model.DepartId = null;
}
if (string.IsNullOrEmpty(model.PositionId))
{
model.PositionId = null;
}
if (string.IsNullOrEmpty(model.PostTitleId))
{
model.PostTitleId = null;
}
if (string.IsNullOrEmpty(model.AuditorId))
{
model.AuditorId = null;
}
#endregion
try
{
model.IdcardType = "SHENFEN_ZHENGJIAN";
//添加
if (!string.IsNullOrEmpty(model.CardNo))
{
int cardNoCount = BLL.PersonService.GetPersonCountByCardNo(model.ProjectId, model.CardNo);
if (cardNoCount > 0)
{
responeData.code = 0;
responeData.message = "此卡号已存在，不能重复！";
return responeData;
}
}
if (!string.IsNullOrEmpty(model.IdentityCard))
{
var identityCardCount = PersonService.GetPersonCountByIdentityCard(model.IdentityCard, model.ProjectId);
if (identityCardCount != null)
{
responeData.code = 0;
responeData.message = "此身份证号已存在，不能重复！";
return responeData;
}
}
model.PersonId = SQLHelper.GetNewID(typeof(Model.SitePerson_Person));
model.Isprint = "0";
BLL.PersonService.AddPerson(model);
responeData.message = "添加成功";
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
}
///
/// 人工时日报同步
///
///
[Route("DailyReportOfLaborHoursSync")]
[HttpPost]
public Model.ResponeData DailyReportOfLaborHoursSync([FromBody] SitePerson_DayReportItem dto)
{
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (string.IsNullOrEmpty(model.ProjectId))
{
responeData.code = 0;
responeData.message = "项目名称ProjectId不能为空";
return responeData;
}
else
{
//判断projectid是否有数据
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "当前项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (dto.ChildList.Count>0)
{
foreach (var item in dto.ChildList)
{
var uid = getUnitIdByUnitCollCropCode(item.UnitId);
if (uid == "")
{
responeData.code = 0;
responeData.message = "子表单位名称UnitId未查询到数据，请检查是否正确。";
return responeData;
}
else
{
item.UnitId = uid;
}
}
}
if (!string.IsNullOrEmpty(model.CompileMan))
{
var userid = getUserIdByIdentityCard(model.CompileMan);
if (userid == "")
{
responeData.code = 0;
responeData.message = "编制人身份证号码CompileMan未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.CompileMan = userid;
}
}
#endregion
model.DayReportId = SQLHelper.GetNewID(typeof(Model.SitePerson_DayReport));
model.States = BLL.Const.State_2;
BLL.SitePerson_DayReportService.AddDayReport(model);
//插入子表
foreach (var item in dto.ChildList)
{
var mapperChild = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var modelChild = mapperChild.Map(item);
modelChild.DayReportDetailId = SQLHelper.GetNewID(typeof(Model.SitePerson_DayReportDetail));
modelChild.DayReportId = model.DayReportId;
BLL.SitePerson_DayReportDetailService.AddDayReportDetail(modelChild);
var posts = (from x in Funs.DB.Base_WorkPost
join y in Funs.DB.SitePerson_Person
on x.WorkPostId equals y.WorkPostId
where y.UnitId == item.UnitId && y.ProjectId == model.ProjectId
orderby x.WorkPostCode
select x).Distinct().ToList();
foreach (var postItem in posts)
{
Model.SitePerson_DayReportUnitDetail newDayReportUnitDetail = new Model.SitePerson_DayReportUnitDetail
{
DayReportDetailId = modelChild.DayReportDetailId,
PostId = postItem.WorkPostId,
CheckPersonNum = GetCheckingCout(postItem.WorkPostId,model.CompileDate,model.ProjectId)
};
newDayReportUnitDetail.RealPersonNum = newDayReportUnitDetail.CheckPersonNum;
newDayReportUnitDetail.PersonWorkTime = newDayReportUnitDetail.RealPersonNum * modelChild.WorkTime;
BLL.SitePerson_DayReportUnitDetailService.AddDayReportUnitDetail(newDayReportUnitDetail);
}
}
responeData.message = "添加成功";
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
#region 得到当前岗位考勤人数
///
/// 得到当前岗位考勤人数
///
///
///
///
///
private int GetCheckingCout(string workPostId,DateTime? CompileDate,string Projectid)
{
int count = 0;
DateTime? nowMont = CompileDate;
if (nowMont.HasValue)
{
var checks = from x in Funs.DB.SitePerson_Checking
join y in Funs.DB.SitePerson_Person on x.PersonId equals y.PersonId
join z in Funs.DB.Base_WorkPost on y.WorkPostId equals z.WorkPostId
where x.IntoOutTime > nowMont.Value.AddDays(-1) && x.IntoOutTime < nowMont.Value.AddDays(1) && y.ProjectId == Projectid
&& z.WorkPostId == workPostId
select x;
count = checks.Count();
}
return count;
}
#endregion
///
/// 培训记录同步
///
///
[Route("TrainRecordSync")]
[HttpPost]
public Model.ResponeData TrainRecordSync([FromBody] EduTrain_TrainRecordItem dto)
{
var responeData = new Model.ResponeData();
var unitid = "";
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (!string.IsNullOrEmpty(model.ProjectId))
{
//判断projectid是否有数据
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "当前所属项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (!string.IsNullOrEmpty(model.TrainTypeId))
{
var pmodel = db.Base_TrainType.FirstOrDefault(x => x.TrainTypeName == model.TrainTypeId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "培训类别名称未查询到数据，请检查是否正确。";
return responeData;
}
else {
model.TrainTypeId = pmodel.TrainTypeId;
}
}
if (!string.IsNullOrEmpty(model.TrainLevelId))
{
var pmodel = db.Base_TrainLevel.FirstOrDefault(x => x.TrainLevelName == model.TrainLevelId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "培训级别名称未查询到数据，请检查是否正确。";
return responeData;
}
else {
model.TrainLevelId = pmodel.TrainLevelId;
}
}
if (!string.IsNullOrEmpty(model.UnitIds))
{
var unitIds = "";
foreach (var item in model.UnitIds.Split(','))
{
var uid = getUnitIdByUnitCollCropCode(item);
if (uid == "")
{
responeData.code = 0;
responeData.message = "单位名称UnitIds未查询到数据，请检查是否正确。";
return responeData;
}
else
{
unitIds += uid+",";
}
}
model.UnitIds = unitIds.Substring(0, unitIds.Length - 1);
var umodel = Funs.DB.Base_Unit.FirstOrDefault(x =>model.UnitIds.Split(',').Contains(x.UnitId));
if (umodel == null)
{
responeData.code = 0;
responeData.message = "单位名称UnitIds未查询到数据，请检查是否正确。";
return responeData;
}
}
if (!string.IsNullOrEmpty(model.CompileMan))
{
var userid = getUserIdByIdentityCard(model.CompileMan);
if (userid == "")
{
responeData.code = 0;
responeData.message = "编制人身份证号码CompileMan未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.CompileMan = userid;
}
var pmodel = db.Sys_User.FirstOrDefault(x => x.UserId == model.CompileMan);
unitid = pmodel.UnitId;
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "编制人CompileMan未查询到数据，请检查是否正确。";
return responeData;
}
}
if (!string.IsNullOrEmpty(model.WorkPostIds))
{
var WorkPostIds = "";
foreach (var item in model.WorkPostIds.Split(','))
{
var pmodel = db.Base_WorkPost.FirstOrDefault(x => x.WorkPostName== item);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "培训岗位名称"+ item + "未查询到数据，请检查是否正确。";
return responeData;
}
else
{
WorkPostIds += item + ",";
}
}
model.WorkPostIds = WorkPostIds.Substring(0, WorkPostIds.Length - 1);
}
if (dto.ChildList.Count>0)
{
foreach (var item in dto.ChildList)
{
var sPmodel = db.SitePerson_Person.FirstOrDefault(x => x.IdentityCard == item.PersonId && x.ProjectId == model.ProjectId);
if (sPmodel == null)
{
responeData.code = 0;
responeData.message = "根据人员身份证号码（" + item + "）和项目名称未查询到该人员数据。";
return responeData;
}
else
{
item.PersonId = sPmodel.PersonId;
}
}
}
if (string.IsNullOrEmpty(model.TrainLevelId))
{
model.TrainLevelId = null;
}
#endregion
model.States= BLL.Const.State_2;
model.TrainingId = SQLHelper.GetNewID(typeof(Model.EduTrain_TrainRecord));
model.TrainPersonNum = dto.ChildList.Count;
model.TrainingCode= CodeRecordsService.ReturnCodeByMenuIdProjectId(Const.ProjectTrainRecordMenuId, model.ProjectId, unitid);
BLL.EduTrain_TrainRecordService.AddTraining(model);
if (dto.ChildList.Count>0)
{
foreach (var item in dto.ChildList)
{
var mapperChild = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var modelChild = mapperChild.Map(item);
modelChild.TrainDetailId= SQLHelper.GetNewID(typeof(Model.EduTrain_TrainRecordDetail));
modelChild.TrainingId = model.TrainingId;
BLL.EduTrain_TrainRecordDetailService.AddTrainDetail(modelChild);
}
}
responeData.message = "添加成功。";
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 培训计划同步
///
///
[Route("TrainPlanSync")]
[HttpPost]
public Model.ResponeData TrainPlanSync([FromBody] Training_PlanDto dto)
{
var unitid = "";
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (!string.IsNullOrEmpty(model.ProjectId))
{
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "当前所属项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (!string.IsNullOrEmpty(model.TrainTypeId))
{
var pmodel = db.Base_TrainType.FirstOrDefault(x => x.TrainTypeName == model.TrainTypeId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "培训类别TrainTypeId未查询到数据，请检查是否正确。";
return responeData;
}
else {
model.TrainTypeId = pmodel.TrainTypeId;
}
}
if (!string.IsNullOrEmpty(model.TrainLevelId))
{
var pmodel = db.Base_TrainLevel.FirstOrDefault(x => x.TrainLevelName == model.TrainLevelId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "培训级别TrainLevelId未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.TrainLevelId = pmodel.TrainLevelId;
}
}
if (!string.IsNullOrEmpty(model.UnitIds))
{
var unitids = "";
foreach (var item in model.UnitIds.Split(','))
{
var uid = getUnitIdByUnitCollCropCode(item);
if (uid == "")
{
responeData.code = 0;
responeData.message = "培训单位名称UnitIds(" + uid + ")未查询到数据，请检查是否正确。";
return responeData;
}
else
{
unitids += uid + ",";
}
}
model.UnitIds = unitids.Substring(0, unitids.Length - 1);
var umodel = Funs.DB.Base_Unit.FirstOrDefault(x => model.UnitIds.Split(',').Contains(x.UnitId));
if (umodel == null)
{
responeData.code = 0;
responeData.message = "培训单位名称UnitIds未查询到数据，请检查是否正确。";
return responeData;
}
}
if (!string.IsNullOrEmpty(model.DesignerId))
{
var userid = getUserIdByIdentityCard(model.DesignerId);
if (userid == "")
{
responeData.code = 0;
responeData.message = "计划制定人身份证号码DesignerId未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.DesignerId = userid;
}
var pmodel = db.Sys_User.FirstOrDefault(x => x.UserId == model.DesignerId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "计划制定人DesignerId未查询到数据，请检查是否正确。";
return responeData;
}
else {
unitid = pmodel.UnitId;
}
}
if (!string.IsNullOrEmpty(model.WorkPostId))
{
var WorkPostId = "";
foreach (var item in model.WorkPostId.Split(','))
{
var pmodel = db.Base_WorkPost.FirstOrDefault(x => x.WorkPostName == item);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "岗位名称" + item + "未查询到数据，请检查是否正确。";
return responeData;
}
else
{
WorkPostId += item + ",";
}
}
model.WorkPostId = WorkPostId.Substring(0, WorkPostId.Length - 1);
//var pmodel = db.Base_WorkPost.FirstOrDefault(x => model.WorkPostId.Split(',').Contains(x.WorkPostId));
//if (pmodel == null)
//{
// responeData.code = 0;
// responeData.message = "适用岗位(WorkPostId)未查询到数据，请检查是否正确。";
// return responeData;
//}
}
if (!string.IsNullOrEmpty(dto.dpSysUser))
{
var personid = "";
foreach (var item in dto.dpSysUser.Split(',')) {
var dpSysUser = db.SitePerson_Person.FirstOrDefault(x=>x.IdentityCard== item && model.UnitIds.Split(',').Contains(x.UnitId));
if (dpSysUser == null)
{
responeData.code = 0;
responeData.message = "当前人员身份证（" + item + "）不在培训单位中。";
return responeData;
}
else {
personid += dpSysUser.PersonId + ",";
}
}
dto.dpSysUser = personid.Substring(0, personid.Length - 1);
var pmodel = db.SitePerson_Person.FirstOrDefault(x => dto.dpSysUser.Split(',').Contains(x.PersonId));
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "人员dpSysUser未查询到数据，请检查是否正确。";
return responeData;
}
}
if (!string.IsNullOrEmpty(dto.dpCompanyTraining))
{
var dpCompanyTraining = "";
foreach (var item in dto.dpCompanyTraining.Split(','))
{
var pmodel = db.Training_CompanyTrainingItem.FirstOrDefault(x => x.CompanyTrainingItemName==item);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "教材" + item + "未查询到数据，请检查是否正确。";
return responeData;
}
else {
dpCompanyTraining += item + ",";
}
}
dto.dpCompanyTraining = dpCompanyTraining.Substring(0, dpCompanyTraining.Length - 1);
}
#endregion
model.PlanId = SQLHelper.GetNewID();
model.PlanCode = CodeRecordsService.ReturnCodeByMenuIdProjectId(Const.ProjectTrainingPlanMenuId, model.ProjectId, unitid);
//插入计划表
TrainingPlanService.AddPlan(model);
//新增培训人员明细
if (!string.IsNullOrEmpty(dto.dpSysUser))
{
////新增培训人员明细
foreach (var PersonId in dto.dpSysUser.Split(','))
{
if (!string.IsNullOrEmpty(PersonId))
{
Model.Training_Task newTrainDetail = new Model.Training_Task
{
TaskId = SQLHelper.GetNewID(),
ProjectId = model.ProjectId,
PlanId = model.PlanId,
UserId = PersonId,
TaskDate = DateTime.Now,
States = Const.State_0, ////未生成培训教材明细
};
db.Training_Task.InsertOnSubmit(newTrainDetail);
db.SubmitChanges();
}
}
}
//新增培训教材类型明细
if (!string.IsNullOrEmpty(dto.dpCompanyTraining))
{
////新增培训教材类型明细
foreach (var CompanyTrainingItemId in dto.dpCompanyTraining.Split(','))
{
if (!string.IsNullOrEmpty(CompanyTrainingItemId))
{
Model.Training_PlanItem newPlanItem = new Model.Training_PlanItem
{
PlanItemId = SQLHelper.GetNewID(),
PlanId = model.PlanId,
};
if (!string.IsNullOrEmpty(CompanyTrainingItemId))
{
newPlanItem.CompanyTrainingItemId = CompanyTrainingItemId;
var trainingItem = Funs.DB.Training_CompanyTrainingItem.FirstOrDefault(x => x.CompanyTrainingItemId == CompanyTrainingItemId);
if (trainingItem != null)
{
newPlanItem.CompanyTrainingId = trainingItem.CompanyTrainingId;
}
}
db.Training_PlanItem.InsertOnSubmit(newPlanItem);
db.SubmitChanges();
}
}
}
responeData.message = "添加成功。";
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
#region 培训任务类
///
/// 培训任务类
///
public class TrainTaskClass {
///
/// 项目名称
///
public string projectName { get; set; }
///
/// 培训计划名称
///
public string planName { get; set; }
///
/// 人员身份证号码(逗号分隔，最后一个不需要逗号)
///
public string personIdCard { get; set; }
}
#endregion
///
/// 培训任务同步
///
///
///
[Route("TrainTaskSync")]
[HttpPost]
public Model.ResponeData TrainTaskSync([FromBody] TrainTaskClass dto)
{
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var pid = getProjectIdByCode(dto.projectName);
if (pid == "")
{
responeData.code = 0;
responeData.message = "项目名称未查询到数据，请检查是否正确。";
return responeData;
}
//根据项目id和计划名称获取计划id
var pmodel = db.Training_Plan.FirstOrDefault(x => x.ProjectId == pid && x.PlanName == dto.planName);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "根据项目名称和培训计划名称未查询到培训计划数据。";
return responeData;
}
else {
var planId = pmodel.PlanId;
//根据人员名称返回人员personid
foreach (var item in dto.personIdCard.Split(','))
{
var sPmodel = db.SitePerson_Person.FirstOrDefault(x => x.IdentityCard == item && x.ProjectId == pid);
if (sPmodel == null)
{
responeData.code = 0;
responeData.message = "根据人员身份证号码（" + item + "）和项目名称未查询到该人员数据。";
return responeData;
}
else {
APITrainingTaskService.getTrainingTaskByPlanIdPersonId(planId, sPmodel.PersonId);
}
}
responeData.message = "培训任务同步成功。";
}
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 培训任务通知同步
///
///
[Route("TrainTaskNoticeSync")]
[HttpPost]
public Model.ResponeData TrainTaskNoticeSync([FromBody] EduTrain_TaskNoticeItem dto)
{
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (!string.IsNullOrEmpty(model.ProjectId))
{
//判断projectid是否有数据
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "当前项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (!string.IsNullOrEmpty(model.TrainType))
{
var pmodel = db.Base_TrainType.FirstOrDefault(x => x.TrainTypeName == model.TrainType);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "培训类型TrainType未查询到数据，请检查是否正确。";
return responeData;
}
else {
model.TrainType = pmodel.TrainTypeId;
}
}
if (!string.IsNullOrEmpty(model.Units))
{
var units = "";
foreach (var item in model.Units.Split(','))
{
var uid = getUnitIdByUnitCollCropCode(item);
if (uid == "")
{
responeData.code = 0;
responeData.message = "单位名称UnitIds(" + item + ")未查询到数据，请检查是否正确。";
return responeData;
}
else
{
units += uid + ",";
}
}
model.Units = units.Substring(0, units.Length - 1);
}
if (!string.IsNullOrEmpty(model.TeachMan))
{
var userid = getUnitIdByUnitCollCropCode(model.TeachMan);
if (userid == "")
{
responeData.code = 0;
responeData.message = "授课人TeachMan未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.TeachMan = userid;
}
}
if (!string.IsNullOrEmpty(model.CreatMan))
{
var userid = getUnitIdByUnitCollCropCode(model.CreatMan);
if (userid == "")
{
responeData.code = 0;
responeData.message = "编制人CreatMan未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.CreatMan = userid;
}
}
if (!string.IsNullOrEmpty(model.State))
{
if (model.State!="0"&&model.State!="1")
{
responeData.code = 0;
responeData.message = "状态只能是0或者1，请检查是否正确。";
return responeData;
}
}
#endregion
model.TaskNoticeId= SQLHelper.GetNewID(typeof(Model.EduTrain_TaskNotice));
BLL.EduTrain_TaskNoticeService.AddEduTrain_TaskNotice(model);
responeData.message = "添加成功";
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 考试计划同步
///
///
[Route("TestPlanSync")]
[HttpPost]
public Model.ResponeData TestPlanSync([FromBody] Training_TestPlanItem dto)
{
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (!string.IsNullOrEmpty(model.ProjectId))
{
//判断projectid是否有数据
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "当前项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (!string.IsNullOrEmpty(model.PlanManId))
{
var userid = getUserIdByIdentityCard(model.PlanManId);
if (userid == "")
{
responeData.code = 0;
responeData.message = "计划人身份证号码PlanManId未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.PlanManId = userid;
}
}
if (!string.IsNullOrEmpty(model.WorkPostIds))
{
var WorkPostIds = "";
foreach (var item in model.WorkPostIds.Split(','))
{
var pmodel = db.Base_WorkPost.FirstOrDefault(x => x.WorkPostName == item);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "考生岗位" + item + "未查询到数据，请检查是否正确。";
return responeData;
}
else
{
WorkPostIds += item + ",";
}
}
model.WorkPostIds = WorkPostIds.Substring(0, WorkPostIds.Length - 1);
}
#endregion
model.TestPlanId = SQLHelper.GetNewID(typeof(Model.Training_TestPlan));
model.States = "3";
db.Training_TestPlan.InsertOnSubmit(model);
db.SubmitChanges();
responeData.message = "添加成功。";
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 考试记录同步
///
///
[Route("TestRecordSync")]
[HttpPost]
public Model.ResponeData TestRecordSync([FromBody] Training_TestRecordDto dto)
{
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (!string.IsNullOrEmpty(model.ProjectId))
{
//判断projectid是否有数据
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "所属项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (!string.IsNullOrEmpty(model.TestPlanId))
{
var pmodel = db.Training_TestPlan.FirstOrDefault(x => x.PlanName == model.TestPlanId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "考试计划名称 TestPlanId未查询到数据，请检查是否正确。";
return responeData;
}
else {
model.TestPlanId = pmodel.PlanId;
}
}
if (!string.IsNullOrEmpty(model.TestManId))
{
var pmodel = db.SitePerson_Person.FirstOrDefault(x => x.ProjectId == model.ProjectId && x.IdentityCard == model.TestManId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "当前考生不在项目中，请检查是否正确。";
return responeData;
}
else {
model.TestManId = pmodel.PersonId;
}
}
#endregion
model.TestRecordId= SQLHelper.GetNewID(typeof(Model.Training_TestRecord));
db.Training_TestRecord.InsertOnSubmit(model);
db.SubmitChanges();
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 日常巡检同步
///
///
[Route("HiddenRectificationSync")]
[HttpPost]
public Model.ResponeData HiddenRectificationSync([FromBody] HSSE_Hazard_HazardRegisterDto dto)
{
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (!string.IsNullOrEmpty(model.ProjectId))
{
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "当前项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (!string.IsNullOrEmpty(model.RegisterTypesId))
{
var pmodel = db.HSSE_Hazard_HazardRegisterTypes.FirstOrDefault(x => x.RegisterTypesName == model.RegisterTypesId);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "检查项RegisterTypesId未查询到数据，请检查是否正确。";
return responeData;
}
else {
model.RegisterTypesId = pmodel.RegisterTypesId;
}
}
if (!string.IsNullOrEmpty(model.ResponsibleUnit))
{
var uid = getUnitIdByUnitCollCropCode(model.ResponsibleUnit);
if (uid == "")
{
responeData.code = 0;
responeData.message = "责任单位名称UnitId未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ResponsibleUnit = uid;
}
}
if (!string.IsNullOrEmpty(model.Place))
{
var umodel = Funs.DB.WBS_UnitWork.FirstOrDefault(x => x.UnitWorkName == model.Place);
if (umodel == null)
{
responeData.code = 0;
responeData.message = "单位工程（受检区域）Place未查询到数据，请检查是否正确。";
return responeData;
}
else {
model.Place = umodel.UnitWorkId;
}
}
if (model.Risk_Level!="一般"&&model.Risk_Level!="重大")
{
responeData.code = 0;
responeData.message = "级别必须为'一般'或者'重大'，请检查是否正确。";
return responeData;
}
if (!string.IsNullOrEmpty(model.ResponsibleMan))
{
var userid = getUserIdByIdentityCard(model.ResponsibleMan);
if (userid == "")
{
responeData.code = 0;
responeData.message = "责任人身份证号码ResponsibleMan未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ResponsibleMan = userid;
}
}
if (!string.IsNullOrEmpty(model.CheckManId))
{
var userid = getUserIdByIdentityCard(model.CheckManId);
if (userid == "")
{
responeData.code = 0;
responeData.message = "检查人身份证号码ResponsibleMan未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.CheckManId = userid;
}
}
#endregion
model.ProblemTypes = "1"; //安全隐患问题
model.CheckCycle = "D";
model.IsEffective = "1";
model.States = "3"; //已闭环
model.HazardRegisterId = SQLHelper.GetNewID(typeof(Model.HSSE_Hazard_HazardRegister));
string urlBefore = "";
string urlAfter = "";
BLL.HSSE_Hazard_HazardRegisterService.AddHazardRegister(model);
try
{
//整改前照片
if (!string.IsNullOrEmpty(model.ImageUrl))
{
// urlBefore = ConfigurationManager.AppSettings["localRoot"] + @"FileUpload\Registration\" + string.Format("{0:yyyyMMddHHmmssffff}", DateTime.Now) + ".jpg";
urlBefore = getUrlByType("Registration");
System.IO.File.WriteAllBytes(urlBefore, Convert.FromBase64String(model.ImageUrl));
urlBefore = urlBefore.Replace(ConfigurationManager.AppSettings["localRoot"], "");
UploadFileService.SaveAttachUrl(UploadFileService.GetSourceByAttachUrl(urlBefore, 10, null), urlBefore, Const.HSSE_HiddenRectificationListMenuId, model.HazardRegisterId);
}
//整改后照片
if (!string.IsNullOrEmpty(model.RectificationImageUrl))
{
//urlAfter = ConfigurationManager.AppSettings["localRoot"] + @"FileUpload\Registration\" + string.Format("{0:yyyyMMddHHmmssffff}", DateTime.Now) + "~r" + ".jpg";
urlAfter = getUrlByType("Registration");
System.IO.File.WriteAllBytes(urlAfter, Convert.FromBase64String(model.RectificationImageUrl));
urlAfter = urlAfter.Replace(ConfigurationManager.AppSettings["localRoot"], "");
UploadFileService.SaveAttachUrl(UploadFileService.GetSourceByAttachUrl(urlAfter, 10, null), urlAfter, Const.HSSE_HiddenRectificationListMenuId, model.HazardRegisterId + "r");
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = "图片上传出错" + ex.Message;
return responeData;
}
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 专项巡检同步
///
///
[Route("CheckSpecialSync")]
[HttpPost]
public Model.ResponeData CheckSpecialSync([FromBody] Check_CheckSpecialDto dto)
{
var responeData = new Model.ResponeData();
var unitid = "";
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (!string.IsNullOrEmpty(model.ProjectId))
{
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "所属项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (!string.IsNullOrEmpty(model.CompileMan))
{
var userid = getUserIdByIdentityCard(model.CompileMan);
if (userid == "")
{
responeData.code = 0;
responeData.message = "编制人身份证号码CompileMan未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.CompileMan = userid;
}
var pmodel = db.Sys_User.FirstOrDefault(x => x.UserId == model.CompileMan);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "编制人CompileMan未查询到数据，请检查是否正确。";
return responeData;
}
else {
unitid = pmodel.UnitId;
}
}
if (!string.IsNullOrEmpty(model.CheckType))
{
if (model.CheckType!="0"&& model.CheckType != "1" && model.CheckType != "2" && model.CheckType != "3")
{
responeData.code = 0;
responeData.message = "检查类型值错误，请检查是否正确。";
return responeData;
}
}
if (!string.IsNullOrEmpty(dto.CheckItemName))
{
var pmodel = db.Technique_CheckItemSet.FirstOrDefault(x => x.CheckItemName == dto.CheckItemName);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "检查类别CheckItemName未查询到数据，请检查是否正确。";
return responeData;
}
}
//检查组人员身份证
if (!string.IsNullOrEmpty(model.PartInPersonIds))
{
var PartInPersonIds = "";
foreach (var item in model.PartInPersonIds.Split(','))
{
var userid = getUserIdByIdentityCard(item);
if (userid == "")
{
responeData.code = 0;
responeData.message = "检查组身份证号码未查询到人员" + item + "，请检查是否正确。";
return responeData;
}
else {
PartInPersonIds += userid + ",";
}
}
model.PartInPersonIds = PartInPersonIds.Substring(0, PartInPersonIds.Length - 1);
}
if (dto.ChildList.Count>0)
{
foreach (var item in dto.ChildList)
{
if (!string.IsNullOrEmpty(item.CheckArea))
{
var pmodel = db.WBS_UnitWork.FirstOrDefault(x => x.UnitWorkName==item.CheckArea);
if (pmodel == null)
{
responeData.code = 0;
responeData.message = "单位工程名称(UnitWorkId)未查询到数据，请检查是否正确。";
return responeData;
}
else {
item.CheckArea = pmodel.UnitWorkId;
}
}
if (!string.IsNullOrEmpty(item.UnitId))
{
var uid = getUnitIdByUnitCollCropCode(item.UnitId);
if (uid == "")
{
responeData.code = 0;
responeData.message = "受检单位UnitId未查询到数据，请检查是否正确。";
return responeData;
}
else
{
item.UnitId = uid;
}
}
if (!string.IsNullOrEmpty(item.HSEManage))
{
var userid = getUserIdByIdentityCard(item.HSEManage);
if (userid == "")
{
responeData.code = 0;
responeData.message = "HSE经理身份证号码未查询到数据，请检查是否正确。";
return responeData;
}
else
{
item.HSEManage = userid;
}
}
}
}
#endregion
model.CheckSpecialCode=CodeRecordsService.ReturnCodeByMenuIdProjectId(BLL.Const.ProjectCheckSpecialMenuId, model.ProjectId, unitid);
model.States = "3";
if (!string.IsNullOrEmpty(model.PartInPersonIds))
{
string partInPersonIds = string.Empty;
string partInPersons = string.Empty;
foreach (var item in model.PartInPersonIds.Split(','))
{
var user = BLL.UserService.GetUserByUserId(item);
if (user != null)
{
partInPersonIds += user.UserId + ",";
partInPersons += user.UserName + ",";
}
}
if (!string.IsNullOrEmpty(partInPersonIds))
{
model.PartInPersonIds = partInPersonIds.Substring(0, partInPersonIds.LastIndexOf(","));
model.PartInPersons = partInPersons.Substring(0, partInPersons.LastIndexOf(","));
}
}
var getCheckItem = Funs.DB.Technique_CheckItemSet.FirstOrDefault(x => x.CheckItemName == dto.CheckItemName);
if (getCheckItem != null)
{
model.CheckItemSetId = getCheckItem.CheckItemSetId;
}
model.CheckSpecialId = SQLHelper.GetNewID(typeof(Model.Check_CheckSpecial));
//新增专项检查主表
Check_CheckSpecialService.AddCheckSpecial(model);
//增加子表
int sortindex = 0;
foreach (var item in dto.ChildList)
{
var mapperChild = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var modelChild = mapperChild.Map(item);
modelChild.CheckSpecialId = model.CheckSpecialId;
if (string.IsNullOrEmpty(modelChild.UnitId))
{
modelChild.UnitId = null;
}
if (string.IsNullOrEmpty(modelChild.WorkArea))
{
modelChild.WorkArea = null;
}
if (string.IsNullOrEmpty(modelChild.CheckArea))
{
modelChild.CheckArea = null;
}
if (modelChild.RectifyOpinion == "1")
{
modelChild.RectifyOpinion = "口头警告";
}
else {
modelChild.RectifyOpinion = "当场纠正";
}
var getHSSE_Hazard_HazardRegisterTypes = Funs.DB.HSSE_Hazard_HazardRegisterTypes.FirstOrDefault(x => x.RegisterTypesName == modelChild.CheckContent);
if (getHSSE_Hazard_HazardRegisterTypes != null)
{
modelChild.CheckItem = getHSSE_Hazard_HazardRegisterTypes.RegisterTypesId;
}
modelChild.SortIndex = sortindex;
modelChild.CheckSpecialDetailId = SQLHelper.GetNewID(typeof(Model.Check_CheckSpecialDetail));
Check_CheckSpecialDetailService.AddCheckSpecialDetail(modelChild);
if (!string.IsNullOrEmpty(item.ImgUrl))
{
var urlBefore = getUrlByType("checkspecial");
System.IO.File.WriteAllBytes(urlBefore, Convert.FromBase64String(item.ImgUrl));
urlBefore = urlBefore.Replace(ConfigurationManager.AppSettings["localRoot"], "");
UploadFileService.SaveAttachUrl(UploadFileService.GetSourceByAttachUrl(urlBefore, 10, null), urlBefore, Const.HSSE_APPCheckSpecialMenuId, modelChild.CheckSpecialDetailId);
}
sortindex += 1;
}
responeData.message = "添加成功";
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 领导带班检查同步
///
///
[Route("LeaderCheckSync")]
[HttpPost]
public Model.ResponeData LeaderCheckSync([FromBody] Check_ProjectLeaderCheckDto dto)
{
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 判断参数
if (!string.IsNullOrEmpty(model.ProjectId))
{
var pid = getProjectIdByCode(model.ProjectId);
if (pid == "")
{
responeData.code = 0;
responeData.message = "所属项目名称未查询到数据，请检查是否正确。";
return responeData;
}
else
{
model.ProjectId = pid;
}
}
if (!string.IsNullOrEmpty(model.UnitIds))
{
var unitIds = "";
foreach (var item in dto.UnitIds.Split(','))
{
var uid = getUnitIdByUnitCollCropCode(item);
if (uid == "")
{
responeData.code = 0;
responeData.message = "单位名称UnitIds"+item+"未查询到数据，请检查是否正确。";
return responeData;
}
else
{
unitIds += uid + ",";
}
}
model.UnitIds = unitIds.Substring(0, unitIds.Length - 1);
}
//带班领导身份证号码
if (!string.IsNullOrEmpty(model.LeaderIds))
{
var LeaderIds = "";
foreach (var item in dto.LeaderIds.Split(','))
{
var Userid = getUserIdByIdentityCard(item);
if (Userid=="")
{
responeData.code = 0;
responeData.message = "带班领导身份证LeaderIds"+item+"未查询到数据，请检查是否正确。";
return responeData;
}
else
{
LeaderIds += Userid + ",";
}
}
model.LeaderIds = LeaderIds;
}
#endregion
model.ProjectLeaderCheckId = SQLHelper.GetNewID(typeof(Model.Check_ProjectLeaderCheck));
model.IsHoldMeet = false;
db.Check_ProjectLeaderCheck.InsertOnSubmit(model);
db.SubmitChanges();
responeData.message = "领导带班检查同步成功";
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 隐患整改单同步
///
///
[Route("RectifyNoticesSync")]
[HttpPost]
public Model.ResponeData RectifyNoticesSync([FromBody] Model.RectifyNoticesDto rectifyNotices)
{
var responeData = new Model.ResponeData();
try
{
using (Model.SUBQHSEDB db = new Model.SUBQHSEDB(Funs.ConnString))
{
#region 参数校验
if (BLL.UnitService.getUnitByUnitName(rectifyNotices.UnitId) == null)
{
responeData.code = 0;
responeData.message = "单位名称(UnitId)未查询到数据，请检查是否正确。";
return responeData;
}
else
{
rectifyNotices.UnitId = BLL.UnitService.getUnitByUnitName(rectifyNotices.UnitId).UnitId;
}
if (BLL.ProjectService.GetProjectByProjectName(rectifyNotices.ProjectId) == null)
{
responeData.code = 0;
responeData.message = "当前项目名称(ProjectId)未查询到数据，请检查是否正确！";
return responeData;
}
else
{
rectifyNotices.ProjectId = BLL.ProjectService.GetProjectByProjectName(rectifyNotices.ProjectId).ProjectId;
}
//检查组人员身份证
if (!string.IsNullOrEmpty(rectifyNotices.CheckManIds))
{
var PartInPersonIds = "";
foreach (var item in rectifyNotices.CheckManIds.Split(','))
{
var userid = getUserIdByIdentityCard(item);
if (userid == "")
{
responeData.code = 0;
responeData.message = "检查组身份证号码未查询到人员" + item + "，请检查是否正确。";
return responeData;
}
else
{
PartInPersonIds += userid + ",";
}
}
rectifyNotices.CheckManIds = PartInPersonIds.Substring(0, PartInPersonIds.Length - 1);
}
if (!string.IsNullOrEmpty(rectifyNotices.WorkAreaId) && BLL.UnitWorkService.GetUnitWorkByUnitWorkName(rectifyNotices.ProjectId, rectifyNotices.WorkAreaId) == null)
{
responeData.code = 0;
responeData.message = "单位工程(WorkAreaId)未查询到数据，请检查是否正确！";
return responeData;
}
else
{
rectifyNotices.WorkAreaId = (string.IsNullOrEmpty(rectifyNotices.WorkAreaId) ? rectifyNotices.WorkAreaId : UnitWorkService.GetUnitWorkByUnitWorkName(rectifyNotices.ProjectId, rectifyNotices.WorkAreaId).UnitWorkId);
}
if (!string.IsNullOrEmpty(rectifyNotices.CompleteManId))
{
if (BLL.UserService.GetUserByIdentityCard(rectifyNotices.CompleteManId)==null)
{
responeData.code = 0;
responeData.message = "该编制人身份证号码未查询到相关人员请检查是否正确。";
return responeData;
}
else
{
rectifyNotices.CompleteManId =
UserService.GetUserByIdentityCard(rectifyNotices.CompleteManId).UserId;
}
}
string[] a = { "1", "2", "3" };
if (!a.Contains(rectifyNotices.HiddenHazardType))
{
responeData.code = 0;
responeData.message = "隐患类别有误！";
return responeData;
}
#endregion
bool insertRectifyNoticesItemItem = false;
Model.Check_RectifyNotices newRectifyNotices = new Model.Check_RectifyNotices
{
RectifyNoticesId = SQLHelper.GetNewID(typeof(Check_RectifyNotices)),
ProjectId = rectifyNotices.ProjectId,
RectifyNoticesCode = rectifyNotices.RectifyNoticesCode,
UnitId = rectifyNotices.UnitId,
CheckManNames = UserService.getUserNamesUserIds(rectifyNotices.CheckManIds),
CheckManIds = rectifyNotices.CheckManIds,
CheckedDate = rectifyNotices.CheckedDate,
HiddenHazardType = rectifyNotices.HiddenHazardType,
States = rectifyNotices.States,
};
if (!string.IsNullOrEmpty(rectifyNotices.WorkAreaId))
{
newRectifyNotices.WorkAreaId = rectifyNotices.WorkAreaId;
}
if (!string.IsNullOrEmpty(rectifyNotices.CompleteManId))
{
newRectifyNotices.CompleteManId = rectifyNotices.CompleteManId;
}
//// 新增整改单
var isUpdate = db.Check_RectifyNotices.FirstOrDefault(x => x.RectifyNoticesId == newRectifyNotices.RectifyNoticesId);
if (isUpdate == null)
{
newRectifyNotices.RectifyNoticesId = SQLHelper.GetNewID();
if (string.IsNullOrEmpty(newRectifyNotices.RectifyNoticesCode))
{
newRectifyNotices.RectifyNoticesCode = CodeRecordsService.ReturnCodeByMenuIdProjectId(Const.ProjectRectifyNoticesMenuId, newRectifyNotices.ProjectId, newRectifyNotices.UnitId);
}
db.Check_RectifyNotices.InsertOnSubmit(newRectifyNotices);
db.SubmitChanges();
CodeRecordsService.InsertCodeRecordsByMenuIdProjectIdUnitId(Const.ProjectRectifyNoticesMenuId, newRectifyNotices.ProjectId, newRectifyNotices.UnitId, newRectifyNotices.RectifyNoticesId, newRectifyNotices.CheckedDate);
try
{
//// 整改单附件
if (!string.IsNullOrEmpty(rectifyNotices.BeAttachUrl))
{
string url = getUrlByType("RectifyNotices");
System.IO.File.WriteAllBytes(url, Convert.FromBase64String(rectifyNotices.BeAttachUrl));
url = url.Replace(ConfigurationManager.AppSettings["localRoot"], "");
APIUpLoadFileService.SaveAttachUrl(Const.ProjectRectifyNoticesMenuId, newRectifyNotices.RectifyNoticesId + "#0", url, "0");
}
//// 反馈单附件
if (!string.IsNullOrEmpty(rectifyNotices.AfAttachUrl))
{
var url = getUrlByType("RectifyNotices");
System.IO.File.WriteAllBytes(url, Convert.FromBase64String(rectifyNotices.BeAttachUrl));
url = url.Replace(ConfigurationManager.AppSettings["localRoot"], "");
APIUpLoadFileService.SaveAttachUrl(Const.ProjectRectifyNoticesMenuId, newRectifyNotices.RectifyNoticesId + "#1", url, "0");
}
//// 整个单据附件
if (!string.IsNullOrEmpty(rectifyNotices.AttachUrl))
{
var url = getUrlByType("RectifyNotices");
System.IO.File.WriteAllBytes(url, Convert.FromBase64String(rectifyNotices.BeAttachUrl));
url = url.Replace(ConfigurationManager.AppSettings["localRoot"], "");
APIUpLoadFileService.SaveAttachUrl(Const.ProjectRectifyNoticesMenuId, newRectifyNotices.RectifyNoticesId, url, "0");
}
}
catch (Exception ex)
{
RectifyNoticesService.DeleteRectifyNoticesById(newRectifyNotices.RectifyNoticesId);
responeData.code = 0;
responeData.message = "图片上传出错" + ex.Message;
return responeData;
}
insertRectifyNoticesItemItem = true;
}
if (insertRectifyNoticesItemItem)
{
//// 新增明细
if (rectifyNotices.RectifyNoticesDtoItem != null && rectifyNotices.RectifyNoticesDtoItem.Count() > 0)
{
foreach (var rItem in rectifyNotices.RectifyNoticesDtoItem)
{
Model.Check_RectifyNoticesItem newItem = new Model.Check_RectifyNoticesItem
{
RectifyNoticesItemId = SQLHelper.GetNewID(),
RectifyNoticesId = newRectifyNotices.RectifyNoticesId,
WrongContent = rItem.WrongContent,
Requirement = rItem.Requirement,
LimitTime = rItem.LimitTime,
RectifyResults = null,
IsRectify = null,
};
db.Check_RectifyNoticesItem.InsertOnSubmit(newItem);
db.SubmitChanges();
if (!string.IsNullOrEmpty(rItem.PhotoBeforeUrl))
{
string url = "";
url = getUrlByType("RectifyNotices");
System.IO.File.WriteAllBytes(url, Convert.FromBase64String(rectifyNotices.BeAttachUrl));
url = url.Replace(ConfigurationManager.AppSettings["localRoot"], "");
APIUpLoadFileService.SaveAttachUrl(Const.ProjectRectifyNoticesMenuId, newItem.RectifyNoticesItemId + "#1", url, "0");
}
}
}
}
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
///
/// 定稿作业票同步
///
///
[Route("LicenseManagerSync")]
[HttpPost]
public Model.ResponeData LicenseManagerSync(LicenseLicensemanagerDto dto)
{
var responeData = new Model.ResponeData();
try
{
using (var db = new Model.SUBQHSEDB(Funs.ConnString))
{
var mapper = EmitMapper.ObjectMapperManager.DefaultInstance.GetMapper();
var model = mapper.Map(dto);
#region 参数校验
if (BLL.ProjectService.GetProjectByProjectName(model.ProjectId) == null)
{
responeData.code = 0;
responeData.message = "当前项目名称(ProjectId)未查询到数据，请检查是否正确！";
return responeData;
}
else
{
model.ProjectId = BLL.ProjectService.GetProjectByProjectName(model.ProjectId).ProjectId;
}
if (BLL.LicenseTypeService.GetLicenseTypeByName(model.LicenseTypeId) == null)
{
responeData.code = 0;
responeData.message = "许可证类型名称(LicenseTypeId)未查询到数据，请检查是否正确！";
return responeData;
}
else
{
model.LicenseTypeId= LicenseTypeService.GetLicenseTypeByName(model.LicenseTypeId).LicenseTypeId;
}
if (BLL.UnitService.getUnitByUnitName(model.UnitId) == null)
{
responeData.code = 0;
responeData.message = "单位名称(UnitId)未查询到数据，请检查是否正确！";
return responeData;
}
else
{
model.UnitId = BLL.UnitService.getUnitByUnitName(model.UnitId).UnitId;
}
if (!string.IsNullOrEmpty(model.WorkAreaId) && BLL.UnitWorkService.GetUnitWorkByUnitWorkName(model.ProjectId, model.WorkAreaId) == null)
{
responeData.code = 0;
responeData.message = "单位工程(WorkAreaId)未查询到数据，请检查是否正确！";
return responeData;
}
else
{
model.WorkAreaId = (string.IsNullOrEmpty(model.WorkAreaId) ? model.WorkAreaId : UnitWorkService.GetUnitWorkByUnitWorkName(model.ProjectId, model.WorkAreaId).UnitWorkId);
}
//if (BLL.LicenseManagerService.GetLicenseManagerByCode(model.ProjectId,model.LicenseManagerCode) != null)
//{
// responeData.code = 0;
// responeData.message = "许可证编号(LicenseManagerCode)已重复！";
// return responeData;
//}
if (!string.IsNullOrEmpty(model.CompileMan))
{
if (BLL.UserService.GetUserByIdentityCard(model.CompileMan) == null)
{
responeData.code = 0;
responeData.message = "该编制人身份证号码未查询到相关人员请检查是否正确。";
return responeData;
}
else
{
model.CompileMan =
UserService.GetUserByIdentityCard(model.CompileMan).UserId;
}
}
else
{
model.CompileMan = null;
}
string[] a = { "0", "1", "2", "-1" };
if (!a.Contains(model.WorkStates))
{
responeData.code = 0;
responeData.message = "开工状态有误！";
return responeData;
}
#endregion
model.LicenseManagerId = SQLHelper.GetNewID();
model.States = BLL.Const.State_2;
BLL.LicenseManagerService.AddLicenseManager(model);
try
{
if (!string.IsNullOrEmpty(dto.AttachByte))
{
string urlBefore = getUrlByType("LicenseManagerAttachUrl");
System.IO.File.WriteAllBytes(urlBefore, Convert.FromBase64String(dto.AttachByte));
urlBefore = urlBefore.Replace(ConfigurationManager.AppSettings["localRoot"], "");
UploadFileService.SaveAttachUrl(UploadFileService.GetSourceByAttachUrl(urlBefore, 10, null), urlBefore, Const.ProjectLicenseManagerMenuId, model.LicenseManagerId);
}
}
catch (Exception ex)
{
LicenseManagerService.DeleteLicenseManagerById(model.LicenseManagerId);
responeData.code = 0;
responeData.message = "图片上次出错" + ex.Message;
return responeData;
}
}
}
catch (Exception ex)
{
responeData.code = 0;
responeData.message = ex.Message;
}
return responeData;
}
}
}