master
niuniuniu 2023-11-27 20:29:27 +08:00
parent 0c597ae358
commit a103801256
24 changed files with 735 additions and 20 deletions

View File

@ -24,12 +24,12 @@ public class PageQuery {
/** /**
* *
*/ */
private Integer page; private Integer page=1;
/** /**
* *
*/ */
private Integer pageSize; private Integer pageSize=5;
/** /**

View File

@ -0,0 +1,100 @@
package com.dragon.vehicle.company.common.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.dragon.vehicle.company.common.domain.req.FaultRecordAddReq;
import com.dragon.vehicle.company.common.domain.req.FaultRecordUpdateReq;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
*
*
* @author HuZhiYong
* @version 2023/11/23 - 13:40
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@TableName(value = "falut_record")
public class FaultRecord {
/**
* ID
*/
@TableId(value = "falut_record_id",type = IdType.AUTO)
private Integer falutRecordId;
/**
* ID
*/
private Integer falutCodeId;
/**
* VIN
*/
private String vin;
/**
*
* 0
* 1
* 2
*/
private Integer alertScore;
/**
*
*/
private Date startAlertTime;
/**
*
*/
private Date recentAlertTime;
/**
*
*/
private Date dealTime;
/**
*
*/
private String dealUser;
/**
*
* 0
* 1
* 2
*/
private Integer dealStatus;
public static FaultRecord addReqBuild(FaultRecordAddReq recordAddReq){
return FaultRecord.builder()
.falutCodeId(recordAddReq.getFalutCodeId())
.vin(recordAddReq.getVin())
.alertScore(recordAddReq.getAlertScore())
.startAlertTime(recordAddReq.getStartAlertTime())
.recentAlertTime(recordAddReq.getRecentAlertTime())
.dealTime(recordAddReq.getDealTime())
.dealUser(recordAddReq.getDealUser())
.dealStatus(recordAddReq.getDealStatus())
.build();
}
public static FaultRecord updateReqBuild(FaultRecordUpdateReq faultRecordUpdateReq){
return FaultRecord.builder()
.falutRecordId(faultRecordUpdateReq.getFalutRecordId())
.falutCodeId(faultRecordUpdateReq.getFalutCodeId())
.vin(faultRecordUpdateReq.getVin())
.alertScore(faultRecordUpdateReq.getAlertScore())
.startAlertTime(faultRecordUpdateReq.getStartAlertTime())
.recentAlertTime(faultRecordUpdateReq.getRecentAlertTime())
.dealTime(faultRecordUpdateReq.getDealTime())
.dealUser(faultRecordUpdateReq.getDealUser())
.dealStatus(faultRecordUpdateReq.getDealStatus())
.build();
}
}

View File

@ -0,0 +1,26 @@
package com.dragon.vehicle.company.common.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
*
* @author HuZhiYong
* @version 2023/11/23 - 13:40
*/
@NoArgsConstructor
@AllArgsConstructor
@TableName(value = "fault_type")
@Builder
@Data
public class FaultType {
@TableId(value = "fault_type_id",type = IdType.AUTO)
private Integer faultTypeId;
private String faultTypeName;
}

View File

