diff --git a/lib/EmergencyService/zdxtEmergencyAppService/src/main/java/com/zdxt/app/task/ComplaintEvaluateTask.java b/lib/EmergencyService/zdxtEmergencyAppService/src/main/java/com/zdxt/app/task/ComplaintEvaluateTask.java new file mode 100644 index 00000000..c9eb12dd --- /dev/null +++ b/lib/EmergencyService/zdxtEmergencyAppService/src/main/java/com/zdxt/app/task/ComplaintEvaluateTask.java @@ -0,0 +1,141 @@ +package com.zdxt.app.task; + +import cn.hutool.core.map.MapUtil; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.zdxt.auth.common.utils.StringUtils; +import com.zdxt.auth.dto.UserBean; +import com.zdxt.auth.feign.UserApi; +import com.zdxt.auth.project.system.dept.service.IDeptService; +import com.zdxt.auth.project.system.dict.service.IDictDataService; +import com.zdxt.auth.project.system.user.service.IUserService; +import com.zdxt.code.domain.EnterpriseComplaint; +import com.zdxt.code.domain.EnterpriseComplaintSatisfy; +import com.zdxt.code.domain.EnterpriseEvaluate; +import com.zdxt.code.domain.MssqAddOrder; +import com.zdxt.code.service.IEnterpriseComplaintSatisfyService; +import com.zdxt.code.service.IEnterpriseComplaintService; +import com.zdxt.code.service.MssqApiService; +import com.zdxt.domain.auth.DictData; +import org.apache.http.HttpEntity; +import org.apache.http.client.methods.CloseableHttpResponse; +import org.apache.http.client.methods.HttpPost; +import org.apache.http.entity.StringEntity; +import org.apache.http.impl.client.CloseableHttpClient; +import org.apache.http.impl.client.HttpClientBuilder; +import org.apache.http.util.EntityUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Component; + +import java.io.IOException; +import java.nio.charset.StandardCharsets; +import java.nio.file.Files; +import java.nio.file.Paths; +import java.security.MessageDigest; +import java.util.*; +import java.util.stream.Collectors; + + +/** + * @Author: kylin + * @Date: 2024/5/9 2:58 下午 + * @Version: 1.0 + * @Desc: TODO + */ +@Component("complaintEvaluateTask") +public class ComplaintEvaluateTask { + + @Value("${srnwg.systemCode}") + private String systemCode; + @Value("${srnwg.integrationKey}") + private String integrationKey; + @Value("${srnwg.url}") + private String znwgUrl; + @Value("${srnwg.paasId}") + private String paasId; + @Value("${srnwg.paasToken}") + private String paasToken; + + @Autowired private IEnterpriseComplaintService iEnterpriseComplaintService; + @Autowired private IEnterpriseComplaintSatisfyService iEnterpriseComplaintSatisfyService; + @Autowired private MssqApiService mssqApiService; + + private static final Logger log = LoggerFactory.getLogger(ComplaintEvaluateTask.class); + + + public void run(){ + this.evaluate(); + } + + /** + * 同步评价详情 + */ + public void evaluate(){ + try { + List list = iEnterpriseComplaintService.selectEnterpriseComplaintList(new EnterpriseComplaint()); + List proWoCodes = new ArrayList<>(); + for (EnterpriseComplaint ec : list) { + if (StringUtils.isNotEmpty(ec.getProWoCode())) { + proWoCodes.add(ec.getProWoCode()); + } + } + MssqAddOrder mssqAddOrder = new MssqAddOrder(); + mssqAddOrder.setProWoCodes(proWoCodes); + String result = mssqApiService.mssqQuerySatisfy(mssqAddOrder); + JSONObject sourceObj = JSONObject.parseObject(result); + JSONArray dataOjbs = sourceObj.getJSONArray("satisfyDatas"); + + int editNum = 0; + int addNum = 0; + for (int i=0; i - + @@ -24,13 +24,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - select pro_wo_id, pr_wo_code, approve_code, approve_time, dis_approve_reason, deal_speed_metrics, deal_effect_metrics, service_metrics, feedback_quality_metrics, writing_evaluation, org_Code, assess_Number, creator, create_time, updator, update_time from enterprise_complaint_satisfy + select pro_wo_id, pro_wo_code, approve_code, approve_time, dis_approve_reason, deal_speed_metrics, deal_effect_metrics, service_metrics, feedback_quality_metrics, writing_evaluation, org_Code, assess_Number, creator, create_time, updator, update_time from enterprise_complaint_satisfy