package com.thhy.materials.modules.biz.concret.service.impl;
|
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.github.pagehelper.util.StringUtil;
|
import com.thhy.general.common.BasicResult;
|
import com.thhy.general.config.SysUserInfo;
|
import com.thhy.general.utils.UserInfoUtils;
|
import com.thhy.materials.modules.biz.concret.entity.ProjectBlokDtos;
|
import com.thhy.materials.modules.biz.concret.entity.TNeedNum;
|
import com.thhy.materials.modules.biz.concret.entity.TSteelNeedYear;
|
import com.thhy.materials.modules.biz.concret.mapper.TSteelNeedYearMapper;
|
import com.thhy.materials.modules.biz.concret.service.TSteelNeedYearService;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import javax.annotation.Resource;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class TSteelNeedYearServiceImpl implements TSteelNeedYearService {
|
|
|
@Resource
|
private TSteelNeedYearMapper yearMapper;
|
|
@Override
|
@Transactional
|
public BasicResult needYearInsert(Map<String, Object> values) {
|
String proId = values.get("proId").toString();//项目id
|
String years = values.get("years").toString();//年份
|
String sizeId = values.get("sizeId").toString();//尺寸id
|
String needId = yearMapper.proIdAndYearAndSizeId(proId,years,sizeId);
|
if(!StringUtil.isEmpty(needId)){
|
return BasicResult.faild("11111","项目、年份及尺寸不能重复","error");
|
}
|
List<Map<String,Object>> sizeList = (List<Map<String, Object>>) values.get("sizeList");
|
if(sizeList==null || sizeList.size()<=0||sizeList.get(0).get("reinforcementId").equals("")){
|
return BasicResult.faild("11111","管片配筋不能为空","error");
|
}
|
values.put("steelNeedId","");
|
yearMapper.needYearInsert(values);
|
for (Map<String,Object> va : sizeList){
|
va.put("steelNeedId",values.get("steelNeedId").toString());
|
yearMapper.needNumInsert(va);
|
}
|
|
return BasicResult.success("添加成功");
|
}
|
|
@Override
|
public BasicResult needYearList(Map<String, Object> values) {
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String companyId = sysUserInfo.getCompanyId();
|
values.put("companyId",companyId);
|
|
Integer pageSize = Integer.valueOf(values.get("pageSize").toString());
|
Integer pageNum = Integer.valueOf(values.get("pageNum").toString());
|
PageHelper.startPage(pageNum,pageSize);
|
List<TSteelNeedYear> needYears = yearMapper.needYearList(values);
|
List< HashMap<String, Object>> num = new ArrayList<HashMap<String, Object> >();
|
for (TSteelNeedYear needYear:needYears){
|
//查看项目下有多少培新
|
List<TNeedNum> needNums = yearMapper.proIdAndHas(needYear.getProId());
|
for (TNeedNum tNeedNum:needNums){
|
//条件 ： 项目 尺寸 管片 查询下面所有块号 块号
|
List<Integer> strings = yearMapper.needProSizePipe(needYear.getProId(),needYear.getSizeId(),tNeedNum.getReinforcementId(),needYear.getYears());
|
HashMap<String, Object> hashMap = new HashMap<>();
|
hashMap.put("proId",needYear.getProId());
|
hashMap.put("sizeId",needYear.getSizeId());
|
hashMap.put("reinforcementId",tNeedNum.getReinforcementId());
|
hashMap.put("years",needYear.getYears());
|
hashMap.put("strings",strings);
|
num.add(hashMap);
|
}
|
}
|
System.out.println("《------------------------------------》");
|
System.out.println("目前的数量"+num);
|
|
for (TSteelNeedYear needYear:needYears){
|
//项目下 块号
|
List<ProjectBlokDtos> blokDtos = yearMapper.proBlokList(needYear.getProId());
|
|
List<TNeedNum> needNums = yearMapper.needYear(needYear.getSteelNeedId());
|
|
for (TNeedNum tNeedNum:needNums){
|
//条件 ： 项目 尺寸 管片 查询下面所有块号 块号
|
// List<Integer> strings = yearMapper.needProSizePipe(needYear.getProId(),needYear.getSizeId(),tNeedNum.getReinforcementId());
|
for (HashMap<String, Object> conuts:num){
|
if(conuts.get("proId").toString().equals(needYear.getProId()) && conuts.get("years").toString().equals(needYear.getYears())
|
&& conuts.get("sizeId").toString().equals(needYear.getSizeId())
|
&& conuts.get("reinforcementId").toString().equals(tNeedNum.getReinforcementId())){
|
List<Integer> strings1 = (List<Integer>) conuts.get("strings");
|
|
|
if(blokDtos.size()==strings1.size()){
|
Integer min = Collections.min(strings1);
|
if(min>=tNeedNum.getNeedNum()){
|
System.out.println("开始值"+strings1);
|
//缺少判断是否是最后一个
|
List<String> collect = needNums.stream().map(a -> {
|
if(conuts.get("proId").toString().equals(needYear.getProId()) && conuts.get("years").toString().equals(needYear.getYears())
|
&& conuts.get("sizeId").toString().equals(needYear.getSizeId())
|
&& conuts.get("reinforcementId").toString().equals(tNeedNum.getReinforcementId())){
|
return a.getId();
|
}else {
|
return null;
|
}
|
}).collect(Collectors.toList());
|
if(collect.get(collect.size()-1).equals(tNeedNum.getId())){
|
for (int i=0 ;i<strings1.size();i++){
|
Integer integer = strings1.get(i);
|
int i1 = (integer - min);
|
strings1.set(i,i1);
|
}
|
conuts.put("strings",strings1);
|
tNeedNum.setOkNum(min);
|
}else {
|
for (int i=0 ;i<strings1.size();i++){
|
Integer integer = strings1.get(i);
|
int i1 = (integer - tNeedNum.getNeedNum());
|
strings1.set(i,i1);
|
}
|
System.out.println("结束值"+strings1);
|
conuts.put("strings",strings1);
|
tNeedNum.setOkNum(tNeedNum.getNeedNum());
|
}
|
|
|
}else if (min<tNeedNum.getNeedNum()&&min>0){
|
for (int i=0 ;i<strings1.size();i++){
|
Integer integer = strings1.get(i);
|
int i1 = (integer - min);
|
strings1.set(i,i1);
|
}
|
conuts.put("strings",strings1);
|
tNeedNum.setOkNum(min);
|
}else {
|
tNeedNum.setOkNum(0);
|
}
|
}
|
}
|
}
|
// if(blokDtos.size()==strings.size()){
|
// Integer min = Collections.min(strings);
|
// tNeedNum.setOkNum(min);
|
// }
|
}
|
needYear.setNeedNums(needNums);
|
}
|
PageInfo<TSteelNeedYear> tSteelNeedYearPageInfo = new PageInfo<>(needYears);
|
return BasicResult.success(tSteelNeedYearPageInfo);
|
}
|
|
@Override
|
@Transactional
|
public BasicResult needYearDel(String steelNeedId) {
|
yearMapper.needYearDel(steelNeedId);
|
yearMapper.needNumDel(steelNeedId);
|
return BasicResult.success("删除成功");
|
}
|
|
@Override
|
public BasicResult needYearInfo(String steelNeedId) {
|
TSteelNeedYear needYear = yearMapper.needYearInfo(steelNeedId);
|
List<TNeedNum> needNums = yearMapper.needYear(needYear.getSteelNeedId());
|
needYear.setNeedNums(needNums);
|
return BasicResult.success(needYear);
|
}
|
|
@Override
|
@Transactional
|
public BasicResult needYearUpdate(Map<String, Object> values) {
|
String steelNeedId = values.get("steelNeedId").toString();
|
String proId = values.get("proId").toString();//项目id
|
String years = values.get("years").toString();//年份
|
String sizeId = values.get("sizeId").toString();//尺寸id
|
String needId = yearMapper.proIdAndYearAndSizeId(proId,years,sizeId);
|
if(!StringUtil.isEmpty(needId)&&!steelNeedId.equals(needId)){
|
return BasicResult.faild("11111","error","项目、年份及尺寸不能重复");
|
}
|
//删除关联表信息
|
yearMapper.needNumDel(steelNeedId);
|
yearMapper.needYearUpdate(values);
|
List<Map<String,Object>> sizeList = (List<Map<String, Object>>) values.get("sizeList");
|
for (Map<String,Object> va : sizeList){
|
va.put("steelNeedId",steelNeedId);
|
yearMapper.needNumInsert(va);
|
}
|
return BasicResult.success("修改成功");
|
}
|
|
@Override
|
public BasicResult selectSteelInfo(Map<String, Object> values) {
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String companyId = sysUserInfo.getCompanyId();
|
values.put("companyId",companyId);
|
Integer pageSize = Integer.valueOf(values.get("pageSize").toString());
|
Integer pageNum = Integer.valueOf(values.get("pageNum").toString());
|
PageHelper.startPage(pageNum,pageSize);
|
List<Map<String, Object>> list = this.yearMapper.selectSteelInfo(values);
|
PageInfo<Map<String, Object>> pageInfo = new PageInfo<>(list);
|
return BasicResult.success(pageInfo);
|
}
|
|
@Override
|
public BasicResult selectPipeInfo(Map<String, Object> values) {
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
String companyId = sysUserInfo.getCompanyId();
|
values.put("companyId",companyId);
|
Integer pageSize = Integer.valueOf(values.get("pageSize").toString());
|
Integer pageNum = Integer.valueOf(values.get("pageNum").toString());
|
PageHelper.startPage(pageNum,pageSize);
|
List<Map<String, Object>> list = this.yearMapper.selectPipeInfo(values);
|
PageInfo<Map<String, Object>> pageInfo = new PageInfo<>(list);
|
return BasicResult.success(pageInfo);
|
}
|
|
}
|
