潘钊 / bsth_control · Files

package com.bsth.service.oil.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.DecimalFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;

import javax.transaction.Transactional;

import org.apache.commons.lang3.StringEscapeUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Direction;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Service;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.bsth.common.Constants;
import com.bsth.common.ResponseCode;
import com.bsth.data.BasicData;
import com.bsth.entity.Cars;
import com.bsth.entity.Line;
import com.bsth.entity.SystemParam;
import com.bsth.entity.mcy_forms.Daily;
import com.bsth.entity.oil.Cyl;
import com.bsth.entity.oil.Dlb;
import com.bsth.entity.oil.Nylog;
import com.bsth.entity.oil.Ylb;
import com.bsth.entity.oil.Ylxxb;
import com.bsth.entity.search.CustomerSpecs;
import com.bsth.entity.sys.Role;
import com.bsth.entity.sys.SysUser;
import com.bsth.repository.CarsRepository;
import com.bsth.repository.LineRepository;
import com.bsth.repository.oil.CylRepository;
import com.bsth.repository.oil.DlbRepository;
import com.bsth.repository.oil.NylogRepository;
import com.bsth.repository.oil.YlbRepository;
import com.bsth.repository.oil.YlxxbRepository;
import com.bsth.security.util.SecurityUtils;
import com.bsth.service.impl.BaseServiceImpl;
import com.bsth.service.oil.DlbService;
import com.bsth.service.oil.YlbService;
import com.bsth.service.realcontrol.ScheduleRealInfoService;
import com.bsth.util.Arith;
import com.bsth.util.BatchSaveUtils;
import com.bsth.util.ReportUtils;
import com.github.abel533.echarts.code.Y;

import javassist.bytecode.stackmap.BasicBlock.Catch;

@Service
public class YlbServiceImpl extends BaseServiceImpl<Ylb,Integer> implements YlbService{
	@Autowired
	YlbRepository repository;
	@Autowired
	NylogRepository nylogRepository;
	@Autowired
	YlxxbRepository ylxxbRepository;

	@Autowired
	DlbService dlbService;
	
	@Autowired
	DlbRepository dlbRepository;
	
	@Autowired
	CylRepository cylRepository;
	
	@Autowired
	CarsRepository carsRepository;
	

	@Autowired
	LineRepository lineRepository;
	
	@Autowired
	ScheduleRealInfoService scheduleRealInfoService;
	
	@Autowired
	JdbcTemplate jdbcTemplate;
	
	Logger logger = LoggerFactory.getLogger(this.getClass());
	
	private static boolean modify_rights_close = false;		//南汇的油电修改权限（由于浦交加了限制，改为默认打开权限）
	
	private static boolean modify_rights_close_pj = true;
	
	/**
	 * 获取进存油信息
	 * @Transactional 回滚事物
	 */
	@Transactional  
	@Override
	public String obtainDsq() throws Exception{
		String result = "failure";
		try { 
			List<Ylb> addList = new ArrayList<Ylb>();
			String type = "";
			List<Cars> carsList=carsRepository.findCars();
			 Map<String, Boolean> carsMap=new HashMap<String, Boolean>();
			 for (int i = 0; i < carsList.size(); i++) {
				 Cars c=carsList.get(i);
				 carsMap.put(c.getInsideCode(), (c.getSfdc()!=null?c.getSfdc():false)
							|| (c.getHydrogen()!=null?c.getHydrogen():false));//电车或氢能源车，排除这些类型就都是油车
			}
			SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
			Date dNow = new Date();   //当前时间
			Date dBefore = new Date();
			Calendar calendar = Calendar.getInstance(); //得到日历
			calendar.setTime(dNow);//把当前时间赋给日历
			calendar.add(Calendar.DAY_OF_MONTH, -1);  //设置为前一天
			dBefore = calendar.getTime();   //得到前一天的时间
			String rq=sdf.format(dBefore);
			//保留两位小数
			DecimalFormat df = new DecimalFormat("#.00");
			// TODO Auto-generated method stub
			Map<String, Object> newMap=new HashMap<String,Object>();
			//当天YLB信息
//			List<Ylb> ylList=repository.obtainYl(rq,"","","","","nbbm");
			List<Ylb> ylList=this.listOrderBy(rq,"","","","","nbbm");
			//当天YLXXB信息
	//		List<Ylxxb> ylxxList=ylxxbRepository.obtainYlxx(rq);
			//前一天所有车辆最后进场班次信息
			List<Ylb> ylListBe=this.listByRqJcsx(rq,"","","","");
//			List<Ylb> ylListBe=repository.listMaxRqJcsx(rq, "", "", "", "");
			List<Cyl> clyList=cylRepository.obtainCyl("","");
			//从排班表中计算出行驶的总里程
			List<Map<String,Object>> listpb=scheduleRealInfoService.yesterdayDataList("", rq, "", "", "", "");
			
			for(int x=0;x<listpb.size();x++){
				boolean sfyc = true;//是否油车
				Map<String, Object> map = listpb.get(x);
				if (carsMap.get(map.get("clZbh").toString()) != null
						&& carsMap.get(map.get("clZbh").toString())) {
					sfyc = false;
				}
				if(sfyc){
					//判断驾驶员驾驶的该车辆是否已经存入了（查出的结果集中日期是相同的，根据驾驶员、内部编号、线路编码判断）
					Ylb t=new Ylb();
					for(int k=0;k<ylList.size();k++){
						Ylb t1=ylList.get(k);
						if(t1.getNbbm().equals(map.get("clZbh").toString())
								&&t1.getJsy().equals(map.get("jGh").toString())
								&&t1.getXlbm().equals(map.get("xlBm").toString())
								&&t1.getLp().equals(map.get("lpName").toString()))
						{
							t=t1;
							type="update";
						}
					}
					
						//当日的第一个班次，出场油量等于前一天的最后一个班次的进场油量
						if(map.get("seqNumber").toString().equals("1")){
							boolean fage=true;
							for (int i = 0; i < ylListBe.size(); i++) {
								Ylb ylb=ylListBe.get(i);
								if(map.get("clZbh").toString().equals(ylb.getNbbm())){
									if(ylb.getJzyl()!=null){
										if(ylb.getJzyl()>=0){
											t.setCzyl(ylb.getJzyl());
											fage=false;
											break;
										}
									}
									
								}
							}
							if(fage){
								for (int y = 0; y < clyList.size(); y++) {
									Cyl cyl=clyList.get(y);
									if(map.get("clZbh").toString().equals(cyl.getNbbm())){
										if(cyl.getCyl()!=null){
											t.setCzyl(cyl.getCyl());
											fage=false;
											break;
										}
									}
								}
							}
							if(fage){
								t.setCzyl(0.0);
							}
						}
						t.setNbbm(map.get("clZbh").toString());
						t.setJsy(map.get("jGh")==null?"":map.get("jGh").toString());
						t.setZlc(map.get("totalKilometers")==null?0.0:Double.parseDouble(map.get("totalKilometers").toString()));
						t.setXlbm(map.get("xlBm")==null?"":map.get("xlBm").toString());
						t.setLinename(map.get("lineName")==null?"":map.get("lineName").toString());
						t.setJcsx(Integer.parseInt(map.get("seqNumber").toString()));
						t.setSsgsdm(map.get("company")==null?"":map.get("company").toString());
						t.setFgsdm(map.get("bCompany")==null?"":map.get("bCompany").toString());
						t.setLp(map.get("lpName")==null?"":map.get("lpName").toString());
						t.setJhsj(map.get("fcsj")==null?"":map.get("fcsj").toString());
						t.setJname(map.get("jName").toString());
						t.setRq(sdf.parse(rq));
						t.setCreatetime(dNow);
						if(!(t.getSsgsdm().equals("") || t.getFgsdm().equals(""))){
							if(type.equals("update")){
								repository.save(t);
							}else{
								addList.add(t);
							}
						}
				}
				
			} 
			if(addList.size()>0){ 
				try {
					new BatchSaveUtils<Ylb>().saveList2(addList, Ylb.class); 
				} catch (Exception e) {
					// TODO: handle exception
					if(e.getMessage().indexOf("PK_YLB_UK")>0){
						newMap.put("fage", "存在相同数据,数据已经过滤");
						logger.info("定时器:存在相同数据,数据已经过滤");
					}
				}
			}
			result = "success";
		}catch (Exception e) {
			// TODO Auto-generated catch block
			throw e;
		}finally{
			logger.info("setDDRB:"+result);
		}
		
		return result;
	}
	
