库存预警 登录

xingyun-api/pom.xml

@@ -41,6 +41,14 @@
             <groupId>com.lframework</groupId>
             <artifactId>xingyun-template</artifactId>
         </dependency>
+
+
+<!--        <dependency>-->
+<!--            <groupId>com.google.code.gson</groupId>-->
+<!--            <artifactId>gson</artifactId>-->
+<!--            <version>2.8.6</version> &lt;!&ndash; 请使用最新的版本号 &ndash;&gt;-->
+<!--        </dependency>-->
+
     </dependencies>
 
     <build>

xingyun-sc/src/main/java/com/lframework/xingyun/sc/controller/stock/ProductStockController.java

@@ -7,6 +7,7 @@ import com.lframework.starter.web.controller.DefaultBaseController;
 import com.lframework.starter.web.resp.InvokeResult;
 import com.lframework.starter.web.resp.InvokeResultBuilder;
 import com.lframework.starter.web.resp.PageResult;
+import com.lframework.starter.web.service.SysParameterService;
 import com.lframework.starter.web.utils.ExcelUtil;
 import com.lframework.starter.web.utils.PageResultUtil;
 import com.lframework.xingyun.sc.bo.stock.product.QueryProductStockBo;
@@ -19,6 +20,9 @@ import io.swagger.annotations.ApiOperation;
 import java.util.List;
 import java.util.stream.Collectors;
 import javax.validation.Valid;
+
+import org.codehaus.groovy.tools.StringHelper;
+import org.hamcrest.text.IsEmptyString;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -38,6 +42,37 @@ public class ProductStockController extends DefaultBaseController {
 
   @Autowired
   private ProductStockService productStockService;
+  @Autowired
+  private SysParameterService sysParameterService;
+
+  /**
+   * 查询商品库存
+   */
+  @ApiOperation("查询库存yujing ")
+  @HasPermission({"stock:product:query"})
+  @GetMapping("/warn")
+  public InvokeResult<PageResult<QueryProductStockBo>> warn(@Valid QueryProductStockVo vo) {
+    String value= sysParameterService.findByKey("kcinfo") ;
+    try {
+      vo.setProductCount(Long.parseLong(value));
+    } catch(Exception e)  {
+      vo.setProductCount(10L) ;
+    }
+
+    PageResult<ProductStock> pageResult = productStockService.query(getPageIndex(vo),
+            getPageSize(vo), vo);
+    List<QueryProductStockBo> results = null;
+
+    List<ProductStock> datas = pageResult.getDatas();
+    if (!CollectionUtil.isEmpty(datas)) {
+      results = datas.stream().map(QueryProductStockBo::new).collect(Collectors.toList());
+    }
+
+    return InvokeResultBuilder.success(PageResultUtil.rebuild(pageResult, results));
+  }
+
+
+
 
   /**
    * 查询商品库存

xingyun-sc/src/main/java/com/lframework/xingyun/sc/vo/stock/QueryProductStockVo.java

@@ -36,4 +36,11 @@ public class QueryProductStockVo extends SortPageVo {
    */
   @ApiModelProperty("商品品牌ID")
   private String brandId;
+
+  /**
+   * 商品品牌ID
+   */
+  @ApiModelProperty("商品数量")
+  private Long productCount;
+  
 }

xingyun-sc/src/main/resources/mappers/stock/ProductStockMapper.xml

@@ -60,9 +60,15 @@
         LEFT JOIN recursion_mapping AS rm ON rm.node_id = g.category_id and rm.node_type = 2
         <where>
             <if test="vo != null">
+                <if test="vo.productCount != null and vo.productCount >0">
+                    AND gs.stock_num <![CDATA[<=]]>  #{vo.productCount}
+                </if>
+
                 <if test="vo.scId != null and vo.scId != ''">
                     AND gs.sc_id = #{vo.scId}
                 </if>
+
+
                 <if test="vo.productCode != null and vo.productCode != ''">
                     AND g.code = #{vo.productCode}
                 </if>

xingyun-template/src/main/java/com/lframework/xingyun/template/inner/controller/AuthController.java

@@ -572,4 +572,52 @@ public class AuthController extends DefaultBaseController {
 
     StpUtil.getSession().set(SecurityConstants.DATA_PERMISSION_SQL_VAR, dataPermissionVar);
   }
+
+
+  @ApiOperation("小程序登录")
+  @OpenApi
+  @PostMapping("/auth/loginwx")
+  public InvokeResult<LoginBo> loginwx(@Valid LoginVo vo) {
+
+    String username = vo.getUsername();
+    String password = vo.getPassword();
+    String tenantId = null;
+    if (TenantUtil.enableTenant()) {
+      String[] tmpArr = username.split("@");
+      if (tmpArr.length <= 1) {
+        throw new DefaultClientException("用户名或密码错误！");
+      }
+
+      tenantId = tmpArr[0];
+      username = tmpArr[1];
+
+      // 检查租户是否存在
+      Tenant tenant = tenantService.getById(tenantId);
+      if (tenant == null) {
+        throw new DefaultClientException("用户名或密码错误！");
+      }
+
+      if (!tenant.getAvailable()) {
+        throw new DefaultClientException("用户已停用，无法登录！");
+      }
+
+      TenantContextHolder.setTenantId(tenant.getId());
+    }
+
+    log.info("用户 {} {} 开始登录", tenantId, username);
+
+   // String sn = vo.getSn();
+    //String captcha = vo.getCaptcha();
+   //captchaValidator.validate(sn, captcha);
+
+    this.checkUserLogin(tenantId == null ? null : Integer.valueOf(tenantId), username, password);
+
+    AbstractUserDetails user = userDetailsService.loadUserByUsername(username);
+
+    LoginDto dto = this.doLogin(user);
+
+    this.addAttributesToSession(user);
+
+    return InvokeResultBuilder.success(new LoginBo(dto));
+  }
 }