fix: FIXME 정리

main
Jonguk. Lim 2 months ago
parent e1e79afcf9
commit 5c36a213f5

@ -14,7 +14,7 @@ import lombok.experimental.*;
@Getter @Getter
@ToString(exclude = {"intgrnSendMast"}) @ToString(exclude = {"intgrnSendMast"})
@SuperBuilder @SuperBuilder
@EqualsAndHashCode @EqualsAndHashCode(callSuper = false)
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor
@Table(name = "ens_intgrn_snd_dtl", indexes = { @Table(name = "ens_intgrn_snd_dtl", indexes = {

@ -9,10 +9,9 @@ import cokr.xit.ens.modules.kkotalk.code.*;
import lombok.*; import lombok.*;
import lombok.experimental.*; import lombok.experimental.*;
// FIXME: 카카오톡 신규 추가
@Entity @Entity
@Getter @Getter
@ToString @ToString(exclude = {"sendMast"})
@SuperBuilder @SuperBuilder
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor

@ -1,28 +1,21 @@
package cokr.xit.ens.modules.kkotalk.domain; package cokr.xit.ens.modules.kkotalk.domain;
import java.util.Objects; import java.util.*;
import javax.persistence.Column; import javax.persistence.*;
import javax.persistence.DiscriminatorValue;
import javax.persistence.Entity;
import javax.persistence.Table;
import org.hibernate.proxy.HibernateProxy; import org.hibernate.proxy.*;
import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.TmpltMng; import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.*;
import lombok.Getter; import lombok.*;
import lombok.NoArgsConstructor; import lombok.experimental.*;
import lombok.Setter;
import lombok.ToString;
import lombok.experimental.SuperBuilder;
// FIXME: 카카오톡 신규 추가
@Entity @Entity
@Getter @Getter
@ToString @ToString
@SuperBuilder @SuperBuilder
@NoArgsConstructor @NoArgsConstructor
@Table(name = "ens_tmplt_mng_kko_talk", schema = "", catalog = "") @Table(name = "ens_tmplt_mng_kko_talk")
@DiscriminatorValue("kkotalk") @DiscriminatorValue("kkotalk")
public class TmpltMngKkoTalk extends TmpltMng { public class TmpltMngKkoTalk extends TmpltMng {

@ -1,10 +1,9 @@
package cokr.xit.ens.modules.kkotalk.domain.repository; package cokr.xit.ens.modules.kkotalk.domain.repository;
import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.*;
import cokr.xit.ens.modules.kkotalk.domain.TmpltMngKkoTalk; import cokr.xit.ens.modules.kkotalk.domain.*;
// FIXME: 카카오톡 신규 추가
public interface TmpltMngKkoTalkRepository extends JpaRepository<TmpltMngKkoTalk, Long>, public interface TmpltMngKkoTalkRepository extends JpaRepository<TmpltMngKkoTalk, Long>,
TmpltMngKkoTalkRepositoryCustom { TmpltMngKkoTalkRepositoryCustom {
} }

@ -1,11 +1,10 @@
package cokr.xit.ens.modules.kkotalk.domain.repository; package cokr.xit.ens.modules.kkotalk.domain.repository;
import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.repository.TmpltMngRepositorySupport; import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.repository.*;
import cokr.xit.ens.modules.common.ctgy.sys.mng.model.TmpltMngSearchDTO; import cokr.xit.ens.modules.common.ctgy.sys.mng.model.*;
import cokr.xit.ens.modules.kkotalk.domain.TmpltMngKkoTalk; import cokr.xit.ens.modules.kkotalk.domain.*;
import cokr.xit.ens.modules.kkotalk.model.TmpltMngKkoTalkDTO; import cokr.xit.ens.modules.kkotalk.model.*;
// FIXME: 카카오톡 신규 추가
public interface TmpltMngKkoTalkRepositoryCustom extends TmpltMngRepositorySupport<TmpltMngKkoTalk, TmpltMngSearchDTO, TmpltMngKkoTalkDTO> { public interface TmpltMngKkoTalkRepositoryCustom extends TmpltMngRepositorySupport<TmpltMngKkoTalk, TmpltMngSearchDTO, TmpltMngKkoTalkDTO> {
} }

@ -3,21 +3,18 @@ package cokr.xit.ens.modules.kkotalk.domain.repository;
import static cokr.xit.ens.modules.common.ctgy.sys.mng.domain.QOrgMng.*; import static cokr.xit.ens.modules.common.ctgy.sys.mng.domain.QOrgMng.*;
import static cokr.xit.ens.modules.kkotalk.domain.QTmpltMngKkoTalk.*; import static cokr.xit.ens.modules.kkotalk.domain.QTmpltMngKkoTalk.*;
import java.util.List; import java.util.*;
import java.util.Optional;
import com.querydsl.core.BooleanBuilder; import com.querydsl.core.*;
import com.querydsl.core.types.Projections; import com.querydsl.core.types.*;
import com.querydsl.core.types.QBean; import com.querydsl.jpa.impl.*;
import com.querydsl.jpa.impl.JPAQueryFactory;
import cokr.xit.ens.core.utils.CmmnUtil; import cokr.xit.ens.core.utils.*;
import cokr.xit.ens.modules.common.ctgy.sys.mng.model.TmpltMngSearchDTO; import cokr.xit.ens.modules.common.ctgy.sys.mng.model.*;
import cokr.xit.ens.modules.kkotalk.domain.TmpltMngKkoTalk; import cokr.xit.ens.modules.kkotalk.domain.*;
import cokr.xit.ens.modules.kkotalk.model.TmpltMngKkoTalkDTO; import cokr.xit.ens.modules.kkotalk.model.*;
import lombok.RequiredArgsConstructor; import lombok.*;
// FIXME: 카카오톡 신규 추가
@RequiredArgsConstructor @RequiredArgsConstructor
public class TmpltMngKkoTalkRepositoryImpl implements TmpltMngKkoTalkRepositoryCustom { public class TmpltMngKkoTalkRepositoryImpl implements TmpltMngKkoTalkRepositoryCustom {

@ -22,7 +22,6 @@ import cokr.xit.ens.modules.kkotalk.model.*;
* *
* </pre> * </pre>
*/ */
// FIXME: 카카오톡 신규 추가
@Mapper @Mapper
public interface IKkoTalkMapper { public interface IKkoTalkMapper {
void saveSndDtlKkoTalk(SendDetailKkoTalkDTO sendDetailKkoTalk); void saveSndDtlKkoTalk(SendDetailKkoTalkDTO sendDetailKkoTalk);
@ -41,5 +40,4 @@ public interface IKkoTalkMapper {
Optional<SendMast> selectSendMastByExternalIdAndEnvelopeId(final Map<String, String> map); Optional<SendMast> selectSendMastByExternalIdAndEnvelopeId(final Map<String, String> map);
Optional<Bill> selectBillByBillUid(final String billUid); Optional<Bill> selectBillByBillUid(final String billUid);
} }

@ -26,7 +26,6 @@ import lombok.experimental.*;
* *
* </pre> * </pre>
*/ */
// FIXME: 카카오톡 신규 추가
public class KkotalkDTO extends KkotalkApiDTO { public class KkotalkDTO extends KkotalkApiDTO {
//------------------ envelop ---------------------------------------------------------------------- //------------------ envelop ----------------------------------------------------------------------

@ -12,7 +12,6 @@ import io.swagger.v3.oas.annotations.media.*;
import lombok.*; import lombok.*;
import lombok.experimental.*; import lombok.experimental.*;
// FIXME: 카카오톡 신규 추가
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
@Data @Data
@ToString @ToString

@ -1,18 +1,14 @@
package cokr.xit.ens.modules.kkotalk.model.config; package cokr.xit.ens.modules.kkotalk.model.config;
import javax.validation.Valid; import javax.validation.*;
import javax.validation.constraints.Size; import javax.validation.constraints.*;
import cokr.xit.ens.modules.kkomydoc.model.config.XitProperty; import cokr.xit.ens.modules.kkomydoc.model.config.*;
import cokr.xit.ens.modules.kkotalk.model.KkotalkApiDTO; import cokr.xit.ens.modules.kkotalk.model.*;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.*;
import lombok.AllArgsConstructor; import lombok.*;
import lombok.Getter; import lombok.experimental.*;
import lombok.NoArgsConstructor;
import lombok.ToString;
import lombok.experimental.SuperBuilder;
// FIXME: 카카오톡 신규 추가
@Getter @Getter
@ToString @ToString
@SuperBuilder @SuperBuilder

@ -32,23 +32,22 @@ public class KkoTalkStat {
@Schema(required = true, title = "진행 상태", example = " ") @Schema(required = true, title = "진행 상태", example = " ")
private KkoTalkStatusCd status; private KkoTalkStatusCd status;
@Schema(required = false, title = "송신 시간(yyyyMMddHHmmss)", example = " ") @Schema(required = false, title = "송신 시간", example = " ")
private String sentDt; private String sentDt;
@Schema(required = false, title = "수신 시간(yyyyMMddHHmmss)", example = " ") @Schema(required = false, title = "수신 시간", example = " ")
private String receivedDt; private String receivedDt;
// FIXME: 카카오톡 적용 필요 @Schema(required = false, title = "열람 인증을 성공한 최초 시간", example = " ")
// @Schema(required = false, title = "열람 인증을 성공한 최초 시간(yyyyMMddHHmmss)", example = " ")
private String authenticatedAt; private String authenticatedAt;
//
// @Schema(required = false, title = "OTT 검증을 성공한 최초 시간(yyyyMMddHHmmss)", example = " ") @Schema(required = false, title = "OTT 검증을 성공한 최초 시간", example = " ")
private String ottVerifiedAt; private String ottVerifiedAt;
//
// @Schema(required = false, title = "최초 열람 시간(yyyyMMddHHmmss)", example = " ") @Schema(required = false, title = "최초 열람 시간", example = " ")
private String readAt; private String readAt;
//
// @Schema(required = false, title = "알림톡 수신 시간(yyyyMMddHHmmss)", example = " ") @Schema(required = false, title = "알림톡 수신 시간", example = " ")
private String userNotifiedAt; private String userNotifiedAt;
@Schema(required = false, title = "에러코드", example = " ") @Schema(required = false, title = "에러코드", example = " ")

@ -1,18 +1,13 @@
package cokr.xit.ens.modules.kkotalk.model.struct; package cokr.xit.ens.modules.kkotalk.model.struct;
import org.mapstruct.Mapper; import org.mapstruct.*;
import org.mapstruct.Mapping;
import cokr.xit.ens.core.mapstruct.GenericMapper; import cokr.xit.ens.core.mapstruct.*;
import cokr.xit.ens.core.mapstruct.StructMapperConfig; import cokr.xit.ens.modules.kkotalk.domain.*;
import cokr.xit.ens.modules.kkotalk.domain.TmpltMngKkoTalk; import cokr.xit.ens.modules.kkotalk.model.*;
import cokr.xit.ens.modules.kkotalk.model.TmpltMngKkoTalkDTO;
// FIXME: 카카오톡 신규 추가
@Mapper(config = StructMapperConfig.class) @Mapper(config = StructMapperConfig.class)
public interface TmpltMngKkoTalkMapper extends GenericMapper<TmpltMngKkoTalkDTO, TmpltMngKkoTalk> { public interface TmpltMngKkoTalkMapper extends GenericMapper<TmpltMngKkoTalkDTO, TmpltMngKkoTalk> {
@Override @Override
@Mapping(target = "orgMng.orgCd", source = "orgCd") @Mapping(target = "orgMng.orgCd", source = "orgCd")
TmpltMngKkoTalk toEntity(TmpltMngKkoTalkDTO tmpltMngKkoTalkDTO); TmpltMngKkoTalk toEntity(TmpltMngKkoTalkDTO tmpltMngKkoTalkDTO);
@ -20,6 +15,4 @@ public interface TmpltMngKkoTalkMapper extends GenericMapper<TmpltMngKkoTalkDTO,
@Override @Override
@Mapping(target = "orgCd", expression = "java(tmpltMngKkoTalk.getOrgMng().getOrgCd())") @Mapping(target = "orgCd", expression = "java(tmpltMngKkoTalk.getOrgMng().getOrgCd())")
TmpltMngKkoTalkDTO toDto(TmpltMngKkoTalk tmpltMngKkoTalk); TmpltMngKkoTalkDTO toDto(TmpltMngKkoTalk tmpltMngKkoTalk);
} }

@ -27,7 +27,6 @@ import cokr.xit.ens.modules.kkotalk.service.support.*;
import lombok.*; import lombok.*;
import lombok.extern.slf4j.*; import lombok.extern.slf4j.*;
// FIXME: 카카오톡 신규 추가
@Slf4j @Slf4j
@Service @Service
@RequiredArgsConstructor @RequiredArgsConstructor
@ -306,7 +305,6 @@ public class KkoTalkService {
throw new EnsException(EnsErrCd.ERR401, "토큰(은)는 필수조건 입니다."); throw new EnsException(EnsErrCd.ERR401, "토큰(은)는 필수조건 입니다.");
OrgMng orgMng = orgMngService.find(orgCd).getResultInfo(); OrgMng orgMng = orgMngService.find(orgCd).getResultInfo();
// FIXME: 카카오톡 토큰검증 API 처리
ResponseEntity<String> resp = kkoTalkApi.validToken( ResponseEntity<String> resp = kkoTalkApi.validToken(
orgMng, orgMng,
KkotalkApiDTO.ValidTokenRequest.builder() KkotalkApiDTO.ValidTokenRequest.builder()
@ -326,7 +324,6 @@ public class KkoTalkService {
throw new EnsException(EnsErrCd.ERR505, String.format("토큰검증 응답데이터 파싱 실패. %s", resp.getBody())); throw new EnsException(EnsErrCd.ERR505, String.format("토큰검증 응답데이터 파싱 실패. %s", resp.getBody()));
} }
// FIXME: 카카오톡 적용 확인
String envelopeStatus = (String) mResponse.get("status"); String envelopeStatus = (String) mResponse.get("status");
if (!CmmnUtil.isEmpty(envelopeStatus)) { if (!CmmnUtil.isEmpty(envelopeStatus)) {
responseVO = EnsResponseVO.okBuilder() responseVO = EnsResponseVO.okBuilder()
@ -356,7 +353,6 @@ public class KkoTalkService {
} finally { } finally {
if (EnsErrCd.OK.equals(responseVO.getErrCode())) { if (EnsErrCd.OK.equals(responseVO.getErrCode())) {
Map<String, Object> resultInfo = (Map<String, Object>) responseVO.getResultInfo(); Map<String, Object> resultInfo = (Map<String, Object>) responseVO.getResultInfo();
// FIXME: 카카오톡 적용 확인 필요??
sendDetailKkoTalkTokenHistRepository.save(SendDetailKkoTalkTokenHist.builder() sendDetailKkoTalkTokenHistRepository.save(SendDetailKkoTalkTokenHist.builder()
.envelopeId(envelopeId) .envelopeId(envelopeId)
.externalId(externalId) .externalId(externalId)
@ -403,7 +399,6 @@ public class KkoTalkService {
throw new EnsException(EnsErrCd.ERR401, "문서식별번호(은)는 필수조건 입니다."); throw new EnsException(EnsErrCd.ERR401, "문서식별번호(은)는 필수조건 입니다.");
OrgMng orgMng = orgMngService.find(orgCd).getResultInfo(); OrgMng orgMng = orgMngService.find(orgCd).getResultInfo();
// FIXME: 카카오툭 토큰 확인 API 호출 처리
ResponseEntity<String> resp = kkoTalkApi.modifyStatus( ResponseEntity<String> resp = kkoTalkApi.modifyStatus(
orgMng, orgMng,
KkotalkDTO.EnvelopeId.builder() KkotalkDTO.EnvelopeId.builder()

@ -1,34 +1,25 @@
package cokr.xit.ens.modules.kkotalk.service.strategy; package cokr.xit.ens.modules.kkotalk.service.strategy;
import java.util.Arrays; import java.util.*;
import java.util.List; import java.util.stream.*;
import java.util.Map;
import java.util.Optional; import javax.validation.*;
import java.util.Set;
import java.util.stream.Collectors; import org.mapstruct.factory.*;
import org.springframework.stereotype.*;
import cokr.xit.ens.core.exception.*;
import cokr.xit.ens.core.exception.code.*;
import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.*;
import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.repository.*;
import cokr.xit.ens.modules.common.ctgy.sys.mng.model.*;
import cokr.xit.ens.modules.common.ctgy.sys.mng.service.strategy.*;
import cokr.xit.ens.modules.kkotalk.domain.*;
import cokr.xit.ens.modules.kkotalk.domain.repository.*;
import cokr.xit.ens.modules.kkotalk.model.*;
import cokr.xit.ens.modules.kkotalk.model.struct.*;
import lombok.*;
import javax.validation.ConstraintViolation;
import javax.validation.Validation;
import javax.validation.Validator;
import org.mapstruct.factory.Mappers;
import org.springframework.stereotype.Component;
import cokr.xit.ens.core.exception.EnsException;
import cokr.xit.ens.core.exception.code.EnsErrCd;
import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.OrgMng;
import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.repository.OrgMngRepository;
import cokr.xit.ens.modules.common.ctgy.sys.mng.domain.repository.TmpltMngRepository;
import cokr.xit.ens.modules.common.ctgy.sys.mng.model.TmpltMngDTO;
import cokr.xit.ens.modules.common.ctgy.sys.mng.model.TmpltMngSearchDTO;
import cokr.xit.ens.modules.common.ctgy.sys.mng.service.strategy.TmpltMngStrategyTemplate;
import cokr.xit.ens.modules.kkotalk.domain.TmpltMngKkoTalk;
import cokr.xit.ens.modules.kkotalk.domain.repository.TmpltMngKkoTalkRepository;
import cokr.xit.ens.modules.kkotalk.model.TmpltMngKkoTalkDTO;
import cokr.xit.ens.modules.kkotalk.model.struct.TmpltMngKkoTalkMapper;
import lombok.RequiredArgsConstructor;
// FIXME: 카카오톡 신규 추가
@Component("tmpltMngStrategy_kkotalk") @Component("tmpltMngStrategy_kkotalk")
@RequiredArgsConstructor @RequiredArgsConstructor
public class TmpltMngStrategyKkoTalk extends TmpltMngStrategyTemplate<Map<String, Object>, TmpltMngKkoTalkDTO> { public class TmpltMngStrategyKkoTalk extends TmpltMngStrategyTemplate<Map<String, Object>, TmpltMngKkoTalkDTO> {
@ -37,7 +28,6 @@ public class TmpltMngStrategyKkoTalk extends TmpltMngStrategyTemplate<Map<String
private final TmpltMngRepository tmpltMngRepository; private final TmpltMngRepository tmpltMngRepository;
private final TmpltMngKkoTalkRepository tmpltMngKkoTalkRepository; private final TmpltMngKkoTalkRepository tmpltMngKkoTalkRepository;
private final TmpltMngKkoTalkMapper kkoTalkMapper = Mappers.getMapper(TmpltMngKkoTalkMapper.class); private final TmpltMngKkoTalkMapper kkoTalkMapper = Mappers.getMapper(TmpltMngKkoTalkMapper.class);
// private final RedisTemplate redisTemplate;
@Override @Override
public List<TmpltMngKkoTalkDTO> findAll(TmpltMngSearchDTO tmpltMngSearchDTO) { public List<TmpltMngKkoTalkDTO> findAll(TmpltMngSearchDTO tmpltMngSearchDTO) {
@ -47,10 +37,6 @@ public class TmpltMngStrategyKkoTalk extends TmpltMngStrategyTemplate<Map<String
@Override @Override
public Optional<TmpltMngKkoTalkDTO> find(String orgCd, String tmpltCd) { public Optional<TmpltMngKkoTalkDTO> find(String orgCd, String tmpltCd) {
return tmpltMngKkoTalkRepository.findDtoByOrgCdAndTmpltCd(orgCd, tmpltCd); return tmpltMngKkoTalkRepository.findDtoByOrgCdAndTmpltCd(orgCd, tmpltCd);
// String key = super.pushCache(redisTemplate, orgCd, tmpltCd, tmpltMngKkoMydocRepository);
// HashOperations<String, String, TmpltMngKkoMydocDTO> hashOperations = redisTemplate.opsForHash();
// return Optional.ofNullable(hashOperations.entries(KEY).get(key));
} }
@ -97,7 +83,5 @@ public class TmpltMngStrategyKkoTalk extends TmpltMngStrategyTemplate<Map<String
throw new EnsException(EnsErrCd.ERR402, "\"미사용\" 상태의 템플릿은 수정 할 수 없습니다."); throw new EnsException(EnsErrCd.ERR402, "\"미사용\" 상태의 템플릿은 수정 할 수 없습니다.");
kkoTalkMapper.updateFromDto(dto, tmpltMng); kkoTalkMapper.updateFromDto(dto, tmpltMng);
tmpltMng.setUpdId("ENS_SYS"); tmpltMng.setUpdId("ENS_SYS");
// super.deleteCache(redisTemplate, dto.getOrgCd(), dto.getTmpltCd());
} }
} }

@ -33,7 +33,6 @@ import cokr.xit.ens.modules.kkotalk.model.*;
import lombok.*; import lombok.*;
import lombok.extern.slf4j.*; import lombok.extern.slf4j.*;
// FIXME: 카카오톡 신규 추가
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor @RequiredArgsConstructor

@ -37,7 +37,6 @@ import lombok.extern.slf4j.*;
* *
* </pre> * </pre>
*/ */
// FIXME: 카카오톡 신규 추가
@Slf4j @Slf4j
@RequiredArgsConstructor @RequiredArgsConstructor
@Component @Component
@ -370,7 +369,6 @@ public class KkoTalkApiService {
return responseEntity; return responseEntity;
} }
// FIXME: 카카오톡 API 호출 시 API 호출 정보 추가 필요
private HttpHeaders getHeaders(final OrgMng orgMng){ private HttpHeaders getHeaders(final OrgMng orgMng){
HttpHeaders headers = new HttpHeaders(); HttpHeaders headers = new HttpHeaders();
headers.setContentType(new MediaType(MediaType.APPLICATION_JSON, Charset.forName("utf-8"))); headers.setContentType(new MediaType(MediaType.APPLICATION_JSON, Charset.forName("utf-8")));

@ -31,7 +31,6 @@ import cokr.xit.ens.modules.kkotalk.service.strategy.*;
import lombok.*; import lombok.*;
import lombok.extern.slf4j.*; import lombok.extern.slf4j.*;
// FIXME: 카카오톡 신규 추가
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor @RequiredArgsConstructor

@ -32,7 +32,6 @@ import cokr.xit.ens.modules.kkotalk.model.*;
import lombok.*; import lombok.*;
import lombok.extern.slf4j.*; import lombok.extern.slf4j.*;
// FIXME: 카카오톡 신규 추가
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor @RequiredArgsConstructor
@ -111,7 +110,6 @@ public class KkoTalkRsltFetcher extends ResultProcTemplate {
.build()) .build())
); );
} finally { } finally {
// FIXME: 카카오톡 추가 - 카카오톡 테이블 업데이트
list list
.forEach(talkMapper::updateKakaotalkStatusBulksResult); .forEach(talkMapper::updateKakaotalkStatusBulksResult);
@ -135,7 +133,6 @@ public class KkoTalkRsltFetcher extends ResultProcTemplate {
if (EnsErrCd.OK.equals(respVO.getErrCode())) { if (EnsErrCd.OK.equals(respVO.getErrCode())) {
sendMast.setError(FieldError.initBuilder().build()); sendMast.setError(FieldError.initBuilder().build());
// FIXME: 카카오톡 코드 반영 필요
Integer readCnt = sendDetails.stream() Integer readCnt = sendDetails.stream()
.map(row -> KkoTalkStatusCd.READ.equals(row.getStatus()) ? 1 : 0) .map(row -> KkoTalkStatusCd.READ.equals(row.getStatus()) ? 1 : 0)
.reduce(Integer::sum) .reduce(Integer::sum)

@ -21,7 +21,6 @@ import cokr.xit.ens.modules.kkotalk.model.config.*;
import lombok.*; import lombok.*;
import lombok.extern.slf4j.*; import lombok.extern.slf4j.*;
// FIXME: 카카오톡 신규 추가
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor @RequiredArgsConstructor
@ -53,7 +52,6 @@ public class KkoTalkRsltProvider implements EnsPhaseProcSupport<EnsResponseVO, L
List<SendDetailKkoTalkDTO> sendDetailKkoTalks = talkMapper.findAllBySendMastId(sendMast.getSendMastId()); List<SendDetailKkoTalkDTO> sendDetailKkoTalks = talkMapper.findAllBySendMastId(sendMast.getSendMastId());
// FIXME: 카카오톡 적용 필요
KkoTalkRsltRespDTO respDTO = KkoTalkRsltRespDTO.builder() KkoTalkRsltRespDTO respDTO = KkoTalkRsltRespDTO.builder()
.sendMastId(sendMast.getSendMastId()) .sendMastId(sendMast.getSendMastId())
.statCd(sendMast.getStatCd()) .statCd(sendMast.getStatCd())
@ -71,7 +69,6 @@ public class KkoTalkRsltProvider implements EnsPhaseProcSupport<EnsResponseVO, L
.status(row.getStatus()) .status(row.getStatus())
.sentDt(row.getSentAt()) .sentDt(row.getSentAt())
.receivedDt(row.getReceivedAt()) .receivedDt(row.getReceivedAt())
// FIXME: 카카오톡 적용 필요
.authenticatedAt(row.getAuthenticatedAt()) .authenticatedAt(row.getAuthenticatedAt())
.ottVerifiedAt(row.getOttVerifiedAt()) .ottVerifiedAt(row.getOttVerifiedAt())
.readAt(row.getReadAt()) .readAt(row.getReadAt())

@ -35,7 +35,6 @@ import cokr.xit.ens.modules.kkotalk.model.*;
import lombok.*; import lombok.*;
import lombok.extern.slf4j.*; import lombok.extern.slf4j.*;
// FIXME: 카카오톡 신규 추가
@Slf4j @Slf4j
@Component @Component
@RequiredArgsConstructor @RequiredArgsConstructor
@ -136,9 +135,7 @@ public class KkoTalkSender extends SendProcTemplate {
row.setErrorMessage(e.getMessage()); row.setErrorMessage(e.getMessage());
}); });
} finally { } finally {
// FIXME: 카카오톡 추가 - 카카오톡 테이블 업데이트 list.forEach(talkMapper::updateKakaotalkSendBulksResult);
list.stream()
.forEach(talkMapper::updateKakaotalkSendBulksResult);
if (!CmmnUtil.isEmpty(envelopes)) if (!CmmnUtil.isEmpty(envelopes))
sendDetailKkoTalkReqHistRepository.saveAll( sendDetailKkoTalkReqHistRepository.saveAll(

Loading…
Cancel
Save