	/**
	 * 获取进存油信息
	 * @Transactional 回滚事物
	 */
	@Transactional  
	@Override
	public Map<String, Object> obtain(Map<String, Object> map2) throws Exception{
		Map<String, Object> newMap = new HashMap<String, Object>();
		try {
			Date date=new Date();
			List<Cars> carsList = carsRepository.findCars();
			Map<String, Boolean> carsMap = new HashMap<String, Boolean>();
			for (int i = 0; i < carsList.size(); i++) {
				Cars c = carsList.get(i);
				carsMap.put(c.getInsideCode(), (c.getSfdc()!=null?c.getSfdc():false)
						|| (c.getHydrogen()!=null?c.getHydrogen():false));//电车或氢能源车，排除这些类型就都是油车
			}
			String rq = map2.get("rq").toString();
			String line = "";
			if (map2.get("xlbm_like") != null) {
				line = map2.get("xlbm_like").toString().trim();
			}
			String gsbm="";
			if(map2.get("ssgsdm_like")!=null){
				gsbm=map2.get("ssgsdm_like").toString();
			}
			String fgsbm="";
			if(map2.get("fgsdm_like")!=null){
				fgsbm=map2.get("fgsdm_like").toString();
			}
			String nbbm="";
			if(map2.get("nbbm_eq")!=null){
				nbbm=map2.get("nbbm_eq").toString();
			}
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			// 保留两位小数
			DecimalFormat df = new DecimalFormat("#.00");
			// TODO Auto-generated method stub
			// 当天YLB信息
			List<Ylb> ylList = this.listOrderBy(rq,gsbm,fgsbm,"",nbbm,"nbbm");

			// 当天YLXXB信息
			List<Ylxxb> ylxxList = ylxxbRepository.obtainYlxx(rq, 0,gsbm);

			// 前一天所有车辆最后进场班次信息
			List<Ylb> ylListBe = this.listByRqJcsx(rq, gsbm, fgsbm, "", nbbm);
			List<Cyl> clyList = cylRepository.obtainCyl(nbbm,gsbm);

			// 从排班表中计算出行驶的总里程
			List<Map<String, Object>> listpb =new ArrayList<Map<String, Object>>();
			List<Map<String, Object>> listpbs=scheduleRealInfoService.yesterdayDataList("", rq, gsbm, fgsbm, "", nbbm);

			String sxtj=map2.get("sxtj").toString();
			if(sxtj.equals("0")){
				listpb=listpbs;
			}else if (sxtj.equals("5")){
					List<String> stringList=new ArrayList<String>();

					List<Object[]> objectLists = repository.checkNbmmFgs(rq, gsbm);
					for (int i = 0; i < objectLists.size(); i++) {
						String clbm=objectLists.get(i)[0].toString();
						stringList.add(clbm);
					}
					
					for (int i = 0; i < stringList.size(); i++) {
						String strNbbm=stringList.get(i);
						for (int j = 0; j < listpbs.size(); j++) {
							Map<String, Object> map = listpbs.get(j);
							String mapNbbm=map.get("clZbh").toString();
							if(strNbbm.equals(mapNbbm)){
								listpb.add(map);
							}
						}
					}
					
			}else{
				List<Object[]> objectLists=repository.checkNbmmNum(rq, gsbm, fgsbm, "",nbbm);
				List<String> stringList=new ArrayList<String>();
				for (int i = 0; i < objectLists.size(); i++) {
					String clbm=objectLists.get(i)[0].toString();
					int cs=Integer.parseInt(objectLists.get(i)[1].toString());
					//一车一单
					if(sxtj.equals("1")){
						if(cs==1){
							stringList.add(clbm);
						}
					}	
					//一车多单
					if(sxtj.equals("2")){
						if(cs>1){
							stringList.add(clbm);
						}
					}
				}
				
				for (int i = 0; i < stringList.size(); i++) {
					String strNbbm=stringList.get(i);
					for (int j = 0; j < listpbs.size(); j++) {
						Map<String, Object> map = listpbs.get(j);
						String mapNbbm=map.get("clZbh").toString();
						if(strNbbm.equals(mapNbbm)){
							listpb.add(map);
						}
					}
				}
			}

			List<Ylb> addList = new ArrayList<Ylb>();
			List<Ylb> updateList = new ArrayList<Ylb>();
			Map<String, Object> ylMap=new HashMap<String, Object>();
			
			Map<String, Object> cMap=new HashMap<String, Object>();
			for (int x = 0; x < listpb.size(); x++) {
				String type = "add";
				boolean sfyc = true;//是否油车
				Map<String, Object> map = listpb.get(x);
				if (carsMap.get(map.get("clZbh").toString()) != null
						&& carsMap.get(map.get("clZbh").toString())) {
					sfyc = false;
				}
				if (sfyc) {
					// 判断驾驶员驾驶的该车辆是否已经存入了（查出的结果集中日期是相同的，根据驾驶员、内部编号、线路编码判断）
					Ylb t = new Ylb();
					for (int k = 0; k < ylList.size(); k++) {
						Ylb t1 = ylList.get(k);
						if (t1.getNbbm().equals(map.get("clZbh").toString())
								&& t1.getJsy().equals(map.get("jGh").toString())
								&& t1.getXlbm().equals(map.get("xlBm").toString()
								)) {
							if(t1.getLp()==null){
								//同人同车同线路不同路牌的过滤  （考虑到历史数据）
								if (cMap.get(map.get("clZbh").toString()+map.get("jGh").toString()+map.get("xlBm").toString())==null) {
									t = t1;
									type = "update";
									cMap.put(map.get("clZbh").toString()+map.get("jGh").toString()+map.get("xlBm").toString(),
											map.get("clZbh").toString());
								}
							}else{
								if(t1.getLp().equals(map.get("lpName").toString())){
									t = t1;
									type = "update";
								}
								
							}
						}
					}
					// 当日的第一个班次，出场油量等于前一天的最后一个班次的进场油量
					if (map.get("seqNumber").toString().equals("1")) {
						boolean fage = true;
						if(line.equals("")){
							for (int i = 0; i < ylListBe.size(); i++) {
								Ylb ylb = ylListBe.get(i);
								if (map.get("clZbh").toString().equals(ylb.getNbbm())) {
									if(ylb.getJzyl()>=0){
										t.setCzyl(ylb.getJzyl());
										fage = false;
										break;
									}
									
								}
							}
							if (fage) {
								for (int y = 0; y < clyList.size(); y++) {
									Cyl cyl = clyList.get(y);
									if (map.get("clZbh").toString().equals(cyl.getNbbm())) {
										if(cyl!=null){
											if(cyl.getCyl()>=0){
												t.setCzyl(cyl.getCyl());
												fage = false;
												break;
											}else {
												if(cyl.getCxrl()!=null){
													if(cyl.getCxrl()>0){
														t.setCzyl(cyl.getCxrl());
														fage = false;
														break;
													}
												}
											}
										}
									}
								}
							}
							if (fage) {
								t.setCzyl(0.0);
							}
						}else{
							if (line.equals(map.get("xlBm").toString())) {
								for (int i = 0; i < ylListBe.size(); i++) {
									Ylb ylb = ylListBe.get(i);
									if (map.get("clZbh").toString().equals(ylb.getNbbm())) {
										if(ylb.getJzyl()>=0){
											t.setCzyl(ylb.getJzyl());
											fage = false;
											break;
										}
										
									}
								}
								if (fage) {
									for (int y = 0; y < clyList.size(); y++) {
										Cyl cyl = clyList.get(y);
										if (map.get("clZbh").toString().equals(cyl.getNbbm())) {
											if(cyl!=null){
												if(cyl.getCyl()>=0){
													t.setCzyl(cyl.getCyl());
													fage = false;
													break;
												}else {
													if(cyl.getCxrl()!=null){
														if(cyl.getCxrl()>0){
															t.setCzyl(cyl.getCxrl());
															fage = false;
															break;
														}
													}
												}
											}
										}
									}
								}
								if (fage) {
									t.setCzyl(0.0);
								}
							}
						}
						
					}
					
					Double jzl = 0.0;
					//一人一车加注量只匹配一次
					if(ylMap.get(map.get("clZbh").toString()+"_"+ map.get("jGh").toString())==null){
						
						boolean fage2=false;
						for (int i = 0; i < ylxxList.size(); i++) {
							Ylxxb ylxxb = ylxxList.get(i);
							if (map.get("clZbh").toString().equals(ylxxb.getNbbm())
									&& map.get("jGh").toString().equals(ylxxb.getJsy())
									&& ylxxb.getJylx()==1) {
								if(ylxxb.getJzl()>0){
									fage2=true;
								}
								
							}
						}
						//车辆的加注量如果有任工干预，略接口过来 数据
						if(fage2){
							// 把当天手工输入的的YLXXB的加注量设置为当天YLB的加注量（根据车号，驾驶员判断,加油类型为1）
							for (int j = 0; j < ylxxList.size(); j++) {
								Ylxxb ylxxb = ylxxList.get(j);
								if (map.get("clZbh").toString().equals(ylxxb.getNbbm())
										&& map.get("jGh").toString().equals(ylxxb.getJsy())
										&& ylxxb.getJylx()==1) {
									jzl =Arith.add(jzl, ylxxb.getJzl());
								}
							}
							ylMap.put(map.get("clZbh").toString()+"_"+ map.get("jGh").toString(),map.get("xlBm") == null ? "" : map.get("xlBm").toString());
						}else{
							// 把当天的YLXXB的加注量设置为当天YLB的加注量（根据车号，驾驶员判断）
							for (int j = 0; j < ylxxList.size(); j++) {
								Ylxxb ylxxb = ylxxList.get(j);
								if (map.get("clZbh").toString().equals(ylxxb.getNbbm())
										&& map.get("jGh").toString().equals(ylxxb.getJsy())) {
									jzl =Arith.add(jzl, ylxxb.getJzl());
								}
							}
							ylMap.put(map.get("clZbh").toString()+"_"+ map.get("jGh").toString(),map.get("xlBm") == null ? "" : map.get("xlBm").toString());
						}
						
					}
					t.setJzl(jzl);
					t.setNbbm(map.get("clZbh").toString());
					t.setJsy(map.get("jGh") == null ? "" : map.get("jGh").toString());
					t.setZlc(map.get("totalKilometers") == null ? 0.0
							: Double.parseDouble(map.get("totalKilometers").toString()));
					t.setXlbm(map.get("xlBm") == null ? "" : map.get("xlBm").toString());
					t.setLinename(map.get("lineName")==null?"":map.get("lineName").toString());
					t.setJcsx(Integer.parseInt(map.get("seqNumber").toString()));
					t.setSsgsdm(map.get("company") == null ? "" : map.get("company").toString());
					t.setFgsdm(map.get("bCompany") == null ? "" : map.get("bCompany").toString());
					t.setJhsj(map.get("fcsj")==null?"":map.get("fcsj").toString());
					t.setRq(sdf.parse(rq));
					t.setLp(map.get("lpName")==null?"":map.get("lpName").toString());
					t.setJname(map.get("jName").toString());
					 if(!(t.getSsgsdm().equals("") || t.getFgsdm().equals(""))){
						 if(type.equals("add")){
							 t.setCreatetime(date);
							 addList.add(t); 
						 }else{
							 t.setUpdatetime(date);
						     updateList.add(t); 
						  }
					 }
//					repository.save(t);
					newMap.put("status", ResponseCode.SUCCESS);

				}
			}
			if(addList.size()>0){ 
				try {
					new BatchSaveUtils<Ylb>().saveList2(addList, Ylb.class); 
				} catch (Exception e) {
					// TODO: handle exception
					if(e.getMessage().indexOf("PK_YLB_UK")>0){
						newMap.put("fage", "存在相同数据,数据已经过滤");
						logger.info("获取:存在相同数据,数据已经过滤");
					}
				}
				
			}
			if(updateList.size()>0){
				for (int i = 0; i < updateList.size(); i++) {
					repository.save(updateList.get(i));
				}
			}
			SysUser user = SecurityUtils.getCurrentUser();
			Nylog nylog=new Nylog();
			nylog.setCreatedate(new Date());
			nylog.setCzmc("获取加存油");
			nylog.setNylx("油");
			nylog.setUserid(user.getUserName());
			nylog.setUsername(user.getName());
			nylog.setCxtj(rq+"-"+gsbm+"-"+fgsbm+"-"+line+"-"+nbbm+"-"+sxtj);
			nylogRepository.save(nylog);
			newMap.put("status", ResponseCode.SUCCESS);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			newMap.put("status", ResponseCode.ERROR);
			throw e;
		}

		return newMap;
	}
	
	
	/**
	 * 进场等于出场
	 */
	@Transactional  
	@Override
	public Map<String, Object> outAndIn(Map<String, Object> map) throws Exception{
		// TODO Auto-generated method stub
		String xlbm="";
		if(map.get("xlbm_like")!=null){
			xlbm= map.get("xlbm_like").toString().trim();
		}
		String gsbm="";
		if(map.get("ssgsdm_like")!=null){
			gsbm=map.get("ssgsdm_like").toString();
		}
		String fgsbm="";
		if(map.get("fgsdm_like")!=null){
			fgsbm=map.get("fgsdm_like").toString();
		}
		String rq = map.get("rq").toString();
		String nbbm="";
		if(map.get("nbbm_eq")!=null){
			nbbm=map.get("nbbm_eq").toString();
		}
		
		Map<String, Object> newMap=new HashMap<String,Object>();
		Map<String, Object> map2=new HashMap<String,Object>();
		try {
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");

			map.put("rq_eq", sdf.parse(rq));
//			List<Cyl> clyList = cylRepository.obtainCyl();
			// 获取车辆存油信息
			List<Cyl> cylList = cylRepository.obtainCyl(nbbm,gsbm);
			// 指定日期YLB信息
			List<Ylb> ylbList =new ArrayList<Ylb>();
			List<Ylb> ylbLists =new ArrayList<Ylb>();
			List<Ylb> iterator2=new ArrayList<Ylb>();
			ylbLists=this.listOrderBy(rq,gsbm,fgsbm,xlbm,nbbm,"jcsx");
			iterator2=this.listOrderBy(rq,gsbm,fgsbm,xlbm,nbbm,"nbbm,jcsx");
			// 从排班表中计算出行驶的总里程

			String sxtj=map.get("sxtj").toString();
			if(sxtj.equals("0")){
				ylbList=ylbLists;
			}else{
				List<Object[]> objectLists=repository.checkNbmmNum(rq, gsbm, fgsbm, xlbm,nbbm);
				List<String> stringList=new ArrayList<String>();
				for (int i = 0; i < objectLists.size(); i++) {
					String clbm=objectLists.get(i)[0].toString();
					int cs=Integer.parseInt(objectLists.get(i)[1].toString());
					//一车一单
					if(sxtj.equals("1")){
						if(cs==1){
							stringList.add(clbm);
						}
					}	
					//一车多单
					if(sxtj.equals("2")){
						if(cs>1){
							stringList.add(clbm);
						}
					}
				}
				
				for (int i = 0; i < stringList.size(); i++) {
					String strNbbm=stringList.get(i);
					for (int j = 0; j < ylbLists.size(); j++) {
						Ylb y = ylbLists.get(j);
						String mapNbbm=y.getNbbm();
						if(strNbbm.equals(mapNbbm)){
							ylbList.add(y);
						}
					}
				}
			}
			
			for (int i=0;i<ylbList.size();i++) {
				Ylb ylb = ylbList.get(i);
				// 判断是否已经计算过
				if (newMap.get("nbbm" + ylb.getNbbm()) == null) {
					String nbbm_eq = ylb.getNbbm();
					Date rq_eq = ylb.getRq();
					// 得到一天总的加油和里程（根据车，时间）
					List<Object[]> sumList = repository.sumLcYl(nbbm_eq, rq_eq,"",gsbm,fgsbm);
					// 保存总的加油量
					Double jzl = 0.0;
					// 保存总的里程
					Double zlc = 0.0;
					//保存总的损耗
					Double zsh = 0.0;
					for (int j = 0; j < sumList.size(); j++) {
						jzl = Arith.add(jzl, Double.valueOf(sumList.get(j)[0].toString()));
						zlc = Arith.add(zlc, Double.valueOf(sumList.get(j)[1].toString()));
						zsh = Arith.add(zsh, Double.valueOf(sumList.get(j)[2].toString()));
					}
//					jzl = Arith.sub(jzl, zsh);
					// 保留两位小数
					DecimalFormat df = new DecimalFormat("#.00");
					Double zyl = 0.0;
					Double nextJzyl = 0.0;
					// 保存已经计算过的车辆，相同车辆编号的车不在计算
					newMap.put("nbbm" + ylb.getNbbm(), ylb.getNbbm());

					// 查询指定车辆，设置进、存、耗油量
					map.remove("nbbm_eq");
					map.put("nbbm_eq", ylb.getNbbm());
					map.put("xlbm_like", ylb.getXlbm());
//					Iterator<Ylb> iterator2 = repository
//							.findAll(new CustomerSpecs<Ylb>(map), new Sort(Direction.ASC, "jcsx")).iterator();
					double czyl=0.0;
					for (int j = 0; j < iterator2.size(); j++) {
						Ylb t = iterator2.get(j);
						if(t.getNbbm().equals(ylb.getNbbm())){
							if (t.getJcsx() == 1) {
								// 进场等于出场的操作 既 最后进场存油量等于第一次的出场存油量
//								Double yl = t.getCzyl();
//								Double jcyl = t.getCzyl();
								czyl = t.getCzyl();
								zyl =jzl;
								Double yh=0.0;
								if(zlc>0 ){
									 yh = Double.parseDouble(df.format(zyl * (t.getZlc() / zlc)));
								}
								nextJzyl =Arith.sub( Arith.add(t.getJzl(), t.getCzyl()),yh);
//								nextJzyl =Arith.sub( Arith.add(Arith.sub(t.getJzl(),t.getSh()), t.getCzyl()),yh);
								//把进场油量的小数和整数分别取出
//								int ylxs=(int) nextJzyl; 10.6--11  10.3--10
								if(zlc>0 && t.getZlc()>0){
									long l=Math.round(nextJzyl);
									double ylxs=l*100/100;
//									nextJzyl = Arith.add(nextJzyl,Arith.sub(nextJzyl,ylxs));
									yh=Arith.add(yh, Arith.sub(nextJzyl,ylxs));
									t.setYh(yh);
									t.setJzyl(ylxs);
									nextJzyl=ylxs;
								}else{
									t.setYh(yh);
									t.setJzyl(nextJzyl);
								}
							} else {
								t.setCzyl(nextJzyl);
								Double yh=0.0;
								if(zlc>0){
									yh= Double.parseDouble(df.format(zyl * (t.getZlc() / zlc)));
								}
								nextJzyl =Arith.sub( Arith.add(t.getJzl(),nextJzyl),yh);
//								nextJzyl =Arith.sub( Arith.add(Arith.sub(t.getJzl(),t.getSh()),nextJzyl),yh);
								if(zlc>0 && t.getZlc()>0){
									long l=0l;
									double ylxs=0.0;
									if(j==iterator2.size()-1){
										ylxs=czyl;
									}else{
										if(iterator2.get(j+1).getNbbm().equals(t.getNbbm())){
											l=Math.round(nextJzyl);
											ylxs=l*100/100;
										}else{
											ylxs=czyl;
										}
										
									}
									yh=Arith.add(yh, Arith.sub(nextJzyl,ylxs));
//									nextJzyl = Arith.add(nextJzyl,Arith.sub(nextJzyl,ylxs));
									
									t.setYh(yh);
									t.setJzyl(ylxs);
									nextJzyl=ylxs;
								}else{
									t.setYh(yh);
									t.setJzyl(nextJzyl);
								}
							}
							if(t.getJzyl()<0){
								t.setJzyl(0.0);
							}
							if(t.getCzyl()<0){
								t.setCzyl(0.0);
							}
							if(t.getYh()<0){
								t.setYh(0.0);
							}
							if(t.getSh()<0){
								t.setSh(0.0);
							}
							repository.save(t);
						}
						map2.put("status", ResponseCode.SUCCESS);
					}
				}
			}
			
			SysUser user = SecurityUtils.getCurrentUser();
			Nylog nylog=new Nylog();
			nylog.setCreatedate(new Date());
			nylog.setCzmc("进场等于出场");
			nylog.setNylx("油");
			nylog.setUserid(user.getUserName());
			nylog.setUsername(user.getName());
			nylog.setCxtj(rq+"-"+gsbm+"-"+fgsbm+"-"+xlbm+"-"+nbbm+"-"+sxtj);
			
			nylogRepository.save(nylog);
		} catch (Exception e) {
			map2.put("status", ResponseCode.ERROR);
			logger.error("save erro.", e);
			throw e; 
		}
		return map2;
	}
	

