1 Star 0 Fork 471

gisinaction/QJ_Single

forked from 落云谷/QJ_OneLotus 
加入 Gitee
与超过 1400万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
XMGLManage.cs 12.33 KB
一键复制 编辑 原始数据 按行查看 历史
using QJY.API;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Web;
using FastReflectionLib;
using QJY.Data;
using Newtonsoft.Json;
using System.Data;
using Senparc.Weixin.QY.Entities;
namespace QJY.API
{
public class XMGLManage : IWsService
{
public void ProcessRequest(HttpContext context, ref Msg_Result msg, string P1, string P2, JH_Auth_UserB.UserInfo UserInfo)
{
MethodInfo methodInfo = typeof(XMGLManage).GetMethod(msg.Action.ToUpper());
XMGLManage model = new XMGLManage();
methodInfo.FastInvoke(model, new object[] { context, msg, P1, P2, UserInfo });
}
/// <summary>
/// 查看项目的详细
/// </summary>
/// <param name="context"></param>
/// <param name="msg"></param>
/// <param name="P1"></param>
/// <param name="P2"></param>
/// <param name="UserInfo"></param>
public void GETXMGLMODEL(HttpContext context, Msg_Result msg, string P1, string P2, JH_Auth_UserB.UserInfo UserInfo)
{
int Id = 0;
int.TryParse(P1, out Id);
DataTable Model = new SZHL_XMGLB().GetDTByCommand("SELECT xm.*,zd.TypeName from SZHL_XMGL xm left join JH_Auth_ZiDian zd on convert(varchar,YXJ)=convert(varchar,zd.ID) WHERE xm.ID=" + Id + "");
msg.Result = Model;
if (Model != null && Model.Rows.Count > 0)
{
DataTable dtpl = new JH_Auth_TLB().GetTL("XMGL", Model.Rows[0]["ID"].ToString());
msg.Result1 = dtpl;
DataTable filedt = dtpl.Copy();
if (filedt != null && filedt.Rows.Count > 0)
{
foreach (DataRow dr in filedt.Rows)
{
if (dr["MSGisHasFiles"] == null || dr["MSGisHasFiles"].ToString() == "")
{
dr.Delete();
}
}
filedt.AcceptChanges();
msg.Result3 = filedt;
}
if (Model.Rows[0]["Files"].ToString() != "")
{
int[] fileIDs = Model.Rows[0]["Files"].ToString().SplitTOInt(',');
List<FT_File> FileList = new FT_FileB().GetEntities(d => fileIDs.Contains(d.ID)).ToList();
msg.Result2 = FileList;
}
}
}
/// <summary>
/// 添加项目管理
/// </summary>
/// <param name="context"></param>
/// <param name="msg"></param>
/// <param name="strParamData"></param>
public void ADDXMGL(HttpContext context, Msg_Result msg, string P1, string P2, JH_Auth_UserB.UserInfo UserInfo)
{
try
{
SZHL_XMGL xmgl = JsonConvert.DeserializeObject<SZHL_XMGL>(P1);
if (string.IsNullOrEmpty(xmgl.XMMC))
{
msg.ErrorMsg = "项目名称不能为空";
return;
}
if (string.IsNullOrEmpty(xmgl.YXJ))
{
msg.ErrorMsg = "请选择项目类型";
return;
}
if (string.IsNullOrEmpty(xmgl.XMFZR))
{
msg.ErrorMsg = "请选择负责人";
return;
}
if (xmgl.StartDate != null && xmgl.EndDate != null)
{
if (xmgl.StartDate >= xmgl.EndDate)
{
msg.ErrorMsg = "结束时间必须大于开始时间";
return;
}
}
#region
if (P2 != null && P2 != "") // 处理微信上传的图片
{
string fids = CommonHelp.ProcessWxIMG(P2, "QYHD", UserInfo);
if (!string.IsNullOrEmpty(xmgl.Files))
{
xmgl.Files += "," + fids;
}
else
{
xmgl.Files = fids;
}
}
#endregion
if (xmgl.ID == 0)
{
xmgl.UpdateDate = DateTime.Now;
xmgl.CRDate = DateTime.Now;
xmgl.CRUser = UserInfo.User.UserName;
xmgl.ComId = UserInfo.User.ComId;
xmgl.CRUserName = UserInfo.User.UserRealName;
new SZHL_XMGLB().Insert(xmgl);
string jsr = xmgl.XMFZR + (string.IsNullOrEmpty(xmgl.XMCYR) ? "" : "," + xmgl.XMCYR);
if (!string.IsNullOrEmpty(jsr))
{
SZHL_TXSX TX = new SZHL_TXSX();
TX.Date = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
TX.APIName = "XMGL";
TX.ComId = UserInfo.User.ComId;
TX.FunName = "XMGLMSG";
TX.TXMode = "XMGL";
TX.CRUserRealName = UserInfo.User.UserRealName;
TX.MsgID = xmgl.ID.ToString();
TX.TXContent = UserInfo.User.UserRealName + "发起了一个项目,等待您处理";
TX.TXUser = jsr;
TX.CRUser = UserInfo.User.UserName;
TXSX.TXSXAPI.AddALERT(TX); //时间为发送时间
}
}
else
{
xmgl.UpdateDate = DateTime.Now;
xmgl.UpdateUser = UserInfo.User.UserName;
xmgl.UpdateUserName = UserInfo.User.UserRealName;
new SZHL_XMGLB().Update(xmgl);
}
msg.Result = xmgl;
}
catch (Exception)
{
msg.ErrorMsg = "添加项目失败";
}
}
public void DELXMGL(HttpContext context, Msg_Result msg, string P1, string P2, JH_Auth_UserB.UserInfo UserInfo)
{
int Id = 0;
int.TryParse(P2, out Id);
new SZHL_XMGLB().Delete(D => D.ID == Id);
}
public void GETXMGLDATA(HttpContext context, Msg_Result msg, string P1, string P2, JH_Auth_UserB.UserInfo UserInfo)
{
string strWhere = " xm.ComId=" + UserInfo.User.ComId;
if (P1 != "")
{
strWhere += string.Format(" And xm.Status='{0}'", P1);
}
if (P2 != "")
{
switch (P2)
{
case "0":
strWhere += string.Format(" And (xm.CRUser='{0}' or ','+XMFZR+',' like '%,{0},%' or ','+XMCYR+',' like '%,{0},%' )", UserInfo.User.UserName);
break;
case "1":
strWhere += string.Format(" And xm.CRUser='{0}'", UserInfo.User.UserName);
break;
case "2":
strWhere += string.Format(" And (','+XMFZR+',' like '%," + UserInfo.User.UserName + ",%' )");
break;
case "3":
strWhere += string.Format(" And (','+XMCYR+',' like '%," + UserInfo.User.UserName + ",%' )");
break;
}
}
string lb = context.Request["lb"] ?? "";
if (lb != "")
{
strWhere += string.Format(" And YXJ='{0}'", lb);
}
string strContent = context.Request["Content"] ?? "";
strContent = strContent.TrimEnd();
if (strContent != "")
{
strWhere += string.Format(" And ( XMMC like '%{0}%' )", strContent);
}
//根据创建时间查询
string time = context.Request["time"] ?? "";
if (time != "")
{
if (time == "1") //近一周
{
strWhere += string.Format(" And datediff(day,xm.CRDate,getdate())<7");
}
else if (time == "2")
{ //近一月
strWhere += string.Format(" And datediff(day,xm.CRDate,getdate())<30");
}
else if (time == "4")
{ //今年
strWhere += string.Format(" And datediff(year,xm.CRDate,getdate())=0");
}
else if (time == "5")
{ //上一年
strWhere += string.Format(" And datediff(year,xm.CRDate,getdate())=1");
}
else if (time == "3") //自定义时间
{
string strTime = context.Request["starTime"] ?? "";
string endTime = context.Request["endTime"] ?? "";
if (strTime != "")
{
strWhere += string.Format(" And convert(varchar(10),xm.CRDate,120) >='{0}'", strTime);
}
if (endTime != "")
{
strWhere += string.Format(" And convert(varchar(10),xm.CRDate,120) <='{0}'", endTime);
}
}
}
int DataID = -1;
int.TryParse(context.Request["ID"] ?? "-1", out DataID);//记录Id
if (DataID != -1)
{
string strIsHasDataQX = new JH_Auth_QY_ModelB().ISHASDATAREADQX("CRM", DataID, UserInfo);
if (strIsHasDataQX == "Y")
{
strWhere += string.Format(" And xm.ID = '{0}'", DataID);
}
}
int page = 0;
int pagecount = 8;
int.TryParse(context.Request["p"] ?? "1", out page);
int.TryParse(context.Request["pagecount"] ?? "8", out pagecount);//页数
page = page == 0 ? 1 : page;
int total = 0;
DataTable dtList = new SZHL_XMGLB().GetDataPager("SZHL_XMGL xm left join JH_Auth_ZiDian zd on convert(varchar,YXJ)=convert(varchar,zd.ID)", "xm.* ,zd.TypeName", pagecount, page, " xm.CRDate desc,xm.Status ", strWhere, ref total);
dtList.Columns.Add("PLList", Type.GetType("System.Object"));
dtList.Columns.Add("FileList", Type.GetType("System.Object"));
for (int i = 0; i < dtList.Rows.Count; i++)
{
dtList.Rows[i]["PLList"] = new JH_Auth_TLB().GetTL("XMGL", dtList.Rows[i]["ID"].ToString());
if (dtList.Rows[i]["Files"].ToString() != "")
dtList.Rows[i]["FileList"] = new FT_FileB().GetEntities(" ID in (" + dtList.Rows[i]["Files"].ToString() + ")");
}
msg.Result = dtList;
msg.Result1 = total;
}
public void GETXMLIST(HttpContext context, Msg_Result msg, string P1, string P2, JH_Auth_UserB.UserInfo UserInfo)
{
string sql = string.Format("SELECT sx.ID,sx.XMMC FROM SZHL_XMGL sx WHERE sx.ComId={0}", UserInfo.User.ComId);
msg.Result = new SZHL_XMGLB().GetDTByCommand(sql);
}
#region 任务发送消息的接口
public void XMGLMSG(HttpContext context, Msg_Result msg, string P1, string P2, JH_Auth_UserB.UserInfo UserInfo)
{
SZHL_TXSX TX = JsonConvert.DeserializeObject<SZHL_TXSX>(P1);
int rwid = 0;
int.TryParse(TX.MsgID, out rwid);
SZHL_XMGL xm = new SZHL_XMGLB().GetEntity(d => d.ID == rwid);
Article ar0 = new Article();
ar0.Title = TX.TXContent;
ar0.Description = xm == null ? "" : xm.XMMC;
ar0.Url = TX.MsgID;
List<Article> al = new List<Article>();
al.Add(ar0);
if (!string.IsNullOrEmpty(TX.TXUser))
try
{
//发送PC消息
UserInfo = new JH_Auth_UserB().GetUserInfo(TX.ComId.Value, TX.CRUser);
new JH_Auth_User_CenterB().SendMsg(UserInfo, TX.TXMode, TX.TXContent, TX.MsgID, TX.TXUser, "B", 0, TX.ISCS);
}
catch (Exception)
{
}
//发送微信消息
WXHelp wx = new WXHelp(UserInfo.QYinfo);
wx.SendTH(al, TX.TXMode, "B", TX.TXUser);
}
#endregion
}
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
C#
1
https://gitee.com/springjava/QJ_Single.git
git@gitee.com:springjava/QJ_Single.git
springjava
QJ_Single
QJ_Single
master

搜索帮助