package com.yeshi.fanli.controller;
|
|
import java.io.IOException;
|
import java.io.PrintWriter;
|
import java.util.Date;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletResponse;
|
|
import com.yeshi.fanli.util.RedisKeyEnum;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import com.yeshi.fanli.service.inter.common.DataMonitorService;
|
import org.yeshi.utils.JsonUtil;
|
import org.yeshi.utils.NetWorkUtil;
|
|
/**
|
* 监控
|
*
|
* @author Administrator
|
*/
|
@Controller
|
@RequestMapping("monitor")
|
public class MonitorController {
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private DataMonitorService dataMonitorService;
|
|
/**
|
* 10分钟外没爬单就判断为异常
|
*
|
* @param out
|
*/
|
@RequestMapping("getTaoBaoOrderParseState")
|
public void getTaoBaoOrderParseState(HttpServletResponse response, PrintWriter out) {
|
Date date = dataMonitorService.getLatestParseTaoBaoOrderSuccessTime();
|
// 10分钟做判断
|
if (date != null && (Math.abs(date.getTime() - System.currentTimeMillis())) < 1000 * 60 * 10) {
|
out.print(JsonUtil.loadTrueResult(""));
|
return;
|
} else {
|
try {
|
response.sendError(666, "订单爬取疑似有问题");
|
return;
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* zookeeper服务
|
*/
|
@RequestMapping("zookeeper")
|
public void zookeeper(HttpServletResponse response, PrintWriter out) {
|
if (NetWorkUtil.isHostConnectable("134.175.68.214", 2181, 2000)) {
|
out.print("200");
|
} else {
|
try {
|
response.sendError(666, "异常");
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
|
/**
|
* 商品服务
|
*/
|
@RequestMapping("dubboGoodsService")
|
public void dubboGoodsService(HttpServletResponse response, PrintWriter out) {
|
if (NetWorkUtil.isHostConnectable("134.175.68.214", 20882, 2000)) {
|
out.print("200");
|
} else {
|
try {
|
response.sendError(666, "异常");
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 订单爬取是否正常
|
* @param platform
|
* @return
|
*/
|
private boolean isParseOrderNormal(String platform) {
|
String st = redisManager.getCommonString(RedisKeyEnum.monitor.getKey() + platform);
|
if (StringUtil.isNullOrEmpty(st)) {
|
return false;
|
}
|
return true;
|
}
|
|
|
/**
|
* 订单解析是否正常
|
* @param sourceType
|
* @param response
|
* @param out
|
*/
|
@RequestMapping("orderParse")
|
public void orderParse(int sourceType, HttpServletResponse response, PrintWriter out) {
|
if (isParseOrderNormal(sourceType+"")) {
|
out.print("200");
|
} else {
|
try {
|
response.sendError(666, "异常");
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
|
|
|
}
|
