Merge branch 'dev' of chenweida/patient-co-management into dev

patient-co-analysis/src/main/java/com/yihu/wlyy/analysis/listener/LabelDataListener.java

@@ -29,6 +29,7 @@ public class LabelDataListener {
    //@Scheduled(cron = "0 0/1 * * * ?") //每分钟执行一次
    @KafkaListener(topics = "flumeLog1")
    public void labelData(ConsumerRecord<?, ?> record) {
        Long startTime = System.currentTimeMillis();
        logger.info("Kafka开始消费");
        Optional<?> kafkaMessage = Optional.ofNullable(record.value());
        if (kafkaMessage.isPresent()) {
@@ -40,7 +41,10 @@ public class LabelDataListener {
                    mongoTemplate.insert(
                            new LabelDataModel(value[0], value[1], value[2], value[3], value[4]), mongoDbTableName
                    );
                    logger.info("保存成功,message:" + message);
                    Long endTime = System.currentTimeMillis();
                    Long time = startTime - endTime;
                    logger.info("time(ms):" + time);
                    logger.info("保存成功 message:" + message);
                } else {
                    logger.error("数据格式错误,message:" + message);
                }

patient-co-analysis/src/main/java/com/yihu/wlyy/analysis/model/LabelDataModel.java

@@ -15,27 +15,27 @@ public class LabelDataModel implements Serializable {
    private String id;
    private String createTime;//时间
    private String code;//操作人code
    private String classMethod;//完整的类路径
    private String requestMapping;//web路径
    private String operaTime;//操作时间
    private String date;//具体的数据
    private String data;//具体的数据
    public LabelDataModel() {
    }
    public LabelDataModel(String createTime, String code, String classMethod, String operaTime, String date) {
    public LabelDataModel(String createTime, String code, String requestMapping, String operaTime, String data) {
        this.createTime = createTime;
        this.code = code;
        this.classMethod = classMethod;
        this.requestMapping = requestMapping;
        this.operaTime = operaTime;
        this.date = date;
        this.data = data;
    }
    public String getDate() {
        return date;
    public String getData() {
        return data;
    }
    public void setDate(String date) {
        this.date = date;
    public void setData(String data) {
        this.data = data;
    }
    public String getId() {
@@ -62,12 +62,12 @@ public class LabelDataModel implements Serializable {
        this.code = code;
    }
    public String getClassMethod() {
        return classMethod;
    public String getRequestMapping() {
        return requestMapping;
    }
    public void setClassMethod(String classMethod) {
        this.classMethod = classMethod;
    public void setRequestMapping(String requestMapping) {
        this.requestMapping = requestMapping;
    }
    public String getOperaTime() {