fanli-server.git

package com.yeshi.fanli.service.impl.user; 
 
import java.io.BufferedReader; 
import java.io.File; 
import java.io.FileInputStream; 
import java.io.FileReader; 
import java.io.InputStream; 
import java.math.BigDecimal; 
import java.text.SimpleDateFormat; 
import java.util.ArrayList; 
import java.util.Calendar; 
import java.util.Collections; 
import java.util.Comparator; 
import java.util.Date; 
import java.util.List; 
import java.util.UUID; 
 
import javax.annotation.Resource; 
 
import org.springframework.stereotype.Service; 
import org.springframework.transaction.annotation.Transactional; 
import org.springframework.web.multipart.MultipartFile; 
import org.yeshi.utils.tencentcloud.COSManager; 
 
import com.yeshi.fanli.dao.mybatis.UserRankingsMapper; 
import com.yeshi.fanli.dto.money.InviteGetMoney; 
import com.yeshi.fanli.entity.bus.user.UserInfo; 
import com.yeshi.fanli.entity.bus.user.UserRankings; 
import com.yeshi.fanli.exception.user.UserRankingsException; 
import com.yeshi.fanli.service.inter.count.HongBaoV2CountService; 
import com.yeshi.fanli.service.inter.user.UserRankingsService; 
import com.yeshi.fanli.util.FilePathEnum; 
import com.yeshi.fanli.util.StringUtil; 
import com.yeshi.fanli.vo.order.HongBaoV2VO; 
 
@Service 
public class UserRankingsServiceImpl implements UserRankingsService { 
    @Resource 
    private UserRankingsMapper userRankingsMapper; 
 
    @Resource 
    private HongBaoV2CountService hongBaoV2CountService;
 
    @Override 
    public int insertSelective(UserRankings record) throws UserRankingsException { 
        // TODO Auto-generated method stub 
        return userRankingsMapper.insertSelective(record); 
    } 
 
    @Override 
    public int updateByPrimaryKey(UserRankings record) throws UserRankingsException { 
        return userRankingsMapper.updateByPrimaryKey(record); 
    } 
 
    @Override 
    public int updateByPrimaryKeySelective(UserRankings record) throws UserRankingsException { 
        return userRankingsMapper.updateByPrimaryKeySelective(record); 
    } 
 
    @Override 
    public int updateBatchSelective(List<UserRankings> list) throws UserRankingsException { 
        return userRankingsMapper.updateBatchSelective(list); 
    } 
 
    @Override 
    @Transactional(rollbackFor=Exception.class) 
    public int deleteBatchById(Long id) throws UserRankingsException { 
        return userRankingsMapper.deleteByPrimaryKey(id); 
    } 
     
     
    @Override 
    public void updateClearTradeState() throws UserRankingsException { 
        userRankingsMapper.updateClearTradeState(); 
    } 
 
 
    @Override 
    @Transactional(rollbackFor=Exception.class) 
    public int deleteBatchByPrimaryKey(List<Long> arrayID) throws UserRankingsException { 
        for (Long id : arrayID) { 
 
            UserRankings userRankings = userRankingsMapper.selectByPrimaryKey(id); 
            String portrait = userRankings.getPortrait(); 
            if (!StringUtil.isNullOrEmpty(portrait)) { 
                COSManager.getInstance().deleteFile(portrait); 
            } 
            userRankingsMapper.deleteByPrimaryKey(id); 
        } 
 
        return arrayID.size(); 
    } 
 
    @Override 
    public UserRankings selectByPrimaryKey(Long id) throws UserRankingsException { 
        // TODO Auto-generated method stub 
        return userRankingsMapper.selectByPrimaryKey(id); 
    } 
 
    @Override 
    public List<UserRankings> selectByNickName(String nickName) throws UserRankingsException { 
        // TODO Auto-generated method stub 
        return userRankingsMapper.selectByNickName(nickName); 
    } 
 
    @Override 
    public List<UserRankings> selectByShowId(String id) throws UserRankingsException { 
        // TODO Auto-generated method stub 
        return userRankingsMapper.selectByShowId(id); 
    } 
 
