You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

1322 lines
48 KiB
Plaintext

This file contains ambiguous Unicode characters!

This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.

using BP.DA;
using BP.En;
using BP.Sys;
using BP.Web;
using BP.WF;
using BP.WF.Template;
using System;
using System.Collections;
using System.Data;
using System.Net.Http;
using System.Web.Http;
using System.Web.Http.Cors;
namespace CCFlow.DataUser.API.Controllers
{
[EnableCors("*", "*", "*")]
public class APIController : ApiController
{
#region 组织结构接口.
/// <summary>
/// 系统登陆
/// </summary>
/// <param name="privateKey">密钥</param>
/// <param name="userNo">登陆账号</param>
/// <param name="orgNo">组织编号</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Port_Login(string privateKey, string userNo, string orgNo=null)
{
OperateResult result = null;
try
{
if (DataType.IsNullOrEmpty(userNo) == true)
return ReturnMessage("err@账号不能为空");
string localKey = BP.Difference.SystemConfig.GetValByKey("PrivateKey", "");
if (DataType.IsNullOrEmpty(localKey) == true)
localKey = "DiGuaDiGua,IamCCBPM";
if (localKey.Equals(privateKey) == false)
return ReturnMessage("err@私约错误,请检查全局文件中配置 PrivateKey");
//执行本地登录.
BP.WF.Dev2Interface.Port_Login(userNo, orgNo);
string token = BP.WF.Dev2Interface.Port_GenerToken();
Hashtable ht = new Hashtable();
ht.Add("No", WebUser.No);
ht.Add("Name", WebUser.Name);
ht.Add("FK_Dept", WebUser.FK_Dept);
ht.Add("FK_DeptName", WebUser.FK_DeptName);
ht.Add("OrgNo", WebUser.OrgNo);
ht.Add("OrgName", WebUser.OrgName);
ht.Add("Token", token);
return ReturnMessage(BP.Tools.Json.ToJson(ht));
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 退出登录
/// </summary>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Port_LoginOut()
{
try
{
BP.WF.Dev2Interface.Port_SigOut();
return ReturnMessage("退出成功");
}
catch (Exception ex)
{
return ReturnMessage("err@" + ex.Message);
}
}
#endregion 组织结构接口.
#region 组织人员岗位维护
/// <summary>
/// 人员信息保存
/// </summary>
/// <param name="token"></param>
/// <param name="orgNo"></param>
/// <param name="userNo"></param>
/// <param name="userName"></param>
/// <param name="deptNo"></param>
/// <param name="kvs"></param>
/// <param name="stats"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Port_Emp_Save(string token, string orgNo, string userNo, string userName, string deptNo, string kvs, string stats)
{
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (WebUser.IsAdmin == false)
return ReturnMessage("err@[" + BP.Web.WebUser.Name + "]不是管理员不能维护人员信息");
string msg = BP.Port.OrganizationAPI.Port_Emp_Save(orgNo, userNo, userName, deptNo, kvs, stats);
return ReturnMessage(msg);
}
/// <summary>
/// 人员删除
/// </summary>
/// <param name="token">Token</param>
/// <param name="orgNo">组织编号</param>
/// <param name="userNo">人员编号</param>
/// <returns>reutrn 1=成功, 其他的标识异常.</returns>
[HttpGet, HttpPost]
public HttpResponseMessage Port_Emp_Delete(string token, string userNo, string orgNo ="" )
{
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (WebUser.IsAdmin == false)
return ReturnMessage("err@[" + BP.Web.WebUser.Name + "]不是管理员不能删除人员信息");
return ReturnMessage(BP.Port.OrganizationAPI.Port_Emp_Delete(orgNo, userNo));
}
/// <returns>return 1 增加成功,其他的增加失败.</returns>
/// <summary>
/// 集团模式下同步组织以及管理员信息
/// </summary>
/// <param name="token">Token</param>
/// <param name="orgNo">组织编号</param>
/// <param name="name">组织名称</param>
/// <param name="adminer">管理员账号</param>
/// <param name="adminerName">管理员名字</param>
/// <param name="keyVals">其他的值:@Leaer=zhangsan@Tel=12233333@Idx=1</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Port_Org_Save(string token, string orgNo, string name, string adminer,string adminerName, string keyVals="")
{
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (WebUser.IsAdmin == false)
return ReturnMessage("err@[" + BP.Web.WebUser.Name + "]不是管理员不能维护组织信息");
return ReturnMessage(BP.Port.OrganizationAPI.Port_Org_Save(orgNo, name, adminer, adminerName,keyVals));
}
/// <summary>
/// 保存部门,如果有此数据则修改,无此数据则增加.
/// </summary>
/// <param name="token">Token</param>
/// <param name="no">部门编号</param>
/// <param name="name">名称</param>
/// <param name="parentNo">父节点编号</param>
/// <param name="orgNo">组织编号</param>
/// <param name="keyVals">其他的值:@Leaer=zhangsan@Tel=18660153393@Idx=1</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Port_Dept_Save(string token, string no, string name, string parentNo, string orgNo="", string keyVals="")
{
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (WebUser.IsAdmin == false)
return ReturnMessage("err@[" + BP.Web.WebUser.Name + "]不是管理员不能维护部门信息");
return ReturnMessage(BP.Port.OrganizationAPI.Port_Dept_Save(orgNo, no, name, parentNo, keyVals));
}
/// <summary>
/// 删除部门
/// </summary>
/// <param name="token">Token</param>
/// <param name="no">要删除的部门编号</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Port_Dept_Delete(string token, string no)
{
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (WebUser.IsAdmin == false)
return ReturnMessage("err@[" + BP.Web.WebUser.Name + "]不是管理员不能删除部门信息");
return ReturnMessage(BP.Port.OrganizationAPI.Port_Dept_Delete(no));
}
/// <summary>
/// 保存岗位, 如果有此数据则修改,无此数据则增加.
/// </summary>
/// <param name="token">Token</param>
/// <param name="orgNo">组织编号</param>
/// <param name="no">岗位编号</param>
/// <param name="name">岗位名称</param>
/// <param name="keyVals">其他值</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Port_Station_Save(string token, string orgNo, string no, string name, string keyVals)
{
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (WebUser.IsAdmin == false)
return ReturnMessage("err@[" + BP.Web.WebUser.Name + "]不是管理员不能维护岗位信息");
return ReturnMessage(BP.Port.OrganizationAPI.Port_Station_Save(orgNo, no, name, keyVals));
}
/// <summary>
/// 删除岗位.
/// </summary>
/// <param name="no">删除指定的岗位编号</param>
/// <returns></returns>
[HttpGet,HttpPost]
public HttpResponseMessage Port_Station_Delete(string token, string no)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (WebUser.IsAdmin == false)
return ReturnMessage("err@[" + BP.Web.WebUser.Name + "]不是管理员不能删除岗位信息");
return ReturnMessage(BP.Port.OrganizationAPI.Port_Station_Delete(no));
}
#endregion 组织人员岗位维护
#region 菜单接口.
/// <summary>
/// 可以发起的流程
/// </summary>
/// <param name="token"></param>
/// <param name="domain">流程所属的域</param>
/// <returns></returns>
[HttpGet,HttpPost]
public HttpResponseMessage DB_Start(string token,string domain)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
//获取可以发起的列表
DataTable dt = BP.WF.Dev2Interface.DB_StarFlows(BP.Web.WebUser.No, domain);
return ReturnMessage(BP.Tools.Json.ToJson(dt));
}
/// <summary>
/// 待办
/// </summary>
/// <param name="token"></param>
/// <param name="domain"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage DB_Todolist(string token, string domain)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
//获取可以发起的列表
DataTable dt = BP.WF.Dev2Interface.DB_GenerEmpWorksOfDataTable(BP.Web.WebUser.No, 0, null, domain, null, null);
return ReturnMessage(BP.Tools.Json.ToJson(dt));
}
/// <summary>
/// 在途
/// </summary>
/// <param name="token"></param>
/// <param name="domain"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage DB_Runing(string token, string domain)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
//获取可以发起的列表
DataTable dt = BP.WF.Dev2Interface.DB_GenerRuning(BP.Web.WebUser.No, false, domain); ;
return ReturnMessage(BP.Tools.Json.ToJson(dt));
}
/// <summary>
/// 草稿
/// </summary>
/// <param name="token"></param>
/// <param name="domain"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage DB_Draft(string token, string domain)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
//获取可以发起的列表
DataTable dt = BP.WF.Dev2Interface.DB_GenerDraftDataTable(null, domain);
return ReturnMessage(BP.Tools.Json.ToJson(dt));
}
/// <summary>
/// 打开的表单
/// </summary>
/// <param name="token"></param>
/// <param name="workID">工作实例WorkID</param>
/// <param name="flowNo">流程编号</param>
/// <param name="nodeID">节点ID</param>
/// <param name="fid">父WorkID</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage GenerFrmUrl(string token, Int64 workID,string flowNo,int nodeID,Int64 fid)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
/*
* 发起的url需要在该流程的开始节点的表单方案中使用SDK表单并把表单的url设置到里面去.
* 设置步骤:
* 1. 打开流程设计器.
* 2. 在开始节点上右键,选择表单方案.
* 3. 选择SDK表单把url配置到文本框里去.
* 比如: /App/F027QingJia.htm
*/
if (nodeID == 0)
nodeID = int.Parse(flowNo + "01");
if (workID == 0)
workID = BP.WF.Dev2Interface.Node_CreateBlankWork(flowNo, BP.Web.WebUser.No);
string url = "";
Node nd = new Node(nodeID);
if (nd.FormType == NodeFormType.SDKForm || nd.FormType == NodeFormType.SelfForm)
{
//.
url = nd.FormUrl;
if (url.Contains("?") == true)
url += "&FK_Flow=" + flowNo + "&FK_Node=" + nodeID + "&WorkID=" + workID + "&Token=" + token + "&UserNo=" + BP.Web.WebUser.No;
else
url += "?FK_Flow=" + flowNo + "&FK_Node=" + nodeID + "&WorkID=" + workID + "&Token=" + token + "&UserNo=" + BP.Web.WebUser.No;
}
else
{
url = "/WF/MyFlow.htm?FK_Flow=" + flowNo + "&FK_Node=" + nodeID + "&WorkID=" + workID + "&Token=" + token;
}
return ReturnMessage(url);
}
#endregion 菜单接口.
#region 节点方法.
/// <summary>
/// 创建WorkID
/// </summary>
/// <param name="token"></param>
/// <param name="flowNo">流程编号</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Node_CreateBlankWorkID(string token, string flowNo)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
Int64 workid = Dev2Interface.Node_CreateBlankWork(flowNo, BP.Web.WebUser.No);
return ReturnMessage(workid.ToString());
}catch(Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 是否可以处理当前的工作
/// </summary>
/// <param name="token"></param>
/// <param name="workID"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Node_IsCanDealWork(string token, Int64 workID)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
GenerWorkFlow gwf = new GenerWorkFlow(workID);
string todoEmps = gwf.TodoEmps;
bool isCanDo = false;
if (gwf.FK_Node.ToString().EndsWith("01") == true)
{
if (gwf.Starter.Equals(BP.Web.WebUser.No) == false)
isCanDo = false; //处理开始节点发送后撤销的情况第2个节点打开了第1个节点撤销了,造成第2个节点也可以发送下去.
else
isCanDo = true; // 开始节点不判断权限.
}
else
{
isCanDo = todoEmps.Contains(";" + WebUser.No + ",");
if (isCanDo == false)
isCanDo = Dev2Interface.Flow_IsCanDoCurrentWork(workID, BP.Web.WebUser.No);
}
return ReturnMessage(isCanDo == true ? "1" : "0");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 设置草稿
/// </summary>
/// <param name="token">密钥</param>
/// <param name="workID">流程实例ID</param>
/// <param name="flowNo"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Node_SetDraft(string token, Int64 workID, string flowNo)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
BP.WF.Dev2Interface.Node_SetDraft(flowNo, workID);
return ReturnMessage("设置草稿成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
[HttpGet, HttpPost]
public HttpResponseMessage Node_HuiQian_Delete(string token, Int64 workid, string empNo)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
BP.WF.Dev2Interface.Node_HuiQian_Delete(workid, empNo);
return ReturnMessage("1");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 把当前工作移交给指定的人员
/// </summary>
/// <param name="token"></param>
/// <param name="workID"></param>
/// <param name="toEmpNo"></param>
/// <param name="msg"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Node_Shift(string token, Int64 workID, string toEmpNo,string msg)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
msg = BP.WF.Dev2Interface.Node_Shift(workID, toEmpNo, msg);
return ReturnMessage(msg);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 给当前的工作增加处理人
/// </summary>
/// <param name="token"></param>
/// <param name="workID"></param>
/// <param name="empNo"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Node_AddTodolist(string token, Int64 workID, string empNo)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
BP.WF.Dev2Interface.Node_AddTodolist(workID, empNo);
return ReturnMessage("增加人员成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 根据ID获取当前的流程实例信息
/// </summary>
/// <param name="token"></param>
/// <param name="workID"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_GenerWorkFlow(string token, Int64 workID)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
GenerWorkFlow gwf = new GenerWorkFlow(workID);
return ReturnMessage(gwf.ToJson());
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 保存参数到WF_GenerWorkFlow,用于方向条件的判断
/// </summary>
/// <param name="token"></param>
/// <param name="workID"></param>
/// <param name="paras"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Node_SaveParas(string token, Int64 workID, string paras)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
BP.WF.Dev2Interface.Flow_SaveParas(workID, paras);
return ReturnMessage("参数保存成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 设置标题
/// </summary>
/// <param name="token"></param>
/// <param name="workID"></param>
/// <param name="title"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_SetTitle(string token,Int64 workID, string title)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
BP.WF.Dev2Interface.Flow_SetFlowTitle(null, workID, title);
return ReturnMessage("标题设置成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 发送接口
/// </summary>
/// <param name="token"></param>
/// <param name="flowNo">流程编号</param>
/// <param name="workID">工作实例WorkID</param>
/// <param name="toNodeID">到达的下一个节点</param>
/// <param name="toEmps">下一个节点的接收人</param>
/// <param name="paras">参数保存到WF_GenerWorkFlow</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Node_SendWork(string token, Int64 workID, string flowNo="", int toNodeID=0,string toEmps="",string paras="")
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if(DataType.IsNullOrEmpty(paras)==false)
BP.WF.Dev2Interface.Flow_SaveParas(workID, paras);
//执行发送.
Hashtable ht = new Hashtable();
ht.Add("FK_Flow", flowNo);
ht.Add("WorkID", workID);
try
{
if (DataType.IsNullOrEmpty(flowNo) == true)
flowNo = DBAccess.RunSQLReturnString("SELECT FK_Flow FROM WF_GenerWorkFlow WHERE WorkID=" + workID);
//执行发送.
SendReturnObjs objs = Dev2Interface.Node_SendWork(flowNo, workID, ht, null, toNodeID, toEmps);
string msg = objs.ToMsgOfText();
return ReturnMessage(msg);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 根据流程编号获取流程实例
/// </summary>
/// <param name="token"></param>
/// <param name="flowNo"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage DB_GenerWorkFlow(string token, string flowNo)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
GenerWorkFlows gwfs = new GenerWorkFlows();
QueryObject qo = new QueryObject(gwfs);
qo.AddWhere("FK_Flow", flowNo);
qo.addAnd();
qo.AddWhere("WFState", ">", 1);
qo.addOrderBy("RDT");
qo.DoQuery();
return ReturnMessage(gwfs.ToJson());
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 获取当前节点可以退回到的节点集合
/// </summary>
/// <param name="token"></param>
/// <param name="nodeID">节点ID</param>
/// <param name="workID">工作实例WorkID</param>
/// <param name="fid">父WorkID</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage DB_GenerWillReturnNodes(string token, int nodeID,Int64 workID,Int64 fid)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
DataTable dt = Dev2Interface.DB_GenerWillReturnNodes(nodeID, workID, fid);
return ReturnMessage(BP.Tools.Json.ToJson(dt));
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 当前节点执行退回操作
/// </summary>
/// <param name="token"></param>
/// <param name="workID">工作实例WorkID</param>
/// <param name="nodeID">当前节点ID</param>
/// <param name="returnToNodeID">退回到的节点</param>
/// <param name="returnToEmp">退回到的接收人</param>
/// <param name="msg">退回原因</param>
/// <param name="isBackToThisNode">是否原路返回到当前节点</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Node_ReturnWork(string token, Int64 workID, int nodeID,int returnToNodeID,string returnToEmp,string msg,bool isBackToThisNode)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
if (returnToNodeID == 0)
{
DataTable dt = BP.WF.Dev2Interface.DB_GenerWillReturnNodes(nodeID, workID, 0);
if (dt.Rows.Count == 1)
{
returnToNodeID = Int32.Parse(dt.Rows[0]["No"].ToString());
returnToEmp = dt.Rows[0]["Rec"].ToString();
}
}
//执行退回.
string strs = Dev2Interface.Node_ReturnWork(workID,
returnToNodeID, returnToEmp, msg, isBackToThisNode);
return ReturnMessage(strs);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 催办
/// </summary>
/// <param name="token"></param>
/// <param name="workIDs">工作实例的WorkID集合</param>
/// <param name="msg">催办信息</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_DoPress(string token, string workIDs,string msg)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (DataType.IsNullOrEmpty(workIDs))
{
return ReturnMessage("err@执行批量催办的WorkIDs不能为空");
}
string[] strs = workIDs.Split(',');
if (msg == null)
msg = "需要您处理待办工作.";
try
{
string info = "";
foreach (string workidStr in strs)
{
if (BP.DA.DataType.IsNullOrEmpty(workidStr) == true)
continue;
info += "@" + BP.WF.Dev2Interface.Flow_DoPress(int.Parse(workidStr), msg, true);
}
return ReturnMessage(info);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 批量审核
/// </summary>
/// <param name="token"></param>
/// <param name="workIDs"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage CC_BatchCheckOver(string token, string workIDs)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (DataType.IsNullOrEmpty(workIDs))
{
return ReturnMessage("err@执行批量审批的WorkIDs不能为空");
}
try
{
string str = BP.WF.Dev2Interface.Node_CC_SetCheckOverBatch(workIDs);
return ReturnMessage(str);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
#endregion 节点方法.
#region 流程方法.
/// <summary>
/// 批量删除流程
/// </summary>
/// <param name="token"></param>
/// <param name="workIDs"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_BatchDeleteByFlag(string token, string workIDs)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (DataType.IsNullOrEmpty(workIDs))
{
return ReturnMessage("err@批量删除的WorkIDs不能为空");
}
try
{
string[] strs = workIDs.Split(',');
foreach (string workidStr in strs)
{
if (BP.DA.DataType.IsNullOrEmpty(workidStr) == true)
continue;
string st1r = BP.WF.Dev2Interface.Flow_DoDeleteFlowByFlag(Int64.Parse(workidStr), "删除", true);
}
return ReturnMessage("删除成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 批量删除
/// </summary>
/// <param name="token"></param>
/// <param name="workIDs">工作实例WorkIDs</param>
/// <param name="isDeleteSubFlows">是否删除子流程</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_BatchDeleteByReal(string token, string workIDs, bool isDeleteSubFlows)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (DataType.IsNullOrEmpty(workIDs))
{
return ReturnMessage("err@批量删除的WorkIDs不能为空");
}
try
{
string[] strs = workIDs.Split(',');
foreach (string workidStr in strs)
{
if (BP.DA.DataType.IsNullOrEmpty(workidStr) == true)
continue;
string st1r = BP.WF.Dev2Interface.Flow_DoDeleteFlowByReal(Int64.Parse(workidStr), isDeleteSubFlows);
}
return ReturnMessage("删除成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 批量恢复逻辑删除的流程
/// </summary>
/// <param name="token"></param>
/// <param name="workIDs"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_BatchDeleteByFlagAndUnDone(string token, string workIDs)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
if (DataType.IsNullOrEmpty(workIDs))
{
return ReturnMessage("err@批量撤销删除的WorkIDs不能为空");
}
try
{
string[] strs = workIDs.Split(',');
foreach (string workidStr in strs)
{
if (BP.DA.DataType.IsNullOrEmpty(workidStr) == true)
continue;
string st1r = BP.WF.Dev2Interface.Flow_DoUnDeleteFlowByFlag(null, int.Parse(workidStr), "删除");
}
return ReturnMessage("撤销删除成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 批量撤回
/// </summary>
/// <param name="token"></param>
/// <param name="workids"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_DoUnSend(string token, string workIDs)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
//获取可以发起的列表
string[] strs = workIDs.Split(',');
if (DataType.IsNullOrEmpty(workIDs))
{
return ReturnMessage("err@批量撤回的WorkIDs不能为空");
}
try
{
string info = "";
foreach (string workidStr in strs)
{
if (BP.DA.DataType.IsNullOrEmpty(workidStr) == true)
continue;
info += BP.WF.Dev2Interface.Flow_DoUnSend(null, Int64.Parse(workidStr), 0, 0);
}
return ReturnMessage(info);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 批量删除草稿
/// </summary>
/// <param name="token"></param>
/// <param name="workids"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_DeleteDraft(string token, string workIDs)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
string[] strs = workIDs.Split(',');
if (DataType.IsNullOrEmpty(workIDs))
{
return ReturnMessage("err@批量删除草稿的WorkIDs不能为空");
}
try
{
foreach (string workidStr in strs)
{
if (BP.DA.DataType.IsNullOrEmpty(workidStr) == true)
continue;
BP.WF.Dev2Interface.Node_DeleteDraft(Int64.Parse(workidStr));
}
return ReturnMessage("删除成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 批量结束流程
/// </summary>
/// <param name="token"></param>
/// <param name="workids"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Flow_DoFlowOver(string token, string workIDs)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
string[] strs = workIDs.Split(',');
if (DataType.IsNullOrEmpty(workIDs))
{
return ReturnMessage("err@批量结束流程的WorkIDs不能为空");
}
try
{
foreach (string workidStr in strs)
{
if (BP.DA.DataType.IsNullOrEmpty(workidStr) == true)
continue;
BP.WF.Dev2Interface.Flow_DoFlowOver(Int64.Parse(workidStr), "批量结束", 1);
}
return ReturnMessage("执行成功");
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
#endregion 节点方法.
#region 批处理相关
/// <summary>
/// 批量处理
/// </summary>
/// <param name="token"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Batch_Init(string token)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
var handle = new BP.WF.HttpHandler.WF();
string str = handle.Batch_Init();
return ReturnMessage(str);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 根据NodeID获取节点信息
/// </summary>
/// <param name="token"></param>
/// <param name="nodeID"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage En_Node(string token,int nodeID)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
Node node = new Node(nodeID);
return ReturnMessage(node.ToJson());
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 根据流程编号获取流程信息
/// </summary>
/// <param name="token"></param>
/// <param name="flowNo"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage En_Flow(string token, string flowNo)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
Flow flow = new Flow(flowNo);
return ReturnMessage(flow.ToJson());
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
/// <summary>
/// 根据流程编号获取流程信息
/// </summary>
/// <param name="token"></param>
/// <param name="nodeID"></param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage WorkCheckModel_Init(string token, int nodeID)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
DataSet ds = new DataSet();
//获取节点信息
BP.WF.Node nd = new BP.WF.Node(nodeID);
Flow fl = nd.HisFlow;
ds.Tables.Add(nd.ToDataTableField("WF_Node"));
string sql = "";
if (nd.IsSubThread == true)
{
sql = "SELECT a.*, b.Starter,b.StarterName,b.ADT,b.WorkID FROM " + fl.PTable
+ " a , WF_EmpWorks b WHERE a.OID=B.FID AND b.WFState Not IN (7) AND b.FK_Node=" + nd.NodeID
+ " AND b.FK_Emp='" + WebUser.No + "'";
}
else
{
sql = "SELECT a.*, b.Starter,b.StarterName,b.ADT,b.WorkID FROM " + fl.PTable
+ " a , WF_EmpWorks b WHERE a.OID=B.WorkID AND b.WFState Not IN (7) AND b.FK_Node=" + nd.NodeID
+ " AND b.FK_Emp='" + WebUser.No + "'";
}
//获取待审批的流程信息集合
DataTable dt = DBAccess.RunSQLReturnTable(sql);
dt.TableName = "Works";
ds.Tables.Add(dt);
//获取按钮权限
BtnLab btnLab = new BtnLab(nodeID);
ds.Tables.Add(btnLab.ToDataTableField("Sys_BtnLab"));
//获取字段属性
MapAttrs attrs = new MapAttrs("ND" + nodeID);
//获取实际中需要展示的列.
string batchParas = nd.GetParaString("BatchFields");
MapAttrs realAttr = new MapAttrs();
if (DataType.IsNullOrEmpty(batchParas) == false)
{
string[] strs = batchParas.Split(',');
foreach (string str in strs)
{
if (string.IsNullOrEmpty(str)
|| str.Contains("@PFlowNo") == true)
continue;
foreach (MapAttr attr in attrs)
{
if (str != attr.KeyOfEn)
continue;
realAttr.AddEntity(attr);
}
}
}
ds.Tables.Add(realAttr.ToDataTableField("Sys_MapAttr"));
return ReturnMessage(BP.Tools.Json.ToJson(ds));
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
[HttpGet, HttpPost]
public HttpResponseMessage Batch_InitDDL(string token, int nodeID)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
GenerWorkFlow gwf = new GenerWorkFlow();
Node nd = new Node(nodeID);
gwf.TodoEmps = WebUser.No + ",";
DataTable mydt = BP.WF.Dev2Interface.Node_GenerDTOfToNodes(gwf, nd);
return ReturnMessage(BP.Tools.Json.ToJson(mydt));
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
[HttpGet, HttpPost]
public HttpResponseMessage WorkCheckModel_Send(string token, string flowNo)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
var handle = new BP.WF.HttpHandler.WF_WorkOpt_Batch();
string str = handle.WorkCheckModel_Send();
return ReturnMessage(str);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
[HttpGet, HttpPost]
public HttpResponseMessage Batch_Delete(string token, string workIDs)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
if (DataType.IsNullOrEmpty(workIDs) == true)
return ReturnMessage("err@没有选择需要处理的工作");
string msg = "";
GenerWorkFlows gwfs = new GenerWorkFlows();
gwfs.RetrieveIn("WorkID", workIDs);
foreach (GenerWorkFlow gwf in gwfs)
{
msg += "@对工作(" + gwf.Title + ")处理情况如下。<br>";
string mes = BP.WF.Dev2Interface.Flow_DoDeleteFlowByFlag(gwf.WorkID, "批量删除", true);
msg += mes;
msg += "<hr>";
}
return ReturnMessage("批量删除成功" + msg);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
#endregion 批处理相关
#region 其他方法.
/// <summary>
/// 查询
/// </summary>
/// <param name="key">关键字</param>
/// <param name="dtFrom">日期从</param>
/// <param name="dtTo">日期到</param>
/// <param name="scop">范围</param>
/// <param name="pageIdx">分页</param>
/// <returns></returns>
[HttpGet, HttpPost]
public HttpResponseMessage Search_Init(string token,string key,string dtFrom,string dtTo,string scop,int pageIdx)
{
//根据token登录
HttpResponseMessage result = Port_GenerToken(token);
if (result != null)
return result;
try
{
GenerWorkFlows gwfs = new GenerWorkFlows();
//创建查询对象.
QueryObject qo = new QueryObject(gwfs);
if (DataType.IsNullOrEmpty(key) == false)
{
qo.AddWhere(GenerWorkFlowAttr.Title, " LIKE ", "%" + key + "%");
qo.addAnd();
}
//我参与的.
if (scop.Equals("0") == true)
qo.AddWhere(GenerWorkFlowAttr.Emps, "LIKE", "%@" + WebUser.No + ",%");
//我发起的.
if (scop.Equals("1") == true)
qo.AddWhere(GenerWorkFlowAttr.Starter, "=", WebUser.No);
//我部门发起的.
if (scop.Equals("2") == true)
qo.AddWhere(GenerWorkFlowAttr.FK_Dept, "=", WebUser.FK_Dept);
//任何一个为空.
if (DataType.IsNullOrEmpty(dtFrom) == true || DataType.IsNullOrEmpty(dtTo) == true)
{
}
else
{
qo.addAnd();
qo.AddWhere(GenerWorkFlowAttr.RDT, ">=", dtFrom);
qo.addAnd();
qo.AddWhere(GenerWorkFlowAttr.RDT, "<=", dtTo);
}
var count = qo.GetCount(); //获得总数.
qo.DoQuery("WorkID", 20, pageIdx);
// qo.DoQuery(); // "WorkID", 20, pageIdx);
DataTable dt = gwfs.ToDataTableField("gwls");
//创建容器.
DataSet ds = new DataSet();
ds.Tables.Add(dt); //增加查询对象.
//增加数量.
DataTable mydt = new DataTable();
mydt.TableName = "count";
mydt.Columns.Add("CC");
DataRow dr = mydt.NewRow();
dr[0] = count.ToString(); //把数量加进去.
mydt.Rows.Add(dr);
ds.Tables.Add(mydt);
return ReturnMessage(BP.Tools.Json.ToJson(ds));
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
}
private HttpResponseMessage Port_GenerToken(string token)
{
//根据token登录
try
{
BP.WF.Dev2Interface.Port_LoginByToken(token);
}
catch (Exception ex)
{
return ReturnMessage(ex.Message);
}
return null;
}
private HttpResponseMessage ReturnMessage(string message)
{
return new HttpResponseMessage { Content = new StringContent(message, System.Text.Encoding.GetEncoding("UTF-8"), "application/json") };
}
#endregion 其他方法.
}
}