package cn.ksource.core.workflow;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import cn.ksource.beans.*;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.web.Constants;

@Service
public class WorkflowBusinessServiceImpl implements WorkflowBusinessService {
	@Autowired
    private BaseDao baseDao;
	
	@Autowired
	private WorkflowCoreService workflowCoreService;
	
	
	public void toNode(WORKFLOW_BASE base,String node_template_id,NodeDealEntity entity){
		workflowCoreService.toNode(base, node_template_id, entity);
	}
	
	@Override
	public List<Map> getBackTemplateNodeList(
			String nodeInstanceId) {
		StringBuilder sql = new StringBuilder();
		sql.append("select tn.* ");
		sql.append("from workflow_template_node tn ");
		sql.append("where tn.ID in (select ROLEBACKNODEID from workflow_roleback_node where  ");
		sql.append("NODETEMPLEID in (select NODE_TEMPLATE_ID from workflow_node where ID=:id))");
		
		return baseDao.queryForList(sql.toString(), new SqlParameter().addValue("id", nodeInstanceId));
	}


	@Override
	public WORKFLOW_BASE toBack(String workflowInstanceId,
			String nodeInstanceId, String userId,
			Integer result, String note, String backNodeTemplateId) {
		GG_USER user = new GG_USER(userId).getInstanceById();
		String userName = user != null ? user.getZsxm() : "";
		
		WorkflowDealEntity entity = new WorkflowDealEntity();
		entity.setBackNodeId(backNodeTemplateId);
		entity.setNodeInstanceId(nodeInstanceId);
		entity.setNote(note);
		entity.setResult(result);
		entity.setUserId(userId);
		entity.setUserName(userName);
		entity.setWfInstanceId(workflowInstanceId);
		
		workflowCoreService.toBack(entity, new HashMap());
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}

	@Override
	public WORKFLOW_BASE toNext(String workflowInstanceId,
			String nodeInstanceId, String userId,
			Integer result, String note) {
		GG_USER user = new GG_USER(userId).getInstanceById();
		String userName = user != null ? user.getZsxm() : "";
		
		WorkflowDealEntity entity = new WorkflowDealEntity();
		entity.setNodeInstanceId(nodeInstanceId);
		entity.setNote(note);
		entity.setResult(result);
		entity.setUserId(userId);
		entity.setUserName(userName);
		entity.setWfInstanceId(workflowInstanceId);
		
		//上一环节指定人员时，主要负责人可以推动流程到下一节点，其他负责人只能更新本节点状态
		WORKFLOW_NODE node = new WORKFLOW_NODE(nodeInstanceId).getInstanceById();
		if (node.getDeal_type() - Constants.WORKFLOW_TEMPLATE_NODE_DEALER_TYPE_ASSIGN == 0 && !isAdminWorkflowNode(workflowInstanceId, nodeInstanceId, userId)) {
			workflowCoreService.toNextByPartner(entity, new HashMap());
		} else {
			workflowCoreService.toNext(entity, new HashMap());
		}
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}

	@Override
	public WORKFLOW_BASE toNext(String workflowInstanceId,
			String nodeInstanceId, String userId,
			Integer result, String note, List<WorkflowDutyerEntity> dutyers) {
		
		GG_USER user = new GG_USER(userId).getInstanceById();
		String userName = user != null ? user.getZsxm() : "";
		
		WorkflowDealEntity entity = new WorkflowDealEntity();
		entity.setNodeInstanceId(nodeInstanceId);
		entity.setNote(note);
		entity.setResult(result);
		entity.setUserId(userId);
		entity.setUserName(userName);
		entity.setWfInstanceId(workflowInstanceId);
		
		//上一环节指定人员时，主要负责人可以推动流程到下一节点，其他负责人只能更新本节点状态
		WORKFLOW_NODE node = new WORKFLOW_NODE(nodeInstanceId).getInstanceById();
		if (node.getDeal_type() - Constants.WORKFLOW_TEMPLATE_NODE_DEALER_TYPE_ASSIGN == 0 && !isAdminWorkflowNode(workflowInstanceId, nodeInstanceId, userId)) {
			workflowCoreService.toNextByPartner(entity, new HashMap());
		} else {
			workflowCoreService.toNext(entity, dutyers, new HashMap());
		}
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}