    @Override 
    public void insertAndUploadFile(UserRankings record, MultipartFile file) throws Exception { 
        // TODO Auto-generated method stub 
        record.setCreatetime(new Date()); 
        userRankingsMapper.insertSelective(record); 
 
        // 上传图片 
        if (file != null) { 
            uploadPicture(file, record); 
        } 
 
    } 
 
    @Override 
    public void uploadPicture(MultipartFile file, UserRankings userRankings) throws Exception { 
 
        /* 修改图片时，先删除已存在图片 */ 
        String portrait = userRankings.getPortrait(); 
        if (!StringUtil.isNullOrEmpty(portrait)) { 
            COSManager.getInstance().deleteFile(portrait); 
        } 
 
        String contentType = file.getContentType(); 
        String type = contentType.substring(contentType.indexOf("/") + 1); 
 
        // 上传文件相对位置 
        String fileUrl = FilePathEnum.userRankings.getPath() + UUID.randomUUID().toString().replace("-", "") + "." + type; 
 
        InputStream inputStream = file.getInputStream(); 
        String uploadFilePath = COSManager.getInstance().uploadFile(inputStream, fileUrl).getUrl(); 
 
        /* 更新数据库信息 */ 
        if (!StringUtil.isNullOrEmpty(uploadFilePath)) { 
            userRankings.setPortrait(uploadFilePath); 
            userRankingsMapper.updateByPrimaryKeySelective(userRankings); 
        } 
    } 
 
    @Override 
    public void removePicture(UserRankings userRankings) throws Exception { 
 
        /* 修改图片时，先删除已存在图片 */ 
        String portrait = userRankings.getPortrait(); 
        if (!StringUtil.isNullOrEmpty(portrait)) { 
            boolean deleteFile = COSManager.getInstance().deleteFile(portrait); 
            if (deleteFile) { 
                userRankings.setPortrait(null); 
                userRankingsMapper.updateByPrimaryKey(userRankings); 
            } 
        } 
 
    } 
 
    @Override 
    public List<UserRankings> query(long start, int count, String key, Integer tradeState, Integer shareState, Integer sort) 
            throws UserRankingsException { 
        return userRankingsMapper.query(start, count, key, tradeState, shareState, sort); 
    } 
 
    @Override 
    public long queryCount(String key, Integer tradeState, Integer shareState) throws UserRankingsException { 
        return userRankingsMapper.queryCount(key, tradeState, shareState); 
    } 
 
    @Override 
    @Transactional(rollbackFor=Exception.class) 
    public void setRewardtBatch(List<Long> idList, Integer type, Double reward, Double startReward, Double endReward) throws Exception { 
 
        for (Long id : idList) { 
 
            UserRankings userRankings = userRankingsMapper.selectByPrimaryKey(id); 
 
            if (userRankings == null) { 
                continue; 
            } 
 
            Double result = 0.00; 
 
            if (reward != null && reward >= 0) { 
                result = reward; 
            } else { 
                if (startReward != null && endReward != null) { 
                    // 随机权重 
                    result = startReward + (Math.random() * ((endReward - startReward) + 1)); 
                } else { 
                    break; 
                } 
            } 
 
            if (type == 1 || type.equals(1)) { 
                userRankings.setTradeReward(new BigDecimal(result)); 
            } else { 
                userRankings.setShareReward(new BigDecimal(result)); 
            } 
 
            userRankingsMapper.updateByPrimaryKeySelective(userRankings); 
 
        } 
 
    } 
 
    @Override 
    @Transactional(rollbackFor=Exception.class) 
    public void setStateBatch(List<Long> idList, Integer type, Integer state) throws Exception { 
 
        for (Long id : idList) { 
 
            UserRankings userRankings = userRankingsMapper.selectByPrimaryKey(id); 
 
            if (userRankings == null) { 
                continue; 
            } 
 
            if (type == 1 || type.equals(1)) { 
                userRankings.setTradeState(state); 
 
                if (state != null && state.equals(1)) { 
                    userRankings.setTradeTime(new Date()); 
                } 
            } else { 
                userRankings.setShareState(state); 
 
                if (state != null && state.equals(1)) { 
                    userRankings.setShareTime(new Date()); 
                } 
            } 
 
            userRankingsMapper.updateByPrimaryKey(userRankings); 
 
        } 
 
    } 
 
