新增common_push_task_num，基础的增删改查接口

alien-entity/src/main/java/shop/alien/entity/store/CommonPushTaskNum.java

@@ -0,0 +1,78 @@
+package shop.alien.entity.store;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 推送任务数量统计表（按机型）
+ */
+@Data
+@JsonInclude
+@TableName("common_push_task_num")
+@ApiModel(value = "CommonPushTaskNum", description = "推送任务数量统计表")
+public class CommonPushTaskNum implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("主键ID")
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    @ApiModelProperty("活动ID，关联 common_push_task.id")
+    @TableField("push_task_id")
+    private Long pushTaskId;
+
+    @ApiModelProperty("机型：1-OPPO 2-VIVO 3-华为 4-苹果 5-荣耀 6-小米 7-三星")
+    @TableField("phone_type")
+    private String phoneType;
+
+    @ApiModelProperty("预计发送数")
+    @TableField("expected_send")
+    private String expectedSend;
+
+    @ApiModelProperty("实际发送数")
+    @TableField("real_send")
+    private String realSend;
+
+    @ApiModelProperty("实际送达数")
+    @TableField("real_delivered")
+    private String realDelivered;
+
+    @ApiModelProperty("点击数")
+    @TableField("click_sum")
+    private String clickSum;
+
+    @ApiModelProperty("展示数")
+    @TableField("show_sum")
+    private String showSum;
+
+    @ApiModelProperty("删除标记，0:未删除，1:已删除")
+    @TableField("delete_flag")
+    @TableLogic
+    private Integer deleteFlag;
+
+    @ApiModelProperty("创建时间")
+    @TableField(value = "created_time", fill = FieldFill.INSERT)
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date createdTime;
+
+    @ApiModelProperty("创建人ID")
+    @TableField("created_user_id")
+    private Integer createdUserId;
+
+    @ApiModelProperty("修改时间")
+    @TableField(value = "updated_time", fill = FieldFill.INSERT_UPDATE)
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date updatedTime;
+
+    @ApiModelProperty("修改人ID")
+    @TableField("updated_user_id")
+    private Integer updatedUserId;
+}

alien-entity/src/main/java/shop/alien/mapper/CommonPushTaskNumMapper.java

@@ -0,0 +1,7 @@
+package shop.alien.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import shop.alien.entity.store.CommonPushTaskNum;
+
+public interface CommonPushTaskNumMapper extends BaseMapper<CommonPushTaskNum> {
+}

alien-store/src/main/java/shop/alien/store/controller/CommonPushTaskNumController.java

@@ -0,0 +1,77 @@
+package shop.alien.store.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiOperationSupport;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+import shop.alien.entity.result.R;
+import shop.alien.entity.store.CommonPushTaskNum;
+import shop.alien.store.service.CommonPushTaskNumService;
+
+@Api(tags = {"推送任务数量统计管理"})
+@Slf4j
+@RestController
+@CrossOrigin
+@RequestMapping("/commonPushTaskNum")
+@RequiredArgsConstructor
+public class CommonPushTaskNumController {
+
+    private final CommonPushTaskNumService commonPushTaskNumService;
+
+    @ApiOperation("新增推送任务数量统计")
+    @ApiOperationSupport(order = 1)
+    @PostMapping("/add")
+    public R<String> add(@RequestBody CommonPushTaskNum taskNum) {
+        return commonPushTaskNumService.add(taskNum);
+    }
+
+    @ApiOperation("根据主键删除（逻辑删除）")
+    @ApiOperationSupport(order = 2)
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "主键ID", dataType = "Long", paramType = "query", required = true)
+    })
+    @GetMapping("/deleteById")
+    public R<String> deleteById(@RequestParam Long id) {
+        return commonPushTaskNumService.deleteById(id);
+    }
+
+    @ApiOperation("更新推送任务数量统计")
+    @ApiOperationSupport(order = 3)
+    @PostMapping("/update")
+    public R<String> update(@RequestBody CommonPushTaskNum taskNum) {
+        return commonPushTaskNumService.update(taskNum);
+    }
+
+    @ApiOperation("根据主键查询")
+    @ApiOperationSupport(order = 4)
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "主键ID", dataType = "Long", paramType = "query", required = true)
+    })
+    @GetMapping("/getById")
+    public R<CommonPushTaskNum> getById(@RequestParam Long id) {
+        return commonPushTaskNumService.getInfoById(id);
+    }
+
+    @ApiOperation("分页列表")
+    @ApiOperationSupport(order = 5)
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "pageNum", value = "页码", dataType = "Integer", paramType = "query", required = true),
+            @ApiImplicitParam(name = "pageSize", value = "每页数量", dataType = "Integer", paramType = "query", required = true),
+            @ApiImplicitParam(name = "pushTaskId", value = "推送任务ID", dataType = "Long", paramType = "query"),
+            @ApiImplicitParam(name = "phoneType", value = "机型：1-OPPO 2-VIVO 3-华为 4-苹果 5-荣耀 6-小米 7-三星", dataType = "String", paramType = "query")
+
+    })
+    @GetMapping("/list")
+    public R<IPage<CommonPushTaskNum>> list(
+            @RequestParam Integer pageNum,
+            @RequestParam Integer pageSize,
+            @RequestParam(required = false) Long pushTaskId,
+            @RequestParam(required = false) String phoneType) {
+        return commonPushTaskNumService.list(pageNum, pageSize, pushTaskId, phoneType);
+    }
+}

