...
|
...
|
@@ -66,13 +66,10 @@ 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.transMap2Bean(ProductExtWithBLOBs.class, data);
|
|
|
productExtWithBLOBs = (ProductExtWithBLOBs) ConvertUtils.toJavaBean(productExtWithBLOBs, data);
|
|
|
if (productExtWithBLOBs == null ) {
|
|
|
return;
|
|
|
}
|
|
|
if(productExtWithBLOBs.getDelayArrivalNotice()==null){
|
|
|
productExtWithBLOBs.setDelayArrivalNotice("");
|
|
|
}
|
|
|
Integer productId;
|
|
|
if (productExtWithBLOBs.getProductSkn() != null) {
|
|
|
Product product = productService.getBySkn(productExtWithBLOBs.getProductSkn());
|
...
|
...
|
|