后端整合模块

src/main/java/com/example/demo/controller/ProductController.java

@@ -20,4 +20,3 @@ public class ProductController {
        return Result.success(productService.findAll(product));
     }
 }
-

src/main/java/com/example/demo/controller/RechargeController.java

@@ -36,7 +36,7 @@ public class RechargeController {
             // 发送消息到 Kafka 队列
             kafkaProducer.sendMessage("recharge-topic", rechargeJson);
 
-            return Result.success("Request added to Kafka queue");
+            return rechargeService.addRecharges(recharge);
         } catch (Exception e) {
             log.error(Arrays.toString(e.getStackTrace()));
             return Result.error(e.getMessage());

src/main/java/com/example/demo/controller/UserController.java

@@ -33,5 +33,8 @@ public class UserController {
     public Result search() throws Exception {
         return Result.success(userSevice.area());
     }
-
+    @PostMapping("/jwcode")
+    public Result jwcode() throws Exception {
+        return Result.success(userSevice.jwcode());
+    }
 }

src/main/java/com/example/demo/domain/entity/DetailY.java

@@ -44,7 +44,7 @@ public class DetailY implements Serializable {
 
     private String adminArea;
     private String adminName;
-    private String userName;
+    private String username;
     private String auditStatus;
     private String auditReson;
     private String orderCode;

src/main/java/com/example/demo/mapper/DetailYMapper.java

@@ -12,13 +12,17 @@ import java.util.List;
 @Mapper
 public interface DetailYMapper {
     @Insert({
-            "insert into detail_y",
-            "(jwcode,order_code,activity_id,recharge_way,product_id,consume_platform,consume_type,refund_type,refund_goods," +
-                    "contact_id,remark,recharge_coin,free_coin,task_coin,admin_id,update_type,detail_flag,create_time,first_recharge)",
-            "values ",
-            "(#{jwcode},#{orderCode},#{activityId},#{rechargeWay},#{productId},#{consumePlatform},#{consumeType},#{refundType}" +
-                    ",#{refundGoods},#{contactId},#{remark},#{rechargeCoin}" +
-                    ",#{freeCoin},#{taskCoin},#{adminId},#{updateType},1,now(),#{firstRecharge})"
+//            "insert into detail_y",
+//            "(jwcode,order_code,activity_id,recharge_way,product_id,consume_platform,consume_type,refund_type,refund_goods,name,username,area" +
+//                    "contact_id,remark,recharge_coin,free_coin,task_coin,admin_id,update_type,detail_flag,create_time,first_recharge)",
+//            "values ",
+//            "(#{jwcode},#{orderCode},#{activityId},#{rechargeWay},#{productId},#{consumePlatform},#{consumeType},#{refundType}" +
+//                    ",#{refundGoods},#{name},#{username},#{area},#{contactId},#{remark},#{rechargeCoin}" +
+//                    ",#{freeCoin},#{taskCoin},#{adminId},#{updateType},1,now(),#{firstRecharge})"
+            "insert into detail_y \n" +
+                    "(jwcode, order_code, activity_id, recharge_way, product_id, consume_platform, consume_type, refund_type, refund_goods, name, username, area, contact_id, remark, recharge_coin, free_coin, task_coin, admin_id, update_type, detail_flag, create_time, first_recharge)\n" +
+                    "values \n" +
+                    "(#{jwcode}, #{orderCode}, #{activityId}, #{rechargeWay}, #{productId}, #{consumePlatform}, #{consumeType}, #{refundType}, #{refundGoods}, #{name}, #{username}, #{area}, #{contactId}, #{remark}, #{rechargeCoin}, #{freeCoin}, #{taskCoin}, #{adminId}, #{updateType}, 1, now(), #{firstRecharge})"
     })
     @Options(useGeneratedKeys = true,keyColumn = "detaily_id",keyProperty = "detailyId")
     int add(DetailY detaily);
@@ -54,7 +58,8 @@ public interface DetailYMapper {
 
     @Select({
             "<script>",
-            "select * from detail_y",
+            "select username,name,detail_y.jwcode,area,detail_y.update_type,detail_y.create_time,detail_y.consume_platform,detail_y.free_coin,detail_y.recharge_coin,detail_y.task_coin from detail_y",
+//            "select * from detail_y",
 //            "select detail_y.*,admin.name,admin.area,user.name as uname,audit.status from detail",
 //            "left join `admin` on `detail_y`.admin_id = `admin`.admin_id",
 //            "left join `user` on `detail_y`.jwcode = `user`.jwcode",

src/main/java/com/example/demo/mapper/UserMapper.java

@@ -11,6 +11,10 @@ import java.util.List;
 @Mapper
 public interface UserMapper {
     @Select({
+            "select jwcode from user"
+    })
+    List<String> selectJwcode();
+    @Select({
             "<script>",
             "select name from user",
             "<where>",

src/main/java/com/example/demo/serviceImpl/AuditServiceImpl.java

@@ -109,6 +109,8 @@ public class AuditServiceImpl implements AuditService {
             Integer status1=audit.getStatus();
             String reson = audit.getReson();
             String name = audit.getName();
+            System.out.println(name+"11111111111111111111111111111111111111111111111");
+            System.out.println(username);
             Integer flag = audit.getFlag();
             Date createTime = audit.getCreateTime();
 
@@ -123,7 +125,7 @@ public class AuditServiceImpl implements AuditService {
             detailY.setActivityName(activityName);
             detailY.setArea(area);
             detailY.setName(name);
-            detailY.setUserName(username);
+            detailY.setUsername(username);
             detailY.setOrderCode(uuid);
             detailY.setStatus(status1);
             detailY.setReson(reson);

src/main/java/com/example/demo/serviceImpl/RechargeServiceImpl.java

@@ -5,6 +5,7 @@ import com.example.demo.domain.entity.Detail;
 import com.example.demo.domain.entity.Recharge;
 import com.example.demo.domain.entity.User;
 import com.example.demo.domain.vo.RechargeVo;
+import com.example.demo.domain.vo.Result;
 import com.example.demo.mapper.AuditMapper;
 import com.example.demo.mapper.DetailMapper;
 import com.example.demo.mapper.RechargeMapper;
@@ -181,10 +182,22 @@ public class RechargeServiceImpl implements RechargeService {
         List<RechargeVo> list= rechargeMapper.select(rechargeVo);
         return new PageInfo<>(list);
     }
+
     @Cacheable(key="#root.method.name")
     @Override
     public int getAllByjwAndup(String jwcode) {
-
         return rechargeMapper.getAllByjwAndup(jwcode);
     }
-}
+
+    @Override
+    public Result addRecharges(List<Recharge> recharges) {
+        try {
+            // 这里可以添加具体的批量添加逻辑，例如调用 DAO 层的方法进行批量插入
+           rechargeMapper.insertBatch(recharges);
+            return Result.success("批量添加成功");
+        } catch (Exception e) {
+            return Result.error("批量添加失败: " + e.getMessage());
+        }
+    }
+    }
+

src/main/java/com/example/demo/serviceImpl/UserServiceImpl.java

@@ -43,6 +43,11 @@ public class UserServiceImpl implements UserSevice {
         return userMapper.selectArea();
     }
 
+    @Override
+    public List<String> jwcode() {
+        return userMapper.selectJwcode();
+    }
+
     //设置免费金币
 //    public User updateFreecoin(Detail userConsumeCoin) {
 //

src/main/java/com/example/demo/sevice/RechargeService.java

@@ -3,6 +3,7 @@ package com.example.demo.sevice;
 
 import com.example.demo.domain.entity.Recharge;
 import com.example.demo.domain.vo.RechargeVo;
+import com.example.demo.domain.vo.Result;
 import com.github.pagehelper.PageInfo;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -17,5 +18,12 @@ public interface RechargeService {
     List<RechargeVo> search(RechargeVo rechargeVo) ;
     PageInfo<RechargeVo> searchForPage(Integer pageNum, Integer pageSize, RechargeVo rechargeVo);
 
+
     int getAllByjwAndup(String jwcode);
+    /**
+     * 批量添加充值记录
+     * @param recharges 充值记录列表
+     * @return 处理结果
+     */
+    Result addRecharges(List<Recharge> recharges);
 }

src/main/java/com/example/demo/sevice/UserSevice.java

@@ -11,4 +11,5 @@ public interface UserSevice {
     UserVo search(UserVo userVo) throws Exception;
     PageInfo<User> searchForPage(Integer pageNum, Integer pageSize, User User);
     List<String> area();
+    List<String> jwcode();
 }