From 1d9f7b0cf4251f3058badb07dd7a2bc06b6bc09a Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期五, 11 四月 2025 10:05:32 +0800 Subject: [PATCH] bug修改 --- cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackageServiceImpl.java | 214 +++++++++++++++++++++++++++++++++++++--------------- 1 files changed, 151 insertions(+), 63 deletions(-) diff --git a/cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackageServiceImpl.java b/cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackageServiceImpl.java index e140bb1..fca703b 100644 --- a/cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackageServiceImpl.java +++ b/cloud-server-course/src/main/java/com/dsh/course/service/impl/TCoursePackageServiceImpl.java @@ -143,12 +143,6 @@ @Override public List<CoursePackageListVo> queryCourseList(Integer uid, CoursePackageList coursePackageList) throws Exception { AppUser appUser = appUserClient.queryAppUser(uid); -// Map<String, String> geocode = gdMapGeocodingUtil.geocode(coursePackageList.getLon(), coursePackageList.getLat()); -// String provinceCode = geocode.get("provinceCode"); -// String cityCode = geocode.get("cityCode"); -// QueryWrapper<TCoursePackage> wrapper = new QueryWrapper<TCoursePackage>().in("status", Arrays.asList(1, 2)) -// .eq("auditStatus", 2).eq("state", 1).eq("provinceCode", provinceCode).eq("cityCode", cityCode); - QueryWrapper<TCoursePackage> wrapper = new QueryWrapper<TCoursePackage>().in("status", Arrays.asList(1, 2)) .eq("auditStatus", 2).eq("state", 1); if (null != coursePackageList.getCoursePackageTypeId()) { @@ -171,7 +165,6 @@ List<TCoursePackage> list1 = this.list(wrapper.last(" order by sort desc, insertTime desc")); Date currentTime = new Date(); -// Filter the list based on the conditions List<TCoursePackage> list = list1.stream() .filter(coursePackage -> coursePackage.getType() != 2 || currentTime.before(coursePackage.getEndTime())) .collect(Collectors.toList()); @@ -188,7 +181,6 @@ coursePackageListVo.setStoreName(null != store ? store.getName() : ""); coursePackageListVo.setCoverDrawing(coursePackage.getCoverDrawing()); - // 2.0修改 String classStartTime = coursePackage.getClassStartTime(); String classEndTime = coursePackage.getClassEndTime(); ArrayList<String> classTime = new ArrayList<>(); @@ -311,35 +303,8 @@ } coursePackageListVo.setPaymentPrice(paymentPrice); - double vipPrice1 = coursePackageListVo.getVipPrice(); - double originalPrice1 = coursePackageListVo.getOriginalPrice(); - double paymentPrice1 = coursePackageListVo.getPaymentPrice(); - -// double minPrice = Math.min(vipPrice1, Math.min(originalPrice1, paymentPrice1)); -// double maxPrice = Math.max(vipPrice1, Math.max(originalPrice1, paymentPrice1)); -// coursePackageListVo.setPaymentPrice(minPrice); -// coursePackageListVo.setOriginalPrice(maxPrice); -// System.out.println("Minimum price: " + minPrice); - - -// } -// else{ -// List<TCoursePackageDiscount> list2 = coursePackageDiscountService.list(new QueryWrapper<TCoursePackageDiscount>().eq("coursePackagePaymentConfigId", coursePackagePaymentConfig.getId()) -// .eq("type", 1).eq("auditStatus", 2).eq("status",1)); -// Double vipPrice = coursePackagePaymentConfig.getCashPayment(); -// for (TCoursePackageDiscount coursePackageDiscount : list2) { -// Double num1 = JSON.parseObject(coursePackageDiscount.getContent()).getDouble("discountMember"); -// if(vipPrice.compareTo(num1) > 0){ -// vipPrice = num1; -// } -// } -// coursePackageListVo.setPaymentPrice(vipPrice); -// coursePackageListVo.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); -// } - if (coursePackageListVo.getPaymentPrice() < coursePackageListVo.getVipPrice()) { coursePackageListVo.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); -// coursePackageListVo.setVipPrice(null); } if (appUser.getIsVip() == 1) { @@ -445,7 +410,6 @@ coursePackageListVo.setPayType(2); } - // 2.0修改 String classStartTime = coursePackage.getClassStartTime(); String classEndTime = coursePackage.getClassEndTime(); ArrayList<String> classTime = new ArrayList<>(); @@ -966,6 +930,7 @@ coursePackageOrder.setStatus(1); coursePackageOrder.setState(1); coursePackageOrder.setInsertTime(new Date()); + coursePackageOrder.setOrderType(1); coursePackageOrderService.save(coursePackageOrder); orderId = coursePackageOrder.getId(); }else{ @@ -977,8 +942,17 @@ coursePackageOrder.setPayUserId(uid); coursePackageOrderService.updateById(coursePackageOrder); } - - ResultUtil weixinpay = payMoneyUtil.weixinpay("购买课程", coursePackagePaymentConfig.getId().toString(), code, paymentPrice.toString(), "/base/course/weChatPaymentCourseCallback", "APP", ""); + TCoursePackage byId = coursePackageService.getById(paymentCourseVo.getId()); + Integer storeId = byId.getStoreId(); + Store store = storeClient.queryStoreById(storeId); + // 是否分账 0否1是 + int isFenZhang= 1; + if (store.getOperatorId()==null || store.getOperatorId()==0){ + // 平台 + isFenZhang = 0; + } + ResultUtil weixinpay = payMoneyUtil.weixinpay("报名运动营"+"-"+isFenZhang, coursePackagePaymentConfig.getId().toString(), code, paymentPrice.toString(), + "/base/course/weChatPaymentCourseCallback", "APP", ""); if (weixinpay.getCode() == 200) { String finalCode = code; new Thread(new Runnable() { @@ -1010,7 +984,7 @@ Map<String, String> data1 = resultUtil.getData(); String s = data1.get("trade_state"); String transaction_id = data1.get("transaction_id"); - if ("REFUND".equals(s) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) { + if ("REFUND".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) { //有待支付的订单,这里不处理 // coursePackageOrder1.setState(3); // coursePackageOrderService.updateById(coursePackageOrder1); @@ -1022,12 +996,15 @@ coursePackageOrder1.setAppUserId(null); coursePackageOrderService.updateById(coursePackageOrder1); //修改课时有效期 - - addCoursePackageOrderStudent(coursePackageOrder1.getId(), coursePackagePaymentConfig); + + + + break; + } - if ("USERPAYING".equals(s)) { + if ("USERPAYING".equals(s) || "NOTPAY".equals(s)) { num++; } } @@ -1041,7 +1018,7 @@ return weixinpay; } - + private String smid = "2088330203191220";//平台支付宝商户号 /** * 课程支付宝支付 * @@ -1055,6 +1032,7 @@ CoursePackagePaymentConfig coursePackagePaymentConfig = coursePackagePaymentConfigService.getById(paymentCourseVo.getCoursePackagePaymentConfigId()); SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5); + String smid1=""; //生成支付订单 if (paymentCourseVo.getOrderId()==null){ CoursePackageOrder coursePackageOrder = new CoursePackageOrder(); @@ -1073,6 +1051,7 @@ coursePackageOrder.setStatus(1); coursePackageOrder.setState(1); coursePackageOrder.setInsertTime(new Date()); + coursePackageOrder.setOrderType(1); coursePackageOrderService.save(coursePackageOrder); }else { CoursePackageOrder coursePackageOrder = coursePackageOrderService.getById(paymentCourseVo.getOrderId()); @@ -1083,8 +1062,22 @@ coursePackageOrder.setPayUserId(uid); coursePackageOrderService.updateById(coursePackageOrder); } - - ResultUtil alipay = payMoneyUtil.alipay("购买课程", "购买课程", coursePackagePaymentConfig.getId().toString(), code, paymentPrice.toString(), "/base/course/aliPaymentCourseCallback"); + // 判断这个课包属于哪个门店 属于哪个运营商 根据运营商 id 获取对应的商户号 + Integer coursePackageId = paymentCourseVo.getId(); + TCoursePackage byId = coursePackageService.getById(coursePackageId); + Store store = storeClient.queryStoreById(byId.getStoreId()); + if (store.getOperatorId() == null){ + smid1 = smid; + }else{ + if (store.getOperatorId()==0){ + smid1 = smid; + }else{ + smid1 = storeClient.getSMIDByOperatorId(store.getOperatorId()); + } + } + ResultUtil alipay = payMoneyUtil.alipay(smid1,"报名运动营", "报名运动营", + coursePackagePaymentConfig.getId().toString(), + code, paymentPrice.toString(), "/base/course/aliPaymentCourseCallback"); if (alipay.getCode() == 200) { String finalCode = code; new Thread(new Runnable() { @@ -1092,7 +1085,6 @@ public void run() { try { Thread.sleep(1000); - int num = 1; int wait = 0; while (num <= 10) { @@ -1128,7 +1120,31 @@ coursePackageOrderService.updateById(coursePackageOrder1); addCoursePackageOrderStudent(coursePackageOrder1.getId(), coursePackagePaymentConfig); moneyOut(tradeNo,tradeNo,finalCode); - break; + // 根据课程id 查询这个课程属于哪个门店 属于哪个运营商 + Integer id = paymentCourseVo.getId(); + TCoursePackage byId = coursePackageService.getById(id); + Integer storeId = byId.getStoreId(); + Store store = storeClient.queryStoreById(storeId); + Integer operatorId = store.getOperatorId(); + if (operatorId==null){ + String smid ="2088330203191220"; + // 说明是平台的 不走分账 +// payMoneyUtil.confirm(smid,finalCode,tradeNo,paymentPrice.toString()); + payMoneyUtil.confirm1(smid,finalCode,tradeNo,paymentPrice.toString()); + break; + }else if (operatorId==0){ + String smid ="2088330203191220"; + // 说明是平台的 + payMoneyUtil.confirm1(smid,finalCode,tradeNo,paymentPrice.toString()); + break; + }else{ + // 当前课程不属于门店 查询这个课程属于哪个门店 属于哪个运营商 + String smidByOperatorId = storeClient.getSMIDByOperatorId(operatorId); + payMoneyUtil.confirm(smidByOperatorId,finalCode,tradeNo,paymentPrice.toString()); + // 分账处理 + extracted(store, coursePackageOrder1, tradeNo); + break; + } } if ("WAIT_BUYER_PAY".equals(s)) { num++; @@ -1144,7 +1160,52 @@ return alipay; } - + private void extracted(Store store, CoursePackageOrder coursePackageOrder1, String tradeNo) throws Exception { + // 分账 + AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", + "2021004105665036", + "MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCi5i9nW/hGLJ3A06cZxTQdviFC7THpdSihoTYGLr9q006hu0V26ecBMY/o4w5bvIX0Ok/yofmZsVcCJpAPvbXL/uqVrIjnRRxXiaeBFThlxoBUTdunvbUSDYfzlEhJr5NvUKI6H6lz2niXlQGx4qy8Hau4ccWit9kM8jwUvsBVQoFgJA+xrjMvooA7YLopQtpOD+UJr5thApTSf1xrnr1W12yolTLEH15JmNV372cqXrYUuqnY0QsaPtxeqJUGAOcGdVLllQ7easEznP8DFBvDdHATcmp2SHNQDUEWN6MCVPbMgY06NQVqAXxqjTAYSVh+6TRu6bofPmpYC3TZB003AgMBAAECggEBAJAcR2+PA3NBYUYHeFrqBRMS8uX8ZR19kjZ7IgoSLTFaQsP9opRylPSPXhrPVBKAE5leRQAHn4MCSlESwHvMfxo7KFjFTFAc6dffZZpipYQUOc9bGampwJh58/3e/pyBgVMG6J23CPf/HJQtNFSkjd/V9+ayb/9l2dUEL3bC0fAZ/dbx8HsxdLw8wn3fLlWLj68hOMqa2deCZe3JdSVsPbeWqkh56FFsMLug0Nd+Ar4TgRl9/jnhXF0JWiD0LmPUYLhboY7EfUBzN4w1iYbDi1P+3zvoOYsiVKAXox9GMhQ2VzOO2UcSTuizSza2e98mGpabl/GpKmCz+RDFjtkX6eECgYEA2MyCij65eO3aGIm3FUe93DULRBYTfX8qJQSJq2WOWA3mmQlEW6L3O2B5/lG2h+8WmN6iLEs9eHpgycGYp7vAqgrANEn16ACVcuyx0scFtrZfZ+kmHMzFfiUWxJjVYk/6YngsGVBLdw6ueM42C8TTP67X9tU5TdVGoGWuqEj4W98CgYEAwFqwprXOch5Pqk/RPbb49r0Ou03K/UbciWnWWKzUhFFNS8MdlQPoDvQZbMwHLeWsa2VhaKITK3x5biLQb3U+0GLOn6lTvEyrEUH+ucREyLgVYTRAvwBPtnvlrzpyxPk2HnslQjju8WrvvLLBMKWUjlTrTOzhaHT21gz3pHMiOakCgYEAhLmfaXdBITGshb054sNLDtdCkGpbgEcrzAHdLps769iGxkYQHXHFngpQZUwtTUcoNGqIKknd1jZFrv7gsD+XkgKG7PwimehRlkwmCX5ilxtLiVgJRzRt6+5U5AMVD90a0tHzXYP0z2yjj73fBJF5KtGl0a10KZxaYrQdm1UhB00CgYBZZgzx/k9rtHC8LAqIj1CYhHejT92G53c6Gkl3vyOqN4sgKhfGmSEySfrDGPRBPZxr8ZtbIPCd5mUdberH0osWGMYFaJI1UsCy7aQwvGpniz7MhZeN7dweaOjwDs8mgtjHQ96mL4XGCDhR0BZ/wIURvZ/6iaGdhbbu9unlsWj3uQKBgQCmZYdsbbZkd3ev6f8rwyvMz+DrCQyYpY44cegBYuJgrZiQnL2fJioeN7ixX0UM48SfwsZEIrzshP/LGAwnc2MdjxKUl4jLN8SEe0NAjXOnz9Zaw740+aOmLpXcLWdP4uM2gIhWsvW1tEkQZCXmm7c9s/RsU8Pmzv+YL3+fSijOzA==", + "json", "GBK", + "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmu8n/4yTHWbn7VOrNc9OsLtDL1bEQ8gC1dHkj8Wy5z0mkaOsjJRIG/28ze12M0V8jdCKuuDr5Z1OPKiqf+XO3ypguEh+mYUVMBM/cZodDFQfTY1TKLWjvQCuaqlA+QUTCK6f7T7stsgyQ1o9Jj0rXZDz6PM4QHSTzjrLIBaeqM5WIBvH+fy/X+QG5Utd+/UT0kc0JyvuKhZ65yVUd/C9VcwJJAPliRsAQNrqYterwAJ9zvw9tF11wj9W0XgJ8Ccu4x3gR1vrlLRJJo/OA97RmxPQ+5hSacWQZCUd1dwiBq+YCrKVHGTj14izRHXrLc0yBlRXo7tBOIqcy3IsvKVthQIDAQAB", + "RSA2"); + AlipayTradeOrderSettleRequest request = new AlipayTradeOrderSettleRequest(); + String randomCode = UUIDUtil.getRandomCode(16); + String proportionByOperatorId = storeClient.getProportionByOperatorId(store.getOperatorId()); + // 支付宝分账比例 + String s1 = proportionByOperatorId.split(",")[1]; + double i = Double.parseDouble(s1); + double v = i * 0.01; + BigDecimal bigDecimal1 = new BigDecimal(String.valueOf(v)); + BigDecimal cashPayment = coursePackageOrder1.getCashPayment(); + // 分账金额 + BigDecimal bigDecimal2 = cashPayment.multiply(bigDecimal1).setScale(2, RoundingMode.DOWN); + request.setBizContent("{" + + " \"out_request_no\":\"" + randomCode + "\"," + + " \"trade_no\":\"" + tradeNo + "\"," + + " \"royalty_parameters\":[" + + " {" + + " \"royalty_type\":\"transfer\"," + + " \"trans_out\":\"" + storeClient.getSMIDByOperatorId(store.getOperatorId()) + "\"," + + " \"trans_out_type\":\"userId\"," + + " \"trans_in_type\":\"userId\"," + + " \"trans_in\":\"" + smid + "\"," + + " \"amount\":" + bigDecimal2 + "," + + " \"desc\":\"平台服务费\"," + + " \"royalty_scene\":\"平台服务费\"," + + " }" + + " ]," + + " \"extend_params\":{" + + " \"royalty_finish\":\"true\"" + + " }," + + " \"royalty_mode\":\"async\"" + + "}"); + AlipayTradeOrderSettleResponse response = alipayClient.execute(request); + if (response.isSuccess()) { + System.out.println("调用成功"); + } else { + System.out.println("调用失败"); + } + } //分账 public void moneyOut(String outNum, String tradeNo,String code) throws AlipayApiException { AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", aliAppid, appPrivateKey, "json", "UTF-8", alipay_public_key, "RSA2"); @@ -1252,6 +1313,7 @@ coursePackageOrder.setStatus(1); coursePackageOrder.setState(1); coursePackageOrder.setInsertTime(new Date()); + coursePackageOrder.setOrderType(1); coursePackageOrderService.save(coursePackageOrder); orderId = coursePackageOrder.getId(); }else{ @@ -1277,10 +1339,10 @@ * @return */ @Override - public ResultUtil paymentCourseCallback(String code, String trade_no, String attach) throws AlipayApiException { + public ResultUtil paymentCourseCallback(String code, String trade_no, String attach) throws Exception { CoursePackageOrder coursePackageOrder1 = coursePackageOrderService.getOne(new QueryWrapper<CoursePackageOrder>() .eq("code", code).eq("state", 1)); - if (coursePackageOrder1.getPayStatus() == 2) { + if (null == coursePackageOrder1 || coursePackageOrder1.getPayStatus() == 2) { return ResultUtil.success(); } coursePackageOrder1.setPayStatus(2); @@ -1290,7 +1352,33 @@ CoursePackagePaymentConfig coursePackagePaymentConfig = coursePackagePaymentConfigService.getById(attach); addCoursePackageOrderStudent(coursePackageOrder1.getId(), coursePackagePaymentConfig); - moneyOut(trade_no,trade_no,code); + TCoursePackage byId = coursePackageService.getById(coursePackageOrder1.getCoursePackageId()); + Store store = storeClient.queryStoreById(byId.getStoreId()); +// moneyOut(trade_no,trade_no,code); + if (store.getOperatorId()!=null && store.getOperatorId()!=0){ + // 休眠两分钟后再调用分账接口 避免提示订单正在处理中 + Thread.sleep(120000); + // 根据运营商id获取对应运营商分账比例 返回格式: 微信分账比例,支付宝分账比例 + String proportionByOperatorId = storeClient.getProportionByOperatorId(store.getOperatorId()); + String[] split = proportionByOperatorId.split(","); + String s1 = split[0]; + if (!s1.equals("未设置")){ + BigDecimal bigDecimal = new BigDecimal(s1); + // 分账比例 + BigDecimal bigDecimal1 = bigDecimal.divide(new BigDecimal(100)).setScale(2); + // 微信商户号 + String s2 = storeClient.getmerchantNumberByOperatorId(store.getOperatorId()); + String nonce_str = UUIDUtil.getRandomCode(16); + ResultUtil fenzhang = payMoneyUtil.fenzhang(trade_no, coursePackageOrder1.getCashPayment().multiply(bigDecimal1), s2,nonce_str); + if (!fenzhang.getCode().equals(200)){ + System.err.println("分账失败 原因是:"+fenzhang.getData().toString()); + }else{ + coursePackageOrder1.setFenzhangNo(fenzhang.getData().toString()); + coursePackageOrder1.setFenzhangOrderNo(nonce_str); + coursePackageOrderService.updateById(coursePackageOrder1); + } + } + } return ResultUtil.success(); } @@ -1300,6 +1388,7 @@ * * @param coursePackagePaymentConfig */ + @Override public void addCoursePackageOrderStudent(Long coursePackageOrderId, CoursePackagePaymentConfig coursePackagePaymentConfig) { CoursePackageOrder coursePackageOrder = coursePackageOrderService.getById(coursePackageOrderId); // 发放优惠券 @@ -1335,19 +1424,22 @@ coursePackageOrderStudentService.saveOrUpdate(coursePackageOrderStudent); //更新学员课时有效期 + boolean b = true; if(null == student.getValidity()){ student.setValidity(calendar.getTime()); addOldPackageStudent(student); + b = false; }else if(calendar.getTimeInMillis() > student.getValidity().getTime()){ student.setValidity(calendar.getTime()); addOldPackageStudent(student); + b = false; } studentClient.frozen(student); //开始排课 - addPackageStudent(coursePackage, coursePackageOrder.getAppUserId(), Integer.valueOf(id), coursePackageOrderStudent, student.getValidity()); - - + if(b){ + addPackageStudent(coursePackage, coursePackageOrder.getAppUserId(), Integer.valueOf(id), coursePackageOrderStudent, student.getValidity()); + } //课时记录 CourseCounsum courseCounsum = new CourseCounsum(); @@ -1355,7 +1447,7 @@ courseCounsum.setChangeType(1); courseCounsum.setNum(coursePackagePaymentConfig.getClassHours()); courseCounsum.setInsertTime(new Date()); - courseCounsum.setReason("购买课包"); + courseCounsum.setReason("报名运动营"); courseCounsumService.save(courseCounsum); //账单记录 if(coursePackageOrder.getPayType() != 3){ @@ -1367,8 +1459,6 @@ courseCounsum1.setAppUserId(coursePackageOrder.getAppUserId()); courseCounsumService.save(courseCounsum1); } - - } else { Date useTime = coursePackageOrderStudent.getUseTime(); coursePackageOrderStudent.setTotalClassHours(coursePackageOrderStudent.getTotalClassHours() + coursePackagePaymentConfig.getClassHours()); @@ -1382,17 +1472,20 @@ coursePackageOrderStudent.setUseTime(calendar.getTime()); coursePackageOrderStudentService.saveOrUpdate(coursePackageOrderStudent); //更新学员课时有效期 + boolean b = true; if(null == student.getValidity()){ student.setValidity(calendar.getTime()); addOldPackageStudent(student); + b = false; }else if(calendar.getTimeInMillis() > student.getValidity().getTime()){ student.setValidity(calendar.getTime()); addOldPackageStudent(student); + b = false; } studentClient.frozen(student); //中间断课,没有连续续费的情况需要重新排课 - if (useTime.compareTo(new Date()) < 0) { + if (useTime.compareTo(new Date()) < 0 && b) { addPackageStudent(coursePackage, coursePackageOrder.getAppUserId(), Integer.valueOf(id), coursePackageOrderStudent, student.getValidity()); } @@ -1414,12 +1507,7 @@ courseCounsum1.setAppUserId(coursePackageOrder.getAppUserId()); courseCounsumService.save(courseCounsum1); } - - } - - - } if(coursePackage.getType() == 2){ addPackageStudent(coursePackage, coursePackageOrder.getAppUserId(), Integer.valueOf(id), null, null); -- Gitblit v1.7.1