diff --git a/src/main/java/com/ycwl/basic/controller/pc/ProjectController.java b/src/main/java/com/ycwl/basic/controller/pc/ProjectController.java new file mode 100644 index 00000000..77027f38 --- /dev/null +++ b/src/main/java/com/ycwl/basic/controller/pc/ProjectController.java @@ -0,0 +1,102 @@ +package com.ycwl.basic.controller.pc; + +import com.ycwl.basic.model.pc.project.entity.ProjectEntity; +import com.ycwl.basic.model.pc.project.req.ProjectReqQuery; +import com.ycwl.basic.model.pc.project.resp.ProjectRespVO; +import com.ycwl.basic.service.pc.ProjectService; +import com.ycwl.basic.storage.enums.StorageAcl; +import com.ycwl.basic.utils.ApiResponse; +import com.ycwl.basic.utils.WxMpUtil; +import com.ycwl.basic.repository.ScenicRepository; +import com.ycwl.basic.storage.StorageFactory; +import com.ycwl.basic.storage.adapters.IStorageAdapter; +import com.ycwl.basic.model.pc.mp.MpConfigEntity; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.io.File; + +/** + * 景区项目管理控制器 + * + * @Author: Claude + * @Date: 2025-01-15 + */ +@RestController +@RequestMapping("/api/project/v1") +public class ProjectController { + + @Autowired + private ProjectService projectService; + + @Autowired + private ScenicRepository scenicRepository; + + // 分页查询 + @PostMapping("/page") + public ApiResponse page(@RequestBody ProjectReqQuery projectReqQuery) { + return ApiResponse.success(projectService.pageQuery(projectReqQuery)); + } + + // 列表查询 + @PostMapping("/list") + public ApiResponse list(@RequestBody ProjectReqQuery projectReqQuery) { + return ApiResponse.success(projectService.list(projectReqQuery)); + } + + // 详情查询 + @GetMapping("/getDetails/{id}") + public ApiResponse getDetails(@PathVariable("id") Long id) { + return ApiResponse.success(projectService.getById(id)); + } + + // 新增或修改 + @PostMapping("/addOrUpdate") + public ApiResponse addOrUpdate(@RequestBody ProjectEntity project) { + return ApiResponse.success(projectService.addOrUpdate(project)); + } + + // 删除 + @DeleteMapping("/delete/{id}") + public ApiResponse delete(@PathVariable("id") Long id) { + return ApiResponse.success(projectService.delete(id)); + } + + // 修改状态 + @PutMapping("/updateStatus/{id}") + public ApiResponse updateStatus(@PathVariable("id") Long id) { + return ApiResponse.success(projectService.updateStatus(id)); + } + + // 根据项目ID下载小程序二维码 + @GetMapping("/{id}/QRCode") + public ApiResponse downloadQrCode(@PathVariable Long id) { + ProjectRespVO project = projectService.getById(id); + if (project == null) { + return ApiResponse.fail("项目不存在"); + } + MpConfigEntity mpConfig = scenicRepository.getScenicMpConfig(project.getScenicId()); + if (mpConfig == null) { + return ApiResponse.fail("小程序配置不存在"); + } + String appId = mpConfig.getAppId(); + String appSecret = mpConfig.getAppSecret(); + String appState = mpConfig.getState(); + String path = "pages/home/index?scenicId=" + project.getScenicId() + "&projectId=" + id; + String filePath = "qr_code_project_" + id + ".jpg"; + IStorageAdapter adapter = StorageFactory.use(); + if (adapter.isExists(filePath)) { + return ApiResponse.success(adapter.getUrl(filePath)); + } + try { + WxMpUtil.generateWXAQRCode(appId, appSecret, appState, path, filePath); + File file = new File(filePath); + String s = adapter.uploadFile(null, file, filePath); + file.delete(); + adapter.setAcl(StorageAcl.PUBLIC_READ, filePath); + return ApiResponse.success(s); + } catch (Exception e) { + return ApiResponse.fail("生成二维码失败"); + } + } +} \ No newline at end of file diff --git a/src/main/java/com/ycwl/basic/mapper/ProjectMapper.java b/src/main/java/com/ycwl/basic/mapper/ProjectMapper.java new file mode 100644 index 00000000..eaad6d5f --- /dev/null +++ b/src/main/java/com/ycwl/basic/mapper/ProjectMapper.java @@ -0,0 +1,48 @@ +package com.ycwl.basic.mapper; + +import com.ycwl.basic.model.pc.project.entity.ProjectEntity; +import com.ycwl.basic.model.pc.project.req.ProjectReqQuery; +import com.ycwl.basic.model.pc.project.resp.ProjectRespVO; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; + +/** + * 景区项目管理Mapper + * + * @Author: Claude + * @Date: 2025-01-15 + */ +@Mapper +public interface ProjectMapper { + + /** + * 分页查询项目列表 + */ + List list(ProjectReqQuery projectReqQuery); + + /** + * 根据ID查询项目详情 + */ + ProjectRespVO getById(Long id); + + /** + * 新增项目 + */ + int add(ProjectEntity project); + + /** + * 根据ID删除项目 + */ + int deleteById(Long id); + + /** + * 更新项目信息 + */ + int update(ProjectEntity project); + + /** + * 更新项目状态 + */ + int updateStatus(Long id); +} \ No newline at end of file diff --git a/src/main/java/com/ycwl/basic/model/pc/project/entity/ProjectEntity.java b/src/main/java/com/ycwl/basic/model/pc/project/entity/ProjectEntity.java new file mode 100644 index 00000000..9ec6f4fb --- /dev/null +++ b/src/main/java/com/ycwl/basic/model/pc/project/entity/ProjectEntity.java @@ -0,0 +1,49 @@ +package com.ycwl.basic.model.pc.project.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.util.Date; + +/** + * 景区项目管理实体类 + * + * @Author: Claude + * @Date: 2025-01-15 + */ +@Data +@TableName("project") +public class ProjectEntity { + @TableId(type = IdType.AUTO) + private Long id; + + /** + * 景区ID + */ + private Long scenicId; + + /** + * 项目名称 + */ + private String name; + + /** + * 最少游玩时间（分钟） + */ + private Integer minPlayTime; + + /** + * 最长游玩时间（分钟） + */ + private Integer maxPlayTime; + + /** + * 状态，0禁用，1启用 + */ + private Integer status; + + private Date createAt; + private Date updateAt; +} \ No newline at end of file diff --git a/src/main/java/com/ycwl/basic/model/pc/project/req/ProjectReqQuery.java b/src/main/java/com/ycwl/basic/model/pc/project/req/ProjectReqQuery.java new file mode 100644 index 00000000..19809799 --- /dev/null +++ b/src/main/java/com/ycwl/basic/model/pc/project/req/ProjectReqQuery.java @@ -0,0 +1,31 @@ +package com.ycwl.basic.model.pc.project.req; + +import com.ycwl.basic.model.common.BaseQueryParameterReq; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + * 项目查询请求参数 + * + * @Author: Claude + * @Date: 2025-01-15 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class ProjectReqQuery extends BaseQueryParameterReq { + + /** + * 景区ID + */ + private Long scenicId; + + /** + * 项目名称（模糊查询） + */ + private String name; + + /** + * 状态，0禁用，1启用 + */ + private Integer status; +} \ No newline at end of file diff --git a/src/main/java/com/ycwl/basic/model/pc/project/resp/ProjectRespVO.java b/src/main/java/com/ycwl/basic/model/pc/project/resp/ProjectRespVO.java new file mode 100644 index 00000000..37537938 --- /dev/null +++ b/src/main/java/com/ycwl/basic/model/pc/project/resp/ProjectRespVO.java @@ -0,0 +1,50 @@ +package com.ycwl.basic.model.pc.project.resp; + +import lombok.Data; + +import java.util.Date; + +/** + * 项目响应数据 + * + * @Author: Claude + * @Date: 2025-01-15 + */ +@Data +public class ProjectRespVO { + + private Long id; + + /** + * 景区ID + */ + private Long scenicId; + + /** + * 景区名称 + */ + private String scenicName; + + /** + * 项目名称 + */ + private String name; + + /** + * 最少游玩时间（分钟） + */ + private Integer minPlayTime; + + /** + * 最长游玩时间（分钟） + */ + private Integer maxPlayTime; + + /** + * 状态，0禁用，1启用 + */ + private Integer status; + + private Date createAt; + private Date updateAt; +} \ No newline at end of file diff --git a/src/main/java/com/ycwl/basic/service/pc/ProjectService.java b/src/main/java/com/ycwl/basic/service/pc/ProjectService.java new file mode 100644 index 00000000..8e0cc1fb --- /dev/null +++ b/src/main/java/com/ycwl/basic/service/pc/ProjectService.java @@ -0,0 +1,47 @@ +package com.ycwl.basic.service.pc; + +import com.github.pagehelper.PageInfo; +import com.ycwl.basic.model.pc.project.entity.ProjectEntity; +import com.ycwl.basic.model.pc.project.req.ProjectReqQuery; +import com.ycwl.basic.model.pc.project.resp.ProjectRespVO; + +import java.util.List; + +/** + * 景区项目管理服务接口 + * + * @Author: Claude + * @Date: 2025-01-15 + */ +public interface ProjectService { + + /** + * 分页查询项目列表 + */ + PageInfo pageQuery(ProjectReqQuery projectReqQuery); + + /** + * 查询项目列表 + */ + List list(ProjectReqQuery projectReqQuery); + + /** + * 根据ID查询项目详情 + */ + ProjectRespVO getById(Long id); + + /** + * 新增或修改项目 + */ + int addOrUpdate(ProjectEntity project); + + /** + * 删除项目 + */ + int delete(Long id); + + /** + * 更新项目状态 + */ + int updateStatus(Long id); +} \ No newline at end of file diff --git a/src/main/java/com/ycwl/basic/service/pc/impl/ProjectServiceImpl.java b/src/main/java/com/ycwl/basic/service/pc/impl/ProjectServiceImpl.java new file mode 100644 index 00000000..4b5998ce --- /dev/null +++ b/src/main/java/com/ycwl/basic/service/pc/impl/ProjectServiceImpl.java @@ -0,0 +1,104 @@ +package com.ycwl.basic.service.pc.impl; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.ycwl.basic.mapper.ProjectMapper; +import com.ycwl.basic.model.pc.project.entity.ProjectEntity; +import com.ycwl.basic.model.pc.project.req.ProjectReqQuery; +import com.ycwl.basic.model.pc.project.resp.ProjectRespVO; +import com.ycwl.basic.repository.ScenicRepository; +import com.ycwl.basic.service.pc.ProjectService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; +import java.util.Map; +import java.util.Objects; +import java.util.stream.Collectors; + +/** + * 景区项目管理服务实现 + * + * @Author: Claude + * @Date: 2025-01-15 + */ +@Service +public class ProjectServiceImpl implements ProjectService { + + @Autowired + private ProjectMapper projectMapper; + + @Autowired + private ScenicRepository scenicRepository; + + @Override + public PageInfo pageQuery(ProjectReqQuery projectReqQuery) { + PageHelper.startPage(projectReqQuery.getPageNum(), projectReqQuery.getPageSize()); + List list = projectMapper.list(projectReqQuery); + + // 批量获取景区名称 + List scenicIds = list.stream() + .map(ProjectRespVO::getScenicId) + .filter(Objects::nonNull) + .distinct() + .collect(Collectors.toList()); + Map scenicNames = scenicRepository.batchGetScenicNames(scenicIds); + + // 设置景区名称 + list.forEach(item -> { + if (item.getScenicId() != null) { + item.setScenicName(scenicNames.get(item.getScenicId())); + } + }); + + PageInfo pageInfo = new PageInfo(list); + return pageInfo; + } + + @Override + public List list(ProjectReqQuery projectReqQuery) { + List list = projectMapper.list(projectReqQuery); + + // 批量获取景区名称 + List scenicIds = list.stream() + .map(ProjectRespVO::getScenicId) + .filter(Objects::nonNull) + .distinct() + .collect(Collectors.toList()); + Map scenicNames = scenicRepository.batchGetScenicNames(scenicIds); + + // 设置景区名称 + list.forEach(item -> { + if (item.getScenicId() != null) { + item.setScenicName(scenicNames.get(item.getScenicId())); + } + }); + + return list; + } + + @Override + public ProjectRespVO getById(Long id) { + return projectMapper.getById(id); + } + + @Override + public int addOrUpdate(ProjectEntity project) { + Long id = project.getId(); + if (id == null) { + return projectMapper.add(project); + } else { + return projectMapper.update(project); + } + } + + @Override + public int delete(Long id) { + return projectMapper.deleteById(id); + } + + @Override + public int updateStatus(Long id) { + return projectMapper.updateStatus(id); + } +} \ No newline at end of file diff --git a/src/main/resources/mapper/ProjectMapper.xml b/src/main/resources/mapper/ProjectMapper.xml new file mode 100644 index 00000000..f94b6428 --- /dev/null +++ b/src/main/resources/mapper/ProjectMapper.xml @@ -0,0 +1,59 @@ + + + + + insert into project(scenic_id, `name`, min_play_time, max_play_time, status, create_at, update_at) + values (#{scenicId}, #{name}, #{minPlayTime}, #{maxPlayTime}, #{status}, now(), now()) + + + + update project set + `name` = #{name}, + min_play_time = #{minPlayTime}, + max_play_time = #{maxPlayTime}, + status = #{status}, + update_at = now() + where id = #{id} + + + + update project + set status = (CASE + status + WHEN 1 THEN + 0 + WHEN 0 THEN + 1 + ELSE 1 + END), + update_at = now() + where id = #{id} + + + + delete from project where id = #{id} + + + + + + \ No newline at end of file