定时任务

src/main/java/com/huiju/estateagents/job/JudglActivityTimeJob.java

 package com.huiju.estateagents.job;
 
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.huiju.estateagents.base.BaseController;
-import com.huiju.estateagents.base.ResponseBean;
-import com.huiju.estateagents.common.StringUtils;
-import com.huiju.estateagents.entity.HelpActivity;
-import com.huiju.estateagents.entity.TaBuildingDynamic;
-import com.huiju.estateagents.entity.TaShareActivity;
 import com.huiju.estateagents.service.*;
-import io.swagger.models.auth.In;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import java.time.LocalDateTime;
-import java.util.ArrayList;
-import java.util.List;
-
 /**
  * @author admin
  * @Title: JudglActivityTimeJob
      * 开启定时任务，每天12：30执行
      */
     @Scheduled(cron = "* 0/5 ** * * ?")
-//    @Scheduled(cron = "0/5 * * * * ?")
     private void configureTasks() {
 
-        //活动列表
-        QueryWrapper<TaBuildingDynamic> buildingDynamicQueryWrapper = new QueryWrapper<>();
-        buildingDynamicQueryWrapper.ne("activity_status", "2");
-        List<TaBuildingDynamic> taBuildingDynamics = iTaBuildingDynamicService.list(buildingDynamicQueryWrapper);
-
-        //拼团活动列表
-        QueryWrapper<TaShareActivity> shareActivityQueryWrapper = new QueryWrapper<>();
-        shareActivityQueryWrapper.ne("activity_status", "2");
-        List<TaShareActivity> taShareActivities = iTaShareActivityService.list(shareActivityQueryWrapper);
-
-        //助力活动列表
-        QueryWrapper<HelpActivity> activityQueryWrapper = new QueryWrapper<>();
-        activityQueryWrapper.ne("activity_status", "2");
-        List<HelpActivity> helpActivities = iHelpActivityService.list(activityQueryWrapper);
-
-        LocalDateTime nowTime = LocalDateTime.now();
-
-        List<String> startActivityIds = new ArrayList<>();
-        List<String> endActivityIds = new ArrayList<>();
-        for (TaBuildingDynamic taBuildingDynamic : taBuildingDynamics){
-            LocalDateTime startTime = taBuildingDynamic.getStartDate();
-            LocalDateTime endTime = taBuildingDynamic.getEndDate();
-            if (nowTime.isAfter(startTime) && endTime.isAfter(nowTime)){
-                startActivityIds.add(taBuildingDynamic.getDynamicId());
-            }
-            if (nowTime.isAfter(endTime)){
-                endActivityIds.add(taBuildingDynamic.getDynamicId());
-            }
-        }
-        iTaBuildingDynamicService.updateUnStartActivity(startActivityIds);
-        iTaBuildingDynamicService.updateEndActivity(endActivityIds);
-
-
-        List<Integer> startGroupActivityIds = new ArrayList<>();
-        List<Integer> endGroupActivityIds = new ArrayList<>();
-        for (TaShareActivity taShareActivity : taShareActivities){
-            LocalDateTime startTime = taShareActivity.getStartTime();
-            LocalDateTime endTime = taShareActivity.getEndTime();
-            if (nowTime.isAfter(startTime) && endTime.isAfter(nowTime)){
-                startGroupActivityIds.add(taShareActivity.getGroupActivityId());
-            }
-            if (nowTime.isAfter(endTime)){
-                endGroupActivityIds.add(taShareActivity.getGroupActivityId());
-            }
-        }
-        iTaShareActivityService.updateUnStartActivity(startGroupActivityIds);
-        iTaShareActivityService.updateEndActivity(endGroupActivityIds);
-        iTaShareRecordService.updateEndActivity(endGroupActivityIds);
-        iTaShareChildRecordService.updateEndActivity(endGroupActivityIds);
-
-        List<Integer> startHelpActivityIds = new ArrayList<>();
-        List<Integer> endHelpActivityIds = new ArrayList<>();
-        for (HelpActivity helpActivity : helpActivities){
-            LocalDateTime startTime = helpActivity.getStartDate();
-            LocalDateTime endTime = helpActivity.getEndDate();
-            if (nowTime.isAfter(startTime) && endTime.isAfter(nowTime)){
-                startHelpActivityIds.add(helpActivity.getHelpActivityId());
-            }
-            if (nowTime.isAfter(endTime)){
-                endHelpActivityIds.add(helpActivity.getHelpActivityId());
-            }
-        }
-        iHelpActivityService.updateUnStartActivity(startHelpActivityIds);
-        iHelpActivityService.updateEndActivity(endHelpActivityIds);
-        iHelpInitiateRecordService.updateEndActivity(endHelpActivityIds);
+        //未开始活动更新为已开始
+        iTaBuildingDynamicService.updateUnStartActivity();
+        //进行中活动更新为已结束
+        iTaBuildingDynamicService.updateProcessingActivity();
+
+        //未开始拼团活动更新为已开始
+        iTaShareActivityService.updateUnStartGroupActivity();
+        //进行中拼团活动更新为已结束
+        iTaShareActivityService.updateProcessingGroupActivity();
+
+        //更新拼团者和参团者数据为已结束
+        iTaShareRecordService.updateActivityProcessToEnd();
+        iTaShareChildRecordService.updateActivityProcessToEnd();
+
+        //未开始助力活动更新为已开始
+        iHelpActivityService.updateUnStartHelpActivity();
+        //进行中助力活动更新为已结束
+        iHelpActivityService.updateProcessingHelpActivity();
+
+        //更新助力者和发起者数据为已结束
+        iHelpInitiateRecordService.updateHelpActivityProcessToEnd();
     }
 
 }

