油量。报表

廖磊
1 parent e8c1bd9d
Showing 1 changed file with 108 additions and 15 deletions
src/main/java/com/bsth/service/oil/impl/CwjyServiceImpl.java
@@ -6,17 +6,26 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Date;
 import java.util.HashMap;
 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.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.entity.oil.Cwjy;
+import com.bsth.entity.oil.Cyl;
 import com.bsth.entity.oil.Ylxxb;
 import com.bsth.repository.oil.CwjyRepository;
 import com.bsth.repository.oil.YlxxbRepository;
@@ -35,8 +44,8 @@ public class CwjyServiceImpl extends BaseServiceImpl&lt;Cwjy,Integer&gt; implements Cw
 	@Autowired
 	JdbcTemplate jdbcTemplate;
-	
-	@SuppressWarnings("unchecked")
+	Logger logger = LoggerFactory.getLogger(this.getClass());
+	/*@SuppressWarnings("unchecked")
 	public PageObject<Ylxxb> Pagequery(Map<String, Object> map) {
 		int page=Integer.parseInt(map.get("page").toString());
 		SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
@@ -129,7 +138,7 @@ public class CwjyServiceImpl extends BaseServiceImpl&lt;Cwjy,Integer&gt; implements Cw
 				 return t;
 			 }
 		});
-		/*List<Object[]> list=repository.obtainCwjycl(rq,nbbm);
+		List<Object[]> list=repository.obtainCwjycl(rq,nbbm);
 		for (int i = 0; i < list.size(); i++) {
 			Ylxxb y=new Ylxxb();
 			y.setGsdm(list.get(i)[0]==null?"":list.get(i)[0].toString());
@@ -148,13 +157,13 @@ public class CwjyServiceImpl extends BaseServiceImpl&lt;Cwjy,Integer&gt; implements Cw
 				e.printStackTrace();
 			}
 			yList.add(y);
-		}*/
+		}
 		PageHelper pageHelper = new PageHelper(listsize, map);
 		pageHelper.getMap();
 		PageObject<Ylxxb> pageObject=pageHelper.getPageObject();
 		pageObject.setDataList(yList);
 		return pageObject;
-	}
+	}*/
 	@Override
 	public Ylxxb bynbbm(Map<String, Object> map) {
@@ -188,28 +197,112 @@ public class CwjyServiceImpl extends BaseServiceImpl&lt;Cwjy,Integer&gt; implements Cw
 		return y;
 	}
+	@Transactional 
 	@Override
