using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Web.Services; using System.Xml; using IM.BLL; using IM.Model; using System.IO; using System.Text; using WebSite.Public.FlashUpload; namespace WebSite.Api.Emp { /// <summary> /// EmpWebService 的摘要说明 /// </summary> [WebService(Namespace = "http://tempuri.org/")] [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)] [System.ComponentModel.ToolboxItem(false)] // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消对下行的注释。 // [System.Web.Script.Services.ScriptService] public class EmpWebService : System.Web.Services.WebService { private const string USERNAME = "sucgm"; private const string PWD = "sucgmltsvc!@#"; #region 插入人员数据 [WebMethod] public string synchEmployee(string uName, string pwd, string xml) { tb_EmployeeBLL ol = new tb_EmployeeBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("employees/employee")) { tb_EmployeeModel mod = new tb_EmployeeModel(); mod.sysId = node["sysId"].InnerText; mod.name = node["name"].InnerText; mod.createDate = Convert.ToDateTime(node["createDate"].InnerText.Length > 0 ? node["createDate"].InnerText : "1900-01-01 00:00:00"); mod.sex = node["sex"].InnerText; mod.mobile = node["mobile"].InnerText; mod.identityNo = node["identityNo"].InnerText; mod.province = node["province"].InnerText; mod.birthDate = node["birthDate"].InnerText; mod.nation = node["nation"].InnerText; mod.blood = node["blood"].InnerText; mod.Subcontractor = node["subcontractor"].InnerText; mod.Worktype = node["worktype"].InnerText; mod.shift = node["shift"].InnerText; mod.empType = node["empType"].InnerText; mod.entryTime = node["entryTime"].InnerText; mod.outTime = node["outTime"].InnerText; mod.medicalCertificate = node["medicalCertificate"].InnerText; mod.Contract = node["contract"].InnerText; mod.contractTime = node["contractTime"].InnerText; mod.Certificate = node["certificate"].InnerText; mod.certificateName = node["certificateName"].InnerText; mod.townSecure = node["townSecure"].InnerText; mod.otherSecure = node["otherSecure"].InnerText; mod.safeCard = node["safeCard"].InnerText; mod.cardTime = node["cardTime"].InnerText; mod.safePost = node["safePost"].InnerText; mod.postTime = node["postTime"].InnerText; mod.orderBook = node["orderBook"].InnerText; mod.orderTime = node["orderTime"].InnerText; mod.safeEducationJiaoDi = node["safeEducationJiaoDi"].InnerText; mod.peccancys = node["peccancys"].InnerText; mod.safetys = node["safetys"].InnerText; mod.projectCode = node["projectCode"].InnerText; mod.createUserMsgCode = node["createUserMsgCode"].InnerText; mod.createUserName = node["createUserName"].InnerText; string c = node["picstr"].InnerText; mod.fileName = node["fileName"].InnerText; mod.del = node["del"].InnerText; if (c.Length > 0) { byte[] a = Convert.FromBase64String(c); ///empphoto/项目编号/xxxx.jpg string paths = Server.MapPath("../../") + "Upload\" + "\empphoto\" + mod.projectCode; if (!Directory.Exists(paths)) { Directory.CreateDirectory(paths); } string path = paths + "\" + mod.fileName + ""; FileStream fs = new FileStream(path, FileMode.Create, FileAccess.Write); fs.Write(a, 0, a.Length); if (fs != null) { fs.Close(); } mod.picstr = "Upload/empphoto/" + mod.projectCode + "/" + mod.fileName + ""; } else { mod.picstr = "Upload/empphoto/" + "NoPhoto.jpg"; } ol.Add(mod); } } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 插入门禁信息 [WebMethod] public string synchCardRecord(string uName, string pwd, string xml) { tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("cardrecords/cardrecord")) { tb_Emp_Card_RecordModel mod = new tb_Emp_Card_RecordModel(); mod.recordId = Convert.ToInt32(node["recordId"].InnerText); mod.empId = node["empId"].InnerText; mod.cardNo = Convert.ToDecimal(node["cardNo"].InnerText); mod.epcCardNo = node["epcCardNo"].InnerText; mod.deviceNo = Convert.ToInt32(node["deviceNo"].InnerText); mod.readerNo = Convert.ToInt32(node["readerNo"].InnerText); mod.status = Convert.ToInt32(node["status"].InnerText); mod.ioDate = Convert.ToDateTime(node["ioDate"].InnerText.Length > 0 ? node["ioDate"].InnerText : "1900-01-01 00:00:00"); mod.analysis = Convert.ToInt32(node["analysis"].InnerText); mod.createDate = Convert.ToDateTime(node["createDate"].InnerText.Length > 0 ? node["createDate"].InnerText : "1900-01-01 00:00:00"); mod.result = Convert.ToInt32(node["result"].InnerText); mod.projectCode = node["projectCode"].InnerText; mod.fileName = node["fileName"].InnerText; string c = node["picstr"].InnerText; if (c.Length > 0) { byte[] a = Convert.FromBase64String(c); ///empphoto/项目编号/xxxx.jpg string paths = Server.MapPath("../../") + "Upload\" + "\empphoto\" + "\cardrecord\" + mod.projectCode; if (!Directory.Exists(paths)) { Directory.CreateDirectory(paths); } string path = paths + "\" + mod.fileName + ""; FileStream fs = new FileStream(path, FileMode.Create, FileAccess.Write); fs.Write(a, 0, a.Length); if (fs != null) { fs.Close(); } mod.picstr = "Upload/empphoto/cardrecord/" + mod.projectCode + "/" + mod.fileName + ""; } else { mod.picstr = ""; } sql1 += synchCardRecordSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 门禁sql拼接 /// <summary> /// 接收mod数据,返回拼接的sql语句 /// </summary> /// <param name="mod"></param> /// <returns></returns> public string synchCardRecordSQL(tb_Emp_Card_RecordModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_Card_Record where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_Card_Record ( "); strSql.Append(" recordId,empId,cardNo,epcCardNo,deviceNo,readerNo,status,ioDate,"); strSql.Append("analysis,createDate,result,projectCode,picstr,similarity,fileName "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.recordId + "','" + mod.empId + "','" + mod.cardNo + "','" + mod.epcCardNo + "','" + mod.deviceNo + "','" + mod.readerNo + "','" + mod.status + "','" + mod.ioDate + "',"); strSql.Append("'" + mod.analysis + "','" + mod.createDate + "','" + mod.result + "','" + mod.projectCode + "','" + mod.picstr + "','" + mod.similarity + "','" + mod.fileName + "' "); strSql.Append(" ) "); return strSql.ToString(); } #endregion #region 插入违章信息 [WebMethod] public string synchViolationRecord(string uName, string pwd, string xml) { tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("violations/violation")) { tb_Emp_ViolationRecordModel mod = new tb_Emp_ViolationRecordModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); mod.recordId = node["recordId"].InnerText; mod.empId = node["empId"].InnerText; mod.violationDate = node["violationDate"].InnerText; mod.grade = node["grade"].InnerText; mod.types = node["types"].InnerText; mod.description = node["description"].InnerText; mod.vtype = node["vtype"].InnerText; mod.createDate = Convert.ToDateTime(node["createDate"].InnerText.Length > 0 ? node["createDate"].InnerText : "1900-01-01 00:00:00"); mod.projectCode = node["projectCode"].InnerText; mod.createUserMsgCode = node["createUserMsgCode"].InnerText; mod.createUserName = node["createUserName"].InnerText; mod.del = node["del"].InnerText; try { foreach (XmlNode node1 in node.SelectNodes("fileName")) { string sysId = node1["sysId"].InnerText; string name = node1["name"].InnerText; string uploadName = node1["uploadName"].InnerText; string filestr = node1["filestr"].InnerText; string Uploadtype = "tb_Emp_ViolationRecord"; string Foreignkey = mod.recordId; string filetype = "application/octet-stream"; string savetype = "0"; string SaveServer = ""; string c = filestr; if (c.Length > 0) { byte[] a = Convert.FromBase64String(c); ///empphoto/项目编号/xxxx.jpg string paths = Server.MapPath("../../") + "Upload\empphoto\ViolationRecord\" + mod.projectCode + "\" + mod.sysId; if (!Directory.Exists(paths)) { Directory.CreateDirectory(paths); } string path = paths + "\" + uploadName + ""; FileStream fs = new FileStream(path, FileMode.Create, FileAccess.Write); fs.Write(a, 0, a.Length); if (fs != null) { fs.Close(); } FileInfo fileInfo = new FileInfo(path); string filesize = fileInfo.Length.ToString(); //string filesize = "0"; //string FilePath = fileInfo.DirectoryName; string FilePath = paths; string FileAppPath = "Upload\empphoto\ViolationRecord\" + mod.projectCode + "\" + mod.sysId + "\" + uploadName + ""; string filenewname = uploadName; string CreateUserId = ""; string createdate = DateTime.Now.ToString(); string downloads = "0"; StringBuilder strSql2 = new StringBuilder(); strSql2.Append("if not exists(select 1 from tb_UploadFileList where SysId='" + sysId + "')"); strSql2.Append(" insert into tb_UploadFileList ( "); strSql2.Append(" SysId,UploadType,ForeignKey,UploadName,FileType,FileSize,SaveType,SaveServer,FilePath,"); strSql2.Append("FileAppPath,FileNewName,CreateUserId,CreateDate,Downloads "); strSql2.Append(" ) "); strSql2.Append(" values ("); //strSql2.Append(" "+string.Format("'{0}',",mod.sysId)+""); strSql2.Append(" '" + sysId + "','" + Uploadtype + "','" + Foreignkey + "','" + name + "','" + filetype + "'," + filesize + ",'" + savetype + "','" + SaveServer + "','" + FilePath + "',"); strSql2.Append("'" + FileAppPath + "','" + filenewname + "','" + CreateUserId + "','" + createdate + "'," + downloads + " "); strSql2.Append(" ) "); //strSql2.Append(" else update tb_Emp_ViolationRecord "); //strSql2.Append(" set "); //strSql2.Append(" empId='" + mod.empId + "',violationDate='" + mod.violationDate + "',grade='" + mod.grade + "',types='" + mod.types + "',description='" + mod.description + "', "); //strSql2.Append(" vtype='" + mod.vtype + "',createDate='" + mod.createDate + "',del='" + mod.del + "' where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "') "); ol.Addfj(strSql2.ToString()); } } } catch { } sql1 += synchViolationRecordSQL(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 违章sql拼接 public string synchViolationRecordSQL(tb_Emp_ViolationRecordModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_ViolationRecord where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_ViolationRecord ( "); strSql.Append(" sysId,recordId,empId,violationDate,grade,types,description,vtype,createDate,"); strSql.Append("projectCode,createUserMsgCode,createUserName,del "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.empId + "','" + mod.violationDate + "','" + mod.grade + "','" + mod.types + "','" + mod.description + "','" + mod.vtype + "','" + mod.createDate + "',"); strSql.Append("'" + mod.projectCode + "','" + mod.createUserMsgCode + "','" + mod.createUserName + "','" + mod.del + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Emp_ViolationRecord "); strSql.Append(" set "); strSql.Append(" empId='" + mod.empId + "',violationDate='" + mod.violationDate + "',grade='" + mod.grade + "',types='" + mod.types + "',description='" + mod.description + "', "); strSql.Append(" vtype='" + mod.vtype + "',createDate='" + mod.createDate + "',createUserMsgCode='" + mod.createUserMsgCode + "',createUserName='" + mod.createUserName + "',del='" + mod.del + "' where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion #region 插入人员定位读头信息 [WebMethod] public string synchReaders(string uName, string pwd, string xml) { tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("readers/reader")) { tb_Emp_ReadersModel mod = new tb_Emp_ReadersModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); mod.recordId = Convert.ToInt32(node["recordId"].InnerText); mod.lrmID = Convert.ToInt32(node["lrmID"].InnerText); mod.lrmName = node["lrmName"].InnerText; mod.lrmType = Convert.ToInt32(node["lrmType"].InnerText); mod.lrmX = Convert.ToInt32(node["lrmX"].InnerText); mod.lrmY = Convert.ToInt32(node["lrmY"].InnerText); mod.lrmState = Convert.ToInt32(node["lrmState"].InnerText); if (node["lrmTime"].InnerText.Length > 0) mod.lrmTime=Convert.ToDateTime(node["lrmTime"].InnerText); else mod.lrmTime = null; mod.rmk = node["rmk"].InnerText; mod.monitorDaySecurity = node["monitorDaySecurity"].InnerText; mod.commentMans = node["commentMans"].InnerText; mod.dangerousMans = node["dangerousMans"].InnerText; mod.mapId = node["mapId"].InnerText; mod.lrmRadius = Convert.ToInt32(node["lrmRadius"].InnerText); //mod.createDate = Convert.ToDateTime(node["createDate"].InnerText.Length > 0 ? node["createDate"].InnerText : DBNull.Value.ToString()); if (node["createDate"].InnerText.Length > 0) mod.createDate=Convert.ToDateTime(node["createDate"].InnerText); else mod.createDate = null; mod.projectCode = node["projectCode"].InnerText; mod.del = node["del"].InnerText; sql1 += synchReadersSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 人员定位读头sql拼接 public string synchReadersSQL(tb_Emp_ReadersModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_Readers where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_Readers ( "); strSql.Append(" sysId,recordId,lrmID,lrmName,lrmType,lrmX,lrmY,lrmState,lrmTime,rmk,monitorDaySecurity,"); strSql.Append("commentMans,dangerousMans,mapId,lrmRadius,createDate,projectCode,del "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.lrmID + "','" + mod.lrmName + "','" + mod.lrmType + "','" + mod.lrmX + "','" + mod.lrmY + "','" + mod.lrmState + "','" + mod.lrmTime + "',"); strSql.Append("'" + mod.rmk + "','" + mod.monitorDaySecurity + "','" + mod.commentMans + "','" + mod.dangerousMans + "','" + mod.mapId + "','" + mod.lrmRadius + "','" + mod.createDate + "','" + mod.projectCode + "','" + mod.del + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Emp_Readers "); strSql.Append(" set "); strSql.Append(" lrmID='" + mod.lrmID + "',lrmName='" + mod.lrmName + "',lrmType='" + mod.lrmType + "',lrmX='" + mod.lrmX + "',lrmY='" + mod.lrmY + "', "); strSql.Append(" lrmState='" + mod.lrmState + "',lrmTime='" + mod.lrmTime + "',rmk='" + mod.rmk + "',monitorDaySecurity='" + mod.monitorDaySecurity + "',commentMans='" + mod.commentMans + "',dangerousMans='" + mod.dangerousMans + "',mapId='" + mod.mapId + "', "); strSql.Append(" lrmRadius='" + mod.lrmRadius + "',createDate='" + mod.createDate + "',del='" + mod.del + "' "); strSql.Append(" where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion #region 插入人员定位读头实时人员信息 [WebMethod] public string synchEntryRecord(string uName, string pwd, string xml) { tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("entryrecords/entryrecord")) { tb_Emp_EntryRecordModel mod =new tb_Emp_EntryRecordModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); mod.recordId = Convert.ToInt32(node["recordId"].InnerText); mod.labelId = Convert.ToInt32(node["labelId"].InnerText); mod.lrmId = Convert.ToInt32(node["lrmId"].InnerText); mod.inTime = Convert.ToDateTime(node["inTime"].InnerText.Length > 0 ? node["inTime"].InnerText : "1900-01-01 00:00:00"); mod.outTime = Convert.ToDateTime(node["outTime"].InnerText.Length > 0 ? node["outTime"].InnerText : "1900-01-01 00:00:00"); mod.rmk = node["rmk"].InnerText; mod.empId = node["empId"].InnerText; mod.projectCode = node["projectCode"].InnerText; sql1 += synchEntryRecordSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 人员定位读头实时人员信息sql拼接 public string synchEntryRecordSQL(tb_Emp_EntryRecordModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_EntryRecord where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_EntryRecord ( "); strSql.Append(" sysId,recordId,labelId,lrmId,inTime,outTime,rmk,empId,projectCode "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.labelId + "','" + mod.lrmId + "','" + mod.inTime + "','" + mod.outTime + "','" + mod.rmk + "','" + mod.empId + "','" + mod.projectCode + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Emp_EntryRecord "); strSql.Append(" set "); strSql.Append(" labelId='" + mod.labelId + "',lrmId='" + mod.lrmId + "',inTime='" + mod.inTime + "',outTime='" + mod.outTime + "',rmk='" + mod.rmk + "', "); strSql.Append(" empId='" + mod.empId + "' "); strSql.Append(" where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion #region 在场人员统计信息 [WebMethod] public string synchCurWorkers(string uName, string pwd, string xml) { tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); string sql1 = ""; string sql2 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("workers/worker")) { tb_Emp_CurWorkInfoModel mod = new tb_Emp_CurWorkInfoModel(); mod.empId = node["empId"].InnerText; if (node["groupId"].InnerText.Length > 0) mod.groupId = Convert.ToInt32(node["groupId"].InnerText); else mod.groupId = null; if (node["IODate"].InnerText.Length > 0) mod.IODate = Convert.ToDateTime(node["IODate"].InnerText); else mod.IODate = null; if (node["director"].InnerText.Length > 0) mod.director = Convert.ToInt32(node["director"].InnerText); else mod.director = null; if (node["lastDirector"].InnerText.Length > 0) mod.lastDirector = Convert.ToInt32(node["lastDirector"].InnerText); else mod.lastDirector = null; if (node["type"].InnerText.Length > 0) mod.type = Convert.ToInt32(node["type"].InnerText); else mod.type = null; mod.projectCode = node["projectCode"].InnerText; sql2 = " delete from tb_Emp_CurWorkInfo where projectCode='" + mod.projectCode + "' "; sql1 += synchCurWorkersSQL(mod); //ol.Add(mod); } sql2 += sql1; ol.Add(sql2); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 在场人员统计信息sql拼接 public string synchCurWorkersSQL(tb_Emp_CurWorkInfoModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append(" insert into tb_Emp_CurWorkInfo ( "); strSql.Append(" empId,groupId,IODate,director,lastDirector,type,projectCode "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.empId + "','" + mod.groupId + "','" + mod.IODate + "','" + mod.director + "','" + mod.lastDirector + "','" + mod.type + "','" + mod.projectCode + "' "); strSql.Append(" ) "); return strSql.ToString(); } #endregion #region 在场人员异常警告信息 [WebMethod] public string synchWarnMessage(string uName, string pwd, string xml) { tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("warnMessages/warnMessage")) { tb_Emp_WarnMessageModel mod = new tb_Emp_WarnMessageModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); mod.recordId = node["recordId"].InnerText; mod.empId = node["empId"].InnerText; mod.content = node["content"].InnerText; mod.type = node["type"].InnerText; if (node["createDate"].InnerText.Length > 0) mod.createDate = Convert.ToDateTime(node["createDate"].InnerText); mod.projectCode = node["projectCode"].InnerText; sql1 += synchWarnMessageSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 在场人员异常警告信息sql拼接 public string synchWarnMessageSQL(tb_Emp_WarnMessageModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_WarnMessage where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_WarnMessage ( "); strSql.Append(" sysId,recordId,empId,content,type,createDate,projectCode "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.empId + "','" + mod.content + "','" + mod.type + "','" + mod.createDate.ToString("yyyy-MM-dd HH:mm:ss.fff") + "','" + mod.projectCode + "' "); strSql.Append(" ) "); return strSql.ToString(); } #endregion #region 闸机设备列表信息 [WebMethod] public string synchMachine(string uName, string pwd, string xml) { tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("machines/machine")) { tb_Device_MachineModel mod = new tb_Device_MachineModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); if (node["recordId"].InnerText.Length > 0) mod.recordId = Convert.ToInt32(node["recordId"].InnerText); else mod.recordId = null; mod.code = node["code"].InnerText; mod.name = node["name"].InnerText; if (node["goupId"].InnerText.Length > 0) mod.goupId = Convert.ToInt32(node["goupId"].InnerText); else mod.goupId = null; mod.ipAddress = node["ipAddress"].InnerText; if (node["computerId"].InnerText.Length > 0) mod.computerId = Convert.ToInt32(node["computerId"].InnerText); else mod.computerId = null; if (node["needSync"].InnerText.Length > 0) mod.needSync = Convert.ToInt32(node["needSync"].InnerText); else mod.needSync = null; mod.del = node["del"].InnerText; mod.projectCode = node["projectCode"].InnerText; sql1 += synchDevice_MachineSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 闸机设备列表信息sql拼接 public string synchDevice_MachineSQL(tb_Device_MachineModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Device_Machine where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Device_Machine ( "); strSql.Append(" sysId,recordId,code,name,goupId,ipAddress,computerId,needSync,del,projectCode "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.code + "','" + mod.name + "','" + mod.goupId + "','" + mod.ipAddress + "','" + mod.computerId + "','" + mod.needSync + "','" + mod.del + "',"); strSql.Append("'" + mod.projectCode + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Device_Machine "); strSql.Append(" set "); strSql.Append(" sysId='" + mod.sysId + "',recordId='" + mod.recordId + "',code='" + mod.code + "',name='" + mod.name + "',goupId='" + mod.goupId + "', "); strSql.Append(" ipAddress='" + mod.ipAddress + "',computerId='" + mod.computerId + "',needSync='" + mod.needSync + "',del='" + mod.del + "',projectCode='" + mod.projectCode + "' "); strSql.Append(" where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion #region 闸机设备列表信息 [WebMethod] public string synchSafeTrain(string uName, string pwd, string xml) { tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1"; try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("safeTrains/safeTrain")) { tb_Emp_SafeTrainModel mod = new tb_Emp_SafeTrainModel(); mod.sysId = node["sysId"].InnerText; mod.title = node["title"].InnerText; mod.content = node["content"].InnerText; mod.participants = node["participants"].InnerText; mod.participantNames = node["participantNames"].InnerText; if (node["createDate"].InnerText.Length > 0) mod.createDate = Convert.ToDateTime(node["createDate"].InnerText); else mod.createDate = null; mod.createUserMsgCode = node["createUserMsgCode"].InnerText; mod.createUserName = node["createUserName"].InnerText; mod.projectCode = node["projectCode"].InnerText; mod.del = node["del"].InnerText; sql1 += synchSafeTrainSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion #region 闸机设备列表信息sql拼接 public string synchSafeTrainSQL(tb_Emp_SafeTrainModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_SafeTrain where sysId='" + mod.sysId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_SafeTrain ( "); strSql.Append(" sysId,title,content,participants,participantNames,createDate,createUserMsgCode,createUserName,projectCode,del "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.title + "','" + mod.content + "','" + mod.participants + "','" + mod.participantNames + "','" + mod.createDate + "','" + mod.createUserMsgCode + "','" + mod.createUserName + "','" + mod.projectCode + "',"); strSql.Append("'" + mod.del + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Emp_SafeTrain "); strSql.Append(" set "); strSql.Append(" sysId='" + mod.sysId + "',title='" + mod.title + "',content='" + mod.content + "',participants='" + mod.participants + "',participantNames='" + mod.participantNames + "', "); strSql.Append(" createDate='" + mod.createDate + "',createUserMsgCode='" + mod.createUserMsgCode + "',createUserName='" + mod.createUserName + "',projectCode='" + mod.projectCode + "',del='" + mod.del + "' "); strSql.Append(" where sysId='" + mod.sysId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion } }
using System;using System.Collections.Generic;using System.Linq;using System.Web;using System.Web.Services;using System.Xml;using IM.BLL;using IM.Model;using System.IO;using System.Text;using WebSite.Public.FlashUpload;
namespace WebSite.Api.Emp{ /// <summary> /// EmpWebService 的摘要说明 /// </summary> [WebService(Namespace = "http://tempuri.org/")] [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)] [System.ComponentModel.ToolboxItem(false)] // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消对下行的注释。 // [System.Web.Script.Services.ScriptService] public class EmpWebService : System.Web.Services.WebService { private const string USERNAME = "sucgm"; private const string PWD = "sucgmltsvc!@#"; #region 插入人员数据 [WebMethod] public string synchEmployee(string uName, string pwd, string xml) {
tb_EmployeeBLL ol = new tb_EmployeeBLL(); string result = "0"; //发送成功
if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("employees/employee")) { tb_EmployeeModel mod = new tb_EmployeeModel(); mod.sysId = node["sysId"].InnerText; mod.name = node["name"].InnerText; mod.createDate = Convert.ToDateTime(node["createDate"].InnerText.Length > 0 ? node["createDate"].InnerText : "1900-01-01 00:00:00"); mod.sex = node["sex"].InnerText; mod.mobile = node["mobile"].InnerText; mod.identityNo = node["identityNo"].InnerText; mod.province = node["province"].InnerText; mod.birthDate = node["birthDate"].InnerText; mod.nation = node["nation"].InnerText; mod.blood = node["blood"].InnerText; mod.Subcontractor = node["subcontractor"].InnerText; mod.Worktype = node["worktype"].InnerText; mod.shift = node["shift"].InnerText; mod.empType = node["empType"].InnerText; mod.entryTime = node["entryTime"].InnerText; mod.outTime = node["outTime"].InnerText; mod.medicalCertificate = node["medicalCertificate"].InnerText; mod.Contract = node["contract"].InnerText; mod.contractTime = node["contractTime"].InnerText; mod.Certificate = node["certificate"].InnerText; mod.certificateName = node["certificateName"].InnerText; mod.townSecure = node["townSecure"].InnerText; mod.otherSecure = node["otherSecure"].InnerText; mod.safeCard = node["safeCard"].InnerText; mod.cardTime = node["cardTime"].InnerText; mod.safePost = node["safePost"].InnerText; mod.postTime = node["postTime"].InnerText; mod.orderBook = node["orderBook"].InnerText; mod.orderTime = node["orderTime"].InnerText; mod.safeEducationJiaoDi = node["safeEducationJiaoDi"].InnerText; mod.peccancys = node["peccancys"].InnerText; mod.safetys = node["safetys"].InnerText; mod.projectCode = node["projectCode"].InnerText; mod.createUserMsgCode = node["createUserMsgCode"].InnerText; mod.createUserName = node["createUserName"].InnerText; string c = node["picstr"].InnerText; mod.fileName = node["fileName"].InnerText; mod.del = node["del"].InnerText; if (c.Length > 0) { byte[] a = Convert.FromBase64String(c); ///empphoto/项目编号/xxxx.jpg string paths = Server.MapPath("../../") + "Upload\" + "\empphoto\" + mod.projectCode; if (!Directory.Exists(paths)) { Directory.CreateDirectory(paths); } string path = paths + "\" + mod.fileName + ""; FileStream fs = new FileStream(path, FileMode.Create, FileAccess.Write); fs.Write(a, 0, a.Length); if (fs != null) { fs.Close(); } mod.picstr = "Upload/empphoto/" + mod.projectCode + "/" + mod.fileName + ""; } else { mod.picstr = "Upload/empphoto/" + "NoPhoto.jpg"; }
ol.Add(mod); } } catch (Exception e) { result = e.Message; //返回异常信息 }
return result; } #endregion
#region 插入门禁信息 [WebMethod] public string synchCardRecord(string uName, string pwd, string xml) {
tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("cardrecords/cardrecord")) { tb_Emp_Card_RecordModel mod = new tb_Emp_Card_RecordModel(); mod.recordId = Convert.ToInt32(node["recordId"].InnerText); mod.empId = node["empId"].InnerText; mod.cardNo = Convert.ToDecimal(node["cardNo"].InnerText); mod.epcCardNo = node["epcCardNo"].InnerText; mod.deviceNo = Convert.ToInt32(node["deviceNo"].InnerText); mod.readerNo = Convert.ToInt32(node["readerNo"].InnerText); mod.status = Convert.ToInt32(node["status"].InnerText); mod.ioDate = Convert.ToDateTime(node["ioDate"].InnerText.Length > 0 ? node["ioDate"].InnerText : "1900-01-01 00:00:00"); mod.analysis = Convert.ToInt32(node["analysis"].InnerText); mod.createDate = Convert.ToDateTime(node["createDate"].InnerText.Length > 0 ? node["createDate"].InnerText : "1900-01-01 00:00:00"); mod.result = Convert.ToInt32(node["result"].InnerText); mod.projectCode = node["projectCode"].InnerText; mod.fileName = node["fileName"].InnerText; string c = node["picstr"].InnerText; if (c.Length > 0) { byte[] a = Convert.FromBase64String(c); ///empphoto/项目编号/xxxx.jpg string paths = Server.MapPath("../../") + "Upload\" + "\empphoto\" + "\cardrecord\" + mod.projectCode; if (!Directory.Exists(paths)) { Directory.CreateDirectory(paths); }
string path = paths + "\" + mod.fileName + ""; FileStream fs = new FileStream(path, FileMode.Create, FileAccess.Write); fs.Write(a, 0, a.Length); if (fs != null) { fs.Close(); } mod.picstr = "Upload/empphoto/cardrecord/" + mod.projectCode + "/" + mod.fileName + "";
} else { mod.picstr = ""; }
sql1 += synchCardRecordSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion
#region 门禁sql拼接 /// <summary> /// 接收mod数据,返回拼接的sql语句 /// </summary> /// <param name="mod"></param> /// <returns></returns> public string synchCardRecordSQL(tb_Emp_Card_RecordModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_Card_Record where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_Card_Record ( "); strSql.Append(" recordId,empId,cardNo,epcCardNo,deviceNo,readerNo,status,ioDate,"); strSql.Append("analysis,createDate,result,projectCode,picstr,similarity,fileName "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.recordId + "','" + mod.empId + "','" + mod.cardNo + "','" + mod.epcCardNo + "','" + mod.deviceNo + "','" + mod.readerNo + "','" + mod.status + "','" + mod.ioDate + "',"); strSql.Append("'" + mod.analysis + "','" + mod.createDate + "','" + mod.result + "','" + mod.projectCode + "','" + mod.picstr + "','" + mod.similarity + "','" + mod.fileName + "' "); strSql.Append(" ) "); return strSql.ToString(); } #endregion
#region 插入违章信息 [WebMethod] public string synchViolationRecord(string uName, string pwd, string xml) {
tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("violations/violation")) { tb_Emp_ViolationRecordModel mod = new tb_Emp_ViolationRecordModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); mod.recordId = node["recordId"].InnerText; mod.empId = node["empId"].InnerText; mod.violationDate = node["violationDate"].InnerText; mod.grade = node["grade"].InnerText; mod.types = node["types"].InnerText; mod.description = node["description"].InnerText; mod.vtype = node["vtype"].InnerText; mod.createDate = Convert.ToDateTime(node["createDate"].InnerText.Length > 0 ? node["createDate"].InnerText : "1900-01-01 00:00:00"); mod.projectCode = node["projectCode"].InnerText; mod.createUserMsgCode = node["createUserMsgCode"].InnerText; mod.createUserName = node["createUserName"].InnerText; mod.del = node["del"].InnerText; try { foreach (XmlNode node1 in node.SelectNodes("fileName")) { string sysId = node1["sysId"].InnerText; string name = node1["name"].InnerText; string uploadName = node1["uploadName"].InnerText; string filestr = node1["filestr"].InnerText; string Uploadtype = "tb_Emp_ViolationRecord"; string Foreignkey = mod.recordId; string filetype = "application/octet-stream"; string savetype = "0"; string SaveServer = ""; string c = filestr; if (c.Length > 0) { byte[] a = Convert.FromBase64String(c); ///empphoto/项目编号/xxxx.jpg string paths = Server.MapPath("../../") + "Upload\empphoto\ViolationRecord\" + mod.projectCode + "\" + mod.sysId; if (!Directory.Exists(paths)) { Directory.CreateDirectory(paths); }
string path = paths + "\" + uploadName + ""; FileStream fs = new FileStream(path, FileMode.Create, FileAccess.Write); fs.Write(a, 0, a.Length); if (fs != null) { fs.Close(); } FileInfo fileInfo = new FileInfo(path); string filesize = fileInfo.Length.ToString(); //string filesize = "0"; //string FilePath = fileInfo.DirectoryName; string FilePath = paths; string FileAppPath = "Upload\empphoto\ViolationRecord\" + mod.projectCode + "\" + mod.sysId + "\" + uploadName + ""; string filenewname = uploadName; string CreateUserId = ""; string createdate = DateTime.Now.ToString(); string downloads = "0";
StringBuilder strSql2 = new StringBuilder(); strSql2.Append("if not exists(select 1 from tb_UploadFileList where SysId='" + sysId + "')"); strSql2.Append(" insert into tb_UploadFileList ( "); strSql2.Append(" SysId,UploadType,ForeignKey,UploadName,FileType,FileSize,SaveType,SaveServer,FilePath,"); strSql2.Append("FileAppPath,FileNewName,CreateUserId,CreateDate,Downloads "); strSql2.Append(" ) "); strSql2.Append(" values ("); //strSql2.Append(" "+string.Format("'{0}',",mod.sysId)+""); strSql2.Append(" '" + sysId + "','" + Uploadtype + "','" + Foreignkey + "','" + name + "','" + filetype + "'," + filesize + ",'" + savetype + "','" + SaveServer + "','" + FilePath + "',"); strSql2.Append("'" + FileAppPath + "','" + filenewname + "','" + CreateUserId + "','" + createdate + "'," + downloads + " "); strSql2.Append(" ) "); //strSql2.Append(" else update tb_Emp_ViolationRecord "); //strSql2.Append(" set "); //strSql2.Append(" empId='" + mod.empId + "',violationDate='" + mod.violationDate + "',grade='" + mod.grade + "',types='" + mod.types + "',description='" + mod.description + "', "); //strSql2.Append(" vtype='" + mod.vtype + "',createDate='" + mod.createDate + "',del='" + mod.del + "' where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "') ");
ol.Addfj(strSql2.ToString()); } } } catch {
} sql1 += synchViolationRecordSQL(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion
#region 违章sql拼接 public string synchViolationRecordSQL(tb_Emp_ViolationRecordModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_ViolationRecord where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_ViolationRecord ( "); strSql.Append(" sysId,recordId,empId,violationDate,grade,types,description,vtype,createDate,"); strSql.Append("projectCode,createUserMsgCode,createUserName,del "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.empId + "','" + mod.violationDate + "','" + mod.grade + "','" + mod.types + "','" + mod.description + "','" + mod.vtype + "','" + mod.createDate + "',"); strSql.Append("'" + mod.projectCode + "','" + mod.createUserMsgCode + "','" + mod.createUserName + "','" + mod.del + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Emp_ViolationRecord "); strSql.Append(" set "); strSql.Append(" empId='" + mod.empId + "',violationDate='" + mod.violationDate + "',grade='" + mod.grade + "',types='" + mod.types + "',description='" + mod.description + "', "); strSql.Append(" vtype='" + mod.vtype + "',createDate='" + mod.createDate + "',createUserMsgCode='" + mod.createUserMsgCode + "',createUserName='" + mod.createUserName + "',del='" + mod.del + "' where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion
#region 插入人员定位读头信息 [WebMethod] public string synchReaders(string uName, string pwd, string xml) {
tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("readers/reader")) { tb_Emp_ReadersModel mod = new tb_Emp_ReadersModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); mod.recordId = Convert.ToInt32(node["recordId"].InnerText); mod.lrmID = Convert.ToInt32(node["lrmID"].InnerText); mod.lrmName = node["lrmName"].InnerText; mod.lrmType = Convert.ToInt32(node["lrmType"].InnerText); mod.lrmX = Convert.ToInt32(node["lrmX"].InnerText); mod.lrmY = Convert.ToInt32(node["lrmY"].InnerText); mod.lrmState = Convert.ToInt32(node["lrmState"].InnerText);
if (node["lrmTime"].InnerText.Length > 0) mod.lrmTime=Convert.ToDateTime(node["lrmTime"].InnerText); else mod.lrmTime = null; mod.rmk = node["rmk"].InnerText; mod.monitorDaySecurity = node["monitorDaySecurity"].InnerText; mod.commentMans = node["commentMans"].InnerText; mod.dangerousMans = node["dangerousMans"].InnerText; mod.mapId = node["mapId"].InnerText; mod.lrmRadius = Convert.ToInt32(node["lrmRadius"].InnerText); //mod.createDate = Convert.ToDateTime(node["createDate"].InnerText.Length > 0 ? node["createDate"].InnerText : DBNull.Value.ToString()); if (node["createDate"].InnerText.Length > 0) mod.createDate=Convert.ToDateTime(node["createDate"].InnerText); else mod.createDate = null; mod.projectCode = node["projectCode"].InnerText; mod.del = node["del"].InnerText;
sql1 += synchReadersSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion
#region 人员定位读头sql拼接 public string synchReadersSQL(tb_Emp_ReadersModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_Readers where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_Readers ( "); strSql.Append(" sysId,recordId,lrmID,lrmName,lrmType,lrmX,lrmY,lrmState,lrmTime,rmk,monitorDaySecurity,"); strSql.Append("commentMans,dangerousMans,mapId,lrmRadius,createDate,projectCode,del "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.lrmID + "','" + mod.lrmName + "','" + mod.lrmType + "','" + mod.lrmX + "','" + mod.lrmY + "','" + mod.lrmState + "','" + mod.lrmTime + "',"); strSql.Append("'" + mod.rmk + "','" + mod.monitorDaySecurity + "','" + mod.commentMans + "','" + mod.dangerousMans + "','" + mod.mapId + "','" + mod.lrmRadius + "','" + mod.createDate + "','" + mod.projectCode + "','" + mod.del + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Emp_Readers "); strSql.Append(" set "); strSql.Append(" lrmID='" + mod.lrmID + "',lrmName='" + mod.lrmName + "',lrmType='" + mod.lrmType + "',lrmX='" + mod.lrmX + "',lrmY='" + mod.lrmY + "', "); strSql.Append(" lrmState='" + mod.lrmState + "',lrmTime='" + mod.lrmTime + "',rmk='" + mod.rmk + "',monitorDaySecurity='" + mod.monitorDaySecurity + "',commentMans='" + mod.commentMans + "',dangerousMans='" + mod.dangerousMans + "',mapId='" + mod.mapId + "', "); strSql.Append(" lrmRadius='" + mod.lrmRadius + "',createDate='" + mod.createDate + "',del='" + mod.del + "' "); strSql.Append(" where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion
#region 插入人员定位读头实时人员信息 [WebMethod] public string synchEntryRecord(string uName, string pwd, string xml) {
tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("entryrecords/entryrecord")) { tb_Emp_EntryRecordModel mod =new tb_Emp_EntryRecordModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); mod.recordId = Convert.ToInt32(node["recordId"].InnerText); mod.labelId = Convert.ToInt32(node["labelId"].InnerText); mod.lrmId = Convert.ToInt32(node["lrmId"].InnerText); mod.inTime = Convert.ToDateTime(node["inTime"].InnerText.Length > 0 ? node["inTime"].InnerText : "1900-01-01 00:00:00"); mod.outTime = Convert.ToDateTime(node["outTime"].InnerText.Length > 0 ? node["outTime"].InnerText : "1900-01-01 00:00:00"); mod.rmk = node["rmk"].InnerText; mod.empId = node["empId"].InnerText; mod.projectCode = node["projectCode"].InnerText; sql1 += synchEntryRecordSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion
#region 人员定位读头实时人员信息sql拼接 public string synchEntryRecordSQL(tb_Emp_EntryRecordModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_EntryRecord where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_EntryRecord ( "); strSql.Append(" sysId,recordId,labelId,lrmId,inTime,outTime,rmk,empId,projectCode "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.labelId + "','" + mod.lrmId + "','" + mod.inTime + "','" + mod.outTime + "','" + mod.rmk + "','" + mod.empId + "','" + mod.projectCode + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Emp_EntryRecord "); strSql.Append(" set "); strSql.Append(" labelId='" + mod.labelId + "',lrmId='" + mod.lrmId + "',inTime='" + mod.inTime + "',outTime='" + mod.outTime + "',rmk='" + mod.rmk + "', "); strSql.Append(" empId='" + mod.empId + "' "); strSql.Append(" where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion
#region 在场人员统计信息 [WebMethod] public string synchCurWorkers(string uName, string pwd, string xml) {
tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); string sql1 = ""; string sql2 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("workers/worker")) { tb_Emp_CurWorkInfoModel mod = new tb_Emp_CurWorkInfoModel(); mod.empId = node["empId"].InnerText; if (node["groupId"].InnerText.Length > 0) mod.groupId = Convert.ToInt32(node["groupId"].InnerText); else mod.groupId = null; if (node["IODate"].InnerText.Length > 0) mod.IODate = Convert.ToDateTime(node["IODate"].InnerText); else mod.IODate = null; if (node["director"].InnerText.Length > 0) mod.director = Convert.ToInt32(node["director"].InnerText); else mod.director = null; if (node["lastDirector"].InnerText.Length > 0) mod.lastDirector = Convert.ToInt32(node["lastDirector"].InnerText); else mod.lastDirector = null; if (node["type"].InnerText.Length > 0) mod.type = Convert.ToInt32(node["type"].InnerText); else mod.type = null; mod.projectCode = node["projectCode"].InnerText;
sql2 = " delete from tb_Emp_CurWorkInfo where projectCode='" + mod.projectCode + "' "; sql1 += synchCurWorkersSQL(mod); //ol.Add(mod); } sql2 += sql1; ol.Add(sql2); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion
#region 在场人员统计信息sql拼接 public string synchCurWorkersSQL(tb_Emp_CurWorkInfoModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append(" insert into tb_Emp_CurWorkInfo ( "); strSql.Append(" empId,groupId,IODate,director,lastDirector,type,projectCode "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.empId + "','" + mod.groupId + "','" + mod.IODate + "','" + mod.director + "','" + mod.lastDirector + "','" + mod.type + "','" + mod.projectCode + "' "); strSql.Append(" ) "); return strSql.ToString(); } #endregion
#region 在场人员异常警告信息 [WebMethod] public string synchWarnMessage(string uName, string pwd, string xml) {
tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("warnMessages/warnMessage")) { tb_Emp_WarnMessageModel mod = new tb_Emp_WarnMessageModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); mod.recordId = node["recordId"].InnerText; mod.empId = node["empId"].InnerText; mod.content = node["content"].InnerText; mod.type = node["type"].InnerText; if (node["createDate"].InnerText.Length > 0) mod.createDate = Convert.ToDateTime(node["createDate"].InnerText); mod.projectCode = node["projectCode"].InnerText; sql1 += synchWarnMessageSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion
#region 在场人员异常警告信息sql拼接 public string synchWarnMessageSQL(tb_Emp_WarnMessageModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_WarnMessage where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_WarnMessage ( "); strSql.Append(" sysId,recordId,empId,content,type,createDate,projectCode "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.empId + "','" + mod.content + "','" + mod.type + "','" + mod.createDate.ToString("yyyy-MM-dd HH:mm:ss.fff") + "','" + mod.projectCode + "' "); strSql.Append(" ) "); return strSql.ToString(); } #endregion
#region 闸机设备列表信息 [WebMethod] public string synchMachine(string uName, string pwd, string xml) {
tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("machines/machine")) { tb_Device_MachineModel mod = new tb_Device_MachineModel(); mod.sysId = Guid.NewGuid().ToString().Replace("-", ""); if (node["recordId"].InnerText.Length > 0) mod.recordId = Convert.ToInt32(node["recordId"].InnerText); else mod.recordId = null; mod.code = node["code"].InnerText; mod.name = node["name"].InnerText; if (node["goupId"].InnerText.Length > 0) mod.goupId = Convert.ToInt32(node["goupId"].InnerText); else mod.goupId = null; mod.ipAddress = node["ipAddress"].InnerText; if (node["computerId"].InnerText.Length > 0) mod.computerId = Convert.ToInt32(node["computerId"].InnerText); else mod.computerId = null; if (node["needSync"].InnerText.Length > 0) mod.needSync = Convert.ToInt32(node["needSync"].InnerText); else mod.needSync = null; mod.del = node["del"].InnerText; mod.projectCode = node["projectCode"].InnerText; sql1 += synchDevice_MachineSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion
#region 闸机设备列表信息sql拼接 public string synchDevice_MachineSQL(tb_Device_MachineModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Device_Machine where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Device_Machine ( "); strSql.Append(" sysId,recordId,code,name,goupId,ipAddress,computerId,needSync,del,projectCode "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.recordId + "','" + mod.code + "','" + mod.name + "','" + mod.goupId + "','" + mod.ipAddress + "','" + mod.computerId + "','" + mod.needSync + "','" + mod.del + "',"); strSql.Append("'" + mod.projectCode + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Device_Machine "); strSql.Append(" set "); strSql.Append(" sysId='" + mod.sysId + "',recordId='" + mod.recordId + "',code='" + mod.code + "',name='" + mod.name + "',goupId='" + mod.goupId + "', "); strSql.Append(" ipAddress='" + mod.ipAddress + "',computerId='" + mod.computerId + "',needSync='" + mod.needSync + "',del='" + mod.del + "',projectCode='" + mod.projectCode + "' "); strSql.Append(" where recordId='" + mod.recordId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion
#region 闸机设备列表信息 [WebMethod] public string synchSafeTrain(string uName, string pwd, string xml) {
tb_Emp_SysnBLL ol = new tb_Emp_SysnBLL(); string result = "0"; //发送成功 if (!uName.Equals(USERNAME) && !pwd.Equals(PWD)) return "-1";
try { XmlDocument doc = new XmlDocument(); string sql1 = ""; doc.LoadXml(xml); foreach (XmlNode node in doc.SelectNodes("safeTrains/safeTrain")) { tb_Emp_SafeTrainModel mod = new tb_Emp_SafeTrainModel(); mod.sysId = node["sysId"].InnerText; mod.title = node["title"].InnerText; mod.content = node["content"].InnerText; mod.participants = node["participants"].InnerText; mod.participantNames = node["participantNames"].InnerText; if (node["createDate"].InnerText.Length > 0) mod.createDate = Convert.ToDateTime(node["createDate"].InnerText); else mod.createDate = null; mod.createUserMsgCode = node["createUserMsgCode"].InnerText; mod.createUserName = node["createUserName"].InnerText; mod.projectCode = node["projectCode"].InnerText; mod.del = node["del"].InnerText; sql1 += synchSafeTrainSQL(mod); //ol.Add(mod); } ol.Add(sql1); } catch (Exception e) { result = e.Message; //返回异常信息 } return result; } #endregion
#region 闸机设备列表信息sql拼接 public string synchSafeTrainSQL(tb_Emp_SafeTrainModel mod) { StringBuilder strSql = new StringBuilder(); strSql.Append("if not exists(select 1 from tb_Emp_SafeTrain where sysId='" + mod.sysId + "' and projectCode='" + mod.projectCode + "')"); strSql.Append(" insert into tb_Emp_SafeTrain ( "); strSql.Append(" sysId,title,content,participants,participantNames,createDate,createUserMsgCode,createUserName,projectCode,del "); strSql.Append(" ) "); strSql.Append(" values ("); strSql.Append(" '" + mod.sysId + "','" + mod.title + "','" + mod.content + "','" + mod.participants + "','" + mod.participantNames + "','" + mod.createDate + "','" + mod.createUserMsgCode + "','" + mod.createUserName + "','" + mod.projectCode + "',"); strSql.Append("'" + mod.del + "' "); strSql.Append(" ) else "); strSql.Append(" update tb_Emp_SafeTrain "); strSql.Append(" set "); strSql.Append(" sysId='" + mod.sysId + "',title='" + mod.title + "',content='" + mod.content + "',participants='" + mod.participants + "',participantNames='" + mod.participantNames + "', "); strSql.Append(" createDate='" + mod.createDate + "',createUserMsgCode='" + mod.createUserMsgCode + "',createUserName='" + mod.createUserName + "',projectCode='" + mod.projectCode + "',del='" + mod.del + "' "); strSql.Append(" where sysId='" + mod.sysId + "' and projectCode='" + mod.projectCode + "' "); return strSql.ToString(); } #endregion }}