Kaynağa Gözat

定时任务修改

魏超 5 yıl önce
ebeveyn
işleme
b4825c9cd2

+ 8
- 1
src/main/java/com/huiju/estateagents/service/impl/HelpInitiateRecordServiceImpl.java Dosyayı Görüntüle

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
5 5
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
6 6
 import com.huiju.estateagents.base.ResponseBean;
7 7
 import com.huiju.estateagents.entity.HelpInitiateRecord;
8
+import com.huiju.estateagents.entity.TaShareRecord;
8 9
 import com.huiju.estateagents.mapper.HelpInitiateRecordMapper;
9 10
 import com.huiju.estateagents.service.IHelpInitiateRecordService;
10 11
 import org.apache.commons.collections.CollectionUtils;
@@ -46,7 +47,13 @@ public class HelpInitiateRecordServiceImpl extends ServiceImpl<HelpInitiateRecor
46 47
 	@Override
47 48
 	public void updateEndActivity(List<Integer> endHelpActivityIds) {
48 49
 		if (CollectionUtils.isNotEmpty(endHelpActivityIds)){
49
-			helpInitiateRecordMapper.updateEndGroupActivity(endHelpActivityIds);
50
+			List<HelpInitiateRecord> helpInitiateRecords = helpInitiateRecordMapper.selectBatchIds(endHelpActivityIds);
51
+			for (HelpInitiateRecord helpInitiateRecord : helpInitiateRecords){
52
+				helpInitiateRecord.setStatus(2);
53
+				if (helpInitiateRecord.getStatus() != 0){
54
+					helpInitiateRecordMapper.updateById(helpInitiateRecord);
55
+				}
56
+			}
50 57
 		}
51 58
 	}
52 59
 }

+ 1
- 0
src/main/java/com/huiju/estateagents/service/impl/TaShareActivityServiceImpl.java Dosyayı Görüntüle

@@ -60,6 +60,7 @@ public class TaShareActivityServiceImpl extends ServiceImpl<TaShareActivityMappe
60 60
 
61 61
     @Override
62 62
     public void updateEndActivity(List<Integer> endGroupActivityId) {
63
+
63 64
         if (CollectionUtils.isNotEmpty(endGroupActivityId)){
64 65
             taShareActivityMapper.updateEndGroupActivity(endGroupActivityId);
65 66
         }

+ 7
- 1
src/main/java/com/huiju/estateagents/service/impl/TaShareChildRecordServiceImpl.java Dosyayı Görüntüle

@@ -108,7 +108,13 @@ public class TaShareChildRecordServiceImpl extends ServiceImpl<TaShareChildRecor
108 108
     @Override
109 109
     public void updateEndActivity(List<Integer> endGroupActivityIds) {
110 110
         if (CollectionUtils.isNotEmpty(endGroupActivityIds)){
111
-            taShareChildRecordMapper.updateEndGroupActivity(endGroupActivityIds);
111
+            List<TaShareChildRecord> taShareChildRecords = taShareChildRecordMapper.selectBatchIds(endGroupActivityIds);
112
+            for (TaShareChildRecord taShareChildRecord : taShareChildRecords){
113
+                taShareChildRecord.setStatus(2);
114
+                if (taShareChildRecord.getStatus() != 0){
115
+                    taShareChildRecordMapper.updateById(taShareChildRecord);
116
+                }
117
+            }
112 118
         }
113 119
     }
114 120
 

+ 7
- 1
src/main/java/com/huiju/estateagents/service/impl/TaShareRecordServiceImpl.java Dosyayı Görüntüle

@@ -151,7 +151,13 @@ public class TaShareRecordServiceImpl extends ServiceImpl<TaShareRecordMapper, T
151 151
     @Override
152 152
     public void updateEndActivity(List<Integer> endGroupActivityIds) {
153 153
         if (CollectionUtils.isNotEmpty(endGroupActivityIds)){
154
-            taShareRecordMapper.updateEndGroupActivity(endGroupActivityIds);
154
+            List<TaShareRecord> taShareRecords = taShareRecordMapper.selectBatchIds(endGroupActivityIds);
155
+            for (TaShareRecord taShareRecord : taShareRecords){
156
+                taShareRecord.setStatus(2);
157
+                if (taShareRecord.getStatus() != 0){
158
+                    taShareRecordMapper.updateById(taShareRecord);
159
+                }
160
+            }
155 161
         }
156 162
     }
157 163