parent
a5b2b39ebe
commit
3712e33b19
@ -0,0 +1,49 @@
|
||||
package com.chanko.yunxi.mes.module.biz.dal.mysql.salaryuser;
|
||||
|
||||
import com.chanko.yunxi.mes.framework.common.pojo.PageResult;
|
||||
import com.chanko.yunxi.mes.framework.mybatis.core.query.LambdaQueryWrapperX;
|
||||
import com.chanko.yunxi.mes.framework.mybatis.core.mapper.BaseMapperX;
|
||||
import com.chanko.yunxi.mes.module.biz.controller.admin.salarysetting.vo.SalarySettingPageReqVO;
|
||||
import com.chanko.yunxi.mes.module.biz.controller.admin.salarysetting.vo.SalaryUserPageReqVO;
|
||||
import com.chanko.yunxi.mes.module.biz.dal.dataobject.salarysetting.SalarySettingDO;
|
||||
import com.chanko.yunxi.mes.module.biz.dal.dataobject.salaryuser.SalaryUserDO;
|
||||
import com.chanko.yunxi.mes.module.system.dal.dataobject.user.AdminUserDO;
|
||||
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
import org.springframework.util.StringUtils;
|
||||
|
||||
/**
|
||||
* 员工工资设置主 Mapper
|
||||
*
|
||||
* @author 管理员
|
||||
*/
|
||||
@Mapper
|
||||
public interface SalaryUserMapper extends BaseMapperX<SalaryUserDO> {
|
||||
|
||||
// default PageResult<SalaryUserDO> selectPage(SalaryUserPageReqVO reqVO) {
|
||||
// return selectPage(reqVO, new LambdaQueryWrapperX<SalaryUserDO>()
|
||||
// .eqIfPresent(SalaryUserDO::getId, reqVO.getId())
|
||||
// .eqIfPresent(SalaryUserDO::getUserId, reqVO.getUserId())
|
||||
// .eqIfPresent(SalaryUserDO::getSalaryType, reqVO.getSalaryType())
|
||||
// .eqIfPresent(SalaryUserDO::getPrice, reqVO.getPrice())
|
||||
// .eqIfPresent(SalaryUserDO::getProcedure, reqVO.getProcedure())
|
||||
// .eqIfPresent(SalaryUserDO::getStatus, reqVO.getStatus())
|
||||
// .betweenIfPresent(SalaryUserDO::getCreateTime, reqVO.getCreateTime())
|
||||
// .orderByDesc(SalaryUserDO::getId));
|
||||
// }
|
||||
|
||||
default PageResult<SalaryUserDO> selectPage(SalaryUserPageReqVO reqVO) {
|
||||
MPJLambdaWrapper<SalaryUserDO> query = new MPJLambdaWrapper<>();
|
||||
query.selectAll(SalaryUserDO.class)
|
||||
.select("u.nickname as userName", "u.username as userCode")
|
||||
.leftJoin(AdminUserDO.class, "u", AdminUserDO::getId, SalaryUserDO::getUserId)
|
||||
.disableSubLogicDel()
|
||||
.orderByDesc(SalaryUserDO::getUserId);
|
||||
query.like(!StringUtils.isEmpty(reqVO.getUserCode()), "u.username", reqVO.getUserCode())
|
||||
.like(!StringUtils.isEmpty(reqVO.getUserName()), "u.nickname", reqVO.getUserName())
|
||||
.eq(!StringUtils.isEmpty(reqVO.getUserId()), SalaryUserDO::getUserId, reqVO.getUserId())
|
||||
;
|
||||
return selectPage(reqVO, query);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,55 @@
|
||||
package com.chanko.yunxi.mes.module.biz.service.salaryuser;
|
||||
|
||||
import javax.validation.*;
|
||||
|
||||
import com.chanko.yunxi.mes.module.biz.controller.admin.salarysetting.vo.SalaryUserPageReqVO;
|
||||
import com.chanko.yunxi.mes.module.biz.controller.admin.salarysetting.vo.SalaryUserSaveReqVO;
|
||||
import com.chanko.yunxi.mes.module.biz.dal.dataobject.salaryuser.SalaryUserDO;
|
||||
import com.chanko.yunxi.mes.framework.common.pojo.PageResult;
|
||||
|
||||
/**
|
||||
* 员工工资设置主 Service 接口
|
||||
*
|
||||
* @author 管理员
|
||||
*/
|
||||
public interface SalaryUserService {
|
||||
|
||||
/**
|
||||
* 创建员工工资设置主
|
||||
*
|
||||
* @param createReqVO 创建信息
|
||||
* @return 编号
|
||||
*/
|
||||
Long createSalaryUser(@Valid SalaryUserSaveReqVO createReqVO);
|
||||
|
||||
/**
|
||||
* 更新员工工资设置主
|
||||
*
|
||||
* @param updateReqVO 更新信息
|
||||
*/
|
||||
void updateSalaryUser(@Valid SalaryUserSaveReqVO updateReqVO);
|
||||
|
||||
/**
|
||||
* 删除员工工资设置主
|
||||
*
|
||||
* @param id 编号
|
||||
*/
|
||||
void deleteSalaryUser(Long id);
|
||||
|
||||
/**
|
||||
* 获得员工工资设置主
|
||||
*
|
||||
* @param id 编号
|
||||
* @return 员工工资设置主
|
||||
*/
|
||||
SalaryUserDO getSalaryUser(Long id);
|
||||
|
||||
/**
|
||||
* 获得员工工资设置主分页
|
||||
*
|
||||
* @param pageReqVO 分页查询
|
||||
* @return 员工工资设置主分页
|
||||
*/
|
||||
PageResult<SalaryUserDO> getSalaryUserPage(SalaryUserPageReqVO pageReqVO);
|
||||
|
||||
}
|
||||
@ -0,0 +1,113 @@
|
||||
package com.chanko.yunxi.mes.module.biz.service.salaryuser;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import com.chanko.yunxi.mes.module.biz.controller.admin.salarysetting.vo.SalaryUserPageReqVO;
|
||||
import com.chanko.yunxi.mes.module.biz.controller.admin.salarysetting.vo.SalaryUserSaveReqVO;
|
||||
import com.chanko.yunxi.mes.module.biz.dal.dataobject.salarysetting.SalarySettingDO;
|
||||
import com.chanko.yunxi.mes.module.biz.dal.dataobject.warehouse.WarehouseDO;
|
||||
import com.chanko.yunxi.mes.module.biz.dal.mysql.salarysetting.SalarySettingMapper;
|
||||
import org.springframework.stereotype.Service;
|
||||
import javax.annotation.Resource;
|
||||
import org.springframework.validation.annotation.Validated;
|
||||
|
||||
import com.chanko.yunxi.mes.module.biz.dal.dataobject.salaryuser.SalaryUserDO;
|
||||
import com.chanko.yunxi.mes.framework.common.pojo.PageResult;
|
||||
import com.chanko.yunxi.mes.framework.common.util.object.BeanUtils;
|
||||
|
||||
import com.chanko.yunxi.mes.module.biz.dal.mysql.salaryuser.SalaryUserMapper;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
import static com.chanko.yunxi.mes.framework.common.exception.util.ServiceExceptionUtil.exception;
|
||||
import static com.chanko.yunxi.mes.module.biz.enums.ErrorCodeConstants.*;
|
||||
|
||||
/**
|
||||
* 员工工资设置主 Service 实现类
|
||||
*
|
||||
* @author 管理员
|
||||
*/
|
||||
@Service
|
||||
@Validated
|
||||
public class SalaryUserServiceImpl implements SalaryUserService {
|
||||
|
||||
@Resource
|
||||
private SalaryUserMapper salaryUserMapper;
|
||||
|
||||
@Resource
|
||||
private SalarySettingMapper salarySettingMapper;
|
||||
|
||||
@Override
|
||||
public Long createSalaryUser(SalaryUserSaveReqVO createReqVO) {
|
||||
// 插入
|
||||
SalaryUserDO salaryUser = BeanUtils.toBean(createReqVO, SalaryUserDO.class);
|
||||
salaryUserMapper.insert(salaryUser);
|
||||
// 返回
|
||||
return salaryUser.getId();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void updateSalaryUser(SalaryUserSaveReqVO updateReqVO) {
|
||||
// 校验存在
|
||||
validateSalaryUserExists(updateReqVO.getId());
|
||||
// 更新
|
||||
SalaryUserDO updateObj = BeanUtils.toBean(updateReqVO, SalaryUserDO.class);
|
||||
salaryUserMapper.updateById(updateObj);
|
||||
|
||||
if(CollUtil.isNotEmpty(updateReqVO.getSetting())){
|
||||
List<SalarySettingDO> insertList = new ArrayList<>(16);
|
||||
List<SalarySettingDO> updateList = new ArrayList<>(16);
|
||||
|
||||
updateReqVO.getSetting().forEach(setting ->{
|
||||
SalarySettingDO salarySettingDO =new SalarySettingDO();
|
||||
if(setting.getId()==null || setting.getId()==0){
|
||||
|
||||
salarySettingDO.setSalaryUserId(updateObj.getId());
|
||||
salarySettingDO.setUserId(updateObj.getUserId());
|
||||
salarySettingDO.setSalaryType(updateObj.getSalaryType());
|
||||
salarySettingDO.setSalaryUserId(updateObj.getId());
|
||||
salarySettingDO.setPrice(updateObj.getPrice());
|
||||
salarySettingDO.setStatus(updateObj.getStatus());
|
||||
insertList.add(salarySettingDO);
|
||||
}else{
|
||||
salarySettingDO.setId(setting.getId());
|
||||
salarySettingDO.setSalaryUserId(updateObj.getId());
|
||||
salarySettingDO.setUserId(updateObj.getUserId());
|
||||
salarySettingDO.setSalaryType(updateObj.getSalaryType());
|
||||
salarySettingDO.setSalaryUserId(updateObj.getId());
|
||||
salarySettingDO.setPrice(updateObj.getPrice());
|
||||
salarySettingDO.setStatus(updateObj.getStatus());
|
||||
updateList.add(salarySettingDO);
|
||||
}
|
||||
});
|
||||
if(CollUtil.isNotEmpty(insertList)) salarySettingMapper.insertBatch(insertList);
|
||||
if(CollUtil.isNotEmpty(updateList)) salarySettingMapper.updateBatch(updateList);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteSalaryUser(Long id) {
|
||||
// 校验存在
|
||||
validateSalaryUserExists(id);
|
||||
// 删除
|
||||
salaryUserMapper.deleteById(id);
|
||||
}
|
||||
|
||||
private void validateSalaryUserExists(Long id) {
|
||||
if (salaryUserMapper.selectById(id) == null) {
|
||||
throw exception(SALARY_USER_NOT_EXISTS);
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public SalaryUserDO getSalaryUser(Long id) {
|
||||
return salaryUserMapper.selectById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public PageResult<SalaryUserDO> getSalaryUserPage(SalaryUserPageReqVO pageReqVO) {
|
||||
return salaryUserMapper.selectPage(pageReqVO);
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in new issue