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.SendWxMessage; 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.AliSmsService; 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 lombok.extern.slf4j.Slf4j; 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.BeanUtils; 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.math.RoundingMode; import java.util.*; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; /** * 订单信息记录Service实现 * @author 江蹄蹄 * @date 2025/07/09 12:00 */ @Slf4j @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; @Autowired private SendWxMessage sendWxMessage; @Autowired private AliSmsService aliSmsService; @Resource private RedisTemplate redisTemplate; @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public OrderReleaseVO create(Orders orders) { OrderReleaseVO orderReleaseVO = new OrderReleaseVO(); Object objects = null; this.initVerification(orders); Member member = memberMapper.selectById(orders.getMember().getId()); if(Objects.isNull(member)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"用户信息异常"); } 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().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(),"参数配置错误,请联系管理员"); } orders.setPayAccount(orders.getEstimatedAccount()); Long tcje = Long.valueOf(new BigDecimal(orders.getPayAccount().toString()).multiply(orders.getPlatformRata()).intValue()); orders.setReceiveAccount(orders.getPayAccount() - tcje); //用餐订单 if(Constants.equalsInteger(orders.getType(),Constants.TWO)){ orders.setStatus(Constants.ordersStatus.waitPay.getKey()); orders.setOutTradeNo(UUID.randomUUID().toString().replace("-","")); //唤起支付业务 objects = this.getWxPayResponse(orders,member.getOpenid()); orderReleaseVO.setObject(objects); }else{ orders.setStatus(Constants.ordersStatus.wait.getKey()); } orders.setOriginPriceNum1(orders.getPriceNum1()); orders.setOriginPriceNum2(orders.getPriceNum2()); orders.setOriginEstimatedAccount(orders.getEstimatedAccount()); orders.setConfirmOtherFee(0l); ordersMapper.insert(orders); orderReleaseVO.setId(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) || 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(" PUBLISH_NUM = ( ifnull(PUBLISH_NUM,0) + 1 )").eq(Member::getId,orders.getMember().getId())); //创建操作日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.UPLOAD; String orderTypeInfo = Constants.getOrderInfo(orders);/*"用工单"; 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); } Integer priceNum2 = orders.getPriceNum2(); 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{ List categoryList = categoryMapper.selectList(new QueryWrapper().lambda().eq(Category::getDeleted,Constants.ZERO) .eq(Category::getType,Constants.TWO) ); if(CollectionUtils.isEmpty(categoryList)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"餐标信息错误"); } //用餐订单 if(CollectionUtils.isEmpty(orders.getCateringDTOList())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } Long sumPrice = 0L; // List cateringDTOList = new ArrayList<>(); 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(),"用餐标准数据错误"); } //餐标信息 List categories = categoryList.stream().filter(i->Constants.equalsInteger(i.getId(),cateringDTO.getId())).collect(Collectors.toList()); if(CollectionUtils.isEmpty(categories)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"用餐标准数据错误，请刷新重试"); } Category category = categories.get(Constants.ZERO); List priceList = JSONArray.parseArray(category.getDetail(),String.class ); if(CollectionUtils.isEmpty(priceList)){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"用餐标准数据错误，请刷新重试"); } if(priceList.stream().filter(i->((Long.valueOf(i)*100)+"").equals((cateringDTO.getPrice()+""))).collect(Collectors.toList()).size()==Constants.ZERO){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"用餐标准数据错误，请刷新重试"); } sumPrice = sumPrice + (cateringDTO.getPrice() * cateringDTO.getNum()) ; } if(new BigDecimal(sumPrice.toString()).compareTo(orders.getPrice())!=Constants.ZERO){ 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(),"金额计算错误!"); } orders.setPriceNum2(priceNum2); } @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 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().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.setId(null); multifile.setIsdeleted(Constants.ZERO); multifile.setCreateDate(new Date()); multifile.setObjId(orders.getId()); multifile.setObjType(Constants.ONE); } multifileMapper.insert(multifileList); } orders.setOriginPriceNum1(orders.getPriceNum1()); orders.setOriginPriceNum2(orders.getPriceNum2()); orders.setOriginEstimatedAccount(orders.getOriginEstimatedAccount()); orders.setConfirmOtherFee(0L); 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())); this.getPriceUnit(orders); //附件信息 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)&& org.apache.commons.lang3.StringUtils.isNotBlank(orders.getReleaseName())){ orderLog.setLogInfo(orderLog.getLogInfo().replace("{userName}",orders.getReleaseName())); }else if(Constants.equalsInteger(orderLog.getOptUserType(),Constants.ONE)&& org.apache.commons.lang3.StringUtils.isNotBlank(orders.getAcceptName())){ 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 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.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 like '%"+model.getReleaseName()+"%' or m1.TELEPHONE like '%"+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()+(new BigDecimal(cateringDTO.getPrice().toString()).divide(new BigDecimal("100"),2,BigDecimal.ROUND_HALF_UP))+" 需"+cateringDTO.getNum()+"份"); }else{ orders.setOrderContent(orders.getOrderContent()+" | "+cateringDTO.getName()+(new BigDecimal(cateringDTO.getPrice().toString()).divide(new BigDecimal("100"),2,BigDecimal.ROUND_HALF_UP))+" 需"+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(),"您自己的订单无法进行该操作"); } 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().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().lambda().setSql(" RECEIVE_NUM = (ifnull(RECEIVE_NUM,0) + 1 )").eq(Member::getId,member.getId())); //创建操作日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.RECEIVE; this.saveOrderLog(orders,ordersLog, ordersLog.getInfo(),member.getId(),null); IdentityInfo wokerIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper().lambda() .eq(IdentityInfo::getMemberId,member.getId()) .eq(IdentityInfo::getType,orders.getType()) .eq(IdentityInfo::getAuditStatus,Constants.TWO) .last("limit 1") ); Member releaseMember = memberMapper.selectById(orders.getReleaseMemberId()); if(Objects.nonNull(releaseMember)){ if(org.apache.commons.lang3.StringUtils.isNotBlank(releaseMember.getOpenid())&&Objects.nonNull(wokerIdentityInfo)){ //发送微信通知 sendWxMessage.acceptMessage(releaseMember.getOpenid(),orders,wokerIdentityInfo.getLinkName(),wokerIdentityInfo.getTelephone()); } if(org.apache.commons.lang3.StringUtils.isNotBlank(orders.getLinkPhone())){ //短信通知 aliSmsService.businessSendSms(Constants.smsContent.accept.getKey(),orders.getLinkPhone(),orders,null, wokerIdentityInfo,categoryMapper); } } } /** * 开始作业 * @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(),"订单修改待确认，无法进行该操作"); } if(orders.getStartDate().getTime()>System.currentTimeMillis()){ 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); Long tcje = Long.valueOf(new BigDecimal(total.toString()).multiply(model.getPlatformRata()).intValue()); Long reciveTotal = total - tcje; ordersMapper.update(new UpdateWrapper().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) .set(Orders::getOriginEstimatedAccount,total) .set(Orders::getReceiveAccount,reciveTotal) .eq(Orders::getId,orders.getId()) ); //创建操作日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.UPD_ORDER; this.saveOrderLog(model,ordersLog, ordersLog.getInfo(),orders.getMember().getId(),null); //通知接单人 订单发生变更 Member member = memberMapper.selectById(model.getAcceptMemberId()); if(Objects.nonNull(member)){ if(org.apache.commons.lang3.StringUtils.isNotBlank(member.getOpenid())){ model.setStartDate(orders.getStartDate()); model.setEndDate(orders.getEndDate()); //发送微信通知 sendWxMessage.orderUpdMessage(member.getOpenid(),model); } IdentityInfo wokerIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper().lambda() .eq(IdentityInfo::getMemberId,member.getId()) .eq(IdentityInfo::getType,orders.getType()) .eq(IdentityInfo::getAuditStatus,Constants.TWO) .last("limit 1") ); if(Objects.nonNull(wokerIdentityInfo)){ //短信通知 aliSmsService.businessSendSms(Constants.smsContent.orderUpd.getKey(),wokerIdentityInfo.getTelephone(),orders,null, null,categoryMapper); } } } @Override public Long getTotal(Orders orders){ if(Objects.isNull(orders) ||Objects.isNull(orders.getPrice()) ||Objects.isNull(orders.getPriceNum1()) ||Objects.isNull(orders.getType()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } BigDecimal bigDecimalPrice = BigDecimal.ZERO; if( (Constants.equalsInteger(orders.getType(),Constants.ZERO) && Constants.equalsInteger(orders.getWorkType(),Constants.ZERO )) || (Constants.equalsInteger(orders.getType(),Constants.ZERO) && Objects.nonNull(orders.getCarType()) && Constants.equalsInteger(orders.getWorkType(),Constants.TWO ) && Constants.equalsInteger(orders.getCarType(),Constants.TWO)) || Constants.equalsInteger(orders.getType(),Constants.ONE) || Constants.equalsInteger(orders.getType(),Constants.TWO) ){ bigDecimalPrice = orders.getPrice().multiply(new BigDecimal(orders.getPriceNum1().toString())); }else{ if(Objects.isNull(orders.getPriceNum2())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } bigDecimalPrice = orders.getPrice().multiply(new BigDecimal(orders.getPriceNum1().toString())).multiply(new BigDecimal(orders.getPriceNum2().toString())); } if(Objects.nonNull(orders.getConfirmOtherFee())){ bigDecimalPrice = bigDecimalPrice.add(new BigDecimal(orders.getConfirmOtherFee().toString())); } return bigDecimalPrice.divide(new BigDecimal("1"),0,BigDecimal.ROUND_HALF_UP).longValue();//orders.getPrice() * orders.getPriceNum1() * orders.getPriceNum2(); } /** * 接单方确认订单费用 */ @Override @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public void confirmFee(ConfirmFeeOrderDTO confirmUpdOrderDTO){ if(Objects.isNull(confirmUpdOrderDTO) || Objects.isNull(confirmUpdOrderDTO.getOrderId()) || Objects.isNull(confirmUpdOrderDTO.getPriceNum1())){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } 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.getAcceptMemberId(),confirmUpdOrderDTO.getMember().getId())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作"); } if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.doing.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行该操作"); } //类型:0=用工；1=运货；2=订餐 if(Constants.equalsInteger(orders.getType(),Constants.ZERO)){ //用工类型:0=采摘工；1=分拣工；2=包装工；（用工订单） if(Constants.equalsInteger(orders.getWorkType(),Constants.ONE)){ //1=分拣工 if( Objects.isNull(confirmUpdOrderDTO.getPriceNum2())){//必须有用工数量（人） throw new BusinessException(ResponseStatus.BAD_REQUEST); } }else if(Constants.equalsInteger(orders.getWorkType(),Constants.TWO)){ //包装工 用车类型(用工包装/运货使用):0=天;1=次/小时;2=重量 if( !Constants.equalsInteger(orders.getCarType(),Constants.TWO) && Objects.isNull(confirmUpdOrderDTO.getPriceNum2())){ //不是按重量计费的，必须有用工数量（人） throw new BusinessException(ResponseStatus.BAD_REQUEST); } } }else if(Constants.equalsInteger(orders.getType(),Constants.ONE)){ //运货订单 }else{ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"该订单不支持该操作，请返回刷新重试！"); } orders.setPriceNum1(confirmUpdOrderDTO.getPriceNum1()); orders.setPriceNum2(confirmUpdOrderDTO.getPriceNum2()); orders.setConfirmOtherFee(confirmUpdOrderDTO.getConfirmOtherFee()); Long totalFee = this.getTotal(orders);//重新计算费用 Long payFee = totalFee;//重新计算费用 Long tcje = Long.valueOf(new BigDecimal(orders.getPayAccount().toString()).multiply(orders.getPlatformRata()).intValue()); Long reciveTotal = payFee - tcje; //BigDecimal recFee = new BigDecimal(payFee).multiply((new BigDecimal(1).subtract(Constants.formatBigDecimal(orders.getPlatformRata())))).setScale(0, RoundingMode.HALF_UP) ; ordersMapper.update(new UpdateWrapper().lambda() .set(Orders::getPriceNum1,confirmUpdOrderDTO.getPriceNum1()) .set(Orders::getPriceNum2,confirmUpdOrderDTO.getPriceNum2()) .set(Orders::getConfirmFeeRemark,confirmUpdOrderDTO.getConfirmFeeRemark()) .set(Orders::getConfirmOtherFee,confirmUpdOrderDTO.getConfirmOtherFee()) .set(Orders::getEstimatedAccount,totalFee) .set(Orders::getStatus,Constants.ordersStatus.feeconfirm.getKey()) .set(Orders::getPayAccount,payFee) .set(Orders::getReceiveAccount,reciveTotal) .set(Orders::getUpdateTime,new Date()) .set(Orders::getConfirmFeeTime,new Date()) .eq(Orders::getId,orders.getId()) ); //记录同意修改的日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.FEE_CONFIRM; this.saveOrderLog(orders,ordersLog, ordersLog.getInfo(),confirmUpdOrderDTO.getMember().getId(),null); //微信通知 Member member = memberMapper.selectById(orders.getReleaseMemberId()); if(Objects.nonNull(member)&& org.apache.commons.lang3.StringUtils.isNotBlank(member.getOpenid())){ sendWxMessage.waitPayMessage(member.getOpenid(),orders); } } /** * 接单方处理订单修改 * @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,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().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().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); } //短信通知 aliSmsService.businessSendSms(!Constants.equalsInteger(confirmUpdOrderDTO.getStatus(),Constants.ONE)? Constants.smsContent.agreeUpd.getKey():Constants.smsContent.disAgreeUpd.getKey() ,orders.getLinkPhone(),null,null, null,categoryMapper); } @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(),"非您的订单无法进行该操作"); } } @Override public String cancelTips(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); } 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,member.getId())); //查询取消次数 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+"小时,无法取消订单"); } return "今日还可主动取消"+(totalCancelTimes-cancelTimes)+"次，是否确认取消"; } /** * 发单方取消订单 * @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.setDeleted(Constants.ZERO); 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,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().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,new Date()) .set(Orders::getCancelTime,new Date()) .set(Orders::getCancelType,Constants.ONE) .eq(Orders::getId,orders.getId()) ); //减少接单量 memberMapper.update(new UpdateWrapper().lambda().setSql("receive_num = (receive_num - 1) ").eq(Member::getId,orders.getAcceptMemberId())); } //减少发单量 memberMapper.update(new UpdateWrapper().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); List members = memberMapper.selectList(new QueryWrapper().lambda() .and(i->i.eq(Member::getId,orders.getReleaseMemberId()).or().eq(Member::getId,orders.getAcceptMemberId())) ); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(members)){ List openIdList = members.stream().map(i->i.getOpenid()).collect(Collectors.toList()); //发送微信通知 orders.setCancelTime(new Date()); sendWxMessage.cancelMessage(openIdList,orders,Constants.ONE); } IdentityInfo wokerIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper().lambda() .eq(IdentityInfo::getMemberId,orders.getAcceptMemberId()) .eq(IdentityInfo::getType,orders.getType()) .eq(IdentityInfo::getAuditStatus,Constants.TWO) .last("limit 1") ); if(Objects.nonNull(wokerIdentityInfo)){ //短信通知 aliSmsService.businessSendSms(Constants.smsContent.releaseCancel.getKey(),wokerIdentityInfo.getTelephone(),orders,null, null,categoryMapper); } } /** * 接单方取消接单 * @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().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,new Date()) .set(Orders::getCancelTime,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().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); List members = memberMapper.selectList(new QueryWrapper().lambda() .and(i->i.eq(Member::getId,orders.getReleaseMemberId()).or().eq(Member::getId,orders.getAcceptMemberId())) ); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(members)){ List openIdList = members.stream().map(i->i.getOpenid()).collect(Collectors.toList()); //发送微信通知 orders.setCancelTime(new Date()); sendWxMessage.cancelMessage(openIdList,orders,Constants.TWO); } //短信通知 aliSmsService.businessSendSms(Constants.smsContent.receiveCancel.getKey(),member.getTelephone(),orders,null, null,categoryMapper); } /** * 完成订单 * @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.getType(),Constants.orderType.scd.getKey())){ if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.doing.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行取消"); } }else{ if(!Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.feeconfirm.getKey())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转,无法进行取消"); } } if(!Constants.equalsInteger(orders.getReleaseMemberId(),doneOrderDTO.getMember().getId())){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"非您的订单无法进行该操作"); } Member payMember = memberMapper.selectById(doneOrderDTO.getMember().getId()); if(Objects.isNull(payMember)){ 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 = (new BigDecimal(orders.getPayAccount().toString()).multiply(Constants.formatBigDecimal(orders.getPlatformRata())).setScale(0,RoundingMode.HALF_UP).longValue()); 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,payMember.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); sendWxMessage.revenueMessage(member.getOpenid(),orders); //短信通知接单方 if(Objects.nonNull(orders.getAcceptMemberId())){ IdentityInfo wokerIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper().lambda() .eq(IdentityInfo::getMemberId,orders.getAcceptMemberId()) .eq(IdentityInfo::getType,orders.getType()) .eq(IdentityInfo::getAuditStatus,Constants.TWO) .last("limit 1") ); if(Objects.nonNull(wokerIdentityInfo)){ aliSmsService.businessSendSms(Constants.smsContent.pay.getKey(),wokerIdentityInfo.getTelephone(),orders,null, null,categoryMapper); } } } 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.FIVE) )) && Constants.equalsInteger(orders.getPayStatus(),Constants.ZERO) )){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"订单状态已流转"); } Member payMember = memberMapper.selectById(reusePayDTO.getMember().getId()); if(Objects.isNull(payMember)){ 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); } orders.setOutTradeNo(UUID.randomUUID().toString().replace("-","")); ordersMapper.updateById(orders); //唤起支付业务 Object object = this.getWxPayResponse(orders,payMember.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().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()); List members = memberMapper.selectList(new QueryWrapper().lambda() .and(i->i.eq(Member::getId,orders.getReleaseMemberId()).or().eq(Member::getId,orders.getAcceptMemberId())) ); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(members)){ List openIdList = members.stream().map(i->i.getOpenid()).collect(Collectors.toList()); orders.setCancelTime(new Date()); //发送微信通知 orders.setCancelTime(new Date()); sendWxMessage.cancelMessage(openIdList,orders,Constants.ZERO); } //短信通知发单方 aliSmsService.businessSendSms(Constants.smsContent.platformCancel.getKey(),orders.getLinkPhone(),orders,null, null,categoryMapper); //短信通知接单方 if(Objects.nonNull(orders.getAcceptMemberId())){ IdentityInfo wokerIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper().lambda() .eq(IdentityInfo::getMemberId,orders.getAcceptMemberId()) .eq(IdentityInfo::getType,orders.getType()) .eq(IdentityInfo::getAuditStatus,Constants.TWO) .last("limit 1") ); if(Objects.nonNull(wokerIdentityInfo)){ aliSmsService.businessSendSms(Constants.smsContent.platformCancel2.getKey(),wokerIdentityInfo.getTelephone(),orders,null, null,categoryMapper); } } } @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,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().lambda() .setSql(" score = ( ifnull(total_score,0) +" + commentDTO.getLevel() + " ) / (ifnull(score_order_num,0) + 1 )") .setSql(" total_score = ifnull(total_score,0) +" + commentDTO.getLevel()) .setSql(" score_order_num = ifnull(score_order_num,0) + 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::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().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.FIVE)){ return ("处理成功!"); }else{ //处理支付完成逻辑 ordersMapper.update(new UpdateWrapper().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().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); // 通知接单方 款项已到账 sendWxMessage.revenueMessage(member.getOpenid(),orders); //短信通知接单方 if(Objects.nonNull(orders.getAcceptMemberId())){ IdentityInfo wokerIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper().lambda() .eq(IdentityInfo::getMemberId,orders.getAcceptMemberId()) .eq(IdentityInfo::getType,orders.getType()) .eq(IdentityInfo::getAuditStatus,Constants.TWO) .last("limit 1") ); if(Objects.nonNull(wokerIdentityInfo)){ aliSmsService.businessSendSms(Constants.smsContent.pay.getKey(),wokerIdentityInfo.getTelephone(),orders,null, null,categoryMapper); } } } } 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(); if(Objects.isNull(model) || 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().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().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().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 ") .eq(Objects.nonNull(model.getType()),Orders::getType,model.getType()) .eq(Objects.nonNull(model.getCommentStatus()),Orders::getCommentStatus,model.getCommentStatus());; if(!(Objects.isNull(model.getQueryLat())||Objects.isNull(model.getQueryLgt()))){ queryWrapper.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); } 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())&&!Constants.equalsInteger(model.getStatus(),Constants.ordersStatus.waitPay.getKey()),Orders::getStatus,model.getStatus()); queryWrapper.in(Objects.nonNull(model.getStatus())&&Constants.equalsInteger(model.getStatus(),Constants.ordersStatus.waitPay.getKey()),Orders::getStatus,model.getStatus(),Constants.ordersStatus.feeconfirm.getKey()); 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.in(Objects.nonNull(model.getStatus())&&Constants.equalsInteger(model.getStatus(),Constants.ordersStatus.waitPay.getKey()),Orders::getStatus,model.getStatus(),Constants.ordersStatus.feeconfirm.getKey()); queryWrapper.orderByDesc(Orders::getAcceptTime); }else{ //查询用户的接单权重 接单大厅 ReceiveWeight receiveWeight = receiveWeightMapper.selectOne(new QueryWrapper().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 iPage = ordersMapper.selectJoinPage(page,Orders.class,queryWrapper); for (Orders orders:iPage.getRecords()) { this.getPriceUnit(orders); if(Constants.equalsInteger(model.getQueryMyOrderType(),Constants.ZERO)||Constants.equalsInteger(model.getQueryMyOrderType(),Constants.ONE)){ orders.setStatusName( Constants.equalsInteger(model.getQueryMyOrderType(),Constants.ZERO)?Constants.ordersStatus.getName(orders.getStatus()): Constants.ordersStatus.getInfo(orders.getStatus()) ); } } 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() .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 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); } orders.setStatusName(Constants.ordersStatus.getName(orders.getStatus())); orders.setCancelStatus(Constants.ZERO); if(Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.accept.getKey())&&Constants.equalsInteger(orders.getIsUpdate(),Constants.ONE)){ String autoConfirmTime = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.AUTO_CONFIRM).getCode(); orders.setConfirmCountdown(DateUtil.getXMinuteAfterDate(orders.getIsUpdateTime(),Integer.valueOf(autoConfirmTime)).getTime() - System.currentTimeMillis()); if(orders.getConfirmCountdown()<=Constants.ZERO){ orders.setConfirmCountdown(0L); } } if(Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.waitPay.getKey())){ orders.setCancelCountdown(DateUtil.getXMinuteAfterDate(orders.getCreateTime(),15).getTime() - System.currentTimeMillis()); if(orders.getCancelCountdown()<=Constants.ZERO){ orders.setCancelCountdown(0L); } } this.getPriceUnit(orders); orders.setCanStart(Constants.ZERO); if(orders.getStatus() <= Constants.ordersStatus.accept.getKey()){ if(Constants.equalsInteger(orders.getReleaseMemberId(),member.getId())){ if(Constants.equalsInteger(orders.getStatus(),Constants.ordersStatus.accept.getKey())&&orders.getStartDate().getTime() <= System.currentTimeMillis()){ orders.setCanStart(Constants.ONE); } //判断是否可修改 已取消次数 与 时间限制 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){ 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().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 ordersList = ordersMapper.selectList(new QueryWrapper().lambda().eq(Orders::getDeleted,Constants.ZERO) .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 memberList = memberMapper.getList(lgt,lat,orders.getType(),orders.getReleaseMemberId()); // memberMapper.selectList(new MPJLambdaWrapper() // .select(Member::getId,Member::getScore) // .select(" ifnull((select r.level from receive_weight r where r.RECEIVE_MAX > RECEIVE_NUM and 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 = 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(" level , score ") // .orderByAsc(Member::getDistance) // .last(" limit 1 ") // ); if(CollectionUtils.isEmpty(memberList)){ continue; } Member member = memberList.get(Constants.ZERO); Member releaseMember = memberMapper.selectById(orders.getReleaseMemberId()); //自动派单 Orders model = ordersMapper.selectById(orders.getId()); if(!Constants.equalsInteger(model.getStatus(),Constants.ONE) || Constants.equalsInteger(releaseMember.getId(),model.getReleaseMemberId())){ //如果订单已删除 并且非发布方 continue; } ordersMapper.update(new UpdateWrapper().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().lambda().setSql(" RECEIVE_NUM = (ifnull(RECEIVE_NUM,0) + 1 )").eq(Member::getId,member.getId())); //创建操作日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.AUTO; this.saveOrderLog(orders,ordersLog, ordersLog.getInfo(),member.getId(),null); IdentityInfo wokerIdentityInfo = identityInfoMapper.selectOne(new QueryWrapper().lambda() .eq(IdentityInfo::getMemberId,member.getId()) .eq(IdentityInfo::getType,orders.getType()) .eq(IdentityInfo::getAuditStatus,Constants.TWO) .last("limit 1") ); //通知发单方 if(org.apache.commons.lang3.StringUtils.isNotBlank(releaseMember.getOpenid())&&Objects.nonNull(wokerIdentityInfo)){ //发送微信通知 sendWxMessage.acceptMessage(releaseMember.getOpenid(),orders,wokerIdentityInfo.getLinkName(),wokerIdentityInfo.getTelephone()); } //通知接单方 sendWxMessage.autoDispatchMessage(member.getOpenid(),orders,GeoUtils.haversineDistance( orders.getLgt().doubleValue(), orders.getLat().doubleValue(), wokerIdentityInfo.getLgt().doubleValue(), wokerIdentityInfo.getLat().doubleValue() )); aliSmsService.businessSendSms(Constants.smsContent.dispatch.getKey(),orders.getLinkPhone(),orders,null, null,categoryMapper); } } //自动评价 订单完成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,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().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.getKey()) .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,new Date()) .eq(Orders::getId,orders.getId()) ); //记录同意修改的日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.AUTO_AGREE; this.saveOrderLog(orders,ordersLog, ordersLog.getInfo(),null,null); } } } //自动取消 订单未支付 @Override @Transactional(rollbackFor = {Exception.class,BusinessException.class}) public void autoCancelWaitPay(){ List ordersList = ordersMapper.selectList(new QueryWrapper().lambda() .eq(Orders::getStatus,Constants.ordersStatus.waitPay) .apply(" DATE_ADD(CREATE_TIME, INTERVAL 15 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::getStatus,Constants.ordersStatus.cancel.getKey()) .set(Orders::getUpdateTime,DateUtil.getCurrDateTime()) .set(Orders::getCancelTime,DateUtil.getCurrDateTime()) .set(Orders::getCancelType,Constants.TWO) .eq(Orders::getId,orders.getId()) ); //记录同意修改的日志 Constants.OrdersLog ordersLog = Constants.OrdersLog.SYSTEM_CANCEL; this.saveOrderLog(orders,ordersLog, ordersLog.getInfo(),orders.getAcceptMemberId(),null); } } } @Override public void initializeCode(){ //更新缓存 redisTemplate.opsForValue().set(Constants.RedisKeys.ORDER_CODE,0); } }