package com.yeshi.fanli.service.impl.activity;
|
|
import java.io.InputStream;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.multipart.MultipartFile;
|
import org.yeshi.utils.tencentcloud.COSManager;
|
|
import com.yeshi.fanli.dao.mybatis.activity.ActivityRuleUserMapper;
|
import com.yeshi.fanli.dao.mybatis.activity.ActivityUserMapper;
|
import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser;
|
import com.yeshi.fanli.entity.bus.activity.ActivityUser;
|
import com.yeshi.fanli.exception.dynamic.ActivityUserException;
|
import com.yeshi.fanli.service.inter.activity.ActivityUserService;
|
import com.yeshi.fanli.util.FilePathEnum;
|
import com.yeshi.fanli.util.StringUtil;
|
|
@Service
|
public class ActivityUserServiceImpl implements ActivityUserService {
|
|
@Resource
|
private ActivityUserMapper activityUserMapper;
|
|
@Resource
|
private ActivityRuleUserMapper activityRuleUserMapper;
|
|
@Override
|
public ActivityUser selectByPrimaryKey(Long id) {
|
return activityUserMapper.selectByPrimaryKey(id);
|
}
|
|
@Override
|
public List<ActivityUser> listRand(int count) {
|
return activityUserMapper.listRand(count);
|
}
|
|
@Override
|
public void addActivityRuleUser(ActivityRuleUser ruleUser) {
|
if (ruleUser == null || ruleUser.getActivityUser() == null)
|
return;
|
// 添加用户
|
ActivityUser user = activityUserMapper.selectByName(ruleUser.getActivityUser().getNickName());
|
if (user == null) {
|
user = ruleUser.getActivityUser();
|
user.setCreateTime(new Date());
|
activityUserMapper.insertSelective(user);
|
}
|
ActivityRuleUser oldRuleUser = activityRuleUserMapper.selectByUserIdAndRuleCode(user.getId(),
|
ruleUser.getRuleCode());
|
if (oldRuleUser == null) {
|
ruleUser.setActivityUser(user);
|
ruleUser.setCreateTime(new Date());
|
activityRuleUserMapper.insertSelective(ruleUser);
|
} else {
|
ActivityRuleUser update = new ActivityRuleUser();
|
update.setId(oldRuleUser.getId());
|
update.setOrderBy(ruleUser.getOrderBy());
|
activityRuleUserMapper.updateByPrimaryKeySelective(update);
|
}
|
}
|
|
|
@Override
|
public ActivityUser getActivityUserByNickName(ActivityUser record, MultipartFile file) throws ActivityUserException{
|
if (record == null || StringUtil.isNullOrEmpty(record.getNickName()))
|
throw new ActivityUserException(1, "昵称不能为空");
|
try {
|
ActivityUser userExist = activityUserMapper.selectByName(record.getNickName().trim());
|
if (userExist != null) {
|
return userExist;
|
}
|
|
// 不存在则新增
|
if (file == null) {
|
throw new ActivityUserException(1, "头像不能为空");
|
}
|
String portrait = uploadPicture(file);
|
record.setPortrait(portrait);
|
record.setCreateTime(new Date());
|
activityUserMapper.insertSelective(record);
|
|
return record;
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new ActivityUserException(1, "用户信息保存异常");
|
}
|
}
|
|
|
/**
|
* 上传图片
|
* @param file
|
* @return
|
* @throws Exception
|
*/
|
public String uploadPicture(MultipartFile file) throws Exception {
|
// 文件解析
|
InputStream inputStream = file.getInputStream();
|
String contentType = file.getContentType();
|
String type = contentType.substring(contentType.indexOf("/") + 1);
|
// 文件路径
|
String filePath= FilePathEnum.activityUser.getPath() +UUID.randomUUID().toString().replace("-", "") + "." + type;
|
// 执行上传
|
String fileLink= COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();
|
|
return fileLink;
|
}
|
|
|
@Override
|
public List<ActivityRuleUser> listByRuleCode(Integer ruleCode, int page, int pageSize) {
|
return activityRuleUserMapper.listByRuleCode(ruleCode, (page - 1) * pageSize, pageSize);
|
}
|
|
@Override
|
public ActivityUser selectByName(String nickName) {
|
return activityUserMapper.selectByName(nickName);
|
}
|
|
|
@Override
|
public long countByRuleCode(Integer ruleCode) {
|
return activityRuleUserMapper.countByRuleCode(ruleCode);
|
}
|
|
|
@Override
|
public void deleteByRuleUserId(Long id) {
|
ActivityRuleUser user = activityRuleUserMapper.selectByPrimaryKey(id);
|
if (user.getActivityUser() != null)
|
activityUserMapper.deleteByPrimaryKey(user.getActivityUser().getId());
|
activityRuleUserMapper.deleteByPrimaryKey(id);
|
}
|
|
@Override
|
public ActivityRuleUser selectRuleUserByPrimaryKey(Long id) {
|
|
return activityRuleUserMapper.selectByPrimaryKey(id);
|
}
|
|
@Override
|
public void updateActivityUser(ActivityUser au) {
|
activityUserMapper.updateByPrimaryKeySelective(au);
|
}
|
|
@Override
|
public void updateActivityRuleUser(ActivityRuleUser au) {
|
activityRuleUserMapper.updateByPrimaryKeySelective(au);
|
}
|
|
@Override
|
public ActivityUser getRandomByDaTaoKeCid(int cid) {
|
int ruleId = 100 + cid;
|
List<ActivityRuleUser> ruleList = activityRuleUserMapper.listByRuleCode(ruleId, 0, 100);
|
return ruleList.get((int) (ruleList.size() * Math.random())).getActivityUser();
|
}
|
|
@Override
|
public ActivityUser getRandomHaoHuo() {
|
List<ActivityRuleUser> ruleList = activityRuleUserMapper.listByRuleCode(ActivityRuleUser.RULE_HAOHUO, 0, 100);
|
return ruleList.get((int) (ruleList.size() * Math.random())).getActivityUser();
|
}
|
|
}
|
