Commit 611481f11c94b5bdd71afccee90756926134ab88

Authored by 朱园亮
1 parent b4f4172f

同池上报水电能源数据

... ... @@ -24,12 +24,12 @@ import java.util.Map;
24 24 @Service
25 25 public class KSDeviceReportService {
26 26
27   - @Value("${ks.third.jdbcUrl:jdbc:postgresql://192.168.0.249:5432/iot}")
  27 + @Value("${ks.third.jdbcUrl:jdbc:postgresql://106.15.73.210:5433/thingskit}")
28 28 private String jdbcUrl;
29 29 @Value("${ks.third.jdbcUserName:postgres}")
30 30 private String jdbcUserName;
31 31
32   - @Value("${ks.third.jdbcPassword:1qaz@WSX}")
  32 + @Value("${ks.third.jdbcPassword:thingskit}")
33 33 private String jdbcPassword;
34 34
35 35 @Value("${ks.third.selectSql:SELECT * FROM ts_kv_dictionary;}")
... ... @@ -38,7 +38,7 @@ public class KSDeviceReportService {
38 38 @Value("${ks.third.selectSql1:SELECT * FROM ts_kv_dictionary;}")
39 39 private String selectSql1;
40 40
41   - @Value("${ks.third.broker:192.168.0.249:1884}")
  41 + @Value("${ks.third.broker:117.71.99.102:11883}")
42 42 private String broker;
43 43 @Value("${ks.third.username:yunpower}")
44 44 private String username;
... ... @@ -46,9 +46,9 @@ public class KSDeviceReportService {
46 46 private String password;
47 47 @Value("${ks.third.topic:storage0}")
48 48 private String topic;
49   - @Value("${ks.third.clientId:2020672015207559170}")
  49 + @Value("${ks.third.clientId:tongchikeji}")
50 50 private String clientId;
51   - @Value("${ks.third.channelSn:8VAUR9H3}")
  51 + @Value("${ks.third.channelSn:B049Z974}")
52 52 private String channelSn;
53 53
54 54 public void deviceElectricity() {
... ...
1   -package com.iot.scheduler.zone;
2   -
3   -import com.iot.scheduler.task.AbstractZoneScheduler;
4   -import lombok.extern.slf4j.Slf4j;
5   -import org.springframework.scheduling.annotation.Scheduled;
6   -import org.springframework.stereotype.Component;
7   -
8   -@Slf4j
9   -@Component
10   -public class ChizhouZoneScheduler extends AbstractZoneScheduler {
11   -
12   - @Override
13   - protected String getZoneName() {
14   - return "Chizhou (池州经开区)";
15   - }
16   -
17   - @Scheduled(cron = "${scheduler.chizhou.pull:0 0/10 * * * ?}")
18   - public void pullDevicesFromThirdParty() {
19   - String taskName = "Pull Devices (3rd Party -> IoT)";
20   - logStart(taskName);
21   - try {
22   - // TODO: Implement actual logic
23   - log.info("[{}] Simulating pulling devices...", getZoneName());
24   - Thread.sleep(1000);
25   - } catch (Exception e) {
26   - logError(taskName, e);
27   - } finally {
28   - logEnd(taskName);
29   - }
30   - }
31   -
32   - @Scheduled(cron = "${scheduler.chizhou.push:0 0/15 * * * ?}")
33   - public void pushDevicesToThirdParty() {
34   - String taskName = "Push Devices (IoT -> 3rd Party)";
35   - logStart(taskName);
36   - try {
37   - // TODO: Implement actual logic
38   - log.info("[{}] Simulating pushing devices...", getZoneName());
39   - Thread.sleep(1000);
40   - } catch (Exception e) {
41   - logError(taskName, e);
42   - } finally {
43   - logEnd(taskName);
44   - }
45   - }
46   -}
src/main/java/com/iot/scheduler/zone/TongChiZoneScheduler.java renamed from src/main/java/com/iot/scheduler/zone/KaiShengZoneScheduler.java
... ... @@ -9,7 +9,7 @@ import org.springframework.stereotype.Component;
9 9
10 10 @Slf4j
11 11 @Component
12   -public class KaiShengZoneScheduler extends AbstractZoneScheduler {
  12 +public class TongChiZoneScheduler extends AbstractZoneScheduler {
13 13 @Resource
14 14 private KSDeviceReportService ksDeviceReportService;
15 15
... ...
... ... @@ -29,9 +29,9 @@ scheduler:
29 29 push: "0 0/5 * * * ?"
30 30 ks:
31 31 third:
32   - jdbcUrl: "jdbc:postgresql://192.168.0.249:5432/iot"
  32 + jdbcUrl: "jdbc:postgresql://106.15.73.210:5433/thingskit"
33 33 jdbcUserName: "postgres"
34   - jdbcPassword: "1qaz@WSX"
  34 + jdbcPassword: "thingskit"
35 35 selectSql: "SELECT
36 36 de.sn AS sn,
37 37 tkl1.dbl_v AS Ep,
... ... @@ -85,8 +85,8 @@ ks:
85 85 LEFT JOIN ts_kv_latest tkl16 ON de.id = tkl16.entity_id
86 86 AND tkl16.key = 79
87 87 WHERE
88   - de.organization_id='1697500a-dc11-45cc-88f5-2ad47472a9bb'
89   - AND de.device_profile_id = 'c2401630-ffec-11f0-926f-2f3182abc65f'"
  88 + de.organization_id='35bcdb94-31ec-4750-9ee9-cc855aa66e17'
  89 + AND de.device_profile_id = '6c1f9650-0298-11f1-9cb8-e3376d1e7978'"
90 90
91 91 selectSql1: "SELECT
92 92 de.sn AS sn,
... ... @@ -99,5 +99,5 @@ ks:
99 99 LEFT JOIN ts_kv_latest tkl2 ON de.id = tkl2.entity_id
100 100 AND tkl2.key = 84
101 101 WHERE
102   - de.organization_id='1697500a-dc11-45cc-88f5-2ad47472a9bb'
103   - AND de.device_profile_id = '4e404b10-ffe7-11f0-926f-2f3182abc65f'"
  102 + de.organization_id='35bcdb94-31ec-4750-9ee9-cc855aa66e17'
  103 + AND de.device_profile_id = 'fdf70e30-0272-11f1-9cb8-e3376d1e7978'"
... ...