增加查询大b的方式

dxhy-core/src/main/java/com/dxhy/core/dao/mailGather/EmailMaintainDao.java

@@ -88,5 +88,6 @@ public interface EmailMaintainDao extends BaseMapper<EmailMaintainVo> {
 
 
     String getUserName(@Param("userCode") String userCode);
+    String getUserByUsername(@Param("username") String username);
 
 }

dxhy-core/src/main/java/com/dxhy/core/service/mailGather/EmailMaintainService.java

@@ -49,6 +49,7 @@ public interface EmailMaintainService {
     boolean deleteById(String id);
 
     String getUserName(String userCode);
+    String getUserByUsername(String username);
 
     int insertBatch(List<EmailMaintainVo> entities);
 

dxhy-core/src/main/java/com/dxhy/core/service/mailGather/impl/EmailMaintainServiceImpl.java

@@ -121,6 +121,13 @@ public class EmailMaintainServiceImpl implements EmailMaintainService {
         return emailMaintainDao.getUserName(userCode);
     }
 
+
+    @Override
+    public String getUserByUsername(String username) {
+        DynamicContextHolder.push("business_itax_read");
+        return emailMaintainDao.getUserByUsername(username);
+    }
+
     @Override
     public int insertBatch(List<EmailMaintainVo> entities) {
         return emailMaintainDao.insertBatch(entities);

dxhy-core/src/main/java/com/dxhy/core/task/SnEmailGatherTask.java

@@ -167,6 +167,12 @@ public class SnEmailGatherTask {
                     List<Map<String, String>> mapList = Lists.newArrayList();
                     EmailParseUtils.saveAttachment(msg, mapList);
                     log.debug("获取附件的数量："+mapList.size());
+                    if(StringUtils.isNotEmpty(maintainVo.getUserId())){
+                        String username = emailMaintainService.getUserByUsername(maintainVo.getUserId());
+                        if(StringUtils.isNotEmpty(username)){
+                            maintainVo.setUserId(username);
+                        }
+                    }
                     for (Map<String, String> map : mapList) {
                         map.put("emailName",emailName);
                         String pdfStream = map.get("pdfStream");
@@ -238,7 +244,7 @@ public class SnEmailGatherTask {
         mailGatherLogService.insert(gatherLogVo);
     }
 
-    public static Map<String, Object> convertToOcrResult(List<OpenServiceOcr> openServiceOcrs, Map<String, String> map,EmailMaintainVo maintainVo){
+    public Map<String, Object> convertToOcrResult(List<OpenServiceOcr> openServiceOcrs, Map<String, String> map,EmailMaintainVo maintainVo){
         List<OcrResultToyxVo> resultToyxVoList = Lists.newArrayList();
         Map<String, Object> hashMap = Maps.newHashMap();
         String batchId = String.valueOf(System.currentTimeMillis());
@@ -260,7 +266,6 @@ public class SnEmailGatherTask {
             resultToyxVo.setFileByte(map.get("pdfStream"));
             resultToyxVo.setEmail(map.get("emailName"));
             resultToyxVo.setEmployeeId(maintainVo.getUserId());
-
             resultToyxVoList.add(resultToyxVo);
         }
         hashMap.put("list",resultToyxVoList);

dxhy-core/src/main/resources/mapper/mailGather/EmailMaintainMapper.xml

@@ -165,6 +165,10 @@
         select username from sys_user where loginname = #{userCode}
     </select>
 
+    <select id="getUserByUsername" resultType="java.lang.String">
+        select code from sys_user where username = #{username}
+    </select>
+
     <select id="selectByEmail" resultType="java.lang.Integer">
         select count(1) from email_maintain where email_address = #{email}
     </select>