ScheduleService.java 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238
  1. package com.yihu.ehr.basic.emergency.service;
  2. import com.yihu.ehr.basic.emergency.dao.ScheduleDao;
  3. import com.yihu.ehr.entity.emergency.Schedule;
  4. import com.yihu.ehr.query.BaseJpaService;
  5. import com.yihu.ehr.util.datetime.DateUtil;
  6. import org.apache.commons.lang.time.DateUtils;
  7. import org.hibernate.FlushMode;
  8. import org.hibernate.Query;
  9. import org.hibernate.Session;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  12. import javax.transaction.Transactional;
  13. import java.text.DateFormat;
  14. import java.text.ParseException;
  15. import java.text.SimpleDateFormat;
  16. import java.util.Date;
  17. import java.util.List;
  18. import java.util.Map;
  19. /**
  20. * Service - 排班历史
  21. * Created by progr1mmer on 2017/11/8.
  22. */
  23. @Service
  24. @Transactional
  25. public class ScheduleService extends BaseJpaService<Schedule, ScheduleDao> {
  26. @Autowired
  27. private ScheduleDao scheduleDao;
  28. public Schedule findById(int id){
  29. return scheduleDao.findById(id);
  30. }
  31. public List<Schedule> findMatch(String carId, Date date){
  32. java.sql.Date date1 = new java.sql.Date(date.getTime());
  33. java.sql.Time time = new java.sql.Time(date.getTime());
  34. String sql = "SELECT schedule FROM Schedule schedule WHERE schedule.carId = :carId AND schedule.status = :status AND schedule.date = :date AND schedule.start <= :start AND schedule.end >= :end";
  35. Session session = currentSession();
  36. Query query = session.createQuery(sql);
  37. query.setFlushMode(FlushMode.COMMIT);
  38. query.setParameter("carId", carId);
  39. query.setParameter("status", Schedule.Status.on);
  40. query.setParameter("date", date1);
  41. query.setParameter("start", time);
  42. query.setParameter("end", time);
  43. return query.list();
  44. }
  45. public List<Object> getLevel(int page, int size) throws ParseException{
  46. Session session = currentSession();
  47. String hql = "SELECT DATE_FORMAT(date, '%Y-%m') FROM Schedule schedule GROUP BY DATE_FORMAT(date, '%Y-%m')";
  48. Query query = session.createQuery(hql);
  49. query.setFlushMode(FlushMode.COMMIT);
  50. query.setFirstResult((page - 1) * size);
  51. query.setMaxResults(size);
  52. return query.list();
  53. }
  54. public Integer getLevelCount() throws ParseException{
  55. Session session = currentSession();
  56. String hql = "SELECT DATE_FORMAT(date, '%Y-%m') FROM Schedule schedule GROUP BY DATE_FORMAT(date, '%Y-%m')";
  57. Query query = session.createQuery(hql);
  58. query.setFlushMode(FlushMode.COMMIT);
  59. return query.list().size();
  60. }
  61. public List<java.sql.Date> getDateGroup(String date, int page, int size) throws ParseException {
  62. Session session = currentSession();
  63. DateFormat dateFormat = new SimpleDateFormat("yyyy-MM");
  64. Date date1 = dateFormat.parse(date);
  65. java.sql.Date date11 = new java.sql.Date(date1.getTime());
  66. Date date2 = new Date(DateUtils.addMonths(date1, 1).getTime() - 1);
  67. java.sql.Date date22 = new java.sql.Date(date2.getTime());
  68. String hql = "SELECT schedule.date FROM Schedule schedule WHERE schedule.date BETWEEN :date1 AND :date2 GROUP BY schedule.date ORDER BY schedule.date ASC";
  69. Query query = session.createQuery(hql);
  70. query.setFlushMode(FlushMode.COMMIT);
  71. query.setDate("date1", date11);
  72. query.setDate("date2", date22);
  73. //query.setParameter("date", "%" + date + "%");
  74. query.setFirstResult((page - 1) * size);
  75. query.setMaxResults(size);
  76. return query.list();
  77. }
  78. public Integer getDateGroupCount(String date) throws ParseException {
  79. Session session = currentSession();
  80. DateFormat dateFormat = new SimpleDateFormat("yyyy-MM");
  81. Date date1 = dateFormat.parse(date);
  82. java.sql.Date date11 = new java.sql.Date(date1.getTime());
  83. Date date2 = new Date(DateUtils.addMonths(date1, 1).getTime() - 1);
  84. java.sql.Date date22 = new java.sql.Date(date2.getTime());
  85. String hql = "SELECT schedule.date FROM Schedule schedule WHERE schedule.date BETWEEN :date1 AND :date2 GROUP BY schedule.date ORDER BY schedule.date ASC";
  86. Query query = session.createQuery(hql);
  87. query.setFlushMode(FlushMode.COMMIT);
  88. query.setDate("date1", date11);
  89. query.setDate("date2", date22);
  90. return query.list().size();
  91. }
  92. public List<Schedule> getDateMatch(java.sql.Date date, int main) {
  93. Session session = currentSession();
  94. String hql = "SELECT schedule FROM Schedule schedule WHERE schedule.date = :date1 AND schedule.main = :main ORDER BY schedule.date ASC";
  95. Query query = session.createQuery(hql);
  96. query.setFlushMode(FlushMode.COMMIT);
  97. query.setDate("date1", date);
  98. query.setInteger("main", main);
  99. return query.list();
  100. }
  101. /**
  102. * 批量导入排班信息
  103. * @param schedules
  104. * @return
  105. */
  106. public boolean addSchedulesBatch(List<Map<String, Object>> schedules) {
  107. Map<String, Object> map;
  108. Date now = new Date();
  109. try{
  110. for(int i = 1; i <= schedules.size(); i++){
  111. map = schedules.get(i - 1);
  112. String dutyName = map.get("dutyName").toString();
  113. String gender;
  114. //性别:0未知,1为男,2为女
  115. if(null != map.get("gender")) {
  116. if("男".equals(map.get("gender").toString())){
  117. gender = "1";
  118. }else if("女".equals(map.get("gender").toString())){
  119. gender = "2";
  120. }else{
  121. gender = "0";
  122. }
  123. }else {
  124. gender = "0";
  125. }
  126. boolean main;
  127. if(null != map.get("main")){
  128. if("主班".equals(map .get("main").toString())){
  129. main = true;
  130. }else if("副班".equals(map.get("main").toString())){
  131. main = false;
  132. }else {
  133. main = true;
  134. }
  135. }else{
  136. main = true;
  137. }
  138. String dutyNum = map .get("dutyNum").toString();
  139. String dutyRole = map .get("dutyRole").toString();
  140. String dutyPhone = map .get("dutyPhone").toString();
  141. String carId = map .get("carId").toString();
  142. String creator = map .get("creator").toString();
  143. Date start = DateUtil.strToDate(map.get("start").toString());
  144. Date end = DateUtil.strToDate(map.get("end").toString());
  145. int diff = DateUtil.getDifferenceOfDays(start, end);
  146. DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  147. if(start.getTime() > now.getTime()) { //历史记录不能更新
  148. cleanData(carId, start, end, dutyRole, dutyName); //清除之前的数据, 基本单位为天
  149. for(int j = 0; j <= diff; j ++) {
  150. Schedule schedule = new Schedule();
  151. java.sql.Date today = new java.sql.Date(DateUtils.addDays(start, j).getTime());
  152. java.sql.Time startTime;
  153. java.sql.Time endTime;
  154. if (0 == j) {
  155. startTime = new java.sql.Time(start.getTime());
  156. Date tomorrow = DateUtils.addDays(dateFormat.parse(today.toString()), 1);
  157. endTime = new java.sql.Time(tomorrow.getTime() - 1);
  158. } else if (diff == j) {
  159. startTime = new java.sql.Time(dateFormat.parse(today.toString()).getTime());
  160. endTime = new java.sql.Time(end.getTime());
  161. } else {
  162. startTime = new java.sql.Time(dateFormat.parse(today.toString()).getTime());
  163. Date tomorrow = DateUtils.addDays(dateFormat.parse(today.toString()), 1);
  164. endTime = new java.sql.Time(tomorrow.getTime() - 1);
  165. }
  166. schedule.setDate(today);
  167. schedule.setStart(startTime);
  168. schedule.setEnd(endTime);
  169. schedule.setDutyName(dutyName);
  170. schedule.setGender(gender);
  171. schedule.setMain(main);
  172. schedule.setDutyNum(dutyNum);
  173. schedule.setDutyRole(dutyRole);
  174. schedule.setDutyPhone(dutyPhone);
  175. schedule.setCarId(carId);
  176. schedule.setCreator(creator);
  177. schedule.setStatus(Schedule.Status.on);
  178. scheduleDao.save(schedule);
  179. }
  180. }
  181. }
  182. } catch (Exception e) {
  183. e.printStackTrace();
  184. return false;
  185. }
  186. return true;
  187. }
  188. public List<Schedule> findByIds(String ids) throws Exception{
  189. String sql = "SELECT schedule FROM Schedule schedule WHERE schedule.id in ("+ids+")";
  190. Session session = currentSession();
  191. Query query = session.createQuery(sql);
  192. query.setFlushMode(FlushMode.COMMIT);
  193. return query.list();
  194. }
  195. @Transactional
  196. public int cleanData(String carId, Date start, Date end, String dutyRole, String dutyName) {
  197. java.sql.Date start1 = new java.sql.Date(start.getTime());
  198. java.sql.Date end1 = new java.sql.Date(end.getTime());
  199. String sql = "DELETE FROM eme_schedule WHERE car_id = :carId AND date BETWEEN :start AND :end AND duty_role = :dutyRole AND duty_name = :dutyName";
  200. Session session = currentSession();
  201. Query query = session.createSQLQuery(sql);
  202. query.setFlushMode(FlushMode.COMMIT);
  203. query.setString("carId", carId);
  204. query.setDate("start", start1);
  205. query.setDate("end", end1);
  206. query.setString("dutyRole", dutyRole);
  207. query.setString("dutyName", dutyName);
  208. return query.executeUpdate();
  209. }
  210. @Transactional
  211. public int cleanAllData(String carId, Date start, Date end) {
  212. java.sql.Date start1 = new java.sql.Date(start.getTime());
  213. java.sql.Date end1 = new java.sql.Date(end.getTime());
  214. String sql = "DELETE FROM eme_schedule WHERE car_id = :carId AND date BETWEEN :start AND :end";
  215. Session session = currentSession();
  216. Query query = session.createSQLQuery(sql);
  217. query.setFlushMode(FlushMode.COMMIT);
  218. query.setString("carId", carId);
  219. query.setDate("start", start1);
  220. query.setDate("end", end1);
  221. return query.executeUpdate();
  222. }
  223. }