	/**
	 * 核对，有加注没里程
	 * @param map
	 * @return
	 */
	@Transactional
	@Override
	public Map<String, Object> checkYl(Map<String, Object> map) throws Exception{
		Map<String, Object> newMap=new HashMap<String,Object>();
//		String xlbm="";
//		if(map.get("xlbm_like")!=null){
//			xlbm=map.get("xlbm_like").toString();
//		}
		// TODO Auto-generated method stub
		
		List<Cars> carsList = carsRepository.findCars();
		Map<String, String> carsMap = new HashMap<String, String>();
		for (int i = 0; i < carsList.size(); i++) {
			Cars c = carsList.get(i);
			carsMap.put(c.getInsideCode(), c.getBrancheCompanyCode()==null?"":c.getBrancheCompanyCode());
		}
		
		try{
			//获取车辆存油信息
			
			String rq=map.get("rq").toString();
			String xlbm="";
			if(map.get("xlbm_like")!=null){
				xlbm= map.get("xlbm_like").toString().trim();
			}
			String gsbm="";
			if(map.get("ssgsdm_like")!=null){
				gsbm=map.get("ssgsdm_like").toString();
			}
			String fgsbm="";
			if(map.get("fgsdm_like")!=null){
				fgsbm=map.get("fgsdm_like").toString();
			}
			String nbbm="";
			if(map.get("nbbm_eq")!=null){
				nbbm=map.get("nbbm_eq").toString();
			}
//			List<Ylb> ylListBe=repository.obtainYlbefore(rq, gsbm, "", xlbm, nbbm);
			List<Ylb> ylListBe=this.listByRqJcsx(rq, gsbm, fgsbm, "", nbbm);
			List<Ylb> ylbList=this.listOrderBy(rq,gsbm,fgsbm,xlbm,nbbm,"nbbm");
//					repository.obtainYl(rq,gsbm,fgsbm,xlbm,nbbm,"nbbm");
//			List<Ylxxb> ylxxbList=ylxxbRepository.obtainYlxx(rq,0,gsbm);
			String sql="select * from bsth_c_ylxxb where yyrq='"+rq+"' "
					+ " and gsdm ='"+gsbm+"' and nylx ='0' and nbbm "
					+ " not in ( select nbbm  from bsth_c_ylb "
					+ " where  rq='"+rq+"' "
					+ " and ssgsdm='"+gsbm+"' and fgsdm ='"+fgsbm+"')"
					+ " and nbbm in (select inside_code from "
					+ " bsth_c_cars where business_code ='"+gsbm+"' "
					+ " and branche_company_code='"+fgsbm+"')";
			
			List<Ylxxb> ylxxbList=jdbcTemplate.query(sql,  
			        new RowMapper<Ylxxb>(){  
	            @Override  
	            public Ylxxb  mapRow(ResultSet rs, int rowNum) throws SQLException {  
	            	Ylxxb s  = new Ylxxb(); 
	            	s.setId(rs.getInt("id"));
	            	s.setYyrq(rs.getDate("yyrq"));
	            	s.setNbbm(rs.getString("nbbm"));
	            	s.setGsdm(rs.getString("gsdm"));
	            	s.setFgsdm(rs.getString("fgsdm"));
	            	s.setJsy(rs.getString("jsy"));
	            	s.setJzl(rs.getDouble("jzl"));
	            	s.setStationid(rs.getString("stationid"));
	            	s.setNylx(rs.getInt("nylx"));
	            	s.setJyggh(rs.getString("jyggh"));
	            	s.setYj(rs.getDouble("yj"));
//	            	s.setLdgh(rs.getString("ldgh"));
	            	s.setBz(rs.getString("bz"));
	                return s;  
	            }  
			});  
			Map<String, Object> m=new HashMap<String,Object>();
			for (int i = 0; i < ylxxbList.size(); i++) {
				Boolean fage=false;
				Ylxxb y1=ylxxbList.get(i);
				if(m.get(y1.getNbbm())==null){
					Line line=BasicData.nbbm2LineMap.get(y1.getNbbm());
					if(null !=line){
						if(!xlbm.equals("")){
							if(line.getLineCode().equals(xlbm)){
								fage=true;
							}
						}else{
							fage=true;
						}
					}
					
					if(fage){
						Ylb t=new Ylb();
						t.setNbbm(y1.getNbbm());
						t.setRq(y1.getYyrq());
						t.setJsy(y1.getJsy());
						t.setJname(BasicData.allPerson.get(y1.getGsdm()+"-"+y1.getJsy()));
						t.setJzl(y1.getJzl());
						t.setSsgsdm(y1.getGsdm());
						String fgsdm="";
						if(null !=carsMap.get(y1.getNbbm())){
							fgsdm=carsMap.get(y1.getNbbm());
						}
						t.setFgsdm(fgsdm);
						t.setJcsx(1);
						if(null !=line){
							t.setXlbm(line.getLineCode());
						}else{
							t.setXlbm("");
						}
						t.setJcsx(1);
						boolean status=true;
						for (int j = 0; j < ylListBe.size(); j++) {
							Ylb b=ylListBe.get(j);
							if(b.getNbbm().equals(y1.getNbbm())){
								t.setCzyl(b.getJzyl());
								status=false;
								break;
							}
						}
						if(status){
							t.setCzyl(0.0);
						}
						t.setJzyl(Arith.add(t.getJzl(), t.getCzyl()));
						t.setYh(0.0);
						 if(!(t.getSsgsdm().equals("") || t.getFgsdm().equals(""))){
							 t.setCreatetime(new Date());
							 try {
								 repository.save(t);
								 m.put(t.getName(), t.getName());
							} catch (Exception e) {
								// TODO: handle exception
								if(e.getMessage().indexOf("PK_YLB_UK")>0){
									newMap.put("fage", "存在相同数据,数据已经过滤");
									logger.info("核对有存油没里程：存在相同数据,数据已经过滤");
								}
							}
						}
					}
				}
			}
			
			SysUser user = SecurityUtils.getCurrentUser();
			Nylog nylog=new Nylog();
			nylog.setCreatedate(new Date());
			nylog.setCzmc("核对加注量");
			nylog.setNylx("油");
			nylog.setUserid(user.getUserName());
			nylog.setUsername(user.getName());
			nylog.setCxtj(rq+"-"+gsbm+"-"+fgsbm+"-"+xlbm+"-"+nbbm+"-");
			nylogRepository.save(nylog);
			newMap.put("status", ResponseCode.SUCCESS);
		}catch(Exception e){
			newMap.put("status", ResponseCode.ERROR);
			logger.error("save erro.", e);
			throw e;
		}
		
		return newMap;
	}


