添加ptl数据删除定时任务

yun-zuoyi
宋军超 5 years ago
parent 5b17289c4f
commit 4d701aa9c4

@ -476,7 +476,7 @@ public class PtlEnumUtil {
@JsonFormat(shape = JsonFormat.Shape.OBJECT) @JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum SYNC_PATTERN { public enum SYNC_PATTERN {
UPDATE(1, "修改"), UPDATE(1, "新增或修改"),
INSERT(2, "新增"); INSERT(2, "新增");
private int value; private int value;

@ -1360,7 +1360,7 @@ public class PtlPcnEnumUtil {
@JsonFormat(shape = JsonFormat.Shape.OBJECT) @JsonFormat(shape = JsonFormat.Shape.OBJECT)
public enum SYNC_PATTERN { public enum SYNC_PATTERN {
UPDATE(1, "修改"), UPDATE(1, "新增或修改"),
INSERT(2, "新增"); INSERT(2, "新增");
private int value; private int value;

@ -6,6 +6,7 @@ import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.repository.NoRepositoryBean; import org.springframework.data.repository.NoRepositoryBean;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -378,4 +379,7 @@ public interface BaseRepository <T, ID extends Serializable> extends JpaReposito
double findMinByProperty(String sumPropertyName,String groupByName,String propertyName, Object value); double findMinByProperty(String sumPropertyName,String groupByName,String propertyName, Object value);
double findMinByProperties(String sumPropertyName,String groupByName,String[] paramName,Object[] paramValue); double findMinByProperties(String sumPropertyName,String groupByName,String[] paramName,Object[] paramValue);
List<T> findByHqlWhereByClear(DdlPackBean packBean, String dateTime);
} }

@ -1548,4 +1548,16 @@ public class BaseRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRep
} }
return num; return num;
} }
@Override
public List<T> findByHqlWhereByClear(DdlPackBean packBean, String dateTime) {
StringBuffer queryString = new StringBuffer();
queryString.append("from " + persistentClass.getSimpleName() + " as model where 1=1 and model.createDatetime <= " + dateTime + " ");
if (packBean != null) {
queryString.append(packBean.getWhereAppend());
}
return entityManager.createQuery(queryString.toString()).getResultList();
}
} }

@ -82,11 +82,11 @@ public class PtlBom extends BaseBean implements Serializable {
@Column(name = "EFF_START_TIME") @Column(name = "EFF_START_TIME")
@ApiParam("有效起始日期") @ApiParam("有效起始日期")
@DynamicField(webFieldType = WmsEnumUtil.FIELD_TYPE.DATETIME) @DynamicField(webFieldType = WmsEnumUtil.FIELD_TYPE.TEXT)
private Date effStartTime; private String effStartTime;
@Column(name = "EFF_END_TIME") @Column(name = "EFF_END_TIME")
@ApiParam("有效截止日期") @ApiParam("有效截止日期")
@DynamicField(webFieldType = WmsEnumUtil.FIELD_TYPE.DATETIME) @DynamicField(webFieldType = WmsEnumUtil.FIELD_TYPE.TEXT)
private Date effEndTime; private String effEndTime;
} }

@ -53,6 +53,6 @@ public class PtlPcnClear extends BaseBean implements Serializable {
@Column(name = "LAST_SYNC_TIME") @Column(name = "LAST_SYNC_TIME")
@ApiParam("上一执行时间") @ApiParam("上一执行时间")
private Date lastSyncTime; private String lastSyncTime;
} }

@ -0,0 +1,16 @@
package cn.estsh.i3plus.pojo.ptl.repository;
import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
import cn.estsh.i3plus.pojo.ptl.bean.PtlPcnClear;
import org.springframework.stereotype.Repository;
/**
* @Description:
* @Reference:
* @Author: adair.song
* @CreateDate:2019-04-24-17:13
* @Modify:
**/
@Repository
public interface PtlPcnClearRepository extends BaseRepository<PtlPcnClear, Long> {
}
Loading…
Cancel
Save