From bf0a347104579e5f7a2ed6e660ebb9f17f76ffc0 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期五, 17 一月 2020 16:51:54 +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 {
+		// 鏂囦欢瑙f瀽 
+		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