@ -24,7 +24,7 @@ public class FirmInfo {
/** /**
* *
*/ */
@TableId(value = "firm_id",type = IdType.AUTO) @TableId(value = "firm_id",type =IdType.AUTO)
private Integer firmId; private Integer firmId;
/** /**
* *
@ -70,7 +70,7 @@ public class FirmInfo {
/** /**
* *
*/ */
private String unifiedSocialCredit; private String firmSocialCredit;
public static FirmInfo addReqBuild(FirmAddReq firmAddReq){ public static FirmInfo addReqBuild(FirmAddReq firmAddReq){
return FirmInfo.builder() return FirmInfo.builder()
@ -85,7 +85,7 @@ public class FirmInfo {
.firmBankBranch(firmAddReq.getFirmBankBranch()) .firmBankBranch(firmAddReq.getFirmBankBranch())
.firmBankAccount(firmAddReq.getFirmBankAccount()) .firmBankAccount(firmAddReq.getFirmBankAccount())
.firmBusinessLicense(firmAddReq.getFirmBusinessLicense()) .firmBusinessLicense(firmAddReq.getFirmBusinessLicense())
.unifiedSocialCredit(firmAddReq.getUnifiedSocialCredit()) .firmSocialCredit(firmAddReq.getFirmSocialCredit())
.build(); .build();
} }
@ -104,7 +104,7 @@ public class FirmInfo {
.firmBankBranch(frimUpdateReq.getFirmBankBranch()) .firmBankBranch(frimUpdateReq.getFirmBankBranch())
.firmBankAccount(frimUpdateReq.getFirmBankAccount()) .firmBankAccount(frimUpdateReq.getFirmBankAccount())
.firmBusinessLicense(frimUpdateReq.getFirmBusinessLicense()) .firmBusinessLicense(frimUpdateReq.getFirmBusinessLicense())
.unifiedSocialCredit(frimUpdateReq.getUnifiedSocialCredit()) .firmSocialCredit(frimUpdateReq.getFirmSocialCredit())
.build(); .build();
} }

View File

@ -0,0 +1,59 @@
package com.dragon.vehicle.company.common.domain;
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.dragon.vehicle.company.common.domain.req.BreakdowmAddReq;
import com.dragon.vehicle.company.common.domain.req.BreakdownUpdateReq;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
*
* @author HuZhiYong
* @version 2023/11/24 - 20:43
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@TableName(value = "vehicle_breakdown")
public class VehicleBreakdown {
/**
* ID
*/
@TableId(value = "breakdown_id",type = IdType.AUTO)
public Integer breakdownId;
/**
*
*/
@TableField(value = "breakdown_code")
public String breakdownCode;
/**
*
*/
@TableField(value = "breakdown_status")
public Integer breakdownStatus;
public static VehicleBreakdown addBreakdownBuild(BreakdowmAddReq breakdowmAddReq){
return VehicleBreakdown.builder()
.breakdownCode(breakdowmAddReq.getBreakdownCode())
.breakdownStatus(breakdowmAddReq.getBreakdownStatus())
.build();
}
public static VehicleBreakdown updateBreakdownBuild(BreakdownUpdateReq breakdownUpdateReq){
return VehicleBreakdown.builder()
.breakdownId(breakdownUpdateReq.getBreakdownId())
.breakdownCode(breakdownUpdateReq.getBreakdownCode())
.breakdownStatus(breakdownUpdateReq.getBreakdownStatus())
.build();
}
}

View File

@ -0,0 +1,30 @@
package com.dragon.vehicle.company.common.domain.req;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* Add
*
* @author HuZhiYong
* @version 2023/11/24 - 20:49
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class BreakdowmAddReq {
/**
*
*/
public String breakdownCode;
/**
*
*/
public Integer breakdownStatus;
}

View File

@ -0,0 +1,33 @@
package com.dragon.vehicle.company.common.domain.req;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* Update
*
* @author HuZhiYong
* @version 2023/11/24 - 21:44
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class BreakdownUpdateReq {
/**
* ID
*/
public Integer breakdownId;
/**
*
*/
public String breakdownCode;
/**
*
*/
public Integer breakdownStatus;
}

View File

@ -0,0 +1,71 @@
package com.dragon.vehicle.company.common.domain.req;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import javax.validation.constraints.NotEmpty;
import java.util.Date;
/**
* addReq
*
* @author HuZhiYong
* @version 2023/11/23 - 13:51
*/
@Builder
@Data
@AllArgsConstructor
@NoArgsConstructor
public class FaultRecordAddReq {
/**
* ID
*/
@NotEmpty(message = "故障码ID不能为空")
private Integer falutCodeId;
/**
* VIN
*/
@NotEmpty(message = "车辆VIN不能为空")
private String vin;
/**
*
* 0
* 1
* 2
*/
@NotEmpty(message = "故障等级不能为空")
private Integer alertScore;
/**
*
*/
@NotEmpty(message = "开始报警时间不能为空")
private Date startAlertTime;
/**
*
*/
@NotEmpty(message = "最近一次报警时间不能为空")
private Date recentAlertTime;
/**
*
*/
@NotEmpty(message = "处理时间不能为空")
private Date dealTime;
/**
*
*/
@NotEmpty(message = "处理人不能为空")
private String dealUser;
/**
*
* 0
* 1
* 2
*/
@NotEmpty(message = "处理状态不能为空")
private Integer dealStatus;
}

View File

@ -0,0 +1,41 @@
package com.dragon.vehicle.company.common.domain.req;
import com.dragon.vehicle.common.page.PageQuery;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import javax.validation.constraints.NotEmpty;
import java.util.Date;
/**
*
*
* @author HuZhiYong
* @version 2023/11/23 - 22:29
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
public class FaultRecordQueryReq extends PageQuery {
@NotEmpty(message = "故障记录表ID不能为空")
private Integer faultRecordId;
@NotEmpty(message = "故障码ID不能为空")
private Integer faultCodeId;
@NotEmpty(message = "车辆vin不能为空")
private String vin;
@NotEmpty(message = "故障等级不能为空")
private Integer alertScore;
@NotEmpty(message = "开始报警时间不能为空")
private Date startAlerTime;
@NotEmpty(message = "最近一次报警时间不能为空")
private Date recentAlerTime;
@NotEmpty(message = "处理时间不能为空")
private Date dealTime;
@NotEmpty(message = "处理人不能为空")
private String dealUser;
@NotEmpty(message = "处理状态不能为空")
private UnknownError dealStatus;
}

View File

@ -0,0 +1,70 @@
package com.dragon.vehicle.company.common.domain.req;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import javax.validation.constraints.NotEmpty;
import java.util.Date;
/**
* UpdateReq
*
* @author HuZhiYong
* @version 2023/11/23 - 13:53
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class FaultRecordUpdateReq {
private Integer falutRecordId;
/**
* ID
*/
@NotEmpty(message = "故障码不能为空")
private Integer falutCodeId;
/**
* VIN
*/
@NotEmpty(message = "车辆VIN不能为空")
private String vin;
/**
*
* 0
* 1
* 2
*/
@NotEmpty(message = "故障等级不能为空")
private Integer alertScore;
/**
*
*/
@NotEmpty(message = "开始报警时间不能为空")
private Date startAlertTime;
/**
*
*/
@NotEmpty(message = "最近一次报警时间不能为空")
private Date recentAlertTime;
/**
*
*/
@NotEmpty(message = "处理时间不能为空")
private Date dealTime;
/**
*
*/
@NotEmpty(message = "处理人不能为空")
private String dealUser;
/**
*
* 0
* 1
* 2
*/
@NotEmpty(message = "处理状态不能为空")
private Integer dealStatus;
}

