同步物料增加处理时间

src/main/java/com/uas/platform/b2b/ps/SyncTask.java

@@ -11,6 +11,7 @@ import org.springframework.data.domain.Sort;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -43,7 +44,7 @@ public class SyncTask {
             for (PersonalProduct product : products) {
                 try {
                     productUsersService.coverToMyProduct(product.getPrId(), product.getEnUU(), product.getUserUU(), product.getMethod());
-                    personalProductService.updateStatusById(Status.DOWNLOADED.value(), product.getId());
+                    personalProductService.updateStatusById(Status.DOWNLOADED.value(), product.getId(), new Date(System.currentTimeMillis()));
                 } catch (Exception e) {
                     e.printStackTrace();
                 }

src/main/java/com/uas/platform/b2b/ps/dao/PersonalProductDao.java

@@ -9,6 +9,8 @@ import org.springframework.data.repository.query.Param;
 import org.springframework.stereotype.Repository;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.Date;
+
 
 /**
  * 个人物料处理数据库操作
@@ -26,8 +28,8 @@ public interface PersonalProductDao extends JpaSpecificationExecutor<PersonalPro
      */
     @Modifying
     @Transactional
-    @Query("update PersonalProduct p set p.status = :status where p.id = :id")
-    void updateStatusById(@Param("status") Integer status, @Param("id") Long id);
+    @Query("update PersonalProduct p set p.status = :status, p.dealTime = :date where p.id = :id")
+    void updateStatusById(@Param("status") Integer status, @Param("id") Long id, @Param("date") Date date);
 
     /**
      * 查询个人物料是否已存在

src/main/java/com/uas/platform/b2b/ps/model/PersonalProduct.java

@@ -68,6 +68,12 @@ public class PersonalProduct implements Serializable {
     @Column(name = "pr_date")
     private Date date;
 
+    /**
+     * 处理时间
+     */
+    @Column(name = "pr_dealtime")
+    private Date dealTime;
+
     public Long getId() {
         return id;
     }
@@ -124,6 +130,14 @@ public class PersonalProduct implements Serializable {
         this.date = date;
     }
 
+    public Date getDealTime() {
+        return dealTime;
+    }
+
+    public void setDealTime(Date dealTime) {
+        this.dealTime = dealTime;
+    }
+
     public PersonalProduct() {
 
     }

src/main/java/com/uas/platform/b2b/ps/service/PersonalProductService.java

@@ -3,6 +3,7 @@ package com.uas.platform.b2b.ps.service;
 import com.uas.platform.b2b.ps.model.PersonalProduct;
 import com.uas.platform.core.model.PageInfo;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -26,7 +27,7 @@ public interface PersonalProductService {
      * @param status 状态
      * @param id id
      */
-    void updateStatusById(Integer status, Long id);
+    void updateStatusById(Integer status, Long id, Date date);
 
     /**
      * 通过物料id和方法进行待处理个人物料信息

src/main/java/com/uas/platform/b2b/ps/service/impl/PersonalProductServiceImpl.java

@@ -13,6 +13,7 @@ import javax.persistence.criteria.CriteriaBuilder;
 import javax.persistence.criteria.CriteriaQuery;
 import javax.persistence.criteria.Predicate;
 import javax.persistence.criteria.Root;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -49,8 +50,8 @@ public class PersonalProductServiceImpl implements PersonalProductService {
      * @param id     id
      */
     @Override
-    public void updateStatusById(Integer status, Long id) {
-        personlProductDao.updateStatusById(status, id);
+    public void updateStatusById(Integer status, Long id, Date date) {
+        personlProductDao.updateStatusById(status, id, date);
     }
 
     /**