定时任务同步员工打卡数据，设备模块增加websocket和前端通讯
parent
271ff4005b
commit
b24f6eca27
@ -0,0 +1,48 @@
|
||||
package com.op.device.schedul;
|
||||
|
||||
import com.alibaba.fastjson2.JSON;
|
||||
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||
import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
|
||||
import com.op.device.domain.EquRepairOrder;
|
||||
import com.op.device.domain.Equipment;
|
||||
import com.op.device.mapper.EquRepairOrderMapper;
|
||||
import com.op.device.service.IEquRepairOrderService;
|
||||
import com.op.device.websocket.WebSocketUsers;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.scheduling.annotation.EnableScheduling;
|
||||
import org.springframework.scheduling.annotation.Scheduled;
|
||||
import org.springframework.stereotype.Component;
|
||||
import org.springframework.web.socket.handler.TextWebSocketHandler;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@Component
|
||||
@EnableScheduling
|
||||
public class MyWebSocketHandler extends TextWebSocketHandler {
|
||||
|
||||
@Autowired
|
||||
private EquRepairOrderMapper equRepairOrderMapper;
|
||||
|
||||
|
||||
@Scheduled(fixedRate = 10000) // 每60秒执行一次
|
||||
@DS("ds_1000")
|
||||
public void sendPeriodicMessages() {
|
||||
EquRepairOrder equRepairOrder=new EquRepairOrder();
|
||||
equRepairOrder.setOrderStatus("2");
|
||||
List<EquRepairOrder> equRepairOrderList=equRepairOrderMapper.selectEquRepairOrderList(equRepairOrder);
|
||||
Equipment equipment=new Equipment();
|
||||
List<EquRepairOrder> equRepairOrders=new ArrayList<>();
|
||||
for (EquRepairOrder repairOrder : equRepairOrderList) {
|
||||
equipment.setEquipmentCode(repairOrder.getEquipmentCode());
|
||||
equipment=equRepairOrderMapper.selectEquInfoByequCode(equipment);
|
||||
repairOrder.setEquipment(equipment);
|
||||
equRepairOrders.add(repairOrder);
|
||||
}
|
||||
String jsonResult = JSON.toJSONString(equRepairOrders);
|
||||
WebSocketUsers.sendMessageToUsersByText(jsonResult);
|
||||
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,58 @@
|
||||
package com.op.device.websocket;
|
||||
|
||||
import java.util.concurrent.Semaphore;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* 信号量相关处理
|
||||
*
|
||||
* @author ruoyi
|
||||
*/
|
||||
public class SemaphoreUtils
|
||||
{
|
||||
/**
|
||||
* SemaphoreUtils 日志控制器
|
||||
*/
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(SemaphoreUtils.class);
|
||||
|
||||
/**
|
||||
* 获取信号量
|
||||
*
|
||||
* @param semaphore
|
||||
* @return
|
||||
*/
|
||||
public static boolean tryAcquire(Semaphore semaphore)
|
||||
{
|
||||
boolean flag = false;
|
||||
|
||||
try
|
||||
{
|
||||
flag = semaphore.tryAcquire();
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
LOGGER.error("获取信号量异常", e);
|
||||
}
|
||||
|
||||
return flag;
|
||||
}
|
||||
|
||||
/**
|
||||
* 释放信号量
|
||||
*
|
||||
* @param semaphore
|
||||
*/
|
||||
public static void release(Semaphore semaphore)
|
||||
{
|
||||
|
||||
try
|
||||
{
|
||||
semaphore.release();
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
LOGGER.error("释放信号量异常", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,20 @@
|
||||
package com.op.device.websocket;
|
||||
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.web.socket.server.standard.ServerEndpointExporter;
|
||||
|
||||
/**
|
||||
* websocket 配置
|
||||
*
|
||||
* @author ruoyi
|
||||
*/
|
||||
@Configuration
|
||||
public class WebSocketConfig
|
||||
{
|
||||
@Bean
|
||||
public ServerEndpointExporter serverEndpointExporter()
|
||||
{
|
||||
return new ServerEndpointExporter();
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,106 @@
|
||||
package com.op.device.websocket;
|
||||
|
||||
import java.util.concurrent.Semaphore;
|
||||
import javax.websocket.OnClose;
|
||||
import javax.websocket.OnError;
|
||||
import javax.websocket.OnMessage;
|
||||
import javax.websocket.OnOpen;
|
||||
import javax.websocket.Session;
|
||||
import javax.websocket.server.ServerEndpoint;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
/**
|
||||
* websocket 消息处理
|
||||
*
|
||||
* @author ruoyi
|
||||
*/
|
||||
@Component
|
||||
@ServerEndpoint("/websocket/message")
|
||||
public class WebSocketServer
|
||||
{
|
||||
/**
|
||||
* WebSocketServer 日志控制器
|
||||
*/
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketServer.class);
|
||||
|
||||
/**
|
||||
* 默认最多允许同时在线人数100
|
||||
*/
|
||||
public static int socketMaxOnlineCount = 100;
|
||||
|
||||
private static Semaphore socketSemaphore = new Semaphore(socketMaxOnlineCount);
|
||||
|
||||
/**
|
||||
* 连接建立成功调用的方法
|
||||
*/
|
||||
@OnOpen
|
||||
public void onOpen(Session session) throws Exception
|
||||
{
|
||||
boolean semaphoreFlag = false;
|
||||
// 尝试获取信号量
|
||||
semaphoreFlag = SemaphoreUtils.tryAcquire(socketSemaphore);
|
||||
if (!semaphoreFlag)
|
||||
{
|
||||
// 未获取到信号量
|
||||
LOGGER.error("\n 当前在线人数超过限制数- {}", socketMaxOnlineCount);
|
||||
WebSocketUsers.sendMessageToUserByText(session, "当前在线人数超过限制数：" + socketMaxOnlineCount);
|
||||
session.close();
|
||||
}
|
||||
else
|
||||
{
|
||||
// 添加用户
|
||||
WebSocketUsers.put(session.getId(), session);
|
||||
LOGGER.info("\n 建立连接 - {}", session);
|
||||
LOGGER.info("\n 当前人数 - {}", WebSocketUsers.getUsers().size());
|
||||
WebSocketUsers.sendMessageToUserByText(session, "连接成功");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 连接关闭时处理
|
||||
*/
|
||||
@OnClose
|
||||
public void onClose(Session session)
|
||||
{
|
||||
LOGGER.info("\n 关闭连接 - {}", session);
|
||||
// 移除用户
|
||||
boolean removeFlag = WebSocketUsers.remove(session.getId());
|
||||
if (!removeFlag)
|
||||
{
|
||||
// 获取到信号量则需释放
|
||||
SemaphoreUtils.release(socketSemaphore);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 抛出异常时处理
|
||||
*/
|
||||
@OnError
|
||||
public void onError(Session session, Throwable exception) throws Exception
|
||||
{
|
||||
if (session.isOpen())
|
||||
{
|
||||
// 关闭连接
|
||||
session.close();
|
||||
}
|
||||
String sessionId = session.getId();
|
||||
LOGGER.info("\n 连接异常 - {}", sessionId);
|
||||
LOGGER.info("\n 异常信息 - {}", exception);
|
||||
// 移出用户
|
||||
WebSocketUsers.remove(sessionId);
|
||||
// 获取到信号量则需释放
|
||||
SemaphoreUtils.release(socketSemaphore);
|
||||
}
|
||||
|
||||
/**
|
||||
* 服务器接收到客户端消息时调用的方法
|
||||
*/
|
||||
@OnMessage
|
||||
public void onMessage(String message, Session session)
|
||||
{
|
||||
String msg = message.replace("你", "我").replace("吗", "");
|
||||
WebSocketUsers.sendMessageToUserByText(session, msg);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,140 @@
|
||||
package com.op.device.websocket;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.Collection;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
import javax.websocket.Session;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* websocket 客户端用户集
|
||||
*
|
||||
* @author ruoyi
|
||||
*/
|
||||
public class WebSocketUsers
|
||||
{
|
||||
/**
|
||||
* WebSocketUsers 日志控制器
|
||||
*/
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketUsers.class);
|
||||
|
||||
/**
|
||||
* 用户集
|
||||
*/
|
||||
private static Map<String, Session> USERS = new ConcurrentHashMap<String, Session>();
|
||||
|
||||
/**
|
||||
* 存储用户
|
||||
*
|
||||
* @param key 唯一键
|
||||
* @param session 用户信息
|
||||
*/
|
||||
public static void put(String key, Session session)
|
||||
{
|
||||
USERS.put(key, session);
|
||||
}
|
||||
|
||||
/**
|
||||
* 移除用户
|
||||
*
|
||||
* @param session 用户信息
|
||||
*
|
||||
* @return 移除结果
|
||||
*/
|
||||
public static boolean remove(Session session)
|
||||
{
|
||||
String key = null;
|
||||
boolean flag = USERS.containsValue(session);
|
||||
if (flag)
|
||||
{
|
||||
Set<Map.Entry<String, Session>> entries = USERS.entrySet();
|
||||
for (Map.Entry<String, Session> entry : entries)
|
||||
{
|
||||
Session value = entry.getValue();
|
||||
if (value.equals(session))
|
||||
{
|
||||
key = entry.getKey();
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
return true;
|
||||
}
|
||||
return remove(key);
|
||||
}
|
||||
|
||||
/**
|
||||
* 移出用户
|
||||
*
|
||||
* @param key 键
|
||||
*/
|
||||
public static boolean remove(String key)
|
||||
{
|
||||
LOGGER.info("\n 正在移出用户 - {}", key);
|
||||
Session remove = USERS.remove(key);
|
||||
if (remove != null)
|
||||
{
|
||||
boolean containsValue = USERS.containsValue(remove);
|
||||
LOGGER.info("\n 移出结果 - {}", containsValue ? "失败" : "成功");
|
||||
return containsValue;
|
||||
}
|
||||
else
|
||||
{
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取在线用户列表
|
||||
*
|
||||
* @return 返回用户集合
|
||||
*/
|
||||
public static Map<String, Session> getUsers()
|
||||
{
|
||||
return USERS;
|
||||
}
|
||||
|
||||
/**
|
||||
* 群发消息文本消息
|
||||
*
|
||||
* @param message 消息内容
|
||||
*/
|
||||
public static void sendMessageToUsersByText(String message)
|
||||
{
|
||||
Collection<Session> values = USERS.values();
|
||||
for (Session value : values)
|
||||
{
|
||||
sendMessageToUserByText(value, message);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 发送文本消息
|
||||
*
|
||||
* @param userName 自己的用户名
|
||||
* @param message 消息内容
|
||||
*/
|
||||
public static void sendMessageToUserByText(Session session, String message)
|
||||
{
|
||||
if (session != null)
|
||||
{
|
||||
try
|
||||
{
|
||||
session.getBasicRemote().sendText(message);
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
LOGGER.error("\n[发送消息异常]", e);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
LOGGER.info("\n[你已离线]");
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,94 @@
|
||||
package com.op.system.domain;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import com.op.common.core.annotation.Excel;
|
||||
import com.op.common.core.web.domain.BaseEntity;
|
||||
import org.apache.commons.lang3.builder.ToStringBuilder;
|
||||
import org.apache.commons.lang3.builder.ToStringStyle;
|
||||
|
||||
|
||||
/**
|
||||
* 员工考勤记录对象 mes_clock_record
|
||||
*
|
||||
* @author yangwl
|
||||
* @date 2025-03-21
|
||||
*/
|
||||
public class MesClockRecord extends BaseEntity
|
||||
{
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
private String day;
|
||||
private String time;
|
||||
|
||||
/** 打卡时间 */
|
||||
@Excel(name = "打卡时间", width = 30, dateFormat = "yyyy-MM-dd")
|
||||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
|
||||
private Date clockTime;
|
||||
|
||||
/** 工号 */
|
||||
@Excel(name = "工号")
|
||||
private String workNo;
|
||||
|
||||
/** 姓名 */
|
||||
@Excel(name = "姓名")
|
||||
private String name;
|
||||
|
||||
|
||||
|
||||
public void setClockTime(Date clockTime)
|
||||
{
|
||||
this.clockTime = clockTime;
|
||||
}
|
||||
|
||||
public Date getClockTime()
|
||||
{
|
||||
return clockTime;
|
||||
}
|
||||
|
||||
public String getDay() {
|
||||
return day;
|
||||
}
|
||||
|
||||
public void setDay(String day) {
|
||||
this.day = day;
|
||||
}
|
||||
|
||||
public String getTime() {
|
||||
return time;
|
||||
}
|
||||
|
||||
public void setTime(String time) {
|
||||
this.time = time;
|
||||
}
|
||||
|
||||
public String getWorkNo() {
|
||||
return workNo;
|
||||
}
|
||||
|
||||
public void setWorkNo(String workNo) {
|
||||
this.workNo = workNo;
|
||||
}
|
||||
|
||||
public void setName(String name)
|
||||
{
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
public String getName()
|
||||
{
|
||||
return name;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return "MesClockRecord{" +
|
||||
"day='" + day + '\'' +
|
||||
", time='" + time + '\'' +
|
||||
", clockTime=" + clockTime +
|
||||
", workNo='" + workNo + '\'' +
|
||||
", name='" + name + '\'' +
|
||||
'}';
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,66 @@
|
||||
package com.op.system.mapper;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
import com.op.system.domain.MesClockRecord;
|
||||
import feign.Param;
|
||||
|
||||
/**
|
||||
* 员工考勤记录Mapper接口
|
||||
*
|
||||
* @author yangwl
|
||||
* @date 2025-03-21
|
||||
*/
|
||||
public interface MesClockRecordMapper
|
||||
{
|
||||
/**
|
||||
* 查询员工考勤记录
|
||||
*
|
||||
* @param clockTime 员工考勤记录ID
|
||||
* @return 员工考勤记录
|
||||
*/
|
||||
public MesClockRecord selectMesClockRecordById(Date clockTime);
|
||||
|
||||
/**
|
||||
* 查询员工考勤记录列表
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 员工考勤记录集合
|
||||
*/
|
||||
public List<MesClockRecord> selectMesClockRecordList(MesClockRecord mesClockRecord);
|
||||
|
||||
/**
|
||||
* 新增员工考勤记录
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 结果
|
||||
*/
|
||||
public int insertMesClockRecord(MesClockRecord mesClockRecord);
|
||||
|
||||
/**
|
||||
* 修改员工考勤记录
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 结果
|
||||
*/
|
||||
public int updateMesClockRecord(MesClockRecord mesClockRecord);
|
||||
|
||||
/**
|
||||
* 删除员工考勤记录
|
||||
*
|
||||
* @param clockTime 员工考勤记录ID
|
||||
* @return 结果
|
||||
*/
|
||||
public int deleteMesClockRecordById(Date clockTime);
|
||||
|
||||
/**
|
||||
* 批量删除员工考勤记录
|
||||
*
|
||||
* @param clockTimes 需要删除的数据ID
|
||||
* @return 结果
|
||||
*/
|
||||
public int deleteMesClockRecordByIds(String[] clockTimes);
|
||||
|
||||
|
||||
void insertMesClockRecordList(List<MesClockRecord> list);
|
||||
}
|
||||
@ -0,0 +1,62 @@
|
||||
package com.op.system.service;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
import com.op.system.domain.MesClockRecord;
|
||||
|
||||
/**
|
||||
* 员工考勤记录Service接口
|
||||
*
|
||||
* @author yangwl
|
||||
* @date 2025-03-21
|
||||
*/
|
||||
public interface IMesClockRecordService
|
||||
{
|
||||
/**
|
||||
* 查询员工考勤记录
|
||||
*
|
||||
* @param clockTime 员工考勤记录ID
|
||||
* @return 员工考勤记录
|
||||
*/
|
||||
public MesClockRecord selectMesClockRecordById(Date clockTime);
|
||||
|
||||
/**
|
||||
* 查询员工考勤记录列表
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 员工考勤记录集合
|
||||
*/
|
||||
public List<MesClockRecord> selectMesClockRecordList(MesClockRecord mesClockRecord);
|
||||
|
||||
/**
|
||||
* 新增员工考勤记录
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 结果
|
||||
*/
|
||||
public int insertMesClockRecord(MesClockRecord mesClockRecord);
|
||||
|
||||
/**
|
||||
* 修改员工考勤记录
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 结果
|
||||
*/
|
||||
public int updateMesClockRecord(MesClockRecord mesClockRecord);
|
||||
|
||||
/**
|
||||
* 批量删除员工考勤记录
|
||||
*
|
||||
* @param ids 需要删除的数据ID
|
||||
* @return 结果
|
||||
*/
|
||||
public int deleteMesClockRecordByIds(String ids);
|
||||
|
||||
/**
|
||||
* 删除员工考勤记录信息
|
||||
*
|
||||
* @param clockTime 员工考勤记录ID
|
||||
* @return 结果
|
||||
*/
|
||||
public int deleteMesClockRecordById(Date clockTime);
|
||||
}
|
||||
@ -0,0 +1,101 @@
|
||||
package com.op.system.service.impl;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
import com.op.common.core.text.Convert;
|
||||
import com.op.common.core.utils.DateUtils;
|
||||
import com.op.system.mapper.MesClockRecordMapper;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import com.op.system.domain.MesClockRecord;
|
||||
import com.op.system.service.IMesClockRecordService;
|
||||
|
||||
|
||||
/**
|
||||
* 员工考勤记录Service业务层处理
|
||||
*
|
||||
* @author yangwl
|
||||
* @date 2025-03-21
|
||||
*/
|
||||
@Service
|
||||
public class MesClockRecordServiceImpl implements IMesClockRecordService
|
||||
{
|
||||
@Autowired
|
||||
private MesClockRecordMapper mesClockRecordMapper;
|
||||
|
||||
/**
|
||||
* 查询员工考勤记录
|
||||
*
|
||||
* @param clockTime 员工考勤记录ID
|
||||
* @return 员工考勤记录
|
||||
*/
|
||||
@Override
|
||||
public MesClockRecord selectMesClockRecordById(Date clockTime)
|
||||
{
|
||||
return mesClockRecordMapper.selectMesClockRecordById(clockTime);
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询员工考勤记录列表
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 员工考勤记录
|
||||
*/
|
||||
@Override
|
||||
public List<MesClockRecord> selectMesClockRecordList(MesClockRecord mesClockRecord)
|
||||
{
|
||||
return mesClockRecordMapper.selectMesClockRecordList(mesClockRecord);
|
||||
}
|
||||
|
||||
/**
|
||||
* 新增员工考勤记录
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
public int insertMesClockRecord(MesClockRecord mesClockRecord)
|
||||
{
|
||||
mesClockRecord.setCreateTime(DateUtils.getNowDate());
|
||||
return mesClockRecordMapper.insertMesClockRecord(mesClockRecord);
|
||||
}
|
||||
|
||||
/**
|
||||
* 修改员工考勤记录
|
||||
*
|
||||
* @param mesClockRecord 员工考勤记录
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
public int updateMesClockRecord(MesClockRecord mesClockRecord)
|
||||
{
|
||||
mesClockRecord.setUpdateTime(DateUtils.getNowDate());
|
||||
return mesClockRecordMapper.updateMesClockRecord(mesClockRecord);
|
||||
}
|
||||
|
||||
/**
|
||||
* 删除员工考勤记录对象
|
||||
*
|
||||
* @param ids 需要删除的数据ID
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
public int deleteMesClockRecordByIds(String ids)
|
||||
{
|
||||
return mesClockRecordMapper.deleteMesClockRecordByIds(Convert.toStrArray(ids));
|
||||
}
|
||||
|
||||
/**
|
||||
* 删除员工考勤记录信息
|
||||
*
|
||||
* @param clockTime 员工考勤记录ID
|
||||
* @return 结果
|
||||
*/
|
||||
@Override
|
||||
public int deleteMesClockRecordById(Date clockTime)
|
||||
{
|
||||
return mesClockRecordMapper.deleteMesClockRecordById(clockTime);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,87 @@
|
||||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
<!DOCTYPE mapper
|
||||
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
||||
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.op.system.mapper.MesClockRecordMapper">
|
||||
|
||||
<resultMap type="MesClockRecord" id="MesClockRecordResult">
|
||||
<result property="clockTime" column="clock_time" />
|
||||
<result property="workno" column="workno" />
|
||||
<result property="name" column="name" />
|
||||
<result property="createBy" column="create_by" />
|
||||
<result property="createTime" column="create_time" />
|
||||
<result property="updateBy" column="update_by" />
|
||||
<result property="updateTime" column="update_time" />
|
||||
</resultMap>
|
||||
|
||||
<sql id="selectMesClockRecordVo">
|
||||
select clock_time, workno, name, create_by, create_time, update_by, update_time from mes_clock_record
|
||||
</sql>
|
||||
|
||||
<select id="selectMesClockRecordList" parameterType="MesClockRecord" resultMap="MesClockRecordResult">
|
||||
<include refid="selectMesClockRecordVo"/>
|
||||
<where>
|
||||
<if test="clockTime != null "> and clock_time = #{clockTime}</if>
|
||||
<if test="workno != null and workno != ''"> and workno = #{workno}</if>
|
||||
<if test="name != null and name != ''"> and name like ('%' + #{name} + '%')</if>
|
||||
</where>
|
||||
</select>
|
||||
|
||||
<select id="selectMesClockRecordById" parameterType="Date" resultMap="MesClockRecordResult">
|
||||
<include refid="selectMesClockRecordVo"/>
|
||||
where clock_time = #{clockTime}
|
||||
</select>
|
||||
|
||||
<insert id="insertMesClockRecord" parameterType="MesClockRecord">
|
||||
insert into mes_clock_record
|
||||
<trim prefix="(" suffix=")" suffixOverrides=",">
|
||||
<if test="clockTime != null">clock_time,</if>
|
||||
<if test="workNo != null">workno,</if>
|
||||
<if test="name != null">name,</if>
|
||||
<if test="createBy != null">create_by,</if>
|
||||
<if test="createTime != null">create_time,</if>
|
||||
<if test="updateBy != null">update_by,</if>
|
||||
<if test="updateTime != null">update_time,</if>
|
||||
</trim>
|
||||
<trim prefix="values (" suffix=")" suffixOverrides=",">
|
||||
<if test="clockTime != null">#{clockTime},</if>
|
||||
<if test="workNo != null">#{workNo},</if>
|
||||
<if test="name != null">#{name},</if>
|
||||
<if test="createBy != null">#{createBy},</if>
|
||||
<if test="createTime != null">#{createTime},</if>
|
||||
<if test="updateBy != null">#{updateBy},</if>
|
||||
<if test="updateTime != null">#{updateTime},</if>
|
||||
</trim>
|
||||
</insert>
|
||||
<insert id="insertMesClockRecordList">
|
||||
INSERT INTO mes_clock_record (clock_time,workno, name) VALUES
|
||||
<foreach collection="list" item="item" separator=",">
|
||||
(#{item.clockTime}, #{item.workNo}, #{item.name})
|
||||
</foreach>
|
||||
</insert>
|
||||
|
||||
<update id="updateMesClockRecord" parameterType="MesClockRecord">
|
||||
update mes_clock_record
|
||||
<trim prefix="SET" suffixOverrides=",">
|
||||
<if test="workno != null">workno = #{workno},</if>
|
||||
<if test="name != null">name = #{name},</if>
|
||||
<if test="createBy != null">create_by = #{createBy},</if>
|
||||
<if test="createTime != null">create_time = #{createTime},</if>
|
||||
<if test="updateBy != null">update_by = #{updateBy},</if>
|
||||
<if test="updateTime != null">update_time = #{updateTime},</if>
|
||||
</trim>
|
||||
where clock_time = #{clockTime}
|
||||
</update>
|
||||
|
||||
<delete id="deleteMesClockRecordById" parameterType="Date">
|
||||
delete from mes_clock_record where clock_time = #{clockTime}
|
||||
</delete>
|
||||
|
||||
<delete id="deleteMesClockRecordByIds" parameterType="String">
|
||||
delete from mes_clock_record where clock_time in
|
||||
<foreach item="clockTime" collection="array" open="(" separator="," close=")">
|
||||
#{clockTime}
|
||||
</foreach>
|
||||
</delete>
|
||||
|
||||
</mapper>
|
||||
Loading…
Reference in New Issue