修改bug
This commit is contained in:
parent
e8bddbd110
commit
4e7c6f6194
|
|
@ -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<String, Object> param){
|
||||
kcEvaluationsStatService.updateHuanhang();//修改换行数据
|
||||
List<KcEvaluationsStat> lbpjblist = kcEvaluationsStatService.getLbpjbSyncList();
|
||||
|
||||
for(KcEvaluationsStat KcEvaluationsStat:lbpjblist){
|
||||
List<KcEvaluationsStat> 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);
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -27,4 +27,8 @@ public interface KcEvaluationsStatMapper extends BaseMapper<KcEvaluationsStat> {
|
|||
List<KcEvaluationsStat> getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat);
|
||||
|
||||
void updateHuanhang();
|
||||
|
||||
List<KcEvaluationsStat> getLbpjbSyncList();
|
||||
|
||||
List<KcEvaluationsStat> getLbpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -24,6 +24,14 @@
|
|||
</select>
|
||||
|
||||
|
||||
<select id="getLbpjbSyncList" resultType="org.jeecg.modules.kc.kcEvaluationsStat.entity.KcEvaluationsStat">
|
||||
SELECT DISTINCT ev.id as col00
|
||||
FROM kc_evaluation EV, KC_EVALUATIONS EVS
|
||||
WHERE ev.id = evs.evaluationid
|
||||
AND ev.evaluationver = '1'
|
||||
</select>
|
||||
|
||||
|
||||
|
||||
<select id="getYbtkbJxsjSyncList" resultType="org.jeecg.modules.kc.kcEvaluationsStat.entity.KcEvaluationsStat">
|
||||
|
||||
|
|
@ -856,6 +864,217 @@
|
|||
ON EVS.QUEID = QUE.ID) THPJ
|
||||
where THPJ.COL00 not in (select col00 from kc_evaluations_stat)
|
||||
</select>
|
||||
|
||||
|
||||
<select id="getLbpjbJxsjSyncList" resultType="org.jeecg.modules.kc.kcEvaluationsStat.entity.KcEvaluationsStat">
|
||||
SELECT distinct LBPJ.COL00,
|
||||
LBPJ.COL01,
|
||||
LBPJ.COL02,
|
||||
LBPJ.COL03,
|
||||
LBPJ.COL04,
|
||||
LBPJ.COL05,
|
||||
LBPJ.COL06,
|
||||
LBPJ.COL07,
|
||||
LBPJ.COL08,
|
||||
LBPJ.COL09,
|
||||
LBPJ.COL10,
|
||||
LBPJ.COL11,
|
||||
LBPJ.COL12,
|
||||
LBPJ.COL13,
|
||||
LBPJ.COL14,
|
||||
LBPJ.COL15,
|
||||
LBPJ.COL16,
|
||||
LBPJ.COL1726,
|
||||
LBPJ.COL18,
|
||||
LBPJ.COL19,
|
||||
LBPJ.COL20,
|
||||
LBPJ.COL21,
|
||||
LBPJ.COL22,
|
||||
LBPJ.COL23,
|
||||
LBPJ.COL24,
|
||||
LBPJ.COL25,
|
||||
LBPJ.COL26,
|
||||
LBPJ.COL2745,
|
||||
LBPJ.COL28,
|
||||
LBPJ.COL29,
|
||||
LBPJ.COL30,
|
||||
LBPJ.COL31,
|
||||
LBPJ.COL32,
|
||||
LBPJ.COL33,
|
||||
LBPJ.COL34,
|
||||
LBPJ.COL35,
|
||||
LBPJ.COL36,
|
||||
LBPJ.COL37,
|
||||
LBPJ.COL38,
|
||||
LBPJ.COL39,
|
||||
LBPJ.COL40,
|
||||
LBPJ.COL41,
|
||||
LBPJ.COL42,
|
||||
LBPJ.COL43,
|
||||
LBPJ.COL44,
|
||||
LBPJ.COL45,
|
||||
LBPJ.COL4655,
|
||||
LBPJ.COL47,
|
||||
LBPJ.COL48,
|
||||
LBPJ.COL49,
|
||||
LBPJ.COL50,
|
||||
LBPJ.COL51,
|
||||
LBPJ.COL52,
|
||||
LBPJ.COL53,
|
||||
LBPJ.COL54,
|
||||
LBPJ.COL55,
|
||||
LBPJ.COL56,
|
||||
LBPJ.COL57
|
||||
FROM (SELECT EVS.EVALUATIONID AS COL00,
|
||||
XQXN.TITLE AS COL01, -- 老版评价表(1)
|
||||
KT.KCMC AS COL02,
|
||||
KT.KKDW AS COL03,
|
||||
KT.SKJS AS COL04,
|
||||
KT.JGH AS COL05,
|
||||
KT.SKRQ AS COL06,
|
||||
KT.SKSJ AS COL07,
|
||||
KT.HH AS COL08,
|
||||
KT.SKDD AS COL09,
|
||||
XSKC.DWMC AS COL10,
|
||||
EVS.UPUSERID AS COL11,
|
||||
EVS.UPUSER AS COL12,
|
||||
TKSF.ITEM_TEXT AS COL13,
|
||||
(SELECT CONTENT
|
||||
FROM kc_evaluation EV,
|
||||
KC_EVALUATIONS EVS,
|
||||
KC_EVALUATIONANS ANS
|
||||
WHERE TRUE
|
||||
AND EV.ID = EVS.evaluationid
|
||||
AND EVS.ANSID = ANS.ID
|
||||
AND EV.evaluationver = '1'
|
||||
AND EVS.EVALUATIONID = #{col00}
|
||||
AND EVS.QUEID = '1') AS COL14,
|
||||
CASE EV.EVALUATIONVER
|
||||
WHEN '2' THEN
|
||||
'线上听课表'
|
||||
WHEN '3' THEN
|
||||
'老版评价表' --
|
||||
WHEN '4' THEN
|
||||
'同行评价表'
|
||||
ELSE
|
||||
'老版评价表'
|
||||
END AS COL15,
|
||||
CASE EV.SOURCE
|
||||
WHEN '0' THEN
|
||||
'课程中心'
|
||||
WHEN '1' THEN
|
||||
'老系统'
|
||||
WHEN '2' THEN
|
||||
'服务大厅'
|
||||
WHEN '3' THEN
|
||||
'后台导入'
|
||||
ELSE
|
||||
'未知数据源'
|
||||
END AS COL16,
|
||||
'' AS COL1726,
|
||||
'' AS COL18,
|
||||
'' AS COL19,
|
||||
'' AS COL20,
|
||||
'' AS COL21,
|
||||
'' AS COL22,
|
||||
'' AS COL23,
|
||||
'' AS COL24,
|
||||
'' AS COL25,
|
||||
'' AS COL26,
|
||||
'' AS COL2745,
|
||||
'' AS COL28,
|
||||
'' AS COL29,
|
||||
'' AS COL30,
|
||||
'' AS COL31,
|
||||
'' AS COL32,
|
||||
'' AS COL33,
|
||||
'' AS COL34,
|
||||
'' AS COL35,
|
||||
'' AS COL36,
|
||||
'' AS COL37,
|
||||
'' AS COL38,
|
||||
'' AS COL39,
|
||||
'' AS COL40,
|
||||
'' AS COL41,
|
||||
'' AS COL42,
|
||||
'' AS COL43,
|
||||
'' AS COL44,
|
||||
'' AS COL45,
|
||||
'' AS COL4655,
|
||||
'' AS COL47,
|
||||
'' AS COL48,
|
||||
'' AS COL49,
|
||||
'' AS COL50,
|
||||
'' AS COL51,
|
||||
'' AS COL52,
|
||||
'' AS COL53,
|
||||
'' AS COL54,
|
||||
'' AS COL55,
|
||||
rjzy.rjzy as col56,
|
||||
ev.rjzy as col57
|
||||
FROM (SELECT UPUSER,
|
||||
UPUSERID,
|
||||
KETANGBIAOID,
|
||||
QUEID,
|
||||
ANSID,
|
||||
EVALUATIONID,
|
||||
DETANSWER
|
||||
FROM (
|
||||
SELECT EVS.UPUSER,
|
||||
EVS.UPUSERID,
|
||||
EVS.KETANGBIAOID,
|
||||
EVS.QUEID,
|
||||
EVS.EVALUATIONID,
|
||||
EVS.ANSID,
|
||||
CASE ANS.SCORE
|
||||
WHEN '5' THEN
|
||||
'A'
|
||||
WHEN '4' THEN
|
||||
'B'
|
||||
WHEN '3' THEN
|
||||
'C'
|
||||
WHEN '2' THEN
|
||||
'D'
|
||||
WHEN '1' THEN
|
||||
'E'
|
||||
ELSE
|
||||
'F'
|
||||
END AS DETANSWER
|
||||
FROM kc_evaluation EV,
|
||||
KC_EVALUATIONS EVS,
|
||||
KC_EVALUATIONANS ANS,
|
||||
KC_EVALUATIONQUE QUE
|
||||
WHERE TRUE
|
||||
AND EV.ID = EVS.evaluationid
|
||||
AND QUE.ID = ANS.QUEID
|
||||
AND EVS.ANSID = ANS.ID
|
||||
AND EV.evaluationver = '1'
|
||||
AND EVS.EVALUATIONID = #{col00}
|
||||
AND QUE.QUETYPE = '1'
|
||||
AND QUE.id = '1'
|
||||
) EVSTMP
|
||||
ORDER BY QUEID) EVS
|
||||
LEFT JOIN (select * from KC_EVALUATION ev left join (select gh,tklx,dwmc,xm,sf,zt,ytkcs,rjzy,xqxn from kc_export_config_tpkwcqkjzglx where xqxn in (select max(xqxn) from kc_export_config_tpkwcqkjzglx)) rjzy on ev.upuserid = rjzy.gh) EV
|
||||
ON EVS.EVALUATIONID = EV.ID
|
||||
LEFT JOIN KC_KETANGBIAO KT
|
||||
ON EVS.KETANGBIAOID = KT.ID
|
||||
left join kc_export_config_tpkwcqkjzglx rjzy on kt.jgh = rjzy.gh
|
||||
LEFT JOIN KC_XQXN_HISTORY XQXN
|
||||
ON KT.SKRQ >= XQXN.START_TIME
|
||||
AND KT.SKRQ <= XQXN.END_TIME
|
||||
LEFT JOIN XXHBXSKC XSKC
|
||||
ON XSKC.GH = EVS.UPUSERID
|
||||
LEFT JOIN (SELECT A.GH, A.DWMC, A.XM, B.ITEM_VALUE, GROUP_CONCAT(distinct B.ITEM_TEXT) as ITEM_TEXT
|
||||
FROM KC_EXPORT_CONFIG_TPKWCQKJZGLX A, SYS_DICT_ITEM B
|
||||
WHERE A.TKLX = B.ITEM_VALUE
|
||||
AND B.DICT_ID = '1682386362753224705'
|
||||
GROUP BY a.gh) TKSF
|
||||
ON TKSF.GH = EVS.UPUSERID
|
||||
LEFT JOIN KC_EVALUATIONQUE QUE
|
||||
ON EVS.QUEID = QUE.ID) LBPJ
|
||||
where LBPJ.COL00 not in (select col00 from kc_evaluations_stat)
|
||||
</select>
|
||||
|
||||
<update id="updateHuanhang">
|
||||
update kc_evaluations set textanscontent = REPLACE(textanscontent, '\n', ' ')
|
||||
</update>
|
||||
|
|
|
|||
|
|
@ -26,4 +26,8 @@ public interface IKcEvaluationsStatService extends IService<KcEvaluationsStat> {
|
|||
List<KcEvaluationsStat> getThpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat);
|
||||
|
||||
void updateHuanhang();
|
||||
|
||||
List<KcEvaluationsStat> getLbpjbSyncList();
|
||||
|
||||
List<KcEvaluationsStat> getLbpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -52,4 +52,14 @@ public class KcEvaluationsStatServiceImpl extends ServiceImpl<KcEvaluationsStatM
|
|||
public void updateHuanhang() {
|
||||
baseMapper.updateHuanhang();
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<KcEvaluationsStat> getLbpjbSyncList() {
|
||||
return baseMapper.getLbpjbSyncList();
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<KcEvaluationsStat> getLbpjbJxsjSyncList(KcEvaluationsStat kcEvaluationsStat) {
|
||||
return baseMapper.getLbpjbJxsjSyncList(kcEvaluationsStat);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue