package com.yihu.jw.service;/** * Created by nature of king on 2018/6/8. */ import com.yihu.base.mysql.query.BaseJpaService; import com.yihu.jw.dao.TaskGoodsDao; import com.yihu.jw.entity.health.bank.TaskGoodsDO; import com.yihu.jw.restmodel.common.Envelop; import com.yihu.jw.rm.health.bank.HealthBankMapping; import com.yihu.jw.util.ISqlUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.BeanPropertyRowMapper; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Service; import javax.transaction.Transactional; import java.util.Date; import java.util.List; import java.util.Map; /** * @author wangzhinan * @create 2018-06-08 15:46 * @desc 活动商品 service **/ @Service @Transactional public class TaskGoodsService extends BaseJpaService { @Autowired private TaskGoodsDao taskGoodsDao; @Autowired private JdbcTemplate jdbcTemplate; /** * 查看商品 * * @param taskGoodsDO 活动商品对象 * @param page 页码 * @param size 分页大小 * @return */ public Envelop selectByCondition(TaskGoodsDO taskGoodsDO, Integer page, Integer size){ String sql = new ISqlUtils().getSql(taskGoodsDO,page,size,"*"); List taskGoodsDOS = jdbcTemplate.query(sql,new BeanPropertyRowMapper(TaskGoodsDO.class)); String sqlcount = new ISqlUtils().getSql(taskGoodsDO,0,0,"count"); List> rstotal = jdbcTemplate.queryForList(sqlcount); Long count = 0L; if(rstotal!=null&&rstotal.size()>0){ count = (Long) rstotal.get(0).get("total"); } return Envelop.getSuccessListWithPage(HealthBankMapping.api_success, taskGoodsDOS,page,size,count); } /** * 添加活动商品 * * @param taskGoodsDO 活动商品对象 * @return */ public Envelop insert(TaskGoodsDO taskGoodsDO){ taskGoodsDO.setCreateTime(new Date()); taskGoodsDO.setUpdateTime(new Date()); Envelop envelop = new Envelop<>(); taskGoodsDao.save(taskGoodsDO); envelop.setObj(true); return envelop; } /** * 更新活动商品 * * @param taskGoodsDO * @return */ public Envelop update(TaskGoodsDO taskGoodsDO){ Envelop envelop = new Envelop<>(); String sql = ISqlUtils.getUpdateSql(taskGoodsDO); jdbcTemplate.update(sql); envelop.setObj(true); return envelop; } }