|
@@ -12,7 +12,7 @@ import org.apache.commons.lang3.StringUtils;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
-import org.springframework.beans.factory.annotation.Value;
|
|
|
|
|
|
+import org.springframework.core.env.Environment;
|
|
import org.springframework.stereotype.Controller;
|
|
import org.springframework.stereotype.Controller;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
@@ -36,10 +36,8 @@ public class OrderController {
|
|
private OrderService orderService;
|
|
private OrderService orderService;
|
|
@Autowired
|
|
@Autowired
|
|
private LoginService loginService;
|
|
private LoginService loginService;
|
|
- @Value("${miniprogram.AppId}")
|
|
|
|
- private String AppId;
|
|
|
|
- @Value("${miniprogram.AppSecret}")
|
|
|
|
- private String AppSecret;
|
|
|
|
|
|
+ @Autowired
|
|
|
|
+ private Environment env;
|
|
|
|
|
|
/**
|
|
/**
|
|
* 确认订单信息
|
|
* 确认订单信息
|
|
@@ -48,9 +46,9 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/confirm")
|
|
@RequestMapping("/confirm")
|
|
- public WxJsonModel confirmOrder(Integer userId, String classifyIDS, Integer organizeID, String productIDs, Integer count) {
|
|
|
|
|
|
+ public CmWxJsonModel confirmOrder(Integer userId, String classifyIDS, Integer organizeID, String productIDs, Integer count) {
|
|
Map<String, Object> map = orderService.confirmOrder(userId, classifyIDS, organizeID, productIDs, count);
|
|
Map<String, Object> map = orderService.confirmOrder(userId, classifyIDS, organizeID, productIDs, count);
|
|
- return WxJsonModel.newInstance().success(map);
|
|
|
|
|
|
+ return CmWxJsonModel.newInstance().success(map);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -60,8 +58,8 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/share")
|
|
@RequestMapping("/share")
|
|
- public WxJsonModel shareOrder(Integer orderID) {
|
|
|
|
- WxJsonModel model = WxJsonModel.newInstance();
|
|
|
|
|
|
+ public CmWxJsonModel shareOrder(Integer orderID) {
|
|
|
|
+ CmWxJsonModel model = CmWxJsonModel.newInstance();
|
|
String shareCode = null;
|
|
String shareCode = null;
|
|
try {
|
|
try {
|
|
shareCode = orderService.shareOrder(orderID);
|
|
shareCode = orderService.shareOrder(orderID);
|
|
@@ -76,9 +74,9 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/shareCode")
|
|
@RequestMapping("/shareCode")
|
|
- public WxJsonModel verifyShareCode(String shareCode, String code, Integer orderID, Integer userID,
|
|
|
|
- Integer organizeID, HttpServletRequest request) {
|
|
|
|
- WxJsonModel model = WxJsonModel.newInstance();
|
|
|
|
|
|
+ public CmWxJsonModel verifyShareCode(String shareCode, String code, Integer orderID, Integer userID,
|
|
|
|
+ Integer organizeID, HttpServletRequest request) {
|
|
|
|
+ CmWxJsonModel model = CmWxJsonModel.newInstance();
|
|
logger.info("Start get SessionKey");
|
|
logger.info("Start get SessionKey");
|
|
Map<String, Object> map = new HashMap<>();
|
|
Map<String, Object> map = new HashMap<>();
|
|
String referer = request.getHeader("Referer"); //获取当前微信小程序的环境
|
|
String referer = request.getHeader("Referer"); //获取当前微信小程序的环境
|
|
@@ -86,8 +84,8 @@ public class OrderController {
|
|
map.put("referer", referer);
|
|
map.put("referer", referer);
|
|
String requestUrl = "https://api.weixin.qq.com/sns/jscode2session";
|
|
String requestUrl = "https://api.weixin.qq.com/sns/jscode2session";
|
|
Map<String, String> requestUrlParam = new HashMap<String, String>();
|
|
Map<String, String> requestUrlParam = new HashMap<String, String>();
|
|
- requestUrlParam.put("appid", AppId);//小程序appId
|
|
|
|
- requestUrlParam.put("secret", AppSecret);//小程序appsecret
|
|
|
|
|
|
+ requestUrlParam.put("appid", env.getProperty("miniprogram.AppId" + organizeID));//小程序appId
|
|
|
|
+ requestUrlParam.put("secret", env.getProperty("miniprogram.AppSecret" + organizeID));//小程序appsecret
|
|
requestUrlParam.put("js_code", code);//小程序端返回的code
|
|
requestUrlParam.put("js_code", code);//小程序端返回的code
|
|
requestUrlParam.put("grant_type", "authorization_code");//默认参数
|
|
requestUrlParam.put("grant_type", "authorization_code");//默认参数
|
|
//发送post请求读取调用微信接口获取openid用户唯一标识
|
|
//发送post请求读取调用微信接口获取openid用户唯一标识
|
|
@@ -116,7 +114,7 @@ public class OrderController {
|
|
if (orderID == null || userID == null || organizeID == null) {
|
|
if (orderID == null || userID == null || organizeID == null) {
|
|
model.error("参数异常");
|
|
model.error("参数异常");
|
|
}
|
|
}
|
|
- WxJsonModel jsonModel = orderService.verifyShareCode(shareCode, openid, orderID, userID, organizeID);
|
|
|
|
|
|
+ CmWxJsonModel jsonModel = orderService.verifyShareCode(shareCode, openid, orderID, userID, organizeID);
|
|
return jsonModel;
|
|
return jsonModel;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -125,8 +123,8 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/particulars")
|
|
@RequestMapping("/particulars")
|
|
- public WxJsonModel particulars(Integer orderID) {
|
|
|
|
- WxJsonModel model = WxJsonModel.newInstance();
|
|
|
|
|
|
+ public CmWxJsonModel particulars(Integer orderID) {
|
|
|
|
+ CmWxJsonModel model = CmWxJsonModel.newInstance();
|
|
Map<String, Object> map = null;
|
|
Map<String, Object> map = null;
|
|
try {
|
|
try {
|
|
map = orderService.particulars(orderID);
|
|
map = orderService.particulars(orderID);
|
|
@@ -158,28 +156,28 @@ public class OrderController {
|
|
@Transactional
|
|
@Transactional
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/submitOrder")
|
|
@RequestMapping("/submitOrder")
|
|
- public synchronized WxJsonModel submitOrder(String params, HttpServletRequest request) {
|
|
|
|
- WxJsonModel wxJsonModel = WxJsonModel.newInstance();
|
|
|
|
|
|
+ public synchronized CmWxJsonModel submitOrder(String params, HttpServletRequest request) {
|
|
|
|
+ CmWxJsonModel cmWxJsonModel = CmWxJsonModel.newInstance();
|
|
logger.info(">>>>>>订单信息params:" + params);
|
|
logger.info(">>>>>>订单信息params:" + params);
|
|
//检查用户是否登入
|
|
//检查用户是否登入
|
|
-// CmOperationUser currentUser = SessionHelper.getCurrentUser(request);
|
|
|
|
|
|
+// CmMallOperationUser currentUser = SessionHelper.getCurrentUser(request);
|
|
HttpSession session = request.getSession();
|
|
HttpSession session = request.getSession();
|
|
String openid = (String) session.getAttribute("openid");
|
|
String openid = (String) session.getAttribute("openid");
|
|
Integer organizeID1 = (Integer) session.getAttribute("organizeID");
|
|
Integer organizeID1 = (Integer) session.getAttribute("organizeID");
|
|
- CmOperationUser currentUser = loginService.doLogin(openid, organizeID1);
|
|
|
|
|
|
+ CmMallOperationUser currentUser = loginService.doLogin(openid, organizeID1);
|
|
if (null == currentUser) {
|
|
if (null == currentUser) {
|
|
- return wxJsonModel.error("-1", "用户账户异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "用户账户异常");
|
|
}
|
|
}
|
|
Integer cmOperationID = currentUser.getId();//当前操作者ID
|
|
Integer cmOperationID = currentUser.getId();//当前操作者ID
|
|
if (StringUtils.isBlank(params)) {
|
|
if (StringUtils.isBlank(params)) {
|
|
- return wxJsonModel.error("-1", "数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "数据异常");
|
|
}
|
|
}
|
|
Map<String, Object> map = new HashMap<String, Object>();
|
|
Map<String, Object> map = new HashMap<String, Object>();
|
|
try {
|
|
try {
|
|
map = (Map<String, Object>) JsonMapper.getInstance().fromJsonString(params, Map.class);
|
|
map = (Map<String, Object>) JsonMapper.getInstance().fromJsonString(params, Map.class);
|
|
if (null == map) {
|
|
if (null == map) {
|
|
logger.info(">>>>>数据异常,参数不能为空");
|
|
logger.info(">>>>>数据异常,参数不能为空");
|
|
- return wxJsonModel.error("-1", "数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "数据异常");
|
|
}
|
|
}
|
|
Integer userId = (Integer) map.get("userId");
|
|
Integer userId = (Integer) map.get("userId");
|
|
Integer organizeID = (Integer) map.get("organizeID");
|
|
Integer organizeID = (Integer) map.get("organizeID");
|
|
@@ -190,31 +188,31 @@ public class OrderController {
|
|
Double orderShouldPayFee = Double.parseDouble(String.valueOf(map.get("orderShouldPayFee")));//此金额为前端计算,适用于后端计算金额复查
|
|
Double orderShouldPayFee = Double.parseDouble(String.valueOf(map.get("orderShouldPayFee")));//此金额为前端计算,适用于后端计算金额复查
|
|
//校验传入参数的正确性
|
|
//校验传入参数的正确性
|
|
if (null == userId) {
|
|
if (null == userId) {
|
|
- return wxJsonModel.error("-1", "用户数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "用户数据异常");
|
|
}
|
|
}
|
|
if (null == organizeID) {
|
|
if (null == organizeID) {
|
|
- return wxJsonModel.error("-1", "组织数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "组织数据异常");
|
|
}
|
|
}
|
|
if (StringUtils.isEmpty(cartType)) {
|
|
if (StringUtils.isEmpty(cartType)) {
|
|
- return wxJsonModel.error("-1", "购买类型数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "购买类型数据异常");
|
|
}
|
|
}
|
|
if (null == addressID) {
|
|
if (null == addressID) {
|
|
- return wxJsonModel.error("-1", "地址数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "地址数据异常");
|
|
}
|
|
}
|
|
if (null == orderInfo) {
|
|
if (null == orderInfo) {
|
|
- return wxJsonModel.error("-1", "订单数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "订单数据异常");
|
|
}
|
|
}
|
|
if (StringUtils.isEmpty(balanceDeductionFlag)) {
|
|
if (StringUtils.isEmpty(balanceDeductionFlag)) {
|
|
- return wxJsonModel.error("-1", "余额抵扣数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "余额抵扣数据异常");
|
|
}
|
|
}
|
|
if (null == orderShouldPayFee) {
|
|
if (null == orderShouldPayFee) {
|
|
- return wxJsonModel.error("-1", "订单应付金额数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "订单应付金额数据异常");
|
|
}
|
|
}
|
|
//保存订单信息
|
|
//保存订单信息
|
|
- return orderService.saveOrderInfo(wxJsonModel, userId, organizeID, cartType, addressID, orderInfo, balanceDeductionFlag, orderShouldPayFee, cmOperationID);
|
|
|
|
|
|
+ return orderService.saveOrderInfo(cmWxJsonModel, userId, organizeID, cartType, addressID, orderInfo, balanceDeductionFlag, orderShouldPayFee, cmOperationID);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
logger.info(">>>>>系统异常" + e.getMessage());
|
|
logger.info(">>>>>系统异常" + e.getMessage());
|
|
- return wxJsonModel.error("-1", "数据异常");
|
|
|
|
|
|
+ return cmWxJsonModel.error("-1", "数据异常");
|
|
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -224,10 +222,16 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/logistics")
|
|
@RequestMapping("/logistics")
|
|
- public WxJsonModel logistics(Integer orderID) {
|
|
|
|
- WxJsonModel model = WxJsonModel.newInstance();
|
|
|
|
- List<CmShopOrder> shopOrderList = orderService.logistics(orderID);
|
|
|
|
- return model.success(shopOrderList);
|
|
|
|
|
|
+ public CmWxJsonModel logistics(Integer orderID) {
|
|
|
|
+ CmWxJsonModel model = CmWxJsonModel.newInstance();
|
|
|
|
+ List<CmMallLogisticsBatch> logistics = null;
|
|
|
|
+ try {
|
|
|
|
+ logistics = orderService.logistics(orderID);
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return model.success(logistics);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -238,14 +242,14 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/myOrder")
|
|
@RequestMapping("/myOrder")
|
|
- public WxJsonModel myOrder(Integer orderState, Integer userID, Integer index, Integer pageSize, Integer organizeID) {
|
|
|
|
- WxJsonModel model = WxJsonModel.newInstance();
|
|
|
|
|
|
+ public CmWxJsonModel myOrder(Integer orderState, Integer userID, Integer index, Integer pageSize, Integer organizeID) {
|
|
|
|
+ CmWxJsonModel model = CmWxJsonModel.newInstance();
|
|
if (userID == null || orderState == null || organizeID == null) return model.error("参数异常");
|
|
if (userID == null || orderState == null || organizeID == null) return model.error("参数异常");
|
|
if (index == null) index = 1;
|
|
if (index == null) index = 1;
|
|
if (pageSize == null) pageSize = 10;
|
|
if (pageSize == null) pageSize = 10;
|
|
PageHelper.startPage(index, pageSize);
|
|
PageHelper.startPage(index, pageSize);
|
|
- List<CmOrder> orderList = orderService.myOrder(userID, orderState, organizeID);
|
|
|
|
- Page<CmOrder> page = new Page<>(orderList);
|
|
|
|
|
|
+ List<CmMallOrder> orderList = orderService.myOrder(userID, orderState, organizeID);
|
|
|
|
+ CmMallPage<CmMallOrder> page = new CmMallPage<>(orderList);
|
|
return model.success(page);
|
|
return model.success(page);
|
|
}
|
|
}
|
|
|
|
|
|
@@ -254,8 +258,8 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/purchase")
|
|
@RequestMapping("/purchase")
|
|
- public WxJsonModel oftenPurchase(Integer userID, Integer organizeID, Integer index, Integer pageSize) {
|
|
|
|
- WxJsonModel model = WxJsonModel.newInstance();
|
|
|
|
|
|
+ public CmWxJsonModel oftenPurchase(Integer userID, Integer organizeID, Integer index, Integer pageSize) {
|
|
|
|
+ CmWxJsonModel model = CmWxJsonModel.newInstance();
|
|
if (userID == null || organizeID == null) return model.error("参数异常");
|
|
if (userID == null || organizeID == null) return model.error("参数异常");
|
|
Map<String, Object> map = orderService.oftenPurchase(userID, organizeID, index, pageSize);
|
|
Map<String, Object> map = orderService.oftenPurchase(userID, organizeID, index, pageSize);
|
|
return model.success(map);
|
|
return model.success(map);
|
|
@@ -266,8 +270,8 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/delete")
|
|
@RequestMapping("/delete")
|
|
- public WxJsonModel deleteOrder(Integer orderID) {
|
|
|
|
- WxJsonModel model = null;
|
|
|
|
|
|
+ public CmWxJsonModel deleteOrder(Integer orderID) {
|
|
|
|
+ CmWxJsonModel model = null;
|
|
try {
|
|
try {
|
|
model = orderService.deleteOrder(orderID);
|
|
model = orderService.deleteOrder(orderID);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
@@ -281,8 +285,8 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/cancel")
|
|
@RequestMapping("/cancel")
|
|
- public WxJsonModel cancelOrder(Integer orderID) {
|
|
|
|
- WxJsonModel model = WxJsonModel.newInstance();
|
|
|
|
|
|
+ public CmWxJsonModel cancelOrder(Integer orderID) {
|
|
|
|
+ CmWxJsonModel model = CmWxJsonModel.newInstance();
|
|
try {
|
|
try {
|
|
orderService.cancelOrder(orderID);
|
|
orderService.cancelOrder(orderID);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
@@ -296,8 +300,8 @@ public class OrderController {
|
|
*/
|
|
*/
|
|
@ResponseBody
|
|
@ResponseBody
|
|
@RequestMapping("/affirm")
|
|
@RequestMapping("/affirm")
|
|
- public WxJsonModel affirmCargo(Integer orderID) {
|
|
|
|
- WxJsonModel model = WxJsonModel.newInstance();
|
|
|
|
|
|
+ public CmWxJsonModel affirmCargo(Integer orderID) {
|
|
|
|
+ CmWxJsonModel model = CmWxJsonModel.newInstance();
|
|
try {
|
|
try {
|
|
orderService.affirmCargo(orderID);
|
|
orderService.affirmCargo(orderID);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|