package com.hxzkoa.services;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.persistence.Query;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.hxzkoa.json.tb_collector;
import com.hxzkoa.json.tb_gas;
import com.hxzkoa.json.tb_gas_history;
import com.hxzkoa.json.tb_tag;
import com.hxzkoa.util.Config;
import com.hxzkoa.util.ModifyConfig;

@Service
public class GasService {
	@PersistenceContext
	private EntityManager em;
	@Autowired
	private CaozuoService cs;
	
	public List<tb_gas> getSensorManagement() {
		String sql = null;
		Query query = null;
		sql = "SELECT id,wei_zhi,gas_type,nong_du,status,collect_ip,tong_dao,waring_zhi,ip,x,y,addtime,name FROM tb_gas";
		query = this.em.createNativeQuery(sql);
		List resultList = query.getResultList();
		List<tb_gas> tb_gasList = new ArrayList<tb_gas>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_gas gas = new tb_gas();
				Object[] obj = (Object[]) resultList.get(i);
				gas.setId((int) obj[0]);
				gas.setWei_zhi(obj[1] == null ? "" : obj[1].toString());
				gas.setGas_type(obj[2] == null ? "" : obj[2].toString());
				gas.setNong_du(obj[3] == null ? "" : obj[3].toString());
				gas.setStatus(obj[4] == null ? "" : obj[4].toString());
				gas.setCollect_ip(obj[5] == null ? "" : obj[5].toString());
				gas.setTong_dao(obj[6] == null ? "" : obj[6].toString());
				gas.setWaring_zhi(obj[7] == null ? "" : obj[7].toString());
				gas.setIp(obj[8] == null ? "" : obj[8].toString());
				gas.setX(obj[9] == null ? "" : obj[9].toString());
				gas.setY(obj[10] == null ? "" : obj[10].toString());
				gas.setAddtime(obj[11] == null ? "" : obj[11].toString());
				gas.setName(obj[12] == null ? "" : obj[12].toString());
				tb_gasList.add(gas);
			}
		}
		return tb_gasList;
	}
	
	public List<tb_gas> getSensorManagement(int page) {
		int perPage = Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"));
		int start = (page - 1) * perPage;
		int end = perPage;
		String sql = null;
		Query query = null;
		sql = "SELECT id,wei_zhi,gas_type,nong_du,status,collect_ip,tong_dao,waring_zhi,ip,x,y,addtime FROM tb_gas LIMIT :start,:end";
		query = this.em.createNativeQuery(sql);
		query.setParameter("start", start);
		query.setParameter("end", end);
		List resultList = query.getResultList();
		List<tb_gas> tb_gasList = new ArrayList<tb_gas>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_gas gas = new tb_gas();
				Object[] obj = (Object[]) resultList.get(i);
				gas.setId((int) obj[0]);
				gas.setWei_zhi(obj[1] == null ? "" : obj[1].toString());
				gas.setGas_type(obj[2] == null ? "" : obj[2].toString());
				gas.setNong_du(obj[3] == null ? "" : obj[3].toString());
				gas.setStatus(obj[4] == null ? "" : obj[4].toString());
				gas.setCollect_ip(obj[5] == null ? "" : obj[5].toString());
				gas.setTong_dao(obj[6] == null ? "" : obj[6].toString());
				gas.setWaring_zhi(obj[7] == null ? "" : obj[7].toString());
				gas.setIp(obj[8] == null ? "" : obj[8].toString());
				gas.setX(obj[9] == null ? "" : obj[9].toString());
				gas.setY(obj[10] == null ? "" : obj[10].toString());
				gas.setAddtime(obj[11] == null ? "" : obj[11].toString());
				tb_gasList.add(gas);
			}
		}
		return tb_gasList;
	}

	public int getSensorManagementCount() {
		String sql = null;
		Query query = null;
		sql = "SELECT count(1) FROM tb_gas";
		query = this.em.createNativeQuery(sql);
		return Integer.parseInt(query.getSingleResult().toString());
	}

	public List<tb_gas> searchSensorManagement(String input) {
		int id = Integer.parseInt(input);
		String sql = null;
		Query query = null;
		sql = "SELECT id,wei_zhi,gas_type,nong_du,status,collect_ip,tong_dao,waring_zhi,ip,x,y,addtime FROM tb_gas WHERE id = :id";
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", id);
		List resultList = query.getResultList();
		List<tb_gas> tb_gasList = new ArrayList<tb_gas>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_gas gas = new tb_gas();
				Object[] obj = (Object[]) resultList.get(i);
				gas.setId((int) obj[0]);
				gas.setWei_zhi(obj[1] == null ? "" : obj[1].toString());
				gas.setGas_type(obj[2] == null ? "" : obj[2].toString());
				gas.setNong_du(obj[3] == null ? "" : obj[3].toString());
				gas.setStatus(obj[4] == null ? "" : obj[4].toString());
				gas.setCollect_ip(obj[5] == null ? "" : obj[5].toString());
				gas.setTong_dao(obj[6] == null ? "" : obj[6].toString());
				gas.setWaring_zhi(obj[7] == null ? "" : obj[7].toString());
				gas.setIp(obj[8] == null ? "" : obj[8].toString()); 
				gas.setX(obj[9] == null ? "" : obj[9].toString());
				gas.setY(obj[10] == null ? "" : obj[10].toString());
				gas.setAddtime(obj[11] == null ? "" : obj[11].toString());
				tb_gasList.add(gas);
			}
		}
		return tb_gasList;
	}

	@Transactional
	public void sensorManagement_delete(String[] checkVal) {
		String sql = null;
		Query query = null;
		for (int i = 0; i < checkVal.length; i++) {
			int id = Integer.parseInt(checkVal[i]);
			sql = "DELETE FROM tb_gas WHERE id = :id";
			cs.tb_caozuo("tb_gas", 2);
			query = this.em.createNativeQuery(sql);
			query.setParameter("id", id);
			query.executeUpdate();
		}
	}

	@Transactional
	public void sensorManagement_deleteAll() {
		String sql = null;
		Query query = null;
		sql = "DELETE FROM tb_gas";
		cs.tb_caozuo("tb_gas", 2);
		query = this.em.createNativeQuery(sql);
		query.executeUpdate();
	}
	
	public List<tb_collector> getcollectorList() {
		String sql = null;
		Query query = null;
		sql = "SELECT macid,ip,macname FROM tb_collector";
		query = this.em.createNativeQuery(sql);
		List resultList = query.getResultList();
		List<tb_collector> tb_collectorList = new ArrayList<tb_collector>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_collector collector = new tb_collector();
				Object[] obj = (Object[]) resultList.get(i);
				collector.setMacid((int) obj[0]);
				collector.setIp(obj[1] == null ? "" : obj[1].toString());
				collector.setMacname(obj[2] == null ? "" : obj[2].toString());
				tb_collectorList.add(collector);
			}
		}
		return tb_collectorList;
	}
	
	public List<tb_collector> getmacName(String gasMacid) {
		String sql = null;
		Query query = null;
		sql = "SELECT id,macname FROM tb_collector WHERE macid = :id ";
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", gasMacid);
		List resultList = query.getResultList();
		List<tb_collector> tb_collectorList = new ArrayList<tb_collector>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_collector gas = new tb_collector();
				Object[] obj = (Object[]) resultList.get(i);
				gas.setMacname(obj[1] == null ? "" : obj[1].toString());
				tb_collectorList.add(gas);
			}
		}
		return tb_collectorList;
	}
	
	@Transactional
	public int sensorManagement_add(tb_gas gas) {
		String sql = null;
		Query query = null;
		sql = "INSERT INTO tb_gas(id,gas_type,collect_ip,tong_dao,waring_zhi,ip,x,y,addtime,wei_zhi,nong_du,status) VALUES(:id,:gas_type,:collect_ip,:tong_dao,:waring_zhi,:ip,:x,:y,now(),:wei_zhi,:nong_du,:status)";
		cs.tb_caozuo("tb_gas", 1);
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", gas.getId());
		query.setParameter("gas_type", gas.getGas_type());
		query.setParameter("collect_ip", gas.getCollect_ip());
		query.setParameter("tong_dao", gas.getTong_dao());
		query.setParameter("waring_zhi", gas.getWaring_zhi());
		query.setParameter("ip", gas.getIp());
		query.setParameter("x", gas.getX());
		query.setParameter("y", gas.getY());
		query.setParameter("nong_du", "0");
		query.setParameter("status", "正常");
		query.setParameter("wei_zhi", gas.getWei_zhi());
		int executeUpdate = query.executeUpdate();
		return executeUpdate;
	}
	
	@Transactional
	public int sensor_exist(String id) {
		String sql = null;
		Query query = null;
		sql = "SELECT count(1) FROM tb_gas WHERE id= :id";
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", id);
		return Integer.parseInt(query.getSingleResult().toString());
	}
	
	@Transactional
	public int sensorManagement_modify(tb_gas gas) {
		String sql = null;
		Query query = null;
		sql = "UPDATE tb_gas SET gas_type = :gas_type,collect_ip = :collect_ip,tong_dao = :tong_dao,waring_zhi = :waring_zhi,ip = :ip,x = :x,y = :y,wei_zhi = :wei_zhi,addtime = now() WHERE id= :id";
		cs.tb_caozuo("tb_gas", 3);
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", gas.getId());
		query.setParameter("gas_type", gas.getGas_type());
		query.setParameter("collect_ip", gas.getCollect_ip());
		query.setParameter("tong_dao", gas.getTong_dao());
		query.setParameter("waring_zhi", gas.getWaring_zhi());
		query.setParameter("ip", gas.getIp());
		query.setParameter("x", gas.getX());
		query.setParameter("y", gas.getY());
		query.setParameter("wei_zhi", gas.getWei_zhi());
		int executeUpdate = query.executeUpdate();
		return executeUpdate;
	}
	
	public List<tb_gas_history> getHistoricalDetection() {
		String sql = null;
		Query query = null;
		sql = "SELECT id,macid,name,type,x,y,deep,waring,addtime FROM tb_gas_history";
		query = this.em.createNativeQuery(sql);
		List resultList = query.getResultList();
		List<tb_gas_history> tb_gas_historyList = new ArrayList<tb_gas_history>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_gas_history gas_history = new tb_gas_history();
				Object[] obj = (Object[]) resultList.get(i);
				gas_history.setId((int) obj[0]);
				gas_history.setMacid(obj[1] == null ? "" : obj[1].toString());
				gas_history.setName(obj[2] == null ? "" : obj[2].toString());
				gas_history.setType(obj[3] == null ? "" : obj[3].toString());
				gas_history.setX((int) obj[4]);
				gas_history.setY((int) obj[5]);
				gas_history.setDeep(obj[6] == null ? "" : obj[6].toString());
				gas_history.setWaring(obj[7] == null ? "" : obj[7].toString());
				gas_history.setAddtime(obj[8] == null ? "" : obj[8].toString());
				tb_gas_historyList.add(gas_history);
			}
		}
		return tb_gas_historyList;
	}

	public List<tb_gas_history> getHistoricalDetection(int page) {
		int perPage = Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"));
		int start = (page - 1) * perPage;
		int end = perPage;
		String sql = null;
		Query query = null;
		sql = "SELECT id,macid,name,type,x,y,deep,waring,addtime FROM tb_gas_history LIMIT :start,:end";
		query = this.em.createNativeQuery(sql);
		query.setParameter("start", start);
		query.setParameter("end", end);
		List resultList = query.getResultList();
		List<tb_gas_history> tb_gas_historyList = new ArrayList<tb_gas_history>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_gas_history gas_history = new tb_gas_history();
				Object[] obj = (Object[]) resultList.get(i);
				gas_history.setId((int) obj[0]);
				gas_history.setMacid(obj[1] == null ? "" : obj[1].toString());
				gas_history.setName(obj[2] == null ? "" : obj[2].toString());
				gas_history.setType(obj[3] == null ? "" : obj[3].toString());
				gas_history.setX(obj[4] == null ? (int)-1 :(int) obj[4]);
				gas_history.setY(obj[5] == null ? (int)-1 :(int) obj[5]);
				gas_history.setDeep(obj[6] == null ? "" : obj[6].toString());
				gas_history.setWaring(obj[7] == null ? "" : obj[7].toString());
				gas_history.setAddtime(obj[8] == null ? "" : obj[8].toString());
				tb_gas_historyList.add(gas_history);
			}
		}
		return tb_gas_historyList;
	}

	public List<tb_gas_history> searchHistoricalDetection(String input) {
		int id = Integer.parseInt(input);
		String sql = null;
		Query query = null;
		sql = "SELECT id,macid,name,type,x,y,deep,waring,addtime FROM tb_gas_history WHERE id = :id";
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", id);
		List resultList = query.getResultList();
		List<tb_gas_history> tb_gas_historyList = new ArrayList<tb_gas_history>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_gas_history gas_history = new tb_gas_history();
				Object[] obj = (Object[]) resultList.get(i);
				gas_history.setId((int) obj[0]);
				gas_history.setMacid(obj[1] == null ? "" : obj[1].toString());
				gas_history.setName(obj[2] == null ? "" : obj[2].toString());
				gas_history.setType(obj[3] == null ? "" : obj[3].toString());
				gas_history.setX((int) obj[4]);
				gas_history.setY((int) obj[5]);
				gas_history.setDeep(obj[6] == null ? "" : obj[6].toString());
				gas_history.setWaring(obj[7] == null ? "" : obj[7].toString());
				gas_history.setAddtime(obj[8] == null ? "" : obj[8].toString());
				tb_gas_historyList.add(gas_history);
			}
		}
		return tb_gas_historyList;
	}

	public int getHistoricalDetectionCount() {
		String sql = null;
		Query query = null;
		sql = "SELECT count(1) FROM tb_gas_history";
		query = this.em.createNativeQuery(sql);
		return Integer.parseInt(query.getSingleResult().toString());
	}

	@Transactional
	public void historicalDetection_delete(String[] checkVal) {
		String sql = null;
		Query query = null;
		for (int i = 0; i < checkVal.length; i++) {
			int id = Integer.parseInt(checkVal[i]);
			sql = "DELETE FROM tb_gas_history WHERE id = :id";
			cs.tb_caozuo("tb_gas_history", 2);
			query = this.em.createNativeQuery(sql);
			query.setParameter("id", id);
			query.executeUpdate();
		}
	}

	@Transactional
	public void historicalDetection_deleteAll() {
		String sql = null;
		Query query = null;
		sql = "DELETE FROM tb_gas_history";
		cs.tb_caozuo("tb_gas_history", 2);
		query = this.em.createNativeQuery(sql);
		query.executeUpdate();
	}

	public List<tb_collector> getCollectorManagement() {
		String sql = null;
		Query query = null;
		sql = "SELECT id,macid,startip,datlenth,ip,macname,posx,posy,addtime FROM tb_collector";
		query = this.em.createNativeQuery(sql);
		List resultList = query.getResultList();
		List<tb_collector> tb_collectorList = new ArrayList<tb_collector>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_collector collector = new tb_collector();
				Object[] obj = (Object[]) resultList.get(i);
				collector.setId((int) obj[0]);
				collector.setMacid((int) obj[1]);
				collector.setStartip((int) obj[2]);
				collector.setDatlenth((int) obj[3]);
				collector.setIp(obj[4] == null ? "" : obj[4].toString());
				collector.setMacname(obj[5] == null ? "" : obj[5].toString());
				collector.setPosx((int) obj[6]);
				collector.setPosy((int) obj[7]);
				collector.setAddtime((Date) obj[8]);
				tb_collectorList.add(collector);
			}
		}
		return tb_collectorList;
	}
	
	public List<tb_collector> getCollectorManagement(int page) {
		int perPage = Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"));
		int start = (page - 1) * perPage;
		int end = perPage;
		String sql = null;
		Query query = null;
		sql = "SELECT id,macid,startip,datlenth,ip,macname,posx,posy,addtime FROM tb_collector LIMIT :start,:end";
		query = this.em.createNativeQuery(sql);
		query.setParameter("start", start);
		query.setParameter("end", end);
		List resultList = query.getResultList();
		List<tb_collector> tb_collectorList = new ArrayList<tb_collector>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_collector collector = new tb_collector();
				Object[] obj = (Object[]) resultList.get(i);
				collector.setId((int) obj[0]);
				collector.setMacid((int) obj[1]);
				collector.setStartip((int) obj[2]);
				collector.setDatlenth((int) obj[3]);
				collector.setIp(obj[4] == null ? "" : obj[4].toString());
				collector.setMacname(obj[5] == null ? "" : obj[5].toString());
				collector.setPosx((int) obj[6]);
				collector.setPosy((int) obj[7]);
				collector.setAddtime((Date) obj[8]);
				tb_collectorList.add(collector);
			}
		}
		return tb_collectorList;
	}

	public List<tb_collector> searchCollectorManagement(String input) {

		int id = Integer.parseInt(input);
		String sql = null;
		Query query = null;
		sql = "SELECT id,macid,startip,datlenth,ip,macname,posx,posy,addtime FROM tb_collector WHERE id = :id";
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", id);
		List resultList = query.getResultList();
		List<tb_collector> tb_collectorList = new ArrayList<tb_collector>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_collector collector = new tb_collector();
				Object[] obj = (Object[]) resultList.get(i);
				collector.setId((int) obj[0]);
				collector.setMacid((int) obj[1]);
				collector.setStartip((int) obj[2]);
				collector.setDatlenth((int) obj[3]);
				collector.setIp(obj[4] == null ? "" : obj[4].toString());
				collector.setMacname(obj[5] == null ? "" : obj[5].toString());
				collector.setPosx((int) obj[6]);
				collector.setPosy((int) obj[7]);
				collector.setAddtime((Date) obj[8]);
				tb_collectorList.add(collector);
			}
		}
		return tb_collectorList;
	}

	public int getCollectorManagementCount() {
		String sql = null;
		Query query = null;
		sql = "SELECT count(1) FROM tb_collector";
		query = this.em.createNativeQuery(sql);
		return Integer.parseInt(query.getSingleResult().toString());
	}

	@Transactional
	public void collectorManagement_delete(String[] checkVal) {
		String sql = null;
		Query query = null;
		for (int i = 0; i < checkVal.length; i++) {
			int id = Integer.parseInt(checkVal[i]);
			sql = "DELETE FROM tb_collector WHERE id = :id";
			cs.tb_caozuo("tb_collector", 2);
			query = this.em.createNativeQuery(sql);
			query.setParameter("id", id);
			query.executeUpdate();
		}
	}

	@Transactional
	public void collectorManagement_deleteAll() {
		String sql = null;
		Query query = null;
		sql = "DELETE FROM tb_collector";
		cs.tb_caozuo("tb_collector", 2);
		query = this.em.createNativeQuery(sql);
		query.executeUpdate();
	}
	
	@Transactional
	public int collectorManagement_add(tb_collector collector) {
		String sql = null;
		Query query = null;
		sql = "INSERT INTO tb_collector(macid,startip,datlenth,ip,macname,posx,posy,addtime) VALUES(:macid,:startip,:datlenth,:ip,:macname,:posx,:posy,now())";
		cs.tb_caozuo("tb_collector", 1);
		query = this.em.createNativeQuery(sql);
		query.setParameter("macid", collector.getMacid());
		query.setParameter("startip", collector.getStartip());
		query.setParameter("datlenth", collector.getDatlenth());
		query.setParameter("ip", collector.getIp());
		query.setParameter("macname", collector.getMacname());
		query.setParameter("posx", collector.getPosx());
		query.setParameter("posy", collector.getPosy());
		int executeUpdate = query.executeUpdate();
		return executeUpdate;
	}
	
	
	@Transactional
	public int collectorManagement_modify(tb_collector collector) {
		String sql = null;
		Query query = null;
		sql = "UPDATE tb_collector SET macid = :macid,startip = :startip,datlenth = :datlenth,ip = :ip,macname = :macname,posx = :posx,posy = :posy,addtime = now() WHERE id= :id";
		cs.tb_caozuo("tb_collector", 3);
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", collector.getId());
		query.setParameter("macid", collector.getMacid());
		query.setParameter("startip", collector.getStartip());
		query.setParameter("datlenth", collector.getDatlenth());
		query.setParameter("ip", collector.getIp());
		query.setParameter("macname", collector.getMacname());
		query.setParameter("posx", collector.getPosx());
		query.setParameter("posy", collector.getPosy());
		int executeUpdate = query.executeUpdate();
		return executeUpdate;
	}
	
	/**获取某个采集仪所占用的通道数意思就是安装了几个气体传感器*/
	@Transactional
	public int getGasNumber(String ip) {
		String sql = null;
		Query query = null;
		sql = "SELECT count(1) FROM tb_gas WHERE ip = :ip";
		query = this.em.createNativeQuery(sql);
		query.setParameter("ip", ip);
		return Integer.parseInt(query.getSingleResult().toString());	
	}
	
	public List<tb_gas> getGas(String tong_dao ,String ip ) {
		String sql = null;
		Query query = null;
		sql = "SELECT id,wei_zhi,gas_type,nong_du,status,collect_ip,tong_dao,waring_zhi,ip,x,y,addtime FROM tb_gas WHERE ip=:ip AND tong_dao=:tong_dao ";
		query = this.em.createNativeQuery(sql);
		query.setParameter("ip", ip);
		query.setParameter("tong_dao", tong_dao);
		List resultList = query.getResultList();
		List<tb_gas> tb_gasList = new ArrayList<tb_gas>();
		if (resultList.size() > 0) {
			for (int i = 0; i < resultList.size(); i++) {
				tb_gas gas = new tb_gas();
				Object[] obj = (Object[]) resultList.get(i);
				gas.setId((int) obj[0]);
				gas.setWei_zhi(obj[1] == null ? "" : obj[1].toString());
				gas.setGas_type(obj[2] == null ? "" : obj[2].toString());
				gas.setNong_du(obj[3] == null ? "" : obj[3].toString());
				gas.setStatus(obj[4] == null ? "" : obj[4].toString());
				gas.setCollect_ip(obj[5] == null ? "" : obj[5].toString());
				gas.setTong_dao(obj[6] == null ? "" : obj[6].toString());
				gas.setWaring_zhi(obj[7] == null ? "" : obj[7].toString());
				gas.setIp(obj[8] == null ? "" : obj[8].toString());
				gas.setX(obj[9] == null ? "" : obj[9].toString());
				gas.setY(obj[10] == null ? "" : obj[10].toString());
				gas.setAddtime(obj[11] == null ? "" : obj[11].toString());
				tb_gasList.add(gas);
			}
		}
		return tb_gasList;
	}
	
	@Transactional
	public void modifyWarning(tb_gas gas) {
		String sql = null;
		Query query = null;
		sql = "UPDATE tb_gas SET status = :status,nong_du=:nong_du,addtime=now() WHERE id= :id";
		cs.tb_caozuo("tb_gas", 3);
		query = this.em.createNativeQuery(sql);
		query.setParameter("id", gas.getId());
		query.setParameter("status", gas.getStatus());
		query.setParameter("nong_du", gas.getNong_du());
		query.executeUpdate();
	}
	

}