From 66b84de58e3efae14c1e258ee716e02ad9557497 Mon Sep 17 00:00:00 2001 From: doum <doum> Date: 星期四, 09 十月 2025 08:48:50 +0800 Subject: [PATCH] 最新版本541200007 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkLineServiceImpl.java | 314 +++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 284 insertions(+), 30 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkLineServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkLineServiceImpl.java index ff6161e..c5b5fa2 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkLineServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkLineServiceImpl.java @@ -1,19 +1,38 @@ package com.doumee.service.business.impl; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.doumee.core.annotation.excel.ExcelImporter; +import com.doumee.core.constants.ResponseStatus; +import com.doumee.core.exception.BusinessException; +import com.doumee.core.utils.Constants; +import com.doumee.core.utils.ScientificNotationTUtil; +import com.doumee.dao.admin.request.CarsImport; +import com.doumee.dao.admin.request.JkLineImport; +import com.doumee.dao.business.CarsMapper; +import com.doumee.dao.business.CategoryMapper; +import com.doumee.dao.business.model.*; +import com.doumee.service.business.third.model.LoginUserInfo; import com.doumee.service.business.third.model.PageData; import com.doumee.service.business.third.model.PageWrap; import com.doumee.core.utils.Utils; import com.doumee.dao.business.JkLineMapper; -import com.doumee.dao.business.model.JkLine; import com.doumee.service.business.JkLineService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.github.yulichang.wrapper.MPJLambdaWrapper; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; +import org.springframework.web.multipart.MultipartFile; +import java.math.BigDecimal; +import java.util.ArrayList; +import java.util.Date; import java.util.List; /** @@ -25,17 +44,45 @@ public class JkLineServiceImpl implements JkLineService { @Autowired + private RedisTemplate<String, Object> redisTemplate; + @Autowired private JkLineMapper jkLineMapper; + @Autowired + private CategoryMapper categoryMapper; + @Autowired + private CarsMapper carsMapper; @Override public Integer create(JkLine jkLine) { + if(jkLineMapper.selectCount(new QueryWrapper<JkLine>().lambda() + .eq(JkLine::getIsdeleted,Constants.ZERO) + .eq(JkLine::getName,jkLine.getName()) )>0){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝绾胯矾鍚嶇О宸插瓨鍦紝璇疯繑鍥炲埛鏂伴〉闈㈡煡鐪嬶紒"); + } + if(categoryMapper.selectOne(new QueryWrapper<Category>().lambda() + .eq(Category::getId,jkLine.getCategoryId()) + .eq(Category::getType,Constants.FOUR) + .eq(Category::getIsdeleted,Constants.ZERO)) ==null){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝鎵�灞炰富绾胯矾涓嶅瓨鍦紝璇疯繑鍥炲埛鏂伴〉闈㈡煡鐪嬶紒"); + } + jkLine.setStatus(Constants.formatIntegerNum(jkLine.getStatus())); + jkLine.setIsdeleted(Constants.ZERO); + jkLine.setCreator(jkLine.getLoginUserInfo().getId()); + jkLine.setCreateDate(new Date()); + jkLine.setEditDate(jkLine.getCreateDate()); + jkLine.setEditor(jkLine.getCreator()); jkLineMapper.insert(jkLine); return jkLine.getId(); } @Override - public void deleteById(Integer id) { - jkLineMapper.deleteById(id); + public void deleteById(Integer id, LoginUserInfo user) { + jkLineMapper.update(null,new UpdateWrapper<JkLine>().lambda() + .set(JkLine::getIsdeleted,Constants.ONE) + .set(JkLine::getEditor,user.getId()) + .set(JkLine::getEditDate,new Date()) + .eq(JkLine::getId,id) + ); } @Override @@ -45,15 +92,34 @@ } @Override - public void deleteByIdInBatch(List<Integer> ids) { + public void deleteByIdInBatch(List<Integer> ids, LoginUserInfo user) { if (CollectionUtils.isEmpty(ids)) { return; } - jkLineMapper.deleteBatchIds(ids); + jkLineMapper.update(null,new UpdateWrapper<JkLine>().lambda() + .set(JkLine::getIsdeleted,Constants.ONE) + .set(JkLine::getEditor,user.getId()) + .set(JkLine::getEditDate,new Date()) + .in(JkLine::getId,ids) + ); } @Override public void updateById(JkLine jkLine) { + if(jkLineMapper.selectCount(new QueryWrapper<JkLine>().lambda() + .ne(JkLine::getId,jkLine.getId()) + .eq(JkLine::getIsdeleted,Constants.ZERO) + .eq(JkLine::getName,jkLine.getName()) )>0){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝绾胯矾鍚嶇О宸插瓨鍦紝璇疯繑鍥炲埛鏂伴〉闈㈡煡鐪嬶紒"); + } + if(categoryMapper.selectOne(new QueryWrapper<Category>().lambda() + .eq(Category::getId,jkLine.getCategoryId()) + .eq(Category::getType,Constants.FOUR) + .eq(Category::getIsdeleted,Constants.ZERO)) ==null){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝鎵�灞炰富绾胯矾涓嶅瓨鍦紝璇疯繑鍥炲埛鏂伴〉闈㈡煡鐪嬶紒"); + } + jkLine.setEditor(jkLine.getLoginUserInfo().getId()); + jkLine.setEditDate(new Date()); jkLineMapper.updateById(jkLine); } @@ -80,67 +146,75 @@ @Override public List<JkLine> findList(JkLine jkLine) { + jkLine.setIsdeleted(Constants.ZERO); QueryWrapper<JkLine> wrapper = new QueryWrapper<>(jkLine); + wrapper.lambda().orderByAsc(JkLine::getCode); return jkLineMapper.selectList(wrapper); } @Override public PageData<JkLine> findPage(PageWrap<JkLine> pageWrap) { IPage<JkLine> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); - QueryWrapper<JkLine> queryWrapper = new QueryWrapper<>(); + MPJLambdaWrapper<JkLine> queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); + pageWrap.getModel().setIsdeleted(Constants.ZERO); + queryWrapper.selectAll(JkLine.class ) + .selectAs(Cars::getCode,JkLine::getCarCode) + .selectAs(Category::getName,JkLine::getCategoryName) + .leftJoin(Category.class,Category::getId,JkLine::getCategoryId ) + .leftJoin(Cars.class,Cars::getId,JkLine::getCarId ); + queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getCarCode()),Cars::getCode, pageWrap.getModel().getCarCode()); + queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getCategoryName()),Category::getName, pageWrap.getModel().getCategoryName()); + queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getCode()),JkLine::getCode, pageWrap.getModel().getCode()); + queryWrapper.eq(StringUtils.isNotBlank(pageWrap.getModel().getWeeks()),JkLine::getWeeks, pageWrap.getModel().getWeeks()); + if (pageWrap.getModel().getId() != null) { - queryWrapper.lambda().eq(JkLine::getId, pageWrap.getModel().getId()); + queryWrapper.eq(JkLine::getId, pageWrap.getModel().getId()); } if (pageWrap.getModel().getCreator() != null) { - queryWrapper.lambda().eq(JkLine::getCreator, pageWrap.getModel().getCreator()); + queryWrapper.eq(JkLine::getCreator, pageWrap.getModel().getCreator()); } if (pageWrap.getModel().getCreateDate() != null) { - queryWrapper.lambda().ge(JkLine::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); - queryWrapper.lambda().le(JkLine::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); + queryWrapper.ge(JkLine::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate())); + queryWrapper.le(JkLine::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate())); } if (pageWrap.getModel().getEditor() != null) { - queryWrapper.lambda().eq(JkLine::getEditor, pageWrap.getModel().getEditor()); + queryWrapper.eq(JkLine::getEditor, pageWrap.getModel().getEditor()); } if (pageWrap.getModel().getEditDate() != null) { - queryWrapper.lambda().ge(JkLine::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); - queryWrapper.lambda().le(JkLine::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); + queryWrapper.ge(JkLine::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate())); + queryWrapper.le(JkLine::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate())); } if (pageWrap.getModel().getIsdeleted() != null) { - queryWrapper.lambda().eq(JkLine::getIsdeleted, pageWrap.getModel().getIsdeleted()); + queryWrapper.eq(JkLine::getIsdeleted, pageWrap.getModel().getIsdeleted()); } if (pageWrap.getModel().getInfo() != null) { - queryWrapper.lambda().eq(JkLine::getInfo, pageWrap.getModel().getInfo()); + queryWrapper.eq(JkLine::getInfo, pageWrap.getModel().getInfo()); } if (pageWrap.getModel().getName() != null) { - queryWrapper.lambda().eq(JkLine::getName, pageWrap.getModel().getName()); + queryWrapper.like(JkLine::getName, pageWrap.getModel().getName()); } if (pageWrap.getModel().getCategoryId() != null) { - queryWrapper.lambda().eq(JkLine::getCategoryId, pageWrap.getModel().getCategoryId()); + queryWrapper.eq(JkLine::getCategoryId, pageWrap.getModel().getCategoryId()); } if (pageWrap.getModel().getCarId() != null) { - queryWrapper.lambda().eq(JkLine::getCarId, pageWrap.getModel().getCarId()); + queryWrapper.eq(JkLine::getCarId, pageWrap.getModel().getCarId()); } if (pageWrap.getModel().getMaxCustomer() != null) { - queryWrapper.lambda().eq(JkLine::getMaxCustomer, pageWrap.getModel().getMaxCustomer()); + queryWrapper.eq(JkLine::getMaxCustomer, pageWrap.getModel().getMaxCustomer()); } if (pageWrap.getModel().getMaxOrder() != null) { - queryWrapper.lambda().eq(JkLine::getMaxOrder, pageWrap.getModel().getMaxOrder()); + queryWrapper.eq(JkLine::getMaxOrder, pageWrap.getModel().getMaxOrder()); } if (pageWrap.getModel().getStatus() != null) { - queryWrapper.lambda().eq(JkLine::getStatus, pageWrap.getModel().getStatus()); + queryWrapper.eq(JkLine::getStatus, pageWrap.getModel().getStatus()); } if (pageWrap.getModel().getSortnum() != null) { - queryWrapper.lambda().eq(JkLine::getSortnum, pageWrap.getModel().getSortnum()); + queryWrapper.eq(JkLine::getSortnum, pageWrap.getModel().getSortnum()); } - for(PageWrap.SortData sortData: pageWrap.getSorts()) { - if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) { - queryWrapper.orderByDesc(sortData.getProperty()); - } else { - queryWrapper.orderByAsc(sortData.getProperty()); - } - } - return PageData.from(jkLineMapper.selectPage(page, queryWrapper)); + queryWrapper.orderByAsc(JkLine::getCode); + IPage<JkLine> result = jkLineMapper.selectJoinPage(page, JkLine.class,queryWrapper); + return PageData.from(result); } @Override @@ -148,4 +222,184 @@ QueryWrapper<JkLine> wrapper = new QueryWrapper<>(jkLine); return jkLineMapper.selectCount(wrapper); } + + @Override + @Transactional(rollbackFor = {BusinessException.class,Exception.class}) + public List<JkLine> importBatch(MultipartFile file, LoginUserInfo loginUserInfo){ + Boolean importing = (Boolean) redisTemplate.opsForValue().get(Constants.RedisKeys.IMPORTING_JKLINE); + if(importing!=null && importing){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝宸插瓨鍦ㄥ鍏ヤ换鍔℃鍦ㄦ墽琛屼腑锛岃绋嶅悗鍐嶈瘯锛�"); + } + redisTemplate.opsForValue().set(Constants.RedisKeys.IMPORTING_JKLINE,true); + try { + ExcelImporter ie = null; + List<JkLineImport> dataList =null; + try { + ie = new ExcelImporter(file,1,0); + dataList = ie.getDataList(JkLineImport.class,null); + } catch (Exception e) { + e.printStackTrace(); + } + if(dataList == null || dataList.size() ==0){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝褰曞叆鏁版嵁涓虹┖锛�"); + } + //褰撳墠鎵�鏈夌嚎璺� + List<JkLine> allList = jkLineMapper.selectJoinList(JkLine.class,new MPJLambdaWrapper<JkLine>() + .selectAll(JkLine.class) + .eq(JkLine::getIsdeleted,Constants.ZERO) + ); + //鎵�鏈変富绾胯矾 + List<Category> categoryList = categoryMapper.selectJoinList(Category.class,new MPJLambdaWrapper<Category>() + .selectAll(Category.class) + .eq(Category::getIsdeleted,Constants.ZERO) + .eq(Category::getType,Constants.FOUR) + ); + //鎵�鏈夌墿娴佽溅杞﹁締 + List<Cars> cars = carsMapper.selectJoinList(Cars.class,new MPJLambdaWrapper<Cars>() + .selectAll(Cars.class) + .eq(Cars::getIsdeleted,Constants.ZERO) +// .eq(Cars::getType,Constants.ONE) + ); + + + List<JkLine> newList = new ArrayList<>(); + List<JkLine> updateList = new ArrayList<>(); + for(int i=0;i<dataList.size();i++){ + JkLineImport model = dataList.get(i); + if(StringUtils.isBlank(model.getName()) + &&StringUtils.isBlank(model.getCategoryName()) + &&StringUtils.isBlank(model.getCarCode()) + &&StringUtils.isBlank(model.getWeeks()) + &&StringUtils.isBlank(model.getCode()) + &&StringUtils.isBlank(model.getMaxCustomer()) + &&StringUtils.isBlank(model.getMaxOrder()) ){ + continue; + } + checkModelParam(model,newList,updateList,i,loginUserInfo,allList,categoryList,cars); + } + if((newList == null || newList.size() ==0) && updateList.size() == 0){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝褰曞叆鏈夋晥鏁版嵁涓虹┖锛�"); + } + if(newList.size()>0){ + jkLineMapper.insert(newList); + } + if(updateList.size()>0){ + for (JkLine c : updateList){ + jkLineMapper.updateById(c); + } + } + newList.addAll(updateList); + return newList; + }catch (BusinessException e){ + throw e; + }catch (Exception e){ + e.printStackTrace(); + throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"淇℃伅瀵煎叆澶辫触锛岃绋嶅悗閲嶈瘯"); + }finally { + redisTemplate.delete(Constants.RedisKeys.IMPORTING_JKLINE); + } + + } + + + private JkLine checkModelParam(JkLineImport model, List<JkLine> newList + , List<JkLine> updateList + ,int index + ,LoginUserInfo loginUserInfo + ,List<JkLine> allList + ,List<Category> categoryList + , List<Cars> carsList) { + if(StringUtils.isBlank(model.getName()) + ||StringUtils.isBlank(model.getCategoryName()) ){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝绗�"+(index+3)+"琛岀嚎璺俊鎭笉瀹屾暣锛岃妫�鏌ヨ〃鏍煎唴瀹癸紒"); + } + for(JkLine param: newList){ + if(StringUtils.isNotBlank(model.getName())&&StringUtils.isNotBlank(param.getName())) { + if (StringUtils.equals(model.getName(), param.getName())) { + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝绗�" + (index + 3) + "琛岀嚎璺悕绉般��" + model.getName() + "銆戦噸澶嶅嚭鐜帮紝璇锋鏌ヨ〃鏍煎唴瀹癸紒"); + } + } + } + Category cate = findCategoryFromListByName(model.getCategoryName(),categoryList); + if(cate == null){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝绗�" + (index + 3) + "琛屾墍灞炰富绾胯矾銆�" + model.getCategoryName() + "銆戜笉瀛樺湪锛岃妫�鏌ヨ〃鏍煎唴瀹癸紒"); + } + Cars car = findCarFromListByName(model.getCarCode(),carsList); + if(car == null){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝绗�" + (index + 3) + "琛岄�佽溅杞﹁締銆�" + model.getCarCode() + "銆戜笉瀛樺湪锛岃妫�鏌ヨ〃鏍煎唴瀹癸紒"); + } + JkLine line = findModelFromList(model.getName(),allList); + if(line == null){ + line = new JkLine(); + line.setCreator(loginUserInfo.getId()); + line.setCreateDate(new Date()); + line.setIsnew(Constants.ONE); + newList.add(line); + }else{ + line.setIsnew(Constants.ZERO); + updateList.add(line); + } + line.setName(model.getName()); + line.setCode(model.getCode()); + line.setCategoryId(cate.getId()); + line.setCarId(car.getId()); + line.setWeeks(model.getWeeks()); + line.setMaxCustomer(getIntegerByVal(model.getMaxCustomer())); + line.setMaxOrder(getIntegerByVal(model.getMaxOrder())); + + line.setEditDate(new Date()); + line.setEditor(loginUserInfo.getId()); + line.setIsdeleted(Constants.ZERO); + return line; + } + + private Integer getIntegerByVal(String maxCustomer) { + try { + return Integer.parseInt(maxCustomer); + }catch (Exception e){ + + } + return null; + } + + private Company findCompanyFromList(String companyName, List<Company> companyList) { + if(companyList !=null){ + for(Company company : companyList){ + if(StringUtils.equals(companyName,company.getCompanyNamePath())){ + return company; + } + } + } + return null; + } + private JkLine findModelFromList(String name, List<JkLine> list) { + if(list !=null){ + for(JkLine model : list){ + if(StringUtils.equals(name,model.getName())){ + return model; + } + } + } + return null; + } + private Category findCategoryFromListByName(String name, List<Category> list) { + if(list !=null){ + for(Category model : list){ + if(StringUtils.equals(name,model.getName())){ + return model; + } + } + } + return null; + } + private Cars findCarFromListByName(String name, List<Cars> list) { + if(list !=null){ + for(Cars model : list){ + if(StringUtils.equals(name,model.getCode())){ + return model; + } + } + } + return null; + } } -- Gitblit v1.9.3