Explorar el Código

Merge pull request '添加接口 北京统计调用 获取填报信息' (#2) from dev into master

Reviewed-on: http://47.92.149.153:3000/tangzp/mztb-parent/pulls/2
master
唐周平 hace 8 meses
padre
commit
9d2ebec6b9
Se han modificado 4 ficheros con 267 adiciones y 6 borrados
  1. +2
    -0
      mztb/src/main/java/cc/smtweb/biz/mztb/web/MztbStartedListener.java
  2. +13
    -0
      mztb/src/main/java/cc/smtweb/biz/mztb/web/base/noLogin/MztbNoLogin.java
  3. +248
    -0
      mztb/src/main/java/cc/smtweb/biz/mztb/web/controller/MztbController.java
  4. +4
    -6
      mztb/src/main/java/cc/smtweb/biz/mztb/web/widgetManage/TaskMonthHandler.java

+ 2
- 0
mztb/src/main/java/cc/smtweb/biz/mztb/web/MztbStartedListener.java Ver fichero

@@ -1,5 +1,6 @@
package cc.smtweb.biz.mztb.web;

import cc.smtweb.biz.mztb.web.base.noLogin.MztbNoLogin;
import cc.smtweb.framework.core.annotation.SwStartListener;
import cc.smtweb.framework.core.common.SwConsts;
import cc.smtweb.framework.core.mvc.controller.IStartListener;
@@ -25,6 +26,7 @@ public class MztbStartedListener implements IStartListener {
SwConsts.SysParam.RUN_PROJECTS = "bpm,mztb";
SwConsts.SysParam.SYS_DEBUG = false;
SwConsts.SysParam.ENABLE_TRANSPORT_ENCRYPT =false;
MztbNoLogin.init();

}



+ 13
- 0
mztb/src/main/java/cc/smtweb/biz/mztb/web/base/noLogin/MztbNoLogin.java Ver fichero

@@ -0,0 +1,13 @@
package cc.smtweb.biz.mztb.web.base.noLogin;

import cc.smtweb.framework.core.session.SessionUtil;

public class MztbNoLogin {
/**
* 免登录接口注册
*/
public static void init() {
SessionUtil.addNoLoginUri("/mztb/push");
SessionUtil.addNoLoginUri("/mztb/pull");
}
}

+ 248
- 0
mztb/src/main/java/cc/smtweb/biz/mztb/web/controller/MztbController.java Ver fichero

@@ -0,0 +1,248 @@
package cc.smtweb.biz.mztb.web.controller;

import cc.smtweb.biz.mztb.web.base.*;
import cc.smtweb.biz.mztb.web.tool.UtilPub;
import cc.smtweb.framework.core.common.R;
import cc.smtweb.framework.core.common.SwMap;
import cc.smtweb.framework.core.db.DbEngine;
import cc.smtweb.framework.core.db.EntityHelper;
import cc.smtweb.framework.core.util.DateUtil;
import cc.smtweb.framework.core.util.RandomUtil;
import cc.smtweb.framework.core.util.StringUtil;
import cc.smtweb.system.bpm.web.sys.user.dept.Dept;
import cc.smtweb.system.bpm.web.sys.user.dept.DeptCache;
import cc.smtweb.system.bpm.web.sys.user.party.Party;
import cc.smtweb.system.bpm.web.sys.user.party.PartyCache;
import cc.smtweb.system.bpm.web.sys.user.role.group.RoleGroup;
import cc.smtweb.system.bpm.web.sys.user.role.group.RoleGroupCache;
import cc.smtweb.system.bpm.web.sys.user.user.*;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;

import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;

/**
* 给北京民政端提供接口
*/
@Slf4j
@Controller
@RequestMapping("/mztb")
public class MztbController {

private static final String PWD_SALT = "goodpj";

@PostMapping("/push")
@ResponseBody
public R pushWork(@RequestBody SwMap swMap) {
// addNewPartyAccount();
DbEngine instance = DbEngine.getInstance();
List<Map<String, Object>> updatePartyList = swMap.readListMap("data");

if (updatePartyList == null || updatePartyList.size() < 1) {
log.info("请求携带需要更新的机构数据为空!");
return R.success();
}

// 批量处理的数据
List<PartyInfo> partysUpdateList = new ArrayList<>();
List<PartyInfo> partysInsertList = new ArrayList<>();
List<Party> sysPartyList = new ArrayList<>();
List<User> userList = new ArrayList<>();
List<UserParty> userPartyList = new ArrayList<>();
List<Dept> deptList = new ArrayList<>();
List<UserRole> userRoleList = new ArrayList<>();
List<UserStatu> userStatuList = new ArrayList<>();

List<String> ptIdList = new ArrayList<>();

// 记录重复数据
List<PartyInfo> partysInsertListExist = new ArrayList<>();
List<Party> sysPartyListExist = new ArrayList<>();
List<User> userListExist = new ArrayList<>();
List<UserParty> userPartyListExist = new ArrayList<>();
List<Dept> deptListExist = new ArrayList<>();
List<String> ptIdListExist = new ArrayList<>();
List<UserRole> userRoleListExist = new ArrayList<>();
List<UserStatu> userStatuListExist = new ArrayList<>();

SwMap existPartyMap = new SwMap();
int insertIndex = 0;
// 使用社会信用代码 当做key 查询当前机构信息
Map<String, PartyInfo> partyInfoMap = instance.query(PartyInfo.class).stream().collect(Collectors.toMap(PartyInfo::getCreditCode, Function.identity()));
for (Map<String, Object> map : updatePartyList) {
PartyInfo partyInfo = new PartyInfo();
SwMap updatePartySwMap = new SwMap();
for (String key : map.keySet()) { // 注意民政端推送数据的字段和填报系统字段要一致
updatePartySwMap.put(key, map.get(key));
}
// 将查询到的数据转为 填报系统机构表数据
partyInfo.getData().putAll(updatePartySwMap);
if (partyInfoMap.containsKey(map.get("pi_credit_code") + "")) { // 判断该机构是否存在
long piIdOld = partyInfoMap.get(map.get("pi_credit_code") + "").getId();
long sysPartyId = partyInfoMap.get(map.get("pi_credit_code") + "").getSysPartyId();
partyInfo.setId(piIdOld);
partyInfo.setSysPartyId(sysPartyId);
partysUpdateList.add(partyInfo);
} else { // 新增(包括 底层的party 填报系统的 partyInfo 默认的用户)
boolean existParty = existPartyMap.containsKey(map.get("pi_credit_code") + "");
if (existParty) {
// 包含就更新机构信息 ,系统机构信息没有可更改的内容故不处理
int index = existPartyMap.readInt(map.get("pi_credit_code") + "");
partysInsertListExist.add(partysInsertList.get(index));
userListExist.add(userList.get(index));
userPartyListExist.add(userPartyList.get(index));
sysPartyListExist.add(sysPartyList.get(index));
deptListExist.add(deptList.get(index));
userRoleListExist.add(userRoleList.get(index));
userStatuListExist.add(userStatuList.get(index));
ptIdListExist.add(ptIdList.get(index));
}
existPartyMap.put(map.get("pi_credit_code") + "", insertIndex);
insertIndex++;

Party party = new Party(); // 底层机构表
party.init();
long ptId = Long.parseLong(map.get("pi_id") + "");
party.setId(ptId);
party.setCode(ptId + "");
party.setName(partyInfo.getPartyName());
// partyInfo.setSysPartyId(ptId);
sysPartyList.add(party);
partysInsertList.add(partyInfo);
// 添加机构id
ptIdList.add(ptId + "");

User user = new User(); // 底层用户表
user.init();
long userId = instance.nextId();
user.setId(userId);
user.setCode(partyInfo.getCreditCode());
user.setName(partyInfo.getPartyName() + "-填报人员");
user.setNicky(partyInfo.getCreditCode());
user.setLevel(100);
user.setStatu(1);
// user.setPwd("13217b04835b4cbceb55edb54a72deb4"); //默认密码 abc@123456
user.setPwd(DigestUtils.md5Hex(PWD_SALT + user.getId() + "abc@123456")); //默认密码 abc@123456
user.setPwdLevel(0);
userList.add(user);

Dept dept = new Dept();// 添加部门
dept.init();
long deptId = instance.nextId();
dept.setId(deptId);
dept.setCode(RandomUtil.randomString(8));
dept.setName("填报部门");
dept.setType("100");
dept.setPtId(ptId);
dept.setStatu(0);
deptList.add(dept);

UserParty userParty = new UserParty(); //用户机构关联表
long userPartyId = instance.nextId();
userParty.setId(userPartyId);
userParty.setPartyId(ptId);
userParty.setUserId(userId);
userParty.setDeptId(deptId); // 关联部门表
userPartyList.add(userParty);

UserRole userRole = new UserRole(); // 用户角色
userRole.setId(instance.nextId());
userRole.setSupId(userPartyId);
userRole.setRoleGroupId(927515588790587392L); // 角色组id todo 先写死 一般不会变
userRoleList.add(userRole);

UserStatu userStatu = new UserStatu(); // 用户登录状态
userStatu.init();
userStatu.setId(userId);
userStatuList.add(userStatu);
}
}

// 删除重复新增的元素
partysInsertList.removeAll(partysInsertListExist);
sysPartyList.removeAll(sysPartyListExist);
userList.removeAll(userListExist);
userPartyList.removeAll(userPartyListExist);
deptList.removeAll(deptListExist);
userRoleList.removeAll(userRoleListExist);
userStatuList.removeAll(userStatuListExist);
ptIdList.removeAll(ptIdListExist);

instance.doTrans(() -> {
// 处理新增或者修改的数据
instance.findDao(PartyInfo.class).batchInsertEntity(partysInsertList);
instance.findDao(PartyInfo.class).batchUpdateEntity(partysUpdateList);
instance.findDao(Party.class).batchInsertEntity(sysPartyList);
instance.findDao(User.class).batchInsertEntity(userList);
instance.findDao(UserParty.class).batchInsertEntity(userPartyList);
instance.findDao(Dept.class).batchInsertEntity(deptList);
instance.findDao(UserRole.class).batchInsertEntity(userRoleList);
instance.findDao(UserStatu.class).batchInsertEntity(userStatuList);

// 将新增的机构 加入角色组的 机构字段
if (ptIdList.size() > 0) {
instance.update("UPDATE " + EntityHelper.getSchemaTableName(RoleGroup.ENTITY_NAME)
+ " SET srg_party_id = CONCAT(srg_party_id,',' ,'" + String.join(",", ptIdList) + "') where srg_id = ? ", 927515588790587392L); // 角色组填报员
}
// 将机构、用户信息放入缓存,或者刷新缓存
PartyCache.getInstance().putList(sysPartyList);
UserCache.getInstance().putList(userList);
UserPartyCache.getInstance().putList(userPartyList);
DeptCache.getInstance().putList(deptList);
UserRoleCache.getInstance().putList(userRoleList);
UserStatuCache.getInstance().putList(userStatuList);
RoleGroupCache.getInstance().refresh();
});
return R.success();
}


@PostMapping("/pull")
@ResponseBody
public R pullWork(@RequestBody SwMap swMap) {
DbEngine instance = DbEngine.getInstance();

String data = swMap.readString("data");
boolean rollBack = swMap.readBool("rollBack", false);
if (rollBack) {
String fillOutIds = swMap.readString("fillOutIds");
List<String> collect = Arrays.stream(fillOutIds.split(",")).collect(Collectors.toList());
if (StringUtil.isEmpty(fillOutIds)) return R.success();
instance.update("update " + EntityHelper.getSchemaTableName(FillOut.ENTITY_NAME)
+ " set fo_read_state = 1,fo_state = 1 where fo_id in (" + StringUtil.join(collect, ",") + ")");
return R.success();
}

// 查询已确认还未推送和未成功 并且为指定任务月的填报数据
List<String> fillOutList = instance.queryStringList(
"select fo_id from " + EntityHelper.getSchemaTableName(FillOut.ENTITY_NAME)
+ " where fo_state = 1 and fo_read_state != 0 and fo_task in (" + data + ") ");
if (fillOutList.size() == 0) {
log.info("未找到还未推送的数据");
return R.success();
}
String sql = "select pi.pi_sys_party_id,fo.*,fi.*,bi.*,yep.* from " + EntityHelper.getSchemaTableName(FillOut.ENTITY_NAME) + " fo\n" +
" inner join " + EntityHelper.getSchemaTableName(FinanceInfo.ENTITY_NAME) + " fi on fo_id = fi_fo_id\n" +
" inner join " + EntityHelper.getSchemaTableName(BusinessInfo.ENTITY_NAME) + " bi on fo_id = bi_fo_id\n" +
" inner join "+EntityHelper.getSchemaTableName(PartyInfo.ENTITY_NAME)+" pi on fo_party_id = pi_id " +
" left join " + EntityHelper.getSchemaTableName(YearEndPersons.ENTITY_NAME) + " yep on fo_id = yep_fo_id " +
" where fo_id in (" + StringUtil.join(fillOutList, ",") + ");";

List<SwMap> query = instance.query(sql, SwMap.class);

instance.update("update " + EntityHelper.getSchemaTableName(FillOut.ENTITY_NAME)
+ " set fo_read_time = ?, fo_read_state = 0 ,fo_state = 2 where fo_id in (" + StringUtil.join(fillOutList, ",") + ")", DateUtil.nowDateTimeLong());
return R.success(query);
}

}

+ 4
- 6
mztb/src/main/java/cc/smtweb/biz/mztb/web/widgetManage/TaskMonthHandler.java Ver fichero

@@ -1,23 +1,21 @@
package cc.smtweb.biz.mztb.web.widgetManage;

import cc.smtweb.biz.mztb.web.base.DbSourceConfig;
import cc.smtweb.biz.mztb.web.domian.FillTask;
import cc.smtweb.biz.mztb.web.tool.DbUtil;
import cc.smtweb.biz.mztb.web.tool.UtilPub;
import cc.smtweb.framework.core.common.R;
import cc.smtweb.framework.core.common.SwEnum;
import cc.smtweb.framework.core.common.SwMap;
import cc.smtweb.framework.core.db.DbEngine;
import cc.smtweb.framework.core.exception.BizException;
import cc.smtweb.framework.core.log.LogFactory;
import cc.smtweb.framework.core.mvc.service.SwListData;
import cc.smtweb.framework.core.session.UserSession;
import cc.smtweb.system.bpm.web.design.form.define.PageDataset;
import cc.smtweb.system.bpm.web.engine.dynPage.DynPageListHandler;
import cc.smtweb.system.bpm.web.engine.dynPage.DynPageLoadHandler;
import cc.smtweb.system.bpm.web.engine.dynPage.DynRetBean;

import java.sql.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;



Cargando…
Cancelar
Guardar