yhlxj/netflix-service/src/main/java/com/cyksj/service/user/impl/UserActivityServiceImpl.java

package com.cyksj.service.user.impl;

import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.cyksj.common.util.Jsons;
import com.cyksj.mapper.UserActivityMapper;
import com.cyksj.mapper.UserMapper;
import com.cyksj.model.entity.CouponUser;
import com.cyksj.model.entity.User;
import com.cyksj.model.entity.UserActivity;
import com.cyksj.service.mange.coupon.CouponCommonService;
import com.cyksj.service.user.UserActivityService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 项目名: yhlxj
 * 文件名: UserActivityServiceImpl
 * 创建者: JavaZou
 * 创建时间:2024/4/16 12:16
 */
@Service
@RequiredArgsConstructor
@Slf4j
public class UserActivityServiceImpl extends ServiceImpl<UserActivityMapper, UserActivity> implements UserActivityService {
	private final CouponCommonService couponCommonService;

	private final UserMapper userMapper;

	@Override
	public void sendStudentCertActivity(User user, String dsCode) throws Exception {
		UserActivity activity = getById(1);
		Long sendUserId = user.getId();
		if (StrUtil.isNotBlank(dsCode)) {
			log.info("用户code:{}进行大学生身份认证成功..", dsCode);
			User toUser = userMapper.selectOne(Wrappers.lambdaQuery(User.class).eq(User::getShowId, dsCode).last("limit 1"));
			if (toUser != null) {
				sendUserId = toUser.getId();
			}
		}
		if (StrUtil.isNotBlank(activity.getCouponIds())) {
			//发送优惠券
			List<Long> couponIds = Jsons.parseList(activity.getCouponIds(), Long.class);
			log.info("uid:{}大学生认证成功,发放优惠券:{}", user.getId(), couponIds);
			for (Long couponId : couponIds) {
				couponCommonService.sendCouponToUser(sendUserId, couponId, 0l, 0l, 0l, CouponUser.Channel.student_cert);
			}
		}
	}

	@Override
	public void saveOrUpdateActivity(UserActivity userActivity) throws Exception {
		checkActivity(userActivity);
		saveOrUpdate(userActivity);
	}


	public void checkActivity(UserActivity userActivity) throws Exception {
		String couponIds = userActivity.getCouponIds();
		if (StrUtil.isNotBlank(couponIds)) {
			List<Long> couponidsList = Jsons.parseList(couponIds, Long.class);
			userActivity.setCouponIds(Jsons.toJson(couponidsList));
		}
	}
}