package com.ruoyi.web.controller.station;
|
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.List;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.ruoyi.common.constant.UrlConstant;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.IdUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.station.domain.*;
|
import com.ruoyi.station.model.TmpDataModel;
|
import com.ruoyi.station.model.WorkUserModel;
|
import com.ruoyi.station.service.*;
|
import org.apache.shiro.authz.annotation.RequiresPermissions;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.ui.ModelMap;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import com.ruoyi.common.annotation.Log;
|
import com.ruoyi.common.enums.BusinessType;
|
import com.ruoyi.common.core.controller.BaseController;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.common.utils.poi.ExcelUtil;
|
import com.ruoyi.common.core.page.TableDataInfo;
|
import org.springframework.web.client.RestTemplate;
|
|
/**
|
* 组Controller
|
*
|
* @author ruoyi
|
* @date 2020-08-27
|
*/
|
@Controller
|
@RequestMapping("/station/team")
|
public class MjTeamController extends BaseController
|
{
|
private String prefix = "station/team";
|
|
@Autowired
|
private IMjTeamService mjTeamService;
|
|
@Autowired
|
private IMjTeamMemberService mjTeamMemberService;
|
|
@Autowired
|
private IMjTeamAreaService mjTeamAreaService;
|
|
@Autowired
|
private IMjFingerprintService mjFingerprintService;
|
|
@Autowired
|
private IMjFingerprintReadHeadService mjFingerprintReadHeadService;
|
|
@Autowired
|
private IMjWorkUserPushService mjWorkUserPushService;
|
|
@Autowired
|
private IMjVisitLogService iMjVisitLogService;
|
@Autowired
|
private IMjHeadsUsersService iMjHeadsUsersService;
|
|
@RequiresPermissions("station:team:view")
|
@GetMapping()
|
public String team()
|
{
|
return prefix + "/team";
|
}
|
|
/**
|
* 查询组列表
|
*/
|
@RequiresPermissions("station:team:list")
|
@PostMapping("/list")
|
@ResponseBody
|
public TableDataInfo list(MjTeam mjTeam)
|
{
|
startPage();
|
List<MjTeam> list = mjTeamService.selectMjTeamList(mjTeam);
|
return getDataTable(list);
|
}
|
|
/**
|
* 导出组列表
|
*/
|
@RequiresPermissions("station:team:export")
|
@Log(title = "组", businessType = BusinessType.EXPORT)
|
@PostMapping("/export")
|
@ResponseBody
|
public AjaxResult export(MjTeam mjTeam)
|
{
|
List<MjTeam> list = mjTeamService.selectMjTeamList(mjTeam);
|
ExcelUtil<MjTeam> util = new ExcelUtil<MjTeam>(MjTeam.class);
|
return util.exportExcel(list, "team");
|
}
|
|
/**
|
* 新增组
|
*/
|
@GetMapping("/add")
|
public String add()
|
{
|
return prefix + "/add";
|
}
|
|
/**
|
* 新增保存组
|
*/
|
@RequiresPermissions("station:team:add")
|
@Log(title = "组", businessType = BusinessType.INSERT)
|
@PostMapping("/add")
|
@ResponseBody
|
public AjaxResult addSave(MjTeam mjTeam)
|
{
|
mjTeam.setUpdateTime(DateUtils.getNowDate());
|
mjTeam.setId(IdUtils.fastSimpleUUID());
|
mjTeam.setTeamNumber(0);
|
mjTeam.setAreaNumber(0);
|
mjTeam.setEquipmentUpdateStatus(0);
|
return toAjax(mjTeamService.insertMjTeam(mjTeam));
|
}
|
|
/**
|
* 修改组
|
*/
|
@GetMapping("/edit/{id}")
|
public String edit(@PathVariable("id") String id, ModelMap mmap)
|
{
|
MjTeam mjTeam = mjTeamService.selectMjTeamById(id);
|
mmap.put("mjTeam", mjTeam);
|
return prefix + "/edit";
|
}
|
|
/**
|
* 修改保存组
|
*/
|
@RequiresPermissions("station:team:edit")
|
@Log(title = "组", businessType = BusinessType.UPDATE)
|
@PostMapping("/edit")
|
@ResponseBody
|
public AjaxResult editSave(MjTeam mjTeam)
|
{
|
return toAjax(mjTeamService.updateMjTeam(mjTeam));
|
}
|
|
/**
|
* 删除组
|
*/
|
@RequiresPermissions("station:team:remove")
|
@Log(title = "组", businessType = BusinessType.DELETE)
|
@PostMapping( "/remove")
|
@ResponseBody
|
public AjaxResult remove(String ids)
|
{
|
return toAjax(mjTeamService.deleteMjTeamByIds(ids));
|
}
|
|
/**
|
* 根据id获取组
|
* @param id
|
* @return
|
*/
|
@PostMapping("/findById")
|
@ResponseBody
|
public Object findById(String id)
|
{
|
MjTeam mjTeam = mjTeamService.selectMjTeamById(id);
|
return mjTeam;
|
}
|
|
/**
|
* 新增组
|
*/
|
@GetMapping("/parent")
|
public String parent()
|
{
|
return prefix + "/parent";
|
}
|
/**
|
* 新增组
|
*/
|
@GetMapping("/parent2")
|
public String parent2()
|
{
|
return prefix + "/parent2";
|
}
|
|
/**
|
*
|
* @param id
|
* @return
|
*/
|
@PostMapping("/pushDataToReadHead2")
|
@ResponseBody
|
public AjaxResult pushDataToReadHead(String id) {
|
addLog("组授权java逻辑代码开始执行，将要推送的数据开始筛选");
|
if(StringUtils.isEmpty(id)) {
|
return AjaxResult.error("未获取到id，请联系管理员！");
|
}
|
MjTeam team = new MjTeam();
|
team.setEquipmentUpdateStatus(0);
|
team.setId(id);
|
List<MjTeam> mjTeams = mjTeamService.selectMjTeamList(team);
|
if(mjTeams != null && mjTeams.size() > 0) {
|
return AjaxResult.error("该组已同步完成！");
|
}
|
|
MjTeamMember teamMember = new MjTeamMember();
|
teamMember.setTeamId(id);
|
List<MjTeamMember> teamMemberList = mjTeamMemberService.selectMjTeamMemberList2(teamMember); //组成员
|
|
MjTeamArea teamArea = new MjTeamArea();
|
teamArea.setTeamId(id);
|
List<MjTeamArea> teamAreaList = mjTeamAreaService.selectMjTeamAreaList2(teamArea); //组区域
|
|
List<String> areaIdList = new ArrayList<>();
|
List<String> AddAreaIdList = new ArrayList<>();
|
List<MjFingerprintReadHead> fingerprintReadHeads = new ArrayList<>();
|
List<MjFingerprintReadHead> addFingerprintReadHeads = new ArrayList<>();
|
List<MjFingerprintReadHead> delFingerprintReadHeads = new ArrayList<>();
|
if(teamAreaList != null && teamAreaList.size() > 0) {
|
for(MjTeamArea area : teamAreaList) {
|
if(area.getStatus() == 0) {
|
if(area.getDelFlag() != 1) {
|
List<MjFingerprintReadHead> heads = null;
|
AddAreaIdList.add(area.getAreaId()); //获取需增加的区域idlist
|
|
MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
|
fingerprintReadHead.setAreaId(area.getAreaId());
|
heads = mjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
|
addFingerprintReadHeads.addAll(heads);
|
MjTeamArea tArea = new MjTeamArea();
|
tArea.setStatus(1);
|
tArea.setId(area.getId());
|
mjTeamAreaService.updateMjTeamArea(tArea); //修改区域状态为已同步
|
}
|
}else if(area.getStatus() == 2) {
|
List<MjFingerprintReadHead> heads = null;
|
MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
|
fingerprintReadHead.setAreaId(area.getAreaId());
|
heads = mjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
|
delFingerprintReadHeads.addAll(heads);
|
|
MjTeamArea tArea = new MjTeamArea();
|
tArea.setStatus(1);
|
tArea.setId(area.getId());
|
mjTeamAreaService.updateMjTeamArea(tArea); //修改区域状态为已同步
|
}else {
|
if(area.getDelFlag() != 1) {
|
List<MjFingerprintReadHead> heads = null;
|
areaIdList.add(area.getAreaId());
|
|
MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
|
fingerprintReadHead.setAreaId(area.getAreaId());
|
heads = mjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
|
fingerprintReadHeads.addAll(heads);
|
}
|
}
|
}
|
}
|
|
List<WorkUserModel> addWorkUserModelList = new ArrayList<>(); //新增用户
|
List<WorkUserModel> addAreaWorkUserModelList = new ArrayList<>(); //新增区域
|
int a = 0;
|
if(teamMemberList != null && teamMemberList.size() > 0) {
|
for(MjTeamMember member : teamMemberList) {
|
if(member.getStatus() == 0) {
|
List<TmpDataModel> mjFingerprintList = mjFingerprintService.selectMjFingerprintListByUserId(Long.parseLong(member.getUserId())); //获取负责人指纹信息
|
WorkUserModel workUserModel = domainToModel(member, mjFingerprintList);
|
addWorkUserModelList.add(workUserModel);
|
MjTeamMember mem = new MjTeamMember();
|
mem.setStatus(1);
|
mem.setId(member.getId());
|
mjTeamMemberService.updateMjTeamMember(mem); //改变用户状态为已同步
|
}else if(member.getStatus() == 2) {
|
if(fingerprintReadHeads != null && fingerprintReadHeads.size() > 0) {
|
fingerprintReadHeads.addAll(delFingerprintReadHeads);
|
delUserTmp(fingerprintReadHeads, member.getUserId());
|
MjTeamMember mem = new MjTeamMember();
|
mem.setStatus(1);
|
mem.setId(member.getId());
|
mjTeamMemberService.updateMjTeamMember(mem); //改变用户状态为已同步
|
}
|
}else { //用户没有变化，区域变化
|
if(delFingerprintReadHeads != null && delFingerprintReadHeads.size() > 0) { //需要删除的区域
|
delUserTmp(delFingerprintReadHeads, member.getUserId());
|
}
|
if(addFingerprintReadHeads != null && addFingerprintReadHeads.size() > 0) { //需要添加的区域
|
List<TmpDataModel> mjFingerprintList = mjFingerprintService.selectMjFingerprintListByUserId(Long.parseLong(member.getUserId())); //获取负责人指纹信息
|
WorkUserModel workUserModel = domainToModel(member, mjFingerprintList);
|
addAreaWorkUserModelList.add(workUserModel);
|
a=1;
|
}
|
}
|
}
|
addLog("组授权java逻辑代码结束执行，将要推送的数据筛选结束");
|
Integer code = 0;
|
if(addWorkUserModelList != null && addWorkUserModelList.size() > 0) {
|
areaIdList.addAll(AddAreaIdList);
|
JSONArray jsonArray=new JSONArray(Collections.singletonList(addWorkUserModelList));
|
String userDatas = jsonArray.toString().substring(1, jsonArray.toString().length()-1);
|
code = addTeamUsers(userDatas, areaIdList, id);
|
}
|
if(a == 1) {
|
JSONArray jsonArray=new JSONArray(Collections.singletonList(addAreaWorkUserModelList));
|
String userDatas = jsonArray.toString().substring(1, jsonArray.toString().length()-1);
|
code = addTeamUsers(userDatas, AddAreaIdList, id);
|
}
|
if(code != 0) {
|
return AjaxResult.error("同步失败！");
|
}
|
}
|
|
MjTeam team1 = new MjTeam();
|
team1.setEquipmentUpdateStatus(0);
|
team1.setId(id);
|
mjTeamService.updateMjTeam(team1); //改变组状态为已同步
|
return AjaxResult.success("同步成功！");
|
|
}
|
|
|
//增加组用户
|
private Integer addTeamUsers(String value, List<String> areaIdList,String id) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
JSONObject jsonObject = null;
|
if(areaIdList.size() > 0) {
|
for(String areaId : areaIdList) {
|
MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
|
fingerprintReadHead.setAreaId(areaId);
|
List<MjFingerprintReadHead> fingerprintReadHeads = mjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
|
for(MjFingerprintReadHead head : fingerprintReadHeads) {
|
MultiValueMap<String, Object> map= new LinkedMultiValueMap<>();
|
|
map.add("ip", head.getIpOrOther());
|
map.add("port", head.getPort());
|
map.add("userDatas", value);
|
|
HttpEntity<MultiValueMap<String, Object>> request = new HttpEntity<>(map, headers);
|
try {
|
addLog("组授权通过C#接口批量增加用户--开始。推送的人数："+value.length()+"人"+"，推送的读头ip:"+head.getIpOrOther());
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktAddUserTmpByList", request , String.class );
|
jsonObject = JSONObject.parseObject(response.getBody());
|
System.out.println(response.getBody());
|
addLog("组授权通过C#接口批量增加用户--结束");
|
/* if(jsonObject != null && (int)jsonObject.get("code") == 0) {
|
MjTeam team = new MjTeam();
|
team.setEquipmentUpdateStatus(0);
|
team.setId(id);
|
mjTeamService.updateMjTeam(team); //改变组状态为已同步
|
}*/
|
}catch (Exception e) {
|
e.printStackTrace();
|
return 1;
|
}
|
}
|
}
|
}
|
if(jsonObject != null) {
|
return (int)jsonObject.get("code");
|
}
|
return 1;
|
}
|
|
//删除组用户指纹
|
private void delUserTmp(List<MjFingerprintReadHead> heads, String userId) {
|
if(heads != null && heads.size() > 0) {
|
addLog("组授权删除组用户指纹开始");
|
for(MjFingerprintReadHead head : heads) {
|
if(StringUtils.isNotEmpty(head.getIpOrOther()) && StringUtils.isNotEmpty(head.getPort())) {
|
mjWorkUserPushService.removeFingerTmp(userId, head.getIpOrOther(), head.getPort());
|
}
|
}
|
addLog("组授权删除组用户指纹结束");
|
}
|
}
|
|
//转换为访问所需model
|
private WorkUserModel domainToModel(MjTeamMember member, List<TmpDataModel> mjFingerprintList) {
|
WorkUserModel workUserModel = new WorkUserModel();
|
workUserModel.setId(member.getUserId().toString().trim());
|
workUserModel.setName(member.getUserName().trim());
|
workUserModel.setPass("");
|
workUserModel.setiPrivilege(0);
|
workUserModel.setFlag("a");
|
workUserModel.setTmpDatas(mjFingerprintList);
|
return workUserModel;
|
}
|
|
private void addLog(String content){
|
MjVisitLog mjVisitLog = new MjVisitLog();
|
mjVisitLog.setDelFlag(1);
|
mjVisitLog.setUserName(content);
|
mjVisitLog.setId(IdUtils.fastSimpleUUID());
|
iMjVisitLogService.insertMjVisitLog(mjVisitLog);
|
}
|
|
/**
|
*
|
* @param id
|
* @return
|
*/
|
@PostMapping("/pushDataToReadHead")
|
@ResponseBody
|
public AjaxResult pushDataToReadHead2(String id) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
List<WorkUserModel> user = getUser(id);
|
String value = JSONArray.toJSON(user).toString();
|
|
MjTeam team = mjTeamService.selectMjTeamById(id);
|
|
MjTeamArea teamArea = new MjTeamArea();
|
teamArea.setTeamId(id);
|
teamArea.setStatus(0);
|
teamArea.setDelFlag(0);
|
List<MjTeamArea> teamAreaList = mjTeamAreaService.selectMjTeamAreaList2(teamArea); //新增的区域
|
for(MjTeamArea mjTeamArea:teamAreaList){
|
MjFingerprintReadHead fingerprintReadHead = new MjFingerprintReadHead();
|
fingerprintReadHead.setAreaId(mjTeamArea.getAreaId());
|
List<MjFingerprintReadHead> hs = mjFingerprintReadHeadService.selectMjFingerprintReadHeadList(fingerprintReadHead);
|
for(MjFingerprintReadHead rh:hs){
|
// for(WorkUserModel u:user){
|
// MjHeadsUsers mjHeadsUsers = new MjHeadsUsers();
|
// mjHeadsUsers.setUserId(Long.valueOf(u.getId()));
|
// mjHeadsUsers.setAuthorizeName(team.getTeamName());
|
// mjHeadsUsers.setAuthorizeResult(0);
|
// mjHeadsUsers.setAuthorizeType(0);
|
// mjHeadsUsers.setAuthorizeStatus(0);
|
// mjHeadsUsers.setHeadId(rh.getId());
|
// mjHeadsUsers.setHeadType(0);
|
// mjHeadsUsers.setMainUser(1);
|
// iMjHeadsUsersService.insertMjHeadsUsers(mjHeadsUsers);
|
// }
|
Thread t = new Thread(new Runnable(){
|
public void run(){
|
MultiValueMap<String, Object> map= new LinkedMultiValueMap<>();
|
|
map.add("ip", rh.getIpOrOther());
|
map.add("port", rh.getPort());
|
map.add("userDatas", value);
|
|
HttpEntity<MultiValueMap<String, Object>> request = new HttpEntity<>(map, headers);
|
try {
|
addLog("组授权通过C#接口批量增加用户--开始。推送的人数："+user.size()+"人"+"，推送的读头ip:"+rh.getIpOrOther());
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktAddUserTmpByList", request , String.class );
|
JSONObject jsonObject = JSONObject.parseObject(response.getBody());
|
System.out.println(response.getBody());
|
addLog("组授权通过C#接口批量增加用户--结束");
|
}catch (Exception e) {
|
e.printStackTrace();
|
|
}
|
|
}});
|
t.start();
|
}
|
|
mjTeamArea.setStatus(1);
|
mjTeamAreaService.updateMjTeamArea(mjTeamArea);
|
}
|
MjTeam mjTeam = mjTeamService.selectMjTeamById(id);
|
mjTeam.setEquipmentUpdateStatus(1);
|
mjTeamService.updateMjTeam(mjTeam);
|
return toAjax(true);
|
}
|
|
public List<WorkUserModel> getUser(String id){
|
MjTeamMember teamMember = new MjTeamMember();
|
teamMember.setTeamId(id);
|
teamMember.setStatus(0);
|
teamMember.setDelFlag(0);
|
List<MjTeamMember> teamMemberList = mjTeamMemberService.selectMjTeamMemberList2(teamMember); //组成员
|
List<WorkUserModel> wums = new ArrayList<WorkUserModel>();
|
for (MjTeamMember mjTeamMember:teamMemberList){
|
List<TmpDataModel> mjFingerprintList = mjFingerprintService.selectMjFingerprintListByUserId(Long.parseLong(mjTeamMember.getUserId())); //获取负责人指纹信息
|
WorkUserModel workUserModel = domainToModel(mjTeamMember, mjFingerprintList);
|
wums.add(workUserModel);
|
|
mjTeamMember.setStatus(1);
|
mjTeamMemberService.updateMjTeamMember(mjTeamMember);
|
}
|
|
return wums;
|
}
|
|
}
|
