weiloong_zhang/zhyManagement
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
zhyManagement/src/main/java/com/management/tzcontroller/DeviceInstallController.java

478 lines
25 KiB
Java
Raw Normal View History

智洋张伟龙编写的代码
2025-06-11 13:58:36 +08:00
package com.management.tzcontroller;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.management.constant.URLConstant;
import com.management.entity.Filter;
import com.management.utils.CrmRequestUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestClientException;
import org.springframework.web.client.RestTemplate;
import java.text.SimpleDateFormat;
优化了部分内容
2025-06-26 20:52:12 +08:00
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
智洋张伟龙编写的代码
2025-06-11 13:58:36 +08:00
import java.util.*;
@RestController
@RequestMapping("/api/device/install")
@Slf4j
public class DeviceInstallController {
private RestTemplate restTemplate = new RestTemplate();
public static void main(String[] args) {
new DeviceInstallController().syncDeviceInstall();
//new DeviceInstallController().upDeviceInstall();
}
/**
* 台账设备安装同步创建
*
* @return void
* @Author weiloong_zhang
*/
@PostMapping("/sync/device")
public void syncDeviceInstall() {
CrmRequestUtil crmRequestUtil = new CrmRequestUtil();
String[] syncStatus = {"option_pending_sync__c", "option_resync__c"};
JSONObject getDeviceInstall = crmRequestUtil.getCRMList(Arrays.asList(
new Filter("GT", "last_modified_time", Arrays.asList("1748923200000")),
new Filter("EQ", "life_status", Arrays.asList("normal")),
//new Filter("EQ", "name", Arrays.asList("DEV202505260012"))
new Filter("IN", "ledger_sync_status__c", Arrays.asList(syncStatus))
), "DeviceObj");
JSONObject deviceInstallRes = new JSONObject();
try {
deviceInstallRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, getDeviceInstall, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
if (!"success".equals(deviceInstallRes.getString("errorDescription")) || deviceInstallRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) {
log.info("设备安装为空或者请求失败，将不再向下执行");
return;
}
log.info("设备信息存在，将继续向下执行");
for (Object deviceInstallObj : deviceInstallRes.getJSONObject("data").getJSONArray("dataList")) {
JSONObject deviceInstallData = JSON.parseObject(JSON.toJSONString(deviceInstallObj));
System.out.println("当前正在处理的设备数据为：" + deviceInstallData);
//开始截取关键数据
//设备id
String deviceId = deviceInstallData.getString("_id");
//设备编号
String deviceName = deviceInstallData.getString("name");
//创建时间
台账设备日志判断优化
2025-06-27 15:49:40 +08:00
String createTime = deviceInstallData.getString("last_modified_time");
智洋张伟龙编写的代码
2025-06-11 13:58:36 +08:00
//开始查询是否已经执行过该单据
JSONObject isLogRes = new JSONObject();
try {
isLogRes = restTemplate.getForObject("http://localhost:18085/Log/query/log_data?table=send_log_tzdevice&log_type=TZSB&dataId=" + deviceId + "&mark=" + createTime, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
if (!isLogRes.getJSONArray("data").isEmpty()) {
log.info("数据已经集成过了，将不再继续向下执行");
continue;
}
log.info("数据不存在，继续向下执行");
//开始封装数据
Map deviceInstallMap = new HashMap<>();
deviceInstallMap.put("crmId", deviceId);//发货设备唯一ID
deviceInstallMap.put("deviceId", deviceInstallData.getString("device_code"));//主板编号
deviceInstallMap.put("ICCID", deviceInstallData.getString("smart_card_number_iccid__c__r") != null ? deviceInstallData.getString("smart_card_number_iccid__c__r") : "");//智能卡号ICCID
deviceInstallMap.put("powerStripVersion", deviceInstallData.getString("power_board_program_versio__c") != null ? deviceInstallData.getString("power_board_program_versio__c") : "");//电源板程序版本号
deviceInstallMap.put("mainBoardVersion", deviceInstallData.getString("mainboard_program_version__c") != null ? deviceInstallData.getString("mainboard_program_version__c") : "");//主板程序版本号
deviceInstallMap.put("hardwareVersion", deviceInstallData.getString("mainboard_hardware_version__c") != null ? deviceInstallData.getString("mainboard_hardware_version__c") : "");//硬件版本号
deviceInstallMap.put("deviceHardwareVersion", deviceInstallData.getString("device_hardware__c") != null ? deviceInstallData.getString("device_hardware__c") : "");//设备硬件
deviceInstallMap.put("systemVersion", deviceInstallData.getString("system_version_number__c") != null ? deviceInstallData.getString("system_version_number__c") : "");//系统版本号
deviceInstallMap.put("fourGVersion", deviceInstallData.getString("version_4g__c") != null ? deviceInstallData.getString("version_4g__c") : "");//4G版本号
deviceInstallMap.put("aiVersion", deviceInstallData.getString("ai_version_number__c") != null ? deviceInstallData.getString("ai_version_number__c") : "");//AI版本号
//deviceInstallMap.put("deviceStatus", "");//todo 设备状态(选项未提供)
deviceInstallMap.put("preSignContract", deviceInstallData.getString("pre_signed_contract_id__c__r") != null ? deviceInstallData.getString("pre_signed_contract_id__c__r") : "");//预签合同
deviceInstallMap.put("contract", deviceInstallData.getString("sales_contract_number__c__r") != null ? deviceInstallData.getString("sales_contract_number__c__r") : "");//销售合同
deviceInstallMap.put("project", deviceInstallData.getString("project_id__c") != null ? deviceInstallData.getString("project_id__c") : "");//项目号
deviceInstallMap.put("vol", deviceInstallData.getString("voltage_level__c__r") != null ? deviceInstallData.getString("voltage_level__c__r") : "");//电压等级
deviceInstallMap.put("line", deviceInstallData.getString("line_name__c") != null ? deviceInstallData.getString("line_name__c") : "");//线路名称
deviceInstallMap.put("tower", deviceInstallData.getString("pole_number__c") != null ? deviceInstallData.getString("pole_number__c") : "");//杆塔号
deviceInstallMap.put("towerType", deviceInstallData.getString("pole_type__c__r") != null ? deviceInstallData.getString("pole_type__c__r") : "");////杆塔类型
deviceInstallMap.put("direction", deviceInstallData.getString("installation_direction__c") != null ? deviceInstallData.getString("installation_direction__c") : "");//安装方向
//获取安装日期时间戳
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String installDateStr = deviceInstallData.getString("install_time") != null ? deviceInstallData.getString("install_time") : "";
String installDate = "";
if (!installDateStr.equals("")) {
installDate = sdf.format(new Date(Long.parseLong(installDateStr)));
}
deviceInstallMap.put("installDate", installDate);//安装日期
//到期日期
String expireDateStr = deviceInstallData.getString("mobile_card_expiration_dat__c") != null ? deviceInstallData.getString("mobile_card_expiration_dat__c") : "";
String expireDate = "";
if (!expireDateStr.equals("")) {
expireDate = sdf.format(new Date(Long.parseLong(expireDateStr)));
}
deviceInstallMap.put("expireDate", expireDate);//到期日期
deviceInstallMap.put("signalStrength", deviceInstallData.getString("telecom_signal_strength__c") != null ? deviceInstallData.getString("telecom_signal_strength__c") : "");//电信信号强度
deviceInstallMap.put("supplier", deviceInstallData.getString("supplier_name__c") != null ? deviceInstallData.getString("supplier_name__c") : "");//供方名称
deviceInstallMap.put("construction", deviceInstallData.getString("construction_company__c__r") != null ? deviceInstallData.getString("construction_company__c__r") : "");//施工方
deviceInstallMap.put("operationPlatform", deviceInstallData.getString("run_platform__c__r") != null ? deviceInstallData.getString("run_platform__c__r") : "");//运行平台
deviceInstallMap.put("thirdDeviceId", deviceInstallData.getString("third_party_platform_id__c") != null ? deviceInstallData.getString("third_party_platform_id__c") : "");//第三方平台编号
deviceInstallMap.put("thirdMotherboardId", deviceInstallData.getString("third_party_mainboard_id__c") != null ? deviceInstallData.getString("third_party_mainboard_id__c") : "");//第三方主板编号
deviceInstallMap.put("sensor", deviceInstallData.getString("sensor__c") != null ? deviceInstallData.getString("sensor__c") : "");//传感器
//更新时间
String updateTimeStr = deviceInstallData.getString("update_time__c") != null ? deviceInstallData.getString("update_time__c") : "";
String updateTime = "";
if (!updateTimeStr.equals("")) {
updateTime = sdf.format(new Date(Long.parseLong(updateTimeStr)));
}
deviceInstallMap.put("updateTime", updateTime);//todo 更新时间(待测)
deviceInstallMap.put("installationSite", deviceInstallData.getString("address") != null ? deviceInstallData.getString("address") : "");//todo 安装地点
deviceInstallMap.put("itemGroup", deviceInstallData.getString("work_group__c") != null ? deviceInstallData.getString("work_group__c") : "");//班组
deviceInstallMap.put("coordinate", deviceInstallData.getString("latitude_longitude__c") != null ? deviceInstallData.getString("latitude_longitude__c") : "");//经纬度
deviceInstallMap.put("stuctureType", deviceInstallData.getString("structure_type__c__r") != null ? deviceInstallData.getString("structure_type__c__r") : "");//结构件类型
deviceInstallMap.put("photoAmount", deviceInstallData.getBigDecimal("photo_count__c") != null ? deviceInstallData.getBigDecimal("photo_count__c") : 0);//拍照张数
deviceInstallMap.put("installationGeography", deviceInstallData.getString("installation_geography__c") != null ? deviceInstallData.getString("installation_geography__c") : "");//安装地理环境
deviceInstallMap.put("constructionWorkers", deviceInstallData.getString("shigongrenyuan__c") != null ? deviceInstallData.getString("shigongrenyuan__c") : "");//施工人员
deviceInstallMap.put("siteManager", deviceInstallData.getString("on_site_responsible_person__c__r") != null ? deviceInstallData.getString("on_site_responsible_person__c__r") : "");//现场负责人
deviceInstallMap.put("siteManagerTel", deviceInstallData.getString("on_site_contact_info__c") != null ? deviceInstallData.getString("on_site_contact_info__c") : "");//现场负责人联系方式
deviceInstallMap.put("devicePurpose", deviceInstallData.getString("device_purpose__c") != null ? deviceInstallData.getString("device_purpose__c") : "");//设备用途
deviceInstallMap.put("dangerType", deviceInstallData.getString("hazard_type__c") != null ? deviceInstallData.getString("hazard_type__c") : "");//隐患类型
deviceInstallMap.put("remarks", deviceInstallData.getString("remark__c") != null ? deviceInstallData.getString("remark__c") : "");//备注
deviceInstallMap.put("deviceDetailState", deviceInstallData.getString("device_installation_status__c__r") != null ? deviceInstallData.getString("device_installation_status__c__r") : "");//设备安装状态
Integer isMaintenance = null;
switch (deviceInstallData.getString("is_maintenance_mode__c") != null ? deviceInstallData.getString("is_maintenance_mode__c") : "") {
case "yes":
isMaintenance = 1;
break;
case "no":
isMaintenance = 0;
break;
default:
isMaintenance = null;
break;
}
deviceInstallMap.put("isMaintenance", isMaintenance);//是否开启维护模式
//更新者
JSONObject updaterJSON = deviceInstallData.getJSONObject("updater__c__r") != null ? deviceInstallData.getJSONObject("updater__c__r") : new JSONObject();
String updaterStr = "";
if (!updaterJSON.isEmpty()) {
updaterStr = updaterJSON.getString("name");
}
deviceInstallMap.put("updater", updaterStr);//更新者
deviceInstallMap.put("deviceAttribute", 1);//todo 主副设备
//开始获取token
String token = new LedgerTokenController().getToken();
if (token == null || "".equals(token)) {
log.info("台账token获取失败，将不再向下执行");
continue;
}
//开始封装请求头
HttpHeaders headers = new HttpHeaders();
headers.set("Content-Type", "application/json");
headers.set("accessToken", token);
HttpEntity reqEntity = new HttpEntity(deviceInstallMap, headers);
System.out.println(JSON.parseObject(JSON.toJSONString(reqEntity)));
//开始发起请求
String deviceUrl = "http://192.168.5.55:9011/crm/initInstallationDevice";
JSONObject deviceResult = new JSONObject();
try {
deviceResult = restTemplate.postForObject(deviceUrl, reqEntity, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println(JSON.parseObject(JSON.toJSONString(deviceResult)));
//开始封装回写程序
Map backReqMap = new HashMap();
backReqMap.put("_id", deviceId);
backReqMap.put("dataObjectApiName", "DeviceObj");
//开始封装日志
Map logMap = new HashMap<>();
logMap.put("log_id", UUID.randomUUID().toString().replace("-", ""));
logMap.put("log_type", "TZSB");
logMap.put("syn_type", "0");
logMap.put("data_name", deviceName);
logMap.put("data_id", deviceId);
logMap.put("mark", createTime);
logMap.put("send_body", JSON.toJSONString(reqEntity));
logMap.put("send_res", JSON.toJSONString(deviceResult));
logMap.put("tableName", "send_log_tzdevice");
//判断是否执行成功
if (deviceResult.getInteger("code") == 0) {
//同步成功
logMap.put("log_status", "0");
logMap.put("res_body", "同步成功");
backReqMap.put("ledger_sync_status__c", "option_sync_success__c");
优化了部分内容
2025-06-26 20:52:12 +08:00
backReqMap.put("ledger_response_status__c", "创建" + deviceResult.getString("msg"));
智洋张伟龙编写的代码
2025-06-11 13:58:36 +08:00
} else {
//同步失败
logMap.put("log_status", "1");
logMap.put("res_body", "同步失败：" + deviceResult.getString("msg"));
backReqMap.put("ledger_sync_status__c", "option_sync_failure__c");
优化了部分内容
2025-06-26 20:52:12 +08:00
backReqMap.put("ledger_response_status__c", "创建" + deviceResult.getString("msg"));
智洋张伟龙编写的代码
2025-06-11 13:58:36 +08:00
}
//开始回写
JSONObject backReq = crmRequestUtil.updateCRM(backReqMap);
JSONObject backRes = new JSONObject();
try {
backRes = restTemplate.postForObject(URLConstant.UPDATE_CRM_MAIN, backReq, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println("回写结果为：" + backRes);
//开始记录日志
JSONObject logRes = new JSONObject();
try {
logRes = restTemplate.postForObject("http://localhost:18085/Log/insert/log_data", logMap, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println("日志插入结果为：" + logRes);
}
}
/**
* 设备安装信息更新
*
* @return void
* @Author weiloong_zhang
*/
@PostMapping("/update/device_install")
public void upDeviceInstall() {
CrmRequestUtil crmRequestUtil = new CrmRequestUtil();
JSONObject getDeviceInstall = crmRequestUtil.getCRMList(Arrays.asList(
//new Filter("EQ", "name", Arrays.asList("DEV202505260012"))
new Filter("GT", "last_modified_time", Arrays.asList("1748923200000")),
优化了设备台账的代码
2025-06-26 21:28:41 +08:00
new Filter("EQ", "ledger_sync_status__c", Arrays.asList("option_ledger_update__c")),
智洋张伟龙编写的代码
2025-06-11 13:58:36 +08:00
new Filter("EQ", "life_status", Arrays.asList("normal"))
), "DeviceObj");
JSONObject deviceInstallRes = new JSONObject();
try {
deviceInstallRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, getDeviceInstall, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
if (!"success".equals(deviceInstallRes.getString("errorDescription")) || deviceInstallRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) {
log.info("设备安装为空或者请求失败，将不再向下执行");
return;
}
log.info("设备信息存在，将继续向下执行");
for (Object deviceInstallObj : deviceInstallRes.getJSONObject("data").getJSONArray("dataList")) {
JSONObject deviceInstallData = JSON.parseObject(JSON.toJSONString(deviceInstallObj));
System.out.println("当前正在处理的设备数据为：" + deviceInstallData);
//开始截取关键数据
//设备id
String deviceId = deviceInstallData.getString("_id");
//设备编号
String deviceName = deviceInstallData.getString("name");
//创建时间
String modifyTime = deviceInstallData.getString("last_modified_time");
//开始查询是否已经执行过该单据
JSONObject isLogRes = new JSONObject();
try {
isLogRes = restTemplate.getForObject("http://localhost:18085/Log/query/log_data?table=send_log_tzdevice&log_type=TZSBUP&dataId=" + deviceId + "&mark=" + modifyTime, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
if (!isLogRes.getJSONArray("data").isEmpty()) {
log.info("数据已经集成过了，将不再继续向下执行");
continue;
}
log.info("数据不存在，继续向下执行");
//开始封装数据
Map deviceInstallMap = new HashMap<>();
deviceInstallMap.put("deviceId", deviceInstallData.getString("device_code"));//主板编号
deviceInstallMap.put("preSignContract", deviceInstallData.getString("pre_signed_contract_id__c__r") != null ? deviceInstallData.getString("pre_signed_contract_id__c__r") : "");//预签合同
deviceInstallMap.put("contract", deviceInstallData.getString("sales_contract_number__c__r") != null ? deviceInstallData.getString("sales_contract_number__c__r") : "");//销售合同
deviceInstallMap.put("project", deviceInstallData.getString("project_number__c") != null ? deviceInstallData.getString("project_number__c") : "");//项目号
//更新者
List updaterList = deviceInstallData.getJSONArray("updater__c") != null ? deviceInstallData.getJSONArray("updater__c") : new ArrayList();
String updaterStr = "";
if (!updaterList.isEmpty()) {
//更新者不为空
JSONObject getUpdater = crmRequestUtil.getCRMList(Arrays.asList(
new Filter("EQ", "user_id", updaterList)
), "PersonnelObj");
JSONObject updaterRes = new JSONObject();
try {
updaterRes = restTemplate.postForObject(URLConstant.GET_CRM_LIST_URL, getUpdater, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
if ("success".equals(updaterRes.getString("errorDescription")) && !updaterRes.getJSONObject("data").getJSONArray("dataList").isEmpty()) {
JSONObject updaterJSON = updaterRes.getJSONObject("data").getJSONArray("dataList").getJSONObject(0);
updaterStr = updaterJSON.getString("name");
} else {
updaterStr = "";
}
}
deviceInstallMap.put("updater", updaterStr);//更新者
//开始获取token
String token = new LedgerTokenController().getToken();
if (token == null || "".equals(token)) {
log.info("台账token获取失败，将不再向下执行");
continue;
}
//开始封装请求头
HttpHeaders headers = new HttpHeaders();
headers.set("Content-Type", "application/json");
headers.set("accessToken", token);
HttpEntity reqEntity = new HttpEntity(Arrays.asList(deviceInstallMap), headers);
System.out.println(JSON.parseObject(JSON.toJSONString(reqEntity)));
//开始发起请求
String deviceUrl = "http://192.168.5.55:9011/crm/updateDeviceContract";
JSONObject deviceResult = new JSONObject();
try {
deviceResult = restTemplate.postForObject(deviceUrl, reqEntity, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println(JSON.parseObject(JSON.toJSONString(deviceResult)));
//开始封装回写程序
Map backReqMap = new HashMap();
backReqMap.put("_id", deviceId);
backReqMap.put("dataObjectApiName", "DeviceObj");
//开始封装日志
Map logMap = new HashMap<>();
logMap.put("log_id", UUID.randomUUID().toString().replace("-", ""));
logMap.put("log_type", "TZSBUP");
logMap.put("syn_type", "0");
logMap.put("data_name", deviceName);
logMap.put("data_id", deviceId);
logMap.put("mark", modifyTime);
logMap.put("send_body", JSON.toJSONString(reqEntity));
logMap.put("send_res", JSON.toJSONString(deviceResult));
logMap.put("tableName", "send_log_tzdevice");
//判断是否执行成功
if (deviceResult.getInteger("code") == 0) {
//同步成功
logMap.put("log_status", "0");
logMap.put("res_body", "同步成功");
backReqMap.put("ledger_sync_status__c", "option_sync_success__c");
优化了部分内容
2025-06-26 20:52:12 +08:00
backReqMap.put("ledger_response_status__c", "更新成功" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
智洋张伟龙编写的代码
2025-06-11 13:58:36 +08:00
} else {
//同步失败
logMap.put("log_status", "1");
logMap.put("res_body", "同步失败：" + deviceResult.getString("msg"));
backReqMap.put("ledger_sync_status__c", "option_sync_failure__c");
优化了部分内容
2025-06-26 20:52:12 +08:00
backReqMap.put("ledger_response_status__c", "更新失败" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
智洋张伟龙编写的代码
2025-06-11 13:58:36 +08:00
}
//开始回写
JSONObject backReq = crmRequestUtil.updateCRM(backReqMap);
JSONObject backRes = new JSONObject();
try {
backRes = restTemplate.postForObject(URLConstant.UPDATE_CRM_MAIN, backReq, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println("回写结果为：" + backRes);
//开始记录日志
JSONObject logRes = new JSONObject();
try {
logRes = restTemplate.postForObject("http://localhost:18085/Log/insert/log_data", logMap, JSONObject.class);
} catch (RestClientException e) {
e.printStackTrace();
}
System.out.println("日志插入结果为：" + logRes);
}
}
}
Reference in New Issue Copy Permalink