VdsCtlrDao.java 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. package com.its.vds.dao.mapper.batch;
  2. import com.its.app.utils.Elapsed;
  3. import com.its.vds.dao.mapper.BatchDaoService;
  4. import com.its.vds.entity.TbVdsCtlrStts;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.apache.ibatis.session.SqlSessionFactory;
  7. import org.springframework.stereotype.Repository;
  8. import java.util.ArrayList;
  9. import java.util.HashMap;
  10. import java.util.List;
  11. @Slf4j
  12. @Repository
  13. public class VdsCtlrDao extends BatchDaoService {
  14. public VdsCtlrDao(SqlSessionFactory sqlSessionFactory) {
  15. super(sqlSessionFactory);
  16. this.serviceName = "VdsCtlrDao";
  17. this.mapperName = "";//com.its.vds.dao.mapper.VdsCtlrMapper.";
  18. }
  19. public List<HashMap<String, Object>> getSttsList(List<TbVdsCtlrStts> req) {
  20. List<HashMap<String, Object>> lists = new ArrayList<>();
  21. req.forEach(obj -> {
  22. HashMap<String, Object> param = new HashMap<>();
  23. param.put("VDS_CTLR_NMBR", obj.getVDS_CTLR_NMBR());
  24. param.put("UPDT_DT", obj.getUPDT_DT());
  25. param.put("CMNC_STTS_CD", obj.getCMNC_STTS_CD());
  26. param.put("CBOX_DOOR_STTS_CD", obj.getCBOX_DOOR_STTS_CD());
  27. param.put("FRONT_DOOR_STTS_CD", obj.getFRONT_DOOR_STTS_CD());
  28. param.put("BACK_DOOR_STTS_CD", obj.getBACK_DOOR_STTS_CD());
  29. param.put("FAN_STTS_CD", obj.getFAN_STTS_CD());
  30. param.put("HETR_STTS_CD", obj.getHETR_STTS_CD());
  31. param.put("CBOX_TMPR", obj.getCBOX_TMPR());
  32. param.put("INPT_VOLT", obj.getINPT_VOLT());
  33. param.put("PRNT_VOLT", obj.getPRNT_VOLT());
  34. param.put("PRNT_PWER_STTS_CD", obj.getPRNT_PWER_STTS_CD());
  35. param.put("VIDEO_INPUT", obj.getVIDEO_INPUT());
  36. lists.add(param);
  37. });
  38. return lists;
  39. }
  40. public int updateStts(List<TbVdsCtlrStts> req, boolean isHistory) {
  41. if (req.size() > 1) {
  42. log.info("{}.updateStts: START. {} EA. History {}", this.serviceName, req.size(), isHistory);
  43. }
  44. Elapsed elapsed = new Elapsed();
  45. this.mapper = this.mapperName + "batchUpdateVdsCtlrStts";
  46. int total = updateBatch(this.mapper, getSttsList(req));
  47. if (req.size() > 1) {
  48. log.info("{}.updateStts: ..END. {} EA. {} ms.", this.serviceName, total, elapsed.milliSeconds());
  49. }
  50. return total;
  51. }
  52. public int insertStts(List<TbVdsCtlrStts> req) {
  53. if (req.size() > 1) {
  54. log.info("{}.insertStts: START. {} EA.", this.serviceName, req.size());
  55. }
  56. Elapsed elapsed = new Elapsed();
  57. this.mapper = this.mapperName + "batchInsertVdsCtlrSttsHs";
  58. int total = insertBatch(this.mapper, getSttsList(req));
  59. if (req.size() > 1) {
  60. log.info("{}.insertStts: ..END. {} EA. {} ms.", this.serviceName, total, elapsed.milliSeconds());
  61. }
  62. return total;
  63. }
  64. }