@Service
public class UserServiceImpl implements UserService {
	
	@Value("${SSO_BASE_URL}")
	public String SSO_BASE_URL;
	@Value("${SSO_USER_TOKEN}")
	public String SSO_USER_TOKEN;
	@Value("${SSO_USER_LOGIN}")
	public String SSO_USER_LOGIN;


	@Override
	public TbUser getUserByToken(String token) {
		try {
			String json = HttpClientUtil.doGet(SSO_BASE_URL + SSO_USER_TOKEN + token);
			TaotaoResult result = TaotaoResult.formatToPojo(json, TbUser.class);
			if (result.getStatus() == 200) {
				TbUser user = (TbUser) result.getData();
				return user;
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}
}

/*
	 * check user data
	 */
	@RequestMapping("/check/{param}/{type}")
	@ResponseBody
	public Object checkUserData(@PathVariable String param, @PathVariable Integer type, String callback) {
		
		TaotaoResult result = null;
		try {
			result = ssoService.checkUserData(param, type);
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		if (!StringUtils.isBlank(callback)) {
			MappingJacksonValue mappingJacksonValue = new MappingJacksonValue(result);
			mappingJacksonValue.setJsonpFunction(callback);
			return mappingJacksonValue;
		}else {
			return result;
		}
	}
	
	/*
	 * create user
	 */
	@RequestMapping(value="/register", method=RequestMethod.POST)
	@ResponseBody
	public TaotaoResult createUser(TbUser user) {
		TaotaoResult result = null;
		
		try {
			result = ssoService.createUser(user);
			
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		return result;
	}

@RequestMapping(value="/login", method=RequestMethod.POST)
@ResponseBody
public TaotaoResult userLogin(String username, String password){
	try {
		TaotaoResult result = ssoService.userLogin(username, password);
		return result;
	} catch (Exception e) {
		e.printStackTrace();
		return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e));
	}
}

@Override
public TaotaoResult getUserByToken(String token) {
	String result = redisPool.get(SSO_SESSION_KEY + ":" + token);
	
	if (StringUtils.isBlank(result)) {
		return TaotaoResult.build(400, "session expired, please relogin");
	}
	
	redisPool.expire(SSO_SESSION_KEY + ":" + token, SSO_SESSION_EXPIRE);
	
	return TaotaoResult.ok(JsonUtils.jsonToPojo(result, TbUser.class));
}

@RequestMapping("/token/{token}")
@ResponseBody
public Object getUserByToken(@PathVariable String token, String callback) {
	TaotaoResult result = null;
	
	try {
		result = ssoService.getUserByToken(token);
	} catch (Exception e) {
		e.printStackTrace();
		result = TaotaoResult.build(500, ExceptionUtil.getStackTrace(e));
	}
	
	if (!StringUtils.isBlank(callback)) {
		MappingJacksonValue mappingJacksonValue = new MappingJacksonValue(result);
		mappingJacksonValue.setJsonpFunction(callback);
		return mappingJacksonValue;
	}else {
		return result;
	}
	
}

@Service
public class ItemServiceImpl implements ItemService {
	
	@Value("${REST_BASE_URL}")
	private String REST_BASE_URL;
	@Value("${ITEM_INFO}")
	private String ITEM_INFO;
	@Value("${ITEM_DESC_URL}")
	private String ITEM_DESC_URL;

	@Override
	public ItemInfo getItemById(Long itemId) {
		try {
			String itemJson = HttpClientUtil.doGet(REST_BASE_URL + ITEM_INFO + itemId);
			if (!StringUtils.isBlank(itemJson)) {
				TaotaoResult result = TaotaoResult.formatToPojo(itemJson, ItemInfo.class);
				if (result.getStatus() == 200) {
					ItemInfo itemInfo = (ItemInfo) result.getData();
					return itemInfo;
				}	
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}
	
	@Override
	public String getItemDescById(Long itemId) {
		try {
			//查询商品描述
			String json = HttpClientUtil.doGet(REST_BASE_URL + ITEM_DESC_URL + itemId);
			//转换成java对象
			TaotaoResult taotaoResult = TaotaoResult.formatToPojo(json, TbItemDesc.class);
			if (taotaoResult.getStatus() == 200) {
				TbItemDesc itemDesc = (TbItemDesc) taotaoResult.getData();
				//取商品描述信息
				String result = itemDesc.getItemDesc();
				return result;
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}


}

@Service
public class SearchServiceImpl implements SearchService {
	
	@Value("${SEARCH_BASE_URL}")
	private String SEARCH_BASE_URL;

	@Override
	public SearchResult search(String query, int page) {
		Map<String, String> param = new HashMap<>();
		param.put("q", query);
		param.put("page", page + "");
		try {
			String getString = HttpClientUtil.doGet(SEARCH_BASE_URL, param);
			TaotaoResult result = TaotaoResult.formatToPojo(getString, SearchResult.class);
			if (result.getStatus() == 200) {
				SearchResult searchResult = (SearchResult) result.getData();
				return searchResult;
			}
		} catch (Exception e) {
			e.printStackTrace();
		}

		return null;
	}

}

@Service
public class ServiceSearchImpl implements SearchService {
	
	@Autowired
	private SearchDao searchDao;

	@Override
	public SearchResult search(String query, int page, int rows) throws Exception {
		SolrQuery solrQuery = new SolrQuery();
		
		solrQuery.setQuery(query);
		
		solrQuery.setStart((page -1) * rows);
		solrQuery.setRows(rows);
		
		solrQuery.set("df", "item_keywords");
		
		solrQuery.setHighlight(true);
		solrQuery.addHighlightField("item_title");
		solrQuery.setHighlightSimplePre("<em style=\"color:red\">");
		solrQuery.setHighlightSimplePost("</em>");
		
		SearchResult result = searchDao.search(solrQuery);
		
		long totalItemCount = result.getTotalItemCount();
		long totalPageCount = totalItemCount / rows;
		if (totalItemCount % rows > 0){
			totalPageCount++;
		}
		
		result.setTotalPageCount(totalPageCount);
		result.setCurrentPageNumber(page);
		result.setCurrentRowCount(rows);
		return result;
	}

}

@Controller
@RequestMapping("/manager")
public class ItemController {
	
	@Autowired ItemService itemService;
	
	@RequestMapping("/import")
	@ResponseBody
	public TaotaoResult importItemsToSolr(){
		TaotaoResult result = itemService.importItemsToSolr();
		
		return result;
	}

}