package com.dsh.guns.modular.system.controller.general;
|
|
import cn.hutool.crypto.SecureUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.dsh.course.entity.Car;
|
import com.dsh.course.entity.City;
|
import com.dsh.course.feignClient.activity.CompanyCityClient;
|
import com.dsh.course.feignClient.activity.CompanyClient;
|
import com.dsh.course.feignClient.activity.model.*;
|
import com.dsh.course.mapper.CarMapper;
|
import com.dsh.course.mapper.CityMapper;
|
import com.dsh.guns.config.UserExt;
|
import com.dsh.guns.core.base.controller.BaseController;
|
import com.dsh.guns.core.base.tips.SuccessTip;
|
import com.dsh.guns.core.common.constant.factory.PageFactory;
|
import com.dsh.guns.core.log.LogObjectHolder;
|
import com.dsh.guns.core.util.SinataUtil;
|
import com.dsh.guns.modular.system.model.*;
|
import com.dsh.guns.modular.system.service.ITOpenCityService;
|
import com.dsh.guns.modular.system.service.ITPhoneService;
|
import com.dsh.guns.modular.system.service.ITRegionService;
|
import com.dsh.guns.modular.system.service.IUserService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.ui.Model;
|
import org.springframework.util.CollectionUtils;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import java.util.*;
|
|
/**
|
* 分公司管理控制器
|
*
|
* @author fengshuonan
|
* @Date 2020-06-06 09:15:48
|
*/
|
@Controller
|
@RequestMapping("/tCompany")
|
public class TCompanyController extends BaseController {
|
|
private String PREFIX = "/system/tCompany/";
|
//
|
// @Autowired
|
// private ITCompanyService tCompanyService;
|
|
@Autowired
|
private ITRegionService tRegionService;
|
|
@Autowired
|
private IUserService userService;
|
|
@Autowired
|
private CompanyClient companyClient;
|
@Autowired
|
private CompanyCityClient companyCityClient;
|
|
@Autowired
|
private CityMapper cityMapper;
|
@Autowired
|
private CarMapper carMapper;
|
@Autowired
|
private ITOpenCityService openCityService;
|
|
// @Value("${pushMinistryOfTransport}")
|
// private boolean pushMinistryOfTransport;
|
|
/**
|
* 跳转到修改平台信息
|
*/
|
@RequestMapping("/admin_update")
|
public String tCompanyUpdate(Model model) {
|
// CompanyInfoRes tCompany = companyClient.queryByTypeAndFlg(new CompanyQueryTypeAndFlgReq(1, 3));
|
CompanyInfoRes tCompany = companyClient.queryById(UserExt.getUser().getObjectId());
|
|
model.addAttribute("item",tCompany);
|
LogObjectHolder.me().set(tCompany);
|
Integer language = UserExt.getLanguage();
|
|
|
//系统用户对象
|
User user = userService.getOne(new QueryWrapper<User>().eq("objectId", tCompany.getId()));
|
model.addAttribute("user",user);
|
|
//经营区域
|
List<Map<String, Object>> scopeList = companyClient.getCompanyScopeById(UserExt.getUser().getObjectId());
|
List<Map<String, Object>> list = new ArrayList<>();
|
for (Map<String, Object> stringObjectMap : scopeList) {
|
Integer openCityId = (Integer) stringObjectMap.get("openCityId");
|
TOpenCity tOpenCity = openCityService.getBaseMapper().selectById(openCityId);
|
if(null == tOpenCity){
|
continue;
|
}
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", openCityId);
|
map.put("name", language == 1 ? tOpenCity.getChineseName() : language == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
list.add(map);
|
}
|
List<TOpenCity> openCities = openCityService.getBaseMapper().selectList(new QueryWrapper<TOpenCity>().ne("flag", 3)
|
.eq("status",3));
|
model.addAttribute("openCity",openCities);
|
model.addAttribute("scopeList", list);
|
model.addAttribute("tOpenCity", JSON.toJSONString(list));
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "platformEdit.html";
|
}
|
|
/**
|
* 跳转到分公司管理首页
|
*/
|
@RequestMapping("")
|
public String index(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "tCompany.html";
|
}
|
|
/**
|
* 跳转到加盟商管理首页
|
*/
|
@RequestMapping("/franchisee")
|
public String franchisee(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "franchisee.html";
|
}
|
|
/**
|
* 跳转到企业审核首页
|
*/
|
@RequestMapping("/auditPage")
|
public String auditPage(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "tCompanyAudit.html";
|
}
|
|
/**
|
* 跳转到添加分公司管理
|
*/
|
@RequestMapping("/tCompany_add")
|
public String tCompanyAdd(Model model) {
|
List<TOpenCity> openCities = openCityService.getBaseMapper().selectList(new QueryWrapper<TOpenCity>().ne("flag", 3)
|
.eq("status",3));
|
model.addAttribute("openCity",openCities);
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "tCompany_add.html";
|
}
|
|
/**
|
* 跳转到添加加盟商司管理
|
*/
|
@RequestMapping("/tCompany_addFranchisee")
|
public String tCompany_addFranchisee(Model model) {
|
Integer roleType = UserExt.getUser().getRoleType();
|
if (1 == roleType){
|
//查询分公司
|
// List<TCompany> companyList = tCompanyService.selectList(new EntityWrapper<TCompany>().eq("type", 2));
|
List<CompanyInfoRes> companyList = companyClient.queryByTypeCompany(2);
|
model.addAttribute("companyList",companyList);
|
}else if (2 == roleType){
|
CompanyInfoRes tCompany = companyClient.queryById(UserExt.getUser().getObjectId());
|
model.addAttribute("company",tCompany);
|
}
|
model.addAttribute("roleType",roleType);
|
List<TOpenCity> openCities = openCityService.getBaseMapper().selectList(new QueryWrapper<TOpenCity>().ne("flag", 3)
|
.eq("status",3));
|
model.addAttribute("openCity",openCities);
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "tCompany_addFranchisee.html";
|
}
|
|
/**
|
* 跳转到查看分公司详情
|
*/
|
@RequestMapping("/tCompany_detail/{tCompanyId}")
|
public String tCompany_detail(@PathVariable Integer tCompanyId, Model model) {
|
CompanyInfoRes tCompany = companyClient.queryById(tCompanyId);
|
model.addAttribute("item",tCompany);
|
LogObjectHolder.me().set(tCompany);
|
|
//系统用户对象
|
User user = userService.getOne(new QueryWrapper<User>().eq("roleType", 2).eq("objectId", tCompanyId).ne("status",3));
|
model.addAttribute("user",user);
|
|
//经营区域
|
List<Map<String, Object>> scopeList = companyClient.getCompanyScopeById(tCompanyId);
|
List<Map<String, Object>> list = new ArrayList<>();
|
for (Map<String, Object> stringObjectMap : scopeList) {
|
Integer openCityId = (Integer) stringObjectMap.get("openCityId");
|
TOpenCity tOpenCity = openCityService.getBaseMapper().selectById(openCityId);
|
if(null == tOpenCity){
|
continue;
|
}
|
stringObjectMap.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", openCityId);
|
map.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
list.add(map);
|
}
|
List<TOpenCity> openCities = openCityService.getBaseMapper().selectList(new QueryWrapper<TOpenCity>().ne("flag", 3)
|
.eq("status",3));
|
model.addAttribute("openCity",openCities);
|
model.addAttribute("scopeList", list);
|
model.addAttribute("tOpenCity", JSON.toJSONString(list));
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "tCompany_detail.html";
|
}
|
|
/**
|
* 跳转到修改分公司管理
|
*/
|
@RequestMapping("/tCompany_update/{tCompanyId}")
|
public String tCompanyUpdate(@PathVariable Integer tCompanyId, Model model) {
|
// TCompany tCompany = tCompanyService.selectById(tCompanyId);
|
CompanyInfoRes tCompany = companyClient.queryById(tCompanyId);
|
model.addAttribute("item",tCompany);
|
LogObjectHolder.me().set(tCompany);
|
|
//系统用户对象
|
User user = userService.getOne(new QueryWrapper<User>().eq("roleType", 2).eq("objectId", tCompanyId));
|
model.addAttribute("user",user);
|
|
//经营区域
|
List<Map<String, Object>> scopeList = companyClient.getCompanyScopeById(tCompanyId);
|
List<Map<String, Object>> list = new ArrayList<>();
|
for (Map<String, Object> stringObjectMap : scopeList) {
|
Integer openCityId = (Integer) stringObjectMap.get("openCityId");
|
TOpenCity tOpenCity = openCityService.getBaseMapper().selectById(openCityId);
|
if(null == tOpenCity){
|
continue;
|
}
|
stringObjectMap.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", openCityId);
|
map.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
list.add(map);
|
}
|
List<TOpenCity> openCities = openCityService.getBaseMapper().selectList(new QueryWrapper<TOpenCity>().ne("flag", 3)
|
.eq("status",3));
|
model.addAttribute("openCity",openCities);
|
model.addAttribute("scopeList",list);
|
model.addAttribute("tOpenCity", JSON.toJSONString(list));
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "tCompany_edit.html";
|
}
|
|
/**
|
* 跳转到查看加盟商
|
*/
|
@RequestMapping("/tCompany_detailFranchisee/{tCompanyId}")
|
public String tCompany_detailFranchisee(@PathVariable Integer tCompanyId, Model model) {
|
CompanyInfoRes tCompany = companyClient.queryById(tCompanyId);
|
model.addAttribute("item",tCompany);
|
LogObjectHolder.me().set(tCompany);
|
|
Integer roleType = UserExt.getUser().getRoleType();
|
model.addAttribute("roleType",roleType);
|
|
CompanyInfoRes obj = companyClient.queryById(tCompany.getSuperiorId());
|
if (SinataUtil.isNotEmpty(obj)){
|
model.addAttribute("companyName",obj.getName());
|
}else {
|
model.addAttribute("companyName","平台");
|
}
|
//经营区域
|
List<Map<String, Object>> scopeList = companyClient.getCompanyScopeById(tCompanyId);
|
List<Map<String, Object>> list = new ArrayList<>();
|
for (Map<String, Object> stringObjectMap : scopeList) {
|
Integer openCityId = (Integer) stringObjectMap.get("openCityId");
|
TOpenCity tOpenCity = openCityService.getBaseMapper().selectById(openCityId);
|
if(null == tOpenCity){
|
continue;
|
}
|
stringObjectMap.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", openCityId);
|
map.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
list.add(map);
|
}
|
List<TOpenCity> openCities = openCityService.getBaseMapper().selectList(new QueryWrapper<TOpenCity>().ne("flag", 3)
|
.eq("status",3));
|
model.addAttribute("openCity",openCities);
|
model.addAttribute("scopeList",scopeList);
|
model.addAttribute("tOpenCity", JSON.toJSONString(list));
|
|
|
//系统用户对象
|
User user = userService.getOne(new QueryWrapper<User>().eq("roleType", 3).eq("objectId", tCompanyId));
|
model.addAttribute("user",user);
|
return PREFIX + "tCompany_detailFranchisee.html";
|
}
|
|
/**
|
* 跳转到修改分公司管理
|
*/
|
@RequestMapping("/tCompany_updateFranchisee/{tCompanyId}")
|
public String tCompany_updateFranchisee(@PathVariable Integer tCompanyId, Model model) {
|
CompanyInfoRes tCompany = companyClient.queryById(tCompanyId);
|
model.addAttribute("item",tCompany);
|
LogObjectHolder.me().set(tCompany);
|
Integer language = UserExt.getLanguage();
|
|
Integer roleType = UserExt.getUser().getRoleType();
|
if (1 == roleType){
|
//查询分公司
|
// List<TCompany> companyList = tCompanyService.selectList(new EntityWrapper<TCompany>().eq("type", 2));
|
List<CompanyInfoRes> companyList = companyClient.queryByTypeCompany(2);
|
model.addAttribute("companyList",companyList);
|
}else if (2 == roleType){
|
CompanyInfoRes obj = companyClient.queryById(11);
|
model.addAttribute("company",obj);
|
}
|
model.addAttribute("roleType",roleType);
|
//系统用户对象
|
User user = userService.getOne(new QueryWrapper<User>().eq("roleType", 3).eq("objectId", tCompanyId));
|
model.addAttribute("user",user);
|
|
//经营区域
|
List<Map<String, Object>> scopeList = companyClient.getCompanyScopeById(1);
|
List<Map<String, Object>> list = new ArrayList<>();
|
for (Map<String, Object> stringObjectMap : scopeList) {
|
Integer openCityId = (Integer) stringObjectMap.get("openCityId");
|
TOpenCity tOpenCity = openCityService.getBaseMapper().selectById(openCityId);
|
if(null == tOpenCity){
|
continue;
|
}
|
stringObjectMap.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", openCityId);
|
map.put("name", language == 1 ? tOpenCity.getChineseName() : language == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
list.add(map);
|
}
|
List<TOpenCity> openCities = openCityService.getBaseMapper().selectList(new QueryWrapper<TOpenCity>().ne("flag", 3)
|
.eq("status",3));
|
model.addAttribute("openCity",openCities);
|
model.addAttribute("scopeList", list);
|
model.addAttribute("tOpenCity", JSON.toJSONString(list));
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "tCompany_updateFranchisee.html";
|
}
|
|
/**
|
* 跳转到立即处理页面
|
*/
|
@RequestMapping("/tCompany_immediately/{id}")
|
public String sysCouponActivityImmediately(@PathVariable Integer id, Model model) {
|
CompanyInfoRes tCompany = companyClient.queryById(id);
|
model.addAttribute("item",tCompany);
|
LogObjectHolder.me().set(tCompany);
|
|
//系统用户对象
|
if(Objects.nonNull(tCompany.getSuperId())){
|
User user = userService.getOne(new QueryWrapper<User>().eq("objectId", tCompany.getSuperId()).ne("status",3));
|
model.addAttribute("user",user);
|
}else {
|
User user = userService.getOne(new QueryWrapper<User>().eq("objectId", id).ne("status",3));
|
if(Objects.nonNull(user)){
|
model.addAttribute("user",user);
|
}else {
|
model.addAttribute("user",new User());
|
}
|
}
|
|
//经营区域
|
List<Map<String, Object>> scopeList = companyClient.getCompanyCityById(id);
|
List<Map<String, Object>> list = new ArrayList<>();
|
for (Map<String, Object> stringObjectMap : scopeList) {
|
Integer openCityId = (Integer) stringObjectMap.get("openCityId");
|
TOpenCity tOpenCity = openCityService.getBaseMapper().selectById(openCityId);
|
if(null == tOpenCity){
|
continue;
|
}
|
stringObjectMap.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", openCityId);
|
map.put("name", UserExt.getLanguage() == 1 ? tOpenCity.getChineseName() : UserExt.getLanguage() == 2 ? tOpenCity.getEnglishName() : tOpenCity.getIndonesianName());
|
list.add(map);
|
}
|
List<TOpenCity> openCities = openCityService.getBaseMapper().selectList(new QueryWrapper<TOpenCity>().ne("flag", 3)
|
.eq("status",3));
|
model.addAttribute("openCity",openCities);
|
model.addAttribute("scopeList", list);
|
model.addAttribute("tOpenCity", JSON.toJSONString(list));
|
model.addAttribute("id",id);
|
model.addAttribute("language", UserExt.getLanguage());
|
return PREFIX + "tCompanyAudit_immediately.html";
|
}
|
|
/**
|
* 立即处理操作
|
*/
|
@RequestMapping(value = "/immediately")
|
@Transactional(rollbackFor = Exception.class)
|
@ResponseBody
|
public Object immediately(@RequestParam Integer id,@RequestParam Integer state,@RequestParam String remark) {
|
CompanyInfoRes tCompany = companyClient.queryById(id);
|
if (SinataUtil.isNotEmpty(tCompany)){
|
if(Objects.nonNull(tCompany.getSuperId()) && state == 3){
|
// 查询出上一条老的数据
|
CompanyInfoRes byId = companyClient.queryById(tCompany.getSuperId());
|
|
Integer byIdId = byId.getId();
|
// 审核通过的新数据覆盖老的数据
|
tCompany.setId(null);
|
BeanUtils.copyProperties(tCompany,byId);
|
byId.setId(byIdId);
|
byId.setSuperId(null);
|
byId.setStatus(state);
|
byId.setRemark(remark);
|
companyClient.updateCompany(byId);
|
|
User user = userService.getOne(Wrappers.lambdaQuery(User.class)
|
.eq(User::getObjectId, byIdId)
|
.last("LIMIT 1"));
|
if(Objects.nonNull(user)){
|
user.setName(tCompany.getName());
|
userService.updateById(user);
|
}
|
|
// 删除老数据的公司经营业务
|
companyCityClient.removeByCompanyId(byId.getId());
|
// 查询新数据的经营业务，指向老数据
|
List<TCompanyCityResp> list = companyClient.getCompanyCityByCompanyId(id);
|
for (TCompanyCityResp tCompanyCityResp : list) {
|
tCompanyCityResp.setCompanyId(byId.getId());
|
tCompanyCityResp.setState(1);
|
companyClient.updateCompanyCity(tCompanyCityResp);
|
}
|
// 删除新数据
|
companyClient.removeById(id);
|
}else {
|
tCompany.setStatus(state);
|
tCompany.setRemark(remark);
|
CompanyInfoRes companyInfoRes = new CompanyInfoRes();
|
BeanUtils.copyProperties(tCompany,companyInfoRes);
|
companyClient.updateCompany(companyInfoRes);
|
}
|
}
|
return SUCCESS_TIP;
|
}
|
|
|
@RequestMapping(value = "/change")
|
@ResponseBody
|
public Object change(@RequestParam Integer code) {
|
List<City> list = new ArrayList<>();
|
if (SinataUtil.isNotEmpty(code)){
|
list = cityMapper.selectList(new QueryWrapper<City>().eq("pid",code));
|
}
|
Integer language = UserExt.getLanguage();
|
if(language==2){
|
for (City city : list) {
|
city.setChineseName(city.getEnglishName());
|
}
|
}
|
if(language==3){
|
for (City city : list) {
|
city.setChineseName(city.getIndonesianName());
|
}
|
}
|
return list;
|
}
|
|
/**
|
* 获取分公司审核列表
|
*/
|
@RequestMapping(value = "/auditList")
|
@ResponseBody
|
public Object auditList(String insertTime,
|
String name,
|
String principalName,
|
String principalPhone,
|
String adminName,
|
String adminPhone,
|
String serviceStr,
|
Integer state) {
|
String beginTime = null;
|
String endTime = null;
|
if (SinataUtil.isNotEmpty(insertTime)){
|
String[] timeArray = insertTime.split(" - ");
|
beginTime = timeArray[0];
|
endTime = timeArray[1];
|
}
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
Integer language = UserExt.getLanguage();
|
List<Map<String, Object>> companyList = companyClient.getAuditList(new GetCompanyListReq(page, beginTime, endTime, name, principalName, principalPhone, adminName, adminPhone, serviceStr, state,language));
|
for (Map<String, Object> stringObjectMap : companyList) {
|
Integer id = (Integer) stringObjectMap.get("id");
|
Integer integer = carMapper.selectCount(new LambdaQueryWrapper<Car>().eq(Car::getCompanyId, id));
|
stringObjectMap.put("carNumber",integer);
|
List<User> users = userService.getBaseMapper().selectList(new LambdaQueryWrapper<User>().eq(User::getObjectId, id));
|
if(!CollectionUtils.isEmpty(users)){
|
stringObjectMap.put("account",users.get(0).getAccount());
|
}else {
|
stringObjectMap.put("account","");
|
}
|
}
|
page.setRecords(companyList);
|
return super.packForBT(page);
|
}
|
|
|
/**
|
* 获取分公司管理列表
|
*/
|
@RequestMapping(value = "/list")
|
@ResponseBody
|
public Object list(String insertTime,
|
String name,
|
String principalName,
|
String principalPhone,
|
String adminName,
|
String adminPhone,
|
String serviceStr,
|
Integer state) {
|
String beginTime = null;
|
String endTime = null;
|
if (SinataUtil.isNotEmpty(insertTime)){
|
String[] timeArray = insertTime.split(" - ");
|
beginTime = timeArray[0];
|
endTime = timeArray[1];
|
}
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
Integer language = UserExt.getLanguage();
|
List<Map<String, Object>> companyList = companyClient.getCompanyList(new GetCompanyListReq(page, beginTime, endTime, name, principalName, principalPhone, adminName, adminPhone, serviceStr, state,language));
|
for (Map<String, Object> stringObjectMap : companyList) {
|
Integer id = (Integer) stringObjectMap.get("id");
|
Integer integer = carMapper.selectCount(new LambdaQueryWrapper<Car>().eq(Car::getCompanyId, id));
|
stringObjectMap.put("carNumber",integer);
|
List<User> users = userService.getBaseMapper().selectList(new LambdaQueryWrapper<User>().eq(User::getObjectId, id));
|
if(users.size()>0) {
|
stringObjectMap.put("account", users.get(0).getAccount());
|
}
|
}
|
page.setRecords(companyList);
|
return super.packForBT(page);
|
}
|
|
/**
|
* 获取分公司管理列表
|
*/
|
@RequestMapping(value = "/listFranchisee")
|
@ResponseBody
|
public Object listFranchisee(String insertTime,
|
String name,
|
String account,
|
String principalName,
|
String principalPhone,
|
String serviceStr,
|
Integer state) {
|
String beginTime = null;
|
String endTime = null;
|
if (SinataUtil.isNotEmpty(insertTime)){
|
String[] timeArray = insertTime.split(" - ");
|
beginTime = timeArray[0];
|
endTime = timeArray[1];
|
}
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
if (UserExt.getUser().getRoleType() == 3){
|
page.setRecords(null);
|
}else{
|
Integer language = UserExt.getLanguage();
|
List<Map<String, Object>> franchiseeList1 = companyClient.getFranchiseeList1(new GetFranchiseeList1Req(page, beginTime, endTime, name, account, principalName, principalPhone, serviceStr, state, UserExt.getUser().getRoleType(), UserExt.getUser().getObjectId(),language));
|
for (Map<String, Object> stringObjectMap : franchiseeList1) {
|
Integer id = (Integer) stringObjectMap.get("id");
|
Integer integer = carMapper.selectCount(new LambdaQueryWrapper<Car>().eq(Car::getFranchiseeId, id));
|
stringObjectMap.put("carNumber",integer);
|
List<User> users = userService.getBaseMapper().selectList(new LambdaQueryWrapper<User>().eq(User::getObjectId, id));
|
stringObjectMap.put("account",users.get(0).getAccount());
|
}
|
page.setRecords(franchiseeList1);
|
}
|
return super.packForBT(page);
|
}
|
|
/**
|
* 新增分公司管理
|
*/
|
@RequestMapping(value = "/add")
|
@ResponseBody
|
public Object add(TCompany tCompany,@RequestParam String subArr,String account,String password) {
|
//判断账号是否已存在
|
int count = userService.getBaseMapper().selectCount(new QueryWrapper<User>().eq("account", account));
|
if (count > 0){
|
return new SuccessTip(500,"error1");
|
}
|
tCompany.setType(2); //2：分公司
|
tCompany.setState(0); //0：正常
|
tCompany.setInsertTime(new Date());
|
SaveCompanyReq saveCompanyReq = new SaveCompanyReq();
|
BeanUtils.copyProperties(tCompany,saveCompanyReq);
|
Integer integer = companyClient.saveCompany(saveCompanyReq);
|
|
//添加User对象
|
User user = new User();
|
user.setAccount(account);
|
// user.setSalt(ShiroKit.getRandomSalt(5));
|
user.setPassword(SecureUtil.md5(password));
|
user.setRoleid("2");
|
user.setDeptid(25);
|
user.setStatus(1);
|
user.setCreatetime(new Date());
|
user.setRoleType(2);
|
user.setObjectId(integer);
|
user.setName(tCompany.getName());
|
user.setSex(1);
|
userService.save(user);
|
|
|
addSet(integer);
|
|
|
|
//添加经营区域
|
addScopeAudit(subArr,integer);
|
return SUCCESS_TIP;
|
}
|
//添加经营区域
|
public void addSocpe(String subArr,Integer id){
|
JSONArray jsonArray = JSON.parseArray(subArr);
|
companyClient.deleteByCompanyId(id);
|
int size = jsonArray.size();
|
companyClient.deleteCompanyCity(id);
|
for (int i = 0; i < size; i++){
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
// TCompanyCityResp tCompanyCity = companyClient.queryCompanyCityByIdAndCompanyId(new QueryCompanyCityReq(jsonObject.getInteger("recordId"), id));
|
|
// TCompanyCity tCompanyCity = tCompanyCityService.selectOne(new EntityWrapper<TCompanyCity>().eq("id", jsonObject.getInteger("recordId")).eq("companyId", id));
|
TCompanyCityResp tCompanyCity = new TCompanyCityResp();
|
Integer openCityId = jsonObject.getInteger("id");
|
tCompanyCity.setOpenCityId(openCityId);
|
tCompanyCity.setCompanyId(id);
|
tCompanyCity.setState(1);
|
companyClient.saveCompanyCity(tCompanyCity);
|
}
|
}
|
|
//添加经营区域
|
public void addScopeAudit(String subArr,Integer id){
|
JSONArray jsonArray = JSON.parseArray(subArr);
|
companyClient.deleteByCompanyId(id);
|
int size = jsonArray.size();
|
companyClient.deleteCompanyCity(id);
|
for (int i = 0; i < size; i++){
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
// TCompanyCityResp tCompanyCity = companyClient.queryCompanyCityByIdAndCompanyId(new QueryCompanyCityReq(jsonObject.getInteger("recordId"), id));
|
|
// TCompanyCity tCompanyCity = tCompanyCityService.selectOne(new EntityWrapper<TCompanyCity>().eq("id", jsonObject.getInteger("recordId")).eq("companyId", id));
|
TCompanyCityResp tCompanyCity = new TCompanyCityResp();
|
Integer openCityId = jsonObject.getInteger("id");
|
tCompanyCity.setOpenCityId(openCityId);
|
tCompanyCity.setCompanyId(id);
|
tCompanyCity.setState(0);
|
companyClient.saveCompanyCity(tCompanyCity);
|
}
|
}
|
|
/**
|
* 新增加盟商管理
|
*/
|
@RequestMapping(value = "/addFranchisee")
|
@ResponseBody
|
public Object addFranchisee(TCompany tCompany,@RequestParam String subArr,String account,String password) {
|
//判断账号是否已存在
|
int count = userService.getBaseMapper().selectCount(new QueryWrapper<User>().eq("account", account));
|
if (count > 0){
|
return "error1";
|
}
|
tCompany.setType(3); //2：分公司
|
if (UserExt.getUser().getRoleType() == 2){
|
tCompany.setSuperiorId(UserExt.getUser().getObjectId());
|
}
|
tCompany.setState(0); //0：正常
|
tCompany.setInsertTime(new Date());
|
SaveCompanyReq saveCompanyReq = new SaveCompanyReq();
|
BeanUtils.copyProperties(tCompany,saveCompanyReq);
|
Integer integer = companyClient.saveCompany(saveCompanyReq);
|
//添加User对象
|
User user = new User();
|
user.setAccount(account);
|
// user.setSalt(ShiroKit.getRandomSalt(5));
|
user.setPassword(SecureUtil.md5(password));
|
user.setRoleid("3");
|
user.setDeptid(26);
|
user.setStatus(1);
|
user.setCreatetime(new Date());
|
user.setRoleType(3);
|
user.setObjectId(integer);
|
user.setName(tCompany.getName());
|
user.setSex(1);
|
userService.save(user);
|
|
addSet(integer);
|
addScopeAudit(subArr,integer);
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 删除分公司管理
|
*/
|
@RequestMapping(value = "/delete")
|
@ResponseBody
|
public Object delete(@RequestParam Integer tCompanyId) {
|
// TCompany tCompany = tCompanyService.selectById(tCompanyId);
|
CompanyInfoRes tCompany = companyClient.queryById(tCompanyId);
|
// tCompany.setFlag("3");
|
tCompany.setFlag(3);
|
companyClient.updateCompany(tCompany);
|
companyCityClient.removeByCompanyId(tCompanyId);
|
userService.remove(new LambdaQueryWrapper<User>().eq(User::getObjectId, tCompanyId));
|
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 修改分公司管理
|
*/
|
@RequestMapping(value = "/update")
|
@ResponseBody
|
public Object update(TCompany tCompany,@RequestParam String subArr,String account,String password,Integer userId) {
|
//判断账号是否已存在
|
User user = userService.getById(userId);
|
//添加User对象
|
if (SinataUtil.isNotEmpty(account) && SinataUtil.isNotEmpty(password)){
|
if (!user.getAccount().equals(account)){
|
//判断账号是否已存在
|
int count = userService.getBaseMapper().selectCount(new QueryWrapper<User>().eq("account", account));
|
if (count > 0){
|
return "error";
|
}
|
}
|
user.setAccount(account);
|
user.setPassword(SecureUtil.md5(password));
|
userService.updateById(user);
|
}
|
CompanyInfoRes companyInfoRes = companyClient.queryById(tCompany.getId());
|
tCompany.setType(companyInfoRes.getType()); //2：分公司
|
tCompany.setState(0); //0：正常
|
tCompany.setInsertTime(new Date());
|
SaveCompanyReq saveCompanyReq = new SaveCompanyReq();
|
BeanUtils.copyProperties(tCompany,saveCompanyReq);
|
saveCompanyReq.setId(null);
|
saveCompanyReq.setSuperId(tCompany.getId());
|
Integer integer = companyClient.saveCompany(saveCompanyReq);
|
|
addSet(integer);
|
//添加经营区域
|
addScopeAudit(subArr,integer);
|
return SUCCESS_TIP;
|
}
|
|
// /**
|
// * 修改分公司管理
|
// */
|
// @RequestMapping(value = "/update")
|
// @ResponseBody
|
// public Object update(TCompany tCompany,@RequestParam String subArr,String account,String password,Integer userId) {
|
// //判断账号
|
// User user = userService.getById(userId);
|
// if (SinataUtil.isNotEmpty(account) && SinataUtil.isNotEmpty(password)){
|
// if (!user.getAccount().equals(account)){
|
// //判断账号是否已存在
|
// int count = userService.getBaseMapper().selectCount(new QueryWrapper<User>().eq("account", account));
|
// if (count > 0){
|
// return "error";
|
// }
|
// }
|
// //修改账号密码
|
// user.setAccount(account);
|
//// user.setSalt(ShiroKit.getRandomSalt(5));
|
// user.setPassword(SecureUtil.md5(password));
|
// }
|
// CompanyInfoRes companyInfoRes = new CompanyInfoRes();
|
// BeanUtils.copyProperties(tCompany,companyInfoRes);
|
//
|
// companyClient.updateCompany(companyInfoRes);
|
// user.setName(tCompany.getName());
|
// userService.updateById(user);
|
//
|
// //添加经营区域
|
// addSocpe(subArr,tCompany.getId());
|
//
|
// CompanyInfoRes tCompany1 = companyClient.queryById(tCompany.getId());
|
// if(tCompany1.getType() == 1){
|
//// new Thread(new Runnable() {
|
//// @Override
|
//// public void run() {
|
//// if(pushMinistryOfTransport){//上传平台数据
|
//// pushMinistryOfTransportUtil.baseInfoCompanyPay();//上传网约车平台公司支付信息
|
//// pushMinistryOfTransportUtil.baseInfoCompany(tCompany.getId());
|
//// pushMinistryOfTransportUtil.baseInfoCompanyService();
|
//// pushMinistryOfTransportUtil.baseInfoCompanyPermit(tCompany.getId());
|
//// }
|
//// }
|
//// }).start();
|
// }
|
// return SUCCESS_TIP;
|
// }
|
|
/**
|
* 修改加盟商管理
|
*/
|
@RequestMapping(value = "/updateFranchisee")
|
@ResponseBody
|
public Object updateFranchisee(TCompany tCompany,@RequestParam String subArr,String account,String password,Integer userId) {
|
//判断账号
|
User user = userService.getById(userId);
|
if (!user.getAccount().equals(account)){
|
//判断账号是否已存在
|
int count = userService.getBaseMapper().selectCount(new QueryWrapper<User>().eq("account", account));
|
if (count > 0){
|
return "error";
|
}
|
user.setAccount(account);
|
user.setPassword(SecureUtil.md5(password));
|
userService.updateById(user);
|
}
|
tCompany.setType(3); //2：分公司
|
if (UserExt.getUser().getRoleType() == 2){
|
tCompany.setSuperiorId(UserExt.getUser().getObjectId());
|
}
|
tCompany.setState(0); //0：正常
|
tCompany.setInsertTime(new Date());
|
SaveCompanyReq saveCompanyReq = new SaveCompanyReq();
|
BeanUtils.copyProperties(tCompany,saveCompanyReq);
|
saveCompanyReq.setId(null);
|
saveCompanyReq.setSuperId(tCompany.getId());
|
Integer integer = companyClient.saveCompany(saveCompanyReq);
|
|
addSet(integer);
|
addScopeAudit(subArr,integer);
|
return SUCCESS_TIP;
|
}
|
|
// /**
|
// * 修改加盟商管理
|
// */
|
// @RequestMapping(value = "/updateFranchisee")
|
// @ResponseBody
|
// public Object updateFranchisee(TCompany tCompany,@RequestParam String subArr,String account,String password,Integer userId) {
|
// //判断账号
|
// User user = userService.getById(userId);
|
// if (!user.getAccount().equals(account)){
|
// //判断账号是否已存在
|
// int count = userService.getBaseMapper().selectCount(new QueryWrapper<User>().eq("account", account));
|
// if (count > 0){
|
// return "error";
|
// }
|
// }
|
//
|
// CompanyInfoRes companyInfoRes = new CompanyInfoRes();
|
// BeanUtils.copyProperties(tCompany,companyInfoRes);
|
// companyClient.updateCompany(companyInfoRes);
|
//
|
// //修改账号密码
|
// user.setAccount(account);
|
//// user.setSalt(ShiroKit.getRandomSalt(5));
|
//// user.setPassword(ShiroKit.md5(password, user.getSalt()));
|
// user.setName(tCompany.getName());
|
// userService.updateById(user);
|
// addSocpe(subArr,tCompany.getId());
|
// return SUCCESS_TIP;
|
// }
|
|
|
@Autowired
|
private ITPhoneService tPhoneService;
|
|
private void addSet(Integer companyId){
|
String json0 = "{\"num1\":\"\",\"num2\":\"\"}";
|
//修改积分设置
|
tPhoneService.addIntegral(json0,companyId);
|
|
|
String json1 = "{\"num1\":\"\",\"num2\":\"\",\"num3\":\"\"}";
|
// 修改等待超时
|
tPhoneService.addWait(json1,companyId);
|
|
String json2 = "[{\"num1\":\"\",\"num2\":\"\"},{\"num1\":\"\",\"num2\":\"\"}]";
|
// 修改注册时长
|
tPhoneService.addRegister(json2,companyId);
|
|
String json3 ="[{\"num1\":\"\",\"num2\":\"\",\"num3\":\"\"},{\"num1\":\"\",\"num2\":\"\",\"num3\":\"\"}]";
|
// 修改用户等级
|
tPhoneService.addUserLevel(json3,companyId);
|
|
String json4 = "{\"num1\":\"\",\"num2\":\"\",\"num3\":\"\",\"num4\":\"\",\"num5\":\"\",\"num6\":\"\",\"num7\":\"\",\"num8\":\"\",\"num9\":\"\",\"num10\":\"\",\"num11\":\"\",\"num12\":\"\"}";
|
//修改摩托车退单
|
tPhoneService.addMotorPushOrder(json4,companyId);
|
|
String json5 = "{\"num1\":\"\",\"num2\":\"\",\"num3\":\"\",\"num4\":\"\",\"num5\":\"\",\"num6\":\"\",\"num7\":\"\",\"num8\":\"\",\"num9\":\"\",\"num10\":\"\",\"num11\":\"\",\"num12\":\"\"}";
|
//修改同城快送推单
|
tPhoneService.addSendOrder(json5,companyId);
|
|
// 修改 取消设置
|
tPhoneService.addCancel(companyId);
|
|
// 修改预约取消设置
|
tPhoneService.addYyCancel(companyId);
|
|
// 修改 报警电话
|
tPhoneService.addPolice(companyId);
|
|
// 修改客服电话
|
tPhoneService.addTalk(companyId);
|
|
//修改保底
|
tPhoneService.addMin(companyId);
|
|
}
|
}
|
