using DAL;
|
using DBUtility;
|
using Microsoft.AspNet.SignalR;
|
using Model;
|
using Newtonsoft.Json.Linq;
|
using SQLHelper;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.SqlClient;
|
using System.Linq;
|
using System.Net;
|
using System.Net.Http;
|
using System.Web;
|
using System.Web.Http;
|
using WebAPI.BLL;
|
using WebAPI.Models;
|
|
namespace WebAPI.Controllers
|
{
|
public class WebAPIController : ApiController
|
{
|
private JsonResult objJsonResult = new JsonResult();
|
private json objjson = new json();
|
// private POInStockBillServices oclscg_poinstockbillmain = new POInStockBillServices();
|
public string sWhere = "";
|
public WebServer webserver = new WebServer();
|
public DataSet ds = new DataSet();
|
|
public static string GetSession(string sMsg)
|
{
|
try
|
{
|
string s = Common.GetSession();
|
return s;
|
}
|
catch (Exception e)
|
{
|
return "";
|
}
|
}
|
/// <summary>
|
/// 写入日志
|
/// </summary>
|
public static bool Add_Log(string WorkList, string CurUserName, string State)
|
{
|
|
DBUtility.ClsPub.SetIPAddress();
|
string IPAddress;
|
string ComputerName;
|
IPAddress = DBUtility.ClsPub.IPAddress;
|
ComputerName = DBUtility.ClsPub.ComputerName;
|
ClsCNSRM oCnLoc = new ClsCNSRM();
|
try
|
{
|
oCnLoc.RunProc("Insert into System_Log(GeginDate,userid,WorkstationName,WorkList,SystemName,NetUserName,State) values " +
|
"(getdate(),'" + CurUserName + "','" + ComputerName + "','" + WorkList + "','SRM系统','" + IPAddress + "','" + State + "')"
|
);
|
|
return true;
|
}
|
catch (Exception e)
|
{
|
return false;
|
|
}
|
|
}
|
/// <summary>
|
/// 日志列表
|
/// </summary>
|
/// <param name="msg"></param>
|
/// <param name="NowPage"></param>
|
/// <param name="OnePage"></param>
|
/// <returns></returns>
|
[Route("GetSystemLog")]
|
[HttpGet]
|
//送货单列表
|
public object GetSystemLog(string HSupNo, string sqlWhere)
|
{
|
string msg = "";
|
try
|
{
|
string VsWhere = "";
|
string PcWhere = "";
|
SQLHelper.ClsCNSRM oCn = new SQLHelper.ClsCNSRM();
|
DataSet ds;
|
//其他过滤
|
if (msg.Trim() == "")
|
{
|
msg = " Where 用户名=^^" + HSupNo.Trim() + "^^ " + sqlWhere;
|
// msg = " Where hsupid in (select hsupid from Gy_UserSupplierRelation where HUserID=^^" + System.Web.HttpContext.Current.Session["HUserName"].ToString() + "^^)";
|
}
|
else
|
{
|
msg = msg + " and 用户名=^^" + HSupNo.Trim() + "^^" + sqlWhere;
|
// msg = msg + " Where hsupid in (select hsupid from Gy_UserSupplierRelation where HUserID=^^" + System.Web.HttpContext.Current.Session["HUserName"].ToString() + "^^)";
|
}
|
//转换特殊字符
|
if (Common.SQLtoChange(msg, ref VsWhere, ref PcWhere) == false)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败";
|
objjson.data = null;
|
return objjson;
|
}
|
//获取总行数
|
Int64 RowTotal = Common.GetRowTotal("h_v_SRM_SystemLogList", VsWhere, ref DBUtility.ClsPub.sExeReturnInfo);
|
//获取返回数据
|
ds = oCn.RunProcReturn("exec h_p_SRM_SystemLogList '" + PcWhere + "'", "h_p_SRM_SystemLogList");
|
if (ds == null || ds.Tables[0].Rows.Count == 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败";
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 10000;
|
objjson.Message = "获取成功";
|
objjson.data = ds.Tables[0];
|
return objjson;
|
}
|
}
|
catch (Exception e)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + e.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
|
}
|
|
/// <summary>
|
/// 获取登录页组织列
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetOrganizations")]
|
[HttpGet]
|
public object GetOrganizations()
|
{
|
try
|
{
|
ClsCN oCn = new ClsCN();
|
DataSet oDs = new DataSet();
|
//==========
|
oDs = oCn.RunProcReturn("select HItemID ID,Hname Name,HStopflag Stopflag from Xt_ORGANIZATIONS", "Xt_ORGANIZATIONS");
|
objjson.code = "1";
|
objjson.count = 1;
|
objjson.Message = "获取成功！";
|
objjson.data = oDs.Tables[0];
|
return objjson; ;
|
}
|
catch (Exception e)
|
{
|
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败！异常" + e.ToString();
|
objjson.data = null;
|
return objjson; ;
|
}
|
}
|
|
/// <summary>
|
/// 登录
|
/// </summary>
|
/// <param name="UserName">用户名</param>
|
/// <param name="PassWord">密码</param>
|
/// <returns></returns>
|
[Route("GetUser")]
|
[HttpGet]
|
public object GetUser(string UserName, string PassWord)
|
{
|
try
|
{
|
DataSet ds = null;
|
ClsCNSRM oCnLoc = new ClsCNSRM();
|
DAL.ClsUser oUser = new DAL.ClsUser();
|
Pub_Class.ClsXt_SystemParameter oSystemParameter = new Pub_Class.ClsXt_SystemParameter();
|
//LogService.Write("测试1："+ DBUtility.ClsPub.sExeReturnInfo);
|
string FCusName = oSystemParameter.GetSingleSystemParameter("WMS_CampanyName", ref DBUtility.ClsPub.sExeReturnInfo);
|
LogService.Write(FCusName);
|
LogService.Write("DBUtility.ClsPub.StrToPsd(PassWord.Trim()):" + DBUtility.ClsPub.StrToPsd(PassWord.Trim()));
|
//if (FCusName == "夏宝电器")
|
// ds = CheckMainID(UserName.Trim(), DBUtility.ClsPub.StrToPsd(PassWord.Trim()));
|
//else
|
// ds = CheckCzymc(UserName.Trim(), DBUtility.ClsPub.StrToPsd(PassWord.Trim()));
|
|
ds = CheckMainID(UserName.Trim(), DBUtility.ClsPub.StrToPsd(PassWord.Trim()));
|
if (ds == null || ds.Tables[0].Rows.Count == 0)
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "密码错误！";
|
objJsonResult.data = null;
|
return objJsonResult;
|
}
|
else
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "登录成功！";
|
objJsonResult.data = ds.Tables[0];
|
Add_Log("主界面", UserName, "登录");
|
return objJsonResult;
|
}
|
}
|
catch (Exception e)
|
{
|
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "登录异常！" + e.ToString();
|
objJsonResult.data = null;
|
return objJsonResult; ;
|
}
|
}
|
public DataSet CheckMainID(string MainID, string sPsd)
|
{
|
DataSet DS;
|
try
|
{
|
SQLHelper.ClsCNSRM oCn = new SQLHelper.ClsCNSRM();
|
DS = oCn.RunProcReturn("select * from Gy_Czygl where Czybm='" + MainID + "' and Czmm='" + sPsd + "' ", "Gy_Czygl");
|
if (DS.Tables[0].Rows.Count == 0)
|
return null;
|
else
|
{
|
return DS;
|
}
|
}
|
catch (Exception e)
|
{
|
throw (e);
|
}
|
}
|
public DataSet CheckCzymc(string sUser, string sPsd)
|
{
|
SQLHelper.ClsCNSRM oCn = new SQLHelper.ClsCNSRM();
|
SqlParameter[] prams ={oCn.MakeInParam("@Czymc",SqlDbType.VarChar,100,sUser ),
|
oCn.MakeInParam("@Czmm",SqlDbType.VarChar ,100,sPsd ),
|
};
|
return oCn.RunProcReturn("select * from Gy_Czygl where Czymc='" + sUser + "' and Czmm='" + sPsd + "' ", prams, "Gy_Czygl");
|
}
|
|
/// <summary>
|
/// 修改密码
|
/// </summary>
|
/// <param name="UserName"></param>
|
/// <param name="PassWord"></param>
|
/// <returns></returns>
|
[Route("GetXGPassword")]
|
[HttpGet]
|
public object GetXGPassword(string UserName, string oldPassword, string PassWord, string Repassword)
|
{
|
try
|
{
|
ClsCNSRM oCn = new ClsCNSRM();
|
DataSet oDs = new DataSet();
|
//==========
|
if (PassWord.Trim() != Repassword.Trim())
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "2次密码不一致！";
|
objJsonResult.data = null;
|
return objJsonResult; ;
|
}
|
//===========
|
//LogService.Write("select Czmm from Gy_Czygl where Czymc='" + UserName + "' and Czmm = '" + DBUtility.ClsPub.StrToPsd(oldPassword.Trim()) + "'");
|
oDs = oCn.RunProcReturn("select Czmm from Gy_Czygl where Czymc='" + UserName + "' and Czmm = '" + DBUtility.ClsPub.StrToPsd(oldPassword.Trim()) + "'", "Gy_Czygl");
|
if (oDs == null || oDs.Tables[0].Rows.Count == 0)
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "原密码错误！";
|
objJsonResult.data = null;
|
return objJsonResult; ;
|
}
|
else
|
{
|
oCn.RunProc("update Gy_Czygl set Czmm='" + DBUtility.ClsPub.StrToPsd(PassWord.Trim()) + "' where Czymc='" + UserName.Trim() + "'");
|
objJsonResult.code = "0";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "* 密码修改成功！";
|
objJsonResult.data = null;
|
Add_Log("主界面", UserName, "修改密码");
|
return objJsonResult; ;
|
}
|
}
|
catch (Exception)
|
{
|
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "修改密码异常！";
|
objJsonResult.data = null;
|
return objJsonResult; ;
|
}
|
}
|
///// <summary>
|
///// 确认交期
|
///// </summary>
|
///// <param name="HInterID"></param>
|
///// <param name="HEntryID"></param>
|
///// <param name="HState"></param>
|
///// <returns></returns>
|
//[Route("UpdateBill")]
|
//[HttpGet]
|
//public object UpdateBill(int HInterID, int HEntryID, int HState)
|
//{
|
// try
|
// {
|
// if (DBUtility.ClsPub.isLong(HInterID) == 0)
|
// {
|
// objJsonResult.code = "0";
|
// objJsonResult.count = 0;
|
// objJsonResult.Message = "N,项目不存在！";
|
// objJsonResult.data = 1;
|
// return objJsonResult;
|
// }
|
// DAL.ClsKf_POStockInBill_K3 oBill = new DAL.ClsKf_POStockInBill_K3();
|
// if (oBill.UpdateBill(HInterID, HEntryID, HState) == "Y")
|
// {
|
// objJsonResult.code = "0";
|
// objJsonResult.count = 1;
|
// objJsonResult.Message = "确认成功！";
|
// objJsonResult.data = 1;
|
// return objJsonResult;
|
// }
|
// else
|
// {
|
// objJsonResult.code = "0";
|
// objJsonResult.count = 0;
|
// objJsonResult.Message = "确认失败！";
|
// objJsonResult.data = 1;
|
// return objJsonResult;
|
// }
|
// }
|
// catch (Exception e)
|
// {
|
// objJsonResult.code = "0";
|
// objJsonResult.count = 0;
|
// objJsonResult.Message = "确认失败！" + e.ToString();
|
// objJsonResult.data = 1;
|
// return objJsonResult;
|
// }
|
//}
|
|
/// <summary>
|
/// 获取打印模板列表
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetOpenTmpList_Json")]
|
[HttpGet]
|
public object GetOpenTmpList_Json(string HNumber)
|
{
|
sWhere = " Where 1=1 ";
|
//sWhere = " Where HStopFlag=0 and HEndFlag=1 and HUSEORGID = " + DBUtility.ClsPub.HORGANIZATIONSID.ToString();
|
if (HNumber != "")
|
{
|
sWhere = sWhere + " and ( HNumber = '" + HNumber + "') ";
|
}
|
try
|
{
|
ds = webserver.GetOpenTmpList(sWhere, ref DBUtility.ClsPub.sErrInfo);
|
if (ds == null || ds.Tables[0].Rows.Count <= 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + DBUtility.ClsPub.sErrInfo;
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "获取成功!";
|
objjson.data = ds.Tables[0];
|
return objjson;
|
}
|
}
|
catch (Exception ex)
|
{
|
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + ex.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
}
|
/// <summary>
|
/// 保存打印模板
|
/// </summary>
|
/// <returns></returns>
|
[Route("SaveOpenTmp")]
|
[HttpGet]
|
public object SaveOpenTmp(string HNumber, string HName)
|
{
|
ClsCNSRM oCn = new ClsCNSRM();
|
try
|
{
|
|
//oCn.BeginTran();
|
//oCn.RunProc("Insert into SRM_OpenTmp " +
|
// " (HNumber,HModel,HName) " +
|
// " Values('" + HNumber + "','" + HName + "','" + HName + "')", ref DBUtility.ClsPub.sExeReturnInfo);
|
////修改上级为非末级代码
|
////oCn.RunProc("Update Gy_OpenTmp set HEndflag=0 where HItemID=" + oModel.HParentID, ref ClsPub.sExeReturnInfo);
|
//oCn.Commit();
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "保存成功!";
|
objjson.data = null;
|
return objjson;
|
}
|
catch (Exception e)
|
{
|
oCn.RollBack();
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "保存失败" + e.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
|
|
}
|
/// <summary>
|
/// 删除印模板
|
/// </summary>
|
/// <returns></returns>
|
[Route("DelOpenTmp")]
|
[HttpGet]
|
public object DelOpenTmp(string HItemID)
|
{
|
ClsCNSRM oCn = new ClsCNSRM();
|
try
|
{
|
//oCn.BeginTran();
|
//oCn.RunProc("Delete from SRM_OpenTmp where HItemID='" + DBUtility.ClsPub.isLong(HItemID) + "'", ref DBUtility.ClsPub.sExeReturnInfo);
|
//oCn.Commit();
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "删除成功!";
|
objjson.data = null;
|
return objjson;
|
}
|
catch (Exception e)
|
{
|
oCn.RollBack();
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "删除失败" + e.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
|
}
|
#region 基础资料
|
/// <summary>
|
/// 获取仓库列表
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetWarehouseList_Json")]
|
[HttpGet]
|
public object GetWarehouseList_Json(string Warehouse)
|
{
|
sWhere = " Where HStopFlag=0 and HEndFlag=1";
|
//sWhere = " Where HStopFlag=0 and HEndFlag=1 and HUSEORGID = " + DBUtility.ClsPub.HORGANIZATIONSID.ToString();
|
if (Warehouse != "")
|
{
|
sWhere = sWhere + " and ( HNumber like '%" + Warehouse + "%' or HName like '%" + Warehouse + "%' ) ";
|
}
|
try
|
{
|
ds = webserver.GetWarehouseList(sWhere, ref DBUtility.ClsPub.sErrInfo);
|
if (ds == null || ds.Tables[0].Rows.Count <= 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + DBUtility.ClsPub.sErrInfo;
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "获取成功!";
|
objjson.data = ds.Tables[0];
|
return objjson;
|
}
|
}
|
catch (Exception ex)
|
{
|
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + ex.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
}
|
/// <summary>
|
/// 获取仓位列表
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetStockPlaceList_Json")]
|
[HttpGet]
|
public object GetStockPlaceList_Json(string StockPlace, Int64 HWhID)
|
{
|
sWhere = " Where HStopFlag=0 and HEndFlag=1";
|
//sWhere = " Where HStopFlag=0 and HEndFlag=1 and HUSEORGID = " + DBUtility.ClsPub.HORGANIZATIONSID.ToString();
|
if (HWhID == 0)
|
{
|
if (StockPlace != "")
|
{
|
sWhere = " Where HStopFlag=0 and ( HNumber like '%" + StockPlace + "%' or HName like '%" + StockPlace + "%' ) ";
|
}
|
else
|
{
|
sWhere = " Where HStopFlag=0 ";
|
}
|
}
|
else
|
{
|
if (StockPlace != "")
|
{
|
sWhere = " Where HStopFlag=0 and HWHID=" + HWhID.ToString() + " and ( HNumber like '%" + StockPlace + "%' or HName like '%" + StockPlace + "%' ) ";
|
}
|
else
|
{
|
sWhere = " Where HStopFlag=0 and HWHID=" + HWhID.ToString();
|
}
|
}
|
try
|
{
|
ds = webserver.GetStockPlaceList(sWhere, ref DBUtility.ClsPub.sErrInfo);
|
if (ds == null || ds.Tables[0].Rows.Count <= 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + DBUtility.ClsPub.sErrInfo;
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "获取成功!";
|
objjson.data = ds.Tables[0];
|
return objjson;
|
}
|
}
|
catch (Exception ex)
|
{
|
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + ex.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
}
|
/// <summary>
|
/// 获取供应商列表
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetSupplierList_Json")]
|
[HttpGet]
|
public object GetSupplierList_Json(string Supplier)
|
{
|
sWhere = " Where HStopFlag=0 and HEndFlag=1";
|
//sWhere = " Where HStopFlag=0 and HEndFlag=1 and HUSEORGID = " + DBUtility.ClsPub.HORGANIZATIONSID.ToString();
|
if (Supplier != "")
|
{
|
sWhere = sWhere + " and ( HNumber like '%" + Supplier + "%' or HName like '%" + Supplier + "%' ) ";
|
}
|
try
|
{
|
ds = webserver.GetSupplierList(sWhere, ref DBUtility.ClsPub.sErrInfo);
|
if (ds == null || ds.Tables[0].Rows.Count <= 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + DBUtility.ClsPub.sErrInfo;
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "获取成功!";
|
objjson.data = ds.Tables[0];
|
return objjson;
|
}
|
}
|
catch (Exception ex)
|
{
|
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + ex.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
}
|
/// <summary>
|
/// 获取客户列表
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetCustomerList_Json")]
|
[HttpGet]
|
public object GetCustomerList_Json(string Customer)
|
{
|
sWhere = " Where HStopFlag=0 and HEndFlag=1";
|
//sWhere = " Where HStopFlag=0 and HEndFlag=1 and HUSEORGID = " + DBUtility.ClsPub.HORGANIZATIONSID.ToString();
|
if (Customer != "")
|
{
|
sWhere = sWhere + " and ( HNumber like '%" + Customer + "%' or HName like '%" + Customer + "%' ) ";
|
}
|
try
|
{
|
ds = webserver.GetCustomerList(sWhere, ref DBUtility.ClsPub.sErrInfo);
|
if (ds == null || ds.Tables[0].Rows.Count <= 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + DBUtility.ClsPub.sErrInfo;
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "获取成功!";
|
objjson.data = ds.Tables[0];
|
return objjson;
|
}
|
}
|
catch (Exception ex)
|
{
|
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + ex.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
}
|
|
/// <summary>
|
/// 获取职员列表
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetEmployeeList_Json")]
|
[HttpGet]
|
public object GetEmployeeList_Json(string Employee, Int64 HGroupID)
|
{
|
sWhere = " Where HStopFlag=0 and HEndFlag=1";
|
//sWhere = " Where HStopFlag=0 and HEndFlag=1 and HUSEORGID = " + DBUtility.ClsPub.HORGANIZATIONSID.ToString();
|
if (HGroupID == 0)
|
{
|
if (Employee != "")
|
{
|
sWhere = " Where HStopFlag=0 and ( HNumber like '%" + Employee + "%' or HName like '%" + Employee + "%' ) ";
|
}
|
else
|
{
|
sWhere = " Where HStopFlag=0 ";
|
}
|
}
|
else
|
{
|
if (Employee != "")
|
{
|
sWhere = " Where HStopFlag=0 and HWHID=" + HGroupID.ToString() + " and ( HNumber like '%" + Employee + "%' or HName like '%" + Employee + "%' ) ";
|
}
|
else
|
{
|
sWhere = " Where HStopFlag=0 and HWHID=" + HGroupID.ToString();
|
}
|
}
|
try
|
{
|
ds = webserver.GetEmployeeList(sWhere, ref DBUtility.ClsPub.sErrInfo);
|
if (ds == null || ds.Tables[0].Rows.Count <= 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + DBUtility.ClsPub.sErrInfo;
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "获取成功!";
|
objjson.data = ds.Tables[0];
|
return objjson;
|
}
|
}
|
catch (Exception ex)
|
{
|
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + ex.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
}
|
/// <summary>
|
/// 获取部门列表
|
/// </summary>
|
/// <returns></returns>
|
[Route("GetDepartmentList_Json")]
|
[HttpGet]
|
public object GetDepartmentList_Json(string Department)
|
{
|
sWhere = " Where HStopFlag=0 and HEndFlag=1";
|
//sWhere = " Where HStopFlag=0 and HEndFlag=1 and HUSEORGID = " + DBUtility.ClsPub.HORGANIZATIONSID.ToString();
|
if (Department != "")
|
{
|
sWhere = sWhere + " and ( HNumber like '%" + Department + "%' or HName like '%" + Department + "%' ) ";
|
}
|
try
|
{
|
ds = webserver.GetDepartmentList(sWhere, ref DBUtility.ClsPub.sErrInfo);
|
if (ds == null || ds.Tables[0].Rows.Count <= 0)
|
{
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + DBUtility.ClsPub.sErrInfo;
|
objjson.data = null;
|
return objjson;
|
}
|
else
|
{
|
objjson.code = "0";
|
objjson.count = 1;
|
objjson.Message = "获取成功!";
|
objjson.data = ds.Tables[0];
|
return objjson;
|
}
|
}
|
catch (Exception ex)
|
{
|
|
objjson.code = "0";
|
objjson.count = 0;
|
objjson.Message = "获取失败" + ex.ToString();
|
objjson.data = null;
|
return objjson;
|
}
|
}
|
#endregion
|
|
|
/// <summary>
|
/// 触发hub的api
|
/// </summary>
|
/// <param name="request">request</param>
|
/// <returns>message</returns>
|
[AllowAnonymous]
|
[Route("show/hub"), HttpGet]
|
public HttpResponseMessage GetMessage(HttpRequestMessage request)
|
{
|
var hub = GlobalHost.ConnectionManager.GetHubContext<MyHub>();
|
//注意这里的showMessage 就是对RepairHub下定义的showMessage方法调用,同样前端也是调用这个方法
|
string aa = hub.Clients.All.showMessage("这里面可以放入任意对象,前台可以收到此内容");
|
return request.CreateResponse(HttpStatusCode.OK, aa);
|
}
|
|
[Route("Message/MsgCount")]
|
[HttpPost]
|
public object MsgCount()
|
{
|
ClsCNSRM oCn = new ClsCNSRM();
|
DataSet oDs = new DataSet();
|
oDs = oCn.RunProcReturn("select * from Gy_Message", "Gy_Message");
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "返回数据";
|
objJsonResult.data = oDs;
|
return objJsonResult; ;
|
}
|
|
|
#region [公告数据查询]
|
[Route("MsgData")]
|
[HttpGet]
|
public object MsgData(string sWhere)
|
{
|
ClsCNSRM oCn = new ClsCNSRM();
|
DataSet oDs = new DataSet();
|
var sql = "select A.HInterID,b.HEntryID,A.HContext,A.HDeptID,D.HName HDeptName, A.HSendMan, B.HReceiveMan,A.HLevel,A.HDescription,case when B.HReadFlag=0 then '未阅' when B.HReadFlag=1 then '已阅' end HReadFlag,A.HDate" +
|
" from OA_InformBillMain A inner join OA_InformBillSub B on A.HInterID=B.HInterID left join Gy_Department D on A.HDeptID=D.HItemID where 1=1 " + sWhere;
|
oDs = oCn.RunProcReturn(sql, "OA_InformBillMain");
|
if (oDs.Tables[0].Rows.Count > 0)
|
{
|
objJsonResult.code = "1";
|
objJsonResult.count = 1;
|
objJsonResult.Message = "返回数据成功！";
|
objJsonResult.data = oDs;
|
}
|
else
|
{
|
objJsonResult.code = "0";
|
objJsonResult.count = 0;
|
objJsonResult.Message = "返回数据失败！";
|
objJsonResult.data = oDs;
|
}
|
return objJsonResult; ;
|
}
|
#endregion
|
|
#region[更改公告状态]
|
[Route("UpdateMessage")]
|
[HttpGet]
|
public object UpdateMessage(string UserName, string HInterID, string HEntryID)
|
{
|
ClsCNSRM oCn = new ClsCNSRM();
|
oCn.BeginTran();
|
oCn.RunProc("Update OA_InformBillSub set HReadFlag=1 HUpDater='" + UserName + "',HUpDateDate=getdate() where HInterID='" + HInterID + "' and HEntryID='" + HEntryID + "'", ref ClsPub.sExeReturnInfo);
|
oCn.Commit();
|
objjson.code = "1";
|
objjson.count = 1;
|
objjson.Message = ClsPub.sExeReturnInfo;
|
objjson.data = null;
|
return objjson; ;
|
}
|
#endregion
|
|
|
}
|
}
|
