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.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.Date; import java.util.List; import java.util.Objects; import java.util.UUID; 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 WxMiniUtilService wxMiniUtilService; @Resource private RedisTemplate redisTemplate; @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public Object create(Orders orders) { 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()); //查询手续费 Category platformCategory = categoryMapper.selectOne(new QueryWrapper().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().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()); //唤起支付业务 objects = this.getWxPayResponse(orders,orders.getMember().getOpenid()); }else{ orders.setStatus(Constants.ordersStatus.wait.getKey()); } ordersMapper.insert(orders); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(orders.getMultifileList())){ List 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.setIsdeleted(Constants.ZERO); multifile.setCreateDate(new Date()); multifile.setObjId(orders.getId()); multifile.setObjType(Constants.ONE); } multifileMapper.insert(multifileList); } //更新用户发单量 memberMapper.update(new UpdateWrapper().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 objects; } 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.getCode()); request.setNotifyUrl(WxMiniConfig.wxProperties.getNotifyUrl());//这个回调url必须是https开头的 Amount amount = new Amount(); amount.setTotal(orders.getEstimatedAccount().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.getLocationRemark()) || StringUtil.isBlank(orders.getLinkPhone()) || Objects.isNull(orders.getLat()) || Objects.isNull(orders.getLgt()) || 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 deleteWrapper = new UpdateWrapper<>(orders); ordersMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids) { if (CollectionUtils.isEmpty(ids)) { return; } ordersMapper.deleteBatchIds(ids); } @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void updateById(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.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().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().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 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.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 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() .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())); 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("元/次"); } } //附件信息 List multifileList = multifileMapper.selectList(new QueryWrapper().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 orderLogList = orderLogMapper.selectList(new QueryWrapper().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; } @Override public Orders findOne(Orders orders) { QueryWrapper wrapper = new QueryWrapper<>(orders); return ordersMapper.selectOne(wrapper); } @Override public List findList(Orders orders) { QueryWrapper wrapper = new QueryWrapper<>(orders); return ordersMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper(); 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.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 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 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 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(),"您自己的订单无法进行该操作"); } //查询用户是否有对应身份 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(),"身份信息异常，请联系管理员"); } } orders.setUpdateTime(new Date()); orders.setAcceptType(Constants.ZERO); orders.setAcceptTime(new Date()); orders.setAcceptMemberId(member.getId()); orders.setStatus(Constants.ordersStatus.accept.getKey()); ordersMapper.updateById(orders); //更新接单量 memberMapper.update(new UpdateWrapper().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); } /** * 发单方修改订单 - 已接单状态 * @param updOrderDataDTO */ @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void updOrderData(UpdOrderDataDTO updOrderDataDTO){ if(Objects.isNull(updOrderDataDTO) || Objects.isNull(updOrderDataDTO.getOrderId()) || Objects.isNull(updOrderDataDTO.getStartDate()) || Objects.isNull(updOrderDataDTO.getEndDate())){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } Orders orders = ordersMapper.selectById(updOrderDataDTO.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.getReleaseMemberId(),updOrderDataDTO.getMember().getId())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作"); } if(Constants.equalsInteger(orders.getIsUpdate(),Constants.ONE)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单已修改，待接单方确认，无法进行该操作"); } orders.setStartDate(updOrderDataDTO.getStartDate()); orders.setEndDate(updOrderDataDTO.getEndDate()); orders.setTotalDays(updOrderDataDTO.getTotalDays()); //用车类型 if(Constants.equalsInteger(orders.getType(),Constants.ONE)){ if(Constants.equalsInteger(orders.getCarType(),Constants.ZERO)) { orders.setPriceNum1(updOrderDataDTO.getTotalDays()); } }else if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){ if(Constants.equalsInteger(orders.getWorkType(),Constants.ONE)||(Constants.equalsInteger(orders.getWorkType(),Constants.TWO)&&Constants.equalsInteger(orders.getCarType(),Constants.ZERO))){ orders.setPriceNum1(updOrderDataDTO.getTotalDays()); } }else{ orders.setPriceNum1(updOrderDataDTO.getTotalDays()); } Long total = this.getTotal(orders); ordersMapper.update(new UpdateWrapper().lambda() .set(Orders::getStartDate,updOrderDataDTO.getStartDate()) .set(Orders::getEndDate,updOrderDataDTO.getEndDate()) .set(Orders::getTotalDays,updOrderDataDTO.getTotalDays()) .set(Orders::getIsUpdate,Constants.ONE) .set(Orders::getIsUpdateTime,"now()") .set(Orders::getUpdateTime,"now()") .set(Orders::getEstimatedAccount,total) .eq(Orders::getId,orders.getId()) ); //创建操作日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.UPD_ORDER; this.saveOrderLog(orders,ordersLog, ordersLog.getInfo(),updOrderDataDTO.getMember().getId(),null); //TODO 通知接单人 订单发生变更 } public Long getTotal(Orders orders){ if( (Constants.equalsInteger(orders.getType(),Constants.ZERO) && Constants.equalsInteger(orders.getWorkType(),Constants.ZERO )) || Constants.equalsInteger(orders.getType(),Constants.ONE) ){ orders.setPriceNum2(Constants.ONE); } 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().lambda() .set(Orders::getIsUpdate,Constants.TWO) .set(Orders::getUpdateTime,"now()") .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().lambda() .set(Orders::getIsUpdate,Constants.TWO) .set(Orders::getUpdateTime,"now()") .set(Orders::getStatus,Constants.ordersStatus.wait.getKey()) .set(Orders::getAcceptMemberId,null) .set(Orders::getAcceptType,null) .eq(Orders::getId,orders.getId()) ); memberMapper.update(new UpdateWrapper().lambda().set(Member::getReceiveNum,"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 发送不同意变更通知 } } /** * 发单方取消订单 * @param orderId * @param member */ @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void releaseCancelOrder(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()) ||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().lambda() .set(Orders::getStatus,Constants.ordersStatus.cancel.getKey()) .set(Orders::getUpdateTime,"now()") .set(Orders::getCancelTime,"now()") .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().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().lambda() .set(Orders::getStatus,Constants.ordersStatus.cancel.getKey()) .set(Orders::getUpdateTime,"now()") .set(Orders::getCancelTime,"now()") .set(Orders::getCancelType,Constants.ONE) .eq(Orders::getId,orders.getId()) ); //TODO 发单方取消订单通知接单方 //减少接单量 memberMapper.update(new UpdateWrapper().lambda().set(Member::getReceiveNum,"receive_num - 1").eq(Member::getId,orders.getAcceptMemberId())); } //减少发单量 memberMapper.update(new UpdateWrapper().lambda().set(Member::getPublishNum,"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 orderId * @param member */ @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void receiveCancelOrder(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.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().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().lambda() .set(Orders::getUpdateTime,"now()") .set(Orders::getStatus,Constants.ordersStatus.wait.getKey()) .set(Orders::getAcceptMemberId,null) .set(Orders::getAcceptType,null) .eq(Orders::getId,orders.getId()) ); //减少接单量 memberMapper.update(new UpdateWrapper().lambda().set(Member::getReceiveNum,"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 Object 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(),"非您的订单无法进行该操作"); } orders.setPayAccount(doneOrderDTO.getAmount()); 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); ordersMapper.updateById(orders); //唤起支付业务 object = this.getWxPayResponse(orders,orders.getMember().getOpenid()); }else{ orders.setStatus(Constants.ordersStatus.done.getKey()); //日志存储 Constants.OrdersLog ordersLog = Constants.OrdersLog.DONE; this.saveOrderLog(orders,ordersLog, ordersLog.getInfo(),doneOrderDTO.getMember().getId(),null); } return object; } @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().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().lambda() .setSql("receive_num = ifnull(receive_num,0) - 1") .eq(Member::getId,orders.getAcceptMemberId())); } Date date = new Date(); ordersMapper.update(new UpdateWrapper().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().lambda() .set(Orders::getCommentStatus,Constants.ONE) .set(Orders::getUpdateTime,"now()") .set(Orders::getCommentTime,"now()") .set(Orders::getCommentLevel,commentDTO.getLevel()) .set(Orders::getCommentType,Constants.ZERO) .eq(Orders::getId,orders.getId()) ); memberMapper.update(new UpdateWrapper().lambda() .set(Member::getScore," ( total_score +" + commentDTO.getLevel() + " ) / (score_order_num + 1 )") .set(Member::getTotalScore," total_score +" + commentDTO.getLevel()) .set(Member::getScoreOrderNum," 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().lambda().eq(Orders::getCode,preOrderId).last("limit 1")); if(Constants.equalsInteger(orders.getType(),Constants.TWO)){ //用餐订单 如果已经流转到已支付 则直接返回 if(!Constants.equalsInteger(orders.getStatus(),Constants.ZERO)){ return ("处理成功!"); }else{ //处理支付完成逻辑 ordersMapper.update(new UpdateWrapper().lambda() .set(Orders::getUpdateTime,"now()") .set(Orders::getStatus,Constants.ordersStatus.wait) .set(Orders::getPayStatus,Constants.ONE) .set(Orders::getPayTime,"now()") .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().lambda() .set(Orders::getUpdateTime,"now()") .set(Orders::getStatus,Constants.FOUR) .set(Orders::getPayStatus,Constants.ONE) .set(Orders::getPayTime,"now()") .set(Orders::getPayMethod,Constants.ZERO) .set(Orders::getWxExternalNo,paymentNo) .set(Orders::getFinishTime,"now()") .eq(Orders::getId,orders.getId()) ); 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()); memberRevenue.setObjId(orders.getId()); memberRevenue.setObjType(Constants.ZERO); memberRevenue.setStatus(Constants.ZERO); memberRevenueMapper.insert(memberRevenue); //更新接单用户的余额与历史总金额 memberMapper.update(new UpdateWrapper().lambda() .set(Member::getAmount,"amount + " + orders.getReceiveAccount() ) .set(Member::getTotalAmount,"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 findPageForMini(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); Orders model = pageWrap.getModel(); 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 "); if(Objects.nonNull(model.getQueryMyOrderType())){ if(Constants.equalsInteger(model.getQueryMyOrderType(),Constants.ZERO)){ //发单方 我的订单 queryWrapper.eq(Orders::getReleaseMemberId,model.getMember().getId()); }else if(Constants.equalsInteger(model.getQueryMyOrderType(),Constants.ONE)){ //接单方 我的订单 queryWrapper.eq(Orders::getAcceptMemberId,model.getMember().getId()); }else{ queryWrapper.eq(Orders::getStatus,Constants.ordersStatus.wait.getKey()); //接单大厅 queryWrapper.and(Constants.equalsInteger(model.getMember().getWorkerIdentity(),Constants.TWO)||Constants.equalsInteger(model.getMember().getDriverIdentity(),Constants.TWO)||Constants.equalsInteger(model.getMember().getChefIdentity(),Constants.TWO),i-> i.eq(Constants.equalsInteger(model.getMember().getWorkerIdentity(),Constants.TWO),Orders::getType,Constants.ZERO) .or() .eq(Constants.equalsInteger(model.getMember().getDriverIdentity(),Constants.TWO),Orders::getType,Constants.ONE) .or() .eq(Constants.equalsInteger(model.getMember().getChefIdentity(),Constants.TWO),Orders::getType,Constants.TWO) ); queryWrapper.apply(!(Constants.equalsInteger(model.getMember().getWorkerIdentity(),Constants.TWO)||Constants.equalsInteger(model.getMember().getDriverIdentity(),Constants.TWO)||Constants.equalsInteger(model.getMember().getChefIdentity(),Constants.TWO))," 1 = 2 " ); } } for(PageWrap.SortData sortData: pageWrap.getSorts()) { if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { queryWrapper.orderByDesc(sortData.getProperty()); } else { queryWrapper.orderByAsc(sortData.getProperty()); } } IPage iPage = ordersMapper.selectJoinPage(page,Orders.class,queryWrapper); 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().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().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().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,Integer userType) { Orders orders = ordersMapper.selectJoinOne(Orders.class,new MPJLambdaWrapper() .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 ") .eq(Orders::getId,id) ); if(Objects.isNull(orders)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } if(Objects.nonNull(userType)){ Member member = memberMapper.selectById( Constants.equalsInteger(userType,Constants.ZERO)?orders.getReleaseMemberId():orders.getAcceptMemberId() ); if(Objects.nonNull(member)){ if(org.apache.commons.lang3.StringUtils.isNotBlank(member.getCoverImage())){ //头像信息 String path = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.RESOURCE_PATH).getCode() +systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.MEMBER_FILES).getCode(); member.setFullCoverImage(path + member.getCoverImage()); } orders.setMember(member); } } List multifileList = multifileMapper.selectList(new QueryWrapper().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); } 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); } //todo 自动派单 public void autoGrabOrders(){ // String autoConfirmTime = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.AUTO_DISPATCH_DISTANCE).getCode(); // List ordersList = ordersMapper.selectList(new QueryWrapper().lambda() // .eq(Orders::getStatus,Constants.FOUR).eq(Orders::getCommentStatus,Constants.ZERO) // .apply(" DATE_ADD(finish_time, INTERVAL 7 DAY) < now() ") // .last("limit 100") // ); } //自动评价 订单完成7天后自动评价4星 @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void autoComment(){ List ordersList = ordersMapper.selectList(new QueryWrapper().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().lambda() .set(Orders::getCommentStatus,Constants.ONE) .set(Orders::getUpdateTime,"now()") .set(Orders::getCommentTime,"now()") .set(Orders::getCommentLevel,Constants.FOUR) .set(Orders::getCommentType,Constants.ZERO) .eq(Orders::getId,orders.getId()) ); memberMapper.update(new UpdateWrapper().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 ordersList = ordersMapper.selectList(new QueryWrapper().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().lambda() .set(Orders::getIsUpdate,Constants.TWO) .set(Orders::getUpdateTime,"now()") .eq(Orders::getId,orders.getId()) ); //记录同意修改的日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.AUTO_AGREE; this.saveOrderLog(orders,ordersLog, ordersLog.getInfo(),orders.getAcceptMemberId(),null); } } } }