View File

@ -77,6 +77,6 @@ public class FirmAddReq {
*/ */
@NotEmpty(message = "企业统一社会信用代码不能为空") @NotEmpty(message = "企业统一社会信用代码不能为空")
@Pattern(regexp = License) @Pattern(regexp = License)
private String unifiedSocialCredit; private String firmSocialCredit;
} }

View File

@ -20,11 +20,6 @@ import static com.dragon.vehicle.company.common.contsants.RegexConstants.*;
@AllArgsConstructor @AllArgsConstructor
public class FirmQueryReq extends PageQuery { public class FirmQueryReq extends PageQuery {
/**
*
*/
@NotEmpty(message = "企业编号不能为空")
private Integer firmId;
/** /**
* *
*/ */
@ -88,5 +83,5 @@ public class FirmQueryReq extends PageQuery {
*/ */
@NotEmpty(message = "企业统一社会信用代码不能为空") @NotEmpty(message = "企业统一社会信用代码不能为空")
@Pattern(regexp = License) @Pattern(regexp = License)
private String unifiedSocialCredit; private String firmSocialCredit;
} }

View File

@ -88,5 +88,5 @@ public class FrimUpdateReq {
*/ */
@NotEmpty(message = "企业统一社会信用代码不能为空") @NotEmpty(message = "企业统一社会信用代码不能为空")
@Pattern(regexp = License) @Pattern(regexp = License)
private String unifiedSocialCredit; private String firmSocialCredit;
} }

