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