// Spinnaker 파이프라인 정의 예시 (Groovy DSL)
pipeline {
    appConfig {
        name = "my-microservice"
        email = "team@example.com"
    }
    
    stages {
        stage("Build") {
            job {
                name = "Build"
                command = "./gradlew build"
            }
        }
        
        stage("Test") {
            job {
                name = "Unit Tests"
                command = "./gradlew test"
            }
        }
        
        stage("Deploy") {
            deploymentStrategy = "blue-green"
            regions = ["us-east-1", "eu-west-1"]
            
            notifications {
                slack {
                    channel = "#deployments"
                    message = "Deploying ${appConfig.name} to ${regions.join(', ')}"
                }
            }
        }
    }
}

// 금융 거래 데이터 처리 예시
import groovy.json.JsonSlurper
import groovy.sql.Sql

// 거래 데이터 로드
def transactionsFile = new File("daily_transactions.json")
def transactions = new JsonSlurper().parse(transactionsFile)

// 데이터베이스 연결
def sql = Sql.newInstance("jdbc:postgresql://localhost:5432/finance", 
                          "username", "password", "org.postgresql.Driver")

// 고액 거래 필터링 및 알림
def highValueTransactions = transactions.findAll { it.amount > 10000 }
highValueTransactions.each { transaction ->
    // 데이터베이스에 기록
    sql.executeInsert("""
        INSERT INTO high_value_transactions 
        (transaction_id, customer_id, amount, timestamp, status)
        VALUES (?, ?, ?, ?, ?)
    """, [transaction.id, transaction.customerId, transaction.amount, 
          new Date(), "PENDING_REVIEW"])
    
    // 컴플라이언스팀에 알림
    sendAlert("compliance@bank.com", 
              "High value transaction detected: $${transaction.amount} by Customer #${transaction.customerId}")
}

// 일일 리포트 생성
def report = generateDailyReport(transactions)
sendEmail("reports@bank.com", "Daily Transaction Report", report)

// 임상 시험 데이터 분석 예시
import org.apache.commons.math3.stat.descriptive.DescriptiveStatistics
import groovy.json.JsonOutput

// 임상 시험 데이터 로드
def clinicalData = new File("clinical_trial_results.csv").text.split("\n")
def headers = clinicalData[0].split(",")
def data = clinicalData[1..-1].collect { line -> 
    def values = line.split(",")
    def row = [:]
    headers.eachWithIndex { header, i -> 
        row[header] = isNumeric(values[i]) ? values[i].toDouble() : values[i]
    }
    return row
}

// 약물 효과 분석
def treatmentGroup = data.findAll { it.group == "treatment" }
def controlGroup = data.findAll { it.group == "control" }

def treatmentStats = calculateStatistics(treatmentGroup.collect { it.response })
def controlStats = calculateStatistics(controlGroup.collect { it.response })

// 결과 리포트 생성
def report = [
    studyName: "Clinical Trial XYZ-123",
    date: new Date().format("yyyy-MM-dd"),
    participants: data.size(),
    treatmentGroup: [
        count: treatmentGroup.size(),
        meanResponse: treatmentStats.mean,
        stdDev: treatmentStats.standardDeviation
    ],
    controlGroup: [
        count: controlGroup.size(),
        meanResponse: controlStats.mean,
        stdDev: controlStats.standardDeviation
    ],
    pValue: calculatePValue(treatmentGroup, controlGroup)
]

// JSON 형식으로 저장
new File("trial_report.json").text = JsonOutput.prettyPrint(JsonOutput.toJson(report))

// 통계 계산 함수
def calculateStatistics(values) {
    def stats = new DescriptiveStatistics()
    values.each { stats.addValue(it) }
    return stats
}

// 숫자 확인 함수
def isNumeric(str) {
    return str.matches("-?\\d+(\\.\\d+)?")
}

// 쇼핑 카트 서비스 테스트 예시 (Spock 프레임워크)
class ShoppingCartServiceSpec extends Specification {
    @Shared CartService cartService
    @Shared ProductService productService
    @Shared UserService userService
    
    def setupSpec() {
        cartService = new CartService()
        productService = Mock(ProductService)
        userService = Mock(UserService)
        cartService.productService = productService
        cartService.userService = userService
    }
    
    def "사용자가 상품을 카트에 추가하면 카트에 상품이 포함되어야 한다"() {
        given: "사용자와 상품이 존재한다"
        def userId = 123
        def productId = 456
        def product = new Product(id: productId, name: "스마트폰", price: 1000000)
        
        and: "상품 서비스가 상품 정보를 제공한다"
        productService.getProduct(productId) >> product
        
        and: "사용자 서비스가 사용자 정보를 제공한다"
        userService.isActive(userId) >> true
        
        when: "사용자가 상품을 카트에 추가한다"
        def result = cartService.addToCart(userId, productId, 1)
        
        then: "카트에 상품이 추가되어야 한다"
        result.success == true
        result.cart.items.size() == 1
        result.cart.items[0].productId == productId
        result.cart.items[0].quantity == 1
        result.cart.total == 1000000
    }
    
    def "재고가 없는 상품은 카트에 추가할 수 없다"() {
        given: "상품이 존재하지만 재고가 없다"
        def userId = 123
        def productId = 789
        def product = new Product(id: productId, name: "품절 상품", price: 50000, inStock: false)
        
        and: "상품 서비스가 상품 정보를 제공한다"
        productService.getProduct(productId) >> product
        
        when: "사용자가 상품을 카트에 추가하려고 한다"
        def result = cartService.addToCart(userId, productId, 1)
        
        then: "재고 부족 오류가 발생해야 한다"
        result.success == false
        result.errorCode == "OUT_OF_STOCK"
    }
}