软测单独项目
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 

332 lines
15 KiB

using FangYar.Model;
using FangYar.Model.OA;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Web;
namespace FangYar.WebUI.ashx
{
/// <summary>
/// Oa_PatrolSentryTaskHandler 的摘要说明
/// </summary>
public class OaPatrolSentryPlanHandler : IHttpHandler
{
private FangYar.BLL.OA.OA_PATROLSENTRYTASK bll = new BLL.OA.OA_PATROLSENTRYTASK();
public void ProcessRequest(HttpContext context)
{
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Other, "查铺查哨计划操作请求", "");
context.Response.ContentType = "text/plain";
string action = context.Request.Params["Action"];
string returnstr = "";
switch (action)
{
case "List":
returnstr = getList(context);
break;
case "Add":
returnstr = Add(context);
break;
case "Delete":
returnstr = Delete(context);
break;
case "Edit":
returnstr = Edit(context);
break;
}
context.Response.Write(returnstr);
}
//查询
private string getList(HttpContext context)
{
string returnstr = "";
try
{
string orgId = context.Request.Params["OrgId"];
string keyword = context.Request.Params["keywords"];
string treeID = context.Request.Params["treeID"];
string page = context.Request.Params["page"];
string limit = context.Request.Params["limit"];
int pageIndex = 1;
int pageSize = 10;//
if (!string.IsNullOrEmpty(page)) { pageIndex = int.Parse(page); }
if (!string.IsNullOrEmpty(limit)) { pageSize = int.Parse(limit); }
int startIndex = (pageIndex - 1) * pageSize;
string where = null;
if (!string.IsNullOrEmpty(treeID) && treeID != orgId)
{
orgId = treeID;
}
where = "ORGID = '" + orgId + "' ";
if (!string.IsNullOrEmpty(keyword))
{
where += " and PLANNAME like '%" + keyword + "%' ";
}
returnstr = "{\"code\":0,\"msg\":\"\",";
int count = FangYar.Common.MySqlHelper.GetCount("select count(1) from oa_patrolsentryplan where " + where);
returnstr += "\"count\":" + count + ",\"data\":";
if (count == 0)
{
returnstr += "[]";
}
else
{
string sqlStr = " select opp.*,fo.ORG_NAME from oa_patrolsentryplan opp left join fire_org fo on opp.ORGID = fo.ORG_ID where " + where + " order by CREATEDATE desc limit " + startIndex + "," + pageSize;
DataTable dt = FangYar.Common.MySqlHelper.QueryTable(sqlStr);
returnstr += FangYar.Common.JsonHelper.ToJson(dt);
}
returnstr += "}";
}
catch (Exception e)
{
returnstr = "{\"code\":0,\"msg\":\"error\",\"count\":0,\"data\":[]}";
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Error, "查铺查哨计划操作请求", "查询异常:" + e);
}
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Query, "查铺查哨计划操作请求", "查询");
return returnstr;
}
//添加
private string Add(HttpContext context)
{
string returnstr = "";
try
{
string orgId = context.Request.Params["orgid"];
string planName = context.Request.Params["planName"];
string workDayArray = context.Request.Params["workDayArray"];
string patrollerid = context.Request.Params["patrollerid"];
string patroller = context.Request.Params["patroller"];
string startTime = context.Request.Params["startTime"];
string endTime = context.Request.Params["endTime"];
string startTime2 = context.Request.Params["startTime2"];
string endTime2 = context.Request.Params["endTime2"];
string startTimeNext = context.Request.Params["startTimeNext"];
string endTimeNext = context.Request.Params["endTimeNext"];
string startTimeNext2 = context.Request.Params["startTimeNext2"];
string endTimeNext2 = context.Request.Params["endTimeNext2"];
string createby = context.Request.Params["createby"];
string spotIds = context.Request.Params["spotIds"];
string spotNames = context.Request.Params["spotNames"];
List<FangYar.Model.OA.CommonSql> SQLStringList = new List<CommonSql>();
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into OA_PATROLSENTRYPLAN(");
strSql.Append("ID,ORGID,PLANNAME,WORK_DAY,PATROLLERID,PATROLLER,BEGINDATE,ENDDATE,STATE,SPOT_IDS,SPOT_NAMES,CREATEDATE,CREATEBY,UPDATEDATE,UPDATEBY,NUMBEROFTIMES,BEGINDATENEXT,ENDDATENEXT)");
strSql.Append(" values (");
strSql.Append("@ID,@ORGID,@PLANNAME,@WORK_DAY,@PATROLLERID,@PATROLLER,@BEGINDATE,@ENDDATE,@STATE,@SPOT_IDS,@SPOT_NAMES,@CREATEDATE,@CREATEBY,@UPDATEDATE,@UPDATEBY,@NUMBEROFTIMES,@BEGINDATENEXT,@ENDDATENEXT)");
MySqlParameter[] parameters1 = {
new MySqlParameter("@ID", Guid.NewGuid().ToString("N")),
new MySqlParameter("@ORGID", orgId),
new MySqlParameter("@PLANNAME", planName+"一"),
new MySqlParameter("@WORK_DAY", workDayArray),
new MySqlParameter("@PATROLLERID", patrollerid),
new MySqlParameter("@PATROLLER", patroller),
new MySqlParameter("@BEGINDATE", startTime),
new MySqlParameter("@ENDDATE", endTime),
new MySqlParameter("@STATE", '0'),
new MySqlParameter("@SPOT_IDS", spotIds),
new MySqlParameter("@SPOT_NAMES", spotNames),
new MySqlParameter("@CREATEDATE", DateTime.Now.ToString("G")),
new MySqlParameter("@CREATEBY", createby),
new MySqlParameter("@UPDATEDATE", DateTime.Now.ToString("G")),
new MySqlParameter("@UPDATEBY", createby),
new MySqlParameter("@NUMBEROFTIMES", 1),
new MySqlParameter("@BEGINDATENEXT", startTimeNext),
new MySqlParameter("@ENDDATENEXT", endTimeNext)};
SQLStringList.Add(new FangYar.Model.OA.CommonSql()
{
sql = strSql.ToString(),
param = parameters1
});
MySqlParameter[] parameters2 = {
new MySqlParameter("@ID", Guid.NewGuid().ToString("N")),
new MySqlParameter("@ORGID", orgId),
new MySqlParameter("@PLANNAME", planName+"二"),
new MySqlParameter("@WORK_DAY", workDayArray),
new MySqlParameter("@PATROLLERID", patrollerid),
new MySqlParameter("@PATROLLER", patroller),
new MySqlParameter("@BEGINDATE", startTime2),
new MySqlParameter("@ENDDATE", endTime2),
new MySqlParameter("@STATE", '0'),
new MySqlParameter("@SPOT_IDS", spotIds),
new MySqlParameter("@SPOT_NAMES", spotNames),
new MySqlParameter("@CREATEDATE", DateTime.Now.ToString("G")),
new MySqlParameter("@CREATEBY", createby),
new MySqlParameter("@UPDATEDATE", DateTime.Now.ToString("G")),
new MySqlParameter("@UPDATEBY", createby),
new MySqlParameter("@NUMBEROFTIMES", 2),
new MySqlParameter("@BEGINDATENEXT", startTimeNext2),
new MySqlParameter("@ENDDATENEXT", endTimeNext2)};
SQLStringList.Add(new FangYar.Model.OA.CommonSql()
{
sql = strSql.ToString(),
param = parameters2
});
if (FangYar.Common.MySqlHelper.ExecuteSqlTranBool(SQLStringList))
{
returnstr = "{\"code\":1,\"msg\":\"添加成功!\",\"count\":0,\"data\":[]}";
}
else
{
returnstr = "{\"code\":-1,\"msg\":\"添加失败!\",\"count\":0,\"data\":[]}";
}
}
catch (Exception e)
{
returnstr = "{\"code\":0,\"msg\":\"error\",\"count\":0,\"data\":[]}";
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Error, "查铺查哨计划操作请求", "添加异常:" + e);
}
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Add, "查铺查哨计划操作请求", "添加");
return returnstr;
}
//删除
private string Delete(HttpContext context)
{
string returnstr = "";
try
{
string Id = context.Request.Params["Id"];
string sqlStr = "delete from oa_patrolsentryplan where ID = '" + Id + "' ";
if (FangYar.Common.MySqlHelper.ExecuteSql(sqlStr) > 0)
{
returnstr = "{\"code\":1,\"msg\":\"删除成功!\",\"count\":0,\"data\":[]}";
}
else
{
returnstr = "{\"code\":1,\"msg\":\"不存在该记录!\",\"count\":0,\"data\":[]}";
}
}
catch (Exception e)
{
returnstr = "{\"code\":0,\"msg\":\"error\",\"count\":0,\"data\":[]}";
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Error, "查铺查哨计划操作请求", "删除异常:" + e);
}
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Delete, "查铺查哨计划操作请求", "删除");
return returnstr;
}
//编辑单条计划
private string Edit(HttpContext context)
{
string returnstr = "";
try
{
string Id = context.Request.Params["Id"];
string numberOfTimes = context.Request.Params["numberOfTimes"];
string orgId = context.Request.Params["orgid"];
string planName = context.Request.Params["planName"];
string workDayArray = context.Request.Params["workDayArray"];
string patrollerid = context.Request.Params["patrollerid"];
string patroller = context.Request.Params["patroller"];
string startTime = context.Request.Params["startTime"];
string endTime = context.Request.Params["endTime"];
string startTimeNext = context.Request.Params["startTimeNext"];
string endTimeNext = context.Request.Params["endTimeNext"];
string createby = context.Request.Params["createby"];
string spotIds = context.Request.Params["spotIds"];
string spotNames = context.Request.Params["spotNames"];
string state = context.Request.Params["state"];
StringBuilder strSql = new StringBuilder();
strSql.Append("update OA_PATROLSENTRYPLAN set ");
strSql.Append("ORGID=@ORGID,");
strSql.Append("PLANNAME=@PLANNAME,");
strSql.Append("WORK_DAY=@WORK_DAY,");
strSql.Append("PATROLLERID=@PATROLLERID,");
strSql.Append("PATROLLER=@PATROLLER,");
strSql.Append("BEGINDATE=@BEGINDATE,");
strSql.Append("ENDDATE=@ENDDATE,");
strSql.Append("STATE=@STATE,");
strSql.Append("SPOT_IDS=@SPOT_IDS,");
strSql.Append("SPOT_NAMES=@SPOT_NAMES,");
strSql.Append("UPDATEDATE=@UPDATEDATE,");
strSql.Append("UPDATEBY=@UPDATEBY,");
strSql.Append("NUMBEROFTIMES=@NUMBEROFTIMES,");
strSql.Append("BEGINDATENEXT=@BEGINDATENEXT,");
strSql.Append("ENDDATENEXT=@ENDDATENEXT");
strSql.Append(" where ID=@ID ");
MySqlParameter[] parameters = {
new MySqlParameter("@ORGID", orgId),
new MySqlParameter("@PLANNAME", planName),
new MySqlParameter("@WORK_DAY", workDayArray),
new MySqlParameter("@PATROLLERID", patrollerid),
new MySqlParameter("@PATROLLER", patroller),
new MySqlParameter("@BEGINDATE", startTime),
new MySqlParameter("@ENDDATE", endTime),
new MySqlParameter("@STATE", state),
new MySqlParameter("@SPOT_IDS", spotIds),
new MySqlParameter("@SPOT_NAMES", spotNames),
new MySqlParameter("@UPDATEDATE", DateTime.Now.ToString("G")),
new MySqlParameter("@UPDATEBY", createby),
new MySqlParameter("@NUMBEROFTIMES", numberOfTimes),
new MySqlParameter("@BEGINDATENEXT", startTimeNext),
new MySqlParameter("@ENDDATENEXT", endTimeNext),
new MySqlParameter("@ID", Id)};
if (FangYar.Common.MySqlHelper.ExecuteSql(strSql.ToString(), parameters) > 0)
{
returnstr = "{\"code\":1,\"msg\":\"编辑成功!\",\"count\":0,\"data\":[]}";
}
else
{
returnstr = "{\"code\":1,\"msg\":\"不存在该记录!\",\"count\":0,\"data\":[]}";
}
}
catch (Exception e)
{
returnstr = "{\"code\":0,\"msg\":\"error\",\"count\":0,\"data\":[]}";
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Error, "查铺查哨计划操作请求", "编辑单条计划异常:" + e);
}
// 记录操作日志
BLL.SysOperationLogHelp.AddSysOperationLog(context, Common.EnumOperationLogType.Update, "查铺查哨计划操作请求", "编辑单条计划");
return returnstr;
}
public bool IsReusable
{
get
{
return false;
}
}
}
}