新增sku侵权状态抓取

AutoTurnOver.DB/api_dao.cs

 using AutoTurnOver.DB.Base;
 using AutoTurnOver.Models;
+using AutoTurnOver.Models.ApiDto;
 using AutoTurnOver.Models.Base;
 using Dapper;
 using System;
@@ -82,5 +83,37 @@ namespace AutoTurnOver.DB
             }
             return _connection.Page<api_sku_sales_volume_dto>(sql, search, parameters);
         }
+
+        /// <summary>
+        /// 获取sku 的侵权状态
+        /// </summary>
+        /// <param name="search"></param>
+        /// <returns></returns>
+        public static Page<api_sku_tort_dto> GetSkuTort(api_sku_tort_search_dto search)
+        {
+            search.page = search.page <= 0 ? 1 : search.page;
+            search.rows = search.rows <= 0 ? 100 : search.rows;
+            var sql = @" select t1.bailun_sku,t1.gmt_modified,(case when t8.id is null then '未侵权' else  '侵权' end) as 'tort_status' from dc_base_sku as t1 left join dc_base_tort as t8  on t1.bailun_sku = t8.bailun_sku where 1=1";
+            DynamicParameters parameters = new DynamicParameters();
+            if (search != null)
+            {
+                if (!string.IsNullOrWhiteSpace( search.bailun_sku))
+                {
+                    sql += " and t1.bailun_sku = @bailun_sku ";
+                    parameters.Add("bailun_sku", search.bailun_sku);
+                }
+                if (search.btime != null)
+                {
+                    sql += " and t1.gmt_modified >= @btime ";
+                    parameters.Add("btime", search.btime);
+                }
+                if (search.etime != null)
+                {
+                    sql += " and t1.gmt_modified <= @etime ";
+                    parameters.Add("etime", search.etime);
+                }
+            }
+            return _connection.Page<api_sku_tort_dto>(sql, search, parameters);
+        }
     }
 }

AutoTurnOver.DB/db_config.cs

@@ -699,16 +699,17 @@ left join dc_base_warehouse as dbw on dacp.warehouse_code = dbw.warehouse_code w
 
         public static string BatchTortStatus(string ids, int tort_status, UserData user)
         {
-
+            var conn = _connection;
+            conn.Open();
             if (tort_status != 1 && tort_status != 0)
             {
                 throw new Exception("状态异常");
             }
-            var datas = _connection.Query<AutoTurnOver.Models.dc_auto_turnover>(" select * from dc_auto_turnover where id in @ids ", new { ids = ids.Split(',') }).AsList();
+            var datas = conn.Query<AutoTurnOver.Models.dc_auto_turnover>(" select * from dc_auto_turnover where id in @ids ", new { ids = ids.Split(',') }).AsList();
             foreach (AutoTurnOver.Models.dc_auto_turnover turnover_item in datas)
             {
                 // 先检查当前状态
-                var oldData = _connection.QueryFirstOrDefault<dc_base_tort>($"select * from dc_base_tort where bailun_sku=@bailun_sku ", new { turnover_item.bailun_sku });
+                var oldData = conn.QueryFirstOrDefault<dc_base_tort>($"select * from dc_base_tort where bailun_sku=@bailun_sku ", new { turnover_item.bailun_sku });
                 if (oldData == null)
                 {
                     if (tort_status == 0)
@@ -737,13 +738,13 @@ left join dc_base_warehouse as dbw on dacp.warehouse_code = dbw.warehouse_code w
                         gmt_create = now,
                         create_user_name = user.UserName
                     };
-                    _connection.Insert<dc_base_tort>(newData);
+                    conn.Insert<dc_base_tort>(newData);
                 }
                 else
                 {
                     if (tort_status == 0)
                     {
-                        _connection.Execute(" delete from  dc_base_tort  where id=@id", new { id = oldData.id });
+                        conn.Execute(" delete from  dc_base_tort  where id=@id", new { id = oldData.id });
                     }
                     else
                     {
@@ -751,6 +752,8 @@ left join dc_base_warehouse as dbw on dacp.warehouse_code = dbw.warehouse_code w
                     }
 
                 }
+
+                _connection.Execute("update dc_base_sku set  gmt_modified=now() where bailun_sku = bailun_sku ",new { bailun_sku = turnover_item.bailun_sku });
             }
 
             return "";

AutoTurnOver.Models/ApiDto/api_sku_tort_dto.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace AutoTurnOver.Models.ApiDto
+{
+    public class api_sku_tort_dto
+    {
+        public string bailun_sku { get; set; }
+        public string tort_status { get; set; }
+        public DateTime gmt_modified { get; set; }
+    }
+}

AutoTurnOver.Models/api_sku_sales_volume_dto.cs

@@ -22,4 +22,11 @@ namespace AutoTurnOver.Models
     {
         public List<string> bailun_sku_list { get; set; }
     }
+
+    public class api_sku_tort_search_dto : page_search_dto
+    {
+        public string bailun_sku { get; set; }
+        public DateTime? btime { get; set; }
+        public DateTime? etime { get; set; }
+    }
 }

AutoTurnOver.Services/ApiServices.cs

@@ -742,5 +742,10 @@ namespace AutoTurnOver.Services
         {
             return api_dao.GetSkuSalesVolume(search);
         }
+        
+        public static Page<api_sku_tort_dto> GetSkuTort(api_sku_tort_search_dto search)
+        {
+            return api_dao.GetSkuTort(search);
+        }
     }
 }

AutoTurnOver/Controllers/ApiController.cs

@@ -25,6 +25,12 @@ namespace AutoTurnOver.Controllers
         public ActionResult<RequestResultDto> GetSkuSalesVolume([FromBody] api_sku_sales_volume_search_dto search)
         {
             return new RequestResultDto { success = true, data = ApiServices.GetSkuSalesVolume(search) };
+        } 
+        
+        [HttpPost("GetSkuTort")]
+        public ActionResult<RequestResultDto> GetSkuTort([FromBody] api_sku_tort_search_dto search)
+        {
+            return new RequestResultDto { success = true, data = ApiServices.GetSkuTort(search) };
         }
 
         /// <summary>