    @Override 
    @Transactional(rollbackFor=Exception.class) 
    public void uploadFile(File file) throws Exception { 
 
        List<UserRankings> list = new ArrayList<UserRankings>(); 
 
        File[] files = file.listFiles(); 
 
        for (File filePic : files) {// 遍历这个数组 
            String name = filePic.getName(); 
            System.out.println("name" + name); 
            String prefix = name.substring(name.lastIndexOf(".") + 1); 
            // 上传文件相对位置 
            String fileUrl = FilePathEnum.userRankings.getPath() + UUID.randomUUID().toString().replace("-", "") + "." + prefix; 
            System.out.println(fileUrl); 
 
            FileInputStream is = new FileInputStream(filePic); 
 
            String uploadFilePath = COSManager.getInstance().uploadFile(is, fileUrl).getUrl(); 
 
            /* 更新数据库信息 */ 
            if (!StringUtil.isNullOrEmpty(uploadFilePath)) { 
                UserRankings userRankings = new UserRankings(); 
                userRankings.setPortrait(uploadFilePath); 
                userRankings.setCreatetime(new Date()); 
                list.add(userRankings); 
            } 
 
            is.close(); 
        } 
 
        if (list.size() > 0) { 
            userRankingsMapper.insertBatch(list); 
        } 
    } 
 
    @Override 
    @Transactional(rollbackFor=Exception.class) 
    public void updateShowID(File file) throws Exception { 
        List<String> listID = new ArrayList<String>(); 
 
        BufferedReader br = new BufferedReader(new FileReader(file));// 构造一个BufferedReader类来读取文件 
        String s = ""; 
        while ((s = br.readLine()) != null) {// 使用readLine方法，一次读一行 
            listID.add(s); 
        } 
        br.close(); 
 
        int i = 0; 
        List<UserRankings> list = userRankingsMapper.queryAll(); 
        for (UserRankings userRankings : list) { 
 
            String showId = listID.get(i); 
            i++; 
 
            userRankings.setShowId(showId); 
        } 
 
        userRankingsMapper.updateBatchSelective(list); 
 
    } 
 
    @Override 
    @Transactional(rollbackFor=Exception.class) 
    public void batchUpNickName(File file) throws Exception { 
        List<String> listID = new ArrayList<String>(); 
 
        BufferedReader br = new BufferedReader(new FileReader(file));// 构造一个BufferedReader类来读取文件 
        String s = ""; 
        while ((s = br.readLine()) != null) {// 使用readLine方法，一次读一行 
            listID.add(s); 
        } 
        br.close(); 
 
        int i = 0; 
        List<UserRankings> list = userRankingsMapper.queryAll(); 
        for (UserRankings userRankings : list) { 
 
            String nickName = listID.get(i); 
            i++; 
 
            userRankings.setNickName(nickName); 
        } 
 
        userRankingsMapper.updateBatchSelective(list); 
 
    } 
 
    @Override 
    public List<UserRankings> listQueryByIds(List<Long> ids) throws UserRankingsException { 
        return userRankingsMapper.listQueryByIds(ids); 
    } 
 
