package com.ruoyi.station.service.impl;
|
|
import java.util.*;
|
|
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.mapper.*;
|
import com.ruoyi.station.model.AreaDoorModel;
|
import com.ruoyi.station.model.DeptUsersModel;
|
import com.ruoyi.station.model.TmpDataModel;
|
import com.ruoyi.station.model.WorkUserModel;
|
import com.ruoyi.station.service.*;
|
import org.apache.ibatis.annotations.Param;
|
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.Service;
|
import com.ruoyi.common.core.text.Convert;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.client.RestTemplate;
|
|
/**
|
* 工单Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2020-08-10
|
*/
|
@Service
|
public class MjWorkOrderServiceImpl implements IMjWorkOrderService
|
{
|
@Autowired
|
private MjWorkOrderMapper mjWorkOrderMapper;
|
|
@Autowired
|
private MjDeptMapper mjDeptMapper;
|
|
@Autowired
|
private MjWorkUserMapper mjWorkUserMapper;
|
|
@Autowired
|
private MjAreaManagementMapper mjAreaManagementMapper;
|
|
@Autowired
|
private MjDoorMapper mjDoorMapper;
|
|
@Autowired
|
private IMjWorkUserPushService mjWorkUserPushService;
|
|
@Autowired
|
private MjFingerprintReadHeadMapper mjFingerprintReadHeadMapper;
|
|
@Autowired
|
private MjOrderDetailMapper mjOrderDetailMapper;
|
|
@Autowired
|
private IMjAuthorizeDetailService mjAuthorizeDetailService;
|
|
@Autowired
|
private IMjFingerprintService mjFingerprintService;
|
|
@Autowired
|
private IMjFingerprintReadHeadService mjFingerprintReadHeadService;
|
|
@Autowired
|
private IMjTemplateAreacontentService iMjTemplateAreacontentService;
|
@Autowired
|
private IMjAreaManagementService iMjAreaManagementService;
|
/**
|
* 查询工单
|
*
|
* @param id 工单ID
|
* @return 工单
|
*/
|
@Override
|
public MjWorkOrder selectMjWorkOrderById(String id)
|
{
|
return mjWorkOrderMapper.selectMjWorkOrderById(id);
|
}
|
|
/**
|
* 查询工单列表
|
*
|
* @param mjWorkOrder 工单
|
* @return 工单
|
*/
|
@Override
|
public List<MjWorkOrder> selectMjWorkOrderList(MjWorkOrder mjWorkOrder)
|
{
|
return mjWorkOrderMapper.selectMjWorkOrderList(mjWorkOrder);
|
}
|
|
/**
|
* 新增工单
|
*
|
* @param mjWorkOrder 工单
|
* @return 结果
|
*/
|
@Override
|
public int insertMjWorkOrder(MjWorkOrder mjWorkOrder)
|
{
|
mjWorkOrder.setCreateTime(DateUtils.getNowDate());
|
return mjWorkOrderMapper.insertMjWorkOrder(mjWorkOrder);
|
}
|
|
/**
|
* 修改工单
|
*
|
* @param mjWorkOrder 工单
|
* @return 结果
|
*/
|
@Override
|
public int updateMjWorkOrder(MjWorkOrder mjWorkOrder)
|
{
|
mjWorkOrder.setUpdateTime(DateUtils.getNowDate());
|
return mjWorkOrderMapper.updateMjWorkOrder(mjWorkOrder);
|
}
|
|
/**
|
* 删除工单对象
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteMjWorkOrderByIds(String ids)
|
{
|
return mjWorkOrderMapper.deleteMjWorkOrderByIds(Convert.toStrArray(ids));
|
}
|
|
/**
|
* 删除工单信息
|
*
|
* @param id 工单ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteMjWorkOrderById(String id)
|
{
|
return mjWorkOrderMapper.deleteMjWorkOrderById(id);
|
}
|
|
/**
|
* 根据当前时间获取有效工单
|
* @return
|
*/
|
@Override
|
public List<MjWorkOrder> selectMjWorkOrderByDate() {
|
return mjWorkOrderMapper.selectMjWorkOrderByDate();
|
}
|
|
|
/**
|
* 根据当前时间获取失效工单
|
* @return
|
*/
|
@Override
|
public List<MjWorkOrder> selectMjWorkOrderByDateForInvalid() {
|
return mjWorkOrderMapper.selectMjWorkOrderByDateForInvalid();
|
}
|
|
/**
|
* 根据获取用户id获取有效工单
|
* @param userId
|
* @return
|
*/
|
@Override
|
public MjWorkOrder selectValidOrderByUserId(Long userId) {
|
return mjWorkOrderMapper.selectValidOrderByUserId(userId);
|
}
|
|
List<DeptUsersModel> depts = null;
|
/**
|
* 获取部门用户列表
|
* @return
|
*/
|
@Override
|
public List<DeptUsersModel> selectDeptUsersList() {
|
depts = mjDeptMapper.selectMjDeptListByDeptParentId("0");
|
if(depts != null && depts.size() > 0) {
|
getDeptChildren(depts);
|
}
|
return depts;
|
}
|
|
List<AreaDoorModel> areaDoorModels = null;
|
/**
|
* 获取区域门禁
|
* @return
|
*/
|
@Override
|
public List<AreaDoorModel> selectAreaDoorList() {
|
areaDoorModels = mjAreaManagementMapper.selectAreaListByAreaParentId("0");
|
if(areaDoorModels != null && areaDoorModels.size() > 0) {
|
getAreaChildren(areaDoorModels);
|
}
|
return areaDoorModels;
|
}
|
|
/**
|
* 递归获取部门用户信息
|
* @param depts
|
*/
|
private void getDeptChildren(List<DeptUsersModel> depts) {
|
for(DeptUsersModel dept : depts) {
|
if(dept != null && StringUtils.isNotEmpty(dept.getId())) {
|
List<DeptUsersModel> deptChildList = mjDeptMapper.selectMjDeptListByDeptParentId(dept.getId());
|
if(deptChildList != null && deptChildList.size() > 0) {
|
dept.setChildren(deptChildList);
|
getDeptChildren(dept.getChildren());
|
}else {
|
List<DeptUsersModel> deptModels = mjWorkUserMapper.selectUserListByDeptId(dept.getId());
|
if(deptModels != null) {
|
dept.setChildren(deptModels);
|
}
|
}
|
}
|
}
|
}
|
|
/**
|
* 递归获取区域门禁信息
|
* @param areaDoorModels
|
*/
|
private void getAreaChildren(List<AreaDoorModel> areaDoorModels) {
|
for(AreaDoorModel areaDoor : areaDoorModels) {
|
if(areaDoor != null && StringUtils.isNotEmpty(areaDoor.getId())) {
|
List<AreaDoorModel> areaDoorChildren = mjAreaManagementMapper.selectAreaListByAreaParentId(areaDoor.getId());
|
if(areaDoorChildren != null && areaDoorChildren.size() > 0) {
|
/* List<AreaDoorModel> doorList = mjDoorMapper.selectDoorListByAreaId(areaDoor.getId());
|
if(doorList != null && doorList.size() > 0) {
|
areaDoor.setChildren(doorList);
|
}*/
|
if(areaDoor.getChildren() != null && areaDoor.getChildren().size() > 0) {
|
for(AreaDoorModel area : areaDoorChildren) {
|
areaDoor.getChildren().add(area);
|
}
|
}else {
|
areaDoor.setChildren(areaDoorChildren);
|
}
|
getAreaChildren(areaDoor.getChildren());
|
}else {
|
/*List<AreaDoorModel> doorList = mjDoorMapper.selectDoorListByAreaId(areaDoor.getId());
|
if(doorList != null) {
|
areaDoor.setChildren(doorList);
|
}*/
|
}
|
}
|
}
|
}
|
|
/**
|
* 获取区域ids
|
* @param areaIds
|
* @return
|
*/
|
@Override
|
public Map<String, String> getAreaIds(String areaIds, String areaNames) {
|
Set<String> areaIdSet = new HashSet<>();
|
Set<String> areaNamesSet = new HashSet<>();
|
Set<String> areaIdsSet = new HashSet<>();
|
Map<String, String> map = new HashMap();
|
|
String[] areaIdArr = areaIds.split(",");
|
String[] areaNameArr = areaNames.split(",");
|
|
for(String areaId : areaIdArr) {
|
areaIdSet.add(areaId.trim());
|
}
|
areaIdsSet.addAll(areaIdSet);
|
|
for(String areaName : areaNameArr) {
|
areaNamesSet.add(areaName.trim());
|
}
|
|
for(String areaId : areaIdSet) {
|
getAreaPid(areaId, areaIdsSet, areaNamesSet); //递归获取父areaId
|
}
|
|
List<String> list = new ArrayList<>(areaIdsSet);
|
List<String> namelist = new ArrayList<>(areaNamesSet);
|
String areaIdsStr = String.join(",", list);
|
String areaNamesStr = String.join(",", namelist);
|
map.put("areaIdsStr", areaIdsStr);
|
map.put("areaNamesStr", areaNamesStr);
|
return map;
|
}
|
|
/**
|
* 递归获取父areaId
|
* @param areaId
|
* @param areaIdsSet
|
*/
|
private void getAreaPid(String areaId, Set<String> areaIdsSet, Set<String> areaNamesSet) {
|
MjAreaManagement areaManagement = mjAreaManagementMapper.selectParentAreaByAreaId(areaId);
|
if(areaManagement != null) {
|
areaIdsSet.add(areaManagement.getId().trim());
|
areaNamesSet.add(areaManagement.getAreaName().trim());
|
getAreaPid(areaManagement.getId(), areaIdsSet, areaNamesSet);
|
}
|
}
|
|
/**
|
* 修改工单
|
* @param mjWorkOrder
|
* @return
|
*/
|
@Override
|
public List<MjOrderDetail> updateOrder(MjWorkOrder mjWorkOrder) {
|
|
/*List<String> newAreaIds = new ArrayList<>();
|
List<String> newUserIds = new ArrayList<>();
|
Set<String> beforeAreaIds = new HashSet<>();
|
List<String> beforeUserIds = new ArrayList<>();*/
|
|
MjOrderDetail orderDetail = new MjOrderDetail();
|
orderDetail.setOrderId(mjWorkOrder.getId());
|
List<MjOrderDetail> orderDetails = mjOrderDetailMapper.selectMjOrderDetailList(orderDetail);
|
if(orderDetails != null) {
|
/*if(StringUtils.isNotEmpty(beforeOrder.getAreaIds())) {
|
String[] beforeAreaIdsArr = beforeOrder.getAreaIds().split(",");
|
beforeAreaIds = Arrays.asList(beforeAreaIdsArr);
|
}*/
|
mjWorkOrder.setUpdateTime(new Date());
|
int num = mjWorkOrderMapper.updateMjWorkOrder(mjWorkOrder); //修改订单
|
if(num>0) {
|
for(MjOrderDetail detail : orderDetails) {
|
mjOrderDetailMapper.deleteMjOrderDetailById(detail.getId()); //删除order_detail
|
/*if(detail != null && StringUtils.isNotEmpty(detail.getAreaId())) {
|
beforeAreaIds.add(detail.getAreaId()); //获取修改前订单的区域
|
}
|
if(detail != null && detail.getUserId() != null) {
|
beforeUserIds.add(detail.getUserId().toString()); //获取修改前订单的用户
|
}*/
|
}
|
|
//王浩杰 2020-09-14
|
// if(StringUtils.isNotEmpty(mjWorkOrder.getTempAreaId())){
|
// String as = mjWorkOrder.getAreaIds();
|
// String an = mjWorkOrder.getAreaNames();
|
// MjTemplateAreacontent mjTemplateAreacontent = new MjTemplateAreacontent();
|
// mjTemplateAreacontent.setTemplatId(mjWorkOrder.getTempAreaId());
|
// List<MjTemplateAreacontent> mjTemplateAreacontents = iMjTemplateAreacontentService.selectMjTemplateAreacontentList(mjTemplateAreacontent);
|
// for(MjTemplateAreacontent mjTemplateAreacontent1:mjTemplateAreacontents){
|
// if(as.indexOf(mjTemplateAreacontent1.getAreaId())==-1){
|
// if(StringUtils.isNotEmpty(as)){
|
// as+=","+mjTemplateAreacontent1.getAreaId();
|
// MjAreaManagement areaManagement = iMjAreaManagementService.selectMjAreaManagementById(mjTemplateAreacontent1.getAreaId());
|
// an+=","+areaManagement.getAreaName();
|
// }else{
|
// as+=mjTemplateAreacontent1.getAreaId();
|
// MjAreaManagement areaManagement = iMjAreaManagementService.selectMjAreaManagementById(mjTemplateAreacontent1.getAreaId());
|
// an+=areaManagement.getAreaName();
|
// }
|
// }
|
// }
|
// mjWorkOrder.setAreaIds(as);
|
// mjWorkOrder.setAreaNames(an);
|
// }
|
//王浩杰 2020-09-14
|
|
//Map<String, String> map = getAreaIds(mjWorkOrder.getAreaIds(), mjWorkOrder.getAreaNames());
|
if(mjWorkOrder.getUserId() != null) {
|
MjOrderDetail detail = new MjOrderDetail();
|
String id = IdUtils.getUUIDInOrderId()+"";
|
detail.setId(id);
|
detail.setUserId(Long.parseLong(mjWorkOrder.getUserId()));
|
detail.setUserName(mjWorkOrder.getUserName());
|
detail.setOrderId(mjWorkOrder.getId());
|
detail.setMainUser(1);
|
// detail.setAreaId(map.get("areaIdsStr"));
|
// detail.setAreaName(map.get("areaNamesStr"));
|
detail.setAreaId(mjWorkOrder.getAreaIds());
|
detail.setAreaName(mjWorkOrder.getAreaNames());
|
detail.setAuthorizeResult("0");
|
detail.setAuthorizeType("0");
|
detail.setCreateTime(new Date());
|
mjOrderDetailMapper.insertMjOrderDetail(detail);
|
}
|
if(StringUtils.isNotEmpty(mjWorkOrder.getUserIds()) && StringUtils.isNotEmpty(mjWorkOrder.getUserNames())) {
|
String[] userIds = mjWorkOrder.getUserIds().split(",");
|
String[] userNames = mjWorkOrder.getUserNames().split(",");
|
for(int i=0; i<userIds.length; i++) {
|
MjOrderDetail detail = new MjOrderDetail();
|
String id = IdUtils.getUUIDInOrderId()+"";
|
detail.setId(id);
|
detail.setUserId(Long.parseLong(userIds[i]));
|
detail.setUserName(userNames[i]);
|
detail.setOrderId(mjWorkOrder.getId());
|
// detail.setAreaId(map.get("areaIdsStr"));
|
// detail.setAreaName(map.get("areaNamesStr"));
|
detail.setAreaId(mjWorkOrder.getAreaIds());
|
detail.setAreaName(mjWorkOrder.getAreaNames());
|
detail.setMainUser(0);
|
detail.setAuthorizeResult("0");
|
detail.setAuthorizeType("0");
|
detail.setCreateTime(new Date());
|
mjOrderDetailMapper.insertMjOrderDetail(detail);
|
}
|
}
|
}
|
/*if(StringUtils.isNotEmpty(mjWorkOrder.getUserIds())) {
|
String[] newUserIdsArr = mjWorkOrder.getUserIds().split(",");
|
newUserIds = Arrays.asList(newUserIdsArr); //获取修改后订单的用户
|
}
|
beforeUserIds.removeAll(newUserIds);//获取被删除的用户
|
|
if(StringUtils.isNotEmpty(mjWorkOrder.getAreaIds())) {
|
String[] newAreaIdsArr = mjWorkOrder.getAreaIds().split(",");
|
newAreaIds = Arrays.asList(newAreaIdsArr); //获取修改后订单的区域
|
}
|
beforeAreaIds.removeAll(newAreaIds); //获取被删除的区域
|
if(beforeAreaIds != null && beforeAreaIds.size() > 0) {
|
for(String areaId : beforeAreaIds) {
|
MjFingerprintReadHead head = new MjFingerprintReadHead();
|
head.setAreaId(areaId);
|
List<MjFingerprintReadHead> heads = mjFingerprintReadHeadMapper.selectMjFingerprintReadHeadList(head);
|
delUserTmpByUserIdAndIp(heads, beforeUserIds); //删除对应读头的用户
|
}
|
}*/
|
}
|
return orderDetails;
|
}
|
|
@Override
|
public void updateUserInReadHead(String orderId) {
|
MjAuthorizeDetail mjAuthorizeDetail = new MjAuthorizeDetail();
|
mjAuthorizeDetail.setOrderId(orderId);
|
mjAuthorizeDetail.setAuthorizeType("0");
|
List<MjAuthorizeDetail> authorizeDetails = mjAuthorizeDetailService.selectMjAuthorizeDetailList(mjAuthorizeDetail);
|
if(authorizeDetails != null && authorizeDetails.size() > 0) {
|
List<WorkUserModel> workUserModelList = new ArrayList<>();
|
List<String> areaIdList = new ArrayList<>();
|
for(MjAuthorizeDetail detail : authorizeDetails) {
|
areaIdList.add(detail.getAreaId());
|
MjFingerprintReadHead head = new MjFingerprintReadHead();
|
head.setAreaId(detail.getAreaId());
|
List<MjFingerprintReadHead> heads = mjFingerprintReadHeadMapper.selectMjFingerprintReadHeadList(head);
|
if(heads != null && heads.size() > 0 && detail.getUserId() != null) {
|
if(detail.getAuthorizeType().equals("0")) {
|
List<TmpDataModel> mjFingerprintList = mjFingerprintService.selectMjFingerprintListByUserId(detail.getUserId()); //获取负责人指纹信息
|
WorkUserModel workUserModel = domainToModel(detail, mjFingerprintList);
|
workUserModelList.add(workUserModel);
|
}else if(detail.getAuthorizeType().equals("1")) {
|
delUserTmpByUserIdAndIp(heads, detail.getUserId().toString());
|
}
|
}
|
}
|
JSONArray jsonArray=new JSONArray(Collections.singletonList(workUserModelList));
|
String userDatas = jsonArray.toString().substring(1, jsonArray.toString().length()-1);
|
addUserTmpByUserIdAndIp(userDatas, areaIdList);
|
}
|
}
|
|
//删除对应读头的用户
|
private void delUserTmpByUserIdAndIp(List<MjFingerprintReadHead> heads, String userId) {
|
if(heads != null && heads.size() > 0) {
|
for(MjFingerprintReadHead head : heads) {
|
if(StringUtils.isNotEmpty(head.getIpOrOther()) && StringUtils.isNotEmpty(head.getPort())) {
|
mjWorkUserPushService.removeFingerTmp(userId, head.getIpOrOther(), head.getPort());
|
}
|
}
|
}
|
}
|
|
//增加对应读头的用户
|
private void addUserTmpByUserIdAndIp(String value, List<String> areaIdList) {
|
RestTemplate restTemplate = new RestTemplate();
|
HttpHeaders headers = new HttpHeaders();
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
|
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 {
|
ResponseEntity<String> response = restTemplate.postForEntity( UrlConstant.ZK_URL+"api/SDZ/ZktdelUserToOpenDoor", request , String.class );
|
System.out.println(response.getBody());
|
}catch (Exception e) {
|
e.printStackTrace();
|
return;
|
}
|
}
|
}
|
}
|
}
|
|
//转换为访问所需model
|
private WorkUserModel domainToModel(MjAuthorizeDetail detail, List<TmpDataModel> mjFingerprintList) {
|
WorkUserModel workUserModel = new WorkUserModel();
|
workUserModel.setId(detail.getUserId().toString().trim());
|
workUserModel.setName(detail.getUserName().trim());
|
workUserModel.setPass("123456");
|
workUserModel.setiPrivilege(0);
|
if(detail.getMainUser() != null && detail.getMainUser() == 1) {
|
workUserModel.setFlag("a");
|
}else {
|
workUserModel.setFlag("x");
|
}
|
|
workUserModel.setTmpDatas(mjFingerprintList);
|
return workUserModel;
|
}
|
|
/**
|
* 工作票号查重
|
* @param orderNo
|
* @return
|
*/
|
@Override
|
public Integer checkOrderNoRepeat(String orderNo) {
|
return mjWorkOrderMapper.checkOrderNoRepeat(orderNo);
|
}
|
|
/**
|
* 根据年份获取工作票数量
|
* @param yearTime
|
* @return
|
*/
|
@Override
|
public Integer selectOrderCountByYear(String yearTime) {
|
return mjWorkOrderMapper.selectOrderCountByYear(yearTime);
|
}
|
|
@Override
|
public String getOrderName(String orderId) {
|
return mjWorkOrderMapper.getOrderName(orderId);
|
}
|
}
|