src/main/java/com/huiju/estateagents/mapper/HelpActivityMapper.java

      */
     IPage<HelpActivity> helpActivityListPage(IPage<HelpActivity> pg, @Param("cityId")Integer cityId, @Param("buildingId")String buildingId, @Param("title")String title, @Param("startDate")String startDate, @Param("endDate") String endDate, @Param("activityStatus")Integer activityStatus, @Param("orgId")Integer orgId);
 
-    void updateUnStartHelpActivity(@Param("list") List<Integer> startHelpActivityId);
+    void updateUnStartHelpActivity();
 
-    void updateEndHelpActivity(@Param("list")List<Integer> endHelpActivityId);
+    void updateProcessingHelpActivity();
 
     /**
      * 微信端查询拼团和助力推首页的活动的

src/main/java/com/huiju/estateagents/mapper/HelpInitiateRecordMapper.java

 
     List<HelpInitiateRecordSucceed> getHelpInitiateRecordSucceedExportList(@Param("pageCode") int i, @Param("pageSize") Integer pageSize, @Param("tel") Integer tel, @Param("helpActivityId") Integer helpActivityId);
 
-    void updateEndGroupActivity(List<Integer> endHelpActivityIds);
+    void updateHelpActivityProcessToEnd();
 	/**
 	 * 获取我的助力列表
 	 * @param pg

src/main/java/com/huiju/estateagents/mapper/TaBuildingDynamicMapper.java

 
     /**
      * 更新未开始的活动
-     * @param startActivityIds
      */
-    void updateUnStartActivity(@Param("list") List<String> startActivityIds);
+    void updateUnStartActivity();
 
     /**
      * 更新结束的活动
-     * @param endActivityIds
      */
-    void updateEndActivity(@Param("list") List<String> endActivityIds);
+    void updateProcessingActivity();
 }

src/main/java/com/huiju/estateagents/mapper/TaShareActivityMapper.java

 public interface TaShareActivityMapper extends BaseMapper<TaShareActivity> {
     TaShareActivity selectTaShareActivityById(@Param("activityId")Integer activityId);
 
-    void updateJoinPeople(@Param("activityId") Integer activityId);
+    void updateUnStartGroupActivity();
 
-    void updateUnStartGroupActivity(@Param("list") List<Integer> startGroupActivityId);
-
-    void updateEndGroupActivity(@Param("list")List<Integer> endGroupActivityId);
+    void updateProcessGroupActivity();
 
     Integer calParticipateNum(@Param("groupActivityId") Integer groupActivityId);
 }

