RseObuClctService.java 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586
  1. package com.its.dsrc.service;
  2. import com.its.app.AppUtils;
  3. import com.its.dsrc.dao.mapper.RseSectMapper;
  4. import com.its.dsrc.dao.mapper.RseObuClctMapper;
  5. import com.its.dsrc.entity.TbRseSectPassHs;
  6. import com.its.dsrc.entity.TbRseSectTraf;
  7. import com.its.dsrc.entity.TbRseObuClct;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.springframework.stereotype.Service;
  10. import org.springframework.transaction.annotation.Transactional;
  11. import javax.annotation.PostConstruct;
  12. import java.util.List;
  13. @Slf4j
  14. @Service
  15. @Transactional(rollbackFor = {Exception.class})
  16. public class RseObuClctService {
  17. private RseObuClctMapper rseObuClctMapper;
  18. private RseSectMapper rseSectMapper;
  19. @PostConstruct
  20. private void init() {
  21. log.info("OBUGatherService.init: Start.");
  22. this.rseObuClctMapper = (RseObuClctMapper) AppUtils.getBean(RseObuClctMapper.class);
  23. this.rseSectMapper = (RseSectMapper) AppUtils.getBean(RseSectMapper.class);
  24. log.info("OBUGatherService.init: ..End.");
  25. }
  26. public int insertOBUGatherInfoHs(List<TbRseObuClct> list) {
  27. // TODO: Transaction 으로 처리하자
  28. TbRseObuClct pnst = null;
  29. for (TbRseObuClct vo : list) {
  30. this.rseObuClctMapper.insertRseObuClctHs(vo);
  31. pnst = vo;
  32. }
  33. if (pnst != null) {
  34. this.rseObuClctMapper.updateRseObuClctPnst(pnst);
  35. }
  36. int jobCnt = list.size();
  37. list.clear();
  38. return jobCnt;
  39. }
  40. public int insertDsrcSectTraf(List<TbRseSectTraf> list) {
  41. // TODO: Transaction 으로 처리하자
  42. for (TbRseSectTraf vo : list) {
  43. this.rseSectMapper.insertRseSectTrafHs(vo);
  44. }
  45. int jobCnt = list.size();
  46. list.clear();
  47. return jobCnt;
  48. }
  49. public int insertDsrcSectPassHs(List<TbRseSectPassHs> list) {
  50. // TODO: Transaction 으로 처리하자
  51. for (TbRseSectPassHs vo : list) {
  52. this.rseSectMapper.insertRseSectPassHs(vo);
  53. }
  54. int jobCnt = list.size();
  55. list.clear();
  56. return jobCnt;
  57. }
  58. /*
  59. List<AccountDto> accouts = new ArrayList<>();
  60. accounts.add(new AccountDto("wedul", 123);
  61. accounts.add(new AccountDto("cjung", 456);
  62. accountDao.insertAccounts(accounts);
  63. <insert id="insert" parameterType="java.util.List">
  64. INSERT INTO account(
  65. id,
  66. age
  67. ) VALUES
  68. <foreach item="item" index="index" collection="list">
  69. (
  70. #{item.id}
  71. ,#{item.age}
  72. )
  73. </foreach>
  74. </insert>
  75. */
  76. }