diff --git a/lottery-system/lottery-common/src/main/java/com/lottery/utils/HttpUtils.java b/lottery-system/lottery-common/src/main/java/com/lottery/utils/HttpUtils.java new file mode 100644 index 0000000..0816170 --- /dev/null +++ b/lottery-system/lottery-common/src/main/java/com/lottery/utils/HttpUtils.java @@ -0,0 +1,56 @@ +package com.lottery.utils; +import java.net.URI; +import java.net.URLEncoder; +import java.net.http.HttpClient; +import java.net.http.HttpRequest; +import java.net.http.HttpResponse; +import java.nio.charset.StandardCharsets; +import java.util.Map; + +public class HttpUtils{ + + private static final HttpClient client = HttpClient.newHttpClient(); + + /** + * 发送 POST 请求（urlencoded 格式，仅设置 Content-Type） + * @param url 接口地址 + * @param params 请求参数（键值对，自动编码） + * @return 响应字符串 + */ + public static String postUrlencoded(String url, Map params) throws Exception { + // 1. 构建 urlencoded 请求体 + StringBuilder requestBody = new StringBuilder(); + for (Map.Entry entry : params.entrySet()) { + if (requestBody.length() > 0) { + requestBody.append("&"); + } + requestBody.append(URLEncoder.encode(entry.getKey(), StandardCharsets.UTF_8)) + .append("=") + .append(URLEncoder.encode(entry.getValue(), StandardCharsets.UTF_8)); + } + + // 2. 创建 HTTP 请求（仅设置 Content-Type） + HttpRequest request = HttpRequest.newBuilder() + .uri(URI.create(url)) + .header("Content-Type", "application/x-www-form-urlencoded") // 仅设置 Content-Type + .POST(HttpRequest.BodyPublishers.ofString(requestBody.toString())) + .build(); + + // 3. 发送请求并返回响应 + return sendRequest(request); + } + + /** + * 发送请求并返回响应 + */ + private static String sendRequest(HttpRequest request) throws Exception { + HttpResponse response = client.send( + request, HttpResponse.BodyHandlers.ofString()); + + if (response.statusCode() >= 400) { + throw new RuntimeException("HTTP 错误，状态码: " + response.statusCode() + ", 响应: " + response.body()); + } + + return response.body(); + } +} \ No newline at end of file diff --git a/lottery-system/lottery-common/src/main/java/com/lottery/utils/ValidationUtils.java b/lottery-system/lottery-common/src/main/java/com/lottery/utils/ValidationUtils.java new file mode 100644 index 0000000..ba055d0 --- /dev/null +++ b/lottery-system/lottery-common/src/main/java/com/lottery/utils/ValidationUtils.java @@ -0,0 +1,68 @@ +package com.lottery.utils; + +/** + * @program: lottery-system + * @ClassName ValidationUtils + * @description: + * @author:jihaipeng + * @create: 2025−07-15 16:26 + * @Version 1.0 + **/ + +public class ValidationUtils { + + /** + * 校验数值是否满足： + * 1. 可以小于 0（允许负数） + * 2. 必须是整数（不能是小数） + * + * @param value 待校验的数值（可以是 String 或 Number 类型） + * @return 是否校验通过 + */ + public static boolean validateInteger(Object value) { + try { + // 如果是 String 类型，先尝试转为 Number + if (value instanceof String) { + // 去掉可能的空格 + String strValue = ((String) value).trim(); + + // 检查是否为空 + if (strValue.isEmpty()) { + return false; + } + + // 尝试解析为 Long（支持更大的整数范围） + try { + Long.parseLong(strValue); + } catch (NumberFormatException e) { + return false; // 解析失败，说明不是整数 + } + } + // 如果是 Number 类型（Integer、Long 等） + else if (value instanceof Number) { + Number num = (Number) value; + + // 检查是否是整数（避免浮点数） + if (num instanceof Double || num instanceof Float) { + double doubleValue = num.doubleValue(); + if (doubleValue != Math.floor(doubleValue)) { + return false; // 有小数部分，不合法 + } + } + + // 如果是 Integer 或 Long，直接合法 + return true; + } + // 其他类型（如非数值类型） + else { + return false; + } + + // 所有检查通过 + return true; + + } catch (Exception e) { + return false; // 任何异常都视为不合法 + } + } +} diff --git a/lottery-system/lottery-pojo/src/main/java/com/lottery/dto/FundingRecordDto.java b/lottery-system/lottery-pojo/src/main/java/com/lottery/dto/FundingRecordDto.java new file mode 100644 index 0000000..0a36b76 --- /dev/null +++ b/lottery-system/lottery-pojo/src/main/java/com/lottery/dto/FundingRecordDto.java @@ -0,0 +1,21 @@ +package com.lottery.dto; + +import lombok.Data; + +/** + * @program: lottery-system + * @ClassName FundingRecordDto + * @description: + * @author:jihaipeng + * @create: 2025−07-15 14:27 + * @Version 1.0 + **/ +@Data +public class FundingRecordDto { + + private String token; + + private Integer activityId; + + private String marketSign; +} diff --git a/lottery-system/lottery-pojo/src/main/java/com/lottery/dto/FundingUserDto.java b/lottery-system/lottery-pojo/src/main/java/com/lottery/dto/FundingUserDto.java new file mode 100644 index 0000000..2e133ba --- /dev/null +++ b/lottery-system/lottery-pojo/src/main/java/com/lottery/dto/FundingUserDto.java @@ -0,0 +1,24 @@ +package com.lottery.dto; + +import lombok.Data; + +import java.time.LocalDateTime; + +/** + * @program: lottery-system + * @ClassName FundingUserDto + * @description: + * @author:jihaipeng + * @create: 2025−07-15 10:47 + * @Version 1.0 + **/ +@Data +public class FundingUserDto { + public Integer activityId; + + private String marketSign; // 市场标识(usa/hk) + private String username; // 用户名 + private String jwcode; // 用户唯一码 + private Integer page=1; + private Integer pagesize=10; +} diff --git a/lottery-system/lottery-pojo/src/main/java/com/lottery/entity/FundingData.java b/lottery-system/lottery-pojo/src/main/java/com/lottery/entity/FundingData.java index 6573ae9..94302e7 100644 --- a/lottery-system/lottery-pojo/src/main/java/com/lottery/entity/FundingData.java +++ b/lottery-system/lottery-pojo/src/main/java/com/lottery/entity/FundingData.java @@ -24,11 +24,9 @@ import java.util.Date; public class FundingData { @TableId(type = IdType.AUTO) // 主键自增策略 private Integer id; - private Date time; // 统计时间(众筹初始时间) + private Integer time; // 统计时间(众筹初始时间) private String stock; // 市场(美股/港股) private Integer addTotal; // 虚拟参与人数 private Integer activityId; // 关联的活动ID - // 可选：关联的活动对象 - private Activity activity; } diff --git a/lottery-system/lottery-pojo/src/main/java/com/lottery/entity/FundingUser.java b/lottery-system/lottery-pojo/src/main/java/com/lottery/entity/FundingUser.java index 79f80fd..d8236ac 100644 --- a/lottery-system/lottery-pojo/src/main/java/com/lottery/entity/FundingUser.java +++ b/lottery-system/lottery-pojo/src/main/java/com/lottery/entity/FundingUser.java @@ -7,6 +7,8 @@ import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor; +import java.time.LocalDate; +import java.time.LocalDateTime; import java.util.Date; /** @@ -27,6 +29,6 @@ public class FundingUser { private String marketSign; // 市场标识(usa/hk) private String username; // 用户名 private String jwcode; // 用户唯一码 - private Date joinTime; // 参与时间 + private LocalDateTime joinTime; // 参与时间 private Integer activityId; // 关联的活动ID } diff --git a/lottery-system/lottery-pojo/src/main/java/com/lottery/vo/FundingUserVo.java b/lottery-system/lottery-pojo/src/main/java/com/lottery/vo/FundingUserVo.java new file mode 100644 index 0000000..f10b169 --- /dev/null +++ b/lottery-system/lottery-pojo/src/main/java/com/lottery/vo/FundingUserVo.java @@ -0,0 +1,25 @@ +package com.lottery.vo; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import lombok.Data; + +import java.time.LocalDateTime; + +/** + * @program: lottery-system + * @ClassName FundingUserDto + * @description: + * @author:jihaipeng + * @create: 2025−07-15 10:09 + * @Version 1.0 + **/ +@Data +public class FundingUserVo { + @TableId(type = IdType.AUTO) // 主键自增策略 + private Integer id; + private String marketSign; // 市场标识(usa/hk) + private String username; // 用户名 + private String jwcode; // 用户唯一码 + private LocalDateTime joinTime; // 参与时间 +} diff --git a/lottery-system/lottery-service/src/main/java/com/lottery/admin/controller/FundingController.java b/lottery-system/lottery-service/src/main/java/com/lottery/admin/controller/FundingController.java index b3a3105..14d59b9 100644 --- a/lottery-system/lottery-service/src/main/java/com/lottery/admin/controller/FundingController.java +++ b/lottery-system/lottery-service/src/main/java/com/lottery/admin/controller/FundingController.java @@ -3,13 +3,18 @@ package com.lottery.admin.controller; import com.lottery.dto.FundingActivityDto; import com.lottery.admin.service.IFundingService; +import com.lottery.dto.FundingRecordDto; +import com.lottery.dto.FundingUserDto; import com.lottery.result.Result; import com.lottery.vo.FundingActivityVo; +import com.lottery.vo.FundingUserVo; +import org.apache.ibatis.annotations.Param; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import java.util.List; +import java.util.Map; /** * @program: lottery-system @@ -69,4 +74,47 @@ public class FundingController { } } + //根据活动id查询助力详情 + @PostMapping("/getActivityDetail") + public Map getActivityDetail(@RequestBody FundingUserDto fundingUserDto) { + // 必填参数校验（可选，但推荐） + if (fundingUserDto.getActivityId() == null) { + throw new IllegalArgumentException("activityId 不能为空"); + } + return fundingService.getActivityDetail(fundingUserDto); + } + + // //根据活动id查询数据统计 + @PostMapping("/getActivityDate") + public Map getActivityDate(@RequestParam Integer activityId ) { + return fundingService.getActivityDate(activityId); + } + + //添加用户参与记录 + @PostMapping("/addRecord") + public Result addRecord(@RequestBody FundingRecordDto fundingRecordDto) throws Exception { + return fundingService.addRecord(fundingRecordDto); + } + + //设置活动初始活动 + @PostMapping("/setActivityTime") + public Result setActivityTime(@RequestParam Integer activityId, @RequestParam Integer time) { + return fundingService.setActivityTime(activityId, time); + } + + //添加虚拟次数 + @PostMapping("/addDateVirtual") + public Result addVirtual(@RequestParam Integer activityId, @RequestParam String stock, @RequestParam Integer addTotal) { + return fundingService.addVirtual(activityId, stock, addTotal); + } + + //返回数据详情 + @PostMapping("/getDate") + public Result > getDate(@RequestParam Integer activityId) { + return Result.success(fundingService.getDate(activityId)); + } + + + + } diff --git a/lottery-system/lottery-service/src/main/java/com/lottery/admin/mapper/IFundingMapper.java b/lottery-system/lottery-service/src/main/java/com/lottery/admin/mapper/IFundingMapper.java index 4d74464..70b6a45 100644 --- a/lottery-system/lottery-service/src/main/java/com/lottery/admin/mapper/IFundingMapper.java +++ b/lottery-system/lottery-service/src/main/java/com/lottery/admin/mapper/IFundingMapper.java @@ -2,9 +2,12 @@ package com.lottery.admin.mapper; import com.lottery.entity.Activity; import com.lottery.vo.FundingActivityVo; +import com.lottery.vo.FundingUserVo; import org.apache.ibatis.annotations.Mapper; +import java.time.LocalDateTime; import java.util.List; +import java.util.Map; /** * @program: lottery-system @@ -22,4 +25,32 @@ public interface IFundingMapper { void updateActivityStatus(Integer id, Integer status); void addActivity(Activity activity); + + + List selectByCondition(Integer activityId, String username, String jwcode, String marketSign, Integer pagesize, int offset); + + + int searchcount(Integer activityId, String username, String jwcode, String marketSign); + + Integer searchPeopleTotal(Integer activityId); + + + Map getMarket(Integer activityId); + + + Integer searchMarketPeople(Integer activityId, String marketSign); + + Integer searchMarketTotal(Integer activityId, String marketSign); + + void addRecord(Integer activityId, String username, String jwcode, String marketSign, LocalDateTime joinTime); + + void setActivityDate(Integer activityId, Integer time); + + void addDate(Integer time, String stock, Integer addTotal, Integer activityId); + + void setVirtual(Integer activityId, String stock, Integer addTotal); + + Integer searchVirtual(Integer activityId, String stock); + + Integer getTime(Integer activityId, String stock); } diff --git a/lottery-system/lottery-service/src/main/java/com/lottery/admin/service/IFundingService.java b/lottery-system/lottery-service/src/main/java/com/lottery/admin/service/IFundingService.java index bff2374..6532dc3 100644 --- a/lottery-system/lottery-service/src/main/java/com/lottery/admin/service/IFundingService.java +++ b/lottery-system/lottery-service/src/main/java/com/lottery/admin/service/IFundingService.java @@ -1,10 +1,14 @@ package com.lottery.admin.service; import com.lottery.dto.FundingActivityDto; +import com.lottery.dto.FundingRecordDto; +import com.lottery.dto.FundingUserDto; import com.lottery.result.Result; import com.lottery.vo.FundingActivityVo; +import com.lottery.vo.FundingUserVo; import java.util.List; +import java.util.Map; /** * @program: lottery-system @@ -23,4 +27,16 @@ public interface IFundingService { void updateActivityStatus(Integer id, Integer status); Result addActivity(FundingActivityDto fundingActivityDto); + + Map getActivityDetail(FundingUserDto fundingUserDto); + + Map getActivityDate(Integer activityId); + + Result addRecord(FundingRecordDto fundingRecordDto) throws Exception; + + Result setActivityTime(Integer activityId, Integer time); + + Result addVirtual(Integer activityId, String stock, Integer addTotal); + + Map getDate(Integer activityId); } diff --git a/lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/FundingServiceImpl.java b/lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/FundingServiceImpl.java index 625a51a..de1d007 100644 --- a/lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/FundingServiceImpl.java +++ b/lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/FundingServiceImpl.java @@ -1,19 +1,29 @@ package com.lottery.admin.service.Impl; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; import com.lottery.dto.FundingActivityDto; +import com.lottery.dto.FundingRecordDto; +import com.lottery.dto.FundingUserDto; import com.lottery.entity.Activity; import com.lottery.admin.mapper.IFundingMapper; import com.lottery.admin.service.IFundingService; import com.lottery.result.Result; import com.lottery.utils.ConvertBeanUtil; +import com.lottery.utils.HttpUtils; +import com.lottery.utils.ValidationUtils; import com.lottery.vo.FundingActivityVo; +import com.lottery.vo.FundingUserVo; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.net.URLEncoder; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.chrono.ChronoLocalDate; +import java.util.HashMap; import java.util.List; +import java.util.Map; import static com.lottery.result.Result.success; @@ -29,8 +39,10 @@ import static com.lottery.result.Result.success; public class FundingServiceImpl implements IFundingService { @Autowired private IFundingMapper fundingMapper; + @Autowired + ObjectMapper objectMapper = new ObjectMapper(); -// 获取所有众筹活动 + // 获取所有众筹活动 @Override public List getFundingActivity() { List list = fundingMapper.getFundingActivity(); @@ -63,7 +75,7 @@ public class FundingServiceImpl implements IFundingService { return Result.failure("结束时间不能为空"); } LocalDate now = LocalDate.now(); - System.out.println( now); + System.out.println(now); if (fundingActivityDto.getEndTime().isBefore(fundingActivityDto.getStartTime())) { return Result.failure("结束时间不能早于开始时间"); } @@ -76,7 +88,170 @@ public class FundingServiceImpl implements IFundingService { activity.setCreatedTime(creatTime); activity.setUpdatedTime(creatTime); fundingMapper.addActivity(activity); + + String one = fundingActivityDto.getMarketOne(); + String two = fundingActivityDto.getMarketTwo(); + Integer activityId = activity.getId(); + Integer time = 0; + Integer addTotal = 0; + + fundingMapper.addDate(time,one, addTotal, activityId); + fundingMapper.addDate(time,two, addTotal, activityId); return Result.success("添加活动成功"); + + + } + + @Override + public Map getActivityDetail(FundingUserDto fundingUserDto) { + // 计算分页偏移量 + int offset = (fundingUserDto.getPage() - 1) * fundingUserDto.getPagesize(); + + // 查询数据列表 + List list = fundingMapper.selectByCondition( + fundingUserDto.getActivityId(), + fundingUserDto.getUsername(), + fundingUserDto.getJwcode(), + fundingUserDto.getMarketSign(), + fundingUserDto.getPagesize(), + offset + ); + + int total = fundingMapper.searchcount( + fundingUserDto.getActivityId(), + fundingUserDto.getUsername(), + fundingUserDto.getJwcode(), + fundingUserDto.getMarketSign() + ); + // 构建返回结果 + Map result = new HashMap<>(); + result.put("list", list); + result.put("total", total); + result.put("page", fundingUserDto.getPage()); + result.put("pageSize", fundingUserDto.getPagesize()); + return result; + + } + + @Override + public Map getActivityDate(Integer activityId) { + + //参与总人数 + Integer people_total = fundingMapper.searchPeopleTotal(activityId); + + //根据活动id查询俩个市场,俩个市场是一条数据 + Map market = fundingMapper.getMarket(activityId); + //获取map + String marketOne = (String) market.get("market_one"); + + String marketTwo = (String) market.get("market_two"); + + //参与市场一的人数 + Integer markerOnePeople = fundingMapper.searchMarketPeople(activityId, marketOne); + //市场一的总的助力次数 + Integer markerOneTotal = fundingMapper.searchMarketTotal(activityId, marketOne); + + //参与市场二的人数 + Integer markerTwoPeople = fundingMapper.searchMarketPeople(activityId, marketTwo); + //市场二的总的助力次数 + Integer markerTwoTotal = fundingMapper.searchMarketTotal(activityId, marketTwo); + + //存入 + market.put("people_total", people_total); + + market.put("marketOnePeople", markerOnePeople); + market.put("marketOneTotal", markerOneTotal); + + + market.put("marketTwoPeople", markerTwoPeople); + market.put("marketTwoTotal", markerTwoTotal); + + return market; } + @Override + public Result addRecord(FundingRecordDto fundingRecordDto) throws Exception { + String token = fundingRecordDto.getToken(); + try { + // 1. 定义请求 URL + String url = "https://api.homilychart.com/hljw/api/v2/member/info"; + + // 准备请求参数 + Map params = new HashMap<>(); + params.put("token", token); // 如果接口需要 token 作为参数 + // 调用接口 + String response = HttpUtils.postUrlencoded(url, params); + JsonNode rootNode = objectMapper.readTree(response); + // 提取 username + String username = rootNode.path("data").path("username").asText(); + String jwcode = rootNode.path("data").path("jwcode").asText(); + LocalDateTime joinTime = LocalDateTime.now(); + String marketSign = fundingRecordDto.getMarketSign(); + Integer activityId = fundingRecordDto.getActivityId(); + //添加到数据库 + fundingMapper.addRecord(activityId, username, jwcode, marketSign, joinTime); + } catch (Exception e) { + System.err.println("请求失败: " + e.getMessage()); + } + + return Result.success("助力成功"); + } + + @Override + public Result setActivityTime(Integer activityId, Integer time) { + if(time == null){ + return Result.failure("初始时间不能为空"); + } + if(!ValidationUtils.validateInteger(time)){ + return Result.failure("时间格式错误"); + } + fundingMapper.setActivityDate(activityId, time); + return Result.success("设置初始时间成功"); + } + + @Override + public Result addVirtual(Integer activityId, String stock, Integer addTotal) { + if(addTotal == null){ + return Result.failure("添加次数不能为空"); + } + if(!ValidationUtils.validateInteger(addTotal)){ + return Result.failure("添加次数格式错误"); + } + fundingMapper.setVirtual(activityId, stock, addTotal); + + return Result.success("设置虚拟次数成功"); + } + + @Override + public Map getDate(Integer activityId) { + //根据活动id查询俩个市场,俩个市场是一条数据 + Map market = fundingMapper.getMarket(activityId); + //获取map + String marketOne = (String) market.get("market_one"); + //市场一的总的助力次数 + Integer markerOneTotal = fundingMapper.searchMarketTotal(activityId, marketOne); + //市场一的虚拟次数 + Integer markerOneVirtual = fundingMapper.searchVirtual(activityId, marketOne); + + String marketTwo = (String) market.get("market_two"); + //市场二的总的助力次数 + Integer markerTwoTotal = fundingMapper.searchMarketTotal(activityId, marketTwo); + //市场二的虚拟次数 + Integer markerTwoVirtual = fundingMapper.searchVirtual(activityId, marketTwo); + + Integer showOne = markerOneTotal + markerOneVirtual; + Integer showTwo = markerTwoTotal + markerTwoVirtual; + Integer time = fundingMapper.getTime(activityId,marketOne); + Map result = new HashMap<>(); + + result.put("time", time) ; + result.put("showOne", showOne); + result.put("showTwo", showTwo); + result.put("markerOneTotal", markerTwoVirtual); + result.put("markerTwoTotal", markerTwoVirtual); + result.put("marketOneVirtual", markerOneVirtual); + result.put("marketTwoVirtual", markerTwoVirtual); + return result; + } } + diff --git a/lottery-system/lottery-service/src/main/resources/mapper/admin/fundingMapper.xml b/lottery-system/lottery-service/src/main/resources/mapper/admin/fundingMapper.xml index 1764bdd..46e74a0 100644 --- a/lottery-system/lottery-service/src/main/resources/mapper/admin/fundingMapper.xml +++ b/lottery-system/lottery-service/src/main/resources/mapper/admin/fundingMapper.xml @@ -1,7 +1,7 @@ - + INSERT INTO activity (activity_name, market_one, market_two, @@ -19,12 +19,45 @@ #{createdTime}, #{updatedTime}) + + INSERT INTO z_user (activity_id, + username, + jwcode, + market_sign, + join_time) + VALUES (#{activityId}, + #{username}, + #{jwcode}, + #{marketSign}, + #{joinTime}) + + + INSERT INTO data (time, + stock, + add_total, + activity_id) + VALUES (#{time}, + #{stock}, + #{addTotal}, + #{activityId}) + UPDATE activity SET status = #{status} WHERE id = #{id} + + UPDATE data + SET time = #{time} + where activity_id = #{activityId} + + + UPDATE data + SET add_total = add_total + #{addTotal} + where activity_id = #{activityId} + and stock = #{stock} + + + + + + + + + + \ No newline at end of file