bugfix for executing job fix

Author: qq254963746

lts-core/src/main/java/com/github/ltsopensource/core/support/bean/BeanCopierFactory.java

@@ -88,7 +88,7 @@ private static String getClassCode(Integer sequence, Class<?> sourceClass, Class
 
         String beanCopierClassName = sourceClass.getSimpleName() + "2" + targetClass.getSimpleName() + BeanCopier.class.getSimpleName() + sequence;
         String classDefinitionCode = "public class " + beanCopierClassName +
-                " extends " + BeanCopierAdapter.class.getSimpleName();
+                " extends " + BeanCopierAdapter.class.getName();
 
         javaSourceBean.setClassDefinition(classDefinitionCode);
 
@@ -107,8 +107,8 @@ private static String getMethodImplCode(Integer sequence, Class<?> sourceClass,
 
         StringBuilder methodCode = new StringBuilder();
         methodCode.append("public void copyProps(").append(Object.class.getName()).append(" sourceObj, ").append(Object.class.getName()).append(" targetObj){\n");
-        methodCode.append(sourceClass.getSimpleName()).append(" source = ").append("(").append(sourceClass.getSimpleName()).append(")sourceObj;\n");
-        methodCode.append(targetClass.getSimpleName()).append(" target = ").append("(").append(targetClass.getSimpleName()).append(")targetObj;\n");
+        methodCode.append(sourceClass.getName()).append(" source = ").append("(").append(sourceClass.getName()).append(")sourceObj;\n");
+        methodCode.append(targetClass.getName()).append(" target = ").append("(").append(targetClass.getName()).append(")targetObj;\n");
 
         // 这里查找了包括父类的属性
         Field[] targetFields = ReflectionUtils.findFields(targetClass);
@@ -132,7 +132,7 @@ private static String getMethodImplCode(Integer sequence, Class<?> sourceClass,
                     if (propCvtMap != null && propCvtMap.containsKey(field.getName())) {
 
                         String converterName = field.getName() + "Converter";
-                        String converterType = PropConverter.class.getSimpleName();
+                        String converterType = PropConverter.class.getName();
 
                         methodCode.append(converterType).append(" ").append(converterName).append(" = (").append(converterType).append(")")
                                 .append(BeanCopierFactory.class.getName()).append(".getConverter(").append(sequence).append(",").append("\"").append(field.getName()).append("\");\n");

lts-core/src/main/java/com/github/ltsopensource/queue/mongo/MongoExecutingJobQueue.java

@@ -72,7 +72,7 @@ public List<JobPo> getJobs(String taskTrackerIdentity) {
     @Override
     public List<JobPo> getDeadJobs(long deadline) {
         Query<JobPo> query = template.createQuery(JobPo.class);
-        query.filter("gmtCreated < ", deadline);
+        query.filter("gmtModified < ", deadline);
         return query.asList();
     }
 

lts-jobtracker/src/main/java/com/github/ltsopensource/jobtracker/sender/JobSender.java

@@ -68,7 +68,6 @@ private List<JobPo> fetchJob(String taskTrackerNodeGroup, String taskTrackerIden
 
             // IMPORTANT: 这里要先切换队列
             try {
-                jobPo.setGmtModified(SystemClock.now());
                 appContext.getExecutingJobQueue().add(jobPo);
             } catch (DupEntryException e) {
                 LOGGER.warn("ExecutingJobQueue already exist:" + JSON.toJSONString(jobPo));