yangjun
/
dbsd_kczx_java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改存储换行的数据

This commit is contained in:
yangjun 2023-08-23 23:42:24 +08:00
parent f234661cfe
commit 1d999b42f5
8 changed files with 438 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

159
jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsThpjbStat.java Normal file
View File

@ -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<String, Object> param){
List<KcEvaluationsStat> thpjblist = kcEvaluationsStatService.getThpjbSyncList();
for(KcEvaluationsStat KcEvaluationsStat:thpjblist){
List<KcEvaluationsStat> 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);
}
}

115
jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsXstkbStat.java Normal file
View File

@ -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<String, Object> param){
List<KcEvaluationsStat> xstkblist = kcEvaluationsStatService.getXstkbSyncList();
for(KcEvaluationsStat KcEvaluationsStat:xstkblist){
List<KcEvaluationsStat> 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);
}
}

115
jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncEvaluationsYbtkbStat.java Normal file
View File

@ -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<String, Object> param){
kcEvaluationsStatService.updateHuanhang();//修改换行数据
List<KcEvaluationsStat> ybtkblist = kcEvaluationsStatService.getYbtkbSyncList();
for(KcEvaluationsStat KcEvaluationsStat:ybtkblist){
List<KcEvaluationsStat> 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);
}
}

2
jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/KcEvaluationsStatMapper.java
View File

@ -25,4 +25,6 @@ public interface KcEvaluationsStatMapper extends BaseMapper<KcEvaluationsStat> {
List<KcEvaluationsStat> getXstkbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); List<KcEvaluationsStat> getXstkbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat);
List<KcEvaluationsStat> getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); List<KcEvaluationsStat> getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat);
void updateHuanhang();
} }

5
jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/mapper/xml/KcEvaluationsStatMapper.xml
View File

@ -116,7 +116,7 @@
WHEN '2' THEN WHEN '2' THEN
'服务大厅' '服务大厅'
WHEN '3' THEN WHEN '3' THEN
'后台导入' '纸质评价'
ELSE ELSE
'未知数据源' '未知数据源'
END AS COL16, END AS COL16,
@ -847,4 +847,7 @@
ORDER BY EVS.QUEID) THPJ ORDER BY EVS.QUEID) THPJ
where THPJ.COL00 not in (select col00 from kc_evaluations_stat) where THPJ.COL00 not in (select col00 from kc_evaluations_stat)
</select> </select>
<update id="updateHuanhang">
update kc_evaluations set textanscontent = REPLACE(textanscontent, '\n', ' ')
</update>
</mapper> </mapper>

2
jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/IKcEvaluationsStatService.java
View File

@ -24,4 +24,6 @@ public interface IKcEvaluationsStatService extends IService<KcEvaluationsStat> {
List<KcEvaluationsStat> getXstkbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); List<KcEvaluationsStat> getXstkbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat);
List<KcEvaluationsStat> getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat); List<KcEvaluationsStat> getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat);
void updateHuanhang();
} }

5
jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcEvaluationsStat/service/impl/KcEvaluationsStatServiceImpl.java
View File

@ -47,4 +47,9 @@ public class KcEvaluationsStatServiceImpl extends ServiceImpl<KcEvaluationsStatM
public List<KcEvaluationsStat> getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat) { public List<KcEvaluationsStat> getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat) {
return baseMapper.getThpjbJxsjSyncList(kcEvaluationsStat); return baseMapper.getThpjbJxsjSyncList(kcEvaluationsStat);
} }
@Override
public void updateHuanhang() {
baseMapper.updateHuanhang();
}
} }

72
jeecg-module-main/src/main/java/org/jeecg/modules/kc/kcSysConfig/controller/KcSysConfigController.java
View File

@ -279,23 +279,23 @@ public class KcSysConfigController extends JeecgController<KcSysConfig, IKcSysCo
kcSysConfig = kcSysConfigService.getById("1"); kcSysConfig = kcSysConfigService.getById("1");
Date dateNow = new Date(); Date dateNow = new Date();
//-----------------向历史数据添加数据-------------------------- // //-----------------向历史数据添加数据--------------------------
List<KcKechengbiao> listKcb = kcKechengbiaoService.list(); // List<KcKechengbiao> listKcb = kcKechengbiaoService.list();
List<KcKechengbiaoHis> listHisKcb = new ArrayList<>(); // List<KcKechengbiaoHis> listHisKcb = new ArrayList<>();
for(int i=0;i<listKcb.size();i++){ // for(int i=0;i<listKcb.size();i++){
KcKechengbiaoHis his = new KcKechengbiaoHis(); // KcKechengbiaoHis his = new KcKechengbiaoHis();
KcKechengbiao KcKechengbiaoPar = listKcb.get(i); // KcKechengbiao KcKechengbiaoPar = listKcb.get(i);
BeanUtils.copyProperties(KcKechengbiaoPar,his); // BeanUtils.copyProperties(KcKechengbiaoPar,his);
his.setXnxq(kcSysConfig.getFlag1()); // his.setXnxq(kcSysConfig.getFlag1());
his.setSjc(dateNow); // his.setSjc(dateNow);
listHisKcb.add(his); // listHisKcb.add(his);
} // }
kcKechengbiaoHisService.saveBatch(listHisKcb); // kcKechengbiaoHisService.saveBatch(listHisKcb);
//-----------------向历史数据添加数据-------------------------- // //-----------------向历史数据添加数据--------------------------
QueryWrapper<KcKechengbiao> queryWrapper = new QueryWrapper<>(); // QueryWrapper<KcKechengbiao> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("xqxn",kcSysConfig.getFlag1()); // queryWrapper.eq("xqxn",kcSysConfig.getFlag1());
kcKechengbiaoService.remove(queryWrapper); // kcKechengbiaoService.remove(queryWrapper);
//-----------------删除原来的数据----------------------- // //-----------------删除原来的数据-----------------------
//-----------------初始化数据------------------------ //-----------------初始化数据------------------------
KcKechengbiao kcKechengbiao = new KcKechengbiao(); KcKechengbiao kcKechengbiao = new KcKechengbiao();
@ -305,25 +305,25 @@ public class KcSysConfigController extends JeecgController<KcSysConfig, IKcSysCo
//---------------向历史数据里添加记录---------------- // //---------------向历史数据里添加记录----------------
List<KcKetangbiaoHis> arrayHisList = new ArrayList<>(); // List<KcKetangbiaoHis> arrayHisList = new ArrayList<>();
List<KcKetangbiao> KcKetangbiaoParList = kcKetangbiaoService.list(); // List<KcKetangbiao> KcKetangbiaoParList = kcKetangbiaoService.list();
for(int i=0;i<KcKetangbiaoParList.size();i++){ // for(int i=0;i<KcKetangbiaoParList.size();i++){
KcKetangbiao KcKetangbiaoPar = KcKetangbiaoParList.get(i); // KcKetangbiao KcKetangbiaoPar = KcKetangbiaoParList.get(i);
KcKetangbiaoHis hisKtb = new KcKetangbiaoHis(); // KcKetangbiaoHis hisKtb = new KcKetangbiaoHis();
BeanUtils.copyProperties(KcKetangbiaoPar,hisKtb); // BeanUtils.copyProperties(KcKetangbiaoPar,hisKtb);
hisKtb.setXnxq(kcSysConfig.getFlag1()); // hisKtb.setXnxq(kcSysConfig.getFlag1());
hisKtb.setSjc(dateNow); // hisKtb.setSjc(dateNow);
arrayHisList.add(hisKtb); // arrayHisList.add(hisKtb);
} // }
kcKetangbiaoHisService.saveBatch(arrayHisList); // kcKetangbiaoHisService.saveBatch(arrayHisList);
//---------------向历史数据里添加记录---------------- // //---------------向历史数据里添加记录----------------
//
//---------------删除对应数据-------------------- // //---------------删除对应数据--------------------
QueryWrapper<KcKetangbiao> queryWrapper2 = new QueryWrapper<>(); // QueryWrapper<KcKetangbiao> queryWrapper2 = new QueryWrapper<>();
queryWrapper2.eq("xnxq",kcSysConfig.getFlag1()); // queryWrapper2.eq("xnxq",kcSysConfig.getFlag1());
kcKetangbiaoService.remove(queryWrapper2); // kcKetangbiaoService.remove(queryWrapper2);
//---------------删除对应数据-------------------- // //---------------删除对应数据--------------------