diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsOldStat.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsOldStat.java new file mode 100644 index 00000000..10516618 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsOldStat.java @@ -0,0 +1,60 @@ +package org.jeecg.modules.kc.grab.SynchronizationService; + +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync; +import org.jeecg.modules.kc.kcEvaluationsStat.entity.KcEvaluationsStat; +import org.jeecg.modules.kc.kcEvaluationsStat.service.IKcEvaluationsStatService; +import org.quartz.JobExecutionContext; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.List; +import java.util.Map; + +@Slf4j +public class SyncEvaluationsOldStat extends BaseSync { + + @Autowired + private IKcEvaluationsStatService kcEvaluationsStatService; + + + /** + * 若参数变量名修改 QuartzJobController中也需对应修改 + */ + + @Override + public void execute(JobExecutionContext jobExecutionContext) { + start(); + run(getParamMap()); + end(); + } + + + /** + * 有参定时任务实现-老版评价表 + * @param param + */ + public void run(Map param){ + kcEvaluationsStatService.updateHuanhang();//修改换行数据 + List lbpjblist = kcEvaluationsStatService.getLbpjbSyncList(); + + for(KcEvaluationsStat KcEvaluationsStat:lbpjblist){ + List entityList = kcEvaluationsStatService.getLbpjbJxsjSyncList(KcEvaluationsStat); + if(entityList!=null && entityList.size()>0){ + KcEvaluationsStat entity = entityList.get(0); + if(StringUtils.isNotBlank(entity.getCol01()) && StringUtils.isNotBlank(entity.getCol02())){ + System.out.println("lbpjb----"+entity.getCol00()); + kcEvaluationsStatService.save(entity); + } + } + } + } + + /** + * 无参定时任务实现 + */ + public void run(){ + run(null); + } + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/KcEvaluationsStatMapper.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/KcEvaluationsStatMapper.java index b03d0a9c..d58e54ee 100644 --- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/KcEvaluationsStatMapper.java +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/KcEvaluationsStatMapper.java @@ -27,4 +27,8 @@ public interface KcEvaluationsStatMapper extends BaseMapper { List getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); void updateHuanhang(); + + List getLbpjbSyncList(); + + List getLbpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); } diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/xml/KcEvaluationsStatMapper.xml b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/xml/KcEvaluationsStatMapper.xml index 5b7ecd17..c3693c09 100644 --- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/xml/KcEvaluationsStatMapper.xml +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/xml/KcEvaluationsStatMapper.xml @@ -24,6 +24,14 @@ + + + + + + + update kc_evaluations set textanscontent = REPLACE(textanscontent, '\n', ' ') diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/IKcEvaluationsStatService.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/IKcEvaluationsStatService.java index a95d1230..afdc5682 100644 --- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/IKcEvaluationsStatService.java +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/IKcEvaluationsStatService.java @@ -26,4 +26,8 @@ public interface IKcEvaluationsStatService extends IService { List getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); void updateHuanhang(); + + List getLbpjbSyncList(); + + List getLbpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); } diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/impl/KcEvaluationsStatServiceImpl.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/impl/KcEvaluationsStatServiceImpl.java index 70c6ce68..3daed39d 100644 --- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/impl/KcEvaluationsStatServiceImpl.java +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/impl/KcEvaluationsStatServiceImpl.java @@ -52,4 +52,14 @@ public class KcEvaluationsStatServiceImpl extends ServiceImpl getLbpjbSyncList() { + return baseMapper.getLbpjbSyncList(); + } + + @Override + public List getLbpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat) { + return baseMapper.getLbpjbJxsjSyncList(kcEvaluationsStat); + } }