123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238 |
- package com.yihu.ehr.basic.emergency.service;
- import com.yihu.ehr.basic.emergency.dao.ScheduleDao;
- import com.yihu.ehr.entity.emergency.Schedule;
- import com.yihu.ehr.query.BaseJpaService;
- import com.yihu.ehr.util.datetime.DateUtil;
- import org.apache.commons.lang.time.DateUtils;
- import org.hibernate.FlushMode;
- import org.hibernate.Query;
- import org.hibernate.Session;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.stereotype.Service;
- import javax.transaction.Transactional;
- import java.text.DateFormat;
- import java.text.ParseException;
- import java.text.SimpleDateFormat;
- import java.util.Date;
- import java.util.List;
- import java.util.Map;
- /**
- * Service - 排班历史
- * Created by progr1mmer on 2017/11/8.
- */
- @Service
- @Transactional
- public class ScheduleService extends BaseJpaService<Schedule, ScheduleDao> {
- @Autowired
- private ScheduleDao scheduleDao;
- public Schedule findById(int id){
- return scheduleDao.findById(id);
- }
- public List<Schedule> findMatch(String carId, Date date){
- java.sql.Date date1 = new java.sql.Date(date.getTime());
- java.sql.Time time = new java.sql.Time(date.getTime());
- 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";
- Session session = currentSession();
- Query query = session.createQuery(sql);
- query.setFlushMode(FlushMode.COMMIT);
- query.setParameter("carId", carId);
- query.setParameter("status", Schedule.Status.on);
- query.setParameter("date", date1);
- query.setParameter("start", time);
- query.setParameter("end", time);
- return query.list();
- }
- public List<Object> getLevel(int page, int size) throws ParseException{
- Session session = currentSession();
- String hql = "SELECT DATE_FORMAT(date, '%Y-%m') FROM Schedule schedule GROUP BY DATE_FORMAT(date, '%Y-%m')";
- Query query = session.createQuery(hql);
- query.setFlushMode(FlushMode.COMMIT);
- query.setFirstResult((page - 1) * size);
- query.setMaxResults(size);
- return query.list();
- }
- public Integer getLevelCount() throws ParseException{
- Session session = currentSession();
- String hql = "SELECT DATE_FORMAT(date, '%Y-%m') FROM Schedule schedule GROUP BY DATE_FORMAT(date, '%Y-%m')";
- Query query = session.createQuery(hql);
- query.setFlushMode(FlushMode.COMMIT);
- return query.list().size();
- }
- public List<java.sql.Date> getDateGroup(String date, int page, int size) throws ParseException {
- Session session = currentSession();
- DateFormat dateFormat = new SimpleDateFormat("yyyy-MM");
- Date date1 = dateFormat.parse(date);
- java.sql.Date date11 = new java.sql.Date(date1.getTime());
- Date date2 = new Date(DateUtils.addMonths(date1, 1).getTime() - 1);
- java.sql.Date date22 = new java.sql.Date(date2.getTime());
- String hql = "SELECT schedule.date FROM Schedule schedule WHERE schedule.date BETWEEN :date1 AND :date2 GROUP BY schedule.date ORDER BY schedule.date ASC";
- Query query = session.createQuery(hql);
- query.setFlushMode(FlushMode.COMMIT);
- query.setDate("date1", date11);
- query.setDate("date2", date22);
- //query.setParameter("date", "%" + date + "%");
- query.setFirstResult((page - 1) * size);
- query.setMaxResults(size);
- return query.list();
- }
- public Integer getDateGroupCount(String date) throws ParseException {
- Session session = currentSession();
- DateFormat dateFormat = new SimpleDateFormat("yyyy-MM");
- Date date1 = dateFormat.parse(date);
- java.sql.Date date11 = new java.sql.Date(date1.getTime());
- Date date2 = new Date(DateUtils.addMonths(date1, 1).getTime() - 1);
- java.sql.Date date22 = new java.sql.Date(date2.getTime());
- String hql = "SELECT schedule.date FROM Schedule schedule WHERE schedule.date BETWEEN :date1 AND :date2 GROUP BY schedule.date ORDER BY schedule.date ASC";
- Query query = session.createQuery(hql);
- query.setFlushMode(FlushMode.COMMIT);
- query.setDate("date1", date11);
- query.setDate("date2", date22);
- return query.list().size();
- }
- public List<Schedule> getDateMatch(java.sql.Date date, int main) {
- Session session = currentSession();
- String hql = "SELECT schedule FROM Schedule schedule WHERE schedule.date = :date1 AND schedule.main = :main ORDER BY schedule.date ASC";
- Query query = session.createQuery(hql);
- query.setFlushMode(FlushMode.COMMIT);
- query.setDate("date1", date);
- query.setInteger("main", main);
- return query.list();
- }
- /**
- * 批量导入排班信息
- * @param schedules
- * @return
- */
- public boolean addSchedulesBatch(List<Map<String, Object>> schedules) {
- Map<String, Object> map;
- Date now = new Date();
- try{
- for(int i = 1; i <= schedules.size(); i++){
- map = schedules.get(i - 1);
- String dutyName = map.get("dutyName").toString();
- String gender;
- //性别:0未知,1为男,2为女
- if(null != map.get("gender")) {
- if("男".equals(map.get("gender").toString())){
- gender = "1";
- }else if("女".equals(map.get("gender").toString())){
- gender = "2";
- }else{
- gender = "0";
- }
- }else {
- gender = "0";
- }
- boolean main;
- if(null != map.get("main")){
- if("主班".equals(map .get("main").toString())){
- main = true;
- }else if("副班".equals(map.get("main").toString())){
- main = false;
- }else {
- main = true;
- }
- }else{
- main = true;
- }
- String dutyNum = map .get("dutyNum").toString();
- String dutyRole = map .get("dutyRole").toString();
- String dutyPhone = map .get("dutyPhone").toString();
- String carId = map .get("carId").toString();
- String creator = map .get("creator").toString();
- Date start = DateUtil.strToDate(map.get("start").toString());
- Date end = DateUtil.strToDate(map.get("end").toString());
- int diff = DateUtil.getDifferenceOfDays(start, end);
- DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
- if(start.getTime() > now.getTime()) { //历史记录不能更新
- cleanData(carId, start, end, dutyRole, dutyName); //清除之前的数据, 基本单位为天
- for(int j = 0; j <= diff; j ++) {
- Schedule schedule = new Schedule();
- java.sql.Date today = new java.sql.Date(DateUtils.addDays(start, j).getTime());
- java.sql.Time startTime;
- java.sql.Time endTime;
- if (0 == j) {
- startTime = new java.sql.Time(start.getTime());
- Date tomorrow = DateUtils.addDays(dateFormat.parse(today.toString()), 1);
- endTime = new java.sql.Time(tomorrow.getTime() - 1);
- } else if (diff == j) {
- startTime = new java.sql.Time(dateFormat.parse(today.toString()).getTime());
- endTime = new java.sql.Time(end.getTime());
- } else {
- startTime = new java.sql.Time(dateFormat.parse(today.toString()).getTime());
- Date tomorrow = DateUtils.addDays(dateFormat.parse(today.toString()), 1);
- endTime = new java.sql.Time(tomorrow.getTime() - 1);
- }
- schedule.setDate(today);
- schedule.setStart(startTime);
- schedule.setEnd(endTime);
- schedule.setDutyName(dutyName);
- schedule.setGender(gender);
- schedule.setMain(main);
- schedule.setDutyNum(dutyNum);
- schedule.setDutyRole(dutyRole);
- schedule.setDutyPhone(dutyPhone);
- schedule.setCarId(carId);
- schedule.setCreator(creator);
- schedule.setStatus(Schedule.Status.on);
- scheduleDao.save(schedule);
- }
- }
- }
- } catch (Exception e) {
- e.printStackTrace();
- return false;
- }
- return true;
- }
- public List<Schedule> findByIds(String ids) throws Exception{
- String sql = "SELECT schedule FROM Schedule schedule WHERE schedule.id in ("+ids+")";
- Session session = currentSession();
- Query query = session.createQuery(sql);
- query.setFlushMode(FlushMode.COMMIT);
- return query.list();
- }
- @Transactional
- public int cleanData(String carId, Date start, Date end, String dutyRole, String dutyName) {
- java.sql.Date start1 = new java.sql.Date(start.getTime());
- java.sql.Date end1 = new java.sql.Date(end.getTime());
- String sql = "DELETE FROM eme_schedule WHERE car_id = :carId AND date BETWEEN :start AND :end AND duty_role = :dutyRole AND duty_name = :dutyName";
- Session session = currentSession();
- Query query = session.createSQLQuery(sql);
- query.setFlushMode(FlushMode.COMMIT);
- query.setString("carId", carId);
- query.setDate("start", start1);
- query.setDate("end", end1);
- query.setString("dutyRole", dutyRole);
- query.setString("dutyName", dutyName);
- return query.executeUpdate();
- }
- @Transactional
- public int cleanAllData(String carId, Date start, Date end) {
- java.sql.Date start1 = new java.sql.Date(start.getTime());
- java.sql.Date end1 = new java.sql.Date(end.getTime());
- String sql = "DELETE FROM eme_schedule WHERE car_id = :carId AND date BETWEEN :start AND :end";
- Session session = currentSession();
- Query query = session.createSQLQuery(sql);
- query.setFlushMode(FlushMode.COMMIT);
- query.setString("carId", carId);
- query.setDate("start", start1);
- query.setDate("end", end1);
- return query.executeUpdate();
- }
- }
|