修改日志上报功能

parent 596fcdcd
package com.cc.controller; package com.cc.controller;
import com.cc.model.tbstry; import com.cc.model.tbstry;
import com.cc.service.QueryManager;
import com.cc.utils.Qgckzp; import com.cc.utils.Qgckzp;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestMethod;
...@@ -24,6 +26,8 @@ import static com.cc.utils.querySolr.$; ...@@ -24,6 +26,8 @@ import static com.cc.utils.querySolr.$;
*/ */
@Controller @Controller
public class RyxxController { public class RyxxController {
@Autowired
QueryManager queryManager;
/** /**
* solr查询全国常口 * solr查询全国常口
* *
...@@ -33,8 +37,7 @@ public class RyxxController { ...@@ -33,8 +37,7 @@ public class RyxxController {
@RequestMapping(value = "/ryxxsearch",method = {RequestMethod.POST,RequestMethod.GET}) @RequestMapping(value = "/ryxxsearch",method = {RequestMethod.POST,RequestMethod.GET})
public @ResponseBody Map<String, Object> ryxxsearch(String value)throws Exception { public @ResponseBody Map<String, Object> ryxxsearch(String value)throws Exception {
Map<String, Object> model = new HashMap<String, Object>(); Map<String, Object> model = new HashMap<String, Object>();
Qgckzp getryxx = new Qgckzp(); tbstry ryxx=queryManager.rysearch(value);
tbstry ryxx = getryxx.getQgckAllxxXml(value);
model.put("ryxx",ryxx); model.put("ryxx",ryxx);
return model; return model;
} }
......
...@@ -63,8 +63,8 @@ public class SolrController { ...@@ -63,8 +63,8 @@ public class SolrController {
//System.out.print(solrzy); //System.out.print(solrzy);
String [] solrlist =solrzy.split(":"); String [] solrlist =solrzy.split(":");
//调用solr查询接口 //调用solr查询接口
//model=$list(solrlist,value);//503A1503025500010000005SolrDocument model=$list(solrlist,value);//503A1503025500010000005SolrDocument
model=queryManager.solrsearchlist(solrlist,value); //model=queryManager.solrsearchlist(solrlist,value);
if(!model.get("solrNum").equals("0")){ if(!model.get("solrNum").equals("0")){
nums.add(model); nums.add(model);
//System.out.println("查出数据"+nums.get(0).get("solrList")); //System.out.println("查出数据"+nums.get(0).get("solrList"));
...@@ -78,8 +78,8 @@ public class SolrController { ...@@ -78,8 +78,8 @@ public class SolrController {
public @ResponseBody Map<String, Object> solrsearchdata(String solr,String value,int num,String sort)throws Exception { public @ResponseBody Map<String, Object> solrsearchdata(String solr,String value,int num,String sort)throws Exception {
Map<String, Object> model = new HashMap<String, Object>(); Map<String, Object> model = new HashMap<String, Object>();
//调用solr查询数据接口 //调用solr查询数据接口
//model=$data(solr,value,num,sort); model=$data(solr,value,num,sort);
model=queryManager.solrsearchdata(solr,value,num,sort); //model=queryManager.solrsearchdata(solr,value,num,sort);
return model; return model;
} }
/** /**
......
package com.cc.service; package com.cc.service;
import com.cc.model.tbstry;
import org.apache.solr.client.solrj.SolrServerException; import org.apache.solr.client.solrj.SolrServerException;
import java.io.IOException; import java.io.IOException;
...@@ -11,4 +12,5 @@ public interface QueryManager { ...@@ -11,4 +12,5 @@ public interface QueryManager {
public Map<String, Object> solrsearchlist(String [] solrlist,String value) throws IOException, SolrServerException; public Map<String, Object> solrsearchlist(String [] solrlist,String value) throws IOException, SolrServerException;
public Map<String, Object> solrsearchdata(String solr,String value,int num,String sort) throws IOException, SolrServerException; public Map<String, Object> solrsearchdata(String solr,String value,int num,String sort) throws IOException, SolrServerException;
public tbstry rysearch(String value);
} }
package com.cc.service.imp; package com.cc.service.imp;
import com.cc.model.tbstry;
import com.cc.service.QueryManager; import com.cc.service.QueryManager;
import com.cc.utils.Qgckzp;
import org.apache.solr.client.solrj.SolrServerException; import org.apache.solr.client.solrj.SolrServerException;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -32,4 +34,13 @@ public class QueryManagerImpl implements QueryManager { ...@@ -32,4 +34,13 @@ public class QueryManagerImpl implements QueryManager {
return $data(solr,value,num,sort); return $data(solr,value,num,sort);
} }
@Override
public tbstry rysearch(String value) {
Qgckzp getryxx = new Qgckzp();
//tbstry ryxx = getryxx.getQgckAllxxXml(value);
tbstry ryxx =new tbstry();
return ryxx;
}
} }
...@@ -46,10 +46,10 @@ public class LogAdvice { ...@@ -46,10 +46,10 @@ public class LogAdvice {
//传入参数 //传入参数
Object[] objArray = joinPoint.getArgs(); Object[] objArray = joinPoint.getArgs();
String objParam=""; String objParam="";
String yymc="智能查询"; String yymc="智能检索";
String cznr=""; String cznr="";
if(null!=methodSignatureName&&methodSignatureName!=""){ if(null!=methodSignatureName&&methodSignatureName!=""){
objParam="zjhm:"+objArray[1]; objParam="zjhm:"+objArray[0];
} }
czlxdm="01"; czlxdm="01";
cznr="执行[查询]动作,参数为:"+objParam; cznr="执行[查询]动作,参数为:"+objParam;
......
...@@ -58,7 +58,8 @@ http://cxf.apache.org/schemas/jaxws.xsd"> ...@@ -58,7 +58,8 @@ http://cxf.apache.org/schemas/jaxws.xsd">
<aop:config> <aop:config>
<!-- 切入点表达式 --> <!-- 切入点表达式 -->
<aop:pointcut expression="execution(* com.cc.service..*(..))" id="txPoint"/> <!--<aop:pointcut expression="execution(* com.cc.service..*(..))" id="txPoint"/>-->
<aop:pointcut expression="execution(* com.cc.service.*.ry*(..))" id="txPoint"/>
<!-- 配置事务增强 --> <!-- 配置事务增强 -->
<aop:advisor advice-ref="txAdvice" pointcut-ref="txPoint"/> <aop:advisor advice-ref="txAdvice" pointcut-ref="txPoint"/>
</aop:config> </aop:config>
......
...@@ -16,7 +16,7 @@ version=@project.version@ ...@@ -16,7 +16,7 @@ version=@project.version@
————————————————————@project.version@-—————————————————————————— ————————————————————@project.version@-——————————————————————————
#1.名称:修改日志存入功能;类别:02;描述:解决重复数据存入问题。
————————————————————@project.version@-—————————————————————————— ————————————————————@project.version@-——————————————————————————
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment