package com.java110.job.task.staffToMachine;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.core.smo.common.IMachineInnerServiceSMO;
|
import com.java110.core.smo.common.IMachineTranslateInnerServiceSMO;
|
import com.java110.core.smo.community.ICommunityInnerServiceSMO;
|
import com.java110.core.smo.community.IRoomInnerServiceSMO;
|
import com.java110.core.smo.order.IOrderInnerServiceSMO;
|
import com.java110.core.smo.user.IOrgCommunityInnerServiceSMO;
|
import com.java110.core.smo.user.IUserInnerServiceSMO;
|
import com.java110.dto.CommunityMemberDto;
|
import com.java110.dto.machine.MachineDto;
|
import com.java110.dto.machine.MachineTranslateDto;
|
import com.java110.dto.order.OrderDto;
|
import com.java110.dto.org.OrgCommunityDto;
|
import com.java110.dto.task.TaskDto;
|
import com.java110.dto.user.UserDto;
|
import com.java110.job.quartz.TaskSystemQuartz;
|
import com.java110.utils.util.DateUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @ClassName TransalateOwnerPhotoToMachine
|
* @Description TODO 传输员工图片到门禁 任务
|
* @Author wuxw
|
* @Date 2020/6/3 20:59
|
* @Version 1.0
|
* add by wuxw 2020/6/3
|
**/
|
@Component
|
public class TranslateStaffPhotoToMachineTemplate extends TaskSystemQuartz {
|
|
private static Logger logger = LoggerFactory.getLogger(TranslateStaffPhotoToMachineTemplate.class);
|
|
@Autowired
|
private IOrderInnerServiceSMO orderInnerServiceSMOImpl;
|
|
@Autowired
|
private IUserInnerServiceSMO userInnerServiceSMOImpl;
|
|
@Autowired
|
private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
|
|
@Autowired
|
private IMachineInnerServiceSMO machineInnerServiceSMOImpl;
|
|
@Autowired
|
private IMachineTranslateInnerServiceSMO machineTranslateInnerServiceSMOImpl;
|
|
@Autowired
|
private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
|
|
@Autowired
|
private IOrgCommunityInnerServiceSMO orgCommunityInnerServiceSMOImpl;
|
|
|
@Override
|
protected void process(TaskDto taskDto) throws Exception {
|
|
logger.debug("任务在执行" + taskDto.toString());
|
|
OrderDto orderDto = new OrderDto();
|
String[] businessTypeCds = new String[]{"100100030001","100100040001"};
|
orderDto.setBusinessTypeCds(businessTypeCds);
|
List<OrderDto> orderDtos = orderInnerServiceSMOImpl.queryOrderByBusinessType(orderDto);
|
|
for (OrderDto tmpOrderDto : orderDtos) {
|
try {
|
logger.debug("开始处理订单" + JSONObject.toJSONString(tmpOrderDto));
|
|
UserDto userDto = new UserDto();
|
userDto.setbId(tmpOrderDto.getbId());
|
List<UserDto> userDtos = userInnerServiceSMOImpl.getStaffs(userDto);
|
|
if (userDtos == null || userDtos.size() < 1) {
|
orderInnerServiceSMOImpl.updateBusinessStatusCd(tmpOrderDto);
|
logger.debug("没有数据数据直接刷为C1" + JSONObject.toJSONString(tmpOrderDto));
|
continue;
|
}
|
dealData(tmpOrderDto, userDtos.get(0));
|
//刷新 状态为C1
|
orderInnerServiceSMOImpl.updateBusinessStatusCd(tmpOrderDto);
|
logger.debug("处理订单结束" + JSONObject.toJSONString(tmpOrderDto));
|
|
} catch (Exception e) {
|
logger.error("执行订单任务失败", e);
|
}
|
}
|
|
}
|
|
/**
|
* 将员工数据同步给所有该小区设备
|
*
|
* @param tmpOrderDto
|
* @param userDto
|
*/
|
private void dealData(OrderDto tmpOrderDto, UserDto userDto) {
|
|
List<String> communityIds = new ArrayList<>();
|
|
if ("9999".equals(userDto.getBelongCommunityId())) {
|
CommunityMemberDto communityMemberDto = new CommunityMemberDto();
|
communityMemberDto.setMemberId(userDto.getStoreId());
|
communityMemberDto.setAuditStatusCd("1100");//审核通过的
|
List<CommunityMemberDto> communityMemberDtos = communityInnerServiceSMOImpl.getCommunityMembers(communityMemberDto);
|
|
if (communityMemberDtos == null || communityMemberDtos.size() < 1) {
|
return;
|
}
|
|
for (CommunityMemberDto tmpCommunityMemberDto : communityMemberDtos) {
|
communityIds.add(tmpCommunityMemberDto.getCommunityId());
|
}
|
} else {
|
OrgCommunityDto orgCommunityDto = new OrgCommunityDto();
|
orgCommunityDto.setOrgId(userDto.getParentOrgId());
|
orgCommunityDto.setStoreId(userDto.getStoreId());
|
List<OrgCommunityDto> orgCommunityDtos = orgCommunityInnerServiceSMOImpl.queryOrgCommunitys(orgCommunityDto);
|
|
if (orgCommunityDtos == null || orgCommunityDtos.size() < 1) {
|
return;
|
}
|
|
for (OrgCommunityDto tmpOrgCommunityDto : orgCommunityDtos) {
|
communityIds.add(tmpOrgCommunityDto.getCommunityId());
|
}
|
}
|
|
for (String communityId : communityIds) {
|
//根据小区ID查询现有设备
|
MachineDto machineDto = new MachineDto();
|
machineDto.setCommunityId(communityId);
|
List<MachineDto> machineDtos = machineInnerServiceSMOImpl.queryMachines(machineDto);
|
|
|
for (MachineDto tmpMachineDto : machineDtos) {
|
if (!"9997".equals(tmpMachineDto.getMachineTypeCd())) {
|
continue;
|
}
|
saveMachineTranslate(tmpOrderDto, tmpMachineDto, userDto);
|
}
|
|
}
|
|
}
|
|
|
private void saveMachineTranslate(OrderDto tmpOrderDto, MachineDto tmpMachineDto, UserDto userDto) {
|
// MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
|
|
|
// machineTranslateDto.setMachineId(tmpMachineDto.getMachineId());
|
// machineTranslateDto.setObjId(userDto.getUserId());
|
// machineTranslateDto.setStatusCd("0");
|
//
|
// int count = machineTranslateInnerServiceSMOImpl.queryMachineTranslatesCount(machineTranslateDto);
|
// if (count > 0) {
|
// updateMachineTranslate(tmpMachineDto, userDto);
|
// return;
|
// }
|
// Map info = new HashMap();
|
//machine_id,machine_code,status_cd,type_cd,machine_translate_id,obj_id,obj_name,state,community_id,b_id
|
MachineTranslateDto tmpMachineTranslateDto = new MachineTranslateDto();
|
tmpMachineTranslateDto.setMachineTranslateId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_machineTranslateId));
|
tmpMachineTranslateDto.setMachineId(tmpMachineDto.getMachineId());
|
tmpMachineTranslateDto.setMachineCode(tmpMachineDto.getMachineCode());
|
tmpMachineTranslateDto.setTypeCd("5566"); //访客人脸
|
tmpMachineTranslateDto.setObjId(userDto.getUserId());
|
tmpMachineTranslateDto.setObjName(userDto.getName());
|
tmpMachineTranslateDto.setState("10000");
|
tmpMachineTranslateDto.setCommunityId(tmpMachineDto.getCommunityId());
|
tmpMachineTranslateDto.setbId("-1");
|
tmpMachineTranslateDto.setObjBId(tmpOrderDto.getbId());
|
machineTranslateInnerServiceSMOImpl.saveMachineTranslate(tmpMachineTranslateDto);
|
|
}
|
|
private void updateMachineTranslate(MachineDto tmpMachineDto, UserDto userDto) {
|
MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
|
machineTranslateDto.setMachineId(tmpMachineDto.getMachineId());
|
machineTranslateDto.setObjId(userDto.getUserId());
|
machineTranslateDto.setState("10000");
|
machineTranslateDto.setCommunityId(tmpMachineDto.getCommunityId());
|
machineTranslateDto.setUpdateTime(DateUtil.getFormatTimeString(new Date(), DateUtil.DATE_FORMATE_STRING_A));
|
machineTranslateInnerServiceSMOImpl.updateMachineTranslateState(machineTranslateDto);
|
|
}
|
}
|
