package com.doumee.service.business.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.config.wx.WxMiniConfig;
|
import com.doumee.config.wx.WxMiniUtilService;
|
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;
|
import com.doumee.core.utils.GeoUtils;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.*;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.dto.*;
|
import com.doumee.dao.vo.OrderReleaseVO;
|
import com.doumee.service.business.OrdersService;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import com.wechat.pay.java.service.partnerpayments.jsapi.model.Amount;
|
import com.wechat.pay.java.service.partnerpayments.jsapi.model.Payer;
|
import com.wechat.pay.java.service.partnerpayments.jsapi.model.PrepayRequest;
|
import com.wechat.pay.java.service.partnerpayments.jsapi.model.PrepayWithRequestPaymentResponse;
|
import com.wechat.pay.java.service.refund.model.RefundNotification;
|
import jodd.util.StringUtil;
|
import lombok.With;
|
import nonapi.io.github.classgraph.json.Id;
|
import org.apache.poi.sl.image.ImageHeaderEMF;
|
import org.checkerframework.checker.units.qual.A;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.util.StringUtils;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* 订单信息记录Service实现
|
* @author 江蹄蹄
|
* @date 2025/07/09 12:00
|
*/
|
@Service
|
public class OrdersServiceImpl implements OrdersService {
|
|
@Autowired
|
private OrdersMapper ordersMapper;
|
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
|
@Autowired
|
private CategoryMapper categoryMapper;
|
|
@Autowired
|
private MultifileMapper multifileMapper;
|
|
@Autowired
|
private OrderLogMapper orderLogMapper;
|
|
@Autowired
|
private MemberMapper memberMapper;
|
|
@Autowired
|
private MemberRevenueMapper memberRevenueMapper;
|
|
@Autowired
|
private IdentityInfoMapper identityInfoMapper;
|
|
@Autowired
|
private WithdrawalOrdersMapper withdrawalOrdersMapper;
|
|
@Autowired
|
private ReceiveWeightMapper receiveWeightMapper;
|
|
@Autowired
|
private WxMiniUtilService wxMiniUtilService;
|
|
@Resource
|
private RedisTemplate<String,Object> redisTemplate;
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public OrderReleaseVO create(Orders orders) {
|
OrderReleaseVO orderReleaseVO = new OrderReleaseVO();
|
Object objects = null;
|
this.initVerification(orders);
|
orders.setCreateTime(new Date());
|
orders.setUpdateTime(orders.getUpdateTime());
|
orders.setPayStatus(Constants.ZERO);
|
orders.setDeleted(Constants.ZERO);
|
orders.setReleaseMemberId(orders.getMember().getId());
|
orders.setCommentStatus(Constants.ZERO);
|
//查询手续费
|
Category platformCategory = categoryMapper.selectOne(new QueryWrapper<Category>().lambda().eq(Category::getType,Constants.THREE).eq(Category::getName,orders.getType()).eq(Category::getDeleted,Constants.ZERO).last("limit 1 "));
|
if(Objects.isNull(platformCategory)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未设置平台配置信息");
|
}
|
orders.setPlatformRata(new BigDecimal(platformCategory.getDetail()).divide(new BigDecimal("100")));
|
//订单编号
|
orders.setCode(this.getNextCode(orders.getType()));
|
Category category = categoryMapper.selectOne(new QueryWrapper<Category>().lambda()
|
.eq(Category::getDeleted,Constants.ZERO).eq(Category::getType,Constants.THREE)
|
.eq(Category::getName,orders.getType())
|
.last("limit 1")
|
);
|
if(Objects.isNull(category)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"参数配置错误,请联系管理员");
|
}
|
//用餐订单
|
if(Constants.equalsInteger(orders.getType(),Constants.TWO)){
|
orders.setStatus(Constants.ordersStatus.waitPay.getKey());
|
orders.setOutTradeNo(UUID.randomUUID().toString().replace("-",""));
|
orders.setPayAccount(orders.getEstimatedAccount());
|
//唤起支付业务
|
objects = this.getWxPayResponse(orders,orders.getMember().getOpenid());
|
orderReleaseVO.setObject(objects);
|
}else{
|
orders.setStatus(Constants.ordersStatus.wait.getKey());
|
}
|
ordersMapper.insert(orders);
|
orderReleaseVO.setId(orders.getId());
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(orders.getMultifileList())){
|
List<Multifile> multifileList = orders.getMultifileList();
|
for (Multifile multifile:multifileList) {
|
if(Objects.isNull(multifile)
|
|| StringUtils.isEmpty(multifile.getFileurl())
|
|| StringUtils.isEmpty(multifile.getName())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"附件信息错误");
|
}
|
multifile.setIsdeleted(Constants.ZERO);
|
multifile.setCreateDate(new Date());
|
multifile.setObjId(orders.getId());
|
multifile.setObjType(Constants.ONE);
|
}
|
multifileMapper.insert(multifileList);
|
}
|
//更新用户发单量
|
memberMapper.update(new UpdateWrapper<Member>().lambda().setSql(" receive_num = ( receive_num + 1 )").eq(Member::getId,orders.getMember().getId()));
|
|
//创建操作日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.UPLOAD;
|
String orderTypeInfo = "用工单";
|
if(!Constants.equalsInteger(orders.getType(),Constants.ZERO)){
|
orderTypeInfo = Constants.equalsInteger(orders.getType(),Constants.ONE)?"用车单":"送餐单";
|
}else{
|
if(Constants.equalsInteger(orders.getWorkType(),Constants.ZERO)){
|
orderTypeInfo = orderTypeInfo + "-采摘工";
|
}else{
|
orderTypeInfo = orderTypeInfo + (Constants.equalsInteger(orders.getWorkType(),Constants.ONE)?"-分拣工":"-包装工");
|
}
|
}
|
String logInfo = ordersLog.getInfo()
|
.replace("{param}",orderTypeInfo);
|
this.saveOrderLog(orders,ordersLog,
|
logInfo,orders.getReleaseMemberId(),null);
|
return orderReleaseVO;
|
}
|
|
private Object getWxPayResponse(Orders orders,String openid){
|
Object response = null;
|
//调起支付
|
PrepayRequest request = new PrepayRequest();
|
request.setAttach("createOrder");
|
request.setDescription("近快订单支付");
|
request.setSpMchid(WxMiniConfig.wxProperties.getMchId());
|
request.setSpAppid(WxMiniConfig.wxProperties.getAppId());
|
request.setSubMchid(WxMiniConfig.wxProperties.getSubMchId());
|
request.setSubAppid(WxMiniConfig.wxProperties.getSubAppId());
|
Payer payer = new Payer();
|
payer.setSubOpenid(openid);
|
request.setPayer(payer);
|
request.setOutTradeNo(orders.getOutTradeNo());
|
request.setNotifyUrl(WxMiniConfig.wxProperties.getNotifyUrl());//这个回调url必须是https开头的
|
Amount amount = new Amount();
|
amount.setTotal(1);//orders.getPayAccount().intValue());
|
request.setAmount(amount);
|
// PrepayResponse res = WxMiniConfig.wxPayService.prepay(request);
|
// 跟之前下单示例一样，填充预下单参数
|
PrepayWithRequestPaymentResponse resParam = WxMiniConfig.jsapiExtService.prepayWithRequestPayment(request,WxMiniConfig.wxProperties.getSubAppId());
|
response =resParam;
|
return response;
|
}
|
|
/**
|
* 日志信息
|
* @param orders 订单信息
|
* @param ordersLog 订单支持分类
|
* @param logInfo 日志内容
|
* @param memberId 移动端操作人
|
* @param userId 系统操作人
|
*/
|
public void saveOrderLog(Orders orders,Constants.OrdersLog ordersLog,String logInfo,Integer memberId,Integer userId){
|
OrderLog orderLog = new OrderLog();
|
orderLog.setCreateTime(orders.getUpdateTime());
|
orderLog.setDeleted(Constants.ZERO);
|
orderLog.setOrderId(orders.getId());
|
orderLog.setTitle(ordersLog.getName());
|
orderLog.setLogInfo(logInfo);
|
orderLog.setObjType(ordersLog.getKey());
|
orderLog.setOrderStatus(orders.getStatus());
|
orderLog.setMemberId(memberId);
|
orderLog.setCreateUser(userId);
|
orderLog.setOptUserType(ordersLog.getUserType());
|
orderLogMapper.insert(orderLog);
|
}
|
|
|
|
|
public void initVerification(Orders orders){
|
if(Objects.isNull(orders)
|
|| Objects.isNull(orders.getType())
|
|| Objects.isNull(orders.getStartDate())
|
|| Objects.isNull(orders.getEndDate())
|
|| StringUtil.isBlank(orders.getLocation())
|
|| StringUtil.isBlank(orders.getLinkPhone())
|
|| Objects.isNull(orders.getLat())
|
|| Objects.isNull(orders.getLgt())
|
|| (!Constants.equalsInteger(orders.getType(),Constants.TWO) && Objects.isNull(orders.getCategoryId()))
|
|| (Constants.equalsInteger(orders.getType(),Constants.ZERO) && Objects.isNull(orders.getWorkType()))
|
|| Objects.isNull(orders.getPriceNum1())
|
|| Objects.isNull(orders.getEstimatedAccount())
|
|| Objects.isNull(orders.getPrice())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
if( (Constants.equalsInteger(orders.getType(),Constants.ZERO) && Constants.equalsInteger(orders.getWorkType(),Constants.TWO) &&
|
( Constants.equalsInteger(orders.getCarType(),Constants.ZERO) || Constants.equalsInteger(orders.getCarType(),Constants.ONE) ))
|
|| (Constants.equalsInteger(orders.getType(),Constants.ZERO) && Constants.equalsInteger(orders.getWorkType(),Constants.ONE))
|
){
|
if(Objects.isNull(orders.getPriceNum2())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
}else{
|
orders.setPriceNum2(Constants.ONE);
|
}
|
orders.setTotalDays(DateUtil.daysBetweenDates(orders.getEndDate(),orders.getStartDate())+1);
|
if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){
|
if(Constants.equalsInteger(orders.getWorkType(),Constants.TWO)
|
&& ( Objects.isNull(orders.getCarType()) ) ){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
}else if(Constants.equalsInteger(orders.getType(),Constants.ONE)){
|
if(Objects.isNull(orders.getTransportTypeId())
|
|| Objects.isNull(orders.getCarType())
|
|| Objects.isNull(orders.getTransportNum())
|
|| StringUtils.isEmpty(orders.getTransportUnit())
|
|| StringUtils.isEmpty(orders.getLocationEnd())
|
|| StringUtils.isEmpty(orders.getCarUnit())
|
|| Objects.isNull(orders.getLatEnd())
|
|| Objects.isNull(orders.getLgtEnd())
|
|| CollectionUtils.isEmpty(orders.getWayInfoDTOList())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
for (WayInfoDTO wayInfoDTO:orders.getWayInfoDTOList()) {
|
if(Objects.isNull(wayInfoDTO)
|
||StringUtils.isEmpty(wayInfoDTO.getLocation())
|
// ||StringUtils.isEmpty(wayInfoDTO.getProvince())
|
// ||StringUtils.isEmpty(wayInfoDTO.getCity())
|
// ||StringUtils.isEmpty(wayInfoDTO.getArea())
|
||Objects.isNull(wayInfoDTO.getLat())
|
||Objects.isNull(wayInfoDTO.getLgt())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
}
|
orders.setWayInfo(JSONObject.toJSONString(orders.getWayInfoDTOList()));
|
}else{
|
//用餐订单
|
if(CollectionUtils.isEmpty(orders.getCateringDTOList())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Long sumPrice = 0L;
|
for (CateringDTO cateringDTO:orders.getCateringDTOList()) {
|
if(Objects.isNull(cateringDTO)
|
|| StringUtils.isEmpty(cateringDTO.getName())
|
|| Objects.isNull(cateringDTO.getPrice())
|
|| Objects.isNull(cateringDTO.getNum())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"用餐标准数据错误");
|
}
|
sumPrice = sumPrice + (cateringDTO.getPrice() * cateringDTO.getNum()) ;
|
}
|
if(!sumPrice.equals(orders.getPrice())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"单价计算错误");
|
}
|
orders.setWayInfo(JSONObject.toJSONString(orders.getCateringDTOList()));
|
}
|
if(!orders.getEstimatedAccount().equals(this.getTotal(orders))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"金额计算错误!");
|
}
|
}
|
|
|
|
|
|
|
|
@Override
|
public void deleteById(Integer id) {
|
ordersMapper.deleteById(id);
|
}
|
|
@Override
|
public void delete(Orders orders) {
|
UpdateWrapper<Orders> deleteWrapper = new UpdateWrapper<>(orders);
|
ordersMapper.delete(deleteWrapper);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<Integer> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
ordersMapper.deleteBatchIds(ids);
|
}
|
|
@Override
|
public void update(Orders orders){
|
if(Objects.isNull(orders)
|
|| Objects.isNull(orders.getId())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Orders model = ordersMapper.selectById(orders.getId());
|
if(!Constants.equalsInteger(model.getReleaseMemberId(),orders.getMember().getId())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作");
|
}
|
if(Constants.equalsInteger(model.getIsUpdate(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单已修改，待接单方确认，无法进行该操作");
|
}
|
if(!Constants.equalsInteger(model.getType(),Constants.TWO)){
|
if(Constants.equalsInteger(model.getStatus(),Constants.ZERO)||Constants.equalsInteger(model.getStatus(),Constants.ONE)){
|
this.updateById(orders);
|
}else if(Constants.equalsInteger(model.getStatus(),Constants.TWO)){
|
this.updOrderData(orders,model);
|
}else{
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
}
|
}else{
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED);
|
}
|
|
|
|
}
|
|
|
|
// @Override
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public void updateById(Orders orders) {
|
|
Orders model = ordersMapper.selectById(orders.getId());
|
if(Constants.equalsInteger(model.getType(),Constants.TWO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"此类订单无法进行修改");
|
}
|
if(!Constants.equalsInteger(model.getStatus(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行该操作");
|
}
|
this.initVerification(orders);
|
orders.setUpdateTime(new Date());
|
Category category = categoryMapper.selectOne(new QueryWrapper<Category>().lambda()
|
.eq(Category::getDeleted,Constants.ZERO).eq(Category::getType,Constants.THREE)
|
.eq(Category::getName,orders.getType())
|
.last("limit 1")
|
);
|
if(Objects.isNull(category)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"参数配置错误,请联系管理员");
|
}
|
multifileMapper.update(new UpdateWrapper<Multifile>().lambda().set(Multifile::getIsdeleted,Constants.ONE).eq(Multifile::getObjType,Constants.ONE)
|
.eq(Multifile::getObjId,orders.getId()));
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(orders.getMultifileList())){
|
List<Multifile> multifileList = orders.getMultifileList();
|
for (Multifile multifile:multifileList) {
|
if(Objects.isNull(multifile)
|
|| Objects.isNull(multifile.getObjType())
|
|| StringUtils.isEmpty(multifile.getFileurl())
|
|| StringUtils.isEmpty(multifile.getName())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"附件信息错误");
|
}
|
multifile.setId(null);
|
multifile.setIsdeleted(Constants.ZERO);
|
multifile.setCreateDate(new Date());
|
multifile.setObjId(orders.getId());
|
multifile.setObjType(Constants.ONE);
|
}
|
multifileMapper.insert(multifileList);
|
}
|
ordersMapper.updateById(orders);
|
}
|
|
@Override
|
public void updateByIdInBatch(List<Orders> orderss) {
|
if (CollectionUtils.isEmpty(orderss)) {
|
return;
|
}
|
for (Orders orders: orderss) {
|
//this.updateById(orders);
|
}
|
}
|
|
@Override
|
public Orders findById(Integer id) {
|
Orders orders = ordersMapper.selectJoinOne(Orders.class,new MPJLambdaWrapper<Orders>()
|
.selectAll(Orders.class)
|
.select(" m1.name " , Orders::getReleaseName)
|
.select(" m1.telephone " , Orders::getReleasePhone)
|
.select(" case when i.AUTH_TYPE = 0 then i.LINK_NAME else i.COMPANY_NAME end " , Orders::getAcceptName)
|
.select(" i.TELEPHONE " , Orders::getAcceptPhone)
|
.select("c1.name",Orders::getCategoryName)
|
.select("c2.name",Orders::getTransportTypeName)
|
.leftJoin(" category c1 on t.category_id = c1.id ")
|
.leftJoin(" category c2 on t.TRANSPORT_TYPE_ID = c2.id ")
|
.leftJoin("member m1 on t.RELEASE_MEMBER_ID = m1.id ")
|
.leftJoin("member m2 on t.ACCEPT_MEMBER_ID = m2.id ")
|
.leftJoin("identity_info i on m2.id = i.MEMBER_ID and i.TYPE = t.type and i.AUDIT_STATUS = 2 ")
|
.eq(Orders::getDeleted,Constants.ZERO)
|
.eq(Orders::getId,id)
|
.orderByDesc(Orders::getId));
|
if(Objects.isNull(orders)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
orders.setStatusName(Constants.ordersStatus.getName(orders.getStatus()));
|
this.getPriceUnit(orders);
|
|
//附件信息
|
List<Multifile> multifileList = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda().eq(Multifile::getObjId,orders.getId())
|
.eq(Multifile::getIsdeleted,Constants.ZERO).eq(Multifile::getObjType,Constants.ONE).orderByAsc(Multifile::getId));
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(multifileList)){
|
String path = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RESOURCE_PATH).getCode()
|
+systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.ORDERS_FILES).getCode();
|
for (Multifile multifile:multifileList) {
|
multifile.setFileurlFull(path + multifile.getFileurl());
|
}
|
orders.setMultifileList(multifileList);
|
}
|
//订单流转记录
|
List<OrderLog> orderLogList = orderLogMapper.selectList(new QueryWrapper<OrderLog>().lambda()
|
.eq(OrderLog::getDeleted,Constants.ZERO)
|
.eq(OrderLog::getOrderId,orders.getId())
|
.orderByAsc(OrderLog::getCreateTime)
|
);
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(orderLogList)){
|
for (OrderLog orderLog:orderLogList) {
|
if(Constants.equalsInteger(orderLog.getOptUserType(),Constants.ZERO)){
|
orderLog.setLogInfo(orderLog.getLogInfo().replace("{userName}",orders.getReleaseName()));
|
}else if(Constants.equalsInteger(orderLog.getOptUserType(),Constants.ONE)){
|
orderLog.setLogInfo(orderLog.getLogInfo().replace("{userName}",orders.getAcceptName()));
|
}
|
}
|
orders.setOrderLogList(orderLogList);
|
}
|
return orders;
|
}
|
|
public void getPriceUnit(Orders orders){
|
if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){
|
if(Constants.equalsInteger(orders.getWorkType(),Constants.ZERO)){
|
orders.setPriceUnit("元/斤");
|
}else if(Constants.equalsInteger(orders.getWorkType(),Constants.ONE)){
|
orders.setPriceUnit("元/人/天");
|
}else{
|
if(Constants.equalsInteger(orders.getCarType(),Constants.ZERO)){
|
orders.setPriceUnit("元/人/天");
|
}else if(Constants.equalsInteger(orders.getCarType(),Constants.ONE)){
|
orders.setPriceUnit("元/人/小时");
|
}else{
|
orders.setPriceUnit("元/斤");
|
}
|
}
|
}else if(Constants.equalsInteger(orders.getType(),Constants.ONE)){
|
if(Constants.equalsInteger(orders.getCarType(),Constants.ZERO)){
|
orders.setPriceUnit("元/天");
|
}else if(Constants.equalsInteger(orders.getCarType(),Constants.ONE)){
|
orders.setPriceUnit("元/次");
|
}
|
}
|
}
|
@Override
|
public Orders findOne(Orders orders) {
|
QueryWrapper<Orders> wrapper = new QueryWrapper<>(orders);
|
return ordersMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<Orders> findList(Orders orders) {
|
QueryWrapper<Orders> wrapper = new QueryWrapper<>(orders);
|
return ordersMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<Orders> findPage(PageWrap<Orders> pageWrap) {
|
IPage<Orders> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<Orders> queryWrapper = new MPJLambdaWrapper<Orders>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
Orders model = pageWrap.getModel();
|
queryWrapper.selectAll(Orders.class)
|
.select(" m1.name " , Orders::getReleaseName)
|
.select(" m1.telephone " , Orders::getReleasePhone)
|
.select(" case when i.AUTH_TYPE = 0 then i.LINK_NAME else i.COMPANY_NAME end " , Orders::getAcceptName)
|
.select(" i.TELEPHONE " , Orders::getAcceptPhone)
|
.select("c1.name",Orders::getCategoryName)
|
.select("c2.name",Orders::getTransportTypeName)
|
.leftJoin(" category c1 on t.category_id = c1.id ")
|
.leftJoin(" category c2 on t.TRANSPORT_TYPE_ID = c2.id ")
|
.leftJoin("member m1 on t.RELEASE_MEMBER_ID = m1.id ")
|
.leftJoin("member m2 on t.ACCEPT_MEMBER_ID = m2.id ")
|
.leftJoin("identity_info i on m2.id = i.MEMBER_ID and i.TYPE = t.type and i.AUDIT_STATUS = 2 ")
|
.eq(Orders::getDeleted,Constants.ZERO)
|
.orderByDesc(Orders::getId)
|
;
|
queryWrapper.ge(Objects.nonNull(model.getCreateTimeStart()),Orders::getCreateTime, Utils.Date.getStart(model.getCreateTimeStart()));
|
queryWrapper.le(Objects.nonNull(model.getCreateTimeEnd()),Orders::getCreateTime, Utils.Date.getEnd(model.getCreateTimeEnd()));
|
queryWrapper.ge(Objects.nonNull(model.getAcceptTimeStart()),Orders::getAcceptTime, Utils.Date.getStart(model.getAcceptTimeStart()));
|
queryWrapper.le(Objects.nonNull(model.getAcceptTimeEnd()),Orders::getAcceptTime, Utils.Date.getEnd(model.getAcceptTimeEnd()));
|
queryWrapper.ge(Objects.nonNull(model.getDoneTimeStart()),Orders::getFinishTime, Utils.Date.getStart(model.getDoneTimeStart()));
|
queryWrapper.le(Objects.nonNull(model.getDoneTimeEnd()),Orders::getFinishTime, Utils.Date.getEnd(model.getDoneTimeEnd()));
|
queryWrapper.like(org.apache.commons.lang3.StringUtils.isNotBlank(model.getCode()),Orders::getCode, model.getCode());
|
queryWrapper.eq(Objects.nonNull(model.getType()),Orders::getType, model.getType());
|
queryWrapper.eq(Objects.nonNull(model.getStatus()),Orders::getStatus, model.getStatus());
|
queryWrapper.eq(Objects.nonNull(model.getCommentStatus()),Orders::getCommentStatus, model.getCommentStatus());
|
queryWrapper.eq(Objects.nonNull(model.getReleaseMemberId()),Orders::getReleaseMemberId, model.getReleaseMemberId());
|
queryWrapper.eq(Objects.nonNull(model.getAcceptMemberId()),Orders::getAcceptMemberId, model.getAcceptMemberId());
|
queryWrapper.eq(Objects.nonNull(model.getAcceptType()),Orders::getAcceptType, model.getAcceptType());
|
queryWrapper.apply(org.apache.commons.lang3.StringUtils.isNotBlank(model.getReleaseName()),"m1.name", model.getReleaseName());
|
queryWrapper.apply(org.apache.commons.lang3.StringUtils.isNotBlank(model.getAcceptName()),"( i.LINK_NAME like '%"+model.getAcceptName()+"%' or i.company_name like '%"+model.getAcceptName()+"%' or i.TELEPHONE like '%"+model.getAcceptName()+"%' ) ");
|
IPage<Orders> iPage = ordersMapper.selectJoinPage(page,Orders.class,queryWrapper);
|
for (Orders orders:iPage.getRecords()) {
|
this.getOrderContent(orders);
|
orders.setStatusName(Constants.ordersStatus.getName(orders.getStatus()));
|
orders.setEstimatedAccountYuan(Objects.nonNull(orders.getEstimatedAccount())&&orders.getEstimatedAccount()>0?orders.getEstimatedAccount()/100:0L);
|
orders.setPayAccountYuan(Objects.nonNull(orders.getPayAccount())&&orders.getPayAccount()>0?orders.getPayAccount()/100:0L);
|
}
|
return PageData.from(iPage);
|
}
|
|
public void getOrderContent(Orders orders){
|
if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){
|
orders.setOrderContent(Constants.workType.getName(orders.getWorkType()) +" | " + orders.getCategoryName());
|
if(Constants.equalsInteger(orders.getWorkType(),Constants.ZERO)){
|
if(Objects.nonNull(orders.getPriceNum1())){
|
orders.setOrderContent(orders.getOrderContent()+" | " +orders.getPriceNum1()+"斤");
|
}
|
}else if(Constants.equalsInteger(orders.getWorkType(),Constants.ONE)){
|
if(Objects.nonNull(orders.getPriceNum2())) {
|
orders.setOrderContent(orders.getOrderContent() + " | " + orders.getPriceNum2() + "人");
|
}
|
}else{
|
if(Constants.equalsInteger(orders.getCarType(),Constants.ZERO)||Constants.equalsInteger(orders.getCarType(),Constants.ONE)){
|
if(Objects.nonNull(orders.getPriceNum2())) {
|
orders.setOrderContent(orders.getOrderContent() + " | " + orders.getPriceNum2() + "人");
|
}
|
}else{
|
if(Objects.nonNull(orders.getPriceNum1())) {
|
orders.setOrderContent(orders.getOrderContent() + " | " + orders.getPriceNum1() + "斤");
|
}
|
}
|
}
|
}else if(Constants.equalsInteger(orders.getType(),Constants.ONE)){
|
if(org.apache.commons.lang3.StringUtils.isNotBlank(orders.getCategoryName())){
|
orders.setOrderContent( orders.getCategoryName() +
|
(StringUtils.isEmpty(orders.getTransportTypeName())?"":" | " + orders.getTransportTypeName() ) +
|
(Objects.isNull(orders.getTransportNum())?null:" | " + orders.getTransportNum() +"斤"));
|
}
|
|
if(Constants.equalsInteger(orders.getCarType(),Constants.ZERO)){
|
if(Objects.nonNull(orders.getPriceNum2())) {
|
orders.setOrderContent(orders.getOrderContent() + " | 用车" + orders.getPriceNum1() + "天");
|
}
|
}else{
|
if(Objects.nonNull(orders.getPriceNum2())) {
|
orders.setOrderContent(orders.getOrderContent() + " | 用车" + orders.getPriceNum1() + "次");
|
}
|
}
|
}else{
|
if(org.apache.commons.lang3.StringUtils.isNotBlank(orders.getWayInfo())){
|
List<CateringDTO> cateringDTOList = JSONArray.parseArray(orders.getWayInfo(),CateringDTO.class);
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(cateringDTOList)){
|
for (CateringDTO cateringDTO:cateringDTOList) {
|
if(StringUtils.isEmpty(orders.getOrderContent())){
|
orders.setOrderContent(cateringDTO.getName()+cateringDTO.getPrice()+" 需"+cateringDTO.getNum()+"份");
|
}else{
|
orders.setOrderContent(orders.getOrderContent()+" | "+cateringDTO.getName()+cateringDTO.getPrice()+" 需"+cateringDTO.getNum()+"份");
|
}
|
}
|
}
|
}
|
}
|
|
}
|
|
|
|
@Override
|
public long count(Orders orders) {
|
QueryWrapper<Orders> wrapper = new QueryWrapper<>(orders);
|
return ordersMapper.selectCount(wrapper);
|
}
|
|
|
/**
|
* 手动接单
|
* @param orderId
|
*/
|
@Override
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public void accept(Integer orderId,Member member){
|
Orders orders = ordersMapper.selectById(orderId);
|
if(Objects.isNull(orders)||Constants.equalsInteger(orders.getDeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.wait.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行该操作");
|
}
|
if(Constants.equalsInteger(orders.getReleaseMemberId(),member.getId())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"您自己的订单无法进行该操作");
|
}
|
member = memberMapper.selectById(member.getId());
|
//查询用户是否有对应身份
|
if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){
|
if(!Constants.equalsInteger(member.getWorkerIdentity(),Constants.TWO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"身份信息异常，请前往个人中心进行身份认证!");
|
}
|
}else if(Constants.equalsInteger(orders.getType(),Constants.ONE)){
|
if(!Constants.equalsInteger(member.getDriverIdentity(),Constants.TWO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"身份信息异常，请前往个人中心进行身份认证!");
|
}
|
}else{
|
if(!Constants.equalsInteger(member.getChefIdentity(),Constants.TWO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"身份信息异常，请前往个人中心进行身份认证!");
|
}
|
}
|
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda().eq(Orders::getId,orders.getId())
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getAcceptType,Constants.ZERO)
|
.set(Orders::getAcceptTime,new Date())
|
.set(Orders::getAcceptMemberId,member.getId())
|
.set(Orders::getStatus,Constants.ordersStatus.accept.getKey())
|
);
|
|
|
|
//更新接单量
|
memberMapper.update(new UpdateWrapper<Member>().lambda().setSql(" publish_num = (publish_num + 1 )").eq(Member::getId,member.getId()));
|
|
//创建操作日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.RECEIVE;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),member.getId(),null);
|
|
//TODO 微信公众号提醒 已接单提醒
|
|
|
|
}
|
|
|
/**
|
* 开始作业
|
* @param orderId
|
* @param member
|
*/
|
@Override
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public void begin(Integer orderId,Member member){
|
Orders orders = ordersMapper.selectById(orderId);
|
if(Objects.isNull(orders)||Constants.equalsInteger(orders.getDeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.accept.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行该操作");
|
}
|
if(!Constants.equalsInteger(orders.getReleaseMemberId(),member.getId())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作");
|
}
|
if(Constants.equalsInteger(orders.getIsUpdate(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单修改待确认，无法进行该操作");
|
}
|
orders.setUpdateTime(new Date());
|
orders.setStatus(Constants.ordersStatus.doing.getKey());
|
orders.setWorkStartTime(new Date());
|
ordersMapper.updateById(orders);
|
|
//创建操作日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.BEGIN;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),member.getId(),null);
|
}
|
|
|
/**
|
* 发单方修改订单 - 已接单状态
|
*/
|
// @Override
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public void updOrderData(Orders orders,Orders model){
|
if(Objects.isNull(orders)
|
|| Objects.isNull(orders.getStartDate())
|
|| Objects.isNull(orders.getEndDate())){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
model.setTotalDays(DateUtil.daysBetweenDates(orders.getEndDate(),orders.getStartDate())+1);
|
model.setStartDate(orders.getStartDate());
|
model.setEndDate(orders.getEndDate());
|
//用车类型
|
if(Constants.equalsInteger(model.getType(),Constants.ONE)){
|
if(Constants.equalsInteger(model.getCarType(),Constants.ZERO)) {
|
model.setPriceNum1(orders.getTotalDays());
|
}
|
}else if(Constants.equalsInteger(model.getType(),Constants.ZERO)){
|
if(Constants.equalsInteger(model.getWorkType(),Constants.ONE)||
|
(Constants.equalsInteger(model.getWorkType(),Constants.TWO)&&Constants.equalsInteger(model.getCarType(),Constants.ZERO))){
|
model.setPriceNum1(orders.getTotalDays());
|
}
|
}else{
|
model.setPriceNum1(orders.getTotalDays());
|
}
|
Long total = this.getTotal(orders);
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getStartDate,model.getStartDate())
|
.set(Orders::getEndDate,model.getEndDate())
|
.set(Orders::getTotalDays,model.getTotalDays())
|
.set(Orders::getIsUpdate,Constants.ONE)
|
.set(Orders::getIsUpdateTime,new Date())
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getEstimatedAccount,total)
|
.eq(Orders::getId,orders.getId())
|
);
|
//创建操作日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.UPD_ORDER;
|
this.saveOrderLog(model,ordersLog,
|
ordersLog.getInfo(),orders.getMember().getId(),null);
|
|
//TODO 通知接单人 订单发生变更
|
}
|
|
|
@Override
|
public Long getTotal(Orders orders){
|
if(Objects.isNull(orders)
|
||Objects.isNull(orders.getPrice())
|
||Objects.isNull(orders.getPriceNum1())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
if(
|
(Constants.equalsInteger(orders.getType(),Constants.ZERO) && Constants.equalsInteger(orders.getWorkType(),Constants.ZERO ))
|
|| Constants.equalsInteger(orders.getType(),Constants.ONE)
|
|| Constants.equalsInteger(orders.getType(),Constants.TWO)
|
){
|
orders.setPriceNum2(Constants.ONE);
|
}else{
|
if(Objects.isNull(orders.getPriceNum2())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
}
|
return orders.getPrice() * orders.getPriceNum1() * orders.getPriceNum2();
|
}
|
|
|
/**
|
* 接单方处理订单修改
|
* @param confirmUpdOrderDTO
|
*/
|
@Override
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public void confirmUpd(ConfirmUpdOrderDTO confirmUpdOrderDTO){
|
if(Objects.isNull(confirmUpdOrderDTO)
|
|| Objects.isNull(confirmUpdOrderDTO.getOrderId())
|
|| Objects.isNull(confirmUpdOrderDTO.getStatus())
|
|| !(Constants.equalsInteger(confirmUpdOrderDTO.getStatus(),Constants.ONE)||
|
Constants.equalsInteger(confirmUpdOrderDTO.getStatus(),Constants.ZERO))
|
){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
Orders orders = ordersMapper.selectById(confirmUpdOrderDTO.getOrderId());
|
if(Objects.isNull(orders)||Constants.equalsInteger(orders.getDeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.accept.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行该操作");
|
}
|
if(!Constants.equalsInteger(orders.getIsUpdate(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单修改状态已流转，无法进行该操作");
|
}
|
if(!Constants.equalsInteger(orders.getAcceptMemberId(),confirmUpdOrderDTO.getMember().getId())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作");
|
}
|
if(!Constants.equalsInteger(confirmUpdOrderDTO.getStatus(),Constants.ONE)){
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getIsUpdate,Constants.TWO)
|
.set(Orders::getUpdateTime,new Date())
|
.eq(Orders::getId,orders.getId())
|
);
|
//记录同意修改的日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.UPD_AGREE;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),confirmUpdOrderDTO.getMember().getId(),null);
|
}else{
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getIsUpdate,Constants.TWO)
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getStatus,Constants.ordersStatus.wait.getKey())
|
.set(Orders::getAcceptMemberId,null)
|
.set(Orders::getAcceptType,null)
|
.eq(Orders::getId,orders.getId())
|
);
|
|
memberMapper.update(new UpdateWrapper<Member>().lambda().setSql("receive_num = receive_num - 1").eq(Member::getId,confirmUpdOrderDTO.getMember().getId()));
|
|
//记录不同意修改的日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.UPD_DISAGREE;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),confirmUpdOrderDTO.getMember().getId(),null);
|
//TODO 发送不同意变更通知
|
}
|
}
|
|
|
@Override
|
public void cancelOrder(Integer orderId,Member member){
|
Orders orders = ordersMapper.selectById(orderId);
|
if(Objects.isNull(orders)||Constants.equalsInteger(orders.getDeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(Constants.equalsInteger(orders.getReleaseMemberId(),member.getId())){
|
this.releaseCancelOrder(orders,member);
|
}else if(Constants.equalsInteger(orders.getAcceptMemberId(),member.getId())){
|
this.receiveCancelOrder(orders,member);
|
}else{
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作");
|
}
|
|
}
|
|
|
|
/**
|
* 发单方取消订单
|
* @param member
|
*/
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public void releaseCancelOrder(Orders orders,Member member){
|
if(!(Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.wait.getKey())
|
||Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.waitPay.getKey())
|
|| Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.accept.getKey()))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行取消");
|
}
|
if(!Constants.equalsInteger(orders.getReleaseMemberId(),member.getId())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作");
|
}
|
//待支付用餐订单/待接单订单进行取消
|
if(Constants.equalsInteger(orders.getStatus(),Constants.ONE)
|
||Constants.equalsInteger(orders.getStatus(),Constants.ZERO)){
|
if(Constants.equalsInteger(orders.getType(),Constants.TWO)&&Constants.equalsInteger(orders.getStatus(),Constants.ONE)){
|
//退款业务
|
WithdrawalOrders withdrawalOrders = new WithdrawalOrders();
|
withdrawalOrders.setCreateTime(new Date());
|
withdrawalOrders.setMemberId(orders.getReleaseMemberId());
|
withdrawalOrders.setAmount(orders.getPayAccount());
|
withdrawalOrders.setStatus(Constants.ZERO);
|
withdrawalOrders.setDoneTime(new Date());
|
withdrawalOrders.setType(Constants.ONE);
|
withdrawalOrders.setObjId(orders.getId());
|
wxMiniUtilService.wxRefund(withdrawalOrders,orders);
|
}
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getStatus,Constants.ordersStatus.cancel.getKey())
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getCancelTime,new Date())
|
.set(Orders::getCancelType,Constants.ZERO)
|
.eq(Orders::getId,orders.getId())
|
);
|
}else{
|
//判断是否可修改 已取消次数 与 时间限制
|
Integer totalCancelTimes = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RELEASE_CANCEL_TIMES).getCode());
|
Long cancelTimes = ordersMapper.selectCount(new QueryWrapper<Orders>().lambda()
|
.apply(" DATE(cancel_time) = DATE(NOW()) ")
|
.eq(Orders::getStatus,Constants.ordersStatus.cancel.getKey())
|
.eq(Orders::getReleaseMemberId,orders.getReleaseMemberId()));
|
//查询取消次数
|
if(totalCancelTimes<=cancelTimes){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"今日订单主动取消次数已超出"+totalCancelTimes+"次,无法取消订单,如需处理请联系客服");
|
}
|
|
Integer cancelTimeHour = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RELEASE_CANCEL_TIME).getCode());
|
Long hours = DateUtil.getBetweenHours(new Date(),orders.getStartDate());
|
if(hours < cancelTimeHour){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"距离订单开始时间不足"+cancelTimeHour+"小时,无法取消订单，如需处理请联系客服");
|
}
|
|
if(Constants.equalsInteger(orders.getType(),Constants.TWO)){
|
//退款业务
|
WithdrawalOrders withdrawalOrders = new WithdrawalOrders();
|
withdrawalOrders.setCreateTime(new Date());
|
withdrawalOrders.setMemberId(orders.getReleaseMemberId());
|
withdrawalOrders.setAmount(orders.getPayAccount());
|
withdrawalOrders.setWxExternalNo("refund_"+orders.getCode());
|
withdrawalOrders.setStatus(Constants.ONE);
|
withdrawalOrders.setDoneTime(new Date());
|
withdrawalOrders.setType(Constants.ONE);
|
withdrawalOrders.setObjId(orders.getId());
|
wxMiniUtilService.wxRefund(withdrawalOrders,orders);
|
}
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getStatus,Constants.ordersStatus.cancel.getKey())
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getCancelTime,new Date())
|
.set(Orders::getCancelType,Constants.ONE)
|
.eq(Orders::getId,orders.getId())
|
);
|
//TODO 发单方取消订单通知接单方
|
|
//减少接单量
|
memberMapper.update(new UpdateWrapper<Member>().lambda().setSql("receive_num = (receive_num - 1) ").eq(Member::getId,orders.getAcceptMemberId()));
|
}
|
//减少发单量
|
memberMapper.update(new UpdateWrapper<Member>().lambda().setSql("publish_num = (publish_num - 1)").eq(Member::getId,orders.getReleaseMemberId()));
|
|
//日志存储
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.RELEASE_CANCEL;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),member.getId(),null);
|
}
|
|
|
/**
|
* 接单方取消接单
|
* @param member
|
*/
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public void receiveCancelOrder(Orders orders,Member member){
|
if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.accept.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行取消");
|
}
|
if(!Constants.equalsInteger(orders.getAcceptMemberId(),member.getId())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作");
|
}
|
//判断是否可修改 已取消次数 与 时间限制
|
Integer totalCancelTimes = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RECEIVE_CANCEL_TIMES).getCode());
|
Long cancelTimes = orderLogMapper.selectCount(new QueryWrapper<OrderLog>().lambda()
|
.apply(" DATE(create_time) = DATE(NOW()) ")
|
.eq(OrderLog::getObjType,Constants.OrdersLog.CANCEL.getKey())
|
.eq(OrderLog::getMemberId,member.getId()));
|
//查询取消次数
|
if(totalCancelTimes<=cancelTimes){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"今日订单主动取消次数已超出"+totalCancelTimes+"次,无法取消订单,如需处理请联系客服");
|
}
|
|
Integer cancelTimeHour = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RECEIVE_CANCEL_TIME).getCode());
|
Long hours = DateUtil.getBetweenHours(new Date(),orders.getStartDate());
|
if(hours < cancelTimeHour){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"距离订单开始时间不足"+cancelTimeHour+"小时,无法取消订单，如需处理请联系客服");
|
}
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getStatus,Constants.ordersStatus.wait.getKey())
|
.set(Orders::getAcceptMemberId,null)
|
.set(Orders::getAcceptType,null)
|
.eq(Orders::getId,orders.getId())
|
);
|
|
//减少接单量
|
memberMapper.update(new UpdateWrapper<Member>().lambda().setSql(" receive_num = receive_num - 1 ").eq(Member::getId,orders.getAcceptMemberId()));
|
//日志存储
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.CANCEL;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),member.getId(),null);
|
|
//TODO 接单方取消订单通知
|
|
}
|
|
|
/**
|
* 完成订单
|
* @param doneOrderDTO
|
*/
|
@Override
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public OrderReleaseVO doneOrder(DoneOrderDTO doneOrderDTO){
|
if(Objects.isNull(doneOrderDTO)||Objects.isNull(doneOrderDTO.getOrderId())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Orders orders = ordersMapper.selectById(doneOrderDTO.getOrderId());
|
if(!Constants.equalsInteger(orders.getType(),Constants.TWO)&&Objects.isNull(doneOrderDTO.getAmount())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
if(Objects.isNull(orders)||Constants.equalsInteger(orders.getDeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.doing.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行取消");
|
}
|
if(!Constants.equalsInteger(orders.getReleaseMemberId(),doneOrderDTO.getMember().getId())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作");
|
}
|
OrderReleaseVO orderReleaseVO = new OrderReleaseVO();
|
orderReleaseVO.setId(orders.getId());
|
Object object = null;
|
//用餐订单
|
if(!Constants.equalsInteger(orders.getType(),Constants.TWO)){
|
orders.setPayAccount(doneOrderDTO.getAmount());
|
//提成金额
|
Long tcje = Long.valueOf(new BigDecimal(orders.getPayAccount().toString()).multiply(orders.getPlatformRata()).intValue());
|
orders.setReceiveAccount(orders.getPayAccount() - tcje);
|
orders.setOutTradeNo(UUID.randomUUID().toString().replace("-",""));
|
ordersMapper.updateById(orders);
|
//唤起支付业务
|
object = this.getWxPayResponse(orders,doneOrderDTO.getMember().getOpenid());
|
orderReleaseVO.setObject(object);
|
}else{
|
orders.setStatus(Constants.ordersStatus.done.getKey());
|
orders.setFinishTime(new Date());
|
ordersMapper.updateById(orders);
|
|
Member member = memberMapper.selectById(orders.getAcceptMemberId());
|
|
//存储流水记录
|
MemberRevenue memberRevenue = new MemberRevenue();
|
memberRevenue.setCreateTime(new Date());
|
memberRevenue.setMemberId(orders.getAcceptMemberId());
|
memberRevenue.setType(orders.getType());
|
memberRevenue.setOptType(Constants.ONE);
|
memberRevenue.setBeforeAmount(member.getAmount());
|
memberRevenue.setAmount(orders.getReceiveAccount());
|
memberRevenue.setAfterAmount(member.getAmount() + orders.getReceiveAccount());
|
if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){
|
memberRevenue.setRemark(Constants.RevenueType.getInfo(memberRevenue.getType()) + "-" +
|
(Constants.equalsInteger(orders.getWorkType(),Constants.ZERO)?"采摘工":(Constants.equalsInteger(orders.getWorkType(),Constants.ONE)?"分拣工":"包装工")));
|
}else{
|
memberRevenue.setRemark(Constants.RevenueType.getInfo(memberRevenue.getType()));
|
}
|
memberRevenue.setObjId(orders.getId());
|
memberRevenue.setObjType(Constants.ZERO);
|
memberRevenue.setStatus(Constants.ZERO);
|
memberRevenueMapper.insert(memberRevenue);
|
|
//日志存储
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.DONE;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),doneOrderDTO.getMember().getId(),null);
|
}
|
return orderReleaseVO;
|
}
|
|
|
|
@Override
|
public OrderReleaseVO reusePay(ReusePayDTO reusePayDTO){
|
if(Objects.isNull(reusePayDTO)||Objects.isNull(reusePayDTO.getOrderId())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Orders orders = ordersMapper.selectById(reusePayDTO.getOrderId());
|
if(Objects.isNull(orders)||Constants.equalsInteger(orders.getDeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(orders.getType(),Constants.TWO)&&Objects.isNull(reusePayDTO.getAmount())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
|
if(!((( Constants.equalsInteger(orders.getType(),Constants.TWO) && Constants.equalsInteger(orders.getStatus(),Constants.ZERO) )
|
|| ( !Constants.equalsInteger(orders.getType(),Constants.TWO) && Constants.equalsInteger(orders.getStatus(),Constants.THREE) ))
|
&& Constants.equalsInteger(orders.getPayStatus(),Constants.ZERO) )){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转");
|
}
|
OrderReleaseVO orderReleaseVO = new OrderReleaseVO();
|
if(!Constants.equalsInteger(orders.getType(),Constants.TWO)){
|
orders.setPayAccount(reusePayDTO.getAmount());
|
//提成金额
|
Long tcje = Long.valueOf(new BigDecimal(orders.getPayAccount().toString()).multiply(orders.getPlatformRata()).intValue());
|
orders.setReceiveAccount(orders.getPayAccount() - tcje);
|
}
|
orders.setOutTradeNo(UUID.randomUUID().toString().replace("-",""));
|
ordersMapper.updateById(orders);
|
//唤起支付业务
|
Object object = this.getWxPayResponse(orders,orders.getMember().getOpenid());
|
orderReleaseVO.setObject(object);
|
orderReleaseVO.setId(orders.getId());
|
return orderReleaseVO;
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public void platformCancel(Integer orderId, LoginUserInfo loginUserInfo){
|
Orders orders = ordersMapper.selectById(orderId);
|
if(Objects.isNull(orders)||Constants.equalsInteger(orders.getDeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!(Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.wait.getKey())||Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.accept.getKey())
|
||Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.doing.getKey())||Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.waitPay.getKey()))){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行取消");
|
}
|
//如果已支付 则需要进行退款
|
if(Constants.equalsInteger(orders.getPayStatus(),Constants.ONE)){
|
WithdrawalOrders withdrawalOrders = new WithdrawalOrders();
|
withdrawalOrders.setCreateTime(new Date());
|
withdrawalOrders.setMemberId(orders.getReleaseMemberId());
|
withdrawalOrders.setAmount(orders.getPayAccount());
|
withdrawalOrders.setWxExternalNo("refund_"+orders.getCode());
|
withdrawalOrders.setStatus(Constants.ONE);
|
withdrawalOrders.setDoneTime(new Date());
|
withdrawalOrders.setType(Constants.ONE);
|
withdrawalOrders.setObjId(orders.getId());
|
wxMiniUtilService.wxRefund(withdrawalOrders,orders);
|
}
|
|
//减少发单量
|
memberMapper.update(new UpdateWrapper<Member>().lambda()
|
.setSql("publish_num = ifnull(publish_num,0) - 1")
|
.eq(Member::getId,orders.getReleaseMemberId()));
|
|
if(Constants.equalsInteger(orders.getStatus(),Constants.TWO)||Constants.equalsInteger(orders.getStatus(),Constants.THREE)){
|
//减少接单量
|
memberMapper.update(new UpdateWrapper<Member>().lambda()
|
.setSql("receive_num = ifnull(receive_num,0) - 1")
|
.eq(Member::getId,orders.getAcceptMemberId()));
|
}
|
Date date = new Date();
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getStatus,Constants.ordersStatus.cancel.getKey())
|
.set(Orders::getUpdateTime,date)
|
.set(Orders::getCancelTime,date)
|
.set(Orders::getCancelType,Constants.TWO)
|
.eq(Orders::getId,orders.getId())
|
);
|
|
//日志存储
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.SYSTEM_CANCEL;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),null,loginUserInfo.getId());
|
}
|
|
|
|
|
@Override
|
public void comment(CommentDTO commentDTO){
|
if(Objects.isNull(commentDTO)
|
|| Objects.isNull(commentDTO.getOrderId())
|
|| Objects.isNull(commentDTO.getLevel())
|
|| commentDTO.getLevel()<1 || commentDTO.getLevel() > 5 ){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Orders orders = ordersMapper.selectById(commentDTO.getOrderId());
|
if(Objects.isNull(orders)
|
||Constants.equalsInteger(orders.getDeleted(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.done.getKey())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行评价");
|
}
|
if(Constants.equalsInteger(orders.getCommentStatus(),Constants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单已评价！");
|
}
|
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getCommentStatus,Constants.ONE)
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getCommentTime,new Date())
|
.set(Orders::getCommentLevel,commentDTO.getLevel())
|
.set(org.apache.commons.lang3.StringUtils.isNotBlank(commentDTO.getInfo()),Orders::getCommentInfo,commentDTO.getInfo())
|
.set(Orders::getCommentType,Constants.ZERO)
|
.eq(Orders::getId,orders.getId())
|
);
|
memberMapper.update(new UpdateWrapper<Member>().lambda()
|
.setSql(" score = ( total_score +" + commentDTO.getLevel() + " ) / (score_order_num + 1 )")
|
.setSql(" total_score = total_score +" + commentDTO.getLevel())
|
.setSql(" score_order_num = score_order_num + 1 " ).eq(Member::getId,orders.getAcceptMemberId())
|
);
|
//日志存储
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.COMMENT;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),orders.getAcceptMemberId(),null);
|
}
|
|
|
/**
|
* 支付回调
|
* @param preOrderId
|
* @param paymentNo
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
|
public String payNotify(String preOrderId,String paymentNo){
|
Orders orders = ordersMapper.selectOne(new QueryWrapper<Orders>().lambda().eq(Orders::getOutTradeNo,preOrderId).last("limit 1"));
|
if(Constants.equalsInteger(orders.getType(),Constants.TWO)){
|
//用餐订单 如果已经流转到已支付 则直接返回
|
if(!Constants.equalsInteger(orders.getStatus(),Constants.ZERO)){
|
return ("处理成功!");
|
}else{
|
//处理支付完成逻辑
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getStatus,Constants.ordersStatus.wait.getKey())
|
.set(Orders::getPayStatus,Constants.ONE)
|
.set(Orders::getPayTime,new Date())
|
.set(Orders::getPayMethod,Constants.ZERO)
|
.set(Orders::getWxExternalNo,paymentNo)
|
.eq(Orders::getId,orders.getId())
|
);
|
|
//存储日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.PAY;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),orders.getReleaseMemberId(),null);
|
}
|
}else{
|
//非用餐类订单
|
if(!Constants.equalsInteger(orders.getStatus(),Constants.THREE)){
|
return ("处理成功!");
|
}else{
|
//处理支付完成逻辑
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getStatus,Constants.FOUR)
|
.set(Orders::getPayStatus,Constants.ONE)
|
.set(Orders::getPayTime,new Date())
|
.set(Orders::getPayMethod,Constants.ZERO)
|
.set(Orders::getWxExternalNo,paymentNo)
|
.set(Orders::getFinishTime,new Date())
|
.eq(Orders::getId,orders.getId())
|
);
|
|
Member member = memberMapper.selectById(orders.getAcceptMemberId());
|
//存储流水记录
|
MemberRevenue memberRevenue = new MemberRevenue();
|
memberRevenue.setCreateTime(new Date());
|
memberRevenue.setDeleted(Constants.ZERO);
|
memberRevenue.setTransactionNo(orders.getCode());
|
memberRevenue.setMemberId(orders.getAcceptMemberId());
|
memberRevenue.setType(orders.getType());
|
memberRevenue.setOptType(Constants.ONE);
|
memberRevenue.setBeforeAmount(member.getAmount());
|
memberRevenue.setAmount(orders.getReceiveAccount());
|
memberRevenue.setAfterAmount(member.getAmount() + orders.getReceiveAccount());
|
if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){
|
memberRevenue.setRemark(Constants.RevenueType.getInfo(memberRevenue.getType()) + "-" +
|
(Constants.equalsInteger(orders.getWorkType(),Constants.ZERO)?"采摘工":(Constants.equalsInteger(orders.getWorkType(),Constants.ONE)?"分拣工":"包装工")));
|
}else{
|
memberRevenue.setRemark(Constants.RevenueType.getInfo(memberRevenue.getType()));
|
}
|
memberRevenue.setObjId(orders.getId());
|
memberRevenue.setObjType(Constants.ZERO);
|
memberRevenue.setStatus(Constants.ZERO);
|
memberRevenueMapper.insert(memberRevenue);
|
|
//更新接单用户的余额与历史总金额
|
memberMapper.update(new UpdateWrapper<Member>().lambda()
|
.setSql(" amount = ( amount + " + orders.getReceiveAccount() +")" )
|
.setSql(" total_amount = ( amount + " + orders.getReceiveAccount() + ")" )
|
.eq(Member::getId,member.getId())
|
);
|
|
//存储日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.PAY;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),orders.getReleaseMemberId(),null);
|
|
//TODO 通知接单方 款项已到账
|
|
}
|
}
|
return ("处理成功!");
|
}
|
|
|
@Override
|
public PageData<Orders> findPageForMini(PageWrap<Orders> pageWrap) {
|
IPage<Orders> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<Orders> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
Orders model = pageWrap.getModel();
|
if(Objects.isNull(model)
|
|| Objects.isNull(model.getQueryLat())
|
|| Objects.isNull(model.getQueryLgt())
|
|| Objects.isNull(model.getQueryMyOrderType())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
BigDecimal chefLat = model.getQueryLat();
|
BigDecimal chefLgt = model.getQueryLgt();
|
BigDecimal driverLat = model.getQueryLat();
|
BigDecimal driverLgt = model.getQueryLgt();
|
BigDecimal workerLat = model.getQueryLat();
|
BigDecimal workerLgt = model.getQueryLgt();
|
IdentityInfo wokerIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper<IdentityInfo>().lambda()
|
.eq(IdentityInfo::getMemberId,model.getMember().getId())
|
.eq(IdentityInfo::getType,Constants.ZERO)
|
.eq(IdentityInfo::getAuditStatus,Constants.TWO)
|
.last("limit 1")
|
);
|
if(Objects.nonNull(wokerIdentityInfo)){
|
workerLat = wokerIdentityInfo.getLat();
|
workerLgt = wokerIdentityInfo.getLgt();
|
}
|
IdentityInfo driverIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper<IdentityInfo>().lambda()
|
.eq(IdentityInfo::getMemberId,model.getMember().getId())
|
.eq(IdentityInfo::getType,Constants.ONE)
|
.eq(IdentityInfo::getAuditStatus,Constants.TWO)
|
.last("limit 1")
|
);
|
if(Objects.nonNull(driverIdentityInfo)){
|
driverLat = driverIdentityInfo.getLat();
|
driverLgt = driverIdentityInfo.getLgt();
|
}
|
IdentityInfo chefIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper<IdentityInfo>().lambda()
|
.eq(IdentityInfo::getMemberId,model.getMember().getId())
|
.eq(IdentityInfo::getType,Constants.TWO)
|
.eq(IdentityInfo::getAuditStatus,Constants.TWO)
|
.last("limit 1")
|
);
|
if(Objects.nonNull(chefIdentityInfo)){
|
chefLat = chefIdentityInfo.getLat();
|
chefLgt = chefIdentityInfo.getLgt();
|
}
|
queryWrapper.selectAll(Orders.class)
|
.select("c1.name",Orders::getCategoryName)
|
.select("c2.name",Orders::getTransportTypeName)
|
.leftJoin(" category c1 on t.category_id = c1.id ")
|
.leftJoin(" category c2 on t.TRANSPORT_TYPE_ID = c2.id ")
|
.select(" case when T.LGT IS NULL OR T.LAT IS NULL THEN 0 " +
|
" when t.TYPE = 0 then CONVERT( ST_Distance_Sphere ( POINT ( t.LGT, t.LAT ), POINT ( "+workerLgt+", "+workerLat+" )) /1000,DECIMAL(15,2)) " +
|
" when t.TYPE = 1 then CONVERT( ST_Distance_Sphere ( POINT ( t.LGT, t.LAT ), POINT ( "+driverLgt+", "+driverLat+" )) /1000,DECIMAL(15,2)) " +
|
" else CONVERT( ST_Distance_Sphere ( POINT ( t.LGT, t.LAT ), POINT ( "+chefLgt+", "+chefLat+" )) /1000,DECIMAL(15,2)) end " , Orders::getDistance)
|
.eq(Objects.nonNull(model.getType()),Orders::getType,model.getType());
|
if(Objects.nonNull(model.getQueryMyOrderType())){
|
if(Constants.equalsInteger(model.getQueryMyOrderType(),Constants.ZERO)){
|
//发单方 我的订单
|
queryWrapper.eq(Orders::getReleaseMemberId,model.getMember().getId());
|
queryWrapper.eq(Objects.nonNull(model.getStatus()),Orders::getStatus,model.getStatus());
|
queryWrapper.orderByDesc(Orders::getCreateTime);
|
}else if(Constants.equalsInteger(model.getQueryMyOrderType(),Constants.ONE)){
|
//接单方 我的订单
|
queryWrapper.eq(Orders::getAcceptMemberId,model.getMember().getId());
|
queryWrapper.eq(Objects.nonNull(model.getStatus()),Orders::getStatus,model.getStatus());
|
queryWrapper.orderByDesc(Orders::getAcceptTime);
|
}else{
|
//查询用户的接单权重
|
ReceiveWeight receiveWeight = receiveWeightMapper.selectOne(new QueryWrapper<ReceiveWeight>().lambda().eq(ReceiveWeight::getDeleted,Constants.ZERO).apply(" RECEIVE_MIN < "+model.getMember().getReceiveNum()+" and RECEIVE_MAX > " + model.getMember().getReceiveNum()).last(" limit 1 "));
|
if(Objects.nonNull(receiveWeight)){
|
queryWrapper.apply(" DATE_ADD(t.CREATE_TIME, INTERVAL "+receiveWeight.getDelayTime()+" MINUTE) < now() ");
|
}
|
queryWrapper.eq(Orders::getStatus,Constants.ordersStatus.wait.getKey());
|
queryWrapper.ne(Orders::getReleaseMemberId,model.getMember().getId());
|
if(Objects.nonNull(model.getSortType())){
|
if(Constants.equalsInteger(model.getSortType(),Constants.ZERO)){
|
queryWrapper.orderByDesc(Orders::getCreateTime);
|
}else if(Constants.equalsInteger(model.getSortType(),Constants.ONE)){
|
queryWrapper.orderByAsc(" distance ");
|
}else{
|
queryWrapper.orderByDesc(Orders::getEstimatedAccount);
|
}
|
}
|
}
|
}
|
IPage<Orders> iPage = ordersMapper.selectJoinPage(page,Orders.class,queryWrapper);
|
for (Orders orders:iPage.getRecords()) {
|
this.getPriceUnit(orders);
|
}
|
// if(Objects.nonNull(model.getQueryMyOrderType())&&Constants.equalsInteger(model.getQueryMyOrderType(),Constants.TWO)){
|
// if(Constants.equalsInteger(model.getMember().getUseIdentity(),Constants.ONE)){
|
// model.getMember().setWorkerIdentityModel(
|
// identityInfoMapper.selectOne(new QueryWrapper<IdentityInfo>().lambda()
|
// .eq(IdentityInfo::getMemberId,model.getMember().getId())
|
// .eq(IdentityInfo::getType,Constants.ZERO)
|
// .eq(IdentityInfo::getAuditStatus,Constants.TWO)
|
// .last("limit 1")
|
// )
|
// );
|
// model.getMember().setDriverIdentityModel(
|
// identityInfoMapper.selectOne(new QueryWrapper<IdentityInfo>().lambda()
|
// .eq(IdentityInfo::getMemberId,model.getMember().getId())
|
// .eq(IdentityInfo::getType,Constants.ONE)
|
// .eq(IdentityInfo::getAuditStatus,Constants.TWO)
|
// .last("limit 1")
|
// )
|
// );
|
// model.getMember().setChefIdentityModel(
|
// identityInfoMapper.selectOne(new QueryWrapper<IdentityInfo>().lambda()
|
// .eq(IdentityInfo::getMemberId,model.getMember().getId())
|
// .eq(IdentityInfo::getType,Constants.TWO)
|
// .eq(IdentityInfo::getAuditStatus,Constants.TWO)
|
// .last("limit 1")
|
// )
|
// );
|
// }
|
// for (Orders orders:iPage.getRecords()) {
|
// this.getDistance(model.getMember(),orders);
|
// }
|
// }
|
return PageData.from(iPage);
|
}
|
|
|
|
|
//定位距离
|
public void getDistance(Member member,Orders orders){
|
try{
|
if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){
|
if(Objects.nonNull(member.getWorkerIdentityModel())&&Objects.nonNull(member.getWorkerIdentityModel().getLgt())
|
&&Objects.nonNull(member.getWorkerIdentityModel().getLat())){
|
orders.setDistance(
|
GeoUtils.haversineDistance(
|
orders.getLgt().doubleValue(),orders.getLat().doubleValue(),
|
member.getWorkerIdentityModel().getLgt().doubleValue(),
|
member.getWorkerIdentityModel().getLat().doubleValue()
|
)
|
);
|
}
|
|
}else if(Constants.equalsInteger(orders.getType(),Constants.ONE)){
|
if(Objects.nonNull(member.getDriverIdentityModel())&&Objects.nonNull(member.getDriverIdentityModel().getLgt())
|
&&Objects.nonNull(member.getDriverIdentityModel().getLat())) {
|
orders.setDistance(
|
GeoUtils.haversineDistance(
|
orders.getLgt().doubleValue(), orders.getLat().doubleValue(),
|
member.getDriverIdentityModel().getLgt().doubleValue(),
|
member.getDriverIdentityModel().getLat().doubleValue()
|
)
|
);
|
}
|
}else{
|
if(Objects.nonNull(member.getChefIdentityModel())&&Objects.nonNull(member.getChefIdentityModel().getLgt())
|
&&Objects.nonNull(member.getChefIdentityModel().getLat())) {
|
orders.setDistance(
|
GeoUtils.haversineDistance(
|
orders.getLgt().doubleValue(),orders.getLat().doubleValue(),
|
member.getChefIdentityModel().getLgt().doubleValue(),
|
member.getChefIdentityModel().getLat().doubleValue()
|
)
|
);
|
}
|
}
|
}catch (Exception e){
|
orders.setDistance(0L);
|
}
|
}
|
|
|
|
@Override
|
public Orders getDetail(Integer id,Member member) {
|
Orders orders = ordersMapper.selectJoinOne(Orders.class,new MPJLambdaWrapper<Orders>()
|
.selectAll(Orders.class)
|
.select(" m1.name " , Orders::getReleaseName)
|
.select(" m1.telephone " , Orders::getReleasePhone)
|
.select(" case when i.AUTH_TYPE = 0 then i.LINK_NAME else i.COMPANY_NAME end " , Orders::getAcceptName)
|
.select(" i.TELEPHONE " , Orders::getAcceptPhone)
|
.select("c1.name",Orders::getCategoryName)
|
.select("c2.name",Orders::getTransportTypeName)
|
.select(" m2.SCORE " , Orders::getScore)
|
.select(" m1.PUBLISH_NUM " , Orders::getPublishNum)
|
.select(" m2.RECEIVE_NUM " , Orders::getReceiveNum)
|
.select(" m1.COVER_IMAGE " , Orders::getReleaseCoverImage)
|
.select(" m2.COVER_IMAGE " , Orders::getAcceptCoverImage)
|
.leftJoin(" category c1 on t.category_id = c1.id ")
|
.leftJoin(" category c2 on t.TRANSPORT_TYPE_ID = c2.id ")
|
.leftJoin("member m1 on t.RELEASE_MEMBER_ID = m1.id ")
|
.leftJoin("member m2 on t.ACCEPT_MEMBER_ID = m2.id ")
|
.leftJoin("identity_info i on m2.id = i.MEMBER_ID and i.TYPE = t.type and i.AUDIT_STATUS = 2 ")
|
|
.eq(Orders::getId,id)
|
);
|
if(Objects.isNull(orders)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
//头像信息
|
String coverPath = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RESOURCE_PATH).getCode()
|
+systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.MEMBER_FILES).getCode();
|
if(org.apache.commons.lang3.StringUtils.isNotBlank(orders.getReleaseCoverImage())){
|
orders.setReleaseCoverImage(coverPath + orders.getReleaseCoverImage());
|
}
|
if(org.apache.commons.lang3.StringUtils.isNotBlank(orders.getAcceptCoverImage())){
|
orders.setAcceptCoverImage(coverPath + orders.getAcceptCoverImage());
|
}
|
List<Multifile> multifileList = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda().eq(Multifile::getObjId,orders.getId())
|
.eq(Multifile::getIsdeleted,Constants.ZERO).eq(Multifile::getObjType,Constants.ONE).orderByAsc(Multifile::getId));
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(multifileList)){
|
String path = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RESOURCE_PATH).getCode()
|
+systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.ORDERS_FILES).getCode();
|
for (Multifile multifile:multifileList) {
|
multifile.setFileurlFull(path + multifile.getFileurl());
|
}
|
orders.setMultifileList(multifileList);
|
}
|
orders.setStatusName(Constants.ordersStatus.getName(orders.getStatus()));
|
orders.setCancelStatus(Constants.ZERO);
|
this.getPriceUnit(orders);
|
if(orders.getStatus() <= Constants.ordersStatus.accept.getKey()){
|
if(Constants.equalsInteger(orders.getReleaseMemberId(),member.getId())){
|
//判断是否可修改 已取消次数 与 时间限制
|
Integer totalCancelTimes = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RELEASE_CANCEL_TIMES).getCode());
|
Long cancelTimes = ordersMapper.selectCount(new QueryWrapper<Orders>().lambda()
|
.apply(" DATE(cancel_time) = DATE(NOW()) ")
|
.eq(Orders::getStatus,Constants.ordersStatus.cancel.getKey())
|
.eq(Orders::getReleaseMemberId,orders.getReleaseMemberId()));
|
//查询取消次数
|
if(totalCancelTimes<=cancelTimes){
|
orders.setCancelStatus(Constants.ONE);
|
return orders;
|
}
|
Integer cancelTimeHour = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RELEASE_CANCEL_TIME).getCode());
|
Long hours = DateUtil.getBetweenHours(new Date(),orders.getStartDate());
|
if(hours < cancelTimeHour){
|
orders.setCancelStatus(Constants.ONE);
|
return orders;
|
}
|
}else if(Constants.equalsInteger(orders.getAcceptMemberId(),member.getId())){
|
//判断是否可修改 已取消次数 与 时间限制
|
Integer totalCancelTimes = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RECEIVE_CANCEL_TIMES).getCode());
|
Long cancelTimes = orderLogMapper.selectCount(new QueryWrapper<OrderLog>().lambda()
|
.apply(" DATE(create_time) = DATE(NOW()) ")
|
.eq(OrderLog::getObjType,Constants.OrdersLog.CANCEL.getKey())
|
.eq(OrderLog::getMemberId,member.getId()));
|
//查询取消次数
|
if(totalCancelTimes<=cancelTimes){
|
orders.setCancelStatus(Constants.ONE);
|
return orders;
|
}
|
|
Integer cancelTimeHour = Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RECEIVE_CANCEL_TIME).getCode());
|
Long hours = DateUtil.getBetweenHours(new Date(),orders.getStartDate());
|
if(hours < cancelTimeHour){
|
orders.setCancelStatus(Constants.ONE);
|
return orders;
|
}
|
}
|
} else{
|
orders.setCancelStatus(Constants.ONE);
|
}
|
return orders;
|
}
|
|
|
|
|
public synchronized String getNextCode(Integer type){
|
String prefix = "YG";
|
if(!Constants.equalsInteger(type,Constants.ZERO)){
|
prefix = (Constants.equalsInteger(type,Constants.ONE)?"YH-":"DC-");
|
}
|
prefix = prefix + DateUtil.getCurrDateTimeShort() +"-";
|
|
Integer countNum = (Integer) redisTemplate.opsForValue().get(Constants.RedisKeys.ORDER_CODE);//RedisUtil.getObject(redisTemplate, Constants.RedisKeys.ORDER_CODE, Integer.class);
|
countNum = Constants.formatIntegerNum(countNum)+1;
|
//更新缓存
|
redisTemplate.opsForValue().set(Constants.RedisKeys.ORDER_CODE,countNum);
|
String nextIndex =Integer.toString( countNum );
|
return prefix + org.apache.commons.lang3.StringUtils.leftPad(nextIndex,3,"0");
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void refundCallback(RefundNotification refundNotification){
|
WithdrawalOrders withdrawalOrders = withdrawalOrdersMapper.selectById(refundNotification.getOutRefundNo());
|
if(Objects.isNull(withdrawalOrders)||!Constants.equalsInteger(withdrawalOrders.getStatus(),Constants.ZERO)){
|
return;
|
}
|
withdrawalOrders.setWxExternalNo(refundNotification.getTransactionId());
|
withdrawalOrders.setUpdateTime(new Date());
|
withdrawalOrders.setDoneTime(withdrawalOrders.getUpdateTime());
|
if (!"SUCCESS".equals(refundNotification.getRefundStatus().name())) {
|
// 如果退款状态不正确，修改退款单状态
|
withdrawalOrders.setStatus(Constants.TWO);
|
}else{
|
withdrawalOrders.setStatus(Constants.ONE);
|
}
|
//更新退款单状态
|
withdrawalOrdersMapper.updateById(withdrawalOrders);
|
}
|
|
|
/**
|
* 自动派单
|
*/
|
@Override
|
public void autoGrabOrders(){
|
String autoConfirmTime = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.AUTO_DISPATCH).getCode();
|
List<Orders> ordersList = ordersMapper.selectList(new QueryWrapper<Orders>().lambda()
|
.eq(Orders::getStatus,Constants.ONE).eq(Orders::getCommentStatus,Constants.ZERO)
|
.apply(" DATE_ADD(create_time, INTERVAL "+autoConfirmTime+" MINUTE) < now() ")
|
.last("limit 100")
|
);
|
for (Orders orders:ordersList) {
|
BigDecimal lat = orders.getLat();
|
BigDecimal lgt = orders.getLgt();
|
//查询范围内的会员
|
List<Member> memberList = memberMapper.selectList(new MPJLambdaWrapper<Member>().selectAll(Member.class)
|
.select(" ifnull((select r.level from receive_weight r where r.RECEIVE_MAX > t.RECEIVE_NUM and t.RECEIVE_NUM > r.RECEIVE_MIN limit 1 ),0) " ,Member::getLevel)
|
.select( " ifnull( (select CONVERT( ST_Distance_Sphere ( POINT ( ii.lgt, ii.lat ), POINT ( "+lgt+", "+lat+" )) /1000,DECIMAL(15,2)) from identity_info ii where ii.AUDIT_STATUS = 2 and type = 0 and ii.member_id = t.ID limit 1 ),0) ",Member::getDistance )
|
|
.apply(" id in (" +
|
" select ii.member_id from identity_info ii where ii.AUDIT_STATUS = 2 and type = '"+orders.getType()+"' " +
|
" and ( CONVERT( ST_Distance_Sphere ( POINT ( ii.lgt, ii.lat ), POINT ( "+lgt+", "+lat+" )) /1000,DECIMAL(15,2))) < 100 " +
|
") ")
|
.orderByDesc(Member::getLevel)
|
.orderByDesc(Member::getScore)
|
.orderByAsc(Member::getDistance)
|
.last(" limit 1 ")
|
);
|
if(CollectionUtils.isEmpty(memberList)){
|
continue;
|
}
|
Member member = memberList.get(Constants.ZERO);
|
//自动派单
|
Orders model = ordersMapper.selectById(orders.getStatus());
|
if(!Constants.equalsInteger(model.getStatus(),Constants.ONE)){
|
continue;
|
}
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda().eq(Orders::getId,model.getId())
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getAcceptType,Constants.ONE)
|
.set(Orders::getAcceptTime,new Date())
|
.set(Orders::getAcceptMemberId,member.getId())
|
.set(Orders::getStatus,Constants.ordersStatus.accept.getKey())
|
);
|
|
//更新接单量
|
memberMapper.update(new UpdateWrapper<Member>().lambda().setSql(" publish_num = (publish_num + 1 )").eq(Member::getId,member.getId()));
|
|
//创建操作日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.AUTO;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),member.getId(),null);
|
|
}
|
}
|
|
//自动评价 订单完成7天后自动评价4星
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void autoComment(){
|
List<Orders> ordersList = ordersMapper.selectList(new QueryWrapper<Orders>().lambda()
|
.eq(Orders::getStatus,Constants.FOUR).eq(Orders::getCommentStatus,Constants.ZERO)
|
.apply(" DATE_ADD(finish_time, INTERVAL 7 DAY) < now() ")
|
.last("limit 100")
|
);
|
|
for (Orders orders:ordersList) {
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getCommentStatus,Constants.ONE)
|
.set(Orders::getUpdateTime,new Date())
|
.set(Orders::getCommentTime,new Date())
|
.set(Orders::getCommentLevel,Constants.FOUR)
|
.set(Orders::getCommentType,Constants.ZERO)
|
.eq(Orders::getId,orders.getId())
|
);
|
|
memberMapper.update(new UpdateWrapper<Member>().lambda()
|
.setSql(" score = ( ( total_score +" + Constants.FOUR + " ) / (score_order_num + 1 ) ) ")
|
.setSql(" total_score = ( total_score +" + Constants.FOUR + ")")
|
.setSql(" score_order_num = ( score_order_num + 1 ) " ).eq(Member::getId,orders.getAcceptMemberId())
|
);
|
|
//日志存储
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.AUTO_COMMENT;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),orders.getAcceptMemberId(),null);
|
}
|
}
|
|
|
//自动确认 订单修改后若未处理 根据配置自动处理
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void autoConfirm(){
|
String autoConfirmTime = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.AUTO_CONFIRM).getCode();
|
List<Orders> ordersList = ordersMapper.selectList(new QueryWrapper<Orders>().lambda()
|
.eq(Orders::getStatus,Constants.ordersStatus.accept).eq(Orders::getIsUpdate,Constants.ONE)
|
.apply(" DATE_ADD(IS_UPDATE_TIME, INTERVAL "+autoConfirmTime+" MINUTE) < now() ")
|
.last("limit 100")
|
);
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ordersList)){
|
for (Orders orders:ordersList) {
|
ordersMapper.update(new UpdateWrapper<Orders>().lambda()
|
.set(Orders::getIsUpdate,Constants.TWO)
|
.set(Orders::getUpdateTime,new Date())
|
.eq(Orders::getId,orders.getId())
|
);
|
//记录同意修改的日志
|
Constants.OrdersLog ordersLog = Constants.OrdersLog.AUTO_AGREE;
|
this.saveOrderLog(orders,ordersLog,
|
ordersLog.getInfo(),orders.getAcceptMemberId(),null);
|
}
|
}
|
}
|
|
|
@Override
|
public void initializeCode(){
|
//更新缓存
|
redisTemplate.opsForValue().set(Constants.RedisKeys.ORDER_CODE,0);
|
}
|
|
|
|
}
|
