package com.ld.igds;
|
|
import com.bstek.bdf2.core.controller.IController;
|
import com.bstek.bdf2.core.orm.jdbc.JdbcDao;
|
import com.ld.igds.common.CoreSerService;
|
import com.ld.igds.sys.service.DicTriggerService;
|
import com.ld.igds.sys.service.SysDeptService;
|
import com.ld.igds.sys.service.SystemService;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.view.service.BuildingService;
|
import com.ld.igds.view.service.HDepotService;
|
import com.ld.igds.view.service.DeviceSerService;
|
import com.ld.igds.view.service.DeviceService;
|
import com.ld.igds.view.service.SysConfService;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 测试Action接口，支持匿名访问
|
* 方位路径：http://127.0.0.1:8080/igds/create.action?companyId=0000&del=0
|
*/
|
@Slf4j
|
@Component
|
public class CreateCompanyAction extends JdbcDao implements IController {
|
|
@Autowired
|
private DicTriggerService dicTriggerService;
|
@Autowired
|
private DeviceSerService deviceSerService;
|
@Autowired
|
private CoreSerService coreSerService;
|
@Autowired
|
private HDepotService depotService;
|
@Autowired
|
private BuildingService buildingService;
|
@Autowired
|
private DeviceService deviceService;
|
@Autowired
|
private SysConfService sysConfService;
|
@Autowired
|
private SysDeptService sysDeptService;
|
@Autowired
|
private SystemService systemService;
|
|
@Override
|
public String getUrl() {
|
return "/create";
|
}
|
|
@Override
|
public void execute(HttpServletRequest request, HttpServletResponse response) {
|
String companyId = request.getParameter("companyId");
|
String del = request.getParameter("del");
|
|
String cache = request.getParameter("cache");
|
|
if (null == cache)
|
cache = "0";
|
|
if (null == del)
|
del = "0";
|
|
try {
|
if (StringUtils.isEmpty(companyId)) {
|
response.getWriter().println(
|
"The 'companyId' parameter not found");
|
return;
|
}
|
|
if(companyId.equals("5000")){
|
response.getWriter().println(
|
"The 'companyId' parameter is not valid");
|
return;
|
}
|
|
if (cache.equals("1")) {
|
flushCache(companyId, null);
|
response.getWriter().println("CACHE SUCCESS");
|
return;
|
}
|
|
String defaultCompanyId = ContextUtil.getDefaultCompanyId();
|
|
if ("0".equals(del)) {
|
int num = check(companyId);
|
if (num > 0) {
|
response.getWriter().println(companyId + " is exist");
|
return;
|
}
|
doExe(defaultCompanyId, companyId, false, response);
|
|
response.getWriter().println("CREATE SUCCESS");
|
}
|
|
if ("1".equals(del)) {
|
doExe(defaultCompanyId, companyId, true, response);
|
|
response.getWriter().println("DEL SUCCESS");
|
}
|
} catch (Exception e) {
|
log.error("处理失败：{}", e.getMessage());
|
}
|
|
}
|
|
private void doExe(String defaultCompanyId, String companyId, boolean isDel, HttpServletResponse response) throws Exception {
|
// 赋值-部门
|
int num = this.addDept(companyId, isDel);
|
|
response.getWriter().println("--addDept---" + num);
|
|
// 赋值-角色
|
num = this.addRole(companyId, isDel);
|
response.getWriter().println("--addRole---" + num);
|
|
|
// 赋值-菜单
|
num = this.addUrl(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addUrl---" + num);
|
|
|
// 赋值-用户
|
num = this.addUser(companyId, isDel);
|
response.getWriter().println("--addUser---" + num);
|
|
|
// 赋值-角色成员
|
num = this.addRoleUser(companyId, isDel);
|
response.getWriter().println("--addRoleUser---" + num);
|
|
// 赋值-用户所属部门
|
num = this.addUserDept(companyId, isDel);
|
response.getWriter().println("--addUserDept---" + num);
|
|
|
// 赋值-角色和资源
|
num = this.addRoleResource(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addRoleResource---" + num);
|
|
// 赋值-建筑物
|
num = this.addBuilding(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addBuilding---" + num);
|
|
|
// 赋值-仓库
|
num = this.addDepot(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addDepot---" + num);
|
|
|
// 赋值-仓库配置
|
num = this.addDepotConf(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addDepotConf---" + num);
|
|
|
// 赋值-设备
|
num = this.addDevice(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addDevice---" + num);
|
|
// 赋值-分机
|
num = this.addDeviceSer(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addDeviceSer---" + num);
|
|
// 赋值-设备位置
|
num = this.addLocation(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addLocation---" + num);
|
|
// 赋值-系统配置
|
num = this.addSysConf(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addSysConf---" + num);
|
|
// 赋值-字典
|
num = this.addDic(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addDic---" + num);
|
|
|
// 赋值-粮情
|
num = this.addGrain(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addGrain---" + num);
|
|
|
// 赋值-气体
|
num = this.addGas(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addGas---" + num);
|
|
// 赋值-虫害
|
num = this.addPest(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addPest---" + num);
|
|
|
// 赋值-出入库配置
|
num = this.addInoutConf(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addInoutConf---" + num);
|
|
// 赋值-新增组织
|
num = this.addCompany(companyId, isDel);
|
response.getWriter().println("--addCompany---" + num);
|
|
// 赋值-出入库
|
num = this.addInoutRecord(defaultCompanyId, companyId, isDel);
|
response.getWriter().println("--addInoutRecord---" + num);
|
|
}
|
|
private int addGas(String defaultCompanyId, String companyId, boolean isDel) {
|
if (isDel) {
|
String del = "DELETE FROM D_GAS WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_gas(BATCH_ID_,COMPANY_ID_,DEPOT_ID_,PER_CO2_,PER_CO2_MAX_,PER_CO2_MIN_,PER_O2_,PER_O2_MAX_,PER_O2_MIN_,PER_PH3_,PER_PH3_MAX_,PER_PH3_MIN_,RECEIVE_DATE_,CHECK_USER_,PER_N2_,PER_N2_MAX_,PER_N2_MIN_,CHECK_NUM_,GAS_END_,GAS_START_,POINTS_) "
|
+ "select BATCH_ID_,?,DEPOT_ID_,PER_CO2_,PER_CO2_MAX_,PER_CO2_MIN_,PER_O2_,PER_O2_MAX_,PER_O2_MIN_,PER_PH3_,PER_PH3_MAX_,PER_PH3_MIN_,RECEIVE_DATE_,CHECK_USER_,PER_N2_,PER_N2_MAX_,PER_N2_MIN_,CHECK_NUM_,GAS_END_,GAS_START_,POINTS_ from d_gas where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(sql,
|
new Object[]{companyId, defaultCompanyId});
|
}
|
|
private int addPest(String defaultCompanyId, String companyId, boolean isDel) {
|
if (isDel) {
|
String del = "DELETE FROM D_PEST WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_pest(BATCH_ID_,COMPANY_ID_,DEPOT_ID_,PEST_MAX_,CHECK_USER_,RECEIVE_DATE_,CHECK_NUM_,PEST_END_,PEST_START_) "
|
+ "select BATCH_ID_,?,DEPOT_ID_,PEST_MAX_,CHECK_USER_,RECEIVE_DATE_,CHECK_NUM_,PEST_END_,PEST_START_ from d_pest where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(sql,
|
new Object[]{companyId, defaultCompanyId});
|
}
|
|
|
|
private int addCompany(String companyId, boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM BDF2_COMPANY WHERE ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO BDF2_COMPANY(ID_,NAME_) VALUES(?,?)";
|
int num = this.getJdbcTemplate()
|
.update(sql, new Object[]{companyId, "新增组织公司"});
|
|
log.info("----------------------新增组织完成-{} ", companyId);
|
return num;
|
}
|
|
private int addRoleUser(String companyId, boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM bdf2_role_member WHERE role_id_ like ?";
|
return this.getJdbcTemplate().update(del,
|
new Object[]{companyId + "-role-%"});
|
}
|
|
String sql = "INSERT INTO bdf2_role_member(ID_,CREATE_DATE_,GRANTED_,ROLE_ID_,USERNAME_) Values (?,?,?,?,?)";
|
|
return this.getJdbcTemplate().update(
|
sql,
|
new Object[]{ContextUtil.getUUID(), new Date(), 1,
|
companyId + "-role-admin", companyId});
|
}
|
|
private int addInoutConf(String defaultCompanyId, String companyId, boolean isDel) {
|
if (isDel) {
|
String del = "DELETE FROM d_inout_conf WHERE COMPANY_ID_ = ?";
|
this.getJdbcTemplate().update(del, new Object[]{companyId});
|
|
del = "DELETE FROM d_inout_sys_conf WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_inout_conf(ID_,COMPANY_ID_,DEPT_ID_,SORT_) values(?,?,?,?)";
|
this.getJdbcTemplate().update(sql, new Object[]{companyId+"-"+System.currentTimeMillis(),companyId,companyId+"_001",1});
|
|
|
sql = "INSERT INTO d_inout_sys_conf(COMPANY_ID_,NOTICE_TAG_IN_,NOTICE_TAG_OUT_,NOTICE_WX_,PROGRESS_IN_,PROGRESS_OUT_) values(?,?,?,?,?,?)";
|
return this.getJdbcTemplate().update(sql, new Object[]{companyId,"Y","Y","N","REGISTER-WEIGHT_FULL-CHECK-WEIGHT_EMPTY-CARD_BACK-RECORD","REGISTER-WEIGHT_EMPTY-WEIGHT_FULL-CARD_BACK-RECORD"});
|
}
|
|
private int addInoutRecord(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_inout_record WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_inout_record( " + " ID_," + " BIZ_TYPE_,"
|
+ " BROKEN_," + " CHECK_STATUS_," + " COMPANY_ID_,"
|
+ " COMPLETE_TIME_," + " COMPLETE_USER_," + " CUSTOMER_ID_,"
|
+ " CUSTOMER_NAME_," + " DE_BROKEN_," + " DE_HANDLE_,"
|
+ " DE_IMPURITY_," + " DE_OTHER_," + " DE_PACK_," + " DE_SUM_,"
|
+ " DE_WET_," + " DEPOT_ID_," + " DEPT_ID_,"
|
+ " EMPTY_WEIGHT_," + " EMPTY_WEIGHT_TIME_,"
|
+ " EMPTY_WEIGHT_USER_," + " FOOD_LEVEL_," + " FOOD_LOCATION_,"
|
+ " FOOD_VARIETY_," + " FOOD_YEAR_," + " FULL_WEIGHT_,"
|
+ " FULL_WEIGHT_TIME_," + " FULL_WEIGHT_USER_,"
|
+ " GROSS_WEIGHT_," + " HANDLE_END_," + " HANDLE_START_,"
|
+ " HANDLE_USER_," + " IMPURITY_," + " INTEL_CARD_,"
|
+ " NET_WEIGHT_," + " PLATE_NUM_," + " PROGRESS_,"
|
+ " RECORD_STATUS_," + " REGISTER_TIME_," + " REGISTER_USER_,"
|
+ " SETTLE_WEIGHT_," + " SUMMARY_," + " TARE_WEIGHT_,"
|
+ " TRANS_TYPE_," + "TYPE_," + "UNIT_NAME_," + "USER_ADDRESS_,"
|
+ "USER_BIRTHDAY_," + "USER_CONTACT_," + "USER_ID_,"
|
+ "USER_NAME_," + "USER_NATION_," + "USER_SEX_," + "WET_,"
|
+ "CHECK_ID_," + "CHECK_USER_," + "CUR_STORAGE_," + "REMARKS_,"
|
+ "FOOD_TYPE_) " +
|
|
"select " + "REPLACE(ID_, ?, ?)," + " BIZ_TYPE_," + " BROKEN_,"
|
+ " CHECK_STATUS_," + " ?," + " COMPLETE_TIME_,"
|
+ " COMPLETE_USER_," + " CUSTOMER_ID_," + " CUSTOMER_NAME_,"
|
+ " DE_BROKEN_," + " DE_HANDLE_," + " DE_IMPURITY_,"
|
+ " DE_OTHER_," + " DE_PACK_," + " DE_SUM_," + " DE_WET_,"
|
+ " DEPOT_ID_," + " DEPT_ID_," + " EMPTY_WEIGHT_,"
|
+ " EMPTY_WEIGHT_TIME_," + " EMPTY_WEIGHT_USER_,"
|
+ " FOOD_LEVEL_," + " FOOD_LOCATION_," + " FOOD_VARIETY_,"
|
+ " FOOD_YEAR_," + " FULL_WEIGHT_," + " FULL_WEIGHT_TIME_,"
|
+ " FULL_WEIGHT_USER_," + " GROSS_WEIGHT_," + " HANDLE_END_,"
|
+ " HANDLE_START_," + " HANDLE_USER_," + " IMPURITY_,"
|
+ " INTEL_CARD_," + " NET_WEIGHT_," + " PLATE_NUM_,"
|
+ " PROGRESS_," + " RECORD_STATUS_," + " REGISTER_TIME_,"
|
+ " REGISTER_USER_," + " SETTLE_WEIGHT_," + " SUMMARY_,"
|
+ " TARE_WEIGHT_," + " TRANS_TYPE_," + "TYPE_," + "UNIT_NAME_,"
|
+ "USER_ADDRESS_," + "USER_BIRTHDAY_," + "USER_CONTACT_,"
|
+ "USER_ID_," + "USER_NAME_," + "USER_NATION_," + "USER_SEX_,"
|
+ "WET_," + "CHECK_ID_," + "CHECK_USER_," + "CUR_STORAGE_,"
|
+ "REMARKS_," + "FOOD_TYPE_ "
|
+ "from d_inout_record where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(
|
sql,
|
new Object[]{defaultCompanyId, companyId, companyId,
|
defaultCompanyId});
|
}
|
|
private int addGrain(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_grain WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_grain(BATCH_ID_,COMPANY_ID_,DEPOT_ID_,TEMP_AVE_,TEMP_MAX_,TEMP_MIN_,HUMIDITY_IN_,HUMIDITY_OUT_,TEMP_IN_,TEMP_OUT_,RECEIVE_DATE_,CHECK_USER_,WEATHER_,CABLE_,CABLE_CIR_,OIL_HEIGHT_,POINTS_) "
|
+ "select BATCH_ID_,?,DEPOT_ID_,TEMP_AVE_,TEMP_MAX_,TEMP_MIN_,HUMIDITY_IN_,HUMIDITY_OUT_,TEMP_IN_,TEMP_OUT_,RECEIVE_DATE_,CHECK_USER_,WEATHER_,CABLE_,CABLE_CIR_,OIL_HEIGHT_,POINTS_ from d_grain where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(sql,
|
new Object[]{companyId, defaultCompanyId});
|
}
|
|
private int addDic(String defaultCompanyId, String companyId, boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_dic_trigger WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_dic_trigger(PARENT_CODE,COMPANY_ID_,CODE_,DISABLED_TAG,NAME_) "
|
+ "select PARENT_CODE,?,CODE_,DISABLED_TAG,NAME_ from d_dic_trigger where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(sql,
|
new Object[]{companyId, defaultCompanyId});
|
}
|
|
private int addSysConf(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_dic_sys_conf WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_dic_sys_conf(COMPANY_ID_,GRAIN_AUTO_,GRAIN_ERROR_AUTO_,ADDRESS_,EMAIL_,GRAIN_ADD_POINT_,PHONE_,SCREE_NAME_,SUPPORT_,SYS_NAME_,GRAIN_MAX_AUTO_,GRAIN_MORE_TAG_,GRAIN_OFFSET_,INTERVAL_GAS_,INTERVAL_PEST_,INTERVAL_TIME_,NETWORK_TYPE_) "
|
+ "VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
|
return this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId, "N", "N", "未配置", "未配置", "N", "未配置",
|
"智慧粮库管理平台", "风正致远信息技术股份有限公司", "智慧粮库管理平台", "N", "N", 0,
|
15, 15, 5, "01"});
|
}
|
|
private int addLocation(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_dic_location WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_dic_location(ID_,COMPANY_ID_,DEPOT_ID_,BIZ_ID_,BIZ_TAG_,SELF_TAG_,POS_X_,POS_Y_,POS_Z_) "
|
+ "select uuid(),?,DEPOT_ID_,REPLACE(BIZ_ID_, ?, ?),BIZ_TAG_,SELF_TAG_,POS_X_,POS_Y_,POS_Z_ from d_dic_location where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId, defaultCompanyId, companyId,
|
defaultCompanyId});
|
}
|
|
private int addDeviceSer(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_device_ser WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_device_ser(ID_,COMPANY_ID_,NAME_,IP_,PORT_,STATUS_,PROTOCOL_,CONTROL_MODEL_,NETWORK_TYPE_,TYPE_,SN_) "
|
+ "select ID_,?,NAME_,IP_,PORT_,STATUS_,PROTOCOL_,CONTROL_MODEL_,NETWORK_TYPE_,TYPE_,SN_ from d_device_ser where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(sql,
|
new Object[]{companyId, defaultCompanyId});
|
}
|
|
private int addDevice(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_device WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_device(ID_,COMPANY_ID_,DEPOT_ID_,PASS_CODE_,NAME_,SER_ID_,TYPE_,LOCATION_,STATUS_,LINK_) "
|
+ "select REPLACE(ID_, ?, ?),?,DEPOT_ID_,PASS_CODE_,NAME_,SER_ID_,TYPE_,LOCATION_,STATUS_,LINK_ from d_device where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(
|
sql,
|
new Object[]{defaultCompanyId, companyId, companyId,
|
defaultCompanyId});
|
}
|
|
private int addDepotConf(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_depot_conf WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_depot_conf(DEPOT_ID_,COMPANY_ID_,GRAIN_SER_,CABLE_START_,CABLE_END_,GAS_START_,GAS_END_,PEST_START_,PEST_END_,"
|
+ "TH_SER_,TH_CONF_,QUANTITY_SER_,CABLE_CIR_,CABLE_RULE_) "
|
+ "select DEPOT_ID_,?,GRAIN_SER_,CABLE_START_,CABLE_END_,GAS_START_,GAS_END_,PEST_START_,PEST_END_,"
|
+ "TH_SER_,TH_CONF_,QUANTITY_SER_,CABLE_CIR_,CABLE_RULE_ from d_depot_conf where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate().update(sql,
|
new Object[]{companyId, defaultCompanyId});
|
}
|
|
private int addDepot(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_depot WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_depot(ID_,COMPANY_ID_,NAME_,DEPOT_TYPE_,DEPOT_STATUS_,STORE_TYPE_,STORAGE_REAL_,FOOD_LEVEL_,FOOD_TYPE_,"
|
+ "FOOD_VARIETY_,FOOD_YEAR_,STORE_KEEPER_,STORE_KEEPER_NAME_,DEPT_ID_,BUILDING_ID_) "
|
+ "select ID_,?,NAME_,DEPOT_TYPE_,DEPOT_STATUS_,STORE_TYPE_,STORAGE_REAL_,FOOD_LEVEL_,FOOD_TYPE_,"
|
+ "FOOD_VARIETY_,FOOD_YEAR_,STORE_KEEPER_,STORE_KEEPER_NAME_,?,BUILDING_ID_ from d_depot where COMPANY_ID_=?";
|
|
return this.getJdbcTemplate()
|
.update(sql,
|
new Object[]{companyId, companyId + "_001",
|
defaultCompanyId});
|
}
|
|
private int addBuilding(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM d_building WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO d_building(ID_,COMPANY_ID_,DEPT_ID_,NAME_) select ID_,?,?,NAME_ from d_building where COMPANY_ID_=?";
|
return this.getJdbcTemplate()
|
.update(sql,
|
new Object[]{companyId, companyId + "_001",
|
defaultCompanyId});
|
}
|
|
private int addRoleResource(String defaultCompanyId, String companyId,
|
boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM bdf2_role_resource WHERE ROLE_ID_ LIKE ?";
|
return this.getJdbcTemplate().update(del,
|
new Object[]{companyId + "-role-%"});
|
}
|
|
String sql = "INSERT INTO bdf2_role_resource(ID_,ROLE_ID_,URL_ID_) "
|
+ "select uuid(),?,REPLACE(URL_ID_,?,?) from bdf2_role_resource where ROLE_ID_ = ?";
|
|
int num1 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId + "-role-admin", defaultCompanyId,
|
companyId, defaultCompanyId + "-role-admin"});
|
|
int num2 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId + "-role-test", defaultCompanyId,
|
companyId, defaultCompanyId + "-role-test"});
|
|
return num1 + num2;
|
}
|
|
private int addUserDept(String companyId, boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM bdf2_user_dept WHERE USERNAME_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO bdf2_user_dept(ID_, DEPT_ID_, USERNAME_) VALUES (?,?,?)";
|
return this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId + "_123", companyId + "_001",
|
companyId});
|
}
|
|
private int addUser(String companyId, boolean isDel) {
|
if (isDel) {
|
String del = "DELETE FROM bdf2_user WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO bdf2_user(USERNAME_,COMPANY_ID_,ADMINISTRATOR_,CNAME_,ENABLED_,ENAME_,PASSWORD_,SALT_,MALE_) VALUES (?,?,?,?,?,?,?,?,?)";
|
return this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId, companyId, 1, "管理员", 1, "admin",
|
"8d310dbcb7e417dc8e528cb56c13dbe250030e8a", "29", 1});
|
}
|
|
private int addUrl(String defaultCompanyId, String companyId, boolean isDel) {
|
if (isDel) {
|
String del = "DELETE FROM bdf2_url WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "insert into bdf2_url(ID_,COMPANY_ID_,FOR_NAVIGATION_,ICON_,NAME_,ORDER_,URL_,TARGET_) "
|
+ "select REPLACE(ID_, ?, ?),?,FOR_NAVIGATION_,ICON_,NAME_,ORDER_,URL_,TARGET_ from bdf2_url where parent_id_ IS NULL and company_id_=?";
|
|
int num1 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{defaultCompanyId, companyId, companyId, defaultCompanyId});
|
|
sql = "insert into bdf2_url(ID_,COMPANY_ID_,FOR_NAVIGATION_,ICON_,NAME_,ORDER_,PARENT_ID_,URL_,TARGET_) "
|
+ "select REPLACE(ID_, ?, ?),?,FOR_NAVIGATION_,ICON_,NAME_,ORDER_,REPLACE(PARENT_ID_, ?, ?),URL_,TARGET_ from bdf2_url where parent_id_ IS NOT NULL and company_id_=?";
|
|
int num2 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{defaultCompanyId, companyId, companyId,
|
defaultCompanyId, companyId, defaultCompanyId});
|
|
return num1 + num2;
|
}
|
|
private int addRole(String companyId, boolean isDel) {
|
if (isDel) {
|
String del = "DELETE FROM bdf2_role WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO bdf2_role(ID_, COMPANY_ID_,CREATE_DATE_,ENABLED_, NAME_, TYPE_) VALUES (?,?,?,?,?,?)";
|
|
int num1 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId + "-role-admin", companyId,
|
new Date(), 1, "管理员角色", "normal"});
|
|
int num2 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId + "-role-test", companyId, new Date(),
|
1, "演示角色", "normal"});
|
|
return num1 + num2;
|
}
|
|
private int addDept(String companyId, boolean isDel) {
|
|
if (isDel) {
|
String del = "DELETE FROM bdf2_dept WHERE COMPANY_ID_ = ?";
|
return this.getJdbcTemplate().update(del, new Object[]{companyId});
|
}
|
|
String sql = "INSERT INTO bdf2_dept(ID_, COMPANY_ID_,CREATE_DATE_, NAME_, PARENT_ID_) VALUES (?,?,?,?,?)";
|
|
int num1 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId, companyId, new Date(), "粮食收储有限公司",
|
null});
|
|
int num2 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId + "_001", companyId, new Date(),
|
"演示中心粮库", companyId});
|
|
int num3 = this.getJdbcTemplate().update(
|
sql,
|
new Object[]{companyId + "_002", companyId, new Date(),
|
"演示地区分库", companyId});
|
|
return num1 + num2 + num3;
|
}
|
|
private int check(String companyId) {
|
String sql = "SELECT COUNT(*) AS num FROM BDF2_COMPANY WHERE ID_ = ?";
|
|
List<Map<String, Object>> result = this.getJdbcTemplate().queryForList(
|
sql, new Object[]{companyId});
|
|
if (null == result || result.isEmpty())
|
return 0;
|
|
Object num = result.get(0).get("num");
|
|
if (Integer.valueOf(num + "") > 0)
|
return 1;
|
|
return 0;
|
}
|
|
public void flushCache(String companyId, String name) throws Exception {
|
|
// 设置分机全部掉线
|
coreSerService.allOffLine(companyId);
|
|
// 初始化缓存
|
dicTriggerService.refreshCache(companyId);
|
|
// 分机
|
coreSerService.refreshCache(companyId);
|
|
// 初始化仓库
|
depotService.flushCache(companyId);
|
|
// 初始化设备
|
deviceSerService.refreshCache(companyId);
|
|
// 系统配置
|
sysConfService.flushCacheSysConf(companyId);
|
|
// 需要先刷新仓库缓存后刷新配置
|
Thread.sleep(500);
|
|
// 参数配置
|
depotService.flushConfCache(companyId);
|
|
// 建筑物
|
buildingService.refreshCache(companyId);
|
|
// 分机配置
|
deviceService.refreshCache(companyId);
|
|
// 子部门配置
|
sysDeptService.flushDeptCache(companyId);
|
|
// 初始化控制柜仓库的虚拟用户
|
depotService.initUserDeptMap(companyId);
|
|
// 刷新菜单
|
systemService.refreshUrlCache();
|
|
log.info("* ");
|
log.info("* ========================");
|
log.info("* ");
|
log.info("* wwww.fzzygf.com");
|
log.info("* 组织={}，初始化缓存完成…………", companyId);
|
log.info("* ");
|
log.info("* ========================");
|
log.info("* ");
|
}
|
|
@Override
|
public boolean anonymousAccess() {
|
return false;
|
}
|
|
@Override
|
public boolean isDisabled() {
|
return false;
|
}
|
|
}
|
