yujian
2019-03-20 1e53e5f28c55ece70b28c752fa318e2fd951e643
fanli/src/main/java/com/yeshi/fanli/service/impl/user/ShamUserServiceImpl.java
@@ -7,15 +7,10 @@
import javax.annotation.Resource;
import org.hibernate.HibernateException;
import org.hibernate.SQLQuery;
import org.hibernate.Session;
import org.springframework.orm.hibernate4.HibernateCallback;
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.ShamUser;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.user.ShamUserService;
@@ -25,55 +20,25 @@
@Service
public class ShamUserServiceImpl implements ShamUserService {
   @Resource
   private ShamUserDao dao;
   @Resource
   private ShamUserMapper shamUserMapper;
   @Resource
   private ConfigService configService;
   @Transactional
   public void addShamUser(ShamUser shamUser) {
      dao.save(shamUser);
      shamUserMapper.insertSelective(shamUser);
   }
   public List<ShamUser> getAll() {
      return dao.list("from ShamUser");
      return shamUserMapper.listAll();
   }
   @SuppressWarnings("unchecked")
   public List<ShamUser> findShamUserList(int sum){
      return (List<ShamUser>) dao.excute(new HibernateCallback<List<ShamUser>>() {
         public List<ShamUser> doInHibernate(Session session)
               throws HibernateException {
            SQLQuery query = session.createSQLQuery("SELECT * FROM yeshi_ec_sham_user").addEntity(ShamUser.class);
            query.setFirstResult(0);
            query.setMaxResults(sum);
            List<ShamUser> list = query.list();
            return list;
         }
      });
   public List<ShamUser> findShamUserList(int sum) {
      return shamUserMapper.listShamUserByKey(0, sum, null);
   }
   @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;
         }
      });
   }
   @Override
   public int deleteByPrimaryKey(Long id) {
@@ -104,23 +69,22 @@
   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>();
@@ -149,7 +113,7 @@
   @Override
   public List<ShamUser> listRandShareUser(int count, BigDecimal shareMoney, int small, int large) {
      List<Integer> listMultiple = new ArrayList<Integer>();
      while (listMultiple.size() < count) {
@@ -182,8 +146,9 @@
            shamUser.setShareBonusPic((String) imgList.get(randBonusPic));
         }
         BigDecimal money = shareMoney.multiply(new BigDecimal(((Integer) listMultiple.get(i)).intValue())).setScale(2, 1);
         // 必须包含 【奖金¥】  这3个符号,  用于前端颜色区分
         BigDecimal money = shareMoney.multiply(new BigDecimal(((Integer) listMultiple.get(i)).intValue()))
               .setScale(2, 1);
         // 必须包含 【奖金¥】 这3个符号, 用于前端颜色区分
         shamUser.setMsg("分享了这个商品,累计获得奖金¥" + money);
      }
@@ -192,7 +157,7 @@
   public void transformId(ShamUser shamUser) {
      String id = shamUser.getId() + "";
      if (id.length() == 1) {
         shamUser.setShowId("2****" + id);
      } else {
@@ -200,7 +165,6 @@
      }
   }
   @Override
   public List<ShamUser> listRandUser(int count) {
      return shamUserMapper.listRand(count);