	@Override
	public WORKFLOW_BASE closeWorkflow(String workflowInstanceId,
			String nodeInstanceId, String userId, Integer result, String note) {
		
		GG_USER user = new GG_USER(userId).getInstanceById();
		String userName = user != null ? user.getZsxm() : "";
		
		WorkflowDealEntity entity = new WorkflowDealEntity();
		entity.setNodeInstanceId(nodeInstanceId);
		entity.setNote(note);
		entity.setResult(result);
		entity.setUserId(userId);
		entity.setUserName(userName);
		entity.setWfInstanceId(workflowInstanceId);
		
		workflowCoreService.handCloseWorkflow(entity, new HashMap());
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}

	@Override
	public WORKFLOW_BASE finishWorkflow(String workflowInstanceId,
			String nodeInstanceId, String userId, Integer result, String note) {
		GG_USER user = new GG_USER(userId).getInstanceById();
		String userName = user != null ? user.getZsxm() : "";
		
		WorkflowDealEntity entity = new WorkflowDealEntity();
		entity.setNodeInstanceId(nodeInstanceId);
		entity.setNote(note);
		entity.setResult(result);
		entity.setUserId(userId);
		entity.setUserName(userName);
		entity.setWfInstanceId(workflowInstanceId);
		
		workflowCoreService.handFinishWorkflow(entity, new HashMap());
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}

	@Override
	public boolean isAdminWorkflowNode(String flowId, String nodeId, String userId) {
		
		StringBuilder sql = new StringBuilder();
		sql.append("select count(u.ID) ");
		sql.append("from workflow_template_node_user u ");
		sql.append("where u.NODE_ID=(select NODE_TEMPLATE_ID from workflow_node where ID=:id) ");
		sql.append("and u.USER_ID=:user_id ");
		sql.append("and u.IS_ADMIN=1 ");
		sql.append("and u.FLOW_INSTANCE_ID=:flow_instance_id ");
		
		SqlParameter param = new SqlParameter();
		param.addValue("id", nodeId);
		param.addValue("user_id", userId);
		param.addValue("flow_instance_id", flowId);
		
		return baseDao.queryForInteger(sql.toString(), param) > 0 ? true : false;
	}

	@Override
	public WORKFLOW_BASE updateWorkflowState(String workflowInstanceId,
			Integer wfstate) {
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById()
		.setWfstate(wfstate)
		.update();
	}
    
	/**
	 * 获取报修设备信息
	 * @param businessId
	 * @return
	 */
	private List<Map> queryCiRepairDetail(String businessId) {
		String sql = "select CI_ID,CI_NAME from sc_workflow_ci_repair_ci where BUSINESS_ID=:business_id ";
		
		SqlParameter param = new SqlParameter();
		param.addValue("business_id", businessId);
		
		return baseDao.queryForList(sql, param);
		
	}

	/**
	 * 获取变更设备信息
	 * @param businessId
	 * @return
	 */
	private List<Map> queryCiChangeDetail(String businessId) {
		String sql = "select CI_ID,CI_NAME from sc_workflow_ci_change_ci where BUSINESS_ID=:business_id ";
		
		SqlParameter param = new SqlParameter();
		param.addValue("business_id", businessId);
		
		return baseDao.queryForList(sql, param);
		
	}
	