src/main/java/com/huiju/estateagents/mapper/TaShareChildRecordMapper.java

 public interface TaShareChildRecordMapper extends BaseMapper<TaShareChildRecord> {
     IPage<TaShareChildRecord> getList(IPage<TaShareChildRecord> pg, @Param("groupActivityId") Integer groupActivityId, @Param("status") Integer status, @Param("recordId") Integer recordId, @Param("orgId") Integer orgId);
     List<ShareChildRecordExport> getShareRecordExportList(@Param("pageCode") Integer pageCode, @Param("pageSize") Integer pageSize, @Param("recordId") Integer recordId , @Param("status")Integer status, @Param("groupActivityId") Integer groupActivityId);
-    void updateEndGroupActivity(List<Integer> endGroupActivityIds);
+    void updateEndGroupActivity();
 }

src/main/java/com/huiju/estateagents/mapper/TaShareRecordMapper.java

     List<ShareRecordSuccessExport> getShareRecordSuccessExportList(@Param("pageCode") Integer pageCode, @Param("pageSize") Integer pageSize, @Param("recordId") Integer recordId , @Param("status")Integer status, @Param("groupActivityId") Integer groupActivityId);
     List<ShareRecordFailExport> getShareRecordFailExportList(@Param("pageCode") Integer pageCode, @Param("pageSize") Integer pageSize, @Param("recordId") Integer recordId , @Param("status")Integer status, @Param("groupActivityId") Integer groupActivityId);
 	List<TaShareRecord> getShareRecordList(Page<TaShareRecord> pg,@Param("orgId") Integer orgId,@Param("personId") String personId);
-    void updateEndGroupActivity(@Param("list")List<Integer> endGroupActivityIds);
+    void updateEndGroupActivity();
 }

src/main/java/com/huiju/estateagents/service/IHelpActivityService.java

     /**
      * 开始助力活动
      */
-    void updateUnStartActivity(List<Integer> startGroupActivityIds);
+    void updateUnStartHelpActivity();
 
     /**
      * 结束助力活动
-     * @param endGroupActivityIds
      */
-    void updateEndActivity(List<Integer> endGroupActivityIds);
+    void updateProcessingHelpActivity();
 
     /**
      * 微信端查询拼团和助力推首页的活动的

src/main/java/com/huiju/estateagents/service/IHelpInitiateRecordService.java

 	 */
 	ResponseBean getInitiateRecord(Integer pageNum, Integer pageSize, Integer orgId, String personId);
 
-	void updateEndActivity(List<Integer> endHelpActivityIds);
+	void updateHelpActivityProcessToEnd();
 }

src/main/java/com/huiju/estateagents/service/ITaBuildingDynamicService.java

 
     /**
      * 开始未进行的活动
-     * @param startActivityId
      */
-    void updateUnStartActivity(List<String> startActivityId);
+    void updateUnStartActivity();
 
     /**
      * 结束过期的活动
-     * @param endActivityId
      */
-    void updateEndActivity(List<String> endActivityId);
+    void updateProcessingActivity();
 
     /**
      * 报名记录导出当前总数

src/main/java/com/huiju/estateagents/service/ITaShareActivityService.java

     ResponseBean getList(Integer pageNum, Integer pageSize, String buildingId, String activityName, String status, LocalDateTime startTime, LocalDateTime endTime, Integer cityId, Integer orgId);
 
     /**
-     * 开始未进行的活动
-     * @param startGroupActivityId
+     * 活动未开始更新为进行中
      */
-    void updateUnStartActivity(List<Integer> startGroupActivityId);
+    void updateUnStartGroupActivity();
 
     /**
-     * 结束过期的活动
-     * @param endGroupActivityId
+     * 活动进行中更新为已结束
      */