	@Override
	public List<Map<String, Object>> oilListMonth(Map<String, Object> map) {
		SimpleDateFormat sdfMonth = new SimpleDateFormat("yyyy-MM-dd"),
				sdfSimple = new SimpleDateFormat("yyyyMMdd");
		
		String type=map.get("type").toString();
		String date=map.get("date").toString().trim();
		String gsdm=map.get("gsdm").toString();
		String fgsdm=map.get("fgsdm").toString();
		String date2=date.substring(0, 8)+"01";
		String lineStr="";
		String line =map.get("line").toString().trim();
		/*if(line !=null && !line.equals("")){
			lineStr =" and xlbm= '"+ line +"'";
		}else{
			lineStr =" and ssgsdm='"+gsdm+"' and fgsdm ='"+fgsdm+"' ";
		}
		String sql="select a.nbbm,a.rq,a.jzyl from (" +
				" select x.nbbm,max(x.rq) as rq,max(x.jcsx) as jcsx from "
				+ "(select nbbm,rq,max(jcsx)  as jcsx from bsth_c_ylb  where rq between  '"
				+ date2 +"'  and '" + date+"' "+lineStr
				+ " group by   nbbm,rq)  x group by x.nbbm ) b" 
				+ "	left join (select nbbm,rq,jzyl,jcsx  FROM   bsth_c_ylb  "
				+ "	where rq between  '"
				+ date2 +"'  and '" + date+"' "+lineStr
				+ ") a "
				+ "	on a.nbbm =b.nbbm and a.jcsx=b.jcsx and a.rq=b.rq "
				+ " where a.nbbm is not null order by a.nbbm";
		
		// TODO Auto-generated method stub
		List<Ylb> list =jdbcTemplate.query(sql,  
			        new RowMapper<Ylb>(){  
			            @Override  
			            public Ylb  mapRow(ResultSet rs, int rowNum) throws SQLException {  
		            		Ylb s  = new Ylb(); 
			            	s.setNbbm(rs.getString("nbbm"));
			            	s.setRq(rs.getDate("rq"));
			            	s.setJzyl(rs.getDouble("jzyl"));
			                return s;  
			            }  
					});  */
		
		double qtyy=0.0;//其他用油
		double cdyy=0.0;//车队用油
		double byyy=0.0;//保养用油
		double cjxx=0.0;//车间小修
		double cjgb=0.0;//车间高保
		double fyyyhj=0.0;//非营运用油合计
		List<Ylb> listYlb=repository.listByMonthJcsx(date2, date, gsdm, fgsdm, line);
		
		Map<String, Object> ms=new HashMap<String,Object>();
		List<Ylb> list=new ArrayList<Ylb>();
		for (int i = 0; i < listYlb.size(); i++) {
			Ylb t=listYlb.get(i);
			fyyyhj =Arith.add(fyyyhj, t.getSh());
			if(t.getShyy()==null){
				qtyy=Arith.add(qtyy, t.getSh());
			}else{
				if(t.getShyy().equals("6")){
					cdyy=Arith.add(cdyy, t.getSh());
				}else if(t.getShyy().equals("2")){
					byyy=Arith.add(byyy, t.getSh());
				}else if(t.getShyy().equals("7")){
					cjxx=Arith.add(cjxx, t.getSh());
				}else if(t.getShyy().equals("8")){
					cjgb=Arith.add(cjgb, t.getSh());
				}else{
					qtyy=Arith.add(qtyy, t.getSh());
				}
			}
			if(ms.get(t.getNbbm())==null){
				ms.put(t.getNbbm(), t.getNbbm());
				list.add(t);
			}
		}
		
		List<Map<String, Object>> mapList = new ArrayList<Map<String, Object>>();
		int  size = 0;
		Map<String, Object> m_ = new HashMap<String, Object>();
		double ycyhj=0.0;
		for(Ylb ylb : list){
			ycyhj=Arith.add(ycyhj, ylb.getJzyl());
			int x=size%3;
			if(x==0 && size>0){
				mapList.add(m_);
        		m_ = new HashMap<String, Object>();
        	}
			size++;
			m_.put("xh"+x, size);
			m_.put("nbbm"+x, ylb.getNbbm()!=null?ylb.getNbbm():"");
			m_.put("rq"+x, ylb.getRq()!=null?sdfMonth.format(ylb.getRq()):"");
			m_.put("jzyl"+x, ylb.getJzyl()!=null?ylb.getJzyl():"");
			
		}
		 if(m_.get("nbbm0")!=null){
	        	if(m_.get("nbbm1")==null){
	        		m_.put("xh1", "");
	        		m_.put("nbbm1" , "");
	        		m_.put("rq1" , "");
	        		m_.put("jzyl1" , "");
	        	}
	        	if(m_.get("nbbm2")==null){
	        		m_.put("xh2", "");
	        		m_.put("nbbm2" , "");
	        		m_.put("rq2" , "");
	        		m_.put("jzyl2" , "");
	        	}
	        	mapList.add(m_);
	        }

		if(type != null && type.equals("export")){
			List<Iterator<?>> listI = new ArrayList<Iterator<?>>();
			Map<String, Object> m = new HashMap<String, Object>();
			m.put("ycyhj", ycyhj);
			m.put("qtyy", qtyy);
			m.put("cdyy", cdyy);
			m.put("byyy", byyy);
			m.put("cjxx", cjxx);
			m.put("cjgb", cjgb);
			m.put("fyyyhj", fyyyhj);
			ReportUtils ee = new ReportUtils();
			try {
				String lineName = "";
				if(map.containsKey("lineName"))
					lineName = map.get("lineName").toString();
				listI.add(mapList.iterator());
				String path = this.getClass().getResource("/").getPath()+"static/pages/forms/";
				ee.excelReplace(listI, new Object[] { m }, path+"mould/oilListMonth.xls",
						path+"export/" + sdfSimple.format(sdfMonth.parse(date))
						+ "-" + lineName + "-月存油报表.xls");
			} catch (Exception e) {
				// TODO: handle exception
				e.printStackTrace();
			}
		}else{
			 m_=new HashMap<String,Object>();
			 m_.put("xh0", "99");
			 m_.put("nbbm0", "存油合计:"+ycyhj +" 非营运用油： 其他用油:"+qtyy +",车队:"+cdyy+",保养用油:"+byyy
					 +",车间(小修):"+cjxx+",车间(高保):"+cjgb+",非营运用油合计:"+fyyyhj);
			 mapList.add(m_);
		}
		
		return mapList;
	}

