package systemuser.internal;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

import org.springframework.security.providers.encoding.PasswordEncoder;

import kernel.exception.BusinessException;
import kernel.util.StringUtils;
import kernel.web.ApplicationUtil;
import kernel.web.Page;
import project.Constants;
import project.log.Log;
import project.log.LogService;
import project.onlinechat.OnlineChatMessageService;
import security.SecUser;
import security.internal.SecUserService;
import systemuser.AdminCustomerService;
import systemuser.AdminSystemUserService;
import systemuser.CustomerService;
import systemuser.model.Customer;

@SuppressWarnings("rawtypes")
public class AdminCustomerServiceImpl implements AdminCustomerService{
	
	protected LogService logService;
	
	private SecUserService secUserService;
	
	private PasswordEncoder passwordEncoder;
	
	private CustomerService customerService;
	
	private AdminSystemUserService adminSystemUserService;
	
	private OnlineChatMessageService onlineChatMessageService;
	
	@Override
	public Page pagedQuery(int pageNo,int pageSize ,String usernamePara) {
		if (pageNo <= 0) pageNo=1;
		Page page=new Page(pageNo,pageSize,Integer.MAX_VALUE);
		
		StringBuilder sqlBuilder = new StringBuilder("SELECT customer.UUID id,customer.USERNAME username,customer.ONLINE_STATE online_state,customer.LAST_CUSTOMER_TIME last_customer_time,");
		sqlBuilder.append("customer.LAST_ONLINE_TIME last_online_time,user.GOOGLE_AUTH_BIND google_auth_bind,user.REMARKS remarks,user.ENABLED enabled ");
		sqlBuilder.append("FROM T_CUSTOMER customer LEFT JOIN SCT_USER user ON user.USERNAME=customer.USERNAME WHERE 1=1 ");
		ArrayList<Object> whereParams=new ArrayList<Object>();
		
		if(StringUtils.isNotEmpty(usernamePara)) {
			sqlBuilder.append("AND customer.USERNAME LIKE ? ");
			whereParams.add("%"+usernamePara+"%");
		}
		
		sqlBuilder.append("ORDER BY customer.CREATE_TIME ASC LIMIT ?,?");
		whereParams.add(page.getFirstElementNumber());
		whereParams.add(pageSize);
		
		List<Map> list=ApplicationUtil.executeDQL(sqlBuilder.toString(),whereParams.toArray(new Object[whereParams.size()]),Map.class);
		page.setElements(list);
		return page;
	}

	@Override
	public void save(SecUser user,String operatorUsername,String loginSafeword,String code,String ip,String superGoogleAuthCode,String autoAnswer) {
		adminSystemUserService.save(user, operatorUsername, loginSafeword, code, ip, superGoogleAuthCode);
		
		Customer entity = new Customer();
		entity.setUsername(user.getUsername());
		entity.setOnline_state(0);
		entity.setCreate_time(new Date());
		entity.setAuto_answer(autoAnswer);
		
		customerService.save(entity);
	}
	
	public void updatePersonalAutoAnswer(String username,String loginSafeword,String ip,String autoAnswer) {
		checkLoginSafeword(username,loginSafeword);
		SecUser user = this.secUserService.findUserByLoginName(username);
		updateAutoAnswer(user,username,ip,autoAnswer);
	}
	
	public void updateAutoAnswer(SecUser user,String operatorUsername,String ip,String autoAnswer) {
		Customer customer = this.customerService.cacheByUsername(user.getUsername());
		String sourceAutoAnswer = customer.getAuto_answer();
		customer.setAuto_answer(autoAnswer);
		customerService.update(customer, false);
		saveLog(user,operatorUsername,"ip:"+ip+"修改了客服["+user.getUsername()+"]自动回复,原自动回复["+sourceAutoAnswer+"],新自动回复["+autoAnswer+"]");
	}
	
	/**
	 * 管理员强制下线
	 * @param username
	 * @param operatorUsername
	 * @param loginSafeword
	 * @param ip
	 */
	public void forceOffline(String username,String operatorUsername,String loginSafeword,String ip) {
		checkLoginSafeword(operatorUsername,loginSafeword);
		offline(username); 
		SecUser user = this.secUserService.findUserByLoginName(username);
		saveLog(user,operatorUsername,"ip:"+ip+"管理员强制下线客服["+username+"]");
	}

	public void offline(String username) {
		Customer customer = customerService.cacheByUsername(username);
		if(customer==null) throw new BusinessException("客服不存在");
		
		customer.setOnline_state(0);
		customer.setLast_offline_time(new Date());
		
		customerService.update(customer,false);
	}
	
	public void online(String username) {
		Customer customer = customerService.cacheByUsername(username);
		if(customer==null) throw new BusinessException("客服不存在");
		
		customer.setOnline_state(1);
		customer.setLast_online_time(new Date());
		customerService.update(customer,false);
		
		onlineChatMessageService.updateNoAnwserUser(username);
	}

	/**
	 * 验证登录人资金密码
	 * @param operatorUsername
	 * @param loginSafeword
	 */
	private void checkLoginSafeword(String operatorUsername,String loginSafeword) {
		SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
		String sysSafeword = sec.getSafeword();
		String safeword_md5 = passwordEncoder.encodePassword(loginSafeword, operatorUsername);
		if (!safeword_md5.equals(sysSafeword)) throw new BusinessException("登录人资金密码错误");
	}
	
	public void saveLog(SecUser secUser, String operator,String context) {
		Log log = new Log();
		log.setCategory(Constants.LOG_CATEGORY_OPERATION);
		log.setOperator(operator);
		log.setUsername(secUser.getUsername());
		log.setPartyId(secUser.getPartyId());
		log.setLog(context);
		log.setCreateTime(new Date());
		
		logService.saveSync(log);
	}
	
	public void setAdminSystemUserService(AdminSystemUserService adminSystemUserService) {
		this.adminSystemUserService = adminSystemUserService;
	}

	public void setCustomerService(CustomerService customerService) {
		this.customerService = customerService;
	}

	public void setOnlineChatMessageService(OnlineChatMessageService onlineChatMessageService) {
		this.onlineChatMessageService = onlineChatMessageService;
	}

	public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
		this.passwordEncoder = passwordEncoder;
	}

	public void setLogService(LogService logService) {
		this.logService = logService;
	}

	public void setSecUserService(SecUserService secUserService) {
		this.secUserService = secUserService;
	}
}