Просмотр исходного кода

//tt product

release_toaliyun_real
xhxu 4 лет назад
Родитель
Сommit
af8ccc5f77
4 измененных файлов: 93 добавлений и 0 удалений
  1. +20
    -0
      mallinkAdmin/src/main/java/com/iformall/controller/market/WxCouponController.java
  2. +1
    -0
      mallinkService/src/main/java/com/iformall/enums/EnumSpuSyncStatus.java
  3. +4
    -0
      mallinkService/src/main/java/com/iformall/service/WxCouponService.java
  4. +68
    -0
      mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java

+ 20
- 0
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);
}

}

+ 1
- 0
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) {


+ 4
- 0
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);
}

+ 68
- 0
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<Product> 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<Product> 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();


Загрузка…
Отмена
Сохранить