定时处理欢迎语业务

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/service/HaobanTimerApiService.java

@@ -99,5 +99,10 @@ public interface HaobanTimerApiService {
     * @throws
      */
     public ServiceResponse<Void> ownerDimission(String params);
+    
+    /**
+     * 定时处理欢迎语后的好友
+     */
+    public ServiceResponse<Void> welcomeForMember(String params);
 
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/ExternalMemberLogMapper.java

 package com.gic.haoban.manage.service.dao.mapper;
 
+import java.util.Date;
+import java.util.List;
+
 import org.apache.ibatis.annotations.Param;
 
 import com.gic.haoban.manage.service.entity.TabExternalMemberLog;
@@ -22,5 +25,7 @@ public interface ExternalMemberLogMapper {
 
     public TabExternalMemberLog selectRelationKey(@Param("enterpriseId") String enterpriseId,
             @Param("relationKey") String relationKey);
+    
+    public List<TabExternalMemberLog> listForTimer(@Param("start")Date start , @Param("end")Date end) ;
 
 }
\ No newline at end of file

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/ExternalMemberService.java

@@ -11,4 +11,6 @@ public interface ExternalMemberService {
 
     public TabExternalMemberLog selectRelationKey(String enterpriseId, String relationKey);
 
+    public void welcomeForMember();
+
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/impl/ExternalMemberServiceImpl.java

 package com.gic.haoban.manage.service.service.impl;
 
+import java.util.Date;
+import java.util.List;
+
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import com.gic.commons.util.DateUtil;
 import com.gic.commons.util.EntityUtil;
 import com.gic.commons.util.UniqueIdUtils;
 import com.gic.haoban.manage.api.dto.ExternalMemberLogDTO;
 import com.gic.haoban.manage.service.dao.mapper.ExternalMemberLogMapper;
+import com.gic.haoban.manage.service.dao.mapper.TabHaobanExternalClerkRelatedMapper;
 import com.gic.haoban.manage.service.entity.TabExternalMemberLog;
+import com.gic.haoban.manage.service.entity.TabHaobanExternalClerkRelated;
 import com.gic.haoban.manage.service.service.ExternalMemberService;
+import com.gic.member.api.dto.MemberDTO;
+import com.gic.member.api.service.MemberOpenCardBusinessService;
+import com.gic.member.api.service.MemberService;
 
 @Service
 public class ExternalMemberServiceImpl implements ExternalMemberService {
 
     @Autowired
     private ExternalMemberLogMapper externalMemberLogMapper;
+    @Autowired
+    private MemberOpenCardBusinessService memberOpenCardBusinessService ;
+    @Autowired
+    private TabHaobanExternalClerkRelatedMapper tabHaobanExternalClerkRelatedMapper ;
+    @Autowired
+    private MemberService memberService ;
 
     @Override
     public int insert(ExternalMemberLogDTO log) {
@@ -38,5 +54,32 @@ public class ExternalMemberServiceImpl implements ExternalMemberService {
         TabExternalMemberLog log = this.externalMemberLogMapper.selectRelationKey(enterpriseId, relationKey);
         return log;
     }
+    
+    @Override
+    public void welcomeForMember() {
+        Date end = DateUtil.getStartTimeOfDay() ;
+        Date start = DateUtil.addNumForDay(end, -1) ;
+        List<TabExternalMemberLog> list = this.externalMemberLogMapper.listForTimer(start, end) ;
+        for(TabExternalMemberLog log : list) {
+            String relationKey = log.getRelationKey() ;
+            TabHaobanExternalClerkRelated related = tabHaobanExternalClerkRelatedMapper.getByRelationKey(relationKey,0);
+            if (related == null) {
+                continue ;
+            }
+            String enterpriseId = log.getEnterpriseId() ;
+            if(StringUtils.isNotEmpty(related.getMemberId())) {
+                this.externalMemberLogMapper.updateStatus(enterpriseId, log.getLogId(), 2) ;
+                continue ;
+            }
+          
+            String unionid = log.getUnionid() ;
+            MemberDTO member = this.memberService.getMemberByUnionid(unionid, enterpriseId) ;
+            if(null == member) {
+                continue ;
+            }
+            String memberId =member.getMemberId() ;
+            this.memberOpenCardBusinessService.memberClerkProcessByQywxFriend(enterpriseId, memberId, unionid, relationKey);
+        }
+    }
 
 }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/HaobanTimerApiServiceImpl.java

@@ -6,6 +6,7 @@ import org.springframework.stereotype.Service;
 import com.gic.api.base.commons.ServiceResponse;
 import com.gic.haoban.manage.api.service.HaobanTimerApiService;
 import com.gic.haoban.manage.service.service.ExternalClerkRelatedService;
+import com.gic.haoban.manage.service.service.ExternalMemberService;
 import com.gic.haoban.manage.service.service.StaffDepartmentRelatedService;
 import com.gic.haoban.manage.service.service.chat.GroupChatService;
 import com.gic.haoban.manage.service.service.hm.HmQrcodeTempService;
@@ -21,6 +22,9 @@ public class HaobanTimerApiServiceImpl implements HaobanTimerApiService {
     private StaffDepartmentRelatedService staffDepartmentRelatedService;
     @Autowired
     private GroupChatService groupChatService;
+    @Autowired
+    private ExternalMemberService externalMemberService ;
+    
 
     @Override
     public ServiceResponse<Void> deleteTempWxHm(String params) {
@@ -69,4 +73,10 @@ public class HaobanTimerApiServiceImpl implements HaobanTimerApiService {
         this.groupChatService.ownerDimission();
         return ServiceResponse.success();
     }
+    
+    @Override
+    public ServiceResponse<Void> welcomeForMember(String params) {
+        this.externalMemberService.welcomeForMember() ;
+        return ServiceResponse.success();
+    }
 }

haoban-manage3-service/src/main/resources/mapper/ExternalMemberLogMapper.xml

@@ -65,4 +65,9 @@
  	  where enterprise_id = #{enterpriseId} and relation_key=#{relationKey} limit 1
   </select>
   
+  <select id="listForTimer"  resultMap="result-map-tabHaobanExternalMemberLog">
+  	 SELECT <include refid="Base_Column_List" /> FROM tab_haoban_external_member_log 
+ 	  	where  create_time >= #{start}  and  create_time <![CDATA[ < ]]>  #{end} and status_flag = 1 
+  </select>
+  	
 </mapper> 
\ No newline at end of file