Browse Source

物联设备

wsl 2 years ago
parent
commit
f6b5cfcdb0

+ 61 - 0
svr/svr-cloud-job/src/main/java/com/yihu/jw/care/config/jpa/ZhDeviceSyncJpa.java

@ -0,0 +1,61 @@
package com.yihu.jw.care.config.jpa;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.JpaVendorAdapter;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.persistence.EntityManagerFactory;
import javax.sql.DataSource;
/**
 * Created by wsl on 2022/11/8
 */
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "gsqflEntityManagerFactory",
        transactionManagerRef = "gsqflTransactionManager",
        basePackages = {"com.yihu.jw.care.zhDevice.dao"})
public class ZhDeviceSyncJpa {
    @Autowired
    private HibernateProperties hibernateProperties;
    @Bean(name = "gsqflDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.zhdevicePush")
    public DataSource zhylyjkglxtDataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean(name = "gsqflEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary(
            @Qualifier("gsqflDataSource") DataSource dataSource) {
        LocalContainerEntityManagerFactoryBean emfb = new LocalContainerEntityManagerFactoryBean();
        emfb.setDataSource(dataSource);
        emfb.setPackagesToScan("com.yihu.jw.care.zhDevice.entity");
        emfb.setPersistenceUnitName("zhdevicePush");
        JpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        emfb.setJpaVendorAdapter(vendorAdapter);
        emfb.setJpaProperties(hibernateProperties.hibProperties());
        return emfb;
    }
    @Bean(name = "gsqflTransactionManager")
    JpaTransactionManager transactionManagerSecondary(
            @Qualifier("gsqflEntityManagerFactory") EntityManagerFactory builder) {
        return new JpaTransactionManager(builder);
    }
}

+ 7 - 0
svr/svr-cloud-job/src/main/java/com/yihu/jw/care/event/ApplicationEvent.java

@ -298,6 +298,13 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
            }else {
            }else {
                logger.info("FAMILY_WECHAT_PUSH_DEVICE_JOB exist");
                logger.info("FAMILY_WECHAT_PUSH_DEVICE_JOB exist");
            }
            }
            if (!quartzHelper.isExistJob("DEVICE_SYNC_JOB")){
                String trigger =  SystemConf.getInstance().getSystemProperties().getProperty("DEVICE_SYNC_JOB");
                quartzHelper.addJob(DeviceSyncJob.class,trigger,"DEVICE_SYNC_JOB",new HashMap<String,Object>());
                logger.info("DEVICE_SYNC_JOB success");
            }else {
                logger.info("DEVICE_SYNC_JOB exist");
            }
        } catch (Exception e) {
        } catch (Exception e) {
            logger.info(" job start failed");
            logger.info(" job start failed");

+ 33 - 0
svr/svr-cloud-job/src/main/java/com/yihu/jw/care/job/device/DeviceSyncJob.java

@ -0,0 +1,33 @@
package com.yihu.jw.care.job.device;
import com.yihu.jw.care.service.device.DeviceSyncService;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
/**
 * Created by wsl on 2022/11/7
 */
public class DeviceSyncJob implements Job {
    private static Logger logger = LoggerFactory.getLogger(DeviceOffLoneJob.class);
    @Autowired
    private DeviceSyncService deviceSyncService;
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        logger.info("DeviceSyncJob start");
        try {
            deviceSyncService.deviceSync();
            logger.info("DeviceSyncJob end");
        } catch (Exception e) {
            logger.info("DeviceSyncJob --ERROR MSG:"+e.getMessage());
            e.printStackTrace();
        }
    }
}

+ 131 - 0
svr/svr-cloud-job/src/main/java/com/yihu/jw/care/service/device/DeviceSyncService.java

@ -0,0 +1,131 @@
package com.yihu.jw.care.service.device;
import com.yihu.jw.care.zhDevice.dao.ZhDeviceSyncDao;
import com.yihu.jw.care.zhDevice.entity.ZhDeviceSyncDO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
 * Created by wsl on 2022/11/7
 */
