diff --git a/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/config/ClassMettingScheduTask.java b/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/config/ClassMettingScheduTask.java index c1d5d0f..ce54e26 100644 --- a/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/config/ClassMettingScheduTask.java +++ b/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/config/ClassMettingScheduTask.java @@ -1,5 +1,10 @@ package com.sercurityControl.proteam.config; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.sercurityControl.proteam.dutyTask.domain.BadWeatherEntity; +import com.sercurityControl.proteam.dutyTask.domain.WeatherBean; +import com.sercurityControl.proteam.dutyTask.mapper.BadWeatherMapper; import com.sercurityControl.proteam.dutyTask.service.TaskService; import com.sercurityControl.proteam.dutyTask.service.WorkTeamSchedule; import com.sercurityControl.proteam.service.DeviceMachineService; @@ -11,6 +16,14 @@ import org.springframework.scheduling.annotation.Scheduled; import javax.annotation.PostConstruct; import javax.annotation.Resource; +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.net.URL; +import java.net.URLConnection; +import java.util.List; +import java.util.zip.GZIPInputStream; /** * 站班会进行管理 自动分配定时任务 @@ -20,6 +33,9 @@ import javax.annotation.Resource; @EnableScheduling public class ClassMettingScheduTask { + @Resource + private BadWeatherMapper mapper; + @Resource public WorkTeamSchedule schedule; @Resource @@ -78,6 +94,69 @@ public class ClassMettingScheduTask { logsService.LoginFileUpload(); } + /** + * 添加天气数据 + */ + @Scheduled(cron = "0 30 1 * * ?") + public void getWeatherData() { + //合肥 + String addressCode="101220101"; + String json=getWeather("https://devapi.qweather.com/v7/weather/15d?location="+addressCode+"&key=b18f5b7c218c413abe751d40ec906d9c"); + JSONObject jsonObject = JSON.parseObject(json); + String code=jsonObject.getString("code"); + if("200".equals(code)){ + String daily=jsonObject.getString("daily"); + List weatherList = JSON.parseArray(String.valueOf(daily), WeatherBean.class ); + if(weatherList!=null&&weatherList.size()>0){ + //清空数据库表数据 + mapper.delBadWeatherData(); + for(WeatherBean wea:weatherList){ + BadWeatherEntity bean = new BadWeatherEntity(); + bean.setDate(wea.getFxDate()); + bean.setWeather(wea.getTextDay()); + bean.setMinTemperature(wea.getTempMin()); + bean.setMaxTemperature(wea.getTempMax()); + if ("晴".equals(wea.getTextDay())){ + bean.setWarning("优"); + } else if ("阴".equals(wea.getTextDay())){ + bean.setWarning("良"); + } else if ("多云".equals(wea.getTextDay())){ + bean.setWarning("良"); + } else if (wea.getTextDay().contains("雨")){ + bean.setWarning("差"); + } else if (wea.getTextDay().contains("雪")){ + bean.setWarning("差"); + }else { + bean.setWarning("良"); + } + int re = mapper.addBadWeather(bean); + } + } + } + } + public static String getWeather(String weather_url){ + String json=""; + StringBuffer sb = new StringBuffer(); + try { + //101280101为广州 3d为未来3天天气 now为当前天气 + URL url = new URL(weather_url); + URLConnection conn = url.openConnection(); + InputStream is = conn.getInputStream(); + GZIPInputStream gzin = new GZIPInputStream(is); + // 设置读取流的编码格式,自定义编码 + InputStreamReader isr = new InputStreamReader(gzin, "utf-8"); + BufferedReader reader = new BufferedReader(isr); + String line = null; + while ((line = reader.readLine()) != null) { + sb.append(line + " "); + } + reader.close(); + } catch (IOException e) { + e.printStackTrace(); + } + json=sb.toString(); + return json; + } } diff --git a/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/controller/TeamManageController.java b/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/controller/TeamManageController.java index 9f27c71..a063b18 100644 --- a/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/controller/TeamManageController.java +++ b/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/controller/TeamManageController.java @@ -27,7 +27,6 @@ public class TeamManageController { @Resource(name = "TeamManageService") private TeamManageService service; - @ApiOperation(value = "班组管理-列表") @PostMapping(value = "getList") @SysLog(title = "班组管理", model = "班组管理->班组管理", operaType = OperaType.QUERY, details = "班组管理",logType = 1) public Map getList(ParamsDto dto) { diff --git a/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/service/impl/TeamManageServiceImpl.java b/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/service/impl/TeamManageServiceImpl.java index c652b25..10eae25 100644 --- a/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/service/impl/TeamManageServiceImpl.java +++ b/securityControl-modules/securityControl-proteam/src/main/java/com/sercurityControl/proteam/supplement/service/impl/TeamManageServiceImpl.java @@ -1,13 +1,9 @@ package com.sercurityControl.proteam.supplement.service.impl; -import com.github.pagehelper.PageHelper; -import com.github.pagehelper.PageInfo; import com.securityControl.common.core.constant.HttpStatus; import com.sercurityControl.proteam.supplement.domain.dto.ParamsDto; import com.sercurityControl.proteam.supplement.domain.vo.TeamManageVo; -import com.sercurityControl.proteam.supplement.mapper.KeyRisksMapper; import com.sercurityControl.proteam.supplement.mapper.TeamManageMapper; -import com.sercurityControl.proteam.supplement.service.KeyRisksService; import com.sercurityControl.proteam.supplement.service.TeamManageService; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; diff --git a/securityControl-modules/securityControl-proteam/src/main/resources/mapper/supplement/TeamManageMapper.xml b/securityControl-modules/securityControl-proteam/src/main/resources/mapper/supplement/TeamManageMapper.xml index 3ebb376..7710d3e 100644 --- a/securityControl-modules/securityControl-proteam/src/main/resources/mapper/supplement/TeamManageMapper.xml +++ b/securityControl-modules/securityControl-proteam/src/main/resources/mapper/supplement/TeamManageMapper.xml @@ -156,5 +156,6 @@ AND jtp.delete_flag = 0 WHERE jt.delete_flag = 0 AND jcmi.class_id IS NULL + limit 30 \ No newline at end of file