From 3d593b39648ff583a255765f76760768d6ba5f55 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Thu, 23 Dec 2021 14:32:14 +0800
Subject: [PATCH] 正式库city_aqi，city_weather,history_aqi第三方数据存入开发库
---
screen-job/src/main/java/com/moral/api/service/CityAqiService.java | 5
screen-manage/src/main/java/com/moral/api/entity/HistoryAqi.java | 45 +++++
screen-manage/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java | 20 ++
screen-manage/src/main/java/com/moral/api/entity/CityAqi.java | 45 +++++
screen-manage/src/main/java/com/moral/api/mapper/CityWeatherMapper.java | 16 +
screen-manage/src/main/resources/mapper/CityAqiMapper.xml | 12 +
screen-manage/src/main/resources/mapper/CityWeatherMapper.xml | 12 +
screen-manage/src/main/java/com/moral/api/service/CityWeatherService.java | 16 +
screen-job/src/main/java/com/moral/api/service/CityWeatherService.java | 19 +
screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java | 8
screen-job/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java | 8
screen-job/src/main/java/com/moral/api/service/HistoryAqiService.java | 5
screen-manage/src/main/java/com/moral/api/mapper/HistoryAqiMapper.java | 16 +
screen-manage/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java | 20 ++
screen-manage/src/main/java/com/moral/api/controller/DataReplicationController.java | 62 ++++++
screen-manage/src/main/java/com/moral/api/service/HistoryAqiService.java | 16 +
screen-job/src/main/java/com/moral/api/task/DataReplicationTask.java | 86 +++++++++
screen-manage/src/main/java/com/moral/api/mapper/CityAqiMapper.java | 16 +
screen-manage/src/main/java/com/moral/api/service/CityAqiService.java | 16 +
screen-manage/src/main/java/com/moral/api/entity/CityWeather.java | 45 +++++
screen-manage/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java | 20 ++
screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java | 8
screen-manage/src/main/resources/mapper/HistoryAqiMapper.xml | 12 +
23 files changed, 521 insertions(+), 7 deletions(-)
diff --git a/screen-job/src/main/java/com/moral/api/service/CityAqiService.java b/screen-job/src/main/java/com/moral/api/service/CityAqiService.java
index 17e3c3c..449aec6 100644
--- a/screen-job/src/main/java/com/moral/api/service/CityAqiService.java
+++ b/screen-job/src/main/java/com/moral/api/service/CityAqiService.java
@@ -1,5 +1,7 @@
package com.moral.api.service;
+import java.util.List;
+
import com.moral.api.entity.CityAqi;
import com.baomidou.mybatisplus.extension.service.IService;
@@ -16,4 +18,7 @@
//aqi���������������insert
void insertCityAqi();
+ //������������city_aqi������
+ List<CityAqi> getCityAqi();
+
}
diff --git a/screen-job/src/main/java/com/moral/api/service/CityWeatherService.java b/screen-job/src/main/java/com/moral/api/service/CityWeatherService.java
index bc57b3e..290158f 100644
--- a/screen-job/src/main/java/com/moral/api/service/CityWeatherService.java
+++ b/screen-job/src/main/java/com/moral/api/service/CityWeatherService.java
@@ -1,5 +1,7 @@
package com.moral.api.service;
+import java.util.List;
+
import com.moral.api.entity.CityWeather;
import com.baomidou.mybatisplus.extension.service.IService;
@@ -15,14 +17,17 @@
//������������������������insert
void insertCityWeather();
-
+
/**
- *@Description: ������city_code���time������������
- *@Param: [cityCode, time]
- *@return: com.moral.api.entity.CityWeather
- *@Author: lizijie
- *@Date: 2021/10/14 16:52
+ * @Description: ������city_code���time������������
+ * @Param: [cityCode, time]
+ * @return: com.moral.api.entity.CityWeather
+ * @Author: lizijie
+ * @Date: 2021/10/14 16:52
**/
- CityWeather getDataByCityCodeAndTime(String cityCode,String time);
+ CityWeather getDataByCityCodeAndTime(String cityCode, String time);
+
+ //������������city_weather������
+ List<CityWeather> getCityWeather();
}
diff --git a/screen-job/src/main/java/com/moral/api/service/HistoryAqiService.java b/screen-job/src/main/java/com/moral/api/service/HistoryAqiService.java
index 65b242f..b342d14 100644
--- a/screen-job/src/main/java/com/moral/api/service/HistoryAqiService.java
+++ b/screen-job/src/main/java/com/moral/api/service/HistoryAqiService.java
@@ -1,5 +1,7 @@
package com.moral.api.service;
+import java.util.List;
+
import com.baomidou.mybatisplus.extension.service.IService;
import com.moral.api.entity.HistoryAqi;
@@ -10,4 +12,7 @@
HistoryAqi getHistoryApiByTimeAndGuid(String guid,String time);
+ //������������history_aqi������
+ List<HistoryAqi> getHistoryAqi();
+
}
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
index e16fc01..9cfadbd 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
@@ -151,4 +151,12 @@
redisTemplate.opsForHash().put(RedisConstants.CITY_AQI, cityCode.toString(), aqi);
}
}
+
+ @Override
+ public List<CityAqi> getCityAqi() {
+ String time = DateUtils.getDateStringOfHour(-1, DateUtils.yyyy_MM_dd_HH_EN) + ":00:00";
+ QueryWrapper<CityAqi> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("time", time);
+ return cityAqiMapper.selectList(queryWrapper);
+ }
}
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java
index ef84f87..e5bcd7d 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java
@@ -83,4 +83,12 @@
}
return cityWeather;
}
+
+ @Override
+ public List<CityWeather> getCityWeather() {
+ String time = DateUtils.getDateStringOfHour(-1, DateUtils.yyyy_MM_dd_HH_EN) + ":00:00";
+ QueryWrapper<CityWeather> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("time", time);
+ return cityWeatherMapper.selectList(queryWrapper);
+ }
}
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java
index 12aa978..062e655 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java
@@ -137,4 +137,12 @@
}
return historyAqi;
}
+
+ @Override
+ public List<HistoryAqi> getHistoryAqi() {
+ String time = DateUtils.getDateStringOfHour(-1, DateUtils.yyyy_MM_dd_HH_EN) + ":00:00";
+ QueryWrapper<HistoryAqi> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("time", time);
+ return historyAqiMapper.selectList(queryWrapper);
+ }
}
diff --git a/screen-job/src/main/java/com/moral/api/task/DataReplicationTask.java b/screen-job/src/main/java/com/moral/api/task/DataReplicationTask.java
new file mode 100644
index 0000000..b74c4ce
--- /dev/null
+++ b/screen-job/src/main/java/com/moral/api/task/DataReplicationTask.java
@@ -0,0 +1,86 @@
+package com.moral.api.task;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpMethod;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.List;
+import java.util.Map;
+
+import com.moral.api.entity.CityAqi;
+import com.moral.api.entity.CityWeather;
+import com.moral.api.entity.HistoryAqi;
+import com.moral.api.service.CityAqiService;
+import com.moral.api.service.CityWeatherService;
+import com.moral.api.service.HistoryAqiService;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.context.XxlJobHelper;
+import com.xxl.job.core.handler.annotation.XxlJob;
+
+/*
+ * ���������������������������������������������������������������������������manager������������������������manager������manager���������������
+ * ���������������������
+ * city_aqi ������aqi������
+ * city_weather ������������������
+ * history_aqi ���������aqi������
+ * */
+@Component
+public class DataReplicationTask {
+
+ @Autowired
+ private CityAqiService cityAqiService;
+
+ @Autowired
+ private CityWeatherService cityWeatherService;
+
+ @Autowired
+ private HistoryAqiService historyAqiService;
+
+ @Autowired
+ private RestTemplate restTemplate;
+
+ //city_aqi������������
+ @XxlJob("cityAqiReplication")
+ public ReturnT cityAqiReplication() {
+ try {
+ List<CityAqi> cityAqi = cityAqiService.getCityAqi();
+ HttpEntity<List<CityAqi>> requestEntity = new HttpEntity<>(cityAqi);
+ restTemplate.exchange("http://47.99.64.149:8082/dataReplication/insertCityAqi", HttpMethod.POST, requestEntity, Map.class);
+ } catch (Exception e) {
+ XxlJobHelper.log(e.getMessage());
+ return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
+ }
+ return ReturnT.SUCCESS;
+ }
+
+ //city_weather������������
+ @XxlJob("cityWeatherReplication")
+ public ReturnT cityWeatherReplication() {
+ try {
+ List<CityWeather> cityWeather = cityWeatherService.getCityWeather();
+ HttpEntity<List<CityWeather>> requestEntity = new HttpEntity<>(cityWeather);
+ restTemplate.exchange("http://47.99.64.149:8082/dataReplication/insertCityWeather", HttpMethod.POST, requestEntity, Map.class);
+ } catch (Exception e) {
+ XxlJobHelper.log(e.getMessage());
+ return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
+ }
+ return ReturnT.SUCCESS;
+ }
+
+ //history_aqi������������
+ @XxlJob("historyAqiReplication")
+ public ReturnT historyAqiReplication() {
+ try {
+ List<HistoryAqi> historyAqi = historyAqiService.getHistoryAqi();
+ HttpEntity<List<HistoryAqi>> requestEntity = new HttpEntity<>(historyAqi);
+ restTemplate.exchange("http://47.99.64.149:8082/dataReplication/insertHistoryAqi", HttpMethod.POST, requestEntity, Map.class);
+ } catch (Exception e) {
+ XxlJobHelper.log(e.getMessage());
+ return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
+ }
+ return ReturnT.SUCCESS;
+ }
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/controller/DataReplicationController.java b/screen-manage/src/main/java/com/moral/api/controller/DataReplicationController.java
new file mode 100644
index 0000000..8456c02
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/controller/DataReplicationController.java
@@ -0,0 +1,62 @@
+package com.moral.api.controller;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+import com.moral.api.entity.CityAqi;
+import com.moral.api.entity.CityWeather;
+import com.moral.api.entity.HistoryAqi;
+import com.moral.api.service.CityAqiService;
+import com.moral.api.service.CityWeatherService;
+import com.moral.api.service.HistoryAqiService;
+import com.moral.constant.ResultMessage;
+
+@Slf4j
+@Api(tags = {"������job���������������������������������"})
+@RestController
+@CrossOrigin(origins = "*", maxAge = 3600)
+@RequestMapping("/dataReplication")
+public class DataReplicationController {
+
+ @Autowired
+ private CityAqiService cityAqiService;
+
+ @Autowired
+ private CityWeatherService cityWeatherService;
+
+ @Autowired
+ private HistoryAqiService historyAqiService;
+
+ @ApiOperation(value = "������aqi������������", notes = "������aqi������������")
+ @PostMapping("insertCityAqi")
+ public ResultMessage insertCityAqi(@RequestBody List<CityAqi> cityAqis) {
+ cityAqis.forEach(cityAqi -> cityAqiService.save(cityAqi));
+ return ResultMessage.ok();
+ }
+
+ @ApiOperation(value = "������������������������", notes = "������������������������")
+ @PostMapping("insertCityWeather")
+ public ResultMessage insertCityWeather(@RequestBody List<CityWeather> cityWeathers) {
+ cityWeathers.forEach(cityWeather -> cityWeatherService.save(cityWeather));
+ return ResultMessage.ok();
+ }
+
+ @ApiOperation(value = "���������aqi������������", notes = "���������aqi������������")
+ @PostMapping("insertHistory")
+ public ResultMessage insertHistory(@RequestBody List<HistoryAqi> historyAqis) {
+ historyAqis.forEach(historyAqi -> historyAqiService.save(historyAqi));
+ return ResultMessage.ok();
+ }
+
+}
+
+
diff --git a/screen-manage/src/main/java/com/moral/api/entity/CityAqi.java b/screen-manage/src/main/java/com/moral/api/entity/CityAqi.java
new file mode 100644
index 0000000..959de6c
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/entity/CityAqi.java
@@ -0,0 +1,45 @@
+package com.moral.api.entity;
+
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import java.io.Serializable;
+import java.util.Date;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * ������aqi���������������������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class CityAqi extends Model<CityAqi> {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * ������id
+ */
+ private Integer cityCode;
+
+ /**
+ * ������
+ */
+ private Date time;
+
+ /**
+ * ������
+ */
+ private String value;
+
+
+ @Override
+ protected Serializable pkVal() {
+ return null;
+ }
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/entity/CityWeather.java b/screen-manage/src/main/java/com/moral/api/entity/CityWeather.java
new file mode 100644
index 0000000..c9d4e6d
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/entity/CityWeather.java
@@ -0,0 +1,45 @@
+package com.moral.api.entity;
+
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import java.io.Serializable;
+import java.util.Date;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * ���������������������������������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class CityWeather extends Model<CityWeather> {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * ������code
+ */
+ private Integer cityCode;
+
+ /**
+ * ������
+ */
+ private Date time;
+
+ /**
+ * ������
+ */
+ private String value;
+
+
+ @Override
+ protected Serializable pkVal() {
+ return null;
+ }
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/entity/HistoryAqi.java b/screen-manage/src/main/java/com/moral/api/entity/HistoryAqi.java
new file mode 100644
index 0000000..97df3b3
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/entity/HistoryAqi.java
@@ -0,0 +1,45 @@
+package com.moral.api.entity;
+
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import java.io.Serializable;
+import java.util.Date;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * ������aqi���������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class HistoryAqi extends Model<HistoryAqi> {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * ������/������/������������id
+ */
+ private String guid;
+
+ /**
+ * ������
+ */
+ private Date time;
+
+ /**
+ * ������
+ */
+ private String value;
+
+
+ @Override
+ protected Serializable pkVal() {
+ return null;
+ }
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/mapper/CityAqiMapper.java b/screen-manage/src/main/java/com/moral/api/mapper/CityAqiMapper.java
new file mode 100644
index 0000000..d9e4b47
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/mapper/CityAqiMapper.java
@@ -0,0 +1,16 @@
+package com.moral.api.mapper;
+
+import com.moral.api.entity.CityAqi;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * ������aqi��������������������� Mapper ������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+public interface CityAqiMapper extends BaseMapper<CityAqi> {
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/mapper/CityWeatherMapper.java b/screen-manage/src/main/java/com/moral/api/mapper/CityWeatherMapper.java
new file mode 100644
index 0000000..f1d50b2
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/mapper/CityWeatherMapper.java
@@ -0,0 +1,16 @@
+package com.moral.api.mapper;
+
+import com.moral.api.entity.CityWeather;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * ��������������������������������� Mapper ������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+public interface CityWeatherMapper extends BaseMapper<CityWeather> {
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/mapper/HistoryAqiMapper.java b/screen-manage/src/main/java/com/moral/api/mapper/HistoryAqiMapper.java
new file mode 100644
index 0000000..88b9853
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/mapper/HistoryAqiMapper.java
@@ -0,0 +1,16 @@
+package com.moral.api.mapper;
+
+import com.moral.api.entity.HistoryAqi;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * ������aqi��������� Mapper ������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+public interface HistoryAqiMapper extends BaseMapper<HistoryAqi> {
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/service/CityAqiService.java b/screen-manage/src/main/java/com/moral/api/service/CityAqiService.java
new file mode 100644
index 0000000..fb29f6c
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/service/CityAqiService.java
@@ -0,0 +1,16 @@
+package com.moral.api.service;
+
+import com.moral.api.entity.CityAqi;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * ������aqi��������������������� ���������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+public interface CityAqiService extends IService<CityAqi> {
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/service/CityWeatherService.java b/screen-manage/src/main/java/com/moral/api/service/CityWeatherService.java
new file mode 100644
index 0000000..1381148
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/service/CityWeatherService.java
@@ -0,0 +1,16 @@
+package com.moral.api.service;
+
+import com.moral.api.entity.CityWeather;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * ��������������������������������� ���������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+public interface CityWeatherService extends IService<CityWeather> {
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/service/HistoryAqiService.java b/screen-manage/src/main/java/com/moral/api/service/HistoryAqiService.java
new file mode 100644
index 0000000..f018a2e
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/service/HistoryAqiService.java
@@ -0,0 +1,16 @@
+package com.moral.api.service;
+
+import com.moral.api.entity.HistoryAqi;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * ������aqi��������� ���������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+public interface HistoryAqiService extends IService<HistoryAqi> {
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
new file mode 100644
index 0000000..fb20ed1
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
@@ -0,0 +1,20 @@
+package com.moral.api.service.impl;
+
+import com.moral.api.entity.CityAqi;
+import com.moral.api.mapper.CityAqiMapper;
+import com.moral.api.service.CityAqiService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * ������aqi��������������������� ���������������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+@Service
+public class CityAqiServiceImpl extends ServiceImpl<CityAqiMapper, CityAqi> implements CityAqiService {
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java
new file mode 100644
index 0000000..1814bdc
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/service/impl/CityWeatherServiceImpl.java
@@ -0,0 +1,20 @@
+package com.moral.api.service.impl;
+
+import com.moral.api.entity.CityWeather;
+import com.moral.api.mapper.CityWeatherMapper;
+import com.moral.api.service.CityWeatherService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * ��������������������������������� ���������������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+@Service
+public class CityWeatherServiceImpl extends ServiceImpl<CityWeatherMapper, CityWeather> implements CityWeatherService {
+
+}
diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java
new file mode 100644
index 0000000..829eccb
--- /dev/null
+++ b/screen-manage/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java
@@ -0,0 +1,20 @@
+package com.moral.api.service.impl;
+
+import com.moral.api.entity.HistoryAqi;
+import com.moral.api.mapper.HistoryAqiMapper;
+import com.moral.api.service.HistoryAqiService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * ������aqi��������� ���������������
+ * </p>
+ *
+ * @author moral
+ * @since 2021-12-23
+ */
+@Service
+public class HistoryAqiServiceImpl extends ServiceImpl<HistoryAqiMapper, HistoryAqi> implements HistoryAqiService {
+
+}
diff --git a/screen-manage/src/main/resources/mapper/CityAqiMapper.xml b/screen-manage/src/main/resources/mapper/CityAqiMapper.xml
new file mode 100644
index 0000000..7e8763e
--- /dev/null
+++ b/screen-manage/src/main/resources/mapper/CityAqiMapper.xml
@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.moral.api.mapper.CityAqiMapper">
+
+ <!-- ������������������������ -->
+ <resultMap id="BaseResultMap" type="com.moral.api.entity.CityAqi">
+ <result column="city_code" property="cityCode"/>
+ <result column="time" property="time"/>
+ <result column="value" property="value"/>
+ </resultMap>
+
+</mapper>
\ No newline at end of file
diff --git a/screen-manage/src/main/resources/mapper/CityWeatherMapper.xml b/screen-manage/src/main/resources/mapper/CityWeatherMapper.xml
new file mode 100644
index 0000000..f643e71
--- /dev/null
+++ b/screen-manage/src/main/resources/mapper/CityWeatherMapper.xml
@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.moral.api.mapper.CityWeatherMapper">
+
+ <!-- ������������������������ -->
+ <resultMap id="BaseResultMap" type="com.moral.api.entity.CityWeather">
+ <result column="city_code" property="cityCode"/>
+ <result column="time" property="time"/>
+ <result column="value" property="value"/>
+ </resultMap>
+
+</mapper>
\ No newline at end of file
diff --git a/screen-manage/src/main/resources/mapper/HistoryAqiMapper.xml b/screen-manage/src/main/resources/mapper/HistoryAqiMapper.xml
new file mode 100644
index 0000000..24404de
--- /dev/null
+++ b/screen-manage/src/main/resources/mapper/HistoryAqiMapper.xml
@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.moral.api.mapper.HistoryAqiMapper">
+
+ <!-- ������������������������ -->
+ <resultMap id="BaseResultMap" type="com.moral.api.entity.HistoryAqi">
+ <result column="guid" property="guid"/>
+ <result column="time" property="time"/>
+ <result column="value" property="value"/>
+ </resultMap>
+
+</mapper>
\ No newline at end of file
--
Gitblit v1.8.0