liupopo
1 year ago
63 changed files with 3346 additions and 326 deletions
@ -0,0 +1,406 @@ |
|||
SELECT * FROM sh_order_index soi WHERE soi.data_id LIKE '%河南安阳%' -- 2798 |
|||
|
|||
SELECT * FROM sh_order_index soi WHERE soi.dg_name LIKE '%河南安阳%' |
|||
|
|||
SELECT * FROM sh_order_index soi WHERE soi.data_id = '河南安阳' |
|||
SELECT * FROM sh_order_index soi WHERE soi.data_id LIKE '%山东曲阜%' -- 306 |
|||
SELECT * FROM sh_order_index soi WHERE soi.data_id LIKE '%庄河整县%' -- 951 |
|||
|
|||
-- 电站数据(监管数据) |
|||
DROP TABLE IF EXISTS `sh_order_index_jg`; |
|||
CREATE TABLE `sh_order_index_jg` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT '电站id', |
|||
order_no varchar(100) DEFAULT NULL COMMENT '电站编码', |
|||
admin_id varchar(100) DEFAULT NULL COMMENT '创建人id', |
|||
customer_id varchar(100) DEFAULT NULL COMMENT '客户id', |
|||
agent_id varchar(100) DEFAULT NULL COMMENT '代理商id', |
|||
product_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
create_time bigint DEFAULT NULL COMMENT '创建时间', |
|||
data_id varchar(100) DEFAULT NULL COMMENT '数据分组', |
|||
workflow_unique varchar(100) DEFAULT NULL COMMENT '当前流程', |
|||
prototype_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
remain_unique varchar(100) DEFAULT NULL COMMENT '', |
|||
is_best varchar(100) DEFAULT NULL COMMENT '是否为标杆电站', |
|||
order_type varchar(100) DEFAULT NULL COMMENT '电站类型', |
|||
update_time bigint DEFAULT NULL COMMENT '修改时间', |
|||
company_id varchar(100) DEFAULT NULL COMMENT '公司id', |
|||
dg_name varchar(100) DEFAULT NULL COMMENT '数据分组说明', |
|||
contract_life varchar(100) DEFAULT NULL COMMENT '合同年限', |
|||
contract_group varchar(100) DEFAULT NULL COMMENT '合同组', |
|||
agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
area_id varchar(100) DEFAULT NULL COMMENT '地区id', |
|||
address varchar(100) DEFAULT NULL COMMENT '详细地址', |
|||
component_number varchar(100) DEFAULT NULL COMMENT '光伏板块数', |
|||
component_power varchar(100) DEFAULT NULL COMMENT '组件安装功率', |
|||
admin_name varchar(100) DEFAULT NULL COMMENT '业务员姓名', |
|||
admin_phone varchar(100) DEFAULT NULL COMMENT '业务员手机号', |
|||
user_name varchar(100) DEFAULT NULL COMMENT '用户名', |
|||
user_phone varchar(100) DEFAULT NULL COMMENT '用户手机号', |
|||
id_card varchar(100) DEFAULT NULL COMMENT '用户身份证号', |
|||
product_name varchar(100) DEFAULT NULL COMMENT '产品名称', |
|||
workflow_name varchar(100) DEFAULT NULL COMMENT '流程名称', |
|||
node_id varchar(100) DEFAULT NULL COMMENT 'nodeID', |
|||
is_agree varchar(100) DEFAULT NULL COMMENT '审核是否通过', |
|||
group_id varchar(100) DEFAULT NULL COMMENT '产品ID', |
|||
sign varchar(100) DEFAULT NULL COMMENT '是否签署合同，1已签署，2未签署', |
|||
uplode_contract varchar(1024) DEFAULT NULL COMMENT '手动上传-合同', |
|||
company_name varchar(100) DEFAULT NULL COMMENT '所属公司名称', |
|||
province_name varchar(100) DEFAULT NULL COMMENT '省', |
|||
city_name varchar(100) DEFAULT NULL COMMENT '市', |
|||
area_name varchar(100) DEFAULT NULL COMMENT '区/县', |
|||
assets_no varchar(100) DEFAULT NULL COMMENT '资产编号', |
|||
change_order_id varchar(100) DEFAULT NULL COMMENT '电站变更id', |
|||
p_agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
operation_id varchar(100) DEFAULT NULL COMMENT '运维id', |
|||
operation_name varchar(100) DEFAULT NULL COMMENT '运维名称', |
|||
all_power bigint DEFAULT NULL COMMENT '总功率', |
|||
order_type_text varchar(100) DEFAULT NULL COMMENT '产品说明', |
|||
is_save varchar(100) DEFAULT NULL COMMENT '是否可编辑', |
|||
is_m varchar(100) DEFAULT NULL COMMENT '0', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT='电站数据(监管数据)'; |
|||
|
|||
|
|||
INSERT INTO sh_order_index_jg |
|||
SELECT * |
|||
FROM sh_order_index soi |
|||
WHERE soi.data_id LIKE '%河南安阳%' or soi.data_id LIKE '%山东曲阜%' or soi.data_id LIKE '%庄河整县%'; |
|||
|
|||
-- 电站数据(监管数据)-进件 |
|||
DROP TABLE IF EXISTS `sh_order_index_jg_jj`; |
|||
CREATE TABLE `sh_order_index_jg_jj` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT '电站id', |
|||
order_no varchar(100) DEFAULT NULL COMMENT '电站编码', |
|||
admin_id varchar(100) DEFAULT NULL COMMENT '创建人id', |
|||
customer_id varchar(100) DEFAULT NULL COMMENT '客户id', |
|||
agent_id varchar(100) DEFAULT NULL COMMENT '代理商id', |
|||
product_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
create_time bigint DEFAULT NULL COMMENT '创建时间', |
|||
data_id varchar(100) DEFAULT NULL COMMENT '数据分组', |
|||
workflow_unique varchar(100) DEFAULT NULL COMMENT '当前流程', |
|||
prototype_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
remain_unique varchar(100) DEFAULT NULL COMMENT '', |
|||
is_best varchar(100) DEFAULT NULL COMMENT '是否为标杆电站', |
|||
order_type varchar(100) DEFAULT NULL COMMENT '电站类型', |
|||
update_time bigint DEFAULT NULL COMMENT '修改时间', |
|||
company_id varchar(100) DEFAULT NULL COMMENT '公司id', |
|||
dg_name varchar(100) DEFAULT NULL COMMENT '数据分组说明', |
|||
contract_life varchar(100) DEFAULT NULL COMMENT '合同年限', |
|||
contract_group varchar(100) DEFAULT NULL COMMENT '合同组', |
|||
agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
area_id varchar(100) DEFAULT NULL COMMENT '地区id', |
|||
address varchar(100) DEFAULT NULL COMMENT '详细地址', |
|||
component_number varchar(100) DEFAULT NULL COMMENT '光伏板块数', |
|||
component_power varchar(100) DEFAULT NULL COMMENT '组件安装功率', |
|||
admin_name varchar(100) DEFAULT NULL COMMENT '业务员姓名', |
|||
admin_phone varchar(100) DEFAULT NULL COMMENT '业务员手机号', |
|||
user_name varchar(100) DEFAULT NULL COMMENT '用户名', |
|||
user_phone varchar(100) DEFAULT NULL COMMENT '用户手机号', |
|||
id_card varchar(100) DEFAULT NULL COMMENT '用户身份证号', |
|||
product_name varchar(100) DEFAULT NULL COMMENT '产品名称', |
|||
workflow_name varchar(100) DEFAULT NULL COMMENT '流程名称', |
|||
node_id varchar(100) DEFAULT NULL COMMENT 'nodeID', |
|||
is_agree varchar(100) DEFAULT NULL COMMENT '审核是否通过', |
|||
group_id varchar(100) DEFAULT NULL COMMENT '产品ID', |
|||
sign varchar(100) DEFAULT NULL COMMENT '是否签署合同，1已签署，2未签署', |
|||
uplode_contract varchar(1024) DEFAULT NULL COMMENT '手动上传-合同', |
|||
company_name varchar(100) DEFAULT NULL COMMENT '所属公司名称', |
|||
province_name varchar(100) DEFAULT NULL COMMENT '省', |
|||
city_name varchar(100) DEFAULT NULL COMMENT '市', |
|||
area_name varchar(100) DEFAULT NULL COMMENT '区/县', |
|||
assets_no varchar(100) DEFAULT NULL COMMENT '资产编号', |
|||
change_order_id varchar(100) DEFAULT NULL COMMENT '电站变更id', |
|||
p_agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
operation_id varchar(100) DEFAULT NULL COMMENT '运维id', |
|||
operation_name varchar(100) DEFAULT NULL COMMENT '运维名称', |
|||
all_power bigint DEFAULT NULL COMMENT '总功率', |
|||
order_type_text varchar(100) DEFAULT NULL COMMENT '产品说明', |
|||
is_save varchar(100) DEFAULT NULL COMMENT '是否可编辑', |
|||
is_m varchar(100) DEFAULT NULL COMMENT '0', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT='电站数据(监管数据)-进件'; |
|||
|
|||
-- workflow:"2_3_0_0_1,1_8_0_0_1" |
|||
INSERT INTO sh_order_index_jg_jj |
|||
SELECT * |
|||
FROM sh_order_index_jg soij |
|||
WHERE soij.workflow_name <> '开始(创建订单)'; |
|||
|
|||
-- 电站数据(监管数据)-签约 |
|||
DROP TABLE IF EXISTS `sh_order_index_jg_qy`; |
|||
CREATE TABLE `sh_order_index_jg_qy` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT '电站id', |
|||
order_no varchar(100) DEFAULT NULL COMMENT '电站编码', |
|||
admin_id varchar(100) DEFAULT NULL COMMENT '创建人id', |
|||
customer_id varchar(100) DEFAULT NULL COMMENT '客户id', |
|||
agent_id varchar(100) DEFAULT NULL COMMENT '代理商id', |
|||
product_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
create_time bigint DEFAULT NULL COMMENT '创建时间', |
|||
data_id varchar(100) DEFAULT NULL COMMENT '数据分组', |
|||
workflow_unique varchar(100) DEFAULT NULL COMMENT '当前流程', |
|||
prototype_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
remain_unique varchar(100) DEFAULT NULL COMMENT '', |
|||
is_best varchar(100) DEFAULT NULL COMMENT '是否为标杆电站', |
|||
order_type varchar(100) DEFAULT NULL COMMENT '电站类型', |
|||
update_time bigint DEFAULT NULL COMMENT '修改时间', |
|||
company_id varchar(100) DEFAULT NULL COMMENT '公司id', |
|||
dg_name varchar(100) DEFAULT NULL COMMENT '数据分组说明', |
|||
contract_life varchar(100) DEFAULT NULL COMMENT '合同年限', |
|||
contract_group varchar(100) DEFAULT NULL COMMENT '合同组', |
|||
agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
area_id varchar(100) DEFAULT NULL COMMENT '地区id', |
|||
address varchar(100) DEFAULT NULL COMMENT '详细地址', |
|||
component_number varchar(100) DEFAULT NULL COMMENT '光伏板块数', |
|||
component_power varchar(100) DEFAULT NULL COMMENT '组件安装功率', |
|||
admin_name varchar(100) DEFAULT NULL COMMENT '业务员姓名', |
|||
admin_phone varchar(100) DEFAULT NULL COMMENT '业务员手机号', |
|||
user_name varchar(100) DEFAULT NULL COMMENT '用户名', |
|||
user_phone varchar(100) DEFAULT NULL COMMENT '用户手机号', |
|||
id_card varchar(100) DEFAULT NULL COMMENT '用户身份证号', |
|||
product_name varchar(100) DEFAULT NULL COMMENT '产品名称', |
|||
workflow_name varchar(100) DEFAULT NULL COMMENT '流程名称', |
|||
node_id varchar(100) DEFAULT NULL COMMENT 'nodeID', |
|||
is_agree varchar(100) DEFAULT NULL COMMENT '审核是否通过', |
|||
group_id varchar(100) DEFAULT NULL COMMENT '产品ID', |
|||
sign varchar(100) DEFAULT NULL COMMENT '是否签署合同，1已签署，2未签署', |
|||
uplode_contract varchar(1024) DEFAULT NULL COMMENT '手动上传-合同', |
|||
company_name varchar(100) DEFAULT NULL COMMENT '所属公司名称', |
|||
province_name varchar(100) DEFAULT NULL COMMENT '省', |
|||
city_name varchar(100) DEFAULT NULL COMMENT '市', |
|||
area_name varchar(100) DEFAULT NULL COMMENT '区/县', |
|||
assets_no varchar(100) DEFAULT NULL COMMENT '资产编号', |
|||
change_order_id varchar(100) DEFAULT NULL COMMENT '电站变更id', |
|||
p_agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
operation_id varchar(100) DEFAULT NULL COMMENT '运维id', |
|||
operation_name varchar(100) DEFAULT NULL COMMENT '运维名称', |
|||
all_power bigint DEFAULT NULL COMMENT '总功率', |
|||
order_type_text varchar(100) DEFAULT NULL COMMENT '产品说明', |
|||
is_save varchar(100) DEFAULT NULL COMMENT '是否可编辑', |
|||
is_m varchar(100) DEFAULT NULL COMMENT '0', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT='电站数据(监管数据)-签约'; |
|||
|
|||
INSERT INTO sh_order_index_jg_qy |
|||
SELECT * |
|||
FROM sh_order_index_jg soij |
|||
WHERE soij.sign=1; |
|||
|
|||
-- 电站数据(监管数据)-交货 |
|||
DROP TABLE IF EXISTS `sh_order_index_jg_jh`; |
|||
CREATE TABLE `sh_order_index_jg_jh` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT '电站id', |
|||
order_no varchar(100) DEFAULT NULL COMMENT '电站编码', |
|||
admin_id varchar(100) DEFAULT NULL COMMENT '创建人id', |
|||
customer_id varchar(100) DEFAULT NULL COMMENT '客户id', |
|||
agent_id varchar(100) DEFAULT NULL COMMENT '代理商id', |
|||
product_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
create_time bigint DEFAULT NULL COMMENT '创建时间', |
|||
data_id varchar(100) DEFAULT NULL COMMENT '数据分组', |
|||
workflow_unique varchar(100) DEFAULT NULL COMMENT '当前流程', |
|||
prototype_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
remain_unique varchar(100) DEFAULT NULL COMMENT '', |
|||
is_best varchar(100) DEFAULT NULL COMMENT '是否为标杆电站', |
|||
order_type varchar(100) DEFAULT NULL COMMENT '电站类型', |
|||
update_time bigint DEFAULT NULL COMMENT '修改时间', |
|||
company_id varchar(100) DEFAULT NULL COMMENT '公司id', |
|||
dg_name varchar(100) DEFAULT NULL COMMENT '数据分组说明', |
|||
contract_life varchar(100) DEFAULT NULL COMMENT '合同年限', |
|||
contract_group varchar(100) DEFAULT NULL COMMENT '合同组', |
|||
agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
area_id varchar(100) DEFAULT NULL COMMENT '地区id', |
|||
address varchar(100) DEFAULT NULL COMMENT '详细地址', |
|||
component_number varchar(100) DEFAULT NULL COMMENT '光伏板块数', |
|||
component_power varchar(100) DEFAULT NULL COMMENT '组件安装功率', |
|||
admin_name varchar(100) DEFAULT NULL COMMENT '业务员姓名', |
|||
admin_phone varchar(100) DEFAULT NULL COMMENT '业务员手机号', |
|||
user_name varchar(100) DEFAULT NULL COMMENT '用户名', |
|||
user_phone varchar(100) DEFAULT NULL COMMENT '用户手机号', |
|||
id_card varchar(100) DEFAULT NULL COMMENT '用户身份证号', |
|||
product_name varchar(100) DEFAULT NULL COMMENT '产品名称', |
|||
workflow_name varchar(100) DEFAULT NULL COMMENT '流程名称', |
|||
node_id varchar(100) DEFAULT NULL COMMENT 'nodeID', |
|||
is_agree varchar(100) DEFAULT NULL COMMENT '审核是否通过', |
|||
group_id varchar(100) DEFAULT NULL COMMENT '产品ID', |
|||
sign varchar(100) DEFAULT NULL COMMENT '是否签署合同，1已签署，2未签署', |
|||
uplode_contract varchar(1024) DEFAULT NULL COMMENT '手动上传-合同', |
|||
company_name varchar(100) DEFAULT NULL COMMENT '所属公司名称', |
|||
province_name varchar(100) DEFAULT NULL COMMENT '省', |
|||
city_name varchar(100) DEFAULT NULL COMMENT '市', |
|||
area_name varchar(100) DEFAULT NULL COMMENT '区/县', |
|||
assets_no varchar(100) DEFAULT NULL COMMENT '资产编号', |
|||
change_order_id varchar(100) DEFAULT NULL COMMENT '电站变更id', |
|||
p_agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
operation_id varchar(100) DEFAULT NULL COMMENT '运维id', |
|||
operation_name varchar(100) DEFAULT NULL COMMENT '运维名称', |
|||
all_power bigint DEFAULT NULL COMMENT '总功率', |
|||
order_type_text varchar(100) DEFAULT NULL COMMENT '产品说明', |
|||
is_save varchar(100) DEFAULT NULL COMMENT '是否可编辑', |
|||
is_m varchar(100) DEFAULT NULL COMMENT '0', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT='电站数据(监管数据)-交货'; |
|||
|
|||
INSERT INTO sh_order_index_jg_jh |
|||
SELECT * |
|||
FROM sh_order_index_jg soij |
|||
WHERE soij.workflow_name in ( |
|||
'确认交货', |
|||
'施工派工', |
|||
'施工资料提交', |
|||
'代理商完工自审', |
|||
'代理商完工自审驳回', |
|||
'完工审核', |
|||
'完工审核驳回', |
|||
'并网资料提交', |
|||
'代理商并网自审', |
|||
'并网审核', |
|||
'并网审核驳回', |
|||
'现场验收', |
|||
'建转运', |
|||
'(工)确认交货', |
|||
'(工)施工派工', |
|||
'(工)完工提交', |
|||
'(工)代理商完工自审', |
|||
'(工)工程完工审核', |
|||
'(工)并网资料提交', |
|||
'(工)代理商并网自审', |
|||
'(工)并网发电验收', |
|||
'(工)验收资料提交', |
|||
'(工)现场审核', |
|||
'(工)建转运' |
|||
); |
|||
|
|||
-- 电站数据(监管数据)-完工 |
|||
DROP TABLE IF EXISTS `sh_order_index_jg_wg`; |
|||
CREATE TABLE `sh_order_index_jg_wg` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT '电站id', |
|||
order_no varchar(100) DEFAULT NULL COMMENT '电站编码', |
|||
admin_id varchar(100) DEFAULT NULL COMMENT '创建人id', |
|||
customer_id varchar(100) DEFAULT NULL COMMENT '客户id', |
|||
agent_id varchar(100) DEFAULT NULL COMMENT '代理商id', |
|||
product_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
create_time bigint DEFAULT NULL COMMENT '创建时间', |
|||
data_id varchar(100) DEFAULT NULL COMMENT '数据分组', |
|||
workflow_unique varchar(100) DEFAULT NULL COMMENT '当前流程', |
|||
prototype_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
remain_unique varchar(100) DEFAULT NULL COMMENT '', |
|||
is_best varchar(100) DEFAULT NULL COMMENT '是否为标杆电站', |
|||
order_type varchar(100) DEFAULT NULL COMMENT '电站类型', |
|||
update_time bigint DEFAULT NULL COMMENT '修改时间', |
|||
company_id varchar(100) DEFAULT NULL COMMENT '公司id', |
|||
dg_name varchar(100) DEFAULT NULL COMMENT '数据分组说明', |
|||
contract_life varchar(100) DEFAULT NULL COMMENT '合同年限', |
|||
contract_group varchar(100) DEFAULT NULL COMMENT '合同组', |
|||
agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
area_id varchar(100) DEFAULT NULL COMMENT '地区id', |
|||
address varchar(100) DEFAULT NULL COMMENT '详细地址', |
|||
component_number varchar(100) DEFAULT NULL COMMENT '光伏板块数', |
|||
component_power varchar(100) DEFAULT NULL COMMENT '组件安装功率', |
|||
admin_name varchar(100) DEFAULT NULL COMMENT '业务员姓名', |
|||
admin_phone varchar(100) DEFAULT NULL COMMENT '业务员手机号', |
|||
user_name varchar(100) DEFAULT NULL COMMENT '用户名', |
|||
user_phone varchar(100) DEFAULT NULL COMMENT '用户手机号', |
|||
id_card varchar(100) DEFAULT NULL COMMENT '用户身份证号', |
|||
product_name varchar(100) DEFAULT NULL COMMENT '产品名称', |
|||
workflow_name varchar(100) DEFAULT NULL COMMENT '流程名称', |
|||
node_id varchar(100) DEFAULT NULL COMMENT 'nodeID', |
|||
is_agree varchar(100) DEFAULT NULL COMMENT '审核是否通过', |
|||
group_id varchar(100) DEFAULT NULL COMMENT '产品ID', |
|||
sign varchar(100) DEFAULT NULL COMMENT '是否签署合同，1已签署，2未签署', |
|||
uplode_contract varchar(1024) DEFAULT NULL COMMENT '手动上传-合同', |
|||
company_name varchar(100) DEFAULT NULL COMMENT '所属公司名称', |
|||
province_name varchar(100) DEFAULT NULL COMMENT '省', |
|||
city_name varchar(100) DEFAULT NULL COMMENT '市', |
|||
area_name varchar(100) DEFAULT NULL COMMENT '区/县', |
|||
assets_no varchar(100) DEFAULT NULL COMMENT '资产编号', |
|||
change_order_id varchar(100) DEFAULT NULL COMMENT '电站变更id', |
|||
p_agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
operation_id varchar(100) DEFAULT NULL COMMENT '运维id', |
|||
operation_name varchar(100) DEFAULT NULL COMMENT '运维名称', |
|||
all_power bigint DEFAULT NULL COMMENT '总功率', |
|||
order_type_text varchar(100) DEFAULT NULL COMMENT '产品说明', |
|||
is_save varchar(100) DEFAULT NULL COMMENT '是否可编辑', |
|||
is_m varchar(100) DEFAULT NULL COMMENT '0', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT='电站数据(监管数据)-完工'; |
|||
|
|||
INSERT INTO sh_order_index_jg_wg |
|||
SELECT * |
|||
FROM sh_order_index_jg soij |
|||
WHERE soij.workflow_name in ( |
|||
'并网资料提交', |
|||
'代理商并网自审', |
|||
'并网审核', |
|||
'并网审核驳回', |
|||
'现场验收', |
|||
'建转运', |
|||
'(工)并网资料提交', |
|||
'(工)代理商并网自审', |
|||
'(工)并网发电验收', |
|||
'(工)验收资料提交', |
|||
'(工)现场审核', |
|||
'(工)建转运' |
|||
); |
|||
|
|||
-- 电站数据(监管数据)-并网 |
|||
DROP TABLE IF EXISTS `sh_order_index_jg_bw`; |
|||
CREATE TABLE `sh_order_index_jg_bw` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT '电站id', |
|||
order_no varchar(100) DEFAULT NULL COMMENT '电站编码', |
|||
admin_id varchar(100) DEFAULT NULL COMMENT '创建人id', |
|||
customer_id varchar(100) DEFAULT NULL COMMENT '客户id', |
|||
agent_id varchar(100) DEFAULT NULL COMMENT '代理商id', |
|||
product_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
create_time bigint DEFAULT NULL COMMENT '创建时间', |
|||
data_id varchar(100) DEFAULT NULL COMMENT '数据分组', |
|||
workflow_unique varchar(100) DEFAULT NULL COMMENT '当前流程', |
|||
prototype_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
remain_unique varchar(100) DEFAULT NULL COMMENT '', |
|||
is_best varchar(100) DEFAULT NULL COMMENT '是否为标杆电站', |
|||
order_type varchar(100) DEFAULT NULL COMMENT '电站类型', |
|||
update_time bigint DEFAULT NULL COMMENT '修改时间', |
|||
company_id varchar(100) DEFAULT NULL COMMENT '公司id', |
|||
dg_name varchar(100) DEFAULT NULL COMMENT '数据分组说明', |
|||
contract_life varchar(100) DEFAULT NULL COMMENT '合同年限', |
|||
contract_group varchar(100) DEFAULT NULL COMMENT '合同组', |
|||
agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
area_id varchar(100) DEFAULT NULL COMMENT '地区id', |
|||
address varchar(100) DEFAULT NULL COMMENT '详细地址', |
|||
component_number varchar(100) DEFAULT NULL COMMENT '光伏板块数', |
|||
component_power varchar(100) DEFAULT NULL COMMENT '组件安装功率', |
|||
admin_name varchar(100) DEFAULT NULL COMMENT '业务员姓名', |
|||
admin_phone varchar(100) DEFAULT NULL COMMENT '业务员手机号', |
|||
user_name varchar(100) DEFAULT NULL COMMENT '用户名', |
|||
user_phone varchar(100) DEFAULT NULL COMMENT '用户手机号', |
|||
id_card varchar(100) DEFAULT NULL COMMENT '用户身份证号', |
|||
product_name varchar(100) DEFAULT NULL COMMENT '产品名称', |
|||
workflow_name varchar(100) DEFAULT NULL COMMENT '流程名称', |
|||
node_id varchar(100) DEFAULT NULL COMMENT 'nodeID', |
|||
is_agree varchar(100) DEFAULT NULL COMMENT '审核是否通过', |
|||
group_id varchar(100) DEFAULT NULL COMMENT '产品ID', |
|||
sign varchar(100) DEFAULT NULL COMMENT '是否签署合同，1已签署，2未签署', |
|||
uplode_contract varchar(1024) DEFAULT NULL COMMENT '手动上传-合同', |
|||
company_name varchar(100) DEFAULT NULL COMMENT '所属公司名称', |
|||
province_name varchar(100) DEFAULT NULL COMMENT '省', |
|||
city_name varchar(100) DEFAULT NULL COMMENT '市', |
|||
area_name varchar(100) DEFAULT NULL COMMENT '区/县', |
|||
assets_no varchar(100) DEFAULT NULL COMMENT '资产编号', |
|||
change_order_id varchar(100) DEFAULT NULL COMMENT '电站变更id', |
|||
p_agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
operation_id varchar(100) DEFAULT NULL COMMENT '运维id', |
|||
operation_name varchar(100) DEFAULT NULL COMMENT '运维名称', |
|||
all_power bigint DEFAULT NULL COMMENT '总功率', |
|||
order_type_text varchar(100) DEFAULT NULL COMMENT '产品说明', |
|||
is_save varchar(100) DEFAULT NULL COMMENT '是否可编辑', |
|||
is_m varchar(100) DEFAULT NULL COMMENT '0', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT='电站数据(监管数据)-并网'; |
|||
|
|||
INSERT INTO sh_order_index_jg_bw |
|||
SELECT * |
|||
FROM sh_order_index_jg soij |
|||
WHERE soij.workflow_name in ( |
|||
'现场验收', |
|||
'建转运', |
|||
'(工)现场审核', |
|||
'(工)建转运' |
|||
); |
|||
@ -0,0 +1,143 @@ |
|||
|
|||
DROP TABLE IF EXISTS `sh_order_index`; |
|||
CREATE TABLE `sh_order_index` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT '电站id', |
|||
order_no varchar(100) DEFAULT NULL COMMENT '电站编码', |
|||
admin_id varchar(100) DEFAULT NULL COMMENT '创建人id', |
|||
customer_id varchar(100) DEFAULT NULL COMMENT '客户id', |
|||
agent_id varchar(100) DEFAULT NULL COMMENT '代理商id', |
|||
product_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
create_time bigint DEFAULT NULL COMMENT '创建时间', |
|||
data_id varchar(100) DEFAULT NULL COMMENT '数据分组', |
|||
workflow_unique varchar(100) DEFAULT NULL COMMENT '当前流程', |
|||
prototype_id varchar(100) DEFAULT NULL COMMENT '产品id', |
|||
remain_unique varchar(100) DEFAULT NULL COMMENT '', |
|||
is_best varchar(100) DEFAULT NULL COMMENT '是否为标杆电站', |
|||
order_type varchar(100) DEFAULT NULL COMMENT '电站类型', |
|||
update_time bigint DEFAULT NULL COMMENT '修改时间', |
|||
company_id varchar(100) DEFAULT NULL COMMENT '公司id', |
|||
dg_name varchar(100) DEFAULT NULL COMMENT '数据分组说明', |
|||
contract_life varchar(100) DEFAULT NULL COMMENT '合同年限', |
|||
contract_group varchar(100) DEFAULT NULL COMMENT '合同组', |
|||
agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
area_id varchar(100) DEFAULT NULL COMMENT '地区id', |
|||
address varchar(100) DEFAULT NULL COMMENT '详细地址', |
|||
component_number varchar(100) DEFAULT NULL COMMENT '光伏板块数', |
|||
component_power varchar(100) DEFAULT NULL COMMENT '组件安装功率', |
|||
admin_name varchar(100) DEFAULT NULL COMMENT '业务员姓名', |
|||
admin_phone varchar(100) DEFAULT NULL COMMENT '业务员手机号', |
|||
user_name varchar(100) DEFAULT NULL COMMENT '用户名', |
|||
user_phone varchar(100) DEFAULT NULL COMMENT '用户手机号', |
|||
id_card varchar(100) DEFAULT NULL COMMENT '用户身份证号', |
|||
product_name varchar(100) DEFAULT NULL COMMENT '产品名称', |
|||
workflow_name varchar(100) DEFAULT NULL COMMENT '流程名称', |
|||
node_id varchar(100) DEFAULT NULL COMMENT 'nodeID', |
|||
is_agree varchar(100) DEFAULT NULL COMMENT '审核是否通过', |
|||
group_id varchar(100) DEFAULT NULL COMMENT '产品ID', |
|||
sign varchar(100) DEFAULT NULL COMMENT '是否签署合同，1已签署，2未签署', |
|||
uplode_contract varchar(1024) DEFAULT NULL COMMENT '手动上传-合同', |
|||
company_name varchar(100) DEFAULT NULL COMMENT '所属公司名称', |
|||
province_name varchar(100) DEFAULT NULL COMMENT '省', |
|||
city_name varchar(100) DEFAULT NULL COMMENT '市', |
|||
area_name varchar(100) DEFAULT NULL COMMENT '区/县', |
|||
assets_no varchar(100) DEFAULT NULL COMMENT '资产编号', |
|||
change_order_id varchar(100) DEFAULT NULL COMMENT '电站变更id', |
|||
p_agent_name varchar(100) DEFAULT NULL COMMENT '代理商名称', |
|||
operation_id varchar(100) DEFAULT NULL COMMENT '运维id', |
|||
operation_name varchar(100) DEFAULT NULL COMMENT '运维名称', |
|||
all_power bigint DEFAULT NULL COMMENT '总功率', |
|||
order_type_text varchar(100) DEFAULT NULL COMMENT '产品说明', |
|||
is_save varchar(100) DEFAULT NULL COMMENT '是否可编辑', |
|||
is_m varchar(100) DEFAULT NULL COMMENT '0', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT='电站数据'; |
|||
|
|||
|
|||
DROP TABLE IF EXISTS `sh_screen_order`; |
|||
CREATE TABLE `sh_screen_order` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT '电站id', |
|||
order_no varchar(100) DEFAULT NULL COMMENT '2021060667629040986641', |
|||
admin_id varchar(100) DEFAULT NULL COMMENT '58,', |
|||
customer_id varchar(100) DEFAULT NULL COMMENT '41,', |
|||
agent_id varchar(100) DEFAULT NULL COMMENT '11,', |
|||
product_id varchar(100) DEFAULT NULL COMMENT '8,', |
|||
create_time varchar(100) DEFAULT NULL COMMENT '1622946409,', |
|||
data_id varchar(100) DEFAULT NULL COMMENT '1,35', |
|||
workflow_unique varchar(100) DEFAULT NULL COMMENT '1_8_0_190_1', |
|||
prototype_id varchar(100) DEFAULT NULL COMMENT '1,', |
|||
remain_unique varchar(100) DEFAULT NULL COMMENT '1,', |
|||
is_best varchar(100) DEFAULT NULL COMMENT '0,', |
|||
order_type varchar(100) DEFAULT NULL COMMENT '1,', |
|||
update_time varchar(100) DEFAULT NULL COMMENT '2024-03-05 10:59:46', |
|||
company_id varchar(100) DEFAULT NULL COMMENT '1,', |
|||
brand varchar(100) DEFAULT NULL COMMENT '山海智慧-古瑞瓦特', |
|||
inverter_sn_code varchar(100) DEFAULT NULL COMMENT 'HSJ0BF20EP', |
|||
generator_number varchar(100) DEFAULT NULL COMMENT '1300771010488', |
|||
username varchar(100) DEFAULT NULL COMMENT '徐金辉', |
|||
phone varchar(100) DEFAULT NULL COMMENT '131****6866', |
|||
component_number varchar(100) DEFAULT NULL COMMENT '89,', |
|||
component_power varchar(100) DEFAULT NULL COMMENT '450,', |
|||
address varchar(100) DEFAULT NULL COMMENT '河北省石家庄市行唐县玉亭乡八里庄村民心路5号', |
|||
area_id varchar(100) DEFAULT NULL COMMENT '15214,', |
|||
name varchar(100) DEFAULT NULL COMMENT '@（行唐）河北晨航能源科技有限公司', |
|||
full_name varchar(100) DEFAULT NULL COMMENT '李**', |
|||
all_power varchar(100) DEFAULT NULL COMMENT '40.05', |
|||
city_name varchar(100) DEFAULT NULL COMMENT '河北省石家庄市行唐县', |
|||
create_time_text varchar(100) DEFAULT NULL COMMENT '2021-06-06 10:26:49', |
|||
order_type_text varchar(100) DEFAULT NULL COMMENT '户用', |
|||
status varchar(100) DEFAULT NULL COMMENT '0,', |
|||
status_text varchar(100) DEFAULT NULL COMMENT '等待', |
|||
first_time_text varchar(100) DEFAULT NULL COMMENT '2021-08-01 00:00:00', |
|||
total_day_power varchar(100) DEFAULT NULL COMMENT '0,', |
|||
total_month_power varchar(100) DEFAULT NULL COMMENT '0,', |
|||
total_year_power varchar(100) DEFAULT NULL COMMENT '6150.1,', |
|||
total_power varchar(100) DEFAULT NULL COMMENT '125715.3,', |
|||
pac varchar(100) DEFAULT NULL COMMENT '0,', |
|||
hour varchar(100) DEFAULT NULL COMMENT '0.0000', |
|||
day_money varchar(100) DEFAULT NULL COMMENT '0.00', |
|||
month_money varchar(100) DEFAULT NULL COMMENT '0.00', |
|||
total_money varchar(100) DEFAULT NULL COMMENT '49582.11', |
|||
avgPowerDay varchar(100) DEFAULT NULL COMMENT '8.66', |
|||
avgPowerMonth varchar(100) DEFAULT NULL COMMENT '3561.15', |
|||
avgPowerYear varchar(100) DEFAULT NULL COMMENT '11417.79', |
|||
avgPowerTotal varchar(100) DEFAULT NULL COMMENT '134367.07', |
|||
avgHour varchar(100) DEFAULT NULL COMMENT '0.17', |
|||
avgCo2 varchar(100) DEFAULT NULL COMMENT '66.98', |
|||
avgTree varchar(100) DEFAULT NULL COMMENT '8372.70', |
|||
avgAllPower varchar(100) DEFAULT NULL COMMENT '31.05', |
|||
avgComponentNumber varchar(100) DEFAULT NULL COMMENT '60', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT="数据大屏发电列表"; |
|||
|
|||
|
|||
|
|||
DROP TABLE IF EXISTS `sh_report_xmlctgb`; |
|||
CREATE TABLE `sh_report_xmlctgb` ( |
|||
id bigint NOT NULL AUTO_INCREMENT COMMENT 'id', |
|||
sjjzrq varchar(100) DEFAULT NULL COMMENT '数据截止日期', |
|||
zbsj varchar(100) DEFAULT NULL COMMENT '制表时间', |
|||
zbh varchar(100) DEFAULT '10' COMMENT '组编号', |
|||
zmc varchar(100) DEFAULT NULL COMMENT '组名称', |
|||
hbh varchar(100) DEFAULT '1001' COMMENT '行编号', |
|||
hmc varchar(100) DEFAULT NULL COMMENT '行名称', |
|||
|
|||
zsj_hs varchar(100) DEFAULT NULL COMMENT '总数据户数', |
|||
zsj_gl varchar(100) DEFAULT NULL COMMENT '总数据功率(MW)', |
|||
hyhj_hs varchar(100) DEFAULT NULL COMMENT '户用合计户数', |
|||
hyhj_gl varchar(100) DEFAULT NULL COMMENT '户用合计功率(MW)', |
|||
ayhy_hs varchar(100) DEFAULT NULL COMMENT '安阳户用户数', |
|||
ayhy_gl varchar(100) DEFAULT NULL COMMENT '安阳户用功率(MW)', |
|||
zhhy_hs varchar(100) DEFAULT NULL COMMENT '庄河户用户数', |
|||
zhhy_gl varchar(100) DEFAULT NULL COMMENT '庄河户用功率(MW)', |
|||
qbhy_hs varchar(100) DEFAULT NULL COMMENT '曲阜户用户数', |
|||
qbhy_gl varchar(100) DEFAULT NULL COMMENT '曲阜户用功率(MW)', |
|||
gsyhj_hs varchar(100) DEFAULT NULL COMMENT '工商业合计户数', |
|||
gsyhj_gl varchar(100) DEFAULT NULL COMMENT '工商业合计功率(MW)', |
|||
aygsy_hs varchar(100) DEFAULT NULL COMMENT '安阳工商业户数', |
|||
aygsy_gl varchar(100) DEFAULT NULL COMMENT '安阳工商业功率(MW)', |
|||
zhgsy_hs varchar(100) DEFAULT NULL COMMENT '庄河工商业户数', |
|||
zhgsy_gl varchar(100) DEFAULT NULL COMMENT '庄河工商业功率(MW)', |
|||
qbgsy_hs varchar(100) DEFAULT NULL COMMENT '曲阜工商业户数', |
|||
qbgsy_gl varchar(100) DEFAULT NULL COMMENT '曲阜工商业功率(MW)', |
|||
PRIMARY KEY (`id`) USING BTREE |
|||
) ENGINE=InnoDB COMMENT="项目各流程通过数据表"; |
|||
@ -0,0 +1,209 @@ |
|||
[{ |
|||
"name": "开始(创建订单)", |
|||
"unique_name": "2_3_0_0_1,1_8_0_0_1" |
|||
}, |
|||
{ |
|||
"name": "业务员录入", |
|||
"unique_name": "2_3_0_95_1,1_8_0_95_1" |
|||
}, |
|||
{ |
|||
"name": "代理商自审", |
|||
"unique_name": "2_3_0_100_1,1_8_0_100_1" |
|||
}, |
|||
{ |
|||
"name": "商务审核", |
|||
"unique_name": "2_3_0_110_1,1_8_0_110_1" |
|||
}, |
|||
{ |
|||
"name": "工程审核", |
|||
"unique_name": "2_3_0_120_1,1_8_0_120_1" |
|||
}, |
|||
{ |
|||
"name": "代理商备货申请", |
|||
"unique_name": "2_3_0_130_1,1_8_0_130_1" |
|||
}, |
|||
{ |
|||
"name": "确认品牌", |
|||
"unique_name": "2_3_0_131_1,1_8_0_131_1" |
|||
}, |
|||
{ |
|||
"name": "出库审核", |
|||
"unique_name": "2_3_0_132_1,1_8_0_132_1" |
|||
}, |
|||
{ |
|||
"name": "确认交货", |
|||
"unique_name": "2_3_0_133_1,1_8_0_133_1" |
|||
}, |
|||
{ |
|||
"name": "施工派工", |
|||
"unique_name": "2_3_0_136_1,1_8_0_136_1" |
|||
}, |
|||
{ |
|||
"name": "施工资料提交", |
|||
"unique_name": "2_3_0_138_1,1_8_0_138_1" |
|||
}, |
|||
{ |
|||
"name": "代理商完工自审", |
|||
"unique_name": "2_3_0_140_1,1_8_0_140_1" |
|||
}, |
|||
{ |
|||
"name": "完工审核", |
|||
"unique_name": "2_3_0_150_1,1_8_0_150_1" |
|||
}, |
|||
{ |
|||
"name": "并网资料提交", |
|||
"unique_name": "2_3_0_155_1,1_8_0_155_1" |
|||
}, |
|||
{ |
|||
"name": "代理商并网自审", |
|||
"unique_name": "2_3_0_160_1,1_8_0_160_1" |
|||
}, |
|||
{ |
|||
"name": "并网审核", |
|||
"unique_name": "2_3_0_170_1,1_8_0_170_1" |
|||
}, |
|||
{ |
|||
"name": "现场验收", |
|||
"unique_name": "2_3_0_180_1,1_8_0_180_1" |
|||
}, |
|||
{ |
|||
"name": "建转运", |
|||
"unique_name": "2_3_0_190_1,1_8_0_190_1" |
|||
}, |
|||
{ |
|||
"name": "(工)创建电站", |
|||
"unique_name": "11_16_0_0_1" |
|||
}, |
|||
{ |
|||
"name": "(工)业务收集资料", |
|||
"unique_name": "11_16_0_210_1" |
|||
}, |
|||
{ |
|||
"name": "(工)代理商自审", |
|||
"unique_name": "11_16_0_100_1" |
|||
}, |
|||
{ |
|||
"name": "(工)商务工程审核", |
|||
"unique_name": "11_16_0_220_1" |
|||
}, |
|||
{ |
|||
"name": "(工)项目经理确认", |
|||
"unique_name": "11_16_0_230_1" |
|||
}, |
|||
{ |
|||
"name": "(工)项目建议书", |
|||
"unique_name": "11_16_0_240_1" |
|||
}, |
|||
{ |
|||
"name": "(工)项目文件", |
|||
"unique_name": "11_16_0_250_1" |
|||
}, |
|||
{ |
|||
"name": "(工)工程部审核", |
|||
"unique_name": "11_16_0_253_1" |
|||
}, |
|||
{ |
|||
"name": "(工)施工合同", |
|||
"unique_name": "11_16_0_255_1" |
|||
}, |
|||
{ |
|||
"name": "(工)代理商申请备货", |
|||
"unique_name": "11_16_0_130_1" |
|||
}, |
|||
{ |
|||
"name": "(工)确认品牌", |
|||
"unique_name": "11_16_0_131_1" |
|||
}, |
|||
{ |
|||
"name": "(工)出库审核", |
|||
"unique_name": "11_16_0_132_1" |
|||
}, |
|||
{ |
|||
"name": "(工)确认交货", |
|||
"unique_name": "11_16_0_133_1" |
|||
}, |
|||
{ |
|||
"name": "(工)施工派工", |
|||
"unique_name": "11_16_0_136_1" |
|||
}, |
|||
{ |
|||
"name": "(工)完工提交", |
|||
"unique_name": "11_16_0_260_1" |
|||
}, |
|||
{ |
|||
"name": "(工)代理商完工自审", |
|||
"unique_name": "11_16_0_140_1" |
|||
}, |
|||
{ |
|||
"name": "(工)工程完工审核", |
|||
"unique_name": "11_16_0_150_1" |
|||
}, |
|||
{ |
|||
"name": "(工)并网资料提交", |
|||
"unique_name": "11_16_0_155_1" |
|||
}, |
|||
{ |
|||
"name": "(工)代理商并网自审", |
|||
"unique_name": "11_16_0_160_1" |
|||
}, |
|||
{ |
|||
"name": "(工)并网发电验收", |
|||
"unique_name": "11_16_0_270_1" |
|||
}, |
|||
{ |
|||
"name": "(工)验收资料提交", |
|||
"unique_name": "11_16_0_280_1" |
|||
}, |
|||
{ |
|||
"name": "(工)现场审核", |
|||
"unique_name": "11_16_0_180_1" |
|||
}, |
|||
{ |
|||
"name": "(工)建转运", |
|||
"unique_name": "11_16_0_190_1" |
|||
} |
|||
] |
|||
|
|||
|
|||
|
|||
'开始(创建订单)', |
|||
'业务员录入', |
|||
'代理商自审', |
|||
'商务审核', |
|||
'工程审核', |
|||
'代理商备货申请', |
|||
'确认品牌', |
|||
'出库审核', |
|||
'确认交货', |
|||
'施工派工', |
|||
'施工资料提交', |
|||
'代理商完工自审', |
|||
'完工审核', |
|||
'并网资料提交', |
|||
'代理商并网自审', |
|||
'并网审核', |
|||
'现场验收', |
|||
'建转运', |
|||
'(工)创建电站', |
|||
'(工)业务收集资料', |
|||
'(工)代理商自审', |
|||
'(工)商务工程审核', |
|||
'(工)项目经理确认', |
|||
'(工)项目建议书', |
|||
'(工)项目文件', |
|||
'(工)工程部审核', |
|||
'(工)施工合同', |
|||
'(工)代理商申请备货', |
|||
'(工)确认品牌', |
|||
'(工)出库审核', |
|||
'(工)确认交货', |
|||
'(工)施工派工', |
|||
'(工)完工提交', |
|||
'(工)代理商完工自审', |
|||
'(工)工程完工审核', |
|||
'(工)并网资料提交', |
|||
'(工)代理商并网自审', |
|||
'(工)并网发电验收', |
|||
'(工)验收资料提交', |
|||
'(工)现场审核', |
|||
'(工)建转运', |
|||
|
After Width: | Height: | Size: 349 KiB |
|
After Width: | Height: | Size: 115 KiB |
|
After Width: | Height: | Size: 46 KiB |
|
After Width: | Height: | Size: 251 KiB |
@ -0,0 +1,96 @@ |
|||
package com.yxt.supervise.gf.biz.home; |
|||
|
|||
import cn.hutool.core.map.MapUtil; |
|||
import cn.hutool.core.util.StrUtil; |
|||
import cn.hutool.json.JSONArray; |
|||
import cn.hutool.json.JSONObject; |
|||
import com.yxt.common.core.result.ResultBean; |
|||
import com.yxt.supervise.gf.biz.home.vo.GroupVo; |
|||
import com.yxt.supervise.gf.shanhai.ShRequester; |
|||
import com.yxt.supervise.gf.shanhai.resp.Homepage; |
|||
import org.springframework.web.bind.annotation.GetMapping; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
import java.util.ArrayList; |
|||
import java.util.HashMap; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
|
|||
@RestController("com.yxt.supervise.gf.biz.HomeRest") |
|||
@RequestMapping("/gf/home") |
|||
public class HomeRest { |
|||
|
|||
@GetMapping("/statistichomepage") |
|||
public ResultBean<GroupVo> statistichomepage() { |
|||
ResultBean rb = ResultBean.fireFail(); |
|||
Homepage resp = ShRequester.getSystem$statistic$homepage(); |
|||
GroupVo vo = new GroupVo(); |
|||
vo.setZskh(resp.getUser_data().get(1).getCount()); |
|||
vo.setYxdzs(resp.getOrder().getCount()); |
|||
vo.setWggm(strMwToDouble(resp.getPowers().getNow())); |
|||
vo.setZkgm(strMwToDouble(resp.getPowers().getAll())); |
|||
|
|||
return rb.success().setData(vo); |
|||
} |
|||
|
|||
@GetMapping("/statisticgroup_new_data") |
|||
public ResultBean<JSONObject> statisticgroup_new_data() { |
|||
ResultBean rb = ResultBean.fireFail(); |
|||
JSONObject obj = ShRequester.getSystem$statistic$group_new_data(); |
|||
List<String> listxa = new ArrayList<>(); |
|||
List<String> listxb = new ArrayList<>(); |
|||
List<Object> listya = new ArrayList<>(); |
|||
List<Object> listyb = new ArrayList<>(); |
|||
Map<String, Object> mapSort = MapUtil.sort(obj); |
|||
mapSort.forEach((k, v) -> { |
|||
if ("0".equals("" + v)) { |
|||
listxa.add(k); |
|||
listya.add(v); |
|||
} else { |
|||
listxb.add(k); |
|||
listyb.add(v); |
|||
} |
|||
}); |
|||
listxa.addAll(listxb); |
|||
listya.addAll(listyb); |
|||
Map<String, Object> map = new HashMap<>(); |
|||
map.put("listx", listxa); |
|||
map.put("listy", listya); |
|||
return rb.success().setData(map); |
|||
} |
|||
@GetMapping("/statisticgroup_area") |
|||
public ResultBean<JSONArray> statisticgroup_area() { |
|||
ResultBean rb = ResultBean.fireFail(); |
|||
JSONArray list = ShRequester.getSystem$statistic$group_area(); |
|||
return rb.success().setData(list); |
|||
} |
|||
@GetMapping("/statisticgroup_node") |
|||
public ResultBean<JSONArray> statisticgroup_node() { |
|||
ResultBean rb = ResultBean.fireFail(); |
|||
JSONArray list = ShRequester.getSystem$statistic$group_node(); |
|||
return rb.success().setData(list); |
|||
} |
|||
@GetMapping("/statisticgroup_dataid") |
|||
public ResultBean<JSONArray> statisticgroup_dataid() { |
|||
ResultBean rb = ResultBean.fireFail(); |
|||
JSONArray list = ShRequester.getSystem$statistic$group_dataid(); |
|||
return rb.success().setData(list); |
|||
} |
|||
|
|||
private double strMwToDouble(String str) { |
|||
|
|||
double ret = 0.0; |
|||
if (StrUtil.isNotBlank(str)) { |
|||
String mw = str.replace("MW", ""); |
|||
try { |
|||
ret = Double.parseDouble(mw); |
|||
} catch (Exception e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
return ret; |
|||
} |
|||
} |
|||
|
|||
|
|||
@ -0,0 +1,11 @@ |
|||
package com.yxt.supervise.gf.biz.home.vo; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class GroupVo { |
|||
private double zskh; // 正式客户
|
|||
private double yxdzs; // 有效电站数
|
|||
private double wggm; // 完工规模
|
|||
private double zkgm; // 在库规模
|
|||
} |
|||
@ -0,0 +1,31 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import cn.hutool.core.util.NumberUtil; |
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class CountValue { |
|||
private long hsnum; |
|||
private double glnum; |
|||
|
|||
public String getHs() { |
|||
if (hsnum == 0) |
|||
return ""; |
|||
return String.valueOf(hsnum); |
|||
} |
|||
/** |
|||
* 获取全球定位系统(GL)数值的字符串表示，格式为两位小数。 |
|||
* 该方法不接受任何参数。 |
|||
* |
|||
* @return 返回一个字符串，表示GL数值。如果glnum为0，则返回空字符串。 |
|||
*/ |
|||
public String getGl() { |
|||
// 判断glnum是否为0，若为0则直接返回空字符串
|
|||
if (glnum == 0) |
|||
return ""; |
|||
// 将glnum除以100000000，转换为更易读的格式
|
|||
double rnum = glnum / 100000000; |
|||
// 使用NumberUtil的decimalFormat方法，格式化rnum为两位小数，并返回结果
|
|||
return NumberUtil.decimalFormat("0.00", rnum); |
|||
} |
|||
} |
|||
@ -0,0 +1,113 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.alibaba.excel.annotation.ExcelProperty; |
|||
import com.alibaba.excel.annotation.write.style.ColumnWidth; |
|||
import lombok.EqualsAndHashCode; |
|||
import lombok.Getter; |
|||
import lombok.Setter; |
|||
|
|||
@Getter |
|||
@Setter |
|||
@EqualsAndHashCode |
|||
@ColumnWidth(20) |
|||
public class OrderIndexExcel { |
|||
|
|||
@ColumnWidth(10) |
|||
@ExcelProperty("电站id") |
|||
private Long id; // 电站id
|
|||
@ExcelProperty("电站编码") |
|||
private String order_no; // 电站编码
|
|||
@ExcelProperty("资产编号") |
|||
private String assets_no; // 资产编号
|
|||
@ExcelProperty("电站功率") |
|||
private long all_power; // 总功率
|
|||
@ExcelProperty("所属代理商") |
|||
private String agent_name; // 代理商名称
|
|||
@ExcelProperty("电站地址") |
|||
private String address; // 详细地址
|
|||
@ExcelProperty("所属公司名称") |
|||
private String company_name; // 所属公司名称
|
|||
@ExcelProperty("业务员姓名") |
|||
private String admin_name; // 业务员姓名
|
|||
@ExcelProperty("客户姓名") |
|||
private String user_name; // 用户名
|
|||
@ExcelProperty("用户电话") |
|||
private String user_phone; // 用户手机号
|
|||
@ExcelProperty("分组") |
|||
private String data_id; // 数据分组
|
|||
@ExcelProperty("产品") |
|||
private String product_name; // 产品名称
|
|||
@ExcelProperty("目前状态") |
|||
private String workflow_name; // 流程名称
|
|||
|
|||
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String admin_id; // 创建人id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String customer_id; // 客户id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String agent_id; // 代理商id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String product_id; // 产品id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private long create_time; // 创建时间
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String workflow_unique; // 当前流程
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String prototype_id; // 产品id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String remain_unique; //
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String is_best; // 是否为标杆电站
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String order_type; // 电站类型
|
|||
// @ExcelProperty("电站编码")
|
|||
// private long update_time; // 修改时间
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String company_id; // 公司id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String dg_name; // 数据分组说明
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String contract_life; // 合同年限
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String contract_group; // 合同组
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String area_id; // 地区id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String component_number; // 光伏板块数
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String component_power; // 组件安装功率
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String admin_phone; // 业务员手机号
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String id_card; // 用户身份证号
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String node_id; // nodeID
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String is_agree; // 审核是否通过
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String group_id; // 产品ID
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String sign; // 是否签署合同，1已签署，2未签署
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String uplode_contract; // 手动上传-合同
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String province_name; // 省
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String city_name; // 市
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String area_name; // 区/县
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String change_order_id; // 电站变更id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String p_agent_name; // 代理商名称
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String operation_id; // 运维id
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String operation_name; // 运维名称
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String order_type_text; // 产品说明
|
|||
// @ExcelProperty("电站编码")
|
|||
// private String is_save; // 是否可编辑 |int |
|
|||
|
|||
} |
|||
@ -0,0 +1,15 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.yxt.common.core.query.Query; |
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class OrderIndexQuery implements Query { |
|||
|
|||
private String page="1"; |
|||
private String limit="10"; |
|||
private String agent_id; |
|||
private String witch_data; |
|||
private String workflow; |
|||
private String[] search_time; |
|||
} |
|||
@ -0,0 +1,64 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableId; |
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import com.yxt.supervise.gf.shanhai.resp.ScreenGetOrderListAreaAvg; |
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
@TableName("sh_screen_order") |
|||
public class ScreenOrder { |
|||
@TableId |
|||
private Long id; // 29,
|
|||
private String order_no; // 2021060667629040986641
|
|||
private String admin_id; // 58,
|
|||
private String customer_id; // 41,
|
|||
private String agent_id; // 11,
|
|||
private String product_id; // 8,
|
|||
private String create_time; // 1622946409,
|
|||
private String data_id; // 1,35
|
|||
private String workflow_unique; // 1_8_0_190_1
|
|||
private String prototype_id; // 1,
|
|||
private String remain_unique; //
|
|||
private String is_best; // 0,
|
|||
private String order_type; // 1,
|
|||
private String update_time; // 2024-03-05 10:59:46
|
|||
private String company_id; // 1,
|
|||
private String brand; // 山海智慧-古瑞瓦特
|
|||
private String inverter_sn_code; // HSJ0BF20EP
|
|||
private String generator_number; // 1300771010488
|
|||
private String username; // 徐金辉
|
|||
private String phone; // 131****6866
|
|||
private String component_number; // 89,
|
|||
private String component_power; // 450,
|
|||
private String address; // 河北省石家庄市行唐县玉亭乡八里庄村民心路5号
|
|||
private String area_id; // 15214,
|
|||
private String name; // @（行唐）河北晨航能源科技有限公司
|
|||
private String full_name; // 李**
|
|||
private String all_power; // 40.05
|
|||
private String city_name; // 河北省石家庄市行唐县
|
|||
private String create_time_text; // 2021-06-06 10:26:49
|
|||
private String order_type_text; // 户用
|
|||
private String status; // 0,
|
|||
private String status_text; // 等待
|
|||
private String first_time_text; // 2021-08-01 00:00:00
|
|||
private String total_day_power; // 0,
|
|||
private String total_month_power; // 0,
|
|||
private String total_year_power; // 6150.1,
|
|||
private String total_power; // 125715.3,
|
|||
private String pac; // 0,
|
|||
private String hour; // 0.0000
|
|||
private String day_money; // 0.00
|
|||
private String month_money; // 0.00
|
|||
private String total_money; // 49582.11
|
|||
// private ScreenGetOrderListAreaAvg area_avg; // {
|
|||
private String avgPowerDay; // 8.66
|
|||
private String avgPowerMonth; // 3561.15
|
|||
private String avgPowerYear; // 11417.79
|
|||
private String avgPowerTotal; // 134367.07
|
|||
private String avgHour; // 0.17
|
|||
private String avgCo2; // 66.98
|
|||
private String avgTree; // 8372.70
|
|||
private String avgAllPower; // 31.05
|
|||
private String avgComponentNumber; // 60
|
|||
} |
|||
@ -0,0 +1,90 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.alibaba.excel.annotation.ExcelProperty; |
|||
import com.alibaba.excel.annotation.write.style.ColumnWidth; |
|||
import com.baomidou.mybatisplus.annotation.TableId; |
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import lombok.Data; |
|||
import lombok.EqualsAndHashCode; |
|||
import lombok.Getter; |
|||
import lombok.Setter; |
|||
|
|||
@Getter |
|||
@Setter |
|||
@EqualsAndHashCode |
|||
@ColumnWidth(20) |
|||
public class ScreenOrderExcel { |
|||
|
|||
@ExcelProperty("电站编号") |
|||
private String order_no; // 2021060667629040986641
|
|||
@ExcelProperty("客户名称") |
|||
private String username; // 徐金辉
|
|||
@ExcelProperty("电站类型") |
|||
private String order_type_text; // 户用
|
|||
@ExcelProperty("电站地址") |
|||
private String address; // 河北省石家庄市行唐县玉亭乡八里庄村民心路5号
|
|||
@ExcelProperty("代理商") |
|||
private String name; // @（行唐）河北晨航能源科技有限公司
|
|||
@ExcelProperty("电站规模(KW)") |
|||
private String all_power; // 40.05
|
|||
@ExcelProperty("实时功率(KW)") |
|||
private String pac; // 0,
|
|||
@ExcelProperty("首次发电时间") |
|||
private String first_time_text; // 2021-08-01 00:00:00
|
|||
@ExcelProperty("今日发电量(KW)") |
|||
private String total_day_power; // 0,
|
|||
@ExcelProperty("今日满发小时数") |
|||
private String hour; // 0.0000
|
|||
@ExcelProperty("当月发电量") |
|||
private String total_month_power; // 0,
|
|||
@ExcelProperty("累计发电量") |
|||
private String total_power; // 125715.3,
|
|||
@ExcelProperty("电站状态") |
|||
private String status_text; // 等待
|
|||
@ExcelProperty("创建日期") |
|||
private String create_time_text; // 2021-06-06 10:26:49
|
|||
@ExcelProperty("更新时间") |
|||
private String update_time; // 2024-03-05 10:59:46
|
|||
|
|||
|
|||
|
|||
|
|||
|
|||
// private Long id; // 29,
|
|||
// private String admin_id; // 58,
|
|||
// private String customer_id; // 41,
|
|||
// private String agent_id; // 11,
|
|||
// private String product_id; // 8,
|
|||
// private String create_time; // 1622946409,
|
|||
// private String data_id; // 1,35
|
|||
// private String workflow_unique; // 1_8_0_190_1
|
|||
// private String prototype_id; // 1,
|
|||
// private String remain_unique; //
|
|||
// private String is_best; // 0,
|
|||
// private String order_type; // 1,
|
|||
// private String company_id; // 1,
|
|||
// private String brand; // 山海智慧-古瑞瓦特
|
|||
// private String inverter_sn_code; // HSJ0BF20EP
|
|||
// private String generator_number; // 1300771010488
|
|||
// private String phone; // 131****6866
|
|||
// private String component_number; // 89,
|
|||
// private String component_power; // 450,
|
|||
// private String area_id; // 15214,
|
|||
// private String full_name; // 李**
|
|||
// private String city_name; // 河北省石家庄市行唐县
|
|||
// private String status; // 0,
|
|||
// private String total_year_power; // 6150.1,
|
|||
// private String day_money; // 0.00
|
|||
// private String month_money; // 0.00
|
|||
// private String total_money; // 49582.11
|
|||
//// private ScreenGetOrderListAreaAvg area_avg; // {
|
|||
// private String avgPowerDay; // 8.66
|
|||
// private String avgPowerMonth; // 3561.15
|
|||
// private String avgPowerYear; // 11417.79
|
|||
// private String avgPowerTotal; // 134367.07
|
|||
// private String avgHour; // 0.17
|
|||
// private String avgCo2; // 66.98
|
|||
// private String avgTree; // 8372.70
|
|||
// private String avgAllPower; // 31.05
|
|||
// private String avgComponentNumber; // 60
|
|||
} |
|||
@ -0,0 +1,11 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import org.apache.ibatis.annotations.Delete; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
|
|||
@Mapper |
|||
public interface ScreenOrderMapper extends BaseMapper<ScreenOrder> { |
|||
@Delete("delete from sh_screen_order where 1=1 ") |
|||
void clearAll(); |
|||
} |
|||
@ -0,0 +1,13 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.yxt.common.core.query.Query; |
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class ScreenOrderQuery implements Query { |
|||
|
|||
private String agent_id; |
|||
private String witch_data; |
|||
private String status; |
|||
private String[] search_time; |
|||
} |
|||
@ -0,0 +1,112 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import cn.hutool.core.bean.BeanUtil; |
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
import cn.hutool.core.util.StrUtil; |
|||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|||
import com.baomidou.mybatisplus.core.metadata.IPage; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.yxt.common.base.utils.PagerUtil; |
|||
import com.yxt.common.core.query.PagerQuery; |
|||
import com.yxt.common.core.result.ResultBean; |
|||
import com.yxt.supervise.gf.shanhai.ShRequester; |
|||
import com.yxt.supervise.gf.shanhai.resp.BaseResponse; |
|||
import com.yxt.supervise.gf.shanhai.resp.BaseResponseListObj; |
|||
import com.yxt.supervise.gf.shanhai.resp.ScreenGetOrderList; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.ArrayList; |
|||
import java.util.HashMap; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
|
|||
@Service |
|||
public class ScreenOrderService extends ServiceImpl<ScreenOrderMapper, ScreenOrder> { |
|||
|
|||
public ResultBean save(Map<String, Object> params) { |
|||
ResultBean rb = ResultBean.fireFail(); |
|||
BaseResponse<BaseResponseListObj<ScreenGetOrderList>> api$screen$screen$getOrderList = ShRequester.getApi$screen$screen$get_order_list(params); |
|||
List<ScreenGetOrderList> list = api$screen$screen$getOrderList.getData().getList(); |
|||
List<ScreenOrder> dblist = new ArrayList<>(); |
|||
list.forEach(item -> { |
|||
ScreenOrder orderIndex1 = new ScreenOrder(); |
|||
BeanUtil.copyProperties(item, orderIndex1); |
|||
BeanUtil.copyProperties(item.getArea_avg(), orderIndex1); |
|||
dblist.add(orderIndex1); |
|||
}); |
|||
this.saveBatch(dblist); |
|||
return rb.success().setMsg("添加成功"); |
|||
} |
|||
|
|||
public IPage<ScreenOrder> listPageFdlb(PagerQuery<ScreenOrderQuery> pq) { |
|||
|
|||
ScreenOrderQuery query = pq.getParams(); |
|||
QueryWrapper<ScreenOrder> qw = queryWarpFdlb(query); |
|||
|
|||
|
|||
IPage<ScreenOrder> page = PagerUtil.queryToPage(pq); |
|||
IPage<ScreenOrder> pagging = baseMapper.selectPage(page, qw); |
|||
return pagging; |
|||
} |
|||
|
|||
private QueryWrapper<ScreenOrder> queryWarpFdlb(ScreenOrderQuery query) { |
|||
QueryWrapper<ScreenOrder> qw = new QueryWrapper<>(); |
|||
|
|||
|
|||
if (StrUtil.isNotBlank(query.getAgent_id())) { |
|||
qw.eq("agent_id", query.getAgent_id()); |
|||
} |
|||
if (StrUtil.isNotBlank(query.getWitch_data())) { |
|||
qw.eq("group_id", query.getAgent_id()); |
|||
} |
|||
if (StrUtil.isNotBlank(query.getStatus())) { |
|||
qw.eq("status", query.getStatus()); |
|||
} |
|||
if (query.getSearch_time() != null && query.getSearch_time().length > 1) { |
|||
String val1 = query.getSearch_time()[0]; |
|||
DateTime time1 = DateUtil.parse(val1); |
|||
Long t1 = time1.getTime() / 1000; |
|||
|
|||
String val2 = query.getSearch_time()[1]; |
|||
DateTime time2 = DateUtil.parse(val2); |
|||
Long t2 = time2.getTime() / 1000; |
|||
|
|||
qw.between("create_time", t1, t2); |
|||
} |
|||
return qw; |
|||
} |
|||
|
|||
public List<ScreenOrderExcel> listFdlbForExcel(PagerQuery<ScreenOrderQuery> pq) { |
|||
List<ScreenOrderExcel> retList = new ArrayList<>(); |
|||
ScreenOrderQuery query = pq.getParams(); |
|||
QueryWrapper<ScreenOrder> qw = queryWarpFdlb(query); |
|||
List<ScreenOrder> orderIndexDbs = baseMapper.selectList(qw); |
|||
orderIndexDbs.forEach(ent -> { |
|||
ScreenOrderExcel oe = new ScreenOrderExcel(); |
|||
BeanUtil.copyProperties(ent, oe); |
|||
retList.add(oe); |
|||
}); |
|||
return retList; |
|||
} |
|||
|
|||
public void clearAndSave() { |
|||
|
|||
Map<String, Object> params = new HashMap<>(); |
|||
params.put("page", 1); |
|||
params.put("limit", "5"); |
|||
BaseResponse<BaseResponseListObj<ScreenGetOrderList>> resp = ShRequester.getApi$screen$screen$get_order_list(params); |
|||
Integer count = resp.getData().getCount(); |
|||
int pages = count / 100 + 1; |
|||
|
|||
baseMapper.clearAll(); |
|||
|
|||
|
|||
for (int i = 1; i < pages; i++) { |
|||
Map<String, Object> map = new HashMap<>(); |
|||
map.put("page", i); |
|||
map.put("limit", "100"); |
|||
this.save(map); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,17 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.IdType; |
|||
import com.baomidou.mybatisplus.annotation.TableId; |
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import com.yxt.supervise.gf.api.orderindex.OrderIndexDb; |
|||
import io.swagger.annotations.ApiModel; |
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* @author feikefei |
|||
* @create 2023-09-21-13:58 |
|||
*/ |
|||
@ApiModel(value = "电站数据(监管数据)") |
|||
@TableName("sh_order_index_jg") |
|||
public class ShOrderIndexJg extends OrderIndexDb { |
|||
} |
|||
@ -0,0 +1,101 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
import com.yxt.supervise.gf.util.ReportTool; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.ArrayList; |
|||
import java.util.Date; |
|||
import java.util.List; |
|||
|
|||
@Service |
|||
public class ShOrderIndexJgBaseService { |
|||
|
|||
public List<ShReportXmlctgb> buildDay(String day, String createTime, ShReportXmlctgbMapperBase baseMapper, String zbh, String zmc) { |
|||
List<ShReportXmlctgb> list = new ArrayList<>(); |
|||
ShReportXmlctgb lj = buildLj(day, createTime, baseMapper, zbh, zmc); |
|||
list.add(lj); |
|||
ShReportXmlctgb dy = buildDy(day, createTime, baseMapper, zbh, zmc); |
|||
list.add(dy); |
|||
ShReportXmlctgb bz = buildBz(day, createTime, baseMapper, zbh, zmc); |
|||
list.add(bz); |
|||
ShReportXmlctgb dr = buildDr(day, createTime, baseMapper, zbh, zmc); |
|||
list.add(dr); |
|||
return list; |
|||
} |
|||
|
|||
private ShReportXmlctgb buildLj(String day, String createTime, ShReportXmlctgbMapperBase baseMapper, String zbh, String zmc) { |
|||
|
|||
Date lastDayTime = DateUtil.offsetDay(DateUtil.parse(day), 1); |
|||
long lastDay = lastDayTime.getTime() / 1000; |
|||
|
|||
ShReportXmlctgb lj = new ShReportXmlctgb(day, createTime); |
|||
lj.setZbh(zbh); |
|||
lj.setZmc(zmc); |
|||
lj.setHbh(zbh + "01"); |
|||
lj.setHmc("累计"); |
|||
CountValue cv = baseMapper.countZsj(lastDay); |
|||
lj.setZsj_hs("" + cv.getHs()); |
|||
lj.setZsj_gl("" + cv.getGl()); |
|||
cv = baseMapper.countHyhj(lastDay); |
|||
lj.setHyhj_hs("" + cv.getHs()); |
|||
lj.setHyhj_gl("" + cv.getGl()); |
|||
return lj; |
|||
} |
|||
|
|||
private ShReportXmlctgb buildDy(String day, String createTime, ShReportXmlctgbMapperBase baseMapper, String zbh, String zmc) { |
|||
DateTime dateTime = DateUtil.parse(day); |
|||
String monthStr = ReportTool.monthStr(dateTime); |
|||
ShReportXmlctgb lj = new ShReportXmlctgb(day, createTime); |
|||
lj.setZbh(zbh); |
|||
lj.setZmc(zmc); |
|||
lj.setHbh(zbh + "02"); |
|||
lj.setHmc(monthStr); |
|||
DateTime beginOfMonth = DateUtil.beginOfMonth(dateTime); |
|||
DateTime endOfMonth = DateUtil.endOfMonth(dateTime); |
|||
long begin = beginOfMonth.getTime() / 1000; |
|||
long end = endOfMonth.getTime() / 1000; |
|||
CountValue cv = baseMapper.countZsjBetween(begin, end); |
|||
lj.setZsj_hs("" + cv.getHs()); |
|||
lj.setZsj_gl("" + cv.getGl()); |
|||
return lj; |
|||
} |
|||
|
|||
private ShReportXmlctgb buildBz(String day, String createTime, ShReportXmlctgbMapperBase baseMapper, String zbh, String zmc) { |
|||
DateTime dateTime = DateUtil.parse(day); |
|||
int weekOfYear = DateUtil.weekOfYear(dateTime); |
|||
String weekStr = "第" + weekOfYear + "周"; |
|||
ShReportXmlctgb lj = new ShReportXmlctgb(day, createTime); |
|||
lj.setZbh(zbh); |
|||
lj.setZmc(zmc); |
|||
lj.setHbh(zbh + "03"); |
|||
lj.setHmc(weekStr); |
|||
DateTime beginOfWeek = DateUtil.beginOfWeek(dateTime); |
|||
DateTime endOfWeek = DateUtil.beginOfWeek(dateTime); |
|||
long begin = beginOfWeek.getTime() / 1000; |
|||
long end = endOfWeek.getTime() / 1000; |
|||
CountValue cv = baseMapper.countZsjBetween(begin, end); |
|||
lj.setZsj_hs("" + cv.getHs()); |
|||
lj.setZsj_gl("" + cv.getGl()); |
|||
return lj; |
|||
} |
|||
|
|||
private ShReportXmlctgb buildDr(String day, String createTime, ShReportXmlctgbMapperBase baseMapper, String zbh, String zmc) { |
|||
DateTime dateTime = DateUtil.parse(day); |
|||
String dayStr = DateUtil.format(dateTime, "MM/dd") + "日"; |
|||
ShReportXmlctgb lj = new ShReportXmlctgb(day, createTime); |
|||
lj.setZbh(zbh); |
|||
lj.setZmc(zmc); |
|||
lj.setHbh(zbh + "04"); |
|||
lj.setHmc(dayStr); |
|||
DateTime beginOfDay = DateUtil.beginOfDay(dateTime); |
|||
DateTime endOfDay = DateUtil.endOfDay(dateTime); |
|||
long begin = beginOfDay.getTime() / 1000; |
|||
long end = endOfDay.getTime() / 1000; |
|||
CountValue cv = baseMapper.countZsjBetween(begin, end); |
|||
lj.setZsj_hs("" + cv.getHs()); |
|||
lj.setZsj_gl("" + cv.getGl()); |
|||
return lj; |
|||
} |
|||
} |
|||
@ -0,0 +1,14 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import com.yxt.supervise.gf.api.orderindex.OrderIndexDb; |
|||
import io.swagger.annotations.ApiModel; |
|||
|
|||
/** |
|||
* @author feikefei |
|||
* @create 2023-09-21-13:58 |
|||
*/ |
|||
@ApiModel(value = "电站数据(监管数据)") |
|||
@TableName("sh_order_index_jg_bw") |
|||
public class ShOrderIndexJgBw extends OrderIndexDb { |
|||
} |
|||
@ -0,0 +1,21 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
import org.apache.ibatis.annotations.Param; |
|||
import org.apache.ibatis.annotations.Select; |
|||
|
|||
@Mapper |
|||
public interface ShOrderIndexJgBwMapper extends BaseMapper<ShOrderIndexJgBw>, ShReportXmlctgbMapperBase { |
|||
|
|||
String table_name = "sh_order_index_jg_bw"; |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where create_time<#{day}") |
|||
CountValue countZsj(@Param("day") long lastDay); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countZsjBetween(@Param("begin") long begin, @Param("end") long end); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where order_type=1 and create_time<#{day}") |
|||
CountValue countHyhj(@Param("day") long lastDay); |
|||
} |
|||
@ -0,0 +1,17 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Service |
|||
public class ShOrderIndexJgBwService extends ServiceImpl<ShOrderIndexJgBwMapper, ShOrderIndexJgBw> { |
|||
@Autowired |
|||
private ShOrderIndexJgBaseService shOrderIndexJgBaseService; |
|||
|
|||
public List<ShReportXmlctgb> buildDay(String day, String createTime) { |
|||
return shOrderIndexJgBaseService.buildDay(day, createTime, this.baseMapper, "50", "并网"); |
|||
} |
|||
} |
|||
@ -0,0 +1,14 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import com.yxt.supervise.gf.api.orderindex.OrderIndexDb; |
|||
import io.swagger.annotations.ApiModel; |
|||
|
|||
/** |
|||
* @author feikefei |
|||
* @create 2023-09-21-13:58 |
|||
*/ |
|||
@ApiModel(value = "电站数据(监管数据)") |
|||
@TableName("sh_order_index_jg_jh") |
|||
public class ShOrderIndexJgJh extends OrderIndexDb { |
|||
} |
|||
@ -0,0 +1,21 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
import org.apache.ibatis.annotations.Param; |
|||
import org.apache.ibatis.annotations.Select; |
|||
|
|||
@Mapper |
|||
public interface ShOrderIndexJgJhMapper extends BaseMapper<ShOrderIndexJgJh> , ShReportXmlctgbMapperBase{ |
|||
|
|||
String table_name = "sh_order_index_jg_jh"; |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where create_time<#{day}") |
|||
CountValue countZsj(@Param("day") long lastDay); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countZsjBetween(@Param("begin") long begin, @Param("end") long end); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where order_type=1 and create_time<#{day}") |
|||
CountValue countHyhj(@Param("day") long lastDay); |
|||
} |
|||
@ -0,0 +1,17 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Service |
|||
public class ShOrderIndexJgJhService extends ServiceImpl<ShOrderIndexJgJhMapper,ShOrderIndexJgJh> { |
|||
@Autowired |
|||
private ShOrderIndexJgBaseService shOrderIndexJgBaseService; |
|||
|
|||
public List<ShReportXmlctgb> buildDay(String day, String createTime) { |
|||
return shOrderIndexJgBaseService.buildDay(day, createTime, this.baseMapper, "30", "交货"); |
|||
} |
|||
} |
|||
@ -0,0 +1,14 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import com.yxt.supervise.gf.api.orderindex.OrderIndexDb; |
|||
import io.swagger.annotations.ApiModel; |
|||
|
|||
/** |
|||
* @author feikefei |
|||
* @create 2023-09-21-13:58 |
|||
*/ |
|||
@ApiModel(value = "电站数据(监管数据)") |
|||
@TableName("sh_order_index_jg_jj") |
|||
public class ShOrderIndexJgJj extends OrderIndexDb { |
|||
} |
|||
@ -0,0 +1,18 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
import org.apache.ibatis.annotations.Param; |
|||
import org.apache.ibatis.annotations.Select; |
|||
|
|||
@Mapper |
|||
public interface ShOrderIndexJgJjMapper extends BaseMapper<ShOrderIndexJgJj>, ShReportXmlctgbMapperBase { |
|||
@Select("select count(1) as hs,sum(all_power) as gl from sh_order_index_jg_jj where create_time<#{day}") |
|||
CountValue countZsj(@Param("day") long lastDay); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from sh_order_index_jg_jj where create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countZsjBetween(@Param("begin") long begin, @Param("end") long end); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from sh_order_index_jg_jj where order_type=1 and create_time<#{day}") |
|||
CountValue countHyhj(@Param("day") long lastDay); |
|||
} |
|||
@ -0,0 +1,22 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.yxt.supervise.gf.util.ReportTool; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.ArrayList; |
|||
import java.util.Date; |
|||
import java.util.List; |
|||
|
|||
@Service |
|||
public class ShOrderIndexJgJjService extends ServiceImpl<ShOrderIndexJgJjMapper, ShOrderIndexJgJj> { |
|||
@Autowired |
|||
private ShOrderIndexJgBaseService shOrderIndexJgBaseService; |
|||
|
|||
public List<ShReportXmlctgb> buildDay(String day, String createTime) { |
|||
return shOrderIndexJgBaseService.buildDay(day, createTime, this.baseMapper, "10", "进件"); |
|||
} |
|||
} |
|||
@ -0,0 +1,105 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import org.apache.ibatis.annotations.Delete; |
|||
import org.apache.ibatis.annotations.Insert; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
|
|||
@Mapper |
|||
public interface ShOrderIndexJgMapper extends BaseMapper<ShOrderIndexJg> { |
|||
@Delete("delete from sh_order_index_jg where 1=1 ") |
|||
void clearAll(); |
|||
|
|||
@Insert("INSERT INTO sh_order_index_jg " + |
|||
"SELECT * " + |
|||
"FROM sh_order_index soi " + |
|||
"WHERE soi.data_id LIKE '%河南安阳%' or soi.data_id LIKE '%山东曲阜%' or soi.data_id LIKE '%庄河整县%' ") |
|||
void init(); |
|||
|
|||
@Delete("delete from sh_order_index_jg_jj where 1=1 ") |
|||
void clearJj(); |
|||
|
|||
@Insert("INSERT INTO sh_order_index_jg_jj " + |
|||
"SELECT * " + |
|||
"FROM sh_order_index_jg soij " + |
|||
"WHERE soij.workflow_name <> '开始(创建订单)' ") |
|||
void initJj(); |
|||
|
|||
@Delete("delete from sh_order_index_jg_qy where 1=1 ") |
|||
void clearQy(); |
|||
|
|||
@Insert("INSERT INTO sh_order_index_jg_qy " + |
|||
"SELECT * " + |
|||
"FROM sh_order_index_jg soij " + |
|||
"WHERE soij.sign=1 ") |
|||
void initQy(); |
|||
|
|||
@Delete("delete from sh_order_index_jg_jh where 1=1 ") |
|||
void clearJh(); |
|||
|
|||
@Insert("INSERT INTO sh_order_index_jg_jh " + |
|||
"SELECT * " + |
|||
"FROM sh_order_index_jg soij " + |
|||
"WHERE soij.workflow_name in ( " + |
|||
"'确认交货', " + |
|||
"'施工派工', " + |
|||
"'施工资料提交', " + |
|||
"'代理商完工自审', " + |
|||
"'代理商完工自审驳回', " + |
|||
"'完工审核', " + |
|||
"'完工审核驳回', " + |
|||
"'并网资料提交', " + |
|||
"'代理商并网自审', " + |
|||
"'并网审核', " + |
|||
"'并网审核驳回', " + |
|||
"'现场验收', " + |
|||
"'建转运', " + |
|||
"'(工)确认交货', " + |
|||
"'(工)施工派工', " + |
|||
"'(工)完工提交', " + |
|||
"'(工)代理商完工自审', " + |
|||
"'(工)工程完工审核', " + |
|||
"'(工)并网资料提交', " + |
|||
"'(工)代理商并网自审', " + |
|||
"'(工)并网发电验收', " + |
|||
"'(工)验收资料提交', " + |
|||
"'(工)现场审核', " + |
|||
"'(工)建转运' " + |
|||
")") |
|||
void initJh(); |
|||
|
|||
@Delete("delete from sh_order_index_jg_wg where 1=1 ") |
|||
void clearWg(); |
|||
|
|||
@Insert("INSERT INTO sh_order_index_jg_wg " + |
|||
"SELECT * " + |
|||
"FROM sh_order_index_jg soij " + |
|||
"WHERE soij.workflow_name in ( " + |
|||
"'并网资料提交', " + |
|||
"'代理商并网自审', " + |
|||
"'并网审核', " + |
|||
"'并网审核驳回', " + |
|||
"'现场验收', " + |
|||
"'建转运', " + |
|||
"'(工)并网资料提交', " + |
|||
"'(工)代理商并网自审', " + |
|||
"'(工)并网发电验收', " + |
|||
"'(工)验收资料提交', " + |
|||
"'(工)现场审核', " + |
|||
"'(工)建转运' " + |
|||
")") |
|||
void initWg(); |
|||
|
|||
@Delete("delete from sh_order_index_jg_bw where 1=1 ") |
|||
void clearBw(); |
|||
@Insert("INSERT INTO sh_order_index_jg_bw " + |
|||
"SELECT * " + |
|||
"FROM sh_order_index_jg soij " + |
|||
"WHERE soij.workflow_name in ( " + |
|||
"'现场验收', " + |
|||
"'建转运', " + |
|||
"'(工)现场审核', " + |
|||
"'(工)建转运' " + |
|||
")") |
|||
void initBw(); |
|||
} |
|||
@ -0,0 +1,14 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import com.yxt.supervise.gf.api.orderindex.OrderIndexDb; |
|||
import io.swagger.annotations.ApiModel; |
|||
|
|||
/** |
|||
* @author feikefei |
|||
* @create 2023-09-21-13:58 |
|||
*/ |
|||
@ApiModel(value = "电站数据(监管数据)") |
|||
@TableName("sh_order_index_jg_qy") |
|||
public class ShOrderIndexJgQy extends OrderIndexDb { |
|||
} |
|||
@ -0,0 +1,21 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
import org.apache.ibatis.annotations.Param; |
|||
import org.apache.ibatis.annotations.Select; |
|||
|
|||
@Mapper |
|||
public interface ShOrderIndexJgQyMapper extends BaseMapper<ShOrderIndexJgQy> , ShReportXmlctgbMapperBase{ |
|||
|
|||
String table_name = "sh_order_index_jg_qy"; |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where create_time<#{day}") |
|||
CountValue countZsj(@Param("day") long lastDay); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countZsjBetween(@Param("begin") long begin, @Param("end") long end); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where order_type=1 and create_time<#{day}") |
|||
CountValue countHyhj(@Param("day") long lastDay); |
|||
} |
|||
@ -0,0 +1,22 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.yxt.supervise.gf.util.ReportTool; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.ArrayList; |
|||
import java.util.Date; |
|||
import java.util.List; |
|||
|
|||
@Service |
|||
public class ShOrderIndexJgQyService extends ServiceImpl<ShOrderIndexJgQyMapper,ShOrderIndexJgQy> { |
|||
@Autowired |
|||
private ShOrderIndexJgBaseService shOrderIndexJgBaseService; |
|||
|
|||
public List<ShReportXmlctgb> buildDay(String day, String createTime) { |
|||
return shOrderIndexJgBaseService.buildDay(day, createTime, this.baseMapper, "20", "签约"); |
|||
} |
|||
} |
|||
@ -0,0 +1,34 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.Date; |
|||
|
|||
@Service |
|||
public class ShOrderIndexJgService extends ServiceImpl<ShOrderIndexJgMapper, ShOrderIndexJg> { |
|||
|
|||
@Autowired |
|||
private ShReportXmlctgbService shReportXmlctgbService; |
|||
public void clearAndInit() { |
|||
this.baseMapper.clearAll(); |
|||
this.baseMapper.init(); |
|||
this.baseMapper.clearJj(); |
|||
this.baseMapper.initJj(); |
|||
this.baseMapper.clearQy(); |
|||
this.baseMapper.initQy(); |
|||
this.baseMapper.clearJh(); |
|||
this.baseMapper.initJh(); |
|||
this.baseMapper.clearWg(); |
|||
this.baseMapper.initWg(); |
|||
this.baseMapper.clearBw(); |
|||
this.baseMapper.initBw(); |
|||
|
|||
DateTime dateTime = DateUtil.offsetDay(new Date(), -1); |
|||
String yestday = DateUtil.format(dateTime, "yyyy-MM-dd"); |
|||
shReportXmlctgbService.buildDay(yestday); |
|||
} |
|||
} |
|||
@ -0,0 +1,14 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import com.yxt.supervise.gf.api.orderindex.OrderIndexDb; |
|||
import io.swagger.annotations.ApiModel; |
|||
|
|||
/** |
|||
* @author feikefei |
|||
* @create 2023-09-21-13:58 |
|||
*/ |
|||
@ApiModel(value = "电站数据(监管数据)") |
|||
@TableName("sh_order_index_jg_wg") |
|||
public class ShOrderIndexJgWg extends OrderIndexDb { |
|||
} |
|||
@ -0,0 +1,21 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
import org.apache.ibatis.annotations.Param; |
|||
import org.apache.ibatis.annotations.Select; |
|||
|
|||
@Mapper |
|||
public interface ShOrderIndexJgWgMapper extends BaseMapper<ShOrderIndexJgWg> , ShReportXmlctgbMapperBase{ |
|||
|
|||
String table_name = "sh_order_index_jg_wg"; |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where create_time<#{day}") |
|||
CountValue countZsj(@Param("day") long lastDay); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countZsjBetween(@Param("begin") long begin, @Param("end") long end); |
|||
|
|||
@Select("select count(1) as hs,sum(all_power) as gl from " + table_name + " where order_type=1 and create_time<#{day}") |
|||
CountValue countHyhj(@Param("day") long lastDay); |
|||
} |
|||
@ -0,0 +1,17 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Service |
|||
public class ShOrderIndexJgWgService extends ServiceImpl<ShOrderIndexJgWgMapper, ShOrderIndexJgWg> { |
|||
@Autowired |
|||
private ShOrderIndexJgBaseService shOrderIndexJgBaseService; |
|||
|
|||
public List<ShReportXmlctgb> buildDay(String day, String createTime) { |
|||
return shOrderIndexJgBaseService.buildDay(day, createTime, this.baseMapper, "40", "完工"); |
|||
} |
|||
} |
|||
@ -0,0 +1,47 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.IdType; |
|||
import com.baomidou.mybatisplus.annotation.TableId; |
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
@TableName("sh_report_xmlctgb") |
|||
public class ShReportXmlctgb { |
|||
public ShReportXmlctgb() { |
|||
} |
|||
|
|||
public ShReportXmlctgb(String sjjzrq, String zbsj) { |
|||
this.sjjzrq = sjjzrq; |
|||
this.zbsj = zbsj; |
|||
} |
|||
|
|||
@TableId |
|||
private Long id; // 电站id
|
|||
|
|||
private String sjjzrq; // 数据截止日期',
|
|||
private String zbsj; // 制表时间',
|
|||
private String zbh; // 组编号',
|
|||
private String zmc; // 组名称',
|
|||
private String hbh; // 行编号',
|
|||
private String hmc; // 行名称',
|
|||
|
|||
private String zsj_hs; // 总数据户数',
|
|||
private String zsj_gl; // 总数据功率(MW)',
|
|||
private String hyhj_hs; // 户用合计户数',
|
|||
private String hyhj_gl; // 户用合计功率(MW)',
|
|||
private String ayhy_hs; // 安阳户用户数',
|
|||
private String ayhy_gl; // 安阳户用功率(MW)',
|
|||
private String zhhy_hs; // 庄河户用户数',
|
|||
private String zhhy_gl; // 庄河户用功率(MW)',
|
|||
private String qbhy_hs; // 曲阜户用户数',
|
|||
private String qbhy_gl; // 曲阜户用功率(MW)',
|
|||
private String gsyhj_hs; // 工商业合计户数',
|
|||
private String gsyhj_gl; // 工商业合计功率(MW)',
|
|||
private String aygsy_hs; // 安阳工商业户数',
|
|||
private String aygsy_gl; // 安阳工商业功率(MW)',
|
|||
private String zhgsy_hs; // 庄河工商业户数',
|
|||
private String zhgsy_gl; // 庄河工商业功率(MW)',
|
|||
private String qbgsy_hs; // 曲阜工商业户数',
|
|||
private String qbgsy_gl; // 曲阜工商业功率(MW)',
|
|||
} |
|||
@ -0,0 +1,37 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
import org.apache.ibatis.annotations.Param; |
|||
import org.apache.ibatis.annotations.Select; |
|||
|
|||
@Mapper |
|||
public interface ShReportXmlctgbMapper extends BaseMapper<ShReportXmlctgb> { |
|||
|
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where create_time<#{day}") |
|||
CountValue countZsj(@Param("tablename") String tablename, @Param("day") long lastDay); |
|||
|
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countZsjBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
|
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type=1 and create_time<#{day}") |
|||
CountValue countHyhj(@Param("tablename") String tablename, @Param("day") long lastDay); |
|||
|
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type=1 and create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countHyhjBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type=1 AND data_id LIKE '%河南安阳%' and create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countAyhyBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type=1 AND data_id LIKE '%庄河整县%' and create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countZhhyBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type=1 AND data_id LIKE '%山东曲阜%' and create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countQbhyBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
|
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type<>1 and create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countGsyhjBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type<>1 AND data_id LIKE '%河南安阳%' and create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countAygsyBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type<>1 AND data_id LIKE '%庄河整县%' and create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countZhgsyBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
@Select("select count(1) as hsnum,sum(all_power) as glnum from ${tablename} where order_type<>1 AND data_id LIKE '%山东曲阜%' and create_time>=#{begin} and create_time<=#{end} ") |
|||
CountValue countQbgsyBetween(@Param("tablename") String tablename, @Param("begin") long begin, @Param("end") long end); |
|||
} |
|||
@ -0,0 +1,9 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
public interface ShReportXmlctgbMapperBase { |
|||
CountValue countZsj(long lastDay); |
|||
|
|||
CountValue countZsjBetween(long begin, long end); |
|||
|
|||
CountValue countHyhj(long lastDay); |
|||
} |
|||
@ -0,0 +1,173 @@ |
|||
package com.yxt.supervise.gf.biz.orderindex; |
|||
|
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
import cn.hutool.core.util.StrUtil; |
|||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|||
import com.yxt.supervise.gf.util.ReportTool; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.ArrayList; |
|||
import java.util.Date; |
|||
import java.util.List; |
|||
|
|||
@Service |
|||
public class ShReportXmlctgbService extends ServiceImpl<ShReportXmlctgbMapper, ShReportXmlctgb> { |
|||
|
|||
public List<ShReportXmlctgb> listOfDay(String day) { |
|||
if (StrUtil.isBlank(day)) { |
|||
day = DateUtil.format(new Date(), "yyyy-MM-dd"); |
|||
} |
|||
QueryWrapper<ShReportXmlctgb> qw = new QueryWrapper<>(); |
|||
qw.eq("sjjzrq", day); |
|||
qw.orderByAsc("hbh"); |
|||
|
|||
List<ShReportXmlctgb> list = this.baseMapper.selectList(qw); |
|||
if (list == null || list.size() == 0) { |
|||
list = buildDay(day); |
|||
} |
|||
return list; |
|||
} |
|||
|
|||
public List<ShReportXmlctgb> buildDay(String day) { |
|||
List<ShReportXmlctgb> list = new ArrayList<>(); |
|||
if (StrUtil.isBlank(day)) { |
|||
return list; |
|||
} |
|||
String createTime = DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss"); |
|||
|
|||
// List<ShReportXmlctgb> listJj = shOrderIndexJgJjService.buildDay(day, createTime);
|
|||
// List<ShReportXmlctgb> listQy = shOrderIndexJgQyService.buildDay(day, createTime);
|
|||
// List<ShReportXmlctgb> listJh = shOrderIndexJgJhService.buildDay(day, createTime);
|
|||
// List<ShReportXmlctgb> listWg = shOrderIndexJgWgService.buildDay(day, createTime);
|
|||
// List<ShReportXmlctgb> listBw = shOrderIndexJgBwService.buildDay(day, createTime);
|
|||
|
|||
List<ShReportXmlctgb> listJj = buildDayOfJd(day, createTime, "sh_order_index_jg_jj", "10", "进件"); |
|||
List<ShReportXmlctgb> listQy = buildDayOfJd(day, createTime, "sh_order_index_jg_qy", "20", "签约"); |
|||
List<ShReportXmlctgb> listJh = buildDayOfJd(day, createTime, "sh_order_index_jg_jh", "30", "交货"); |
|||
List<ShReportXmlctgb> listWg = buildDayOfJd(day, createTime, "sh_order_index_jg_wg", "40", "完工"); |
|||
List<ShReportXmlctgb> listBw = buildDayOfJd(day, createTime, "sh_order_index_jg_bw", "50", "并网"); |
|||
list.addAll(listJj); |
|||
list.addAll(listQy); |
|||
list.addAll(listJh); |
|||
list.addAll(listWg); |
|||
list.addAll(listBw); |
|||
baseMapper.delete(new QueryWrapper<ShReportXmlctgb>().eq("sjjzrq", day)); |
|||
this.saveBatch(list); |
|||
return list; |
|||
} |
|||
|
|||
private List<ShReportXmlctgb> buildDayOfJd(String day, String createTime, String tablename, String zbh, String zmc) { |
|||
List<ShReportXmlctgb> list = new ArrayList<>(); |
|||
ShReportXmlctgb lj = buildLj(day, createTime, tablename, zbh, zmc); |
|||
list.add(lj); |
|||
ShReportXmlctgb dy = buildDy(day, createTime, tablename, zbh, zmc); |
|||
list.add(dy); |
|||
ShReportXmlctgb bz = buildBz(day, createTime, tablename, zbh, zmc); |
|||
list.add(bz); |
|||
ShReportXmlctgb dr = buildDr(day, createTime, tablename, zbh, zmc); |
|||
list.add(dr); |
|||
return list; |
|||
} |
|||
|
|||
private void fillReportItem(String tablename, long begin, long end, ShReportXmlctgb lj) { |
|||
CountValue cv = baseMapper.countZsjBetween(tablename, begin, end); |
|||
lj.setZsj_hs("" + cv.getHs()); |
|||
lj.setZsj_gl("" + cv.getGl()); |
|||
cv = baseMapper.countHyhjBetween(tablename, begin, end); |
|||
lj.setHyhj_hs("" + cv.getHs()); |
|||
lj.setHyhj_gl("" + cv.getGl()); |
|||
cv = baseMapper.countAyhyBetween(tablename, begin, end); |
|||
lj.setAyhy_hs("" + cv.getHs()); |
|||
lj.setAyhy_gl("" + cv.getGl()); |
|||
cv = baseMapper.countZhhyBetween(tablename, begin, end); |
|||
lj.setZhhy_hs("" + cv.getHs()); |
|||
lj.setZhhy_gl("" + cv.getGl()); |
|||
cv = baseMapper.countQbhyBetween(tablename, begin, end); |
|||
lj.setQbhy_hs("" + cv.getHs()); |
|||
lj.setQbhy_gl("" + cv.getGl()); |
|||
cv = baseMapper.countGsyhjBetween(tablename, begin, end); |
|||
lj.setGsyhj_hs("" + cv.getHs()); |
|||
lj.setGsyhj_gl("" + cv.getGl()); |
|||
cv = baseMapper.countAygsyBetween(tablename, begin, end); |
|||
lj.setAygsy_hs("" + cv.getHs()); |
|||
lj.setAygsy_gl("" + cv.getGl()); |
|||
cv = baseMapper.countZhgsyBetween(tablename, begin, end); |
|||
lj.setZhgsy_hs("" + cv.getHs()); |
|||
lj.setZhgsy_gl("" + cv.getGl()); |
|||
cv = baseMapper.countQbgsyBetween(tablename, begin, end); |
|||
lj.setQbgsy_hs("" + cv.getHs()); |
|||
lj.setQbgsy_gl("" + cv.getGl()); |
|||
} |
|||
|
|||
private ShReportXmlctgb buildLj(String day, String createTime, String tablename, String zbh, String zmc) { |
|||
|
|||
// Date lastDayTime = DateUtil.offsetDay(DateUtil.parse(day), 1);
|
|||
// long lastDay = lastDayTime.getTime() / 1000;
|
|||
|
|||
DateTime dateTime = DateUtil.parse(day); |
|||
|
|||
ShReportXmlctgb lj = new ShReportXmlctgb(day, createTime); |
|||
lj.setZbh(zbh); |
|||
lj.setZmc(zmc); |
|||
lj.setHbh(zbh + "01"); |
|||
lj.setHmc("累计"); |
|||
DateTime endOfDay = DateUtil.endOfDay(dateTime); |
|||
long begin = 1262275200L; |
|||
long end = endOfDay.getTime() / 1000; |
|||
|
|||
fillReportItem(tablename, begin, end, lj); |
|||
|
|||
return lj; |
|||
} |
|||
|
|||
private ShReportXmlctgb buildDy(String day, String createTime, String tablename, String zbh, String zmc) { |
|||
DateTime dateTime = DateUtil.parse(day); |
|||
String monthStr = ReportTool.monthStr(dateTime); |
|||
ShReportXmlctgb lj = new ShReportXmlctgb(day, createTime); |
|||
lj.setZbh(zbh); |
|||
lj.setZmc(zmc); |
|||
lj.setHbh(zbh + "02"); |
|||
lj.setHmc(monthStr); |
|||
DateTime beginOfMonth = DateUtil.beginOfMonth(dateTime); |
|||
DateTime endOfMonth = DateUtil.endOfMonth(dateTime); |
|||
long begin = beginOfMonth.getTime() / 1000; |
|||
long end = endOfMonth.getTime() / 1000; |
|||
fillReportItem(tablename, begin, end, lj); |
|||
return lj; |
|||
} |
|||
|
|||
private ShReportXmlctgb buildBz(String day, String createTime, String tablename, String zbh, String zmc) { |
|||
DateTime dateTime = DateUtil.parse(day); |
|||
int weekOfYear = DateUtil.weekOfYear(dateTime); |
|||
String weekStr = "第" + weekOfYear + "周"; |
|||
ShReportXmlctgb lj = new ShReportXmlctgb(day, createTime); |
|||
lj.setZbh(zbh); |
|||
lj.setZmc(zmc); |
|||
lj.setHbh(zbh + "03"); |
|||
lj.setHmc(weekStr); |
|||
DateTime beginOfWeek = DateUtil.beginOfWeek(dateTime); |
|||
DateTime endOfWeek = DateUtil.endOfWeek(dateTime); |
|||
long begin = beginOfWeek.getTime() / 1000; |
|||
long end = endOfWeek.getTime() / 1000; |
|||
fillReportItem(tablename, begin, end, lj); |
|||
return lj; |
|||
} |
|||
|
|||
private ShReportXmlctgb buildDr(String day, String createTime, String tablename, String zbh, String zmc) { |
|||
DateTime dateTime = DateUtil.parse(day); |
|||
String dayStr = DateUtil.format(dateTime, "MM/dd") + "日"; |
|||
ShReportXmlctgb lj = new ShReportXmlctgb(day, createTime); |
|||
lj.setZbh(zbh); |
|||
lj.setZmc(zmc); |
|||
lj.setHbh(zbh + "04"); |
|||
lj.setHmc(dayStr); |
|||
DateTime beginOfDay = DateUtil.beginOfDay(dateTime); |
|||
DateTime endOfDay = DateUtil.endOfDay(dateTime); |
|||
long begin = beginOfDay.getTime() / 1000; |
|||
long end = endOfDay.getTime() / 1000; |
|||
fillReportItem(tablename, begin, end, lj); |
|||
return lj; |
|||
} |
|||
} |
|||
@ -0,0 +1,15 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Data |
|||
public class GroupCount { |
|||
|
|||
private String name; // "全部电站",
|
|||
private int group_id; // 0,
|
|||
private long count; // 9202,
|
|||
private long count2; // 9200
|
|||
private List<String> workflow_unique; // [],
|
|||
} |
|||
@ -0,0 +1,201 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Data |
|||
public class Homepage { |
|||
private HomepageNewOrder new_order; |
|||
private HomepageOrder order; |
|||
private HomepagePowers powers; |
|||
private List<HomepageOrderArea> order_area; |
|||
private List<HomepageUserData> user_data; |
|||
} |
|||
// {
|
|||
// "new_order": {
|
|||
// "count": 9,
|
|||
// "line": [
|
|||
// {
|
|||
// "time": "2024/03/14",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/15",
|
|||
// "count": 3
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/16",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/17",
|
|||
// "count": 0
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/18",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/19",
|
|||
// "count": 2
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/20",
|
|||
// "count": 1
|
|||
// }
|
|||
// ],
|
|||
// "rise_count": -71
|
|||
// },
|
|||
// "order": {
|
|||
// "count": 4897,
|
|||
// "rise_count": 0
|
|||
// },
|
|||
// "powers": {
|
|||
// "all": "344.97MW",
|
|||
// "now": "153.53MW"
|
|||
// },
|
|||
// "order_area": [
|
|||
// {
|
|||
// "name": "河北省",
|
|||
// "level": 0,
|
|||
// "parent_code": 0,
|
|||
// "area_id": 13336,
|
|||
// "count": 1536,
|
|||
// "all_power": 46388425,
|
|||
// "power": "46.39MW"
|
|||
// },
|
|||
// {
|
|||
// "name": "辽宁省",
|
|||
// "level": 0,
|
|||
// "parent_code": 0,
|
|||
// "area_id": 114983,
|
|||
// "count": 417,
|
|||
// "all_power": "14072075",
|
|||
// "power": "14.07MW"
|
|||
// },
|
|||
// {
|
|||
// "name": "江西省",
|
|||
// "level": 0,
|
|||
// "parent_code": 0,
|
|||
// "area_id": 257906,
|
|||
// "count": 153,
|
|||
// "all_power": 4889940,
|
|||
// "power": "4.89MW"
|
|||
// },
|
|||
// {
|
|||
// "name": "山东省",
|
|||
// "level": 0,
|
|||
// "parent_code": 0,
|
|||
// "area_id": 281410,
|
|||
// "count": 266,
|
|||
// "all_power": "10476360",
|
|||
// "power": "10.48MW"
|
|||
// },
|
|||
// {
|
|||
// "name": "河南省",
|
|||
// "level": 0,
|
|||
// "parent_code": 0,
|
|||
// "area_id": 360760,
|
|||
// "count": 1729,
|
|||
// "all_power": 74145200,
|
|||
// "power": "74.15MW"
|
|||
// },
|
|||
// {
|
|||
// "name": "海南省",
|
|||
// "level": 0,
|
|||
// "parent_code": 0,
|
|||
// "area_id": 523893,
|
|||
// "count": 1,
|
|||
// "all_power": "2608500",
|
|||
// "power": "2.61MW"
|
|||
// },
|
|||
// {
|
|||
// "name": "陕西省",
|
|||
// "level": 0,
|
|||
// "parent_code": 0,
|
|||
// "area_id": 639304,
|
|||
// "count": 34,
|
|||
// "all_power": 944810,
|
|||
// "power": "944.81KW"
|
|||
// }
|
|||
// ],
|
|||
// "user_data": [
|
|||
// {
|
|||
// "user_type": 1,
|
|||
// "count": 4597,
|
|||
// "rise": 0
|
|||
// },
|
|||
// {
|
|||
// "user_type": 2,
|
|||
// "count": 5484,
|
|||
// "rise": 0
|
|||
// }
|
|||
// ],
|
|||
// "user_line": {
|
|||
// "add_formal_user": 16,
|
|||
// "add_tmp_user": 7,
|
|||
// "tmp_line": [
|
|||
// {
|
|||
// "time": "2024/03/14",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/15",
|
|||
// "count": 2
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/16",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/17",
|
|||
// "count": 0
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/18",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/19",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/20",
|
|||
// "count": 1
|
|||
// }
|
|||
// ],
|
|||
// "formal_line": [
|
|||
// {
|
|||
// "time": "2024/03/14",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/15",
|
|||
// "count": 5
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/16",
|
|||
// "count": 3
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/17",
|
|||
// "count": 0
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/18",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/19",
|
|||
// "count": 1
|
|||
// },
|
|||
// {
|
|||
// "time": "2024/03/20",
|
|||
// "count": 5
|
|||
// }
|
|||
// ],
|
|||
// "rise_add_tmp_user": -72,
|
|||
// "rise_add_formal_user": -50
|
|||
// }
|
|||
// }
|
|||
@ -0,0 +1,9 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class HomepageLineItem { |
|||
private String time; // 2024/03/14
|
|||
private int count; // 1
|
|||
} |
|||
@ -0,0 +1,11 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Data |
|||
public class HomepageNewOrder { |
|||
private int count; |
|||
private List<HomepageLineItem> line; |
|||
} |
|||
@ -0,0 +1,10 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class HomepageOrder { |
|||
|
|||
private long count; //4897,
|
|||
private long rise_count; // 0
|
|||
} |
|||
@ -0,0 +1,29 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import cn.hutool.core.util.NumberUtil; |
|||
import cn.hutool.core.util.StrUtil; |
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class HomepageOrderArea { |
|||
private String name; // "河北省",
|
|||
private int level; // 0,
|
|||
private long parent_code; // 0,
|
|||
private int area_id; // 13336,
|
|||
private int count; // 1536,
|
|||
private long all_power; // 46388425,
|
|||
private String power; // "46.39MW"
|
|||
|
|||
public double getPowerNum() { |
|||
double ret = 0.0; |
|||
if (StrUtil.isNotBlank(power)) { |
|||
String mw = power.replace("MW", ""); |
|||
try { |
|||
ret = Double.parseDouble(mw); |
|||
} catch (Exception e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
return ret; |
|||
} |
|||
} |
|||
@ -0,0 +1,11 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import cn.hutool.core.util.StrUtil; |
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class HomepagePowers { |
|||
|
|||
private String all; // "344.97MW",
|
|||
private String now; // "153.53MW"
|
|||
} |
|||
@ -0,0 +1,10 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class HomepageUserData { |
|||
private int user_type; // 1,
|
|||
private int count; // 4597,
|
|||
private int rise; // 0
|
|||
} |
|||
@ -0,0 +1,15 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Data |
|||
public class HomepageUserLine { |
|||
private int add_formal_user; // 16,
|
|||
private int add_tmp_user; // 7,
|
|||
private List<HomepageLineItem> tmp_line; |
|||
private List<HomepageLineItem> formal_line; |
|||
private int rise_add_tmp_user; // 16,
|
|||
private int rise_add_formal_user; // 7,
|
|||
} |
|||
@ -0,0 +1,50 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class ScreenGetOrderList { |
|||
private String id; // 29,
|
|||
private String order_no; // 2021060667629040986641
|
|||
private String admin_id; // 58,
|
|||
private String customer_id; // 41,
|
|||
private String agent_id; // 11,
|
|||
private String product_id; // 8,
|
|||
private String create_time; // 1622946409,
|
|||
private String data_id; // 1,35
|
|||
private String workflow_unique; // 1_8_0_190_1
|
|||
private String prototype_id; // 1,
|
|||
private String remain_unique; //
|
|||
private String is_best; // 0,
|
|||
private String order_type; // 1,
|
|||
private String update_time; // 2024-03-05 10:59:46
|
|||
private String company_id; // 1,
|
|||
private String brand; // 山海智慧-古瑞瓦特
|
|||
private String inverter_sn_code; // HSJ0BF20EP
|
|||
private String generator_number; // 1300771010488
|
|||
private String username; // 徐金辉
|
|||
private String phone; // 131****6866
|
|||
private String component_number; // 89,
|
|||
private String component_power; // 450,
|
|||
private String address; // 河北省石家庄市行唐县玉亭乡八里庄村民心路5号
|
|||
private String area_id; // 15214,
|
|||
private String name; // @（行唐）河北晨航能源科技有限公司
|
|||
private String full_name; // 李**
|
|||
private String all_power; // 40.05
|
|||
private String city_name; // 河北省石家庄市行唐县
|
|||
private String create_time_text; // 2021-06-06 10:26:49
|
|||
private String order_type_text; // 户用
|
|||
private String status; // 0,
|
|||
private String status_text; // 等待
|
|||
private String first_time_text; // 2021-08-01 00:00:00
|
|||
private String total_day_power; // 0,
|
|||
private String total_month_power; // 0,
|
|||
private String total_year_power; // 6150.1,
|
|||
private String total_power; // 125715.3,
|
|||
private String pac; // 0,
|
|||
private String hour; // 0.0000
|
|||
private String day_money; // 0.00
|
|||
private String month_money; // 0.00
|
|||
private String total_money; // 49582.11
|
|||
private ScreenGetOrderListAreaAvg area_avg; |
|||
} |
|||
@ -0,0 +1,17 @@ |
|||
package com.yxt.supervise.gf.shanhai.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class ScreenGetOrderListAreaAvg { |
|||
|
|||
private String avgPowerDay; // 8.66
|
|||
private String avgPowerMonth; // 3561.15
|
|||
private String avgPowerYear; // 11417.79
|
|||
private String avgPowerTotal; // 134367.07
|
|||
private String avgHour; // 0.17
|
|||
private String avgCo2; // 66.98
|
|||
private String avgTree; // 8372.70
|
|||
private String avgAllPower; // 31.05
|
|||
private String avgComponentNumber; // 60
|
|||
} |
|||
@ -0,0 +1,41 @@ |
|||
package com.yxt.supervise.gf.util; |
|||
|
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
|
|||
import java.util.Date; |
|||
|
|||
public class ReportTool { |
|||
|
|||
public static String monthStr(String day) { |
|||
DateTime dateTime = DateUtil.parse(day); |
|||
return monthStr(dateTime); |
|||
} |
|||
|
|||
public static String monthStr(Date dateTime) { |
|||
int month = DateUtil.month(dateTime); |
|||
if (month == 0) |
|||
return "一月"; |
|||
if (month == 1) |
|||
return "二月"; |
|||
if (month == 2) |
|||
return "三月"; |
|||
if (month == 3) |
|||
return "四月"; |
|||
if (month == 4) |
|||
return "五月"; |
|||
if (month == 5) |
|||
return "六月"; |
|||
if (month == 6) |
|||
return "七月"; |
|||
if (month == 7) |
|||
return "八月"; |
|||
if (month == 8) |
|||
return "九月"; |
|||
if (month == 9) |
|||
return "十月"; |
|||
if (month == 10) |
|||
return "十一月"; |
|||
return "十二月"; |
|||
} |
|||
} |
|||
@ -0,0 +1,20 @@ |
|||
package demo.tool; |
|||
|
|||
import cn.hutool.core.date.DateTime; |
|||
import cn.hutool.core.date.DateUtil; |
|||
|
|||
import java.util.Date; |
|||
|
|||
public class ToolTests { |
|||
public static void main(String[] args) { |
|||
// long t = 1665973324L*1000;
|
|||
long t = Long.parseLong("1665973324000"); |
|||
System.out.println(System.currentTimeMillis()); //from_unixtime select from_unixtime(1252999488);
|
|||
// Date d = new Date(1252999488000L);
|
|||
Date d = new Date(t); |
|||
System.out.println(DateUtil.format(d, "yyyy-MM-dd HH:mm:ss")); |
|||
|
|||
DateTime parse = DateUtil.parse("2010-01-01 00:00:00"); |
|||
System.out.println("2010-01-01 00:00:00 === " + parse.getTime()); //1262275200000
|
|||
} |
|||
} |
|||
Loading…
Reference in new issue