videoalliance/.svn/pristine/e8/e89309b72cc0aef599700b8f7d695816ec4a749e.svn-base

package com.chinacreator.videoalliance.order.action;

import java.io.UnsupportedEncodingException;
import java.util.HashMap;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import com.chinacreator.common.util.URLUtil;
import com.chinacreator.videoalliance.order.bean.KafkaBean;
import com.chinacreator.videoalliance.order.dao.KafkaDao;
import com.chinacreator.videoalliance.order.util.JsonUtil;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
public class KafkaOrderAction {
	
	private static Logger log = Logger.getLogger(KafkaOrderAction.class);
	
	  @Autowired
	  private KafkaDao kafkaDao;
	  
	  @RequestMapping({"/kafkaOrder.do"})
	  @ResponseBody
	  public Object doOrder(HttpServletRequest request)
	    throws Exception
	  { 
		 Map<String,String> outmap = new HashMap<String, String>();
		 String resultCode = "0";
		 String errorInfo = "";
		 try{
		 String readStr =  URLUtil.readInputStream(request.getInputStream());
		 KafkaBean bean = (KafkaBean) JsonUtil.jsonToBean(readStr, KafkaBean.class);
		 kafkaDao.insert(bean);
		 }catch(Exception e){
			 log.error(e.getMessage(),e);
			  resultCode = "8000";
			  errorInfo = "VIP系统忙！";
		 }
		 outmap.put("resultcode", resultCode);
		  outmap.put("errorInfo", errorInfo);
		  return outmap;
	  }
	  
	  public static void main(String[] args) throws UnsupportedEncodingException, Exception {
		 String str ="{\"partition\":\"1\",\"offset\":\"15759783\",\"serialNumber\":\"17690284021\",\"productId\":\"90063345\",\"netTypeCode\":\"50\",\"actionCode\":\"0\",\"operaTime\":\"20170605161153\"}";
		 KafkaBean bean = (KafkaBean) JsonUtil.jsonToBean(str, KafkaBean.class);
		 System.out.println(bean.getSerialNumber());
		 KafkaDao kafkaDao = new KafkaDao();
		 kafkaDao.insert(bean);
	}
}