diff --git a/code/db/pkg/telsale_archievement_pkg.pck b/code/db/pkg/telsale_archievement_pkg.pck index 45b3f88..b861154 100644 --- a/code/db/pkg/telsale_archievement_pkg.pck +++ b/code/db/pkg/telsale_archievement_pkg.pck @@ -4,11 +4,15 @@ CREATE OR REPLACE PACKAGE telsale_archievement_pkg IS -- Created : 2023/3/10 15:13:34 -- Purpose : 桌面霸屏项目基础数据生成包 + TYPE cur_type IS REF CURSOR; + PROCEDURE department_archievement ( a_department_code IN VARCHAR2, a_attaching_rate OUT VARCHAR2, - a_renewal_rate OUT VARCHAR2 + a_renewal_rate OUT VARCHAR2, + a_total OUT VARCHAR2, + a_mensual_cur OUT cur_type ); END telsale_archievement_pkg; @@ -20,14 +24,27 @@ CREATE OR REPLACE PACKAGE BODY telsale_archievement_pkg IS ( a_department_code IN VARCHAR2, a_attaching_rate OUT VARCHAR2, - a_renewal_rate OUT VARCHAR2 + a_renewal_rate OUT VARCHAR2, + a_total OUT VARCHAR2, + a_mensual_cur OUT cur_type ) IS l_this_month VARCHAR2(4); + l_this_year DATE; l_department_name VARCHAR2(100); BEGIN l_this_month := to_char(SYSDATE, 'mm') || '月'; + l_this_year := to_date(to_char(SYSDATE, + 'yyyy') || '-01-01 00:00:00', + 'yyyy-mm-dd hh24:mi:ss'); + + SELECT bm.department_name + INTO l_department_name + FROM idst0.bm_t bm + WHERE bm.department_code = a_department_code; + + --车非渗透率 SELECT decode(SUM(cf.车险个人客户保费), 0, 0, @@ -38,11 +55,7 @@ CREATE OR REPLACE PACKAGE BODY telsale_archievement_pkg IS WHERE cf.月份 = l_this_month AND 部门代码 = a_department_code; - SELECT bm.department_name - INTO l_department_name - FROM idst0.bm_t bm - WHERE bm.department_code = a_department_code; - + --续保率 SELECT decode(SUM(到期数), 0, 0, @@ -51,6 +64,31 @@ CREATE OR REPLACE PACKAGE BODY telsale_archievement_pkg IS INTO a_renewal_rate FROM 坐席续保统计 WHERE 部门 = l_department_name; + + --总业绩 + SELECT round(nvl(SUM(cf.车险个人客户保费 + cf.车非融合保费), + 0), + 0) + INTO a_total + FROM 车非每日保费 cf + WHERE 部门代码 = a_department_code + AND 签单日期 >= l_this_year + AND 签单日期 <= SYSDATE; + + --每月业绩 + OPEN a_mensual_cur FOR + SELECT cf.月份 mm, + round(nvl(SUM(cf.车险个人客户保费 + cf.车非融合保费), + 0), + 0) bf + FROM 车非每日保费 cf + WHERE 部门代码 = a_department_code + AND 签单日期 >= to_date(to_char(SYSDATE, + 'yyyy') || '-01-01 00:00:00', + 'yyyy-mm-dd hh24:mi:ss') + AND 签单日期 <= SYSDATE + GROUP BY cf.月份 + ORDER BY cf.月份; END; BEGIN diff --git a/code/鍚庣/desktop_archievement_backend/src/main/java/com/cpic/xim/utils/archievement/DepartmentArchievement.java b/code/鍚庣/desktop_archievement_backend/src/main/java/com/cpic/xim/utils/archievement/DepartmentArchievement.java index 79cffb8..64b4211 100644 --- a/code/鍚庣/desktop_archievement_backend/src/main/java/com/cpic/xim/utils/archievement/DepartmentArchievement.java +++ b/code/鍚庣/desktop_archievement_backend/src/main/java/com/cpic/xim/utils/archievement/DepartmentArchievement.java @@ -19,6 +19,8 @@ import java.sql.CallableStatement; import java.util.Vector; import com.fasterxml.jackson.annotation.JsonProperty; +import oracle.jdbc.OracleTypes; + public class DepartmentArchievement { @@ -66,7 +68,7 @@ public class DepartmentArchievement { DepartmentArchievement archievement = new DepartmentArchievement(); - String sql = "{call telsale_archievement_pkg.department_archievement(?,?,?)}"; + String sql = "{call telsale_archievement_pkg.department_archievement(?,?,?,?,?)}"; Class.forName( "oracle.jdbc.driver.OracleDriver" ); Connection connection = DriverManager.getConnection( jdbcURL, userName, password ); @@ -75,11 +77,14 @@ public class DepartmentArchievement statement.setString( 1, departmentCode ); statement.registerOutParameter( 2, java.sql.Types.VARCHAR ); statement.registerOutParameter( 3, java.sql.Types.VARCHAR ); + statement.registerOutParameter( 4, java.sql.Types.VARCHAR ); + statement.registerOutParameter( 5, OracleTypes.CURSOR ); statement.execute(); String attach_rate = statement.getString( 2 ); String renewal_rate = statement.getString( 3 ); + String totalArchievement = statement.getString( 4 ); archievement.setAttachingRate( attach_rate ); archievement.setInsuranceRenewalRate( renewal_rate );