Merge branch 'master' of http://git.elinkit.com.cn:7070/r/epmet-cloud

3 years ago · 7922a32a0d
12 changed files with 68 additions and 44 deletions
--- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/YtHsResUtils.java
+++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/YtHsResUtils.java
@ -2,11 +2,11 @@ package com.epmet.commons.tools.utils;

 import com.alibaba.fastjson.JSON;
 import com.epmet.commons.tools.dto.result.YtHsjcResDTO;
-import com.epmet.commons.tools.exception.EpmetErrorCode;
-import com.epmet.commons.tools.exception.EpmetException;
 import lombok.extern.slf4j.Slf4j;

 import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Map;

 /**
 * @Description
@ -15,8 +15,12 @@ import java.util.ArrayList;
 */
@Slf4j
 public class YtHsResUtils {
-    static String url = "https://10.2.2.60:8191/sjzt/server/hsjcxx?appkey=DR4jF5Be7sCsqDmCamq2tmYCl";
-
+    private static String URL = "http://10.2.2.60:8191/sjzt/server/hsjcxx";
+    private static final String APP_KEY_VALUE = "DR4jF5Be7sCsqDmCamq2tmYCl";
+    private static final String APP_KEY = "appkey";
+    private static final String CARD_NO = "card_no";
+    private static final String ROW_NUM = "ROWNUM";
+    private static final String PAGE_SIZE = "PAGESIZE";
    /**
     * desc:图片同步扫描
     *
@ -24,19 +28,26 @@ public class YtHsResUtils {
     */
    public static YtHsjcResDTO hsjc(String cardNo, Integer rowNum, Integer pageSize) {
        try {
-            String param = String.format("&card_no=%s&ROWNUM=%s&PAGESIZE=%s", cardNo, rowNum, pageSize);
-            String apiUrl = url.concat(param);
-            Result<String> result = HttpClientManager.getInstance().sendPostByJSON(apiUrl, null);
+            //String param = String.format("&card_no=%s&ROWNUM=%s&PAGESIZE=%s", cardNo, rowNum, pageSize);
+            //String apiUrl = url.concat(param);
+            Map<String,Object> param = new HashMap<>();
+            param.put(APP_KEY,APP_KEY_VALUE);
+            param.put(CARD_NO,cardNo);
+            param.put(ROW_NUM,rowNum);
+            param.put(PAGE_SIZE,pageSize);
+            log.info("hsjc api param:{}",param);
+            Result<String> result = HttpClientManager.getInstance().sendGet(URL, param);
+            log.info("hsjc api result:{}",JSON.toJSONString(result));
            if (result.success()) {
                return JSON.parseObject(result.getData(), YtHsjcResDTO.class);
            }
-            YtHsjcResDTO resultResult = new YtHsjcResDTO();
-            resultResult.setData(new ArrayList<>());
-            return resultResult;
        } catch (Exception e) {
-            log.error(String.format("烟台核算检测结果查询异常cardNo:%s,异常信息:%s", cardNo, e.getMessage()));
-            throw new EpmetException(EpmetErrorCode.SERVER_ERROR.getCode(), "获取核算检测结果api异常"+e.getMessage());
+            e.printStackTrace();
+            log.warn(String.format("烟台核酸检测结果查询异常cardNo:%s,异常信息:%s", cardNo, e.getMessage()));
        }
+        YtHsjcResDTO resultResult = new YtHsjcResDTO();
+        resultResult.setData(new ArrayList<>());
+        return resultResult;
    }
 }

