package cn.ksource.web.service.workFlowSupport;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.beans.GG_MESSAGE;
|
import cn.ksource.beans.WORKFLOW_BASE;
|
import cn.ksource.beans.WORKFLOW_NODE;
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.DateUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.core.web.SysInfoMsg;
|
import cn.ksource.core.web.WebUtil;
|
import cn.ksource.core.workflow.NodeAnswerEntity;
|
import cn.ksource.core.workflow.NodeDealEntity;
|
import cn.ksource.core.workflow.NodeFinishEntity;
|
import cn.ksource.core.workflow.WorkflowBusinessService;
|
import cn.ksource.core.workflow.WorkflowCoreService;
|
import cn.ksource.web.Constants;
|
import cn.ksource.web.controller.wechat.util.WechatConstants;
|
import cn.ksource.web.entity.WorkFlowSupportEntity;
|
import cn.ksource.web.facade.message.MessageFacade;
|
@SuppressWarnings("unchecked")
|
@Service
|
public class WorkFlowSupportServiceImpl implements WorkFlowSupportService{
|
|
@Resource
|
private WorkflowBusinessService workflowBusinessService;
|
@Resource
|
private WorkflowCoreService workflowCoreService;
|
@Resource
|
private BaseDao baseDao;
|
@Autowired
|
private MessageFacade messageFacade;
|
|
@Override
|
public SysInfoMsg doOrderFlow(WorkFlowSupportEntity support) {
|
boolean nodeAdmin = true;
|
SysInfoMsg msg = new SysInfoMsg();
|
WORKFLOW_BASE base = new WORKFLOW_BASE();
|
if(StringUtil.isBlank(support.getNodeId())){//若流程未启动,则启动流程
|
if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND)){
|
base = workflowBusinessService.startCIRemindWorkflow(support.getOrderId());
|
}else if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH)){
|
base = workflowBusinessService.startCIHealthWorkflow(support.getOrderId());
|
}else if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_RELEASE)){
|
base = workflowBusinessService.startReleaseWorkflow(support.getOrderId(),support.getNote());
|
}else if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_STOCK)){
|
base = workflowBusinessService.startStockWorkflow(support.getOrderId(),support.getNote());
|
}else if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_SPARE)){
|
base = workflowBusinessService.startSpareWorkflow(support.getOrderId(),support.getNote());
|
}else if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CKLC)){
|
base = workflowBusinessService.startDeliveryWorkflow(support.getOrderId(),support.getNote());
|
}else if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_KCPD)){//库存盘点
|
base = workflowBusinessService.startInventoryWorkflow(support.getOrderId(),support.getNote());
|
}else if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_BSBY)){//报损报溢
|
base = workflowBusinessService.startOverageLossWorkflow(support.getOrderId(),support.getNote());
|
}
|
}else{//若流程已启动,则结束当前环节
|
base = new WORKFLOW_BASE(support.getFlowId()).getInstanceById();
|
NodeFinishEntity finishEntity = new NodeFinishEntity();
|
finishEntity.setDeal_result(1);
|
finishEntity.setDeal_note_title(support.getUserName()+"完成了节点");
|
finishEntity.setDeal_note(support.getNote());
|
WORKFLOW_NODE node = new WORKFLOW_NODE(support.getNodeId()).getInstanceById();
|
workflowCoreService.finishNode(base, node, finishEntity);
|
}
|
|
if(support.isFlowEndflag()){//结束环节
|
workflowCoreService.finishWorkFlow(base);
|
return msg;
|
}else{//非结束环节
|
if(StringUtil.isNotBlank(support.getNextNodeTemplateId())){//下一节点不为空
|
NodeDealEntity entity = new NodeDealEntity();
|
if(support.getDealer_type()!=null&&support.getDealer_type().equals("1")){//发送到组
|
entity.setDealer_type(1);
|
entity.setRoleID(support.getRoleId());
|
entity.setRoleName(support.getRoleName());
|
}else{//发送到人
|
//若下环节执行人为空,从配置文件读取执行人列表
|
if(support.getNextUserList()==null||support.getNextUserList().size()==0){
|
if(!support.isEverDealflag()){
|
support.setNextUserList(getNodeExecutor(support.getNextNodeTemplateId()));
|
}else{
|
//根据环节模板id 获取曾经处理人
|
support.setNextUserList(getEverNodeExecutor(support.getFlowId(),support.getEverNodeTemplateId()));
|
}
|
}
|
entity.setDealer_type(2);
|
entity.setDealerList(support.getNextUserList());
|
}
|
|
if(StringUtil.isNotBlank(support.getNodeId())){
|
WORKFLOW_NODE node = new WORKFLOW_NODE(support.getNodeId()).getInstanceById();
|
Integer is_admin = node.getIs_admin();
|
if(is_admin!=null&&is_admin==1){
|
workflowCoreService.toNode(base, support.getNextNodeTemplateId(), entity);
|
}else{
|
nodeAdmin = false;
|
}
|
}else{
|
workflowCoreService.toNode(base, support.getNextNodeTemplateId(), entity);
|
}
|
//发送消息
|
sendMessage(base,support);
|
}
|
}
|
|
//提醒信息
|
if(StringUtil.isNotBlank(support.getNextNodeTemplateId())){
|
//设置环节名称
|
msg.setNodeName(base.getCurrent_node_name());
|
String dealers = "";
|
if(nodeAdmin){
|
if(support.getDealer_type()!=null&&support.getDealer_type().equals("1")){
|
msg.setDealUserType("1");
|
msg.setDealUserName(support.getRoleName());
|
}else{
|
for(Map map:support.getNextUserList()){
|
if(dealers.equals("")){
|
dealers = dealers + map.get("USER_NAME").toString();
|
}else{
|
dealers = dealers + " , " + map.get("USER_NAME").toString();
|
}
|
if(map.get("IS_ADMIN")!=null&&map.get("IS_ADMIN").toString().equals("1")){
|
dealers = dealers + "(主负责人)";
|
}
|
}
|
msg.setDealUserType("2");
|
msg.setDealUserName(dealers);
|
}
|
}else{
|
//发多人环节 非主负责人提交
|
String text = "任务已完成，请等待主负责人【" + base.getCurrent_dealer_name() + "】提交工单";
|
msg.setText(text);
|
}
|
|
}
|
return msg;
|
}
|
|
@Override
|
public SysInfoMsg doOrderSendback(WorkFlowSupportEntity support) {
|
SysInfoMsg msg = new SysInfoMsg();
|
//关闭当前节点
|
WORKFLOW_BASE base = new WORKFLOW_BASE(support.getFlowId()).getInstanceById();
|
NodeFinishEntity finishEntity = new NodeFinishEntity();
|
finishEntity.setDeal_result(3);
|
finishEntity.setDeal_note_title(support.getUserName()+"回退了节点");
|
finishEntity.setDeal_note(support.getNote());
|
WORKFLOW_NODE node = new WORKFLOW_NODE(support.getNodeId()).getInstanceById();
|
workflowCoreService.finishNode(base, node, finishEntity);
|
|
|
//回退到上一节点
|
NodeDealEntity entity = new NodeDealEntity();
|
List<Map> nextUserList = getEverNodeExecutor(support.getFlowId(),support.getEverNodeTemplateId());
|
support.setNextUserList(nextUserList);
|
entity.setBefore_Dealer_type(2);
|
entity.setDealer_type(2);
|
entity.setDealerList(nextUserList);
|
entity.setFlow_type(2);
|
entity.setSource_node_instance_id(node.getId());
|
workflowCoreService.toNode(base, support.getEverNodeTemplateId(), entity);
|
|
//发送消息
|
msg.setNodeName(base.getCurrent_node_name());
|
String dealers = "";
|
for(Map map:support.getNextUserList()){
|
if(dealers.equals("")){
|
dealers = dealers + map.get("USER_NAME").toString();
|
}else{
|
dealers = dealers + " , " + map.get("USER_NAME").toString();
|
}
|
if(map.get("IS_ADMIN")!=null&&map.get("IS_ADMIN").toString().equals("1")){
|
dealers = dealers + "(主负责人)";
|
}
|
}
|
msg.setDealUserType("2");
|
msg.setDealUserName(dealers);
|
sendMessage(base,support);
|
return msg;
|
|
}
|
|
|
public void sendMessage(WORKFLOW_BASE base,WorkFlowSupportEntity support){
|
//发送消息
|
GG_MESSAGE message = new GG_MESSAGE();
|
message.setTitle(base.getWfname())
|
.setContent(base.getWfname())
|
.setSender_id(support.getUserId())
|
.setSender_name(support.getUserName())
|
.setSend_time(DateUtil.getCurrentDate14())
|
.setBusiness_id(base.getBusiness_id());
|
|
|
if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND)){
|
//例行巡检
|
message.setWeb_url(Constants.REMIND_WEB_MSG_URL+"?flowId="+base.getId()+"&orderId="+base.getBusiness_id())
|
.setWx_url(WechatConstants.ORDER_INCIDENT_DETAIL_ADDRESS+"?orderId="+base.getBusiness_id()+"&orderType="+Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND)
|
.setType(Constants.GG_MESSAGE_TYPE_LXXJ)
|
.setOrder_code(base.getOrder_code());
|
}else if(support.getWorkFlowType().equals(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH)){
|
//健康检查
|
message.setWeb_url(Constants.HEALTH_WEB_MSG_URL+"?flowId="+base.getId()+"&orderId="+base.getBusiness_id())
|
.setWx_url(WechatConstants.ORDER_INCIDENT_DETAIL_ADDRESS+"?orderId="+base.getBusiness_id()+"&orderType="+Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH)
|
.setType(Constants.GG_MESSAGE_TYPE_JKJC)
|
.setOrder_code(base.getOrder_code());
|
}
|
//messageFacade.doSendMessage(message, support.getNextUserList());
|
}
|
|
/**
|
* 根据节点模板Id 获取执行人
|
* @param nodeTemplateId
|
* @return
|
*/
|
public List<Map> getNodeExecutor(String nodeTemplateId){
|
String sql = "select u.* from " +
|
"workflow_template_node n inner join WORKFLOW_TEMPLATE_NODE_PARTNER p " +
|
"on n.ID = p.NODE_ID " +
|
"inner join WORKFLOW_TEMPLATE_NODE_USER u " +
|
"on p.ID = u.PARTNER_NODE_ID " +
|
"where n.ID=:nodeTemplateId LIMIT 1 ";
|
Map map = baseDao.queryForMap(sql,new SqlParameter().addValue("nodeTemplateId", nodeTemplateId));
|
map.put("IS_ADMIN", "1");
|
List<Map> list = new ArrayList<Map>();
|
list.add(map);
|
return list;
|
}
|
|
/**
|
* 获取执行过的节点的执行人
|
* @param flowId
|
* @param nodeTemplateId
|
* @return
|
*/
|
public List<Map> getEverNodeExecutor(String flowId,String nodeTemplateId){
|
String sql = "select current_dealer_id USER_ID,current_dealer_name USER_NAME,1 as IS_ADMIN from workflow_node " +
|
"where IS_ADMIN = 1 and flowid = :flowId and node_template_id=:nodeTemplateId order by createtime desc limit 1";
|
|
Map map = baseDao.queryForMap(sql,new SqlParameter().addValue("nodeTemplateId", nodeTemplateId)
|
.addValue("flowId", flowId));
|
List<Map> list = new ArrayList<Map>();
|
list.add(map);
|
return list;
|
|
}
|
|
@Override
|
public List<Map> getNotDealList(String flowId) {
|
StringBuilder sql = new StringBuilder();
|
Map param = new HashMap();
|
param.put("flowId",flowId);
|
sql.append(" select CURRENT_DEALER_NAME name from workflow_node where FLOWID = :flowId and FLOWSTATE!=3 ");
|
sql.append(" and (IS_ADMIN<>1 or IS_ADMIN is null) ");
|
return baseDao.queryForList(sql.toString(),param);
|
}
|
|
@Override
|
public Map getOrderFlowInfo(String flowId) {
|
Map param = new HashMap();
|
param.put("flowId", flowId);
|
String sql = " select b.ORDER_CODE,b.BUSINESSTYPE,b.PROJECT_ID,b.WFNAME,b.CUSTOMER_NAME,b.SUB_CUSTOMER_NAME,b.PROJECT_NAME,n.CURRENT_DEAL_ROLENAME roleName,n.deal_type dealType,g.SJHM telphone,n.FLOWSTATE nodeState,b.WFSTATE flowState,b.CURRENT_NODE_NAME nodeName,b.CURRENT_DEALER_NAME userName "+
|
" from workflow_base b inner join workflow_node n on "+
|
" b.CURRENT_NODE_ID = n.id "+
|
" left join gg_user g on g.ID = b.CURRENT_DEALER_ID "+
|
" where FLOWID = :flowId ";
|
return baseDao.queryForMap(sql,param);
|
}
|
|
|
public List<Map> getProjectManager(String projectId){
|
String sql = "SELECT A.PROJECT_MANAGER_ID USER_ID,A.PROJECT_MANAGER_NAME USER_NAME,1 as IS_ADMIN FROM SC_PARTNER_CUSTOMER_PROJECT A WHERE A.PROJECT_STATE != 2 " +
|
" and id=:projectId ";
|
SqlParameter parameter = new SqlParameter();
|
parameter.addValue("projectId", projectId);
|
return baseDao.queryForList(sql,parameter);
|
}
|
|
|
public List<Map> getAllExecutors() {
|
|
SqlParameter param = new SqlParameter();
|
|
Map<String,Map> rset = new HashMap<String, Map>();
|
List<Map> rlist = new ArrayList<Map>();
|
List<Map> ulist = new ArrayList<Map>();
|
|
StringBuilder sql = new StringBuilder();
|
|
sql.setLength(0);
|
sql.append("SELECT * FROM AC_ROLE WHERE STATE=1 ORDER BY SXH ASC ");
|
rlist=baseDao.queryForList(sql.toString(), param);
|
|
sql.setLength(0);
|
sql.append("SELECT A.ID USER_ID,A.ZSXM USER_NAME,B.JSBH ROLEID FROM GG_USER A, AC_USER_REF_ROLE B WHERE A.ID = B.YHBH AND A.ZT = 1 ");
|
ulist=baseDao.queryForList(sql.toString(), param);
|
|
if(rlist!=null&&rlist.size()>0){
|
for(Map map:rlist ){
|
rset.put(map.get("ID").toString(), map);
|
}
|
if(ulist!=null&&ulist.size()>0){
|
for(Map map:ulist){
|
String key = map.get("ROLEID").toString();
|
Map roleMap = rset.get(key);
|
if(roleMap!=null){
|
if(roleMap.get("children")==null){
|
roleMap.put("children", new ArrayList());
|
}
|
((List)roleMap.get("children")).add(map);
|
}
|
}
|
}
|
}
|
return rlist;
|
}
|
|
|
/**
|
* 关闭工单(orderId,closeNote,nodeId)
|
* @param request
|
*/
|
@Override
|
public void doCloseWrokFlow(HttpServletRequest request){
|
String orderId = request.getParameter("orderId");
|
String closeNote = request.getParameter("closeNote");
|
String nodeId = request.getParameter("nodeId");
|
String flowId = request.getParameter("flowId");
|
String userName = WebUtil.getLoginUser(request).getLoginUser().get("ZSXM").toString();
|
WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById();
|
NodeFinishEntity finishEntity = new NodeFinishEntity();
|
finishEntity.setDeal_result(1);
|
finishEntity.setDeal_note_title(userName+"关闭了工单");
|
finishEntity.setDeal_note(closeNote);
|
WORKFLOW_NODE node = new WORKFLOW_NODE(nodeId).getInstanceById();
|
workflowCoreService.finishNode(base, node, finishEntity);
|
workflowCoreService.closeWorkFlow(base);
|
}
|
|
@Override
|
public boolean nodeAnswer(HttpServletRequest request) {
|
String flowId = request.getParameter("flowId");
|
String nodeId = request.getParameter("nodeId");
|
WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById();
|
WORKFLOW_NODE node = new WORKFLOW_NODE(nodeId).getInstanceById();
|
NodeAnswerEntity entity = new NodeAnswerEntity();
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
entity.setUser_id(user.get("ID").toString());
|
entity.setUser_name(user.get("ZSXM").toString());
|
boolean flag = workflowCoreService.answerNode(base, node, entity);
|
return flag;
|
}
|
|
@Override
|
public boolean saveLinkOrders(String flowId, String[] linkOrderIds) {
|
baseDao.execute("DELETE FROM ORDER_REF_ORDER WHERE BUSINESS_ID = :flowId ", new SqlParameter("flowId",flowId));
|
if(null!=linkOrderIds && linkOrderIds.length>0) {
|
List<SqlParameter> paramList = new ArrayList<SqlParameter>();
|
for(String linkOrderId : linkOrderIds) {
|
SqlParameter sqlParameter = new SqlParameter();
|
sqlParameter.put("id", StringUtil.getUUID());
|
sqlParameter.put("businessId", flowId);
|
sqlParameter.put("relateFlowId", linkOrderId);
|
paramList.add(sqlParameter);
|
}
|
String insertSql = "INSERT INTO ORDER_REF_ORDER(ID,BUSINESS_ID,RELATE_FLOW_ID) VALUES (:id,:businessId,:relateFlowId)";
|
baseDao.executeBatch(insertSql, paramList);
|
return true;
|
}
|
return false;
|
}
|
|
@Override
|
public boolean saveLinkDevices(String flowId, String[] linkDeviceIds) {
|
baseDao.execute("DELETE FROM CMDB_CI_REF_ORDER WHERE FLOW_ID = :flowId ", new SqlParameter("flowId",flowId));
|
if(null!=linkDeviceIds && linkDeviceIds.length!=0) {
|
List<SqlParameter> list = new ArrayList<SqlParameter>();
|
for(String linkDeviceId : linkDeviceIds) {
|
SqlParameter sqlParameter = new SqlParameter();
|
sqlParameter.put("id", StringUtil.getUUID());
|
sqlParameter.put("ciId", linkDeviceId);
|
sqlParameter.put("flow_id", flowId);
|
list.add(sqlParameter);
|
}
|
|
String insertCmdb_ci_ref_orderSql = "INSERT CMDB_CI_REF_ORDER(ID,FLOW_ID,CI_ID) VALUES (:id,:flow_id,:ciId)";
|
baseDao.executeBatch(insertCmdb_ci_ref_orderSql,list);
|
return true;
|
}
|
return false;
|
}
|
|
@Override
|
public List getLinkConfigure(String flowId) {
|
String sql = " SELECT B.ID,B.LV3_ID THIRD_CATE_ID,B.CINAME FROM CMDB_CI_REF_ORDER R,CMDB_CI_BASE B " +
|
" WHERE R.CI_ID = B.ID AND R.FLOW_ID = :flowId AND B.STATE = 1 ";
|
return baseDao.queryForList(sql,new SqlParameter("flowId",flowId));
|
}
|
|
@Override
|
public void getMyOrderDateSql(StringBuilder builder, Map paramMap) {
|
builder.append(" select DATE_FORMAT(b.CREATETIME,'%Y-%m-%d') m_date ");
|
builder.append(" from WORKFLOW_BASE B ");
|
builder.append(" inner join ");
|
builder.append(" ( ");
|
builder.append(" select * from ( ");
|
builder.append(" select ID NODEID, CREATETIME NODETIME,FLOWSTATE NODESTATE,FLOWID from WORKFLOW_NODE ");
|
builder.append(" where CURRENT_DEALER_ID = :userId ");
|
builder.append(" order by FLOWSTATE asc ");
|
builder.append(" ) t ");
|
builder.append(" group by FLOWID ");
|
builder.append(" ) n ");
|
builder.append(" on b.ID = n.FLOWID ");
|
//builder.append(" where b.PARTNER_ID =:partnerId ");
|
//工单类型
|
builder.append(" where b.BUSINESSTYPE = :bustype ");
|
//是否选择月份
|
String selMonth = ConvertUtil.obj2StrBlank(paramMap.get("selMonth"));
|
if(StringUtil.isNotBlank(selMonth)){
|
builder.append(" AND DATE_FORMAT(b.CREATETIME,'%Y%m') = :selMonth ");
|
}
|
|
builder.append(" group by DATE_FORMAT(b.CREATETIME,'%Y-%m-%d') ");
|
builder.append(" order by b.CREATETIME asc ");
|
}
|
|
@Override
|
public void getAllOrderDateSql(StringBuilder builder, Map paramMap) {
|
builder.append(" select DATE_FORMAT(b.CREATETIME,'%Y-%m-%d') m_date ");
|
builder.append(" from WORKFLOW_BASE b ");
|
//builder.append(" where b.PARTNER_ID =:partnerId ");
|
builder.append(" where b.BUSINESSTYPE = :bustype");
|
|
String customer_id = ConvertUtil.obj2StrBlank(paramMap.get("customer_id"));
|
|
if(StringUtil.notEmpty(customer_id)) {
|
builder.append(" AND b.CUSTOMER_ID = :customer_id");
|
}
|
//builder = getProjectSql(builder,projects);
|
//是否选择月份
|
String selMonth = ConvertUtil.obj2StrBlank(paramMap.get("selMonth"));
|
if(StringUtil.isNotBlank(selMonth)){
|
builder.append(" AND DATE_FORMAT(b.CREATETIME,'%Y%m') = :selMonth ");
|
}
|
builder.append(" group by DATE_FORMAT(b.CREATETIME,'%Y-%m-%d') ");
|
builder.append(" order by b.CREATETIME asc ");
|
|
|
|
}
|
|
private StringBuilder getProjectSql(StringBuilder buffer, List<Map> projects) {
|
if(null != projects && projects.size()>0) {
|
buffer.append(" AND b.PROJECT_ID IN ( ");
|
for(Map project : projects) {
|
String projectId = ConvertUtil.obj2StrBlank(project.get("PROJECT_ID"));
|
buffer.append("'");
|
buffer.append(projectId);
|
buffer.append("',");
|
}
|
buffer.deleteCharAt(buffer.length()-1);
|
buffer.append(")");
|
} else {
|
buffer.append(" AND b.PROJECT_ID = '' ");
|
}
|
return buffer;
|
}
|
|
@Override
|
public Map getNodeInfoByFlowId(String flowId, String userId) {
|
SqlParameter param = new SqlParameter();
|
param.addValue("flowId", flowId)
|
.addValue("userId", userId);
|
String sql = " select n.* from workflow_base b,workflow_node n where b.id = n.flowid " +
|
"and b.id = :flowId and n.current_dealer_id = :userId and (n.flowstate = 1 or n.flowstate=2 ) ";
|
return baseDao.queryForMap(sql, param);
|
}
|
}
|
