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

Commit 090d12ce authored by liuran's avatar liuran

Merge remote-tracking branch 'origin/new_member' into new_member

parents d47d6b76 d04b264a
...@@ -31,7 +31,8 @@ public class AdamMemberBuildParam implements Serializable { ...@@ -31,7 +31,8 @@ public class AdamMemberBuildParam implements Serializable {
private String avatar; private String avatar;
@ApiModelProperty(required = true, value = "弹窗文案[200]", example = "加入摩登天空会员您可享受到.....") @ApiModelProperty(required = true, value = "弹窗文案[200]", example = "加入摩登天空会员您可享受到.....")
@NotBlank(message = "弹窗文案不能为空") @NotBlank(message = "弹窗文案不能为空")
private String interestsDetail; // private String interestsDetail;
private String noticeInfo;
@ApiModelProperty(required = true, value = "注意事项[200]", example = "摩登天空会员需注意以下事项.....") @ApiModelProperty(required = true, value = "注意事项[200]", example = "摩登天空会员需注意以下事项.....")
@NotBlank(message = "注意事项不能为空") @NotBlank(message = "注意事项不能为空")
private String notes; private String notes;
......
...@@ -44,7 +44,7 @@ public class KylinOrderTicketPreVo implements Serializable, Cloneable { ...@@ -44,7 +44,7 @@ public class KylinOrderTicketPreVo implements Serializable, Cloneable {
private BigDecimal priceRefund; private BigDecimal priceRefund;
@ApiModelProperty(value = "退款张数") @ApiModelProperty(value = "退款张数")
private Integer refundNumber; private Integer refundNumber;
@ApiModelProperty(value = "是否使用优惠 exchange/no") @ApiModelProperty(value = "是否使用优惠 exchange/no")
private String couponType; private String couponType;
@ApiModelProperty(value = "取票方式 电子票electronic快递票express") @ApiModelProperty(value = "取票方式 电子票electronic快递票express")
private String getTicketType; private String getTicketType;
......
...@@ -88,7 +88,7 @@ public class AdamMemberAdminController extends BaseController { ...@@ -88,7 +88,7 @@ public class AdamMemberAdminController extends BaseController {
AdamMember::getLimitation, AdamMember::getLimitation,
AdamMember::getLimitbAt, AdamMember::getLimitbAt,
AdamMember::getLimiteAt, AdamMember::getLimiteAt,
AdamMember::getInterestsDetail, AdamMember::getNoticeInfo,
AdamMember::getNotes, AdamMember::getNotes,
AdamMember::getType, AdamMember::getType,
AdamMember::getOnsale, AdamMember::getOnsale,
......
...@@ -224,7 +224,6 @@ var refreshItem = function(){ ...@@ -224,7 +224,6 @@ var refreshItem = function(){
/** 关闭选项卡 */ /** 关闭选项卡 */
var closeItem = function(dataId){ var closeItem = function(dataId){
console.log(dataId, '这个科技')
var topWindow = $(window.parent.document); var topWindow = $(window.parent.document);
if($.common.isNotEmpty(dataId)){ if($.common.isNotEmpty(dataId)){
window.parent.$.modal.closeLoading(); window.parent.$.modal.closeLoading();
......
...@@ -929,7 +929,6 @@ var table = { ...@@ -929,7 +929,6 @@ var table = {
}, },
// 关闭选项卡 // 关闭选项卡
closeTab: function (dataId) { closeTab: function (dataId) {
console.log(dataId, '看看这个是啥')
closeItem(dataId); closeItem(dataId);
}, },
// 禁用按钮 // 禁用按钮
......
...@@ -188,7 +188,8 @@ ...@@ -188,7 +188,8 @@
<div class="form-group"> <div class="form-group">
<label class="col-sm-2 control-label">会员弹窗文案:</label> <label class="col-sm-2 control-label">会员弹窗文案:</label>
<div class="col-sm-10"> <div class="col-sm-10">
<textarea class="form-control text_menber" name="interestsDetail" size="10" th:field="*{interestsDetail}"/> <!-- <textarea class="form-control text_menber" name="interestsDetail" size="10" th:field="*{interestsDetail}"/>-->
<textarea class="form-control text_menber" name="noticeInfo" size="10" th:field="*{noticeInfo}"/>
</div> </div>
</div> </div>
<div class="form-group"> <div class="form-group">
...@@ -880,10 +881,13 @@ ...@@ -880,10 +881,13 @@
subTitle:{ subTitle:{
required:true, required:true,
}, },
limitation:{ // limitation:{
required:true, // required:true,
}, // },
interestsDetail:{ // interestsDetail:{
// required:true,
// },
noticeInfo:{
required:true, required:true,
}, },
notes:{ notes:{
...@@ -900,14 +904,17 @@ ...@@ -900,14 +904,17 @@
"subTitle": { "subTitle": {
required: "请输入会员说明", required: "请输入会员说明",
}, },
"limitation": { // "limitation": {
required: "请选择是否限购", // required: "请选择是否限购",
}, // },
"interestsDetail": { // "interestsDetail": {
required: "请选择注意事项", // required: "请填写弹窗文案",
// },
"noticeInfo": {
required: "请填写弹窗文案",
}, },
"notes": { "notes": {
required: "请选择是否限购", required: "请填写注意事项",
}, },
"onsale": { "onsale": {
required: "请选择是否开售", required: "请选择是否开售",
......
...@@ -316,7 +316,7 @@ ...@@ -316,7 +316,7 @@
showId = ''; showId = '';
} }
if (showId) { if (showId) {
useScope = 90; useScope = 80;
busiName = $('#searchIpt').val(); busiName = $('#searchIpt').val();
busiId = showId; busiId = showId;
} }
......
...@@ -64,6 +64,7 @@ ...@@ -64,6 +64,7 @@
// updateUrl: prefix + "/edit/{id}", // updateUrl: prefix + "/edit/{id}",
// exportUrl: prefix + "/export", // exportUrl: prefix + "/export",
sortName: "createdAt", sortName: "createdAt",
sortOrder: "desc",
modalName: "优先券", modalName: "优先券",
columns: [ columns: [
{ {
......
...@@ -298,6 +298,10 @@ ...@@ -298,6 +298,10 @@
field: 'statusName', field: 'statusName',
title: '退款状态' title: '退款状态'
}, },
{
field: 'mailno',
title: '运单号'
},
{ {
field: 'refundError', field: 'refundError',
title: '退款结果备注', title: '退款结果备注',
......
...@@ -53,6 +53,7 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad ...@@ -53,6 +53,7 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad
AdamMember adamMember = new AdamMember(); AdamMember adamMember = new AdamMember();
BeanUtils.copyProperties(parameter, adamMember); BeanUtils.copyProperties(parameter, adamMember);
adamMember.setLimitation(0); adamMember.setLimitation(0);
adamMember.setName(adamMember.getTitle());
// DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); // DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
// adamMember.setLimitbAt(LocalDateTime.parse(parameter.getLimitbAt(), dateTimeFormatter)); // adamMember.setLimitbAt(LocalDateTime.parse(parameter.getLimitbAt(), dateTimeFormatter));
// adamMember.setLimiteAt(LocalDateTime.parse(parameter.getLimitbAt(), dateTimeFormatter)); // adamMember.setLimiteAt(LocalDateTime.parse(parameter.getLimitbAt(), dateTimeFormatter));
......
...@@ -10,8 +10,7 @@ public class SmsEnum { ...@@ -10,8 +10,7 @@ public class SmsEnum {
M02("正在现场"), M02("正在现场"),
M03("新血计划"), M03("新血计划"),
M04("摩登小家伙"), M04("摩登小家伙"),
M05("五百里Live") M05("五百里Live");
;
private final String val; private final String val;
ADSignName(String val) { ADSignName(String val) {
...@@ -65,6 +64,12 @@ public class SmsEnum { ...@@ -65,6 +64,12 @@ public class SmsEnum {
* - 模版内容:您已成功购买$(name)门票。可至个人中心查看订单http://tcn/ExMir1B。演出$(time)开始。微信关注摩登天空服务号,联系我们。 * - 模版内容:您已成功购买$(name)门票。可至个人中心查看订单http://tcn/ExMir1B。演出$(time)开始。微信关注摩登天空服务号,联系我们。
*/ */
SMS_223203737, SMS_223203737,
/**
* 购票短信
* - 模版内容:您已成功购买${name}门票。可至个人中心查看订单 http://t.cn/ExMlr1B。演出${time}开始。微信关注 摩登天空服务号,获得更多演出资讯。特别提示:下载“正在现场APP”最新版,使用“在场”功能,可结识该场演出中共同观演的在场好友。
*/
SMS_225995308,
; ;
} }
} }
...@@ -99,4 +99,5 @@ global-auth: ...@@ -99,4 +99,5 @@ global-auth:
- ${liquidnet.info.context}/webjars/** - ${liquidnet.info.context}/webjars/**
- ${liquidnet.info.context}/swagger-resources/** - ${liquidnet.info.context}/swagger-resources/**
- ${liquidnet.info.context}/v2/api-docs* - ${liquidnet.info.context}/v2/api-docs*
- ${liquidnet.info.context}/candy-coupon/useBack - ${liquidnet.info.context}/candy-coupon/useBack
\ No newline at end of file - ${liquidnet.info.context}/candy-coupon/useBackJxl
\ No newline at end of file
...@@ -76,6 +76,8 @@ public class OrderRefundDao implements Serializable { ...@@ -76,6 +76,8 @@ public class OrderRefundDao implements Serializable {
private String performanceTitle; private String performanceTitle;
private String mailno;
public void setStatusName(Integer status){ public void setStatusName(Integer status){
this.status=status; this.status=status;
switch (status){ switch (status){
......
...@@ -34,10 +34,11 @@ ...@@ -34,10 +34,11 @@
<result column="created_at" property="createdAt"/> <result column="created_at" property="createdAt"/>
</resultMap> </resultMap>
<select id="misRefundList" resultType="com.liquidnet.service.kylin.dao.OrderRefundDao" resultMap="misRefundListResult"> <select id="misRefundList" resultType="com.liquidnet.service.kylin.dao.OrderRefundDao" resultMap="misRefundListResult">
SELECT a.*, b.order_code, b.performance_title SELECT a.*, b.order_code, b.performance_title, d.mailno
FROM kylin_order_refunds AS a FROM kylin_order_refunds AS a
JOIN kylin_order_tickets AS b ON a.order_tickets_id = b.order_tickets_id JOIN kylin_order_tickets AS b ON a.order_tickets_id = b.order_tickets_id
JOIN kylin_order_ticket_relations AS c ON a.order_tickets_id = c.order_id JOIN kylin_order_ticket_relations AS c ON a.order_tickets_id = c.order_id
LEFT JOIN kylin_order_express AS d ON d.order_refunds_id = a.order_refunds_id
<where> <where>
<if test="orderTicketsId!=''"> <if test="orderTicketsId!=''">
AND a.order_tickets_id = #{orderTicketsId} AND a.order_tickets_id = #{orderTicketsId}
...@@ -75,7 +76,7 @@ ...@@ -75,7 +76,7 @@
</otherwise> </otherwise>
</choose> </choose>
</where> </where>
ORDER BY mid DESC ORDER BY a.mid DESC
</select> </select>
<select id="selectRefundingCount" resultType="java.lang.Integer"> <select id="selectRefundingCount" resultType="java.lang.Integer">
SELECT COUNT(*) SELECT COUNT(*)
......
...@@ -313,7 +313,7 @@ ...@@ -313,7 +313,7 @@
INNER JOIN kylin_order_ticket_status kots ON kot.order_tickets_id = kots.order_id INNER JOIN kylin_order_ticket_status kots ON kot.order_tickets_id = kots.order_id
INNER JOIN kylin_order_ticket_relations kotr ON kot.order_tickets_id = kotr.order_id INNER JOIN kylin_order_ticket_relations kotr ON kot.order_tickets_id = kotr.order_id
LEFT JOIN (SELECT * FROM kylin_order_express WHERE express_status NOT IN (1, 3)) AS oe ON oe.order_tickets_id = LEFT JOIN (SELECT * FROM kylin_order_express WHERE express_status NOT IN (1, 3) AND send_type = 1) AS oe ON oe.order_tickets_id =
kot.order_tickets_id kot.order_tickets_id
-- LEFT JOIN (SELECT * FROM kylin_order_express_route ORDER BY mid DESC LIMIT 1) AS oer ON oe.order_express_id = -- LEFT JOIN (SELECT * FROM kylin_order_express_route ORDER BY mid DESC LIMIT 1) AS oer ON oe.order_express_id =
-- oer.order_express_id -- oer.order_express_id
......
...@@ -96,7 +96,7 @@ public class AdamUserServiceImpl implements IAdamUserService { ...@@ -96,7 +96,7 @@ public class AdamUserServiceImpl implements IAdamUserService {
initUserMobileLocateObjs.add(new Object[]{ initUserMobileLocateObjs.add(new Object[]{
userInfoVo.getUid(), mobile, 1, userInfoVo.getUid(), mobile, 1,
mobileLocateArr[0], mobileLocateArr[1], mobileLocateArr[2], mobileLocateArr[3], mobileLocateArr[4], mobileLocateArr[0], mobileLocateArr[1], mobileLocateArr[2], mobileLocateArr[3], mobileLocateArr[4],
cliIpAddr, headerCliSource, now, cliIpAddr, headerCliSource, now, now mobile, cliIpAddr, headerCliSource, now, cliIpAddr, headerCliSource, now, now
}); });
} }
...@@ -164,7 +164,7 @@ public class AdamUserServiceImpl implements IAdamUserService { ...@@ -164,7 +164,7 @@ public class AdamUserServiceImpl implements IAdamUserService {
initUserMobileLocateObjs.add(new Object[]{ initUserMobileLocateObjs.add(new Object[]{
userInfoVo.getUid(), userInfoVo.getMobile(), 1, userInfoVo.getUid(), userInfoVo.getMobile(), 1,
mobileLocateArr[0], mobileLocateArr[1], mobileLocateArr[2], mobileLocateArr[3], mobileLocateArr[4], mobileLocateArr[0], mobileLocateArr[1], mobileLocateArr[2], mobileLocateArr[3], mobileLocateArr[4],
cliIpAddr, headerCliSource, now, cliIpAddr, headerCliSource, now, now userInfoVo.getMobile(), cliIpAddr, headerCliSource, now, cliIpAddr, headerCliSource, now, now
}); });
} }
......
package com.liquidnet.service.candy.controller; package com.liquidnet.service.candy.controller;
import com.fasterxml.jackson.core.type.TypeReference;
import com.liquidnet.commons.lang.util.CollectionUtil; import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.commons.lang.util.CurrentUtil; import com.liquidnet.commons.lang.util.CurrentUtil;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.candy.param.BackCouponParam; import com.liquidnet.service.candy.param.BackCouponParam;
import com.liquidnet.service.candy.service.ICandyCouponService; import com.liquidnet.service.candy.service.ICandyCouponService;
...@@ -15,6 +17,7 @@ import io.swagger.annotations.ApiImplicitParam; ...@@ -15,6 +17,7 @@ import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.CollectionUtils;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
...@@ -22,6 +25,7 @@ import javax.validation.Valid; ...@@ -22,6 +25,7 @@ import javax.validation.Valid;
import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
...@@ -202,6 +206,29 @@ public class CandyCouponController { ...@@ -202,6 +206,29 @@ public class CandyCouponController {
return ResponseDto.success(); return ResponseDto.success();
} }
@PostMapping("useBackJxl")
@ApiOperation("回退券jxl")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", dataType = "String", name = "uCouponIds", value = "uCouponIds", required = true),
@ApiImplicitParam(type = "form", dataType = "String", name = "uid", value = "uid", required = true),
})
public ResponseDto<Boolean> useBackCoupon(
@RequestParam("uCouponIds") @NotNull @NotBlank String uCouponIds,
@RequestParam("uid") @NotNull @NotBlank String uid
) {
BackCouponParam aNew = BackCouponParam.getNew();
aNew.setuCouponIds(uCouponIds);
aNew.setUid(uid);
List<BackCouponParam> backCouponParam = new ArrayList<>();
backCouponParam.add(aNew);
if (backCouponParam.size() > 100) {
return ResponseDto.failure("数据量不得大于100");
}
candyCouponService.useBackCoupon(backCouponParam);
return ResponseDto.success();
}
//兑换券 //兑换券
@PostMapping("receive") @PostMapping("receive")
@ApiOperation("领取券") @ApiOperation("领取券")
......
...@@ -393,19 +393,20 @@ public class CandyCouponServiceImpl implements ICandyCouponService { ...@@ -393,19 +393,20 @@ public class CandyCouponServiceImpl implements ICandyCouponService {
if (vo.getCouType() != -1) { if (vo.getCouType() != -1) {
redisDataUtils.setCouponByUid(uid, dtoList); redisDataUtils.setCouponByUid(uid, dtoList);
LocalDateTime now = LocalDateTime.now();
//入库 //入库
if (dto.getCcouponId() == null) { if (dto.getCcouponId() == null || (null != dto.getCcouponId() && dto.getUsedAt() != null)) {// 是公有券且为使用后退回的券,则更新
queueUtils.sendMsgByRedis( queueUtils.sendMsgByRedis(
MQConst.CandyQueue.COUPON_USE.getKey(), MQConst.CandyQueue.COUPON_USE.getKey(),
SqlMapping.get("candy_coupon.use", SqlMapping.get("candy_coupon.use",
LocalDateTime.now(), content, uid, uCouponId now, content, uid, uCouponId
) )
); );
} else { } else {
queueUtils.sendMsgByRedis( queueUtils.sendMsgByRedis(
MQConst.CandyQueue.COUPON_USE.getKey(), MQConst.CandyQueue.COUPON_USE.getKey(),
SqlMapping.get("candy_coupon.use_insert", SqlMapping.get("candy_coupon.use_insert",
uCouponId, uid, dto.getCouponId(), LocalDateTime.now(), content uCouponId, uid, dto.getCouponId(), dto.getBindAt(), dto.getDuedAt(), now, content, now
) )
); );
} }
......
# -- 使用券 -- # -- 使用券 --
candy_coupon.use=UPDATE candy_user_coupon SET state = 3 ,used_at = ? , used_for = ? WHERE uid = ? AND ucoupon_id = ? candy_coupon.use=UPDATE candy_user_coupon SET state = 3 ,used_at = ? , used_for = ? WHERE uid = ? AND ucoupon_id = ?
candy_coupon.use_insert=INSERT INTO candy_user_coupon (ucoupon_id , uid , state , coupon_id , used_at , used_for ) VALUE ( ? , ? , 3 , ? , ? ,? ) #candy_coupon.use_insert=INSERT INTO candy_user_coupon (ucoupon_id , uid , state , coupon_id , used_at , used_for ) VALUE ( ? , ? , 3 , ? , ? ,? )
candy_coupon.use_insert=INSERT INTO candy_user_coupon (ucoupon_id , uid , state , coupon_id , bind_at, dued_at, used_at , used_for, created_at) VALUE ( ? , ? , 3 , ? , ? , ?, ?, ?, ?)
# -- 回退券 -- # -- 回退券 --
candy_coupon.back=UPDATE candy_user_coupon SET state = 1 WHERE uid = ? AND ucoupon_id = ? candy_coupon.back=UPDATE candy_user_coupon SET state = 1 WHERE uid = ? AND ucoupon_id = ?
# -- 领取券 -- # -- 领取券 --
......
...@@ -875,6 +875,8 @@ alter table kylin_order_express add express_phone varchar(255) not null default ...@@ -875,6 +875,8 @@ alter table kylin_order_express add express_phone varchar(255) not null default
alter table kylin_order_express add send_express_address varchar(255) not null default '' comment '退票发货快递地址' after express_phone; alter table kylin_order_express add send_express_address varchar(255) not null default '' comment '退票发货快递地址' after express_phone;
alter table kylin_order_express add appointment_time varchar(255) not null default '' comment '退票发货快递预约取件时间' after send_express_address; alter table kylin_order_express add appointment_time varchar(255) not null default '' comment '退票发货快递预约取件时间' after send_express_address;
alter table kylin_order_express add order_refunds_id varchar(255) NOT NULL DEFAULT '' COMMENT 'order_refunds_id' after order_tickets_id;
drop TABLE if exists `kylin_order_express_fee_info`; drop TABLE if exists `kylin_order_express_fee_info`;
CREATE TABLE `kylin_order_express_fee_info` CREATE TABLE `kylin_order_express_fee_info`
( (
......
...@@ -247,11 +247,11 @@ public class KylinOrderTicketsRefundServiceImpl { ...@@ -247,11 +247,11 @@ public class KylinOrderTicketsRefundServiceImpl {
Map token = CurrentUtil.getTokenClaims(); Map token = CurrentUtil.getTokenClaims();
String username = StringUtils.defaultString(((String) token.get("nickname")), ""); String username = StringUtils.defaultString(((String) token.get("nickname")), "");
String orderRefundId = refundsStatusService.userOrderTicketRefunding(orderTicketVo, refundSinglePrice, priceExpress, priceCharges, orderTicketEntitiesId, reason, picList, uid, username, kylinOrderRefundsVoBaseList.size()); String orderRefundId = refundsStatusService.userOrderTicketRefunding(orderTicketVo, refundSinglePrice, priceExpress, priceCharges, orderTicketEntitiesId, reason, picList, uid, username, kylinOrderRefundsVoBaseList.size(), sendExpressType);
if (!orderRefundId.isEmpty()) { if (!orderRefundId.isEmpty()) {
// 退款申请成功 异步去快递下单 // 退款申请成功 异步去快递下单
if (orderTicketVo.getGetTicketType().equals("express") && sendExpressType > 0) {// 快递票 if (orderTicketVo.getGetTicketType().equals("express") && sendExpressType > 0) {// 快递票
expressPlace(sendExpressType, expressNumber, expressContacts, expressPhone, sendExpressAddress, appointmentTime, orderTicketVo, performanceVo); expressPlace(sendExpressType, expressNumber, expressContacts, expressPhone, sendExpressAddress, appointmentTime, orderTicketVo, performanceVo, orderRefundId);
} }
HashMap<String, String> map = CollectionUtil.mapStringString(); HashMap<String, String> map = CollectionUtil.mapStringString();
...@@ -313,7 +313,11 @@ public class KylinOrderTicketsRefundServiceImpl { ...@@ -313,7 +313,11 @@ public class KylinOrderTicketsRefundServiceImpl {
} }
@Async @Async
public void expressPlace(Integer sendExpressType, String expressNumber, String expressContacts, String expressPhone, String sendExpressAddress, String appointmentTime, KylinOrderTicketVo orderTicketVo, KylinPerformanceVo performanceVo) { public void expressPlace(Integer sendExpressType, String expressNumber, String expressContacts, String expressPhone, String sendExpressAddress, String appointmentTime, KylinOrderTicketVo orderTicketVo, KylinPerformanceVo performanceVo, String orderRefundId) {
expressContacts = (null == expressContacts) ? "" : expressContacts;
expressPhone = (null == expressPhone) ? "" : expressPhone;
sendExpressAddress = (null == sendExpressAddress) ? "" : sendExpressAddress;
appointmentTime = (null == appointmentTime) ? "" : appointmentTime;
if (sendExpressType == 1) { // 上门取件 if (sendExpressType == 1) { // 上门取件
// 请求下单数据 // 请求下单数据
Map<String, String> hBody = new HashMap<>(); Map<String, String> hBody = new HashMap<>();
...@@ -345,12 +349,14 @@ public class KylinOrderTicketsRefundServiceImpl { ...@@ -345,12 +349,14 @@ public class KylinOrderTicketsRefundServiceImpl {
// 生成签名并请求 // 生成签名并请求
String result = shunfengSignUtils.generateSignatureAndRequestNew(hBody, "/public/order/v1/placeOrder"); String result = shunfengSignUtils.generateSignatureAndRequestNew(hBody, "/public/order/v1/placeOrder");
log.info("expressPlaceResult result:[{}]", result);
HashMap hashMap = new HashMap(); HashMap hashMap = new HashMap();
try { try {
hashMap = JsonUtils.fromJson(result, HashMap.class); hashMap = JsonUtils.fromJson(result, HashMap.class);
} catch (Exception e) { } catch (Exception e) {
log.info("expressPlaceExceptionInfo sendExpressType:[{}], sendExpressAddress:[{}], appointmentTime:[{}], expressNumber:[{}], orderTicketVo:[{}]", sendExpressType, sendExpressAddress, appointmentTime, expressNumber, orderTicketVo); log.info("expressPlaceParams sendExpressType:[{}], expressNumber:[{}], expressContacts:[{}], expressPhone:[{}], sendExpressAddress:[{}], appointmentTime:[{}], orderTicketVo:[{}], performanceVo:[{}]",
log.error("expressPlaceExceptionError", e); sendExpressType, expressNumber, expressContacts, expressPhone, sendExpressAddress, appointmentTime, orderTicketVo, performanceVo);
log.error("expressPlaceFromJsonException e:[{}]", e);
} }
if (null == hashMap.get("succ") || hashMap.get("succ").equals("fail")) { if (null == hashMap.get("succ") || hashMap.get("succ").equals("fail")) {
String msg = ""; String msg = "";
...@@ -359,8 +365,9 @@ public class KylinOrderTicketsRefundServiceImpl { ...@@ -359,8 +365,9 @@ public class KylinOrderTicketsRefundServiceImpl {
} else { } else {
msg = (String) hashMap.get("msg"); msg = (String) hashMap.get("msg");
} }
log.info("expressPlaceExceptionInfo sendExpressType:[{}], sendExpressAddress:[{}], appointmentTime:[{}], expressNumber:[{}], orderTicketVo:[{}]", sendExpressType, sendExpressAddress, appointmentTime, expressNumber, orderTicketVo); log.info("expressPlaceParams sendExpressType:[{}], expressNumber:[{}], expressContacts:[{}], expressPhone:[{}], sendExpressAddress:[{}], appointmentTime:[{}], orderTicketVo:[{}], performanceVo:[{}]",
log.error("expressPlaceResultError", msg); sendExpressType, expressNumber, expressContacts, expressPhone, sendExpressAddress, appointmentTime, orderTicketVo, performanceVo);
log.error("expressPlaceResultError msg:[{}]", msg);
} else { } else {
HashMap hashMapResult = (HashMap) hashMap.get("result"); HashMap hashMapResult = (HashMap) hashMap.get("result");
// 生成预快递单 REDIS 队列入数据库 // 生成预快递单 REDIS 队列入数据库
...@@ -368,10 +375,18 @@ public class KylinOrderTicketsRefundServiceImpl { ...@@ -368,10 +375,18 @@ public class KylinOrderTicketsRefundServiceImpl {
LinkedList<String> sqls = CollectionUtil.linkedListString(); LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("kylin_order_refund.refundOrderExpress")); sqls.add(SqlMapping.get("kylin_order_refund.refundOrderExpress"));
LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
String remark = (String) hashMapResult.get("remark");
String proName = (String) hashMapResult.get("proName");
String goodsValueTotal = (String) hashMapResult.get("goodsValueTotal");
String goodsNumber = (String) hashMapResult.get("goodsNumber");
remark = (null == remark) ? "" : remark;
proName = (null == proName) ? "" : proName;
goodsValueTotal = (null == goodsValueTotal) ? "" : goodsValueTotal;
goodsNumber = (null == goodsNumber) ? "" : goodsNumber;
sqlsDataA.add(new Object[]{ sqlsDataA.add(new Object[]{
orderExpressId, orderTicketVo.getPerformanceId(), orderTicketVo.getOrderTicketsId(), OrderExpressCode, hashMapResult.get("mailno"), expressType, hashMapResult.get("filter_result"), hashMapResult.get("remark"), KylinTableStatusConst.ORDER_EXPRESS_STATUS2 orderExpressId, orderTicketVo.getPerformanceId(), orderTicketVo.getOrderTicketsId(), orderRefundId, OrderExpressCode, hashMapResult.get("mailno"), expressType, hashMapResult.get("filter_result"), remark, KylinTableStatusConst.ORDER_EXPRESS_STATUS2
, 2, sendExpressType, expressContacts, expressPhone, sendExpressAddress, appointmentTime , 2, sendExpressType, expressContacts, expressPhone, sendExpressAddress, appointmentTime
, hashMapResult.get("proName"), hashMapResult.get("cargoTypeCode"), hashMapResult.get("limitTypeCode"), hashMapResult.get("expressTypeCode"), hashMapResult.get("goodsValueTotal"), hashMapResult.get("goodsNumber") , proName, hashMapResult.get("cargoTypeCode"), hashMapResult.get("limitTypeCode"), hashMapResult.get("expressTypeCode"), goodsValueTotal, goodsNumber
, now , now
}); });
queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_ORDER_REFUND_EXPRESS.getKey(), queueUtils.sendMsgByRedis(MQConst.KylinQueue.SQL_ORDER_REFUND_EXPRESS.getKey(),
...@@ -389,13 +404,13 @@ public class KylinOrderTicketsRefundServiceImpl { ...@@ -389,13 +404,13 @@ public class KylinOrderTicketsRefundServiceImpl {
} else if (sendExpressType == 2) { // 自主发货 } else if (sendExpressType == 2) { // 自主发货
// 生成预快递单 REDIS 队列入数据库 // 生成预快递单 REDIS 队列入数据库
String orderExpressId = IDGenerator.nextSnowId(); String orderExpressId = IDGenerator.nextSnowId();
String OrderExpressCode = "NEWUR" + orderExpressId; String OrderExpressCode = "NOWUR" + orderExpressId;
LocalDateTime now = LocalDateTime.now(); LocalDateTime now = LocalDateTime.now();
LinkedList<String> sqls = CollectionUtil.linkedListString(); LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("kylin_order_refund.refundOrderExpress")); sqls.add(SqlMapping.get("kylin_order_refund.refundOrderExpress"));
LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr(); LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
sqlsDataA.add(new Object[]{ sqlsDataA.add(new Object[]{
orderExpressId, orderTicketVo.getPerformanceId(), orderTicketVo.getOrderTicketsId(), OrderExpressCode, expressNumber, expressType, "", "", KylinTableStatusConst.ORDER_EXPRESS_STATUS2 orderExpressId, orderTicketVo.getPerformanceId(), orderTicketVo.getOrderTicketsId(), orderRefundId, OrderExpressCode, expressNumber, expressType, "", "", KylinTableStatusConst.ORDER_EXPRESS_STATUS2
, 2, sendExpressType, expressContacts, expressPhone, sendExpressAddress, appointmentTime , 2, sendExpressType, expressContacts, expressPhone, sendExpressAddress, appointmentTime
, "", "", "", "", "", "" , "", "", "", "", "", ""
, now , now
......
...@@ -60,7 +60,8 @@ public class KylinRefundsStatusServiceImpl { ...@@ -60,7 +60,8 @@ public class KylinRefundsStatusServiceImpl {
String picList, String picList,
String uid, String uid,
String username, String username,
int refundCount int refundCount,
Integer sendExpressType
) { ) {
try { try {
LocalDateTime time = LocalDateTime.now(); LocalDateTime time = LocalDateTime.now();
...@@ -110,7 +111,11 @@ public class KylinRefundsStatusServiceImpl { ...@@ -110,7 +111,11 @@ public class KylinRefundsStatusServiceImpl {
kylinOrderRefunds.setPriceExpress(priceExpress); kylinOrderRefunds.setPriceExpress(priceExpress);
kylinOrderRefunds.setPriceCharges(priceCharges); kylinOrderRefunds.setPriceCharges(priceCharges);
kylinOrderRefunds.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY); kylinOrderRefunds.setStatus(KylinTableStatusConst.ORDER_REFUND_STATUS_APPLY);
kylinOrderRefunds.setType(KylinTableStatusConst.ORDER_REFUND_TYPE_APPLY); if (orderInfo.getGetTicketType().equals("express") && sendExpressType > 0) {// 快递票
kylinOrderRefunds.setType(KylinTableStatusConst.ORDER_REFUND_TYPE_APPLY3);
} else {
kylinOrderRefunds.setType(KylinTableStatusConst.ORDER_REFUND_TYPE_APPLY2);
}
kylinOrderRefunds.setApplicantId(uid); kylinOrderRefunds.setApplicantId(uid);
kylinOrderRefunds.setApplicantName(username); kylinOrderRefunds.setApplicantName(username);
kylinOrderRefunds.setApplicantAt(time); kylinOrderRefunds.setApplicantAt(time);
......
...@@ -72,13 +72,13 @@ public class HttpsUtils { ...@@ -72,13 +72,13 @@ public class HttpsUtils {
HttpPost httpPost = new HttpPost(url); HttpPost httpPost = new HttpPost(url);
// 设置头信息 // 设置头信息
if (CollectionUtils.isEmpty(header)) { if (!CollectionUtils.isEmpty(header)) {
for (Map.Entry<String, String> entry : header.entrySet()) { for (Map.Entry<String, String> entry : header.entrySet()) {
httpPost.addHeader(entry.getKey(), entry.getValue()); httpPost.addHeader(entry.getKey(), entry.getValue());
} }
} }
// 设置请求参数 // 设置请求参数
if (CollectionUtils.isEmpty(param)) { if (!CollectionUtils.isEmpty(param)) {
List<NameValuePair> formparams = new ArrayList<NameValuePair>(); List<NameValuePair> formparams = new ArrayList<NameValuePair>();
for (Map.Entry<String, String> entry : param.entrySet()) { for (Map.Entry<String, String> entry : param.entrySet()) {
//给参数赋值 //给参数赋值
......
...@@ -73,6 +73,7 @@ public class ShunfengSignUtils { ...@@ -73,6 +73,7 @@ public class ShunfengSignUtils {
Map<String, String> querys = new HashMap<>(); Map<String, String> querys = new HashMap<>();
try { try {
HttpEntity httpEntity = new StringEntity(body, "utf-8"); HttpEntity httpEntity = new StringEntity(body, "utf-8");
log.info("generateSignatureAndRequestNew body:[{}], headers:[{}]", body, headers);
String post = HttpsUtils.post(URL + url, headers, querys, httpEntity); String post = HttpsUtils.post(URL + url, headers, querys, httpEntity);
return post; return post;
} catch (Exception e) { } catch (Exception e) {
......
...@@ -31,7 +31,7 @@ kylin_order_ticket_entities.refund=UPDATE kylin_order_ticket_entities SET is_pay ...@@ -31,7 +31,7 @@ kylin_order_ticket_entities.refund=UPDATE kylin_order_ticket_entities SET is_pay
kylin_order_refund.refund=INSERT INTO kylin_order_refunds (order_refunds_id,order_tickets_id,order_refund_code,price,price_express,price_charges,status,type,applicant_id,applicant_name,applicant_at,reason,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?) kylin_order_refund.refund=INSERT INTO kylin_order_refunds (order_refunds_id,order_tickets_id,order_refund_code,price,price_express,price_charges,status,type,applicant_id,applicant_name,applicant_at,reason,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)
kylin_order_refund_entities.refund=INSERT INTO kylin_order_refund_entities (order_refunds_entities_id,order_refunds_id,refund_price,order_ticket_entities_id,created_at) VALUES(?,?,?,?,?) kylin_order_refund_entities.refund=INSERT INTO kylin_order_refund_entities (order_refunds_entities_id,order_refunds_id,refund_price,order_ticket_entities_id,created_at) VALUES(?,?,?,?,?)
kylin_order_refund_pic.refund=INSERT INTO kylin_order_refund_pic (refund_pic_id,order_refunds_id,pic_url,created_at) VALUES (?,?,?,?) kylin_order_refund_pic.refund=INSERT INTO kylin_order_refund_pic (refund_pic_id,order_refunds_id,pic_url,created_at) VALUES (?,?,?,?)
kylin_order_refund.refundOrderExpress=INSERT INTO kylin_order_express (order_express_id,performances_id,order_tickets_id,order_express_code,mailno,express_type,filter_result,remark,express_status,send_type,send_express_type,express_contacts,express_phone,send_express_address,appointment_time,pro_name,cargo_type_code,limit_type_code,express_type_code,goods_value_total,goods_number,created_at) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?) kylin_order_refund.refundOrderExpress=INSERT INTO kylin_order_express (order_express_id,performances_id,order_tickets_id,order_refunds_id,order_express_code,mailno,express_type,filter_result,remark,express_status,send_type,send_express_type,express_contacts,express_phone,send_express_address,appointment_time,pro_name,cargo_type_code,limit_type_code,express_type_code,goods_value_total,goods_number,created_at) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
# ------------------------用户发起订单退款撤回---------------------------- # ------------------------用户发起订单退款撤回----------------------------
kylin_order_ticket_status.withDraw=UPDATE kylin_order_ticket_status SET status = ? ,updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null) kylin_order_ticket_status.withDraw=UPDATE kylin_order_ticket_status SET status = ? ,updated_at = ? WHERE order_id = ? and (updated_at <= ? or created_at = ? or updated_at is null)
......
...@@ -193,7 +193,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -193,7 +193,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
int ticketMemberLimit = ticketData.getLimitCountMember();//会员票种限购 int ticketMemberLimit = ticketData.getLimitCountMember();//会员票种限购
int performanceLimit = performanceData.getLimitCount();//普通演出限购 int performanceLimit = performanceData.getLimitCount();//普通演出限购
// int performanceMemberLimit = performanceData.getLimitCountMember();//会员演出限购 // int performanceMemberLimit = performanceData.getLimitCountMember();//会员演出限购
int performanceMemberLimit = 0;//会员演出限购 int performanceMemberLimit = 1;//会员演出限购
int isTrueName = ticketData.getIsTrueName();//是否演出实名 int isTrueName = ticketData.getIsTrueName();//是否演出实名
if (!canBuyStatus.contains(performanceData.getAppStatus())) { if (!canBuyStatus.contains(performanceData.getAppStatus())) {
...@@ -905,9 +905,9 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -905,9 +905,9 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
SmsEnum.ADTemplate adTemplate = null; SmsEnum.ADTemplate adTemplate = null;
if (orderTicketData.getGetTicketType().equals("express")) { if (orderTicketData.getGetTicketType().equals("express")) {
adTemplate = SmsEnum.ADTemplate.SMS_223203737; adTemplate = SmsEnum.ADTemplate.SMS_225995308;
} else if (orderTicketData.getGetTicketType().equals("electronic")) { } else if (orderTicketData.getGetTicketType().equals("electronic")) {
adTemplate = ticketData.getIsShowCode() == 1 ? SmsEnum.ADTemplate.SMS_223203737 : SmsEnum.ADTemplate.SMS_223203737; adTemplate = ticketData.getIsShowCode() == 1 ? SmsEnum.ADTemplate.SMS_225995308 : SmsEnum.ADTemplate.SMS_225995308;
} }
if (null != adTemplate) { if (null != adTemplate) {
......
...@@ -217,7 +217,7 @@ public class KylinRefundsStatusServiceImpl { ...@@ -217,7 +217,7 @@ public class KylinRefundsStatusServiceImpl {
dataUtils.delOrderRefundVo(refundInfo.getOrderRefundsId()); dataUtils.delOrderRefundVo(refundInfo.getOrderRefundsId());
dataUtils.delOrderRefundVoByOrderId(refundInfo.getOrderTicketsId()); dataUtils.delOrderRefundVoByOrderId(refundInfo.getOrderTicketsId());
if (refundInfo.getType() == KylinTableStatusConst.ORDER_REFUND_TYPE_APPLY) { if (refundInfo.getType() != KylinTableStatusConst.ORDER_REFUND_TYPE_AUTO) {
// 退还库存 // 退还库存
for (String entitiesId : orderTicketEntitiesIdsArr) { for (String entitiesId : orderTicketEntitiesIdsArr) {
KylinOrderTicketEntities entitiesInfo = kylinOrderTicketEntitiesMapper.selectOne( KylinOrderTicketEntities entitiesInfo = kylinOrderTicketEntitiesMapper.selectOne(
...@@ -229,7 +229,7 @@ public class KylinRefundsStatusServiceImpl { ...@@ -229,7 +229,7 @@ public class KylinRefundsStatusServiceImpl {
dataUtils.changeBuyInfo(orderInfo.getUserId(), entitiesInfo.getEnterIdCode(), orderRelations.getPerformanceId(), entitiesInfo.getTicketId(), -1); dataUtils.changeBuyInfo(orderInfo.getUserId(), entitiesInfo.getEnterIdCode(), orderRelations.getPerformanceId(), entitiesInfo.getTicketId(), -1);
} }
} }
// 退所有优惠券 提前购优惠不退 // 退所有优惠券 提前购优惠不退
if (newStatus == KylinTableStatusConst.ORDER_STATUS4) { if (newStatus == KylinTableStatusConst.ORDER_STATUS4) {
KylinPerformanceVo performanceVo = dataUtils.getPerformanceVo(orderRelations.getPerformanceId()); KylinPerformanceVo performanceVo = dataUtils.getPerformanceVo(orderRelations.getPerformanceId());
if (performanceVo.getIsRefundVoucher() > 0) { if (performanceVo.getIsRefundVoucher() > 0) {
......
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