分页等。。。

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/param/KylinAcitveParam.java

+package com.liquidnet.service.kylin.dto.param;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.liquidnet.commons.lang.util.DateUtil;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2022-07-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class KylinAcitveParam implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private Long mid;
+
+    /**
+     * 活动名称
+     */
+    @ApiModelProperty(value = "活动名称")
+    private String activeName;
+
+    /**
+     * 券的数量
+     */
+    @ApiModelProperty(value = "券的数量")
+    private Integer number;
+
+    /**
+     * activeId
+     */
+    @ApiModelProperty(value = "activeId")
+    private String activeId;
+
+    /**
+     * 创建时间
+     */
+    @ApiModelProperty(value = "创建时间")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern= DateUtil.DATE_FULL_STR)
+    private LocalDateTime createdAt;
+
+    /**
+     * 修改时间
+     */
+    @ApiModelProperty(value = "修改时间")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern=DateUtil.DATE_FULL_STR)
+    private LocalDateTime updatedAt;
+
+    /**
+     * 0未删除1已删除
+     */
+    @ApiModelProperty(value = "0未删除1已删除")
+    private Integer delTag;
+
+    /**
+     * 演出id
+     */
+    @ApiModelProperty(value = "演出id")
+    private String performanceId;
+
+
+}

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinAcitveService.java

 package com.liquidnet.service.kylin.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.github.pagehelper.PageInfo;
 import com.liquidnet.service.kylin.dao.KylinAcitve;
 
 /**
@@ -15,5 +16,6 @@ public interface IKylinAcitveService extends IService<KylinAcitve> {
 
     boolean addKylinAcitve(KylinAcitve kylinAcitve);
 
+    PageInfo<KylinAcitve> pageKylinAcitve(int pageSize, int pageNumber);
 
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/kylin/KylinAcitveController.java

 package com.liquidnet.client.admin.web.controller.zhengzai.kylin;
 
 
+import com.liquidnet.client.admin.common.core.domain.AjaxResult;
 import com.liquidnet.client.admin.zhengzai.kylin.service.impl.KylinAcitveServiceImpl;
+import com.liquidnet.service.kylin.dao.KylinAcitve;
+import com.liquidnet.service.kylin.dto.param.KylinAcitveParam;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.RequestMapping;
-
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 /**
  * <p>
@@ -20,4 +23,21 @@ public class KylinAcitveController {
     @Autowired
     private KylinAcitveServiceImpl kylinAcitveService;
 
+    @PostMapping("add")
+    @ApiOperation(value = "增加活动")
+    @ResponseBody
+    public AjaxResult add(@RequestBody KylinAcitveParam kylinAcitveParam) {
+        KylinAcitve kylinAcitve=new KylinAcitve();
+        BeanUtils.copyProperties(kylinAcitveParam,kylinAcitve);
+        kylinAcitveService.addKylinAcitve(kylinAcitve);
+        return AjaxResult.success("操作成功", "");
+    }
+    @PostMapping("page")
+    @ApiOperation(value = "分页活动")
+    @ResponseBody
+    public AjaxResult page( @RequestParam(name = "pageSize", required = true) int pageSize,@RequestParam(name = "pageNumber", required = true)int pageNumber) {
+        return AjaxResult.success(kylinAcitveService.pageKylinAcitve(pageSize,pageNumber));
+    }
+
+
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinAcitveServiceImpl.java

 package com.liquidnet.client.admin.zhengzai.kylin.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.kylin.dao.KylinAcitve;
 import com.liquidnet.service.kylin.dao.KylinTicketActive;
@@ -36,23 +40,43 @@ public class KylinAcitveServiceImpl extends ServiceImpl<KylinAcitveMapper, Kylin
     @Override
     @Transactional
     public boolean addKylinAcitve(KylinAcitve kylinAcitve) {
-        //kylinAcitve.setActiveId();
+        kylinAcitve.setActiveId(IDGenerator.nextSnowId());
         //保存活动
         kylinAcitveMapper.insert(kylinAcitve);
         //创建券
         iKylinTicketActiveService.saveBatch(getKylinTicketActive(kylinAcitve.getNumber(),kylinAcitve.getActiveId()));
         return true;
     }
+
+    @Override
+    public PageInfo<KylinAcitve> pageKylinAcitve(int pageSize, int pageNumber) {
+        PageInfo<KylinAcitve> pageInfoTmp = null;
+        try {
+            PageHelper.startPage(pageNumber, pageSize);
+            LambdaQueryWrapper<KylinAcitve> queryWrapper = Wrappers.lambdaQuery(KylinAcitve.class);
+            List<KylinAcitve> list=kylinAcitveMapper.selectList(queryWrapper);
+            pageInfoTmp = new PageInfo(list);
+        } catch (Exception e) {
+            return new PageInfo();
+        }
+        return pageInfoTmp;
+    }
+
     public List<KylinTicketActive> getKylinTicketActive(int number,String activeId){
         List<KylinTicketActive> list = new ArrayList<>();
         if(number>0){
-            KylinTicketActive kylinTicketActive=new KylinTicketActive();
-            kylinTicketActive.setActivityId(activeId);
-            kylinTicketActive.setCode(IDGenerator.createCode(3, 4, true));
-            kylinTicketActive.setState(1);
-            kylinTicketActive.setCreatedAt(LocalDateTime.now());
-            kylinTicketActive.setUpdatedAt(LocalDateTime.now());
-            list.add(kylinTicketActive);
+            for(int i=0;i<number;i++){
+                KylinTicketActive kylinTicketActive=new KylinTicketActive();
+                kylinTicketActive.setTicketId(IDGenerator.nextSnowId());
+                kylinTicketActive.setActivityId(activeId);
+                kylinTicketActive.setCode(IDGenerator.createCode(3, 4, true));
+                kylinTicketActive.setState(1);
+                kylinTicketActive.setCreatedAt(LocalDateTime.now());
+                kylinTicketActive.setUpdatedAt(LocalDateTime.now());
+                kylinTicketActive.setDelTag(0);
+                list.add(kylinTicketActive);
+            }
+            return list;
         }
         return null;
     }