新增合同结束时间

.idea/dataSources.xml

@@ -5,7 +5,7 @@
       <driver-ref>mysql.8</driver-ref>
       <synchronize>true</synchronize>
       <jdbc-driver>com.mysql.cj.jdbc.Driver</jdbc-driver>
-      <jdbc-url>jdbc:mysql://172.18.96.11:3306</jdbc-url>
+      <jdbc-url>jdbc:mysql://172.18.96.20:3306</jdbc-url>
       <jdbc-additional-properties>
         <property name="com.intellij.clouds.kubernetes.db.host.port" />
         <property name="com.intellij.clouds.kubernetes.db.enabled" value="false" />

.idea/sqldialects.xml

@@ -8,6 +8,7 @@
     <file url="file://$PROJECT_DIR$/dw/dim/dim_engine_equipment_d.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/dw/dim/dim_parking_info_d.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/dw/dim/dim_project_base_info_d.sql" dialect="MySQL" />
+    <file url="file://$PROJECT_DIR$/dw/dim/dim_room_d.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/dw/dwd/dwd_business_contract_info_d.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/dw/dwd/dwd_engine_equipment_inspection_task_d.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/dw/dwd/dwd_engine_equipment_status_d.sql" dialect="MySQL" />
@@ -25,6 +26,7 @@
     <file url="file://$PROJECT_DIR$/dw/dws/dws_innoveco_new_retail_m.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/dw/dws/dws_law_not_tran_payment_m.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/dw/dws/dws_law_tran_coll_d.sql" dialect="MySQL" />
+    <file url="file://$PROJECT_DIR$/dw/dws/dws_operation_subcompany_plan_level_d.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/dw/ods/ods_cost_budget_data_d.sql" dialect="Oracle" />
     <file url="file://$PROJECT_DIR$/finereport/kanban/mobile/创新生态_mobile.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/finereport/kanban/mobile/物业_mobile.sql" dialect="MySQL" />
@@ -37,6 +39,7 @@
     <file url="file://$PROJECT_DIR$/finereport/tianbao/6_innovation/多经四大业务指标完成情况填报表.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/finereport/tianbao/EARLY_WARNING/看板数据预警-项目维度.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/finereport/xiazuan/2_operation/住服比异常项目.sql" dialect="MySQL" />
+    <file url="file://$PROJECT_DIR$/finereport/xiazuan/2_operation/未完成计划明细.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/finereport/xiazuan/2_operation/计划到期明细.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/finereport/xiazuan/2_operation/项目明细弹窗.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/finereport/xiazuan/3_property/2_报事情况报表.sql" dialect="MySQL" />
@@ -47,6 +50,10 @@
     <file url="file://$PROJECT_DIR$/finereport/xiazuan/6_innovation/7_空间运营出租率明细.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/finereport/xiazuan/6_innovation/9_多径回款情况.sql" dialect="MySQL" />
     <file url="file://$PROJECT_DIR$/finereport/xiazuan/6_innovation/新零售订单明细.sql" dialect="MySQL" />
+    <file url="file://$PROJECT_DIR$/finereport/xiazuan/权责亏损项目明细.sql" dialect="MySQL" />
+    <file url="file://$PROJECT_DIR$/finereport/问题修复/计划到期明细组织架构为空.sql" dialect="MySQL" />
+    <file url="file://$PROJECT_DIR$/finereport/预警/片区预警数据.sql" dialect="MySQL" />
+    <file url="file://$PROJECT_DIR$/finereport/预警/项目预警数据.sql" dialect="MySQL" />
     <file url="PROJECT" dialect="MySQL" />
   </component>
 </project>

dw/dim/dim_project_base_info_d.sql

@@ -2,6 +2,8 @@
 -- 修改人： 杨坤安
 -- 修改日期: 2024-09-06
 -- 修改内容： 一个项目接管面积会有多个，先累加再关联
+-- 修改日期: 2024-09-24
+-- 修改内容: 项目对应业态取值规则变更
 -- *****************************
 select
     b.CommId
@@ -57,6 +59,7 @@ select
      , a.CityLevel
      , a.CommitteeTermStartDate
      , a.CommitteeTermEndDate
