潘钊 / 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 javax.transaction.Transactional;

import org.apache.commons.lang3.StringEscapeUtils;
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.ResponseCode;
import com.bsth.data.BasicData;
import com.bsth.entity.Cars;
import com.bsth.entity.Line;
import com.bsth.entity.mcy_forms.Daily;
import com.bsth.entity.oil.Cyl;
import com.bsth.entity.oil.Ylb;
import com.bsth.entity.oil.Ylxxb;
import com.bsth.entity.search.CustomerSpecs;
import com.bsth.repository.CarsRepository;
import com.bsth.repository.oil.CylRepository;
import com.bsth.repository.oil.YlbRepository;
import com.bsth.repository.oil.YlxxbRepository;
import com.bsth.service.impl.BaseServiceImpl;
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;

@Service
public class YlbServiceImpl extends BaseServiceImpl<Ylb,Integer> implements YlbService{
	@Autowired
	YlbRepository repository;
	
	@Autowired
	YlxxbRepository ylxxbRepository;
	
	@Autowired
	CylRepository cylRepository;
	
	@Autowired
	CarsRepository carsRepository;
	
	@Autowired
	ScheduleRealInfoService scheduleRealInfoService;
	
	@Autowired
	JdbcTemplate jdbcTemplate;
	
	Logger logger = LoggerFactory.getLogger(this.getClass());
	
	
	
