|
@@ -238,229 +238,6 @@ public class WxNotifyController {
|
|
|
|
|
|
|
|
|
|
|
|
-
|
|
|
-
|
|
|
- @Transactional
|
|
|
- public void writeVipDataToDb(WxJsOrder wxJsOrder) {
|
|
|
- long oneYearLong = 1000 * 60 * 60 * 24 * 365l;
|
|
|
- Date now = new Date();
|
|
|
- OrderInfo orderInfo = new OrderInfo();
|
|
|
- orderInfo.setGoodsName(wxJsOrder.getGoodsName());
|
|
|
- orderInfo.setUserId(wxJsOrder.getUserId());
|
|
|
- orderInfo.setOutTradeNo(wxJsOrder.getOutTradeNo());
|
|
|
- orderInfo.setTotal(wxJsOrder.getTotal());
|
|
|
- orderInfo.setTradeType(1);
|
|
|
- orderInfo.setSuccessTime(wxJsOrder.getSuccessTime());
|
|
|
- orderInfo.setPayType(1);
|
|
|
-
|
|
|
-
|
|
|
- if ("科一专项VIP".equals(wxJsOrder.getGoodsName())) {
|
|
|
- UserVip userVip = userVipService.getUserVipByUserId(wxJsOrder.getUserId());
|
|
|
- if (userVip != null) {
|
|
|
- //修改会员信息
|
|
|
- Date km1Date = userVip.getSubject1();
|
|
|
- if (km1Date != null) { //存在会员时间
|
|
|
- if (km1Date.compareTo(now) < 0) { //会员已过期
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km1oneYear = new Date(x);
|
|
|
- userVip.setSubject1(km1oneYear);
|
|
|
- } else { //会员时间延长
|
|
|
- long x = km1Date.getTime() + oneYearLong;
|
|
|
- Date km1oneYear = new Date(x);
|
|
|
- userVip.setSubject1(km1oneYear);
|
|
|
- }
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- } else {
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km1oneYear = new Date(x);
|
|
|
- userVip.setSubject1(km1oneYear);
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
- } else {
|
|
|
- //新增会员信息
|
|
|
- UserVip uv = new UserVip();
|
|
|
- uv.setUserId(wxJsOrder.getUserId());
|
|
|
- uv.setUserName(wxJsOrder.getUserName());
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km1oneYear = new Date(x);
|
|
|
- uv.setSubject1(km1oneYear);
|
|
|
- userVipService.save(uv);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
-
|
|
|
- } else if ("科二专项VIP".equals(wxJsOrder.getGoodsName())) {
|
|
|
- UserVip userVip = userVipService.getUserVipByUserId(wxJsOrder.getUserId());
|
|
|
- if (userVip != null) {
|
|
|
- //修改会员信息
|
|
|
- Date km2Date = userVip.getSubject2();
|
|
|
- if (km2Date != null) { //存在会员时间
|
|
|
- if (km2Date.compareTo(now) < 0) { //会员已过期
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km2oneYear = new Date(x);
|
|
|
- userVip.setSubject2(km2oneYear);
|
|
|
- } else { //会员时间延长
|
|
|
- long x = km2Date.getTime() + oneYearLong;
|
|
|
- Date km2oneYear = new Date(x);
|
|
|
- userVip.setSubject2(km2oneYear);
|
|
|
- }
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- } else {
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km2oneYear = new Date(x);
|
|
|
- userVip.setSubject2(km2oneYear);
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
- } else {
|
|
|
- //新增会员信息
|
|
|
- UserVip uv = new UserVip();
|
|
|
- uv.setUserId(wxJsOrder.getUserId());
|
|
|
- uv.setUserName(wxJsOrder.getUserName());
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km2oneYear = new Date(x);
|
|
|
- uv.setSubject2(km2oneYear);
|
|
|
- userVipService.save(uv);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
- } else if ("科三专项VIP".equals(wxJsOrder.getGoodsName())) {
|
|
|
- UserVip userVip = userVipService.getUserVipByUserId(wxJsOrder.getUserId());
|
|
|
- if (userVip != null) {
|
|
|
- //修改会员信息
|
|
|
- Date km3Date = userVip.getSubject3();
|
|
|
- if (km3Date != null) { //存在会员时间
|
|
|
- if (km3Date.compareTo(now) < 0) { //会员已过期
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km3oneYear = new Date(x);
|
|
|
- userVip.setSubject3(km3oneYear);
|
|
|
- } else { //会员时间延长
|
|
|
- long x = km3Date.getTime() + oneYearLong;
|
|
|
- Date km3oneYear = new Date(x);
|
|
|
- userVip.setSubject3(km3oneYear);
|
|
|
- }
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- } else {
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km3oneYear = new Date(x);
|
|
|
- userVip.setSubject3(km3oneYear);
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
- } else {
|
|
|
- //新增会员信息
|
|
|
- UserVip uv = new UserVip();
|
|
|
- uv.setUserId(wxJsOrder.getUserId());
|
|
|
- uv.setUserName(wxJsOrder.getUserName());
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km3oneYear = new Date(x);
|
|
|
- uv.setSubject3(km3oneYear);
|
|
|
- userVipService.save(uv);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
-
|
|
|
- } else if ("科四专项VIP".equals(wxJsOrder.getGoodsName())) {
|
|
|
- UserVip userVip = userVipService.getUserVipByUserId(wxJsOrder.getUserId());
|
|
|
- if (userVip != null) {
|
|
|
- //修改会员信息
|
|
|
- Date km4Date = userVip.getSubject4();
|
|
|
- if (km4Date != null) { //存在会员时间
|
|
|
- if (km4Date.compareTo(now) < 0) { //会员已过期
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km4oneYear = new Date(x);
|
|
|
- userVip.setSubject4(km4oneYear);
|
|
|
- } else { //会员时间延长
|
|
|
- long x = km4Date.getTime() + oneYearLong;
|
|
|
- Date km4oneYear = new Date(x);
|
|
|
- userVip.setSubject4(km4oneYear);
|
|
|
- }
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- } else {
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km4oneYear = new Date(x);
|
|
|
- userVip.setSubject4(km4oneYear);
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
- } else {
|
|
|
- //新增会员信息
|
|
|
- UserVip uv = new UserVip();
|
|
|
- uv.setUserId(wxJsOrder.getUserId());
|
|
|
- uv.setUserName(wxJsOrder.getUserName());
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km4oneYear = new Date(x);
|
|
|
- uv.setSubject4(km4oneYear);
|
|
|
- userVipService.save(uv);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
-
|
|
|
- } else if ("科目一二三四所有付费权益".equals(wxJsOrder.getGoodsName())) {
|
|
|
- UserVip userVip = userVipService.getUserVipByUserId(wxJsOrder.getUserId());
|
|
|
- if (userVip != null) {
|
|
|
- //修改会员信息
|
|
|
- Date km1Date = userVip.getSubject1();
|
|
|
- Date km2Date = userVip.getSubject2();
|
|
|
- Date km3Date = userVip.getSubject3();
|
|
|
- Date km4Date = userVip.getSubject4();
|
|
|
- if (km1Date != null) { //科目一处理
|
|
|
- long x = km1Date.getTime() + oneYearLong;
|
|
|
- Date km1oneYear = new Date(x);
|
|
|
- userVip.setSubject1(km1oneYear);
|
|
|
- } else {
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km1oneYear = new Date(x);
|
|
|
- userVip.setSubject1(km1oneYear);
|
|
|
- }
|
|
|
- if (km2Date != null) { //科目二处理
|
|
|
- long x = km2Date.getTime() + oneYearLong;
|
|
|
- Date km2oneYear = new Date(x);
|
|
|
- userVip.setSubject2(km2oneYear);
|
|
|
- } else {
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km2oneYear = new Date(x);
|
|
|
- userVip.setSubject2(km2oneYear);
|
|
|
- }
|
|
|
- if (km3Date != null) { //科目三处理
|
|
|
- long x = km3Date.getTime() + oneYearLong;
|
|
|
- Date km3oneYear = new Date(x);
|
|
|
- userVip.setSubject3(km3oneYear);
|
|
|
- } else {
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km3oneYear = new Date(x);
|
|
|
- userVip.setSubject3(km3oneYear);
|
|
|
- }
|
|
|
- if (km4Date != null) { //科目四处理
|
|
|
- long x = km4Date.getTime() + oneYearLong;
|
|
|
- Date km4oneYear = new Date(x);
|
|
|
- userVip.setSubject4(km4oneYear);
|
|
|
- } else {
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date km4oneYear = new Date(x);
|
|
|
- userVip.setSubject4(km4oneYear);
|
|
|
- }
|
|
|
- userVipService.updateById(userVip);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- } else {
|
|
|
- //新增会员信息
|
|
|
- UserVip uv = new UserVip();
|
|
|
- uv.setUserId(wxJsOrder.getUserId());
|
|
|
- uv.setUserName(wxJsOrder.getUserName());
|
|
|
- long x = now.getTime() + oneYearLong;
|
|
|
- Date oneYear = new Date(x);
|
|
|
- uv.setSubject1(oneYear);
|
|
|
- uv.setSubject2(oneYear);
|
|
|
- uv.setSubject3(oneYear);
|
|
|
- uv.setSubject4(oneYear);
|
|
|
- userVipService.save(uv);
|
|
|
- orderInfoService.save(orderInfo);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
private String getSourString(WxpayNotifyDTO wxpayNotifyDTO) throws GeneralSecurityException, IOException {
|
|
|
AesUtil aesUtil = new AesUtil(wxpayConfig.getV3key().getBytes());
|
|
|
WxpayNotifyDTO.WxpaySource wxpaySource = wxpayNotifyDTO.getResource();
|