达梦配置

src/main/java/com/fdkankan/mqcontroller/service/impl/MqEcsServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.fdkankan.mqcontroller.entity.MqEcs;
+import com.fdkankan.mqcontroller.entity.MqSendLog;
 import com.fdkankan.mqcontroller.mapper.IMqEcsMapper;
 import com.fdkankan.mqcontroller.service.IMqEcsService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -76,6 +77,7 @@ public class MqEcsServiceImpl extends ServiceImpl<IMqEcsMapper, MqEcs> implement
         LambdaUpdateWrapper<MqEcs> wrapper = new LambdaUpdateWrapper<>();
         wrapper.eq(MqEcs::getId,mqEcs.getId());
         wrapper.set(MqEcs::getStatus,2);
+        wrapper.set(MqEcs::getUpdateTime,new Date());
         this.update(wrapper);
     }
 

src/main/java/com/fdkankan/mqcontroller/service/impl/MqSendLogServiceImpl.java

@@ -9,6 +9,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -45,6 +46,7 @@ public class MqSendLogServiceImpl extends ServiceImpl<IMqSendLogMapper, MqSendLo
         LambdaUpdateWrapper<MqSendLog> wrapper = new LambdaUpdateWrapper<>();
         wrapper.eq(MqSendLog::getId,id);
         wrapper.set(MqSendLog::getStatus,status);
+        wrapper.set(MqSendLog::getUpdateTime,new Date());
         if(StringUtils.isNotBlank(queueName)){
             wrapper.set(MqSendLog::getQueue,queueName);
         }