88e030b7
 王彪总
init project
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
package com.java110.job.adapt.Repair;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.dto.notice.NoticeStaffDto;
import com.java110.dto.repair.RepairDto;
import com.java110.dto.repair.RepairSettingDto;
import com.java110.dto.repairEvent.RepairEventDto;
import com.java110.dto.system.Business;
import com.java110.intf.community.IRepairEventV1InnerServiceSMO;
import com.java110.intf.community.IRepairInnerServiceSMO;
import com.java110.job.adapt.DatabusAdaptImpl;
import com.java110.job.msgNotify.IMsgNotify;
import com.java110.job.msgNotify.MsgNotifyFactory;
import com.java110.po.owner.RepairUserPo;
import com.java110.utils.util.Assert;
import com.java110.utils.util.ListUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* 报修催单
*/
@Component(value = "repairUrgeAdapt")
public class RepairUrgeAdapt extends DatabusAdaptImpl {
@Autowired
private IRepairEventV1InnerServiceSMO repairEventV1InnerServiceSMOImpl;
@Autowired
private IRepairInnerServiceSMO repairInnerServiceSMOImpl;
@Override
public void execute(Business business, List<Business> businesses) throws Exception {
JSONObject data = business.getData();
System.out.println("repairUrgeAdapt 收到日志：>>>>>>>>>>>>>" + data.toJSONString());
Assert.hasKeyAndValue(data, "eventId", "未包含时间ID");
RepairEventDto repairEventDto = new RepairEventDto();
repairEventDto.setEventId(data.getString("eventId"));
List<RepairEventDto> repairEventDtos = repairEventV1InnerServiceSMOImpl.queryRepairEvents(repairEventDto);
if (ListUtil.isNull(repairEventDtos)) {
return;
}
//获取报修id
String repairId = repairEventDtos.get(0).getRepairId();
RepairDto repairDto = new RepairDto();
repairDto.setRepairId(repairId);
repairDto.setStatusCd("0");
List<RepairDto> repairDtos = repairInnerServiceSMOImpl.queryRepairs(repairDto);
Assert.listOnlyOne(repairDtos, "不存在这条报修信息");
IMsgNotify msgNotify = null;
if (RepairSettingDto.NOTIFY_WAY_SMS.equals(repairDtos.get(0).getNotifyWay())) {
msgNotify = MsgNotifyFactory.getMsgNotify(MsgNotifyFactory.NOTIFY_WAY_ALI);
} else if (RepairSettingDto.NOTIFY_WAY_WECHAT.equals(repairDtos.get(0).getNotifyWay())) {
msgNotify = MsgNotifyFactory.getMsgNotify(MsgNotifyFactory.NOTIFY_WAY_WECHAT);
} else {
return;
}
msgNotify.sendStaffMsg(
new NoticeStaffDto(repairDtos.get(0).getCommunityId(),
repairEventDtos.get(0).getStaffId(),
repairDtos.get(0).getRepairSettingTypeName() + "工单催单",
repairDtos.get(0).getRepairName())
);
}
}
|