	/**
	 * 获取进存油信息
	 * @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());
			}
			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=repository.obtainYlbefore(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 sfdc=true;
				Map<String, Object> map=listpb.get(x);
				if (carsMap.get(map.get("clZbh").toString())!=null) {
					 sfdc= carsMap.get(map.get("clZbh").toString());
				}else{
					sfdc=true;
				}
				if(!sfdc){
					//判断驾驶员驾驶的该车辆是否已经存入了（查出的结果集中日期是相同的，根据驾驶员、内部编号、线路编码判断）
					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()))
						{
							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);
							}
						}
						
						/*Double jzl=0.0;
						//把当天的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+=ylxxb.getJzl();
							}
						}
						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.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.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("定时器:存在相同数据,数据已经过滤");
					}
				}
//				new BatchSaveUtils<Ylb>().saveList(addList, Ylb.class); 
			}
			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());
			}
			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,line,nbbm,"nbbm");
//					repository.obtainYl(rq,gsbm,fgsbm,line,nbbm,"nbbm");
			// 当天YLXXB信息
			List<Ylxxb> ylxxList = ylxxbRepository.obtainYlxx(rq, 0,gsbm);
			// 前一天所有车辆最后进场班次信息
//			List<Ylb> ylListBe = repository.obtainYlbefore(rq, gsbm, fgsbm, line, nbbm);
			List<Ylb> ylListBe =repository.listMaxRqJcsx(rq, gsbm, fgsbm, line, 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(line, rq, gsbm, fgsbm, "", nbbm);

			String sxtj=map2.get("sxtj").toString();
			if(sxtj.equals("0")){
				listpb=listpbs;
			}else{
				List<Object[]> objectLists=repository.checkNbmmNum(rq, gsbm, fgsbm, line,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>();
			String ins="";
			Map<String, Object> ylMap=new HashMap<String, Object>();
			for (int x = 0; x < listpb.size(); x++) {
				String type = "add";
				boolean sfdc = true;
				Map<String, Object> map = listpb.get(x);
				if (carsMap.get(map.get("clZbh").toString()) != null) {
					sfdc = carsMap.get(map.get("clZbh").toString());
				} else {
					sfdc = true;
				}
				if (!sfdc) {
					// 判断驾驶员驾驶的该车辆是否已经存入了（查出的结果集中日期是相同的，根据驾驶员、内部编号、线路编码判断）
					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())) {
							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()>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){
						
					}else{
						boolean fage2=false;
						for (int i = 0; i < ylxxList.size(); i++) {
							Ylxxb ylxxb = ylxxList.get(i);
							if (map.get("clZbh").toString().equals(ylxxb.getNbbm())
									&& 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.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));
					
					 if(!(t.getSsgsdm().equals("") || t.getFgsdm().equals(""))){
						 if(type.equals("add")){
							 t.setCreatetime(date);
							 addList.add(t); 
						 }else{
							 t.setUpdatetime(date);
						     updateList.add(t); 
						     ins += t.getId().toString()+",";
						  }
					 }
//					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));
				}
			}
			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>();
//			if(xlbm.equals("")){
				ylbLists=this.listOrderBy(rq,gsbm,fgsbm,xlbm,nbbm,"jcsx");
//						repository.obtainYl(rq,gsbm,fgsbm,xlbm,nbbm,"jcsx");
				iterator2=this.listOrderBy(rq,gsbm,fgsbm,xlbm,nbbm,"nbbm,jcsx");
//						repository.obtainYl(rq,gsbm,fgsbm,xlbm,nbbm,"nbbm,jcsx");
//			}else{
//				ylbLists=repository.obtainYl_eq(rq,gsbm,fgsbm,xlbm,nbbm,"jcsx");
//				iterator2=repository.obtainYl_eq(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(Arith.sub(t.getJzl(),t.getSh()), t.getCzyl()),yh);
								//把进场油量的小数和整数分别取出
//								int ylxs=(int) nextJzyl; 10.6--11  10.3--10
								if(zlc>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(Arith.sub(t.getJzl(),t.getSh()),nextJzyl),yh);
								if(zlc>0){
									long l=0l;
									double ylxs=0.0;
									if(j==iterator2.size()-1){
										ylxs=czyl;
									}else{
//										l=Math.round(nextJzyl);
//										ylxs=l*100/100;
										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);
								}
							}
							repository.save(t);
							/*for (int z = 0; z < cylList.size(); z++) {
								Cyl cyl = cylList.get(z);
								if (t.getNbbm().equals(cyl.getNbbm())) {
									cyl.setCyl(t.getJzyl());
									cyl.setUpdatetime(t.getRq());
									break;
								}
								cylRepository.save(cyl);
							}*/
						}
						map2.put("status", ResponseCode.SUCCESS);
					}
				}
			}
		} catch (Exception e) {
			map2.put("status", ResponseCode.ERROR);
			logger.error("save erro.", e);
			throw e; 
		}
		return map2;
	}
	
	/**
	 * 拆分
	 */
	/*
	@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));
			int id = Integer.parseInt(map.get("id").toString());
			// 最后存油量
			Double yl = Double.parseDouble(map.get("jzyl").toString());
			Double sh= Double.parseDouble(map.get("sh").toString());
			String shyy=map.get("shyy").toString();
			Ylb ylb = repository.findOne(id);
			List<Cyl> cylListAdd=new ArrayList<Cyl>();
			Map<String, Object> cylMapAdd=new HashMap<String,Object>();
			String nbbm_eq = ylb.getNbbm();
			Date rq_eq = ylb.getRq();
			// 得到一天总的加油和里程（根据车，时间）
			List<Object[]> sumList = repository.sumLcYl(nbbm_eq, rq_eq,ylb.getXlbm());
			// 保存总的加油量
			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=repository.obtainYl(sdf.format(rq_eq),ylb.getSsgsdm(),ylb.getFgsdm(),ylb.getXlbm(),
					ylb.getNbbm(),"jcsx");
//			Iterator<Ylb> iterator = repository.findAll(new CustomerSpecs<Ylb>(map), new Sort(Direction.ASC, "jcsx"))
//					.iterator();
			// 根据jcyl排序1为该车当日第一个出场，出场油量为前一天的存油
			// 保留两位小数
			DecimalFormat df = new DecimalFormat("#.00");
			Double zyl = 0.0;
			Double nextJzyl = 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);
					}
					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()), Arith.add(yh, t.getSh()));
					long l=Math.round(nextJzyl);
					double ylxs=l*100/100;
//					nextJzyl = Arith.add(nextJzyl,Arith.sub(nextJzyl,ylxs));
					yh=Arith.add(yh, Arith.sub(ylxs,nextJzyl));
					t.setJzyl(ylxs);
					t.setYh(yh);
					nextJzyl=ylxs;
				} 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()));
						long l=Math.round(nextJzyl);
						double ylxs=l*100/100;
//						nextJzyl = Arith.add(nextJzyl,Arith.sub(nextJzyl,ylxs));
						yh=Arith.add(yh, Arith.sub(ylxs,nextJzyl));
						t.setJzyl(ylxs);
						t.setYh(yh);
						nextJzyl=ylxs;
				}
				repository.save(t);

				// 设置存油量
				Cyl cyl = null;
				boolean fage = false;
				for (int z = 0; z < cylList.size(); z++) {
					cyl = cylList.get(z);
					if (t.getNbbm().equals(cyl.getNbbm())) {
						cyl.setCyl(t.getJzyl());
						cyl.setUpdatetime(t.getRq());
						fage = true;
						break;
					}
				}
				if (fage) {
					cylRepository.save(cyl);
				} else {
					if(cylMapAdd.get(t.getNbbm())!=null){
						for (int l = 0; l < cylListAdd.size(); l++) {
							cyl=cylListAdd.get(l);
							if(cyl.getNbbm().equals(t.getNbbm())){
								cyl.setNbbm(t.getNbbm());
								cyl.setCyl(t.getJzyl());
								cyl.setGsdm(t.getSsgsdm());
								cyl.setFgsdm(t.getFgsdm());
								cyl.setUpdatetime(t.getRq());
							}
						}
					}else{
						cyl = new Cyl();
						cyl.setNbbm(t.getNbbm());
						cyl.setCyl(t.getJzyl());
						cyl.setGsdm(t.getSsgsdm());
						cyl.setFgsdm(t.getFgsdm());
						cyl.setUpdatetime(t.getRq());
						cylListAdd.add(cyl);
					}
				}

				newMap.put("status", ResponseCode.SUCCESS);
			}
			for (int i = 0; i < cylListAdd.size(); i++) {
				cylRepository.save(cylListAdd.get(i));
			}
		} catch (Exception e) {
			newMap.put("status", ResponseCode.ERROR);
			logger.error("save erro.", e);
			throw e; 
		}
		return newMap;
	}*/

	/**
	 * 核对，有加注没里程
	 * @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=repository.listMaxRqJcsx(rq, gsbm, fgsbm, xlbm, 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);
			for (int i = 0; i < ylxxbList.size(); i++) {
				Boolean fage=true;
				Ylxxb y1=ylxxbList.get(i);
				for(int y=0;y<ylbList.size();y++){
					Ylb y2=ylbList.get(y);
					if(y1.getNbbm().equals(y2.getNbbm())){
						fage=false;
						break;
					}
				}
				
				if(fage){
					Ylb t=new Ylb();
					t.setNbbm(y1.getNbbm());
					t.setRq(y1.getYyrq());
					t.setJsy(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);
					Line line= BasicData.nbbm2LineMap.get(y1.getNbbm());
					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);
					}
//					double jzyl=Arith.add(t.getJzl(), t.getCzyl());
					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);
						} catch (Exception e) {
							// TODO: handle exception
							if(e.getMessage().indexOf("PK_YLB_UK")>0){
								newMap.put("fage", "存在相同数据,数据已经过滤");
								logger.info("核对有存油没里程：存在相同数据,数据已经过滤");
							}
						}
						
						/*if(null!=cyl){
							cyl.setCyl(Arith.add(t.getJzl(), t.getCzyl()));
							cyl.setUpdatetime(y1.getYyrq());
							cylRepository.save(cyl);
						}*/
					}
				}
			}
			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<Ylb> oilListMonth(String line, String date, String type) {
		String date2=date.substring(0, 8)+"01";
		String lineStr="";
		if(line !=null && !line.equals("")){
			lineStr =" and xlbm= '"+ line +"'";
		}
		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;  
			            }  
					});  
		
		if(type != null && type.equals("export")){
			SimpleDateFormat sdfMonth = new SimpleDateFormat("yyyy-MM-dd"),
					sdfSimple = new SimpleDateFormat("yyyyMMdd");
			
			List<Map<String, Object>> mapList = new ArrayList<Map<String, Object>>();
			for(Ylb ylb : list){
				Map<String, Object> m = new HashMap<String, Object>();
				m.put("nbbm", ylb.getNbbm()!=null?ylb.getNbbm():"");
				m.put("rq", ylb.getRq()!=null?sdfMonth.format(ylb.getRq()):"");
				m.put("jzyl", ylb.getJzyl()!=null?ylb.getJzyl():"");
				mapList.add(m);
			}
			
			List<Iterator<?>> listI = new ArrayList<Iterator<?>>();
			Map<String, Object> m = new HashMap<String, Object>();
			ReportUtils ee = new ReportUtils();
			try {
				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)) + ".xls");
			} catch (Exception e) {
				// TODO: handle exception
				e.printStackTrace();
			}
		}
		
		return list;
	}

	@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();
		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);
							}
						}
					}
				}
			}
		}
		List<Object[]> sumYlbList=new ArrayList<Object[]>();
		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);
