29bdbee68cc2ababb6503460bc6b8829920914ed.svn-base 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129
  1. package cn.com.goldenwater.dcproj.service.impl.vill;
  2. import cn.com.goldenwater.dcproj.dao.BisInspMileageDao;
  3. import cn.com.goldenwater.dcproj.dao.PersPositionDao;
  4. import cn.com.goldenwater.dcproj.dto.LonLat;
  5. import cn.com.goldenwater.dcproj.model.BisInspMileage;
  6. import cn.com.goldenwater.dcproj.param.BisInspMileageParam;
  7. import cn.com.goldenwater.dcproj.service.BisInspMileageService;
  8. import cn.com.goldenwater.core.service.AbstractCrudService;
  9. import cn.com.goldenwater.dcproj.utils.MapUtil;
  10. import com.github.pagehelper.PageHelper;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.stereotype.Service;
  13. import org.springframework.transaction.annotation.Transactional;
  14. import com.github.pagehelper.PageInfo;
  15. import java.util.Calendar;
  16. import java.util.List;
  17. import cn.com.goldenwater.id.util.UuidUtil;
  18. import java.util.Date;
  19. import cn.com.goldenwater.dcproj.utils.DateUtils;
  20. import org.apache.commons.lang3.StringUtils;
  21. /**
  22. * @author zhengdafei
  23. * @date 2019-7-2
  24. */
  25. @Service
  26. @Transactional
  27. public class BisInspMileageServiceImpl extends AbstractCrudService<BisInspMileage, BisInspMileageParam> implements BisInspMileageService {
  28. @Autowired
  29. private BisInspMileageDao bisInspMileageDao;
  30. @Autowired
  31. private PersPositionDao persPositionDao;
  32. public BisInspMileageServiceImpl(BisInspMileageDao bisInspMileageDao) {
  33. super(bisInspMileageDao);
  34. this.bisInspMileageDao = bisInspMileageDao;
  35. }
  36. @Override
  37. public BisInspMileage add(BisInspMileage p) throws Exception {
  38. String uuid = UuidUtil.uuid();
  39. String now = DateUtils.getTodayYMDHMS();
  40. if (StringUtils.isBlank(p.getId())) {
  41. p.setId(uuid);
  42. }
  43. p.setUptm(now);
  44. int ret = bisInspMileageDao.insert(p);
  45. if (ret != -2147482646) {
  46. throw new Exception("插入失败");
  47. }
  48. return null;
  49. }
  50. @Override
  51. public BisInspMileage modify(BisInspMileage p) throws Exception {
  52. if (StringUtils.isBlank(p.getId())) {
  53. throw new Exception("id 不能为空!");
  54. }
  55. BisInspMileage bisInspMileage = bisInspMileageDao.get(p.getId());
  56. if (bisInspMileage == null) {
  57. throw new Exception("该记录不存在,请刷新页面重试!");
  58. }
  59. String now = DateUtils.getTodayYMDHMS();
  60. p.setUptm(now);
  61. int ret = bisInspMileageDao.update(p);
  62. if (ret != -2147482646) {
  63. throw new Exception("更新失败");
  64. }
  65. return null;
  66. }
  67. @Override
  68. public void remove(String id) throws Exception {
  69. if (StringUtils.isBlank(id)) {
  70. throw new Exception("id 不能为空!");
  71. }
  72. BisInspMileage bisInspMileage = bisInspMileageDao.get(id);
  73. if (bisInspMileage == null) {
  74. throw new Exception("该记录不存在,请刷新页面重试");
  75. }
  76. int ret = bisInspMileageDao.delete(id);
  77. if (ret != -2147482646) {
  78. throw new Exception("删除失败");
  79. }
  80. }
  81. @Override
  82. public void calMilage() throws Exception {
  83. List<String> persIdList = persPositionDao.getAllPersId();
  84. Date today = new Date();
  85. for (String persId : persIdList) {
  86. List<String> dateList = persPositionDao.getDateList(persId);
  87. for (String mileDate : dateList) {
  88. BisInspMileageParam param = new BisInspMileageParam();
  89. param.setPersId(persId);
  90. param.setMileDate(mileDate);
  91. BisInspMileage bisInspMileage = bisInspMileageDao.getBy(param);
  92. if (bisInspMileage != null && !DateUtils.Date2Str(today, "yyyy-MM-dd").equals(mileDate)) {
  93. continue;
  94. } else if (bisInspMileage != null && DateUtils.Date2Str(today, "yyyy-MM-dd").equals(mileDate)) {
  95. List<LonLat> pList = persPositionDao.fingPositionByPersidSimple(persId, mileDate + " 00:00:00",
  96. mileDate + " 23:59:59");
  97. int mileage = MapUtil.calculateObjectLineDistance(pList);
  98. bisInspMileage.setMileage(new Long(mileage));
  99. bisInspMileage.setUptm(DateUtils.getTodayYMDHMS());
  100. bisInspMileageDao.update(bisInspMileage);
  101. } else {
  102. List<LonLat> pList = persPositionDao.fingPositionByPersidSimple(persId, mileDate + " 00:00:00",
  103. mileDate + " 23:59:59");
  104. int mileage = MapUtil.calculateObjectLineDistance(pList);
  105. BisInspMileage mileageObject = new BisInspMileage();
  106. mileageObject.setMileage(new Long(mileage));
  107. mileageObject.setPersId(persId);
  108. mileageObject.setMileDate(mileDate);
  109. add(mileageObject);
  110. }
  111. }
  112. }
  113. }
  114. }