package cn.ksource.web.facade.uc.order;

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

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

import cn.ksource.beans.SC_WORKFLOW_CI_REMIND;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.web.Constants;
import cn.ksource.web.service.order.OrderService;

@Service("ucCiRemindFacade")
public class UcCiRemindFacadeImpl implements UcCiRemindFacade {
	
	@Autowired
	private BaseDao baseDao;
	
	@Autowired
	private OrderService orderService;
	
	@Override
	public int queryRemindOrderCount(Map<String,String> params) {
		StringBuilder builder = new StringBuilder();
		
		params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND));
		
		builder = getAllRemindSql(builder,params);
		String sql = "select count(*) from ( " + builder.toString() + " ) t" ;
		return baseDao.queryForInteger(sql.toString(),params);
	}

	@Override
	public PageInfo queryRemindOrderList(PageInfo pageInfo,Map<String,String> params) {
		
		StringBuilder builder = new StringBuilder();
		
		params.put("businessType", ConvertUtil.obj2StrBlank(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND));
		
		builder = getAllRemindSql(builder,params);
		return baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), params);
	}

	/**
	 * 服务台工单列表
	 * @param request
	 * @return
	 */
	private StringBuilder getAllRemindSql(StringBuilder builder,Map<String,String> params){
		String flowState = params.get("flowState");
		String subCustomerId = params.get("subCustomerId");
		
		
		builder.append(" SELECT b.ID FLOWID,b.WFNAME,b.CREATERNAME,b.CREATETIME,b.CURRENT_NODE_NAME,b.BUSINESSTYPE, t.PLAN_EXECUTION_DATE, ");
		builder.append(" r.ORDER_CODE,r.ID ORDERID,r.SERVICE_CONTENT,b.CUSTOMER_NAME,b.SUB_CUSTOMER_NAME,B.WFSTATE  ");
		builder.append(" FROM SC_WORKFLOW_CI_REMIND r  ");
		builder.append(" INNER JOIN WORKFLOW_BASE B on r.FLOW_ID = b.ID INNER JOIN CI_REMIND_TIMERTASK t on r.FLOW_ID = t.FLOW_ID");
		builder.append(" WHERE  b.BUSINESSTYPE = :businessType ");
		//工单状态
		if(StringUtil.notEmpty(flowState)) {
			builder.append(" AND B.WFSTATE =:flowState ");
		}
		
		builder.append(" AND  B.CUSTOMER_ID = :cusId ");
		
		
		//下属单位
		if(StringUtil.isNotBlank(subCustomerId)) {
			builder.append(" AND b.SUB_CUSTOMER_ID = :subCustomerId ");
			
		}
		//工单编号
		String orderCode = params.get("orderCode");
		if(StringUtil.notEmpty(orderCode)) {
			builder.append(" AND r.ORDER_CODE LIKE :orderCode");
			params.put("orderCode", "%"+orderCode+"%");
		}
		builder.append(" ORDER BY b.CREATETIME DESC,t.PLAN_EXECUTION_DATE DESC");
		
		return builder;
	}
	
	@Override
	public List<Map> getRemindCiList(String orderId) {
		StringBuilder sql = new StringBuilder();
		sql.append(" select b.ID CIID,r.USER_NAME,r.DEAL_STATE,r.ID,c.NAME CATENAME,c.ID CATEID,b.CINAME,b.SEARCHCODE,b.POSITION from SC_WORKFLOW_CI_REMIND_DETAIL r  ");
		sql.append(" inner join cmdb_ci_base b   ");
		sql.append(" on r.CI_ID = b.ID   ");
		sql.append(" inner join cmdb_ci_category c   ");
		sql.append(" on b.LV3_ID  = c.ID   ");
		sql.append(" where r.ORDER_ID = :orderId  ");
		return baseDao.queryForList(sql.toString(),new SqlParameter("orderId",orderId));
	}
	
	@Override
	public Map getRemindeItem(String flowId) {
		Map param = new HashMap();
		param.put("flowId",flowId);
		StringBuilder sql = new StringBuilder();
		sql.append("SELECT * FROM SC_WORKFLOW_CI_REMIND c ");
		sql.append(" WHERE  c.FLOW_ID=:flowId");
		Map remindMap=baseDao.queryForMap(sql.toString(), param);
		Map map =new HashMap();
		if(remindMap!=null && remindMap.size()>0){
			//服务工程师
			StringBuilder selSql=new StringBuilder();
			selSql.append("SELECT A.CURRENT_DEALER_NAME,B.SJHM FROM workflow_node A,GG_USER B WHERE A.CURRENT_DEALER_ID=B.ID AND A.FLOWID=:flowId AND A.IS_ADMIN=1 AND A.NODE_TEMPLATE_ID=:nodeId");
			Map dealerMap=baseDao.queryForMap(selSql.toString(),new SqlParameter().addValue("flowId", flowId).addValue("nodeId", Constants.REMIND_DEAL));
			System.out.println(dealerMap);
			map.put("dealerMap", dealerMap);
			//应维护配置数量
			sql.setLength(0);
			param.put("orderId",remindMap.get("ID"));
			sql.append("SELECT ID FROM SC_WORKFLOW_CI_REMIND_DETAIL WHERE ORDER_ID=:orderId");
			List detailCountList=baseDao.queryForList(sql.toString(),param);
			map.put("detailCount", detailCountList.size());
			if(detailCountList==null || detailCountList.size()==0)map.put("detailCount", 0);
			//实际维护配置数量
			sql.setLength(0);
			param.put("state",Constants.CI_REMIND_DETAIL_STATE_ONE);
			sql.append("SELECT ID FROM SC_WORKFLOW_CI_REMIND_DETAIL WHERE ORDER_ID=:orderId AND DEAL_STATE=:state");
			List detailStateCountList=baseDao.queryForList(sql.toString(),param);
			map.put("detailStateCount", detailStateCountList.size());
			if(detailStateCountList==null || detailStateCountList.size()==0)map.put("detailStateCount", 0);
			//审核人
			sql.setLength(0);
			sql.append("SELECT * FROM WORKFLOW_NODE WHERE NODE_TEMPLATE_ID=:templateId AND FLOWID=:flowId ORDER BY CREATETIME DESC");
			param.put("templateId", "04e5ae6861fd4ef6bbc521e30b4d11bc");
			param.put("flowId", flowId);
			List<Map> nodeList=baseDao.queryForList(sql.toString(), param);
			if(nodeList!=null && nodeList.size()>0){
				map.put("node", nodeList.get(0));
			}
			//文档列表
			String fileSql = "select * from GG_FILES where EXTEND1=:BUSINESS_ID AND DEL_FLAG = 1 order by  ORDERNUM";
			List<Map> fileList = baseDao.queryForList(fileSql,new SqlParameter("BUSINESS_ID",flowId));
			map.put("fileList", fileList);
			//涉及工单列表
			List<Map> orderList=orderService.queryLinkOrders(flowId);
			if(orderList!=null && orderList.size()>0){
				for(Map orderMap:orderList){
					orderMap.put("WFSTATE", Constants.getWORKFLOW_BASE_WFSTATE_Label(orderMap.get("WFSTATE").toString()));
				}
			}
			map.put("orderList", orderList);
		}
		map.put("remindMap", remindMap);
		return map;
	}
	
	@Override
	public Map getPatrolInfo(String patrolId) {
		String sql = " select * from SC_WORKFLOW_CI_REMIND_DETAIL where id = :patrolId";
		SqlParameter param = new SqlParameter();
		param.addValue("patrolId", patrolId);
		return baseDao.queryForMap(sql, param);
	}
	
	@Override
	public Map getRemindDetail(String orderId) {
		Map param=new HashMap();
		param.put("orderId", orderId);
		StringBuilder sql=new StringBuilder();
		sql.append("SELECT c.USER_NAME,c.ORDER_NOTE,b.CINAME,b.POSITION,c.FINISH_TIME,c.DEAL_STATE FROM SC_WORKFLOW_CI_REMIND_DETAIL c,CMDB_CI_BASE b ");
		sql.append(" WHERE c.CI_ID=b.ID AND c.ORDER_ID=:orderId");
		List<Map> detailList=baseDao.queryForList(sql.toString(),param);
		if(detailList!=null && detailList.size()>0){
			for(Map map :detailList){
				map.put("DEAL_STATE", Constants.getmapCI_REMIND_DETAIL_STATE(Integer.parseInt(map.get("DEAL_STATE").toString())));
			}
		}
		SC_WORKFLOW_CI_REMIND remind = new SC_WORKFLOW_CI_REMIND(orderId).getInstanceById();
		Map map = new HashMap();
		map.put("remind", remind);
		map.put("detailList", detailList);
		return map;
	}

}