朋友圈

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

@@ -42,7 +42,7 @@ public interface QwMomentPlanAttendMapper {
 
     TaskDetailDTO taskDetail(@Param("planId") Long planId, @Param("clerkId") String execClerkId);
 
-    TabQwMomentPlanAttend getByStaff(@Param("planId") Long planId, @Param("staffId") String staffId);
+    List<TabQwMomentPlanAttend> getByStaff(@Param("planId") Long planId, @Param("staffId") String staffId);
 
     List<TaskListWxaDTO> taskListWxa(TaskListWxaQDTO qdto);
 

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

@@ -492,7 +492,11 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
         TabQwMomentPlan plan = this.qwMomentPlanMapper.getById(planId) ;
         List< TabQwMomentPlanAttend> list = this.qwMomentPlanAttendMapper.listForData(planId) ;
         for(TabQwMomentPlanAttend item : list) {
-            this.getQwData(item , 0 , plan.getMomentId());
+            try {
+                this.getQwData(item, 0, plan.getMomentId());
+            }catch (Exception e) {
+                logger.info("异常",e);
+            }
         }
         CountBO bo = this.qwMomentPlanAttendMapper.getQwCount(planId) ;
         if (null != bo && (null != bo.getLikeCount() || null != bo.getCommentCount())) {
@@ -589,17 +593,25 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
         cursor = dto.getNext_cursor();
         List<MomentUserDTO> list = dto.getTask_list() ;
         for (MomentUserDTO item : list) {
-            String userid = item.getUserid() ;
-            int chatStatus = item.getPublish_status() ;
-            if(chatStatus==1) {
-                TabHaobanStaff staff = this.staffMapper.selectByUserIdAndEnterpriseId(userid, wxEnterpriseId);
-                if(null != staff) {
-                    String staffId = staff.getStaffId();
-                    TabQwMomentPlanAttend attend = this.qwMomentPlanAttendMapper.getByStaff(planId, staffId);
-                    if(attend.getTaskStatus()==1) {
-                       this.qwMomentPlanAttendService.finishTaskUpdateData(attend.getAttendId(),attend.getPlanId(),new Date(),null) ;
+            try {
+                String userid = item.getUserid() ;
+                int chatStatus = item.getPublish_status() ;
+                if(chatStatus==1) {
+                    TabHaobanStaff staff = this.staffMapper.selectByUserIdAndEnterpriseId(userid, wxEnterpriseId);
+                    if(null != staff) {
+                        String staffId = staff.getStaffId();
+                        List<TabQwMomentPlanAttend> tabList = this.qwMomentPlanAttendMapper.getByStaff(planId, staffId);
+                        if(CollectionUtils.isNotEmpty(tabList)) {
+                            for(TabQwMomentPlanAttend attend :tabList) {
+                                if(attend.getTaskStatus()==1) {
+                                    this.qwMomentPlanAttendService.finishTaskUpdateData(attend.getAttendId(),attend.getPlanId(),new Date(),null) ;
+                                }
+                            }
+                        }
                     }
                 }
+            }catch (Exception e) {
+                logger.info("异常",e);
             }
         }
         // 从企微拉取下一批数据
@@ -617,7 +629,11 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
             List<Long> planIdList = this.qwMomentPlanMapper.listForData(1) ;
             if(CollectionUtils.isNotEmpty(planIdList)) {
                 for(Long planId : planIdList) {
-                    this.getQwPublishData(planId,null) ;
+                    try{
+                        this.getQwPublishData(planId,null) ;
+                    }catch (Exception e) {
+                        logger.info("异常",e);
+                    }
                 }
             }
         }
@@ -627,7 +643,11 @@ public class QwMomentPlanServiceImpl implements QwMomentPlanService {
             List<Long> planIdList = this.qwMomentPlanMapper.listForData(2) ;
             if(CollectionUtils.isNotEmpty(planIdList)) {
                 for(Long planId : planIdList) {
-                    this.getQwData(planId);
+                    try {
+                        this.getQwData(planId);
+                    }catch (Exception e) {
+                        logger.info("异常",e);
+                    }
                 }
             }
         }

haoban-manage3-service/src/main/resources/mapper/moment/qwMomentPlanAttendMapper.xml

@@ -160,7 +160,7 @@
         </if>
     </select>
     <select id="listForData" resultMap="result-map-tabHaobanQwMomentPlanAttend" parameterType="java.lang.Long">
-        select <include refid="Base_Column_List" /> from tab_haoban_qw_moment_plan_attend where plan_id =#{planId} and delete_flag = 0
+        select <include refid="Base_Column_List" /> from tab_haoban_qw_moment_plan_attend where plan_id =#{planId} and delete_flag = 0 and task_status = 2
     </select>
 
     <select id="getQwCount" resultType="com.gic.haoban.manage.service.pojo.bo.moment.CountBO">