Kaynağa Gözat

fix 循环依赖

zoujiajian 3 yıl önce
ebeveyn
işleme
74ce0166a8

+ 2 - 0
netflix-service/src/main/java/com/cyksj/service/market/task/TaskService.java

@@ -20,4 +20,6 @@ public interface TaskService {
 	void completeTask(TaskType type, Long userId);
 
 	void batchVerifyFollow( List<TaskFollowPlatVerify> taskFollowPlatVerifyList);
+
+	void pointsRecord(Long userId, Integer points, String remark, Boolean isLottery);
 }

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

@@ -9,12 +9,12 @@ 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;
+import com.cyksj.mapper.market.sign.UserPointsRecordMapper;
 import com.cyksj.mapper.market.task.TaskFollowPlatVerifyMapper;
 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;
@@ -46,7 +46,7 @@ public class TaskServiceImpl implements TaskService {
 
 	private final TaskFollowPlatVerifyMapper taskFollowPlatVerifyMapper;
 
-	private final MarketFrontService marketFrontService;
+	private final UserPointsRecordMapper userPointsRecordMapper;
 
 	@Override
 	public void saveTask(Task task) {
@@ -135,7 +135,7 @@ public class TaskServiceImpl implements TaskService {
 					}
 					if (verifyStatus == success) {
 						record.setStatus(TaskUserCompleteRecord.Status.received);
-						marketFrontService.pointsRecord(record.getUserId(), record.getPoints(), PointsRecordConst.TASK, false);
+						this.pointsRecord(record.getUserId(), record.getPoints(), PointsRecordConst.TASK, false);
 					} else if (verifyStatus == fail) {
 						record.setStatus(TaskUserCompleteRecord.Status.fail);
 					}
@@ -145,6 +145,20 @@ public class TaskServiceImpl implements TaskService {
 		});
 	}
 
+	@Override
+	public void pointsRecord(Long userId, Integer points, String remark, Boolean isLottery) {
+		UserPointsRecord userPointsRecord = new UserPointsRecord();
+		userPointsRecord.setUserId(userId);
+		userPointsRecord.setPoints(points);
+		userPointsRecord.setRemark(remark);
+		userPointsRecordMapper.insert(userPointsRecord);
+
+		if (!isLottery) {
+			//发放爱心
+			userPointsRecordMapper.updateUserPoints(userId, points);
+		}
+	}
+
 	public void checkTask(Task task) {
 		Long typeId = task.getTypeId();
 		TaskType taskType = taskTypeMapper.selectById(typeId);