package common.crm;

import com.alibaba.fastjson.JSONObject;
import common.BaseClass;
import common.YosException;
import common.YosLogger;
import common.crm.bean.item;
import common.crm.bean.sku;
import common.crm.bean.warrantycard;
import common.data.QuerySQL;
import common.data.Row;
import common.data.SQLFactory;
import common.data.db.QueryCallBack;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/rest/pull")
public class crm_pull extends BaseClass {

    @GetMapping("/pullMachinecodes")
    @ResponseBody
    public String pullMachinecodes(HttpServletRequest request, HttpServletResponse response, @RequestParam("fmachinecodes") String[] fmachinecodes, @RequestParam("token") String token) {
        runTask("CRM请求同步序列号", () -> {
            sku sku = new sku(YosLogger.logger);
            for (String fmachinecode : fmachinecodes) {
                if (!fmachinecode.isEmpty()) {
                    sku.oneAction(fmachinecode);
                }
            }
        });
        return getSuccessResult().toString();
    }

    @GetMapping("/pullAnyProducts")
    @ResponseBody
    public String pullAnyProducts(HttpServletRequest request, HttpServletResponse response, @RequestParam("fprodNums") String[] fprodNums, @RequestParam("isAllFields") String isAllFields, @RequestParam("token") String token) {
        runTask("CRM请求同步商品档案", () -> {
            item item = new item(YosLogger.logger);
            for (String fprodNum : fprodNums) {
                if (!fprodNum.isEmpty()) {
                    item.oneAction(fprodNum, isAllFields.equals("true"));
                }
            }
        });
        return getSuccessResult().toString();
    }

    @GetMapping("/pullWarrantycards")
    @ResponseBody
    public String pullWarrantycards(HttpServletRequest request, HttpServletResponse response, @RequestParam("fcustomnum") String fcustomnum, @RequestParam("fmachinecodes") String[] fmachinecodes, @RequestParam("token") String token) {
        runTask("CRM请求同步客户保修卡", () -> {
            try {
                warrantycard warrantycard = new warrantycard(YosLogger.logger);
                QuerySQL querySQL = SQLFactory.createQuerySQL(dbConnect, "sa_warrantycard", "cardno");
                querySQL.setSiteid("MD").setWhere("sku", fmachinecodes);
                querySQL.query(new QueryCallBack() {
                    @Override
                    public void onRowLoaded(long rowindex, Row row) throws YosException {
                        warrantycard.oneAction(row.getString("cardno"));
                    }
                });
            } catch (Exception e) {
                e.printStackTrace();
            }

        });
        return getSuccessResult().toString();
    }


    public JSONObject getSuccessResult() {
        JSONObject object = new JSONObject();
        object.put("code", 1);
        object.put("msg", "");
        object.put("data", "");
        object.put("uri", "");
        return object;
    }
}