    @Override 
    public List<InviteGetMoney> getRank(long start, int count) { 
         
        List<InviteGetMoney> resultList = new ArrayList<InviteGetMoney>(); 
         
        List<InviteGetMoney> rankingsList = new ArrayList<InviteGetMoney>(); 
         
        try { 
 
             List<UserRankings> userRankingsList = query(0, count, null, 1, null, 2); 
 
            for (UserRankings userRankings : userRankingsList) { 
 
                InviteGetMoney invite = new InviteGetMoney(); 
                String showId = userRankings.getShowId(); 
                if (StringUtil.isNullOrEmpty(showId)) { 
                    showId = "2***5"; 
                } 
                invite.setUid(showId); 
                invite.setName(userRankings.getNickName()); 
                // invite.setIcon(userRankings.getPortrait()); 
                invite.setPortrait(userRankings.getPortrait()); 
                invite.setMoney(userRankings.getTradeReward()); 
                invite.setCreateTime(userRankings.getCreatetime()); 
                rankingsList.add(invite); 
            } 
 
            Calendar calendar = Calendar.getInstance(); 
            calendar.add(Calendar.DATE, -1); 
 
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); // 设置时间格式 
            String defaultDate = sdf.format(calendar.getTime()); // 格式化前一天 
 
            // 真实用户 
            List<HongBaoV2VO> listHongBao = hongBaoV2CountService.listShareAndInviteMoney(0, count, defaultDate); 
            if (listHongBao != null && listHongBao.size() > 0) { 
                HongBaoV2VO hongBao = listHongBao.get(0); 
                BigDecimal maxMoney = hongBao.getTotalMoney(); 
 
                UserRankings userRankings = userRankingsList.get(userRankingsList.size() - 1); 
                BigDecimal mminMoney = userRankings.getTradeReward(); 
 
                // 真实数据大于最低金额 
                if (maxMoney.compareTo(mminMoney) > 0) { 
                    for (HongBaoV2VO hb : listHongBao) { 
                        BigDecimal rewardMoney = hb.getTotalMoney(); 
 
                        // 奖金高到低排序，不满足结束循环 
                        if (rewardMoney.compareTo(mminMoney) <= 0) { 
                            break; 
                        } 
 
                        UserInfo userInfo = hb.getUserInfo(); 
                        if (userInfo != null) { 
 
                            InviteGetMoney invite = new InviteGetMoney(); 
 
                            invite.setName(userInfo.getNickName()); 
                            // invite.setIcon(userRankings.getPortrait()); 
                            invite.setPortrait(userInfo.getPortrait()); 
                            invite.setMoney(rewardMoney); 
                            invite.setCreateTime(new Date()); 
 
                            // 处理id 
                            Long id = userInfo.getId(); 
                            String uid = id + ""; 
                            String index = uid.substring(0, 1); 
                            String end = uid.substring(uid.length() - 1, uid.length()); 
                            invite.setUid(index + "***" + end); 
                            rankingsList.add(invite); 
 
                        } 
 
                    } 
                } 
            } 
 
            List<InviteGetMoney> list = listSort(rankingsList); 
             
            if (list.size() > count) { 
                resultList = list.subList(0, count-1); 
            } else { 
                resultList = list; 
            } 
             
            for (int i = 0 ;i<resultList.size() ; i++) { 
                long n = i+1; 
                String icon = ""; 
                if (n == 1) { 
                    icon ="http://buxinimg.oss-cn-qingdao.aliyuncs.com/5e75b65b6eca4c74850a7306d7584663.png"; 
                } 
                if (n == 2) { 
                    icon ="http://buxinimg.oss-cn-qingdao.aliyuncs.com/442c950dd14a41a8849c0597f643ddd2.png"; 
                } 
                if (n == 3) { 
                    icon ="http://buxinimg.oss-cn-qingdao.aliyuncs.com/5c9559905f034541888e674b30dbbeb3.png"; 
                } 
                if (n == 4) { 
                    icon ="http://buxinimg.oss-cn-qingdao.aliyuncs.com/531b640cf73042ac929750e5ff610a20.png"; 
                } 
                if (n == 5) { 
                    icon ="http://buxinimg.oss-cn-qingdao.aliyuncs.com/2a229650a22c4ce09e3c60e8cddafdd6.png"; 
                } 
                resultList.get(i).setIcon(icon); 
                 
                 
                resultList.get(i).setRankIcon("http://ec-1255749512.file.myqcloud.com/resource/rank/rank_icon_3.png"); 
                resultList.get(i).setId(n); 
            } 
             
             
        } catch (UserRankingsException e) { 
            e.printStackTrace(); 
        } 
         
        return resultList; 
         
         
    } 
 
    public List<InviteGetMoney> listSort(List<InviteGetMoney> list) { 
 
        Collections.sort(list, new Comparator<InviteGetMoney>() { 
            public int compare(InviteGetMoney p1, InviteGetMoney p2) { 
 
                // 按照Person的年龄进行升序排列 
                if (p1.getMoney().compareTo(p2.getMoney()) < 0) { 
                    return 1; 
                } 
 
                if (p1.getMoney().compareTo(p2.getMoney()) == 0) { 
                    return 0; 
                } 
                return -1; 
            } 
        }); 
 
        return list; 
    } 
}