--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/IcNatCompareRecordDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/IcNatCompareRecordDTO.java
@ -60,7 +60,7 @@ public class IcNatCompareRecordDTO implements Serializable {
     * 真实手机号
     */
    @ColumnWidth(20)
-    @ExcelProperty("手机号")
+    @ExcelProperty("联系方式")
    private String realMobile;

    /**
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/CollectDetailResultDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/CollectDetailResultDTO.java
@ -73,4 +73,6 @@ public class CollectDetailResultDTO implements Serializable {
    private String checkReason;

    private List<IcResiCollectMemDetailDTO> memberList;
+
+    private String orgIdPath;
 }
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/data/IcNatCompareRecordExcelData.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/data/IcNatCompareRecordExcelData.java
@ -21,8 +21,8 @@ public class IcNatCompareRecordExcelData {
    @ExcelProperty("身份证号")
    private String idCard;

-    @NotBlank(message = "手机号为必填项")
-    @ExcelProperty("手机号")
+    @NotBlank(message = "联系方式为必填项")
+    @ExcelProperty("联系方式")
    private String mobile;

    @Data
@ -36,7 +36,7 @@ public class IcNatCompareRecordExcelData {
        @ExcelProperty("身份证号")
        private String idCard;

-        @ExcelProperty("手机号")
+        @ExcelProperty("联系方式")
        @ColumnWidth(20)
        private String mobile;

--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/handler/IcNatCompareRecordExcelImportListener.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/handler/IcNatCompareRecordExcelImportListener.java
@ -89,12 +89,17 @@ public class IcNatCompareRecordExcelImportListener implements ReadListener<IcNat
                if (null != hsjcResDTO && CollectionUtils.isNotEmpty(hsjcResDTO.getData()) && null != hsjcResDTO.getData().get(0)) {
                    YtHsjcResDetailDTO ytHsjcResDetailDTO = hsjcResDTO.getData().get(0);
                    String testTime = ytHsjcResDetailDTO.getTest_time();
-                    compareRecordEntity.setLatestNatTime(DateUtils.parse(testTime, DateUtils.DATE_PATTERN));
-                    compareRecordEntity.setNatAddress(StringUtils.isNotBlank(ytHsjcResDetailDTO.getSampling_org_pcr()) ? ytHsjcResDetailDTO.getSample_result_pcr() : StrConstant.EPMETY_STR);
+                    if (StringUtils.isNotBlank(testTime)) {
+                        // 赋值最近一次核酸时间
+                        compareRecordEntity.setLatestNatTime(DateUtils.parse(testTime, DateUtils.DATE_TIME_PATTERN));
+                    }
+                    // 赋值检测地点
+                    compareRecordEntity.setNatAddress(StringUtils.isNotBlank(ytHsjcResDetailDTO.getSampling_org_pcr()) ? ytHsjcResDetailDTO.getSampling_org_pcr() : StrConstant.EPMETY_STR);

                    // "sample_result_pcr":"2",// 核酸检测结果 1:阳性,2:阴性
                    String sample_result_pcr = ytHsjcResDetailDTO.getSample_result_pcr();
                    if (NumConstant.ONE_STR.equals(sample_result_pcr)) {
+                        // 检测结果(0:阴性  1:阳性):接口填入
                        compareRecordEntity.setNatResult(NumConstant.ONE_STR);
                    } else if (NumConstant.TWO_STR.equals(sample_result_pcr)) {
                        compareRecordEntity.setNatResult(NumConstant.ZERO_STR);
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java
@ -32,6 +32,7 @@ import com.epmet.service.IcNatService;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@ -223,14 +224,16 @@ public class DataSyncConfigServiceImpl extends BaseServiceImpl<DataSyncConfigDao
                        e.setIsResiUser(StringUtils.isBlank(idCard.getUserId()) ? NumConstant.ZERO_STR : NumConstant.ONE_STR);
                        e.setUserId(idCard.getUserId());
                        e.setUserType("sync");
-                        e.setName(natInfo.getName());
-                        e.setMobile(natInfo.getTelephone());
-                        e.setIdCard(natInfo.getCard_no());
+                        e.setName(StringUtils.isNotBlank(natInfo.getName()) ? natInfo.getName() : "");
+                        e.setMobile(StringUtils.isNotBlank(natInfo.getTelephone()) ? natInfo.getTelephone() : "");
+                        e.setIdCard(StringUtils.isNotBlank(natInfo.getCard_no()) ? natInfo.getCard_no() : "");
                        e.setNatTime(DateUtils.parseDate(natInfo.getTest_time(),DateUtils.DATE_TIME_PATTERN));
                        e.setNatResult(natInfo.getSample_result_pcr());
                        e.setNatAddress(natInfo.getSampling_org_pcr());
                        e.setAgencyId(idCard.getAgencyId());
                        e.setPids(idCard.getPids());
+                        e.setAttachmentType("");
+                        e.setAttachmentUrl("");
                        entities.add(e);
                    });
                }
@ -240,7 +243,9 @@ public class DataSyncConfigServiceImpl extends BaseServiceImpl<DataSyncConfigDao
                entities.forEach(e -> existNatInfos.stream().filter(i -> i.getUserId().equals(e.getUserId()) && i.getIdCard().equals(e.getIdCard())).forEach(i -> e.setExistStatus(true)));
                Map<Boolean, List<IcNatEntity>> groupByStatus = entities.stream().collect(Collectors.groupingBy(IcNatEntity::getExistStatus));
                if (CollectionUtils.isNotEmpty(groupByStatus.get(false))){
-                    icNatService.insertBatch(groupByStatus.get(false));
+                    for (List<IcNatEntity> icNatEntities : ListUtils.partition(groupByStatus.get(false), 500)) {
+                        icNatService.insertBatch(icNatEntities);
+                    }
                }
                //组织关系表
                List<IcNatRelationEntity> relationEntities = new ArrayList<>();
@ -257,7 +262,9 @@ public class DataSyncConfigServiceImpl extends BaseServiceImpl<DataSyncConfigDao
                    }
                });
                if (CollectionUtils.isNotEmpty(relationEntities)){
-                    icNatRelationService.insertBatch(relationEntities);
+                    for (List<IcNatRelationEntity> icNatRelationEntities : ListUtils.partition(relationEntities, 500)) {
+                        icNatRelationService.insertBatch(icNatRelationEntities);
+                    }
                }
            }
        }
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiCollectServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiCollectServiceImpl.java
@ -224,6 +224,7 @@ public class IcResiCollectServiceImpl extends BaseServiceImpl<IcResiCollectDao,
            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "暂无查询到信息","暂无查询到信息");
        }
        CollectDetailResultDTO result = ConvertUtils.sourceToTarget(entity, CollectDetailResultDTO.class);
+        result.setOrgIdPath(StringUtils.isBlank(entity.getPids()) ? entity.getAgencyId() : entity.getPids()+":"+entity.getAgencyId());
        //查询成员信息
        List<IcResiCollectMemDetailDTO> memberList = icResiMemberDao.selectListByCollectId(dto.getId());
        result.setMemberList(memberList);
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcTripReportRecordServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcTripReportRecordServiceImpl.java
@ -264,7 +264,10 @@ public class IcTripReportRecordServiceImpl extends BaseServiceImpl<IcTripReportR
    @Transactional(rollbackFor = Exception.class)
    public void delete(String customerId, String userId, String[] ids) {
        CustomerStaffInfoCacheResult staffInfo=queryCurrentStaff(customerId,userId);
-        baseDao.batchDel(userId,staffInfo.getAgencyId(),ids);
+        int delTotal=baseDao.batchDel(userId,staffInfo.getAgencyId(),ids);
+        if (0 == delTotal) {
+            throw  new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),"行程上报删除失败，请确认组织id是否一致","记录删除失败");
+        }
    }

    /**
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcVaccinePrarmeterServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcVaccinePrarmeterServiceImpl.java
@ -324,23 +324,7 @@ public class IcVaccinePrarmeterServiceImpl extends BaseServiceImpl<IcVaccinePrar
                list.get(i).setAddStatus(true);
                continue;
            }
-            if("0".equals(list.get(i).getIsVaccination())){
-                // 未接种 判断是否填写原因
-                if (StringUtils.isBlank(list.get(i).getReason()) && !list.get(i).getAddStatus()){
-                    errorInfo.add(getErrorInfo(list.get(i), "选择未接种时，原因不能为空",i+1));
-                    list.get(i).setAddStatus(true);
-                    continue;
-                }
-                if("其他原因".equals(list.get(i).getReason())){
-                    // 未接种原因选择其他，判断是否填写备注
-                    if (StringUtils.isBlank(list.get(i).getNote()) && !list.get(i).getAddStatus()){
-                        errorInfo.add(getErrorInfo(list.get(i), "选择其他原因时，备注不能为空",i+1));
-                        list.get(i).setAddStatus(true);
-                        continue;
-                    }
-                }
-
-            }else{
+            if("1".equals(list.get(i).getIsVaccination())){
                // 已接种 判断是否填写接种时间地点
                if (StringUtils.isBlank(list.get(i).getFirstVacTime()) && !list.get(i).getAddStatus()){
                    errorInfo.add(getErrorInfo(list.get(i), "第一次接种时间不能为空",i+1));
@ -372,6 +356,17 @@ public class IcVaccinePrarmeterServiceImpl extends BaseServiceImpl<IcVaccinePrar
 //                    list.get(i).setAddStatus(true);
 //                    continue;
 //                }
+
+
+            }
+
+            if("其他原因".equals(list.get(i).getReason())){
+                // 未接种原因选择其他，判断是否填写备注
+                if (StringUtils.isBlank(list.get(i).getNote()) && !list.get(i).getAddStatus()){
+                    errorInfo.add(getErrorInfo(list.get(i), "选择其他原因时，备注不能为空",i+1));
+                    list.get(i).setAddStatus(true);
+                    continue;
+                }
            }

            // 校验所属网格通过名称能否匹配到ID
--- a/epmet-user/epmet-user-server/src/main/resources/excel/ic_nat_compare_record_template.xlsx
+++ b/epmet-user/epmet-user-server/src/main/resources/excel/ic_nat_compare_record_template.xlsx
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncConfigDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncConfigDao.xml
@ -37,7 +37,8 @@
            DATA_NAME AS dataName,
            switch_status AS switchStatus,
            sort AS sort,
-            data_code AS dataCode
+            data_code AS dataCode,
+            customer_id as customerId
        FROM data_sync_config
        WHERE DEL_FLAG = 0
          <if test='null != customerId and customerId != "" '>
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/IcTripReportRecordDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/IcTripReportRecordDao.xml
@ -68,8 +68,7 @@

    <update id="batchDel" parameterType="map">
        update ic_trip_report_record set del_flag='1',UPDATED_BY=#{userId},UPDATED_TIME=NOW()
-        WHERE USER_TYPE !='resi'
-        AND AGENCY_ID=#{agencyId}
+        WHERE  AGENCY_ID=#{agencyId}
        AND (
        <foreach collection="ids" item="id" separator=" OR ">
            id=#{id}