diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsThpjbStat.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsThpjbStat.java new file mode 100644 index 00000000..222c1d15 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsThpjbStat.java @@ -0,0 +1,159 @@ +package org.jeecg.modules.kc.grab.SynchronizationService; + +import lombok.extern.slf4j.Slf4j; +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 SyncEvaluationsThpjbStat extends BaseSync { + + @Autowired + private IKcEvaluationsStatService kcEvaluationsStatService; + + + /** + * 若参数变量名修改 QuartzJobController中也需对应修改 + */ + + @Override + public void execute(JobExecutionContext jobExecutionContext) { + start(); + run(getParamMap()); + end(); + } + + + /** + * 有参定时任务实现 + * @param param + */ + public void run(Map param){ + List thpjblist = kcEvaluationsStatService.getThpjbSyncList(); + for(KcEvaluationsStat KcEvaluationsStat:thpjblist){ + List entityList = kcEvaluationsStatService.getThpjbJxsjSyncList(KcEvaluationsStat); + if(entityList!=null && entityList.size()>0){ + KcEvaluationsStat entity = entityList.get(0); + String col2745 = entity.getCol2745(); + if(col2745.length()>0){ + System.out.println("thpjb----"+entity.getCol00()); + String arr[] = col2745.split("@"); + try { + entity.setCol28(arr[1]); + }catch (Exception e){ + entity.setCol28(""); + } + try { + entity.setCol29(arr[2]); + }catch (Exception e){ + entity.setCol29(""); + } + try { + entity.setCol30(arr[3]); + }catch (Exception e){ + entity.setCol30(""); + } + try { + entity.setCol31(arr[4]); + }catch (Exception e){ + entity.setCol31(""); + } + try { + entity.setCol32(arr[5]); + }catch (Exception e){ + entity.setCol32(""); + } + try { + entity.setCol33(arr[6]); + }catch (Exception e){ + entity.setCol33(""); + } + try { + entity.setCol34(arr[7]); + }catch (Exception e){ + entity.setCol34(""); + } + try { + entity.setCol35(arr[8]); + }catch (Exception e){ + entity.setCol35(""); + } + try { + entity.setCol36(arr[9]); + }catch (Exception e){ + entity.setCol36(""); + } + try { + entity.setCol37(arr[10]); + }catch (Exception e){ + entity.setCol37(""); + } + try { + entity.setCol38(arr[11]); + }catch (Exception e){ + entity.setCol38(""); + } + try { + entity.setCol39(arr[12]); + }catch (Exception e){ + entity.setCol39(""); + } + try { + entity.setCol40(arr[13]); + }catch (Exception e){ + entity.setCol40(""); + } + try { + entity.setCol41(arr[14]); + }catch (Exception e){ + entity.setCol41(""); + } + try { + entity.setCol42(arr[15]); + }catch (Exception e){ + entity.setCol42(""); + } + try { + entity.setCol43(arr[16]); + }catch (Exception e){ + entity.setCol43(""); + } + try { + entity.setCol44(arr[17]); + }catch (Exception e){ + entity.setCol44(""); + } + try { + entity.setCol45(arr[18]); + }catch (Exception e){ + entity.setCol45(""); + } + + try { + entity.setCol2745(arr[0]); + }catch (Exception e){ + entity.setCol2745(""); + } + kcEvaluationsStatService.save(entity); + } + } + } + + //最后的保存 +// kcEvaluationsStatService.saveBatch(inslist); + + } + + /** + * 无参定时任务实现 + */ + public void run(){ + run(null); + } + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsXstkbStat.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsXstkbStat.java new file mode 100644 index 00000000..b6c21e59 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsXstkbStat.java @@ -0,0 +1,115 @@ +package org.jeecg.modules.kc.grab.SynchronizationService; + +import lombok.extern.slf4j.Slf4j; +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 SyncEvaluationsXstkbStat extends BaseSync { + + @Autowired + private IKcEvaluationsStatService kcEvaluationsStatService; + + + /** + * 若参数变量名修改 QuartzJobController中也需对应修改 + */ + + @Override + public void execute(JobExecutionContext jobExecutionContext) { + start(); + run(getParamMap()); + end(); + } + + + /** + * 有参定时任务实现 + * @param param + */ + public void run(Map param){ + + List xstkblist = kcEvaluationsStatService.getXstkbSyncList(); + for(KcEvaluationsStat KcEvaluationsStat:xstkblist){ + List entityList = kcEvaluationsStatService.getXstkbJxsjSyncList(KcEvaluationsStat); + if(entityList!=null && entityList.size()>0){ + KcEvaluationsStat entity = entityList.get(0); + String col4655 = entity.getCol4655(); + if(col4655.length()>0){ + System.out.println("xstkb----"+entity.getCol00()); + String arr[] = col4655.split("@"); + try { + entity.setCol47(arr[1]); + }catch (Exception e){ + entity.setCol47(""); + } + try { + entity.setCol48(arr[2]); + }catch (Exception e){ + entity.setCol48(""); + } + try { + entity.setCol49(arr[3]); + }catch (Exception e){ + entity.setCol49(""); + } + try { + entity.setCol50(arr[4]); + }catch (Exception e){ + entity.setCol50(""); + } + try { + entity.setCol51(arr[5]); + }catch (Exception e){ + entity.setCol51(""); + } + try { + entity.setCol52(arr[6]); + }catch (Exception e){ + entity.setCol52(""); + } + try { + entity.setCol53(arr[7]); + }catch (Exception e){ + entity.setCol53(""); + } + try { + entity.setCol54(arr[8]); + }catch (Exception e){ + entity.setCol54(""); + } + try { + entity.setCol55(arr[9]); + }catch (Exception e){ + entity.setCol55(""); + } + try { + entity.setCol4655(arr[0]); + }catch (Exception e){ + entity.setCol4655(""); + } + kcEvaluationsStatService.save(entity); + } + } + } + + + //最后的保存 +// kcEvaluationsStatService.saveBatch(inslist); + + } + + /** + * 无参定时任务实现 + */ + public void run(){ + run(null); + } + +} diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsYbtkbStat.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsYbtkbStat.java new file mode 100644 index 00000000..1b7fc690 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsYbtkbStat.java @@ -0,0 +1,115 @@ +package org.jeecg.modules.kc.grab.SynchronizationService; + +import lombok.extern.slf4j.Slf4j; +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 SyncEvaluationsYbtkbStat 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 ybtkblist = kcEvaluationsStatService.getYbtkbSyncList(); + + for(KcEvaluationsStat KcEvaluationsStat:ybtkblist){ + List entityList = kcEvaluationsStatService.getYbtkbJxsjSyncList(KcEvaluationsStat); + if(entityList!=null && entityList.size()>0){ + KcEvaluationsStat entity = entityList.get(0); + String col1726 = entity.getCol1726(); + if(col1726.length()>0){ + System.out.println("ybtkb----"+entity.getCol00()); + String arr[] = col1726.split("@"); + try { + entity.setCol18(arr[1]); + }catch (Exception e){ + entity.setCol18(""); + } + try { + entity.setCol19(arr[2]); + }catch (Exception e){ + entity.setCol19(""); + } + try { + entity.setCol20(arr[3]); + }catch (Exception e){ + entity.setCol20(""); + } + try { + entity.setCol21(arr[4]); + }catch (Exception e){ + entity.setCol21(""); + } + try { + entity.setCol22(arr[5]); + }catch (Exception e){ + entity.setCol22(""); + } + try { + entity.setCol23(arr[6]); + }catch (Exception e){ + entity.setCol23(""); + } + try { + entity.setCol24(arr[7]); + }catch (Exception e){ + entity.setCol24(""); + } + try { + entity.setCol25(arr[8]); + }catch (Exception e){ + entity.setCol25(""); + } + try { + entity.setCol26(arr[9]); + }catch (Exception e){ + entity.setCol26(""); + } + try { + entity.setCol1726(arr[0]); + }catch (Exception e){ + entity.setCol1726(""); + } + kcEvaluationsStatService.save(entity); + } + } + } + + //最后的保存 +// kcEvaluationsStatService.saveBatch(inslist); + + } + + /** + * 无参定时任务实现 + */ + 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 75c4d81e..b03d0a9c 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 @@ -25,4 +25,6 @@ public interface KcEvaluationsStatMapper extends BaseMapper { List getXstkbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); List getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); + + void updateHuanhang(); } 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 34ae3cbe..b42f37c2 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 @@ -116,7 +116,7 @@ WHEN '2' THEN '服务大厅' WHEN '3' THEN - '后台导入' + '纸质评价' ELSE '未知数据源' END AS COL16, @@ -847,4 +847,7 @@ ORDER BY EVS.QUEID) THPJ where THPJ.COL00 not in (select col00 from kc_evaluations_stat) + + update kc_evaluations set textanscontent = REPLACE(textanscontent, '\n', ' ') + \ No newline at end of file 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 b0c0d816..a95d1230 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 @@ -24,4 +24,6 @@ public interface IKcEvaluationsStatService extends IService { List getXstkbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); List getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); + + void updateHuanhang(); } 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 5fc64d83..70c6ce68 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 @@ -47,4 +47,9 @@ public class KcEvaluationsStatServiceImpl extends ServiceImpl getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat) { return baseMapper.getThpjbJxsjSyncList(kcEvaluationsStat); } + + @Override + public void updateHuanhang() { + baseMapper.updateHuanhang(); + } } diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcSysConfig/controller/KcSysConfigController.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcSysConfig/controller/KcSysConfigController.java index ee850709..e97a00d1 100644 --- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcSysConfig/controller/KcSysConfigController.java +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcSysConfig/controller/KcSysConfigController.java @@ -279,23 +279,23 @@ public class KcSysConfigController extends JeecgController listKcb = kcKechengbiaoService.list(); - List listHisKcb = new ArrayList<>(); - for(int i=0;i queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("xqxn",kcSysConfig.getFlag1()); - kcKechengbiaoService.remove(queryWrapper); - //-----------------删除原来的数据----------------------- +// //-----------------向历史数据添加数据-------------------------- +// List listKcb = kcKechengbiaoService.list(); +// List listHisKcb = new ArrayList<>(); +// for(int i=0;i queryWrapper = new QueryWrapper<>(); +// queryWrapper.eq("xqxn",kcSysConfig.getFlag1()); +// kcKechengbiaoService.remove(queryWrapper); +// //-----------------删除原来的数据----------------------- //-----------------初始化数据------------------------ KcKechengbiao kcKechengbiao = new KcKechengbiao(); @@ -305,25 +305,25 @@ public class KcSysConfigController extends JeecgController arrayHisList = new ArrayList<>(); - List KcKetangbiaoParList = kcKetangbiaoService.list(); - for(int i=0;i queryWrapper2 = new QueryWrapper<>(); - queryWrapper2.eq("xnxq",kcSysConfig.getFlag1()); - kcKetangbiaoService.remove(queryWrapper2); - //---------------删除对应数据-------------------- +// //---------------向历史数据里添加记录---------------- +// List arrayHisList = new ArrayList<>(); +// List KcKetangbiaoParList = kcKetangbiaoService.list(); +// for(int i=0;i queryWrapper2 = new QueryWrapper<>(); +// queryWrapper2.eq("xnxq",kcSysConfig.getFlag1()); +// kcKetangbiaoService.remove(queryWrapper2); +// //---------------删除对应数据--------------------