package com.ishop.merchant.service;
|
|
import com.ishop.merchant.OrderConstants;
|
import com.ishop.model.po.EbMerchantOrder;
|
import com.ishop.model.po.EbOrder;
|
import com.ishop.model.po.EbOrderDetail;
|
import com.ishop.model.po.EbOrderInvoice;
|
import com.ishop.model.po.EbOrderInvoiceDetail;
|
import com.walker.db.page.GenericPager;
|
import com.walker.infrastructure.time.TimeRange;
|
import com.walker.infrastructure.utils.StringUtils;
|
import com.walker.jdbc.service.BaseServiceImpl;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class OrderServiceImpl extends BaseServiceImpl {
|
|
private static final String SQL_PAGE_USER_LIST = "select * from eb_order where uid=:uid";
|
private static final String SQL_PAGE_PLATFORM_ORDER = "select id,mer_id,order_no,uid,pay_price,pay_type,paid,status" +
|
",refund_status,is_user_del,is_merchant_del,cancel_status,level,type,create_time from eb_order where 1=1";
|
|
/**
|
* 发货（express）数据库更新。
|
* @param orderInvoice
|
* @param orderInvoiceDetailList
|
* @param orderDetailUpdateList
|
* @param updateOrder
|
* @date 2023-08-21
|
*/
|
public void execSendExpress(EbOrderInvoice orderInvoice
|
, List<EbOrderInvoiceDetail> orderInvoiceDetailList, List<EbOrderDetail> orderDetailUpdateList, EbOrder updateOrder){
|
// 1:写入发货单
|
// 2:写入发货单明细
|
// 3:更新订单明细表中，邮递数量（delivery_num）字段
|
// 4:更新商户订单快递方式为(express)，暂时无需设置，默认就是
|
// 5:更新平台订单为：已发货
|
this.insert(orderInvoice);
|
this.insert(orderInvoiceDetailList);
|
this.update(orderDetailUpdateList);
|
this.update(updateOrder);
|
}
|
|
/**
|
* 分页查询平台订单
|
* @param merId 商户ID，可选
|
* @param orderNo 订单编号，可选
|
* @param type 订单类型，可选
|
* @param timeRange 时间范围，可选
|
* @param status 订单状态，可选
|
* @return
|
* @date 2023-07-20
|
*/
|
public GenericPager<EbOrder> queryPagePlatformOrderList(Integer merId, String orderNo, Integer type, TimeRange timeRange, String status){
|
Map<String, Object> param = new HashMap<>(4);
|
StringBuilder sql = new StringBuilder(SQL_PAGE_PLATFORM_ORDER);
|
if(merId != null && merId > 0){
|
sql.append(" and mer_id=:merId");
|
param.put("merId", merId);
|
}
|
if(StringUtils.isNotEmpty(orderNo)){
|
sql.append(" and order_no=:orderNo");
|
param.put("orderNo", orderNo);
|
}
|
if(type != null && type >= 0){
|
sql.append(" and type=:type");
|
param.put("type", type);
|
}
|
if(timeRange != null){
|
if(timeRange.getStartTime() != null){
|
sql.append(" and create_time >= :startTime");
|
param.put("startTime", timeRange.getStartTime());
|
}
|
if(timeRange.getEndTime() != null){
|
sql.append(" and create_time <= :endTime");
|
param.put("endTime", timeRange.getEndTime());
|
}
|
}
|
if(StringUtils.isNotEmpty(status)){
|
this.setupStatusCondition(sql, status);
|
}
|
sql.append(" order by id desc");
|
return this.selectSplit(sql.toString(), param, new EbOrder());
|
}
|
|
private void setupStatusCondition(StringBuilder sql, String status){
|
//未支付
|
if(status.equals(OrderConstants.MERCHANT_ORDER_STATUS_UNPAID)){
|
sql.append(" and paid=0");
|
sql.append(" and status=").append(OrderConstants.ORDER_STATUS_WAIT_PAY);
|
sql.append(" and cancel_status=").append(OrderConstants.ORDER_CANCEL_STATUS_NORMAL);
|
sql.append(" and is_user_del=0");
|
|
} else if(status.equals(OrderConstants.MERCHANT_ORDER_STATUS_NOT_SHIPPED)){
|
// 未发货
|
sql.append(" and (status=").append(OrderConstants.ORDER_STATUS_WAIT_SHIPPING)
|
.append(" or status=").append(OrderConstants.ORDER_STATUS_PART_SHIPPING).append(")");
|
sql.append(" and cancel_status=").append(OrderConstants.ORDER_CANCEL_STATUS_NORMAL);
|
sql.append(" and refund_status<>").append(OrderConstants.ORDER_REFUND_STATUS_REFUND);
|
sql.append(" and is_user_del=0");
|
|
} else if(status.equals(OrderConstants.MERCHANT_ORDER_STATUS_SPIKE)){
|
//待收货
|
sql.append(" and status=").append(OrderConstants.ORDER_STATUS_WAIT_RECEIPT);
|
sql.append(" and cancel_status=").append(OrderConstants.ORDER_CANCEL_STATUS_NORMAL);
|
sql.append(" and refund_status<>").append(OrderConstants.ORDER_REFUND_STATUS_REFUND);
|
sql.append(" and is_user_del=0");
|
|
} else if(status.equals(OrderConstants.MERCHANT_ORDER_STATUS_RECEIVING)){
|
//已收货
|
sql.append(" and status=").append(OrderConstants.ORDER_STATUS_TAKE_DELIVERY);
|
sql.append(" and cancel_status=").append(OrderConstants.ORDER_CANCEL_STATUS_NORMAL);
|
sql.append(" and refund_status<>").append(OrderConstants.ORDER_REFUND_STATUS_REFUND);
|
sql.append(" and is_user_del=0");
|
|
} else if(status.equals(OrderConstants.MERCHANT_ORDER_STATUS_COMPLETE)){
|
//交易完成
|
sql.append(" and status=").append(OrderConstants.ORDER_STATUS_COMPLETE);
|
sql.append(" and cancel_status=").append(OrderConstants.ORDER_CANCEL_STATUS_NORMAL);
|
sql.append(" and refund_status<>").append(OrderConstants.ORDER_REFUND_STATUS_REFUND);
|
sql.append(" and is_user_del=0");
|
|
} else if(status.equals(OrderConstants.MERCHANT_ORDER_STATUS_AWAIT_VERIFICATION)){
|
//待核销
|
sql.append(" and status=").append(OrderConstants.ORDER_STATUS_AWAIT_VERIFICATION);
|
sql.append(" and cancel_status=").append(OrderConstants.ORDER_CANCEL_STATUS_NORMAL);
|
sql.append(" and refund_status<>").append(OrderConstants.ORDER_REFUND_STATUS_REFUND);
|
sql.append(" and is_user_del=0");
|
|
} else if(status.equals(OrderConstants.MERCHANT_ORDER_STATUS_REFUNDED)){
|
//已退款
|
sql.append(" and paid=1");
|
sql.append(" and cancel_status=").append(OrderConstants.ORDER_CANCEL_STATUS_NORMAL);
|
sql.append(" and refund_status=").append(OrderConstants.ORDER_REFUND_STATUS_REFUND);
|
sql.append(" and is_user_del=0");
|
|
} else if(status.equals(OrderConstants.MERCHANT_ORDER_STATUS_DELETED)){
|
sql.append(" and is_user_del=1");
|
}
|
}
|
|
/**
|
* 根据主订单编号，返回一个商户订单信息。
|
* <p>原：（支付完成进行商户拆单后可用）</p>
|
* @param orderNo
|
* @return
|
* @date 2023-07-20
|
*/
|
public EbMerchantOrder queryMerchantOrderOne(String orderNo){
|
List<EbMerchantOrder> list = this.select("select * from eb_merchant_order where order_no=? limit 1", new Object[]{orderNo}, new EbMerchantOrder());
|
if(StringUtils.isEmptyList(list)){
|
return null;
|
}
|
return list.get(0);
|
}
|
|
/**
|
* 根据平台订单编号，查询商户订单列表，商户订单（可能多商品）对应一个平台订单。
|
* @param orderNo
|
* @return
|
* @date 2023-07-13
|
*/
|
public List<EbMerchantOrder> queryMerchantOrderList(String orderNo){
|
EbMerchantOrder param = new EbMerchantOrder();
|
param.setOrderNo(orderNo);
|
return this.select(param);
|
}
|
|
/**
|
* 根据订单编号，返回订单信息。
|
* @param orderNo
|
* @return
|
* @date 2023-07-12
|
*/
|
public EbOrder queryOrder(String orderNo){
|
EbOrder order = new EbOrder();
|
order.setOrderNo(orderNo);
|
List<EbOrder> list = this.select(order);
|
if(StringUtils.isEmptyList(list)){
|
return null;
|
}
|
return list.get(0);
|
}
|
|
/**
|
* 平台订单，如果用订单编号（不用主键），还要配合商户ID才能确定一条记录。
|
* @param orderNo
|
* @param merId
|
* @return
|
* @date 2023-08-18
|
*/
|
public EbOrder queryPlatformOrder(String orderNo, int merId){
|
EbOrder order = new EbOrder();
|
order.setOrderNo(orderNo);
|
order.setMerId(merId);
|
List<EbOrder> list = this.select(order);
|
if(StringUtils.isEmptyList(list)){
|
return null;
|
}
|
return list.get(0);
|
}
|
|
public List<EbOrderDetail> queryOrderDetailList(String orderNo){
|
EbOrderDetail detail = new EbOrderDetail();
|
detail.setOrderNo(orderNo);
|
return this.select(detail);
|
}
|
|
/**
|
* 根据平台订单ID，查询对应商品ID集合。
|
* @param orderNo
|
* @return
|
* @date 2023-09-09
|
*/
|
public List<Long> queryOrderProductIds(String orderNo){
|
List<Map<String, Object>> list = this.select(SQL_ORDER_PRODUCT_ID, new Object[]{orderNo});
|
if(StringUtils.isEmptyList(list)){
|
return null;
|
}
|
List<Long> data = new ArrayList<>(2);
|
for(Map<String, Object> map : list){
|
data.add(Long.parseLong(map.get("product_id").toString()));
|
}
|
return data;
|
}
|
|
private static final String SQL_ORDER_PRODUCT_ID = "select product_id from eb_order_detail where order_no=?";
|
|
/**
|
* 订单发货获取订单详情列表
|
* @param orderNo
|
* @return
|
* @date 2023-08-21
|
*/
|
public List<EbOrderDetail> queryShipmentList(String orderNo){
|
return this.select(SQL_SHIP_ORDER_DETAIL, new Object[]{orderNo}, new EbOrderDetail());
|
}
|
|
private static final String SQL_SHIP_ORDER_DETAIL = "select id,product_name,image,sku,pay_num,delivery_num,refund_num from eb_order_detail where order_no=?";
|
|
/**
|
* 分页返回用户订单列表
|
* @param userId
|
* @param status 订单状态（-1：全部，0：待支付，1：待发货,2：部分发货， 3：待核销，4：待收货,5：已收货,6：已完成，9：已取消）
|
* @return
|
* @date 2023-07-07
|
*/
|
public GenericPager<EbOrder> queryUserOrderList(long userId, Integer status){
|
StringBuilder sql = new StringBuilder(SQL_PAGE_USER_LIST);
|
Map<String, Object> param = new HashMap<>(8);
|
param.put("uid", userId);
|
|
if(status != null && status.intValue() >= 0){
|
if(status.intValue() == 1){
|
sql.append(" and (status=").append(OrderConstants.ORDER_STATUS_WAIT_SHIPPING);
|
sql.append(" or status=").append(OrderConstants.ORDER_STATUS_PART_SHIPPING).append(")");
|
} else {
|
sql.append(" and status=:status");
|
param.put("status", status);
|
}
|
}
|
// 退款状态
|
sql.append(" and refund_status<").append(OrderConstants.ORDER_REFUND_STATUS_REFUND);
|
sql.append(" and is_user_del=0");
|
sql.append(" and is_merchant_del=0");
|
sql.append(" and (type=").append(OrderConstants.ORDER_TYPE_NORMAL)
|
.append(" or type=").append(OrderConstants.ORDER_TYPE_SECKILL).append(")");
|
sql.append(" and is_del=0");
|
sql.append(" order by id desc");
|
return this.selectSplit(sql.toString(), param, new EbOrder());
|
}
|
}
|