@Service
public class DeviceSyncService {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Autowired
    private ZhDeviceSyncDao zhDeviceSyncDao;
    public static void main(String[] args) {
        String abc = "24.48540661,118.09643550";
        String[] split = abc.split(",");
        System.out.println(split[0]);
    }
    public void deviceSync(){
        zhDeviceSyncDao.deleteAll();
        List<ZhDeviceSyncDO> listset = new ArrayList<>();
        String sql = "SELECT d.device_name as deviceName ,d.device_code as deviceSn,d.contact_status ,d.device_model,d.manufacturer,p.address AS patientAddress,p.lat_lon AS latLon,d.category_code FROM base.wlyy_devices d \n" +
                "    INNER JOIN base.wlyy_patient_device pd ON d.device_code = pd.device_sn INNER JOIN base.base_patient p ON p.id = pd.user where d.category_code NOT in(18,19,20,21) AND contact_status IS NOT NULL";
        List<Map<String, Object>> deviceList = jdbcTemplate.queryForList(sql);
        for (Map<String, Object> deviceS : deviceList) {
            ZhDeviceSyncDO zhDeviceSyncDO = new ZhDeviceSyncDO();
            String lat = "";
            String lng = "";
            String[] deviceSns = deviceS.get("deviceSn").toString().split(",");
            if (2<=deviceSns.length) {
                lat=deviceSns[0];
                lng=deviceSns[1];
            }
            zhDeviceSyncDO.setDeviceCode(deviceS.get("deviceSn").toString());//sn码
            zhDeviceSyncDO.setDeviceName(deviceS.get("deviceName").toString());//设备名称
            zhDeviceSyncDO.setManufacturer(deviceS.get("manufacturer")+"");//设备制造厂商
            zhDeviceSyncDO.setLinkType(4);//通讯方式  3-2G/3G/4G/5G、 4-WIFI
            zhDeviceSyncDO.setProvinceCode("330000");
            zhDeviceSyncDO.setProvinceName("浙江省");
            zhDeviceSyncDO.setCityCode("330100");
            zhDeviceSyncDO.setCityName("杭州市");
            zhDeviceSyncDO.setDistrictName("330105");
            zhDeviceSyncDO.setDistrictCode("拱墅区");
            zhDeviceSyncDO.setAddress(deviceS.get("patientAddress").toString());
            switch (deviceS.get("category_code").toString()) {
                case "14":  //气感
                    zhDeviceSyncDO.setDeviceTypeName("燃气泄漏监测");
                    zhDeviceSyncDO.setDeviceTypeCode("G1-009");
                    break;
                case "15":  //烟感
                    zhDeviceSyncDO.setDeviceTypeName("烟感检测");
                    zhDeviceSyncDO.setDeviceTypeCode("G6-013");
                    break;
                case "12": //防跌倒
                    zhDeviceSyncDO.setDeviceTypeName("防跌倒视频监测");
                    zhDeviceSyncDO.setDeviceTypeCode("S1-999");
                    break;
                case "2":   //血压
                    zhDeviceSyncDO.setDeviceTypeName("血压监测");
                    zhDeviceSyncDO.setDeviceTypeCode("G7-002");
                    break;
                case "1":   //血糖
                    zhDeviceSyncDO.setDeviceTypeName("血糖监测");
                    zhDeviceSyncDO.setDeviceTypeCode("G3-999");
                    break;
                case "13":  //睡眠带
                    zhDeviceSyncDO.setDeviceTypeName("睡眠带");
                    zhDeviceSyncDO.setDeviceTypeCode("Z2-005");
                    break;
                case "16":
                    zhDeviceSyncDO.setDeviceTypeName("云芯防走失拐杖");
                    zhDeviceSyncDO.setDeviceTypeCode("G99-999");
                    break;
                case "4":
                    zhDeviceSyncDO.setDeviceTypeName("X1防走失拐杖");
                    zhDeviceSyncDO.setDeviceTypeCode("G99-999");
                    break;
                case "7":
                    zhDeviceSyncDO.setDeviceTypeName("SOS紧急呼叫器");
                    zhDeviceSyncDO.setDeviceTypeCode("J1-001");
                    break;
                default:
                    break;
            }
            zhDeviceSyncDO.setLat(lat);//维
            zhDeviceSyncDO.setLng(lng);//经
            zhDeviceSyncDO.setState(Integer.parseInt(deviceS.get("contact_status").toString()));//0-离线,1-在线,3-停用(长期离线)
            if (1!=Integer.parseInt(deviceS.get("contact_status").toString())){
                zhDeviceSyncDO.setDisabledType(4);
                zhDeviceSyncDO.setReason("长时间未连接网络获取最新状态!默认判定离线状态");
            }
            zhDeviceSyncDO.setTransmissionIntercal(00000);//传输间隔
            zhDeviceSyncDO.setDept("朝辉街道");
            zhDeviceSyncDO.setScene1("r-0");
            zhDeviceSyncDO.setScene2("r-60");
            zhDeviceSyncDO.setScene3("r-604");
            //zhDeviceSyncDO.setUnifiedAddressCode();//政法委统一地 址库编码
            listset.add(zhDeviceSyncDO);
        }
        zhDeviceSyncDao.save(listset);
    }
}

