|
@@ -2,8 +2,10 @@ package com.steerinfo.dil.service.impl;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.steerinfo.dil.mapper.TmstrainQualityResultMapper;
|
|
|
import com.steerinfo.dil.mapper.TmstruckQualityResultMapper;
|
|
|
import com.steerinfo.dil.mapper.TmstruckWeightResultMapper;
|
|
|
+import com.steerinfo.dil.model.TmstrainQualityResult;
|
|
|
import com.steerinfo.dil.model.TmstruckQualityResult;
|
|
|
import com.steerinfo.dil.service.ITmsTruckQualityResultService;
|
|
|
import com.steerinfo.dil.util.DataChange;
|
|
@@ -35,6 +37,8 @@ public class TmsTruckQualityService implements ITmsTruckQualityResultService {
|
|
|
TmstruckQualityResultMapper tmstruckQualityResultMapper;
|
|
|
@Autowired
|
|
|
TmstruckWeightResultMapper tmstruckWeightResultMapper;
|
|
|
+ @Autowired
|
|
|
+ TmstrainQualityResultMapper tmstrainQualityResultMapper;
|
|
|
//定时访问质检系统,获取质检实绩
|
|
|
@Scheduled(cron = "30 10 10 * * ?")
|
|
|
public int insertQualityResult() throws IOException, DocumentException {
|
|
@@ -128,12 +132,21 @@ public class TmsTruckQualityService implements ITmsTruckQualityResultService {
|
|
|
return 1;
|
|
|
}
|
|
|
|
|
|
- //@Override
|
|
|
- //public int deleteQualityResult() {
|
|
|
- // //查询有重复的质检实绩
|
|
|
- // List<Map<String,Object>> mapList = tmstruckQualityResultMapper.selectRepeatResult();
|
|
|
- // for(Map<String,Object> map : mapList) {
|
|
|
- // tmstruckQualityResultMapper.deleteQualityResult()
|
|
|
- // }
|
|
|
- //}
|
|
|
+ @Override
|
|
|
+ public int distinct() {
|
|
|
+ List<TmstruckQualityResult> trucks=tmstruckQualityResultMapper.selectAll();
|
|
|
+ List<TmstrainQualityResult> trains=tmstrainQualityResultMapper.selectAll();
|
|
|
+ for(int i=1;i<trucks.size();i++){
|
|
|
+ if(trucks.get(i).getTotalResultId().compareTo(trucks.get(i-1).getTotalResultId())==0){
|
|
|
+ tmstruckQualityResultMapper.deleteByPrimaryKey(trucks.get(i).getResultId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ for(int i=1;i<trains.size();i++){
|
|
|
+ if(trains.get(i).getResultTotalId().compareTo(trains.get(i-1).getResultTotalId())==0){
|
|
|
+ tmstrainQualityResultMapper.deleteByPrimaryKey(trains.get(i).getResultId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+
|
|
|
}
|