	/**
	 * 获取新增、变更、报废设备信息
	 * @param businessId
	 * @return
	 */
	private List<Map> queryCiReferDetail(String businessId, int referType) {
		String sql = "select CI_ID,CI_NAME from sc_workflow_ci_refer where BUSINESS_ID=:business_id and REFER_TYPE=:refer_type ";
		
		SqlParameter param = new SqlParameter();
		param.addValue("business_id", businessId);
		param.addValue("refer_type", referType);
		
		return baseDao.queryForList(sql, param);
		
	}
	
	
	@Override
	public WORKFLOW_BASE startCIRemindWorkflow(String businessId) {
		//获取提醒申请信息
		SC_WORKFLOW_CI_REMIND remind = new SC_WORKFLOW_CI_REMIND().setId(businessId).queryForBean();
		if (remind == null) {
			return null;
		}
		
		//启动智能提醒流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND);
		startEntity.setCustomerId(remind.getCustomer_id());
		startEntity.setFlowName(remind.getName());
		startEntity.setOrderCode(remind.getOrder_code());
		startEntity.setCustomerName(remind.getCustomer_name());
		startEntity.setUserName("系统定时任务");
		//服务内容说明
		startEntity.setWfNote(remind.getService_content());
		startEntity.setSubCustomerId(remind.getSub_customer_id());
		startEntity.setSubCustomerName(remind.getSub_customer_name());
		
		//客户加盟商信息
		SC_PARTNER_CUSTOMER_INFO customer = new SC_PARTNER_CUSTOMER_INFO().setId(remind.getCustomer_id()).queryForBean();
		if (customer != null) {
			
		}
		//获取智能提醒设备
		//List<Map> ciList = this.queryCiRemindCi(businessId);
		//startEntity.setCiList(ciList);
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, new HashMap());
		//反写智能提醒表中流程编号
		if (work_base != null) {
			remind.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}
	
	/**
	 * 获取智能提醒设备信息
	 * @param businessId
	 * @return
	 */
	private List<Map> queryCiRemindCi(String businessId) {
		String sql = "select CI_ID,CI_NAME from sc_workflow_ci_remind_ci where BUSINESS_ID=:business_id ";
		
		SqlParameter param = new SqlParameter();
		param.addValue("business_id", businessId);
		
		return baseDao.queryForList(sql, param);
		
	}
	
	@Override
	public WORKFLOW_BASE startCIHealthWorkflow(String businessId) {
		//获取体检申请信息
		SC_WORKFLOW_CI_HEALTH health = new SC_WORKFLOW_CI_HEALTH(businessId).getInstanceById();
		if (health == null) {
			return null;
		}
		
		//启动健康检查流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH);
		startEntity.setCustomerId(health.getCustomer_id());
		startEntity.setCustomerName(health.getCustomer_name());
		startEntity.setFlowName(health.getName());
		
		startEntity.setSubCustomerId(health.getSub_customer_id());
		startEntity.setSubCustomerName(health.getSub_customer_name());
		
		startEntity.setOrderCode(health.getOrder_code());
		//申请人指定为客户
		startEntity.setUserId("");
		startEntity.setUserName("系统定时任务");
		
		//获取健康体检设备
		//List<Map> ciList = this.queryCiHealthCi(businessId);
		//startEntity.setCiList(ciList);
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, new HashMap());
		
		//反写健康检查申请表中流程编号
		if (work_base != null) {
			health.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}

	@Override
	public WORKFLOW_BASE toLast(String workflowInstanceId,
			String nodeInstanceId, String userId, Integer result, String note) {

		GG_USER user = new GG_USER(userId).getInstanceById();
		String userName = user != null ? user.getZsxm() : "";
		
		WorkflowDealEntity entity = new WorkflowDealEntity();
		entity.setNodeInstanceId(nodeInstanceId);
		entity.setNote(note);
		entity.setResult(result);
		entity.setUserId(userId);
		entity.setUserName(userName);
		entity.setWfInstanceId(workflowInstanceId);
		
		workflowCoreService.toLast(entity, new HashMap());
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}
	
	/**
	 * 获取健康检查设备信息
	 * @param businessId
	 * @return
	 */
	private List<Map> queryCiHealthCi(String businessId) {
		String sql = "select CI_ID,CI_NAME from sc_workflow_ci_health_ci where BUSINESS_ID=:business_id ";
		
		SqlParameter param = new SqlParameter();
		param.addValue("business_id", businessId);
		
		return baseDao.queryForList(sql, param);
	}