-	public Map<String, Object> savejzl(Ylxxb t) {
+	public Map<String, Object> savejzl(Map<String, Object> maps) throws Exception {
 		// TODO Auto-generated method stub
 		Map<String, Object> map=new HashMap<String,Object>();
 		try {
 			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
-			String rq = sdf.format(t.getYyrq());
-			String nbbm=t.getNbbm();
-			List<Ylxxb> yList=ylxxbRepository.obtainYlxx2(rq,nbbm);
-			if(yList.size()>0){
-				t.setId(yList.get(0).getId());
-				ylxxbRepository.save(t);
-			}else{
-				ylxxbRepository.save(t);
+//			String rq = sdf.format(t.getYyrq());
+//			String nbbm=t.getNbbm();
+//			List<Ylxxb> yList=ylxxbRepository.obtainYlxx2(rq,nbbm);
+//			if(yList.size()>0){
+//				t.setId(yList.get(0).getId());
+//				ylxxbRepository.save(t);
+//			}else{
+//				ylxxbRepository.save(t);
+//			}
+			String gsbm=maps.get("gsbm").toString();
+			String fgsbm=maps.get("fgsbm").toString();
+			String rq=maps.get("rq").toString();
+			Date date=sdf.parse(rq);
+			String json =StringEscapeUtils.unescapeHtml4(maps.get("ylbList").toString());
+			JSONArray jsonArray=JSONArray.parseArray(json);
+			JSONObject jsonObject;
+			// 获取车辆存油信息
+			for (int i = 0; i < jsonArray.size(); i++) {
+				jsonObject=jsonArray.getJSONObject(i);
+				Integer id =jsonObject.getInteger("id");
+				String jsy=jsonObject.getString("jsy");
+				double jzl=jsonObject.getDoubleValue("jzl");
+				String stationid=jsonObject.getString("stationid");
+				int nylx=jsonObject.getIntValue("nylx");
+				String jyggh=jsonObject.getString("jyggh");
+				String bz=jsonObject.getString("bz");
+				Ylxxb y;
+				if(id>0){
+					y=ylxxbRepository.findOne(id);
+					y.setJsy(jsy);
+					y.setJzl(jzl);
+					y.setStationid(stationid);
+					y.setJyggh(jyggh);
+					y.setBz(bz);
+					y.setCreatetime(date);
+					ylxxbRepository.save(y);
+				}else{
+					y=new Ylxxb();
+					y.setGsdm(gsbm);
+					y.setJsy(jsy);
+					y.setJzl(jzl);
+					y.setStationid(stationid);
+					y.setJyggh(jyggh);
+					y.setBz(bz);
+					y.setCreatetime(date);
+					y.setJylx(1);
+					ylxxbRepository.save(y);
+				}
 			}
 			map.put("status", ResponseCode.SUCCESS);
+			
 		} catch (Exception e) {
 			map.put("status", ResponseCode.ERROR);
-			e.printStackTrace();
+			logger.error("save erro.", e);
+			throw e;
 			// TODO: handle exception
 		}
 		return map;
 	}
+	@Override
+	public List<Ylxxb> Pagequery(Map<String, Object> map) {
+		// TODO Auto-generated method stub
+		String rq=map.get("rq").toString();
+		String nbbm=map.get("nbbh").toString();
+		String sql="SELECT a.gsdm as gsdm,a.fgsdm as fgsdm,a.nbbm as nbbm,"
+				+ "b.jyggh as jyggh,b.jzl as jzl ,b.stationid as stationid,b.jsy as jsy,"
+				+ "b.nylx as nylx,b.yj as yj,b.bz as bz,b.id as id ,c.jsy as ldgh  FROM  bsth_c_cwjy  a "+ 
+				   " left  join ("
+				   + " select * from bsth_c_ylxxb b "
+				   + "where to_days(b.yyrq)=to_days('"+rq+"') and jylx=1) b " +
+				  " on a.nbbm=b.nbbm "
+				  + "left join (select nbbm,group_concat(jsy) as jsy  "
+				  + "from bsth_c_ylb where  to_days(rq)= to_days('"+rq+"' ) group by nbbm "+
+				   " ) c on a.nbbm=c.nbbm  "
+				   + "where  a.nbbm like '%"+nbbm+"%'";
+		
+		List<Ylxxb> yList= jdbcTemplate.query(sql,
+				 new RowMapper<Ylxxb>(){
+			 @Override
+			 public Ylxxb  mapRow(ResultSet rs, int rowNum) throws SQLException {  
+				 Ylxxb t=new Ylxxb();
+				 t.setId(rs.getInt("id"));
+				 t.setGsdm(rs.getString("gsdm"));
+				 t.setFgsdm(rs.getString("fgsdm"));
+				 t.setNbbm(rs.getString("nbbm"));
+				 t.setJyggh(rs.getString("jyggh"));
+				 t.setJsy(rs.getString("jsy"));
+				 t.setJzl(rs.getDouble("jzl"));
+				 t.setStationid(rs.getString("stationid"));
+				 t.setNylx(rs.getInt("nylx"));
+				 t.setYj(rs.getDouble("yj"));
+				 t.setBz(rs.getString("bz"));
+				 t.setJsy(rs.getString("ldgh"));
+				 return t;
+			 }
+		});
+		
+		return yList;
+	}
+
 }