View File

@ -0,0 +1,37 @@
package com.dragon.vehicle.company.common.domain.req;
import com.dragon.vehicle.common.page.PageQuery;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import javax.validation.constraints.NotEmpty;
/**
* Query
*
* @author HuZhiYong
* @version 2023/11/24 - 22:22
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@SuperBuilder
public class VehicleBreakdownQueryReq extends PageQuery {
/**
* ID
*/
@NotEmpty(message = "故障码ID不能为空")
public Integer breakdownId;
/**
*
*/
@NotEmpty(message = "故障码代码不能为空")
public String breakdownCode;
/**
*
*/
@NotEmpty(message = "故障码状态不能为空")
public Integer breakdownStatus;
}

View File

@ -60,5 +60,6 @@ public class AopLog {
logger.info("调用后:目标方法的类名:{},方法名:{},传递的参数为:{}",className,methodName,mapper.writeValueAsString(obj)); logger.info("调用后:目标方法的类名:{},方法名:{},传递的参数为:{}",className,methodName,mapper.writeValueAsString(obj));
logger.info("耗时:{}ms",System.currentTimeMillis()-startTime.get()); logger.info("耗时:{}ms",System.currentTimeMillis()-startTime.get());
return obj; return obj;
} }
} }

View File

@ -0,0 +1,69 @@
package com.dragon.vehicle.company.server.controller;
import com.dragon.common.core.domain.Result;
import com.dragon.common.core.web.page.TableDataInfo;
import com.dragon.vehicle.company.common.domain.FaultRecord;
import com.dragon.vehicle.company.common.domain.req.FaultRecordAddReq;
import com.dragon.vehicle.company.common.domain.req.FaultRecordQueryReq;
import com.dragon.vehicle.company.common.domain.req.FaultRecordUpdateReq;
import com.dragon.vehicle.company.server.service.FaultRecordService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
/**
*
*
* @author HuZhiYong
* @version 2023/11/23 - 14:30
*/
@RestController
@RequestMapping("/faultRecord")
public class FaultRecordController {
@Autowired
private FaultRecordService faultRecordService;
/**
*
* @param faultRecordAddReq
* @return
*/
@PostMapping()
public Result<String> addFaultRecord(@RequestBody @Validated FaultRecordAddReq faultRecordAddReq){
faultRecordService.save(FaultRecord.addReqBuild(faultRecordAddReq));
return Result.success();
}
/**
*
* @param recordUpdateReq
* @return
*/
@PostMapping("/{updateById}")
public Result<String> updateFaultRecord(@RequestBody FaultRecordUpdateReq recordUpdateReq){
faultRecordService.updateById(FaultRecord.updateReqBuild(recordUpdateReq));
return Result.success();
}
/**
*
* @param faultRecordId
* @return
*/
@PostMapping("/{faultRecordId}")
public Result delRecordId(@PathVariable Integer faultRecordId){
faultRecordService.removeById(faultRecordId);
return Result.success();
}
/**
*
*/
@GetMapping("/list")
public Result<TableDataInfo<FaultRecord>> selectFaultList( FaultRecordQueryReq faultRecordQueryReq){
TableDataInfo<FaultRecord> tableDataInfo=faultRecordService.seletFaultlist(faultRecordQueryReq);
return Result.success (tableDataInfo);
}
}

View File

