diff --git a/tkdata-model-server/pom.xml b/tkdata-model-server/pom.xml index 5215c89..8b2aae6 100644 --- a/tkdata-model-server/pom.xml +++ b/tkdata-model-server/pom.xml @@ -49,6 +49,11 @@ cn.iocoder.boot yudao-spring-boot-starter-excel + + cn.iocoder.boot + yudao-module-infra + 2.6.0-jdk8-SNAPSHOT + UTF-8 diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/EmployeeHostsController.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/EmployeeHostsController.java new file mode 100644 index 0000000..d4525d8 --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/EmployeeHostsController.java @@ -0,0 +1,112 @@ +package cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts; + +import org.springframework.web.bind.annotation.*; +import javax.annotation.Resource; +import org.springframework.validation.annotation.Validated; +import org.springframework.security.access.prepost.PreAuthorize; +import io.swagger.v3.oas.annotations.tags.Tag; +import io.swagger.v3.oas.annotations.Parameter; +import io.swagger.v3.oas.annotations.Operation; + +import javax.validation.constraints.*; +import javax.validation.*; +import javax.servlet.http.*; +import java.util.*; +import java.io.IOException; + +import cn.iocoder.yudao.framework.common.pojo.PageParam; +import cn.iocoder.yudao.framework.common.pojo.PageResult; +import cn.iocoder.yudao.framework.common.pojo.CommonResult; +import cn.iocoder.yudao.framework.common.util.object.BeanUtils; +import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success; + +import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils; + +import cn.iocoder.yudao.framework.apilog.core.annotation.ApiAccessLog; +import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.*; + +import cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts.vo.*; +import cn.iocoder.yudao.module.tkdata.dal.dataobject.employeehosts.EmployeeHostsDO; +import cn.iocoder.yudao.module.tkdata.service.employeehosts.EmployeeHostsService; + +@Tag(name = "管理后台 - 员工分配主播表") +@RestController +@RequestMapping("/server/employee-hosts") +@Validated +public class EmployeeHostsController { + + @Resource + private EmployeeHostsService employeeHostsService; + + @PostMapping("/create") + @Operation(summary = "创建员工分配主播") + @PreAuthorize("@ss.hasPermission('server:employee-hosts:create')") + public CommonResult createEmployeeHosts(@Valid @RequestBody EmployeeHostsSaveReqVO createReqVO) { + return success(employeeHostsService.createEmployeeHosts(createReqVO)); + } + + @PutMapping("/update") + @Operation(summary = "更新员工分配主播") + @PreAuthorize("@ss.hasPermission('server:employee-hosts:update')") + public CommonResult updateEmployeeHosts(@Valid @RequestBody EmployeeHostsSaveReqVO updateReqVO) { + employeeHostsService.updateEmployeeHosts(updateReqVO); + return success(true); + } + + @DeleteMapping("/delete") + @Operation(summary = "删除员工分配主播") + @Parameter(name = "id", description = "编号", required = true) + @PreAuthorize("@ss.hasPermission('server:employee-hosts:delete')") + public CommonResult deleteEmployeeHosts(@RequestParam("id") Long id) { + employeeHostsService.deleteEmployeeHosts(id); + return success(true); + } + + @DeleteMapping("/delete-list") + @Parameter(name = "ids", description = "编号", required = true) + @Operation(summary = "批量删除员工分配主播") + @PreAuthorize("@ss.hasPermission('server:employee-hosts:delete')") + public CommonResult deleteEmployeeHostsList(@RequestParam("ids") List ids) { + employeeHostsService.deleteEmployeeHostsListByIds(ids); + return success(true); + } + + @GetMapping("/get") + @Operation(summary = "获得员工分配主播") + @Parameter(name = "id", description = "编号", required = true, example = "1024") + @PreAuthorize("@ss.hasPermission('server:employee-hosts:query')") + public CommonResult getEmployeeHosts(@RequestParam("id") Long id) { + EmployeeHostsDO employeeHosts = employeeHostsService.getEmployeeHosts(id); + return success(BeanUtils.toBean(employeeHosts, EmployeeHostsRespVO.class)); + } + + @GetMapping("/page") + @Operation(summary = "获得员工分配主播分页") + @PreAuthorize("@ss.hasPermission('server:employee-hosts:query')") + public CommonResult> getEmployeeHostsPage(@Valid EmployeeHostsPageReqVO pageReqVO) { + PageResult pageResult = employeeHostsService.getEmployeeHostsPage(pageReqVO); + return success(BeanUtils.toBean(pageResult, EmployeeHostsRespVO.class)); + } + + @GetMapping("/export-excel") + @Operation(summary = "导出员工分配主播Excel") + @PreAuthorize("@ss.hasPermission('server:employee-hosts:export')") + @ApiAccessLog(operateType = EXPORT) + public void exportEmployeeHostsExcel(@Valid EmployeeHostsPageReqVO pageReqVO, + HttpServletResponse response) throws IOException { + pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE); + List list = employeeHostsService.getEmployeeHostsPage(pageReqVO).getList(); + // 导出 Excel + ExcelUtils.write(response, "员工分配主播.xls", "数据", EmployeeHostsRespVO.class, + BeanUtils.toBean(list, EmployeeHostsRespVO.class)); + } + + @PostMapping("/allocation") + @Parameter(name = "hostsList", description = "主播信息List", required = true) + @Operation(summary = "批量分配主播给员工") + @PreAuthorize("@ss.hasPermission('server:employee-hosts:allocation')") + public CommonResult deleteNewHostsList(@RequestBody List hostsList) { + return success(employeeHostsService.allocationHostsEmployee(hostsList)); + } + +} \ No newline at end of file diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsPageReqVO.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsPageReqVO.java new file mode 100644 index 0000000..7253a22 --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsPageReqVO.java @@ -0,0 +1,56 @@ +package cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts.vo; + +import lombok.*; +import java.util.*; +import io.swagger.v3.oas.annotations.media.Schema; +import cn.iocoder.yudao.framework.common.pojo.PageParam; +import org.springframework.format.annotation.DateTimeFormat; +import java.time.LocalDateTime; + +import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND; + +@Schema(description = "管理后台 - 员工分配主播分页 Request VO") +@Data +public class EmployeeHostsPageReqVO extends PageParam { + + @Schema(description = "主播id", example = "26407") + private String hostsId; + + @Schema(description = "用户 Id", example = "22763") + private Long userId; + + @Schema(description = "主播等级") + private String hostsLevel; + + @Schema(description = "主播金币") + private Integer hostsCoins; + + @Schema(description = "邀请类型", example = "1") + private Integer invitationType; + + @Schema(description = "在线人数") + private Integer onlineFans; + + @Schema(description = "粉丝数量") + private Integer fans; + + @Schema(description = "关注数量") + private Integer fllowernum; + + @Schema(description = "昨日金币") + private Integer yesterdayCoins; + + @Schema(description = "主播国家") + private String country; + + @Schema(description = "直播类型 娱乐，游戏 ") + private String hostsKind; + + @Schema(description = "操作状态", example = "1") + private Integer operationStatus; + + @Schema(description = "数据插入时间") + @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) + private LocalDateTime[] createTime; + +} \ No newline at end of file diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsRespVO.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsRespVO.java new file mode 100644 index 0000000..d7afda9 --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsRespVO.java @@ -0,0 +1,71 @@ +package cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.*; +import java.util.*; +import org.springframework.format.annotation.DateTimeFormat; +import java.time.LocalDateTime; +import com.alibaba.excel.annotation.*; + +@Schema(description = "管理后台 - 员工分配主播 Response VO") +@Data +@ExcelIgnoreUnannotated +public class EmployeeHostsRespVO { + + @Schema(description = "主键", requiredMode = Schema.RequiredMode.REQUIRED, example = "14489") + @ExcelProperty("主键") + private Long id; + + @Schema(description = "主播id", requiredMode = Schema.RequiredMode.REQUIRED, example = "26407") + @ExcelProperty("主播id") + private String hostsId; + + @Schema(description = "用户 Id", example = "22763") + @ExcelProperty("用户 Id") + private Long userId; + + @Schema(description = "主播等级") + @ExcelProperty("主播等级") + private String hostsLevel; + + @Schema(description = "主播金币") + @ExcelProperty("主播金币") + private Integer hostsCoins; + + @Schema(description = "邀请类型", example = "1") + @ExcelProperty("邀请类型") + private Integer invitationType; + + @Schema(description = "在线人数") + @ExcelProperty("在线人数") + private Integer onlineFans; + + @Schema(description = "粉丝数量") + @ExcelProperty("粉丝数量") + private Integer fans; + + @Schema(description = "关注数量") + @ExcelProperty("关注数量") + private Integer fllowernum; + + @Schema(description = "昨日金币") + @ExcelProperty("昨日金币") + private Integer yesterdayCoins; + + @Schema(description = "主播国家") + @ExcelProperty("主播国家") + private String country; + + @Schema(description = "直播类型 娱乐，游戏 ") + @ExcelProperty("直播类型 娱乐，游戏 ") + private String hostsKind; + + @Schema(description = "操作状态", example = "1") + @ExcelProperty("操作状态") + private Integer operationStatus; + + @Schema(description = "数据插入时间") + @ExcelProperty("数据插入时间") + private LocalDateTime createTime; + +} \ No newline at end of file diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsSaveReqVO.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsSaveReqVO.java new file mode 100644 index 0000000..9db2f19 --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/employeehosts/vo/EmployeeHostsSaveReqVO.java @@ -0,0 +1,52 @@ +package cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.*; +import java.util.*; +import javax.validation.constraints.*; + +@Schema(description = "管理后台 - 员工分配主播新增/修改 Request VO") +@Data +public class EmployeeHostsSaveReqVO { + + @Schema(description = "主键", requiredMode = Schema.RequiredMode.REQUIRED, example = "14489") + private Long id; + + @Schema(description = "主播id", requiredMode = Schema.RequiredMode.REQUIRED, example = "26407") + @NotEmpty(message = "主播id不能为空") + private String hostsId; + + @Schema(description = "用户 Id", example = "22763") + private Long userId; + + @Schema(description = "主播等级") + private String hostsLevel; + + @Schema(description = "主播金币") + private Integer hostsCoins; + + @Schema(description = "邀请类型", example = "1") + private Integer invitationType; + + @Schema(description = "在线人数") + private Integer onlineFans; + + @Schema(description = "粉丝数量") + private Integer fans; + + @Schema(description = "关注数量") + private Integer fllowernum; + + @Schema(description = "昨日金币") + private Integer yesterdayCoins; + + @Schema(description = "主播国家") + private String country; + + @Schema(description = "直播类型 娱乐，游戏 ") + private String hostsKind; + + @Schema(description = "操作状态", example = "1") + private Integer operationStatus; + +} \ No newline at end of file diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/newhosts/NewHostsController.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/newhosts/NewHostsController.java index ee84b09..c7f1dca 100644 --- a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/newhosts/NewHostsController.java +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/newhosts/NewHostsController.java @@ -1,5 +1,6 @@ package cn.iocoder.yudao.module.tkdata.controller.admin.newhosts; +import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.AllocationHostsSaveReqVO; import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.NewHostsPageReqVO; import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.NewHostsRespVO; import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.NewHostsSaveReqVO; diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/newhosts/vo/AllocationHostsSaveReqVO.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/newhosts/vo/AllocationHostsSaveReqVO.java new file mode 100644 index 0000000..d9720df --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/controller/admin/newhosts/vo/AllocationHostsSaveReqVO.java @@ -0,0 +1,51 @@ +package cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +/* + * @author: ziin + * @date: 2025/6/17 14:18 + */ +@Schema(description = "管理后台 - 分配主播数据新增Request VO") +@Data +public class AllocationHostsSaveReqVO { + + @Schema(description = "主播id", example = "306") + private String hostsId; + + @Schema(description = "主播等级") + private String hostsLevel; + + @Schema(description = "主播金币") + private Integer hostsCoins; + + @Schema(description = "邀请类型", example = "0") + private Integer invitationType; + + @Schema(description = "在线人数") + private Integer onlineFans; + + @Schema(description = "粉丝数量") + private Integer fans; + + @Schema(description = "关注数量") + private Integer fllowernum; + + @Schema(description = "昨日金币") + private Integer yesterdayCoins; + + @Schema(description = "主播国家") + private String country; + + @Schema(description = "直播类型 娱乐，游戏 ") + private String hostsKind; + + @Schema(description = "是否已经分配给员工", example = "0") + private Integer isAssigned; + + @Schema(description = "用户 Id", example = "10967") + private Long userId; + +} + diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/dal/dataobject/employeehosts/EmployeeHostsDO.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/dal/dataobject/employeehosts/EmployeeHostsDO.java new file mode 100644 index 0000000..c27550f --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/dal/dataobject/employeehosts/EmployeeHostsDO.java @@ -0,0 +1,80 @@ +package cn.iocoder.yudao.module.tkdata.dal.dataobject.employeehosts; + +import lombok.*; +import java.util.*; +import java.time.LocalDateTime; +import java.time.LocalDateTime; +import com.baomidou.mybatisplus.annotation.*; +import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO; + +/** + * 员工分配主播 DO + * + * @author 芋道源码 + */ +@TableName("server_employee_hosts") +@KeySequence("server_employee_hosts_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。 +@Data +@EqualsAndHashCode(callSuper = true) +@ToString(callSuper = true) +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class EmployeeHostsDO extends BaseDO { + + /** + * 主键 + */ + @TableId + private Long id; + /** + * 主播id + */ + private String hostsId; + /** + * 用户 Id + */ + private Long userId; + /** + * 主播等级 + */ + private String hostsLevel; + /** + * 主播金币 + */ + private Integer hostsCoins; + /** + * 邀请类型 + */ + private Integer invitationType; + /** + * 在线人数 + */ + private Integer onlineFans; + /** + * 粉丝数量 + */ + private Integer fans; + /** + * 关注数量 + */ + private Integer fllowernum; + /** + * 昨日金币 + */ + private Integer yesterdayCoins; + /** + * 主播国家 + */ + private String country; + /** + * 直播类型 娱乐，游戏 + */ + private String hostsKind; + /** + * 操作状态 + */ + private Integer operationStatus; + + +} \ No newline at end of file diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/dal/mysql/employeehosts/EmployeeHostsMapper.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/dal/mysql/employeehosts/EmployeeHostsMapper.java new file mode 100644 index 0000000..e1e8300 --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/dal/mysql/employeehosts/EmployeeHostsMapper.java @@ -0,0 +1,43 @@ +package cn.iocoder.yudao.module.tkdata.dal.mysql.employeehosts; + +import java.util.*; + +import cn.iocoder.yudao.framework.common.pojo.PageResult; +import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX; +import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX; +import cn.iocoder.yudao.module.tkdata.dal.dataobject.employeehosts.EmployeeHostsDO; +import org.apache.ibatis.annotations.Mapper; +import cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts.vo.*; + +/** + * 员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 Mapper + * + * @author 芋道源码 + */ +@Mapper +public interface EmployeeHostsMapper extends BaseMapperX { + + default PageResult selectPage(EmployeeHostsPageReqVO reqVO) { + return selectPage(reqVO, new LambdaQueryWrapperX() + .likeIfPresent(EmployeeHostsDO::getHostsId, reqVO.getHostsId()) + .eqIfPresent(EmployeeHostsDO::getUserId, reqVO.getUserId()) + .eqIfPresent(EmployeeHostsDO::getHostsLevel, reqVO.getHostsLevel()) + .eqIfPresent(EmployeeHostsDO::getHostsCoins, reqVO.getHostsCoins()) + .eqIfPresent(EmployeeHostsDO::getInvitationType, reqVO.getInvitationType()) + .eqIfPresent(EmployeeHostsDO::getOnlineFans, reqVO.getOnlineFans()) + .eqIfPresent(EmployeeHostsDO::getFans, reqVO.getFans()) + .eqIfPresent(EmployeeHostsDO::getFllowernum, reqVO.getFllowernum()) + .eqIfPresent(EmployeeHostsDO::getYesterdayCoins, reqVO.getYesterdayCoins()) + .eqIfPresent(EmployeeHostsDO::getCountry, reqVO.getCountry()) + .eqIfPresent(EmployeeHostsDO::getHostsKind, reqVO.getHostsKind()) + .eqIfPresent(EmployeeHostsDO::getOperationStatus, reqVO.getOperationStatus()) + .betweenIfPresent(EmployeeHostsDO::getCreateTime, reqVO.getCreateTime()) + .orderByDesc(EmployeeHostsDO::getId)); + } + + int insertIgnore(EmployeeHostsDO bean); + + int batchInsertIgnore(List list); + + +} \ No newline at end of file diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/enums/ErrorCodeConstants.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/enums/ErrorCodeConstants.java index 6f4539a..01ba14b 100644 --- a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/enums/ErrorCodeConstants.java +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/enums/ErrorCodeConstants.java @@ -9,6 +9,7 @@ import cn.iocoder.yudao.framework.common.exception.ErrorCode; */ public interface ErrorCodeConstants { - ErrorCode NEW_HOSTS_NOT_EXISTS = new ErrorCode(1_001_101_000, "主播数据不存在"); - + //===============主播信息 1_001_300_000================= + ErrorCode NEW_HOSTS_NOT_EXISTS = new ErrorCode(1_001_301_000, "主播数据不存在"); + ErrorCode EMPLOYEE_HOSTS_NOT_EXISTS = new ErrorCode(1_001_301_001, "分配员工数据不存在"); } diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsService.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsService.java new file mode 100644 index 0000000..ded3900 --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsService.java @@ -0,0 +1,63 @@ +package cn.iocoder.yudao.module.tkdata.service.employeehosts; + +import java.util.*; +import javax.validation.*; +import cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts.vo.*; +import cn.iocoder.yudao.module.tkdata.dal.dataobject.employeehosts.EmployeeHostsDO; +import cn.iocoder.yudao.framework.common.pojo.PageResult; +import cn.iocoder.yudao.framework.common.pojo.PageParam; + +/** + * 员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 Service 接口 + * + * @author 芋道源码 + */ +public interface EmployeeHostsService { + + /** + * 创建员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 + * + * @param createReqVO 创建信息 + * @return 编号 + */ + Long createEmployeeHosts(@Valid EmployeeHostsSaveReqVO createReqVO); + + /** + * 更新员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 + * + * @param updateReqVO 更新信息 + */ + void updateEmployeeHosts(@Valid EmployeeHostsSaveReqVO updateReqVO); + + /** + * 删除员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 + * + * @param id 编号 + */ + void deleteEmployeeHosts(Long id); + + /** + * 批量删除员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 + * + * @param ids 编号 + */ + void deleteEmployeeHostsListByIds(List ids); + + /** + * 获得员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 + * + * @param id 编号 + * @return 员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 + */ + EmployeeHostsDO getEmployeeHosts(Long id); + + /** + * 获得员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工分页 + * + * @param pageReqVO 分页查询 + * @return 员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工分页 + */ + PageResult getEmployeeHostsPage(EmployeeHostsPageReqVO pageReqVO); + + Integer allocationHostsEmployee(List hostsList); +} \ No newline at end of file diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsServiceImpl.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsServiceImpl.java new file mode 100644 index 0000000..967586f --- /dev/null +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/employeehosts/EmployeeHostsServiceImpl.java @@ -0,0 +1,107 @@ +package cn.iocoder.yudao.module.tkdata.service.employeehosts; + +import cn.hutool.core.collection.CollUtil; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import org.springframework.validation.annotation.Validated; +import org.springframework.transaction.annotation.Transactional; + +import java.util.*; +import cn.iocoder.yudao.module.tkdata.controller.admin.employeehosts.vo.*; +import cn.iocoder.yudao.module.tkdata.dal.dataobject.employeehosts.EmployeeHostsDO; +import cn.iocoder.yudao.framework.common.pojo.PageResult; +import cn.iocoder.yudao.framework.common.pojo.PageParam; +import cn.iocoder.yudao.framework.common.util.object.BeanUtils; + +import cn.iocoder.yudao.module.tkdata.dal.mysql.employeehosts.EmployeeHostsMapper; + +import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; +import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList; +import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.diffList; +import static cn.iocoder.yudao.module.tkdata.enums.ErrorCodeConstants.EMPLOYEE_HOSTS_NOT_EXISTS; + + +/** + * 员工分配主播表，结构和主播表相同，多了user_id 字段来区分所属员工 Service 实现类 + * + * @author 芋道源码 + */ +@Service +@Validated +public class EmployeeHostsServiceImpl implements EmployeeHostsService { + + @Resource + private EmployeeHostsMapper employeeHostsMapper; + + @Override + public Long createEmployeeHosts(EmployeeHostsSaveReqVO createReqVO) { + // 插入 + EmployeeHostsDO employeeHosts = BeanUtils.toBean(createReqVO, EmployeeHostsDO.class); + employeeHostsMapper.insert(employeeHosts); + // 返回 + return employeeHosts.getId(); + } + + @Override + public void updateEmployeeHosts(EmployeeHostsSaveReqVO updateReqVO) { + // 校验存在 + validateEmployeeHostsExists(updateReqVO.getId()); + // 更新 + EmployeeHostsDO updateObj = BeanUtils.toBean(updateReqVO, EmployeeHostsDO.class); + employeeHostsMapper.updateById(updateObj); + } + + @Override + public void deleteEmployeeHosts(Long id) { + // 校验存在 + validateEmployeeHostsExists(id); + // 删除 + employeeHostsMapper.deleteById(id); + } + + @Override + public void deleteEmployeeHostsListByIds(List ids) { + // 校验存在 + validateEmployeeHostsExists(ids); + // 删除 + employeeHostsMapper.deleteByIds(ids); + } + + private void validateEmployeeHostsExists(List ids) { + List list = employeeHostsMapper.selectByIds(ids); + if (CollUtil.isEmpty(list) || list.size() != ids.size()) { + throw exception(EMPLOYEE_HOSTS_NOT_EXISTS); + } + } + + private void validateEmployeeHostsExists(Long id) { + if (employeeHostsMapper.selectById(id) == null) { + throw exception(EMPLOYEE_HOSTS_NOT_EXISTS); + } + } + + @Override + public EmployeeHostsDO getEmployeeHosts(Long id) { + return employeeHostsMapper.selectById(id); + } + + @Override + public PageResult getEmployeeHostsPage(EmployeeHostsPageReqVO pageReqVO) { + return employeeHostsMapper.selectPage(pageReqVO); + } + + @Override + public Integer allocationHostsEmployee(List hostsList) { + int count = 0; +// for (EmployeeHostsSaveReqVO employeeHostsSaveReqVO : hostsList) { +// int i = employeeHostsMapper.insertIgnore(); +// count += i; +// } + ArrayList employeeHostsDOS = new ArrayList<>(); + for (EmployeeHostsSaveReqVO employeeHostsSaveReqVO : hostsList) { + employeeHostsDOS.add(BeanUtils.toBean(employeeHostsSaveReqVO, EmployeeHostsDO.class)); + } + return employeeHostsMapper.batchInsertIgnore(employeeHostsDOS); + } + +} \ No newline at end of file diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/newhosts/NewHostsService.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/newhosts/NewHostsService.java index c000516..2c1907f 100644 --- a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/newhosts/NewHostsService.java +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/newhosts/NewHostsService.java @@ -4,6 +4,7 @@ import java.util.*; import javax.validation.*; import cn.iocoder.yudao.framework.common.pojo.PageResult; import cn.iocoder.yudao.framework.common.pojo.PageParam; +import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.AllocationHostsSaveReqVO; import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.NewHostsPageReqVO; import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.NewHostsSaveReqVO; import cn.iocoder.yudao.module.tkdata.dal.dataobject.newhosts.NewHostsDO; diff --git a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/newhosts/NewHostsServiceImpl.java b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/newhosts/NewHostsServiceImpl.java index 7c5833a..0f1eef0 100644 --- a/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/newhosts/NewHostsServiceImpl.java +++ b/tkdata-model-server/src/main/java/cn/iocoder/yudao/module/tkdata/service/newhosts/NewHostsServiceImpl.java @@ -1,6 +1,7 @@ package cn.iocoder.yudao.module.tkdata.service.newhosts; import cn.hutool.core.collection.CollUtil; +import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.AllocationHostsSaveReqVO; import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.NewHostsPageReqVO; import cn.iocoder.yudao.module.tkdata.controller.admin.newhosts.vo.NewHostsSaveReqVO; import cn.iocoder.yudao.module.tkdata.dal.dataobject.newhosts.NewHostsDO; @@ -9,19 +10,16 @@ import cn.iocoder.yudao.module.tkdata.enums.ErrorCodeConstants; import org.springframework.stereotype.Service; import javax.annotation.Resource; import org.springframework.validation.annotation.Validated; -import org.springframework.transaction.annotation.Transactional; import java.util.*; import cn.iocoder.yudao.framework.common.pojo.PageResult; -import cn.iocoder.yudao.framework.common.pojo.PageParam; import cn.iocoder.yudao.framework.common.util.object.BeanUtils; import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList; -import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.diffList; /** diff --git a/tkdata-model-server/src/main/resources/mapper/employeehosts/EmployeeHostsMapper.xml b/tkdata-model-server/src/main/resources/mapper/employeehosts/EmployeeHostsMapper.xml new file mode 100644 index 0000000..41d55d6 --- /dev/null +++ b/tkdata-model-server/src/main/resources/mapper/employeehosts/EmployeeHostsMapper.xml @@ -0,0 +1,60 @@ + + + + + + + + + + + INSERT IGNORE INTO server_employee_hosts + + hosts_id, + user_id, + hosts_level, + hosts_coins, + Invitation_type, + online_fans, + fans, + fllowernum, + yesterday_coins, + country, + operation_status, + hosts_kind + + + #{hostsId}, + #{userId}, + #{hostsLevel}, + #{hostsCoins}, + #{invitationType}, + #{onlineFans}, + #{fans}, + #{fllowernum}, + #{yesterdayCoins}, + #{country}, + #{operationStatus}, + #{hostsKind} + + + + + + INSERT IGNORE INTO server_employee_hosts + (hosts_id, user_id, hosts_level, hosts_coins, Invitation_type, + online_fans, fans, fllowernum, yesterday_coins, country, + operation_status, hosts_kind) + VALUES + + (#{item.hostsId}, #{item.userId}, #{item.hostsLevel}, #{item.hostsCoins}, #{item.invitationType}, + #{item.onlineFans}, #{item.fans}, #{item.fllowernum}, #{item.yesterdayCoins}, #{item.country}, + #{item.operationStatus}, #{item.hostsKind}) + + + \ No newline at end of file