From 184d1341ae248cf02a8225ca7bfbba463e18496e Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期一, 13 四月 2020 17:47:40 +0800
Subject: [PATCH] 消息
---
fanli/src/main/java/com/yeshi/fanli/service/impl/activity/ActivityUserServiceImpl.java | 62 +++++++++++++++++++++++++++++++
1 files changed, 62 insertions(+), 0 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/activity/ActivityUserServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/activity/ActivityUserServiceImpl.java
index 38abc11..b6ab664 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/activity/ActivityUserServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/activity/ActivityUserServiceImpl.java
@@ -1,17 +1,24 @@
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 {
@@ -56,17 +63,72 @@
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);
--
Gitblit v1.8.0