alien-store/src/main/java/shop/alien/store/service/CommonPushTaskNumService.java

@@ -0,0 +1,19 @@
+package shop.alien.store.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.IService;
+import shop.alien.entity.result.R;
+import shop.alien.entity.store.CommonPushTaskNum;
+
+public interface CommonPushTaskNumService extends IService<CommonPushTaskNum> {
+
+    R<String> add(CommonPushTaskNum taskNum);
+
+    R<String> deleteById(Long id);
+
+    R<String> update(CommonPushTaskNum taskNum);
+
+    R<CommonPushTaskNum> getInfoById(Long id);
+
+    R<IPage<CommonPushTaskNum>> list(Integer pageNum, Integer pageSize, Long pushTaskId, String phoneType);
+}

alien-store/src/main/java/shop/alien/store/service/impl/CommonPushTaskNumServiceImpl.java

@@ -0,0 +1,66 @@
+package shop.alien.store.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import shop.alien.entity.result.R;
+import shop.alien.entity.store.CommonPushTaskNum;
+import shop.alien.mapper.CommonPushTaskNumMapper;
+import shop.alien.store.service.CommonPushTaskNumService;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class CommonPushTaskNumServiceImpl extends ServiceImpl<CommonPushTaskNumMapper, CommonPushTaskNum> implements CommonPushTaskNumService {
+
+    @Override
+    public R<String> add(CommonPushTaskNum taskNum) {
+        log.info("CommonPushTaskNumServiceImpl.add, param={}", taskNum);
+        boolean result = this.save(taskNum);
+        return result ? R.success("新增成功") : R.fail("新增失败");
+    }
+
+    @Override
+    public R<String> deleteById(Long id) {
+        log.info("CommonPushTaskNumServiceImpl.deleteById, id={}", id);
+        boolean result = this.removeById(id);
+        return result ? R.success("删除成功") : R.fail("删除失败");
+    }
+
+    @Override
+    public R<String> update(CommonPushTaskNum taskNum) {
+        log.info("CommonPushTaskNumServiceImpl.update, param={}", taskNum);
+        if (taskNum.getId() == null) {
+            return R.fail("id不能为空");
+        }
+        boolean result = this.updateById(taskNum);
+        return result ? R.success("更新成功") : R.fail("更新失败");
+    }
+
+    @Override
+    public R<CommonPushTaskNum> getInfoById(Long id) {
+        log.info("CommonPushTaskNumServiceImpl.getInfoById, id={}", id);
+        return R.data(this.getById(id));
+    }
+
+    @Override
+    public R<IPage<CommonPushTaskNum>> list(Integer pageNum, Integer pageSize, Long pushTaskId, String phoneType) {
+        log.info("CommonPushTaskNumServiceImpl.list, pageNum={}, pageSize={}, pushTaskId={}, phoneType={}",
+                pageNum, pageSize, pushTaskId, phoneType);
+        Page<CommonPushTaskNum> page = new Page<>(pageNum, pageSize);
+        LambdaQueryWrapper<CommonPushTaskNum> wrapper = new LambdaQueryWrapper<>();
+        if (pushTaskId != null) {
+            wrapper.eq(CommonPushTaskNum::getPushTaskId, pushTaskId);
+        }
+        if (StringUtils.isNotBlank(phoneType)) {
+            wrapper.eq(CommonPushTaskNum::getPhoneType, phoneType);
+        }
+        wrapper.orderByDesc(CommonPushTaskNum::getUpdatedTime);
+        return R.data(this.page(page, wrapper));
+    }
+}