//				}
				sumYlbList=repository.sumYlb(rq, gsbm, fgsbm, xlbm, stringList);
			}
//			else{
//				sumYlbList=repository.sumYlb2(rq, gsbm, fgsbm, xlbm, nbbm);
//			}
			
		}
		
		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>();
		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();
		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){
						listYlb=repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
					}
				}else if(sxtj.equals("2")){
					if(cs>1){
						listYlb=repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
					}
				}else{
					listYlb=repository.listYlb(rq, 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){
					listYlb=repository.listYlb(rq, 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){
					listYlb=repository.listYlb(rq, gsbm, fgsbm, xlbm, stringList);
				}
			}
		}

		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);
			/*t.setJzyl(jzyl);
			t.setSh(sh);
			t.setShyy(shyy);
			t.setNs(ns);
			t.setRylx(rylx);
			t.setId(jsonObject.getInteger("id"));*/
			repository.ylbUpdate(id, czyl, jzyl, yh, sh, shyy, ns, rylx,yhlx);
			/*for (int z = 0; z < cylList.size(); z++) {
				Cyl cyl = cylList.get(z);
				if (nbbm.equals(cyl.getNbbm())) {
					cyl.setCyl(jzyl);
					cyl.setUpdatetime(sdf.parse(rq));
					break;
				}
				cylRepository.save(cyl);
			}*/
		}
//		List<Map<String, Object>> list=(List<Map<String, Object>>) map.get("ylbList");
		
		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());
			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.findOne(id);
				String nbbm_eq = ylb.getNbbm();
				Date rq_eq = ylb.getRq();
				// 得到一天总的加油和里程（根据车，时间）
				List<Object[]> 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=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()), Arith.add(yh, t.getSh()));
						if(zlc>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()));
							if(zlc>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);
							}
					}
					repository.save(t);
					for (int z = 0; z < cylList.size(); z++) {
						Cyl cyl = cylList.get(z);
						if (t.getNbbm().equals(cyl.getNbbm())) {
							cyl.setCyl(t.getJzyl());
							cyl.setUpdatetime(t.getRq());
							break;
						}
						cylRepository.save(cyl);
					}
				}
				newMap.put("status", ResponseCode.SUCCESS);
			}
		} 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 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);
		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.delete(id);
		}
		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 to_days('"+rq+"')=to_days(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;
	}
}