package com.java110.job.task.noticeStaff;
|
|
import com.java110.dto.community.CommunityDto;
|
import com.java110.dto.community.CommunityMemberDto;
|
import com.java110.dto.inspection.InspectionTaskDetailDto;
|
import com.java110.dto.inspection.InspectionTaskDto;
|
import com.java110.dto.notice.NoticeStaffDto;
|
import com.java110.dto.privilege.BasePrivilegeDto;
|
import com.java110.dto.repair.RepairDto;
|
import com.java110.dto.repair.RepairUserDto;
|
import com.java110.dto.task.TaskDto;
|
import com.java110.dto.user.UserDto;
|
import com.java110.intf.community.*;
|
import com.java110.intf.order.IPrivilegeInnerServiceSMO;
|
import com.java110.intf.store.ISmallWeChatInnerServiceSMO;
|
import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO;
|
import com.java110.intf.user.IStaffAppAuthInnerServiceSMO;
|
import com.java110.intf.user.IUserInnerServiceSMO;
|
import com.java110.job.msgNotify.IMsgNotify;
|
import com.java110.job.msgNotify.MsgNotifyFactory;
|
import com.java110.job.quartz.TaskSystemQuartz;
|
import com.java110.utils.cache.MappingCache;
|
import com.java110.utils.constant.MappingConstant;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.DateUtil;
|
import com.java110.utils.util.ListUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.text.ParseException;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 通知员工工单处理
|
*/
|
@Component
|
public class NoticeStaffTaskTemplate extends TaskSystemQuartz {
|
|
@Autowired
|
private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
|
|
@Autowired
|
private IInspectionPlanInnerServiceSMO inspectionPlanInnerServiceSMOImpl;
|
|
@Autowired
|
private IInspectionPlanStaffInnerServiceSMO inspectionPlanStaffInnerServiceSMOImpl;
|
|
@Autowired
|
private IInspectionRoutePointRelInnerServiceSMO inspectionRoutePointRelInnerServiceSMOImpl;
|
|
|
@Autowired
|
private IInspectionTaskInnerServiceSMO inspectionTaskInnerServiceSMOImpl;
|
|
@Autowired
|
private IInspectionTaskDetailInnerServiceSMO inspectionTaskDetailInnerServiceSMOImpl;
|
|
@Autowired
|
private IPrivilegeInnerServiceSMO privilegeInnerServiceSMO;
|
|
@Autowired
|
private IRepairInnerServiceSMO repairInnerServiceSMOImpl;
|
|
@Autowired
|
private IRepairUserInnerServiceSMO repairUserInnerServiceSMOImpl;
|
|
|
@Autowired
|
private IUserInnerServiceSMO userInnerServiceSMO;
|
|
|
@Override
|
protected void process(TaskDto taskDto) throws Exception {
|
logger.debug("开始执行微信模板信息推送" + taskDto.toString());
|
|
// 获取小区
|
List<CommunityDto> communityDtos = getAllCommunity();
|
|
for (CommunityDto communityDto : communityDtos) {
|
try {
|
//todo 巡检 任务生成提醒
|
publishStaffInspectionTask(taskDto, communityDto);
|
} catch (Exception e) {
|
logger.error("巡检 任务生成提醒", e);
|
}
|
try {
|
//todo 巡检情况通知
|
notifyTodayInspection(communityDto);
|
} catch (Exception e) {
|
logger.error("巡检情况通知", e);
|
}
|
|
try {
|
//todo 报修快超时通知
|
notifyRepairTimeout(communityDto);
|
} catch (Exception e) {
|
logger.error("巡检情况通知", e);
|
}
|
}
|
}
|
|
/**
|
* 报修超时通知
|
*
|
* @param communityDto
|
*/
|
private void notifyRepairTimeout(CommunityDto communityDto) {
|
|
RepairDto repairDto = new RepairDto();
|
repairDto.setCommunityId(communityDto.getCommunityId());
|
repairDto.setStatess(new String[]{RepairDto.STATE_WAIT, RepairDto.STATE_TAKING});
|
List<RepairDto> repairDtos = repairInnerServiceSMOImpl.queryRepairs(repairDto);
|
if (ListUtil.isNull(repairDtos)) {
|
return;
|
}
|
|
RepairUserDto repairUserDto;
|
List<RepairUserDto> repairUserDtos;
|
IMsgNotify msgNotify = MsgNotifyFactory.getMsgNotify(MsgNotifyFactory.NOTIFY_WAY_WECHAT);
|
for (RepairDto tRepairDto : repairDtos) {
|
if (!NoticeTaskUtil.isRepairAboutTimeout(tRepairDto)) {
|
continue;
|
}
|
repairUserDto = new RepairUserDto();
|
repairUserDto.setRepairId(tRepairDto.getRepairId());
|
repairUserDto.setState(RepairUserDto.STATE_DOING);
|
repairUserDtos = repairUserInnerServiceSMOImpl.queryRepairUsers(repairUserDto);
|
if (ListUtil.isNull(repairUserDtos)) {
|
continue;
|
}
|
try {
|
msgNotify.sendStaffMsg(
|
new NoticeStaffDto(communityDto.getCommunityId(),
|
repairUserDtos.get(0).getStaffId(),
|
tRepairDto.getRepairName() + "提交报修单快超时了",
|
"系统管理员"));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
//todo 提示已经超时的工单
|
for (RepairDto tRepairDto : repairDtos) {
|
if (!NoticeTaskUtil.isRepairTimeout(tRepairDto)) {
|
continue;
|
}
|
repairUserDto = new RepairUserDto();
|
repairUserDto.setRepairId(tRepairDto.getRepairId());
|
repairUserDto.setState(RepairUserDto.STATE_DOING);
|
repairUserDtos = repairUserInnerServiceSMOImpl.queryRepairUsers(repairUserDto);
|
if (ListUtil.isNull(repairUserDtos)) {
|
continue;
|
}
|
try {
|
msgNotify.sendStaffMsg(
|
new NoticeStaffDto(communityDto.getCommunityId(),
|
repairUserDtos.get(0).getStaffId(),
|
tRepairDto.getRepairName() + "提交报修单已超时",
|
"系统管理员"));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 今日巡检情况通知
|
*
|
* @param communityDto
|
*/
|
private void notifyTodayInspection(CommunityDto communityDto) {
|
|
if (!NoticeTaskUtil.isNotifyTodayInspection(communityDto)) {
|
return;
|
}
|
|
CommunityMemberDto communityMemberDto = new CommunityMemberDto();
|
communityMemberDto.setCommunityId(communityDto.getCommunityId());
|
communityMemberDto.setAuditStatusCd(CommunityMemberDto.AUDIT_STATUS_NORMAL);
|
communityMemberDto.setMemberTypeCd(CommunityMemberDto.MEMBER_TYPE_PROPERTY);
|
List<CommunityMemberDto> communityMemberDtos = communityInnerServiceSMOImpl.getCommunityMembers(communityMemberDto);
|
Assert.listOnlyOne(communityMemberDtos, "小区没有物业公司");
|
|
BasePrivilegeDto basePrivilegeDto = new BasePrivilegeDto();
|
basePrivilegeDto.setResource("/todayInspectionNotifyStaff");
|
basePrivilegeDto.setStoreId(communityMemberDtos.get(0).getMemberId());
|
basePrivilegeDto.setCommunityId(communityDto.getCommunityId());
|
List<UserDto> userDtos = privilegeInnerServiceSMO.queryPrivilegeUsers(basePrivilegeDto);
|
if (ListUtil.isNull(userDtos)) {
|
return;
|
}
|
|
IMsgNotify msgNotify = MsgNotifyFactory.getMsgNotify(MsgNotifyFactory.NOTIFY_WAY_WECHAT);
|
String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN, "STAFF_WECHAT_URL");
|
if (wechatUrl.endsWith("/")) {
|
wechatUrl += "#/pages/inspection/inspectionTodayReport";
|
} else {
|
wechatUrl += "/#/pages/inspection/inspectionTodayReport";
|
}
|
for (UserDto userDto : userDtos) {
|
//根据 userId 查询到openId
|
try {
|
msgNotify.sendStaffMsg(
|
new NoticeStaffDto(communityDto.getCommunityId(),
|
userDto.getUserId(),
|
communityDto.getName() + "今日巡检情况",
|
"系统管理员",
|
wechatUrl));
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 巡检任务
|
*
|
* @param taskDto
|
* @param communityDto
|
*/
|
private void publishStaffInspectionTask(TaskDto taskDto, CommunityDto communityDto) {
|
|
InspectionTaskDetailDto inspectionTaskDetailDto = new InspectionTaskDetailDto();
|
inspectionTaskDetailDto.setCommunityId(communityDto.getCommunityId());
|
inspectionTaskDetailDto.setState(InspectionTaskDto.STATE_NO_START);
|
inspectionTaskDetailDto.setQrCodeTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B));
|
inspectionTaskDetailDto.setSendFlag(InspectionTaskDetailDto.SEND_FLAG_N);
|
List<InspectionTaskDetailDto> inspectionTaskDetailDtos = inspectionTaskDetailInnerServiceSMOImpl.queryInspectionTaskDetails(inspectionTaskDetailDto);
|
for (InspectionTaskDetailDto tInspectionTaskDetailDto : inspectionTaskDetailDtos) {
|
String startTime = tInspectionTaskDetailDto.getPointStartTime();
|
startTime = DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B) + " " + startTime + ":00";
|
Date startDate = null;
|
try {
|
startDate = DateUtil.getDateFromString(startTime, DateUtil.DATE_FORMATE_STRING_A);
|
} catch (ParseException e) {
|
e.printStackTrace();
|
startDate = new Date();
|
}
|
|
//还没有到时间
|
if (startDate.getTime() > DateUtil.getCurrentDate().getTime()) {
|
return;
|
}
|
|
IMsgNotify msgNotify = MsgNotifyFactory.getMsgNotify(MsgNotifyFactory.NOTIFY_WAY_WECHAT);
|
String staffWechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN, "STAFF_WECHAT_URL");
|
staffWechatUrl = staffWechatUrl
|
+ "pages/excuteOneQrCodeInspection/excuteOneQrCodeInspection?inspectionId="
|
+ tInspectionTaskDetailDto.getInspectionId()
|
+ "&inspectionName=" + tInspectionTaskDetailDto.getInspectionName()
|
+ "&itemId=" + tInspectionTaskDetailDto.getItemId();
|
try {
|
msgNotify.sendStaffMsg(
|
new NoticeStaffDto(communityDto.getCommunityId(),
|
tInspectionTaskDetailDto.getPlanUserId(),
|
tInspectionTaskDetailDto.getInspectionName() + "未巡检，请及时巡检",
|
"系统管理员",
|
staffWechatUrl)
|
);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
|
InspectionTaskDetailDto inspectionTaskDetailPo = new InspectionTaskDetailDto();
|
inspectionTaskDetailPo.setTaskDetailId(tInspectionTaskDetailDto.getTaskDetailId());
|
inspectionTaskDetailPo.setSendFlag(InspectionTaskDetailDto.SEND_FLAG_Y);
|
inspectionTaskDetailPo.setStatusCd("0");
|
inspectionTaskDetailInnerServiceSMOImpl.updateInspectionTaskDetail(inspectionTaskDetailPo);
|
}
|
|
}
|
|
}
|