+ 11 - 0
svr/svr-cloud-job/src/main/java/com/yihu/jw/care/zhDevice/dao/ZhDeviceSyncDao.java

@ -0,0 +1,11 @@
package com.yihu.jw.care.zhDevice.dao;
import com.yihu.jw.care.zhDevice.entity.ZhDeviceSyncDO;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.repository.PagingAndSortingRepository;
/**
 * Created by wsl on 2022/11/7
 */
public interface ZhDeviceSyncDao extends PagingAndSortingRepository<ZhDeviceSyncDO, String>, JpaSpecificationExecutor<ZhDeviceSyncDO> {
}

+ 563 - 0
svr/svr-cloud-job/src/main/java/com/yihu/jw/care/zhDevice/entity/ZhDeviceSyncDO.java

@ -0,0 +1,563 @@
package com.yihu.jw.care.zhDevice.entity;
import com.yihu.jw.entity.iot.gateway.IdEntity;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Table;
/**
 * Created by wsl on 2022/11/7
 */
@Entity
@Table(name = "device_sync")
public class ZhDeviceSyncDO extends IdEntity {
    /**
     * 设备名称
     */
    private String deviceName;
    /**
     * 设备sn码
     */
    private String deviceCode;
    /**
     * 版本号
     */
    private String version;
    /**
     * 设备型号
     */
    private String productKey;
    /**
     * mac 地址/imei码
     */
    private String mac;
    /**
     * 设备类型编码
     */
    private String deviceTypeCode;
    /**
     * 设备类型名称
     */
    private String deviceTypeName;
    /**
     * 生产日期
     */
    private String productionDate;
    /**
     * 生产批次
     */
    private String batchProduction;
    /**
     * 设备制造商
     */
    private String manufacturer;
    /**
     * 网关识别码
     */
    private String gateway;
    /**
     * 自定义字段
     */
    private String extendInfo;
    /**
     * 通讯方式
     */
    private Integer linkType;
    /**
     * 通讯卡号
     */
    private String cardNum;
    /**
     * 集成商名称
     */
    private String integrator;
    /**
     * 上线日期
     */
    private String installDate;
    /**
     * 位置信息类别 1-楼宇,2-电梯,3-车库,4-室外
     */
    private String orgCode;
    /**
     * 安装人员
     */
    private String installPerson;
    /**
     * 省编码
     */
    private String provinceCode;
    /**
     * 省
     */
    private String provinceName;
    /**
     * 市编码
     */
    private String cityCode;
    /**
     * 市
     */
    private String cityName;
    /**
     * 区编码
     */
    private String districtCode;
    /**
     * 区
     */
    private String districtName;
    /**
     * 街道编码
     */
    private String streetCode;
    /**
     * 街道名称
     */
    private String streetName;
    /**
     * 位置信息
     */
    private String address;
    /**
     * 地图经度
     */
    private String lng;
    /**
     * 地图纬度
     */
    private String lat;
    /**
     * 数据状态 1-新增/修改,-1-删除
     */
    private Integer state;
    /**
     * 停用原因
     */
    private Integer disabledType;
    /**
     * 停用原因说明
     */
    private String reason;
    /**
     * 传输间隔
     */
    private Integer transmissionIntercal;
    /**
     * 部门/单位
     */
    private String dept;
    /**
     * 设备管理者
     */
    private String manager;
    /**
     * 设备使用者
     */
    private String user;
    /**
     * 一级场景编码
     */
    private String scene1;
    /**
     * 二级场景编码
     */
    private String scene2;
    /**
     * 三级场景编码
     */
    private String scene3;
    /**
     * 政法委统一地 址库编码
     */
    private String unifiedAddressCode;
    @Column(name = "product_key")
    public String getProductKey() {
        return productKey;
    }
    public void setProductKey(String productKey) {
        this.productKey = productKey;
    }
    public String getMac() {
        return mac;
    }
    public void setMac(String mac) {
        this.mac = mac;
    }
    @Column(name = "device_name")
    public String getDeviceName() {
        return deviceName;
    }
    public void setDeviceName(String deviceName) {
        this.deviceName = deviceName;
    }
    @Column(name = "device_code")
    public String getDeviceCode() {
        return deviceCode;
    }
    public void setDeviceCode(String deviceCode) {
        this.deviceCode = deviceCode;
    }
    public String getVersion() {
        return version;
    }
    public void setVersion(String version) {
        this.version = version;
    }
    @Column(name = "device_type_code")
    public String getDeviceTypeCode() {
        return deviceTypeCode;
    }
    public void setDeviceTypeCode(String deviceTypeCode) {
        this.deviceTypeCode = deviceTypeCode;
    }
    @Column(name = "device_type_name")
    public String getDeviceTypeName() {
        return deviceTypeName;
    }
    public void setDeviceTypeName(String deviceTypeName) {
        this.deviceTypeName = deviceTypeName;
    }
    @Column(name = "production_date")
    public String getProductionDate() {
        return productionDate;
    }
    public void setProductionDate(String productionDate) {
        this.productionDate = productionDate;
    }
    @Column(name = "batch_production")
    public String getBatchProduction() {
        return batchProduction;
    }
    public void setBatchProduction(String batchProduction) {
        this.batchProduction = batchProduction;
    }
    @Column(name = "manufacturer" )
    public String getManufacturer() {
        return manufacturer;
    }
    public void setManufacturer(String manufacturer) {
        this.manufacturer = manufacturer;
    }
    public String getGateway() {
        return gateway;
    }
    public void setGateway(String gateway) {
        this.gateway = gateway;
    }
    @Column(name = "extend_info")
    public String getExtendInfo() {
        return extendInfo;
    }
    public void setExtendInfo(String extendInfo) {
        this.extendInfo = extendInfo;
    }
    @Column(name = "link_type")
    public Integer getLinkType() {
        return linkType;
    }
    public void setLinkType(Integer linkType) {
        this.linkType = linkType;
    }
    @Column(name = "card_num")
    public String getCardNum() {
        return cardNum;
    }
    public void setCardNum(String cardNum) {
        this.cardNum = cardNum;
    }
    public String getIntegrator() {
        return integrator;
    }
    public void setIntegrator(String integrator) {
        this.integrator = integrator;
    }
    @Column(name = "install_date")
    public String getInstallDate() {
        return installDate;
    }
    public void setInstallDate(String installDate) {
        this.installDate = installDate;
    }
    @Column(name = "org_code")
    public String getOrgCode() {
        return orgCode;
    }
    public void setOrgCode(String orgCode) {
        this.orgCode = orgCode;
    }
    @Column(name = "install_person")
    public String getInstallPerson() {
        return installPerson;
    }
    public void setInstallPerson(String installPerson) {
        this.installPerson = installPerson;
    }
    @Column(name = "province_code")
    public String getProvinceCode() {
        return provinceCode;
    }
    public void setProvinceCode(String provinceCode) {
        this.provinceCode = provinceCode;
    }
    @Column(name = "province_name")
    public String getProvinceName() {
        return provinceName;
    }
    public void setProvinceName(String provinceName) {
        this.provinceName = provinceName;
    }
    @Column(name = "city_code")
    public String getCityCode() {
        return cityCode;
    }
    public void setCityCode(String cityCode) {
        this.cityCode = cityCode;
    }
    @Column(name = "city_name")
    public String getCityName() {
        return cityName;
    }
    public void setCityName(String cityName) {
        this.cityName = cityName;
    }
    @Column(name = "district_code")
    public String getDistrictCode() {
        return districtCode;
    }
    public void setDistrictCode(String districtCode) {
        this.districtCode = districtCode;
    }
    @Column(name = "district_name")
    public String getDistrictName() {
        return districtName;
    }
    public void setDistrictName(String districtName) {
        this.districtName = districtName;
    }
    @Column(name = "street_code")
    public String getStreetCode() {
        return streetCode;
    }
    public void setStreetCode(String streetCode) {
        this.streetCode = streetCode;
    }
    @Column(name = "street_name")
    public String getStreetName() {
        return streetName;
    }
    public void setStreetName(String streetName) {
        this.streetName = streetName;
    }
    public String getAddress() {
        return address;
    }
    public void setAddress(String address) {
        this.address = address;
    }
    public String getLng() {
        return lng;
    }
    public void setLng(String lng) {
        this.lng = lng;
    }
    public String getLat() {
        return lat;
    }
    public void setLat(String lat) {
        this.lat = lat;
    }
    public Integer getState() {
        return state;
    }
    public void setState(Integer state) {
        this.state = state;
    }
    @Column(name = "disabled_type")
    public Integer getDisabledType() {
        return disabledType;
    }
    public void setDisabledType(Integer disabledType) {
        this.disabledType = disabledType;
    }
    public String getReason() {
        return reason;
    }
    public void setReason(String reason) {
        this.reason = reason;
    }
    @Column(name = "transmission_intercal")
    public Integer getTransmissionIntercal() {
        return transmissionIntercal;
    }
    public void setTransmissionIntercal(Integer transmissionIntercal) {
        this.transmissionIntercal = transmissionIntercal;
    }
    public String getDept() {
        return dept;
    }
    public void setDept(String dept) {
        this.dept = dept;
    }
    public String getManager() {
        return manager;
    }
    public void setManager(String manager) {
        this.manager = manager;
    }
    public String getUser() {
        return user;
    }
    public void setUser(String user) {
        this.user = user;
    }
    public String getScene1() {
        return scene1;
    }
    public void setScene1(String scene1) {
        this.scene1 = scene1;
    }
    public String getScene2() {
        return scene2;
    }
    public void setScene2(String scene2) {
        this.scene2 = scene2;
    }
    public String getScene3() {
        return scene3;
    }
    public void setScene3(String scene3) {
        this.scene3 = scene3;
    }
    @Column(name = "unified_address_code")
    public String getUnifiedAddressCode() {
        return unifiedAddressCode;
    }
    public void setUnifiedAddressCode(String unifiedAddressCode) {
        this.unifiedAddressCode = unifiedAddressCode;
    }
}

