| | |
| | | package com.moral.api.controller; |
| | | |
| | | import com.moral.api.service.*; |
| | | import com.moral.api.util.DeviceExcelDTO; |
| | | import com.moral.api.util.EmailSpringUtil; |
| | | import com.moral.api.util.ExcelUtil; |
| | | import com.moral.api.util.HttpUtils; |
| | | import com.moral.constant.ResultMessage; |
| | | import com.moral.util.DateUtils; |
| | |
| | | import org.apache.http.HttpResponse; |
| | | import org.apache.http.util.EntityUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.core.io.ByteArrayResource; |
| | | import org.springframework.web.bind.annotation.GetMapping; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | | import org.springframework.web.bind.annotation.RestController; |
| | | |
| | | import java.util.Date; |
| | | import java.util.HashMap; |
| | | import java.util.Map; |
| | | import javax.mail.MessagingException; |
| | | import java.io.ByteArrayOutputStream; |
| | | import java.io.IOException; |
| | | import java.util.*; |
| | | |
| | | /** |
| | | * @ClassName UserController |
| | |
| | | private HistoryAqiService historyAqiService; |
| | | @Autowired |
| | | private HistoryHourlyService historyHourlyService; |
| | | @Autowired |
| | | private HistoryMonthlyService historyMonthlyService; |
| | | @Autowired |
| | | private DeviceService deviceService; |
| | | @Autowired |
| | | private EmailSpringUtil emailSpringUtil; |
| | | |
| | | @GetMapping("insertHistoryDaily") |
| | | @ApiOperation(value = "天数据补录", notes = "天数据补录") |
| | |
| | | @GetMapping("insertHistoryFiveMinutely") |
| | | @ApiOperation(value = "5分钟数据", notes = "5分钟数据") |
| | | public ResultMessage insertHistoryFiveMinutely() { |
| | | String format = DateUtils.yyyy_MM_dd_HH_mm_EN; |
| | | historyFiveMinutelyService.insertHistoryFiveMinutely(); |
| | | String s ="2023-10-13 03:35"; |
| | | String s1 ="2023-10-13 03:40"; |
| | | Date start = DateUtils.getDate(s,format); |
| | | Date end = DateUtils.getDate(s1,format); |
| | | return new ResultMessage(); |
| | | } |
| | | |
| | | @GetMapping("dateInsertHistoryHourlyJKAvg") |
| | | @ApiOperation(value = "疾控中心小时数据", notes = "疾控中心小时数据") |
| | | public ResultMessage dateInsertHistoryHourlyJKAvg(String start,String end) { |
| | | // String format = DateUtils.yyyy_MM_dd_HH_mm_EN; |
| | | // String start ="2023-11-19 09:00" |
| | | // String end ="2023-11-19 10:00"; |
| | | // Date start1 = DateUtils.getDate(start,format); |
| | | // Date end1 = DateUtils.getDate(end,format); |
| | | historyHourlyService.dateInsertHistoryHourlyJKAvg(start, end); |
| | | return new ResultMessage(); |
| | | } |
| | | |
| | |
| | | |
| | | @GetMapping("insertHistoryAqi") |
| | | @ApiOperation(value = "过控制战补偿", notes = "过控制战补偿") |
| | | public ResultMessage insertHistoryAqi() { |
| | | historyAqiService.insertHistoryAqi(); |
| | | public ResultMessage insertHistoryAqi(String time) { |
| | | historyAqiService.insertHistoryAqi(time); |
| | | return new ResultMessage(); |
| | | } |
| | | |
| | |
| | | @ApiOperation(value = "获取天气小时数据", notes = "获取天气小时数据") |
| | | public ResultMessage insertCityWeather() { |
| | | cityWeatherService.insertCityWeather(); |
| | | return new ResultMessage(); |
| | | } |
| | | |
| | | @GetMapping("insertHistoryMonthly") |
| | | @ApiOperation(value = "月数据", notes = "月数据") |
| | | public ResultMessage insertHistoryMonthly() { |
| | | historyMonthlyService.insertHistoryMonthly(); |
| | | return new ResultMessage(); |
| | | } |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | @GetMapping("excelDevice") |
| | | @ApiOperation(value = "excle", notes = "excle") |
| | | public void excelDevice() throws IOException { |
| | | String startTime = DateUtils.dateToDateString(DateUtils.addDays(new Date(),-1),DateUtils.yyyy_MM_dd_EN); |
| | | List<DeviceExcelDTO> list = deviceService.ListDeviceExcel(startTime,null,72); |
| | | String path = Objects.requireNonNull(this.getClass().getClassLoader().getResource("")).getPath(); |
| | | String fileName = String.format("%s疾控中心数据-%s.xlsx",path,startTime); |
| | | ByteArrayOutputStream out = null; |
| | | try { |
| | | // 生成excel文件 |
| | | out = ExcelUtil.generateExcel(list, DeviceExcelDTO.class); |
| | | // 发送邮件 |
| | | String content = startTime+"疾控中心设备统计数据"; |
| | | String toMail = "909710561@qq.com"; |
| | | emailSpringUtil.sendEmail("设备分钟数据",content,false,"909710561@qq.com", |
| | | toMail,"null",null, fileName, new ByteArrayResource(out.toByteArray())); |
| | | } catch (IOException e) { |
| | | log.error(String.format("生成excel失败,原因:%s",e)); |
| | | e.printStackTrace(); |
| | | } catch (MessagingException e) { |
| | | log.error(String.format("邮件发送失败,原因:%s",e)); |
| | | e.printStackTrace(); |
| | | }finally { |
| | | if(out != null){ |
| | | out.close(); |
| | | } |
| | | } |
| | | } |
| | | } |