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

调整更新物料库为已上传状态。

yujia 7 лет назад
Родитель
Сommit
813100ae2e

+ 26 - 3
src/main/java/com/uas/platform/b2c/external/erp/prod/service/impl/ProdServiceImpl.java

@@ -33,6 +33,9 @@ import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageImpl;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.jpa.domain.Specification;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 
@@ -40,6 +43,8 @@ import javax.persistence.criteria.CriteriaBuilder;
 import javax.persistence.criteria.CriteriaQuery;
 import javax.persistence.criteria.Predicate;
 import javax.persistence.criteria.Root;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -69,6 +74,9 @@ public class ProdServiceImpl implements ProdService {
     @Autowired
     private ProductPrivateDao productPrivateDao;
 
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
     @Autowired
     private ReleaseProductByBatchService releaseProductByBatchService;
 
@@ -234,14 +242,29 @@ public class ProdServiceImpl implements ProdService {
                 content1.add(prod);
             }
         }
-        PageImpl<Prod> page = new PageImpl<>(content1, new PageInfo(pageParams), productPrivates.getTotalElements());
+        PageImpl<Prod> page = new PageImpl<>(content1, info, productPrivates.getTotalElements());
         return page;
     }
 
+    @Transactional
     @Override
-    public void updateNewProdDowned(List<String> list) {
+    public void updateNewProdDowned(final List<String> list) {
         if (!CollectionUtils.isEmpty(list)) {
-            productDao.updateProductMallERPDowned(list);
+            String sql = "update products set pr_erpdown = '已上传' where pr_pcmpcode = ? and pr_pbranden = ?;";
+            jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    String str = list.get(i);
+                    String[] split = str.split("-");
+                    ps.setString(1, split[0]);
+                    ps.setString(2, split[1]);
+                }
+
+                @Override
+                public int getBatchSize() {
+                    return list.size();
+                }
+            });
         }
     }
 }

+ 3 - 1
src/main/java/com/uas/platform/b2c/external/erp/prod/util/ModelConvertUtil.java

@@ -4,6 +4,8 @@ import com.uas.api.b2c_erp.seller.model.Prod;
 import com.uas.platform.b2c.prod.commodity.model.V_ProductPrivate;
 import com.uas.platform.b2c.prod.product.component.modal.ComponentInfo;
 
+import java.util.UUID;
+
 /**
  * 类型转换
  *
@@ -31,7 +33,7 @@ public class ModelConvertUtil {
        prod.setPr_uuid(v_productPrivate.getCmpUuId());
        prod.setPbrand(v_productPrivate.getPbrand());
        prod.setPbranden(v_productPrivate.getPbranden());
-       prod.setPr_code(v_productPrivate.getProdNum());
+       prod.setPr_code(UUID.randomUUID().toString());
        prod.setPr_spec(v_productPrivate.getSpec());
        prod.setPr_unit(v_productPrivate.getUnit());
        return prod;