New password: " + newPass; + + + String answer = ""; + try { + EmailUtility.sendEmail(mail_host, mail_port, mail_login, mail_password, recipient, subject, content); + answer = "New password was sent successfully on \"" + recipient + "\".\nIf there is no email then check the spam folder."; + } catch (Exception ex) { + logger.info(ex.getMessage()); + answer = "There were an error: " + ex.getMessage(); + //error=true; + } finally { + //request.setAttribute("Message", resultMessage); + //context.getRequestDispatcher("/Result.jsp").forward(request, response); + } + + if (!mEerror) { + try { + Statement stt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); + stt.execute("update main._users set password=md5('" + newPass + "') where email=lower('" + login + "');"); + stt.close(); + stt=null; + } catch (SQLException ex) { + logger.info(ex.getMessage()); + xmlstring = "
Password: " + newPass; + + //String answer = ""; + try { + EmailUtility.sendEmail(mail_host, mail_port, mail_login, mail_password, recipient, subject, content); + //answer = "New password was sent successfully on \"" + recipient + "\".\nIf there is no email then check the spam folder."; + } catch (Exception ex) { + logger.info(ex.getMessage()); + //answer = "There were an error: " + ex.getMessage(); + } finally { + //request.setAttribute("Message", resultMessage); + //context.getRequestDispatcher("/Result.jsp").forward(request, response); + } + + } + } catch (SQLException ex) { + logger.info(ex.getMessage()); + } + } + rs.close(); + stt.close(); + rs=null; + stt=null; + } catch (SQLException ex) { + logger.info(ex.getMessage()); + xmlstring = "
"; + + try { + Statement stt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); + ResultSet rs = stt.executeQuery("select Coalesce(surname,'') || ' ' || Coalesce(name,'') || ' ' || Coalesce(patronymic,'') as name from main._users where id=" + user.id + ""); + if (rs != null) { + try { + while (rs.next()) { + uName = "" + rs.getString("name") + "
"; + } + } catch (SQLException ex) { + logger.info(ex.getMessage()); + } + } + rs.close(); + stt.close(); + rs=null; + stt=null; + } catch (SQLException ex) { + logger.info(ex.getMessage()); + result="
"; + expr = xpath.compile("objects-list/filter/column"); + exprResult = expr.evaluate(nTypeR, XPathConstants.NODESET); + nodeList = (NodeList) exprResult; + for(int i=0;i
"; + } + } + */ + + String sql_query=""; + try { + sql_query = (String) xpath.compile("objects-list/sql-query/text()").evaluate(nTypeS, XPathConstants.STRING); + } catch (XPathExpressionException ex) { + logger.info(ex.getMessage()); + } + + //sql_query=Tools.replaceAll(sql_query,"${id}","null"); + //logger.info("sql_query1 = " + sql_query); + + Node nextnode = f1.getFirstChild(); + while (nextnode != null) { + if (nextnode.getNodeName().equals("column")) { + try { + String vn = nextnode.getAttributes().getNamedItem("n").getNodeValue(); + /*String size; + Node n = nextnode.getAttributes().getNamedItem("size"); + if (n != null) { + size = n.getNodeValue(); + }*/ + String vt = nextnode.getAttributes().getNamedItem("vt").getNodeValue(); + String val = getCharacterDataFromElement((Element) nextnode); + + val = getSQLValue(vt, val); + + sql_query = Tools.replaceAll(sql_query,"${" + vn + "}", val); + } catch (Exception ex) { + logger.info(ex.getMessage()); + } + } + nextnode = nextnode.getNextSibling(); + } + sql_query = Tools.replaceAll(sql_query,"${_user_id}", (String) user.id); //Set current user id in sql query. + + //logger.info("sql_query2 = " + sql_query); + + + try { + Statement stt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); + ResultSet rs = stt.executeQuery(sql_query); + if (rs != null) { + //Create Excel file and write result set + Writer writer = null; + Random rand = new Random(); + String tmpName = "file_" + rand.nextInt(1000) + ".xls"; //TODO Not safety, the file names can match. + + try { + String tmpPath = data_dir + "temp" + File.separator; + File file = new File(tmpPath); + if (!file.exists()) { + file.mkdirs(); + } + + writer = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(tmpPath + tmpName), "utf-8")); + + writer.write("\n"); + writer.write(" \n"); + writer.write("
"); + writer.write("" + __("Creator",user,conn) + ": " + uName); + + //writer.write(filter); + + xPathfactory = XPathFactory.newInstance(); + xpath = xPathfactory.newXPath(); + try { + expr = xpath.compile("objects-list/@d"); + + writer.write("
| " + getText(nodeList.item(i).getAttributes().getNamedItem("d").getNodeValue(),user,conn) + + " | "); + } + writer.write("
| " + val + " | "); + } + writer.write("
"); + + javax.xml.xpath.XPathFactory xPathfactory = XPathFactory.newInstance(); + XPath xpath = xPathfactory.newXPath(); + XPathExpression expr=null; + + Object exprResult=null; + try { + expr = xpath.compile("//metadata/type[@n='" + typename + "']"); + exprResult = expr.evaluate(doc, XPathConstants.NODESET); + } catch (XPathExpressionException ex) { + logger.info(ex.getMessage()); + } + NodeList nodeList = (NodeList) exprResult; + + Node nTypeS = null; + if (nodeList.getLength() > 0) + nTypeS = nodeList.item(0); + + try { + expr = xpath.compile("properties/prop[@n='"+field+"']/@path"); + path = (String) expr.evaluate(nTypeS, XPathConstants.STRING); + } catch (XPathExpressionException ex) { + logger.info(ex.getMessage()); + } + } + + if(path!=null && !path.equals("")) + { + ResultSet rs = null; + try { + String sql="SELECT "+field+" as name FROM main."+typename+" WHERE id="+String.valueOf(id); + rs = stt.executeQuery(sql); + } catch (SQLException ex) { + logger.info(ex.getMessage()); + } + if (rs != null) { + try { + if (rs.next()) + filename = rs.getString(1); + rs.close(); + } catch (SQLException ex) { + logger.info(ex.getMessage()); + } + } + if(!filename.equals("")) + { + file = new File(path+File.separator+filename); + } + } + + if(conn!=null){try{conn.close();}catch(SQLException ex){}} + + response.setContentType("application/octet-stream"); + response.setHeader("Content-Disposition", "attachment; filename="+afterFirst(filename,"_")); + response.setHeader("Cache-Control", "no-cache"); + return new FileSystemResource(file); + } + + + @RequestMapping(value = "/upload", method = { RequestMethod.GET, RequestMethod.POST }) + @ResponseBody + public String uploadFile(HttpServletResponse response,@RequestParam(required=false,name="file") MultipartFile file) { + + String result=""; + String data_dir=""; + + + try { + String fullPath = context.getRealPath("/WEB-INF/config.xml"); + + File fXmlFile = new File(fullPath); + DocumentBuilderFactory dbFactory = DocumentBuilderFactory.newInstance(); + DocumentBuilder dBuilder = dbFactory.newDocumentBuilder(); + Document doc = dBuilder.parse(fXmlFile); + Element nMain = doc.getDocumentElement(); + NodeList nl = nMain.getChildNodes(); + for (int i = 0; i < nl.getLength(); i++) { + if (nl.item(i).getNodeName().equals("data-dir")) + data_dir = nl.item(i).getTextContent(); + } + } catch (Exception ex) { + logger.info(ex.getMessage()); + } + + + String fileName = ""; + + if (file!=null && !file.isEmpty()) { + try { + + byte[] bytes = file.getBytes(); + fileName = file.getOriginalFilename(); + + File dir = new File(data_dir); + if (!dir.exists()) dir.mkdirs(); + + BufferedOutputStream stream = new BufferedOutputStream(new FileOutputStream(new File(data_dir + fileName))); + stream.write(bytes); + stream.flush(); + stream.close(); + + //Calc CRC32 + long crc32=0; + FileInputStream fin = new FileInputStream(data_dir + fileName); + Checksum sum_control = new CRC32(); + for (int b = fin.read(); b != -1; b = fin.read()) { + sum_control.update(b); + } + crc32 = sum_control.getValue(); + fin.close(); + + //To be rename file, add CRC32 in begin. + File srcFile = new File(data_dir + fileName); + File destFile = new File(data_dir + Long.toHexString(crc32) +"_"+ fileName); + FileUtils.copyFile(srcFile, destFile); + FileUtils.forceDelete(srcFile); + + //logger.info("Uploaded Filename: " + Long.toHexString(crc32) +"_"+ fileName); + result+="ok=" + Long.toHexString(crc32) +"_"+ fileName + "\n"; + + } catch (Exception ex) { + logger.info(ex.getMessage()); + } + } + + //This code put into iframe + response.setContentType("text/html"); + + result+=""; + result+=""; + result+=" "; + result+=" "; + result+=" "; + result+=" "; + result+=" "; + result+=" "; + result+=""; + + //deleteTempFiles($dir); + + return result; + } + + //Send generated report to the client for downloading + @RequestMapping(value = "/reports",method = RequestMethod.GET, produces = "application/octet-stream") + @ResponseBody + public FileSystemResource sendReport(HttpServletResponse response,@RequestParam(required=true,name="file") String fileName) { + String data_dir = ""; + //Load DB configuration from "config.xml" + try { + String fullPath = context.getRealPath("/WEB-INF/config.xml"); + + File fXmlFile = new File(fullPath); + DocumentBuilderFactory dbFactory = DocumentBuilderFactory.newInstance(); + DocumentBuilder dBuilder = dbFactory.newDocumentBuilder(); + Document doc = dBuilder.parse(fXmlFile); + Element nMain = doc.getDocumentElement(); + NodeList nl = nMain.getChildNodes(); + for (int i = 0; i < nl.getLength(); i++) { + if (nl.item(i).getNodeName().equals("data-dir")) + data_dir = nl.item(i).getTextContent(); + } + } catch (Exception ex) { + logger.info(ex.getMessage()); + } + + + File file = new File(data_dir + "temp" + File.separator + fileName); + if(file.exists()) + { + //logger.info("Send report: " + fileName); + + //response.setContentType("application/octet-stream"); //Commented because it is specified in the function declaration. + response.setHeader("Content-Disposition","attachment; filename="+fileName); + response.setContentLength((int) file.length()); + return new FileSystemResource(file); + }else + { + logger.info("File not found: " + fileName); + return null; + } + } + + String getSQLValue(String t, String v) { + //if($t=='object' && (strtoupper($v)!='NULL' && gettype($v)=='string')) $t='string'; //Если id шники uuid + + //if(t.equals("object")) t="string"; + + if (t.equals("object") || t.equals("uid")) { + if (v.equals("")) + v = "NULL"; + } else if (t.equals("i4") || t.equals("integer")) { + if (v.equals("")) + v = "NULL"; + } else if (t.equals("f8")) { + if (v.equals("")) + v = "NULL"; + v = Tools.replaceAll(v,",", "."); //The decimal part: point. + } else if (t.equals("f4")) { + if (v.equals("")) + v = "NULL"; + v = Tools.replaceAll(v,",", "."); //The decimal part: point. + } else if (t.equals("b")) { + if (v.equals("")) + v = "NULL"; + else if (v.equals("1")) + v = "true"; + else if (v.equals("0")) + v = "false"; + } else if (t.equals("string") || t.equals("text") || t.equals("dateTime") || t.equals("date")) { + if (v.equals("")) { + v = "NULL"; + } else { + v = Tools.replaceAll(v,"'", "''"); + v = "'" + v + "'"; + } + } else { + v = "'" + v + "'"; + } + return v; + } + + private String nodeToString(Node node) { + StringWriter sw = new StringWriter(); + try { + Transformer t = TransformerFactory.newInstance().newTransformer(); + t.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes"); + t.transform(new DOMSource(node), new StreamResult(sw)); + } catch (TransformerException ex) { + System.out.println(ex.getMessage()); + System.out.println("nodeToString Transformer Exception"); + } + return sw.toString(); + } + + //Replace all the values of the first filter values from the second + public void setFilter(Node n1, Node n2) { + if (n1 == null || n2 == null) + return; + + XPathFactory xPathfactory = XPathFactory.newInstance(); + XPath xpath = xPathfactory.newXPath(); + + Node nc1 = n1.getFirstChild(); + while (nc1 != null) { + if (nc1.getNodeName().equals("column")) { + try { + String path = "column[@n='" + nc1.getAttributes().getNamedItem("n").getNodeValue() + "']"; + XPathExpression expr = xpath.compile(path); + NodeList nodeList = (NodeList) expr.evaluate(n2, XPathConstants.NODESET); + if (nodeList.getLength() > 0) { + Node nc2 = nodeList.item(0); + + setCharacterDataToElement((Element) nc1, getCharacterDataFromElement((Element) nc2)); + + //getCdata($nc1)->nodeValue=getCdata($nc2)->nodeValue; + } + + } catch (Exception ex) { + System.out.println(ex.getMessage()); + //String message = "XML parsing error!"; + //return; + } + } + nc1 = nc1.getNextSibling(); + } + } + + public static String getCharacterDataFromElement(Element e) { + Node child = e.getFirstChild(); + if (child instanceof CharacterData) { + CharacterData cd = (CharacterData) child; + return cd.getData().trim(); + } + return ""; + } + + public void setCharacterDataToElement(Element e, String data) { + Node child = e.getFirstChild(); + if (child instanceof CharacterData) { + CharacterData cd = (CharacterData) child; + cd.setData(data); + } else //Create new CDATA node + { + Document doc = e.getOwnerDocument(); + e.appendChild(doc.createCDATASection(data)); + } + } + + public static String getRandomString(int length) { + final String characters = "abcdefghijklmnopqrstuvwxyz1234567890"; + StringBuilder result = new StringBuilder(); + while (length > 0) { + Random rand = new Random(); + result.append(characters.charAt(rand.nextInt(characters.length()))); + length--; + } + return result.toString(); + } + + //Перевести слово по идентификатору из базы + public String __(String key,User user,Connection conn) + { + String result=""; + ResultSet rs=null; + Statement st = null; + try { + st = conn.createStatement(); + String sql = "select t.translation from main._translations t where t.identifier='"+key+"' and t.language_id='"+user.language_id+"';"; + rs = st.executeQuery(sql); + if(rs != null) { + if (rs.next()) { + result = rs.getString(1); + } + } + } catch( SQLException ex ) + { + logger.info(ex.getMessage()); + }finally{ + if(st!=null) try{st.close();}catch(SQLException ex) {} + if(rs!=null) try{rs.close();}catch(SQLException ex) {} + } + + /*if(result.equals("")) + { + if(m_props==null || !user.language_id.equals(m_props_loc)) + { + m_props_loc = user.language_id; + + InputStream utf8in = getClass().getClassLoader().getResourceAsStream("messages_"+m_props_loc+".properties"); + Reader reader; + try { + reader = new InputStreamReader(utf8in, "UTF-8"); + m_props = new Properties(); + m_props.load(reader); + } catch (IOException ex) { + logger.info(ex.getMessage()); + } + } + result = m_props.getProperty(key,""); + }*/ + + if(result.equals("")) + { + result = Tools.replaceAll(key,"_", " "); + } + return result; + } + + //Translate text by patterns + public String getText(String text,User user,Connection conn) { + int pos1 = 0; + while (true) { + pos1 = text.indexOf("_('", pos1); + if (pos1 == -1) + break; + int pos2 = text.indexOf("')", pos1); + if (pos2 == -1) + break; + + text = text.substring(0, pos1) + __(text.substring(pos1 + 3, pos2),user,conn) + text.substring(pos2 + 2); + } + return text; + } + + public static String afterFirst(String str, String ch) + { + int i=str.indexOf(ch); + if(i!=-1) + { + return str.substring(i+ch.length()); + } + return ""; + } + + //Получить узел метаданных из базы данных + public String getTypeStrNode(Connection conn,String typeName) + { + String result=""; + String sql="select xml from main._metadata where name='"+typeName+"';"; + try { + Statement st = conn.createStatement(); + ResultSet rs=null; + try { + rs = st.executeQuery(sql); + } catch( SQLException ex ) { + ex.printStackTrace(); + } + try { + if(rs!=null) + { + if(rs.next()) + { + result=rs.getString(1); + } + rs.close(); + } + st.close(); + } catch (SQLException ex) { + ex.printStackTrace(); + } + } catch (SQLException ex) { + ex.printStackTrace(); + } + return result; + } + + //Пропарсить сткоку в DOM + public Document parseString(String xml) + { + Document doc=null; + try { + DocumentBuilderFactory dbFactory = DocumentBuilderFactory.newInstance(); + DocumentBuilder dBuilder = dbFactory.newDocumentBuilder(); + doc = dBuilder.parse(new InputSource(new StringReader(xml))); + } catch (Exception ex) { + ex.printStackTrace(); + } + return doc; + } + +} \ No newline at end of file diff --git a/metadata/dbms/DBMSTree.java b/metadata/dbms/DBMSTree.java new file mode 100644 index 0000000..29e57c2 --- /dev/null +++ b/metadata/dbms/DBMSTree.java @@ -0,0 +1,457 @@ +package kz.goodssales.GoodsSales.dbms; + +import java.io.ByteArrayInputStream; +import java.io.File; +import java.io.InputStream; +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.sql.Statement; + +import javax.servlet.ServletContext; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.xpath.XPath; +import javax.xml.xpath.XPathConstants; +import javax.xml.xpath.XPathExpression; +import javax.xml.xpath.XPathExpressionException; +import javax.xml.xpath.XPathFactory; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.ModelAttribute; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestMethod; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.SessionAttributes; +import org.springframework.web.context.ServletContextAware; +import org.w3c.dom.DOMException; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + +import tctable.Tools; +import tools.User; +import tools.XMLTools; + +@Controller +@SessionAttributes( { "user" }) //Сесионный объект +public class DBMSTree implements ServletContextAware { + + private static final Logger logger = LoggerFactory.getLogger(kz.goodssales.GoodsSales.dbms.DBMSTree.class); + private ServletContext context; + + //If not created object "user", create him. + @ModelAttribute("user") + public User populatePerson() { + return new User("none"); + } + + @RequestMapping(value = "/tree",method = RequestMethod.POST,produces = "application/xml; charset=utf-8") + @ResponseBody + public Object ajaxTamer(@ModelAttribute User user,@RequestBody byte[] reqData,@RequestParam(required=false,name="lng") String language_id) { + + if(language_id!=null && !language_id.equals("")) + user.language_id=language_id; + + logger.info("user.id="+user.id+" user.name="+user.name+" user.language_id="+user.language_id+" user.country_id="+user.country_id); + + boolean error=false; + String result="
 |
 |