Test_Project_Web/e5
1
0
Fork 0
mirror of https://github.com/luoye663/e5.git synced 2024-12-25 11:18:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

backup

Browse Source
This commit is contained in:
LuoYe 2021-08-17 17:56:15 +08:00
parent 201ede424f
commit cfeab18dd0
6 changed files with 93 additions and 128 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
src/main/java/io/qyi/e5/outlook_log/controller/OutlookLogController.java
View File

@ -57,6 +57,7 @@ public class OutlookLogController {
@Autowired
InfluxDBClient influxDBClient;
@Value("${spring.influx.org:''}")
private String org;
@ -64,8 +65,6 @@ public class OutlookLogController {
private String bucket;
private final Logger logger = LoggerFactory.getLogger(this.getClass());
@Value("${page.size}")
private int pageSize;
@ -90,71 +89,4 @@ public class OutlookLogController {
return ResultUtil.success(logVo);
}
@GetMapping("/save")
public String save(){
ArrayList<Point> arrayList = new ArrayList<>();
for (int i = 0; i < 1000; i++) {
OutlookLog outlookLog = new OutlookLog();
Point point = Point.measurement(bucket)
.addTag("githubid", "22121")
.addField("aaaaaa1", i)
.addField("aaaaaa2", i)
.addField("aaaaaa3", i)
.time(Instant.now().toEpochMilli(), WritePrecision.MS);
arrayList.add(point);
}
try (WriteApi writeApi = influxDBClient.getWriteApi()) {
// writeApi.writePoint(bucket, org, point);
writeApi.writePoints(bucket,org, arrayList);
}
return "ok";
}
@GetMapping("/find")
public void find(){
String flux = "from(bucket:\"e5\") |> range(start: 0)" +
"|> filter(fn: (r) => r[\"_measurement\"] == \"e5s\")" +
// "|> filter(fn: (r) => r[\"_field\"] == \"aaaaaa1\")" +
"|> limit(n: 100)";
QueryApi queryApi = influxDBClient.getQueryApi();
List<FluxTable> tables = queryApi.query(flux,org);
for (FluxTable fluxTable : tables) {
List<FluxRecord> records = fluxTable.getRecords();
for (FluxRecord fluxRecord : records) {
System.out.println(fluxRecord.getField());
System.out.println(fluxRecord.getTime() + " ->" + fluxRecord.getValueByKey("_value"));
}
}
/*queryApi.query(flux,org,(cancellable, fluxRecord) -> {
//
// The callback to consume a FluxRecord.
//
// cancelable - object has the cancel method to stop asynchronous query
//
System.out.println(fluxRecord.getTime() + ": " + fluxRecord.getValueByKey("_value"));
}, throwable -> {
//
// The callback to consume any error notification.
//
System.out.println("Error occurred: " + throwable.getMessage());
}, () -> {
//
// The callback to consume a notification about successfully end of stream.
//
System.out.println("Query completed");
});*/
}
}

19
src/main/java/io/qyi/e5/outlook_log/entity/OutlookLog.java
View File

@ -2,10 +2,14 @@ package io.qyi.e5.outlook_log.entity;
import java.io.Serializable;
import java.sql.Timestamp;
import java.time.Instant;
import java.time.LocalDateTime;
import java.util.Date;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.influxdb.annotations.Column;
import com.influxdb.annotations.Measurement;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
@ -19,42 +23,43 @@ import lombok.experimental.Accessors;
* @since 2020-03-03
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@Measurement(name = "OutlookLog")
public class OutlookLog implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
/**
* github_id
*/
private Integer githubId;
// private Integer githubId;
/**
* outlook_id
*/
private Integer outlookId;
// private Integer outlookId;
/**
* 调用时间
*/
private Timestamp callTime;
@Column(timestamp = true)
private Instant callTime;
/**
* 调用结果
*/
@Column
private Integer result;
/**
* 如果有错误原因则记录
*/
@Column
private String msg;
/**
* 原始错误消息
*/
@Column
private String originalMsg;

24
src/main/java/io/qyi/e5/outlook_log/mapper/OutlookLogMapper.java
View File

@ -1,24 +0,0 @@
package io.qyi.e5.outlook_log.mapper;
import io.qyi.e5.outlook_log.entity.OutlookLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import java.util.List;
/**
* <p>
* Mapper 接口
* </p>
*
* @author 落叶
* @since 2020-03-03
*/
public interface OutlookLogMapper extends BaseMapper<OutlookLog> {
@Select("select * from e5.d_#{githubId}_#{outlookId}")
List<OutlookLog> findAllList(@Param("githubId") int githubId,@Param("outlookId") int outlookId);
}

3
src/main/java/io/qyi/e5/outlook_log/service/IOutlookLogService.java
View File

@ -13,9 +13,8 @@ import java.util.List;
* @author 落叶
* @since 2020-03-03
*/
public interface IOutlookLogService extends IService<OutlookLog> {
public interface IOutlookLogService {
void addLog(int githubId,int outlookId, String msg,int result,String original_msg);
int deleteInfo(int github_id);
List<OutlookLog> findAllList(int githubId, int outlookId);
}

29
src/main/java/io/qyi/e5/outlook_log/service/impl/OutlookLogServiceImpl.java
View File

@ -1,11 +1,8 @@
package io.qyi.e5.outlook_log.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import io.qyi.e5.outlook_log.entity.OutlookLog;
import io.qyi.e5.outlook_log.mapper.OutlookLogMapper;
import io.qyi.e5.outlook_log.service.IOutlookLogService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import java.util.List;
@ -19,30 +16,32 @@ import java.util.List;
* @since 2020-03-03
*/
@Service
@DS("td")
public class OutlookLogServiceImpl extends ServiceImpl<OutlookLogMapper, OutlookLog> implements IOutlookLogService {
public class OutlookLogServiceImpl implements IOutlookLogService {
@Override
public void addLog(int githubId,int outlookId, String msg, int result,String original_msg) {
OutlookLog outlookLog = new OutlookLog();
outlookLog.setGithubId(githubId)
.setOutlookId(outlookId)
.setResult(result)
// .setCallTime((int) (System.currentTimeMillis() / 1000))
.setMsg(msg)
.setOriginalMsg(original_msg);
// OutlookLog outlookLog = new OutlookLog();
// outlookLog.setGithubId(githubId)
// .setOutlookId(outlookId)
// .setResult(result)
// .setMsg(msg)
// .setOriginalMsg(original_msg);
baseMapper.insert(outlookLog);
// baseMapper.insert(outlookLog);
}
@Override
public int deleteInfo(int github_id) {
QueryWrapper<OutlookLog> outlookLogQueryWrapper = new QueryWrapper<>();
outlookLogQueryWrapper.eq("github_id", github_id);
return baseMapper.delete(outlookLogQueryWrapper);
// return baseMapper.delete(outlookLogQueryWrapper);
return 0;
}
@Override
public List<OutlookLog> findAllList(int githubId, int outlookId) {
return baseMapper.findAllList(githubId, outlookId);
// return baseMapper.findAllList(githubId, outlookId);
return null;
}
}

76
src/test/java/influxdb2Test.java
View File

@ -1,22 +1,76 @@
import io.qyi.e5.bean.influx2.InfluxdbConfig;
import io.qyi.e5.outlook_log.service.IOutlookLogService;
import com.influxdb.LogLevel;
import com.influxdb.client.*;
import com.influxdb.client.domain.WritePrecision;
import com.influxdb.client.write.Point;
import com.influxdb.query.FluxRecord;
import com.influxdb.query.FluxTable;
import io.qyi.e5.outlook_log.entity.OutlookLog;
import org.junit.jupiter.api.Test;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.springframework.cglib.beans.BeanMap;
import java.time.Instant;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
public class influxdb2Test {
InfluxDBClient influxDBClient = InfluxDBClientFactory.create("http://127.0.0.1:8086", "o-oFFLbRCFHmGFMMYR7kLFGb4jTUXkJkTCmPBeZxn32prCKxwVpS-FM3pLyCvv0gVao-Cm6c_s2Yl-7Ud_xH_Q==".toCharArray()
);
@InjectMocks
InfluxdbConfig influxdbConfig;
private String org = "luoye";
@Mock
IOutlookLogService outlookLogService;
@Test
public void save(){
influxDBClient.setLogLevel(LogLevel.BASIC);
WriteOptions writeOptions = WriteOptions.builder()
.batchSize(5000)
.flushInterval(1000)
.bufferLimit(10000)
.jitterInterval(1000)
.retryInterval(5000)
.build();
List<OutlookLog> list = new ArrayList<>();
for (int i = 0; i < 100; i++) {
OutlookLog outlookLog = new OutlookLog();
outlookLog.setResult(0).setMsg(i + "- ok").setOriginalMsg("加入成功").setCallTime(Instant.now());
list.add(outlookLog);
}
OutlookLog outlookLog = new OutlookLog();
outlookLog.setResult(0).setMsg(i + "- ok").setOriginalMsg("加入成功").setCallTime(Instant.now());
BeanMap.create(outlookLog).getBean();
try (WriteApi writeApi = influxDBClient.getWriteApi(writeOptions)) {
// writeApi.writeMeasurement();
// writeApi.writeMeasurements("e5", org ,WritePrecision.NS,list);
Point point = Point
.measurement("githubId_123")
.addTag("githubId","123465")
.addFields(fields)
.time(Instant.now(), WritePrecision.NS);
}
influxDBClient.close();
}
@Test
public void test1(){
// outlookLogService.findAllList(1000, 2000);
influxdbConfig.influxDBClient();
public void find(){
String flux = "from(bucket:\"e5\") |> range(start: 0)" +
"|> filter(fn: (r) => r[\"_measurement\"] == \"OutlookLog\")" +
// "|> filter(fn: (r) => r[\"_field\"] == \"aaaaaa1\")" +
"|> limit(n: 100)";
QueryApi queryApi = influxDBClient.getQueryApi();
List<FluxTable> tables = queryApi.query(flux,org);
for (FluxTable fluxTable : tables) {
List<FluxRecord> records = fluxTable.getRecords();
for (FluxRecord fluxRecord : records) {
System.out.println(fluxRecord.getField());
System.out.println(fluxRecord.getTime() + " ->" + fluxRecord.getValueByKey("_value"));
}
}
influxDBClient.close();
}
}