fix 审核通过自动发放积分

netflix-service/src/main/java/com/cyksj/service/market/task/impl/TaskServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.cyksj.common.constant.PointsRecordConst;
 import com.cyksj.common.constant.TaskTypeEnum;
 import com.cyksj.common.exception.BusinessRuntimeException;
 import com.cyksj.mapper.manage.distribute.UserDistributeSharedMapper;
@@ -13,6 +14,7 @@ import com.cyksj.mapper.market.task.TaskMapper;
 import com.cyksj.mapper.market.task.TaskTypeMapper;
 import com.cyksj.mapper.market.task.TaskUserCompleteRecordMapper;
 import com.cyksj.model.entity.*;
+import com.cyksj.service.market.MarketFrontService;
 import com.cyksj.service.market.task.TaskService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -44,6 +46,8 @@ public class TaskServiceImpl implements TaskService {
 
 	private final TaskFollowPlatVerifyMapper taskFollowPlatVerifyMapper;
 
+	private final MarketFrontService marketFrontService;
+
 	@Override
 	public void saveTask(Task task) {
 		checkTask(task);
@@ -130,7 +134,8 @@ public class TaskServiceImpl implements TaskService {
 						return;
 					}
 					if (verifyStatus == success) {
-						record.setStatus(TaskUserCompleteRecord.Status.complete);
+						record.setStatus(TaskUserCompleteRecord.Status.received);
+						marketFrontService.pointsRecord(record.getUserId(), record.getPoints(), PointsRecordConst.TASK, false);
 					} else if (verifyStatus == fail) {
 						record.setStatus(TaskUserCompleteRecord.Status.fail);
 					}

netflix-service/src/main/java/com/cyksj/task/SignStatisticsDataScheduler.java

@@ -14,6 +14,7 @@ import com.cyksj.model.entity.SignStatisticsData;
 import com.cyksj.model.entity.SignUser;
 import com.cyksj.model.entity.TaskFollowPlatVerify;
 import com.cyksj.model.entity.TaskUserCompleteRecord;
+import com.cyksj.service.market.MarketFrontService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -42,6 +43,8 @@ public class SignStatisticsDataScheduler {
 
 	private final TaskUserCompleteRecordMapper taskUserCompleteRecordMapper;
 
+	private final MarketFrontService marketFrontService;
+
 	@Scheduled(cron = "0 0 0 * * ?")
 	public void signStatisticsData() {
 		Date thisZeroDate = DateUtil.beginOfDay(DateTime.now());
@@ -118,8 +121,9 @@ public class SignStatisticsDataScheduler {
 					.eq(TaskUserCompleteRecord::getUserId, data.getUserId())
 					.eq(TaskUserCompleteRecord::getTaskId, data.getTaskId())
 					.last("limit 1"));
-			record.setStatus(TaskUserCompleteRecord.Status.complete);
+			record.setStatus(TaskUserCompleteRecord.Status.received);
 			taskUserCompleteRecordMapper.updateById(record);
+			marketFrontService.pointsRecord(record.getUserId(), record.getPoints(), PointsRecordConst.TASK, false);
 		});
 	}
 }