diff --git a/src/weaver/interfaces/dito/mq/RocketmqUtil.java b/src/weaver/interfaces/dito/mq/RocketmqUtil.java
index 2e83c5d2..751cb163 100644
--- a/src/weaver/interfaces/dito/mq/RocketmqUtil.java
+++ b/src/weaver/interfaces/dito/mq/RocketmqUtil.java
@@ -1875,7 +1875,7 @@ public class RocketmqUtil {
 
                                 int status5count = 0;
                                 List<String> loginList = new ArrayList<String>();
-                                sql = " select id from hrmresource where loginid like '"+staffCode+"%' " ;
+                                sql = " select id from hrmresource where (loginid like '"+staffCode+"_cf_%' or loginid='"+staffCode+"') " ;
                                 bb.writeLog("loginidisnotnull-sql:" + sql);
                                 rs.executeQuery(sql);
                                 while (rs.next()) {
@@ -1938,7 +1938,7 @@ public class RocketmqUtil {
                             {
                                 int status5count = 0;
                                 List<String> loginList = new ArrayList<String>();
-                                sql = " select id from hrmresource where loginid like '"+staffCode+"%' " ;
+                                sql = " select id from hrmresource where (loginid like '"+staffCode+"_cf_%' or loginid='"+staffCode+"') " ;
                                 bb.writeLog("staff-sql:"+sql);
                                 rs.executeQuery(sql);
                                 while (rs.next()){
@@ -2011,7 +2011,7 @@ public class RocketmqUtil {
                                 {
                                     int status5count = 0;
                                     List<String> loginList = new ArrayList<String>();
-                                    sql = " select id from hrmresource where loginid like '"+staffCode+"%' " ;
+                                    sql = " select id from hrmresource where (loginid like '"+staffCode+"_cf_%' or loginid='"+staffCode+"')" ;
                                     bb.writeLog("staff-M-sql:"+sql);
                                     rs.executeQuery(sql);
                                     while (rs.next()){