Authored by 胡古飞

Merge branch '0220'

... ... @@ -66,10 +66,13 @@ public class ProductExtMqListener extends AbstractMqListener implements ChannelA
public void updateData(final Map data, final String indexName) throws Exception {
long begin = System.currentTimeMillis();
ProductExtWithBLOBs productExtWithBLOBs = new ProductExtWithBLOBs();
productExtWithBLOBs = (ProductExtWithBLOBs) ConvertUtils.toJavaBean(productExtWithBLOBs, data);
productExtWithBLOBs = (ProductExtWithBLOBs) ConvertUtils.transMap2Bean(ProductExtWithBLOBs.class, data);
if (productExtWithBLOBs == null ) {
return;
}
if(productExtWithBLOBs.getDelayArrivalNotice()==null){
productExtWithBLOBs.setDelayArrivalNotice("");
}
Integer productId;
if (productExtWithBLOBs.getProductSkn() != null) {
Product product = productService.getBySkn(productExtWithBLOBs.getProductSkn());
... ...