package quartz;

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

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import com.amarsoft.are.jbo.BizObject;
import com.amarsoft.are.jbo.BizObjectManager;
import com.amarsoft.are.jbo.JBOException;
import com.amarsoft.are.jbo.JBOFactory;
import com.amarsoft.are.jbo.JBOTransaction;
import com.amarsoft.are.util.StringFunction;
import com.base.util.QuartzUtil;
//import com.tenwa.action.channelportal.ContractSignAction;
//import com.tenwa.action.channelportal.comm.ContractTransferRightForEnd;
import com.tenwa.comm.util.jboutil.DataOperatorUtil;
import com.tenwa.lease.app.quartzmession.JobInitUserName;

import jbo.com.tenwa.lease.comm.DAY_DISTRIBUTE;
import jbo.com.tenwa.lease.comm.VI_AUTODISTRIBUTE;
import jbo.sys.OVERDUE_DUNNING_INFO;

public class AutoDistribute implements Job {
	private JobInitUserName jboName;
	//指定的北财催款员id（正式环境需要修改）
	private String beicaiUserID = "8009011U00000021";
	
	
	@Override
	public void execute(JobExecutionContext arg0) throws JobExecutionException {
		String startime = StringFunction.getTodayNow();

		Object userId = arg0.getTrigger().getJobDataMap().get("CurUserId");
		String curUserId = userId == null ? "system" : userId.toString();
		JBOTransaction tx = null;
		try {
			tx = JBOFactory.createJBOTransaction();
			//给非北财分配催款员
			ownershipTransferSign(tx, arg0);
			//北财逾期的合同分配给指定催款员
			distributeBeicai(tx, arg0);
			QuartzUtil.insertLog(startime, "quartz.AutoDistribute", "success","成功", curUserId);
		} catch (Exception e) {
			QuartzUtil.insertLog(startime, "quartz.AutoDistribute", "error","失败", curUserId);
			e.printStackTrace();
			try {
				if(tx!=null)tx.rollback();
			} catch (JBOException e1) {
				e1.printStackTrace();
			}
		}finally {
			try {
				if(tx!=null)tx.commit();
			} catch (JBOException e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 北财逾期的合同分配给指定催款员
	 * @param tx
	 * @param arg0
	 * @throws JBOException 
	 */
	public void distributeBeicai(JBOTransaction tx, JobExecutionContext arg0)  {
		try {
		// 获取所有逾期的需要催收的合同信息
		BizObjectManager bom;
		BizObjectManager overdueManager;
		
		overdueManager = JBOFactory.getBizObjectManager(OVERDUE_DUNNING_INFO.CLASS_NAME, tx);
		bom = JBOFactory.getBizObjectManager(VI_AUTODISTRIBUTE.CLASS_NAME, tx);
		@SuppressWarnings("unchecked")
		List<BizObject> boList = bom.createQuery("SELECT O.id,O.over_days FROM O WHERE O.project_manage IN (SELECT ur.userid FROM jbo.awe.USER_ROLE ur WHERE ur.roleid ='800R00000044')").getResultList(false);
		for (BizObject bo : boList) {
			String contractId = bo.getAttribute("id").toString();
			
			//查询是否已经有催款员(目前北财只有一个指定的催款员)			
			BizObject overdue = overdueManager.createQuery("contract_id=:contract_id").setParameter("contract_id", contractId).getSingleResult(false);
			if(overdue == null){
				BizObject overdueBizObject = overdueManager.newObject();
				String uuid = UUID.randomUUID().toString().replace("-", "");
				
				overdueBizObject.setAttributeValue("id", uuid);
				overdueBizObject.setAttributeValue("part_dept", beicaiUserID);
				overdueBizObject.setAttributeValue("contract_id", contractId);
				overdueManager.saveObject(overdueBizObject);
			}
		}
		}catch(JBOException e) {
			e.printStackTrace();
		}
		
	}
	
	

	/**
	 * 给非北财分配催款员
	 * @param tx
	 * @param arg0
	 * @throws Exception
	 */
	public void ownershipTransferSign(JBOTransaction tx,JobExecutionContext arg0) throws Exception{
		//获取天数
		Map<String,Integer> dayMap = getDay(tx);
		int beginDay1 = dayMap.get("beginDay1");
		int endDay1 = dayMap.get("endDay1");
		int beginDay2 = dayMap.get("beginDay2");
		int endDay2 = dayMap.get("endDay2");
		int beginDay3 = dayMap.get("beginDay3");
		
		//获取催款员角色下的用户
		Map<String,String[]> userMap = getUser(tx);
		String[] A = userMap.get("A");//轻催租
		String[] B = userMap.get("B");//中催组
		String[] C = userMap.get("C");//重催组
			
		BizObjectManager overdueManager = JBOFactory.getBizObjectManager(OVERDUE_DUNNING_INFO.CLASS_NAME, tx);
		
		//获取所有逾期的需要催收的合同信息
		String conInfo1 = getContractId(tx);
		if(!(conInfo1 == null || conInfo1.length() <= 0)){
		String[] conInfos = conInfo1.split(",");
			for(String conInfo:conInfos){
				String contract_id = conInfo.split("@")[0];//合同id
				String overDays = conInfo.split("@")[1];//逾期天数
				int overDay = Integer.valueOf(overDays);
				//根据合同id查询表中数据，有则修改，无则新增
				BizObject overdue = overdueManager.createQuery("contract_id=:contract_id").setParameter("contract_id", contract_id).getSingleResult(false);
				if(overdue!=null){//修改
					//催款员
					String partDept = overdue.getAttribute("part_dept").toString();
					
					if(overDay>=beginDay2 && overDay<=endDay2){
						if(Arrays.asList(B).contains(partDept)){
							//此催款员是中催组的人员，不做任何操作
						}else{//此催款员不是中催组的人员，则修改为中催组的人员
							String person = getBPerson(tx);
							updatePartDept(overdueManager, contract_id, person);
						}
					}else if(overDay>=beginDay3){
						if(Arrays.asList(C).contains(partDept)){
							//此催款员是重催组的人员，不做任何操作
						}else{
							//此催款员不是重催组的人员，则修改为重催组的人员
							String person = getCPerson(tx);
							updatePartDept(overdueManager, contract_id, person);		
						}
					}else if(overDay>=beginDay1 && overDay<=endDay1){
						if(Arrays.asList(A).contains(partDept)){
							//此催款员是轻催组的人员，不做任何操作
						}else{
							//此催款员不是中催组的人员，则修改为轻催组的人员
							String person = getAPerson(tx);
							updatePartDept(overdueManager, contract_id, person);
						}//此催款员不是中催组的人员，则修改为轻催组的人员
					}
				}else{//新增
					
					if(overDay>=beginDay1 && overDay<=endDay1){
						String person = getAPerson(tx);
						savePartDept(overdueManager, contract_id,person);
					}else if(overDay>=beginDay2 && overDay<=endDay2){
						String person = getBPerson(tx);
						savePartDept(overdueManager, contract_id ,person);	
					}else if(overDay>=beginDay3){
						String person = getCPerson(tx);
						savePartDept(overdueManager, contract_id, person);
						
					}
				}
			}
		}
	}
	
	
	
	
	
	/**
	 * 修改方法
	 * @param overdueManager
	 * @param contract_id
	 * @param person
	 * @throws JBOException
	 */
	private void updatePartDept(BizObjectManager overdueManager, String contract_id,
			String person) throws JBOException {
		overdueManager.createQuery("UPDATE O SET O.part_dept='"+person+"' WHERE contract_id='"+contract_id+"'").executeUpdate();
	}
	/**
	 * 保存方法
	 * @param overdueManager
	 * @param contract_id
	 * @param overdueBizObject
	 * @param person
	 * @throws JBOException
	 */
	private void savePartDept(BizObjectManager overdueManager, String contract_id, String person)
			throws JBOException {
		BizObject overdueBizObject = overdueManager.newObject();
		String uuid = UUID.randomUUID().toString().replace("-", "");
		
		overdueBizObject.setAttributeValue("id", uuid);
		overdueBizObject.setAttributeValue("part_dept", person);
		overdueBizObject.setAttributeValue("contract_id", contract_id);
		overdueManager.saveObject(overdueBizObject);
	}
	
	/**
	 * 获取催款员的天数配置
	 * @param tx
	 * @return
	 * @throws JBOException
	 */
	public Map<String, Integer> getDay(JBOTransaction tx) throws JBOException {
		Map<String, Integer> map = new HashMap<String, Integer>();
		int beginDay1 = 0;
		int endDay1 = 0;
		int beginDay2 = 0;
		int endDay2 = 0;
		int beginDay3 = 0;

		// 获取天数
		@SuppressWarnings("unchecked")
		List<BizObject> dayDistribute = JBOFactory.createBizObjectQuery(DAY_DISTRIBUTE.CLASS_NAME, "select * from O").getResultList(false);
		for (BizObject bizObject : dayDistribute) {
			String role = bizObject.getAttribute("role").toString();
			int beginDay = bizObject.getAttribute("begin_day").getInt();
			int endDay = bizObject.getAttribute("end_day") == null ? 0 : bizObject.getAttribute("end_day").getInt();
			if ("轻催组".equals(role)) {
				beginDay1 = beginDay;
				endDay1 = endDay;
			} else if ("中催组".equals(role)) {
				beginDay2 = beginDay;
				endDay2 = endDay;
			} else {
				beginDay3 = beginDay;
			}
		}
		map.put("beginDay1", beginDay1);
		map.put("endDay1", endDay1);
		map.put("beginDay2", beginDay2);
		map.put("endDay2", endDay2);
		map.put("beginDay3", beginDay3);
		return map;
	}
	/**
	 * 获取催款员角色下的用户
	 * @param tx
	 * @return
	 */
	public Map<String,String[]> getUser(JBOTransaction tx){
		
		Map<String,String[]> usermap = new HashMap<String, String[]>();
		try {
			//轻催组下的用户
			String Sql1="SELECT ur.roleid,O.userid AS userid,O.loginid,O.username FROM USER_INFO O LEFT JOIN USER_ROLE AS ur ON ur.USERID = O.USERID LEFT JOIN USER_TASK_INFO uti ON uti.userid=O.userid AND uti.roleid=ur.roleid WHERE O.status='1' AND ur.roleid='800R00000041'";
			
			List<Map<String, String>>dataListA = DataOperatorUtil.getDataBySql(tx, Sql1, null);
			String userA = new String();
			for (Map<String, String> map : dataListA) {
				String userid = map.get("userid");
				userA += userid+"@";	
			}
			String[] A =null;
			A = userA.split("@");
			usermap.put("A", A);
			//中催组下的用户
			String Sql2="SELECT ur.roleid,O.userid AS userid,O.loginid,O.username FROM USER_INFO O LEFT JOIN USER_ROLE AS ur ON ur.USERID = O.USERID LEFT JOIN USER_TASK_INFO uti ON uti.userid=O.userid AND uti.roleid=ur.roleid WHERE O.status='1' AND ur.roleid='800R00000042'";
			List<Map<String, String>> dataListB = DataOperatorUtil.getDataBySql(tx, Sql2, null);
			String userB = new String();
			for (Map<String, String> map : dataListB) {
				String userid = map.get("userid");
				userB += userid+"@";
			}
			String[] B =null;
			B = userB.split("@");
			usermap.put("B", B);
			//重催组下的用户
			String Sql3="SELECT ur.roleid,O.userid,O.loginid,O.username FROM USER_INFO O LEFT JOIN USER_ROLE AS ur ON ur.USERID = O.USERID LEFT JOIN USER_TASK_INFO uti ON uti.userid=O.userid AND uti.roleid=ur.roleid WHERE O.status='1' AND ur.roleid='800R00000043'";
			List<Map<String, String>> dataListC = DataOperatorUtil.getDataBySql(tx, Sql3, null);
			String userC = new String();
			for (Map<String, String> map : dataListC) {
				String userid = map.get("userid");
				userC += userid+"@";
			}
			String[] C =null;
			C = userC.split("@");
			usermap.put("C", C);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return usermap;
	}
	
	/**
	 * 获取所有逾期的需要催收的合同信息
	 * 
	 * @param tx
	 * @return
	 * @throws Exception
	 */
	public String getContractId(JBOTransaction tx) throws Exception {
		/*
		 * BizObjectManager
		 * bom=JBOFactory.getBizObjectManager(LB_CONTRACT_INFO.CLASS_NAME,tx);
		 * List<BizObject> boList = bom.createQuery(
		 * "SELECT O.id,vo.over_days FROM O LEFT JOIN jbo.com.tenwa.lease.comm.LB_UNION_LESSEE lul ON lul.contract_id = O.id LEFT JOIN jbo.sys.OVERDUE_DUNNING_INFO odi ON odi.contract_id = O.id LEFT JOIN jbo.sys.USER_INFO ui ON ui.userid = odi.part_dept LEFT JOIN jbo.app.tenwa.calc.VI_OVERDUE_RENT_PLAN_SUM vo ON vo.contract_id=O.id WHERE lul.is_main='Y' AND O.contract_status='31' AND vo.over_money>0"
		 * ).getResultList(true);
		 */
		// 获取所有逾期的需要催收的合同信息(非北财合同)
		BizObjectManager bom = JBOFactory.getBizObjectManager(VI_AUTODISTRIBUTE.CLASS_NAME, tx);
		@SuppressWarnings("unchecked")
		List<BizObject> boList = bom.createQuery("SELECT O.id,O.over_days FROM O WHERE O.project_manage NOT IN (SELECT ur.userid FROM jbo.awe.USER_ROLE ur WHERE ur.roleid ='800R00000044')").getResultList(true);

		String conInfos = new String();
		for (BizObject bo : boList) {
			conInfos += bo.getAttribute("id") + "@";
			conInfos += bo.getAttribute("over_days") + ",";
		}
		return conInfos;
	}
	/**
	 * 获取中催组的人员
	 * @param tx
	 * @return
	 */
	public String getBPerson(JBOTransaction tx){
		String person = "";
		try {
			//中催组下未分配且上岗的催款员
			String sqlN = "SELECT MAX(O.userid) AS userid"
					+" FROM USER_INFO O LEFT JOIN USER_ROLE AS ur ON ur.USERID = O.USERID" 
					+" LEFT JOIN USER_TASK_INFO uti ON uti.userid=O.userid AND uti.roleid=ur.roleid"
					+ " WHERE O.status='1' AND uti.induction_state='induction_state01' AND ur.roleid='800R00000042'"
					+ " AND O.userid NOT IN "
					+ " (SELECT part_dept FROM OVERDUE_DUNNING_INFO)";
			//虽然只让查出一条数据
			List<Map<String, String>> dataListAN = DataOperatorUtil.getDataBySql(tx, sqlN, null);
			//此时中催组的所有人员都已分配，选出目前任务最少的人，且上岗
			String sqlY = "SELECT MAX(o.part_dept) AS userid FROM "
					+ "(SELECT COUNT(*) number,part_dept FROM OVERDUE_DUNNING_INFO GROUP BY part_dept) o"+ 
					" LEFT JOIN USER_INFO ui ON ui.userid=o.part_dept"+
					" LEFT JOIN USER_ROLE AS ur ON ur.USERID = ui.USERID"+ 
					" LEFT JOIN USER_TASK_INFO uti ON uti.userid=ui.userid AND uti.roleid=ur.roleid"+
					" WHERE uti.roleid='800R00000042' AND "+
					" o.number IN (SELECT MIN(t.number) FROM"+ 
					" (SELECT COUNT(*) number,part_dept FROM OVERDUE_DUNNING_INFO GROUP BY part_dept) t"+
					" LEFT JOIN USER_INFO ui ON ui.userid=t.part_dept"+
					" LEFT JOIN USER_ROLE AS ur ON ur.USERID = ui.USERID"+
					" LEFT JOIN USER_TASK_INFO uti ON uti.userid=ui.userid AND uti.roleid=ur.roleid"+
					" WHERE uti.roleid='800R00000042' AND ui.status='1' AND uti.induction_state='induction_state01')";

			//虽然只能查出一条数据
			List<Map<String, String>> dataListAY = DataOperatorUtil.getDataBySql(tx, sqlY, null);
			
			
			if(dataListAN.size()>0){
				String useridAN = new String();
				for (Map<String, String> map : dataListAN) {
					String userid = map.get("userid");
					useridAN += userid+"@";
				}
				String[] AN =null;
				AN = useridAN.split("@");
				person = AN[0];
				
				if(person==null || "".equals(person) || "null".equals(person)){
					String useridAY = new String();
					for (Map<String, String> map : dataListAY) {
						String userid = map.get("userid");
						useridAY += userid+"@";
					}
					String[] AY =null;
					AY = useridAY.split("@");
					person = AY[0];
				}
			}else{
				String useridAY = new String();
				for (Map<String, String> map : dataListAY) {
					String userid = map.get("userid");
					useridAY += userid+"@";
				}
				String[] AY =null;
				AY = useridAY.split("@");
				person = AY[0];
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return person;
	}
	/**
	 * 获取重催组下的人员
	 * @param tx
	 * @return
	 */
	public String getCPerson(JBOTransaction tx){
		
		String person = "";
		try {
			//重催组下未分配的用户，且上岗
			String sqlN = "SELECT MAX(O.userid) AS userid"
					+" FROM USER_INFO O LEFT JOIN USER_ROLE AS ur ON ur.USERID = O.USERID" 
					+" LEFT JOIN USER_TASK_INFO uti ON uti.userid=O.userid AND uti.roleid=ur.roleid"
					+ " WHERE O.status='1' AND uti.induction_state='induction_state01' AND ur.roleid='800R00000043'"
					+ " AND O.userid NOT IN "
					+ " (SELECT part_dept FROM OVERDUE_DUNNING_INFO)";
			//虽然只让查出一条数据
			List<Map<String, String>> dataListAN = DataOperatorUtil.getDataBySql(tx, sqlN, null);
			//此时重催组的所有人员都已分配，选出目前任务最少的人，且上岗
			String sqlY = "SELECT MAX(o.part_dept) AS userid FROM "
					+ "(SELECT COUNT(*) number,part_dept FROM OVERDUE_DUNNING_INFO GROUP BY part_dept) o"+ 
					" LEFT JOIN USER_INFO ui ON ui.userid=o.part_dept"+
					" LEFT JOIN USER_ROLE AS ur ON ur.USERID = ui.USERID"+ 
					" LEFT JOIN USER_TASK_INFO uti ON uti.userid=ui.userid AND uti.roleid=ur.roleid"+
					" WHERE uti.roleid='800R00000043' AND "+
					" o.number IN (SELECT MIN(t.number) FROM"+ 
					" (SELECT COUNT(*) number,part_dept FROM OVERDUE_DUNNING_INFO GROUP BY part_dept) t"+
					" LEFT JOIN USER_INFO ui ON ui.userid=t.part_dept"+
					" LEFT JOIN USER_ROLE AS ur ON ur.USERID = ui.USERID"+
					" LEFT JOIN USER_TASK_INFO uti ON uti.userid=ui.userid AND uti.roleid=ur.roleid"+
					" WHERE uti.roleid='800R00000043' AND ui.status='1' AND uti.induction_state='induction_state01')";

			//虽然只能查出一条数据
			List<Map<String, String>> dataListAY = DataOperatorUtil.getDataBySql(tx, sqlY, null);
			
			
			if(dataListAN.size()>0){
				String useridAN = new String();
				for (Map<String, String> map : dataListAN) {
					String userid = map.get("userid");
					useridAN += userid+"@";
				}
				String[] AN =null;
				AN = useridAN.split("@");
				person = AN[0];
				
				if(person==null || "".equals(person) || "null".equals(person)){
					String useridAY = new String();
					for (Map<String, String> map : dataListAY) {
						String userid = map.get("userid");
						useridAY += userid+"@";
					}
					String[] AY =null;
					AY = useridAY.split("@");
					person = AY[0];
				}
			}else{
				String useridAY = new String();
				for (Map<String, String> map : dataListAY) {
					String userid = map.get("userid");
					useridAY += userid+"@";
				}
				String[] AY =null;
				AY = useridAY.split("@");
				person = AY[0];
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return person;
	}
	/**
	 * 获取轻催组人员
	 * @return
	 */
	public String getAPerson(JBOTransaction tx){
		String person = "";
		try {
			//轻催组下未分配且上岗的催款员
			String sqlN = "SELECT MAX(O.userid) AS userid"
			+" FROM USER_INFO O LEFT JOIN USER_ROLE AS ur ON ur.USERID = O.USERID" 
			+" LEFT JOIN USER_TASK_INFO uti ON uti.userid=O.userid AND uti.roleid=ur.roleid"
			+" WHERE O.status='1' AND uti.induction_state='induction_state01' AND ur.roleid='800R00000041'"
			+" AND O.userid NOT IN"
			+ " (SELECT part_dept FROM OVERDUE_DUNNING_INFO)";
			//虽然只让查出一条数据
			List<Map<String, String>> dataListAN = DataOperatorUtil.getDataBySql(tx, sqlN, null);
			//此时轻催组的所有人员都已分配，选出目前任务最少的人，且上岗
			String sqlY = "SELECT MAX(o.part_dept) AS userid FROM "
					+ "(SELECT COUNT(*) number,part_dept FROM OVERDUE_DUNNING_INFO GROUP BY part_dept) o"+ 
					" LEFT JOIN USER_INFO ui ON ui.userid=o.part_dept"+
					" LEFT JOIN USER_ROLE AS ur ON ur.USERID = ui.USERID"+ 
					" LEFT JOIN USER_TASK_INFO uti ON uti.userid=ui.userid AND uti.roleid=ur.roleid"+
					" WHERE uti.roleid='800R00000041' AND "+
					" o.number IN (SELECT MIN(t.number) FROM"+ 
					" (SELECT COUNT(*) number,part_dept FROM OVERDUE_DUNNING_INFO GROUP BY part_dept) t"+
					" LEFT JOIN USER_INFO ui ON ui.userid=t.part_dept"+
					" LEFT JOIN USER_ROLE AS ur ON ur.USERID = ui.USERID"+
					" LEFT JOIN USER_TASK_INFO uti ON uti.userid=ui.userid AND uti.roleid=ur.roleid"+
					" WHERE uti.roleid='800R00000041' AND ui.status='1' AND uti.induction_state='induction_state01')";
			
			//虽然只能查出一条数据
			List<Map<String, String>> dataListAY = DataOperatorUtil.getDataBySql(tx, sqlY, null);;
			
			if(dataListAN.size()>0){
				String useridAN = new String();
				for (Map<String, String> map : dataListAN) {
					String userid = map.get("userid");
					useridAN += userid+"@";
				}
				String[] AN =null;
				AN = useridAN.split("@");
				person = AN[0];
				if(person==null || "".equals(person) || "null".equals(person)){
					String useridAY = new String();
					for (Map<String, String> map : dataListAY) {
						String userid = map.get("userid");
						useridAY += userid+"@";
					}
					String[] AY =null;
					AY = useridAY.split("@");
					person = AY[0];
				}
			}else{
				String useridAY = new String();
				for (Map<String, String> map : dataListAY) {
					String userid = map.get("userid");
					useridAY += userid+"@";
				}
				String[] AY =null;
				AY = useridAY.split("@");
				person = AY[0];
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		return person;
	}
}