From b22f741e6918c675fabe5aabc688d2f52858319a Mon Sep 17 00:00:00 2001
From: jiaosong <jiaosong6760@dingtalk.com>
Date: 星期一, 09 十月 2023 09:46:43 +0800
Subject: [PATCH] #pgsql 退款 结算
---
server/services/src/main/java/com/doumee/dao/business/web/response/PayOrderDTO.java | 9
server/services/src/main/java/com/doumee/service/business/impl/PricingRuleServiceImpl.java | 103 ++++++
server/services/src/main/java/com/doumee/service/business/GoodsorderService.java | 13
server/services/src/main/java/com/doumee/dao/business/web/response/PricingRuleDTO.java | 36 ++
server/services/src/main/java/com/doumee/service/business/PricingRuleService.java | 26 +
server/services/src/main/java/com/doumee/core/utils/DateUtil.java | 7
server/services/src/main/java/com/doumee/core/constants/Constants.java | 532 +++++++++++++++++++-------------
server/platform/src/main/java/com/doumee/api/business/GoodsorderController.java | 3
server/services/src/main/java/com/doumee/dao/business/model/MemberRides.java | 28
server/services/src/main/java/com/doumee/dao/business/model/Refund.java | 2
server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesResponse.java | 4
server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java | 141 ++++++++
server/services/src/main/java/com/doumee/dao/business/web/response/RidesDetailResponse.java | 5
13 files changed, 654 insertions(+), 255 deletions(-)
diff --git a/server/platform/src/main/java/com/doumee/api/business/GoodsorderController.java b/server/platform/src/main/java/com/doumee/api/business/GoodsorderController.java
index d0ffd07..1fa11a5 100644
--- a/server/platform/src/main/java/com/doumee/api/business/GoodsorderController.java
+++ b/server/platform/src/main/java/com/doumee/api/business/GoodsorderController.java
@@ -1,5 +1,6 @@
package com.doumee.api.business;
+import com.doumee.api.BaseController;
import com.doumee.core.annotation.excel.ExcelExporter;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.model.ApiResponse;
@@ -25,7 +26,7 @@
@Api(tags = "璁㈠崟淇℃伅琛�")
@RestController
@RequestMapping("/business/goodsorder")
-public class GoodsorderController {
+public class GoodsorderController extends BaseController {
@Autowired
diff --git a/server/services/src/main/java/com/doumee/core/constants/Constants.java b/server/services/src/main/java/com/doumee/core/constants/Constants.java
index 072f1cb..c0f4808 100644
--- a/server/services/src/main/java/com/doumee/core/constants/Constants.java
+++ b/server/services/src/main/java/com/doumee/core/constants/Constants.java
@@ -18,33 +18,34 @@
public class Constants {
- public static final String DEFAULT_PWD = "DEFAULT_PWD";
- public static final String TRUE = "t";
- public static final String FALSE = "f";
- public static final String TOKEN ="TOKEN" ;
- public static final String SYSTEM ="SYSTEM" ;
- public static final String MINI_PROGRAMME ="MINI_PROGRAMME" ;
- public static final String IMG_DIR = "IMG_DIR";
- public static final String FILE_DIR ="FILE_DIR" ;
- public static final String PRIVATE_KEY = "PRIVATE_KEY";
- public static String REDIS_DEBUG_STR="test_";
+ public static final String DEFAULT_PWD = "DEFAULT_PWD";
+ public static final String TRUE = "t";
+ public static final String FALSE = "f";
+ public static final String TOKEN = "TOKEN";
+ public static final String SYSTEM = "SYSTEM";
+ public static final String MINI_PROGRAMME = "MINI_PROGRAMME";
+ public static final String IMG_DIR = "IMG_DIR";
+ public static final String FILE_DIR = "FILE_DIR";
+ public static final String PRIVATE_KEY = "PRIVATE_KEY";
+ public static String REDIS_DEBUG_STR = "test_";
- /**
- * 鏁版嵁鏉冮檺鑼冨洿锛�0鍙湅鑷繁锛�1鍙湅鑷繁鎵�鍦ㄦ牎鍖猴紱2鐪嬪叏閮ㄦ牎鍖猴紱3鐪嬫寚瀹氭牎鍖猴紙澶氶�夛級
- */
- public interface PermissionType{
- int self =0;
- int self_campus =1;
- int all =2;
- int partful = 3;
- }
- public interface goodsorderStatus{
- int waitPay =0;
- int pay =1;
- int cancel =2;
- int fail = 3;
- int over = 4;
- }
+ /**
+ * 鏁版嵁鏉冮檺鑼冨洿锛�0鍙湅鑷繁锛�1鍙湅鑷繁鎵�鍦ㄦ牎鍖猴紱2鐪嬪叏閮ㄦ牎鍖猴紱3鐪嬫寚瀹氭牎鍖猴紙澶氶�夛級
+ */
+ public interface PermissionType {
+ int self = 0;
+ int self_campus = 1;
+ int all = 2;
+ int partful = 3;
+ }
+
+ public interface goodsorderStatus {
+ int waitPay = 0;
+ int pay = 1;
+ int cancel = 2;
+ int fail = 3;
+ int over = 4;
+ }
public interface goodsorderPayStatus{
int waitPay =0;
int pay =1;
@@ -54,219 +55,316 @@
public static String getUUID(){
return UUID.randomUUID().toString().replace("-","");
}
- public interface RedisKeys {
- public static final String submission_period_key = "sp_";
- }
-
-
- public static final String ACCESS_ID="ACCESS_ID";
-
- public static final String BUCKETNAME = "BUCKETNAME";
-
- public static final String OSS = "OSS";
-
- public static final String ACCESS_KEY = "ACCESS_KEY";
-
- public static final String SCRATCH_REDIRECT = "SCRATCH_REDIRECT";
-
- public static final String ENDPOINT = "ENDPOINT";
-
- public static final String TESTCASE_UPLOAD_PATH = "TESTCASE_UPLOAD_PATH";
-
- public static final String RESOURCE_PATH = "RESOURCE_PATH";
- public static final String UPLOAD_FILE = "UPLOAD_FILE";
- public static final String AVATAR_FILE = "AVATAR_FILE";
- //鐢ㄦ埛鍗忚
- public static final String AGREEMENT = "AGREEMENT";
- //璁′环瑙勫垯
- public static final String PRICING_RULE = "PRICING_RULE";
- //灏忕▼搴忎富棰樺悕绉�
- public static final String PROJECT_NAME = "PROJECT_NAME";
- //灏忕▼搴忔湇鍔＄鐢佃瘽
- public static final String SERVER_PHONE = "SERVER_PHONE";
- //灏忕▼搴忕璧佹祦绋嬭棰�
- public static final String RENT_TIPS_VIDEO = "RENT_TIPS_VIDEO";
- //绉熻祦椤荤煡
- public static final String LEASE_NOTICE = "LEASE_NOTICE";
- //绉熻祦椤荤煡鍥剧墖
- public static final String LEASE_NOTICE_URL = "LEASE_NOTICE_URL";
- //鎶奸噾
- public static final String RENT_DEPOSIT = "RENT_DEPOSIT";
- //娓╅Θ鎻愮ず
- public static final String TIPS = "TIPS";
-
-
-
-
-
-
- public static final String FILES_DIR = "FILES_DIR";
- public static final String SCRATCH_REDIRECT_URL = "SCRATCH_REDIRECT_URL";
- public static final Integer ZERO = 0 ;
- public static final Integer ONE = 1 ;
- public static final Integer TWO = 2 ;
- public static final Integer THREE = 3 ;
-
- public static int formatIntegerNum(Integer num){
- if(num == null){
- return 0;
- }
- return num;
- }
-
- public interface UserActionsType{
- String cancelPrePay="CANCEL_PRE_PAY";
-
- //璁㈠崟缁撶畻璁㈠崟
- String close="CLOSE";
- String forceRefund="FORCE_REFUND";
- String login="LOGIN";
- String pay="PAY";
- String preForceRefund="PRE_FORCE_REFUND";
- String prePay="PRE_PAY";
- String preRefund="PRE_REFUND";
- String refund="REFUND";
- String register="REGISTER";
- String rent="RENT";
- }
- public static BigDecimal formatDecimalNum(BigDecimal num){
- if(num == null){
- return new BigDecimal(0);
- }
- return num;
- }
- public static int compareBigdecimal(BigDecimal num,BigDecimal num2){
- if(num == null){
- num =new BigDecimal(0);
- }
- if(num2 == null){
- num2 =new BigDecimal(0);
- }
- if (num.compareTo(num2) == 1) {
- return 1;
- } else if (num.compareTo(num2)== -1) {
- return -1;
- }
- return 0;
- }
-
- public static long formatLongNum(Long num){
- if(num == null){
- return 0;
- }
- return num;
- }
- public static String formatImgPath(String avatar, String imgPath) {
- if(StringUtils.isBlank(avatar)){
- return null;
- }
- return imgPath+avatar;
- }
- public static String getIpAddr(HttpServletRequest request) {
- String ipAddress = request.getHeader("x-forwarded-for");
- if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
- ipAddress = request.getHeader("Proxy-Client-IP");
+ public interface RedisKeys {
+ public static final String submission_period_key = "sp_";
}
- if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
- ipAddress = request.getHeader("WL-Proxy-Client-IP");
+
+
+ public static final String ACCESS_ID = "ACCESS_ID";
+
+ public static final String BUCKETNAME = "BUCKETNAME";
+
+ public static final String OSS = "OSS";
+
+ public static final String ACCESS_KEY = "ACCESS_KEY";
+
+ public static final String SCRATCH_REDIRECT = "SCRATCH_REDIRECT";
+
+ public static final String ENDPOINT = "ENDPOINT";
+
+ public static final String TESTCASE_UPLOAD_PATH = "TESTCASE_UPLOAD_PATH";
+
+ public static final String RESOURCE_PATH = "RESOURCE_PATH";
+ public static final String UPLOAD_FILE = "UPLOAD_FILE";
+ public static final String AVATAR_FILE = "AVATAR_FILE";
+ //鐢ㄦ埛鍗忚
+ public static final String AGREEMENT = "AGREEMENT";
+ //璁′环瑙勫垯
+ public static final String PRICING_RULE = "PRICING_RULE";
+ //灏忕▼搴忎富棰樺悕绉�
+ public static final String PROJECT_NAME = "PROJECT_NAME";
+ //灏忕▼搴忔湇鍔＄鐢佃瘽
+ public static final String SERVER_PHONE = "SERVER_PHONE";
+ //灏忕▼搴忕璧佹祦绋嬭棰�
+ public static final String RENT_TIPS_VIDEO = "RENT_TIPS_VIDEO";
+ //绉熻祦椤荤煡
+ public static final String LEASE_NOTICE = "LEASE_NOTICE";
+ //绉熻祦椤荤煡鍥剧墖
+ public static final String LEASE_NOTICE_URL = "LEASE_NOTICE_URL";
+ //鎶奸噾
+ public static final String RENT_DEPOSIT = "RENT_DEPOSIT";
+ //娓╅Θ鎻愮ず
+ public static final String TIPS = "TIPS";
+
+
+ public static final String FILES_DIR = "FILES_DIR";
+ public static final String SCRATCH_REDIRECT_URL = "SCRATCH_REDIRECT_URL";
+ public static final Integer ZERO = 0;
+ public static final Integer ONE = 1;
+ public static final Integer TWO = 2;
+ public static final Integer THREE = 3;
+
+ public static int formatIntegerNum(Integer num) {
+ if (num == null) {
+ return 0;
+ }
+ return num;
}
- if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
- ipAddress = request.getRemoteAddr();
- String localIp = "127.0.0.1";
- String localIpv6 = "0:0:0:0:0:0:0:1";
- if (ipAddress.equals(localIp) || ipAddress.equals(localIpv6)) {
- // 鏍规嵁缃戝崱鍙栨湰鏈洪厤缃殑IP
- InetAddress inet = null;
- try {
- inet = InetAddress.getLocalHost();
- ipAddress = inet.getHostAddress();
- } catch (UnknownHostException e) {
- e.printStackTrace();
+
+ public interface UserActionsType {
+ String cancelPrePay = "CANCEL_PRE_PAY";
+
+ //璁㈠崟缁撶畻璁㈠崟
+ String close = "CLOSE";
+ String forceRefund = "FORCE_REFUND";
+ String login = "LOGIN";
+ String pay = "PAY";
+ String preForceRefund = "PRE_FORCE_REFUND";
+ String prePay = "PRE_PAY";
+ String preRefund = "PRE_REFUND";
+ String refund = "REFUND";
+ String register = "REGISTER";
+ String rent = "RENT";
+ }
+
+ public enum GOODSORDER_STATUS{
+ // 0寰呮敮浠� 1宸叉敮浠� 2宸插彇娑� 3鏀粯澶辫触 4宸茬粨绠�
+ UN_PAY("寰呮敮浠�", 0,"寰呮敮浠�"),
+
+ HAVING_PAY("宸叉敮浠�", 1,"宸叉敮浠�"),
+
+ CANCEL("宸插彇娑�", 2,"宸插彇娑�"),
+
+ PAY_FAILURE("鏀粯澶辫触", 3,"鏀粯澶辫触"),
+
+ CLOSE("宸茬粨绠�", 4,"宸茬粨绠�"),
+ ;
+ String name;
+
+ Integer key;
+
+ String info;
+
+ GOODSORDER_STATUS(String name, Integer key, String info) {
+ this.name = name;
+ this.key = key;
+ this.info = info;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public Integer getKey() {
+ return key;
+ }
+
+ public void setKey(Integer key) {
+ this.key = key;
+ }
+
+ public String getInfo() {
+ return info;
+ }
+
+ public void setInfo(String info) {
+ this.info = info;
+ }
+ }
+
+ public enum MEMBER_RIDES_STATUS{
+// 0璇锋眰寮�閿佷腑 1楠戣涓� 2宸茶繕杞� 3寮�閿佸け璐�
+ LOCKING("璇锋眰寮�閿佷腑", 0,"璇锋眰寮�閿佷腑"),
+
+ RIDES_RUNNING("楠戣涓�", 1,"楠戣涓�"),
+
+ BACK_CYCLING("宸茶繕杞�", 2,"宸茶繕杞�"),
+
+ LOCKING_DEFEAT("寮�閿佸け璐�", 3,"寮�閿佸け璐�")
+ ;
+ String name;
+
+ Integer key;
+
+ String info;
+
+ MEMBER_RIDES_STATUS(String name, Integer key, String info) {
+ this.name = name;
+ this.key = key;
+ this.info = info;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public Integer getKey() {
+ return key;
+ }
+
+ public void setKey(Integer key) {
+ this.key = key;
+ }
+
+ public String getInfo() {
+ return info;
+ }
+
+ public void setInfo(String info) {
+ this.info = info;
+ }
+ }
+
+ public static BigDecimal formatDecimalNum(BigDecimal num) {
+ if (num == null) {
+ return new BigDecimal(0);
+ }
+ return num;
+ }
+
+ public static int compareBigdecimal(BigDecimal num, BigDecimal num2) {
+ if (num == null) {
+ num = new BigDecimal(0);
+ }
+ if (num2 == null) {
+ num2 = new BigDecimal(0);
+ }
+ if (num.compareTo(num2) == 1) {
+ return 1;
+ } else if (num.compareTo(num2) == -1) {
+ return -1;
+ }
+ return 0;
+ }
+
+ public static long formatLongNum(Long num) {
+ if (num == null) {
+ return 0;
+ }
+ return num;
+ }
+
+ public static String formatImgPath(String avatar, String imgPath) {
+ if (StringUtils.isBlank(avatar)) {
+ return null;
+ }
+ return imgPath + avatar;
+ }
+
+ public static String getIpAddr(HttpServletRequest request) {
+ String ipAddress = request.getHeader("x-forwarded-for");
+ if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
+ ipAddress = request.getHeader("Proxy-Client-IP");
+ }
+ if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
+ ipAddress = request.getHeader("WL-Proxy-Client-IP");
+ }
+ if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
+ ipAddress = request.getRemoteAddr();
+ String localIp = "127.0.0.1";
+ String localIpv6 = "0:0:0:0:0:0:0:1";
+ if (ipAddress.equals(localIp) || ipAddress.equals(localIpv6)) {
+ // 鏍规嵁缃戝崱鍙栨湰鏈洪厤缃殑IP
+ InetAddress inet = null;
+ try {
+ inet = InetAddress.getLocalHost();
+ ipAddress = inet.getHostAddress();
+ } catch (UnknownHostException e) {
+ e.printStackTrace();
+ }
}
}
- }
- // 瀵逛簬閫氳繃澶氫釜浠ｇ悊鐨勬儏鍐碉紝绗竴涓狪P涓哄鎴风鐪熷疄IP,澶氫釜IP鎸夌収','鍒嗗壊
- String ipSeparate = ",";
- int ipLength = 15;
- if (ipAddress != null && ipAddress.length() > ipLength) {
- if (ipAddress.indexOf(ipSeparate) > 0) {
- ipAddress = ipAddress.substring(0, ipAddress.indexOf(ipSeparate));
+ // 瀵逛簬閫氳繃澶氫釜浠ｇ悊鐨勬儏鍐碉紝绗竴涓狪P涓哄鎴风鐪熷疄IP,澶氫釜IP鎸夌収','鍒嗗壊
+ String ipSeparate = ",";
+ int ipLength = 15;
+ if (ipAddress != null && ipAddress.length() > ipLength) {
+ if (ipAddress.indexOf(ipSeparate) > 0) {
+ ipAddress = ipAddress.substring(0, ipAddress.indexOf(ipSeparate));
+ }
}
+ return ipAddress;
}
- return ipAddress;
- }
- public static String getSHA256Str(String str) {
- MessageDigest messageDigest;
- String encdeStr = "";
- try {
- messageDigest = MessageDigest.getInstance("SHA-256");
- byte[] hash = messageDigest.digest(str.getBytes("UTF-8"));
- encdeStr = Hex.encodeHexString(hash);
- } catch (NoSuchAlgorithmException e) {
- e.printStackTrace();
- } catch (UnsupportedEncodingException e) {
- e.printStackTrace();
- }
- return encdeStr;
- }
- public static String trimEndSpaceStr(String outPut){
- String newOutPut = "";
- if(StringUtils.isNotBlank(outPut)){
- String[] ostrs = outPut.split("\n");
- for(String str : ostrs){
- String text = str.replace("\n","").replaceAll("\\s+$", "");
- newOutPut += text+"\n";
-
+ public static String getSHA256Str(String str) {
+ MessageDigest messageDigest;
+ String encdeStr = "";
+ try {
+ messageDigest = MessageDigest.getInstance("SHA-256");
+ byte[] hash = messageDigest.digest(str.getBytes("UTF-8"));
+ encdeStr = Hex.encodeHexString(hash);
+ } catch (NoSuchAlgorithmException e) {
+ e.printStackTrace();
+ } catch (UnsupportedEncodingException e) {
+ e.printStackTrace();
}
- if(newOutPut.endsWith("\n")){
- newOutPut = newOutPut.substring(0,newOutPut.length()-1);
+ return encdeStr;
+ }
+
+ public static String trimEndSpaceStr(String outPut) {
+ String newOutPut = "";
+ if (StringUtils.isNotBlank(outPut)) {
+ String[] ostrs = outPut.split("\n");
+ for (String str : ostrs) {
+ String text = str.replace("\n", "").replaceAll("\\s+$", "");
+ newOutPut += text + "\n";
+
+ }
+ if (newOutPut.endsWith("\n")) {
+ newOutPut = newOutPut.substring(0, newOutPut.length() - 1);
+ }
}
+ return newOutPut;
}
- return newOutPut;
- }
- public static String delHTMLTag(String htmlStr) {
- if (StringUtils.isBlank(htmlStr)) {
- return "";
+ public static String delHTMLTag(String htmlStr) {
+ if (StringUtils.isBlank(htmlStr)) {
+ return "";
+ }
+ String regEx_script = "<script[^>]*?>[\\s\\S]*?<\\/script>"; // 瀹氫箟script鐨勬鍒欒〃杈惧紡
+ String regEx_style = "<style[^>]*?>[\\s\\S]*?<\\/style>"; // 瀹氫箟style鐨勬鍒欒〃杈惧紡
+ String regEx_html = "<[^>]+>"; // 瀹氫箟HTML鏍囩鐨勬鍒欒〃杈惧紡
+
+ Pattern p_script = Pattern.compile(regEx_script, Pattern.CASE_INSENSITIVE);
+ Matcher m_script = p_script.matcher(htmlStr);
+ htmlStr = m_script.replaceAll(""); // 杩囨护script鏍囩
+
+ Pattern p_style = Pattern.compile(regEx_style, Pattern.CASE_INSENSITIVE);
+ Matcher m_style = p_style.matcher(htmlStr);
+ htmlStr = m_style.replaceAll(""); // 杩囨护style鏍囩
+
+ Pattern p_html = Pattern.compile(regEx_html, Pattern.CASE_INSENSITIVE);
+ Matcher m_html = p_html.matcher(htmlStr);
+ htmlStr = m_html.replaceAll(""); // 杩囨护html鏍囩
+
+ htmlStr = htmlStr.replace(" ", " "); // 杩囨护绌烘牸鏍囩
+ htmlStr = htmlStr.replace(" ", " "); // 杩囨护绌烘牸鏍囩
+
+ return htmlStr.trim(); // 杩斿洖鏂囨湰瀛楃涓�
}
- String regEx_script = "<script[^>]*?>[\\s\\S]*?<\\/script>"; // 瀹氫箟script鐨勬鍒欒〃杈惧紡
- String regEx_style = "<style[^>]*?>[\\s\\S]*?<\\/style>"; // 瀹氫箟style鐨勬鍒欒〃杈惧紡
- String regEx_html = "<[^>]+>"; // 瀹氫箟HTML鏍囩鐨勬鍒欒〃杈惧紡
-
- Pattern p_script = Pattern.compile(regEx_script, Pattern.CASE_INSENSITIVE);
- Matcher m_script = p_script.matcher(htmlStr);
- htmlStr = m_script.replaceAll(""); // 杩囨护script鏍囩
-
- Pattern p_style = Pattern.compile(regEx_style, Pattern.CASE_INSENSITIVE);
- Matcher m_style = p_style.matcher(htmlStr);
- htmlStr = m_style.replaceAll(""); // 杩囨护style鏍囩
-
- Pattern p_html = Pattern.compile(regEx_html, Pattern.CASE_INSENSITIVE);
- Matcher m_html = p_html.matcher(htmlStr);
- htmlStr = m_html.replaceAll(""); // 杩囨护html鏍囩
-
- htmlStr = htmlStr.replace(" "," "); // 杩囨护绌烘牸鏍囩
- htmlStr = htmlStr.replace(" "," "); // 杩囨护绌烘牸鏍囩
-
- return htmlStr.trim(); // 杩斿洖鏂囨湰瀛楃涓�
- }
- public static List<String> checkUUID(String checkValue){
- String [] str = checkValue.split(",");
+ public static List<String> checkUUID(String checkValue) {
+ String[] str = checkValue.split(",");
List<String> strList = new ArrayList<>();
- for (String s:str) {
- try{
+ for (String s : str) {
+ try {
String uuid = UUID.fromString(s).toString();
strList.add(uuid);
//do something
- } catch (IllegalArgumentException exception){
+ } catch (IllegalArgumentException exception) {
continue;
}
}
return strList;
- }
+ }
}
diff --git a/server/services/src/main/java/com/doumee/core/utils/DateUtil.java b/server/services/src/main/java/com/doumee/core/utils/DateUtil.java
index d51d0f6..88f215a 100644
--- a/server/services/src/main/java/com/doumee/core/utils/DateUtil.java
+++ b/server/services/src/main/java/com/doumee/core/utils/DateUtil.java
@@ -10,7 +10,6 @@
import java.text.DateFormatSymbols;
import java.text.ParseException;
import java.text.SimpleDateFormat;
-import java.time.Duration;
import java.util.Date;
import java.util.*;
@@ -3011,11 +3010,11 @@
* @param end
* @return
*/
- public static long betweenMin(Date begin, Date end) {
+ public static Integer betweenMin(Date begin, Date end) {
long createTime =begin.getTime();//鑾峰彇鍒涘缓鏃堕棿鐨勬椂闂存埑
long currentTime =Objects.isNull(end)?System.currentTimeMillis():end.getTime();//鑾峰彇褰撳墠鏃堕棿鐨勬椂闂存埑
long diff=(currentTime-createTime)/1000/60;//鑾峰彇涓や釜鏃堕棿鐩稿樊鐨勫垎閽�
- return diff;
+ return (int)diff;
}
@@ -3038,4 +3037,4 @@
return consuming.toString();
}
-}
\ No newline at end of file
+}
diff --git a/server/services/src/main/java/com/doumee/dao/business/model/MemberRides.java b/server/services/src/main/java/com/doumee/dao/business/model/MemberRides.java
index 427a040..dd62879 100644
--- a/server/services/src/main/java/com/doumee/dao/business/model/MemberRides.java
+++ b/server/services/src/main/java/com/doumee/dao/business/model/MemberRides.java
@@ -41,7 +41,7 @@
@ExcelColumn(name="缂栬緫浜�")
private String editor;
- @ApiModelProperty(value = "鏄惁宸插垹闄� 0鏈垹闄� 1宸插垹闄�", example = "1")
+ @ApiModelProperty(value = "鏄惁宸插垹闄� 0鏈垹闄� 1宸插垹闄�")
@ExcelColumn(name="鏄惁宸插垹闄� 0鏈垹闄� 1宸插垹闄�")
@TableLogic
private Integer isdeleted;
@@ -64,7 +64,7 @@
@ExcelColumn(name="杞﹁締缂栫爜")
private String bikeCode;
- @ApiModelProperty(value = "褰撳墠璐︽埛浣欓", example = "1")
+ @ApiModelProperty(value = "褰撳墠璐︽埛浣欓")
@ExcelColumn(name="褰撳墠璐︽埛浣欓")
private BigDecimal balance;
@@ -111,31 +111,31 @@
@ExcelColumn(name="杩樿溅鎸囦护缂栫爜")
private String backCommondId;
- @ApiModelProperty(value = "璧锋浠�", example = "1")
+ @ApiModelProperty(value = "璧锋浠�")
@ExcelColumn(name="璧锋浠�")
private BigDecimal basePrice;
- @ApiModelProperty(value = "璧锋浠锋椂闂�", example = "1")
+ @ApiModelProperty(value = "璧锋浠锋椂闂�")
@ExcelColumn(name="璧锋浠锋椂闂�")
private Integer baseTime;
- @ApiModelProperty(value = "瓒呭嚭鍗曚环", example = "1")
+ @ApiModelProperty(value = "瓒呭嚭鍗曚环")
@ExcelColumn(name="瓒呭嚭鍗曚环")
- private Integer unitPrice;
+ private BigDecimal unitPrice;
- @ApiModelProperty(value = "瓒呭嚭鏃堕棿鍗曚綅", example = "1")
+ @ApiModelProperty(value = "瓒呭嚭鏃堕棿鍗曚綅")
@ExcelColumn(name="瓒呭嚭鏃堕棿鍗曚綅")
private Integer unitTime;
- @ApiModelProperty(value = "楠戣浠锋牸", example = "1")
+ @ApiModelProperty(value = "楠戣浠锋牸")
@ExcelColumn(name="楠戣浠锋牸")
private BigDecimal price;
- @ApiModelProperty(value = "楠戣瀹為檯浠锋牸", example = "1")
+ @ApiModelProperty(value = "楠戣瀹為檯浠锋牸")
@ExcelColumn(name="楠戣瀹為檯浠锋牸")
private BigDecimal actualPrice;
- @ApiModelProperty(value = "楠戣璁¤垂鏃堕暱", example = "1")
+ @ApiModelProperty(value = "楠戣璁¤垂鏃堕暱")
@ExcelColumn(name="楠戣璁¤垂鏃堕暱")
private Integer duration;
@@ -144,7 +144,7 @@
//@JsonFormat(pattern = "yyyy-MM-dd")
private Date closeDate;
- @ApiModelProperty(value = "缁撶畻鐘舵�� 0鏈粨绠� 1宸茬粨鏉�", example = "1")
+ @ApiModelProperty(value = "缁撶畻鐘舵�� 0鏈粨绠� 1宸茬粨鏉�")
@ExcelColumn(name="缁撶畻鐘舵�� 0鏈粨绠� 1宸茬粨鏉�")
private Integer closeStatus;
@@ -152,7 +152,7 @@
@ExcelColumn(name="鍏宠仈璁㈠崟缂栫爜(鍏宠仈goodsorder锛�")
private String ordreId;
- @ApiModelProperty(value = "鏄惁缁撶畻璁¤垂杞﹀瀷 0鍚� 1鏄�", example = "1")
+ @ApiModelProperty(value = "鏄惁缁撶畻璁¤垂杞﹀瀷 0鍚� 1鏄�")
@ExcelColumn(name="鏄惁缁撶畻璁¤垂杞﹀瀷 0鍚� 1鏄�")
private Integer isStandard;
@@ -164,11 +164,11 @@
@ExcelColumn(name="鏄惁鑺傚亣鏃� 0涓嶆槸 1鏄�")
private String isHoliday;
- @ApiModelProperty(value = "鐘舵�� 0璇锋眰寮�閿佷腑 1楠戣涓� 2宸茶繕杞� 3寮�閿佸け璐�", example = "1")
+ @ApiModelProperty(value = "鐘舵�� 0璇锋眰寮�閿佷腑 1楠戣涓� 2宸茶繕杞� 3寮�閿佸け璐�")
@ExcelColumn(name="鐘舵�� 0璇锋眰寮�閿佷腑 1楠戣涓� 2宸茶繕杞� 3寮�閿佸け璐�")
private Integer status;
- @ApiModelProperty(value = "杩樿溅绫诲瀷 0姝ｅ父杩樿溅 1寮哄埗杩樿溅", example = "1")
+ @ApiModelProperty(value = "杩樿溅绫诲瀷 0姝ｅ父杩樿溅 1寮哄埗杩樿溅")
@ExcelColumn(name="杩樿溅绫诲瀷 0姝ｅ父杩樿溅 1寮哄埗杩樿溅")
private Integer backType;
diff --git a/server/services/src/main/java/com/doumee/dao/business/model/Refund.java b/server/services/src/main/java/com/doumee/dao/business/model/Refund.java
index f19d889..c328599 100644
--- a/server/services/src/main/java/com/doumee/dao/business/model/Refund.java
+++ b/server/services/src/main/java/com/doumee/dao/business/model/Refund.java
@@ -59,7 +59,7 @@
@ApiModelProperty(value = "鐢ㄦ埛缂栫爜锛堝叧鑱攎ember琛級", example = "1")
@ExcelColumn(name="鐢ㄦ埛缂栫爜锛堝叧鑱攎ember琛級")
- private BigDecimal memberId;
+ private String memberId;
@ApiModelProperty(value = "浜ゆ槗閲戦", example = "1")
@ExcelColumn(name="浜ゆ槗閲戦")
diff --git a/server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesResponse.java b/server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesResponse.java
index 83fc050..6d4d589 100644
--- a/server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesResponse.java
+++ b/server/services/src/main/java/com/doumee/dao/business/web/response/MemberRidesResponse.java
@@ -30,10 +30,10 @@
private Date rideEndTime;
@ApiModelProperty(value = "楠戣鏃堕暱")
- private long rideTime;
+ private Integer rideTime;
@ApiModelProperty(value = "璁¤垂鏃堕暱")
- private long duration;
+ private Integer duration;
@ApiModelProperty(value = "杞﹀瀷")
private String bikeType;
diff --git a/server/services/src/main/java/com/doumee/dao/business/web/response/PayOrderDTO.java b/server/services/src/main/java/com/doumee/dao/business/web/response/PayOrderDTO.java
index 940dfed..928a5ef 100644
--- a/server/services/src/main/java/com/doumee/dao/business/web/response/PayOrderDTO.java
+++ b/server/services/src/main/java/com/doumee/dao/business/web/response/PayOrderDTO.java
@@ -1,6 +1,8 @@
package com.doumee.dao.business.web.response;
+import com.doumee.core.annotation.excel.ExcelColumn;
import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.math.BigDecimal;
@@ -13,14 +15,19 @@
@ApiModel("浜ゆ槗鏄庣粏")
public class PayOrderDTO {
+ @ApiModelProperty(value = "璁㈠崟缂栫爜")
private String orderCode;
- private Integer payType;
+ @ApiModelProperty(value = "鏀粯鏂瑰紡 0寰俊 1鏀粯瀹�")
+ private Integer payWay;
+ @ApiModelProperty(value = "閫�娆剧被鍨� 0缁撶畻閫�娆� 1寮哄埗缁撶畻閫�娆� 2缁撶畻鍚庨��娆�")
private Integer refundType;
+ @ApiModelProperty(value = "浜ゆ槗閲戦")
private BigDecimal money;
+ @ApiModelProperty(value = "鏀粯鏃堕棿")
private Date payDate;
}
diff --git a/server/services/src/main/java/com/doumee/dao/business/web/response/PricingRuleDTO.java b/server/services/src/main/java/com/doumee/dao/business/web/response/PricingRuleDTO.java
new file mode 100644
index 0000000..b249a65
--- /dev/null
+++ b/server/services/src/main/java/com/doumee/dao/business/web/response/PricingRuleDTO.java
@@ -0,0 +1,36 @@
+package com.doumee.dao.business.web.response;
+
+import com.doumee.dao.business.model.MemberRides;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ *
+ * 璁′环瑙勫垯
+ * @author T14
+ */
+@Data
+@ApiModel("璁′环瑙勫垯")
+public class PricingRuleDTO {
+
+ @ApiModelProperty(value = "璧锋鍗曚环")
+ private BigDecimal startFare;
+
+ @ApiModelProperty(value = "鍗曚环")
+ private BigDecimal price;
+
+ @ApiModelProperty(value = "璁′环鏂瑰紡 1:涓�鍙ｄ环 2:闃舵瀹氫环")
+ private Integer type;
+
+ @ApiModelProperty(value = "杞﹁締绫诲瀷")
+ private String paramId;
+
+ @ApiModelProperty(value = "杞﹀瀷鍚嶇О")
+ private String bikeType;
+
+ @ApiModelProperty(value = "璁′环鍓湰")
+ private MemberRides memberRides;
+}
diff --git a/server/services/src/main/java/com/doumee/dao/business/web/response/RidesDetailResponse.java b/server/services/src/main/java/com/doumee/dao/business/web/response/RidesDetailResponse.java
index 8520aef..38fb132 100644
--- a/server/services/src/main/java/com/doumee/dao/business/web/response/RidesDetailResponse.java
+++ b/server/services/src/main/java/com/doumee/dao/business/web/response/RidesDetailResponse.java
@@ -1,5 +1,6 @@
package com.doumee.dao.business.web.response;
+import com.doumee.dao.business.model.BaseParam;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
@@ -20,13 +21,13 @@
public class RidesDetailResponse {
@ApiModelProperty(value = "棰勮娑堣垂閲戦")
- private long amount;
+ private BigDecimal amount;
@ApiModelProperty(value = "杞﹀瀷")
private String bikeType;
@ApiModelProperty(value = "璁¤垂鏃堕暱")
- private long duration;
+ private Integer duration;
@ApiModelProperty(value = "楠戣璁板綍")
private List<MemberRidesResponse> memberRidesResponseList;
diff --git a/server/services/src/main/java/com/doumee/service/business/GoodsorderService.java b/server/services/src/main/java/com/doumee/service/business/GoodsorderService.java
index c599567..66d6a1d 100644
--- a/server/services/src/main/java/com/doumee/service/business/GoodsorderService.java
+++ b/server/services/src/main/java/com/doumee/service/business/GoodsorderService.java
@@ -7,6 +7,7 @@
import com.doumee.dao.business.model.Goodsorder;
import com.doumee.dao.business.web.response.HomeResponse;
import com.doumee.dao.business.web.response.GoodsorderDetailDTO;
+import com.doumee.dao.business.web.response.RidesDetailResponse;
import java.util.List;
@@ -116,6 +117,7 @@
*/
Object createGoodsOrderPay(String memberId);
+
/**
* 鎶奸噾鏀粯鍥炶皟涓氬姟
* @param preOrderId
@@ -137,5 +139,14 @@
* @param id
* @return
*/
- Goodsorder closerGoodsorder(String id);
+ void closerGoodsorder(String id);
+
+
+
+ /**
+ * 鎶奸噾鏀粯涓氬姟
+ * @param id
+ * @return
+ */
+ RidesDetailResponse getRidesDetailResponse(String id);
}
diff --git a/server/services/src/main/java/com/doumee/service/business/PricingRuleService.java b/server/services/src/main/java/com/doumee/service/business/PricingRuleService.java
new file mode 100644
index 0000000..3cfab59
--- /dev/null
+++ b/server/services/src/main/java/com/doumee/service/business/PricingRuleService.java
@@ -0,0 +1,26 @@
+package com.doumee.service.business;
+
+import com.doumee.dao.business.model.MemberRides;
+import com.doumee.dao.business.web.response.PricingRuleDTO;
+
+import java.util.List;
+
+/**
+ *
+ * 鑾峰彇璁′环瑙勫垯
+ * @author T14
+ */
+public interface PricingRuleService {
+
+
+ /**
+ * 鑾峰彇鑾峰彇璁′环瑙勫垯
+ * @param goodaorderId
+ * @return
+ */
+ PricingRuleDTO getPricingRule(String goodaorderId);
+
+
+ PricingRuleDTO getPricingRule(List<MemberRides> memberRidesList);
+
+}
diff --git a/server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
index 888b31f..4a7c2cf 100644
--- a/server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
+++ b/server/services/src/main/java/com/doumee/service/business/impl/GoodsorderServiceImpl.java
@@ -9,6 +9,7 @@
import com.doumee.core.constants.Constants;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
+import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.DateUtil;
@@ -22,19 +23,18 @@
import com.doumee.dao.business.model.Goodsorder;
import com.doumee.dao.business.model.Member;
import com.doumee.dao.business.model.MemberRides;
-import com.doumee.dao.business.web.response.HomeResponse;
+import com.doumee.dao.business.web.response.*;
import com.doumee.dao.business.join.MemberRidesJoinMapper;
import com.doumee.dao.business.model.*;
-import com.doumee.dao.business.web.response.GoodsorderDetailDTO;
-import com.doumee.dao.business.web.response.MemberRidesResponse;
-import com.doumee.dao.business.web.response.PayOrderDTO;
import com.doumee.service.business.GoodsorderService;
+import com.doumee.service.business.PricingRuleService;
import com.github.binarywang.wxpay.bean.notify.WxPayNotifyResponse;
import com.github.binarywang.wxpay.bean.request.BaseWxPayRequest;
import com.github.binarywang.wxpay.bean.request.WxPayUnifiedOrderRequest;
import com.github.binarywang.wxpay.exception.WxPayException;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import org.apache.commons.lang3.StringUtils;
+import org.apache.shiro.SecurityUtils;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -51,6 +51,7 @@
import java.util.Date;
import java.util.List;
import java.util.Objects;
+import java.util.stream.Collectors;
@Service
public class GoodsorderServiceImpl implements GoodsorderService {
@@ -74,14 +75,14 @@
@Autowired
private BaseParamMapper baseParamMapper;
-
-
-
@Autowired
private RefundMapper refundMapper;
@Autowired
private MemberRidesJoinMapper memberRidesJoinMapper;
+
+ @Autowired
+ PricingRuleService pricingRuleService;
@Override
public String create(Goodsorder goodsorder) {
@@ -237,7 +238,7 @@
PayOrderDTO payOrderDTO = new PayOrderDTO();
payOrderDTO.setOrderCode(goodsorder.getCode());
- payOrderDTO.setPayType(goodsorder.getPayWay());
+ payOrderDTO.setPayWay(goodsorder.getPayWay());
payOrderDTO.setMoney(goodsorder.getMoney());
payOrderDTO.setPayDate(goodsorder.getPayDate());
payOrderDTOList.add(0,payOrderDTO);
@@ -245,7 +246,8 @@
refunds.forEach(s->{
PayOrderDTO refundOrderDTO = new PayOrderDTO();
refundOrderDTO.setOrderCode(s.getCode());
- refundOrderDTO.setPayType(s.getPayWay());
+ refundOrderDTO.setPayWay(s.getPayWay());
+ refundOrderDTO.setRefundType(s.getType());
refundOrderDTO.setMoney(s.getMoney());
refundOrderDTO.setPayDate(s.getDoneDate());
payOrderDTOList.add(refundOrderDTO);
@@ -262,17 +264,132 @@
}
@Override
- public Goodsorder closerGoodsorder(String id) {
+ public void closerGoodsorder(String id) {
+
+ LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
Goodsorder goodsorder = goodsorderMapper.selectById(id);
+ QueryWrapper<MemberRides> wrapper = new QueryWrapper<>();
+ wrapper.lambda()
+ .eq(MemberRides::getOrdreId,id);
+ List<MemberRides> memberRides = memberRidesMapper.selectList(wrapper);
+ if (!CollectionUtils.isEmpty(memberRides)){
+ boolean exitUnBack = memberRides.stream().anyMatch(s -> !Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey().equals(s.getStatus()));
+ if (exitUnBack){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠璁㈠崟鏈夋湭瀹屾垚鐨勯獞琛岋紝鏃犳硶寮哄埗缁撶畻");
+ }
+
+ PricingRuleDTO pricingRule = pricingRuleService.getPricingRule(memberRides);
+ RidesDetailResponse ridesDetailResponse = new RidesDetailResponse();
+ List<MemberRidesResponse> collect = memberRides.stream().map(s -> {
+ MemberRidesResponse memberRidesResponse = new MemberRidesResponse();
+ memberRidesResponse.setRideStartTime(s.getRentDate());
+ memberRidesResponse.setRideEndTime(s.getBackDate());
+ memberRidesResponse.setRideTime(DateUtil.betweenMin(memberRidesResponse.getRideStartTime(), memberRidesResponse.getRideEndTime()));
+ memberRidesResponse.setDuration(s.getDuration());
+ memberRidesResponse.setBikeType(s.getParamName());
+ memberRidesResponse.setBikeCode(s.getBikeCode());
+ memberRidesResponse.setBasePrice(s.getBasePrice());
+ memberRidesResponse.setBaseTime(s.getBaseTime());
+ memberRidesResponse.setUnitPrice(s.getUnitTime());
+ memberRidesResponse.setUnitTime(s.getUnitTime());
+ return memberRidesResponse;
+ }).collect(Collectors.toList());
+
+ Integer durationSum = memberRides.stream().filter(s -> s.getDuration() > 0).mapToInt(s -> s.getDuration()).sum();
+ if (durationSum > pricingRule.getMemberRides().getBaseTime()){
+ BigDecimal basePrice = pricingRule.getMemberRides().getBasePrice();
+ BigDecimal multiply = pricingRule.getMemberRides().getUnitPrice().multiply(new BigDecimal((durationSum - pricingRule.getMemberRides().getBaseTime())));
+ ridesDetailResponse.setAmount(basePrice.add(multiply));
+ }else {
+ ridesDetailResponse.setAmount(pricingRule.getMemberRides().getBasePrice());
+ }
+ ridesDetailResponse.setBikeType(pricingRule.getBikeType());
+ ridesDetailResponse.setDuration(durationSum);
+ ridesDetailResponse.setMemberRidesResponseList(collect);
-
- return null;
+ Refund refund = new Refund();
+ refund.setCreateDate(new Date());
+ refund.setCreator(principal.getId());
+ refund.setEditDate(new Date());
+ refund.setEditor(principal.getId());
+ refund.setIsdeleted(Constants.ZERO);
+ refund.setInfo("绯荤粺缁撶畻鍚庤鍗曡嚜鍔ㄥ畬缁�");
+// refund.setCode();
+ refund.setMemberId(goodsorder.getMemberId());
+ refund.setMoney(goodsorder.getMoney().subtract(ridesDetailResponse.getAmount()));
+// refund.setStatus();
+// refund.setPreOrderid();
+// refund.setOnlineOrderid();
+ refund.setPayWay(goodsorder.getPayWay());
+ refund.setDoneDate(new Date());
+ refund.setType(Constants.ONE);
+ refund.setObjId(goodsorder.getId());
+ refund.setReason("纭畾寮哄埗缁撶畻鍚楋紵缁撶畻鍚庤鍗曡嚜鍔ㄥ畬缁�");
+ refundMapper.insert(refund);
+ Goodsorder update = new Goodsorder();
+ update.setId(goodsorder.getId());
+ update.setStatus(Constants.GOODSORDER_STATUS.CLOSE.getKey());
+ update.setCloseMoney(goodsorder.getMoney().subtract(ridesDetailResponse.getAmount()));
+ update.setCloseId(refund.getId());
+ update.setCloseDate(refund.getDoneDate());
+ update.setCloseInfo(refund.getInfo());
+ update.setCloseUserId(principal.getId());
+ update.setCloseType(Constants.ONE);
+ goodsorderMapper.updateById(update);
+ }
}
@Override
+ public RidesDetailResponse getRidesDetailResponse(String id) {
+
+ QueryWrapper<MemberRides> wrapper = new QueryWrapper<>();
+ wrapper.lambda()
+ .eq(MemberRides::getOrdreId,id);
+ List<MemberRides> memberRides = memberRidesMapper.selectList(wrapper);
+ if (!CollectionUtils.isEmpty(memberRides)){
+ boolean exitUnBack = memberRides.stream().anyMatch(s -> !Constants.MEMBER_RIDES_STATUS.BACK_CYCLING.getKey().equals(s.getStatus()));
+ if (exitUnBack){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠璁㈠崟鏈夋湭瀹屾垚鐨勯獞琛岋紝鏃犳硶寮哄埗缁撶畻");
+ }
+
+ PricingRuleDTO pricingRule = pricingRuleService.getPricingRule(memberRides);
+ RidesDetailResponse ridesDetailResponse = new RidesDetailResponse();
+ List<MemberRidesResponse> collect = memberRides.stream().map(s -> {
+ MemberRidesResponse memberRidesResponse = new MemberRidesResponse();
+ memberRidesResponse.setRideStartTime(s.getRentDate());
+ memberRidesResponse.setRideEndTime(s.getBackDate());
+ memberRidesResponse.setRideTime(DateUtil.betweenMin(memberRidesResponse.getRideStartTime(), memberRidesResponse.getRideEndTime()));
+ memberRidesResponse.setDuration(s.getDuration());
+ memberRidesResponse.setBikeType(s.getParamName());
+ memberRidesResponse.setBikeCode(s.getBikeCode());
+ memberRidesResponse.setBasePrice(s.getBasePrice());
+ memberRidesResponse.setBaseTime(s.getBaseTime());
+ memberRidesResponse.setUnitPrice(s.getUnitTime());
+ memberRidesResponse.setUnitTime(s.getUnitTime());
+ return memberRidesResponse;
+ }).collect(Collectors.toList());
+
+ Integer durationSum = memberRides.stream().filter(s -> s.getDuration() > 0).mapToInt(s -> s.getDuration()).sum();
+ if (durationSum > pricingRule.getMemberRides().getBaseTime()){
+ BigDecimal basePrice = pricingRule.getMemberRides().getBasePrice();
+ BigDecimal multiply = pricingRule.getMemberRides().getUnitPrice().multiply(new BigDecimal((durationSum - pricingRule.getMemberRides().getBaseTime())));
+ ridesDetailResponse.setAmount(basePrice.add(multiply));
+ }else {
+ ridesDetailResponse.setAmount(pricingRule.getMemberRides().getBasePrice());
+ }
+ ridesDetailResponse.setBikeType(pricingRule.getBikeType());
+ ridesDetailResponse.setDuration(durationSum);
+ ridesDetailResponse.setMemberRidesResponseList(collect);
+ return ridesDetailResponse;
+ }
+
+ return new RidesDetailResponse();
+ }
+
+ @Override
public Object createGoodsOrderPay(String memberId){
Member member = memberMapper.selectById(memberId);
if(Objects.isNull(member)){
diff --git a/server/services/src/main/java/com/doumee/service/business/impl/PricingRuleServiceImpl.java b/server/services/src/main/java/com/doumee/service/business/impl/PricingRuleServiceImpl.java
new file mode 100644
index 0000000..91a34ba
--- /dev/null
+++ b/server/services/src/main/java/com/doumee/service/business/impl/PricingRuleServiceImpl.java
@@ -0,0 +1,103 @@
+package com.doumee.service.business.impl;
+import java.math.BigDecimal;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.doumee.core.constants.Constants;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
+import com.doumee.dao.business.BaseParamMapper;
+import com.doumee.dao.business.MemberRidesMapper;
+import com.doumee.dao.business.PricingDetailMapper;
+import com.doumee.dao.business.PricingParamMapper;
+import com.doumee.dao.business.model.BaseParam;
+import com.doumee.dao.business.model.MemberRides;
+import com.doumee.dao.business.web.response.PricingRuleDTO;
+import com.doumee.service.business.PricingRuleService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+/**
+ *
+ * 鑾峰彇璁′环瑙勫垯
+ * @author T14
+ */
+
+@Service
+public class PricingRuleServiceImpl implements PricingRuleService {
+
+
+ @Autowired
+ PricingParamMapper pricingParamMapper;
+
+ @Autowired
+ PricingDetailMapper pricingParamMapper;
+
+
+ @Autowired
+ MemberRidesMapper memberRidesMapper;
+
+
+ @Autowired
+ BaseParamMapper baseParamMapper;
+
+
+ @Override
+ public PricingRuleDTO getPricingRule(String goodaorderId) {
+ QueryWrapper<MemberRides> wrapper = new QueryWrapper<>();
+ wrapper.lambda()
+ .eq(MemberRides::getOrdreId,goodaorderId);
+ List<MemberRides> memberRides = memberRidesMapper.selectList(wrapper);
+ if (CollectionUtils.isEmpty(memberRides)){
+ return null;
+ }
+ PricingRuleDTO pricingRule = getPricingRule(memberRides);
+ return pricingRule;
+ }
+
+
+ @Override
+ public PricingRuleDTO getPricingRule(List<MemberRides> memberRidesList) {
+ if (!CollectionUtils.isEmpty(memberRidesList)){
+ List<String> collect = memberRidesList.stream()
+ .filter(s -> Objects.nonNull(s.getActualPrice()))
+ .map(s -> s.getParamId())
+ .collect(Collectors.toList());
+ QueryWrapper<BaseParam> wrapper = new QueryWrapper<>();
+ wrapper.lambda()
+ .eq(BaseParam::getIsdeleted, Constants.ZERO)
+ .eq(BaseParam::getType, Constants.THREE)
+ .in(BaseParam::getId,collect)
+ .orderByDesc(BaseParam::getSortnum)
+ .last("limit 1");
+ BaseParam baseParam = baseParamMapper.selectOne(wrapper);
+
+ MemberRides memberRides = memberRidesList.stream()
+ .filter(s -> baseParam.getId().equals(s.getParamId()))
+ .findFirst().orElseThrow(() -> new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "娌℃湁杞﹁締绫诲瀷缂栫爜"));
+ PricingRuleDTO pricingRuleDTO = new PricingRuleDTO();
+ if (memberRides.getBaseTime() < 0){
+ //涓�鍙ｄ环瀹氫环
+ pricingRuleDTO.setStartFare(memberRides.getBasePrice());
+ pricingRuleDTO.setPrice(new BigDecimal("0"));
+ pricingRuleDTO.setType(Constants.ONE);
+ pricingRuleDTO.setParamId(baseParam.getId());
+ pricingRuleDTO.setBikeType(baseParam.getName());
+ pricingRuleDTO.setMemberRides(memberRides);
+ }else {
+ pricingRuleDTO.setStartFare(memberRides.getBasePrice());
+ pricingRuleDTO.setPrice(memberRides.getUnitPrice());
+ pricingRuleDTO.setType(Constants.TWO);
+ pricingRuleDTO.setParamId(baseParam.getId());
+ pricingRuleDTO.setBikeType(baseParam.getName());
+ pricingRuleDTO.setMemberRides(memberRides);
+ }
+ return pricingRuleDTO;
+ }
+ return null;
+ }
+}
--
Gitblit v1.9.3