-    void updateEndActivity(List<Integer> endGroupActivityId);
+    void updateProcessingGroupActivity();
 
     /**
      * 查询拼团  已开始 和 未开始

src/main/java/com/huiju/estateagents/service/ITaShareChildRecordService.java

     ResponseBean validateRule(TaShareChildRecord taShareChildRecord);
     Integer getShareRecord(Integer recordId, Integer status);
     List<ShareChildRecordExport> getShareRecordExportList(Integer pageCode, Integer pageSize, Integer recordId, Integer status, Integer groupActivityId);
-	void updateEndActivity(List<Integer> endGroupActivityIds);
+	void updateActivityProcessToEnd();
 	/**
 	 * 微信端成为团员
 	 *

src/main/java/com/huiju/estateagents/service/ITaShareRecordService.java

     Integer getShareRecord(Integer recordId, Integer status);
     List<ShareRecordSuccessExport>  getShareRecordSuccessExportList(Integer pageCode, Integer pageSize, Integer recordId, Integer status, Integer groupActivityId);
     List<ShareRecordFailExport>  getShareRecordFailExportList(Integer pageCode, Integer pageSize, Integer recordId, Integer status, Integer groupActivityId);
-	void updateEndActivity(List<Integer> endGroupActivityIds);
+	void updateActivityProcessToEnd();
     /**
 	 * 分页获取微信端发起拼团记录
 	 * @param pageNum

src/main/java/com/huiju/estateagents/service/impl/HelpActivityServiceImpl.java

     }
 
     @Override
-    public void updateUnStartActivity(List<Integer> startHelpActivityIds) {
-        if (CollectionUtils.isNotEmpty(startHelpActivityIds)){
-            taHelpActivityMapper.updateUnStartHelpActivity(startHelpActivityIds);
-        }
+    public void updateUnStartHelpActivity() {
+        taHelpActivityMapper.updateUnStartHelpActivity();
     }
 
     @Override
-    public void updateEndActivity(List<Integer> endHelpActivityIds) {
-        if (CollectionUtils.isNotEmpty(endHelpActivityIds)){
-            taHelpActivityMapper.updateEndHelpActivity(endHelpActivityIds);
-        }
+    public void updateProcessingHelpActivity() {
+        taHelpActivityMapper.updateProcessingHelpActivity();
     }
 
     @Override

src/main/java/com/huiju/estateagents/service/impl/HelpInitiateRecordServiceImpl.java

 	}
 
 	@Override
-	public void updateEndActivity(List<Integer> endHelpActivityIds) {
-		if (CollectionUtils.isNotEmpty(endHelpActivityIds)){
-			List<HelpInitiateRecord> helpInitiateRecords = helpInitiateRecordMapper.selectBatchIds(endHelpActivityIds);
-			for (HelpInitiateRecord helpInitiateRecord : helpInitiateRecords){
-				helpInitiateRecord.setStatus(2);
-				if (helpInitiateRecord.getStatus() != 0){
-					helpInitiateRecordMapper.updateById(helpInitiateRecord);
-				}
-			}
-		}
+	public void updateHelpActivityProcessToEnd() {
+		helpInitiateRecordMapper.updateHelpActivityProcessToEnd();
 	}
 }

src/main/java/com/huiju/estateagents/service/impl/TaBuildingDynamicServiceImpl.java

     }
 
     @Override
-    public void updateUnStartActivity(List<String> startActivityIds) {
-        if (CollectionUtils.isNotEmpty(startActivityIds)){
-            buildingDynamicMapper.updateUnStartActivity(startActivityIds);
-        }
+    public void updateUnStartActivity() {
+        buildingDynamicMapper.updateUnStartActivity();
     }
 
     @Override
-    public void updateEndActivity(List<String> endActivityIds) {
-        if (CollectionUtils.isNotEmpty(endActivityIds)){
-            buildingDynamicMapper.updateEndActivity(endActivityIds);
-        }
+    public void updateProcessingActivity() {
+        buildingDynamicMapper.updateProcessingActivity();
     }
 
     @Override

src/main/java/com/huiju/estateagents/service/impl/TaShareActivityServiceImpl.java

     }
 
     @Override
-    public void updateUnStartActivity(List<Integer> startGroupActivityId) {
-        if (CollectionUtils.isNotEmpty(startGroupActivityId)){
-            taShareActivityMapper.updateUnStartGroupActivity(startGroupActivityId);
-        }
+    public void updateUnStartGroupActivity() {
+        taShareActivityMapper.updateUnStartGroupActivity();
     }
 
     @Override
-    public void updateEndActivity(List<Integer> endGroupActivityId) {
-
-        if (CollectionUtils.isNotEmpty(endGroupActivityId)){
-            taShareActivityMapper.updateEndGroupActivity(endGroupActivityId);
-        }
+    public void updateProcessingGroupActivity() {
+        taShareActivityMapper.updateProcessGroupActivity();
     }
 
     @Override

src/main/java/com/huiju/estateagents/service/impl/TaShareChildRecordServiceImpl.java

             //扣取积分,更新参团人数
             taPerson.setPoints(taPerson.getPoints() - taShareActivity.getIntegral());
             taPersonMapper.updateById(taPerson);
-            activityMapper.updateJoinPeople(taShareChildRecord.getGroupActivityId());
             responseBean.addSuccess("您已成功参团");
 
         }catch (Exception e){
     }
 
     @Override
-    public void updateEndActivity(List<Integer> endGroupActivityIds) {
-        if (CollectionUtils.isNotEmpty(endGroupActivityIds)){
-            List<TaShareChildRecord> taShareChildRecords = taShareChildRecordMapper.selectBatchIds(endGroupActivityIds);
-            for (TaShareChildRecord taShareChildRecord : taShareChildRecords){
-                taShareChildRecord.setStatus(2);
-                if (taShareChildRecord.getStatus() != 0){
-                    taShareChildRecordMapper.updateById(taShareChildRecord);
-                }
-            }
-        }
+    public void updateActivityProcessToEnd() {
+        taShareChildRecordMapper.updateEndGroupActivity();
     }
 
     /**

src/main/java/com/huiju/estateagents/service/impl/TaShareRecordServiceImpl.java

             //扣取积分,更新参团人数
             taPerson.setPoints(taPerson.getPoints() - taShareActivity.getIntegral());
             taPersonMapper.updateById(taPerson);
-            activityMapper.updateJoinPeople(taShareRecord.getGroupActivityId());
             responseBean.addSuccess("您已成功发起拼团，赶快邀请好友参团吧");
 
         }catch (Exception e){
     }
 
     @Override
-    public void updateEndActivity(List<Integer> endGroupActivityIds) {
-        if (CollectionUtils.isNotEmpty(endGroupActivityIds)){
-            List<TaShareRecord> taShareRecords = taShareRecordMapper.selectBatchIds(endGroupActivityIds);
-            for (TaShareRecord taShareRecord : taShareRecords){
-                taShareRecord.setStatus(2);
-                if (taShareRecord.getStatus() != 0){
-                    taShareRecordMapper.updateById(taShareRecord);
-                }
-            }
-        }
+    public void updateActivityProcessToEnd() {
+        taShareRecordMapper.updateEndGroupActivity();
     }
 
     /**

src/main/resources/mapper/HelpActivityMapper.xml

     </select>
 
     <update id="updateUnStartHelpActivity">
-        update ta_help_activity t set t.activity_status = 0
-        where t.help_activity_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+        update ta_help_activity
+        set activity_status = 0
+        where
+        help_activity_id in (
+            select
+            help_activity_id
+            from
+            (
+            select
+            t.help_activity_id
+            from
+            ta_help_activity t
+            where
+            t.activity_status != '2'
+            and NOW() > t.start_date
+            and NOW() &lt; t.end_date
+            ) s
+        )
     </update>
 
-    <update id="updateEndHelpActivity">
-        update ta_help_activity t set t.activity_status = 2
-        where t.help_activity_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+    <update id="updateProcessingHelpActivity">
+        update ta_help_activity
+        set activity_status = 2
+        where
+            help_activity_id in (
+                select
+                    help_activity_id
+                from
+                    (
+                        select
+                            t.help_activity_id
+                        from
+                            ta_help_activity t
+                        where
+                            t.activity_status != '2'
+                        and NOW() > t.end_date
+                    ) s
+            )
     </update>
+
     <select id="selectWxhelpActivityAndGroup" resultType="com.huiju.estateagents.entity.HelpActivity">
 		(
 			SELECT

src/main/resources/mapper/HelpInitiateRecordMapper.xml

 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.huiju.estateagents.mapper.HelpInitiateRecordMapper">
 
-    <update id="updateEndGroupActivity">
-        update ta_help_initiate_record t set t.status = 2
-        where t.help_activity_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+    <update id="updateHelpActivityProcessToEnd">
+      update ta_help_initiate_record a
+        set a.`status` = '2'
+        where
+            a.help_activity_id in (
+                select
+                    t.help_activity_id
+                from
+                    ta_help_activity t
+                where (NOW() > t.end_date or t.activity_status = '2')
+            )
+        and a.`status` = '1'
     </update>
 
     <select id="selectPageList" resultType="com.huiju.estateagents.entity.HelpInitiateRecord">

src/main/resources/mapper/TaBuildingDynamicMapper.xml

     </update>
 
     <update id="updateUnStartActivity">
-      update ta_building_dynamic t set t.activity_status = 0
-      where t.dynamic_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+        update ta_building_dynamic
+        set activity_status = 0
+        where
+        dynamic_id in (
+            select
+            dynamic_id
+            from
+            (
+            select
+            t.dynamic_id
+            from
+            ta_building_dynamic t
+            where
+            t.activity_status != '2'
+            and NOW() > t.create_date
+            and NOW() &lt; t.end_date
+            ) s
+        )
     </update>
 
-    <update id="updateEndActivity">
-        update ta_building_dynamic t set t.activity_status = 2
-        where t.dynamic_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+    <update id="updateProcessingActivity">
+        update ta_building_dynamic
+        set activity_status = 2
+        where
+            dynamic_id in (
+                select
+                    dynamic_id
+                from
+                    (
+                        select
+                            t.dynamic_id
+                        from
+                            ta_building_dynamic t
+                        where
+                            t.activity_status != '2'
+                        and NOW() > t.end_date
+                    ) s
+            );
     </update>
 
     <select id="updateTaBuildingDynamic">

src/main/resources/mapper/TaShareActivityMapper.xml

     </select>
 
     <update id="updateUnStartGroupActivity">
-        update ta_share_activity t set t.activity_status = 0
-        where t.group_activity_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+        update ta_share_activity
+        set activity_status = 0
+        where
+        group_activity_id in (
+            select
+            group_activity_id
+            from
+            (
+            select
+            t.group_activity_id
+            from
+            ta_share_activity t
+            where
+            t.activity_status != '2'
+            and NOW() > t.start_time
+            and NOW() &lt; t.end_time
+            ) s
+        )
     </update>
 
-    <update id="updateEndGroupActivity">
-        update ta_share_activity t set t.activity_status = 2
-        where t.group_activity_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+    <update id="updateProcessGroupActivity">
+        update ta_share_activity
+        set activity_status = 2
+        where
+	    group_activity_id in (
+            select
+                group_activity_id
+            from
+                (
+                    select
+                        t.group_activity_id
+                    from
+                        ta_share_activity t
+                    where
+                        t.activity_status != '2'
+                    and NOW() > t.end_time
+                ) s
+	    )
     </update>
 
     <select id="calParticipateNum" resultType="java.lang.Integer">

src/main/resources/mapper/TaShareChildRecordMapper.xml

 <mapper namespace="com.huiju.estateagents.mapper.TaShareChildRecordMapper">
 
     <update id="updateEndGroupActivity">
-        update ta_share_child_record t set t.status = 2
-        where t.group_activity_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+        update ta_share_child_record a
+        set a.`status` = '2'
+        where a.group_activity_id in (
+            select
+                    t.group_activity_id
+                from
+                    ta_share_activity t
+                where (NOW() > t.end_time or t.activity_status = '2')
+        ) and a.`status` = '1';
     </update>
 
     <select id="getList" resultType="com.huiju.estateagents.entity.TaShareChildRecord">

src/main/resources/mapper/TaShareRecordMapper.xml

 <mapper namespace="com.huiju.estateagents.mapper.TaShareRecordMapper">
 
     <update id="updateEndGroupActivity">
-        update ta_share_record t set t.status = 2
-        where t.group_activity_id in
-        <foreach collection="list" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
+        update ta_share_record a
+        set a.`status` = '2'
+        where
+            a.group_activity_id in (
+                select
+                    t.group_activity_id
+                from
+                    ta_share_activity t
+                where (NOW() > t.end_time or t.activity_status = '2')
+            )
+        and a.`status` = '1';
     </update>
 
     <select id="recordSuccessList" resultType="com.huiju.estateagents.entity.TaShareRecord">