From 7a372033d44ba48383d9d1bc97e5d583b26a266f Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 22 Aug 2024 16:41:59 +0800
Subject: [PATCH] 后台

---
 /dev/null                              |  345 -------------------------------------------------
 src/main/resources/application-dev.yml |   16 +-
 2 files changed, 8 insertions(+), 353 deletions(-)

diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index c047b56..54cf749 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -18,17 +18,17 @@
           username: db_guess
           password: db_guess123!@#
           driver-class-name: com.mysql.cj.jdbc.Driver
-          url: jdbc:mysql://47.243.240.123:3306/db_guess?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
-#          username: db_mall_gfa
-#          password: db_mall_gfa123!@#123
-#          driver-class-name: com.mysql.cj.jdbc.Driver
-#          url: jdbc:mysql://47.111.90.145:3306/db_mall_gfa?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
+          url: jdbc:mysql://8.210.56.119:3306/db_guess?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
+  #          username: db_mall_gfa
+  #          password: db_mall_gfa123!@#123
+  #          driver-class-name: com.mysql.cj.jdbc.Driver
+  #          url: jdbc:mysql://47.111.90.145:3306/db_mall_gfa?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
 
   redis:
     # Redis数据库索引(默认为 0)
-    database: 1
+    database: 14
     # Redis服务器地址
-    host: 47.243.240.123
+    host: 8.210.56.119
     # Redis服务器连接端口
     port: 6379
     # Redis 密码
@@ -46,7 +46,7 @@
     # 连接超时时间(毫秒)
     timeout: 5000
   rabbitmq:
-    host: 47.243.240.123
+    host: 8.210.56.119
     port: 5672
     username: xc_rabbit
     password: xuncong123