	@Override
	public StringBuffer checkNbmmNum(String rq, String gsbm, String fgsbm, String xlbm,String nbbm,int lx) {
		StringBuffer stringList =new StringBuffer();
		List<Object[]> objectList=repository.checkNbmmNum(rq, gsbm, fgsbm, xlbm,nbbm);
		for (int i = 0; i < objectList.size(); i++) {
			String clbm=objectList.get(i)[0].toString()+",";
			int cs=Integer.parseInt(objectList.get(i)[1].toString());
			//一车一单
			if(lx==1){
				if(cs==1){
					stringList.append(clbm);
				}
			}
			//一车多单
			if(lx==2){
				if(cs>1){
					stringList.append(clbm);
				}
				
			}
		}
		return stringList;
	}
	
	

	@Override
	public Map<String, Object> sumYlb(Map<String, Object> map) {
		// TODO Auto-generated method stub
		List<String> stringList=new ArrayList<String>();
		String rq=map.get("rq").toString();
		String gsbm=map.get("ssgsdm_like").toString();
		String fgsbm=map.get("fgsdm_like").toString();
		String xlbm=map.get("xlbm_like").toString().trim();
		String nbbm=map.get("nbbm_eq").toString();
		String sxtj=map.get("sxtj").toString();
		String type=map.get("type").toString();
		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		List<Object[]> sumYlbList=new ArrayList<Object[]>();
		try {
		if(nbbm.trim()!=""){
			stringList.add(nbbm);
		}else{
			if(!sxtj.equals("0")){
				List<Object[]> objectLists;
				if(sxtj.equals("3")){
					//有加油没里程
					objectLists=repository.checkNbmmYl(rq, gsbm, fgsbm, xlbm, nbbm);
					for (int i = 0; i < objectLists.size(); i++) {
						String clbm=objectLists.get(i)[0].toString();
						double jzl=Double.parseDouble(objectLists.get(i)[1].toString());
						double zlc=Double.parseDouble(objectLists.get(i)[2].toString());
						if(jzl>0 && zlc<=0){
							stringList.add(clbm);
						}
						
					}
					
				}else if(sxtj.equals("4")){
					//有里程没加油
					objectLists=repository.checkNbmmYl(rq, gsbm, fgsbm, xlbm, nbbm);
					for (int i = 0; i < objectLists.size(); i++) {
						String clbm=objectLists.get(i)[0].toString();
						double jzl=Double.parseDouble(objectLists.get(i)[1].toString());
						double zlc=Double.parseDouble(objectLists.get(i)[2].toString());
						if(zlc>0 && jzl<=0){
							stringList.add(clbm);
						}
						
					}
				}else{
					objectLists=repository.checkNbmmNum(rq, gsbm, fgsbm, xlbm,nbbm);
					for (int i = 0; i < objectLists.size(); i++) {
						String clbm=objectLists.get(i)[0].toString();
						int cs=Integer.parseInt(objectLists.get(i)[1].toString());
						//一车一单
					
						if(sxtj.equals("1")){
							if(cs==1){
								stringList.add(clbm);
							}
						}
						//一车多单
						if(sxtj.equals("2")){
							if(cs>1){
								stringList.add(clbm);
							}
						}
					}
				}
			}
		}
		if(sxtj.equals("0")){
			sumYlbList=repository.sumYlb2(rq, gsbm, fgsbm, xlbm,nbbm);
		}else{
			if(stringList.size()>0){
				
//				String strings[]=new String[stringList.size()];
//					for(int i=0;i<stringList.size();i++){
//					strings[i]=stringList.get(i);
//				}
				if (type.equals("1"))
					sumYlbList=repository.sumYlb(rq, gsbm, fgsbm, xlbm, stringList);
				else
					sumYlbList=repository.sumYlb_s(sdf.parse(rq+" 00:00:00"), gsbm, fgsbm, xlbm, stringList);
			}
//			else{
//				sumYlbList=repository.sumYlb2(rq, gsbm, fgsbm, xlbm, nbbm);
//			}
			
		}
		} catch (ParseException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		Double jzl=0.0,yh=0.0,sh=0.0; 
		for (int i = 0; i < sumYlbList.size(); i++) {
			jzl = Arith.add(jzl, Double.valueOf(sumYlbList.get(i)[0].toString()));
			yh = Arith.add(yh, Double.valueOf(sumYlbList.get(i)[1].toString()));
			sh = Arith.add(sh, Double.valueOf(sumYlbList.get(i)[2].toString()));
		}
		
		Map<String, Object> sumMap=new HashMap<String,Object>();
		sumMap.put("jzl", jzl);
		sumMap.put("yh", yh);
		sumMap.put("sh", sh);
		
//		String sql="select sum(jzl),sum(yh),sum(sh) from bsth_c_ylb "
//				+ " where to_days('"+map.get("rq").toString()+"')=to_days(rq)  "
//				+ " and ssgsdm like '%"+map.get("ssgsdm_like").toString()+"%' "
//				+ " and fgsdm like '%"+map.get("fgsdm_like").toString()+"%' "
//				+ " and xlbm like '%"+map.get("xlbm_like").toString()+ "%'"
//				+ " and nbbm like '%"+map.get("nbbm_eq").toString()+"% '";
//		if(map.get("nbbm_in")!=null){
////			sql +=" and nbbm in ("
//		}
		return sumMap;
	}

	
	
	@Override
	public List<Ylb> listYlb(Map<String, Object> map) {
		// TODO Auto-generated method stub
		List<Ylb> listYlb = new ArrayList<Ylb>();
		try {
			List<String> stringList = new ArrayList<String>();
			String rq = map.get("rq").toString();
			String gsbm = map.get("ssgsdm_like").toString();
			String fgsbm = map.get("fgsdm_like").toString();
			String xlbm = map.get("xlbm_like").toString().trim();
			String nbbm = map.get("nbbm_eq").toString();
			String sxtj = map.get("sxtj").toString();
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			String type = map.get("type").toString();
			if (nbbm.trim() != "") {
				stringList.add(nbbm);
				List<Object[]> objectLists = repository.checkNbmmNum(rq, gsbm, fgsbm, xlbm, nbbm);
				if (objectLists.size() > 0) {
					int cs = Integer.parseInt(objectLists.get(0)[1].toString());
					if (sxtj.equals("1")) {
						if (cs == 1) {
							if (type.equals("1"))
								listYlb = repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
							else
								listYlb = repository.listYlb_s(sdf.parse(rq+" 00:00:00"), gsbm, fgsbm, xlbm, stringList);

						}
					} else if (sxtj.equals("2")) {
						if (cs > 1) {
							if (type.equals("1"))
								listYlb = repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
							else
								listYlb = repository.listYlb_s(sdf.parse(rq+" 00:00:00"), gsbm, fgsbm, xlbm, stringList);
						}
					} else {
						if (type.equals("1"))
							listYlb = repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
						else
							listYlb = repository.listYlb_s(sdf.parse(rq+" 00:00:00"), gsbm, fgsbm, xlbm, stringList);
					}
				}

			} else {
				// 全部
				if (sxtj.equals("0")) {
					List<Object[]> objectLists = repository.checkNbmmNum(rq, gsbm, fgsbm, xlbm, nbbm);
					for (int i = 0; i < objectLists.size(); i++) {
						String clbm = objectLists.get(i)[0].toString();
						stringList.add(clbm);
					}
					if (stringList.size() > 0) {
						if (type.equals("1"))
							listYlb = repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
						else
							listYlb = repository.listYlb_s(sdf.parse(rq+" 00:00:00"), gsbm, fgsbm, xlbm, stringList);
					}
				}else if(sxtj.equals("5")){
					List<Object[]> objectLists = repository.checkNbmmFgs(rq, gsbm);
					for (int i = 0; i < objectLists.size(); i++) {
						String clbm =objectLists.get(i)[0].toString();
						stringList.add(clbm);
					}
					
					if (stringList.size() > 0) {
						if (type.equals("1"))
							listYlb = repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
						else
							listYlb = repository.listYlb_s(sdf.parse(rq+" 00:00:00"), gsbm, fgsbm, xlbm, stringList);
					}
				} else {
					List<Object[]> objectLists;
					if (sxtj.equals("3")) {
						// 有加油没里程
						objectLists = repository.checkNbmmYl(rq, gsbm, fgsbm, xlbm, nbbm);
						for (int i = 0; i < objectLists.size(); i++) {
							String clbm = objectLists.get(i)[0].toString();
							double jzl = Double.parseDouble(objectLists.get(i)[1].toString());
							double zlc = Double.parseDouble(objectLists.get(i)[2].toString());
							if (jzl > 0 && zlc <= 0) {
								stringList.add(clbm);
							}

						}

					} else if (sxtj.equals("4")) {
						// 有里程没加油
						objectLists = repository.checkNbmmYl(rq, gsbm, fgsbm, xlbm, nbbm);
						for (int i = 0; i < objectLists.size(); i++) {
							String clbm = objectLists.get(i)[0].toString();
							double jzl = Double.parseDouble(objectLists.get(i)[1].toString());
							double zlc = Double.parseDouble(objectLists.get(i)[2].toString());
							if (zlc > 0 && jzl <= 0) {
								stringList.add(clbm);
							}

						}
					} else {
						objectLists = repository.checkNbmmNum(rq, gsbm, fgsbm, xlbm, nbbm);
						for (int i = 0; i < objectLists.size(); i++) {
							String clbm = objectLists.get(i)[0].toString();
							int cs = Integer.parseInt(objectLists.get(i)[1].toString());
							// 一车一单
							if (sxtj.equals("1")) {
								if (cs == 1) {
									stringList.add(clbm);
								}
							}
							// 一车多单
							if (sxtj.equals("2")) {
								if (cs > 1) {
									stringList.add(clbm);
								}
							}
						}
					}

					if (stringList.size() > 0) {
						if (type.equals("1"))
							listYlb = repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
						else
							listYlb = repository.listYlb_s(sdf.parse(rq+" 00:00:00"), gsbm, fgsbm, xlbm, stringList);
					}
				}
			}
		} catch (ParseException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return listYlb;
	}
	
	@Transactional  
	@Override
	public Map<String, Object> saveYlbList(Map<String, Object> map) throws Exception {
		// TODO Auto-generated method stub
		Map<String, Object> newMap=new HashMap<String,Object>();
		try{
		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
		String json =StringEscapeUtils.unescapeHtml4(map.get("ylbList").toString());
		JSONArray jsonArray=JSONArray.parseArray(json);
		JSONObject jsonObject;
		// 获取车辆存油信息
		List<Cyl> cylList = cylRepository.obtainCyl("","");
		for (int i = 0; i < jsonArray.size(); i++) {
//			Ylb t=new Ylb();
			jsonObject=jsonArray.getJSONObject(i);
			double czyl = jsonObject.getDoubleValue("czyl");
			double jzl =jsonObject.getDoubleValue("jzl");
			double jzyl =jsonObject.getDoubleValue("jzyl");
			double sh  =jsonObject.getDoubleValue("sh");
			String shyy =jsonObject.getString("shyy");
			double ns = jsonObject.getDoubleValue("ns");
			String rylx =jsonObject.getString("rylx");
			int yhlx =jsonObject.getIntValue("yhlx");
			Integer id =jsonObject.getInteger("id");
			String nbbm =jsonObject.getString("nbbm");
			String rq=jsonObject.getString("rq");
			double yh = Arith.sub(Arith.add(czyl, jzl),jzyl);
			if(yh<0){
				yh=0.0;
			}
			repository.ylbUpdate(id, czyl, jzyl, yh, sh, shyy, ns, rylx,yhlx);
		}
//		List<Map<String, Object>> list=(List<Map<String, Object>>) map.get("ylbList");
		SysUser user = SecurityUtils.getCurrentUser();
		Nylog nylog=new Nylog();
		nylog.setCreatedate(new Date());
		nylog.setCzmc("保存全部");
		nylog.setNylx("油");
		nylog.setUserid(user.getUserName());
		nylog.setUsername(user.getName());
		nylog.setCxtj("");
		nylogRepository.save(nylog);
		newMap.put("status", ResponseCode.SUCCESS);
		}catch(Exception e){
			newMap.put("status", ResponseCode.ERROR);
			logger.error("save erro.", e);
			throw e;
		}
		return newMap;
	}
	
	/**
	 * 拆分
	 */
	@Transactional  
	@Override
	public Map<String, Object> sort(Map<String, Object> map) throws Exception{
		// TODO Auto-generated method stub
		Map<String, Object> newMap = new HashMap<String, Object>();
		SimpleDateFormat sdf =new SimpleDateFormat("yyyy-MM-dd");
		
		try {
			List<Cyl> cylList = cylRepository.findAll(new CustomerSpecs<Cyl>(newMap));
			String json =StringEscapeUtils.unescapeHtml4(map.get("ylbList").toString());
			String fgsbm="999";
			if(map.get("fgsbm")!=null){
				fgsbm=map.get("fgsbm").toString();
			}
			JSONArray jsonArray=JSONArray.parseArray(json);
			JSONObject jsonObject;
			for (int x = 0; x < jsonArray.size(); x++) {
				jsonObject=jsonArray.getJSONObject(x);
				Double yl =jsonObject.getDoubleValue("jzyl");
				Double sh  =jsonObject.getDoubleValue("sh");
				String shyy =jsonObject.getString("shyy");
				Double ns = jsonObject.getDoubleValue("ns");
				String rylx =jsonObject.getString("rylx");
				Integer id =jsonObject.getInteger("id");
				Ylb ylb = repository.findById(id).get();
				String nbbm_eq = ylb.getNbbm();
				Date rq_eq = ylb.getRq();
				// 得到一天总的加油和里程（根据车，时间）
				List<Object[]>  sumList=new ArrayList<Object[]>();
				if(fgsbm.equals(""))
					sumList = repository.sumLcYl(nbbm_eq, rq_eq,"",ylb.getSsgsdm(),fgsbm);
				else
					sumList = repository.sumLcYl(nbbm_eq, rq_eq,"",ylb.getSsgsdm(),ylb.getFgsdm());

				// 保存总的加油量
				Double jzl = 0.0;
				// 保存总的里程
				Double zlc = 0.0;
				//保存总的损耗
				Double zsh = 0.0;
				for (int j = 0; j < sumList.size(); j++) {
					jzl = Arith.add(jzl, Double.valueOf(sumList.get(j)[0].toString()));
					zlc = Arith.add(zlc, Double.valueOf(sumList.get(j)[1].toString()));
					zsh = Arith.add(zsh, Double.valueOf(sumList.get(j)[2].toString()));
				}
//				jzl = Arith.sub(jzl, zsh);
				//新的 损耗不等于 旧的损耗 总损耗从新算
				/*if(Arith.sub(ylb.getSh(),sh )!=0){
					zsh =Arith.add(Arith.sub(zsh, ylb.getSh()), sh);
					jzl =Arith.sub(jzl, zsh);
				}else{
					jzl =Arith.sub(jzl, zsh);
				}*/
				map.put("nbbm_eq", nbbm_eq);
				map.put("rq_eq", rq_eq);
				List<Ylb> iterator2=null;
				if(fgsbm.equals(""))
					iterator2=this.listOrderBy(sdf.format(rq_eq),ylb.getSsgsdm(),fgsbm,"",
							ylb.getNbbm(),"jcsx");
				else
					iterator2=this.listOrderBy(sdf.format(rq_eq),ylb.getSsgsdm(),ylb.getFgsdm(),"",
							ylb.getNbbm(),"jcsx");
					
//						repository.obtainYl(sdf.format(rq_eq),ylb.getSsgsdm(),ylb.getFgsdm(),"",
//						ylb.getNbbm(),"jcsx");
				DecimalFormat df = new DecimalFormat("#.00");
				Double zyl = 0.0;
				Double nextJzyl = 0.0;
				// 车的，进，出油量及耗油
				double czyl=0.0;
				for (int i = 0; i < iterator2.size(); i++) {
					Ylb t = iterator2.get(i);
					if (t.getJcsx() == 1) {
						if(t.getId()==id){
							t.setSh(sh);
							t.setShyy(shyy);
						}
						czyl=t.getCzyl();
						Double jcyl = t.getCzyl();
						zyl = Arith.sub(Arith.add(jcyl, jzl), yl);
						Double yh = 0.0;
						if (zlc > 0 && t.getZlc() > 0) {
							yh = Double.parseDouble(df.format(zyl * (t.getZlc() / zlc)));
						}
						nextJzyl =Arith.sub(Arith.add(t.getJzl(), t.getCzyl()), yh);
//						nextJzyl =Arith.sub(Arith.add(t.getJzl(), t.getCzyl()), Arith.add(yh, t.getSh()));
						if(zlc>0 && t.getZlc() > 0){
							long l=Math.round(nextJzyl);
							double ylxs=l*100/100;
//								nextJzyl = Arith.add(nextJzyl,Arith.sub(nextJzyl,ylxs));
							yh=Arith.add(yh, Arith.sub(nextJzyl,ylxs));
							t.setYh(yh);
							t.setJzyl(ylxs);
							nextJzyl=ylxs;
						}else{
							t.setYh(yh);
							t.setJzyl(nextJzyl);
						}
					} else {
						if(t.getId()==id){
							t.setSh(sh);
							t.setShyy(shyy);
						}
							t.setCzyl(nextJzyl);
							Double yh =0.0;
							if (t.getZlc() >= 0) {
								yh= Double.parseDouble(df.format(zyl * (t.getZlc() / zlc)));
							}
//							nextJzyl = Arith.sub(Arith.add(t.getJzl(), nextJzyl), Arith.add(yh, t.getSh()));
							nextJzyl = Arith.sub(Arith.add(t.getJzl(), nextJzyl), yh);
							if(zlc>0 && t.getZlc() >0){
								long l=0l;
								double ylxs=0.0;
								if(i==iterator2.size()-1){
									ylxs=yl;
								}else{
									l=Math.round(nextJzyl);
									ylxs=l*100/100;
								}
								yh=Arith.add(yh, Arith.sub(nextJzyl,ylxs));
								t.setYh(yh);
								t.setJzyl(ylxs);
								nextJzyl=ylxs;
							}else{
								t.setYh(yh);
								t.setJzyl(nextJzyl);
							}
					}
					if(t.getJzyl()<0){
						t.setJzyl(0.0);
					}
					if(t.getCzyl()<0){
						t.setCzyl(0.0);
					}
					if(t.getYh()<0){
						t.setYh(0.0);
					}
					if(t.getSh()<0){
						t.setSh(0.0);
					}
					repository.save(t);
				}
				newMap.put("status", ResponseCode.SUCCESS);
			}
			
			SysUser user = SecurityUtils.getCurrentUser();
			Nylog nylog=new Nylog();
			nylog.setCreatedate(new Date());
			nylog.setCzmc("拆分");
			nylog.setNylx("油");
			nylog.setUserid(user.getUserName());
			nylog.setUsername(user.getName());
			nylog.setCxtj("");
			nylogRepository.save(nylog);
		} catch (Exception e) {
			newMap.put("status", ResponseCode.ERROR);
			logger.error("save erro.", e);
			throw e; 
		}
		return newMap;
	}

	
	@Override
	public String checkJsy(Map<String, Object> map) {
		// TODO Auto-generated method stub
		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
		String rq=map.get("date").toString();
		String nbbm=map.get("nbbm").toString();
		String jsy =map.get("jsy").toString();
		String xlbm=map.get("xlbm").toString();
		List<Ylb> list= repository.checkYlb(rq, nbbm, jsy,xlbm,"nbbm");
		String type="1";
		if(list.size()>0){
			type="0";
		}
		return type;
	}
	
	@Override
	public String checkDate(Map<String, Object> map) {
		// TODO Auto-generated method stub
		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
		
		int days = SystemParam.getHistorySaveDays();
		
		String rq=map.get("rq").toString();
		String gsbm=map.get("ssgsdm_like").toString();
		String type="1";
		if(gsbm.equals("26") && modify_rights_close){	//南汇公司的修改权限
			Date date=new Date();
			try {
				long day2=date.getTime();
				long day1=sdf.parse(rq).getTime();
				long d = (day2 - day1) / (24*3600*1000);  
			    if(d >= days){
			    	type="2";
			    }
			} catch (ParseException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if(modify_rights_close_pj){	//浦交规定的修改权限，今天昨天前天三天可修改
			Date date=new Date();
			try {
				long day2=date.getTime();
				long day1=sdf.parse(rq).getTime();
				long d = (day2 - day1) / (24*3600*1000);  
			    if(d > days){
			    	type="2";
			    }
			} catch (ParseException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return type;
	}
	
	@Override
	public String getModifyRights(){
		return modify_rights_close?"关闭":"打开";	//打开是可编辑(false)，关闭是不可编辑(true)
	}
	
	@Override
	public String modifyRightsChange(){
		if(modify_rights_close){
			modify_rights_close = false;
		} else {
			modify_rights_close = true;
		}
		return modify_rights_close?"权限关闭":"权限打开";
	}
	
	@Override
	public String getModifyRightsPj(){
		return modify_rights_close_pj?"关闭":"打开";
	}
	
	@Override
	public String modifyRightsChangePj(){
		if(modify_rights_close_pj){
			modify_rights_close_pj = false;
		} else {
			modify_rights_close_pj = true;
		}
		return modify_rights_close_pj?"权限关闭":"权限打开";
	}
	
	

	@Override
	public Map<String, Object> saveYlb(Ylb t) {
		Map<String, Object> map = new HashMap<>();
		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
		String rq=sdf.format(t.getRq());
		String gsdm=t.getSsgsdm();
		String fgsdm=t.getFgsdm();
		String xlbm=t.getXlbm();
		String jhsj=t.getJhsj();
		String jsy=t.getJsy();
		String nbbm=t.getNbbm();
		t.setCreatetime(new Date());
		String[] jhsjStr = jhsj.split(":");
		long fcsjL= Long.parseLong(jhsjStr[0])*60+Long.parseLong(jhsjStr[1]);
		List<Ylb> list=this.listOrderBy(rq, gsdm, fgsdm, xlbm, nbbm, "jhsj");
//				repository.obtainYl(rq, gsdm, fgsdm, xlbm, nbbm, "jhsj");
		int jcsx=1;
		if(list.size()>0){
			for (int i = 0; i < list.size(); i++) {
				Ylb y=list.get(i);
				String[] fcsjStr = y.getJhsj().split(":");
				long fcsj=Long.parseLong(fcsjStr[0])*60+Long.parseLong(fcsjStr[1]);
				if(fcsjL>fcsj){
					jcsx=jcsx+y.getJcsx();
				}else{
					y.setJcsx(y.getJcsx()+1);
					repository.save(y);
				}
			}
			
		}
		t.setJcsx(jcsx);
		repository.save(t);
		
		SysUser user = SecurityUtils.getCurrentUser();
		Nylog nylog=new Nylog();
		nylog.setCreatedate(new Date());
		nylog.setCzmc("手动添加");
		nylog.setNylx("油");
		nylog.setUserid(user.getUserName());
		nylog.setUsername(user.getName());
		nylog.setCxtj("");
		nylogRepository.save(nylog);
		map.put("status", ResponseCode.SUCCESS);
        map.put("t", t);
		return map;
	}
	@Transactional  
	@Override
	public Map<String, Object> deleteIds(Map<String, Object> map) throws Exception{
		// TODO Auto-generated method stub
		Map<String, Object> maps = new HashMap<>();
		try{
		String json =StringEscapeUtils.unescapeHtml4(map.get("ids").toString());
		JSONArray jsonArray=JSONArray.parseArray(json);
		JSONObject jsonObject;
		for (int x = 0; x < jsonArray.size(); x++) {
			jsonObject=jsonArray.getJSONObject(x);
			Integer id =jsonObject.getInteger("id");
			repository.deleteById(id);
		}
		
		SysUser user = SecurityUtils.getCurrentUser();
		Nylog nylog=new Nylog();
		nylog.setCreatedate(new Date());
		nylog.setCzmc("删除");
		nylog.setNylx("油");
		nylog.setUserid(user.getUserName());
		nylog.setUsername(user.getName());
		nylog.setCxtj("");
		nylogRepository.save(nylog);
		maps.put("status", ResponseCode.SUCCESS);
		} catch (Exception e) {
			maps.put("status", ResponseCode.ERROR);
			logger.error("save erro.", e);
			throw e; 
		}
		return maps;
	}
	
	public  List<Ylb> listOrderBy(String rq,String gsdm,
			String fgsdm,String xlbm,String nbbm,
			String px) {
		// TODO Auto-generated method stub
		String sql="SELECT * FROM bsth_c_ylb  "
				+ " where rq ='"+rq+"' and ssgsdm like '%"+gsdm+"%' "
				+ " and fgsdm like '%"+fgsdm+"%'";
		if(xlbm.equals("")){
			sql+= " and xlbm like '%"+xlbm+"%' ";
		}else{
			sql+= " and xlbm = '"+xlbm+"' ";
		}
				
		sql += "and nbbm like '%"+nbbm+"%' order by "+px+" asc ";
		
		List<Ylb> list = jdbcTemplate.query(sql, new RowMapper<Ylb>() {
			@Override
			public Ylb mapRow(ResultSet arg0, int arg1) throws SQLException {
				Ylb y = new Ylb();
				y.setId(arg0.getInt("id"));
				return y;
			}
		});
		List<Ylb> lists=new ArrayList<Ylb>();
		List<Ylb> ylbLists=repository.obtainYl(rq,gsdm,fgsdm,xlbm,nbbm,"jcsx");
		for (int i = 0; i < list.size(); i++) {
			Ylb t=list.get(i);
			for (int j = 0; j < ylbLists.size(); j++) {
				Ylb t2=ylbLists.get(j);
				if(t.getId().intValue()==t2.getId().intValue()){
					lists.add(t2);
					break;
				}
			}
		}
		
		return lists;
	}

	@Override
	public Map<String, Object> updateHistory(Map<String, Object> map) throws Exception {
		// TODO Auto-generated method stub
		Map<String, Object> newMap = new HashMap<String, Object>();

		List<Cars> carsList = carsRepository.findCars();
		Map<String, Boolean> carsMap = new HashMap<String, Boolean>();
		for (int i = 0; i < carsList.size(); i++) {
			Cars c = carsList.get(i);
			carsMap.put(c.getInsideCode(), c.getSfdc());
		}
		try{
			String date = map.get("date").toString();
			String line = map.get("line").toString();
			List<Line> listLine=lineRepository.findLineByCode(line);
			String gsdm ="";
			String fgsdm ="";
			if(listLine.size()>0){
				Line l=listLine.get(0);
				gsdm=l.getCompany();
				fgsdm=l.getBrancheCompany();
			}
			
			String nbbmstr="";
			List<Map<String, Object>> listpbYc=new ArrayList<Map<String, Object>>();//油车数据
			List<Map<String, Object>> listpbDc=new ArrayList<Map<String, Object>>();//电车数据
			List<Map<String,Object>> listpb=scheduleRealInfoService.yesterdayDataList("", date,gsdm, fgsdm, "", "");
			for (int i = 0; i < listpb.size(); i++) {
				if(listpb.get(i).get("xlBm").toString().equals(line)){
					nbbmstr +=listpb.get(i).get("clZbh").toString();
				}
			}
			for (int i = 0; i < listpb.size(); i++) {
				boolean sfdc=true;
				Map<String, Object> m = listpb.get(i);
				if (carsMap.get(m.get("clZbh").toString()) != null) {
					sfdc = carsMap.get(m.get("clZbh").toString());
				} else {
					sfdc = true;
				}
				if(nbbmstr.indexOf(m.get("clZbh").toString())>-1){
					if(sfdc){
						listpbDc.add(m);
					}else{
						listpbYc.add(m);
					}
				}
			}
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
			//初始存油量
			List<Cyl> clyList = cylRepository.obtainCyl("",gsdm);
			List<Ylxxb> ylxxList = ylxxbRepository.obtainYlxx(date, 0,gsdm);
			//重新统计油车数据开始
			List<Ylb> ylListBe =repository.listByRqJcsx(date, gsdm, fgsdm, "", "");
			List<Ylb> ylbList=this.listOrderBy(date,gsdm,fgsdm,"","","nbbm");
			List<Ylb> ylbList_upd=new ArrayList<Ylb>(); 
			List<Ylb> ylbList_del=new ArrayList<Ylb>(); 
			
			for (int j = 0; j < ylbList.size(); j++) {
				Ylb t=ylbList.get(j);
				boolean fage=true;
				if(StringUtils.isEmpty(t.getLp())){
					fage=false;
				}else{
					for (int i = 0; i < listpbYc.size(); i++) {
						Map<String, Object> m = listpbYc.get(i);
						if(t.getNbbm().equals(m.get("clZbh").toString())
						&&t.getJsy().equals(m.get("jGh").toString())
						&&t.getXlbm().equals(m.get("xlBm").toString())
						&&t.getLp().equals(m.get("lpName").toString())){
							//该条记录不用删除
							fage =false;
							ylbList_upd.add(t);
						}
					}
				}
				if(fage){
					if(t.getXlbm().equals(line)){
						ylbList_del.add(t);
					}
				}
				
			}
			String nbbmStr="";
			List<Ylb> list=new ArrayList<Ylb>();
			/*
			 * 第一步 修改车辆里程 和加注量
			 */
			Map<String, Object> ylMap=new HashMap<String, Object>();
			for (int x = 0; x < listpbYc.size(); x++) {
				String type = "add";
				Map<String, Object> maps = listpbYc.get(x);
					// 判断驾驶员驾驶的该车辆是否已经存入了（查出的结果集中日期是相同的，根据驾驶员、内部编号、线路编码判断）
					Ylb t = new Ylb();
					for (int k = 0; k < ylbList_upd.size(); k++) {
						Ylb t1 = ylbList_upd.get(k);
						if (t1.getNbbm().equals(maps.get("clZbh").toString())
								&& t1.getJsy().equals(maps.get("jGh").toString())
								&& t1.getXlbm().equals(maps.get("xlBm").toString())
								&& t1.getLp().equals(maps.get("lpName").toString())) {
									t = t1;
									type = "update";
						}
					}
					if(type.equals("add")){
						// 当日的第一个班次，出场油量等于前一天的最后一个班次的进场油量
						if (maps.get("seqNumber").toString().equals("1")) {
							boolean fage = true;
							for (int i = 0; i < ylListBe.size(); i++) {
								Ylb ylb = ylListBe.get(i);
								if (maps.get("clZbh").toString().equals(ylb.getNbbm())) {
									if(ylb.getJzyl()>=0){
										t.setCzyl(ylb.getJzyl());
										fage = false;
										break;
									}
								}
							}
							if (fage) {
								for (int y = 0; y < clyList.size(); y++) {
									Cyl cyl = clyList.get(y);
									if (maps.get("clZbh").toString().equals(cyl.getNbbm())) {
										if(cyl!=null){
											if(cyl.getCyl()>=0){
												t.setCzyl(cyl.getCyl());
												fage = false;
												break;
											}else {
												if(cyl.getCxrl()!=null){
													if(cyl.getCxrl()>0){
														t.setCzyl(cyl.getCxrl());
														fage = false;
														break;
													}
												}
											}
										}
									}
								}
							}
							if (fage) {
								t.setCzyl(0.0);
							}
						}
					}
					
					Double jzl = 0.0;
					//一人一车加注量只匹配一次
					if(ylMap.get(maps.get("clZbh").toString()+"_"+ maps.get("jGh").toString())!=null){
					}else{
						boolean fage2=false;
						for (int i = 0; i < ylxxList.size(); i++) {
							Ylxxb ylxxb = ylxxList.get(i);
							if (maps.get("clZbh").toString().equals(ylxxb.getNbbm())
									&& maps.get("jGh").toString().equals(ylxxb.getJsy())
									&& ylxxb.getJylx()==1) {
								if(ylxxb.getJzl()>0){
									fage2=true;
								}
							}
						}
						//车辆的加注量如果有任工干预，略接口过来 数据
						if(fage2){
							// 把当天手工输入的的YLXXB的加注量设置为当天YLB的加注量（根据车号，驾驶员判断,加油类型为1）
							for (int j = 0; j < ylxxList.size(); j++) {
								Ylxxb ylxxb = ylxxList.get(j);
								if (maps.get("clZbh").toString().equals(ylxxb.getNbbm())
										&& maps.get("jGh").toString().equals(ylxxb.getJsy())
										&& ylxxb.getJylx()==1) {
									jzl =Arith.add(jzl, ylxxb.getJzl());
								}
							}
							ylMap.put(maps.get("clZbh").toString()+"_"+ maps.get("jGh").toString(),maps.get("xlBm") == null ? "" : maps.get("xlBm").toString());
						}else{
							// 把当天的YLXXB的加注量设置为当天YLB的加注量（根据车号，驾驶员判断）
							for (int j = 0; j < ylxxList.size(); j++) {
								Ylxxb ylxxb = ylxxList.get(j);
								if (maps.get("clZbh").toString().equals(ylxxb.getNbbm())
										&& maps.get("jGh").toString().equals(ylxxb.getJsy())) {
									jzl =Arith.add(jzl, ylxxb.getJzl());
								}
							}
							ylMap.put(maps.get("clZbh").toString()+"_"+ maps.get("jGh").toString(),maps.get("xlBm") == null ? "" : maps.get("xlBm").toString());
						}
					}
					t.setJzl(jzl);
					t.setNbbm(maps.get("clZbh").toString());
					t.setJsy(maps.get("jGh") == null ? "" : maps.get("jGh").toString());
					t.setJname(maps.get("jName").toString());
					t.setZlc(maps.get("totalKilometers") == null ? 0.0
							: Double.parseDouble(maps.get("totalKilometers").toString()));
					t.setXlbm(maps.get("xlBm") == null ? "" : maps.get("xlBm").toString());
					t.setJcsx(Integer.parseInt(maps.get("seqNumber").toString()));
					t.setSsgsdm(maps.get("company") == null ? "" : maps.get("company").toString());
					t.setFgsdm(maps.get("bCompany") == null ? "" : maps.get("bCompany").toString());
					t.setJhsj(maps.get("fcsj")==null?"":maps.get("fcsj").toString());
					t.setRq(sdf.parse(date));
					t.setLp(maps.get("lpName")==null?"":maps.get("lpName").toString());
					if(!(t.getSsgsdm().equals("") || t.getFgsdm().equals(""))){
						 if(type.equals("add")){
							 if(nbbmStr.indexOf(t.getNbbm())<0){
								 nbbmStr +=t.getNbbm()+",";
							 }
							 t.setCreatetime(new Date());
						 }else{
							 t.setUpdatetime(new Date());
						 }
				    }
					try {
					    repository.save(t);
					} catch (Exception e) {
						// TODO: handle exception
						if(e.getMessage().indexOf("PK_YLB_UK")>0){
							newMap.put("fage", "存在相同数据,数据已经过滤");
							logger.info("油量存在相同数据,数据已经过滤");
						}
					}
				    
			    }
				for (int i = 0; i < ylbList_del.size(); i++) {
					Ylb y=ylbList_del.get(i);
					if(nbbmStr.indexOf(y.getNbbm())<0){
						 nbbmStr +=y.getNbbm()+",";
					 }
					repository.deleteById(y.getId());
				}
				
				//重新计算删除了的或者新增了的车的车的油耗信息（考虑车辆可能跨线路，从分公司赛选计算）
				double czyl=0.0;
				List<Ylb> iterator2=this.listOrderBy(date,gsdm,fgsdm,"","","nbbm,jcsx");
				String[] nbbms=nbbmStr.split(",");
				for (int i = 0; i < nbbms.length; i++) {
					String clzbm=nbbms[i];
					// 得到一天总的加油和里程（根据车，时间）
					List<Object[]> sumList = repository.sumLcYl(clzbm, sdf.parse(date),"",gsdm,fgsdm);
					// 保存总的加油量
					Double jzl = 0.0;
					// 保存总的里程
					Double zlc = 0.0;
					for (int j = 0; j < sumList.size(); j++) {
						jzl = Arith.add(jzl, Double.valueOf(sumList.get(j)[0].toString()));
						zlc = Arith.add(zlc, Double.valueOf(sumList.get(j)[1].toString()));
					}
					// 保留两位小数
					DecimalFormat df = new DecimalFormat("#.00");
					Double zyl = 0.0;
					Double nextJzyl = 0.0;
					for (int j = 0; j < iterator2.size(); j++) {
						Ylb t = iterator2.get(j);
						if(t.getNbbm().equals(clzbm)){
							if (t.getJcsx() == 1) {
								// 进场等于出场的操作 既 最后进场存油量等于第一次的出场存油量
								czyl = t.getCzyl();
								zyl =jzl;
								Double yh=0.0;
								if(zlc>0 ){
									 yh = Double.parseDouble(df.format(zyl * (t.getZlc() / zlc)));
								}
								nextJzyl =Arith.sub( Arith.add(t.getJzl(), t.getCzyl()),yh);
								//把进场油量的小数和整数分别取出
								if(zlc>0 && t.getZlc()>0){
									long l=Math.round(nextJzyl);
									double ylxs=l*100/100;
									yh=Arith.add(yh, Arith.sub(nextJzyl,ylxs));
									t.setYh(yh);
									t.setJzyl(ylxs);
									nextJzyl=ylxs;
								}else{
									t.setYh(yh);
									t.setJzyl(nextJzyl);
								}
							} else {
								t.setCzyl(nextJzyl);
								Double yh=0.0;
								if(zlc>0){
									yh= Double.parseDouble(df.format(zyl * (t.getZlc() / zlc)));
								}
								nextJzyl =Arith.sub( Arith.add(t.getJzl(),nextJzyl),yh);
								if(zlc>0 && t.getZlc()>0){
									long l=0l;
									double ylxs=0.0;
									if(j==iterator2.size()-1){
										ylxs=czyl;
									}else{
										if(iterator2.get(j+1).getNbbm().equals(t.getNbbm())){
											l=Math.round(nextJzyl);
											ylxs=l*100/100;
										}else{
											ylxs=czyl;
										}
										
									}
									yh=Arith.add(yh, Arith.sub(nextJzyl,ylxs));
									t.setYh(yh);
									t.setJzyl(ylxs);
									nextJzyl=ylxs;
								}else{
									t.setYh(yh);
									t.setJzyl(nextJzyl);
								}
							}
							if(t.getJzyl()<0){
								t.setJzyl(0.0);
							}
							if(t.getCzyl()<0){
								t.setCzyl(0.0);
							}
							if(t.getYh()<0){
								t.setYh(0.0);
							}
							if(t.getSh()<0){
								t.setSh(0.0);
							}
							repository.save(t);
						}
					}
				}
				
				//重新统计油车数据结束
				
				
				//重新获取电耗数据开始
				Map<String, List<Dlb>> mapList=dlbService.updeteHistory(listpbDc, date, gsdm, fgsdm, line);
				List<Dlb> delDlb=mapList.get("delList");
				for (int i = 0; i < delDlb.size(); i++) {
					Dlb d=delDlb.get(i);
					dlbRepository.deleteById(d.getId());
				}
				List<Dlb> updDlb=mapList.get("updList");
				for (int i = 0; i < updDlb.size(); i++) {
					Dlb d=updDlb.get(i);
					try {
						dlbRepository.save(d);
					} catch (Exception e) {
						// TODO: handle exception
						if(e.getMessage().indexOf("PK_DLB_UK")>0){
							newMap.put("fage", "存在相同数据,数据已经过滤");
							logger.info("电量存在相同数据,数据已经过滤");
						}
					}
				}
				//重新获取电耗数据结束
				
				SysUser user = SecurityUtils.getCurrentUser();
				Nylog nylog=new Nylog();
				nylog.setCreatedate(new Date());
				nylog.setCzmc("重新统计");
				nylog.setNylx("油");
				nylog.setUserid(user.getUserName());
				nylog.setUsername(user.getName());
				nylog.setCxtj(line+"-"+ date+"-"+gsdm+"-"+fgsdm);
				nylogRepository.save(nylog);
				newMap.put("status", ResponseCode.SUCCESS);
			}catch(Exception e){
				// TODO Auto-generated catch block
				newMap.put("status", ResponseCode.ERROR);
				throw e;
			}
		
		
		return newMap;
	}

	public List<Ylb> listByRqJcsx(String rq,String gsdm,String fgsdm,String xlbm,String nbbm) {
		List<Ylb> list=repository.listByRqJcsx(rq, gsdm, fgsdm, xlbm, nbbm);
		Map<String, Object> m=new HashMap<String,Object>();
		List<Ylb> list_=new ArrayList<Ylb>();
		for (int i = 0; i < list.size(); i++) {
			Ylb t=list.get(i);
			if(m.get(t.getNbbm())==null){
				m.put(t.getNbbm(), t.getNbbm());
				list_.add(t);
			}
		}
		return list_;
	}

	@Override
	public Map<String, Object> update(Map<String, Object> map) {
		if(map.get("id")!=null){
			if(map.get("id").toString().length()>0){
				Integer id=Integer.parseInt(map.get("id").toString());
				String jsy=map.get("jsy").toString();
				Ylb t=repository.findById(id).get();
				t.setJsy(jsy);
				repository.save(t);
				map.put("status", ResponseCode.SUCCESS);
			}
		}
		return map;
	}
}