日志分析

patient-co-analysis/src/main/java/com/yihu/wlyy/analysis/etl/ILogTransform.java

@@ -16,7 +16,7 @@ public interface ILogTransform {
     *
     * @param log
     */
    void transform(DataModel log);
    void transform(JSONObject log);
    /**
     * 获取日志类型

patient-co-analysis/src/main/java/com/yihu/wlyy/analysis/etl/LogDataTransform.java

@@ -1,6 +1,6 @@
package com.yihu.wlyy.analysis.etl;
import com.yihu.wlyy.analysis.model.DataModel;
import org.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -10,7 +10,7 @@ import java.util.Map;
/**
 * 日志信息分析提取
 *
 * <p>
 * Created by lyr-pc on 2017/2/17.
 */
public class LogDataTransform {
@@ -37,7 +37,7 @@ public class LogDataTransform {
     * @return
     */
    public static LogDataTransform getLogTransform() {
        if(instance == null) {
        if (instance == null) {
            synchronized (obj) {
                if (instance == null) {
                    instance = new LogDataTransform();
@@ -52,12 +52,12 @@ public class LogDataTransform {
     *
     * @param log
     */
    public void transform(DataModel log) {
    public void transform(JSONObject log) {
        try {
            ILogTransform transform = transforms.get(log.getLogType());
            ILogTransform transform = transforms.get(log.getString("logType"));
            if (transform == null) {
                logger.error("logType:" + log.getLogType() + " transform can not find");
                logger.error("logType:" + log.getString("logType") + " transform can not find");
            } else {
                transform.transform(log);
            }
@@ -104,7 +104,7 @@ public class LogDataTransform {
            logger.info("log transform init success");
        } catch (Exception e) {
            e.printStackTrace();
            logger.error("log transform init failed");
            logger.error("log transform init failed:" + e.getMessage());
        }
    }
}

patient-co-analysis/src/main/java/com/yihu/wlyy/analysis/etl/transform/ConsultLogTransform.java

@@ -3,6 +3,7 @@ package com.yihu.wlyy.analysis.etl.transform;
import com.yihu.wlyy.analysis.etl.BusinessTypeEnum;
import com.yihu.wlyy.analysis.etl.ILogTransform;
import com.yihu.wlyy.analysis.model.DataModel;
import org.json.JSONObject;
/**
 * 咨询日志提取分析
@@ -14,7 +15,7 @@ public class ConsultLogTransform implements ILogTransform {
    private final BusinessTypeEnum logType = BusinessTypeEnum.consult;
    @Override
    public void transform(DataModel log) {
    public void transform(JSONObject log) {
    }

patient-co-analysis/src/main/java/com/yihu/wlyy/analysis/etl/transform/RegisterLogTransform.java

@@ -3,10 +3,11 @@ package com.yihu.wlyy.analysis.etl.transform;
import com.yihu.wlyy.analysis.etl.ILogTransform;
import com.yihu.wlyy.analysis.etl.BusinessTypeEnum;
import com.yihu.wlyy.analysis.model.DataModel;
import org.json.JSONObject;
/**
 * 注册日志信息提取分析
 *
 * <p>
 * Created by lyr-pc on 2017/2/17.
 */
public class RegisterLogTransform implements ILogTransform {
@@ -14,7 +15,7 @@ public class RegisterLogTransform implements ILogTransform {
    private final BusinessTypeEnum logType = BusinessTypeEnum.register;
    @Override
    public void transform(DataModel log) {
    public void transform(JSONObject log) {
    }