	@Override
	public WORKFLOW_NODE getLastWorkflowNode(String flowId, String nodeId) {
		String sql = "select * from workflow_node where FLOWID=:flowid and ID<>:id and FLOWSTATE=3 order by CREATETIME desc limit 0,1 ";
		SqlParameter param = new SqlParameter();
		param.addValue("flowid", flowId);
		param.addValue("id", nodeId);
		
		return baseDao.queryForBean(sql, param, new WORKFLOW_NODE());
	}

	@Override
	public WORKFLOW_BASE toNode(int nodeNum, String workflowInstanceId,
			String nodeInstanceId, String userId, Integer result, String note,
			List<WorkflowDutyerEntity> dutyers) {
		GG_USER user = new GG_USER(userId).getInstanceById();
		String userName = user != null ? user.getZsxm() : "";
		
		WorkflowDealEntity entity = new WorkflowDealEntity();
		entity.setNodeInstanceId(nodeInstanceId);
		entity.setNote(note);
		entity.setResult(result);
		entity.setUserId(userId);
		entity.setUserName(userName);
		entity.setWfInstanceId(workflowInstanceId);
		
	    workflowCoreService.toNode(nodeNum, entity, dutyers, new HashMap());
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}

	@Override
	public WORKFLOW_BASE startIncidentWorkflow(String businessId,String bz) {
		//获取事件申请信息
		SC_WORKFLOW_INCIDENT incident = new SC_WORKFLOW_INCIDENT(businessId).getInstanceById();
		if (incident == null) {
			return null;
		}
		
		//启动事件流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT);
		startEntity.setCustomerId(incident.getCustomer_id());
		startEntity.setCustomerName(incident.getCustomer_name());
		startEntity.setFlowName(incident.getFlow_name());
		startEntity.setOrderCode(incident.getOrder_code());
		startEntity.setUserId(incident.getCreate_user_id());
		startEntity.setUserName(incident.getCreate_user_name());
		startEntity.setWfNote(incident.getDescrip());
		startEntity.setSubCustomerId(incident.getSub_customer_id());
		startEntity.setSubCustomerName(incident.getSub_customer_name());
		startEntity.setNote(incident.getDescrip());
		
		//获取关联设备
		/*List<Map> ciList = this.queryIncidentCi(businessId);
		startEntity.setCiList(ciList);*/
		
		Map map = new HashMap();
		map.put("bz", bz);
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, map);
		
		if (work_base != null) {
			incident.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}
	/**
	 * 入库流程
	 */
	@Override
	public WORKFLOW_BASE startStockWorkflow(String businessId,String bz) {
		//获取事件申请信息
		SPARE_PART_STORAGE incident = new SPARE_PART_STORAGE(businessId).getInstanceById();
		if (incident == null) {
			return null;
		}
		
		//启动事件流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_STOCK);
		startEntity.setFlowName(incident.getOrder_name());
		startEntity.setOrderCode(incident.getOrder_code());
		startEntity.setUserId(incident.getCreate_id());
		startEntity.setUserName(incident.getCreate_name());
		startEntity.setWfNote(incident.getStorage_reason());
		Map map = new HashMap();
		map.put("bz", bz);
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, map);
		
		if (work_base != null) {
			incident.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}
	/**
	 * 备件申领流程
	 */
	@Override
	public WORKFLOW_BASE startSpareWorkflow(String businessId,String bz) {
		//获取事件申请信息
		SPARE_PART_APPLY incident = new SPARE_PART_APPLY(businessId).getInstanceById();
		if (incident == null) {
			return null;
		}
		
		//启动事件流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_SPARE);
		startEntity.setFlowName(incident.getOrder_name());
		startEntity.setOrderCode(incident.getOrder_code());
		startEntity.setUserId(incident.getCreate_id());
		startEntity.setUserName(incident.getCreate_name());
		startEntity.setWfNote(incident.getApply_reason());
		Map map = new HashMap();
		map.put("bz", bz);
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, map);
		
		if (work_base != null) {
			incident.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}
	
