记得上下班打卡 | git大法好,push需谨慎

Commit b25cf54e authored by wangyifan's avatar wangyifan

Merge branch 'dev-goblin-fahuo' into jxl-datongfensi

parents 60674a7b 90798b6b
...@@ -101,7 +101,7 @@ public class GoblinStoreOrderVo implements Serializable, Cloneable { ...@@ -101,7 +101,7 @@ public class GoblinStoreOrderVo implements Serializable, Cloneable {
private Integer payCountdownMinute; private Integer payCountdownMinute;
@ApiModelProperty(value = " 快递单号[废弃]") @ApiModelProperty(value = " 快递单号[废弃]")
private String mailNo; private String mailNo;
@ApiModelProperty(value = " 发货时间[废弃]") @ApiModelProperty(value = " 发货时间")
private String deliveryTime; private String deliveryTime;
@ApiModelProperty(value = " 物流公司姓名[废弃]") @ApiModelProperty(value = " 物流公司姓名[废弃]")
private String logisticsCompany; private String logisticsCompany;
......
...@@ -104,4 +104,7 @@ public interface AdamCaomeiBadgeMapper extends BaseMapper<AdamCaomeiBadge> { ...@@ -104,4 +104,7 @@ public interface AdamCaomeiBadgeMapper extends BaseMapper<AdamCaomeiBadge> {
"values (#{userId}, #{badgeId}, #{source}, now())" "values (#{userId}, #{badgeId}, #{source}, now())"
}) })
int insertUserBadge(@Param("userId") String userId, @Param("badgeId") String badgeId, @Param("source") Integer source); int insertUserBadge(@Param("userId") String userId, @Param("badgeId") String badgeId, @Param("source") Integer source);
@Select("select title from kylin_performances where performances_id = #{performanceId}")
String selectKylinPerformanceTitleById(@Param("performanceId") String performanceId);
} }
...@@ -67,7 +67,7 @@ ...@@ -67,7 +67,7 @@
IFNULL(b.icon, '') AS icon, IFNULL(b.icon, '') AS icon,
IFNULL(b.share_text, '') AS shareText, IFNULL(b.share_text, '') AS shareText,
IFNULL(b.type, 0) AS type, IFNULL(b.type, 0) AS type,
IFNULL(b.performance_id, '') AS performanceId, performance_id AS performanceId,
ub.created_at AS claimedAt, ub.created_at AS claimedAt,
ub.source AS source ub.source AS source
FROM adam_caomei_user_badge ub FROM adam_caomei_user_badge ub
......
...@@ -812,6 +812,11 @@ public class AdamRdmService { ...@@ -812,6 +812,11 @@ public class AdamRdmService {
if (vo != null) { if (vo != null) {
return vo.getTitle(); return vo.getTitle();
} }
// 从数据库查询
String title = adamCaomeiBadgeMapper.selectKylinPerformanceTitleById(performanceId);
if (!StringUtils.isEmpty(title)) {
return title;
}
return null; return null;
} catch (Exception e) { } catch (Exception e) {
log.warn("[getPerformanceTitleById] 读取演出缓存失败, performanceId: {}", performanceId, e); log.warn("[getPerformanceTitleById] 读取演出缓存失败, performanceId: {}", performanceId, e);
......
...@@ -230,6 +230,8 @@ public class AdamCaomeiBadgeUserServiceImpl implements IAdamCaomeiBadgeUserServi ...@@ -230,6 +230,8 @@ public class AdamCaomeiBadgeUserServiceImpl implements IAdamCaomeiBadgeUserServi
dto.setType(badge.getType()); dto.setType(badge.getType());
dto.setClaimedAt(now); dto.setClaimedAt(now);
dto.setSource(source); dto.setSource(source);
dto.setSubTitle(badge.getSubTitle());
dto.setPerformanceId(StringUtils.defaultString(badge.getPerformanceId()));
adamRdmService.addUserCaomeiBadgeDtoByUid(uid, badgeVos, dto); adamRdmService.addUserCaomeiBadgeDtoByUid(uid, badgeVos, dto);
......
...@@ -124,6 +124,7 @@ public class AdamCaomeiPassportUserServiceImpl implements IAdamCaomeiPassportUse ...@@ -124,6 +124,7 @@ public class AdamCaomeiPassportUserServiceImpl implements IAdamCaomeiPassportUse
dto.setType(b.getType()); dto.setType(b.getType());
dto.setClaimedAt(grantAt); dto.setClaimedAt(grantAt);
dto.setSource(1); dto.setSource(1);
dto.setSubTitle(b.getSubTitle());
return dto; return dto;
}) })
.collect(Collectors.toList()); .collect(Collectors.toList());
......
...@@ -776,7 +776,13 @@ public class GoblinOrderAppServiceImpl implements IGoblinOrderAppService { ...@@ -776,7 +776,13 @@ public class GoblinOrderAppServiceImpl implements IGoblinOrderAppService {
LocalDateTime canRefundTimeDateTime = null; LocalDateTime canRefundTimeDateTime = null;
if (orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_2.getValue() || orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_4.getValue()) { if (orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_2.getValue() || orderVo.getStatus() == GoblinStatusConst.Status.ORDER_STATUS_4.getValue()) {
try { try {
// 允许退款修改成发货时间+14天
// canRefundTimeDateTime = LocalDateTime.parse(orderVo.getPayTime(), DTF_YMD_HMS).plusDays(7);
if (StringUtil.isBlank(orderVo.getDeliveryTime())) {
canRefundTimeDateTime = LocalDateTime.parse(orderVo.getPayTime(), DTF_YMD_HMS).plusDays(7); canRefundTimeDateTime = LocalDateTime.parse(orderVo.getPayTime(), DTF_YMD_HMS).plusDays(7);
}else {
canRefundTimeDateTime = LocalDateTime.parse(orderVo.getDeliveryTime(), DTF_YMD_HMS).plusDays(14);
}
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
......
...@@ -575,7 +575,7 @@ public class GoblinStoreOrderServiceImpl implements IGoblinStoreOrderService { ...@@ -575,7 +575,7 @@ public class GoblinStoreOrderServiceImpl implements IGoblinStoreOrderService {
LinkedList<Object[]> sqlsOrder = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlsOrder = CollectionUtil.linkedListObjectArr();
LinkedList<Object[]> sqlsOrderSku = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlsOrderSku = CollectionUtil.linkedListObjectArr();
LinkedList<Object[]> sqlsMail = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlsMail = CollectionUtil.linkedListObjectArr();
sqls.add(SqlMapping.get("goblin_order.store.express")); sqls.add(SqlMapping.get("goblin_order.store.expressTime"));
sqls.add(SqlMapping.get("goblin_order.store.orderSkuStatus")); sqls.add(SqlMapping.get("goblin_order.store.orderSkuStatus"));
sqls.add(SqlMapping.get("goblin_order.mail")); sqls.add(SqlMapping.get("goblin_order.mail"));
// GoblinStoreInfoVo storeInfoVo = redisUtils.getStoreInfoVoByUid(uid); // GoblinStoreInfoVo storeInfoVo = redisUtils.getStoreInfoVoByUid(uid);
...@@ -658,13 +658,15 @@ public class GoblinStoreOrderServiceImpl implements IGoblinStoreOrderService { ...@@ -658,13 +658,15 @@ public class GoblinStoreOrderServiceImpl implements IGoblinStoreOrderService {
log.setType(GoblinStatusConst.Status.ORDER_LOG_STATUS_13.getValue()); log.setType(GoblinStatusConst.Status.ORDER_LOG_STATUS_13.getValue());
log.setRemark("发货:orderId=[" + orderId + "],orderSkuId=[" + StringUtils.join(skuIds, ",") + "],mailNo=[" + mailNo + "]"); log.setRemark("发货:orderId=[" + orderId + "],orderSkuId=[" + StringUtils.join(skuIds, ",") + "],mailNo=[" + mailNo + "]");
// 发货时间
orderVo.setDeliveryTime(nowStr);
//redis //redis
redisUtils.setGoblinOrder(orderId, orderVo); redisUtils.setGoblinOrder(orderId, orderVo);
//mongo //mongo
mongoUtils.updateGoblinStoreOrderVo(orderId, orderVo); mongoUtils.updateGoblinStoreOrderVo(orderId, orderVo);
//mysql //mysql
sqlsOrder.add(new Object[]{ sqlsOrder.add(new Object[]{
orderVo.getStatus(), now, orderId, now, now orderVo.getStatus(), now, now, orderId, now, now
}); });
queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getKey(), queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getKey(),
SqlMapping.gets(sqls, sqlsOrder, sqlsOrderSku, sqlsMail)); SqlMapping.gets(sqls, sqlsOrder, sqlsOrderSku, sqlsMail));
......
...@@ -118,6 +118,7 @@ goblin_order.store.orderSkuPush=UPDATE goblin_order_sku SET status = ? , updated ...@@ -118,6 +118,7 @@ goblin_order.store.orderSkuPush=UPDATE goblin_order_sku SET status = ? , updated
goblin_order.store.orderPush=UPDATE goblin_store_order SET status = ? ,zhengzai_status=?, updated_at = ?,push_time = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null) goblin_order.store.orderPush=UPDATE goblin_store_order SET status = ? ,zhengzai_status=?, updated_at = ?,push_time = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
goblin_order.store.express=UPDATE goblin_store_order SET status = ? , updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null) goblin_order.store.express=UPDATE goblin_store_order SET status = ? , updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
goblin_order.store.expressTime=UPDATE goblin_store_order SET status = ?, delivery_time = ? , updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
goblin_order.mail=INSERT INTO goblin_mail (`mail_id`,`order_id`,`mail_no`,`delivery_time`,`logistics_company`,`order_sku_ids`,`created_at`) VALUES (?,?,?,?,?,?,?) goblin_order.mail=INSERT INTO goblin_mail (`mail_id`,`order_id`,`mail_no`,`delivery_time`,`logistics_company`,`order_sku_ids`,`created_at`) VALUES (?,?,?,?,?,?,?)
goblin_order.mail.update=UPDATE goblin_mail SET mail_no = ? , updated_at = ? WHERE mail_id = ? goblin_order.mail.update=UPDATE goblin_mail SET mail_no = ? , updated_at = ? WHERE mail_id = ?
goblin_order.store.address=UPDATE goblin_order_attr SET express_contacts = ? ,express_address_detail = ? , express_phone = ? , updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null) goblin_order.store.address=UPDATE goblin_order_attr SET express_contacts = ? ,express_address_detail = ? , express_phone = ? , updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
......
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