yujian
2019-05-23 a06001d130f3b088a1afbd7d7dc8616d209a9fd5
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoServiceImpl.java
@@ -1,5 +1,6 @@
package com.yeshi.fanli.service.impl.user;
import java.io.IOException;
import java.io.InputStream;
import java.io.Serializable;
import java.math.BigDecimal;
@@ -18,10 +19,12 @@
import org.hibernate.Query;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.springframework.core.task.TaskExecutor;
import org.springframework.orm.hibernate4.HibernateCallback;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;
import org.yeshi.utils.HttpUtil;
import org.yeshi.utils.NumberUtil;
import org.yeshi.utils.tencentcloud.COSManager;
@@ -47,6 +50,7 @@
import com.yeshi.fanli.service.inter.count.HongBaoV2CountService;
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionAuthRecordService;
import com.yeshi.fanli.service.inter.user.SpreadUserImgService;
import com.yeshi.fanli.service.inter.user.UserActiveLogService;
import com.yeshi.fanli.service.inter.user.UserExtraTaoBaoInfoService;
import com.yeshi.fanli.service.inter.user.UserInfoService;
@@ -63,6 +67,9 @@
@Service
public class UserInfoServiceImpl implements UserInfoService {
   @Resource(name = "taskExecutor")
   private TaskExecutor executor;
   @Resource
   private UserInfoDao userInfoDao;
@@ -107,6 +114,11 @@
   @Resource
   private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;
   @Resource
   private SpreadUserImgService spreadUserImgService;
   public UserInfo getUserByLoginTypeAndOpenId(int loginType, String openid, String appid) {
      List<UserInfo> list = null;
@@ -907,4 +919,61 @@
      return null;
   }
   @Override
   public void uploadPortrait(MultipartFile file, Long uid) throws UserInfoException, IOException {
      UserInfo userInfo = userInfoMapper.selectByPKey(uid);
      if(userInfo == null) {
         throw new UserInfoException(1, "用户不存在");
      }
      String portrait = userInfo.getPortrait();
      if (portrait != null && portrait.trim().length() > 0 && portrait.contains("/img/user/")) {
         COSManager.getInstance().deleteFile(portrait);
      }
      // 文件解析
      InputStream inputStream = file.getInputStream();
      String contentType = file.getContentType();
      String type = contentType.substring(contentType.indexOf("/") + 1);
      // 文件路径
      String filePath="/img/user/"+UUID.randomUUID().toString().replace("-", "") + "." + type;
      // 执行上传
      String fileLink= COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();
      userInfo.setPortrait(fileLink);
      userInfoMapper.updateByPrimaryKeySelective(userInfo);
      executor.execute(new Runnable() {
         @Override
         public void run() {
            try {
               // 删除分享头像信息
                spreadUserImgService.deleteImgUrl(uid);
            } catch (Exception e) {
               try {
                  LogHelper.errorDetailInfo(e);
               } catch (Exception e1) {
                  e1.printStackTrace();
               }
            }
         }
      });
   }
   @Override
   public void saveUserInfo(String nickName, Long uid) throws UserInfoException {
      UserInfo userInfo = userInfoMapper.selectByPKey(uid);
      if(userInfo == null) {
         throw new UserInfoException(1, "用户不存在");
      }
      userInfo.setNickName(nickName);
      userInfoMapper.updateByPrimaryKeySelective(userInfo);
   }
}