diff --git a/src/test/java/cc/mrbird/febs/AgentTest.java b/src/test/java/cc/mrbird/febs/AgentTest.java
deleted file mode 100644
index 6d1b7a1..0000000
--- a/src/test/java/cc/mrbird/febs/AgentTest.java
+++ /dev/null
@@ -1,33 +0,0 @@
-package cc.mrbird.febs;
-
-import cc.mrbird.febs.mall.dto.ApiCreateRoomDto;
-import cc.mrbird.febs.mall.service.GameService;
-import lombok.extern.slf4j.Slf4j;
-import org.junit.jupiter.api.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-
-/**
- * @author wzy
- * @date 2021-09-25
- **/
-@Slf4j
-@SpringBootTest
-public class AgentTest {
-
-    @Autowired
-    private GameService gameService;
-
-//    /**
-//     * 房主操作
-//     */
-//    //创建房间
-//    @Test
-//    public void createRoom() {
-//
-//        ApiCreateRoomDto apiCreateRoomDto = new ApiCreateRoomDto();
-//        apiCreateRoomDto.setRoomType(1);
-//        apiCreateRoomDto.setGameTime(10);
-//        gameService.createRoom(apiCreateRoomDto);
-//    }
-}
diff --git a/src/test/java/cc/mrbird/febs/PayTest.java b/src/test/java/cc/mrbird/febs/PayTest.java
deleted file mode 100644
index 8820dad..0000000
--- a/src/test/java/cc/mrbird/febs/PayTest.java
+++ /dev/null
@@ -1,69 +0,0 @@
-package cc.mrbird.febs;
-
-import cc.mrbird.febs.pay.properties.WxPayProperties;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.lang.UUID;
-import cn.hutool.core.util.RandomUtil;
-import com.alibaba.fastjson.JSONObject;
-import com.alipay.api.AlipayApiException;
-import com.alipay.api.domain.AlipayTradeAppPayModel;
-import com.alipay.api.response.AlipayTradeAppPayResponse;
-import com.github.binarywang.wxpay.bean.order.WxPayAppOrderResult;
-import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
-import com.github.binarywang.wxpay.bean.result.WxPayUnifiedOrderResult;
-import com.github.binarywang.wxpay.exception.WxPayException;
-import com.github.binarywang.wxpay.service.WxPayService;
-import com.ijpay.alipay.AliPayApi;
-import lombok.extern.slf4j.Slf4j;
-import org.junit.jupiter.api.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-
-/**
- * @author wzy
- * @date 2021-09-27
- **/
-@Slf4j
-@SpringBootTest
-public class PayTest {
-
-//    @Test
-//    public void aliPay() throws AlipayApiException {
-//        AlipayTradeAppPayModel model = new AlipayTradeAppPayModel();
-//        model.setBody("这是测试用");
-//        model.setSubject("支付测试用的");
-//        model.setOutTradeNo("2021092712215802974");
-//        model.setTimeoutExpress("15m");
-//        model.setTotalAmount("0.01");
-//        model.setPassbackParams("callback params");
-//        model.setProductCode("QUICK_MSECURITY_PAY");
-//        AlipayTradeAppPayResponse resp = AliPayApi.appPayToResponse(model, "");
-//        log.info("=====>>>{}", JSONObject.toJSONString(resp));
-//    }
-//
-//    @Autowired
-//    private WxPayService wxPayService;
-//
-//    @Autowired
-//    private WxPayProperties wxPayProperties;
-//
-//    @Test
-//    public void wxPayTest() {
-//        WxPayUnifiedOrderRequest request = new WxPayUnifiedOrderRequest();
-//        request.setAppid(wxPayProperties.getAppId());
-//        request.setMchId(wxPayProperties.getMchId());
-//        request.setNotifyUrl(wxPayProperties.getNoticeUrl());
-//        request.setBody("这是body");
-//        request.setOutTradeNo(RandomUtil.randomString(32));
-//        request.setTimeExpire("20230407114500");
-//        request.setSpbillCreateIp("127.0.0.1");
-//        request.setTradeType("APP");
-//        request.setTotalFee(1);
-//        try {
-//            WxPayAppOrderResult result = wxPayService.createOrder(request);
-//            System.out.println(1111);
-//        } catch (WxPayException e) {
-//            e.printStackTrace();
-//        }
-//    }
-}
diff --git a/src/test/java/cc/mrbird/febs/ProfitTest.java b/src/test/java/cc/mrbird/febs/ProfitTest.java
deleted file mode 100644
index 489209f..0000000
--- a/src/test/java/cc/mrbird/febs/ProfitTest.java
+++ /dev/null
@@ -1,345 +0,0 @@
-package cc.mrbird.febs;
-
-import cc.mrbird.febs.mall.mapper.*;
-import cc.mrbird.febs.mall.service.*;
-import cc.mrbird.febs.pay.service.LaKaLaService;
-import cc.mrbird.febs.pay.service.NBYHService;
-import org.junit.jupiter.api.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.core.io.ResourceLoader;
-
-/**
- * @author wzy
- * @date 2022-06-02
- **/
-@SpringBootTest
-public class ProfitTest {
-
-//    @Autowired
-//    private IAgentService agentService;
-//    @Autowired
-//    private MallMemberMapper memberMapper;
-//    @Autowired
-//    private DataDictionaryCustomMapper dataDictionaryCustomMapper;
-//    @Autowired
-//    private MallProductBuyMapper mallProductBuyMapper;
-//    @Test
-//    public void dynamicProfit(){
-//
-//        QueryWrapper<MallProductBuy> query = new QueryWrapper<>();
-//        query.eq("state", ProductEnum.PRODUCT_BUY_SUCCESS.getValue());
-//        query.eq("mate_state",ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
-//        List<MallProductBuy> mallProductBuys = mallProductBuyMapper.selectList(query);
-//        if(CollUtil.isEmpty(mallProductBuys)){
-//            return;
-//        }
-//
-//        Set<Long> collect = mallProductBuys.stream().map(MallProductBuy::getMemberId).collect(Collectors.toSet());
-//        if(CollUtil.isEmpty(collect)){
-//            return;
-//        }
-//        for(Long memberId : collect){
-//            MallMember mallMember = memberMapper.selectById(memberId);
-//            if(ObjectUtil.isEmpty(mallMember)){
-//                continue;
-//            }
-//            //上级
-//            String referrerId = mallMember.getReferrerId();
-//            MallMember mallMemberRef = memberMapper.selectInfoByInviteId(referrerId);
-//            if(ObjectUtil.isEmpty(mallMemberRef)){
-//                continue;
-//            }
-//            List<MallMember> mallMembersAll = memberMapper.selectAllChildAgentListByInviteId(referrerId);
-//
-//            List<MallMember> mallMembers = memberMapper.selectByRefererId(referrerId);
-//            Set<Long> mallMembersSet = mallMembers.stream().map(MallMember::getId).collect(Collectors.toSet());
-//            mallMembersSet.retainAll(collect);
-//            List<Long> intersection = new ArrayList<>(mallMembersSet);//上级直推有效人数
-//            if(CollUtil.isEmpty(intersection)){
-//                mallMemberRef.setLevel(MemberLevelNewEnum.ZERO_LEVEL.getType());
-//                memberMapper.updateById(mallMemberRef);
-//                continue;
-//            }
-//            /**
-//             * 从会员等级最低到最高,比较intersection与会员设置的直推人数directCntLevel比较
-//             * directCntLevel >= intersection.size(),则满足升级会员等级条件,跳出循环
-//             * teamCnt >= mallMembersAll.size(),则满足升级会员等级条件,跳出循环
-//             * 达到最高级别后,升级会员等级,跳出循环
-//             */
-//            String level = MemberLevelNewEnum.ZERO_LEVEL.getType();
-//            boolean flag = false;
-//            while (!flag){
-//                DataDictionaryCustom levelDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
-//                        level, level
-//                );
-//                TeamPerkDto teamPerkDto = JSONObject.parseObject(levelDic.getValue(), TeamPerkDto.class);
-//                Integer directCntLevel = teamPerkDto.getDirectCnt();
-//                Integer teamCnt = teamPerkDto.getTeamCnt();
-//                if(directCntLevel <= intersection.size()){
-//                    if(teamCnt <= mallMembersAll.size()){
-//                        mallMemberRef.setLevel(level);
-//                        memberMapper.updateById(mallMemberRef);
-//
-//                        String nextLevel = MemberLevelNewEnum.ZERO_LEVEL.getNextLevel(level);
-//                        level = nextLevel;
-//                        if(level.equals(MemberLevelNewEnum.WU_LEVEL.getType()) &&
-//                                nextLevel.equals(MemberLevelNewEnum.WU_LEVEL.getType()) ){
-//                            mallMemberRef.setLevel(level);
-//                            memberMapper.updateById(mallMemberRef);
-//                            flag = true;
-//                        }
-//                    }else{
-//                        flag = true;
-//                    }
-//                }else{
-//                    flag = true;
-//                }
-//            }
-//        }
-//    }
-//    @Autowired
-//    private AgentConsumer agentConsumer;
-//
-//    @Autowired
-//    private IAgentService agentService;
-//
-//    @Autowired
-//    private IMemberProfitService memberProfitService;
-//
-//    @Autowired
-//    private IApiMallOrderInfoService iApiMallOrderInfoService;
-//
-//    @Autowired
-//    private MallMemberMapper memberMapper;
-//
-//    @Autowired
-//    private AgentProducer agentProducer;
-//
-//    @Test
-//    public void dynamicProfit() {
-//        agentService.perkMoneyConsumer(Long.parseLong("796"));
-////        memberProfitService.dynamicProfit(Long.parseLong("709"));
-////        memberProfitService.scoreRecordReleaseJob();
-////        memberProfitService.achieveReleaseJob();
-////        agentProducer.sendPerkMoneyMsg(679L);
-////        agentService.perkMoneyConsumer(665L);
-////        memberProfitService.teamEqualsPerkJob(null);
-////        List<MallMember> mallMemberTeamPerk = new ArrayList<>();
-////        MallMember mallMember = memberMapper.selectById(233L);
-////        List<String> ids = StrUtil.split(mallMember.getReferrerIds(), ',');
-////        List<MallMember> mallMembers = memberMapper.selectByInviteIds(ids);
-////        Map<String, List<MallMember>> collect = mallMembers.stream().collect(Collectors.groupingBy(MallMember::getLevel));
-////        Set<String> set = collect.keySet(); // 得到所有key的集合
-////        for (String key : set) {
-////            List<MallMember> value = collect.get(key);
-////            System.out.println(key + " " + value);
-////            mallMemberTeamPerk.add(value.get(0));
-////
-////            System.out.println(value.get(0).getName());
-////
-////        }
-////        List<Long> mallMemberStarIds = mallMemberTeamPerk.stream().map(MallMember::getId).collect(Collectors.toList());
-////
-////        System.out.println(mallMemberStarIds);
-//    }
-
-
-//    @Autowired
-//    private LaKaLaService laKaLaService;
-//    @Autowired
-//    ResourceLoader resourceLoader;
-//    @Autowired
-//    private NBYHService nbyhService;
-//    @Autowired
-//    private IAdminMallMemberService mallMemberService;
-//    @Autowired
-//    private MallProductNftMapper mallProductNftMapper;
-//
-//    @Test
-//    public void agentProfitTrade() {
-//        boolean flag = true;
-//        Integer i = 0;
-////        while (flag){
-//////            agentService.BuyToSellV2();
-////            DateTime dateTime = DateUtil.offsetDay(new DateTime(), i);
-////            agentService.BuyToSellV3(dateTime);
-////            i = i+1;
-////            List<MallProductBuy> mallProductBuys = mallProductBuyMapper.selectListByStateAndMateState(
-////                    ProductEnum.PRODUCT_BUY_SUCCESS.getValue(),
-////                    ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
-////            if(CollUtil.isEmpty(mallProductBuys)){
-////                flag = false;
-////            }
-////        }
-//        System.out.println(i);
-//    }
-//    @Test
-//    public void agentProfit() {
-////        try {
-////            System.out.println(resourceLoader.getResource("classpath:lkl/api_private_key.pem").getInputStream());
-////        } catch (IOException e) {
-////            e.printStackTrace();
-////        }
-////        LaKaLaCreateOrderReqDate laKaLaCreateOrderReqDate = new LaKaLaCreateOrderReqDate();
-////        //订单编号
-////        laKaLaCreateOrderReqDate.setOut_order_no("2023041918302032901");
-////        //订单金额,分计
-////        laKaLaCreateOrderReqDate.setTotal_amount(new BigDecimal(1).longValue());
-////        laKaLaCreateOrderReqDate.setOrder_info("礼品一");
-////        laKaLaService.verifyCreateOrder(laKaLaCreateOrderReqDate);
-//    }
-//
-//
-////    @Test
-////    public void staticProfit() {
-////        memberProfitService.staticProfit(new Date());
-////    }
-//
-//    @Test
-//    public void thankfulProfit() {
-//        memberProfitService.mqPerkRetryJob();
-//    }
-//
-//    @Test
-//    public void rankProfit() {
-//        memberProfitService.rankProfit();
-//    }
-//
-//    @Autowired
-//    private MallOrderInfoMapper mallOrderInfoMapper;
-//
-//    @Test
-//    public void directorProfitTest() {
-//        memberProfitService.storeAndDirectorProfit(new Date());
-//    }
-//
-//    @Autowired
-//    private MallOrderItemMapper mallOrderItemMapper;
-//
-//    @Autowired
-//    private IMallAchieveService mallAchieveService;
-//
-//    @Test
-//    public void achieveTest() {
-//        List<MallOrderItem> items = mallOrderItemMapper.selectList(null);
-//        for (MallOrderItem item : items) {
-//            mallAchieveService.add(item.getId());
-//        }
-//    }
-//
-//    @Test
-//    public void paramTest() {
-//        Map<String, Integer> map = new HashMap<>();
-//        BigDecimal amount = new BigDecimal("100");
-//        map.put("amount", 1);
-//        changeAmount(map);
-//        System.out.println(map.get("amount"));
-//    }
-//
-//    public void changeAmount(Map<String, Integer> amount) {
-//        amount.put("amount", 2);
-//    }
-//
-//    @Test
-//    public void scorePool(){
-//        memberProfitService.scorePool();
-//    }
-//
-//    @Test
-//    public void staticProfit(){
-//        memberProfitService.staticProfit(null);
-//    }
-//
-//    @Autowired
-//    private OrderSettlementJob orderSettlementJob;
-//
-//    @Test
-//    public void orderSettlementJobTest() {
-////        orderSettlementJob.normalGoodsSettlementJob();
-//
-//        mallAchieveService.add(83L);
-//    }
-//
-//
-//    @Autowired
-//    private UnipayService unipayService;
-//    @Test
-//    public void unipay(){
-//        UnipayDto unipayDto = new UnipayDto();
-//        unipayDto.setAmount(new BigDecimal("0.01"));
-//        unipayDto.setFrpCode("ALIPAY_H5");
-//        unipayDto.setTradeMerchantNo("777180800385820");
-////        unipayDto.setFrpCode("WEIXIN_APP3");
-//        unipayDto.setOrderNo("2022082316415386395");
-//        unipayDto.setProductName("洗护套装");
-//        unipayService.unipay(unipayDto);
-//    }
-//    @Test
-//    public void getAgreeMentPaySms(){
-//        AgreeMentPaySmsDto agreeMentPaySmsDto = new AgreeMentPaySmsDto();
-//        agreeMentPaySmsDto.setOrderNo("2022082617305930328");
-//
-//        BigDecimal value = new BigDecimal("0.1").setScale(2, BigDecimal.ROUND_DOWN);
-//        DecimalFormat decimalFormat = new DecimalFormat("0.00#");
-//        String strVal = decimalFormat.format(value);
-//        agreeMentPaySmsDto.setOrderAmount(new BigDecimal(strVal));
-//        agreeMentPaySmsDto.setName("肖永");
-//        agreeMentPaySmsDto.setCreatedTime(DateUtil.now());
-//        agreeMentPaySmsDto.setIdType("1");
-//        agreeMentPaySmsDto.setIdCardNum("430321199310113713");
-//        agreeMentPaySmsDto.setBankNo("6222031901002389639");
-//        agreeMentPaySmsDto.setPhone("15274802129");
-//        String agreeMentPaySms = unipayService.getAgreeMentPaySms(agreeMentPaySmsDto);
-//        if("JS000000".equals(agreeMentPaySms)){
-//            System.out.println("获取成功");
-//        }else{
-//            System.out.println(agreeMentPaySms);
-//        }
-//    }
-//
-//    @Test
-//    public void agreementSign(){
-//        AgreementSignDto agreementSignDto = new AgreementSignDto();
-//        agreementSignDto.setOrderNo("2022082614465345250");
-//        agreementSignDto.setSmsCode("841243");
-//        unipayService.agreementSign(agreementSignDto);
-//    }
-//
-//    @Test
-//    public void agreementPay(){
-//        AgreementPayDto agreementPayDto = new AgreementPayDto();
-//        agreementPayDto.setOrderNo("2022082614465345250");
-//
-//        BigDecimal value = new BigDecimal("0.1").setScale(2, BigDecimal.ROUND_DOWN);
-//        DecimalFormat decimalFormat = new DecimalFormat("0.00#");
-//        String strVal = decimalFormat.format(value);
-//        agreementPayDto.setOrderAmount(new BigDecimal(strVal));
-//        agreementPayDto.setOrderTime(DateUtil.now());
-//        agreementPayDto.setOrderDesc("测试");
-//        agreementPayDto.setBankNo("6222031901002389639");
-//        unipayService.agreementPay(agreementPayDto);
-//    }
-//
-//    @Test
-//    public void singlePay(){
-//        /**
-//         * 调用汇聚代付
-//         */
-//        String orderNo = MallUtils.getOrderNum("W");
-//        SinglePayDto singlePayDto = new SinglePayDto();
-//        singlePayDto.setMerchantOrderNo(orderNo);
-//        singlePayDto.setReceiverAccountNoEncBankNo("6222031903210023839639");
-//        singlePayDto.setReceiverAccountNoEncName("肖永");
-//        singlePayDto.setReceiverAccountType("201");
-//        BigDecimal paidAmount = new BigDecimal(1.00);
-//        singlePayDto.setPaidAmount(paidAmount);
-//        singlePayDto.setCurrency("201");
-//        singlePayDto.setIsChecked("202");
-//        singlePayDto.setPaidDesc("用户提现");
-//        singlePayDto.setPaidUse("202");
-//        String singlePayRep = unipayService.singlePay(singlePayDto);
-//
-//        System.out.println(singlePayRep);
-//    }
-}

--
Gitblit v1.9.1