@ -14,7 +14,7 @@ import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
@RestController @RestController
@RequestMapping("/firm/company") @RequestMapping("/firm")
public class FirmController { public class FirmController {
@Autowired @Autowired
@ -50,14 +50,13 @@ public class FirmController {
* *
* @return * @return
*/ */
@GetMapping("/list") @GetMapping("/firmInfoList")
public Result<TableDataInfo<FirmInfo>> selectFirmList(@RequestBody @Validated FirmQueryReq firmQueryReq){ public Result<TableDataInfo<FirmInfo>> selectFirmList( FirmQueryReq firmQueryReq){
TableDataInfo<FirmInfo> tableDataInfo = firmService.selectFirmList(firmQueryReq); TableDataInfo<FirmInfo> tableDataInfo = firmService.selectFirmList(firmQueryReq);
return Result.success(tableDataInfo); return Result.success(tableDataInfo);
} }
/** /**
* *
* @param firmId * @param firmId

View File

@ -0,0 +1,13 @@
package com.dragon.vehicle.company.server.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dragon.vehicle.company.common.domain.FaultRecord;
import org.apache.ibatis.annotations.Mapper;
/**
* @author HuZhiYong
* @version 2023/11/23 - 14:32
*/
@Mapper
public interface FaultRecordMapper extends BaseMapper<FaultRecord> {
}

View File

@ -0,0 +1,13 @@
package com.dragon.vehicle.company.server.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dragon.vehicle.company.common.domain.VehicleBreakdown;
import org.apache.ibatis.annotations.Mapper;
/**
* @author HuZhiYong
* @version 2023/11/24 - 21:29
*/
@Mapper
public interface VehicleBreakdownMapper extends BaseMapper<VehicleBreakdown> {
}

View File

@ -0,0 +1,14 @@
package com.dragon.vehicle.company.server.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.dragon.common.core.web.page.TableDataInfo;
import com.dragon.vehicle.company.common.domain.FaultRecord;
import com.dragon.vehicle.company.common.domain.req.FaultRecordQueryReq;
/**
* @author HuZhiYong
* @version 2023/11/23 - 14:31
*/
public interface FaultRecordService extends IService<FaultRecord> {
TableDataInfo<FaultRecord> seletFaultlist(FaultRecordQueryReq faultRecordQueryReq);
}

View File

@ -0,0 +1,15 @@
package com.dragon.vehicle.company.server.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.dragon.common.core.web.page.TableDataInfo;
import com.dragon.vehicle.company.common.domain.VehicleBreakdown;
import com.dragon.vehicle.company.common.domain.req.VehicleBreakdownQueryReq;
/**
* @author HuZhiYong
* @version 2023/11/24 - 21:29
*/
public interface VehicleBreakdownService extends IService<VehicleBreakdown> {
TableDataInfo<VehicleBreakdown> selectBreaklist(VehicleBreakdownQueryReq vehicleBreakdownQueryReq);
}

View File

@ -0,0 +1,79 @@
package com.dragon.vehicle.company.server.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.dragon.common.core.exception.ServiceException;
import com.dragon.common.core.utils.StringUtils;
import com.dragon.common.core.web.page.TableDataInfo;
import com.dragon.vehicle.company.common.domain.FaultRecord;
import com.dragon.vehicle.company.common.domain.req.FaultRecordQueryReq;
import com.dragon.vehicle.company.server.mapper.FaultRecordMapper;
import com.dragon.vehicle.company.server.service.FaultRecordService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.io.Serializable;
/**
* @author HuZhiYong
* @version 2023/11/23 - 14:31
*/
@Service
@Log4j2
public class FaultRecordServiceImpl extends ServiceImpl<FaultRecordMapper, FaultRecord> implements FaultRecordService {
@Autowired
private FaultRecordMapper faultRecordMapper;
@Override
public boolean save(FaultRecord entity) {
boolean save = super.save(entity);
if (!save){
log.warn("添加失败:[{}]",entity.getFalutCodeId());
throw new ServiceException("添加失败");
}
return true;
}
@Override
public boolean updateById(FaultRecord entity) {
boolean update = super.updateById(entity);
if (!update){
log.warn("修改失败:[{}]",entity.getFalutCodeId());
throw new ServiceException("修改失败");
}
return true;
}
@Override
public boolean removeById(Serializable id) {
boolean remove = super.removeById(id);
if (!remove){
log.warn("删除失败:[{}]",id);
throw new ServiceException("删除失败");
}
return true;
}
@Override
public TableDataInfo<FaultRecord> seletFaultlist(FaultRecordQueryReq faultRecordQueryReq) {
LambdaQueryWrapper<FaultRecord> queryWrapper = new LambdaQueryWrapper<>();
if (StringUtils.isNotEmpty(faultRecordQueryReq.getVin())){
queryWrapper.like(FaultRecord::getVin,faultRecordQueryReq);
}
if (StringUtils.isNotEmpty(faultRecordQueryReq.getDealUser())){
queryWrapper.like(FaultRecord::getDealUser,faultRecordQueryReq);
}
Page<FaultRecord> page = this.page(faultRecordQueryReq.buildPage());
return TableDataInfo.<FaultRecord>builder()
.rows(page.getRecords())
.total(page.getTotal())
.build();
}
}

View File

@ -112,8 +112,8 @@ public class FirmServiceImpl extends ServiceImpl<FirmMapper, FirmInfo> implement
queryWrapper.eq(FirmInfo::getFirmBankAccount,firmQueryReq.getFirmBankAccount()); queryWrapper.eq(FirmInfo::getFirmBankAccount,firmQueryReq.getFirmBankAccount());
} }
if (StringUtils.isNotEmpty(firmQueryReq.getUnifiedSocialCredit())){ if (StringUtils.isNotEmpty(firmQueryReq.getFirmSocialCredit())){
queryWrapper.eq(FirmInfo::getUnifiedSocialCredit,firmQueryReq.getUnifiedSocialCredit()); queryWrapper.eq(FirmInfo::getFirmSocialCredit,firmQueryReq.getFirmSocialCredit());
} }
if (StringUtils.isNotEmpty(firmQueryReq.getFirmRepresentativeId())){ if (StringUtils.isNotEmpty(firmQueryReq.getFirmRepresentativeId())){

View File

@ -0,0 +1,50 @@
package com.dragon.vehicle.company.server.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.dragon.common.core.utils.StringUtils;
import com.dragon.common.core.web.page.TableDataInfo;
import com.dragon.vehicle.company.common.domain.VehicleBreakdown;
import com.dragon.vehicle.company.common.domain.req.VehicleBreakdownQueryReq;
import com.dragon.vehicle.company.server.mapper.VehicleBreakdownMapper;
import com.dragon.vehicle.company.server.service.VehicleBreakdownService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @author HuZhiYong
* @version 2023/11/24 - 21:29
*/
@Service
public class VehicleBreakdownServiceImpl extends ServiceImpl<VehicleBreakdownMapper, VehicleBreakdown> implements VehicleBreakdownService {
@Autowired
private VehicleBreakdownMapper vehicleBreakdownMapper;
@Override
public TableDataInfo<VehicleBreakdown> selectBreaklist(VehicleBreakdownQueryReq vehicleBreakdownQueryReq) {
LambdaQueryWrapper<VehicleBreakdown> queryWrapper = new LambdaQueryWrapper<>();
if (StringUtils.isNotEmpty(vehicleBreakdownQueryReq.breakdownCode)){
queryWrapper.like(VehicleBreakdown::getBreakdownCode,vehicleBreakdownQueryReq.getBreakdownCode());
}
Page<VehicleBreakdown> page = this.page(vehicleBreakdownQueryReq.buildPage(), queryWrapper);
return TableDataInfo.<VehicleBreakdown>builder()
.rows(page.getRecords())
.total(page.getTotal())
.build();
}
@Override
public boolean updateById(VehicleBreakdown entity) {
LambdaUpdateWrapper<VehicleBreakdown> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.eq(VehicleBreakdown::getBreakdownId,entity.breakdownId)
.set(VehicleBreakdown::getBreakdownStatus,1);
vehicleBreakdownMapper.update(null,updateWrapper);
return true;
}
}