众筹

lottery-system/lottery-pojo/src/main/java/com/lottery/dto/FundingRecordDto.java

@@ -13,8 +13,6 @@ import lombok.Data;
 @Data
 public class FundingRecordDto {
 
-    private String token;
-
     private Integer activityId;
 
     private String marketSign;

lottery-system/lottery-pojo/src/main/java/com/lottery/entity/Market.java

@@ -0,0 +1,28 @@
+package com.lottery.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @program: lottery-system
+ * @ClassName market
+ * @description:
+ * @author:jihaipeng
+ * @create: 2025−07-16 12:01
+ * @Version 1.0
+ **/
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName("market")
+public class Market {
+    private Integer id;
+    private String market;
+    private String text;
+    private String icon;
+    private Integer des;
+    private Integer flag;
+}

lottery-system/lottery-pojo/src/main/java/com/lottery/vo/ApiFundingTimeVo.java

@@ -0,0 +1,21 @@
+package com.lottery.vo;
+
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * @program: lottery-system
+ * @ClassName ApiFundingTimeVo
+ * @description:
+ * @author:jihaipeng
+ * @create: 2025−07-16 13:49
+ * @Version 1.0
+ **/
+@Data
+public class ApiFundingTimeVo {
+    private String marketOne;
+    private String marketTwo;
+    private LocalDate startTime;
+    private LocalDate endTime;
+}

lottery-system/lottery-pojo/src/main/java/com/lottery/vo/ApiFundingVO.java

@@ -0,0 +1,26 @@
+package com.lottery.vo;
+
+import lombok.Data;
+
+import java.time.LocalDate;
+
+/**
+ * @program: lottery-system
+ * @ClassName ApiFundingVO
+ * @description:
+ * @author:jihaipeng
+ * @create: 2025−07-16 11:30
+ * @Version 1.0
+ **/
+@Data
+public class ApiFundingVO {
+    private String marketOne;
+    private String marketTwo;
+    private LocalDate startTime;
+    private LocalDate endTime;
+    private Integer Totalcount;
+    private Integer marketOneCount;
+    private Integer marketTwoCount;
+    private String marketAddOne;
+    private String marketAddTwo;
+}

lottery-system/lottery-service/src/main/java/com/lottery/admin/controller/FundingController.java

@@ -7,9 +7,10 @@ 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.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.info.ProjectInfoAutoConfiguration;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
@@ -25,18 +26,23 @@ import java.util.Map;
  * @Version 1.0
  **/
 @RestController
-@RequestMapping("/funding")
+@RequestMapping("/admin/funding")
 public class FundingController {
 
     @Autowired
     private IFundingService fundingService;
 
+    private final static Logger LOGGER = LoggerFactory.getLogger(FundingController.class);
+    @Autowired
+    private ProjectInfoAutoConfiguration projectInfoAutoConfiguration;
+
     /**
      * 获取所有众筹活动
      * @return
      */
     @GetMapping("/getActivity")
     public Result<List<FundingActivityVo>> getFundingActivity(){
+        LOGGER.info("获取所有众筹活动");
       List<FundingActivityVo> list = fundingService.getFundingActivity();
       return Result.success(list);
     }
@@ -44,7 +50,8 @@ public class FundingController {
 
     //修改众筹的活动状态
     @PostMapping("/updateActivityStatus")
-    public Result<String> updateActivityStatus(@RequestParam @Validated Integer id, @RequestParam @Validated  Integer status) {
+    public Result updateActivityStatus(@RequestParam @Validated Integer id, @RequestParam @Validated  Integer status) {
+        LOGGER.info("修改的众筹活动id为{}，修改的众筹活动状态为{}", id, status);
         // 参数校验
         if (id == null || status == null) {
             return Result.failure("参数不能为空");
@@ -56,8 +63,7 @@ public class FundingController {
             return Result.failure("活动状态值非法");
         }
         try {
-            fundingService.updateActivityStatus(id, status);
-            return Result.success("修改活动状态成功");
+            return fundingService.updateActivityStatus(id, status);
         } catch (Exception e) {
             return Result.failure("修改活动状态失败");
         }
@@ -67,8 +73,10 @@ public class FundingController {
     //添加活动
     @PostMapping("/addActivity")
     public Result<String> addActivity(@Validated @RequestBody FundingActivityDto fundingActivityDto) {
+        LOGGER.info("添加活动，参数为{}", fundingActivityDto);
         try {
             return fundingService.addActivity(fundingActivityDto);
+
         } catch (Exception e) {
             return Result.failure("添加活动失败");
         }
@@ -76,45 +84,54 @@ public class FundingController {
 
     //根据活动id查询助力详情
     @PostMapping("/getActivityDetail")
-    public Map<String, Object> getActivityDetail(@RequestBody FundingUserDto fundingUserDto) {
+    public Result<Map<String, Object>> getActivityDetail(@RequestBody FundingUserDto fundingUserDto) {
+        LOGGER.info("接口getActivityDetail查询助力详情，查询条件{}",fundingUserDto);
         // 必填参数校验（可选，但推荐）
         if (fundingUserDto.getActivityId() == null) {
             throw new IllegalArgumentException("activityId 不能为空");
         }
-        return fundingService.getActivityDetail(fundingUserDto);
+        return Result.success(fundingService.getActivityDetail(fundingUserDto));
     }
 
     // //根据活动id查询数据统计
     @PostMapping("/getActivityDate")
-    public Map<String, Object> getActivityDate(@RequestParam Integer activityId ) {
-        return fundingService.getActivityDate(activityId);
+    public Result<Map<String, Object>> getActivityDate(@RequestParam Integer activityId ) {
+        LOGGER.info("接口getActivityDate查询后台数据统计,活动id为{}",activityId);
+        return Result.success(fundingService.getActivityDate(activityId));
     }
 
-    //添加用户参与记录
-    @PostMapping("/addRecord")
-    public Result<String> addRecord(@RequestBody FundingRecordDto fundingRecordDto) throws Exception {
-        return fundingService.addRecord(fundingRecordDto);
-    }
+//    //添加用户参与记录
+//    @PostMapping("/addRecord")
+//    public Result<String> addRecord(@RequestBody FundingRecordDto fundingRecordDto) throws Exception {
+//        return fundingService.addRecord(fundingRecordDto);
+//    }
 
     //设置活动初始活动
     @PostMapping("/setActivityTime")
     public Result<String> setActivityTime(@RequestParam Integer activityId, @RequestParam Integer time) {
+        LOGGER.info("设置id={}的活动初始时间为{}",activityId,time);
         return fundingService.setActivityTime(activityId, time);
     }
 
     //添加虚拟次数
     @PostMapping("/addDateVirtual")
     public Result<String> addVirtual(@RequestParam Integer activityId, @RequestParam String stock, @RequestParam Integer addTotal) {
+       LOGGER.info("添加虚拟次数,id={},stock={},addTotal={}",activityId,stock,addTotal);
         return fundingService.addVirtual(activityId, stock, addTotal);
     }
 
     //返回数据详情
     @PostMapping("/getDate")
     public Result<Map<String, Object> > getDate(@RequestParam Integer activityId) {
+        LOGGER.info("返回id={}的活动的设置数据详情",activityId);
         return Result.success(fundingService.getDate(activityId));
     }
 
-
-
+    //获取市场股票列表
+    @GetMapping("/getMarketList")
+    public Result<List> getMarket() {
+        LOGGER.info("获取市场股票列表");
+        return Result.success(fundingService.getMarketList());
+    }
 
 }

lottery-system/lottery-service/src/main/java/com/lottery/admin/mapper/IFundingMapper.java

@@ -42,7 +42,7 @@ public interface IFundingMapper {
 
     Integer searchMarketTotal(Integer activityId, String marketSign);
 
-    void addRecord(Integer activityId, String username, String jwcode, String marketSign, LocalDateTime joinTime);
+//    void addRecord(Integer activityId, String username, String jwcode, String marketSign, LocalDateTime joinTime);
 
     void setActivityDate(Integer activityId, Integer time);
 
@@ -53,4 +53,8 @@ public interface IFundingMapper {
     Integer searchVirtual(Integer activityId, String stock);
 
     Integer getTime(Integer activityId, String stock);
+
+    List<String>  getMarketList();
+
+    Integer selectStatus();
 }

lottery-system/lottery-service/src/main/java/com/lottery/admin/service/IFundingService.java

@@ -24,7 +24,7 @@ public interface IFundingService {
     List<FundingActivityVo> getFundingActivity();
 
 
-    void updateActivityStatus(Integer id, Integer status);
+    Result<String> updateActivityStatus(Integer id, Integer status);
 
     Result<String> addActivity(FundingActivityDto fundingActivityDto);
 
@@ -32,11 +32,13 @@ public interface IFundingService {
 
     Map<String, Object> getActivityDate(Integer activityId);
 
-    Result<String> addRecord(FundingRecordDto fundingRecordDto) throws Exception;
+//    Result<String> addRecord(FundingRecordDto fundingRecordDto) throws Exception;
 
     Result<String> setActivityTime(Integer activityId, Integer time);
 
     Result<String> addVirtual(Integer activityId, String stock, Integer addTotal);
 
     Map<String, Object> getDate(Integer activityId);
+
+    List getMarketList();
 }

lottery-system/lottery-service/src/main/java/com/lottery/admin/service/Impl/FundingServiceImpl.java

@@ -51,9 +51,16 @@ public class FundingServiceImpl implements IFundingService {
 
     //修改众筹的活动状态
     @Override
-    public void updateActivityStatus(Integer id, Integer status) {
+    public Result<String> updateActivityStatus(Integer id, Integer status) {
+        if(status == 1){
+            //查询状态
+            Integer statuss = fundingMapper.selectStatus();
+            if(statuss >= 1){
+                return Result.failure("当前有活动正在启用,修改状态失败");
+            }
+        }
         fundingMapper.updateActivityStatus(id, status);
-
+        return Result.success("修改状态成功");
     }
 
     //添加众筹活动
@@ -82,6 +89,15 @@ public class FundingServiceImpl implements IFundingService {
         if (fundingActivityDto.getEndTime().isBefore(ChronoLocalDate.from(now))) {
             return Result.failure("结束时间不能早于当前时间");
         }
+        //查询状态
+        Integer status = fundingMapper.selectStatus();
+        Integer statuss = fundingActivityDto.getStatus();
+        if(statuss == 1){
+            if(status >= 1){
+                return Result.failure("当前有活动正在进行,新添加活动状态应为禁用");
+            }
+        }
+
         Activity activity = ConvertBeanUtil.convert(fundingActivityDto, Activity.class);
         //获取当前时间
         LocalDateTime creatTime = LocalDateTime.now();
@@ -99,7 +115,6 @@ public class FundingServiceImpl implements IFundingService {
         fundingMapper.addDate(time,two, addTotal, activityId);
         return Result.success("添加活动成功");
 
-
     }
 
     @Override
@@ -138,14 +153,11 @@ public class FundingServiceImpl implements IFundingService {
 
         //参与总人数
         Integer people_total = fundingMapper.searchPeopleTotal(activityId);
-
         //根据活动id查询俩个市场,俩个市场是一条数据
         Map<String, Object> 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);
         //市场一的总的助力次数
@@ -169,33 +181,32 @@ public class FundingServiceImpl implements IFundingService {
         return market;
     }
 
-    @Override
-    public Result<String> addRecord(FundingRecordDto fundingRecordDto) throws Exception {
-        String token = fundingRecordDto.getToken();
-        try {
-            // 1. 定义请求 URL
-            String url = "https://api.homilychart.com/hljw/api/v2/member/info";
-
-            // 准备请求参数
-            Map<String, String> 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<String> addRecord(String token,FundingRecordDto fundingRecordDto) throws Exception {
+//        try {
+//            // 1. 定义请求 URL
+//            String url = "https://api.homilychart.com/hljw/api/v2/member/info";
+//
+//            // 准备请求参数
+//            Map<String, String> 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<String> setActivityTime(Integer activityId, Integer time) {
@@ -241,6 +252,7 @@ public class FundingServiceImpl implements IFundingService {
 
         Integer showOne = markerOneTotal + markerOneVirtual;
         Integer showTwo = markerTwoTotal + markerTwoVirtual;
+
         Integer time = fundingMapper.getTime(activityId,marketOne);
         Map<String, Object> result = new HashMap<>();
 
@@ -253,5 +265,10 @@ public class FundingServiceImpl implements IFundingService {
         result.put("marketTwoVirtual", markerTwoVirtual);
         return result;
     }
+
+    @Override
+    public List getMarketList() {
+        return fundingMapper.getMarketList();
+    }
 }
 

lottery-system/lottery-service/src/main/java/com/lottery/api/controller/ApiFundingController.java

@@ -0,0 +1,50 @@
+package com.lottery.api.controller;
+
+import com.lottery.admin.controller.FundingController;
+import com.lottery.api.service.ApiIFundingService;
+import com.lottery.dto.FundingRecordDto;
+import com.lottery.result.Result;
+import com.lottery.vo.ApiFundingVO;
+import lombok.Data;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @program: lottery-system
+ * @ClassName FundingController
+ * @description:
+ * @author:jihaipeng
+ * @create: 2025−07-16 11:00
+ * @Version 1.0
+ **/
+@RestController
+@RequestMapping("/api/funding")
+public class ApiFundingController {
+
+    @Autowired
+    private ApiIFundingService fundingService;
+    private final static Logger LOGGER = LoggerFactory.getLogger(ApiFundingController.class);
+
+    //前台获取活动列表
+    @GetMapping("/getActivity")
+    public Result<ApiFundingVO> getFundingActivity(@RequestParam Integer activityId){
+        LOGGER.info("前台获取众筹活动所有数据");
+        return Result.success(fundingService.getActivityDetail(activityId));
+    }
+
+    //前台获取活动详情
+    @PostMapping("/getActivity1")
+    public Result<ApiFundingVO> getFundingActivity1(@RequestHeader String token){
+        LOGGER.info("前台获取众筹活动所有数据");
+        return fundingService.getActivityDetailOne(token);
+    }
+
+    //添加用户参与记录
+    @PostMapping("/addRecord")
+    public Result<String> addRecord(@RequestHeader String token,@RequestBody FundingRecordDto fundingRecordDto) throws Exception {
+        LOGGER.info("添加用户参与记录，参数为{}", fundingRecordDto);
+        return fundingService.addRecord(token,fundingRecordDto);
+    }
+}

lottery-system/lottery-service/src/main/java/com/lottery/api/mapper/ApiIFundingMapper.java

@@ -0,0 +1,35 @@
+package com.lottery.api.mapper;
+
+import com.lottery.vo.ApiFundingTimeVo;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.Map;
+
+/**
+ * @program: lottery-system
+ * @ClassName IFundingMapper
+ * @description:
+ * @author:jihaipeng
+ * @create: 2025−07-16 11:06
+ * @Version 1.0
+ **/
+@Mapper
+public interface ApiIFundingMapper {
+
+
+    Integer getTime(Integer activityId, String markerSign);
+
+    Integer searchVirtual(Integer activityId, String marketSign);
+
+    Integer searchMarketTotal(Integer activityId, String marketSign);
+
+    ApiFundingTimeVo getMarket(Integer activityId);
+
+    Integer selectStatus();
+
+    void addRecord(Integer activityId, String username, String jwcode, String marketSign, LocalDateTime joinTime);
+
+    LocalDate selectCount(String jwcode, String marketSign,Integer activityId);
+}

lottery-system/lottery-service/src/main/java/com/lottery/api/service/ApiIFundingService.java

@@ -0,0 +1,24 @@
+package com.lottery.api.service;
+
+import com.lottery.dto.FundingRecordDto;
+import com.lottery.result.Result;
+import com.lottery.vo.ApiFundingVO;
+
+import javax.print.DocFlavor;
+
+/**
+ * @program: lottery-system
+ * @ClassName IFundingService
+ * @description:
+ * @author:jihaipeng
+ * @create: 2025−07-16 11:06
+ * @Version 1.0
+ **/
+
+public interface ApiIFundingService {
+    ApiFundingVO getActivityDetail(Integer activityId);
+
+    Result getActivityDetailOne(String  token);
+
+    Result<String> addRecord(String  token,FundingRecordDto fundingRecordDto);
+}

lottery-system/lottery-service/src/main/java/com/lottery/api/service/Impl/ApiFundingServiceImpl.java

@@ -0,0 +1,214 @@
+package com.lottery.api.service.Impl;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.lottery.api.mapper.ApiIFundingMapper;
+import com.lottery.api.service.ApiIFundingService;
+import com.lottery.dto.FundingRecordDto;
+import com.lottery.result.Result;
+import com.lottery.utils.HttpUtils;
+import com.lottery.vo.ApiFundingTimeVo;
+import com.lottery.vo.ApiFundingVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @program: lottery-system
+ * @ClassName FundingServiceIMpl
+ * @description:
+ * @author:jihaipeng
+ * @create: 2025−07-16 11:07
+ * @Version 1.0
+ **/
+@Service
+public class ApiFundingServiceImpl implements ApiIFundingService {
+
+    @Autowired
+    private ApiIFundingMapper fundingMapper;
+
+    @Autowired
+    ObjectMapper objectMapper = new ObjectMapper();
+
+    //返回前台所有数据
+    @Override
+    public ApiFundingVO getActivityDetail(Integer activityId) {
+
+        //根据活动id查询活动时间，市场一，市场二，设置的初始时间，俩个市场总助力次数
+
+        //根据活动id查询俩个市场,俩个市场是一条数据
+        ApiFundingTimeVo data= fundingMapper.getMarket(activityId);
+
+
+        String marketOne = (String) data.getMarketOne();
+        String marketTwo = (String) data.getMarketTwo();
+        LocalDate startTime = (LocalDate) data.getStartTime();
+        LocalDate endTime = (LocalDate) data.getEndTime();
+
+
+        //市场一的总的助力次数
+        Integer markerOneTotal = fundingMapper.searchMarketTotal(activityId, marketOne);
+        if (markerOneTotal == null) {
+            markerOneTotal = 0; // 默认值
+        }
+        //市场一的虚拟次数
+        Integer markerOneVirtual = fundingMapper.searchVirtual(activityId, marketOne);
+        if (markerOneVirtual == null) {
+            markerOneVirtual = 0; // 默认值
+        }
+
+        //市场二的总的助力次数
+        Integer markerTwoTotal = fundingMapper.searchMarketTotal(activityId, marketTwo);
+        if (markerTwoTotal == null) {
+            markerTwoTotal = 0; // 默认值
+        }
+        //市场二的虚拟次数
+        Integer markerTwoVirtual = fundingMapper.searchVirtual(activityId, marketTwo);
+        if (markerTwoVirtual == null) {
+            markerTwoVirtual = 0; // 默认值
+        }
+        //获取的设置时间
+        Integer time = fundingMapper.getTime(activityId,marketOne);
+
+        Integer oneShow = markerOneTotal + markerOneVirtual;
+        Integer twoShow = markerTwoTotal + markerTwoVirtual;
+
+        ApiFundingVO apiFundingVO = new ApiFundingVO();
+
+        apiFundingVO.setMarketOne(marketOne);
+        apiFundingVO.setMarketTwo(marketTwo);
+        apiFundingVO.setMarketOneCount(oneShow);
+        apiFundingVO.setMarketTwoCount(twoShow);
+        apiFundingVO.setTotalcount(time);
+        apiFundingVO.setStartTime(startTime);
+        apiFundingVO.setEndTime(endTime);
+
+        return apiFundingVO;
+    }
+
+    @Override
+    public Result  getActivityDetailOne(String  token) {
+        //根据活动id查询活动时间，市场一，市场二，设置的初始时间，俩个市场总助力次数
+        Integer activityId = fundingMapper.selectStatus();
+        if(activityId==null){
+            return Result.failure("没有活动开启");
+        }
+
+        //根据活动id查询俩个市场,俩个市场是一条数据
+        ApiFundingTimeVo data= fundingMapper.getMarket(activityId);
+
+
+        String marketOne = (String) data.getMarketOne();
+        String marketTwo = (String) data.getMarketTwo();
+        LocalDate startTime = (LocalDate) data.getStartTime();
+        LocalDate endTime = (LocalDate) data.getEndTime();
+
+        String username = "";
+        String jwcode = "";
+
+        try {
+            // 1. 定义请求 URL
+            String url = "https://api.homilychart.com/hljw/api/v2/member/info";
+
+            // 准备请求参数
+            Map<String, String> params = new HashMap<>();
+            params.put("token", token); // 如果接口需要 token 作为参数
+            // 调用接口
+            String response = HttpUtils.postUrlencoded(url, params);
+            JsonNode rootNode = objectMapper.readTree(response);
+            // 提取 username
+             username = rootNode.path("data").path("username").asText();
+            jwcode = rootNode.path("data").path("jwcode").asText();
+            LocalDateTime joinTime = LocalDateTime.now();
+
+        } catch (Exception e) {
+            System.err.println("请求失败: " + e.getMessage());
+        }
+        LocalDate now = LocalDate.now();
+        String markeroneadd = "点击助力";
+        String marketTwoadd = "点击助力";
+        //通过精网号+市场名查询该用户是否助力过
+        LocalDate count1 = fundingMapper.selectCount(jwcode,marketOne,activityId);
+
+        if(count1!=null && count1.equals(now))
+            markeroneadd = "已助力";
+
+        LocalDate count2 = fundingMapper.selectCount(jwcode,marketTwo,activityId);
+        if(count2!=null && count2.equals(now))
+            marketTwoadd = "已助力";
+
+        //市场一的总的助力次数
+        Integer markerOneTotal = fundingMapper.searchMarketTotal(activityId, marketOne);
+        if (markerOneTotal == null) {
+            markerOneTotal = 0; // 默认值
+        }
+        //市场一的虚拟次数
+        Integer markerOneVirtual = fundingMapper.searchVirtual(activityId, marketOne);
+        if (markerOneVirtual == null) {
+            markerOneVirtual = 0; // 默认值
+        }
+
+        //市场二的总的助力次数
+        Integer markerTwoTotal = fundingMapper.searchMarketTotal(activityId, marketTwo);
+        if (markerTwoTotal == null) {
+            markerTwoTotal = 0; // 默认值
+        }
+        //市场二的虚拟次数
+        Integer markerTwoVirtual = fundingMapper.searchVirtual(activityId, marketTwo);
+        if (markerTwoVirtual == null) {
+            markerTwoVirtual = 0; // 默认值
+        }
+        //获取的设置时间
+        Integer time = fundingMapper.getTime(activityId,marketOne);
+
+        Integer oneShow = markerOneTotal + markerOneVirtual;
+        Integer twoShow = markerTwoTotal + markerTwoVirtual;
+
+        ApiFundingVO apiFundingVO = new ApiFundingVO();
+
+        apiFundingVO.setMarketOne(marketOne);
+        apiFundingVO.setMarketTwo(marketTwo);
+        apiFundingVO.setMarketOneCount(oneShow);
+        apiFundingVO.setMarketTwoCount(twoShow);
+        apiFundingVO.setTotalcount(time);
+        apiFundingVO.setStartTime(startTime);
+        apiFundingVO.setEndTime(endTime);
+        apiFundingVO.setMarketAddOne(markeroneadd);
+        apiFundingVO.setMarketTwo(marketTwoadd);
+        return Result.success(apiFundingVO);
+    }
+
+
+    @Override
+    public Result<String> addRecord(String token,FundingRecordDto fundingRecordDto) {
+
+        try {
+            // 1. 定义请求 URL
+            String url = "https://api.homilychart.com/hljw/api/v2/member/info";
+
+            // 准备请求参数
+            Map<String, String> 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("助力成功");
+    }
+
+}

lottery-system/lottery-service/src/main/resources/application.yml

@@ -1,6 +1,6 @@
 server:
   port: 12699  # 服务端口
-
+  forward-headers-strategy: native  # 全局生效
 spring:
   # ========== 数据源配置 (MySQL) ==========
   datasource:
@@ -36,6 +36,13 @@ mybatis:
     map-underscore-to-camel-case: true  # 开启驼峰命名转换
     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl  # 打印SQL日志
 
+logging:
+  config: classpath:logback-spring.xml
+  level:
+    root: INFO
+    org.springframework: WARN
+    com.link: INFO
+
 # ========== 自定义配置（示例） ==========
 lottery:
   jwt:

lottery-system/lottery-service/src/main/resources/logback-spring.xml

@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+
+    <!-- 定义日志输出模式 -->
+    <property name="LOG_PATTERN" value="%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n"/>
+
+    <!-- 控制台输出 -->
+    <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>${LOG_PATTERN}</pattern>
+        </encoder>
+    </appender>
+
+    <!-- 通用日志文件 -->
+    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>logs/spring-boot-application.log</file>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!-- 设置日志文件的命名模式 -->
+            <fileNamePattern>logs/spring-boot-application.%d{yyyy-MM-dd}.log</fileNamePattern>
+            <maxHistory>14</maxHistory> <!-- 保留14天的日志文件 -->
+        </rollingPolicy>
+        <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
+            <maxFileSize>10MB</maxFileSize>
+        </triggeringPolicy>
+        <encoder>
+            <pattern>${LOG_PATTERN}</pattern>
+        </encoder>
+    </appender>
+
+    <!-- 根日志配置 -->
+    <root level="INFO">
+        <appender-ref ref="CONSOLE" />
+        <appender-ref ref="FILE" />
+    </root>
+
+</configuration>

lottery-system/lottery-service/src/main/resources/mapper/admin/AdminGradeMapper.xml

@@ -1,8 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.lottery.admin.mapper.AdminGradeMapper">
-
-    <select id="selectByName" resultType="com.lottery.entity.Grade">
-        select * from grade where grade_name = #{gradeName}
-    </select>
-</mapper>

lottery-system/lottery-service/src/main/resources/mapper/admin/fundingMapper.xml

@@ -19,18 +19,18 @@
                #{createdTime},
                 #{updatedTime})
     </insert>
-    <insert id="addRecord">
-        INSERT INTO z_user (activity_id,
-                            username,
-                            jwcode,
-                            market_sign,
-                            join_time)
-        VALUES (#{activityId},
-                #{username},
-                #{jwcode},
-                #{marketSign},
-                #{joinTime})
-    </insert>
+<!--    <insert id="addRecord">-->
+<!--        INSERT INTO z_user (activity_id,-->
+<!--                            username,-->
+<!--                            jwcode,-->
+<!--                            market_sign,-->
+<!--                            join_time)-->
+<!--        VALUES (#{activityId},-->
+<!--                #{username},-->
+<!--                #{jwcode},-->
+<!--                #{marketSign},-->
+<!--                #{joinTime})-->
+<!--    </insert>-->
     <insert id="addDate">
         INSERT INTO data (time,
                          stock,
@@ -130,12 +130,7 @@
         WHERE market_sign = #{marketSign}
           AND activity_id = #{activityId}
     </select>
-    <select id="searchMarketTotal" resultType="java.lang.Integer">
-        SELECT COUNT(*)
-        FROM z_user
-        WHERE market_sign = #{marketSign}
-          AND activity_id = #{activityId}
-    </select>
+
     <select id="searchVirtual" resultType="java.lang.Integer">
         SELECT
         add_total
@@ -145,7 +140,6 @@
         activity_id = #{activityId}
           and stock = #{stock}
     </select>
-
     <select id="getTime" resultType="java.lang.Integer">
         SELECT
             time
@@ -155,5 +149,28 @@
             activity_id = #{activityId}
           and stock = #{stock}
     </select>
+    <select id="getMarketList" resultType="string">
+        SELECT
+        text
+        FROM
+        market
+    </select>
+    <select id="selectStatus" resultType="java.lang.Integer">
+        SELECT
+        count(*)
+        FROM
+        activity
+        WHERE
+        status = 1
+    </select>
+    <select id="searchMarketTotal" resultType="java.lang.Integer">
+        SELECT
+        COUNT(*)
+        FROM z_user
+        WHERE
+        market_sign = #{marketSign}
+          AND activity_id = #{activityId}
+    </select>
+
 
 </mapper>

lottery-system/lottery-service/src/main/resources/mapper/api/ApiIFundingService.xml

@@ -0,0 +1,72 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.lottery.api.mapper.ApiIFundingMapper">
+    <insert id="addRecord">
+        INSERT INTO z_user (activity_id,
+                            username,
+                            jwcode,
+                            market_sign,
+                            join_time)
+        VALUES (#{activityId},
+                #{username},
+                #{jwcode},
+                #{marketSign},
+                #{joinTime})
+    </insert>
+
+    <select id="getTime" resultType="java.lang.Integer">
+        SELECT
+            time
+        FROM
+            data
+        WHERE
+            activity_id = #{activityId}
+          and stock = #{markerSign}
+    </select>
+
+    <select id="searchMarketTotal" resultType="java.lang.Integer">
+        SELECT COUNT(*)
+        FROM z_user
+        WHERE market_sign = #{marketSign}
+          AND activity_id = #{activityId}
+    </select>
+    <select id="searchVirtual" resultType="java.lang.Integer">
+        SELECT
+            add_total
+        FROM
+            data
+        WHERE
+            activity_id = #{activityId}
+          and stock = #{marketSign}
+    </select>
+    <select id="getMarket" resultType="com.lottery.vo.ApiFundingTimeVo" parameterType="java.lang.Integer">
+        SELECT
+            market_one,
+            market_two,
+            start_time,
+            end_time
+        FROM
+            activity
+        WHERE
+            id = #{activityId}
+    </select>
+    <select id="selectStatus" resultType="java.lang.Integer">
+        SELECT
+            id
+        FROM
+            activity
+        WHERE
+            status = 1
+    </select>
+    <select id="selectCount" resultType="java.time.LocalDate">
+        SELECT join_time
+        FROM z_user
+        WHERE activity_id = #{activityId}
+          and market_sign = #{marketSign}
+          and jwcode = #{jwcode}
+        order by join_time desc
+            LIMIT 1
+    </select>
+
+
+</mapper>