/i!ddlmZddlmZddlmZddlZddlmZmZm Z m Z m Z ddl m Z ddlmZddlmZmZmZmZdd lmZeZej0eZej7d ee j8 eej:eej<fd ed e fdZejAd eeej:e ddde dddde ddde ddde dde dd e dd!e dd"e dd#e dd$e dd%d&e dd'd(e dd)e dd*eej<fd e d+e!d,e!d-e"d.e"d/ee"d0ee"d1ee"d2ee"d3ee"d4eed5ee"d6ee"d7eed8eefd9Z#ejAd:e$eej:eej<fd e fd;Z%ejAdeej<fd4ed e d+e!d,e!fd?Z&ejAd@eeej:eej<fdAed e fdBZ'ejQd@eeej:eej<fdAed ed e fdCZ)ejUd@e$eej:eej<fdAed e fdDZ+y)E)Optional)UUID)datetimeN) APIRouterDepends HTTPExceptionQuerystatus) AsyncSession)deps)ViolationCreateViolationUpdateViolationResponseViolationListResponse)ViolationService/)response_model status_code violation_indbcNKtj||d{}|S7w)a% Create a new violation record. (Admin only) **Request Body:** - `product_name`: Name of the product - `msp`: Manufacturer Suggested Price - `scraped_price`: Price found during scraping - `url`: URL where the violation was found - `violation_date`: Date of the violation - `vendor_id`: (Optional) Associated vendor ID - `barcode_number`: (Optional) Product barcode - `reference_id`: (Optional) Reference identifier - `source_type`: (Optional) 'registered' or 'discovered' (default: 'registered') N)rcreate_violation)rr current_user violations ?/var/www/html/marco-python-backend/app/api/routes/violations.pyrrs)('77LIII J %#%)rz Page number)ge description dzItems per page)rlerviolation_datez]^(violation_date|created_at|product_name|price_difference|percentage_difference|vendor_name)$zField to sort by)regexrdescz ^(asc|desc)$z=Sort order: asc (A-Z/oldest first) or desc (Z-A/newest first)zSearch by product name)rzDGlobal search across product name, vendor name, marketplace, and URLzSearch by vendor namezSearch by marketplacez Search by URLzFilter by vendor IDz^(registered|discovered)$zFilter by source typez^(open|notified)$z-Filter by violation status (open or notified)zFilter from this datezFilter until this datepagelimitsort_by sort_order product_namesearch vendor_name marketplaceurl vendor_id source_typeviolation_status date_fromdate_tocKtj|||||||||| | | | | |d{\}}t||||S7w)a Retrieve a list of all violations with pagination, sorting, and filtering. **Query Parameters:** - `page`: Page number (default: 1) - `limit`: Items per page (default: 10, max: 100) - `sort_by`: Sort field - violation_date, created_at, product_name, price_difference, percentage_difference, or vendor_name **Search Parameters (dynamic, partial match):** - `product_name`: Search by product name - `search`: Search by product name (alternative/legacy parameter) - `vendor_name`: Search by vendor name - `marketplace`: Search by marketplace (e.g., Amazon, eBay, Flipkart) - `url`: Search by URL **Filter Parameters:** - `vendor_id`: Filter by specific vendor ID - `source_type`: Filter by source (registered or discovered) - `violation_status`: Filter by status (open or notified) - `date_from`: Filter violations from this date (inclusive) - `date_to`: Filter violations until this date (inclusive) )r&r'r(r)r*r+r,r-r.r/r0r1r2r3Nitemstotalr&r')rget_violationsr)rr&r'r(r)r*r+r,r-r.r/r0r1r2r3r violationsr7s rr8r8-sir/== ! )J$ !zTQV WW%s(AAAz /statisticscLKtj|d{}|S7w)z Get statistics about violations including: - Total violation count - Count by source type (registered vs discovered) - Average price difference - Average percentage difference N)rget_statistics)rrstatss rget_violation_statisticsr={s%#11"5 5E L 6s $"$z/vendor/{vendor_id})r)rr"ctKtj||||d{\}}t||||S7w)z? Get all violations associated with a specific vendor. )r/r&r'Nr5)rget_violations_by_vendorr)r/rr&r'rr9r7s rget_vendor_violationsr@sD/GG id%J !zTQV WW s 868z/{violation_id} violation_idcNKtj||d{}|S7w)zH Retrieve a single violation by its ID with vendor information. N)rget_violation_by_id)rArrrs r get_violationrDs)'::2|LLI MrcPKtj|||d{}|S7w)z4 Update an existing violation. (Admin only) N)rupdate_violation)rArrrrs rrFrFs+'77L,WWI Xs &$&cRKtj||d{ddiS7w)z1 Delete a violation record. (Admin only) NmessagezViolation deleted successfully)rdelete_violation)rArrs rrIrIs/  + +B === 7 88>s '% '),typingruuidrrloggingfastapirrrr r sqlalchemy.ext.asyncior app.apir app.schemas.violationr rrrapp.services.violation_servicerrouter getLogger__name__loggerpostHTTP_201_CREATEDget_dbget_current_userrgetintstrr8dictr=r@rDputrFdeleterIrrbs0DD/ <    8 $S!2@W@WXt{{+../!Y.C 56t{{+aA=9raC5EFm& S #(:R"S!$4z{!&t9P!Q!&t9P!QtA %d8M N!& )+" ', !C' %*$h ?JX7JXZM$/t{{+../  0  !2GHt{{+aAraC(../ XXX X  XIX" .?@t{{+../   A  .?@t{{+../  !   A  6t{{+../ 9 9 97 9ra