123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191 |
- package com.jjt;
- import cn.hutool.json.JSONArray;
- import cn.hutool.json.JSONObject;
- import com.ruoyi.RuoYiApplication;
- import com.ruoyi.biz.service.IIotService;
- import com.ruoyi.common.utils.DateUtils;
- import org.apache.poi.ss.usermodel.Cell;
- import org.apache.poi.ss.usermodel.Row;
- import org.apache.poi.ss.usermodel.Sheet;
- import org.apache.poi.ss.usermodel.Workbook;
- import org.apache.poi.xssf.usermodel.XSSFWorkbook;
- import org.junit.jupiter.api.Test;
- import org.springframework.boot.test.context.SpringBootTest;
- import org.springframework.jdbc.core.JdbcTemplate;
- import javax.annotation.Resource;
- import java.io.FileOutputStream;
- import java.io.IOException;
- import java.time.*;
- import java.util.ArrayList;
- import java.util.Date;
- import java.util.List;
- import java.util.concurrent.atomic.AtomicInteger;
- /**
- * DataProcess$
- *
- * @author wukai
- * @date 2024/5/7 11:49
- */
- @SpringBootTest(classes = RuoYiApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
- public class DataProcess {
- @Resource
- private JdbcTemplate jdbcTemplate;
- @Resource
- private IIotService iotService;
- @Test
- void excel() {
- String code = "106";
- String table = "root.tl.suxi.knittings" + code + "_plc1";
- Workbook workbook = new XSSFWorkbook();
- for (int i = 21; i <= 26; i++) {
- String date = "2024-05-" + i;
- System.err.println(date);
- List<String[]> list = new ArrayList<>();
- for (int j = 1; j <= 12; j++) {
- List<String[]> pList = get(table, date, j);
- list.addAll(pList);
- }
- Sheet sheet = workbook.createSheet(date);
- toExcel(list, sheet);
- }
- try (FileOutputStream outputStream = new FileOutputStream("D:\\SYSTEM\\Desktop\\temp\\excel\\小经编机" + code + "号.xlsx")) {
- workbook.write(outputStream);
- } catch (IOException e) {
- e.printStackTrace();
- } finally {
- try {
- workbook.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- public List<String[]> get(String table, String date, int period) {
- List<String[]> list = new ArrayList<>();
- LocalDate localDate = LocalDate.parse(date);
- LocalDateTime ldt = LocalDateTime.of(localDate, LocalTime.MIN);
- LocalDateTime start = ldt.plusHours(2 * period).minusHours(2);
- LocalDateTime end = start.plusHours(2);
- start = start.minusSeconds(1);
- Long startTime = start.toInstant(ZoneOffset.of("+8")).toEpochMilli();
- Long endTime = end.toInstant(ZoneOffset.of("+8")).toEpochMilli();
- String sql = "select Capacity_data_5,Capacity_data_6,Capacity_data_7,Capacity_data_8,Capacity_data_9,Capacity_data_10,Capacity_data_11,Capacity_data_12,Capacity_data_13,Capacity_data_14,Capacity_data_15,Capacity_data_16,Capacity_data_17,Capacity_data_18,Capacity_data_19" +
- " from %s where time>%s and time <=%s";
- sql = String.format(sql, table, startTime, endTime);
- iotService.query(sql);
- JSONObject jsonObject = iotService.query(sql);
- JSONObject data = jsonObject.getJSONObject("data");
- JSONArray values = data.getJSONArray("values");
- JSONArray timestamps = data.getJSONArray("timestamps");
- for (int i = 0; i < values.size(); i++) {
- String[] temp = new String[16];
- temp[0] = timestamps.getStr(i);
- JSONArray da = values.getJSONArray(i);
- for (int j = 1; j < temp.length; j++) {
- temp[j] = da.getStr(j - 1);
- }
- list.add(temp);
- }
- return list;
- }
- public void toExcel(List<String[]> list, Sheet sheet) {
- String[] names = {"时间", "GB1剩余时间", "GB2剩余时间", "GB3剩余时间", "GB4剩余时间", "GB5剩余时间", "GB1盘头剩余周长", "GB2盘头剩余周长", "GB3盘头剩余周长", "GB4盘头剩余周长", "GB5盘头剩余周长", "GB1盘头剩余圈数", "GB2盘头剩余圈数", "GB3盘头剩余圈数", "GB4盘头剩余圈数", "GB5盘头剩余圈数"};
- Row title = sheet.createRow(0);
- for (int i = 0; i < names.length; i++) {
- Cell cell = title.createCell(i);
- cell.setCellValue(names[i]);
- }
- AtomicInteger index = new AtomicInteger(1);
- list.forEach(d -> {
- Row row = sheet.createRow(index.get());
- Long time = Long.parseLong(d[0]);
- String date = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, new Date(time));
- Cell cell = row.createCell(0);
- cell.setCellValue(date);
- for (int j = 1; j <= 10; j++) {
- cell = row.createCell(j);
- cell.setCellValue(Float.parseFloat(d[j]));
- }
- for (int j = 11; j < d.length; j++) {
- cell = row.createCell(j);
- cell.setCellValue(Integer.parseInt(d[j]));
- }
- index.getAndIncrement();
- });
- }
- @Test
- void data() {
- String table = "root.tl.suxi.knittings98_plc1";
- String[] arr = {
- "time>2024-05-03T00:00:00 and time <=2024-05-03T02:00:00",
- "time>2024-05-03T02:00:00 and time <=2024-05-03T04:00:00",
- "time>2024-05-03T04:00:00 and time <=2024-05-03T06:00:00",
- "time>2024-05-03T06:00:00 and time <=2024-05-03T08:00:00",
- "time>2024-05-03T08:00:00 and time <=2024-05-03T10:00:00",
- "time>2024-05-03T10:00:00 and time <=2024-05-03T12:00:00",
- "time>2024-05-03T12:00:00 and time <=2024-05-03T14:00:00",
- "time>2024-05-03T14:00:00 and time <=2024-05-03T16:00:00",
- "time>2024-05-03T16:00:00 and time <=2024-05-03T18:00:00",
- "time>2024-05-03T18:00:00 and time <=2024-05-03T20:00:00",
- "time>2024-05-03T20:00:00 and time <=2024-05-03T22:00:00",
- "time>2024-05-03T22:00:00 and time <=2024-05-04T00:00:00",
- "time>2024-05-04T00:00:00 and time <=2024-05-04T02:00:00",
- "time>2024-05-04T02:00:00 and time <=2024-05-04T04:00:00",
- "time>2024-05-04T04:00:00 and time <=2024-05-04T06:00:00",
- "time>2024-05-04T06:00:00 and time <=2024-05-04T08:00:00",
- "time>2024-05-04T08:00:00 and time <=2024-05-04T10:00:00",
- "time>2024-05-04T10:00:00 and time <=2024-05-04T12:00:00",
- "time>2024-05-04T12:00:00 and time <=2024-05-04T14:00:00",
- "time>2024-05-04T14:00:00 and time <=2024-05-04T16:00:00",
- "time>2024-05-04T16:00:00 and time <=2024-05-04T18:00:00",
- "time>2024-05-04T18:00:00 and time <=2024-05-04T20:00:00",
- "time>2024-05-04T20:00:00 and time <=2024-05-04T22:00:00",
- "time>2024-05-04T22:00:00 and time <=2024-05-05T00:00:00"
- };
- // for (String where : arr) {
- // process(table, where);
- // }
- String where = "time>=2024-05-05T12:00:00 and time <=2024-05-05T14:00:00";
- process(table, where);
- }
- @Test
- void process(String table, String where) {
- String sql = "select Alarm_unit_1,Alarm_unit_2,Alarm_unit_3,Alarm_unit_4,Alarm_unit_5,Alarm_unit_6,Alarm_unit_7,Alarm_unit_8,Alarm_unit_9,Alarm_unit_10,Alarm_unit_11,Alarm_unit_12,Alarm_unit_13,Alarm_unit_14,Alarm_unit_15,Alarm_unit_16,Alarm_unit_17,Alarm_unit_18,Alarm_unit_19,Alarm_unit_20,Alarm_unit_21,Alarm_unit_22,Alarm_unit_23,Alarm_unit_24,Alarm_unit_25,Alarm_unit_26,Alarm_unit_27,Capacity_data_1,Capacity_data_2,Capacity_data_3,Capacity_data_4,Capacity_data_5,Capacity_data_6,Capacity_data_7,Capacity_data_8,Capacity_data_9,Capacity_data_10,Capacity_data_11,Capacity_data_12,Capacity_data_13,Capacity_data_14,Capacity_data_15,Capacity_data_16,Capacity_data_17,Capacity_data_18,Capacity_data_19,Capacity_data_20,Capacity_data_21,Capacity_data_22,Capacity_data_23,Capacity_data_24,Capacity_data_25,Capacity_data_26,Capacity_data_27,Capacity_data_28,Capacity_data_29,Capacity_data_30,Capacity_data_31,Capacity_data_32,Capacity_data_33,Capacity_data_34,Capacity_data_35,Capacity_data_36,Capacity_data_37,Capacity_data_38,Capacity_data_39,Capacity_data_40,Capacity_data_41,Capacity_data_42,Capacity_data_43,Capacity_data_44,Capacity_data_45,Capacity_data_46,Capacity_data_47,Capacity_data_48,Capacity_data_49,Capacity_data_50,Capacity_data_51,Capacity_data_52,Capacity_data_53,System_data_1,System_data_2,System_data_3,System_data_4,System_data_5,System_data_6,System_data_7,System_data_8,System_data_9,System_data_10,System_data_11,System_data_12,System_data_13,System_data_14,System_data_15,System_data_16,System_data_17,System_data_18,System_data_19,System_data_20,System_data_21,System_data_22,System_data_23,System_data_24,System_data_25,System_data_26,System_data_27,System_data_28,System_data_29,System_data_30,System_data_31,System_data_32,System_data_33,System_data_34,System_data_35,System_data_36,System_data_37,System_data_38,System_data_39,System_data_40,Formula_data_1,Formula_data_2,Formula_data_3,Formula_data_4,Formula_data_5,Formula_data_6,Formula_data_7,Formula_data_8,Formula_data_9,Formula_data_10,Formula_data_11,Formula_data_12,Formula_data_13,Formula_data_14,Formula_data_15,Formula_data_16,Formula_data_17,Formula_data_18,Formula_data_19,Formula_data_20,Formula_data_21,Formula_data_22,Formula_data_23,Formula_data_24,Formula_data_25,Formula_data_26,Formula_data_27,Formula_data_28,Formula_data_29,Formula_data_30,Formula_data_31,Formula_data_32,Formula_data_33,Formula_data_34,Formula_data_35" +
- " from " + table +
- " where " + where;
- // System.err.println(res);
- JSONObject jsonObject = iotService.query(sql);
- JSONObject data = jsonObject.getJSONObject("data");
- JSONArray array = data.getJSONArray("values");
- JSONArray columnNames = data.getJSONArray("columnNames");
- JSONArray timestamps = data.getJSONArray("timestamps");
- List list = new ArrayList<>();
- for (int i = 0; i < timestamps.size(); i++) {
- Object[] arr = new Object[columnNames.size() + 1];
- arr[0] = LocalDateTime.ofInstant(Instant.ofEpochMilli(timestamps.getLong(i)), ZoneId.systemDefault());
- JSONArray da = array.getJSONArray(i);
- for (int j = 0; j < da.size(); j++) {
- arr[j + 1] = da.get(j);
- }
- list.add(arr);
- }
- sql = "INSERT INTO TWIN_DATA(DATA_TIME,Alarm_unit_1,Alarm_unit_2,Alarm_unit_3,Alarm_unit_4,Alarm_unit_5,Alarm_unit_6,Alarm_unit_7,Alarm_unit_8,Alarm_unit_9,Alarm_unit_10,Alarm_unit_11,Alarm_unit_12,Alarm_unit_13,Alarm_unit_14,Alarm_unit_15,Alarm_unit_16,Alarm_unit_17,Alarm_unit_18,Alarm_unit_19,Alarm_unit_20,Alarm_unit_21,Alarm_unit_22,Alarm_unit_23,Alarm_unit_24,Alarm_unit_25,Alarm_unit_26,Alarm_unit_27,Capacity_data_1,Capacity_data_2,Capacity_data_3,Capacity_data_4,Capacity_data_5,Capacity_data_6,Capacity_data_7,Capacity_data_8,Capacity_data_9,Capacity_data_10,Capacity_data_11,Capacity_data_12,Capacity_data_13,Capacity_data_14,Capacity_data_15,Capacity_data_16,Capacity_data_17,Capacity_data_18,Capacity_data_19,Capacity_data_20,Capacity_data_21,Capacity_data_22,Capacity_data_23,Capacity_data_24,Capacity_data_25,Capacity_data_26,Capacity_data_27,Capacity_data_28,Capacity_data_29,Capacity_data_30,Capacity_data_31,Capacity_data_32,Capacity_data_33,Capacity_data_34,Capacity_data_35,Capacity_data_36,Capacity_data_37,Capacity_data_38,Capacity_data_39,Capacity_data_40,Capacity_data_41,Capacity_data_42,Capacity_data_43,Capacity_data_44,Capacity_data_45,Capacity_data_46,Capacity_data_47,Capacity_data_48,Capacity_data_49,Capacity_data_50,Capacity_data_51,Capacity_data_52,Capacity_data_53,System_data_1,System_data_2,System_data_3,System_data_4,System_data_5,System_data_6,System_data_7,System_data_8,System_data_9,System_data_10,System_data_11,System_data_12,System_data_13,System_data_14,System_data_15,System_data_16,System_data_17,System_data_18,System_data_19,System_data_20,System_data_21,System_data_22,System_data_23,System_data_24,System_data_25,System_data_26,System_data_27,System_data_28,System_data_29,System_data_30,System_data_31,System_data_32,System_data_33,System_data_34,System_data_35,System_data_36,System_data_37,System_data_38,System_data_39,System_data_40,Formula_data_1,Formula_data_2,Formula_data_3,Formula_data_4,Formula_data_5,Formula_data_6,Formula_data_7,Formula_data_8,Formula_data_9,Formula_data_10,Formula_data_11,Formula_data_12,Formula_data_13,Formula_data_14,Formula_data_15,Formula_data_16,Formula_data_17,Formula_data_18,Formula_data_19,Formula_data_20,Formula_data_21,Formula_data_22,Formula_data_23,Formula_data_24,Formula_data_25,Formula_data_26,Formula_data_27,Formula_data_28,Formula_data_29,Formula_data_30,Formula_data_31,Formula_data_32,Formula_data_33,Formula_data_34,Formula_data_35)" +
- " VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
- jdbcTemplate.batchUpdate(sql, list);
- }
- }
|