感觉自己写的很棒的一个Oracle存储过程,(其实想说很叼^,^).
集成了一堆操作数据的功能(至少几十), 包括存储过程执行异常信息输出帮助诊断.
亮点很多, 比如`over(partition by t.u_id order by t.u_id)`, 哈哈.
是个很多客户都在用的稳定的关键存储过程!（客户没有一千也有三五百，并且还在不停的增加）
每天都要运行 无数次。因为每个客户的坐席每次打电话都要用到，包括导入客户资料，几万，几十万的批量导入，速度都不错，每次执行都有日志记录。
1 create or replace procedure NAG_CUSTOMER_TOPOOLW( 2 --客户ID集(如:"10001,10002,10003,") (最后一位逗号,) 3 --或者是 客户资料表的where条件(and xx=xxx and yyy=yy) (无最后一位识别) 4 --或者是 数据池数据ID集(如:"10001,10002,10003,;") (最后一位是分号;) 5 --或者是 数据池和 客户资料的条件("and xc=xc and dpd_dp_id=id!") (最后一位是感叹号!) 6 --或者是 select 语句,只有一个字段DPD_ID) (最后一位是井号#) 7 --或者是 自动外拨的,从临时表取数据,最后一位是 符号@ (如'来自自动外拨(预测外拨)@') 8 V_IDW in clob, 9 10 V_FromDPID in varchar2,--从原来哪个池转出 11 V_ToDPID in varchar2,--转到哪个池 12 13 V_KH in number,--保留归属人 14 V_DF in number,--从原数据池中删除 15 V_KCS in number,--保留拨打状态 16 17 V_ToUID in number:=0,--转给谁 18 V_ActUID in number,--谁操作的 19 20 OutRow out number, --影响的行数; -999999表示满了,数据量已达上限,未做分配; 21 V_GID in number:=null 22 ) Authid Current_User is 23 /*批量的数据流转 24 Auth: Lzpong 2014/05/28 25 + 几乎完全重新写 2014/10/24 26 已经在这个池的数据不会被操作 27 兼容传入ID集 或者 客户表的where的条件 +或者 DPD_ID集(分号结尾) 2014/10/24 28 如果传入的是ID集,末尾必须有逗号(,),如果是池数据ID集再加个分号(;) 29 +实现了平均分配 2014/10/24 +2014/11/12修正重写 30 +实现了数据限制 2014/10/24 +2014/11/12修正重写 31 +修正流转数据不齐全 2014/12/01 32 +修正了 临时表去重导致的 慢问题,并目标池标记删除的不删除重新插入了 2014/12/19 33 +insert/update 使用merge 大大提高速度 2014/12/23 34 +自动外拨转数据到数据池,用到了临时表 "NAG_FIXTABLE_TEMP" 2015/01/29 35 +客户资料在数据池中唯一检查 2015/04/20 36 +数据池转移检查 转入和转出池的指定转移规则属性 2015/04/20 37 +删除原池数据前前加入确认检查已转入目标池 2015/05/06 38 +共享,关注 流转后删除/更新 ;更改分配前在临时表,最后一次性操作数据表,增强效率 2015/05/18 39 +修复 低权限人可操作所有数据bug; 全局数据唯一设置使数据汇总流转不能流转 2015/05/22 40 +修复 条件转移 原池不删除 2015/05/22 41 +修复 数据限制判断部分 慢(部分改了) 42 +限制 审核状态的不能流转 2015/06/08 43 +日志 输出完整的调用日志和调试输出信息 2015/06/09 44 +重大修改整理 完全整理操作流程 ~2015/06/17 45 +为了给其他功能(导入,未接来电转移等)通用,为where条件时,客户资料操作转移,完全由查询条件限定的(如数据规则限制) 2015/07/07 46 +客户资料到数据池 和 自动外拨 到数据池 也检查 数据唯一性 2015/07/07 47 +修复剩余量小于0的不限制情况 2015/07/08 48 +(池流转)删除源数据时,改为仅更新DPD_DP_ID 2015/07/13 49 +更新/修复/优化 改删除原池数据为更新池ID等 2015/07/24 50 +限制 非超管 需要业务规则允许才能单池间流转多条池数据 2015/08/05 51 +所有入池转移均根据唯一设置检查或不检查数据唯一性 2015/08/11 52 +数据转移时清除组ID 53 +加快表(datapooldata)数据量大时更新数据执行速度,原merge慢 2015/11/17 54 +指定到人的转移,超过限制的不转移 2015/12/24 55 +修改第一次进池 update 很慢的问题 xy 2016/3/1 56 +除去客户姓名入池,避免客户姓名太长导致出错 2016/04/16 57 +修复V_ToUID==null时不能平均分配; 优化日志总是全部输出 2016/04/26 58 +增加入池到组功能,只有不保留归属且不指定到人才能到指定组;否则组ID为空(包括不正确的组ID,保留归属,指定到人) lzp 2016/04/29 59 +加入功能: 在启用同类型检查唯一性的时候,(字典)池类型代码 小于1才检查 lzp 2016/06/12- 60 +不保留归属,转到人的,清除组ID; 返回不同的错误代码 lzpong 2016/09/09 61 +不保留拨打状态入池后,非未拨打的改为callBack lzpong 2016/12/23 62 */ 63 /*指定要使用的临时表 64 NAG_IDS_TEMP 65 NAG_IDS1_TEMP 66 NAG_ALLIDS_TEMP 67 NAG_FIXTABLE_TEMP (自动外拨转数据到数据池时) 68 返回的错误代码: 69 -900001 : 参数错误 70 -900002 : 目标池已结束, 或设置不允许转入 71 -900099 : 可操作流转的数据量为0 72 -900012 : 没有任何的比例用来分配 73 -900013 : 没有可按比例分配的用户 74 -999999 : 目标池用户数据量达到限制, 或用户数据总量达到限制; 超级管理员在池的上限也受限 75 -999888 : 不允许流转多条到池数据,没有流转多条的权限 76 */ 77 tType number:=0; --转数据的类型 1:客户表到池 1.5:自动外拨到池 2:单池到单池 3:多池到单池 4:来自数据池(池查询)(混合查询) 5:来自数据池(池查询结果)(池查询) 78 fenp number; --目标池的分配类型:1自动抽取,2平均分配,3自定义分配 79 --isLimit number; --目标池是否有数据限制 80 str1 varchar2(5000); 81 znum number; 82 xnum number;--数据状态 0:未启动 1:已启动 2:已结束,不能操作数据了 83 ynum number;--是否允许转入 0:不允许 1:允许 84 tnum number; 85 pnum number; 86 unum number; 87 cursor dusers is select * from nag_allids_temp; --用户 88 cursor newdatas is select * from nag_ids_temp where flag=0 and u_id is null; --未分配数据 89 strFrom varchar2(200); 90 dpname varchar2(200):=0; --数据池名 91 pici varchar(22):=to_char(systimestamp,'yyyymmdd_hh24missxff3'); --分配批次 92 onlyOne number; --客户资料在数据池中唯一? 93 d_DF number:=V_DF; --数据池转出是否删除数据 94 d_ToUID number;--指定的转给谁,V_ToUID 检查 95 GM number;--操作人是否是超管(>0),(流转多条池数据限制) 96 gid number:=V_GID; 97 --调试信息输出日志 98 bgDate date:=sysdate; 99 --调试信息记录输出 100 v_strMsg long; 101 ---------------------------------比例分配新增的参数------------------------------------------ 102 hastemp number;--临时变量 103 SUM_DPL_RATIOCOUNT number;--目标池比例总和 104 TYPE ref_cursor_type IS REF CURSOR; 105 Prorete_Cursor ref_cursor_type; 106 /*V_DPU_U_ID_TEMP varchar(50); 107 V_U_LEVEL_TEMP varchar(50); 108 V_DPL_RATIOCOUNT_TEMP varchar(50);*/ 109 V_DPL_RATIOCOUNT_TEMP number;--用于计算比例基数 比例 110 V_U_COUNT_TEMP number;----用于计算比例基数 人数 111 V_SUMRATIONCOUNT number;--用于计算比例基数 总量 112 V_BASECOUNT number;--基数 113 V_DPU_U_ID_TEMP number;--数据池用户 114 V_U_ID_GETCOUNT number;--分配量 115 V_U_ID_KFP number;--用户可分配量(临时变量) 116 --------------------------------------------------------------------------------------------- 117 begin 118 OutRow:=0; 119 if((V_ToDPID is null) or (V_FromDPID is null and V_ToDPID is null) or (V_ToDPID=V_FromDPID)) then --执行前置条件检查 120 OutRow:=-900001; 121 null; 122 else --前置条件满足,开始执行 123 /*begin 124 insert into T_CUSTOPOOL_PARAM( t_idw, t_fromdpid, t_todpid, t_kh, t_df, t_kcs, t_touid, t_actuid, t_outrow, t_date,t_Times,t_msg) 125 values(substr(V_IDW,4000), V_FromDPID, V_ToDPID, V_KH, V_DF, V_KCS, d_ToUID, V_ActUID, OutRow, sysdate, tnum, substr(v_str,1,3999)); 126 commit; 127 end;*/ 128 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 84 begin Exec '); 129 select to_number(sp_param1) into onlyOne from NAG_SYSPARAM where sp_id=29;--唯一性检查开关 130 --select dp_pooltype , nvl(d_datapool,0) into xnum,ynum from nag_datapool left join nag_dictionary on d_id=dp_pooltype where dp_id=V_ToDPID; 131 if(onlyOne=1 /*and ynum<1*/)then --是否删除原池数据 132 d_DF:=1; 133 end if; 134 select DP_START,DP_TRANSINT into xnum,ynum from nag_datapool where dp_id=V_ToDPID; 135 if(xnum=2 or ynum<1)then --目标池 已结束 或 不允许转入 136 OutRow:=-900002; 137 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 128 目标池 已结束 或 不允许转入'); 138 return ; 139 end if; 140 141 --如果是单池转移,--暂做记录来源池ID 142 if(V_FromDPID is not null and V_FromDPID>10)then 143 dpname:=V_FromDPID; 144 end if; 145 --确保转到人存在 146 select count(u_id) into d_ToUID from nag_user where u_id=V_ToUID; 147 if(d_ToUID>0)then 148 d_ToUID:=V_ToUID; 149 end if; 150 --操作人是否是超管(>0) 151 select count(gu_g_id) into GM from nag_groupuser where gu_u_id=V_ActUID and gu_g_id=10000; 152 153 --清理临时表 154 execute immediate 'truncate table NAG_IDS_TEMP';--实际(去重)数据操作表 155 execute immediate 'truncate table NAG_IDS1_TEMP';--临时表 156 --要操作的ID集合,放到临时表(NAG_IDS_TEMP),flag='0' 的可用, 并 group by 去重 157 strFrom:=substr(V_IDW,length(V_IDW),1);--判断数据来源 158 CASE strFrom 159 WHEN chr(44) THEN --',' 为CM_ID集 160 insert into NAG_IDS1_TEMP(CM_ID,DP_ID,FLAG)--CM_ID 客户ID,数据池ID,0 161 select COLUMN_VALUE,dpname,0 from table(splitstr(V_IDW)) 162 where COLUMN_VALUE!=';' and COLUMN_VALUE is not null; 163 insert into nag_ids_temp(cm_id,flag)--CM_ID 客户ID,0 164 select cm_id,0 from nag_ids1_temp group by cm_id; 165 166 if(V_FromDPID is not null and V_FromDPID>10)then 167 update nag_ids_temp t set dp_id=V_FromDPID; 168 end if; 169 170 WHEN chr(59) THEN --';' 是数据池数据ID(dpd_id),多个池的数据 171 --为DPD_ID集 172 insert into NAG_IDS1_TEMP(DPD_ID,FLAG)--数据池数据ID,0 173 select COLUMN_VALUE,0 from table(splitstr(V_IDW)) 174 where COLUMN_VALUE!=';' and COLUMN_VALUE is not null; 175 --根据dpd_id 更新pd_id,cm_id 176 merge into nag_ids1_temp t 177 using (select d.dpd_cm_id,d.dpd_dp_id,d.dpd_id from nag_datapooldata d where d.dpd_actstate=1) tt on (t.dpd_id=tt.dpd_id) 178 when matched then 179 update set cm_id=tt.dpd_cm_id, dp_id= tt.dpd_dp_id, t.flag=0; 180 --CM_ID去重插入 181 --insert into nag_ids_temp(cm_id,dp_id,flag) --使用merge 貌似耗时差的不多 182 --select cm_id,dp_id,0 from (select cm_id,dp_id,row_number() over(partition by t.cm_id order by t.cm_id) rnum from nag_ids1_temp t) where rnum<2 ; 183 merge into nag_ids_temp t 184 using(select cm_id,dp_id from ( 185 select dpd_id,cm_id,dp_id,row_number() over(partition by t.cm_id order by t.cm_id) rnum from nag_ids1_temp t) where rnum<2 )Q on (1=2) 186 when not matched then insert (t.cm_id,t.dp_id,t.flag) values(Q.cm_id,Q.dp_id,0); 187 tType:=3; --多池到单池 188 if(V_FromDPID is not null and V_FromDPID>10)then 189 strFrom:='来自数据池('||V_FromDPID||')/勾选'; 190 else 191 strFrom:='来自数据池(数据汇总/勾选)'; 192 end if; 193 194 WHEN chr(33) THEN --'!' 混合条件 195 str1:='insert into NAG_IDS1_TEMP(cm_id,dp_id,flag) select cm_id,dpd_dp_id,0 from nag_customer c,nag_datapooldata d where c.cm_id=d.dpd_cm_id and d.dpd_actstate=1 '||substr(V_IDW,0,length(V_IDW)-1)||' group by cm_id,dpd_dp_id'; 196 execute immediate str1; 197 --CMID去重 198 merge into nag_ids_temp t using(select cm_id,dp_id from ( 199 select dpd_id,cm_id,dp_id,row_number() over(partition by t.cm_id order by t.cm_id) rnum from nag_ids1_temp t) where rnum<2 )Q on (1=2) 200 when not matched then insert (t.cm_id,t.dp_id,t.flag) values(Q.cm_id,Q.dp_id,0); 201 202 tType:=4; --池查询到单池 203 if(V_FromDPID is not null and V_FromDPID>10)then 204 strFrom:='来自数据池('||V_FromDPID||')/查询'; 205 else 206 strFrom:='来自数据池(数据汇总/查询)'; 207 end if; 208 209 WHEN chr(35) THEN --'#' select语句 210 execute immediate 'insert into NAG_IDS1_TEMP(DPD_ID) '||substr(V_IDW,0,length(V_IDW)-1); 211 --根据dpd_id 更新pd_id,cm_id 212 merge into nag_ids1_temp t 213 using (select d.dpd_cm_id,d.dpd_dp_id,d.dpd_id from nag_datapooldata d where d.dpd_actstate=1) tt on (t.dpd_id=tt.dpd_id) 214 when matched then 215 update set cm_id=tt.dpd_cm_id, dp_id= tt.dpd_dp_id, t.flag=0; 216 --CM_ID去重插入 217 merge into nag_ids_temp t using(select cm_id,dp_id from ( 218 select dpd_id,cm_id,dp_id,row_number() over(partition by t.cm_id order by t.cm_id) rnum from nag_ids1_temp t) where rnum<2 )Q on (1=2) 219 when not matched then insert (t.cm_id,t.dp_id,t.flag) values(Q.cm_id,Q.dp_id,0); 220 221 tType:=5; --池查询到单池 222 if(V_FromDPID is not null and V_FromDPID>10)then 223 strFrom:='来自数据池('||V_FromDPID||')/查询结果'; 224 else 225 strFrom:='来自数据池(数据汇总/查询结果)'; 226 end if; 227 d_DF:=1; 228 229 WHEN chr(64) THEN --'@' 来自自动外拨 230 --CMID去重 231 merge into nag_ids_temp t using(select all_id,flag from ( 232 select all_id,flag,row_number() over(partition by t.all_id order by t.all_id) rnum from nag_fixtable_temp t) where rnum<2 )Q on (1=2) 233 when not matched then insert (t.cm_id,t.u_id,t.flag) values(Q.all_id,Q.flag,0); 234 tType:=1.5; 235 strFrom:=substr(V_IDW,0,length(V_IDW)-1); 236 237 ELSE --为where的条件 238 str1:=''; 239 --修复普通人员可以流转所有数据(不选择时) 2015/05/22 240 --为了给其他功能(导入,未接来电转移等)通用,客户资料操作转移 完全由查询条件限定的(如数据规则限制) 2015/07/07 241 execute immediate 'insert into NAG_IDS1_TEMP(cm_id,dp_id,flag) select cm_id,'||dpname||',0 from nag_customer left join nag_contact ct on ct_cm_id=cm_id where 1=1 '||V_IDW||str1||' group by cm_id'; 242 insert into nag_ids_temp(cm_id,flag) select cm_id,0 from nag_ids1_temp group by cm_id; 243 update nag_customer c set c.CM_HOLDERID=null where c.CM_HOLDERID=0 and exists(select 1 from NAG_IDS1_TEMP t where t.cm_id=c.cm_id); 244 if(V_FromDPID is not null and V_FromDPID>10)then 245 update nag_ids_temp set dp_id=V_FromDPID; 246 end if; 247 248 END CASE; --来路分析结束 249 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 236 into '||sql%rowcount); 250 --没有数据转移 251 select count(cm_id) into OutRow from nag_ids_temp; 252 if(OutRow=0)then 253 OutRow:=-900099; 254 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 243 可操作数量为0'); 255 return; 256 elsif(OutRow>1 and tType>=2 and GM<1 and V_FromDPID>10)then --非超管,流转多条池数据,检查流转(数量)规则 257 select count(ps_g_id) into xnum from nag_permission,nag_groupuser where gu_g_id=ps_g_id and ps_br_id=900 and gu_u_id=V_ActUID; 258 if(xnum<1)then 259 OutRow:=-999888;--没有流转多条的权限 260 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 250 没有流转多条的权限 '); 261 return; 262 end if; 263 end if; 264 --客户表到池 / 单池到单池 265 if(tType=0)then --来自多池 V_FromDPID 也为空,排除 266 if(V_FromDPID is null or V_FromDPID <100)then 267 tType:=1; 268 strFrom:='来自客户资料'; 269 else 270 tType:=2; 271 strFrom:='来自数据池('||V_FromDPID||')/查询'; 272 end if; 273 end if; 274 275 --所有不需要执行(与目标池客户重复)的打上标识:'1' 276 if(tType>=2)then 277 --除去在本身在目标池的 278 delete from nag_ids_temp where dp_id=V_ToDPID; 279 delete from nag_ids1_temp where dp_id=V_ToDPID; 280 --审核状态的不能流转 标记:1 281 update nag_ids_temp t set flag=1 282 where exists(select dpd_id from nag_datapooldata d where d.dpd_cm_id=t.cm_id and d.dpd_dp_id=t.dp_id and d.dpd_actstate=1 and d.dpd_auditstate=1); 283 end if; 284 --数据唯一检查:数据本身在目标池 不需要执行的 标记:1 285 update nag_ids_temp set flag=1 where dp_id=V_ToDPID ; 286 update nag_ids1_temp set flag=1 where dp_id=V_ToDPID ; 287 --数据唯一检查:与目标池数据重复 标记:1 288 update nag_ids_temp set flag=1 289 where exists (select dpd_cm_id from nag_datapooldata where dpd_dp_id=V_ToDPID and dpd_cm_id=cm_id and dpd_actstate=1); 290 --数据池中唯一检查:与目标池同类型池唯一(排除原池) 重复标记:1 291 if(onlyOne>0)then 292 --select dp_pooltype into xnum from nag_datapool where dp_id=V_ToDPID; 293 select dp_pooltype , nvl(d_datapool,0) into xnum,ynum from nag_datapool left join nag_dictionary on d_id=dp_pooltype where dp_id=V_ToDPID; 294 --数据唯一检查:此类型的池是否检查唯一性 295 if(ynum<1)then 296 if(tType>=2)then--来自数据池 297 update nag_ids_temp t set flag=1 298 where exists (select dpd_cm_id from nag_datapooldata d,nag_datapool p where p.dp_id!=t.dp_id and p.dp_id=d.dpd_dp_id and p.dp_pooltype=xnum and d.dpd_cm_id=t.cm_id and d.dpd_actstate=1); 299 else --来自客户资料(没有池ID) 300 update nag_ids_temp t set flag=1 301 where exists (select dpd_cm_id from nag_datapooldata d,nag_datapool p where p.dp_id!=V_ToDPID and p.dp_id=d.dpd_dp_id and p.dp_pooltype=xnum and d.dpd_cm_id=t.cm_id and d.dpd_actstate=1); 302 end if; 303 end if; 304 end if; 305 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 285 update '||sql%rowcount); 306 --===========================================如果没有可转移数据,跳到结束执行====================================================-- 307 select count(cm_id) into OutRow from nag_ids_temp where flag=0; 308 if(OutRow=0)then 309 OutRow:=-900099; 310 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 290 可操作数量为0'); 311 goto endExc; 312 end if; 313 314 --数据池类型:1自动抽取,2平均分配,3自定义分配,4资源分配,5自定义抽取 315 select dp_dataassign into fenp from nag_datapool where dp_id=V_ToDPID; 316 select dp_name into dpname from nag_datapool where dp_id=V_ToDPID; 317 318 execute immediate 'truncate table nag_allids_temp'; 319 --用户的可分配数量 (uid,可分配数,已分配数) --v_userdatadistribute 代替 320 insert into nag_allids_temp(all_id,tag5,tag6) 321 select u_id,leftnum, 0 from v_userdatadistribute where dp_id=V_ToDPID; 322 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 299 into '||sql%rowcount); 323 324 --=============================================上面数据已准备,下面开始分配======================================================-- 325 326 --需要平均分配: 目标池为平均分配,且 不保留归属并且没有指定目标用户 327 if(fenp=2 and (tType<2 or (V_KH=0 and (V_ToUID<100 or V_ToUID is null)))) then --平均分配 328 begin 329 gid:=null; 330 --根据目标池成员删除临时表非目标池成员的数据,删除非池成员 331 delete from nag_allids_temp a where not exists(select pu.dpu_u_id from nag_datapooluser pu where pu.dpu_dp_id=V_ToDPID and pu.dpu_u_id=a.all_id); 332 --有归属的更新数量,防止超限 333 update nag_allids_temp a set tag5=(select a.tag5+count(cm_id) from nag_ids_temp t where t.u_id=a.all_id and flag=0); 334 --用户数 335 select count(*) into ynum from nag_allids_temp; 336 --可分配总量 337 select sum(tag5) into xnum from nag_allids_temp; 338 339 --循环分配 340 znum:=0; --第几轮 341 for cur in newdatas loop 342 exit when xnum=0 and ynum<1; 343 unum:=0; 344 --找第znum轮还有没分配的,或者下一轮的 345 select count(*) into pnum from nag_allids_temp where tag6=znum and tag5>0; 346 347 if(pnum>0)then --本轮有 348 select all_id into unum from nag_allids_temp where rownum<2 and tag6=znum and tag5>0; 349 350 else --得进入下一轮 351 znum:=znum+1; 352 select count(*) into pnum from nag_allids_temp where tag6=znum and tag5>0; 353 354 if(pnum<1)then exit; end if;--没人可分配了,退出 355 select all_id into unum from nag_allids_temp where rownum<2 and tag6=znum and tag5>0; 356 357 end if; 358 359 --没人要分配了,退出 360 if(unum=0)then exit; end if; 361 362 --分配,在临时表,并记录 363 update nag_allids_temp set tag6=tag6+1,tag5=tag5-1 where all_id=unum; --记录,并进入下一轮待命 364 update nag_ids_temp set u_id=unum where cm_id=cur.cm_id; 365 366 xnum:=xnum-1; 367 368 end loop; 369 370 --操作日志/消息 371 for ur in dusers loop 372 if(ur.tag6>0)then 373 --操作日志 374 insert into nag_system_log(sl_u_id,sl_type,sl_module,sl_content) 375 values(V_ActUID,'数据转移','平均分配('||dpname||'-池:ID-'||V_ToDPID||'),'||strFrom,'因平均分配规则,给用户['||ur.all_id||']分配了'||ur.tag6||'条数据'); 376 377 --消息(系统消息) 378 insert into nag_messages(m_type,m_from,m_to,m_msg) 379 values(4,V_ActUID,ur.all_id,'你的平均分配数据池('||dpname||')新增了'||ur.tag6||'条数据<a href=''#'' onclick="parent.window.OpenTab('''||dpname||''',''/DataPool/DataPoolShow?FNID=3000'||'&'||'DPID='||V_ToDPID||'&'||'BATCH='||pici||''',true)">查看</a>'); 380 end if; 381 382 end loop; 383 384 --有剩余数据的操作日志/消息 385 select count(*) into xnum from nag_ids_temp where u_id is not null and flag=0;--已分配量 386 select count(*) into tnum from nag_ids_temp where u_id is null and flag=0;--剩余量 387 if(tnum>0)then 388 insert into nag_system_log(sl_u_id,sl_type,sl_module,sl_content) 389 values(V_ActUID,'数据转移','平均分配池('||dpname||' ID='||V_ToDPID||'),'||strFrom,'由平均分配规则,给('||dpname||')的'||ynum||'个用户分配了:'||xnum||'条数据,剩余:'||tnum||'条数据未分配,成为公共数据'); 390 end if; 391 392 --给执行者报告 393 insert into nag_messages(m_type,m_from,m_to,m_msg) 394 values(4,V_ActUID,V_ActUID,'你给平均分配池('||dpname||' ID='||V_ToDPID||')的'||ynum||'个用户分配了:'||xnum||'条数据,剩余:'||tnum||'条数据未分配,成为公共数据'); 395 396 end;--平均分配块结束 397 ----------------------------------------------------比例分配------------------------------------- 398 --需要比例分配: 目标池为比例分配,且 不保留归属并且没有指定目标用户 399 --数据池中-转入数据池-保留数据归属(不打勾),并且是清除数据数据归属是才满足比例分配 400 elsif (fenp=6 and (V_KH=0 and (V_ToUID<100 or V_ToUID is null))) then 401 begin 402 --比例分配 403 select count(*) into hastemp from user_tables where table_name=upper('TEMP_PRORATE_'||V_ActUID); 404 if(hastemp)>0 then 405 execute immediate 'drop table TEMP_PRORATE_'||V_ActUID||' purge '; 406 end if; 407 select count(*) into hastemp from user_tables where table_name=upper('TEMP_PRORATE_EXT'||V_ActUID); 408 if(hastemp>0) then 409 execute immediate 'drop table TEMP_PRORATE_EXT'||V_ActUID||' purge '; 410 end if; 411 --删除没有分配量的用户 412 delete from nag_allids_temp where tag5<1; 413 --用户,等级,比例 414 execute immediate 'create table TEMP_PRORATE_'||V_ActUID||'(DPU_U_ID,U_LEVEL,DPL_RATIOCOUNT) 415 as select DPU_U_ID,U_LEVEL,DPL_RATIOCOUNT from nag_datapooluser inner join nag_user on dpu_u_id=u_id 416 left join NAG_DATAPOOLLIMIT on dpl_dp_id=dpu_dp_id and dpl_level=U_LEVEL 417 where dpu_dp_id='||V_ToDPID||' and exists(select 1 from nag_allids_temp atp where atp.all_id=dpu_u_id) '; 418 --等级,比例,成员数 419 execute immediate 'create table TEMP_PRORATE_EXT'||V_ActUID||'(DPL_LEVEL,DPL_RATIOCOUNT,U_COUNT) as select DPL_LEVEL,DPL_RATIOCOUNT,(select count(1) from TEMP_PRORATE_'||V_ActUID||' tee where tee.U_LEVEL=nmt.DPL_LEVEL) as U_COUNT from NAG_DATAPOOLLIMIT nmt where dpl_dp_id='||V_ToDPID||''; 420 --查看有成员数的比例是不是大于0 421 execute immediate ' select sum(DPL_RATIOCOUNT) from TEMP_PRORATE_EXT'||V_ActUID||' where U_COUNT>0' into SUM_DPL_RATIOCOUNT; 422 if(SUM_DPL_RATIOCOUNT<1)then--没有任何的比例用来分配 423 OutRow:=-900012; 424 goto endExc; 425 end if; 426 --删除没有比例的用户 427 execute immediate 'delete from TEMP_PRORATE_'||V_ActUID||' where DPL_RATIOCOUNT<1'; 428 execute immediate 'select count(1) from TEMP_PRORATE_'||V_ActUID||' ' into hastemp; 429 if hastemp<1 then 430 OutRow:=-900013; 431 goto endExc; 432 end if; 433 --删除没有比例的等级 434 execute immediate 'delete from TEMP_PRORATE_EXT'||V_ActUID||' where U_COUNT<1 or DPL_RATIOCOUNT<0.00000001 '; 435 V_SUMRATIONCOUNT:=0; 436 --开始计算总量 437 open Prorete_Cursor for 'select DPL_RATIOCOUNT,U_COUNT from TEMP_PRORATE_EXT'||V_ActUID||''; 438 loop 439 fetch Prorete_Cursor into V_DPL_RATIOCOUNT_TEMP,V_U_COUNT_TEMP; 440 exit when Prorete_Cursor%notfound; 441 V_SUMRATIONCOUNT:=V_SUMRATIONCOUNT+(V_DPL_RATIOCOUNT_TEMP*V_U_COUNT_TEMP); 442 end loop; 443 close Prorete_Cursor; 444 --临时表可分配的数量 445 select count(1) into hastemp from nag_ids_temp where flag=0; 446 --计算出比例最小基数 447 V_BASECOUNT:=hastemp/V_SUMRATIONCOUNT; 448 449 open Prorete_Cursor for 'select DPU_U_ID,DPL_RATIOCOUNT from TEMP_PRORATE_'||V_ActUID||''; 450 loop 451 fetch Prorete_Cursor into V_DPU_U_ID_TEMP,V_DPL_RATIOCOUNT_TEMP; 452 exit when Prorete_Cursor%notfound or hastemp<1; 453 V_U_ID_GETCOUNT:=V_DPL_RATIOCOUNT_TEMP*V_BASECOUNT; 454 --判断是否小数点进1 455 if(V_U_ID_GETCOUNT>trunc(V_U_ID_GETCOUNT)) then 456 V_U_ID_GETCOUNT:=trunc(V_U_ID_GETCOUNT)+1; 457 end if; 458 --用户可分配量写入临时变量 459 select tag5 into V_U_ID_KFP from nag_allids_temp where all_id=V_DPU_U_ID_TEMP; 460 if V_U_ID_GETCOUNT>V_U_ID_KFP then 461 V_U_ID_GETCOUNT:=V_U_ID_KFP; 462 end if; 463 update nag_ids_temp set u_id=V_DPU_U_ID_TEMP where rownum<V_U_ID_GETCOUNT+1 and flag=0 and u_id is null; 464 hastemp:=hastemp-V_U_ID_GETCOUNT; 465 end loop; 466 close Prorete_Cursor; 467 468 /*select * from v_userdatadistribute*/ 469 /*insert into strtable values('比例分配'||(select count(1) from nag_ids_temp where flag=1) );*/ 470 end; 471 --------------------------------------比例分配结束----------------------------------------------- 472 else --=================================非平均分配=============================================-- 473 begin 474 if(V_KH=0)then --不保留归属 475 begin 476 update nag_ids_temp set u_id=null;--清除归属 477 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 365 update '||sql%rowcount); 478 --指定到人的话,数据限制适配 479 if(d_ToUID>100)then 480 select count(*) into tnum from nag_allids_temp t where t.tag5>0 and t.all_id=d_ToUID; 481 if(tnum=0)then 482 OutRow:=-999999; --数据量达到限额 483 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 370 数据量达到限额 '); 484 rollback; 485 return; 486 end if; 487 --分配,不超过剩余可分配数 488 select tag5 into tnum from nag_allids_temp where all_id=d_ToUID; 489 update nag_ids_temp set u_id=d_ToUID where flag=0 and rownum<=tnum; 490 tnum:=sql%rowcount; 491 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 378 update '||sql%rowcount); 492 --超过的数据量,不转移 493 --delete from nag_ids_temp where u_id is null; 494 update nag_ids_temp set flag=2 where u_id is null; 495 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 380 delete '||sql%rowcount); 496 --发消息(系统消息) 497 insert into nag_messages(m_type,m_from,m_to,m_msg) 498 values(4,V_ActUID,d_ToUID,'你的数据池('||dpname||')新增了'||tnum||'条数据<a href=''#'' onclick="parent.window.OpenTab('''||dpname||''',''/DataPool/DataPoolShow?FNID=3000'||'&'||'DPID='||V_ToDPID||'&'||'BATCH='||pici||''',true)">查看</a>'); 499 end if; 500 501 --操作日志 502 insert into nag_system_log(sl_u_id,sl_type,sl_module,sl_content) 503 values(V_ActUID,'数据转移','指定分配('||dpname||'-池:ID='||V_ToDPID||'),'||strFrom,'给用户[ID='||d_ToUID||']分配了:'||tnum||'条数据,总数为:'||xnum||'条'); 504 505 end;--不保留归属块结束 506 else --保留归属 507 begin 508 gid:=null; 509 if(tType<2)then --来自客户表(或自动外拨) 510 if(tType=1)then 511 --或许已经有归属了,就保留归属转入池 512 update nag_customer c set cm_holderid=( 513 select u.u_id from nag_user u where c.cm_holder = u.u_agentid 514 )where c.cm_holderid is null and exists(select 1 from nag_ids_temp t where c.cm_id=t.cm_id); 515 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 397 update '||sql%rowcount); 516 --客户归属有的,保留其归属 517 update (select t.u_id,c.cm_holderid from nag_ids_temp t,nag_customer c where t.cm_id=c.cm_id) set u_id=cm_holderid; 518 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 400 update '||sql%rowcount); 519 end if; 520 --如果是第一次入池,记录 521 /* update nag_customer set CM_DATAPOOLID=V_ToDPID 522 where CM_DATAPOOLID is null and cm_id in (select cm_id from nag_ids_temp where flag=0);*/ 523 --edit person xy 2016/3/1 524 update nag_customer nr set CM_DATAPOOLID=V_ToDPID 525 where CM_DATAPOOLID is null and exists(select 1 from nag_ids_temp where flag=0 and cm_id=nr.cm_id); 526 527 else --来自数据池 528 update nag_ids_temp t set t.u_id=(select dpd_u_id from nag_datapooldata d where t.cm_id=d.dpd_cm_id and t.dp_id=d.dpd_dp_id and d.dpd_actstate=1 and rownum<2); 529 /* 530 merge into nag_ids_temp t 531 using nag_datapooldata d on(t.cm_id=d.dpd_cm_id and t.dp_id=d.dpd_dp_id and d.dpd_actstate=1) 532 when matched then 533 update set t.u_id=d.dpd_u_id; 534 */ 535 end if; 536 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 413 insert pool '||sql%rowcount); 537 538 end;--保留归属块结束 539 end if;--是否保留归属 540 541 end;--非平均分配块结束 542 end if; --是否需要平均分配 543 544 --超限的不转移 (修复剩余量小于0的不限制情况) 545 update nag_ids_temp tt set flag=2 546 where exists(--是否存在超限,或已超限 547 select cm_id from ( 548 select t.cm_id,t.u_id,a.tag5,row_number() over(partition by t.u_id order by t.u_id) rnum 549 from nag_ids_temp t,nag_allids_temp a where t.u_id=a.all_id) A 550 where (A.rnum>A.tag5 or A.tag5<1) and A.u_id=tt.u_id and A.cm_id=tt.cm_id 551 ) and tt.u_id is not null; 552 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 429 update '||sql%rowcount); 553 554 --对保留归属(且有归属)的单条转移进行特殊判断 555 select count(cm_id) into xnum from nag_ids_temp; 556 if(xnum=1 and V_KH=1)then 557 select count(cm_id) into xnum from nag_ids_temp where u_id is not null;--有归属数量 558 select count(cm_id) into ynum from nag_ids_temp where u_id is not null and flag=0;--有归属且能转移数量 559 if( xnum>0 and ynum=0)then 560 OutRow:=-999999; 561 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 439 可操作数量为0'); 562 goto endExc; 563 end if; 564 end if; 565 566 select count(*) into ynum from nag_group where g_id=V_GID; 567 if(ynum<1)then --正确的组ID 568 gid:=null; 569 end if; 570 --=============================================上面数据已准备,下面开始转移======================================================-- 571 572 --删除标记已删除的数据 , 不管删除状态(dpd_actstate=0)了会有问题 573 --delete from nag_datapooldata dd where dd.dpd_actstate=0 and dd.dpd_dp_id=V_ToDPID 574 -- and exists (select cm_id from nag_ids_temp where cm_id=dd.dpd_cm_id and flag=0); 575 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 447 delete '||sql%rowcount); 576 --已分配的数据进池,未分配/剩余的也一起进池 577 if(tType<2)then --来自客户表 578 merge into nag_datapooldata 579 using (select pici PICI, t.cm_id ,t.u_id,u.u_agentid,u.u_agentname,(select wm_concat(g_name) from nag_group,nag_groupuser where gu_g_id=g_id and gu_u_id=t.u_id and g_pid>-1 group by gu_u_id) u_agentpartment 580 from nag_customer cm, nag_user u, nag_ids_temp t 581 where cm.cm_id=t.cm_id and t.u_id=u.u_id(+) and t.flag=0 582 )tt on (1=0) 583 when not matched then 584 insert (dpd_batch,dpd_createdate,dpd_dp_id,dpd_cm_id,dpd_u_id,DPD_AGENTID,DPD_AGENTNAME,dpd_agentpartment,dpd_gid) 585 values (tt.PICI,sysdate,V_ToDPID,tt.cm_id ,tt.u_id,tt.u_agentid,tt.u_agentname,u_agentpartment, gid); 586 587 else --来自数据池 588 if(d_DF>0)then --删除原池数据的 589 if(V_KH=1)then --保留归属的话 590 update nag_datapooldata d --2015/11/17 lzp 加快表数据量大时执行速度,原merge慢 591 set d.dpd_dp_id=V_ToDPID,d.dpd_batch=pici,d.dpd_createdate=sysdate 592 ,d.dpd_dialstate=0,d.dpd_dialstatestr='未拨打',d.dpd_dialstarttime=null,d.dpd_dialendtime=null,d.dpd_callresult=null,d.dpd_dialtimes=0 593 ,d.dpd_agentpartment=(select wm_concat(g_name) from nag_group,nag_groupuser where gu_g_id=g_id and gu_u_id=d.dpd_u_id and g_pid>-1 group by gu_u_id) 594 where DPD_ACTSTATE=1 and exists(select 1 from nag_ids_temp tt where tt.cm_id=d.dpd_cm_id and tt.flag=0 and d.dpd_dp_id=tt.dp_id); 595 596 else --不保留归属 597 update nag_datapooldata d --2015/11/17 lzp 加快表数据量大时执行速度,原merge慢 598 set d.dpd_dp_id=V_ToDPID,d.dpd_batch=pici,d.dpd_createdate=sysdate,d.dpd_allocdate=sysdate,d.DPD_ALLOCDAYNUM=1,d.dpd_gid=gid 599 ,d.dpd_dialstate=0,d.dpd_dialstatestr='未拨打',d.dpd_dialstarttime=null,d.dpd_dialendtime=null,d.dpd_callresult=null,d.dpd_dialtimes=0 600 ,(d.dpd_u_id,d.dpd_agentid,d.dpd_agentname,d.dpd_agentpartment) 601 =(select u.u_id,u.u_agentid,u.u_agentname,wm_concat(g_name) from nag_group g,nag_groupuser,nag_ids_temp t 602 left join nag_user u on t.u_id=u.u_id 603 where gu_g_id=g.g_id and gu_u_id=t.u_id and t.cm_id=d.dpd_cm_id and d.dpd_dp_id=t.dp_id and g.g_pid>-1 group by u.u_id,u.u_agentid,u.u_agentname) 604 where DPD_ACTSTATE=1 and exists(select 1 from (select t.cm_id,t.dp_id,t.u_id,u.u_agentid,u.u_agentname from nag_ids_temp t 605 left join nag_user u on t.u_id=u.u_id where t.flag=0)tt where tt.cm_id=d.dpd_cm_id and d.dpd_dp_id=tt.dp_id); 606 end if; 607 608 else --不删除原池数据 609 merge into nag_datapooldata 610 using (select pici PICI,t.cm_id ,t.u_id ,u.u_agentid ,u.u_agentname ,d.dpd_dialtel,(select wm_concat(g_name) from nag_group,nag_groupuser where gu_g_id=g_id and gu_u_id=t.u_id and g_pid>-1 group by gu_u_id) dpd_agentpartment,d.dpd_dialstate,d.dpd_dialstatestr,d.dpd_dialstarttime,d.dpd_dialendtime,d.dpd_recordfile,d.dpd_talklength,d.dpd_officiallength ,d.dpd_nextcalltime,d.dpd_callresult,d.dpd_summary,d.dpd_dialtimes,d.dpd_string1,d.dpd_string2,d.dpd_string3,d.dpd_string4,d.dpd_string5,d.dpd_string6,d.dpd_string7,d.dpd_string8,d.dpd_string9,d.dpd_string10,d.dpd_number1,d.dpd_number2,d.dpd_number3,d.dpd_number4,d.dpd_number5,d.dpd_number6,d.dpd_date1,d.dpd_date2,d.dpd_date3,d.dpd_date4,d.dpd_date5,d.dpd_comment1,d.dpd_comment2,d.dpd_comment3,d.dpd_comment4,d.dpd_comment5, d.dpd_actstate,d.dpd_act_u_id,d.dpd_actdate,d.dpd_allocdate,d.DPD_ALLOCDAYNUM 611 from nag_customer cm, nag_user u ,nag_datapooldata d, nag_ids_temp t 612 where cm.cm_id=t.cm_id and t.u_id=u.u_id(+) and t.flag=0 and t.dp_id=d.dpd_dp_id(+) and t.cm_id=d.dpd_cm_id(+) 613 )tt on (1=0) 614 when not matched then 615 insert (dpd_batch,dpd_dp_id,dpd_cm_id,dpd_u_id,DPD_AGENTID,DPD_AGENTNAME ,dpd_dialtel,dpd_agentpartment,dpd_dialstate,dpd_dialstatestr,dpd_dialstarttime,dpd_dialendtime,dpd_recordfile,dpd_talklength,dpd_officiallength ,dpd_nextcalltime,dpd_callresult,dpd_summary,dpd_dialtimes,dpd_string1,dpd_string2,dpd_string3,dpd_string4,dpd_string5,dpd_string6,dpd_string7,dpd_string8,dpd_string9,dpd_string10,dpd_number1,dpd_number2,dpd_number3,dpd_number4,dpd_number5,dpd_number6,dpd_date1,dpd_date2,dpd_date3,dpd_date4,dpd_date5,dpd_comment1,dpd_comment2,dpd_comment3,dpd_comment4,dpd_comment5,dpd_createdate,dpd_actstate,dpd_act_u_id,dpd_actdate,dpd_allocdate,DPD_ALLOCDAYNUM, dpd_gid) 616 values (tt.PICI,V_ToDPID,tt.cm_id ,tt.u_id ,tt.u_agentid ,tt.u_agentname ,tt.dpd_dialtel,tt.dpd_agentpartment,tt.dpd_dialstate,tt.dpd_dialstatestr,tt.dpd_dialstarttime,tt.dpd_dialendtime,tt.dpd_recordfile,tt.dpd_talklength,tt.dpd_officiallength ,tt.dpd_nextcalltime,tt.dpd_callresult,tt.dpd_summary,tt.dpd_dialtimes,tt.dpd_string1,tt.dpd_string2,tt.dpd_string3,tt.dpd_string4,tt.dpd_string5,tt.dpd_string6,tt.dpd_string7,tt.dpd_string8,tt.dpd_string9,tt.dpd_string10,tt.dpd_number1,tt.dpd_number2,tt.dpd_number3,tt.dpd_number4,tt.dpd_number5,tt.dpd_number6,tt.dpd_date1,tt.dpd_date2,tt.dpd_date3,tt.dpd_date4,tt.dpd_date5,tt.dpd_comment1,tt.dpd_comment2,tt.dpd_comment3,tt.dpd_comment4,tt.dpd_comment5,sysdate,tt.dpd_actstate,tt.dpd_act_u_id,tt.dpd_actdate,tt.dpd_allocdate,tt.DPD_ALLOCDAYNUM, gid); 617 end if; 618 --不保留归属,转到人的,清除组ID lzpong 2015/09/09 619 if (V_KH=0 and V_ToUID>100) then 620 update nag_datapooldata set dpd_gid=null 621 where dpd_dp_id=V_ToDPID and dpd_gid is not null and dpd_u_id is not null and dpd_actstate=1 622 and exists(select 1 from nag_ids_temp t where t.u_id=dpd_u_id and t.cm_id=dpd_cm_id); 623 end if; 624 end if;--数据流转 625 OutRow:=sql%rowcount; 626 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 487 merge into pool '||sql%rowcount); 627 628 --=============================================数据已转移成功,下面后续动作======================================================-- 629 630 if(OutRow>0)then 631 --不保留拨打状态,非未拨打的改为callBack 632 if(V_KCS=0 and tType>1)then 633 update nag_datapooldata set DPD_DIALSTATE=2,DPD_DIALSTATESTR='callback',dpd_callresult=null where dpd_batch=pici and DPD_DIALSTATE>0; 634 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3')||' 495 merge '||sql%rowcount); 635 end if; 636 --不保留归属 更新分配时间/持有天数 637 if(V_KH=0)then 638 update nag_datapooldata set dpd_allocdate=null,DPD_ALLOCDAYNUM=null where dpd_batch=pici and DPD_U_ID is null; --(无归属) 639 update nag_datapooldata set dpd_allocdate=sysdate,DPD_ALLOCDAYNUM=1 where dpd_batch=pici and dpd_u_id is not null;--(有归属) 640 end if; 641 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 502 update '||sql%rowcount); 642 if(d_DF=1)then 643 --更新流转记录历史(删除) 644 update nag_dataallcationhistory set dah_isdelete=1 645 where exists (select /*+ ORDERED USE_NL(nag_ids1_temp)*/ t1.cm_id from nag_ids1_temp t1,nag_ids_temp t where t1.dp_id=DAH_OUTCALLID and DAH_CUSTOMERID=t1.cm_id and t1.cm_id=t.cm_id and t.flag=0); 646 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 507 update '||sql%rowcount); 647 end if; 648 --添加流转到记录(入池) 649 merge into NAG_DATAALLCATIONHISTORY 650 using(select t.cm_id,u.u_agentid,u.u_agentname,u.U_ID from nag_ids_temp t 651 left join nag_user u on t.u_id=u.u_id where t.flag=0 652 )tt on (1=0) 653 when not matched then 654 insert (DAH_OUTCALLID, DAH_OUTCALLNAME, DAH_CUSTOMERID, DAH_AGENTID, DAH_AGENTNAME,DAH_CREATEBY,DAH_TYPE) 655 values (V_ToDPID,dpname,tt.cm_id,tt.u_agentid,tt.u_agentname,V_ActUID,strFrom); 656 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 517 merge '||sql%rowcount); 657 658 --操作日志/消息 659 if(fenp=1 and OutRow>1)then --是公共池,并防止拨打自动流转产生垃圾消息 660 insert into nag_system_log(sl_u_id,sl_type,sl_module,sl_content) 661 values(V_ActUID,'数据转移','自动抽取出池','给自动抽取池('||dpname||'),增加数据量:'||OutRow); 662 663 insert into nag_messages(m_type,m_from,m_to,m_msg) 664 select 4,V_ActUID,dpu_u_id,dpname||',迎来了一波公共数据,<a href=''#'' onclick="parent.window.OpenTab('''||dpname||''',''/DataPool/DataPoolShow?FNID=3000'||'&'||'DPID='||V_ToDPID||''',true)">立即前往抽取数据</a>' from nag_datapooluser where dpu_dp_id=V_ToDPID; 665 666 --elsif(fenp=3)then --自定义池 667 -- null; --通知谁去分配数据 668 end if; 669 --操作日志/消息,分配到组的 670 if(gid is not null)then 671 select g_name into str1 from nag_group where g_id=gid; 672 select u_agentname||'转入数据池'||dpname||'['||OutRow||'] 条数据,并分配给组['||str1||']成为组公共数据; '||strFrom into str1 from nag_user where u_id=V_ActUID; 673 674 insert into nag_system_log(sl_u_id,sl_type,sl_module,sl_content) 675 values( V_ActUID, '新组公共数据', '数据转移', str1); 676 677 insert into nag_messages(m_type,m_from,m_to,m_title,m_msg) 678 select 5,V_ActUID, gm_u_id ,'新数据到组(组公共数据)',str1 from nag_groupmanger where gm_g_id=gid; 679 680 insert into NAG_DATATOGROUPUSERHISTORY 681 values (V_ToDPID,gid,null,OutRow,sysdate,V_ActUID); 682 end if; 683 684 --如果流转成功,更新关注共享? 685 if(tType>=2)then 686 --更新关注?用户在目标池内 687 select sp_param1 into xnum from nag_sysparam where sp_id=16;--数据流转时更新关注 688 if xnum is not null and xnum=1 689 then 690 merge into NAG_CUSTOMERATTENTION using nag_ids_temp on(flag=0 and ca_cm_id=cm_id and ca_dp_id=dp_id) 691 when matched then update set ca_u_id=0 delete where 1=1; 692 693 merge into NAG_CUSTOMERATTENTIONHISTORY using nag_ids_temp on(flag=0 and cah_cm_id=cm_id and cah_dp_id=dp_id) 694 when matched then update set CAH_ENDDATETIME=sysdate; 695 end if; 696 --存在共享,更新共享? 697 select sp_param1 into xnum from nag_sysparam where sp_id=15;--池中已共享的数据流转时更新共享 698 if xnum is not null and xnum=1 699 then 700 merge into NAG_CUSTOMERSHARE using nag_ids_temp on(flag=0 and cs_cm_id=cm_id and cs_dp_id=dp_id) 701 when matched then update set cs_from_u_id=0 delete where 1=1; 702 703 merge into NAG_CUSTOMERSHAREHISTORY using nag_ids_temp on(flag=0 and csh_cm_id=cm_id and csh_dp_id=dp_id) 704 when matched then update set CSH_ENDDATETIME=sysdate; 705 end if; 706 v_strMsg:=v_strMsg||chr(10)||(to_char(systimestamp,'hh24:mi:ssxff3') ||' 562 merge '||sql%rowcount); 707 end if; --更新关注共享 708 709 end if; --if(OutRow>0) 710 commit; 711 -----------------最后,提交更改----------------- 712 <<endExc>> 713 --记录执行日志 714 tnum:=(sysdate-bgDate)*48600; 715 --if ((tnum>0 and OutRow>1)) then 716 v_strMsg:=strFrom||chr(10)||v_strMsg; 717 insert into T_CUSTOPOOL_PARAM( t_idw, t_fromdpid, t_todpid, t_kh, t_df, t_kcs, t_touid, t_actuid, t_outrow, t_date,t_Times,t_msg) 718 values(substr(V_IDW,1,3985)||'...', V_FromDPID, V_ToDPID, V_KH, V_DF, V_KCS, d_ToUID, V_ActUID, OutRow, sysdate, tnum, substr(v_strMsg,1,3999)); 719 commit; 720 dbms_output.put_line(v_strMsg); 721 --end if; 722 723 end if; 724 725 exception 726 when others then 727 OutRow:=SQLCODE; 728 IF(OutRow>0)THEN OutRow:=-OutRow;END IF; 729 dbms_output.put_line(SQLCODE||'---'||SQLERRM); 730 rollback; 731 --调用日志记录 732 v_strMsg:=strFrom||chr(10)||'SQL ERRCODE:'||SQLERRM||chr(10)||v_strMsg||chr(10)||dbms_utility.format_error_backtrace; 733 insert into T_CUSTOPOOL_PARAM( t_idw, t_fromdpid, t_todpid, t_kh, t_df, t_kcs, t_touid, t_actuid, t_outrow, t_date,t_Msg,t_Times) 734 values(substr(V_IDW,1,3985)||'...', V_FromDPID, V_ToDPID, V_KH, V_DF, V_KCS, d_ToUID, V_ActUID, OutRow,sysdate,substr(v_strMsg,1,3999),(sysdate-bgDate)*48600); 735 commit; 736 dbms_output.put_line(v_strMsg); 737 738 end NAG_CUSTOMER_TOPOOLW;
当然了 , 也很大!!
不过速度还是很快的啦!!!
其中一个视图 v_userdatadistribute:
1 create or replace view v_userdatadistribute as 2 with Q1 as( 3 --U_ID,U_AGENTID,U_AGENTNAME,DP_ID,DP_NAME --用户,数据池(已结束除外) 4 select u_id,u_agentid,u_agentname,dp_id,dp_name,u_level,dp_islimit,u_maxdatacount U_MAXDATANUM from nag_user,nag_datapool where dp_start<2 5 ),Q2 as( 6 --DP_ID,UID,DP_TOTALCOUNT --用户各池数据总量 7 select dpd_dp_id dp_id,dpd_u_id u_id,count(dpd_id) DP_TOTALCOUNT from nag_datapooldata,nag_datapool where dp_id=dpd_dp_id and dpd_u_id>0 and dpd_actstate>0 group by dpd_dp_id,dpd_u_id 8 ),Q3 as( 9 --UID,U_LEVEL,DPID,DP_TOTALCOUNT --用户受限数据池数量限制量 10 select u_id,dpu_dp_id dp_id,dpl_totalcout DPL_DATANUM from nag_user,nag_datapooluser,nag_datapoollimit,nag_datapool where u_level=dpl_level and u_id=dpu_u_id and dpl_dp_id=dpu_dp_id and dpl_dp_id=dp_id and dp_islimit>0 11 ),Q4 as( 12 --U_ID,U_DATACOUNT --用户受限池的总数据量 13 --select u_id,sum(DP_TOTALCOUNT) U_TOTALCOUNT from Q2 group by u_id --貌似这个更慢? 14 select dpd_u_id u_id, count(dpd_id) U_TOTALCOUNT from nag_datapooldata,nag_datapool where dp_id=dpd_dp_id and dp_islimit>0 and dpd_actstate>0 and dpd_u_id>0 group by dpd_u_id 15 ),Q as( 16 select Q1.u_id,Q1.u_agentid,Q1.u_agentname,Q1.dp_id,Q1.dp_name,Q1.u_level,Q1.dp_islimit 17 ,(case when Q1.U_MAXDATANUM is null or Q1.dp_islimit=0 then 9999999999 else Q1.U_MAXDATANUM end) U_MAXDATANUM --非池成员或是没有相应等级(包括是/否池成员)或非限制池的不限制 18 ,nvl(Q3.DPL_DATANUM,9999999999) DPL_DATANUM --没有等级的不限制 19 ,nvl(Q4.U_TOTALCOUNT,0) U_TOTALCOUNT --用户拥有数据量(不包括受限池) 20 ,nvl(Q2.DP_TOTALCOUNT,0) DP_TOTALCOUNT --池拥有数据量 21 from Q1 22 left join Q2 on Q1.u_id=Q2.u_id and Q1.dp_id=Q2.dp_id 23 left join Q3 on Q1.u_id=Q3.u_id and Q1.dp_id=Q3.dp_id 24 left join Q4 on Q1.u_id=Q4.u_id 25 ) 26 select Q.U_ID,Q.U_AGENTID,Q.U_AGENTNAME,Q.DP_ID,Q.DP_NAME,Q.U_LEVEL,Q.dp_islimit,Q.U_MAXDATANUM,Q.DPL_DATANUM,Q.U_TOTALCOUNT,Q.DP_TOTALCOUNT 27 ,case when Q.dp_islimit=0 then 9999999999 else Q.U_MAXDATANUM-Q.U_TOTALCOUNT end u_leftnum --用户剩余量 28 ,case when Q.dp_islimit=0 then 9999999999 else Q.DPL_DATANUM-Q.DP_TOTALCOUNT end dp_leftnum --池剩余量 29 ,case when Q.dp_islimit=0 then 9999999999 else least((Q.U_MAXDATANUM-Q.U_TOTALCOUNT),(Q.DPL_DATANUM-Q.DP_TOTALCOUNT)) end leftnum --可用量 30 from Q--这些情况数据不受限: 池不参与数据限制; 不是池成员; 是池成员但是没有对应的等级 31 ;
执行日志表:
1 create table T_CUSTOPOOL_PARAM 2 ( 3 t_idw VARCHAR2(4000), --条件参数(以下如同) 4 t_fromdpid VARCHAR2(40), 5 t_todpid VARCHAR2(40), 6 t_kh NUMBER, 7 t_df NUMBER, 8 t_kcs NUMBER, 9 t_touid NUMBER, 10 t_actuid NUMBER, 11 t_outrow NUMBER, --结果 12 t_date DATE default sysdate, --时间 13 t_msg VARCHAR2(4000), --异常等消息 14 t_times NUMBER --耗时,毫秒 15 );