+     , b.DictionaryName AS StateNameNew
 from (
          select
              c.CommId
@@ -117,5 +120,26 @@ from (
                              on a.ParentId = c.id
          group by 1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26,27,28,29,30,31,32,33
      ) a
-         right join (select * from ods_erp_tb_hspr_community_d where IsDelete = 0) b
+    right join
+    (
+        SELECT
+        b1.*
+        ,b2.DictionaryName
+        FROM
+        (
+            select
+                *
+            from ods_erp_tb_hspr_community_d
+            where IsDelete = 0
+        )b1
+        LEFT JOIN
+        (-- add 2024-09-24  项目业态新规则取数
+            select
+                DictionaryCode -- 项目业态编码
+                 ,DictionaryName -- 项目业态名称
+            from ods_erp_tb_dictionary_projectformat_d
+        )b2
+        ON B1.CommKind = b2.DictionaryCode
+
+    ) b
     on a.CommId = b.CommId

dw/dws/dws_operation_subcompany_plan_level_d.sql

@@ -1,5 +1,5 @@
 select
-    left(a.start_date,7) ym
+    left(a.end_date,7) ym
      , b.subcompanyid1 subcompanyid
      , c.subcompanyname
      , c.supsubcomid
@@ -7,7 +7,7 @@ select
      , count(*) plan_num
      , count(plan_name) plan_adjust_num
      , sum(case when plan_status = 2 then 1 else 0 end) plan_cancel_num
-     , sum(case when plan_status = 6 then 1 else 0 end) plan_exempt_assess_num
+     , sum(case when plan_status = 7 then 1 else 0 end) plan_exempt_assess_num
      , sum(case when plan_status = 4 then 1 else 0 end) plan_incomplete_num
      , sum(case when left(start_date,7) = left(input_date,7) then 1 else 0 end) plan_thism_num
      , sum(case when plan_status = 0 then 1 else 0 end) plan_in_progress_num
@@ -33,8 +33,9 @@ from (
                     on b.subcompanyid1 = c.id
          left join (select distinct plan_name from dwd_operations_plan_adjust_info_d) d
                    on a.id = d.plan_name
+WHERE left(a.end_date,7) = '2024-09'
 group by
-    left(a.start_date,7)
+    left(a.end_date,7)
        , b.subcompanyid1
        , c.subcompanyname
        , c.supsubcomid

finereport/xiazuan/1_finance/1_收缴下钻.sql

@@ -8,58 +8,76 @@ FROM dim_organ_mapping
 WHERE 1=1
     ${IF(LEN(p_area)>0," AND organ_code IN ('"+JOINARRAY(p_area,"','")+"')", "")}
 
-
 -- dic_片区
 
 
 SELECT DISTINCT
     organ_code AS 片区id,
     organ_name AS 片区名称
-FROM dim_organ_mapping
-
+FROM dws_finance_fees_serial_m
+where 1=1 and organ_code is not null
+  and organ_name not in ('东湖商管','领悦总部','演示机构')
+    ${if(GETUSERDEPARTMENTS(2)="领悦集团总部","","and organ_name = '"+GETUSERDEPARTMENTS(2)+"'")}
 
 -- dict_费用类型
 
-select distinct ParentCostCode, ParentCostName
+select distinct ParentCostCode, case when ParentCostCode = '0008' then '代收代缴水电费' else ParentCostName end ParentCostName
 from dws_finance_fees_serial_m
+where ParentCostCode in ('0001','0007','0008')
 order by ParentCostCode asc
 
 
+
+-- report_多经收缴情况
+SELECT
+    ${if(len(p_area) == 0,"organ_code code, organ_name name,","comm_id code, comm_name name,")}
+        `year_month`, index_type, index_receivable, index_receipts, index_not_receipts, collection_rate, update_user, update_time
+FROM ods_caiwu_profit
+where 1=1
+-- ${if(len(p_area) == 0,"","and organ_code = '" + p_area+ "'")}
+    ${IF(LEN(p_area)>0," AND organ_code IN ('"+JOINARRAY(p_area,"','")+"')", "")}
+      ${if(len(p_startdate) == 0,"","and `year_month` = '" + replace(p_startdate,"-","") + "'")}
+      ${if(left(fine_role,2)=="项目","and comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
+
+
+
 -- report_收缴率
 
 
-select
+select * from (
+                  select
                       ${if(len(p_area) == 0,"a.organ_code code, a.organ_name name,","a.comm_id code, a.comm_name name,")}
                       a.ym, ParentCostCode, ParentCostName
-     , (pr_paid_cu_amt + cu_paid_cu_amt + pr_exempt_cu_amt + cu_exempt_cu_amt)/10000 cu_paid_amt
-     , (cu_receivable_amt + pr_exempt_cu_amt + cu_exempt_cu_amt)/10000 cu_receivable_amt
-     , (- cu_paid_pr_amt + cu_offset_pr_amt)/10000 pr_paid_amt
-     , (pr_total_receivable_amt + pr_total_received_amt + cu_early_exempt_pr_amt + cu_exempt_pr_amt)/10000 pr_receivable_amt
+                       , (ifnull(pr_paid_cu_amt,0) + ifnull(cu_paid_cu_amt,0) - ifnull(pr_offset_cu_amt,0) - ifnull(cu_offset_cu_amt,0))/10000 cu_paid_amt
+                       , (ifnull(cu_receivable_amt,0) + ifnull(pr_exempt_cu_amt,0) + ifnull(cu_exempt_cu_amt,0))/10000 cu_receivable_amt
+                       , (- ifnull(cu_paid_pr_amt,0) - ifnull(cu_offset_pr_amt,0))/10000 pr_paid_amt
+                       , (ifnull(pr_total_receivable_amt,0) + ifnull(pr_total_received_amt,0) + ifnull(cu_early_exempt_pr_amt,0) + ifnull(cu_exempt_pr_amt,0))/10000 pr_receivable_amt
                        , case when a.ParentCostCode = '0001' then b.index_dq_target else 0 end cu_coll_rate_target
                        , case when a.ParentCostCode = '0001' then b.index_wq_target else 0 end pr_coll_rate_target
                        , case when a.ParentCostCode = '0008' then b.index_sd_target
                               when a.ParentCostCode = '0007' then b.index_dj_target else 0 end total_coll_rate_target
-from dws_finance_fees_serial_m a
+                  from dws_finance_fees_serial_m a
                            left join ods_finance_collection_target_area b
                                      on a.organ_code = b.organ_code and a.ym = b.ym
                            left join ods_finance_collection_target_project c
                                      on a.comm_id = c.comm_id and a.ym = c.ym
-where 1=1
+                  where 1=1 and a.organ_code is not null
+                    and a.organ_name not in ('东湖商管','领悦总部','演示机构') and a.comm_name not like '%天富%'
                       ${if(len(p_startdate) == 0,"","and a.ym = '" + p_startdate + "'")}
                       ${if(len(p_feestype) == 0,"","and a.ParentCostCode = '" + p_feestype+ "'")}
-      ${if(len(p_area) == 0,"","and a.organ_code = '" + p_area+ "'")}
-;
-
+                      -- ${if(len(p_area) == 0,"","and a.organ_code = '" + p_area+ "'")}
+                      ${IF(LEN(p_area)>0," AND a.organ_code IN ('"+JOINARRAY(p_area,"','")+"')", "")}
+                      ${if(left(fine_role,2)=="项目","and a.comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
+              ) a where not (cu_paid_amt=0 and cu_receivable_amt=0 and pr_paid_amt=0 and pr_receivable_amt = 0)
 
 -- report_收缴率目标
 
-
 select
     organ_code code
      , organ_name name
      , ym
-     , index_dq_target
-     , index_wq_target
+     , ${IF(p_feestype = '0001',"index_dq_target",IF(p_feestype = "0007","''","''"))} AS index_dq_target
+     , ${IF(p_feestype = '0001',"index_wq_target",IF(p_feestype = "0007","''","''"))} AS index_wq_target
      , index_sd_target
      , index_dj_target
      , index_ac_target_dq
@@ -73,8 +91,8 @@ select
     comm_id code
      , comm_name name
      , ym
-     , index_dq_target
-     , index_wq_target
+     , ${IF(p_feestype = '0001',"index_dq_target",IF(p_feestype = "0007","''","''"))} AS index_dq_target
+     , ${IF(p_feestype = '0001',"index_wq_target",IF(p_feestype = "0007","''","''"))} AS index_wq_target
      , index_sd_target
      , index_dj_target
      , index_ac_target_dq
@@ -83,21 +101,56 @@ select
 from ods_finance_collection_target_project
 where 1=1
     ${if(len(p_startdate) == 0,"","and ym = '" + p_startdate + "'")}
+      ${if(left(fine_role,2)=="项目","and comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
+
+--    report_物业费收缴总目标
+
+select organ_code, ym, index_dq_target, index_wq_target from ods_finance_collection_target_area where organ_code = '5501'
+    ${if(left(fine_role,2)=="项目","and comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
 
 
 -- report_中科目收缴率
 
 select
+    CostName
+     , sum((ifnull(cu_receivable_amt,0) - ifnull(cu_paid_amt,0)) + (ifnull(pr_receivable_amt,0) - ifnull(pr_paid_amt,0))) owed_amt
+from (
+         select
              b.organ_code, b.organ_name, b.comm_id, b.comm_name, ym
                                                                                                                                                             ${if(len(p_feestype) == 0,", ParentCostCode CostCode, ParentCostName CostName",", MiddleCostCode CostCode, MiddleCostName CostName")}
-     , (pr_paid_cu_amt + cu_paid_cu_amt + pr_exempt_cu_amt + cu_exempt_cu_amt)/10000 cu_paid_amt
-     , (cu_receivable_amt + pr_exempt_cu_amt + cu_exempt_cu_amt)/10000 cu_receivable_amt
-     , (- cu_paid_pr_amt + cu_offset_pr_amt)/10000 pr_paid_amt
-     , (pr_total_receivable_amt + pr_total_received_amt + cu_early_exempt_pr_amt + cu_exempt_pr_amt)/10000 pr_receivable_amt
-from dwd_finance_fees_serial_d a
-         inner join (select distinct organ_code, organ_name, comm_id, comm_name from dim_organ_mapping where comm_id is not null) b
+              , (ifnull(pr_paid_cu_amt,0) + ifnull(cu_paid_cu_amt,0) - ifnull(pr_offset_cu_amt,0) - ifnull(cu_offset_cu_amt,0))/10000 cu_paid_amt
+              , (ifnull(cu_receivable_amt,0) + ifnull(pr_exempt_cu_amt,0) + ifnull(cu_exempt_cu_amt,0))/10000 cu_receivable_amt
+              , (- ifnull(cu_paid_pr_amt,0) - ifnull(cu_offset_pr_amt,0))/10000 pr_paid_amt
+              , (ifnull(pr_total_receivable_amt,0) + ifnull(pr_total_received_amt,0) + ifnull(cu_early_exempt_pr_amt,0) + ifnull(cu_exempt_pr_amt,0))/10000 pr_receivable_amt
+         from dwd_finance_fees_serial_d a
+                  left join(
+             select a.CommID comm_id, a.CommName comm_name, b.OrganCode organ_code, b.OrganName organ_name from ods_erp_tb_hspr_community_d a
+                                                                                                                    left join (
+                 select * from ods_erp_tb_sys_organ_d
+                 where length(OrganCode) = 4
+             ) b
+                                                                                                                              on left(a.OrganCode,4) = b.OrganCode
+         ) b
                            on a.commid = b.comm_id
-where 1=1
+         where 1=1
+           and ((a.ParentCostCode = '0008' and a.MiddleCostCode in ('00080001','00080002','00080003','00080004','00080005','00080006','00080007','00080008','00080017','00080018','00080019','00080022','00080023','00080024','00080027','00080028','00080032','00080035')) or a.ParentCostCode = '0001')
+           and a.organ_name not in ('东湖商管','领悦总部','演示机构') and a.comm_name not like '%天富%'
              ${if(len(p_startdate) == 0,"","and ym = '" + p_startdate + "'")}
              ${if(len(p_feestype) == 0,"","and ParentCostCode = '" + p_feestype+ "'")}
-      ${if(len(p_area) == 0,"","and b.organ_code = '" + p_area+ "'")}
+             -- ${if(len(p_area) == 0,"","and b.organ_code = '" + p_area+ "'")}
+             ${IF(LEN(p_area)>0," AND b.organ_code IN ('"+JOINARRAY(p_area,"','")+"')", "")}
+             ${if(left(fine_role,2)=="项目","and a.comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
+     ) a
+where not (cu_paid_amt=0 and cu_receivable_amt=0 and pr_paid_amt=0 and pr_receivable_amt = 0)
+group by CostName
+union all
+SELECT
+    index_type, sum(index_not_receipts)
+FROM ods_caiwu_profit
+where 1=1
+-- ${if(len(p_area) == 0,"","and organ_code = '" + p_area+ "'")}
+    ${IF(LEN(p_area)>0," AND organ_code IN ('"+JOINARRAY(p_area,"','")+"')", "")}
+      ${if(len(p_startdate) == 0,"","and `year_month` = '" + replace(p_startdate,"-","") + "'")}
+      ${if(left(fine_role,2)=="项目","and comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
+group by index_type
+order by owed_amt desc

finereport/xiazuan/2_operation/未完成计划明细.sql

@@ -0,0 +1,105 @@
+-- *****************************
+-- 创建人员: 杨坤安
+-- 创建时间:
+-- 功能描述: 未完成计划明细
+-- *****************************
+
+with one_to_many AS(
+    SELECT
+        a.username AS username -- 用户名
+         ,SUBSTRING_INDEX(SUBSTRING_INDEX(a.mang_project, ',',b.help_topic_id + 1),',',-1) AS mang_project -- 管理项目名
+    FROM ods_one_to_many_perm a
+             JOIN mysql.help_topic b
+                  on b.help_topic_id < (LENGTH(a.mang_project) - length(replace(a.mang_project,',','')) + 1)
+    WHERE a.username  = '${fine_username}'
+)
+select
+    ${if(len(p_area) == 0,"c.organ_name","c.comm_name")} as p_area
+     ,c.oa_comm_id                   as oa_comm_id       -- oa项目id
+     ,c.oa_comm_name                 as oa_comm_name     -- oa项目名称
+     ,c.oa_organ_code                as oa_organ_code    -- oa片区id
+     ,c.oa_organ_name                as oa_organ_name    -- oa片区名称
+     ,c.organ_code                   as organ_code       -- erp片区编码
+     ,c.organ_name                   as organ_name       -- erp片区名称
+     ,c.comm_id                      as comm_id          -- erp项目id
+     ,c.comm_name                    as comm_name        -- erp项目名称
+     ,b.subcompanyid1 				 as subcompanyid1 	 -- 公司id
+     ,a.plan_name 					 as plan_name		 -- 计划名称
+     ,a.eval_criteria				 as plan_desc        -- 计划内容
+     ,a.plan_level					 as plan_level		 -- 计划等级
+     ,left(a.start_date,7) 			 as ym 				 -- 计划开始年月
+     ,a.start_dt    				 as start_dt		 -- 计划开始时
+     ,a.end_date					 as end_date		 -- 计划结束时间
+     ,a.finish_date                  as finish_date      -- 计划完成时间
+     ,a.input_date                   as input_date       -- 计划录入时间
+     ,a.day_diff                     as day_diff         -- 距离计划结束天数
+     ,a.responsible_person1			 as responsible_person1 		-- 责任人编码
+     ,b.lastname 					 as executor_name    -- 责任人名称
+     ,d.lastname                     AS lastname        -- 执行人
+     ,left(a.end_ym,7)               as end_ym           -- 计划结束年月
+from
+    (
+        SELECT
+            concat(left(trim(start_date),5),lpad(substring_index(substring_index(trim(start_date),'-',2),'-',-1),2,0),right(trim(start_date),3)) as start_date
+             ,a.start_date    as start_dt   -- 计划开始时间
+             ,a.plan_level    	-- 计划等级
+             ,jt.responsible_person1   		-- 责任人
+             ,a.plan_status		-- 计划状态
+             ,a.input_date   	-- 录入时间
+             ,a.end_date	  		-- 计划结束时间
+             ,a.plan_name   		-- 计划名称
+             ,concat(left(trim(end_date),5),lpad(substring_index(substring_index(trim(end_date),'-',2),'-',-1),2,0),right(trim(end_date),3)) as end_ym
+             ,a.finish_date      -- 完成时间
+             ,TO_DAYS(a.end_date) - TO_DAYS(curdate()) AS day_diff
+             ,a.eval_criteria		-- 评价标准
+             ,a.executor  -- 执行人
+        FROM dw.dwd_operations_plan_info_d a,
+             JSON_TABLE (
+                     cast( CONCAT( '["', REPLACE ( responsible_person1, ',', '","' ), '"]' ) AS json ),
+                     "$[*]" COLUMNS ( responsible_person1 INT PATH "$" )
+             ) AS jt
+        WHERE a.plan_status = '4'
+    )a
+        left join
+    (
+        select
+            id
+             ,subcompanyid1		-- 公司id
+             ,lastname			-- 执行人
+        from dw.ods_oa_hrmresource_d
+
+    )b
+    on a.responsible_person1 = b.id
+        left join
+    (
+        select
+            distinct
+            organ_code -- erp片区id
+                   ,organ_name -- erp片区名称
+                   ,comm_id    -- erp项目id
+                   ,comm_name  -- erp项目名称
+                   ,oa_organ_code  -- oa片区id
+                   ,oa_organ_name  -- oa片区名称
+                   ,oa_comm_id     -- oa项目id
+                   ,oa_comm_name   -- oa项目名称
+        from dim_organ_mapping -- 组织结构映射维度表
+        -- where comm_id is not null
+    )c
+    on b.subcompanyid1 = c.oa_comm_id
+        left join
+    (
+        select
+            id
+             ,subcompanyid1		-- 公司id
+             ,lastname			-- 执行人
+        from dw.ods_oa_hrmresource_d
+
+    )d
+    on a.executor = d.id
+where 1 = 1
+    ${if(len(p_startdate) == 0,"","and left(a.end_ym,7) = '" + p_startdate + "'")}
+    ${IF(LEN(p_area)!=0," and organ_code IN ('"+p_area+"')","")}
+-- ${if(left(fine_role,2)=="项目","and comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
+  AND CASE WHEN (SELECT mang_project FROM ods_one_to_many_perm WHERE username  = '${fine_username}' AND mang_organ IS NULL) IS NOT NULL
+    THEN comm_name IN (SELECT mang_project FROM one_to_many WHERE username  = '${fine_username}')
+    ELSE ${if(left(fine_role,2)=="项目","comm_name = '"+GETUSERDEPARTMENTS(3)+"'","1=1")} END

finereport/xiazuan/2_operation/计划到期明细.sql

@@ -5,7 +5,18 @@
 -- 目   录: xianzuan>2_运营>计划到期明细.fvs
 -- ****************************************
 
+
+
 -- 【数据集: report_计划到期】
+with one_to_many AS(
+    SELECT
+        a.username AS username -- 用户名
+         ,SUBSTRING_INDEX(SUBSTRING_INDEX(a.mang_project, ',',b.help_topic_id + 1),',',-1) AS mang_project -- 管理项目名
+    FROM ods_one_to_many_perm a
+             JOIN mysql.help_topic b
+                  on b.help_topic_id < (LENGTH(a.mang_project) - length(replace(a.mang_project,',','')) + 1)
+    WHERE a.username  = '${fine_username}'
+)
 select
     ${if(len(p_area) == 0,"c.organ_name","c.comm_name")} as p_area
      ,c.oa_comm_id                   as oa_comm_id       -- oa项目id
@@ -28,6 +39,7 @@ select
      ,a.day_diff                     as day_diff         -- 距离计划结束天数
      ,a.responsible_person1			 as responsible_person1 		-- 责任人编码
      ,b.lastname 					 as executor_name    -- 责任人名称
+     ,d.lastname                     AS lastname        -- 执行人
      ,left(a.end_ym,7)               as end_ym           -- 计划结束年月
 from
     (
@@ -44,6 +56,7 @@ from
              ,a.finish_date      -- 完成时间
              ,TO_DAYS(a.end_date) - TO_DAYS(curdate()) AS day_diff
              ,a.eval_criteria		-- 评价标准
+             ,a.executor  -- 执行人
         FROM dw.dwd_operations_plan_info_d a,
              JSON_TABLE (
                      cast( CONCAT( '["', REPLACE ( responsible_person1, ',', '","' ), '"]' ) AS json ),
@@ -77,12 +90,26 @@ from
                    ,oa_comm_id     -- oa项目id
                    ,oa_comm_name   -- oa项目名称
         from dim_organ_mapping -- 组织结构映射维度表
-        where comm_id is not null
+        -- where comm_id is not null
     )c
     on b.subcompanyid1 = c.oa_comm_id
-    where 1 = 1
+    left join
+    (
+        select
+            id
+             ,subcompanyid1		-- 公司id
+             ,lastname			-- 执行人
+        from dw.ods_oa_hrmresource_d
+
+    )d
+    on a.executor = d.id
+where 1 = 1
     ${if(len(p_startdate) == 0,"","and left(a.end_ym,7) = '" + p_startdate + "'")}
     ${IF(LEN(p_area)!=0," and organ_code IN ('"+p_area+"')","")}
+-- ${if(left(fine_role,2)=="项目","and comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
+  AND CASE WHEN (SELECT mang_project FROM ods_one_to_many_perm WHERE username  = '${fine_username}' AND mang_organ IS NULL) IS NOT NULL
+    THEN comm_name IN (SELECT mang_project FROM one_to_many WHERE username  = '${fine_username}')
+    ELSE ${if(left(fine_role,2)=="项目","comm_name = '"+GETUSERDEPARTMENTS(3)+"'","1=1")} END
 
 
 

finereport/xiazuan/2_operation/项目明细弹窗.sql

@@ -31,7 +31,7 @@ SELECT
     ,A.UndergroundArea                      AS undergroundarea  -- 地下面积
     ,A.ContractArea                         AS contractarea     -- 合约面积
     ,A.TakeOverArea                         AS takeoverarea     -- 在管面积
-    ,E.CalcArea                             AS CalcArea         -- 收费面积
+    ,C.CalcArea                             AS CalcArea         -- 收费面积
     ,A.GreenArea                            AS greenarea        -- 绿化面积
     ,C.room_num                             AS room_num         -- 总户数
     ,C.delivered_num                        AS delivered_num    -- 已交付户数
@@ -123,19 +123,43 @@ ON A.CommId = B.comm_id
 LEFT JOIN
 (
         SELECT
-            CommID
-            ,SUM(CASE WHEN roomstate <> 0 THEN 1 ELSE 0 END) AS room_num -- 项目对应房间数量
-            ,SUM(CASE WHEN roomstate IN ( '1', '4', '9', '10', '5', '6' ) THEN buildarea ELSE 0 END ) AS sold_area -- 已售面积
-            ,SUM(CASE WHEN roomstate = '2' THEN buildarea ELSE 0 END ) AS unsold_area -- 未售面积
-            ,SUM(CASE WHEN roomstate NOT IN('0','2')  THEN 1 ELSE 0 END ) AS delivered_num -- 已交付户数
-            ,SUM(CASE WHEN roomstate IN ( '4', '9', '10', '5', '6' ) THEN 1 ELSE 0 END ) AS  rece_num -- 已接房数
-            ,SUM(CASE WHEN roomstate = '4' THEN 1 ELSE 0 END ) AS fit_num -- 正在装修户数
-            ,SUM(CASE WHEN roomstate IN ( '9', '10', '5', '6' ) THEN 1 ELSE 0 END ) AS done_fit_num -- 已完成装修户数
-            ,SUM(CASE WHEN roomstate = '5' THEN 1 ELSE 0 END ) AS done_fit_no --  已完成装修未入住
-            ,SUM(CASE WHEN roomstate IN ( '9', '10', '6' ) THEN 1 ELSE 0 END ) AS done_fit_yes -- 已完成装修已入住
-        FROM dw.dim_room_d a
-        -- 排除掉房间表里房屋状态是未删除而在费用表里是删除的房子
-        WHERE exists(SELECT 1 FROM dim_bind_cost_stan_detail_d B WHERE a.CommID = b.CommID AND A.RoomID = b.RoomID)
+            a.CommID AS CommID
+            ,SUM(CASE WHEN a.roomstate <> 0 THEN 1 ELSE 0 END) AS room_num -- 项目对应房间数量
+            ,SUM(CASE WHEN a.roomstate IN ( '1', '4', '9', '10', '5', '6' ) THEN a.buildarea ELSE 0 END ) AS sold_area -- 已售面积
+            ,SUM(CASE WHEN a.roomstate = '2' THEN a.buildarea ELSE 0 END ) AS unsold_area -- 未售面积
+            ,SUM(CASE WHEN a.roomstate NOT IN('0','2')  THEN 1 ELSE 0 END ) AS delivered_num -- 已交付户数
+            ,SUM(CASE WHEN a.roomstate IN ( '4', '9', '10', '5', '6' ) THEN 1 ELSE 0 END ) AS  rece_num -- 已接房数
+            ,SUM(CASE WHEN a.roomstate = '4' THEN 1 ELSE 0 END ) AS fit_num -- 正在装修户数
+            ,SUM(CASE WHEN a.roomstate IN ( '9', '10', '5', '6' ) THEN 1 ELSE 0 END ) AS done_fit_num -- 已完成装修户数
+            ,SUM(CASE WHEN a.roomstate = '5' THEN 1 ELSE 0 END ) AS done_fit_no --  已完成装修未入住
+            ,SUM(CASE WHEN a.roomstate IN ( '9', '10', '6' ) THEN 1 ELSE 0 END ) AS done_fit_yes -- 已完成装修已入住
+            ,SUM(b.CalcArea) AS CalcArea
+            FROM
+            (
+                SELECT
+                *
+                FROM  dw.dim_room_d
+            )a
+            LEFT JOIN
+            (
+                SELECT
+                b1.CommId AS CommId
+                ,b1.RoomID AS RoomID
+                ,SUM(CalcArea) AS  CalcArea
+                FROM
+                (
+                    SELECT
+                    CommId
+                    , CalcArea
+                    , RoomID
+                    FROM ods_erp_tb_hspr_coststansetting_d
+                    WHERE RoomID <> '0'
+                    GROUP BY CommId, CalcArea, RoomID
+                )b1
+                GROUP BY  b1.CommId,b1.RoomID
+            )b
+            ON a.CommID = b.CommId
+            AND a.RoomID = b.RoomID
             GROUP BY CommID
 )C
     ON A.CommId = C.CommID
@@ -152,38 +176,6 @@ LEFT JOIN
     )D
     ON A.COMMID = D.COMMID
     LEFT JOIN
-    (
-        SELECT
-            A.CommId AS CommId
-             ,SUM(A.CalcArea ) AS CalcArea
-        FROM
-        (
-                SELECT
-                    CommId
-                     ,CalcArea
-                     ,RoomID
-                FROM dim_bind_cost_stan_detail_d
-                WHERE RoomID <> 0
-                GROUP BY
-                    CommId
-                       ,CalcArea
-                       ,RoomID
-        )A
-        JOIN
-        (-- 排除掉费用表里房屋状态是未删除而在房间表里是删除的房子
-            SELECT
-            CommID
-            ,RoomID
-            FROM dw.dim_room_d
-            GROUP BY CommID,RoomID
-        )B
-        ON A.RoomID = B.RoomID
-        AND a.CommID = B.CommID
-        GROUP BY
-        A.CommId
-    )E
-    ON A.COMMID = E.COMMID
-    LEFT JOIN
     (
         SELECT
             A.CommId
@@ -430,3 +422,291 @@ AND CASE WHEN'${fine_username}' = 'WangXiaoLi0726'
     WHEN'${fine_username}' = 'WangJing'
     THEN comm_name IN('【乐山】澜山悦','【乐山】领地蘭台府')
     ELSE ${if(left(fine_role,2)=="项目","comm_name = '"+GETUSERDEPARTMENTS(3)+"'","1=1")}
+
+
+-- ======================================
+-- 数据集逻辑
+-- ======================================
+
+
+-- ****************************************
+-- 创建人员: 杨坤安
+-- 创建日期: 2024-07-22
+-- 功   能: 帆软明细报表-项目明细弹窗
+-- 目   录: xianzuan>2_运营>项目明细弹窗.fvs
+-- ****************************************
+with one_to_many AS(
+    SELECT
+    a.username AS username -- 用户名
+        ,SUBSTRING_INDEX(SUBSTRING_INDEX(a.mang_project, ',',b.help_topic_id + 1),',',-1) AS mang_project -- 管理项目名
+    FROM ods_one_to_many_perm a
+    JOIN mysql.help_topic b
+    on b.help_topic_id < (LENGTH(a.mang_project) - length(replace(a.mang_project,',','')) + 1)
+    WHERE a.username  = '${fine_username}'
+    )
+SELECT
+    A.ManageKindName , -- 管理性质名称 【项目归属】
+    A.Province,-- 省
+    A.City,-- 市
+    A.Citylevel,-- 城市级别
+    A.ManageStage,-- 项目状态
+    A.TakeOverTime,-- 交付时间
+    A.CommFrom,-- 项目来源
+    A.DevSubject,-- 项目开发商名称
+    A.CommAddress,-- 项目地址
+    CASE
+        WHEN ProjectFloorPlan IS NULL
+            OR JSON_EXTRACT( JSON_EXTRACT( cast( A.ProjectFloorPlan AS JSON ), '$[0]' ), '$.FileName' ) IS NULL THEN'否'
+        WHEN JSON_EXTRACT( JSON_EXTRACT( cast( A.ProjectFloorPlan AS JSON ), '$[0]' ), '$.FileName' ) IS NOT NULL THEN'是'
+        END AS IS_UPLOAD,-- 是否有上传项目平面图 -- 项目平面图
+    ( A.FloorArea + A.UndergroundArea ) AS TotalArea,-- 建筑总面积
+    A.FloorArea,-- 地上面积
+    A.UndergroundArea,-- 地下面积
+    A.GreenArea,-- 绿化面积
+    A.ContractTerm,
+    A.PropertyMgrEntrustType,
+    CASE
+        WHEN A.IsContractFiled = '1' THEN'是' ELSE '否'
+        END AS 是否办理合同备案,
+    A.ProjectDeliverySituation,
+    D.UnsoldParkingCount,
+    IF( A.PedEntrExitsCount = 0 OR PedEntrExitsCount IS NULL, '-', PedEntrExitsCount ) AS PedEntrExitsCount,
+    IF( A.CarEntrExitsCount = 0 OR CarEntrExitsCount IS NULL, '-', CarEntrExitsCount ) AS CarEntrExitsCount,
+    IF( A.MixedEntrExitsCount = 0 OR MixedEntrExitsCount IS NULL, '-', MixedEntrExitsCount ) AS MixedEntrExitsCount,
+    IF( A.GuardedEntrExitsCount = 0 OR GuardedEntrExitsCount IS NULL, '-', GuardedEntrExitsCount ) AS GuardedEntrExitsCount,
+    IF( A.MonitoringRoomCount = 0 OR MonitoringRoomCount IS NULL, '-', MonitoringRoomCount ) AS MonitoringRoomCount,
+
+    -- TotalEntrExitsCount = PedEntrExitsCount + CarEntrExitsCount +MixedEntrExitsCount
+    IF( A.PedEntrExitsCount = 0 OR PedEntrExitsCount IS NULL, '-', PedEntrExitsCount )
+        +  IF( A.CarEntrExitsCount = 0 OR CarEntrExitsCount IS NULL, '-', CarEntrExitsCount )
+        +  IF( A.MixedEntrExitsCount = 0 OR MixedEntrExitsCount IS NULL, '-', MixedEntrExitsCount ) AS TotalEntrExitsCount,
+
+    A.IsMonRoomMergedToGate,
+    A.ContractArea,-- 合同面积 【建筑面积】
+    A.TakeOverArea,-- 接管面积 【合约面积】
+    A.ManageContractArea ManageContractArea,-- 管理口径合同面积  【在管面积】
+    A.StateNameNew AS StateName,-- 业态  【项目业态】
+    A.ContractName,-- 合同类型
+    A.GetMethod,-- 项目获取渠道
+    A.ContractPartyName,-- 合同对方名称
+    CASE
+        WHEN A.IsSetCommittee = '1' THEN'是' ELSE '否'
+        END AS 是否成立委员会,-- 是否已成立业主委员会
+    A.CommitteeTime,-- 业委会成立时间
+    A.ChargeMode,
+    CASE WHEN A.IsSetCommittee = '1' THEN CONCAT(DATE_FORMAT(A.CommitteeTermStartDate, '%Y-%m-%d' ) , ' 至 ',DATE_FORMAT(A.CommitteeTermEndDate, '%Y-%m-%d' ))
+         ELSE NULL END
+        AS 任职天数,-- 任职时间
+    C.room_num AS room_num,-- 总户数
+    B.organ_name AS organ_name,-- erp片区名称
+    B.comm_name AS comm_name,-- erp项目名称
+    C.`已售面积`,
+    C.`未售面积`,
+    D.`已售车位`,
+    C.`已交付户数`,
+    C.`已接房数`,
+    C.`正在装修户数`,
+    C.`已完成装修户数`,
+    C.`已完成装修未入住`,
+    C.`已完成装修已入住`,
+    (C.`已完成装修已入住` / C.`已交付户数` ) AS 入住率,
+    (C.`已完成装修户数` / C.`已交付户数` ) AS 装修率,
+    C.收费面积,-- 收费面积
+    A.签约时间,
+    G.住宅高层,
+    G.住宅多层,
+    G.别墅,
+    G.联排物业服务费,
+    G.叠拼物业服务费,
+    G.洋房物业费,
+    G.公寓物业服务费,
+    G.商铺物业服务费,
+    G.写字楼物业服务费,
+    G.幼儿园物业服务费,
+    G.厂区物业服务费,
+    G.酒店物业服务费,
+    G.车位管理物业服务费,
+    G.车位月租费用,
+    A.ContractEndTime
+FROM
+    (
+        SELECT
+            T.*
+             ,max(T.GetTime) OVER(PARTITION BY T.CommId)AS 签约时间
+        FROM
+            (
+                SELECT
+                    *
+                     ,row_number() OVER(PARTITION BY CommId ORDER BY GetTime DESC) AS RK
+                FROM dw.dim_project_base_info_d -- 项目维度表
+            )T
+        WHERE T.RK = 1
+    ) A
+        JOIN
+    (
+        SELECT
+            organ_code, -- erp片区id
+            organ_name, -- erp片区名称
+            comm_id, -- erp项目id
+            comm_name -- erp项目名称
+        FROM dw.dim_organ_mapping -- 片区项目映射维度表
+        WHERE comm_id IS NOT NULL
+          AND comm_name NOT LIKE '%撤场%'
+          AND comm_name NOT LIKE '%案场%'
+          AND comm_name NOT LIKE '%禁用%'
+          AND length( comm_id ) != 0
+
+            ${IF(LEN(p_area)!=0," and organ_code IN ('"+p_area+"')","")}
+-- ${if(left(fine_role,2)=="项目","and comm_name = '"+GETUSERDEPARTMENTS(3)+"'","")}
+AND CASE WHEN (SELECT mang_project FROM ods_one_to_many_perm WHERE username  = '${fine_username}') IS NOT NULL
+         THEN comm_name IN (SELECT mang_project FROM one_to_many WHERE username  = '${fine_username}')
+     ELSE ${if(left(fine_role,2)=="项目","comm_name = '"+GETUSERDEPARTMENTS(3)+"'","1=1")}
+            END
+
+        GROUP BY
+            organ_code, -- erp片区id
+            organ_name, -- erp片区名称
+            comm_id, -- erp项目id
+            comm_name -- erp项目名称
+    )B
+    ON A.CommId = B.comm_id
+        LEFT JOIN
+    (
+
+        SELECT
+            a.CommID
+                ,SUM(CASE WHEN a.roomstate <> 0 THEN 1 ELSE 0 END) AS room_num, -- 项目对应房间数量
+            SUM( CASE WHEN a.roomstate IN ( '1', '4', '9', '10', '5', '6' ) THEN a.buildarea ELSE 0 END ) AS 已售面积,
+            SUM( CASE WHEN a.roomstate = '2' THEN a.buildarea ELSE 0 END ) AS 未售面积,
+            SUM( CASE WHEN a.roomstate NOT IN('0','2') THEN 1 ELSE 0 END ) AS 已交付户数,
+            SUM( CASE WHEN a.roomstate IN ( '4', '9', '10', '5', '6' ) THEN 1 ELSE 0 END ) AS 已接房数,
+            SUM( CASE WHEN a.roomstate = '4' THEN 1 ELSE 0 END ) AS 正在装修户数,
+            SUM( CASE WHEN a.roomstate IN ( '9', '10', '5', '6' ) THEN 1 ELSE 0 END ) AS 已完成装修户数,
+            SUM( CASE WHEN a.roomstate = '5' THEN 1 ELSE 0 END ) AS 已完成装修未入住,
+            SUM( CASE WHEN a.roomstate IN ( '9', '10', '6' ) THEN 1 ELSE 0 END ) AS 已完成装修已入住,
+            --   SUM(b.CalcArea) AS 收费面积
+            SUM(CASE WHEN a.roomstate IS NOT NULL AND a.roomstate <> '' THEN a.CalcArea ELSE 0 END) AS 收费面积
+        FROM
+            (
+                SELECT
+                    *
+                FROM  dw.dim_room_d
+            )a
+                LEFT JOIN
+            (
+                SELECT
+                    b1.CommId AS CommId
+                     ,b1.RoomID AS RoomID
+                     ,SUM(CalcArea) AS  CalcArea
+                FROM
+                    (
+                        SELECT
+                            CommId
+                             , CalcArea
+                             , RoomID
+                        FROM ods_erp_tb_hspr_coststansetting_d
+                        WHERE RoomID <> '0'
+                        GROUP BY CommId, CalcArea, RoomID
+                    )b1
+                GROUP BY  b1.CommId,b1.RoomID
+            )b
+            ON a.CommID = b.CommId
+                AND a.RoomID = b.RoomID
+        GROUP BY CommID
+    )C
+    ON A.CommId = C.CommID
+        LEFT JOIN
+    (
+        SELECT
+            CommID
+             ,SUM( CASE WHEN ParkingState IN ( '0001', '0003' ) THEN 1 ELSE 0 END ) AS 已售车位
+             ,SUM(CASE WHEN ParkingState IN ( '0002', '0004' ) THEN 1 ELSE 0 END) AS UnsoldParkingCount
+        FROM ods_erp_tb_hspr_parking_d
+        WHERE IsDelete = '0'
+        GROUP BY
+            CommID
+    )D
+    ON A.COMMID = D.COMMID
+        LEFT JOIN
+    (
+        SELECT
+            A.CommId
+             -- 住宅高层
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName IN ('高层物业服务费', '电梯电费', '公共能耗费') THEN ROUND(ROUND(B.StanAmount,2),2) END),',','\n'),'-') AS  住宅高层
+             -- 住宅多层
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName IN ('多层物业服务费', '公共能耗费') THEN ROUND(B.StanAmount,2) END),',','\n'),'-') AS 住宅多层
+             -- 别墅
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName IN ('别墅物业服务费', '公共能耗费') THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 别墅
+             -- 联排物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE '%联排%' THEN ROUND(B.StanAmount,2) END),',','\n'),'-') AS 联排物业服务费
+             -- 叠拼物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE  '%叠拼%' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 叠拼物业服务费
+             -- 洋房物业费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE  '%洋房%' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 洋房物业费
+             -- 公寓物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE  '%公寓%' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS  公寓物业服务费
+             -- 商铺物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE  '%商铺%' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 商铺物业服务费
+             -- 写字楼物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE  '%写字楼%' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS  写字楼物业服务费
+             -- 幼儿园物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE  '%幼儿园%' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 幼儿园物业服务费
+             -- 厂区物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE  '%厂区%' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 厂区物业服务费
+             -- 酒店物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName LIKE  '%酒店%' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 酒店物业服务费
+             -- 车位管理物业服务费
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName IN('车位管理物业服务费','车位物业服务费') THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 车位管理物业服务费
+             -- 车位月租费用
+             ,IFNULL(REPLACE(group_concat(CASE WHEN B.CostName = '车位月租' THEN  ROUND(B.StanAmount,2) END),',','\n'),'-') AS 车位月租费用
+
+        FROM
+            (
+
+                SELECT
+                    DISTINCT
+                    CommID
+                           ,CostID
+                           ,StanID
+                FROM dim_bind_cost_stan_detail_d  -- 绑定的收费标准明细
+--	WHERE CommID = '214330'
+            )A
+                LEFT JOIN
+            (
+
+                SELECT
+                    B1.CommID AS CommID
+                     ,B1.COSTID AS COSTID
+                     ,B1.StanID AS StanID
+                     ,B1.StanAmount AS StanAmount
+                     ,B2.COSTNAME AS COSTNAME
+                FROM
+                    (
+                        SELECT
+                            CommID
+                             ,COSTID
+                             ,StanID
+                             ,StanAmount
+                        FROM dim_cost_stand_d  -- 小区收费标准
+                        WHERE StanAmount <> 0
+                    )B1
+                        LEFT JOIN
+                    (
+
+                        SELECT
+                            distinct
+                            COMMID
+                                   ,COSTID
+                                   ,COSTNAME
+                        FROM dim_costitem_d -- 项目上的费用名称
+                    )B2
+                    ON B1.CommID = B2.COMMID
+                        AND B1.CostID = B2.COSTID
+            )B
+            ON A.CommID = B.COMMID
+                AND A.CostID = B.COSTID
+                AND A.StanID = B.StanID
+        GROUP BY
+            A.CommId
+    )G
+    ON A.COMMID = G.COMMID

finereport/xiazuan/权责亏损项目明细.sql

@@ -0,0 +1,32 @@
+with one_to_many AS(
+    SELECT
+        a.username AS username -- 用户名
+         ,SUBSTRING_INDEX(SUBSTRING_INDEX(a.mang_project, ',',b.help_topic_id + 1),',',-1) AS mang_project -- 管理项目名
+    FROM ods_one_to_many_perm a
+              JOIN mysql.help_topic b
+                  on b.help_topic_id < (LENGTH(a.mang_project) - length(replace(a.mang_project,',','')) + 1)
+    WHERE a.username  = '${fine_username}'
+)
+SELECT
+    organ_code             -- erp片区code
+    ,organ_name             -- erp片区名称
+    ,comm_id                -- 项目id
+    ,comm_name              -- 项目名称
+    ,index_income_target    -- 收入目标
+    ,index_income_fact      -- 收入完成
+    ,income_completion_rate -- 完成率
+    ,index_cost_target      -- 成本目标
+    ,index_cost_fact        -- 成本完成
+    ,cost_completion_rate   -- 完成率
+    ,index_profit_target    -- 利润目标
+    ,index_profit_fact      -- 利润完成
+    ,profit_completion_rate -- 完成率
+    ,index_market_target    -- 市扩目标
+    ,index_market_fact      -- 市扩完成
+    ,market_completion_rate -- 完成率
+from ods_caiwu_feecollection
+where category = '物业'
+and index_profit_fact < 0
+${IF(LEN(p_startdate)>0," AND yr_month ='" + p_startdate + "'","and yr_month  = '2024-06' ")}
+${if(len(p_area) == 0,"","and organ_code in ('" + p_area + "')")}
+${IF(LEN(p_shop)!=0," and comm_name IN ('"+JOINARRAY(p_shop,"','")+"')","")}

finereport/问题修复/计划到期明细组织架构为空.sql

@@ -0,0 +1,90 @@
+
+
+
+SELECT
+     c.organ_name
+     ,c.comm_name
+     ,c.oa_comm_id                   as oa_comm_id       -- oa项目id
+     ,c.oa_comm_name                 as oa_comm_name     -- oa项目名称
+     ,c.oa_organ_code                as oa_organ_code    -- oa片区id
+     ,c.oa_organ_name                as oa_organ_name    -- oa片区名称
+     ,c.organ_code                   as organ_code       -- erp片区编码
+     ,c.organ_name                   as organ_name       -- erp片区名称
+     ,c.comm_id                      as comm_id          -- erp项目id
+     ,c.comm_name                    as comm_name        -- erp项目名称
+     ,b.subcompanyid1 				 as subcompanyid1 	 -- 公司id
+     ,a.plan_name 					 as plan_name		 -- 计划名称
+     ,a.eval_criteria				 as plan_desc        -- 计划内容
+     ,a.plan_level					 as plan_level		 -- 计划等级
+     ,left(a.start_date,7) 			 as ym 				 -- 计划开始年月
+     ,a.start_dt    				 as start_dt		 -- 计划开始时
+     ,a.end_date					 as end_date		 -- 计划结束时间
+     ,a.finish_date                  as finish_date      -- 计划完成时间
+     ,a.input_date                   as input_date       -- 计划录入时间
+     ,a.day_diff                     as day_diff         -- 距离计划结束天数
+     ,a.responsible_person1			 as responsible_person1 		-- 责任人编码
+     ,b.lastname 					 as executor_name    -- 责任人名称
+     ,left(a.end_ym,7)               as end_ym           -- 计划结束年月
+from
+    (
+        SELECT
+            concat(left(trim(start_date),5),lpad(substring_index(substring_index(trim(start_date),'-',2),'-',-1),2,0),right(trim(start_date),3)) as start_date
+             ,a.start_date    as start_dt   -- 计划开始时间
+             ,a.plan_level    	-- 计划等级
+             ,jt.responsible_person1   		-- 责任人
+             ,a.plan_status		-- 计划状态
+             ,a.input_date   	-- 录入时间
+             ,a.end_date	  		-- 计划结束时间
+             ,a.plan_name   		-- 计划名称
+             ,concat(left(trim(end_date),5),lpad(substring_index(substring_index(trim(end_date),'-',2),'-',-1),2,0),right(trim(end_date),3)) as end_ym
+             ,a.finish_date      -- 完成时间
+             ,TO_DAYS(a.end_date) - TO_DAYS(curdate()) AS day_diff
+             ,a.eval_criteria		-- 评价标准
+        FROM dw.dwd_operations_plan_info_d a,
+             JSON_TABLE (
+                     cast( CONCAT( '["', REPLACE ( responsible_person1, ',', '","' ), '"]' ) AS json ),
+                     "$[*]" COLUMNS ( responsible_person1 INT PATH "$" )
+             ) AS jt
+        -- WHERE  TO_DAYS(a.end_date) - TO_DAYS(curdate())  <= 3
+        --  AND TO_DAYS(a.end_date) - TO_DAYS(curdate()) >= 1
+        where a.end_date > date_format(CURDATE() - INTERVAL 3 day,'%Y-%m-%d')
+          and a.end_date <= date_format(CURDATE(),'%Y-%m-%d')
+    )a
+        left join
+    (
+        select
+            id
+             ,subcompanyid1		-- 公司id
+             ,lastname			-- 执行人
+        from dw.ods_oa_hrmresource_d
+
+    )b
+    on a.responsible_person1 = b.id
+        left join
+    (
+        select
+            distinct
+            organ_code -- erp片区id
+                   ,organ_name -- erp片区名称
+                   ,comm_id    -- erp项目id
+                   ,comm_name  -- erp项目名称
+                   ,oa_organ_code  -- oa片区id
+                   ,oa_organ_name  -- oa片区名称
+                   ,oa_comm_id     -- oa项目id
+                   ,oa_comm_name   -- oa项目名称
+        from dim_organ_mapping -- 组织结构映射维度表
+        -- WHERE oa_comm_id = '610'
+        WHERE oa_organ_code = '610'
+        -- where comm_id is not null
+    )c
+    on b.subcompanyid1 = c.oa_comm_id
+;
+
+
+
+select
+    id
+     ,subcompanyid1		-- 公司id
+     ,lastname			-- 执行人
+from dw.ods_oa_hrmresource_d
+WHERE ods_oa_hrmresource_d.subcompanyid1 = '610';

finereport/预警/片区预警数据.sql

@@ -0,0 +1,312 @@
+CREATE TABLE dim_early_warning_organ_d(
+
+    organ_name               VARCHAR(50)   COMMENT '片区名称'
+    ,km_comple_rate           DECIMAL(6,4)  COMMENT '客满得分完成率'
+    ,ts_close_rate            DECIMAL(6,4)  COMMENT '投诉关闭率'
+    ,report_close_rate        DECIMAL(6,4)  COMMENT '报事关闭率'
+    ,cu_coll_comple_rate      DECIMAL(6,4)  COMMENT '当期收缴完成率'
+    ,pr_coll_comple_rate      DECIMAL(6,4)  COMMENT '往期收缴完成率'
+    ,total_coll_comple_rate   DECIMAL(6,4)  COMMENT '综合收缴完成率'
+    ,xing_revenue_rate        DECIMAL(6,4)  COMMENT '新零售收入完成率'
+    ,space_operate_rate       DECIMAL(6,4)  COMMENT '空间运营收入完成率'
+    ,meiju_revenue_rate       DECIMAL(6,4)  COMMENT '美居收入完成率(片区)'
+    ,rent_revenue_rate        DECIMAL(6,4)  COMMENT '资产租售收入完成率(片区)'
+    ,firth_revenue_rate       DECIMAL(6,4) COMMENT '四大业务收入完成率(片区)'
+    ,payment_rate             DECIMAL(6,4)  COMMENT '回款率(片区)'
+    ,account_rate             DECIMAL(6,4)  COMMENT '销户率(片区)'
+    ,device_space_rate        DECIMAL(6,4)  COMMENT '设备空间巡查完成率'
+    ,water_electric_rate      DECIMAL(6,4)  COMMENT '水电费收缴率'
+)COMMENT = '片区预警指标数据';
+
+ SELECT * FROM dim_early_warning_organ_d;
+INSERT INTO dim_early_warning_organ_d
+SELECT
+    T.organ_name AS organ_name
+     ,SUM(km_comple_rate) AS km_comple_rate -- 客满得分完成率
+     ,SUM(ts_close_rate)  AS ts_close_rate -- 投诉关闭率
+     ,SUM(report_close_rate) AS report_close_rate -- 报事关闭率
+     ,SUM(cu_coll_comple_rate) AS cu_coll_comple_rate -- 当期收缴完成率
+     ,SUM(pr_coll_comple_rate) AS pr_coll_comple_rate -- 往期收缴完成率
+     ,SUM(total_coll_comple_rate) AS total_coll_comple_rate -- 综合收缴完成率
+     ,SUM(xing_revenue_rate) AS xing_revenue_rate -- 新零售收入完成率
+     ,SUM(space_operate_rate) AS space_operate_rate -- 空间运营收入完成率
+     ,SUM(meiju_revenue_rate) AS meiju_revenue_rate -- 美居收入完成率(片区)
+     ,SUM(rent_revenue_rate)   AS rent_revenue_rate -- 资产租售收入完成率(片区)
+     ,SUM(firth_revenue_rate) AS  firth_revenue_rate -- 四大业务收入完成率(片区)
+     ,SUM(payment_rate) AS  payment_rate   -- 回款率(片区)
+     ,SUM(account_rate) AS account_rate -- 销户率(片区)
+     ,SUM(device_space_rate) AS device_space_rate -- 设备空间巡查完成率
+     ,SUM(water_electric_rate) AS water_electric_rate -- 水电费收缴率
+FROM
+    (
+        SELECT
+            T1.organ_name AS organ_name
+             ,IF(IFNULL(T1.organ_target,0)=0,0,T2.index_mydf / T1.organ_target)  AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS xing_revenue_rate -- 新零售收入完成率
+             ,0              AS space_operate_rate -- 空间运营收入完成率
+             ,0              AS meiju_revenue_rate -- 美居收入完成率(片区)
+             ,0              AS rent_revenue_rate -- 资产租售收入完成率(片区)
+             ,0              AS firth_revenue_rate  -- 四大业务收入完成率(片区)
+             ,0              AS payment_rate     -- 回款率(片区)
+             ,0              AS account_rate -- 销户率(片区)
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM
+            (
+                SELECT
+                    DISTINCT
+                    organ_name -- 片区名称
+                           ,organ_target -- 目标得分
+                FROM ods_wuye_satisfaction_target
+                WHERE yr = LEFT(CURRENT_DATE,4)
+                  AND organ_target IS NOT NULL
+            )T1
+                LEFT JOIN
+            (
+                /*各片区得分*/
+                SELECT
+                    organ_name
+                     ,SUM(IFNULL(index_mydf,0))  AS index_mydf
+                FROM ods_wuye_complaint_half_year
+                WHERE yr = LEFT(CURRENT_DATE,4)
+                  AND t_quarter = '二季度'
+                -- AND t_quarter = CASE WHEN QUARTER(CURDATE()) = 1 THEN '一季度'
+                --                      WHEN QUARTER(CURDATE()) = 2 THEN '二季度'
+                --                      WHEN QUARTER(CURDATE()) = 3 THEN '三季度'
+                --                      WHEN QUARTER(CURDATE()) = 4 THEN '四季度' END
+                --
+                GROUP BY organ_name
+            )T2
+            ON T1.organ_name = T2.organ_name
+        UNION ALL
+-- 投诉关闭率/报事关闭率
+        SELECT
+            organ_name   AS organ_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,IF(IFNULL(sum(tousu_incident_num),0)=0,0,sum(tousu_close_incident_num) / sum(tousu_incident_num))  AS ts_close_rate -- 投诉关闭率
+             ,IF(IFNULL(sum(incident_num),0)=0,0,sum(completed_incident_num - completed_not_close_incident_num) / sum(incident_num)) AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS xing_revenue_rate -- 新零售收入完成率
+             ,0              AS space_operate_rate -- 空间运营收入完成率
+             ,0              AS meiju_revenue_rate -- 美居收入完成率(片区)
+             ,0              AS rent_revenue_rate -- 资产租售收入完成率(片区)
+             ,0              AS firth_revenue_rate  -- 四大业务收入完成率(片区)
+             ,0              AS payment_rate     -- 回款率(片区)
+             ,0              AS account_rate -- 销户率(片区)
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM dws_estate_incident_info_m
+        WHERE incident_ym =  date_format(current_date,'%Y%m')
+        GROUP BY
+            organ_name
+        UNION ALL
+-- 收缴率
+        SELECT
+            T1.organ_name  AS organ_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,SUM(T1.cu_collection_rate) / SUM(T2.index_dq_target) AS cu_coll_comple_rate -- 当期收缴完成率
+             ,SUM(T1.pr_collection_rate) / SUM(T2.index_wq_target) AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS xing_revenue_rate -- 新零售收入完成率
+             ,0              AS space_operate_rate -- 空间运营收入完成率
+             ,0              AS meiju_revenue_rate -- 美居收入完成率(片区)
+             ,0              AS rent_revenue_rate -- 资产租售收入完成率(片区)
+             ,0              AS firth_revenue_rate  -- 四大业务收入完成率(片区)
+             ,0              AS payment_rate     -- 回款率(片区)
+             ,0              AS account_rate -- 销户率(片区)
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM
+            (
+                SELECT
+                    organ_code
+                     ,organ_name
+                     ,sum(ifnull(pr_paid_cu_amt,0) + ifnull(cu_paid_cu_amt,0) - ifnull(pr_offset_cu_amt,0) - ifnull(cu_offset_cu_amt,0)) / sum(ifnull(cu_receivable_amt,0) + ifnull(pr_exempt_cu_amt,0) + ifnull(cu_exempt_cu_amt,0)) cu_collection_rate
+                     ,sum((- ifnull(cu_paid_pr_amt,0) - ifnull(cu_offset_pr_amt,0))) / sum(ifnull(pr_total_receivable_amt,0) + ifnull(pr_total_received_amt,0) + ifnull(cu_early_exempt_pr_amt,0) + ifnull(cu_exempt_pr_amt,0)) pr_collection_rate
+                from dwd_finance_fees_serial_d
+                where ParentCostCode = '0001'
+                  and ym = left(current_date,7)
+                  and organ_name not in ('东湖商管','领悦总部','演示机构')
+                  and comm_name not like '%天富%'
+                  and comm_name not in('【喀什】融合国际新城','【贵阳】鹏淇·宏桥公园（撤场）')
+                GROUP BY
+                    organ_code
+                       ,organ_name
+            )T1
+                LEFT JOIN
+            (
+                select
+                    organ_code
+                     ,index_dq_target
+                     ,index_wq_target
+                from ods_finance_collection_target_area
+                WHERE ym = left(current_date,7)
+            )T2
+            ON T1.organ_code = T2.organ_code
+        GROUP BY
+            T1.organ_name
+        UNION ALL
+-- 综合收缴率
+        SELECT
+            T1.organ_name  AS organ_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,SUM(T1.index_receipts) / SUM(T2.index_dj_target)             AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS xing_revenue_rate -- 新零售收入完成率
+             ,0              AS space_operate_rate -- 空间运营收入完成率
+             ,0              AS meiju_revenue_rate -- 美居收入完成率(片区)
+             ,0              AS rent_revenue_rate -- 资产租售收入完成率(片区)
+             ,0              AS firth_revenue_rate  -- 四大业务收入完成率(片区)
+             ,0              AS payment_rate     -- 回款率(片区)
+             ,0              AS account_rate -- 销户率(片区)
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM
+            (
+                SELECT
+                    organ_code
+                     ,organ_name
+                     ,SUM(index_receivable) /  SUM(index_receipts) AS index_receipts
+                FROM ods_caiwu_profit
+                -- where `year_month` = date_format(current_date,'%Y%m')
+                where `year_month` =  '202408'
+                  and comm_name not in('【喀什】融合国际新城','【贵阳】鹏淇·宏桥公园（撤场）')
+                GROUP BY
+                    organ_code
+                       ,organ_name
+            )T1
+                LEFT JOIN
+            (
+                select
+                    organ_code
+                     ,index_dj_target
+                from ods_finance_collection_target_area
+                WHERE ym = left(current_date,7)
+            )T2
+            ON T1.organ_code = T2.organ_code
+        GROUP BY  T1.organ_name
+-- 收入完成率(片区)
+        UNION ALL
+        SELECT
+            organ_name  AS organ_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,IFNULL(CASE WHEN SUM(CASE WHEN revenue_type = '创新' AND business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END) = 0 THEN 0
+                          ELSE SUM(CASE WHEN revenue_type = '创新' AND business_type = '收入' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                              / SUM(CASE WHEN revenue_type = '创新' AND business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                         END,0)               AS xing_revenue_rate -- 新零售收入完成率
+             ,IFNULL(CASE WHEN SUM(CASE WHEN revenue_type = '附属' AND business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END) = 0 THEN 0
+                          ELSE SUM(CASE WHEN revenue_type = '附属' AND business_type = '收入' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                              / SUM(CASE WHEN revenue_type = '附属' AND business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                         END,0)    AS space_operate_rate -- 空间运营收入完成率
+             ,IFNULL(CASE WHEN SUM(CASE WHEN revenue_type = '拎包' AND business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END) = 0 THEN 0
+                          ELSE SUM(CASE WHEN revenue_type = '拎包' AND business_type = '收入' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                              / SUM(CASE WHEN revenue_type = '拎包' AND business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                         END,0)              AS meiju_revenue_rate -- 美居收入完成率(片区)
+             ,IFNULL(CASE WHEN SUM(CASE WHEN revenue_type = '资产' AND business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END)  = 0 THEN 0
+                          ELSE SUM(CASE WHEN revenue_type = '资产' AND business_type = '收入' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                              / SUM(CASE WHEN revenue_type = '资产' AND business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                         END,0)              AS rent_revenue_rate -- 资产租售收入完成率(片区)
+             ,IFNULL(CASE WHEN SUM(CASE WHEN business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END) = 0 THEN 0
+                          ELSE SUM(CASE WHEN business_type = '收入' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                              / SUM(CASE WHEN business_type = '目标' THEN COALESCE(revenue_value,0) ELSE 0 END)
+                         END,0)               AS firth_revenue_rate  -- 四大业务收入完成率(片区)
+             ,0              AS payment_rate     -- 回款率(片区)
+             ,0              AS account_rate -- 销户率(片区)
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM  dw.ods_innoveco_metrics_finish_d
+        WHERE business_type in('收入','目标') -- 业务类型
+          AND YM = LEFT(current_date,7)
+        GROUP BY
+            organ_name
+        UNION ALL
+-- 回款率/销户率
+        SELECT
+            organ_name   AS organ_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS xing_revenue_rate -- 新零售收入完成率
+             ,0              AS space_operate_rate -- 空间运营收入完成率
+             ,0              AS meiju_revenue_rate -- 美居收入完成率(片区)
+             ,0              AS rent_revenue_rate -- 资产租售收入完成率(片区)
+             ,0              AS firth_revenue_rate  -- 四大业务收入完成率(片区)
+             ,SUM(IFNULL(payment_coll_amt,0)) / SUM(IFNULL(trans_amt,0)) AS payment_rate     -- 回款率(片区)
+             ,SUM(IFNULL(payment_coll_num,0)) / SUM(IFNULL(trans_household_num,0)) AS account_rate -- 销户率(片区)
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM dws_law_tran_coll_d
+        WHERE ymd <= CURRENT_DATE()
+        GROUP BY
+            organ_name
+        UNION ALL
+-- 设备空间巡查完成率
+        SELECT
+            organ_name     AS organ_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS xing_revenue_rate -- 新零售收入完成率
+             ,0              AS space_operate_rate -- 空间运营收入完成率
+             ,0              AS meiju_revenue_rate -- 美居收入完成率(片区)
+             ,0              AS rent_revenue_rate -- 资产租售收入完成率(片区)
+             ,0              AS firth_revenue_rate  -- 四大业务收入完成率(片区)
+             ,0              AS payment_rate     -- 回款率(片区)
+             ,0               AS account_rate -- 销户率(片区)
+             ,SUM(task_finish_num) / SUM(task_num) AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM dws_engine_equipment_inspect_task_m
+        where task_ym = date_format(current_date,'%Y%m')
+        GROUP BY
+            organ_name
+        UNION ALL
+-- 水电费收缴率
+        SELECT
+            organ_name     AS organ_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS xing_revenue_rate -- 新零售收入完成率
+             ,0              AS space_operate_rate -- 空间运营收入完成率
+             ,0              AS meiju_revenue_rate -- 美居收入完成率(片区)
+             ,0              AS rent_revenue_rate -- 资产租售收入完成率(片区)
+             ,0              AS firth_revenue_rate  -- 四大业务收入完成率(片区)
+             ,0              AS payment_rate     -- 回款率(片区)
+             ,0              AS account_rate -- 销户率(片区)
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,sum((ifnull(pr_paid_cu_amt,0) + ifnull(cu_paid_cu_amt,0) - ifnull(pr_offset_cu_amt,0) - ifnull(cu_offset_cu_amt,0))+(- ifnull(cu_paid_pr_amt,0) - ifnull(cu_offset_pr_amt,0))) / sum((ifnull(cu_receivable_amt,0) + ifnull(pr_exempt_cu_amt,0) + ifnull(cu_exempt_cu_amt,0))+(ifnull(pr_total_receivable_amt,0) + ifnull(pr_total_received_amt,0) + ifnull(cu_early_exempt_pr_amt,0) + ifnull(cu_exempt_pr_amt,0)))  AS water_electric_rate -- 水电费收缴率
+        FROM dwd_finance_fees_serial_d
+        WHERE ParentCostCode = '0008'
+          AND MiddleCostCode in ('00080001','00080002','00080003','00080004','00080005','00080006','00080007','00080008','00080017','00080018','00080019','00080022','00080023','00080024','00080027','00080028','00080032','00080035')
+          AND ym = LEFT(current_date,7)
+        GROUP BY organ_name
+    )T
+JOIN (SELECT organ_name FROM dim_organ_mapping GROUP BY organ_name)t1 ON T.organ_name = t1.organ_name
+GROUP BY T.organ_name
+;

finereport/预警/项目预警数据.sql

@@ -0,0 +1,246 @@
+DROP TABLE dim_early_warning_comm_d;
+-- 项目预警指标数据
+CREATE TABLE dim_early_warning_comm_d(
+    organ_code               VARCHAR(50)   COMMENT '片区id'
+    ,organ_name               VARCHAR(50)   COMMENT '片区名称'
+    ,comm_id                  VARCHAR(50)   COMMENT '项目id'
+    ,comm_name                VARCHAR(50)   COMMENT '项目名称'
+    ,km_comple_rate           DECIMAL(6,4)  COMMENT '客满得分完成率'
+    ,ts_close_rate            DECIMAL(6,4)  COMMENT '投诉关闭率'
+    ,report_close_rate        DECIMAL(6,4)  COMMENT '报事关闭率'
+    ,cu_coll_comple_rate      DECIMAL(6,4)  COMMENT '当期收缴完成率'
+    ,pr_coll_comple_rate      DECIMAL(6,4)  COMMENT '往期收缴完成率'
+    ,total_coll_comple_rate   DECIMAL(6,4)  COMMENT '综合收缴完成率'
+    ,device_space_rate        DECIMAL(6,4)  COMMENT '设备空间巡查完成率'
+    ,water_electric_rate      DECIMAL(6,4)  COMMENT '水电费收缴率'
+)COMMENT = '项目预警指标数据';
+
+SELECT * FROM dim_early_warning_comm_d;
+INSERT INTO dim_early_warning_comm_d
+SELECT
+    T.organ_code AS organ_code
+     ,T.organ_name AS organ_name
+     ,T.comm_id    AS comm_id
+     ,T.comm_name   AS comm_name
+     ,SUM(km_comple_rate) AS km_comple_rate -- 客满得分完成率
+     ,SUM(ts_close_rate)  AS ts_close_rate -- 投诉关闭率
+     ,SUM(report_close_rate) AS report_close_rate -- 报事关闭率
+     ,SUM(cu_coll_comple_rate) AS cu_coll_comple_rate -- 当期收缴完成率
+     ,SUM(pr_coll_comple_rate) AS pr_coll_comple_rate -- 往期收缴完成率
+     ,sum(total_coll_comple_rate) AS total_coll_comple_rate
+     ,SUM(device_space_rate) AS device_space_rate -- 设备空间巡查完成率
+     ,SUM(water_electric_rate) AS water_electric_rate -- 水电费收缴率
+FROM
+    (
+        SELECT
+            T1.organ_code AS organ_code
+             ,T1.organ_name AS organ_name
+             ,T1.comm_id    AS comm_id
+             ,T1.comm_name   AS comm_name
+             ,IF(IFNULL(T1.comm_target,0)=0,0,(IFNULL(T2.index_dc_myddf,0) / IFNULL(T1.comm_target,0)))  AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM
+            (
+                SELECT
+                    organ_code
+                     ,organ_name -- 片区名称
+                     ,comm_id
+                     ,comm_name   -- 项目名称
+                     ,comm_target -- 项目目标得分
+                FROM ods_wuye_satisfaction_target
+                WHERE yr = LEFT(CURRENT_DATE,4)
+                  AND comm_name NOT LIKE '%案场%'
+                  AND comm_name NOT LIKE '%撤场%'
+                  AND comm_name NOT LIKE '%禁用%'
+                -- AND  comm_type = ''
+            )T1
+                LEFT JOIN
+            (
+                SELECT
+                    organ_code
+                     ,organ_name
+                     ,comm_id
+                     ,comm_name
+                     ,index_dc_myddf
+                FROM ods_wuye_complaint
+                WHERE yr = LEFT(CURRENT_DATE,4)
+                  AND jd = '二季度'
+                -- AND jd = CASE WHEN QUARTER(CURDATE()) = 1 THEN '一季度'
+                --                      WHEN QUARTER(CURDATE()) = 2 THEN '二季度'
+                --                      WHEN QUARTER(CURDATE()) = 3 THEN '三季度'
+                --                      WHEN QUARTER(CURDATE()) = 4 THEN '四季度' EN
+            )T2
+            ON T1.organ_code = T2.organ_code
+                AND T1.comm_id = T2.comm_id
+        UNION ALL
+-- 投诉关闭率/报事关闭率
+        SELECT
+            organ_code      AS organ_code
+             ,organ_name     AS organ_name
+             ,comm_id        AS comm_id
+             ,comm_name      AS comm_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,IF(IFNULL(sum(tousu_incident_num),0)=0,0,sum(tousu_close_incident_num) / sum(tousu_incident_num))  AS ts_close_rate -- 投诉关闭率
+             ,IF(IFNULL(sum(incident_num),0)=0,0,sum(completed_incident_num - completed_not_close_incident_num) / sum(incident_num)) AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM dws_estate_incident_info_m
+        WHERE incident_ym =  date_format(current_date,'%Y%m')
+        GROUP BY
+            organ_name,comm_name,comm_id,organ_code
+        UNION ALL
+-- 收缴率
+        SELECT
+            T1.organ_code  AS organ_code
+             ,T1.organ_name  AS organ_name
+             ,T1.commid      AS comm_id
+             ,T1.comm_name   AS comm_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,SUM(T1.cu_collection_rate) / SUM(T2.index_dq_target) AS cu_coll_comple_rate -- 当期收缴完成率
+             ,SUM(T1.pr_collection_rate) / SUM(T2.index_wq_target) AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM
+            (
+                SELECT
+                    commid
+                     ,comm_name
+                     ,organ_code
+                     ,organ_name
+                     ,sum(ifnull(pr_paid_cu_amt,0) + ifnull(cu_paid_cu_amt,0) - ifnull(pr_offset_cu_amt,0) - ifnull(cu_offset_cu_amt,0)) / sum(ifnull(cu_receivable_amt,0) + ifnull(pr_exempt_cu_amt,0) + ifnull(cu_exempt_cu_amt,0)) cu_collection_rate
+                     ,sum((- ifnull(cu_paid_pr_amt,0) - ifnull(cu_offset_pr_amt,0))) / sum(ifnull(pr_total_receivable_amt,0) + ifnull(pr_total_received_amt,0) + ifnull(cu_early_exempt_pr_amt,0) + ifnull(cu_exempt_pr_amt,0)) pr_collection_rate
+                from dwd_finance_fees_serial_d
+                where ParentCostCode = '0001'
+                  and ym = left(current_date,7)
+                  and organ_name not in ('东湖商管','领悦总部','演示机构')
+                  and comm_name not like '%天富%'
+                  and comm_name not in('【喀什】融合国际新城','【贵阳】鹏淇·宏桥公园（撤场）')
+                GROUP BY
+                    organ_code
+                       ,organ_name
+                       ,commid
+                       ,comm_name
+            )T1
+                LEFT JOIN
+            (
+                select
+                    comm_id
+                     ,comm_name
+                     ,organ_code
+                     ,organ_name
+                     ,index_dq_target
+                     ,index_wq_target
+                from ods_finance_collection_target_project
+                WHERE ym = left(current_date,7)
+            )T2
+            ON T1.organ_code = T2.organ_code
+                AND T1.commid = T2.comm_id
+        GROUP BY
+            T1.organ_name,T1.comm_name,T1.commid,T1.organ_code
+        UNION ALL
+-- 综合收缴率
+        SELECT
+            T1.organ_code    AS organ_code
+             ,T1.organ_name  AS organ_name
+             ,T1.comm_id     AS comm_id
+             ,T1.comm_name   AS comm_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,SUM(T1.index_receipts) / SUM(T2.index_dj_target)             AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM
+            (
+                SELECT
+                    organ_code
+                     ,organ_name
+                     ,comm_id
+                     ,comm_name
+                     ,SUM(index_receivable) /  SUM(index_receipts) AS index_receipts
+                FROM ods_caiwu_profit
+                -- where `year_month` = date_format(current_date,'%Y%m')
+                where `year_month` =  '202408'
+                  and comm_name not in('【喀什】融合国际新城','【贵阳】鹏淇·宏桥公园（撤场）')
+                GROUP BY
+                    organ_code
+                       ,organ_name
+                       ,comm_id
+                       ,comm_name
+            )T1
+                LEFT JOIN
+            (
+                select
+                    organ_code
+                     ,comm_id
+                     ,index_dj_target
+                from ods_finance_collection_target_project
+                WHERE ym = left(current_date,7)
+            )T2
+            ON T1.organ_code = T2.organ_code
+                AND T1.comm_id = T2.comm_id
+        GROUP BY
+            T1.organ_code,T1.organ_name,T1.comm_id ,T1.comm_name
+        UNION ALL
+-- 设备空间巡查完成率
+        SELECT
+            organ_code      AS organ_code
+             ,organ_name     AS organ_name
+             ,comm_id        AS comm_id
+             ,comm_name      AS comm_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,SUM(task_finish_num) / SUM(task_num) AS device_space_rate -- 设备空间巡查完成率
+             ,0              AS water_electric_rate -- 水电费收缴率
+        FROM dws_engine_equipment_inspect_task_m
+        where task_ym = date_format(current_date,'%Y%m')
+        GROUP BY
+            organ_name
+               ,organ_code
+               ,comm_id
+               ,comm_name
+        UNION ALL
+-- 水电费收缴率
+        SELECT
+            organ_code     AS organ_code
+             ,organ_name     AS organ_name
+             ,commid         AS comm_id
+             ,comm_name      AS comm_name
+             ,0              AS km_comple_rate -- 客满得分完成率
+             ,0              AS ts_close_rate -- 投诉关闭率
+             ,0              AS report_close_rate -- 报事关闭率
+             ,0              AS cu_coll_comple_rate -- 当期收缴完成率
+             ,0              AS pr_coll_comple_rate -- 往期收缴完成率
+             ,0              AS total_coll_comple_rate -- 综合收缴完成率
+             ,0              AS device_space_rate -- 设备空间巡查完成率
+             ,sum((ifnull(pr_paid_cu_amt,0) + ifnull(cu_paid_cu_amt,0) - ifnull(pr_offset_cu_amt,0) - ifnull(cu_offset_cu_amt,0))+(- ifnull(cu_paid_pr_amt,0) - ifnull(cu_offset_pr_amt,0))) / sum((ifnull(cu_receivable_amt,0) + ifnull(pr_exempt_cu_amt,0) + ifnull(cu_exempt_cu_amt,0))+(ifnull(pr_total_receivable_amt,0) + ifnull(pr_total_received_amt,0) + ifnull(cu_early_exempt_pr_amt,0) + ifnull(cu_exempt_pr_amt,0)))  AS water_electric_rate -- 水电费收缴率
+        FROM dwd_finance_fees_serial_d
+        WHERE ParentCostCode = '0008'
+          AND MiddleCostCode in ('00080001','00080002','00080003','00080004','00080005','00080006','00080007','00080008','00080017','00080018','00080019','00080022','00080023','00080024','00080027','00080028','00080032','00080035')
+          AND ym = LEFT(current_date,7)
+        GROUP BY organ_name,organ_code,commid,comm_name
+    )T JOIN (SELECT organ_code,comm_id FROM dim_organ_mapping GROUP BY organ_code,comm_id)t1 ON T.comm_id = t1.comm_id and T.organ_code = t1.organ_code
+
+GROUP BY T.organ_code
+       ,T.organ_name
+       ,T.comm_id
+       ,T.comm_name
+;

finereport/预警/预警指标填报.sql

@@ -0,0 +1,17 @@
+DROP TABLE ods_index_early_warning;
+CREATE TABLE ods_index_early_warning(
+                                        index_name    VARCHAR(50)   COMMENT '指标名称'
+    ,comm_organ   VARCHAR(50)   COMMENT '项目/片区'
+    ,index_value  DECIMAL(6,4)  COMMENT '预警值'
+    ,mang_organ   VARCHAR(100)  COMMENT '角色'
+    ,update_by    VARCHAR(50)   COMMENT '更新人'
+    ,update_time  TIMESTAMP     COMMENT '更新时间'
+)COMMENT = '指标预警值填报';
+
+
+SELECT
+    index_name    -- 指标名称
+     ,comm_organ   -- 项目/片区
+     ,index_value  -- 预警值
+     ,mang_organ   -- 角色
+FROM ods_index_early_warning