/**
 * 
 */
package com.yoho.unions.server.restapi;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.yoho.service.model.union.request.ActivateUnionRequestBO;
import com.yoho.service.model.union.request.ActivateUnionRequestVO;
import com.yoho.service.model.union.response.ActiveUnionResponseBO;
import com.yoho.unions.common.constant.UnionConstant;
import com.yoho.unions.common.enums.ClientTypeEnum;
import com.yoho.unions.common.utils.SpringContextUtil;
import com.yoho.unions.server.service.MainUnionService;

/**
 * 描述：
 * 激活联盟入口
 * @author ping.huang
 * 2016年3月16日
 */
@Controller
@RequestMapping("/ActivateUnionRest")
public class ActivateUnionRest {

	static Logger log = LoggerFactory.getLogger(ActivateUnionRest.class);
	
	static ExecutorService exe = Executors.newFixedThreadPool(20);
	
	/**
	 * 激活联盟
	 * @param request
	 * @return 
	 */
	@RequestMapping("/activateUnion")
	@ResponseBody public ActiveUnionResponseBO activateUnion(ActivateUnionRequestVO vo) {
		log.info("addUnion with param is {}", vo);
		ActivateUnionRequestBO bo = new ActivateUnionRequestBO();
		BeanUtils.copyProperties(vo, bo);
		String clientType = vo.getClient_type();
		if (!ClientTypeEnum.ANDROID.getName().equalsIgnoreCase(clientType) && !ClientTypeEnum.IPHONE.getName().equalsIgnoreCase(clientType)) {
			log.warn("activateUnion error with param is {}", vo);
			return new ActiveUnionResponseBO(600, "error");
		}
		//多线程处理
		exe.execute(new RunActivate(bo));
		return new ActiveUnionResponseBO(200, "success");
	}
	
	public static class RunActivate implements Runnable {

		public RunActivate(ActivateUnionRequestBO bo) {
			this.bo = bo;
		}
		
		private ActivateUnionRequestBO bo;
		
		@Override
		public void run() {
			MainUnionService service = null;
			if (ClientTypeEnum.ANDROID.getName().equalsIgnoreCase(bo.getClient_type())) {
				//处理安卓的服务
				for (String str : UnionConstant.andriodServiceList) {
					//捕获异常，不影响后面的联盟
					try {
						service = SpringContextUtil.getBean(str, MainUnionService.class);
						service.activeUnion(bo);
					} catch (Exception e) {
						log.warn("addUnion error with param is {}", bo);
					}
				}
			} else if (ClientTypeEnum.IPHONE.getName().equalsIgnoreCase(bo.getClient_type())) {
				//处理iOS的服务
				for (String str : UnionConstant.iOSServiceList) {
					//捕获异常，不影响后面的联盟
					try {
						service = SpringContextUtil.getBean(str, MainUnionService.class);
						service.activeUnion(bo);
					} catch (Exception e) {
						log.warn("addUnion error with param is {}", bo);
					}
				}
			}
		}

		public ActivateUnionRequestBO getBo() {
			return bo;
		}

		public void setBo(ActivateUnionRequestBO bo) {
			this.bo = bo;
		}
		
	}
}