package cn.ksource.web.facade.wechat.ewyw; 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.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import cn.ksource.beans.CUSTOMER_CONTACTS; import cn.ksource.beans.GG_MESSAGE; import cn.ksource.beans.GG_RECORD; import cn.ksource.beans.REPAIR_RECORD; import cn.ksource.beans.SC_PARTNER_CUSTOMER_INFO; import cn.ksource.beans.SC_SERVCE_CATEGORY; import cn.ksource.beans.SC_WORKFLOW_INCIDENT; 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.page.PageInfo; import cn.ksource.core.util.AjaxUtil; import cn.ksource.core.util.ConvertUtil; import cn.ksource.core.util.DateUtil; import cn.ksource.core.util.JsonUtil; import cn.ksource.core.util.NumberUtil; 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.facade.incident.IncidentFacade; import cn.ksource.web.facade.message.MessageFacade; import cn.ksource.web.facade.servicelist.SlaPartnerFacade; import cn.ksource.web.service.DataDictionaryService; import cn.ksource.web.service.WorkOrderCodeService; import cn.ksource.web.service.device.DeviceService; import cn.ksource.web.service.file.FileService; import cn.ksource.web.service.order.OrderService; import cn.ksource.web.service.record.RecordService; import cn.ksource.web.service.sl.SlaProjectService; import cn.ksource.web.service.sl.sla.NoticeUser; import cn.ksource.web.service.sl.sla.SLAEntity; import cn.ksource.web.service.sl.sla.SLALevel; @Service("ewIncidentFacade") public class EwIncidentFacadeImpl implements EwIncidentFacade { @Autowired private BaseDao baseDao; @Autowired private WorkOrderCodeService workOrderCodeService; @Autowired private DataDictionaryService dataDictionaryService; @Autowired private WorkflowBusinessService workflowBusinessService; @Autowired private WorkflowCoreService workflowCoreService; @Autowired private FileService fileService; @Autowired private MessageFacade messageFacade; @Autowired private RecordService recordService; @Autowired private OrderService orderService; @Autowired private DeviceService deviceService; @Resource(name="slaProjectService") private SlaProjectService slaProjectService; @Resource(name="slaPartnerFacade") private SlaPartnerFacade slaPartnerFacade; @Override public String doOrderConfirm(HttpServletRequest request) { String incidentId = request.getParameter("incidentId"); String flowId = request.getParameter("flowId"); Map user = WebUtil.getEngineerMsg(request); String userId = ConvertUtil.obj2StrBlank(user.get("ID")); String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM")); NodeAnswerEntity answerEntity = new NodeAnswerEntity(); answerEntity.setUser_id(userId); answerEntity.setUser_name(userName); WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById(); //判断该工单是否已经响应过 //工单响应 boolean result = workflowCoreService.answerNode(base, new WORKFLOW_NODE(base.getCurrent_node_id()).getInstanceById(), answerEntity); if(!result) { return "2"; } //判断是否是第一次响应，如果是第一次响应的话，则更新事件表中实际响应时间（第一次响应时间） String selectSql = "SELECT ANSWER_TIME,CREATE_TIME,ANSWER_TIMEOUT_TIME FROM SC_WORKFLOW_INCIDENT WHERE ID = :incidentId"; Map map = baseDao.queryForMap(selectSql,new SqlParameter("incidentId",incidentId)); String answerTime = ConvertUtil.obj2StrBlank(map.get("ANSWER_TIME")); long create_time = ConvertUtil.obj2Long(map.get("CREATE_TIME")); Map paramMap = new HashMap(); StringBuilder builder = new StringBuilder("UPDATE SC_WORKFLOW_INCIDENT SET STATE = STATE + 1"); if(!StringUtil.notEmpty(answerTime)) { long answer_time = DateUtil.getCurrentDate14(); //判断是否响应超时 long answer_timeout_time = ConvertUtil.obj2Long(map.get("ANSWER_TIMEOUT_TIME")); String answer_timeout = "2"; if(answer_time>answer_timeout_time) { answer_timeout = "1"; } builder.append(",ANSWER_TIME = :answerTime,ANSWER_USE_TIME = :answer_user_time,ANSWER_TIMEOUT = :answer_timeout "); paramMap.put("answerTime",answer_time); paramMap.put("answer_timeout", answer_timeout); //计算第一次响应时间和创建事件的事件差 将时间差转化为分钟 long seconds = DateUtil.getSecondsFormDate2Date(create_time, answer_time); //将秒转化为分钟 double sjxysj = NumberUtil.div(ConvertUtil.obj2Double(seconds), ConvertUtil.obj2Double(60), 1); paramMap.put("answer_user_time", sjxysj); //如果是第一次响应，则删除所有的响应通知 String deleteSql = "DELETE FROM SC_INCIDENT_SLA_NOTICE WHERE TYPE = 1 AND INCIDENT_ID = :incidentId"; baseDao.execute(deleteSql, new SqlParameter("incidentId",incidentId)); } builder.append(" WHERE ID = :incidentId"); paramMap.put("incidentId", incidentId); baseDao.execute(builder.toString(), paramMap); return "1"; } @Override public String doOrderConfirm(String incidentId, String userId, String userName) { String flowId = ""; NodeAnswerEntity answerEntity = new NodeAnswerEntity(); answerEntity.setUser_id(userId); answerEntity.setUser_name(userName); if(StringUtil.notEmpty(incidentId)) { SC_WORKFLOW_INCIDENT incident = new SC_WORKFLOW_INCIDENT(incidentId).getInstanceById(); flowId = incident.getFlow_id(); } WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById(); //判断该工单是否已经响应过 //工单响应 boolean result = workflowCoreService.answerNode(base, new WORKFLOW_NODE(base.getCurrent_node_id()).getInstanceById(), answerEntity); if(!result) { return "2"; } //判断是否是第一次响应，如果是第一次响应的话，则更新事件表中实际响应时间（第一次响应时间） String selectSql = "SELECT ANSWER_TIME,CREATE_TIME,ANSWER_TIMEOUT_TIME FROM SC_WORKFLOW_INCIDENT WHERE ID = :incidentId"; Map map = baseDao.queryForMap(selectSql,new SqlParameter("incidentId",incidentId)); String answerTime = ConvertUtil.obj2StrBlank(map.get("ANSWER_TIME")); long create_time = ConvertUtil.obj2Long(map.get("CREATE_TIME")); Map paramMap = new HashMap(); StringBuilder builder = new StringBuilder("UPDATE SC_WORKFLOW_INCIDENT SET STATE = STATE + 1"); if(!StringUtil.notEmpty(answerTime)) { long answer_time = DateUtil.getCurrentDate14(); //判断是否响应超时 long answer_timeout_time = ConvertUtil.obj2Long(map.get("ANSWER_TIMEOUT_TIME")); String answer_timeout = "2"; if(answer_time>answer_timeout_time) { answer_timeout = "1"; } builder.append(",ANSWER_TIME = :answerTime,ANSWER_USE_TIME = :answer_user_time,ANSWER_TIMEOUT = :answer_timeout "); paramMap.put("answerTime",answer_time); paramMap.put("answer_timeout", answer_timeout); //计算第一次响应时间和创建事件的事件差 将时间差转化为分钟 long seconds = DateUtil.getSecondsFormDate2Date(create_time, answer_time); //将秒转化为分钟 double sjxysj = NumberUtil.div(ConvertUtil.obj2Double(seconds), ConvertUtil.obj2Double(60), 1); paramMap.put("answer_user_time", sjxysj); //如果是第一次响应，则删除所有的响应通知 String deleteSql = "DELETE FROM SC_INCIDENT_SLA_NOTICE WHERE TYPE = 1 AND INCIDENT_ID = :incidentId"; baseDao.execute(deleteSql, new SqlParameter("incidentId",incidentId)); } builder.append(" WHERE ID = :incidentId"); paramMap.put("incidentId", incidentId); baseDao.execute(builder.toString(), paramMap); return "1"; } @Override public Map queryCusSub(String customerId) { Map resultMap = new HashMap(); String subcusId = ""; if(!StringUtil.isEmpty(customerId)){ String[] subs = customerId.split("--"); if(subs.length > 1){ subcusId = subs[1]; } } String sql = "SELECT * FROM SC_PARTNER_CUSTOMER_INFO WHERE CUSTOMER_STATE = 1 "; List cusList = baseDao.queryForList(sql); Map cusMap = new HashMap(); if(null!=cusList && cusList.size()>0){ for(Map cus:cusList){ cusMap.put(cus.get("ID"), cus.get("CUSTOMER_NAME")); } } String selectSubSql = "SELECT * FROM SC_PARTNER_CUSTOMER_SUB WHERE DEL_FLAG = 1 ORDER BY MY_LEVEL "; List subCus = baseDao.queryForList(selectSubSql); List subs = new ArrayList(); List checkSl = new ArrayList(); Map cacheMap = new HashMap(); if(null!=subCus && subCus.size()>0){ for(Map cus : subCus) { String level = ConvertUtil.obj2StrBlank(cus.get("MY_LEVEL")); String id = ConvertUtil.obj2Str(cus.get("ID")); String name = ConvertUtil.obj2StrBlank(cus.get("CUSTOMER_NAME")); String cusId = ConvertUtil.obj2StrBlank(cus.get("CUSTOMER_ID")); if(subcusId.equals(id)) { cus.put("checked", 1); Map map = new HashMap(); map.put("checkId", cusId + "--" +id); map.put("checkName",cusMap.get(cusId) + "--" + name); checkSl.add(map); } else { cus.put("checked", 2); } if(level.equals("1")) { List ejList = new ArrayList(); cacheMap.put(id, ejList); cus.put("subs", ejList); subs.add(cus); continue; } if(level.equals("2")) { String pid = ConvertUtil.obj2StrBlank(cus.get("P_ID")); List ejList = (List)cacheMap.get(pid); ejList.add(cus); } } } if(null!=cusList && cusList.size()>0){ for(Map cus:cusList){ if(!StringUtil.isEmpty(customerId)){ if(StringUtil.isEmpty(subcusId)){ String id = ConvertUtil.obj2Str(cus.get("ID")); String name = ConvertUtil.obj2StrBlank(cus.get("CUSTOMER_NAME")); if(customerId.equals(id)) { cus.put("checked", 1); Map map = new HashMap(); map.put("checkId", id); map.put("checkName", name); checkSl.add(map); } else { cus.put("checked", 2); } } } for(Map sub:subs){ if(sub.get("CUSTOMER_ID").equals(cus.get("ID"))){ List subcus = (List)cus.get("sublist"); if(subcus == null){ subcus = new ArrayList(); subcus.add(sub); cus.put("sublist", subcus); }else{ subcus.add(sub); cus.put("sublist", subcus); } } } } } resultMap.put("cusList", cusList); resultMap.put("checks", checkSl); return resultMap; } @Override public Map queryContactInfo(String customer_id, String contactPhone) { String selectSql = "SELECT CONTACT_NAME,YWKS,SUB_CUSTOMER_ID,SUB_CUSTOMER_NAME FROM CUSTOMER_CONTACTS WHERE CONTACTS_TYPE = :contactPhone AND CUSTOMER_ID = :customer_id "; Map map = baseDao.queryForMap(selectSql,new SqlParameter("contactPhone",contactPhone).addValue("customer_id", customer_id)); if(null!=map && map.size()>0) { map.put("hasMsg", "1"); } else { map.put("hasMsg", "2"); } return map; } @Override public List queryLinkDevice(Map params) { StringBuilder builder = new StringBuilder(); builder = getDevicesql(builder,params); List devices = baseDao.queryForList( builder.toString(), params); for(Map device : devices){ device.put("LASTUPDATETIME", DateUtil.format("yyyy-MM-dd HH:mm:ss", device.get("LASTUPDATETIME"))); int i = device.get("STATE") == null ? 0 : ConvertUtil.obj2Int(device.get("STATE")); device.put("STATE", Constants.getCMDB_CI_BASE_USINGSTATE_Label(i)); } return devices; } public StringBuilder getDevicesql(StringBuilder builder,Map params){ String customerId = params.get("customerId"); String ciids = params.get("ciids"); String cmdbName = AjaxUtil.decode(params.get("cmdbName")); String subCustomerId = ""; if(!StringUtil.isEmpty(customerId)){ String[] subs = customerId.split("--"); if(subs.length > 1){ customerId = subs[0]; subCustomerId = subs[1]; if(customerId.equals(subCustomerId)){ subCustomerId=""; } }else{ customerId = subs[0]; } } //查询关联设备 //builder.append("SELECT A.* FROM CMDB_CI_BASE A,CMDB_CI_FLOW B WHERE A.ID = B.CFG_ID AND B.STATE = 4 AND A.STATE = 1 "); builder.append("SELECT\n" + " A.*\n" + "FROM\n" + " CMDB_CI_BASE A\n" + "left JOIN CMDB_CI_FLOW B ON A.ID = B.CFG_ID\n" + "WHERE\n" + " A.STATE = 1 and (b.STATE is null or b.STATE = 4)" ); if(StringUtil.notEmpty(ciids)){ String ciid[] = ciids.split("-"); if (!StringUtil.isEmpty(ciids)) { String para=""; for(int i=0;i queryLinkOrder(Map params) { String orderCode = params.get("orderCode"); String customerId = params.get("customerId"); String orderids = params.get("orderids"); StringBuilder sql = new StringBuilder("SELECT A.ID,A.WFNAME,A.BUSINESSTYPE,A.WFSTATE,A.BUSINESS_ID,A.ORDER_CODE,A.CUSTOMER_NAME,A.CREATETIME,A.CREATERNAME FROM WORKFLOW_BASE A WHERE A.WFSTATE != :wfstate AND A.WFSTATE != :wfstate1 "); if(!StringUtil.isEmpty(customerId)){ String[] subs = customerId.split("--"); if(subs.length > 1){ customerId = subs[0]; params.put("customerId", customerId); } } if(!StringUtil.isEmpty(customerId)){ sql.append(" AND A.CUSTOMER_ID = :customerId "); } params.put("wfstate", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_DELETE)); params.put("wfstate1", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_WFSTATE_CLOSE)); String flowid[] = orderids.split("-"); if (!StringUtil.isEmpty(orderids)) { String para=""; for(int i=0;i list = baseDao.queryForList(sql.toString(),params); for (Map map2 : list) { map2.put("BUSINESSTYPE_TEXT", Constants.mapWORKFLOW_BUSINESS_TYPE_Label(ConvertUtil.obj2Str(map2.get("BUSINESSTYPE")))); map2.put("WFSTATE_TEXT", Constants.getWORKFLOW_BASE_WFSTATE_Label(ConvertUtil.obj2Str(map2.get("WFSTATE")))); map2.put("CREATE_TIME", DateUtil.format("yyyy-MM-dd HH:mm:ss", map2.get("CREATE_TIME"))); } return list; } @Override public Map saveEngineerIncident(HttpServletRequest request, SC_WORKFLOW_INCIDENT sc_workflow_incident) { Map resultMap = new HashMap(); resultMap.put("result", "2"); Map user = WebUtil.getEngineerMsg(request); String userId = ConvertUtil.obj2StrBlank(user.get("ID")); String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM")); String customerId = sc_workflow_incident.getCustomer_id(); String customerName = sc_workflow_incident.getCustomer_name(); String subCustomerId = ""; String subCustomerName = ""; if(!StringUtil.isEmpty(customerId)){ String[] subs = customerId.split("--"); String[] subNames = customerName.split("--"); if(subs.length > 1){ customerId = subs[0]; subCustomerId = subs[1]; customerName = subNames[0]; subCustomerName = subNames[1]; }else{ subCustomerId = subs[0]; subCustomerName = subNames[0]; } } String happen_time = request.getParameter("happen_time"); happen_time = happen_time.replace("-", "").replace(" ", "").replace(":", ""); sc_workflow_incident.setHappen_time(ConvertUtil.obj2Long(happen_time+"00")); sc_workflow_incident.setCustomer_id(customerId).setSub_customer_id(subCustomerId).setSub_customer_name(subCustomerName); String type_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getType_id()).get("DATAVALUE")); sc_workflow_incident.setType_name(type_name); String apply_type_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getApply_type_id()).get("DATAVALUE")); sc_workflow_incident.setApply_type_name(apply_type_name); String source_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getSource_id()).get("DATAVALUE")); sc_workflow_incident.setSource_name(source_name); String priority_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getPriority_id()).get("DATAVALUE")); sc_workflow_incident.setPriority_name(priority_name); String influence_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getInfluence_id()).get("DATAVALUE")); sc_workflow_incident.setInfluence_name(influence_name); String serivceListId = request.getParameter("serivceListId"); String serivceList = request.getParameter("serivceList"); String first_category_id = new String(); String first_category_name = new String(); String second_category_id = new String(); String second_category_name = new String(); String third_category_id = new String(); String third_category_name = new String(); if(StringUtil.notEmpty(serivceListId) && StringUtil.notEmpty(serivceList)) { String[] serivceListIds = serivceListId.split("-"); String[] serivceLists = serivceList.split("->"); first_category_id = serivceListIds[0]; first_category_name = serivceLists[0]; second_category_id = serivceListIds[1]; second_category_name = serivceLists[1]; third_category_id = serivceListIds[2]; third_category_name = serivceLists[2]; } //查询当前项目的服务台组的编号 String selectSql = "SELECT A.* FROM AC_ROLE A WHERE A.IDENTIFY = :roleid "; Map map = baseDao.queryForMap(selectSql,new SqlParameter("roleid",Constants.ROLE_SERVICE)); String roleId = ConvertUtil.obj2StrBlank(map.get("ID")); String roleName = ConvertUtil.obj2StrBlank(map.get("ROLENAME")); List dealerList = new ArrayList(); //查询改组下面的所有人员信息 String selectUser = "SELECT B.ID AS USER_ID,B.ZSXM AS USER_NAME FROM AC_USER_REF_ROLE A,GG_USER B WHERE A.JSBH = :roleId AND A.YHBH = B.ID "; dealerList = baseDao.queryForList(selectUser,new SqlParameter("roleId",roleId)); if(dealerList == null || dealerList.size() == 0){ resultMap.put("result", 2); resultMap.put("nouser", 1); return resultMap; } String state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT; String node_template_id = Constants.KFRY; String order_code = workOrderCodeService.getIncidentOrderCode(); //响应时间为分钟 Long requestAnswerTime = sc_workflow_incident.getRequest_answer_time(); Long dealTime = sc_workflow_incident.getRequest_deal_time(); if(null == requestAnswerTime) { requestAnswerTime = Long.valueOf(0); } if(null == dealTime) { dealTime = Long.valueOf(0); } //处理时间为小时 long createTime = DateUtil.getCurrentDate14(); long answerTimeoutTime = DateUtil.getTimeAdd(createTime, ConvertUtil.obj2Int(requestAnswerTime),2); long dealTimeoutTime = DateUtil.getTimeAdd(createTime, ConvertUtil.obj2Int(dealTime),1); sc_workflow_incident.setFirst_category_id(first_category_id).setFirst_category_name(first_category_name).setSecond_category_id(second_category_id) .setSecond_category_name(second_category_name).setThird_category_id(third_category_id).setThird_category_name(third_category_name).setCreate_user_id(userId).setCreate_user_name(userName) .setCreate_time(createTime); String id = StringUtil.getUUID(); sc_workflow_incident.setId(id).setState(ConvertUtil.obj2Integer(state)).setOrder_code(order_code).setFlow_name(sc_workflow_incident.getName()).setAnswer_timeout(2).setAnswer_timeout_time(answerTimeoutTime).setDeal_timeout(2).setDeal_timeout_time(dealTimeoutTime).setCreate_type(2); sc_workflow_incident.insert(); String bz = request.getParameter("bz"); //启动流程 WORKFLOW_BASE base = workflowBusinessService.startIncidentWorkflow(id,bz); //启动流程 NodeDealEntity entity = new NodeDealEntity(); entity.setDealer_type(3); entity.setBefore_Dealer_type(1); entity.setRoleID(roleId); entity.setRoleName(roleName); workflowBusinessService.toNode(base, node_template_id, entity); String hasMsg = request.getParameter("hasMsg"); if(StringUtil.notEmptyNum(hasMsg) && hasMsg.equals("2")) { //保存联系人的信息 CUSTOMER_CONTACTS project_contacts = new CUSTOMER_CONTACTS(); project_contacts.setId(StringUtil.getUUID()).setCustomer_id(sc_workflow_incident.getCustomer_id()) .setContact_name(sc_workflow_incident.getContact_name()).setContacts_type(sc_workflow_incident.getContact_phone()).setYwks(sc_workflow_incident.getKeshi()) .setIs_satis(0).setState(1).setIsemail(1).setIsphone(1).setAllow_login(2).setSub_customer_id(sc_workflow_incident.getSub_customer_id()).setSub_customer_name(sc_workflow_incident.getSub_customer_name()); project_contacts.insert(); } String wxUrl = WechatConstants.ORDER_INCIDENT_DETAIL_ADDRESS+"?orderId="+base.getBusiness_id()+"&orderType="+Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT; //发送消息 GG_MESSAGE message = new GG_MESSAGE(); message.setTitle(sc_workflow_incident.getName()) .setContent(sc_workflow_incident.getName()) .setSender_id(userId) .setSender_name(userName) .setSend_time(DateUtil.getCurrentDate14()) .setBusiness_id(base.getBusiness_id()) .setWeb_url(Constants.INCIDENT_WEB_MSG_URL+"?flowId="+base.getId()+"&orderId="+base.getBusiness_id()) .setWx_url(wxUrl) .setOrder_code(order_code) .setType(Constants.GG_MESSAGE_TYPE_SJGL); messageFacade.doSendMessage(message, dealerList); //所有的业务主键都是flowId(即流程主表的id) String flowId = base.getId(); //提交工单时添加关联工单 String[] orderId = request.getParameterValues("orderId"); orderService.saveLinkOrders(flowId,orderId,request); //提交工单时上传文档附件 //fileService.uploadFile(request,flowId,flowId,null,null,Constants.GG_FOLDERS_SJFOLDERS,Constants.FILE_STATE_SHTG,null); //提交工单时添加关联设备 String[] deviceId = request.getParameterValues("deviceId"); deviceService.saveLinkDevices(flowId,deviceId); //添加处理记录 GG_RECORD record = new GG_RECORD(); record.setDeal_content("创建事件："+userName+"创建了事件"); record.setDeal_user_id("1"); record.setDeal_user_name(userName); record.setBusiness_id(flowId); recordService.addRecord(record); resultMap.put("result", "1"); SysInfoMsg msg = new SysInfoMsg("1",roleName,Constants.incidentNode.get(node_template_id)); resultMap.put("msg", msg); resultMap.put("incidentId", id); //增加该事件的SLA通知信息 addSlaNoticeMsg(id,createTime,sc_workflow_incident.getSla_id(),sc_workflow_incident.getCustomer_id(),sc_workflow_incident.getThird_category_id(),answerTimeoutTime,dealTimeoutTime,dealerList); //一键报修 String repair = request.getParameter("repair"); if(!StringUtil.isEmpty(repair)){ REPAIR_RECORD repairrecord = new REPAIR_RECORD(); repairrecord.setId(repair).setIncident_id(sc_workflow_incident.getId()).setStatus(3).update(); } return resultMap; } private void addSlaNoticeMsg(String id,long createTime,String levelId,String customer_id,String third_category_id,long answerTimeoutTime,long dealTimeoutTime,List dealLists) { SLAEntity slaEntity = slaProjectService.getLevelMsg( customer_id, third_category_id); if(null!=slaEntity) { Map levelMap = slaEntity.getLevelMap(); if(null!=levelMap && levelMap.size()>0) { SLALevel level = levelMap.get(levelId); if(null != level) { String insertSql = "INSERT INTO SC_INCIDENT_SLA_NOTICE (ID,INCIDENT_ID,TYPE,NOTICE_TIME,STATUS,NOTICE_USERS,OUT_TIME) VALUES (:id,:incidentId,:type,:noticeTime,1,:noticeUsers,:out_time)"; List params = new ArrayList(); String responseTime = level.getResponseTime(); String noticeUsers = level.getUserId(); if(StringUtil.notEmpty(responseTime)) { //响应时间为分钟，将其转化为毫秒 SqlParameter sqlParameter = new SqlParameter(); sqlParameter.put("id", StringUtil.getUUID()); sqlParameter.put("incidentId", id); sqlParameter.put("type", 1); sqlParameter.put("noticeTime", answerTimeoutTime); sqlParameter.put("noticeUsers", noticeUsers); sqlParameter.put("out_time", ""); params.add(sqlParameter); List noticeUser1 = level.getResponseNotices(); if(null!=noticeUser1 && noticeUser1.size()>0) { for(NoticeUser noticeUser : noticeUser1) { String overTime = noticeUser.getOverTime(); if(StringUtil.notEmpty(overTime)) { SqlParameter sqlParameter1 = new SqlParameter(); sqlParameter1.put("id", StringUtil.getUUID()); sqlParameter1.put("incidentId", id); sqlParameter1.put("type", 1); sqlParameter1.put("noticeTime", DateUtil.getTimeAdd(answerTimeoutTime, ConvertUtil.obj2Int(overTime),2)); StringBuffer bufferUser = new StringBuffer(); if(null!=dealLists && dealLists.size()>0) { for(Map map : dealLists) { String user_id = ConvertUtil.obj2StrBlank(map.get("USER_ID")); bufferUser.append(user_id); bufferUser.append(","); } bufferUser.deleteCharAt(bufferUser.lastIndexOf(",")); } System.out.println("bufferUser---------->"+bufferUser); sqlParameter1.put("noticeUsers", noticeUser.getUserId()+bufferUser.toString()); sqlParameter1.put("out_time", overTime); params.add(sqlParameter1); } } } } String resolveTime = level.getResolveTime(); if(StringUtil.notEmpty(resolveTime)) { //解决时间为小时，将其转化为毫秒 SqlParameter sqlParameter = new SqlParameter(); sqlParameter.put("id", StringUtil.getUUID()); sqlParameter.put("incidentId", id); sqlParameter.put("type", 2); sqlParameter.put("noticeTime", dealTimeoutTime); sqlParameter.put("noticeUsers", noticeUsers); sqlParameter.put("out_time", ""); params.add(sqlParameter); List noticeUser2 = level.getResolveNotices(); if(null!=noticeUser2 && noticeUser2.size()>0) { for(NoticeUser noticeUser : noticeUser2) { String overTime = noticeUser.getOverTime(); if(StringUtil.notEmpty(overTime)) { SqlParameter sqlParameter1 = new SqlParameter(); sqlParameter1.put("id", StringUtil.getUUID()); sqlParameter1.put("incidentId", id); sqlParameter1.put("type", 2); sqlParameter1.put("noticeTime", DateUtil.getTimeAdd(dealTimeoutTime, ConvertUtil.obj2Int(overTime),2)); sqlParameter1.put("noticeUsers", noticeUser.getUserId()); sqlParameter1.put("out_time", overTime); params.add(sqlParameter1); } } } } if(params.size()>0) { baseDao.executeBatch(insertSql,params); } } } } } @Override public Map saveFwtIncident(HttpServletRequest request, SC_WORKFLOW_INCIDENT sc_workflow_incident) { String dtype = new String(); Map resultMap = new HashMap(); resultMap.put("result", 2); System.out.println("selectUser-------------->"+request.getParameter("selectUser")); Map user = WebUtil.getEngineerMsg(request); String userId = ConvertUtil.obj2StrBlank(user.get("ID")); String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM")); String customerId = sc_workflow_incident.getCustomer_id(); String customerName = sc_workflow_incident.getCustomer_name(); String subCustomerId = ""; String subCustomerName = ""; if(!StringUtil.isEmpty(customerId)){ String[] subs = customerId.split("--"); String[] subNames = customerName.split("--"); if(subs.length > 1){ customerId = subs[0]; subCustomerId = subs[1]; customerName = subNames[0]; subCustomerName = subNames[1]; }else{ subCustomerId = subs[0]; subCustomerName = subNames[0]; } } String happen_time = request.getParameter("happen_time"); happen_time = happen_time.replace("-", "").replace(" ", "").replace(":", ""); sc_workflow_incident.setHappen_time(ConvertUtil.obj2Long(happen_time+"00")); String currentUserId = userId; String currentUserName = userName; sc_workflow_incident.setCustomer_id(customerId).setSub_customer_id(subCustomerId).setSub_customer_name(subCustomerName); String type_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getType_id()).get("DATAVALUE")); sc_workflow_incident.setType_name(type_name); String apply_type_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getApply_type_id()).get("DATAVALUE")); sc_workflow_incident.setApply_type_name(apply_type_name); String source_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getSource_id()).get("DATAVALUE")); sc_workflow_incident.setSource_name(source_name); String priority_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getPriority_id()).get("DATAVALUE")); sc_workflow_incident.setPriority_name(priority_name); String influence_name = ConvertUtil.obj2StrBlank(dataDictionaryService.getDataDictionaryByKey(sc_workflow_incident.getInfluence_id()).get("DATAVALUE")); sc_workflow_incident.setInfluence_name(influence_name); String serivceListId = request.getParameter("serivceListId"); String serivceList = request.getParameter("serivceList"); String first_category_id = new String(); String first_category_name = new String(); String second_category_id = new String(); String second_category_name = new String(); String third_category_id = new String(); String third_category_name = new String(); if(StringUtil.notEmpty(serivceListId) && StringUtil.notEmpty(serivceList)) { String[] serivceListIds = serivceListId.split("-"); String[] serivceLists = serivceList.split("-"); first_category_id = serivceListIds[0]; first_category_name = serivceLists[0]; second_category_id = serivceListIds[1]; second_category_name = serivceLists[1]; third_category_id = serivceListIds[2]; third_category_name = serivceLists[2]; } String dealer_type = "1"; String dealUserId = userId; String dealUserName = userName; String type = request.getParameter("type"); String state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT; String node_template_id = Constants.KFRY; if(type.equals("1")) { String selectUser = request.getParameter("selectUser"); if(StringUtil.notEmpty(selectUser)) { String[] userMsg = selectUser.split("-"); if(userMsg.length==4) { dealer_type = userMsg[0]; String userType = userMsg[1]; dealUserId = userMsg[2]; dealUserName = userMsg[3]; if(userType.equals(Constants.ROLE_SERVICE)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT; node_template_id = Constants.KFRY; } else if(userType.equals(Constants.ROLE_OPERATION)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYCJSZC; node_template_id = Constants.YCJSZC; } else if(userType.equals(Constants.ROLE_FLINE)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX; node_template_id = Constants.YXCL; } else if(userType.equals(Constants.ROLE_SLINE)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX; node_template_id = Constants.EXCL; } else if(userType.equals(Constants.ROLE_TLINE)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX; node_template_id = Constants.SXCL; } } } } String order_code = workOrderCodeService.getIncidentOrderCode(); //响应时间为分钟 Long requestAnswerTime = sc_workflow_incident.getRequest_answer_time(); Long dealTime = sc_workflow_incident.getRequest_deal_time(); if(null == requestAnswerTime) { requestAnswerTime = Long.valueOf(0); } if(null == dealTime) { dealTime = Long.valueOf(0); } //处理时间为小时 long createTime = DateUtil.getCurrentDate14(); long answerTimeoutTime = DateUtil.getTimeAdd(createTime, ConvertUtil.obj2Int(requestAnswerTime),2); long dealTimeoutTime = DateUtil.getTimeAdd(createTime, ConvertUtil.obj2Int(dealTime),1); sc_workflow_incident.setFirst_category_id(first_category_id).setFirst_category_name(first_category_name).setSecond_category_id(second_category_id) .setSecond_category_name(second_category_name).setThird_category_id(third_category_id).setThird_category_name(third_category_name).setCreate_user_id(userId).setCreate_user_name(userName) .setCreate_time(createTime); String id = StringUtil.getUUID(); sc_workflow_incident.setId(id).setState(ConvertUtil.obj2Integer(state)).setOrder_code(order_code).setFlow_name(sc_workflow_incident.getName()).setAnswer_timeout(2).setAnswer_timeout_time(answerTimeoutTime).setDeal_timeout(2).setDeal_timeout_time(dealTimeoutTime).setCreate_type(1); sc_workflow_incident.insert(); String bz = request.getParameter("bz"); NodeDealEntity entity = new NodeDealEntity(); entity.setDealer_type(3); List dealerList = new ArrayList(); if(dealer_type.equals("1")) { entity.setBefore_Dealer_type(2); Map map = new HashMap(); map.put("USER_ID", dealUserId); map.put("USER_NAME", dealUserName); map.put("IS_ADMIN", "1"); dealerList.add(map); dtype = "2"; } else { if(dealer_type.equals("2")){ dtype = "3"; }else{ dtype = "1"; } entity.setBefore_Dealer_type(1); entity.setRoleID(dealUserId); entity.setRoleName(dealUserName); //查询改角色/分组下面的所有人员信息 String usersql = "SELECT B.ID AS USER_ID ,B.ZSXM AS USER_NAME FROM AC_USER_REF_ROLE A,GG_USER B WHERE A.YHBH = B.ID AND A.JSBH = :groupId "; dealerList = baseDao.queryForList(usersql,new SqlParameter("groupId",dealUserId)); if(dealerList == null || dealerList.size() == 0){ String groupusersql = "SELECT B.ID AS USER_ID ,B.ZSXM AS USER_NAME FROM AC_ROLE_GROUP_USER A,GG_USER B WHERE A.USER_ID = B.ID AND A.GROUP_ID = :groupId AND A.STATE = 1 "; dealerList = baseDao.queryForList(groupusersql,new SqlParameter("groupId",dealUserId)); if(dealerList == null || dealerList.size() == 0){ resultMap.put("result", 2); resultMap.put("nouser", 2); return resultMap; } } } //启动流程 WORKFLOW_BASE base = workflowBusinessService.startIncidentWorkflow(id,bz); entity.setDealerList(dealerList); workflowBusinessService.toNode(base, node_template_id, entity); String hasMsg = request.getParameter("hasMsg"); if(StringUtil.notEmptyNum(hasMsg) && hasMsg.equals("2")) { //保存联系人的信息 CUSTOMER_CONTACTS project_contacts = new CUSTOMER_CONTACTS(); project_contacts.setId(StringUtil.getUUID()).setCustomer_id(sc_workflow_incident.getCustomer_id()) .setContact_name(sc_workflow_incident.getContact_name()).setContacts_type(sc_workflow_incident.getContact_phone()).setYwks(sc_workflow_incident.getKeshi()) .setIs_satis(0).setState(1).setIsemail(1).setIsphone(1).setAllow_login(2).setSub_customer_id(sc_workflow_incident.getSub_customer_id()).setSub_customer_name(sc_workflow_incident.getSub_customer_name()); project_contacts.insert(); } //dtype = ConvertUtil.obj2StrBlank(entity.getBefore_Dealer_type()); String wxUrl = WechatConstants.ORDER_INCIDENT_DETAIL_ADDRESS+"?orderId="+base.getBusiness_id()+"&orderType="+Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT; //System.out.println("wxUrl------------------------>"+wxUrl); //发送消息 GG_MESSAGE message = new GG_MESSAGE(); message.setTitle(sc_workflow_incident.getName()) .setContent(sc_workflow_incident.getName()) .setSender_id(currentUserId) .setSender_name(currentUserName) .setSend_time(DateUtil.getCurrentDate14()) .setBusiness_id(base.getBusiness_id()) .setWeb_url(Constants.INCIDENT_WEB_MSG_URL+"?flowId="+base.getId()+"&orderId="+base.getBusiness_id()) .setWx_url(wxUrl) .setOrder_code(order_code) .setType(Constants.GG_MESSAGE_TYPE_SJGL); messageFacade.doSendMessage(message, dealerList); //所有的业务主键都是flowId(即流程主表的id) String flowId = base.getId(); //提交工单时添加关联工单 String[] orderId = request.getParameterValues("orderId"); orderService.saveLinkOrders(flowId,orderId,request); //提交工单时上传文档附件 //fileService.uploadFile(request,flowId,flowId,null,null,Constants.GG_FOLDERS_SJFOLDERS,Constants.FILE_STATE_SHTG,null); //提交工单时添加关联设备 String[] deviceId = request.getParameterValues("deviceId"); deviceService.saveLinkDevices(flowId,deviceId); //添加处理记录 GG_RECORD record = new GG_RECORD(); record.setDeal_content("创建事件："+userName+"创建了事件"); record.setDeal_user_id("1"); record.setDeal_user_name(userName); record.setBusiness_id(flowId); recordService.addRecord(record); SysInfoMsg msg = new SysInfoMsg(dtype,dealUserName,Constants.incidentNode.get(node_template_id)); resultMap.put("msg", msg); resultMap.put("incidentId", id); resultMap.put("result", 1); //增加该事件的SLA通知信息 addSlaNoticeMsg(id,createTime,sc_workflow_incident.getSla_id(),sc_workflow_incident.getCustomer_id(),sc_workflow_incident.getThird_category_id(),answerTimeoutTime,dealTimeoutTime,dealerList); return resultMap; } @Override public Map users(String threeServiceListId, String flowId, String customerId) { Map cacheMap = new HashMap(); String currentNode = new String(); if(StringUtil.notEmpty(flowId)) { Map node = getCurrentNode(flowId); currentNode = ConvertUtil.obj2StrBlank(node.get("NODE_TEMPLATE_ID")); } else { currentNode = Constants.KFRY; } //查询当前节点能发送的节点 String selectSql = "SELECT * FROM SC_WORKFLOW_INCIDENT_FLOWRULE WHERE PROJECT_ID = :projectId"; List list = baseDao.queryForList(selectSql,new SqlParameter("projectId",customerId)); if(null!=list && list.size()>0) { Map m = list.get(0); String json = ConvertUtil.obj2StrBlank(m.get(Constants.incidentNodeColunm.get(currentNode))); List nodes = JsonUtil.json2List(json); if(null!=nodes && nodes.size()>0) { for(Map n : nodes) { cacheMap.put(n.get("nodeId"), n); } } }else{ String gsSql = "SELECT * FROM SC_WORKFLOW_INCIDENT_FLOWRULE WHERE (PROJECT_ID IS NULL OR PROJECT_ID = '')"; List gslist = baseDao.queryForList(gsSql); if(null!=gslist && gslist.size()>0) { Map m = gslist.get(0); String json = ConvertUtil.obj2StrBlank(m.get(Constants.incidentNodeColunm.get(currentNode))); List nodes = JsonUtil.json2List(json); if(null!=nodes && nodes.size()>0) { for(Map n : nodes) { cacheMap.put(n.get("nodeId"), n); } } } } //查询该客户该项目对应的服务目录选择的服务目录人员 List serviceUsers = new ArrayList(); SC_SERVCE_CATEGORY cate = new SC_SERVCE_CATEGORY(threeServiceListId).getInstanceById(); Map serviceUserMap = slaPartnerFacade.querySlaUser(customerId,threeServiceListId,cate.getP_id(),3); if(serviceUserMap !=null && serviceUserMap.size() > 0){ Map yxMap = (Map)serviceUserMap.get("yxMap"); Map exMap = (Map)serviceUserMap.get("exMap"); Map sxMap = (Map)serviceUserMap.get("sxMap"); serviceUsers.add(yxMap); serviceUsers.add(exMap); serviceUsers.add(sxMap); } Map serviceUserCache = new HashMap(); Map serviceGroupCache = new HashMap(); String groupRole = "SELECT A.*,B.IDENTIFY FROM AC_ROLE_GROUP A,AC_ROLE B WHERE A.JSBH = B.ID "; List groupList = baseDao.queryForList(groupRole); String role = "SELECT * FROM AC_ROLE "; List roleList = baseDao.queryForList(role); Map cache = new HashMap(); for(Map map:groupList){ cache.put(map.get("ID"), map.get("IDENTIFY")); } Map cacheRole = new HashMap(); for(Map map:roleList){ cacheRole.put(map.get("ID"), map.get("IDENTIFY")); } for(Map serviceUser : serviceUsers) { String userType = ConvertUtil.obj2StrBlank(serviceUser.get("USER_TYPE")); if(userType.equals("1")) { String group_id = ConvertUtil.obj2StrBlank(serviceUser.get("GROUP_ID")); if(cache.containsKey(group_id)){ serviceGroupCache.put(group_id+cache.get(group_id), serviceUser); } } else { String user_id = ConvertUtil.obj2StrBlank(serviceUser.get("USER_ID")); String group_id = ConvertUtil.obj2StrBlank(serviceUser.get("GROUP_ID")); if(cacheRole.containsKey(group_id)){ serviceUserCache.put(user_id+cacheRole.get(group_id), serviceUser); } } } List kfry = new ArrayList(); List yczc = new ArrayList(); List yxgcs = new ArrayList(); List exgcs = new ArrayList(); List sxgcs = new ArrayList(); Map removeUser = new HashMap(); //查询出该项目组下的所有的人员 String userSql = "SELECT A.*,C.IDENTIFY FROM GG_USER A,AC_USER_REF_ROLE B,AC_ROLE C WHERE A.ID = B.YHBH AND B.JSBH = C.ID ORDER BY C.IDENTIFY ASC "; List users = baseDao.queryForList(userSql); List seluserList = new ArrayList(); //运维经理 SC_PARTNER_CUSTOMER_INFO customer = new SC_PARTNER_CUSTOMER_INFO(customerId).getInstanceById(); for(Map user : users) { String groupType = ConvertUtil.obj2StrBlank(user.get("IDENTIFY")); String userId = ConvertUtil.obj2StrBlank(user.get("ID")); String username = ConvertUtil.obj2StrBlank(user.get("ZSXM")); String unitKey = userId+groupType; if(serviceUserCache.containsKey(unitKey)||unitKey.equals(customer.getYwjl_id()+Constants.ROLE_OPERATION)) { user.put("type", 1); Map mapuser = new HashMap(); mapuser.put("id", "1-"+groupType+"-"+userId+"-"+username); mapuser.put("name", username); if(Constants.ROLE_SERVICE.equals(groupType)){ mapuser.put("type", "kf"); }else if(Constants.ROLE_OPERATION.equals(groupType)){ mapuser.put("type", "ywjl"); }else if(Constants.ROLE_FLINE.equals(groupType)){ mapuser.put("type", "yx"); }else if(Constants.ROLE_SLINE.equals(groupType)){ mapuser.put("type", "ex"); }else if(Constants.ROLE_TLINE.equals(groupType)){ mapuser.put("type", "sx"); } seluserList.add(mapuser); } else { user.put("type", 2); } if(groupType.equals(Constants.ROLE_SERVICE)) { if(!removeUser.containsKey(unitKey)) { if(!cacheMap.containsKey(Constants.KFRY)) { user.put("usered", 1); } kfry.add(user); removeUser.put(unitKey, user); } continue; } if(groupType.equals(Constants.ROLE_OPERATION)) { if(!removeUser.containsKey(unitKey)) { if(!cacheMap.containsKey(Constants.YCJSZC)) { user.put("usered", 1); } yczc.add(user); removeUser.put(unitKey, user); } continue; } if(groupType.equals(Constants.ROLE_FLINE)) { if(!removeUser.containsKey(unitKey)) { if(!cacheMap.containsKey(Constants.YXCL)) { user.put("usered", 1); } yxgcs.add(user); removeUser.put(unitKey, user); } continue; } if(groupType.equals(Constants.ROLE_SLINE)) { if(!removeUser.containsKey(unitKey)) { if(!cacheMap.containsKey(Constants.EXCL)) { user.put("usered", 1); } exgcs.add(user); removeUser.put(unitKey, user); } continue; } if(groupType.equals(Constants.ROLE_TLINE)) { if(!removeUser.containsKey(unitKey)) { if(!cacheMap.containsKey(Constants.SXCL)) { user.put("usered", 1); } sxgcs.add(user); removeUser.put(unitKey, user); } } } List zkfry = new ArrayList(); List zyczc = new ArrayList(); List zyxgcs = new ArrayList(); List zexgcs = new ArrayList(); List zsxgcs = new ArrayList(); for(Map group : groupList) { String groupType = ConvertUtil.obj2StrBlank(group.get("IDENTIFY")); String group_Id = ConvertUtil.obj2StrBlank(group.get("ID")); String group_Name = ConvertUtil.obj2StrBlank(group.get("GROUPNAME")); if(serviceGroupCache.containsKey(group_Id+groupType)) { group.put("type", 1); Map mapuser = new HashMap(); mapuser.put("id", "2-"+groupType+"-"+group_Id+"-"+group_Name); mapuser.put("name", group_Name); if(Constants.ROLE_SERVICE.equals(groupType)){ mapuser.put("type", "kf"); }else if(Constants.ROLE_OPERATION.equals(groupType)){ mapuser.put("type", "ywjl"); }else if(Constants.ROLE_FLINE.equals(groupType)){ mapuser.put("type", "yx"); }else if(Constants.ROLE_SLINE.equals(groupType)){ mapuser.put("type", "ex"); }else if(Constants.ROLE_TLINE.equals(groupType)){ mapuser.put("type", "sx"); } seluserList.add(mapuser); } else { group.put("type", 2); } if(groupType.equals(Constants.ROLE_FLINE)) { if(!cacheMap.containsKey(Constants.YXCL)) { group.put("usered", 1); } zyxgcs.add(group); continue; } if(groupType.equals(Constants.ROLE_SLINE)) { if(!cacheMap.containsKey(Constants.EXCL)) { group.put("usered", 1); } zexgcs.add(group); continue; } if(groupType.equals(Constants.ROLE_TLINE)) { if(!cacheMap.containsKey(Constants.SXCL)) { group.put("usered", 1); } zsxgcs.add(group); } } Map jskfry = new HashMap(); Map jsyczc = new HashMap(); Map jsyxgcs = new HashMap(); Map jsexgcs = new HashMap(); Map jssxgcs = new HashMap(); Map param = new HashMap(); String rolesql = "SELECT ID,ROLENAME FROM AC_ROLE WHERE IDENTIFY = :identify"; param.put("identify", Constants.ROLE_SERVICE); jskfry = baseDao.queryForMap(rolesql,param); param.put("identify", Constants.ROLE_OPERATION); jsyczc = baseDao.queryForMap(rolesql,param); param.put("identify", Constants.ROLE_FLINE); jsyxgcs = baseDao.queryForMap(rolesql,param); param.put("identify", Constants.ROLE_SLINE); jsexgcs = baseDao.queryForMap(rolesql,param); param.put("identify", Constants.ROLE_TLINE); jssxgcs = baseDao.queryForMap(rolesql,param); Map resultMap = new HashMap(); resultMap.put("kfry", kfry); resultMap.put("yczc", yczc); resultMap.put("yxgcs", yxgcs); resultMap.put("exgcs", exgcs); resultMap.put("sxgcs", sxgcs); resultMap.put("zkfry", zkfry); resultMap.put("zyczc", zyczc); resultMap.put("zyxgcs", zyxgcs); resultMap.put("zexgcs", zexgcs); resultMap.put("zsxgcs", zsxgcs); resultMap.put("jskfry", jskfry); resultMap.put("jsyczc", jsyczc); resultMap.put("jsyxgcs", jsyxgcs); resultMap.put("jsexgcs", jsexgcs); resultMap.put("jssxgcs", jssxgcs); int size = 1; if(cacheMap.containsKey(Constants.KFRY)) { resultMap.put("kf", 1); size++; } else { resultMap.put("kf", 2); } if(cacheMap.containsKey(Constants.YCJSZC)) { resultMap.put("sjjl", 1); size++; } else { resultMap.put("sjjl", 2); } if(cacheMap.containsKey(Constants.YXCL)) { resultMap.put("yx", 1); size++; } else { resultMap.put("yx", 2); } if(cacheMap.containsKey(Constants.EXCL)) { resultMap.put("ex", 1); size++; } else { resultMap.put("ex", 2); } if(cacheMap.containsKey(Constants.SXCL)) { resultMap.put("sx", 1); size++; } else { resultMap.put("sx", 2); } resultMap.put("size", size); resultMap.put("seluserList", seluserList); return resultMap; } public Map getCurrentNode(String flowId) { String selectSql = "SELECT B.NODE_TEMPLATE_ID FROM WORKFLOW_BASE A,WORKFLOW_NODE B WHERE A.CURRENT_NODE_ID = B.ID AND A.ID = :id"; return baseDao.queryForMap(selectSql,new SqlParameter("id",flowId)); } @Override public Map saveDispatchTask(HttpServletRequest request) { String type = new String(); Map resultMap = new HashMap(); resultMap.put("result", 2); String id = request.getParameter("id"); String selectUser = request.getParameter("userMsg"); String dealer_type = "1"; String dealUserId = new String(); String dealUserName = new String(); String state = new String(); String node_template_id = Constants.KFRY; if(StringUtil.notEmpty(selectUser)) { String[] userMsg = selectUser.split("-"); if(userMsg.length==4) { dealer_type = userMsg[0]; String userType = userMsg[1]; dealUserId = userMsg[2]; dealUserName = userMsg[3]; if(userType.equals(Constants.ROLE_SERVICE)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDFWT; node_template_id = Constants.KFRY; } else if(userType.equals(Constants.ROLE_OPERATION)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYCJSZC; node_template_id = Constants.YCJSZC; } else if(userType.equals(Constants.ROLE_FLINE)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDYX; node_template_id = Constants.YXCL; } else if(userType.equals(Constants.ROLE_SLINE)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDEX; node_template_id = Constants.EXCL; } else if(userType.equals(Constants.ROLE_TLINE)) { state = Constants.SC_WORKFLOW_INCIDENT_STATE_FPDSX; node_template_id = Constants.SXCL; } } } if(StringUtil.notEmpty(dealUserId) && StringUtil.notEmpty(dealUserName)) { //执行分派任务 WORKFLOW_BASE base = new WORKFLOW_BASE(id).getInstanceById(); NodeDealEntity entity = new NodeDealEntity(); entity.setDealer_type(3); List dealerList = new ArrayList(); if(dealer_type.equals("1")) { entity.setBefore_Dealer_type(2); Map map = new HashMap(); map.put("USER_ID", dealUserId); map.put("USER_NAME", dealUserName); map.put("IS_ADMIN", "1"); dealerList.add(map); entity.setDealerList(dealerList); type = "2"; } else { if(dealer_type.equals("2")){ type = "3"; }else{ type = "1"; } entity.setBefore_Dealer_type(1); entity.setRoleID(dealUserId); entity.setRoleName(dealUserName); //查询改组下面的所有人员信息 String selectUserSql = "SELECT B.ID AS USER_ID,B.ZSXM AS USER_NAME FROM AC_USER_REF_ROLE A,GG_USER B WHERE A.JSBH = :roleId AND A.YHBH = B.ID"; dealerList = baseDao.queryForList(selectUserSql,new SqlParameter("roleId",dealUserId)); if(dealerList == null || dealerList.size() == 0){ String groupusersql = "SELECT B.ID AS USER_ID ,B.ZSXM AS USER_NAME FROM AC_ROLE_GROUP_USER A,GG_USER B WHERE A.USER_ID = B.ID AND A.GROUP_ID = :groupId AND A.STATE = 1 "; dealerList = baseDao.queryForList(groupusersql,new SqlParameter("groupId",dealUserId)); if(dealerList == null || dealerList.size() == 0){ resultMap.put("result", 2); resultMap.put("nouser", 2); return resultMap; } } } String bz = request.getParameter("bz"); NodeFinishEntity finishEntity = new NodeFinishEntity(); finishEntity.setDeal_result(1); finishEntity.setDeal_note_title("节点转至 ：" + dealUserName); finishEntity.setDeal_note(bz); WORKFLOW_NODE node = new WORKFLOW_NODE(base.getCurrent_node_id()).getInstanceById(); boolean canFinish = workflowCoreService.finishNode(base, node, finishEntity); if (canFinish) { workflowBusinessService.toNode(base, node_template_id, entity); } //更新事件状态 String updateIncidentSql = "UPDATE SC_WORKFLOW_INCIDENT SET STATE = :state WHERE ID = :incidentId "; baseDao.execute(updateIncidentSql, new SqlParameter("state",state).addValue("incidentId", base.getBusiness_id())); Map user = WebUtil.getEngineerMsg(request); String userId = ConvertUtil.obj2StrBlank(user.get("ID")); String userName = ConvertUtil.obj2StrBlank(user.get("ZSXM")); String flowId = base.getId(); //增加事件处理记录 GG_RECORD record = new GG_RECORD(); record.setDeal_content("指派任务："+userName+"将事件指派给了"+dealUserName); record.setDeal_time(DateUtil.getCurrentDate14()); record.setDeal_user_id("1"); record.setDeal_user_name(userName); record.setBusiness_id(base.getId()); recordService.addRecord(record); String wxUrl = WechatConstants.ORDER_INCIDENT_DETAIL_ADDRESS+"?orderId="+base.getBusiness_id()+"&orderType="+Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT; //发送消息 GG_MESSAGE message = new GG_MESSAGE(); message.setTitle(base.getWfname()) .setContent(base.getWfname()) .setSender_id(userId) .setSender_name(userName) .setSend_time(DateUtil.getCurrentDate14()) .setBusiness_id(base.getBusiness_id()) .setWeb_url(Constants.INCIDENT_WEB_MSG_URL+"?flowId="+base.getId()+"&orderId="+base.getBusiness_id()) .setWx_url(wxUrl) .setOrder_code(base.getOrder_code()) .setType(Constants.GG_MESSAGE_TYPE_SJGL); messageFacade.doSendMessage(message, dealerList); resultMap.put("result", 1); //type = ConvertUtil.obj2StrBlank(entity.getBefore_Dealer_type()); } SysInfoMsg msg = new SysInfoMsg(type,dealUserName,Constants.incidentNode.get(node_template_id)); resultMap.put("msg", msg); return resultMap; } @Override public int checkFz(Map param) { String sql="select count(id) from AC_ROLE_GROUP_USER where GROUP_ID=:id and STATE=1"; return baseDao.queryForInteger(sql, param); } @Override public int checkJs(Map param) { String sql="select count(id) from AC_USER_REF_ROLE where JSBH=:id"; return baseDao.queryForInteger(sql, param); } }