Commit e863329b by 吕明尚

logger.info换为logger.debug

parent 3c23dc06
...@@ -96,12 +96,12 @@ public class QPServiceImplAspect { ...@@ -96,12 +96,12 @@ public class QPServiceImplAspect {
couponLog.setMessage(outParams); couponLog.setMessage(outParams);
couponLog.setCreateTime(new Date()); couponLog.setCreateTime(new Date());
couponLog.setNumber(TRY_NUMBER); couponLog.setNumber(TRY_NUMBER);
logger.info("优惠卷操作日志:{}", couponLog); logger.debug("优惠卷操作日志:{}", couponLog);
logger.info("开始执行新增正常日志"); logger.debug("开始执行新增正常日志");
boolean isSaved = couponLogService.save(couponLog); boolean isSaved = couponLogService.save(couponLog);
System.out.println(couponLog + "============================================================"); System.out.println(couponLog + "============================================================");
if (isSaved) { if (isSaved) {
logger.info("新增日志成功"); logger.debug("新增日志成功");
} else { } else {
logger.warn("新增日志失败"); logger.warn("新增日志失败");
} }
...@@ -142,13 +142,13 @@ public class QPServiceImplAspect { ...@@ -142,13 +142,13 @@ public class QPServiceImplAspect {
} catch (Exception e2) { } catch (Exception e2) {
logger.error("Error while processing exception log", e2); logger.error("Error while processing exception log", e2);
} finally { } finally {
logger.info("优惠卷操作日志:{}", couponLog); logger.debug("优惠卷操作日志:{}", couponLog);
logger.info("开始执行新增错误日志"); logger.debug("开始执行新增错误日志");
boolean i = couponLogService.save(couponLog); boolean i = couponLogService.save(couponLog);
if (i) { if (i) {
logger.info("新增日志成功"); logger.debug("新增日志成功");
} else { } else {
logger.info("新增日志失败"); logger.debug("新增日志失败");
} }
} }
} }
......
...@@ -172,7 +172,7 @@ public class WeChatController { ...@@ -172,7 +172,7 @@ public class WeChatController {
} }
}); });
logger.info("处理后的openIdMap: {}", openIdMap); logger.debug("处理后的openIdMap: {}", openIdMap);
List<SConsumerToken> sConsumerTokenList; List<SConsumerToken> sConsumerTokenList;
try { try {
...@@ -196,7 +196,7 @@ public class WeChatController { ...@@ -196,7 +196,7 @@ public class WeChatController {
} }
}); });
logger.info("更新完成的消费者令牌列表: {}", sConsumerTokenList); logger.debug("更新完成的消费者令牌列表: {}", sConsumerTokenList);
} }
@GetMapping("/test1") @GetMapping("/test1")
......
...@@ -85,7 +85,7 @@ public class CouponRetryTask { ...@@ -85,7 +85,7 @@ public class CouponRetryTask {
TuangouReceiptGetConsumedReponseEntity getconsumed = qpService.getconsumed(item.getCouponCode(), openShopUuid); TuangouReceiptGetConsumedReponseEntity getconsumed = qpService.getconsumed(item.getCouponCode(), openShopUuid);
if (!ObjectUtils.isEmpty(getconsumed)) { if (!ObjectUtils.isEmpty(getconsumed)) {
item.setCouponPayPrice(BigDecimal.valueOf(getconsumed.getDeal_price())); item.setCouponPayPrice(BigDecimal.valueOf(getconsumed.getDeal_price()));
logger.info("美团优惠卷购买金额为:" + item.getCouponPayPrice()); logger.debug("美团优惠卷购买金额为:" + item.getCouponPayPrice());
} else { } else {
item.setUseStatus(UserStatusEnum.EXPIRED.getCode()); item.setUseStatus(UserStatusEnum.EXPIRED.getCode());
} }
...@@ -95,7 +95,7 @@ public class CouponRetryTask { ...@@ -95,7 +95,7 @@ public class CouponRetryTask {
JSONObject amount = certificate.getJSONObject("amount"); JSONObject amount = certificate.getJSONObject("amount");
if (NumberUtils.isNumber(amount.getStr("pay_amount"))) { if (NumberUtils.isNumber(amount.getStr("pay_amount"))) {
item.setCouponPayPrice(BigDecimal.valueOf(Double.parseDouble(amount.getStr("pay_amount")) / 100)); item.setCouponPayPrice(BigDecimal.valueOf(Double.parseDouble(amount.getStr("pay_amount")) / 100));
logger.info("抖音优惠卷购买金额为:" + item.getCouponPayPrice()); logger.debug("抖音优惠卷购买金额为:" + item.getCouponPayPrice());
} else { } else {
logger.warn("Invalid pay amount for coupon " + item.getId()); logger.warn("Invalid pay amount for coupon " + item.getId());
} }
...@@ -123,7 +123,7 @@ public class CouponRetryTask { ...@@ -123,7 +123,7 @@ public class CouponRetryTask {
TuangouReceiptGetConsumedReponseEntity getconsumed = qpService.getconsumed(item.getCouponCode(), openShopUuid); TuangouReceiptGetConsumedReponseEntity getconsumed = qpService.getconsumed(item.getCouponCode(), openShopUuid);
if (!ObjectUtils.isEmpty(getconsumed)) { if (!ObjectUtils.isEmpty(getconsumed)) {
item.setCouponPayPrice(BigDecimal.valueOf(getconsumed.getDeal_price())); item.setCouponPayPrice(BigDecimal.valueOf(getconsumed.getDeal_price()));
logger.info("美团优惠卷购买金额为:" + item.getCouponPayPrice()); logger.debug("美团优惠卷购买金额为:" + item.getCouponPayPrice());
} else { } else {
item.setUseStatus(UserStatusEnum.EXPIRED.getCode()); item.setUseStatus(UserStatusEnum.EXPIRED.getCode());
} }
...@@ -133,7 +133,7 @@ public class CouponRetryTask { ...@@ -133,7 +133,7 @@ public class CouponRetryTask {
JSONObject amount = certificate.getJSONObject("amount"); JSONObject amount = certificate.getJSONObject("amount");
if (NumberUtils.isNumber(amount.getStr("pay_amount"))) { if (NumberUtils.isNumber(amount.getStr("pay_amount"))) {
item.setCouponPayPrice(BigDecimal.valueOf(Double.parseDouble(amount.getStr("pay_amount")) / 100)); item.setCouponPayPrice(BigDecimal.valueOf(Double.parseDouble(amount.getStr("pay_amount")) / 100));
logger.info("抖音优惠卷购买金额为:" + item.getCouponPayPrice()); logger.debug("抖音优惠卷购买金额为:" + item.getCouponPayPrice());
} else { } else {
logger.warn("Invalid pay amount for coupon " + item.getId()); logger.warn("Invalid pay amount for coupon " + item.getId());
} }
......
...@@ -87,7 +87,7 @@ public class OrderTask { ...@@ -87,7 +87,7 @@ public class OrderTask {
public void autoCancel() { public void autoCancel() {
String redisKey = Constants.ORDER_AUTO_CANCEL_KEY; String redisKey = Constants.ORDER_AUTO_CANCEL_KEY;
Long size = redisUtil.getListSize(redisKey); Long size = redisUtil.getListSize(redisKey);
logger.info("orderTask.autoCancel | size:" + size); logger.debug("orderTask.autoCancel | size:" + size);
if (size < 1) { if (size < 1) {
return; return;
} }
...@@ -145,7 +145,7 @@ public class OrderTask { ...@@ -145,7 +145,7 @@ public class OrderTask {
couponUser.setUseStatus(CouponStatusEnum.NORMAL.getValue()); couponUser.setUseStatus(CouponStatusEnum.NORMAL.getValue());
consumerCouponService.updateById(couponUser); consumerCouponService.updateById(couponUser);
} }
logger.info(String.format("删除订单,订单号【%s】",sOrder.getOrderNo())); logger.debug(String.format("删除订单,订单号【%s】", sOrder.getOrderNo()));
return Boolean.TRUE; return Boolean.TRUE;
}); });
return execute; return execute;
...@@ -160,7 +160,7 @@ public class OrderTask { ...@@ -160,7 +160,7 @@ public class OrderTask {
public void refundApply() { public void refundApply() {
String redisKey = Constants.ORDER_TASK_REDIS_KEY_AFTER_REFUND_BY_USER; String redisKey = Constants.ORDER_TASK_REDIS_KEY_AFTER_REFUND_BY_USER;
Long size = redisUtil.getListSize(redisKey); Long size = redisUtil.getListSize(redisKey);
logger.info("OrderTask.refundApply | size:" + size); logger.debug("OrderTask.refundApply | size:" + size);
if (size < 1) { if (size < 1) {
return; return;
} }
...@@ -207,10 +207,10 @@ public class OrderTask { ...@@ -207,10 +207,10 @@ public class OrderTask {
try { try {
execute = transactionTemplate.execute(e -> { execute = transactionTemplate.execute(e -> {
orderService.updateById(tempOrder); orderService.updateById(tempOrder);
logger.info("=================开始处理优惠券退款================="); logger.debug("=================开始处理优惠券退款=================");
logger.info("=================" + sOrder.getId() + "================="); logger.debug("=================" + sOrder.getId() + "=================");
logger.info("=================" + sOrder.getCouponId() + "================="); logger.debug("=================" + sOrder.getCouponId() + "=================");
logger.info("================================================="); logger.debug("=================================================");
// 退优惠券 // 退优惠券
if (ObjectUtil.isNotNull(sOrder.getCouponId())) { if (ObjectUtil.isNotNull(sOrder.getCouponId())) {
SConsumerCoupon couponUser = consumerCouponService.getById(sOrder.getCouponId()); SConsumerCoupon couponUser = consumerCouponService.getById(sOrder.getCouponId());
...@@ -244,17 +244,17 @@ public class OrderTask { ...@@ -244,17 +244,17 @@ public class OrderTask {
SOrder byOrderNo = orderService.getByOrderNo(String.valueOf(orderNo)); SOrder byOrderNo = orderService.getByOrderNo(String.valueOf(orderNo));
if (ObjectUtil.isEmpty(byOrderNo)) { if (ObjectUtil.isEmpty(byOrderNo)) {
redisUtil.delete(o); redisUtil.delete(o);
logger.info("订单号为:" + jsonObject.getStr("orderNo") + "的订单不存在"); logger.debug("订单号为:" + jsonObject.getStr("orderNo") + "的订单不存在");
return; return;
} }
if (!byOrderNo.getStatus().equals(OrderStatusEnum.UNUSED.getCode())) { if (!byOrderNo.getStatus().equals(OrderStatusEnum.UNUSED.getCode())) {
redisUtil.delete(o); redisUtil.delete(o);
logger.info("订单号为:" + jsonObject.getStr("orderNo") + "的订单状态异常"); logger.debug("订单号为:" + jsonObject.getStr("orderNo") + "的订单状态异常");
return; return;
} }
if (OrderStatusEnum.CANCEL.getCode().equals(byOrderNo.getStatus())) { if (OrderStatusEnum.CANCEL.getCode().equals(byOrderNo.getStatus())) {
redisUtil.delete(o); redisUtil.delete(o);
logger.info("订单号为:" + jsonObject.getStr("orderNo") + "的订单已取消"); logger.debug("订单号为:" + jsonObject.getStr("orderNo") + "的订单已取消");
return; return;
} }
//时间到期前30分钟到29分 //时间到期前30分钟到29分
...@@ -267,7 +267,7 @@ public class OrderTask { ...@@ -267,7 +267,7 @@ public class OrderTask {
SStore sStore = storeService.getById(byOrderNo.getStoreId()); SStore sStore = storeService.getById(byOrderNo.getStoreId());
SRoom sRoom = roomService.getById(byOrderNo.getRoomId()); SRoom sRoom = roomService.getById(byOrderNo.getRoomId());
smsService.sendSmsOrderStartRemind(byOrderNo.getConsumerPhone(), sStore, sRoom); smsService.sendSmsOrderStartRemind(byOrderNo.getConsumerPhone(), sStore, sRoom);
logger.info("订单号为:" + jsonObject.getStr("orderNo") + "的订单开始预定时间到15分钟"); logger.debug("订单号为:" + jsonObject.getStr("orderNo") + "的订单开始预定时间到15分钟");
return; return;
} }
if (expirationTime.getTime() < new Date().getTime()) { if (expirationTime.getTime() < new Date().getTime()) {
......
...@@ -139,7 +139,7 @@ public class RedisTask { ...@@ -139,7 +139,7 @@ public class RedisTask {
expiredCoupons.add(coupon.getId()); expiredCoupons.add(coupon.getId());
} }
} }
logger.info("券码:{}->查询结束:{}", coupon.getCouponCode(), getconsumed); logger.debug("券码:{}->查询结束:{}", coupon.getCouponCode(), getconsumed);
} else if (StringUtils.isNoneEmpty(coupon.getTiktokSkuId()) && coupon.getPlatformType().equals(PlatformTypeEnum.TIKTOK.getCode())) { } else if (StringUtils.isNoneEmpty(coupon.getTiktokSkuId()) && coupon.getPlatformType().equals(PlatformTypeEnum.TIKTOK.getCode())) {
//抖音复验券 //抖音复验券
JSONObject object = tiktokService.certificateGet(coupon.getEncryptedCode()); JSONObject object = tiktokService.certificateGet(coupon.getEncryptedCode());
...@@ -250,7 +250,7 @@ public class RedisTask { ...@@ -250,7 +250,7 @@ public class RedisTask {
sOrder = isOrderService.getByOrderNo(jsonObject.getStr("orderNo")); sOrder = isOrderService.getByOrderNo(jsonObject.getStr("orderNo"));
if (ObjectUtils.isEmpty(sOrder)) { if (ObjectUtils.isEmpty(sOrder)) {
redisUtil.delete(o); redisUtil.delete(o);
logger.info("订单号为:{}的订单不存在", jsonObject.getStr("orderNo")); logger.debug("订单号为:{}的订单不存在", jsonObject.getStr("orderNo"));
throw new BaseException("订单不存在!"); throw new BaseException("订单不存在!");
} }
} }
...@@ -262,7 +262,7 @@ public class RedisTask { ...@@ -262,7 +262,7 @@ public class RedisTask {
DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN), DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN),
DateUtil.format(DateUtil.offsetMinute(new Date(), 1), DatePattern.NORM_DATETIME_PATTERN), "1", DateUtil.format(DateUtil.offsetMinute(new Date(), 1), DatePattern.NORM_DATETIME_PATTERN), "1",
DeviceOpSourceEnum.DEVICE_SOURCE_20.getCode()); DeviceOpSourceEnum.DEVICE_SOURCE_20.getCode());
logger.info("订单号为:" + sOrder.getOrderNo() + "的订单距离结束时间还有15分钟"); logger.debug("订单号为:" + sOrder.getOrderNo() + "的订单距离结束时间还有15分钟");
// 从门店集合中判断门店id相同的门店对象 // 从门店集合中判断门店id相同的门店对象
SOrder finalSOrder = sOrder; SOrder finalSOrder = sOrder;
SStore sStore = sStoreList.stream().filter(item -> item.getId().equals(finalSOrder.getStoreId())).findFirst().orElse(null); SStore sStore = sStoreList.stream().filter(item -> item.getId().equals(finalSOrder.getStoreId())).findFirst().orElse(null);
...@@ -272,7 +272,7 @@ public class RedisTask { ...@@ -272,7 +272,7 @@ public class RedisTask {
smsService.sendSmsOrderEndRemind(sOrder.getConsumerPhone(), sStore, sRoom); smsService.sendSmsOrderEndRemind(sOrder.getConsumerPhone(), sStore, sRoom);
//推送订单结束消息 //推送订单结束消息
wechatNewService.sendMiniSubscribeMessage(sOrder, MessageReminderEnum.END); wechatNewService.sendMiniSubscribeMessage(sOrder, MessageReminderEnum.END);
logger.info("保洁工单派单通知发送开始"); logger.debug("保洁工单派单通知发送开始");
//通知保洁人员 //通知保洁人员
sConsumerService.selectListByStoreId(sOrder.getStoreId()).stream().forEach(item -> { sConsumerService.selectListByStoreId(sOrder.getStoreId()).stream().forEach(item -> {
// 循环发送短信提示门店保洁打扫卫生 // 循环发送短信提示门店保洁打扫卫生
...@@ -280,7 +280,7 @@ public class RedisTask { ...@@ -280,7 +280,7 @@ public class RedisTask {
//公众号发送保洁工单派单通知 //公众号发送保洁工单派单通知
wechatNewService.sendPublicTemplateMessage(finalSOrder, MessageReminderEnum.CLEANING, item.getId()); wechatNewService.sendPublicTemplateMessage(finalSOrder, MessageReminderEnum.CLEANING, item.getId());
}); });
logger.info("保洁工单派单通知发送结束"); logger.debug("保洁工单派单通知发送结束");
return; return;
} }
//判断时间是否在5分钟到4分钟 //判断时间是否在5分钟到4分钟
...@@ -290,7 +290,7 @@ public class RedisTask { ...@@ -290,7 +290,7 @@ public class RedisTask {
DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN), DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN),
DateUtil.format(DateUtil.offsetMinute(new Date(), 1), DatePattern.NORM_DATETIME_PATTERN), "1", DateUtil.format(DateUtil.offsetMinute(new Date(), 1), DatePattern.NORM_DATETIME_PATTERN), "1",
DeviceOpSourceEnum.DEVICE_SOURCE_20.getCode()); DeviceOpSourceEnum.DEVICE_SOURCE_20.getCode());
logger.info("订单号为:" + sOrder.getOrderNo() + "的订单距离结束时间还有5分钟"); logger.debug("订单号为:" + sOrder.getOrderNo() + "的订单距离结束时间还有5分钟");
} }
//判断是否过期 //判断是否过期
if (expirationTime.getTime() < new Date().getTime()) { if (expirationTime.getTime() < new Date().getTime()) {
...@@ -331,7 +331,7 @@ public class RedisTask { ...@@ -331,7 +331,7 @@ public class RedisTask {
map.put("expirationTime", date.toString()); map.put("expirationTime", date.toString());
JSONObject json = new JSONObject(map); JSONObject json = new JSONObject(map);
redisUtil.set(ReceiptRdeisEnum.ROOM_EXPIRE_TIME.getValue() + sOrder.getOrderNo(), json.toString()); redisUtil.set(ReceiptRdeisEnum.ROOM_EXPIRE_TIME.getValue() + sOrder.getOrderNo(), json.toString());
logger.info("订单号为:" + sOrder.getOrderNo() + "的订单已结束,更改订单状态为已使用"); logger.debug("订单号为:" + sOrder.getOrderNo() + "的订单已结束,更改订单状态为已使用");
} }
}); });
...@@ -377,7 +377,7 @@ public class RedisTask { ...@@ -377,7 +377,7 @@ public class RedisTask {
//更改订单状态 //更改订单状态
sOrder.setStatus(OrderStatusEnum.USED.getCode()); sOrder.setStatus(OrderStatusEnum.USED.getCode());
isOrderService.updateById(sOrder); isOrderService.updateById(sOrder);
logger.info("订单号为:" + sOrder.getOrderNo() + "的订单已有续单,更改订单状态为已使用"); logger.debug("订单号为:" + sOrder.getOrderNo() + "的订单已有续单,更改订单状态为已使用");
return true; return true;
} }
return false; return false;
......
...@@ -357,7 +357,7 @@ public class DeviceOpServiceImpl implements DeviceOpService { ...@@ -357,7 +357,7 @@ public class DeviceOpServiceImpl implements DeviceOpService {
// 设置消息队列 // 设置消息队列
this.setRedisCache(device.getDevId(), mqttxVo); this.setRedisCache(device.getDevId(), mqttxVo);
} }
logger.info("延时执行语音播报完成!"); logger.debug("延时执行语音播报完成!");
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} }
...@@ -400,7 +400,7 @@ public class DeviceOpServiceImpl implements DeviceOpService { ...@@ -400,7 +400,7 @@ public class DeviceOpServiceImpl implements DeviceOpService {
mqttxVo.setSource(source); mqttxVo.setSource(source);
// 设置消息队列 // 设置消息队列
this.setRedisCache(device.getDevId(), mqttxVo); this.setRedisCache(device.getDevId(), mqttxVo);
logger.info("延时执行开锁/关锁、取电/断电完成!"); logger.debug("延时执行开锁/关锁、取电/断电完成!");
} catch (InterruptedException e) { } catch (InterruptedException e) {
e.printStackTrace(); e.printStackTrace();
} }
......
...@@ -110,7 +110,7 @@ public class OrderPayServiceImpl implements OrderPayService { ...@@ -110,7 +110,7 @@ public class OrderPayServiceImpl implements OrderPayService {
CreateOrderRequestVo unifiedorderVo = getUnifiedorderVo(sOrder, userToken.getToken(), appId, mchId, signKey); CreateOrderRequestVo unifiedorderVo = getUnifiedorderVo(sOrder, userToken.getToken(), appId, mchId, signKey);
// 预下单(统一下单) // 预下单(统一下单)
CreateOrderResponseVo responseVo = wechatNewService.payUnifiedorder(unifiedorderVo); CreateOrderResponseVo responseVo = wechatNewService.payUnifiedorder(unifiedorderVo);
logger.info("CreateOrderResponseVo :", JsonConvertUtil.write2JsonStr(responseVo)); logger.debug("CreateOrderResponseVo :", JsonConvertUtil.write2JsonStr(responseVo));
// 组装前端预下单参数 // 组装前端预下单参数
ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>(); ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>();
map.put("appId", unifiedorderVo.getAppid()); map.put("appId", unifiedorderVo.getAppid());
...@@ -196,7 +196,7 @@ public class OrderPayServiceImpl implements OrderPayService { ...@@ -196,7 +196,7 @@ public class OrderPayServiceImpl implements OrderPayService {
SaobeiMiniPayRequestVo unifiedorderVo = getSaobeiUnifiedOrderVo(sOrder, userToken.getToken(), appId, mchId, signKey); SaobeiMiniPayRequestVo unifiedorderVo = getSaobeiUnifiedOrderVo(sOrder, userToken.getToken(), appId, mchId, signKey);
// 预下单(统一下单) // 预下单(统一下单)
SaobeiMiniPayResponse response = saobeiService.wechatMinipay(unifiedorderVo); SaobeiMiniPayResponse response = saobeiService.wechatMinipay(unifiedorderVo);
logger.info("SaobeiMiniPayResponse :", JsonConvertUtil.write2JsonStr(response)); logger.debug("SaobeiMiniPayResponse :", JsonConvertUtil.write2JsonStr(response));
// 组装前端预下单参数 // 组装前端预下单参数
ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>(); ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>();
map.put("appId", response.getAppId()); map.put("appId", response.getAppId());
...@@ -285,7 +285,7 @@ public class OrderPayServiceImpl implements OrderPayService { ...@@ -285,7 +285,7 @@ public class OrderPayServiceImpl implements OrderPayService {
SaobeiMiniPayRequestVo unifiedorderVo = getSaobeiUnifiedRechargeVo(recharge, userToken.getToken(), appId, mchId, signKey); SaobeiMiniPayRequestVo unifiedorderVo = getSaobeiUnifiedRechargeVo(recharge, userToken.getToken(), appId, mchId, signKey);
// 预下单(统一下单) // 预下单(统一下单)
SaobeiMiniPayResponse response = saobeiService.wechatMinipay(unifiedorderVo); SaobeiMiniPayResponse response = saobeiService.wechatMinipay(unifiedorderVo);
logger.info("SaobeiMiniPayResponse :", JsonConvertUtil.write2JsonStr(response)); logger.debug("SaobeiMiniPayResponse :", JsonConvertUtil.write2JsonStr(response));
// 组装前端预下单参数 // 组装前端预下单参数
ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>(); ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>();
map.put("appId", response.getAppId()); map.put("appId", response.getAppId());
...@@ -370,7 +370,7 @@ public class OrderPayServiceImpl implements OrderPayService { ...@@ -370,7 +370,7 @@ public class OrderPayServiceImpl implements OrderPayService {
SaobeiMiniPayRequestVo unifiedorderVo = getSaobeiUnifiedEquityMembersOrderVo(equityMembersOrder, userToken.getToken(), appId, mchId, signKey); SaobeiMiniPayRequestVo unifiedorderVo = getSaobeiUnifiedEquityMembersOrderVo(equityMembersOrder, userToken.getToken(), appId, mchId, signKey);
// 预下单(统一下单) // 预下单(统一下单)
SaobeiMiniPayResponse response = saobeiService.wechatMinipay(unifiedorderVo); SaobeiMiniPayResponse response = saobeiService.wechatMinipay(unifiedorderVo);
logger.info("SaobeiMiniPayResponse :", JsonConvertUtil.write2JsonStr(response)); logger.debug("SaobeiMiniPayResponse :", JsonConvertUtil.write2JsonStr(response));
// 组装前端预下单参数 // 组装前端预下单参数
ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>(); ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>();
map.put("appId", response.getAppId()); map.put("appId", response.getAppId());
......
...@@ -240,8 +240,8 @@ public class QPServiceImpl implements QPService { ...@@ -240,8 +240,8 @@ public class QPServiceImpl implements QPService {
if (Boolean.FALSE.equals(b)) { if (Boolean.FALSE.equals(b)) {
throw new RuntimeException("请联系管理员"); throw new RuntimeException("请联系管理员");
} }
logger.info("code:{}", code); logger.debug("code:{}", code);
logger.info("验卷准备开始"); logger.debug("验卷准备开始");
String o = redisUtil.get(ReceiptRdeisEnum.MT_SESSION_KEY.getValue()); String o = redisUtil.get(ReceiptRdeisEnum.MT_SESSION_KEY.getValue());
JSONObject sessionKey = new JSONObject(o); JSONObject sessionKey = new JSONObject(o);
String session = (String) sessionKey.get("access_token"); String session = (String) sessionKey.get("access_token");
...@@ -253,7 +253,7 @@ public class QPServiceImpl implements QPService { ...@@ -253,7 +253,7 @@ public class QPServiceImpl implements QPService {
logger.error("验卷准备失败:{}", invoke.getMsg()); logger.error("验卷准备失败:{}", invoke.getMsg());
throw new RuntimeException(invoke.getMsg()); throw new RuntimeException(invoke.getMsg());
} }
logger.info("验卷准备结束:{}", invoke.getData().toString()); logger.debug("验卷准备结束:{}", invoke.getData().toString());
return invoke.getData(); return invoke.getData();
} }
...@@ -264,8 +264,8 @@ public class QPServiceImpl implements QPService { ...@@ -264,8 +264,8 @@ public class QPServiceImpl implements QPService {
@Override @Override
public List<TuangouReceiptConsumeResponseEntity> consume(String code, int count, String openShopUuid, String status) { public List<TuangouReceiptConsumeResponseEntity> consume(String code, int count, String openShopUuid, String status) {
String o = redisUtil.get(ReceiptRdeisEnum.MT_SESSION_KEY.getValue()); String o = redisUtil.get(ReceiptRdeisEnum.MT_SESSION_KEY.getValue());
logger.info("code:{}", code); logger.debug("code:{}", code);
logger.info("验卷开始"); logger.debug("验卷开始");
JSONObject sessionKey = new JSONObject(o); JSONObject sessionKey = new JSONObject(o);
String session = (String) sessionKey.get("access_token"); String session = (String) sessionKey.get("access_token");
SConsumer user = FrontTokenComponent.getWxSConsumerEntry(); SConsumer user = FrontTokenComponent.getWxSConsumerEntry();
...@@ -287,7 +287,7 @@ public class QPServiceImpl implements QPService { ...@@ -287,7 +287,7 @@ public class QPServiceImpl implements QPService {
throw new RuntimeException(invoke.getMsg()); throw new RuntimeException(invoke.getMsg());
} }
redisUtil.delete(ReceiptRdeisEnum.PREPARE.getValue() + code); redisUtil.delete(ReceiptRdeisEnum.PREPARE.getValue() + code);
logger.info("验卷结束:{}", invoke.getData()); logger.debug("验卷结束:{}", invoke.getData());
return invoke.getData(); return invoke.getData();
} }
......
...@@ -79,13 +79,13 @@ public class SConsumerCenterServiceImpl extends ServiceImpl<SConsumerMapper, SCo ...@@ -79,13 +79,13 @@ public class SConsumerCenterServiceImpl extends ServiceImpl<SConsumerMapper, SCo
public LoginResponse weChatAuthorizeProgramLogin(String code, RegisterThirdSConsumerRequest request) { public LoginResponse weChatAuthorizeProgramLogin(String code, RegisterThirdSConsumerRequest request) {
//访问微信小程序的API 通过 code 来获取 用户信息 //访问微信小程序的API 通过 code 来获取 用户信息
WeChatMiniAuthorizeVo response = wechatNewService.miniAuthCode(code); WeChatMiniAuthorizeVo response = wechatNewService.miniAuthCode(code);
logger.info("小程序登陆成功 = " + JSON.toJSONString(response)); logger.debug("小程序登陆成功 = " + JSON.toJSONString(response));
logger.info("小程序登陆成功 = OpenId " + response.getOpenId()); logger.debug("小程序登陆成功 = OpenId " + response.getOpenId());
//检测是否存在 //检测是否存在
SConsumerToken sConsumerToken = sConsumerTokenService.getByOpenid(response.getOpenId()); SConsumerToken sConsumerToken = sConsumerTokenService.getByOpenid(response.getOpenId());
LoginResponse loginResponse = new LoginResponse(); LoginResponse loginResponse = new LoginResponse();
if (ObjectUtil.isNotNull(sConsumerToken)) {// 已存在,正常登录 if (ObjectUtil.isNotNull(sConsumerToken)) {// 已存在,正常登录
logger.info("小程序登陆成功 = Id " + sConsumerToken.getUid()); logger.debug("小程序登陆成功 = Id " + sConsumerToken.getUid());
SConsumer sConsumer = sConsumerService.getById(sConsumerToken.getUid()); SConsumer sConsumer = sConsumerService.getById(sConsumerToken.getUid());
if (sConsumer == null || sConsumer.getStatus() == 0) { if (sConsumer == null || sConsumer.getStatus() == 0) {
throw new BaseException("当前账户已禁用,请联系管理员!"); throw new BaseException("当前账户已禁用,请联系管理员!");
......
...@@ -1015,7 +1015,7 @@ public class SOrderServiceImpl extends ServiceImpl<SOrderMapper, SOrder> impleme ...@@ -1015,7 +1015,7 @@ public class SOrderServiceImpl extends ServiceImpl<SOrderMapper, SOrder> impleme
.eq(SStoreConsumer::getPosition, PositionEnum.CUSTOMER_SERVICE.getCode()) .eq(SStoreConsumer::getPosition, PositionEnum.CUSTOMER_SERVICE.getCode())
.eq(SStoreConsumer::getStoreId, sOrder.getStoreId()) .eq(SStoreConsumer::getStoreId, sOrder.getStoreId())
).stream().collect(Collectors.toMap(SStoreConsumer::getConsumerId, Function.identity())); ).stream().collect(Collectors.toMap(SStoreConsumer::getConsumerId, Function.identity()));
logger.info("订单预订成功通知发送开始"); logger.debug("订单预订成功通知发送开始");
consumers.forEach(o -> { consumers.forEach(o -> {
SStoreConsumer sStoreConsumer = consumerMap.get(o.getId()); SStoreConsumer sStoreConsumer = consumerMap.get(o.getId());
if (ObjectUtil.isNotEmpty(sStoreConsumer)) { if (ObjectUtil.isNotEmpty(sStoreConsumer)) {
...@@ -1029,7 +1029,7 @@ public class SOrderServiceImpl extends ServiceImpl<SOrderMapper, SOrder> impleme ...@@ -1029,7 +1029,7 @@ public class SOrderServiceImpl extends ServiceImpl<SOrderMapper, SOrder> impleme
} }
}); });
smsService.sendSmsOrderPredetermine(phones, sOrder, sStore, room); smsService.sendSmsOrderPredetermine(phones, sOrder, sStore, room);
logger.info("订单预订成功通知发送结束"); logger.debug("订单预订成功通知发送结束");
} }
} }
return response; return response;
...@@ -1700,7 +1700,7 @@ public class SOrderServiceImpl extends ServiceImpl<SOrderMapper, SOrder> impleme ...@@ -1700,7 +1700,7 @@ public class SOrderServiceImpl extends ServiceImpl<SOrderMapper, SOrder> impleme
.eq(SStoreConsumer::getPosition, PositionEnum.CUSTOMER_SERVICE.getCode()) .eq(SStoreConsumer::getPosition, PositionEnum.CUSTOMER_SERVICE.getCode())
.eq(SStoreConsumer::getStoreId, sOrder.getStoreId()) .eq(SStoreConsumer::getStoreId, sOrder.getStoreId())
).stream().collect(Collectors.toMap(SStoreConsumer::getConsumerId, Function.identity())); ).stream().collect(Collectors.toMap(SStoreConsumer::getConsumerId, Function.identity()));
logger.info("订单预订成功通知发送开始"); logger.debug("订单预订成功通知发送开始");
consumers.forEach(o->{ consumers.forEach(o->{
SStoreConsumer sStoreConsumer = consumerMap.get(o.getId()); SStoreConsumer sStoreConsumer = consumerMap.get(o.getId());
if (ObjectUtil.isNotEmpty(sStoreConsumer)) { if (ObjectUtil.isNotEmpty(sStoreConsumer)) {
...@@ -1714,7 +1714,7 @@ public class SOrderServiceImpl extends ServiceImpl<SOrderMapper, SOrder> impleme ...@@ -1714,7 +1714,7 @@ public class SOrderServiceImpl extends ServiceImpl<SOrderMapper, SOrder> impleme
} }
}); });
smsService.sendSmsOrderPredetermine(phones, sOrder, sStore, sRoom); smsService.sendSmsOrderPredetermine(phones, sOrder, sStore, sRoom);
logger.info("订单预订成功通知发送结束"); logger.debug("订单预订成功通知发送结束");
} }
} }
......
...@@ -792,7 +792,7 @@ public class WechatNewServiceImpl implements WechatNewService { ...@@ -792,7 +792,7 @@ public class WechatNewServiceImpl implements WechatNewService {
String accessToken = getPublicAccessToken(); String accessToken = getPublicAccessToken();
String url = StrUtil.format(WeChatConstants.WECHAT_PUBLIC_MENU_CREATE_URL, accessToken); String url = StrUtil.format(WeChatConstants.WECHAT_PUBLIC_MENU_CREATE_URL, accessToken);
String result = restTemplateUtil.postJsonData(url, JSONObject.parseObject(data)); String result = restTemplateUtil.postJsonData(url, JSONObject.parseObject(data));
logger.info("微信消息发送结果:" + result); logger.debug("微信消息发送结果:" + result);
JSONObject jsonObject = JSONObject.parseObject(result); JSONObject jsonObject = JSONObject.parseObject(result);
if (ObjectUtil.isNull(jsonObject)) { if (ObjectUtil.isNull(jsonObject)) {
throw new BaseException("微信平台接口异常,没任何数据返回!"); throw new BaseException("微信平台接口异常,没任何数据返回!");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment