Commit 3ceed9cd by 雷紫添

去掉原采集中的代码

parent 3b5b288d
......@@ -76,8 +76,14 @@
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>${guava.version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.aspectj/aspectjweaver -->
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.13</version>
</dependency>
<!-- 数据库驱动包 -->
<dependency>
<groupId>org.oracle</groupId>
......@@ -116,54 +122,8 @@
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
<!--采集生成js文件功能 -->
<dependency>
<groupId>com.founder</groupId>
<artifactId>jwzh-framework-utils</artifactId>
<version>${jwzh.framework.version}</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
<exclusion> <groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.founder</groupId>
<artifactId>jwzh-framework-base-server</artifactId>
<version>${jwzh.framework.version}</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.founder</groupId>
<artifactId>jwzh-manage-api</artifactId>
<version>${jwzh.manager-api.version}</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
<build>
......@@ -199,37 +159,18 @@
</resource>
</resources>
</build>
<repositories>
<repository>
<id>founder</id>
<url>http://39.99.224.27:8081/nexus/content/groups/public/</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
<repository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/snapshot</url>
<id>aliyun-repos</id>
<url>https://maven.aliyun.com/mvn/view</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
<repository>
<id>release</id>
<name>release</name>
<url>https://maven2.pavlab.msl.ubc.ca/</url>
<id>aliyun-repos-guide</id>
<url>https://maven.aliyun.com/mvn/guide</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
......@@ -237,37 +178,13 @@
</repositories>
<pluginRepositories>
<!-- 公司的maven plugin仓库 -->
<pluginRepository>
<id>founder</id>
<url>http://39.99.224.27:8081/nexus/content/groups/public/</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</pluginRepository>
<pluginRepository>
<id>spring-snapshots</id>
<name>Spring Snapshots</name>
<url>https://repo.spring.io/snapshot</url>
<snapshots>
<enabled>true</enabled>
</snapshots>
</pluginRepository>
<pluginRepository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
<id>aliyun-plugin</id>
<url>https://maven.aliyun.com/nexus/content/groups/public/</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</pluginRepository>
<pluginRepository>
<id>release</id>
<name>release</name>
<url>https://maven2.pavlab.msl.ubc.ca/</url>
</pluginRepository>
</pluginRepositories>
</project>
package com.founder.config;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import javax.sql.DataSource;
/**
* Created by summer on 2016/11/25.
*/
@Configuration
@MapperScan(basePackages = "com.founder.dictmanager.dao", sqlSessionTemplateRef = "managerSqlSessionTemplate")
public class DataSourceManagerConfig {
@Bean(name = "managerDataSource")
@ConfigurationProperties(prefix = "spring.datasource.manager")
public DataSource managerDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "managerSqlSessionFactory")
public SqlSessionFactory managerSqlSessionFactory(@Qualifier("managerDataSource") DataSource dataSource) throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mybatis/managerMapper/*.xml"));
return bean.getObject();
}
@Bean(name = "managerSqlSessionTemplate")
public SqlSessionTemplate managerSqlSessionTemplate(@Qualifier("managerSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
package com.founder.dao;
import com.founder.dictmanager.model.SysXxyyfwGzxx;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.Map;
@Component
@Mapper
public interface SysXxyyfwGzxxDao {
public String test();
//public int queryCount(Map<String,Object> param);
public List<SysXxyyfwGzxx> queryPageList(Map<String, Object> param);
int update(SysXxyyfwGzxx sysXxyyfwGzxx);
int queryUnDealCodeCount();
}
package com.founder.dictmanager.controller;
import com.founder.dictmanager.model.GabXfdm;
import com.founder.dictmanager.service.DictService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.List;
@Controller
public class SysDictManagerController {
@Autowired
private DictService sysDictService;
@RequestMapping("/test")
@ResponseBody
public void test(){
sysDictService.test();
}
@RequestMapping("/updateDict")
@ResponseBody
public void updateDict(){
List<GabXfdm> lists=sysDictService.getGabXfdmRows(1);
int r= -1;
try {
//r = sysDictService.updateManagerDict(lists.get(0));
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("更新行数:"+r);
}
@RequestMapping("/updateTestOrgDict")
@ResponseBody
public void updateOrgDict(){
GabXfdm gabXfdm=new GabXfdm();
gabXfdm.setBghdm("测试代码");
gabXfdm.setBghmc("测试部门");
gabXfdm.setSyjdm("测试上级代码");
gabXfdm.setSyjmc("测试上级名称");
gabXfdm.setId("014");
gabXfdm.setBghdm("670000000000");
gabXfdm.setBglx("1");
int r= -1;
try {
r = sysDictService.updateManagerDict(gabXfdm);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("更新行数:"+r);
}
@RequestMapping("/updateDicts")
@ResponseBody
public void updateDicts(int rows){
if(rows<=0){
return;
}
List<GabXfdm> lists=sysDictService.getGabXfdmRows(rows);
int r= -1;
try {
//r = sysDictService.updateManagerDict(lists.get(0));
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("更新行数:"+r);
}
}
package com.founder.dictmanager.dao.manager;
import com.founder.dictmanager.model.OrganizitionForManager;
import com.founder.dictmanager.model.SysDictForManager;
import com.founder.dictmanager.model.SysDictGl;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
@Component
@Mapper
public interface ManagerSysDictDao {
public String test();
int insertSysDict(SysDictForManager sysDictForManager);
//int addSysDictGl();
OrganizitionForManager queryOrganizition(OrganizitionForManager paramOrg);
int insertOrganizition(OrganizitionForManager organizition);
int updateOrganizition(OrganizitionForManager organizition);
int updateSysDict(SysDictForManager sysDictForManager);
SysDictForManager querySysDict(SysDictForManager paramCode);
void deleteRepeatDict(SysDictForManager sysDictForManager);
void deleteRepeatOrgDict(OrganizitionForManager organizition);
SysDictGl querySysDictGl(SysDictGl paramCode);
}
package com.founder.dictmanager.dao.manager;
import com.founder.framework.base.entity.SessionBean;
import com.founder.framework.utils.EasyUIPage;
import com.founder.dictmanager.model.SysDictForManager;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
@Mapper
public interface SysDictDao {
List<SysDictForManager> queryListByZdbh(String zdbh);
EasyUIPage queryList(EasyUIPage page, SysDictForManager entity);
SysDictForManager query(SysDictForManager entity);
void update(SysDictForManager entity, SessionBean sessionBean);
void delete(SysDictForManager entity, SessionBean sessionBean);
boolean existDm(SysDictForManager entity);
String getDictCt(String zdbh, String dm);
String getDictDm(String zdbh, String ct);
List<SysDictForManager> querListByGlid(Long glid);
List<SysDictForManager> queryDictForCustomize(String querySql);
}
package com.founder.dictmanager.dao.manager;
import com.founder.dictmanager.model.SysDictGl;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
@Mapper
public interface SysDictGlDao {
List<SysDictGl> queryAll();
SysDictGl query(SysDictGl entity);
}
package com.founder.dictmanager.dictionary.api;
import com.founder.dictmanager.dao.manager.SysDictDao;
import com.founder.dictmanager.dao.manager.SysDictGlDao;
import com.founder.dictmanager.dictionary.service.DictOtherCreator;
import com.founder.dictmanager.dictionary.service.DictTreeCreator;
import com.founder.dictmanager.dictionary.service.SysDictServiceImpl;
import com.founder.dictmanager.model.SysDictGl;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.sql.SQLException;
import java.util.List;
@Service("SysDictJsFileService")
public class SysdictServiceApi {
private static Logger logger = LoggerFactory.getLogger(SysdictServiceApi.class);
@Value("${jslocation}")
private String JSPath;
@Autowired
private SysDictGlDao sysDictGlDao;
@Autowired
private SysDictDao sysDictDao;
@Autowired
private SysDictServiceImpl sysDictService;
public void checkJSFile() throws Exception {
List<SysDictGl> list = this.sysDictGlDao.queryAll();
for(int i = 0; i < list.size(); ++i) {
SysDictGl entity = list.get(i);
String zdywm = entity.getZdywm();
if ("GB_D_XZQHDM".equals(zdywm)) {
this.createJS(entity);
}
//this.createJS(entity);
}
}
public void createJS(SysDictGl entity) throws SQLException, IOException {
SysDictGl dbEntity = this.sysDictGlDao.query(entity);
String zdsclb = dbEntity.getZdsclb();
String zdywm = dbEntity.getZdywm();
String zdzwm = dbEntity.getZdzwm();
//3-自定义 2-树形 1-列表
try {
Class classObject;
if ("3".equals(zdsclb)) {
classObject = Class.forName("com.founder.dictmanager.dictionary.service.DictOther_" + zdywm);
DictOtherCreator creator = (DictOtherCreator)classObject.newInstance();
creator.setSysDictDao(this.sysDictDao);
creator.setJSPath(JSPath);
creator.createOtherJS(zdywm, zdzwm);
} else if ("2".equals(zdsclb)) {
classObject = Class.forName("com.founder.dictmanager.dictionary.service.DictTree_" + zdywm);
DictTreeCreator creator = (DictTreeCreator)classObject.newInstance();
creator.setSysDictDao(this.sysDictDao);
creator.setJSPath(JSPath);
creator.createTreeJS(zdywm, zdzwm);
} else {
this.sysDictService.createListJS(zdywm, zdzwm);
}
} catch (Exception var8) {
logger.error("生成字典JS文件 :" + zdywm + ".js 出错: " + var8.getMessage(), var8);
System.out.println("文件 :" + zdywm + ".js 创建失败!");
}
}
}
package com.founder.dictmanager.dictionary.controller;
import com.alibaba.fastjson.JSON;
import com.founder.framework.components.AppConst;
import com.founder.dictmanager.dictionary.api.SysdictServiceApi;
import com.founder.dictmanager.model.SysDictGl;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.servlet.ModelAndView;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;
@Controller
@RequestMapping(value = "sysDictGl")
public class SysDictGlController {
private Logger logger = LoggerFactory.getLogger(this.getClass());
@Resource(name = "SysDictJsFileService")
private SysdictServiceApi sysDictGlService;
@RequestMapping(value = "/query", method = RequestMethod.GET)
public ModelAndView query() {
ModelAndView mv = new ModelAndView("dictionary/sysDictGl");
return mv;
}
@RequestMapping(value = "/queryCondition", method = RequestMethod.GET)
public ModelAndView queryCondition() {
ModelAndView mv = new ModelAndView("dictionary/sysDictGlQueryCondition");
return mv;
}
@RequestMapping(value = "/add", method = RequestMethod.GET)
public ModelAndView add() {
ModelAndView mv = new ModelAndView("dictionary/sysDictGlAdd");
return mv;
}
@RequestMapping(value = "/createJS", method = RequestMethod.POST)
public ModelAndView createJS(SysDictGl entity) {
ModelAndView mv = new ModelAndView("redirect:/forward/"
+ AppConst.FORWORD);
Map<String, Object> model = new HashMap<String, Object>();
try {
if (entity.getId() != null) { // 注销
sysDictGlService.createJS(entity);
model.put(AppConst.STATUS, AppConst.SUCCESS);
model.put(AppConst.MESSAGES, "生成JS文件成功!");
}
} catch (Exception e) {
logger.error(e.getLocalizedMessage(), e);
model.put(AppConst.STATUS, AppConst.FAIL);
model.put(AppConst.MESSAGES, "生成JS文件成功失败!");
}
mv.addObject(AppConst.MESSAGES, JSON.toJSON(model));
return mv;
}
}
package com.founder.dictmanager.dictionary.service;
import com.founder.dictmanager.dao.manager.SysDictDao;
import com.founder.dictmanager.model.SysDictForManager;
import org.springframework.beans.factory.annotation.Value;
import java.util.List;
import java.util.Map;
public abstract class DictOtherCreator {
private SysDictDao sysDictDao;
public String getJSPath() {
return JSPath;
}
public void setJSPath(String JSPath) {
this.JSPath = JSPath;
}
@Value("${JSPath}")
protected String JSPath;
public void setSysDictDao(SysDictDao sysDictDao) {
this.sysDictDao = sysDictDao;
}
public SysDictDao getSysDictDao() {
return sysDictDao;
}
/**
* 创建其他字典JS文件<br>
*
* @param zdbh
* 字典类别
* @param zdbhMc
* 字典名称
* @throws Exception void
*/
public abstract void createOtherJS(String zdbh, String zdbhMc)
throws Exception;
/**
* 根据代码取得其他字典的词条<br>
*
* @param zdbh
* @param dm
* @return
* @throws Exception
* String
*/
public abstract String getDictCt(String zdbh, String dm) throws Exception;
/**
* 获得字典的列表<br>
*
* @param zdbh
* @return List
*/
public abstract List<SysDictForManager> getDictList(String zdbh);
/**
* 获得字典的集合<br>
*
* @param zdbh
* @return HashMap
*/
public abstract Map<String, String> getDictMap(String zdbh);
}
package com.founder.dictmanager.dictionary.service;
import com.founder.dictmanager.dao.manager.SysDictDao;
import org.springframework.beans.factory.annotation.Value;
public abstract class DictTreeCreator {
private SysDictDao sysDictDao;
@Value("${JSPath}")
protected String JSPath;
public String getJSPath() {
return JSPath;
}
public void setJSPath(String JSPath) {
this.JSPath = JSPath;
}
public void setSysDictDao(SysDictDao sysDictDao) {
this.sysDictDao = sysDictDao;
}
public SysDictDao getSysDictDao() {
return sysDictDao;
}
/**
* 创建树形字典JS文件<br>
*
* @param zdbh
* 字典类别
* @param zdbhMc
* 字典名称
* @throws Exception void
*/
public abstract void createTreeJS(String zdbh, String zdbhMc)
throws Exception;
}
package com.founder.dictmanager.dictionary.service;
import com.founder.framework.utils.StringUtils;
import com.founder.framework.utils.TreeDataBuilder;
import com.founder.framework.utils.TreeNode;
import com.founder.dictmanager.model.SysDictForManager;
import java.io.FileOutputStream;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.util.ArrayList;
import java.util.List;
/**
* 编写方法测试,未使用。行政区划
* Created by Founder on 2017/4/27.
*/
public class DictTree_GB_D_XZQHDM extends DictTreeCreator {
private String treeName="籍贯省市县代码";
public DictTree_GB_D_XZQHDM(){
}
@Override
public void createTreeJS(String zdbh, String zdbhMc) throws Exception {
List<SysDictForManager> dictList = super.getSysDictDao().queryListByZdbh(zdbh);
if (dictList != null && dictList.size() > 0) { // 有数据
String dm,xt_zxbz;
//分组
List<SysDictForManager> dictList1=new ArrayList<>();//一级
List<SysDictForManager> dictList2=new ArrayList<>();//二级
List<SysDictForManager> dictList3=new ArrayList<>();//三级
for(int i = 0; i < dictList.size(); i++ ){
xt_zxbz = StringUtils.nullToStr(dictList.get(i).getXtZxbz());
if ("1".equals(xt_zxbz)) {
continue;
}
dm = dictList.get(i).getDm();
if(dm.endsWith("0000")){//第一级判定条件
dictList1.add(dictList.get(i));
}else if(dm.endsWith("00")&&!dm.endsWith("0000")){//第二级判定条件
dictList2.add(dictList.get(i));
}else if(!dm.endsWith("00")&&!dm.endsWith("0000")){//第三级判定条件
dictList3.add(dictList.get(i));
}
}
List<TreeNode> nodeList1 = new ArrayList<TreeNode>();//根节点
for(int j1 = 0; j1 < dictList1.size(); j1++) {//遍历根节点
String dm1 = dictList1.get(j1).getDm();
TreeNode treeNode1 = new TreeNode();
String mc1 = dictList1.get(j1).getCt();
String py1 = dictList1.get(j1).getPy();
treeNode1.setId(dm1);
treeNode1.setText(mc1);
treeNode1.setPy(py1);
String dmflag1=dm1.substring(0,2);//前两位相同
List<TreeNode> nodeList2 = new ArrayList<TreeNode>();//子节点
for (int j2 = 0; j2 < dictList2.size(); j2++) {//遍历子节点
String dm2 = dictList2.get(j2).getDm();
if(dm2.startsWith(dmflag1)){
String mc2 = dictList2.get(j2).getCt();
String py2= dictList2.get(j2).getPy();
TreeNode treeNode2 = new TreeNode();
treeNode2.setId(dm2);
treeNode2.setText(mc2);
treeNode2.setPy(py2);
String dmflag2=dm2.substring(0,4);//前四位相同
List<TreeNode> nodeList3 = new ArrayList<TreeNode>();//孙节点
for (int j3 = 0; j3 < dictList3.size(); j3++) {//遍历孙节点
String dm3 = dictList3.get(j3).getDm();
if(dm3.startsWith(dmflag2)&&dm3.startsWith(dmflag1)){
TreeNode treeNode3 = new TreeNode();
String mc3 = dictList3.get(j3).getCt();
String py3 = dictList3.get(j3).getPy();
treeNode3.setId(dm3);
treeNode3.setText(mc3);
treeNode3.setPy(py3);
nodeList3.add(treeNode3);
}
}
if (nodeList3.size() > 0) {
treeNode2.setState("closed");
treeNode2.setChildren(nodeList3);
}
nodeList2.add(treeNode2);
}
}
//特殊2级节点(由三级节点改成二级节点:针对没有二级节点的三级节点)
for (int k3 = 0; k3 < dictList3.size(); k3++) {
String dm3 = dictList3.get(k3).getDm();
boolean flag=true;
for(int k2 = 0; k2 < dictList2.size(); k2++){
String dm2 = dictList2.get(k2).getDm();
String dmflag2=dm2.substring(0,4);//前四位相同
if(dm3.startsWith(dmflag2)){
flag=false; //有二级
}
}
if(flag&&dm3.startsWith(dmflag1)){
TreeNode treeNode3 = new TreeNode();
treeNode3.setId(dm3);
treeNode3.setText(dictList3.get(k3).getCt());
treeNode3.setPy(dictList3.get(k3).getPy());
nodeList2.add(treeNode3);
}
}
if (nodeList2.size() > 0) {
treeNode1.setState("closed");
treeNode1.setChildren(nodeList2);
}
nodeList1.add(treeNode1);
}
String tableNameUpper = zdbh.toUpperCase();
Writer fileWriter = new OutputStreamWriter(new FileOutputStream(
JSPath + tableNameUpper + ".js"), "UTF8");
fileWriter.write("[{\"id\":\"ROOT\",\"text\":\"" + zdbhMc
+ "\",\"iconCls\":\"icon-treeroot1\",\"children\":"
+ StringUtils.enterNewline + StringUtils.enterNewline);
fileWriter.write(TreeDataBuilder.getTreeData(nodeList1));
fileWriter.write(StringUtils.enterNewline + "}]");
fileWriter.flush();
fileWriter.close();
System.out.println("文件 :" + tableNameUpper + ".js 创建成功!");
} else {
String tableNameUpper = zdbh.toUpperCase();
Writer fileWriter = new OutputStreamWriter(new FileOutputStream(
JSPath + tableNameUpper + ".js"), "UTF8");
fileWriter.write("[]");
fileWriter.flush();
fileWriter.close();
System.out.println("字典: " + treeName + " 无数据, 创建空文件成功!");
System.out.println("文件 :" + tableNameUpper + ".js 创建成功!");
}
}
}
package com.founder.dictmanager.dictionary.service;
import com.founder.framework.annotation.MethodAnnotation;
import com.founder.framework.annotation.TypeAnnotation;
import com.founder.framework.utils.EasyUIPage;
import com.founder.dictmanager.model.SysDictForManager;
@TypeAnnotation("字典项管理")
public interface SysDictService {
/**
* 查询列表<br>
*
* @param page
* @param entity
* @return
*/
@MethodAnnotation(value = "查询")
public EasyUIPage queryList(EasyUIPage page, SysDictForManager entity);
/**
* 查询单条<br>
*
* @param entity
* @return
*/
public SysDictForManager query(SysDictForManager entity);
/**
* 创建列表字典JS文件<br>
*
* @param zdbh
* 字典类别
* @param zdbhMc
* 字典名称
* @throws Exception void
*/
public void createListJS(String zdbh, String zdbhMc) throws Exception;
}
package com.founder.dictmanager.dictionary.service;
import com.founder.framework.utils.EasyUIPage;
import com.founder.framework.utils.StringUtils;
import com.founder.dictmanager.dao.manager.SysDictDao;
import com.founder.dictmanager.dao.manager.SysDictGlDao;
import com.founder.dictmanager.model.SysDictForManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import java.io.FileOutputStream;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.util.List;
@Service("sysDictService")
//@Transactional
public class SysDictServiceImpl implements SysDictService {
private static Logger logger = LoggerFactory.getLogger(SysDictServiceImpl.class);
@Value("${jslocation}")
private String JSPath;
@Autowired
private SysDictDao sysDictDao;
@Autowired
private SysDictGlDao sysDictGlDao;
/**
* 查询列表<br>
*
* @param page
* @param entity
* @return
*/
public EasyUIPage queryList(EasyUIPage page, SysDictForManager entity) {
return sysDictDao.queryList(page, entity);
}
/**
* 查询单条<br>
*
* @param entity
* @return
*/
public SysDictForManager query(SysDictForManager entity) {
return sysDictDao.query(entity);
}
/**
* 创建列表字典JS文件<br>
*
* @param zdbh
* 字典类别
* @param zdbhMc
* 字典名称
* @throws Exception void
*/
public void createListJS(String zdbh, String zdbhMc) throws Exception {
List<SysDictForManager> list = sysDictDao.queryListByZdbh(zdbh);
if (list != null && list.size() > 0) {
String dm, mc, py,wb, xt_zxbz;
StringBuffer sb = new StringBuffer();
sb.append("[" + StringUtils.enterNewline);
long countAdd = 0;
long count = list.size();
for (int i = 0; i < list.size(); i++) {
SysDictForManager entity = list.get(i);
countAdd++;
dm = StringUtils.nullToStr(entity.getDm());
mc = StringUtils.nullToStr(entity.getCt());
py = StringUtils.nullToStr(entity.getPy());
wb = StringUtils.nullToStr(entity.getWb());
dm = dm.replaceAll("\n", "");
mc = mc.replaceAll("\n", "");
py = py.replaceAll("\n", "");
wb = wb.replaceAll("\n", "");
mc = mc.replaceAll("\\\\", "\\\\\\\\");
mc = mc.replaceAll("\"", "\\\\\"");
py = py.replaceAll("\\\\", "\\\\\\\\");
wb = wb.replaceAll("\\\\", "\\\\\\\\");
xt_zxbz = StringUtils.nullToStr(entity.getXtZxbz());
if ("1".equals(xt_zxbz)) {
mc += "(已注销)";
}
String optionString = "\"id\":\"" + dm + "\",\"text\":\"" + mc
+ "\",\"py\":\"" + py + "\",\"wb\":\"" + wb + "\"";
sb.append("{" + optionString + "}");
if (countAdd < count) {
sb.append(",");
}
sb.append(StringUtils.enterNewline);
}
sb.append("]" + StringUtils.enterNewline);
String tableNameUpper = zdbh.toUpperCase();
Writer fileWriter = new OutputStreamWriter(new FileOutputStream(
JSPath + tableNameUpper + ".js"), "UTF8");
fileWriter.write(sb.toString());
fileWriter.flush();
fileWriter.close();
System.out.println("文件 :" + tableNameUpper + ".js 创建成功!");
} else {
String tableNameUpper = zdbh.toUpperCase();
Writer fileWriter = new OutputStreamWriter(new FileOutputStream(
JSPath + tableNameUpper + ".js"), "UTF8");
fileWriter.write("[]");
fileWriter.flush();
fileWriter.close();
System.out.println("字典: " + zdbhMc + " 无数据, 创建空文件成功!");
System.out.println("文件 :" + tableNameUpper + ".js 创建成功!");
}
}
}
\ No newline at end of file
package com.founder.dictmanager.model;
/**
* 公安部下发代码
*/
public class GabXfdm {
//代码类型
private String id;
//变更类型
private String bglx;
//变更后代码
private String bghdm;
//变更后名称
private String bghmc;
//变更前代码
private String bgqdm;
//变更前名称
private String bgqmc;
//上一级代码
private String syjdm;
//上一级名称
private String syjmc;
//备注
private String bz;
//关联信息应用服务告知信息ID
private String glid;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getBglx() {
return bglx;
}
public void setBglx(String bglx) {
this.bglx = bglx;
}
public String getBghdm() {
return bghdm;
}
public void setBghdm(String bghdm) {
this.bghdm = bghdm;
}
public String getBghmc() {
return bghmc;
}
public void setBghmc(String bghmc) {
this.bghmc = bghmc;
}
public String getBgqdm() {
return bgqdm;
}
public void setBgqdm(String bgqdm) {
this.bgqdm = bgqdm;
}
public String getBgqmc() {
return bgqmc;
}
public void setBgqmc(String bgqmc) {
this.bgqmc = bgqmc;
}
public String getSyjdm() {
return syjdm;
}
public void setSyjdm(String syjdm) {
this.syjdm = syjdm;
}
public String getSyjmc() {
return syjmc;
}
public void setSyjmc(String syjmc) {
this.syjmc = syjmc;
}
public String getBz() {
return bz;
}
public void setBz(String bz) {
this.bz = bz;
}
public String getGlid() {
return glid;
}
public void setGlid(String glid) {
this.glid = glid;
}
}
package com.founder.dictmanager.model;
/**
* manager库字典代码
*/
public class SysDictForManager {
//主键
private Double id;
//字典上级编号
private Double glid;
//字典编号
private String zdbh;
//字典名称
private String zdmc;
//字典代码
private String dm;
//字典词条
private String ct;
//字典拼音
private String py;
//字典五笔
private String wb;
//备注
private String bz;
//操作时间
private String xtCjsj;
//录入时间
private String xtLrsj;
//操作人姓名
private String xtLrrxm;
//操作人ID
private String xtLrrid;
//操作人部门
private String xtLrrbm;
//操作人部门ID
private String xtLrrbmid;
//操作IP
private String xtLrip;
//最后修改时间
private String xtZhxgsj;
//最后修改人姓名
private String xtZhxgrxm;
//最后修改人ID
private String xtZhxgrid;
//最后修改人部门
private String xtZhxgrbm;
//最后修改人部门ID
private String xtZhxgrbmid;
//最后修改IP
private String xtZhxgip;
//注销标志
private String xtZxbz;
//注销原因
private String xtZxyy;
public Double getId() {
return id;
}
public void setId(Double id) {
this.id = id;
}
public Double getGlid() {
return glid;
}
public void setGlid(Double glid) {
this.glid = glid;
}
public String getZdbh() {
return zdbh;
}
public void setZdbh(String zdbh) {
this.zdbh = zdbh;
}
public String getZdmc() {
return zdmc;
}
public void setZdmc(String zdmc) {
this.zdmc = zdmc;
}
public String getDm() {
return dm;
}
public void setDm(String dm) {
this.dm = dm;
}
public String getCt() {
return ct;
}
public void setCt(String ct) {
this.ct = ct;
}
public String getPy() {
return py;
}
public void setPy(String py) {
this.py = py;
}
public String getWb() {
return wb;
}
public void setWb(String wb) {
this.wb = wb;
}
public String getBz() {
return bz;
}
public void setBz(String bz) {
this.bz = bz;
}
public String getXtCjsj() {
return xtCjsj;
}
public void setXtCjsj(String xtCjsj) {
this.xtCjsj = xtCjsj;
}
public String getXtLrsj() {
return xtLrsj;
}
public void setXtLrsj(String xtLrsj) {
this.xtLrsj = xtLrsj;
}
public String getXtLrrxm() {
return xtLrrxm;
}
public void setXtLrrxm(String xtLrrxm) {
this.xtLrrxm = xtLrrxm;
}
public String getXtLrrid() {
return xtLrrid;
}
public void setXtLrrid(String xtLrrid) {
this.xtLrrid = xtLrrid;
}
public String getXtLrrbm() {
return xtLrrbm;
}
public void setXtLrrbm(String xtLrrbm) {
this.xtLrrbm = xtLrrbm;
}
public String getXtLrrbmid() {
return xtLrrbmid;
}
public void setXtLrrbmid(String xtLrrbmid) {
this.xtLrrbmid = xtLrrbmid;
}
public String getXtLrip() {
return xtLrip;
}
public void setXtLrip(String xtLrip) {
this.xtLrip = xtLrip;
}
public String getXtZhxgsj() {
return xtZhxgsj;
}
public void setXtZhxgsj(String xtZhxgsj) {
this.xtZhxgsj = xtZhxgsj;
}
public String getXtZhxgrxm() {
return xtZhxgrxm;
}
public void setXtZhxgrxm(String xtZhxgrxm) {
this.xtZhxgrxm = xtZhxgrxm;
}
public String getXtZhxgrid() {
return xtZhxgrid;
}
public void setXtZhxgrid(String xtZhxgrid) {
this.xtZhxgrid = xtZhxgrid;
}
public String getXtZhxgrbm() {
return xtZhxgrbm;
}
public void setXtZhxgrbm(String xtZhxgrbm) {
this.xtZhxgrbm = xtZhxgrbm;
}
public String getXtZhxgrbmid() {
return xtZhxgrbmid;
}
public void setXtZhxgrbmid(String xtZhxgrbmid) {
this.xtZhxgrbmid = xtZhxgrbmid;
}
public String getXtZhxgip() {
return xtZhxgip;
}
public void setXtZhxgip(String xtZhxgip) {
this.xtZhxgip = xtZhxgip;
}
public String getXtZxbz() {
return xtZxbz;
}
public void setXtZxbz(String xtZxbz) {
this.xtZxbz = xtZxbz;
}
public String getXtZxyy() {
return xtZxyy;
}
public void setXtZxyy(String xtZxyy) {
this.xtZxyy = xtZxyy;
}
}
package com.founder.dictmanager.model;
import java.util.Date;
/**
* 刑专字典
*/
public class SysDictForXzxt {
//主键ID
private String id;
//代码
private String code;
//代码名称
private String name;
//组ID
private String groupid;
//null
private String levelid;
//拼音输入
private String spell;
//五笔输入
private String wbzx;
//录入人
private String lrr;
//录入时间
private java.util.Date lrsj;
//改写人
private String gxr;
//改写时间
private java.util.Date gxsj;
//null
private String simple;
//录入人单位代码
private String lrdwdm;
//录入人单位名称
private String lrdwmc;
//组名称
private String groupname;
//删除标识
private Double scbz;
//应用场景,命案:0表示命案不使用,magl表示命案使用
private String yycj1;
//应用场景,拐卖妇女儿童:0表示拐卖妇女儿童不使用,gmfnetgl表示拐卖妇女儿童使用
private String yycj2;
//应用场景,盗抢车:0表示盗抢车不使用,dqcgl表示盗抢车使用
private String yycj3;
//应用场景,涉枪:0表示涉枪不使用,sqgl表示涉枪使用
private String yycj4;
//父节点code代码
private String pid;
//null
private String isparent;
//应用场景 跨区域系列团伙案件 0表示不可用, kqyxlthaj表示可用
private String yycj7;
//应用场景,涉黑:0表示涉黑不使用,shgl表示涉黑使用
private String yycj5;
//应用场景,涉恶:0表示涉恶不使用,segl表示涉恶使用
private String yycj6;
//描述
private String description;
//null
private String endcode;
//null
private String startcode;
//应用场景 文物案件0表示不可用,wwajgl表示可用
private String yycj8;
//是否启用别名判断标志 0-不启用 1-启用
private String sfqybmpdbz;
//代码名称别名
private String dmmcbm;
//信息操作人员 公安机关机构代码
private String gxdwdm;
//信息操作人员 公安机关名称
private String gxdwmc;
//部省业务联动服务公安部下发 0:否 1:是
private String gabxf;
//应用场景,涉黑扫恶:0表示涉黑扫恶不使用,shcegl表示涉黑扫恶使用
private String yycj9;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getGroupid() {
return groupid;
}
public void setGroupid(String groupid) {
this.groupid = groupid;
}
public String getLevelid() {
return levelid;
}
public void setLevelid(String levelid) {
this.levelid = levelid;
}
public String getSpell() {
return spell;
}
public void setSpell(String spell) {
this.spell = spell;
}
public String getWbzx() {
return wbzx;
}
public void setWbzx(String wbzx) {
this.wbzx = wbzx;
}
public String getLrr() {
return lrr;
}
public void setLrr(String lrr) {
this.lrr = lrr;
}
public Date getLrsj() {
return lrsj;
}
public void setLrsj(Date lrsj) {
this.lrsj = lrsj;
}
public String getGxr() {
return gxr;
}
public void setGxr(String gxr) {
this.gxr = gxr;
}
public Date getGxsj() {
return gxsj;
}
public void setGxsj(Date gxsj) {
this.gxsj = gxsj;
}
public String getSimple() {
return simple;
}
public void setSimple(String simple) {
this.simple = simple;
}
public String getLrdwdm() {
return lrdwdm;
}
public void setLrdwdm(String lrdwdm) {
this.lrdwdm = lrdwdm;
}
public String getLrdwmc() {
return lrdwmc;
}
public void setLrdwmc(String lrdwmc) {
this.lrdwmc = lrdwmc;
}
public String getGroupname() {
return groupname;
}
public void setGroupname(String groupname) {
this.groupname = groupname;
}
public Double getScbz() {
return scbz;
}
public void setScbz(Double scbz) {
this.scbz = scbz;
}
public String getYycj1() {
return yycj1;
}
public void setYycj1(String yycj1) {
this.yycj1 = yycj1;
}
public String getYycj2() {
return yycj2;
}
public void setYycj2(String yycj2) {
this.yycj2 = yycj2;
}
public String getYycj3() {
return yycj3;
}
public void setYycj3(String yycj3) {
this.yycj3 = yycj3;
}
public String getYycj4() {
return yycj4;
}
public void setYycj4(String yycj4) {
this.yycj4 = yycj4;
}
public String getPid() {
return pid;
}
public void setPid(String pid) {
this.pid = pid;
}
public String getIsparent() {
return isparent;
}
public void setIsparent(String isparent) {
this.isparent = isparent;
}
public String getYycj7() {
return yycj7;
}
public void setYycj7(String yycj7) {
this.yycj7 = yycj7;
}
public String getYycj5() {
return yycj5;
}
public void setYycj5(String yycj5) {
this.yycj5 = yycj5;
}
public String getYycj6() {
return yycj6;
}
public void setYycj6(String yycj6) {
this.yycj6 = yycj6;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
public String getEndcode() {
return endcode;
}
public void setEndcode(String endcode) {
this.endcode = endcode;
}
public String getStartcode() {
return startcode;
}
public void setStartcode(String startcode) {
this.startcode = startcode;
}
public String getYycj8() {
return yycj8;
}
public void setYycj8(String yycj8) {
this.yycj8 = yycj8;
}
public String getSfqybmpdbz() {
return sfqybmpdbz;
}
public void setSfqybmpdbz(String sfqybmpdbz) {
this.sfqybmpdbz = sfqybmpdbz;
}
public String getDmmcbm() {
return dmmcbm;
}
public void setDmmcbm(String dmmcbm) {
this.dmmcbm = dmmcbm;
}
public String getGxdwdm() {
return gxdwdm;
}
public void setGxdwdm(String gxdwdm) {
this.gxdwdm = gxdwdm;
}
public String getGxdwmc() {
return gxdwmc;
}
public void setGxdwmc(String gxdwmc) {
this.gxdwmc = gxdwmc;
}
public String getGabxf() {
return gabxf;
}
public void setGabxf(String gabxf) {
this.gabxf = gabxf;
}
public String getYycj9() {
return yycj9;
}
public void setYycj9(String yycj9) {
this.yycj9 = yycj9;
}
}
package com.founder.dictmanager.model;
/**
* 字典类别配置
*/
public class SysDictGl {
//主键
private Double id;
//字典英文名
private String zdywm;
//字典中文名
private String zdzwm;
//引用标准
private String zdyybz;
//字典JS版本号
private Double zdbbh;
//字典业务类别:01-公共02-地址管理系统03-人口管理系统 04-案事件系统05-情报分析系统 99-其他
private String zdywlb;
//字典状态标识
private String zdztbs;
//注册时间
private String zdczsj;
//代码长度
private Double zddmcd;
//字典生成类别1-列表 2-树形 3-自定义
private String zdsclb;
//字典使用类别 1-下拉 2-树形选择
private String zdsylb;
public Double getId() {
return id;
}
public void setId(Double id) {
this.id = id;
}
public String getZdywm() {
return zdywm;
}
public void setZdywm(String zdywm) {
this.zdywm = zdywm;
}
public String getZdzwm() {
return zdzwm;
}
public void setZdzwm(String zdzwm) {
this.zdzwm = zdzwm;
}
public String getZdyybz() {
return zdyybz;
}
public void setZdyybz(String zdyybz) {
this.zdyybz = zdyybz;
}
public Double getZdbbh() {
return zdbbh;
}
public void setZdbbh(Double zdbbh) {
this.zdbbh = zdbbh;
}
public String getZdywlb() {
return zdywlb;
}
public void setZdywlb(String zdywlb) {
this.zdywlb = zdywlb;
}
public String getZdztbs() {
return zdztbs;
}
public void setZdztbs(String zdztbs) {
this.zdztbs = zdztbs;
}
public String getZdczsj() {
return zdczsj;
}
public void setZdczsj(String zdczsj) {
this.zdczsj = zdczsj;
}
public Double getZddmcd() {
return zddmcd;
}
public void setZddmcd(Double zddmcd) {
this.zddmcd = zddmcd;
}
public String getZdsclb() {
return zdsclb;
}
public void setZdsclb(String zdsclb) {
this.zdsclb = zdsclb;
}
public String getZdsylb() {
return zdsylb;
}
public void setZdsylb(String zdsylb) {
this.zdsylb = zdsylb;
}
}
package com.founder.dictmanager.model;
import java.util.Date;
/**
* 信息应用服务告知信息
*/
public class SysXxyyfwGzxx {
//主键
private String id;
//告知标题
private String bt;
//告知内容
private String nr;
//发布时间
private String fbsj;
//发布单位名称
private String fbdwmc;
//发布人姓名
private String fbrxm;
//发布人身份证号
private String fbrsfzh;
//接收单位名称
private String jsdwmc;
//接收单位代码
private String jsdwdm;
//接收人姓名
private String jsrxm;
//接收人身份证号
private String jsrsfzh;
//消息类型
private String lx;
//服务方行政区划
private String fwfxzqh;
//服务方服务标识
private String fwffwbz;
//发布单位代码
private String fbdwdm;
//代码种类
private String dmzl;
//变更类型类型
private String bglx;
//变更后代码
private String bghdm;
//变更后名称
private String bghmc;
//变更前代码
private String bgqdm;
//变更前名称
private String bgqmc;
//处理标志
private String clbz;
//null
private java.util.Date lrsj;
//上一级代码
private String syjdm;
//上一级代码名称
private String syjdmmc;
//备注
private String bz;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getBt() {
return bt;
}
public void setBt(String bt) {
this.bt = bt;
}
public String getNr() {
return nr;
}
public void setNr(String nr) {
this.nr = nr;
}
public String getFbsj() {
return fbsj;
}
public void setFbsj(String fbsj) {
this.fbsj = fbsj;
}
public String getFbdwmc() {
return fbdwmc;
}
public void setFbdwmc(String fbdwmc) {
this.fbdwmc = fbdwmc;
}
public String getFbrxm() {
return fbrxm;
}
public void setFbrxm(String fbrxm) {
this.fbrxm = fbrxm;
}
public String getFbrsfzh() {
return fbrsfzh;
}
public void setFbrsfzh(String fbrsfzh) {
this.fbrsfzh = fbrsfzh;
}
public String getJsdwmc() {
return jsdwmc;
}
public void setJsdwmc(String jsdwmc) {
this.jsdwmc = jsdwmc;
}
public String getJsdwdm() {
return jsdwdm;
}
public void setJsdwdm(String jsdwdm) {
this.jsdwdm = jsdwdm;
}
public String getJsrxm() {
return jsrxm;
}
public void setJsrxm(String jsrxm) {
this.jsrxm = jsrxm;
}
public String getJsrsfzh() {
return jsrsfzh;
}
public void setJsrsfzh(String jsrsfzh) {
this.jsrsfzh = jsrsfzh;
}
public String getLx() {
return lx;
}
public void setLx(String lx) {
this.lx = lx;
}
public String getFwfxzqh() {
return fwfxzqh;
}
public void setFwfxzqh(String fwfxzqh) {
this.fwfxzqh = fwfxzqh;
}
public String getFwffwbz() {
return fwffwbz;
}
public void setFwffwbz(String fwffwbz) {
this.fwffwbz = fwffwbz;
}
public String getFbdwdm() {
return fbdwdm;
}
public void setFbdwdm(String fbdwdm) {
this.fbdwdm = fbdwdm;
}
public String getDmzl() {
return dmzl;
}
public void setDmzl(String dmzl) {
this.dmzl = dmzl;
}
public String getBglx() {
return bglx;
}
public void setBglx(String bglx) {
this.bglx = bglx;
}
public String getBghdm() {
return bghdm;
}
public void setBghdm(String bghdm) {
this.bghdm = bghdm;
}
public String getBghmc() {
return bghmc;
}
public void setBghmc(String bghmc) {
this.bghmc = bghmc;
}
public String getBgqdm() {
return bgqdm;
}
public void setBgqdm(String bgqdm) {
this.bgqdm = bgqdm;
}
public String getBgqmc() {
return bgqmc;
}
public void setBgqmc(String bgqmc) {
this.bgqmc = bgqmc;
}
public String getClbz() {
return clbz;
}
public void setClbz(String clbz) {
this.clbz = clbz;
}
public Date getLrsj() {
return lrsj;
}
public void setLrsj(Date lrsj) {
this.lrsj = lrsj;
}
public String getSyjdm() {
return syjdm;
}
public void setSyjdm(String syjdm) {
this.syjdm = syjdm;
}
public String getSyjdmmc() {
return syjdmmc;
}
public void setSyjdmmc(String syjdmmc) {
this.syjdmmc = syjdmmc;
}
public String getBz() {
return bz;
}
public void setBz(String bz) {
this.bz = bz;
}
}
package com.founder.dictmanager.service;
import com.founder.dictmanager.model.GabXfdm;
import java.util.List;
public interface DictService {
public void test();
public List<GabXfdm> getGabXfdmRows(int rows);
public int updateManagerDict(GabXfdm gabXfdm) throws Exception;
public int updateManagerDicts(List<GabXfdm> gabXfdms);
public int updateXzxtDict(GabXfdm gabXfdm);
public int updateXzxtDicts(List<GabXfdm> gabXfdms);
public void updateSysDictJsFiles();
int getUndealXfdms();
}
package com.founder.dictmanager.service;
public interface RedisService {
public void flushAll();
}
package com.founder.dictmanager.service.impl;
import com.founder.dictmanager.service.RedisService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import java.util.Iterator;
import java.util.Set;
@Service
public class RedisServiceImpl implements RedisService {
private Logger logger = LoggerFactory.getLogger(RedisServiceImpl.class);
@Autowired
private StringRedisTemplate redisTemplate;
@Override
public void flushAll() {
logger.warn("开始清理redis!");
try {
Set<String> keysets=redisTemplate.keys("*");
Iterator<String> iterator=keysets.iterator();
while(iterator.hasNext()){
String key=iterator.next();
logger.info(key);
}
redisTemplate.delete(keysets);
} catch (Exception e) {
e.printStackTrace();
}
logger.warn("清理redis完毕!");
}
}
package com.founder.task;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import com.founder.model.Rycj;
import com.founder.model.Jccj;
import com.founder.service.RycjService;
import com.founder.service.LogService;
import com.founder.dictmanager.model.GabXfdm;
import com.founder.dictmanager.service.DictService;
import com.founder.dictmanager.service.RedisService;
@Component
public class ScheduleTask {
@Autowired
private RycjService rycjService;
@Autowired
private LogService logService;
@Autowired
private DictService sysDictService;
@Autowired
private RedisService redisService;
private SimpleDateFormat format=new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
private Logger logger= LoggerFactory.getLogger(ScheduleTask.class);
/*
* 定时任务从采集平台获取的信息发送给公安部
* */
/*
* 定时执行-查询一个表中的数据,存到字典表或者字典js文件
* */
private void xxbsSerevice(){
logger.info("This is a say method!"+format.format(new Date()));
//1.从表中获取未上报的信息
List<Rycj> list= rycjService.selectRycj();
if(list!=null&&list.size()>0){
for(Rycj r:list) {
r.getRycj_dzwjwz();//url
Rycj rycj =new Rycj();
rycj.setTaskid(r.getTaskid());
rycj.setUser_id(r.getUser_id());
/*//直接从服务器获取zip包并转成base64
Jccj jccj =new Jccj();
URL url = new URL(r.getRycj_dzwjwz());
URL url = new URL("http://47.92.129.99/neimeng/FZXZ/201909/JCXX-R1100000500002014070008.zip");
InputStream inStream = url.openStream();
ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
byte[] buff = new byte[100]; //buff用于存放循环读取的临时数据
int rc = 0;
while ((rc = inStream.read(buff, 0, 100)) > 0) {
swapStream.write(buff, 0, rc);
}
byte[] in_b = swapStream.toByteArray(); //in_b为转换之后的结果
final String encodedText = encoder.encodeToString(in_b);
jccj.setXxsb_zip(encodedText);
jccj.setTaskid("JCXX-R1100000500002014070008");
jccj.setUser_id("142728188997588823");
jccj.setUser_dept("1400000000");
jccj.setVersion("1.00");*/
//2..将从采集平台获取的信息,在发送给公安部
// JSONObject jsonResult= requestByPost("http://api.xz.xz.ga/jccj/xxbs",jccj);
//更新写日志
//公安部接口开通后Status_code等在jsonResult中解析
rycj.setStatus_code("10102");
rycj.setZxjgdm("00000");
rycj.setStatus_message("大西瓜");
rycjService.updateStatusByPrimaryKey(rycj);
logService.insertLog(rycj);
}
}
}
private void dictSerevice(){
//查询信息服务告知信息处理标志为"0"的数量
int undealCodes=sysDictService.getUndealXfdms();
logger.info("undealCodes:"+undealCodes);
if(undealCodes>0){
int q=undealCodes/100;
int m=undealCodes%100;
logger.info("undealCodes:"+undealCodes+",q:"+q+",m:"+m);
for(int i=0;i<q;i++){
logger.warn("这是第"+i+"批次任务");
List<GabXfdm> lists=sysDictService.getGabXfdmRows(100);
int r= -1;
try {
r = sysDictService.updateManagerDicts(lists);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("更新行数:"+r);
}
if(m>0){
logger.warn("这是剩余的"+m+"次任务");
List<GabXfdm> lists=sysDictService.getGabXfdmRows(m);
int r= -1;
try {
r = sysDictService.updateManagerDicts(lists);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("更新行数:"+r);
}
//刷新redis
redisService.flushAll();
//更新js文件
sysDictService.updateSysDictJsFiles();
}
}
}
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.founder.dictmanager.dao.manager.SysDictGlDao">
<!-- 查询所有 -->
<select id="queryAll" parameterType="string" resultType="com.founder.dictmanager.model.SysDictGl">
select * from SYS_DICT_GL2 t where ZDZTBS = '0' order by ZDYWM
</select>
<!-- 查询单条 -->
<select id="query" parameterType="com.founder.dictmanager.model.SysDictGl" resultType="com.founder.dictmanager.model.SysDictGl">
select * from SYS_DICT_GL2 t
where 1=1
and ID = #{id}
and ZDZTBS = '0'
and rownum = 1
</select>
</mapper>
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.founder.dictmanager.dao.manager.SysDictDao">
<resultMap id="SysDictForManager" type="com.founder.dictmanager.model.SysDictForManager">
<id column="ID" property="id" jdbcType="INTEGER"/>
<result column="GLID" property="glid" jdbcType="INTEGER"/>
<result column="ZDBH" property="zdbh" jdbcType="VARCHAR"/>
<result column="ZDMC" property="zdmc" jdbcType="VARCHAR"/>
<result column="DM" property="dm" jdbcType="VARCHAR"/>
<result column="CT" property="ct" jdbcType="VARCHAR"/>
<result column="PY" property="py" jdbcType="VARCHAR"/>
<result column="WB" property="wb" jdbcType="VARCHAR"/>
<result column="BZ" property="bz" jdbcType="VARCHAR"/>
<result column="XT_CJSJ" property="xtCjsj" jdbcType="VARCHAR"/>
<result column="XT_LRSJ" property="xtLrsj" jdbcType="VARCHAR"/>
<result column="XT_LRRXM" property="xtLrrxm" jdbcType="VARCHAR"/>
<result column="XT_LRRID" property="xtLrrid" jdbcType="VARCHAR"/>
<result column="XT_LRRBM" property="xtLrrbm" jdbcType="VARCHAR"/>
<result column="XT_LRRBMID" property="xtLrrbmid" jdbcType="VARCHAR"/>
<result column="XT_LRIP" property="xtLrip" jdbcType="VARCHAR"/>
<result column="XT_ZHXGSJ" property="xtZhxgsj" jdbcType="VARCHAR"/>
<result column="XT_ZHXGRXM" property="xtZhxgrxm" jdbcType="VARCHAR"/>
<result column="XT_ZHXGRID" property="xtZhxgrid" jdbcType="VARCHAR"/>
<result column="XT_ZHXGRBM" property="xtZhxgrbm" jdbcType="VARCHAR"/>
<result column="XT_ZHXGRBMID" property="xtZhxgrbmid" jdbcType="VARCHAR"/>
<result column="XT_ZHXGIP" property="xtZhxgip" jdbcType="VARCHAR"/>
<result column="XT_ZXBZ" property="xtZxbz" jdbcType="VARCHAR"/>
<result column="XT_ZXYY" property="xtZxyy" jdbcType="VARCHAR"/>
</resultMap>
<!-- 查询列表 -->
<select id="queryCount" parameterType="Map" resultType="Integer">
select count(*) from SYS_DICT2 t where t.XT_ZXBZ = '0' and t.GLID = #{sysDict.glid}
<if test="sysDict.dm !=null and sysDict.dm != ''">
and DM like '%'||#{sysDict.dm}||'%'
</if>
<if test="sysDict.ct !=null and sysDict.ct != ''">
and DM like '%'||#{sysDict.dm}||'%'
</if>
</select>
<select id="queryList" parameterType="Map" resultMap="SysDictForManager">
select * from (
select rownum r ,m.* from (
select * from SYS_DICT2 t
where t.XT_ZXBZ = '0'
and t.GLID = #{sysDict.glid}
<if test="sysDict.dm !=null and sysDict.dm != ''">
and DM like '%'||#{sysDict.dm}||'%'
</if>
<if test="sysDict.ct !=null and sysDict.ct != ''">
and DM like '%'||#{sysDict.dm}||'%'
</if>
order by $sort$ $order$) m
where rownum <![CDATA[<=]]> #{end} )
where r <![CDATA[>]]> #{begin}
</select>
<!-- 查询单条 -->
<select id="query" parameterType="com.founder.dictmanager.model.SysDictForManager" resultMap="SysDictForManager">
select * from SYS_DICT2 t where ID = #{id} and XT_ZXBZ = '0' and rownum = 1
</select>
<!-- 查询指定字典的所有字典项(根据glid) -->
<select id="queryListByGlid" parameterType="com.founder.dictmanager.model.SysDictForManager" resultMap="SysDictForManager">
elect * from SYS_DICT2 t where GLID = #{glid} and XT_ZXBZ = '0' order by DM
</select>
<!-- 根据字典代码查询词条 -->
<select id="queryCt" parameterType="com.founder.dictmanager.model.SysDictForManager" resultType="String">
select CT from SYS_DICT2 t where t.XT_ZXBZ = '0' and ZDBH = #{zdbh} and DM = #{dm} and rownum = 1
</select>
<!-- 查询指定字典的所有字典项(根据zdbh)-->
<select id="queryListByZdbh" parameterType="com.founder.dictmanager.model.SysDictForManager" resultMap="SysDictForManager">
select * from SYS_DICT2 t where ZDBH = #{zdbh} and XT_ZXBZ = '0' order by DM
</select>
<!-- 自定义查询(用于自定义生成查询) -->
<select id="queryDictForCustomize" parameterType="String" resultType="java.util.HashMap">
<![CDATA[ $querySqlString$ ]]>
</select>
</mapper>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.founder.dao.SysXxyyfwGzxxDao">
<select id="test" resultType="string">
select to_char(sysdate,'yyyy-MM-dd hh24:mi:ss') from dual
</select>
<resultMap id="SysXxyyfwGzxx" type="com.founder.dictmanager.model.SysXxyyfwGzxx">
<id column="ID" property="id" jdbcType="VARCHAR"/>
<result column="BT" property="bt" jdbcType="VARCHAR"/>
<result column="NR" property="nr" jdbcType="VARCHAR"/>
<result column="FBSJ" property="fbsj" jdbcType="VARCHAR"/>
<result column="FBDWMC" property="fbdwmc" jdbcType="VARCHAR"/>
<result column="FBRXM" property="fbrxm" jdbcType="VARCHAR"/>
<result column="FBRSFZH" property="fbrsfzh" jdbcType="VARCHAR"/>
<result column="JSDWMC" property="jsdwmc" jdbcType="VARCHAR"/>
<result column="JSDWDM" property="jsdwdm" jdbcType="VARCHAR"/>
<result column="JSRXM" property="jsrxm" jdbcType="VARCHAR"/>
<result column="JSRSFZH" property="jsrsfzh" jdbcType="VARCHAR"/>
<result column="LX" property="lx" jdbcType="VARCHAR"/>
<result column="FWFXZQH" property="fwfxzqh" jdbcType="VARCHAR"/>
<result column="FWFFWBZ" property="fwffwbz" jdbcType="VARCHAR"/>
<result column="FBDWDM" property="fbdwdm" jdbcType="VARCHAR"/>
<result column="DMZL" property="dmzl" jdbcType="VARCHAR"/>
<result column="BGLX" property="bglx" jdbcType="VARCHAR"/>
<result column="BGHDM" property="bghdm" jdbcType="VARCHAR"/>
<result column="BGHMC" property="bghmc" jdbcType="VARCHAR"/>
<result column="BGQDM" property="bgqdm" jdbcType="VARCHAR"/>
<result column="BGQMC" property="bgqmc" jdbcType="VARCHAR"/>
<result column="CLBZ" property="clbz" jdbcType="VARCHAR"/>
<result column="LRSJ" property="lrsj" jdbcType="TIMESTAMP"/>
<result column="SYJDM" property="syjdm" jdbcType="VARCHAR"/>
<result column="SYJDMMC" property="syjdmmc" jdbcType="VARCHAR"/>
<result column="BZ" property="bz" jdbcType="VARCHAR"/>
</resultMap>
<select id="queryPageList" resultMap="SysXxyyfwGzxx" parameterType="map">
select * from (
select t.*,rownum rn from(
select
ID as id,
BT as bt,
NR as nr,
FBSJ as fbsj,
FBDWMC as fbdwmc,
FBRXM as fbrxm,
FBRSFZH as fbrsfzh,
JSDWMC as jsdwmc,
JSDWDM as jsdwdm,
JSRXM as jsrxm,
JSRSFZH as jsrsfzh,
LX as lx,
FWFXZQH as fwfxzqh,
FWFFWBZ as fwffwbz,
FBDWDM as fbdwdm,
DMZL as dmzl,
BGLX as bglx,
BGHDM as bghdm,
BGHMC as bghmc,
BGQDM as bgqdm,
BGQMC as bgqmc,
CLBZ as clbz,
LRSJ as lrsj,
SYJDM as syjdm,
SYJDMMC as syjdmmc,
BZ as bz
from SYS_XXYYFW_GZXX
where 1=1
<if test="id != null and id != ''"> AND ID = #{id , jdbcType=VARCHAR } </if>
<if test="bt != null and bt != ''"> AND BT = #{bt , jdbcType=VARCHAR } </if>
<if test="nr != null and nr != ''"> AND NR = #{nr , jdbcType=VARCHAR } </if>
<if test="fbsj != null and fbsj != ''"> AND FBSJ = #{fbsj , jdbcType=VARCHAR } </if>
<if test="fbdwmc != null and fbdwmc != ''"> AND FBDWMC = #{fbdwmc , jdbcType=VARCHAR } </if>
<if test="fbrxm != null and fbrxm != ''"> AND FBRXM = #{fbrxm , jdbcType=VARCHAR } </if>
<if test="fbrsfzh != null and fbrsfzh != ''"> AND FBRSFZH = #{fbrsfzh , jdbcType=VARCHAR } </if>
<if test="jsdwmc != null and jsdwmc != ''"> AND JSDWMC = #{jsdwmc , jdbcType=VARCHAR } </if>
<if test="jsdwdm != null and jsdwdm != ''"> AND JSDWDM = #{jsdwdm , jdbcType=VARCHAR } </if>
<if test="jsrxm != null and jsrxm != ''"> AND JSRXM = #{jsrxm , jdbcType=VARCHAR } </if>
<if test="jsrsfzh != null and jsrsfzh != ''"> AND JSRSFZH = #{jsrsfzh , jdbcType=VARCHAR } </if>
<if test="lx != null and lx != ''"> AND LX = #{lx , jdbcType=VARCHAR } </if>
<if test="fwfxzqh != null and fwfxzqh != ''"> AND FWFXZQH = #{fwfxzqh , jdbcType=VARCHAR } </if>
<if test="fwffwbz != null and fwffwbz != ''"> AND FWFFWBZ = #{fwffwbz , jdbcType=VARCHAR } </if>
<if test="fbdwdm != null and fbdwdm != ''"> AND FBDWDM = #{fbdwdm , jdbcType=VARCHAR } </if>
<if test="dmzl != null and dmzl != ''"> AND DMZL = #{dmzl , jdbcType=VARCHAR } </if>
<if test="bglx != null and bglx != ''"> AND BGLX = #{bglx , jdbcType=VARCHAR } </if>
<if test="bghdm != null and bghdm != ''"> AND BGHDM = #{bghdm , jdbcType=VARCHAR } </if>
<if test="bghmc != null and bghmc != ''"> AND BGHMC = #{bghmc , jdbcType=VARCHAR } </if>
<if test="bgqdm != null and bgqdm != ''"> AND BGQDM = #{bgqdm , jdbcType=VARCHAR } </if>
<if test="bgqmc != null and bgqmc != ''"> AND BGQMC = #{bgqmc , jdbcType=VARCHAR } </if>
<if test="clbz != null and clbz != ''"> AND CLBZ = #{clbz , jdbcType=VARCHAR } </if>
<if test="lrsj != null"> AND LRSJ = #{lrsj , jdbcType=TIMESTAMP } </if>
<if test="syjdm != null and syjdm != ''"> AND SYJDM = #{syjdm , jdbcType=VARCHAR } </if>
<if test="syjdmmc != null and syjdmmc != ''"> AND SYJDMMC = #{syjdmmc , jdbcType=VARCHAR } </if>
<if test="bz != null and bz != ''"> AND BZ = #{bz , jdbcType=VARCHAR } </if>
) t where rownum <![CDATA[<=]]> #{endNum}
) where rn <![CDATA[>]]> #{startNum}
</select>
<update id="update" parameterType="com.founder.dictmanager.model.SysXxyyfwGzxx">
UPDATE SYS_XXYYFW_GZXX
<set>
<if test="bt != null and bt != ''"> BT = #{bt , jdbcType=VARCHAR } ,</if>
<if test="nr != null and nr != ''"> NR = #{nr , jdbcType=VARCHAR } ,</if>
<if test="fbsj != null and fbsj != ''"> FBSJ = #{fbsj , jdbcType=VARCHAR } ,</if>
<if test="fbdwmc != null and fbdwmc != ''"> FBDWMC = #{fbdwmc , jdbcType=VARCHAR } ,</if>
<if test="fbrxm != null and fbrxm != ''"> FBRXM = #{fbrxm , jdbcType=VARCHAR } ,</if>
<if test="fbrsfzh != null and fbrsfzh != ''"> FBRSFZH = #{fbrsfzh , jdbcType=VARCHAR } ,</if>
<if test="jsdwmc != null and jsdwmc != ''"> JSDWMC = #{jsdwmc , jdbcType=VARCHAR } ,</if>
<if test="jsdwdm != null and jsdwdm != ''"> JSDWDM = #{jsdwdm , jdbcType=VARCHAR } ,</if>
<if test="jsrxm != null and jsrxm != ''"> JSRXM = #{jsrxm , jdbcType=VARCHAR } ,</if>
<if test="jsrsfzh != null and jsrsfzh != ''"> JSRSFZH = #{jsrsfzh , jdbcType=VARCHAR } ,</if>
<if test="lx != null and lx != ''"> LX = #{lx , jdbcType=VARCHAR } ,</if>
<if test="fwfxzqh != null and fwfxzqh != ''"> FWFXZQH = #{fwfxzqh , jdbcType=VARCHAR } ,</if>
<if test="fwffwbz != null and fwffwbz != ''"> FWFFWBZ = #{fwffwbz , jdbcType=VARCHAR } ,</if>
<if test="fbdwdm != null and fbdwdm != ''"> FBDWDM = #{fbdwdm , jdbcType=VARCHAR } ,</if>
<if test="dmzl != null and dmzl != ''"> DMZL = #{dmzl , jdbcType=VARCHAR } ,</if>
<if test="bglx != null and bglx != ''"> BGLX = #{bglx , jdbcType=VARCHAR } ,</if>
<if test="bghdm != null and bghdm != ''"> BGHDM = #{bghdm , jdbcType=VARCHAR } ,</if>
<if test="bghmc != null and bghmc != ''"> BGHMC = #{bghmc , jdbcType=VARCHAR } ,</if>
<if test="bgqdm != null and bgqdm != ''"> BGQDM = #{bgqdm , jdbcType=VARCHAR } ,</if>
<if test="bgqmc != null and bgqmc != ''"> BGQMC = #{bgqmc , jdbcType=VARCHAR } ,</if>
<if test="clbz != null and clbz != ''"> CLBZ = #{clbz , jdbcType=VARCHAR } ,</if>
<if test="lrsj != null"> LRSJ = #{lrsj , jdbcType=TIMESTAMP } ,</if>
<if test="syjdm != null and syjdm != ''"> SYJDM = #{syjdm , jdbcType=VARCHAR } ,</if>
<if test="syjdmmc != null and syjdmmc != ''"> SYJDMMC = #{syjdmmc , jdbcType=VARCHAR } ,</if>
<if test="bz != null and bz != ''"> BZ = #{bz , jdbcType=VARCHAR } ,</if>
</set>
where 1=1
and ID = #{id , jdbcType=VARCHAR }
</update>
<select id="queryUnDealCodeCount" resultType="int">
select count(1) from SYS_XXYYFW_GZXX where 1=1 and CLBZ ='0'
</select>
</mapper>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.founder.dao.XzxtSysDictDao">
<select id="test" resultType="string">
select to_char(sysdate,'yyyy-MM-dd hh24:mi:ss') from dual
</select>
</mapper>
\ 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