	/**
	 * 出库申请流程
	 */
	@Override
	public WORKFLOW_BASE startDeliveryWorkflow(String businessId,String bz) {
		//获取事件申请信息
		SPARE_PART_DELIVERY incident = new SPARE_PART_DELIVERY(businessId).getInstanceById();
		if (incident == null) {
			return null;
		}
		
		//启动事件流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CKLC);
		startEntity.setFlowName(incident.getOrder_name());
		startEntity.setOrderCode(incident.getOrder_code());
		startEntity.setUserId(incident.getCreate_id());
		startEntity.setUserName(incident.getCreate_name());
		startEntity.setWfNote(incident.getDelivery_reason());
		Map map = new HashMap();
		map.put("bz", bz);
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, map);
		
		if (work_base != null) {
			incident.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}
	
	/**
	 * 报损报溢流程
	 */
	@Override
	public WORKFLOW_BASE startOverageLossWorkflow(String businessId,String bz) {
		//获取事件申请信息
		OVERAGE_LOSS incident = new OVERAGE_LOSS(businessId).getInstanceById();
		if (incident == null) {
			return null;
		}
		
		//启动事件流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_BSBY);
		startEntity.setFlowName(incident.getOrder_name());
		startEntity.setOrderCode(incident.getOrder_code());
		startEntity.setUserId(incident.getCreate_id());
		startEntity.setUserName(incident.getCreate_name());
		startEntity.setWfNote(incident.getNote());
		Map map = new HashMap();
		map.put("bz", bz);
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, map);
		
