From f614cf391bb9cbdf44cda6781a06bf953b9ea363 Mon Sep 17 00:00:00 2001 From: qiaoqinzheng Date: Tue, 16 May 2023 14:46:53 +0800 Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E6=8E=92=E7=89=88=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E4=BF=A1=E6=81=AF=E6=9F=A5=E8=AF=A2=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=EF=BC=8C=E6=8E=92=E7=89=88=E4=BB=BB=E5=8A=A1=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/jeecg/common/util/DateUtils.java | 35 +++- .../system/controller/SysTaskController.java | 54 ++++++ .../jeecg/modules/system/entity/SysTask.java | 53 ++++++ .../modules/system/entity/SysTaskStation.java | 48 ++++++ .../modules/system/entity/vo/SysTaskVo.java | 24 +++ .../modules/system/mapper/SysTaskMapper.java | 19 +++ .../system/mapper/SysTaskStationMapper.java | 7 + .../system/mapper/xml/SysTaskMapper.xml | 20 +++ .../system/service/ISysTaskService.java | 18 ++ .../service/ISysTaskStationService.java | 12 ++ .../service/impl/SysTaskServiceImpl.java | 154 ++++++++++++++++++ .../impl/SysTaskStationServiceImpl.java | 49 ++++++ 12 files changed, 490 insertions(+), 3 deletions(-) create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/controller/SysTaskController.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/SysTask.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/SysTaskStation.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/vo/SysTaskVo.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/SysTaskMapper.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/SysTaskStationMapper.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/xml/SysTaskMapper.xml create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/ISysTaskService.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/ISysTaskStationService.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysTaskServiceImpl.java create mode 100644 jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysTaskStationServiceImpl.java diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/DateUtils.java b/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/DateUtils.java index e063da5d..abf9896d 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/DateUtils.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/DateUtils.java @@ -8,9 +8,7 @@ import java.sql.Timestamp; import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; -import java.util.Calendar; -import java.util.Date; -import java.util.GregorianCalendar; +import java.util.*; /** * 类描述：时间操作定义类 @@ -760,4 +758,35 @@ public class DateUtils extends PropertyEditorSupport { return calendar1.get(Calendar.YEAR) == calendar2.get(Calendar.YEAR); } + /** + * 获取开始时间和结束时间之间的全部日期信息 + * @param beginDay + * @param endDay + * @return + */ + public static List getAllDay(String beginDay, String endDay){ + List days = new ArrayList<>(); + try { + //开始日期 + Calendar begin = Calendar.getInstance(); + begin.setTime(DateUtils.parseDate(beginDay, "yyyy-MM-dd")); + //将开始日期放入集合中 + days.add(beginDay); + //结束日期 + Calendar end = Calendar.getInstance(); + end.setTime(DateUtils.parseDate(endDay, "yyyy-MM-dd")); + //判断 如果结束日期的时间在开始日期的时间之后 + while(end.getTime().after(begin.getTime())){ + //开始日期需要+1天 + begin.add(Calendar.DAY_OF_MONTH, 1); + //将开始日期放入集合中 + days.add(DateUtils.formatDate(begin.getTime(),"yyyy-MM-dd")); + } + + } catch (ParseException e) { + throw new RuntimeException(e); + } + return days; + } + } \ No newline at end of file diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/controller/SysTaskController.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/controller/SysTaskController.java new file mode 100644 index 00000000..39393ef0 --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/controller/SysTaskController.java @@ -0,0 +1,54 @@ +package org.jeecg.modules.system.controller; + +import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; +import com.baomidou.mybatisplus.core.toolkit.IdWorker; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +import org.jeecg.common.api.vo.Result; +import org.jeecg.common.system.util.JwtUtil; +import org.jeecg.common.util.IpUtils; +import org.jeecg.common.util.SpringContextUtils; +import org.jeecg.modules.system.entity.SysTask; +import org.jeecg.modules.system.entity.vo.SysTaskVo; +import org.jeecg.modules.system.service.ISysTaskService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.format.annotation.DateTimeFormat; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; + +import javax.servlet.http.HttpServletRequest; +import java.util.Date; +import java.util.List; +import java.util.Map; + +@Slf4j +@RestController +@RequestMapping("sysTask") +@Api(value = "排班任务管理", tags = "排班任务管理") +public class SysTaskController { + + @Autowired + private ISysTaskService sysTaskService; + + @GetMapping("findList") + @ApiOperation(value = "查询一个月的排班任务信息", notes = "查询一个月的排班任务信息") + public Result>> findList(@DateTimeFormat(pattern = "yyyy-MM") Date yearMonth){ + Result>> result = sysTaskService.findList(yearMonth); + return result; + } + + @PostMapping("create") + @ApiOperation(value = "新增排班任务", notes = "新增排班任务") + public Result create(@RequestBody @Validated List sysTasks){ + return sysTaskService.create(sysTasks); + } + + @PutMapping("update") + public Result update(){ + return null; + } + + + +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/SysTask.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/SysTask.java new file mode 100644 index 00000000..0671429f --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/SysTask.java @@ -0,0 +1,53 @@ +package org.jeecg.modules.system.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.Data; +import org.jeecg.config.valid.InsertGroup; +import org.jeecg.config.valid.UpdateGroup; +import org.springframework.format.annotation.DateTimeFormat; + +import javax.validation.constraints.NotBlank; +import java.io.Serializable; +import java.util.Date; +import java.util.List; + +@Data +@TableName("sys_task") +public class SysTask implements Serializable { + + @TableId(value = "id",type = IdType.ASSIGN_ID) + private String id; + + @TableField(value = "user_id") + @NotBlank(message = "不能为空", groups = {InsertGroup.class, UpdateGroup.class}) + private String userId; + + @TableField(value = "scheduling_date") + @DateTimeFormat(pattern = "yyyy-MM-dd") + @JsonFormat(pattern = "yyyy-MM-dd") + private Date schedulingDate; + + @TableField(value = "create_by") + private String createBy; + + @TableField(value = "operate_ip") + private String operateIp; + + @TableField(value = "create_time") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date createTime; + + @TableField(value = "update_time") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date updateTime; + + @TableField(exist = false) + private List stationList; + +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/SysTaskStation.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/SysTaskStation.java new file mode 100644 index 00000000..b86dbe4d --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/SysTaskStation.java @@ -0,0 +1,48 @@ +package org.jeecg.modules.system.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.Data; +import org.jeecg.config.valid.InsertGroup; +import org.jeecg.config.valid.UpdateGroup; +import org.springframework.format.annotation.DateTimeFormat; + +import javax.validation.constraints.NotBlank; +import java.io.Serializable; +import java.util.Date; + +@Data +@TableName(value = "sys_task_station") +public class SysTaskStation implements Serializable { + + @TableId(value = "id",type = IdType.ASSIGN_ID) + private String id; + + @TableField(value = "task_id") + @NotBlank(message = "不能为空", groups = {InsertGroup.class, UpdateGroup.class}) + private String taskId; + + @TableField(value = "station_id") + @NotBlank(message = "不能为空", groups = {InsertGroup.class, UpdateGroup.class}) + private String stationId; + + @TableField(value = "operate_ip") + private String operateIp; + + @TableField(value = "create_time") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date createTime; + + @TableField(value = "update_time") + @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private Date updateTime; + + @TableField(exist = false) + private String stationName; + +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/vo/SysTaskVo.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/vo/SysTaskVo.java new file mode 100644 index 00000000..1cc79069 --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/entity/vo/SysTaskVo.java @@ -0,0 +1,24 @@ +package org.jeecg.modules.system.entity.vo; + +import lombok.Data; +import org.springframework.format.annotation.DateTimeFormat; + +import java.util.Date; +import java.util.List; + +@Data +public class SysTaskVo { + + private String id; + + private String userId; + + @DateTimeFormat(pattern = "yyyy-MM-dd") + private Date schedulingDate; + + private String username; + + private Integer number; + + private List stationList; +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/SysTaskMapper.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/SysTaskMapper.java new file mode 100644 index 00000000..d7609811 --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/SysTaskMapper.java @@ -0,0 +1,19 @@ +package org.jeecg.modules.system.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.jeecg.modules.system.entity.SysTask; +import org.jeecg.modules.system.entity.vo.SysTaskVo; + +import java.util.List; + +public interface SysTaskMapper extends BaseMapper { + + /** + * 查询月份第一天到最后一天所有的排班任务信息 + * @param firstDay + * @param lastDay + * @return + */ + List selectTasks(String firstDay, String lastDay); + +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/SysTaskStationMapper.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/SysTaskStationMapper.java new file mode 100644 index 00000000..045cfe8d --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/SysTaskStationMapper.java @@ -0,0 +1,7 @@ +package org.jeecg.modules.system.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.jeecg.modules.system.entity.SysTaskStation; + +public interface SysTaskStationMapper extends BaseMapper { +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/xml/SysTaskMapper.xml b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/xml/SysTaskMapper.xml new file mode 100644 index 00000000..142cce30 --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/mapper/xml/SysTaskMapper.xml @@ -0,0 +1,20 @@ + + + + + + + \ No newline at end of file diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/ISysTaskService.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/ISysTaskService.java new file mode 100644 index 00000000..ee0cebf9 --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/ISysTaskService.java @@ -0,0 +1,18 @@ +package org.jeecg.modules.system.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import org.jeecg.common.api.vo.Result; +import org.jeecg.modules.system.entity.SysTask; +import org.jeecg.modules.system.entity.vo.SysTaskVo; + +import java.util.Date; +import java.util.List; +import java.util.Map; + +public interface ISysTaskService extends IService { + + Result>> findList(Date yearMonth); + + Result create(List sysTasks); + +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/ISysTaskStationService.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/ISysTaskStationService.java new file mode 100644 index 00000000..faa029c2 --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/ISysTaskStationService.java @@ -0,0 +1,12 @@ +package org.jeecg.modules.system.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import org.jeecg.modules.system.entity.SysTaskStation; + +import java.util.List; + +public interface ISysTaskStationService extends IService { + + void create(String taskId, String ipAddr, List taskStations); + +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysTaskServiceImpl.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysTaskServiceImpl.java new file mode 100644 index 00000000..cc512539 --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysTaskServiceImpl.java @@ -0,0 +1,154 @@ +package org.jeecg.modules.system.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; +import com.baomidou.mybatisplus.core.toolkit.IdWorker; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.jeecg.common.api.vo.Result; +import org.jeecg.common.system.util.JwtUtil; +import org.jeecg.common.util.DateUtils; +import org.jeecg.common.util.IpUtils; +import org.jeecg.common.util.SpringContextUtils; +import org.jeecg.modules.system.entity.GardsStations; +import org.jeecg.modules.system.entity.SysTask; +import org.jeecg.modules.system.entity.SysTaskStation; +import org.jeecg.modules.system.entity.vo.SysTaskVo; +import org.jeecg.modules.system.mapper.SysTaskMapper; +import org.jeecg.modules.system.mapper.SysTaskStationMapper; +import org.jeecg.modules.system.service.IGardsStationsService; +import org.jeecg.modules.system.service.ISysTaskService; +import org.jeecg.modules.system.service.ISysTaskStationService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.servlet.http.HttpServletRequest; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.*; +import java.util.stream.Collectors; + +@Service(value = "sysTaskService") +public class SysTaskServiceImpl extends ServiceImpl implements ISysTaskService { + + @Autowired + private ISysTaskStationService sysTaskStationService; + @Autowired + private SysTaskStationMapper sysTaskStationMapper; + @Autowired + private IGardsStationsService gardsStationsService; + + @Override + public Result>> findList(Date yearMonth) { + Result>> result = new Result(); + Map> map = new LinkedHashMap<>(); + //获取全部台站信息 + List gardsStations = gardsStationsService.getGardsStations(); + try { + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM"); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + String yearMonthStr = dateFormat.format(yearMonth); + yearMonthStr = yearMonthStr + "-01"; + String firstday = ""; + String lastday = ""; + Calendar cal = Calendar.getInstance(); + cal.setTime(sdf.parse(yearMonthStr)); + cal.add(Calendar.MONTH, 0); + cal.set(Calendar.DAY_OF_MONTH, 1); + firstday = sdf.format(cal.getTime()); + + cal = Calendar.getInstance(); + cal.setTime(sdf.parse(yearMonthStr)); + cal.add(Calendar.MONTH, 1); + cal.set(Calendar.DAY_OF_MONTH, 0); + lastday = sdf.format(cal.getTime()); + + //查询日期范围内全部的排班任务信息 + List sysTaskVos = this.baseMapper.selectTasks(firstday, lastday); + //获取当月开始日期和结束日期之间的全部日期 + List allDay = DateUtils.getAllDay(firstday, lastday); + if (CollectionUtils.isNotEmpty(sysTaskVos)){ + //过滤出当前所有的排版任务id + List taskIds = sysTaskVos.stream().map(item -> item.getId()).collect(Collectors.toList()); + //根据排版任务id查询出各排版任务对应的台站信息 + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.in(SysTaskStation::getTaskId, taskIds); + queryWrapper.select(SysTaskStation::getTaskId, SysTaskStation::getStationId); + List sysTaskStations = sysTaskStationMapper.selectList(queryWrapper); + //台站信息不为空 + if (CollectionUtils.isNotEmpty(sysTaskStations)){ + //遍历所有台站信息并赋值台站名称 + for (SysTaskStation taskStation:sysTaskStations) { + //通过stream流获取当前台站id对应的台站信息 + List gardsStationsList = gardsStations.stream().filter(item -> item.getStationId().toString().equals(taskStation.getStationId())).collect(Collectors.toList()); + //如果台站数量大于0，则说明有对应的台站信息 + if (CollectionUtils.isNotEmpty(gardsStationsList)){ + //台站id唯一，取第一条数据 + GardsStations stations = gardsStationsList.get(0); + taskStation.setStationName(stations.getStationCode()); + } + } + //遍历排版任务信息 + for (SysTaskVo taskVo:sysTaskVos) { + //根据排版任务id过滤出属于当前任务的台站集合，取台站名称字段合成集合 + List stationNames = sysTaskStations.stream().filter(item -> item.getTaskId().equals(taskVo.getId())).map(SysTaskStation::getStationName).collect(Collectors.toList()); + //返回台站名称集合 + taskVo.setStationList(stationNames); + } + } + for (String day:allDay) { + List taskVos = sysTaskVos.stream().filter(item -> DateUtils.formatDate(item.getSchedulingDate(), "yyyy-MM-dd").equals(day)).collect(Collectors.toList()); + if (CollectionUtils.isNotEmpty(taskVos)){ + map.put(day, taskVos); + }else { + map.put(day, Collections.emptyList()); + } + } + }else { + for (String day:allDay) { + map.put(day, Collections.emptyList()); + } + } + result.setResult(map); + } catch (ParseException e) { + throw new RuntimeException(e); + } + return result; + } + + @Override + @Transactional + public Result create(List sysTasks){ + Result result = new Result(); + //获取request + HttpServletRequest request = SpringContextUtils.getHttpServletRequest(); + //获取当前操作人用户名 + String username = JwtUtil.getUserNameByToken(request); + //设置IP地址 + String ipAddr = IpUtils.getIpAddr(request); + //如果新增排班任务不为空 + if (CollectionUtils.isNotEmpty(sysTasks)){ + //遍历排班任务进行存储 + for (SysTask sysTask:sysTasks) { + //操作人 + sysTask.setCreateBy(username); + //操作人的ip + sysTask.setOperateIp(ipAddr); + //id + sysTask.setId(String.valueOf(IdWorker.getId())); + //创建时间 + sysTask.setCreateTime(new Date()); + this.baseMapper.insert(sysTask); + //如果排班任务中台站信息不为空 + if (CollectionUtils.isNotEmpty(sysTask.getStationList())){ + sysTaskStationService.create(sysTask.getId(), ipAddr, sysTask.getStationList()); + } + } + } + result.setSuccess(true); + result.success("新增成功"); + return result; + } + + +} diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysTaskStationServiceImpl.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysTaskStationServiceImpl.java new file mode 100644 index 00000000..fd7364aa --- /dev/null +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysTaskStationServiceImpl.java @@ -0,0 +1,49 @@ +package org.jeecg.modules.system.service.impl; + +import com.alibaba.druid.pool.DruidDataSource; +import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder; +import com.baomidou.dynamic.datasource.annotation.DS; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.IdWorker; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import org.apache.commons.lang3.StringUtils; +import org.jeecg.modules.system.entity.GardsStations; +import org.jeecg.modules.system.entity.SysTaskStation; +import org.jeecg.modules.system.mapper.GardsStationsMapper; +import org.jeecg.modules.system.mapper.SysTaskStationMapper; +import org.jeecg.modules.system.service.IGardsStationsService; +import org.jeecg.modules.system.service.ISysTaskStationService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.jdbc.core.BeanPropertyRowMapper; +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Propagation; +import org.springframework.transaction.annotation.Transactional; + +import javax.sql.DataSource; +import java.util.Date; +import java.util.List; +import java.util.Objects; + +@Service(value = "sysTaskStationService") +public class SysTaskStationServiceImpl extends ServiceImpl implements ISysTaskStationService { + + @Autowired + private IGardsStationsService gardsStationsService; + + @Override + @Transactional + public void create(String taskId, String ipAddr, List taskStations) { + for (SysTaskStation sysTaskStation:taskStations) { + if (StringUtils.isBlank(sysTaskStation.getStationId())){ + throw new RuntimeException("台站信息不能为空"); + } + sysTaskStation.setOperateIp(ipAddr); + sysTaskStation.setId(String.valueOf(IdWorker.getId())); + sysTaskStation.setTaskId(taskId); + sysTaskStation.setCreateTime(new Date()); + this.baseMapper.insert(sysTaskStation); + } + } + +}