ufo / yohoufo-fore · Commits

Go to a project

Authored by tanling
Commit 5893f4bf1dae6c2fce60db293d68fb06c0fa768b 1 parent 69b64284

url

Inline Side-by-side
Showing 4 changed files with 115 additions and 115 deletions
... ... @@ -10,7 +10,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/erpUfo")
@RequestMapping("/erp")
public class ErpGWOrderController {
... ...
... ... @@ -125,8 +125,8 @@ public class SellerOrderService implements IOrderListService, IOrderDetailServi
private PriceComputePrepareProcessor priceComputePrepareProcessor;
@Autowired
private ChangePricePrepareProcessor changePricePrepareProcessor;
// @Autowired
// private ChangePricePrepareProcessor changePricePrepareProcessor;
@Autowired
private AdjustPricePrepareProcessor adjustPricePrepareProcessor;
... ... @@ -177,7 +177,7 @@ public class SellerOrderService implements IOrderListService, IOrderDetailServi
public SoldPrdComputeBo computeChangePrice(BatchChangePriceReq req) throws GatewayException {
log.info("in computeChangePrice, req {}", req);
ChangePricePrepareDTO pcn = changePricePrepareProcessor.checkAndAcquire(req);
ChangePricePrepareDTO pcn = null;
/*
if (pcn.getTips() != null){
throw new UfoServiceException(SellerOrderPrepareProcessor.TIPS_ERROR_CODE, pcn.getTips() );
... ... @@ -588,7 +588,7 @@ public class SellerOrderService implements IOrderListService, IOrderDetailServi
* @return
*/
public BatchChangePriceResp batchChangePrice(BatchChangePriceReq req) throws GatewayException {
ChangePricePrepareDTO cppDto = changePricePrepareProcessor.checkAndAcquire(req);
ChangePricePrepareDTO cppDto = null;
BigDecimal preSalePrice = cppDto.getPreSalePrice(),
salePrice = cppDto.getSalePrice();
boolean isSurper = cppDto.isSuper();
... ...
package com.yohoufo.order.service.impl.processor;
import com.google.common.base.Splitter;
import com.yohobuy.ufo.model.order.common.SkupStatus;
import com.yohobuy.ufo.model.order.req.BatchChangePriceReq;
import com.yohoufo.common.exception.GatewayException;
import com.yohoufo.common.exception.UfoServiceException;
import com.yohoufo.dal.order.SellerOrderGoodsMapper;
import com.yohoufo.dal.order.model.SellerOrderGoods;
import com.yohoufo.order.model.dto.ChangePricePrepareDTO;
import com.yohoufo.order.model.dto.SkupDto;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.Assert;
import java.math.BigDecimal;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* Created by chao.chen on 2018/11/21.
* 根据批次号来调价
*/
@Service
public class ChangePricePrepareProcessor extends AbstractChangePricePrepareProcessor<BatchChangePriceReq> {
@Autowired
private SellerOrderGoodsMapper sellerOrderGoodsMapper;
@Override
public ChangePricePrepareDTO checkAndAcquire(BatchChangePriceReq req) throws GatewayException {
String skupList = req.getSkupList();
if (StringUtils.isBlank(skupList)) {
logger.warn("ChangePrice checkAndAcquire uid illegal , req {}", req);
throw new UfoServiceException(400, "参数[skupList]为空");
}
return super.checkAndAcquire(req);
}
@Override
protected List<Integer> getExpectedSkups(BatchChangePriceReq req) {
List<String> skupStrList = Splitter.on(',').trimResults().omitEmptyStrings().splitToList(req.getSkupList());
return skupStrList.parallelStream().map(Integer::valueOf).collect(Collectors.toList());
}
@Override
protected List<SellerOrderGoods> getRealSkupOrderGoodsList(BatchChangePriceReq req) {
Long batchNo = checkNAcquireBatchNo(req.getBatchNo());
SellerOrderGoods condition = new SellerOrderGoods();
condition.setBatchNo(batchNo);
//按照批次，同一个批次不需要有两个价格，需要排除支付中的订单
return sellerOrderGoodsMapper.selectByBatchNo(condition, Arrays.asList(SkupStatus.CAN_SELL.getCode(), SkupStatus.SELL_OUT.getCode()));
}
@Override
protected Map<Integer, SkupDto> checkNeedProcessSkups(List<Integer> expectedSkups,
BigDecimal oldPrice,
BigDecimal newPrice,
Map<Integer, SkupDto> skupOfSalingMap) {
Assert.notEmpty(expectedSkups,"expectedSkups must not be empty");
Assert.notEmpty(skupOfSalingMap,"skupOfSalingMap must not be empty");
Map<Integer, SkupDto> map = new HashMap<>(expectedSkups.size());
for (Integer skup : expectedSkups) {
if (!skupOfSalingMap.containsKey(skup)) {
logger.warn("ChangePrice checkNeedProcessSkups skup is in other status , skup {}", skup);
throw new UfoServiceException(501, "部分商品不可调价");
}
SellerOrderGoods sellerOrderGoods = skupOfSalingMap.get(skup).getSellerOrderGoods();
//校验价格
if (sellerOrderGoods.getGoodsPrice().compareTo(newPrice) == 0) {
logger.warn("skup:{} goodsPrice:{} and newPrice:{} must not be equals",
skup, sellerOrderGoods.getGoodsPrice(), newPrice);
throw new UfoServiceException(401, "前后价格没有变化");
}
map.put(skup, skupOfSalingMap.get(skup));
}
return map;
}
private Long checkNAcquireBatchNo(String batchNoStr) {
Long batchNo = null;
boolean isIllegalBatchNo;
try {
isIllegalBatchNo = (StringUtils.isBlank(batchNoStr) || (batchNo = Long.valueOf(batchNoStr)) <= 0L);
} catch (Exception ex) {
isIllegalBatchNo = true;
logger.warn("ChangePrice checkAndAcquire batchNoStr illegal , batchNoStr {}", batchNoStr, ex);
}
if (isIllegalBatchNo) {
throw new UfoServiceException(400, "参数[batchNoStr]非法");
}
return batchNo;
}
}
//package com.yohoufo.order.service.impl.processor;
//
//import com.google.common.base.Splitter;
//import com.yohobuy.ufo.model.order.common.SkupStatus;
//import com.yohobuy.ufo.model.order.req.BatchChangePriceReq;
//import com.yohoufo.common.exception.GatewayException;
//import com.yohoufo.common.exception.UfoServiceException;
//import com.yohoufo.dal.order.SellerOrderGoodsMapper;
//import com.yohoufo.dal.order.model.SellerOrderGoods;
//import com.yohoufo.order.model.dto.ChangePricePrepareDTO;
//import com.yohoufo.order.model.dto.SkupDto;
//import org.apache.commons.lang3.StringUtils;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//import org.springframework.util.Assert;
//
//import java.math.BigDecimal;
//import java.util.Arrays;
//import java.util.HashMap;
//import java.util.List;
//import java.util.Map;
//import java.util.stream.Collectors;
//
///**
// * Created by chao.chen on 2018/11/21.
// * 根据批次号来调价
// */
//@Service
//public class ChangePricePrepareProcessor extends AbstractChangePricePrepareProcessor<BatchChangePriceReq> {
//
// @Autowired
// private SellerOrderGoodsMapper sellerOrderGoodsMapper;
//
// @Override
// public ChangePricePrepareDTO checkAndAcquire(BatchChangePriceReq req) throws GatewayException {
// String skupList = req.getSkupList();
// if (StringUtils.isBlank(skupList)) {
// logger.warn("ChangePrice checkAndAcquire uid illegal , req {}", req);
// throw new UfoServiceException(400, "参数[skupList]为空");
// }
// return super.checkAndAcquire(req);
// }
//
//
// @Override
// protected List<Integer> getExpectedSkups(BatchChangePriceReq req) {
// List<String> skupStrList = Splitter.on(',').trimResults().omitEmptyStrings().splitToList(req.getSkupList());
// return skupStrList.parallelStream().map(Integer::valueOf).collect(Collectors.toList());
// }
//
// @Override
// protected List<SellerOrderGoods> getRealSkupOrderGoodsList(BatchChangePriceReq req) {
// Long batchNo = checkNAcquireBatchNo(req.getBatchNo());
// SellerOrderGoods condition = new SellerOrderGoods();
// condition.setBatchNo(batchNo);
// //按照批次，同一个批次不需要有两个价格，需要排除支付中的订单
// return sellerOrderGoodsMapper.selectByBatchNo(condition, Arrays.asList(SkupStatus.CAN_SELL.getCode(), SkupStatus.SELL_OUT.getCode()));
// }
//
// @Override
// protected Map<Integer, SkupDto> checkNeedProcessSkups(List<Integer> expectedSkups,
// BigDecimal oldPrice,
// BigDecimal newPrice,
// Map<Integer, SkupDto> skupOfSalingMap) {
// Assert.notEmpty(expectedSkups,"expectedSkups must not be empty");
// Assert.notEmpty(skupOfSalingMap,"skupOfSalingMap must not be empty");
// Map<Integer, SkupDto> map = new HashMap<>(expectedSkups.size());
//
// for (Integer skup : expectedSkups) {
//
// if (!skupOfSalingMap.containsKey(skup)) {
// logger.warn("ChangePrice checkNeedProcessSkups skup is in other status , skup {}", skup);
// throw new UfoServiceException(501, "部分商品不可调价");
// }
//
// SellerOrderGoods sellerOrderGoods = skupOfSalingMap.get(skup).getSellerOrderGoods();
//
// //校验价格
// if (sellerOrderGoods.getGoodsPrice().compareTo(newPrice) == 0) {
// logger.warn("skup:{} goodsPrice:{} and newPrice:{} must not be equals",
// skup, sellerOrderGoods.getGoodsPrice(), newPrice);
// throw new UfoServiceException(401, "前后价格没有变化");
// }
//
// map.put(skup, skupOfSalingMap.get(skup));
// }
//
//
// return map;
// }
//
//
// private Long checkNAcquireBatchNo(String batchNoStr) {
// Long batchNo = null;
// boolean isIllegalBatchNo;
// try {
// isIllegalBatchNo = (StringUtils.isBlank(batchNoStr) || (batchNo = Long.valueOf(batchNoStr)) <= 0L);
//
// } catch (Exception ex) {
// isIllegalBatchNo = true;
// logger.warn("ChangePrice checkAndAcquire batchNoStr illegal , batchNoStr {}", batchNoStr, ex);
// }
//
// if (isIllegalBatchNo) {
// throw new UfoServiceException(400, "参数[batchNoStr]非法");
// }
// return batchNo;
// }
//}
... ...
... ... @@ -13,7 +13,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping(value = "/erpUfo")
@RequestMapping("/erp")
public class ErpGWCouponController {
private final Logger logger = LoggerFactory.getLogger(getClass());
... ...