claudeで作ったのを追加
This commit is contained in:
parent
d342117267
commit
65c241c814
10 changed files with 2070 additions and 0 deletions
104
claude/Android_ApiService.kt
Normal file
104
claude/Android_ApiService.kt
Normal file
|
|
@ -0,0 +1,104 @@
|
|||
// app/src/main/java/com/example/mobilepos/data/api/SyncApiService.kt
|
||||
|
||||
package com.example.mobilepos.data.api
|
||||
|
||||
import retrofit2.Response
|
||||
import retrofit2.http.*
|
||||
import com.example.mobilepos.data.models.*
|
||||
import java.util.UUID
|
||||
|
||||
interface SyncApiService {
|
||||
|
||||
@POST("/api/v1/sync")
|
||||
suspend fun syncDocuments(
|
||||
@Header("X-API-Key") apiKey: String,
|
||||
@Body request: SyncRequestDto
|
||||
): Response<SyncResponseDto>
|
||||
|
||||
@GET("/api/v1/customers")
|
||||
suspend fun getCustomers(
|
||||
@Header("X-API-Key") apiKey: String
|
||||
): Response<CustomerListResponse>
|
||||
|
||||
@GET("/api/v1/documents/{id}")
|
||||
suspend fun getDocument(
|
||||
@Header("X-API-Key") apiKey: String,
|
||||
@Path("id") documentId: Int
|
||||
): Response<DocumentDetailResponse>
|
||||
|
||||
@POST("/api/v1/receipts/{invoiceId}")
|
||||
suspend fun createReceipt(
|
||||
@Header("X-API-Key") apiKey: String,
|
||||
@Path("invoiceId") invoiceId: Int
|
||||
): Response<ReceiptCreateResponse>
|
||||
|
||||
@GET("/api/v1/health")
|
||||
suspend fun healthCheck(
|
||||
@Header("X-API-Key") apiKey: String
|
||||
): Response<HealthCheckResponse>
|
||||
}
|
||||
|
||||
// ========== API Response Models ==========
|
||||
|
||||
data class CustomerListResponse(
|
||||
val status: String,
|
||||
val customers: List<CustomerDto>
|
||||
)
|
||||
|
||||
data class DocumentDetailResponse(
|
||||
val status: String,
|
||||
val document: DocumentDto
|
||||
)
|
||||
|
||||
data class ReceiptCreateResponse(
|
||||
val status: String,
|
||||
val receiptId: Int,
|
||||
val message: String
|
||||
)
|
||||
|
||||
data class HealthCheckResponse(
|
||||
val status: String,
|
||||
val timestamp: Long
|
||||
)
|
||||
|
||||
// ========== Retrofit Factory ==========
|
||||
|
||||
import okhttp3.OkHttpClient
|
||||
import okhttp3.logging.HttpLoggingInterceptor
|
||||
import retrofit2.Retrofit
|
||||
import retrofit2.converter.gson.GsonConverterFactory
|
||||
import com.google.gson.GsonBuilder
|
||||
|
||||
object ApiClient {
|
||||
private var retrofit: Retrofit? = null
|
||||
|
||||
fun getClient(baseUrl: String): Retrofit {
|
||||
if (retrofit == null) {
|
||||
val httpLoggingInterceptor = HttpLoggingInterceptor().apply {
|
||||
level = HttpLoggingInterceptor.Level.BODY
|
||||
}
|
||||
|
||||
val okHttpClient = OkHttpClient.Builder()
|
||||
.addInterceptor(httpLoggingInterceptor)
|
||||
.connectTimeout(30, java.util.concurrent.TimeUnit.SECONDS)
|
||||
.readTimeout(30, java.util.concurrent.TimeUnit.SECONDS)
|
||||
.writeTimeout(30, java.util.concurrent.TimeUnit.SECONDS)
|
||||
.build()
|
||||
|
||||
val gson = GsonBuilder()
|
||||
.setDateFormat("yyyy-MM-dd'T'HH:mm:ss")
|
||||
.create()
|
||||
|
||||
retrofit = Retrofit.Builder()
|
||||
.baseUrl(baseUrl)
|
||||
.client(okHttpClient)
|
||||
.addConverterFactory(GsonConverterFactory.create(gson))
|
||||
.build()
|
||||
}
|
||||
return retrofit!!
|
||||
}
|
||||
|
||||
fun getSyncApiService(baseUrl: String): SyncApiService {
|
||||
return getClient(baseUrl).create(SyncApiService::class.java)
|
||||
}
|
||||
}
|
||||
109
claude/Android_DAO.kt
Normal file
109
claude/Android_DAO.kt
Normal file
|
|
@ -0,0 +1,109 @@
|
|||
// app/src/main/java/com/example/mobilepos/data/dao/DocumentDao.kt
|
||||
|
||||
package com.example.mobilepos.data.dao
|
||||
|
||||
import androidx.room.*
|
||||
import com.example.mobilepos.data.models.*
|
||||
import kotlinx.coroutines.flow.Flow
|
||||
|
||||
@Dao
|
||||
interface CustomerDao {
|
||||
@Insert(onConflict = OnConflictStrategy.REPLACE)
|
||||
suspend fun insertCustomer(customer: CustomerEntity)
|
||||
|
||||
@Update
|
||||
suspend fun updateCustomer(customer: CustomerEntity)
|
||||
|
||||
@Delete
|
||||
suspend fun deleteCustomer(customer: CustomerEntity)
|
||||
|
||||
@Query("SELECT * FROM customers WHERE id = :id")
|
||||
suspend fun getCustomerById(id: Int): CustomerEntity?
|
||||
|
||||
@Query("SELECT * FROM customers ORDER BY name ASC")
|
||||
fun getAllCustomers(): Flow<List<CustomerEntity>>
|
||||
|
||||
@Query("SELECT * FROM customers WHERE synced = 0")
|
||||
suspend fun getUnsyncedCustomers(): List<CustomerEntity>
|
||||
|
||||
@Query("UPDATE customers SET synced = 1 WHERE id = :id")
|
||||
suspend fun markCustomerAsSynced(id: Int)
|
||||
}
|
||||
|
||||
@Dao
|
||||
interface DocumentDao {
|
||||
@Insert(onConflict = OnConflictStrategy.REPLACE)
|
||||
suspend fun insertDocument(document: DocumentEntity): Long
|
||||
|
||||
@Update
|
||||
suspend fun updateDocument(document: DocumentEntity)
|
||||
|
||||
@Delete
|
||||
suspend fun deleteDocument(document: DocumentEntity)
|
||||
|
||||
@Query("SELECT * FROM documents WHERE id = :id")
|
||||
suspend fun getDocumentById(id: Int): DocumentEntity?
|
||||
|
||||
@Query("SELECT * FROM documents WHERE customerId = :customerId ORDER BY documentDate DESC")
|
||||
fun getDocumentsByCustomer(customerId: Int): Flow<List<DocumentEntity>>
|
||||
|
||||
@Query("SELECT * FROM documents WHERE docType = :docType ORDER BY documentDate DESC")
|
||||
fun getDocumentsByType(docType: String): Flow<List<DocumentEntity>>
|
||||
|
||||
@Query("SELECT * FROM documents WHERE status = :status ORDER BY documentDate DESC")
|
||||
fun getDocumentsByStatus(status: String): Flow<List<DocumentEntity>>
|
||||
|
||||
@Query("SELECT * FROM documents WHERE docType = 'invoice' AND paidDate IS NULL ORDER BY paymentDueDate ASC")
|
||||
fun getUnpaidInvoices(): Flow<List<DocumentEntity>>
|
||||
|
||||
@Query("SELECT * FROM documents WHERE synced = 0")
|
||||
suspend fun getUnsyncedDocuments(): List<DocumentEntity>
|
||||
|
||||
@Query("SELECT * FROM documents ORDER BY documentDate DESC")
|
||||
fun getAllDocuments(): Flow<List<DocumentEntity>>
|
||||
|
||||
@Query("UPDATE documents SET synced = 1, syncTimestamp = :timestamp WHERE id = :id")
|
||||
suspend fun markDocumentAsSynced(id: Int, timestamp: Long)
|
||||
|
||||
@Query("UPDATE documents SET status = :status, paidDate = :paidDate WHERE id = :id")
|
||||
suspend fun updateDocumentStatus(id: Int, status: String, paidDate: Long?)
|
||||
|
||||
@Query("UPDATE documents SET paymentDueDate = :dueDate WHERE id = :id")
|
||||
suspend fun updatePaymentDueDate(id: Int, dueDate: Long)
|
||||
|
||||
@Query("DELETE FROM documents WHERE docType = :docType")
|
||||
suspend fun deleteDocumentsByType(docType: String)
|
||||
}
|
||||
|
||||
@Dao
|
||||
interface PaymentTermsDao {
|
||||
@Insert(onConflict = OnConflictStrategy.REPLACE)
|
||||
suspend fun insertPaymentTerms(terms: PaymentTermsEntity)
|
||||
|
||||
@Query("SELECT * FROM payment_terms WHERE documentId = :documentId")
|
||||
suspend fun getPaymentTermsByDocument(documentId: Int): PaymentTermsEntity?
|
||||
|
||||
@Query("SELECT * FROM payment_terms ORDER BY createdAt DESC")
|
||||
suspend fun getAllPaymentTerms(): List<PaymentTermsEntity>
|
||||
|
||||
@Delete
|
||||
suspend fun deletePaymentTerms(terms: PaymentTermsEntity)
|
||||
}
|
||||
|
||||
@Dao
|
||||
interface SyncLogDao {
|
||||
@Insert
|
||||
suspend fun insertSyncLog(log: SyncLogEntity)
|
||||
|
||||
@Query("SELECT * FROM sync_logs ORDER BY timestamp DESC LIMIT :limit")
|
||||
suspend fun getRecentSyncLogs(limit: Int = 10): List<SyncLogEntity>
|
||||
|
||||
@Query("SELECT * FROM sync_logs WHERE deviceId = :deviceId ORDER BY timestamp DESC LIMIT :limit")
|
||||
suspend fun getSyncLogsByDevice(deviceId: String, limit: Int = 10): List<SyncLogEntity>
|
||||
|
||||
@Query("SELECT MAX(timestamp) FROM sync_logs WHERE operation = 'sync' AND status = 'success'")
|
||||
suspend fun getLastSuccessfulSyncTime(): Long?
|
||||
|
||||
@Query("DELETE FROM sync_logs WHERE timestamp < :olderThanMillis")
|
||||
suspend fun deleteSyncLogsOlderThan(olderThanMillis: Long)
|
||||
}
|
||||
71
claude/Android_Database.kt
Normal file
71
claude/Android_Database.kt
Normal file
|
|
@ -0,0 +1,71 @@
|
|||
// app/src/main/java/com/example/mobilepos/data/AppDatabase.kt
|
||||
|
||||
package com.example.mobilepos.data
|
||||
|
||||
import android.content.Context
|
||||
import androidx.room.Database
|
||||
import androidx.room.Room
|
||||
import androidx.room.RoomDatabase
|
||||
import androidx.room.migration.Migration
|
||||
import androidx.sqlite.db.SupportSQLiteDatabase
|
||||
import com.example.mobilepos.data.dao.*
|
||||
import com.example.mobilepos.data.models.*
|
||||
|
||||
@Database(
|
||||
entities = [
|
||||
CustomerEntity::class,
|
||||
DocumentEntity::class,
|
||||
PaymentTermsEntity::class,
|
||||
SyncLogEntity::class
|
||||
],
|
||||
version = 2,
|
||||
exportSchema = true
|
||||
)
|
||||
abstract class AppDatabase : RoomDatabase() {
|
||||
abstract fun customerDao(): CustomerDao
|
||||
abstract fun documentDao(): DocumentDao
|
||||
abstract fun paymentTermsDao(): PaymentTermsDao
|
||||
abstract fun syncLogDao(): SyncLogDao
|
||||
|
||||
companion object {
|
||||
@Volatile
|
||||
private var INSTANCE: AppDatabase? = null
|
||||
|
||||
fun getInstance(context: Context): AppDatabase {
|
||||
return INSTANCE ?: synchronized(this) {
|
||||
val instance = Room.databaseBuilder(
|
||||
context.applicationContext,
|
||||
AppDatabase::class.java,
|
||||
"mobile_pos_database"
|
||||
)
|
||||
.addMigrations(MIGRATION_1_2)
|
||||
.build()
|
||||
INSTANCE = instance
|
||||
instance
|
||||
}
|
||||
}
|
||||
|
||||
// マイグレーション: v1 -> v2
|
||||
private val MIGRATION_1_2 = object : Migration(1, 2) {
|
||||
override fun migrate(database: SupportSQLiteDatabase) {
|
||||
// syncTimestamp カラムを追加
|
||||
database.execSQL(
|
||||
"ALTER TABLE documents ADD COLUMN syncTimestamp INTEGER"
|
||||
)
|
||||
// インデックスを追加（パフォーマンス向上）
|
||||
database.execSQL(
|
||||
"CREATE INDEX IF NOT EXISTS idx_documents_customerId ON documents(customerId)"
|
||||
)
|
||||
database.execSQL(
|
||||
"CREATE INDEX IF NOT EXISTS idx_documents_docType ON documents(docType)"
|
||||
)
|
||||
database.execSQL(
|
||||
"CREATE INDEX IF NOT EXISTS idx_documents_status ON documents(status)"
|
||||
)
|
||||
database.execSQL(
|
||||
"CREATE INDEX IF NOT EXISTS idx_documents_synced ON documents(synced)"
|
||||
)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
170
claude/Android_Models.kt
Normal file
170
claude/Android_Models.kt
Normal file
|
|
@ -0,0 +1,170 @@
|
|||
// app/src/main/java/com/example/mobilepos/data/models/Models.kt
|
||||
|
||||
package com.example.mobilepos.data.models
|
||||
|
||||
import androidx.room.Entity
|
||||
import androidx.room.PrimaryKey
|
||||
import androidx.room.TypeConverters
|
||||
import java.util.Date
|
||||
|
||||
// ========== Room Database Entities ==========
|
||||
|
||||
@Entity(tableName = "customers")
|
||||
data class CustomerEntity(
|
||||
@PrimaryKey
|
||||
val id: Int,
|
||||
val odooCustomerId: Int? = null,
|
||||
val name: String,
|
||||
val address: String? = null,
|
||||
val phone: String? = null,
|
||||
val email: String? = null,
|
||||
val createdAt: Long = System.currentTimeMillis(),
|
||||
val updatedAt: Long = System.currentTimeMillis(),
|
||||
val synced: Boolean = false
|
||||
)
|
||||
|
||||
@Entity(tableName = "documents")
|
||||
data class DocumentEntity(
|
||||
@PrimaryKey
|
||||
val id: Int = 0,
|
||||
val odooId: Int? = null,
|
||||
val docType: String, // quotation, delivery, invoice, receipt
|
||||
val customerId: Int,
|
||||
val documentDate: Long,
|
||||
val items: String, // JSON string
|
||||
val subtotal: Double,
|
||||
val tax: Double,
|
||||
val total: Double,
|
||||
val status: String, // draft, sent, confirmed, paid
|
||||
val billingDate: Long? = null,
|
||||
val paymentDueDate: Long,
|
||||
val paymentMethod: String? = null,
|
||||
val paidDate: Long? = null,
|
||||
val notes: String? = null,
|
||||
val createdAt: Long = System.currentTimeMillis(),
|
||||
val updatedAt: Long = System.currentTimeMillis(),
|
||||
val synced: Boolean = false,
|
||||
val syncTimestamp: Long? = null
|
||||
)
|
||||
|
||||
@Entity(tableName = "payment_terms")
|
||||
data class PaymentTermsEntity(
|
||||
@PrimaryKey
|
||||
val id: Int = 0,
|
||||
val documentId: Int,
|
||||
val billingDate: Long? = null,
|
||||
val paymentDueDate: Long,
|
||||
val paymentMethod: String,
|
||||
val createdAt: Long = System.currentTimeMillis()
|
||||
)
|
||||
|
||||
@Entity(tableName = "sync_logs")
|
||||
data class SyncLogEntity(
|
||||
@PrimaryKey
|
||||
val id: Int = 0,
|
||||
val deviceId: String,
|
||||
val operation: String, // sync, upload, download
|
||||
val documentCount: Int,
|
||||
val status: String, // success, failure
|
||||
val message: String? = null,
|
||||
val timestamp: Long = System.currentTimeMillis()
|
||||
)
|
||||
|
||||
// ========== Data Transfer Objects (DTOs) ==========
|
||||
|
||||
data class CustomerDto(
|
||||
val id: Int,
|
||||
val name: String,
|
||||
val address: String? = null,
|
||||
val phone: String? = null,
|
||||
val email: String? = null
|
||||
)
|
||||
|
||||
data class DocumentItemDto(
|
||||
val productName: String,
|
||||
val quantity: Double,
|
||||
val unitPrice: Double,
|
||||
val subtotal: Double
|
||||
)
|
||||
|
||||
data class PaymentTermsDto(
|
||||
val billingDate: Long? = null,
|
||||
val paymentDueDate: Long,
|
||||
val paymentMethod: String
|
||||
)
|
||||
|
||||
data class DocumentDto(
|
||||
val id: Int = 0,
|
||||
val docType: String,
|
||||
val customerId: Int,
|
||||
val documentDate: Long,
|
||||
val items: List<DocumentItemDto>,
|
||||
val subtotal: Double,
|
||||
val tax: Double,
|
||||
val total: Double,
|
||||
val paymentTerms: PaymentTermsDto,
|
||||
val status: String = "draft",
|
||||
val notes: String? = null
|
||||
)
|
||||
|
||||
data class SyncRequestDto(
|
||||
val deviceId: String,
|
||||
val lastSyncTimestamp: Long? = null,
|
||||
val documents: List<DocumentDto>
|
||||
)
|
||||
|
||||
data class SyncResponseDto(
|
||||
val status: String,
|
||||
val message: String,
|
||||
val syncedDocuments: Int,
|
||||
val newDocuments: List<Map<String, Any>>? = null
|
||||
)
|
||||
|
||||
// ========== UI State Models ==========
|
||||
|
||||
data class DocumentUIState(
|
||||
val id: Int = 0,
|
||||
val docType: String = "quotation",
|
||||
val customer: CustomerDto? = null,
|
||||
val customerId: Int = 0,
|
||||
val documentDate: Long = System.currentTimeMillis(),
|
||||
val items: List<DocumentItemDto> = emptyList(),
|
||||
val subtotal: Double = 0.0,
|
||||
val tax: Double = 0.0,
|
||||
val total: Double = 0.0,
|
||||
val billingDate: Long? = null,
|
||||
val paymentDueDate: Long = System.currentTimeMillis(),
|
||||
val paymentMethod: String = "bank_transfer",
|
||||
val status: String = "draft",
|
||||
val notes: String = "",
|
||||
val isSaving: Boolean = false,
|
||||
val isLoading: Boolean = false,
|
||||
val errorMessage: String? = null,
|
||||
val showPaymentDatePicker: Boolean = false
|
||||
)
|
||||
|
||||
data class DocumentListUIState(
|
||||
val documents: List<DocumentEntity> = emptyList(),
|
||||
val isLoading: Boolean = false,
|
||||
val errorMessage: String? = null,
|
||||
val filter: String = "all" // all, quotation, delivery, invoice, receipt
|
||||
)
|
||||
|
||||
data class SyncUIState(
|
||||
val isSyncing: Boolean = false,
|
||||
val syncProgress: Int = 0,
|
||||
val lastSyncTime: Long? = null,
|
||||
val syncedCount: Int = 0,
|
||||
val totalCount: Int = 0,
|
||||
val errorMessage: String? = null,
|
||||
val status: String = "ready"
|
||||
)
|
||||
|
||||
// ========== Payment Term Patterns ==========
|
||||
enum class PaymentPattern(val displayName: String, val days: Int? = null) {
|
||||
IMMEDIATE("即支払い", 0),
|
||||
END_OF_MONTH("末締め翌月末", null),
|
||||
THIRTY_DAYS("30日後", 30),
|
||||
SIXTY_DAYS("60日後", 60),
|
||||
CUSTOM("カスタム", null)
|
||||
}
|
||||
390
claude/Android_PdfGenerator.kt
Normal file
390
claude/Android_PdfGenerator.kt
Normal file
|
|
@ -0,0 +1,390 @@
|
|||
// app/src/main/java/com/example/mobilepos/util/PdfGenerator.kt
|
||||
|
||||
package com.example.mobilepos.util
|
||||
|
||||
import android.content.Context
|
||||
import android.graphics.pdf.PdfDocument
|
||||
import android.graphics.Canvas
|
||||
import android.graphics.Paint
|
||||
import android.graphics.Color
|
||||
import android.graphics.Typeface
|
||||
import java.io.File
|
||||
import java.io.FileOutputStream
|
||||
import java.text.SimpleDateFormat
|
||||
import java.util.*
|
||||
import com.example.mobilepos.data.models.*
|
||||
import com.google.gson.Gson
|
||||
|
||||
object PdfGenerator {
|
||||
|
||||
private const val PAGE_WIDTH = 595 // A4幅（ポイント）
|
||||
private const val PAGE_HEIGHT = 842 // A4高さ（ポイント）
|
||||
private const val MARGIN = 40
|
||||
private const val CONTENT_WIDTH = PAGE_WIDTH - (MARGIN * 2)
|
||||
|
||||
fun generateQuotationPdf(
|
||||
context: Context,
|
||||
document: DocumentEntity,
|
||||
customer: CustomerEntity,
|
||||
fileName: String = "quotation_${document.id}.pdf"
|
||||
): File? {
|
||||
return try {
|
||||
val pdfDocument = PdfDocument()
|
||||
var pageHeight = PAGE_HEIGHT
|
||||
var yPosition = MARGIN
|
||||
|
||||
val pageInfo = PdfDocument.PageInfo.Builder(PAGE_WIDTH, pageHeight, 1).create()
|
||||
var page = pdfDocument.startPage(pageInfo)
|
||||
var canvas = page.canvas
|
||||
|
||||
// ヘッダー
|
||||
yPosition = drawHeader(canvas, yPosition, "見積書")
|
||||
yPosition += 20
|
||||
|
||||
// 会社情報（左上）
|
||||
yPosition = drawCompanyInfo(canvas, yPosition)
|
||||
yPosition += 20
|
||||
|
||||
// 見積情報
|
||||
canvas.drawText("見積日：${formatDate(document.documentDate)}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 20
|
||||
canvas.drawText("見積番号：QT-${document.id.toString().padStart(6, '0')}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 30
|
||||
|
||||
// 顧客情報
|
||||
yPosition = drawCustomerInfo(canvas, yPosition, customer)
|
||||
yPosition += 20
|
||||
|
||||
// 区切り線
|
||||
canvas.drawLine(MARGIN.toFloat(), yPosition.toFloat(), (PAGE_WIDTH - MARGIN).toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 10
|
||||
|
||||
// 商品テーブルヘッダー
|
||||
yPosition = drawTableHeader(canvas, yPosition)
|
||||
yPosition += 5
|
||||
|
||||
// 商品行
|
||||
val items = parseDocumentItems(document.items)
|
||||
for (item in items) {
|
||||
if (yPosition > PAGE_HEIGHT - 100) {
|
||||
// 新しいページ
|
||||
pdfDocument.finishPage(page)
|
||||
val newPageInfo = PdfDocument.PageInfo.Builder(PAGE_WIDTH, pageHeight, pdfDocument.pages.size + 1).create()
|
||||
page = pdfDocument.startPage(newPageInfo)
|
||||
canvas = page.canvas
|
||||
yPosition = MARGIN
|
||||
}
|
||||
yPosition = drawTableRow(canvas, yPosition, item)
|
||||
}
|
||||
|
||||
yPosition += 10
|
||||
canvas.drawLine(MARGIN.toFloat(), yPosition.toFloat(), (PAGE_WIDTH - MARGIN).toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 15
|
||||
|
||||
// 合計
|
||||
yPosition = drawTotals(canvas, yPosition, document)
|
||||
yPosition += 20
|
||||
|
||||
// 支払期限
|
||||
val dueDate = formatDate(document.paymentDueDate)
|
||||
canvas.drawText("お支払い期限：$dueDate", MARGIN.toFloat(), yPosition.toFloat(), getPaint(bold = true))
|
||||
yPosition += 20
|
||||
canvas.drawText("お支払い方法：${document.paymentMethod ?: "銀行振込"}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
|
||||
// 備考
|
||||
if (!document.notes.isNullOrEmpty()) {
|
||||
yPosition += 20
|
||||
canvas.drawText("備考：", MARGIN.toFloat(), yPosition.toFloat(), getPaint(bold = true))
|
||||
yPosition += 15
|
||||
val noteLines = document.notes!!.split("\n")
|
||||
for (line in noteLines) {
|
||||
canvas.drawText(line, MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 15
|
||||
}
|
||||
}
|
||||
|
||||
pdfDocument.finishPage(page)
|
||||
|
||||
// ファイル保存
|
||||
val outputFile = File(context.getExternalFilesDir(null), fileName)
|
||||
val fos = FileOutputStream(outputFile)
|
||||
pdfDocument.writeTo(fos)
|
||||
fos.close()
|
||||
pdfDocument.close()
|
||||
|
||||
outputFile
|
||||
} catch (e: Exception) {
|
||||
e.printStackTrace()
|
||||
null
|
||||
}
|
||||
}
|
||||
|
||||
fun generateInvoicePdf(
|
||||
context: Context,
|
||||
document: DocumentEntity,
|
||||
customer: CustomerEntity,
|
||||
fileName: String = "invoice_${document.id}.pdf"
|
||||
): File? {
|
||||
return try {
|
||||
val pdfDocument = PdfDocument()
|
||||
var pageHeight = PAGE_HEIGHT
|
||||
var yPosition = MARGIN
|
||||
|
||||
val pageInfo = PdfDocument.PageInfo.Builder(PAGE_WIDTH, pageHeight, 1).create()
|
||||
var page = pdfDocument.startPage(pageInfo)
|
||||
var canvas = page.canvas
|
||||
|
||||
// ヘッダー
|
||||
yPosition = drawHeader(canvas, yPosition, "請求書")
|
||||
yPosition += 20
|
||||
|
||||
// 会社情報
|
||||
yPosition = drawCompanyInfo(canvas, yPosition)
|
||||
yPosition += 20
|
||||
|
||||
// 請求情報
|
||||
canvas.drawText("請求日：${formatDate(document.documentDate)}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 20
|
||||
canvas.drawText("請求番号：INV-${document.id.toString().padStart(6, '0')}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 30
|
||||
|
||||
// 顧客情報
|
||||
yPosition = drawCustomerInfo(canvas, yPosition, customer)
|
||||
yPosition += 20
|
||||
|
||||
// 区切り線
|
||||
canvas.drawLine(MARGIN.toFloat(), yPosition.toFloat(), (PAGE_WIDTH - MARGIN).toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 10
|
||||
|
||||
// 商品テーブル
|
||||
yPosition = drawTableHeader(canvas, yPosition)
|
||||
yPosition += 5
|
||||
|
||||
val items = parseDocumentItems(document.items)
|
||||
for (item in items) {
|
||||
if (yPosition > PAGE_HEIGHT - 150) {
|
||||
pdfDocument.finishPage(page)
|
||||
val newPageInfo = PdfDocument.PageInfo.Builder(PAGE_WIDTH, pageHeight, pdfDocument.pages.size + 1).create()
|
||||
page = pdfDocument.startPage(newPageInfo)
|
||||
canvas = page.canvas
|
||||
yPosition = MARGIN
|
||||
}
|
||||
yPosition = drawTableRow(canvas, yPosition, item)
|
||||
}
|
||||
|
||||
yPosition += 10
|
||||
canvas.drawLine(MARGIN.toFloat(), yPosition.toFloat(), (PAGE_WIDTH - MARGIN).toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 15
|
||||
|
||||
// 合計
|
||||
yPosition = drawTotals(canvas, yPosition, document)
|
||||
yPosition += 20
|
||||
|
||||
// 支払期限・方法
|
||||
val dueDate = formatDate(document.paymentDueDate)
|
||||
canvas.drawText("お支払い期限：$dueDate", MARGIN.toFloat(), yPosition.toFloat(), getPaint(bold = true))
|
||||
yPosition += 20
|
||||
canvas.drawText("お支払い方法：${document.paymentMethod ?: "銀行振込"}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
|
||||
pdfDocument.finishPage(page)
|
||||
|
||||
val outputFile = File(context.getExternalFilesDir(null), fileName)
|
||||
val fos = FileOutputStream(outputFile)
|
||||
pdfDocument.writeTo(fos)
|
||||
fos.close()
|
||||
pdfDocument.close()
|
||||
|
||||
outputFile
|
||||
} catch (e: Exception) {
|
||||
e.printStackTrace()
|
||||
null
|
||||
}
|
||||
}
|
||||
|
||||
fun generateReceiptPdf(
|
||||
context: Context,
|
||||
document: DocumentEntity,
|
||||
customer: CustomerEntity,
|
||||
fileName: String = "receipt_${document.id}.pdf"
|
||||
): File? {
|
||||
return try {
|
||||
val pdfDocument = PdfDocument()
|
||||
var pageHeight = PAGE_HEIGHT
|
||||
var yPosition = MARGIN
|
||||
|
||||
val pageInfo = PdfDocument.PageInfo.Builder(PAGE_WIDTH, pageHeight, 1).create()
|
||||
val page = pdfDocument.startPage(pageInfo)
|
||||
val canvas = page.canvas
|
||||
|
||||
// ヘッダー
|
||||
yPosition = drawHeader(canvas, yPosition, "領収書")
|
||||
yPosition += 20
|
||||
|
||||
// 会社情報
|
||||
yPosition = drawCompanyInfo(canvas, yPosition)
|
||||
yPosition += 20
|
||||
|
||||
// 領収情報
|
||||
canvas.drawText("領収日：${formatDate(document.documentDate)}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 20
|
||||
canvas.drawText("領収番号：RCP-${document.id.toString().padStart(6, '0')}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 30
|
||||
|
||||
// 顧客情報
|
||||
yPosition = drawCustomerInfo(canvas, yPosition, customer)
|
||||
yPosition += 20
|
||||
|
||||
// 金額
|
||||
canvas.drawText("お振込金額", MARGIN.toFloat(), yPosition.toFloat(), getPaint(bold = true))
|
||||
yPosition += 20
|
||||
|
||||
val totalText = "¥${String.format("%,d", document.total.toLong())}"
|
||||
val totalPaint = getPaint(bold = true, size = 36f)
|
||||
canvas.drawText(totalText, MARGIN.toFloat(), yPosition.toFloat(), totalPaint)
|
||||
yPosition += 40
|
||||
|
||||
// 摘要
|
||||
canvas.drawText("摘要：商品・サービス提供代金", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
yPosition += 20
|
||||
|
||||
// 支払い日
|
||||
if (document.paidDate != null) {
|
||||
canvas.drawText("お支払い日：${formatDate(document.paidDate!!)}", MARGIN.toFloat(), yPosition.toFloat(), getPaint())
|
||||
}
|
||||
|
||||
pdfDocument.finishPage(page)
|
||||
|
||||
val outputFile = File(context.getExternalFilesDir(null), fileName)
|
||||
val fos = FileOutputStream(outputFile)
|
||||
pdfDocument.writeTo(fos)
|
||||
fos.close()
|
||||
pdfDocument.close()
|
||||
|
||||
outputFile
|
||||
} catch (e: Exception) {
|
||||
e.printStackTrace()
|
||||
null
|
||||
}
|
||||
}
|
||||
|
||||
// ========== ヘルパー関数 ==========
|
||||
|
||||
private fun drawHeader(canvas: Canvas, yPosition: Int, title: String): Int {
|
||||
val paint = getPaint(bold = true, size = 28f)
|
||||
canvas.drawText(title, MARGIN.toFloat(), (yPosition + 25).toFloat(), paint)
|
||||
return yPosition + 40
|
||||
}
|
||||
|
||||
private fun drawCompanyInfo(canvas: Canvas, yPosition: Int): Int {
|
||||
val paint = getPaint(size = 10f)
|
||||
var y = yPosition
|
||||
canvas.drawText("株式会社 ○○○○", MARGIN.toFloat(), y.toFloat(), paint)
|
||||
y += 12
|
||||
canvas.drawText("住所：〒000-0000 ○○県○○市○○町1-1", MARGIN.toFloat(), y.toFloat(), paint)
|
||||
y += 12
|
||||
canvas.drawText("電話：09X-XXXX-XXXX", MARGIN.toFloat(), y.toFloat(), paint)
|
||||
y += 12
|
||||
canvas.drawText("メール：info@example.com", MARGIN.toFloat(), y.toFloat(), paint)
|
||||
return y
|
||||
}
|
||||
|
||||
private fun drawCustomerInfo(canvas: Canvas, yPosition: Int, customer: CustomerEntity): Int {
|
||||
val paint = getPaint()
|
||||
var y = yPosition
|
||||
canvas.drawText("ご購入者様", MARGIN.toFloat(), y.toFloat(), paint)
|
||||
y += 20
|
||||
canvas.drawText(customer.name, MARGIN.toFloat(), y.toFloat(), paint)
|
||||
y += 15
|
||||
if (!customer.address.isNullOrEmpty()) {
|
||||
canvas.drawText("住所：${customer.address}", MARGIN.toFloat(), y.toFloat(), paint)
|
||||
y += 15
|
||||
}
|
||||
if (!customer.phone.isNullOrEmpty()) {
|
||||
canvas.drawText("電話：${customer.phone}", MARGIN.toFloat(), y.toFloat(), paint)
|
||||
y += 15
|
||||
}
|
||||
return y
|
||||
}
|
||||
|
||||
private fun drawTableHeader(canvas: Canvas, yPosition: Int): Int {
|
||||
val paint = getPaint(bold = true)
|
||||
val smallPaint = getPaint(size = 10f)
|
||||
|
||||
var x = MARGIN
|
||||
canvas.drawText("品目", x.toFloat(), yPosition.toFloat(), paint)
|
||||
x += 200
|
||||
canvas.drawText("数量", x.toFloat(), yPosition.toFloat(), paint)
|
||||
x += 80
|
||||
canvas.drawText("単価", x.toFloat(), yPosition.toFloat(), paint)
|
||||
x += 80
|
||||
canvas.drawText("小計", x.toFloat(), yPosition.toFloat(), paint)
|
||||
|
||||
return yPosition + 15
|
||||
}
|
||||
|
||||
private fun drawTableRow(canvas: Canvas, yPosition: Int, item: DocumentItemDto): Int {
|
||||
val paint = getPaint(size = 11f)
|
||||
|
||||
val productText = item.productName
|
||||
val quantityText = String.format("%.2f", item.quantity)
|
||||
val unitPriceText = "¥${String.format("%,d", item.unitPrice.toLong())}"
|
||||
val subtotalText = "¥${String.format("%,d", item.subtotal.toLong())}"
|
||||
|
||||
var x = MARGIN
|
||||
canvas.drawText(productText, x.toFloat(), yPosition.toFloat(), paint)
|
||||
x += 200
|
||||
canvas.drawText(quantityText, x.toFloat(), yPosition.toFloat(), paint)
|
||||
x += 80
|
||||
canvas.drawText(unitPriceText, x.toFloat(), yPosition.toFloat(), paint)
|
||||
x += 80
|
||||
canvas.drawText(subtotalText, x.toFloat(), yPosition.toFloat(), paint)
|
||||
|
||||
return yPosition + 15
|
||||
}
|
||||
|
||||
private fun drawTotals(canvas: Canvas, yPosition: Int, document: DocumentEntity): Int {
|
||||
val paint = getPaint()
|
||||
val boldPaint = getPaint(bold = true)
|
||||
|
||||
var y = yPosition
|
||||
val rightX = (PAGE_WIDTH - MARGIN - 100).toFloat()
|
||||
|
||||
// 小計
|
||||
canvas.drawText("小計：", rightX - 80, y.toFloat(), paint)
|
||||
canvas.drawText("¥${String.format("%,d", document.subtotal.toLong())}", rightX.toFloat(), y.toFloat(), paint)
|
||||
y += 20
|
||||
|
||||
// 税金
|
||||
canvas.drawText("税金：", rightX - 80, y.toFloat(), paint)
|
||||
canvas.drawText("¥${String.format("%,d", document.tax.toLong())}", rightX.toFloat(), y.toFloat(), paint)
|
||||
y += 20
|
||||
|
||||
// 合計
|
||||
canvas.drawText("合計：", rightX - 80, y.toFloat(), boldPaint)
|
||||
canvas.drawText("¥${String.format("%,d", document.total.toLong())}", rightX.toFloat(), y.toFloat(), boldPaint)
|
||||
|
||||
return y + 20
|
||||
}
|
||||
|
||||
private fun getPaint(bold: Boolean = false, size: Float = 12f): Paint {
|
||||
return Paint().apply {
|
||||
this.typeface = if (bold) Typeface.create(Typeface.DEFAULT, Typeface.BOLD) else Typeface.DEFAULT
|
||||
this.textSize = size
|
||||
this.color = Color.BLACK
|
||||
}
|
||||
}
|
||||
|
||||
private fun formatDate(timestamp: Long): String {
|
||||
val sdf = SimpleDateFormat("yyyy年MM月dd日", Locale.JAPAN)
|
||||
return sdf.format(Date(timestamp))
|
||||
}
|
||||
|
||||
private fun parseDocumentItems(itemsJson: String): List<DocumentItemDto> {
|
||||
return try {
|
||||
val gson = Gson()
|
||||
gson.fromJson(itemsJson, Array<DocumentItemDto>::class.java).toList()
|
||||
} catch (e: Exception) {
|
||||
emptyList()
|
||||
}
|
||||
}
|
||||
}
|
||||
414
claude/README.md
Normal file
414
claude/README.md
Normal file
|
|
@ -0,0 +1,414 @@
|
|||
# モバイルPOS・見積/納品/請求/領収書システム
|
||||
|
||||
## 概要
|
||||
|
||||
Proxmox CT上で動作するオフラインファーストのスマートフォンアプリケーション。
|
||||
営業現場で完全スタンドアロンで見積・納品・請求・領収書を作成・管理し、
|
||||
ネットワーク接続時にOdooと同期します。
|
||||
|
||||
## アーキテクチャ
|
||||
|
||||
```
|
||||
┌─────────────────┐
|
||||
│ Android App │ ← スマホ（完全オフライン対応）
|
||||
│ SQLite DB │
|
||||
│ PDF生成 │
|
||||
└────────┬────────┘
|
||||
│ (ネットワーク接続時)
|
||||
│
|
||||
┌────▼─────────────────────────┐
|
||||
│ REST API コンテナ │
|
||||
│ (Python FastAPI) │
|
||||
│ - 同期エンドポイント │
|
||||
│ - Odoo連携 │
|
||||
└────┬────────────────┬─────────┘
|
||||
│ │
|
||||
┌────▼──────┐ ┌─────▼─────┐
|
||||
│ PostgreSQL│ │ Odoo │
|
||||
│ DB │ │ (Sales) │
|
||||
└───────────┘ └───────────┘
|
||||
```
|
||||
|
||||
## ディレクトリ構成
|
||||
|
||||
```
|
||||
project_root/
|
||||
├── docker-compose.yml # Odoo + API + DB
|
||||
├── api/
|
||||
│ ├── main.py # FastAPI メイン
|
||||
│ ├── requirements.txt
|
||||
│ └── Dockerfile
|
||||
├── addons/ # Odooカスタムモジュール
|
||||
├── scheduler/ # 定期同期スクリプト
|
||||
└── android/
|
||||
├── Models.kt # データモデル
|
||||
├── DAO.kt # Room DAO
|
||||
├── Database.kt # Room DB
|
||||
├── ApiService.kt # Retrofit API
|
||||
└── PdfGenerator.kt # PDF生成
|
||||
```
|
||||
|
||||
## セットアップ手順
|
||||
|
||||
### 1. Docker環境構築（Proxmox CT）
|
||||
|
||||
```bash
|
||||
# リポジトリクローン
|
||||
git clone <your-repo-url>
|
||||
cd project_root
|
||||
|
||||
# 環境変数設定
|
||||
cp .env.example .env
|
||||
# .envを編集（API_SECRET_KEY等）
|
||||
|
||||
# コンテナ起動
|
||||
docker-compose up -d
|
||||
|
||||
# ログ確認
|
||||
docker-compose logs -f api
|
||||
docker-compose logs -f odoo
|
||||
```
|
||||
|
||||
### 2. Odooの初期セットアップ
|
||||
|
||||
```bash
|
||||
# Odooにアクセス
|
||||
# http://localhost:8069
|
||||
|
||||
# 以下のモジュールを有効化
|
||||
# - Sales (見積・受注管理)
|
||||
# - Invoicing (請求・領収書)
|
||||
# - Accounting (会計・売掛金)
|
||||
|
||||
# API認証設定
|
||||
# Admin > 設定 > API キーを生成
|
||||
```
|
||||
|
||||
### 3. REST APIの初期化
|
||||
|
||||
```bash
|
||||
# DB テーブル作成
|
||||
docker-compose exec api python -c "from main import Base, engine; Base.metadata.create_all(bind=engine)"
|
||||
|
||||
# テスト
|
||||
curl -X GET http://localhost:8000/api/v1/health \
|
||||
-H "X-API-Key: your_secret_key"
|
||||
```
|
||||
|
||||
### 4. Androidアプリ開発
|
||||
|
||||
#### 依存パッケージ (build.gradle)
|
||||
|
||||
```gradle
|
||||
dependencies {
|
||||
// Room
|
||||
implementation "androidx.room:room-runtime:2.6.0"
|
||||
implementation "androidx.room:room-ktx:2.6.0"
|
||||
kapt "androidx.room:room-compiler:2.6.0"
|
||||
|
||||
// Retrofit
|
||||
implementation "com.squareup.retrofit2:retrofit:2.9.0"
|
||||
implementation "com.squareup.retrofit2:converter-gson:2.9.0"
|
||||
implementation "com.squareup.okhttp3:logging-interceptor:4.11.0"
|
||||
|
||||
// Coroutines
|
||||
implementation "org.jetbrains.kotlinx:kotlinx-coroutines-android:1.7.3"
|
||||
|
||||
// Jetpack Compose
|
||||
implementation "androidx.compose.ui:ui:1.6.0"
|
||||
implementation "androidx.compose.material3:material3:1.1.0"
|
||||
|
||||
// PDF (iText or Apache POI)
|
||||
implementation "com.itextpdf:itext-core:8.0.0"
|
||||
|
||||
// Gson
|
||||
implementation "com.google.code.gson:gson:2.10.1"
|
||||
}
|
||||
```
|
||||
|
||||
#### AndroidManifest.xml の設定
|
||||
|
||||
```xml
|
||||
<!-- パーミッション -->
|
||||
<uses-permission android:name="android.permission.INTERNET" />
|
||||
<uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" />
|
||||
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />
|
||||
```
|
||||
|
||||
#### build.gradle 設定
|
||||
|
||||
```gradle
|
||||
android {
|
||||
compileSdk 34
|
||||
|
||||
defaultConfig {
|
||||
applicationId "com.example.mobilepos"
|
||||
minSdk 26
|
||||
targetSdk 34
|
||||
}
|
||||
|
||||
buildFeatures {
|
||||
compose = true
|
||||
}
|
||||
|
||||
composeOptions {
|
||||
kotlinCompilerExtensionVersion = "1.5.0"
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
## API エンドポイント
|
||||
|
||||
### 同期
|
||||
|
||||
**POST** `/api/v1/sync`
|
||||
```bash
|
||||
curl -X POST http://localhost:8000/api/v1/sync \
|
||||
-H "X-API-Key: secret_key" \
|
||||
-H "Content-Type: application/json" \
|
||||
-d '{
|
||||
"device_id": "device_001",
|
||||
"last_sync_timestamp": null,
|
||||
"documents": [
|
||||
{
|
||||
"doc_type": "quotation",
|
||||
"customer_id": 1,
|
||||
"document_date": "2026-01-31T10:00:00",
|
||||
"items": [
|
||||
{
|
||||
"product_name": "商品A",
|
||||
"quantity": 10,
|
||||
"unit_price": 1000,
|
||||
"subtotal": 10000
|
||||
}
|
||||
],
|
||||
"subtotal": 10000,
|
||||
"tax": 1000,
|
||||
"total": 11000,
|
||||
"payment_terms": {
|
||||
"billing_date": "2026-01-31",
|
||||
"payment_due_date": "2026-02-28",
|
||||
"payment_method": "bank_transfer"
|
||||
}
|
||||
}
|
||||
]
|
||||
}'
|
||||
```
|
||||
|
||||
### 顧客一覧
|
||||
|
||||
**GET** `/api/v1/customers`
|
||||
```bash
|
||||
curl http://localhost:8000/api/v1/customers \
|
||||
-H "X-API-Key: secret_key"
|
||||
```
|
||||
|
||||
### ドキュメント取得
|
||||
|
||||
**GET** `/api/v1/documents/{id}`
|
||||
|
||||
### 領収書自動生成
|
||||
|
||||
**POST** `/api/v1/receipts/{invoice_id}`
|
||||
```bash
|
||||
# 入金から1週間以内の請求書から領収書を生成
|
||||
curl -X POST http://localhost:8000/api/v1/receipts/1 \
|
||||
-H "X-API-Key: secret_key"
|
||||
```
|
||||
|
||||
## Android実装ガイド
|
||||
|
||||
### 1. データベース初期化
|
||||
|
||||
```kotlin
|
||||
val db = AppDatabase.getInstance(context)
|
||||
val documentDao = db.documentDao()
|
||||
val customerDao = db.customerDao()
|
||||
```
|
||||
|
||||
### 2. ドキュメント作成・保存
|
||||
|
||||
```kotlin
|
||||
val document = DocumentEntity(
|
||||
docType = "quotation",
|
||||
customerId = 1,
|
||||
documentDate = System.currentTimeMillis(),
|
||||
items = Gson().toJson(listOf(
|
||||
DocumentItemDto("商品A", 10.0, 1000.0, 10000.0)
|
||||
)),
|
||||
subtotal = 10000.0,
|
||||
tax = 1000.0,
|
||||
total = 11000.0,
|
||||
paymentDueDate = calculateDueDate(PaymentPattern.END_OF_MONTH),
|
||||
synced = false
|
||||
)
|
||||
|
||||
documentDao.insertDocument(document)
|
||||
```
|
||||
|
||||
### 3. PDF生成
|
||||
|
||||
```kotlin
|
||||
val file = PdfGenerator.generateQuotationPdf(
|
||||
context = context,
|
||||
document = document,
|
||||
customer = customer,
|
||||
fileName = "quotation_${document.id}.pdf"
|
||||
)
|
||||
|
||||
// ファイル共有
|
||||
val uri = FileProvider.getUriForFile(context, "${context.packageName}.fileprovider", file)
|
||||
val shareIntent = Intent(Intent.ACTION_SEND).apply {
|
||||
type = "application/pdf"
|
||||
putExtra(Intent.EXTRA_STREAM, uri)
|
||||
}
|
||||
startActivity(Intent.createChooser(shareIntent, "PDFを共有"))
|
||||
```
|
||||
|
||||
### 4. 同期処理
|
||||
|
||||
```kotlin
|
||||
suspend fun syncDocuments(context: Context) {
|
||||
val apiKey = "your_secret_key"
|
||||
val baseUrl = "http://your_api_server:8000"
|
||||
val apiService = ApiClient.getSyncApiService(baseUrl)
|
||||
|
||||
val db = AppDatabase.getInstance(context)
|
||||
val unsyncedDocs = db.documentDao().getUnsyncedDocuments()
|
||||
|
||||
val request = SyncRequestDto(
|
||||
deviceId = getDeviceId(),
|
||||
documents = unsyncedDocs.map { convertToDto(it) }
|
||||
)
|
||||
|
||||
try {
|
||||
val response = apiService.syncDocuments(apiKey, request)
|
||||
if (response.isSuccessful && response.body()?.status == "success") {
|
||||
response.body()?.newDocuments?.forEach { doc ->
|
||||
db.documentDao().markDocumentAsSynced(doc["local_id"] as Int, System.currentTimeMillis())
|
||||
}
|
||||
}
|
||||
} catch (e: Exception) {
|
||||
Log.e("Sync", "Error: ${e.message}")
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
### 5. 支払期限の計算
|
||||
|
||||
```kotlin
|
||||
fun calculatePaymentDueDate(billingDate: Long, pattern: PaymentPattern): Long {
|
||||
val calendar = Calendar.getInstance().apply {
|
||||
timeInMillis = billingDate
|
||||
}
|
||||
|
||||
return when (pattern) {
|
||||
PaymentPattern.IMMEDIATE -> calendar.timeInMillis
|
||||
PaymentPattern.END_OF_MONTH -> {
|
||||
calendar.set(Calendar.DAY_OF_MONTH, 1)
|
||||
calendar.add(Calendar.MONTH, 1)
|
||||
calendar.add(Calendar.DAY_OF_MONTH, -1)
|
||||
calendar.timeInMillis
|
||||
}
|
||||
PaymentPattern.THIRTY_DAYS -> {
|
||||
calendar.add(Calendar.DAY_OF_MONTH, 30)
|
||||
calendar.timeInMillis
|
||||
}
|
||||
PaymentPattern.SIXTY_DAYS -> {
|
||||
calendar.add(Calendar.DAY_OF_MONTH, 60)
|
||||
calendar.timeInMillis
|
||||
}
|
||||
else -> calendar.timeInMillis
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
## 同期フロー
|
||||
|
||||
### オフライン時
|
||||
1. スマホアプリで見積/納品/請求/領収書を作成
|
||||
2. SQLiteに自動保存
|
||||
3. PDF生成・送信（メール等）
|
||||
|
||||
### ネットワーク接続時
|
||||
1. 未同期ドキュメントを検出
|
||||
2. REST APIに送信
|
||||
3. API が Odoo に登録
|
||||
4. 同期完了後、ローカルの synced フラグを更新
|
||||
5. Odoo で売掛金管理・レポート生成
|
||||
|
||||
## 支払条件パターン
|
||||
|
||||
| パターン | 説明 | 計算方式 |
|
||||
|---------|------|--------|
|
||||
| 即支払い | 当日支払い | 請求日 |
|
||||
| 末締め翌月末 | 末締めで翌月末払い | 翌月末日 |
|
||||
| 30日後 | 請求日から30日後 | 請求日 + 30日 |
|
||||
| 60日後 | 請求日から60日後 | 請求日 + 60日 |
|
||||
| カスタム | 任意設定 | ユーザーが指定 |
|
||||
|
||||
## セキュリティ
|
||||
|
||||
- API キーは環境変数で管理
|
||||
- HTTPS通信を推奨（本番環境）
|
||||
- トークン認証で API アクセス制限
|
||||
- Odoo への認証も環境変数化
|
||||
|
||||
## トラブルシューティング
|
||||
|
||||
### API接続エラー
|
||||
```bash
|
||||
# ヘルスチェック
|
||||
curl http://localhost:8000/api/v1/health -H "X-API-Key: your_key"
|
||||
|
||||
# ログ確認
|
||||
docker-compose logs api
|
||||
```
|
||||
|
||||
### Odoo連携エラー
|
||||
```bash
|
||||
# Odooログ
|
||||
docker-compose logs odoo
|
||||
|
||||
# DBテーブル確認
|
||||
docker-compose exec postgres psql -U odoo -d odoo -c "\dt"
|
||||
```
|
||||
|
||||
### Android PDF生成エラー
|
||||
- ストレージパーミッション確認
|
||||
- 外部ストレージ空き容量確認
|
||||
- iText/Apache POI の対応バージョン確認
|
||||
|
||||
## 今後の実装予定
|
||||
|
||||
- [ ] Odoo REST API 直接連携
|
||||
- [ ] Nextcloud WebDAV バックアップ統合
|
||||
- [ ] 複数ユーザー・デバイス同期
|
||||
- [ ] オフライン時の競合解決
|
||||
- [ ] 売掛金ダッシュボード
|
||||
- [ ] Web UI（PCから Odoo 管理用）
|
||||
- [ ] カスタム領収書テンプレート
|
||||
- [ ] 電子署名対応
|
||||
|
||||
## 開発者向け情報
|
||||
|
||||
### REST API テスト
|
||||
```bash
|
||||
# FastAPI ドキュメント
|
||||
http://localhost:8000/docs
|
||||
```
|
||||
|
||||
### DB マイグレーション
|
||||
```bash
|
||||
# 新しいテーブル追加時
|
||||
# Android: Migrations クラスを追加
|
||||
# API: SQLAlchemy モデルを追加 → DB再作成
|
||||
```
|
||||
|
||||
## ライセンス
|
||||
|
||||
MIT License
|
||||
|
||||
## サポート
|
||||
|
||||
問題報告は Issues で。
|
||||
374
claude/api_main.py
Normal file
374
claude/api_main.py
Normal file
|
|
@ -0,0 +1,374 @@
|
|||
"""
|
||||
Mobile Sync API - Odoo連携
|
||||
見積/納品/請求/領収書のモバイル同期エンドポイント
|
||||
"""
|
||||
|
||||
from fastapi import FastAPI, HTTPException, Depends, Header, Request
|
||||
from fastapi.responses import JSONResponse
|
||||
from pydantic import BaseModel
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Optional, List
|
||||
import sqlalchemy as sa
|
||||
from sqlalchemy import create_engine, Column, Integer, String, DateTime, JSON, Numeric, Boolean, ForeignKey
|
||||
from sqlalchemy.orm import sessionmaker, declarative_base, Session
|
||||
from sqlalchemy.ext.declarative import declarative_base
|
||||
import os
|
||||
import json
|
||||
import requests
|
||||
from dateutil.relativedelta import relativedelta
|
||||
import logging
|
||||
|
||||
# ========== 設定 ==========
|
||||
DATABASE_URL = os.getenv("DATABASE_URL", "postgresql://odoo:odoo_secure_password@localhost:5432/odoo")
|
||||
ODOO_URL = os.getenv("ODOO_URL", "http://localhost:8069")
|
||||
ODOO_USER = os.getenv("ODOO_USER", "admin")
|
||||
ODOO_PASSWORD = os.getenv("ODOO_PASSWORD", "admin")
|
||||
API_SECRET_KEY = os.getenv("API_SECRET_KEY", "your_secret_key_here")
|
||||
|
||||
# ========== ログ設定 ==========
|
||||
logging.basicConfig(level=logging.INFO)
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
# ========== DB設定 ==========
|
||||
engine = create_engine(DATABASE_URL, echo=False)
|
||||
SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
|
||||
Base = declarative_base()
|
||||
|
||||
# ========== SQLAlchemy モデル ==========
|
||||
class Customer(Base):
|
||||
__tablename__ = "mobile_customers"
|
||||
|
||||
id = Column(Integer, primary_key=True)
|
||||
odoo_customer_id = Column(Integer, unique=True, nullable=True)
|
||||
name = Column(String(255))
|
||||
address = Column(String(500), nullable=True)
|
||||
phone = Column(String(20), nullable=True)
|
||||
email = Column(String(255), nullable=True)
|
||||
created_at = Column(DateTime, default=datetime.utcnow)
|
||||
updated_at = Column(DateTime, default=datetime.utcnow, onupdate=datetime.utcnow)
|
||||
synced = Column(Boolean, default=False)
|
||||
|
||||
class Document(Base):
|
||||
__tablename__ = "mobile_documents"
|
||||
|
||||
id = Column(Integer, primary_key=True)
|
||||
odoo_id = Column(Integer, unique=True, nullable=True)
|
||||
doc_type = Column(String(50)) # quotation, delivery, invoice, receipt
|
||||
customer_id = Column(Integer, ForeignKey("mobile_customers.id"))
|
||||
document_date = Column(DateTime)
|
||||
items = Column(JSON) # [{product_name, quantity, unit_price, subtotal}, ...]
|
||||
subtotal = Column(Numeric(12, 2))
|
||||
tax = Column(Numeric(12, 2))
|
||||
total = Column(Numeric(12, 2))
|
||||
status = Column(String(50)) # draft, sent, confirmed, paid, etc.
|
||||
billing_date = Column(DateTime, nullable=True)
|
||||
payment_due_date = Column(DateTime, nullable=True)
|
||||
payment_method = Column(String(100), nullable=True)
|
||||
paid_date = Column(DateTime, nullable=True)
|
||||
notes = Column(String(1000), nullable=True)
|
||||
created_at = Column(DateTime, default=datetime.utcnow)
|
||||
updated_at = Column(DateTime, default=datetime.utcnow, onupdate=datetime.utcnow)
|
||||
synced = Column(Boolean, default=False)
|
||||
sync_timestamp = Column(DateTime, nullable=True)
|
||||
|
||||
class SyncLog(Base):
|
||||
__tablename__ = "sync_logs"
|
||||
|
||||
id = Column(Integer, primary_key=True)
|
||||
device_id = Column(String(255))
|
||||
operation = Column(String(50)) # sync, upload, download
|
||||
document_count = Column(Integer)
|
||||
status = Column(String(50)) # success, failure
|
||||
message = Column(String(500), nullable=True)
|
||||
timestamp = Column(DateTime, default=datetime.utcnow)
|
||||
|
||||
# ========== Pydantic モデル ==========
|
||||
class ItemModel(BaseModel):
|
||||
product_name: str
|
||||
quantity: float
|
||||
unit_price: float
|
||||
subtotal: float
|
||||
|
||||
class PaymentTermsModel(BaseModel):
|
||||
billing_date: Optional[datetime] = None
|
||||
payment_due_date: datetime
|
||||
payment_method: str # bank_transfer, cash, etc.
|
||||
|
||||
class DocumentModel(BaseModel):
|
||||
doc_type: str # quotation, delivery, invoice, receipt
|
||||
customer_id: int
|
||||
document_date: datetime
|
||||
items: List[ItemModel]
|
||||
subtotal: float
|
||||
tax: float
|
||||
total: float
|
||||
payment_terms: PaymentTermsModel
|
||||
status: str = "draft"
|
||||
notes: Optional[str] = None
|
||||
|
||||
class SyncRequest(BaseModel):
|
||||
device_id: str
|
||||
last_sync_timestamp: Optional[datetime] = None
|
||||
documents: List[DocumentModel]
|
||||
|
||||
class SyncResponse(BaseModel):
|
||||
status: str
|
||||
message: str
|
||||
synced_documents: int
|
||||
new_documents: Optional[List[dict]] = None
|
||||
|
||||
# ========== FastAPI アプリ ==========
|
||||
app = FastAPI(title="Mobile Sync API", version="1.0.0")
|
||||
|
||||
# ========== DB セッション依存性 ==========
|
||||
def get_db():
|
||||
db = SessionLocal()
|
||||
try:
|
||||
yield db
|
||||
finally:
|
||||
db.close()
|
||||
|
||||
# ========== 認証 ==========
|
||||
async def verify_api_key(x_api_key: str = Header(None)):
|
||||
if x_api_key != API_SECRET_KEY:
|
||||
raise HTTPException(status_code=401, detail="Invalid API key")
|
||||
return x_api_key
|
||||
|
||||
# ========== ヘルパー関数 ==========
|
||||
def calculate_payment_due_date(billing_date: datetime, pattern: str) -> datetime:
|
||||
"""
|
||||
支払期限を計算
|
||||
patterns:
|
||||
- "immediate": 即支払い（当日）
|
||||
- "end_of_month": 末締め翌月末
|
||||
- "30days": 30日後
|
||||
- "60days": 60日後
|
||||
"""
|
||||
if pattern == "immediate":
|
||||
return billing_date
|
||||
elif pattern == "end_of_month":
|
||||
# 翌月末
|
||||
next_month = billing_date + relativedelta(months=1)
|
||||
return next_month.replace(day=1) - timedelta(days=1)
|
||||
elif pattern == "30days":
|
||||
return billing_date + timedelta(days=30)
|
||||
elif pattern == "60days":
|
||||
return billing_date + timedelta(days=60)
|
||||
else:
|
||||
# デフォルト：30日後
|
||||
return billing_date + timedelta(days=30)
|
||||
|
||||
def sync_to_odoo(db: Session, document: Document) -> dict:
|
||||
"""
|
||||
ドキュメントを Odoo に同期
|
||||
"""
|
||||
try:
|
||||
# Odoo XML-RPC または REST API を使用してデータを送信
|
||||
# ここでは簡略版
|
||||
logger.info(f"Syncing document {document.id} to Odoo")
|
||||
|
||||
# TODO: Odoo API呼び出し
|
||||
# response = odoo_api.create_document(...)
|
||||
|
||||
document.synced = True
|
||||
document.sync_timestamp = datetime.utcnow()
|
||||
db.commit()
|
||||
|
||||
return {"status": "success", "odoo_id": document.odoo_id}
|
||||
except Exception as e:
|
||||
logger.error(f"Error syncing to Odoo: {str(e)}")
|
||||
return {"status": "error", "message": str(e)}
|
||||
|
||||
# ========== エンドポイント ==========
|
||||
|
||||
@app.post("/api/v1/sync", response_model=SyncResponse, dependencies=[Depends(verify_api_key)])
|
||||
async def sync_documents(request: SyncRequest, db: Session = Depends(get_db)):
|
||||
"""
|
||||
モバイルアプリからのドキュメント同期
|
||||
"""
|
||||
try:
|
||||
synced_count = 0
|
||||
new_documents = []
|
||||
|
||||
for doc in request.documents:
|
||||
# 顧客を確認
|
||||
customer = db.query(Customer).filter(Customer.id == doc.customer_id).first()
|
||||
if not customer:
|
||||
logger.warning(f"Customer {doc.customer_id} not found")
|
||||
continue
|
||||
|
||||
# ドキュメント作成
|
||||
db_doc = Document(
|
||||
doc_type=doc.doc_type,
|
||||
customer_id=doc.customer_id,
|
||||
document_date=doc.document_date,
|
||||
items=json.dumps([item.model_dump() for item in doc.items]),
|
||||
subtotal=doc.subtotal,
|
||||
tax=doc.tax,
|
||||
total=doc.total,
|
||||
status=doc.status,
|
||||
billing_date=doc.payment_terms.billing_date,
|
||||
payment_due_date=doc.payment_terms.payment_due_date,
|
||||
payment_method=doc.payment_terms.payment_method,
|
||||
notes=doc.notes,
|
||||
synced=False
|
||||
)
|
||||
|
||||
db.add(db_doc)
|
||||
db.commit()
|
||||
db.refresh(db_doc)
|
||||
|
||||
# Odoo に同期
|
||||
sync_result = sync_to_odoo(db, db_doc)
|
||||
|
||||
synced_count += 1
|
||||
new_documents.append({
|
||||
"local_id": db_doc.id,
|
||||
"odoo_id": db_doc.odoo_id,
|
||||
"doc_type": db_doc.doc_type,
|
||||
"status": sync_result["status"]
|
||||
})
|
||||
|
||||
# ログ記録
|
||||
sync_log = SyncLog(
|
||||
device_id=request.device_id,
|
||||
operation="sync",
|
||||
document_count=synced_count,
|
||||
status="success",
|
||||
message=f"Synced {synced_count} documents"
|
||||
)
|
||||
db.add(sync_log)
|
||||
db.commit()
|
||||
|
||||
return SyncResponse(
|
||||
status="success",
|
||||
message=f"Successfully synced {synced_count} documents",
|
||||
synced_documents=synced_count,
|
||||
new_documents=new_documents
|
||||
)
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Sync error: {str(e)}")
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@app.get("/api/v1/customers", dependencies=[Depends(verify_api_key)])
|
||||
async def get_customers(db: Session = Depends(get_db)):
|
||||
"""
|
||||
顧客一覧取得（オンライン時にマスタ更新）
|
||||
"""
|
||||
try:
|
||||
customers = db.query(Customer).all()
|
||||
return {
|
||||
"status": "success",
|
||||
"customers": [
|
||||
{
|
||||
"id": c.id,
|
||||
"name": c.name,
|
||||
"address": c.address,
|
||||
"phone": c.phone,
|
||||
"email": c.email
|
||||
} for c in customers
|
||||
]
|
||||
}
|
||||
except Exception as e:
|
||||
logger.error(f"Error fetching customers: {str(e)}")
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@app.get("/api/v1/documents/{doc_id}", dependencies=[Depends(verify_api_key)])
|
||||
async def get_document(doc_id: int, db: Session = Depends(get_db)):
|
||||
"""
|
||||
特定ドキュメント取得
|
||||
"""
|
||||
try:
|
||||
doc = db.query(Document).filter(Document.id == doc_id).first()
|
||||
if not doc:
|
||||
raise HTTPException(status_code=404, detail="Document not found")
|
||||
|
||||
return {
|
||||
"status": "success",
|
||||
"document": {
|
||||
"id": doc.id,
|
||||
"doc_type": doc.doc_type,
|
||||
"customer_id": doc.customer_id,
|
||||
"document_date": doc.document_date,
|
||||
"items": json.loads(doc.items) if doc.items else [],
|
||||
"total": float(doc.total),
|
||||
"payment_due_date": doc.payment_due_date,
|
||||
"status": doc.status
|
||||
}
|
||||
}
|
||||
except HTTPException:
|
||||
raise
|
||||
except Exception as e:
|
||||
logger.error(f"Error fetching document: {str(e)}")
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@app.post("/api/v1/receipts/{invoice_id}", dependencies=[Depends(verify_api_key)])
|
||||
async def create_receipt(invoice_id: int, db: Session = Depends(get_db)):
|
||||
"""
|
||||
請求書から領収書を自動生成
|
||||
入金1週間以内の場合に発行可能
|
||||
"""
|
||||
try:
|
||||
invoice = db.query(Document).filter(
|
||||
Document.id == invoice_id,
|
||||
Document.doc_type == "invoice"
|
||||
).first()
|
||||
|
||||
if not invoice:
|
||||
raise HTTPException(status_code=404, detail="Invoice not found")
|
||||
|
||||
if not invoice.paid_date:
|
||||
raise HTTPException(status_code=400, detail="Invoice not yet paid")
|
||||
|
||||
# 入金1週間以内かチェック
|
||||
days_since_payment = (datetime.utcnow() - invoice.paid_date).days
|
||||
if days_since_payment > 7:
|
||||
raise HTTPException(status_code=400, detail="Receipt cannot be issued (payment older than 7 days)")
|
||||
|
||||
# 領収書作成
|
||||
receipt = Document(
|
||||
doc_type="receipt",
|
||||
customer_id=invoice.customer_id,
|
||||
document_date=datetime.utcnow(),
|
||||
items=invoice.items,
|
||||
subtotal=invoice.subtotal,
|
||||
tax=invoice.tax,
|
||||
total=invoice.total,
|
||||
status="issued",
|
||||
paid_date=invoice.paid_date,
|
||||
synced=False
|
||||
)
|
||||
|
||||
db.add(receipt)
|
||||
db.commit()
|
||||
db.refresh(receipt)
|
||||
|
||||
return {
|
||||
"status": "success",
|
||||
"receipt_id": receipt.id,
|
||||
"message": "Receipt created successfully"
|
||||
}
|
||||
|
||||
except HTTPException:
|
||||
raise
|
||||
except Exception as e:
|
||||
logger.error(f"Error creating receipt: {str(e)}")
|
||||
raise HTTPException(status_code=500, detail=str(e))
|
||||
|
||||
@app.get("/api/v1/health", dependencies=[Depends(verify_api_key)])
|
||||
async def health_check():
|
||||
"""
|
||||
ヘルスチェック
|
||||
"""
|
||||
return {"status": "ok", "timestamp": datetime.utcnow()}
|
||||
|
||||
# ========== DB初期化 ==========
|
||||
@app.on_event("startup")
|
||||
async def startup():
|
||||
Base.metadata.create_all(bind=engine)
|
||||
logger.info("Database tables created")
|
||||
|
||||
if __name__ == "__main__":
|
||||
import uvicorn
|
||||
uvicorn.run(app, host="0.0.0.0", port=8000)
|
||||
96
claude/docker-compose.yml
Normal file
96
claude/docker-compose.yml
Normal file
|
|
@ -0,0 +1,96 @@
|
|||
version: '3.8'
|
||||
|
||||
services:
|
||||
# PostgreSQL（Odoo用）
|
||||
postgres:
|
||||
image: postgres:15-alpine
|
||||
container_name: odoo_db
|
||||
environment:
|
||||
POSTGRES_DB: odoo
|
||||
POSTGRES_USER: odoo
|
||||
POSTGRES_PASSWORD: odoo_secure_password
|
||||
volumes:
|
||||
- postgres_data:/var/lib/postgresql/data
|
||||
ports:
|
||||
- "5432:5432"
|
||||
networks:
|
||||
- odoo_network
|
||||
restart: unless-stopped
|
||||
|
||||
# Odoo
|
||||
odoo:
|
||||
image: odoo:17.0
|
||||
container_name: odoo_app
|
||||
depends_on:
|
||||
- postgres
|
||||
environment:
|
||||
HOST: postgres
|
||||
USER: odoo
|
||||
PASSWORD: odoo_secure_password
|
||||
DB_NAME: odoo
|
||||
volumes:
|
||||
- odoo_data:/var/lib/odoo
|
||||
- ./addons:/mnt/extra-addons
|
||||
ports:
|
||||
- "8069:8069"
|
||||
networks:
|
||||
- odoo_network
|
||||
restart: unless-stopped
|
||||
|
||||
# REST API（モバイル同期用）
|
||||
api:
|
||||
build:
|
||||
context: ./api
|
||||
dockerfile: Dockerfile
|
||||
container_name: mobile_sync_api
|
||||
depends_on:
|
||||
- postgres
|
||||
- odoo
|
||||
environment:
|
||||
DATABASE_URL: postgresql://odoo:odoo_secure_password@postgres:5432/odoo
|
||||
ODOO_URL: http://odoo:8069
|
||||
ODOO_USER: admin
|
||||
ODOO_PASSWORD: admin
|
||||
API_SECRET_KEY: your_secret_key_here_change_me
|
||||
ports:
|
||||
- "8000:8000"
|
||||
volumes:
|
||||
- ./api:/app
|
||||
networks:
|
||||
- odoo_network
|
||||
command: uvicorn main:app --host 0.0.0.0 --port 8000 --reload
|
||||
restart: unless-stopped
|
||||
|
||||
# 同期・バックアップスクリプト（定期実行）
|
||||
sync_scheduler:
|
||||
build:
|
||||
context: ./scheduler
|
||||
dockerfile: Dockerfile
|
||||
container_name: sync_scheduler
|
||||
depends_on:
|
||||
- postgres
|
||||
- odoo
|
||||
- api
|
||||
environment:
|
||||
DATABASE_URL: postgresql://odoo:odoo_secure_password@postgres:5432/odoo
|
||||
ODOO_URL: http://odoo:8069
|
||||
ODOO_USER: admin
|
||||
ODOO_PASSWORD: admin
|
||||
NEXTCLOUD_URL: https://your_nextcloud_url
|
||||
NEXTCLOUD_USER: your_nextcloud_user
|
||||
NEXTCLOUD_PASSWORD: your_nextcloud_password
|
||||
volumes:
|
||||
- ./scheduler:/app
|
||||
- sync_logs:/var/log/sync
|
||||
networks:
|
||||
- odoo_network
|
||||
restart: unless-stopped
|
||||
|
||||
volumes:
|
||||
postgres_data:
|
||||
odoo_data:
|
||||
sync_logs:
|
||||
|
||||
networks:
|
||||
odoo_network:
|
||||
driver: bridge
|
||||
334
claude/odoo_sync.py
Normal file
334
claude/odoo_sync.py
Normal file
|
|
@ -0,0 +1,334 @@
|
|||
# api/odoo_sync.py
|
||||
"""
|
||||
Odoo連携モジュール
|
||||
REST API が受け取ったドキュメントを Odoo に同期
|
||||
"""
|
||||
|
||||
import requests
|
||||
import logging
|
||||
from typing import Dict, List, Optional
|
||||
from datetime import datetime
|
||||
import json
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
class OdooClient:
|
||||
"""Odoo XML-RPC クライアント"""
|
||||
|
||||
def __init__(self, odoo_url: str, db: str, username: str, password: str):
|
||||
self.odoo_url = odoo_url
|
||||
self.db = db
|
||||
self.username = username
|
||||
self.password = password
|
||||
self.uid = None
|
||||
self.authenticate()
|
||||
|
||||
def authenticate(self):
|
||||
"""Odoo 認証"""
|
||||
try:
|
||||
import xmlrpc.client
|
||||
common = xmlrpc.client.ServerProxy(f'{self.odoo_url}/xmlrpc/2/common')
|
||||
self.uid = common.authenticate(self.db, self.username, self.password, {})
|
||||
logger.info(f"Odoo authenticated: uid={self.uid}")
|
||||
except Exception as e:
|
||||
logger.error(f"Odoo authentication failed: {str(e)}")
|
||||
raise
|
||||
|
||||
def create_customer(self, name: str, address: str = "", phone: str = "", email: str = "") -> int:
|
||||
"""顧客を Odoo に作成"""
|
||||
try:
|
||||
import xmlrpc.client
|
||||
models = xmlrpc.client.ServerProxy(f'{self.odoo_url}/xmlrpc/2/object')
|
||||
|
||||
partner_data = {
|
||||
'name': name,
|
||||
'street': address,
|
||||
'phone': phone,
|
||||
'email': email,
|
||||
'customer_rank': 1,
|
||||
}
|
||||
|
||||
partner_id = models.execute_kw(
|
||||
self.db, self.uid, self.password,
|
||||
'res.partner', 'create', [partner_data]
|
||||
)
|
||||
|
||||
logger.info(f"Created Odoo customer: {partner_id}")
|
||||
return partner_id
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Error creating customer: {str(e)}")
|
||||
return 0
|
||||
|
||||
def create_quotation(self, customer_id: int, items: List[Dict],
|
||||
payment_due_date: str, notes: str = "") -> int:
|
||||
"""見積を Odoo に作成"""
|
||||
try:
|
||||
import xmlrpc.client
|
||||
models = xmlrpc.client.ServerProxy(f'{self.odoo_url}/xmlrpc/2/object')
|
||||
|
||||
# 見積ラインの準備
|
||||
order_lines = []
|
||||
for item in items:
|
||||
# 商品をOdooから検索（簡略版）
|
||||
product_search = models.execute_kw(
|
||||
self.db, self.uid, self.password,
|
||||
'product.product', 'search',
|
||||
[[('name', '=', item['product_name'])]]
|
||||
)
|
||||
|
||||
product_id = product_search[0] if product_search else 1
|
||||
|
||||
line_data = (0, 0, {
|
||||
'product_id': product_id,
|
||||
'product_qty': item['quantity'],
|
||||
'price_unit': item['unit_price'],
|
||||
})
|
||||
order_lines.append(line_data)
|
||||
|
||||
# 見積作成
|
||||
quotation_data = {
|
||||
'partner_id': customer_id,
|
||||
'order_line': order_lines,
|
||||
'date_order': datetime.now().isoformat(),
|
||||
'payment_term_id': self._get_payment_term_id(payment_due_date),
|
||||
'note': notes,
|
||||
}
|
||||
|
||||
quotation_id = models.execute_kw(
|
||||
self.db, self.uid, self.password,
|
||||
'sale.order', 'create', [quotation_data]
|
||||
)
|
||||
|
||||
logger.info(f"Created Odoo quotation: {quotation_id}")
|
||||
return quotation_id
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Error creating quotation: {str(e)}")
|
||||
return 0
|
||||
|
||||
def create_invoice(self, customer_id: int, items: List[Dict],
|
||||
payment_due_date: str, notes: str = "") -> int:
|
||||
"""請求書を Odoo に作成"""
|
||||
try:
|
||||
import xmlrpc.client
|
||||
models = xmlrpc.client.ServerProxy(f'{self.odoo_url}/xmlrpc/2/object')
|
||||
|
||||
invoice_lines = []
|
||||
for item in items:
|
||||
product_search = models.execute_kw(
|
||||
self.db, self.uid, self.password,
|
||||
'product.product', 'search',
|
||||
[[('name', '=', item['product_name'])]]
|
||||
)
|
||||
|
||||
product_id = product_search[0] if product_search else 1
|
||||
|
||||
line_data = (0, 0, {
|
||||
'product_id': product_id,
|
||||
'quantity': item['quantity'],
|
||||
'price_unit': item['unit_price'],
|
||||
})
|
||||
invoice_lines.append(line_data)
|
||||
|
||||
invoice_data = {
|
||||
'partner_id': customer_id,
|
||||
'invoice_line_ids': invoice_lines,
|
||||
'invoice_date': datetime.now().date().isoformat(),
|
||||
'invoice_date_due': payment_due_date,
|
||||
'note': notes,
|
||||
}
|
||||
|
||||
invoice_id = models.execute_kw(
|
||||
self.db, self.uid, self.password,
|
||||
'account.move', 'create', [invoice_data]
|
||||
)
|
||||
|
||||
logger.info(f"Created Odoo invoice: {invoice_id}")
|
||||
return invoice_id
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Error creating invoice: {str(e)}")
|
||||
return 0
|
||||
|
||||
def record_payment(self, invoice_id: int, amount: float, payment_date: str) -> int:
|
||||
"""支払いを記録"""
|
||||
try:
|
||||
import xmlrpc.client
|
||||
models = xmlrpc.client.ServerProxy(f'{self.odoo_url}/xmlrpc/2/object')
|
||||
|
||||
payment_data = {
|
||||
'move_id': invoice_id,
|
||||
'amount': amount,
|
||||
'payment_date': payment_date,
|
||||
}
|
||||
|
||||
payment_id = models.execute_kw(
|
||||
self.db, self.uid, self.password,
|
||||
'account.payment', 'create', [payment_data]
|
||||
)
|
||||
|
||||
logger.info(f"Recorded payment: {payment_id}")
|
||||
return payment_id
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Error recording payment: {str(e)}")
|
||||
return 0
|
||||
|
||||
def get_customer_by_email(self, email: str) -> Optional[int]:
|
||||
"""メールアドレスで顧客を検索"""
|
||||
try:
|
||||
import xmlrpc.client
|
||||
models = xmlrpc.client.ServerProxy(f'{self.odoo_url}/xmlrpc/2/object')
|
||||
|
||||
result = models.execute_kw(
|
||||
self.db, self.uid, self.password,
|
||||
'res.partner', 'search',
|
||||
[[('email', '=', email)]]
|
||||
)
|
||||
|
||||
return result[0] if result else None
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Error searching customer: {str(e)}")
|
||||
return None
|
||||
|
||||
def _get_payment_term_id(self, due_date: str) -> int:
|
||||
"""支払い条件を Odoo から取得"""
|
||||
try:
|
||||
import xmlrpc.client
|
||||
models = xmlrpc.client.ServerProxy(f'{self.odoo_url}/xmlrpc/2/object')
|
||||
|
||||
# 簡略版：「30日」の支払い条件 ID を取得
|
||||
result = models.execute_kw(
|
||||
self.db, self.uid, self.password,
|
||||
'account.payment.term', 'search',
|
||||
[[('name', 'like', '30')]]
|
||||
)
|
||||
|
||||
return result[0] if result else 1
|
||||
|
||||
except Exception as e:
|
||||
logger.warning(f"Could not get payment term: {str(e)}")
|
||||
return 1
|
||||
|
||||
|
||||
class SyncService:
|
||||
"""REST API と Odoo の同期サービス"""
|
||||
|
||||
def __init__(self, odoo_client: OdooClient):
|
||||
self.odoo = odoo_client
|
||||
|
||||
def sync_document(self, db_session, document_entity) -> Dict:
|
||||
"""ドキュメントを Odoo に同期"""
|
||||
|
||||
# 顧客情報を取得
|
||||
customer = db_session.query(Customer).filter(
|
||||
Customer.id == document_entity.customer_id
|
||||
).first()
|
||||
|
||||
if not customer:
|
||||
return {"status": "error", "message": "Customer not found"}
|
||||
|
||||
# Odoo 顧客 ID を確認・作成
|
||||
odoo_customer_id = customer.odoo_customer_id
|
||||
if not odoo_customer_id:
|
||||
odoo_customer_id = self.odoo.create_customer(
|
||||
name=customer.name,
|
||||
address=customer.address or "",
|
||||
phone=customer.phone or "",
|
||||
email=customer.email or ""
|
||||
)
|
||||
customer.odoo_customer_id = odoo_customer_id
|
||||
db_session.commit()
|
||||
|
||||
if not odoo_customer_id:
|
||||
return {"status": "error", "message": "Could not create/find Odoo customer"}
|
||||
|
||||
# ドキュメントタイプ別処理
|
||||
items = json.loads(document_entity.items)
|
||||
|
||||
try:
|
||||
if document_entity.doc_type == "quotation":
|
||||
odoo_id = self.odoo.create_quotation(
|
||||
customer_id=odoo_customer_id,
|
||||
items=items,
|
||||
payment_due_date=self._format_date(document_entity.payment_due_date),
|
||||
notes=document_entity.notes or ""
|
||||
)
|
||||
|
||||
elif document_entity.doc_type == "invoice":
|
||||
odoo_id = self.odoo.create_invoice(
|
||||
customer_id=odoo_customer_id,
|
||||
items=items,
|
||||
payment_due_date=self._format_date(document_entity.payment_due_date),
|
||||
notes=document_entity.notes or ""
|
||||
)
|
||||
|
||||
else:
|
||||
odoo_id = 0
|
||||
|
||||
if odoo_id:
|
||||
document_entity.odoo_id = odoo_id
|
||||
return {"status": "success", "odoo_id": odoo_id}
|
||||
else:
|
||||
return {"status": "error", "message": "Failed to create Odoo document"}
|
||||
|
||||
except Exception as e:
|
||||
logger.error(f"Sync error: {str(e)}")
|
||||
return {"status": "error", "message": str(e)}
|
||||
|
||||
@staticmethod
|
||||
def _format_date(timestamp: int) -> str:
|
||||
"""タイムスタンプを ISO 形式に変換"""
|
||||
from datetime import datetime
|
||||
return datetime.fromtimestamp(timestamp / 1000).isoformat()
|
||||
|
||||
|
||||
# FastAPI メインに統合される部分
|
||||
|
||||
from fastapi import FastAPI, Depends
|
||||
from sqlalchemy.orm import Session
|
||||
|
||||
app = FastAPI()
|
||||
|
||||
# グローバル Odoo クライアント
|
||||
odoo_client = OdooClient(
|
||||
odoo_url=os.getenv("ODOO_URL", "http://localhost:8069"),
|
||||
db="odoo",
|
||||
username=os.getenv("ODOO_USER", "admin"),
|
||||
password=os.getenv("ODOO_PASSWORD", "admin")
|
||||
)
|
||||
|
||||
sync_service = SyncService(odoo_client)
|
||||
|
||||
@app.post("/api/v1/sync")
|
||||
async def sync_documents(request: SyncRequest, db: Session = Depends(get_db)):
|
||||
"""ドキュメント同期エンドポイント"""
|
||||
|
||||
synced_count = 0
|
||||
new_documents = []
|
||||
|
||||
for doc in request.documents:
|
||||
# ドキュメント作成（DB）
|
||||
db_doc = Document(...)
|
||||
db.add(db_doc)
|
||||
db.commit()
|
||||
|
||||
# Odoo に同期
|
||||
result = sync_service.sync_document(db, db_doc)
|
||||
|
||||
if result["status"] == "success":
|
||||
synced_count += 1
|
||||
new_documents.append({
|
||||
"local_id": db_doc.id,
|
||||
"odoo_id": result.get("odoo_id"),
|
||||
"doc_type": db_doc.doc_type
|
||||
})
|
||||
|
||||
return SyncResponse(
|
||||
status="success",
|
||||
message=f"Synced {synced_count} documents",
|
||||
synced_documents=synced_count,
|
||||
new_documents=new_documents
|
||||
)
|
||||
8
claude/requirements_api.txt
Normal file
8
claude/requirements_api.txt
Normal file
|
|
@ -0,0 +1,8 @@
|
|||
fastapi==0.104.1
|
||||
uvicorn==0.24.0
|
||||
pydantic==2.5.0
|
||||
sqlalchemy==2.0.23
|
||||
psycopg2-binary==2.9.9
|
||||
python-dateutil==2.8.2
|
||||
requests==2.31.0
|
||||
python-multipart==0.0.6
|
||||
Loading…
Reference in a new issue