blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/logistics/pojo/entity/PrWorkOrder.java

@@ -7,7 +7,6 @@ import lombok.EqualsAndHashCode;
 import org.springblade.core.mp.base.BaseEntity;
 
 import java.io.Serial;
-import java.io.Serializable;
 import java.math.BigDecimal;
 import java.util.Date;
 
@@ -20,7 +19,8 @@ import java.util.Date;
 @Data
 @TableName("PR_WORK_ORDER")
 @Schema(description = "车间订单->视图")
-public class PrWorkOrder  implements Serializable {
+@EqualsAndHashCode(callSuper = true)
+public class PrWorkOrder extends BaseEntity {
 
     @Serial
     private static final long serialVersionUID = 1L;

blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/DsTaskingMapper.java

@@ -95,8 +95,7 @@ public interface DsTaskingMapper extends BaseMapper<DsTaskingEntity> {
 	 * 读取老mes返工任务数据
 	 * @return
 	 */
-	List<DsTaskingEntity> selectOldMesReworkTasking(@Param("startTime") Date startTime,
-													@Param("endTime")Date endTime);
+	List<DsTaskingEntity> selectOldMesReworkTasking();
 
 	/**
 	 * 根据条件查询 新mes
@@ -134,10 +133,4 @@ public interface DsTaskingMapper extends BaseMapper<DsTaskingEntity> {
 	List<DsPartEntity> getOldMesAllPart(@Param("startTime") String startTime,
 										@Param("endTime") String endTime,
 										@Param("partCodeList") List<String> partCodeList);
-
-	/**
-	 * 获取上一次返工任务同步时间
-	 * @return
-	 */
-	DsTaskingEntity getMaxReworkSyncTime();
 }

blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/mapper/TaskingMapper.xml

@@ -116,7 +116,6 @@
     <select id="selectOldMesReworkTasking"
             resultType="org.springblade.desk.dashboard.pojo.entity.DsTaskingEntity">
         select * from P_RB_REWORK_ORDER
-        WHERE SYNC_TIME BETWEEN #{startTime} AND #{endTime}
     </select>
     <select id="selectReworkTasking" resultType="org.springblade.desk.dashboard.pojo.entity.DsTaskingEntity">
         select * from DS_TASKING where is_deleted = 0
@@ -153,11 +152,5 @@
         </if>
 
     </select>
-    <select id="getMaxReworkSyncTime" resultType="org.springblade.desk.dashboard.pojo.entity.DsTaskingEntity">
-         SELECT * FROM (
-            SELECT * FROM DS_TASKING where TASK_TYPE = 6
-            ORDER BY SYNC_TIME DESC
-        ) WHERE ROWNUM = 1;
-    </select>
 
 </mapper>

blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/service/impl/DsTaskingServiceImpl.java

@@ -1031,25 +1031,9 @@ public class DsTaskingServiceImpl extends BaseServiceImpl<DsTaskingMapper, DsTas
 	@Override
 	public boolean reworkTask() {
 		log.info("开始同步返工任务...");
-		// 1. 获取上次同步的最大时间
-		DsTaskingEntity dsTaskingEntity = taskingMapper.getMaxReworkSyncTime();
-		Date startTime = null;
-		Date endTime = new Date();
-
-		if (dsTaskingEntity != null && dsTaskingEntity.getSyncTime() != null) {
-			// 在上次同步时间基础上增加1毫秒，避免重复
-			Calendar calendar = Calendar.getInstance();
-			calendar.setTime(dsTaskingEntity.getSyncTime());
-			calendar.add(Calendar.MILLISECOND, 1);
-			startTime = calendar.getTime();
-			log.info("同步时间范围：{} - {}", startTime, endTime);
-		} else {
-			// 首次同步
-			log.info("首次同步，同步所有历史任务");
-		}
 
 		// 存储过程在老mes执行，同步老mes执行完存储过程后的数据
-		List<DsTaskingEntity> reworkTasks = taskingMapper.selectOldMesReworkTasking(startTime,endTime);
+		List<DsTaskingEntity> reworkTasks = taskingMapper.selectOldMesReworkTasking();
 
 		if (CollectionUtils.isEmpty(reworkTasks)) {
 			log.info("未读取到返工任务信息");