| | |
|---|
| | | package com.yeshi.fanli.service.impl.user;
|
|---|
| | |
|
|---|
| | | import java.text.DecimalFormat;
|
|---|
| | | import java.math.BigDecimal;
|
|---|
| | | import java.util.ArrayList;
|
|---|
| | | import java.util.Collections;
|
|---|
| | | import java.util.Comparator;
|
|---|
| | | import java.util.List;
|
|---|
| | |
|
|---|
| | | import javax.annotation.Resource;
|
|---|
| | |
|
|---|
| | | import org.apache.ibatis.annotations.Param;
|
|---|
| | | import org.hibernate.HibernateException;
|
|---|
| | | import org.hibernate.SQLQuery;
|
|---|
| | | import org.hibernate.Session;
|
|---|
| | | import org.springframework.orm.hibernate4.HibernateCallback;
|
|---|
| | | import com.yeshi.fanli.entity.SystemEnum;
|
|---|
| | | import com.yeshi.fanli.service.inter.common.CommonConfigService;
|
|---|
| | | import org.springframework.stereotype.Service;
|
|---|
| | | import org.springframework.transaction.annotation.Transactional;
|
|---|
| | |
|
|---|
| | | import com.yeshi.fanli.dao.mybatis.user.ShamUserMapper;
|
|---|
| | | import com.yeshi.fanli.dao.user.ShamUserDao;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.HongBaoMessage;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.ShamUser;
|
|---|
| | | import com.yeshi.fanli.entity.system.ConfigKeyEnum;
|
|---|
| | | import com.yeshi.fanli.service.inter.config.ConfigService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.ShamUserService;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.Utils;
|
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | |
|
|---|
| | | import net.sf.json.JSONArray;
|
|---|
| | |
|
|---|
| | | @Service
|
|---|
| | | public class ShamUserServiceImpl implements ShamUserService {
|
|---|
| | | |
|---|
| | | @Resource
|
|---|
| | | private ShamUserDao dao;
|
|---|
| | | |
|---|
| | | @Resource
|
|---|
| | | private ShamUserMapper shamUserMapper;
|
|---|
| | | |
|---|
| | | |
|---|
| | | @Transactional
|
|---|
| | | public void addShamUser(ShamUser shamUser) {
|
|---|
| | | dao.save(shamUser);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public List<ShamUser> getAll() {
|
|---|
| | | return dao.list("from ShamUser");
|
|---|
| | | }
|
|---|
| | | @Resource
|
|---|
| | | private ShamUserMapper shamUserMapper;
|
|---|
| | |
|
|---|
| | | |
|---|
| | | @SuppressWarnings("unchecked")
|
|---|
| | | public List<ShamUser> findShamUserList(int sum){
|
|---|
| | | return (List<ShamUser>) dao.excute(new HibernateCallback<List<ShamUser>>() {
|
|---|
| | | @Resource
|
|---|
| | | private ConfigService configService;
|
|---|
| | | @Resource
|
|---|
| | | private CommonConfigService commonConfigService;
|
|---|
| | |
|
|---|
| | | public List<ShamUser> doInHibernate(Session session)
|
|---|
| | | throws HibernateException {
|
|---|
| | | SQLQuery query = session.createSQLQuery("SELECT * FROM yeshi_ec_demouser ORDER BY id desc").addEntity(ShamUser.class);
|
|---|
| | | query.setFirstResult(0);
|
|---|
| | | query.setMaxResults(sum);
|
|---|
| | | List<ShamUser> list = query.list();
|
|---|
| | | return list;
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | @SuppressWarnings("unchecked")
|
|---|
| | | public List<HongBaoMessage> getManyData() {
|
|---|
| | | |
|---|
| | | return (List<HongBaoMessage>) dao.excute(new HibernateCallback<List<HongBaoMessage>>() {
|
|---|
| | | @Transactional
|
|---|
| | | public void addShamUser(ShamUser shamUser) {
|
|---|
| | | shamUserMapper.insertSelective(shamUser);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public List<HongBaoMessage> doInHibernate(Session session)
|
|---|
| | | throws HibernateException {
|
|---|
| | | SQLQuery query = session.createSQLQuery("SELECT * FROM yeshi_ec_sham_user ORDER BY RAND()").addEntity(ShamUser.class);
|
|---|
| | | query.setFirstResult(0);
|
|---|
| | | query.setMaxResults(Constant.PAGE_SIZE);
|
|---|
| | | List<ShamUser> list = query.list();
|
|---|
| | | List<HongBaoMessage> hbmList=new ArrayList<HongBaoMessage>();
|
|---|
| | | if(list.size()>0){
|
|---|
| | | HongBaoMessage hbm = null;
|
|---|
| | | DecimalFormat df = new DecimalFormat("######0.00"); |
|---|
| | | for (ShamUser shamUser : list) {
|
|---|
| | | hbm=new HongBaoMessage();
|
|---|
| | | hbm.setName(shamUser.getName());
|
|---|
| | | hbm.setPicUrl(shamUser.getPicUrl());
|
|---|
| | | double random = (Math.random()+0.01)*20;
|
|---|
| | | String format = df.format(random);
|
|---|
| | | hbm.setContent("悄悄领取了"+format+"元红包");
|
|---|
| | | hbmList.add(hbm);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | return hbmList;
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | @Transactional
|
|---|
| | | public void delete(final long id) {
|
|---|
| | | dao.excute(new HibernateCallback() {
|
|---|
| | | public Object doInHibernate(Session session)
|
|---|
| | | throws HibernateException {
|
|---|
| | | session.createQuery(" delete ShamUser su where su.id = ? ").setParameter(0, id).executeUpdate();
|
|---|
| | | return null;
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | }
|
|---|
| | | public List<ShamUser> getAll() {
|
|---|
| | | return shamUserMapper.listAll();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @SuppressWarnings("unchecked")
|
|---|
| | | public List<HongBaoMessage> findShamThreeSaleInfo() {
|
|---|
| | | public List<ShamUser> findShamUserList(int sum) {
|
|---|
| | | return shamUserMapper.listShamUserByKey(0, sum, null);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return (List<HongBaoMessage>) dao.excute(new HibernateCallback<List<HongBaoMessage>>() {
|
|---|
| | | @Override
|
|---|
| | | public int deleteByPrimaryKey(Long id) {
|
|---|
| | | return shamUserMapper.deleteByPrimaryKey(id);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public List<HongBaoMessage> doInHibernate(Session session)
|
|---|
| | | throws HibernateException {
|
|---|
| | | SQLQuery query = session.createSQLQuery("SELECT * FROM yeshi_ec_sham_user ORDER BY RAND()").addEntity(ShamUser.class);
|
|---|
| | | query.setFirstResult(0);
|
|---|
| | | query.setMaxResults(5);
|
|---|
| | | List<ShamUser> list = query.list();
|
|---|
| | | List<HongBaoMessage> hbmList=new ArrayList<HongBaoMessage>();
|
|---|
| | | if(list.size()>0){
|
|---|
| | | HongBaoMessage hbm = null;
|
|---|
| | | DecimalFormat df = new DecimalFormat("######0.00"); |
|---|
| | | for (ShamUser shamUser : list) {
|
|---|
| | | String name = shamUser.getName();
|
|---|
| | | if(name != null){
|
|---|
| | | if(name.length() > 2){
|
|---|
| | | name = Utils.getStarString(name,1,name.length()-1);
|
|---|
| | | }else{
|
|---|
| | | name = name.substring(0, 1)+"**"+name.substring(name.length()-1);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | shamUser.setName(name);
|
|---|
| | | hbm=new HongBaoMessage();
|
|---|
| | | hbm.setName(shamUser.getName());
|
|---|
| | | hbm.setPicUrl(shamUser.getPicUrl());
|
|---|
| | | double random = (Math.random()+100)*10;
|
|---|
| | | String format = df.format(random);
|
|---|
| | | hbm.setContent(format+"");
|
|---|
| | | hbmList.add(hbm);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | Collections.sort(hbmList, new Comparator<HongBaoMessage>() {
|
|---|
| | | public int compare(HongBaoMessage o1, HongBaoMessage o2) {
|
|---|
| | | double o1m = Double.parseDouble(o1.getContent());
|
|---|
| | | double o2m = Double.parseDouble(o2.getContent());
|
|---|
| | | double m=o1m-o2m;
|
|---|
| | | return m<0?1:-1;
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | return hbmList;
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | | |
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public int insert(ShamUser record) {
|
|---|
| | | return shamUserMapper.insert(record);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public int deleteByPrimaryKey(Long id) {
|
|---|
| | | return shamUserMapper.deleteByPrimaryKey(id);
|
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public int insertSelective(ShamUser record) {
|
|---|
| | | return shamUserMapper.insertSelective(record);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public int insert(ShamUser record) {
|
|---|
| | | return shamUserMapper.insert(record);
|
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public ShamUser selectByPrimaryKey(Long id) {
|
|---|
| | | return shamUserMapper.selectByPrimaryKey(id);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public int insertSelective(ShamUser record) {
|
|---|
| | | return shamUserMapper.insertSelective(record);
|
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public int updateByPrimaryKeySelective(ShamUser record) {
|
|---|
| | | return shamUserMapper.updateByPrimaryKeySelective(record);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public ShamUser selectByPrimaryKey(Long id) {
|
|---|
| | | return shamUserMapper.selectByPrimaryKey(id);
|
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public int updateByPrimaryKey(ShamUser record) {
|
|---|
| | | return shamUserMapper.updateByPrimaryKey(record);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public int updateByPrimaryKeySelective(ShamUser record) {
|
|---|
| | | return shamUserMapper.updateByPrimaryKeySelective(record);
|
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public List<ShamUser> listDistinctPicUrl(long start, int count) {
|
|---|
| | | return shamUserMapper.listByDistinctPicUrl(start, count);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public int updateByPrimaryKey(ShamUser record) {
|
|---|
| | | return shamUserMapper.updateByPrimaryKey(record);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | |
|---|
| | | @Override
|
|---|
| | | public List<ShamUser> listDistinctPicUrl(long start, int count) {
|
|---|
| | | return shamUserMapper.listByDistinctPicUrl(start, count);
|
|---|
| | | }
|
|---|
| | | @Override
|
|---|
| | | public int insertBatch(List<ShamUser> list) {
|
|---|
| | | return shamUserMapper.insertBatch(list);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public int updateBatchSelective(List<ShamUser> list) {
|
|---|
| | | return shamUserMapper.updateBatchSelective(list);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public List<ShamUser> listRandCouponUser(int count, int smallTime, int largeTime) {
|
|---|
| | | List<Integer> listTime = new ArrayList<Integer>();
|
|---|
| | |
|
|---|
| | | while (listTime.size() < count) {
|
|---|
| | | int time = smallTime + (int) (Math.random() * (largeTime - smallTime + 1));
|
|---|
| | | if (!listTime.contains(Integer.valueOf(time))) {
|
|---|
| | | listTime.add(Integer.valueOf(time));
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | Collections.sort(listTime);
|
|---|
| | |
|
|---|
| | | List<ShamUser> listRand = shamUserMapper.listRand(count);
|
|---|
| | |
|
|---|
| | | for (int i = 1; i <= count; i++) {
|
|---|
| | | ShamUser shamUser = (ShamUser) listRand.get(i - 1);
|
|---|
| | |
|
|---|
| | | transformId(shamUser);
|
|---|
| | |
|
|---|
| | | shamUser.setMsg(listTime.get(listTime.size() - i) + "秒前购买了此商品");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return listRand;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public List<ShamUser> listRandShareUser(int count, BigDecimal shareMoney, int small, int large) {
|
|---|
| | |
|
|---|
| | | List<Integer> listMultiple = new ArrayList<Integer>();
|
|---|
| | |
|
|---|
| | | while (listMultiple.size() < count) {
|
|---|
| | | int Multiple = small + (int) (Math.random() * (large - small + 1));
|
|---|
| | | listMultiple.add(Integer.valueOf(Multiple));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | List<String> imgList = new ArrayList<String>();
|
|---|
| | | String value = commonConfigService.getValue(ConfigKeyEnum.shareBonusPicture.getKey());
|
|---|
| | |
|
|---|
| | | if (!StringUtil.isNullOrEmpty(value)) {
|
|---|
| | | JSONArray array = JSONArray.fromObject(value);
|
|---|
| | | if (array != null) {
|
|---|
| | | for (int n = 0; n < array.size(); n++) {
|
|---|
| | | imgList.add(array.optString(n));
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | List<ShamUser> listRand = shamUserMapper.listRand(count);
|
|---|
| | |
|
|---|
| | | for (int i = 0; i < count; i++) {
|
|---|
| | | ShamUser shamUser = (ShamUser) listRand.get(i);
|
|---|
| | |
|
|---|
| | | transformId(shamUser);
|
|---|
| | |
|
|---|
| | | if (imgList.size() > 0) {
|
|---|
| | | int randBonusPic = (int) (Math.random() * imgList.size());
|
|---|
| | | shamUser.setShareBonusPic((String) imgList.get(randBonusPic));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | BigDecimal money = shareMoney.multiply(new BigDecimal(((Integer) listMultiple.get(i)).intValue()))
|
|---|
| | | .setScale(2, 1);
|
|---|
| | | // 必须包含 【奖金¥】 这3个符号， 用于前端颜色区分
|
|---|
| | | shamUser.setMsg("分享了这个商品,累计获得奖金¥" + money);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return listRand;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public void transformId(ShamUser shamUser) {
|
|---|
| | | String id = shamUser.getId() + "";
|
|---|
| | | if (id.length() == 1) {
|
|---|
| | | shamUser.setShowId("2****" + id);
|
|---|
| | | } else {
|
|---|
| | | shamUser.setShowId(id.substring(0, 1) + "****" + id.substring(id.length() - 2, id.length() - 1));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | String name = shamUser.getName();
|
|---|
| | | if (StringUtil.isNullOrEmpty(name)) {
|
|---|
| | | // 名字为空时
|
|---|
| | | String start = randomName();
|
|---|
| | | String end = randomName();
|
|---|
| | | shamUser.setName(start + "**" + end);
|
|---|
| | | } else if (name.length() == 1) {
|
|---|
| | | // 一个字
|
|---|
| | | String start = name;
|
|---|
| | | if (start.trim().length() == 0 || start.equals("*")) {
|
|---|
| | | start = randomName();
|
|---|
| | | }
|
|---|
| | | String end = randomName();
|
|---|
| | | shamUser.setName(start + "**" + end);
|
|---|
| | | } else {
|
|---|
| | | // 两个字及其以上
|
|---|
| | | String start = name.substring(0, 1);
|
|---|
| | | String end = name.substring(name.length() - 2, name.length() - 1);
|
|---|
| | | if (start.trim().length() == 0 || start.equals("*")) {
|
|---|
| | | start = randomName();
|
|---|
| | | }
|
|---|
| | | if (end.trim().length() == 0 || end.equals("*")) {
|
|---|
| | | end = randomName();
|
|---|
| | | }
|
|---|
| | | shamUser.setName(start + "**" + end);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 随机名称
|
|---|
| | | *
|
|---|
| | | * @return
|
|---|
| | | */
|
|---|
| | | public String randomName() {
|
|---|
| | | String[] array = {"A", "B", "C", "D", "E", "F", "G", "H", "I", "J", "K", "L", "M", "N", "O", "P", "Q", "R", "S", "T", "U", "V", "W", "X", "Y", "Z",
|
|---|
| | | "我", "半", "士", "思", "一", "成", "城", "罗", "落", "花", "化", "夫", "福", "扶", "浮", "生", "若", "梦", "你", "繁", "华", "三", "起", "七", "易", "已", "意", "衣",
|
|---|
| | | "且", "听", "风", "峰", "枫", "音", "吟", "绝", "倔", "空", "离", "丽", "厘", "留", "六", "流", "瘤", "陆", "鏐", "陸", "紅", "誰", "為", "美", "陳", "塵", "車", "晨",
|
|---|
| | | "光", "零", "鱗", "藺", "離", "口", "了", "酒", "舊", "傷", "賞", "殤", "橋", "巧", "喬", "愛", "啊", "嗄", "譚", "談", "貪", "銀", "汗", "航", "孔", "名", "明", "明", "闵"
|
|---|
| | | , "铭", "鸣", "冥", "飞", "费", "非", "废", "达", "去", "曲", "渠", "小", "笑", "晓", "消", "校", "西", "妖", "娆", "破", "眸", "凉", "微", "兮", "つ", "越", "黑", "舊", "素",
|
|---|
| | | "憾", "无", "っ", "つ", "烟", "東", "烁", "弃", "绕", "雪", "月", "航"};
|
|---|
| | | return array[(int) (Math.random() * array.length - 1)];
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public List<ShamUser> listRandUser(int count) {
|
|---|
| | | return shamUserMapper.listRand(count);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
