增加获取上传产品用户数

src/main/java/com/uas/platform/b2c/prod/commodity/controller/ProductController.java

@@ -430,4 +430,16 @@ public class ProductController {
 	public List<Product> getProductsByKeyword(String keyword) {
 		return new ArrayList<>();
 	}
+
+	/**
+	 * 根据起止时间统计未审核品牌数
+	 *
+	 * @param fromDate 开始时间
+	 * @param toDate 截止时间
+	 * @return 返回时间
+	 */
+	@RequestMapping(value = "/apply/count", method = RequestMethod.GET)
+	public ResultMap countProduct(Long fromDate, Long toDate) {
+		return productService.countProduct(fromDate, toDate);
+	}
 }

src/main/java/com/uas/platform/b2c/prod/commodity/dao/ProductDao.java

@@ -8,6 +8,7 @@ import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 
+import java.util.Date;
 import java.util.List;
 
 /**

src/main/java/com/uas/platform/b2c/prod/commodity/model/Product.java

@@ -22,7 +22,8 @@ import java.util.Set;
 	@Index(name = "products_brand_index", columnList = "pr_brand"),
 	@Index(name = "products_enuu_code_index", columnList = "pr_enuu,pr_code", unique = true),
 	@Index(name = "products_enuu_standard_index", columnList = "pr_enuu,pr_standard"),
-	@Index(name = "products_erpdown_index", columnList = "pr_erpdown")})
+	@Index(name = "products_erpdown_index", columnList = "pr_erpdown"),
+	@Index(name = "pr_createtime_index", columnList = "pr_create_time")})
 @Logger
 //@Cacheable
 //@org.hibernate.annotations.Cache(usage = CacheConcurrencyStrategy.READ_WRITE, region = "com.uas.platform.b2b.model.Product")

src/main/java/com/uas/platform/b2c/prod/commodity/service/ProductService.java

@@ -8,6 +8,8 @@ import com.uas.platform.b2c.trade.support.ResultMap;
 import com.uas.platform.core.model.PageInfo;
 import com.uas.platform.core.model.PageParams;
 import org.springframework.data.domain.Page;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
 
 import java.util.List;
 import java.util.Map;
@@ -344,4 +346,14 @@ public interface ProductService {
      * @param list
      */
     void saveByJdbcTemplate(List<ReleaseProductByBatch> list);
+
+
+    /**
+     * 根据起止时间统计未审核品牌数
+     *
+     * @param fromDate 开始时间
+     * @param toDate 截止时间
+     * @return 返回时间
+     */
+    ResultMap countProduct(Long fromDate, Long toDate);
 }

src/main/java/com/uas/platform/b2c/prod/commodity/service/impl/ProductServiceImpl.java

@@ -90,6 +90,7 @@ import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
+import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
 
@@ -2340,5 +2341,27 @@ public class ProductServiceImpl implements ProductService {
         }
 
     }
+
+    /**
+     * 根据起止时间统计未审核品牌数
+     *
+     * @param fromDate 开始时间
+     * @param toDate   截止时间
+     * @return 返回时间
+     */
+    @Override
+    public ResultMap countProduct(Long fromDate, Long toDate) {
+        if (fromDate == null || toDate == null) {
+            //统计所有的未审核的品牌信息
+            Integer count = jdbcTemplate.queryForInt("select count(1) from products p left join product$private pp on p.pr_id = pp.pr_id  where pp.pr_b2cenabled = 1;");
+            return ResultMap.success(count);
+        } else {
+            Date fromT = new Date(fromDate);
+            Date toT = new Date(toDate);
+            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            Integer count = jdbcTemplate.queryForInt("select count(1) from products p left join product$private pp on p.pr_id = pp.pr_id  where pr_create_time < '" + dateFormat.format(toT) + "' and pr_create_time > '" + dateFormat.format(fromT) + "' and pp.pr_b2cenabled = 1;");
+            return ResultMap.success(count);
+        }
+    }
 }