hwf453
/
admin-client-temperature
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

20250913

Browse Source
master
修改密码漏洞修复完成 3 months ago
parent 2db668569e
commit abd36d3cf9
6 changed files with 59 additions and 55 deletions
Show Stats Download Patch File Download Diff File

4
admin-client-temperature.iml
Unescape Escape View File

@ -10,9 +10,7 @@
<configuration> <configuration>
<setting name="validation-enabled" value="true" /> <setting name="validation-enabled" value="true" />
<setting name="provider-name" value="Hibernate" /> <setting name="provider-name" value="Hibernate" />
<datasource-mapping> <datasource-mapping />
<factory-entry name="entityManagerFactory" />
</datasource-mapping>
<naming-strategy-map /> <naming-strategy-map />
</configuration> </configuration>
</facet> </facet>

6
src/main/java/com/rehome/mqttclienttemperature/AdminClientTemperatureApplication.java
Unescape Escape View File

@ -19,9 +19,9 @@ import javax.annotation.Resource;
import java.util.Map; import java.util.Map;
@Slf4j @Slf4j
@EnableJpaAuditing //@EnableJpaAuditing
@EnableScheduling //@EnableScheduling
@EnableAsync //@EnableAsync
@SpringBootApplication @SpringBootApplication
public class AdminClientTemperatureApplication implements CommandLineRunner, ApplicationContextAware { public class AdminClientTemperatureApplication implements CommandLineRunner, ApplicationContextAware {

2
src/main/java/com/rehome/mqttclienttemperature/MqttDianDengTechClient.java
Unescape Escape View File

@ -112,7 +112,7 @@ public class MqttDianDengTechClient {
log.info("message RSA:"+strData); log.info("message RSA:"+strData);
if(strData!=null&&strData.length()>=11){ if(strData!=null&&strData.length()>=11){
String[] strDataTemperature = strData.split(" "); String[] strDataTemperature = strData.split(" ");
temperatureEspService.saveTemperature(strDataTemperature[0],strDataTemperature[1],s); //temperatureEspService.saveTemperature(strDataTemperature[0],strDataTemperature[1],s);
} }
} }

30
src/main/java/com/rehome/mqttclienttemperature/controller/JdbcDemoController.java
Unescape Escape View File

@ -53,7 +53,7 @@ import java.util.concurrent.*;
*/ */
@Slf4j @Slf4j
@RestController //@RestController
public class JdbcDemoController { public class JdbcDemoController {
@Resource @Resource
@ -64,20 +64,26 @@ public class JdbcDemoController {
static { static {
//配置数据源 //配置数据源
ds.setId("1"); // ds.setId("1");
ds.setName("mysql"); // ds.setName("mysql");
ds.setUrl("jdbc:mysql://192.168.1.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true"); // ds.setUrl("jdbc:mysql://192.168.1.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true");
ds.setUsername("root"); // ds.setUsername("root");
ds.setPassword("Skyinno251,"); // ds.setPassword("Skyinno251,");
ds.setDriver("com.mysql.cj.jdbc.Driver"); // ds.setDriver("com.mysql.cj.jdbc.Driver");
// ds.setId("2"); // ds.setId("2");
// ds.setName("oracle"); // ds.setName("oracle");
// ds.setUrl("jdbc:oracle:thin:@192.168.1.9:1521/orcl"); // ds.setUrl("jdbc:oracle:thin:@192.168.3.9:1521/orcl");
// ds.setUrl("jdbc:oracle:thin:@192.168.3.7:1521/orcl");
// ds.setUsername("appserver"); // ds.setUsername("appserver");
// ds.setPassword("appserver"); // ds.setPassword("appserver");
// ds.setDriver("oracle.jdbc.driver.OracleDriver"); // ds.setDriver("oracle.jdbc.driver.OracleDriver");
ds.setId("3");
ds.setName("sqlserver");
ds.setUrl("jdbc:sqlserver://192.168.3.29:1433;DatabaseName=appserver;encrypt=false");
ds.setUsername("sa");
ds.setPassword("452131wW");
ds.setDriver("com.microsoft.sqlserver.jdbc.SQLServerDriver");
} }
/** /**
@ -85,16 +91,16 @@ public class JdbcDemoController {
* *
* @return * @return
*/ */
//@RequestMapping("/api/list") @RequestMapping("/api/list")
public ResponseDto queryList() { public ResponseDto queryList() {
// 自定义一个线程池,内部包含8个线程 // 自定义一个线程池,内部包含8个线程
ExecutorService customPool = Executors.newFixedThreadPool(8); ExecutorService customPool = Executors.newFixedThreadPool(2);
// 自定义一个线程池,内部包含10个线程 // 自定义一个线程池,内部包含10个线程
ExecutorService executorService = Executors.newFixedThreadPool(10); ExecutorService executorService = Executors.newFixedThreadPool(10);
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
String sql = "select * from temperature where id = ?"; String sql = "select * from temperature where id = ?";
List<Object> jdbcParamValues = new ArrayList<>(); List<Object> jdbcParamValues = new ArrayList<>();
for (int i = 2292104; i < 2298700; i++) { for (int i = 2575155; i < 2600000; i++) {
jdbcParamValues.add(i + 1); jdbcParamValues.add(i + 1);
Gson gson = new Gson(); Gson gson = new Gson();
ResponseDto responseDto = JdbcUtil.executeSql(ds, sql, jdbcParamValues); ResponseDto responseDto = JdbcUtil.executeSql(ds, sql, jdbcParamValues);

14
src/main/java/com/rehome/mqttclienttemperature/entity/WebServiceProvince.java
Unescape Escape View File

@ -1,7 +1,7 @@
package com.rehome.mqttclienttemperature.entity; package com.rehome.mqttclienttemperature.entity;
import io.swagger.annotations.ApiModelProperty; //import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import org.hibernate.annotations.Proxy; import org.hibernate.annotations.Proxy;
import org.springframework.data.annotation.CreatedDate; import org.springframework.data.annotation.CreatedDate;
@ -18,27 +18,27 @@ import java.util.Date;
public class WebServiceProvince implements Serializable { public class WebServiceProvince implements Serializable {
@Id @Id
@GeneratedValue(strategy = GenerationType.IDENTITY) @GeneratedValue(strategy = GenerationType.IDENTITY)
@ApiModelProperty(value = "主键") //@ApiModelProperty(value = "主键")
private Long id; private Long id;
@ApiModelProperty(value = "洲、国内外省份") //@ApiModelProperty(value = "洲、国内外省份")
@Column(length = 100) @Column(length = 100)
private String provinceName; private String provinceName;
@ApiModelProperty(value = "日期") //@ApiModelProperty(value = "日期")
@Temporal(TemporalType.TIMESTAMP) @Temporal(TemporalType.TIMESTAMP)
@CreatedDate @CreatedDate
private Date createDate; private Date createDate;
@ApiModelProperty(value = "时") //@ApiModelProperty(value = "时")
@Column(length = 20) @Column(length = 20)
private String dataHour; private String dataHour;
@ApiModelProperty(value = "分") //@ApiModelProperty(value = "分")
@Column(length = 20) @Column(length = 20)
private String dataMinute; private String dataMinute;
@ApiModelProperty(value = "秒") //@ApiModelProperty(value = "秒")
@Column(length = 20) @Column(length = 20)
private String dataSecond; private String dataSecond;
} }

58
src/main/java/com/rehome/mqttclienttemperature/entity/WebServiceWeatherInfo.java
Unescape Escape View File

@ -1,6 +1,6 @@
package com.rehome.mqttclienttemperature.entity; package com.rehome.mqttclienttemperature.entity;
import io.swagger.annotations.ApiModelProperty; //import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import org.hibernate.annotations.Proxy; import org.hibernate.annotations.Proxy;
import org.springframework.data.annotation.CreatedDate; import org.springframework.data.annotation.CreatedDate;
@ -31,123 +31,123 @@ public class WebServiceWeatherInfo {
@Id @Id
@GeneratedValue(strategy = GenerationType.IDENTITY) @GeneratedValue(strategy = GenerationType.IDENTITY)
@ApiModelProperty(value = "主键") //@ApiModelProperty(value = "主键")
private Long id; private Long id;
@Column(length = 100) @Column(length = 100)
@ApiModelProperty(value = "洲、国内外省份名称") //@ApiModelProperty(value = "洲、国内外省份名称")
private String provinceName; private String provinceName;
@Column(length = 100) @Column(length = 100)
@ApiModelProperty(value = "国内外城市中文名称") //@ApiModelProperty(value = "国内外城市中文名称")
private String cityName; private String cityName;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "城市编号") //@ApiModelProperty(value = "城市编号")
private String cityCode; private String cityCode;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "城市图片名称") //@ApiModelProperty(value = "城市图片名称")
private String cityPhoto; private String cityPhoto;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "天气最后更新时间") //@ApiModelProperty(value = "天气最后更新时间")
private String weatherLastUpdate; private String weatherLastUpdate;
@Column(length = 20) @Column(length = 20)
@ApiModelProperty(value = "当天的 气温") //@ApiModelProperty(value = "当天的 气温")
private String weatherNow; private String weatherNow;
@ApiModelProperty(value = "概况") //@ApiModelProperty(value = "概况")
private String weatherShortDesc; private String weatherShortDesc;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "风向和风力") //@ApiModelProperty(value = "风向和风力")
private String windDesc; private String windDesc;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "天气趋势开始图片名称(以下称：图标一)") //@ApiModelProperty(value = "天气趋势开始图片名称(以下称：图标一)")
private String weatherTrendStart; private String weatherTrendStart;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "天气趋势结束图片名称(以下称：图标二)") //@ApiModelProperty(value = "天气趋势结束图片名称(以下称：图标二)")
private String weatherTrendEnd; private String weatherTrendEnd;
//存放长文本 //存放长文本
//@Lob //@Lob
//@Basic(fetch = FetchType.LAZY) //@Basic(fetch = FetchType.LAZY)
@ApiModelProperty(value = "现在的天气实况") //@ApiModelProperty(value = "现在的天气实况")
@Column(columnDefinition = "text") @Column(columnDefinition = "text")
private String weatherRealStatus; private String weatherRealStatus;
//存放长文本 //存放长文本
//@Lob //@Lob
//@Basic(fetch = FetchType.LAZY) //@Basic(fetch = FetchType.LAZY)
@ApiModelProperty(value = "天气和生活指数") //@ApiModelProperty(value = "天气和生活指数")
@Column(columnDefinition = "text") @Column(columnDefinition = "text")
private String weatherLiveIndex; private String weatherLiveIndex;
@Column(length = 20) @Column(length = 20)
@ApiModelProperty(value = "第二天的 气温") //@ApiModelProperty(value = "第二天的 气温")
private String nextDateTemperature; private String nextDateTemperature;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "第二天的 概况") //@ApiModelProperty(value = "第二天的 概况")
private String nextDateWeatherShortDesc; private String nextDateWeatherShortDesc;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "第二天的 风向和风力") //@ApiModelProperty(value = "第二天的 风向和风力")
private String nextDateWindDesc; private String nextDateWindDesc;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "第二天的 图标一") //@ApiModelProperty(value = "第二天的 图标一")
private String nextDateWeatherTrendStart; private String nextDateWeatherTrendStart;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "第二天的 图标二") //@ApiModelProperty(value = "第二天的 图标二")
private String nextDateWeatherTrendEnd; private String nextDateWeatherTrendEnd;
@Column(length = 20) @Column(length = 20)
@ApiModelProperty(value = "第三天的 气温") //@ApiModelProperty(value = "第三天的 气温")
private String threeDayTemperature; private String threeDayTemperature;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "第三天的 概况") //@ApiModelProperty(value = "第三天的 概况")
private String threeWeatherShortDesc; private String threeWeatherShortDesc;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "第三天的 风向和风力") //@ApiModelProperty(value = "第三天的 风向和风力")
private String threeDayWindDesc; private String threeDayWindDesc;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "第三天的 图标一") //@ApiModelProperty(value = "第三天的 图标一")
private String threeDayWeatherTrendStart; private String threeDayWeatherTrendStart;
@Column(length = 30) @Column(length = 30)
@ApiModelProperty(value = "第三天的 图标二") //@ApiModelProperty(value = "第三天的 图标二")
private String threeDayWeatherTrendEnd; private String threeDayWeatherTrendEnd;
@ApiModelProperty(value = "被查询的城市或地区的介绍") //@ApiModelProperty(value = "被查询的城市或地区的介绍")
//存放长文本 //存放长文本
// @Lob // @Lob
// @Basic(fetch = FetchType.LAZY) // @Basic(fetch = FetchType.LAZY)
@Column(columnDefinition = "text") @Column(columnDefinition = "text")
private String cityIntroduce; private String cityIntroduce;
@ApiModelProperty(value = "日期") //@ApiModelProperty(value = "日期")
@Temporal(TemporalType.TIMESTAMP) @Temporal(TemporalType.TIMESTAMP)
@CreatedDate @CreatedDate
private Date createDate; private Date createDate;
@ApiModelProperty(value = "时") //@ApiModelProperty(value = "时")
@Column(length = 20) @Column(length = 20)
private String dataHour; private String dataHour;
@ApiModelProperty(value = "分") //@ApiModelProperty(value = "分")
@Column(length = 20) @Column(length = 20)
private String dataMinute; private String dataMinute;
@ApiModelProperty(value = "秒") //@ApiModelProperty(value = "秒")
@Column(length = 20) @Column(length = 20)
private String dataSecond; private String dataSecond;

Write Preview
Loading…
Cancel
Save