Skip to content

D
docker-iot-v3
Commit 1c8ffdf0 authored by 吴文龙's avatar 吴文龙
Browse files
Options

update

parent bd02ea1e
Hide whitespace changes
Inline Side-by-side
Showing with 602 additions and 902 deletions
db/iot_dbapi.sql deleted 100644 → 0
View file @ bd02ea1e
/*
Navicat Premium Data Transfer
Source Server : 47.96.236.169
Source Server Type : MySQL
Source Server Version : 80028
Source Host : 47.96.236.169:33306
Source Schema : iot_dbapi
Target Server Type : MySQL
Target Server Version : 80028
File Encoding : 65001
Date: 28/11/2022 19:47:18
*/
SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;
-- ----------------------------
-- Table structure for api_auth
-- ----------------------------
DROP TABLE IF EXISTS `api_auth`;
CREATE TABLE `api_auth` (
`id` int NOT NULL AUTO_INCREMENT,
`token_id` int DEFAULT NULL,
`group_id` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of api_auth
-- ----------------------------
BEGIN;
INSERT INTO `api_auth` (`id`, `token_id`, `group_id`) VALUES (7, 1, 'XlscLq30');
INSERT INTO `api_auth` (`id`, `token_id`, `group_id`) VALUES (8, 2, 'XlscLq30');
COMMIT;
-- ----------------------------
-- Table structure for api_config
-- ----------------------------
DROP TABLE IF EXISTS `api_config`;
CREATE TABLE `api_config` (
`id` varchar(255) NOT NULL,
`path` varchar(255) DEFAULT NULL,
`name` varchar(255) DEFAULT NULL,
`note` varchar(255) DEFAULT NULL,
`params` text,
`status` int DEFAULT NULL,
`datasource_id` varchar(255) DEFAULT NULL,
`previlege` int DEFAULT NULL,
`group_id` varchar(255) DEFAULT NULL,
`cache_plugin` varchar(255) DEFAULT NULL,
`cache_plugin_params` varchar(255) DEFAULT NULL,
`create_time` varchar(20) DEFAULT NULL,
`update_time` varchar(20) DEFAULT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `path` (`path`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of api_config
-- ----------------------------
BEGIN;
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('0qLjHowN', 'v1_switch_detail', '南泰君霖对外接口-班组开停机状态查询', NULL, '[{\"name\":\"date\",\"type\":\"string\",\"note\":\"营业日期\"},{\"name\":\"deviceName\",\"type\":\"string\",\"note\":\"设备名称\"},{\"name\":\"grpcode\",\"type\":\"string\",\"note\":\"班组am或pm\"},{\"name\":\"grptype\",\"type\":\"string\",\"note\":\"分区\"}]', 1, 'kSC2Qziy', 0, 'XlscLq30', NULL, NULL, '2022-11-15 13:55:43', '2022-11-15 14:05:44');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('3qxDmpBG', 'dbapi/f_set_trep_group_detail', '生产-保存班组能耗数据', NULL, '[]', 1, 'kSC2Qziy', 1, 'OPKu3Okm', NULL, NULL, '2022-09-29 14:32:10', '2022-11-15 21:31:37');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('5SeUCRJy', 'dbapi/f_rep_device_groups_detail', 'f_rep_device_groups_detail', NULL, '[{\"name\":\"did\",\"type\":\"string\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-10-10 12:27:08', '2022-11-04 00:33:28');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('7TVjkWPy', 'f_set_days_key_detail', '生产-保存每日能耗数据-停用', NULL, '[]', 0, 'kSC2Qziy', 1, 'OGvyLgXx', NULL, NULL, '2022-11-02 16:48:26', '2022-11-16 01:45:39');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('9xFhax2y', 'junlin_hous_key', 'junlin_hous_key', NULL, '[]', 1, 'kSC2Qziy', 1, 'OPKu3Okm', NULL, NULL, '2022-09-24 08:05:07', '2022-09-24 19:00:16');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('B1ANmtET', 'f_set_sta_detail', '生产-当前状态持续时长统计', NULL, '[]', 1, 'kSC2Qziy', 1, 'OGvyLgXx', NULL, NULL, '2022-10-16 00:45:27', '2022-11-16 16:19:48');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('bw6ULlLe', 'f_func_rep_test', 'f_func_rep_test', NULL, '[]', 1, 'EhgozRdv', 1, 'OGvyLgXx', NULL, NULL, '2022-09-24 23:20:40', '2022-09-24 23:47:39');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('cD4sCi7I', 'v1_group_detail', '南泰君霖对外接口-班组能耗查询', NULL, '[{\"name\":\"deviceName\",\"type\":\"string\",\"note\":\"设备名称\"},{\"name\":\"propName\",\"type\":\"string\",\"note\":\"属性名称\"},{\"name\":\"grpcode\",\"type\":\"string\",\"note\":\"班组am或pm\"},{\"name\":\"grptype\",\"type\":\"string\",\"note\":\"分组A区或B区等\"},{\"name\":\"arr\",\"type\":\"string\",\"note\":\"开始日期\"},{\"name\":\"dep\",\"type\":\"string\",\"note\":\"结束日期\"}]', 1, 'kSC2Qziy', 0, 'XlscLq30', NULL, NULL, '2022-11-15 13:25:47', '2022-11-17 10:26:06');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('CQ9VkAr9', 'dbapi/f_rep_hour_key_detail', 'f_rep_hour_key_detail', NULL, '[{\"name\":\"tid\",\"type\":\"string\",\"note\":\"租户ID\"},{\"name\":\"grpid\",\"type\":\"string\",\"note\":\"分组ID\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-09-24 09:49:48', '2022-11-04 00:37:17');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('EeBkndxU', 'f_set_hours_switch_detail', '生产-每小时保存开停机变化数据', NULL, '[]', 1, 'kSC2Qziy', 1, 'OGvyLgXx', NULL, NULL, '2022-11-12 13:35:21', '2022-11-14 13:52:41');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('EnFpExkx', 'dbapi/f_rep_days_hours_device', 'f_rep_days_hours_device', NULL, '[{\"name\":\"did\",\"type\":\"string\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-09-27 23:30:00', '2022-09-29 13:47:12');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('FNMVwfcu', 'f_set_group_switch_detail', '生产-班组保存开停机状态', NULL, '[]', 1, 'kSC2Qziy', 1, 'OGvyLgXx', NULL, NULL, '2022-11-12 13:36:00', '2022-11-14 13:52:57');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('hGLKRYiu', 'f_trep_day_detail', 'f_trep_day_detail', NULL, '[{\"name\":\"month\",\"type\":\"string\",\"note\":\"日期示例10代表10月\"},{\"name\":\"deviceName\",\"type\":\"string\",\"note\":\"设备名称\"},{\"name\":\"propName\",\"type\":\"string\",\"note\":\"属性名称\"},{\"name\":\"year\",\"type\":\"string\",\"note\":\"年份\"},{\"name\":\"grptype\",\"type\":\"string\",\"note\":\"分组A区或B区等\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-10-09 23:36:54', '2022-11-15 15:55:42');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('HYORZYyI', 'dbapi/f_rep_yesterday_key_sum', 'f_rep_yesterday_key_sum', NULL, '[{\"name\":\"tid\",\"type\":\"string\"},{\"name\":\"grpid\",\"type\":\"string\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-11-03 17:43:35', '2022-11-03 18:25:46');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('IHQJLVtr', 'dbapi/f_rep_group_key_sum', 'f_rep_group_key_sum', NULL, '[{\"name\":\"tid\",\"type\":\"string\"},{\"name\":\"grpid\",\"type\":\"string\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-11-03 17:42:58', '2022-11-04 00:12:09');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('K4QZT40A', 'f_junlin_rep_out_key', 'f_junlin_rep_out_key', NULL, '[{\"name\":\"bdate\",\"type\":\"string\",\"note\":\"日期\"}]', 1, 'kSC2Qziy', 0, 'XlscLq30', NULL, NULL, '2022-09-28 14:49:53', '2022-09-28 14:49:53');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('kU15HMrE', 'dbapi/f_rep_device_days_detail', 'f_rep_device_days_detail', NULL, '[{\"name\":\"did\",\"type\":\"string\",\"note\":\"设备ID\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-10-10 11:38:43', '2022-10-11 12:06:28');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('N8sgjOWD', 'dbapi/f_rep_hour_key_sum', 'f_rep_hour_key_sum', NULL, '[{\"name\":\"tid\",\"type\":\"string\"},{\"name\":\"grpid\",\"type\":\"string\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-09-25 22:26:44', '2022-11-03 15:23:25');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('pjYii91f', 'f_junlin_temp_cache', '生产-君霖定制处理缓存数据', NULL, '[]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-11-16 02:05:49', '2022-11-16 02:05:49');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('RSuNGzhs', 'f_set_day_switch_detail', '生产-每日保存开停机数据', NULL, '[]', 1, 'kSC2Qziy', 1, 'OGvyLgXx', NULL, NULL, '2022-11-12 13:36:36', '2022-11-14 13:53:12');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('tCoVivD8', 'dbapi/f_set_hour_key_detail', '生产-每小时保存能耗数据', NULL, '[]', 1, 'kSC2Qziy', 1, 'OGvyLgXx', NULL, NULL, '2022-09-26 13:38:15', '2022-11-15 22:41:30');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('UDzGSkeZ', 'set_tcode_base', 'set_tcode_base', NULL, '[]', 1, 'kSC2Qziy', 1, 'OPKu3Okm', NULL, NULL, '2022-09-24 09:24:20', '2022-09-24 09:24:20');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('v7p2AAqp', 'v1_device_detail', '南泰君霖对外接口-设备实时采集数据查询', NULL, '[{\"name\":\"deviceName\",\"type\":\"string\",\"note\":\"设备名称\"},{\"name\":\"key\",\"type\":\"string\",\"note\":\"属性名称\"},{\"name\":\"grptype\",\"type\":\"string\",\"note\":\"分区\"}]', 1, 'kSC2Qziy', 0, 'XlscLq30', NULL, NULL, '2022-11-15 14:25:59', '2022-11-15 14:27:35');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('VyCtYO0f', 'dbapi/f_rep_device_lastDays_detail', 'f_rep_device_lastDays_detail', NULL, '[{\"name\":\"did\",\"type\":\"string\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-11-03 18:39:46', '2022-11-03 18:44:56');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('wFz52Yb1', 'dbapi/f_rep_device_months_detail', 'f_rep_device_months_detail', NULL, '[{\"name\":\"did\",\"type\":\"string\",\"note\":\"设备ID\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-10-10 12:30:16', '2022-10-11 12:13:20');
INSERT INTO `api_config` (`id`, `path`, `name`, `note`, `params`, `status`, `datasource_id`, `previlege`, `group_id`, `cache_plugin`, `cache_plugin_params`, `create_time`, `update_time`) VALUES ('xfXpHIg0', 'f_trep_group_detail', 'f_trep_group_detail', NULL, '[{\"name\":\"date\",\"type\":\"string\",\"note\":\"日期\"},{\"name\":\"deviceName\",\"type\":\"string\",\"note\":\"设备名称\"},{\"name\":\"propName\",\"type\":\"string\",\"note\":\"属性名称\"},{\"name\":\"grpcode\",\"type\":\"string\",\"note\":\"班组am或pm\"},{\"name\":\"grptype\",\"type\":\"string\",\"note\":\"分组A区B区等\"}]', 1, 'kSC2Qziy', 1, 'XlscLq30', NULL, NULL, '2022-09-29 15:11:36', '2022-11-17 10:25:20');
COMMIT;
-- ----------------------------
-- Table structure for api_group
-- ----------------------------
DROP TABLE IF EXISTS `api_group`;
CREATE TABLE `api_group` (
`id` varchar(255) NOT NULL,
`name` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `name` (`name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of api_group
-- ----------------------------
BEGIN;
INSERT INTO `api_group` (`id`, `name`) VALUES ('OGvyLgXx', '公共分组');
INSERT INTO `api_group` (`id`, `name`) VALUES ('OPKu3Okm', '南泰君霖');
INSERT INTO `api_group` (`id`, `name`) VALUES ('XlscLq30', '南泰君霖-输出');
COMMIT;
-- ----------------------------
-- Table structure for api_sql
-- ----------------------------
DROP TABLE IF EXISTS `api_sql`;
CREATE TABLE `api_sql` (
`id` int NOT NULL AUTO_INCREMENT,
`api_id` varchar(11) NOT NULL,
`sql_text` text NOT NULL,
`transform_plugin` varchar(255) DEFAULT NULL,
`transform_plugin_params` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=267 DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of api_sql
-- ----------------------------
BEGIN;
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (4, 'UDzGSkeZ', 'insert into tcode_device(tid,fid,fname,wid,wname,grpid,grpname,gid,gname,did,dname,knumb,kcnt,sort,halt,htime,ctime,mtime)\nSELECT \nt.tid,t.fid,t.fname,t.wid,t.wname,t.grpid,t.grpname,t.gid,t.gname,\nt.did,t.dname,count(1) as key_cnt ,\nsum(t.volume_on_day) as keyval_cnt,\n\'1000\' as sort,\n\'F\' as halt,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP\nfrom vcode_key_detail t \nGROUP BY t.tid,t.fid,t.fname,t.wid,t.wname,t.grpid,t.grpname,t.gid,t.gname,t.did,t.dname\nORDER BY t.dname desc \nON conflict(tid,did)\ndo update set \nfid = EXCLUDED.fid,\nfname = EXCLUDED.fname,\nwid = EXCLUDED.wid,\nwname = EXCLUDED.wname,\ngrpid = EXCLUDED.grpid,\ngrpname = EXCLUDED.grpname,\ngid = EXCLUDED.gid,\ngname = EXCLUDED.gname,\ndname = EXCLUDED.dname,\nknumb = EXCLUDED.knumb,\nkcnt = EXCLUDED.kcnt,\nmtime = CURRENT_TIMESTAMP;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (48, '9xFhax2y', 'INSERT into trep_hkey_detail(tid,did,key,bdate,hours,val,ctime,mtime)\nSELECT t.tid,t.did, \n case when t.key = \'gas\' then \'蒸汽\' \n when t.key = \'正向累积数值整数部分\' then \'碱用量\'\n else t.key \n end as key ,\n current_date as bdate,\ndate_part(\'hour\', CURRENT_TIME) as hours,t.val_ex ,\nCURRENT_TIMESTAMP ,CURRENT_TIMESTAMP\nfrom \n(\n SELECT \n to_number(a.val,\'999999999.999999999\') + to_number(b.val,\'999999999.999999999\') as val_ex,\n a.* from \n (\n SELECT t.* from vcode_key_detail t \n where t.key = \'正向累积数值整数部分\'\n \n ) a,\n (\n SELECT t.* from vcode_key_detail t \n WHERE t.key = \'正向累积数值小数部分\'\n ) b\n where a.tid = b.tid and \n a.did = b.did and \n a.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\'\n union all \n SELECT to_number(t.val,\'999999999.999999999\') as val_ex,t.* from vcode_key_detail t \n where t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n t.key = \'gas\'\n) t\nON CONFLICT (tid,did,key,bdate,hours)\nDO UPDATE SET \nval = EXCLUDED.val,\nmtime = CURRENT_TIMESTAMP;\n \n\n\n ', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (50, 'bw6ULlLe', 'begin;\nSELECT func05(\'cur_open\');\nfetch all in cur_open;\nend; ', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (72, 'K4QZT40A', 'SELECT t.* from trep_dkey_detail t \nwhere t.bdate = #{bdate} and \n t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\'', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (77, 'EnFpExkx', 'SELECT t.key,\njsonb_agg(b) as arr\nfrom tcode_model_detail_ex t\n left JOIN \n (select concat(bdate,\' \',hours,\':00:00\')::TIMESTAMP::VARCHAR as time ,tid,key as nkey,val as value \n from trep_hkey_detail \n where ctime >= (CURRENT_TIMESTAMP - interval \'24 hour\')) b \non t.tid = b.tid and \n t.key = b.nkey \nwhere t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n t.code = \'all\' and \n substr(t.ex_s1,1,1) = \'1\'\nGROUP BY t.key;\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (151, 'kU15HMrE', 'SELECT case when t.key = \'蒸汽\' then \'vapor\'\n when t.key = \'碱用量\' then \'alkali\' \n else t.key end as key,t.sort,jsonb_agg(b ORDER BY b.bdate,to_number(b.hours, \'99\')) as arr\n from tcode_model_detail_ex t\n left JOIN \n (select concat(bdate,\' \',hours,\':00:00\')::TIMESTAMP::VARCHAR as time,tid,\n case when key = \'蒸汽\' then \'vapor\'\n when key = \'碱用量\' then \'alkali\' \n else key end as nkey,val as value ,bdate,hours\n from trep_hkey_detail \n where bdate = CURRENT_DATE and \n did::varchar = #{did}\n ) b \n on t.tid = b.tid and \n t.key = b.nkey \n where t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n t.code = \'all\' and \n t.key in (\'vapor\',\'alkali\',\'electric\',\'gas\',\'water\')\n GROUP BY t.key,t.sort\n ORDER BY t.sort', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (153, 'wFz52Yb1', 'SELECT case when t.key = \'蒸汽\' then \'vapor\'\n when t.key = \'碱用量\' then \'alkali\' \n else t.key end as key,t.sort,jsonb_agg(b ORDER BY b.bdate,to_number(b.hours, \'99\')) as arr\n from tcode_model_detail_ex t\n left JOIN \n (select concat(bdate,\' \',hours,\':00:00\')::TIMESTAMP::VARCHAR as time,tid,\n case when key = \'蒸汽\' then \'vapor\'\n when key = \'碱用量\' then \'alkali\' \n else key end as nkey,val as value ,bdate,hours\n from trep_hkey_detail \n where bdate = CURRENT_DATE and \n did::varchar = #{did}\n ) b \n on t.tid = b.tid and \n t.key = b.nkey \n where t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n t.code = \'all\' and \n t.key in (\'vapor\',\'alkali\',\'electric\',\'gas\',\'water\')\n GROUP BY t.key,t.sort\n ORDER BY t.sort', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (193, 'N8sgjOWD', 'SELECT b.* from (\n SELECT case when a.key = \'alkali\' then \'碱用量\'\n when a.key = \'vapor\' then \'蒸汽\'\n else a.key \n end as name ,\n a.val as value,\n case when a.key = \'alkali\' then \'1020\'\n when a.key = \'vapor\' then \'1010\'\n else a.key \n end as sort \n from (\n SELECT t.key,\n sum(to_number(val_dep, \'9999999999999999999.99\'))-sum(to_number(val_arr, \'9999999999999999999.99\')) as val\n from trep_hkey_detail t,vcode_key_detail b \n where t.tid = b.tid and \n t.did = b.did and \n t.key = b.key and \n (t.tid::VARCHAR = #{tid}) AND\n (\'\'=#{grpid} or b.grpid::VARCHAR= #{grpid}) and \n t.key in (\'vapor\',\'alkali\') and \n t.bdate = CURRENT_DATE \n group by t.key \n ) a \n) b \norder by b.sort\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (194, 'N8sgjOWD', 'SELECT \'蒸汽\' as name,sum(value) as value from (\n SELECT \n concat(a.bdate,\' \',a.hours,\':00:00\')::timestamp as time,\n (a.cval - b.cval) as value,\n a.key,a.hours,a.did\nfrom \n(SELECT to_number(t.val,\'999999999.99\') as cval,t.*,\n b.dname,b.id\n from trep_hkey_detail t,tcode_device b \n where t.tid = b.id and \n t.tid::character varying= #{tid} and \n (\'\' = \'\' or b.gid::character varying = \'\') and \n t.did = b.did and \n t.bdate = CURRENT_DATE - 1\n) a,\n(SELECT to_number(t.val,\'999999999.99\') as cval,t.*,\n b.dname,b.id\n from trep_hkey_detail t,tcode_device b \n where t.tid = b.id and \n t.tid::character varying= #{tid} and \n (\'\' = \'\' or b.gid::character varying = \'\') and \n t.did = b.did and \n t.bdate = CURRENT_DATE - 1\n) b \nwhere a.tid = b.id and \n a.did = b.did and \n a.key = b.key and \n a.key = \'蒸汽\' and \n a.bdate = b.bdate and \n to_number(a.hours,\'999999999\') - 1 = to_number(b.hours, \'999999999\')\n) t \nunion all \nSELECT \'碱用量\' as name,sum(value) as value from (\n SELECT \n concat(a.bdate,\' \',a.hours,\':00:00\')::timestamp as time,\n (a.cval - b.cval) as value,\n a.key,a.hours,a.did\nfrom \n(SELECT to_number(t.val,\'999999999.99\') as cval,t.*,\n b.dname,b.id\n from trep_hkey_detail t,tcode_device b \n where t.tid = b.id and \n t.tid::character varying= #{tid} and \n (\'\' = \'\' or b.gid::character varying = \'\') and \n t.did = b.did and \n t.bdate = CURRENT_DATE - 1\n) a,\n(SELECT to_number(t.val,\'999999999.99\') as cval,t.*,\n b.dname,b.id\n from trep_hkey_detail t,tcode_device b \n where t.tid = b.id and \n t.tid::character varying= #{tid} and \n (\'\' = \'\' or b.gid::character varying = \'\') and \n t.did = b.did and \n t.bdate = CURRENT_DATE -1 \n) b \nwhere a.tid = b.id and \n a.did = b.did and \n a.key = b.key and \n a.key = \'碱用量\' and \n a.bdate = b.bdate and \n to_number(a.hours,\'999999999\') - 1 = to_number(b.hours, \'999999999\')\n) t \n\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (202, 'HYORZYyI', 'SELECT name, sum(value) as value \nfrom \n( \n SELECT to_number(t.val_dep,\'9999999999999999999.99\') - to_number(t.val_arr, \'9999999999999999999.99\') as value,\n b.name,t.key,c.descript,d.dname,d.grpname,\n t.bdate,to_char(t.ctime,\'yyyy-mm-dd hh24:mi:ss\') as ctime,to_char(t.mtime,\'yyyy-mm-dd hh24:mi:ss\') as mtime \n from trep_group_detail t,tcode_model_detail_ex b,tcode_group c ,vcode_key_detail d \n where t.tid = b.tid and \n t.tid = c.tid and \n t.tid = d.tid and \n t.did = d.did and \n t.key = d.key and \n t.grpcode = c.code and \n t.bdate = CURRENT_DATE-1 and \n t.key in (\'vapor\',\'alkali\') and \n (t.tid::VARCHAR = #{tid}) AND\n (\'\'=#{grpid} or d.grpid::VARCHAR= #{grpid}) and \n b.code = \'all\' and \n d.grpname != \'\' and \n t.key = b.key and \n substr(b.ex_s1,3,1) = \'1\'\n) a\ngroup by a.name \nORDER BY a.name desc \n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (203, 'HYORZYyI', 'SELECT b.* from (\n SELECT case when a.key = \'alkali\' then \'碱用量\'\n when a.key = \'vapor\' then \'蒸汽\'\n else a.key \n end as name ,\n a.val as value,\n case when a.key = \'alkali\' then \'1020\'\n when a.key = \'vapor\' then \'1010\'\n else a.key \n end as sort \n from (\n SELECT t.key,\n sum(to_number(val_dep, \'9999999999999999999.99\'))-sum(to_number(val_arr, \'9999999999999999999.99\')) as val\n from trep_hkey_detail t,vcode_key_detail b \n where t.tid = b.tid and \n t.did = b.did and \n t.key = b.key and \n (t.tid::VARCHAR = #{tid}) AND\n (\'\'=#{grpid} or b.grpid::VARCHAR= #{grpid}) and \n t.key in (\'vapor\',\'alkali\') and \n t.bdate = CURRENT_DATE \n group by t.key \n ) a \n) b \norder by b.sort\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (205, 'VyCtYO0f', 'SELECT case when t.key = \'蒸汽\' then \'vapor\'\n when t.key = \'碱用量\' then \'alkali\' \n else t.key end as key,t.sort,jsonb_agg(b ORDER BY b.bdate,to_number(b.hours, \'99\')) as arr\n from tcode_model_detail_ex t\n left JOIN \n (select concat(bdate,\' \',hours,\':00:00\')::TIMESTAMP::VARCHAR as time,tid,\n case when key = \'蒸汽\' then \'vapor\'\n when key = \'碱用量\' then \'alkali\' \n else key end as nkey,val as value ,bdate,hours\n from trep_hkey_detail \n where bdate = CURRENT_DATE -1 and \n did::varchar = #{did}\n ) b \n on t.tid = b.tid and \n t.key = b.nkey \n where t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n t.code = \'all\' and \n t.key in (\'vapor\',\'alkali\',\'electric\',\'gas\',\'water\')\n GROUP BY t.key,t.sort\n ORDER BY t.sort', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (210, 'IHQJLVtr', 'SELECT name, sum(value) as value \nfrom \n( \n SELECT to_number(t.val_dep,\'9999999999999999999.99\') - to_number(t.val_arr, \'9999999999999999999.99\') as value,\n b.name,t.key,c.descript,d.dname,d.grpname,\n t.bdate,to_char(t.ctime,\'yyyy-mm-dd hh24:mi:ss\') as ctime,to_char(t.mtime,\'yyyy-mm-dd hh24:mi:ss\') as mtime \n from trep_group_detail t,tcode_model_detail_ex b,(\n SELECT a.* from\n (\n SELECT CONCAT((CURRENT_DATE)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group t\n where t.dep >= t.arr\n union\n SELECT CONCAT((CURRENT_DATE)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE+1)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group t\n where t.dep < t.arr\n union\n SELECT CONCAT((CURRENT_DATE-1)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group t\n where t.dep < t.arr\n ) a\n where CURRENT_TIMESTAMP > a.tarr and\n CURRENT_TIMESTAMP <= a.tdep\n limit 1\n ) c ,vcode_key_detail d \n where t.tid = b.tid and \n t.tid = c.tid and \n t.tid = d.tid and \n t.did = d.did and \n t.key = d.key and \n t.grpcode = c.code and \n (t.ctime BETWEEN c.tarr and c.tdep) and \n t.key in (\'vapor\',\'alkali\') and \n (t.tid::VARCHAR = #{tid}) AND\n (\'\'=#{grpid} or d.grpid::VARCHAR= #{grpid}) and \n b.code = \'all\' and \n d.grpname != \'\' and \n t.key = b.key and \n substr(b.ex_s1,3,1) = \'1\'\n) a\ngroup by a.name \nORDER BY a.name desc \n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (211, 'IHQJLVtr', 'SELECT b.* from (\n SELECT case when a.key = \'alkali\' then \'碱用量\'\n when a.key = \'vapor\' then \'蒸汽\'\n else a.key \n end as name ,\n a.val as value,\n case when a.key = \'alkali\' then \'1020\'\n when a.key = \'vapor\' then \'1010\'\n else a.key \n end as sort \n from (\n SELECT t.key,\n sum(to_number(val_dep, \'9999999999999999999.99\'))-sum(to_number(val_arr, \'9999999999999999999.99\')) as val\n from trep_hkey_detail t,vcode_key_detail b \n where t.tid = b.tid and \n t.did = b.did and \n t.key = b.key and \n (t.tid::VARCHAR = #{tid}) AND\n (\'\'=#{grpid} or b.grpid::VARCHAR= #{grpid}) and \n t.key in (\'vapor\',\'alkali\') and \n t.bdate = CURRENT_DATE \n group by t.key \n ) a \n) b \norder by b.sort\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (215, '5SeUCRJy', 'SELECT case when t.key = \'蒸汽\' then \'vapor\'\n when t.key = \'碱用量\' then \'alkali\' \n else t.key end as key,t.sort,jsonb_agg(b ORDER BY b.bdate,to_number(b.hours, \'99\')) as arr\n from tcode_model_detail_ex t\n left JOIN \n (select concat(bdate,\' \',hours,\':00:00\')::TIMESTAMP::VARCHAR as time,tid,\n case when key = \'蒸汽\' then \'vapor\'\n when key = \'碱用量\' then \'alkali\' \n else key end as nkey,val as value ,bdate,hours\n from trep_hkey_detail \n where DATE_PART(\'Day\',CURRENT_DATE::timestamp - ctime::timestamp) < 1 and \n DATE_PART(\'hour\',ctime) <= 24 and \n did::varchar = #{did}\n ) b \n on t.tid = b.tid and \n t.key = b.nkey \n where t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n t.code = \'all\' and \n t.key in (\'vapor\',\'alkali\',\'electric\',\'gas\',\'water\')\n GROUP BY t.key,t.sort\n ORDER BY t.sort', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (216, 'CQ9VkAr9', 'SELECT a.time,a.key,sum(value) as value \nfrom (\nSELECT \n concat(t.bdate,\' \',t.hours,\':00:00\')::timestamp as time,\n t.key,\n (to_number(t.val_dep, \'9999999999999999.99\'))-(to_number(t.val_arr, \'9999999999999999.99\')) as value\nfrom trep_hkey_detail t,vcode_key_detail b \nwhere \n (\'\' = #{tid} or t.tid::VARCHAR = #{tid}) and\n (\'\' = #{grpid} or b.grpid::varchar = #{grpid}) and \n t.key in (\'vapor\') and \n t.tid = b.tid and \n t.did = b.did and \n t.key = b.key and \n DATE_PART(\'Day\',CURRENT_DATE::timestamp - t.ctime::timestamp) < 1 and \n DATE_PART(\'hour\',t.ctime) <= 24 \n order by t.bdate,right(concat(\'00\',t.hours),2)\n) a\nGROUP BY a.time,a.key \nORDER BY a.time,a.key', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (217, 'CQ9VkAr9', 'SELECT a.time,a.key,sum(value) as value \nfrom (\nSELECT \n concat(t.bdate,\' \',t.hours,\':00:00\')::timestamp as time,\n t.key,\n (to_number(t.val_dep, \'9999999999999999.99\'))-(to_number(t.val_arr, \'9999999999999999.99\')) as value\nfrom trep_hkey_detail t,vcode_key_detail b \nwhere \n (\'\' = #{tid} or t.tid::VARCHAR = #{tid}) and\n (\'\' = #{grpid} or b.grpid::varchar = #{grpid}) and \n t.key in (\'alkali\') and \n t.tid = b.tid and \n t.did = b.did and \n t.key = b.key and \n t.ctime > CURRENT_DATE - 1\n order by t.bdate,right(concat(\'00\',t.hours),2)\n) a\nGROUP BY a.time,a.key \nORDER BY a.time,a.key;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (225, 'EeBkndxU', 'insert into trep_hours_sta_detail as thsd (tid,did,key,bdate,hours,cron,len,val,time,ctime,mtime,created_time,updated_time)\nSELECT a.tid,a.did,a.key,CURRENT_DATE,\n date_part(\'hour\', CURRENT_TIME) as hours,\n 20 as cron,1 as len ,\n a.val,20*1,\n CURRENT_TIMESTAMP,CURRENT_TIMESTAMP,\n (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8,\n (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8\nfrom \n(\n SELECT t.tid,t.did,t.key,\n case when round(date_part(\'epoch\', now()::timestamp - t.update_time::timestamp)::NUMERIC / 60) >= 5 then \'9\' \n else t.val \n end as val\n from vcode_key_detail t ,tcode_model_detail b \n where t.tid = b.tenant_id and \n t.key = b.key and \n b.code = \'default\' and \n b.change = true\n) a\nON CONFLICT (tid,did,key,bdate,hours,val)\nDO UPDATE SET \nlen = thsd.len + EXCLUDED.len,\ntime = (thsd.len + EXCLUDED.len) * 20,\nmtime = CURRENT_TIMESTAMP,\nupdated_time = (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8;\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (226, 'FNMVwfcu', '\ninsert into trep_group_sta_detail as trep \n (tid,did,bdate,grpcode,key,val,cron,len,time,ctime,mtime,created_time,updated_time)\nSELECT a.tid,a.did,a.tarr::date as bdate,a.code,a.key,\n a.val,\n 20 as cron,1 as len ,\n 20*1 as time,\n CURRENT_TIMESTAMP,CURRENT_TIMESTAMP,\n (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8,\n (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8 \nfrom \n(\n SELECT t.tid,t.did,t.key,\n case when round(date_part(\'epoch\', now()::timestamp - t.update_time::timestamp)::NUMERIC / 60) >= 5 then \'9\' \n else t.val \n end as val,c.code,c.descript,c.tarr,c.tdep\n from vcode_key_detail t ,tcode_model_detail b,(\n SELECT a.* from\n (\n SELECT CONCAT((CURRENT_DATE)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE+tdays)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group t\n UNION\n SELECT CONCAT((CURRENT_DATE-tdays)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group t\n where t.tdays > 0\n \n ) a \n where (CURRENT_TIMESTAMP BETWEEN a.tarr and a.tdep) \n ) c\n where t.tid = b.tenant_id and \n t.tid = c.tid and \n t.key = b.key and \n b.code = \'default\' and \n b.change = true\n) a\nON CONFLICT (tid,did,bdate,grpcode,key,val)\nDO UPDATE SET \nlen = trep.len + EXCLUDED.len,\ntime = (trep.len + EXCLUDED.len) * 20,\nmtime = CURRENT_TIMESTAMP,\nupdated_time = (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8;\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (227, 'RSuNGzhs', 'insert into trep_day_sta_detail as trep \n (tid,did,bdate,key,val,cron,len,time,ctime,mtime,created_time,updated_time)\nSELECT a.tid,a.did,a.tarr::date as bdate,a.key,\n a.val,\n 20 as cron,1 as len ,\n 20*1 as time,\n CURRENT_TIMESTAMP,CURRENT_TIMESTAMP,\n (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8,\n (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8 \nfrom \n(\n SELECT t.tid,t.did,t.key,\n case when round(date_part(\'epoch\', now()::timestamp - t.update_time::timestamp)::NUMERIC / 60) >= 5 then \'9\' \n else t.val \n end as val,c.tarr,c.tdep\n from vcode_key_detail t ,tcode_model_detail b,(\n SELECT a.* from\n (\n SELECT CONCAT((CURRENT_DATE)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE+tdays)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group_days t\n UNION\n SELECT CONCAT((CURRENT_DATE-tdays)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group_days t\n where t.tdays > 0\n \n ) a \n where (CURRENT_TIMESTAMP BETWEEN a.tarr and a.tdep) \n ) c\n where t.tid = b.tenant_id and \n t.tid = c.tid and \n t.key = b.key and \n b.code = \'default\' and \n b.change = true\n) a\nON CONFLICT (tid,did,bdate,key,val)\nDO UPDATE SET \nlen = trep.len + EXCLUDED.len,\ntime = (trep.len + EXCLUDED.len) * 20,\nmtime = CURRENT_TIMESTAMP,\nupdated_time = (extract(epoch from CURRENT_TIMESTAMP) * 1000)::int8;\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (235, '0qLjHowN', 'SELECT t.*,\n d.fid,d.fname,d.wid,d.wname,d.grpid,d.grpname,d.gid,d.gname,d.dname,d.volume_on_day \n from trep_group_sta_detail t,tcode_group c ,vcode_key_detail d \n where t.tid = d.tid and \n t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n t.tid = c.tid and \n t.tid = d.tid and \n t.key = d.key and \n t.grpcode = c.code and \n t.bdate::varchar = #{date}::varchar and \n (d.dname like concat(#{deviceName},\'%\') or \'\' = #{deviceName}) and \n (c.code = #{grpcode} or \'\' = #{grpcode}) and \n (d.grpname like concat(#{grptype},\'%\') or \'\' = #{grptype}) and \n d.grpname != \'\' ;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (237, 'v7p2AAqp', 'SELECT t.* \nfrom vcode_key_detail t \nwhere t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n (t.dname like concat(#{deviceName},\'%\') or \'\' = #{deviceName}) and \n (t.key = #{key} or \'\' = #{key}) and \n (t.grpname like concat(#{grptype},\'%\') or \'\' = #{grptype}) and \n t.grpname != \'\' ;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (240, 'hGLKRYiu', 'SELECT to_number(t.val_dep,\'9999999999999999999.9999\') - to_number(t.val_arr, \'9999999999999999999.9999\') as value,\n b.name,d.dname,d.key,d.grpname,\n t.bdate,to_char(t.ctime,\'yyyy-mm-dd hh24:mi:ss\') as ctime,to_char(t.mtime,\'yyyy-mm-dd hh24:mi:ss\') as mtime \n from trep_dkey_detail t,tcode_model_detail_ex b,vcode_key_detail d\n where t.tid = b.tid and \n t.tid = d.tid and \n t.did = d.did and \n t.key = d.key and \n (t.bdate BETWEEN concat(to_char(date_trunc(\'month\', concat(#{year},\'-\',#{month},\'-01\')::DATE - interval \'1\' month),\'yyyy-mm\'),\'-26\')::DATE and \n concat(#{year},\'-\',#{month},\'-25\')::DATE) and \n (d.dname like concat(#{deviceName},\'%\') or \'\' = #{deviceName}) and \n (b.name like concat(#{propName},\'%\') or \'\' = #{propName}) and \n (d.grpname like concat(#{grptype},\'%\') or \'\' = #{grptype}) and \n b.code = \'all\' and \n t.key = b.key and \n d.grpname != \'\' and \n substr(b.ex_s1,3,1) = \'1\'\n ORDER BY bdate desc,grpname,dname,key asc ;\n ', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (246, '3qxDmpBG', 'SELECT trep_group_detail_function();', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (247, '3qxDmpBG', 'INSERT into trep_dkey_detail(tid,did,key,bdate,ctime,mtime,val,val_dep,val_arr)\nselect a.tid,a.did,a.key,a.bdate,\nmin(a.ctime),max(a.mtime),\n(to_number(min(val_arr), \'999999999999999.99\') + sum(a.value))::varchar as val,\n(to_number(min(val_arr), \'999999999999999.99\') + sum(a.value))::varchar as val_dep,\nmin(val_arr) as val_arr\nfrom \n(\nSELECT t.*,to_number(t.val_dep, \'999999999999999.9999\') - to_number(t.val_arr, \'999999999999999.9999\') as value \nfrom trep_group_detail t\nwhere t.bdate = CURRENT_DATE\n) a\ngroup by a.tid,a.did,a.key,a.bdate\nON CONFLICT (tid,did,key,bdate)\nDO UPDATE SET \nval = EXCLUDED.val,\nval_dep = EXCLUDED.val_dep,\nmtime = CURRENT_TIMESTAMP;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (248, 'tCoVivD8', 'INSERT into trep_hkey_detail(tid,did,key,bdate,hours,val,ctime,mtime,val_arr,val_dep)\nSELECT t.tid,t.did, t.key,current_date as bdate,\ndate_part(\'hour\', CURRENT_TIME) as hours,t.val ,\nCURRENT_TIMESTAMP ,CURRENT_TIMESTAMP,\nt.val,t.val\n from vcode_key_detail t,tcode_model_detail b\nwhere t.tid = b.tenant_id and \n t.key = b.key and \n b.code = \'default\' and \n b.halt = \'F\' and \n b.hour = true \n ON CONFLICT (tid,did,key,bdate,hours)\nDO UPDATE SET \nval = EXCLUDED.val,\nval_dep = EXCLUDED.val_dep,\nmtime = CURRENT_TIMESTAMP;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (249, 'tCoVivD8', 'update trep_hkey_detail \n set peak = case when c.switch = 1 then \n (to_number(val_dep,\'9999999999999999999.99\') - to_number(val_arr, \'9999999999999999999.99\'))::varchar else \n \'0.00\' end ,\n valley = case when c.switch = 0 then \n (to_number(val_dep,\'9999999999999999999.99\') - to_number(val_arr, \'9999999999999999999.99\'))::varchar else \n \'0.00\' end \n from \n (SELECT case when CURRENT_TIME >= \'08:00\'::time then 1\n else 0 end \n as switch) c\nwhere bdate = CURRENT_DATE and \n hours = date_part(\'hour\', CURRENT_TIME)::varchar and \n key = \'electric\';', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (250, '7TVjkWPy', 'INSERT into trep_dkey_detail(tid,did,key,bdate,val_arr,val_dep,val,ctime,mtime) \nSELECT t.tid,t.did,t.key,c.tarr::date as bdate,\n t.val,t.val,t.val,CURRENT_TIMESTAMP,CURRENT_TIMESTAMP\n from vcode_key_detail t ,tcode_model_detail b,\n (\n SELECT a.* from\n (\n SELECT CONCAT((CURRENT_DATE)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE+tdays)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group_days t\n UNION\n SELECT CONCAT((CURRENT_DATE-tdays)::TEXT,\' \',t.arr)::TIMESTAMP as tarr,\n CONCAT((CURRENT_DATE)::TEXT,\' \',t.dep)::TIMESTAMP as tdep,\n t.* from tcode_group_days t\n where t.tdays > 0\n \n ) a \n where (CURRENT_TIMESTAMP BETWEEN a.tarr and a.tdep) \n ) c\n where \n t.tid = b.tenant_id and \n t.tid = c.tid and \n t.key = b.key and \n b.code = \'default\' and \n b.day = true\nON CONFLICT (tid,did,key,bdate)\nDO UPDATE SET \nval_dep = EXCLUDED.val_dep,\nmtime = CURRENT_TIMESTAMP;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (251, '7TVjkWPy', 'update trep_dkey_detail \n set peak = (to_number(val_dep,\'9999999999999999999.99\') - to_number(val_arr, \'9999999999999999999.99\'))::varchar,\n valley = \'0.00\'\nwhere bdate = CURRENT_DATE and \n key = \'electric\';', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (252, 'pjYii91f', 'SELECT tmp_cache_group_detail_function();', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (262, 'B1ANmtET', 'insert into trep_sta_detail(tid,did,key,val_arr,val_dep)\nSELECT a.tid,a.did,a.key,a.val as val_arr,a.val as val_dep\nfrom \n(\n SELECT t.tid,t.did,t.key,\n min(case when round(date_part(\'epoch\', now()::timestamp - \n (select max(update_time)\n from vcode_key_detail x \n where x.tid = t.tid and \n x.did = t.did and \n x.key = t.key \n )::timestamp\n )::NUMERIC / 60) >= 5 then \'9\' \n else t.val \n end ) as val\n from vcode_key_detail t ,tcode_model_detail b \n where t.tid = b.tenant_id and \n t.key = b.key and \n b.code = \'default\' and \n b.change = true \n GROUP BY t.tid,t.did,t.key\n) a\nON CONFLICT (tid,did,key)\nDO UPDATE SET \nval_dep = EXCLUDED.val_dep,\nmtime = CURRENT_TIMESTAMP;\n\n', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (263, 'B1ANmtET', 'INSERT into trep_hsta_detail(tid,did,key,val,arr,dep)\nSELECT t.tid,t.did,t.key,t.val_arr,t.ctime,t.mtime\n from trep_sta_detail t \n where t.val_arr != t.val_dep ;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (264, 'B1ANmtET', 'UPDATE trep_sta_detail \n set val_arr = val_dep,ctime = CURRENT_TIMESTAMP \n where val_arr != val_dep;', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (265, 'xfXpHIg0', 'SELECT to_number(t.val_dep,\'9999999999999999999.9999\') - to_number(t.val_arr, \'9999999999999999999.9999\') as value,\n b.name,c.descript,d.dname,d.grpname,\n t.bdate,to_char(t.ctime,\'yyyy-mm-dd hh24:mi:ss\') as ctime,to_char(t.mtime,\'yyyy-mm-dd hh24:mi:ss\') as mtime \n from trep_group_detail t,tcode_model_detail_ex b,tcode_group c ,vcode_key_detail d \n where t.tid = b.tid and \n t.tid = c.tid and \n t.tid = d.tid and \n t.did = d.did and \n t.key = d.key and \n t.grpcode = c.code and \n t.bdate::varchar = #{date}::varchar and \n (d.dname like concat(\'%\',#{deviceName},\'%\') or \'\' = #{deviceName}) and \n (b.name like concat(#{propName},\'%\') or \'\' = #{propName}) and \n (c.code = #{grpcode} or \'\' = #{grpcode}) and \n (d.grpname like concat(#{grptype},\'%\') or \'\' = #{grptype}) and \n b.code = \'all\' and \n d.grpname != \'\' and \n t.key = b.key and \n substr(b.ex_s1,3,1) = \'1\'', NULL, NULL);
INSERT INTO `api_sql` (`id`, `api_id`, `sql_text`, `transform_plugin`, `transform_plugin_params`) VALUES (266, 'cD4sCi7I', 'SELECT to_number(t.val_dep,\'9999999999999999999.9999\') - to_number(t.val_arr, \'9999999999999999999.9999\') as value,\n b.name,c.descript,d.dname,d.grpname,\n t.bdate,to_char(t.ctime,\'yyyy-mm-dd hh24:mi:ss\') as ctime,to_char(t.mtime,\'yyyy-mm-dd hh24:mi:ss\') as mtime \n from trep_group_detail t,tcode_model_detail_ex b,tcode_group c ,vcode_key_detail d \n where t.tid = b.tid and \n t.tid = \'22eed190-39af-11ed-8d4e-1d9073a615c6\' and \n t.tid = c.tid and \n t.tid = d.tid and \n t.did = d.did and \n t.key = d.key and \n t.grpcode = c.code and \n (t.bdate BETWEEN #{arr}::date and #{dep}::date ) and \n (d.dname like concat(\'%\',#{deviceName},\'%\') or \'\' = #{deviceName}) and \n (b.name like concat(#{propName},\'%\') or \'\' = #{propName}) and \n (c.code = #{grpcode} or \'\' = #{grpcode}) and \n (d.grpname like concat(#{grptype},\'%\') or \'\' = #{grptype}) and \n b.code = \'all\' and \n d.grpname != \'\' and \n t.key = b.key and \n substr(b.ex_s1,3,1) = \'1\'\n order by t.did,t.key,t.bdate,t.grpcode;\n\n \n ', NULL, NULL);
COMMIT;
-- ----------------------------
-- Table structure for datasource
-- ----------------------------
DROP TABLE IF EXISTS `datasource`;
CREATE TABLE `datasource` (
`id` varchar(255) NOT NULL,
`name` varchar(255) DEFAULT NULL,
`note` varchar(255) DEFAULT NULL,
`type` varchar(255) DEFAULT NULL,
`url` varchar(255) DEFAULT NULL,
`username` varchar(255) DEFAULT NULL,
`password` varchar(255) DEFAULT NULL,
`driver` varchar(100) DEFAULT NULL,
`table_sql` varchar(255) DEFAULT NULL,
`create_time` varchar(20) DEFAULT NULL,
`update_time` varchar(20) DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of datasource
-- ----------------------------
BEGIN;
INSERT INTO `datasource` (`id`, `name`, `note`, `type`, `url`, `username`, `password`, `driver`, `table_sql`, `create_time`, `update_time`) VALUES ('EhgozRdv', 'V3-测试环境', '', 'postgresql', 'jdbc:postgresql://121.199.175.235:30433/hsiotdb', 'postgres', 'ZeDk5+VSpaKseaGVpkfEcA==', 'org.postgresql.Driver', 'SELECT table_name FROM information_schema.tables WHERE table_schema = \'public\' ORDER BY table_name', '2022-09-24 23:19:12', '2022-09-24 23:19:12');
INSERT INTO `datasource` (`id`, `name`, `note`, `type`, `url`, `username`, `password`, `driver`, `table_sql`, `create_time`, `update_time`) VALUES ('kSC2Qziy', '物联平台V3生产', '', 'postgresql', 'jdbc:postgresql://47.99.83.75:30433/hsiotdb', 'postgres', 'ZeDk5+VSpaKseaGVpkfEcA==', 'org.postgresql.Driver', 'SELECT table_name FROM information_schema.tables WHERE table_schema = \'public\' ORDER BY table_name', '2022-09-23 12:30:22', '2022-09-23 13:13:59');
COMMIT;
-- ----------------------------
-- Table structure for firewall
-- ----------------------------
DROP TABLE IF EXISTS `firewall`;
CREATE TABLE `firewall` (
`status` varchar(255) DEFAULT NULL,
`mode` varchar(255) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of firewall
-- ----------------------------
BEGIN;
INSERT INTO `firewall` (`status`, `mode`) VALUES ('off', 'black');
COMMIT;
-- ----------------------------
-- Table structure for ip_rules
-- ----------------------------
DROP TABLE IF EXISTS `ip_rules`;
CREATE TABLE `ip_rules` (
`type` varchar(255) DEFAULT NULL,
`ip` varchar(10240) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of ip_rules
-- ----------------------------
BEGIN;
INSERT INTO `ip_rules` (`type`, `ip`) VALUES ('white', NULL);
INSERT INTO `ip_rules` (`type`, `ip`) VALUES ('black', NULL);
COMMIT;
-- ----------------------------
-- Table structure for token
-- ----------------------------
DROP TABLE IF EXISTS `token`;
CREATE TABLE `token` (
`id` int NOT NULL AUTO_INCREMENT,
`token` varchar(255) DEFAULT NULL,
`note` varchar(255) DEFAULT NULL,
`expire` bigint DEFAULT NULL,
`create_time` bigint DEFAULT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of token
-- ----------------------------
BEGIN;
INSERT INTO `token` (`id`, `token`, `note`, `expire`, `create_time`) VALUES (1, '6f3ec539d2ad4d08384e9c1f080e2eda', '', NULL, 1663984118254);
INSERT INTO `token` (`id`, `token`, `note`, `expire`, `create_time`) VALUES (2, 'a4359cffacda5d0f24d11af4e6952312', '南泰君霖', NULL, 1668485985478);
COMMIT;
-- ----------------------------
-- Table structure for user
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
`id` int NOT NULL AUTO_INCREMENT,
`username` varchar(255) DEFAULT NULL,
`password` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `username` (`username`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb3;
-- ----------------------------
-- Records of user
-- ----------------------------
BEGIN;
INSERT INTO `user` (`id`, `username`, `password`) VALUES (1, 'admin', 'admin');
COMMIT;
CREATE TABLE `api_execute_log` (
`id` varchar(255) NOT NULL,
`create_time` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '日志创建时间',
`execute_time` int NOT NULL DEFAULT '0' COMMENT '执行时长单位毫秒',
`api_path` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '执行api地址',
`api_id` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '执行api标识',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3;
SET FOREIGN_KEY_CHECKS = 1;
db/iot_dbapi_mysql.sql
View file @ 1c8ffdf0
This source diff could not be displayed because it is too large. You can view the blob instead.
db/iot_job_mysql.sql
View file @ 1c8ffdf0
This source diff could not be displayed because it is too large. You can view the blob instead.
db/job.sql deleted 100644 → 0
View file @ bd02ea1e
/*
Navicat Premium Data Transfer
Source Server : 47.96.236.169
Source Server Type : MySQL
Source Server Version : 80028
Source Host : 47.96.236.169:33306
Source Schema : iot_job
Target Server Type : MySQL
Target Server Version : 80028
File Encoding : 65001
Date: 28/11/2022 19:52:07
*/
SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;
-- ----------------------------
-- Table structure for hs_api_job
-- ----------------------------
DROP TABLE IF EXISTS `hs_api_job`;
CREATE TABLE `hs_api_job` (
`id` int NOT NULL AUTO_INCREMENT,
`job_id` int NOT NULL COMMENT '任务标识',
`api_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT 'api标识',
`update_time` datetime NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 29 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = 'Api调度任务';
-- ----------------------------
-- Records of hs_api_job
-- ----------------------------
BEGIN;
INSERT INTO `hs_api_job` (`id`, `job_id`, `api_id`, `update_time`) VALUES (1, 2, 'j0BpIQhp', '2022-09-23 12:32:13'), (2, 3, '9xFhax2y', '2022-09-24 08:05:07'), (3, 4, 'UDzGSkeZ', '2022-09-24 09:24:21'), (4, 5, 'CQ9VkAr9', '2022-09-24 09:49:48'), (5, 6, 'bw6ULlLe', '2022-09-24 23:20:41'), (6, 7, 'N8sgjOWD', '2022-09-25 22:26:44'), (7, 8, 'tCoVivD8', '2022-09-26 13:38:16'), (8, 9, 'O3KlnSsU', '2022-09-26 14:05:34'), (9, 10, 'EnFpExkx', '2022-09-27 23:30:01'), (10, 11, 'K4QZT40A', '2022-09-28 14:49:53'), (11, 12, '3qxDmpBG', '2022-09-29 14:32:10'), (12, 13, 'xfXpHIg0', '2022-09-29 15:11:37'), (13, 14, 'hGLKRYiu', '2022-10-09 23:36:54'), (14, 15, 'kU15HMrE', '2022-10-10 11:38:43'), (15, 16, '5SeUCRJy', '2022-10-10 12:27:08'), (16, 17, 'wFz52Yb1', '2022-10-10 12:30:16'), (17, 18, 'B1ANmtET', '2022-10-16 00:45:28'), (18, 19, '7TVjkWPy', '2022-11-02 16:48:27'), (19, 20, 'IHQJLVtr', '2022-11-03 17:42:59'), (20, 21, 'HYORZYyI', '2022-11-03 17:43:35'), (21, 22, 'VyCtYO0f', '2022-11-03 18:39:46'), (22, 23, 'EeBkndxU', '2022-11-12 13:35:21'), (23, 24, 'FNMVwfcu', '2022-11-12 13:36:01'), (24, 25, 'RSuNGzhs', '2022-11-12 13:36:37'), (25, 26, 'cD4sCi7I', '2022-11-15 13:25:47'), (26, 27, '0qLjHowN', '2022-11-15 13:55:43'), (27, 28, 'v7p2AAqp', '2022-11-15 14:26:00'), (28, 29, 'pjYii91f', '2022-11-16 02:05:50');
COMMIT;
-- ----------------------------
-- Table structure for xxl_job_group
-- ----------------------------
DROP TABLE IF EXISTS `xxl_job_group`;
CREATE TABLE `xxl_job_group` (
`id` int NOT NULL AUTO_INCREMENT,
`app_name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '执行器AppName',
`title` varchar(12) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '执行器名称',
`address_type` tinyint NOT NULL DEFAULT 0 COMMENT '执行器地址类型：0=自动注册、1=手动录入',
`address_list` text CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL COMMENT '执行器地址列表，多地址逗号分隔',
`update_time` datetime NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 5 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci;
-- ----------------------------
-- Records of xxl_job_group
-- ----------------------------
BEGIN;
INSERT INTO `xxl_job_group` (`id`, `app_name`, `title`, `address_type`, `address_list`, `update_time`) VALUES (1, 'xxl-job-executor-sample', '示例执行器', 0, NULL, '2022-11-28 19:51:54'), (4, 'dbapi-job-executor', 'dbapi', 0, 'http://10.227.8.243:8888/', '2022-11-28 19:51:54');
COMMIT;
-- ----------------------------
-- Table structure for xxl_job_info
-- ----------------------------
DROP TABLE IF EXISTS `xxl_job_info`;
CREATE TABLE `xxl_job_info` (
`id` int NOT NULL AUTO_INCREMENT,
`job_group` int NOT NULL COMMENT '执行器主键ID',
`job_desc` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
`add_time` datetime NULL DEFAULT NULL,
`update_time` datetime NULL DEFAULT NULL,
`author` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '作者',
`alarm_email` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '报警邮件',
`schedule_type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL DEFAULT 'NONE' COMMENT '调度类型',
`schedule_conf` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '调度配置，值含义取决于调度类型',
`misfire_strategy` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL DEFAULT 'DO_NOTHING' COMMENT '调度过期策略',
`executor_route_strategy` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '执行器路由策略',
`executor_handler` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '执行器任务handler',
`executor_param` varchar(512) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '执行器任务参数',
`executor_block_strategy` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '阻塞处理策略',
`executor_timeout` int NOT NULL DEFAULT 0 COMMENT '任务执行超时时间，单位秒',
`executor_fail_retry_count` int NOT NULL DEFAULT 0 COMMENT '失败重试次数',
`glue_type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT 'GLUE类型',
`glue_source` mediumtext CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL COMMENT 'GLUE源代码',
`glue_remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT 'GLUE备注',
`glue_updatetime` datetime NULL DEFAULT NULL COMMENT 'GLUE更新时间',
`child_jobid` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '子任务ID，多个逗号分隔',
`trigger_status` tinyint NOT NULL DEFAULT 0 COMMENT '调度状态：0-停止，1-运行',
`trigger_last_time` bigint NOT NULL DEFAULT 0 COMMENT '上次调度时间',
`trigger_next_time` bigint NOT NULL DEFAULT 0 COMMENT '下次调度时间',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 30 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci;
-- ----------------------------
-- Table structure for xxl_job_lock
-- ----------------------------
DROP TABLE IF EXISTS `xxl_job_lock`;
CREATE TABLE `xxl_job_lock` (
`lock_name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '锁名称',
PRIMARY KEY (`lock_name`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci;
-- ----------------------------
-- Records of xxl_job_lock
-- ----------------------------
BEGIN;
INSERT INTO `xxl_job_lock` (`lock_name`) VALUES ('schedule_lock');
COMMIT;
-- ----------------------------
-- Table structure for xxl_job_log_report
-- ----------------------------
DROP TABLE IF EXISTS `xxl_job_log_report`;
CREATE TABLE `xxl_job_log_report` (
`id` int NOT NULL AUTO_INCREMENT,
`trigger_day` datetime NULL DEFAULT NULL COMMENT '调度-时间',
`running_count` int NOT NULL DEFAULT 0 COMMENT '运行中-日志数量',
`suc_count` int NOT NULL DEFAULT 0 COMMENT '执行成功-日志数量',
`fail_count` int NOT NULL DEFAULT 0 COMMENT '执行失败-日志数量',
`update_time` datetime NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE,
UNIQUE INDEX `i_trigger_day`(`trigger_day` ASC) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 72 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci;
-- ----------------------------
-- Records of xxl_job_log_report
-- ----------------------------
BEGIN;
INSERT INTO `xxl_job_log_report` (`id`, `trigger_day`, `running_count`, `suc_count`, `fail_count`, `update_time`) VALUES (1, '2022-09-21 00:00:00', 0, 0, 0, NULL), (2, '2022-09-20 00:00:00', 0, 0, 0, NULL), (3, '2022-09-19 00:00:00', 0, 0, 0, NULL), (4, '2022-09-22 00:00:00', 0, 0, 0, NULL), (5, '2022-09-23 00:00:00', 0, 0, 0, NULL), (6, '2022-09-24 00:00:00', 0, 7071, 7, NULL), (7, '2022-09-25 00:00:00', 0, 8897, 28, NULL), (8, '2022-09-26 00:00:00', 0, 14564, 0, NULL), (9, '2022-09-27 00:00:00', 0, 26208, 0, NULL), (10, '2022-09-28 00:00:00', 0, 26208, 0, NULL), (11, '2022-09-29 00:00:00', 0, 29611, 0, NULL), (12, '2022-09-30 00:00:00', 0, 34848, 0, NULL), (13, '2022-10-01 00:00:00', 0, 34848, 0, NULL), (14, '2022-10-02 00:00:00', 0, 34848, 0, NULL), (15, '2022-10-03 00:00:00', 0, 34848, 0, NULL), (16, '2022-10-04 00:00:00', 0, 34848, 0, NULL), (17, '2022-10-05 00:00:00', 0, 34848, 0, NULL), (18, '2022-10-06 00:00:00', 0, 34848, 0, NULL), (19, '2022-10-07 00:00:00', 0, 34848, 0, NULL), (20, '2022-10-08 00:00:00', 0, 34848, 0, NULL), (21, '2022-10-09 00:00:00', 0, 22853, 11997, NULL), (22, '2022-10-10 00:00:00', 0, 24517, 10331, NULL), (23, '2022-10-11 00:00:00', 0, 34848, 0, NULL), (24, '2022-10-12 00:00:00', 0, 34848, 0, NULL), (25, '2022-10-13 00:00:00', 0, 34848, 0, NULL), (26, '2022-10-14 00:00:00', 0, 34848, 0, NULL), (27, '2022-10-15 00:00:00', 0, 34848, 0, NULL), (28, '2022-10-16 00:00:00', 0, 39029, 0, NULL), (29, '2022-10-17 00:00:00', 0, 39168, 0, NULL), (30, '2022-10-18 00:00:00', 0, 39168, 0, NULL), (31, '2022-10-19 00:00:00', 0, 39168, 0, NULL), (32, '2022-10-20 00:00:00', 0, 38117, 0, NULL), (33, '2022-10-21 00:00:00', 0, 30240, 0, NULL), (34, '2022-10-22 00:00:00', 0, 30240, 0, NULL), (35, '2022-10-23 00:00:00', 0, 30240, 0, NULL), (36, '2022-10-24 00:00:00', 0, 30240, 0, NULL), (37, '2022-10-25 00:00:00', 0, 30240, 0, NULL), (38, '2022-10-26 00:00:00', 1253, 28987, 0, NULL), (39, '2022-10-27 00:00:00', 8640, 21600, 0, NULL), (40, '2022-10-28 00:00:00', 8640, 21600, 0, NULL), (41, '2022-10-29 00:00:00', 8640, 21600, 0, NULL), (42, '2022-10-30 00:00:00', 8640, 21600, 0, NULL), (43, '2022-10-31 00:00:00', 0, 21600, 0, NULL), (44, '2022-11-01 00:00:00', 0, 21600, 0, NULL), (45, '2022-11-02 00:00:00', 0, 22447, 0, NULL), (46, '2022-11-03 00:00:00', 0, 24480, 0, NULL), (47, '2022-11-04 00:00:00', 0, 24480, 0, NULL), (48, '2022-11-05 00:00:00', 0, 24480, 0, NULL), (49, '2022-11-06 00:00:00', 0, 24480, 0, NULL), (50, '2022-11-07 00:00:00', 3, 24450, 27, NULL), (51, '2022-11-08 00:00:00', 0, 24480, 0, NULL), (52, '2022-11-09 00:00:00', 0, 24480, 0, NULL), (53, '2022-11-10 00:00:00', 0, 24480, 0, NULL), (54, '2022-11-11 00:00:00', 0, 24480, 0, NULL), (55, '2022-11-12 00:00:00', 0, 30087, 0, NULL), (56, '2022-11-13 00:00:00', 0, 37440, 0, NULL), (57, '2022-11-14 00:00:00', 0, 37440, 0, NULL), (58, '2022-11-15 00:00:00', 0, 36956, 0, NULL), (59, '2022-11-16 00:00:00', 0, 38501, 0, NULL), (60, '2022-11-17 00:00:00', 0, 38880, 0, NULL), (61, '2022-11-18 00:00:00', 0, 38822, 58, NULL), (62, '2022-11-19 00:00:00', 0, 38880, 0, NULL), (63, '2022-11-20 00:00:00', 0, 38880, 0, NULL), (64, '2022-11-21 00:00:00', 0, 38880, 0, NULL), (65, '2022-11-22 00:00:00', 0, 38880, 0, NULL), (66, '2022-11-23 00:00:00', 0, 38880, 0, NULL), (67, '2022-11-24 00:00:00', 0, 38880, 0, NULL), (68, '2022-11-25 00:00:00', 0, 38880, 0, NULL), (69, '2022-11-26 00:00:00', 0, 38880, 0, NULL), (70, '2022-11-27 00:00:00', 0, 38880, 0, NULL), (71, '2022-11-28 00:00:00', 0, 32191, 0, NULL);
COMMIT;
-- ----------------------------
-- Table structure for xxl_job_logglue
-- ----------------------------
DROP TABLE IF EXISTS `xxl_job_logglue`;
CREATE TABLE `xxl_job_logglue` (
`id` int NOT NULL AUTO_INCREMENT,
`job_id` int NOT NULL COMMENT '任务，主键ID',
`glue_type` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT 'GLUE类型',
`glue_source` mediumtext CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL COMMENT 'GLUE源代码',
`glue_remark` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT 'GLUE备注',
`add_time` datetime NULL DEFAULT NULL,
`update_time` datetime NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci;
-- ----------------------------
-- Records of xxl_job_logglue
-- ----------------------------
BEGIN;
COMMIT;
-- ----------------------------
-- Table structure for xxl_job_registry
-- ----------------------------
DROP TABLE IF EXISTS `xxl_job_registry`;
CREATE TABLE `xxl_job_registry` (
`id` int NOT NULL AUTO_INCREMENT,
`registry_group` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
`registry_key` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
`registry_value` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,
`update_time` datetime NULL DEFAULT NULL,
PRIMARY KEY (`id`) USING BTREE,
INDEX `i_g_k_v`(`registry_group` ASC, `registry_key` ASC, `registry_value` ASC) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 14 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci;
-- ----------------------------
-- Records of xxl_job_registry
-- ----------------------------
BEGIN;
INSERT INTO `xxl_job_registry` (`id`, `registry_group`, `registry_key`, `registry_value`, `update_time`) VALUES (13, 'EXECUTOR', 'dbapi-job-executor', 'http://10.227.8.243:8888/', '2022-11-28 19:51:51');
COMMIT;
-- ----------------------------
-- Table structure for xxl_job_user
-- ----------------------------
DROP TABLE IF EXISTS `xxl_job_user`;
CREATE TABLE `xxl_job_user` (
`id` int NOT NULL AUTO_INCREMENT,
`username` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '账号',
`password` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL COMMENT '密码',
`role` tinyint NOT NULL COMMENT '角色：0-普通用户、1-管理员',
`permission` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '权限：执行器ID列表，多个逗号分割',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE INDEX `i_username`(`username` ASC) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci;
-- ----------------------------
-- Records of xxl_job_user
-- ----------------------------
BEGIN;
INSERT INTO `xxl_job_user` (`id`, `username`, `password`, `role`, `permission`) VALUES (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, NULL);
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;
db/postgres-update.txt deleted 100644 → 0
View file @ bd02ea1e
ALTER TABLE "public"."hs_board_manage" ADD COLUMN "sort" int4 DEFAULT 0;
COMMENT ON COLUMN "public"."hs_board_manage"."sort" IS '排序值';
ALTER TABLE "public"."hs_last_expand_extension" ALTER COLUMN "volume_on_history" SET NOT NULL;
COMMENT ON COLUMN "public"."hs_last_expand_extension"."volume_on_history" IS '';
ALTER TABLE "public"."hs_user_extension" ALTER COLUMN "registrate_applet" DROP DEFAULT;
CREATE TABLE "public"."tb_tenant_menu_role" (
"id" uuid NOT NULL,
"created_time" int8,
"created_user" uuid,
"tenant_id" uuid,
"updated_time" int8,
"updated_user" uuid,
"remark" varchar(255) COLLATE "pg_catalog"."default",
"tenant_menu_id" uuid,
"tenant_sys_role_id" uuid,
"flg" varchar(255) COLLATE "pg_catalog"."default",
CONSTRAINT "tb_tenant_menu_role_pkey" PRIMARY KEY ("id")
)
;
ALTER TABLE "public"."tb_tenant_menu_role" OWNER TO "postgres";
ALTER TABLE "public"."tcode_base" ALTER COLUMN "created_time" SET DEFAULT 0;
ALTER TABLE "public"."tcode_base" ALTER COLUMN "updated_time" SET DEFAULT 0;
ALTER TABLE "public"."tcode_device" DROP CONSTRAINT "tcode_device_did_mcode_tenant_id_key";
ALTER TABLE "public"."tcode_device" ADD CONSTRAINT "tcode_device_mcode_tenant_id_did_key" UNIQUE ("mcode", "tenant_id", "did");
ALTER TABLE "public"."tcode_group" ADD CONSTRAINT "tcode_group_pkey" PRIMARY KEY ("tid", "code");
CREATE TABLE "public"."tcode_group_electric" (
"tid" uuid NOT NULL,
"code" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
"arr" time(6),
"dep" time(6),
"tdays" int4,
CONSTRAINT "tcode_group_electric_pkey" PRIMARY KEY ("tid", "code")
)
;
ALTER TABLE "public"."tcode_group_electric" OWNER TO "postgres";
COMMENT ON COLUMN "public"."tcode_group_electric"."tid" IS '租户ID';
COMMENT ON COLUMN "public"."tcode_group_electric"."code" IS '峰电peak，谷电valley';
COMMENT ON COLUMN "public"."tcode_group_electric"."arr" IS '开始时间';
COMMENT ON COLUMN "public"."tcode_group_electric"."dep" IS '结束时间';
COMMENT ON COLUMN "public"."tcode_group_electric"."tdays" IS '是否跨日，1为跨日';
ALTER TABLE "public"."tcode_model" ADD COLUMN "credential" varchar(255) COLLATE "pg_catalog"."default";
COMMENT ON COLUMN "public"."tcode_model"."credential" IS '网关令牌';
ALTER TABLE "public"."tcode_model_detail" ADD COLUMN "credential" varchar(255) COLLATE "pg_catalog"."default";
COMMENT ON COLUMN "public"."tcode_model_detail"."credential" IS '网关令牌';
ALTER TABLE "public"."tcode_model_detail_ex" ALTER COLUMN "gid" SET NOT NULL;
ALTER TABLE "public"."tcode_model_detail_ex" ADD CONSTRAINT "tcode_model_detail_ex_pkey" PRIMARY KEY ("tid", "gid", "code", "key");
CREATE TABLE "public"."tcode_model_ex" (
"tid" uuid NOT NULL,
"gid" uuid,
"code" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
"name" varchar(255) COLLATE "pg_catalog"."default",
"ctime" timestamp(6) DEFAULT CURRENT_TIMESTAMP,
"mtime" timestamp(6) DEFAULT CURRENT_TIMESTAMP
)
;
ALTER TABLE "public"."tcode_model_ex" OWNER TO "postgres";
ALTER TABLE "public"."trep_dkey_detail" DROP CONSTRAINT "trep_dkey_detail_pkey";
COMMENT ON COLUMN "public"."trep_dkey_detail"."tid" IS '租户ID';
COMMENT ON COLUMN "public"."trep_dkey_detail"."did" IS '设备ID';
COMMENT ON COLUMN "public"."trep_dkey_detail"."key" IS '属性';
ALTER TABLE "public"."trep_dkey_detail" ALTER COLUMN "bdate" SET NOT NULL;
COMMENT ON COLUMN "public"."trep_dkey_detail"."bdate" IS '营业日期';
COMMENT ON COLUMN "public"."trep_dkey_detail"."val" IS '最新遥测值-废弃';
COMMENT ON COLUMN "public"."trep_dkey_detail"."ctime" IS '创建时间';
COMMENT ON COLUMN "public"."trep_dkey_detail"."mtime" IS '修改时间';
COMMENT ON COLUMN "public"."trep_dkey_detail"."val_arr" IS '遥测值开始';
COMMENT ON COLUMN "public"."trep_dkey_detail"."val_dep" IS '遥测值结束';
COMMENT ON COLUMN "public"."trep_dkey_detail"."peak" IS '峰电-电能属性有效';
COMMENT ON COLUMN "public"."trep_dkey_detail"."valley" IS '谷电-电能属性有效';
ALTER TABLE "public"."trep_dkey_detail" ADD CONSTRAINT "trep_dkey_detail_pkey" PRIMARY KEY ("tid", "did", "key", "bdate");
COMMENT ON COLUMN "public"."trep_hkey_detail"."peak" IS '峰电';
COMMENT ON COLUMN "public"."trep_hkey_detail"."valley" IS '谷电';
ALTER TABLE "public"."trep_hsta_detail" ALTER COLUMN "aid" SET DEFAULT nextval('trep_sta_hdetail_aid_seq'::regclass);
CREATE TABLE "public"."trep_htotal_detail" (
"id" uuid NOT NULL,
"tid" uuid NOT NULL,
"did" uuid NOT NULL,
"key" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
"bdate" date DEFAULT date(now()),
"val_arr" varchar(255) COLLATE "pg_catalog"."default",
"val_dep" varchar(255) COLLATE "pg_catalog"."default",
"ctime" timestamp(6) DEFAULT now(),
"mtime" timestamp(6) DEFAULT now(),
CONSTRAINT "trep_htotal_detail_pkey" PRIMARY KEY ("id")
)
;
ALTER TABLE "public"."trep_htotal_detail" OWNER TO "postgres";
COMMENT ON COLUMN "public"."trep_htotal_detail"."id" IS '主键ID';
COMMENT ON COLUMN "public"."trep_htotal_detail"."tid" IS '租户id';
COMMENT ON COLUMN "public"."trep_htotal_detail"."did" IS '设备id';
COMMENT ON COLUMN "public"."trep_htotal_detail"."key" IS '属性key';
COMMENT ON COLUMN "public"."trep_htotal_detail"."bdate" IS '营业日期';
COMMENT ON COLUMN "public"."trep_htotal_detail"."val_arr" IS '首次统计属性值';
COMMENT ON COLUMN "public"."trep_htotal_detail"."val_dep" IS '最后统计属性值';
COMMENT ON COLUMN "public"."trep_htotal_detail"."ctime" IS '创建时间';
COMMENT ON COLUMN "public"."trep_htotal_detail"."mtime" IS '修改时间';
CREATE TABLE "public"."trep_total_detail" (
"tid" uuid NOT NULL,
"did" uuid NOT NULL,
"key" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
"val_arr" varchar(255) COLLATE "pg_catalog"."default",
"val_dep" varchar(255) COLLATE "pg_catalog"."default",
"ctime" timestamp(6) DEFAULT now(),
"mtime" timestamp(6) DEFAULT now(),
CONSTRAINT "trep_total_detail_pkey" PRIMARY KEY ("tid", "did", "key")
)
;
ALTER TABLE "public"."trep_total_detail" OWNER TO "postgres";
COMMENT ON COLUMN "public"."trep_total_detail"."tid" IS '租户id';
COMMENT ON COLUMN "public"."trep_total_detail"."did" IS '设备id';
COMMENT ON COLUMN "public"."trep_total_detail"."key" IS '属性key';
COMMENT ON COLUMN "public"."trep_total_detail"."val_arr" IS '首次统计属性值';
COMMENT ON COLUMN "public"."trep_total_detail"."val_dep" IS '最后统计属性值';
COMMENT ON COLUMN "public"."trep_total_detail"."ctime" IS '创建时间';
COMMENT ON COLUMN "public"."trep_total_detail"."mtime" IS '修改时间';
CREATE TABLE "public"."trep_yield_detail" (
"tid" uuid NOT NULL,
"did" uuid NOT NULL,
"bdate" date NOT NULL,
"key" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
"key_yield" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
"val_arr" varchar(255) COLLATE "pg_catalog"."default",
"val_dep" varchar(255) COLLATE "pg_catalog"."default",
"val_yield" varchar(255) COLLATE "pg_catalog"."default",
"ctime" timestamp(6),
"mtime" timestamp(6),
CONSTRAINT "trep_yield_detail_pkey" PRIMARY KEY ("tid", "did", "bdate", "key", "key_yield")
)
;
ALTER TABLE "public"."trep_yield_detail" OWNER TO "postgres";
COMMENT ON COLUMN "public"."trep_yield_detail"."tid" IS '租户ID';
COMMENT ON COLUMN "public"."trep_yield_detail"."did" IS '设备ID';
COMMENT ON COLUMN "public"."trep_yield_detail"."bdate" IS '营业日期';
COMMENT ON COLUMN "public"."trep_yield_detail"."key" IS '能耗属性名称key';
COMMENT ON COLUMN "public"."trep_yield_detail"."key_yield" IS '对应产量key';
COMMENT ON COLUMN "public"."trep_yield_detail"."val_arr" IS '开始值';
COMMENT ON COLUMN "public"."trep_yield_detail"."val_dep" IS '能耗结束值';
COMMENT ON COLUMN "public"."trep_yield_detail"."val_yield" IS '产量数据';
COMMENT ON COLUMN "public"."trep_yield_detail"."ctime" IS '开始时间';
COMMENT ON COLUMN "public"."trep_yield_detail"."mtime" IS '结束时间';
DROP FUNCTION "public"."trep_group_detail_function"();
CREATE OR REPLACE FUNCTION "public"."trep_group_detail_function"()
RETURNS "pg_catalog"."int4" AS $BODY$
declare
total integer;
BEGIN
INSERT into trep_group_detail(tid,did,key,bdate,grpcode,val_arr,val_dep,ctime,mtime)
SELECT t.tid,t.did, t.key,c.tarr::date as bdate,
c.code,t.val ,t.val,
CURRENT_TIMESTAMP ,CURRENT_TIMESTAMP
from vcode_key_detail t,tcode_model_detail_ex b ,(
SELECT a.* from
(
SELECT CONCAT((CURRENT_DATE)::TEXT,' ',t.arr)::TIMESTAMP as tarr,
CONCAT((CURRENT_DATE)::TEXT,' ',t.dep)::TIMESTAMP as tdep,
t.* from tcode_group t
where t.dep >= t.arr
union
SELECT CONCAT((CURRENT_DATE)::TEXT,' ',t.arr)::TIMESTAMP as tarr,
CONCAT((CURRENT_DATE+1)::TEXT,' ',t.dep)::TIMESTAMP as tdep,
t.* from tcode_group t
where t.dep < t.arr
union
SELECT CONCAT((CURRENT_DATE-1)::TEXT,' ',t.arr)::TIMESTAMP as tarr,
CONCAT((CURRENT_DATE)::TEXT,' ',t.dep)::TIMESTAMP as tdep,
t.* from tcode_group t
where t.dep < t.arr
) a
where CURRENT_TIMESTAMP >= a.tarr and
CURRENT_TIMESTAMP <= a.tdep
limit 1
) c
where t.tid = b.tid and t.tid = c.tid and b.code = 'all' and t.key = b.key and substr(b.ex_s1,3,1) = '1'
ON CONFLICT (tid,did,key,bdate,grpcode)
DO UPDATE SET
val_dep = EXCLUDED.val_dep,
mtime = CURRENT_TIMESTAMP;
RETURN total;
END;
$BODY$
LANGUAGE plpgsql VOLATILE
COST 100;
ALTER FUNCTION "public"."trep_group_detail_function"() OWNER TO "postgres";
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment