From b3bc53644abbb1b21b8466f16116d128329015e2 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 4 Jan 2019 14:33:41 +0800 Subject: [PATCH 01/12] =?UTF-8?q?[C=E7=AB=AF=E5=9B=BE=E7=89=87=E4=B8=8A?= =?UTF-8?q?=E4=BC=A0][=E4=BF=AE=E6=94=B9]:=E6=B7=BB=E5=8A=A0=E8=BF=87?= =?UTF-8?q?=E6=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iformall/interceptor/HttpServletRequestWrapperFilter.java | 4 +++- .../java/com/iformall/interceptor/RequestInterceptor.java | 1 + 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java b/mallinkAdmin/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java index c0e7a01d6..4df979d09 100644 --- a/mallinkAdmin/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java +++ b/mallinkAdmin/src/main/java/com/iformall/interceptor/HttpServletRequestWrapperFilter.java @@ -17,7 +17,9 @@ public class HttpServletRequestWrapperFilter implements Filter { ServletRequest requestWrapper = null; if (request instanceof HttpServletRequest) { String url = ((HttpServletRequest) request).getRequestURI(); - if (!url.contains("awsFileUpload") && !url.contains("ueditor/exec") + if (!url.contains("awsFileUpload") + && !url.contains("cimgUpload") + && !url.contains("ueditor/exec") && !url.contains("/wxCUserBasicInfo/importTemplate")) { requestWrapper = new BodyReaderHttpServletRequestWrapper((HttpServletRequest) request); } else { diff --git a/mallinkAdmin/src/main/java/com/iformall/interceptor/RequestInterceptor.java b/mallinkAdmin/src/main/java/com/iformall/interceptor/RequestInterceptor.java index bc04dfea6..efaa52f5b 100644 --- a/mallinkAdmin/src/main/java/com/iformall/interceptor/RequestInterceptor.java +++ b/mallinkAdmin/src/main/java/com/iformall/interceptor/RequestInterceptor.java @@ -45,6 +45,7 @@ public class RequestInterceptor extends HandlerInterceptorAdapter { String url = request.getRequestURL().toString(); if(url.contains("pvlog") || url.contains("awsFileUpload") + || url.contains("cimgUpload") || url.contains("ueditor/exec")) { // pvlog不检查幂等 // awsFileUpload不检查幂等 From b02bef77cb1735537e3d94c979630c50b2762fde Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 4 Jan 2019 14:48:35 +0800 Subject: [PATCH 02/12] =?UTF-8?q?[C=E7=AB=AF=E5=9B=BE=E7=89=87=E4=B8=8A?= =?UTF-8?q?=E4=BC=A0][=E4=BF=AE=E6=94=B9]:=E4=B8=8A=E4=BC=A0=E6=96=87?= =?UTF-8?q?=E4=BB=B6=E5=90=8D=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/controller/UploadController.java | 13 ++----------- 1 file changed, 2 insertions(+), 11 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/UploadController.java b/mallinkAdmin/src/main/java/com/iformall/controller/UploadController.java index d7224312d..063cc2f1f 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/UploadController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/UploadController.java @@ -209,17 +209,8 @@ public class UploadController extends BaseController { metadata.setContentType(multiReq.getContentType()); metadata.setContentLength(multiReq.getSize()); - FileOutputStream fos = null; - BufferedInputStream fs = null; - - String fileName = ""; - int dot = multiReq.getOriginalFilename().lastIndexOf('.'); - if (dot >= 0) { - fileName = "cimg/" + multiReq.getOriginalFilename().substring(dot, multiReq.getOriginalFilename().length()); - } else { - fileName = "cimg/" + UUID.randomUUID().toString(); - } - + String fileName = multiReq.getOriginalFilename(); + fileName = "cimg/" + fileName; ResultData data = awsUpload(multiReq, metadata, fileName); return data; } From 392dd7a3ddcd01b9097a748d7c01c5b5551030f4 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 4 Jan 2019 22:29:11 +0800 Subject: [PATCH 03/12] =?UTF-8?q?[coupon=E8=A1=A5=E8=B4=B4=E5=AD=97?= =?UTF-8?q?=E6=AE=B5][=E4=BF=AE=E6=94=B9]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/resources/mapper/WxCouponMapper.xml | 30 ++++++++++++++++++- 1 file changed, 29 insertions(+), 1 deletion(-) diff --git a/mallinkService/src/main/resources/mapper/WxCouponMapper.xml b/mallinkService/src/main/resources/mapper/WxCouponMapper.xml index c38315b5a..bca5a8da5 100644 --- a/mallinkService/src/main/resources/mapper/WxCouponMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxCouponMapper.xml @@ -27,10 +27,14 @@ + + - `id`,`tenant_id`,`type`,`cover_img`,`title`,`sub_title`,`sale_price`,`use_price`,`use_limit_quantity`,`send_type`,`valid_type`,`valid_start_date`,`valid_end_date`,`valid_days`,`detail`,`price`,`unit`,`remain_inventory`,`inventory`,`remark`,`status`,`create_date`,`update_date`,`business`,`support_transfer`,`subsidy_num`,`subsidy_type` + `id`,`tenant_id`,`type`,`cover_img`,`title`,`sub_title`,`sale_price`,`use_price`,`use_limit_quantity`,`send_type`, + `valid_type`,`valid_start_date`,`valid_end_date`,`valid_days`,`detail`,`price`,`unit`,`remain_inventory`,`inventory`, + `remark`,`status`,`create_date`,`update_date`,`business`,`support_transfer`,`subsidy_num`,`subsidy_type` @@ -136,6 +140,14 @@ and `support_transfer` = #{supportTransfer} + + and `subsidy_type` = #{subsidyType} + + + + and `subsidy_num` = #{subsidyNum} + + and id in @@ -255,6 +267,14 @@ and `support_transfer` = #{supportTransfer} + + and `subsidy_type` = #{subsidyType} + + + + and `subsidy_num` = #{subsidyNum} + + and id in @@ -374,6 +394,14 @@ and `support_transfer` = #{supportTransfer} + + and `subsidy_type` = #{subsidyType} + + + + and `subsidy_num` = #{subsidyNum} + + and id in From ad95a632f5da4653f35f01530be36c3f5cd6c62f Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 4 Jan 2019 22:30:18 +0800 Subject: [PATCH 04/12] =?UTF-8?q?[coupon=20channel][=E7=A7=BB=E9=99=A4]:?= =?UTF-8?q?=E7=A7=BB=E9=99=A4=E6=97=A0=E7=94=A8=E7=9A=84sql?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/resources/mapper/WxCouponChannelMapper.xml | 5 ----- 1 file changed, 5 deletions(-) diff --git a/mallinkService/src/main/resources/mapper/WxCouponChannelMapper.xml b/mallinkService/src/main/resources/mapper/WxCouponChannelMapper.xml index 9c7bd6b09..ff7fa5c41 100644 --- a/mallinkService/src/main/resources/mapper/WxCouponChannelMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxCouponChannelMapper.xml @@ -91,11 +91,6 @@ - - update wx_coupon_channel set status=#{status} where tenant_id=#{tenantId} and coupon_id=#{couponId} From d64f6bac0b8da11caae6716c5f0e055a88ebb578 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 4 Jan 2019 23:45:56 +0800 Subject: [PATCH 05/12] =?UTF-8?q?[=E5=82=A8=E5=80=BC=E5=8D=A1][=E6=96=B0?= =?UTF-8?q?=E5=A2=9E]:=E5=82=A8=E5=80=BC=E5=8D=A1=E8=B4=AD=E4=B9=B0?= =?UTF-8?q?=E6=9C=AA=E6=94=AF=E4=BB=98=E6=A3=80=E6=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../schedule/OrderExpiringSchedule.java | 21 ++++++++++++------- 1 file changed, 14 insertions(+), 7 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java index b315119fd..163040b99 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java @@ -37,21 +37,28 @@ public class OrderExpiringSchedule { Map dateMap = new HashMap(); Date curDate = new Date(); + Date expireDate = new Date(curDate.getTime() - TIME_OUT_VALUE ); - // 只检查券相关订单 + // 券相关订单 dateMap.put("type", EnumOrderType.COUPON.getCode()); - dateMap.put("endDate", new Date(curDate.getTime() - TIME_OUT_VALUE )); - List wxOrderList = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap); + dateMap.put("endDate", expireDate); + List orderCoupons = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap); + orderCoupons.parallelStream().forEach( o -> { + orderExpired(o); + }); - for(WxOrder wxOrder: wxOrderList){ - orderExpired(wxOrder); - } + // 卡相关订单 + dateMap.put("type", EnumOrderType.PREPAIDCARD.getCode()); + dateMap.put("endDate", new Date(curDate.getTime() - TIME_OUT_VALUE )); + List orderCards = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap); + orderCards.parallelStream().forEach( o -> { + orderExpired(o); + }); } @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) public void orderExpired(WxOrder order) { order.setUpdateDate(new Date()); - order.setType(EnumOrderType.COUPON.getCode()); order.setOrderStatus(EnumOrderStatus.ORDER_STATUS_OVERTIME_CANCEL.getCode()); wxOrderMapper.updateByPrimaryKeySelective(order); From 9dc21b62b096f2d1a60854cbfdc1b24f4a3d0d5e Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Fri, 4 Jan 2019 23:51:56 +0800 Subject: [PATCH 06/12] =?UTF-8?q?[=E5=82=A8=E5=80=BC=E5=8D=A1][=E6=96=B0?= =?UTF-8?q?=E5=A2=9E]:=E5=82=A8=E5=80=BC=E5=8D=A1=E8=B4=AD=E4=B9=B0?= =?UTF-8?q?=E6=9C=AA=E6=94=AF=E4=BB=98=E6=A3=80=E6=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/iformall/schedule/OrderExpiringSchedule.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java index 163040b99..3a13030c0 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java @@ -49,7 +49,7 @@ public class OrderExpiringSchedule { // 卡相关订单 dateMap.put("type", EnumOrderType.PREPAIDCARD.getCode()); - dateMap.put("endDate", new Date(curDate.getTime() - TIME_OUT_VALUE )); + dateMap.put("endDate", expireDate); List orderCards = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap); orderCards.parallelStream().forEach( o -> { orderExpired(o); From 93526c4cd1c7cde535f4cbabea845c643716177c Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Sat, 5 Jan 2019 08:08:36 +0800 Subject: [PATCH 07/12] =?UTF-8?q?[=E5=82=A8=E5=80=BC=E5=8D=A1][=E7=A7=BB?= =?UTF-8?q?=E9=99=A4]:=E5=8D=A1=E6=94=AF=E4=BB=98=E8=AE=A2=E5=8D=95?= =?UTF-8?q?=E4=B8=8D=E9=9C=80=E8=A6=81=E6=A3=80=E6=9F=A5=E8=BF=87=E6=9C=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/schedule/OrderExpiringSchedule.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java index 3a13030c0..0052426ce 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/OrderExpiringSchedule.java @@ -46,14 +46,6 @@ public class OrderExpiringSchedule { orderCoupons.parallelStream().forEach( o -> { orderExpired(o); }); - - // 卡相关订单 - dateMap.put("type", EnumOrderType.PREPAIDCARD.getCode()); - dateMap.put("endDate", expireDate); - List orderCards = wxOrderMapper.findListOfUnpaidOrderByDate(dateMap); - orderCards.parallelStream().forEach( o -> { - orderExpired(o); - }); } @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) From dcf12895b50fef842ee63051e7d4a20d88c190d3 Mon Sep 17 00:00:00 2001 From: gongbiao Date: Sat, 5 Jan 2019 11:56:10 +0800 Subject: [PATCH 08/12] =?UTF-8?q?[=E4=BC=9A=E5=91=98=E5=88=97=E8=A1=A8][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9][=E5=AF=BC=E5=85=A5]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/interceptor/RequestInterceptor.java | 3 ++- .../main/java/com/iformall/domain/vo/CUserBaseInfoT.java | 2 ++ .../service/impl/WxCUserBasicInfoServiceImpl.java | 9 +++++---- pom.xml | 9 +-------- 4 files changed, 10 insertions(+), 13 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/interceptor/RequestInterceptor.java b/mallinkAdmin/src/main/java/com/iformall/interceptor/RequestInterceptor.java index efaa52f5b..3adf70465 100644 --- a/mallinkAdmin/src/main/java/com/iformall/interceptor/RequestInterceptor.java +++ b/mallinkAdmin/src/main/java/com/iformall/interceptor/RequestInterceptor.java @@ -46,7 +46,8 @@ public class RequestInterceptor extends HandlerInterceptorAdapter { if(url.contains("pvlog") || url.contains("awsFileUpload") || url.contains("cimgUpload") - || url.contains("ueditor/exec")) { + || url.contains("ueditor/exec") + || url.contains("/wxCUserBasicInfo/importTemplate")) { // pvlog不检查幂等 // awsFileUpload不检查幂等 // ueditor 不检查幂等 diff --git a/mallinkService/src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java b/mallinkService/src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java index 9df810a27..e22fa2e31 100644 --- a/mallinkService/src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java +++ b/mallinkService/src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java @@ -4,6 +4,7 @@ import cn.afterturn.easypoi.excel.annotation.Excel; import javax.persistence.Transient; import javax.validation.constraints.NotNull; +import javax.validation.constraints.Pattern; import java.io.Serializable; public class CUserBaseInfoT implements Serializable { @@ -19,6 +20,7 @@ public class CUserBaseInfoT implements Serializable { @Excel(name="手机号",width = 20,orderNum = "3") @io.swagger.annotations.ApiModelProperty(value="微信用户绑定的手机号",name="phone") @NotNull + @Pattern(regexp = "1[34578]\\d{9}", message = "手机号不正确") private String phone; /**用户昵称**/ @Excel(name="微信昵称",width = 20,orderNum = "4") diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java index acc98d9d7..ab046fef4 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java @@ -514,12 +514,13 @@ public class WxCUserBasicInfoServiceImpl implements WxCUserBasicInfoService { final IdWorker idWorker = IdWorker.get(); ImportParams params = new ImportParams(); - IExcelDataHandler handler = new UserExcelHandler(); - handler.setNeedHandlerFields(new String[]{"姓名", "性别", "手机号", "微信昵称", "学历", "生日", "地址", "上次活跃时间", "注册时间", "标签", "成长值"});// 注意这里对应的是excel的列名。也就是对象上指定的列名。 - params.setDataHandler(handler); + //IExcelDataHandler handler = new UserExcelHandler(); + //handler.setNeedHandlerFields(new String[]{"姓名", "性别", "手机号", "微信昵称", "学历", "生日", "地址", "上次活跃时间", "注册时间", "标签", "成长值"});// 注意这里对应的是excel的列名。也就是对象上指定的列名。 + //params.setDataHandler(handler); //params.setVerifyHandler(); // 需要验证 - params.setNeedVerfiy(true); + params.setImportFields(new String[]{"姓名", "性别", "手机号", "微信昵称", "学历", "生日", "地址", "上次活跃时间", "注册时间", "标签", "成长值"}); + params.setNeedVerify(true); try { diff --git a/pom.xml b/pom.xml index 5f4d3421a..706ac09fd 100644 --- a/pom.xml +++ b/pom.xml @@ -260,14 +260,7 @@ cn.afterturn easypoi-spring-boot-starter - 3.3.0 - - - - - org.apache.poi - poi-ooxml-schemas - 3.15 + 4.0.0 From a9dc5e9a6c2ed1de2cb984701d4b6bf786522f8e Mon Sep 17 00:00:00 2001 From: gongbiao Date: Sat, 5 Jan 2019 12:21:00 +0800 Subject: [PATCH 09/12] =?UTF-8?q?[=E4=BC=9A=E5=91=98=E5=88=97=E8=A1=A8][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9][=E5=AF=BC=E5=85=A5=E6=97=B6=E6=89=8B?= =?UTF-8?q?=E6=9C=BA=E5=8F=B7=E6=A3=80=E9=AA=8C]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mallinkService/src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java b/mallinkService/src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java index e22fa2e31..f5e4a6afc 100644 --- a/mallinkService/src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java +++ b/mallinkService/src/main/java/com/iformall/domain/vo/CUserBaseInfoT.java @@ -20,7 +20,7 @@ public class CUserBaseInfoT implements Serializable { @Excel(name="手机号",width = 20,orderNum = "3") @io.swagger.annotations.ApiModelProperty(value="微信用户绑定的手机号",name="phone") @NotNull - @Pattern(regexp = "1[34578]\\d{9}", message = "手机号不正确") + @Pattern(regexp = "1[0123456789]\\d{9}", message = "手机号不正确") private String phone; /**用户昵称**/ @Excel(name="微信昵称",width = 20,orderNum = "4") From 6409723ac9bbf01d708908edacae7a6488384b16 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Sat, 5 Jan 2019 12:23:49 +0800 Subject: [PATCH 10/12] =?UTF-8?q?[=E5=82=A8=E5=80=BC=E5=8D=A1][=E4=BF=AE?= =?UTF-8?q?=E6=94=B9]:=E8=BF=87=E6=9C=9F=E4=B8=8E=E9=80=80=E6=AC=BE?= =?UTF-8?q?=E5=88=86=E7=A6=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../schedule/CouponOrderExpiringSchedule.java | 51 ++++++++++++++----- .../impl/WxRefundOrderServiceImpl.java | 4 -- 2 files changed, 39 insertions(+), 16 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java index faa011180..1f54b38f6 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java @@ -1,9 +1,14 @@ package com.iformall.schedule; +import com.iformall.common.ErrorCode; +import com.iformall.common.ResultData; import com.iformall.config.PayProperty; import com.iformall.domain.po.*; import com.iformall.enums.EnumAppType; +import com.iformall.enums.EnumCouponOrderStatus; +import com.iformall.enums.EnumCouponType; import com.iformall.enums.EnumPayType; +import com.iformall.exception.MallinkException; import com.iformall.mapper.*; import com.iformall.service.WxPayOrderService; import com.iformall.service.WxRefundOrderService; @@ -15,6 +20,7 @@ import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; +import java.util.Date; import java.util.List; @Component @@ -50,20 +56,41 @@ public class CouponOrderExpiringSchedule { List list = wxCouponOrderMapper.findExpiredCouponOrderByValidDate(); + list.parallelStream().forEach(co -> { + // 券过期与退款分离 + couponOrderExpire(co); + + if(!co.getCouponType().equals(EnumCouponType.CARD_MULTIMCH.getCode())) { + // 非储值卡, 可以退款 + WxAppinfo appinfo = new WxAppinfo(); + appinfo.setTenantId(co.getTenantId()); + appinfo.setType(EnumAppType.B.getCode()); + appinfo = wxAppinfoMapper.findList(appinfo).get(0); + + try { + wxRefundOrderService.createRefundOrder(payProperty.isReal(), appinfo, co.getId(), EnumPayType.PAY_AUTO_REFUND, null); + } catch (Exception e) { + logger.error("退款失败:"+e.getMessage()+"couponOrderId="+co.getId()); + } + } - for(WxCouponOrder co:list) { - - WxAppinfo appinfo = new WxAppinfo(); - appinfo.setTenantId(co.getTenantId()); - appinfo.setType(EnumAppType.B.getCode()); - appinfo = wxAppinfoMapper.findList(appinfo).get(0); + }); + } - try { - wxRefundOrderService.createRefundOrder(payProperty.isReal(), appinfo, co.getId(), EnumPayType.PAY_AUTO_REFUND, null); - } catch (Exception e) { - logger.error("退款失败:"+e.getMessage()+"couponOrderId="+co.getId()); - continue; - } + private void couponOrderExpire(WxCouponOrder co) { + // 标记 couponOrder过期 + WxCouponOrder wxCouponOrder = new WxCouponOrder(); + wxCouponOrder.setId(co.getId()); + if(co.getCouponType().equals(EnumCouponType.CARD_MULTIMCH.getCode())) { + wxCouponOrder.setCouponOrderStatus(EnumCouponOrderStatus.CARD_OVER_TIME.getCode()); // 卡线下退款 + } else { + wxCouponOrder.setCouponOrderStatus(EnumCouponOrderStatus.COUPON_ORDER_OVER_TIME.getCode()); //券已过期 + } + wxCouponOrder.setUpdateDate(new Date()); + try { + wxCouponOrderMapper.updateByPrimaryKeySelective(wxCouponOrder); + } catch (Exception e) { + logger.error("db failed: couponOrder-" + wxCouponOrder.getId() + ", e:" + e.getMessage()); } } } \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxRefundOrderServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxRefundOrderServiceImpl.java index f7f205af2..b36725355 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxRefundOrderServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxRefundOrderServiceImpl.java @@ -300,10 +300,6 @@ public class WxRefundOrderServiceImpl implements WxRefundOrderService { throw new MallinkException(ErrorCode.REFUND_PAY_ORDER_IS_ZERO); } - if (wxCouponOrder.getCouponOrderStatus().equals(EnumCouponOrderStatus.COUPON_ORDER_OVER_TIME.getCode())) { - logger.error("已过期: couponOrder-" + couponOrderId); - throw new MallinkException(ErrorCode.COUPON_ORDER_IS_OVER_TIME); - } if (wxCouponOrder.getCouponOrderStatus().equals(EnumCouponOrderStatus.COUPON_ORDER_INVALID.getCode())) { logger.error("已退款: couponOrder-" + couponOrderId); throw new MallinkException(ErrorCode.COUPON_ORDER_IS_OVER_TIME); From 52ab2b88cf4550229c594bb4514135af1302c68d Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Sat, 5 Jan 2019 12:44:17 +0800 Subject: [PATCH 11/12] =?UTF-8?q?[=E5=82=A8=E5=80=BC=E5=8D=A1][=E4=BF=AE?= =?UTF-8?q?=E6=94=B9]:=E5=82=A8=E5=80=BC=E5=8D=A1=E6=94=AF=E4=BB=98?= =?UTF-8?q?=E5=A1=AB=E5=86=99cUserId?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/controller/WxCardPayController.java | 7 ++++++- .../main/java/com/iformall/service/WxOrderService.java | 4 +++- .../com/iformall/service/impl/WxOrderServiceImpl.java | 8 ++------ 3 files changed, 11 insertions(+), 8 deletions(-) diff --git a/mallinkCApi/src/main/java/com/iformall/controller/WxCardPayController.java b/mallinkCApi/src/main/java/com/iformall/controller/WxCardPayController.java index e122846c4..0ea1d9a73 100644 --- a/mallinkCApi/src/main/java/com/iformall/controller/WxCardPayController.java +++ b/mallinkCApi/src/main/java/com/iformall/controller/WxCardPayController.java @@ -6,6 +6,7 @@ import com.iformall.common.ErrorCode; import com.iformall.common.ResultData; import com.iformall.domain.po.*; import com.iformall.domain.vo.WxCardSpendVo; +import com.iformall.enums.EnumMerchantStatus; import com.iformall.exception.MallinkException; import com.iformall.service.*; import io.swagger.annotations.Api; @@ -106,10 +107,14 @@ public class WxCardPayController extends BaseController { WxCUser user = getUser(); WxMerchant merchant = wxMerchantService.getById(merchantId); + if (merchant.getStatus() == EnumMerchantStatus.NOT_VALID.getCode()) { + logger.error("商户已禁用, merchantId: " + merchant.getId()); + return new ResultData(ErrorCode.MERCHANT_INFO_NOT_VALID); + } WxOrder order = null; try { - order = wxOrderService.saveCardPayOrder(merchant, totalFeeStr, payment); + order = wxOrderService.saveCardPayOrder(merchant, user, totalFeeStr, payment); } catch (MallinkException e) { logger.error("saveCardPayOrder 1" + e.getMessage()); return new ResultData(e.getErrorCode(), e.getMessage()); diff --git a/mallinkService/src/main/java/com/iformall/service/WxOrderService.java b/mallinkService/src/main/java/com/iformall/service/WxOrderService.java index dae516d91..afea50e2c 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxOrderService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxOrderService.java @@ -51,10 +51,12 @@ public interface WxOrderService { /** * 商户码-储值卡支付 * @param merchant + * @param cUser * @param totalFeeStr + * @param payment * @return 订单id */ - WxOrder saveCardPayOrder(WxMerchant merchant, String totalFeeStr, Integer payment); + WxOrder saveCardPayOrder(WxMerchant merchant, WxCUser cUser, String totalFeeStr, Integer payment); /** * 免费券订单接口 diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java index d658ec1ef..e7eb3411b 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java @@ -452,12 +452,7 @@ public class WxOrderServiceImpl implements WxOrderService { @Override @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) - public WxOrder saveCardPayOrder(WxMerchant merchant, String totalFeeStr, Integer payment) { - if (merchant.getStatus() == EnumMerchantStatus.NOT_VALID.getCode()) { - logger.error("商户已禁用, merchantId: " + merchant.getId()); - throw new MallinkException(ErrorCode.MERCHANT_INFO_NOT_VALID); - } - + public WxOrder saveCardPayOrder(WxMerchant merchant, WxCUser cUser, String totalFeeStr, Integer payment) { Date curr = new Date(); final IdWorker idWorker = IdWorker.get(); @@ -473,6 +468,7 @@ public class WxOrderServiceImpl implements WxOrderService { record.setOrderNumber(orderNumber); record.setType(EnumOrderType.PREPAIDCARD.getCode()); record.setProductId(merchant.getId()); + record.setcUserId(cUser.getId()); record.setPaymentType(EnumPayType.PAY_PAYMENT.getCode()); record.setPayment(payment); record.setOrderStatus(EnumOrderStatus.ORDER_STATUS_PENDING_PAYMENT.getCode()); From 49fb863bb3e74894262c5a4cb69dcc2e3f19c438 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Sat, 5 Jan 2019 12:51:11 +0800 Subject: [PATCH 12/12] =?UTF-8?q?[=E5=82=A8=E5=80=BC=E5=8D=A1][=E4=BF=AE?= =?UTF-8?q?=E6=94=B9]:=E5=82=A8=E5=80=BC=E5=8D=A1=E6=94=AF=E4=BB=98?= =?UTF-8?q?=E6=9B=B4=E6=96=B0order=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/WxCardSpendServiceImpl.java | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCardSpendServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCardSpendServiceImpl.java index 2c222914d..b033183ca 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCardSpendServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCardSpendServiceImpl.java @@ -119,7 +119,7 @@ public class WxCardSpendServiceImpl implements WxCardSpendService { return new ResultData(ErrorCode.DB_FAIL.getCode(), "获取payAccount失败"); } - // 5. 扣减计算 + // 4. 扣减计算 Integer payment = cardInfo.getSaleAmount() * record.getDeductionAmount() / cardInfo.getAmount(); Double dChargeFee = Math.ceil(payment * 1.0D * payAccount.getRate() / 10000); Integer real_payment = payment - dChargeFee.intValue(); @@ -132,7 +132,7 @@ public class WxCardSpendServiceImpl implements WxCardSpendService { remain_real_pament = cardInfo.getRemainingShareFeeAmount() - real_payment; } - // 6 insert card_spend + // 5 insert card_spend record.setId(idWorker.nextId()); record.setPayment(payment); record.setRealPayment(real_payment); @@ -150,6 +150,19 @@ public class WxCardSpendServiceImpl implements WxCardSpendService { return new ResultData(ErrorCode.DB_FAIL.getCode(), "card spend 插入出错!"); } + // 6. update order status + WxOrder orderUpdate = new WxOrder(); + orderUpdate.setId(order.getId()); + orderUpdate.setPaymentTime(curDate); + orderUpdate.setOrderStatus(EnumOrderStatus.ORDER_STATUS_PAYMENT_SUCCESS.getCode()); + orderUpdate.setUpdateDate(curDate); + try { + wxOrderMapper.updateByPrimaryKeySelective(orderUpdate); + } catch (Exception e) { + logger.error("order update error"); + return new ResultData(ErrorCode.DB_FAIL.getCode(), "order update 出错!"); + } + // 7. update card info cardInfo.setRemainingAmount(remaingAmount); cardInfo.setRemainingShareFeeAmount(remain_real_pament);