From aa7500e10900d5a655af8a57990d8d84a2d117e6 Mon Sep 17 00:00:00 2001 From: masterspirit Date: Sat, 25 Aug 2018 17:22:53 +0800 Subject: [PATCH] =?UTF-8?q?[=E7=96=B2=E5=8A=B3=E5=BA=A6][=E6=96=B0?= =?UTF-8?q?=E5=A2=9E]=E7=96=B2=E5=8A=B3=E5=BA=A6=E8=AE=BE=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/PushLimitController.java | 61 ++++++ .../java/com/simple/domain/po/PushLimit.java | 182 ++++++++++++++++++ .../com/simple/mapper/PushLimitMapper.java | 17 ++ .../com/simple/service/PushLimitService.java | 47 +++++ .../service/impl/PushLimitServiceImpl.java | 53 +++++ .../main/resources/mapper/PushLimitMapper.xml | 86 +++++++++ 6 files changed, 446 insertions(+) create mode 100644 mallinkAdmin/src/main/java/com/simple/controller/PushLimitController.java create mode 100644 mallinkService/src/main/java/com/simple/domain/po/PushLimit.java create mode 100644 mallinkService/src/main/java/com/simple/mapper/PushLimitMapper.java create mode 100644 mallinkService/src/main/java/com/simple/service/PushLimitService.java create mode 100644 mallinkService/src/main/java/com/simple/service/impl/PushLimitServiceImpl.java create mode 100644 mallinkService/src/main/resources/mapper/PushLimitMapper.xml diff --git a/mallinkAdmin/src/main/java/com/simple/controller/PushLimitController.java b/mallinkAdmin/src/main/java/com/simple/controller/PushLimitController.java new file mode 100644 index 000000000..5f5e786d5 --- /dev/null +++ b/mallinkAdmin/src/main/java/com/simple/controller/PushLimitController.java @@ -0,0 +1,61 @@ +package com.simple.controller; + +import com.github.pagehelper.PageInfo; +import com.simple.common.Result; +import com.simple.common.ResultData; +import com.simple.domain.po.PushLimit; +import com.simple.service.PushLimitService; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; +import org.apache.log4j.Logger; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +@RestController +@RequestMapping("pushLimit") +public class PushLimitController extends BaseController +{ + @Autowired + private PushLimitService pushLimitService; + + private Logger logger = Logger.getLogger(PushLimitController.class); + + @ApiOperation("分页列表接口") + @GetMapping("list") + @ApiImplicitParams({ + @ApiImplicitParam(name="pageNum",value="页数",dataType="int", paramType = "query",required=true), + @ApiImplicitParam(name="pageSize",value="每页条数",dataType="int", paramType = "query",required=true)}) + public ResultData list(@ModelAttribute PushLimit pushLimit, Integer pageNum, Integer pageSize) { + if (null == pushLimit) pushLimit = new PushLimit(); + final PageInfo page = pushLimitService.listAsPage(pushLimit, pageNum, pageSize); + return new ResultData(page); + } + + + + @ApiOperation("根据id更新接口") + @PostMapping("update") + public ResultData update(@RequestBody PushLimit pushLimit) { + pushLimitService.saveOrUpdate(pushLimit); + return new ResultData(); + } + + @ApiOperation("根据id删除接口") + @GetMapping("/del") + @ApiImplicitParam(name="id",value="id",dataType="Long", paramType = "query",required=true) + public ResultData delete(Long id) { + pushLimitService.deleteById(id); + return new ResultData(Result.SUCCESS, "删除成功", null); + } + + @ApiOperation("根据id查询接口") + @GetMapping("/findById") + @ApiImplicitParam(name="id",value="id",dataType="Long", paramType = "query",required=true) + public ResultData findById(Long id) { + return new ResultData(Result.SUCCESS,"查询成功",pushLimitService.getById(id)); + } + + + +} diff --git a/mallinkService/src/main/java/com/simple/domain/po/PushLimit.java b/mallinkService/src/main/java/com/simple/domain/po/PushLimit.java new file mode 100644 index 000000000..f69432df6 --- /dev/null +++ b/mallinkService/src/main/java/com/simple/domain/po/PushLimit.java @@ -0,0 +1,182 @@ +package com.simple.domain.po; + +import javax.persistence.*; +import java.util.*; +import java.math.*; +import javax.persistence.Transient; +import java.util.List; +import javax.persistence.Id; +import java.io.Serializable; + +@Table(name = "push_limit") +public class PushLimit implements Serializable { + private static final long serialVersionUID = 1L; + + @Id + protected Long id; + + @Transient + protected List ids; + @Transient + protected String sortColumns; + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + + public String getSortColumns() { + return sortColumns; + } + + public List getIds() { + return ids; + } + + public void setIds(List ids) { + this.ids = ids; + } + + + + /***/ + @io.swagger.annotations.ApiModelProperty(value="",name="tenantId") + private String tenantId; + /*每人每天可接收短信数**/ + @io.swagger.annotations.ApiModelProperty(value="每人每天可接收短信数",name="msgAmount") + private Integer msgAmount; + /*每人每周可接收发券数**/ + @io.swagger.annotations.ApiModelProperty(value="每人每周可接收发券数",name="couponAmount") + private Integer couponAmount; + /*每人几天内,不会收到同一个券**/ + @io.swagger.annotations.ApiModelProperty(value="每人几天内,不会收到同一个券",name="couponDay") + private Integer couponDay; + /*禁止发券,发短信开始时间**/ + @io.swagger.annotations.ApiModelProperty(value="禁止发券,发短信开始时间",name="refuseTimeStart") + private String refuseTimeStart; + /*禁止发券,发短信结束时间**/ + @io.swagger.annotations.ApiModelProperty(value="禁止发券,发短信结束时间",name="refuseTimeEnd") + private String refuseTimeEnd; + /***/ + @io.swagger.annotations.ApiModelProperty(value="",name="createTime") + private Date createTime; + /***/ + @io.swagger.annotations.ApiModelProperty(value="",name="updateTime") + private Date updateTime; + public String getTenantId() { + return tenantId; + } + public void setTenantId(String _tenantId) { + tenantId = _tenantId; + } + public Integer getMsgAmount() { + return msgAmount; + } + public void setMsgAmount(Integer _msgAmount) { + msgAmount = _msgAmount; + } + public Integer getCouponAmount() { + return couponAmount; + } + public void setCouponAmount(Integer _couponAmount) { + couponAmount = _couponAmount; + } + public Integer getCouponDay() { + return couponDay; + } + public void setCouponDay(Integer _couponDay) { + couponDay = _couponDay; + } + public String getRefuseTimeStart() { + return refuseTimeStart; + } + public void setRefuseTimeStart(String _refuseTimeStart) { + refuseTimeStart = _refuseTimeStart; + } + public String getRefuseTimeEnd() { + return refuseTimeEnd; + } + public void setRefuseTimeEnd(String _refuseTimeEnd) { + refuseTimeEnd = _refuseTimeEnd; + } + public Date getCreateTime() { + return createTime; + } + public void setCreateTime(Date _createTime) { + createTime = _createTime; + } + public Date getUpdateTime() { + return updateTime; + } + public void setUpdateTime(Date _updateTime) { + updateTime = _updateTime; + } + + + + public static enum Field + { + Id_ASC("`id` ASC"),Id_DESC("`id` DESC") + ,TenantId_ASC("`tenantId` ASC"),TenantId_DESC("`tenantId` DESC") + ,MsgAmount_ASC("`msgAmount` ASC"),MsgAmount_DESC("`msgAmount` DESC") + ,CouponAmount_ASC("`couponAmount` ASC"),CouponAmount_DESC("`couponAmount` DESC") + ,CouponDay_ASC("`couponDay` ASC"),CouponDay_DESC("`couponDay` DESC") + ,RefuseTimeStart_ASC("`refuseTimeStart` ASC"),RefuseTimeStart_DESC("`refuseTimeStart` DESC") + ,RefuseTimeEnd_ASC("`refuseTimeEnd` ASC"),RefuseTimeEnd_DESC("`refuseTimeEnd` DESC") + ,CreateTime_ASC("`createTime` ASC"),CreateTime_DESC("`createTime` DESC") + ,UpdateTime_ASC("`updateTime` ASC"),UpdateTime_DESC("`updateTime` DESC") + ; + private String value; + Field(String value){ + this.value = value; + } + public String getValue() { + return value; + } + public void setCol(String value) { + this.value = value; + } + @Override + public String toString() { + return this.getValue(); + } + } + + public void setSortColumns(PushLimit.Field... fields) + { + if (fields == null || fields.length == 0) { + return; + } + for (int k = 0; k < fields.length; k++) { + if (fields[k] == null) { + return; + } + } + StringBuilder sb = new StringBuilder(fields[0].toString()); + for (int k = 1; k < fields.length; k++) { + sb.append(","); + sb.append(fields[k].toString()); + } + + } + + public void setSortColumns(String sortColumns) + { + if (sortColumns == null || "".equals(sortColumns.trim())) { + return; + } + if (sortColumns.contains(",")) { + String[] cols = sortColumns.split(","); + java.util.List fList = new java.util.ArrayList(); + for (int k = 0; k < cols.length; k++) { + fList.add(Field.valueOf(cols[k])); + } + this.setSortColumns(fList.toArray(new Field[fList.size()])); + } else { + this.setSortColumns(Field.valueOf(sortColumns)); + } + } +} diff --git a/mallinkService/src/main/java/com/simple/mapper/PushLimitMapper.java b/mallinkService/src/main/java/com/simple/mapper/PushLimitMapper.java new file mode 100644 index 000000000..ba55ddf6e --- /dev/null +++ b/mallinkService/src/main/java/com/simple/mapper/PushLimitMapper.java @@ -0,0 +1,17 @@ +package com.simple.mapper; + +import com.simple.common.CommonMapper; +import com.simple.domain.po.PushLimit; + +import java.util.List; + +public interface PushLimitMapper extends CommonMapper { + + List findList(PushLimit pushLimit); + + + + + + +} diff --git a/mallinkService/src/main/java/com/simple/service/PushLimitService.java b/mallinkService/src/main/java/com/simple/service/PushLimitService.java new file mode 100644 index 000000000..452a61470 --- /dev/null +++ b/mallinkService/src/main/java/com/simple/service/PushLimitService.java @@ -0,0 +1,47 @@ +package com.simple.service; + +import com.github.pagehelper.PageInfo; +import com.simple.domain.po.PushLimit; + +public interface PushLimitService { + + /** + * 根据实体查询分页列表 + * + * @param record + * @param offset + * @param limit + * @return + */ + PageInfo listAsPage(PushLimit record, Integer pageIndex, Integer pageSize); + + /** + * 根据Id获得实体 + * + * @param id + * @return + */ + PushLimit getById(Long id); + + /** + * 保存或更新实体 + * + * @param record + */ + void saveOrUpdate(PushLimit record); + + /** + * 根据Id删除实体 + * + * @param id + */ + void deleteById(Long id); + + + + + + + + +} diff --git a/mallinkService/src/main/java/com/simple/service/impl/PushLimitServiceImpl.java b/mallinkService/src/main/java/com/simple/service/impl/PushLimitServiceImpl.java new file mode 100644 index 000000000..cb3fc7c1c --- /dev/null +++ b/mallinkService/src/main/java/com/simple/service/impl/PushLimitServiceImpl.java @@ -0,0 +1,53 @@ +package com.simple.service.impl; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.simple.common.IdWorker; +import com.simple.domain.po.PushLimit; +import com.simple.mapper.PushLimitMapper; +import com.simple.service.PushLimitService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +@Service +public class PushLimitServiceImpl implements PushLimitService { + + @Autowired + PushLimitMapper pushLimitMapper; + + + @Override + public PageInfo listAsPage(PushLimit record, Integer pageIndex, Integer pageSize) { + return PageHelper.startPage(pageIndex, pageSize).doSelectPageInfo(() -> pushLimitMapper.findList(record)); + } + + @Override + public PushLimit getById(Long id) { + return pushLimitMapper.selectByPrimaryKey(id); + } + + @Override + public void saveOrUpdate(PushLimit record) { + if (record.getId() == null) { + //record.setId(UUID.randomUUID().toString().replaceAll("-", "")); + IdWorker idWorker = new IdWorker(0, 0); + record.setId(idWorker.nextId()); + pushLimitMapper.insertSelective(record); + } else { + pushLimitMapper.updateByPrimaryKeySelective(record); + } + } + + @Override + public void deleteById(Long id) { + pushLimitMapper.deleteByPrimaryKey(id); + } + + + + + + + + +} diff --git a/mallinkService/src/main/resources/mapper/PushLimitMapper.xml b/mallinkService/src/main/resources/mapper/PushLimitMapper.xml new file mode 100644 index 000000000..9567dfb30 --- /dev/null +++ b/mallinkService/src/main/resources/mapper/PushLimitMapper.xml @@ -0,0 +1,86 @@ + + + + + + + + + + + + + + + + + `id`,`tenant_id`,`msg_amount`,`coupon_amount`,`coupon_day`,`refuse_time_start`,`refuse_time_end`,`create_time`,`update_time` + + + + where 1 = 1 + + + and `id` = #{id} + + + + + and `tenant_id` like concat('%', #{tenantId},'%') + + + + + and `msg_amount` = #{msgAmount} + + + + + and `coupon_amount` = #{couponAmount} + + + + + and `coupon_day` = #{couponDay} + + + + + and `refuse_time_start` like concat('%', #{refuseTimeStart},'%') + + + + + and `refuse_time_end` like concat('%', #{refuseTimeEnd},'%') + + + + + and `create_time` = #{createTime} + + + + + and `update_time` = #{updateTime} + + + + and id in + + #{idItem} + + + order by ${sortColumns} + + + + + + + + + +