From af8ccc5f77f7ee8bbb6c3edbb32d5af8fea70c50 Mon Sep 17 00:00:00 2001 From: xhxu Date: Thu, 9 Jun 2022 17:08:14 +0800 Subject: [PATCH] //tt product --- .../controller/market/WxCouponController.java | 20 ++++++ .../com/iformall/enums/EnumSpuSyncStatus.java | 1 + .../com/iformall/service/WxCouponService.java | 4 ++ .../service/impl/WxCouponServiceImpl.java | 68 +++++++++++++++++++ 4 files changed, 93 insertions(+) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/market/WxCouponController.java b/mallinkAdmin/src/main/java/com/iformall/controller/market/WxCouponController.java index d441c5fc9..cf60c27b2 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/market/WxCouponController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/market/WxCouponController.java @@ -655,4 +655,24 @@ public class WxCouponController extends BaseController { } } + @ApiOperation("实时查询审核状态") + @GetMapping("/goods/product/draft") + @SystemControllerLog(description = "实时查询审核状态") + public ResultData productDraft(Long id) { + if (id == null) { + return new ResultData(ResultData.ERROR, "缺少id"); + } + return wxCouponService.productDraftGet(id); + } + + @ApiOperation("实时查询线上商品状态") + @GetMapping("/goods/product/online") + @SystemControllerLog(description = "实时查询审核状态") + public ResultData productOnline(Long id) { + if (id == null) { + return new ResultData(ResultData.ERROR, "缺少id"); + } + return wxCouponService.productOnlineGet(id); + } + } diff --git a/mallinkService/src/main/java/com/iformall/enums/EnumSpuSyncStatus.java b/mallinkService/src/main/java/com/iformall/enums/EnumSpuSyncStatus.java index 537553ae3..43de3788a 100644 --- a/mallinkService/src/main/java/com/iformall/enums/EnumSpuSyncStatus.java +++ b/mallinkService/src/main/java/com/iformall/enums/EnumSpuSyncStatus.java @@ -11,6 +11,7 @@ public enum EnumSpuSyncStatus { sync_pull_off(2, "下架"), sync_audit_rejection(3, "审核拒绝"), sync_audit_pass(4, "审核通过"), + sync_audit_disable(5, "封禁"), ; public static EnumSpuSyncStatus getEnum(Integer code) { diff --git a/mallinkService/src/main/java/com/iformall/service/WxCouponService.java b/mallinkService/src/main/java/com/iformall/service/WxCouponService.java index c33b48c27..38110856c 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxCouponService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxCouponService.java @@ -282,4 +282,8 @@ public interface WxCouponService { int handlerTtGoodsAudit(TtCouponChannelPoi couponChannelPoi); + + ResultData productDraftGet(Long id); + + ResultData productOnlineGet(Long id); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java index efe13ecf5..343b39bfa 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java @@ -1356,6 +1356,74 @@ public class WxCouponServiceImpl implements WxCouponService { return ttCouponChannelPoiMapper.updateBySpuId(couponChannelPoi); } + @Override + public ResultData productDraftGet(Long id) { + TtCouponChannelPoi ttCouponChannelPoi = ttCouponChannelPoiMapper.selectById(id); + if(ttCouponChannelPoi == null){ + return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL.getCode(),"该商品未提交审核"); + } + try { + TtWebService ttWebService = ttMerchantPoiService.getTtWebService(ttCouponChannelPoi); + List products = ttWebService.getGoodsService().productDraftGet(null, ttCouponChannelPoi.getId().toString()); + if(products.size() > 0){ + Product product = products.get(0); + if(product.getDraftStatus().intValue() == 12 && !EnumSpuSyncStatus.sync_audit_rejection.getCode().equals(ttCouponChannelPoi.getLastStatus())){ + ttCouponChannelPoi.setLastStatus(EnumSpuSyncStatus.sync_audit_rejection.getCode()); + ttCouponChannelPoi.setLastStatusDesc(product.getAuditMsg()); + ttCouponChannelPoi.setUpdateDate(new Date()); + ttCouponChannelPoiMapper.updateById(ttCouponChannelPoi); + + }else if(product.getDraftStatus().intValue() == 1 && !EnumSpuSyncStatus.sync_audit_pass.getCode().equals(ttCouponChannelPoi.getLastStatus())){ + ttCouponChannelPoi.setLastStatus(EnumSpuSyncStatus.sync_audit_pass.getCode()); + ttCouponChannelPoi.setLastStatusDesc(""); + ttCouponChannelPoi.setUpdateDate(new Date()); + ttCouponChannelPoiMapper.updateById(ttCouponChannelPoi); + } + + return new ResultData(product); + }else{ + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR.getCode(),"未查询到审核数据"); + } + } catch (WxErrorException e) { + e.printStackTrace(); + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR.getCode(),e.getMessage()); + } + } + + @Override + public ResultData productOnlineGet(Long id) { + TtCouponChannelPoi ttCouponChannelPoi = ttCouponChannelPoiMapper.selectById(id); + if(ttCouponChannelPoi == null){ + return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL.getCode(),"该商品未提交审核"); + } + try { + TtWebService ttWebService = ttMerchantPoiService.getTtWebService(ttCouponChannelPoi); + List products = ttWebService.getGoodsService().productOnlineGet(null, ttCouponChannelPoi.getId().toString()); + if(products.size() > 0){ + Product product = products.get(0); + if(product.getOnlineStatus().intValue() == 1 && !EnumSpuSyncStatus.sync_put_on.getCode().equals(ttCouponChannelPoi.getStatus())){ + ttCouponChannelPoi.setStatus(EnumSpuSyncStatus.sync_put_on.getCode()); + ttCouponChannelPoi.setUpdateDate(new Date()); + ttCouponChannelPoiMapper.updateById(ttCouponChannelPoi); + }else if(product.getOnlineStatus().intValue() == 2 && !EnumSpuSyncStatus.sync_pull_off.getCode().equals(ttCouponChannelPoi.getStatus())){ + ttCouponChannelPoi.setStatus(EnumSpuSyncStatus.sync_pull_off.getCode()); + ttCouponChannelPoi.setUpdateDate(new Date()); + ttCouponChannelPoiMapper.updateById(ttCouponChannelPoi); + }else if(product.getOnlineStatus().intValue() == 3 && !EnumSpuSyncStatus.sync_audit_disable.getCode().equals(ttCouponChannelPoi.getStatus())){ + ttCouponChannelPoi.setStatus(EnumSpuSyncStatus.sync_audit_disable.getCode()); + ttCouponChannelPoi.setUpdateDate(new Date()); + ttCouponChannelPoiMapper.updateById(ttCouponChannelPoi); + } + return new ResultData(product); + }else{ + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR.getCode(),"未查询到在线数据"); + } + } catch (WxErrorException e) { + e.printStackTrace(); + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR.getCode(),e.getMessage()); + } + } + private void syncCouponChannelPoi(WxCoupon coupon,Long couponChannelId,String productId){ TtCouponChannelPoi ttCouponChannelPoi = ttCouponChannelPoiMapper.selectById(coupon.getId()); Date date = new Date();