+ 45 - 1
svr/svr-cloud-job/src/main/java/com/yihu/jw/care/zhylyjkglxt/sql记录.sql

@ -672,4 +672,48 @@ CREATE TABLE `base_infant_activity` (
-- 设备同步
CREATE TABLE `device_sync` (
                               `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
                               `device_name` varchar(50) NOT NULL COMMENT '设备名称',
                               `device_code` varchar(50) NOT NULL COMMENT '设备sn码',
                               `version` varchar(20) DEFAULT NULL COMMENT '版本号',
                               `DEFAULT NULL` varchar(50) DEFAULT NULL COMMENT '设备型号',
                               `DEFAULT NULL` varchar(50) DEFAULT NULL COMMENT 'MAC 地址/IMEI码',
                               `device_type_code` varchar(50) NOT NULL COMMENT '设备类型编码',
                               `device_type_name` varchar(50) NOT NULL COMMENT '设备类型名称',
                               `production_date` varchar(20) DEFAULT NULL COMMENT '生产日期',
                               `batch_production` varchar(20) DEFAULT NULL COMMENT '生产批次',
                               `manufacturer` varchar(15) NOT NULL COMMENT '设备制造商',
                               `gateway` varchar(50) DEFAULT NULL COMMENT '网关识别码',
                               `extend_info` varchar(20) DEFAULT NULL COMMENT '自定义字段',
                               `link_type` INT(2) NOT NULL COMMENT '通讯方式',
                               `card_num` varchar(50) DEFAULT NULL COMMENT '通讯卡号',
                               `integrator` varchar(50) DEFAULT NULL COMMENT '集成商名称',
                               `install_date` varchar(50) DEFAULT NULL COMMENT '上线日期',
                               `org_code` varchar(15) DEFAULT NULL COMMENT '位置信息类别 1-楼宇,2-电梯,3-车库,4-室外',
                               `install_person` varchar(50) DEFAULT NULL COMMENT '安装人员',
                               `province_code` varchar(50) NOT NULL COMMENT '省编码',
                               `province_name` varchar(50) NOT NULL COMMENT '省',
                               `city_code` varchar(50) NOT NULL COMMENT '市编码',
                               `city_name` varchar(50) NOT NULL COMMENT '市',
                               `district_code` varchar(50) NOT NULL COMMENT '区编码',
                               `district_name` varchar(50) NOT NULL COMMENT '区',
                               `street_code` varchar(50) DEFAULT NULL COMMENT '街道编码',
                               `street_name` varchar(50) DEFAULT NULL COMMENT '街道名称',
                               `address` varchar(50) NOT NULL COMMENT '位置信息',
                               `lng` varchar(50) NOT NULL COMMENT '地图经度',
                               `lat` varchar(50) NOT NULL COMMENT '地图纬度',
                               `state` INT(50) NOT NULL COMMENT '数据状态 1-新增/修改,-1-删除',
                               `disabled_type` INT(50) DEFAULT NULL COMMENT '停用原因',
                               `reason` varchar(50) DEFAULT NULL COMMENT '停用原因说明',
                               `transmission_intercal` INT(10) DEFAULT NULL COMMENT '传输间隔',
                               `dept` varchar(20) NOT NULL COMMENT '部门/单位',
                               `manager` varchar(20) DEFAULT NULL COMMENT '设备管理者',
                               `user` varchar(20) DEFAULT NULL COMMENT '设备使用者',
                               `scene1` varchar(20) NOT NULL COMMENT '一级场景编码',
                               `scene2` varchar(20) NOT NULL COMMENT '二级场景编码',
                               `scene3` varchar(20) NOT NULL COMMENT '三级场景编码',
                               `unified_address_code` varchar(20) NOT NULL COMMENT '政法委统一地 址库编码',
                               PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='设备基础信息同步';

+ 4 - 0
svr/svr-cloud-job/src/main/resources/application.yml

@ -193,6 +193,10 @@ spring:
      jdbcUrl: jdbc:mysql://10.71.83.98:3306/gsq_zhjd_zhylyjkglxt?useUnicode:true&amp;characterEncoding=utf-8&amp;autoReconnect=true&useSSL=false
      jdbcUrl: jdbc:mysql://10.71.83.98:3306/gsq_zhjd_zhylyjkglxt?useUnicode:true&amp;characterEncoding=utf-8&amp;autoReconnect=true&useSSL=false
      username: gsq_zhjd_zhylyjkglxt
      username: gsq_zhjd_zhylyjkglxt
      password: 'GSQ_YTHPT@2021'
      password: 'GSQ_YTHPT@2021'
    zhdevicePush:
      jdbcUrl: jdbc:mysql://10.18.44.26:3306/gsqfl?useUnicode:true&amp;characterEncoding=utf-8&amp;autoReconnect=true&useSSL=false
      username: gsq_flzz
      password: 'GsFL_634gdfas'
  activemq:
  activemq:
    broker-url: tcp://10.18.43.40:61616
    broker-url: tcp://10.18.43.40:61616
    user: admin
    user: admin

+ 3 - 1
svr/svr-cloud-job/src/main/resources/system.properties

@ -55,4 +55,6 @@ DEL_PUSH_MESSAGE_WEATHER_FORECAST_JOB = 0 5 0 * * ?
#\u6BCF\u5929\u665A\u4E0A8\u70B9\u9644\u9001\u671D\u6656\u65E5\u62A5
#\u6BCF\u5929\u665A\u4E0A8\u70B9\u9644\u9001\u671D\u6656\u65E5\u62A5
PUSH_ZHAO_HUI_RI_BAO_JOB = 0 0 20 * * ?
PUSH_ZHAO_HUI_RI_BAO_JOB = 0 0 20 * * ?
#\u5BB6\u5C5E\u5FAE\u4FE1\u63A8\u9001 \u6BCF\u5929\u65E9\u4E0A\u5341\u70B9
#\u5BB6\u5C5E\u5FAE\u4FE1\u63A8\u9001 \u6BCF\u5929\u65E9\u4E0A\u5341\u70B9
FAMILY_WECHAT_PUSH_DEVICE_JOB = 0 0 10 * * ?
FAMILY_WECHAT_PUSH_DEVICE_JOB = 0 0 10 * * ?
#\u6BCF\u5929 \u7269\u8054\u8BBE\u5907\u5BF9\u63A5 \u63A8\u6B7B
DEVICE_SYNC_JOB = 0 0 23 * * ?