diff --git a/ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java b/ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java index 1728edcb..b44ab045 100644 --- a/ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java +++ b/ghy-quartz/src/main/java/com/ghy/quartz/service/impl/OrderServiceImpl.java @@ -143,47 +143,24 @@ public class OrderServiceImpl implements OrderService { orderMasterService.updateTimeout(order.getId(), 1); timeout = true; // 通知一次超时 - // 主订单未约 - if (order.getIsCall().equals("01")) { - try { - // 推送公众号通知数据。 - // 消息组装。 - Map paramsNew = new HashMap<>(); - // 订单编号 - paramsNew.put("thing9", "您有1条订单,超时未联系客户"); - // 名称 - paramsNew.put("thing10", "进入【我的订单--未约未排】操作处理"); - CustomerAddress address = customerAddressService.selectByCustomerAddressId(order.getAddressId()); - paramsNew.put("thing2", address.getName()); - // 预约时间 - paramsNew.put("time8", com.ghy.common.utils.DateUtils.parseDateToStr("yyyy年MM月dd日 HH:mm", new Date())); - // 查师傅信息 - Worker worker = workerService.selectById(order.getWorkerId()); - WechatMsgUtils.sendWeChatMsg(WechatMsgUtils.getToken(), worker.getWxOpenId(), WxMsgEnum.TIMEOUT_ORDER, paramsNew); - } catch (Exception e) { - log.error(e.getMessage(), e); - } - } - //主订单未排 - if (order.getIsCall().equals("02")) { - try { - // 推送公众号通知数据。 - // 消息组装。 - Map paramsNew = new HashMap<>(); - // 订单编号 - paramsNew.put("thing9", "您有1条订单联系客户后,未排时间"); - // 名称 - paramsNew.put("thing10", "进入【我的订单--未约未排--预约时间】"); - CustomerAddress address = customerAddressService.selectByCustomerAddressId(order.getAddressId()); - paramsNew.put("thing2", address.getName()); - // 预约时间 - paramsNew.put("time8", com.ghy.common.utils.DateUtils.parseDateToStr("yyyy年MM月dd日 HH:mm", new Date())); - // 查师傅信息 - Worker worker = workerService.selectById(order.getWorkerId()); - WechatMsgUtils.sendWeChatMsg(WechatMsgUtils.getToken(), worker.getWxOpenId(), WxMsgEnum.TIMEOUT_ORDER, paramsNew); - } catch (Exception e) { - log.error(e.getMessage(), e); - } + // 通知师傅新订单 + try { + // 推送公众号通知数据。 + // 消息组装。 + Map paramsNew = new HashMap<>(); + // 订单编号 + paramsNew.put("thing9", "您帐号有1条新订单超时未接"); + // 名称 + paramsNew.put("thing10", "请进入【我的订单--新订单】操作处理"); + CustomerAddress address = customerAddressService.selectByCustomerAddressId(order.getAddressId()); + paramsNew.put("thing2", address.getName()); + // 预约时间 + paramsNew.put("time8", com.ghy.common.utils.DateUtils.parseDateToStr("yyyy年MM月dd日 HH:mm", new Date())); + // 查师傅信息 + Worker worker = workerService.selectById(order.getWorkerId()); + WechatMsgUtils.sendWeChatMsg(WechatMsgUtils.getToken(), worker.getWxOpenId(), WxMsgEnum.TIMEOUT_ORDER, paramsNew); + } catch (Exception e) { + log.error(e.getMessage(), e); } } } @@ -214,24 +191,49 @@ public class OrderServiceImpl implements OrderService { orderMasterService.updateTimeout(order.getId(), 1); timeout = true; //主单超时未约未排 - - try { - // 推送公众号通知数据。 - // 消息组装。 - Map paramsNew = new HashMap<>(); - // 订单编号 - paramsNew.put("thing9", "您有1条订单,超时未联系客户"); - // 名称 - paramsNew.put("thing10", "进入【我的订单--未约未排】操作处理"); - CustomerAddress address = customerAddressService.selectByCustomerAddressId(order.getAddressId()); - paramsNew.put("thing2", address.getName()); - // 预约时间 - paramsNew.put("time8", com.ghy.common.utils.DateUtils.parseDateToStr("yyyy年MM月dd日 HH:mm", new Date())); - // 查师傅信息 - Worker worker = workerService.selectById(order.getWorkerId()); - WechatMsgUtils.sendWeChatMsg(WechatMsgUtils.getToken(), worker.getWxOpenId(), WxMsgEnum.TIMEOUT_ORDER, paramsNew); - } catch (Exception e) { - log.error(e.getMessage(), e); + log.info("主订单是否未约未排[{}]",order.getIsCall()); + if (order.getIsCall().equals("01")) { + log.info("主订单未约[{}]",order.getIsCall()); + try { + // 推送公众号通知数据。 + // 消息组装。 + Map paramsNew = new HashMap<>(); + // 订单编号 + paramsNew.put("thing9", "您有1条订单,超时未联系客户"); + // 名称 + paramsNew.put("thing10", "进入【我的订单--未约未排】操作处理"); + CustomerAddress address = customerAddressService.selectByCustomerAddressId(order.getAddressId()); + paramsNew.put("thing2", address.getName()); + // 预约时间 + paramsNew.put("time8", com.ghy.common.utils.DateUtils.parseDateToStr("yyyy年MM月dd日 HH:mm", new Date())); + // 查师傅信息 + Worker worker = workerService.selectById(order.getWorkerId()); + WechatMsgUtils.sendWeChatMsg(WechatMsgUtils.getToken(), worker.getWxOpenId(), WxMsgEnum.TIMEOUT_ORDER, paramsNew); + } catch (Exception e) { + log.error(e.getMessage(), e); + } + } + //主订单未排 + if (order.getIsCall().equals("02")) { + log.info("主订单未排[{}]",order.getIsCall()); + try { + // 推送公众号通知数据。 + // 消息组装。 + Map paramsNew = new HashMap<>(); + // 订单编号 + paramsNew.put("thing9", "您有1条订单联系客户后,未排时间"); + // 名称 + paramsNew.put("thing10", "进入【我的订单--未约未排--预约时间】"); + CustomerAddress address = customerAddressService.selectByCustomerAddressId(order.getAddressId()); + paramsNew.put("thing2", address.getName()); + // 预约时间 + paramsNew.put("time8", com.ghy.common.utils.DateUtils.parseDateToStr("yyyy年MM月dd日 HH:mm", new Date())); + // 查师傅信息 + Worker worker = workerService.selectById(order.getWorkerId()); + WechatMsgUtils.sendWeChatMsg(WechatMsgUtils.getToken(), worker.getWxOpenId(), WxMsgEnum.TIMEOUT_ORDER, paramsNew); + } catch (Exception e) { + log.error(e.getMessage(), e); + } } } } @@ -279,9 +281,10 @@ public class OrderServiceImpl implements OrderService { afterParam.setOrderDetailId(order.getId()); List afterServiceRecord = afterServiceRecordService.selectAfterServiceRecordList(afterParam); if (CollectionUtil.isNotEmpty(afterServiceRecord) && (afterServiceRecord.get(0).getCustomerFinalCheck() == null || afterServiceRecord.get(0).getCustomerFinalCheck() != 1L)) { + log.info("售后订单更新时间[{}]",afterServiceRecord.get(0).getUpdateTime()); // 查询一下售后单时间 Date afterTime = getOverTime(afterServiceRecord.get(0).getUpdateTime(), 30 * 60 * 1000); - if (afterTime.before(now)) { + if (afterTime.before(now)&&!timeout) { log.info("售后订单[{}]超时30分钟", order.getId()); orderDetailService.updateAfterTimeout(order.getId(), 1, 0); // 售后超时通知