淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 fanli/src/main/java/com/yeshi/fanli/controller/MonitorController.java

@@ -1,126 +1,126 @@
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();

            }

        }

    }









}

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();
            }
        }
    }




}