yujian
2019-05-23 a06001d130f3b088a1afbd7d7dc8616d209a9fd5
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoServiceImpl.java
@@ -19,6 +19,7 @@
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;
@@ -49,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;
@@ -65,6 +67,9 @@
@Service
public class UserInfoServiceImpl implements UserInfoService {
   @Resource(name = "taskExecutor")
   private TaskExecutor executor;
   @Resource
   private UserInfoDao userInfoDao;
@@ -109,6 +114,11 @@
   @Resource
   private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;
   @Resource
   private SpreadUserImgService spreadUserImgService;
   public UserInfo getUserByLoginTypeAndOpenId(int loginType, String openid, String appid) {
      List<UserInfo> list = null;
@@ -910,7 +920,7 @@
   }
   @Override
   public void uploadPortrait(MultipartFile file,Long uid) throws UserInfoException, IOException {
   public void uploadPortrait(MultipartFile file, Long uid) throws UserInfoException, IOException {
      
      UserInfo userInfo = userInfoMapper.selectByPKey(uid);
      if(userInfo == null) {
@@ -934,7 +944,25 @@
      String fileLink= COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();
      
      userInfo.setPortrait(fileLink);
      userInfoMapper.updateByPrimaryKey(userInfo);
      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();
               }
            }
         }
      });
   }
   
   
@@ -945,9 +973,7 @@
         throw new UserInfoException(1, "用户不存在");
      }
      
      UserInfo updateInfo = new UserInfo();
      updateInfo.setId(userInfo.getId());
      updateInfo.setNickName(nickName);
      userInfoMapper.updateByPrimaryKeySelective(updateInfo);
      userInfo.setNickName(nickName);
      userInfoMapper.updateByPrimaryKeySelective(userInfo);
   }
}