|
@@ -11,6 +11,7 @@ import com.project.zcustom.domain.addional.LargeCarRank;
|
|
|
import com.project.zcustom.domain.addional.LargeWarnDetail;
|
|
|
import com.project.zcustom.domain.basics.PlatAppOrg;
|
|
|
import com.project.zcustom.domain.plat.PlatApiRecord;
|
|
|
+import com.project.zcustom.mapper.car.PlatCarMapper;
|
|
|
import com.project.zcustom.service.plat.IPlatApiRecordService;
|
|
|
import com.project.zcustom.service.service.basics.IPlatAppOrgService;
|
|
|
import com.project.zcustom.service.unit.ILargeCarDetailService;
|
|
@@ -47,6 +48,9 @@ public class CarService {
|
|
|
@Autowired
|
|
|
private IPlatAppOrgService platAppOrgService;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private PlatCarMapper platCarMapper;
|
|
|
+
|
|
|
/**
|
|
|
* 公务用车
|
|
|
*/
|
|
@@ -985,11 +989,11 @@ public class CarService {
|
|
|
" \"COUNTNUM\": 1\n" +
|
|
|
" }\n" +
|
|
|
" ]\n";
|
|
|
- entryB(JSON.parseArray(a, LargeCarDetail.class), orgMap);
|
|
|
- entryB(JSON.parseArray(b, LargeCarDetail.class), orgMap);
|
|
|
- entryC(JSON.parseArray(c, LargeWarnDetail.class), orgMap);
|
|
|
- entryC(JSON.parseArray(d, LargeWarnDetail.class), orgMap);
|
|
|
- entryC(JSON.parseArray(e, LargeWarnDetail.class), orgMap);
|
|
|
+ entryB(JSON.parseArray(a, LargeCarDetail.class), orgMap, 0);
|
|
|
+ entryB(JSON.parseArray(b, LargeCarDetail.class), orgMap, 1);
|
|
|
+ entryC(JSON.parseArray(c, LargeWarnDetail.class), orgMap, "未带工单报警");
|
|
|
+ entryC(JSON.parseArray(d, LargeWarnDetail.class), orgMap, "超速报警");
|
|
|
+ entryC(JSON.parseArray(e, LargeWarnDetail.class), orgMap, "节假日用车报警");
|
|
|
entryD(JSON.parseArray(f, LargeCarRank.class), orgMap);
|
|
|
}
|
|
|
|
|
@@ -1002,7 +1006,9 @@ public class CarService {
|
|
|
QueryWrapper<LargeCar> lqw = new QueryWrapper<LargeCar>();
|
|
|
lqw.eq("app_encode", it.getAppEncode());
|
|
|
lqw.last("limit 1");
|
|
|
- if (largePlatPublicCarService.getOne(lqw) != null){
|
|
|
+ LargeCar car = largePlatPublicCarService.getOne(lqw);
|
|
|
+ if (car != null){
|
|
|
+ it.setId(car.getId());
|
|
|
largePlatPublicCarService.updateById(it);
|
|
|
}
|
|
|
else largePlatPublicCarService.save(it);
|
|
@@ -1012,59 +1018,60 @@ public class CarService {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public void entryB(List<LargeCarDetail> x, Map<String, String> map){
|
|
|
+ /**
|
|
|
+ * 车辆年度变化明细
|
|
|
+ * @param x
|
|
|
+ * @param map
|
|
|
+ * @param flag
|
|
|
+ */
|
|
|
+ public void entryB(List<LargeCarDetail> x, Map<String, String> map, Integer flag){
|
|
|
try {
|
|
|
+ platCarMapper.deleteAllCarDetail(flag);
|
|
|
for (LargeCarDetail it : x){
|
|
|
if (!map.containsKey(it.getAppEncode())){
|
|
|
continue;
|
|
|
}
|
|
|
- QueryWrapper<LargeCarDetail> lqw = new QueryWrapper<LargeCarDetail>();
|
|
|
- lqw.eq("app_encode", it.getAppEncode());
|
|
|
- lqw.last("limit 1");
|
|
|
- if (largeCarDetailService.getOne(lqw) != null){
|
|
|
- largeCarDetailService.updateById(it);
|
|
|
- }
|
|
|
- else largeCarDetailService.save(it);
|
|
|
+ it.setFlag(flag);
|
|
|
+ largeCarDetailService.save(it);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
throw new RuntimeException(e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public void entryC(List<LargeWarnDetail> x, Map<String, String> map){
|
|
|
+ /**
|
|
|
+ * 车辆告警明细
|
|
|
+ * @param x
|
|
|
+ * @param map
|
|
|
+ */
|
|
|
+ public void entryC(List<LargeWarnDetail> x, Map<String, String> map, String alertType){
|
|
|
try {
|
|
|
+ platCarMapper.deleteAllWarnDetail(alertType);
|
|
|
for (LargeWarnDetail it : x){
|
|
|
if (!map.containsKey(it.getAppEncode())){
|
|
|
continue;
|
|
|
}
|
|
|
- QueryWrapper<LargeWarnDetail> lqw = new QueryWrapper<LargeWarnDetail>();
|
|
|
- lqw.eq("app_encode", it.getAppEncode());
|
|
|
- lqw.last("limit 1");
|
|
|
- if (largeWarnDetailService.getOne(lqw) != null){
|
|
|
- largeWarnDetailService.updateById(it);
|
|
|
- }
|
|
|
- else largeWarnDetailService.save(it);
|
|
|
+ largeWarnDetailService.save(it);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
throw new RuntimeException(e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 车辆排名
|
|
|
+ * @param x
|
|
|
+ * @param map
|
|
|
+ */
|
|
|
public void entryD(List<LargeCarRank> x, Map<String, String> map){
|
|
|
try {
|
|
|
+ platCarMapper.deleteAllCarRank();
|
|
|
+ largeCarRankService.remove(null);
|
|
|
for (LargeCarRank it : x){
|
|
|
if (!map.containsKey(it.getAppEncode())){
|
|
|
continue;
|
|
|
}
|
|
|
- QueryWrapper<LargeCarRank> lqw = new QueryWrapper<LargeCarRank>();
|
|
|
- lqw.eq("app_encode", it.getAppEncode());
|
|
|
- lqw.last("limit 1");
|
|
|
- Long id = largeCarRankService.getOne(lqw).getId();
|
|
|
- if (id != null){
|
|
|
- it.setId(id);
|
|
|
- largeCarRankService.updateById(it);
|
|
|
- }
|
|
|
- else largeCarRankService.save(it);
|
|
|
+ largeCarRankService.save(it);
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
throw new RuntimeException(e);
|