Compare commits

..

No commits in common. "a4e810da126875b9daf2e06456ca0d7c8be20674" and "b2072073a93c9613ed7968db5d139b388ae7d90a" have entirely different histories.

6 changed files with 23 additions and 32 deletions

View File

@ -1,4 +1,4 @@
package com.genersoft.iot.vmp.common; package com.genersoft.iot.vmp.gb28181.bean;
public class RemoteAddressInfo { public class RemoteAddressInfo {
private String ip; private String ip;

View File

@ -5,7 +5,7 @@ import com.genersoft.iot.vmp.conf.UserSetting;
import com.genersoft.iot.vmp.gb28181.auth.DigestServerAuthenticationHelper; import com.genersoft.iot.vmp.gb28181.auth.DigestServerAuthenticationHelper;
import com.genersoft.iot.vmp.gb28181.bean.Device; import com.genersoft.iot.vmp.gb28181.bean.Device;
import com.genersoft.iot.vmp.gb28181.bean.GbSipDate; import com.genersoft.iot.vmp.gb28181.bean.GbSipDate;
import com.genersoft.iot.vmp.common.RemoteAddressInfo; import com.genersoft.iot.vmp.gb28181.bean.RemoteAddressInfo;
import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo; import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo;
import com.genersoft.iot.vmp.gb28181.service.IDeviceService; import com.genersoft.iot.vmp.gb28181.service.IDeviceService;
import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver; import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver;

View File

@ -5,7 +5,7 @@ import com.genersoft.iot.vmp.conf.DynamicTask;
import com.genersoft.iot.vmp.conf.UserSetting; import com.genersoft.iot.vmp.conf.UserSetting;
import com.genersoft.iot.vmp.gb28181.bean.Device; import com.genersoft.iot.vmp.gb28181.bean.Device;
import com.genersoft.iot.vmp.gb28181.bean.Platform; import com.genersoft.iot.vmp.gb28181.bean.Platform;
import com.genersoft.iot.vmp.common.RemoteAddressInfo; import com.genersoft.iot.vmp.gb28181.bean.RemoteAddressInfo;
import com.genersoft.iot.vmp.gb28181.bean.SipMsgInfo; import com.genersoft.iot.vmp.gb28181.bean.SipMsgInfo;
import com.genersoft.iot.vmp.gb28181.service.IDeviceService; import com.genersoft.iot.vmp.gb28181.service.IDeviceService;
import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent; import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent;

View File

@ -1,7 +1,7 @@
package com.genersoft.iot.vmp.gb28181.utils; package com.genersoft.iot.vmp.gb28181.utils;
import com.genersoft.iot.vmp.gb28181.bean.Gb28181Sdp; import com.genersoft.iot.vmp.gb28181.bean.Gb28181Sdp;
import com.genersoft.iot.vmp.common.RemoteAddressInfo; import com.genersoft.iot.vmp.gb28181.bean.RemoteAddressInfo;
import com.genersoft.iot.vmp.utils.DateUtil; import com.genersoft.iot.vmp.utils.DateUtil;
import com.genersoft.iot.vmp.utils.GitUtil; import com.genersoft.iot.vmp.utils.GitUtil;
import gov.nist.javax.sip.address.AddressImpl; import gov.nist.javax.sip.address.AddressImpl;

View File

@ -1,4 +1,3 @@
drop table if exists wvp_resources_tree; drop table if exists wvp_resources_tree;
drop table if exists wvp_platform_catalog; drop table if exists wvp_platform_catalog;
drop table if exists wvp_platform_gb_stream; drop table if exists wvp_platform_gb_stream;
@ -389,7 +388,7 @@ create table IF NOT EXISTS wvp_record_plan_item
); );
DELIMITER // -- 重定义分隔符避免分号冲突
CREATE PROCEDURE `wvp_20250111`() CREATE PROCEDURE `wvp_20250111`()
BEGIN BEGIN
@ -419,8 +418,7 @@ BEGIN
alter table wvp_cloud_record add server_id character varying(50); alter table wvp_cloud_record add server_id character varying(50);
update wvp_cloud_record set server_id = serverId; update wvp_cloud_record set server_id = serverId;
END IF; END IF;
END;// END;
call wvp_20250111(); call wvp_20250111();
DROP PROCEDURE wvp_20250111; DROP PROCEDURE wvp_20250111;
DELIMITER ;

View File

@ -1,7 +1,6 @@
/* /*
* 20240528 * 20240528
*/ */
DELIMITER // -- 重定义分隔符避免分号冲突
CREATE PROCEDURE `wvp_20240528`() CREATE PROCEDURE `wvp_20240528`()
BEGIN BEGIN
IF NOT EXISTS (SELECT column_name FROM information_schema.columns IF NOT EXISTS (SELECT column_name FROM information_schema.columns
@ -40,10 +39,9 @@ BEGIN
THEN THEN
alter table wvp_media_server add ws_flv_ssl_port integer; alter table wvp_media_server add ws_flv_ssl_port integer;
END IF; END IF;
END; // END;
call wvp_20240528(); call wvp_20240528();
DROP PROCEDURE wvp_20240528; DROP PROCEDURE wvp_20240528;
DELIMITER ;
create table IF NOT EXISTS wvp_user_api_key ( create table IF NOT EXISTS wvp_user_api_key (
id serial primary key , id serial primary key ,
@ -60,7 +58,6 @@ create table IF NOT EXISTS wvp_user_api_key (
/* /*
* 20241222 * 20241222
*/ */
DELIMITER // -- 重定义分隔符避免分号冲突
CREATE PROCEDURE `wvp_20241222`() CREATE PROCEDURE `wvp_20241222`()
BEGIN BEGIN
IF EXISTS (SELECT column_name FROM information_schema.STATISTICS IF EXISTS (SELECT column_name FROM information_schema.STATISTICS
@ -119,14 +116,13 @@ BEGIN
set wdc.data_type = 3, wdc.data_device_id = ct.stream_proxy_id where wdc.stream_proxy_id is not null; set wdc.data_type = 3, wdc.data_device_id = ct.stream_proxy_id where wdc.stream_proxy_id is not null;
alter table wvp_device_channel drop stream_proxy_id; alter table wvp_device_channel drop stream_proxy_id;
END IF; END IF;
END; // END;
call wvp_20241222(); call wvp_20241222();
DROP PROCEDURE wvp_20241222; DROP PROCEDURE wvp_20241222;
DELIMITER ;
/* /*
* 20241231 * 20241231
*/ */
DELIMITER //
CREATE PROCEDURE `wvp_20241231`() CREATE PROCEDURE `wvp_20241231`()
BEGIN BEGIN
IF not EXISTS (SELECT column_name FROM information_schema.columns IF not EXISTS (SELECT column_name FROM information_schema.columns
@ -134,14 +130,14 @@ BEGIN
THEN THEN
alter table wvp_stream_proxy add relates_media_server_id character varying(50); alter table wvp_stream_proxy add relates_media_server_id character varying(50);
END IF; END IF;
END; // END;
call wvp_20241231(); call wvp_20241231();
DROP PROCEDURE wvp_20241231; DROP PROCEDURE wvp_20241231;
DELIMITER ;
/* /*
* 20250111 * 20250111
*/ */
DELIMITER // -- 重定义分隔符避免分号冲突
CREATE PROCEDURE `wvp_20250111`() CREATE PROCEDURE `wvp_20250111`()
BEGIN BEGIN
IF EXISTS (SELECT column_name FROM information_schema.STATISTICS IF EXISTS (SELECT column_name FROM information_schema.STATISTICS
@ -161,15 +157,14 @@ BEGIN
THEN THEN
alter table wvp_cloud_record modify file_path varchar(500) null; alter table wvp_cloud_record modify file_path varchar(500) null;
END IF; END IF;
END; // END;
call wvp_20250111(); call wvp_20250111();
DROP PROCEDURE wvp_20250111; DROP PROCEDURE wvp_20250111;
DELIMITER ;
/* /*
* 20250211 * 20250211
*/ */
DELIMITER // -- 重定义分隔符避免分号冲突
CREATE PROCEDURE `wvp_20250211`() CREATE PROCEDURE `wvp_20250211`()
BEGIN BEGIN
IF EXISTS (SELECT column_name FROM information_schema.STATISTICS IF EXISTS (SELECT column_name FROM information_schema.STATISTICS
@ -189,15 +184,14 @@ BEGIN
THEN THEN
alter table wvp_device add position_capability integer; alter table wvp_device add position_capability integer;
END IF; END IF;
END; // END;
call wvp_20250211(); call wvp_20250211();
DROP PROCEDURE wvp_20250211; DROP PROCEDURE wvp_20250211;
DELIMITER ;
/** /**
* 20250312 * 20250312
*/ */
DELIMITER // -- 重定义分隔符避免分号冲突
CREATE PROCEDURE `wvp_20250312`() CREATE PROCEDURE `wvp_20250312`()
BEGIN BEGIN
DECLARE serverId VARCHAR(32) DEFAULT '你的服务ID'; DECLARE serverId VARCHAR(32) DEFAULT '你的服务ID';
@ -234,38 +228,37 @@ BEGIN
THEN THEN
alter table wvp_platform add server_id character varying(50); alter table wvp_platform add server_id character varying(50);
END IF; END IF;
END; // END;
call wvp_20250312(); call wvp_20250312();
DROP PROCEDURE wvp_20250312; DROP PROCEDURE wvp_20250312;
DELIMITER ;
/* /*
* 20250319 * 20250319
*/ */
DELIMITER // -- 重定义分隔符避免分号冲突
CREATE PROCEDURE `wvp_20250319`() CREATE PROCEDURE `wvp_20250319`()
BEGIN BEGIN
IF NOT EXISTS (SELECT column_name FROM information_schema.columns IF NOT EXISTS (SELECT column_name FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_speed') WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_speed')
THEN THEN
alter table wvp_device_channel add gps_speed double precision; alter table wvp_device_channel add gps_speed double precision;
END IF; END IF;
IF NOT EXISTS (SELECT column_name FROM information_schema.columns IF NOT EXISTS (SELECT column_name FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_altitude') WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_altitude')
THEN THEN
alter table wvp_device_channel add gps_altitude double precision; alter table wvp_device_channel add gps_altitude double precision;
END IF; END IF;
IF NOT EXISTS (SELECT column_name FROM information_schema.columns IF NOT EXISTS (SELECT column_name FROM information_schema.STATISTICS
WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_direction') WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_direction')
THEN THEN
alter table wvp_device_channel add gps_direction double precision; alter table wvp_device_channel add gps_direction double precision;
END IF; END IF;
END; // END;
call wvp_20250319(); call wvp_20250319();
DROP PROCEDURE wvp_20250319; DROP PROCEDURE wvp_20250319;
DELIMITER ;