根据登录账号查询本地账号

mt
2023年7月6日17:45:54

@@ -15,29 +15,26 @@ import java.util.List;
 @Repository
 public interface SysUserRepository extends JpaSpecificationExecutor<SysUser>, JpaRepository<SysUser, Long> {
 
-
-
-
-    @Query(nativeQuery = true, value = "select TOP 1 * from t_au_user where login_name = ?1 ")
-    public SysUser findByLoginName(String loginName);
-
     /**
-     * 根据用户登录名list查询用户列表信息
+     * 根据登录名本地账号用户信息
      *
-     * @param loginNames
+     * @param loginName
      * @return
      */
-    @Query(nativeQuery = true, value = "select * from t_au_user where login_name IN (?1) ")
-    public List<SysUser> findUserListByLoginNames(List loginNames);
+    @Query(nativeQuery = true, value = "select top 1 * from t_au_user a where a.login_name = ?1 " +
+            "   and a.user_source_id in( " +
+            "    select id from dbo.T_BI_DICTIONARY_ENTRIES " +
+            "    where dict_code='userSourceCode' and code='LOCALUSER') ")
+    public SysUser findUserByLoginName(String loginName);
 
     /**
-     * 根据登录名查询单个用户信息
+     * 根据用户登录名list查询用户列表信息
      *
-     * @param loginName
+     * @param loginNames
      * @return
      */
-    @Query(nativeQuery = true, value = "select * from t_au_user where login_name = ?1")
-    public SysUser findUserByLoginName(String loginName);
+    @Query(nativeQuery = true, value = "select * from t_au_user where login_name IN (?1) ")
+    public List<SysUser> findUserListByLoginNames(List loginNames);
 
     @Query(nativeQuery = true, value = "select * from t_au_user where username = ?1")
     public List<SysUser> findByUserName(String userName);
@@ -74,5 +71,4 @@ public interface SysUserRepository extends JpaSpecificationExecutor<SysUser>, Jp
      */
     @Query(nativeQuery = true,value = "select ID from T_AU_USER where IS_VALID = 1 AND ORG_NAME = 'RDE' AND CONS_DISTRIBUTION = '2'")
     public List<BigDecimal> findByDistribution();
-
-}
+}
\ No newline at end of file

@@ -294,6 +294,7 @@ public class ChmConsignmentService {
             result.setUpdateTime(pushTime);
             if (!creator.equals("IDE-ICLEAR-API")){
                 SysUser sysUser = sysUserRepository.findUserByLoginName(creator);
+
                 result.setCreatorId(sysUser);
                 result.setCreator(sysUser.getLoginName());
             }
@@ -513,7 +514,7 @@ public class ChmConsignmentService {
             ChmConsignment chmConsignmentDB=this.findChmConsignmentByConsignmentCode(chmConsignment.getConsignmentCode(), DateUtils.addDate(DateUtils.getCurrentDate(),-7));
 
             //获取用户账号信息
-            SysUser sysUser = sysUserRepository.findByLoginName("CUSTOMS");
+            SysUser sysUser = sysUserRepository.findUserByLoginName("CUSTOMS");
             //设置当前运单创建人ID
             chmConsignment.setCreatorId(sysUser);
             //设置创建人名称