		if (work_base != null) {
			incident.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}
	@Override
	public WORKFLOW_BASE startInventoryWorkflow(String businessId,String bz) {
		//获取事件申请信息
		STOCK_INVENTORY stockInventory = new STOCK_INVENTORY(businessId).getInstanceById();
		if (stockInventory == null) {
			return null;
		}
		//启动库存盘点
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_KCPD);
		startEntity.setFlowName(stockInventory.getOrder_name());
		startEntity.setOrderCode(stockInventory.getOrder_code());
		startEntity.setUserId(stockInventory.getCreate_id());
		startEntity.setUserName(stockInventory.getCreate_name());
		startEntity.setWfNote(stockInventory.getNote());
		Map map = new HashMap();
		map.put("bz", bz);
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, map);

		if (work_base != null) {
			stockInventory.setFlow_id(work_base.getId()).update();
		}
		return work_base;
	}

	public WORKFLOW_BASE startIncident_LocalWorkflow(String businessId, String bz){
		//获取事件申请信息
		SC_WORKFLOW_INCIDENT_LOCAL incident = new SC_WORKFLOW_INCIDENT_LOCAL(businessId).getInstanceById();
		if (incident == null) {
			return null;
		}
		
		//启动事件流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT_LOCAL);
		startEntity.setCustomerId(incident.getCustomer_id());
		startEntity.setCustomerName(incident.getCustomer_name());
		startEntity.setFlowName(incident.getFlow_name());
		startEntity.setOrderCode(incident.getOrder_code());
		startEntity.setUserId(incident.getCreate_user_id());
		startEntity.setUserName(incident.getCreate_user_name());
		startEntity.setWfNote(incident.getDescrip());
		startEntity.setSubCustomerId(incident.getSub_customer_id());
		startEntity.setSubCustomerName(incident.getSub_customer_name());;
		
		//获取关联设备
		/*String sql = "select CI_ID,CI_NAME from SC_WORKFLOW_INCIDENT_LOCAL_CI where BUSINESS_ID=:business_id ";
		
		SqlParameter param = new SqlParameter();  
		param.addValue("business_id", businessId);  
		
		List<Map> ciList = baseDao.queryForList(sql, param);  
		
		startEntity.setCiList(ciList);   */
		
		
		Map map = new HashMap();
		map.put("bz", bz);
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, map);
		
		//反写健康检查申请表中流程编号
		if (work_base != null) {
			incident.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}
	
	
	public WORKFLOW_BASE startQuestionWorkflow(String businessId,String bz){
		
		//获取问题信息
		SC_WORKFLOW_QUESTION incident = new SC_WORKFLOW_QUESTION(businessId).getInstanceById();
		if (incident == null) {
			return null;
		}
		
		//启动问题流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_QUESTION);
		startEntity.setCustomerId(incident.getCustomer_id());
		startEntity.setCustomerName(incident.getCustomer_name());
		startEntity.setFlowName(incident.getFlow_name());
		startEntity.setOrderCode(incident.getOrder_code());
		startEntity.setUserId(incident.getCreate_user_id());
		startEntity.setUserName(incident.getCreate_user_name());
		startEntity.setWfNote(incident.getDescrip());
		startEntity.setSubCustomerId(incident.getSub_customer_id());
		startEntity.setSubCustomerName(incident.getSub_customer_name());
		startEntity.setNote(bz);
		Map map = new HashMap();
		map.put("bz", bz);
		//获取关联设备
		/*String sql = "select CI_ID,CI_NAME from SC_WORKFLOW_INCIDENT_LOCAL_CI where BUSINESS_ID=:business_id ";
		
		SqlParameter param = new SqlParameter();  
		param.addValue("business_id", businessId);  
		
		List<Map> ciList = baseDao.queryForList(sql, param);  
		
		startEntity.setCiList(ciList);  */ 
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, map);
		
		//反写健康检查申请表中流程编号
		if (work_base != null) {
			incident.setFlow_id(work_base.getId())
			.update();
		}
		return work_base;
	}
	
	
	
	
	
	private List<Map> queryIncidentCi(String businessId) {
        String sql = "select CI_ID,CI_NAME from sc_workflow_incident_ci where BUSINESS_ID=:business_id ";
		
		SqlParameter param = new SqlParameter();
		param.addValue("business_id", businessId);
		
		return baseDao.queryForList(sql, param);
	}

	@Override
	public WORKFLOW_BASE resetNodeDealer(String workflowInstanceId,
			String nodeInstanceId, String userId, String userName) {
		
		//更新节点处理人，角色置空
		new WORKFLOW_NODE().setId(nodeInstanceId)
		.setCurrent_dealer_id(userId)
		.setCurrent_dealer_name(userName)
		.setCurrent_deal_roleida("")
		.setCurrent_deal_rolename("")
		.update();
		
		//更新流程处理人
		new WORKFLOW_BASE().setId(workflowInstanceId)
		.setCurrent_dealer_id(userId)
		.setCurrent_dealer_name(userName)
		.setCurrent_deal_roleida("")
		.setCurrent_deal_rolename("")
		.update();
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}

	@Override
	public WORKFLOW_BASE deleteWorkflow(String workflowInstanceId,
			String nodeInstanceId, String userId, Integer result, String note) {
		GG_USER user = new GG_USER(userId).getInstanceById();
		String userName = user != null ? user.getZsxm() : "";
		
		WorkflowDealEntity entity = new WorkflowDealEntity();
		entity.setNodeInstanceId(nodeInstanceId);
		entity.setNote(note);
		entity.setResult(result);
		entity.setUserId(userId);
		entity.setUserName(userName);
		entity.setWfInstanceId(workflowInstanceId);
		
		workflowCoreService.handDeleteWorkflow(entity, new HashMap());
		
		return new WORKFLOW_BASE(workflowInstanceId).getInstanceById();
	}

	public WORKFLOW_BASE startChangeWorkflow(String businessId){

		//获取问题信息
		SC_WORKFLOW_CHANGE incident = new SC_WORKFLOW_CHANGE(businessId).getInstanceById();
		if (incident == null) {
			return null;
		}

		//启动问题流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_CHANGE);
		startEntity.setCustomerId(incident.getCustomer_id());
		startEntity.setCustomerName(incident.getCustomer_name());
		startEntity.setFlowName(incident.getFlow_name());
		startEntity.setOrderCode(incident.getOrder_code());
		startEntity.setUserId(incident.getCreate_user_id());
		startEntity.setUserName(incident.getCreate_user_name());
		startEntity.setWfNote(incident.getDescrip());
		startEntity.setProjectId(incident.getProject_id());
		startEntity.setProjectName(incident.getProject_name());
		startEntity.setSubCustomerId(incident.getSub_customer_id());
		startEntity.setSubCustomerName(incident.getSub_customer_name());

		//客户加盟商信息
		SC_PARTNER_CUSTOMER_INFO customer = new SC_PARTNER_CUSTOMER_INFO().setId(incident.getCustomer_id()).queryForBean();

		//获取关联设备
		/*String sql = "select CI_ID,CI_NAME from SC_WORKFLOW_INCIDENT_LOCAL_CI where BUSINESS_ID=:business_id ";

		SqlParameter param = new SqlParameter();
		param.addValue("business_id", businessId);

		List<Map> ciList = baseDao.queryForList(sql, param);

		startEntity.setCiList(ciList);  */

		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, new HashMap());

		//反写健康检查申请表中流程编号
		if (work_base != null) {
			incident.setFlow_id(work_base.getId())
					.update();
		}
		return work_base;
	}
	
	@Override
	public WORKFLOW_BASE startReleaseWorkflow(String businessId,String note) {
		//获取新增申请信息
		SC_WORKFLOW_RELEASE release = new SC_WORKFLOW_RELEASE().setId(businessId).getInstanceById();
		if (release == null) {
			return null;
		}
		
		//启动新增流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_RELEASE);
		startEntity.setCustomerId(release.getCustomer_id());
		startEntity.setCustomerName(release.getCustomer_name());
		//startEntity.setFlowName("发布管理-"+release.getOrder_code());
		startEntity.setFlowName(release.getName());
		startEntity.setOrderCode(release.getOrder_code());
		startEntity.setUserId(release.getRelease_user_id());
		startEntity.setUserName(release.getRelease_user_name());
		startEntity.setProjectId(release.getProject_id());
		startEntity.setProjectName(release.getProject_name());
		startEntity.setSubCustomerId(release.getSub_customer_id());
		startEntity.setSubCustomerName(release.getSub_customer_name());
		startEntity.setNote(note);
		//客户加盟商信息
		SC_PARTNER_CUSTOMER_INFO customer = new SC_PARTNER_CUSTOMER_INFO().setId(release.getCustomer_id()).queryForBean();
		/*if (customer != null) {
			startEntity.setPartnerId(customer.getPartner_id());
			startEntity.setPartnerName(customer.getPartner_name());
		}*/
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, new HashMap());
		
		//反写新增申请表中流程编号
		if (work_base != null) {
			release.setFlow_id(work_base.getId())
			.update();
		}
		
		return work_base;
	}
	
	@Override
	public WORKFLOW_BASE startCIAddWorkflow(String businessId) {
		//获取新增申请信息
		SC_WORKFLOW_CI_ADD add = new SC_WORKFLOW_CI_ADD().setId(businessId).getInstanceById();
		if (add == null) {
			return null;
		}
		
		//启动新增流程
		WorkflowStartEntity startEntity = new WorkflowStartEntity();
		startEntity.setBusinessId(businessId);
		startEntity.setBusinessType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_ADD);
		startEntity.setCustomerId(add.getCustomer_id());
		startEntity.setCustomerName(add.getCustomer_name());
		startEntity.setFlowName(add.getFlow_name());
		startEntity.setOrderCode(add.getOrder_code());
		startEntity.setUserId(add.getApply_user_id());
		startEntity.setUserName(add.getApply_user_name());
		startEntity.setNote(add.getApply_reason());
		
		/*//客户加盟商信息
		SC_PARTNER_CUSTOMER_INFO customer = new SC_PARTNER_CUSTOMER_INFO().setId(add.getCustomer_id()).queryForBean();
		if (customer != null) {
			startEntity.setPartnerId(customer.getPartner_id());
			startEntity.setPartnerName(customer.getPartner_name());
		}*/
		
		WORKFLOW_BASE work_base = workflowCoreService.startWorkflow(startEntity, new HashMap());
		
		//反写新增申请表中流程编号
		if (work_base != null) {
			add.setFlow_id(work_base.getId())
			.update();
		}
		
		return work_base;
	}

}