From a20310f135ebf1c8ccff2b619f3eff3d704436a0 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: 星期四, 08 十二月 2022 13:12:03 +0800
Subject: [PATCH] Merge branch 'xinghong-dev' of http://git.homecommunity.cn/supervip/MicroCommunity
---
service-job/src/main/java/com/java110/job/adapt/Repair/MachineAddOwnerRepairAdapt.java | 37 +++++++++++++++++++++++++++++++++++--
1 files changed, 35 insertions(+), 2 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/adapt/Repair/MachineAddOwnerRepairAdapt.java b/service-job/src/main/java/com/java110/job/adapt/Repair/MachineAddOwnerRepairAdapt.java
index 96d72c3..eec3989 100755
--- a/service-job/src/main/java/com/java110/job/adapt/Repair/MachineAddOwnerRepairAdapt.java
+++ b/service-job/src/main/java/com/java110/job/adapt/Repair/MachineAddOwnerRepairAdapt.java
@@ -1,6 +1,7 @@
package com.java110.job.adapt.Repair;
import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.factory.WechatFactory;
import com.java110.dto.CommunityMemberDto;
@@ -22,6 +23,7 @@
import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO;
import com.java110.intf.user.IStaffAppAuthInnerServiceSMO;
import com.java110.job.adapt.DatabusAdaptImpl;
+import com.java110.po.owner.RepairPoolPo;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.util.Assert;
import com.java110.utils.util.StringUtil;
@@ -32,6 +34,7 @@
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
+import java.util.ArrayList;
import java.util.List;
/**
@@ -71,9 +74,34 @@
@Override
public void execute(Business business, List<Business> businesses) {
+ JSONObject data = business.getData();
+ JSONArray businessOwnerRepairs = new JSONArray();
+ System.out.println("鏀跺埌鏃ュ織锛�>>>>>>>>>>>>>" + data.toJSONString());
+ if (data.containsKey(RepairPoolPo.class.getSimpleName())) {
+ Object bObj = data.get(RepairPoolPo.class.getSimpleName());
+ if (bObj instanceof JSONObject) {
+ businessOwnerRepairs.add(bObj);
+ } else if (bObj instanceof List) {
+ businessOwnerRepairs = JSONArray.parseArray(JSONObject.toJSONString(bObj));
+ } else {
+ businessOwnerRepairs = (JSONArray) bObj;
+ }
+ } else {
+ if (data instanceof JSONObject) {
+ businessOwnerRepairs.add(data);
+ }
+ }
+ //JSONObject businessOwnerCar = data.getJSONObject("businessOwnerCar");
+ for (int bOwnerRepairIndex = 0; bOwnerRepairIndex < businessOwnerRepairs.size(); bOwnerRepairIndex++) {
+ JSONObject businessOwnerRepair = businessOwnerRepairs.getJSONObject(bOwnerRepairIndex);
+ doDealOwnerRepair(business, businessOwnerRepair);
+ }
+ }
+
+ private void doDealOwnerRepair(Business business, JSONObject businessOwnerRepair) {
RepairDto repairDto = new RepairDto();
- repairDto.setbId(business.getbId());
- repairDto.setStatusCd("0");
+ repairDto.setRepairId(businessOwnerRepair.getString("repairId"));
+// repairDto.setStatusCd("0");
List<RepairDto> repairDtos = repairInnerServiceSMO.queryRepairs(repairDto);
//鑾峰彇鎶ヤ慨绫诲瀷
String repairTypeName = repairDtos.get(0).getRepairTypeName();
@@ -145,7 +173,12 @@
basePrivilegeDto.setCommunityId(communityMemberDtos.get(0).getCommunityId());
List<UserDto> userDtos = privilegeInnerServiceSMO.queryPrivilegeUsers(basePrivilegeDto);
String url = sendMsgUrl + accessToken;
+ List<String> userIds = new ArrayList<>();
for (UserDto userDto : userDtos) {
+ if (userIds.contains(userDto.getUserId())) {
+ continue;
+ }
+ userIds.add(userDto.getUserId());
//鏍规嵁 userId 鏌ヨ鍒皁penId
StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();
staffAppAuthDto.setStaffId(userDto.getUserId());
--
Gitblit v1.8.0