Commit e726ec82 authored by qinhu's avatar qinhu

修改质量控制

parent 6ed334c1
...@@ -134,7 +134,7 @@ public class NormProductionController { ...@@ -134,7 +134,7 @@ public class NormProductionController {
} }
} }
return BaseResponse.okData(null); return BaseResponse.okData(new Page<>());
} }
@GetMapping("/statistics/detail") @GetMapping("/statistics/detail")
...@@ -158,7 +158,7 @@ public class NormProductionController { ...@@ -158,7 +158,7 @@ public class NormProductionController {
Page<NormProduction.NormProductionDetail> rts = PageUtil.listConvertToPage(collect, pageQuery); Page<NormProduction.NormProductionDetail> rts = PageUtil.listConvertToPage(collect, pageQuery);
return BaseResponse.okData(rts); return BaseResponse.okData(rts);
} }
return BaseResponse.okData(null); return BaseResponse.okData(new Page<>());
} }
@GetMapping("/total/production") @GetMapping("/total/production")
......
...@@ -7,6 +7,7 @@ import cn.wise.sc.cement.business.model.vo.QualityDetailVo; ...@@ -7,6 +7,7 @@ import cn.wise.sc.cement.business.model.vo.QualityDetailVo;
import cn.wise.sc.cement.business.service.IEntrustService; import cn.wise.sc.cement.business.service.IEntrustService;
import cn.wise.sc.cement.business.service.IQualityApplyService; import cn.wise.sc.cement.business.service.IQualityApplyService;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiImplicitParams;
...@@ -61,7 +62,7 @@ public class QualityController { ...@@ -61,7 +62,7 @@ public class QualityController {
List<EntrustVo> records = baseResponse.getData().getRecords(); List<EntrustVo> records = baseResponse.getData().getRecords();
if (records.size() == 0) { if (records.size() == 0) {
return BaseResponse.okData(null); return BaseResponse.okData(new Page<>());
} }
List<Integer> projectIds = records.stream().map(EntrustVo::getId).collect(Collectors.toList()); List<Integer> projectIds = records.stream().map(EntrustVo::getId).collect(Collectors.toList());
Set<Integer> qualityApplyIds = iQualityApplyService.selectQualityApplyStatusByProIds(projectIds); Set<Integer> qualityApplyIds = iQualityApplyService.selectQualityApplyStatusByProIds(projectIds);
......
package cn.wise.sc.cement.business.controller; package cn.wise.sc.cement.business.controller;
import cn.hutool.core.collection.CollectionUtil;
import cn.wise.sc.cement.business.entity.Consumables; import cn.wise.sc.cement.business.entity.Consumables;
import cn.wise.sc.cement.business.entity.GroupStandard;
import cn.wise.sc.cement.business.entity.Standard; import cn.wise.sc.cement.business.entity.Standard;
import cn.wise.sc.cement.business.model.BaseResponse; import cn.wise.sc.cement.business.model.BaseResponse;
import cn.wise.sc.cement.business.model.PageQuery; import cn.wise.sc.cement.business.model.PageQuery;
...@@ -19,6 +21,7 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -19,6 +21,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.List; import java.util.List;
/** /**
...@@ -34,152 +37,159 @@ import java.util.List; ...@@ -34,152 +37,159 @@ import java.util.List;
@RequestMapping("/business/standard") @RequestMapping("/business/standard")
public class StandardController { public class StandardController {
private static final Logger log = LoggerFactory.getLogger("StandardController"); private static final Logger log = LoggerFactory.getLogger("StandardController");
@Autowired @Autowired
private IStandardService standardService; private IStandardService standardService;
@ApiOperation(value = "标样分页列表") @ApiOperation(value = "标样分页列表")
@ApiImplicitParams(value = { @ApiImplicitParams(value = {
@ApiImplicitParam(name = "name", value = "易耗品名称", paramType = "query", dataType = "String"), @ApiImplicitParam(name = "name", value = "易耗品名称", paramType = "query", dataType = "String"),
@ApiImplicitParam(name = "supplierName", value = "购买厂商名称", paramType = "query", dataType = "String") @ApiImplicitParam(name = "supplierName", value = "购买厂商名称", paramType = "query", dataType = "String")
}) })
@GetMapping("/getPage") @GetMapping("/getPage")
public BaseResponse getPage(PageQuery pageQuery, String name, String supplierName) { public BaseResponse getPage(PageQuery pageQuery, String name, String supplierName) {
try { try {
return standardService.getPage(pageQuery, name, supplierName); return standardService.getPage(pageQuery, name, supplierName);
} catch (Exception e) { } catch (Exception e) {
log.debug("标样分页列表{}", e); log.debug("标样分页列表{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation("标样信息列表导出") @ApiOperation("标样信息列表导出")
@PostMapping("/export") @PostMapping("/export")
public void export(String name, String supplierName, String fileName, HttpServletResponse response) { public void export(String name, String supplierName, String fileName, HttpServletResponse response) {
try { try {
standardService.export(name, supplierName, fileName, response); standardService.export(name, supplierName, fileName, response);
} catch (Exception e) { } catch (Exception e) {
log.debug("标样信息列表导出{}", e); log.debug("标样信息列表导出{}", e);
} }
} }
@ApiOperation(value = "新增标样") @ApiOperation(value = "新增标样")
@PostMapping("/create") @PostMapping("/create")
public BaseResponse create(@RequestBody StandardQuery query) { public BaseResponse create(@RequestBody StandardQuery query) {
try { try {
return standardService.create(query); return standardService.create(query);
} catch (Exception e) { } catch (Exception e) {
log.debug("新增标样{}", e); log.debug("新增标样{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "修改标样") @ApiOperation(value = "修改标样")
@PostMapping("/update") @PostMapping("/update")
public BaseResponse update(@RequestBody StandardQuery query) { public BaseResponse update(@RequestBody StandardQuery query) {
try { try {
return standardService.update(query); return standardService.update(query);
} catch (Exception e) { } catch (Exception e) {
log.debug("修改标样{}", e); log.debug("修改标样{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "查看历史标样材料信息") @ApiOperation(value = "查看历史标样材料信息")
@GetMapping("/getHistoryStandard/{id}") @GetMapping("/getHistoryStandard/{id}")
public BaseResponse getHistoryStandard(@PathVariable Integer id) { public BaseResponse getHistoryStandard(@PathVariable Integer id) {
try { try {
return standardService.getHistoryStandard(id); return standardService.getHistoryStandard(id);
} catch (Exception e) { } catch (Exception e) {
log.debug("查看历史标样材料信息{}", e); log.debug("查看历史标样材料信息{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "标样详情") @ApiOperation(value = "标样详情")
@GetMapping("/{id}") @GetMapping("/{id}")
public BaseResponse getById(@PathVariable Integer id) { public BaseResponse getById(@PathVariable Integer id) {
try { try {
return standardService.getDetail(id); return standardService.getDetail(id);
} catch (Exception e) { } catch (Exception e) {
log.debug("标样详情{}", e); log.debug("标样详情{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "标样列表") @ApiOperation(value = "标样列表")
@GetMapping("/getList") @GetMapping("/getList")
public BaseResponse getList() { public BaseResponse getList() {
try { try {
List<Standard> list = standardService.list(); List<Standard> list = standardService.list();
return BaseResponse.okData(list); return BaseResponse.okData(list);
} catch (Exception e) { } catch (Exception e) {
log.debug("标样列表{}", e); log.debug("标样列表{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "删除标样") @ApiOperation(value = "删除标样")
@PostMapping("/delete/{id}") @PostMapping("/delete/{id}")
public BaseResponse delete(@PathVariable Integer id) { public BaseResponse delete(@PathVariable Integer id) {
try { try {
standardService.removeById(id); standardService.removeById(id);
return BaseResponse.okData("删除成功"); return BaseResponse.okData("删除成功");
} catch (Exception e) { } catch (Exception e) {
log.debug("删除标样{}", e); log.debug("删除标样{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "新增入库") @ApiOperation(value = "新增入库")
@PostMapping("/enter") @PostMapping("/enter")
public BaseResponse enter(@RequestBody ChangeStockQuery query) { public BaseResponse enter(@RequestBody ChangeStockQuery query) {
try { try {
return standardService.enter(query); return standardService.enter(query);
} catch (Exception e) { } catch (Exception e) {
log.debug("新增入库{}", e); log.debug("新增入库{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "领用出库") @ApiOperation(value = "领用出库")
@PostMapping("/out") @PostMapping("/out")
public BaseResponse out(@RequestBody ChangeStockQuery query) { public BaseResponse out(@RequestBody ChangeStockQuery query) {
try { try {
return standardService.out(query); return standardService.out(query);
} catch (Exception e) { } catch (Exception e) {
log.debug("领用出库{}", e); log.debug("领用出库{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "变更有效期") @ApiOperation(value = "变更有效期")
@PostMapping("/changeValidDate") @PostMapping("/changeValidDate")
public BaseResponse changeValidDate(@RequestBody ChangeValidDateQuery query) { public BaseResponse changeValidDate(@RequestBody ChangeValidDateQuery query) {
try { try {
return standardService.changeValidDate(query); return standardService.changeValidDate(query);
} catch (Exception e) { } catch (Exception e) {
log.debug("变更有效期{}", e); log.debug("变更有效期{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation(value = "过期处置") @ApiOperation(value = "过期处置")
@PostMapping("/overdue") @PostMapping("/overdue")
public BaseResponse overdue(Integer id) { public BaseResponse overdue(Integer id) {
try { try {
return standardService.overdue(id); return standardService.overdue(id);
} catch (Exception e) { } catch (Exception e) {
log.debug("过期处置{}", e); log.debug("过期处置{}", e);
} }
return BaseResponse.errorMsg("失败!"); return BaseResponse.errorMsg("失败!");
} }
@ApiOperation("获取样本标准值列表") @ApiOperation("获取样本标准值列表")
@GetMapping("/detailList") @GetMapping("/detailList")
public BaseResponse<List<StandardValueVo>> getStandardDetailList() { public BaseResponse<List<StandardValueVo>> getStandardDetailList() {
return standardService.getStandardDetailList(); return standardService.getStandardDetailList();
} }
@ApiOperation("按检测组获取标样信息")
@GetMapping("/list/byGroup")
public BaseResponse<List<GroupStandard>> getStandards() {
return BaseResponse.okData(standardService.getStandards());
}
} }
package cn.wise.sc.cement.business.entity;
import lombok.Data;
import java.io.Serializable;
import java.util.Map;
/**
* @description: 标样值
* @author: qh
* @create: 2020-11-05 10:11
**/
@Data
public class GroupStandard implements Serializable {
private static final long serialVersionUID = 42L;
/**
* 检测组id
*/
private String groupName;
/**
* 标准样品key:value
*/
private Map<String, String> map;
}
...@@ -40,9 +40,9 @@ public class NormProduction implements Serializable { ...@@ -40,9 +40,9 @@ public class NormProduction implements Serializable {
private Integer assessId; private Integer assessId;
/** /**
* 类型 0:检测组 1:处理项 * 类型 1:检测组 0:处理项
*/ */
@ApiModelProperty("类型 0:检测组 1:处理项") @ApiModelProperty("类型 1:检测组 0:处理项")
private Integer type; private Integer type;
/** /**
......
package cn.wise.sc.cement.business.entity;
import lombok.Data;
import java.io.Serializable;
/**
* @description:
* @author: qh
* @create: 2020-11-05 11:02
**/
@Data
public class StandardGroupDto implements Serializable {
private String groupName;
private Integer groupId;
private String elementName;
private String elementValue;
}
\ No newline at end of file
package cn.wise.sc.cement.business.mapper; package cn.wise.sc.cement.business.mapper;
import cn.wise.sc.cement.business.entity.Standard; import cn.wise.sc.cement.business.entity.Standard;
import cn.wise.sc.cement.business.entity.StandardGroupDto;
import cn.wise.sc.cement.business.model.vo.StandardValueVo; import cn.wise.sc.cement.business.model.vo.StandardValueVo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
...@@ -21,4 +22,12 @@ public interface StandardMapper extends BaseMapper<Standard> { ...@@ -21,4 +22,12 @@ public interface StandardMapper extends BaseMapper<Standard> {
List<StandardValueVo> getStandardDetaulList(); List<StandardValueVo> getStandardDetaulList();
List<Map<String, Object>> exportList(@Param("params") Map<String, Object> params); List<Map<String, Object>> exportList(@Param("params") Map<String, Object> params);
/**
* @return
*
*/
List<StandardGroupDto> getStandardsByGroup();
} }
...@@ -43,5 +43,12 @@ ...@@ -43,5 +43,12 @@
<include refid="where"/> <include refid="where"/>
ORDER BY t.id DESC ORDER BY t.id DESC
</select> </select>
<select id="getStandardsByGroup" resultType="cn.wise.sc.cement.business.entity.StandardGroupDto">
select s.id as group_id,s.`name` as group_name,sv.element_name,sv.element_value FROM standard s
INNER JOIN
(SELECT * FROM standard_value) sv
ON s.id = sv.standard_id AND s.`status` = 1
</select>
</mapper> </mapper>
...@@ -26,10 +26,10 @@ public class NormProductionVo { ...@@ -26,10 +26,10 @@ public class NormProductionVo {
private Integer assessId; private Integer assessId;
/** /**
* 类型 0:检测组 1:处理项 * 类型 1:检测组 0:处理项
*/ */
@ApiModelProperty("类型 0:检测组 1:处理项") @ApiModelProperty("类型 1:检测组 0:处理项")
private Integer type; private String type;
/** /**
* 定额工日 * 定额工日
......
package cn.wise.sc.cement.business.service; package cn.wise.sc.cement.business.service;
import cn.wise.sc.cement.business.entity.EntityEnclosure; import cn.wise.sc.cement.business.entity.EntityEnclosure;
import cn.wise.sc.cement.business.entity.GroupStandard;
import cn.wise.sc.cement.business.entity.Standard; import cn.wise.sc.cement.business.entity.Standard;
import cn.wise.sc.cement.business.model.BaseResponse; import cn.wise.sc.cement.business.model.BaseResponse;
import cn.wise.sc.cement.business.model.PageQuery; import cn.wise.sc.cement.business.model.PageQuery;
...@@ -46,4 +47,10 @@ public interface IStandardService extends IService<Standard> { ...@@ -46,4 +47,10 @@ public interface IStandardService extends IService<Standard> {
BaseResponse<String> overdue(Integer id); BaseResponse<String> overdue(Integer id);
BaseResponse<List<StandardValueVo>> getStandardDetailList(); BaseResponse<List<StandardValueVo>> getStandardDetailList();
/**
* 按检测组获取标样信息
* @return GroupStandard
*/
List<GroupStandard> getStandards();
} }
package cn.wise.sc.cement.business.service.impl;
import lombok.Data;
/**
* @description: key:"",vale:""的映射对象
* @author: qh
* @create: 2020-11-05 10:47
**/
@Data
public class KeyValueMap {
private String name;
private String value;
}
...@@ -185,6 +185,11 @@ public class NormProductionServiceImpl extends ServiceImpl<NormProductionMapper, ...@@ -185,6 +185,11 @@ public class NormProductionServiceImpl extends ServiceImpl<NormProductionMapper,
.findFirst() .findFirst()
.ifPresent(opt -> normProductionVo.setAssessName(opt.getName())); .ifPresent(opt -> normProductionVo.setAssessName(opt.getName()));
} }
if (arg.getType() == 1) {
normProductionVo.setType("检测项");
} else {
normProductionVo.setType("处理项");
}
records.add(normProductionVo); records.add(normProductionVo);
}); });
rts.setRecords(records); rts.setRecords(records);
...@@ -436,7 +441,7 @@ public class NormProductionServiceImpl extends ServiceImpl<NormProductionMapper, ...@@ -436,7 +441,7 @@ public class NormProductionServiceImpl extends ServiceImpl<NormProductionMapper,
//处理非标准产值没有用名职位信息 //处理非标准产值没有用名职位信息
QueryWrapper<SysUser> qw = new QueryWrapper<>(); QueryWrapper<SysUser> qw = new QueryWrapper<>();
qw.in("id", userIds); qw.in("id", userIds);
if(CollectionUtil.isEmpty(userIds)){ if (CollectionUtil.isEmpty(userIds)) {
return null; return null;
} }
List<SysUser> users = iSysUserService.list(qw); List<SysUser> users = iSysUserService.list(qw);
......
...@@ -11,12 +11,11 @@ import cn.wise.sc.cement.business.model.PageQuery; ...@@ -11,12 +11,11 @@ import cn.wise.sc.cement.business.model.PageQuery;
import cn.wise.sc.cement.business.model.query.*; import cn.wise.sc.cement.business.model.query.*;
import cn.wise.sc.cement.business.model.vo.StandardValueVo; import cn.wise.sc.cement.business.model.vo.StandardValueVo;
import cn.wise.sc.cement.business.model.vo.StandardVo; import cn.wise.sc.cement.business.model.vo.StandardVo;
import cn.wise.sc.cement.business.service.IStandardEnterService;
import cn.wise.sc.cement.business.service.IStandardService; import cn.wise.sc.cement.business.service.IStandardService;
import cn.wise.sc.cement.business.service.IStandardValueService; import cn.wise.sc.cement.business.service.IStandardValueService;
import cn.wise.sc.cement.business.service.ISysUserService; import cn.wise.sc.cement.business.service.ISysUserService;
import cn.wise.sc.cement.business.util.ExcelUtil; import cn.wise.sc.cement.business.util.ExcelUtil;
import cn.wise.sc.cement.business.wrapper.page.Query; import cn.wise.sc.cement.business.util.ObjUtils;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
...@@ -34,8 +33,10 @@ import javax.servlet.http.HttpServletResponse; ...@@ -34,8 +33,10 @@ import javax.servlet.http.HttpServletResponse;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Set;
/** /**
* <p> * <p>
...@@ -48,367 +49,409 @@ import java.util.Map; ...@@ -48,367 +49,409 @@ import java.util.Map;
@Service @Service
public class StandardServiceImpl extends ServiceImpl<StandardMapper, Standard> implements IStandardService { public class StandardServiceImpl extends ServiceImpl<StandardMapper, Standard> implements IStandardService {
@Resource @Resource
private StandardMapper standardMapper; private StandardMapper standardMapper;
@Autowired @Autowired
private ISysUserService userService; private ISysUserService userService;
@Resource @Resource
private StandardEnterMapper standardEnterMapper; private StandardEnterMapper standardEnterMapper;
@Resource @Resource
private StandardOutMapper standardOutMapper; private StandardOutMapper standardOutMapper;
@Autowired @Autowired
private IStandardValueService standardValueService; private IStandardValueService standardValueService;
@Autowired @Autowired
private CommonServiceImpl commonService; private CommonServiceImpl commonService;
/** /**
* 分页查询 * 分页查询
* *
* @param pageQuery * @param pageQuery
* @param name * @param name
* @param supplierName * @param supplierName
* @return * @return
*/ */
@Override @Override
public BaseResponse<IPage<Standard>> getPage(PageQuery pageQuery, String name, String supplierName) { public BaseResponse<IPage<Standard>> getPage(PageQuery pageQuery, String name, String supplierName) {
QueryWrapper<Standard> qw = new QueryWrapper<>(); QueryWrapper<Standard> qw = new QueryWrapper<>();
if (StringUtils.isNotEmpty(name)) { if (StringUtils.isNotEmpty(name)) {
qw.like("name", name); qw.like("name", name);
} }
if (StringUtils.isNotEmpty(supplierName)) { if (StringUtils.isNotEmpty(supplierName)) {
qw.like("supplier_name", supplierName); qw.like("supplier_name", supplierName);
} }
qw.orderByDesc("name"); qw.orderByDesc("name");
IPage<Standard> page = new Page<>(pageQuery.getPageNo(), pageQuery.getPageSize()); IPage<Standard> page = new Page<>(pageQuery.getPageNo(), pageQuery.getPageSize());
page = standardMapper.selectPage(page, qw); page = standardMapper.selectPage(page, qw);
return BaseResponse.okData(page); return BaseResponse.okData(page);
} }
/** /**
* 标样信息列表导出 * 标样信息列表导出
* *
* @param name * @param name
* @param supplierName * @param supplierName
* @param fileName * @param fileName
* @param response * @param response
*/ */
@Override @Override
public void export(String name, String supplierName, String fileName, HttpServletResponse response) { public void export(String name, String supplierName, String fileName, HttpServletResponse response) {
Map<String, Object> params = new HashMap<>(); Map<String, Object> params = new HashMap<>();
params.put("supplierName", supplierName); params.put("supplierName", supplierName);
params.put("name", name); params.put("name", name);
List<Map<String, Object>> list = standardMapper.exportList(params); List<Map<String, Object>> list = standardMapper.exportList(params);
if (!CollectionUtils.isEmpty(list)) { if (!CollectionUtils.isEmpty(list)) {
Map<String, Object> map = list.get(0); Map<String, Object> map = list.get(0);
String[] headers = new String[map.size()]; String[] headers = new String[map.size()];
headers[0] = "序号"; headers[0] = "序号";
headers[1] = "标样名称"; headers[1] = "标样名称";
headers[2] = "标物代号"; headers[2] = "标物代号";
headers[3] = "经销单位"; headers[3] = "经销单位";
headers[4] = "存放位置"; headers[4] = "存放位置";
headers[5] = "进样日期"; headers[5] = "进样日期";
headers[6] = "有效日期"; headers[6] = "有效日期";
headers[7] = "剩余库存"; headers[7] = "剩余库存";
headers[8] = "状态"; headers[8] = "状态";
List<Object[]> datas = new ArrayList<>(list.size()); List<Object[]> datas = new ArrayList<>(list.size());
for (Map<String, Object> m : list) { for (Map<String, Object> m : list) {
Object[] objects = new Object[headers.length]; Object[] objects = new Object[headers.length];
for (int j = 0; j < headers.length; j++) { for (int j = 0; j < headers.length; j++) {
String obj = m.get(headers[j]).toString(); String obj = m.get(headers[j]).toString();
if (j == 0) { if (j == 0) {
obj = obj.split("\\.")[0]; obj = obj.split("\\.")[0];
} }
objects[j] = obj; objects[j] = obj;
} }
datas.add(objects); datas.add(objects);
} }
ExcelUtil.excelExport( ExcelUtil.excelExport(
fileName == null || fileName.trim().length() <= 0 ? "标样信息" : fileName, headers, fileName == null || fileName.trim().length() <= 0 ? "标样信息" : fileName, headers,
datas, response); datas, response);
} }
} }
/** /**
* 新增标样 * 新增标样
* *
* @param query * @param query
* @return * @return
*/ */
@Transactional @Transactional
@Override @Override
public BaseResponse<Standard> create(StandardQuery query) { public BaseResponse<Standard> create(StandardQuery query) {
if (StringUtils.isEmpty(query.getName())) { if (StringUtils.isEmpty(query.getName())) {
return BaseResponse.errorMsg("标样名称不能为空!"); return BaseResponse.errorMsg("标样名称不能为空!");
} }
LoginUser loginUser = userService.getLoginUser(); LoginUser loginUser = userService.getLoginUser();
if (loginUser == null) { if (loginUser == null) {
return BaseResponse.errorMsg("请登录账号"); return BaseResponse.errorMsg("请登录账号");
} }
QueryWrapper<Standard> qw = new QueryWrapper<>(); QueryWrapper<Standard> qw = new QueryWrapper<>();
qw.eq("name", query.getName()); qw.eq("name", query.getName());
int count = standardMapper.selectCount(qw); int count = standardMapper.selectCount(qw);
if (count > 0) { if (count > 0) {
return BaseResponse.errorMsg(query.getName() + "已存在"); return BaseResponse.errorMsg(query.getName() + "已存在");
} }
Standard standard = new Standard(); Standard standard = new Standard();
BeanUtils.copyProperties(query, standard); BeanUtils.copyProperties(query, standard);
standard.setStatus(1) standard.setStatus(1)
.setCreateTime(LocalDateTime.now()); .setCreateTime(LocalDateTime.now());
standardMapper.insert(standard); standardMapper.insert(standard);
//添加标准值 //添加标准值
if (query.getStandardValueQueryList() != null && query.getStandardValueQueryList().size() > 0) { if (query.getStandardValueQueryList() != null && query.getStandardValueQueryList().size() > 0) {
List<StandardValueQuery> standardValueQueryList = query.getStandardValueQueryList(); List<StandardValueQuery> standardValueQueryList = query.getStandardValueQueryList();
List<StandardValue> standardValueList = new ArrayList<>(); List<StandardValue> standardValueList = new ArrayList<>();
for (StandardValueQuery standardValueQuery : standardValueQueryList) { for (StandardValueQuery standardValueQuery : standardValueQueryList) {
StandardValue standardValue = new StandardValue(); StandardValue standardValue = new StandardValue();
standardValue.setStandardId(standard.getId()) standardValue.setStandardId(standard.getId())
.setElementName(standardValueQuery.getElementName()) .setElementName(standardValueQuery.getElementName())
.setCreateTime(LocalDateTime.now()); .setCreateTime(LocalDateTime.now());
if (standardValueQuery.getElementValue() != null && standardValueQuery.getElementValue().size() > 0) { if (standardValueQuery.getElementValue() != null && standardValueQuery.getElementValue().size() > 0) {
String elementValue = JSON.toJSON(standardValueQuery.getElementValue()).toString(); String elementValue = JSON.toJSON(standardValueQuery.getElementValue()).toString();
standardValue.setElementValue(elementValue); standardValue.setElementValue(elementValue);
} else { } else {
standardValue.setElementValue(null); standardValue.setElementValue(null);
} }
standardValueList.add(standardValue); standardValueList.add(standardValue);
} }
standardValueService.saveBatch(standardValueList); standardValueService.saveBatch(standardValueList);
} }
//标样入库记录添加 //标样入库记录添加
StandardEnter enter = new StandardEnter(); StandardEnter enter = new StandardEnter();
enter.setStandardId(standard.getId()) enter.setStandardId(standard.getId())
.setUserId(loginUser.getId()) .setUserId(loginUser.getId())
.setEnterNum(query.getStockNum()) .setEnterNum(query.getStockNum())
.setCreateTime(LocalDateTime.now()) .setCreateTime(LocalDateTime.now())
.setRemark("新增标样"); .setRemark("新增标样");
standardEnterMapper.insert(enter); standardEnterMapper.insert(enter);
//保存标样材料信息 //保存标样材料信息
Boolean ref = commonService.saveEntityEnclosure(EntityEnclosure.EntityType.STANDARD_SAMPLE, standard.getId(), query.getEnclosureQueryList()); Boolean ref = commonService.saveEntityEnclosure(EntityEnclosure.EntityType.STANDARD_SAMPLE, standard.getId(), query.getEnclosureQueryList());
if (!ref) { if (!ref) {
return BaseResponse.errorMsg("保存保存校核附件失败!"); return BaseResponse.errorMsg("保存保存校核附件失败!");
} }
return BaseResponse.okData(standard); return BaseResponse.okData(standard);
} }
/** /**
* 修改标样 * 修改标样
* *
* @param query * @param query
* @return * @return
*/ */
@Transactional @Transactional
@Override @Override
public BaseResponse<Standard> update(StandardQuery query) { public BaseResponse<Standard> update(StandardQuery query) {
if (StringUtils.isEmpty(query.getName())) { if (StringUtils.isEmpty(query.getName())) {
return BaseResponse.errorMsg("标样名称不能为空!"); return BaseResponse.errorMsg("标样名称不能为空!");
} }
QueryWrapper<Standard> qw = new QueryWrapper<>(); QueryWrapper<Standard> qw = new QueryWrapper<>();
qw.eq("name", query.getName()); qw.eq("name", query.getName());
qw.ne("id", query.getId()); qw.ne("id", query.getId());
int count = standardMapper.selectCount(qw); int count = standardMapper.selectCount(qw);
if (count > 0) { if (count > 0) {
return BaseResponse.errorMsg(query.getName() + "已存在"); return BaseResponse.errorMsg(query.getName() + "已存在");
} }
Standard standard = new Standard(); Standard standard = new Standard();
BeanUtils.copyProperties(query, standard); BeanUtils.copyProperties(query, standard);
standardMapper.updateById(standard); standardMapper.updateById(standard);
//添加标准值 //添加标准值
if (query.getStandardValueQueryList() != null && query.getStandardValueQueryList().size() > 0) { if (query.getStandardValueQueryList() != null && query.getStandardValueQueryList().size() > 0) {
//删除之前的标准值信息 //删除之前的标准值信息
QueryWrapper<StandardValue> queryWrapper = new QueryWrapper<>(); QueryWrapper<StandardValue> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("standard_id", standard.getId()); queryWrapper.eq("standard_id", standard.getId());
standardValueService.remove(queryWrapper); standardValueService.remove(queryWrapper);
//添加新的标准值 //添加新的标准值
List<StandardValueQuery> standardValueQueryList = query.getStandardValueQueryList(); List<StandardValueQuery> standardValueQueryList = query.getStandardValueQueryList();
List<StandardValue> standardValueList = new ArrayList<>(); List<StandardValue> standardValueList = new ArrayList<>();
for (StandardValueQuery standardValueQuery : standardValueQueryList) { for (StandardValueQuery standardValueQuery : standardValueQueryList) {
StandardValue standardValue = new StandardValue(); StandardValue standardValue = new StandardValue();
standardValue.setStandardId(standard.getId()) standardValue.setStandardId(standard.getId())
.setElementName(standardValueQuery.getElementName()) .setElementName(standardValueQuery.getElementName())
.setCreateTime(LocalDateTime.now()); .setCreateTime(LocalDateTime.now());
if (standardValueQuery.getElementValue() != null && standardValueQuery.getElementValue().size() > 0) { if (standardValueQuery.getElementValue() != null && standardValueQuery.getElementValue().size() > 0) {
String elementValue = JSON.toJSON(standardValueQuery.getElementValue()).toString(); String elementValue = JSON.toJSON(standardValueQuery.getElementValue()).toString();
standardValue.setElementValue(elementValue); standardValue.setElementValue(elementValue);
} else { } else {
standardValue.setElementValue(null); standardValue.setElementValue(null);
} }
standardValueList.add(standardValue); standardValueList.add(standardValue);
} }
standardValueService.saveBatch(standardValueList); standardValueService.saveBatch(standardValueList);
} }
//保存标样材料信息 //保存标样材料信息
Boolean ref = commonService.saveEntityEnclosure(EntityEnclosure.EntityType.STANDARD_SAMPLE, standard.getId(), query.getEnclosureQueryList()); Boolean ref = commonService.saveEntityEnclosure(EntityEnclosure.EntityType.STANDARD_SAMPLE, standard.getId(), query.getEnclosureQueryList());
if (!ref) { if (!ref) {
return BaseResponse.errorMsg("保存保存校核附件失败!"); return BaseResponse.errorMsg("保存保存校核附件失败!");
} }
return BaseResponse.okData(standard); return BaseResponse.okData(standard);
} }
@Resource @Resource
private EntityEnclosureMapper entityEnclosureMapper; private EntityEnclosureMapper entityEnclosureMapper;
/** /**
* 查看历史标样材料信息 * 查看历史标样材料信息
* *
* @param id * @param id
* @return * @return
*/ */
@Override @Override
public BaseResponse<List<EntityEnclosure>> getHistoryStandard(Integer id) { public BaseResponse<List<EntityEnclosure>> getHistoryStandard(Integer id) {
QueryWrapper<EntityEnclosure> wrapper = new QueryWrapper<>(); QueryWrapper<EntityEnclosure> wrapper = new QueryWrapper<>();
wrapper.eq("entity_type", EntityEnclosure.EntityType.STANDARD_SAMPLE); wrapper.eq("entity_type", EntityEnclosure.EntityType.STANDARD_SAMPLE);
wrapper.eq("entity_id", id); wrapper.eq("entity_id", id);
List<EntityEnclosure> entityEnclosureList = entityEnclosureMapper.selectList(wrapper); List<EntityEnclosure> entityEnclosureList = entityEnclosureMapper.selectList(wrapper);
return BaseResponse.okData(entityEnclosureList); return BaseResponse.okData(entityEnclosureList);
} }
/** /**
* 标样详情 * 标样详情
* *
* @param id 标样表id * @param id 标样表id
* @return * @return
*/ */
@Override @Override
public BaseResponse<StandardVo> getDetail(Integer id) { public BaseResponse<StandardVo> getDetail(Integer id) {
Standard standard = standardMapper.selectById(id); Standard standard = standardMapper.selectById(id);
if (standard == null) { if (standard == null) {
return BaseResponse.errorMsg("信息错误!"); return BaseResponse.errorMsg("信息错误!");
} }
StandardVo standardVo = new StandardVo(); StandardVo standardVo = new StandardVo();
BeanUtils.copyProperties(standard, standardVo); BeanUtils.copyProperties(standard, standardVo);
List<EntityEnclosure> entityEnclosureList = commonService.getEnclosureList List<EntityEnclosure> entityEnclosureList = commonService.getEnclosureList
(EntityEnclosure.EntityType.STANDARD_SAMPLE, standard.getId()); (EntityEnclosure.EntityType.STANDARD_SAMPLE, standard.getId());
List<EnclosureQuery> enclosureQueryList = new ArrayList<>(); List<EnclosureQuery> enclosureQueryList = new ArrayList<>();
for (EntityEnclosure entityEnclosure : entityEnclosureList) { for (EntityEnclosure entityEnclosure : entityEnclosureList) {
EnclosureQuery enclosureQuery = new EnclosureQuery(); EnclosureQuery enclosureQuery = new EnclosureQuery();
enclosureQuery.setAlias(entityEnclosure.getAlias()) enclosureQuery.setAlias(entityEnclosure.getAlias())
.setEnclosureUrl(entityEnclosure.getEnclosureUrl()) .setEnclosureUrl(entityEnclosure.getEnclosureUrl())
.setExtName(entityEnclosure.getExtName()); .setExtName(entityEnclosure.getExtName());
enclosureQueryList.add(enclosureQuery); enclosureQueryList.add(enclosureQuery);
} }
standardVo.setEnclosureQueryList(enclosureQueryList); standardVo.setEnclosureQueryList(enclosureQueryList);
QueryWrapper<StandardValue> queryWrapper = new QueryWrapper<>(); QueryWrapper<StandardValue> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("standard_id", standard.getId()); queryWrapper.eq("standard_id", standard.getId());
List<StandardValue> standardValueList = standardValueService.list(queryWrapper); List<StandardValue> standardValueList = standardValueService.list(queryWrapper);
standardVo.setStandardValueList(standardValueList); standardVo.setStandardValueList(standardValueList);
return BaseResponse.okData(standardVo); return BaseResponse.okData(standardVo);
} }
/** /**
* 新增入库 * 新增入库
* *
* @param query * @param query
* @return * @return
*/ */
@Transactional @Transactional
@Override @Override
public BaseResponse<String> enter(ChangeStockQuery query) { public BaseResponse<String> enter(ChangeStockQuery query) {
if (query == null || query.getId() == null) { if (query == null || query.getId() == null) {
return BaseResponse.errorMsg("参数错误!"); return BaseResponse.errorMsg("参数错误!");
} }
Standard standard = standardMapper.selectById(query.getId()); Standard standard = standardMapper.selectById(query.getId());
if (standard == null) { if (standard == null) {
return BaseResponse.errorMsg("数据错误!"); return BaseResponse.errorMsg("数据错误!");
} }
StandardEnter enter = new StandardEnter(); StandardEnter enter = new StandardEnter();
enter.setStandardId(standard.getId()) enter.setStandardId(standard.getId())
.setUserId(userService.getLoginUser().getId()) .setUserId(userService.getLoginUser().getId())
.setEnterNum(query.getChangeNum()) .setEnterNum(query.getChangeNum())
.setCreateTime(LocalDateTime.now()) .setCreateTime(LocalDateTime.now())
.setRemark(query.getRemark()); .setRemark(query.getRemark());
standardEnterMapper.insert(enter); standardEnterMapper.insert(enter);
standard.setStockNum(standard.getStockNum().add(enter.getEnterNum())); standard.setStockNum(standard.getStockNum().add(enter.getEnterNum()));
standardMapper.updateById(standard); standardMapper.updateById(standard);
return BaseResponse.okData("新增入库完成"); return BaseResponse.okData("新增入库完成");
} }
/** /**
* 领用出库 * 领用出库
* *
* @param query * @param query
* @return * @return
*/ */
@Transactional @Transactional
@Override @Override
public BaseResponse<String> out(ChangeStockQuery query) { public BaseResponse<String> out(ChangeStockQuery query) {
if (query == null || query.getId() == null) { if (query == null || query.getId() == null) {
return BaseResponse.errorMsg("参数错误!"); return BaseResponse.errorMsg("参数错误!");
} }
Standard standard = standardMapper.selectById(query.getId()); Standard standard = standardMapper.selectById(query.getId());
if (standard == null) { if (standard == null) {
return BaseResponse.errorMsg("数据错误!"); return BaseResponse.errorMsg("数据错误!");
} }
StandardOut out = new StandardOut(); StandardOut out = new StandardOut();
out.setStandardId(standard.getId()) out.setStandardId(standard.getId())
.setUserId(userService.getLoginUser().getId()) .setUserId(userService.getLoginUser().getId())
.setCollectNum(query.getChangeNum()) .setCollectNum(query.getChangeNum())
.setCreateTime(LocalDateTime.now()) .setCreateTime(LocalDateTime.now())
.setRemark(query.getRemark()); .setRemark(query.getRemark());
standardOutMapper.insert(out); standardOutMapper.insert(out);
standard.setStockNum(standard.getStockNum().subtract(out.getCollectNum())); standard.setStockNum(standard.getStockNum().subtract(out.getCollectNum()));
standardMapper.updateById(standard); standardMapper.updateById(standard);
return BaseResponse.okData("领用出库完成"); return BaseResponse.okData("领用出库完成");
} }
/** /**
* 变更有效期 * 变更有效期
* *
* @param query * @param query
* @return * @return
*/ */
@Transactional @Transactional
@Override @Override
public BaseResponse<String> changeValidDate(ChangeValidDateQuery query) { public BaseResponse<String> changeValidDate(ChangeValidDateQuery query) {
if (query == null || query.getId() == null) { if (query == null || query.getId() == null) {
return BaseResponse.errorMsg("参数错误!"); return BaseResponse.errorMsg("参数错误!");
} }
Standard standard = standardMapper.selectById(query.getId()); Standard standard = standardMapper.selectById(query.getId());
if (standard == null) { if (standard == null) {
return BaseResponse.errorMsg("数据错误!"); return BaseResponse.errorMsg("数据错误!");
} }
standard.setValidDate(query.getValidDate()); standard.setValidDate(query.getValidDate());
standardMapper.updateById(standard); standardMapper.updateById(standard);
return BaseResponse.okData("变更有效期完成"); return BaseResponse.okData("变更有效期完成");
} }
/** /**
* 过期处置 * 过期处置
* *
* @param id * @param id
* @return * @return
*/ */
@Transactional @Transactional
@Override @Override
public BaseResponse<String> overdue(Integer id) { public BaseResponse<String> overdue(Integer id) {
if (id == null) { if (id == null) {
return BaseResponse.errorMsg("参数错误!"); return BaseResponse.errorMsg("参数错误!");
} }
Standard standard = standardMapper.selectById(id); Standard standard = standardMapper.selectById(id);
if (standard == null) { if (standard == null) {
return BaseResponse.errorMsg("数据错误!"); return BaseResponse.errorMsg("数据错误!");
} }
standard.setStatus(0); standard.setStatus(0);
standardMapper.updateById(standard); standardMapper.updateById(standard);
return BaseResponse.okData("过期处置完成"); return BaseResponse.okData("过期处置完成");
} }
@Override @Override
public BaseResponse<List<StandardValueVo>> getStandardDetailList() { public BaseResponse<List<StandardValueVo>> getStandardDetailList() {
List<StandardValueVo> standardValueVos = standardMapper.getStandardDetaulList(); List<StandardValueVo> standardValueVos = standardMapper.getStandardDetaulList();
if (standardValueVos.size() != 0) { if (standardValueVos.size() != 0) {
return BaseResponse.okData(standardValueVos); return BaseResponse.okData(standardValueVos);
} else { } else {
return BaseResponse.errorMsg("没找数据!"); return BaseResponse.errorMsg("没找数据!");
} }
} }
@Override
public List<GroupStandard> getStandards() {
List<StandardGroupDto> list = standardMapper.getStandardsByGroup();
List<GroupStandard> rts = new ArrayList<>(list.size());
Set<Integer> standardIds = new HashSet<>();
for (StandardGroupDto tmp : list) {
if (!standardIds.contains(tmp.getGroupId())) {
standardIds.add(tmp.getGroupId());
GroupStandard groupStandard = new GroupStandard();
groupStandard.setGroupName(tmp.getGroupName());
Map<String, String> map = new HashMap<>();
List<KeyValueMap> keyValueMaps = ObjUtils.str2Obj(tmp.getElementValue());
keyValueMaps
.stream()
.filter(arg -> "标准值".equals(arg.getName()))
.findFirst()
.ifPresent(arg -> {
map.put(tmp.getElementName(), arg.getValue());
});
groupStandard.setMap(map);
rts.add(groupStandard);
} else {
//根据groupName找到标准值
rts.stream()
.filter(arg -> arg.getGroupName().equals(tmp.getGroupName()))
.findFirst()
.ifPresent(arg -> {
List<KeyValueMap> keyValueMaps = ObjUtils.str2Obj(tmp.getElementValue());
//将新的标准添加到map
keyValueMaps
.stream()
.filter(opt -> "标准值".equals(opt.getName()))
.findFirst()
.ifPresent(opt -> arg.getMap().put(tmp.getElementName(), opt.getValue()));
});
}
}
return rts;
}
} }
package cn.wise.sc.cement.business.util;
import cn.hutool.core.lang.Assert;
import cn.wise.sc.cement.business.service.impl.KeyValueMap;
import com.alibaba.fastjson.JSON;
import java.util.List;
/**
* @description:
* @author: qh
* @create: 2020-11-05 10:48
**/
public class ObjUtils {
public static List<KeyValueMap> str2Obj(String str){
Assert.notBlank(str,"带解析字符串不允许为空!");
return JSON.parseArray(str, KeyValueMap.class);
}
}
...@@ -15,7 +15,7 @@ public class PageUtil { ...@@ -15,7 +15,7 @@ public class PageUtil {
public static <T> Page<T> listConvertToPage(List<T> list, PageQuery pageQuery) { public static <T> Page<T> listConvertToPage(List<T> list, PageQuery pageQuery) {
if (CollectionUtil.isEmpty(list)){ if (CollectionUtil.isEmpty(list)){
return null; return new Page<>();
} }
int start = pageQuery.getPageNo() > 0 ? pageQuery.getPageNo() : 1; int start = pageQuery.getPageNo() > 0 ? pageQuery.getPageNo() : 1;
int pageSize = pageQuery.getPageSize() > 0 ? pageQuery.getPageSize() : 10; int pageSize = pageQuery.getPageSize() > 0 ? pageQuery.getPageSize() : 10;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment