package com.szwl.controller; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.szwl.model.entity.TEquipment; import com.szwl.model.entity.TSugarDo; import com.szwl.service.TAdminService; import com.szwl.service.TEquipmentService; import com.szwl.service.TProductService; import com.szwl.service.TSugarDoService; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.ResponseBody; import javax.annotation.Resource; import java.util.ArrayList; import java.util.List; import java.util.Random; @Controller("apiSugarDoController") @RequestMapping("/api/SugarDo") public class SugarDoOrderController { @Autowired private TSugarDoService sugarDoService; @Autowired TEquipmentService equipmentService; //远程做糖状态回返 @RequestMapping(value = "/updateSugarDoStatus.htm", method = RequestMethod.GET, produces = "text/html;charset=utf-8") @ResponseBody public String updateSugarDoStatus(String clientId, String status, String no, String note) { if(!StringUtils.isEmpty(no)&&!StringUtils.isEmpty(status)){ LambdaQueryWrapper query = Wrappers.lambdaQuery(); query.eq(TSugarDo::getNo,no); query.eq(TSugarDo::getClientId,clientId); List list = sugarDoService.list(query); TSugarDo sugarDo = list.get(0); if(sugarDo.getClientId().equals(clientId)){ sugarDo.setStatus(status); if(status.equals("2")){ sugarDo.setNote(note); } sugarDoService.updateById(sugarDo); }else { return "error"; } }else { return "error"; } return "success"; } /** * 远程做糖 */ // @RequestMapping(value = "/doSugar", method = RequestMethod.GET, produces = "application/json;charset=UTF-8") // @ResponseBody // public Object getProductions(String adminId,String clientId,String productName) { //// productName = "夏日倾城"; // JSONObject jsonObject = new JSONObject(); // if(StringUtils.isEmpty(adminId)){ // jsonObject.put("code", 1); // jsonObject.put("errmsg", "adminId为空"); // return jsonObject; // } // if(StringUtils.isEmpty(clientId)){ // jsonObject.put("code", 1); // jsonObject.put("errmsg", "clientId为空"); // return jsonObject; // } // Admin admin = adminService.find(Long.valueOf(adminId)); // Equipment equipment = equipmentService.findByClientId(clientId); // if(!equipment.getAdminId().toString().equals(admin.getId().toString())){ // jsonObject.put("code", 1); // jsonObject.put("errmsg", "clientId与adminId不匹配"); // return jsonObject; // } // int j =0; // ArrayList filters = new ArrayList<>(); // filters.add(Filter.eq("equipmentId", equipment.getId())); // List products = productService.findList(null, filters, null); // for (Product product:products){ // if(product.getProductName().equals(productName)){ // j++; // } // } // if(j==0){ // jsonObject.put("code", 1); // jsonObject.put("errmsg", "商品未找到"); // return jsonObject; // } // StringBuilder number = new StringBuilder(); // Random random = new Random(); // number.append(String.valueOf(adminId)).append("-"); // for (int i = 0; i < 6; i++) { // number.append(String.valueOf(random.nextInt(10))); // } // JSONObject kindData = new JSONObject(); // kindData.put("productName" , productName); // kindData.put("no" , number.toString()); // equipmentService.sentMessage(equipment.getClientId(), PushUtils.buildJson("dosugar", kindData.toString()).toString()); // // jsonObject.put("code", 0); // jsonObject.put("errmsg", "发送成功!"); // return jsonObject; // } }